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 ff39dacb3fc868ab6efb03ebcedd823e33da7c22..75dfb0550c85c76cc53cdb9ec2c28e273dd68b2a 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() {