1

子スレッドで (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;
}

そのようなエラーは発生しません。私が理解しているように、ファイル記述子テーブルは親プロセスとその子スレッド間で共有されるため、ソケットハンドルは有効である必要があります。

私は何を間違っていますか？

4

1 に答える 1

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

これにより、オブジェクトの少なくとも 1 つのコピー、server場合によっては複数のコピーが作成されます。また、コピー コンストラクターを定義していないため、すべてのコピーが同じソケットを共有し、スコープから外れた最初のコピーがソケットを閉じます。新しいスレッドが開始されるまでに一時コピーは破棄され、ソケットが閉じられているためserver_task、新しいスレッドで実行される のコピーは閉じられたソケットを参照します。

taskおよび型の移動コンストラクターを定義してserver_task、ソケットの所有権がコピーされずに転送されるようにし、オブジェクトをスレッドに移動する必要があります。

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

または、サーバーを参照によって新しいスレッドに渡して、コピーがないようにする必要があります。

thread.push_back(std::thread(std::ref(server)));
于 2013-07-24T15:27:50.460 に答える