Assert the files either exist or not. @param fExists ture if they should exist @param nMax number of entries to check

Throws {@link IllegalStateException} if this factory has been disposed via invocation of {@link #dispose()}.

Eventually assert a remote latch count. @param member the cluster member to query @param sName the latch name @param count the initial latch cou

Assert thread stack trace contains a caller with {@code clz} name and {@code sMethodName method name}. @param t the thread @param clz

Assign the specified primary partition for this member. This can only be called on a service thread. @param iPartition the partition being assigned

Obtains a reference to the {@link ClusteredAssignment} cache. @return a reference to the {@link ClusteredAssignment} cache

Atomically sets the value of the mark to the given update value if the current reference is equal to the expected reference. Any given invocation of

Atomically sets the value of the stamp to the given update value if the current reference is {@code ==} to the expected reference. Any given invocati

Return the active {@link Span} if any, otherwise return a {@link Span} that is effectively a no-op. @return the active {@link Span} if any, otherwise

Wait for the read lock released event. @param timeout the maximum amount of time to wait @return the global order of the read released event

Bar entry to the thread gate by other threads, but do not wait for the gate to close. When all other threads have exited, the status of the thread gat

Report that an array of values has been encountered in the POF stream. <p> This method call will be followed by a separate call to an "on" or "begin"

Report that a sparse array of values has been encountered in the POF stream. <p> This method call will be followed by a separate call to an "on" or "b

Report that a uniform collection of values has been encountered in the POF stream. <p> This method call will be followed by a separate call to an "on"

Report that a map of key/value pairs (with the keys being of a uniform type) has been encountered in the POF stream. <p> This method call will be foll

Report that a map of key/value pairs (with the keys being of a uniform type and the values being of a uniform type) has been encountered in the POF st

Report that a uniform sparse array of values has been encountered in the POF stream. <p> This method call will be followed by a separate call to an "o

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

A Predicate utility builder. @param sPattern the pattern part for the Predicate creation @param parser the parser used to parse the values @retu

The bundle operation to be performed against a collected map of entries by the concrete AbstractEntryBundler implementations. If an exception occurs d

The bundle operation to be performed against a collected set of binary entries by the concrete AbstractEntryBundler implementations. If an exception o

Create key producing function based on method parameters. @param method the annotated method @return key generator function

Extract cache name from the annotated method or class. @param annotatedType the type potentially annotated with {@link CacheName} annotation @param

Calculate the bucket for the specified hash code. @param nHash the hash code for the key @return the bucket index

Calculate the number of bytes needed to store a packed integer using a variable-length format. <p> The format differs from DataOutput in that DataOutp

Calculate how many partitions this member owns. @param fPrimary if true, calculate the primary ownership; otherwise the backup ownership @return the

Return true iff <code>sMacro</code> contains the delimiter that this processor handles. @param sMacro the macro parameter @return true iff this pro

Returns {@code true} if the {@link SocketProviderFactory} can use the global provider builder over this builder, if a global builder is present. @ret

Return the "first" value with an index which is greater than or equal to the specified index. @param lIndex the index @return the value or null

Return the "first" index which is greater than or equal to the specified index. @param lIndex the index @return the index or NOT_FOUND

@param buf @param cSize @param of

Check that the specified string is neither a null nor an empty string. @param s the string to check @param sName the name of the corresponding

Check the passed object to verify that it passes the restriction of this Collection. @param o the Object to check @throws ClassCastException if th

Check if the current user is allowed to "join" the cache. @param cache the cache

Check that the specified object is within the range of this view. @param o the object to check

Validate a year-month interval. @param cYears the number of years @param cMonths the number of months

Clear listener events.

Returns a {@link Builder} instance that can build a {@link Coherence} instance using the specified {@link CoherenceConfiguration}. <p> The {@link Cohe

Make a clone of the passed object. @param o the object to clone @return a clone of the passed object

Return a copy of the specified object. @param o the object to clone @param <T> the type of the object @return the new object

Instantiate a copy of this message. This is quite different from the standard "clone" since only the "transmittable" portion of the message (and none

Close the Channel and reclaim all resources held by the Channel. <p> When this method is invoked, it will not return until Message processing has been

Close the HandshakeHandler's channel. @param eReason the reason for the disconnect, or null

Close all connections maintained by the TcpRing.

Close the channel.

Close and clean-up this subscriber. @param fDestroyed {@code true} if this call is in response to the caches being destroyed/rele

Close this {@link NamedTopicPublisher}. <p> The {@link Option}s passed to this method will override any options that were set when this publisher was

Close a subscription. @param subscriber the subscriber identifier @param fDestroyed {@code true} if the subscription is destroyed

Collect all store entries. @param store the store to iterate @return key-to-value map

Finish the commit for the entry for which this Status exists. If there are any threads waiting on the entry for which this Status exists, one will be

Returns the OCI compartment ID. @return the compartment ID

compute the number of packets sent by the publisher. @return the number of packets sent by the publisher

Compute the offset of the STORE value bytes. @param cbKey key length in bytes @return offset of STORE value bytes relative to the entry start

Return numeric Java version from java.version property. @param sVersion java.version string of 1.5, 1.6, 1.7, 1.8, 1.9, 1.10, 11, 15, 16, 17, 18, ...

Apply the specified options to a socket. @param socket the socket to configure @param options the options to apply, or null for none @throws Sock

Ensures a cache for given scheme. @param info the cache info @param xmlScheme the corresponding scheme @param loader ClassLoader that shou

Consume the specified number of bytes. @param cb the number of bytes consumed.

Determine if the remote NamedCache contains the specified keys. @param colKeys the keys @return true if the NamedCache contains the specified keys

{@inheritDoc}

Return true iff one of the causes is InvalidClassException. @param t Throwable to check for InvalidClassException @return true iff one of the cause

Convert the specified map event into another MapEvent that ensures the lazy event data conversion using the specified converters. @param event the

Write the given integer to a buffer, returning a read-only view. @param n the integer to convert to a buffer @return a read only buffer

Convert binary UTF-8 encode data to a String. This method is a helper to allow various I/O implementations to share a single, efficient implementation

Convert a {@link Binary} in the cache's serialization format to a {@link Binary} in the request's serialization format. @param binary the {@link Bin

Copy the specified file according to the source and destination File objects preserving the time-stamp of the source. @param fileFrom the {@link Fil

Create an instance of {@link Map} based on the contents of the provided map. @param map the map to copy @return an instance of {@link Map} populat

Create an APPENDING file with the specified id. @param nFileId file id @throws IOException on I/O failure

Create a {@link PublisherChannelConnector}. @param nChannel the channel identifier @return a {@link PublisherChannelConnector}

Create new LiteralBaseToken representing a Double with given value @param s the text of the literal @return a LiteralBaseToken for a Double

Create an {@link ErrorMessage} from a {@link Throwable}. @param error the error to create the message from @param serializer the serializer to

Create a new {@link ExecutionContext}. The following properties will be set on the returned context: <ul> <li>silent mode is enabled</li> <li>

Spin up a new {@link TaskExecutorService}. This is used for ExecutorService lifecycle tests such as shutdown tests. @return a new {@link TaskExecuto

Create a new HTTPS client. @return a new HTTPS client

Creates a POF index file at the specified base directory. By default, the index will be created in the subdirectory {@code META-INF/pof.idx}. @param

Create a LocalCacheValue for an LocalCache entry. @param internalValue internal format of value @param ldtCreation entry creation time @param pol