diff options
Diffstat (limited to 'src/core/sockimpl.h')
| -rw-r--r-- | src/core/sockimpl.h | 74 |
1 files changed, 37 insertions, 37 deletions
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; |