actix/actix-web
1
0
Fork 0
mirror of https://github.com/fafhrd91/actix-web synced 2025-01-30 18:42:52 +01:00
Code Issues Releases Wiki Activity

Handle socket read disconnect

Browse Source
This commit is contained in:
Nikolay Kim 2019-05-25 03:07:40 -07:00
parent 3f196f469d
commit 7f12b754e9
3 changed files with 16 additions and 3 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

7
actix-http/CHANGES.md
View File

@ -1,5 +1,12 @@
# Changes # Changes
## [0.2.1] - 2019-05-2
### Fixed
* Handle socket read disconnect
## [0.2.0] - 2019-05-12 ## [0.2.0] - 2019-05-12
### Changed ### Changed

4
actix-http/Cargo.toml
View File

@ -1,6 +1,6 @@
[package] [package]
name = "actix-http" name = "actix-http"
version = "0.2.0" version = "0.2.1"
authors = ["Nikolay Kim <fafhrd91@gmail.com>"] authors = ["Nikolay Kim <fafhrd91@gmail.com>"]
description = "Actix http primitives" description = "Actix http primitives"
readme = "README.md" readme = "README.md"
@ -47,7 +47,7 @@ secure-cookies = ["ring"]
actix-service = "0.4.0" actix-service = "0.4.0"
actix-codec = "0.1.2" actix-codec = "0.1.2"
actix-connect = "0.2.0" actix-connect = "0.2.0"
actix-utils = "0.4.0" actix-utils = "0.4.1"
actix-server-config = "0.1.1" actix-server-config = "0.1.1"
actix-threadpool = "0.1.0" actix-threadpool = "0.1.0"

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

@ -583,6 +583,9 @@ where
self.ka_timer = Some(Delay::new(interval)); self.ka_timer = Some(Delay::new(interval));
} else { } else {
self.flags.insert(Flags::READ_DISCONNECT); self.flags.insert(Flags::READ_DISCONNECT);
if let Some(mut payload) = self.payload.take() {
payload.set_error(PayloadError::Incomplete(None));
}
return Ok(()); return Ok(());
} }
} else { } else {
@ -694,7 +697,10 @@ where
if let Some(true) = if let Some(true) =
read_available(&mut inner.io, &mut inner.read_buf)? read_available(&mut inner.io, &mut inner.read_buf)?
{ {
inner.flags.insert(Flags::READ_DISCONNECT) inner.flags.insert(Flags::READ_DISCONNECT);
if let Some(mut payload) = inner.payload.take() {
payload.feed_eof();
}
} }
} }