hbase-commits mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From te...@apache.org
Subject hbase git commit: HBASE-17256 Rpc handler monitoring will be removed when the task queue is full (Guangxu Cheng)
Date Mon, 05 Dec 2016 19:32:23 GMT
Repository: hbase
Updated Branches:
  refs/heads/master 39653862a -> 319060580


HBASE-17256 Rpc handler monitoring will be removed when the task queue is full (Guangxu Cheng)


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

Branch: refs/heads/master
Commit: 3190605801fb18ac1c0d47fdc8964a93fab0d8f2
Parents: 3965386
Author: tedyu <yuzhihong@gmail.com>
Authored: Mon Dec 5 11:32:17 2016 -0800
Committer: tedyu <yuzhihong@gmail.com>
Committed: Mon Dec 5 11:32:17 2016 -0800

----------------------------------------------------------------------
 .../main/java/org/apache/hadoop/hbase/monitoring/TaskMonitor.java | 3 +++
 1 file changed, 3 insertions(+)
----------------------------------------------------------------------


http://git-wip-us.apache.org/repos/asf/hbase/blob/31906058/hbase-server/src/main/java/org/apache/hadoop/hbase/monitoring/TaskMonitor.java
----------------------------------------------------------------------
diff --git a/hbase-server/src/main/java/org/apache/hadoop/hbase/monitoring/TaskMonitor.java
b/hbase-server/src/main/java/org/apache/hadoop/hbase/monitoring/TaskMonitor.java
index 9980044..4e75eb6 100644
--- a/hbase-server/src/main/java/org/apache/hadoop/hbase/monitoring/TaskMonitor.java
+++ b/hbase-server/src/main/java/org/apache/hadoop/hbase/monitoring/TaskMonitor.java
@@ -73,6 +73,9 @@ public class TaskMonitor {
         new Class<?>[] { MonitoredTask.class },
         new PassthroughInvocationHandler<MonitoredTask>(stat));
     TaskAndWeakRefPair pair = new TaskAndWeakRefPair(stat, proxy);
+    if (tasks.isFull()) {
+      purgeExpiredTasks();
+    }
     tasks.add(pair);
     return proxy;
   }


Mime
View raw message