Toggle navigation
Home
org.apache.ignite.internal.processors.cache.transactions.IgniteInternalTx to org.apache.ignite.internal.processors.cache.distributed.near.GridNearTxPrepareResponse
No. of Instances - 10
No. of Commits - 1
No. of Projects - {'ignite'}
Hierarchy/Composition: -
Primitive Info: -
NameSpace: Internal -> Internal
Mapping:
Update argument list (Method invocation)
prepareNearTx
to
prepareNearTx
prepareColocatedTx
to
prepareColocatedTx
prepareNearTx
to
prepareNearTx
Cascading Type Change (Similar)
IgniteInternalTx
to
GridNearTxPrepareResponse
IgniteInternalFuture<IgniteInternalTx>
to
IgniteInternalFuture<GridNearTxPrepareResponse>
C2<IgniteInternalTx,Exception,IgniteInternalTx>
to
C2<GridNearTxPrepareResponse,Exception,GridNearTxPrepareResponse>
C2<Object,Exception,IgniteInternalFuture<IgniteInternalTx>>
to
C2<Object,Exception,IgniteInternalFuture<GridNearTxPrepareResponse>>
IgniteInternalTx
to
GridNearTxPrepareResponse
IgniteInternalFuture<IgniteInternalTx>
to
IgniteInternalFuture<GridNearTxPrepareResponse>
C2<IgniteInternalTx,Exception,IgniteInternalTx>
to
C2<GridNearTxPrepareResponse,Exception,GridNearTxPrepareResponse>
C2<Object,Exception,IgniteInternalFuture<IgniteInternalTx>>
to
C2<Object,Exception,IgniteInternalFuture<GridNearTxPrepareResponse>>
IgniteInternalFuture<IgniteInternalTx>
to
IgniteInternalFuture<?>
IgniteInternalTx
to
GridNearTxPrepareResponse
Add or Remove Method invocation
locTx.prepareAsyncLocal(req.reads(),req.writes(),req.transactionNodes(),req.last(),req.lastBackups(),completeCb)
to
locTx.prepareAsyncLocal(req.reads(),req.writes(),req.transactionNodes(),req.last(),req.lastBackups())
U.error(log,"Failed to prepare DHT transaction: " + tx,e)
to
U.error(log,"Failed to prepare transaction: " + locTx,e)
locTx.prepareAsyncLocal(req.reads(),req.writes(),req.transactionNodes(),req.last(),req.lastBackups(),completeCb)
to
locTx.prepareAsyncLocal(req.reads(),req.writes(),req.transactionNodes(),req.last(),req.lastBackups())
U.error(log,"Failed to prepare DHT transaction: " + tx,e)
to
U.error(log,"Failed to prepare transaction: " + locTx,e)
Update Anonymous class
{ @Override public IgniteInternalFuture<IgniteInternalTx> apply( Object o, Exception ex){ if (ex != null) throw new GridClosureException(ex); IgniteInternalFuture<IgniteInternalTx> fut=locTx.prepareAsyncLocal(req.reads(),req.writes(),req.transactionNodes(),req.last(),req.lastBackups(),completeCb); if (locTx.isRollbackOnly()) locTx.rollbackAsync(); return fut; } }
to
{ @Override public IgniteInternalFuture<GridNearTxPrepareResponse> apply( Object o, Exception ex){ if (ex != null) throw new GridClosureException(ex); IgniteInternalFuture<GridNearTxPrepareResponse> fut=locTx.prepareAsyncLocal(req.reads(),req.writes(),req.transactionNodes(),req.last(),req.lastBackups()); if (locTx.isRollbackOnly()) locTx.rollbackAsync(); return fut; } }
{ @Override public IgniteInternalFuture<IgniteInternalTx> apply( Object o, Exception ex){ if (ex != null) throw new GridClosureException(ex); IgniteInternalFuture<IgniteInternalTx> fut=locTx.prepareAsyncLocal(req.reads(),req.writes(),req.transactionNodes(),req.last(),req.lastBackups(),completeCb); if (locTx.isRollbackOnly()) locTx.rollbackAsync(); return fut; } }
to
{ @Override public IgniteInternalFuture<GridNearTxPrepareResponse> apply( Object o, Exception ex){ if (ex != null) throw new GridClosureException(ex); IgniteInternalFuture<GridNearTxPrepareResponse> fut=locTx.prepareAsyncLocal(req.reads(),req.writes(),req.transactionNodes(),req.last(),req.lastBackups()); if (locTx.isRollbackOnly()) locTx.rollbackAsync(); return fut; } }
Rename Variable
tx
to
res
Other
fut
to
fut
f
to
f
fut
to
fut
fut
to
fut