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/socket.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/socket.h')
| -rw-r--r-- | src/core/socket.h | 4 |
1 files changed, 4 insertions, 0 deletions
diff --git a/src/core/socket.h b/src/core/socket.h index 2dc06009..56cf60c0 100644 --- a/src/core/socket.h +++ b/src/core/socket.h @@ -87,6 +87,10 @@ extern void nni_sock_unnotify(nni_sock *, nni_notify *); extern void nni_sock_ep_remove(nni_sock *, nni_ep *); +// nni_sock_pipe_init adds the pipe to the socket. It is called by +// the generic pipe creation code. +extern int nni_sock_pipe_init(nni_sock *, nni_pipe *); + extern void nni_sock_pipe_stop(nni_sock *, nni_pipe *); // nni_sock_pipe_ready lets the socket know the pipe is ready for |