diff options
Diffstat (limited to 'src/mesh/gnunet-service-mesh.c')
-rw-r--r-- | src/mesh/gnunet-service-mesh.c | 9 |
1 files changed, 6 insertions, 3 deletions
diff --git a/src/mesh/gnunet-service-mesh.c b/src/mesh/gnunet-service-mesh.c index 9f302dcda..c1a35b37f 100644 --- a/src/mesh/gnunet-service-mesh.c +++ b/src/mesh/gnunet-service-mesh.c | |||
@@ -1221,7 +1221,10 @@ send_core_create_path (void *cls, size_t size, void *buf) | |||
1221 | 1221 | ||
1222 | if (size < size_needed || NULL == buf) | 1222 | if (size < size_needed || NULL == buf) |
1223 | { | 1223 | { |
1224 | GNUNET_log (GNUNET_ERROR_TYPE_DEBUG, "MESH: Retransmitting create path\n"); | 1224 | GNUNET_log (GNUNET_ERROR_TYPE_DEBUG, "MESH: create path retransmit!\n"); |
1225 | GNUNET_log (GNUNET_ERROR_TYPE_DEBUG, "MESH: buf: %p\n", buf); | ||
1226 | GNUNET_log (GNUNET_ERROR_TYPE_DEBUG, "MESH: size: (%u/%u)\n", | ||
1227 | size, size_needed); | ||
1225 | GNUNET_CORE_notify_transmit_ready (core_handle, 0, 0, | 1228 | GNUNET_CORE_notify_transmit_ready (core_handle, 0, 0, |
1226 | GNUNET_TIME_UNIT_FOREVER_REL, | 1229 | GNUNET_TIME_UNIT_FOREVER_REL, |
1227 | path_get_first_hop (t->tree, peer->id), | 1230 | path_get_first_hop (t->tree, peer->id), |
@@ -1639,11 +1642,11 @@ handle_mesh_path_create (void *cls, const struct GNUNET_PeerIdentity *peer, | |||
1639 | path_add_to_origin (orig_peer_info, path); /* inverts path! */ | 1642 | path_add_to_origin (orig_peer_info, path); /* inverts path! */ |
1640 | info = GNUNET_malloc (sizeof (struct MeshDataDescriptor)); | 1643 | info = GNUNET_malloc (sizeof (struct MeshDataDescriptor)); |
1641 | info->origin = &t->id; | 1644 | info->origin = &t->id; |
1642 | info->peer = GNUNET_CONTAINER_multihashmap_get (peers, &id.hashPubKey); | 1645 | info->peer = GNUNET_CONTAINER_multihashmap_get (peers, &peer->hashPubKey); |
1643 | GNUNET_assert (NULL != info->peer); | 1646 | GNUNET_assert (NULL != info->peer); |
1644 | for (j = 0; info->peer->core_transmit[j]; j++) | 1647 | for (j = 0; info->peer->core_transmit[j]; j++) |
1645 | { | 1648 | { |
1646 | if (j == 9) | 1649 | if (j == (CORE_QUEUE_SIZE - 1)) |
1647 | { | 1650 | { |
1648 | GNUNET_break (0); | 1651 | GNUNET_break (0); |
1649 | return GNUNET_OK; | 1652 | return GNUNET_OK; |