Diff: MQTTSNUDP.h

Revision:

1:70b751b7a189

--- /dev/null	Thu Jan 01 00:00:00 1970 +0000
+++ b/MQTTSNUDP.h	Mon Aug 20 16:42:45 2018 +0200
@@ -0,0 +1,48 @@
+#if !defined(MQTTSOCKET_H)
+#define MQTTSOCKET_H
+
+#include "MQTTmbed.h"
+#include "udp_interface.h"
+
+class MQTTSNUDP
+{
+	int mSocket;
+	UDPinterface *mInterface;
+	char mHost[128];
+	int mPort;
+
+public:
+
+	MQTTSNUDP(UDPinterface *interface) : mSocket(-1), mInterface(interface), mPort(-1)
+	{
+	}
+
+    int connect(char* hostname, int port, int timeout=1000)
+    {
+        strncpy(mHost, hostname, 128);
+        mPort = port;
+        mSocket = mInterface->connect(hostname, port);
+        return mSocket;
+    }
+
+    int read(unsigned char* buffer, int len, int timeout)
+    {
+    	char rxHost[256];
+    	int rxPort;
+        return mInterface->read(mSocket, rxHost, &rxPort, buffer, len, timeout);
+    }
+    
+    int write(unsigned char* buffer, int len, int timeout)
+    {
+        return mInterface->write(mSocket, mHost, mPort, buffer, len, timeout);
+    }
+    
+    int disconnect()
+    {
+    	return mInterface->disconnect(mSocket);
+    }
+};
+
+
+
+#endif