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

OZG-7426 add more logs

parent 59d1896f
No related branches found
No related tags found
No related merge requests found
......@@ -85,8 +85,10 @@ class UploadServerStreamObserver<M, T> implements StreamObserver<T> {
@Override
public synchronized void onNext(T fileUploadRequest) {
if (hasMetadata.test(fileUploadRequest)) {
LOG.debug("Received metadata.");
setMetadata(fileUploadRequest);
} else {
LOG.debug("Received file content chunk.");
if (Objects.isNull(contentIdFuture)) {
contentIdFuture = initContentUpload();
}
......@@ -139,6 +141,7 @@ class UploadServerStreamObserver<M, T> implements StreamObserver<T> {
LOG.debug("Complete upload request.");
closeOutputPipe();
var newContentId = getContentId();
LOG.debug("newContentId: {}", newContentId);
try {
var fileId = metadataUploader.apply(fileMetadata.get(), newContentId);
responseConsumer.accept(fileId);
......
0% Loading or .
You are about to add 0 people to the discussion. Proceed with caution.
Please register or to comment