|
|
| version 1.1.1.1.2.6, 2011/11/23 00:56:46 | version 1.1.1.1.2.8, 2011/11/23 08:50:03 |
|---|---|
| Line 15 main(int argc, char **argv) | Line 15 main(int argc, char **argv) |
| return 1; | return 1; |
| } | } |
| if (!mqttLoadRTLM(&cfg, 0)) { | if (!mqttLoadRTLM(&cfg, 0)) { |
| printf("Error:: Can't load RTL module\n"); | printf("Error:: Can't load RTL ACC module\n"); |
| UnloadConfig(&cfg); | |
| return 2; | return 2; |
| } | } |
| if (!mqttLoadRTLM(&cfg, 1)) { | |
| printf("Error:: Can't load RTL PUB module\n"); | |
| mqttUnloadRTLM(0); | |
| UnloadConfig(&cfg); | |
| return 2; | |
| } | |
| acc = mqttOpenDB(&cfg, 0); | acc = mqttOpenACC(&cfg); |
| if (!acc) | if (!acc) |
| goto end; | goto end; |
| pub = mqttOpenDB(&cfg, 1); | pub = mqttOpenPUB(&cfg); |
| if (!pub) | if (!pub) |
| goto end; | goto end; |
| if (mqttMkDir(&cfg)) { | |
| printf("Error:: in statedir #%d - %s\n", errno, strerror(errno)); | |
| goto end; | |
| } | |
| printf("success!\n"); | printf("success!\n"); |
| end: | end: |
| mqttCloseDB(pub); | mqttClosePUB(pub); |
| mqttCloseDB(acc); | mqttCloseACC(acc); |
| mqttUnloadRTLM(1); | |
| mqttUnloadRTLM(0); | mqttUnloadRTLM(0); |
| UnloadConfig(&cfg); | UnloadConfig(&cfg); |
| return 0; | return 0; |