berkus
/
actix-web
mirror of https://github.com/fafhrd91/actix-web
1
0
Fork 0
Code Issues Releases Wiki Activity

fix extra branch in h1 dispatcher timer

This commit is contained in:
fakeshadow 2021-01-07 22:25:43 +08:00
parent d3c476b8c2
commit 1c73dcfa83
1 changed files with 10 additions and 15 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

25
actix-http/src/h1/dispatcher.rs
View File

@ -687,15 +687,11 @@ where
if let Some(deadline) =
this.codec.config().client_disconnect_timer()
{
if let Some(timer) = this.ka_timer.as_mut().as_pin_mut()
if let Some(mut timer) =
this.ka_timer.as_mut().as_pin_mut()
{
timer.reset(deadline);
let _ = this
.ka_timer
.as_mut()
.as_pin_mut()
.unwrap()
.poll(cx);
timer.as_mut().reset(deadline);
let _ = timer.poll(cx);
}
} else {
// no shutdown timeout, drop socket
@ -720,15 +716,14 @@ where
} else if let Some(deadline) =
this.codec.config().keep_alive_expire()
{
if let Some(timer) = this.ka_timer.as_mut().as_pin_mut() {
timer.reset(deadline);
let _ =
this.ka_timer.as_mut().as_pin_mut().unwrap().poll(cx);
if let Some(mut timer) = this.ka_timer.as_mut().as_pin_mut() {
timer.as_mut().reset(deadline);
let _ = timer.poll(cx);
}
}
} else if let Some(timer) = this.ka_timer.as_mut().as_pin_mut() {
timer.reset(*this.ka_expire);
let _ = this.ka_timer.as_mut().as_pin_mut().unwrap().poll(cx);
} else if let Some(mut timer) = this.ka_timer.as_mut().as_pin_mut() {
timer.as_mut().reset(*this.ka_expire);
let _ = timer.poll(cx);
}
}
Poll::Pending => {}