Important changes to repositories hosted on mbed.com
Mbed hosted mercurial repositories are deprecated and are due to be permanently deleted in July 2026.
To keep a copy of this software download the repository Zip archive or clone locally using Mercurial.
It is also possible to export all your personal repositories from the account settings page.
Fork of MQTT by
MQTTmbed.h@43:21da1f744243, 2014-09-29 (annotated)
- Committer:
- icraggs
- Date:
- Mon Sep 29 11:34:26 2014 +0000
- Revision:
- 43:21da1f744243
- Parent:
- MQTT_mbed.h@29:833386b16f3e
QoS 2 processing
Who changed what in which revision?
| User | Revision | Line number | New contents of line |
|---|---|---|---|
| icraggs | 29:833386b16f3e | 1 | #if !defined(MQTT_MBED_H) |
| icraggs | 29:833386b16f3e | 2 | #define MQTT_MBED_H |
| icraggs | 29:833386b16f3e | 3 | |
| icraggs | 29:833386b16f3e | 4 | #include "mbed.h" |
| icraggs | 29:833386b16f3e | 5 | |
| icraggs | 29:833386b16f3e | 6 | class Countdown |
| icraggs | 29:833386b16f3e | 7 | { |
| icraggs | 29:833386b16f3e | 8 | public: |
| icraggs | 29:833386b16f3e | 9 | Countdown() |
| icraggs | 29:833386b16f3e | 10 | { |
| icraggs | 29:833386b16f3e | 11 | t = Timer(); |
| icraggs | 29:833386b16f3e | 12 | } |
| icraggs | 29:833386b16f3e | 13 | |
| icraggs | 29:833386b16f3e | 14 | Countdown(int ms) |
| icraggs | 29:833386b16f3e | 15 | { |
| icraggs | 29:833386b16f3e | 16 | t = Timer(); |
| icraggs | 29:833386b16f3e | 17 | countdown_ms(ms); |
| icraggs | 29:833386b16f3e | 18 | } |
| icraggs | 29:833386b16f3e | 19 | |
| icraggs | 29:833386b16f3e | 20 | |
| icraggs | 29:833386b16f3e | 21 | bool expired() |
| icraggs | 29:833386b16f3e | 22 | { |
| icraggs | 29:833386b16f3e | 23 | return t.read_ms() >= interval_end_ms; |
| icraggs | 29:833386b16f3e | 24 | } |
| icraggs | 29:833386b16f3e | 25 | |
| icraggs | 43:21da1f744243 | 26 | void countdown_ms(unsigned long ms) |
| icraggs | 29:833386b16f3e | 27 | { |
| icraggs | 29:833386b16f3e | 28 | t.stop(); |
| icraggs | 29:833386b16f3e | 29 | interval_end_ms = ms; |
| icraggs | 29:833386b16f3e | 30 | t.reset(); |
| icraggs | 29:833386b16f3e | 31 | t.start(); |
| icraggs | 29:833386b16f3e | 32 | } |
| icraggs | 29:833386b16f3e | 33 | |
| icraggs | 29:833386b16f3e | 34 | void countdown(int seconds) |
| icraggs | 29:833386b16f3e | 35 | { |
| icraggs | 43:21da1f744243 | 36 | countdown_ms((unsigned long)seconds * 1000L); |
| icraggs | 29:833386b16f3e | 37 | } |
| icraggs | 29:833386b16f3e | 38 | |
| icraggs | 29:833386b16f3e | 39 | int left_ms() |
| icraggs | 29:833386b16f3e | 40 | { |
| icraggs | 29:833386b16f3e | 41 | return interval_end_ms - t.read_ms(); |
| icraggs | 29:833386b16f3e | 42 | } |
| icraggs | 29:833386b16f3e | 43 | |
| icraggs | 29:833386b16f3e | 44 | private: |
| icraggs | 29:833386b16f3e | 45 | Timer t; |
| icraggs | 43:21da1f744243 | 46 | unsigned long interval_end_ms; |
| icraggs | 29:833386b16f3e | 47 | }; |
| icraggs | 29:833386b16f3e | 48 | |
| icraggs | 29:833386b16f3e | 49 | #endif |
