Mercurial > hg > Database > Alice
diff src/alice/datasegment/RemoteDataSegmentManager.java @ 254:2ec10cfa8cc3
refactor
author | sugi |
---|---|
date | Mon, 01 Jul 2013 20:00:07 +0900 |
parents | 32e7d5271477 |
children | b4690114a0cd |
line wrap: on
line diff
--- a/src/alice/datasegment/RemoteDataSegmentManager.java Tue Jun 18 17:14:20 2013 +0900 +++ b/src/alice/datasegment/RemoteDataSegmentManager.java Mon Jul 01 20:00:07 2013 +0900 @@ -83,9 +83,9 @@ } @Override - public void take(Receiver receiver, String key, int index, CodeSegment cs) { + public void take(Receiver receiver, CodeSegment cs) { int seq = this.seq.getAndIncrement(); - Command cmd = new Command(CommandType.TAKE, receiver, key, null, index, seq, replyQueue, cs, null); + Command cmd = new Command(CommandType.TAKE, receiver, receiver.key, null, receiver.index, seq, replyQueue, cs, null); seqHash.put(seq, cmd); connection.sendCommand(cmd); if (logger.isDebugEnabled()) @@ -93,9 +93,9 @@ } @Override - public void quickTake(Receiver receiver, String key, int index, CodeSegment cs) { + public void quickTake(Receiver receiver, CodeSegment cs) { int seq = this.seq.getAndIncrement(); - Command cmd = new Command(CommandType.TAKE, receiver, key, null, index, seq, replyQueue, cs, null, true); + Command cmd = new Command(CommandType.TAKE, receiver, receiver.key, null, receiver.index, seq, replyQueue, cs, null, true); seqHash.put(seq, cmd); connection.write(cmd); if (logger.isDebugEnabled()) @@ -103,9 +103,9 @@ } @Override - public void peek(Receiver receiver, String key, int index, CodeSegment cs) { + public void peek(Receiver receiver, CodeSegment cs) { int seq = this.seq.getAndIncrement(); - Command cmd = new Command(CommandType.PEEK, receiver, key, null, index, seq, replyQueue, cs, null); + Command cmd = new Command(CommandType.PEEK, receiver, receiver.key, null, receiver.index, seq, replyQueue, cs, null); seqHash.put(seq, cmd); connection.sendCommand(cmd); if (logger.isDebugEnabled()) @@ -114,9 +114,9 @@ @Override - public void quickPeek(Receiver receiver, String key, int index, CodeSegment cs) { + public void quickPeek(Receiver receiver, CodeSegment cs) { int seq = this.seq.getAndIncrement(); - Command cmd = new Command(CommandType.PEEK, receiver, key, null, index, seq, replyQueue, cs, null, true); + Command cmd = new Command(CommandType.PEEK, receiver, receiver.key, null, receiver.index, seq, replyQueue, cs, null, true); seqHash.put(seq, cmd); connection.write(cmd); if (logger.isDebugEnabled())