diff options
| -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); |