summaryrefslogtreecommitdiff
diff options
context:
space:
mode:
authorAlan Antonuk <alan.antonuk@gmail.com>2018-01-09 22:23:39 -0800
committerAlan Antonuk <alan.antonuk@gmail.com>2018-01-09 22:46:29 -0800
commit8dab630df1f12db6ed48b2e7a653e948fcff2c9d (patch)
treead7f11ec7af4b146c3b2ef80a9d245596165dd4f
parentabf48864499ecc6ea1cb7eb4dc563b2f78c11325 (diff)
downloadrabbitmq-c-8dab630df1f12db6ed48b2e7a653e948fcff2c9d.tar.gz
Lib: fix socket leak when sockfd == 0
amqp_open_socket_inner will leak the socket when sockfd == 0. Fixes CID: 1383631 caught by Coverity.
-rw-r--r--librabbitmq/amqp_socket.c2
1 files changed, 1 insertions, 1 deletions
diff --git a/librabbitmq/amqp_socket.c b/librabbitmq/amqp_socket.c
index a5bbd4b..6e06fbd 100644
--- a/librabbitmq/amqp_socket.c
+++ b/librabbitmq/amqp_socket.c
@@ -498,7 +498,7 @@ int amqp_open_socket_inner(char const *hostname, int portnumber,
for (addr = address_list; addr; addr = addr->ai_next) {
sockfd = connect_socket(addr, deadline);
- if (sockfd > 0) {
+ if (sockfd >= 0) {
last_error = AMQP_STATUS_OK;
break;
} else if (sockfd == AMQP_STATUS_TIMEOUT) {