mirror of
https://github.com/rustfs/rustfs.git
synced 2026-08-23 12:49:04 +00:00
fix(ecstore): remove duplicate decommission error helper
This commit is contained in:
@@ -1049,22 +1049,6 @@ fn resolve_decommission_partial_listing_entry(
|
|||||||
))
|
))
|
||||||
}
|
}
|
||||||
|
|
||||||
async fn record_decommission_entry_error(
|
|
||||||
entry_error: &Arc<tokio::sync::Mutex<Option<Error>>>,
|
|
||||||
rx: &CancellationToken,
|
|
||||||
err: Error,
|
|
||||||
) {
|
|
||||||
if rx.is_cancelled() {
|
|
||||||
return;
|
|
||||||
}
|
|
||||||
|
|
||||||
let mut first_err = entry_error.lock().await;
|
|
||||||
if first_err.is_none() && !rx.is_cancelled() {
|
|
||||||
*first_err = Some(err);
|
|
||||||
rx.cancel();
|
|
||||||
}
|
|
||||||
}
|
|
||||||
|
|
||||||
fn validate_decommission_durable_ilm_copy(
|
fn validate_decommission_durable_ilm_copy(
|
||||||
path: &str,
|
path: &str,
|
||||||
source_record: &ValidatedDurableIlmRecord,
|
source_record: &ValidatedDurableIlmRecord,
|
||||||
|
|||||||
Reference in New Issue
Block a user