Mercurial > hg > Members > tatsuki > Alice
diff src/alice/daemon/IncomingTcpConnection.java @ 73:4bfd81352cfa
change to concurrent data segment
| author | kazz <kazz@cr.ie.u-ryukyu.ac.jp> |
|---|---|
| date | Tue, 21 Feb 2012 22:55:17 +0900 |
| parents | 1d4f2b72fb31 |
| children | 409d7679cf7b |
line wrap: on
line diff
--- a/src/alice/daemon/IncomingTcpConnection.java Tue Feb 21 21:11:50 2012 +0900 +++ b/src/alice/daemon/IncomingTcpConnection.java Tue Feb 21 22:55:17 2012 +0900 @@ -44,23 +44,23 @@ CommandType type = CommandType.getCommandTypeFromId(msg.type); switch (type) { case UPDATE: - lmanager.addCommand(getDataSegmentKey(msg), + lmanager.submitCommand(getDataSegmentKey(msg), new Command(type, null, null, msg.val, 0, 0, null, null, reverseKey)); break; case PUT: - lmanager.addCommand(getDataSegmentKey(msg), + lmanager.submitCommand(getDataSegmentKey(msg), new Command(type, null, null, msg.val, 0, 0, null, null, reverseKey)); break; case PEEK: - lmanager.addCommand(getDataSegmentKey(msg), + lmanager.submitCommand(getDataSegmentKey(msg), new Command(type, null, null, null, msg.index, msg.seq, connection.sendQueue, null, null)); break; case TAKE: - lmanager.addCommand(getDataSegmentKey(msg), + lmanager.submitCommand(getDataSegmentKey(msg), new Command(type, null, null, null, msg.index, msg.seq, connection.sendQueue, null, null)); break; case REMOVE: - lmanager.addCommand(getDataSegmentKey(msg), + lmanager.submitCommand(getDataSegmentKey(msg), new Command(type, null, null, null, 0, 0, null, null, null)); break; case REPLY: