session: workaround for stream.close interrupted

pull/2356/head
mwojcik 2024-02-27 16:52:36 +08:00 committed by Sébastien Bourdeauducq
parent 450fe91e93
commit 42d3c3b4b2
1 changed files with 7 additions and 1 deletions

View File

@ -976,7 +976,13 @@ pub fn thread(io: Io, aux_mutex: &Mutex,
drtio::clear_buffers(&io, &aux_mutex);
}
}
stream.close().expect("session: close socket");
loop {
match stream.close() {
Ok(_) => break,
Err(SchedError::Interrupted) => (),
Err(e) => panic!("session: close socket: {:?}", e)
};
}
});
}