mirror of
https://github.com/rustfs/rustfs.git
synced 2026-08-16 09:58:21 +00:00
chore(ecstore): drop the io_support dead_code blanket (#6082)
This commit is contained in:
@@ -13,7 +13,6 @@
|
|||||||
// limitations under the License.
|
// limitations under the License.
|
||||||
|
|
||||||
// #730: I/O backend selection keeps test-only and staged rio helpers scoped here.
|
// #730: I/O backend selection keeps test-only and staged rio helpers scoped here.
|
||||||
#![allow(dead_code)]
|
|
||||||
|
|
||||||
pub(crate) mod bitrot;
|
pub(crate) mod bitrot;
|
||||||
pub(crate) mod compress;
|
pub(crate) mod compress;
|
||||||
|
|||||||
@@ -25,9 +25,20 @@ use tokio::io::AsyncRead;
|
|||||||
|
|
||||||
#[cfg(feature = "rio-v2")]
|
#[cfg(feature = "rio-v2")]
|
||||||
const MINIO_S2_COMPRESSION_SCHEME: &str = "klauspost/compress/s2";
|
const MINIO_S2_COMPRESSION_SCHEME: &str = "klauspost/compress/s2";
|
||||||
|
// The S2 padding multiple rio-v2 pads compressed streams to before
|
||||||
|
// encryption. Only the padding test asserts it today, so the lib target sees
|
||||||
|
// it as unused (backlog#1823).
|
||||||
#[cfg(feature = "rio-v2")]
|
#[cfg(feature = "rio-v2")]
|
||||||
|
#[allow(dead_code, reason = "on-disk contract asserted by the rio-v2 padding test (backlog#1823)")]
|
||||||
const ENCRYPTED_S2_PADDING_MULTIPLE: usize = 256;
|
const ENCRYPTED_S2_PADDING_MULTIPLE: usize = 256;
|
||||||
|
|
||||||
|
/// Which rio implementation this build compiled in. Only the feature-seam
|
||||||
|
/// guard test in lib.rs reads it, so the lib target sees it as unused
|
||||||
|
/// (backlog#1823).
|
||||||
|
#[allow(
|
||||||
|
dead_code,
|
||||||
|
reason = "asserted by the rio backend feature-seam test in lib.rs (backlog#1823)"
|
||||||
|
)]
|
||||||
pub const fn backend_name() -> &'static str {
|
pub const fn backend_name() -> &'static str {
|
||||||
#[cfg(feature = "rio-v2")]
|
#[cfg(feature = "rio-v2")]
|
||||||
{
|
{
|
||||||
@@ -53,17 +64,6 @@ pub fn compression_metadata_value(algorithm: CompressionAlgorithm) -> String {
|
|||||||
}
|
}
|
||||||
}
|
}
|
||||||
|
|
||||||
pub fn compression_scheme_to_algorithm(scheme: &str) -> std::io::Result<CompressionAlgorithm> {
|
|
||||||
#[cfg(feature = "rio-v2")]
|
|
||||||
if scheme.eq_ignore_ascii_case(MINIO_S2_COMPRESSION_SCHEME) {
|
|
||||||
// rio_v2 currently routes all compressed-object handling through the S2
|
|
||||||
// reader implementation, so the enum is only a placeholder token here.
|
|
||||||
return Ok(CompressionAlgorithm::default());
|
|
||||||
}
|
|
||||||
|
|
||||||
CompressionAlgorithm::from_str(scheme)
|
|
||||||
}
|
|
||||||
|
|
||||||
#[derive(Debug, Clone, Copy, PartialEq, Eq)]
|
#[derive(Debug, Clone, Copy, PartialEq, Eq)]
|
||||||
pub enum ReadCompressionBackend {
|
pub enum ReadCompressionBackend {
|
||||||
Legacy,
|
Legacy,
|
||||||
@@ -82,6 +82,11 @@ pub fn compression_scheme_to_read_plan(scheme: &str) -> std::io::Result<(Compres
|
|||||||
#[derive(Debug, Clone, Copy, PartialEq, Eq)]
|
#[derive(Debug, Clone, Copy, PartialEq, Eq)]
|
||||||
pub enum ReadEncryptionBackend {
|
pub enum ReadEncryptionBackend {
|
||||||
Legacy,
|
Legacy,
|
||||||
|
// Never constructed today — every read still selects Legacy — but the
|
||||||
|
// decrypt paths below carry live match arms for it. This is the rio-v2
|
||||||
|
// read seam (backlog#1638 / #1835), not dead code: deleting the variant
|
||||||
|
// would delete those arms with it.
|
||||||
|
#[allow(dead_code, reason = "rio-v2 read seam; match arms below are live (backlog#1823)")]
|
||||||
V2,
|
V2,
|
||||||
}
|
}
|
||||||
|
|
||||||
|
|||||||
Reference in New Issue
Block a user