Skip to content
Snippets Groups Projects
Commit 108a25aa authored by Evgeny Bardin's avatar Evgeny Bardin
Browse files

OZG-7426 do send method synchronized

parent ea0ba9b3
No related branches found
No related tags found
No related merge requests found
......@@ -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() {
......
0% Loading or .
You are about to add 0 people to the discussion. Proceed with caution.
Please register or to comment