1 files changed, 20 insertions, 11 deletions

diff --git a/src/pq/pq.h b/src/pq/pq.h
index 3c89626a9..d10931d99 100644
--- a/src/pq/pq.h
+++ b/src/pq/pq.h
@@ -28,6 +28,7 @@
 #include "gnunet_util_lib.h"
 #include "gnunet_pq_lib.h"
 
+
 /**
  * Handle to Postgres database.
  */
@@ -59,24 +60,32 @@ struct GNUNET_PQ_Context
   char *load_path;
 
   /**
-   * Function to call on Postgres FDs.
+   * Map managing event subscriptions.
    */
-  GNUNET_PQ_SocketCallback sc;
+  struct GNUNET_CONTAINER_MultiShortmap *channel_map;
 
   /**
-   * Closure for @e sc.
+   * Task responsible for processing events.
    */
-  void *sc_cls;
+  struct GNUNET_SCHEDULER_Task *event_task;
 
   /**
-   * Map managing event subscriptions.
+   * File descriptor wrapper for @e event_task.
    */
-  struct GNUNET_CONTAINER_MultiShortmap *channel_map;
-
-  /**
-   * Lock to access @e channel_map.
-   */
-  pthread_mutex_t notify_lock;
+  struct GNUNET_NETWORK_Handle *rfd;
 };
 
+
+/**
+ * Internal API. Reconnect should re-register notifications
+ * after a disconnect.
+ *
+ * @param db the DB handle
+ * @param fd socket to listen on
+ */
+void
+GNUNET_PQ_event_reconnect_ (struct GNUNET_PQ_Context *db,
+                            int fd);
+
+
 #endif