smeb_y/0g-storage-node
1
0
Fork 0
mirror of https://github.com/0glabs/0g-storage-node.git synced 2025-04-04 07:27:27 +00:00
Code Issues Actions Packages Projects Releases Wiki Activity

chunk_write_control.rs

Browse Source
This commit is contained in:
Eric 2025-02-15 15:00:20 +03:00
parent 5a6f132934
commit 341bf016e7
No known key found for this signature in database
GPG Key ID: F019D208BD1B7DE6
1 changed files with 2 additions and 2 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

4
node/chunk_pool/src/mem_pool/chunk_write_control.rs
View File

@ -13,7 +13,7 @@ enum SlotStatus {
} }
/// Sliding window is used to control the concurrent uploading process of a file. /// Sliding window is used to control the concurrent uploading process of a file.
/// Bounded window allows segments to be uploaded concurrenly, while having a capacity /// Bounded window allows segments to be uploaded concurrently, while having a capacity
/// limit on writing threads per file. Meanwhile, the left_boundary field records /// limit on writing threads per file. Meanwhile, the left_boundary field records
/// how many segments have been uploaded. /// how many segments have been uploaded.
struct CtrlWindow { struct CtrlWindow {
@ -165,7 +165,7 @@ impl ChunkPoolWriteCtrl {
if file_ctrl.total_segments != total_segments { if file_ctrl.total_segments != total_segments {
bail!( bail!(
"file size in segment doesn't match with file size declared in previous segment. Previous total segments:{}, current total segments:{}s", "file size in segment doesn't match with file size declared in previous segment. Previous total segments:{}, current total segments:{}",
file_ctrl.total_segments, file_ctrl.total_segments,
total_segments total_segments
); );