Mercurial > hg > Database > Alice

comparison src/alice/datasegment/DataSegmentManager.java @ 71:a3a2605e16a2

Find changesets by keywords (author, files, the commit message), revision number or hash, or revset expression.
change checking debug mode of logger
author kazz <kazz@cr.ie.u-ryukyu.ac.jp>
date Tue, 21 Feb 2012 21:10:15 +0900
parents 1d4f2b72fb31
children 1044a79ce4ef
comparison
equal deleted inserted replaced
70:f2d4a4686036 71:a3a2605e16a2
12 public abstract class DataSegmentManager { 12 public abstract class DataSegmentManager {
13 13
14 protected ConcurrentHashMap<Integer, Command> seqHash = new ConcurrentHashMap<Integer, Command>(); 14 protected ConcurrentHashMap<Integer, Command> seqHash = new ConcurrentHashMap<Integer, Command>();
15 protected LinkedBlockingQueue<Command> replyQueue = new LinkedBlockingQueue<Command>(); 15 protected LinkedBlockingQueue<Command> replyQueue = new LinkedBlockingQueue<Command>();
16 protected AtomicInteger seq = new AtomicInteger(1); 16 protected AtomicInteger seq = new AtomicInteger(1);
17 boolean debug = false;
18 17
19 protected Runnable replyThread = new Runnable() { 18 protected Runnable replyThread = new Runnable() {
20 Logger logger = Logger.getLogger("reply"); 19 Logger logger = Logger.getLogger("reply");
21 @Override 20 @Override
22 public void run() { 21 public void run() {
28 logger.warn("conflict sequence number"); 27 logger.warn("conflict sequence number");
29 continue; 28 continue;
30 } 29 }
31 seqHash.remove(reply.seq); 30 seqHash.remove(reply.seq);
32 cmd.cs.ids.reply(cmd.receiver, new DataSegmentValue(reply.index, reply.val, reply.reverseKey)); 31 cmd.cs.ids.reply(cmd.receiver, new DataSegmentValue(reply.index, reply.val, reply.reverseKey));
33 if (debug) 32 if (logger.isDebugEnabled())
34 logger.debug(reply.getCommandString() + " " + cmd.getCommandString()); 33 logger.debug(reply.getCommandString() + " " + cmd.getCommandString());
35 } catch (InterruptedException e) { 34 } catch (InterruptedException e) {
36 e.printStackTrace(); 35 e.printStackTrace();
37 } 36 }
38 } 37 }