Mercurial > hg > Papers > 2016 > nozomi-thesis

annotate paper/source/IncomingTcpConnection.java @ 3:a97aa059242f

Find changesets by keywords (author, files, the commit message), revision number or hash, or revset expression.
add images & sources
author Nozomi Teruya <e125769@ie.u-ryukyu.ac.jp>
date Fri, 05 Feb 2016 21:00:41 +0900
parents
children
Ignore whitespace changes - Everywhere: Within whitespace: At end of lines:
rev   line source
3
a97aa059242f add images & sources
Nozomi Teruya <e125769@ie.u-ryukyu.ac.jp>
parents:
diff changeset
1 while (true) {
a97aa059242f add images & sources
Nozomi Teruya <e125769@ie.u-ryukyu.ac.jp>
parents:
diff changeset
2 Command cmd = null;
a97aa059242f add images & sources
Nozomi Teruya <e125769@ie.u-ryukyu.ac.jp>
parents:
diff changeset
3 ReceiveData rData = null;
a97aa059242f add images & sources
Nozomi Teruya <e125769@ie.u-ryukyu.ac.jp>
parents:
diff changeset
4 CommandMessage msg = unpacker.read(CommandMessage.class);
a97aa059242f add images & sources
Nozomi Teruya <e125769@ie.u-ryukyu.ac.jp>
parents:
diff changeset
5 CommandType type = CommandType.getCommandTypeFromId(msg.type);
a97aa059242f add images & sources
Nozomi Teruya <e125769@ie.u-ryukyu.ac.jp>
parents:
diff changeset
6 switch (type) {
a97aa059242f add images & sources
Nozomi Teruya <e125769@ie.u-ryukyu.ac.jp>
parents:
diff changeset
7 case UPDATE:
a97aa059242f add images & sources
Nozomi Teruya <e125769@ie.u-ryukyu.ac.jp>
parents:
diff changeset
8 case PUT:
a97aa059242f add images & sources
Nozomi Teruya <e125769@ie.u-ryukyu.ac.jp>
parents:
diff changeset
9 int dataSize = unpacker.readInt();
a97aa059242f add images & sources
Nozomi Teruya <e125769@ie.u-ryukyu.ac.jp>
parents:
diff changeset
10 rData = new ReceiveData(unpacker.getSerializedByteArray(dataSize), msg.compressed, msg.serialized);
a97aa059242f add images & sources
Nozomi Teruya <e125769@ie.u-ryukyu.ac.jp>
parents:
diff changeset
11 cmd = new Command(type, null, null, rData, 0, 0, null, null, reverseKey);
a97aa059242f add images & sources
Nozomi Teruya <e125769@ie.u-ryukyu.ac.jp>
parents:
diff changeset
12 lmanager.getDataSegmentKey(msg.key).runCommand(cmd);
a97aa059242f add images & sources
Nozomi Teruya <e125769@ie.u-ryukyu.ac.jp>
parents:
diff changeset
13 break;