aboutsummaryrefslogtreecommitdiff
path: root/src/dht
diff options
context:
space:
mode:
Diffstat (limited to 'src/dht')
-rw-r--r--src/dht/gnunet-service-dht_clients.c13
-rw-r--r--src/dht/gnunet-service-wdht_clients.c13
-rw-r--r--src/dht/gnunet-service-xdht_clients.c13
-rw-r--r--src/dht/gnunet-service-xdht_neighbours.c18
-rw-r--r--src/dht/gnunet_dht_profiler.c13
5 files changed, 47 insertions, 23 deletions
diff --git a/src/dht/gnunet-service-dht_clients.c b/src/dht/gnunet-service-dht_clients.c
index a5757c25a..942bf5785 100644
--- a/src/dht/gnunet-service-dht_clients.c
+++ b/src/dht/gnunet-service-dht_clients.c
@@ -926,13 +926,18 @@ send_reply_to_client (void *cls, size_t size, void *buf)
926 reply); 926 reply);
927 memcpy (&cbuf[off], reply->msg, msize); 927 memcpy (&cbuf[off], reply->msg, msize);
928 GNUNET_free (reply); 928 GNUNET_free (reply);
929 GNUNET_log (GNUNET_ERROR_TYPE_DEBUG, "Transmitting %u bytes to client %p\n", 929 GNUNET_log (GNUNET_ERROR_TYPE_DEBUG,
930 msize, client->client_handle); 930 "Transmitting %u bytes to client %p\n",
931 (unsigned int) msize,
932 client->client_handle);
931 off += msize; 933 off += msize;
932 } 934 }
933 process_pending_messages (client); 935 process_pending_messages (client);
934 GNUNET_log (GNUNET_ERROR_TYPE_DEBUG, "Transmitted %u/%u bytes to client %p\n", 936 GNUNET_log (GNUNET_ERROR_TYPE_DEBUG,
935 (unsigned int) off, (unsigned int) size, client->client_handle); 937 "Transmitted %u/%u bytes to client %p\n",
938 (unsigned int) off,
939 (unsigned int) size,
940 client->client_handle);
936 return off; 941 return off;
937} 942}
938 943
diff --git a/src/dht/gnunet-service-wdht_clients.c b/src/dht/gnunet-service-wdht_clients.c
index 8eb114660..3d2eba460 100644
--- a/src/dht/gnunet-service-wdht_clients.c
+++ b/src/dht/gnunet-service-wdht_clients.c
@@ -318,13 +318,18 @@ send_reply_to_client (void *cls, size_t size, void *buf)
318 reply); 318 reply);
319 memcpy (&cbuf[off], reply->msg, msize); 319 memcpy (&cbuf[off], reply->msg, msize);
320 GNUNET_free (reply); 320 GNUNET_free (reply);
321 GNUNET_log (GNUNET_ERROR_TYPE_DEBUG, "Transmitting %u bytes to client %p\n", 321 GNUNET_log (GNUNET_ERROR_TYPE_DEBUG,
322 msize, client->client_handle); 322 "Transmitting %u bytes to client %p\n",
323 (unsigned int) msize,
324 client->client_handle);
323 off += msize; 325 off += msize;
324 } 326 }
325 process_pending_messages (client); 327 process_pending_messages (client);
326 GNUNET_log (GNUNET_ERROR_TYPE_DEBUG, "Transmitted %u/%u bytes to client %p\n", 328 GNUNET_log (GNUNET_ERROR_TYPE_DEBUG,
327 (unsigned int) off, (unsigned int) size, client->client_handle); 329 "Transmitted %u/%u bytes to client %p\n",
330 (unsigned int) off,
331 (unsigned int) size,
332 client->client_handle);
328 return off; 333 return off;
329} 334}
330 335
diff --git a/src/dht/gnunet-service-xdht_clients.c b/src/dht/gnunet-service-xdht_clients.c
index 3475d00c9..bc5504ebe 100644
--- a/src/dht/gnunet-service-xdht_clients.c
+++ b/src/dht/gnunet-service-xdht_clients.c
@@ -318,13 +318,18 @@ send_reply_to_client (void *cls, size_t size, void *buf)
318 reply); 318 reply);
319 memcpy (&cbuf[off], reply->msg, msize); 319 memcpy (&cbuf[off], reply->msg, msize);
320 GNUNET_free (reply); 320 GNUNET_free (reply);
321 GNUNET_log (GNUNET_ERROR_TYPE_DEBUG, "Transmitting %u bytes to client %p\n", 321 GNUNET_log (GNUNET_ERROR_TYPE_DEBUG,
322 msize, client->client_handle); 322 "Transmitting %u bytes to client %p\n",
323 (unsigned int) msize,
324 client->client_handle);
323 off += msize; 325 off += msize;
324 } 326 }
325 process_pending_messages (client); 327 process_pending_messages (client);
326 GNUNET_log (GNUNET_ERROR_TYPE_DEBUG, "Transmitted %u/%u bytes to client %p\n", 328 GNUNET_log (GNUNET_ERROR_TYPE_DEBUG,
327 (unsigned int) off, (unsigned int) size, client->client_handle); 329 "Transmitted %u/%u bytes to client %p\n",
330 (unsigned int) off,
331 (unsigned int) size,
332 client->client_handle);
328 return off; 333 return off;
329} 334}
330 335
diff --git a/src/dht/gnunet-service-xdht_neighbours.c b/src/dht/gnunet-service-xdht_neighbours.c
index c6de94a5a..6f3137f8a 100644
--- a/src/dht/gnunet-service-xdht_neighbours.c
+++ b/src/dht/gnunet-service-xdht_neighbours.c
@@ -3309,8 +3309,10 @@ send_verify_successor_message (void *cls)
3309 trail_id = trail->trail_id; 3309 trail_id = trail->trail_id;
3310 if (NULL == GDS_ROUTING_get_next_hop(trail_id,GDS_ROUTING_SRC_TO_DEST)) 3310 if (NULL == GDS_ROUTING_get_next_hop(trail_id,GDS_ROUTING_SRC_TO_DEST))
3311 { 3311 {
3312 DEBUG(" NO ENTRY FOUND IN %s ROUTING TABLE for trail id %s, line", 3312 DEBUG(" NO ENTRY FOUND IN %s ROUTING TABLE for trail id %s, line %u",
3313 GNUNET_i2s(&my_identity), GNUNET_h2s(&trail->trail_id), __LINE__); 3313 GNUNET_i2s (&my_identity),
3314 GNUNET_h2s (&trail->trail_id),
3315 __LINE__);
3314 GNUNET_break(0); 3316 GNUNET_break(0);
3315 return; 3317 return;
3316 } 3318 }
@@ -5352,8 +5354,10 @@ handle_dht_p2p_verify_successor_result(void *cls,
5352 { 5354 {
5353 /* Here it may happen that source peer has found a new successor, and removed 5355 /* Here it may happen that source peer has found a new successor, and removed
5354 the trail, Hence no entry found in the routing table. Fail silently.*/ 5356 the trail, Hence no entry found in the routing table. Fail silently.*/
5355 DEBUG(" NO ENTRY FOUND IN %s ROUTING TABLE for trail id %s, line", 5357 DEBUG (" NO ENTRY FOUND IN %s ROUTING TABLE for trail id %s, line %u",
5356 GNUNET_i2s(&my_identity), GNUNET_h2s(&trail_id), __LINE__); 5358 GNUNET_i2s (&my_identity),
5359 GNUNET_h2s (&trail_id),
5360 __LINE__);
5357 GNUNET_break_op(0); 5361 GNUNET_break_op(0);
5358 return GNUNET_OK; 5362 return GNUNET_OK;
5359 } 5363 }
@@ -5773,8 +5777,10 @@ handle_dht_p2p_trail_teardown (void *cls, const struct GNUNET_PeerIdentity *peer
5773 next_hop = GDS_ROUTING_get_next_hop (trail_id, trail_direction); 5777 next_hop = GDS_ROUTING_get_next_hop (trail_id, trail_direction);
5774 if (NULL == next_hop) 5778 if (NULL == next_hop)
5775 { 5779 {
5776 DEBUG(" NO ENTRY FOUND IN %s ROUTING TABLE for trail id %s, line", 5780 DEBUG(" NO ENTRY FOUND IN %s ROUTING TABLE for trail id %s, line %u",
5777 GNUNET_i2s(&my_identity), GNUNET_h2s(&trail_id), __LINE__); 5781 GNUNET_i2s (&my_identity),
5782 GNUNET_h2s(&trail_id),
5783 __LINE__);
5778 GNUNET_break (0); 5784 GNUNET_break (0);
5779 return GNUNET_SYSERR; 5785 return GNUNET_SYSERR;
5780 } 5786 }
diff --git a/src/dht/gnunet_dht_profiler.c b/src/dht/gnunet_dht_profiler.c
index 03ea62152..065ea5d1b 100644
--- a/src/dht/gnunet_dht_profiler.c
+++ b/src/dht/gnunet_dht_profiler.c
@@ -494,8 +494,10 @@ bandwidth_stats_cont (void *cls,
494 struct GNUNET_TESTBED_Operation *op, 494 struct GNUNET_TESTBED_Operation *op,
495 const char *emsg) 495 const char *emsg)
496{ 496{
497 INFO ("# Outgoing bandwidth: %u\n", outgoing_bandwidth); 497 INFO ("# Outgoing bandwidth: %llu\n",
498 INFO ("# Incoming bandwidth: %u\n", incoming_bandwidth); 498 (unsigned long long) outgoing_bandwidth);
499 INFO ("# Incoming bandwidth: %llu\n",
500 (unsigned long long) incoming_bandwidth);
499 GNUNET_SCHEDULER_shutdown (); 501 GNUNET_SCHEDULER_shutdown ();
500} 502}
501 503
@@ -508,8 +510,8 @@ bandwidth_stats_cont (void *cls,
508 * @param subsystem name of subsystem that created the statistic 510 * @param subsystem name of subsystem that created the statistic
509 * @param name the name of the datum 511 * @param name the name of the datum
510 * @param value the current value 512 * @param value the current value
511 * @param is_persistent GNUNET_YES if the value is persistent, GNUNET_NO if not 513 * @param is_persistent #GNUNET_YES if the value is persistent, #GNUNET_NO if not
512 * @return GNUNET_OK to continue, GNUNET_SYSERR to abort iteration 514 * @return #GNUNET_OK to continue, #GNUNET_SYSERR to abort iteration
513 */ 515 */
514static int 516static int
515bandwidth_stats_iterator (void *cls, 517bandwidth_stats_iterator (void *cls,
@@ -635,7 +637,8 @@ get_iter (void *cls,
635 637
636 total_put_path_length = total_put_path_length + (double)put_path_length; 638 total_put_path_length = total_put_path_length + (double)put_path_length;
637 total_get_path_length = total_get_path_length + (double)get_path_length; 639 total_get_path_length = total_get_path_length + (double)get_path_length;
638 DEBUG ("total_put_path_length = %f,put_path \n",total_put_path_length); 640 DEBUG ("total_put_path_length = %u,put_path \n",
641 total_put_path_length);
639 /* Summarize if profiling is complete */ 642 /* Summarize if profiling is complete */
640 if (n_active == n_gets_fail + n_gets_ok) 643 if (n_active == n_gets_fail + n_gets_ok)
641 { 644 {