Add cork() and eagain() to socket

Signed-off-by: Andrew Opalach <andrew@akon.city>

1 files changed, 4 insertions, 2 deletions

diff --git a/src/socket/socket.h b/src/socket/socket.h
index fde26f4..31f23f3 100644
--- a/src/socket/socket.h
+++ b/src/socket/socket.h
@@ -8,8 +8,8 @@
 #else
 #include <unistd.h>
 #include <sys/un.h>
-#include <poll.h>
 #include <sys/eventfd.h>
+#include <poll.h>
 #endif
 
 enum {
@@ -50,9 +50,9 @@ struct nn_socket {
 #endif
 
 #ifndef NAUNET_ON_WINDOWS // Posix-only helpers.
+#define nn_eventfd eventfd
 #define nn_pollfd pollfd
 #define nn_nfds nfds_t
-#define nn_eventfd eventfd
 void nn_fd_set_blocking(s32 fd, bool blocking);
 s32 nn_poll_fds(struct nn_pollfd *fds, nn_nfds nfds, s64 timeout_ns);
 #endif
@@ -61,6 +61,7 @@ bool nn_socket_init(struct nn_socket *sock, s32 flags);
 
 void nn_socket_set_blocking(struct nn_socket *sock, bool blocking);
 void nn_socket_set_nodelay(struct nn_socket *sock, s32 nodelay);
+void nn_socket_set_cork(struct nn_socket *sock, s32 cork);
 void nn_socket_set_reuse_addr(struct nn_socket *sock, s32 reuse_addr);
 
 u32 nn_socket_get_send_buf(struct nn_socket *sock);
@@ -81,6 +82,7 @@ ssize_t nn_socket_write(struct nn_socket *sock, void *buf, size_t size);
 ssize_t nn_socket_sendto(struct nn_socket *sock, void *buf, size_t size);
 ssize_t nn_socket_recvfrom(struct nn_socket *sock, void *buf, size_t size);
 
+bool nn_socket_eagain(ssize_t ret);
 bool nn_socket_check_error(ssize_t ret);
 
 void nn_socket_shutdown(struct nn_socket *sock);