Toggle navigation
Home
org.apache.ignite.internal.processors.cache.GridCacheReturn<java.lang.management.PlatformManagedObject> to org.apache.ignite.internal.processors.cache.GridCacheReturn
No. of Instances - 18
No. of Commits - 1
No. of Projects - {'ignite'}
Hierarchy/Composition: -
Primitive Info: -
NameSpace: Internal -> Internal
Mapping:
Cascading Type Change (Similar)
C2<GridCacheReturn<V>,Exception,IgniteInternalFuture<GridNearLockResponse>>
to
C2<GridCacheReturn,Exception,IgniteInternalFuture<GridNearLockResponse>>
GridCacheReturn<Object>
to
GridCacheReturn
GridCacheReturn<Object>
to
GridCacheReturn
GridCacheReturn<>
to
GridCacheReturn
GridCacheReturn<>
to
GridCacheReturn
GridCacheReturn<Object>
to
GridCacheReturn
GridCacheReturn<Object>
to
GridCacheReturn
GridCacheReturn<>
to
GridCacheReturn
GridCacheReturn<>
to
GridCacheReturn
Update Anonymous class
{ @Override public IgniteInternalFuture<GridNearLockResponse> apply( GridCacheReturn<V> o, Exception e){ if (e != null) e=U.unwrap(e); assert !t.empty(); final GridNearLockResponse resp=createLockReply(nearNode,entries,req,t,t.xidVersion(),e); if (resp.error() == null && t.onePhaseCommit()) { assert t.implicit(); return t.commitAsync().chain(new C1<IgniteInternalFuture<IgniteInternalTx>,GridNearLockResponse>(){ @Override public GridNearLockResponse apply( IgniteInternalFuture<IgniteInternalTx> f){ try { f.get(); } catch ( IgniteCheckedException e1) { resp.error(e1); } sendLockReply(nearNode,t,req,resp); return resp; } } ); } else { sendLockReply(nearNode,t,req,resp); return new GridFinishedFutureEx<>(resp); } } }
to
{ @Override public IgniteInternalFuture<GridNearLockResponse> apply( GridCacheReturn o, Exception e){ if (e != null) e=U.unwrap(e); assert !t.empty(); final GridNearLockResponse resp=createLockReply(nearNode,entries,req,t,t.xidVersion(),e); if (resp.error() == null && t.onePhaseCommit()) { assert t.implicit(); return t.commitAsync().chain(new C1<IgniteInternalFuture<IgniteInternalTx>,GridNearLockResponse>(){ @Override public GridNearLockResponse apply( IgniteInternalFuture<IgniteInternalTx> f){ try { f.get(); } catch ( IgniteCheckedException e1) { resp.error(e1); } sendLockReply(nearNode,t,req,resp); return resp; } } ); } else { sendLockReply(nearNode,t,req,resp); return new GridFinishedFutureEx<>(resp); } } }