diff options
author | Christian Grothoff <christian@grothoff.org> | 2015-01-25 21:14:37 +0000 |
---|---|---|
committer | Christian Grothoff <christian@grothoff.org> | 2015-01-25 21:14:37 +0000 |
commit | 896e28ee7d8aee5fb15c905eef18a6f73e844d7f (patch) | |
tree | 95e48ba3293a1f0c1b8ebc4eede2fd3415d5622d /src | |
parent | e42d7009eba71665bd5fb6b0c1decd9a0cddcb0e (diff) | |
download | gnunet-896e28ee7d8aee5fb15c905eef18a6f73e844d7f.tar.gz gnunet-896e28ee7d8aee5fb15c905eef18a6f73e844d7f.zip |
-address dying doesn't depend on bandwidth suggestion of ATS, just on in_destroy flag
Diffstat (limited to 'src')
-rw-r--r-- | src/ats/ats_api_scheduling.c | 6 | ||||
-rw-r--r-- | src/ats/plugin_ats_proportional.c | 14 |
2 files changed, 10 insertions, 10 deletions
diff --git a/src/ats/ats_api_scheduling.c b/src/ats/ats_api_scheduling.c index b1ceb4083..8d2cdc84e 100644 --- a/src/ats/ats_api_scheduling.c +++ b/src/ats/ats_api_scheduling.c | |||
@@ -479,9 +479,7 @@ process_ats_address_suggestion_message (void *cls, | |||
479 | } | 479 | } |
480 | if (NULL == sh->suggest_cb) | 480 | if (NULL == sh->suggest_cb) |
481 | return; | 481 | return; |
482 | if ( (GNUNET_YES == ar->in_destroy) && | 482 | if (GNUNET_YES == ar->in_destroy) |
483 | ( (0 != ntohl (m->bandwidth_out.value__)) || | ||
484 | (0 != ntohl (m->bandwidth_in.value__)) ) ) | ||
485 | { | 483 | { |
486 | /* ignore suggestion, as this address is dying */ | 484 | /* ignore suggestion, as this address is dying */ |
487 | return; | 485 | return; |
@@ -490,7 +488,7 @@ process_ats_address_suggestion_message (void *cls, | |||
490 | (GNUNET_HELLO_address_check_option (ar->address, | 488 | (GNUNET_HELLO_address_check_option (ar->address, |
491 | GNUNET_HELLO_ADDRESS_INFO_INBOUND)) ) | 489 | GNUNET_HELLO_ADDRESS_INFO_INBOUND)) ) |
492 | { | 490 | { |
493 | GNUNET_break (0); | 491 | GNUNET_assert (0); |
494 | return; | 492 | return; |
495 | } | 493 | } |
496 | sh->suggest_cb (sh->suggest_cb_cls, | 494 | sh->suggest_cb (sh->suggest_cb_cls, |
diff --git a/src/ats/plugin_ats_proportional.c b/src/ats/plugin_ats_proportional.c index 99cbb1b55..874741a2b 100644 --- a/src/ats/plugin_ats_proportional.c +++ b/src/ats/plugin_ats_proportional.c | |||
@@ -587,17 +587,19 @@ distribute_bandwidth (struct GAS_PROPORTIONAL_Handle *s, | |||
587 | if (count_addresses != net->active_addresses) | 587 | if (count_addresses != net->active_addresses) |
588 | { | 588 | { |
589 | GNUNET_break (0); | 589 | GNUNET_break (0); |
590 | LOG(GNUNET_ERROR_TYPE_WARNING, | 590 | LOG (GNUNET_ERROR_TYPE_WARNING, |
591 | "%s: Counted %u active addresses, but network says to have %u active addresses \n", | 591 | "%s: Counted %u active addresses, but network says to have %u active addresses\n", |
592 | net->desc, count_addresses, net->active_addresses); | 592 | net->desc, count_addresses, net->active_addresses); |
593 | for (cur_address = net->head; NULL != cur_address; cur_address = cur_address->next) | 593 | for (cur_address = net->head; NULL != cur_address; cur_address = cur_address->next) |
594 | { | 594 | { |
595 | if (GNUNET_YES != cur_address->addr->active) | 595 | if (GNUNET_YES != cur_address->addr->active) |
596 | continue; | 596 | continue; |
597 | 597 | ||
598 | LOG (GNUNET_ERROR_TYPE_WARNING, "Active: `%s' `%s' length %u\n", | 598 | LOG (GNUNET_ERROR_TYPE_WARNING, |
599 | GNUNET_i2s (&cur_address->addr->peer), cur_address->addr->plugin, | 599 | "Active: `%s' `%s' length %u\n", |
600 | cur_address->addr->addr_len); | 600 | GNUNET_i2s (&cur_address->addr->peer), |
601 | cur_address->addr->plugin, | ||
602 | cur_address->addr->addr_len); | ||
601 | } | 603 | } |
602 | } | 604 | } |
603 | 605 | ||