Fork for Get Started Demo
Dependencies: DebouncedInterrupt dash7-alp mbed-rtos mbed wizzi-utils
Fork of D7A_Demo_full by
main.cpp@15:78f0945fbf69, 2016-01-28 (annotated)
- Committer:
- Jeej
- Date:
- Thu Jan 28 10:59:20 2016 +0000
- Revision:
- 15:78f0945fbf69
- Parent:
- 14:02bfe80b3db8
Warning prints
Who changed what in which revision?
User | Revision | Line number | New contents of line |
---|---|---|---|
Jeej | 0:aa25c4c8ddbf | 1 | #include "mbed.h" |
Jeej | 0:aa25c4c8ddbf | 2 | #include "rtos.h" |
Jeej | 0:aa25c4c8ddbf | 3 | #include "dbg.h" |
Jeej | 3:b77b01171cc0 | 4 | #include "DebouncedInterrupt.h" |
Jeej | 5:e18c38942326 | 5 | #include "system.h" |
Jeej | 11:1a5a4f7cc5d3 | 6 | #include "files.h" |
Jeej | 7:4226c77951a4 | 7 | #include "alp.h" |
Jeej | 2:c3cfaa7d5bb8 | 8 | |
Jeej | 7:4226c77951a4 | 9 | // Semaphore for notifiying button presses |
Jeej | 7:4226c77951a4 | 10 | Semaphore button_user(1); |
Jeej | 2:c3cfaa7d5bb8 | 11 | |
Jeej | 13:218d2b6a9390 | 12 | alp_err_t d7a_write_file(const uint8_t file_id, |
Jeej | 7:4226c77951a4 | 13 | const uint16_t offset, |
Jeej | 7:4226c77951a4 | 14 | const uint16_t file_size, |
Jeej | 7:4226c77951a4 | 15 | const uint8_t* const content) |
Jeej | 7:4226c77951a4 | 16 | { |
Jeej | 7:4226c77951a4 | 17 | alp_err_t err = ALP_ERR_NO; |
Jeej | 7:4226c77951a4 | 18 | void* file = NULL; |
Jeej | 7:4226c77951a4 | 19 | |
Jeej | 7:4226c77951a4 | 20 | //err = write_file(file_id, offset, file_size, content); |
mikl_andre | 8:9beb450228d4 | 21 | PRINT("D7 File %d Write (offset %d, size %d)\r\n", file_id, offset, file_size); |
Jeej | 7:4226c77951a4 | 22 | switch (file_id) |
Jeej | 7:4226c77951a4 | 23 | { |
Jeej | 7:4226c77951a4 | 24 | case REVISION_DEVICE_FILE_ID: |
Jeej | 7:4226c77951a4 | 25 | file = &revision; |
Jeej | 7:4226c77951a4 | 26 | break; |
Jeej | 7:4226c77951a4 | 27 | case ALARM_DATA_FILE_ID: |
Jeej | 7:4226c77951a4 | 28 | file = &alarm_data; |
Jeej | 7:4226c77951a4 | 29 | break; |
Jeej | 7:4226c77951a4 | 30 | case ALARM_CMD_FILE_ID: |
Jeej | 7:4226c77951a4 | 31 | file = &alarm_cmd; |
Jeej | 7:4226c77951a4 | 32 | // Update alarm file |
Jeej | 7:4226c77951a4 | 33 | alarm_data.status = !content[0]; |
Jeej | 7:4226c77951a4 | 34 | // Simulate button press |
Jeej | 7:4226c77951a4 | 35 | button_user.release(); |
Jeej | 7:4226c77951a4 | 36 | break; |
Jeej | 7:4226c77951a4 | 37 | case TEMP_DATA_FILE_ID: |
Jeej | 7:4226c77951a4 | 38 | file = &temp_data; |
Jeej | 7:4226c77951a4 | 39 | break; |
Jeej | 7:4226c77951a4 | 40 | default: |
Jeej | 7:4226c77951a4 | 41 | PRINT("Unknown file id %d\r\n", file_id); |
Jeej | 7:4226c77951a4 | 42 | err = ALP_ERR_FILE_NOT_FOUND; |
Jeej | 7:4226c77951a4 | 43 | break; |
Jeej | 7:4226c77951a4 | 44 | } |
Jeej | 7:4226c77951a4 | 45 | |
Jeej | 7:4226c77951a4 | 46 | if (file != NULL) |
Jeej | 7:4226c77951a4 | 47 | { |
Jeej | 7:4226c77951a4 | 48 | memcpy(file+offset, content, file_size); |
Jeej | 7:4226c77951a4 | 49 | } |
Jeej | 7:4226c77951a4 | 50 | |
Jeej | 7:4226c77951a4 | 51 | return err; |
Jeej | 7:4226c77951a4 | 52 | } |
Jeej | 12:d17ef6ce50c8 | 53 | |
Jeej | 13:218d2b6a9390 | 54 | alp_err_t d7a_read_file( const uint8_t file_id, |
Jeej | 7:4226c77951a4 | 55 | const uint16_t offset, |
Jeej | 7:4226c77951a4 | 56 | const uint16_t file_size, |
Jeej | 7:4226c77951a4 | 57 | uint8_t* buf) |
Jeej | 7:4226c77951a4 | 58 | { |
Jeej | 7:4226c77951a4 | 59 | alp_err_t err = ALP_ERR_NO; |
Jeej | 7:4226c77951a4 | 60 | void* file = NULL; |
Jeej | 7:4226c77951a4 | 61 | |
mikl_andre | 8:9beb450228d4 | 62 | PRINT("D7 File %d Read (offset %d, size %d)\r\n", file_id, offset, file_size); |
mikl_andre | 8:9beb450228d4 | 63 | |
Jeej | 7:4226c77951a4 | 64 | switch (file_id) |
Jeej | 7:4226c77951a4 | 65 | { |
Jeej | 7:4226c77951a4 | 66 | case REVISION_DEVICE_FILE_ID: |
Jeej | 7:4226c77951a4 | 67 | file = &revision; |
Jeej | 7:4226c77951a4 | 68 | break; |
Jeej | 7:4226c77951a4 | 69 | case ALARM_DATA_FILE_ID: |
Jeej | 7:4226c77951a4 | 70 | file = &alarm_data; |
Jeej | 7:4226c77951a4 | 71 | break; |
Jeej | 7:4226c77951a4 | 72 | case ALARM_CMD_FILE_ID: |
Jeej | 7:4226c77951a4 | 73 | file = &alarm_cmd; |
Jeej | 7:4226c77951a4 | 74 | break; |
Jeej | 7:4226c77951a4 | 75 | case TEMP_DATA_FILE_ID: |
Jeej | 7:4226c77951a4 | 76 | file = &temp_data; |
Jeej | 7:4226c77951a4 | 77 | break; |
Jeej | 7:4226c77951a4 | 78 | default: |
Jeej | 7:4226c77951a4 | 79 | PRINT("Unknown file id %d\r\n", file_id); |
Jeej | 7:4226c77951a4 | 80 | err = ALP_ERR_FILE_NOT_FOUND; |
Jeej | 7:4226c77951a4 | 81 | break; |
Jeej | 7:4226c77951a4 | 82 | } |
Jeej | 7:4226c77951a4 | 83 | |
Jeej | 7:4226c77951a4 | 84 | if (file != NULL) |
Jeej | 7:4226c77951a4 | 85 | { |
Jeej | 7:4226c77951a4 | 86 | memcpy(buf, file+offset, file_size); |
Jeej | 7:4226c77951a4 | 87 | } |
Jeej | 7:4226c77951a4 | 88 | |
Jeej | 7:4226c77951a4 | 89 | return err; |
Jeej | 7:4226c77951a4 | 90 | } |
Jeej | 7:4226c77951a4 | 91 | |
Jeej | 13:218d2b6a9390 | 92 | const d7a_config_t shield1001_config = { |
Jeej | 7:4226c77951a4 | 93 | .tx = PB_6, |
Jeej | 7:4226c77951a4 | 94 | .rx = PA_10, |
Jeej | 7:4226c77951a4 | 95 | .rts = PA_5, |
Jeej | 7:4226c77951a4 | 96 | .cts = PC_7, |
Jeej | 7:4226c77951a4 | 97 | .rx_buffer_size = 256, |
Jeej | 13:218d2b6a9390 | 98 | .local_timeout = 3000, |
Jeej | 13:218d2b6a9390 | 99 | .distant_timeout = 10000, |
Jeej | 13:218d2b6a9390 | 100 | .write = d7a_write_file, |
Jeej | 13:218d2b6a9390 | 101 | .read = d7a_read_file, |
Jeej | 7:4226c77951a4 | 102 | }; |
Jeej | 7:4226c77951a4 | 103 | |
Jeej | 7:4226c77951a4 | 104 | |
Jeej | 2:c3cfaa7d5bb8 | 105 | // Checks the status of the report send. |
Jeej | 13:218d2b6a9390 | 106 | void check_status( alp_response_t* response, char* message ) |
Jeej | 2:c3cfaa7d5bb8 | 107 | { |
Jeej | 13:218d2b6a9390 | 108 | if (response != NULL) |
Jeej | 2:c3cfaa7d5bb8 | 109 | { |
Jeej | 13:218d2b6a9390 | 110 | /* |
Jeej | 13:218d2b6a9390 | 111 | Accessing the list of acknowledges. |
Jeej | 13:218d2b6a9390 | 112 | */ |
Jeej | 13:218d2b6a9390 | 113 | if (response->nb_ack == 0) |
Jeej | 13:218d2b6a9390 | 114 | { |
Jeej | 13:218d2b6a9390 | 115 | PRINT("%s NO RESPONSE!\r\n", message); |
Jeej | 13:218d2b6a9390 | 116 | } |
Jeej | 13:218d2b6a9390 | 117 | else |
Jeej | 13:218d2b6a9390 | 118 | { |
Jeej | 13:218d2b6a9390 | 119 | for(uint8_t i=0 ; i < response->nb_ack ; i++) |
Jeej | 13:218d2b6a9390 | 120 | { |
Jeej | 13:218d2b6a9390 | 121 | PRINT("%s -%d- ERR:0x%02X UID:%02X%02X%02X%02X%02X%02X%02X%02X\r\n", message, i+1, response->ack[i].err, |
Jeej | 13:218d2b6a9390 | 122 | response->ack[i].uid[0], response->ack[i].uid[1], response->ack[i].uid[2], response->ack[i].uid[3], |
Jeej | 13:218d2b6a9390 | 123 | response->ack[i].uid[4], response->ack[i].uid[5], response->ack[i].uid[6], response->ack[i].uid[7]); |
Jeej | 13:218d2b6a9390 | 124 | } |
Jeej | 13:218d2b6a9390 | 125 | } |
Jeej | 13:218d2b6a9390 | 126 | |
Jeej | 13:218d2b6a9390 | 127 | /* |
Jeej | 13:218d2b6a9390 | 128 | Do not forget to free the response! |
Jeej | 13:218d2b6a9390 | 129 | */ |
Jeej | 13:218d2b6a9390 | 130 | FREE(response); |
Jeej | 13:218d2b6a9390 | 131 | } |
Jeej | 13:218d2b6a9390 | 132 | else |
Jeej | 13:218d2b6a9390 | 133 | { |
Jeej | 13:218d2b6a9390 | 134 | PRINT("%s ERROR!\r\n", message); |
Jeej | 2:c3cfaa7d5bb8 | 135 | } |
Jeej | 2:c3cfaa7d5bb8 | 136 | } |
Jeej | 0:aa25c4c8ddbf | 137 | |
Jeej | 3:b77b01171cc0 | 138 | // Interrupt Service Routine on button press. |
Jeej | 3:b77b01171cc0 | 139 | void button_push_isr( void ) |
Jeej | 3:b77b01171cc0 | 140 | { |
Jeej | 3:b77b01171cc0 | 141 | button_user.release(); |
Jeej | 3:b77b01171cc0 | 142 | } |
Jeej | 3:b77b01171cc0 | 143 | |
Jeej | 3:b77b01171cc0 | 144 | // This Thread monitors the user button |
Jeej | 3:b77b01171cc0 | 145 | // and reports the alarm status |
Jeej | 3:b77b01171cc0 | 146 | void alarm_thread( const void* args ) |
Jeej | 10:e16d5cfd4198 | 147 | { |
Jeej | 7:4226c77951a4 | 148 | // Get modem |
Jeej | 13:218d2b6a9390 | 149 | D7A_modem* wm1001 = (D7A_modem*)args; |
Jeej | 13:218d2b6a9390 | 150 | uint8_t target_uid[8] = { 0x00, 0x1B, 0xC5, 0x0C, 0x70, 0x00, 0x06, 0xA7 }; |
Jeej | 13:218d2b6a9390 | 151 | uint8_t led_on_cmd[5] = { 0, 0, 0, 9, 2 }; |
Jeej | 13:218d2b6a9390 | 152 | uint8_t led_off_cmd[5] = { 0, 0, 0, 9, 3 }; |
Jeej | 13:218d2b6a9390 | 153 | uint8_t buf[20]; |
Jeej | 13:218d2b6a9390 | 154 | alp_response_t* response; |
Jeej | 11:1a5a4f7cc5d3 | 155 | |
Jeej | 3:b77b01171cc0 | 156 | // Enable interrupt on User button |
Jeej | 3:b77b01171cc0 | 157 | DebouncedInterrupt button(USER_BUTTON); |
Jeej | 10:e16d5cfd4198 | 158 | button.attach(&button_push_isr, IRQ_FALL, 500, true); |
Jeej | 12:d17ef6ce50c8 | 159 | |
Jeej | 3:b77b01171cc0 | 160 | while(true) |
Jeej | 3:b77b01171cc0 | 161 | { |
Jeej | 3:b77b01171cc0 | 162 | // Wait for button press |
Jeej | 3:b77b01171cc0 | 163 | button_user.wait(); |
Jeej | 5:e18c38942326 | 164 | |
Jeej | 13:218d2b6a9390 | 165 | response = NULL; |
Jeej | 13:218d2b6a9390 | 166 | |
Jeej | 7:4226c77951a4 | 167 | // Invert alarm status |
Jeej | 7:4226c77951a4 | 168 | alarm_data.status = !alarm_data.status; |
Jeej | 7:4226c77951a4 | 169 | |
mikl_andre | 8:9beb450228d4 | 170 | PRINT("NOTIFY ALARM STATE CHANGE %d\r\n", alarm_data.status); |
Jeej | 10:e16d5cfd4198 | 171 | FLUSH(); |
Jeej | 13:218d2b6a9390 | 172 | |
Jeej | 3:b77b01171cc0 | 173 | // Notify alarm status |
Jeej | 7:4226c77951a4 | 174 | check_status(wm1001->notify_filechange(ALARM_DATA_FILE_ID), "ALARM REPORT"); |
Jeej | 15:78f0945fbf69 | 175 | |
Jeej | 15:78f0945fbf69 | 176 | PRINT("SENDING CMD %d\r\n", alarm_data.status); |
Jeej | 11:1a5a4f7cc5d3 | 177 | if (alarm_data.status) |
Jeej | 11:1a5a4f7cc5d3 | 178 | { |
Jeej | 13:218d2b6a9390 | 179 | /* |
Jeej | 13:218d2b6a9390 | 180 | Writes a file in broadcast and wait for the first response |
Jeej | 13:218d2b6a9390 | 181 | */ |
Jeej | 13:218d2b6a9390 | 182 | response = wm1001->write(NULL, ACCESS_CLASS_SC, 80, 0, 5, led_on_cmd, RESP_ANYCAST); |
Jeej | 13:218d2b6a9390 | 183 | |
Jeej | 13:218d2b6a9390 | 184 | /* |
Jeej | 13:218d2b6a9390 | 185 | Reads a file from the specified UID into 'buf' |
Jeej | 13:218d2b6a9390 | 186 | When the UID is specified, the resp parameter is always ANYCAST |
Jeej | 13:218d2b6a9390 | 187 | */ |
Jeej | 13:218d2b6a9390 | 188 | //response = wm1001->read(target_uid, ACCESS_CLASS_SC, ALARM_CMD_FILE_ID, 0, 1, buf); |
Jeej | 11:1a5a4f7cc5d3 | 189 | } |
Jeej | 11:1a5a4f7cc5d3 | 190 | else |
Jeej | 11:1a5a4f7cc5d3 | 191 | { |
Jeej | 13:218d2b6a9390 | 192 | /* |
Jeej | 13:218d2b6a9390 | 193 | Writes a file in broadcast and wait for all the responses before timeout. |
Jeej | 13:218d2b6a9390 | 194 | */ |
Jeej | 13:218d2b6a9390 | 195 | response = wm1001->write(NULL, ACCESS_CLASS_SC, 80, 0, 5, led_off_cmd, RESP_ALLCAST); |
Jeej | 13:218d2b6a9390 | 196 | |
Jeej | 13:218d2b6a9390 | 197 | /* |
Jeej | 13:218d2b6a9390 | 198 | Reads a file in broadcast and wait for all the responses before timeout. |
Jeej | 13:218d2b6a9390 | 199 | 'buf' is filled with the data of the last response recieved. |
Jeej | 13:218d2b6a9390 | 200 | */ |
Jeej | 13:218d2b6a9390 | 201 | //response = wm1001->read(NULL, ACCESS_CLASS_SC, ALARM_CMD_FILE_ID, 0, 1, buf, RESP_ALLCAST); |
Jeej | 11:1a5a4f7cc5d3 | 202 | } |
Jeej | 13:218d2b6a9390 | 203 | |
Jeej | 13:218d2b6a9390 | 204 | check_status(response, "CMD"); |
Jeej | 5:e18c38942326 | 205 | } |
Jeej | 5:e18c38942326 | 206 | } |
Jeej | 5:e18c38942326 | 207 | |
Jeej | 5:e18c38942326 | 208 | // This Thread reads the chip temperature |
Jeej | 5:e18c38942326 | 209 | // and reports it every 5 minutes |
Jeej | 5:e18c38942326 | 210 | void temp_thread( const void* args ) |
Jeej | 5:e18c38942326 | 211 | { |
Jeej | 7:4226c77951a4 | 212 | // Get modem |
Jeej | 13:218d2b6a9390 | 213 | D7A_modem* wm1001 = (D7A_modem*)args; |
Jeej | 5:e18c38942326 | 214 | |
Jeej | 5:e18c38942326 | 215 | while(true) |
Jeej | 5:e18c38942326 | 216 | { |
Jeej | 7:4226c77951a4 | 217 | temp_data.value = system_get_temperature(); |
Jeej | 7:4226c77951a4 | 218 | |
mikl_andre | 8:9beb450228d4 | 219 | PRINT("NOTIFY TEMPERATURE %d C\r\n", temp_data.value); |
Jeej | 7:4226c77951a4 | 220 | |
Jeej | 5:e18c38942326 | 221 | // Notify temp value |
Jeej | 14:02bfe80b3db8 | 222 | check_status(wm1001->notify_filechange(TEMP_DATA_FILE_ID), "TEMP REPORT"); |
Jeej | 3:b77b01171cc0 | 223 | |
Jeej | 7:4226c77951a4 | 224 | // Wait 5 minutes |
Jeej | 7:4226c77951a4 | 225 | // The function Thread::wait(...) takes a uin32_t as parameter |
Jeej | 7:4226c77951a4 | 226 | // but the maximum value is uin16_t (65535) |
Jeej | 7:4226c77951a4 | 227 | for (uint8_t i=0 ; i<5 ; i++) { Thread::wait(60000); } |
Jeej | 4:1edd956b015f | 228 | } |
Jeej | 4:1edd956b015f | 229 | } |
Jeej | 4:1edd956b015f | 230 | |
Jeej | 0:aa25c4c8ddbf | 231 | int main() |
Jeej | 0:aa25c4c8ddbf | 232 | { |
Jeej | 0:aa25c4c8ddbf | 233 | // ----- Debug session over USB Serial ----- // |
Jeej | 0:aa25c4c8ddbf | 234 | DBG_OPEN(); |
Jeej | 1:49da0144dd4c | 235 | |
Jeej | 1:49da0144dd4c | 236 | // Clear some lines on the terminal |
Jeej | 7:4226c77951a4 | 237 | PRINT("\r\n\nBOOT\r\n"); |
Jeej | 1:49da0144dd4c | 238 | |
Jeej | 5:e18c38942326 | 239 | // Initialize system functions |
Jeej | 5:e18c38942326 | 240 | system_open(); |
Jeej | 7:4226c77951a4 | 241 | |
Jeej | 7:4226c77951a4 | 242 | // Initialize ALP modem |
Jeej | 14:02bfe80b3db8 | 243 | D7A_modem wm1001(&shield1001_config, PB_0); |
Jeej | 2:c3cfaa7d5bb8 | 244 | |
Jeej | 7:4226c77951a4 | 245 | // Register the files |
Jeej | 14:02bfe80b3db8 | 246 | wm1001.register_file(&revision_device_fh); |
Jeej | 7:4226c77951a4 | 247 | wm1001.register_file(&alarm_data_fh); |
Jeej | 7:4226c77951a4 | 248 | wm1001.register_file(&alarm_cmd_fh); |
Jeej | 14:02bfe80b3db8 | 249 | wm1001.register_file(&temp_data_fh); |
Jeej | 4:1edd956b015f | 250 | |
Jeej | 2:c3cfaa7d5bb8 | 251 | // Send the Revision report |
Jeej | 14:02bfe80b3db8 | 252 | PRINT("NOTIFY REVISION\r\n"); |
Jeej | 14:02bfe80b3db8 | 253 | check_status(wm1001.notify_filechange(REVISION_DEVICE_FILE_ID), "REPORT REVISION"); |
Jeej | 2:c3cfaa7d5bb8 | 254 | |
Jeej | 5:e18c38942326 | 255 | // Init Threads |
Jeej | 13:218d2b6a9390 | 256 | Thread t_alarm_thread(alarm_thread, &wm1001, osPriorityNormal, DEFAULT_STACK_SIZE*8); |
Jeej | 14:02bfe80b3db8 | 257 | Thread t_temp_thread(temp_thread, &wm1001, osPriorityNormal, DEFAULT_STACK_SIZE*4); |
Jeej | 3:b77b01171cc0 | 258 | |
Jeej | 0:aa25c4c8ddbf | 259 | // Set main task to lowest priority |
Jeej | 0:aa25c4c8ddbf | 260 | osThreadSetPriority(osThreadGetId(), osPriorityIdle); |
Jeej | 0:aa25c4c8ddbf | 261 | while(true) |
Jeej | 0:aa25c4c8ddbf | 262 | { |
Jeej | 0:aa25c4c8ddbf | 263 | // Wait to avoid beeing stuck in loop |
Jeej | 0:aa25c4c8ddbf | 264 | Thread::wait(osWaitForever); |
Jeej | 0:aa25c4c8ddbf | 265 | } |
Jeej | 0:aa25c4c8ddbf | 266 | } |