MCPcopy Create free account
hub / github.com/NodeDB-Lab/nodedb / set_quiesce

Method set_quiesce

nodedb/src/data/executor/core_loop/accessors.rs:13–18  ·  view source on GitHub ↗

Install the shared scan-quiesce registry. Called once by the server bootstrap in `main.rs` after `SharedState::open`.

(
        &mut self,
        quiesce: std::sync::Arc<crate::bridge::quiesce::CollectionQuiesce>,
    )

Source from the content-addressed store, hash-verified

11 /// Install the shared scan-quiesce registry. Called once by the
12 /// server bootstrap in `main.rs` after `SharedState::open`.
13 pub fn set_quiesce(
14 &mut self,
15 quiesce: std::sync::Arc<crate::bridge::quiesce::CollectionQuiesce>,
16 ) {
17 self.quiesce = Some(quiesce);
18 }
19
20 /// Acquire a scan guard for `(tid, collection)`. Returns `Ok(None)`
21 /// if no quiesce registry is installed (e.g. in tests) — callers

Callers 1

spawn_coreFunction · 0.80

Calls

no outgoing calls

Tested by

no test coverage detected