Mercurial > hg > Database > Alice

comparison src/alice/datasegment/DataSegmentManager.java @ 7:352eb19d837d

Find changesets by keywords (author, files, the commit message), revision number or hash, or revset expression.
implements reply of LocalDataSegment
author one
date Thu, 12 Jan 2012 13:48:34 +0900
parents c78a1cc2cd8f
children c4d6ff56b9bf
comparison
equal deleted inserted replaced
6:c78a1cc2cd8f 7:352eb19d837d
4 import java.util.concurrent.LinkedBlockingQueue; 4 import java.util.concurrent.LinkedBlockingQueue;
5 5
6 import org.msgpack.type.Value; 6 import org.msgpack.type.Value;
7 7
8 import alice.codesegment.CodeSegment; 8 import alice.codesegment.CodeSegment;
9 import alice.codesegment.Reply;
10 9
11 public abstract class DataSegmentManager { 10 public abstract class DataSegmentManager {
12 public ConcurrentHashMap<String, DataSegmentKey> dataSegments = new ConcurrentHashMap<String, DataSegmentKey>(); 11 public ConcurrentHashMap<String, DataSegmentKey> dataSegments = new ConcurrentHashMap<String, DataSegmentKey>();
13 public ConcurrentHashMap<Integer, Command> seqHash = new ConcurrentHashMap<Integer, Command>(); 12 public ConcurrentHashMap<Integer, Command> seqHash = new ConcurrentHashMap<Integer, Command>();
14 public LinkedBlockingQueue<Reply> replyQueue = new LinkedBlockingQueue<Reply>(); 13 public LinkedBlockingQueue<Reply> replyQueue = new LinkedBlockingQueue<Reply>();
15 14
16 public abstract void put(String key, Value val); 15 public abstract void put(String key, Value val);
17 public abstract void update(String key, Value val); 16 public abstract void update(String key, Value val);
18 public void take(String key, CodeSegment cs) { 17 public void take(String argKey, String key, CodeSegment cs) {
19 take(key, 0, cs); 18 take(argKey, key, 0, cs);
20 } 19 }
21 public abstract void take(String key, int index, CodeSegment cs); 20 public abstract void take(String argKey, String key, int index, CodeSegment cs);
22 public void peek(String key, CodeSegment cs) { 21 public void peek(String argKey, String key, CodeSegment cs) {
23 peek(key, 0, cs); 22 peek(argKey, key, 0, cs);
24 } 23 }
25 public abstract void peek(String key, int index, CodeSegment cs); 24 public abstract void peek(String argKey, String key, int index, CodeSegment cs);
26 public abstract void remove(String key); 25 public abstract void remove(String key);
27 26
28 } 27 }