Skip to content
Snippets Groups Projects
Verified Commit 4acabf4b authored by Timm Fitschen's avatar Timm Fitschen
Browse files

WIP: files

parent 542f37e6
No related branches found
No related tags found
3 merge requests!44Release 0.6,!43Merge f-GRPC-main to dev,!26F grpc f files
Pipeline #11919 passed
caosdb-proto @ af178772
Subproject commit c3783d64c31f8ee3495c28746dfb0bf23abfc20a
Subproject commit af178772ef43ded290168f33852ef3d85583b20a
package org.caosdb.server.grpc;
import com.google.protobuf.ByteString;
import java.io.FileInputStream;
import java.io.FileNotFoundException;
import java.io.IOException;
......@@ -10,7 +11,6 @@ import org.caosdb.api.entity.v1alpha1.FileChunk;
import org.caosdb.api.entity.v1alpha1.FileDownloadResponse;
import org.caosdb.api.entity.v1alpha1.TransmissionStatus;
import org.caosdb.server.entity.FileProperties;
import com.google.protobuf.ByteString;
public class DownloadBuffer {
......@@ -36,8 +36,7 @@ public class DownloadBuffer {
final long unread_bytes = fileChannel.size() - position;
final long next_chunk_size = Math.min(unread_bytes, getChunkSize());
final MappedByteBuffer map =
fileChannel.map(MapMode.READ_ONLY, position, next_chunk_size);
final MappedByteBuffer map = fileChannel.map(MapMode.READ_ONLY, position, next_chunk_size);
final FileChunk.Builder builder = FileChunk.newBuilder();
builder.setData(ByteString.copyFrom(map));
......
package org.caosdb.server.grpc;
import io.grpc.stub.StreamObserver;
import java.util.Collection;
import java.util.HashMap;
import java.util.Iterator;
......@@ -50,7 +51,6 @@ import org.caosdb.server.transaction.Retrieve;
import org.caosdb.server.transaction.WriteTransaction;
import org.caosdb.server.utils.EntityStatus;
import org.caosdb.server.utils.ServerMessages;
import io.grpc.stub.StreamObserver;
public class EntityTransactionServiceImpl extends EntityTransactionServiceImplBase {
......
0% Loading or .
You are about to add 0 people to the discussion. Proceed with caution.
Please register or to comment