pull/423/head
Nitin 10 years ago
parent df6f04403a
commit d0f84e101d

@ -67,21 +67,21 @@ public class HikariPool extends PoolBase implements HikariPoolMXBean, IBagStateL
private static final ClockSource clockSource = ClockSource.INSTANCE; private static final ClockSource clockSource = ClockSource.INSTANCE;
private final long ALIVE_BYPASS_WINDOW_MS = Long.getLong("com.zaxxer.hikari.aliveBypassWindow", TimeUnit.SECONDS.toMillis(1)); private static final long ALIVE_BYPASS_WINDOW_MS = Long.getLong("com.zaxxer.hikari.aliveBypassWindow", TimeUnit.SECONDS.toMillis(1));
private final long HOUSEKEEPING_PERIOD_MS = Long.getLong("com.zaxxer.hikari.housekeeping.periodMs", TimeUnit.SECONDS.toMillis(30)); private static final long HOUSEKEEPING_PERIOD_MS = Long.getLong("com.zaxxer.hikari.housekeeping.periodMs", TimeUnit.SECONDS.toMillis(30));
private static final int POOL_NORMAL = 0; private static final int POOL_NORMAL = 0;
private static final int POOL_SUSPENDED = 1; private static final int POOL_SUSPENDED = 1;
private static final int POOL_SHUTDOWN = 2; private static final int POOL_SHUTDOWN = 2;
final ConcurrentBag<PoolEntry> connectionBag; private volatile int poolState;
final ScheduledThreadPoolExecutor houseKeepingExecutorService;
private final AtomicInteger totalConnections; private final AtomicInteger totalConnections;
private final ThreadPoolExecutor addConnectionExecutor; private final ThreadPoolExecutor addConnectionExecutor;
private final ThreadPoolExecutor closeConnectionExecutor; private final ThreadPoolExecutor closeConnectionExecutor;
private final ScheduledThreadPoolExecutor houseKeepingExecutorService;
private volatile int poolState; private final ConcurrentBag<PoolEntry> connectionBag;
private final String poolName; private final String poolName;
private final ProxyLeakTask leakTask; private final ProxyLeakTask leakTask;

@ -29,7 +29,7 @@ import com.zaxxer.hikari.util.UtilityElf;
abstract class PoolBase abstract class PoolBase
{ {
protected final Logger LOGGER = LoggerFactory.getLogger(getClass()); protected final Logger LOGGER = LoggerFactory.getLogger(PoolBase.class);
protected final HikariConfig config; protected final HikariConfig config;
protected long connectionTimeout; protected long connectionTimeout;

Loading…
Cancel
Save