Darkages/SpotMicroESP32-Leika
1
0
Fork 0
Code Issues Pull Requests Actions Packages Projects Releases Wiki Activity

🧵 Takes semaphore onWSClose

Browse Source
This commit is contained in:
Rune Harlyk
2024-07-22 23:31:33 +02:00
parent b204e49e36
commit 9e58939dfd
1 changed files with 2 additions and 0 deletions
Download Patch File Download Diff File Expand all files Collapse all files
esp32/lib/ESP32-sveltekit/EventSocket.cpp
+2
View File
@@ -61,9 +61,11 @@ void EventSocket::onWSOpen(PsychicWebSocketClient *client) {
} }
void EventSocket::onWSClose(PsychicWebSocketClient *client) { void EventSocket::onWSClose(PsychicWebSocketClient *client) {
xSemaphoreTake(clientSubscriptionsMutex, portMAX_DELAY);
for (auto &event_subscriptions : client_subscriptions) { for (auto &event_subscriptions : client_subscriptions) {
event_subscriptions.second.remove(client->socket()); event_subscriptions.second.remove(client->socket());
} }
xSemaphoreGive(clientSubscriptionsMutex);
ESP_LOGI("EventSocket", "ws[%s][%u] disconnect", client->remoteIP().toString().c_str(), client->socket()); ESP_LOGI("EventSocket", "ws[%s][%u] disconnect", client->remoteIP().toString().c_str(), client->socket());
} }