From 108a25aaf508baffb7e2865675a3f1d4b5c7cf02 Mon Sep 17 00:00:00 2001
From: Evgeny Bardin <evgeny.bardin@external.mgm-cp.com>
Date: Thu, 23 Jan 2025 12:51:23 +0100
Subject: [PATCH] OZG-7426 do send method synchronized
---
.../de/ozgcloud/common/binaryfile/GrpcFileUploadUtils.java | 5 +++--
1 file changed, 3 insertions(+), 2 deletions(-)
diff --git a/ozgcloud-common-lib/src/main/java/de/ozgcloud/common/binaryfile/GrpcFileUploadUtils.java b/ozgcloud-common-lib/src/main/java/de/ozgcloud/common/binaryfile/GrpcFileUploadUtils.java
index ff39dac..75dfb05 100644
--- a/ozgcloud-common-lib/src/main/java/de/ozgcloud/common/binaryfile/GrpcFileUploadUtils.java
+++ b/ozgcloud-common-lib/src/main/java/de/ozgcloud/common/binaryfile/GrpcFileUploadUtils.java
@@ -112,8 +112,9 @@ public class GrpcFileUploadUtils {
closeStreams();
}
- void sendNext() {
+ synchronized void sendNext() {
if (done.get()) {
+ LOG.debug("Sending is finished (fileSenderId = {})", fileSenderId);
return;
}
waitForObserver();
@@ -121,7 +122,7 @@ public class GrpcFileUploadUtils {
while (!done.get() && isReady()) {
sendNextChunk();
}
- LOG.debug("Finished or waiting to become ready. (fileSenderId = {})", fileSenderId);
+ LOG.debug("Finished ({}) or waiting to become ready. (fileSenderId = {})", done.get(), fileSenderId);
}
boolean isReady() {
--
GitLab