我已经使用 lwip+freeRTOS 在我的一个嵌入式设备中开发了一个 tcp 服务器。
现在这是我使用我的设备(我们将其命名为 lwipDevice )与其他设备(其他设备具有 Linux 系统,我们将其命名为 LinuxDevice )通信的流程

  • lwipDevice 发送 UDP 数据包到 LinuxDevice 以启动我准备共享我的信息。
  • 现在 LinuxDevice 成功识别此消息并将一个 TCP 数据包(包含命令)发送到 lwipDevice 以告知发送其信息。
  • 但在 lwipDevice 端没有收到此消息。因此它不会向 LinuxDevice 发送任何响应。并且一次又一次地重复步骤 1-3。

  • 现在这是 TCP 服务器的 lwipDevice 代码:
    long server_sock=-1;
    #define FAIL 1
    #define PASS 0
    int CreateTcpServerSocket(long *pSock, int port)
    {
        struct sockaddr_in   sin;
        int addrlen = sizeof(sin);
        int   e;
        struct linger linger;
        linger.l_linger=0;
        int i = 1;
    
        *pSock = socket(AF_INET, SOCK_STREAM, 0);
    
        if (*pSock == -1)
        {
            printf("*** createTcpSercerSocket:open sock error,port %d\n",port);
            return FAIL;
        }
    
        memset((char *)&sin, 0, sizeof(sin));
        sin.sin_family = AF_INET;
        sin.sin_len = sizeof(sin);
        sin.sin_addr.s_addr = htonl(INADDR_ANY);   /* wildcard IP address */
        sin.sin_port = htons(port);
    
    
        e = bind(*pSock, (struct sockaddr*)&sin, addrlen);
        if (e != 0)
        {
            printf("error %d binding tcp listen on port\n");
            closesocket(*pSock);
            *pSock = -1;
            return FAIL;
        }
    
        lwip_ioctl(*pSock, FIONBIO, &i); //Set Non blocking mode
    
        e = listen(*pSock, 2);
    
        if (e != 0)
        {
            pprintf("error :listen on TCP server\n");
            closesocket(*pSock);
            *pSock = -1;
            return FAIL;
        }
    
        return PASS;
    }
    void vTCPTask(void *parm)
    {
        struct sockaddr client; /* for BSDish accept() call */
        int clientsize;
        long sock;
    
        if(CreateTcpServerSocket(&server_sock, 8000) == FAIL) //Here server created successfully
        {
            printf("Fail to create server!!!!!\n");
            server_sock=-1;
        }
    
        while(1)
        {
            // some code for other stuff
    
            sock= accept(server_sock, &client, &clientsize); //This line always fails and reurn -1
    
            if(sock != -1)
            {
                printf("accepted socket:\n\n");
                //...now receive data from client....
                // send some data to client
            }
    
            // some code for other stuff
    
            //sleep for 15 seconds
        }
    
    }
    int main()
    {
    
        //...initilization of lwip stack
        //....some more code
        //...................
    
        xTaskCreate(vTCPTask, (signed char const *) "tcptask",
        356, NULL, 3, (xTaskHandle *)&xNotifierServiceTaskHandle);
    
    
        /* Start the scheduler */
        vTaskStartScheduler();
    
        return 1
    }
    

    我已经检查了 lwip_accept 函数,它将从这种情况返回:
      if (netconn_is_nonblocking(sock->conn) && (sock->rcvevent <= 0))
      {
        LWIP_DEBUGF(SOCKETS_DEBUG, ("lwip_accept(%d): returning EWOULDBLOCK\n", s));
        sock_set_errno(sock, EWOULDBLOCK);
        return -1;
      }
    

    编辑:

    我知道 netconn_is_nonblocking(sock->conn) 条件将始终为真,因为已将套接字设置为非阻塞模式。但是为什么 sock->rcvevent 总是为零,即使 LinuxDevice 已经向它发送了数据包?

    编辑:

    出于测试目的,已对任务中的所有其他代码进行了注释(请参阅 //some code for other stuff ),然后成功接受了套接字,我尝试接收数据包,但现在问题是它现在卡在 lwip_recvfrom 函数中(注意: LinuxDevice 继续发送数据包)。于是进一步调试,发现卡在函数sys_arch_mbox_fetch(函数调用流程:: lwip_recvfrom\netconn_recv\netconn_recv_data\sys_arch_mbox_fetch)中。

    有谁知道它有什么问题?

    最佳答案

    您已将套接字配置为非阻塞,因此 accept() 调用将永远不会阻塞。如果没有未决的传入连接,它将返回 EWOULDBLOCK 错误代码,这就是您所看到的。

    关于c - TCP 服务器在 LWIP+FreeRTOS 中似乎不起作用,我们在Stack Overflow上找到一个类似的问题:https://stackoverflow.com/questions/24968326/

    10-11 19:32