thebestvibedev/tromcho.net
1
0
Fork 0
Code Issues Pull Requests Actions Packages Projects Releases Wiki Activity

Fix missing wait for short writes in vitastor-cli dd

Browse Source
This commit is contained in:
Vitaliy Filippov
2026-02-03 01:28:13 +03:00
parent 9cc2beed95
commit ac2ce48cb2
1 changed files with 3 additions and 3 deletions
Download Patch File Download Diff File Expand all files Collapse all files
src/cmd/cli_dd.cpp
+3 -3
View File
@@ -890,12 +890,12 @@ resume_2:
clock_gettime(CLOCK_REALTIME, &tv_begin); clock_gettime(CLOCK_REALTIME, &tv_begin);
tv_progress = tv_begin; tv_progress = tv_begin;
resume_3: resume_3:
while ((ignore_errors || !copy_error) && (!in_eof || read_buffers.size() || in_waiting > 0 || out_waiting > 0)) while ((ignore_errors || !copy_error) && (!in_eof || read_buffers.size() || in_waiting > 0 || out_waiting > 0 || short_writes.size()))
{ {
print_progress(false); print_progress(false);
while ((ignore_errors || !copy_error) && while ((ignore_errors || !copy_error) &&
(!in_eof && in_waiting < in_iodepth && read_buffers.size() < out_iodepth || (!in_eof && in_waiting < in_iodepth && read_buffers.size() < out_iodepth ||
read_buffers.size() && out_waiting < out_iodepth)) (read_buffers.size() || short_writes.size()) && out_waiting < out_iodepth))
{ {
if (!in_eof && in_waiting < in_iodepth && read_buffers.size() < out_iodepth) if (!in_eof && in_waiting < in_iodepth && read_buffers.size() < out_iodepth)
{ {
@@ -904,7 +904,7 @@ resume_3:
break; break;
} }
} }
if (read_buffers.size() && out_waiting < out_iodepth) if ((read_buffers.size() || short_writes.size()) && out_waiting < out_iodepth)
{ {
if (!add_write_op()) if (!add_write_op())
{ {