accumulo-commits mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From els...@apache.org
Subject [1/3] git commit: ACCUMULO-378 Need to turn on Trace for traces to be logged.
Date Thu, 22 May 2014 22:37:45 GMT
Repository: accumulo
Updated Branches:
  refs/heads/ACCUMULO-378 e798d5008 -> 0f6b6d0fb


ACCUMULO-378 Need to turn on Trace for traces to be logged.


Project: http://git-wip-us.apache.org/repos/asf/accumulo/repo
Commit: http://git-wip-us.apache.org/repos/asf/accumulo/commit/4288bbe4
Tree: http://git-wip-us.apache.org/repos/asf/accumulo/tree/4288bbe4
Diff: http://git-wip-us.apache.org/repos/asf/accumulo/diff/4288bbe4

Branch: refs/heads/ACCUMULO-378
Commit: 4288bbe442394af8512cd0d801dbb98d76d10b46
Parents: e798d50
Author: Josh Elser <elserj@apache.org>
Authored: Thu May 22 17:15:00 2014 -0400
Committer: Josh Elser <elserj@apache.org>
Committed: Thu May 22 17:15:29 2014 -0400

----------------------------------------------------------------------
 .../accumulo/master/replication/ReplicationDriver.java   | 11 +++++++++++
 1 file changed, 11 insertions(+)
----------------------------------------------------------------------


http://git-wip-us.apache.org/repos/asf/accumulo/blob/4288bbe4/server/master/src/main/java/org/apache/accumulo/master/replication/ReplicationDriver.java
----------------------------------------------------------------------
diff --git a/server/master/src/main/java/org/apache/accumulo/master/replication/ReplicationDriver.java
b/server/master/src/main/java/org/apache/accumulo/master/replication/ReplicationDriver.java
index 3069c97..b340009 100644
--- a/server/master/src/main/java/org/apache/accumulo/master/replication/ReplicationDriver.java
+++ b/server/master/src/main/java/org/apache/accumulo/master/replication/ReplicationDriver.java
@@ -24,6 +24,9 @@ import org.apache.accumulo.core.conf.Property;
 import org.apache.accumulo.core.util.Daemon;
 import org.apache.accumulo.fate.util.UtilWaitThread;
 import org.apache.accumulo.master.Master;
+import org.apache.accumulo.trace.instrument.CountSampler;
+import org.apache.accumulo.trace.instrument.Sampler;
+import org.apache.accumulo.trace.instrument.Trace;
 import org.apache.log4j.Logger;
 
 /**
@@ -50,6 +53,8 @@ public class ReplicationDriver extends Daemon {
 
   @Override
   public void run() {
+    Sampler sampler = new CountSampler(10);
+
     while (master.stillMaster()) {
       if (null == workMaker) {
         try {
@@ -67,6 +72,10 @@ public class ReplicationDriver extends Daemon {
         rcrr = new RemoveCompleteReplicationRecords(conn);
       }
 
+      if (sampler.next()) {
+        Trace.on("masterReplicationDriver");
+      }
+
       // Make status markers from replication records in metadata, removing entries in
       // metadata which are no longer needed (closed records)
       // This will end up creating the replication table too
@@ -83,6 +92,8 @@ public class ReplicationDriver extends Daemon {
       // So it's important that we run these sequentially and not concurrently
       rcrr.run();
 
+      Trace.offNoFlush();
+
       // Sleep for a bit
       UtilWaitThread.sleep(conf.getTimeInMillis(Property.MASTER_REPLICATION_SCAN_INTERVAL));
     }


Mime
View raw message