Skip to content

Commit 292bdbe

Browse files
committed
exit if mosquitto_connect() fails
1 parent 2ebc128 commit 292bdbe

File tree

1 file changed

+3
-1
lines changed
  • host/openbeacon-mqtt/src

1 file changed

+3
-1
lines changed

host/openbeacon-mqtt/src/main.c

Lines changed: 3 additions & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -333,7 +333,9 @@ main (int argc, char **argv)
333333
/* initialize Mosquitto library */
334334
mosquitto_lib_init();
335335
mosq = mosquitto_new("openbeacon-mqtt", true, NULL);
336-
mosquitto_connect(mosq, (argc > 1) ? argv[1] : "127.0.0.1", MOSQUITTO_TCP_PORT, 600);
336+
ret = mosquitto_connect(mosq, (argc > 1) ? argv[1] : "127.0.0.1", MOSQUITTO_TCP_PORT, 600);
337+
if (ret != MOSQ_ERR_SUCCESS)
338+
return -1;
337339
mosquitto_loop_start(mosq);
338340

339341
/* main loop */

0 commit comments

Comments
 (0)