MQTT fork

Dependencies:   FP MQTTPacket

Fork of MQTT by MQTT

Files at this revision

API Documentation at this revision

Comitter:
vcoubard
Date:
Thu Sep 07 11:18:53 2017 +0000
Parent:
49:08571008b958
Commit message:
Revert Countdown changes and fix invalid use (copy assignment/copy construction) of it in client .

Changed in this revision

MQTTClient.h Show annotated file Show diff for this revision Revisions of this file
MQTTmbed.h Show annotated file Show diff for this revision Revisions of this file
--- a/MQTTClient.h	Thu Sep 07 09:55:54 2017 +0100
+++ b/MQTTClient.h	Thu Sep 07 11:18:53 2017 +0000
@@ -276,8 +276,6 @@
 template<class Network, class Timer, int a, int MAX_MESSAGE_HANDLERS>
 MQTT::Client<Network, Timer, a, MAX_MESSAGE_HANDLERS>::Client(Network& network, unsigned int command_timeout_ms)  : ipstack(network), packetid()
 {
-    last_sent = Timer();
-    last_received = Timer();
     this->command_timeout_ms = command_timeout_ms;
     cleanSession();
 }
@@ -504,7 +502,7 @@
 int MQTT::Client<Network, Timer, a, b>::yield(unsigned long timeout_ms)
 {
     int rc = SUCCESS;
-    Timer timer = Timer();
+    Timer timer;
 
     timer.countdown_ms(timeout_ms);
     while (!timer.expired())
--- a/MQTTmbed.h	Thu Sep 07 09:55:54 2017 +0100
+++ b/MQTTmbed.h	Thu Sep 07 11:18:53 2017 +0000
@@ -3,36 +3,29 @@
 
 #include "mbed.h"
 
-class Countdown
+class Countdown : private mbed::NonCopyable<Countdown>
 {
 public:
-    Countdown()
+    Countdown() : t() 
     {
-        t = new Timer();
     }
 
-    Countdown(int ms)
+    Countdown(int ms) : t() 
     {
-        t = new Timer();
         countdown_ms(ms);
     }
 
-    ~Countdown()
-    {
-        delete t;
-    }
-
     bool expired()
     {
-        return t->read_ms() >= interval_end_ms;
+        return t.read_ms() >= interval_end_ms;
     }
 
     void countdown_ms(unsigned long ms)
     {
-        t->stop();
+        t.stop();
         interval_end_ms = ms;
-        t->reset();
-        t->start();
+        t.reset();
+        t.start();
     }
 
     void countdown(int seconds)
@@ -42,11 +35,11 @@
 
     int left_ms()
     {
-        return interval_end_ms - t->read_ms();
+        return interval_end_ms - t.read_ms();
     }
 
 private:
-    Timer *t;
+    Timer t;
     unsigned long interval_end_ms;
 };