aboutsummaryrefslogtreecommitdiff
path: root/src/transport/transport_api_new.c
diff options
context:
space:
mode:
authorChristian Grothoff <christian@grothoff.org>2011-06-06 11:12:17 +0000
committerChristian Grothoff <christian@grothoff.org>2011-06-06 11:12:17 +0000
commitbca24b48e92b81a55732608dcbf4e84b28ebbb27 (patch)
tree6df971993f77a0859187417658786813c6690b3f /src/transport/transport_api_new.c
parentf030d71dbf12001d36b6b6e1e3767b5ebf287a5d (diff)
downloadgnunet-bca24b48e92b81a55732608dcbf4e84b28ebbb27.tar.gz
gnunet-bca24b48e92b81a55732608dcbf4e84b28ebbb27.zip
fix
Diffstat (limited to 'src/transport/transport_api_new.c')
-rw-r--r--src/transport/transport_api_new.c4
1 files changed, 2 insertions, 2 deletions
diff --git a/src/transport/transport_api_new.c b/src/transport/transport_api_new.c
index b9e7b49af..2a8c78f24 100644
--- a/src/transport/transport_api_new.c
+++ b/src/transport/transport_api_new.c
@@ -662,8 +662,7 @@ transport_notify_ready (void *cls, size_t size, void *buf)
662 while ( (NULL == h->control_head) && 662 while ( (NULL == h->control_head) &&
663 (NULL != (n = GNUNET_CONTAINER_heap_peek (h->ready_heap))) ) 663 (NULL != (n = GNUNET_CONTAINER_heap_peek (h->ready_heap))) )
664 { 664 {
665 n->hn = NULL; 665 if (GNUNET_YES != n->is_ready)
666 if (GNUNET_YES != n->is_ready)
667 { 666 {
668 /* peer not ready, wait for notification! */ 667 /* peer not ready, wait for notification! */
669 GNUNET_assert (n == GNUNET_CONTAINER_heap_remove_root (h->ready_heap)); 668 GNUNET_assert (n == GNUNET_CONTAINER_heap_remove_root (h->ready_heap));
@@ -679,6 +678,7 @@ transport_notify_ready (void *cls, size_t size, void *buf)
679 if (GNUNET_BANDWIDTH_tracker_get_delay (&n->out_tracker, th->notify_size).rel_value > 0) 678 if (GNUNET_BANDWIDTH_tracker_get_delay (&n->out_tracker, th->notify_size).rel_value > 0)
680 break; /* too early */ 679 break; /* too early */
681 GNUNET_assert (n == GNUNET_CONTAINER_heap_remove_root (h->ready_heap)); 680 GNUNET_assert (n == GNUNET_CONTAINER_heap_remove_root (h->ready_heap));
681 n->hn = NULL;
682 n->th = NULL; 682 n->th = NULL;
683 n->is_ready = GNUNET_NO; 683 n->is_ready = GNUNET_NO;
684 GNUNET_assert (size >= sizeof (struct OutboundMessage)); 684 GNUNET_assert (size >= sizeof (struct OutboundMessage));