Memory mapped read/address-space implementation

CorfuDB · Dec 19, 2017 · 6de72c0 · 6de72c0
1 parent f1b680a
commit 6de72c0
Show file tree

Hide file tree

Showing 6 changed files with 470 additions and 187 deletions.
diff --git a/format/proto/types.proto b/format/proto/types.proto
@@ -53,6 +53,23 @@ message LogEntry {
     optional int64 checkpointedStreamStartLogAddress = 15;
 }
 
+message LogEntryMetadataOnly {
+    optional DataType data_type = 1;
+    // don't deserialize bytes
+    optional int64 global_address = 3;
+    repeated string	streams = 6;
+    map<string, int64> logical_addresses = 7;
+    map<string, int64> backpointers = 8;
+    optional DataRank rank = 9;
+    optional CheckpointEntryType checkpointEntryType = 10;
+    optional int64 checkpointId_most_significant = 11;
+    optional int64 checkpointId_least_significant = 12;
+    optional int64 checkpointedStreamId_most_significant = 13;
+    optional int64 checkpointedStreamId_least_significant = 14;
+    //  Tail of the stream at the time of taking the checkpoint snapshot.
+    optional int64 checkpointedStreamStartLogAddress = 15;
+}
+
 message LogHeader {
     optional int32 version = 1;
     optional bool verify_checksum = 2;

diff --git a/infrastructure/src/main/java/org/corfudb/infrastructure/LogUnitServer.java b/infrastructure/src/main/java/org/corfudb/infrastructure/LogUnitServer.java
@@ -323,8 +323,8 @@ private void resetLogUnit(CorfuMsg msg, ChannelHandlerContext ctx, IServerRouter
      *     the read() and append(). Any address that cannot be retrieved should be returned as
      *     unwritten (null).
      */
-    public synchronized ILogData handleRetrieval(long address) {
-        LogData entry = streamLog.read(address);
+    public ILogData handleRetrieval(long address) {
+        ILogData entry = streamLog.read(address);
         log.trace("Retrieved[{} : {}]", address, entry);
         return entry;
     }