We read every piece of feedback, and take your input very seriously.
To see all available qualifiers, see our documentation.
1 parent 586cd52 commit 2d599e9Copy full SHA for 2d599e9
1 file changed
disktest-lib/src/stream.rs
@@ -79,16 +79,17 @@ fn thread_worker(
79
return;
80
}
81
82
+ let chunk_size = generator.get_base_size() * chunk_factor;
83
+
84
// Run the generator work loop.
85
let mut index = 0;
86
let mut cur_level = level.load(Ordering::Relaxed);
87
while !abort.load(Ordering::SeqCst) {
88
if cur_level < DtStream::MAX_THRES {
89
// Get the next chunk from the generator.
- let size = generator.get_base_size() * chunk_factor;
- let mut data = cache_cons.pull(size);
90
+ let mut data = cache_cons.pull(chunk_size);
91
generator.next(&mut data, chunk_factor);
- debug_assert_eq!(data.len(), size);
92
+ debug_assert_eq!(data.len(), chunk_size);
93
94
// Invert the bit pattern, if requested.
95
if invert_pattern {
0 commit comments