Merge 0d17842 into 275b86e

uzhastik · web-flow · commit 357057430449 · 2025-01-09T18:54:31.000+03:00
diff --git a/ydb/library/yql/udfs/common/clickhouse/client/src/IO/WriteBufferFromFileDescriptor.cpp b/ydb/library/yql/udfs/common/clickhouse/client/src/IO/WriteBufferFromFileDescriptor.cpp
@@ -48,7 +48,7 @@ void WriteBufferFromFileDescriptor::nextImpl()
     Stopwatch watch;
 
     size_t bytes_written = 0;
-    while (bytes_written != offset())
+    while (bytes_written < offset())
     {
         ProfileEvents::increment(ProfileEvents::WriteBufferFromFileDescriptorWrite);
 
diff --git a/ydb/library/yql/udfs/common/clickhouse/client/src/IO/WriteBufferFromFileDescriptorDiscardOnFailure.cpp b/ydb/library/yql/udfs/common/clickhouse/client/src/IO/WriteBufferFromFileDescriptorDiscardOnFailure.cpp
@@ -11,7 +11,7 @@ namespace NDB
 void WriteBufferFromFileDescriptorDiscardOnFailure::nextImpl()
 {
     size_t bytes_written = 0;
-    while (bytes_written != offset())
+    while (bytes_written < offset())
     {
         ssize_t res = ::write(fd, working_buffer.begin() + bytes_written, offset() - bytes_written);
 

Original file line number	Diff line number	Diff line change
`@@ -48,7 +48,7 @@ void WriteBufferFromFileDescriptor::nextImpl()`
`48`	`48`	`Stopwatch watch;`
`49`	`49`
`50`	`50`	`size_t bytes_written = 0;`
`51`		`- while (bytes_written != offset())`
	`51`	`+ while (bytes_written < offset())`
`52`	`52`	`{`
`53`	`53`	`ProfileEvents::increment(ProfileEvents::WriteBufferFromFileDescriptorWrite);`
`54`	`54`
Original file line number	Diff line number	Diff line change
`@@ -11,7 +11,7 @@ namespace NDB`
`11`	`11`	`void WriteBufferFromFileDescriptorDiscardOnFailure::nextImpl()`
`12`	`12`	`{`
`13`	`13`	`size_t bytes_written = 0;`
`14`		`- while (bytes_written != offset())`
	`14`	`+ while (bytes_written < offset())`
`15`	`15`	`{`
`16`	`16`	`ssize_t res = ::write(fd, working_buffer.begin() + bytes_written, offset() - bytes_written);`
`17`	`17`