generic-library/libzmq
1
0
Fork 0
mirror of https://github.com/zeromq/libzmq.git synced 2025-10-29 12:18:04 +01:00
Code Issues Projects Releases Wiki Activity

pipe being attached to the PAIR socket during its termination process is immediately asked to terminate itself

Browse Source
This commit is contained in:
Martin Sustrik
2010-09-01 07:54:57 +02:00
parent 47c064f2ea
commit aaa07613d3
1 changed files with 6 additions and 1 deletions
Download Patch File Download Diff File Expand all files Collapse all files

7
src/pair.cpp
View File

@@ -44,7 +44,6 @@ zmq::pair_t::~pair_t ()
void zmq::pair_t::xattach_pipes (class reader_t *inpipe_, void zmq::pair_t::xattach_pipes (class reader_t *inpipe_,
class writer_t *outpipe_, const blob_t &peer_identity_) class writer_t *outpipe_, const blob_t &peer_identity_)
{ {
zmq_assert (!terminating);
zmq_assert (!inpipe && !outpipe); zmq_assert (!inpipe && !outpipe);
inpipe = inpipe_; inpipe = inpipe_;
@@ -54,6 +53,12 @@ void zmq::pair_t::xattach_pipes (class reader_t *inpipe_,
outpipe = outpipe_; outpipe = outpipe_;
outpipe_alive = true; outpipe_alive = true;
outpipe->set_event_sink (this); outpipe->set_event_sink (this);
if (terminating) {
register_term_acks (2);
inpipe_->terminate ();
outpipe_->terminate ();
}
} }
void zmq::pair_t::terminated (class reader_t *pipe_) void zmq::pair_t::terminated (class reader_t *pipe_)