From 3d7fefedc9ba60bd8e8448efe8b628446d958536 Mon Sep 17 00:00:00 2001 From: Christian Grothoff Date: Sun, 11 Aug 2013 21:21:56 +0000 Subject: changing time measurement from milliseconds to microseconds --- src/fragmentation/defragmentation.c | 10 +++++----- src/fragmentation/fragmentation.c | 16 ++++++++-------- 2 files changed, 13 insertions(+), 13 deletions(-) (limited to 'src/fragmentation') diff --git a/src/fragmentation/defragmentation.c b/src/fragmentation/defragmentation.c index 2d3f4a57b..f42207046 100644 --- a/src/fragmentation/defragmentation.c +++ b/src/fragmentation/defragmentation.c @@ -354,13 +354,13 @@ estimate_latency (struct MessageContext *mc) for (i = 0; i < total; i++) { x[i] = (double) i; - y[i] = (double) (first[i].time.abs_value - first[0].time.abs_value); + y[i] = (double) (first[i].time.abs_value_us - first[0].time.abs_value_us); } gsl_fit_mul (x, 1, y, 1, total, &c1, &cov11, &sumsq); c1 += sqrt (sumsq); /* add 1 std dev */ - ret.rel_value = (uint64_t) c1; - if (ret.rel_value == 0) - ret = GNUNET_TIME_UNIT_MILLISECONDS; /* always at least 1 */ + ret.rel_value_us = (uint64_t) c1; + if (0 == ret.rel_value_us) + ret = GNUNET_TIME_UNIT_MICROSECONDS; /* always at least 1 */ return ret; } @@ -381,7 +381,7 @@ discard_oldest_mc (struct GNUNET_DEFRAGMENT_Context *dc) while (NULL != pos) { if ((old == NULL) || - (old->last_update.abs_value > pos->last_update.abs_value)) + (old->last_update.abs_value_us > pos->last_update.abs_value_us)) old = pos; pos = pos->next; } diff --git a/src/fragmentation/fragmentation.c b/src/fragmentation/fragmentation.c index f859b32c7..39a5af814 100644 --- a/src/fragmentation/fragmentation.c +++ b/src/fragmentation/fragmentation.c @@ -1,6 +1,6 @@ /* This file is part of GNUnet - (C) 2009, 2011 Christian Grothoff (and other contributing authors) + (C) 2009-2013 Christian Grothoff (and other contributing authors) GNUnet is free software; you can redistribute it and/or modify it under the terms of the GNU General Public License as published @@ -180,7 +180,7 @@ transmit_next (void *cls, const struct GNUNET_SCHEDULER_TaskContext *tc) delay = GNUNET_BANDWIDTH_tracker_get_delay (fc->tracker, fsize); else delay = GNUNET_TIME_UNIT_ZERO; - if (delay.rel_value > 0) + if (delay.rel_value_us > 0) { fc->task = GNUNET_SCHEDULER_add_delayed (delay, &transmit_next, fc); return; @@ -207,7 +207,7 @@ transmit_next (void *cls, const struct GNUNET_SCHEDULER_TaskContext *tc) GNUNET_BANDWIDTH_tracker_consume (fc->tracker, fsize); GNUNET_STATISTICS_update (fc->stats, _("# fragments transmitted"), 1, GNUNET_NO); - if (0 != fc->last_round.abs_value) + if (0 != fc->last_round.abs_value_us) GNUNET_STATISTICS_update (fc->stats, _("# fragments retransmitted"), 1, GNUNET_NO); @@ -367,8 +367,8 @@ GNUNET_FRAGMENT_process_ack (struct GNUNET_FRAGMENT_Context *fc, /* normal ACK, can update running average of delay... */ fc->wack = GNUNET_NO; ndelay = GNUNET_TIME_absolute_get_duration (fc->last_round); - fc->ack_delay.rel_value = - (ndelay.rel_value / fc->num_transmissions + 3 * fc->ack_delay.rel_value) / 4; + fc->ack_delay.rel_value_us = + (ndelay.rel_value_us / fc->num_transmissions + 3 * fc->ack_delay.rel_value_us) / 4; fc->num_transmissions = 0; /* calculate ratio msg sent vs. msg acked */ ack_cnt = 0; @@ -392,11 +392,11 @@ GNUNET_FRAGMENT_process_ack (struct GNUNET_FRAGMENT_Context *fc, { /* some loss, slow down proportionally */ fprintf (stderr, "Prop loss\n"); - fc->msg_delay.rel_value = ((fc->msg_delay.rel_value * ack_cnt) / snd_cnt); + fc->msg_delay.rel_value_us = ((fc->msg_delay.rel_value_us * ack_cnt) / snd_cnt); } - else if (1 < fc->msg_delay.rel_value) + else if (100 < fc->msg_delay.rel_value_us) { - fc->msg_delay.rel_value--; /* try a bit faster */ + fc->msg_delay.rel_value_us -= 100; /* try a bit faster */ } fc->msg_delay = GNUNET_TIME_relative_min (fc->msg_delay, GNUNET_TIME_UNIT_SECONDS); -- cgit v1.2.3