diff options
author | Christian Grothoff <christian@grothoff.org> | 2011-06-06 11:12:17 +0000 |
---|---|---|
committer | Christian Grothoff <christian@grothoff.org> | 2011-06-06 11:12:17 +0000 |
commit | bca24b48e92b81a55732608dcbf4e84b28ebbb27 (patch) | |
tree | 6df971993f77a0859187417658786813c6690b3f /src/transport/transport_api_new.c | |
parent | f030d71dbf12001d36b6b6e1e3767b5ebf287a5d (diff) | |
download | gnunet-bca24b48e92b81a55732608dcbf4e84b28ebbb27.tar.gz gnunet-bca24b48e92b81a55732608dcbf4e84b28ebbb27.zip |
fix
Diffstat (limited to 'src/transport/transport_api_new.c')
-rw-r--r-- | src/transport/transport_api_new.c | 4 |
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)); |