view paper/source/IncomingTcpConnection.java @ 149:d57aa814a69a

add source, add chapter2
author Nozomi Teruya <e125769@ie.u-ryukyu.ac.jp>
date Sat, 27 Jan 2018 19:16:38 +0900
parents
children
line wrap: on
line source

while (true) {
    Command cmd = null;
    ReceiveData rData = null;
    CommandMessage msg = unpacker.read(CommandMessage.class);
    CommandType type = CommandType.getCommandTypeFromId(msg.type);
    switch (type) {
    case UPDATE:
    case PUT:
        int dataSize = unpacker.readInt();
        rData = new ReceiveData(unpacker.getSerializedByteArray(dataSize), msg.compressed, msg.serialized);
        cmd = new Command(type, null, null, rData, 0, 0, null, null, reverseKey);
        lmanager.getDataSegmentKey(msg.key).runCommand(cmd);
        break;