Mercurial > hg > Database > Alice

annotate src/main/java/alice/daemon/IncomingTcpConnection.java @ 531:b6049fb123d8 dispose

Find changesets by keywords (author, files, the commit message), revision number or hash, or revset expression.
resolve unzip, working TestRemoteAlice
author Nozomi Teruya <e125769@ie.u-ryukyu.ac.jp>
date Sun, 03 May 2015 15:58:31 +0900
parents 4aeebea0c9b5
children 33f981dd91d2
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.*;
528
6ebddfac7ff6 delete RecieveData.setCompressFlag
kazz <kazz@cr.ie.u-ryukyu.ac.jp>
parents: 527
diff changeset
8 import org.msgpack.MessagePack;
345
8f71c3e6f11d Change directory structure Maven standard
sugi
parents:
diff changeset
9 import org.msgpack.unpacker.Unpacker;
8f71c3e6f11d Change directory structure Maven standard
sugi
parents:
diff changeset
10
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();
529
cb7c31848d16 add CompressedDSMs
Nozomi Teruya <e125769@ie.u-ryukyu.ac.jp>
parents: 528
diff changeset
19 private CompressedLocalDataSegmentManager compressedlmanager = DataSegment.getCompressedLocal();
528
6ebddfac7ff6 delete RecieveData.setCompressFlag
kazz <kazz@cr.ie.u-ryukyu.ac.jp>
parents: 527
diff changeset
20 private static final MessagePack packer = new MessagePack();
419
aefbe41fcf12 change tab to space
sugi
parents: 417
diff changeset
21
aefbe41fcf12 change tab to space
sugi
parents: 417
diff changeset
22 public IncomingTcpConnection(DataSegmentManager manager) {
aefbe41fcf12 change tab to space
sugi
parents: 417
diff changeset
23 this.manager = manager;
aefbe41fcf12 change tab to space
sugi
parents: 417
diff changeset
24 }
aefbe41fcf12 change tab to space
sugi
parents: 417
diff changeset
25
aefbe41fcf12 change tab to space
sugi
parents: 417
diff changeset
26 public IncomingTcpConnection(Connection connection, DataSegmentManager manager, String reverseKey) {
aefbe41fcf12 change tab to space
sugi
parents: 417
diff changeset
27 this.manager = manager;
aefbe41fcf12 change tab to space
sugi
parents: 417
diff changeset
28 this.connection = connection;
aefbe41fcf12 change tab to space
sugi
parents: 417
diff changeset
29 this.reverseKey = reverseKey;
aefbe41fcf12 change tab to space
sugi
parents: 417
diff changeset
30 }
aefbe41fcf12 change tab to space
sugi
parents: 417
diff changeset
31
aefbe41fcf12 change tab to space
sugi
parents: 417
diff changeset
32 public LocalDataSegmentManager getLocalDataSegmentManager(){
aefbe41fcf12 change tab to space
sugi
parents: 417
diff changeset
33 return lmanager;
aefbe41fcf12 change tab to space
sugi
parents: 417
diff changeset
34 }
345
8f71c3e6f11d Change directory structure Maven standard
sugi
parents:
diff changeset
35
529
cb7c31848d16 add CompressedDSMs
Nozomi Teruya <e125769@ie.u-ryukyu.ac.jp>
parents: 528
diff changeset
36 public CompressedLocalDataSegmentManager getCompressedLocalDataSegmentManager(){
cb7c31848d16 add CompressedDSMs
Nozomi Teruya <e125769@ie.u-ryukyu.ac.jp>
parents: 528
diff changeset
37 return compressedlmanager;
cb7c31848d16 add CompressedDSMs
Nozomi Teruya <e125769@ie.u-ryukyu.ac.jp>
parents: 528
diff changeset
38 }
cb7c31848d16 add CompressedDSMs
Nozomi Teruya <e125769@ie.u-ryukyu.ac.jp>
parents: 528
diff changeset
39
419
aefbe41fcf12 change tab to space
sugi
parents: 417
diff changeset
40 /**
aefbe41fcf12 change tab to space
sugi
parents: 417
diff changeset
41 * pipeline thread for receiving
aefbe41fcf12 change tab to space
sugi
parents: 417
diff changeset
42 */
aefbe41fcf12 change tab to space
sugi
parents: 417
diff changeset
43 public void run() {
aefbe41fcf12 change tab to space
sugi
parents: 417
diff changeset
44 Unpacker unpacker = null;
aefbe41fcf12 change tab to space
sugi
parents: 417
diff changeset
45 try {
528
6ebddfac7ff6 delete RecieveData.setCompressFlag
kazz <kazz@cr.ie.u-ryukyu.ac.jp>
parents: 527
diff changeset
46 unpacker = packer.createUnpacker(connection.socket.getInputStream());
419
aefbe41fcf12 change tab to space
sugi
parents: 417
diff changeset
47 } catch (IOException e) {
aefbe41fcf12 change tab to space
sugi
parents: 417
diff changeset
48 e.printStackTrace();
aefbe41fcf12 change tab to space
sugi
parents: 417
diff changeset
49 }
aefbe41fcf12 change tab to space
sugi
parents: 417
diff changeset
50 if (unpacker == null) {
aefbe41fcf12 change tab to space
sugi
parents: 417
diff changeset
51 return;
aefbe41fcf12 change tab to space
sugi
parents: 417
diff changeset
52 }
aefbe41fcf12 change tab to space
sugi
parents: 417
diff changeset
53 while (true) {
aefbe41fcf12 change tab to space
sugi
parents: 417
diff changeset
54 try {
447
d30451d1882f fix IncomingUdpConnection and passed UdpTest
sugi
parents: 446
diff changeset
55 Command cmd = null;
458
bcf6f4a6fcd0 need set Meta DataSegment PUT API
sugi
parents: 455
diff changeset
56 ReceiveData rData = null;
530
4aeebea0c9b5 can't unzip
Nozomi Teruya <e125769@ie.u-ryukyu.ac.jp>
parents: 529
diff changeset
57 CommandMessage msg = unpacker.read(CommandMessage.class);///read header
419
aefbe41fcf12 change tab to space
sugi
parents: 417
diff changeset
58 CommandType type = CommandType.getCommandTypeFromId(msg.type);
aefbe41fcf12 change tab to space
sugi
parents: 417
diff changeset
59 switch (type) {
aefbe41fcf12 change tab to space
sugi
parents: 417
diff changeset
60 case UPDATE:
aefbe41fcf12 change tab to space
sugi
parents: 417
diff changeset
61 case PUT:
526
928907206d21 remove CompressedRDSM & CompressedLDSM class
Nozomi Teruya <e125769@ie.u-ryukyu.ac.jp>
parents: 525
diff changeset
62 System.out.println("in TCP PUT");
531
b6049fb123d8 resolve unzip, working TestRemoteAlice
Nozomi Teruya <e125769@ie.u-ryukyu.ac.jp>
parents: 530
diff changeset
63 rData = new ReceiveData(packer.read(unpacker.getSerializedByteArray(unpacker.readInt()), byte[].class), msg.compressed, msg.dataSize);///read rData
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);
530
4aeebea0c9b5 can't unzip
Nozomi Teruya <e125769@ie.u-ryukyu.ac.jp>
parents: 529
diff changeset
72 cmd.setCompressFlag(msg.compressed);
526
928907206d21 remove CompressedRDSM & CompressedLDSM class
Nozomi Teruya <e125769@ie.u-ryukyu.ac.jp>
parents: 525
diff changeset
73
530
4aeebea0c9b5 can't unzip
Nozomi Teruya <e125769@ie.u-ryukyu.ac.jp>
parents: 529
diff changeset
74 if (rData.compressed()){
4aeebea0c9b5 can't unzip
Nozomi Teruya <e125769@ie.u-ryukyu.ac.jp>
parents: 529
diff changeset
75 compressedlmanager.getDataSegmentKey(msg.key).runCommand(cmd);
4aeebea0c9b5 can't unzip
Nozomi Teruya <e125769@ie.u-ryukyu.ac.jp>
parents: 529
diff changeset
76 } else {
4aeebea0c9b5 can't unzip
Nozomi Teruya <e125769@ie.u-ryukyu.ac.jp>
parents: 529
diff changeset
77 lmanager.getDataSegmentKey(msg.key).runCommand(cmd);
4aeebea0c9b5 can't unzip
Nozomi Teruya <e125769@ie.u-ryukyu.ac.jp>
parents: 529
diff changeset
78 }
526
928907206d21 remove CompressedRDSM & CompressedLDSM class
Nozomi Teruya <e125769@ie.u-ryukyu.ac.jp>
parents: 525
diff changeset
79
419
aefbe41fcf12 change tab to space
sugi
parents: 417
diff changeset
80 break;
aefbe41fcf12 change tab to space
sugi
parents: 417
diff changeset
81 case PEEK:
aefbe41fcf12 change tab to space
sugi
parents: 417
diff changeset
82 case TAKE:
531
b6049fb123d8 resolve unzip, working TestRemoteAlice
Nozomi Teruya <e125769@ie.u-ryukyu.ac.jp>
parents: 530
diff changeset
83 System.out.println("in TCP TAKE");
446
a91890dff56e refactor
sugi
parents: 445
diff changeset
84 cmd = new Command(type, null, null, null, msg.index, msg.seq, null, null, connection);
530
4aeebea0c9b5 can't unzip
Nozomi Teruya <e125769@ie.u-ryukyu.ac.jp>
parents: 529
diff changeset
85 cmd.setCompressFlag(msg.compressed);
526
928907206d21 remove CompressedRDSM & CompressedLDSM class
Nozomi Teruya <e125769@ie.u-ryukyu.ac.jp>
parents: 525
diff changeset
86
530
4aeebea0c9b5 can't unzip
Nozomi Teruya <e125769@ie.u-ryukyu.ac.jp>
parents: 529
diff changeset
87 if (msg.compressed){
4aeebea0c9b5 can't unzip
Nozomi Teruya <e125769@ie.u-ryukyu.ac.jp>
parents: 529
diff changeset
88 compressedlmanager.getDataSegmentKey(msg.key).runCommand(cmd);
4aeebea0c9b5 can't unzip
Nozomi Teruya <e125769@ie.u-ryukyu.ac.jp>
parents: 529
diff changeset
89 } else {
4aeebea0c9b5 can't unzip
Nozomi Teruya <e125769@ie.u-ryukyu.ac.jp>
parents: 529
diff changeset
90 lmanager.getDataSegmentKey(msg.key).runCommand(cmd);
4aeebea0c9b5 can't unzip
Nozomi Teruya <e125769@ie.u-ryukyu.ac.jp>
parents: 529
diff changeset
91 }
526
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, "");
530
4aeebea0c9b5 can't unzip
Nozomi Teruya <e125769@ie.u-ryukyu.ac.jp>
parents: 529
diff changeset
96 lmanager.getDataSegmentKey(msg.key).runCommand(cmd);//ToDo:fix
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:
531
b6049fb123d8 resolve unzip, working TestRemoteAlice
Nozomi Teruya <e125769@ie.u-ryukyu.ac.jp>
parents: 530
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
531
b6049fb123d8 resolve unzip, working TestRemoteAlice
Nozomi Teruya <e125769@ie.u-ryukyu.ac.jp>
parents: 530
diff changeset
102 rData = new ReceiveData(packer.read(unpacker.getSerializedByteArray(unpacker.readInt()), byte[].class), msg.compressed, msg.dataSize);
526
928907206d21 remove CompressedRDSM & CompressedLDSM class
Nozomi Teruya <e125769@ie.u-ryukyu.ac.jp>
parents: 525
diff changeset
103
467
6e304a7a60e7 remove white space
sugi
parents: 459
diff changeset
104 Command rCmd = new Command(type, null, null, rData, msg.index, msg.seq, null, null, "");
530
4aeebea0c9b5 can't unzip
Nozomi Teruya <e125769@ie.u-ryukyu.ac.jp>
parents: 529
diff changeset
105 cmd.setCompressFlag(msg.compressed);
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 }