diff options
Diffstat (limited to 'src/core/socket.c')
| -rw-r--r-- | src/core/socket.c | 21 |
1 files changed, 18 insertions, 3 deletions
diff --git a/src/core/socket.c b/src/core/socket.c index 6bb1d5d5..dffc8a2d 100644 --- a/src/core/socket.c +++ b/src/core/socket.c @@ -27,14 +27,13 @@ */ struct nng_socket { - int s_proto; nni_mutex_t s_mx; nni_msgqueue_t s_uwq; /* Upper write queue. */ nni_msgqueue_t s_urq; /* Upper read queue. */ - /* uwq */ - /* urq */ + struct nni_protocol s_ops; + /* options */ /* pipes */ /* endpoints */ @@ -43,6 +42,22 @@ struct nng_socket { int s_senderr; /* Protocol state machine use. */ }; +/* + * nni_socket_sendq and nni_socket_recvq are called by the protocol + * to obtain the upper read and write queues. + */ +nni_msgqueue_t +nng_socket_sendq(nng_socket_t s) +{ + return (s->s_uwq); +} + +nni_msgqueue_t +nni_socket_recvq(nng_socket_t s) +{ + return (s->s_urq); +} + int nng_socket_create(nng_socket_t *sockp, int proto) { |