Added option to restart engine if system time jumps around too much.

git-svn-id: http://yate.null.ro/svn/yate/trunk@6291 acf43c95-373e-0410-b603-e72c3f656dc1
This commit is contained in:
paulc 2018-01-10 12:13:53 +00:00
parent 809f127c54
commit ecb4c6954b
2 changed files with 40 additions and 3 deletions

View File

@ -64,6 +64,12 @@
; restart every 10 seconds ; restart every 10 seconds
;restarts=0 ;restarts=0
; timejump: int: Forward system time jump in seconds accepted without restart
; If non-zero and system time jumps backwards or too much forward
; an alert will be logged and if supervised the engine will restart
; Valid range 8 to 120, 0 disables check (default)
;timejump=0
; warntime: int: Warn time limit for message dispatch in milliseconds, a value ; warntime: int: Warn time limit for message dispatch in milliseconds, a value
; of zero disables such warnings ; of zero disables such warnings
;warntime=0 ;warntime=0

View File

@ -158,6 +158,14 @@ using namespace TelEngine;
// Size of log relay buffer in bytes // Size of log relay buffer in bytes
#define MAX_LOGBUFF 4096 #define MAX_LOGBUFF 4096
// Minimum and maximum settable time jump
#ifndef MIN_TIME_JUMP
#define MIN_TIME_JUMP (MAX_SANITY + 3)
#endif
#ifndef MAX_TIME_JUMP
#define MAX_TIME_JUMP 120
#endif
#ifndef HOST_NAME_MAX #ifndef HOST_NAME_MAX
#define HOST_NAME_MAX 255 #define HOST_NAME_MAX 255
#endif #endif
@ -171,6 +179,7 @@ static u_int64_t s_restarts = 0;
static bool s_makeworker = true; static bool s_makeworker = true;
static bool s_keepclosing = false; static bool s_keepclosing = false;
static bool s_nounload = false; static bool s_nounload = false;
static long s_timejump = 0;
static int s_super_handle = -1; static int s_super_handle = -1;
static int s_run_attempt = 0; static int s_run_attempt = 0;
static int s_max_sanity = MAX_SANITY; static int s_max_sanity = MAX_SANITY;
@ -1493,6 +1502,10 @@ int Engine::engineInit()
s_maxqueued = s_cfg.getIntValue("general","maxqueued",s_maxqueued,0,10000); s_maxqueued = s_cfg.getIntValue("general","maxqueued",s_maxqueued,0,10000);
s_maxevents = s_cfg.getIntValue("general","maxevents",s_maxevents,0,1000); s_maxevents = s_cfg.getIntValue("general","maxevents",s_maxevents,0,1000);
s_restarts = s_cfg.getIntValue("general","restarts"); s_restarts = s_cfg.getIntValue("general","restarts");
s_timejump = s_cfg.getIntValue("general","timejump",0,0,MAX_TIME_JUMP);
if (s_timejump && (s_timejump < MIN_TIME_JUMP))
s_timejump = MIN_TIME_JUMP;
s_timejump *= 1000;
m_dispatcher.warnTime(1000*(u_int64_t)s_cfg.getIntValue("general","warntime")); m_dispatcher.warnTime(1000*(u_int64_t)s_cfg.getIntValue("general","warntime"));
extraPath(clientMode() ? "client" : "server"); extraPath(clientMode() ? "client" : "server");
extraPath(s_cfg.getValue("general","extrapath")); extraPath(s_cfg.getValue("general","extrapath"));
@ -1600,6 +1613,7 @@ int Engine::run()
{ {
// engine loop // engine loop
long corr = 0; long corr = 0;
uint64_t last = 0;
int stops = MAX_STOP; int stops = MAX_STOP;
while (s_haltcode == -1 || ((--stops >= 0) && dispatch("engine.stop",true))) { while (s_haltcode == -1 || ((--stops >= 0) && dispatch("engine.stop",true))) {
if (s_cmds) { if (s_cmds) {
@ -1633,6 +1647,10 @@ int Engine::run()
= s_cfg.getIntValue("general","maxqueued",s_maxqueued,0,10000)))); = s_cfg.getIntValue("general","maxqueued",s_maxqueued,0,10000))));
s_params.setParam("maxevents",String((s_maxevents s_params.setParam("maxevents",String((s_maxevents
= s_cfg.getIntValue("general","maxevents",s_maxevents,0,1000)))); = s_cfg.getIntValue("general","maxevents",s_maxevents,0,1000))));
s_timejump = s_cfg.getIntValue("general","timejump",s_timejump,0,MAX_TIME_JUMP);
if (s_timejump && (s_timejump < MIN_TIME_JUMP))
s_timejump = MIN_TIME_JUMP;
s_timejump *= 1000;
initPlugins(); initPlugins();
} }
@ -1686,15 +1704,28 @@ int Engine::run()
else else
s_makeworker = true; s_makeworker = true;
if (s_restarts && (Time::now() >= s_restarts)) { uint64_t now = Time::now();
if (last) {
long diff = (long)((int64_t)(now - last) / 1000);
if ((diff <= 0) || (s_timejump && (diff > s_timejump))) {
const char* rst = (s_timejump && (s_super_handle >= 0)) ? " Restarting!" : "";
Alarm("engine","system",DebugCrit,"System time advanced by %ld msec.%s",diff,rst);
if (s_timejump)
restart(0,false);
}
}
last = now;
if (s_restarts && (now >= s_restarts)) {
if (!(usedPlugins() || dispatch("engine.busy"))) { if (!(usedPlugins() || dispatch("engine.busy"))) {
s_haltcode = 128; s_restarts = 0;
restart(0,false);
break; break;
} }
DDebug(DebugAll,"Engine busy - will try to restart later"); DDebug(DebugAll,"Engine busy - will try to restart later");
// If we cannot restart now try again in 10s // If we cannot restart now try again in 10s
s_restarts = Time::now() + 10000000; s_restarts = now + 10000000;
} }
uint64_t disp = m_dispatcher.dispatchCount(); uint64_t disp = m_dispatcher.dispatchCount();
m_messageRate = (unsigned int)(disp - m_dispatchedLast); m_messageRate = (unsigned int)(disp - m_dispatchedLast);
m_dispatchedLast = disp; m_dispatchedLast = disp;