diff options
| -rw-r--r-- | librabbitmq/amqp_socket.c | 12 |
1 files changed, 0 insertions, 12 deletions
diff --git a/librabbitmq/amqp_socket.c b/librabbitmq/amqp_socket.c index dbd6dac..15c616a 100644 --- a/librabbitmq/amqp_socket.c +++ b/librabbitmq/amqp_socket.c @@ -338,12 +338,6 @@ int amqp_open_socket_noblock(char const *hostname, res = connect(sockfd, addr->ai_addr, addr->ai_addrlen); if (0 == res) { - /* Connected immediately, set to blocking mode again */ - if (AMQP_STATUS_OK != amqp_os_socket_setsockblock(sockfd, 1)) { - last_error = AMQP_STATUS_SOCKET_ERROR; - continue; - } - last_error = AMQP_STATUS_OK; break; } @@ -390,12 +384,6 @@ int amqp_open_socket_noblock(char const *hostname, break; } - /* socket is ready to be written to, set to blocking mode again */ - if (AMQP_STATUS_OK != amqp_os_socket_setsockblock(sockfd, 1)) { - last_error = AMQP_STATUS_SOCKET_ERROR; - continue; - } - last_error = AMQP_STATUS_OK; break; } else if (0 == res) { |