Skip to content

Commit 4892ea1

Browse files
authored
Merge pull request #7 from cloudflare/cbranch/nonblock
Set restart coordinator socket to nonblocking mode
2 parents c7a87f1 + 185aba2 commit 4892ea1

File tree

1 file changed

+1
-0
lines changed

1 file changed

+1
-0
lines changed

src/lib.rs

Lines changed: 1 addition & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -344,6 +344,7 @@ fn new_restart_coordination_socket_stream(
344344
) -> io::Result<(Option<OwnedFd>, impl Stream<Item = RestartResponder>)> {
345345
if let Some(path) = restart_coordination_socket {
346346
let listener = bind_restart_coordination_socket(path)?;
347+
listener.set_nonblocking(true)?;
347348
let inherit_socket = OwnedFd::from(listener.try_clone()?);
348349
let listener = UnixListener::from_std(listener)?;
349350
let st = listen_for_restart_events(listener);

0 commit comments

Comments
 (0)