diff --git a/syndicate-server/src/counter.rs b/syndicate-server/src/counter.rs index 385e1e8..c15b8dd 100644 --- a/syndicate-server/src/counter.rs +++ b/syndicate-server/src/counter.rs @@ -4,9 +4,13 @@ use syndicate::actor::*; pub fn adjust(t: &mut Activation, f: &Arc>, 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>, delta: isize) { pub fn sync_and_adjust(t: &mut Activation, r: &Arc>, f: &Arc>, 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)