Function unique_origin_nodes

nodedb/src/control/backup/orchestrator.rs:161–180

Enumerate the unique node IDs that hold any vShard right now. In single-node mode (no routing table) returns `[self.node_id]`, which may be 0 — that's fine; the section's origin_node_id is only carried for traceability/debugging, not for routing.

(state: &SharedState)

/// which may be 0 — that's fine; the section's origin_node_id is
/// only carried for traceability/debugging, not for routing.
fn unique_origin_nodes(state: &SharedState) -> Vec<u64> {
    let Some(routing) = state.cluster_routing.as_ref() else {
        return vec![state.node_id];
    };
    let table = routing.read().expect("routing table poisoned");
    let mut set = BTreeSet::new();
    for info in table.group_members().values() {
        if info.leader != 0 {
            set.insert(info.leader);
        }
        for &m in &info.members {
            set.insert(m);
        }
    }
    if set.is_empty() {
        vec![state.node_id]
    } else {
        set.into_iter().collect()
    }
}

fn is_self(state: &SharedState, node_id: u64) -> bool {
    node_id == state.node_id || node_id == 0 || state.cluster_transport.is_none()