diff options
author | Christian Grothoff <christian@grothoff.org> | 2010-11-01 22:44:28 +0000 |
---|---|---|
committer | Christian Grothoff <christian@grothoff.org> | 2010-11-01 22:44:28 +0000 |
commit | bdef044d942a5f75f698bef989a1e768e79d2976 (patch) | |
tree | 59ef3e1b4158bb1ab76af5d88df503a69f5ab3be | |
parent | e9cf3782a3c5c2bcf6bdeff58b8a3536585791eb (diff) | |
download | gnunet-bdef044d942a5f75f698bef989a1e768e79d2976.tar.gz gnunet-bdef044d942a5f75f698bef989a1e768e79d2976.zip |
fixes from LRN for DEBUG code
-rw-r--r-- | src/core/gnunet-service-core.c | 6 | ||||
-rw-r--r-- | src/datastore/datastore_api.c | 4 | ||||
-rw-r--r-- | src/datastore/plugin_datastore_sqlite.c | 4 | ||||
-rw-r--r-- | src/dht/plugin_dhtlog_mysql_dump.c | 10 | ||||
-rw-r--r-- | src/dht/plugin_dhtlog_mysql_dump_load.c | 10 | ||||
-rw-r--r-- | src/dv/gnunet-service-dv.c | 3 | ||||
-rw-r--r-- | src/fs/gnunet-service-fs.c | 10 | ||||
-rw-r--r-- | src/statistics/gnunet-service-statistics.c | 8 | ||||
-rw-r--r-- | src/topology/gnunet-daemon-topology.c | 4 | ||||
-rw-r--r-- | src/transport/gnunet-service-transport.c | 8 | ||||
-rw-r--r-- | src/transport/transport_api.c | 18 |
11 files changed, 43 insertions, 42 deletions
diff --git a/src/core/gnunet-service-core.c b/src/core/gnunet-service-core.c index 5e71ef897..767041087 100644 --- a/src/core/gnunet-service-core.c +++ b/src/core/gnunet-service-core.c | |||
@@ -42,9 +42,9 @@ | |||
42 | #include "core.h" | 42 | #include "core.h" |
43 | 43 | ||
44 | 44 | ||
45 | #define DEBUG_HANDSHAKE GNUNET_NO | 45 | #define DEBUG_HANDSHAKE GNUNET_YES |
46 | 46 | ||
47 | #define DEBUG_CORE_QUOTA GNUNET_NO | 47 | #define DEBUG_CORE_QUOTA GNUNET_YES |
48 | 48 | ||
49 | /** | 49 | /** |
50 | * Receive and send buffer windows grow over time. For | 50 | * Receive and send buffer windows grow over time. For |
@@ -3540,7 +3540,7 @@ handle_encrypted_message (struct Neighbour *n, | |||
3540 | #if DEBUG_CORE_SET_QUOTA | 3540 | #if DEBUG_CORE_SET_QUOTA |
3541 | GNUNET_log (GNUNET_ERROR_TYPE_DEBUG, | 3541 | GNUNET_log (GNUNET_ERROR_TYPE_DEBUG, |
3542 | "Received %u b/s as new inbound limit for peer `%4s'\n", | 3542 | "Received %u b/s as new inbound limit for peer `%4s'\n", |
3543 | (unsigned int) ntohl (pt->inbound_bw_limit.rel_value__), | 3543 | (unsigned int) ntohl (pt->inbound_bw_limit.value__), |
3544 | GNUNET_i2s (&n->peer)); | 3544 | GNUNET_i2s (&n->peer)); |
3545 | #endif | 3545 | #endif |
3546 | n->bw_out_external_limit = pt->inbound_bw_limit; | 3546 | n->bw_out_external_limit = pt->inbound_bw_limit; |
diff --git a/src/datastore/datastore_api.c b/src/datastore/datastore_api.c index 4172b5c99..6c817a840 100644 --- a/src/datastore/datastore_api.c +++ b/src/datastore/datastore_api.c | |||
@@ -1318,7 +1318,7 @@ GNUNET_DATASTORE_get_random (struct GNUNET_DATASTORE_Handle *h, | |||
1318 | #if DEBUG_DATASTORE | 1318 | #if DEBUG_DATASTORE |
1319 | GNUNET_log (GNUNET_ERROR_TYPE_DEBUG, | 1319 | GNUNET_log (GNUNET_ERROR_TYPE_DEBUG, |
1320 | "Asked to get random entry in %llu ms\n", | 1320 | "Asked to get random entry in %llu ms\n", |
1321 | (unsigned long long) timeout.abs_value); | 1321 | (unsigned long long) timeout.rel_value); |
1322 | #endif | 1322 | #endif |
1323 | qc.rc.iter = iter; | 1323 | qc.rc.iter = iter; |
1324 | qc.rc.iter_cls = iter_cls; | 1324 | qc.rc.iter_cls = iter_cls; |
@@ -1378,7 +1378,7 @@ GNUNET_DATASTORE_get_zero_anonymity (struct GNUNET_DATASTORE_Handle *h, | |||
1378 | #if DEBUG_DATASTORE | 1378 | #if DEBUG_DATASTORE |
1379 | GNUNET_log (GNUNET_ERROR_TYPE_DEBUG, | 1379 | GNUNET_log (GNUNET_ERROR_TYPE_DEBUG, |
1380 | "Asked to get zero-anonymity entry in %llu ms\n", | 1380 | "Asked to get zero-anonymity entry in %llu ms\n", |
1381 | (unsigned long long) timeout.abs_value); | 1381 | (unsigned long long) timeout.rel_value); |
1382 | #endif | 1382 | #endif |
1383 | qc.rc.iter = iter; | 1383 | qc.rc.iter = iter; |
1384 | qc.rc.iter_cls = iter_cls; | 1384 | qc.rc.iter_cls = iter_cls; |
diff --git a/src/datastore/plugin_datastore_sqlite.c b/src/datastore/plugin_datastore_sqlite.c index 05ebed7c5..01df7b670 100644 --- a/src/datastore/plugin_datastore_sqlite.c +++ b/src/datastore/plugin_datastore_sqlite.c | |||
@@ -28,7 +28,7 @@ | |||
28 | #include "plugin_datastore.h" | 28 | #include "plugin_datastore.h" |
29 | #include <sqlite3.h> | 29 | #include <sqlite3.h> |
30 | 30 | ||
31 | #define DEBUG_SQLITE GNUNET_NO | 31 | #define DEBUG_SQLITE GNUNET_YES |
32 | 32 | ||
33 | 33 | ||
34 | /** | 34 | /** |
@@ -667,7 +667,7 @@ sqlite_plugin_put (void *cls, | |||
667 | type, | 667 | type, |
668 | GNUNET_h2s(key), | 668 | GNUNET_h2s(key), |
669 | priority, | 669 | priority, |
670 | (unsigned long long) GNUNET_TIME_absolute_get_remaining (expiration).abs_value, | 670 | (unsigned long long) GNUNET_TIME_absolute_get_remaining (expiration).rel_value, |
671 | (long long) expiration.abs_value); | 671 | (long long) expiration.abs_value); |
672 | #endif | 672 | #endif |
673 | GNUNET_CRYPTO_hash (data, size, &vhash); | 673 | GNUNET_CRYPTO_hash (data, size, &vhash); |
diff --git a/src/dht/plugin_dhtlog_mysql_dump.c b/src/dht/plugin_dhtlog_mysql_dump.c index 8b16c155d..f8a2811b1 100644 --- a/src/dht/plugin_dhtlog_mysql_dump.c +++ b/src/dht/plugin_dhtlog_mysql_dump.c | |||
@@ -35,7 +35,7 @@ | |||
35 | #include "dhtlog.h" | 35 | #include "dhtlog.h" |
36 | 36 | ||
37 | 37 | ||
38 | #define DEBUG_DHTLOG GNUNET_NO | 38 | #define DEBUG_DHTLOG GNUNET_YES |
39 | 39 | ||
40 | /** | 40 | /** |
41 | * Maximum number of supported parameters for a prepared | 41 | * Maximum number of supported parameters for a prepared |
@@ -519,11 +519,11 @@ update_trials (unsigned long long trialuid, | |||
519 | { | 519 | { |
520 | int ret; | 520 | int ret; |
521 | #if DEBUG_DHTLOG | 521 | #if DEBUG_DHTLOG |
522 | if (trialuid != current_trial) | 522 | /* if (trialuid != current_trial) |
523 | { | 523 | { |
524 | fprintf (stderr, | 524 | fprintf (stderr, |
525 | _("Trialuid to update is not equal to current_trial\n")); | 525 | _("Trialuid to update is not equal to current_trial\n")); |
526 | } | 526 | }*/ |
527 | #endif | 527 | #endif |
528 | 528 | ||
529 | if (outfile == NULL) | 529 | if (outfile == NULL) |
@@ -586,11 +586,11 @@ add_connections (unsigned long long trialuid, unsigned int totalConnections) | |||
586 | { | 586 | { |
587 | int ret; | 587 | int ret; |
588 | #if DEBUG_DHTLOG | 588 | #if DEBUG_DHTLOG |
589 | if (trialuid != current_trial) | 589 | /* if (trialuid != current_trial) |
590 | { | 590 | { |
591 | fprintf (stderr, | 591 | fprintf (stderr, |
592 | _("Trialuid to update is not equal to current_trial(!)(?)\n")); | 592 | _("Trialuid to update is not equal to current_trial(!)(?)\n")); |
593 | } | 593 | }*/ |
594 | #endif | 594 | #endif |
595 | if (outfile == NULL) | 595 | if (outfile == NULL) |
596 | return GNUNET_SYSERR; | 596 | return GNUNET_SYSERR; |
diff --git a/src/dht/plugin_dhtlog_mysql_dump_load.c b/src/dht/plugin_dhtlog_mysql_dump_load.c index ac4b91301..a5231d9eb 100644 --- a/src/dht/plugin_dhtlog_mysql_dump_load.c +++ b/src/dht/plugin_dhtlog_mysql_dump_load.c | |||
@@ -36,7 +36,7 @@ | |||
36 | #include "dhtlog.h" | 36 | #include "dhtlog.h" |
37 | 37 | ||
38 | 38 | ||
39 | #define DEBUG_DHTLOG GNUNET_NO | 39 | #define DEBUG_DHTLOG GNUNET_YES |
40 | 40 | ||
41 | /** | 41 | /** |
42 | * Maximum number of supported parameters for a prepared | 42 | * Maximum number of supported parameters for a prepared |
@@ -347,11 +347,11 @@ update_trials (unsigned long long trialuid, | |||
347 | { | 347 | { |
348 | int ret; | 348 | int ret; |
349 | #if DEBUG_DHTLOG | 349 | #if DEBUG_DHTLOG |
350 | if (trialuid != current_trial) | 350 | /* if (trialuid != current_trial) |
351 | { | 351 | { |
352 | fprintf (stderr, | 352 | fprintf (stderr, |
353 | _("Trialuid to update is not equal to current_trial\n")); | 353 | _("Trialuid to update is not equal to current_trial\n")); |
354 | } | 354 | }*/ |
355 | #endif | 355 | #endif |
356 | 356 | ||
357 | if (outfile == NULL) | 357 | if (outfile == NULL) |
@@ -404,11 +404,11 @@ add_connections (unsigned long long trialuid, unsigned int totalConnections) | |||
404 | { | 404 | { |
405 | int ret; | 405 | int ret; |
406 | #if DEBUG_DHTLOG | 406 | #if DEBUG_DHTLOG |
407 | if (trialuid != current_trial) | 407 | /* if (trialuid != current_trial) |
408 | { | 408 | { |
409 | fprintf (stderr, | 409 | fprintf (stderr, |
410 | _("Trialuid to update is not equal to current_trial(!)(?)\n")); | 410 | _("Trialuid to update is not equal to current_trial(!)(?)\n")); |
411 | } | 411 | }*/ |
412 | #endif | 412 | #endif |
413 | if (outfile == NULL) | 413 | if (outfile == NULL) |
414 | return GNUNET_SYSERR; | 414 | return GNUNET_SYSERR; |
diff --git a/src/dv/gnunet-service-dv.c b/src/dv/gnunet-service-dv.c index c9360fbb4..2d91bce41 100644 --- a/src/dv/gnunet-service-dv.c +++ b/src/dv/gnunet-service-dv.c | |||
@@ -1534,9 +1534,10 @@ static int handle_dv_data_message (void *cls, | |||
1534 | else | 1534 | else |
1535 | { | 1535 | { |
1536 | #if DEBUG_MESSAGE_DROP | 1536 | #if DEBUG_MESSAGE_DROP |
1537 | direct_id = GNUNET_strdup(GNUNET_i2s(&dn->identity)); | 1537 | char *direct_id = GNUNET_strdup(GNUNET_i2s(&dn->identity)); |
1538 | GNUNET_log (GNUNET_ERROR_TYPE_DEBUG, | 1538 | GNUNET_log (GNUNET_ERROR_TYPE_DEBUG, |
1539 | "%s: DROPPING MESSAGE type %d, forwarding failed! Message immediately from %s!\n", GNUNET_i2s(&my_identity), ntohs(((struct GNUNET_MessageHeader *)&incoming[1])->type), direct_id); | 1539 | "%s: DROPPING MESSAGE type %d, forwarding failed! Message immediately from %s!\n", GNUNET_i2s(&my_identity), ntohs(((struct GNUNET_MessageHeader *)&incoming[1])->type), direct_id); |
1540 | GNUNET_free (direct_id); | ||
1540 | #endif | 1541 | #endif |
1541 | return GNUNET_SYSERR; | 1542 | return GNUNET_SYSERR; |
1542 | } | 1543 | } |
diff --git a/src/fs/gnunet-service-fs.c b/src/fs/gnunet-service-fs.c index 1cd114261..ad770f779 100644 --- a/src/fs/gnunet-service-fs.c +++ b/src/fs/gnunet-service-fs.c | |||
@@ -41,7 +41,7 @@ | |||
41 | #include "gnunet-service-fs_indexing.h" | 41 | #include "gnunet-service-fs_indexing.h" |
42 | #include "fs.h" | 42 | #include "fs.h" |
43 | 43 | ||
44 | #define DEBUG_FS GNUNET_NO | 44 | #define DEBUG_FS GNUNET_YES |
45 | 45 | ||
46 | /** | 46 | /** |
47 | * Should we introduce random latency in processing? Required for proper | 47 | * Should we introduce random latency in processing? Required for proper |
@@ -2789,7 +2789,7 @@ target_peer_select_cb (void *cls, | |||
2789 | GNUNET_log (GNUNET_ERROR_TYPE_WARNING, | 2789 | GNUNET_log (GNUNET_ERROR_TYPE_WARNING, |
2790 | "NOT sending query since we send %u others to this peer in the last %llums\n", | 2790 | "NOT sending query since we send %u others to this peer in the last %llums\n", |
2791 | MAX_QUEUE_PER_PEER, | 2791 | MAX_QUEUE_PER_PEER, |
2792 | cp->avg_delay.abs_value); | 2792 | cp->avg_delay.rel_value); |
2793 | #endif | 2793 | #endif |
2794 | return GNUNET_YES; /* skip */ | 2794 | return GNUNET_YES; /* skip */ |
2795 | } | 2795 | } |
@@ -2964,7 +2964,7 @@ forward_request_task (void *cls, | |||
2964 | GNUNET_log (GNUNET_ERROR_TYPE_DEBUG, | 2964 | GNUNET_log (GNUNET_ERROR_TYPE_DEBUG, |
2965 | "No peer selected for forwarding of query `%s', will try again in %llu ms!\n", | 2965 | "No peer selected for forwarding of query `%s', will try again in %llu ms!\n", |
2966 | GNUNET_h2s (&pr->query), | 2966 | GNUNET_h2s (&pr->query), |
2967 | delay.abs_value); | 2967 | delay.rel_value); |
2968 | #endif | 2968 | #endif |
2969 | pr->task = GNUNET_SCHEDULER_add_delayed (sched, | 2969 | pr->task = GNUNET_SCHEDULER_add_delayed (sched, |
2970 | delay, | 2970 | delay, |
@@ -3283,9 +3283,9 @@ struct GNUNET_TIME_Relative art_delay; | |||
3283 | 1, | 3283 | 1, |
3284 | GNUNET_NO); | 3284 | GNUNET_NO); |
3285 | #if DEBUG_FS | 3285 | #if DEBUG_FS |
3286 | GNUNET_log (GNUNET_ERROR_TYPE_DEBUG, | 3286 | /* GNUNET_log (GNUNET_ERROR_TYPE_DEBUG, |
3287 | "Duplicate response `%s', discarding.\n", | 3287 | "Duplicate response `%s', discarding.\n", |
3288 | GNUNET_h2s (&mhash)); | 3288 | GNUNET_h2s (&mhash));*/ |
3289 | #endif | 3289 | #endif |
3290 | return GNUNET_YES; /* duplicate */ | 3290 | return GNUNET_YES; /* duplicate */ |
3291 | case GNUNET_BLOCK_EVALUATION_RESULT_INVALID: | 3291 | case GNUNET_BLOCK_EVALUATION_RESULT_INVALID: |
diff --git a/src/statistics/gnunet-service-statistics.c b/src/statistics/gnunet-service-statistics.c index 50f347694..92f79cc91 100644 --- a/src/statistics/gnunet-service-statistics.c +++ b/src/statistics/gnunet-service-statistics.c | |||
@@ -305,7 +305,7 @@ transmit (struct GNUNET_SERVER_Client *client, | |||
305 | GNUNET_log (GNUNET_ERROR_TYPE_DEBUG, | 305 | GNUNET_log (GNUNET_ERROR_TYPE_DEBUG, |
306 | "Transmitting value for `%s:%s' (%d): %llu\n", | 306 | "Transmitting value for `%s:%s' (%d): %llu\n", |
307 | e->service, e->name, | 307 | e->service, e->name, |
308 | e->persistent, e->abs_value); | 308 | e->persistent, e->value); |
309 | #endif | 309 | #endif |
310 | GNUNET_SERVER_notification_context_unicast (nc, client, &m->header, GNUNET_NO); | 310 | GNUNET_SERVER_notification_context_unicast (nc, client, &m->header, GNUNET_NO); |
311 | GNUNET_free (m); | 311 | GNUNET_free (m); |
@@ -479,7 +479,7 @@ handle_set (void *cls, | |||
479 | "Received request to update statistic on `%s:%s' (%u) to/by %llu\n", | 479 | "Received request to update statistic on `%s:%s' (%u) to/by %llu\n", |
480 | service, name, | 480 | service, name, |
481 | (unsigned int) flags, | 481 | (unsigned int) flags, |
482 | (unsigned long long) abs_value); | 482 | (unsigned long long) value); |
483 | #endif | 483 | #endif |
484 | pos = start; | 484 | pos = start; |
485 | prev = NULL; | 485 | prev = NULL; |
@@ -522,7 +522,7 @@ handle_set (void *cls, | |||
522 | #if DEBUG_STATISTICS | 522 | #if DEBUG_STATISTICS |
523 | GNUNET_log (GNUNET_ERROR_TYPE_DEBUG, | 523 | GNUNET_log (GNUNET_ERROR_TYPE_DEBUG, |
524 | "Statistic `%s:%s' updated to value %llu.\n", | 524 | "Statistic `%s:%s' updated to value %llu.\n", |
525 | service, name, pos->abs_value); | 525 | service, name, pos->value); |
526 | #endif | 526 | #endif |
527 | if (changed) | 527 | if (changed) |
528 | notify_change (pos); | 528 | notify_change (pos); |
@@ -548,7 +548,7 @@ handle_set (void *cls, | |||
548 | #if DEBUG_STATISTICS | 548 | #if DEBUG_STATISTICS |
549 | GNUNET_log (GNUNET_ERROR_TYPE_DEBUG, | 549 | GNUNET_log (GNUNET_ERROR_TYPE_DEBUG, |
550 | "New statistic on `%s:%s' with value %llu created.\n", | 550 | "New statistic on `%s:%s' with value %llu created.\n", |
551 | service, name, pos->abs_value); | 551 | service, name, pos->value); |
552 | #endif | 552 | #endif |
553 | GNUNET_SERVER_receive_done (client, GNUNET_OK); | 553 | GNUNET_SERVER_receive_done (client, GNUNET_OK); |
554 | } | 554 | } |
diff --git a/src/topology/gnunet-daemon-topology.c b/src/topology/gnunet-daemon-topology.c index fa693f13a..dc7face2d 100644 --- a/src/topology/gnunet-daemon-topology.c +++ b/src/topology/gnunet-daemon-topology.c | |||
@@ -35,7 +35,7 @@ | |||
35 | #include "gnunet_util_lib.h" | 35 | #include "gnunet_util_lib.h" |
36 | 36 | ||
37 | 37 | ||
38 | #define DEBUG_TOPOLOGY GNUNET_NO | 38 | #define DEBUG_TOPOLOGY GNUNET_YES |
39 | 39 | ||
40 | /** | 40 | /** |
41 | * For how long do we blacklist a peer after a failed connection | 41 | * For how long do we blacklist a peer after a failed connection |
@@ -1275,7 +1275,7 @@ hello_advertising_ready (void *cls, | |||
1275 | #if DEBUG_TOPOLOGY | 1275 | #if DEBUG_TOPOLOGY |
1276 | GNUNET_log (GNUNET_ERROR_TYPE_DEBUG, | 1276 | GNUNET_log (GNUNET_ERROR_TYPE_DEBUG, |
1277 | "Sending `%s' with %u bytes", | 1277 | "Sending `%s' with %u bytes", |
1278 | "HELLO" | 1278 | "HELLO", |
1279 | (unsigned int) want); | 1279 | (unsigned int) want); |
1280 | #endif | 1280 | #endif |
1281 | GNUNET_STATISTICS_update (stats, | 1281 | GNUNET_STATISTICS_update (stats, |
diff --git a/src/transport/gnunet-service-transport.c b/src/transport/gnunet-service-transport.c index c1bb7bec6..87d73baf4 100644 --- a/src/transport/gnunet-service-transport.c +++ b/src/transport/gnunet-service-transport.c | |||
@@ -39,9 +39,9 @@ | |||
39 | #include "plugin_transport.h" | 39 | #include "plugin_transport.h" |
40 | #include "transport.h" | 40 | #include "transport.h" |
41 | 41 | ||
42 | #define DEBUG_BLACKLIST GNUNET_NO | 42 | #define DEBUG_BLACKLIST GNUNET_YES |
43 | 43 | ||
44 | #define DEBUG_PING_PONG GNUNET_NO | 44 | #define DEBUG_PING_PONG GNUNET_YES |
45 | 45 | ||
46 | #define DEBUG_TRANSPORT_HELLO GNUNET_YES | 46 | #define DEBUG_TRANSPORT_HELLO GNUNET_YES |
47 | 47 | ||
@@ -1554,7 +1554,7 @@ find_ready_address(struct NeighbourList *neighbour) | |||
1554 | best_address->addr, | 1554 | best_address->addr, |
1555 | best_address->addrlen) | 1555 | best_address->addrlen) |
1556 | : "<inbound>", | 1556 | : "<inbound>", |
1557 | best_address->latency.abs_value); | 1557 | best_address->latency.rel_value); |
1558 | #endif | 1558 | #endif |
1559 | } | 1559 | } |
1560 | else | 1560 | else |
@@ -1667,7 +1667,7 @@ try_transmission_to_peer (struct NeighbourList *neighbour) | |||
1667 | "No validated destination address available to transmit message of size %u to peer `%4s', will wait %llums to find an address.\n", | 1667 | "No validated destination address available to transmit message of size %u to peer `%4s', will wait %llums to find an address.\n", |
1668 | mq->message_buf_size, | 1668 | mq->message_buf_size, |
1669 | GNUNET_i2s (&mq->neighbour_id), | 1669 | GNUNET_i2s (&mq->neighbour_id), |
1670 | timeout.abs_value); | 1670 | timeout.rel_value); |
1671 | #endif | 1671 | #endif |
1672 | /* FIXME: might want to trigger peerinfo lookup here | 1672 | /* FIXME: might want to trigger peerinfo lookup here |
1673 | (unless that's already pending...) */ | 1673 | (unless that's already pending...) */ |
diff --git a/src/transport/transport_api.c b/src/transport/transport_api.c index ad81940ae..5410aca8a 100644 --- a/src/transport/transport_api.c +++ b/src/transport/transport_api.c | |||
@@ -471,7 +471,7 @@ schedule_peer_transmission (struct GNUNET_TRANSPORT_Handle *h) | |||
471 | #if DEBUG_TRANSPORT | 471 | #if DEBUG_TRANSPORT |
472 | GNUNET_log (GNUNET_ERROR_TYPE_DEBUG, | 472 | GNUNET_log (GNUNET_ERROR_TYPE_DEBUG, |
473 | "Would need %llu ms before bandwidth is available for delivery to `%4s', that is too long. Signaling timeout.\n", | 473 | "Would need %llu ms before bandwidth is available for delivery to `%4s', that is too long. Signaling timeout.\n", |
474 | duration.abs_value, | 474 | duration.rel_value, |
475 | GNUNET_i2s (&n->id)); | 475 | GNUNET_i2s (&n->id)); |
476 | #endif | 476 | #endif |
477 | if (th->notify_delay_task != GNUNET_SCHEDULER_NO_TASK) | 477 | if (th->notify_delay_task != GNUNET_SCHEDULER_NO_TASK) |
@@ -492,7 +492,7 @@ schedule_peer_transmission (struct GNUNET_TRANSPORT_Handle *h) | |||
492 | (unsigned int) n->out_tracker.available_bytes_per_s__, | 492 | (unsigned int) n->out_tracker.available_bytes_per_s__, |
493 | (unsigned int) th->notify_size - sizeof (struct OutboundMessage), | 493 | (unsigned int) th->notify_size - sizeof (struct OutboundMessage), |
494 | GNUNET_i2s (&n->id), | 494 | GNUNET_i2s (&n->id), |
495 | duration.abs_value); | 495 | duration.rel_value); |
496 | #endif | 496 | #endif |
497 | retry_time = GNUNET_TIME_relative_min (retry_time, | 497 | retry_time = GNUNET_TIME_relative_min (retry_time, |
498 | duration); | 498 | duration); |
@@ -608,7 +608,7 @@ transport_notify_ready (void *cls, size_t size, void *buf) | |||
608 | GNUNET_log (GNUNET_ERROR_TYPE_DEBUG, | 608 | GNUNET_log (GNUNET_ERROR_TYPE_DEBUG, |
609 | "Message of %u bytes with timeout %llums constructed for `%4s'\n", | 609 | "Message of %u bytes with timeout %llums constructed for `%4s'\n", |
610 | (unsigned int) mret, | 610 | (unsigned int) mret, |
611 | (unsigned long long) GNUNET_TIME_absolute_get_remaining (th->timeout).abs_value, | 611 | (unsigned long long) GNUNET_TIME_absolute_get_remaining (th->timeout).rel_value, |
612 | GNUNET_i2s (&n->id)); | 612 | GNUNET_i2s (&n->id)); |
613 | #endif | 613 | #endif |
614 | if (mret != 0) | 614 | if (mret != 0) |
@@ -755,7 +755,7 @@ schedule_control_transmit (struct GNUNET_TRANSPORT_Handle *h, | |||
755 | #if DEBUG_TRANSPORT | 755 | #if DEBUG_TRANSPORT |
756 | GNUNET_log (GNUNET_ERROR_TYPE_DEBUG, | 756 | GNUNET_log (GNUNET_ERROR_TYPE_DEBUG, |
757 | "Control transmit of %u bytes within %llums requested\n", | 757 | "Control transmit of %u bytes within %llums requested\n", |
758 | size, (unsigned long long) timeout.abs_value); | 758 | size, (unsigned long long) timeout.rel_value); |
759 | #endif | 759 | #endif |
760 | th = GNUNET_malloc (sizeof (struct ControlMessage)); | 760 | th = GNUNET_malloc (sizeof (struct ControlMessage)); |
761 | th->h = h; | 761 | th->h = h; |
@@ -868,11 +868,11 @@ GNUNET_TRANSPORT_set_quota (struct GNUNET_TRANSPORT_Handle *handle, | |||
868 | if (n != NULL) | 868 | if (n != NULL) |
869 | { | 869 | { |
870 | #if DEBUG_TRANSPORT | 870 | #if DEBUG_TRANSPORT |
871 | if (ntohl (quota_out.rel_value__) != n->out_tracker.available_bytes_per_s__) | 871 | if (ntohl (quota_out.value__) != n->out_tracker.available_bytes_per_s__) |
872 | GNUNET_log (GNUNET_ERROR_TYPE_DEBUG, | 872 | GNUNET_log (GNUNET_ERROR_TYPE_DEBUG, |
873 | "Quota changed from %u to %u for peer `%s'\n", | 873 | "Quota changed from %u to %u for peer `%s'\n", |
874 | (unsigned int) n->out_tracker.available_bytes_per_s__, | 874 | (unsigned int) n->out_tracker.available_bytes_per_s__, |
875 | (unsigned int) ntohl (quota_out.rel_value__), | 875 | (unsigned int) ntohl (quota_out.value__), |
876 | GNUNET_i2s (target)); | 876 | GNUNET_i2s (target)); |
877 | else | 877 | else |
878 | GNUNET_log (GNUNET_ERROR_TYPE_DEBUG, | 878 | GNUNET_log (GNUNET_ERROR_TYPE_DEBUG, |
@@ -888,7 +888,7 @@ GNUNET_TRANSPORT_set_quota (struct GNUNET_TRANSPORT_Handle *handle, | |||
888 | #if DEBUG_TRANSPORT | 888 | #if DEBUG_TRANSPORT |
889 | GNUNET_log (GNUNET_ERROR_TYPE_DEBUG, | 889 | GNUNET_log (GNUNET_ERROR_TYPE_DEBUG, |
890 | "Quota changed to %u for peer `%s', but I have no such neighbour!\n", | 890 | "Quota changed to %u for peer `%s', but I have no such neighbour!\n", |
891 | (unsigned int) ntohl (quota_out.rel_value__), | 891 | (unsigned int) ntohl (quota_out.value__), |
892 | GNUNET_i2s (target)); | 892 | GNUNET_i2s (target)); |
893 | #endif | 893 | #endif |
894 | } | 894 | } |
@@ -1235,7 +1235,7 @@ schedule_reconnect (struct GNUNET_TRANSPORT_Handle *h) | |||
1235 | #if DEBUG_TRANSPORT | 1235 | #if DEBUG_TRANSPORT |
1236 | GNUNET_log (GNUNET_ERROR_TYPE_DEBUG, | 1236 | GNUNET_log (GNUNET_ERROR_TYPE_DEBUG, |
1237 | "Scheduling task to reconnect to transport service in %llu ms.\n", | 1237 | "Scheduling task to reconnect to transport service in %llu ms.\n", |
1238 | h->reconnect_delay.abs_value); | 1238 | h->reconnect_delay.rel_value); |
1239 | #endif | 1239 | #endif |
1240 | GNUNET_assert (h->client == NULL); | 1240 | GNUNET_assert (h->client == NULL); |
1241 | GNUNET_assert (h->reconnect_task == GNUNET_SCHEDULER_NO_TASK); | 1241 | GNUNET_assert (h->reconnect_task == GNUNET_SCHEDULER_NO_TASK); |
@@ -1802,7 +1802,7 @@ GNUNET_TRANSPORT_notify_transmit_ready (struct GNUNET_TRANSPORT_Handle | |||
1802 | GNUNET_log (GNUNET_ERROR_TYPE_DEBUG, | 1802 | GNUNET_log (GNUNET_ERROR_TYPE_DEBUG, |
1803 | "Asking transport service for transmission of %u bytes to peer `%4s' within %llu ms.\n", | 1803 | "Asking transport service for transmission of %u bytes to peer `%4s' within %llu ms.\n", |
1804 | size, GNUNET_i2s (target), | 1804 | size, GNUNET_i2s (target), |
1805 | (unsigned long long) timeout.abs_value); | 1805 | (unsigned long long) timeout.rel_value); |
1806 | #endif | 1806 | #endif |
1807 | n = neighbour_find (handle, target); | 1807 | n = neighbour_find (handle, target); |
1808 | if (n == NULL) | 1808 | if (n == NULL) |