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_tcp_socket.c | |
| parent | b6a1dfec14e70fc6afe8ce9710231e552ba6bfb5 (diff) | |
| download | rabbitmq-c-6ad770dc62f76fa0625d277b521a120b549d9fc2.tar.gz | |
Add nonblocking connect support
Diffstat (limited to 'librabbitmq/amqp_tcp_socket.c')
| -rw-r--r-- | librabbitmq/amqp_tcp_socket.c | 4 |
1 files changed, 2 insertions, 2 deletions
diff --git a/librabbitmq/amqp_tcp_socket.c b/librabbitmq/amqp_tcp_socket.c index 6ab71ef..9a9fc69 100644 --- a/librabbitmq/amqp_tcp_socket.c +++ b/librabbitmq/amqp_tcp_socket.c @@ -220,10 +220,10 @@ start: } static int -amqp_tcp_socket_open(void *base, const char *host, int port) +amqp_tcp_socket_open(void *base, const char *host, int port, struct timeval *timeout) { struct amqp_tcp_socket_t *self = (struct amqp_tcp_socket_t *)base; - self->sockfd = amqp_open_socket(host, port); + self->sockfd = amqp_open_socket_noblock(host, port, timeout); if (0 > self->sockfd) { int err = self->sockfd; self->sockfd = -1; |