# HG changeset patch # User sugi # Date 1364755262 -32400 # Node ID 2a019206c2f0061d2c9e728249776ae870986aa3 # Parent ca1c9c477f5471e43072aa6447d44b2491e7d046 remove SEDA from local diff -r ca1c9c477f54 -r 2a019206c2f0 src/alice/datasegment/LocalDataSegmentManager.java --- 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()); }