Sample MQTT program - simple send and receive

Dependencies:   C12832 MQTT

Fork of HelloMQTT by MQTT

Revision:
8:a3e3113054a1
--- /dev/null	Thu Jan 01 00:00:00 1970 +0000
+++ b/Linux-example/LinuxMQTT.h	Tue May 20 15:08:05 2014 +0000
@@ -0,0 +1,64 @@
+#if !defined(LINUXMQTT_H)
+#define LINUXMQTT_H
+
+class Countdown
+{
+public:
+    Countdown()
+    { 
+    
+    }
+
+    Countdown(int ms)
+    { 
+        countdown_ms(ms);
+    }
+    
+
+    bool expired()
+    {
+        struct timeval now, res;
+        gettimeofday(&now, NULL);
+        timersub(&end_time, &now, &res);        
+        //printf("left %d ms\n", (res.tv_sec < 0) ? 0 : res.tv_sec * 1000 + res.tv_usec / 1000);
+        //if (res.tv_sec > 0 || res.tv_usec > 0)
+        //  printf("expired %d %d\n", res.tv_sec, res.tv_usec);
+        return res.tv_sec < 0 || (res.tv_sec == 0 && res.tv_usec <= 0);
+    }
+    
+
+    void countdown_ms(int ms)  
+    {
+        struct timeval now;
+        gettimeofday(&now, NULL);
+        struct timeval interval = {ms / 1000, (ms % 1000) * 1000};
+        //printf("interval %d %d\n", interval.tv_sec, interval.tv_usec);
+        timeradd(&now, &interval, &end_time);
+    }
+
+    
+    void countdown(int seconds)
+    {
+        struct timeval now;
+        gettimeofday(&now, NULL);
+        struct timeval interval = {seconds, 0};
+        timeradd(&now, &interval, &end_time);
+    }
+
+    
+    int left_ms()
+    {
+        struct timeval now, res;
+        gettimeofday(&now, NULL);
+        timersub(&end_time, &now, &res);
+        //printf("left %d ms\n", (res.tv_sec < 0) ? 0 : res.tv_sec * 1000 + res.tv_usec / 1000);
+        return (res.tv_sec < 0) ? 0 : res.tv_sec * 1000 + res.tv_usec / 1000;
+    }
+    
+private:
+
+    struct timeval end_time;
+};
+
+
+#endif
\ No newline at end of file