summaryrefslogtreecommitdiff
path: root/librabbitmq/amqp_tcp_socket.c
diff options
context:
space:
mode:
authorAlan Antonuk <alan.antonuk@gmail.com>2013-04-11 10:53:59 -0700
committerAlan Antonuk <alan.antonuk@gmail.com>2013-04-17 09:56:29 -0700
commita2a91f532b7e648b2468acad39ae7169ac020d0a (patch)
tree78010b44a0e00011cc17787d144abc7dc358c560 /librabbitmq/amqp_tcp_socket.c
parent317a56cfffb05e72713bfa8a8e7236b7c39ddb8d (diff)
downloadrabbitmq-c-a2a91f532b7e648b2468acad39ae7169ac020d0a.tar.gz
Fix code formatting to match the rest of the lib
Diffstat (limited to 'librabbitmq/amqp_tcp_socket.c')
-rw-r--r--librabbitmq/amqp_tcp_socket.c88
1 files changed, 44 insertions, 44 deletions
diff --git a/librabbitmq/amqp_tcp_socket.c b/librabbitmq/amqp_tcp_socket.c
index cd3f6ce..f65a6ce 100644
--- a/librabbitmq/amqp_tcp_socket.c
+++ b/librabbitmq/amqp_tcp_socket.c
@@ -31,96 +31,96 @@
#include <stdlib.h>
struct amqp_tcp_socket_t {
- const struct amqp_socket_class_t *klass;
- int sockfd;
+ const struct amqp_socket_class_t *klass;
+ int sockfd;
};
static ssize_t
amqp_tcp_socket_writev(void *base, const struct iovec *iov, int iovcnt)
{
- struct amqp_tcp_socket_t *self = (struct amqp_tcp_socket_t *)base;
- return amqp_os_socket_writev(self->sockfd, iov, iovcnt);
+ struct amqp_tcp_socket_t *self = (struct amqp_tcp_socket_t *)base;
+ return amqp_os_socket_writev(self->sockfd, iov, iovcnt);
}
static ssize_t
amqp_tcp_socket_send(void *base, const void *buf, size_t len, int flags)
{
- struct amqp_tcp_socket_t *self = (struct amqp_tcp_socket_t *)base;
- return send(self->sockfd, buf, len, flags);
+ struct amqp_tcp_socket_t *self = (struct amqp_tcp_socket_t *)base;
+ return send(self->sockfd, buf, len, flags);
}
static ssize_t
amqp_tcp_socket_recv(void *base, void *buf, size_t len, int flags)
{
- struct amqp_tcp_socket_t *self = (struct amqp_tcp_socket_t *)base;
- return recv(self->sockfd, buf, len, flags);
+ struct amqp_tcp_socket_t *self = (struct amqp_tcp_socket_t *)base;
+ return recv(self->sockfd, buf, len, flags);
}
static int
amqp_tcp_socket_open(void *base, const char *host, int port)
{
- struct amqp_tcp_socket_t *self = (struct amqp_tcp_socket_t *)base;
- self->sockfd = amqp_open_socket(host, port);
- if (0 > self->sockfd) {
- return -1;
- }
- return 0;
+ struct amqp_tcp_socket_t *self = (struct amqp_tcp_socket_t *)base;
+ self->sockfd = amqp_open_socket(host, port);
+ if (0 > self->sockfd) {
+ return -1;
+ }
+ return 0;
}
static int
amqp_tcp_socket_close(void *base)
{
- struct amqp_tcp_socket_t *self = (struct amqp_tcp_socket_t *)base;
- int status = -1;
- if (self) {
- status = amqp_os_socket_close(self->sockfd);
- free(self);
- }
- return status;
+ struct amqp_tcp_socket_t *self = (struct amqp_tcp_socket_t *)base;
+ int status = -1;
+ if (self) {
+ status = amqp_os_socket_close(self->sockfd);
+ free(self);
+ }
+ return status;
}
static int
amqp_tcp_socket_error(AMQP_UNUSED void *base)
{
- return amqp_os_socket_error();
+ return amqp_os_socket_error();
}
static int
amqp_tcp_socket_get_sockfd(void *base)
{
- struct amqp_tcp_socket_t *self = (struct amqp_tcp_socket_t *)base;
- return self->sockfd;
+ struct amqp_tcp_socket_t *self = (struct amqp_tcp_socket_t *)base;
+ return self->sockfd;
}
static const struct amqp_socket_class_t amqp_tcp_socket_class = {
- amqp_tcp_socket_writev, /* writev */
- amqp_tcp_socket_send, /* send */
- amqp_tcp_socket_recv, /* recv */
- amqp_tcp_socket_open, /* open */
- amqp_tcp_socket_close, /* close */
- amqp_tcp_socket_error, /* error */
- amqp_tcp_socket_get_sockfd /* get_sockfd */
+ amqp_tcp_socket_writev, /* writev */
+ amqp_tcp_socket_send, /* send */
+ amqp_tcp_socket_recv, /* recv */
+ amqp_tcp_socket_open, /* open */
+ amqp_tcp_socket_close, /* close */
+ amqp_tcp_socket_error, /* error */
+ amqp_tcp_socket_get_sockfd /* get_sockfd */
};
amqp_socket_t *
amqp_tcp_socket_new(void)
{
- struct amqp_tcp_socket_t *self = calloc(1, sizeof(*self));
- if (!self) {
- return NULL;
- }
- self->klass = &amqp_tcp_socket_class;
- self->sockfd = -1;
- return (amqp_socket_t *)self;
+ struct amqp_tcp_socket_t *self = calloc(1, sizeof(*self));
+ if (!self) {
+ return NULL;
+ }
+ self->klass = &amqp_tcp_socket_class;
+ self->sockfd = -1;
+ return (amqp_socket_t *)self;
}
void
amqp_tcp_socket_set_sockfd(amqp_socket_t *base, int sockfd)
{
- struct amqp_tcp_socket_t *self;
- if (base->klass != &amqp_tcp_socket_class) {
- amqp_abort("<%p> is not of type amqp_tcp_socket_t", base);
- }
- self = (struct amqp_tcp_socket_t *)base;
- self->sockfd = sockfd;
+ struct amqp_tcp_socket_t *self;
+ if (base->klass != &amqp_tcp_socket_class) {
+ amqp_abort("<%p> is not of type amqp_tcp_socket_t", base);
+ }
+ self = (struct amqp_tcp_socket_t *)base;
+ self->sockfd = sockfd;
}