Mercurial > hg > Database > Alice

changeset 66:3c5c567c47d7

Find changesets by keywords (author, files, the commit message), revision number or hash, or revset expression.
logger off for experiment
author kazz
date Thu, 09 Feb 2012 22:32:15 +0900
parents ca42a2c8ac22
children 2afbb6404840
files src/alice/codesegment/OutputDataSegment.java src/alice/datasegment/LocalDataSegmentManager.java src/alice/datasegment/RemoteDataSegmentManager.java
diffstat 3 files changed, 13 insertions(+), 13 deletions(-) [+]
line wrap: on
line diff
--- a/src/alice/codesegment/OutputDataSegment.java	Thu Feb 09 19:33:46 2012 +0900
+++ b/src/alice/codesegment/OutputDataSegment.java	Thu Feb 09 22:32:15 2012 +0900
@@ -33,11 +33,11 @@
 	}
 
 	public void put(String managerKey, String key, byte[] val) {
-		DataSegment.get(managerKey).put(key, ValueFactory.createRawValue(val), cs);
+		DataSegment.get(managerKey).put(key, ValueFactory.createRawValue(val, true), cs);
 	}
 	
 	public void update(String managerKey, String key, byte[] val) {
-		DataSegment.get(managerKey).update(key, ValueFactory.createRawValue(val), cs);
+		DataSegment.get(managerKey).update(key, ValueFactory.createRawValue(val, true), cs);
 	}
 	
 	public void put(String managerKey, String key, int val) {
--- a/src/alice/datasegment/LocalDataSegmentManager.java	Thu Feb 09 19:33:46 2012 +0900
+++ b/src/alice/datasegment/LocalDataSegmentManager.java	Thu Feb 09 22:32:15 2012 +0900
@@ -12,7 +12,7 @@
 	private String reverseKey = "local";
 	private ConcurrentHashMap<String, DataSegmentKey> dataSegments = new ConcurrentHashMap<String, DataSegmentKey>();
 	
-	private Logger logger = Logger.getLogger("local");
+//	private Logger logger = Logger.getLogger("local");
 	
 	public LocalDataSegmentManager() {
 		new Thread(replyThread, "LocalDataSegmentManager").start();
@@ -38,7 +38,7 @@
 		DataSegmentKey dataSegmentKey = getDataSegmentKey(key);
 		Command cmd = new Command(CommandType.PUT, null, key, val, 0, 0, replyQueue, cs, reverseKey);
 		dataSegmentKey.addCommand(cmd);
-		logger.debug(cmd.getCommandString());
+//		logger.debug(cmd.getCommandString());
 	}
 	
 	
@@ -50,7 +50,7 @@
 		DataSegmentKey dataSegmentKey = getDataSegmentKey(key);
 		Command cmd = new Command(CommandType.UPDATE, null, key, val, 0, 0, replyQueue, cs, reverseKey);
 		dataSegmentKey.addCommand(cmd);
-		logger.debug(cmd.getCommandString());
+//		logger.debug(cmd.getCommandString());
 	}
 
 	@Override
@@ -60,7 +60,7 @@
 		Command cmd = new Command(CommandType.TAKE, receiver, key, null, index, seq, replyQueue, cs, null);
 		seqHash.put(seq, cmd);
 		dataSegmentKey.addCommand(cmd);
-		logger.debug(cmd.getCommandString());
+//		logger.debug(cmd.getCommandString());
 	}
 
 	@Override
@@ -70,7 +70,7 @@
 		Command cmd = new Command(CommandType.PEEK, receiver, key, null, index, seq, replyQueue, cs, null);
 		seqHash.put(seq, cmd); // waiting for PUT or UPDATE at unique sequence number
 		dataSegmentKey.addCommand(cmd);
-		logger.debug(cmd.getCommandString());
+//		logger.debug(cmd.getCommandString());
 	}
 
 	@Override
@@ -78,7 +78,7 @@
 		DataSegmentKey dataSegmentKey = getDataSegmentKey(key);
 		Command cmd = new Command(CommandType.REMOVE, null, key, null, 0, 0, replyQueue, null, null);
 		dataSegmentKey.addCommand(cmd);
-		logger.debug(cmd.getCommandString());
+//		logger.debug(cmd.getCommandString());
 	}
 	
 	@Override public void finish() {
--- a/src/alice/datasegment/RemoteDataSegmentManager.java	Thu Feb 09 19:33:46 2012 +0900
+++ b/src/alice/datasegment/RemoteDataSegmentManager.java	Thu Feb 09 22:32:15 2012 +0900
@@ -53,14 +53,14 @@
 	public void put(String key, Value val, CodeSegment cs) {
 		Command cmd = new Command(CommandType.PUT, null, key, val, 0, 0, null, cs, null);
 		connection.sendCommand(cmd); // put command on the transmission thread
-		logger.debug(cmd.getCommandString());
+//		logger.debug(cmd.getCommandString());
 	}
 
 	@Override
 	public void update(String key, Value val, CodeSegment cs) {
 		Command cmd = new Command(CommandType.UPDATE, null, key, val, 0, 0, null, cs, null);
 		connection.sendCommand(cmd);
-		logger.debug(cmd.getCommandString());
+//		logger.debug(cmd.getCommandString());
 	}
 
 	@Override
@@ -69,7 +69,7 @@
 		Command cmd = new Command(CommandType.TAKE, receiver, key, null, index, seq, replyQueue, cs, null);
 		seqHash.put(seq, cmd);
 		connection.sendCommand(cmd);
-		logger.debug(cmd.getCommandString());
+//		logger.debug(cmd.getCommandString());
 	}
 
 	@Override
@@ -78,14 +78,14 @@
 		Command cmd = new Command(CommandType.PEEK, receiver, key, null, index, seq, replyQueue, cs, null);
 		seqHash.put(seq, cmd);
 		connection.sendCommand(cmd);
-		logger.debug(cmd.getCommandString());
+//		logger.debug(cmd.getCommandString());
 	}
 
 	@Override
 	public void remove(String key) {
 		Command cmd = new Command(CommandType.REMOVE, null, key, null, 0, 0, null, null, null);
 		connection.sendCommand(cmd);
-		logger.debug(cmd.getCommandString());
+//		logger.debug(cmd.getCommandString());
 	}
 
 	@Override