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 1B38510692 for ; Fri, 14 Mar 2014 21:11:35 +0000 (UTC) Received: (qmail 78909 invoked by uid 500); 14 Mar 2014 21:11:34 -0000 Delivered-To: apmail-accumulo-commits-archive@accumulo.apache.org Received: (qmail 78813 invoked by uid 500); 14 Mar 2014 21:11:33 -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 78588 invoked by uid 99); 14 Mar 2014 21:11:28 -0000 Received: from tyr.zones.apache.org (HELO tyr.zones.apache.org) (140.211.11.114) by apache.org (qpsmtpd/0.29) with ESMTP; Fri, 14 Mar 2014 21:11:28 +0000 Received: by tyr.zones.apache.org (Postfix, from userid 65534) id E36DD8B7AA9; Fri, 14 Mar 2014 21:11:27 +0000 (UTC) Content-Type: text/plain; charset="us-ascii" MIME-Version: 1.0 Content-Transfer-Encoding: 7bit From: elserj@apache.org To: commits@accumulo.apache.org Date: Fri, 14 Mar 2014 21:11:27 -0000 Message-Id: X-Mailer: ASF-Git Admin Mailer Subject: [01/26] git commit: ACCUMULO-2319 Move MemoryManagementFramework thread starts out of constructor Repository: accumulo Updated Branches: refs/heads/ACCUMULO-2061 db76dd751 -> de5c29bc8 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/ACCUMULO-2061 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;