Return-Path: X-Original-To: apmail-accumulo-commits-archive@www.apache.org Delivered-To: apmail-accumulo-commits-archive@www.apache.org Received: from mail.apache.org (hermes.apache.org [140.211.11.3]) by minotaur.apache.org (Postfix) with SMTP id 81F07102E6 for ; Wed, 12 Mar 2014 20:55:48 +0000 (UTC) Received: (qmail 50259 invoked by uid 500); 12 Mar 2014 20:55:38 -0000 Delivered-To: apmail-accumulo-commits-archive@accumulo.apache.org Received: (qmail 50132 invoked by uid 500); 12 Mar 2014 20:55:36 -0000 Mailing-List: contact commits-help@accumulo.apache.org; run by ezmlm Precedence: bulk List-Help: List-Unsubscribe: List-Post: List-Id: Reply-To: dev@accumulo.apache.org Delivered-To: mailing list commits@accumulo.apache.org Received: (qmail 50116 invoked by uid 99); 12 Mar 2014 20:55:36 -0000 Received: from tyr.zones.apache.org (HELO tyr.zones.apache.org) (140.211.11.114) by apache.org (qpsmtpd/0.29) with ESMTP; Wed, 12 Mar 2014 20:55:35 +0000 Received: by tyr.zones.apache.org (Postfix, from userid 65534) id BD76F942C54; Wed, 12 Mar 2014 20:55:35 +0000 (UTC) Content-Type: text/plain; charset="us-ascii" MIME-Version: 1.0 Content-Transfer-Encoding: 7bit From: bhavanki@apache.org To: commits@accumulo.apache.org Date: Wed, 12 Mar 2014 20:55:35 -0000 Message-Id: <35a43ab8646d4b25bbadcc3828c08320@git.apache.org> X-Mailer: ASF-Git Admin Mailer Subject: [01/10] git commit: ACCUMULO-2319 Move MemoryManagementFramework thread starts out of constructor Repository: accumulo Updated Branches: refs/heads/1.4.5-SNAPSHOT 117dce765 -> d11acbe5d refs/heads/1.5.2-SNAPSHOT 43cebf8c0 -> bf0b7f78b refs/heads/1.6.0-SNAPSHOT c657c5758 -> 7ed250ab9 refs/heads/master 2368eef2f -> 28c23e6aa ACCUMULO-2319 Move MemoryManagementFramework thread starts out of constructor Project: http://git-wip-us.apache.org/repos/asf/accumulo/repo Commit: http://git-wip-us.apache.org/repos/asf/accumulo/commit/d11acbe5 Tree: http://git-wip-us.apache.org/repos/asf/accumulo/tree/d11acbe5 Diff: http://git-wip-us.apache.org/repos/asf/accumulo/diff/d11acbe5 Branch: refs/heads/1.4.5-SNAPSHOT Commit: d11acbe5dc3f88efcb03b5b08832ecfa9fc15381 Parents: 117dce7 Author: Bill Havanki Authored: Wed Mar 12 10:50:20 2014 -0400 Committer: Bill Havanki Committed: Wed Mar 12 10:50:20 2014 -0400 ---------------------------------------------------------------------- .../TabletServerResourceManager.java | 21 ++++++++++++-------- 1 file changed, 13 insertions(+), 8 deletions(-) ---------------------------------------------------------------------- http://git-wip-us.apache.org/repos/asf/accumulo/blob/d11acbe5/src/server/src/main/java/org/apache/accumulo/server/tabletserver/TabletServerResourceManager.java ---------------------------------------------------------------------- diff --git a/src/server/src/main/java/org/apache/accumulo/server/tabletserver/TabletServerResourceManager.java b/src/server/src/main/java/org/apache/accumulo/server/tabletserver/TabletServerResourceManager.java index f7f04c9..87d73b5 100644 --- a/src/server/src/main/java/org/apache/accumulo/server/tabletserver/TabletServerResourceManager.java +++ b/src/server/src/main/java/org/apache/accumulo/server/tabletserver/TabletServerResourceManager.java @@ -187,6 +187,7 @@ public class TabletServerResourceManager { } memMgmt = new MemoryManagementFramework(); + memMgmt.startThreads(); } @@ -230,6 +231,8 @@ public class TabletServerResourceManager { private LinkedBlockingQueue memUsageReports; private long lastMemCheckTime = System.currentTimeMillis(); private long maxMem; + private Thread memoryGuardThread; + private Thread minorCompactionInitiatorThread; MemoryManagementFramework() { tabletReports = Collections.synchronizedMap(new HashMap()); @@ -242,10 +245,9 @@ public class TabletServerResourceManager { } }; - Thread t1 = new Daemon(new LoggingRunnable(log, r1)); - t1.setPriority(Thread.NORM_PRIORITY + 1); - t1.setName("Accumulo Memory Guard"); - t1.start(); + memoryGuardThread = new Daemon(new LoggingRunnable(log, r1)); + memoryGuardThread.setPriority(Thread.NORM_PRIORITY + 1); + memoryGuardThread.setName("Accumulo Memory Guard"); Runnable r2 = new Runnable() { public void run() { @@ -253,10 +255,13 @@ public class TabletServerResourceManager { } }; - Thread t2 = new Daemon(new LoggingRunnable(log, r2)); - t2.setName("Accumulo Minor Compaction Initiator"); - t2.start(); - + minorCompactionInitiatorThread = new Daemon(new LoggingRunnable(log, r2)); + minorCompactionInitiatorThread.setName("Accumulo Minor Compaction Initiator"); + } + + void startThreads() { + memoryGuardThread.start(); + minorCompactionInitiatorThread.start(); } private long lastMemTotal = 0;