gsadmin/rustfs
1
0
Fork 0
mirror of https://github.com/rustfs/rustfs.git synced 2026-09-21 10:03:26 +00:00
Code Issues Packages Projects Releases Wiki Activity

test(rpc): assert retryable rejection of stale boot epochs

Browse Source
This commit is contained in:
overtrue
2026-09-15 04:18:27 +08:00
parent 7cfed11c9a
commit 1c4b39b99c
1 changed files with 4 additions and 3 deletions
Download Patch File Download Diff File Expand all files Collapse all files
crates/e2e_test/src/internode_rpc_signature_e2e_test.rs
+4 -3
View File
@@ -58,10 +58,11 @@
//! //!
//! Every covered handler checks the digest before touching storage, and //! Every covered handler checks the digest before touching storage, and
//! `MakeVolume` resolves its disk *after* that check. Aiming at a disk that //! `MakeVolume` resolves its disk *after* that check. Aiming at a disk that
//! cannot exist gives three cleanly separable outcomes with zero side effects //! cannot exist gives four cleanly separable outcomes with zero side effects
//! on the server's real data: //! on the server's real data:
//! //!
//! - `Err(Unauthenticated)` — rejected by `check_auth` (signature layer). //! - `Err(Unauthenticated)` — rejected by `check_auth` (signature layer).
//! - `Err(Unavailable)` — a valid signature with a stale boot epoch, rejected before execution.
//! - `Err(PermissionDenied)` — rejected by the handler's body-digest gate. //! - `Err(PermissionDenied)` — rejected by the handler's body-digest gate.
//! - `Ok(success: false)` — **authentication passed**; the request reached //! - `Ok(success: false)` — **authentication passed**; the request reached
//! handler logic and only then failed on the bogus disk. //! handler logic and only then failed on the bogus disk.
@@ -468,8 +469,8 @@ async fn replay_scope_rejects_replay_path_transplant_and_stale_epoch_e2e() -> Te
rustfs_protos::evict_failed_connection(&url).await; rustfs_protos::evict_failed_connection(&url).await;
assert_rejected( assert_rejected(
call_make_volume(&url, request.clone(), stale_epoch).await, call_make_volume(&url, request.clone(), stale_epoch).await,
Code::Unauthenticated, Code::Unavailable,
None, Some("RPC boot epoch changed"),
"a replay-scoped signature captured before the receiving process restart", "a replay-scoped signature captured before the receiving process restart",
); );