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.c14
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}