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/LogHandler.cpp@123:ce602c91a9c3, 2016-09-23 (annotated)

Committer:
davidjhoward
Date:
Fri Sep 23 15:25:06 2016 +0000
Revision:
123:ce602c91a9c3
Parent:
116:7337ed514891
Child:
124:48119db89152
continue work on logging

Who changed what in which revision?

UserRevisionLine numberNew contents of line
davidjhoward 116:7337ed514891 1 #include "LogHandler.h"
davidjhoward 116:7337ed514891 2 #include "LogLocalApi.h"
davidjhoward 116:7337ed514891 3 #include "CloudFileReceiver.h"
davidjhoward 116:7337ed514891 4 #include "MTSLog.h"
davidjhoward 116:7337ed514891 5 #include "MbedJSONValue.h"
davidjhoward 116:7337ed514891 6 #include "global.h"
davidjhoward 116:7337ed514891 7 #include <sstream>
davidjhoward 116:7337ed514891 8 #include <iostream>
davidjhoward 116:7337ed514891 9
davidjhoward 116:7337ed514891 10 Mail<LoggerQueue_t, 16> LoggerQueue;
davidjhoward 116:7337ed514891 11
davidjhoward 123:ce602c91a9c3 12 size_t LoggerXmitLength = LOG_BYTES_PER_ENTRY;
davidjhoward 116:7337ed514891 13
davidjhoward 123:ce602c91a9c3 14 bool LogHandler( bool joined )
davidjhoward 116:7337ed514891 15 {
davidjhoward 116:7337ed514891 16 int32_t ret;
davidjhoward 123:ce602c91a9c3 17 char buffer[LOG_BYTES_PER_ENTRY];
davidjhoward 116:7337ed514891 18 std::string tmp_buffer;
davidjhoward 123:ce602c91a9c3 19 bool log_in_eeprom=false;
davidjhoward 123:ce602c91a9c3 20 bool log_to_send=false;
davidjhoward 116:7337ed514891 21
davidjhoward 116:7337ed514891 22 osEvent evt = LoggerQueue.get(50);
davidjhoward 123:ce602c91a9c3 23 if( (evt.status == osEventMail) ) {
davidjhoward 123:ce602c91a9c3 24 // pull the log event from the queue, even if we are not joined
davidjhoward 116:7337ed514891 25 LoggerQueue_t *LoggerEvent = (LoggerQueue_t*)evt.value.p;
davidjhoward 116:7337ed514891 26 logInfo("Log Msg Received: log entry: %s", LoggerEvent->log_entry);
davidjhoward 123:ce602c91a9c3 27 strncpy( buffer, LoggerEvent->log_entry, (LoggerXmitLength-1) );
davidjhoward 123:ce602c91a9c3 28 tmp_buffer.assign(buffer);
davidjhoward 123:ce602c91a9c3 29 log_to_send = true;
davidjhoward 123:ce602c91a9c3 30 // printf("%s:%d: Found Log Event on LoggerQueue to send to cloud\r\n", __func__, __LINE__);
davidjhoward 123:ce602c91a9c3 31 LoggerQueue.free(LoggerEvent);
davidjhoward 123:ce602c91a9c3 32 }
davidjhoward 123:ce602c91a9c3 33
davidjhoward 123:ce602c91a9c3 34 if( (evt.status == osEventMail) && (joined == false) ) {
davidjhoward 123:ce602c91a9c3 35 // if we pulled a log from the queue put it in the EEPROM
davidjhoward 123:ce602c91a9c3 36 LogLocalApi( tmp_buffer.c_str() );
davidjhoward 123:ce602c91a9c3 37 // printf("%s:%d: Not Connected, Putting Logger event In EEPROM\r\n", __func__, __LINE__);
davidjhoward 123:ce602c91a9c3 38 return false;
davidjhoward 123:ce602c91a9c3 39 }
davidjhoward 123:ce602c91a9c3 40
davidjhoward 123:ce602c91a9c3 41 if( (evt.status != osEventMail) && joined == true) {
davidjhoward 123:ce602c91a9c3 42 // nothing on the queue, see if there is anything in the EEPROM to send.
davidjhoward 123:ce602c91a9c3 43 log_in_eeprom = LogLocalApi_PopEntry( buffer );
davidjhoward 123:ce602c91a9c3 44 if( log_in_eeprom == true ) {
davidjhoward 116:7337ed514891 45 tmp_buffer.assign(buffer);
davidjhoward 123:ce602c91a9c3 46 log_to_send = true;
davidjhoward 123:ce602c91a9c3 47 // printf("%s:%d: Found Log Event in EEPROM to send to cloud\r\n", __func__, __LINE__);
davidjhoward 123:ce602c91a9c3 48 }
davidjhoward 123:ce602c91a9c3 49 else
davidjhoward 123:ce602c91a9c3 50 {
davidjhoward 123:ce602c91a9c3 51 // printf("%s:%d: Nothing in EEPROM\r\n", __func__, __LINE__);
davidjhoward 116:7337ed514891 52 }
davidjhoward 116:7337ed514891 53 }
davidjhoward 116:7337ed514891 54
davidjhoward 123:ce602c91a9c3 55 if( log_to_send == false ) {
davidjhoward 123:ce602c91a9c3 56 // no event log to send, send the heart beat message.
davidjhoward 123:ce602c91a9c3 57 // printf("%s:%d: No Log Event to send, attempt heart beat\r\n", __func__, __LINE__);
davidjhoward 123:ce602c91a9c3 58 tmp_buffer = "{\"mtype\":\"20\"}";
davidjhoward 123:ce602c91a9c3 59 }
davidjhoward 123:ce602c91a9c3 60
davidjhoward 123:ce602c91a9c3 61 if( joined == true ) {
davidjhoward 116:7337ed514891 62 std::vector<uint8_t> data(tmp_buffer.begin(), tmp_buffer.end());
davidjhoward 116:7337ed514891 63 if ((ret = GLOBAL_mdot->send(data)) == mDot::MDOT_OK) {
davidjhoward 123:ce602c91a9c3 64 // printf("%s:%d: Successful send to cloud\r\n", __func__, __LINE__);
davidjhoward 116:7337ed514891 65 return true;
davidjhoward 116:7337ed514891 66 }
davidjhoward 123:ce602c91a9c3 67 // printf("failed to send, ret=%d, %s\r\n", ret, mDot::getReturnCodeString(ret).c_str());
davidjhoward 116:7337ed514891 68 }
davidjhoward 116:7337ed514891 69
davidjhoward 123:ce602c91a9c3 70 if( log_to_send == true ) {
davidjhoward 123:ce602c91a9c3 71 // We had a log event ready to send but didn't send it.
davidjhoward 123:ce602c91a9c3 72 // Store it in the EEPROM for the next attempt.
davidjhoward 123:ce602c91a9c3 73 // printf("%s:%d: Could not send Log Event to cloud, store in EEPROM\r\n", __func__, __LINE__);
davidjhoward 123:ce602c91a9c3 74 LogLocalApi( tmp_buffer.c_str() );
davidjhoward 123:ce602c91a9c3 75 }
davidjhoward 123:ce602c91a9c3 76 else
davidjhoward 123:ce602c91a9c3 77 {
davidjhoward 123:ce602c91a9c3 78 // printf("%s:%d: Could not send to cloud, nothing to store in EEPROM\r\n", __func__, __LINE__);
davidjhoward 123:ce602c91a9c3 79 }
davidjhoward 116:7337ed514891 80 return false;
davidjhoward 116:7337ed514891 81 }