MCPcopy Create free account

hub / github.com/oracle/coherence / functions

Functions78,752 in github.com/oracle/coherence

⨍ Functions 78,752◇ Types & classes 10,274
↓ 2 callersMethodensureBackingMapContext
Shortcut version of getBackingMapContext by name, for callers which already hold the storage.
prj/coherence-core-components/src/main/java/com/tangosol/coherence/component/util/WrapperContext.java:137
↓ 2 callersMethodensureBeanQuery
Create/Obtain the MBeanQuery. @return the MBeanQuery
prj/coherence-core/src/main/java/com/tangosol/coherence/reporter/JMXQueryHandler.java:538
↓ 2 callersMethodensureBinaryValue
(BackingMapContext context, Binary binary, Object oValue)
prj/coherence-core/src/main/java/com/tangosol/internal/net/queue/processor/AbstractQueueProcessor.java:210
↓ 2 callersMethodensureBound
Ensure that the socket is bound. @throws SocketException if an I/O error occurs
prj/coherence-core/src/main/java/com/tangosol/net/TcpDatagramSocket.java:1210
↓ 2 callersMethodensureBuffer
Return a ByteBuffer from the optimal PoolSegment for a specific count of bytes. @param cb the size to match @return the buffer
prj/coherence-core/src/main/java/com/oracle/coherence/common/internal/io/SegmentedBufferManager.java:351
↓ 2 callersMethodensureBufferedEntryCapacity
Ensure the reusable buffered-append array can hold the specified entry. @param cbEntry required entry size @return the reusable entry buffer
prj/coherence-core/src/main/java/com/tangosol/io/journal2/PartitionJournal.java:758
↓ 2 callersMethodensureCache
Ensure the NamedCache associated with the RequestHandler. @param subject Subject associated with the client
prj/coherence-core/src/main/java/com/tangosol/coherence/memcached/DefaultRequestHandler.java:653
↓ 2 callersMethodensureCache
Return the ConfigurableCacheMap that uses this eviction policy. <p> If the ConfigurableCacheMap property has not been intialized, it is set to the Con
prj/coherence-core/src/main/java/com/tangosol/net/cache/AbstractEvictionPolicy.java:88
↓ 2 callersMethodensureCache
(String sName, ClassLoader loader)
prj/coherence-core/src/main/java/com/tangosol/net/internal/ViewCacheService.java:103
↓ 2 callersMethodensureCache
Obtain the specified {@link NamedCache}. @param scope the scope name for the cache @param name the cache name @param loader the {@link ClassLoa
prj/test/functional/grpc-proxy-tck/src/main/java/grpc/proxy/BaseGrpcIT.java:344
↓ 2 callersMethodensureCache
(ConfigurableCacheFactory factory)
prj/test/functional/persistence/src/main/java/persistence/JournalBackingMapRecoveryBenchmarkTests.java:150
↓ 2 callersMethodensureCacheInternal
Implementation of {@link #ensureTypedCache(String, ClassLoader, TypeAssertion)}
prj/coherence-core/src/main/java/com/tangosol/net/ExtensibleConfigurableCacheFactory.java:250
↓ 2 callersMethodensureChannel
Return the Channel used by this remote topic. If the Channel is null or is not open, this method throws an exception. @return a Channel that can be u
prj/coherence-core-components/src/main/java/com/tangosol/coherence/component/net/extend/RemotePublisher.java:160
↓ 2 callersMethodensureChunksPublisher
Ensures a chunks publisher is available and active. <p/> This method creates a new chunks publisher if none exists or if the current publisher is inac
prj/coherence-rag-parent/coherence-rag/src/main/java/com/oracle/coherence/rag/api/Store.java:963
↓ 2 callersMethodensureClassLoader
Ensures we have a non-null {@link ClassLoader} that we can use for loading classes. @param loader the proposed {@link ClassLoader}, which may be <co
prj/coherence-core/src/main/java/com/tangosol/coherence/config/builder/StaticFactoryInstanceBuilder.java:143
↓ 2 callersMethodensureClone
(Object o)
prj/coherence-core-components/src/main/java/com/tangosol/coherence/component/util/transactionCache/Local.java:344
↓ 2 callersMethodensureCoherenceSession
()
prj/test/functional/bootstrap/src/main/java/bootstrap/ExtendApp.java:36
↓ 2 callersMethodensureCollection
Return a Collection representation of the specified value, which could be a Collection, Object[], scalar, or NO_VALUE. @param oValue the value @ret
prj/coherence-core/src/main/java/com/tangosol/util/SimpleMapIndex.java:405
↓ 2 callersMethodensureCollectionInternal
(String sName, Class<C> clsCollection, ClassLoader loader, ScopedReferenceStore<C> store,
prj/coherence-core/src/main/java/com/tangosol/net/ExtensibleConfigurableCacheFactory.java:412
↓ 2 callersMethodensureCollectionInternal
(String sName, Class<Q> clzQueue, NamedQueueScheme<Q> scheme, Session session)
prj/coherence-concurrent/src/main/java/com/oracle/coherence/concurrent/Queues.java:241
↓ 2 callersMethodensureCompatibility
Ensure that the specified buffer is compatible with this manager. <p> The AbstractBufferManager implementation is a no-op. @param buff the buffer to
prj/coherence-core/src/main/java/com/oracle/coherence/common/internal/io/AbstractBufferManager.java:180
↓ 2 callersMethodensureCompatible
Ensure that the given histogram is compatible with this histogram. @param histThat the histogram to ensure compatibility with
prj/test/performance/psr/src/main/java/com/tangosol/coherence/performance/psr/Histogram.java:424
↓ 2 callersMethodensureConfigCCFMap
Ensure that a map from URI to ConfigurableCacheFactory for the specified loader exists (creating it if necessary). @param loader the class loader to
prj/coherence-core/src/main/java/com/tangosol/net/ScopedCacheFactoryBuilder.java:337
↓ 2 callersMethodensureConfigMap
Ensure that a map from URL to ConfigurableCacheFactory for the specified loader exists (creating it if necessary). @param loader the class loader to
prj/coherence-core/src/main/java/com/tangosol/net/ScopedCacheFactoryBuilder.java:358
↓ 2 callersMethodensureConnection
Obtain a Connection for the specified address. @param addr the destination address @return the corresponding connection @throws IOException if an
prj/coherence-core/src/main/java/com/tangosol/net/TcpDatagramSocket.java:1305
↓ 2 callersMethodensureConnection
Ensures that we have a connection to the SFTP endpoint. @throws IOException if a connection cannot be established or there is an error
prj/examples/tutorials/210-archiver/src/main/java/com/oracle/coherence/tutorials/archiver/SFTPSnapshotArchiver.java:474
↓ 2 callersMethodensureConverters
Instantiate the {@link Converter converters} necessary to support the processing mode that this {@code ContinuousQueryCache} will be operating under.
prj/coherence-core/src/main/java/com/tangosol/net/cache/ContinuousQueryCache.java:3061
↓ 2 callersMethodensureDaemonPool
Ensure that the correct worker-pool implementation exists for the current service configuration. @param fVirtual {@code true} if the virtual-thread
prj/coherence-core-components/src/main/java/com/tangosol/coherence/component/util/daemon/queueProcessor/Service.java:1264
↓ 2 callersMethodensureDiff
Make sure that a WriteBuffer exists if one doesn't already. @param out the existing WriteBuffer or null @param cbMax the expected resulting size
prj/coherence-core/src/main/java/com/tangosol/io/BinaryDeltaCompressor.java:358
↓ 2 callersMethodensureDirectory
Based on {@code root} ensure it is a directory and can be read. Display a warning message if not the case and return null. @param root the file reso
prj/coherence-core/src/main/java/com/tangosol/dev/introspect/ClassPathResourceDiscoverer.java:476
↓ 2 callersMethodensureDocsPublisher
Ensures a documents publisher is available and active. <p/> This method creates a new documents publisher if none exists or if the current publisher i
prj/coherence-rag-parent/coherence-rag/src/main/java/com/oracle/coherence/rag/api/Store.java:982
↓ 2 callersMethodensureElement
Ensure that a child element exists. This is a convenience method. It combines the functionality of findElement() and addElement(). If any part of th
prj/coherence-core/src/main/java/com/tangosol/run/xml/SimpleElement.java:377
↓ 2 callersMethodensureEntry
(String sName, boolean fDir)
prj/coherence-core/src/main/java/com/tangosol/engarde/DirectoryStorage.java:291
↓ 2 callersMethodensureExtentSet
Ensure extent-key set exists in supplied map. @param mapExtentToKeys extent-key map @param lExtentId extent id @return extent key set
prj/coherence-core/src/main/java/com/tangosol/io/journal2/JournalRecovery.java:753
↓ 2 callersMethodensureExtentState
Ensure and return the state for the specified extent. @param lExtentId extent id @return the state for the extent @throws IOException on I/O failu
prj/coherence-core/src/main/java/com/tangosol/persistence/journal/JournalPersistenceManager.java:1198
↓ 2 callersMethodensureFactory
()
prj/test/functional/persistence/src/main/java/persistence/JournalMigrationTests.java:210
↓ 2 callersMethodensureFactory
()
prj/test/functional/persistence/src/main/java/persistence/JournalBackingMapRecoveryBenchmarkTests.java:304
↓ 2 callersMethodensureFolders
(File file)
prj/coherence-docker/src/test/java/com/oracle/coherence/docker/FileUtils.java:116
↓ 2 callersMethodensureGroupName
()
prj/test/functional/grpc-client-netty/src/main/java/netty/grpc/client/topics/AbstractSimpleSubscriberTests.java:237
↓ 2 callersMethodensureGuardSupport
Return the GuardSupport for this Daemon, creating and initializing it if necessary. @return the GuardSupport for this Daemon
prj/coherence-core-components/src/main/java/com/tangosol/coherence/component/util/Daemon.java:506
↓ 2 callersMethodensureIdleDaemonStack
Ensure the published idle-daemon stack exists.
prj/coherence-core-components/src/main/java/com/tangosol/coherence/component/util/DaemonPool.java:816
↓ 2 callersMethodensureIndexMap
Ensure that the map of indexes maintained by this cache exists. @return the map of indexes.
prj/coherence-core/src/main/java/com/tangosol/net/cache/ContinuousQueryCache.java:2050
↓ 2 callersMethodensureIndexMap
Ensure that the map of indexes maintaned by this cache handler exists.
prj/coherence-core-components/src/main/java/com/tangosol/coherence/component/util/LocalCache.java:1252
↓ 2 callersMethodensureIndexMap
Ensure that the map of indexes maintaned by this cache handler exists.
prj/coherence-core-components/src/main/java/com/tangosol/coherence/component/util/CacheHandler.java:578
↓ 2 callersMethodensureInitialized
Ensures that this repository is initialized by creating necessary indices on the backing map. <p/> Base framework classes that extend this class shoul
prj/coherence-core/src/main/java/com/oracle/coherence/repository/AbstractRepositoryBase.java:93
↓ 2 callersMethodensureInternalCache
Create and initialize this {@code ContinuousQueryCache}'s (if not already present) internal cache. This method is called by {@link #configureSynchroni
prj/coherence-core/src/main/java/com/tangosol/net/cache/ContinuousQueryCache.java:585
↓ 2 callersMethodensureInternalIterator
Create (if necessary) and return the default iterator. @return the default iterator
prj/coherence-core/src/main/java/com/tangosol/net/CompositeAddressProvider.java:509
↓ 2 callersMethodensureKeyListenerMap
()
prj/coherence-core-components/src/main/java/com/tangosol/coherence/component/util/daemon/queueProcessor/service/grid/partitionedService/partitionedCache/Storage.java:2864
↓ 2 callersMethodensureListener
Ensure a MapListener for the given index. The listener will route the map events into the corresponding MapIndex calls. @param index the index @re
prj/coherence-core/src/main/java/com/tangosol/util/InvocableMapHelper.java:907
↓ 2 callersMethodensureLoadFactor
Check whether or not the specified segment is overloaded and if so, grow the bucket array (which suggests with high probability that the per-segment l
prj/coherence-core/src/main/java/com/tangosol/util/SegmentedHashMap.java:825
↓ 2 callersMethodensureLoaded
()
prj/test/performance/framework/src/main/java/com/tangosol/coherence/performance/JavaFlightRecorder.java:29
↓ 2 callersMethodensureLocalModel
Ensure that there exists a LocalModel for the given name.
prj/coherence-core-components/src/main/java/com/tangosol/coherence/component/net/management/Gateway.java:734
↓ 2 callersMethodensureLocked
Ensure the caller acquires the SafeNamedCache lock, or an excpetion is thrown.
prj/coherence-core-components/src/main/java/com/tangosol/coherence/component/util/SafeNamedTopic.java:374
↓ 2 callersMethodensureLockingObserver
Ensure that the specified {@link StreamObserver} is a safe observer. <p> If the specified observer is not an instance of {@link LockingStreamObserver}
prj/coherence-grpc/src/main/java/com/oracle/coherence/grpc/LockingStreamObserver.java:98
↓ 2 callersMethodensureLookup
(Internal) Initialize the constant pool lookup if it does not already exist.
prj/coherence-core/src/main/java/com/tangosol/dev/assembler/ConstantPool.java:400
↓ 2 callersMethodensureMBean
Return control when either: <ol> <li>the persistence mbean has been registered or</li> <li>the timeout of 60s has been reached</li> </ol> Note
prj/test/functional/events/src/main/java/events/RecoverEventTests.java:348
↓ 2 callersMethodensureMap
Return a map that can be used to store reduced values, creating it if one has not already been created. @return a set that can be used to store disti
prj/coherence-core/src/main/java/com/tangosol/util/aggregator/ReducerAggregator.java:158
↓ 2 callersMethodensureMember
Ensure that the member has joined the given service. @param service the service for which to check membership @param member the member to check se
prj/test/functional/partition/src/main/java/partition/ConfigurationTests.java:371
↓ 2 callersMethodensureMemberTimeoutStamp
Ensure that the specified member is stamped with a datetime indicating when it was last timed-out. If the member is not already stamped, stamp it wit
prj/coherence-core-components/src/main/java/com/tangosol/coherence/component/util/daemon/queueProcessor/service/grid/ClusterService.java:15013
↓ 2 callersMethodensureMethodParams
Return a {@link MethodParameter} array to hold method parameter descriptions. @param cParam the maximum number of parameters @return a MethodParame
prj/coherence-core/src/main/java/com/tangosol/dev/assembler/MethodParametersAttribute.java:162
↓ 2 callersMethodensureMinBuffer
Return a ByteBuffer of at least the specified size. @param cbMin the minimum required size @param cbMax the maximum desired size @return the buff
prj/coherence-core/src/main/java/com/oracle/coherence/common/internal/io/SegmentedBufferManager.java:397
↓ 2 callersMethodensureMsgArrayTemp
Return the MsgArrayTemp property, ensuring that the size of the array is greater or equal to the specified size. @see #onPacketAck
prj/coherence-core-components/src/main/java/com/tangosol/coherence/component/util/daemon/queueProcessor/packetProcessor/PacketPublisher.java:1313
↓ 2 callersMethodensureNoEffectTraces
()
prj/test/unit/coherence-tests/src/test/java/com/tangosol/coherence/component/util/VirtualDaemonPoolComponentTest.java:1777
↓ 2 callersMethodensureObjectNameCache
Ensure initialization of cache of ObjectName objects keyed by the canonical names.
prj/coherence-core-components/src/main/java/com/tangosol/coherence/component/net/management/Gateway.java:767
↓ 2 callersMethodensureOfferSnapshot
()
prj/coherence-core/src/main/java/com/tangosol/internal/net/queue/SimpleQueueStatistics.java:149
↓ 2 callersMethodensureOpenPersistentStore
Ensure that a persistent store is opened for the partition associated with this control, opening a new store if one does not already exist. This metho
prj/coherence-core-components/src/main/java/com/tangosol/coherence/component/util/daemon/queueProcessor/service/grid/PartitionedService.java:21987
↓ 2 callersMethodensureOperationalContext
Get the {@link OperationalContext} in which the {@link TcpAcceptorDependencies} are operating. If the OperationalContext has not been set, then obtain
prj/coherence-core/src/main/java/com/tangosol/internal/net/service/peer/acceptor/DefaultTcpAcceptorDependencies.java:549
↓ 2 callersMethodensurePage
Ensure that the specified entry contains a {@link Page}. <p> If the entry does not contain a {@link Page} then a new {@link Page} will be created. A s
prj/coherence-core/src/main/java/com/tangosol/internal/net/topic/impl/paged/PagedTopicPartition.java:425
↓ 2 callersMethodensurePartitionVersion
Return a PartitionVersion data structure that represents the provided partition @param nPartition the partition @return a PartitionVersion data str
prj/coherence-core/src/main/java/com/tangosol/net/internal/StorageVersion.java:332
↓ 2 callersMethodensurePersistenceMBean
Return control when either: <ol> <li>the persistence mbean has been registered or</li> <li>the timeout of 60s has been reached</li> </ol> Note
prj/test/functional/persistence/src/main/java/persistence/PersistenceTestHelper.java:461
↓ 2 callersMethodensurePollSnapshot
()
prj/coherence-core/src/main/java/com/tangosol/internal/net/queue/SimpleQueueStatistics.java:136
↓ 2 callersMethodensureProperties
Return a copy of the default properties to pass to new servers. @return a copy of the default properties
prj/coherence-testing-support/src/main/java/com/oracle/coherence/testing/AbstractRollingRestartTest.java:463
↓ 2 callersMethodensureReferenceRegistry
Obtain the registry for identity-reference pairs, creating it if necessary. @return the identity-reference registry, never null
prj/coherence-core/src/main/java/com/tangosol/io/pof/reflect/AbstractPofValue.java:587
↓ 2 callersMethodensureRegistry
(String sClusterName, int cMember)
prj/test/functional/jmx/src/main/java/jmx/BaseMBeanServerProxyNotificationTests.java:96
↓ 2 callersMethodensureRemoteModel
Obtain the RemoteModel for a given MBean name and owning Member Id, creating the RemoteModel instance if required.
prj/coherence-core-components/src/main/java/com/tangosol/coherence/component/net/management/Connector.java:730
↓ 2 callersMethodensureResults
{@inheritDoc}
prj/coherence-core/src/main/java/com/tangosol/net/cache/AbstractKeyBundler.java:281
↓ 2 callersMethodensureResults
{@inheritDoc}
prj/coherence-core/src/main/java/com/tangosol/net/cache/AbstractEntryBundler.java:248
↓ 2 callersMethodensureResults
{@inheritDoc}
prj/coherence-core/src/main/java/com/tangosol/net/cache/AbstractBinaryEntryBundler.java:258
↓ 2 callersMethodensureRunningCluster
Declared as public only to be accessed by the action.
prj/coherence-core-components/src/main/java/com/tangosol/coherence/component/util/SafeCluster.java:592
↓ 2 callersMethodensureRunningNamedCache
()
prj/coherence-core-components/src/main/java/com/tangosol/coherence/component/util/SafeNamedCache.java:1555
↓ 2 callersMethodensureRunningNamedTopic
()
prj/coherence-core-components/src/main/java/com/tangosol/coherence/component/util/SafeNamedTopic.java:408
↓ 2 callersMethodensureSafeSet
(Set set)
prj/test/functional/filter/src/main/java/filter/MiscTests.java:300
↓ 2 callersMethodensureScopeName
(String sName)
prj/test/functional/grpc-proxy-tck/src/main/java/grpc/proxy/BaseGrpcIT.java:416
↓ 2 callersMethodensureSelector
Ensure that the selector is available @param chan the channel which needs a selector @return the selector @throws IOException if an IO error occurs
prj/coherence-core/src/main/java/com/oracle/coherence/common/internal/net/RunnableSelectionService.java:129
↓ 2 callersMethodensureSeniority
Initializes the machine senior member. If then current member is determined to be the machine senior member also initializes the address scan array.
prj/coherence-core-components/src/main/java/com/tangosol/coherence/component/util/daemon/IpMonitor.java:288
↓ 2 callersMethodensureSerializationMode
Return the lambdas serialization mode of {@link ExternalizableHelper#LAMBDA_SERIALIZATION}. <p> If not explicitly configured in {@link ExternalizableH
prj/coherence-core/src/main/java/com/tangosol/internal/util/invoke/Lambdas.java:359
↓ 2 callersMethodensureService
Called NOT on the cluster service thread.
prj/coherence-core-components/src/main/java/com/tangosol/coherence/component/util/daemon/queueProcessor/service/grid/ClusterService.java:1788
↓ 2 callersMethodensureServiceInternal
Ensure the service for the specified scheme. @param xmlScheme the scheme @return running Service corresponding to the scheme
prj/coherence-core/src/main/java/com/tangosol/net/DefaultConfigurableCacheFactory.java:1102
↓ 2 callersMethodensureSession
(SessionConfiguration configuration, Context context)
prj/coherence-core/src/main/java/com/tangosol/internal/net/DefaultSessionProvider.java:138
↓ 2 callersMethodensureSessionInternal
Ensure the specified {@link Session} exists. @param configuration the {@link SessionConfiguration configuration} for the {@link Session} @param mode
prj/coherence-core/src/main/java/com/tangosol/net/Coherence.java:1775
↓ 2 callersMethodensureSet
(Integer ignored, SubscriberId id, Set<SubscriberId> setId)
prj/coherence-core/src/main/java/com/tangosol/internal/net/topic/SimpleChannelAllocationStrategy.java:200
↓ 2 callersMethodensureSet
Return a set that can be used to store distinct values, creating it if one has not already been created. @return a set that can be used to store dist
prj/coherence-core/src/main/java/com/tangosol/util/aggregator/DistinctValues.java:190
↓ 2 callersMethodensureStatistics
(String sTopicName)
prj/coherence-core/src/main/java/com/tangosol/internal/net/topic/impl/paged/PagedTopicBackingMapManager.java:157
↓ 2 callersMethodensureStorage
Ensure that the storage array has at least the specified capacity. @param c the required capacity @return the array
prj/coherence-core/src/main/java/com/tangosol/internal/util/LongBag.java:232
↓ 2 callersMethodensureStorage
Ensure that the storage array has at least the specified capacity. @param c the required capacity @return the array
prj/coherence-core/src/main/java/com/tangosol/internal/util/DoubleBag.java:235
↓ 2 callersMethodensureStorage
Ensure that the storage array has at least the specified capacity. @param c the required capacity @return the array
prj/coherence-core/src/main/java/com/tangosol/internal/util/IntBag.java:232
↓ 2 callersMethodensureSubscriptionKeys
(int nChannel, int nPart, SubscriberGroupId groupId)
prj/coherence-core/src/main/java/com/tangosol/internal/net/topic/impl/paged/PagedTopicSubscriberConnector.java:552
↓ 2 callersMethodensureSuspended
If service is not suspended then suspend and set ResumeOnCompletion to be true. If the service is suspended then just set ResumeOnCompletion to false
prj/coherence-core-components/src/main/java/com/tangosol/coherence/component/util/daemon/queueProcessor/service/grid/PartitionedService.java:29312
↓ 2 callersMethodensureSynchronized
Ensure that the {@code ContinuousQueryCache} listeners have been registered and its content synchronized with the underlying {@link NamedCache}. @par
prj/coherence-core/src/main/java/com/tangosol/net/cache/ContinuousQueryCache.java:1941
↓ 2 callersMethodensureTargetQueue
Return the queue associated with the target of the specified entry.
prj/coherence-core-components/src/main/java/com/tangosol/coherence/component/util/queue/concurrentQueue/BalancedQueue.java:201
← previousnext →14,001–14,100 of 78,752, ranked by callers