aboutsummaryrefslogtreecommitdiff
path: root/src/core/socket.c
diff options
context:
space:
mode:
authorGarrett D'Amore <garrett@damore.org>2017-01-07 22:13:33 -0800
committerGarrett D'Amore <garrett@damore.org>2017-01-07 22:13:33 -0800
commitac007b5a8703504a0579b5c0a6f6771078f36245 (patch)
tree01c6f4eac5320badd1a5e0f5e378c1b310ac06cb /src/core/socket.c
parent4121745aad5b3a1c483c6bffb22dcae6e132d4f9 (diff)
downloadnng-ac007b5a8703504a0579b5c0a6f6771078f36245.tar.gz
nng-ac007b5a8703504a0579b5c0a6f6771078f36245.tar.bz2
nng-ac007b5a8703504a0579b5c0a6f6771078f36245.zip
Uncrustify fix for last.
Diffstat (limited to 'src/core/socket.c')
-rw-r--r--src/core/socket.c44
1 files changed, 23 insertions, 21 deletions
diff --git a/src/core/socket.c b/src/core/socket.c
index 2ef35d7a..e9f61e97 100644
--- a/src/core/socket.c
+++ b/src/core/socket.c
@@ -138,6 +138,8 @@ nni_sock_open(nni_sock **sockp, uint16_t pnum)
nni_sock *sock;
nni_proto *proto;
int rv;
+ nni_proto_sock_ops *sops;
+ nni_proto_pipe_ops *pops;
if ((proto = nni_proto_find(pnum)) == NULL) {
return (NNG_ENOTSUP);
@@ -160,27 +162,29 @@ nni_sock_open(nni_sock **sockp, uint16_t pnum)
NNI_LIST_INIT(&sock->s_eps, nni_ep, ep_node);
sock->s_sock_ops = *proto->proto_sock_ops;
- if (sock->s_sock_ops.sock_sfilter == NULL) {
- sock->s_sock_ops.sock_sfilter = nni_sock_nullfilter;
+ sops = &sock->s_sock_ops;
+ if (sops->sock_sfilter == NULL) {
+ sops->sock_sfilter = nni_sock_nullfilter;
}
- if (sock->s_sock_ops.sock_rfilter == NULL) {
- sock->s_sock_ops.sock_rfilter = nni_sock_nullfilter;
+ if (sops->sock_rfilter == NULL) {
+ sops->sock_rfilter = nni_sock_nullfilter;
}
- if (sock->s_sock_ops.sock_getopt == NULL) {
- sock->s_sock_ops.sock_getopt = nni_sock_nullgetopt;
+ if (sops->sock_getopt == NULL) {
+ sops->sock_getopt = nni_sock_nullgetopt;
}
- if (sock->s_sock_ops.sock_setopt == NULL) {
- sock->s_sock_ops.sock_setopt = nni_sock_nullsetopt;
+ if (sops->sock_setopt == NULL) {
+ sops->sock_setopt = nni_sock_nullsetopt;
}
- if (sock->s_sock_ops.sock_close == NULL) {
- sock->s_sock_ops.sock_close = nni_sock_nullop;
+ if (sops->sock_close == NULL) {
+ sops->sock_close = nni_sock_nullop;
}
sock->s_pipe_ops = *proto->proto_pipe_ops;
- if (sock->s_pipe_ops.pipe_add == NULL) {
- sock->s_pipe_ops.pipe_add = nni_sock_nulladdpipe;
+ pops = &sock->s_pipe_ops;
+ if (pops->pipe_add == NULL) {
+ pops->pipe_add = nni_sock_nulladdpipe;
}
- if (sock->s_pipe_ops.pipe_rem == NULL) {
- sock->s_pipe_ops.pipe_rem = nni_sock_nullop;
+ if (pops->pipe_rem == NULL) {
+ pops->pipe_rem = nni_sock_nullop;
}
if ((rv = nni_mtx_init(&sock->s_mx)) != 0) {
@@ -217,7 +221,7 @@ nni_sock_open(nni_sock **sockp, uint16_t pnum)
return (rv);
}
- if ((rv = sock->s_sock_ops.sock_init(&sock->s_data, sock)) != 0) {
+ if ((rv = sops->sock_init(&sock->s_data, sock)) != 0) {
nni_msgq_fini(sock->s_urq);
nni_msgq_fini(sock->s_uwq);
nni_thr_fini(&sock->s_reaper);
@@ -229,11 +233,10 @@ nni_sock_open(nni_sock **sockp, uint16_t pnum)
// NB: If these functions are NULL, the thread initialization is
// largely a NO-OP. The system won't actually create the threads.
- rv = nni_thr_init(&sock->s_sender, sock->s_sock_ops.sock_send,
- sock->s_data);
+ rv = nni_thr_init(&sock->s_sender, sops->sock_send, sock->s_data);
if (rv != 0) {
nni_thr_wait(&sock->s_reaper);
- sock->s_sock_ops.sock_fini(&sock->s_data);
+ sops->sock_fini(&sock->s_data);
nni_msgq_fini(sock->s_urq);
nni_msgq_fini(sock->s_uwq);
nni_thr_fini(&sock->s_reaper);
@@ -241,11 +244,10 @@ nni_sock_open(nni_sock **sockp, uint16_t pnum)
nni_mtx_fini(&sock->s_mx);
NNI_FREE_STRUCT(sock);
}
- rv = nni_thr_init(&sock->s_recver, sock->s_sock_ops.sock_recv,
- sock->s_data);
+ rv = nni_thr_init(&sock->s_recver, sops->sock_recv, sock->s_data);
if (rv != 0) {
nni_thr_wait(&sock->s_sender);
- sock->s_sock_ops.sock_fini(&sock->s_data);
+ sops->sock_fini(&sock->s_data);
nni_msgq_fini(sock->s_urq);
nni_msgq_fini(sock->s_uwq);
nni_thr_fini(&sock->s_sender);