hbase-commits mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From t...@apache.org
Subject svn commit: r956766 - in /hbase/trunk: ./ src/main/java/org/apache/hadoop/hbase/ src/main/java/org/apache/hadoop/hbase/master/ src/main/java/org/apache/hadoop/hbase/regionserver/
Date Tue, 22 Jun 2010 03:57:13 GMT
Author: todd
Date: Tue Jun 22 03:57:12 2010
New Revision: 956766

URL: http://svn.apache.org/viewvc?rev=956766&view=rev
Log:
HBASE-2764. Force all Chore tasks to have a thread name

Modified:
    hbase/trunk/CHANGES.txt
    hbase/trunk/src/main/java/org/apache/hadoop/hbase/Chore.java
    hbase/trunk/src/main/java/org/apache/hadoop/hbase/master/BaseScanner.java
    hbase/trunk/src/main/java/org/apache/hadoop/hbase/master/OldLogsCleaner.java
    hbase/trunk/src/main/java/org/apache/hadoop/hbase/master/ServerManager.java
    hbase/trunk/src/main/java/org/apache/hadoop/hbase/regionserver/HRegionServer.java

Modified: hbase/trunk/CHANGES.txt
URL: http://svn.apache.org/viewvc/hbase/trunk/CHANGES.txt?rev=956766&r1=956765&r2=956766&view=diff
==============================================================================
--- hbase/trunk/CHANGES.txt (original)
+++ hbase/trunk/CHANGES.txt Tue Jun 22 03:57:12 2010
@@ -719,6 +719,7 @@ Release 0.21.0 - Unreleased
    HBASE-2735  Make HBASE-2694 replication-friendly
    HBASE-2683  Make it obvious in the documentation that ZooKeeper needs 
                permanent storage
+   HBASE-2764  Force all Chore tasks to have a thread name
 
   NEW FEATURES
    HBASE-1961  HBase EC2 scripts

Modified: hbase/trunk/src/main/java/org/apache/hadoop/hbase/Chore.java
URL: http://svn.apache.org/viewvc/hbase/trunk/src/main/java/org/apache/hadoop/hbase/Chore.java?rev=956766&r1=956765&r2=956766&view=diff
==============================================================================
--- hbase/trunk/src/main/java/org/apache/hadoop/hbase/Chore.java (original)
+++ hbase/trunk/src/main/java/org/apache/hadoop/hbase/Chore.java Tue Jun 22 03:57:12 2010
@@ -46,8 +46,8 @@ public abstract class Chore extends Thre
    * @param s When this flag is set to true, this thread will cleanup and exit
    * cleanly.
    */
-  public Chore(final int p, final AtomicBoolean s) {
-    super();
+  public Chore(String name, final int p, final AtomicBoolean s) {
+    super(name);
     this.sleeper = new Sleeper(p, s);
     this.stop = s;
   }

Modified: hbase/trunk/src/main/java/org/apache/hadoop/hbase/master/BaseScanner.java
URL: http://svn.apache.org/viewvc/hbase/trunk/src/main/java/org/apache/hadoop/hbase/master/BaseScanner.java?rev=956766&r1=956765&r2=956766&view=diff
==============================================================================
--- hbase/trunk/src/main/java/org/apache/hadoop/hbase/master/BaseScanner.java (original)
+++ hbase/trunk/src/main/java/org/apache/hadoop/hbase/master/BaseScanner.java Tue Jun 22 03:57:12
2010
@@ -132,7 +132,8 @@ abstract class BaseScanner extends Chore
 
   BaseScanner(final HMaster master, final boolean rootRegion,
       final AtomicBoolean stop) {
-    super(master.getConfiguration().
+    super("Scanner for " + (rootRegion ? "-ROOT-":".META.") + " table",
+        master.getConfiguration().
         getInt("hbase.master.meta.thread.rescanfrequency", 60 * 1000), stop);
     this.rootRegion = rootRegion;
     this.master = master;

Modified: hbase/trunk/src/main/java/org/apache/hadoop/hbase/master/OldLogsCleaner.java
URL: http://svn.apache.org/viewvc/hbase/trunk/src/main/java/org/apache/hadoop/hbase/master/OldLogsCleaner.java?rev=956766&r1=956765&r2=956766&view=diff
==============================================================================
--- hbase/trunk/src/main/java/org/apache/hadoop/hbase/master/OldLogsCleaner.java (original)
+++ hbase/trunk/src/main/java/org/apache/hadoop/hbase/master/OldLogsCleaner.java Tue Jun 22
03:57:12 2010
@@ -61,7 +61,7 @@ public class OldLogsCleaner extends Chor
   public OldLogsCleaner(final int p, final AtomicBoolean s,
                         Configuration conf, FileSystem fs,
                         Path oldLogDir) {
-    super(p, s);
+    super("OldLogsCleaner", p, s);
     this.maxDeletedLogs =
         conf.getInt("hbase.master.logcleaner.maxdeletedlogs", 20);
     this.fs = fs;

Modified: hbase/trunk/src/main/java/org/apache/hadoop/hbase/master/ServerManager.java
URL: http://svn.apache.org/viewvc/hbase/trunk/src/main/java/org/apache/hadoop/hbase/master/ServerManager.java?rev=956766&r1=956765&r2=956766&view=diff
==============================================================================
--- hbase/trunk/src/main/java/org/apache/hadoop/hbase/master/ServerManager.java (original)
+++ hbase/trunk/src/main/java/org/apache/hadoop/hbase/master/ServerManager.java Tue Jun 22
03:57:12 2010
@@ -104,7 +104,7 @@ public class ServerManager {
    */
   class ServerMonitor extends Chore {
     ServerMonitor(final int period, final AtomicBoolean stop) {
-      super(period, stop);
+      super("ServerMonitor", period, stop);
     }
 
     @Override

Modified: hbase/trunk/src/main/java/org/apache/hadoop/hbase/regionserver/HRegionServer.java
URL: http://svn.apache.org/viewvc/hbase/trunk/src/main/java/org/apache/hadoop/hbase/regionserver/HRegionServer.java?rev=956766&r1=956765&r2=956766&view=diff
==============================================================================
--- hbase/trunk/src/main/java/org/apache/hadoop/hbase/regionserver/HRegionServer.java (original)
+++ hbase/trunk/src/main/java/org/apache/hadoop/hbase/regionserver/HRegionServer.java Tue
Jun 22 03:57:12 2010
@@ -869,7 +869,7 @@ public class HRegionServer implements HR
 
     MajorCompactionChecker(final HRegionServer h,
         final int sleepTime, final AtomicBoolean stopper) {
-      super(sleepTime, stopper);
+      super("MajorCompactionChecker", sleepTime, stopper);
       this.instance = h;
       LOG.info("Runs every " + sleepTime + "ms");
     }



Mime
View raw message