mirror of
https://github.com/fafhrd91/actix-net
synced 2025-03-20 16:05:18 +01:00
tweak server logging
This commit is contained in:
parent
a1d15f2e08
commit
1c8fcaebbc
@ -5,7 +5,7 @@ use actix_rt::{
|
|||||||
time::{sleep, Instant},
|
time::{sleep, Instant},
|
||||||
System,
|
System,
|
||||||
};
|
};
|
||||||
use log::{error, info};
|
use log::{debug, error, info};
|
||||||
use mio::{Interest, Poll, Token as MioToken};
|
use mio::{Interest, Poll, Token as MioToken};
|
||||||
|
|
||||||
use crate::server::Server;
|
use crate::server::Server;
|
||||||
@ -229,7 +229,7 @@ impl Accept {
|
|||||||
WAKER_TOKEN => {
|
WAKER_TOKEN => {
|
||||||
let exit = self.handle_waker(sockets);
|
let exit = self.handle_waker(sockets);
|
||||||
if exit {
|
if exit {
|
||||||
info!("Accept is stopped.");
|
info!("Accept thread stopped");
|
||||||
return;
|
return;
|
||||||
}
|
}
|
||||||
}
|
}
|
||||||
@ -365,14 +365,14 @@ impl Accept {
|
|||||||
|
|
||||||
fn register_logged(&self, info: &mut ServerSocketInfo) {
|
fn register_logged(&self, info: &mut ServerSocketInfo) {
|
||||||
match self.register(info) {
|
match self.register(info) {
|
||||||
Ok(_) => info!("Resume accepting connections on {}", info.lst.local_addr()),
|
Ok(_) => debug!("Resume accepting connections on {}", info.lst.local_addr()),
|
||||||
Err(e) => error!("Can not register server socket {}", e),
|
Err(e) => error!("Can not register server socket {}", e),
|
||||||
}
|
}
|
||||||
}
|
}
|
||||||
|
|
||||||
fn deregister_logged(&self, info: &mut ServerSocketInfo) {
|
fn deregister_logged(&self, info: &mut ServerSocketInfo) {
|
||||||
match self.poll.registry().deregister(&mut info.lst) {
|
match self.poll.registry().deregister(&mut info.lst) {
|
||||||
Ok(_) => info!("Paused accepting connections on {}", info.lst.local_addr()),
|
Ok(_) => debug!("Paused accepting connections on {}", info.lst.local_addr()),
|
||||||
Err(e) => {
|
Err(e) => {
|
||||||
error!("Can not deregister server socket {}", e)
|
error!("Can not deregister server socket {}", e)
|
||||||
}
|
}
|
||||||
|
@ -250,7 +250,14 @@ impl ServerBuilder {
|
|||||||
if self.sockets.is_empty() {
|
if self.sockets.is_empty() {
|
||||||
panic!("Server should have at least one bound socket");
|
panic!("Server should have at least one bound socket");
|
||||||
} else {
|
} else {
|
||||||
info!("Starting {} workers", self.threads);
|
for (_, name, lst) in &self.sockets {
|
||||||
|
info!(
|
||||||
|
r#"Starting service: "{}", workers: {}, listening on: {}"#,
|
||||||
|
name,
|
||||||
|
self.threads,
|
||||||
|
lst.local_addr()
|
||||||
|
);
|
||||||
|
}
|
||||||
|
|
||||||
// start workers
|
// start workers
|
||||||
let handles = (0..self.threads)
|
let handles = (0..self.threads)
|
||||||
@ -264,9 +271,6 @@ impl ServerBuilder {
|
|||||||
.collect();
|
.collect();
|
||||||
|
|
||||||
// start accept thread
|
// start accept thread
|
||||||
for sock in &self.sockets {
|
|
||||||
info!("Starting \"{}\" service on {}", sock.1, sock.2);
|
|
||||||
}
|
|
||||||
self.accept.start(
|
self.accept.start(
|
||||||
mem::take(&mut self.sockets)
|
mem::take(&mut self.sockets)
|
||||||
.into_iter()
|
.into_iter()
|
||||||
@ -312,7 +316,7 @@ impl ServerBuilder {
|
|||||||
// Handle `SIGINT`, `SIGTERM`, `SIGQUIT` signals and stop actix system
|
// Handle `SIGINT`, `SIGTERM`, `SIGQUIT` signals and stop actix system
|
||||||
match sig {
|
match sig {
|
||||||
Signal::Int => {
|
Signal::Int => {
|
||||||
info!("SIGINT received, starting forced shutdown");
|
info!("SIGINT received; starting forced shutdown");
|
||||||
self.exit = true;
|
self.exit = true;
|
||||||
self.handle_cmd(ServerCommand::Stop {
|
self.handle_cmd(ServerCommand::Stop {
|
||||||
graceful: false,
|
graceful: false,
|
||||||
@ -321,7 +325,7 @@ impl ServerBuilder {
|
|||||||
}
|
}
|
||||||
|
|
||||||
Signal::Term => {
|
Signal::Term => {
|
||||||
info!("SIGTERM received, starting graceful shutdown");
|
info!("SIGTERM received; starting graceful shutdown");
|
||||||
self.exit = true;
|
self.exit = true;
|
||||||
self.handle_cmd(ServerCommand::Stop {
|
self.handle_cmd(ServerCommand::Stop {
|
||||||
graceful: true,
|
graceful: true,
|
||||||
@ -330,7 +334,7 @@ impl ServerBuilder {
|
|||||||
}
|
}
|
||||||
|
|
||||||
Signal::Quit => {
|
Signal::Quit => {
|
||||||
info!("SIGQUIT received, starting forced shutdown");
|
info!("SIGQUIT received; starting forced shutdown");
|
||||||
self.exit = true;
|
self.exit = true;
|
||||||
self.handle_cmd(ServerCommand::Stop {
|
self.handle_cmd(ServerCommand::Stop {
|
||||||
graceful: false,
|
graceful: false,
|
||||||
@ -390,7 +394,7 @@ impl ServerBuilder {
|
|||||||
}
|
}
|
||||||
|
|
||||||
if found {
|
if found {
|
||||||
error!("Worker has died {:?}, restarting", idx);
|
error!("Worker {} has died; restarting", idx);
|
||||||
|
|
||||||
let mut new_idx = self.handles.len();
|
let mut new_idx = self.handles.len();
|
||||||
'found: loop {
|
'found: loop {
|
||||||
|
@ -466,11 +466,11 @@ impl Future for ServerWorker {
|
|||||||
{
|
{
|
||||||
let num = this.counter.total();
|
let num = this.counter.total();
|
||||||
if num == 0 {
|
if num == 0 {
|
||||||
info!("Shutting down worker, 0 connections");
|
info!("Shutting down idle worker");
|
||||||
let _ = tx.send(true);
|
let _ = tx.send(true);
|
||||||
return Poll::Ready(());
|
return Poll::Ready(());
|
||||||
} else if graceful {
|
} else if graceful {
|
||||||
info!("Graceful worker shutdown, {} connections", num);
|
info!("Graceful worker shutdown; finishing {} connections", num);
|
||||||
this.shutdown(false);
|
this.shutdown(false);
|
||||||
|
|
||||||
this.state = WorkerState::Shutdown(Shutdown {
|
this.state = WorkerState::Shutdown(Shutdown {
|
||||||
@ -479,7 +479,7 @@ impl Future for ServerWorker {
|
|||||||
tx,
|
tx,
|
||||||
});
|
});
|
||||||
} else {
|
} else {
|
||||||
info!("Force shutdown worker, {} connections", num);
|
info!("Force shutdown worker, closing {} connections", num);
|
||||||
this.shutdown(true);
|
this.shutdown(true);
|
||||||
|
|
||||||
let _ = tx.send(false);
|
let _ = tx.send(false);
|
||||||
|
Loading…
x
Reference in New Issue
Block a user