Mercurial > hg > Members > tatsuki > Alice

changeset 237:2a019206c2f0

Find changesets by keywords (author, files, the commit message), revision number or hash, or revset expression.
remove SEDA from local
author sugi
date Mon, 01 Apr 2013 03:41:02 +0900
parents ca1c9c477f54
children e4a5da56b394
files src/alice/datasegment/LocalDataSegmentManager.java
diffstat 1 files changed, 14 insertions(+), 7 deletions(-) [+]
line wrap: on
line diff
--- a/src/alice/datasegment/LocalDataSegmentManager.java	Sat Mar 30 18:39:45 2013 +0900
+++ b/src/alice/datasegment/LocalDataSegmentManager.java	Mon Apr 01 03:41:02 2013 +0900
@@ -65,7 +65,8 @@
 	public void put(String key, Value val) {
 		DataSegmentKey dataSegmentKey = getDataSegmentKey(key);
 		Command cmd = new Command(CommandType.PUT, null, key, val, 0, 0, null, null, reverseKey);
-		submitCommand(dataSegmentKey, cmd);
+		//submitCommand(dataSegmentKey, cmd);
+		dataSegmentKey.runCommand(cmd);
 		if (logger.isDebugEnabled())
 			logger.debug(cmd.getCommandString());
 	}
@@ -73,7 +74,8 @@
 	public void putObject(String key, Object obj) {
 		DataSegmentKey dataSegmentKey = getDataSegmentKey(key);
 		Command cmd = new Command(CommandType.PUT, null, key, obj, 0, 0, null, null, reverseKey);
-		submitCommand(dataSegmentKey, cmd);
+		dataSegmentKey.runCommand(cmd);
+		//submitCommand(dataSegmentKey, cmd);
 		if (logger.isDebugEnabled())
 			logger.debug(cmd.getCommandString());
 	}
@@ -85,7 +87,8 @@
 	public void update(String key, Value val) {
 		DataSegmentKey dataSegmentKey = getDataSegmentKey(key);
 		Command cmd = new Command(CommandType.UPDATE, null, key, val, 0, 0, null, null, reverseKey);
-		submitCommand(dataSegmentKey, cmd);
+		dataSegmentKey.runCommand(cmd);
+		//submitCommand(dataSegmentKey, cmd);
 		if (logger.isDebugEnabled())
 			logger.debug(cmd.getCommandString());
 	}
@@ -93,7 +96,8 @@
 	public void updateObject(String key, Object val) {
 		DataSegmentKey dataSegmentKey = getDataSegmentKey(key);
 		Command cmd = new Command(CommandType.UPDATE, null, key, val, 0, 0, null, null, reverseKey);
-		submitCommand(dataSegmentKey, cmd);
+		dataSegmentKey.runCommand(cmd);
+		//submitCommand(dataSegmentKey, cmd);
 		if (logger.isDebugEnabled())
 			logger.debug(cmd.getCommandString());
 	}
@@ -103,7 +107,8 @@
 		DataSegmentKey dataSegmentKey = getDataSegmentKey(key);
 		int seq = this.seq.getAndIncrement();
 		Command cmd = new Command(CommandType.TAKE, receiver, key, null, index, seq, replyQueue, cs, null);
-		submitCommand(dataSegmentKey, cmd);
+		dataSegmentKey.runCommand(cmd);
+		//submitCommand(dataSegmentKey, cmd);
 		if (logger.isDebugEnabled())
 			logger.debug(cmd.getCommandString());
 	}
@@ -113,7 +118,8 @@
 		DataSegmentKey dataSegmentKey = getDataSegmentKey(key);
 		int seq = this.seq.getAndIncrement();
 		Command cmd = new Command(CommandType.PEEK, receiver, key, null, index, seq, replyQueue, cs, null);
-		submitCommand(dataSegmentKey, cmd);
+		//submitCommand(dataSegmentKey, cmd);
+		dataSegmentKey.runCommand(cmd);
 		if (logger.isDebugEnabled())
 			logger.debug(cmd.getCommandString());
 	}
@@ -122,7 +128,8 @@
 	public void remove(String key) {
 		DataSegmentKey dataSegmentKey = getDataSegmentKey(key);
 		Command cmd = new Command(CommandType.REMOVE, null, key, null, 0, 0, replyQueue, null, null);
-		submitCommand(dataSegmentKey, cmd);
+		//submitCommand(dataSegmentKey, cmd);
+		dataSegmentKey.runCommand(cmd);
 		if (logger.isDebugEnabled())
 			logger.debug(cmd.getCommandString());
 	}