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

problem: wss transport return incorrect return code for error

Browse Source 
Solution: return -1 for errors
This commit is contained in:
somdoron
2019-10-04 20:45:54 +03:00
parent 2018be643a
commit a9bb526403
4 changed files with 53 additions and 8 deletions
Download Patch File Download Diff File Expand all files Collapse all files

6
src/stream_engine_base.cpp
View File

@@ -354,7 +354,7 @@ void zmq::stream_engine_base_t::out_event ()
// If there is no data to send, stop polling for output.
if (_outsize == 0) {
_output_stopped = true;
reset_pollout (_handle);
reset_pollout ();
return;
}
}
@@ -370,7 +370,7 @@ void zmq::stream_engine_base_t::out_event ()
// The engine is not terminated until we detect input error;
// this is necessary to prevent losing incoming messages.
if (nbytes == -1) {
reset_pollout (_handle);
reset_pollout ();
return;
}
@@ -381,7 +381,7 @@ void zmq::stream_engine_base_t::out_event ()
// to send, stop polling for output.
if (unlikely (_handshaking))
if (_outsize == 0)
reset_pollout (_handle);
reset_pollout ();
}
void zmq::stream_engine_base_t::restart_output ()