diff options
| -rw-r--r-- | src/core/protocol.h | 6 | ||||
| -rw-r--r-- | src/core/sockimpl.h | 74 |
2 files changed, 40 insertions, 40 deletions
diff --git a/src/core/protocol.h b/src/core/protocol.h index 79296cdf..4edebfc2 100644 --- a/src/core/protocol.h +++ b/src/core/protocol.h @@ -122,9 +122,9 @@ struct nni_proto { nni_proto_id proto_self; // Our identity nni_proto_id proto_peer; // Peer identity uint32_t proto_flags; // Protocol flags - const nni_proto_sock_ops *proto_sock_ops; // Per-socket opeations - const nni_proto_pipe_ops *proto_pipe_ops; // Per-pipe operations. - const nni_proto_ctx_ops * proto_ctx_ops; // Context operations. + const nni_proto_sock_ops *proto_sock_ops; // Per-socket operations + const nni_proto_pipe_ops *proto_pipe_ops; // Per-pipe operations + const nni_proto_ctx_ops * proto_ctx_ops; // Context operations // proto_init, if not NULL, provides a function that initializes // global values. The main purpose of this may be to initialize diff --git a/src/core/sockimpl.h b/src/core/sockimpl.h index e9bf69fb..c3b39ab1 100644 --- a/src/core/sockimpl.h +++ b/src/core/sockimpl.h @@ -16,28 +16,28 @@ // are subject to change at any time. struct nni_dialer { - nni_sp_dialer_ops d_ops; // transport ops - nni_sp_tran * d_tran; // transport pointer - void * d_data; // transport private - uint32_t d_id; // endpoint id - nni_list_node d_node; // per socket list - nni_sock * d_sock; - nni_url * d_url; - nni_pipe * d_pipe; // active pipe (for re-dialer) - int d_ref; - bool d_closed; // full shutdown - bool d_closing; - nni_atomic_flag d_started; - nni_mtx d_mtx; - nni_list d_pipes; - nni_aio * d_user_aio; - nni_aio d_con_aio; - nni_aio d_tmo_aio; // backoff timer - nni_duration d_maxrtime; // maximum time for reconnect - nni_duration d_currtime; // current time for reconnect - nni_duration d_inirtime; // initial time for reconnect - nni_time d_conntime; // time of last good connect - nni_reap_node d_reap; + nni_sp_dialer_ops d_ops; // transport ops + nni_sp_tran * d_tran; // transport pointer + void * d_data; // transport private + uint32_t d_id; // endpoint id + nni_list_node d_node; // per socket list + nni_sock * d_sock; + nni_url * d_url; + nni_pipe * d_pipe; // active pipe (for re-dialer) + int d_ref; + bool d_closed; // full shutdown + bool d_closing; + nni_atomic_flag d_started; + nni_mtx d_mtx; + nni_list d_pipes; + nni_aio * d_user_aio; + nni_aio d_con_aio; + nni_aio d_tmo_aio; // backoff timer + nni_duration d_maxrtime; // maximum time for reconnect + nni_duration d_currtime; // current time for reconnect + nni_duration d_inirtime; // initial time for reconnect + nni_time d_conntime; // time of last good connect + nni_reap_node d_reap; #ifdef NNG_ENABLE_STATS nni_stat_item st_root; @@ -59,21 +59,21 @@ struct nni_dialer { }; struct nni_listener { - nni_sp_listener_ops l_ops; // transport ops - nni_sp_tran * l_tran; // transport pointer - void * l_data; // transport private - uint32_t l_id; // endpoint id - nni_list_node l_node; // per socket list - nni_sock * l_sock; - nni_url * l_url; - int l_ref; - bool l_closed; // full shutdown - bool l_closing; // close started (shutdown) - nni_atomic_flag l_started; - nni_list l_pipes; - nni_aio l_acc_aio; - nni_aio l_tmo_aio; - nni_reap_node l_reap; + nni_sp_listener_ops l_ops; // transport ops + nni_sp_tran * l_tran; // transport pointer + void * l_data; // transport private + uint32_t l_id; // endpoint id + nni_list_node l_node; // per socket list + nni_sock * l_sock; + nni_url * l_url; + int l_ref; + bool l_closed; // full shutdown + bool l_closing; // close started (shutdown) + nni_atomic_flag l_started; + nni_list l_pipes; + nni_aio l_acc_aio; + nni_aio l_tmo_aio; + nni_reap_node l_reap; #ifdef NNG_ENABLE_STATS nni_stat_item st_root; |