Skip to content
Merged
Changes from all commits
Commits
File filter

Filter by extension

Filter by extension

Conversations
Failed to load comments.
Loading
Jump to
Jump to file
Failed to load files.
Loading
Diff view
Diff view
8 changes: 8 additions & 0 deletions src/ws-ckpt/src/crates/daemon/src/listener.rs
Original file line number Diff line number Diff line change
Expand Up @@ -62,6 +62,14 @@ pub async fn run_listener(
break;
}
}

// Reap finished connections. JoinSet holds each task's handle and output
// slot until it is joined, so without this the set grows by one entry per
// CLI invocation and is only released at shutdown. try_join_next never
// awaits, so reaping cannot delay the next accept; a join_next branch in
// the select! above would instead need a second mutable borrow of
// join_set while the accept arm still spawns into it.
while join_set.try_join_next().is_some() {}
Comment thread
yummypeng marked this conversation as resolved.
}

// 7. Wait for in-flight tasks to complete (with timeout)
Expand Down
Loading