aboutsummaryrefslogtreecommitdiff
path: root/src/core/endpt.c
diff options
context:
space:
mode:
authorGarrett D'Amore <garrett@damore.org>2016-12-23 02:08:40 -0800
committerGarrett D'Amore <garrett@damore.org>2016-12-23 02:08:40 -0800
commit229d4c7decb71fd607aaec14ecbae81e380cc700 (patch)
treef35cef9f46113d86a6b33d04c188bbdb948cf150 /src/core/endpt.c
parent471a454900ab6142e5a3c1f53866996172d2aad4 (diff)
downloadnng-229d4c7decb71fd607aaec14ecbae81e380cc700.tar.gz
nng-229d4c7decb71fd607aaec14ecbae81e380cc700.tar.bz2
nng-229d4c7decb71fd607aaec14ecbae81e380cc700.zip
Uncrustify fixes.
Diffstat (limited to 'src/core/endpt.c')
-rw-r--r--src/core/endpt.c8
1 files changed, 7 insertions, 1 deletions
diff --git a/src/core/endpt.c b/src/core/endpt.c
index ad1a0b9a..ba557e3a 100644
--- a/src/core/endpt.c
+++ b/src/core/endpt.c
@@ -20,7 +20,7 @@ struct nng_endpt {
void * ep_data;
nni_list_node_t ep_sock_node;
nni_socket * ep_sock;
- char ep_addr[NNG_MAXADDRLEN];
+ char ep_addr[NNG_MAXADDRLEN];
nni_thread * ep_dialer;
nni_thread * ep_listener;
int ep_close;
@@ -77,6 +77,7 @@ nni_endpt_create(nni_endpt **epp, nni_socket *sock, const char *addr)
return (0);
}
+
void
nni_endpt_destroy(nni_endpt *ep)
{
@@ -96,10 +97,12 @@ nni_endpt_destroy(nni_endpt *ep)
nni_free(ep, sizeof (*ep));
}
+
void
nni_endpt_close(nni_endpt *ep)
{
nni_pipe *pipe;
+
nni_mutex_enter(&ep->ep_mx);
if (ep->ep_close) {
nni_mutex_exit(&ep->ep_mx);
@@ -115,6 +118,7 @@ nni_endpt_close(nni_endpt *ep)
nni_mutex_exit(&ep->ep_mx);
}
+
int
nni_endpt_listen(nni_endpt *ep)
{
@@ -124,6 +128,7 @@ nni_endpt_listen(nni_endpt *ep)
return (ep->ep_ops.ep_listen(ep->ep_data));
}
+
int
nni_endpt_dial(nni_endpt *ep, nni_pipe **pp)
{
@@ -145,6 +150,7 @@ nni_endpt_dial(nni_endpt *ep, nni_pipe **pp)
return (0);
}
+
int
nni_endpt_accept(nni_endpt *ep, nni_pipe **pp)
{