diff options
author | Christian Grothoff <christian@grothoff.org> | 2010-05-31 09:17:11 +0000 |
---|---|---|
committer | Christian Grothoff <christian@grothoff.org> | 2010-05-31 09:17:11 +0000 |
commit | b8fa03a10def5c08fea806d6316ec3d00b6e42bd (patch) | |
tree | a9b1969df8e5493a32bbd25b4202bedf555c75d7 /src/util/bandwidth.c | |
parent | 868d1b6b8294377fa8845648c49980e8671bb969 (diff) | |
download | gnunet-b8fa03a10def5c08fea806d6316ec3d00b6e42bd.tar.gz gnunet-b8fa03a10def5c08fea806d6316ec3d00b6e42bd.zip |
nicer
Diffstat (limited to 'src/util/bandwidth.c')
-rw-r--r-- | src/util/bandwidth.c | 47 |
1 files changed, 11 insertions, 36 deletions
diff --git a/src/util/bandwidth.c b/src/util/bandwidth.c index 71701a84c..e35cf3323 100644 --- a/src/util/bandwidth.c +++ b/src/util/bandwidth.c | |||
@@ -27,7 +27,7 @@ | |||
27 | #include "gnunet_bandwidth_lib.h" | 27 | #include "gnunet_bandwidth_lib.h" |
28 | #include "gnunet_server_lib.h" | 28 | #include "gnunet_server_lib.h" |
29 | 29 | ||
30 | #define DEBUG_BANDWIDTH GNUNET_NO | 30 | #define DEBUG_BANDWIDTH GNUNET_YES |
31 | 31 | ||
32 | /** | 32 | /** |
33 | * Create a new bandwidth value. | 33 | * Create a new bandwidth value. |
@@ -169,46 +169,22 @@ static void | |||
169 | update_tracker (struct GNUNET_BANDWIDTH_Tracker *av) | 169 | update_tracker (struct GNUNET_BANDWIDTH_Tracker *av) |
170 | { | 170 | { |
171 | struct GNUNET_TIME_Absolute now; | 171 | struct GNUNET_TIME_Absolute now; |
172 | uint64_t avail_per_ms; | ||
173 | uint64_t delta_time; | 172 | uint64_t delta_time; |
174 | uint64_t delta_avail; | 173 | uint64_t delta_avail; |
175 | uint64_t left_bytes; | 174 | uint64_t left_bytes; |
176 | uint64_t left_time_ms; | 175 | uint64_t max_carry; |
177 | 176 | ||
178 | now = GNUNET_TIME_absolute_get (); | 177 | now = GNUNET_TIME_absolute_get (); |
179 | delta_time = now.value - av->last_update__.value; | 178 | delta_time = now.value - av->last_update__.value; |
180 | delta_avail = (delta_time * ((unsigned long long) av->available_bytes_per_s__) + 500LL) / 1000LL; | 179 | delta_avail = (delta_time * ((unsigned long long) av->available_bytes_per_s__) + 500LL) / 1000LL; |
181 | if (av->consumption_since_last_update__ >= delta_avail) | 180 | av->consumption_since_last_update__ -= delta_avail; |
181 | av->last_update__ = now; | ||
182 | if (av->consumption_since_last_update__ < 0) | ||
182 | { | 183 | { |
183 | av->consumption_since_last_update__ -= delta_avail; | 184 | left_bytes = - av->consumption_since_last_update__; |
184 | av->last_update__ = now; | 185 | max_carry = av->available_bytes_per_s__ * av->max_carry_s__; |
185 | } | 186 | if (max_carry > left_bytes) |
186 | else | 187 | av->consumption_since_last_update__ = -max_carry; |
187 | { | ||
188 | left_bytes = delta_avail - av->consumption_since_last_update__; | ||
189 | avail_per_ms = ((unsigned long long) av->available_bytes_per_s__ + 500LL) / 1000LL; | ||
190 | if (avail_per_ms > 0) | ||
191 | { | ||
192 | left_time_ms = left_bytes / avail_per_ms; | ||
193 | if (left_time_ms > ((unsigned long long) av->max_carry_s__) * 1000LL) | ||
194 | { | ||
195 | /* need to limit accumulation of unused bandwidth */ | ||
196 | left_time_ms = ((unsigned long long) av->max_carry_s__) * 1000LL; | ||
197 | if (left_time_ms * avail_per_ms < GNUNET_SERVER_MAX_MESSAGE_SIZE) | ||
198 | { | ||
199 | /* need to still allow GNUNET_SERVER_MAX_MESSAGE_SIZE accumulation */ | ||
200 | if (left_bytes > GNUNET_SERVER_MAX_MESSAGE_SIZE) | ||
201 | left_bytes = GNUNET_SERVER_MAX_MESSAGE_SIZE; | ||
202 | left_time_ms = left_bytes / avail_per_ms; | ||
203 | } | ||
204 | } | ||
205 | } | ||
206 | else | ||
207 | { | ||
208 | left_time_ms = 0; | ||
209 | } | ||
210 | av->consumption_since_last_update__ = 0; | ||
211 | av->last_update__.value = now.value - left_time_ms; | ||
212 | } | 188 | } |
213 | #if DEBUG_BANDWIDTH | 189 | #if DEBUG_BANDWIDTH |
214 | GNUNET_log (GNUNET_ERROR_TYPE_DEBUG, | 190 | GNUNET_log (GNUNET_ERROR_TYPE_DEBUG, |
@@ -266,8 +242,7 @@ GNUNET_BANDWIDTH_tracker_consume (struct GNUNET_BANDWIDTH_Tracker *av, | |||
266 | } | 242 | } |
267 | else | 243 | else |
268 | { | 244 | { |
269 | av->last_update__.value -= ((-size) * av->available_bytes_per_s__ + 500LL) / 1000LL; | 245 | av->consumption_since_last_update__ += size; |
270 | update_tracker (av); | ||
271 | } | 246 | } |
272 | return GNUNET_NO; | 247 | return GNUNET_NO; |
273 | } | 248 | } |
@@ -340,7 +315,7 @@ GNUNET_BANDWIDTH_tracker_get_available (struct GNUNET_BANDWIDTH_Tracker *av) | |||
340 | { | 315 | { |
341 | struct GNUNET_BANDWIDTH_Value32NBO bps; | 316 | struct GNUNET_BANDWIDTH_Value32NBO bps; |
342 | uint64_t avail; | 317 | uint64_t avail; |
343 | uint64_t used; | 318 | int64_t used; |
344 | 319 | ||
345 | update_tracker (av); | 320 | update_tracker (av); |
346 | bps = GNUNET_BANDWIDTH_value_init (av->available_bytes_per_s__); | 321 | bps = GNUNET_BANDWIDTH_value_init (av->available_bytes_per_s__); |