1 files changed, 60 insertions, 59 deletions

diff --git a/src/cadet/cadet_api_list_peers.c b/src/cadet/cadet_api_list_peers.c
index 65e9ad4da..8865b6f57 100644
--- a/src/cadet/cadet_api_list_peers.c
+++ b/src/cadet/cadet_api_list_peers.c
@@ -34,7 +34,8 @@
 /**
  * Operation handle.
  */
-struct GNUNET_CADET_PeersLister {
+struct GNUNET_CADET_PeersLister
+{
   /**
    * Monitor callback
    */
@@ -74,18 +75,18 @@ struct GNUNET_CADET_PeersLister {
  * @param info Message itself.
  */
 static void
-handle_get_peers(void *cls,
-                 const struct GNUNET_CADET_LocalInfoPeers *info)
+handle_get_peers (void *cls,
+                  const struct GNUNET_CADET_LocalInfoPeers *info)
 {
   struct GNUNET_CADET_PeersLister *pl = cls;
   struct GNUNET_CADET_PeerListEntry ple;
 
   ple.peer = info->destination;
-  ple.have_tunnel = (int)ntohs(info->tunnel);
-  ple.n_paths = (unsigned int)ntohs(info->paths);
-  ple.best_path_length = (unsigned int)ntohl(info->best_path_length);
-  pl->peers_cb(pl->peers_cb_cls,
-               &ple);
+  ple.have_tunnel = (int) ntohs (info->tunnel);
+  ple.n_paths = (unsigned int) ntohs (info->paths);
+  ple.best_path_length = (unsigned int) ntohl (info->best_path_length);
+  pl->peers_cb (pl->peers_cb_cls,
+                &ple);
 }
 
 
@@ -96,16 +97,16 @@ handle_get_peers(void *cls,
  * @param msg Message itself.
  */
 static void
-handle_get_peers_end(void *cls,
-                     const struct GNUNET_MessageHeader *msg)
+handle_get_peers_end (void *cls,
+                      const struct GNUNET_MessageHeader *msg)
 {
   struct GNUNET_CADET_PeersLister *pl = cls;
 
-  (void)msg;
+  (void) msg;
 
-  pl->peers_cb(pl->peers_cb_cls,
-               NULL);
-  GNUNET_CADET_list_peers_cancel(pl);
+  pl->peers_cb (pl->peers_cb_cls,
+                NULL);
+  GNUNET_CADET_list_peers_cancel (pl);
 }
 
 
@@ -115,7 +116,7 @@ handle_get_peers_end(void *cls,
  * @param cls a `struct GNUNET_CADET_PeersLister` operation
  */
 static void
-reconnect(void *cls);
+reconnect (void *cls);
 
 
 /**
@@ -125,18 +126,18 @@ reconnect(void *cls);
  * @param error error code from MQ
  */
 static void
-error_handler(void *cls,
-              enum GNUNET_MQ_Error error)
+error_handler (void *cls,
+               enum GNUNET_MQ_Error error)
 {
   struct GNUNET_CADET_PeersLister *pl = cls;
 
-  GNUNET_MQ_destroy(pl->mq);
+  GNUNET_MQ_destroy (pl->mq);
   pl->mq = NULL;
-  pl->backoff = GNUNET_TIME_randomized_backoff(pl->backoff,
-                                               GNUNET_TIME_UNIT_MINUTES);
-  pl->reconnect_task = GNUNET_SCHEDULER_add_delayed(pl->backoff,
-                                                    &reconnect,
-                                                    pl);
+  pl->backoff = GNUNET_TIME_randomized_backoff (pl->backoff,
+                                                GNUNET_TIME_UNIT_MINUTES);
+  pl->reconnect_task = GNUNET_SCHEDULER_add_delayed (pl->backoff,
+                                                     &reconnect,
+                                                     pl);
 }
 
 
@@ -146,35 +147,35 @@ error_handler(void *cls,
  * @param cls a `struct GNUNET_CADET_PeersLister` operation
  */
 static void
-reconnect(void *cls)
+reconnect (void *cls)
 {
   struct GNUNET_CADET_PeersLister *pl = cls;
   struct GNUNET_MQ_MessageHandler handlers[] = {
-    GNUNET_MQ_hd_fixed_size(get_peers,
-                            GNUNET_MESSAGE_TYPE_CADET_LOCAL_INFO_PEERS,
-                            struct GNUNET_CADET_LocalInfoPeers,
-                            pl),
-    GNUNET_MQ_hd_fixed_size(get_peers_end,
-                            GNUNET_MESSAGE_TYPE_CADET_LOCAL_INFO_PEERS_END,
-                            struct GNUNET_MessageHeader,
-                            pl),
-    GNUNET_MQ_handler_end()
+    GNUNET_MQ_hd_fixed_size (get_peers,
+                             GNUNET_MESSAGE_TYPE_CADET_LOCAL_INFO_PEERS,
+                             struct GNUNET_CADET_LocalInfoPeers,
+                             pl),
+    GNUNET_MQ_hd_fixed_size (get_peers_end,
+                             GNUNET_MESSAGE_TYPE_CADET_LOCAL_INFO_PEERS_END,
+                             struct GNUNET_MessageHeader,
+                             pl),
+    GNUNET_MQ_handler_end ()
   };
   struct GNUNET_MessageHeader *msg;
   struct GNUNET_MQ_Envelope *env;
 
   pl->reconnect_task = NULL;
-  pl->mq = GNUNET_CLIENT_connect(pl->cfg,
-                                 "cadet",
-                                 handlers,
-                                 &error_handler,
-                                 pl);
+  pl->mq = GNUNET_CLIENT_connect (pl->cfg,
+                                  "cadet",
+                                  handlers,
+                                  &error_handler,
+                                  pl);
   if (NULL == pl->mq)
     return;
-  env = GNUNET_MQ_msg(msg,
-                      GNUNET_MESSAGE_TYPE_CADET_LOCAL_REQUEST_INFO_PEERS);
-  GNUNET_MQ_send(pl->mq,
-                 env);
+  env = GNUNET_MQ_msg (msg,
+                       GNUNET_MESSAGE_TYPE_CADET_LOCAL_REQUEST_INFO_PEERS);
+  GNUNET_MQ_send (pl->mq,
+                  env);
 }
 
 
@@ -189,27 +190,27 @@ reconnect(void *cls)
  * @return NULL on error
  */
 struct GNUNET_CADET_PeersLister *
-GNUNET_CADET_list_peers(const struct GNUNET_CONFIGURATION_Handle *cfg,
-                        GNUNET_CADET_PeersCB callback,
-                        void *callback_cls)
+GNUNET_CADET_list_peers (const struct GNUNET_CONFIGURATION_Handle *cfg,
+                         GNUNET_CADET_PeersCB callback,
+                         void *callback_cls)
 {
   struct GNUNET_CADET_PeersLister *pl;
 
   if (NULL == callback)
-    {
-      GNUNET_break(0);
-      return NULL;
-    }
-  pl = GNUNET_new(struct GNUNET_CADET_PeersLister);
+  {
+    GNUNET_break (0);
+    return NULL;
+  }
+  pl = GNUNET_new (struct GNUNET_CADET_PeersLister);
   pl->peers_cb = callback;
   pl->peers_cb_cls = callback_cls;
   pl->cfg = cfg;
-  reconnect(pl);
+  reconnect (pl);
   if (NULL == pl->mq)
-    {
-      GNUNET_free(pl);
-      return NULL;
-    }
+  {
+    GNUNET_free (pl);
+    return NULL;
+  }
   return pl;
 }
 
@@ -221,15 +222,15 @@ GNUNET_CADET_list_peers(const struct GNUNET_CONFIGURATION_Handle *cfg,
  * @return Closure given to GNUNET_CADET_get_peers().
  */
 void *
-GNUNET_CADET_list_peers_cancel(struct GNUNET_CADET_PeersLister *pl)
+GNUNET_CADET_list_peers_cancel (struct GNUNET_CADET_PeersLister *pl)
 {
   void *ret = pl->peers_cb_cls;
 
   if (NULL != pl->mq)
-    GNUNET_MQ_destroy(pl->mq);
+    GNUNET_MQ_destroy (pl->mq);
   if (NULL != pl->reconnect_task)
-    GNUNET_SCHEDULER_cancel(pl->reconnect_task);
-  GNUNET_free(pl);
+    GNUNET_SCHEDULER_cancel (pl->reconnect_task);
+  GNUNET_free (pl);
   return ret;
 }