Handle client stop during incoming stream handling in 1 more place

hier-failure-domains
Vitaliy Filippov 2023-05-11 01:34:35 +03:00
parent e431ecb715
commit ce4a8067b5
1 changed files with 4 additions and 1 deletions

View File

@ -103,7 +103,10 @@ bool osd_messenger_t::handle_read(int result, osd_client_t *cl)
cl->recv_list.eat(result);
if (cl->recv_list.done >= cl->recv_list.count)
{
handle_finished_read(cl);
if (!handle_finished_read(cl))
{
goto fin;
}
}
}
if (result >= cl->read_iov.iov_len)