switch_time.c File Reference

Data Structures
struct	timer_private
struct	timer_matrix
Defines
#define	UINT32_MAX   0xffffffff
#define	MAX_TICK   UINT32_MAX - 1024
#define	MS_PER_TICK   10
#define	MAX_ELEMENTS   3600
#define	IDLE_SPEED   100
#define	STEP_MS   1
#define	STEP_MIC   1000
#define	check_roll()
Typedefs
typedef timer_private	timer_private_t
typedef timer_matrix	timer_matrix_t
Functions
	SWITCH_MODULE_LOAD_FUNCTION (softtimer_load)
	SWITCH_MODULE_SHUTDOWN_FUNCTION (softtimer_shutdown)
	SWITCH_MODULE_RUNTIME_FUNCTION (softtimer_runtime)
	SWITCH_MODULE_DEFINITION (CORE_SOFTTIMER_MODULE, softtimer_load, softtimer_shutdown, softtimer_runtime)
switch_time_t	switch_timestamp_now (void)
time_t	switch_timestamp (time_t *t)
void	switch_time_set_monotonic (switch_bool_t enable)
void	switch_time_sync (void)
void	switch_sleep (switch_interval_time_t t)

---

Define Documentation

#define check_roll (   )

Value: if (private_info->roll < TIMER_MATRIX[timer->interval].roll) { \ private_info->roll++; \ private_info->reference = private_info->start = TIMER_MATRIX[timer->interval].tick; \ } \

#define IDLE_SPEED   100

#define MAX_ELEMENTS   3600

#define MAX_TICK   UINT32_MAX - 1024

#define MS_PER_TICK   10

#define STEP_MIC   1000

#define STEP_MS   1

#define UINT32_MAX   0xffffffff

---

Typedef Documentation

typedef struct timer_matrix timer_matrix_t

typedef struct timer_private timer_private_t

---

Function Documentation

SWITCH_MODULE_DEFINITION (  CORE_SOFTTIMER_MODULE  , softtimer_load  , softtimer_shutdown  , softtimer_runtime  )

SWITCH_MODULE_LOAD_FUNCTION (  softtimer_load   )

{ switch_timer_interface_t *timer_interface; module_pool = pool; /* connect my internal structure to the blank pointer passed to me */ *module_interface = switch_loadable_module_create_module_interface(pool, modname); timer_interface = switch_loadable_module_create_interface(*module_interface, SWITCH_TIMER_INTERFACE); timer_interface->interface_name = "soft"; timer_interface->timer_init = timer_init; timer_interface->timer_next = timer_next; timer_interface->timer_step = timer_step; timer_interface->timer_sync = timer_sync; timer_interface->timer_check = timer_check; timer_interface->timer_destroy = timer_destroy; /* indicate that the module should continue to be loaded */ return SWITCH_STATUS_SUCCESS; }

Here is the call graph for this function:

SWITCH_MODULE_RUNTIME_FUNCTION (  softtimer_runtime   )

{ switch_time_t too_late = STEP_MIC * 1000; uint32_t current_ms = 0; uint32_t x, tick = 0; switch_time_t ts = 0, last = 0; int fwd_errs = 0, rev_errs = 0; switch_time_sync(); memset(&globals, 0, sizeof(globals)); switch_mutex_init(&globals.mutex, SWITCH_MUTEX_NESTED, module_pool); globals.STARTED = globals.RUNNING = 1; switch_mutex_lock(runtime.throttle_mutex); runtime.sps = runtime.sps_total; switch_mutex_unlock(runtime.throttle_mutex); if (MONO) { int loops; for(loops = 0; loops < 3; loops++) { ts = time_now(0); /* if it returns the same value every time it won't be of much use.*/ if (ts == last) { switch_log_printf(SWITCH_CHANNEL_LOG, SWITCH_LOG_CRIT, "Broken MONOTONIC Clock Detected!, Support Disabled.\n"); MONO = 0; runtime.reference = switch_time_now(); runtime.initiated = runtime.reference; break; } switch_yield(STEP_MIC); last = ts; } } ts = 0; last = 0; fwd_errs = rev_errs = 0; while (globals.RUNNING == 1) { runtime.reference += STEP_MIC; while ((ts = time_now(runtime.offset)) < runtime.reference) { if (ts < last) { if (MONO) { switch_log_printf(SWITCH_CHANNEL_LOG, SWITCH_LOG_CRIT, "Virtual Migration Detected! Syncing Clock\n"); switch_time_sync(); } else { int64_t diff = (int64_t)(ts - last); switch_log_printf(SWITCH_CHANNEL_LOG, SWITCH_LOG_CRIT, "Reverse Clock Skew Detected!\n"); runtime.reference = switch_time_now(); current_ms = 0; tick = 0; runtime.initiated += diff; rev_errs++; } } else { rev_errs = 0; } switch_yield(STEP_MIC); last = ts; } if (ts > (runtime.reference + too_late)) { if (MONO) { switch_log_printf(SWITCH_CHANNEL_LOG, SWITCH_LOG_CRIT, "Virtual Migration Detected! Syncing Clock\n"); switch_time_sync(); } else { switch_time_t diff = ts - runtime.reference - STEP_MIC; switch_log_printf(SWITCH_CHANNEL_LOG, SWITCH_LOG_CRIT, "Forward Clock Skew Detected!\n"); fwd_errs++; runtime.reference = switch_time_now(); current_ms = 0; tick = 0; runtime.initiated += diff; } } else { fwd_errs = 0; } if (fwd_errs > 9 || rev_errs > 9) { switch_log_printf(SWITCH_CHANNEL_LOG, SWITCH_LOG_CRIT, "Auto Re-Syncing clock.\n"); switch_time_sync(); fwd_errs = rev_errs = 0; } runtime.timestamp = ts; current_ms += STEP_MS; tick += STEP_MS; if (tick >= 1000) { if (runtime.sps <= 0) { switch_log_printf(SWITCH_CHANNEL_LOG, SWITCH_LOG_CRIT, "Over Session Rate of %d!\n", runtime.sps_total); } switch_mutex_lock(runtime.throttle_mutex); runtime.sps_last = runtime.sps_total - runtime.sps; runtime.sps = runtime.sps_total; switch_mutex_unlock(runtime.throttle_mutex); tick = 0; } if ((current_ms % MS_PER_TICK) == 0) { for (x = MS_PER_TICK; x <= MAX_ELEMENTS; x += MS_PER_TICK) { if ((current_ms % x) == 0) { if (TIMER_MATRIX[x].count) { TIMER_MATRIX[x].tick++; if (TIMER_MATRIX[x].tick == MAX_TICK) { TIMER_MATRIX[x].tick = 0; TIMER_MATRIX[x].roll++; } } } } } if (current_ms == MAX_ELEMENTS) { current_ms = 0; } } switch_mutex_lock(globals.mutex); globals.RUNNING = 0; switch_mutex_unlock(globals.mutex); return SWITCH_STATUS_TERM; }

Here is the call graph for this function:

SWITCH_MODULE_SHUTDOWN_FUNCTION (  softtimer_shutdown   )

{ if (globals.RUNNING) { switch_mutex_lock(globals.mutex); globals.RUNNING = -1; switch_mutex_unlock(globals.mutex); while (globals.RUNNING) { switch_yield(10000); } } #if defined(WIN32) timeEndPeriod(1); #endif return SWITCH_STATUS_SUCCESS; }

Here is the call graph for this function:

---

Variable Documentation

switch_mutex_t* mutex

int32_t RUNNING

int32_t STARTED

---