Method run_as_holder

crates/openshell-server/src/compute/mod.rs:915–972

(
        self: &Arc<Self>,
        lease: &lease::ReconcilerLease,
        mut guard: lease::LeaseGuard,
        shutdown_rx: &mut watch::Receiver<bool>,
    )

    }

    async fn run_as_holder(
        self: &Arc<Self>,
        lease: &lease::ReconcilerLease,
        mut guard: lease::LeaseGuard,
        shutdown_rx: &mut watch::Receiver<bool>,
    ) {
        use lease::LEASE_RENEWAL_INTERVAL;

        let (cancel_tx, cancel_rx) = watch::channel(false);

        let runtime = self.clone();
        let watch_cancel = cancel_rx.clone();
        let watch_handle = tokio::spawn(async move {
            runtime.watch_loop(watch_cancel).await;
        });

        let runtime = self.clone();
        let reconcile_handle = tokio::spawn(async move {
            runtime.reconcile_loop(cancel_rx).await;
        });

        loop {
            tokio::select! {
                () = tokio::time::sleep(LEASE_RENEWAL_INTERVAL) => {
                    match lease.renew(&mut guard).await {
                        Ok(()) => {
                            debug!(replica = %lease.replica_id(), "renewed reconciler lease");
                        }
                        Err(e) => {
                            warn!(
                                replica = %lease.replica_id(),
                                error = %e,
                                "reconciler lease renewal failed — releasing holder role"
                            );
                            break;
                        }
                    }
                }
                _ = shutdown_rx.changed() => {
                    if *shutdown_rx.borrow() {
                        info!(replica = %lease.replica_id(), "shutdown — releasing reconciler lease");
                        if let Err(e) = lease.release(guard).await {
                            warn!(error = %e, "failed to release reconciler lease on shutdown");
                        }
                        let _ = cancel_tx.send(true);
                        let _ = watch_handle.await;
                        let _ = reconcile_handle.await;
                        return;
                    }
                }
            }
        }

        let _ = cancel_tx.send(true);
        let _ = watch_handle.await;
        let _ = reconcile_handle.await;
        info!(replica = %lease.replica_id(), "reconciler lease lost — returning to standby");
    }