1 /*
2 * Copyright (C) 2021 HiSilicon (Shanghai) Technologies CO., LIMITED.
3 *
4 * This program is free software; you can redistribute it and/or
5 * modify it under the terms of the GNU General Public License
6 * as published by the Free Software Foundation; either version 2
7 * of the License, or (at your option) any later version.
8 *
9 * This program is distributed in the hope that it will be useful,
10 * but WITHOUT ANY WARRANTY; without even the implied warranty of
11 * MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE. See the
12 * GNU General Public License for more details.
13 *
14 * You should have received a copy of the GNU General Public License
15 * along with this program; if not, write to the Free Software
16 * Foundation, Inc., 51 Franklin Street, Fifth Floor, Boston, MA 02110-1301, USA.
17 */
18
19 /* ****************************************************************************
20 1 头文件包含
21 **************************************************************************** */
22 #include "wal_ioctl.h"
23 #include "wal_event_msg.h"
24
25 #ifdef __cplusplus
26 #if __cplusplus
27 extern "C" {
28 #endif
29 #endif
30
31 /* ****************************************************************************
32 2 全局变量定义
33 **************************************************************************** */
34 /* ****************************************************************************
35 3 函数实现
36 **************************************************************************** */
37 #define DATA_ACQ_WAITTIME (5 * HZ)
38 /* ****************************************************************************
39 函 数 名 : dmac_data_acq_start_from_hso
40 功能描述 : 执行histudo设置的数采选项
41 **************************************************************************** */
wal_data_acq_start_from_hso(const hi_char * puc_ifname,const wlan_data_acq_stru * data_acq)42 hi_u32 wal_data_acq_start_from_hso(const hi_char *puc_ifname, const wlan_data_acq_stru *data_acq)
43 {
44 oal_net_device_stru *netdev = HI_NULL;
45 wal_msg_write_stru write_msg;
46 hi_u32 ret;
47
48 if ((puc_ifname == HI_NULL) || (data_acq == HI_NULL)) {
49 oam_error_log0(0, OAM_SF_ANY, "{wal_data_acq_start_from_hso::puc_ifname/pst_data_acq is null!}\r\n");
50 return HI_ERR_CODE_PTR_NULL;
51 }
52
53 netdev = oal_get_netdev_by_name(puc_ifname);
54 if (netdev == HI_NULL) {
55 oam_error_log0(0, 0, "{wal_data_acq_start_from_hso::pst_netdev is null!}");
56 return HI_ERR_CODE_PTR_NULL;
57 }
58
59 /* 填写事件头 */
60 wal_write_msg_hdr_init(&write_msg, WLAN_CFGID_DATA_ACQ_START, sizeof(wlan_data_acq_stru));
61 /* 填写消息体 */
62 if (memcpy_s(write_msg.auc_value, sizeof(write_msg.auc_value), data_acq, sizeof(wlan_data_acq_stru)) != EOK) {
63 oam_error_log0(0, OAM_SF_ANY, "{wal_cfg80211_open_wmm::mem safe function err!}");
64 return HI_FAIL;
65 }
66
67 ret = wal_send_cfg_event(netdev, WAL_MSG_TYPE_WRITE, WAL_MSG_WRITE_MSG_HDR_LENGTH + sizeof(wlan_data_acq_stru),
68 (hi_u8 *)&write_msg, HI_FALSE, HI_NULL);
69 if (oal_unlikely(ret != HI_SUCCESS)) {
70 oam_warning_log1(0, OAM_SF_ANY, "{wal_cfg80211_open_wmm:return err code %d!}\r\n", ret);
71 return HI_FAIL;
72 }
73
74 return ret;
75 }
76
77 /* ****************************************************************************
78 函 数 名 : wal_data_acq_report_to_hso
79 功能描述 : 上报histudo数据采集是否完成
80 **************************************************************************** */
wal_data_acq_status_to_hso(const hi_char * puc_ifname,const wlan_data_acq_stru * data_acq)81 hi_u8 wal_data_acq_status_to_hso(const hi_char *puc_ifname, const wlan_data_acq_stru *data_acq)
82 {
83 wal_msg_write_stru write_msg;
84
85 if ((puc_ifname == HI_NULL) || (data_acq == HI_NULL)) {
86 oam_error_log0(0, OAM_SF_ANY, "{wal_data_acq_status_to_hso::puc_ifname/pst_data_acq is null!}\r\n");
87 return HI_FALSE;
88 }
89
90 oal_net_device_stru *netdev = oal_get_netdev_by_name(puc_ifname);
91 if (netdev == HI_NULL) {
92 oam_error_log0(0, 0, "{wal_data_acq_status_to_hso::pst_netdev is null!}");
93 return HI_FALSE;
94 }
95
96 mac_vap_stru *mac_vap = oal_net_dev_priv(netdev);
97 if (mac_vap == NULL) {
98 oam_error_log0(0, OAM_SF_ANY, "{wal_data_acq_status_to_hso::cann't acquire mac_vap from netdev!}");
99 return HI_ERR_CODE_PTR_NULL;
100 }
101
102 hmac_vap_stru *hmac_vap = hmac_vap_get_vap_stru(mac_vap->vap_id);
103 if (hmac_vap == HI_NULL) {
104 oam_error_log0(0, OAM_SF_ANY, "{wal_data_acq_status_to_hso::hmac_vap_get_vap_stru, return null!}");
105 return HI_ERR_CODE_PTR_NULL;
106 }
107 hmac_vap->station_info_query_completed_flag = HI_FALSE;
108
109 /* 填写事件头 */
110 wal_write_msg_hdr_init(&write_msg, WLAN_CFGID_DATA_ACQ_STATUS, sizeof(wlan_data_acq_stru));
111 /* 填写消息体 */
112 if (memcpy_s(write_msg.auc_value, sizeof(write_msg.auc_value), data_acq, sizeof(wlan_data_acq_stru)) != EOK) {
113 oam_error_log0(0, OAM_SF_ANY, "{wal_data_acq_status_to_hso::mem safe function err!}");
114 return HI_FALSE;
115 }
116
117 hi_u32 ret = wal_send_cfg_event(netdev, WAL_MSG_TYPE_WRITE,
118 WAL_MSG_WRITE_MSG_HDR_LENGTH + sizeof(wlan_data_acq_stru), (hi_u8 *)&write_msg, HI_FALSE, HI_NULL);
119 if (ret != HI_SUCCESS) {
120 oam_error_log1(0, OAM_SF_ANY, "{wal_data_acq_status_to_hso::wal_send_cfg_event return err code %d!}\r\n", ret);
121 return HI_FALSE;
122 }
123
124 ret = (hi_u32)hi_wait_event_timeout((hmac_vap->query_wait_q), /* use非wifi目录定义宏函数,误告警,lin_t e26告警屏蔽 */
125 (HI_TRUE == hmac_vap->station_info_query_completed_flag), DATA_ACQ_WAITTIME);
126 if (ret == 0) {
127 oam_warning_log1(mac_vap->vap_id, OAM_SF_ANY, "wal_data_acq_result_addr_to_hso:query temp timeout.ret:%d", ret);
128 return HI_FALSE;
129 }
130
131 return hmac_vap->acq_status_filter;
132 }
133
134 /* ****************************************************************************
135 函 数 名 : wal_data_acq_report_to_hso
136 功能描述 : 上报histudo数据采集结果
137 **************************************************************************** */
wal_data_acq_result_addr_to_hso(const hi_char * puc_ifname,const wlan_data_acq_stru * data_acq,wlan_acq_result_addr_stru * data_result_addr)138 hi_u32 wal_data_acq_result_addr_to_hso(const hi_char *puc_ifname, const wlan_data_acq_stru *data_acq,
139 wlan_acq_result_addr_stru *data_result_addr)
140 {
141 wal_msg_write_stru write_msg;
142
143 if ((puc_ifname == HI_NULL) || (data_acq == HI_NULL) || (data_result_addr == HI_NULL)) {
144 oam_error_log0(0, OAM_SF_ANY, "{wal_data_acq_result_addr_to_hso::parameter is null!}\r\n");
145 return HI_ERR_CODE_PTR_NULL;
146 }
147
148 oal_net_device_stru *netdev = oal_get_netdev_by_name(puc_ifname);
149 if (netdev == HI_NULL) {
150 oam_error_log0(0, 0, "{wal_data_acq_result_addr_to_hso::pst_netdev is null!}");
151 return HI_ERR_CODE_PTR_NULL;
152 }
153
154 mac_vap_stru *mac_vap = oal_net_dev_priv(netdev);
155 if (mac_vap == NULL) {
156 oam_error_log0(0, OAM_SF_ANY, "{wal_data_acq_result_addr_to_hso::cann't acquire mac_vap from netdev!}");
157 return HI_ERR_CODE_PTR_NULL;
158 }
159
160 hmac_vap_stru *hmac_vap = hmac_vap_get_vap_stru(mac_vap->vap_id);
161 if (hmac_vap == HI_NULL) {
162 oam_error_log0(0, OAM_SF_ANY, "{wal_data_acq_result_addr_to_hso::hmac_vap_get_vap_stru, return null!}");
163 return HI_ERR_CODE_PTR_NULL;
164 }
165 hmac_vap->station_info_query_completed_flag = HI_FALSE;
166
167 /* 填写事件头 */
168 wal_write_msg_hdr_init(&write_msg, WLAN_CFGID_DATA_ACQ_REPORT, sizeof(wlan_data_acq_stru));
169 /* 填写消息体 */
170 if (memcpy_s(write_msg.auc_value, sizeof(write_msg.auc_value), data_acq, sizeof(wlan_data_acq_stru)) != EOK) {
171 oam_error_log0(0, OAM_SF_ANY, "{wal_data_acq_status_to_hso::mem safe function err!}");
172 return HI_FAIL;
173 }
174
175 hi_u32 ret = wal_send_cfg_event(netdev, WAL_MSG_TYPE_WRITE,
176 WAL_MSG_WRITE_MSG_HDR_LENGTH + sizeof(wlan_data_acq_stru), (hi_u8 *)&write_msg, HI_FALSE, HI_NULL);
177 if (ret != HI_SUCCESS) {
178 oam_error_log1(0, OAM_SF_ANY, "{wal_data_acq_status_to_hso::wal_send_cfg_event return err code %d!}\r\n", ret);
179 return HI_FAIL;
180 }
181
182 ret = (hi_u32)hi_wait_event_timeout((hmac_vap->query_wait_q), /* use非wifi目录定义宏函数,误告警,lin_t e26告警屏蔽 */
183 (HI_TRUE == hmac_vap->station_info_query_completed_flag), DATA_ACQ_WAITTIME);
184 if (ret == 0) {
185 oam_warning_log1(mac_vap->vap_id, OAM_SF_ANY, "wal_data_acq_result_addr_to_hso: query temp timeout[%d]", ret);
186 return HI_FAIL;
187 }
188
189 data_result_addr->start_addr = hmac_vap->acq_result_addr.start_addr;
190 data_result_addr->middle_addr1 = hmac_vap->acq_result_addr.middle_addr1;
191 data_result_addr->middle_addr2 = hmac_vap->acq_result_addr.middle_addr2;
192 data_result_addr->end_addr = hmac_vap->acq_result_addr.end_addr;
193
194 return HI_SUCCESS;
195 }
196
197 #ifdef __cplusplus
198 #if __cplusplus
199 }
200 #endif
201 #endif
202