do no drain backlog on backpressure
@@ -407,7 +407,7 @@ impl Accept {
}
fn accept(&mut self, sockets: &mut Slab<ServerSocketInfo>, token: usize) {
- loop {
+ while !self.backpressure {
let info = sockets
.get_mut(token)
.expect("ServerSocketInfo is removed from Slab");
