Official reference client implementation for Cumulocity SmartREST on u-blox C027.
Dependencies: C027_Support C12832 LM75B MMA7660 MbedSmartRest mbed-rtos mbed
Fork of MbedSmartRestMain by
operation/PollThread.h@106:c61f0d62b625, 2015-05-11 (annotated)
- Committer:
- xinlei
- Date:
- Mon May 11 18:10:44 2015 +0000
- Revision:
- 106:c61f0d62b625
- Parent:
- 101:dbcd3bc51758
- Child:
- 108:f1ee3e1eb126
SmartRestSSLSocket and various bug-fixes for rc3
Who changed what in which revision?
User | Revision | Line number | New contents of line |
---|---|---|---|
xinlei | 96:5dfdc8568e9f | 1 | #ifndef POLLTHREAD_H |
xinlei | 96:5dfdc8568e9f | 2 | #define POLLTHREAD_H |
xinlei | 96:5dfdc8568e9f | 3 | #include "SmartRestSocket.h" |
xinlei | 96:5dfdc8568e9f | 4 | #include "Operation.h" |
xinlei | 96:5dfdc8568e9f | 5 | #include "SmartRestConf.h" |
xinlei | 96:5dfdc8568e9f | 6 | #include "ControlParser.h" |
xinlei | 96:5dfdc8568e9f | 7 | |
xinlei | 96:5dfdc8568e9f | 8 | class PollThread |
xinlei | 96:5dfdc8568e9f | 9 | { |
xinlei | 96:5dfdc8568e9f | 10 | public: |
xinlei | 97:ea056f6be2e8 | 11 | PollThread(OperationPool& pool, |
xinlei | 99:e369fc75c000 | 12 | ConfigSync& configSync): |
xinlei | 97:ea056f6be2e8 | 13 | sock(), parser(pool, configSync), |
xinlei | 96:5dfdc8568e9f | 14 | thread(PollThread::threadWrapper, this) { |
xinlei | 96:5dfdc8568e9f | 15 | strncpy(uri, "/devicecontrol/notifications", sizeof(uri)); |
xinlei | 96:5dfdc8568e9f | 16 | } |
xinlei | 101:dbcd3bc51758 | 17 | virtual ~PollThread() {} |
xinlei | 96:5dfdc8568e9f | 18 | bool handshake(); |
xinlei | 96:5dfdc8568e9f | 19 | bool subscribe(); |
xinlei | 96:5dfdc8568e9f | 20 | bool connect(); |
xinlei | 96:5dfdc8568e9f | 21 | void setChannel(long channel) { snprintf(chn, sizeof(chn), "/%ld", channel); } |
xinlei | 96:5dfdc8568e9f | 22 | void threadFunc(); |
xinlei | 96:5dfdc8568e9f | 23 | static void threadWrapper(const void *p) { ((PollThread*)p)->threadFunc(); } |
xinlei | 96:5dfdc8568e9f | 24 | private: |
xinlei | 96:5dfdc8568e9f | 25 | char chn[16]; |
xinlei | 96:5dfdc8568e9f | 26 | char uri[30]; |
xinlei | 96:5dfdc8568e9f | 27 | char bayeuxId[50]; |
xinlei | 96:5dfdc8568e9f | 28 | char buf[SMARTREST_SIZE]; |
xinlei | 106:c61f0d62b625 | 29 | char buf2[SMARTREST_BODY_SIZE]; |
xinlei | 96:5dfdc8568e9f | 30 | SmartRestSocket sock; |
xinlei | 96:5dfdc8568e9f | 31 | ControlParser parser; |
xinlei | 96:5dfdc8568e9f | 32 | Thread thread; |
xinlei | 96:5dfdc8568e9f | 33 | }; |
xinlei | 96:5dfdc8568e9f | 34 | |
xinlei | 96:5dfdc8568e9f | 35 | #endif /* POLLTHREAD_H */ |