Mercurial > hg > Database > Alice
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); }