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@125:f11cc566d073, 2016-09-23 (annotated)

Committer:
davidjhoward
Date:
Fri Sep 23 20:31:35 2016 +0000
Revision:
125:f11cc566d073
Parent:
124:48119db89152
Child:
149:950c90425f7c
more logging work

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