Update algo thunder
This commit is contained in:
parent
b2fb6296a1
commit
a972e5474e
1 changed files with 2 additions and 1 deletions
|
@ -6,6 +6,7 @@
|
||||||
#include "timer.h"
|
#include "timer.h"
|
||||||
#include "proxy.h"
|
#include "proxy.h"
|
||||||
|
|
||||||
|
#define PROBE_EVERY 5
|
||||||
uint64_t compute_delta(struct timespec* prev_time, uint64_t max, uint8_t update) {
|
uint64_t compute_delta(struct timespec* prev_time, uint64_t max, uint8_t update) {
|
||||||
struct timespec curr;
|
struct timespec curr;
|
||||||
int secs, nsecs;
|
int secs, nsecs;
|
||||||
|
@ -111,7 +112,7 @@ int schedule(struct evt_core_ctx* ctx, struct evt_core_fdinfo* fdinfo, struct bu
|
||||||
}
|
}
|
||||||
|
|
||||||
// We let some time for blacklisted links to recover
|
// We let some time for blacklisted links to recover
|
||||||
if (is_blacklisted (thunderc, thunderc->selected_link) && thunderc->to_increment[thunderc->selected_link] < 10) continue;
|
if (is_blacklisted (thunderc, thunderc->selected_link) && thunderc->to_increment[thunderc->selected_link] < PROBE_EVERY) continue;
|
||||||
|
|
||||||
//printf("URL %s has been retained\n", url);
|
//printf("URL %s has been retained\n", url);
|
||||||
|
|
||||||
|
|
Loading…
Reference in a new issue