--- mqtt/src/Attic/mqtt.c 2011/12/13 15:23:43 1.1.1.1.2.27 +++ mqtt/src/Attic/mqtt.c 2011/12/14 12:45:30 1.1.1.1.2.28 @@ -86,6 +86,7 @@ main(int argc, char **argv) AIT_SET_STR(&args->User, ""); AIT_SET_STR(&args->Pass, ""); + args->ka = MQTT_KEEPALIVE; strlcpy(szCfgName, DEFAULT_CONFIG, sizeof szCfgName); while ((ch = getopt(argc, argv, "T:U:P:p:t:s:q:drc:W:M:fDvh")) != -1) switch (ch) { @@ -200,12 +201,33 @@ main(int argc, char **argv) return 2; } - if (try2Connect(sock) == -1) { - close(sock); - UnloadConfig(&cfg); - args->free(args); - free(args); - return 3; + printf("Connected ... "); + switch (try2Connect(sock)) { + case -1: + printf("FAILED!\n"); + close(sock); + UnloadConfig(&cfg); + args->free(args); + free(args); + return 3; + case MQTT_RETCODE_ACCEPTED: + printf("OK\n"); + break; + case MQTT_RETCODE_REFUSE_VER: + printf("Incorrect version\n"); + break; + case MQTT_RETCODE_REFUSE_ID: + printf("Incorrect connectID\n"); + break; + case MQTT_RETCODE_REFUSE_UNAVAIL: + printf("Service unavailable\n"); + break; + case MQTT_RETCODE_REFUSE_USERPASS: + printf("Refuse user/pass\n"); + break; + case MQTT_RETCODE_DENIED: + printf("DENIED.\n"); + break; } shutdown(sock, SHUT_RDWR);