Skip to content

Commit eb97c59

Browse files
committed
actor runtime cleanup
1 parent 962cf4e commit eb97c59

File tree

1 file changed

+5
-34
lines changed

1 file changed

+5
-34
lines changed

crates/theater/src/actor/runtime.rs

Lines changed: 5 additions & 34 deletions
Original file line numberDiff line numberDiff line change
@@ -12,14 +12,11 @@ use crate::interceptor::{RecordingInterceptor, ReplayRecordingInterceptor};
1212
use crate::pack_bridge::{AsyncRuntime, CallInterceptor, HostLinkerBuilder, PackInstance, Value};
1313
use crate::events::wasm::WasmEventData;
1414
use crate::events::ChainEventData;
15-
use crate::handler::Handler;
1615
use crate::handler::HandlerContext;
1716
use crate::handler::HandlerRegistry;
1817
use crate::id::TheaterId;
1918
use crate::messages::TheaterCommand;
2019
use crate::metrics::MetricsCollector;
21-
use crate::store::ContentStore;
22-
use crate::ManifestConfig;
2320

2421
use crate::Result;
2522
use crate::ShutdownController;
@@ -36,34 +33,15 @@ use tracing::{debug, error, info, warn};
3633
use super::types::ActorControl;
3734
use super::types::ActorInfo;
3835

39-
/// Maximum time to wait for graceful shutdown before forceful termination
40-
#[allow(dead_code)]
41-
const SHUTDOWN_TIMEOUT: std::time::Duration = std::time::Duration::from_secs(5);
42-
4336
/// # ActorRuntime
4437
///
4538
/// Coordinates the execution and lifecycle of a single WebAssembly actor within the Theater system.
4639
///
47-
/// `ActorRuntime` manages the various components that make up an actor's execution environment,
48-
/// including handlers and communication channels. It's responsible for starting the actor,
49-
/// setting up its capabilities via handlers, executing operations, and ensuring proper shutdown.
50-
///
51-
/// Note: The struct fields are currently unused as the runtime is driven by the
52-
/// `start()` and `build_actor_resources()` functions which manage the instance
53-
/// through shared wrappers.
54-
#[allow(dead_code)]
55-
pub struct ActorRuntime {
56-
/// Unique identifier for this actor
57-
pub id: TheaterId,
58-
config: ManifestConfig,
59-
handlers: Vec<Box<dyn Handler>>,
60-
metrics: MetricsCollector,
61-
operation_rx: Receiver<ActorOperation>,
62-
info_rx: Receiver<ActorInfo>,
63-
control_rx: Receiver<ActorControl>,
64-
theater_tx: Sender<TheaterCommand>,
65-
actor_phase_manager: ActorPhaseManager,
66-
}
40+
/// `ActorRuntime` provides static methods for building and running actors. It manages the various
41+
/// components that make up an actor's execution environment, including handlers and communication
42+
/// channels. It's responsible for starting the actor, setting up its capabilities via handlers,
43+
/// executing operations, and ensuring proper shutdown.
44+
pub struct ActorRuntime;
6745

6846
/// # Result of starting an actor
6947
///
@@ -220,13 +198,6 @@ impl ActorRuntime {
220198
});
221199
}
222200

223-
// Store manifest (but don't record an event - the manifest hash varies between runs)
224-
let manifest_store = ContentStore::from_id("manifest");
225-
// Manifest storage removed - manifests are now optional and stored
226-
// at the runtime level if needed, not in the actor's content store.
227-
debug!("Actor {} ready (manifest_store available for actor content)", id);
228-
let _ = manifest_store; // suppress unused warning
229-
230201
// ----------------- Checkpoint Load Component -----------------
231202

232203
if !actor_phase_manager.is_phase(ActorPhase::Starting) {

0 commit comments

Comments
 (0)