VladislavD
/
monitor
1
0
Fork 0
Code Issues 4 Pull Requests Packages Projects Releases 1 Wiki Activity

key: String -> Arc<str>

feature/configv2
prplV 2025-05-04 09:31:42 -04:00
parent 281841b68a
commit a16eb78b79
1 changed files with 3 additions and 3 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

6
noxis-rs/src/utils/services.rs
View File

@ -16,7 +16,7 @@ pub mod v2 {
type MpscSender = Arc<Sender<Events>>; type MpscSender = Arc<Sender<Events>>;
// type EventHandlers<'a> = Vec<MpscSender<Events<'a>>>; // type EventHandlers<'a> = Vec<MpscSender<Events<'a>>>;
type EventHandlers = HashMap<String, (Triggers, MpscSender)>; type EventHandlers = HashMap<Arc<str>, (Triggers, MpscSender)>;
// type wrapper for service wait queue // type wrapper for service wait queue
type ConnectionQueue = BTreeMap<u32, VecDeque<Arc<str>>>; type ConnectionQueue = BTreeMap<u32, VecDeque<Arc<str>>>;
@ -92,7 +92,7 @@ pub mod v2 {
}); });
} }
// event add // event add
self.event_registrator.entry(proc_name.to_string()).or_insert((trigger, sender)); self.event_registrator.entry(proc_name).or_insert((trigger, sender));
} }
async fn check_state(&self) -> anyhow::Result<()> { async fn check_state(&self) -> anyhow::Result<()> {
let mut addrs = self.access_url.to_socket_addrs()?; let mut addrs = self.access_url.to_socket_addrs()?;
@ -148,7 +148,7 @@ pub mod v2 {
for name in iterator { for name in iterator {
let proc_name = name.to_string(); let proc_name = name.to_string();
info!("Trying to notify process `{}` ...", &proc_name); info!("Trying to notify process `{}` ...", &proc_name);
let sender_opt = self.event_registrator.get(&proc_name) let sender_opt = self.event_registrator.get(&name)
.map(|(trigger, sender)| .map(|(trigger, sender)|
(trigger.to_service_negative_event(name.clone()), sender) (trigger.to_service_negative_event(name.clone()), sender)
); );