Give up on uncrustify; switch to clang-format.

1 files changed, 24 insertions, 48 deletions

diff --git a/src/core/endpt.c b/src/core/endpt.c
index ddfde49e..0582b92b 100644
--- a/src/core/endpt.c
+++ b/src/core/endpt.c
@@ -9,16 +9,15 @@
 
 #include "core/nng_impl.h"
 
-#include <string.h>
-#include <stdlib.h>
 #include <stdio.h>
+#include <stdlib.h>
+#include <string.h>
 
 // Functionality related to end points.
 
 static nni_objhash *nni_eps = NULL;
-static void *nni_ep_ctor(uint32_t);
-static void nni_ep_dtor(void *);
-
+static void *       nni_ep_ctor(uint32_t);
+static void         nni_ep_dtor(void *);
 
 int
 nni_ep_sys_init(void)
@@ -32,7 +31,6 @@ nni_ep_sys_init(void)
 	return (rv);
 }
 
-
 void
 nni_ep_sys_fini(void)
 {
@@ -40,11 +38,10 @@ nni_ep_sys_fini(void)
 	nni_eps = NULL;
 }
 
-
 int
 nni_ep_find(nni_ep **epp, uint32_t id)
 {
-	int rv;
+	int     rv;
 	nni_ep *ep;
 
 	if ((rv = nni_init()) != 0) {
@@ -68,7 +65,6 @@ nni_ep_find(nni_ep **epp, uint32_t id)
 	return (0);
 }
 
-
 void
 nni_ep_hold(nni_ep *ep)
 {
@@ -78,35 +74,32 @@ nni_ep_hold(nni_ep *ep)
 	NNI_ASSERT(rv == 0);
 }
 
-
 void
 nni_ep_rele(nni_ep *ep)
 {
 	nni_objhash_unref(nni_eps, ep->ep_id);
 }
 
-
 uint32_t
 nni_ep_id(nni_ep *ep)
 {
 	return (ep->ep_id);
 }
 
-
 static void *
 nni_ep_ctor(uint32_t id)
 {
 	nni_ep *ep;
-	int rv;
+	int     rv;
 
 	if ((ep = NNI_ALLOC_STRUCT(ep)) == NULL) {
 		return (NULL);
 	}
 	ep->ep_closed = 0;
-	ep->ep_bound = 0;
-	ep->ep_pipe = NULL;
-	ep->ep_id = id;
-	ep->ep_data = NULL;
+	ep->ep_bound  = 0;
+	ep->ep_pipe   = NULL;
+	ep->ep_id     = id;
+	ep->ep_data   = NULL;
 
 	NNI_LIST_NODE_INIT(&ep->ep_node);
 
@@ -126,7 +119,6 @@ nni_ep_ctor(uint32_t id)
 	return (ep);
 }
 
-
 static void
 nni_ep_dtor(void *ptr)
 {
@@ -140,14 +132,13 @@ nni_ep_dtor(void *ptr)
 	NNI_FREE_STRUCT(ep);
 }
 
-
 int
 nni_ep_create(nni_ep **epp, nni_sock *sock, const char *addr, int mode)
 {
 	nni_tran *tran;
-	nni_ep *ep;
-	int rv;
-	uint32_t id;
+	nni_ep *  ep;
+	int       rv;
+	uint32_t  id;
 
 	if ((tran = nni_tran_find(addr)) == NULL) {
 		return (NNG_ENOTSUP);
@@ -165,14 +156,13 @@ nni_ep_create(nni_ep **epp, nni_sock *sock, const char *addr, int mode)
 	ep->ep_mode = mode;
 
 	// Could safely use strcpy here, but this avoids discussion.
-	(void) snprintf(ep->ep_addr, sizeof (ep->ep_addr), "%s", addr);
+	(void) snprintf(ep->ep_addr, sizeof(ep->ep_addr), "%s", addr);
 
 	// Make a copy of the endpoint operations.  This allows us to
 	// modify them (to override NULLs for example), and avoids an extra
 	// dereference on hot paths.
 	ep->ep_ops = *tran->tran_ep;
 
-
 	if ((rv = ep->ep_ops.ep_init(&ep->ep_data, addr, sock, mode)) != 0) {
 		nni_objhash_unref(nni_eps, id);
 		return (rv);
@@ -187,7 +177,6 @@ nni_ep_create(nni_ep **epp, nni_sock *sock, const char *addr, int mode)
 	return (0);
 }
 
-
 void
 nni_ep_stop(nni_ep *ep)
 {
@@ -200,14 +189,12 @@ nni_ep_stop(nni_ep *ep)
 	nni_mtx_unlock(&ep->ep_mtx);
 }
 
-
 void
 nni_ep_close(nni_ep *ep)
 {
 	nni_ep_stop(ep);
 }
 
-
 void
 nni_ep_remove(nni_ep *ep)
 {
@@ -236,12 +223,11 @@ nni_ep_remove(nni_ep *ep)
 	nni_objhash_unref(nni_eps, ep->ep_id);
 }
 
-
 static int
 nni_ep_connect_aio(nni_ep *ep, void **pipep)
 {
 	nni_aio aio;
-	int rv;
+	int     rv;
 
 	nni_aio_init(&aio, NULL, NULL);
 	aio.a_endpt = ep->ep_data;
@@ -255,12 +241,11 @@ nni_ep_connect_aio(nni_ep *ep, void **pipep)
 	return (rv);
 }
 
-
 static int
 nni_ep_connect_sync(nni_ep *ep)
 {
 	nni_pipe *pipe;
-	int rv;
+	int       rv;
 
 	rv = nni_pipe_create(&pipe, ep, ep->ep_sock, ep->ep_tran);
 	if (rv != 0) {
@@ -281,7 +266,6 @@ nni_ep_connect_sync(nni_ep *ep)
 	return (0);
 }
 
-
 int
 nni_ep_pipe_add(nni_ep *ep, nni_pipe *pipe)
 {
@@ -297,7 +281,6 @@ nni_ep_pipe_add(nni_ep *ep, nni_pipe *pipe)
 	return (0);
 }
 
-
 void
 nni_ep_pipe_remove(nni_ep *ep, nni_pipe *pipe)
 {
@@ -316,14 +299,13 @@ nni_ep_pipe_remove(nni_ep *ep, nni_pipe *pipe)
 	nni_mtx_unlock(&ep->ep_mtx);
 }
 
-
 // nni_dialer is the thread worker that dials in the background.
 static void
 nni_dialer(void *arg)
 {
-	nni_ep *ep = arg;
-	int rv;
-	nni_time cooldown;
+	nni_ep *     ep = arg;
+	int          rv;
+	nni_time     cooldown;
 	nni_duration maxrtime = 0, nmaxrtime;
 	nni_duration defrtime = 0, ndefrtime;
 	nni_duration rtime;
@@ -337,7 +319,7 @@ nni_dialer(void *arg)
 			// Times changed, so reset them.
 			defrtime = ndefrtime;
 			maxrtime = nmaxrtime;
-			rtime = defrtime;
+			rtime    = defrtime;
 		}
 
 		nni_mtx_lock(&ep->ep_mtx);
@@ -380,7 +362,6 @@ nni_dialer(void *arg)
 	}
 }
 
-
 int
 nni_ep_dial(nni_ep *ep, int flags)
 {
@@ -423,12 +404,11 @@ nni_ep_dial(nni_ep *ep, int flags)
 	return (rv);
 }
 
-
 static int
 nni_ep_accept_aio(nni_ep *ep, void **pipep)
 {
 	nni_aio aio;
-	int rv;
+	int     rv;
 
 	nni_aio_init(&aio, NULL, NULL);
 	aio.a_endpt = ep->ep_data;
@@ -442,12 +422,11 @@ nni_ep_accept_aio(nni_ep *ep, void **pipep)
 	return (rv);
 }
 
-
 static int
 nni_ep_accept_sync(nni_ep *ep)
 {
 	nni_pipe *pipe;
-	int rv;
+	int       rv;
 
 	if (ep->ep_closed) {
 		return (NNG_ECLOSED);
@@ -468,12 +447,11 @@ nni_ep_accept_sync(nni_ep *ep)
 	return (0);
 }
 
-
 static void
 nni_listener(void *arg)
 {
 	nni_ep *ep = arg;
-	int rv;
+	int     rv;
 
 	for (;;) {
 		nni_time cooldown;
@@ -534,7 +512,7 @@ nni_listener(void *arg)
 		default:
 			// Other cases we sleep just a tiny bit to avoid
 			// burning the cpu (e.g. out of files).
-			cooldown = 1000;        // 1 msec
+			cooldown = 1000; // 1 msec
 			break;
 		}
 		cooldown += nni_clock();
@@ -549,7 +527,6 @@ nni_listener(void *arg)
 	}
 }
 
-
 int
 nni_ep_listen(nni_ep *ep, int flags)
 {
@@ -594,7 +571,6 @@ nni_ep_listen(nni_ep *ep, int flags)
 	return (0);
 }
 
-
 void
 nni_ep_list_init(nni_list *list)
 {