diff options
| author | Martin Sustrik <sustrik@250bpm.com> | 2011-05-25 10:25:51 +0200 |
|---|---|---|
| committer | Martin Sustrik <sustrik@250bpm.com> | 2011-05-25 10:25:51 +0200 |
| commit | 87a6490b39c44e8f9c521f6ccea14f800a712d3f (patch) | |
| tree | 3a4f5dceb1b737675e57a500e14a74d870d2bc63 /src/socket_base.cpp | |
| parent | 3d4203decf87a5d5fb1718c2163f6d9c6c24328d (diff) | |
All pipe termination code moved to pipe_t
Till now the code was spread over mutliple locations.
Additionally, the code was made more formally correct,
with explicit pipe state machine etc.
Signed-off-by: Martin Sustrik <sustrik@250bpm.com>
Diffstat (limited to 'src/socket_base.cpp')
| -rw-r--r-- | src/socket_base.cpp | 4 |
1 files changed, 2 insertions, 2 deletions
diff --git a/src/socket_base.cpp b/src/socket_base.cpp index fae55f2..1682c05 100644 --- a/src/socket_base.cpp +++ b/src/socket_base.cpp @@ -450,8 +450,8 @@ int zmq::socket_base_t::connect (const char *addr_) // Attach local end of the pipe to the socket object. attach_pipe (pipes [0], blob_t ()); - // Attach remote end of the pipe to the session object. - session->attach_pipe (pipes [1], blob_t ()); + // Attach remote end of the pipe to the session object later on. + session->attach_pipe (pipes [1]); } // Activate the session. Make it a child of this socket. |