HelloMQTT porting to FRDM-K64F+AppShield
Dependencies: C12832 EthernetInterface MQTT mbed-rtos mbed
Fork of HelloMQTT by
Tested with RabbitMQ 3.4.4 on OSX.
modification are below
- skip QOS2 test since RabbitMQ is not supported QOS2 message type
Diff: Linux-example/LinuxMQTT.h
- Revision:
- 8:a3e3113054a1
diff -r 3de634f2d40c -r a3e3113054a1 Linux-example/LinuxMQTT.h --- /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