Return-Path: <commits-return-41877-archive-asf-public=cust-asf.ponee.io@hbase.apache.org>
X-Original-To: archive-asf-public-internal@cust-asf2.ponee.io
Delivered-To: archive-asf-public-internal@cust-asf2.ponee.io
Received: from cust-asf.ponee.io (cust-asf.ponee.io [163.172.22.183])
	by cust-asf2.ponee.io (Postfix) with ESMTP id 899DD200BCF
	for <archive-asf-public-internal@cust-asf2.ponee.io>; Mon,  5 Dec 2016 21:14:27 +0100 (CET)
Received: by cust-asf.ponee.io (Postfix)
	id 883AF160B18; Mon,  5 Dec 2016 20:14:27 +0000 (UTC)
Delivered-To: archive-asf-public@cust-asf.ponee.io
Received: from mail.apache.org (hermes.apache.org [140.211.11.3])
	by cust-asf.ponee.io (Postfix) with SMTP id D1829160B09
	for <archive-asf-public@cust-asf.ponee.io>; Mon,  5 Dec 2016 21:14:26 +0100 (CET)
Received: (qmail 79001 invoked by uid 500); 5 Dec 2016 20:14:26 -0000
Mailing-List: contact commits-help@hbase.apache.org; run by ezmlm
Precedence: bulk
List-Help: <mailto:commits-help@hbase.apache.org>
List-Unsubscribe: <mailto:commits-unsubscribe@hbase.apache.org>
List-Post: <mailto:commits@hbase.apache.org>
List-Id: <commits.hbase.apache.org>
Reply-To: dev@hbase.apache.org
Delivered-To: mailing list commits@hbase.apache.org
Received: (qmail 78991 invoked by uid 99); 5 Dec 2016 20:14:26 -0000
Received: from git1-us-west.apache.org (HELO git1-us-west.apache.org) (140.211.11.23)
    by apache.org (qpsmtpd/0.29) with ESMTP; Mon, 05 Dec 2016 20:14:26 +0000
Received: by git1-us-west.apache.org (ASF Mail Server at git1-us-west.apache.org, from userid 33)
	id C5BA8E076F; Mon,  5 Dec 2016 20:14:25 +0000 (UTC)
Content-Type: text/plain; charset="us-ascii"
MIME-Version: 1.0
Content-Transfer-Encoding: 7bit
From: tedyu@apache.org
To: commits@hbase.apache.org
Message-Id: <32f6f558934b41de8977e98797f6d524@git.apache.org>
X-Mailer: ASF-Git Admin Mailer
Subject: hbase git commit: HBASE-17256 Rpc handler monitoring will be removed
 when the task queue is full (Guangxu Cheng)
Date: Mon,  5 Dec 2016 20:14:25 +0000 (UTC)
archived-at: Mon, 05 Dec 2016 20:14:27 -0000

Repository: hbase
Updated Branches:
  refs/heads/branch-1 600fa8de7 -> c2801a2ea


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/c2801a2e
Tree: http://git-wip-us.apache.org/repos/asf/hbase/tree/c2801a2e
Diff: http://git-wip-us.apache.org/repos/asf/hbase/diff/c2801a2e

Branch: refs/heads/branch-1
Commit: c2801a2ea87a870195557122ede08095f15b19c1
Parents: 600fa8d
Author: tedyu <yuzhihong@gmail.com>
Authored: Mon Dec 5 12:14:20 2016 -0800
Committer: tedyu <yuzhihong@gmail.com>
Committed: Mon Dec 5 12:14:20 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/c2801a2e/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 b620fac..c8e0a39 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;
   }