diff options
Diffstat (limited to 'src/dht')
-rw-r--r-- | src/dht/gnunet-service-dht_clients.c | 13 | ||||
-rw-r--r-- | src/dht/gnunet-service-wdht_clients.c | 13 | ||||
-rw-r--r-- | src/dht/gnunet-service-xdht_clients.c | 13 | ||||
-rw-r--r-- | src/dht/gnunet-service-xdht_neighbours.c | 18 | ||||
-rw-r--r-- | src/dht/gnunet_dht_profiler.c | 13 |
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 | */ |
514 | static int | 516 | static int |
515 | bandwidth_stats_iterator (void *cls, | 517 | bandwidth_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 | { |