Check for closed socket in amqp_ssl_socket_send().

alanxz · Jan 7, 2015 · 656f833 · 656f833
1 parent 9cbc6cd
commit 656f833
Showing 1 changed file with 4 additions and 0 deletions.
diff --git 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;