@Override
public synchronized void close() {
- dropConnection();
+ releaseConnection();
this.chain.close();
- // TODO should this perform cleanup ?
}
@Override
@Override
public void releaseConnection() {
- dropConnection();
cleanup();
+ dropConnection();
}
@GuardedBy("this")
@Override
public void onTransactionChainFailed(final TransactionChain<?, ?> chain, final AsyncTransaction<?, ?> transaction, final Throwable cause) {
LOG.error("Transaction chain failed.", cause);
- dropConnection();
+ releaseConnection();
this.chain.close();
this.chain = this.rib.createPeerChain(this);
}