Mercurial > hg > Database > Alice
diff src/main/java/alice/daemon/IncomingTcpConnection.java @ 600:0564f38e9bfe dispose
change allow using ids only peek from Normal Code Segment
| author | Nozomi Teruya <e125769@ie.u-ryukyu.ac.jp> |
|---|---|
| date | Tue, 16 Feb 2016 19:12:52 +0900 |
| parents | 3284428f525e |
| children |
line wrap: on
line diff
--- a/src/main/java/alice/daemon/IncomingTcpConnection.java Mon Feb 15 01:16:35 2016 +0900 +++ b/src/main/java/alice/daemon/IncomingTcpConnection.java Tue Feb 16 19:12:52 2016 +0900 @@ -77,19 +77,7 @@ cmd = new Command(type, null, null, rData, 0, 0, null, null, reverseKey); cmd.setCompressFlag(msg.compressed); - if (msg.meta){ - if (msg.compressed){ - compressedmetalmanager.getDataSegmentKey(msg.key).runCommand(cmd); - } else { - metalmanager.getDataSegmentKey(msg.key).runCommand(cmd); - } - } else { - if (msg.compressed){ - compressedlmanager.getDataSegmentKey(msg.key).runCommand(cmd); - } else { - lmanager.getDataSegmentKey(msg.key).runCommand(cmd); - } - } + runCommand(msg, cmd); break; case PEEK: @@ -97,19 +85,7 @@ cmd = new Command(type, null, null, null, msg.index, msg.seq, null, null, connection); cmd.setCompressFlag(msg.compressed); - if (msg.meta){ - if (msg.compressed){ - compressedmetalmanager.getDataSegmentKey(msg.key).runCommand(cmd); - } else { - metalmanager.getDataSegmentKey(msg.key).runCommand(cmd); - } - } else { - if (msg.compressed){ - compressedlmanager.getDataSegmentKey(msg.key).runCommand(cmd); - } else { - lmanager.getDataSegmentKey(msg.key).runCommand(cmd); - } - } + runCommand(msg, cmd); break; case REMOVE: @@ -146,6 +122,22 @@ } } + private void runCommand(CommandMessage msg, Command cmd) { + if (msg.meta){ + if (msg.compressed){ + compressedmetalmanager.getDataSegmentKey(msg.key).runCommand(cmd); + } else { + metalmanager.getDataSegmentKey(msg.key).runCommand(cmd); + } + } else { + if (msg.compressed){ + compressedlmanager.getDataSegmentKey(msg.key).runCommand(cmd); + } else { + lmanager.getDataSegmentKey(msg.key).runCommand(cmd); + } + } + } + public void setReverseKey(String name) { this.reverseKey = name; setName(name+"-IncomingTcp");