Commit 8bc79ca6 authored by Alessio Netti's avatar Alessio Netti
Browse files

Bugfixes

- Collectagent will not hang anymore when pushers crash or terminate abruptly without properly closing their connections
- Issue was related to message buffers not being cleaned up in SimpleMQTTServerMessageThread upon a connection release
parent 70ccf194
...@@ -509,6 +509,10 @@ void SimpleMQTTServerMessageThread::releaseConnection(int connectionId) ...@@ -509,6 +509,10 @@ void SimpleMQTTServerMessageThread::releaseConnection(int connectionId)
fds[connectionId].fd = -1; fds[connectionId].fd = -1;
fds[connectionId].events = 0; fds[connectionId].events = 0;
fds[connectionId].revents = 0; fds[connectionId].revents = 0;
if (msg[connectionId]) {
delete msg[connectionId];
msg[connectionId] = NULL;
}
numConnections--; numConnections--;
#ifdef SimpleMQTTVerbose #ifdef SimpleMQTTVerbose
......
Supports Markdown
0% or .
You are about to add 0 people to the discussion. Proceed with caution.
Finish editing this message first!
Please register or to comment