1 files changed, 46 insertions, 51 deletions

diff --git a/src/util/nc.c b/src/util/nc.c
index 7a3c5877e..ab7ef122d 100644
--- a/src/util/nc.c
+++ b/src/util/nc.c
@@ -11,12 +11,12 @@
      WITHOUT ANY WARRANTY; without even the implied warranty of
      MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE.  See the GNU
      Affero General Public License for more details.
-    
+
      You should have received a copy of the GNU Affero General Public License
      along with this program.  If not, see <http://www.gnu.org/licenses/>.
 
      SPDX-License-Identifier: AGPL3.0-or-later
-*/
+ */
 
 /**
  * @file util/nc.c
@@ -28,15 +28,13 @@
 #include "platform.h"
 #include "gnunet_util_lib.h"
 
-#define LOG(kind,...) GNUNET_log_from (kind, "util-nc", __VA_ARGS__)
+#define LOG(kind, ...) GNUNET_log_from(kind, "util-nc", __VA_ARGS__)
 
 
 /**
  * Lists of subscribers we manage for notifications.
  */
-struct SubscriberList
-{
-
+struct SubscriberList {
   /**
    * This is a doubly linked list.
    */
@@ -57,12 +55,11 @@ struct SubscriberList
    * the MQ's destruction.
    */
   struct GNUNET_MQ_DestroyNotificationHandle *mq_nh;
-  
+
   /**
    * Message queue for the subscriber.
    */
   struct GNUNET_MQ_Handle *mq;
-
 };
 
 
@@ -74,9 +71,7 @@ struct SubscriberList
  * (notification) messages are queued up until the subscriber is able to
  * read them.
  */
-struct GNUNET_NotificationContext
-{
-
+struct GNUNET_NotificationContext {
   /**
    * Head of list of subscribers receiving notifications.
    */
@@ -91,7 +86,6 @@ struct GNUNET_NotificationContext
    * Maximum number of optional messages to queue per subscriber.
    */
   unsigned int queue_length;
-
 };
 
 
@@ -101,15 +95,15 @@ struct GNUNET_NotificationContext
  * @param cls our `struct SubscriberList *`
  */
 static void
-handle_mq_destroy (void *cls)
+handle_mq_destroy(void *cls)
 {
-  struct SubscriberList *pos = cls; 
+  struct SubscriberList *pos = cls;
   struct GNUNET_NotificationContext *nc = pos->nc;
 
-  GNUNET_CONTAINER_DLL_remove (nc->subscribers_head,
-                               nc->subscribers_tail,
-                               pos);
-  GNUNET_free (pos);
+  GNUNET_CONTAINER_DLL_remove(nc->subscribers_head,
+                              nc->subscribers_tail,
+                              pos);
+  GNUNET_free(pos);
 }
 
 
@@ -122,11 +116,11 @@ handle_mq_destroy (void *cls)
  * @return handle to the notification context
  */
 struct GNUNET_NotificationContext *
-GNUNET_notification_context_create (unsigned int queue_length)
+GNUNET_notification_context_create(unsigned int queue_length)
 {
   struct GNUNET_NotificationContext *nc;
 
-  nc = GNUNET_new (struct GNUNET_NotificationContext);
+  nc = GNUNET_new(struct GNUNET_NotificationContext);
   nc->queue_length = queue_length;
   return nc;
 }
@@ -138,19 +132,19 @@ GNUNET_notification_context_create (unsigned int queue_length)
  * @param nc context to destroy.
  */
 void
-GNUNET_notification_context_destroy (struct GNUNET_NotificationContext *nc)
+GNUNET_notification_context_destroy(struct GNUNET_NotificationContext *nc)
 {
   struct SubscriberList *pos;
 
   while (NULL != (pos = nc->subscribers_head))
-  {
-    GNUNET_CONTAINER_DLL_remove (nc->subscribers_head,
-                                 nc->subscribers_tail,
-                                 pos);
-    GNUNET_MQ_destroy_notify_cancel (pos->mq_nh);
-    GNUNET_free (pos);
-  }
-  GNUNET_free (nc);
+    {
+      GNUNET_CONTAINER_DLL_remove(nc->subscribers_head,
+                                  nc->subscribers_tail,
+                                  pos);
+      GNUNET_MQ_destroy_notify_cancel(pos->mq_nh);
+      GNUNET_free(pos);
+    }
+  GNUNET_free(nc);
 }
 
 
@@ -161,23 +155,24 @@ GNUNET_notification_context_destroy (struct GNUNET_NotificationContext *nc)
  * @param mq message queue add
  */
 void
-GNUNET_notification_context_add (struct GNUNET_NotificationContext *nc,
-                                 struct GNUNET_MQ_Handle *mq)
+GNUNET_notification_context_add(struct GNUNET_NotificationContext *nc,
+                                struct GNUNET_MQ_Handle *mq)
 {
   struct SubscriberList *cl;
 
   for (cl = nc->subscribers_head; NULL != cl; cl = cl->next)
     if (cl->mq == mq)
-      return; /* already present */
-  cl = GNUNET_new (struct SubscriberList);
-  GNUNET_CONTAINER_DLL_insert (nc->subscribers_head,
-                               nc->subscribers_tail,
-                               cl);
+      return;
+  /* already present */
+  cl = GNUNET_new(struct SubscriberList);
+  GNUNET_CONTAINER_DLL_insert(nc->subscribers_head,
+                              nc->subscribers_tail,
+                              cl);
   cl->nc = nc;
   cl->mq = mq;
-  cl->mq_nh = GNUNET_MQ_destroy_notify (cl->mq,
-                                        &handle_mq_destroy,
-                                        cl);
+  cl->mq_nh = GNUNET_MQ_destroy_notify(cl->mq,
+                                       &handle_mq_destroy,
+                                       cl);
 }
 
 
@@ -189,22 +184,22 @@ GNUNET_notification_context_add (struct GNUNET_NotificationContext *nc,
  * @param can_drop can this message be dropped due to queue length limitations
  */
 void
-GNUNET_notification_context_broadcast (struct GNUNET_NotificationContext *nc,
-                                       const struct GNUNET_MessageHeader *msg,
-                                       int can_drop)
+GNUNET_notification_context_broadcast(struct GNUNET_NotificationContext *nc,
+                                      const struct GNUNET_MessageHeader *msg,
+                                      int can_drop)
 {
   struct SubscriberList *pos;
   struct GNUNET_MQ_Envelope *env;
 
   for (pos = nc->subscribers_head; NULL != pos; pos = pos->next)
-  {
-    if ( (GNUNET_YES == can_drop) &&
-         (GNUNET_MQ_get_length (pos->mq) > nc->queue_length) )
-      continue;
-    env = GNUNET_MQ_msg_copy (msg);
-    GNUNET_MQ_send (pos->mq,
-                    env);
-  }
+    {
+      if ((GNUNET_YES == can_drop) &&
+          (GNUNET_MQ_get_length(pos->mq) > nc->queue_length))
+        continue;
+      env = GNUNET_MQ_msg_copy(msg);
+      GNUNET_MQ_send(pos->mq,
+                     env);
+    }
 }
 
 
@@ -215,7 +210,7 @@ GNUNET_notification_context_broadcast (struct GNUNET_NotificationContext *nc,
  * @return number of current subscribers
  */
 unsigned int
-GNUNET_notification_context_get_size (struct GNUNET_NotificationContext *nc)
+GNUNET_notification_context_get_size(struct GNUNET_NotificationContext *nc)
 {
   unsigned int num;
   struct SubscriberList *pos;