gsadmin/rustfs
1
0
Fork 0
mirror of https://github.com/rustfs/rustfs.git synced 2026-07-26 08:18:18 +00:00
Code Issues Packages Projects Releases Wiki Activity

test(ilm): cover manual transition queue pressure (#5189)

Browse Source 
Co-authored-by: heihutu <heihutu@gmail.com>
This commit is contained in:
houseme
2026-07-24 19:10:04 +08:00
committed by GitHub
parent ea417b6a32
commit 7876319811
1 changed files with 33 additions and 15 deletions
Download Patch File Download Diff File Expand all files Collapse all files
crates/ecstore/src/bucket/lifecycle/bucket_lifecycle_ops.rs
+33 -15
View File
@@ -2492,6 +2492,24 @@ impl ManualTransitionRunReport {
pub fn was_truncated(&self) -> bool {
self.truncated_by_limit || self.truncated_by_duration
}
fn record_enqueue_outcome(&mut self, outcome: TransitionEnqueueOutcome) {
match outcome {
TransitionEnqueueOutcome::Queued => self.enqueued = self.enqueued.saturating_add(1),
TransitionEnqueueOutcome::AlreadyInFlight => {
self.skipped_already_in_flight = self.skipped_already_in_flight.saturating_add(1);
}
TransitionEnqueueOutcome::QueueFull => {
self.skipped_queue_full = self.skipped_queue_full.saturating_add(1);
}
TransitionEnqueueOutcome::QueueClosed => {
self.skipped_queue_closed = self.skipped_queue_closed.saturating_add(1);
}
TransitionEnqueueOutcome::QueueSendTimedOut => {
self.skipped_queue_timeout = self.skipped_queue_timeout.saturating_add(1);
}
}
}
}
pub async fn enqueue_transition_for_existing_objects(api: Arc<ECStore>, bucket: &str) -> Result<(), Error> {
@@ -2818,21 +2836,7 @@ async fn enqueue_transition_with_lifecycle_report(
let outcome = runtime_sources::transition_state_handle()
.queue_transition_task_outcome(oi, &event, src)
.await;
match outcome {
TransitionEnqueueOutcome::Queued => report.enqueued = report.enqueued.saturating_add(1),
TransitionEnqueueOutcome::AlreadyInFlight => {
report.skipped_already_in_flight = report.skipped_already_in_flight.saturating_add(1);
}
TransitionEnqueueOutcome::QueueFull => {
report.skipped_queue_full = report.skipped_queue_full.saturating_add(1);
}
TransitionEnqueueOutcome::QueueClosed => {
report.skipped_queue_closed = report.skipped_queue_closed.saturating_add(1);
}
TransitionEnqueueOutcome::QueueSendTimedOut => {
report.skipped_queue_timeout = report.skipped_queue_timeout.saturating_add(1);
}
}
report.record_enqueue_outcome(outcome);
return outcome.is_handled();
}
_ => report.skipped_not_transition = report.skipped_not_transition.saturating_add(1),
@@ -6390,6 +6394,20 @@ mod tests {
assert_eq!(report.skipped_already_transitioned, 1);
}
#[test]
fn manual_transition_report_marks_queue_pressure_partial() {
let options = ManualTransitionRunOptions::default();
let mut report = ManualTransitionRunReport::new("bucket", &options);
report.record_enqueue_outcome(TransitionEnqueueOutcome::QueueFull);
assert_eq!(report.enqueued, 0);
assert_eq!(report.skipped_queue_full, 1);
assert_eq!(report.skipped_queue_closed, 0);
assert_eq!(report.skipped_queue_timeout, 0);
assert!(report.has_partial_enqueue());
}
#[test]
fn manual_transition_version_marker_preserves_null_version_cursor() {
let null_version = ObjectInfo {