-
Notifications
You must be signed in to change notification settings - Fork 9
Commit
This commit does not belong to any branch on this repository, and may belong to a fork outside of the repository.
- Loading branch information
1 parent
51975db
commit 4baae49
Showing
6 changed files
with
124 additions
and
9 deletions.
There are no files selected for viewing
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
94 changes: 94 additions & 0 deletions
94
carapace-server/src/main/java/org/carapaceproxy/server/cache/CachePoolTrimmer.java
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
| Original file line number | Diff line number | Diff line change |
|---|---|---|
| @@ -0,0 +1,94 @@ | ||
| package org.carapaceproxy.server.cache; | ||
|
|
||
| import org.carapaceproxy.core.HttpProxyServer; | ||
| import org.carapaceproxy.core.RuntimeServerConfiguration; | ||
|
|
||
| import java.util.concurrent.Executors; | ||
| import java.util.concurrent.ScheduledExecutorService; | ||
| import java.util.concurrent.ScheduledFuture; | ||
| import java.util.concurrent.TimeUnit; | ||
| import java.util.logging.Level; | ||
| import java.util.logging.Logger; | ||
|
|
||
| public class CachePoolTrimmer implements Runnable { | ||
|
|
||
| public static final int DEFAULT_CACHE_POOL_TRIM_INTERVAL = 3600; // seconds | ||
| private static final Logger LOG = Logger.getLogger(CachePoolTrimmer.class.getName()); | ||
|
|
||
| private ScheduledExecutorService timer; | ||
| private ScheduledFuture<?> scheduledFuture; | ||
| private HttpProxyServer parent; | ||
|
|
||
| // can change at runtime | ||
| private volatile int period; | ||
| private volatile boolean started; // keep track of start() calling | ||
|
|
||
| public CachePoolTrimmer(HttpProxyServer parent) { | ||
| this.period = DEFAULT_CACHE_POOL_TRIM_INTERVAL; | ||
| this.parent = parent; | ||
| } | ||
|
|
||
| public int getPeriod() { | ||
| return period; | ||
| } | ||
|
|
||
| public void setPeriod(int period) { | ||
| this.period = period; | ||
| } | ||
|
|
||
| public synchronized void start() { | ||
| started = true; | ||
| if (period <= 0) { | ||
| return; | ||
| } | ||
| if (timer == null) { | ||
| timer = Executors.newSingleThreadScheduledExecutor(); | ||
| } | ||
| LOG.info("Starting cache trim scheduler, period: " + period + " seconds"); | ||
| scheduledFuture = timer.scheduleAtFixedRate(this, period, period, TimeUnit.SECONDS); | ||
| } | ||
|
|
||
| public synchronized void stop() { | ||
| started = false; | ||
| if (timer != null) { | ||
| timer.shutdown(); | ||
| try { | ||
| timer.awaitTermination(10, TimeUnit.SECONDS); | ||
| timer = null; | ||
| scheduledFuture = null; | ||
| } catch (InterruptedException err) { | ||
| Thread.currentThread().interrupt(); | ||
| } | ||
| } | ||
| } | ||
|
|
||
|
|
||
| public synchronized void reloadConfiguration(RuntimeServerConfiguration newConfiguration) { | ||
| int newPeriod = newConfiguration.getCachePoolTrimInterval(); | ||
| boolean changePeriod = period != newPeriod; | ||
| boolean restart = scheduledFuture != null && changePeriod; | ||
|
|
||
| if (restart) { | ||
| scheduledFuture.cancel(true); | ||
| } | ||
|
|
||
| if (changePeriod) { | ||
| period = newPeriod; | ||
| LOG.info("Applying new cache trim interval " + period + " s"); | ||
| } | ||
|
|
||
| if (restart || started) { | ||
| start(); | ||
| } | ||
| } | ||
|
|
||
| @Override | ||
| public void run() { | ||
| if (parent.trimCachePool()) { | ||
| LOG.log(Level.INFO, "Cache PooledByteBufAllocator: trim successful"); | ||
| } else { | ||
| LOG.log(Level.INFO, "Cache PooledByteBufAllocator: No memory released by cache trim"); | ||
| } | ||
| } | ||
|
|
||
| } |
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters