aboutsummaryrefslogtreecommitdiff
path: root/src
diff options
context:
space:
mode:
authorChristian Grothoff <christian@grothoff.org>2015-01-25 21:14:37 +0000
committerChristian Grothoff <christian@grothoff.org>2015-01-25 21:14:37 +0000
commit896e28ee7d8aee5fb15c905eef18a6f73e844d7f (patch)
tree95e48ba3293a1f0c1b8ebc4eede2fd3415d5622d /src
parente42d7009eba71665bd5fb6b0c1decd9a0cddcb0e (diff)
downloadgnunet-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.c6
-rw-r--r--src/ats/plugin_ats_proportional.c14
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