aboutsummaryrefslogtreecommitdiff
path: root/src/core/socket.c
diff options
context:
space:
mode:
authorGarrett D'Amore <garrett@damore.org>2016-12-14 11:38:04 -0800
committerGarrett D'Amore <garrett@damore.org>2016-12-14 11:38:04 -0800
commitff791199733ee69ca41fd0e1e567cc07e4b2f07f (patch)
treef5f2690665e0a986561252af1e9cd16a5473f938 /src/core/socket.c
parent26d934f3aaedb81e2b2343d235b41b046084ee8a (diff)
downloadnng-ff791199733ee69ca41fd0e1e567cc07e4b2f07f.tar.gz
nng-ff791199733ee69ca41fd0e1e567cc07e4b2f07f.tar.bz2
nng-ff791199733ee69ca41fd0e1e567cc07e4b2f07f.zip
Oops... Pipe list initialization was not complete.
Diffstat (limited to 'src/core/socket.c')
-rw-r--r--src/core/socket.c10
1 files changed, 8 insertions, 2 deletions
diff --git a/src/core/socket.c b/src/core/socket.c
index aeebdf25..d48f2b86 100644
--- a/src/core/socket.c
+++ b/src/core/socket.c
@@ -35,9 +35,11 @@ struct nng_socket {
struct nni_protocol s_ops;
void *s_data; /* Protocol private. */
+
/* options */
- /* pipes */
- /* endpoints */
+
+ nni_list_t s_eps;
+ nni_list_t s_pipes;
int s_besteffort; /* Best effort mode delivery. */
int s_senderr; /* Protocol state machine use. */
@@ -73,6 +75,10 @@ nng_socket_create(nng_socket_t *sockp, uint16_t proto)
return (NNG_ENOMEM);
}
sock->s_ops = *ops;
+
+ nni_pipe_list_init(&sock->s_pipes);
+ //NNI_LIST_INIT(&sock->s_eps, nng_endpt_t, ep_node);
+
if ((rv = sock->s_ops.proto_create(&sock->s_data, sock)) != 0) {
nni_free(sock, sizeof (*sock));
return (rv);