Gabriel Arnautu / MQTTS

fork of wolfSSL/MQTTS library with increased message buffer & increased number of subscribed topics

Dependencies:   FP MQTTPacket

Fork of MQTTS by wolf SSL

Files at this revision

API Documentation at this revision

Revision 41:b7e86fa6dbb8, committed 2014-08-15

Comitter:
icraggs
Date:
Fri Aug 15 10:23:56 2014 +0000
Parent:
40:9623a2c9c8ac
Child:
42:f5beda831651
Commit message:
Add logging and getter for EthernetInterface object

Changed in this revision

MQTTClient.h Show annotated file Show diff for this revision Revisions of this file
MQTTEthernet.h Show annotated file Show diff for this revision Revisions of this file
MQTT_logging.h Show annotated file Show diff for this revision Revisions of this file 
--- a/MQTTClient.h	Fri Aug 01 23:44:12 2014 +0000
+++ b/MQTTClient.h	Fri Aug 15 10:23:56 2014 +0000
@@ -28,6 +28,7 @@
 #include "FP.h"
 #include "MQTTPacket.h"
 #include "stdio.h"
+#include "MQTT_logging.h"
 
 namespace MQTT
 {

--- a/MQTTEthernet.h	Fri Aug 01 23:44:12 2014 +0000
+++ b/MQTTEthernet.h	Fri Aug 15 10:23:56 2014 +0000
@@ -15,6 +15,16 @@
         eth.connect();
     }
     
+    EthernetInterface& getEth()
+    {
+        return eth;
+    }
+    
+    void reconnect()
+    {
+        eth.connect();  // nothing I've tried actually works to reconnect 
+    }
+    
 private:
 
     EthernetInterface eth;

--- /dev/null	Thu Jan 01 00:00:00 1970 +0000
+++ b/MQTT_logging.h	Fri Aug 15 10:23:56 2014 +0000
@@ -0,0 +1,39 @@
+#if !defined(MQTT_LOGGING_H)
+#define MQTT_LOGGING_H
+
+#define STREAM      stdout
+#if !defined(DEBUG)
+#define DEBUG(...)    \
+    {\
+    fprintf(STREAM, "DEBUG:   %s L#%d ", __PRETTY_FUNCTION__, __LINE__);  \
+    fprintf(STREAM, ##__VA_ARGS__); \
+    fflush(STREAM); \
+    }
+#endif
+#if !defined(LOG)
+#define LOG(...)    \
+    {\
+    fprintf(STREAM, "LOG:   %s L#%d ", __PRETTY_FUNCTION__, __LINE__);  \
+    fprintf(STREAM, ##__VA_ARGS__); \
+    fflush(STREAM); \
+    }
+#endif
+#if !defined(WARN)
+#define WARN(...)   \
+    { \
+    fprintf(STREAM, "WARN:  %s L#%d ", __PRETTY_FUNCTION__, __LINE__);  \
+    fprintf(STREAM, ##__VA_ARGS__); \
+    fflush(STREAM); \
+    }
+#endif 
+#if !defined(ERROR)
+#define ERROR(...)  \
+    { \
+    fprintf(STREAM, "ERROR: %s L#%d ", __PRETTY_FUNCTION__, __LINE__); \
+    fprintf(STREAM, ##__VA_ARGS__); \
+    fflush(STREAM); \
+    exit(1); \
+    }
+#endif
+
+#endif
\ No newline at end of file