From 9abda03413ff487070b28cc5b44a13e0c985282d Mon Sep 17 00:00:00 2001
From: Oskari Timperi <oskari.timperi@iki.fi>
Date: Sat, 18 Feb 2017 15:40:10 +0200
Subject: Add MqttClientIsConnected()

---
 src/client.c | 5 +++++
 src/mqtt.h   | 2 ++
 2 files changed, 7 insertions(+)

(limited to 'src')

diff --git a/src/client.c b/src/client.c
index c9fa876..4d796a9 100644
--- a/src/client.c
+++ b/src/client.c
@@ -282,6 +282,11 @@ int MqttClientDisconnect(MqttClient *client)
     return MqttClientQueueSimplePacket(client, MqttPacketTypeDisconnect);
 }
 
+int MqttClientIsConnected(MqttClient *client)
+{
+    return client->stream.sock != -1;
+}
+
 int MqttClientRunOnce(MqttClient *client, int timeout)
 {
     int rv;
diff --git a/src/mqtt.h b/src/mqtt.h
index 4ea0930..f07ff3c 100644
--- a/src/mqtt.h
+++ b/src/mqtt.h
@@ -73,6 +73,8 @@ int MqttClientConnect(MqttClient *client, const char *host, short port,
 
 int MqttClientDisconnect(MqttClient *client);
 
+int MqttClientIsConnected(MqttClient *client);
+
 int MqttClientRunOnce(MqttClient *client, int timeout);
 
 int MqttClientRun(MqttClient *client);
-- 
cgit v1.2.3