ext/zeromq/src/session_base.cpp in rbczmq-1.7.4 vs ext/zeromq/src/session_base.cpp in rbczmq-1.7.5
- old
+ new
@@ -241,11 +241,11 @@
pipe->check_read ();
return;
}
if (likely (pipe_ == pipe))
- engine->activate_out ();
+ engine->restart_output ();
else
engine->zap_msg_available ();
}
void zmq::session_base_t::write_activated (pipe_t *pipe_)
@@ -255,10 +255,10 @@
zmq_assert (terminating_pipes.count (pipe_) == 1);
return;
}
if (engine)
- engine->activate_in ();
+ engine->restart_input ();
}
void zmq::session_base_t::hiccuped (pipe_t *)
{
// Hiccups are always sent from session to socket, not the other