Erick / Mbed 2 deprecated ICE_BLE_TEST

Dependencies:   NaturalTinyShell_ice libmDot-12Sept mbed-rtos mbed

Fork of ICE by Erick

src/main.cpp

Committer:
davidjhoward
Date:
2016-09-16
Revision:
69:9e1ff95fd9c5
Parent:
67:49f266601d83
Parent:
68:dbe39d83eb98
Child:
73:3750cc5251e9

File content as of revision 69:9e1ff95fd9c5:

/******************************************************************************
 *
 * File:                main.cpp
 * Desciption:          main ICE driver routine
 *
 *****************************************************************************/
#include "mbed.h"
#include "rtos.h"
#include <stdio.h>
#include "mDot.h"
#include "global.h"
#include "ConfigurationHandler.h"
#include "AnalyticsLogger.h"
#include "ModbusMaster.h"
#include "BLEDataHandler.h"
#include "LoRaInit.h"
#include "ControlTask.h"
#include "OutputTask.h"
#include "CloudDataHandler.h"
#include "rtc.h"

// main thread identifier (for signaling)
osThreadId mainThreadId = NULL;
int sig_continue = 0x1;

// data handler to configuration hanlder mailbox
Mail<Message_t, 16> MailBox;
Mail<Message_t, 16> ModbusMasterMailBox;
Mail<OutputControlMsg_t, 16> OutputMasterMailBox;
Mail<AnalyticsLoggerReq_t, 16> AnalyticsLoggerMailBox;
Mail<CloudDataHandlerReq_t, 16> CloudDataHandlerMailBox;

// local function prototypes
static void banner(void);

// for file system access outside of main()
mDot *GLOBAL_mdot;

Thread *GLOBAL_analyticsLogger_thread = NULL;
Thread *GLOBAL_modbusMaster_thread = NULL;
Thread *GLOBAL_BLE_thread = NULL;
Thread *GLOBAL_CDH_thread = NULL;
Thread *GLOBAL_configHandler_thread = NULL;
Thread *GLOBAL_controlTask_thread = NULL;
Thread *GLOBAL_outputTask_thread = NULL;

// store modbus register information
std::map<std::string,ModbusRegister> ModbusRegisterMap;

I2C i2c_instance(I2C_SDA, I2C_SCL);
I2C* i2c;

/*****************************************************************************
 * Function:            banner()
 * Description:         Display the application boot banner
 *
 * @param               none
 * @return              none
 *****************************************************************************/
static void banner( void )
{
    int iyr=0, imo=0, idy=0, ihr=0, imn=0, isc=0;

    rtc_get_time(&iyr, &imo, &idy, &ihr, &imn, &isc);

    printf("\n\n\r\nWelcome to Project: ICE v0.0.35\n");
    printf("\rThe Intelligent Connected Experience\n");
    printf("\rCopyright 2016 Nalco Water, an Ecolab Company\n");

    printf("\r\t  _____    _____   ______ \n");
    printf("\r\t |_   _|  / ____| |  ____|\n");
    printf("\r\t   | |   | |      | |__   \n");
    printf("\r\t   | |   | |      |  __|  \n");
    printf("\r\t  _| |_  | |____  | |____ \n");
    printf("\r\t |_____|  \\_____| |______|\n");

    printf("\r\nCurrent time is: %04d-%02d-%02d %02d:%02d:%02d\r\n", iyr, imo, idy, ihr, imn, isc);

    printf("\r\n\r\n\r\r\n");
}

/*****************************************************************************
 * Function:            banner()
 * Description:         Display the application boot banner
 *
 * @param               none
 * @return              none
 *****************************************************************************/
int main( void )
{
    mDot *dot;
    struct tm rtc_time;
    time_t curr_sec;
    int year=0;

    // singleton object instatiation
    GLOBAL_mdot = dot = mDot::getInstance();
    mDotRadioInit( dot );

    i2c = &i2c_instance;

    rtc_init();

    rtc_get_time(&year, &rtc_time.tm_mon, &rtc_time.tm_mday, &rtc_time.tm_hour, &rtc_time.tm_min, &rtc_time.tm_sec);
    rtc_time.tm_mon = rtc_time.tm_mon - 1;
    rtc_time.tm_year = year - 1900;
    curr_sec =  mktime( &rtc_time );
    set_time(curr_sec);

    // for signaling from the configuration handler
    mainThreadId = osThreadGetId();

    banner();
    printf("\rMultiTech mDot library version: %s\n", dot->getId().c_str());

    // start the configuration handler
    Thread configHandler_thread(ConfigurationHandler, NULL, osPriorityNormal, 3072, NULL);
    
    Thread outputTask_thread(OutputTask, NULL, osPriorityNormal, 3072, NULL);
    Thread controlTask_thread(ControlTask);

    // wait for the configuration handler to signal us
    osSignalWait(sig_continue, osWaitForever);

    printf("\r%s: continuing to initialize...\n", __func__);

    Thread analyticsLoggerThread(AnalyticsLogger);
    Thread modbusMaster_thread(ModbusMaster, NULL, osPriorityHigh, 10000, NULL);
    Thread BLE_thread(BLEDataHandler);
    Thread CDH_thread(CloudDataHandler, NULL, osPriorityNormal, 8000, NULL);

    // assign globals
    GLOBAL_analyticsLogger_thread = &analyticsLoggerThread;
    GLOBAL_modbusMaster_thread = &modbusMaster_thread;
    GLOBAL_BLE_thread = & BLE_thread;
    GLOBAL_CDH_thread = & CDH_thread;
    GLOBAL_configHandler_thread = &configHandler_thread;
    GLOBAL_controlTask_thread = &controlTask_thread;
    GLOBAL_outputTask_thread = &outputTask_thread;

    Thread::wait(1000);

#if 0 
    // display free memory on the heap
    printf("\r\n");
    __heapstats((__heapprt)fprintf,stdout);
#endif 

    printf("\r\n");
    Thread::wait(1000);
    printf("\r\n");

    // start the command shell
    ntshell_execute(&ntshell, func_read, func_write, func_cb_ntshell);
}