An API for using MQTT over multiple transports

Dependencies:   FP MQTTPacket

Dependents:   IBMIoTClientEthernetExample_W5500 IBMIoTClientEthernetExample_W5200

Fork of MQTT by MQTT

Files at this revision

API Documentation at this revision

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