Read the constant information from the stream. Since constants can be inter-related, the dependencies are not derefenced until all constants are disa

For disassembly of ops, update the LocalVariable/LocalVariableType tables to point to the disassembled ops. @param attrTable the local variable tabl

Delink this Node and discard its value. @return the value of this Node before it was discarded

Disconnect a specific subscriber from a topic. <p> Disconnecting a subscriber will cause channels to be reallocated and positions to be rolled back to

Dispatch this event to the specified listeners collection. @param listeners the listeners collection @throws ClassCastException if any of the target

Dispatch this event to the specified listeners collection. <p> This call is equivalent to <pre> dispatch(listeners, true); </pre> @param listeners

Dispatch the {@link Type#ACTIVATING} event to all concerned {@link com.tangosol.net.events.EventInterceptor EventInterceptors}. @param ccf the {@lin

Dispatch a {@link ConnectionEvent}. @param type the type of the event to dispatch

Helper to perform the dispatch of a {@link TopicLifecycleEvent} being given its type @param eventType the enum representing the event type @param to

Helper to perform the dispatch of a {@link TopicLifecycleEvent} being given its type @param eventType the enum representing the event type @param to

Display a list of names from the supplied contacts. @param listContacts the List of contacts to display names from

Display the operating system level info on TCP port usage.

Display the collected statistics for the given snapshot and type of operation. @param snapshot the snapshot that was archived or retrieved @param sT

{@inheritDoc}

{@inheritDoc}

{@inheritDoc}

Decrement the SharedBuffer's reference count, once it reaches zero the shared buffer will be released to the manager.

Perform disconnect processing. <p> This may be called multiple times. @param fFirst true iff this is the first disconnect @param eReason

Access the specified NamedCache. @param sName the name of the target NamedCache @param cIter the number of iterations @param cThread the number o

Output the command history

The main mechanics of invokeAny. See AbstractExecutorService#doInvokeAny(Collection, boolean, long) on which this implementation is based. @param col

Notify all member aware services that an extend client member open and close/loses a connection with proxy service. On receiving NotifyConnectionOpen

Start the ownership protocol either as a result of the normal distribution checks, or an explicit recovery from persistent snapshot. @param sSnapshot

Update the specified NamedCache. @param sName the name of the target NamedCache @param cIter the number of iterations @param cThread the number o

Perform release processing. @param handlerNext the handler for the next connection @param continuation the continuation to run after the release h

Issue a quorum roll-call. Called on the service thread only.

Performs the following checks: <ol> <li>Will log any classes in package {@value #PORTABLE_TYPE_PACKAGE} (included subpackages) that implement

The stop() implementation method. This method must only be called by a thread that has synchronized on this RemoteService.

Ensure that the backup owners for the specified partition are synchronized to the specified partition version. Called on the service thread by the pri

Helper for testChildCacheMutate tests.

Applies the filter to the thread and invokes the runnable @param filter the application-specific ObjectInputFilter @param runnable the runnable t

Writes the serialization header and payload. @param out the {@link WriteBuffer.BufferOutput} to write to @param o the object to ser

Return the document identifier. @return the document identifier

Double rotate a node in a given direction. @param node the node to rotate @param fLeft the final rotation direction @return the node's new parent

Drain as much of the clear-text buffer into the supplied buffers The caller must hold the read monitor. @param aBuffDst the destination buffers @pa

Move as many defered packets as possible from the member's defered queue, to publisher's defered-ready queue.

Acquires and returns all permits that are immediately available, or if negative permits are available, releases them. Upon return, zero permits are av

Emit any and all receipts

Release the specified buffer from the segment. @param buffer the buffer

Drops all registered key and filter-based listeners.

Provide the entire set of trait information in a printed format. @param out PrintWriter object to dump the information to @param sIndent a stri

Dump information collected from tools. @param tools tools instance to dump information from

Create a String of the specified length containing the specified character. @param ch the character to fill the String with @param cch the length of

Eats a character escape sequence. See EscapeSequence (Java Language Specification 3.10.6). @exception CompilerException If a lexical error is encoun

Eats a floating point literal. Floating point literals are composed of five parts, most of which are optional: digits, dot, digits, exponent, and su

Eats an identifier or a keyword. Note that this method assumes that it is only called if the next character is a "Java letter". @exception CompilerE

Returns the embedding for this chunk. @return the embedding, may be null if not set

Emit a notification.

Create an empty {@link MaybeByteString}. @return an empty {@link MaybeByteString}

Return a {@link Storage} {@link TaskExecutorService.Registration.Option}. @param fStorageEnabled whether the Option represents enabled (true), or di

Create a {@link CoverageProfile}. @param parameters the Jacoco parameters @return a Jacoco profile with the specified parameters

Encode an attribute value so that it can be quoted and made part of a valid and well formed XML document. @param sValue the attribute value to enco

Encode the opaque cookie used in a paged request. @param parts the partition set to encode @param page the current page @return an encoded page r

Encode the given PartitionSet and integer value into a new Binary. @param parts the PartitionSet @param n the integer value @return a new Binary c

Encode the passed buffer into a delta value that will cause the old value to be replaced by the value in the passed buffer. @param buf a non-null, no

Encodes a raw byte array into a BASE64 <code>char[]</code> representation i accordance with RFC 2045. @param sArr The bytes to convert. If <code>n

Encrypt the specified object using the private credentials for the given Subject (encryptor), which is usually associated with the current thread. @p

Encrypt the supplied contents, storing them in the outgoing buffer. The caller must hold the write monitor. @param aBuffSrc an array of ByteBuffers

Update the SelectionKeys once the handshake protocol has completed. The caller must hold the write monitor. @throws IOException if an I/O error occu

End the current aggregated recovery summary and return its formatted contents. @return the formatted summary, or {@code null} if no metrics were

Enforce the message size limit of an incoming message. @param cbSize the message size @throws IOException if the message size exceeds the limit

Enlist the head entry of the queue. @param entry the entry the processor is being invoked against @param fReadOnly {@code true} to enlist the h

Enlist the tail entry of the queue. @param entry the entry the processor is being invoked against @param fReadOnly {@code true} to enlist the h

Enqueue a prepared send entry. @param entry the send entry

Transform the given MapEvent into a FilterEvent if it is not already a FilterEvent and there are matching filters associated with the specified Listen

Ensure that the slab has not been leaked, and reallocate if it has. @return true iff ensure performed an allocation

Ensures accessibility on the passed method. @param method the method to set accessibility on @throws IllegalArgumentException if an exception was

Ensure that this {@link PagedTopicConnector} is active. @throws IllegalStateException if not active

Ensure that this {@link NamedTopic} is active. @throws IllegalStateException if not active

Get a mutable set of items that were added to the delta set. @return a mutable set of added items

Ensure current appending file can fit the specified entry size. @param cbEntry entry size @return appending file @throws IOException on I/O failur