diff options
| author | Alan Antonuk <alan.antonuk@gmail.com> | 2013-06-18 15:20:37 -0700 |
|---|---|---|
| committer | Alan Antonuk <alan.antonuk@gmail.com> | 2013-06-18 15:20:37 -0700 |
| commit | 2e37bb39ea71f44cb670665ae2d94bd03074c486 (patch) | |
| tree | 27d0b1588215ec7a5d067e169db68bcfab51cf15 /librabbitmq | |
| parent | 7477449997792e68f5721180f10e42a31979a56c (diff) | |
| download | rabbitmq-c-github-ask-2e37bb39ea71f44cb670665ae2d94bd03074c486.tar.gz | |
FIX: handle amqp_get_sockfd failure in wait_frame
CID 1035138
CID 1035137
Diffstat (limited to 'librabbitmq')
| -rw-r--r-- | librabbitmq/amqp_socket.c | 3 |
1 files changed, 3 insertions, 0 deletions
diff --git a/librabbitmq/amqp_socket.c b/librabbitmq/amqp_socket.c index d32849a..5232330 100644 --- a/librabbitmq/amqp_socket.c +++ b/librabbitmq/amqp_socket.c @@ -392,6 +392,9 @@ static int wait_frame_inner(amqp_connection_state_t state, struct timeval tv; fd = amqp_get_sockfd(state); + if (-1 == fd) { + return AMQP_STATUS_CONNECTION_CLOSED; + } FD_ZERO(&read_fd); FD_SET(fd, &read_fd); |