diff options
| author | Garrett D'Amore <garrett@damore.org> | 2017-07-15 15:45:48 -0700 |
|---|---|---|
| committer | Garrett D'Amore <garrett@damore.org> | 2017-07-15 15:45:48 -0700 |
| commit | 7f95fde8d752dd93c20ff0a209334f4aec549111 (patch) | |
| tree | f6226f1e9741ae855a96d215600dacb006927434 /src/core/endpt.h | |
| parent | 5fe345c66139fc3242c4fdbd78bf05e5670581e8 (diff) | |
| download | nng-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.h | 3 |
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; }; |
