aboutsummaryrefslogtreecommitdiff
path: root/src/mesh/gnunet-service-mesh_peer.c
diff options
context:
space:
mode:
Diffstat (limited to 'src/mesh/gnunet-service-mesh_peer.c')
-rw-r--r--src/mesh/gnunet-service-mesh_peer.c15
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 */
761static size_t 761static 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}