1 file changed +4
-5
lines changed Original file line number Diff line number Diff line change @@ -574,11 +574,10 @@ UnixNetVConnection::net_read_io(NetHandler *nh)
574
574
return ;
575
575
}
576
576
577
- // We should only splice once to the pipe
578
- // Linux splice() does not merge pipe buffer page so there is no guarantee that we can splice to pipe again
579
- // without receiving EAGAIN from pipe even if data_in_pipe < pipe_capacity
580
- // Disable read until consumer finish a successful splice from pipe to socket operation
581
- // which means there are available pages in the pipe
577
+ // We should only splice once to the pipe until the pipe is cleared by consumer
578
+ // Linux splice() does not merge pipe buffer page so there is no guarantee that
579
+ // we can splice to pipe again without receiving EAGAIN from pipe even if data_in_pipe < pipe_capacity
580
+ // Disable read until consumer finish a successful splice from pipe to socket operation and the pipe is empty
582
581
read_disable (nh, this );
583
582
return ;
584
583
}
0 commit comments