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.
Dependencies: NaturalTinyShell_ice libmDot-12Sept mbed-rtos mbed
Fork of ICE by
src/CloudDataHandler/CloudDataHandler.cpp@26:6bd4868171c7, 2016-09-08 (annotated)
- Committer:
- davidjhoward
- Date:
- Thu Sep 08 17:55:32 2016 +0000
- Revision:
- 26:6bd4868171c7
- Parent:
- 20:653923c2f37a
- Child:
- 27:38205cebc3da
added send/receive to CloudDataHandler
Who changed what in which revision?
User | Revision | Line number | New contents of line |
---|---|---|---|
jmarkel44 | 20:653923c2f37a | 1 | #include "CloudDataHandler.h" |
davidjhoward | 26:6bd4868171c7 | 2 | #include "MTSLog.h" |
jmarkel44 | 20:653923c2f37a | 3 | #include <stdio.h> |
davidjhoward | 26:6bd4868171c7 | 4 | #include "mDot.h" |
davidjhoward | 26:6bd4868171c7 | 5 | #include <vector> |
jmarkel44 | 20:653923c2f37a | 6 | #include "rtos.h" |
davidjhoward | 26:6bd4868171c7 | 7 | #include "global.h" |
jmarkel44 | 20:653923c2f37a | 8 | |
jmarkel44 | 20:653923c2f37a | 9 | void CloudDataHandler(void const *args) |
jmarkel44 | 20:653923c2f37a | 10 | { |
davidjhoward | 26:6bd4868171c7 | 11 | int32_t ret; |
davidjhoward | 26:6bd4868171c7 | 12 | |
jmarkel44 | 20:653923c2f37a | 13 | printf("\r%s has started...\n", __func__); |
davidjhoward | 26:6bd4868171c7 | 14 | |
jmarkel44 | 20:653923c2f37a | 15 | while ( true ) { |
davidjhoward | 26:6bd4868171c7 | 16 | |
davidjhoward | 26:6bd4868171c7 | 17 | std::string tmp_buffer("{\"mtype\":\"20\"}"); |
davidjhoward | 26:6bd4868171c7 | 18 | std::vector<uint8_t> data(tmp_buffer.begin(), tmp_buffer.end()); |
davidjhoward | 26:6bd4868171c7 | 19 | |
davidjhoward | 26:6bd4868171c7 | 20 | // send the data to the gateway |
davidjhoward | 26:6bd4868171c7 | 21 | if ((ret = GLOBAL_mdot->send(data)) != mDot::MDOT_OK) |
davidjhoward | 26:6bd4868171c7 | 22 | logError("failed to send", ret, mDot::getReturnCodeString(ret).c_str()); |
davidjhoward | 26:6bd4868171c7 | 23 | else { |
davidjhoward | 26:6bd4868171c7 | 24 | logInfo("Sent to gateway: %s", tmp_buffer.c_str()); |
davidjhoward | 26:6bd4868171c7 | 25 | std::vector<uint8_t> rcvData(256); |
davidjhoward | 26:6bd4868171c7 | 26 | rcvData.clear(); |
davidjhoward | 26:6bd4868171c7 | 27 | if ((ret = GLOBAL_mdot->recv(rcvData)) == mDot::MDOT_OK) { |
davidjhoward | 26:6bd4868171c7 | 28 | if (!rcvData.empty()) { |
davidjhoward | 26:6bd4868171c7 | 29 | std::string rcv_string(rcvData.begin(), rcvData.end()); |
davidjhoward | 26:6bd4868171c7 | 30 | logInfo("Received Data: %s", rcv_string.c_str()); |
davidjhoward | 26:6bd4868171c7 | 31 | // if( edIotParse( rcvData, &parseObj ) == true ) { |
davidjhoward | 26:6bd4868171c7 | 32 | // edIotProcessIn( &parseObj, &execEnv, dot ); |
davidjhoward | 26:6bd4868171c7 | 33 | } |
davidjhoward | 26:6bd4868171c7 | 34 | } |
davidjhoward | 26:6bd4868171c7 | 35 | } |
davidjhoward | 26:6bd4868171c7 | 36 | Thread::wait(5000); |
jmarkel44 | 20:653923c2f37a | 37 | } |
jmarkel44 | 20:653923c2f37a | 38 | } |