--- mqtt/src/mqttd.c 2011/11/29 23:31:57 1.1.1.1.2.4 +++ mqtt/src/mqttd.c 2011/11/30 00:12:30 1.1.1.1.2.5 @@ -27,6 +27,7 @@ main(int argc, char **argv) register int i; sqlite3 *acc = NULL, *pub = NULL; FILE *logg = NULL; + int sock, ret = 0; strlcpy(szCfgName, DEFAULT_CONFIG, sizeof szCfgName); while ((ch = getopt(argc, argv, "hvc:")) != -1) @@ -58,22 +59,35 @@ main(int argc, char **argv) return 2; } acc = call.OpenACC(&cfg); - if (!acc) + if (!acc) { + ret = 3; goto end; + } pub = call.OpenPUB(&cfg); - if (!pub) + if (!pub) { + ret = 3; goto end; + } logg = call.OpenLOG(&cfg); - if (!logg) + if (!logg) { + ret = 3; goto end; + } if (mqttMkDir(&cfg)) { printf("Error:: in statedir #%d - %s\n", errno, strerror(errno)); + ret = 3; goto end; } VERB(2) printf("Service is ready for start engine ...\n"); + if ((sock = srv_Socket(&cfg)) == -1) { + ret = 4; + goto end; + } + + srv_Close(sock); end: call.CloseLOG(logg); call.ClosePUB(pub); @@ -81,5 +95,5 @@ end: for (i = 0; i < 3; i++) mqttUnloadRTLM(i); UnloadConfig(&cfg); - return 0; + return ret; }