summaryrefslogtreecommitdiff
path: root/librabbitmq/amqp_openssl.c
diff options
context:
space:
mode:
authorAlan Antonuk <alan.antonuk@gmail.com>2015-04-27 22:19:30 -0700
committerAlan Antonuk <alan.antonuk@gmail.com>2015-05-03 20:24:03 -0700
commit43b6fc5ea0f36866dd79e9697e9e6a0135362e10 (patch)
treeee7916d391cf49284226aa08f2f39e9200f98c9f /librabbitmq/amqp_openssl.c
parent2b8a417b27e221a7bf0201cdc4023ac05de0f108 (diff)
downloadrabbitmq-c-43b6fc5ea0f36866dd79e9697e9e6a0135362e10.tar.gz
Remove writev specific code.
Diffstat (limited to 'librabbitmq/amqp_openssl.c')
-rw-r--r--librabbitmq/amqp_openssl.c38
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 */