From 2764323580ef296249b0b7ca131f60f9f4f68b38 Mon Sep 17 00:00:00 2001 From: Nikolay Kim Date: Thu, 13 Sep 2018 13:32:51 -0700 Subject: [PATCH] fix service availability check --- src/server/mod.rs | 2 +- src/server/worker.rs | 4 ++-- 2 files changed, 3 insertions(+), 3 deletions(-) diff --git a/src/server/mod.rs b/src/server/mod.rs index fb65b430..b080ffe5 100644 --- a/src/server/mod.rs +++ b/src/server/mod.rs @@ -37,5 +37,5 @@ impl Message for StopServer { } /// Socket id token -#[derive(Clone, Copy)] +#[derive(Clone, Copy, Debug)] pub(crate) struct Token(usize); diff --git a/src/server/worker.rs b/src/server/worker.rs index 33d3bc79..985f6891 100644 --- a/src/server/worker.rs +++ b/src/server/worker.rs @@ -20,7 +20,7 @@ use super::accept::AcceptNotify; use super::services::{BoxedServerService, InternalServerServiceFactory, ServerMessage}; use super::Token; -#[derive(Message)] +#[derive(Debug, Message)] pub(crate) struct Conn { pub io: net::TcpStream, pub handler: Token, @@ -148,7 +148,7 @@ impl Worker { }).and_then(|services, act, ctx| { act.services.extend(services); let mut readiness = CheckReadiness { - avail: true, + avail: false, idx: 0, fut: None, };