Mercurial > hg > Database > Alice

annotate src/main/java/alice/daemon/IncomingTcpConnection.java @ 527:bfec2c3ff1b8 dispose

Find changesets by keywords (author, files, the commit message), revision number or hash, or revset expression.
change unzip
author Nozomi Teruya <e125769@ie.u-ryukyu.ac.jp>
date Thu, 30 Apr 2015 18:14:02 +0900
parents 928907206d21
children 6ebddfac7ff6
Ignore whitespace changes - Everywhere: Within whitespace: At end of lines:
rev   line source
345
8f71c3e6f11d Change directory structure Maven standard
sugi
parents:
diff changeset
1 package alice.daemon;
8f71c3e6f11d Change directory structure Maven standard
sugi
parents:
diff changeset
2
8f71c3e6f11d Change directory structure Maven standard
sugi
parents:
diff changeset
3 import java.io.EOFException;
8f71c3e6f11d Change directory structure Maven standard
sugi
parents:
diff changeset
4 import java.io.IOException;
8f71c3e6f11d Change directory structure Maven standard
sugi
parents:
diff changeset
5 import java.nio.channels.ClosedChannelException;
8f71c3e6f11d Change directory structure Maven standard
sugi
parents:
diff changeset
6
527
bfec2c3ff1b8 change unzip
Nozomi Teruya <e125769@ie.u-ryukyu.ac.jp>
parents: 526
diff changeset
7 import alice.datasegment.*;
345
8f71c3e6f11d Change directory structure Maven standard
sugi
parents:
diff changeset
8 import org.msgpack.unpacker.Unpacker;
8f71c3e6f11d Change directory structure Maven standard
sugi
parents:
diff changeset
9
8f71c3e6f11d Change directory structure Maven standard
sugi
parents:
diff changeset
10 import alice.codesegment.SingletonMessage;
8f71c3e6f11d Change directory structure Maven standard
sugi
parents:
diff changeset
11 import alice.topology.manager.keeparive.RespondData;
8f71c3e6f11d Change directory structure Maven standard
sugi
parents:
diff changeset
12
8f71c3e6f11d Change directory structure Maven standard
sugi
parents:
diff changeset
13 public class IncomingTcpConnection extends Thread {
419
aefbe41fcf12 change tab to space
sugi
parents: 417
diff changeset
14
480
c06070403ed4 named IncomingTcp and OutboundTcp Thread
sugi
parents: 478
diff changeset
15 private Connection connection;
c06070403ed4 named IncomingTcp and OutboundTcp Thread
sugi
parents: 478
diff changeset
16 protected DataSegmentManager manager;
c06070403ed4 named IncomingTcp and OutboundTcp Thread
sugi
parents: 478
diff changeset
17 protected String reverseKey;
419
aefbe41fcf12 change tab to space
sugi
parents: 417
diff changeset
18 private LocalDataSegmentManager lmanager = DataSegment.getLocal();
526
928907206d21 remove CompressedRDSM & CompressedLDSM class
Nozomi Teruya <e125769@ie.u-ryukyu.ac.jp>
parents: 525
diff changeset
19 private LocalDataSegmentManager compressedlmanager = DataSegment.getCompressedLocal();
419
aefbe41fcf12 change tab to space
sugi
parents: 417
diff changeset
20
aefbe41fcf12 change tab to space
sugi
parents: 417
diff changeset
21 public IncomingTcpConnection(DataSegmentManager manager) {
aefbe41fcf12 change tab to space
sugi
parents: 417
diff changeset
22 this.manager = manager;
aefbe41fcf12 change tab to space
sugi
parents: 417
diff changeset
23 }
aefbe41fcf12 change tab to space
sugi
parents: 417
diff changeset
24
aefbe41fcf12 change tab to space
sugi
parents: 417
diff changeset
25 public IncomingTcpConnection(Connection connection, DataSegmentManager manager, String reverseKey) {
aefbe41fcf12 change tab to space
sugi
parents: 417
diff changeset
26 this.manager = manager;
aefbe41fcf12 change tab to space
sugi
parents: 417
diff changeset
27 this.connection = connection;
aefbe41fcf12 change tab to space
sugi
parents: 417
diff changeset
28 this.reverseKey = reverseKey;
aefbe41fcf12 change tab to space
sugi
parents: 417
diff changeset
29 }
aefbe41fcf12 change tab to space
sugi
parents: 417
diff changeset
30
aefbe41fcf12 change tab to space
sugi
parents: 417
diff changeset
31 public LocalDataSegmentManager getLocalDataSegmentManager(){
aefbe41fcf12 change tab to space
sugi
parents: 417
diff changeset
32 return lmanager;
aefbe41fcf12 change tab to space
sugi
parents: 417
diff changeset
33 }
345
8f71c3e6f11d Change directory structure Maven standard
sugi
parents:
diff changeset
34
526
928907206d21 remove CompressedRDSM & CompressedLDSM class
Nozomi Teruya <e125769@ie.u-ryukyu.ac.jp>
parents: 525
diff changeset
35 public LocalDataSegmentManager getCompressedLocalDataSegmentManager(){//追加
928907206d21 remove CompressedRDSM & CompressedLDSM class
Nozomi Teruya <e125769@ie.u-ryukyu.ac.jp>
parents: 525
diff changeset
36 return compressedlmanager;
928907206d21 remove CompressedRDSM & CompressedLDSM class
Nozomi Teruya <e125769@ie.u-ryukyu.ac.jp>
parents: 525
diff changeset
37 }
928907206d21 remove CompressedRDSM & CompressedLDSM class
Nozomi Teruya <e125769@ie.u-ryukyu.ac.jp>
parents: 525
diff changeset
38
419
aefbe41fcf12 change tab to space
sugi
parents: 417
diff changeset
39 /**
aefbe41fcf12 change tab to space
sugi
parents: 417
diff changeset
40 * pipeline thread for receiving
aefbe41fcf12 change tab to space
sugi
parents: 417
diff changeset
41 */
aefbe41fcf12 change tab to space
sugi
parents: 417
diff changeset
42 public void run() {
aefbe41fcf12 change tab to space
sugi
parents: 417
diff changeset
43 Unpacker unpacker = null;
aefbe41fcf12 change tab to space
sugi
parents: 417
diff changeset
44 try {
445
86b74532e66c change Protocol
sugi
parents: 443
diff changeset
45 unpacker = SingletonMessage.getInstance().createUnpacker(connection.socket.getInputStream());
419
aefbe41fcf12 change tab to space
sugi
parents: 417
diff changeset
46 } catch (IOException e) {
aefbe41fcf12 change tab to space
sugi
parents: 417
diff changeset
47 e.printStackTrace();
aefbe41fcf12 change tab to space
sugi
parents: 417
diff changeset
48 }
aefbe41fcf12 change tab to space
sugi
parents: 417
diff changeset
49 if (unpacker == null) {
aefbe41fcf12 change tab to space
sugi
parents: 417
diff changeset
50 return;
aefbe41fcf12 change tab to space
sugi
parents: 417
diff changeset
51 }
aefbe41fcf12 change tab to space
sugi
parents: 417
diff changeset
52 while (true) {
aefbe41fcf12 change tab to space
sugi
parents: 417
diff changeset
53 try {
447
d30451d1882f fix IncomingUdpConnection and passed UdpTest
sugi
parents: 446
diff changeset
54 Command cmd = null;
458
bcf6f4a6fcd0 need set Meta DataSegment PUT API
sugi
parents: 455
diff changeset
55 ReceiveData rData = null;
419
aefbe41fcf12 change tab to space
sugi
parents: 417
diff changeset
56 CommandMessage msg = unpacker.read(CommandMessage.class);
aefbe41fcf12 change tab to space
sugi
parents: 417
diff changeset
57 CommandType type = CommandType.getCommandTypeFromId(msg.type);
aefbe41fcf12 change tab to space
sugi
parents: 417
diff changeset
58 switch (type) {
aefbe41fcf12 change tab to space
sugi
parents: 417
diff changeset
59 case UPDATE:
aefbe41fcf12 change tab to space
sugi
parents: 417
diff changeset
60 case PUT:
526
928907206d21 remove CompressedRDSM & CompressedLDSM class
Nozomi Teruya <e125769@ie.u-ryukyu.ac.jp>
parents: 525
diff changeset
61 System.out.println("in TCP PUT");
525
30a74eee59c7 working TestRemoteAlice
Nozomi Teruya <e125769@ie.u-ryukyu.ac.jp>
parents: 524
diff changeset
62 rData = new ReceiveData(unpacker.getSerializedByteArray(unpacker.readInt()));
30a74eee59c7 working TestRemoteAlice
Nozomi Teruya <e125769@ie.u-ryukyu.ac.jp>
parents: 524
diff changeset
63 rData.setCompressFlag(msg.compressed);
526
928907206d21 remove CompressedRDSM & CompressedLDSM class
Nozomi Teruya <e125769@ie.u-ryukyu.ac.jp>
parents: 525
diff changeset
64
488
7ef0ebb40c9b add measurement data in protocol
sugi
parents: 480
diff changeset
65 if (msg.setTime) {
7ef0ebb40c9b add measurement data in protocol
sugi
parents: 480
diff changeset
66 rData.setTime = true;
7ef0ebb40c9b add measurement data in protocol
sugi
parents: 480
diff changeset
67 rData.time = msg.time;
7ef0ebb40c9b add measurement data in protocol
sugi
parents: 480
diff changeset
68 rData.depth = msg.depth;
7ef0ebb40c9b add measurement data in protocol
sugi
parents: 480
diff changeset
69 }
526
928907206d21 remove CompressedRDSM & CompressedLDSM class
Nozomi Teruya <e125769@ie.u-ryukyu.ac.jp>
parents: 525
diff changeset
70
458
bcf6f4a6fcd0 need set Meta DataSegment PUT API
sugi
parents: 455
diff changeset
71 cmd = new Command(type, null, null, rData, 0, 0, null, null, reverseKey);
526
928907206d21 remove CompressedRDSM & CompressedLDSM class
Nozomi Teruya <e125769@ie.u-ryukyu.ac.jp>
parents: 525
diff changeset
72
928907206d21 remove CompressedRDSM & CompressedLDSM class
Nozomi Teruya <e125769@ie.u-ryukyu.ac.jp>
parents: 525
diff changeset
73 if (msg.compressed){
928907206d21 remove CompressedRDSM & CompressedLDSM class
Nozomi Teruya <e125769@ie.u-ryukyu.ac.jp>
parents: 525
diff changeset
74 compressedlmanager.getDataSegmentKey(msg.key).runCommand(cmd);
928907206d21 remove CompressedRDSM & CompressedLDSM class
Nozomi Teruya <e125769@ie.u-ryukyu.ac.jp>
parents: 525
diff changeset
75 } else {
928907206d21 remove CompressedRDSM & CompressedLDSM class
Nozomi Teruya <e125769@ie.u-ryukyu.ac.jp>
parents: 525
diff changeset
76 lmanager.getDataSegmentKey(msg.key).runCommand(cmd);
928907206d21 remove CompressedRDSM & CompressedLDSM class
Nozomi Teruya <e125769@ie.u-ryukyu.ac.jp>
parents: 525
diff changeset
77 }
928907206d21 remove CompressedRDSM & CompressedLDSM class
Nozomi Teruya <e125769@ie.u-ryukyu.ac.jp>
parents: 525
diff changeset
78
419
aefbe41fcf12 change tab to space
sugi
parents: 417
diff changeset
79 break;
aefbe41fcf12 change tab to space
sugi
parents: 417
diff changeset
80 case PEEK:
aefbe41fcf12 change tab to space
sugi
parents: 417
diff changeset
81 case TAKE:
526
928907206d21 remove CompressedRDSM & CompressedLDSM class
Nozomi Teruya <e125769@ie.u-ryukyu.ac.jp>
parents: 525
diff changeset
82 System.out.println("in TCP TAKE");
446
a91890dff56e refactor
sugi
parents: 445
diff changeset
83 cmd = new Command(type, null, null, null, msg.index, msg.seq, null, null, connection);
449
09a80f83c605 add Serialized and compressed flag on protocol header
sugi
parents: 447
diff changeset
84 cmd.setQuickFlag(msg.quickFlag);
526
928907206d21 remove CompressedRDSM & CompressedLDSM class
Nozomi Teruya <e125769@ie.u-ryukyu.ac.jp>
parents: 525
diff changeset
85 cmd.setCompressFlag(msg.compressed);
928907206d21 remove CompressedRDSM & CompressedLDSM class
Nozomi Teruya <e125769@ie.u-ryukyu.ac.jp>
parents: 525
diff changeset
86
928907206d21 remove CompressedRDSM & CompressedLDSM class
Nozomi Teruya <e125769@ie.u-ryukyu.ac.jp>
parents: 525
diff changeset
87 if (msg.compressed) {
928907206d21 remove CompressedRDSM & CompressedLDSM class
Nozomi Teruya <e125769@ie.u-ryukyu.ac.jp>
parents: 525
diff changeset
88 compressedlmanager.getDataSegmentKey(msg.key).runCommand(cmd);
928907206d21 remove CompressedRDSM & CompressedLDSM class
Nozomi Teruya <e125769@ie.u-ryukyu.ac.jp>
parents: 525
diff changeset
89 } else {
928907206d21 remove CompressedRDSM & CompressedLDSM class
Nozomi Teruya <e125769@ie.u-ryukyu.ac.jp>
parents: 525
diff changeset
90 lmanager.getDataSegmentKey(msg.key).runCommand(cmd);
928907206d21 remove CompressedRDSM & CompressedLDSM class
Nozomi Teruya <e125769@ie.u-ryukyu.ac.jp>
parents: 525
diff changeset
91 }
928907206d21 remove CompressedRDSM & CompressedLDSM class
Nozomi Teruya <e125769@ie.u-ryukyu.ac.jp>
parents: 525
diff changeset
92
467
6e304a7a60e7 remove white space
sugi
parents: 459
diff changeset
93 break;
419
aefbe41fcf12 change tab to space
sugi
parents: 417
diff changeset
94 case REMOVE:
446
a91890dff56e refactor
sugi
parents: 445
diff changeset
95 cmd = new Command(type, null, null, null, 0, 0, null, null, "");
a91890dff56e refactor
sugi
parents: 445
diff changeset
96 lmanager.getDataSegmentKey(msg.key).runCommand(cmd);
419
aefbe41fcf12 change tab to space
sugi
parents: 417
diff changeset
97 break;
aefbe41fcf12 change tab to space
sugi
parents: 417
diff changeset
98 case REPLY:
526
928907206d21 remove CompressedRDSM & CompressedLDSM class
Nozomi Teruya <e125769@ie.u-ryukyu.ac.jp>
parents: 525
diff changeset
99 System.out.println("in TCP REPLY");
446
a91890dff56e refactor
sugi
parents: 445
diff changeset
100 cmd = manager.getAndRemoveCmd(msg.seq);
526
928907206d21 remove CompressedRDSM & CompressedLDSM class
Nozomi Teruya <e125769@ie.u-ryukyu.ac.jp>
parents: 525
diff changeset
101
527
bfec2c3ff1b8 change unzip
Nozomi Teruya <e125769@ie.u-ryukyu.ac.jp>
parents: 526
diff changeset
102 rData = new ReceiveData(unpacker.getSerializedByteArray(unpacker.readInt()));//ここのコンストラクタでx
525
30a74eee59c7 working TestRemoteAlice
Nozomi Teruya <e125769@ie.u-ryukyu.ac.jp>
parents: 524
diff changeset
103 rData.setCompressFlag(msg.compressed);
526
928907206d21 remove CompressedRDSM & CompressedLDSM class
Nozomi Teruya <e125769@ie.u-ryukyu.ac.jp>
parents: 525
diff changeset
104
467
6e304a7a60e7 remove white space
sugi
parents: 459
diff changeset
105 Command rCmd = new Command(type, null, null, rData, msg.index, msg.seq, null, null, "");
452
f68d103498e0 refactor (InputDataSegment holder class changed)
sugi
parents: 449
diff changeset
106 cmd.cs.ids.reply(cmd.receiver, rCmd);
419
aefbe41fcf12 change tab to space
sugi
parents: 417
diff changeset
107 break;
aefbe41fcf12 change tab to space
sugi
parents: 417
diff changeset
108 case PING:
471
be0b61986ff7 checking having DataSegmentManger before get DataSegmentManager
sugi
parents: 467
diff changeset
109 if (DataSegment.contains(reverseKey))
be0b61986ff7 checking having DataSegmentManger before get DataSegmentManager
sugi
parents: 467
diff changeset
110 DataSegment.get(reverseKey).response(msg.key);
419
aefbe41fcf12 change tab to space
sugi
parents: 417
diff changeset
111 break;
aefbe41fcf12 change tab to space
sugi
parents: 417
diff changeset
112 case RESPONSE:
525
30a74eee59c7 working TestRemoteAlice
Nozomi Teruya <e125769@ie.u-ryukyu.ac.jp>
parents: 524
diff changeset
113 rData = new ReceiveData(new RespondData(reverseKey, System.currentTimeMillis()));
527
bfec2c3ff1b8 change unzip
Nozomi Teruya <e125769@ie.u-ryukyu.ac.jp>
parents: 526
diff changeset
114 DataSegment.getLocal().put(msg.key, rData, null);
419
aefbe41fcf12 change tab to space
sugi
parents: 417
diff changeset
115 break;
aefbe41fcf12 change tab to space
sugi
parents: 417
diff changeset
116 default:
aefbe41fcf12 change tab to space
sugi
parents: 417
diff changeset
117 break;
aefbe41fcf12 change tab to space
sugi
parents: 417
diff changeset
118 }
aefbe41fcf12 change tab to space
sugi
parents: 417
diff changeset
119 } catch (ClosedChannelException e) {
aefbe41fcf12 change tab to space
sugi
parents: 417
diff changeset
120 return;
aefbe41fcf12 change tab to space
sugi
parents: 417
diff changeset
121 } catch (EOFException e) {
aefbe41fcf12 change tab to space
sugi
parents: 417
diff changeset
122 return;
aefbe41fcf12 change tab to space
sugi
parents: 417
diff changeset
123 } catch (IOException e) {
478
cf345b10a21a bug fix
sugi
parents: 471
diff changeset
124 return;
419
aefbe41fcf12 change tab to space
sugi
parents: 417
diff changeset
125 }
aefbe41fcf12 change tab to space
sugi
parents: 417
diff changeset
126 }
443
2f2623484b77 change protocol
sugi
parents: 419
diff changeset
127 }
480
c06070403ed4 named IncomingTcp and OutboundTcp Thread
sugi
parents: 478
diff changeset
128
c06070403ed4 named IncomingTcp and OutboundTcp Thread
sugi
parents: 478
diff changeset
129 public void setReverseKey(String name) {
c06070403ed4 named IncomingTcp and OutboundTcp Thread
sugi
parents: 478
diff changeset
130 this.reverseKey = name;
c06070403ed4 named IncomingTcp and OutboundTcp Thread
sugi
parents: 478
diff changeset
131 setName(name+"-IncomingTcp");
c06070403ed4 named IncomingTcp and OutboundTcp Thread
sugi
parents: 478
diff changeset
132 }
345
8f71c3e6f11d Change directory structure Maven standard
sugi
parents:
diff changeset
133 }