diff options
| author | Alan Antonuk <alan.antonuk@gmail.com> | 2015-04-06 22:48:27 -0700 |
|---|---|---|
| committer | Alan Antonuk <alan.antonuk@gmail.com> | 2015-04-19 22:09:32 -0700 |
| commit | 8a2b35620a8cbe094bce0b6b3ed33e3c49ebc048 (patch) | |
| tree | 440222a47388d1c9a66bc4708cc8be4ae295f57f | |
| parent | a240c6930627ffd0bb61628b3a4f399f9062d275 (diff) | |
| download | rabbitmq-c-8a2b35620a8cbe094bce0b6b3ed33e3c49ebc048.tar.gz | |
Leave socket as non-blocking after connect
| -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) { |