diff options
Diffstat (limited to 'src/mesh/gnunet-service-mesh_peer.c')
-rw-r--r-- | src/mesh/gnunet-service-mesh_peer.c | 15 |
1 files changed, 8 insertions, 7 deletions
diff --git a/src/mesh/gnunet-service-mesh_peer.c b/src/mesh/gnunet-service-mesh_peer.c index a1389b539..1679e2e66 100644 --- a/src/mesh/gnunet-service-mesh_peer.c +++ b/src/mesh/gnunet-service-mesh_peer.c | |||
@@ -436,7 +436,7 @@ send_core_connection_create (struct MeshConnection *c, size_t size, void *buf) | |||
436 | GNUNET_PEER_resolve (p->peers[i], peer_ptr++); | 436 | GNUNET_PEER_resolve (p->peers[i], peer_ptr++); |
437 | } | 437 | } |
438 | 438 | ||
439 | LOG (GNUNET_ERROR_TYPE_DEBUG, | 439 | LOG (GNUNET_ERROR_TYPE_DEBUG, |
440 | "CONNECTION CREATE (%u bytes long) sent!\n", | 440 | "CONNECTION CREATE (%u bytes long) sent!\n", |
441 | size_needed); | 441 | size_needed); |
442 | return size_needed; | 442 | return size_needed; |
@@ -738,7 +738,7 @@ search_handler (void *cls, const struct MeshPeerPath *path) | |||
738 | if (3 <= connection_count) | 738 | if (3 <= connection_count) |
739 | return; | 739 | return; |
740 | 740 | ||
741 | if (MESH_TUNNEL3_SEARCHING == GMT_get_state (peer->tunnel)) | 741 | if (MESH_TUNNEL3_SEARCHING == GMT_get_cstate (peer->tunnel)) |
742 | { | 742 | { |
743 | LOG (GNUNET_ERROR_TYPE_DEBUG, " ... connect!\n"); | 743 | LOG (GNUNET_ERROR_TYPE_DEBUG, " ... connect!\n"); |
744 | GMP_connect (peer); | 744 | GMP_connect (peer); |
@@ -755,7 +755,7 @@ search_handler (void *cls, const struct MeshPeerPath *path) | |||
755 | * @param buf Where the to write the message. | 755 | * @param buf Where the to write the message. |
756 | * | 756 | * |
757 | * @return number of bytes written to buf | 757 | * @return number of bytes written to buf |
758 | * | 758 | * |
759 | * FIXME add GNUNET_MESSAGE_TYPE_MESH_KEEPALIVE | 759 | * FIXME add GNUNET_MESSAGE_TYPE_MESH_KEEPALIVE |
760 | */ | 760 | */ |
761 | static size_t | 761 | static size_t |
@@ -787,6 +787,7 @@ queue_send (void *cls, size_t size, void *buf) | |||
787 | 787 | ||
788 | dst_id = GNUNET_PEER_resolve2 (peer->id); | 788 | dst_id = GNUNET_PEER_resolve2 (peer->id); |
789 | LOG (GNUNET_ERROR_TYPE_DEBUG, "* towards %s\n", GNUNET_i2s (dst_id)); | 789 | LOG (GNUNET_ERROR_TYPE_DEBUG, "* towards %s\n", GNUNET_i2s (dst_id)); |
790 | LOG (GNUNET_ERROR_TYPE_DEBUG, "* on connection %s\n", GMC_2s (c)); | ||
790 | /* Check if buffer size is enough for the message */ | 791 | /* Check if buffer size is enough for the message */ |
791 | if (queue->size > size) | 792 | if (queue->size > size) |
792 | { | 793 | { |
@@ -1341,7 +1342,7 @@ GMP_connect (struct MeshPeer *peer) | |||
1341 | { | 1342 | { |
1342 | GMD_search_stop (peer->search_h); | 1343 | GMD_search_stop (peer->search_h); |
1343 | peer->search_h = NULL; | 1344 | peer->search_h = NULL; |
1344 | LOG (GNUNET_ERROR_TYPE_DEBUG, | 1345 | LOG (GNUNET_ERROR_TYPE_DEBUG, |
1345 | " Stopping DHT GET for peer %s\n", | 1346 | " Stopping DHT GET for peer %s\n", |
1346 | GMP_2s (peer)); | 1347 | GMP_2s (peer)); |
1347 | } | 1348 | } |
@@ -1354,8 +1355,8 @@ GMP_connect (struct MeshPeer *peer) | |||
1354 | LOG (GNUNET_ERROR_TYPE_DEBUG, | 1355 | LOG (GNUNET_ERROR_TYPE_DEBUG, |
1355 | " Starting DHT GET for peer %s\n", GMP_2s (peer)); | 1356 | " Starting DHT GET for peer %s\n", GMP_2s (peer)); |
1356 | peer->search_h = GMD_search (id, &search_handler, peer); | 1357 | peer->search_h = GMD_search (id, &search_handler, peer); |
1357 | if (MESH_TUNNEL3_NEW == GMT_get_state (t)) | 1358 | if (MESH_TUNNEL3_NEW == GMT_get_cstate (t)) |
1358 | GMT_change_state (t, MESH_TUNNEL3_SEARCHING); | 1359 | GMT_change_cstate (t, MESH_TUNNEL3_SEARCHING); |
1359 | } | 1360 | } |
1360 | } | 1361 | } |
1361 | 1362 | ||
@@ -1709,4 +1710,4 @@ GMP_2s (const struct MeshPeer *peer) | |||
1709 | if (NULL == peer) | 1710 | if (NULL == peer) |
1710 | return "(NULL)"; | 1711 | return "(NULL)"; |
1711 | return GNUNET_i2s (GNUNET_PEER_resolve2 (peer->id)); | 1712 | return GNUNET_i2s (GNUNET_PEER_resolve2 (peer->id)); |
1712 | } \ No newline at end of file | 1713 | } |