Diff: ICE-Application/src/AnalyticsLogger/AnalyticsLogger.cpp

Revision:

0:61364762ee0e

diff -r 000000000000 -r 61364762ee0e ICE-Application/src/AnalyticsLogger/AnalyticsLogger.cpp
--- /dev/null	Thu Jan 01 00:00:00 1970 +0000
+++ b/ICE-Application/src/AnalyticsLogger/AnalyticsLogger.cpp	Tue Jan 24 19:05:33 2017 +0000
@@ -0,0 +1,110 @@
+/******************************************************************************
+ *
+ * File:                AnalyticsLogger.cpp
+ * Desciption:          source for the ICE Analytics Logger
+ *
+ *****************************************************************************/
+#include "global.h"
+#include <stdio.h>
+#include <string>
+#include <sstream>
+#include <iostream>
+#include <vector>
+#include <time.h>
+#include "AnalyticsLogger.h"
+#include "LoggerApi.h"
+//#include "rtc.h"
+
+static void checkStackUsage(void);
+
+/*****************************************************************************
+ * Function:             AnalyticsLogger
+ * Description:          entry point for the Analytics Logger
+ *
+ * @param                (IN) args (user-defined arguments)
+ * @return               none
+ *****************************************************************************/
+void AnalyticsLogger(void const *args)
+{
+    struct tm       *ts;
+    time_t curr_sec;
+    int last_min=8;
+    bool log_sent=false;
+    
+    printf("\rAnalyticsLogger has started...\n");
+
+    while ( true ) {
+
+        std::ostringstream log_event;
+
+        curr_sec = time(0);
+        ts = localtime(&curr_sec);
+//        printf("curr_sec=%ld, min=%d (last=%d)\r\n", curr_sec, ts->tm_min, last_min );
+        if( ((ts->tm_min%5) == 0) && (ts->tm_min != last_min) ) {
+            last_min = ts->tm_min;
+
+            int map_count = ModbusRegisterMap.size();
+            int collected_count = 0;
+
+            log_event << "\"lr\":[";
+            std::map<std::string, ModbusRegister>::iterator iter;
+            for (iter = ModbusRegisterMap.begin(); iter != ModbusRegisterMap.end(); ++iter) {
+
+                collected_count = collected_count + 1;
+
+                log_event << "{\"t\":"<< "\"" << iter->first.c_str() << "\"," << "\"v\":"<< "\"" << RegisterValueMap[iter->first].float_value<< "\"},";
+                log_sent = false;
+                if( log_event.str().size() >= 150 ) {
+                    std::string str = log_event.str();
+                    str.erase( str.size() - 1 );
+                    if( collected_count == map_count ) {
+                        str.append("],\"seq\":\"0\"");
+                    } else {
+                        str.append("],\"seq\":\"1\"");
+                    }
+//                    printf("%s:%d: Logging %s : len=%d\r\n", __func__, __LINE__, str.c_str(), str.length() );
+                    LiveDataLoggerApi( str.c_str() );
+                    log_event.str("");
+                    log_event.clear();
+                    log_event << "\"lr\":[";
+                    log_sent = true;
+                }
+            }
+            if( log_sent == false ) {
+                std::string str = log_event.str();
+                str.erase( str.size() - 1 );
+                str.append("],\"seq\":\"0\"");
+                if( str.length() > 20 ) {
+//                    printf("%s:%d: Logging %s : len=%d\r\n", __func__, __LINE__, str.c_str(), str.length() );
+                    LiveDataLoggerApi( str.c_str() );
+                }
+            }
+        }
+
+        Thread::wait(5000);
+        checkStackUsage();
+    }
+}
+
+//
+// For optimizing/debugging purposes only!
+//
+static void checkStackUsage(void)
+{
+    const float threshold = .85;
+
+    std::vector<std::pair<std::string, Thread*> > taskList;
+    taskList.push_back(make_pair((std::string)"AnalyticsLogger",  GLOBAL_analyticsLogger_thread));
+    taskList.push_back(make_pair((std::string)"DataHandler",      GLOBAL_dataHandler_thread));
+    taskList.push_back(make_pair((std::string)"ConfigHandler",    GLOBAL_configHandler_thread));
+    taskList.push_back(make_pair((std::string)"ControlTask",      GLOBAL_controlTask_thread));
+    taskList.push_back(make_pair((std::string)"ModbusMaster",     GLOBAL_modbusMaster_thread));
+    taskList.push_back(make_pair((std::string)"OutputTask",       GLOBAL_outputTask_thread));
+    for ( std::vector<std::pair<std::string, Thread*> >::iterator pos = taskList.begin(); pos != taskList.end(); ++ pos) {
+        // do something
+        if ( (float) pos->second->max_stack() / (float) pos->second->stack_size() >= threshold ) {
+            printf("\rWARNING: %s has used %.2f%% of its stack!\n", pos->first.c_str(),
+                   (double)((float)pos->second->max_stack() / (float)pos->second->stack_size()) * 100.0);
+        }
+    }
+}
\ No newline at end of file