struct mqtt_client_conf
{
struct mosquitto *mosq;
- bool connected;
+ _Bool connected;
char *host;
int port;
char *client_id;
status = mosquitto_reconnect (conf->mosq);
if (status != MOSQ_ERR_SUCCESS)
{
+ char errbuf[1024];
ERROR ("mqtt_connect_broker: mosquitto_connect failed: %s",
- (status == MOSQ_ERR_ERRNO ?
- strerror(errno) : mosquitto_strerror (status)));
+ (status == MOSQ_ERR_ERRNO)
+ ? sstrerror(errno, errbuf, sizeof (errbuf))
+ : mosquitto_strerror (status));
return (-1);
}
- conf->connected = true;
+ conf->connected = 1;
c_release (LOG_INFO,
- &conf->complaint_cantpublish,
- "mqtt plugin: successfully reconnected to broker \"%s:%d\"",
- conf->host, conf->port);
+ &conf->complaint_cantpublish,
+ "mqtt plugin: successfully reconnected to broker \"%s:%d\"",
+ conf->host, conf->port);
return (0);
} /* mqtt_reconnect_broker */
/* Mark our connection "down" regardless of the error as a safety
* measure; we will try to reconnect the next time we have to publish a
* message */
- conf->connected = false;
+ conf->connected = 0;
pthread_mutex_unlock (&conf->lock);
return (-1);
conf = user_data->data;
status = format_topic (topic, sizeof (topic), ds, vl, conf);
+ if (status != 0)
{
ERROR ("mqtt plugin: format_topic failed with status %d.", status);
return (status);
return (-1);
}
- conf->connected = false;
+ conf->connected = 0;
conf->host = strdup (MQTT_DEFAULT_HOST);
conf->port = MQTT_DEFAULT_PORT;
conf->client_id = strdup (MQTT_DEFAULT_CLIENT_ID);
DEBUG ("mqtt plugin: successfully connected to broker \"%s:%d\"",
conf->host, conf->port);
- conf->connected = true;
+ conf->connected = 1;
plugin_register_write ("mqtt", mqtt_write, &user_data);