3party/libzmq
0
0
Fork 0
mirror of https://github.com/zeromq/libzmq.git synced 2025-03-10 07:56:09 +00:00
Code Issues Packages Projects Releases Wiki Activity

Don't reconnect on protocol errors

Browse Source
This commit is contained in:
Martin Hurton 2014-05-18 08:49:29 +02:00
parent ed076d4620
commit 9a53f334d2
1 changed files with 16 additions and 4 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

20
src/session_base.cpp
View File

@ -376,10 +376,22 @@ void zmq::session_base_t::engine_error (
if (pipe) if (pipe)
clean_pipes (); clean_pipes ();
if (active) zmq_assert (reason == stream_engine_t::connection_error
reconnect (); || reason == stream_engine_t::timeout_error
else || reason == stream_engine_t::protocol_error);
terminate ();
switch (reason) {
case stream_engine_t::timeout_error:
case stream_engine_t::connection_error:
if (active)
reconnect ();
else
terminate ();
break;
case stream_engine_t::protocol_error:
terminate ();
break;
}
// Just in case there's only a delimiter in the pipe. // Just in case there's only a delimiter in the pipe.
if (pipe) if (pipe)