_messageQueu size is not reset

[RonKrem]

Platform

ESP32

IDE / Tooling

PlatformIO

What happened?

My ESP32 server is sending data to the client at regular intervals using websockets. Switch away from that server to another and the AsyncEventSource _messageQueue naturally begins to fill. If it does fill (32 entries) the message:

[908712][E][AsyncEventSource.cpp:230] _queueMessage(): Event message queue overflow: discard message

begins to appear on the console for every write. However, you can reconnect to the ESP32 server again, and once the connection is made, it will empty the queue and continue on, seemingly without any problems (apart from the >32 missing entries). However, the above message continues to appear, even when the _messageQueue.size() function returns normal values.

Causing no problems, but is there any reason this message is not reset along with the queue contents?

Stack Trace

None

Minimal Reproductible Example (MRE)

Not required

I confirm that:

• I have read the documentation.
• I have searched for similar discussions.
• I have searched for similar issues.
• I have looked at the examples.
• I have upgraded to the lasted version of ESPAsyncWebServer (and AsyncTCP for ESP32).

[mathieucarbou]

Hello,
2 things:
1- the queue is per client. So if the client is gone, the queue is gone also.
2- please make sure to upgrade the libraries and use the ones from the correct project / org : the line numbers do not seem to match this library.
3- test with another client: maybe you have a bug in your client (js?) code ?
4 - if the steps above did not solve your issue, please provide a MRE. It is possible also that your code on the MCU is wrong and floods the client queues on certain conditions.
Thanks!

[RonKrem]

Many thanks for that reply.

1. My experience disagrees with your point 1. I added a print statement in AsyncEventSource to print the queue's contents. I can disconnect from the ESP32 web server and connect to my local net then watch the queue count increase in the Platformio console window. If I reconnect to the ESP32 before 32 entries, the original display continues as if nothing had happened. If I let it go past 32 and the console starts printing the above error message, I can still go back to the ESP32 and reconnect and the display continues, albeit with a data gap. Remember I am using websockets.
2. A quick look at platformio.ini does not mention revisions for the ESPAsyncWebServer library. I'll check that.
3. I assume there is no way my code can print that error message when the queue contents is just 1 or 2.
4. This could be possible although console.log messages in the javascript just show a single packet arriving (interval is every 5 seconds). I'll have another look.

[mathieucarbou]

yes, the queue is per client.

ESPAsyncWebServer/src/AsyncEventSource.h

Lines 123 to 130 in 25845e7

	class AsyncEventSourceClient {
	private:
	AsyncClient *_client;
	AsyncEventSource *_server;
	uint32_t _lastId{0};
	size_t _inflight{0}; // num of unacknowledged bytes that has been written to socket buffer
	size_t _max_inflight{SSE_MAX_INFLIGH}; // max num of unacknowledged bytes that could be written to socket buffer
	std::list<AsyncEventSourceMessage> _messageQueue;

Please provide a MRE to allow us reproduce and we'll look.