From d5fee3f9d888703b5b9426b99489e7441e710f24 Mon Sep 17 00:00:00 2001 From: Mathieu Carbou Date: Sun, 26 May 2024 13:56:14 +0200 Subject: [PATCH] Fix logging --- src/AsyncEventSource.cpp | 6 +++++- src/AsyncWebSocket.cpp | 4 ++++ 2 files changed, 9 insertions(+), 1 deletion(-) diff --git a/src/AsyncEventSource.cpp b/src/AsyncEventSource.cpp index 1c34c85..98f18de 100644 --- a/src/AsyncEventSource.cpp +++ b/src/AsyncEventSource.cpp @@ -193,7 +193,11 @@ void AsyncEventSourceClient::_queueMessage(AsyncEventSourceMessage *dataMessage) //length() is not thread-safe, thus acquiring the lock before this call.. _lockmq.lock(); if(_messageQueue.length() >= SSE_MAX_QUEUED_MESSAGES){ - ets_printf(String(F("ERROR: Too many messages queued\n")).c_str()); +#ifdef ESP8266 + ets_printf(String(F("ERROR: Too many messages queued\n")).c_str()); +#else + log_e("Too many messages queued: deleting message"); +#endif delete dataMessage; } else { _messageQueue.add(dataMessage); diff --git a/src/AsyncWebSocket.cpp b/src/AsyncWebSocket.cpp index 594ffb5..787b52a 100644 --- a/src/AsyncWebSocket.cpp +++ b/src/AsyncWebSocket.cpp @@ -461,7 +461,11 @@ void AsyncWebSocketClient::_queueMessage(std::shared_ptr> b if (_messageQueue.size() >= WS_MAX_QUEUED_MESSAGES) { l.unlock(); +#ifdef ESP8266 ets_printf("AsyncWebSocketClient::_queueMessage: Too many messages queued, closing connection\n"); +#else + log_e("Too many messages queued: closing connection"); +#endif _status = WS_DISCONNECTED; if (_client) _client->close(true); return;