debug fds

1 files changed, 41 insertions, 0 deletions

diff --git a/src/util/scheduler.c b/src/util/scheduler.c
index 81f7d8cf0..a7dca4af7 100644
--- a/src/util/scheduler.c
+++ b/src/util/scheduler.c
@@ -46,6 +46,11 @@
 #define EXECINFO GNUNET_NO
 
 /**
+ * Check each file descriptor before adding
+ */
+#define DEBUG_FDS GNUNET_NO
+
+/**
  * Depth of the traces collected via EXECINFO.
  */
 #define MAX_TRACE_DEPTH 50
@@ -1225,6 +1230,42 @@ add_without_sets (struct GNUNET_TIME_Relative delay,
   t->num_backtrace_strings = backtrace(backtrace_array, MAX_TRACE_DEPTH);
   t->backtrace_strings = backtrace_symbols(backtrace_array, t->num_backtrace_strings);
 #endif
+#ifdef DEBUG_FDS
+  if (-1 != rfd)
+    {
+      int flags = fcntl(rfd, F_GETFD);
+      if (flags == -1 && errno == EBADF)
+        {
+          GNUNET_log(GNUNET_ERROR_TYPE_ERROR, "Got invalid file descriptor %d!\n", rfd);
+#if EXECINFO
+          int i;
+
+          for (i=0;i<t->num_backtrace_strings;i++)
+            GNUNET_log (GNUNET_ERROR_TYPE_DEBUG,
+                        "Trace: %s\n",
+                        t->backtrace_strings[i]);
+#endif
+          GNUNET_assert(0);
+        }
+    }
+  if (-1 != wfd)
+    {
+      int flags = fcntl(wfd, F_GETFD);
+      if (flags == -1 && errno == EBADF)
+        {
+          GNUNET_log(GNUNET_ERROR_TYPE_ERROR, "Got invalid file descriptor %d!\n", wfd);
+#if EXECINFO
+          int i;
+
+          for (i=0;i<t->num_backtrace_strings;i++)
+            GNUNET_log (GNUNET_ERROR_TYPE_DEBUG,
+                        "Trace: %s\n",
+                        t->backtrace_strings[i]);
+#endif
+          GNUNET_assert(0);
+        }
+    }
+#endif
   t->read_fd = rfd;
   GNUNET_assert(wfd >= -1);
   t->write_fd = wfd;