syndicate-lang
/
syndicate-rs
1
0
Fork 0
Code Issues 1 Pull Requests Projects Releases Wiki Activity

More debug in counter.rs

This commit is contained in:
Tony Garnock-Jones 2021-09-28 15:18:33 +02:00
parent e8b7fbad0e
commit fe7086b84b
1 changed files with 6 additions and 0 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

6
syndicate-server/src/counter.rs
View File

@ -4,9 +4,13 @@ use syndicate::actor::*;
pub fn adjust(t: &mut Activation, f: &Arc<Field<isize>>, delta: isize) {
let f = f.clone();
tracing::trace!(v0 = ?t.get(&f), "adjust");
*t.get_mut(&f) += delta;
tracing::trace!(v1 = ?t.get(&f), "adjust");
t.on_stop(move |t| {
tracing::trace!(v0 = ?t.get(&f), "cleanup");
*t.get_mut(&f) -= delta;
tracing::trace!(v1 = ?t.get(&f), "cleanup");
Ok(())
});
}
@ -14,7 +18,9 @@ pub fn adjust(t: &mut Activation, f: &Arc<Field<isize>>, delta: isize) {
pub fn sync_and_adjust<M: 'static + Send>(t: &mut Activation, r: &Arc<Ref<M>>, f: &Arc<Field<isize>>, delta: isize) {
let f = f.clone();
let sync_handler = t.create(move |t: &mut Activation| {
tracing::trace!(v0 = ?t.get(&f), "sync");
*t.get_mut(&f) += delta;
tracing::trace!(v1 = ?t.get(&f), "sync");
Ok(())
});
t.sync(r, sync_handler)