From bca0a27e2f4978a5a74748b07613c0e30014880c Mon Sep 17 00:00:00 2001 From: Garrett D'Amore Date: Thu, 22 Dec 2016 23:17:12 -0800 Subject: Implemened synchronous & asynchronuos dialer, accepter. Getting close... --- src/core/endpt.h | 24 +++++++++++++----------- 1 file changed, 13 insertions(+), 11 deletions(-) (limited to 'src/core/endpt.h') diff --git a/src/core/endpt.h b/src/core/endpt.h index 7512daa8..64935c4c 100644 --- a/src/core/endpt.h +++ b/src/core/endpt.h @@ -16,17 +16,19 @@ // OUSIDE of the core is STRICTLY VERBOTEN. NO DIRECT ACCESS BY PROTOCOLS // OR TRANSPORTS. struct nng_endpt { - nni_endpt_ops ep_ops; - void * ep_data; // Transport private - nni_list_node ep_sock_node; // Per socket list - nni_socket * ep_sock; - char ep_addr[NNG_MAXADDRLEN]; - nni_thread * ep_dialer; - nni_thread * ep_listener; - int ep_close; - nni_mutex ep_mx; - nni_cond ep_cv; - nni_list ep_pipes; // Active list of pipes + nni_endpt_ops ep_ops; + void * ep_data; // Transport private + nni_list_node ep_sock_node; // Per socket list + nni_socket * ep_sock; + char ep_addr[NNG_MAXADDRLEN]; + nni_thread * ep_dialer; + nni_thread * ep_listener; + int ep_stop; // thread exits before start + int ep_start; // start thread running + int ep_close; // full shutdown + nni_mutex ep_mx; + nni_cond ep_cv; + nni_pipe * ep_pipe; // Connected pipe (dialers only) }; extern int nni_endpt_create(nni_endpt **, nni_socket *, const char *); -- cgit v1.2.3-70-g09d2