Mercurial > hg > Database > Alice

annotate src/alice/datasegment/RemoteDataSegmentManager.java @ 14:e3f1b21718b0

Find changesets by keywords (author, files, the commit message), revision number or hash, or revset expression.
implements RemoteDataSegment
author kazz <kazz@cr.ie.u-ryukyu.ac.jp>
date Sun, 15 Jan 2012 00:56:25 +0900
parents src/alice/datasegment/RemoteDataSegment.java@30f97d776a3e
children 72dd27d952b0
Ignore whitespace changes - Everywhere: Within whitespace: At end of lines:
rev   line source
12
c4d6ff56b9bf unite Command and Reply
one
parents:
diff changeset
1 package alice.datasegment;
c4d6ff56b9bf unite Command and Reply
one
parents:
diff changeset
2
c4d6ff56b9bf unite Command and Reply
one
parents:
diff changeset
3 import org.msgpack.type.Value;
c4d6ff56b9bf unite Command and Reply
one
parents:
diff changeset
4
c4d6ff56b9bf unite Command and Reply
one
parents:
diff changeset
5 import alice.codesegment.CodeSegment;
14
e3f1b21718b0 implements RemoteDataSegment
kazz <kazz@cr.ie.u-ryukyu.ac.jp>
parents: 13
diff changeset
6 import alice.daemon.Connection;
e3f1b21718b0 implements RemoteDataSegment
kazz <kazz@cr.ie.u-ryukyu.ac.jp>
parents: 13
diff changeset
7 import alice.daemon.IncomingTcpConnection;
e3f1b21718b0 implements RemoteDataSegment
kazz <kazz@cr.ie.u-ryukyu.ac.jp>
parents: 13
diff changeset
8 import alice.daemon.OutboundTcpConnection;
12
c4d6ff56b9bf unite Command and Reply
one
parents:
diff changeset
9
14
e3f1b21718b0 implements RemoteDataSegment
kazz <kazz@cr.ie.u-ryukyu.ac.jp>
parents: 13
diff changeset
10 public class RemoteDataSegmentManager extends DataSegmentManager {
e3f1b21718b0 implements RemoteDataSegment
kazz <kazz@cr.ie.u-ryukyu.ac.jp>
parents: 13
diff changeset
11
e3f1b21718b0 implements RemoteDataSegment
kazz <kazz@cr.ie.u-ryukyu.ac.jp>
parents: 13
diff changeset
12 Connection connection;
e3f1b21718b0 implements RemoteDataSegment
kazz <kazz@cr.ie.u-ryukyu.ac.jp>
parents: 13
diff changeset
13
e3f1b21718b0 implements RemoteDataSegment
kazz <kazz@cr.ie.u-ryukyu.ac.jp>
parents: 13
diff changeset
14 public RemoteDataSegmentManager(Connection connection) {
e3f1b21718b0 implements RemoteDataSegment
kazz <kazz@cr.ie.u-ryukyu.ac.jp>
parents: 13
diff changeset
15 this.connection = connection;
e3f1b21718b0 implements RemoteDataSegment
kazz <kazz@cr.ie.u-ryukyu.ac.jp>
parents: 13
diff changeset
16 new IncomingTcpConnection(connection, this).start();
e3f1b21718b0 implements RemoteDataSegment
kazz <kazz@cr.ie.u-ryukyu.ac.jp>
parents: 13
diff changeset
17 new OutboundTcpConnection(connection).start();
e3f1b21718b0 implements RemoteDataSegment
kazz <kazz@cr.ie.u-ryukyu.ac.jp>
parents: 13
diff changeset
18 new Thread(replyThread).start();
e3f1b21718b0 implements RemoteDataSegment
kazz <kazz@cr.ie.u-ryukyu.ac.jp>
parents: 13
diff changeset
19 }
e3f1b21718b0 implements RemoteDataSegment
kazz <kazz@cr.ie.u-ryukyu.ac.jp>
parents: 13
diff changeset
20
12
c4d6ff56b9bf unite Command and Reply
one
parents:
diff changeset
21 @Override
c4d6ff56b9bf unite Command and Reply
one
parents:
diff changeset
22 public void put(String key, Value val) {
14
e3f1b21718b0 implements RemoteDataSegment
kazz <kazz@cr.ie.u-ryukyu.ac.jp>
parents: 13
diff changeset
23 connection.sendCommand(new Command(CommandType.PUT, null, key, val, 0, 0, null, null));
12
c4d6ff56b9bf unite Command and Reply
one
parents:
diff changeset
24 }
c4d6ff56b9bf unite Command and Reply
one
parents:
diff changeset
25
c4d6ff56b9bf unite Command and Reply
one
parents:
diff changeset
26 @Override
c4d6ff56b9bf unite Command and Reply
one
parents:
diff changeset
27 public void update(String key, Value val) {
14
e3f1b21718b0 implements RemoteDataSegment
kazz <kazz@cr.ie.u-ryukyu.ac.jp>
parents: 13
diff changeset
28 connection.sendCommand(new Command(CommandType.UPDATE, null, key, val, 0, 0, null, null));
12
c4d6ff56b9bf unite Command and Reply
one
parents:
diff changeset
29 }
c4d6ff56b9bf unite Command and Reply
one
parents:
diff changeset
30
c4d6ff56b9bf unite Command and Reply
one
parents:
diff changeset
31 @Override
c4d6ff56b9bf unite Command and Reply
one
parents:
diff changeset
32 public void take(String argKey, String key, int index, CodeSegment cs) {
14
e3f1b21718b0 implements RemoteDataSegment
kazz <kazz@cr.ie.u-ryukyu.ac.jp>
parents: 13
diff changeset
33 int seq = this.seq.getAndIncrement();
e3f1b21718b0 implements RemoteDataSegment
kazz <kazz@cr.ie.u-ryukyu.ac.jp>
parents: 13
diff changeset
34 Command cmd = new Command(CommandType.TAKE, argKey, key, null, index, seq, replyQueue, cs);
e3f1b21718b0 implements RemoteDataSegment
kazz <kazz@cr.ie.u-ryukyu.ac.jp>
parents: 13
diff changeset
35 seqHash.put(seq, cmd);
e3f1b21718b0 implements RemoteDataSegment
kazz <kazz@cr.ie.u-ryukyu.ac.jp>
parents: 13
diff changeset
36 connection.sendCommand(cmd);
12
c4d6ff56b9bf unite Command and Reply
one
parents:
diff changeset
37 }
c4d6ff56b9bf unite Command and Reply
one
parents:
diff changeset
38
c4d6ff56b9bf unite Command and Reply
one
parents:
diff changeset
39 @Override
c4d6ff56b9bf unite Command and Reply
one
parents:
diff changeset
40 public void peek(String argKey, String key, int index, CodeSegment cs) {
14
e3f1b21718b0 implements RemoteDataSegment
kazz <kazz@cr.ie.u-ryukyu.ac.jp>
parents: 13
diff changeset
41 int seq = this.seq.getAndIncrement();
e3f1b21718b0 implements RemoteDataSegment
kazz <kazz@cr.ie.u-ryukyu.ac.jp>
parents: 13
diff changeset
42 Command cmd = new Command(CommandType.PEEK, argKey, key, null, index, seq, replyQueue, cs);
e3f1b21718b0 implements RemoteDataSegment
kazz <kazz@cr.ie.u-ryukyu.ac.jp>
parents: 13
diff changeset
43 seqHash.put(seq, cmd);
e3f1b21718b0 implements RemoteDataSegment
kazz <kazz@cr.ie.u-ryukyu.ac.jp>
parents: 13
diff changeset
44 connection.sendCommand(cmd);
12
c4d6ff56b9bf unite Command and Reply
one
parents:
diff changeset
45 }
c4d6ff56b9bf unite Command and Reply
one
parents:
diff changeset
46
c4d6ff56b9bf unite Command and Reply
one
parents:
diff changeset
47 @Override
c4d6ff56b9bf unite Command and Reply
one
parents:
diff changeset
48 public void remove(String key) {
14
e3f1b21718b0 implements RemoteDataSegment
kazz <kazz@cr.ie.u-ryukyu.ac.jp>
parents: 13
diff changeset
49 connection.sendCommand(new Command(CommandType.REMOVE, null, key, null, 0, 0, null, null));
12
c4d6ff56b9bf unite Command and Reply
one
parents:
diff changeset
50 }
13
30f97d776a3e implements Alice daemon
one
parents: 12
diff changeset
51
12
c4d6ff56b9bf unite Command and Reply
one
parents:
diff changeset
52 }