当在另一个线程上更改pollfd时,Linux和OS X之间poll()的差异

内容导读

互联网集市收集整理的这篇技术教程文章主要介绍了当在另一个线程上更改pollfd时,Linux和OS X之间poll()的差异，小编现在分享给大家，供广大互联网技能从业者学习和参考。文章包含3787字，纯文字阅读大概需要6分钟。

内容图文

我试图在OS X上的多线程环境中运行libwebsockets.我无法触发从主服务线程以外的其他线程发送数据.在libwebsocket docs上暗示这应该是可能的(demo code,mailinglist).所以我挖掘代码并在poll()函数中发现了问题.

似乎poll()在作为参数给出的struct pollfd方面表现不同.当poll()处于活动状态时,libwebsockets依赖于更改fds.event字段的可能性.这在Linux上工作正常,但不适用于OS X.

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

#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 X上编译
在Linux上使用g -std = c 11 -pthread -o poll poll.cpp

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

OS X上的输出：

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 X,Linux)中找不到任何有关它的详细信息.

解决方法:

您似乎首先说,您发现了一些声称支持和定义行为的文档.我很想知道你在哪里阅读,因为我无法在poll(2)的Linux手册页中找到任何内容,也没有在POSIX man page for poll()文档中找到不同的线程实际上可以更改事件数组参数中的值的另一个线程传递给poll(),并且不同线程的更改实际上在原始线程的poll()调用中生效,而不管与内存屏障有关的任何问题等等.

在这个主题上,对我来说,这两个手册页似乎都是完全沉默的.它们不表示这是预期的,支持的还是定义的行为;或者这不是受支持或定义的行为.

一个不同的线程可以将参数修改为另一个线程发出的系统调用的命题,之后 – 另一个线程已经进入系统调用之后,对我来说似乎是反向交叉的.如果这是受支持的行为,我希望它是明确记录的,我在Linux或POSIX手册页中找不到任何对它的引用.

话虽如此：即使我将我的软件范围限制在Linux,即使我不需要关心其他平台;由于没有任何这方面的文档,即使我的测试显示Linux内核以这种方式实现poll(2),我也不希望有任何保证未来某些内核版本将继续以这种方式运行.我不能依赖这种行为,除了我测试过的特定内核构建.

那么,回答你的问题：对这个主题具有权威性的唯一文档是有问题的手册页.他们没有明确将此视为合法行为;虽然他们也没有明确说这是非法行为,但由于上述原因,我认为这是不受支持的,未定义的行为.

内容总结

以上是互联网集市为您收集整理的当在另一个线程上更改pollfd时,Linux和OS X之间poll()的差异全部内容，希望文章能够帮你解决当在另一个线程上更改pollfd时,Linux和OS X之间poll()的差异所遇到的程序开发问题。 如果觉得互联网集市技术教程内容还不错，欢迎将互联网集市网站推荐给程序员好友。

内容备注

版权声明：本文内容由互联网用户自发贡献，该文观点与技术仅代表作者本人。本站仅提供信息存储空间服务，不拥有所有权，不承担相关法律责任。如发现本站有涉嫌侵权/违法违规的内容， 请发送邮件至 gblab@vip.qq.com 举报，一经查实，本站将立刻删除。

内容手机端

---