actix/actix-net
1
0
Fork 0
mirror of https://github.com/fafhrd91/actix-net synced 2025-06-28 12:10:37 +02:00
Code Issues Releases Wiki Activity

add test for restart worker thread (#328)

Browse Source
This commit is contained in:
fakeshadow
2021-04-15 10:49:43 -07:00
committed by GitHub
parent 3c1f57706a
commit 8e98d9168c
2 changed files with 157 additions and 16 deletions
Download Patch File Download Diff File Expand all files Collapse all files

3
actix-server/src/worker.rs
View File

@ -125,6 +125,8 @@ impl WorkerAvailability {
///
/// Worker accepts Socket objects via unbounded channel and starts stream processing.
pub(crate) struct ServerWorker {
// UnboundedReceiver<Conn> should always be the first field.
// It must be dropped as soon as ServerWorker dropping.
rx: UnboundedReceiver<Conn>,
rx2: UnboundedReceiver<Stop>,
services: Box<[WorkerService]>,
@ -370,6 +372,7 @@ impl Default for WorkerState {
impl Drop for ServerWorker {
fn drop(&mut self) {
// Stop the Arbiter ServerWorker runs on on drop.
Arbiter::current().stop();
}
}