Lwip: netconn TCP app Опции

[k000858]

В проекте используется LwIP + FreeRTOS. Поднят TCP сервер на Netconn API.
Необходимо данные из входящего соединения отправлять в последовательный порт, и в обратную сторону.
Проблема в том, что реализация TCP соединения подразумевает блокирующую функцию обработки принятых данных

Код

            while (netconn_recv(ntcnn232->newc, &buf) == ERR_OK)
            {

То есть пока не принял данные по TCP не могу отправить принятые данные по последовательному порту.

Как быть в этой ситуации?

Пока реализовано так: 2 задачи ОС:
1) сидит в блокирующей функции и отправляет принимаемые данные в последовательный порт
2) отправляет данные, принимаемые по последовательному порту, в TCP

Но это создает кучу проблем, например работа этих задач может "сломать" соединение.

Есть альтернативы как это можно реализовать?

[DeNi]

Можно включить в LWIP таймауты, тогда из функции netconn_recv будет выходить через указанное время, даже если ничего не принято.
#define LWIP_SO_RCVTIMEO 1 // accept, receive
#define LWIP_SO_SNDTIMEO 1 // send

Если надо прервать ожидание netconn_recv из другой задачи, во FreeRTOS можно включить опцию
#define INCLUDE_xTaskAbortDelay 1
и вызовом xTaskAbortDelay(hTask) разблокировать задачу.

И насколько помню в lwip/port/sys_arch.c ожидание из очереди без таймаута там зачем-то обернуто в цикл,
хотя документация на FreeRTOS говорить что вызов xQueueReceive с portMAX_DELAY бесконечный.
Так что если не убрать цикл, задача опять заблокируется.

И есть вариант вообще без надобности не блокировать задачу вызовом netconn_recv,
для этого при создании соединение использовать netconn_new_with_proto_and_callback и назначить callback,
в котором допустим взводить семафор. Сколько раз был вызван callback c NETCONN_EVT_RCVPLUS, столько раз
и надо вызвать netconn_recv. Посмотрите как в LWIP реализованы сокеты, там аналогично сделано.

[k000858]

И есть вариант вообще без надобности не блокировать задачу вызовом netconn_recv,
для этого при создании соединение использовать netconn_new_with_proto_and_callback и назначить callback,
в котором допустим взводить семафор. Сколько раз был вызван callback c NETCONN_EVT_RCVPLUS, столько раз
и надо вызвать netconn_recv. Посмотрите как в LWIP реализованы сокеты, там аналогично сделано.

Такой вариант бы хорошо подошел. можете привести пример кода, особенно интересует часть с закрытием соединения (мы сервер, подключен клиент, клиент закрывает соединение - в калбэке NETCONN_EVT_RCVPLUS 0 длинны) ??? у меня с этим какой то затык.