X-Git-Url: http://git.onelab.eu/?a=blobdiff_plain;f=lib%2Fsocket-util.c;h=9fea7bdab55455951929e304185578f46c6f4ea6;hb=780325b5b8d4c0552b4b7719e0a38200d99f6b08;hp=c2f74d03700d29336e15b30ace0f8e44e7b6e322;hpb=85b20fd6ee585f462e012fbcc7f966a81edab2ed;p=sliver-openvswitch.git diff --git a/lib/socket-util.c b/lib/socket-util.c index c2f74d037..9fea7bdab 100644 --- a/lib/socket-util.c +++ b/lib/socket-util.c @@ -17,7 +17,6 @@ #include #include "socket-util.h" #include -#include #include #include #include @@ -410,13 +409,8 @@ make_unix_socket(int style, bool nonblock, * it will only happen if style is SOCK_STREAM or SOCK_SEQPACKET, and only * if a backlog of un-accepted connections has built up in the kernel.) */ if (nonblock) { - int flags = fcntl(fd, F_GETFL, 0); - if (flags == -1) { - error = errno; - goto error; - } - if (fcntl(fd, F_SETFL, flags | O_NONBLOCK) == -1) { - error = errno; + error = set_nonblocking(fd); + if (error) { goto error; } } @@ -1101,7 +1095,7 @@ send_iovec_and_fds(int sock, const struct iovec *iovs, size_t n_iovs, const int fds[], size_t n_fds) { - assert(sock >= 0); + ovs_assert(sock >= 0); if (n_fds > 0) { union { struct cmsghdr cm; @@ -1109,8 +1103,8 @@ send_iovec_and_fds(int sock, } cmsg; struct msghdr msg; - assert(!iovec_is_empty(iovs, n_iovs)); - assert(n_fds <= SOUTIL_MAX_FDS); + ovs_assert(!iovec_is_empty(iovs, n_iovs)); + ovs_assert(n_fds <= SOUTIL_MAX_FDS); memset(&cmsg, 0, sizeof cmsg); cmsg.cm.cmsg_len = CMSG_LEN(n_fds * sizeof *fds); @@ -1285,7 +1279,7 @@ recv_data_and_fds(int sock, size_t n_fds = (p->cmsg_len - CMSG_LEN(0)) / sizeof *fds; const int *fds_data = (const int *) CMSG_DATA(p); - assert(n_fds > 0); + ovs_assert(n_fds > 0); if (n_fds > SOUTIL_MAX_FDS) { VLOG_ERR("%zu fds received but only %d supported", n_fds, SOUTIL_MAX_FDS);