如果之前有人問過這個問題,我很抱歉。我正在編寫一個使用選擇多路複用的非阻塞套接字客戶端。讓我困惑的一件事是,無論服務器在線還是離線,無阻塞連接都會成功。我搜索了很多帖子,並遵循他們的解決方案,但沒有一個在我的linux ubuntu機器上工作。非阻塞套接字連接總是成功?
static void callback_on_select_write(int connect_fd) {
// Client write event arrived;
int error = -1;
socklen_t len = sizeof(error);
if(getsockopt(connect_fd, SOL_SOCKET, SO_ERROR, &error, &len) == -1) {
return;
}
// getsockopt puts the errno value for connect into erro so 0 means no-error.
if(error == 0) {
// Connection ok.
}
else {
cerr << "Failed to connect\n";
return;
}
// Ready to write/read
}
每次選擇返回並調用這個回調總是成功,即,將「準備讀/寫」塊,而不是cerring故障。爲什麼會發生?如何設計便攜式機制來檢測連接是否真的成功?以下是我創建連接器的方式。
int make_socket_client(const ::std::string& hostname, const ::std::string& port) {
struct addrinfo hints;
struct addrinfo* res {nullptr};
struct addrinfo* ptr {nullptr};
memset(&hints, 0, sizeof(struct addrinfo));
hints.ai_family = AF_UNSPEC;
hints.ai_socktype = SOCK_STREAM;
hints.ai_protocol = IPPROTO_TCP;
int rv;
int connector;
if((rv = getaddrinfo(hostname.c_str(), port.c_str(), &hints, &res)) != 0) {
return -1;
}
// Try to get the first available client connection.
for(ptr = res; ptr != nullptr; ptr = ptr->ai_next) {
// Ignore undefined ip type.
if(ptr->ai_family != AF_INET && ptr->ai_family != AF_INET6) {
continue;
}
// Create a listener socket and bind it to the localhost as the server.
if((connector = socket(ptr->ai_family, ptr->ai_socktype, ptr->ai_protocol)) == -1){
continue;
}
make_fd_nonblocking(connector);
if(connect(connector, (struct sockaddr*)ptr->ai_addr, ptr->ai_addrlen) < 0) {
// This is what we expect.
if(errno == EINPROGRESS) {
break;
}
else {
close(connector);
continue;
}
}
else {
break;
}
}
freeaddrinfo(res);
if(ptr == nullptr) {
return -1;
}
return connector;
}
當然,你應該看看'connect_fd'上的SO_ERROR?什麼是'事件'?此代碼不夠完整,無法回答問題。 – EJP
對不起。它只應該是connect_fd。 – Jes
原始'connect()'返回零嗎? – EJP