diff options
Diffstat (limited to 'librabbitmq/win32/socket.c')
| -rw-r--r-- | librabbitmq/win32/socket.c | 17 |
1 files changed, 13 insertions, 4 deletions
diff --git a/librabbitmq/win32/socket.c b/librabbitmq/win32/socket.c index 43b919b..06db54e 100644 --- a/librabbitmq/win32/socket.c +++ b/librabbitmq/win32/socket.c @@ -45,7 +45,8 @@ static int called_wsastartup; -int amqp_socket_init(void) +int +amqp_socket_init(void) { if (!called_wsastartup) { WSADATA data; @@ -59,7 +60,8 @@ int amqp_socket_init(void) return 0; } -char *amqp_os_error_string(int err) +char * +amqp_os_error_string(int err) { char *msg, *copy; @@ -85,7 +87,14 @@ amqp_socket_setsockopt(int sock, int level, int optname, } int -amqp_socket_writev(int sock, struct iovec *iov, int nvecs) +amqp_socket_close(int sockfd, AMQP_UNUSED void *user_data) +{ + return closesocket(sockfd); +} + +int +amqp_socket_writev(int sock, struct iovec *iov, int nvecs, + AMQP_UNUSED void *user_data) { DWORD ret; if (WSASend(sock, (LPWSABUF)iov, nvecs, &ret, 0, NULL, NULL) == 0) @@ -95,7 +104,7 @@ amqp_socket_writev(int sock, struct iovec *iov, int nvecs) } int -amqp_socket_error(void) +amqp_socket_error(AMQP_UNUSED void *user_data) { return WSAGetLastError() | ERROR_CATEGORY_OS; } |