--- mqtt/src/mqttd.c 2012/05/22 14:15:04 1.2.2.8 +++ mqtt/src/mqttd.c 2012/06/01 11:39:15 1.2.2.9 @@ -97,8 +97,9 @@ main(int argc, char **argv) for (i = 0; i < 3; i++) if (!mqttLoadRTLM(&cfg, i)) { printf("Error:: Can't load RTL module\n"); - while (i--) - mqttUnloadRTLM(i); + mqttUnloadRTLM(acc); + mqttUnloadRTLM(pub); + mqttUnloadRTLM(logg); cfgUnloadConfig(&cfg); closelog(); return 2; @@ -119,6 +120,7 @@ main(int argc, char **argv) goto end; } + if (mqttMkDir(&cfg)) { printf("Error:: in statedir #%d - %s\n", errno, strerror(errno)); ret = 3; @@ -190,9 +192,10 @@ end: /* free all resources */ call.CloseLOG(logg); call.ClosePUB(pub); call.CloseACC(acc); - for (i = 0; i < 3; i++) - mqttUnloadRTLM(i); - closelog(); + mqttUnloadRTLM(acc); + mqttUnloadRTLM(pub); + mqttUnloadRTLM(logg); cfgUnloadConfig(&cfg); + closelog(); return ret; }