From 795aebbee77bb74d8792df96dfe1aa79ec9548fc Mon Sep 17 00:00:00 2001 From: Garrett D'Amore Date: Mon, 10 Jul 2017 15:02:38 -0700 Subject: Give up on uncrustify; switch to clang-format. --- src/core/pipe.c | 33 ++++++++------------------------- 1 file changed, 8 insertions(+), 25 deletions(-) (limited to 'src/core/pipe.c') diff --git a/src/core/pipe.c b/src/core/pipe.c index 9151ede0..702e8eb1 100644 --- a/src/core/pipe.c +++ b/src/core/pipe.c @@ -29,10 +29,10 @@ nni_pipe_ctor(uint32_t id) return (NULL); } - p->p_tran_data = NULL; + p->p_tran_data = NULL; p->p_proto_data = NULL; p->p_proto_dtor = NULL; - p->p_id = id; + p->p_id = id; NNI_LIST_NODE_INIT(&p->p_sock_node); NNI_LIST_NODE_INIT(&p->p_ep_node); @@ -40,7 +40,6 @@ nni_pipe_ctor(uint32_t id) return (p); } - static void nni_pipe_dtor(void *ptr) { @@ -58,7 +57,6 @@ nni_pipe_dtor(void *ptr) NNI_FREE_STRUCT(p); } - int nni_pipe_sys_init(void) { @@ -73,7 +71,6 @@ nni_pipe_sys_init(void) return (0); } - void nni_pipe_sys_fini(void) { @@ -81,7 +78,6 @@ nni_pipe_sys_fini(void) nni_pipes = NULL; } - // nni_pipe_id returns the 32-bit pipe id, which can be used in backtraces. uint32_t nni_pipe_id(nni_pipe *p) @@ -89,21 +85,18 @@ nni_pipe_id(nni_pipe *p) return (p->p_id); } - void nni_pipe_recv(nni_pipe *p, nni_aio *aio) { p->p_tran_ops.p_recv(p->p_tran_data, aio); } - void nni_pipe_send(nni_pipe *p, nni_aio *aio) { p->p_tran_ops.p_send(p->p_tran_data, aio); } - // nni_pipe_close closes the underlying connection. It is expected that // subsequent attempts receive or send (including any waiting receive) will // simply return NNG_ECLOSED. @@ -128,7 +121,6 @@ nni_pipe_close(nni_pipe *p) nni_mtx_unlock(&p->p_mtx); } - // We have to stop asynchronously using a task, because otherwise we can // wind up having a callback from an AIO trying to cancel itself. That // simply will not work. @@ -147,7 +139,6 @@ nni_pipe_remove(nni_pipe *p) nni_objhash_unref(nni_pipes, p->p_id); } - void nni_pipe_stop(nni_pipe *p) { @@ -163,20 +154,18 @@ nni_pipe_stop(nni_pipe *p) nni_taskq_dispatch(NULL, &p->p_reap_tqe); } - uint16_t nni_pipe_peer(nni_pipe *p) { return (p->p_tran_ops.p_peer(p->p_tran_data)); } - static void nni_pipe_start_cb(void *arg) { - nni_pipe *p = arg; - nni_aio *aio = &p->p_start_aio; - int rv; + nni_pipe *p = arg; + nni_aio * aio = &p->p_start_aio; + int rv; nni_mtx_lock(&p->p_mtx); if ((rv = nni_aio_result(aio)) != 0) { @@ -192,13 +181,12 @@ nni_pipe_start_cb(void *arg) } } - int nni_pipe_create(nni_pipe **pp, nni_ep *ep, nni_sock *sock, nni_tran *tran) { nni_pipe *p; - int rv; - uint32_t id; + int rv; + uint32_t id; rv = nni_objhash_alloc(nni_pipes, &id, (void **) &p); if (rv != 0) { @@ -209,7 +197,7 @@ nni_pipe_create(nni_pipe **pp, nni_ep *ep, nni_sock *sock, nni_tran *tran) return (rv); } p->p_sock = sock; - p->p_ep = ep; + p->p_ep = ep; // Make a copy of the transport ops. We can override entry points // and we avoid an extra dereference on hot code paths. @@ -234,7 +222,6 @@ nni_pipe_create(nni_pipe **pp, nni_ep *ep, nni_sock *sock, nni_tran *tran) return (0); } - int nni_pipe_getopt(nni_pipe *p, int opt, void *val, size_t *szp) { @@ -245,7 +232,6 @@ nni_pipe_getopt(nni_pipe *p, int opt, void *val, size_t *szp) return (p->p_tran_ops.p_getopt(p->p_tran_data, opt, val, szp)); } - int nni_pipe_start(nni_pipe *p) { @@ -262,21 +248,18 @@ nni_pipe_start(nni_pipe *p) return (0); } - void * nni_pipe_get_proto_data(nni_pipe *p) { return (p->p_proto_data); } - void nni_pipe_sock_list_init(nni_list *list) { NNI_LIST_INIT(list, nni_pipe, p_sock_node); } - void nni_pipe_ep_list_init(nni_list *list) { -- cgit v1.2.3-70-g09d2