From 2f73ea96e15ea1b0a8082aa373ec0092ef6c9e3b Mon Sep 17 00:00:00 2001 From: Quentin Dufour Date: Thu, 29 Aug 2019 18:25:37 +0200 Subject: [PATCH] Fix scheduler --- src/algo_thunder.c | 2 ++ 1 file changed, 2 insertions(+) diff --git a/src/algo_thunder.c b/src/algo_thunder.c index b856504..fc88556 100644 --- a/src/algo_thunder.c +++ b/src/algo_thunder.c @@ -118,6 +118,7 @@ int schedule(struct evt_core_ctx* ctx, struct evt_core_fdinfo* fdinfo, struct bu sprintf(url, "tcp:write:127.0.0.1:%d", 7500 + thunderc->selected_link); to_fdinfo = evt_core_get_from_url (ctx, url); } while (to_fdinfo == NULL); + printf("URL %s has been retained\n", url); // 2. We create the packet template union abstract_packet links = { @@ -140,6 +141,7 @@ int schedule(struct evt_core_ctx* ctx, struct evt_core_fdinfo* fdinfo, struct bu thunderc->delta_t_per_link[i] += mili_sec; li[i].delta_t = thunderc->delta_t_per_link[i] > UINT16_MAX ? UINT16_MAX : thunderc->delta_t_per_link[i]; } + thunderc->delta_t_per_link[thunderc->selected_link] = 0; li[thunderc->selected_link].delta_t = 0; if (ctx->verbose > 1) {