svn commit: r1569371 - /hbase/branches/0.96/hbase-server/src/main/java/org/apache/hadoop/hbase/regionserver/MemStoreFlusher.java

[mbertozzi]

Author: mbertozzi
Date: Tue Feb 18 15:00:27 2014
New Revision: 1569371

URL: http://svn.apache.org/r1569371
Log:
HBASE-10563 Set name for FlushHandler thread (Himanshu Vashishtha)

Modified:
    
hbase/branches/0.96/hbase-server/src/main/java/org/apache/hadoop/hbase/regionserver/MemStoreFlusher.java

Modified: 
hbase/branches/0.96/hbase-server/src/main/java/org/apache/hadoop/hbase/regionserver/MemStoreFlusher.java
URL: 
http://svn.apache.org/viewvc/hbase/branches/0.96/hbase-server/src/main/java/org/apache/hadoop/hbase/regionserver/MemStoreFlusher.java?rev=1569371&r1=1569370&r2=1569371&view=diff
==============================================================================
--- 
hbase/branches/0.96/hbase-server/src/main/java/org/apache/hadoop/hbase/regionserver/MemStoreFlusher.java
 (original)
+++ 
hbase/branches/0.96/hbase-server/src/main/java/org/apache/hadoop/hbase/regionserver/MemStoreFlusher.java
 Tue Feb 18 15:00:27 2014
@@ -219,6 +219,11 @@ class MemStoreFlusher implements FlushRe
   }
 
   private class FlushHandler extends HasThread {
+
+    private FlushHandler(String name) {
+      super(name);
+    }
+
     @Override
     public void run() {
       while (!server.isStopped()) {
@@ -362,7 +367,7 @@ class MemStoreFlusher implements FlushRe
     ThreadFactory flusherThreadFactory = Threads.newDaemonThreadFactory(
         server.getServerName().toShortString() + "-MemStoreFlusher", eh);
     for (int i = 0; i < flushHandlers.length; i++) {
-      flushHandlers[i] = new FlushHandler();
+      flushHandlers[i] = new FlushHandler("MemStoreFlusher." + i);
       flusherThreadFactory.newThread(flushHandlers[i]);
       flushHandlers[i].start();
     }