Wait for this listener to receive the required number of events that was set when it was created. @param timeout the amount of time to wait @param u

Throw an assertion exception. @param sMsg the assertion message

Rebalance the tree following the removal of a node. @param pruned the node whose sub-tree shrunk @param fPrunedLeft the side on which the sub-

Block until this thread has exclusive access to perform operations against the OverflowMap.

Block until this thread has exclusive access to perform operations against the OverflowMap.

Return binary quantized value for this {@link Vector} as a bit vector. @return binary quantized value for this {@link Vector} as a bit vector

Quantize a float vector to a bit vector. @param vector the float vector to quantize @return the result of the binary quantization of the float vecto

Obtain an instance of the {@link BinaryBlindPutProcessor}. @param value the serialized value to put into the cache @param ttl the expiry value fo

Create a Boolean typed {@link SimpleModelAttribute} {@link Builder}. @param sName the attribute name @param <M> the model type @return a {@link

Copy from one part of the buffer to another. This method only supports copying from a latter part of the buffer to an earlier part of the buffer. @pa

Builds the configured {@link LuceneQueryParser} instance. @return a new LuceneQueryParser @throws IllegalStateException if required configuration is

Build a Descriptor object from a comma-delimited string of key-value pairs.

Construct and configure a {@link ConfigurableCacheFactory} for the specified cache config URI and {@link ClassLoader}. @param sConfigURI the URI

Build an index description for this index. @return an index description for this index if there is an index definition; null otherwise

The bundle operation to be performed against a collected set of keys by the concrete AbstractKeyBundler implementations. If an exception occurs during

@see Directed#selectType @see Sequel#selectType

Determine the partition-hash of the given key. The partition-hash is a property of the key identity itself, irrespective of the associated PartitionS

{@inheritDoc}

{@inheritDoc}

{@inheritDoc}

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

Calculate the old bucket for the specified hash code. @param nHash the hash code for the key @return the bucket index using the previous modulo

Calculate a cache cost for the specified cache entry key and value. @param oKey the cache key to evaluate for unit cost @param oValue the cache v

Calculate a cache cost for the specified object. <p> The default implementation uses the unit calculator type of the containing cache. @param oValue

Calculate a cache cost for the specified object. <p/> The default implementation uses the unit calculator type of the containing cache. @param oValue

Cancels all provided {@link Future futures}. @param futures list of {@link Future futures} @param <T> the future result type

Capitalize a string. @param s the string to capitalize @return the capitalized string

CAS the state of the subscriber. @param nPrevState the expected previous state of the subscriber @param nState the state of the subscriber @re

Create {@link ChainedSet} from two {@code Set}s or an existing {@code ChainedSet} and another {@code Set}. @param setFirst the first Set; could be

Converts text content to OCI ChatContent format. @param text the text content @return list containing a single TextContent instance

Converts text content to OCI ChatContent format. @param text the text content @return list containing a single TextContent instance

Verify that the stream is still open.

Check if the associated cache service is backlogged. @param backlogEndedContinuation Continuation to call when backlog ends. @return true iff assoc

@param buffer @param bIn @throws IOException

If there is a buffer manager, check if the current buffer should be shrunk.

Given a proposed capacity, validate the current capacity and adjust it as necessary. @param c the proposed capacity, in terms of the number of eleme

Check if the current thread is either the service thread or one of its daemons. If true, issue a warning that this could lead to deadlock. <p> This i

@return true iff all the flags are set

Test if the underlying store can be destroyed, and if so, destroy it.

Determine if a connection drop should be simulated @return true if the connection has been dropped

Validates the passed XmlElement, copying the element into a new valid element if necessary. @param element the XML element @return a XML element, c

Check the passed value to verify that it does belong in this ContinuousQueryCache. @param entry a key value pair to check. @throws IllegalArgumentE

Verify that this SimpleEntry is mutable.

Determine if the time has come to set up a new page for storing current cache data. This potentially destroys the oldest page, if the maximum number o

Check whether or not the timeout is reached. @param ldtStart an operation start time @param cTimeout the number of milliseconds left until timeout

If ResumeOnCompletion is true then resume the service as it was previously automatically suspended.

After a mutation operation has reduced the size of an underlying Set, check if the delegation model should be replaced with a more size- efficient sto

Check if the given name will be truncated in the table, and if yes, add the full name to the footer table. @param listFooter the list containing c

Check the passed object to verify that it passes the "value" restriction of this Map. @param o the Object to check @throws ClassCastException if t

Release any resources created by the EchoServer.

Release any resources created by the EchoNIOServer.

Clear out all references in the array of free lists.

Clear optimized filter order recursively for this filter and any nested {@link ArrayFilter} instances.

Make sure the trait doesn't have a UID.

Creates a cloned copy of this Component, including its sub-traits. @return a cloned copy of this Component @exception CloneNotSupportedException i

Create a clone of this Ownership. @return a clone of the Ownership object

Create a clone of this Binary object. @return a Binary object with the same contents as this Binary object

Close the application writer and release all used resources

Close the stream, flushing any accumulated bytes. The underlying writer is not closed. @exception IOException if an I/O error occurs

Close this {@link BatchingOperationsQueue}. This {@link BatchingOperationsQueue} will no longer accept values but the pending values can continue to b

Close the underlying BerkeleyDB database used to store keys associated with the given extent identifier. @param lExtentId the extent identifier

Close the current application entry. @exception IOException if an I/O error has occurred

Close the current application entry. @exception IOException if an I/O error has occurred

Close an Environment. <p> This includes closing the environment and databases, and if temporary deleting the associated files. @param fDeregister ind

The close() implementation method. This method is called on the service thread. @param fNotify if true, notify the peer that the Channel is being cl

The close() implementation method. This method is called on the service thread. @param fNotify if true, notify the peer that the Connection is being

Notify the UserTypeWriter that it is being "closed". This notification allows the UserTypeWriter to write any remaining data that it has pending to wr

Called on the service thread when the service is stopped to close all currently open polls.

Helper method to close a Status, processing any pending events as part of the process. @param status the Status object to close

Add the necessary instructions to the provided {@link MethodVisitor} to coerce from the source primitive ({@code chSrc}) to the destination primitive(

Collect orphaned partitions. @return the set of orphaned partitions

Collect available connection information regarding the specified Member.

Adapts a {@code Collector} to perform an additional finishing transformation. For example, one could adapt the {@link #toList()} collector to always

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

Configure the incremental compact.