New API is needed in case stored procedures trigger events for

our own process.

NEWS: Add new GNUNET_PQ_event_do_poll() API to gnunet_pq_lib.h

2 files changed, 17 insertions, 4 deletions

diff --git a/src/include/gnunet_pq_lib.h b/src/include/gnunet_pq_lib.h
index 78eaf0d49..69cf84583 100644
--- a/src/include/gnunet_pq_lib.h
+++ b/src/include/gnunet_pq_lib.h
@@ -1562,6 +1562,19 @@ GNUNET_PQ_event_listen_cancel (struct GNUNET_DB_EventHandler *eh);
 
 
 /**
+ * Poll for events right now. Useful if we may have
+ * triggered an event for ourselves.  Not needed when
+ * using GNUNET_PQ_event_notify(), but useful when
+ * stored procedures may have triggered events.
+ * Does nothing if there are no events.
+ *
+ * @param[in,out] db database to check for events
+ */
+void
+GNUNET_PQ_event_do_poll (struct GNUNET_PQ_Context *db);
+
+
+/**
  * Notify all that listen on @a es of an event.
  *
  * Unlike many other calls, this function is thread-safe and may be called
diff --git a/src/pq/pq_event.c b/src/pq/pq_event.c
index 16bd898fb..fff9e16f7 100644
--- a/src/pq/pq_event.c
+++ b/src/pq/pq_event.c
@@ -185,8 +185,8 @@ do_notify (void *cls,
 }
 
 
-static void
-event_do_poll (struct GNUNET_PQ_Context *db)
+void
+GNUNET_PQ_event_do_poll (struct GNUNET_PQ_Context *db)
 {
   PGnotify *n;
   unsigned int cnt = 0;
@@ -276,7 +276,7 @@ do_scheduler_notify (void *cls)
   db->event_task = NULL;
   if (NULL == db->rfd)
     GNUNET_PQ_reconnect (db);
-  event_do_poll (db);
+  GNUNET_PQ_event_do_poll (db);
   if (NULL != db->event_task)
     return;
   GNUNET_log (GNUNET_ERROR_TYPE_INFO,
@@ -577,7 +577,7 @@ GNUNET_PQ_event_notify (struct GNUNET_PQ_Context *db,
                      PQerrorMessage (db->conn));
   }
   PQclear (result);
-  event_do_poll (db);
+  GNUNET_PQ_event_do_poll (db);
 }