From 82a09d7e58d79df367e0bfaea9a0fbb6c7246eac Mon Sep 17 00:00:00 2001
From: Nick <gurinderu@gmail.com>
Date: Fri, 14 Apr 2023 14:42:00 +0300
Subject: [PATCH] Fix

---
 aquamarine/src/actor.rs   | 4 ++--
 aquamarine/src/plumber.rs | 5 ++++-
 2 files changed, 6 insertions(+), 3 deletions(-)

diff --git a/aquamarine/src/actor.rs b/aquamarine/src/actor.rs
index a915c42f26..c7eff50aba 100644
--- 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
index b54689a859..b67825243f 100644
--- 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) {