Mercurial > hg > Members > tatsuki > Alice
diff src/alice/datasegment/DataSegmentKey.java @ 14:e3f1b21718b0
implements RemoteDataSegment
| author | kazz <kazz@cr.ie.u-ryukyu.ac.jp> |
|---|---|
| date | Sun, 15 Jan 2012 00:56:25 +0900 |
| parents | 30f97d776a3e |
| children | bb075e103cd3 |
line wrap: on
line diff
--- a/src/alice/datasegment/DataSegmentKey.java Fri Jan 13 19:04:59 2012 +0900 +++ b/src/alice/datasegment/DataSegmentKey.java Sun Jan 15 00:56:25 2012 +0900 @@ -43,7 +43,7 @@ LinkedList<Command> removeList = new LinkedList<Command>(); for (Command waitCmd : waitList) { if (waitCmd.index < index) { - waitCmd.replyQueue.put(new Command(CommandType.REPLY, null, cmd.val, index, waitCmd.seq, null, null)); + waitCmd.replyQueue.put(new Command(CommandType.REPLY, null, null, cmd.val, index, waitCmd.seq, null, null)); removeList.add(waitCmd); if (waitCmd.type == CommandType.TAKE) { // delete data, if it run take cmd. dataList.remove(dsv); @@ -62,7 +62,7 @@ } for (DataSegmentValue data : dataList) { if (data.index > cmd.index) { - cmd.replyQueue.put(new Command(CommandType.REPLY, null, data.val, data.index, cmd.seq, null, null)); + cmd.replyQueue.put(new Command(CommandType.REPLY, null, null, data.val, data.index, cmd.seq, null, null)); break; } } @@ -75,7 +75,7 @@ } for (DataSegmentValue data : dataList) { if (data.index > cmd.index) { - cmd.replyQueue.put(new Command(CommandType.REPLY, null, data.val, data.index, cmd.seq, null, null)); + cmd.replyQueue.put(new Command(CommandType.REPLY, null, null, data.val, data.index, cmd.seq, null, null)); dataList.remove(data); break; }