diff src/main/java/alice/datasegment/CompressedLocalDataSegmentManager.java @ 523:145c425db88d dispose

add CompressedLDSM
author Nozomi Teruya <e125769@ie.u-ryukyu.ac.jp>
date Thu, 09 Apr 2015 18:36:26 +0900
parents
children
line wrap: on
line diff
--- /dev/null	Thu Jan 01 00:00:00 1970 +0000
+++ b/src/main/java/alice/datasegment/CompressedLocalDataSegmentManager.java	Thu Apr 09 18:36:26 2015 +0900
@@ -0,0 +1,27 @@
+package alice.datasegment;
+
+import alice.codesegment.CodeSegment;
+import org.apache.log4j.Logger;
+
+import java.util.concurrent.ConcurrentHashMap;
+
+/**
+ * Created by e125769 on 4/8/15.
+ */
+public class CompressedLocalDataSegmentManager extends LocalDataSegmentManager{
+    private String reverseKey = "compressedLocal";
+    //private ConcurrentHashMap<String, DataSegmentKey> dataSegments = new ConcurrentHashMap<String, DataSegmentKey>();
+    private Logger logger = Logger.getLogger("compressedLocal");
+
+
+    @Override
+    public void peek(Receiver receiver, CodeSegment cs, boolean quickFlag) {//とりあえずコピペ
+        DataSegmentKey dataSegmentKey = getDataSegmentKey(receiver.key);
+        int seq = this.seq.getAndIncrement();
+        Command cmd = new Command(CommandType.PEEK, receiver, receiver.key, null, receiver.index, seq, replyQueue, cs, null);
+        dataSegmentKey.runCommand(cmd);
+        if (logger.isDebugEnabled())
+            logger.debug(cmd.getCommandString());
+    }
+
+}