Webserver only w/o any other functions, single thread. Running on STM32F013+W5500
Dependencies: NTPClient W5500Interface Watchdog device_configuration eeprom_flash mbed-rpc-nucleo mbed-rtos mbed
Fork of F103-Serial-to-Ethernet by
main.cpp@14:18eda020a589, 2014-09-28 (annotated)
- Committer:
- olympux
- Date:
- Sun Sep 28 21:54:34 2014 +0000
- Revision:
- 14:18eda020a589
- Parent:
- 13:bcf840da68fd
- Child:
- 15:edeb0aed160d
TCP client works with mbed.org, but not with TCP server on Hercules
Who changed what in which revision?
User | Revision | Line number | New contents of line |
---|---|---|---|
olympux | 0:c2eac797face | 1 | /* |
olympux | 0:c2eac797face | 2 | * |
olympux | 2:18f10e7209f4 | 3 | * Alarm and Monitoring application |
olympux | 0:c2eac797face | 4 | |
olympux | 0:c2eac797face | 5 | */ |
olympux | 0:c2eac797face | 6 | #include "mbed.h" |
olympux | 12:7c152c0ca4d8 | 7 | #include "eeprom.h" |
olympux | 0:c2eac797face | 8 | #include "EthernetInterface.h" |
olympux | 9:d2534ecf88c6 | 9 | #include "NTPClient.h" |
olympux | 0:c2eac797face | 10 | #include "rtos.h" |
olympux | 0:c2eac797face | 11 | |
olympux | 12:7c152c0ca4d8 | 12 | #include "my_eeprom_funcs.h" |
olympux | 12:7c152c0ca4d8 | 13 | |
olympux | 0:c2eac797face | 14 | |
olympux | 2:18f10e7209f4 | 15 | /* |
olympux | 2:18f10e7209f4 | 16 | * Hardware defines |
olympux | 0:c2eac797face | 17 | */ |
olympux | 2:18f10e7209f4 | 18 | #define ST_NUCLEO // hardware pin mapping |
olympux | 0:c2eac797face | 19 | |
olympux | 0:c2eac797face | 20 | #ifdef ST_NUCLEO |
olympux | 9:d2534ecf88c6 | 21 | // Ethernet |
olympux | 0:c2eac797face | 22 | SPI spi(PA_7, PA_6, PA_5); // mosi, miso, sclk |
olympux | 11:709f90a3b599 | 23 | EthernetInterface eth(&spi, PA_4, PC_9); // spi, cs, reset |
olympux | 0:c2eac797face | 24 | #endif |
olympux | 0:c2eac797face | 25 | |
olympux | 9:d2534ecf88c6 | 26 | // Serial |
olympux | 2:18f10e7209f4 | 27 | Serial uart(USBTX,USBRX); |
olympux | 2:18f10e7209f4 | 28 | |
olympux | 9:d2534ecf88c6 | 29 | // Digital inputs |
olympux | 11:709f90a3b599 | 30 | DigitalIn din0(PB_14); |
olympux | 11:709f90a3b599 | 31 | DigitalIn din1(PB_12); |
olympux | 11:709f90a3b599 | 32 | DigitalIn din2(PB_10); |
olympux | 11:709f90a3b599 | 33 | DigitalIn din3(PB_1); |
olympux | 11:709f90a3b599 | 34 | DigitalIn din4(PB_15); |
olympux | 11:709f90a3b599 | 35 | DigitalIn din5(PB_13); |
olympux | 11:709f90a3b599 | 36 | DigitalIn din6(PB_11); |
olympux | 11:709f90a3b599 | 37 | DigitalIn din7(PB_2); |
olympux | 9:d2534ecf88c6 | 38 | // Digital outputs |
olympux | 11:709f90a3b599 | 39 | DigitalOut dout0(PB_3); |
olympux | 11:709f90a3b599 | 40 | DigitalOut dout1(PB_5); |
olympux | 11:709f90a3b599 | 41 | DigitalOut dout2(PB_7); |
olympux | 11:709f90a3b599 | 42 | DigitalOut dout3(PB_9); |
olympux | 11:709f90a3b599 | 43 | DigitalOut dout4(PD_2); |
olympux | 11:709f90a3b599 | 44 | DigitalOut dout5(PB_4); |
olympux | 11:709f90a3b599 | 45 | DigitalOut dout6(PB_6); |
olympux | 11:709f90a3b599 | 46 | DigitalOut dout7(PB_8); |
olympux | 9:d2534ecf88c6 | 47 | // Analog inputs |
olympux | 11:709f90a3b599 | 48 | AnalogIn ain0(PC_0); |
olympux | 11:709f90a3b599 | 49 | AnalogIn ain1(PC_1); |
olympux | 9:d2534ecf88c6 | 50 | // Analog outputs |
olympux | 11:709f90a3b599 | 51 | //AnalogOut ano0(PA_8); |
olympux | 11:709f90a3b599 | 52 | //AnalogOut ano1(PA_15); |
olympux | 11:709f90a3b599 | 53 | |
olympux | 12:7c152c0ca4d8 | 54 | void update_digital_outputs(char* buf); |
olympux | 12:7c152c0ca4d8 | 55 | void update_sending_frame(char* buf); |
olympux | 11:709f90a3b599 | 56 | |
olympux | 9:d2534ecf88c6 | 57 | |
olympux | 9:d2534ecf88c6 | 58 | |
olympux | 13:bcf840da68fd | 59 | /* |
olympux | 13:bcf840da68fd | 60 | * EEPROM section |
olympux | 13:bcf840da68fd | 61 | */ |
olympux | 6:d054e394fba3 | 62 | // Virtual address defined by the user: 0xFFFF value is prohibited |
olympux | 6:d054e394fba3 | 63 | uint16_t VirtAddVarTab[NumbOfVar] = {0x1212, 0x1313, 0x1414, 0x1515, // IP_Addr |
olympux | 6:d054e394fba3 | 64 | 0x2212, 0x2313, 0x2414, 0x2515, // IP_Subnet |
olympux | 6:d054e394fba3 | 65 | 0x3212, 0x3313, 0x3414, 0x3515, // IP_Gateway |
olympux | 6:d054e394fba3 | 66 | 0x4212, // TCP server port, not used |
olympux | 8:64848959adb9 | 67 | 0x5212, // UDP server port, not used |
olympux | 12:7c152c0ca4d8 | 68 | 0x8888, // 1st run? |
olympux | 12:7c152c0ca4d8 | 69 | 0x6212, 0x6313, 0x6414, // MAC |
olympux | 12:7c152c0ca4d8 | 70 | |
olympux | 12:7c152c0ca4d8 | 71 | // this section is for the TCP server that this device connects to in TCP client mode |
olympux | 12:7c152c0ca4d8 | 72 | 0x7212, 0x7313, // auto transmit status, time period |
olympux | 12:7c152c0ca4d8 | 73 | 0x8212, 0x8313,0x8414, 0x8515, // TCP server IP address |
olympux | 12:7c152c0ca4d8 | 74 | 0x9212 // TCP server port |
olympux | 6:d054e394fba3 | 75 | }; |
olympux | 0:c2eac797face | 76 | |
olympux | 2:18f10e7209f4 | 77 | /* |
olympux | 2:18f10e7209f4 | 78 | * Network configuration |
olympux | 2:18f10e7209f4 | 79 | */ |
olympux | 4:568c97f2a407 | 80 | #define TCP_SERVER |
olympux | 4:568c97f2a407 | 81 | //#define TCP_CLIENT |
olympux | 4:568c97f2a407 | 82 | #define UDP_SERVER |
olympux | 4:568c97f2a407 | 83 | //#define UDP_CLIENT |
olympux | 10:4cd965d79de0 | 84 | #define NTP |
olympux | 4:568c97f2a407 | 85 | |
olympux | 4:568c97f2a407 | 86 | #define TCP_SERVER_WAIT_CLIENT_TIMEOUT 200 |
olympux | 4:568c97f2a407 | 87 | #define TCP_SERVER_RECEIVE_TIMEOUT 3000 |
olympux | 4:568c97f2a407 | 88 | #define UDP_SERVER_RECEIVE_TIMEOUT 200 |
olympux | 4:568c97f2a407 | 89 | |
olympux | 13:bcf840da68fd | 90 | NTPClient ntp; |
olympux | 13:bcf840da68fd | 91 | |
olympux | 13:bcf840da68fd | 92 | |
olympux | 13:bcf840da68fd | 93 | /* |
olympux | 13:bcf840da68fd | 94 | * Variables for network configuration, server |
olympux | 13:bcf840da68fd | 95 | */ |
olympux | 11:709f90a3b599 | 96 | uint8_t u8mac[6], u8ip_addr[4];// keep mac and ip address in 8-bits |
olympux | 11:709f90a3b599 | 97 | uint16_t u16mac_addr[3], u16ip_addr[4], u16ip_subnet[4], u16ip_gateway[4]; // 16-bits, directly loaded from eeprom |
olympux | 11:709f90a3b599 | 98 | char str_ip_addr[16], str_ip_subnet[16], str_ip_gateway[16]; // for printf, converted from 16-bits u16ip_xxx |
olympux | 9:d2534ecf88c6 | 99 | uint16_t first_run = 0; // first run flag |
olympux | 9:d2534ecf88c6 | 100 | |
olympux | 12:7c152c0ca4d8 | 101 | const uint16_t tcp_server_local_port = 10000; // fixed |
olympux | 12:7c152c0ca4d8 | 102 | const uint16_t udp_server_local_port = 11000; // fixed |
olympux | 12:7c152c0ca4d8 | 103 | |
olympux | 12:7c152c0ca4d8 | 104 | // TCP client: this section is used for the TCP server that this device connects to in TCP client mode |
olympux | 12:7c152c0ca4d8 | 105 | // this device will transmit status every transmit_time_period |
olympux | 12:7c152c0ca4d8 | 106 | uint16_t auto_transmit_flag = 0, transmit_time_period = 1000; // auto transmit status, time period = 1s |
olympux | 12:7c152c0ca4d8 | 107 | uint16_t u16server_ip_addr[4]; // directly loaded from eeprom |
olympux | 14:18eda020a589 | 108 | uint8_t u8server_ip_addr[4]; // server ip address in 8-bits |
olympux | 14:18eda020a589 | 109 | char str_server_ip_addr[16];// for printf, converted from 16-bits u16server_ip_addr |
olympux | 12:7c152c0ca4d8 | 110 | uint16_t u16tcp_server_port; // directly loaded from eeprom |
olympux | 12:7c152c0ca4d8 | 111 | |
olympux | 13:bcf840da68fd | 112 | char buffer[256]; // socket buffer |
olympux | 12:7c152c0ca4d8 | 113 | |
olympux | 0:c2eac797face | 114 | |
olympux | 13:bcf840da68fd | 115 | /* |
olympux | 13:bcf840da68fd | 116 | * Protocol |
olympux | 13:bcf840da68fd | 117 | */ |
olympux | 9:d2534ecf88c6 | 118 | // Commands |
olympux | 9:d2534ecf88c6 | 119 | #define DEVICE_ID "NNIO" |
olympux | 9:d2534ecf88c6 | 120 | #define DISCOVERY_COMMAND "NNIODS" |
olympux | 9:d2534ecf88c6 | 121 | #define TCP_SERVER_PORT_COMAMND "NNIOTP" |
olympux | 9:d2534ecf88c6 | 122 | #define UDP_SERVER_PORT_COMAMND "NNIOUP" |
olympux | 11:709f90a3b599 | 123 | #define RECEIVING_PROTOCOL_ENABLE_OUTPUT 'O' |
olympux | 11:709f90a3b599 | 124 | #define QUERY_STATUS_COMMAND 'Q' |
olympux | 11:709f90a3b599 | 125 | #define DIGITAL_HIGH 'H' |
olympux | 11:709f90a3b599 | 126 | #define DIGITAL_LOW 'L' |
olympux | 9:d2534ecf88c6 | 127 | |
olympux | 9:d2534ecf88c6 | 128 | |
olympux | 9:d2534ecf88c6 | 129 | // Positions |
olympux | 11:709f90a3b599 | 130 | #define RECEIVING_PROTOCOL_LENGTH 58 |
olympux | 11:709f90a3b599 | 131 | #define RECEIVING_PROTOCOL_ID_POS 0 |
olympux | 9:d2534ecf88c6 | 132 | #define RECEIVING_PROTOCOL_OP_POS 4 |
olympux | 9:d2534ecf88c6 | 133 | #define RECEIVING_PROTOCOL_EN_DO_POS RECEIVING_PROTOCOL_OP_POS + 0 |
olympux | 9:d2534ecf88c6 | 134 | #define RECEIVING_PROTOCOL_EN_A0O_POS RECEIVING_PROTOCOL_OP_POS + 1 |
olympux | 9:d2534ecf88c6 | 135 | #define RECEIVING_PROTOCOL_EN_A1O_POS RECEIVING_PROTOCOL_OP_POS + 2 |
olympux | 9:d2534ecf88c6 | 136 | #define RECEIVING_PROTOCOL_EN_UART_POS RECEIVING_PROTOCOL_OP_POS + 3 |
olympux | 9:d2534ecf88c6 | 137 | #define RECEIVING_PROTOCOL_COMMAND_POS RECEIVING_PROTOCOL_OP_POS + 4 |
olympux | 11:709f90a3b599 | 138 | |
olympux | 11:709f90a3b599 | 139 | #define RECEIVING_PROTOCOL_IP_POS 9 |
olympux | 11:709f90a3b599 | 140 | #define RECEIVING_PROTOCOL_DO_POS 13 |
olympux | 11:709f90a3b599 | 141 | #define RECEIVING_PROTOCOL_A0O_POS 21 |
olympux | 11:709f90a3b599 | 142 | #define RECEIVING_PROTOCOL_A01_POS 23 |
olympux | 11:709f90a3b599 | 143 | #define RECEIVING_PROTOCOL_UART_POS 25 |
olympux | 9:d2534ecf88c6 | 144 | |
olympux | 9:d2534ecf88c6 | 145 | |
olympux | 11:709f90a3b599 | 146 | #define SENDING_PROTOCOL_LENGTH 39 |
olympux | 11:709f90a3b599 | 147 | #define SENDING_PROTOCOL_ID_POS 0 |
olympux | 11:709f90a3b599 | 148 | #define SENDING_PROTOCOL_MAC_POS 4 |
olympux | 11:709f90a3b599 | 149 | #define SENDING_PROTOCOL_IP_POS 10 |
olympux | 11:709f90a3b599 | 150 | #define SENDING_PROTOCOL_DI_POS 14 |
olympux | 11:709f90a3b599 | 151 | #define SENDING_PROTOCOL_DO_POS 22 |
olympux | 11:709f90a3b599 | 152 | #define SENDING_PROTOCOL_AI0_POS 30 |
olympux | 11:709f90a3b599 | 153 | #define SENDING_PROTOCOL_AI1_POS 32 |
olympux | 11:709f90a3b599 | 154 | #define SENDING_PROTOCOL_AO0_POS 34 |
olympux | 11:709f90a3b599 | 155 | #define SENDING_PROTOCOL_AO1_POS 36 |
olympux | 11:709f90a3b599 | 156 | #define SENDING_PROTOCOL_CR_POS 38 |
olympux | 0:c2eac797face | 157 | |
olympux | 2:18f10e7209f4 | 158 | |
olympux | 2:18f10e7209f4 | 159 | /* |
olympux | 2:18f10e7209f4 | 160 | * RTOS |
olympux | 2:18f10e7209f4 | 161 | */ |
olympux | 2:18f10e7209f4 | 162 | struct message_t { |
olympux | 2:18f10e7209f4 | 163 | int len; |
olympux | 2:18f10e7209f4 | 164 | char *msg; |
olympux | 2:18f10e7209f4 | 165 | }; |
olympux | 3:972ed747474c | 166 | Queue<message_t, 16> uart_queue; |
olympux | 2:18f10e7209f4 | 167 | |
olympux | 3:972ed747474c | 168 | Mutex uart_mutex; |
olympux | 2:18f10e7209f4 | 169 | |
olympux | 2:18f10e7209f4 | 170 | |
olympux | 2:18f10e7209f4 | 171 | /* |
olympux | 2:18f10e7209f4 | 172 | * Threads |
olympux | 2:18f10e7209f4 | 173 | */ |
olympux | 0:c2eac797face | 174 | void uart_thread(void const *args) { |
olympux | 2:18f10e7209f4 | 175 | message_t *p_message; |
olympux | 0:c2eac797face | 176 | |
olympux | 0:c2eac797face | 177 | while (true) { |
olympux | 3:972ed747474c | 178 | osEvent evt = uart_queue.get(); |
olympux | 2:18f10e7209f4 | 179 | if (evt.status == osEventMessage) { |
olympux | 2:18f10e7209f4 | 180 | p_message = (message_t*)evt.value.p; |
olympux | 11:709f90a3b599 | 181 | uart_mutex.lock(); // mutex for stdio is not neccessary |
olympux | 3:972ed747474c | 182 | //uart.printf("len=%d\n", p_message->len); |
olympux | 3:972ed747474c | 183 | uart.printf("%s\n", p_message->msg); |
olympux | 3:972ed747474c | 184 | uart_mutex.unlock(); |
olympux | 2:18f10e7209f4 | 185 | } |
olympux | 0:c2eac797face | 186 | } |
olympux | 0:c2eac797face | 187 | } |
olympux | 0:c2eac797face | 188 | |
olympux | 0:c2eac797face | 189 | |
olympux | 6:d054e394fba3 | 190 | /* |
olympux | 6:d054e394fba3 | 191 | * Ethernet init |
olympux | 6:d054e394fba3 | 192 | */ |
olympux | 4:568c97f2a407 | 193 | int ethernet_init(void) { |
olympux | 11:709f90a3b599 | 194 | printf("Start initialising ethernet\n"); |
olympux | 14:18eda020a589 | 195 | int ret = eth.init(u8mac, str_ip_addr, str_ip_subnet, str_ip_gateway); // static |
olympux | 0:c2eac797face | 196 | |
olympux | 0:c2eac797face | 197 | if (!ret) { |
olympux | 11:709f90a3b599 | 198 | printf("Initialized, MAC: %s\n", eth.getMACAddress()); |
olympux | 0:c2eac797face | 199 | } else { |
olympux | 11:709f90a3b599 | 200 | printf("Error eth.init() - ret = %d\n", ret); |
olympux | 0:c2eac797face | 201 | return -1; |
olympux | 0:c2eac797face | 202 | } |
olympux | 0:c2eac797face | 203 | |
olympux | 0:c2eac797face | 204 | ret = eth.connect(); |
olympux | 0:c2eac797face | 205 | if (!ret) { |
olympux | 11:709f90a3b599 | 206 | printf("IP: %s, MASK: %s, GW: %s\n", eth.getIPAddress(), eth.getNetworkMask(), eth.getGateway()); |
olympux | 0:c2eac797face | 207 | } else { |
olympux | 11:709f90a3b599 | 208 | printf("Error eth.connect() - ret = %d\n", ret); |
olympux | 0:c2eac797face | 209 | return -1; |
olympux | 0:c2eac797face | 210 | } |
olympux | 3:972ed747474c | 211 | |
olympux | 4:568c97f2a407 | 212 | return 0; |
olympux | 4:568c97f2a407 | 213 | } |
olympux | 4:568c97f2a407 | 214 | |
olympux | 4:568c97f2a407 | 215 | |
olympux | 6:d054e394fba3 | 216 | |
olympux | 6:d054e394fba3 | 217 | |
olympux | 4:568c97f2a407 | 218 | |
olympux | 4:568c97f2a407 | 219 | int main() |
olympux | 4:568c97f2a407 | 220 | { |
olympux | 4:568c97f2a407 | 221 | message_t message; |
olympux | 9:d2534ecf88c6 | 222 | int n, ret; |
olympux | 4:568c97f2a407 | 223 | |
olympux | 4:568c97f2a407 | 224 | /* |
olympux | 9:d2534ecf88c6 | 225 | * Configure |
olympux | 4:568c97f2a407 | 226 | */ |
olympux | 11:709f90a3b599 | 227 | uart.baud(115200); |
olympux | 4:568c97f2a407 | 228 | |
olympux | 4:568c97f2a407 | 229 | |
olympux | 4:568c97f2a407 | 230 | /* |
olympux | 4:568c97f2a407 | 231 | * UI threads |
olympux | 4:568c97f2a407 | 232 | */ |
olympux | 4:568c97f2a407 | 233 | Thread t1(uart_thread); |
olympux | 4:568c97f2a407 | 234 | |
olympux | 6:d054e394fba3 | 235 | |
olympux | 6:d054e394fba3 | 236 | /* |
olympux | 6:d054e394fba3 | 237 | * FLASH |
olympux | 6:d054e394fba3 | 238 | */ |
olympux | 12:7c152c0ca4d8 | 239 | load_eeprom_network(); |
olympux | 4:568c97f2a407 | 240 | |
olympux | 4:568c97f2a407 | 241 | /* |
olympux | 4:568c97f2a407 | 242 | * Ethernet |
olympux | 4:568c97f2a407 | 243 | */ |
olympux | 6:d054e394fba3 | 244 | ret = ethernet_init(); |
olympux | 4:568c97f2a407 | 245 | if (ret) { |
olympux | 11:709f90a3b599 | 246 | printf("Ethernet initialisation failed. App halted\r\n"); |
olympux | 4:568c97f2a407 | 247 | while (true) {}; |
olympux | 4:568c97f2a407 | 248 | } |
olympux | 4:568c97f2a407 | 249 | |
olympux | 12:7c152c0ca4d8 | 250 | |
olympux | 12:7c152c0ca4d8 | 251 | /* |
olympux | 12:7c152c0ca4d8 | 252 | * TCP/UDP setup |
olympux | 12:7c152c0ca4d8 | 253 | */ |
olympux | 3:972ed747474c | 254 | #ifdef TCP_SERVER |
olympux | 3:972ed747474c | 255 | TCPSocketServer tcp_server; |
olympux | 3:972ed747474c | 256 | TCPSocketConnection tcp_client; |
olympux | 3:972ed747474c | 257 | |
olympux | 12:7c152c0ca4d8 | 258 | tcp_server.bind(tcp_server_local_port); |
olympux | 3:972ed747474c | 259 | tcp_server.listen(); |
olympux | 11:709f90a3b599 | 260 | printf("TCP server started...\r\n"); |
olympux | 4:568c97f2a407 | 261 | tcp_server.set_blocking(false, TCP_SERVER_WAIT_CLIENT_TIMEOUT); |
olympux | 3:972ed747474c | 262 | #endif |
olympux | 14:18eda020a589 | 263 | |
olympux | 14:18eda020a589 | 264 | |
olympux | 14:18eda020a589 | 265 | #ifdef TCP_CLIENT |
olympux | 14:18eda020a589 | 266 | TCPSocketConnection tcp_sock; |
olympux | 14:18eda020a589 | 267 | if (!tcp_sock.is_connected()) { |
olympux | 14:18eda020a589 | 268 | ret = tcp_sock.connect("mbed.org", 80); |
olympux | 14:18eda020a589 | 269 | if (ret > -1) { |
olympux | 14:18eda020a589 | 270 | printf("Successfully connected to TCP server\r\n"); |
olympux | 14:18eda020a589 | 271 | char http_cmd[] = "GET /media/uploads/mbed_official/hello.txt HTTP/1.0\n\n"; |
olympux | 14:18eda020a589 | 272 | tcp_sock.send_all(http_cmd, sizeof(http_cmd)-1); |
olympux | 14:18eda020a589 | 273 | |
olympux | 14:18eda020a589 | 274 | while (true) { |
olympux | 14:18eda020a589 | 275 | n = tcp_sock.receive(buffer, sizeof(buffer)-1); |
olympux | 14:18eda020a589 | 276 | if (n <= 0) |
olympux | 14:18eda020a589 | 277 | break; |
olympux | 14:18eda020a589 | 278 | buffer[n] = '\0'; |
olympux | 14:18eda020a589 | 279 | printf("Received %d chars from server:\n%s\n", n, buffer); |
olympux | 14:18eda020a589 | 280 | } |
olympux | 14:18eda020a589 | 281 | tcp_sock.close(); |
olympux | 14:18eda020a589 | 282 | } |
olympux | 14:18eda020a589 | 283 | else printf("Connecting to TCP server failed\r\n"); |
olympux | 14:18eda020a589 | 284 | } |
olympux | 14:18eda020a589 | 285 | #endif |
olympux | 14:18eda020a589 | 286 | |
olympux | 3:972ed747474c | 287 | |
olympux | 3:972ed747474c | 288 | #ifdef UDP_SERVER |
olympux | 3:972ed747474c | 289 | UDPSocket udp_server; |
olympux | 3:972ed747474c | 290 | Endpoint ep_udp_client; |
olympux | 3:972ed747474c | 291 | |
olympux | 12:7c152c0ca4d8 | 292 | ret = udp_server.bind(udp_server_local_port); |
olympux | 11:709f90a3b599 | 293 | printf("UDP started (sock.bind = %d)\r\n", ret); |
olympux | 4:568c97f2a407 | 294 | udp_server.set_blocking(false, UDP_SERVER_RECEIVE_TIMEOUT); |
olympux | 3:972ed747474c | 295 | #endif |
olympux | 3:972ed747474c | 296 | |
olympux | 3:972ed747474c | 297 | |
olympux | 12:7c152c0ca4d8 | 298 | /* |
olympux | 12:7c152c0ca4d8 | 299 | * Network processor |
olympux | 12:7c152c0ca4d8 | 300 | */ |
olympux | 0:c2eac797face | 301 | while (true) { |
olympux | 9:d2534ecf88c6 | 302 | // FOR INTERFACING |
olympux | 4:568c97f2a407 | 303 | #ifdef TCP_SERVER |
olympux | 4:568c97f2a407 | 304 | // no tcp client connected |
olympux | 4:568c97f2a407 | 305 | if (!tcp_client.is_connected()) |
olympux | 4:568c97f2a407 | 306 | { |
olympux | 4:568c97f2a407 | 307 | // wait for client within timeout |
olympux | 4:568c97f2a407 | 308 | ret = tcp_server.accept(tcp_client); |
olympux | 2:18f10e7209f4 | 309 | |
olympux | 4:568c97f2a407 | 310 | // tcp client connected |
olympux | 4:568c97f2a407 | 311 | if (ret > -1) { |
olympux | 11:709f90a3b599 | 312 | printf("Connection from: %s\r\n", tcp_client.get_address()); |
olympux | 4:568c97f2a407 | 313 | |
olympux | 4:568c97f2a407 | 314 | // loop waiting and receiving data within timeout |
olympux | 4:568c97f2a407 | 315 | tcp_client.set_blocking(false, TCP_SERVER_RECEIVE_TIMEOUT); // Timeout after x seconds |
olympux | 4:568c97f2a407 | 316 | while (true) { |
olympux | 9:d2534ecf88c6 | 317 | n = tcp_client.receive(buffer, sizeof(buffer)); |
olympux | 4:568c97f2a407 | 318 | if (n <= 0) break; |
olympux | 4:568c97f2a407 | 319 | |
olympux | 9:d2534ecf88c6 | 320 | // got some data, test it |
olympux | 11:709f90a3b599 | 321 | printf("TCP server received: %s\r\n", buffer); |
olympux | 11:709f90a3b599 | 322 | |
olympux | 9:d2534ecf88c6 | 323 | //// send to uart |
olympux | 9:d2534ecf88c6 | 324 | //buffer[n] = '\0'; |
olympux | 9:d2534ecf88c6 | 325 | //message.len = n; |
olympux | 9:d2534ecf88c6 | 326 | //message.msg = buffer; |
olympux | 9:d2534ecf88c6 | 327 | //uart_queue.put(&message); |
olympux | 9:d2534ecf88c6 | 328 | //// echo to tcp client |
olympux | 9:d2534ecf88c6 | 329 | //tcp_client.send_all(buffer, n); |
olympux | 9:d2534ecf88c6 | 330 | //if (n <= 0) break; |
olympux | 4:568c97f2a407 | 331 | |
olympux | 9:d2534ecf88c6 | 332 | // process received data |
olympux | 9:d2534ecf88c6 | 333 | switch (n) { |
olympux | 9:d2534ecf88c6 | 334 | // length 58-bytes, Receiving protocol |
olympux | 11:709f90a3b599 | 335 | case RECEIVING_PROTOCOL_LENGTH: { |
olympux | 11:709f90a3b599 | 336 | printf("Checking device ID..."); |
olympux | 9:d2534ecf88c6 | 337 | // check device id |
olympux | 9:d2534ecf88c6 | 338 | char* id = strstr(buffer, DEVICE_ID); |
olympux | 9:d2534ecf88c6 | 339 | if (id == NULL) |
olympux | 9:d2534ecf88c6 | 340 | break; |
olympux | 9:d2534ecf88c6 | 341 | else if ((id - buffer) > 0) |
olympux | 9:d2534ecf88c6 | 342 | break; |
olympux | 11:709f90a3b599 | 343 | printf("Correct.\r\n"); |
olympux | 9:d2534ecf88c6 | 344 | |
olympux | 9:d2534ecf88c6 | 345 | // firstly, update outputs if required |
olympux | 9:d2534ecf88c6 | 346 | // digital outputs |
olympux | 11:709f90a3b599 | 347 | if (buffer[RECEIVING_PROTOCOL_EN_DO_POS] == RECEIVING_PROTOCOL_ENABLE_OUTPUT) { |
olympux | 11:709f90a3b599 | 348 | printf("Update digital outputs\r\n"); |
olympux | 12:7c152c0ca4d8 | 349 | char str_dout[9]; |
olympux | 12:7c152c0ca4d8 | 350 | memcpy(str_dout, &buffer[RECEIVING_PROTOCOL_DO_POS], 8); |
olympux | 12:7c152c0ca4d8 | 351 | str_dout[8] = '\0'; |
olympux | 12:7c152c0ca4d8 | 352 | update_digital_outputs(str_dout); |
olympux | 9:d2534ecf88c6 | 353 | } |
olympux | 9:d2534ecf88c6 | 354 | // analog output 0 |
olympux | 11:709f90a3b599 | 355 | if (buffer[RECEIVING_PROTOCOL_EN_A0O_POS] == RECEIVING_PROTOCOL_ENABLE_OUTPUT) { |
olympux | 11:709f90a3b599 | 356 | printf("Update analog output 0\r\n"); |
olympux | 9:d2534ecf88c6 | 357 | } |
olympux | 11:709f90a3b599 | 358 | // analog output 1 |
olympux | 11:709f90a3b599 | 359 | if (buffer[RECEIVING_PROTOCOL_EN_A1O_POS] == RECEIVING_PROTOCOL_ENABLE_OUTPUT) { |
olympux | 11:709f90a3b599 | 360 | printf("Update analog output 1\r\n"); |
olympux | 9:d2534ecf88c6 | 361 | } |
olympux | 9:d2534ecf88c6 | 362 | // UART |
olympux | 11:709f90a3b599 | 363 | if (buffer[RECEIVING_PROTOCOL_EN_UART_POS] == RECEIVING_PROTOCOL_ENABLE_OUTPUT) { |
olympux | 11:709f90a3b599 | 364 | printf("UART data: "); |
olympux | 11:709f90a3b599 | 365 | char str_uart[33]; |
olympux | 11:709f90a3b599 | 366 | memcpy(str_uart, &buffer[RECEIVING_PROTOCOL_UART_POS], 32); |
olympux | 11:709f90a3b599 | 367 | str_uart[32] = '\0'; |
olympux | 11:709f90a3b599 | 368 | printf("%s\r\n", str_uart); |
olympux | 9:d2534ecf88c6 | 369 | } |
olympux | 9:d2534ecf88c6 | 370 | |
olympux | 9:d2534ecf88c6 | 371 | // then, check query status command and sending protocol if required |
olympux | 11:709f90a3b599 | 372 | if (buffer[RECEIVING_PROTOCOL_COMMAND_POS] == QUERY_STATUS_COMMAND) { |
olympux | 11:709f90a3b599 | 373 | printf("Sent device status through TCP\r\n"); |
olympux | 9:d2534ecf88c6 | 374 | // sending protocol |
olympux | 12:7c152c0ca4d8 | 375 | update_sending_frame(buffer); |
olympux | 11:709f90a3b599 | 376 | tcp_client.send_all(buffer, SENDING_PROTOCOL_LENGTH); |
olympux | 9:d2534ecf88c6 | 377 | } |
olympux | 9:d2534ecf88c6 | 378 | |
olympux | 9:d2534ecf88c6 | 379 | break; |
olympux | 9:d2534ecf88c6 | 380 | } |
olympux | 9:d2534ecf88c6 | 381 | default: |
olympux | 9:d2534ecf88c6 | 382 | break; |
olympux | 9:d2534ecf88c6 | 383 | } |
olympux | 9:d2534ecf88c6 | 384 | |
olympux | 4:568c97f2a407 | 385 | } // end loop if no data received within timeout |
olympux | 4:568c97f2a407 | 386 | tcp_client.close(); |
olympux | 4:568c97f2a407 | 387 | } // if client connected |
olympux | 4:568c97f2a407 | 388 | } // if no client connected |
olympux | 3:972ed747474c | 389 | #endif |
olympux | 3:972ed747474c | 390 | |
olympux | 9:d2534ecf88c6 | 391 | |
olympux | 9:d2534ecf88c6 | 392 | |
olympux | 9:d2534ecf88c6 | 393 | // ONLY FOR CONFIGRATION |
olympux | 9:d2534ecf88c6 | 394 | #ifdef UDP_SERVER |
olympux | 4:568c97f2a407 | 395 | // wait for udp packet within timeout |
olympux | 9:d2534ecf88c6 | 396 | n = udp_server.receiveFrom(ep_udp_client, buffer, sizeof(buffer)); |
olympux | 9:d2534ecf88c6 | 397 | if (n <= 0) continue; |
olympux | 3:972ed747474c | 398 | |
olympux | 9:d2534ecf88c6 | 399 | // got some data, test it |
olympux | 11:709f90a3b599 | 400 | printf("UDP received: %s\r\n", buffer); |
olympux | 11:709f90a3b599 | 401 | |
olympux | 9:d2534ecf88c6 | 402 | //// send to uart |
olympux | 7:d45bd480e90f | 403 | //buffer[n] = '\0'; |
olympux | 7:d45bd480e90f | 404 | //message.len = n; |
olympux | 7:d45bd480e90f | 405 | //message.msg = buffer; |
olympux | 7:d45bd480e90f | 406 | //uart_queue.put(&message); |
olympux | 9:d2534ecf88c6 | 407 | //// echo |
olympux | 11:709f90a3b599 | 408 | //printf("Received packet from: %s\r\n", client.get_address()); |
olympux | 7:d45bd480e90f | 409 | //udp_server.sendTo(ep_udp_client, buffer, n); |
olympux | 4:568c97f2a407 | 410 | |
olympux | 6:d054e394fba3 | 411 | // process received data |
olympux | 6:d054e394fba3 | 412 | switch (n) { |
olympux | 9:d2534ecf88c6 | 413 | // length = 6, a CONFIGURATION command (discovery command, TCP port, or UDP port) |
olympux | 9:d2534ecf88c6 | 414 | // Format: NNIODS, NNIOTP or NNIOUP |
olympux | 9:d2534ecf88c6 | 415 | case 6: |
olympux | 7:d45bd480e90f | 416 | // discovery command |
olympux | 9:d2534ecf88c6 | 417 | if (strstr(buffer, "NNIODS") != NULL) { |
olympux | 14:18eda020a589 | 418 | udp_server.sendTo(ep_udp_client, eth.getIPAddress(), strlen(eth.getIPAddress())); |
olympux | 10:4cd965d79de0 | 419 | } // NNIODS |
olympux | 7:d45bd480e90f | 420 | // ask for TCP server port |
olympux | 9:d2534ecf88c6 | 421 | else if (strstr(buffer, "NNIOTP") != NULL) { |
olympux | 7:d45bd480e90f | 422 | char port[5]; |
olympux | 12:7c152c0ca4d8 | 423 | sprintf(port, "%5d", tcp_server_local_port); |
olympux | 7:d45bd480e90f | 424 | udp_server.sendTo(ep_udp_client, port, strlen(port)); |
olympux | 10:4cd965d79de0 | 425 | } // NNIOTP |
olympux | 7:d45bd480e90f | 426 | // ask for UDP server port |
olympux | 9:d2534ecf88c6 | 427 | else if (strstr(buffer, "NNIOUP") != NULL) { |
olympux | 7:d45bd480e90f | 428 | char port[5]; |
olympux | 12:7c152c0ca4d8 | 429 | sprintf(port, "%5d", udp_server_local_port); |
olympux | 7:d45bd480e90f | 430 | udp_server.sendTo(ep_udp_client, port, strlen(port)); |
olympux | 10:4cd965d79de0 | 431 | } // NNIOUP |
olympux | 10:4cd965d79de0 | 432 | else if (strstr(buffer, "NNIOTM") != NULL) { |
olympux | 10:4cd965d79de0 | 433 | #ifdef NTP |
olympux | 10:4cd965d79de0 | 434 | char str_time[50]; |
olympux | 10:4cd965d79de0 | 435 | |
olympux | 11:709f90a3b599 | 436 | printf("Trying to update time...\r\n"); |
olympux | 10:4cd965d79de0 | 437 | if (ntp.setTime("0.pool.ntp.org") == 0) { |
olympux | 11:709f90a3b599 | 438 | printf("Set time successfully\r\n"); |
olympux | 10:4cd965d79de0 | 439 | time_t ctTime; |
olympux | 10:4cd965d79de0 | 440 | ctTime = time(NULL); |
olympux | 10:4cd965d79de0 | 441 | |
olympux | 11:709f90a3b599 | 442 | printf("Time is set to (UTC): %s\r\n", ctime(&ctTime)); |
olympux | 10:4cd965d79de0 | 443 | sprintf(str_time, "%s", ctime(&ctTime)); |
olympux | 10:4cd965d79de0 | 444 | udp_server.sendTo(ep_udp_client, str_time, strlen(str_time)); |
olympux | 10:4cd965d79de0 | 445 | } |
olympux | 10:4cd965d79de0 | 446 | else { |
olympux | 11:709f90a3b599 | 447 | printf("Error\r\n"); |
olympux | 10:4cd965d79de0 | 448 | sprintf(str_time, "ERR"); |
olympux | 10:4cd965d79de0 | 449 | udp_server.sendTo(ep_udp_client, str_time, strlen(str_time)); |
olympux | 10:4cd965d79de0 | 450 | } |
olympux | 10:4cd965d79de0 | 451 | #elif |
olympux | 11:709f90a3b599 | 452 | printf("NTP disabled\r\n"); |
olympux | 10:4cd965d79de0 | 453 | sprintf(str_time, "DIS"); |
olympux | 10:4cd965d79de0 | 454 | udp_server.sendTo(ep_udp_client, str_time, strlen(str_time)); |
olympux | 10:4cd965d79de0 | 455 | #endif |
olympux | 10:4cd965d79de0 | 456 | } // NNIOTM |
olympux | 10:4cd965d79de0 | 457 | |
olympux | 7:d45bd480e90f | 458 | break; |
olympux | 9:d2534ecf88c6 | 459 | // length = 19, SET NETWORK CONFIGURATION |
olympux | 9:d2534ecf88c6 | 460 | // Format: 4E 4E 49 4F C0 A8 00 78 FF FF FF 00 C0 A8 00 01 00 00 01 |
olympux | 9:d2534ecf88c6 | 461 | // (NNIO; IP: 192.168.0.120; Subnet: 255.255.255.0; GW: 192.168.0.1; MAC: 0 0 1) |
olympux | 9:d2534ecf88c6 | 462 | case 19:{ |
olympux | 9:d2534ecf88c6 | 463 | // check device id |
olympux | 9:d2534ecf88c6 | 464 | char* id = strstr(buffer, DEVICE_ID); |
olympux | 9:d2534ecf88c6 | 465 | if (id == NULL) |
olympux | 9:d2534ecf88c6 | 466 | break; |
olympux | 9:d2534ecf88c6 | 467 | else if ((id - buffer) > 0) |
olympux | 9:d2534ecf88c6 | 468 | break; |
olympux | 9:d2534ecf88c6 | 469 | |
olympux | 11:709f90a3b599 | 470 | printf("Received user configuration\r\n"); |
olympux | 12:7c152c0ca4d8 | 471 | write_eeprom_network(&buffer[4]); // parameters from 3rd char, 15-bytes |
olympux | 6:d054e394fba3 | 472 | break; |
olympux | 9:d2534ecf88c6 | 473 | } |
olympux | 6:d054e394fba3 | 474 | default: |
olympux | 6:d054e394fba3 | 475 | break; |
olympux | 4:568c97f2a407 | 476 | } |
olympux | 3:972ed747474c | 477 | #endif |
olympux | 4:568c97f2a407 | 478 | } // network processor |
olympux | 11:709f90a3b599 | 479 | } |
olympux | 11:709f90a3b599 | 480 | |
olympux | 12:7c152c0ca4d8 | 481 | /* |
olympux | 12:7c152c0ca4d8 | 482 | * Update digital outputs following receiving frame from TCP client |
olympux | 12:7c152c0ca4d8 | 483 | */ |
olympux | 12:7c152c0ca4d8 | 484 | void update_digital_outputs(char* buf) { |
olympux | 12:7c152c0ca4d8 | 485 | printf("Digital outputs: %s\n", buf); |
olympux | 11:709f90a3b599 | 486 | |
olympux | 12:7c152c0ca4d8 | 487 | dout0 = (buf[0] == DIGITAL_HIGH)? 1 : 0; |
olympux | 12:7c152c0ca4d8 | 488 | dout1 = (buf[1] == DIGITAL_HIGH)? 1 : 0; |
olympux | 12:7c152c0ca4d8 | 489 | dout2 = (buf[2] == DIGITAL_HIGH)? 1 : 0; |
olympux | 12:7c152c0ca4d8 | 490 | dout3 = (buf[3] == DIGITAL_HIGH)? 1 : 0; |
olympux | 12:7c152c0ca4d8 | 491 | dout4 = (buf[4] == DIGITAL_HIGH)? 1 : 0; |
olympux | 12:7c152c0ca4d8 | 492 | dout5 = (buf[5] == DIGITAL_HIGH)? 1 : 0; |
olympux | 12:7c152c0ca4d8 | 493 | dout6 = (buf[6] == DIGITAL_HIGH)? 1 : 0; |
olympux | 12:7c152c0ca4d8 | 494 | dout7 = (buf[7] == DIGITAL_HIGH)? 1 : 0; |
olympux | 12:7c152c0ca4d8 | 495 | } |
olympux | 12:7c152c0ca4d8 | 496 | |
olympux | 12:7c152c0ca4d8 | 497 | void update_sending_frame(char* buf) { |
olympux | 12:7c152c0ca4d8 | 498 | memcpy(&buf[SENDING_PROTOCOL_ID_POS], DEVICE_ID, 4); // device id |
olympux | 12:7c152c0ca4d8 | 499 | memcpy(&buf[SENDING_PROTOCOL_MAC_POS], &u8mac, 6); |
olympux | 12:7c152c0ca4d8 | 500 | memcpy(&buf[SENDING_PROTOCOL_IP_POS], &u8ip_addr, 4); |
olympux | 11:709f90a3b599 | 501 | |
olympux | 12:7c152c0ca4d8 | 502 | buf[SENDING_PROTOCOL_DI_POS+0] = (din0 == 1) ? DIGITAL_HIGH : DIGITAL_LOW; |
olympux | 12:7c152c0ca4d8 | 503 | buf[SENDING_PROTOCOL_DI_POS+1] = (din1 == 1) ? DIGITAL_HIGH : DIGITAL_LOW; |
olympux | 12:7c152c0ca4d8 | 504 | buf[SENDING_PROTOCOL_DI_POS+2] = (din2 == 1) ? DIGITAL_HIGH : DIGITAL_LOW; |
olympux | 12:7c152c0ca4d8 | 505 | buf[SENDING_PROTOCOL_DI_POS+3] = (din3 == 1) ? DIGITAL_HIGH : DIGITAL_LOW; |
olympux | 12:7c152c0ca4d8 | 506 | buf[SENDING_PROTOCOL_DI_POS+4] = (din4 == 1) ? DIGITAL_HIGH : DIGITAL_LOW; |
olympux | 12:7c152c0ca4d8 | 507 | buf[SENDING_PROTOCOL_DI_POS+5] = (din5 == 1) ? DIGITAL_HIGH : DIGITAL_LOW; |
olympux | 12:7c152c0ca4d8 | 508 | buf[SENDING_PROTOCOL_DI_POS+6] = (din6 == 1) ? DIGITAL_HIGH : DIGITAL_LOW; |
olympux | 12:7c152c0ca4d8 | 509 | buf[SENDING_PROTOCOL_DI_POS+7] = (din7 == 1) ? DIGITAL_HIGH : DIGITAL_LOW; |
olympux | 11:709f90a3b599 | 510 | |
olympux | 12:7c152c0ca4d8 | 511 | buf[SENDING_PROTOCOL_DO_POS+0] = (dout0 == 1) ? DIGITAL_HIGH : DIGITAL_LOW; |
olympux | 12:7c152c0ca4d8 | 512 | buf[SENDING_PROTOCOL_DO_POS+1] = (dout1 == 1) ? DIGITAL_HIGH : DIGITAL_LOW; |
olympux | 12:7c152c0ca4d8 | 513 | buf[SENDING_PROTOCOL_DO_POS+2] = (dout2 == 1) ? DIGITAL_HIGH : DIGITAL_LOW; |
olympux | 12:7c152c0ca4d8 | 514 | buf[SENDING_PROTOCOL_DO_POS+3] = (dout3 == 1) ? DIGITAL_HIGH : DIGITAL_LOW; |
olympux | 12:7c152c0ca4d8 | 515 | buf[SENDING_PROTOCOL_DO_POS+4] = (dout4 == 1) ? DIGITAL_HIGH : DIGITAL_LOW; |
olympux | 12:7c152c0ca4d8 | 516 | buf[SENDING_PROTOCOL_DO_POS+5] = (dout5 == 1) ? DIGITAL_HIGH : DIGITAL_LOW; |
olympux | 12:7c152c0ca4d8 | 517 | buf[SENDING_PROTOCOL_DO_POS+6] = (dout6 == 1) ? DIGITAL_HIGH : DIGITAL_LOW; |
olympux | 12:7c152c0ca4d8 | 518 | buf[SENDING_PROTOCOL_DO_POS+7] = (dout7 == 1) ? DIGITAL_HIGH : DIGITAL_LOW; |
olympux | 11:709f90a3b599 | 519 | |
olympux | 12:7c152c0ca4d8 | 520 | uint16_t val = ain0.read_u16(); |
olympux | 12:7c152c0ca4d8 | 521 | memcpy(&buf[SENDING_PROTOCOL_AI0_POS], &val, 2); |
olympux | 12:7c152c0ca4d8 | 522 | val = ain1.read_u16(); |
olympux | 12:7c152c0ca4d8 | 523 | memcpy(&buf[SENDING_PROTOCOL_AI1_POS], &val, 2); |
olympux | 12:7c152c0ca4d8 | 524 | val = 0; |
olympux | 12:7c152c0ca4d8 | 525 | memcpy(&buf[SENDING_PROTOCOL_AO0_POS], &val, 2); |
olympux | 12:7c152c0ca4d8 | 526 | val = 0; |
olympux | 12:7c152c0ca4d8 | 527 | memcpy(&buf[SENDING_PROTOCOL_AO1_POS], &val, 2); |
olympux | 12:7c152c0ca4d8 | 528 | buf[SENDING_PROTOCOL_CR_POS] = 0x0D; |
olympux | 12:7c152c0ca4d8 | 529 | buf[SENDING_PROTOCOL_CR_POS+1] = '\0'; |
olympux | 4:568c97f2a407 | 530 | } |