diff options
author | Alan Antonuk <alan.antonuk@gmail.com> | 2015-04-27 22:19:30 -0700 |
---|---|---|
committer | Alan Antonuk <alan.antonuk@gmail.com> | 2015-05-03 20:24:03 -0700 |
commit | 43b6fc5ea0f36866dd79e9697e9e6a0135362e10 (patch) | |
tree | ee7916d391cf49284226aa08f2f39e9200f98c9f /librabbitmq/amqp_openssl.c | |
parent | 2b8a417b27e221a7bf0201cdc4023ac05de0f108 (diff) | |
download | rabbitmq-c-43b6fc5ea0f36866dd79e9697e9e6a0135362e10.tar.gz |
Remove writev specific code.
Diffstat (limited to 'librabbitmq/amqp_openssl.c')
-rw-r--r-- | librabbitmq/amqp_openssl.c | 38 |
1 files changed, 0 insertions, 38 deletions
diff --git a/librabbitmq/amqp_openssl.c b/librabbitmq/amqp_openssl.c index cd9707c..c225cdd 100644 --- a/librabbitmq/amqp_openssl.c +++ b/librabbitmq/amqp_openssl.c @@ -120,43 +120,6 @@ amqp_ssl_socket_send(void *base, } static ssize_t -amqp_ssl_socket_writev(void *base, - struct iovec *iov, - int iovcnt) -{ - struct amqp_ssl_socket_t *self = (struct amqp_ssl_socket_t *)base; - ssize_t ret = -1; - char *bufferp; - size_t bytes; - int i; - if (-1 == self->sockfd) { - return AMQP_STATUS_SOCKET_CLOSED; - } - - bytes = 0; - for (i = 0; i < iovcnt; ++i) { - bytes += iov[i].iov_len; - } - if (self->length < bytes) { - self->buffer = realloc(self->buffer, bytes); - if (!self->buffer) { - self->length = 0; - ret = AMQP_STATUS_NO_MEMORY; - goto exit; - } - self->length = bytes; - } - bufferp = self->buffer; - for (i = 0; i < iovcnt; ++i) { - memcpy(bufferp, iov[i].iov_base, iov[i].iov_len); - bufferp += iov[i].iov_len; - } - ret = amqp_ssl_socket_send(self, self->buffer, bytes); -exit: - return ret; -} - -static ssize_t amqp_ssl_socket_recv(void *base, void *buf, size_t len, @@ -450,7 +413,6 @@ amqp_ssl_socket_delete(void *base) } static const struct amqp_socket_class_t amqp_ssl_socket_class = { - amqp_ssl_socket_writev, /* writev */ amqp_ssl_socket_send, /* send */ amqp_ssl_socket_recv, /* recv */ amqp_ssl_socket_open, /* open */ |