Mercurial > hg > Database > Alice

comparison src/main/java/alice/daemon/IncomingTcpConnection.java @ 488:7ef0ebb40c9b dispose

Find changesets by keywords (author, files, the commit message), revision number or hash, or revset expression.
add measurement data in protocol
author sugi
date Mon, 08 Dec 2014 23:11:26 +0900
parents c06070403ed4
children 118e150ac9f3
comparison
equal deleted inserted replaced
487:c1cf44777eef 488:7ef0ebb40c9b
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 rData = new ReceiveData(getSerializedByteArray(unpacker), msg.compressed, msg.serialized); 62 rData = new ReceiveData(getSerializedByteArray(unpacker), msg.compressed, msg.serialized);
63 if (msg.setTime) {
64 rData.setTime = true;
65 rData.time = msg.time;
66 rData.depth = msg.depth;
67 }
63 cmd = new Command(type, null, null, rData, 0, 0, null, null, reverseKey); 68 cmd = new Command(type, null, null, rData, 0, 0, null, null, reverseKey);
64 lmanager.getDataSegmentKey(msg.key).runCommand(cmd); 69 lmanager.getDataSegmentKey(msg.key).runCommand(cmd);
65 break; 70 break;
66 case PEEK: 71 case PEEK:
67 case TAKE: 72 case TAKE: