diff options
Diffstat (limited to 'src/socket')
| -rw-r--r-- | src/socket/socket_internal.h | 6 | ||||
| -rw-r--r-- | src/socket/socket_linux.c | 7 |
2 files changed, 8 insertions, 5 deletions
diff --git a/src/socket/socket_internal.h b/src/socket/socket_internal.h index fd9a001..193fa43 100644 --- a/src/socket/socket_internal.h +++ b/src/socket/socket_internal.h @@ -14,9 +14,11 @@ static inline str *nn_socket_display_addr(str *addr) static inline void nn_socket_apply_flags(struct nn_socket *sock, s32 flags) { - if (flags & NNWT_SOCKET_NONBLOCKING) + if (flags & NNWT_SOCKET_NONBLOCKING) { nn_socket_set_blocking(sock, false); + } - if (flags & NNWT_SOCKET_NODELAY) + if (flags & NNWT_SOCKET_NODELAY) { nn_socket_set_nodelay(sock, 1); + } } diff --git a/src/socket/socket_linux.c b/src/socket/socket_linux.c index c3467dd..0dadfbe 100644 --- a/src/socket/socket_linux.c +++ b/src/socket/socket_linux.c @@ -24,7 +24,6 @@ s32 nn_poll_fds(struct nn_pollfd *fds, nn_nfds nfds, s64 timeout_ns) return ppoll(fds, nfds, tsp, NULL); } - bool nn_socket_init(struct nn_socket *sock, s32 flags) { switch (sock->type) { @@ -137,8 +136,9 @@ bool nn_socket_bind(struct nn_socket *sock, str *addr, u16 port) switch (sock->type) { case NNWT_SOCKET_TCP: case NNWT_SOCKET_UDP: - if (!parse_address(sock, addr, port)) + if (!parse_address(sock, addr, port)) { return false; + } saddr = sock->addrinfo->ai_addr; addrlen = sock->addrinfo->ai_addrlen; break; @@ -228,8 +228,9 @@ bool nn_socket_connect(struct nn_socket *sock, str *addr, u16 port) switch (sock->type) { case NNWT_SOCKET_TCP: case NNWT_SOCKET_UDP: - if (!parse_address(sock, addr, port)) + if (!parse_address(sock, addr, port)) { return false; + } ret = connect(sock->fd, sock->addrinfo->ai_addr, sock->addrinfo->ai_addrlen); break; case NNWT_SOCKET_UNIX: |