From 656f833016ec2dae1f51425ea667c6a6f644a9ae Mon Sep 17 00:00:00 2001 From: Alan Antonuk Date: Tue, 6 Jan 2015 21:17:17 -0800 Subject: [PATCH] Check for closed socket in amqp_ssl_socket_send(). --- librabbitmq/amqp_openssl.c | 4 ++++ 1 file changed, 4 insertions(+) diff --git a/librabbitmq/amqp_openssl.c b/librabbitmq/amqp_openssl.c index 85b9ca5c0..c1b55151c 100644 --- a/librabbitmq/amqp_openssl.c +++ b/librabbitmq/amqp_openssl.c @@ -81,6 +81,10 @@ amqp_ssl_socket_send(void *base, { struct amqp_ssl_socket_t *self = (struct amqp_ssl_socket_t *)base; ssize_t res; + if (-1 == self->sockfd) { + return AMQP_STATUS_SOCKET_CLOSED; + } + ERR_clear_error(); self->internal_error = 0;