diff options
Diffstat (limited to 'src/ats/ats_api_performance.c')
-rw-r--r-- | src/ats/ats_api_performance.c | 22 |
1 files changed, 12 insertions, 10 deletions
diff --git a/src/ats/ats_api_performance.c b/src/ats/ats_api_performance.c index e81f0d394..51980f079 100644 --- a/src/ats/ats_api_performance.c +++ b/src/ats/ats_api_performance.c | |||
@@ -27,6 +27,10 @@ | |||
27 | #include "gnunet_ats_service.h" | 27 | #include "gnunet_ats_service.h" |
28 | #include "ats.h" | 28 | #include "ats.h" |
29 | 29 | ||
30 | |||
31 | #define LOG(kind,...) GNUNET_log_from(kind, "ats-performance-api", __VA_ARGS__) | ||
32 | |||
33 | |||
30 | /** | 34 | /** |
31 | * Message in linked list we should send to the ATS service. The | 35 | * Message in linked list we should send to the ATS service. The |
32 | * actual binary message follows this struct. | 36 | * actual binary message follows this struct. |
@@ -520,11 +524,10 @@ process_ar_message (struct GNUNET_ATS_PerformanceHandle *ph, | |||
520 | GNUNET_break(0); | 524 | GNUNET_break(0); |
521 | return GNUNET_SYSERR; | 525 | return GNUNET_SYSERR; |
522 | } | 526 | } |
523 | GNUNET_log (GNUNET_ERROR_TYPE_DEBUG, | 527 | LOG (GNUNET_ERROR_TYPE_DEBUG, |
524 | "Received %s message for peer %s and plugin %s\n", | 528 | "Received ATS_ADDRESSLIST_RESPONSE message for peer %s and plugin %s\n", |
525 | "ATS_ADDRESSLIST_RESPONSE", | 529 | GNUNET_i2s (&pi->peer), |
526 | GNUNET_i2s (&pi->peer), | 530 | plugin_name); |
527 | plugin_name); | ||
528 | 531 | ||
529 | next = ph->addresslist_head; | 532 | next = ph->addresslist_head; |
530 | while (NULL != (alh = next)) | 533 | while (NULL != (alh = next)) |
@@ -546,9 +549,8 @@ process_ar_message (struct GNUNET_ATS_PerformanceHandle *ph, | |||
546 | (0 == ats_count) ) | 549 | (0 == ats_count) ) |
547 | { | 550 | { |
548 | /* Done */ | 551 | /* Done */ |
549 | GNUNET_log (GNUNET_ERROR_TYPE_DEBUG, | 552 | LOG (GNUNET_ERROR_TYPE_DEBUG, |
550 | "Received last message for %s\n", | 553 | "Received last message for ATS_ADDRESSLIST_RESPONSE\n"); |
551 | "ATS_ADDRESSLIST_RESPONSE"); | ||
552 | bandwidth_zero.value__ = htonl (0); | 554 | bandwidth_zero.value__ = htonl (0); |
553 | GNUNET_CONTAINER_DLL_remove (ph->addresslist_head, | 555 | GNUNET_CONTAINER_DLL_remove (ph->addresslist_head, |
554 | ph->addresslist_tail, | 556 | ph->addresslist_tail, |
@@ -622,8 +624,8 @@ process_ats_message (void *cls, | |||
622 | return; | 624 | return; |
623 | 625 | ||
624 | reconnect: | 626 | reconnect: |
625 | GNUNET_log (GNUNET_ERROR_TYPE_DEBUG, | 627 | LOG (GNUNET_ERROR_TYPE_DEBUG, |
626 | "Reconnecting!\n"); | 628 | "Reconnecting!\n"); |
627 | if (NULL != ph->th) | 629 | if (NULL != ph->th) |
628 | { | 630 | { |
629 | GNUNET_CLIENT_notify_transmit_ready_cancel (ph->th); | 631 | GNUNET_CLIENT_notify_transmit_ready_cancel (ph->th); |