0

我有个问题。我的程序同时包含 10 个 TCP Server。一旦注意到来自客户端的请求，适当的 tcp 服务器套接字将接受连接并在单独的线程中处理它。我知道这不是解决我的实际问题的最有效方法，但没关系..

在 main 我有一个 for 循环，它将调用一个名为 Peer 的对象中的函数，它是 StartThread()

for (it= ListOfPeers.begin();it!= ListOfPeers.end();it++)
{
    (*it).second->StartThread();
}

当然，在某些条件下会使用此循环，但我想尽可能地缩小代码范围。

函数 StartThread 将在每个对等对象中调用：

    void StartThread()
{
    pthread_t threadDoEvent;
    pthread_create( &threadDoEvent, NULL, &DoEvent_helper,this);
    pthread_detach(threadDoEvent);
}

void *DoEvent_helper( void *ptr ) // Helper to implement thread
{
    return ((Peer *)ptr)->DoEvent();
}

DoEvent 是处理请求和连接的函数：

void* DoEvent()
{
    unsigned char  buffer[1024];
    int rc;
    int    close_conn= FALSE;
    int new_sd;

    new_sd = accept(Socket, NULL, NULL);
    if (new_sd < 0)
    {
        if (errno != EWOULDBLOCK)
        {
            perror("  accept() failed");
            close_conn = TRUE;
        }
    }


    do
    {
        rc = recv(new_sd, buffer, sizeof(buffer), 0);
        if (rc < 0)
        {
            if (errno != EWOULDBLOCK)
            {
                perror("  recv() failed");
                close_conn = TRUE;
            }
            break;
        }

        if (rc == 0)
        {
            printf("  Connection closed\n");
            close_conn = TRUE;
            break;
        }

[DO SOMETHING WITH THE BUFFER]

        rc = send(new_sd, buffer, len, 0);
        if (rc <= 0)
        {
            perror("  send() failed");
            close_conn = TRUE;
            break;
        }
    }while (close_conn==FALSE);
     close(new_sd);
}

我的问题是为什么我收到一个错误：recv() failed: Bad file descriptor???? 当我在 pthread_create 和 pthread_detach 之间添加 sleep(1) 时，一切正常！有人可以向我解释这种情况吗？或者也许可以帮助我解决我的问题？

谢谢！

4

2 回答 2

1

好吧，即使失败，您也会尝试接收。accept这使我相信您Socket在尝试接受被动文件描述符之前没有正确设置它。

如果您在主线程中设置Socket描述符，则可能是新线程在您执行此操作之前启动并运行。

于 2013-09-12T07:46:32.987 回答
0

确保 new_sd 在持久内存中。例如，如果它是由启动线程并退出的函数分配的，那么 new_sd 将指向垃圾。（至少对我来说是这样）

于 2013-12-13T21:42:29.503 回答