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

test(get): cover fast path pre-commit errors (#2502)

Browse Source 
Co-authored-by: houseme <housemecn@gmail.com>
This commit is contained in:
安正超
2026-04-12 20:13:15 +08:00
committed by GitHub
parent 30cc481731
commit 0e697fa7e1
1 changed files with 30 additions and 0 deletions
Download Patch File Download Diff File Expand all files Collapse all files
rustfs/src/app/object_usecase/get_object_flow.rs
+30
View File
@@ -595,4 +595,34 @@ mod tests {
assert_eq!(err.streamed_bytes, 5);
assert_eq!(err.source.kind(), std::io::ErrorKind::UnexpectedEof);
}
#[tokio::test]
async fn materialize_chunk_stream_before_commit_rejects_long_body() {
let chunk_stream: BoxChunkStream = Box::pin(futures_util::stream::iter(vec![
Ok(IoChunk::Shared(bytes::Bytes::from_static(b"hello "))),
Ok(IoChunk::Shared(bytes::Bytes::from_static(b"world!"))),
]));
let err = materialize_chunk_stream_before_commit_with_threshold(chunk_stream, 11, 8 * 1024, 1024)
.await
.unwrap_err();
assert_eq!(err.streamed_bytes, 12);
assert_eq!(err.source.kind(), std::io::ErrorKind::InvalidData);
}
#[tokio::test]
async fn materialize_chunk_stream_before_commit_preserves_midstream_io_errors() {
let chunk_stream: BoxChunkStream = Box::pin(futures_util::stream::iter(vec![
Ok(IoChunk::Shared(bytes::Bytes::from_static(b"hello"))),
Err(std::io::Error::new(std::io::ErrorKind::BrokenPipe, "writer closed")),
]));
let err = materialize_chunk_stream_before_commit_with_threshold(chunk_stream, 11, 8 * 1024, 1024)
.await
.unwrap_err();
assert_eq!(err.streamed_bytes, 5);
assert_eq!(err.source.kind(), std::io::ErrorKind::BrokenPipe);
}
}