quentin/tor_multipath_voip
1
0
Fork 0
Code Issues Pull requests Projects Releases Wiki Activity

Deactivate scheduler is now possible

Browse source
This commit is contained in:
Quentin 2019-09-19 10:08:32 +02:00
parent 634edf04b5
commit cb9b9f7bc6
1 changed files with 5 additions and 2 deletions
Show stats Download patch file Download diff file Expand all files Collapse all files

5
src/algo_thunder.c
View file

@ -27,7 +27,10 @@ uint64_t compute_delta(struct timespec* prev_time, uint64_t max, uint8_t update)
} }
int is_blacklisted(struct thunder_ctx* thunderc, int link_id) { int is_blacklisted(struct thunder_ctx* thunderc, int link_id) {
if (thunderc->scheduler_activated)
return thunderc->blacklisted[link_id] >= thunderc->received_pkts_on_link[link_id]; return thunderc->blacklisted[link_id] >= thunderc->received_pkts_on_link[link_id];
return 0;
} }
void prepare(struct evt_core_ctx* ctx, struct evt_core_fdinfo* fdinfo, struct buffer_packet* bp) { void prepare(struct evt_core_ctx* ctx, struct evt_core_fdinfo* fdinfo, struct buffer_packet* bp) {
@ -475,7 +478,7 @@ void algo_thunder_init(struct evt_core_ctx* ctx, struct algo_ctx* app_ctx, struc
if (ap->algo_specific_params != NULL) { if (ap->algo_specific_params != NULL) {
char *parse_ptr, *token, *params; char *parse_ptr, *token, *params;
for (params = ap->algo_specific_params ; ; params = NULL) { for (params = ap->algo_specific_params; ; params = NULL) {
token = strtok_r(params, ",", &parse_ptr); token = strtok_r(params, ",", &parse_ptr);
if (token == NULL) break; if (token == NULL) break;
sscanf(token, "jitter=%ld", &thunderc->allowed_jitter_ms); sscanf(token, "jitter=%ld", &thunderc->allowed_jitter_ms);