mirror of
https://github.com/rustfs/rustfs.git
synced 2026-08-17 02:15:28 +00:00
test(site-replication): preserve collapsed retry liability
This commit is contained in:
@@ -14437,7 +14437,7 @@ mod tests {
|
|||||||
}
|
}
|
||||||
|
|
||||||
#[test]
|
#[test]
|
||||||
fn test_retry_event_dequeue_matches_deployment_id_or_endpoint() {
|
fn test_retry_event_dequeue_preserves_collapsed_path_across_peer_identity() {
|
||||||
let peer = PeerInfo {
|
let peer = PeerInfo {
|
||||||
deployment_id: "current-dep".to_string(),
|
deployment_id: "current-dep".to_string(),
|
||||||
..peer("remote", "https://remote.example.com")
|
..peer("remote", "https://remote.example.com")
|
||||||
@@ -14462,9 +14462,8 @@ mod tests {
|
|||||||
|
|
||||||
let removed = dequeue_site_replication_retry_events(&mut queue, &peer, path);
|
let removed = dequeue_site_replication_retry_events(&mut queue, &peer, path);
|
||||||
|
|
||||||
assert_eq!(removed, 1);
|
assert_eq!(removed, 0);
|
||||||
assert_eq!(queue.len(), 1);
|
assert_eq!(queue.len(), 2);
|
||||||
assert_eq!(queue[0].id, "different-path");
|
|
||||||
}
|
}
|
||||||
|
|
||||||
#[test]
|
#[test]
|
||||||
|
|||||||
Reference in New Issue
Block a user