vinzenz/hyperhive
0
0
Fork 0
Code Issues Pull requests Projects Releases Packages Wiki Activity Actions

fix: move sleep to only occur when recv returns empty, avoid message delivery delay

Browse source
This commit is contained in:
damocles 2026-05-16 13:48:04 +02:00
parent 4ceae6cf67
commit d99e0812d0
1 changed files with 7 additions and 2 deletions
Download patch file Download diff file Expand all files Collapse all files

9
hive-ag3nt/src/bin/hive-ag3nt.rs
View file

@ -166,7 +166,13 @@ async fn serve(
turn::emit_turn_end(&bus, &outcome); turn::emit_turn_end(&bus, &outcome);
bus.set_state(TurnState::Idle); bus.set_state(TurnState::Idle);
} }
Ok(AgentResponse::Empty) => {} Ok(AgentResponse::Empty) => {
// Idle: brief sleep before next poll to avoid busy-looping
// on consecutive Empty responses. The recv() call already
// waits up to 180s for messages, so this is just for
// responsiveness if recv() times out.
tokio::time::sleep(interval).await;
}
Ok(AgentResponse::Ok Ok(AgentResponse::Ok
| AgentResponse::Status { .. } | AgentResponse::Status { .. }
| AgentResponse::Recent { .. } | AgentResponse::Recent { .. }
@ -180,7 +186,6 @@ async fn serve(
tracing::warn!(error = ?e, "recv failed; retrying"); tracing::warn!(error = ?e, "recv failed; retrying");
} }
} }
tokio::time::sleep(interval).await;
} }
} }