Mercurial > hg > Papers > 2015 > nozomi-sigos
view paper/source/IncomingTcpConnection.java @ 23:7de82f13512b default tip
last update
author | Nozomi Teruya <e125769@ie.u-ryukyu.ac.jp> |
---|---|
date | Wed, 08 Jul 2015 17:34:13 +0900 |
parents | 0127effb8fcd |
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;