diff options
Diffstat (limited to 'src/mesh/gnunet-service-mesh_peer.c')
-rw-r--r-- | src/mesh/gnunet-service-mesh_peer.c | 14 |
1 files changed, 7 insertions, 7 deletions
diff --git a/src/mesh/gnunet-service-mesh_peer.c b/src/mesh/gnunet-service-mesh_peer.c index 8bd4b6567..99f8eb07d 100644 --- a/src/mesh/gnunet-service-mesh_peer.c +++ b/src/mesh/gnunet-service-mesh_peer.c | |||
@@ -232,16 +232,16 @@ queue_debug (struct MeshPeer *peer) | |||
232 | { | 232 | { |
233 | struct MeshPeerQueue *q; | 233 | struct MeshPeerQueue *q; |
234 | 234 | ||
235 | LOG (GNUNET_ERROR_TYPE_DEBUG, "Messages queued towards %s\n", GMP_2s (peer)); | 235 | LOG (GNUNET_ERROR_TYPE_DEBUG, "QQQ Messages queued towards %s\n", GMP_2s (peer)); |
236 | LOG (GNUNET_ERROR_TYPE_DEBUG, " core tmt rdy: %p\n", peer->core_transmit); | 236 | LOG (GNUNET_ERROR_TYPE_DEBUG, "QQQ core tmt rdy: %p\n", peer->core_transmit); |
237 | 237 | ||
238 | for (q = peer->queue_head; NULL != q; q = q->next) | 238 | for (q = peer->queue_head; NULL != q; q = q->next) |
239 | { | 239 | { |
240 | LOG (GNUNET_ERROR_TYPE_DEBUG, " - %s %s on %s\n", | 240 | LOG (GNUNET_ERROR_TYPE_DEBUG, "QQQ - %s %s on %s\n", |
241 | GM_m2s (q->type), GM_f2s (q->fwd), GMC_2s (q->c)); | 241 | GM_m2s (q->type), GM_f2s (q->fwd), GMC_2s (q->c)); |
242 | } | 242 | } |
243 | 243 | ||
244 | LOG (GNUNET_ERROR_TYPE_DEBUG, "End queued towards %s\n", GMP_2s (peer)); | 244 | LOG (GNUNET_ERROR_TYPE_DEBUG, "QQQ End queued towards %s\n", GMP_2s (peer)); |
245 | } | 245 | } |
246 | 246 | ||
247 | 247 | ||
@@ -926,7 +926,7 @@ queue_send (void *cls, size_t size, void *buf) | |||
926 | c = queue->c; | 926 | c = queue->c; |
927 | 927 | ||
928 | dst_id = GNUNET_PEER_resolve2 (peer->id); | 928 | dst_id = GNUNET_PEER_resolve2 (peer->id); |
929 | LOG (GNUNET_ERROR_TYPE_DEBUG, "* on connection %s\n", GMC_2s (c)); | 929 | LOG (GNUNET_ERROR_TYPE_DEBUG, " on connection %s\n", GMC_2s (c)); |
930 | /* Check if buffer size is enough for the message */ | 930 | /* Check if buffer size is enough for the message */ |
931 | if (queue->size > size) | 931 | if (queue->size > size) |
932 | { | 932 | { |
@@ -1006,7 +1006,7 @@ queue_send (void *cls, size_t size, void *buf) | |||
1006 | queue = peer_get_first_message (peer); | 1006 | queue = peer_get_first_message (peer); |
1007 | if (NULL != queue) | 1007 | if (NULL != queue) |
1008 | { | 1008 | { |
1009 | LOG (GNUNET_ERROR_TYPE_DEBUG, "* more data!\n"); | 1009 | LOG (GNUNET_ERROR_TYPE_DEBUG, " more data!\n"); |
1010 | if (NULL == peer->core_transmit) | 1010 | if (NULL == peer->core_transmit) |
1011 | { | 1011 | { |
1012 | peer->core_transmit = | 1012 | peer->core_transmit = |
@@ -1031,7 +1031,7 @@ queue_send (void *cls, size_t size, void *buf) | |||
1031 | // GMC_stop_poll(); FIXME needed? | 1031 | // GMC_stop_poll(); FIXME needed? |
1032 | } | 1032 | } |
1033 | 1033 | ||
1034 | LOG (GNUNET_ERROR_TYPE_DEBUG, "* Return %d\n", data_size); | 1034 | LOG (GNUNET_ERROR_TYPE_DEBUG, " return %d\n", data_size); |
1035 | queue_debug (peer); | 1035 | queue_debug (peer); |
1036 | return data_size; | 1036 | return data_size; |
1037 | } | 1037 | } |