diff src/main/java/alice/datasegment/CompressedLocalDataSegmentManager.java @ 574:ea21af9a4762 dispose

delete serializeFlag, fix MessagePack pack&unpack
author Nozomi Teruya <e125769@ie.u-ryukyu.ac.jp>
date Tue, 15 Dec 2015 11:49:07 +0900
parents 8c17a9e66cc7
children
line wrap: on
line diff
--- a/src/main/java/alice/datasegment/CompressedLocalDataSegmentManager.java	Thu Nov 26 23:36:53 2015 +0900
+++ b/src/main/java/alice/datasegment/CompressedLocalDataSegmentManager.java	Tue Dec 15 11:49:07 2015 +0900
@@ -17,30 +17,12 @@
 
     public CompressedLocalDataSegmentManager(LocalDataSegmentManager manager) {
         this.manager = manager;
-        new Thread(replyThread, "CompressedLocalDataSegmentManager-replyCommand").start();
     }
 
     public void setReverseKey(String s){
         reverseKey = s;
     }
 
-    private class RunCommand implements Runnable {
-
-        DataSegmentKey key;
-        Command cmd;
-
-        public RunCommand(DataSegmentKey key, Command cmd) {
-            this.key = key;
-            this.cmd = cmd;
-        }
-
-        @Override
-        public void run() {
-            key.runCommand(cmd);
-        }
-
-    }
-
     public void submitCommand(DataSegmentKey key, Command cmd) {
         manager.submitCommand(key, cmd);
     }