Mercurial > hg > Database > Alice

annotate src/alice/datasegment/RemoteDataSegmentManager.java @ 23:54bf607118ae

Find changesets by keywords (author, files, the commit message), revision number or hash, or revset expression.
change method to create RemoteDSM
author kazz <kazz@cr.ie.u-ryukyu.ac.jp>
date Tue, 17 Jan 2012 01:10:29 +0900
parents 0bb03861b5cd
children 50c75cb3de60
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
23
54bf607118ae change method to create RemoteDSM
kazz <kazz@cr.ie.u-ryukyu.ac.jp>
parents: 20
diff changeset
3 import java.io.IOException;
54bf607118ae change method to create RemoteDSM
kazz <kazz@cr.ie.u-ryukyu.ac.jp>
parents: 20
diff changeset
4 import java.net.InetSocketAddress;
54bf607118ae change method to create RemoteDSM
kazz <kazz@cr.ie.u-ryukyu.ac.jp>
parents: 20
diff changeset
5 import java.nio.channels.SocketChannel;
54bf607118ae change method to create RemoteDSM
kazz <kazz@cr.ie.u-ryukyu.ac.jp>
parents: 20
diff changeset
6
12
c4d6ff56b9bf unite Command and Reply
one
parents:
diff changeset
7 import org.msgpack.type.Value;
c4d6ff56b9bf unite Command and Reply
one
parents:
diff changeset
8
c4d6ff56b9bf unite Command and Reply
one
parents:
diff changeset
9 import alice.codesegment.CodeSegment;
14
e3f1b21718b0 implements RemoteDataSegment
kazz <kazz@cr.ie.u-ryukyu.ac.jp>
parents: 13
diff changeset
10 import alice.daemon.Connection;
e3f1b21718b0 implements RemoteDataSegment
kazz <kazz@cr.ie.u-ryukyu.ac.jp>
parents: 13
diff changeset
11 import alice.daemon.IncomingTcpConnection;
e3f1b21718b0 implements RemoteDataSegment
kazz <kazz@cr.ie.u-ryukyu.ac.jp>
parents: 13
diff changeset
12 import alice.daemon.OutboundTcpConnection;
12
c4d6ff56b9bf unite Command and Reply
one
parents:
diff changeset
13
14
e3f1b21718b0 implements RemoteDataSegment
kazz <kazz@cr.ie.u-ryukyu.ac.jp>
parents: 13
diff changeset
14 public class RemoteDataSegmentManager extends DataSegmentManager {
e3f1b21718b0 implements RemoteDataSegment
kazz <kazz@cr.ie.u-ryukyu.ac.jp>
parents: 13
diff changeset
15
e3f1b21718b0 implements RemoteDataSegment
kazz <kazz@cr.ie.u-ryukyu.ac.jp>
parents: 13
diff changeset
16 Connection connection;
e3f1b21718b0 implements RemoteDataSegment
kazz <kazz@cr.ie.u-ryukyu.ac.jp>
parents: 13
diff changeset
17
23
54bf607118ae change method to create RemoteDSM
kazz <kazz@cr.ie.u-ryukyu.ac.jp>
parents: 20
diff changeset
18 // TODO: delete this constructor later
54bf607118ae change method to create RemoteDSM
kazz <kazz@cr.ie.u-ryukyu.ac.jp>
parents: 20
diff changeset
19 @Deprecated
14
e3f1b21718b0 implements RemoteDataSegment
kazz <kazz@cr.ie.u-ryukyu.ac.jp>
parents: 13
diff changeset
20 public RemoteDataSegmentManager(Connection connection) {
e3f1b21718b0 implements RemoteDataSegment
kazz <kazz@cr.ie.u-ryukyu.ac.jp>
parents: 13
diff changeset
21 this.connection = connection;
e3f1b21718b0 implements RemoteDataSegment
kazz <kazz@cr.ie.u-ryukyu.ac.jp>
parents: 13
diff changeset
22 new IncomingTcpConnection(connection, this).start();
e3f1b21718b0 implements RemoteDataSegment
kazz <kazz@cr.ie.u-ryukyu.ac.jp>
parents: 13
diff changeset
23 new OutboundTcpConnection(connection).start();
20
0bb03861b5cd set name to Thread
kazz <kazz@cr.ie.u-ryukyu.ac.jp>
parents: 18
diff changeset
24 new Thread(replyThread, "RemoteDataSegmentManager-"
0bb03861b5cd set name to Thread
kazz <kazz@cr.ie.u-ryukyu.ac.jp>
parents: 18
diff changeset
25 + connection.socket.getInetAddress().getHostName()
0bb03861b5cd set name to Thread
kazz <kazz@cr.ie.u-ryukyu.ac.jp>
parents: 18
diff changeset
26 + ":" + connection.socket.getPort()).start();
14
e3f1b21718b0 implements RemoteDataSegment
kazz <kazz@cr.ie.u-ryukyu.ac.jp>
parents: 13
diff changeset
27 }
e3f1b21718b0 implements RemoteDataSegment
kazz <kazz@cr.ie.u-ryukyu.ac.jp>
parents: 13
diff changeset
28
23
54bf607118ae change method to create RemoteDSM
kazz <kazz@cr.ie.u-ryukyu.ac.jp>
parents: 20
diff changeset
29 public RemoteDataSegmentManager(String key, final String hostName, final int port) {
54bf607118ae change method to create RemoteDSM
kazz <kazz@cr.ie.u-ryukyu.ac.jp>
parents: 20
diff changeset
30 connection = new Connection();
54bf607118ae change method to create RemoteDSM
kazz <kazz@cr.ie.u-ryukyu.ac.jp>
parents: 20
diff changeset
31 final RemoteDataSegmentManager manager = this;
54bf607118ae change method to create RemoteDSM
kazz <kazz@cr.ie.u-ryukyu.ac.jp>
parents: 20
diff changeset
32 new Thread(replyThread, "RemoteDataSegmentManager-"
54bf607118ae change method to create RemoteDSM
kazz <kazz@cr.ie.u-ryukyu.ac.jp>
parents: 20
diff changeset
33 + connection.socket.getInetAddress().getHostName()
54bf607118ae change method to create RemoteDSM
kazz <kazz@cr.ie.u-ryukyu.ac.jp>
parents: 20
diff changeset
34 + ":" + connection.socket.getPort()).start();
54bf607118ae change method to create RemoteDSM
kazz <kazz@cr.ie.u-ryukyu.ac.jp>
parents: 20
diff changeset
35 new Thread("Connect-" + key) {
54bf607118ae change method to create RemoteDSM
kazz <kazz@cr.ie.u-ryukyu.ac.jp>
parents: 20
diff changeset
36 public void run() {
54bf607118ae change method to create RemoteDSM
kazz <kazz@cr.ie.u-ryukyu.ac.jp>
parents: 20
diff changeset
37 boolean connect = true;
54bf607118ae change method to create RemoteDSM
kazz <kazz@cr.ie.u-ryukyu.ac.jp>
parents: 20
diff changeset
38 do {
54bf607118ae change method to create RemoteDSM
kazz <kazz@cr.ie.u-ryukyu.ac.jp>
parents: 20
diff changeset
39 try {
54bf607118ae change method to create RemoteDSM
kazz <kazz@cr.ie.u-ryukyu.ac.jp>
parents: 20
diff changeset
40 SocketChannel sc = SocketChannel.open(new InetSocketAddress(hostName, port));
54bf607118ae change method to create RemoteDSM
kazz <kazz@cr.ie.u-ryukyu.ac.jp>
parents: 20
diff changeset
41 connection.socket = sc.socket();
54bf607118ae change method to create RemoteDSM
kazz <kazz@cr.ie.u-ryukyu.ac.jp>
parents: 20
diff changeset
42 connect = false;
54bf607118ae change method to create RemoteDSM
kazz <kazz@cr.ie.u-ryukyu.ac.jp>
parents: 20
diff changeset
43 } catch (IOException e) {
54bf607118ae change method to create RemoteDSM
kazz <kazz@cr.ie.u-ryukyu.ac.jp>
parents: 20
diff changeset
44 try {
54bf607118ae change method to create RemoteDSM
kazz <kazz@cr.ie.u-ryukyu.ac.jp>
parents: 20
diff changeset
45 Thread.sleep(500);
54bf607118ae change method to create RemoteDSM
kazz <kazz@cr.ie.u-ryukyu.ac.jp>
parents: 20
diff changeset
46 } catch (InterruptedException e1) {
54bf607118ae change method to create RemoteDSM
kazz <kazz@cr.ie.u-ryukyu.ac.jp>
parents: 20
diff changeset
47 e1.printStackTrace();
54bf607118ae change method to create RemoteDSM
kazz <kazz@cr.ie.u-ryukyu.ac.jp>
parents: 20
diff changeset
48 }
54bf607118ae change method to create RemoteDSM
kazz <kazz@cr.ie.u-ryukyu.ac.jp>
parents: 20
diff changeset
49 }
54bf607118ae change method to create RemoteDSM
kazz <kazz@cr.ie.u-ryukyu.ac.jp>
parents: 20
diff changeset
50 } while (connect);
54bf607118ae change method to create RemoteDSM
kazz <kazz@cr.ie.u-ryukyu.ac.jp>
parents: 20
diff changeset
51 new IncomingTcpConnection(connection, manager).start();
54bf607118ae change method to create RemoteDSM
kazz <kazz@cr.ie.u-ryukyu.ac.jp>
parents: 20
diff changeset
52 new OutboundTcpConnection(connection).start();
54bf607118ae change method to create RemoteDSM
kazz <kazz@cr.ie.u-ryukyu.ac.jp>
parents: 20
diff changeset
53 }
54bf607118ae change method to create RemoteDSM
kazz <kazz@cr.ie.u-ryukyu.ac.jp>
parents: 20
diff changeset
54 }.start();
54bf607118ae change method to create RemoteDSM
kazz <kazz@cr.ie.u-ryukyu.ac.jp>
parents: 20
diff changeset
55 }
54bf607118ae change method to create RemoteDSM
kazz <kazz@cr.ie.u-ryukyu.ac.jp>
parents: 20
diff changeset
56
12
c4d6ff56b9bf unite Command and Reply
one
parents:
diff changeset
57 @Override
c4d6ff56b9bf unite Command and Reply
one
parents:
diff changeset
58 public void put(String key, Value val) {
14
e3f1b21718b0 implements RemoteDataSegment
kazz <kazz@cr.ie.u-ryukyu.ac.jp>
parents: 13
diff changeset
59 connection.sendCommand(new Command(CommandType.PUT, null, key, val, 0, 0, null, null));
12
c4d6ff56b9bf unite Command and Reply
one
parents:
diff changeset
60 }
c4d6ff56b9bf unite Command and Reply
one
parents:
diff changeset
61
c4d6ff56b9bf unite Command and Reply
one
parents:
diff changeset
62 @Override
c4d6ff56b9bf unite Command and Reply
one
parents:
diff changeset
63 public void update(String key, Value val) {
14
e3f1b21718b0 implements RemoteDataSegment
kazz <kazz@cr.ie.u-ryukyu.ac.jp>
parents: 13
diff changeset
64 connection.sendCommand(new Command(CommandType.UPDATE, null, key, val, 0, 0, null, null));
12
c4d6ff56b9bf unite Command and Reply
one
parents:
diff changeset
65 }
c4d6ff56b9bf unite Command and Reply
one
parents:
diff changeset
66
c4d6ff56b9bf unite Command and Reply
one
parents:
diff changeset
67 @Override
18
72dd27d952b0 change InputDataSegment API
kazz <kazz@cr.ie.u-ryukyu.ac.jp>
parents: 14
diff changeset
68 public void take(DataSegmentReceiver receiver, String key, int index, CodeSegment cs) {
14
e3f1b21718b0 implements RemoteDataSegment
kazz <kazz@cr.ie.u-ryukyu.ac.jp>
parents: 13
diff changeset
69 int seq = this.seq.getAndIncrement();
18
72dd27d952b0 change InputDataSegment API
kazz <kazz@cr.ie.u-ryukyu.ac.jp>
parents: 14
diff changeset
70 Command cmd = new Command(CommandType.TAKE, receiver, key, null, index, seq, replyQueue, cs);
14
e3f1b21718b0 implements RemoteDataSegment
kazz <kazz@cr.ie.u-ryukyu.ac.jp>
parents: 13
diff changeset
71 seqHash.put(seq, cmd);
e3f1b21718b0 implements RemoteDataSegment
kazz <kazz@cr.ie.u-ryukyu.ac.jp>
parents: 13
diff changeset
72 connection.sendCommand(cmd);
12
c4d6ff56b9bf unite Command and Reply
one
parents:
diff changeset
73 }
c4d6ff56b9bf unite Command and Reply
one
parents:
diff changeset
74
c4d6ff56b9bf unite Command and Reply
one
parents:
diff changeset
75 @Override
18
72dd27d952b0 change InputDataSegment API
kazz <kazz@cr.ie.u-ryukyu.ac.jp>
parents: 14
diff changeset
76 public void peek(DataSegmentReceiver receiver, String key, int index, CodeSegment cs) {
14
e3f1b21718b0 implements RemoteDataSegment
kazz <kazz@cr.ie.u-ryukyu.ac.jp>
parents: 13
diff changeset
77 int seq = this.seq.getAndIncrement();
18
72dd27d952b0 change InputDataSegment API
kazz <kazz@cr.ie.u-ryukyu.ac.jp>
parents: 14
diff changeset
78 Command cmd = new Command(CommandType.PEEK, receiver, key, null, index, seq, replyQueue, cs);
14
e3f1b21718b0 implements RemoteDataSegment
kazz <kazz@cr.ie.u-ryukyu.ac.jp>
parents: 13
diff changeset
79 seqHash.put(seq, cmd);
e3f1b21718b0 implements RemoteDataSegment
kazz <kazz@cr.ie.u-ryukyu.ac.jp>
parents: 13
diff changeset
80 connection.sendCommand(cmd);
12
c4d6ff56b9bf unite Command and Reply
one
parents:
diff changeset
81 }
c4d6ff56b9bf unite Command and Reply
one
parents:
diff changeset
82
c4d6ff56b9bf unite Command and Reply
one
parents:
diff changeset
83 @Override
c4d6ff56b9bf unite Command and Reply
one
parents:
diff changeset
84 public void remove(String key) {
14
e3f1b21718b0 implements RemoteDataSegment
kazz <kazz@cr.ie.u-ryukyu.ac.jp>
parents: 13
diff changeset
85 connection.sendCommand(new Command(CommandType.REMOVE, null, key, null, 0, 0, null, null));
12
c4d6ff56b9bf unite Command and Reply
one
parents:
diff changeset
86 }
13
30f97d776a3e implements Alice daemon
one
parents: 12
diff changeset
87
12
c4d6ff56b9bf unite Command and Reply
one
parents:
diff changeset
88 }