我正在尝试用 C++ 编写套接字抽象。我正在使用 poll() 系统调用来等待数据准备好读取。但是,当我运行我的程序时,如果我将它设置为无限期轮询,则 poll() 永远不会返回,即使我发送套接字数据也是如此。
这是一个简单的程序来说明我的问题。我在 OSX 上用这一行编译它:clang++ -g -Wall -pedantic -std=c++0x -stdlib=libc++ pollTest.cpp -o pollTest
. 我正在使用该nc
程序设置一个侦听套接字以供程序连接。当我运行它时, poll() 调用永远挂起,由于数据准备好读取而永远不会返回。
#include <poll.h>
#include <sys/types.h>
#include <sys/socket.h>
#include <netinet/tcp.h>
#include <netdb.h>
#include <unistd.h>
#include <poll.h>
#include <fcntl.h>
#include <cstdlib>
#include <iostream>
void connectSocket(int& fd, std::string hostname, std::string service) {
struct addrinfo hints, *res, *res0;
int error;
int s;
memset(&hints, 0, sizeof(hints));
hints.ai_family = AF_INET;
hints.ai_socktype = SOCK_STREAM;
error = getaddrinfo(hostname.c_str(), service.c_str(), &hints, &res0);
if (error) {
throw error;
}
s = -1;
for (res = res0; res; res = res->ai_next) {
s = socket(res->ai_family, res->ai_socktype,
res->ai_protocol);
if (s < 0) {
continue;
}
if (connect(s, res->ai_addr, res->ai_addrlen) < 0) {
close(s);
s = -1;
continue;
}
break; /* okay we got one */
}
if (s < 0) {
throw s;
}
}
int main() {
int socketFileDescriptor = -1;
connectSocket(socketFileDescriptor, "localhost", "9999");
pollfd socketPolls[1];
socketPolls[0].fd = socketFileDescriptor;
socketPolls[0].events = POLLIN | POLLPRI | POLLRDBAND | POLLRDNORM;
poll(socketPolls, 1, -1);
std::cerr << socketPolls[0].revents;
}
关于为什么会发生这种情况的任何想法?我觉得好像我已经很好地阅读了文档,并且正在正确使用系统调用。(我没有在这个示例程序中进行错误检查,但我在我的项目中进行了)。任何帮助,将不胜感激!