annotate src/alice/datasegment/DataSegmentManager.java @ 71:a3a2605e16a2

change checking debug mode of logger
author kazz <kazz@cr.ie.u-ryukyu.ac.jp>
date Tue, 21 Feb 2012 21:10:15 +0900 (2012-02-21)
parents 1d4f2b72fb31
children 1044a79ce4ef
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
39
3155337e754e add logger
kazz <kazz@cr.ie.u-ryukyu.ac.jp>
parents: 33
diff changeset
7 import org.apache.log4j.Logger;
3
91057e15065f add DataSegment API and CodeSegment
one
parents: 2
diff changeset
8 import org.msgpack.type.Value;
2
f71eabb1df2a create outline of DataSegment model
one
parents:
diff changeset
9
3
91057e15065f add DataSegment API and CodeSegment
one
parents: 2
diff changeset
10 import alice.codesegment.CodeSegment;
2
f71eabb1df2a create outline of DataSegment model
one
parents:
diff changeset
11
f71eabb1df2a create outline of DataSegment model
one
parents:
diff changeset
12 public abstract class DataSegmentManager {
14
e3f1b21718b0 implements RemoteDataSegment
kazz <kazz@cr.ie.u-ryukyu.ac.jp>
parents: 13
diff changeset
13
13
30f97d776a3e implements Alice daemon
one
parents: 12
diff changeset
14 protected ConcurrentHashMap<Integer, Command> seqHash = new ConcurrentHashMap<Integer, Command>();
69
1d4f2b72fb31 delete KeyThread
kazz <kazz@cr.ie.u-ryukyu.ac.jp>
parents: 68
diff changeset
15 protected LinkedBlockingQueue<Command> replyQueue = new LinkedBlockingQueue<Command>();
14
e3f1b21718b0 implements RemoteDataSegment
kazz <kazz@cr.ie.u-ryukyu.ac.jp>
parents: 13
diff changeset
16 protected AtomicInteger seq = new AtomicInteger(1);
68
d4c7f7b1096b remove copy at OutboundTcpConnection
kazz <kazz@cr.ie.u-ryukyu.ac.jp>
parents: 67
diff changeset
17
14
e3f1b21718b0 implements RemoteDataSegment
kazz <kazz@cr.ie.u-ryukyu.ac.jp>
parents: 13
diff changeset
18 protected Runnable replyThread = new Runnable() {
39
3155337e754e add logger
kazz <kazz@cr.ie.u-ryukyu.ac.jp>
parents: 33
diff changeset
19 Logger logger = Logger.getLogger("reply");
14
e3f1b21718b0 implements RemoteDataSegment
kazz <kazz@cr.ie.u-ryukyu.ac.jp>
parents: 13
diff changeset
20 @Override
e3f1b21718b0 implements RemoteDataSegment
kazz <kazz@cr.ie.u-ryukyu.ac.jp>
parents: 13
diff changeset
21 public void run() {
e3f1b21718b0 implements RemoteDataSegment
kazz <kazz@cr.ie.u-ryukyu.ac.jp>
parents: 13
diff changeset
22 while (true) {
e3f1b21718b0 implements RemoteDataSegment
kazz <kazz@cr.ie.u-ryukyu.ac.jp>
parents: 13
diff changeset
23 try {
e3f1b21718b0 implements RemoteDataSegment
kazz <kazz@cr.ie.u-ryukyu.ac.jp>
parents: 13
diff changeset
24 Command reply = replyQueue.take();
e3f1b21718b0 implements RemoteDataSegment
kazz <kazz@cr.ie.u-ryukyu.ac.jp>
parents: 13
diff changeset
25 Command cmd = seqHash.get(reply.seq);
44
73158dc54c59 fix peek api
kazz <kazz@cr.ie.u-ryukyu.ac.jp>
parents: 41
diff changeset
26 if (cmd == null) {
73158dc54c59 fix peek api
kazz <kazz@cr.ie.u-ryukyu.ac.jp>
parents: 41
diff changeset
27 logger.warn("conflict sequence number");
73158dc54c59 fix peek api
kazz <kazz@cr.ie.u-ryukyu.ac.jp>
parents: 41
diff changeset
28 continue;
73158dc54c59 fix peek api
kazz <kazz@cr.ie.u-ryukyu.ac.jp>
parents: 41
diff changeset
29 }
73158dc54c59 fix peek api
kazz <kazz@cr.ie.u-ryukyu.ac.jp>
parents: 41
diff changeset
30 seqHash.remove(reply.seq);
28
98ab26e09a98 Configuration Manager work and implements reverseKey
kazz <kazz@cr.ie.u-ryukyu.ac.jp>
parents: 18
diff changeset
31 cmd.cs.ids.reply(cmd.receiver, new DataSegmentValue(reply.index, reply.val, reply.reverseKey));
71
a3a2605e16a2 change checking debug mode of logger
kazz <kazz@cr.ie.u-ryukyu.ac.jp>
parents: 69
diff changeset
32 if (logger.isDebugEnabled())
68
d4c7f7b1096b remove copy at OutboundTcpConnection
kazz <kazz@cr.ie.u-ryukyu.ac.jp>
parents: 67
diff changeset
33 logger.debug(reply.getCommandString() + " " + cmd.getCommandString());
14
e3f1b21718b0 implements RemoteDataSegment
kazz <kazz@cr.ie.u-ryukyu.ac.jp>
parents: 13
diff changeset
34 } catch (InterruptedException e) {
e3f1b21718b0 implements RemoteDataSegment
kazz <kazz@cr.ie.u-ryukyu.ac.jp>
parents: 13
diff changeset
35 e.printStackTrace();
e3f1b21718b0 implements RemoteDataSegment
kazz <kazz@cr.ie.u-ryukyu.ac.jp>
parents: 13
diff changeset
36 }
e3f1b21718b0 implements RemoteDataSegment
kazz <kazz@cr.ie.u-ryukyu.ac.jp>
parents: 13
diff changeset
37 }
e3f1b21718b0 implements RemoteDataSegment
kazz <kazz@cr.ie.u-ryukyu.ac.jp>
parents: 13
diff changeset
38 }
e3f1b21718b0 implements RemoteDataSegment
kazz <kazz@cr.ie.u-ryukyu.ac.jp>
parents: 13
diff changeset
39
e3f1b21718b0 implements RemoteDataSegment
kazz <kazz@cr.ie.u-ryukyu.ac.jp>
parents: 13
diff changeset
40 };
2
f71eabb1df2a create outline of DataSegment model
one
parents:
diff changeset
41
69
1d4f2b72fb31 delete KeyThread
kazz <kazz@cr.ie.u-ryukyu.ac.jp>
parents: 68
diff changeset
42 public void addReplyCommand(Command cmd) {
1d4f2b72fb31 delete KeyThread
kazz <kazz@cr.ie.u-ryukyu.ac.jp>
parents: 68
diff changeset
43 try {
1d4f2b72fb31 delete KeyThread
kazz <kazz@cr.ie.u-ryukyu.ac.jp>
parents: 68
diff changeset
44 replyQueue.put(cmd);
1d4f2b72fb31 delete KeyThread
kazz <kazz@cr.ie.u-ryukyu.ac.jp>
parents: 68
diff changeset
45 } catch (InterruptedException e) {
1d4f2b72fb31 delete KeyThread
kazz <kazz@cr.ie.u-ryukyu.ac.jp>
parents: 68
diff changeset
46 e.printStackTrace();
1d4f2b72fb31 delete KeyThread
kazz <kazz@cr.ie.u-ryukyu.ac.jp>
parents: 68
diff changeset
47 }
1d4f2b72fb31 delete KeyThread
kazz <kazz@cr.ie.u-ryukyu.ac.jp>
parents: 68
diff changeset
48 }
1d4f2b72fb31 delete KeyThread
kazz <kazz@cr.ie.u-ryukyu.ac.jp>
parents: 68
diff changeset
49
40
20616fe4d28a add log viewer
kazz <kazz@cr.ie.u-ryukyu.ac.jp>
parents: 39
diff changeset
50 public abstract void put(String key, Value val, CodeSegment cs);
20616fe4d28a add log viewer
kazz <kazz@cr.ie.u-ryukyu.ac.jp>
parents: 39
diff changeset
51 public abstract void update(String key, Value val, CodeSegment cs);
33
20c67f673224 change name of DataSegmentReceiver
kazz <kazz@cr.ie.u-ryukyu.ac.jp>
parents: 30
diff changeset
52 public void take(Receiver receiver, String key, CodeSegment cs) {
18
72dd27d952b0 change InputDataSegment API
kazz <kazz@cr.ie.u-ryukyu.ac.jp>
parents: 14
diff changeset
53 take(receiver, key, 0, cs);
2
f71eabb1df2a create outline of DataSegment model
one
parents:
diff changeset
54 }
33
20c67f673224 change name of DataSegmentReceiver
kazz <kazz@cr.ie.u-ryukyu.ac.jp>
parents: 30
diff changeset
55 public abstract void take(Receiver receiver, String key, int index, CodeSegment cs);
20c67f673224 change name of DataSegmentReceiver
kazz <kazz@cr.ie.u-ryukyu.ac.jp>
parents: 30
diff changeset
56 public void peek(Receiver receiver, String key, CodeSegment cs) {
18
72dd27d952b0 change InputDataSegment API
kazz <kazz@cr.ie.u-ryukyu.ac.jp>
parents: 14
diff changeset
57 peek(receiver, key, 0, cs);
2
f71eabb1df2a create outline of DataSegment model
one
parents:
diff changeset
58 }
33
20c67f673224 change name of DataSegmentReceiver
kazz <kazz@cr.ie.u-ryukyu.ac.jp>
parents: 30
diff changeset
59 public abstract void peek(Receiver receiver, String key, int index, CodeSegment cs);
3
91057e15065f add DataSegment API and CodeSegment
one
parents: 2
diff changeset
60 public abstract void remove(String key);
41
f9334781344a add close api
kazz <kazz@cr.ie.u-ryukyu.ac.jp>
parents: 40
diff changeset
61 public abstract void close();
30
b5a21baf0b07 implements RingTopology
kazz <kazz@cr.ie.u-ryukyu.ac.jp>
parents: 28
diff changeset
62 public abstract void finish();
2
f71eabb1df2a create outline of DataSegment model
one
parents:
diff changeset
63
f71eabb1df2a create outline of DataSegment model
one
parents:
diff changeset
64 }