--- mqtt/src/mqttd.c 2012/04/15 21:48:23 1.2.2.3 +++ mqtt/src/mqttd.c 2012/05/22 14:15:04 1.2.2.8 @@ -11,11 +11,10 @@ cfg_root_t cfg; sessions_t Sessions; sched_root_task_t *root; sqlite3 *acc, *pub; -pthread_mutex_t mtx_sess, mtx_pub; FILE *logg; extern char compiled[], compiledby[], compilehost[]; static char szCfgName[MAXPATHLEN]; -intptr_t Kill; +volatile intptr_t Kill; static void @@ -43,7 +42,7 @@ sigHand(int sig) break; } - syslog(LOG_ERR, "Error:: can't reload #%d - %s", cfg_GetErrno(), cfg_GetError()); + ioLIBERR(cfg); case SIGTERM: ioDEBUG(1, "Terminate MQTT service in progress"); Kill++; @@ -93,8 +92,6 @@ main(int argc, char **argv) printf("Error:: can't load #%d - %s\n", cfg_GetErrno(), cfg_GetError()); return 1; } - pthread_mutex_init(&mtx_sess, NULL); - pthread_mutex_init(&mtx_pub, NULL); openlog("mqttd", LOG_PID | LOG_CONS, LOG_DAEMON); /* load 3 plugins */ for (i = 0; i < 3; i++) @@ -104,8 +101,6 @@ main(int argc, char **argv) mqttUnloadRTLM(i); cfgUnloadConfig(&cfg); closelog(); - pthread_mutex_destroy(&mtx_pub); - pthread_mutex_destroy(&mtx_sess); return 2; } acc = call.OpenACC(&cfg); @@ -199,7 +194,5 @@ end: /* free all resources */ mqttUnloadRTLM(i); closelog(); cfgUnloadConfig(&cfg); - pthread_mutex_destroy(&mtx_pub); - pthread_mutex_destroy(&mtx_sess); return ret; }