version 1.2.2.2, 2012/04/15 21:44:33
|
version 1.2.2.7, 2012/05/05 14:51:02
|
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; |
|
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 43 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 68 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 93 main(int argc, char **argv)
|
Line 94 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 103 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 152 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 178 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 196 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; |
} |
} |