Code
Hub
Workspaces
Following
Trending
Connect
MCP
copy
Create free account
hub
/
github.com/oracle/coherence
/ functions
Functions
78,752 in github.com/oracle/coherence
⨍
Functions
78,752
◇
Types & classes
10,274
↓ 2 callers
Method
assertCloneEquals
Assert that the two DefaultInitiatorDependencies are equal. @param deps1 the first DefaultInitiatorDependencies object @param deps2 the second Defa
prj/test/unit/coherence-tests/src/test/java/com/tangosol/internal/net/service/peer/initiator/DefaultInitiatorDependenciesTest.java:110
↓ 2 callers
Method
assertCloneEquals
Assert that the two PartitionedServiceDependencies are equal. @param deps1 the first PartitionedServiceDependencies object @param deps2 the second
prj/test/unit/coherence-tests/src/test/java/com/tangosol/internal/net/service/grid/PartitionedServiceDependenciesTest.java:149
↓ 2 callers
Method
assertClusterStarted
Assert that a cluster is running in a remote process. @param custer the {@link CoherenceCluster} wrapping the remote processes @param sCluster
prj/test/functional/management/src/main/java/management/MultiCluster.java:103
↓ 2 callers
Method
assertCoherenceClient
(String sImageName, String sClient, RemoteCallable<Void>... assertions)
prj/coherence-docker/src/test/java/com/oracle/coherence/docker/DockerImageTests.java:144
↓ 2 callers
Method
assertComplementaryEntrySet
Verify that the two entry sets are complementary @param setEntries1 the first entry set @param setEntries2 the second entry set @param map
prj/coherence-testing-support/src/main/java/com/oracle/coherence/testing/AbstractTestInfrastructure.java:1564
↓ 2 callers
Method
assertDefault
Assert that the default SecurityDependencies is set correctly. @param deps the SecurityDependencies object
prj/test/unit/coherence-tests/src/test/java/com/tangosol/internal/net/security/DefaultSecurityDependenciesTest.java:47
↓ 2 callers
Method
assertDefaultConfiguration
(CoherenceConfiguration cfg)
prj/test/unit/coherence-core-tests/src/test/java/com/tangosol/net/CoherenceConfigurationTest.java:207
↓ 2 callers
Method
assertEvent
Assert that the client received the listener event @param fExpected true if client event expected
prj/test/functional/cache/src/main/java/cache/MapListenerTests.java:446
↓ 2 callers
Method
assertGetsMatchEntries
Verify that the results of get() match the values in the passed set of entries. @param map a Map to test @param setEntries a Set containing
prj/coherence-testing-support/src/main/java/com/oracle/coherence/testing/util/BaseMapTest.java:1433
↓ 2 callers
Method
assertHealthChecks
(CoherenceCluster cluster)
prj/test/functional/health/src/main/java/health/HealthRollingUpgradeTests.java:78
↓ 2 callers
Method
assertIdenticalCollections
Compare two Collection objects for equality. @param coll1 the first Collection to compare @param coll2 the second Collection to compare
prj/coherence-testing-support/src/main/java/com/oracle/coherence/testing/util/BaseMapTest.java:1250
↓ 2 callers
Method
assertIdenticalSets
Compare two Set objects for equality. <pre> Collection and Set (values, keySet, entrySet) size isEmpty contains iterator toArray
prj/coherence-testing-support/src/main/java/com/oracle/coherence/testing/util/BaseMapTest.java:1039
↓ 2 callers
Method
assertJsonPropertyAnnotations
Assert each property name in a JsonMap with an @class property has an explicit @JsonProperty annotation. Assist in identifying missing @JsonProperty a
prj/coherence-json/src/test/java/com/oracle/coherence/io/json/AbstractSerializerTest.java:289
↓ 2 callers
Method
assertLinesLessThanEightyCharacters
(String sText)
prj/test/unit/coherence-tests/src/test/java/com/tangosol/coherence/dslquery/queryplus/HelpTextTest.java:51
↓ 2 callers
Method
assertMBeansRegistered
(CoherenceCluster cluster)
prj/test/functional/jmx/src/main/java/jmx/BaseMBeanServerProxyNotificationTests.java:126
↓ 2 callers
Method
assertMapContainsKeySetKeys
Verify that the results of containsKey() is true for all objects in the passed set of keys. @param map a Map to test @param setKeys a Set conta
prj/coherence-testing-support/src/main/java/com/oracle/coherence/testing/util/BaseMapTest.java:1388
↓ 2 callers
Method
assertMapContainsValuesCollectionValues
Verify that the results of containsValue() is true for all values in the passed Collection of values. @param map a Map to test @param collVal
prj/coherence-testing-support/src/main/java/com/oracle/coherence/testing/util/BaseMapTest.java:1411
↓ 2 callers
Method
assertNoIndexInconsistencies
(NamedCache cache, int cPartitions, int cExpectedIndexes, String sStage)
prj/test/functional/persistence/src/main/java/persistence/BerkeleyDBSimplePersistenceTests.java:817
↓ 2 callers
Method
assertNotSameCollection
(Collection<?> c, String sMsg)
prj/coherence-core/src/main/java/com/tangosol/internal/net/queue/NamedMapBlockingDeque.java:434
↓ 2 callers
Method
assertOpen
@throws ConnectionException if the Channel is closed or closing
prj/coherence-core-components/src/main/java/com/tangosol/coherence/component/net/extend/Channel.java:350
↓ 2 callers
Method
assertPackedIntLength
@see ByteArrayWriteBuffer.ByteArrayBufferOutput#writePackedInt(int)
prj/test/unit/coherence-tests/src/test/java/com/tangosol/io/ByteArrayWriteBufferTest.java:1998
↓ 2 callers
Method
assertPackedLongLength
@see ByteArrayWriteBuffer.ByteArrayBufferOutput#writePackedLong(long)
prj/test/unit/coherence-tests/src/test/java/com/tangosol/io/ByteArrayWriteBufferTest.java:2013
↓ 2 callers
Method
assertPages
Returns a collection of pages from the results. <p> This method will throw a {@link TopicException} if any of the results is an error result. @param
prj/coherence-core/src/main/java/com/tangosol/internal/net/topic/impl/paged/agent/EnsureSubscriptionProcessor.java:339
↓ 2 callers
Method
assertRemoteClient
(CoherenceClusterMember client)
prj/test/functional/concurrent/src/main/java/concurrent/ExtendClientBootstrapTests.java:101
↓ 2 callers
Method
assertRemoteClient
(CoherenceClusterMember client)
prj/test/functional/bootstrap/src/main/java/bootstrap/ExtendClientTests.java:103
↓ 2 callers
Method
assertSerialization
(Serializer serializer)
prj/test/unit/coherence-core-tests/src/test/java/com/tangosol/util/BinaryDecoratedObjectTest.java:46
↓ 2 callers
Method
assertState
Ensures required state has been correctly set or throws an {@link IllegalStateException}. @throws {@link IllegalStateException} if member variables
prj/coherence-core/src/main/java/com/tangosol/io/pof/reflect/internal/ClassMetadata.java:547
↓ 2 callers
Method
assertTimeEquals
(Date expected, Date actual)
prj/test/unit/coherence-tests/src/test/java/com/tangosol/io/pof/generator/PortableTypeGeneratorTest.java:221
↓ 2 callers
Method
assertTopicType
Assert that a topic is a gRPC topic and return its {@link GrpcNamedTopicConnector}. @param topic the {@link NamedTopic} @return the {@link GrpcName
prj/coherence-grpc-client-common/src/main/java/com/oracle/coherence/grpc/client/common/topics/GrpcRemoteTopicService.java:411
↓ 2 callers
Method
assignIndexToValue
Inform the value of its virtual index prior to adding it to the array. This is used by the add() method as the value cannot know it's index prior to c
prj/coherence-core-components/src/main/java/com/tangosol/coherence/component/util/windowedArray/OptimisticWindowedArray.java:126
↓ 2 callers
Method
assignOrphan
Assign the specified orphaned partition to this member. This can only be called on a service thread.
prj/coherence-core-components/src/main/java/com/tangosol/coherence/component/util/daemon/queueProcessor/service/grid/PartitionedService.java:889
↓ 2 callers
Method
assignPartitionOwners
Assign a given partition to the given owners.
prj/coherence-core-components/src/main/java/com/tangosol/coherence/component/util/daemon/queueProcessor/service/grid/PartitionedService.java:1028
↓ 2 callers
Method
assignStores
Return a Map containing assignments of member id to stores based on the given constraints. <p> The algorithm will attempt to fairly distribute assignm
prj/coherence-core/src/main/java/com/tangosol/persistence/GUIDHelper.java:168
↓ 2 callers
Method
associate
Associate one (the child) with another channel (the parent). Once associated the child channel will be handled serially with respect to the parent an
prj/coherence-core/src/main/java/com/oracle/coherence/common/net/SelectionService.java:84
↓ 2 callers
Method
assumeJDKVersionLessThanOrEqual
Skip test if current Java version is greater than required {@code} nMaxVersion. Use when a tested feature has been deprecated and defaulted to not all
prj/coherence-testing-support/src/main/java/com/oracle/coherence/testing/CheckJDK.java:48
↓ 2 callers
Method
assumeManagement
Transition this node to become a management node, start an MBeanConnector and register the JMX service URL with the NameService. This method is called
prj/coherence-core-components/src/main/java/com/tangosol/coherence/component/net/management/Connector.java:436
↓ 2 callers
Method
async
()
prj/coherence-grpc-client-common/src/main/java/com/oracle/coherence/grpc/client/common/NamedCacheClient.java:366
↓ 2 callers
Method
atInfo
Obtains a {@link Logging} option to set logging to info level. @return a {@link Logging} option to set logging to info level
prj/coherence-bedrock/coherence-bedrock/src/main/java/com/oracle/bedrock/runtime/coherence/options/Logging.java:131
↓ 2 callers
Method
attachMBeanIfConfigured
Attach the manager to the service-level MBean if MBean context was set.
prj/coherence-core/src/main/java/com/tangosol/persistence/journal/JournalPersistenceManager.java:3696
↓ 2 callers
Method
authenticate
Perform SASL Plain Authentication and return authenticated Subject. @param abPayload the value from the request message @return the authenticated S
prj/coherence-core/src/main/java/com/tangosol/coherence/memcached/DefaultRequestHandler.java:637
↓ 2 callers
Method
autoDetect
Auto-detects the {@link Member} based on the current environment. @return a {@link Member}
prj/coherence-concurrent/src/main/java/com/oracle/coherence/concurrent/executor/options/Member.java:89
↓ 2 callers
Method
autoStartServicesSafe
A {@link Predicate} to determine if all the services of {@link CoherenceClusterMember}s are safe. @return a {@link Predicate}
prj/coherence-bedrock/coherence-bedrock/src/main/java/com/oracle/bedrock/runtime/coherence/CoherenceCluster.java:300
↓ 2 callers
Method
available
Returns the number of bytes that can be read (or skipped over) from this input stream without blocking by the next caller of a method for this input s
prj/coherence-core/src/main/java/com/tangosol/io/nio/ByteBufferInputStream.java:183
↓ 2 callers
Method
averagingInt
Returns a {@code Collector} that produces the arithmetic mean of an integer-valued function applied to the input elements. If no elements are present
prj/coherence-core/src/main/java/com/tangosol/util/stream/RemoteCollectors.java:588
↓ 2 callers
Method
averagingLong
Returns a {@code Collector} that produces the arithmetic mean of a long-valued function applied to the input elements. If no elements are present, th
prj/coherence-core/src/main/java/com/tangosol/util/stream/RemoteCollectors.java:614
↓ 2 callers
Method
await
(long cMillis)
prj/coherence-core/src/main/java/com/oracle/coherence/common/base/SingleWaiterMultiNotifier.java:40
↓ 2 callers
Method
await
(CountDownLatch latch)
prj/test/unit/coherence-core-tests/src/test/java/com/tangosol/persistence/journal/JournalPersistenceMBeanRegistryTest.java:312
↓ 2 callers
Method
awaitDone
()
prj/test/unit/coherence-tests/src/test/java/com/tangosol/coherence/component/util/VirtualDaemonPoolComponentTest.java:2110
↓ 2 callers
Method
awaitDone
()
prj/test/unit/coherence-tests/src/test/java/com/tangosol/coherence/component/util/VirtualDaemonPoolComponentTest.java:2187
↓ 2 callers
Method
awaitFuture
(CompletableFuture<T> future, long nMillis)
prj/coherence-grpc-client-common/src/main/java/com/oracle/coherence/grpc/client/common/v1/GrpcConnectionV1.java:501
↓ 2 callers
Method
awaitLatestGuardable
(int cExpected)
prj/test/functional/core/src/main/java/com/tangosol/coherence/component/util/DaemonPoolIT.java:1635
↓ 2 callers
Method
awaitLocksReleasedBy
Wait until the server-side lock holder no longer references a failed owner. @param member the member to query from @param sLockName the lock nam
prj/test/functional/concurrent/src/main/java/concurrent/locks/AbstractClusteredRemoteReadWriteLockExtendIT.java:507
↓ 2 callers
Method
balancedInsertion
Insert a node into a tree and rebalance. @param parent the location at which to insert the node @param child the node to insert
prj/coherence-core/src/main/java/com/tangosol/util/AbstractSparseArray.java:798
↓ 2 callers
Method
barEntryInternal
Internal version of bar-entry. @param oContender the lock contender @param cMillis the timeout @return true iff barred
prj/coherence-core/src/main/java/com/oracle/coherence/common/util/ThreadGate.java:153
↓ 2 callers
Method
beforeAll
(ExtensionContext context)
prj/test/functional/grpc-client-tck/src/main/java/grpc/client/ServerHelper.java:84
↓ 2 callers
Method
beforeClassSetup
()
prj/test/functional/jcache/src/main/java/com/tangosol/coherence/jcachetesting/AbstractCoherenceCacheTests.java:102
↓ 2 callers
Method
begin
(int character, JsonType type)
prj/coherence-json/src/main/java/com/oracle/coherence/io/json/genson/stream/JsonReader.java:449
↓ 2 callers
Method
begin
()
prj/coherence-core-components/src/main/java/com/tangosol/coherence/component/util/deltaMap/TransactionMap.java:195
↓ 2 callers
Method
beginCollection
{@inheritDoc}
prj/coherence-core/src/main/java/com/tangosol/io/pof/DuplexingPofHandler.java:300
↓ 2 callers
Method
beginInternal
Begin a sequence of mutating operations that should be committed atomically and return a token that represents the atomic unit. <p> Note: this method
prj/coherence-core/src/main/java/com/tangosol/persistence/AbstractPersistenceManager.java:2466
↓ 2 callers
Method
beginMap
{@inheritDoc}
prj/coherence-core/src/main/java/com/tangosol/io/pof/DuplexingPofHandler.java:354
↓ 2 callers
Method
beginUserType
{@inheritDoc}
prj/coherence-core/src/main/java/com/tangosol/io/pof/WritingPofHandler.java:1318
↓ 2 callers
Method
benchmarkLogLevel
()
prj/test/performance/benchmarks/src/main/java/com/tangosol/coherence/performance/benchmarks/daemonpool/MultiMemberBenchmarkState.java:411
↓ 2 callers
Method
bigDecimalValue
()
prj/coherence-json/src/main/java/com/oracle/coherence/io/json/genson/ext/jsr353/GensonJsonNumber.java:77
↓ 2 callers
Method
bindService
Bind this assignment strategy to the specified partitioned service, and return the bound service. @param sService the name of the service to bind @
prj/coherence-core/src/main/java/com/tangosol/net/partition/MirroringAssignmentStrategy.java:146
↓ 2 callers
Method
boundedPrincipal
(String sPrincipal)
prj/coherence-rag-parent/coherence-rag/src/main/java/com/oracle/coherence/rag/api/RagSecurity.java:864
↓ 2 callers
Method
breakLines
Breaks the specified string into a multi-line string. @param sText the string to break @param nWidth the max width of resulting lines (including t
prj/coherence-core/src/main/java/com/oracle/coherence/common/base/Formatting.java:428
↓ 2 callers
Method
build
(String query)
prj/test/unit/coherence-tests/src/test/java/com/tangosol/coherence/dslquery/queryplus/TraceStatementBuilderTest.java:99
↓ 2 callers
Method
buildDeltaMap
Build a table of all child (local) names that have deltas that would require classes to be generated. @param tblDelta the table into which the local
prj/coherence-core/src/main/java/com/tangosol/dev/component/Component.java:7733
↓ 2 callers
Method
buildDirectory
Build the full directory path for enumerating some item from the OS repository. @param nType the item type @param sPackage the name of the p
prj/coherence-core/src/main/java/com/tangosol/dev/component/OSStorage.java:1083
↓ 2 callers
Method
buildMessage
Return the failure message. @return the failure message
prj/coherence-testing-support/src/main/java/com/oracle/coherence/testing/util/CatchConcurrentExceptionsRule.java:114
↓ 2 callers
Method
buildSocketAddressProvider
()
prj/coherence-grpc-client-common/src/main/java/com/oracle/coherence/grpc/client/common/AbstractGrpcChannelFactory.java:268
↓ 2 callers
Method
bundle
Attempt to bundling two objects. @param oSrc the source object @param oDst the destination object @return true if oSrc was bundled into oDst
prj/coherence-core-components/src/main/java/com/tangosol/coherence/component/util/queue/concurrentQueue/balancedQueue/BundlingQueue.java:570
↓ 2 callers
Method
by
Return a Filtered option with the specified filter. @param filter the filter @return the Filtered option
prj/coherence-core/src/main/java/com/tangosol/net/topic/Subscriber.java:1546
↓ 2 callers
Method
cacheNameForDeque
Return the name of the cache used to hold queue content fpr a given deque name. @param sName the name of the queue @return the name of the cache us
prj/coherence-concurrent/src/main/java/com/oracle/coherence/concurrent/Queues.java:204
↓ 2 callers
Method
cacheNameForPagedQueue
Return the name of the cache used to hold queue content fpr a given paged queue name. @param sName the name of the queue @return the name of the ca
prj/coherence-concurrent/src/main/java/com/oracle/coherence/concurrent/Queues.java:216
↓ 2 callers
Method
cacheStoreRemoveOnWriteBehind
(String sCacheName)
prj/test/functional/rwbm/src/main/java/rwbm/ReadWriteBackingMapTests.java:3255
↓ 2 callers
Method
calcBodyLength
@see Directed#selectType @see Sequel#selectType
prj/coherence-core-components/src/main/java/com/tangosol/coherence/component/net/packet/MessagePacket.java:318
↓ 2 callers
Method
calcHeaderLength
@see Directed#selectType @see Sequel#selectType
prj/coherence-core-components/src/main/java/com/tangosol/coherence/component/net/packet/messagePacket/Broadcast.java:216
↓ 2 callers
Method
calcHeaderLength
@see Directed#selectType @see Sequel#selectType
prj/coherence-core-components/src/main/java/com/tangosol/coherence/component/net/packet/messagePacket/Sequel.java:170
↓ 2 callers
Method
calcUTF
Figure out how many bytes it will take to hold the passed String. <p> This method is tightly bound to formatUTF. @param s the String @return the bi
prj/coherence-core/src/main/java/com/tangosol/io/AbstractWriteBuffer.java:995
↓ 2 callers
Method
calculateBatchSize
Calculate the number of partitions that can be included in a partial response given the size of a single partition's worth of results. @param cPart
prj/coherence-core-components/src/main/java/com/tangosol/coherence/component/net/extend/message/request/NamedCacheRequest.java:139
↓ 2 callers
Method
calculateBinarySize
Return the physical size of the given Collection of Binary instances. @param col the Collection @param fEntries if true, the given Collection conta
prj/coherence-core-components/src/main/java/com/tangosol/coherence/component/net/extend/message/request/NamedCacheRequest.java:164
↓ 2 callers
Method
calculateCapacity
Calculate capacity of a HashSet or HashMap that will require no rehashing unless the specified maximum number of elements/entries is exceeded. @param
prj/coherence-core/src/main/java/com/tangosol/util/Base.java:139
↓ 2 callers
Method
calculateEndangered
Calculate the total number of endangered partitions. Used by the JMX.
prj/coherence-core-components/src/main/java/com/tangosol/coherence/component/util/daemon/queueProcessor/service/grid/PartitionedService.java:1158
↓ 2 callers
Method
calculateExpiry
Calculate the expiry timestamp based on the expiry delay value. @param cDelay the expiry delay @return the expiry timestamp
prj/coherence-core/src/main/java/com/tangosol/net/cache/BackingMapBinaryEntry.java:413
↓ 2 callers
Method
calculateFairShare
Return the "fair share" (F) load. It is a ceiling for the load on a for fully balance distribution. The fairness goal is to achieve such a state that
prj/coherence-core/src/main/java/com/tangosol/net/partition/SimpleAssignmentStrategy.java:2369
↓ 2 callers
Method
calculateHashIncrement
Provide an arbitrary prime increment to add to a hash code in order to determine the next index in a hash chain in an open hash data structure. <p> Th
prj/coherence-core/src/main/java/com/tangosol/util/OpenHashMap.java:911
↓ 2 callers
Method
calculateIteratorEffectiveness
Helper method to calculate effectiveness (or rather ineffectiveness) of a simple iteration against a key set that has to be performed due to an absenc
prj/coherence-core/src/main/java/com/tangosol/util/filter/ExtractorFilter.java:219
↓ 2 callers
Method
calculateKeyPartition
Determine the partition to which the given key should be assigned for the specified PartitionService, taking into consideration the associations provi
prj/coherence-core/src/main/java/com/tangosol/net/partition/DefaultKeyPartitioningStrategy.java:75
↓ 2 callers
Method
calculateMinThreshold
Calculate the minimum number of storage enabled nodes necessary to proceed with the service recovery. @param cLast the "last well-formed" member set
prj/coherence-core/src/main/java/com/tangosol/net/ConfigurableQuorumPolicy.java:889
↓ 2 callers
Method
calculateMinimumNodeCount
Given a set of Member objects, calculate the minimum number of nodes on a single machine. @param setMembers the member set @return the minimum numb
prj/coherence-core/src/main/java/com/tangosol/net/ConfigurableQuorumPolicy.java:979
↓ 2 callers
Method
calculateOwnershipConflicts
Calculate the PartitionSet of conflicting partitions.
prj/coherence-core-components/src/main/java/com/tangosol/coherence/component/util/daemon/queueProcessor/service/grid/PartitionedService.java:1275
↓ 2 callers
Method
calculatePartition
Return the partition associated with the specified hash value in the specified PartitionedService. @param service the PartitionedService @param nHas
prj/coherence-core/src/main/java/com/tangosol/net/partition/DefaultKeyPartitioningStrategy.java:124
↓ 2 callers
Method
calculateRequestTimeout
Calculate the default timeout in milliseconds for the given Request. @param request the Request @return the default timeout for the given Request i
prj/coherence-core-components/src/main/java/com/tangosol/coherence/component/net/extend/Channel.java:379
↓ 2 callers
Method
calculateSize
Calculate the memory footprint for this instance. The calculation is discretionary to the implementation. <p> Note: If utilizing {@link SimpleMemoryCa
prj/coherence-core/src/main/java/com/tangosol/util/Sizable.java:32
↓ 2 callers
Method
calculateSizeCode
Determine which "free bucket" a block of a particular size would go into. @param cbBlock the size of the block @return the size code for a block of
prj/coherence-core/src/main/java/com/tangosol/io/nio/BinaryMap.java:3563
↓ 2 callers
Method
calculateStatsId
Calculate a somewhat unique ID for the type of the passed Object. @param o a user type value @return an ID that is hopefully unique across the set
prj/coherence-core/src/main/java/com/tangosol/util/ExternalizableHelper.java:3688
↓ 2 callers
Method
calculateTotalLength
Calculate the total number of element in the array of arrays. @param aao an array of arrays @return the total number of elements
prj/coherence-core/src/main/java/com/tangosol/util/ImmutableMultiList.java:517
↓ 2 callers
Method
calculateUnits
Calculate a cache cost for the specified object. <p> The default implementation uses the unit calculator type of the containing cache. @param oValue
prj/coherence-core/src/main/java/com/tangosol/net/cache/LocalCache.java:2822
← previous
next →
13,401–13,500 of 78,752, ranked by callers