Toggle navigation
Home
java.util.concurrent.atomic.AtomicReference to org.apache.ignite.internal.IgniteInternalFuture
No. of Instances - 1
No. of Commits - 1
No. of Projects - {'ignite'}
Hierarchy/Composition: -
Primitive Info: -
NameSpace: Jdk -> Internal
Mapping:
Update Anonymous class
{ @Override public void apply( IgniteInternalFuture<?> f){ try { f.get(); } catch ( IgniteCheckedException e) { if (log.isDebugEnabled()) log.debug("Got optimistic tx failure [tx=" + this + ", err="+ e+ ']'); } GridNearTxFinishFuture fut0=rollbackFut.get(); fut0.finish(); } }
to
{ @Override public void apply( IgniteInternalFuture<?> f){ try { f.get(); } catch ( IgniteCheckedException e) { if (log.isDebugEnabled()) log.debug("Got optimistic tx failure [tx=" + this + ", err="+ e+ ']'); } GridNearTxFinishFuture fut0=rollbackFut; fut0.finish(); } }