gnunet-svn
[Top][All Lists]
Advanced

[Date Prev][Date Next][Thread Prev][Thread Next][Date Index][Thread Index]

[GNUnet-SVN] r31769 - gnunet/src/transport


From: gnunet
Subject: [GNUnet-SVN] r31769 - gnunet/src/transport
Date: Sun, 29 Dec 2013 18:06:08 +0100

Author: wachs
Date: 2013-12-29 18:06:08 +0100 (Sun, 29 Dec 2013)
New Revision: 31769

Modified:
   gnunet/src/transport/gnunet-service-transport_manipulation.c
Log:
fix indent


Modified: gnunet/src/transport/gnunet-service-transport_manipulation.c
===================================================================
--- gnunet/src/transport/gnunet-service-transport_manipulation.c        
2013-12-29 15:40:27 UTC (rev 31768)
+++ gnunet/src/transport/gnunet-service-transport_manipulation.c        
2013-12-29 17:06:08 UTC (rev 31769)
@@ -679,47 +679,50 @@
  * @param peer the disconnecting peer
  */
 void
-GST_manipulation_peer_disconnect (const struct GNUNET_PeerIdentity *peer)
+GST_manipulation_peer_disconnect(const struct GNUNET_PeerIdentity *peer)
 {
-       struct TM_Peer *tmp;
-       struct DelayQueueEntry *dqe;
-       struct DelayQueueEntry *next;
+  struct TM_Peer *tmp;
+  struct DelayQueueEntry *dqe;
+  struct DelayQueueEntry *next;
 
-       if (NULL != (tmp = GNUNET_CONTAINER_multipeermap_get (man_handle.peers, 
peer)))
-       {
-                       next = tmp->send_head;
-                       while (NULL != (dqe = next))
-                       {
-                                       next = dqe->next;
-                                       GNUNET_CONTAINER_DLL_remove 
(tmp->send_head, tmp->send_tail, dqe);
-                                       if (NULL != dqe->cont)
-                                                       dqe->cont 
(dqe->cont_cls, GNUNET_SYSERR, dqe->msg_size, 0);
-                                       GNUNET_free (dqe);
-                       }
-       }
-       else if (UINT32_MAX != find_metric (&man_handle.general, 
GNUNET_ATS_QUALITY_NET_DELAY, TM_SEND))
-       {
-                       next = generic_dqe_head;
-                       while (NULL != (dqe = next))
-                       {
-                                       next = dqe->next;
-                                       if (0 == memcmp (peer, &dqe->id, sizeof 
(dqe->id)))
-                                       {
-                                                       
GNUNET_CONTAINER_DLL_remove (generic_dqe_head, generic_dqe_tail, dqe);
-                                                       if (NULL != dqe->cont)
-                                                               dqe->cont 
(dqe->cont_cls, GNUNET_SYSERR, dqe->msg_size, 0);
-                                                       GNUNET_free (dqe);
-                                       }
-                       }
-                       if (GNUNET_SCHEDULER_NO_TASK != generic_send_delay_task)
-                       {
-                                       GNUNET_SCHEDULER_cancel 
(generic_send_delay_task);
-                                       if (NULL != generic_dqe_head)
-                                               generic_send_delay_task = 
GNUNET_SCHEDULER_add_delayed (
-                                                               
GNUNET_TIME_absolute_get_remaining(generic_dqe_head->sent_at),
-                                                               &send_delayed, 
generic_dqe_head);
-                       }
-       }
+  if (NULL != (tmp = GNUNET_CONTAINER_multipeermap_get(man_handle.peers, 
peer)))
+    {
+      next = tmp->send_head;
+      while (NULL != (dqe = next))
+        {
+          next = dqe->next;
+          GNUNET_CONTAINER_DLL_remove(tmp->send_head, tmp->send_tail, dqe);
+          if (NULL != dqe->cont)
+            dqe->cont(dqe->cont_cls, GNUNET_SYSERR, dqe->msg_size, 0);
+          GNUNET_free(dqe);
+        }
+    }
+  else if (UINT32_MAX
+      != find_metric(&man_handle.general, GNUNET_ATS_QUALITY_NET_DELAY,
+          TM_SEND))
+    {
+      next = generic_dqe_head;
+      while (NULL != (dqe = next))
+        {
+          next = dqe->next;
+          if (0 == memcmp(peer, &dqe->id, sizeof(dqe->id)))
+            {
+              GNUNET_CONTAINER_DLL_remove(generic_dqe_head, generic_dqe_tail,
+                  dqe);
+              if (NULL != dqe->cont)
+                dqe->cont(dqe->cont_cls, GNUNET_SYSERR, dqe->msg_size, 0);
+              GNUNET_free(dqe);
+            }
+        }
+      if (GNUNET_SCHEDULER_NO_TASK != generic_send_delay_task)
+        {
+          GNUNET_SCHEDULER_cancel(generic_send_delay_task);
+          if (NULL != generic_dqe_head)
+            generic_send_delay_task = GNUNET_SCHEDULER_add_delayed(
+                GNUNET_TIME_absolute_get_remaining(generic_dqe_head->sent_at),
+                &send_delayed, generic_dqe_head);
+        }
+    }
 }
 
 




reply via email to

[Prev in Thread] Current Thread [Next in Thread]