• Home
  • Line#
  • Scopes#
  • Navigate#
  • Raw
  • Download
1 /*
2  * Copyright (C) 2016 The Android Open Source Project
3  *
4  * Licensed under the Apache License, Version 2.0 (the "License");
5  * you may not use this file except in compliance with the License.
6  * You may obtain a copy of the License at
7  *
8  *      http://www.apache.org/licenses/LICENSE-2.0
9  *
10  * Unless required by applicable law or agreed to in writing, software
11  * distributed under the License is distributed on an "AS IS" BASIS,
12  * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
13  * See the License for the specific language governing permissions and
14  * limitations under the License.
15  */
16 
17 #include <array>
18 #include <chrono>
19 
20 #include <android-base/logging.h>
21 #include <cutils/properties.h>
22 #include <net/if.h>
23 
24 #include "hidl_sync_util.h"
25 #include "wifi_legacy_hal.h"
26 #include "wifi_legacy_hal_stubs.h"
27 
28 namespace {
29 // Constants ported over from the legacy HAL calling code
30 // (com_android_server_wifi_WifiNative.cpp). This will all be thrown
31 // away when this shim layer is replaced by the real vendor
32 // implementation.
33 static constexpr uint32_t kMaxVersionStringLength = 256;
34 static constexpr uint32_t kMaxCachedGscanResults = 64;
35 static constexpr uint32_t kMaxGscanFrequenciesForBand = 64;
36 static constexpr uint32_t kLinkLayerStatsDataMpduSizeThreshold = 128;
37 static constexpr uint32_t kMaxWakeReasonStatsArraySize = 32;
38 static constexpr uint32_t kMaxRingBuffers = 10;
39 static constexpr uint32_t kMaxWifiUsableChannels = 256;
40 static constexpr uint32_t kMaxSupportedRadioCombinationsMatrixLength = 256;
41 // need a long timeout (1000ms) for chips that unload their driver.
42 static constexpr uint32_t kMaxStopCompleteWaitMs = 1000;
43 static constexpr char kDriverPropName[] = "wlan.driver.status";
44 
45 // Helper function to create a non-const char* for legacy Hal API's.
makeCharVec(const std::string & str)46 std::vector<char> makeCharVec(const std::string& str) {
47     std::vector<char> vec(str.size() + 1);
48     vec.assign(str.begin(), str.end());
49     vec.push_back('\0');
50     return vec;
51 }
52 }  // namespace
53 
54 namespace android {
55 namespace hardware {
56 namespace wifi {
57 namespace V1_6 {
58 namespace implementation {
59 namespace legacy_hal {
60 
61 // Legacy HAL functions accept "C" style function pointers, so use global
62 // functions to pass to the legacy HAL function and store the corresponding
63 // std::function methods to be invoked.
64 //
65 // Callback to be invoked once |stop| is complete
66 std::function<void(wifi_handle handle)> on_stop_complete_internal_callback;
onAsyncStopComplete(wifi_handle handle)67 void onAsyncStopComplete(wifi_handle handle) {
68     const auto lock = hidl_sync_util::acquireGlobalLock();
69     if (on_stop_complete_internal_callback) {
70         on_stop_complete_internal_callback(handle);
71         // Invalidate this callback since we don't want this firing again.
72         on_stop_complete_internal_callback = nullptr;
73     }
74 }
75 
76 // Callback to be invoked for driver dump.
77 std::function<void(char*, int)> on_driver_memory_dump_internal_callback;
onSyncDriverMemoryDump(char * buffer,int buffer_size)78 void onSyncDriverMemoryDump(char* buffer, int buffer_size) {
79     if (on_driver_memory_dump_internal_callback) {
80         on_driver_memory_dump_internal_callback(buffer, buffer_size);
81     }
82 }
83 
84 // Callback to be invoked for firmware dump.
85 std::function<void(char*, int)> on_firmware_memory_dump_internal_callback;
onSyncFirmwareMemoryDump(char * buffer,int buffer_size)86 void onSyncFirmwareMemoryDump(char* buffer, int buffer_size) {
87     if (on_firmware_memory_dump_internal_callback) {
88         on_firmware_memory_dump_internal_callback(buffer, buffer_size);
89     }
90 }
91 
92 // Callback to be invoked for Gscan events.
93 std::function<void(wifi_request_id, wifi_scan_event)> on_gscan_event_internal_callback;
onAsyncGscanEvent(wifi_request_id id,wifi_scan_event event)94 void onAsyncGscanEvent(wifi_request_id id, wifi_scan_event event) {
95     const auto lock = hidl_sync_util::acquireGlobalLock();
96     if (on_gscan_event_internal_callback) {
97         on_gscan_event_internal_callback(id, event);
98     }
99 }
100 
101 // Callback to be invoked for Gscan full results.
102 std::function<void(wifi_request_id, wifi_scan_result*, uint32_t)>
103         on_gscan_full_result_internal_callback;
onAsyncGscanFullResult(wifi_request_id id,wifi_scan_result * result,uint32_t buckets_scanned)104 void onAsyncGscanFullResult(wifi_request_id id, wifi_scan_result* result,
105                             uint32_t buckets_scanned) {
106     const auto lock = hidl_sync_util::acquireGlobalLock();
107     if (on_gscan_full_result_internal_callback) {
108         on_gscan_full_result_internal_callback(id, result, buckets_scanned);
109     }
110 }
111 
112 // Callback to be invoked for link layer stats results.
113 std::function<void((wifi_request_id, wifi_iface_stat*, int, wifi_radio_stat*))>
114         on_link_layer_stats_result_internal_callback;
onSyncLinkLayerStatsResult(wifi_request_id id,wifi_iface_stat * iface_stat,int num_radios,wifi_radio_stat * radio_stat)115 void onSyncLinkLayerStatsResult(wifi_request_id id, wifi_iface_stat* iface_stat, int num_radios,
116                                 wifi_radio_stat* radio_stat) {
117     if (on_link_layer_stats_result_internal_callback) {
118         on_link_layer_stats_result_internal_callback(id, iface_stat, num_radios, radio_stat);
119     }
120 }
121 
122 // Callback to be invoked for rssi threshold breach.
123 std::function<void((wifi_request_id, uint8_t*, int8_t))>
124         on_rssi_threshold_breached_internal_callback;
onAsyncRssiThresholdBreached(wifi_request_id id,uint8_t * bssid,int8_t rssi)125 void onAsyncRssiThresholdBreached(wifi_request_id id, uint8_t* bssid, int8_t rssi) {
126     const auto lock = hidl_sync_util::acquireGlobalLock();
127     if (on_rssi_threshold_breached_internal_callback) {
128         on_rssi_threshold_breached_internal_callback(id, bssid, rssi);
129     }
130 }
131 
132 // Callback to be invoked for ring buffer data indication.
133 std::function<void(char*, char*, int, wifi_ring_buffer_status*)>
134         on_ring_buffer_data_internal_callback;
onAsyncRingBufferData(char * ring_name,char * buffer,int buffer_size,wifi_ring_buffer_status * status)135 void onAsyncRingBufferData(char* ring_name, char* buffer, int buffer_size,
136                            wifi_ring_buffer_status* status) {
137     const auto lock = hidl_sync_util::acquireGlobalLock();
138     if (on_ring_buffer_data_internal_callback) {
139         on_ring_buffer_data_internal_callback(ring_name, buffer, buffer_size, status);
140     }
141 }
142 
143 // Callback to be invoked for error alert indication.
144 std::function<void(wifi_request_id, char*, int, int)> on_error_alert_internal_callback;
onAsyncErrorAlert(wifi_request_id id,char * buffer,int buffer_size,int err_code)145 void onAsyncErrorAlert(wifi_request_id id, char* buffer, int buffer_size, int err_code) {
146     const auto lock = hidl_sync_util::acquireGlobalLock();
147     if (on_error_alert_internal_callback) {
148         on_error_alert_internal_callback(id, buffer, buffer_size, err_code);
149     }
150 }
151 
152 // Callback to be invoked for radio mode change indication.
153 std::function<void(wifi_request_id, uint32_t, wifi_mac_info*)>
154         on_radio_mode_change_internal_callback;
onAsyncRadioModeChange(wifi_request_id id,uint32_t num_macs,wifi_mac_info * mac_infos)155 void onAsyncRadioModeChange(wifi_request_id id, uint32_t num_macs, wifi_mac_info* mac_infos) {
156     const auto lock = hidl_sync_util::acquireGlobalLock();
157     if (on_radio_mode_change_internal_callback) {
158         on_radio_mode_change_internal_callback(id, num_macs, mac_infos);
159     }
160 }
161 
162 // Callback to be invoked to report subsystem restart
163 std::function<void(const char*)> on_subsystem_restart_internal_callback;
onAsyncSubsystemRestart(const char * error)164 void onAsyncSubsystemRestart(const char* error) {
165     const auto lock = hidl_sync_util::acquireGlobalLock();
166     if (on_subsystem_restart_internal_callback) {
167         on_subsystem_restart_internal_callback(error);
168     }
169 }
170 
171 // Callback to be invoked for rtt results results.
172 std::function<void(wifi_request_id, unsigned num_results, wifi_rtt_result* rtt_results[])>
173         on_rtt_results_internal_callback;
onAsyncRttResults(wifi_request_id id,unsigned num_results,wifi_rtt_result * rtt_results[])174 void onAsyncRttResults(wifi_request_id id, unsigned num_results, wifi_rtt_result* rtt_results[]) {
175     const auto lock = hidl_sync_util::acquireGlobalLock();
176     if (on_rtt_results_internal_callback) {
177         on_rtt_results_internal_callback(id, num_results, rtt_results);
178         on_rtt_results_internal_callback = nullptr;
179     }
180 }
181 
182 // Callbacks for the various NAN operations.
183 // NOTE: These have very little conversions to perform before invoking the user
184 // callbacks.
185 // So, handle all of them here directly to avoid adding an unnecessary layer.
186 std::function<void(transaction_id, const NanResponseMsg&)> on_nan_notify_response_user_callback;
onAysncNanNotifyResponse(transaction_id id,NanResponseMsg * msg)187 void onAysncNanNotifyResponse(transaction_id id, NanResponseMsg* msg) {
188     const auto lock = hidl_sync_util::acquireGlobalLock();
189     if (on_nan_notify_response_user_callback && msg) {
190         on_nan_notify_response_user_callback(id, *msg);
191     }
192 }
193 
194 std::function<void(const NanPublishRepliedInd&)> on_nan_event_publish_replied_user_callback;
onAysncNanEventPublishReplied(NanPublishRepliedInd *)195 void onAysncNanEventPublishReplied(NanPublishRepliedInd* /* event */) {
196     LOG(ERROR) << "onAysncNanEventPublishReplied triggered";
197 }
198 
199 std::function<void(const NanPublishTerminatedInd&)> on_nan_event_publish_terminated_user_callback;
onAysncNanEventPublishTerminated(NanPublishTerminatedInd * event)200 void onAysncNanEventPublishTerminated(NanPublishTerminatedInd* event) {
201     const auto lock = hidl_sync_util::acquireGlobalLock();
202     if (on_nan_event_publish_terminated_user_callback && event) {
203         on_nan_event_publish_terminated_user_callback(*event);
204     }
205 }
206 
207 std::function<void(const NanMatchInd&)> on_nan_event_match_user_callback;
onAysncNanEventMatch(NanMatchInd * event)208 void onAysncNanEventMatch(NanMatchInd* event) {
209     const auto lock = hidl_sync_util::acquireGlobalLock();
210     if (on_nan_event_match_user_callback && event) {
211         on_nan_event_match_user_callback(*event);
212     }
213 }
214 
215 std::function<void(const NanMatchExpiredInd&)> on_nan_event_match_expired_user_callback;
onAysncNanEventMatchExpired(NanMatchExpiredInd * event)216 void onAysncNanEventMatchExpired(NanMatchExpiredInd* event) {
217     const auto lock = hidl_sync_util::acquireGlobalLock();
218     if (on_nan_event_match_expired_user_callback && event) {
219         on_nan_event_match_expired_user_callback(*event);
220     }
221 }
222 
223 std::function<void(const NanSubscribeTerminatedInd&)>
224         on_nan_event_subscribe_terminated_user_callback;
onAysncNanEventSubscribeTerminated(NanSubscribeTerminatedInd * event)225 void onAysncNanEventSubscribeTerminated(NanSubscribeTerminatedInd* event) {
226     const auto lock = hidl_sync_util::acquireGlobalLock();
227     if (on_nan_event_subscribe_terminated_user_callback && event) {
228         on_nan_event_subscribe_terminated_user_callback(*event);
229     }
230 }
231 
232 std::function<void(const NanFollowupInd&)> on_nan_event_followup_user_callback;
onAysncNanEventFollowup(NanFollowupInd * event)233 void onAysncNanEventFollowup(NanFollowupInd* event) {
234     const auto lock = hidl_sync_util::acquireGlobalLock();
235     if (on_nan_event_followup_user_callback && event) {
236         on_nan_event_followup_user_callback(*event);
237     }
238 }
239 
240 std::function<void(const NanDiscEngEventInd&)> on_nan_event_disc_eng_event_user_callback;
onAysncNanEventDiscEngEvent(NanDiscEngEventInd * event)241 void onAysncNanEventDiscEngEvent(NanDiscEngEventInd* event) {
242     const auto lock = hidl_sync_util::acquireGlobalLock();
243     if (on_nan_event_disc_eng_event_user_callback && event) {
244         on_nan_event_disc_eng_event_user_callback(*event);
245     }
246 }
247 
248 std::function<void(const NanDisabledInd&)> on_nan_event_disabled_user_callback;
onAysncNanEventDisabled(NanDisabledInd * event)249 void onAysncNanEventDisabled(NanDisabledInd* event) {
250     const auto lock = hidl_sync_util::acquireGlobalLock();
251     if (on_nan_event_disabled_user_callback && event) {
252         on_nan_event_disabled_user_callback(*event);
253     }
254 }
255 
256 std::function<void(const NanTCAInd&)> on_nan_event_tca_user_callback;
onAysncNanEventTca(NanTCAInd * event)257 void onAysncNanEventTca(NanTCAInd* event) {
258     const auto lock = hidl_sync_util::acquireGlobalLock();
259     if (on_nan_event_tca_user_callback && event) {
260         on_nan_event_tca_user_callback(*event);
261     }
262 }
263 
264 std::function<void(const NanBeaconSdfPayloadInd&)> on_nan_event_beacon_sdf_payload_user_callback;
onAysncNanEventBeaconSdfPayload(NanBeaconSdfPayloadInd * event)265 void onAysncNanEventBeaconSdfPayload(NanBeaconSdfPayloadInd* event) {
266     const auto lock = hidl_sync_util::acquireGlobalLock();
267     if (on_nan_event_beacon_sdf_payload_user_callback && event) {
268         on_nan_event_beacon_sdf_payload_user_callback(*event);
269     }
270 }
271 
272 std::function<void(const NanDataPathRequestInd&)> on_nan_event_data_path_request_user_callback;
onAysncNanEventDataPathRequest(NanDataPathRequestInd * event)273 void onAysncNanEventDataPathRequest(NanDataPathRequestInd* event) {
274     const auto lock = hidl_sync_util::acquireGlobalLock();
275     if (on_nan_event_data_path_request_user_callback && event) {
276         on_nan_event_data_path_request_user_callback(*event);
277     }
278 }
279 std::function<void(const NanDataPathConfirmInd&)> on_nan_event_data_path_confirm_user_callback;
onAysncNanEventDataPathConfirm(NanDataPathConfirmInd * event)280 void onAysncNanEventDataPathConfirm(NanDataPathConfirmInd* event) {
281     const auto lock = hidl_sync_util::acquireGlobalLock();
282     if (on_nan_event_data_path_confirm_user_callback && event) {
283         on_nan_event_data_path_confirm_user_callback(*event);
284     }
285 }
286 
287 std::function<void(const NanDataPathEndInd&)> on_nan_event_data_path_end_user_callback;
onAysncNanEventDataPathEnd(NanDataPathEndInd * event)288 void onAysncNanEventDataPathEnd(NanDataPathEndInd* event) {
289     const auto lock = hidl_sync_util::acquireGlobalLock();
290     if (on_nan_event_data_path_end_user_callback && event) {
291         on_nan_event_data_path_end_user_callback(*event);
292     }
293 }
294 
295 std::function<void(const NanTransmitFollowupInd&)> on_nan_event_transmit_follow_up_user_callback;
onAysncNanEventTransmitFollowUp(NanTransmitFollowupInd * event)296 void onAysncNanEventTransmitFollowUp(NanTransmitFollowupInd* event) {
297     const auto lock = hidl_sync_util::acquireGlobalLock();
298     if (on_nan_event_transmit_follow_up_user_callback && event) {
299         on_nan_event_transmit_follow_up_user_callback(*event);
300     }
301 }
302 
303 std::function<void(const NanRangeRequestInd&)> on_nan_event_range_request_user_callback;
onAysncNanEventRangeRequest(NanRangeRequestInd * event)304 void onAysncNanEventRangeRequest(NanRangeRequestInd* event) {
305     const auto lock = hidl_sync_util::acquireGlobalLock();
306     if (on_nan_event_range_request_user_callback && event) {
307         on_nan_event_range_request_user_callback(*event);
308     }
309 }
310 
311 std::function<void(const NanRangeReportInd&)> on_nan_event_range_report_user_callback;
onAysncNanEventRangeReport(NanRangeReportInd * event)312 void onAysncNanEventRangeReport(NanRangeReportInd* event) {
313     const auto lock = hidl_sync_util::acquireGlobalLock();
314     if (on_nan_event_range_report_user_callback && event) {
315         on_nan_event_range_report_user_callback(*event);
316     }
317 }
318 
319 std::function<void(const NanDataPathScheduleUpdateInd&)> on_nan_event_schedule_update_user_callback;
onAsyncNanEventScheduleUpdate(NanDataPathScheduleUpdateInd * event)320 void onAsyncNanEventScheduleUpdate(NanDataPathScheduleUpdateInd* event) {
321     const auto lock = hidl_sync_util::acquireGlobalLock();
322     if (on_nan_event_schedule_update_user_callback && event) {
323         on_nan_event_schedule_update_user_callback(*event);
324     }
325 }
326 
327 // Callbacks for the various TWT operations.
328 std::function<void(const TwtSetupResponse&)> on_twt_event_setup_response_callback;
onAsyncTwtEventSetupResponse(TwtSetupResponse * event)329 void onAsyncTwtEventSetupResponse(TwtSetupResponse* event) {
330     const auto lock = hidl_sync_util::acquireGlobalLock();
331     if (on_twt_event_setup_response_callback && event) {
332         on_twt_event_setup_response_callback(*event);
333     }
334 }
335 
336 std::function<void(const TwtTeardownCompletion&)> on_twt_event_teardown_completion_callback;
onAsyncTwtEventTeardownCompletion(TwtTeardownCompletion * event)337 void onAsyncTwtEventTeardownCompletion(TwtTeardownCompletion* event) {
338     const auto lock = hidl_sync_util::acquireGlobalLock();
339     if (on_twt_event_teardown_completion_callback && event) {
340         on_twt_event_teardown_completion_callback(*event);
341     }
342 }
343 
344 std::function<void(const TwtInfoFrameReceived&)> on_twt_event_info_frame_received_callback;
onAsyncTwtEventInfoFrameReceived(TwtInfoFrameReceived * event)345 void onAsyncTwtEventInfoFrameReceived(TwtInfoFrameReceived* event) {
346     const auto lock = hidl_sync_util::acquireGlobalLock();
347     if (on_twt_event_info_frame_received_callback && event) {
348         on_twt_event_info_frame_received_callback(*event);
349     }
350 }
351 
352 std::function<void(const TwtDeviceNotify&)> on_twt_event_device_notify_callback;
onAsyncTwtEventDeviceNotify(TwtDeviceNotify * event)353 void onAsyncTwtEventDeviceNotify(TwtDeviceNotify* event) {
354     const auto lock = hidl_sync_util::acquireGlobalLock();
355     if (on_twt_event_device_notify_callback && event) {
356         on_twt_event_device_notify_callback(*event);
357     }
358 }
359 
360 // Callback to report current CHRE NAN state
361 std::function<void(chre_nan_rtt_state)> on_chre_nan_rtt_internal_callback;
onAsyncChreNanRttState(chre_nan_rtt_state state)362 void onAsyncChreNanRttState(chre_nan_rtt_state state) {
363     const auto lock = hidl_sync_util::acquireGlobalLock();
364     if (on_chre_nan_rtt_internal_callback) {
365         on_chre_nan_rtt_internal_callback(state);
366     }
367 }
368 
369 // End of the free-standing "C" style callbacks.
370 
WifiLegacyHal(const std::weak_ptr<wifi_system::InterfaceTool> iface_tool,const wifi_hal_fn & fn,bool is_primary)371 WifiLegacyHal::WifiLegacyHal(const std::weak_ptr<wifi_system::InterfaceTool> iface_tool,
372                              const wifi_hal_fn& fn, bool is_primary)
373     : global_func_table_(fn),
374       global_handle_(nullptr),
375       awaiting_event_loop_termination_(false),
376       is_started_(false),
377       iface_tool_(iface_tool),
378       is_primary_(is_primary) {}
379 
initialize()380 wifi_error WifiLegacyHal::initialize() {
381     LOG(DEBUG) << "Initialize legacy HAL";
382     // this now does nothing, since HAL function table is provided
383     // to the constructor
384     return WIFI_SUCCESS;
385 }
386 
start()387 wifi_error WifiLegacyHal::start() {
388     // Ensure that we're starting in a good state.
389     CHECK(global_func_table_.wifi_initialize && !global_handle_ && iface_name_to_handle_.empty() &&
390           !awaiting_event_loop_termination_);
391     if (is_started_) {
392         LOG(DEBUG) << "Legacy HAL already started";
393         return WIFI_SUCCESS;
394     }
395     LOG(DEBUG) << "Waiting for the driver ready";
396     wifi_error status = global_func_table_.wifi_wait_for_driver_ready();
397     if (status == WIFI_ERROR_TIMED_OUT || status == WIFI_ERROR_UNKNOWN) {
398         LOG(ERROR) << "Failed or timed out awaiting driver ready";
399         return status;
400     }
401 
402     if (is_primary_) {
403         property_set(kDriverPropName, "ok");
404 
405         if (!iface_tool_.lock()->SetWifiUpState(true)) {
406             LOG(ERROR) << "Failed to set WiFi interface up";
407             return WIFI_ERROR_UNKNOWN;
408         }
409     }
410 
411     LOG(DEBUG) << "Starting legacy HAL";
412     status = global_func_table_.wifi_initialize(&global_handle_);
413     if (status != WIFI_SUCCESS || !global_handle_) {
414         LOG(ERROR) << "Failed to retrieve global handle";
415         return status;
416     }
417     std::thread(&WifiLegacyHal::runEventLoop, this).detach();
418     status = retrieveIfaceHandles();
419     if (status != WIFI_SUCCESS || iface_name_to_handle_.empty()) {
420         LOG(ERROR) << "Failed to retrieve wlan interface handle";
421         return status;
422     }
423     LOG(DEBUG) << "Legacy HAL start complete";
424     is_started_ = true;
425     return WIFI_SUCCESS;
426 }
427 
stop(std::unique_lock<std::recursive_mutex> * lock,const std::function<void ()> & on_stop_complete_user_callback)428 wifi_error WifiLegacyHal::stop(
429         /* NONNULL */ std::unique_lock<std::recursive_mutex>* lock,
430         const std::function<void()>& on_stop_complete_user_callback) {
431     if (!is_started_) {
432         LOG(DEBUG) << "Legacy HAL already stopped";
433         on_stop_complete_user_callback();
434         return WIFI_SUCCESS;
435     }
436     LOG(DEBUG) << "Stopping legacy HAL";
437     on_stop_complete_internal_callback = [on_stop_complete_user_callback,
438                                           this](wifi_handle handle) {
439         CHECK_EQ(global_handle_, handle) << "Handle mismatch";
440         LOG(INFO) << "Legacy HAL stop complete callback received";
441         // Invalidate all the internal pointers now that the HAL is
442         // stopped.
443         invalidate();
444         if (is_primary_) iface_tool_.lock()->SetWifiUpState(false);
445         on_stop_complete_user_callback();
446         is_started_ = false;
447     };
448     awaiting_event_loop_termination_ = true;
449     global_func_table_.wifi_cleanup(global_handle_, onAsyncStopComplete);
450     const auto status =
451             stop_wait_cv_.wait_for(*lock, std::chrono::milliseconds(kMaxStopCompleteWaitMs),
452                                    [this] { return !awaiting_event_loop_termination_; });
453     if (!status) {
454         LOG(ERROR) << "Legacy HAL stop failed or timed out";
455         return WIFI_ERROR_UNKNOWN;
456     }
457     LOG(DEBUG) << "Legacy HAL stop complete";
458     return WIFI_SUCCESS;
459 }
460 
isStarted()461 bool WifiLegacyHal::isStarted() {
462     return is_started_;
463 }
464 
waitForDriverReady()465 wifi_error WifiLegacyHal::waitForDriverReady() {
466     return global_func_table_.wifi_wait_for_driver_ready();
467 }
468 
getDriverVersion(const std::string & iface_name)469 std::pair<wifi_error, std::string> WifiLegacyHal::getDriverVersion(const std::string& iface_name) {
470     std::array<char, kMaxVersionStringLength> buffer;
471     buffer.fill(0);
472     wifi_error status = global_func_table_.wifi_get_driver_version(getIfaceHandle(iface_name),
473                                                                    buffer.data(), buffer.size());
474     return {status, buffer.data()};
475 }
476 
getFirmwareVersion(const std::string & iface_name)477 std::pair<wifi_error, std::string> WifiLegacyHal::getFirmwareVersion(
478         const std::string& iface_name) {
479     std::array<char, kMaxVersionStringLength> buffer;
480     buffer.fill(0);
481     wifi_error status = global_func_table_.wifi_get_firmware_version(getIfaceHandle(iface_name),
482                                                                      buffer.data(), buffer.size());
483     return {status, buffer.data()};
484 }
485 
requestDriverMemoryDump(const std::string & iface_name)486 std::pair<wifi_error, std::vector<uint8_t>> WifiLegacyHal::requestDriverMemoryDump(
487         const std::string& iface_name) {
488     std::vector<uint8_t> driver_dump;
489     on_driver_memory_dump_internal_callback = [&driver_dump](char* buffer, int buffer_size) {
490         driver_dump.insert(driver_dump.end(), reinterpret_cast<uint8_t*>(buffer),
491                            reinterpret_cast<uint8_t*>(buffer) + buffer_size);
492     };
493     wifi_error status = global_func_table_.wifi_get_driver_memory_dump(getIfaceHandle(iface_name),
494                                                                        {onSyncDriverMemoryDump});
495     on_driver_memory_dump_internal_callback = nullptr;
496     return {status, std::move(driver_dump)};
497 }
498 
requestFirmwareMemoryDump(const std::string & iface_name)499 std::pair<wifi_error, std::vector<uint8_t>> WifiLegacyHal::requestFirmwareMemoryDump(
500         const std::string& iface_name) {
501     std::vector<uint8_t> firmware_dump;
502     on_firmware_memory_dump_internal_callback = [&firmware_dump](char* buffer, int buffer_size) {
503         firmware_dump.insert(firmware_dump.end(), reinterpret_cast<uint8_t*>(buffer),
504                              reinterpret_cast<uint8_t*>(buffer) + buffer_size);
505     };
506     wifi_error status = global_func_table_.wifi_get_firmware_memory_dump(
507             getIfaceHandle(iface_name), {onSyncFirmwareMemoryDump});
508     on_firmware_memory_dump_internal_callback = nullptr;
509     return {status, std::move(firmware_dump)};
510 }
511 
getSupportedFeatureSet(const std::string & iface_name)512 std::pair<wifi_error, uint64_t> WifiLegacyHal::getSupportedFeatureSet(
513         const std::string& iface_name) {
514     feature_set set = 0, chip_set = 0;
515     wifi_error status = WIFI_SUCCESS;
516 
517     static_assert(sizeof(set) == sizeof(uint64_t),
518                   "Some feature_flags can not be represented in output");
519     wifi_interface_handle iface_handle = getIfaceHandle(iface_name);
520 
521     global_func_table_.wifi_get_chip_feature_set(
522             global_handle_, &chip_set); /* ignore error, chip_set will stay 0 */
523 
524     if (iface_handle) {
525         status = global_func_table_.wifi_get_supported_feature_set(iface_handle, &set);
526     }
527     return {status, static_cast<uint64_t>(set | chip_set)};
528 }
529 
getPacketFilterCapabilities(const std::string & iface_name)530 std::pair<wifi_error, PacketFilterCapabilities> WifiLegacyHal::getPacketFilterCapabilities(
531         const std::string& iface_name) {
532     PacketFilterCapabilities caps;
533     wifi_error status = global_func_table_.wifi_get_packet_filter_capabilities(
534             getIfaceHandle(iface_name), &caps.version, &caps.max_len);
535     return {status, caps};
536 }
537 
setPacketFilter(const std::string & iface_name,const std::vector<uint8_t> & program)538 wifi_error WifiLegacyHal::setPacketFilter(const std::string& iface_name,
539                                           const std::vector<uint8_t>& program) {
540     return global_func_table_.wifi_set_packet_filter(getIfaceHandle(iface_name), program.data(),
541                                                      program.size());
542 }
543 
readApfPacketFilterData(const std::string & iface_name)544 std::pair<wifi_error, std::vector<uint8_t>> WifiLegacyHal::readApfPacketFilterData(
545         const std::string& iface_name) {
546     PacketFilterCapabilities caps;
547     wifi_error status = global_func_table_.wifi_get_packet_filter_capabilities(
548             getIfaceHandle(iface_name), &caps.version, &caps.max_len);
549     if (status != WIFI_SUCCESS) {
550         return {status, {}};
551     }
552 
553     // Size the buffer to read the entire program & work memory.
554     std::vector<uint8_t> buffer(caps.max_len);
555 
556     status = global_func_table_.wifi_read_packet_filter(
557             getIfaceHandle(iface_name), /*src_offset=*/0, buffer.data(), buffer.size());
558     return {status, move(buffer)};
559 }
560 
getGscanCapabilities(const std::string & iface_name)561 std::pair<wifi_error, wifi_gscan_capabilities> WifiLegacyHal::getGscanCapabilities(
562         const std::string& iface_name) {
563     wifi_gscan_capabilities caps;
564     wifi_error status =
565             global_func_table_.wifi_get_gscan_capabilities(getIfaceHandle(iface_name), &caps);
566     return {status, caps};
567 }
568 
startGscan(const std::string & iface_name,wifi_request_id id,const wifi_scan_cmd_params & params,const std::function<void (wifi_request_id)> & on_failure_user_callback,const on_gscan_results_callback & on_results_user_callback,const on_gscan_full_result_callback & on_full_result_user_callback)569 wifi_error WifiLegacyHal::startGscan(
570         const std::string& iface_name, wifi_request_id id, const wifi_scan_cmd_params& params,
571         const std::function<void(wifi_request_id)>& on_failure_user_callback,
572         const on_gscan_results_callback& on_results_user_callback,
573         const on_gscan_full_result_callback& on_full_result_user_callback) {
574     // If there is already an ongoing background scan, reject new scan requests.
575     if (on_gscan_event_internal_callback || on_gscan_full_result_internal_callback) {
576         return WIFI_ERROR_NOT_AVAILABLE;
577     }
578 
579     // This callback will be used to either trigger |on_results_user_callback|
580     // or |on_failure_user_callback|.
581     on_gscan_event_internal_callback = [iface_name, on_failure_user_callback,
582                                         on_results_user_callback,
583                                         this](wifi_request_id id, wifi_scan_event event) {
584         switch (event) {
585             case WIFI_SCAN_RESULTS_AVAILABLE:
586             case WIFI_SCAN_THRESHOLD_NUM_SCANS:
587             case WIFI_SCAN_THRESHOLD_PERCENT: {
588                 wifi_error status;
589                 std::vector<wifi_cached_scan_results> cached_scan_results;
590                 std::tie(status, cached_scan_results) = getGscanCachedResults(iface_name);
591                 if (status == WIFI_SUCCESS) {
592                     on_results_user_callback(id, cached_scan_results);
593                     return;
594                 }
595                 FALLTHROUGH_INTENDED;
596             }
597             // Fall through if failed. Failure to retrieve cached scan
598             // results should trigger a background scan failure.
599             case WIFI_SCAN_FAILED:
600                 on_failure_user_callback(id);
601                 on_gscan_event_internal_callback = nullptr;
602                 on_gscan_full_result_internal_callback = nullptr;
603                 return;
604         }
605         LOG(FATAL) << "Unexpected gscan event received: " << event;
606     };
607 
608     on_gscan_full_result_internal_callback = [on_full_result_user_callback](
609                                                      wifi_request_id id, wifi_scan_result* result,
610                                                      uint32_t buckets_scanned) {
611         if (result) {
612             on_full_result_user_callback(id, result, buckets_scanned);
613         }
614     };
615 
616     wifi_scan_result_handler handler = {onAsyncGscanFullResult, onAsyncGscanEvent};
617     wifi_error status =
618             global_func_table_.wifi_start_gscan(id, getIfaceHandle(iface_name), params, handler);
619     if (status != WIFI_SUCCESS) {
620         on_gscan_event_internal_callback = nullptr;
621         on_gscan_full_result_internal_callback = nullptr;
622     }
623     return status;
624 }
625 
stopGscan(const std::string & iface_name,wifi_request_id id)626 wifi_error WifiLegacyHal::stopGscan(const std::string& iface_name, wifi_request_id id) {
627     // If there is no an ongoing background scan, reject stop requests.
628     // TODO(b/32337212): This needs to be handled by the HIDL object because we
629     // need to return the NOT_STARTED error code.
630     if (!on_gscan_event_internal_callback && !on_gscan_full_result_internal_callback) {
631         return WIFI_ERROR_NOT_AVAILABLE;
632     }
633     wifi_error status = global_func_table_.wifi_stop_gscan(id, getIfaceHandle(iface_name));
634     // If the request Id is wrong, don't stop the ongoing background scan. Any
635     // other error should be treated as the end of background scan.
636     if (status != WIFI_ERROR_INVALID_REQUEST_ID) {
637         on_gscan_event_internal_callback = nullptr;
638         on_gscan_full_result_internal_callback = nullptr;
639     }
640     return status;
641 }
642 
getValidFrequenciesForBand(const std::string & iface_name,wifi_band band)643 std::pair<wifi_error, std::vector<uint32_t>> WifiLegacyHal::getValidFrequenciesForBand(
644         const std::string& iface_name, wifi_band band) {
645     static_assert(sizeof(uint32_t) >= sizeof(wifi_channel),
646                   "Wifi Channel cannot be represented in output");
647     std::vector<uint32_t> freqs;
648     freqs.resize(kMaxGscanFrequenciesForBand);
649     int32_t num_freqs = 0;
650     wifi_error status = global_func_table_.wifi_get_valid_channels(
651             getIfaceHandle(iface_name), band, freqs.size(),
652             reinterpret_cast<wifi_channel*>(freqs.data()), &num_freqs);
653     CHECK(num_freqs >= 0 && static_cast<uint32_t>(num_freqs) <= kMaxGscanFrequenciesForBand);
654     freqs.resize(num_freqs);
655     return {status, std::move(freqs)};
656 }
657 
setDfsFlag(const std::string & iface_name,bool dfs_on)658 wifi_error WifiLegacyHal::setDfsFlag(const std::string& iface_name, bool dfs_on) {
659     return global_func_table_.wifi_set_nodfs_flag(getIfaceHandle(iface_name), dfs_on ? 0 : 1);
660 }
661 
enableLinkLayerStats(const std::string & iface_name,bool debug)662 wifi_error WifiLegacyHal::enableLinkLayerStats(const std::string& iface_name, bool debug) {
663     wifi_link_layer_params params;
664     params.mpdu_size_threshold = kLinkLayerStatsDataMpduSizeThreshold;
665     params.aggressive_statistics_gathering = debug;
666     return global_func_table_.wifi_set_link_stats(getIfaceHandle(iface_name), params);
667 }
668 
disableLinkLayerStats(const std::string & iface_name)669 wifi_error WifiLegacyHal::disableLinkLayerStats(const std::string& iface_name) {
670     // TODO: Do we care about these responses?
671     uint32_t clear_mask_rsp;
672     uint8_t stop_rsp;
673     return global_func_table_.wifi_clear_link_stats(getIfaceHandle(iface_name), 0xFFFFFFFF,
674                                                     &clear_mask_rsp, 1, &stop_rsp);
675 }
676 
getLinkLayerStats(const std::string & iface_name)677 std::pair<wifi_error, LinkLayerStats> WifiLegacyHal::getLinkLayerStats(
678         const std::string& iface_name) {
679     LinkLayerStats link_stats{};
680     LinkLayerStats* link_stats_ptr = &link_stats;
681 
682     on_link_layer_stats_result_internal_callback = [&link_stats_ptr](
683                                                            wifi_request_id /* id */,
684                                                            wifi_iface_stat* iface_stats_ptr,
685                                                            int num_radios,
686                                                            wifi_radio_stat* radio_stats_ptr) {
687         wifi_radio_stat* l_radio_stats_ptr;
688         wifi_peer_info* l_peer_info_stats_ptr;
689 
690         if (iface_stats_ptr != nullptr) {
691             link_stats_ptr->iface = *iface_stats_ptr;
692             l_peer_info_stats_ptr = iface_stats_ptr->peer_info;
693             for (uint32_t i = 0; i < iface_stats_ptr->num_peers; i++) {
694                 WifiPeerInfo peer;
695                 peer.peer_info = *l_peer_info_stats_ptr;
696                 if (l_peer_info_stats_ptr->num_rate > 0) {
697                     /* Copy the rate stats */
698                     peer.rate_stats.assign(
699                             l_peer_info_stats_ptr->rate_stats,
700                             l_peer_info_stats_ptr->rate_stats + l_peer_info_stats_ptr->num_rate);
701                 }
702                 peer.peer_info.num_rate = 0;
703                 link_stats_ptr->peers.push_back(peer);
704                 l_peer_info_stats_ptr =
705                         (wifi_peer_info*)((u8*)l_peer_info_stats_ptr + sizeof(wifi_peer_info) +
706                                           (sizeof(wifi_rate_stat) *
707                                            l_peer_info_stats_ptr->num_rate));
708             }
709             link_stats_ptr->iface.num_peers = 0;
710         } else {
711             LOG(ERROR) << "Invalid iface stats in link layer stats";
712         }
713         if (num_radios <= 0 || radio_stats_ptr == nullptr) {
714             LOG(ERROR) << "Invalid radio stats in link layer stats";
715             return;
716         }
717         l_radio_stats_ptr = radio_stats_ptr;
718         for (int i = 0; i < num_radios; i++) {
719             LinkLayerRadioStats radio;
720 
721             radio.stats = *l_radio_stats_ptr;
722             // Copy over the tx level array to the separate vector.
723             if (l_radio_stats_ptr->num_tx_levels > 0 &&
724                 l_radio_stats_ptr->tx_time_per_levels != nullptr) {
725                 radio.tx_time_per_levels.assign(
726                         l_radio_stats_ptr->tx_time_per_levels,
727                         l_radio_stats_ptr->tx_time_per_levels + l_radio_stats_ptr->num_tx_levels);
728             }
729             radio.stats.num_tx_levels = 0;
730             radio.stats.tx_time_per_levels = nullptr;
731             /* Copy over the channel stat to separate vector */
732             if (l_radio_stats_ptr->num_channels > 0) {
733                 /* Copy the channel stats */
734                 radio.channel_stats.assign(
735                         l_radio_stats_ptr->channels,
736                         l_radio_stats_ptr->channels + l_radio_stats_ptr->num_channels);
737             }
738             link_stats_ptr->radios.push_back(radio);
739             l_radio_stats_ptr =
740                     (wifi_radio_stat*)((u8*)l_radio_stats_ptr + sizeof(wifi_radio_stat) +
741                                        (sizeof(wifi_channel_stat) *
742                                         l_radio_stats_ptr->num_channels));
743         }
744     };
745 
746     wifi_error status = global_func_table_.wifi_get_link_stats(0, getIfaceHandle(iface_name),
747                                                                {onSyncLinkLayerStatsResult});
748     on_link_layer_stats_result_internal_callback = nullptr;
749     return {status, link_stats};
750 }
751 
startRssiMonitoring(const std::string & iface_name,wifi_request_id id,int8_t max_rssi,int8_t min_rssi,const on_rssi_threshold_breached_callback & on_threshold_breached_user_callback)752 wifi_error WifiLegacyHal::startRssiMonitoring(
753         const std::string& iface_name, wifi_request_id id, int8_t max_rssi, int8_t min_rssi,
754         const on_rssi_threshold_breached_callback& on_threshold_breached_user_callback) {
755     if (on_rssi_threshold_breached_internal_callback) {
756         return WIFI_ERROR_NOT_AVAILABLE;
757     }
758     on_rssi_threshold_breached_internal_callback = [on_threshold_breached_user_callback](
759                                                            wifi_request_id id, uint8_t* bssid_ptr,
760                                                            int8_t rssi) {
761         if (!bssid_ptr) {
762             return;
763         }
764         std::array<uint8_t, 6> bssid_arr;
765         // |bssid_ptr| pointer is assumed to have 6 bytes for the mac
766         // address.
767         std::copy(bssid_ptr, bssid_ptr + 6, std::begin(bssid_arr));
768         on_threshold_breached_user_callback(id, bssid_arr, rssi);
769     };
770     wifi_error status = global_func_table_.wifi_start_rssi_monitoring(
771             id, getIfaceHandle(iface_name), max_rssi, min_rssi, {onAsyncRssiThresholdBreached});
772     if (status != WIFI_SUCCESS) {
773         on_rssi_threshold_breached_internal_callback = nullptr;
774     }
775     return status;
776 }
777 
stopRssiMonitoring(const std::string & iface_name,wifi_request_id id)778 wifi_error WifiLegacyHal::stopRssiMonitoring(const std::string& iface_name, wifi_request_id id) {
779     if (!on_rssi_threshold_breached_internal_callback) {
780         return WIFI_ERROR_NOT_AVAILABLE;
781     }
782     wifi_error status =
783             global_func_table_.wifi_stop_rssi_monitoring(id, getIfaceHandle(iface_name));
784     // If the request Id is wrong, don't stop the ongoing rssi monitoring. Any
785     // other error should be treated as the end of background scan.
786     if (status != WIFI_ERROR_INVALID_REQUEST_ID) {
787         on_rssi_threshold_breached_internal_callback = nullptr;
788     }
789     return status;
790 }
791 
getRoamingCapabilities(const std::string & iface_name)792 std::pair<wifi_error, wifi_roaming_capabilities> WifiLegacyHal::getRoamingCapabilities(
793         const std::string& iface_name) {
794     wifi_roaming_capabilities caps;
795     wifi_error status =
796             global_func_table_.wifi_get_roaming_capabilities(getIfaceHandle(iface_name), &caps);
797     return {status, caps};
798 }
799 
configureRoaming(const std::string & iface_name,const wifi_roaming_config & config)800 wifi_error WifiLegacyHal::configureRoaming(const std::string& iface_name,
801                                            const wifi_roaming_config& config) {
802     wifi_roaming_config config_internal = config;
803     return global_func_table_.wifi_configure_roaming(getIfaceHandle(iface_name), &config_internal);
804 }
805 
enableFirmwareRoaming(const std::string & iface_name,fw_roaming_state_t state)806 wifi_error WifiLegacyHal::enableFirmwareRoaming(const std::string& iface_name,
807                                                 fw_roaming_state_t state) {
808     return global_func_table_.wifi_enable_firmware_roaming(getIfaceHandle(iface_name), state);
809 }
810 
configureNdOffload(const std::string & iface_name,bool enable)811 wifi_error WifiLegacyHal::configureNdOffload(const std::string& iface_name, bool enable) {
812     return global_func_table_.wifi_configure_nd_offload(getIfaceHandle(iface_name), enable);
813 }
814 
startSendingOffloadedPacket(const std::string & iface_name,uint32_t cmd_id,uint16_t ether_type,const std::vector<uint8_t> & ip_packet_data,const std::array<uint8_t,6> & src_address,const std::array<uint8_t,6> & dst_address,uint32_t period_in_ms)815 wifi_error WifiLegacyHal::startSendingOffloadedPacket(const std::string& iface_name,
816                                                       uint32_t cmd_id, uint16_t ether_type,
817                                                       const std::vector<uint8_t>& ip_packet_data,
818                                                       const std::array<uint8_t, 6>& src_address,
819                                                       const std::array<uint8_t, 6>& dst_address,
820                                                       uint32_t period_in_ms) {
821     std::vector<uint8_t> ip_packet_data_internal(ip_packet_data);
822     std::vector<uint8_t> src_address_internal(src_address.data(),
823                                               src_address.data() + src_address.size());
824     std::vector<uint8_t> dst_address_internal(dst_address.data(),
825                                               dst_address.data() + dst_address.size());
826     return global_func_table_.wifi_start_sending_offloaded_packet(
827             cmd_id, getIfaceHandle(iface_name), ether_type, ip_packet_data_internal.data(),
828             ip_packet_data_internal.size(), src_address_internal.data(),
829             dst_address_internal.data(), period_in_ms);
830 }
831 
stopSendingOffloadedPacket(const std::string & iface_name,uint32_t cmd_id)832 wifi_error WifiLegacyHal::stopSendingOffloadedPacket(const std::string& iface_name,
833                                                      uint32_t cmd_id) {
834     return global_func_table_.wifi_stop_sending_offloaded_packet(cmd_id,
835                                                                  getIfaceHandle(iface_name));
836 }
837 
selectTxPowerScenario(const std::string & iface_name,wifi_power_scenario scenario)838 wifi_error WifiLegacyHal::selectTxPowerScenario(const std::string& iface_name,
839                                                 wifi_power_scenario scenario) {
840     return global_func_table_.wifi_select_tx_power_scenario(getIfaceHandle(iface_name), scenario);
841 }
842 
resetTxPowerScenario(const std::string & iface_name)843 wifi_error WifiLegacyHal::resetTxPowerScenario(const std::string& iface_name) {
844     return global_func_table_.wifi_reset_tx_power_scenario(getIfaceHandle(iface_name));
845 }
846 
setLatencyMode(const std::string & iface_name,wifi_latency_mode mode)847 wifi_error WifiLegacyHal::setLatencyMode(const std::string& iface_name, wifi_latency_mode mode) {
848     return global_func_table_.wifi_set_latency_mode(getIfaceHandle(iface_name), mode);
849 }
850 
setThermalMitigationMode(wifi_thermal_mode mode,uint32_t completion_window)851 wifi_error WifiLegacyHal::setThermalMitigationMode(wifi_thermal_mode mode,
852                                                    uint32_t completion_window) {
853     return global_func_table_.wifi_set_thermal_mitigation_mode(global_handle_, mode,
854                                                                completion_window);
855 }
856 
setDscpToAccessCategoryMapping(uint32_t start,uint32_t end,uint32_t access_category)857 wifi_error WifiLegacyHal::setDscpToAccessCategoryMapping(uint32_t start, uint32_t end,
858                                                          uint32_t access_category) {
859     return global_func_table_.wifi_map_dscp_access_category(global_handle_, start, end,
860                                                             access_category);
861 }
862 
resetDscpToAccessCategoryMapping()863 wifi_error WifiLegacyHal::resetDscpToAccessCategoryMapping() {
864     return global_func_table_.wifi_reset_dscp_mapping(global_handle_);
865 }
866 
getLoggerSupportedFeatureSet(const std::string & iface_name)867 std::pair<wifi_error, uint32_t> WifiLegacyHal::getLoggerSupportedFeatureSet(
868         const std::string& iface_name) {
869     uint32_t supported_feature_flags = 0;
870     wifi_error status = WIFI_SUCCESS;
871 
872     wifi_interface_handle iface_handle = getIfaceHandle(iface_name);
873 
874     if (iface_handle) {
875         status = global_func_table_.wifi_get_logger_supported_feature_set(iface_handle,
876                                                                           &supported_feature_flags);
877     }
878     return {status, supported_feature_flags};
879 }
880 
startPktFateMonitoring(const std::string & iface_name)881 wifi_error WifiLegacyHal::startPktFateMonitoring(const std::string& iface_name) {
882     return global_func_table_.wifi_start_pkt_fate_monitoring(getIfaceHandle(iface_name));
883 }
884 
getTxPktFates(const std::string & iface_name)885 std::pair<wifi_error, std::vector<wifi_tx_report>> WifiLegacyHal::getTxPktFates(
886         const std::string& iface_name) {
887     std::vector<wifi_tx_report> tx_pkt_fates;
888     tx_pkt_fates.resize(MAX_FATE_LOG_LEN);
889     size_t num_fates = 0;
890     wifi_error status = global_func_table_.wifi_get_tx_pkt_fates(
891             getIfaceHandle(iface_name), tx_pkt_fates.data(), tx_pkt_fates.size(), &num_fates);
892     CHECK(num_fates <= MAX_FATE_LOG_LEN);
893     tx_pkt_fates.resize(num_fates);
894     return {status, std::move(tx_pkt_fates)};
895 }
896 
getRxPktFates(const std::string & iface_name)897 std::pair<wifi_error, std::vector<wifi_rx_report>> WifiLegacyHal::getRxPktFates(
898         const std::string& iface_name) {
899     std::vector<wifi_rx_report> rx_pkt_fates;
900     rx_pkt_fates.resize(MAX_FATE_LOG_LEN);
901     size_t num_fates = 0;
902     wifi_error status = global_func_table_.wifi_get_rx_pkt_fates(
903             getIfaceHandle(iface_name), rx_pkt_fates.data(), rx_pkt_fates.size(), &num_fates);
904     CHECK(num_fates <= MAX_FATE_LOG_LEN);
905     rx_pkt_fates.resize(num_fates);
906     return {status, std::move(rx_pkt_fates)};
907 }
908 
getWakeReasonStats(const std::string & iface_name)909 std::pair<wifi_error, WakeReasonStats> WifiLegacyHal::getWakeReasonStats(
910         const std::string& iface_name) {
911     WakeReasonStats stats;
912     stats.cmd_event_wake_cnt.resize(kMaxWakeReasonStatsArraySize);
913     stats.driver_fw_local_wake_cnt.resize(kMaxWakeReasonStatsArraySize);
914 
915     // This legacy struct needs separate memory to store the variable sized wake
916     // reason types.
917     stats.wake_reason_cnt.cmd_event_wake_cnt =
918             reinterpret_cast<int32_t*>(stats.cmd_event_wake_cnt.data());
919     stats.wake_reason_cnt.cmd_event_wake_cnt_sz = stats.cmd_event_wake_cnt.size();
920     stats.wake_reason_cnt.cmd_event_wake_cnt_used = 0;
921     stats.wake_reason_cnt.driver_fw_local_wake_cnt =
922             reinterpret_cast<int32_t*>(stats.driver_fw_local_wake_cnt.data());
923     stats.wake_reason_cnt.driver_fw_local_wake_cnt_sz = stats.driver_fw_local_wake_cnt.size();
924     stats.wake_reason_cnt.driver_fw_local_wake_cnt_used = 0;
925 
926     wifi_error status = global_func_table_.wifi_get_wake_reason_stats(getIfaceHandle(iface_name),
927                                                                       &stats.wake_reason_cnt);
928 
929     CHECK(stats.wake_reason_cnt.cmd_event_wake_cnt_used >= 0 &&
930           static_cast<uint32_t>(stats.wake_reason_cnt.cmd_event_wake_cnt_used) <=
931                   kMaxWakeReasonStatsArraySize);
932     stats.cmd_event_wake_cnt.resize(stats.wake_reason_cnt.cmd_event_wake_cnt_used);
933     stats.wake_reason_cnt.cmd_event_wake_cnt = nullptr;
934 
935     CHECK(stats.wake_reason_cnt.driver_fw_local_wake_cnt_used >= 0 &&
936           static_cast<uint32_t>(stats.wake_reason_cnt.driver_fw_local_wake_cnt_used) <=
937                   kMaxWakeReasonStatsArraySize);
938     stats.driver_fw_local_wake_cnt.resize(stats.wake_reason_cnt.driver_fw_local_wake_cnt_used);
939     stats.wake_reason_cnt.driver_fw_local_wake_cnt = nullptr;
940 
941     return {status, stats};
942 }
943 
registerRingBufferCallbackHandler(const std::string & iface_name,const on_ring_buffer_data_callback & on_user_data_callback)944 wifi_error WifiLegacyHal::registerRingBufferCallbackHandler(
945         const std::string& iface_name, const on_ring_buffer_data_callback& on_user_data_callback) {
946     if (on_ring_buffer_data_internal_callback) {
947         return WIFI_ERROR_NOT_AVAILABLE;
948     }
949     on_ring_buffer_data_internal_callback = [on_user_data_callback](
950                                                     char* ring_name, char* buffer, int buffer_size,
951                                                     wifi_ring_buffer_status* status) {
952         if (status && buffer) {
953             std::vector<uint8_t> buffer_vector(reinterpret_cast<uint8_t*>(buffer),
954                                                reinterpret_cast<uint8_t*>(buffer) + buffer_size);
955             on_user_data_callback(ring_name, buffer_vector, *status);
956         }
957     };
958     wifi_error status = global_func_table_.wifi_set_log_handler(0, getIfaceHandle(iface_name),
959                                                                 {onAsyncRingBufferData});
960     if (status != WIFI_SUCCESS) {
961         on_ring_buffer_data_internal_callback = nullptr;
962     }
963     return status;
964 }
965 
deregisterRingBufferCallbackHandler(const std::string & iface_name)966 wifi_error WifiLegacyHal::deregisterRingBufferCallbackHandler(const std::string& iface_name) {
967     if (!on_ring_buffer_data_internal_callback) {
968         return WIFI_ERROR_NOT_AVAILABLE;
969     }
970     on_ring_buffer_data_internal_callback = nullptr;
971     return global_func_table_.wifi_reset_log_handler(0, getIfaceHandle(iface_name));
972 }
973 
getRingBuffersStatus(const std::string & iface_name)974 std::pair<wifi_error, std::vector<wifi_ring_buffer_status>> WifiLegacyHal::getRingBuffersStatus(
975         const std::string& iface_name) {
976     std::vector<wifi_ring_buffer_status> ring_buffers_status;
977     ring_buffers_status.resize(kMaxRingBuffers);
978     uint32_t num_rings = kMaxRingBuffers;
979     wifi_error status = global_func_table_.wifi_get_ring_buffers_status(
980             getIfaceHandle(iface_name), &num_rings, ring_buffers_status.data());
981     CHECK(num_rings <= kMaxRingBuffers);
982     ring_buffers_status.resize(num_rings);
983     return {status, std::move(ring_buffers_status)};
984 }
985 
startRingBufferLogging(const std::string & iface_name,const std::string & ring_name,uint32_t verbose_level,uint32_t max_interval_sec,uint32_t min_data_size)986 wifi_error WifiLegacyHal::startRingBufferLogging(const std::string& iface_name,
987                                                  const std::string& ring_name,
988                                                  uint32_t verbose_level, uint32_t max_interval_sec,
989                                                  uint32_t min_data_size) {
990     return global_func_table_.wifi_start_logging(getIfaceHandle(iface_name), verbose_level, 0,
991                                                  max_interval_sec, min_data_size,
992                                                  makeCharVec(ring_name).data());
993 }
994 
getRingBufferData(const std::string & iface_name,const std::string & ring_name)995 wifi_error WifiLegacyHal::getRingBufferData(const std::string& iface_name,
996                                             const std::string& ring_name) {
997     return global_func_table_.wifi_get_ring_data(getIfaceHandle(iface_name),
998                                                  makeCharVec(ring_name).data());
999 }
1000 
registerErrorAlertCallbackHandler(const std::string & iface_name,const on_error_alert_callback & on_user_alert_callback)1001 wifi_error WifiLegacyHal::registerErrorAlertCallbackHandler(
1002         const std::string& iface_name, const on_error_alert_callback& on_user_alert_callback) {
1003     if (on_error_alert_internal_callback) {
1004         return WIFI_ERROR_NOT_AVAILABLE;
1005     }
1006     on_error_alert_internal_callback = [on_user_alert_callback](wifi_request_id id, char* buffer,
1007                                                                 int buffer_size, int err_code) {
1008         if (buffer) {
1009             CHECK(id == 0);
1010             on_user_alert_callback(
1011                     err_code,
1012                     std::vector<uint8_t>(reinterpret_cast<uint8_t*>(buffer),
1013                                          reinterpret_cast<uint8_t*>(buffer) + buffer_size));
1014         }
1015     };
1016     wifi_error status = global_func_table_.wifi_set_alert_handler(0, getIfaceHandle(iface_name),
1017                                                                   {onAsyncErrorAlert});
1018     if (status != WIFI_SUCCESS) {
1019         on_error_alert_internal_callback = nullptr;
1020     }
1021     return status;
1022 }
1023 
deregisterErrorAlertCallbackHandler(const std::string & iface_name)1024 wifi_error WifiLegacyHal::deregisterErrorAlertCallbackHandler(const std::string& iface_name) {
1025     if (!on_error_alert_internal_callback) {
1026         return WIFI_ERROR_NOT_AVAILABLE;
1027     }
1028     on_error_alert_internal_callback = nullptr;
1029     return global_func_table_.wifi_reset_alert_handler(0, getIfaceHandle(iface_name));
1030 }
1031 
registerRadioModeChangeCallbackHandler(const std::string & iface_name,const on_radio_mode_change_callback & on_user_change_callback)1032 wifi_error WifiLegacyHal::registerRadioModeChangeCallbackHandler(
1033         const std::string& iface_name,
1034         const on_radio_mode_change_callback& on_user_change_callback) {
1035     if (on_radio_mode_change_internal_callback) {
1036         return WIFI_ERROR_NOT_AVAILABLE;
1037     }
1038     on_radio_mode_change_internal_callback = [on_user_change_callback](
1039                                                      wifi_request_id /* id */, uint32_t num_macs,
1040                                                      wifi_mac_info* mac_infos_arr) {
1041         if (num_macs > 0 && mac_infos_arr) {
1042             std::vector<WifiMacInfo> mac_infos_vec;
1043             for (uint32_t i = 0; i < num_macs; i++) {
1044                 WifiMacInfo mac_info;
1045                 mac_info.wlan_mac_id = mac_infos_arr[i].wlan_mac_id;
1046                 mac_info.mac_band = mac_infos_arr[i].mac_band;
1047                 for (int32_t j = 0; j < mac_infos_arr[i].num_iface; j++) {
1048                     WifiIfaceInfo iface_info;
1049                     iface_info.name = mac_infos_arr[i].iface_info[j].iface_name;
1050                     iface_info.channel = mac_infos_arr[i].iface_info[j].channel;
1051                     mac_info.iface_infos.push_back(iface_info);
1052                 }
1053                 mac_infos_vec.push_back(mac_info);
1054             }
1055             on_user_change_callback(mac_infos_vec);
1056         }
1057     };
1058     wifi_error status = global_func_table_.wifi_set_radio_mode_change_handler(
1059             0, getIfaceHandle(iface_name), {onAsyncRadioModeChange});
1060     if (status != WIFI_SUCCESS) {
1061         on_radio_mode_change_internal_callback = nullptr;
1062     }
1063     return status;
1064 }
1065 
registerSubsystemRestartCallbackHandler(const on_subsystem_restart_callback & on_restart_callback)1066 wifi_error WifiLegacyHal::registerSubsystemRestartCallbackHandler(
1067         const on_subsystem_restart_callback& on_restart_callback) {
1068     if (on_subsystem_restart_internal_callback) {
1069         return WIFI_ERROR_NOT_AVAILABLE;
1070     }
1071     on_subsystem_restart_internal_callback = [on_restart_callback](const char* error) {
1072         on_restart_callback(error);
1073     };
1074     wifi_error status = global_func_table_.wifi_set_subsystem_restart_handler(
1075             global_handle_, {onAsyncSubsystemRestart});
1076     if (status != WIFI_SUCCESS) {
1077         on_subsystem_restart_internal_callback = nullptr;
1078     }
1079     return status;
1080 }
1081 
startRttRangeRequest(const std::string & iface_name,wifi_request_id id,const std::vector<wifi_rtt_config> & rtt_configs,const on_rtt_results_callback & on_results_user_callback)1082 wifi_error WifiLegacyHal::startRttRangeRequest(
1083         const std::string& iface_name, wifi_request_id id,
1084         const std::vector<wifi_rtt_config>& rtt_configs,
1085         const on_rtt_results_callback& on_results_user_callback) {
1086     if (on_rtt_results_internal_callback) {
1087         return WIFI_ERROR_NOT_AVAILABLE;
1088     }
1089 
1090     on_rtt_results_internal_callback = [on_results_user_callback](wifi_request_id id,
1091                                                                   unsigned num_results,
1092                                                                   wifi_rtt_result* rtt_results[]) {
1093         if (num_results > 0 && !rtt_results) {
1094             LOG(ERROR) << "Unexpected nullptr in RTT results";
1095             return;
1096         }
1097         std::vector<const wifi_rtt_result*> rtt_results_vec;
1098         std::copy_if(rtt_results, rtt_results + num_results, back_inserter(rtt_results_vec),
1099                      [](wifi_rtt_result* rtt_result) { return rtt_result != nullptr; });
1100         on_results_user_callback(id, rtt_results_vec);
1101     };
1102 
1103     std::vector<wifi_rtt_config> rtt_configs_internal(rtt_configs);
1104     wifi_error status = global_func_table_.wifi_rtt_range_request(
1105             id, getIfaceHandle(iface_name), rtt_configs.size(), rtt_configs_internal.data(),
1106             {onAsyncRttResults});
1107     if (status != WIFI_SUCCESS) {
1108         on_rtt_results_internal_callback = nullptr;
1109     }
1110     return status;
1111 }
1112 
cancelRttRangeRequest(const std::string & iface_name,wifi_request_id id,const std::vector<std::array<uint8_t,6>> & mac_addrs)1113 wifi_error WifiLegacyHal::cancelRttRangeRequest(
1114         const std::string& iface_name, wifi_request_id id,
1115         const std::vector<std::array<uint8_t, 6>>& mac_addrs) {
1116     if (!on_rtt_results_internal_callback) {
1117         return WIFI_ERROR_NOT_AVAILABLE;
1118     }
1119     static_assert(sizeof(mac_addr) == sizeof(std::array<uint8_t, 6>), "MAC address size mismatch");
1120     // TODO: How do we handle partial cancels (i.e only a subset of enabled mac
1121     // addressed are cancelled).
1122     std::vector<std::array<uint8_t, 6>> mac_addrs_internal(mac_addrs);
1123     wifi_error status = global_func_table_.wifi_rtt_range_cancel(
1124             id, getIfaceHandle(iface_name), mac_addrs.size(),
1125             reinterpret_cast<mac_addr*>(mac_addrs_internal.data()));
1126     // If the request Id is wrong, don't stop the ongoing range request. Any
1127     // other error should be treated as the end of rtt ranging.
1128     if (status != WIFI_ERROR_INVALID_REQUEST_ID) {
1129         on_rtt_results_internal_callback = nullptr;
1130     }
1131     return status;
1132 }
1133 
getRttCapabilities(const std::string & iface_name)1134 std::pair<wifi_error, wifi_rtt_capabilities> WifiLegacyHal::getRttCapabilities(
1135         const std::string& iface_name) {
1136     wifi_rtt_capabilities rtt_caps;
1137     wifi_error status =
1138             global_func_table_.wifi_get_rtt_capabilities(getIfaceHandle(iface_name), &rtt_caps);
1139     return {status, rtt_caps};
1140 }
1141 
getRttResponderInfo(const std::string & iface_name)1142 std::pair<wifi_error, wifi_rtt_responder> WifiLegacyHal::getRttResponderInfo(
1143         const std::string& iface_name) {
1144     wifi_rtt_responder rtt_responder;
1145     wifi_error status = global_func_table_.wifi_rtt_get_responder_info(getIfaceHandle(iface_name),
1146                                                                        &rtt_responder);
1147     return {status, rtt_responder};
1148 }
1149 
enableRttResponder(const std::string & iface_name,wifi_request_id id,const wifi_channel_info & channel_hint,uint32_t max_duration_secs,const wifi_rtt_responder & info)1150 wifi_error WifiLegacyHal::enableRttResponder(const std::string& iface_name, wifi_request_id id,
1151                                              const wifi_channel_info& channel_hint,
1152                                              uint32_t max_duration_secs,
1153                                              const wifi_rtt_responder& info) {
1154     wifi_rtt_responder info_internal(info);
1155     return global_func_table_.wifi_enable_responder(id, getIfaceHandle(iface_name), channel_hint,
1156                                                     max_duration_secs, &info_internal);
1157 }
1158 
disableRttResponder(const std::string & iface_name,wifi_request_id id)1159 wifi_error WifiLegacyHal::disableRttResponder(const std::string& iface_name, wifi_request_id id) {
1160     return global_func_table_.wifi_disable_responder(id, getIfaceHandle(iface_name));
1161 }
1162 
setRttLci(const std::string & iface_name,wifi_request_id id,const wifi_lci_information & info)1163 wifi_error WifiLegacyHal::setRttLci(const std::string& iface_name, wifi_request_id id,
1164                                     const wifi_lci_information& info) {
1165     wifi_lci_information info_internal(info);
1166     return global_func_table_.wifi_set_lci(id, getIfaceHandle(iface_name), &info_internal);
1167 }
1168 
setRttLcr(const std::string & iface_name,wifi_request_id id,const wifi_lcr_information & info)1169 wifi_error WifiLegacyHal::setRttLcr(const std::string& iface_name, wifi_request_id id,
1170                                     const wifi_lcr_information& info) {
1171     wifi_lcr_information info_internal(info);
1172     return global_func_table_.wifi_set_lcr(id, getIfaceHandle(iface_name), &info_internal);
1173 }
1174 
nanRegisterCallbackHandlers(const std::string & iface_name,const NanCallbackHandlers & user_callbacks)1175 wifi_error WifiLegacyHal::nanRegisterCallbackHandlers(const std::string& iface_name,
1176                                                       const NanCallbackHandlers& user_callbacks) {
1177     on_nan_notify_response_user_callback = user_callbacks.on_notify_response;
1178     on_nan_event_publish_terminated_user_callback = user_callbacks.on_event_publish_terminated;
1179     on_nan_event_match_user_callback = user_callbacks.on_event_match;
1180     on_nan_event_match_expired_user_callback = user_callbacks.on_event_match_expired;
1181     on_nan_event_subscribe_terminated_user_callback = user_callbacks.on_event_subscribe_terminated;
1182     on_nan_event_followup_user_callback = user_callbacks.on_event_followup;
1183     on_nan_event_disc_eng_event_user_callback = user_callbacks.on_event_disc_eng_event;
1184     on_nan_event_disabled_user_callback = user_callbacks.on_event_disabled;
1185     on_nan_event_tca_user_callback = user_callbacks.on_event_tca;
1186     on_nan_event_beacon_sdf_payload_user_callback = user_callbacks.on_event_beacon_sdf_payload;
1187     on_nan_event_data_path_request_user_callback = user_callbacks.on_event_data_path_request;
1188     on_nan_event_data_path_confirm_user_callback = user_callbacks.on_event_data_path_confirm;
1189     on_nan_event_data_path_end_user_callback = user_callbacks.on_event_data_path_end;
1190     on_nan_event_transmit_follow_up_user_callback = user_callbacks.on_event_transmit_follow_up;
1191     on_nan_event_range_request_user_callback = user_callbacks.on_event_range_request;
1192     on_nan_event_range_report_user_callback = user_callbacks.on_event_range_report;
1193     on_nan_event_schedule_update_user_callback = user_callbacks.on_event_schedule_update;
1194 
1195     return global_func_table_.wifi_nan_register_handler(
1196             getIfaceHandle(iface_name),
1197             {onAysncNanNotifyResponse, onAysncNanEventPublishReplied,
1198              onAysncNanEventPublishTerminated, onAysncNanEventMatch, onAysncNanEventMatchExpired,
1199              onAysncNanEventSubscribeTerminated, onAysncNanEventFollowup,
1200              onAysncNanEventDiscEngEvent, onAysncNanEventDisabled, onAysncNanEventTca,
1201              onAysncNanEventBeaconSdfPayload, onAysncNanEventDataPathRequest,
1202              onAysncNanEventDataPathConfirm, onAysncNanEventDataPathEnd,
1203              onAysncNanEventTransmitFollowUp, onAysncNanEventRangeRequest,
1204              onAysncNanEventRangeReport, onAsyncNanEventScheduleUpdate});
1205 }
1206 
nanEnableRequest(const std::string & iface_name,transaction_id id,const NanEnableRequest & msg)1207 wifi_error WifiLegacyHal::nanEnableRequest(const std::string& iface_name, transaction_id id,
1208                                            const NanEnableRequest& msg) {
1209     NanEnableRequest msg_internal(msg);
1210     return global_func_table_.wifi_nan_enable_request(id, getIfaceHandle(iface_name),
1211                                                       &msg_internal);
1212 }
1213 
nanDisableRequest(const std::string & iface_name,transaction_id id)1214 wifi_error WifiLegacyHal::nanDisableRequest(const std::string& iface_name, transaction_id id) {
1215     return global_func_table_.wifi_nan_disable_request(id, getIfaceHandle(iface_name));
1216 }
1217 
nanPublishRequest(const std::string & iface_name,transaction_id id,const NanPublishRequest & msg)1218 wifi_error WifiLegacyHal::nanPublishRequest(const std::string& iface_name, transaction_id id,
1219                                             const NanPublishRequest& msg) {
1220     NanPublishRequest msg_internal(msg);
1221     return global_func_table_.wifi_nan_publish_request(id, getIfaceHandle(iface_name),
1222                                                        &msg_internal);
1223 }
1224 
nanPublishCancelRequest(const std::string & iface_name,transaction_id id,const NanPublishCancelRequest & msg)1225 wifi_error WifiLegacyHal::nanPublishCancelRequest(const std::string& iface_name, transaction_id id,
1226                                                   const NanPublishCancelRequest& msg) {
1227     NanPublishCancelRequest msg_internal(msg);
1228     return global_func_table_.wifi_nan_publish_cancel_request(id, getIfaceHandle(iface_name),
1229                                                               &msg_internal);
1230 }
1231 
nanSubscribeRequest(const std::string & iface_name,transaction_id id,const NanSubscribeRequest & msg)1232 wifi_error WifiLegacyHal::nanSubscribeRequest(const std::string& iface_name, transaction_id id,
1233                                               const NanSubscribeRequest& msg) {
1234     NanSubscribeRequest msg_internal(msg);
1235     return global_func_table_.wifi_nan_subscribe_request(id, getIfaceHandle(iface_name),
1236                                                          &msg_internal);
1237 }
1238 
nanSubscribeCancelRequest(const std::string & iface_name,transaction_id id,const NanSubscribeCancelRequest & msg)1239 wifi_error WifiLegacyHal::nanSubscribeCancelRequest(const std::string& iface_name,
1240                                                     transaction_id id,
1241                                                     const NanSubscribeCancelRequest& msg) {
1242     NanSubscribeCancelRequest msg_internal(msg);
1243     return global_func_table_.wifi_nan_subscribe_cancel_request(id, getIfaceHandle(iface_name),
1244                                                                 &msg_internal);
1245 }
1246 
nanTransmitFollowupRequest(const std::string & iface_name,transaction_id id,const NanTransmitFollowupRequest & msg)1247 wifi_error WifiLegacyHal::nanTransmitFollowupRequest(const std::string& iface_name,
1248                                                      transaction_id id,
1249                                                      const NanTransmitFollowupRequest& msg) {
1250     NanTransmitFollowupRequest msg_internal(msg);
1251     return global_func_table_.wifi_nan_transmit_followup_request(id, getIfaceHandle(iface_name),
1252                                                                  &msg_internal);
1253 }
1254 
nanStatsRequest(const std::string & iface_name,transaction_id id,const NanStatsRequest & msg)1255 wifi_error WifiLegacyHal::nanStatsRequest(const std::string& iface_name, transaction_id id,
1256                                           const NanStatsRequest& msg) {
1257     NanStatsRequest msg_internal(msg);
1258     return global_func_table_.wifi_nan_stats_request(id, getIfaceHandle(iface_name), &msg_internal);
1259 }
1260 
nanConfigRequest(const std::string & iface_name,transaction_id id,const NanConfigRequest & msg)1261 wifi_error WifiLegacyHal::nanConfigRequest(const std::string& iface_name, transaction_id id,
1262                                            const NanConfigRequest& msg) {
1263     NanConfigRequest msg_internal(msg);
1264     return global_func_table_.wifi_nan_config_request(id, getIfaceHandle(iface_name),
1265                                                       &msg_internal);
1266 }
1267 
nanTcaRequest(const std::string & iface_name,transaction_id id,const NanTCARequest & msg)1268 wifi_error WifiLegacyHal::nanTcaRequest(const std::string& iface_name, transaction_id id,
1269                                         const NanTCARequest& msg) {
1270     NanTCARequest msg_internal(msg);
1271     return global_func_table_.wifi_nan_tca_request(id, getIfaceHandle(iface_name), &msg_internal);
1272 }
1273 
nanBeaconSdfPayloadRequest(const std::string & iface_name,transaction_id id,const NanBeaconSdfPayloadRequest & msg)1274 wifi_error WifiLegacyHal::nanBeaconSdfPayloadRequest(const std::string& iface_name,
1275                                                      transaction_id id,
1276                                                      const NanBeaconSdfPayloadRequest& msg) {
1277     NanBeaconSdfPayloadRequest msg_internal(msg);
1278     return global_func_table_.wifi_nan_beacon_sdf_payload_request(id, getIfaceHandle(iface_name),
1279                                                                   &msg_internal);
1280 }
1281 
nanGetVersion()1282 std::pair<wifi_error, NanVersion> WifiLegacyHal::nanGetVersion() {
1283     NanVersion version;
1284     wifi_error status = global_func_table_.wifi_nan_get_version(global_handle_, &version);
1285     return {status, version};
1286 }
1287 
nanGetCapabilities(const std::string & iface_name,transaction_id id)1288 wifi_error WifiLegacyHal::nanGetCapabilities(const std::string& iface_name, transaction_id id) {
1289     return global_func_table_.wifi_nan_get_capabilities(id, getIfaceHandle(iface_name));
1290 }
1291 
nanDataInterfaceCreate(const std::string & iface_name,transaction_id id,const std::string & data_iface_name)1292 wifi_error WifiLegacyHal::nanDataInterfaceCreate(const std::string& iface_name, transaction_id id,
1293                                                  const std::string& data_iface_name) {
1294     return global_func_table_.wifi_nan_data_interface_create(id, getIfaceHandle(iface_name),
1295                                                              makeCharVec(data_iface_name).data());
1296 }
1297 
nanDataInterfaceDelete(const std::string & iface_name,transaction_id id,const std::string & data_iface_name)1298 wifi_error WifiLegacyHal::nanDataInterfaceDelete(const std::string& iface_name, transaction_id id,
1299                                                  const std::string& data_iface_name) {
1300     return global_func_table_.wifi_nan_data_interface_delete(id, getIfaceHandle(iface_name),
1301                                                              makeCharVec(data_iface_name).data());
1302 }
1303 
nanDataRequestInitiator(const std::string & iface_name,transaction_id id,const NanDataPathInitiatorRequest & msg)1304 wifi_error WifiLegacyHal::nanDataRequestInitiator(const std::string& iface_name, transaction_id id,
1305                                                   const NanDataPathInitiatorRequest& msg) {
1306     NanDataPathInitiatorRequest msg_internal(msg);
1307     return global_func_table_.wifi_nan_data_request_initiator(id, getIfaceHandle(iface_name),
1308                                                               &msg_internal);
1309 }
1310 
nanDataIndicationResponse(const std::string & iface_name,transaction_id id,const NanDataPathIndicationResponse & msg)1311 wifi_error WifiLegacyHal::nanDataIndicationResponse(const std::string& iface_name,
1312                                                     transaction_id id,
1313                                                     const NanDataPathIndicationResponse& msg) {
1314     NanDataPathIndicationResponse msg_internal(msg);
1315     return global_func_table_.wifi_nan_data_indication_response(id, getIfaceHandle(iface_name),
1316                                                                 &msg_internal);
1317 }
1318 
1319 typedef struct {
1320     u8 num_ndp_instances;
1321     NanDataPathId ndp_instance_id;
1322 } NanDataPathEndSingleNdpIdRequest;
1323 
nanDataEnd(const std::string & iface_name,transaction_id id,uint32_t ndpInstanceId)1324 wifi_error WifiLegacyHal::nanDataEnd(const std::string& iface_name, transaction_id id,
1325                                      uint32_t ndpInstanceId) {
1326     NanDataPathEndSingleNdpIdRequest msg;
1327     msg.num_ndp_instances = 1;
1328     msg.ndp_instance_id = ndpInstanceId;
1329     wifi_error status = global_func_table_.wifi_nan_data_end(id, getIfaceHandle(iface_name),
1330                                                              (NanDataPathEndRequest*)&msg);
1331     return status;
1332 }
1333 
setCountryCode(const std::string & iface_name,std::array<int8_t,2> code)1334 wifi_error WifiLegacyHal::setCountryCode(const std::string& iface_name,
1335                                          std::array<int8_t, 2> code) {
1336     std::string code_str(code.data(), code.data() + code.size());
1337     return global_func_table_.wifi_set_country_code(getIfaceHandle(iface_name), code_str.c_str());
1338 }
1339 
retrieveIfaceHandles()1340 wifi_error WifiLegacyHal::retrieveIfaceHandles() {
1341     wifi_interface_handle* iface_handles = nullptr;
1342     int num_iface_handles = 0;
1343     wifi_error status =
1344             global_func_table_.wifi_get_ifaces(global_handle_, &num_iface_handles, &iface_handles);
1345     if (status != WIFI_SUCCESS) {
1346         LOG(ERROR) << "Failed to enumerate interface handles";
1347         return status;
1348     }
1349     iface_name_to_handle_.clear();
1350     for (int i = 0; i < num_iface_handles; ++i) {
1351         std::array<char, IFNAMSIZ> iface_name_arr = {};
1352         status = global_func_table_.wifi_get_iface_name(iface_handles[i], iface_name_arr.data(),
1353                                                         iface_name_arr.size());
1354         if (status != WIFI_SUCCESS) {
1355             LOG(WARNING) << "Failed to get interface handle name";
1356             continue;
1357         }
1358         // Assuming the interface name is null terminated since the legacy HAL
1359         // API does not return a size.
1360         std::string iface_name(iface_name_arr.data());
1361         LOG(INFO) << "Adding interface handle for " << iface_name;
1362         iface_name_to_handle_[iface_name] = iface_handles[i];
1363     }
1364     return WIFI_SUCCESS;
1365 }
1366 
getIfaceHandle(const std::string & iface_name)1367 wifi_interface_handle WifiLegacyHal::getIfaceHandle(const std::string& iface_name) {
1368     const auto iface_handle_iter = iface_name_to_handle_.find(iface_name);
1369     if (iface_handle_iter == iface_name_to_handle_.end()) {
1370         LOG(ERROR) << "Unknown iface name: " << iface_name;
1371         return nullptr;
1372     }
1373     return iface_handle_iter->second;
1374 }
1375 
runEventLoop()1376 void WifiLegacyHal::runEventLoop() {
1377     LOG(DEBUG) << "Starting legacy HAL event loop";
1378     global_func_table_.wifi_event_loop(global_handle_);
1379     const auto lock = hidl_sync_util::acquireGlobalLock();
1380     if (!awaiting_event_loop_termination_) {
1381         LOG(FATAL) << "Legacy HAL event loop terminated, but HAL was not stopping";
1382     }
1383     LOG(DEBUG) << "Legacy HAL event loop terminated";
1384     awaiting_event_loop_termination_ = false;
1385     stop_wait_cv_.notify_one();
1386 }
1387 
getGscanCachedResults(const std::string & iface_name)1388 std::pair<wifi_error, std::vector<wifi_cached_scan_results>> WifiLegacyHal::getGscanCachedResults(
1389         const std::string& iface_name) {
1390     std::vector<wifi_cached_scan_results> cached_scan_results;
1391     cached_scan_results.resize(kMaxCachedGscanResults);
1392     int32_t num_results = 0;
1393     wifi_error status = global_func_table_.wifi_get_cached_gscan_results(
1394             getIfaceHandle(iface_name), true /* always flush */, cached_scan_results.size(),
1395             cached_scan_results.data(), &num_results);
1396     CHECK(num_results >= 0 && static_cast<uint32_t>(num_results) <= kMaxCachedGscanResults);
1397     cached_scan_results.resize(num_results);
1398     // Check for invalid IE lengths in these cached scan results and correct it.
1399     for (auto& cached_scan_result : cached_scan_results) {
1400         int num_scan_results = cached_scan_result.num_results;
1401         for (int i = 0; i < num_scan_results; i++) {
1402             auto& scan_result = cached_scan_result.results[i];
1403             if (scan_result.ie_length > 0) {
1404                 LOG(DEBUG) << "Cached scan result has non-zero IE length " << scan_result.ie_length;
1405                 scan_result.ie_length = 0;
1406             }
1407         }
1408     }
1409     return {status, std::move(cached_scan_results)};
1410 }
1411 
createVirtualInterface(const std::string & ifname,wifi_interface_type iftype)1412 wifi_error WifiLegacyHal::createVirtualInterface(const std::string& ifname,
1413                                                  wifi_interface_type iftype) {
1414     // Create the interface if it doesn't exist. If interface already exist,
1415     // Vendor Hal should return WIFI_SUCCESS.
1416     wifi_error status = global_func_table_.wifi_virtual_interface_create(global_handle_,
1417                                                                          ifname.c_str(), iftype);
1418     return handleVirtualInterfaceCreateOrDeleteStatus(ifname, status);
1419 }
1420 
deleteVirtualInterface(const std::string & ifname)1421 wifi_error WifiLegacyHal::deleteVirtualInterface(const std::string& ifname) {
1422     // Delete the interface if it was created dynamically.
1423     wifi_error status =
1424             global_func_table_.wifi_virtual_interface_delete(global_handle_, ifname.c_str());
1425     return handleVirtualInterfaceCreateOrDeleteStatus(ifname, status);
1426 }
1427 
handleVirtualInterfaceCreateOrDeleteStatus(const std::string & ifname,wifi_error status)1428 wifi_error WifiLegacyHal::handleVirtualInterfaceCreateOrDeleteStatus(const std::string& ifname,
1429                                                                      wifi_error status) {
1430     if (status == WIFI_SUCCESS) {
1431         // refresh list of handlers now.
1432         status = retrieveIfaceHandles();
1433     } else if (status == WIFI_ERROR_NOT_SUPPORTED) {
1434         // Vendor hal does not implement this API. Such vendor implementations
1435         // are expected to create / delete interface by other means.
1436 
1437         // check if interface exists.
1438         if (if_nametoindex(ifname.c_str())) {
1439             status = retrieveIfaceHandles();
1440         }
1441     }
1442     return status;
1443 }
1444 
getSupportedIfaceName(uint32_t iface_type,std::string & ifname)1445 wifi_error WifiLegacyHal::getSupportedIfaceName(uint32_t iface_type, std::string& ifname) {
1446     std::array<char, IFNAMSIZ> buffer;
1447 
1448     wifi_error res = global_func_table_.wifi_get_supported_iface_name(
1449             global_handle_, (uint32_t)iface_type, buffer.data(), buffer.size());
1450     if (res == WIFI_SUCCESS) ifname = buffer.data();
1451 
1452     return res;
1453 }
1454 
multiStaSetPrimaryConnection(const std::string & ifname)1455 wifi_error WifiLegacyHal::multiStaSetPrimaryConnection(const std::string& ifname) {
1456     return global_func_table_.wifi_multi_sta_set_primary_connection(global_handle_,
1457                                                                     getIfaceHandle(ifname));
1458 }
1459 
multiStaSetUseCase(wifi_multi_sta_use_case use_case)1460 wifi_error WifiLegacyHal::multiStaSetUseCase(wifi_multi_sta_use_case use_case) {
1461     return global_func_table_.wifi_multi_sta_set_use_case(global_handle_, use_case);
1462 }
1463 
setCoexUnsafeChannels(std::vector<wifi_coex_unsafe_channel> unsafe_channels,uint32_t restrictions)1464 wifi_error WifiLegacyHal::setCoexUnsafeChannels(
1465         std::vector<wifi_coex_unsafe_channel> unsafe_channels, uint32_t restrictions) {
1466     return global_func_table_.wifi_set_coex_unsafe_channels(global_handle_, unsafe_channels.size(),
1467                                                             unsafe_channels.data(), restrictions);
1468 }
1469 
setVoipMode(const std::string & iface_name,wifi_voip_mode mode)1470 wifi_error WifiLegacyHal::setVoipMode(const std::string& iface_name, wifi_voip_mode mode) {
1471     return global_func_table_.wifi_set_voip_mode(getIfaceHandle(iface_name), mode);
1472 }
1473 
twtRegisterHandler(const std::string & iface_name,const TwtCallbackHandlers & user_callbacks)1474 wifi_error WifiLegacyHal::twtRegisterHandler(const std::string& iface_name,
1475                                              const TwtCallbackHandlers& user_callbacks) {
1476     on_twt_event_setup_response_callback = user_callbacks.on_setup_response;
1477     on_twt_event_teardown_completion_callback = user_callbacks.on_teardown_completion;
1478     on_twt_event_info_frame_received_callback = user_callbacks.on_info_frame_received;
1479     on_twt_event_device_notify_callback = user_callbacks.on_device_notify;
1480 
1481     return global_func_table_.wifi_twt_register_handler(
1482             getIfaceHandle(iface_name),
1483             {onAsyncTwtEventSetupResponse, onAsyncTwtEventTeardownCompletion,
1484              onAsyncTwtEventInfoFrameReceived, onAsyncTwtEventDeviceNotify});
1485 }
1486 
twtGetCapability(const std::string & iface_name)1487 std::pair<wifi_error, TwtCapabilitySet> WifiLegacyHal::twtGetCapability(
1488         const std::string& iface_name) {
1489     TwtCapabilitySet capSet;
1490     wifi_error status =
1491             global_func_table_.wifi_twt_get_capability(getIfaceHandle(iface_name), &capSet);
1492     return {status, capSet};
1493 }
1494 
twtSetupRequest(const std::string & iface_name,const TwtSetupRequest & msg)1495 wifi_error WifiLegacyHal::twtSetupRequest(const std::string& iface_name,
1496                                           const TwtSetupRequest& msg) {
1497     TwtSetupRequest msgInternal(msg);
1498     return global_func_table_.wifi_twt_setup_request(getIfaceHandle(iface_name), &msgInternal);
1499 }
1500 
twtTearDownRequest(const std::string & iface_name,const TwtTeardownRequest & msg)1501 wifi_error WifiLegacyHal::twtTearDownRequest(const std::string& iface_name,
1502                                              const TwtTeardownRequest& msg) {
1503     TwtTeardownRequest msgInternal(msg);
1504     return global_func_table_.wifi_twt_teardown_request(getIfaceHandle(iface_name), &msgInternal);
1505 }
1506 
twtInfoFrameRequest(const std::string & iface_name,const TwtInfoFrameRequest & msg)1507 wifi_error WifiLegacyHal::twtInfoFrameRequest(const std::string& iface_name,
1508                                               const TwtInfoFrameRequest& msg) {
1509     TwtInfoFrameRequest msgInternal(msg);
1510     return global_func_table_.wifi_twt_info_frame_request(getIfaceHandle(iface_name), &msgInternal);
1511 }
1512 
twtGetStats(const std::string & iface_name,uint8_t configId)1513 std::pair<wifi_error, TwtStats> WifiLegacyHal::twtGetStats(const std::string& iface_name,
1514                                                            uint8_t configId) {
1515     TwtStats stats;
1516     wifi_error status =
1517             global_func_table_.wifi_twt_get_stats(getIfaceHandle(iface_name), configId, &stats);
1518     return {status, stats};
1519 }
1520 
twtClearStats(const std::string & iface_name,uint8_t configId)1521 wifi_error WifiLegacyHal::twtClearStats(const std::string& iface_name, uint8_t configId) {
1522     return global_func_table_.wifi_twt_clear_stats(getIfaceHandle(iface_name), configId);
1523 }
1524 
setDtimConfig(const std::string & iface_name,uint32_t multiplier)1525 wifi_error WifiLegacyHal::setDtimConfig(const std::string& iface_name, uint32_t multiplier) {
1526     return global_func_table_.wifi_set_dtim_config(getIfaceHandle(iface_name), multiplier);
1527 }
1528 
getUsableChannels(uint32_t band_mask,uint32_t iface_mode_mask,uint32_t filter_mask)1529 std::pair<wifi_error, std::vector<wifi_usable_channel>> WifiLegacyHal::getUsableChannels(
1530         uint32_t band_mask, uint32_t iface_mode_mask, uint32_t filter_mask) {
1531     std::vector<wifi_usable_channel> channels;
1532     channels.resize(kMaxWifiUsableChannels);
1533     uint32_t size = 0;
1534     wifi_error status = global_func_table_.wifi_get_usable_channels(
1535             global_handle_, band_mask, iface_mode_mask, filter_mask, channels.size(), &size,
1536             reinterpret_cast<wifi_usable_channel*>(channels.data()));
1537     CHECK(size >= 0 && size <= kMaxWifiUsableChannels);
1538     channels.resize(size);
1539     return {status, std::move(channels)};
1540 }
1541 
triggerSubsystemRestart()1542 wifi_error WifiLegacyHal::triggerSubsystemRestart() {
1543     return global_func_table_.wifi_trigger_subsystem_restart(global_handle_);
1544 }
1545 
setIndoorState(bool isIndoor)1546 wifi_error WifiLegacyHal::setIndoorState(bool isIndoor) {
1547     return global_func_table_.wifi_set_indoor_state(global_handle_, isIndoor);
1548 }
1549 
1550 std::pair<wifi_error, wifi_radio_combination_matrix*>
getSupportedRadioCombinationsMatrix()1551 WifiLegacyHal::getSupportedRadioCombinationsMatrix() {
1552     char* buffer = new char[kMaxSupportedRadioCombinationsMatrixLength];
1553     std::fill(buffer, buffer + kMaxSupportedRadioCombinationsMatrixLength, 0);
1554     uint32_t size = 0;
1555     wifi_radio_combination_matrix* radio_combination_matrix_ptr =
1556             reinterpret_cast<wifi_radio_combination_matrix*>(buffer);
1557     wifi_error status = global_func_table_.wifi_get_supported_radio_combinations_matrix(
1558             global_handle_, kMaxSupportedRadioCombinationsMatrixLength, &size,
1559             radio_combination_matrix_ptr);
1560     CHECK(size >= 0 && size <= kMaxSupportedRadioCombinationsMatrixLength);
1561     return {status, radio_combination_matrix_ptr};
1562 }
1563 
chreNanRttRequest(const std::string & iface_name,bool enable)1564 wifi_error WifiLegacyHal::chreNanRttRequest(const std::string& iface_name, bool enable) {
1565     if (enable)
1566         return global_func_table_.wifi_nan_rtt_chre_enable_request(0, getIfaceHandle(iface_name),
1567                                                                    NULL);
1568     else
1569         return global_func_table_.wifi_nan_rtt_chre_disable_request(0, getIfaceHandle(iface_name));
1570 }
1571 
chreRegisterHandler(const std::string & iface_name,const ChreCallbackHandlers & handler)1572 wifi_error WifiLegacyHal::chreRegisterHandler(const std::string& iface_name,
1573                                               const ChreCallbackHandlers& handler) {
1574     if (on_chre_nan_rtt_internal_callback) {
1575         return WIFI_ERROR_NOT_AVAILABLE;
1576     }
1577 
1578     on_chre_nan_rtt_internal_callback = handler.on_wifi_chre_nan_rtt_state;
1579 
1580     wifi_error status = global_func_table_.wifi_chre_register_handler(getIfaceHandle(iface_name),
1581                                                                       {onAsyncChreNanRttState});
1582     if (status != WIFI_SUCCESS) {
1583         on_chre_nan_rtt_internal_callback = nullptr;
1584     }
1585     return status;
1586 }
1587 
enableWifiTxPowerLimits(const std::string & iface_name,bool enable)1588 wifi_error WifiLegacyHal::enableWifiTxPowerLimits(const std::string& iface_name, bool enable) {
1589     return global_func_table_.wifi_enable_tx_power_limits(getIfaceHandle(iface_name), enable);
1590 }
1591 
invalidate()1592 void WifiLegacyHal::invalidate() {
1593     global_handle_ = nullptr;
1594     iface_name_to_handle_.clear();
1595     on_driver_memory_dump_internal_callback = nullptr;
1596     on_firmware_memory_dump_internal_callback = nullptr;
1597     on_gscan_event_internal_callback = nullptr;
1598     on_gscan_full_result_internal_callback = nullptr;
1599     on_link_layer_stats_result_internal_callback = nullptr;
1600     on_rssi_threshold_breached_internal_callback = nullptr;
1601     on_ring_buffer_data_internal_callback = nullptr;
1602     on_error_alert_internal_callback = nullptr;
1603     on_radio_mode_change_internal_callback = nullptr;
1604     on_subsystem_restart_internal_callback = nullptr;
1605     on_rtt_results_internal_callback = nullptr;
1606     on_nan_notify_response_user_callback = nullptr;
1607     on_nan_event_publish_terminated_user_callback = nullptr;
1608     on_nan_event_match_user_callback = nullptr;
1609     on_nan_event_match_expired_user_callback = nullptr;
1610     on_nan_event_subscribe_terminated_user_callback = nullptr;
1611     on_nan_event_followup_user_callback = nullptr;
1612     on_nan_event_disc_eng_event_user_callback = nullptr;
1613     on_nan_event_disabled_user_callback = nullptr;
1614     on_nan_event_tca_user_callback = nullptr;
1615     on_nan_event_beacon_sdf_payload_user_callback = nullptr;
1616     on_nan_event_data_path_request_user_callback = nullptr;
1617     on_nan_event_data_path_confirm_user_callback = nullptr;
1618     on_nan_event_data_path_end_user_callback = nullptr;
1619     on_nan_event_transmit_follow_up_user_callback = nullptr;
1620     on_nan_event_range_request_user_callback = nullptr;
1621     on_nan_event_range_report_user_callback = nullptr;
1622     on_nan_event_schedule_update_user_callback = nullptr;
1623     on_twt_event_setup_response_callback = nullptr;
1624     on_twt_event_teardown_completion_callback = nullptr;
1625     on_twt_event_info_frame_received_callback = nullptr;
1626     on_twt_event_device_notify_callback = nullptr;
1627     on_chre_nan_rtt_internal_callback = nullptr;
1628 }
1629 
1630 }  // namespace legacy_hal
1631 }  // namespace implementation
1632 }  // namespace V1_6
1633 }  // namespace wifi
1634 }  // namespace hardware
1635 }  // namespace android
1636