diff options
| author | Alan Antonuk <alan.antonuk@gmail.com> | 2015-01-06 21:17:17 -0800 |
|---|---|---|
| committer | Alan Antonuk <alan.antonuk@gmail.com> | 2015-01-06 21:17:17 -0800 |
| commit | 656f833016ec2dae1f51425ea667c6a6f644a9ae (patch) | |
| tree | 362e12511d946da4309b6fae7200935837a38365 | |
| parent | 9cbc6cda9b1ad08b640e4a7578d06566c9a202f2 (diff) | |
| download | rabbitmq-c-656f833016ec2dae1f51425ea667c6a6f644a9ae.tar.gz | |
Check for closed socket in amqp_ssl_socket_send().
| -rw-r--r-- | librabbitmq/amqp_openssl.c | 4 |
1 files changed, 4 insertions, 0 deletions
diff --git a/librabbitmq/amqp_openssl.c b/librabbitmq/amqp_openssl.c index 85b9ca5..c1b5515 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; |