[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);
+ }
+ }
}
[Prev in Thread] |
Current Thread |
[Next in Thread] |
- [GNUnet-SVN] r31769 - gnunet/src/transport,
gnunet <=