Skip to content

Commit

Permalink
Merge pull request #1511 from sorenh/linger_fix
Browse files Browse the repository at this point in the history
Avoid terminating connections prematurely
  • Loading branch information
c-rack committed Aug 6, 2015
2 parents ba6e133 + abc845d commit 84a93d4
Showing 1 changed file with 2 additions and 1 deletion.
3 changes: 2 additions & 1 deletion src/session_base.cpp
Original file line number Diff line number Diff line change
Expand Up @@ -460,7 +460,8 @@ void zmq::session_base_t::process_term (int linger_)
// TODO: Should this go into pipe_t::terminate ?
// 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->check_read ();
if (!engine)
pipe->check_read ();
}

if (zap_pipe != NULL)
Expand Down

0 comments on commit 84a93d4

Please sign in to comment.