generic-library/libzmq
1
0
Fork 0
mirror of https://github.com/zeromq/libzmq.git synced 2025-11-06 13:21:10 +01:00
Code Issues Projects Releases Wiki Activity

Issue #1382: Do not send data to backend when there are no listeners (+ tests)

Browse Source
This commit is contained in:
Rik van der Heijden
2015-04-24 23:01:20 +02:00
parent dbacc34238
commit 7b9e9b838d
6 changed files with 121 additions and 2 deletions
Download Patch File Download Diff File Expand all files Collapse all files

6
src/proxy.cpp
View File

@@ -159,14 +159,16 @@ int zmq::proxy (
}
// Process a request
if (state == active
&& items [0].revents & ZMQ_POLLIN) {
&& items [0].revents & ZMQ_POLLIN
&& items [1].revents & ZMQ_POLLOUT) {
rc = forward(frontend_, backend_, capture_,msg);
if (unlikely (rc < 0))
return -1;
}
// Process a reply
if (state == active
&& items [1].revents & ZMQ_POLLIN) {
&& items [1].revents & ZMQ_POLLIN
&& items [0].revents & ZMQ_POLLOUT) {
rc = forward(backend_, frontend_, capture_,msg);
if (unlikely (rc < 0))
return -1;