mirror of
https://github.com/zeromq/libzmq.git
synced 2025-03-17 16:43:58 +00:00
Problem: zmq_proxy_steerable didnt act on PAUSE/RESUME (fixes issue #88)
This commit is contained in:
parent
8a9fece30a
commit
4bba965d98
@ -130,7 +130,8 @@ int zmq::proxy (
|
|||||||
}
|
}
|
||||||
}
|
}
|
||||||
// Process a request
|
// Process a request
|
||||||
if (items [0].revents & ZMQ_POLLIN
|
if (state == active
|
||||||
|
&& items [0].revents & ZMQ_POLLIN
|
||||||
&& items [1].revents & ZMQ_POLLOUT) {
|
&& items [1].revents & ZMQ_POLLOUT) {
|
||||||
while (true) {
|
while (true) {
|
||||||
rc = frontend_->recv (&msg, 0);
|
rc = frontend_->recv (&msg, 0);
|
||||||
@ -163,7 +164,8 @@ int zmq::proxy (
|
|||||||
}
|
}
|
||||||
}
|
}
|
||||||
// Process a reply
|
// Process a reply
|
||||||
if (items [1].revents & ZMQ_POLLIN
|
if (state == active
|
||||||
|
&& items [1].revents & ZMQ_POLLIN
|
||||||
&& items [0].revents & ZMQ_POLLOUT) {
|
&& items [0].revents & ZMQ_POLLOUT) {
|
||||||
while (true) {
|
while (true) {
|
||||||
rc = backend_->recv (&msg, 0);
|
rc = backend_->recv (&msg, 0);
|
||||||
|
Loading…
x
Reference in New Issue
Block a user