From fde488a69dd512a629c59033e632e8312381e016 Mon Sep 17 00:00:00 2001
From: Chinmay Soman <csoman@linkedin.com>
Date: Fri, 27 Jan 2012 14:39:01 -0800
Subject: [PATCH] Removed some unnecessary functions in DynamicEventThrottler

---
 .../voldemort/store/readonly/fetcher/HdfsFetcher.java  |  4 ++--
 src/java/voldemort/utils/DynamicEventThrottler.java    | 10 +---------
 src/java/voldemort/utils/DynamicThrottleLimit.java     |  6 +-----
 3 files changed, 4 insertions(+), 16 deletions(-)

diff --git a/contrib/hadoop-store-builder/src/java/voldemort/store/readonly/fetcher/HdfsFetcher.java b/contrib/hadoop-store-builder/src/java/voldemort/store/readonly/fetcher/HdfsFetcher.java
index de4e01f845..cede02a582 100644
--- a/contrib/hadoop-store-builder/src/java/voldemort/store/readonly/fetcher/HdfsFetcher.java
+++ b/contrib/hadoop-store-builder/src/java/voldemort/store/readonly/fetcher/HdfsFetcher.java
@@ -111,9 +111,10 @@ public HdfsFetcher(DynamicThrottleLimit dynThrottleLimit,
                        Long reportingIntervalBytes,
                        int bufferSize,
                        long minBytesPerSecond) {
-        if(dynThrottleLimit != null) {
+        if(dynThrottleLimit != null && dynThrottleLimit.getRate() != 0) {
             this.maxBytesPerSecond = dynThrottleLimit.getRate();
             this.throttler = new DynamicEventThrottler(dynThrottleLimit);
+            this.globalThrottleLimit = dynThrottleLimit;
             logger.info("Initializing Dynamic Event throttler with rate : "
                         + this.maxBytesPerSecond + " bytes / sec");
         } else
@@ -122,7 +123,6 @@ public HdfsFetcher(DynamicThrottleLimit dynThrottleLimit,
         this.bufferSize = bufferSize;
         this.status = null;
         this.minBytesPerSecond = minBytesPerSecond;
-        this.globalThrottleLimit = dynThrottleLimit;
     }
 
     public File fetch(String sourceFileUrl, String destinationFile) throws IOException {
diff --git a/src/java/voldemort/utils/DynamicEventThrottler.java b/src/java/voldemort/utils/DynamicEventThrottler.java
index 063d5281d5..3ff2c0476b 100644
--- a/src/java/voldemort/utils/DynamicEventThrottler.java
+++ b/src/java/voldemort/utils/DynamicEventThrottler.java
@@ -20,18 +20,10 @@ public DynamicEventThrottler(Time time, long ratePerSecond, long intervalMs) {
         super(time, ratePerSecond, intervalMs);
     }
 
-    public void updateRate(long l) {
+    public synchronized void updateRate(long l) {
         this.dynamicRatePerSecond = l;
     }
 
-    public void incrementNumJobs() {
-        this.dynThrottleLimit.incrementNumJobs();
-    }
-
-    public void decrementNumJobs() {
-        this.dynThrottleLimit.decrementNumJobs();
-    }
-
     @Override
     public long getRate() {
         if(this.dynThrottleLimit != null)
diff --git a/src/java/voldemort/utils/DynamicThrottleLimit.java b/src/java/voldemort/utils/DynamicThrottleLimit.java
index 2ab0e0b68d..280cd180de 100644
--- a/src/java/voldemort/utils/DynamicThrottleLimit.java
+++ b/src/java/voldemort/utils/DynamicThrottleLimit.java
@@ -14,11 +14,7 @@ public DynamicThrottleLimit(long val) {
     }
 
     public long getRate() {
-        long retVal;
-        synchronized(this) {
-            retVal = this.dynamicRatePerSecond;
-        }
-        return retVal;
+        return this.dynamicRatePerSecond;
     }
 
     public void incrementNumJobs() {