actix/actix-net
1
0
Fork 0
mirror of https://github.com/fafhrd91/actix-net synced 2024-11-27 21:22:57 +01:00
Code Issues Releases Wiki Activity

fix service availability check

Browse Source
This commit is contained in:
Nikolay Kim 2018-09-13 13:32:51 -07:00
parent d50829d956
commit 2764323580
2 changed files with 3 additions and 3 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

2
src/server/mod.rs
View File

@ -37,5 +37,5 @@ impl Message for StopServer {
} }
/// Socket id token /// Socket id token
#[derive(Clone, Copy)] #[derive(Clone, Copy, Debug)]
pub(crate) struct Token(usize); pub(crate) struct Token(usize);

4
src/server/worker.rs
View File

@ -20,7 +20,7 @@ use super::accept::AcceptNotify;
use super::services::{BoxedServerService, InternalServerServiceFactory, ServerMessage}; use super::services::{BoxedServerService, InternalServerServiceFactory, ServerMessage};
use super::Token; use super::Token;
#[derive(Message)] #[derive(Debug, Message)]
pub(crate) struct Conn { pub(crate) struct Conn {
pub io: net::TcpStream, pub io: net::TcpStream,
pub handler: Token, pub handler: Token,
@ -148,7 +148,7 @@ impl Worker {
}).and_then(|services, act, ctx| { }).and_then(|services, act, ctx| {
act.services.extend(services); act.services.extend(services);
let mut readiness = CheckReadiness { let mut readiness = CheckReadiness {
avail: true, avail: false,
idx: 0, idx: 0,
fut: None, fut: None,
}; };