Mirrors/esp-idf
1
0
Fork 0
mirror of https://github.com/espressif/esp-idf.git synced 2026-10-02 03:00:34 +03:00
Code Issues Packages Projects Releases Wiki Activity

fix(wifi) : Reschedule roam in based on backoff time

Browse Source
This commit is contained in:
tarun.kumar
2026-05-06 15:19:03 +05:30
parent 16f8e1fda1
commit 66429b1ba7
2 changed files with 26 additions and 3 deletions
Download Patch File Download Diff File Expand all files Collapse all files
components/esp_wifi/wifi_apps/roaming_app/src/esp_roaming_i.h
+1
View File
@@ -146,6 +146,7 @@ struct roaming_app {
uint8_t bssid_blacklist_count; uint8_t bssid_blacklist_count;
#endif #endif
bool allow_reconnect; bool allow_reconnect;
struct cand_bss *pending_roam_bss;
}; };
#ifdef __cplusplus #ifdef __cplusplus
components/esp_wifi/wifi_apps/roaming_app/src/roaming_app.c
+25 -3
View File
@@ -1481,10 +1481,25 @@ void roaming_app_trigger_roam(struct cand_bss *bss)
gettimeofday(&now, NULL); gettimeofday(&now, NULL);
ESP_LOGD(ROAMING_TAG, "Processing trigger roaming request."); ESP_LOGD(ROAMING_TAG, "Processing trigger roaming request.");
if (g_roaming_app.pending_roam_bss) {
eloop_cancel_timeout(roaming_app_trigger_roam_internal_handler, NULL, g_roaming_app.pending_roam_bss);
os_free(g_roaming_app.pending_roam_bss);
g_roaming_app.pending_roam_bss = NULL;
}
if (g_roaming_app.sta_connected && roaming_app_roam_backoff_active(&now, 0)) { if (g_roaming_app.sta_connected && roaming_app_roam_backoff_active(&now, 0)) {
ESP_LOGD(ROAMING_TAG, "Ignoring request as time difference to last roam attempt is %ld", const struct timeval *anchor = roaming_app_get_backoff_anchor();
time_diff_sec(&now, &g_roaming_app.last_roam_attempt_time)); long elapsed_sec = time_diff_sec(&now, anchor);
goto free_bss; long remaining_sec = (long)g_roaming_app.config.backoff_time - elapsed_sec;
ESP_LOGD(ROAMING_TAG,
"Deferring roam during backoff (elapsed %ld s since anchor), reschedule in %ld s",
elapsed_sec, remaining_sec);
if (eloop_register_timeout((unsigned int)remaining_sec, 0,
roaming_app_trigger_roam_internal_handler, NULL, (void *)bss)) {
ESP_LOGE(ROAMING_TAG, "Could not register roaming event.");
goto free_bss;
}
g_roaming_app.pending_roam_bss = bss;
return;
} }
#if NETWORK_ASSISTED_ROAMING_ENABLED #if NETWORK_ASSISTED_ROAMING_ENABLED
if (g_roaming_app.sta_connected && g_roaming_app.config.btm_roaming_enabled && g_roaming_app.current_bss.btm_support) { if (g_roaming_app.sta_connected && g_roaming_app.config.btm_roaming_enabled && g_roaming_app.current_bss.btm_support) {
@@ -1532,6 +1547,9 @@ static void roaming_app_trigger_roam_internal_handler(void *ctx, void *data)
if (!data) { if (!data) {
ESP_LOGE(ROAMING_TAG, "No data received for roaming event"); ESP_LOGE(ROAMING_TAG, "No data received for roaming event");
} else { } else {
if (g_roaming_app.pending_roam_bss == data) {
g_roaming_app.pending_roam_bss = NULL;
}
roaming_app_trigger_roam((struct cand_bss *)data); roaming_app_trigger_roam((struct cand_bss *)data);
} }
} }
@@ -2158,6 +2176,10 @@ static void roaming_app_cancel_pending_events(void)
eloop_cancel_timeout(roaming_app_connected_event_handler, ELOOP_ALL_CTX, ELOOP_ALL_CTX); eloop_cancel_timeout(roaming_app_connected_event_handler, ELOOP_ALL_CTX, ELOOP_ALL_CTX);
eloop_cancel_timeout(roaming_app_disconnected_event_handler, ELOOP_ALL_CTX, ELOOP_ALL_CTX); eloop_cancel_timeout(roaming_app_disconnected_event_handler, ELOOP_ALL_CTX, ELOOP_ALL_CTX);
eloop_cancel_timeout(roaming_app_trigger_roam_internal_handler, ELOOP_ALL_CTX, ELOOP_ALL_CTX); eloop_cancel_timeout(roaming_app_trigger_roam_internal_handler, ELOOP_ALL_CTX, ELOOP_ALL_CTX);
if (g_roaming_app.pending_roam_bss) {
os_free(g_roaming_app.pending_roam_bss);
g_roaming_app.pending_roam_bss = NULL;
}
eloop_cancel_timeout(enable_reconnect, ELOOP_ALL_CTX, ELOOP_ALL_CTX); eloop_cancel_timeout(enable_reconnect, ELOOP_ALL_CTX, ELOOP_ALL_CTX);
eloop_cancel_timeout(disable_reconnect, ELOOP_ALL_CTX, ELOOP_ALL_CTX); eloop_cancel_timeout(disable_reconnect, ELOOP_ALL_CTX, ELOOP_ALL_CTX);
#if LOW_RSSI_ROAMING_ENABLED #if LOW_RSSI_ROAMING_ENABLED