summaryrefslogtreecommitdiff
path: root/src/core/socket.h
diff options
context:
space:
mode:
authorGarrett D'Amore <garrett@damore.org>2017-07-10 15:02:38 -0700
committerGarrett D'Amore <garrett@damore.org>2017-07-10 15:02:38 -0700
commit795aebbee77bb74d8792df96dfe1aa79ec9548fc (patch)
tree58c16424c16b9e71cebdceaee4507ab6608f80da /src/core/socket.h
parentde90f97167d2df6739db47b2c6aad85f06250270 (diff)
downloadnng-795aebbee77bb74d8792df96dfe1aa79ec9548fc.tar.gz
nng-795aebbee77bb74d8792df96dfe1aa79ec9548fc.tar.bz2
nng-795aebbee77bb74d8792df96dfe1aa79ec9548fc.zip
Give up on uncrustify; switch to clang-format.
Diffstat (limited to 'src/core/socket.h')
-rw-r--r--src/core/socket.h95
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