mirrors/ntex
1
0
Fork 0
mirror of https://github.com/ntex-rs/ntex.git synced 2025-04-04 21:37:58 +03:00
Code Issues Projects Releases Packages Wiki Activity

wip

Browse source
This commit is contained in:
Nikolay Kim 2025-03-12 20:16:37 +05:00
parent 9fd6959316
commit 0a20cddd27
2 changed files with 13 additions and 9 deletions
Download patch file Download diff file Expand all files Collapse all files

7
ntex-rt/src/arbiter.rs
View file

@ -152,7 +152,12 @@ impl Arbiter {
} }
} }
fn with_sender(sys_id: usize, id: usize, name: Arc<String>, sender: Sender<ArbiterCommand>) -> Self { fn with_sender(
sys_id: usize,
id: usize,
name: Arc<String>,
sender: Sender<ArbiterCommand>,
) -> Self {
Self { Self {
id, id,
sys_id, sys_id,

15
ntex-rt/src/system.rs
View file

@ -121,11 +121,10 @@ impl System {
/// ///
/// This method should be called from the context where the system has been initialized /// This method should be called from the context where the system has been initialized
pub fn list_arbiters<F, R>(f: F) -> R pub fn list_arbiters<F, R>(f: F) -> R
where F: FnOnce(&[Arbiter]) -> R, where
F: FnOnce(&[Arbiter]) -> R,
{ {
ARBITERS.with(|arbs| { ARBITERS.with(|arbs| f(arbs.borrow().list.as_ref()))
f(arbs.borrow().list.as_ref())
})
} }
pub(super) fn sys(&self) -> &Sender<SystemCommand> { pub(super) fn sys(&self) -> &Sender<SystemCommand> {
@ -185,18 +184,18 @@ pub(super) enum SystemCommand {
pub(super) struct SystemSupport { pub(super) struct SystemSupport {
stop: Option<oneshot::Sender<i32>>, stop: Option<oneshot::Sender<i32>>,
commands: Receiver<SystemCommand>, commands: Receiver<SystemCommand>,
ping_interval: usize, _ping_interval: usize,
} }
impl SystemSupport { impl SystemSupport {
pub(super) fn new( pub(super) fn new(
stop: oneshot::Sender<i32>, stop: oneshot::Sender<i32>,
commands: Receiver<SystemCommand>, commands: Receiver<SystemCommand>,
ping_interval: usize, _ping_interval: usize,
) -> Self { ) -> Self {
Self { Self {
commands, commands,
ping_interval, _ping_interval,
stop: Some(stop), stop: Some(stop),
} }
} }
@ -241,7 +240,7 @@ impl SystemSupport {
for (idx, arb) in arbiters.list.iter().enumerate() { for (idx, arb) in arbiters.list.iter().enumerate() {
if &hnd == arb { if &hnd == arb {
arbiters.list.remove(idx); arbiters.list.remove(idx);
break break;
} }
} }
} }