Fix

fluencelabs · Apr 14, 2023 · 0b8b30b · 0b8b30b
1 parent 55e41cc
commit 0b8b30b
Show file tree

Hide file tree

Showing 2 changed files with 6 additions and 3 deletions.
diff --git a/aquamarine/src/actor.rs b/aquamarine/src/actor.rs
@@ -34,9 +34,9 @@ use crate::{AquaRuntime, InterpretationStats};
 
 pub struct Actor<RT, F> {
     /// Particle of that actor is expired after that deadline
-    pub deadline: Deadline,
+    deadline: Deadline,
     future: Option<(usize, Fut<RT>)>,
-    pub mailbox: VecDeque<Particle>,
+    mailbox: VecDeque<Particle>,
     waker: Option<Waker>,
     functions: Functions<F>,
     /// Particle that's memoized on the actor creation.

diff --git a/aquamarine/src/plumber.rs b/aquamarine/src/plumber.rs
@@ -196,7 +196,10 @@ impl<RT: AquaRuntime, F: ParticleFunctionStatic> Plumber<RT, F> {
                 if !actor.is_expired(now) || actor.is_executing() {
                     return true; // keep actor
                 }
-
+                log::debug!(
+                    target: "particle_reap",
+                    "Reaping particle's actor particle_id={particle_id}, peer_id={peer_id})"
+                );
                 // cleanup files and dirs after particle processing (vault & prev_data)
                 // TODO: do not pass vm https://github.com/fluencelabs/fluence/issues/1216
                 if let Err(err) = actor.cleanup(particle_id, &peer_id.to_string(), &mut vm) {