diff options
| author | Ogulcan Celik <ogulcancelik@gmail.com> | 2026-06-02 23:38:01 +0300 |
|---|---|---|
| committer | Ogulcan Celik <ogulcancelik@gmail.com> | 2026-06-02 23:38:01 +0300 |
| commit | 9ddb03ff347e88558637ce490fbdab63d55a9f3e (patch) | |
| tree | 774ce7499f889921c420c78732bd8c869650654a | |
| parent | 86b5fe01e26d8592a3d8eb4fcebaeef55186fa93 (diff) | |
fix: shorten handoff ownership ack wait
| -rw-r--r-- | .config/nextest.toml | 6 | ||||
| -rw-r--r-- | src/server/handoff.rs | 4 |
2 files changed, 3 insertions, 7 deletions
diff --git a/.config/nextest.toml b/.config/nextest.toml deleted file mode 100644 index 7f8738bc..00000000 --- a/.config/nextest.toml +++ /dev/null @@ -1,6 +0,0 @@ -[test-groups] -live-handoff = { max-threads = 1 } - -[[profile.default.overrides]] -filter = 'binary(live_handoff)' -test-group = 'live-handoff' diff --git a/src/server/handoff.rs b/src/server/handoff.rs index 01f9e678..816537ab 100644 --- a/src/server/handoff.rs +++ b/src/server/handoff.rs @@ -23,6 +23,8 @@ const HANDOFF_VERSION: u32 = 1; #[cfg(unix)] const READY_TIMEOUT: Duration = Duration::from_secs(30); #[cfg(unix)] +const OWNED_ACK_TIMEOUT: Duration = Duration::from_millis(500); +#[cfg(unix)] pub(crate) const MAX_FDS_PER_HANDOFF: usize = 64; #[cfg(unix)] pub(crate) const MAX_REPLAY_BYTES_PER_PANE: usize = 8 * 1024; @@ -198,7 +200,7 @@ pub(crate) fn report_committed(stream: &mut UnixStream) -> io::Result<()> { #[cfg(unix)] pub(crate) fn wait_owned_ack(stream: &mut UnixStream) { - if let Err(err) = stream.set_read_timeout(Some(READY_TIMEOUT)) { + if let Err(err) = stream.set_read_timeout(Some(OWNED_ACK_TIMEOUT)) { warn!(err = %err, "failed to set handoff ownership ack timeout"); return; } |