Mercurial > hg > Database > Alice
diff src/main/java/alice/datasegment/DataSegmentManager.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 | 79d5b317b2b6 |
children | 928907206d21 |
line wrap: on
line diff
--- a/src/main/java/alice/datasegment/DataSegmentManager.java Fri Jan 23 23:53:36 2015 +0900 +++ b/src/main/java/alice/datasegment/DataSegmentManager.java Thu Apr 09 18:36:26 2015 +0900 @@ -18,7 +18,7 @@ protected Runnable replyThread = new Runnable() { Logger logger = Logger.getLogger("reply"); @Override - public void run() { + public void run() {//SEDAのREPLYスレッドのなごり。消してもいい。 while (true) { try { Command reply = replyQueue.take(); @@ -50,10 +50,11 @@ } } - public abstract void put(String key, ReceiveData rData, SendOption option); - public abstract void update(String key, ReceiveData rData, SendOption option); - public abstract void peek(Receiver receiver, CodeSegment cs, SendOption option); - public abstract void take(Receiver receiver, CodeSegment cs, SendOption option); + //各コマンドの抽象クラス + public abstract void put(String key, ReceiveData rData, boolean quickFlag); + public abstract void update(String key, ReceiveData rData, boolean quickFlag); + public abstract void peek(Receiver receiver, CodeSegment cs, boolean quickFlag); + public abstract void take(Receiver receiver, CodeSegment cs, boolean quickFlag); public abstract void remove(String key); public abstract void shutdown();