We read every piece of feedback, and take your input very seriously.
To see all available qualifiers, see our documentation.
There was an error while loading. Please reload this page.
1 parent dd582d2 commit bec9cc4Copy full SHA for bec9cc4
shard_connection.cpp
@@ -465,8 +465,10 @@ void shard_connection::fill_pipeline(void)
465
}
466
467
// don't exceed requests
468
- if (m_conns_manager->hold_pipeline(m_id))
+ if (m_conns_manager->hold_pipeline(m_id)) {
469
+ bufferevent_disable(m_bev, EV_WRITE|EV_READ);
470
break;
471
+ }
472
473
// client manage requests logic
474
m_conns_manager->create_request(now, m_id);
0 commit comments