| 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 |