generic-library/libzmq
1
0
Fork 0
mirror of https://github.com/zeromq/libzmq.git synced 2024-12-14 02:57:47 +01:00
Code Issues Projects Releases Wiki Activity

Merge pull request #1511 from sorenh/linger_fix

Browse Source 
Avoid terminating connections prematurely
This commit is contained in:
Constantin Rack 2015-08-06 20:45:45 +02:00
commit 84a93d4251
1 changed files with 2 additions and 1 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

3
src/session_base.cpp
View File

@ -460,7 +460,8 @@ void zmq::session_base_t::process_term (int linger_)
// TODO: Should this go into pipe_t::terminate ? // TODO: Should this go into pipe_t::terminate ?
// In case there's no engine and there's only delimiter in the // In case there's no engine and there's only delimiter in the
// pipe it wouldn't be ever read. Thus we check for it explicitly. // pipe it wouldn't be ever read. Thus we check for it explicitly.
pipe->check_read (); if (!engine)
pipe->check_read ();
} }
if (zap_pipe != NULL) if (zap_pipe != NULL)