| 220 | } |
| 221 | |
| 222 | bool zmq::pipe_t::write (const msg_t *msg_) |
| 223 | { |
| 224 | if (unlikely (!check_write ())) |
| 225 | return false; |
| 226 | |
| 227 | const bool more = (msg_->flags () & msg_t::more) != 0; |
| 228 | const bool is_routing_id = msg_->is_routing_id (); |
| 229 | _out_pipe->write (*msg_, more); |
| 230 | if (!more && !is_routing_id) |
| 231 | _msgs_written++; |
| 232 | |
| 233 | return true; |
| 234 | } |
| 235 | |
| 236 | void zmq::pipe_t::rollback () const |
| 237 | { |