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