From 1eb0af7ed563c6d77e1b8e36e81ba6ede7e49f5a Mon Sep 17 00:00:00 2001
From: Eelco Dolstra <eelco.dolstra@logicblox.com>
Date: Thu, 24 Jul 2014 00:16:06 +0200
Subject: [PATCH] Add some assertions

---
 src/libutil/monitor-fd.hh | 6 ++++++
 1 file changed, 6 insertions(+)

diff --git a/src/libutil/monitor-fd.hh b/src/libutil/monitor-fd.hh
index d8db6508a..ebfc230f9 100644
--- a/src/libutil/monitor-fd.hh
+++ b/src/libutil/monitor-fd.hh
@@ -1,6 +1,7 @@
 #pragma once
 
 #include <thread>
+#include <atomic>
 
 #include <poll.h>
 #include <sys/types.h>
@@ -14,10 +15,12 @@ class MonitorFdHup
 {
 private:
     std::thread thread;
+    std::atomic_bool quit;
 
 public:
     MonitorFdHup(int fd)
     {
+        quit = false;
         thread = std::thread([&]() {
             /* Wait indefinitely until a POLLHUP occurs. */
             struct pollfd fds[1];
@@ -25,8 +28,10 @@ public:
             fds[0].events = 0;
             if (poll(fds, 1, -1) == -1) {
                 if (errno != EINTR) abort(); // can't happen
+                assert(quit);
                 return; // destructor is asking us to exit
             }
+            assert(fds[0].revents & POLLHUP);
             /* We got POLLHUP, so send an INT signal to the main thread. */
             kill(getpid(), SIGINT);
         });
@@ -34,6 +39,7 @@ public:
 
     ~MonitorFdHup()
     {
+        quit = true;
         pthread_kill(thread.native_handle(), SIGINT);
         thread.join();
     }