Skip to content

Commit 5a41b82

Browse files
authored
Skip jobs when reinitializing to Faulted (#1583)
Fixes #1579 (hopefully)
1 parent ece8a48 commit 5a41b82

File tree

1 file changed

+8
-1
lines changed

1 file changed

+8
-1
lines changed

upstairs/src/downstairs.rs

+8-1
Original file line numberDiff line numberDiff line change
@@ -654,7 +654,14 @@ impl Downstairs {
654654
// Specifically, we want to skip jobs if the only path back online for
655655
// that client goes through live-repair; if that client can come back
656656
// through replay, then the jobs must remain live.
657-
if matches!(self.clients[client_id].state(), DsState::LiveRepair) {
657+
let client_state = self.clients[client_id].state();
658+
if matches!(
659+
client_state,
660+
DsState::LiveRepair | DsState::LiveRepairReady
661+
) || matches!(
662+
client_state,
663+
DsState::Active | DsState::Offline if !self.can_replay
664+
) {
658665
self.skip_all_jobs(client_id);
659666
}
660667

0 commit comments

Comments
 (0)