From bf726842a0311c80c1e92ce9cd66bb939e056be4 Mon Sep 17 00:00:00 2001
From: OZGCloud <ozgcloud@mgm-tp.com>
Date: Fri, 10 Nov 2023 08:33:47 +0100
Subject: [PATCH] fix loop check
---
.../kop/common/binaryfile/GrpcFileUploadUtils.java | 12 +++++++-----
1 file changed, 7 insertions(+), 5 deletions(-)
diff --git a/kop-common-lib/src/main/java/de/itvsh/kop/common/binaryfile/GrpcFileUploadUtils.java b/kop-common-lib/src/main/java/de/itvsh/kop/common/binaryfile/GrpcFileUploadUtils.java
index d262e24..1666f3f 100644
--- a/kop-common-lib/src/main/java/de/itvsh/kop/common/binaryfile/GrpcFileUploadUtils.java
+++ b/kop-common-lib/src/main/java/de/itvsh/kop/common/binaryfile/GrpcFileUploadUtils.java
@@ -87,14 +87,16 @@ public class GrpcFileUploadUtils {
}
void sendNext() {
- while (!done.get() && isReady()) {
+ if (!done.get()) {
waitForOberver();
- LOG.debug("Sending next chunk.");
sendMetaData();
- long sentSize = sendNextChunk();
- checkForEndOfStream(sentSize);
+ do {
+ LOG.debug("Sending next chunk.");
+ long sentSize = sendNextChunk();
+ checkForEndOfStream(sentSize);
+ } while (!done.get() && isReady());
+ LOG.debug("Finished or waiting to become ready.");
}
- LOG.debug("Finished or waiting to become ready.");
}
private boolean isReady() {
--
GitLab