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 84c922a commit fbff305Copy full SHA for fbff305
shard_connection.cpp
@@ -449,14 +449,9 @@ void shard_connection::process_response(void)
449
450
// update events
451
if (m_bev != NULL) {
452
- // no pending response, nothing to read
453
- if (m_pending_resp == 0) {
454
- bufferevent_disable(m_bev, EV_READ);
455
- }
456
-
457
- // output buffer empty, nothing to write
458
- if (evbuffer_get_length(bufferevent_get_output(m_bev)) == 0) {
459
- bufferevent_disable(m_bev, EV_WRITE);
+ // no pending response (nothing to read) and output buffer empty (nothing to write)
+ if ((m_pending_resp == 0) && (evbuffer_get_length(bufferevent_get_output(m_bev)) == 0)) {
+ bufferevent_disable(m_bev, EV_WRITE|EV_READ);
460
}
461
462
0 commit comments