Radu-Adrian Marcu / Mbed OS SOFT253_GroupA_AssignmentRepo

3rd Repo, trying to figure this out.

Dependencies:   LPS25H hts221

Fork of SOFT253_Template_Weather_OS_54 by Stage-1 Students SoCEM

main.cpp@85:422d0a1b95cf, 2017-05-13 (annotated)

Committer:
niallfrancis
Date:
Sat May 13 17:35:58 2017 +0000
Revision:
85:422d0a1b95cf
Parent:
83:0d3572a8a851 
Finished commenting classes;

Who changed what in which revision?

UserRevisionLine numberNew contents of line
Jonathan Austin 0:2757d7abb7d9 1 #include "mbed.h"
martinsimpson 32:260a288be58f 2 #include "rtos.h"
aburch1 74:749727490f44 3 #include "hts221.h"
aburch1 74:749727490f44 4 #include "LPS25H.h"
aburch1 74:749727490f44 5
aburch1 81:996c0a3319b4 6 #include "MessageLogger.h"
aburch1 74:749727490f44 7 #include "CircularArray.h"
aburch1 74:749727490f44 8 #include "FakeSensor.h"
aburch1 74:749727490f44 9
FairyMental 43:3983059e0d91 10 #include <string.h>
FairyMental 34:09ed07f2acba 11 #include <stdio.h>
FairyMental 34:09ed07f2acba 12 #include <ctype.h>
FairyMental 41:d222c043c96d 13 #include <iostream>
aburch1 74:749727490f44 14 #include <sstream>
martinsimpson 32:260a288be58f 15
FairyMental 36:19d3f752f9c3 16 #define SIGNAL_doMeasure 1
aburch1 75:b44645bbf2d2 17 #define SIGNAL_printMessage 2
aburch1 81:996c0a3319b4 18 #define SIGNAL_terminate 3
FairyMental 36:19d3f752f9c3 19 #define SWITCH1_RELEASE 90
Netaphous 65:3723d2729b68 20 #define BUFFER_SIZE 120
FairyMental 34:09ed07f2acba 21
aburch1 83:0d3572a8a851 22 /**
aburch1 83:0d3572a8a851 23 @file : main.cpp
aburch1 83:0d3572a8a851 24 @authors : Radu Marcu, Jacob Williams, Niall Francis, Arron Burch
aburch1 83:0d3572a8a851 25
aburch1 83:0d3572a8a851 26 @section DESCRIPTION
aburch1 83:0d3572a8a851 27
aburch1 83:0d3572a8a851 28 This is the main class where the program runs on startup, this is
aburch1 83:0d3572a8a851 29 a multi-threaded application that will that make the ST F401 Nucleo Target board
aburch1 83:0d3572a8a851 30 take periodic measurements of senor data, including temperature,
aburch1 83:0d3572a8a851 31 pressure and humidity, at a fixed set sample rate. A max of 120 measurements are stored
aburch1 83:0d3572a8a851 32 within RAM at any one time, available to be printed to a termial output via a serial port
aburch1 83:0d3572a8a851 33 connection.
aburch1 83:0d3572a8a851 34 Once 120 measurements are stored, the oldest measurements are overwritten using a circular
aburch1 83:0d3572a8a851 35 buffer, so that the most recent 120 measurements can always be stored on the device.
aburch1 83:0d3572a8a851 36 The application can provide logging data when measurements are taken if logging is turned
aburch1 83:0d3572a8a851 37 on using the logging command (See readme.md).
aburch1 83:0d3572a8a851 38 The application has been written to reduce power consumption where possible by utilising
aburch1 83:0d3572a8a851 39 Thread signals and sleeping when not in use.
aburch1 83:0d3572a8a851 40 Serial Communications are handled within a sepearate thread to ensure that no action will
aburch1 83:0d3572a8a851 41 block or interrupt the CPU when measuring samples.
aburch1 83:0d3572a8a851 42 The serial communications use a priority system, allowing errors to be printed with a higher
aburch1 83:0d3572a8a851 43 priority than logging messages and the application to be terminated and reset by user input
aburch1 83:0d3572a8a851 44 if required.
aburch1 83:0d3572a8a851 45 */
aburch1 83:0d3572a8a851 46
FairyMental 57:dfcdda1e42b6 47 //
FairyMental 57:dfcdda1e42b6 48 // MBED DECLARATIONS
FairyMental 57:dfcdda1e42b6 49 //
martinsimpson 32:260a288be58f 50 DigitalOut myled(LED1);
Netaphous 50:c07e968b9582 51 DigitalIn onBoardSwitch(USER_BUTTON);
martinsimpson 32:260a288be58f 52 I2C i2c2(I2C_SDA, I2C_SCL);
Netaphous 50:c07e968b9582 53
FairyMental 57:dfcdda1e42b6 54 //
FairyMental 57:dfcdda1e42b6 55 // SENSOR DECLARATIONS
Netaphous 50:c07e968b9582 56 // MAKE SURE ONE OF THESE IS COMMENTED OUT
Netaphous 50:c07e968b9582 57 // Real sensor
aburch1 83:0d3572a8a851 58 LPS25H barometer(i2c2, LPS25H_V_CHIP_ADDR);
aburch1 83:0d3572a8a851 59 HTS221 measurer(I2C_SDA, I2C_SCL);
Netaphous 50:c07e968b9582 60 // Fake sensor
aburch1 83:0d3572a8a851 61 // FakeBarometer barometer(1029.0, 1031.0);
aburch1 83:0d3572a8a851 62 // FakeMeasurer measurer(20.0, 25.0, 30.0, 50.0);
Netaphous 50:c07e968b9582 63
FairyMental 57:dfcdda1e42b6 64 //
FairyMental 57:dfcdda1e42b6 65 // THREADS DECLARATION
FairyMental 57:dfcdda1e42b6 66 //
aburch1 82:668b51a39148 67 osThreadId mainThreadId;
aburch1 83:0d3572a8a851 68 Thread *producerThread;
aburch1 83:0d3572a8a851 69 Thread *measurementThread;
aburch1 83:0d3572a8a851 70 Thread *consumerThread;
aburch1 74:749727490f44 71 Thread *loggingThread;
FairyMental 58:7fc6e3e4d746 72 Ticker timer;
FairyMental 58:7fc6e3e4d746 73 Ticker realTimeDate;
FairyMental 57:dfcdda1e42b6 74 //
FairyMental 57:dfcdda1e42b6 75 // GLOBAL VARIABLES
FairyMental 57:dfcdda1e42b6 76 //
FairyMental 34:09ed07f2acba 77 Mail<Measure, 16> mail_box;
FairyMental 46:0de1f3c7d118 78 LocalDate *localDate;
aburch1 82:668b51a39148 79 bool logging = false;
aburch1 82:668b51a39148 80 bool measuring = true;
aburch1 81:996c0a3319b4 81 double sampleRate = 15;
aburch1 81:996c0a3319b4 82 char temp[256];
FairyMental 49:83bea7fb2728 83
aburch1 74:749727490f44 84 // Logging objects
aburch1 75:b44645bbf2d2 85 MessageLogger logger;
aburch1 74:749727490f44 86
aburch1 81:996c0a3319b4 87 CircularArray buffer(BUFFER_SIZE, &logger);
FairyMental 57:dfcdda1e42b6 88 //
aburch1 83:0d3572a8a851 89 // Called by a ticker
FairyMental 57:dfcdda1e42b6 90 // Adds 1 second every second to the clock
aburch1 83:0d3572a8a851 91 //
FairyMental 46:0de1f3c7d118 92 void RealTimeDate()
FairyMental 46:0de1f3c7d118 93 {
FairyMental 46:0de1f3c7d118 94 localDate->TickSecond();
FairyMental 46:0de1f3c7d118 95 }
FairyMental 58:7fc6e3e4d746 96
FairyMental 58:7fc6e3e4d746 97 //
FairyMental 58:7fc6e3e4d746 98 // Ticker that signals the measureThread to do a measure
FairyMental 58:7fc6e3e4d746 99 //
FairyMental 58:7fc6e3e4d746 100 void SendSignalDoMeasure()
aburch1 82:668b51a39148 101 {
aburch1 83:0d3572a8a851 102 measurementThread->signal_set(SIGNAL_doMeasure);
FairyMental 58:7fc6e3e4d746 103 }
FairyMental 58:7fc6e3e4d746 104
FairyMental 57:dfcdda1e42b6 105 //
aburch1 83:0d3572a8a851 106 // Called by ticker every T seconds
aburch1 83:0d3572a8a851 107 // Reads values from sensor board, sends between threads using a mail queue
aburch1 83:0d3572a8a851 108 //
aburch1 83:0d3572a8a851 109 void MeasurementThread()
aburch1 79:4e6b53eb678b 110 {
aburch1 82:668b51a39148 111 float temperature , humidity, pressure;
FairyMental 35:484e384f9bf1 112
FairyMental 36:19d3f752f9c3 113 while(true)
FairyMental 36:19d3f752f9c3 114 {
aburch1 79:4e6b53eb678b 115 temperature = 0;
aburch1 79:4e6b53eb678b 116 humidity = 0;
aburch1 79:4e6b53eb678b 117 pressure = 0;
aburch1 83:0d3572a8a851 118
FairyMental 36:19d3f752f9c3 119 Thread::signal_wait(SIGNAL_doMeasure);
FairyMental 57:dfcdda1e42b6 120
FairyMental 36:19d3f752f9c3 121 Measure *measure = mail_box.alloc();
FairyMental 36:19d3f752f9c3 122 if (measure == NULL)
FairyMental 36:19d3f752f9c3 123 {
aburch1 82:668b51a39148 124 logger.SendError("Out of memory\r\n");
FairyMental 36:19d3f752f9c3 125 return;
FairyMental 36:19d3f752f9c3 126 }
FairyMental 34:09ed07f2acba 127
aburch1 83:0d3572a8a851 128 //Read data from measurer, puts data into a measure object.
FairyMental 36:19d3f752f9c3 129 measurer.ReadTempHumi(&temperature,&humidity);
FairyMental 36:19d3f752f9c3 130 barometer.get();
FairyMental 36:19d3f752f9c3 131 pressure = barometer.pressure();
FairyMental 47:468a89d62c23 132
FairyMental 36:19d3f752f9c3 133 measure->temperature = temperature;
FairyMental 36:19d3f752f9c3 134 measure->humidity = humidity;
FairyMental 36:19d3f752f9c3 135 measure->pressure = pressure;
Netaphous 67:8d0e88172e2a 136 measure->date.setValues(localDate);
FairyMental 36:19d3f752f9c3 137
FairyMental 57:dfcdda1e42b6 138 osStatus stat = mail_box.put(measure);
martinsimpson 32:260a288be58f 139
aburch1 83:0d3572a8a851 140 // Check if mailbox allocation was unsuccessful
aburch1 83:0d3572a8a851 141 if (stat == osErrorResource)
aburch1 83:0d3572a8a851 142 {
aburch1 81:996c0a3319b4 143 snprintf(temp, 256, "queue->put() Error code: %4Xh, Resource not available\r\n", stat);
aburch1 81:996c0a3319b4 144 logger.SendError(temp);
FairyMental 36:19d3f752f9c3 145 mail_box.free(measure);
FairyMental 36:19d3f752f9c3 146 return;
FairyMental 36:19d3f752f9c3 147 }
aburch1 82:668b51a39148 148
aburch1 83:0d3572a8a851 149 // Print measurement taken if logging is enabled
aburch1 82:668b51a39148 150 if(logging)
aburch1 82:668b51a39148 151 {
aburch1 82:668b51a39148 152 logger.SendMessage("Measurement Taken:\r\n");
aburch1 82:668b51a39148 153 char *ptr = localDate->ToString();
aburch1 83:0d3572a8a851 154 snprintf(temp, 256, " %s T: %f, H: %f, P: %f\n\r",ptr, temperature, humidity, pressure);
aburch1 82:668b51a39148 155 logger.SendMessage(temp);
aburch1 82:668b51a39148 156 }
FairyMental 34:09ed07f2acba 157 }
FairyMental 34:09ed07f2acba 158 }
FairyMental 34:09ed07f2acba 159
FairyMental 57:dfcdda1e42b6 160 //
aburch1 83:0d3572a8a851 161 // Receives data through mail queue, then adds it to the circular array buffer.
aburch1 83:0d3572a8a851 162 //
FairyMental 37:00775e368a71 163 void ProducerThread()
FairyMental 34:09ed07f2acba 164 {
FairyMental 57:dfcdda1e42b6 165 while (true)
FairyMental 57:dfcdda1e42b6 166 {
FairyMental 34:09ed07f2acba 167 osEvent evt = mail_box.get();
FairyMental 34:09ed07f2acba 168
aburch1 83:0d3572a8a851 169 // Check if mailbox retrieval was successful
aburch1 83:0d3572a8a851 170 if (evt.status == osEventMail)
aburch1 83:0d3572a8a851 171 {
FairyMental 57:dfcdda1e42b6 172 Measure *measure = (Measure*)evt.value.p;
FairyMental 47:468a89d62c23 173 Measure msr(measure->date,measure->temperature, measure->humidity,measure->pressure);
Netaphous 65:3723d2729b68 174
Netaphous 65:3723d2729b68 175 buffer.pushValue(msr);
FairyMental 34:09ed07f2acba 176 mail_box.free(measure);
aburch1 83:0d3572a8a851 177 }
aburch1 83:0d3572a8a851 178 else
aburch1 83:0d3572a8a851 179 {
aburch1 82:668b51a39148 180 snprintf(temp, 256, "ERROR: %x\r\n", evt.status);
aburch1 81:996c0a3319b4 181 logger.SendError(temp);
aburch1 83:0d3572a8a851 182 }
FairyMental 57:dfcdda1e42b6 183 }
FairyMental 34:09ed07f2acba 184 }
aburch1 83:0d3572a8a851 185
Netaphous 69:72f237750d85 186 int i;
niallfrancis 85:422d0a1b95cf 187
aburch1 83:0d3572a8a851 188 /**
aburch1 83:0d3572a8a851 189 Compares two char arrays and returns result
aburch1 83:0d3572a8a851 190
aburch1 83:0d3572a8a851 191 @param command : First char Array / pointer
aburch1 83:0d3572a8a851 192 @param targetCommand : Second char Array / pointer
aburch1 83:0d3572a8a851 193 @param size : Size of the smallest char arrays (between param1 and param2)
aburch1 83:0d3572a8a851 194 @return : TRUE if equal, FALSE if not equal
aburch1 83:0d3572a8a851 195 */
aburch1 83:0d3572a8a851 196 bool CompareCommands(char command[],char targetCommand[], int size)
FairyMental 42:b1f29874ab70 197 {
aburch1 83:0d3572a8a851 198 for(i = 0; i < size; i ++)
aburch1 83:0d3572a8a851 199 {
aburch1 83:0d3572a8a851 200 if(command[i] != targetCommand[i])
aburch1 83:0d3572a8a851 201 {
aburch1 83:0d3572a8a851 202 return false;
FairyMental 42:b1f29874ab70 203 }
aburch1 83:0d3572a8a851 204 }
aburch1 83:0d3572a8a851 205 return true;
aburch1 83:0d3572a8a851 206 }
aburch1 74:749727490f44 207
aburch1 83:0d3572a8a851 208 /**
aburch1 83:0d3572a8a851 209 Reads commands from the terminal and 'consumes' the data accordingly.
aburch1 83:0d3572a8a851 210 */
aburch1 83:0d3572a8a851 211 void ConsumerThread()
FairyMental 39:618ad21e2b34 212 {
FairyMental 41:d222c043c96d 213 char charCmd;
aburch1 83:0d3572a8a851 214 //Char array that stores the chars entered when user presses enter.
FairyMental 41:d222c043c96d 215 char command[40];
FairyMental 57:dfcdda1e42b6 216 //Current Command Size
aburch1 83:0d3572a8a851 217 int crtSize = 0;
aburch1 81:996c0a3319b4 218 logger.SendMessage("\r\nAwaiting Command: \r\n");
FairyMental 39:618ad21e2b34 219 while(1)
FairyMental 39:618ad21e2b34 220 {
FairyMental 41:d222c043c96d 221 charCmd = NULL;
FairyMental 41:d222c043c96d 222 charCmd = getchar();
aburch1 82:668b51a39148 223 if(logging)
aburch1 82:668b51a39148 224 {
aburch1 82:668b51a39148 225 logging = false;
aburch1 83:0d3572a8a851 226 logger.SendMessage("\rKey Pressed. Debug logging disabled.\r\n");
aburch1 82:668b51a39148 227 charCmd = NULL;
aburch1 82:668b51a39148 228 }
aburch1 80:959151952153 229
FairyMental 41:d222c043c96d 230 if(charCmd != NULL)
FairyMental 41:d222c043c96d 231 {
FairyMental 57:dfcdda1e42b6 232 //If BACKSPACE is pressed, Print "DEL" so it deletes last character typed.
aburch1 83:0d3572a8a851 233 if (charCmd == 127 && crtSize > 0 )
FairyMental 43:3983059e0d91 234 {
aburch1 83:0d3572a8a851 235 command[--crtSize] = '\0';
FairyMental 43:3983059e0d91 236 }
FairyMental 57:dfcdda1e42b6 237 //If NOT enter AND NOT Backspace is pressed, SAVE the char
FairyMental 57:dfcdda1e42b6 238 else if(charCmd != 13 && charCmd != 127)
FairyMental 41:d222c043c96d 239 {
aburch1 83:0d3572a8a851 240 command[crtSize++] = charCmd;
FairyMental 41:d222c043c96d 241 }
aburch1 83:0d3572a8a851 242 // If enter is pressed, process the command.
aburch1 83:0d3572a8a851 243 else if(charCmd == 13)
FairyMental 49:83bea7fb2728 244 {
aburch1 83:0d3572a8a851 245 logger.SendMessage("\n");
aburch1 83:0d3572a8a851 246 // Get first word of command.
FairyMental 43:3983059e0d91 247 char *charPos;
FairyMental 43:3983059e0d91 248 charPos = strtok(command," -,");
FairyMental 57:dfcdda1e42b6 249
aburch1 83:0d3572a8a851 250 // Check if it's a "read" command
aburch1 81:996c0a3319b4 251 if(CompareCommands(charPos, "read",4))
FairyMental 42:b1f29874ab70 252 {
FairyMental 43:3983059e0d91 253 charPos = strtok(NULL," -,");
aburch1 83:0d3572a8a851 254 // Check if it's a "read all" command
aburch1 81:996c0a3319b4 255 if(CompareCommands(charPos, "all",3))
aburch1 82:668b51a39148 256 {
Netaphous 65:3723d2729b68 257 // Changed to use circular buffer rather than list buffer
Netaphous 65:3723d2729b68 258 buffer.readAll();
aburch1 81:996c0a3319b4 259 logger.SendMessage("D O N E ! \r\n");
FairyMental 43:3983059e0d91 260 }
aburch1 83:0d3572a8a851 261 // Check if it's a "read n" command
FairyMental 43:3983059e0d91 262 else if(strtol(charPos,NULL,10) != 0)
FairyMental 43:3983059e0d91 263 {
aburch1 81:996c0a3319b4 264 int num = atoi(charPos);
aburch1 80:959151952153 265
aburch1 83:0d3572a8a851 266 buffer.readN(num);
aburch1 81:996c0a3319b4 267 logger.SendMessage("D O N E ! \r\n");
FairyMental 60:db8c5b7fc548 268 }
FairyMental 60:db8c5b7fc548 269 else
FairyMental 60:db8c5b7fc548 270 {
aburch1 81:996c0a3319b4 271 logger.SendMessage("Expected parameters: \"all\" | \"n\", where n is a number.\r\n");
FairyMental 43:3983059e0d91 272 }
FairyMental 42:b1f29874ab70 273 }
aburch1 83:0d3572a8a851 274 // Check if it's a "delete" command
aburch1 81:996c0a3319b4 275 else if (CompareCommands(charPos,"delete",6))
FairyMental 44:b523c9a9dd97 276 {
FairyMental 44:b523c9a9dd97 277 charPos = strtok(NULL," -,");
aburch1 83:0d3572a8a851 278 // Check if it's a "delete all" command
aburch1 81:996c0a3319b4 279 if(CompareCommands(charPos,"all",3))
FairyMental 44:b523c9a9dd97 280 {
aburch1 81:996c0a3319b4 281 logger.SendMessage("Deleting all measures performed so far: \r\n");
Netaphous 65:3723d2729b68 282
Netaphous 65:3723d2729b68 283 buffer.deleteAll();
FairyMental 44:b523c9a9dd97 284 }
aburch1 83:0d3572a8a851 285 // Check if it's a "delete n" command
FairyMental 44:b523c9a9dd97 286 else if (strtol(charPos,NULL,10) != 0)
FairyMental 44:b523c9a9dd97 287 {
Netaphous 65:3723d2729b68 288 // Changed to use circular buffer rather than list buffer
aburch1 83:0d3572a8a851 289 buffer.deleteN(atoi(charPos));
aburch1 81:996c0a3319b4 290 logger.SendMessage("Elements deleted!\r\n");
FairyMental 60:db8c5b7fc548 291 }
FairyMental 60:db8c5b7fc548 292 else
FairyMental 60:db8c5b7fc548 293 {
aburch1 81:996c0a3319b4 294 logger.SendMessage("Expected parameters: \"all\" | \"n\", where n is a number.");
aburch1 81:996c0a3319b4 295 }
FairyMental 44:b523c9a9dd97 296 }
aburch1 83:0d3572a8a851 297 // Check if it's a "status" command
aburch1 81:996c0a3319b4 298 else if (CompareCommands(charPos,"status",6))
FairyMental 45:9a33f2bc2b4e 299 {
FairyMental 46:0de1f3c7d118 300 char *ptr = localDate->ToString();
Netaphous 65:3723d2729b68 301
aburch1 82:668b51a39148 302 snprintf(temp, 256, "\nStatus: \r\n");
aburch1 82:668b51a39148 303 logger.SendMessage(temp);
aburch1 82:668b51a39148 304 snprintf(temp, 256, " # of measures: %i \r\n", buffer.getSize());
aburch1 82:668b51a39148 305 logger.SendMessage(temp);
aburch1 82:668b51a39148 306 snprintf(temp, 256, " Sampling: %s \r\n", measuring ? "On" : "Off");
aburch1 82:668b51a39148 307 logger.SendMessage(temp);
aburch1 82:668b51a39148 308 snprintf(temp, 256, " Logging: %s \r\n", logging ? "On" : "Off");
aburch1 82:668b51a39148 309 logger.SendMessage(temp);
aburch1 82:668b51a39148 310 snprintf(temp, 256, " Current Date: %s \r\n", ptr);
aburch1 82:668b51a39148 311 logger.SendMessage(temp);
aburch1 82:668b51a39148 312 snprintf(temp, 256, " Sample Rate(s): %2.2f \r\n", sampleRate);
aburch1 81:996c0a3319b4 313 logger.SendMessage(temp);
FairyMental 45:9a33f2bc2b4e 314 }
aburch1 83:0d3572a8a851 315 //Check if it's a "settime" command
aburch1 81:996c0a3319b4 316 else if (CompareCommands(charPos,"settime",7))
FairyMental 48:a8219954b3f2 317 {
FairyMental 48:a8219954b3f2 318 int h,m,s;
aburch1 83:0d3572a8a851 319
aburch1 81:996c0a3319b4 320 charPos = strtok(NULL," -,");
FairyMental 48:a8219954b3f2 321 if(strtol(charPos,NULL,10) != 0)
FairyMental 48:a8219954b3f2 322 {
FairyMental 48:a8219954b3f2 323 h = atoi(charPos);
FairyMental 48:a8219954b3f2 324 }
aburch1 81:996c0a3319b4 325 charPos = strtok(NULL," -,");
FairyMental 48:a8219954b3f2 326 if(strtol(charPos,NULL,10) != 0)
FairyMental 48:a8219954b3f2 327 {
FairyMental 48:a8219954b3f2 328 m = atoi(charPos);
FairyMental 48:a8219954b3f2 329 }
aburch1 81:996c0a3319b4 330 charPos = strtok(NULL," -,");
FairyMental 48:a8219954b3f2 331 if(strtol(charPos,NULL,10) != 0)
FairyMental 48:a8219954b3f2 332 {
FairyMental 48:a8219954b3f2 333 s = atoi(charPos);
FairyMental 48:a8219954b3f2 334 }
FairyMental 48:a8219954b3f2 335 if((h>=0 && h < 24) && (m>=0 && m<60) && (s>=0 && s<60))
FairyMental 48:a8219954b3f2 336 {
FairyMental 48:a8219954b3f2 337 localDate->hour = h;
FairyMental 48:a8219954b3f2 338 localDate->min = m;
FairyMental 48:a8219954b3f2 339 localDate->sec = s;
FairyMental 60:db8c5b7fc548 340 char *ptr = localDate->ToString();
aburch1 81:996c0a3319b4 341 snprintf(temp, 256, "Updated Date to: %s \r\n", ptr);
aburch1 81:996c0a3319b4 342 logger.SendMessage(temp);
FairyMental 48:a8219954b3f2 343 }
FairyMental 48:a8219954b3f2 344 else
FairyMental 48:a8219954b3f2 345 {
aburch1 81:996c0a3319b4 346 logger.SendMessage("\r\nWrong format! please use HH-MM-SS. \r\n");
FairyMental 48:a8219954b3f2 347 }
FairyMental 48:a8219954b3f2 348 }
aburch1 83:0d3572a8a851 349 //Check if it's a "setdate" command
aburch1 81:996c0a3319b4 350 else if (CompareCommands(charPos,"setdate",7))
FairyMental 48:a8219954b3f2 351 {
FairyMental 48:a8219954b3f2 352 int d,m,y;
aburch1 83:0d3572a8a851 353
aburch1 81:996c0a3319b4 354 charPos = strtok(NULL," ,-");
FairyMental 48:a8219954b3f2 355 if(strtol(charPos,NULL,10) != 0)
FairyMental 48:a8219954b3f2 356 {
FairyMental 48:a8219954b3f2 357 d = atoi(charPos);
FairyMental 48:a8219954b3f2 358 }
aburch1 83:0d3572a8a851 359
aburch1 81:996c0a3319b4 360 charPos = strtok(NULL," ,-");
FairyMental 48:a8219954b3f2 361 if(strtol(charPos,NULL,10) != 0)
FairyMental 48:a8219954b3f2 362 {
FairyMental 48:a8219954b3f2 363 m = atoi(charPos);
FairyMental 48:a8219954b3f2 364 }
aburch1 83:0d3572a8a851 365
aburch1 81:996c0a3319b4 366 charPos = strtok(NULL," ,-");
FairyMental 48:a8219954b3f2 367 if(strtol(charPos,NULL,10) != 0)
FairyMental 48:a8219954b3f2 368 {
FairyMental 48:a8219954b3f2 369 y = atoi(charPos);
FairyMental 48:a8219954b3f2 370 }
aburch1 83:0d3572a8a851 371
FairyMental 48:a8219954b3f2 372 if((d>=0 && d < 31) && (m>=0 && m<13))
FairyMental 48:a8219954b3f2 373 {
FairyMental 48:a8219954b3f2 374 localDate->day = d;
FairyMental 48:a8219954b3f2 375 localDate->month = m;
FairyMental 48:a8219954b3f2 376 localDate->year = y;
FairyMental 60:db8c5b7fc548 377 char *ptr = localDate->ToString();
aburch1 81:996c0a3319b4 378 snprintf(temp, 256, "Updated Date to: %s \r\n", ptr);
aburch1 81:996c0a3319b4 379 logger.SendMessage(temp);
FairyMental 48:a8219954b3f2 380 }
FairyMental 48:a8219954b3f2 381 else
FairyMental 48:a8219954b3f2 382 {
aburch1 81:996c0a3319b4 383 logger.SendMessage("Wrong format! please use DD-MM-YYYY. \r\n");
FairyMental 48:a8219954b3f2 384 }
FairyMental 48:a8219954b3f2 385 }
aburch1 83:0d3572a8a851 386 // Check if it's a "state" command
aburch1 81:996c0a3319b4 387 else if(CompareCommands(charPos,"state",5))
FairyMental 49:83bea7fb2728 388 {
FairyMental 49:83bea7fb2728 389 charPos = strtok(NULL," ,");
aburch1 83:0d3572a8a851 390
aburch1 83:0d3572a8a851 391 // Check if it should be turned on / off
aburch1 81:996c0a3319b4 392 if(CompareCommands(charPos,"on",2))
FairyMental 49:83bea7fb2728 393 {
aburch1 83:0d3572a8a851 394 logger.SendMessage("Sampling turned on!\r\n");
aburch1 82:668b51a39148 395 timer.attach(&SendSignalDoMeasure, sampleRate);
aburch1 82:668b51a39148 396 SendSignalDoMeasure();
aburch1 82:668b51a39148 397 measuring = true;
FairyMental 49:83bea7fb2728 398 }
aburch1 81:996c0a3319b4 399 else if (CompareCommands(charPos,"off",3))
FairyMental 49:83bea7fb2728 400 {
aburch1 83:0d3572a8a851 401 logger.SendMessage("Sampling turned off!\r\n");
aburch1 82:668b51a39148 402 timer.detach();
aburch1 82:668b51a39148 403 measuring = false;
aburch1 82:668b51a39148 404 }
aburch1 82:668b51a39148 405 else
aburch1 82:668b51a39148 406 {
aburch1 82:668b51a39148 407 logger.SendMessage("Expected parameters: \"on\" | \"off\"\r\n");
aburch1 82:668b51a39148 408 }
aburch1 82:668b51a39148 409 }
aburch1 83:0d3572a8a851 410 // Check if it's a "logging" command
aburch1 82:668b51a39148 411 else if(CompareCommands(charPos,"logging",7))
aburch1 82:668b51a39148 412 {
aburch1 82:668b51a39148 413 charPos = strtok(NULL," ,");
aburch1 82:668b51a39148 414 //Check if it should be turned ON / OFF
aburch1 82:668b51a39148 415 if(CompareCommands(charPos,"on",2))
aburch1 82:668b51a39148 416 {
aburch1 82:668b51a39148 417 logging = true;
aburch1 83:0d3572a8a851 418 logger.SendMessage("Debug logging turned on!\r\n");
aburch1 82:668b51a39148 419 logger.SendMessage("Press any key to deactivate\r\n");
aburch1 82:668b51a39148 420 }
aburch1 82:668b51a39148 421 else if (CompareCommands(charPos,"off",3))
aburch1 82:668b51a39148 422 {
aburch1 82:668b51a39148 423 logger.SendMessage("Logging is already turned off.\r\n");
FairyMental 60:db8c5b7fc548 424 }
FairyMental 60:db8c5b7fc548 425 else
FairyMental 60:db8c5b7fc548 426 {
aburch1 81:996c0a3319b4 427 logger.SendMessage("Expected parameters: \"on\" | \"off\"\r\n");
FairyMental 49:83bea7fb2728 428 }
FairyMental 58:7fc6e3e4d746 429 }
aburch1 83:0d3572a8a851 430 // Check if it's a "sett" command
aburch1 81:996c0a3319b4 431 else if(CompareCommands(charPos,"sett",4))
FairyMental 58:7fc6e3e4d746 432 {
FairyMental 58:7fc6e3e4d746 433 charPos = strtok(NULL," ,");
aburch1 81:996c0a3319b4 434 double auxRate = atof(charPos);
FairyMental 68:d3765f93c16a 435 // Validate rate
aburch1 81:996c0a3319b4 436 if(auxRate >= 0.1 &&
aburch1 81:996c0a3319b4 437 auxRate <= 60)
FairyMental 58:7fc6e3e4d746 438 {
FairyMental 58:7fc6e3e4d746 439 sampleRate = auxRate;
FairyMental 58:7fc6e3e4d746 440 timer.detach();
FairyMental 58:7fc6e3e4d746 441 timer.attach(&SendSignalDoMeasure, sampleRate);
aburch1 81:996c0a3319b4 442 snprintf(temp, 256, "Successfully updated sample rate to: %2.2f .\r\n",sampleRate);
aburch1 81:996c0a3319b4 443 logger.SendMessage(temp);
FairyMental 58:7fc6e3e4d746 444 }
FairyMental 58:7fc6e3e4d746 445 else
FairyMental 58:7fc6e3e4d746 446 {
aburch1 81:996c0a3319b4 447 logger.SendMessage("Sample rate must be between 0.1 and 60.\r\n");
FairyMental 58:7fc6e3e4d746 448 }
FairyMental 58:7fc6e3e4d746 449 }
aburch1 83:0d3572a8a851 450 // Check if it's a "help" command
aburch1 81:996c0a3319b4 451 else if (CompareCommands(charPos,"help",4) || CompareCommands(charPos,"?",1))
aburch1 75:b44645bbf2d2 452 {
aburch1 82:668b51a39148 453 logger.SendMessage("\nAvailable Commands:\r\n");
aburch1 82:668b51a39148 454 logger.SendMessage(" read <all|n> - Read all or n first measures.\r\n");
aburch1 82:668b51a39148 455 logger.SendMessage(" delete <all|n> - Delete all or n first measures.\r\n");
aburch1 81:996c0a3319b4 456 logger.SendMessage(" setdate <DD> <MM> <YYYY> Set current date.\r\n");
aburch1 81:996c0a3319b4 457 logger.SendMessage(" settime <HH> <MM> <SS> Set current time.\r\n");
aburch1 81:996c0a3319b4 458 logger.SendMessage(" sett <T> Set sample rate (in seconds).\r\n");
aburch1 81:996c0a3319b4 459 logger.SendMessage(" status - Status report of device.\r\n");
aburch1 82:668b51a39148 460 logger.SendMessage(" state - <on|off> - Turn sampling on or off.\r\n");
aburch1 82:668b51a39148 461 logger.SendMessage(" logging <on|off> - Turn logging on or off.\r\n");
aburch1 83:0d3572a8a851 462 logger.SendMessage(" reset - Resets the current session of the application.\r\n");
aburch1 82:668b51a39148 463 }
aburch1 83:0d3572a8a851 464 // Check if it's a "reset" command
aburch1 82:668b51a39148 465 else if (CompareCommands(charPos,"reset",5))
aburch1 82:668b51a39148 466 {
aburch1 82:668b51a39148 467 logger.SendError("Program Terminating...\r\n");
aburch1 75:b44645bbf2d2 468 }
aburch1 83:0d3572a8a851 469 // If command is not recognized
FairyMental 60:db8c5b7fc548 470 else
FairyMental 60:db8c5b7fc548 471 {
aburch1 81:996c0a3319b4 472 logger.SendMessage("Command not recognized. Type \"help\" for more info.\r\n");
FairyMental 60:db8c5b7fc548 473 }
aburch1 83:0d3572a8a851 474
aburch1 83:0d3572a8a851 475 if(!logging)
aburch1 82:668b51a39148 476 {
aburch1 82:668b51a39148 477 logger.SendMessage("\r\nAwaiting Command:\r\n");
aburch1 82:668b51a39148 478 }
aburch1 83:0d3572a8a851 479
aburch1 83:0d3572a8a851 480 // Clear currently stored command
FairyMental 41:d222c043c96d 481 int i = 0;
aburch1 83:0d3572a8a851 482 for(i =0 ; i < crtSize; i++)
FairyMental 41:d222c043c96d 483 command[i] = ' ';
FairyMental 41:d222c043c96d 484 command[0] = 0;
aburch1 83:0d3572a8a851 485 crtSize = 0;
FairyMental 41:d222c043c96d 486 }
FairyMental 41:d222c043c96d 487 }
FairyMental 39:618ad21e2b34 488 }
FairyMental 39:618ad21e2b34 489 }
aburch1 73:cfad270d2f2c 490
aburch1 83:0d3572a8a851 491 /**
aburch1 83:0d3572a8a851 492 Waits for a signal from the MessageLogger before confirming a message is to be printed,
aburch1 83:0d3572a8a851 493 ensuring messages are displayed in the correct order.
aburch1 83:0d3572a8a851 494
aburch1 83:0d3572a8a851 495 If an error is recieved, error is prioritised and signal is sent to the main thread for the
aburch1 83:0d3572a8a851 496 program to be terminated, waiting for user input to reset.
aburch1 83:0d3572a8a851 497 */
aburch1 73:cfad270d2f2c 498 void LoggingThread()
aburch1 83:0d3572a8a851 499 {
aburch1 82:668b51a39148 500 while(true)
aburch1 82:668b51a39148 501 {
aburch1 82:668b51a39148 502 Thread::signal_wait(SIGNAL_printMessage);
aburch1 82:668b51a39148 503
aburch1 82:668b51a39148 504 while(true)
aburch1 82:668b51a39148 505 {
aburch1 75:b44645bbf2d2 506 if(logger.GetError())
aburch1 75:b44645bbf2d2 507 {
aburch1 82:668b51a39148 508 osSignalSet(mainThreadId, SIGNAL_terminate);
aburch1 75:b44645bbf2d2 509 }
aburch1 75:b44645bbf2d2 510 else if(!logger.GetMessage())
aburch1 75:b44645bbf2d2 511 {
aburch1 82:668b51a39148 512 break;
aburch1 82:668b51a39148 513 }
aburch1 82:668b51a39148 514 }
aburch1 82:668b51a39148 515 }
aburch1 73:cfad270d2f2c 516 }
FairyMental 34:09ed07f2acba 517
aburch1 83:0d3572a8a851 518 /**
aburch1 83:0d3572a8a851 519 Main Thread: Entry point to program.
aburch1 83:0d3572a8a851 520 */
FairyMental 34:09ed07f2acba 521 int main() {
aburch1 83:0d3572a8a851 522
aburch1 83:0d3572a8a851 523 mainThreadId = osThreadGetId();
aburch1 83:0d3572a8a851 524
FairyMental 34:09ed07f2acba 525 measurer.init();
FairyMental 34:09ed07f2acba 526 measurer.calib();
Netaphous 54:53ee2d07d684 527
aburch1 83:0d3572a8a851 528 localDate = new LocalDate();
FairyMental 34:09ed07f2acba 529
aburch1 83:0d3572a8a851 530 // Timer initialised for measurements to be collected every sampleRate seconds.
FairyMental 58:7fc6e3e4d746 531 timer.attach(&SendSignalDoMeasure, sampleRate);
FairyMental 46:0de1f3c7d118 532 realTimeDate.attach(&RealTimeDate,1.0);
FairyMental 34:09ed07f2acba 533
aburch1 83:0d3572a8a851 534 // Start Threads
aburch1 83:0d3572a8a851 535
aburch1 80:959151952153 536 loggingThread = new Thread();
aburch1 80:959151952153 537 loggingThread->start(LoggingThread);
aburch1 80:959151952153 538
aburch1 80:959151952153 539 logger.SetThread(loggingThread);
aburch1 80:959151952153 540
aburch1 83:0d3572a8a851 541 producerThread = new Thread();
aburch1 83:0d3572a8a851 542 producerThread->start(ProducerThread);
aburch1 83:0d3572a8a851 543
aburch1 83:0d3572a8a851 544 measurementThread = new Thread();
aburch1 83:0d3572a8a851 545 measurementThread->start(MeasurementThread);
aburch1 83:0d3572a8a851 546
aburch1 83:0d3572a8a851 547 consumerThread = new Thread();
aburch1 83:0d3572a8a851 548 consumerThread->start(ConsumerThread);
aburch1 74:749727490f44 549
aburch1 82:668b51a39148 550 logger.SendMessage("\r\n--- W E L C O M E ---\r\n");
aburch1 82:668b51a39148 551
aburch1 82:668b51a39148 552 SendSignalDoMeasure();
FairyMental 34:09ed07f2acba 553
aburch1 75:b44645bbf2d2 554 while(true)
martinsimpson 32:260a288be58f 555 {
aburch1 83:0d3572a8a851 556 // Waits for temination signal from logging thread when an error is received.
aburch1 82:668b51a39148 557 osSignalWait(SIGNAL_terminate, osWaitForever);
aburch1 82:668b51a39148 558
aburch1 83:0d3572a8a851 559 producerThread->terminate();
aburch1 83:0d3572a8a851 560 measurementThread->terminate();
aburch1 83:0d3572a8a851 561 consumerThread->terminate();
aburch1 82:668b51a39148 562 loggingThread->terminate();
aburch1 82:668b51a39148 563
aburch1 83:0d3572a8a851 564 // Waits for user input before resetting the system.
aburch1 82:668b51a39148 565 printf("Press any key to restart...");
aburch1 82:668b51a39148 566 char c = getchar();
aburch1 83:0d3572a8a851 567 printf("===============================\n\n\n");
aburch1 82:668b51a39148 568 NVIC_SystemReset();
FairyMental 68:d3765f93c16a 569 }
Netaphous 70:ee19a73ed215 570 }