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
src/main.cpp@109:bb4ef6a4bd0a, 2016-09-22 (annotated)
- Committer:
- jmarkel44
- Date:
- Thu Sep 22 14:47:35 2016 +0000
- Revision:
- 109:bb4ef6a4bd0a
- Parent:
- 103:109fba818301
- Child:
- 151:9d47fe5ba805
- Child:
- 159:18c54339ee7f
changed 'cat' to allcoate on file size;
Who changed what in which revision?
User | Revision | Line number | New contents of line |
---|---|---|---|
jmarkel44 | 0:65cfa4873284 | 1 | /****************************************************************************** |
jmarkel44 | 3:8ea4db957749 | 2 | * |
jmarkel44 | 0:65cfa4873284 | 3 | * File: main.cpp |
jmarkel44 | 103:109fba818301 | 4 | * Desciption: Ground Zero |
jmarkel44 | 0:65cfa4873284 | 5 | * |
jmarkel44 | 0:65cfa4873284 | 6 | *****************************************************************************/ |
jmarkel44 | 0:65cfa4873284 | 7 | #include "mbed.h" |
jmarkel44 | 0:65cfa4873284 | 8 | #include "rtos.h" |
jmarkel44 | 0:65cfa4873284 | 9 | #include <stdio.h> |
jmarkel44 | 0:65cfa4873284 | 10 | #include "mDot.h" |
jmarkel44 | 0:65cfa4873284 | 11 | #include "global.h" |
jmarkel44 | 0:65cfa4873284 | 12 | #include "ConfigurationHandler.h" |
jmarkel44 | 0:65cfa4873284 | 13 | #include "AnalyticsLogger.h" |
jmarkel44 | 0:65cfa4873284 | 14 | #include "ModbusMaster.h" |
jmarkel44 | 0:65cfa4873284 | 15 | #include "BLEDataHandler.h" |
davidjhoward | 16:7f6599312962 | 16 | #include "LoRaInit.h" |
jmarkel44 | 20:653923c2f37a | 17 | #include "ControlTask.h" |
jmarkel44 | 48:1c7861d80d16 | 18 | #include "OutputTask.h" |
jmarkel44 | 20:653923c2f37a | 19 | #include "CloudDataHandler.h" |
davidjhoward | 59:c68c5bc9d077 | 20 | #include "rtc.h" |
jmarkel44 | 0:65cfa4873284 | 21 | |
jmarkel44 | 0:65cfa4873284 | 22 | // main thread identifier (for signaling) |
jmarkel44 | 0:65cfa4873284 | 23 | osThreadId mainThreadId = NULL; |
jmarkel44 | 75:96512ccc0443 | 24 | |
jmarkel44 | 103:109fba818301 | 25 | // bootup sequence signals |
jmarkel44 | 75:96512ccc0443 | 26 | int sig_output_continue = 0x1; |
jmarkel44 | 75:96512ccc0443 | 27 | int sig_config_continue = 0x2; |
jmarkel44 | 0:65cfa4873284 | 28 | |
jmarkel44 | 0:65cfa4873284 | 29 | // data handler to configuration hanlder mailbox |
jmarkel44 | 0:65cfa4873284 | 30 | Mail<Message_t, 16> MailBox; |
davidjhoward | 31:4b1587034318 | 31 | Mail<Message_t, 16> ModbusMasterMailBox; |
jmarkel44 | 65:be025ac18fb5 | 32 | Mail<OutputControlMsg_t, 16> OutputMasterMailBox; |
davidjhoward | 58:a4422d19b2ea | 33 | Mail<AnalyticsLoggerReq_t, 16> AnalyticsLoggerMailBox; |
jmarkel44 | 0:65cfa4873284 | 34 | |
jmarkel44 | 0:65cfa4873284 | 35 | // local function prototypes |
jmarkel44 | 0:65cfa4873284 | 36 | static void banner(void); |
jmarkel44 | 0:65cfa4873284 | 37 | |
jmarkel44 | 77:43e0a3d9e536 | 38 | // for object (singleton) access outside of main() |
jmarkel44 | 13:c80c283f9db2 | 39 | mDot *GLOBAL_mdot; |
jmarkel44 | 13:c80c283f9db2 | 40 | |
jmarkel44 | 34:f345fdec711d | 41 | Thread *GLOBAL_analyticsLogger_thread = NULL; |
jmarkel44 | 34:f345fdec711d | 42 | Thread *GLOBAL_modbusMaster_thread = NULL; |
jmarkel44 | 34:f345fdec711d | 43 | Thread *GLOBAL_BLE_thread = NULL; |
jmarkel44 | 34:f345fdec711d | 44 | Thread *GLOBAL_CDH_thread = NULL; |
jmarkel44 | 34:f345fdec711d | 45 | Thread *GLOBAL_configHandler_thread = NULL; |
jmarkel44 | 34:f345fdec711d | 46 | Thread *GLOBAL_controlTask_thread = NULL; |
jmarkel44 | 48:1c7861d80d16 | 47 | Thread *GLOBAL_outputTask_thread = NULL; |
jmarkel44 | 34:f345fdec711d | 48 | |
jmarkel44 | 13:c80c283f9db2 | 49 | // store modbus register information |
jmarkel44 | 13:c80c283f9db2 | 50 | std::map<std::string,ModbusRegister> ModbusRegisterMap; |
davidjhoward | 82:f3e495a98877 | 51 | std::map<std::string,SimulateInput> SimulateInputMap; |
davidjhoward | 7:c0c03193612d | 52 | |
davidjhoward | 58:a4422d19b2ea | 53 | I2C i2c_instance(I2C_SDA, I2C_SCL); |
davidjhoward | 58:a4422d19b2ea | 54 | I2C* i2c; |
davidjhoward | 58:a4422d19b2ea | 55 | |
jmarkel44 | 0:65cfa4873284 | 56 | /***************************************************************************** |
jmarkel44 | 103:109fba818301 | 57 | * Function: timestamp_boot_record() |
jmarkel44 | 103:109fba818301 | 58 | * Description: timestamp the boot record with current time |
jmarkel44 | 103:109fba818301 | 59 | * |
jmarkel44 | 103:109fba818301 | 60 | * @param none |
jmarkel44 | 103:109fba818301 | 61 | * @return none |
jmarkel44 | 103:109fba818301 | 62 | *****************************************************************************/ |
jmarkel44 | 103:109fba818301 | 63 | static void timestamp_boot_record(void) |
jmarkel44 | 103:109fba818301 | 64 | { |
jmarkel44 | 109:bb4ef6a4bd0a | 65 | char time_string[80]; |
jmarkel44 | 103:109fba818301 | 66 | time_t curr_sec; |
jmarkel44 | 103:109fba818301 | 67 | struct tm *ts; |
jmarkel44 | 103:109fba818301 | 68 | |
jmarkel44 | 103:109fba818301 | 69 | curr_sec = time(0); |
jmarkel44 | 103:109fba818301 | 70 | ts = localtime(&curr_sec); |
jmarkel44 | 103:109fba818301 | 71 | strftime(time_string, sizeof(time_string), "%Y-%m-%d %H:%M:%S", ts); |
jmarkel44 | 103:109fba818301 | 72 | |
jmarkel44 | 103:109fba818301 | 73 | // see if we can open the boot record |
jmarkel44 | 103:109fba818301 | 74 | mDot::mdot_file file = GLOBAL_mdot->openUserFile("boot.time", mDot::FM_RDWR); |
jmarkel44 | 103:109fba818301 | 75 | if ( file.fd < 0 ) { |
jmarkel44 | 103:109fba818301 | 76 | file = GLOBAL_mdot->openUserFile("boot.time", mDot::FM_CREAT|mDot::FM_RDWR); |
jmarkel44 | 103:109fba818301 | 77 | GLOBAL_mdot->writeUserFile(file, time_string, sizeof(time_string)); |
jmarkel44 | 103:109fba818301 | 78 | } else { |
jmarkel44 | 103:109fba818301 | 79 | GLOBAL_mdot->seekUserFile(file, 0, SEEK_CUR); |
jmarkel44 | 103:109fba818301 | 80 | GLOBAL_mdot->writeUserFile(file, time_string, sizeof(time_string)); |
jmarkel44 | 103:109fba818301 | 81 | } |
jmarkel44 | 103:109fba818301 | 82 | GLOBAL_mdot->closeUserFile(file); |
jmarkel44 | 103:109fba818301 | 83 | return; |
jmarkel44 | 103:109fba818301 | 84 | } |
jmarkel44 | 103:109fba818301 | 85 | |
jmarkel44 | 103:109fba818301 | 86 | /***************************************************************************** |
jmarkel44 | 0:65cfa4873284 | 87 | * Function: banner() |
jmarkel44 | 0:65cfa4873284 | 88 | * Description: Display the application boot banner |
jmarkel44 | 0:65cfa4873284 | 89 | * |
jmarkel44 | 0:65cfa4873284 | 90 | * @param none |
jmarkel44 | 0:65cfa4873284 | 91 | * @return none |
jmarkel44 | 0:65cfa4873284 | 92 | *****************************************************************************/ |
jmarkel44 | 0:65cfa4873284 | 93 | static void banner( void ) |
jmarkel44 | 0:65cfa4873284 | 94 | { |
davidjhoward | 101:8a25782572a3 | 95 | struct tm *ts; |
davidjhoward | 101:8a25782572a3 | 96 | time_t curr_sec; |
davidjhoward | 101:8a25782572a3 | 97 | char time_string[80]; |
davidjhoward | 59:c68c5bc9d077 | 98 | |
davidjhoward | 101:8a25782572a3 | 99 | curr_sec = time(0); |
davidjhoward | 101:8a25782572a3 | 100 | ts = localtime(&curr_sec); |
davidjhoward | 101:8a25782572a3 | 101 | strftime(time_string, sizeof(time_string), "%Y-%m-%d %H:%M:%S", ts); |
davidjhoward | 60:96e17fb215a6 | 102 | |
jmarkel44 | 75:96512ccc0443 | 103 | printf("\n\n\r\nWelcome to Project: ICE v0.0.69\n"); |
jmarkel44 | 0:65cfa4873284 | 104 | printf("\rThe Intelligent Connected Experience\n"); |
jmarkel44 | 0:65cfa4873284 | 105 | printf("\rCopyright 2016 Nalco Water, an Ecolab Company\n"); |
jmarkel44 | 0:65cfa4873284 | 106 | |
jmarkel44 | 0:65cfa4873284 | 107 | printf("\r\t _____ _____ ______ \n"); |
jmarkel44 | 0:65cfa4873284 | 108 | printf("\r\t |_ _| / ____| | ____|\n"); |
jmarkel44 | 0:65cfa4873284 | 109 | printf("\r\t | | | | | |__ \n"); |
jmarkel44 | 0:65cfa4873284 | 110 | printf("\r\t | | | | | __| \n"); |
jmarkel44 | 0:65cfa4873284 | 111 | printf("\r\t _| |_ | |____ | |____ \n"); |
jmarkel44 | 0:65cfa4873284 | 112 | printf("\r\t |_____| \\_____| |______|\n"); |
davidjhoward | 60:96e17fb215a6 | 113 | |
davidjhoward | 101:8a25782572a3 | 114 | printf("\r\nCurrent time is: %s\r\n", time_string); |
jmarkel44 | 0:65cfa4873284 | 115 | |
jmarkel44 | 75:96512ccc0443 | 116 | printf("\r\n\r\n\r\n"); |
jmarkel44 | 75:96512ccc0443 | 117 | printf("\rMultiTech mDot library version: %s\n", GLOBAL_mdot->getId().c_str()); |
jmarkel44 | 75:96512ccc0443 | 118 | |
jmarkel44 | 0:65cfa4873284 | 119 | } |
jmarkel44 | 0:65cfa4873284 | 120 | |
jmarkel44 | 0:65cfa4873284 | 121 | /***************************************************************************** |
jmarkel44 | 0:65cfa4873284 | 122 | * Function: banner() |
jmarkel44 | 0:65cfa4873284 | 123 | * Description: Display the application boot banner |
jmarkel44 | 0:65cfa4873284 | 124 | * |
jmarkel44 | 0:65cfa4873284 | 125 | * @param none |
jmarkel44 | 0:65cfa4873284 | 126 | * @return none |
jmarkel44 | 0:65cfa4873284 | 127 | *****************************************************************************/ |
jmarkel44 | 0:65cfa4873284 | 128 | int main( void ) |
jmarkel44 | 0:65cfa4873284 | 129 | { |
jmarkel44 | 0:65cfa4873284 | 130 | mDot *dot; |
davidjhoward | 101:8a25782572a3 | 131 | struct tm rtc_time; |
davidjhoward | 101:8a25782572a3 | 132 | time_t curr_sec; |
davidjhoward | 101:8a25782572a3 | 133 | int year=0; |
davidjhoward | 60:96e17fb215a6 | 134 | |
davidjhoward | 60:96e17fb215a6 | 135 | // singleton object instatiation |
davidjhoward | 21:85c69494c0ff | 136 | GLOBAL_mdot = dot = mDot::getInstance(); |
davidjhoward | 21:85c69494c0ff | 137 | mDotRadioInit( dot ); |
davidjhoward | 60:96e17fb215a6 | 138 | |
davidjhoward | 58:a4422d19b2ea | 139 | i2c = &i2c_instance; |
davidjhoward | 60:96e17fb215a6 | 140 | |
davidjhoward | 101:8a25782572a3 | 141 | rtc_init(); |
davidjhoward | 101:8a25782572a3 | 142 | |
davidjhoward | 60:96e17fb215a6 | 143 | rtc_get_time(&year, &rtc_time.tm_mon, &rtc_time.tm_mday, &rtc_time.tm_hour, &rtc_time.tm_min, &rtc_time.tm_sec); |
davidjhoward | 60:96e17fb215a6 | 144 | rtc_time.tm_mon = rtc_time.tm_mon - 1; |
davidjhoward | 60:96e17fb215a6 | 145 | rtc_time.tm_year = year - 1900; |
davidjhoward | 60:96e17fb215a6 | 146 | curr_sec = mktime( &rtc_time ); |
davidjhoward | 101:8a25782572a3 | 147 | |
davidjhoward | 101:8a25782572a3 | 148 | set_time(curr_sec); |
jmarkel44 | 103:109fba818301 | 149 | timestamp_boot_record(); |
davidjhoward | 60:96e17fb215a6 | 150 | |
jmarkel44 | 13:c80c283f9db2 | 151 | // for signaling from the configuration handler |
jmarkel44 | 0:65cfa4873284 | 152 | mainThreadId = osThreadGetId(); |
jmarkel44 | 3:8ea4db957749 | 153 | |
jmarkel44 | 0:65cfa4873284 | 154 | banner(); |
jmarkel44 | 103:109fba818301 | 155 | |
jmarkel44 | 103:109fba818301 | 156 | // start the output task |
jmarkel44 | 77:43e0a3d9e536 | 157 | Thread outputTask_thread(OutputTask, NULL, osPriorityNormal, (1024*8), NULL); |
jmarkel44 | 75:96512ccc0443 | 158 | osSignalWait(sig_output_continue, osWaitForever); |
jmarkel44 | 103:109fba818301 | 159 | |
jmarkel44 | 3:8ea4db957749 | 160 | // start the configuration handler |
jmarkel44 | 71:34856d21f2bf | 161 | Thread configHandler_thread(ConfigurationHandler, NULL, osPriorityNormal, (1024*3), NULL); |
jmarkel44 | 75:96512ccc0443 | 162 | osSignalWait(sig_config_continue, osWaitForever); |
jmarkel44 | 3:8ea4db957749 | 163 | |
jmarkel44 | 103:109fba818301 | 164 | // we're clear to start running the controls |
jmarkel44 | 77:43e0a3d9e536 | 165 | Thread controlTask_thread(ControlTask, NULL, osPriorityNormal, (1024*2), NULL); |
jmarkel44 | 75:96512ccc0443 | 166 | //printf("\r%s: continuing to initialize...\n", __func__); |
jmarkel44 | 3:8ea4db957749 | 167 | |
jmarkel44 | 34:f345fdec711d | 168 | Thread analyticsLoggerThread(AnalyticsLogger); |
jmarkel44 | 71:34856d21f2bf | 169 | Thread modbusMaster_thread(ModbusMaster, NULL, osPriorityHigh, (1024*10), NULL); |
jmarkel44 | 3:8ea4db957749 | 170 | Thread BLE_thread(BLEDataHandler); |
jmarkel44 | 71:34856d21f2bf | 171 | Thread CDH_thread(CloudDataHandler, NULL, osPriorityNormal, (1024*8), NULL); |
davidjhoward | 60:96e17fb215a6 | 172 | |
davidjhoward | 60:96e17fb215a6 | 173 | // assign globals |
jmarkel44 | 34:f345fdec711d | 174 | GLOBAL_analyticsLogger_thread = &analyticsLoggerThread; |
jmarkel44 | 34:f345fdec711d | 175 | GLOBAL_modbusMaster_thread = &modbusMaster_thread; |
jmarkel44 | 34:f345fdec711d | 176 | GLOBAL_BLE_thread = & BLE_thread; |
jmarkel44 | 34:f345fdec711d | 177 | GLOBAL_CDH_thread = & CDH_thread; |
jmarkel44 | 34:f345fdec711d | 178 | GLOBAL_configHandler_thread = &configHandler_thread; |
jmarkel44 | 34:f345fdec711d | 179 | GLOBAL_controlTask_thread = &controlTask_thread; |
jmarkel44 | 48:1c7861d80d16 | 180 | GLOBAL_outputTask_thread = &outputTask_thread; |
jmarkel44 | 3:8ea4db957749 | 181 | |
jmarkel44 | 1:057d8fc6cb2f | 182 | Thread::wait(1000); |
jmarkel44 | 0:65cfa4873284 | 183 | printf("\r\n"); |
davidjhoward | 60:96e17fb215a6 | 184 | |
jmarkel44 | 3:8ea4db957749 | 185 | // start the command shell |
jmarkel44 | 0:65cfa4873284 | 186 | ntshell_execute(&ntshell, func_read, func_write, func_cb_ntshell); |
jmarkel44 | 3:8ea4db957749 | 187 | } |