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

Merge pull request #1043 from hurtonm/dont_reconnect_on_protocol_errors

Browse Source 
Don't reconnect on protocol errors
This commit is contained in:
Pieter Hintjens 2014-05-18 10:53:32 +02:00
commit 77f5f7adae
1 changed files with 16 additions and 4 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

12
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 ();
zmq_assert (reason == stream_engine_t::connection_error
|| reason == stream_engine_t::timeout_error
|| reason == stream_engine_t::protocol_error);
switch (reason) {
case stream_engine_t::timeout_error:
case stream_engine_t::connection_error:
if (active) if (active)
reconnect (); reconnect ();
else else
terminate (); 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)