version 1.2.2.1, 2012/04/11 15:08:27
|
version 1.2.2.8, 2012/05/22 14:15:04
|
Line 11 cfg_root_t cfg;
|
Line 11 cfg_root_t cfg;
|
sessions_t Sessions; |
sessions_t Sessions; |
sched_root_task_t *root; |
sched_root_task_t *root; |
sqlite3 *acc, *pub; |
sqlite3 *acc, *pub; |
pthread_mutex_t mtx_sess, mtx_pub; |
|
FILE *logg; |
FILE *logg; |
extern char compiled[], compiledby[], compilehost[]; |
extern char compiled[], compiledby[], compilehost[]; |
static char szCfgName[MAXPATHLEN]; |
static char szCfgName[MAXPATHLEN]; |
intptr_t Kill; | volatile intptr_t Kill; |
|
|
|
|
static void |
static void |
Line 43 sigHand(int sig)
|
Line 42 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 93 main(int argc, char **argv)
|
Line 92 main(int argc, char **argv)
|
printf("Error:: can't load #%d - %s\n", cfg_GetErrno(), cfg_GetError()); |
printf("Error:: can't load #%d - %s\n", cfg_GetErrno(), cfg_GetError()); |
return 1; |
return 1; |
} |
} |
pthread_mutex_init(&mtx_sess, NULL); |
|
pthread_mutex_init(&mtx_pub, NULL); |
|
openlog("mqttd", LOG_PID | LOG_CONS, LOG_DAEMON); |
openlog("mqttd", LOG_PID | LOG_CONS, LOG_DAEMON); |
/* load 3 plugins */ |
/* load 3 plugins */ |
for (i = 0; i < 3; i++) |
for (i = 0; i < 3; i++) |
Line 104 main(int argc, char **argv)
|
Line 101 main(int argc, char **argv)
|
mqttUnloadRTLM(i); |
mqttUnloadRTLM(i); |
cfgUnloadConfig(&cfg); |
cfgUnloadConfig(&cfg); |
closelog(); |
closelog(); |
pthread_mutex_destroy(&mtx_pub); |
|
pthread_mutex_destroy(&mtx_sess); |
|
return 2; |
return 2; |
} |
} |
acc = call.OpenACC(&cfg); |
acc = call.OpenACC(&cfg); |
Line 155 main(int argc, char **argv)
|
Line 150 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 164 main(int argc, char **argv)
|
Line 159 main(int argc, char **argv)
|
sigaction(SIGTERM, &sa, NULL); |
sigaction(SIGTERM, &sa, NULL); |
sigaction(SIGCHLD, &sa, NULL); |
sigaction(SIGCHLD, &sa, NULL); |
sigaction(SIGPIPE, &sa, NULL); |
sigaction(SIGPIPE, &sa, NULL); |
ioDEBUG(2, "Service is ready for start engine ..."); | ioDEBUG(2, "Service is ready for starting engine ..."); |
|
|
if ((sock = srv_Socket(&cfg)) == -1) { |
if ((sock = srv_Socket(&cfg)) == -1) { |
ret = 4; |
ret = 4; |
Line 181 main(int argc, char **argv)
|
Line 176 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); |
Line 198 end:
|
Line 194 end:
|
mqttUnloadRTLM(i); |
mqttUnloadRTLM(i); |
closelog(); |
closelog(); |
cfgUnloadConfig(&cfg); |
cfgUnloadConfig(&cfg); |
pthread_mutex_destroy(&mtx_pub); |
|
pthread_mutex_destroy(&mtx_sess); |
|
return ret; |
return ret; |
} |
} |