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

[gnunet]

Author: wachs
Date: 2013-05-23 16:57:20 +0200 (Thu, 23 May 2013)
New Revision: 27274

Modified:
   gnunet/src/transport/gnunet-service-transport_manipulation.c
Log:
one '&' to break it all...


Modified: gnunet/src/transport/gnunet-service-transport_manipulation.c
===================================================================
--- gnunet/src/transport/gnunet-service-transport_manipulation.c        
2013-05-23 14:14:44 UTC (rev 27273)
+++ gnunet/src/transport/gnunet-service-transport_manipulation.c        
2013-05-23 14:57:20 UTC (rev 27274)
@@ -361,6 +361,7 @@
 
        if (NULL != tmp)
        {
+                       GNUNET_break (GNUNET_YES == 
GST_neighbours_test_connected (&dqe->id));
                        tmp->send_delay_task = GNUNET_SCHEDULER_NO_TASK;
                        GNUNET_CONTAINER_DLL_remove (tmp->send_head, 
tmp->send_tail, dqe);
                        GST_neighbours_send (&dqe->id, dqe->msg, dqe->msg_size, 
dqe->timeout, dqe->cont, dqe->cont_cls);
@@ -375,7 +376,8 @@
        }
        else
        {
-               /* Remove from generic queue */
+                       /* Remove from generic queue */
+                       GNUNET_break (GNUNET_YES == 
GST_neighbours_test_connected (&dqe->id));
                        generic_send_delay_task = GNUNET_SCHEDULER_NO_TASK;
                        GNUNET_CONTAINER_DLL_remove (generic_dqe_head, 
generic_dqe_tail, dqe);
                        GST_neighbours_send (&dqe->id, dqe->msg, dqe->msg_size, 
dqe->timeout, dqe->cont, dqe->cont_cls);
@@ -412,6 +414,7 @@
 
        if (NULL != (tmp = GNUNET_CONTAINER_multihashmap_get (man_handle.peers, 
&target->hashPubKey)))
        {
+                       GNUNET_break (GNUNET_YES == 
GST_neighbours_test_connected(target));
                        /* Manipulate here */
                        /* Delay */
                        if (UINT32_MAX != find_metric(tmp, 
GNUNET_ATS_QUALITY_NET_DELAY, TM_SEND))
@@ -439,6 +442,7 @@
        }
        else if (UINT32_MAX != find_metric (&man_handle.general, 
GNUNET_ATS_QUALITY_NET_DELAY, TM_SEND))
        {
+                       GNUNET_break (GNUNET_YES == 
GST_neighbours_test_connected(target));
                        /* We have a delay */
                        delay.rel_value = find_metric (&man_handle.general, 
GNUNET_ATS_QUALITY_NET_DELAY, TM_SEND);
                        dqe = GNUNET_malloc (sizeof (struct DelayQueueEntry) + 
msg_size);
@@ -672,7 +676,7 @@
                        while (NULL != (dqe = next))
                        {
                                        next = dqe->next;
-                                       if (0 == memcmp (&peer, &dqe->id, 
sizeof (dqe->id)))
+                                       if (0 == memcmp (peer, &dqe->id, sizeof 
(dqe->id)))
                                        {
                                                        
GNUNET_CONTAINER_DLL_remove (generic_dqe_head, generic_dqe_tail, dqe);
                                                        if (NULL != dqe->cont)