version 1.2.2.2, 2012/04/15 21:44:33
|
version 1.2.2.5, 2012/04/24 08:06:09
|
Line 9 io_enableDEBUG;
|
Line 9 io_enableDEBUG;
|
|
|
cfg_root_t cfg; |
cfg_root_t cfg; |
sessions_t Sessions; |
sessions_t Sessions; |
|
pubs_t Pubs; |
sched_root_task_t *root; |
sched_root_task_t *root; |
sqlite3 *acc, *pub; |
sqlite3 *acc, *pub; |
pthread_mutex_t mtx_sess, mtx_pub; |
pthread_mutex_t mtx_sess, mtx_pub; |
Line 43 sigHand(int sig)
|
Line 44 sigHand(int sig)
|
break; |
break; |
} |
} |
|
|
syslog(LOG_ERR, "Error:: can't reload #%d - %s", cfg_GetErrno(), cfg_GetError()); | ioLIBERR(cfg); |
case SIGTERM: |
case SIGTERM: |
ioDEBUG(1, "Terminate MQTT service in progress"); |
ioDEBUG(1, "Terminate MQTT service in progress"); |
Kill++; |
Kill++; |
Line 68 main(int argc, char **argv)
|
Line 69 main(int argc, char **argv)
|
ait_val_t v; |
ait_val_t v; |
|
|
TAILQ_INIT(&Sessions); |
TAILQ_INIT(&Sessions); |
|
TAILQ_INIT(&Pubs); |
|
|
strlcpy(szCfgName, DEFAULT_CONFIG, sizeof szCfgName); |
strlcpy(szCfgName, DEFAULT_CONFIG, sizeof szCfgName); |
while ((ch = getopt(argc, argv, "hvbc:")) != -1) |
while ((ch = getopt(argc, argv, "hvbc:")) != -1) |
Line 155 main(int argc, char **argv)
|
Line 157 main(int argc, char **argv)
|
goto end; |
goto end; |
} |
} |
else |
else |
ioVERBOSE(1) printf("Start service in batch mode ...\n"); | ioDEBUG(1, "Start service in batch mode ..."); |
|
|
memset(&sa, 0, sizeof sa); |
memset(&sa, 0, sizeof sa); |
sigemptyset(&sa.sa_mask); |
sigemptyset(&sa.sa_mask); |
Line 181 main(int argc, char **argv)
|
Line 183 main(int argc, char **argv)
|
} |
} |
|
|
if (!(root = schedBegin())) { |
if (!(root = schedBegin())) { |
printf("Error:: scheduler #%d - %s\n", sched_GetErrno(), sched_GetError()); | ioLIBERR(sched); |
ret = 6; |
ret = 6; |
goto end; |
goto end; |
} |
} |
|
|
|
/* go catch the cat ... */ |
Run(sock); |
Run(sock); |
|
|
schedEnd(&root); |
schedEnd(&root); |
end: | end: /* free all resources */ |
srv_Close(sock); |
srv_Close(sock); |
call.CloseLOG(logg); |
call.CloseLOG(logg); |
call.ClosePUB(pub); |
call.ClosePUB(pub); |