diff options
-rw-r--r-- | librabbitmq/amqp_socket.c | 5 | ||||
-rw-r--r-- | librabbitmq/amqp_tcp_socket.c | 4 |
2 files changed, 4 insertions, 5 deletions
diff --git a/librabbitmq/amqp_socket.c b/librabbitmq/amqp_socket.c index f4ecaeb..545f2cd 100644 --- a/librabbitmq/amqp_socket.c +++ b/librabbitmq/amqp_socket.c @@ -75,7 +75,6 @@ #ifdef _WIN32 # define poll(fdarray, nfds, timeout) WSAPoll(fdarray, nfds, timeout) -# define EINPROGRESS WSAEWOULDBLOCK #endif static int @@ -434,7 +433,11 @@ int amqp_open_socket_inner(char const *hostname, break; } +#ifdef _WIN32 + if (WSAEWOULDBLOCK == amqp_os_socket_error()) { +#else if (EINPROGRESS == amqp_os_socket_error()) { +#endif last_error = amqp_poll_write(sockfd, deadline); if (AMQP_STATUS_OK == last_error) { int result; diff --git a/librabbitmq/amqp_tcp_socket.c b/librabbitmq/amqp_tcp_socket.c index b70ccf0..e14cf38 100644 --- a/librabbitmq/amqp_tcp_socket.c +++ b/librabbitmq/amqp_tcp_socket.c @@ -32,10 +32,6 @@ #include <stdio.h> #include <stdlib.h> -#ifdef _WIN32 -# define EWOULDBLOCK WSAEWOULDBLOCK -#endif - struct amqp_tcp_socket_t { const struct amqp_socket_class_t *klass; int sockfd; |