Erick / Mbed 2 deprecated ICE_BLE_TEST

Dependencies:   NaturalTinyShell_ice libmDot-12Sept mbed-rtos mbed

Fork of ICE by Erick

src/main.cpp

Committer:
jmarkel44
Date:
2016-09-13
Revision:
51:66b820f203a5
Parent:
48:1c7861d80d16
Child:
52:e25c857451b6

File content as of revision 51:66b820f203a5:

/******************************************************************************
 *
 * 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"

// 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<OutputControlReq_t, 16> OutputMasterMailBox;

// 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;

/*****************************************************************************
 * Function:            banner()
 * Description:         Display the application boot banner
 *
 * @param               none
 * @return              none
 *****************************************************************************/
static void banner( void )
{
    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\n\r\n\r\r\n");
}

/*****************************************************************************
 * Function:            banner()
 * Description:         Display the application boot banner
 *
 * @param               none
 * @return              none
 *****************************************************************************/
int main( void )
{
    mDot *dot;
    
    // singleton object instatiation 
    GLOBAL_mdot = dot = mDot::getInstance();
    mDotRadioInit( dot );

    // 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);
    Thread BLE_thread(BLEDataHandler);
    Thread CDH_thread(CloudDataHandler, NULL, osPriorityNormal, 6000, 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);

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

    printf("\r\n");
    Thread::wait(1000);
    printf("\r\n");
    
    // start the command shell
    ntshell_execute(&ntshell, func_read, func_write, func_cb_ntshell);
}