Check for POLLHUP when polling sockets

19bda2d4 · Michael Ott · fd792f6d · 19bda2d4
Commit 19bda2d4 authored Oct 20, 2016 by Michael Ott
--- a/CollectAgent/simplemqttserverthread.cpp
+++ b/CollectAgent/simplemqttserverthread.cpp
@@ -291,6 +291,10 @@ void SimpleMQTTServerMessageThread::run()
                  cout << "fd(" << fds[connectionId].fd << ") revents: " << hex << fds[connectionId].revents << dec << "\n";
                  coutMtx.unlock();
 #endif
+                  /* Remote side hung up */
+                  if (fds[connectionId].revents & POLLHUP) {
+                      releaseConnection(connectionId);
+                  }

                  if (fds[connectionId].revents & POLLIN) {
                      char* readPtr;