访问子线程中的套接字描述符时"Bad file descriptor"

"Bad file descriptor" when accessing socket descriptor in child thread

本文关键字：Bad file descriptor 描述 线程 套接字 访问      更新时间：2023-10-16

当尝试访问子线程中的套接字描述符（使用bind（）或listen（））时，我得到错误：

错误的文件描述符

以下是代码（忽略标题）：

class task {
private:
    std::int32_t        socFd;
    std::string         path;
    char                buffer[MAX_SOC_BUFFER];
    struct sockaddr_un  socAddr;
public:
    void init() {
        if ((socFd = socket((std::int32_t)AF_UNIX, (std::int32_t)SOCK_STREAM, 0)) == -1) {
            perror("socket");
            exit(1);
        }
        socAddr.sun_family = AF_UNIX;
        strcpy(socAddr.sun_path, getSocPath().c_str());
    }
    task(const std::string& path) : path{path}
    {
        init();
    }
    auto getSocketFd() ->decltype(socFd) {
        return socFd;
    }
    const std::string& getSocPath() {
        return path;
    }
    auto getSocAddr() -> decltype(socAddr)&
    {
        return socAddr;
    }
    char* getBuff() {
        return buffer;
    }
    virtual ~ task() {
        close(getSocketFd());
    }
};

class server_task : public task{
public:
    void init () {
        ::unlink(getSocPath().c_str());
        size_t len = sizeof(getSocAddr());
        if (bind(getSocketFd(), (struct sockaddr *)&(getSocAddr()), len) == -1) {
            perror("bind");
            exit(1);
        }
    }
    server_task(const std::string& path) : task(path)
    {
        init();
    }
    void operator()() {
        struct sockaddr_un remote;
        if (listen(getSocketFd(), 5) == -1) {
            perror("listen");
            exit(1);
        }
        for(;;) {
            int done, n, socFd2;
            printf("Waiting for a connection...n");
            socklen_t t = sizeof(remote);
            if ((socFd2 = accept(getSocketFd(), (struct sockaddr *)&remote, &t)) == -1) {
                perror("accept");
                exit(1);
            }
            printf("Connected.n");
            done = 0;
            do {
                n = recv(socFd2, getBuff(), 100, 0);
                if (n <= 0) {
                    if (n < 0) perror("recv");
                    done = 1;
                }
                if (!done) {
                    std::string buffStr(getBuff());
                    std::transform(buffStr.begin(), buffStr.end(),buffStr.begin(), ::toupper);
                    if (send(socFd2, buffStr.c_str(), n, 0) < 0) {
                        perror("send");
                        done = 1;
                    }
                }
            } while (!done);
            close(socFd2);
        }
    }
};

int main(){
std::vector<std::thread> threads;
server_task server("/tmp/temp_socket");
threads.push_back(std::thread(server));
for(auto& thread : threads)
    thread.join();
return 0;

}

如果我将main()功能更改为：

int main(){
    server_task server("/tmp/temp_socket");
    server();
    return 0;
}

没有发生这样的错误。据我所知，文件描述符表在父进程及其子线程之间共享，因此套接字句柄应该是有效的。

我做错了什么？

threads.push_back(std::thread(server));

这会创建server对象的至少一个副本，可能是多个副本，并且因为您没有定义副本构造函数，所以每个副本都共享同一个套接字，第一个超出范围的副本会关闭套接字。当新线程启动时，临时副本已经被销毁并关闭了套接字，因此在新线程中运行的server_task的副本指的是一个关闭的套接字。

您应该为task和server_task类型定义一个移动构造函数，以便套接字的所有权被转移而不是复制，然后将对象移动到线程中：

thread.push_back(std::thread(std::move(server)));

否则，您应该通过引用将服务器传递给新线程，这样就没有副本：

thread.push_back(std::thread(std::ref(server)));
相关文章：