conn limit sequential messages

Process at most 4 messages from one connection
before re-contending.
This commit is contained in:
Michael Davidsaver
2020-04-17 17:35:48 -07:00
parent 2a0dd0ee4f
commit e741e41159
+3 -1
View File
@@ -94,8 +94,10 @@ void ConnBase::bevEvent(short events)
void ConnBase::bevRead()
{
auto rx = bufferevent_get_input(bev.get());
unsigned niter;
while(bev && evbuffer_get_length(rx)>=8) {
for(niter=0; niter<4 && bev && evbuffer_get_length(rx)>=8; niter++) {
uint8_t header[8];
auto ret = evbuffer_copyout(rx, header, sizeof(header));