vinzenz/hyperhive
vinzenz/hyperhive
Watch
0
0
Fork
You've already forked hyperhive
 0
Code Issues Pull requests Projects Releases Packages Wiki Activity Actions

fix(#2290): update stale spawn_poll references in comments

Browse source
This commit is contained in:
atlas 2026-07-09 01:07:35 +02:00
commit df44becd4a
2 changed files with 5 additions and 6 deletions
Download patch file Download diff file Expand all files Collapse all files

9
hive-c0re/src/coordinator.rs
View file

@ -1452,12 +1452,11 @@ impl Coordinator {
/// Ensure a runtime dir + (for sub-agents) per-agent socket exists. /// Ensure a runtime dir + (for sub-agents) per-agent socket exists.
/// ///
/// **Prefer the split form:** /// **Prefer the split form (event-driven):**
/// - dir creation → `lifecycle::ensure_agent_runtime_dir(name)` /// - dir creation → `lifecycle::ensure_agent_runtime_dir(name)`
/// - listener registration → `register_agent(name)` (eagerly, on first /// - listener registration → `register_agent(name)` at each explicit
/// spawn) or leave it to `mcp_sockets::spawn_poll` (reconcile within /// lifecycle event (spawn, reconcile-start). `mcp_sockets::sync_on_start`
/// 10 s, safe for the start + rebuild paths where the container /// covers the daemon-restart case.
/// takes longer than that to boot).
/// ///
/// This method is kept as a convenience shim for any remaining callers /// This method is kept as a convenience shim for any remaining callers
/// that need the combined semantics in one call. /// that need the combined semantics in one call.

2
hive-c0re/src/job_queue/exec.rs
View file

@ -344,7 +344,7 @@ async fn run_drain(coord: &Arc<Coordinator>, claim: &Claim, ctx: &Ctx<'_>) -> Re
async fn run_write_dropin(coord: &Arc<Coordinator>, claim: &Claim) -> Result<NodeOutput> { async fn run_write_dropin(coord: &Arc<Coordinator>, claim: &Claim) -> Result<NodeOutput> {
let name = &claim.agent; let name = &claim.agent;
// write_dropins only needs the path value to build AgentPaths; the // write_dropins only needs the path value to build AgentPaths; the
// dir doesn't need to exist at this point (created by ensure_runtime // dir doesn't need to exist at this point (created by ensure_agent_runtime_dir
// on the upstream Prebuild/Start node). // on the upstream Prebuild/Start node).
let agent_dir = Coordinator::agent_dir(name); let agent_dir = Coordinator::agent_dir(name);
let hive = coord.hive_env(); let hive = coord.hive_env();