diff options
author | Matthias Wachs <wachs@net.in.tum.de> | 2014-07-17 11:18:49 +0000 |
---|---|---|
committer | Matthias Wachs <wachs@net.in.tum.de> | 2014-07-17 11:18:49 +0000 |
commit | badde1cd7041289866d2118a7ab1ec4360cc061c (patch) | |
tree | 96837d473b782bf935a111045648a9863d1a2257 /src/ats/gnunet-service-ats_addresses.c | |
parent | 615d5aef87f985e4c489fac6c6d6232d35f8b0c2 (diff) | |
download | gnunet-badde1cd7041289866d2118a7ab1ec4360cc061c.tar.gz gnunet-badde1cd7041289866d2118a7ab1ec4360cc061c.zip |
bandwidth stability for ATS
Diffstat (limited to 'src/ats/gnunet-service-ats_addresses.c')
-rw-r--r-- | src/ats/gnunet-service-ats_addresses.c | 11 |
1 files changed, 7 insertions, 4 deletions
diff --git a/src/ats/gnunet-service-ats_addresses.c b/src/ats/gnunet-service-ats_addresses.c index 357358c7c..70224e67a 100644 --- a/src/ats/gnunet-service-ats_addresses.c +++ b/src/ats/gnunet-service-ats_addresses.c | |||
@@ -1850,7 +1850,6 @@ load_quotas (const struct GNUNET_CONFIGURATION_Handle *cfg, | |||
1850 | return GNUNET_ATS_NetworkTypeCount; | 1850 | return GNUNET_ATS_NetworkTypeCount; |
1851 | } | 1851 | } |
1852 | 1852 | ||
1853 | |||
1854 | /** | 1853 | /** |
1855 | * Callback for solver to notify about assignment changes | 1854 | * Callback for solver to notify about assignment changes |
1856 | * | 1855 | * |
@@ -1862,6 +1861,8 @@ bandwidth_changed_cb (void *cls, struct ATS_Address *address) | |||
1862 | { | 1861 | { |
1863 | struct GAS_Addresses_Handle *handle = cls; | 1862 | struct GAS_Addresses_Handle *handle = cls; |
1864 | struct GAS_Addresses_Suggestion_Requests *cur; | 1863 | struct GAS_Addresses_Suggestion_Requests *cur; |
1864 | uint32_t diff_out; | ||
1865 | uint32_t diff_in; | ||
1865 | 1866 | ||
1866 | GNUNET_assert(handle != NULL); | 1867 | GNUNET_assert(handle != NULL); |
1867 | GNUNET_assert(address != NULL); | 1868 | GNUNET_assert(address != NULL); |
@@ -1905,13 +1906,15 @@ bandwidth_changed_cb (void *cls, struct ATS_Address *address) | |||
1905 | GNUNET_BANDWIDTH_value_init (0)); | 1906 | GNUNET_BANDWIDTH_value_init (0)); |
1906 | 1907 | ||
1907 | return; | 1908 | return; |
1908 | |||
1909 | } | 1909 | } |
1910 | 1910 | ||
1911 | /* Do bandwidth stability check */ | 1911 | /* Do bandwidth stability check */ |
1912 | int diff = abs (address->assigned_bw_out - address->last_notified_bw_out); | 1912 | diff_out = abs (address->assigned_bw_out - address->last_notified_bw_out); |
1913 | 1913 | diff_in = abs (address->assigned_bw_in - address->last_notified_bw_in); | |
1914 | 1914 | ||
1915 | if ( (diff_out < htonl(GNUNET_CONSTANTS_DEFAULT_BW_IN_OUT.value__)) && | ||
1916 | (diff_in < htonl(GNUNET_CONSTANTS_DEFAULT_BW_IN_OUT.value__)) ) | ||
1917 | return; | ||
1915 | 1918 | ||
1916 | GNUNET_log(GNUNET_ERROR_TYPE_INFO, | 1919 | GNUNET_log(GNUNET_ERROR_TYPE_INFO, |
1917 | "Sending bandwidth update for peer `%s': %u %u\n", | 1920 | "Sending bandwidth update for peer `%s': %u %u\n", |