aboutsummaryrefslogtreecommitdiff
path: root/src/core/endpt.h
diff options
context:
space:
mode:
authorGarrett D'Amore <garrett@damore.org>2017-07-15 15:45:48 -0700
committerGarrett D'Amore <garrett@damore.org>2017-07-15 15:45:48 -0700
commit7f95fde8d752dd93c20ff0a209334f4aec549111 (patch)
treef6226f1e9741ae855a96d215600dacb006927434 /src/core/endpt.h
parent5fe345c66139fc3242c4fdbd78bf05e5670581e8 (diff)
downloadnng-7f95fde8d752dd93c20ff0a209334f4aec549111.tar.gz
nng-7f95fde8d752dd93c20ff0a209334f4aec549111.tar.bz2
nng-7f95fde8d752dd93c20ff0a209334f4aec549111.zip
Some initial progress on *connect* async.
This actually is breaking at the moment, because we don't have good integration with timeouts, and there are some frustrating races with timeouts at points that can cause apparent hangs.
Diffstat (limited to 'src/core/endpt.h')
-rw-r--r--src/core/endpt.h3
1 files changed, 2 insertions, 1 deletions
diff --git a/src/core/endpt.h b/src/core/endpt.h
index a47586a0..3350bc59 100644
--- a/src/core/endpt.h
+++ b/src/core/endpt.h
@@ -26,18 +26,19 @@ struct nni_ep {
nni_list_node ep_node; // per socket list
nni_sock * ep_sock;
char ep_addr[NNG_MAXADDRLEN];
- nni_thr ep_thr;
int ep_mode;
int ep_started;
int ep_stop;
int ep_closed; // full shutdown
int ep_bound; // true if we bound locally
+ int ep_refcnt;
nni_mtx ep_mtx;
nni_cv ep_cv;
nni_pipe * ep_pipe; // Connected pipe (dialers only)
nni_list ep_pipes;
nni_aio ep_acc_aio;
nni_aio ep_con_aio;
+ nni_aio ep_con_syn; // used for sync connect
nni_taskq_ent ep_reap_tqe;
};