Toggle navigation
Home
java.lang.Boolean to java.lang.Long
No. of Instances - 9
No. of Commits - 1
No. of Projects - {'atomix'}
Hierarchy/Composition: SIBLING
Primitive Info: -
NameSpace: Jdk -> Jdk
Mapping:
Cascading Type Change (Different)
TachyonTException
to
tachyon.thrift.TachyonTException
renameFile_result
to
reinitializeFile_result
free_result
to
getWorkerId_result
CompareAndSetFunction<>
to
CompareAndSwapFunction<>
Consumer<Boolean>
to
Consumer<Long>
Consumer<Boolean>
to
Consumer<Long>
Cascading Type Change (Similar)
Boolean
to
Long
AsyncMethodCallback<Boolean>
to
AsyncMethodCallback<Long>
Boolean
to
Long
AsyncMethodCallback<Boolean>
to
AsyncMethodCallback<Long>
Boolean
to
Long
Boolean
to
Long
Boolean
to
Long
boolean
to
long
Update Anonymous class
{ public void onComplete( Boolean o){ free_result result=new free_result(); result.success=o; result.setSuccessIsSet(true); try { fcall.sendResponse(fb,result,org.apache.thrift.protocol.TMessageType.REPLY,seqid); return; } catch ( Exception e) { LOGGER.error("Exception writing to internal frame buffer",e); } fb.close(); } public void onError( Exception e){ byte msgType=org.apache.thrift.protocol.TMessageType.REPLY; org.apache.thrift.TBase msg; free_result result=new free_result(); if (e instanceof tachyon.thrift.TachyonTException) { result.e=(tachyon.thrift.TachyonTException)e; result.setEIsSet(true); msg=result; } else { msgType=org.apache.thrift.protocol.TMessageType.EXCEPTION; msg=(org.apache.thrift.TBase)new org.apache.thrift.TApplicationException(org.apache.thrift.TApplicationException.INTERNAL_ERROR,e.getMessage()); } try { fcall.sendResponse(fb,msg,msgType,seqid); return; } catch ( Exception ex) { LOGGER.error("Exception writing to internal frame buffer",ex); } fb.close(); } }
to
{ public void onComplete( Long o){ getWorkerId_result result=new getWorkerId_result(); result.success=o; result.setSuccessIsSet(true); try { fcall.sendResponse(fb,result,org.apache.thrift.protocol.TMessageType.REPLY,seqid); return; } catch ( Exception e) { LOGGER.error("Exception writing to internal frame buffer",e); } fb.close(); } public void onError( Exception e){ byte msgType=org.apache.thrift.protocol.TMessageType.REPLY; org.apache.thrift.TBase msg; getWorkerId_result result=new getWorkerId_result(); { msgType=org.apache.thrift.protocol.TMessageType.EXCEPTION; msg=(org.apache.thrift.TBase)new org.apache.thrift.TApplicationException(org.apache.thrift.TApplicationException.INTERNAL_ERROR,e.getMessage()); } try { fcall.sendResponse(fb,msg,msgType,seqid); return; } catch ( Exception ex) { LOGGER.error("Exception writing to internal frame buffer",ex); } fb.close(); } }
{ @Override public Boolean call() throws Exception { try (IgniteInternalTx tx=CU.txStartInternal(ctx,atomicView,PESSIMISTIC,REPEATABLE_READ)){ GridCacheAtomicLongValue val=atomicView.get(key); if (val == null) throw new IgniteCheckedException("Failed to find atomic long with given name: " + name); boolean retVal=val.get() == expVal; if (retVal) { val.set(newVal); atomicView.getAndPut(key,val); tx.commit(); } return retVal; } catch ( Error|Exception e) { U.error(log,"Failed to compare and set: " + this,e); throw e; } } }
to
{ @Override public Long call() throws Exception { try (IgniteInternalTx tx=CU.txStartInternal(ctx,atomicView,PESSIMISTIC,REPEATABLE_READ)){ GridCacheAtomicLongValue val=atomicView.get(key); if (val == null) throw new IgniteCheckedException("Failed to find atomic long with given name: " + name); long retVal=val.get(); if (retVal == expVal) { val.set(newVal); atomicView.getAndPut(key,val); tx.commit(); } return retVal; } catch ( Error|Exception e) { U.error(log,"Failed to compare and set: " + this,e); throw e; } } }
Rename Variable
compareAndSet
to
compareAndSwap
internalCompareAndSet
to
internalCompareAndSetAndGet
Add or Remove Method invocation
keyEncoded
to
params.toArray()
msgEncoded
to
params.toArray()
invalidateEntryOnChange
to
params.toArray()
Arrays.<Object>asList(getName(),getIdsListName())
to
Arrays.<Object>asList(getName(),getIdsListName(),getTimeoutName())
RedisCommands.EVAL_BOOLEAN
to
Arrays.<Object>asList(getName(),getIdsListName(),getTimeoutName())
Update String Literal
"return 1;"
to
"counter = counter + 1;"
"return 0;"
to
"return counter;"
"redis.call('publish', KEYS[2], ARGV[2]); "
to
"redis.call('publish', KEYS[2], ARGV[j+1]); "
Update argument list (Method invocation)
evalWriteAsync
to
evalWriteAsync
evalWriteAsync
to
evalWriteAsync