# HG changeset patch # User Shinji KONO # Date 1505387088 -32400 # Node ID d0d1cd3dfc11f83f071f85fefe2700253d4f919b # Parent 71dfb0051be098ae9b81645ca97c4040b88fe00f fix UDP conection diff -r 71dfb0051be0 -r d0d1cd3dfc11 src/main/java/alice/daemon/IncomingUdpConnection.java --- a/src/main/java/alice/daemon/IncomingUdpConnection.java Thu Sep 14 19:01:18 2017 +0900 +++ b/src/main/java/alice/daemon/IncomingUdpConnection.java Thu Sep 14 20:04:48 2017 +0900 @@ -44,10 +44,13 @@ receive.flip(); CommandMessage msg = unpacker.read(CommandMessage.class); CommandType type = CommandType.getCommandTypeFromId(msg.type); + int dataSize = unpacker.readInt(); + byte [] data = new byte[dataSize]; switch (type) { case UPDATE: case PUT: - rData = new ReceiveData(unpacker.getSerializedByteArray(unpacker.readInt())); + receive.get(data); + rData = new ReceiveData(data); cmd = new Command(type, null, null, rData, 0, 0, null, null, reverseKey); if (msg.compressed){ @@ -74,8 +77,8 @@ break; case REPLY: cmd = manager.getAndRemoveCmd(msg.seq); - - rData = new ReceiveData(unpacker.getSerializedByteArray(unpacker.readInt())); + receive.get(data); + rData = new ReceiveData(data); Command rCmd = new Command(type, null, null, rData, msg.index, msg.seq, null, null, ""); cmd.cs.ids.reply(cmd.receiver, rCmd);