diff options
| author | zaq178miami <pinepain@gmail.com> | 2013-06-23 19:36:10 +0300 |
|---|---|---|
| committer | Alan Antonuk <alan.antonuk@gmail.com> | 2013-07-06 22:28:45 -0700 |
| commit | 6ad770dc62f76fa0625d277b521a120b549d9fc2 (patch) | |
| tree | 964847f5a839c7ccbfba6c09bc9b5ca3102c89d4 /librabbitmq/amqp_openssl.c | |
| parent | b6a1dfec14e70fc6afe8ce9710231e552ba6bfb5 (diff) | |
| download | rabbitmq-c-6ad770dc62f76fa0625d277b521a120b549d9fc2.tar.gz | |
Add nonblocking connect support
Diffstat (limited to 'librabbitmq/amqp_openssl.c')
| -rw-r--r-- | librabbitmq/amqp_openssl.c | 4 |
1 files changed, 2 insertions, 2 deletions
diff --git a/librabbitmq/amqp_openssl.c b/librabbitmq/amqp_openssl.c index 2bd4fda..f70d377 100644 --- a/librabbitmq/amqp_openssl.c +++ b/librabbitmq/amqp_openssl.c @@ -232,7 +232,7 @@ error: } static int -amqp_ssl_socket_open(void *base, const char *host, int port) +amqp_ssl_socket_open(void *base, const char *host, int port, struct timeval *timeout) { struct amqp_ssl_socket_t *self = (struct amqp_ssl_socket_t *)base; long result; @@ -247,7 +247,7 @@ amqp_ssl_socket_open(void *base, const char *host, int port) } SSL_set_mode(self->ssl, SSL_MODE_AUTO_RETRY); - self->sockfd = amqp_open_socket(host, port); + self->sockfd = amqp_open_socket_noblock(host, port, timeout); if (0 > self->sockfd) { status = self->sockfd; self->internal_error = amqp_os_socket_error(); |