Mercurial > hg > Database > Alice

annotate src/alice/datasegment/DataSegmentManager.java @ 30:b5a21baf0b07

Find changesets by keywords (author, files, the commit message), revision number or hash, or revset expression.
implements RingTopology
author kazz <kazz@cr.ie.u-ryukyu.ac.jp>
date Tue, 17 Jan 2012 16:13:03 +0900
parents 98ab26e09a98
children 20c67f673224
Ignore whitespace changes - Everywhere: Within whitespace: At end of lines:
rev   line source
2
f71eabb1df2a create outline of DataSegment model
one
parents:
diff changeset
1 package alice.datasegment;
f71eabb1df2a create outline of DataSegment model
one
parents:
diff changeset
2
f71eabb1df2a create outline of DataSegment model
one
parents:
diff changeset
3 import java.util.concurrent.ConcurrentHashMap;
6
c78a1cc2cd8f implements Reply
one
parents: 5
diff changeset
4 import java.util.concurrent.LinkedBlockingQueue;
14
e3f1b21718b0 implements RemoteDataSegment
kazz <kazz@cr.ie.u-ryukyu.ac.jp>
parents: 13
diff changeset
5 import java.util.concurrent.atomic.AtomicInteger;
6
c78a1cc2cd8f implements Reply
one
parents: 5
diff changeset
6
3
91057e15065f add DataSegment API and CodeSegment
one
parents: 2
diff changeset
7 import org.msgpack.type.Value;
2
f71eabb1df2a create outline of DataSegment model
one
parents:
diff changeset
8
3
91057e15065f add DataSegment API and CodeSegment
one
parents: 2
diff changeset
9 import alice.codesegment.CodeSegment;
2
f71eabb1df2a create outline of DataSegment model
one
parents:
diff changeset
10
f71eabb1df2a create outline of DataSegment model
one
parents:
diff changeset
11 public abstract class DataSegmentManager {
14
e3f1b21718b0 implements RemoteDataSegment
kazz <kazz@cr.ie.u-ryukyu.ac.jp>
parents: 13
diff changeset
12
13
30f97d776a3e implements Alice daemon
one
parents: 12
diff changeset
13 protected ConcurrentHashMap<String, DataSegmentKey> dataSegments = new ConcurrentHashMap<String, DataSegmentKey>();
30f97d776a3e implements Alice daemon
one
parents: 12
diff changeset
14 protected ConcurrentHashMap<Integer, Command> seqHash = new ConcurrentHashMap<Integer, Command>();
14
e3f1b21718b0 implements RemoteDataSegment
kazz <kazz@cr.ie.u-ryukyu.ac.jp>
parents: 13
diff changeset
15 public LinkedBlockingQueue<Command> replyQueue = new LinkedBlockingQueue<Command>();
e3f1b21718b0 implements RemoteDataSegment
kazz <kazz@cr.ie.u-ryukyu.ac.jp>
parents: 13
diff changeset
16 protected AtomicInteger seq = new AtomicInteger(1);
e3f1b21718b0 implements RemoteDataSegment
kazz <kazz@cr.ie.u-ryukyu.ac.jp>
parents: 13
diff changeset
17 protected Runnable replyThread = new Runnable() {
e3f1b21718b0 implements RemoteDataSegment
kazz <kazz@cr.ie.u-ryukyu.ac.jp>
parents: 13
diff changeset
18
e3f1b21718b0 implements RemoteDataSegment
kazz <kazz@cr.ie.u-ryukyu.ac.jp>
parents: 13
diff changeset
19 @Override
e3f1b21718b0 implements RemoteDataSegment
kazz <kazz@cr.ie.u-ryukyu.ac.jp>
parents: 13
diff changeset
20 public void run() {
e3f1b21718b0 implements RemoteDataSegment
kazz <kazz@cr.ie.u-ryukyu.ac.jp>
parents: 13
diff changeset
21 while (true) {
e3f1b21718b0 implements RemoteDataSegment
kazz <kazz@cr.ie.u-ryukyu.ac.jp>
parents: 13
diff changeset
22 try {
e3f1b21718b0 implements RemoteDataSegment
kazz <kazz@cr.ie.u-ryukyu.ac.jp>
parents: 13
diff changeset
23 Command reply = replyQueue.take();
e3f1b21718b0 implements RemoteDataSegment
kazz <kazz@cr.ie.u-ryukyu.ac.jp>
parents: 13
diff changeset
24 Command cmd = seqHash.get(reply.seq);
28
98ab26e09a98 Configuration Manager work and implements reverseKey
kazz <kazz@cr.ie.u-ryukyu.ac.jp>
parents: 18
diff changeset
25 cmd.cs.ids.reply(cmd.receiver, new DataSegmentValue(reply.index, reply.val, reply.reverseKey));
14
e3f1b21718b0 implements RemoteDataSegment
kazz <kazz@cr.ie.u-ryukyu.ac.jp>
parents: 13
diff changeset
26 } catch (InterruptedException e) {
e3f1b21718b0 implements RemoteDataSegment
kazz <kazz@cr.ie.u-ryukyu.ac.jp>
parents: 13
diff changeset
27 e.printStackTrace();
e3f1b21718b0 implements RemoteDataSegment
kazz <kazz@cr.ie.u-ryukyu.ac.jp>
parents: 13
diff changeset
28 }
e3f1b21718b0 implements RemoteDataSegment
kazz <kazz@cr.ie.u-ryukyu.ac.jp>
parents: 13
diff changeset
29 }
e3f1b21718b0 implements RemoteDataSegment
kazz <kazz@cr.ie.u-ryukyu.ac.jp>
parents: 13
diff changeset
30 }
e3f1b21718b0 implements RemoteDataSegment
kazz <kazz@cr.ie.u-ryukyu.ac.jp>
parents: 13
diff changeset
31
e3f1b21718b0 implements RemoteDataSegment
kazz <kazz@cr.ie.u-ryukyu.ac.jp>
parents: 13
diff changeset
32 };
2
f71eabb1df2a create outline of DataSegment model
one
parents:
diff changeset
33
f71eabb1df2a create outline of DataSegment model
one
parents:
diff changeset
34 public abstract void put(String key, Value val);
5
80375ae09a1f add update api
one
parents: 3
diff changeset
35 public abstract void update(String key, Value val);
18
72dd27d952b0 change InputDataSegment API
kazz <kazz@cr.ie.u-ryukyu.ac.jp>
parents: 14
diff changeset
36 public void take(DataSegmentReceiver receiver, String key, CodeSegment cs) {
72dd27d952b0 change InputDataSegment API
kazz <kazz@cr.ie.u-ryukyu.ac.jp>
parents: 14
diff changeset
37 take(receiver, key, 0, cs);
2
f71eabb1df2a create outline of DataSegment model
one
parents:
diff changeset
38 }
18
72dd27d952b0 change InputDataSegment API
kazz <kazz@cr.ie.u-ryukyu.ac.jp>
parents: 14
diff changeset
39 public abstract void take(DataSegmentReceiver receiver, String key, int index, CodeSegment cs);
72dd27d952b0 change InputDataSegment API
kazz <kazz@cr.ie.u-ryukyu.ac.jp>
parents: 14
diff changeset
40 public void peek(DataSegmentReceiver receiver, String key, CodeSegment cs) {
72dd27d952b0 change InputDataSegment API
kazz <kazz@cr.ie.u-ryukyu.ac.jp>
parents: 14
diff changeset
41 peek(receiver, key, 0, cs);
2
f71eabb1df2a create outline of DataSegment model
one
parents:
diff changeset
42 }
18
72dd27d952b0 change InputDataSegment API
kazz <kazz@cr.ie.u-ryukyu.ac.jp>
parents: 14
diff changeset
43 public abstract void peek(DataSegmentReceiver receiver, String key, int index, CodeSegment cs);
3
91057e15065f add DataSegment API and CodeSegment
one
parents: 2
diff changeset
44 public abstract void remove(String key);
30
b5a21baf0b07 implements RingTopology
kazz <kazz@cr.ie.u-ryukyu.ac.jp>
parents: 28
diff changeset
45 public abstract void finish();
2
f71eabb1df2a create outline of DataSegment model
one
parents:
diff changeset
46
f71eabb1df2a create outline of DataSegment model
one
parents:
diff changeset
47 }