From 8a2b35620a8cbe094bce0b6b3ed33e3c49ebc048 Mon Sep 17 00:00:00 2001 From: Alan Antonuk Date: Mon, 6 Apr 2015 22:48:27 -0700 Subject: Leave socket as non-blocking after connect --- librabbitmq/amqp_socket.c | 12 ------------ 1 file changed, 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) { -- cgit v1.2.1