return Collections.unmodifiableSet(propertyKeysToInclude); | return Collections.unmodifiableSet(propertyKeysToInclude.get()); | propertyKeysToInclude | propertyKeysToInclude.get() | neo4j | 5513bae7e2bd44220d28a8af2a44ea1bd88347e7 | org.neo4j.kernel.impl.api.AutoIndexing.AutoIndexOperations | | _1 | propertyKeysToInclude |
---|
_2 | propertyKeysToInclude |
---|
| TCIVar | propertyKeysToInclude |
---|
| | TCIVar | propertyKeysToInclude |
---|
| Uses | True |
if(propertyKeysToInclude.contains(name)) | if(propertyKeysToInclude.get().contains(name)) | propertyKeysToInclude | propertyKeysToInclude.get() | neo4j | 5513bae7e2bd44220d28a8af2a44ea1bd88347e7 | org.neo4j.kernel.impl.api.AutoIndexing.AutoIndexOperations | | _1 | propertyKeysToInclude |
---|
_2 | propertyKeysToInclude |
---|
| TCIVar | propertyKeysToInclude |
---|
| | TCIVar | propertyKeysToInclude |
---|
| Uses | True |
if(propertyKeysToInclude.contains(name)) | if(propertyKeysToInclude.get().contains(name)) | propertyKeysToInclude | propertyKeysToInclude.get() | neo4j | 5513bae7e2bd44220d28a8af2a44ea1bd88347e7 | org.neo4j.kernel.impl.api.AutoIndexing.AutoIndexOperations | | _1 | propertyKeysToInclude |
---|
_2 | propertyKeysToInclude |
---|
| TCIVar | propertyKeysToInclude |
---|
| | TCIVar | propertyKeysToInclude |
---|
| Uses | True |
if(propertyKeysToInclude.contains(name)) | if(propertyKeysToInclude.get().contains(name)) | propertyKeysToInclude | propertyKeysToInclude.get() | neo4j | 5513bae7e2bd44220d28a8af2a44ea1bd88347e7 | org.neo4j.kernel.impl.api.AutoIndexing.AutoIndexOperations | | _1 | propertyKeysToInclude |
---|
_2 | propertyKeysToInclude |
---|
| TCIVar | propertyKeysToInclude |
---|
| | TCIVar | propertyKeysToInclude |
---|
| Uses | True |
failureCause.printStackTrace(new PrintWriter(writer)); | failureCause.get().printStackTrace(new PrintWriter(writer)); | failureCause | failureCause.get() | elasticsearch | c4569432d1a47a481c2c56dabb56eb14541850d2 | org.elasticsearch.shield.transport.netty.HandshakeWaitingHandlerTests | | _1 | failureCause |
---|
_2 | failureCause |
---|
| | | | Uses | True |
assertThat(failureCause,anyOf(instanceOf(SSLException.class),instanceOf(AssertionError.class))); | assertThat(failureCause.get(),anyOf(instanceOf(SSLException.class),instanceOf(AssertionError.class))); | failureCause | failureCause.get() | elasticsearch | c4569432d1a47a481c2c56dabb56eb14541850d2 | org.elasticsearch.shield.transport.netty.HandshakeWaitingHandlerTests | | _1 | failureCause |
---|
_2 | failureCause |
---|
| | | | Uses | True |
shardIterator=checkpoint.getShardIterator(kinesis); | shardIterator=checkpoint.get().getShardIterator(kinesis); | checkpoint | checkpoint.get() | beam | ec3944659d16d696bcd73589aa035dbaa9aede2c | org.apache.beam.sdk.io.kinesis.ShardRecordsIterator | | | | | | Uses | True |
return state.hashCode(); | return state.get().hashCode(); | state | state.get() | sonarqube | ef72cd98a1dc1044e59021e3999857309902d718 | org.sonar.process.Lifecycle | | | | | | Uses | True |
failureCause.printStackTrace(new PrintWriter(writer)); | failureCause.get().printStackTrace(new PrintWriter(writer)); | failureCause | failureCause.get() | elasticsearch | 82a595e6968bb26fed1518d391753eefb0a9156b | org.elasticsearch.shield.transport.netty.HandshakeWaitingHandlerTests | | _1 | failureCause |
---|
_2 | failureCause |
---|
| | | | Uses | True |
assertThat(failureCause,anyOf(instanceOf(SSLException.class),instanceOf(AssertionError.class))); | assertThat(failureCause.get(),anyOf(instanceOf(SSLException.class),instanceOf(AssertionError.class))); | failureCause | failureCause.get() | elasticsearch | 82a595e6968bb26fed1518d391753eefb0a9156b | org.elasticsearch.shield.transport.netty.HandshakeWaitingHandlerTests | | _1 | failureCause |
---|
_2 | failureCause |
---|
| | | | Uses | True |
String lookupAddress=loadManager.getLeastLoaded(serviceUnit).getResourceId(); | String lookupAddress=loadManager.get().getLeastLoaded(serviceUnit).getResourceId(); | loadManager | loadManager.get() | pulsar | 1e02afb29fb3016f8a2ea8851c3b0fa56b4be85b | com.yahoo.pulsar.broker.namespace.NamespaceService | | _1 | loadManager |
---|
_2 | loadManager |
---|
| | | | Uses | True |
loadManager.doLoadShedding(); | loadManager.get().doLoadShedding(); | loadManager | loadManager.get() | pulsar | 1e02afb29fb3016f8a2ea8851c3b0fa56b4be85b | com.yahoo.pulsar.broker.loadbalance.LoadSheddingTask | | _1 | loadManager |
---|
_2 | loadManager |
---|
| | | | Uses | True |
loadManager.writeLoadReportOnZookeeper(); | loadManager.get().writeLoadReportOnZookeeper(); | loadManager | loadManager.get() | pulsar | 1e02afb29fb3016f8a2ea8851c3b0fa56b4be85b | com.yahoo.pulsar.broker.loadbalance.LoadReportUpdaterTask | | _1 | loadManager |
---|
_2 | loadManager |
---|
| | | | Uses | True |
return delegate.hashCode(); | return delegate.get().hashCode(); | delegate | delegate.get() | geode | a9d346f6581cd2861a9f9870574a441c9c439d36 | org.apache.geode.internal.ScheduledThreadPoolExecutorWithKeepAlive.DelegatingScheduledFuture | | | | | | Uses | True |
return delegate.equals(o); | return delegate.get().equals(o); | delegate | delegate.get() | geode | a9d346f6581cd2861a9f9870574a441c9c439d36 | org.apache.geode.internal.ScheduledThreadPoolExecutorWithKeepAlive.DelegatingScheduledFuture | | | | | | Uses | True |
return delegate.compareTo(o); | return delegate.get().compareTo(o); | delegate | delegate.get() | geode | a9d346f6581cd2861a9f9870574a441c9c439d36 | org.apache.geode.internal.ScheduledThreadPoolExecutorWithKeepAlive.DelegatingScheduledFuture | | | | | | Uses | True |
return delegate.getDelay(unit); | return delegate.get().getDelay(unit); | delegate | delegate.get() | geode | a9d346f6581cd2861a9f9870574a441c9c439d36 | org.apache.geode.internal.ScheduledThreadPoolExecutorWithKeepAlive.DelegatingScheduledFuture | | | | | | Uses | True |
delegate.cancel(true); | delegate.get().cancel(true); | delegate | delegate.get() | geode | a9d346f6581cd2861a9f9870574a441c9c439d36 | org.apache.geode.internal.ScheduledThreadPoolExecutorWithKeepAlive.DelegatingScheduledFuture | | | | | | Uses | True |
_exitSynchronizer.countDown(); | _exitSynchronizer.get().countDown(); | _exitSynchronizer | _exitSynchronizer.get() | jetty.project | d926f04217a9314fa9e2513251382b4cab78217f | org.eclipse.jetty.server.session.TestContextScopeListener | | _1 | _exitSynchronizer |
---|
_2 | _exitSynchronizer |
---|
| | | | Uses | True |
assert !content.hasRemaining(); | assert !content.get().hasRemaining(); | content | content.get() | cryptomator | edf92adfecb5fd6444cdf173c91c4c9cf60d0324 | org.cryptomator.filesystem.inmem.InMemoryFile | | | | | | Uses | True |
privateSession.evaluate(msg,true); | privateSession.get().evaluate(msg,true); | privateSession | privateSession.get() | graylog2-server | e6b859cf0565ce74fd535bfee9f452e0a1817e53 | org.graylog2.filters.RulesFilter | | _1 | privateSession |
---|
_2 | privateSession |
---|
| | | | Uses | True |
fragmentResultCacheContext.get().getFragmentResultCacheManager().put(fragmentResultCacheContext.get().getHashedCanonicalPlanFragment(),split.get(),outputPages); | fragmentResultCacheContext.get().get().getFragmentResultCacheManager().put(fragmentResultCacheContext.get().get().getHashedCanonicalPlanFragment(),split.get(),outputPages); | fragmentResultCacheContext | fragmentResultCacheContext.get() | presto | 8974bf2508711d7683cd1ad21d76e76319edfd89 | com.facebook.presto.operator.Driver | | _1 | fragmentResultCacheContext |
---|
_2 | fragmentResultCacheContext |
---|
| TCIVar | fragmentResultCacheContext |
---|
| | TCIVar | fragmentResultCacheContext |
---|
| Uses | True |
fragmentResultCacheContext.get().getFragmentResultCacheManager().put(fragmentResultCacheContext.get().getHashedCanonicalPlanFragment(),split.get(),outputPages); | fragmentResultCacheContext.get().get().getFragmentResultCacheManager().put(fragmentResultCacheContext.get().get().getHashedCanonicalPlanFragment(),split.get(),outputPages); | fragmentResultCacheContext | fragmentResultCacheContext.get() | presto | 8974bf2508711d7683cd1ad21d76e76319edfd89 | com.facebook.presto.operator.Driver | | _1 | fragmentResultCacheContext |
---|
_2 | fragmentResultCacheContext |
---|
| TCIVar | fragmentResultCacheContext |
---|
| | TCIVar | fragmentResultCacheContext |
---|
| Uses | True |
checkState(fragmentResultCacheContext.isPresent()); | checkState(fragmentResultCacheContext.get().isPresent()); | fragmentResultCacheContext | fragmentResultCacheContext.get() | presto | 8974bf2508711d7683cd1ad21d76e76319edfd89 | com.facebook.presto.operator.Driver | | _1 | fragmentResultCacheContext |
---|
_2 | fragmentResultCacheContext |
---|
| TCIVar | fragmentResultCacheContext |
---|
| | TCIVar | fragmentResultCacheContext |
---|
| Uses | True |
return fragmentResultCacheContext.isPresent() && split.get() != null && split.get().getConnectorSplit().getNodeSelectionStrategy() != NO_PREFERENCE; | return fragmentResultCacheContext.get().isPresent() && split.get() != null && split.get().getConnectorSplit().getNodeSelectionStrategy() != NO_PREFERENCE; | fragmentResultCacheContext | fragmentResultCacheContext.get() | presto | 8974bf2508711d7683cd1ad21d76e76319edfd89 | com.facebook.presto.operator.Driver | | _1 | fragmentResultCacheContext |
---|
_2 | fragmentResultCacheContext |
---|
| TCIVar | fragmentResultCacheContext |
---|
| | TCIVar | fragmentResultCacheContext |
---|
| Uses | True |
if(fragmentResultCacheContext.isPresent() && !(split.getConnectorSplit() instanceof RemoteSplit)) | if(fragmentResultCacheContext.get().isPresent() && !(split.getConnectorSplit() instanceof RemoteSplit)) | fragmentResultCacheContext | fragmentResultCacheContext.get() | presto | 8974bf2508711d7683cd1ad21d76e76319edfd89 | com.facebook.presto.operator.Driver | | _1 | fragmentResultCacheContext |
---|
_2 | fragmentResultCacheContext |
---|
| TCIVar | fragmentResultCacheContext |
---|
| | TCIVar | fragmentResultCacheContext |
---|
| Uses | True |
this.cachedResult.set(fragmentResultCacheContext.get().getFragmentResultCacheManager().get(fragmentResultCacheContext.get().getHashedCanonicalPlanFragment(),split)); | this.cachedResult.set(fragmentResultCacheContext.get().get().getFragmentResultCacheManager().get(fragmentResultCacheContext.get().get().getHashedCanonicalPlanFragment(),split)); | fragmentResultCacheContext | fragmentResultCacheContext.get() | presto | 8974bf2508711d7683cd1ad21d76e76319edfd89 | com.facebook.presto.operator.Driver | | _1 | fragmentResultCacheContext |
---|
_2 | fragmentResultCacheContext |
---|
| TCIVar | fragmentResultCacheContext |
---|
| | TCIVar | fragmentResultCacheContext |
---|
| Uses | True |
this.cachedResult.set(fragmentResultCacheContext.get().getFragmentResultCacheManager().get(fragmentResultCacheContext.get().getHashedCanonicalPlanFragment(),split)); | this.cachedResult.set(fragmentResultCacheContext.get().get().getFragmentResultCacheManager().get(fragmentResultCacheContext.get().get().getHashedCanonicalPlanFragment(),split)); | fragmentResultCacheContext | fragmentResultCacheContext.get() | presto | 8974bf2508711d7683cd1ad21d76e76319edfd89 | com.facebook.presto.operator.Driver | | _1 | fragmentResultCacheContext |
---|
_2 | fragmentResultCacheContext |
---|
| TCIVar | fragmentResultCacheContext |
---|
| | TCIVar | fragmentResultCacheContext |
---|
| Uses | True |
Preconditions.checkNotNull(lastBuild); | return Preconditions.checkNotNull(lastBuild.get()); | lastBuild | lastBuild.get() | buck | 1ddcf787f7b97d13c9322c982161e0b5a402d00b | com.facebook.buck.cli.BuildCommand | | | | | | Uses | True |
managementTask.run(); | managementTask.get().run(); | managementTask | managementTask.get() | geode | 42726bd99c9ebb57ec5d3e987d47ecae9f4ea3a7 | org.apache.geode.management.internal.LocalManager | | _1 | managementTask |
---|
_2 | managementTask |
---|
| | | | Uses | True |
managementTask.run(); | managementTask.get().run(); | managementTask | managementTask.get() | geode | 42726bd99c9ebb57ec5d3e987d47ecae9f4ea3a7 | org.apache.geode.management.internal.LocalManager | | _1 | managementTask |
---|
_2 | managementTask |
---|
| | | | Uses | True |
List<Future<InternalDistributedMember>> futureTaskList=executorService.invokeAll(giiTaskList); | List<Future<InternalDistributedMember>> futureTaskList=executorService.get().invokeAll(giiTaskList); | executorService | executorService.get() | geode | 42726bd99c9ebb57ec5d3e987d47ecae9f4ea3a7 | org.apache.geode.management.internal.FederatingManager | | _1 | executorService |
---|
_2 | executorService |
---|
| | | | Uses | True |
executorService.execute(task); | executorService.get().execute(task); | executorService | executorService.get() | geode | 42726bd99c9ebb57ec5d3e987d47ecae9f4ea3a7 | org.apache.geode.management.internal.FederatingManager | | _1 | executorService |
---|
_2 | executorService |
---|
| | | | Uses | True |
executorService.shutdownNow(); | executorService.get().shutdownNow(); | executorService | executorService.get() | geode | 42726bd99c9ebb57ec5d3e987d47ecae9f4ea3a7 | org.apache.geode.management.internal.FederatingManager | | _1 | executorService |
---|
_2 | executorService |
---|
| | | | Uses | True |
ExecutingQuery executingQuery=new ExecutingQuery(queryId,clientConnection,statement.username(),queryText,queryParameters,statement.getTransaction().getMetaData(),() -> statement.locks().activeLockCount(),statement.getPageCursorTracer(),threadId,threadName,clock,cpuClock,heapAllocation); | ExecutingQuery executingQuery=new ExecutingQuery(queryId,clientConnection,statement.username(),queryText,queryParameters,statement.getTransaction().getMetaData(),() -> statement.locks().activeLockCount(),statement.getPageCursorTracer(),threadId,threadName,clock,cpuClockRef.get(),heapAllocationRef.get()); | heapAllocation | heapAllocation.get() | neo4j | b0564802414028e71c8034da72774b1934cf1a7c | org.neo4j.kernel.impl.api.StackingQueryRegistrationOperations | | _1 | heapAllocation |
---|
_2 | heapAllocationRef |
---|
| | | | Uses | True |
ExecutingQuery executingQuery=new ExecutingQuery(queryId,clientConnection,statement.username(),queryText,queryParameters,statement.getTransaction().getMetaData(),() -> statement.locks().activeLockCount(),statement.getPageCursorTracer(),threadId,threadName,clock,cpuClock,heapAllocation); | ExecutingQuery executingQuery=new ExecutingQuery(queryId,clientConnection,statement.username(),queryText,queryParameters,statement.getTransaction().getMetaData(),() -> statement.locks().activeLockCount(),statement.getPageCursorTracer(),threadId,threadName,clock,cpuClockRef.get(),heapAllocationRef.get()); | cpuClock | cpuClock.get() | neo4j | b0564802414028e71c8034da72774b1934cf1a7c | org.neo4j.kernel.impl.api.StackingQueryRegistrationOperations | | | | | | Uses | True |
if(pubsubClient.isEOF() && notYetRead.isEmpty()) | if(pubsubClient.get().isEOF() && notYetRead.isEmpty()) | pubsubClient | pubsubClient.get() | beam | 9c6c32bb11ef80c3cbb744e23e4b8c312592a3f7 | org.apache.beam.sdk.io.PubsubUnboundedSource.PubsubReader | | _1 | pubsubClient |
---|
_2 | pubsubClient |
---|
| | | | Uses | True |
ackTimeoutMs=pubsubClient.ackDeadlineSeconds(subscription) * 1000; | ackTimeoutMs=pubsubClient.get().ackDeadlineSeconds(subscription) * 1000; | pubsubClient | pubsubClient.get() | beam | 9c6c32bb11ef80c3cbb744e23e4b8c312592a3f7 | org.apache.beam.sdk.io.PubsubUnboundedSource.PubsubReader | | _1 | pubsubClient |
---|
_2 | pubsubClient |
---|
| | | | Uses | True |
Collection<PubsubClient.IncomingMessage> receivedMessages=pubsubClient.pull(requestTimeMsSinceEpoch,subscription,PULL_BATCH_SIZE,true); | Collection<PubsubClient.IncomingMessage> receivedMessages=pubsubClient.get().pull(requestTimeMsSinceEpoch,subscription,PULL_BATCH_SIZE,true); | pubsubClient | pubsubClient.get() | beam | 9c6c32bb11ef80c3cbb744e23e4b8c312592a3f7 | org.apache.beam.sdk.io.PubsubUnboundedSource.PubsubReader | | _1 | pubsubClient |
---|
_2 | pubsubClient |
---|
| | | | Uses | True |
pubsubClient.modifyAckDeadline(subscription,ackIds,extensionSec); | pubsubClient.get().modifyAckDeadline(subscription,ackIds,extensionSec); | pubsubClient | pubsubClient.get() | beam | 9c6c32bb11ef80c3cbb744e23e4b8c312592a3f7 | org.apache.beam.sdk.io.PubsubUnboundedSource.PubsubReader | | _1 | pubsubClient |
---|
_2 | pubsubClient |
---|
| | | | Uses | True |
pubsubClient.modifyAckDeadline(subscription,ackIds,0); | pubsubClient.get().modifyAckDeadline(subscription,ackIds,0); | pubsubClient | pubsubClient.get() | beam | 9c6c32bb11ef80c3cbb744e23e4b8c312592a3f7 | org.apache.beam.sdk.io.PubsubUnboundedSource.PubsubReader | | _1 | pubsubClient |
---|
_2 | pubsubClient |
---|
| | | | Uses | True |
pubsubClient.acknowledge(subscription,ackIds); | pubsubClient.get().acknowledge(subscription,ackIds); | pubsubClient | pubsubClient.get() | beam | 9c6c32bb11ef80c3cbb744e23e4b8c312592a3f7 | org.apache.beam.sdk.io.PubsubUnboundedSource.PubsubReader | | _1 | pubsubClient |
---|
_2 | pubsubClient |
---|
| | | | Uses | True |
complete.execute(); | complete.get().execute(); | complete | complete.get() | ratpack | 6de4240955da151dfb6e1973654cd02ca99ebcff | ratpack.exec.internal.DefaultExecution.MultiEventExecStream | | | | | | Uses | True |
List<ConfigChange> configChanges=calcPropertyChanges(m_configProperties,newConfigProperties); | List<ConfigChange> configChanges=calcPropertyChanges(m_configProperties.get(),newConfigProperties); | m_configProperties | m_configProperties.get() | apollo | c6b4dd501b5b7f6413270a3c1ea56bebef54e2eb | com.ctrip.apollo.internals.DefaultConfig | | _1 | m_configProperties |
---|
_2 | m_configProperties |
---|
| | | | Uses | True |
if(newProperties.equals(m_configProperties)) | if(newProperties.equals(m_configProperties.get())) | m_configProperties | m_configProperties.get() | apollo | c6b4dd501b5b7f6413270a3c1ea56bebef54e2eb | com.ctrip.apollo.internals.DefaultConfig | | _1 | m_configProperties |
---|
_2 | m_configProperties |
---|
| | | | Uses | True |
value=m_configProperties.getProperty(key); | value=m_configProperties.get().getProperty(key); | m_configProperties | m_configProperties.get() | apollo | c6b4dd501b5b7f6413270a3c1ea56bebef54e2eb | com.ctrip.apollo.internals.DefaultConfig | | _1 | m_configProperties |
---|
_2 | m_configProperties |
---|
| | | | Uses | True |
return buildStageInfo(plan,stageExecutions); | return buildStageInfo(plan.get(),stageExecutions); | plan | plan.get() | presto | 0890b3dc4bb18e1e6567fe8e2ca82a81dcd3a9c0 | com.facebook.presto.execution.scheduler.SqlQueryScheduler | | | | | | Uses | True |
return buildStageInfo(plan,stageInfos); | return buildStageInfo(plan.get(),stageInfos); | plan | plan.get() | presto | 0890b3dc4bb18e1e6567fe8e2ca82a81dcd3a9c0 | com.facebook.presto.execution.scheduler.LegacySqlQueryScheduler | | | | | | Uses | True |
return createClientToServerConnection(nextServer,true); | return createClientToServerConnection(nextServer.get(),true); | nextServer | nextServer.get() | geode | 5e0b25a3247cb12075fd7bba97cb96b0e42dcb2c | org.apache.geode.cache.client.internal.pooling.ConnectionManagerJUnitTest.DummyFactory | | | | | | Uses | True |
if(excludedServers.contains(nextServer)) | if(excludedServers.contains(nextServer.get())) | nextServer | nextServer.get() | geode | 5e0b25a3247cb12075fd7bba97cb96b0e42dcb2c | org.apache.geode.cache.client.internal.pooling.ConnectionManagerJUnitTest.DummyFactory | | | | | | Uses | True |
return scmUsage.getUsed(); | return scmUsage.get().getUsed(); | scmUsage | scmUsage.get() | hadoop | 732133cb2a8f8667da1ae955d5ce73eef1a0436e | org.apache.hadoop.ozone.container.common.volume.VolumeUsage | | | | | | Uses | True |
cpuBoundSemaphore.acquire(); | cpuBoundSemaphore.get().acquire(); | cpuBoundSemaphore | cpuBoundSemaphore.get() | bazel | b5bfcc1ed0388fb5f0e3924d8fd33ea1bb3db0e1 | com.google.devtools.build.lib.skyframe.ConfiguredTargetFunction | | _1 | cpuBoundSemaphore |
---|
_2 | cpuBoundSemaphore |
---|
| | | | Uses | True |
currentExecutions.remove(watchId); | currentExecutions.get().remove(watchId); | currentExecutions | currentExecutions.get() | elasticsearch | 2c38d12e236a3279daa344bc8b52f0e8f49ad4b5 | org.elasticsearch.xpack.watcher.execution.ExecutionService | | _1 | currentExecutions |
---|
_2 | currentExecutions |
---|
| | | | Uses | True |
boolean executionAlreadyExists=currentExecutions.put(watchId,new WatchExecution(ctx,Thread.currentThread())); | boolean executionAlreadyExists=currentExecutions.get().put(watchId,new WatchExecution(ctx,Thread.currentThread())); | currentExecutions | currentExecutions.get() | elasticsearch | 2c38d12e236a3279daa344bc8b52f0e8f49ad4b5 | org.elasticsearch.xpack.watcher.execution.ExecutionService | | _1 | currentExecutions |
---|
_2 | currentExecutions |
---|
| | | | Uses | True |
response.cancelQuit(); | quitResponse.get().cancelQuit(); | response | response.get() | cryptomator | c6b786a771824444fabf764a10abfcee3128fa1f | org.cryptomator.ui.quit.QuitController | | | | | | Uses | True |
complete.execute(); | complete.get().execute(); | complete | complete.get() | ratpack | 9e10c1b42390fe8ca272bbf435cd1f79bd8216bf | ratpack.exec.internal.DefaultExecution.MultiEventExecStream | | | | | | Uses | True |
onFrame(serverSession,frame,callback); | onFrame(serverSession.get(),frame,callback); | serverSession | serverSession.get() | jetty.project | 55f82ceeecbcc2ae95a016557f0b8808e99562ac | org.eclipse.jetty.websocket.core.proxy.ProxyFrameHandler | | _1 | serverSession |
---|
_2 | serverSession |
---|
| | | | Uses | True |
SpawnResult result=fallbackRunner.exec(spawn,context); | SpawnResult result=fallbackRunner.get().exec(spawn,context); | fallbackRunner | fallbackRunner.get() | bazel | d6ce2643811b7814be43e4a6763c1663412831fe | com.google.devtools.build.lib.remote.RemoteSpawnRunner | | _1 | fallbackRunner |
---|
_2 | fallbackRunner |
---|
| | | | Uses | True |
return fallbackRunner.exec(spawn,context); | return fallbackRunner.get().exec(spawn,context); | fallbackRunner | fallbackRunner.get() | bazel | d6ce2643811b7814be43e4a6763c1663412831fe | com.google.devtools.build.lib.remote.RemoteSpawnRunner | | _1 | fallbackRunner |
---|
_2 | fallbackRunner |
---|
| | | | Uses | True |
return fallbackRunner.exec(spawn,context); | return fallbackRunner.get().exec(spawn,context); | fallbackRunner | fallbackRunner.get() | bazel | d6ce2643811b7814be43e4a6763c1663412831fe | com.google.devtools.build.lib.remote.RemoteSpawnRunner | | _1 | fallbackRunner |
---|
_2 | fallbackRunner |
---|
| | | | Uses | True |
id=mDb.get(mEdgesColumn,RocksUtils.toByteArray(inodeId,name)); | id=db().get(mEdgesColumn.get(),RocksUtils.toByteArray(inodeId,name)); | mEdgesColumn | mEdgesColumn.get() | alluxio | 646fe30a935d434cadb0b7f186b2c461f9a67b0c | alluxio.master.metastore.rocks.RocksInodeStore | | _1 | mEdgesColumn |
---|
_2 | mEdgesColumn |
---|
| | | | Uses | True |
mDb.delete(mEdgesColumn,mDisableWAL,RocksUtils.toByteArray(parentId,name)); | db().delete(mEdgesColumn.get(),mDisableWAL,RocksUtils.toByteArray(parentId,name)); | mEdgesColumn | mEdgesColumn.get() | alluxio | 646fe30a935d434cadb0b7f186b2c461f9a67b0c | alluxio.master.metastore.rocks.RocksInodeStore | | _1 | mEdgesColumn |
---|
_2 | mEdgesColumn |
---|
| | | | Uses | True |
mDb.put(mEdgesColumn,mDisableWAL,RocksUtils.toByteArray(parentId,childName),Longs.toByteArray(childId)); | db().put(mEdgesColumn.get(),mDisableWAL,RocksUtils.toByteArray(parentId,childName),Longs.toByteArray(childId)); | mEdgesColumn | mEdgesColumn.get() | alluxio | 646fe30a935d434cadb0b7f186b2c461f9a67b0c | alluxio.master.metastore.rocks.RocksInodeStore | | _1 | mEdgesColumn |
---|
_2 | mEdgesColumn |
---|
| | | | Uses | True |
inode=mDb.get(mInodesColumn,Longs.toByteArray(id)); | inode=db().get(mInodesColumn.get(),Longs.toByteArray(id)); | mInodesColumn | mInodesColumn.get() | alluxio | 646fe30a935d434cadb0b7f186b2c461f9a67b0c | alluxio.master.metastore.rocks.RocksInodeStore | | _1 | mInodesColumn |
---|
_2 | mInodesColumn |
---|
| | | | Uses | True |
mDb.put(mInodesColumn,mDisableWAL,Longs.toByteArray(inode.getId()),inode.toProto().toByteArray()); | db().put(mInodesColumn.get(),mDisableWAL,Longs.toByteArray(inode.getId()),inode.toProto().toByteArray()); | mInodesColumn | mInodesColumn.get() | alluxio | 646fe30a935d434cadb0b7f186b2c461f9a67b0c | alluxio.master.metastore.rocks.RocksInodeStore | | _1 | mInodesColumn |
---|
_2 | mInodesColumn |
---|
| | | | Uses | True |
mDb.delete(mInodesColumn,mDisableWAL,id); | db().delete(mInodesColumn.get(),mDisableWAL,id); | mInodesColumn | mInodesColumn.get() | alluxio | 646fe30a935d434cadb0b7f186b2c461f9a67b0c | alluxio.master.metastore.rocks.RocksInodeStore | | _1 | mInodesColumn |
---|
_2 | mInodesColumn |
---|
| | | | Uses | True |
meta=mDb.get(mBlockMetaColumn,Longs.toByteArray(id)); | meta=db().get(mBlockMetaColumn.get(),Longs.toByteArray(id)); | mBlockMetaColumn | mBlockMetaColumn.get() | alluxio | 646fe30a935d434cadb0b7f186b2c461f9a67b0c | alluxio.master.metastore.rocks.RocksBlockStore | | _1 | mBlockMetaColumn |
---|
_2 | mBlockMetaColumn |
---|
| | | | Uses | True |
if(result.getException() != null) | if(result.get().getException() != null) | result | result.get() | tomcat | 69c5b520a068ea5b9366fc077f49bd2fbef9ccf5 | org.apache.tomcat.websocket.FutureToSendHandler | | | | | | Uses | True |
throw new ExecutionException(result.getException()); | throw new ExecutionException(result.get().getException()); | result | result.get() | tomcat | 69c5b520a068ea5b9366fc077f49bd2fbef9ccf5 | org.apache.tomcat.websocket.FutureToSendHandler | | | | | | Uses | True |
if(result.getException() != null) | if(result.get().getException() != null) | result | result.get() | tomcat | 69c5b520a068ea5b9366fc077f49bd2fbef9ccf5 | org.apache.tomcat.websocket.FutureToSendHandler | | | | | | Uses | True |
throw new ExecutionException(result.getException()); | throw new ExecutionException(result.get().getException()); | result | result.get() | tomcat | 69c5b520a068ea5b9366fc077f49bd2fbef9ccf5 | org.apache.tomcat.websocket.FutureToSendHandler | | | | | | Uses | True |
assertThat(reference.get()).isSameAs(withStop); | assertThat(reference.get()).isSameAs(withStop.get()); | withStop | withStop.get() | geode | ae0d6bcdbc41a364b21bc5c55bd982271ad1284b | org.apache.geode.test.dunit.rules.tests.DistributedReferenceTest.SetWithStopInRemoteVm | | | | | | Uses | True |
reference.set(withStop); | reference.set(withStop.get()); | withStop | withStop.get() | geode | ae0d6bcdbc41a364b21bc5c55bd982271ad1284b | org.apache.geode.test.dunit.rules.tests.DistributedReferenceTest.SetWithStopInRemoteVm | | | | | | Uses | True |
assertThat(reference.get()).isSameAs(withStop); | assertThat(reference.get()).isSameAs(withStop.get()); | withStop | withStop.get() | geode | ae0d6bcdbc41a364b21bc5c55bd982271ad1284b | org.apache.geode.test.dunit.rules.tests.DistributedReferenceTest.SetWithStopInLocalVm | | | | | | Uses | True |
reference.set(withStop); | reference.set(withStop.get()); | withStop | withStop.get() | geode | ae0d6bcdbc41a364b21bc5c55bd982271ad1284b | org.apache.geode.test.dunit.rules.tests.DistributedReferenceTest.SetWithStopInLocalVm | | | | | | Uses | True |
reference.set(withStop); | reference.set(withStop.get()); | withStop | withStop.get() | geode | ae0d6bcdbc41a364b21bc5c55bd982271ad1284b | org.apache.geode.test.dunit.rules.tests.DistributedReferenceTest.SetWithStopInEachVm | | | | | | Uses | True |
assertThat(reference.get()).isSameAs(withDisconnect); | assertThat(reference.get()).isSameAs(withDisconnect.get()); | withDisconnect | withDisconnect.get() | geode | ae0d6bcdbc41a364b21bc5c55bd982271ad1284b | org.apache.geode.test.dunit.rules.tests.DistributedReferenceTest.SetWithDisconnectInRemoteVm | | _1 | withDisconnect |
---|
_2 | withDisconnect |
---|
| | | | Uses | True |
reference.set(withDisconnect); | reference.set(withDisconnect.get()); | withDisconnect | withDisconnect.get() | geode | ae0d6bcdbc41a364b21bc5c55bd982271ad1284b | org.apache.geode.test.dunit.rules.tests.DistributedReferenceTest.SetWithDisconnectInRemoteVm | | _1 | withDisconnect |
---|
_2 | withDisconnect |
---|
| | | | Uses | True |
assertThat(reference.get()).isSameAs(withDisconnect); | assertThat(reference.get()).isSameAs(withDisconnect.get()); | withDisconnect | withDisconnect.get() | geode | ae0d6bcdbc41a364b21bc5c55bd982271ad1284b | org.apache.geode.test.dunit.rules.tests.DistributedReferenceTest.SetWithDisconnectInLocalVm | | _1 | withDisconnect |
---|
_2 | withDisconnect |
---|
| | | | Uses | True |
reference.set(withDisconnect); | reference.set(withDisconnect.get()); | withDisconnect | withDisconnect.get() | geode | ae0d6bcdbc41a364b21bc5c55bd982271ad1284b | org.apache.geode.test.dunit.rules.tests.DistributedReferenceTest.SetWithDisconnectInLocalVm | | _1 | withDisconnect |
---|
_2 | withDisconnect |
---|
| | | | Uses | True |
assertThat(reference.get()).isSameAs(withDisconnect); | assertThat(reference.get()).isSameAs(withDisconnect.get()); | withDisconnect | withDisconnect.get() | geode | ae0d6bcdbc41a364b21bc5c55bd982271ad1284b | org.apache.geode.test.dunit.rules.tests.DistributedReferenceTest.SetWithDisconnectInEachVm | | _1 | withDisconnect |
---|
_2 | withDisconnect |
---|
| | | | Uses | True |
reference.set(withDisconnect); | reference.set(withDisconnect.get()); | withDisconnect | withDisconnect.get() | geode | ae0d6bcdbc41a364b21bc5c55bd982271ad1284b | org.apache.geode.test.dunit.rules.tests.DistributedReferenceTest.SetWithDisconnectInEachVm | | _1 | withDisconnect |
---|
_2 | withDisconnect |
---|
| | | | Uses | True |
assertThat(reference.get()).isSameAs(withClose); | assertThat(reference.get()).isSameAs(withClose.get()); | withClose | withClose.get() | geode | ae0d6bcdbc41a364b21bc5c55bd982271ad1284b | org.apache.geode.test.dunit.rules.tests.DistributedReferenceTest.SetWithCloseInRemoteVm | | | | | | Uses | True |
reference.set(withClose); | reference.set(withClose.get()); | withClose | withClose.get() | geode | ae0d6bcdbc41a364b21bc5c55bd982271ad1284b | org.apache.geode.test.dunit.rules.tests.DistributedReferenceTest.SetWithCloseInRemoteVm | | | | | | Uses | True |
assertThat(reference.get()).isSameAs(withClose); | assertThat(reference.get()).isSameAs(withClose.get()); | withClose | withClose.get() | geode | ae0d6bcdbc41a364b21bc5c55bd982271ad1284b | org.apache.geode.test.dunit.rules.tests.DistributedReferenceTest.SetWithCloseInLocalVm | | | | | | Uses | True |
reference.set(withClose); | reference.set(withClose.get()); | withClose | withClose.get() | geode | ae0d6bcdbc41a364b21bc5c55bd982271ad1284b | org.apache.geode.test.dunit.rules.tests.DistributedReferenceTest.SetWithCloseInLocalVm | | | | | | Uses | True |
assertThat(reference.get()).isSameAs(withClose); | assertThat(reference.get()).isSameAs(withClose.get()); | withClose | withClose.get() | geode | ae0d6bcdbc41a364b21bc5c55bd982271ad1284b | org.apache.geode.test.dunit.rules.tests.DistributedReferenceTest.SetWithCloseInEachVm | | | | | | Uses | True |
reference.set(withClose); | reference.set(withClose.get()); | withClose | withClose.get() | geode | ae0d6bcdbc41a364b21bc5c55bd982271ad1284b | org.apache.geode.test.dunit.rules.tests.DistributedReferenceTest.SetWithCloseInEachVm | | | | | | Uses | True |
assertThat(reference.get()).isSameAs(closeable); | assertThat(reference.get()).isSameAs(closeable.get()); | closeable | closeable.get() | geode | ae0d6bcdbc41a364b21bc5c55bd982271ad1284b | org.apache.geode.test.dunit.rules.tests.DistributedReferenceTest.SetCloseableInRemoteVm | | | | | | Uses | True |
reference.set(closeable); | reference.set(closeable.get()); | closeable | closeable.get() | geode | ae0d6bcdbc41a364b21bc5c55bd982271ad1284b | org.apache.geode.test.dunit.rules.tests.DistributedReferenceTest.SetCloseableInRemoteVm | | | | | | Uses | True |
assertThat(reference.get()).isSameAs(closeable); | assertThat(reference.get()).isSameAs(closeable.get()); | closeable | closeable.get() | geode | ae0d6bcdbc41a364b21bc5c55bd982271ad1284b | org.apache.geode.test.dunit.rules.tests.DistributedReferenceTest.SetCloseableInLocalVm | | | | | | Uses | True |
reference.set(closeable); | reference.set(closeable.get()); | closeable | closeable.get() | geode | ae0d6bcdbc41a364b21bc5c55bd982271ad1284b | org.apache.geode.test.dunit.rules.tests.DistributedReferenceTest.SetCloseableInLocalVm | | | | | | Uses | True |
assertThat(reference.get()).isSameAs(closeable); | assertThat(reference.get()).isSameAs(closeable.get()); | closeable | closeable.get() | geode | ae0d6bcdbc41a364b21bc5c55bd982271ad1284b | org.apache.geode.test.dunit.rules.tests.DistributedReferenceTest.SetCloseableInEachVm | | | | | | Uses | True |
reference.set(closeable); | reference.set(closeable.get()); | closeable | closeable.get() | geode | ae0d6bcdbc41a364b21bc5c55bd982271ad1284b | org.apache.geode.test.dunit.rules.tests.DistributedReferenceTest.SetCloseableInEachVm | | | | | | Uses | True |
assertThat(reference.get()).isSameAs(autoCloseable); | assertThat(reference.get()).isSameAs(autoCloseable.get()); | autoCloseable | autoCloseable.get() | geode | ae0d6bcdbc41a364b21bc5c55bd982271ad1284b | org.apache.geode.test.dunit.rules.tests.DistributedReferenceTest.SetAutoCloseableInRemoteVm | | _1 | autoCloseable |
---|
_2 | autoCloseable |
---|
| | | | Uses | True |
reference.set(autoCloseable); | reference.set(autoCloseable.get()); | autoCloseable | autoCloseable.get() | geode | ae0d6bcdbc41a364b21bc5c55bd982271ad1284b | org.apache.geode.test.dunit.rules.tests.DistributedReferenceTest.SetAutoCloseableInRemoteVm | | _1 | autoCloseable |
---|
_2 | autoCloseable |
---|
| | | | Uses | True |
assertThat(reference.get()).isSameAs(autoCloseable); | assertThat(reference.get()).isSameAs(autoCloseable.get()); | autoCloseable | autoCloseable.get() | geode | ae0d6bcdbc41a364b21bc5c55bd982271ad1284b | org.apache.geode.test.dunit.rules.tests.DistributedReferenceTest.SetAutoCloseableInLocalVm | | _1 | autoCloseable |
---|
_2 | autoCloseable |
---|
| | | | Uses | True |
reference.set(autoCloseable); | reference.set(autoCloseable.get()); | autoCloseable | autoCloseable.get() | geode | ae0d6bcdbc41a364b21bc5c55bd982271ad1284b | org.apache.geode.test.dunit.rules.tests.DistributedReferenceTest.SetAutoCloseableInLocalVm | | _1 | autoCloseable |
---|
_2 | autoCloseable |
---|
| | | | Uses | True |
assertThat(reference.get()).isSameAs(autoCloseable); | assertThat(reference.get()).isSameAs(autoCloseable.get()); | autoCloseable | autoCloseable.get() | geode | ae0d6bcdbc41a364b21bc5c55bd982271ad1284b | org.apache.geode.test.dunit.rules.tests.DistributedReferenceTest.SetAutoCloseableInEachVm | | _1 | autoCloseable |
---|
_2 | autoCloseable |
---|
| | | | Uses | True |
reference.set(autoCloseable); | reference.set(autoCloseable.get()); | autoCloseable | autoCloseable.get() | geode | ae0d6bcdbc41a364b21bc5c55bd982271ad1284b | org.apache.geode.test.dunit.rules.tests.DistributedReferenceTest.SetAutoCloseableInEachVm | | _1 | autoCloseable |
---|
_2 | autoCloseable |
---|
| | | | Uses | True |
assertThat(reference.get()).isSameAs(autoCloseable); | assertThat(reference.get()).isSameAs(autoCloseable.get()); | autoCloseable | autoCloseable.get() | geode | ae0d6bcdbc41a364b21bc5c55bd982271ad1284b | org.apache.geode.test.dunit.rules.tests.DistributedReferenceTest.DisableAutoCloseInLocalVm | | _1 | autoCloseable |
---|
_2 | autoCloseable |
---|
| | | | Uses | True |
reference.set(autoCloseable); | reference.set(autoCloseable.get()); | autoCloseable | autoCloseable.get() | geode | ae0d6bcdbc41a364b21bc5c55bd982271ad1284b | org.apache.geode.test.dunit.rules.tests.DistributedReferenceTest.DisableAutoCloseInLocalVm | | _1 | autoCloseable |
---|
_2 | autoCloseable |
---|
| | | | Uses | True |
startImporters(m_importers.values()); | startImporters(m_importers.get().values()); | m_importers | m_importers.get() | voltdb | 4b697a4af25891fe9027e7f787ee75d073d6f863 | org.voltdb.importer.ImporterLifeCycleManager | | _1 | m_importers |
---|
_2 | m_importers |
---|
| | | | Uses | True |
if(buildRunning && updateThread == null) | if(buildRunning && updateThread.get() == null) | updateThread | updateThread.get() | bazel | 2421c5f7de8d3aaa66049c78944a4ac3bf3367ab | com.google.devtools.build.lib.runtime.ExperimentalEventHandler | | _1 | updateThread |
---|
_2 | updateThread |
---|
| | | | Uses | True |
puttingThread.interrupt(); | puttingThread.get().interrupt(); | puttingThread | puttingThread.get() | geode | 52a6e4279b74f6c374061b9132df42fa8cb7f89c | org.apache.geode.internal.cache.InterruptDiskJUnitTest | | _1 | puttingThread |
---|
_2 | puttingThread |
---|
| | | | Uses | True |
return FileStateValue.create(rootedPath,tsgm); | return FileStateValue.create(rootedPath,tsgm.get()); | tsgm | tsgm.get() | bazel | c73051c6baad0aaaf1fdf34d5ad19602b8df628a | com.google.devtools.build.lib.skyframe.FileStateFunction | | | | | | Uses | True |
metadataHandler=new ActionMetadataHandler(state.inputArtifactData,action.getOutputs(),tsgm); | metadataHandler=new ActionMetadataHandler(state.inputArtifactData,action.getOutputs(),tsgm.get()); | tsgm | tsgm.get() | bazel | c73051c6baad0aaaf1fdf34d5ad19602b8df628a | com.google.devtools.build.lib.skyframe.ActionExecutionFunction | | | | | | Uses | True |
metadataHandler=new ActionMetadataHandler(state.inputArtifactData,action.getOutputs(),tsgm); | metadataHandler=new ActionMetadataHandler(state.inputArtifactData,action.getOutputs(),tsgm.get()); | tsgm | tsgm.get() | bazel | c73051c6baad0aaaf1fdf34d5ad19602b8df628a | com.google.devtools.build.lib.skyframe.ActionExecutionFunction | | | | | | Uses | True |
LOGGER.debug(STR0,path,sessionId,lock); | LOGGER.debug(STR0,path,sessionId.get(),lock); | sessionId | sessionId.get() | camel | 96a7cfdd691c35ca5c8d66de60103fa799aec9eb | org.apache.camel.component.consul.ha.ConsulClusterView | | | | | | Uses | True |
LOGGER.debug(STR0,sessionId); | LOGGER.debug(STR0,sessionId.get()); | sessionId | sessionId.get() | camel | 96a7cfdd691c35ca5c8d66de60103fa799aec9eb | org.apache.camel.component.consul.ha.ConsulClusterView | | | | | | Uses | True |
b.append(getContextPath()).append(',').append(getBaseResource()).append(',').append(_availability); | b.append(getContextPath()).append(',').append(getBaseResource()).append(',').append(_availability.get()); | _availability | _availability.get() | jetty.project | 66ec16006edb96a5904f60b9aa067dfeb4217528 | org.eclipse.jetty.server.handler.ContextHandler | | _1 | _availability |
---|
_2 | _availability |
---|
| | | | Uses | True |
@SuppressWarnings(STR0) Iterator iter=m_kSafetySet.iterator(); | @SuppressWarnings(STR0) Iterator iter=m_kSafetySet.get().iterator(); | m_kSafetySet | m_kSafetySet.get() | voltdb | 961af3d1940ee202019ee393450d56c6e00e27aa | org.voltdb.iv2.KSafetyStats | | _1 | m_kSafetySet |
---|
_2 | m_kSafetySet |
---|
| | | | Uses | True |