From a9d85a50f7f9eb19eb4af73fae18162c64cd69ba Mon Sep 17 00:00:00 2001 From: mr-chelyshkin Date: Thu, 19 Feb 2026 14:58:08 +0400 Subject: [PATCH] [fix] minor changes --- src/core/registry.rs | 7 ++++--- src/events/event.rs | 2 +- src/policies/jitter.rs | 4 +++- 3 files changed, 8 insertions(+), 5 deletions(-) diff --git a/src/core/registry.rs b/src/core/registry.rs index 3c4b048..0653d41 100644 --- a/src/core/registry.rs +++ b/src/core/registry.rs @@ -108,10 +108,11 @@ impl Registry { msg = rx.recv() => match msg { Ok(ev) => me.handle_event(&ev).await, Err(tokio::sync::broadcast::error::RecvError::Closed) => break, - Err(tokio::sync::broadcast::error::RecvError::Lagged(_)) => { + Err(tokio::sync::broadcast::error::RecvError::Lagged(n)) => { me.bus.publish( - Event::new(EventKind::TaskFailed) - .with_reason("registry_listener_lagged") + Event::new(EventKind::SubscriberOverflow) + .with_task("registry") + .with_reason(format!("registry_listener_lagged({})", n)) ); continue; } diff --git a/src/events/event.rs b/src/events/event.rs index 1c1ccd7..128c8d9 100644 --- a/src/events/event.rs +++ b/src/events/event.rs @@ -259,7 +259,7 @@ impl Event { /// Creates a new event of the given kind with current timestamp and next sequence number. pub fn new(kind: EventKind) -> Self { Self { - seq: EVENT_SEQ.fetch_add(1, AtomicOrdering::Relaxed), + seq: EVENT_SEQ.fetch_add(1, AtomicOrdering::Release), kind, at: SystemTime::now(), attempt: None, diff --git a/src/policies/jitter.rs b/src/policies/jitter.rs index 21d1b45..f1b8dba 100644 --- a/src/policies/jitter.rs +++ b/src/policies/jitter.rs @@ -68,7 +68,9 @@ impl JitterPolicy { JitterPolicy::None => delay, JitterPolicy::Full => self.full_jitter(delay), JitterPolicy::Equal => self.equal_jitter(delay), - JitterPolicy::Decorrelated => delay, + JitterPolicy::Decorrelated => { + panic!("Decorrelated jitter requires context; use apply_decorrelated() instead") + } } }