diff options
author | Bart Polot <bart@net.in.tum.de> | 2013-07-22 23:31:16 +0000 |
---|---|---|
committer | Bart Polot <bart@net.in.tum.de> | 2013-07-22 23:31:16 +0000 |
commit | e04eeb1369916a25d3277d774203d4bfa9adb564 (patch) | |
tree | 84cd7f731436d5bc26f7240923f3358d4b192d7e | |
parent | 7a0ed741f1e532adc72b7bfa072c38112fbf4098 (diff) | |
download | gnunet-e04eeb1369916a25d3277d774203d4bfa9adb564.tar.gz gnunet-e04eeb1369916a25d3277d774203d4bfa9adb564.zip |
- send ack could call queue_add and set the handler
-rw-r--r-- | src/mesh/gnunet-service-mesh.c | 30 |
1 files changed, 17 insertions, 13 deletions
diff --git a/src/mesh/gnunet-service-mesh.c b/src/mesh/gnunet-service-mesh.c index cc1d6c0e6..a3847792f 100644 --- a/src/mesh/gnunet-service-mesh.c +++ b/src/mesh/gnunet-service-mesh.c | |||
@@ -3611,7 +3611,7 @@ queue_send (void *cls, size_t size, void *buf) | |||
3611 | 3611 | ||
3612 | GNUNET_log (GNUNET_ERROR_TYPE_DEBUG, "* Queue send\n"); | 3612 | GNUNET_log (GNUNET_ERROR_TYPE_DEBUG, "* Queue send\n"); |
3613 | 3613 | ||
3614 | if (NULL == buf || 0 ==size) | 3614 | if (NULL == buf || 0 == size) |
3615 | { | 3615 | { |
3616 | GNUNET_log (GNUNET_ERROR_TYPE_DEBUG, "* Buffer size 0.\n"); | 3616 | GNUNET_log (GNUNET_ERROR_TYPE_DEBUG, "* Buffer size 0.\n"); |
3617 | return 0; | 3617 | return 0; |
@@ -3733,19 +3733,23 @@ queue_send (void *cls, size_t size, void *buf) | |||
3733 | queue = queue_get_next (peer); | 3733 | queue = queue_get_next (peer); |
3734 | if (NULL != queue) | 3734 | if (NULL != queue) |
3735 | { | 3735 | { |
3736 | struct GNUNET_PeerIdentity id; | ||
3737 | |||
3738 | GNUNET_log (GNUNET_ERROR_TYPE_DEBUG, "* more data!\n"); | 3736 | GNUNET_log (GNUNET_ERROR_TYPE_DEBUG, "* more data!\n"); |
3739 | GNUNET_PEER_resolve (peer->id, &id); | 3737 | if (NULL == peer->core_transmit) { |
3740 | peer->core_transmit = | 3738 | peer->core_transmit = |
3741 | GNUNET_CORE_notify_transmit_ready(core_handle, | 3739 | GNUNET_CORE_notify_transmit_ready(core_handle, |
3742 | 0, | 3740 | 0, |
3743 | 0, | 3741 | 0, |
3744 | GNUNET_TIME_UNIT_FOREVER_REL, | 3742 | GNUNET_TIME_UNIT_FOREVER_REL, |
3745 | &id, | 3743 | &dst_id, |
3746 | queue->size, | 3744 | queue->size, |
3747 | &queue_send, | 3745 | &queue_send, |
3748 | peer); | 3746 | peer); |
3747 | } | ||
3748 | else | ||
3749 | { | ||
3750 | GNUNET_log (GNUNET_ERROR_TYPE_DEBUG, | ||
3751 | "* tmt rdy called somewhere else\n"); | ||
3752 | } | ||
3749 | } | 3753 | } |
3750 | if (peer->id == t->next_hop) | 3754 | if (peer->id == t->next_hop) |
3751 | fc = &t->next_fc; | 3755 | fc = &t->next_fc; |