freertos+lwip tcp接收数据超时问题

冰水混合物

int8_t send_http_request(char* sendBuf,void (*handle_function)(cJSON* valid_data))
{
        IP4_ADDR(&server_ipaddr,MAIN_SERVER_IP_ADDR0,MAIN_SERVER_IP_ADDR1,MAIN_SERVER_IP_ADDR2,MAIN_SERVER_IP_ADDR3);
        server_port = MAIN_SERVER_PORT;
               
        tcp_clientconn = netconn_new(NETCONN_TCP);
        if(tcp_clientconn==NULL)
        {
                printf("新建连接失败\r\n");
                return;
        }
       
        errCode = netconn_connect(tcp_clientconn,&server_ipaddr,server_port);
        if(errCode == ERR_OK)
        {       
                finalRecvBuf = (char*)mymalloc(4000*sizeof(char));//定义finalRecvBuf长度是数据包的总长度
                memset(finalRecvBuf,0x00,4000);
               
                tcp_clientconn->send_timeout = 3000;//发送超时时间设定3秒
               
                //NETCONN_COPY,会将数据拷贝给内核进程，这种方式，用户可以直接复用buf
                errCode = netconn_write(tcp_clientconn,sendBuf,strlen((const char*) sendBuf),NETCONN_NOCOPY);
//                if(errCode == ERR_OK)
//                {
//                        DEBUG_PRINT_VAR("send sucess\r\n");
//                }
//                else
//                {
//                        DEBUG_PRINT_VAR("send failure\r\n");
//                }
               
                tcp_clientconn->recv_timeout  = 5000;//接收超时时间设定5秒
               
//                netconn_recv(tcp_clientconn,&recevingBuf);

                //循环接收数据
                while(1)
                {
                        errCode = netconn_recv(tcp_clientconn,&recevingBuf);
                        printf("errCode--->%d\r\n",errCode);
                               
                        if(errCode == ERR_OK && recevingBuf!=NULL)
                        {
                                taskENTER_CRITICAL();         //进入临界区                       
                                for(;;)
                                {
                                        //若第一个数据包的长度和总长度大小相等，直接拷贝出来
                                        if(recevingBuf->p->tot_len == recevingBuf->p->len)
                                        {
//                                                DEBUG_PRINT_VAR("尾包数据包------->%s\r\n",(char *)recevingBuf->p->payload);
                                               
                                                strncat(finalRecvBuf,(char *)recevingBuf->p->payload,recevingBuf->p->tot_len);
                                               
                                                break;
                                        }
                                        //若第一个数据包的长度和总长度大小不相等，需要循环将每个包里的内容拼接到buf中
                                        else
                                        {
//                                                DEBUG_PRINT_VAR("单个数据包------->%s\r\n",(char *)recevingBuf->p->payload);
                                               
                                                strncat(finalRecvBuf,(char *)recevingBuf->p->payload,recevingBuf->p->len);
                                               
        //                                        DEBUG_PRINT_VAR("p->payload 累加buf---->%s\r\n",finalRecvBuf);
        //                                        DEBUG_PRINT_VAR("数据包长度--->%d\r\n",strlen(finalRecvBuf));                                               
                                                recevingBuf->p = recevingBuf->p->next;
                                        }
                                }
                                printf("接收正常\r\n");
//                                printf("p->payload total内容是 ---->%s，接收数据长度--->%d\r\n",finalRecvBuf,strlen(finalRecvBuf));                                                                                                               
                                netbuf_delete(recevingBuf);//需要在此时释放recevingBuf否则会导致内存异常
                                recevingBuf = NULL;
                                taskEXIT_CRITICAL();
                        }
                        else if(errCode == ERR_MEM)
                        {
                                break;
                        }
                        else if(errCode == ERR_CLSD)//服务器关闭连接
                        {       
                                errCode = 0;
                                netconn_close(tcp_clientconn);
                                netconn_delete(tcp_clientconn);                               
                                break;
                        }
                        else if(errCode == ERR_TIMEOUT)//超时也break出去
                        {
                                printf("接收超时\r\n");
                                errCode = -1;
                                continue;
                        }                               
                }
}

这个函数接收1000字节以上的数据，能够成功3、4次，之后便一直是超时，很郁闷，求指点迷津

冰水混合物

记录一下，目前已经解决了这个问题。是lwip内存分配策略导致的问题，将pbuf_pool_bufsize 改为了LWIP_MEM_ALIGN_SIZE(TCP_MSS+40+PBUF_LINK_HLEN)，并将分配策略改为MEMP_MEM_MALLOC

冰水混合物

而且是不可恢复的超时，即便新建连接、发送、接收，还是超时，逆天了。ps：接收少量内容<200字节没用这个现象