diff options
| author |   Andrew Opalach <andrew@akon.city>
| 2024-12-26 15:24:35 -0500 |
|---|---|---|
| committer | Andrew Opalach <andrew@akon.city>
| 2024-12-26 15:24:35 -0500 |
| commit | be4eb3831a2e5b44fb6e4c2d077e3c07edf6b776 (patch) | |
| tree | dc0f0479070cc716fba9e26d4848a9786913c823 /src/socket | |
| parent | f5df41d650ea03de846466c66a62d0517b22f375 (diff) | |
| download | libnaunet-be4eb3831a2e5b44fb6e4c2d077e3c07edf6b776.tar.gz libnaunet-be4eb3831a2e5b44fb6e4c2d077e3c07edf6b776.tar.bz2 libnaunet-be4eb3831a2e5b44fb6e4c2d077e3c07edf6b776.zip | |
Revise style and cleanup
Signed-off-by: Andrew Opalach <andrew@akon.city>
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: |