diff options
Diffstat (limited to 'src/core/socket.h')
| -rw-r--r-- | src/core/socket.h | 95 |
1 files changed, 47 insertions, 48 deletions
diff --git a/src/core/socket.h b/src/core/socket.h index 928264d9..c4619b42 100644 --- a/src/core/socket.h +++ b/src/core/socket.h @@ -10,82 +10,81 @@ #ifndef CORE_SOCKET_H #define CORE_SOCKET_H - // NB: This structure is supplied here for use by the CORE. Use of this library // OUSIDE of the core is STRICTLY VERBOTEN. NO DIRECT ACCESS BY PROTOCOLS OR // TRANSPORTS. struct nni_socket { - nni_mtx s_mx; - nni_cv s_cv; + nni_mtx s_mx; + nni_cv s_cv; - uint32_t s_id; + uint32_t s_id; - nni_msgq * s_uwq; // Upper write queue - nni_msgq * s_urq; // Upper read queue + nni_msgq *s_uwq; // Upper write queue + nni_msgq *s_urq; // Upper read queue - uint16_t s_protocol; - uint16_t s_peer; - uint32_t s_flags; + uint16_t s_protocol; + uint16_t s_peer; + uint32_t s_flags; - nni_proto_pipe_ops s_pipe_ops; - nni_proto_sock_ops s_sock_ops; + nni_proto_pipe_ops s_pipe_ops; + nni_proto_sock_ops s_sock_ops; - void * s_data; // Protocol private + void *s_data; // Protocol private // XXX: options - nni_duration s_linger; // linger time - nni_duration s_sndtimeo; // send timeout - nni_duration s_rcvtimeo; // receive timeout - nni_duration s_reconn; // reconnect time - nni_duration s_reconnmax; // max reconnect time + nni_duration s_linger; // linger time + nni_duration s_sndtimeo; // send timeout + nni_duration s_rcvtimeo; // receive timeout + nni_duration s_reconn; // reconnect time + nni_duration s_reconnmax; // max reconnect time - nni_list s_eps; // active endpoints - nni_list s_pipes; // active pipes + nni_list s_eps; // active endpoints + nni_list s_pipes; // active pipes - size_t s_rcvmaxsz; // maximum receive size + size_t s_rcvmaxsz; // maximum receive size - int s_ep_pend; // EP dial/listen in progress - int s_closing; // Socket is closing - int s_closed; // Socket closed - int s_besteffort; // Best effort mode delivery - int s_senderr; // Protocol state machine use - int s_recverr; // Protocol state machine use + int s_ep_pend; // EP dial/listen in progress + int s_closing; // Socket is closing + int s_closed; // Socket closed + int s_besteffort; // Best effort mode delivery + int s_senderr; // Protocol state machine use + int s_recverr; // Protocol state machine use - nni_event s_recv_ev; // Event for readability - nni_event s_send_ev; // Event for sendability + nni_event s_recv_ev; // Event for readability + nni_event s_send_ev; // Event for sendability - nni_notifyfd s_send_fd; - nni_notifyfd s_recv_fd; + nni_notifyfd s_send_fd; + nni_notifyfd s_recv_fd; - uint32_t s_nextid; // Next Pipe ID. + uint32_t s_nextid; // Next Pipe ID. }; -extern int nni_sock_sys_init(void); +extern int nni_sock_sys_init(void); extern void nni_sock_sys_fini(void); -extern int nni_sock_find(nni_sock **, uint32_t); -extern void nni_sock_hold(nni_sock *); -extern void nni_sock_rele(nni_sock *); -extern int nni_sock_open(nni_sock **, uint16_t); -extern void nni_sock_close(nni_sock *); -extern int nni_sock_shutdown(nni_sock *); +extern int nni_sock_find(nni_sock **, uint32_t); +extern void nni_sock_hold(nni_sock *); +extern void nni_sock_rele(nni_sock *); +extern int nni_sock_open(nni_sock **, uint16_t); +extern void nni_sock_close(nni_sock *); +extern int nni_sock_shutdown(nni_sock *); extern uint16_t nni_sock_proto(nni_sock *); extern uint16_t nni_sock_peer(nni_sock *); -extern int nni_sock_setopt(nni_sock *, int, const void *, size_t); -extern int nni_sock_getopt(nni_sock *, int, void *, size_t *); -extern int nni_sock_recvmsg(nni_sock *, nni_msg **, nni_time); -extern int nni_sock_sendmsg(nni_sock *, nni_msg *, nni_time); -extern int nni_sock_dial(nni_sock *, const char *, nni_ep **, int); -extern int nni_sock_listen(nni_sock *, const char *, nni_ep **, int); +extern int nni_sock_setopt(nni_sock *, int, const void *, size_t); +extern int nni_sock_getopt(nni_sock *, int, void *, size_t *); +extern int nni_sock_recvmsg(nni_sock *, nni_msg **, nni_time); +extern int nni_sock_sendmsg(nni_sock *, nni_msg *, nni_time); +extern int nni_sock_dial(nni_sock *, const char *, nni_ep **, int); +extern int nni_sock_listen(nni_sock *, const char *, nni_ep **, int); extern uint32_t nni_sock_id(nni_sock *); extern void nni_sock_lock(nni_sock *); extern void nni_sock_unlock(nni_sock *); extern nni_notify *nni_sock_notify(nni_sock *, int, nng_notify_func, void *); -extern void nni_sock_unnotify(nni_sock *, nni_notify *); +extern void nni_sock_unnotify(nni_sock *, nni_notify *); -extern int nni_sock_ep_add(nni_sock *, nni_ep *); +extern int nni_sock_ep_add(nni_sock *, nni_ep *); extern void nni_sock_ep_remove(nni_sock *, nni_ep *); extern void nni_sock_pipe_stop(nni_sock *, nni_pipe *); @@ -123,7 +122,7 @@ extern nni_msgq *nni_sock_recvq(nni_sock *); extern nni_mtx *nni_sock_mtx(nni_sock *); extern nni_duration nni_sock_linger(nni_sock *); -extern size_t nni_sock_rcvmaxsz(nni_sock *); +extern size_t nni_sock_rcvmaxsz(nni_sock *); extern void nni_sock_reconntimes(nni_sock *, nni_duration *, nni_duration *); -#endif // CORE_SOCKET_H +#endif // CORE_SOCKET_H |