Mercurial > hg > Database > Alice

comparison 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
comparison
equal deleted inserted replaced
526:928907206d21 527:bfec2c3ff1b8
2 2
3 import java.io.EOFException; 3 import java.io.EOFException;
4 import java.io.IOException; 4 import java.io.IOException;
5 import java.nio.channels.ClosedChannelException; 5 import java.nio.channels.ClosedChannelException;
6 6
7 import alice.datasegment.*;
7 import org.msgpack.unpacker.Unpacker; 8 import org.msgpack.unpacker.Unpacker;
8 9
9 import alice.codesegment.SingletonMessage; 10 import alice.codesegment.SingletonMessage;
10 import alice.datasegment.Command;
11 import alice.datasegment.CommandType;
12 import alice.datasegment.DataSegment;
13 import alice.datasegment.DataSegmentManager;
14 import alice.datasegment.LocalDataSegmentManager;
15 import alice.datasegment.ReceiveData;
16 import alice.topology.manager.keeparive.RespondData; 11 import alice.topology.manager.keeparive.RespondData;
17 12
18 public class IncomingTcpConnection extends Thread { 13 public class IncomingTcpConnection extends Thread {
19 14
20 private Connection connection; 15 private Connection connection;
102 break; 97 break;
103 case REPLY: 98 case REPLY:
104 System.out.println("in TCP REPLY"); 99 System.out.println("in TCP REPLY");
105 cmd = manager.getAndRemoveCmd(msg.seq); 100 cmd = manager.getAndRemoveCmd(msg.seq);
106 101
107 rData = new ReceiveData(unpacker.getSerializedByteArray(unpacker.readInt())); 102 rData = new ReceiveData(unpacker.getSerializedByteArray(unpacker.readInt()));//ここのコンストラクタでx
108 rData.setCompressFlag(msg.compressed); 103 rData.setCompressFlag(msg.compressed);
109 104
110 Command rCmd = new Command(type, null, null, rData, msg.index, msg.seq, null, null, ""); 105 Command rCmd = new Command(type, null, null, rData, msg.index, msg.seq, null, null, "");
111 cmd.cs.ids.reply(cmd.receiver, rCmd); 106 cmd.cs.ids.reply(cmd.receiver, rCmd);
112 break; 107 break;
114 if (DataSegment.contains(reverseKey)) 109 if (DataSegment.contains(reverseKey))
115 DataSegment.get(reverseKey).response(msg.key); 110 DataSegment.get(reverseKey).response(msg.key);
116 break; 111 break;
117 case RESPONSE: 112 case RESPONSE:
118 rData = new ReceiveData(new RespondData(reverseKey, System.currentTimeMillis())); 113 rData = new ReceiveData(new RespondData(reverseKey, System.currentTimeMillis()));
119 DataSegment.getLocal().put(msg.key, rData, false); 114 DataSegment.getLocal().put(msg.key, rData, null);
120 break; 115 break;
121 default: 116 default:
122 break; 117 break;
123 } 118 }
124 } catch (ClosedChannelException e) { 119 } catch (ClosedChannelException e) {