Toggle navigation
Home
java.util.concurrent.atomic.AtomicReference<org.apache.ignite.internal.processors.cache.distributed.near.GridNearTxFinishFuture> to org.apache.ignite.internal.processors.cache.distributed.near.GridNearTxFinishFuture
No. of Instances - 2
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(); } }
{ @Override public void apply( IgniteInternalFuture<?> f){ GridNearTxFinishFuture fut0=commitFut.get(); try { prepareFut.get(); fut0.finish(); } catch ( Error|RuntimeException e) { commitErr.compareAndSet(null,e); fut0.onDone(e); throw e; } catch ( IgniteCheckedException e) { commitErr.compareAndSet(null,e); fut0.onDone(e); } } }
to
{ @Override public void apply( IgniteInternalFuture<?> f){ GridNearTxFinishFuture fut0=commitFut; try { prepareFut.get(); fut0.finish(); } catch ( Error|RuntimeException e) { COMMIT_ERR_UPD.compareAndSet(GridNearTxLocal.this,null,e); fut0.onDone(e); throw e; } catch ( IgniteCheckedException e) { COMMIT_ERR_UPD.compareAndSet(GridNearTxLocal.this,null,e); fut0.onDone(e); } } }
Add or Remove Method invocation
commitErr.compareAndSet(null,e)
to
COMMIT_ERR_UPD.compareAndSet(GridNearTxLocal.this,null,e)