Mercurial > hg > Database > Alice

comparison src/main/java/alice/daemon/IncomingTcpConnection.java @ 627:f5365a5e6672 dispose

Find changesets by keywords (author, files, the commit message), revision number or hash, or revset expression.
don't use unpacker
author nozomi
date Thu, 14 Sep 2017 18:00:15 +0900
parents 4835788cbb7e
children 71dfb0051be0
comparison
equal deleted inserted replaced
626:0960dd991266 627:f5365a5e6672
58 CommandType type = CommandType.getCommandTypeFromId(msg.type); 58 CommandType type = CommandType.getCommandTypeFromId(msg.type);
59 switch (type) { 59 switch (type) {
60 case UPDATE: 60 case UPDATE:
61 case PUT: 61 case PUT:
62 int dataSize = unpacker.readInt(); 62 int dataSize = unpacker.readInt();
63 //byte[] data = unpacker.getSerializedByteArray(dataSize);
64 byte[] data = new byte[dataSize];
65 connection.socket.getInputStream().read(data);
66 rData = new ReceiveData(data, msg.compressed, msg.dataSize);
63 67
64 rData = new ReceiveData(unpacker.getSerializedByteArray(dataSize), msg.compressed, msg.dataSize);
65 /* 68 /*
66 rData = new ReceiveData(new byte[dataSize], msg.compressed, msg.dataSize); 69 rData = new ReceiveData(new byte[dataSize], msg.compressed, msg.dataSize);
67 try { 70 try {
68 unpacker.readPayload(rData.getMessagePack()); 71 unpacker.readPayload(rData.getMessagePack());
69 } catch ( ); 72 } catch ( );