您好,各位大佬朋友们!
目前小弟在用正点原子STM32F767 + FreeRTOS +LWIP 调试UDP以及TCP服务器端。。
1. 系统仅存在UART串口printf,以及ETH。其他外设均无
2. udpTask + tcpTask + DefaultTask(默认执行周期20ms,使用osDelay(20)延时)
3. udpTask任务内仅包含:udp_send函数
4. tcpTask任务无任何内容,只有osDelay(20);
5. default任务无任何内容,只有osDelay(10);
遇到的问题:
1. 移植STM32F7官方udp 例程,初始化等操作。可ping通,然后通过udp接收回调函数,反馈接受的内容实现,收发。
2. udp_send HAL接口,不定期不定时返回-4(概率比较大)偶尔-8,err。此时在windows相关小黄人助手里面看到接收的字节大概为20W左右(17字节一帧,20ms周期)。有些时候会达到300W字节。就开始返回-4.
3. FreeRTSO系统正常运行。ETH 的udp send发送失败。以太网RJ45灯灭。ping不通。
跪求各位大佬给一些建议或者入手查看思路。真的快被逼疯了。
以下附上部分源码:
1. 创建三个Task;
/* Create the thread(s) */
/* definition and creation of defaultTask */
osThreadDef(defaultTask, StartDefaultTask, osPriorityNormal, 0, 128);
defaultTaskHandle = osThreadCreate(osThread(defaultTask), NULL);
/* USER CODE BEGIN RTOS_THREADS */
/* definition and creation of myTaskLED */
osThreadDef(udpTaskA, udpTask, osPriorityIdle, 0, 1024);
UDPTaskHandle = osThreadCreate(osThread(udpTaskA), NULL);
/* definition and creation of myTaskTCP */
osThreadDef(tcpTaskB, tcpTask, osPriorityIdle, 0, 512);
TCPServerHandle = osThreadCreate(osThread(tcpTaskB), NULL);
/* USER CODE END RTOS_THREADS */
2. UDP发送任务
void udpTask(void const * argument)
{
UINT8 tempA = 0xFF;
UINT8 i = 0;
udp_echoserver_init();
printf("UDP Task ok \n");
/* Infinite loop */
for(;;)
{
//CheckNaviMessagePacket(&naviMessage,sizeof(naviMessage));
UDPSendMessage(NULL,sizeof(NS_CtrlInfo_t));
osDelay(20);
}
/* USER CODE END LEDTask */
}
3. 回调函数
void udp_echoserver_receive_callback(void *arg, struct udp_pcb *upcb, struct pbuf *p, const ip_addr_t *addr, UINT16 port)
{
/* Connect to the remote client */
udp_connect(upcb, addr, UDP_CLIENT_PORT);
/*GetNaviMessage(&p->payload,p->len);*/
memset(recdata,0,sizeof(recdata));
memcpy((char *)recdata,p->payload,p->len);
/* Tell the client that we have accepted it */
udp_send(upcb, p);
/* free the UDP connection, so we can accept new clients */
udp_disconnect(upcb);
/* Free the p buffer */
pbuf_free(p);
}
4. 实际udpTask发送内容
void UDPSendMessage(UINT8 *ptrMsg, UINT8 Len)
{
UINT8 srcIP[4] = {192,168,12,99};
err_t ret;
struct pbuf *ptr;
ptr=pbuf_alloc(PBUF_TRANSPORT,strlen((char*)recdata),PBUF_POOL); //申请内存
if(ptr)
{
udp_connect(udpTaskPCB, srcIP, UDP_CLIENT_PORT);
ptr->payload=(void*)recdata;
ptr->len = sizeof(recdata);
ret = udp_send(udpTaskPCB,ptr); //udp发送数据
udp_disconnect(udpTaskPCB);
pbuf_free(ptr);//释放内存
printf("Ret %d \n",ret);
}
}
5. udp初始化
void udp_echoserver_init(void)
{
err_t err;
/* Create a new UDP control block */
udpTaskPCB = udp_new(); //创建一个新的UDP控制块
if (udpTaskPCB)
{
/* Bind the udpTaskPCB to the UDP_PORT port */
/* Using IP_ADDR_ANY allow the udpTaskPCB to be used by any local interface */
err = udp_bind(udpTaskPCB, IP_ADDR_ANY, UDP_SERVER_PORT); //绑定本地IP地址及端口
if(err == ERR_OK)
{
/* Set a receive callback for the upcb */
udp_recv(udpTaskPCB, udp_echoserver_receive_callback, NULL); //注册接收数据回调函数
}
else
{
udp_remove(udpTaskPCB);
printf("can not bind pcb");
}
}
else
{
printf("can not create pcb");
}
}
跪求各位大佬给指点!!!!!!!!谢谢~!!!!!! |
|