From c9ad5216603b3e653b3379f5df3bf8867311e7bb Mon Sep 17 00:00:00 2001 From: Nitin Date: Fri, 8 Jan 2016 19:10:03 +0530 Subject: [PATCH] cleanup + rearrange statements --- .../java/com/zaxxer/hikari/HikariConfig.java | 7 ++++--- .../com/zaxxer/hikari/pool/HikariPool.java | 18 +++++++----------- 2 files changed, 11 insertions(+), 14 deletions(-) diff --git a/src/main/java/com/zaxxer/hikari/HikariConfig.java b/src/main/java/com/zaxxer/hikari/HikariConfig.java index ffeaaff0..f0aab1e6 100644 --- a/src/main/java/com/zaxxer/hikari/HikariConfig.java +++ b/src/main/java/com/zaxxer/hikari/HikariConfig.java @@ -116,14 +116,15 @@ public class HikariConfig implements HikariConfigMXBean dataSourceProperties = new Properties(); healthCheckProperties = new Properties(); + minIdle = -1; + maxPoolSize = 10; + maxLifetime = MAX_LIFETIME; connectionTimeout = CONNECTION_TIMEOUT; validationTimeout = VALIDATION_TIMEOUT; idleTimeout = IDLE_TIMEOUT; + isAutoCommit = true; isInitializationFailFast = true; - minIdle = -1; - maxPoolSize = 10; - maxLifetime = MAX_LIFETIME; String systemProp = System.getProperty("hikaricp.configurationFile"); if ( systemProp != null) { diff --git a/src/main/java/com/zaxxer/hikari/pool/HikariPool.java b/src/main/java/com/zaxxer/hikari/pool/HikariPool.java index 3eec7908..00724e55 100644 --- a/src/main/java/com/zaxxer/hikari/pool/HikariPool.java +++ b/src/main/java/com/zaxxer/hikari/pool/HikariPool.java @@ -67,17 +67,16 @@ public class HikariPool extends PoolBase implements HikariPoolMXBean, IBagStateL private static final ClockSource clockSource = ClockSource.INSTANCE; - private final long ALIVE_BYPASS_WINDOW_MS = Long.getLong("com.zaxxer.hikari.aliveBypassWindowMs", TimeUnit.MILLISECONDS.toMillis(500)); - private final long HOUSEKEEPING_PERIOD_MS = Long.getLong("com.zaxxer.hikari.housekeeping.periodMs", TimeUnit.SECONDS.toMillis(30)); - - private final PoolEntryCreator POOL_ENTRY_CREATOR = new PoolEntryCreator(); - private static final int POOL_NORMAL = 0; private static final int POOL_SUSPENDED = 1; private static final int POOL_SHUTDOWN = 2; private volatile int poolState; + private final long ALIVE_BYPASS_WINDOW_MS = Long.getLong("com.zaxxer.hikari.aliveBypassWindowMs", TimeUnit.MILLISECONDS.toMillis(500)); + private final long HOUSEKEEPING_PERIOD_MS = Long.getLong("com.zaxxer.hikari.housekeeping.periodMs", TimeUnit.SECONDS.toMillis(30)); + + private final PoolEntryCreator POOL_ENTRY_CREATOR = new PoolEntryCreator(); private final AtomicInteger totalConnections; private final ThreadPoolExecutor addConnectionExecutor; private final ThreadPoolExecutor closeConnectionExecutor; @@ -89,7 +88,6 @@ public class HikariPool extends PoolBase implements HikariPoolMXBean, IBagStateL private final SuspendResumeLock suspendResumeLock; private MetricsTrackerDelegate metricsTracker; - private boolean isRecordMetrics; /** * Construct a HikariPool with the specified configuration. @@ -264,8 +262,7 @@ public class HikariPool extends PoolBase implements HikariPoolMXBean, IBagStateL public void setMetricRegistry(Object metricRegistry) { - this.isRecordMetrics = metricRegistry != null; - if (isRecordMetrics) { + if (metricRegistry != null) { setMetricsTrackerFactory(new CodahaleMetricsTrackerFactory((MetricRegistry) metricRegistry)); } else { @@ -275,8 +272,7 @@ public class HikariPool extends PoolBase implements HikariPoolMXBean, IBagStateL public void setMetricsTrackerFactory(MetricsTrackerFactory metricsTrackerFactory) { - this.isRecordMetrics = metricsTrackerFactory != null; - if (isRecordMetrics) { + if (metricsTrackerFactory != null) { this.metricsTracker = new MetricsTrackerDelegate(metricsTrackerFactory.create(config.getPoolName(), getPoolStats())); } else { @@ -588,8 +584,8 @@ public class HikariPool extends PoolBase implements HikariPoolMXBean, IBagStateL validationTimeout = config.getValidationTimeout(); leakTask.updateLeakDetectionThreshold(config.getLeakDetectionThreshold()); - final long now = clockSource.currentTime(); final long idleTimeout = config.getIdleTimeout(); + final long now = clockSource.currentTime(); // Detect retrograde time as well as forward leaps of unacceptable duration if (now < previous || now > clockSource.plusMillis(previous, (2 * HOUSEKEEPING_PERIOD_MS))) {