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

wip

Browse source
This commit is contained in:
Nikolay Kim 2025-03-13 01:50:28 +05:00
parent 1488809658
commit a1f86846c4
2 changed files with 10 additions and 6 deletions
Download patch file Download diff file Expand all files Collapse all files

2
ntex-rt/src/builder.rs
View file

@ -57,7 +57,7 @@ impl Builder {
/// Sets ping interval for spawned arbiters. /// Sets ping interval for spawned arbiters.
/// ///
/// Interval is in milliseconds. By default 1000 milliseconds is set. /// Interval is in milliseconds. By default 5000 milliseconds is set.
/// To disable pings set value to zero. /// To disable pings set value to zero.
pub fn ping_interval(mut self, interval: usize) -> Self { pub fn ping_interval(mut self, interval: usize) -> Self {
self.ping_interval = interval; self.ping_interval = interval;

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

@ -127,7 +127,8 @@ impl System {
/// Retrieves a list of all arbiters in the system. /// Retrieves a list of all arbiters in the system.
/// ///
/// This method should be called from the context where the system has been initialized /// This method should be called from the thread where the system has been initialized,
/// typically the "main" thread.
pub fn list_arbiters<F, R>(f: F) -> R pub fn list_arbiters<F, R>(f: F) -> R
where where
F: FnOnce(&[Arbiter]) -> R, F: FnOnce(&[Arbiter]) -> R,
@ -137,7 +138,8 @@ impl System {
/// Retrieves a list of last pings records for specified arbiter. /// Retrieves a list of last pings records for specified arbiter.
/// ///
/// This method should be called from the context where the system has been initialized /// This method should be called from the thread where the system has been initialized,
/// typically the "main" thread.
pub fn list_arbiter_pings<F, R>(id: Id, f: F) -> R pub fn list_arbiter_pings<F, R>(id: Id, f: F) -> R
where where
F: FnOnce(Option<&VecDeque<PingRecord>>) -> R, F: FnOnce(Option<&VecDeque<PingRecord>>) -> R,
@ -282,8 +284,10 @@ impl SystemSupport {
#[derive(Copy, Clone, Debug)] #[derive(Copy, Clone, Debug)]
pub struct PingRecord { pub struct PingRecord {
/// Ping start time
pub start: Instant, pub start: Instant,
pub ttl: Option<Duration>, /// Round-trip time, if value is not set then ping is in process
pub rtt: Option<Duration>,
} }
async fn ping_arbiter(arb: Arbiter, interval: Duration) { async fn ping_arbiter(arb: Arbiter, interval: Duration) {
@ -303,7 +307,7 @@ async fn ping_arbiter(arb: Arbiter, interval: Duration) {
PINGS.with(|pings| { PINGS.with(|pings| {
let mut p = pings.borrow_mut(); let mut p = pings.borrow_mut();
let recs = p.entry(arb.id()).or_default(); let recs = p.entry(arb.id()).or_default();
recs.push_front(PingRecord { start, ttl: None }); recs.push_front(PingRecord { start, rtt: None });
recs.truncate(10); recs.truncate(10);
}); });
@ -324,7 +328,7 @@ async fn ping_arbiter(arb: Arbiter, interval: Duration) {
.unwrap() .unwrap()
.front_mut() .front_mut()
.unwrap() .unwrap()
.ttl = Some(Instant::now() - start); .rtt = Some(Instant::now() - start);
}); });
} }
} }