MCPcopy Create free account

hub / github.com/oracle/coherence / functions

Functions78,752 in github.com/oracle/coherence

↓ 2 callersMethodcloneMessage
Instantiate a copy of this message. This is quite different from the standard "clone" since only the "transmittable" portion of the message (and none
prj/coherence-core-components/src/main/java/com/tangosol/coherence/component/net/message/requestMessage/DistributedCacheRequest.java:253
↓ 2 callersMethodclose
()
prj/coherence-core/src/main/java/com/tangosol/internal/net/topic/NamedTopicView.java:103
↓ 2 callersMethodclose
Stop listening for connections on the specified address. @param addr the address to stop listening on @throws IOException on an I/O error
prj/coherence-core/src/main/java/com/oracle/coherence/common/internal/net/MultiplexedSocketProvider.java:2317
↓ 2 callersMethodclose
Release the acquired exclusive access to this Lockable.
prj/coherence-core/src/main/java/com/oracle/coherence/common/base/Lockable.java:45
↓ 2 callersMethodclose
Closes this {@link ClusteredTaskCoordinator} and notifies the {@link Task.Subscriber}s that there will no longer be any further items by calling {@lin
prj/coherence-concurrent/src/main/java/com/oracle/coherence/concurrent/executor/ClusteredTaskCoordinator.java:207
↓ 2 callersMethodclose
Closes the {@link Executor}.
prj/coherence-concurrent/src/main/java/com/oracle/coherence/concurrent/executor/ClusteredRegistration.java:1191
↓ 2 callersMethodclose
()
prj/coherence-json/src/main/java/com/oracle/coherence/io/json/genson/ext/jsr353/GensonJsonGenerator.java:310
↓ 2 callersMethodclose
Close all resources associated with the MessageBus
prj/coherence-core-components/src/main/java/com/tangosol/coherence/component/net/MessageHandler.java:431
↓ 2 callersMethodclose
Close the Connection.
prj/coherence-core-components/src/main/java/com/tangosol/coherence/component/net/extend/Connection.java:495
↓ 2 callersMethodcloseAppendFile
()
prj/coherence-core/src/main/java/com/tangosol/io/journal2/PartitionJournal.java:1703
↓ 2 callersMethodcloseChannel
Close socket channel. @param channel socket channel to close
prj/coherence-core/src/main/java/com/tangosol/coherence/memcached/server/MemcachedServer.java:428
↓ 2 callersMethodcloseFiles
Close all open file handles without clearing retained metadata.
prj/coherence-core/src/main/java/com/tangosol/io/journal2/PartitionJournal.java:1450
↓ 2 callersMethodcloseInternal
Close this extent without taking the extent lock. @throws IOException on I/O failure
prj/coherence-core/src/main/java/com/tangosol/persistence/journal/JournalPersistenceManager.java:3261
↓ 2 callersMethodcloseInternal
Internal version of close. @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:241
↓ 2 callersMethodcloseOutbound
Close the outbound socket. @param addr the {@link SocketAddress address} of the outbound socket
prj/coherence-core/src/main/java/com/tangosol/net/TcpDatagramSocket.java:1361
↓ 2 callersMethodcloseOutbound
Called to terminate or accept termination of the connection. If the caller passes <code>true</code> to this method, it is the caller's responsibility
prj/coherence-core/src/main/java/com/oracle/coherence/common/internal/net/ssl/SSLSocketChannel.java:657
↓ 2 callersMethodcloseQuietly
()
prj/coherence-core/src/main/java/com/tangosol/io/journal2/PartitionJournal.java:1713
↓ 2 callersMethodcloseRunners
()
prj/test/performance/psr/src/test/java/com/tangosol/coherence/performance/PsrPerformanceEnvironment.java:1191
↓ 2 callersMethodcloseSink
Closes the <em>sink</em> and <em>source</em>. @throws IOException if an error occurs
prj/coherence-http-netty/src/main/java/com/tangosol/coherence/http/netty/NettyHttpServer.java:1366
↓ 2 callersMethodcloseSubscriber
A helper method to close a {@link Task.Subscriber} using the calling {@link Thread}. <p> Closing a {@link Task.Subscriber} involves calling either {@l
prj/coherence-concurrent/src/main/java/com/oracle/coherence/concurrent/executor/AbstractTaskCoordinator.java:188
↓ 2 callersMethodcloseSubscriber
(CoherenceClusterMember member, String sId)
prj/test/distribution/topics-compatibility/topics-14.1.1.2206.3/src/test/java/topics/TopicSubscriber.java:42
↓ 2 callersMethodclusterModeTag
()
prj/test/performance/benchmarks/src/main/java/com/tangosol/coherence/performance/benchmarks/daemonpool/DaemonPoolDirectBenchmark.java:223
↓ 2 callersMethodcoerceType
Add the necessary instructions to the provided {@link MethodVisitor} coercing from the source type ({@code sTypeSrc}) to the destination type ({@code
prj/coherence-core/src/main/java/com/tangosol/internal/util/invoke/RemotableClassGenerator.java:78
↓ 2 callersMethodcollectIndexInconsistencies
(NamedCache cache, int cPartitions, int cExpectedIndexes)
prj/test/functional/persistence/src/main/java/persistence/BerkeleyDBSimplePersistenceTests.java:833
↓ 2 callersMethodcollectKeys
Return an array of the primary storage keys that belong to the specified partition. @param aoKeys the array into which the keys are to be copied, if
prj/coherence-core-components/src/main/java/com/tangosol/coherence/component/util/daemon/queueProcessor/service/grid/partitionedService/partitionedCache/Storage.java:1865
↓ 2 callersMethodcollectListeners
Collect all Listeners that should be notified for a given event. <p> <b>Note</b>: The returned value must be treated as an immutable. @param event th
prj/coherence-core/src/main/java/com/tangosol/util/MapListenerSupport.java:573
↓ 2 callersMethodcollectScheduledDistributions
Collect the scheduled partition distributions, grouped by the primary owner and storage index. A partition distribution (either primary or backup) is
prj/coherence-core/src/main/java/com/tangosol/net/partition/SimpleAssignmentStrategy.java:1887
↓ 2 callersMethodcollectSet
Extracts all keys in <tt>col</tt> where the key is contained by the PartitionSet or null is no PartitionSet is defined return all entries. The entries
prj/coherence-core/src/main/java/com/tangosol/internal/util/UnsafeSubSet.java:238
↓ 2 callersMethodcollection
()
prj/test/unit/coherence-core-tests/src/test/java/com/tangosol/util/ChainedSetTest.java:19
↓ 2 callersMethodcombineMembersLeft
Combine any members that that left during the poll with the set of members that failed during the snapshot operation. setMembersLeft is never null and
prj/coherence-core-components/src/main/java/com/tangosol/coherence/component/util/daemon/queueProcessor/service/grid/PartitionedService.java:29167
↓ 2 callersMethodcommit
()
prj/coherence-core/src/main/java/com/tangosol/coherence/http/DefaultHttpServer.java:507
↓ 2 callersMethodcommit
Asynchronously Commit a position. @param subscriber the subscriber @param nChannel the channel to commit @param position the position in the c
prj/coherence-core/src/main/java/com/tangosol/internal/net/topic/SubscriberConnector.java:168
↓ 2 callersMethodcommitInternal
Asynchronously commit the specified channel and position. @param nChannel the channel to commit @param position the position within the channel t
prj/coherence-core/src/main/java/com/tangosol/internal/net/topic/NamedTopicSubscriber.java:1440
↓ 2 callersMethodcommitInternal
Commit a sequence of mutating operations represented by the given token as an atomic unit. <p> Note: this method is guaranteed to only be called by a
prj/coherence-core/src/main/java/com/tangosol/persistence/AbstractPersistenceManager.java:2481
↓ 2 callersMethodcommitted
(CommitResult result, Position head)
prj/coherence-core/src/main/java/com/tangosol/internal/net/topic/BaseRemoteSubscriber.java:301
↓ 2 callersMethodcompactNext
Perform an incremental compaction of the next block.
prj/coherence-core/src/main/java/com/tangosol/io/nio/BinaryMap.java:3310
↓ 2 callersMethodcompactUntil
Perform an an incremental compact at the specified block. @param cbReqFree the number of bytes required to be free
prj/coherence-core/src/main/java/com/tangosol/io/nio/BinaryMap.java:3071
↓ 2 callersMethodcomparableMax
Return an aggregator that calculates a maximum of the {@link Comparable} values extracted from a set of entries in a Map. All the extracted objects wi
prj/coherence-core/src/main/java/com/tangosol/util/Aggregators.java:815
↓ 2 callersMethodcomparableMin
Return an aggregator that calculates a minimum of the {@link Comparable} values extracted from a set of entries in a Map. All the extracted objects wi
prj/coherence-core/src/main/java/com/tangosol/util/Aggregators.java:893
↓ 2 callersMethodcomparator
()
prj/coherence-core/src/main/java/com/tangosol/internal/util/PartitionedIndexMap.java:791
↓ 2 callersMethodcomparator
()
prj/coherence-core/src/main/java/com/tangosol/util/SafeSortedMap.java:587
↓ 2 callersMethodcompare
Compares extracted values (by specified <tt>ValueExtractor</tt>) of given arguments for order. @param o1 the first object to be compared @param o2
prj/test/functional/filter/src/main/java/filter/MyExtractorComparator.java:74
↓ 2 callersMethodcompareFiles
Compare two files to determine if the contents are equal @param sFile1 first text file to compare. @param sFile2 second text file. @return true if t
prj/test/functional/reporter/src/main/java/reporter/AbstractReporterTests.java:125
↓ 2 callersMethodcompareImportance
(Member member)
prj/coherence-core-components/src/main/java/com/tangosol/coherence/component/net/MessageHandler.java:481
↓ 2 callersMethodcompareTo
(Position other)
prj/coherence-core/src/main/java/com/tangosol/internal/net/topic/impl/paged/model/PagedPosition.java:113
↓ 2 callersMethodcompareTo
Compares this Lease object with the specified Lease object with an intent to figure out which lease is more "up-to-date". Returns a negative integer,
prj/coherence-core-components/src/main/java/com/tangosol/coherence/component/net/Lease.java:362
↓ 2 callersMethodcompareTo
Compares this object with the specified object for order. Returns a negative integer, zero, or a positive integer as this object is less than, equal
prj/coherence-core-components/src/main/java/com/tangosol/coherence/component/net/Member.java:806
↓ 2 callersMethodcomparingLong
Accepts a function that extracts a {@code long} sort key from a type {@code T}, and returns a {@code Comparator<T>} that compares by that sort key. @
prj/coherence-core/src/main/java/com/tangosol/util/function/Remote.java:2619
↓ 2 callersMethodcompartmentId
Returns the OCI compartment ID. @return the compartment ID
prj/coherence-rag-parent/models/coherence-rag-oci/src/main/java/com/oracle/coherence/rag/model/oci/OciGenAiStreamingChatModel.java:481
↓ 2 callersMethodcompartmentId
Returns the OCI compartment ID. @return the compartment ID
prj/coherence-rag-parent/models/coherence-rag-oci/src/main/java/com/oracle/coherence/rag/model/oci/OciGenAiEmbeddingModel.java:255
↓ 2 callersMethodcompileFinallyClauses
Compile "finally" clause invocations. @param code the assembler code attribute to compile to @exception CompilerException thrown if an error occur
prj/coherence-core/src/main/java/com/tangosol/dev/compiler/java/BranchStatement.java:65
↓ 2 callersMethodcomplete
{@inheritDoc}
prj/coherence-core/src/main/java/com/tangosol/io/pof/PofBufferReader.java:4353
↓ 2 callersMethodcompleteAppend
Update in-memory journal state after an entry has been appended successfully. @param info appending file metadata @param plan append plan @pa
prj/coherence-core/src/main/java/com/tangosol/io/journal2/PartitionJournal.java:505
↓ 2 callersMethodcompleteSync
Common code with onNext/onError for synchronization processing. @param binEntry entry being handled @param exception exception to be relayed, if s
prj/coherence-core/src/main/java/com/tangosol/net/cache/ReadWriteBackingMap.java:7468
↓ 2 callersMethodcompleteSynchronous
Complete this element's {@link CompletableFuture} synchronously. @param result the value to use to complete the future @param onComplete an opt
prj/coherence-core/src/main/java/com/tangosol/internal/net/topic/impl/paged/BatchingOperationsQueue.java:924
↓ 2 callersMethodcomposeURL
(int port)
prj/test/functional/metrics/src/main/java/metrics/AbstractMetricsFunctionalTest.java:152
↓ 2 callersMethodcomposite
Construct a composite processor for the specified array of individual entry processors. <p> The result of the composite processor execution is an arra
prj/coherence-core/src/main/java/com/tangosol/util/Processors.java:200
↓ 2 callersMethodcompute
Compute a new mapping for the specified key and its current value. <p> If the function returns {@code null}, the mapping is removed (or remains absent
prj/coherence-core/src/main/java/com/tangosol/net/AsyncNamedMap.java:1046
↓ 2 callersMethodcomputeAverageOutOfOrderOffset
compute the average out of order offset for packets which arrived out of order. @return the average out of order offset
prj/coherence-core/src/main/java/com/tangosol/net/DatagramTest.java:1808
↓ 2 callersMethodcomputeAveragePacketSize
compute average packet size. @return the average packet size received
prj/coherence-core/src/main/java/com/tangosol/net/DatagramTest.java:1865
↓ 2 callersMethodcomputeCpuCount
compute the total number of cores for this machine. @param cCores the core count @return core count
prj/coherence-core/src/main/java/com/tangosol/license/ProcessorInfo.java:863
↓ 2 callersMethodcomputeDeserializationClass
Compute class to be used to deserialize {@code serializedInstance}. Handles special casing for deserialization class for root objects. @param seriali
prj/coherence-json/src/test/java/com/oracle/coherence/io/json/AbstractSerializerTest.java:541
↓ 2 callersMethodcomputeMissingPackets
compute the number of missing packets. @return the number of missing packets
prj/coherence-core/src/main/java/com/tangosol/net/DatagramTest.java:1797
↓ 2 callersMethodcomputeRttNanos
Return the average round trip time of a packet in milliseconds. @return the average packet round trip time
prj/coherence-core/src/main/java/com/tangosol/net/DatagramTest.java:1775
↓ 2 callersMethodcomputeSlot
Helper for computing slot for a given sample value. @param cHigh the number of high precision slots @param nValue the value @return the slot
prj/coherence-core/src/main/java/com/oracle/coherence/common/internal/util/ScaledHistogram.java:70
↓ 2 callersMethodcomputeSuccessRate
compute the success rate for receiving packets. @return the success rate
prj/coherence-core/src/main/java/com/tangosol/net/DatagramTest.java:1818
↓ 2 callersMethodcomputeValLenOffset
Compute the offset of the {@code val_len} field for a STORE entry. @return offset of {@code val_len} relative to the entry start
prj/coherence-core/src/main/java/com/tangosol/io/journal2/JournalEntry.java:94
↓ 2 callersMethodcomputeVersionFromJavaHome
Compute java version from JAVA_HOME string. @param sJavaHome path to JAVA_HOME @return numeric Java version 5-11, 15 and on
prj/coherence-testing-support/src/main/java/com/oracle/coherence/testing/CheckJDK.java:80
↓ 2 callersMethodconcurrently
Specify that the {@link Task} should be executed concurrently on its assigned {@link Executor}s. <p> This is the default setting for execution. @retu
prj/coherence-concurrent/src/main/java/com/oracle/coherence/concurrent/executor/Task.java:476
↓ 2 callersMethodconfig
Returns the Lucene index configuration for this partial result. @return the LuceneIndex.Config instance
prj/coherence-lucene/src/main/java/com/oracle/coherence/lucene/LuceneSearch.java:521
↓ 2 callersMethodconfigure
Called to configure a {@link Context.Builder}. This allows addition of any language specific options to the {@link Context.Builder}. This builder will
prj/coherence-core/src/main/java/com/tangosol/internal/util/graal/ScriptHandler.java:38
↓ 2 callersMethodconfigure
Configure a newly created LogOutput instance using the supplied dependencies.
prj/coherence-core-components/src/main/java/com/tangosol/coherence/component/util/LogOutput.java:101
↓ 2 callersMethodconfigureBufferPool
Configure the BufferPool child component using the supplied dependencies.
prj/coherence-core-components/src/main/java/com/tangosol/coherence/component/util/daemon/queueProcessor/service/peer/acceptor/TcpAcceptor.java:451
↓ 2 callersMethodconfigureEviction
Configure the eviction type and policy. @param nType one of the EVICTION_POLICY_ enumerated values @param policy an external eviction policy, or n
prj/coherence-core/src/main/java/com/tangosol/net/cache/LocalCache.java:1634
↓ 2 callersMethodconfigureEviction
Configure the eviction type and policy. @param nType one of the EVICTION_POLICY_ enumerated values @param policy an external eviction policy, or n
prj/test/unit/coherence-tests/src/test/java/com/tangosol/net/cache/OldCache.java:1468
↓ 2 callersMethodconfigureEviction
Configure the eviction type and policy. @param nType one of the EVICTION_POLICY_ enumerated values @param policy an external eviction policy, or n
prj/test/unit/coherence-tests/src/test/java/com/tangosol/net/cache/OldOldCache.java:1242
↓ 2 callersMethodconfigureIndexWriter
Sets a consumer that can be used to customize the {@link IndexWriterConfig} before creating the index. This allows for fine-grained control over all a
prj/coherence-lucene/src/main/java/com/oracle/coherence/lucene/LuceneIndex.java:253
↓ 2 callersMethodconfigureJaxbMarshaller
Configure a JAXB marshaller. @param marshaller marshaller to configure @throws PropertyException when there is an error processing a property
prj/coherence-rest/src/main/java/com/tangosol/coherence/rest/io/JaxbXmlMarshaller.java:124
↓ 2 callersMethodconfigureMBeanContext
Configure service-level MBean context on active and backup managers. @param manager manager to configure @param role manager role
prj/coherence-core/src/main/java/com/tangosol/persistence/journal/JournalPersistenceEnvironment.java:278
↓ 2 callersMethodconfigureProxy
Configures Java HTTP proxy settings from standard environment variables. <p/> Supported environment variables: <ul> <li>{@code HTTP_PROXY} or {@code
prj/coherence-core/src/main/java/com/oracle/coherence/common/net/HttpProxyHelper.java:51
↓ 2 callersMethodconfigureProxyForScheme
Configures proxy settings for a specific URL scheme (http or https). <p/> This method reads the proxy configuration from environment variables for the
prj/coherence-core/src/main/java/com/oracle/coherence/common/net/HttpProxyHelper.java:68
↓ 2 callersMethodconfigureSSL
Configure HTTPS client. @return an HTTPS client
prj/test/functional/rest/src/main/java/rest/AbstractRestTests.java:1773
↓ 2 callersMethodconfigureSocket
Apply socket options to a socket. @param socket the socket to configure @throws SocketException on configuration error
prj/coherence-core/src/main/java/com/tangosol/net/TcpDatagramSocket.java:1198
↓ 2 callersMethodconfigureSocket
Configure the given ServerSocket. @param socket the ServerSocket to configure
prj/coherence-core-components/src/main/java/com/tangosol/coherence/component/util/daemon/queueProcessor/service/peer/acceptor/TcpAcceptor.java:463
↓ 2 callersMethodconfigureUnitCalculator
Configure a UnitCalculator for the specified ConfigurableCacheMap. @param xmlCache cache scheme that may contain a "unit-calculator" element @param
prj/coherence-core/src/main/java/com/tangosol/net/DefaultConfigurableCacheFactory.java:2355
↓ 2 callersMethodconfigureUnitCalculator
Configure the unit calculator type and implementation. @param nType one of the UNIT_CALCULATOR_ enumerated values @param calculator an externa
prj/coherence-core/src/main/java/com/tangosol/net/cache/LocalCache.java:1684
↓ 2 callersMethodconfigureUnitCalculator
Configure the unit calculator type and implementation. @param nType one of the UNIT_CALCULATOR_ enumerated values @param calculator an externa
prj/test/unit/coherence-tests/src/test/java/com/tangosol/net/cache/OldCache.java:1518
↓ 2 callersMethodconfigureUnitCalculator
Configure the unit calculator type and implementation. @param nType one of the UNIT_CALCULATOR_ enumerated values @param calculator an externa
prj/test/unit/coherence-tests/src/test/java/com/tangosol/net/cache/OldOldCache.java:1285
↓ 2 callersMethodconfiguredRawValues
(String sProperty, String sDefault)
prj/coherence-rag-parent/coherence-rag/src/main/java/com/oracle/coherence/rag/api/RagSecurity.java:766
↓ 2 callersMethodconfirmSubscriber
(long lSubscription, com.tangosol.internal.net.topic.impl.paged.model.SubscriberId subscriberId)
prj/coherence-core-components/src/main/java/com/tangosol/coherence/component/util/daemon/queueProcessor/service/grid/partitionedService/partitionedCache/PagedTopic.java:588
↓ 2 callersMethodconnect
Perform the actual connect to the peer @throws IOException on an I/O error
prj/coherence-core/src/main/java/com/oracle/coherence/common/internal/net/socketbus/AbstractSocketBus.java:1316
↓ 2 callersMethodconnect
Connect to the specified cluster member.
prj/coherence-core-components/src/main/java/com/tangosol/coherence/component/net/TcpRing.java:264
↓ 2 callersMethodconnect
Create a connection to the specified member. Called on the service thread when either (a) the specified Member is announced to join this Service; or
prj/coherence-core-components/src/main/java/com/tangosol/coherence/component/net/MessageHandler.java:500
↓ 2 callersMethodconsumeLiteral
Reads the next literal value into _booleanValue, _doubleValue or _intValue and returns the type of the readed literal, possible values are : INTEGER,
prj/coherence-json/src/main/java/com/oracle/coherence/io/json/genson/stream/JsonReader.java:517
↓ 2 callersMethodconsumeValue
()
prj/coherence-json/src/main/java/com/oracle/coherence/io/json/genson/stream/JsonReader.java:407
↓ 2 callersMethodcontains
Return true if the current rule contains the specified action mask. @param nMask the action bitmask to test for @return true if the current rule co
prj/coherence-core/src/main/java/com/tangosol/net/ConfigurableQuorumPolicy.java:459
↓ 2 callersMethodcontains
(int nId)
prj/coherence-core-components/src/main/java/com/tangosol/coherence/component/net/memberSet/SingleMemberSet.java:211
↓ 2 callersMethodcontainsAll
Return a filter that tests if the extracted collection contains all of the specified values. @param extractor the ValueExtractor to use @param setVa
prj/coherence-core/src/main/java/com/tangosol/util/Filters.java:399
↓ 2 callersMethodcontainsAll
(Collection<?> c)
prj/coherence-json/src/main/java/com/oracle/coherence/io/json/genson/ext/jsr353/GensonJsonArray.java:143
↓ 2 callersMethodcontainsAll
Optimized implementation.
prj/coherence-core-components/src/main/java/com/tangosol/coherence/component/util/daemon/queueProcessor/service/grid/partitionedService/partitionedCache/BinaryMap.java:889
← previousnext →13,601–13,700 of 78,752, ranked by callers