Erick / Mbed 2 deprecated ICE_BLE_TEST

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 Erick

src/CloudDataHandler/CloudDataHandler.cpp

Committer:
davidjhoward
Date:
2016-09-23
Revision:
123:ce602c91a9c3
Parent:
116:7337ed514891
Child:
149:950c90425f7c

File content as of revision 123:ce602c91a9c3:

#include "CloudDataHandler.h"
#include "CloudFileReceiver.h"
#include "LogHandler.h"
#include "MTSLog.h"
#include <stdio.h>
#include "mDot.h"
#include <vector>
#include "rtos.h"
#include "global.h"

void CloudDataHandler(void const *args)
{
    int32_t ret;
    bool joined;
    bool sent;

    printf("\r%s has started...\n", __func__);

    while ( true ) {

        std::string tmp_buffer;

        if (!GLOBAL_mdot->getNetworkJoinStatus()) {
            logInfo("network not joined, joining network");
            if ((ret = GLOBAL_mdot->joinNetwork()) != mDot::MDOT_OK) {
                logError("failed to join network %d:%s", ret, mDot::getReturnCodeString(ret).c_str());
                joined = false;
            }
        } else {
            joined = true;
        }

        sent = LogHandler( joined );
        if( sent == true ) {
            // sent a packet, try to receive back.
            logInfo("Sent to gateway: %s", tmp_buffer.c_str());
            std::vector<uint8_t> rcvData(256);
            rcvData.clear();
            if ((ret = GLOBAL_mdot->recv(rcvData)) == mDot::MDOT_OK) {
                if (!rcvData.empty()) {
                    std::string rcv_string(rcvData.begin(), rcvData.end());
                    logInfo("Received Data: %s", rcv_string.c_str());
                    CloudFileReceiver( &rcv_string, GLOBAL_mdot );
                }
            }
        }
        Thread::wait(10000);
    }
}