actix/actix-extras
1
0
Fork 0
mirror of https://github.com/actix/actix-extras.git synced 2024-11-28 01:32:57 +01:00
Code Issues Releases Wiki Activity

Fixed broken build on wrong variable usage (#440)

Browse Source
This commit is contained in:
Mathieu Amiot 2018-08-03 11:11:51 +00:00 committed by Douman
parent 8c89c90c50
commit f8e5d7c6c1
1 changed files with 6 additions and 6 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

12
src/server/worker.rs
View File

@ -307,11 +307,11 @@ impl StreamHandlerType {
let _ = io.set_nodelay(true); let _ = io.set_nodelay(true);
let io = TcpStream::from_std(io, &Handle::default()) let io = TcpStream::from_std(io, &Handle::default())
.expect("failed to associate TCP stream"); .expect("failed to associate TCP stream");
self.settings.ssl_conn_add(); h.ssl_conn_add();
current_thread::spawn(TlsAcceptorExt::accept_async(acceptor, io).then( current_thread::spawn(TlsAcceptorExt::accept_async(acceptor, io).then(
move |res| { move |res| {
self.settings.ssl_conn_del(); h.ssl_conn_del();
match res { match res {
Ok(io) => current_thread::spawn(HttpChannel::new( Ok(io) => current_thread::spawn(HttpChannel::new(
h, io, peer, http2, h, io, peer, http2,
@ -330,11 +330,11 @@ impl StreamHandlerType {
let _ = io.set_nodelay(true); let _ = io.set_nodelay(true);
let io = TcpStream::from_std(io, &Handle::default()) let io = TcpStream::from_std(io, &Handle::default())
.expect("failed to associate TCP stream"); .expect("failed to associate TCP stream");
self.settings.ssl_conn_add(); h.ssl_conn_add();
current_thread::spawn(SslAcceptorExt::accept_async(acceptor, io).then( current_thread::spawn(SslAcceptorExt::accept_async(acceptor, io).then(
move |res| { move |res| {
self.settings.ssl_conn_del(); h.ssl_conn_del();
match res { match res {
Ok(io) => { Ok(io) => {
let http2 = if let Some(p) = let http2 = if let Some(p) =
@ -362,11 +362,11 @@ impl StreamHandlerType {
let _ = io.set_nodelay(true); let _ = io.set_nodelay(true);
let io = TcpStream::from_std(io, &Handle::default()) let io = TcpStream::from_std(io, &Handle::default())
.expect("failed to associate TCP stream"); .expect("failed to associate TCP stream");
self.settings.ssl_conn_add(); h.ssl_conn_add();
current_thread::spawn(ServerConfigExt::accept_async(acceptor, io).then( current_thread::spawn(ServerConfigExt::accept_async(acceptor, io).then(
move |res| { move |res| {
self.settings.ssl_conn_del(); h.ssl_conn_del();
match res { match res {
Ok(io) => { Ok(io) => {
let http2 = if let Some(p) = let http2 = if let Some(p) =