diff options
Diffstat (limited to 'src/cadet/gnunet-service-cadet_peer.c')
| -rw-r--r-- | src/cadet/gnunet-service-cadet_peer.c | 24 |
1 files changed, 21 insertions, 3 deletions
diff --git a/src/cadet/gnunet-service-cadet_peer.c b/src/cadet/gnunet-service-cadet_peer.c index 8003c05cd..f99ce482f 100644 --- a/src/cadet/gnunet-service-cadet_peer.c +++ b/src/cadet/gnunet-service-cadet_peer.c @@ -754,7 +754,7 @@ peer_destroy (struct CadetPeer *peer) /** - * Iterator over peer hash map entries to destroy the peer during shutdown. + * Iterator over peer hash map entries to destroy the peer during in_shutdown. * * @param cls closure * @param key current key code @@ -1155,8 +1155,26 @@ queue_send (void *cls, size_t size, void *buf) /* Sanity checking */ if (NULL == buf || 0 == size) { - peer->tmt_time.abs_value_us = 0; - peer->core_transmit = NULL; + LOG (GNUNET_ERROR_TYPE_DEBUG, " not allowed/\n"); + if (GNUNET_NO == in_shutdown) + { + queue = peer_get_first_message (peer); + dst_id = GNUNET_PEER_resolve2 (peer->id); + peer->core_transmit = + GNUNET_CORE_notify_transmit_ready (core_handle, + GNUNET_NO, get_priority (queue), + GNUNET_TIME_UNIT_FOREVER_REL, + dst_id, + get_core_size (queue->size), + &queue_send, + peer); + peer->tmt_time = GNUNET_TIME_absolute_get (); + } + else + { + peer->core_transmit = NULL; + peer->tmt_time.abs_value_us = 0; + } return 0; } |