| | |
| | | #include "lwip/tcp.h" |
| | | #include "lwip/inet.h" |
| | | |
| | | |
| | | #define DEVICE_PORT 5025 |
| | | #define CONTROL_PORT 5026 |
| | | |
| | | #define SCPI_THREAD_PRIO (tskIDLE_PRIORITY + 2) |
| | | |
| | | #define SCPI_MSG_TIMEOUT 0 |
| | |
| | | iprintf("**ERROR: %ld, \"%s\"\r\n", (int32_t) err, SCPI_ErrorTranslate(err)); |
| | | if (err != 0) { |
| | | /* New error */ |
| | | /* Beep */ |
| | | /* Error LED ON */ |
| | | SCPI_Event_ErrorIndicatorOn(context, err); |
| | | } else { |
| | | /* No more errors in the queue */ |
| | | /* Error LED OFF */ |
| | | SCPI_Event_ErrorIndicatorOff(context, err); |
| | | } |
| | | return 0; |
| | | } |
| | |
| | | } |
| | | |
| | | scpi_result_t SCPI_SystemCommTcpipControlQ(scpi_t * context) { |
| | | SCPI_ResultInt(context, CONTROL_PORT); |
| | | SCPI_ResultInt(context, SCPI_CONTROL_PORT); |
| | | return SCPI_RES_OK; |
| | | } |
| | | |
| | |
| | | netconn_delete(newconn); |
| | | } else { |
| | | /* connection established */ |
| | | SCPI_Event_DeviceConnected(newconn); |
| | | iprintf("***Connection established %s\r\n", inet_ntoa(newconn->pcb.ip->remote_ip)); |
| | | user_data->io = newconn; |
| | | } |
| | |
| | | |
| | | static void closeIo(user_data_t * user_data) { |
| | | /* connection closed */ |
| | | SCPI_Event_DeviceDisconnected(user_data->io); |
| | | netconn_close(user_data->io); |
| | | netconn_delete(user_data->io); |
| | | user_data->io = NULL; |
| | |
| | | |
| | | scpi_context.user_context = &user_data; |
| | | |
| | | user_data.io_listen = createServer(DEVICE_PORT); |
| | | user_data.io_listen = createServer(SCPI_DEVICE_PORT); |
| | | LWIP_ASSERT("user_data.io_listen != NULL", user_data.io_listen != NULL); |
| | | |
| | | user_data.control_io_listen = createServer(CONTROL_PORT); |
| | | user_data.control_io_listen = createServer(SCPI_CONTROL_PORT); |
| | | LWIP_ASSERT("user_data.control_io_listen != NULL", user_data.control_io_listen != NULL); |
| | | |
| | | while (1) { |
| | |
| | | xReturned = xTaskCreate(scpi_server_thread, "SCPI", DEFAULT_THREAD_STACKSIZE, NULL, SCPI_THREAD_PRIO, &xHandle); |
| | | LWIP_ASSERT("scpi_server_init failed", xReturned == pdPASS); |
| | | } |
| | | |
| | | /* Called by processIoListen() for additional reporting. Override on demand. */ |
| | | void __attribute__((weak)) SCPI_Event_DeviceConnected(struct netconn * conn) { |
| | | /* Remote or Eth LED ON */ |
| | | } |
| | | |
| | | /* Called by closeIO() for additional reporting. Override on demand. */ |
| | | void __attribute__((weak)) SCPI_Event_DeviceDisconnected(struct netconn * conn) { |
| | | /* Remote or Eth LED OFF */ |
| | | } |
| | | |
| | | /* Called by SCPI_Error() for reporting. Override on demand. */ |
| | | void __attribute__((weak)) SCPI_Event_ErrorIndicatorOn(scpi_t * context, int_fast16_t err) { |
| | | /* New error : Beep, Error LED ON */ |
| | | } |
| | | |
| | | /* Called by SCPI_Error() for reporting. Override on demand. */ |
| | | void __attribute__((weak)) SCPI_Event_ErrorIndicatorOff(scpi_t * context, int_fast16_t err) { |
| | | /* No more errors in the queue : Error LED OFF */ |
| | | } |