X-Git-Url: https://git.ozlabs.org/?a=blobdiff_plain;f=ccan%2Fnet%2Fnet.c;h=e9199839936e85aebb93b0bcd486669b150d73da;hb=cedcaa1bbb44cad610973c449340c0fde9ae0280;hp=394c4e49f2bb16024ea576b0aa68ed1376c25bcc;hpb=fc8acdbbe2484794aa3c3bea8c00f0de80e48811;p=ccan diff --git a/ccan/net/net.c b/ccan/net/net.c index 394c4e49..e9199839 100644 --- a/ccan/net/net.c +++ b/ccan/net/net.c @@ -1,10 +1,7 @@ /* Licensed under BSD-MIT - see LICENSE file for details */ #include #include -#include -#include #include -#include #include #include #include @@ -116,7 +113,7 @@ int net_connect_async(const struct addrinfo *addrinfo, struct pollfd pfds[2]) close_noerr(pfds[i].fd); return -1; } - return pfds[0].fd; + return pfds[i].fd; } } @@ -159,6 +156,9 @@ int net_connect_complete(struct pollfd pfds[2]) } continue; } + if (!(pfds[i].revents & POLLOUT)) + continue; + if (getsockopt(pfds[i].fd, SOL_SOCKET, SO_ERROR, &err, &errlen) != 0) { net_connect_abort(pfds); @@ -231,7 +231,7 @@ static bool should_listen(const struct addrinfo *addrinfo) static int make_listen_fd(const struct addrinfo *addrinfo) { - int saved_errno, fd, on = 1; + int fd, on = 1; fd = socket(addrinfo->ai_family, addrinfo->ai_socktype, addrinfo->ai_protocol); @@ -247,9 +247,7 @@ static int make_listen_fd(const struct addrinfo *addrinfo) return fd; fail: - saved_errno = errno; - close(fd); - errno = saved_errno; + close_noerr(fd); return -1; }