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())