re-add timeout filter when recover from backpressure

This commit is contained in:
fakeshadow 2020-12-28 14:00:09 +08:00
parent 3208d5634e
commit 2f188fcc94
1 changed files with 4 additions and 0 deletions

View File

@ -295,6 +295,10 @@ impl Accept {
if !on {
self.backpressure = false;
for (token, info) in sockets.iter_mut() {
if info.timeout.is_some() {
// socket will attempt to re-register itself when its timeout completes
continue;
}
self.register_logged(token, info);
}
}