gilles/asusctl
1
0
Fork 0
mirror of https://gitlab.com/asus-linux/asusctl.git synced 2026-02-06 00:15:04 +01:00
Code Issues Packages Projects Releases Wiki Activity

Previous inotify macro was blocking. Needs async closures...

Browse Source
This commit is contained in:
Luke D. Jones
2022-09-21 22:41:24 +12:00
parent 5d87747d96
commit 283cb7e589
1 changed files with 10 additions and 11 deletions
Download Patch File Download Diff File Expand all files Collapse all files

11
daemon/src/lib.rs
View File

@@ -83,23 +83,22 @@ macro_rules! task_watch_item {
executor: &mut Executor<'a>, executor: &mut Executor<'a>,
signal_ctxt: SignalContext<'a>, signal_ctxt: SignalContext<'a>,
) -> Result<(), RogError> { ) -> Result<(), RogError> {
use zbus::export::futures_util::StreamExt;
let ctrl = self.clone(); let ctrl = self.clone();
concat_idents::concat_idents!(watch_fn = monitor_, $name { concat_idents::concat_idents!(watch_fn = monitor_, $name {
let mut watch = self.$self_inner.watch_fn()?; let mut watch = self.$self_inner.watch_fn()?;
executor executor
.spawn(async move { .spawn(async move {
let mut buffer = [0; 1024]; let mut buffer = [0; 1024];
loop { watch.event_stream(&mut buffer).unwrap().for_each(|e|{
if let Ok(events) = watch.read_events_blocking(&mut buffer) {
for _ in events {
let value = ctrl.$name(); let value = ctrl.$name();
dbg!(value); dbg!(value);
concat_idents::concat_idents!(notif_fn = notify_, $name { concat_idents::concat_idents!(notif_fn = notify_, $name {
Self::notif_fn(&signal_ctxt, value).await.unwrap(); Self::notif_fn(&signal_ctxt, value).await.unwrap();
}); });
} smol::future::ready(())
} }).await;
}
}) })
.detach(); .detach();
dbg!("SPWADEWFWEFE"); dbg!("SPWADEWFWEFE");