Remove chain actors (#5502, #5687)

linera-client/src/client_context.rs

@@ -320,8 +320,8 @@ where
             options.long_lived_services,
             chain_modes,
             name,
-            options.chain_worker_ttl,
-            options.sender_chain_worker_ttl,
+            crate::util::non_zero_duration(options.chain_worker_ttl),
+            crate::util::non_zero_duration(options.sender_chain_worker_ttl),
             options.prioritize_bundles_from.clone().unwrap_or_default(),
             options.ignore_bundles_from.clone().unwrap_or_default(),
             options.to_chain_client_options(),

linera-client/src/unit_tests/chain_listener.rs

@@ -120,8 +120,8 @@ async fn test_chain_listener() -> anyhow::Result<()> {
             false,
             [(chain_id0, ListeningMode::FullChain)],
             format!("Client node for {:.8}", chain_id0),
-            Duration::from_secs(30),
-            Duration::from_secs(1),
+            Some(Duration::from_secs(30)),
+            Some(Duration::from_secs(1)),
             HashSet::new(),
             HashSet::new(),
             chain_client::Options::test_default(),
@@ -235,8 +235,8 @@ async fn test_chain_listener_follow_only() -> anyhow::Result<()> {
                 (chain_b_id, ListeningMode::FullChain),
             ],
             "Client node with follow-only and owned chains".to_string(),
-            Duration::from_secs(30),
-            Duration::from_secs(1),
+            Some(Duration::from_secs(30)),
+            Some(Duration::from_secs(1)),
             HashSet::new(),
             HashSet::new(),
             chain_client::Options::test_default(),
@@ -386,8 +386,8 @@ async fn test_chain_listener_admin_chain() -> anyhow::Result<()> {
             false,
             std::iter::empty::<(ChainId, ListeningMode)>(),
             "Client node with no chains".to_string(),
-            Duration::from_secs(30),
-            Duration::from_secs(1),
+            Some(Duration::from_secs(30)),
+            Some(Duration::from_secs(1)),
             HashSet::new(),
             HashSet::new(),
             chain_client::Options::test_default(),
@@ -465,8 +465,8 @@ async fn test_chain_listener_listen_command_adds_chains_to_wallet() -> anyhow::R
             false,
             std::iter::empty::<(ChainId, ListeningMode)>(),
             "Client node with no chains".to_string(),
-            Duration::from_secs(30),
-            Duration::from_secs(1),
+            Some(Duration::from_secs(30)),
+            Some(Duration::from_secs(1)),
             HashSet::new(),
             HashSet::new(),
             chain_client::Options::test_default(),
@@ -584,8 +584,8 @@ async fn test_listener_uses_autosigner_for_incoming_messages() -> anyhow::Result
             false,
             [(chain_id0, ListeningMode::FullChain)],
             format!("Client node for {:.8}", chain_id0),
-            Duration::from_secs(30),
-            Duration::from_secs(1),
+            Some(Duration::from_secs(30)),
+            Some(Duration::from_secs(1)),
             HashSet::new(),
             HashSet::new(),
             chain_client::Options::test_default(),
@@ -787,8 +787,8 @@ async fn test_chain_listener_sparse_event_download() -> anyhow::Result<()> {
             false,
             [(receiver_id, ListeningMode::FullChain)],
             format!("Client node for {:.8}", receiver_id),
-            Duration::from_secs(30),
-            Duration::from_secs(1),
+            Some(Duration::from_secs(30)),
+            Some(Duration::from_secs(1)),
             HashSet::new(),
             HashSet::new(),
             chain_client::Options::test_default(),

linera-client/src/util.rs

@@ -13,6 +13,11 @@ use linera_base::{
 use linera_core::{data_types::RoundTimeout, node::NotificationStream, worker::Reason};
 use tokio_stream::StreamExt as _;
 
+/// Treats a zero `Duration` as `None` (disabled).
+pub fn non_zero_duration(d: Duration) -> Option<Duration> {
+    (d > Duration::ZERO).then_some(d)
+}
+
 pub fn parse_json<T: serde::de::DeserializeOwned>(s: &str) -> anyhow::Result<T> {
     Ok(serde_json::from_str(s.trim())?)
 }

linera-core/Cargo.toml

@@ -76,6 +76,7 @@ proptest = { workspace = true, optional = true }
 rand = { workspace = true, features = ["std_rng"] }
 serde.workspace = true
 serde_json.workspace = true
+sync_wrapper.workspace = true
 test-log = { workspace = true, optional = true }
 test-strategy = { workspace = true, optional = true }
 thiserror.workspace = true

linera-core/src/chain_worker/config.rs

@@ -9,9 +9,12 @@ use linera_base::{crypto::ValidatorSecretKey, identifiers::ChainId, time::Durati
 
 use crate::CHAIN_INFO_MAX_RECEIVED_LOG_ENTRIES;
 
-/// Configuration parameters for the [`ChainWorkerState`][`super::state::ChainWorkerState`].
+/// Configuration parameters for the chain worker and its owning
+/// [`WorkerState`][`crate::worker::WorkerState`].
 #[derive(Clone)]
 pub struct ChainWorkerConfig {
+    /// A name used for logging.
+    pub nickname: String,
     /// The signature key pair of the validator. The key may be missing for replicas
     /// without voting rights (possibly with a partial view of chains).
     pub key_pair: Option<Arc<ValidatorSecretKey>>,
@@ -24,13 +27,17 @@ pub struct ChainWorkerConfig {
     /// Blocks with a timestamp this far in the future will still be accepted, but the validator
     /// will wait until that timestamp before voting.
     pub block_time_grace_period: Duration,
-    /// Idle chain workers free their memory after that duration without requests.
-    pub ttl: Duration,
-    /// TTL for sender chains.
-    // We don't want them to keep in memory forever since usually they're short-lived.
-    pub sender_chain_ttl: Duration,
+    /// Idle chain workers free their memory after this duration without requests.
+    /// `None` means no expiry (handle lives forever).
+    pub ttl: Option<Duration>,
+    /// TTL for sender chains. `None` means no expiry.
+    pub sender_chain_ttl: Option<Duration>,
     /// The size to truncate receive log entries in chain info responses.
     pub chain_info_max_received_log_entries: usize,
+    /// Maximum number of entries in the block cache.
+    pub block_cache_size: usize,
+    /// Maximum number of entries in the execution state cache.
+    pub execution_state_cache_size: usize,
     /// Chain IDs whose incoming bundles should be processed first.
     pub priority_bundle_origins: HashSet<ChainId>,
     /// Chain IDs whose incoming bundles should be ignored.
@@ -63,14 +70,17 @@ impl ChainWorkerConfig {
 impl Default for ChainWorkerConfig {
     fn default() -> Self {
         Self {
+            nickname: String::new(),
             key_pair: None,
             allow_inactive_chains: false,
             allow_messages_from_deprecated_epochs: false,
             long_lived_services: false,
             block_time_grace_period: Default::default(),
-            ttl: Default::default(),
-            sender_chain_ttl: Default::default(),
+            ttl: None,
+            sender_chain_ttl: None,
             chain_info_max_received_log_entries: CHAIN_INFO_MAX_RECEIVED_LOG_ENTRIES,
+            block_cache_size: crate::worker::DEFAULT_BLOCK_CACHE_SIZE,
+            execution_state_cache_size: crate::worker::DEFAULT_EXECUTION_STATE_CACHE_SIZE,
             priority_bundle_origins: HashSet::new(),
             ignored_bundle_origins: HashSet::new(),
             cross_chain_message_chunk_limit: usize::MAX,