This is merely a historical archive of years 2008-2021, before the migration to mailman3.
A maintained and still updated list archive can be found at https://lists.osmocom.org/hyperkitty/list/gerrit-log@lists.osmocom.org/.
Stefan Sperling gerrit-no-reply at lists.osmocom.orgStefan Sperling has uploaded this change for review. ( https://gerrit.osmocom.org/10489
Change subject: fix time delta calculations in sched_clck.c
......................................................................
fix time delta calculations in sched_clck.c
Use osmo_clock_gettime() to read the monotonic clock instead
of gettimeofday() which could drift backwards.
This requires switching the scheduler clock from struct timeval
to struct timespec. Expand some variables to 64 bits in order
to keep types used in calculations compatible.
The previous implementation unconditionally subtracted microsecond
values from different time measurements, causing overflow if the
current measurement was taken in less of a fraction of a second
than the past measurement. Use timespecsub() for the subtraction
instead which accounts for fractions of a second correctly.
Change-Id: Ic93f90685c6d6dc28dfc4ad48c998e0eac113cf8
Related: OS#3467
---
M src/host/trxcon/sched_clck.c
M src/host/trxcon/scheduler.h
2 files changed, 33 insertions(+), 35 deletions(-)
git pull ssh://gerrit.osmocom.org:29418/osmocom-bb refs/changes/89/10489/1
diff --git a/src/host/trxcon/sched_clck.c b/src/host/trxcon/sched_clck.c
index 59cffb2..0707232 100644
--- a/src/host/trxcon/sched_clck.c
+++ b/src/host/trxcon/sched_clck.c
@@ -27,12 +27,15 @@
#include <errno.h>
#include <stdlib.h>
#include <stdint.h>
+#include <inttypes.h>
#include <string.h>
#include <osmocom/core/talloc.h>
#include <osmocom/core/msgb.h>
#include <osmocom/core/bits.h>
#include <osmocom/core/fsm.h>
+#include <osmocom/core/timer.h>
+#include <osmocom/core/timer_compat.h>
#include <osmocom/gsm/a5.h>
#include "scheduler.h"
@@ -47,8 +50,9 @@
static void sched_clck_tick(void *data)
{
struct trx_sched *sched = (struct trx_sched *) data;
- struct timeval tv_now, *tv_clock;
- int32_t elapsed;
+ struct timespec tv_now, *tv_clock, elapsed;
+ int64_t elapsed_us;
+ const struct timespec frame_duration = { .tv_sec = 0, .tv_nsec = FRAME_DURATION_uS * 1000 };
/* Check if transceiver is still alive */
if (sched->fn_counter_lost++ == TRX_LOSS_FRAMES) {
@@ -59,16 +63,16 @@
}
/* Get actual / previous frame time */
- gettimeofday(&tv_now, NULL);
+ osmo_clock_gettime(CLOCK_MONOTONIC, &tv_now);
tv_clock = &sched->clock;
- elapsed = (tv_now.tv_sec - tv_clock->tv_sec) * 1000000
- + (tv_now.tv_usec - tv_clock->tv_usec);
+ timespecsub(&tv_now, tv_clock, &elapsed);
+ elapsed_us = (elapsed.tv_sec * 1000000) + (elapsed.tv_nsec / 1000);
/* If someone played with clock, or if the process stalled */
- if (elapsed > FRAME_DURATION_uS * MAX_FN_SKEW || elapsed < 0) {
+ if (elapsed_us > FRAME_DURATION_uS * MAX_FN_SKEW || elapsed_us < 0) {
LOGP(DSCH, LOGL_NOTICE, "PC clock skew: "
- "elapsed uS %d\n", elapsed);
+ "elapsed uS %" PRIu64 "\n", elapsed_us);
sched->state = SCH_CLCK_STATE_WAIT;
@@ -76,14 +80,11 @@
}
/* Schedule next FN clock */
- while (elapsed > FRAME_DURATION_uS / 2) {
- tv_clock->tv_usec += FRAME_DURATION_uS;
- elapsed -= FRAME_DURATION_uS;
-
- if (tv_clock->tv_usec >= 1000000) {
- tv_clock->tv_sec++;
- tv_clock->tv_usec -= 1000000;
- }
+ while (elapsed_us > FRAME_DURATION_uS / 2) {
+ struct timespec next;
+ timespecadd(tv_clock, &frame_duration, &next);
+ *tv_clock = next;
+ elapsed_us -= FRAME_DURATION_uS;
sched->fn_counter_proc = (sched->fn_counter_proc + 1)
% GSM_HYPERFRAME;
@@ -94,11 +95,11 @@
}
osmo_timer_schedule(&sched->clock_timer, 0,
- FRAME_DURATION_uS - elapsed);
+ FRAME_DURATION_uS - elapsed_us);
}
static void sched_clck_correct(struct trx_sched *sched,
- struct timeval *tv_now, uint32_t fn)
+ struct timespec *tv_now, uint32_t fn)
{
sched->fn_counter_proc = fn;
@@ -107,7 +108,7 @@
sched->clock_cb(sched);
/* Schedule first FN clock */
- memcpy(&sched->clock, tv_now, sizeof(struct timeval));
+ sched->clock = *tv_now;
memset(&sched->clock_timer, 0, sizeof(sched->clock_timer));
sched->clock_timer.cb = sched_clck_tick;
@@ -117,14 +118,14 @@
int sched_clck_handle(struct trx_sched *sched, uint32_t fn)
{
- struct timeval tv_now, *tv_clock;
- int32_t elapsed, elapsed_fn;
+ struct timespec tv_now, *tv_clock, elapsed;
+ int64_t elapsed_us, elapsed_fn;
/* Reset lost counter */
sched->fn_counter_lost = 0;
/* Get actual / previous frame time */
- gettimeofday(&tv_now, NULL);
+ osmo_clock_gettime(CLOCK_MONOTONIC, &tv_now);
tv_clock = &sched->clock;
/* If this is the first CLCK IND */
@@ -142,8 +143,8 @@
osmo_timer_del(&sched->clock_timer);
/* Calculate elapsed time / frames since last processed fn */
- elapsed = (tv_now.tv_sec - tv_clock->tv_sec) * 1000000
- + (tv_now.tv_usec - tv_clock->tv_usec);
+ timespecsub(&tv_now, tv_clock, &elapsed);
+ elapsed_us = (elapsed.tv_sec * 1000000) + (elapsed.tv_nsec / 1000);
elapsed_fn = (fn + GSM_HYPERFRAME - sched->fn_counter_proc)
% GSM_HYPERFRAME;
@@ -159,8 +160,8 @@
return 0;
}
- LOGP(DSCH, LOGL_INFO, "GSM clock jitter: %d\n",
- elapsed_fn * FRAME_DURATION_uS - elapsed);
+ LOGP(DSCH, LOGL_INFO, "GSM clock jitter: %" PRIu64 "\n",
+ elapsed_fn * FRAME_DURATION_uS - elapsed_us);
/* Too many frames have been processed already */
if (elapsed_fn < 0) {
@@ -168,14 +169,11 @@
* Set clock to the time or last FN should
* have been transmitted
*/
- tv_clock->tv_sec = tv_now.tv_sec;
- tv_clock->tv_usec = tv_now.tv_usec +
- (0 - elapsed_fn) * FRAME_DURATION_uS;
-
- if (tv_clock->tv_usec >= 1000000) {
- tv_clock->tv_sec++;
- tv_clock->tv_usec -= 1000000;
- }
+ struct timespec duration, next;
+ duration.tv_sec = 0;
+ duration.tv_nsec = (0 - elapsed_fn) * FRAME_DURATION_uS * 1000;
+ timespecadd(&tv_now, &duration, &next);
+ *tv_clock = next;
/* Set time to the time our next FN has to be transmitted */
osmo_timer_schedule(&sched->clock_timer, 0,
@@ -195,7 +193,7 @@
}
/* Schedule next FN to be transmitted */
- memcpy(tv_clock, &tv_now, sizeof(struct timeval));
+ *tv_clock = tv_now;
osmo_timer_schedule(&sched->clock_timer, 0, FRAME_DURATION_uS);
return 0;
diff --git a/src/host/trxcon/scheduler.h b/src/host/trxcon/scheduler.h
index f36c3b2..6c3a2f2 100644
--- a/src/host/trxcon/scheduler.h
+++ b/src/host/trxcon/scheduler.h
@@ -21,7 +21,7 @@
/*! \brief Clock state */
uint8_t state;
/*! \brief Local clock source */
- struct timeval clock;
+ struct timespec clock;
/*! \brief Count of processed frames */
uint32_t fn_counter_proc;
/*! \brief Local frame counter advance */
--
To view, visit https://gerrit.osmocom.org/10489
To unsubscribe, or for help writing mail filters, visit https://gerrit.osmocom.org/settings
Gerrit-Project: osmocom-bb
Gerrit-Branch: master
Gerrit-MessageType: newchange
Gerrit-Change-Id: Ic93f90685c6d6dc28dfc4ad48c998e0eac113cf8
Gerrit-Change-Number: 10489
Gerrit-PatchSet: 1
Gerrit-Owner: Stefan Sperling <ssperling at sysmocom.de>
-------------- next part --------------
An HTML attachment was scrubbed...
URL: <http://lists.osmocom.org/pipermail/gerrit-log/attachments/20180817/32a91f51/attachment.htm>