Skip to content

Commit bec9cc4

Browse files
YaacovHazanyaacovhazan-Redislabs
authored andcommitted
fix issue #94 cluster mode stuck (#106)
add missing bufferevent_disable for connections that complete to send new requests
1 parent dd582d2 commit bec9cc4

File tree

1 file changed

+3
-1
lines changed

1 file changed

+3
-1
lines changed

shard_connection.cpp

+3-1
Original file line numberDiff line numberDiff line change
@@ -465,8 +465,10 @@ void shard_connection::fill_pipeline(void)
465465
}
466466

467467
// don't exceed requests
468-
if (m_conns_manager->hold_pipeline(m_id))
468+
if (m_conns_manager->hold_pipeline(m_id)) {
469+
bufferevent_disable(m_bev, EV_WRITE|EV_READ);
469470
break;
471+
}
470472

471473
// client manage requests logic
472474
m_conns_manager->create_request(now, m_id);

0 commit comments

Comments
 (0)