在另一个线程上更改pollfd时Linux和OS之间的轮询()差异

Question

我试图让libwebsocket在OS上的多线程环境中运行。我无法触发从与主服务线程不同的线程发送数据。在libwebsocket文档中，暗示这是可能的(演示代码、邮寄名单)。因此，我深入研究了代码，并发现了轮询()函数中的问题。

对于作为参数给出的struct pollfd，民意测验()的表现似乎有所不同。libwebsockets依赖于在fds.event ()处于活动状态时更改字段的可能性。这在Linux上运行得很好，但在OS上却不起作用。

我编写了一个小测试程序来演示这种行为：

#include <unistd.h>
#include <netdb.h>
#include <poll.h>
#include <iostream>
#include <thread>

#define PORT "3490"

struct pollfd    fds[1];
bool connected = false;

void main_loop() {
    int sockfd, new_fd; 
    struct addrinfo hints, *servinfo, *p;
    socklen_t sin_size;
    int yes=1;
    char s[INET6_ADDRSTRLEN];
    int rv;

    memset(&hints, 0, sizeof hints);
    hints.ai_family = AF_INET;
    hints.ai_socktype = SOCK_STREAM;
    hints.ai_flags = AI_PASSIVE; 

    if ((rv = getaddrinfo(NULL, PORT, &hints, &servinfo)) != 0) {
        fprintf(stderr, "getaddrinfo: %s\n", gai_strerror(rv));
        return;
    }

    for(p = servinfo; p != NULL; p = p->ai_next) {
        if ((sockfd = socket(p->ai_family, p->ai_socktype, p->ai_protocol)) == -1) {
            perror("server: socket");
            continue;
        }

        if (setsockopt(sockfd, SOL_SOCKET, SO_REUSEADDR, &yes, sizeof(int)) == -1) {
            perror("setsockopt");
            exit(1);
        }

        if (bind(sockfd, p->ai_addr, p->ai_addrlen) == -1) {
            close(sockfd);
            perror("server: bind");
            continue;
        }

        break;
    }

    freeaddrinfo(servinfo);

    if (p == NULL)  {
        fprintf(stderr, "server: failed to bind\n");
        exit(1);
    }

    if (listen(sockfd, 10) == -1) {
        perror("listen");
        exit(1);
    }

    printf("server: waiting for connections...\n");

    new_fd = accept(sockfd, NULL, &sin_size);
    if (new_fd == -1) {
        perror("accept");
        return;
    }

    fds[0].fd = new_fd;
    fds[0].events = POLLIN;
    connected = true;

    printf("event is %i\n", fds[0].events);
    int ret = poll(fds, 1, 5000);
    printf("event is %i\n", fds[0].events); //expecting 1 on Mac and 5 on Linux

    if (send(new_fd, "Hello, world!\n", 14, 0) == -1)
        perror("send");

    close(new_fd); 
    close(sockfd);
}

void second_thread()
{
    while(connected == false){}
    sleep(1);
    fds[0].events = POLLIN|POLLOUT;
    printf("set event to %i\n", fds[0].events);
}

int main() {

    std::thread t1(main_loop);
    std::thread t2(second_thread);

    t1.join();
    t2.join();

    return 0;
}

使用clang++ -std=c++11 -stdlib=libc++ -o poll poll.cpp在OS上编译，在Linux上使用g++ -std=c++11 -pthread -o poll poll.cpp编译

程序开始监听端口3490。如果您连接到它(例如使用netcat localhost 3490)，它将轮询主线程上的输入，并尝试更改第二个线程中的事件标志。它将在5秒后退出。

OS上的输出：

server: waiting for connections...
event is 1
set event to 5
event is 1

Linux上的输出：

server: waiting for connections...
event is 1
set event to 5
event is 5

所以我的问题是:是否有任何可以解释这种行为的文档？libwebsockets所做的是安全的，期望在投票活动时更改fds.events是合法的？我在手册中找不到关于它的任何细节(OS，Linux)。

Answer 1

一开始，您似乎是说，您发现了一些文档，声称这是支持和定义的行为。我很想知道你在哪里读到的，因为我在民意测验(2)的Linux手册页中，或者在POSIX民意测验手册页()中都找不到任何东西，它记录了一个不同的线程实际上可以改变另一个线程传递给轮询()的事件数组参数中的值，并且不同线程的更改实际上在原始线程的轮询()调用中生效，而不管与内存障碍有关的任何问题，等等。

在我看来，在这个主题上，两页手册似乎都是完全沉默的。它们并不表示这是预期的、支持的或定义的行为；或者这是否是支持的或定义的行为。

一个不同的线程可以修改另一个线程发出的系统调用的参数，在--之后--另一个线程已经进入了syscall，这在我看来是相反的。如果这是受支持的行为，我希望它被显式地记录下来，并且我在Linux或POSIX手册页中找不到对它的任何引用。

话虽如此:即使我将软件的范围限制在Linux上，即使我不需要关心其他平台；考虑到没有任何这方面的文档，而且即使我的测试显示Linux内核实现轮询(2)是这样的，我也不会指望将来的内核版本会继续这样运行。我将无法依赖这种行为，除非使用特定的内核构建来测试它。

因此，要回答您的问题:有关此主题的唯一权威文档是所讨论的手册页。他们没有明确地将此记录为合法行为；尽管他们也没有明确表示这是非法行为，但出于上述原因，我认为这是不支持的、未定义的行为。