hive-c0re/src/meta.rs

@@ -20,7 +20,6 @@ use std::path::{Path, PathBuf};
 
 use anyhow::{Context, Result, bail};
 use tokio::process::Command;
-use tokio::sync::Mutex;
 
 use crate::lifecycle;
 
@@ -29,17 +28,6 @@ const APPLIED_ROOT: &str = "/var/lib/hyperhive/applied";
 const GIT_NAME: &str = "hive-c0re";
 const GIT_EMAIL: &str = "hive-c0re@hyperhive";
 
-/// Single-writer lock around every meta-repo operation. Git isn't
-/// safe to drive from concurrent processes against the same `.git/`
-/// — two simultaneous `git add` / `commit` invocations race on
-/// `.git/index.lock`; if either dies before releasing, the lock
-/// sticks and the next operation hits "another git process seems to
-/// be running" until somebody `rm`s it manually. Holding this mutex
-/// across each public function's git+nix calls makes parallel
-/// rebuilds (`auto_update` + dashboard-triggered + apply-commit)
-/// take turns instead of colliding.
-static META_LOCK: Mutex<()> = Mutex::const_new(());
-
 /// Where the manager sees this directory inside its container (RO bind).
 #[allow(dead_code)] // wired up by set_nspawn_flags in a follow-up commit
 pub const CONTAINER_MANAGER_META_MOUNT: &str = "/meta";
@@ -68,7 +56,6 @@ pub async fn sync_agents(
     operator_pronouns: &str,
     agents: &[AgentSpec],
 ) -> Result<()> {
-    let _guard = META_LOCK.lock().await;
     let dir = meta_dir();
     std::fs::create_dir_all(&dir).with_context(|| format!("create {}", dir.display()))?;
 
@@ -117,7 +104,6 @@ pub async fn sync_agents(
 /// meta history only carries successful deploys.
 #[allow(dead_code)] // wired up by actions::run_apply_commit in a later commit
 pub async fn prepare_deploy(name: &str) -> Result<()> {
-    let _guard = META_LOCK.lock().await;
     let dir = meta_dir();
     let input = format!("agent-{name}");
     nix(&dir, &["flake", "update", &input]).await?;
@@ -132,7 +118,6 @@ pub async fn prepare_deploy(name: &str) -> Result<()> {
 /// place (nothing staged → nothing to commit).
 #[allow(dead_code)]
 pub async fn finalize_deploy(name: &str, sha: &str, tag: &str) -> Result<()> {
-    let _guard = META_LOCK.lock().await;
     let dir = meta_dir();
     if !has_staged_changes(&dir).await? {
         return Ok(());
@@ -146,7 +131,6 @@ pub async fn finalize_deploy(name: &str, sha: &str, tag: &str) -> Result<()> {
 /// captured in `applied/<n>`'s annotated `failed/<id>` tag.
 #[allow(dead_code)]
 pub async fn abort_deploy() -> Result<()> {
-    let _guard = META_LOCK.lock().await;
     let dir = meta_dir();
     git(&dir, &["restore", "--staged", "flake.lock"]).await?;
     git(&dir, &["restore", "flake.lock"]).await
@@ -173,7 +157,6 @@ async fn has_staged_changes(dir: &Path) -> Result<bool> {
 /// semantics — it always wants the latest main.
 #[allow(dead_code)] // wired up by lifecycle::rebuild in this commit
 pub async fn lock_update_for_rebuild(name: &str) -> Result<()> {
-    let _guard = META_LOCK.lock().await;
     let dir = meta_dir();
     let input = format!("agent-{name}");
     nix(&dir, &["flake", "update", &input]).await?;
@@ -189,7 +172,6 @@ pub async fn lock_update_for_rebuild(name: &str) -> Result<()> {
 /// because the per-agent inputs aren't touched.
 #[allow(dead_code)]
 pub async fn lock_update_hyperhive() -> Result<()> {
-    let _guard = META_LOCK.lock().await;
     let dir = meta_dir();
     nix(&dir, &["flake", "update", "hyperhive"]).await?;
     if git_is_clean(&dir).await? {

hive-c0re/src/migrate.rs

@@ -49,17 +49,6 @@ pub async fn run(coord: &Arc<Coordinator>) -> Result<()> {
         tracing::info!("migration: {KILL_SWITCH} set — skipping");
         return Ok(());
     }
-    // Stale meta index lock: a previous hive-c0re crash mid-`git add`
-    // can leave `.git/index.lock` behind, which blocks every
-    // subsequent meta op until somebody `rm`s it manually. We just
-    // booted so nothing of ours is holding it; safe to clear.
-    let meta_lock = std::path::PathBuf::from("/var/lib/hyperhive/meta/.git/index.lock");
-    if meta_lock.exists() {
-        match std::fs::remove_file(&meta_lock) {
-            Ok(()) => tracing::warn!("cleared stale meta/.git/index.lock"),
-            Err(e) => tracing::warn!(error = ?e, "clear stale meta lock failed"),
-        }
-    }
     let names = enumerate_agents().await;
     tracing::info!(count = names.len(), "migration: scanning");