Selective merge of dev changes.

pull/316/merge
Brett Wooldridge 10 years ago
parent 84a0b48d92
commit dbdc196a24

@ -194,7 +194,7 @@ public class HikariPool implements HikariPoolMBean, IBagStateListener
else { else {
metricsContext.setConnectionLastOpen(bagEntry, now); metricsContext.setConnectionLastOpen(bagEntry, now);
metricsContext.stop(); metricsContext.stop();
return ProxyFactory.getProxyConnection(this, bagEntry, leakTask.start(bagEntry)); return ProxyFactory.getProxyConnection(this, bagEntry, leakTask.start(bagEntry), now);
} }
} }
while (timeout > 0L); while (timeout > 0L);

@ -72,13 +72,13 @@ public abstract class ConnectionProxy implements IHikariConnectionProxy
SQL_ERRORS.add("JZ0C1"); // Sybase disconnect error SQL_ERRORS.add("JZ0C1"); // Sybase disconnect error
} }
protected ConnectionProxy(final HikariPool pool, final PoolBagEntry bagEntry, final LeakTask leakTask) { protected ConnectionProxy(final HikariPool pool, final PoolBagEntry bagEntry, final LeakTask leakTask, final long now) {
this.parentPool = pool; this.parentPool = pool;
this.bagEntry = bagEntry; this.bagEntry = bagEntry;
this.delegate = bagEntry.connection; this.delegate = bagEntry.connection;
this.leakTask = leakTask; this.leakTask = leakTask;
this.lastAccess = bagEntry.lastAccess; this.lastAccess = now;
this.openStatements = new FastList<Statement>(Statement.class, 16); this.openStatements = new FastList<Statement>(Statement.class, 16);
} }

@ -47,7 +47,7 @@ public final class ProxyFactory
* @param leakTask a leak detetection task * @param leakTask a leak detetection task
* @return a proxy that wraps the specified {@link Connection} * @return a proxy that wraps the specified {@link Connection}
*/ */
public static IHikariConnectionProxy getProxyConnection(final HikariPool pool, final PoolBagEntry bagEntry, final LeakTask leakTask) public static IHikariConnectionProxy getProxyConnection(final HikariPool pool, final PoolBagEntry bagEntry, final LeakTask leakTask, final long now)
{ {
// Body is injected by JavassistProxyFactory // Body is injected by JavassistProxyFactory
return null; return null;

Loading…
Cancel
Save