diff options
| author | Martin Sustrik <sustrik@fastmq.commkdir> | 2009-09-16 14:02:43 +0200 |
|---|---|---|
| committer | Martin Sustrik <sustrik@fastmq.commkdir> | 2009-09-16 14:02:43 +0200 |
| commit | 4631fde7e385ea31e85f41290614afb9bda391c9 (patch) | |
| tree | 4e936e8835d461eebc23ed9673ef874837492173 /src/session.cpp | |
| parent | 9c522dccaf0b2c8074bd96fbfb4c968f45748ba4 (diff) | |
ZMQII-8: Failure during orphan pipe deallocation
Diffstat (limited to 'src/session.cpp')
| -rw-r--r-- | src/session.cpp | 6 |
1 files changed, 5 insertions, 1 deletions
diff --git a/src/session.cpp b/src/session.cpp index 9593827..d455462 100644 --- a/src/session.cpp +++ b/src/session.cpp @@ -55,6 +55,9 @@ bool zmq::session_t::read (::zmq_msg_t *msg_) bool zmq::session_t::write (::zmq_msg_t *msg_) { + if (!out_pipe) + return true; + if (out_pipe->write (msg_)) { zmq_msg_init (msg_); return true; @@ -65,7 +68,8 @@ bool zmq::session_t::write (::zmq_msg_t *msg_) void zmq::session_t::flush () { - out_pipe->flush (); + if (out_pipe) + out_pipe->flush (); } void zmq::session_t::detach () |