Доброго времени суток, уважаемые коллеги! Встала задача принимать пакеты из UART и передавать их в сеть. Запустил задачу-сервер на Socket API из примера ST, проверил, send - receive работает. Но когда дело дошло до реальной реализации, выяснилось, что функции accept и receive намертво блокируют задачу. Блокировку функцией accept решил вот такой нехитрой конструкцией:
if (accept_state==0){
newconn = accept(sock, (struct sockaddr *)&remotehost, (socklen_t *)&size);//принимаем входящее подключение
accept_state=1;
}
То есть, сервер принимает только одно входящее подключение. Общий вид главного цикла задачи-сервера:
while (1)
{
if (accept_state==0){
newconn = accept(sock, (struct sockaddr *)&remotehost, (socklen_t *)&size);//принимаем входящее подключение
accept_state=1;
}
event=osMessageGet(UART_RX_QHandle,10);//получаем указатель на структуру, которую нужно передать в сокет
if (event.status==osEventMessage){
printf ("Queue received at %lu\r\n", osKernelSysTick());
pDataToSend=(UART_RX_Data*)event.value.v;
HAL_GPIO_TogglePin(LD2_GPIO_Port,LD2_Pin);
send(newconn, pDataToSend->payload, pDataToSend->size, 0);//отправляем данные в сокет
HAL_UART_Receive_IT(&huart3,uartRXBuffer,UART3RX_BUF_SIZE);//включаем приём в UART
printf ("Switch context at %lu\r\n", osKernelSysTick());
osThreadYield();
}
}
в общем, циклично, по приходу пакета в UART, в задачу-сервер через очередь передается указатель на данные, которые нужно отправить в сокет.
Вот теперь возникли два вопроса. Первый - как корректно завершить соединение по запросу от клиента? Попробовал сделать так:
nbytes=recv(newconn, rxBuf, BUFLEN, MSG_PEEK);
if (nbytes<=0){
close(newconn);
}
Сразу перестала работать очередь, потому что функция recv наглухо блокирует задачу. Что подскажете?
И второй вопрос. Как отслеживать физический дисконнект? Может, кто уже решал эту задачу?
