Return {@link LocalAtomicMarkableReference} instance for the specified name. @param sName the name of the atomic value @param <V> the type of obj

Return {@link LocalAtomicReference} instance for the specified name. @param sName the name of the atomic value @param <V> the type of object refe

Return {@link LocalAtomicStampedReference} instance for the specified name. @param sName the name of the atomic value @param <V> the type of obje

Lock this Status.

Lock everything. This method will not return until the lock is placed. It must not be called on a thread that could already hold a lock.

Obtain an exclusive lock on the specified file. The lock should be released with the {@link #unlockFile(FileLock) unlockFile} method. @param file th

Log handled exception running registered CacheEntryListener for CacheEntryEvent @param listener throwing unexpected exception @param e handled except

Lookup the given name from the NameService. The object bound to the NameService should be a String. <p> The <code>sName</code> parameter string consis

Start a Coherence server. <p> This method will start Coherence configured with a single session that uses the default cache configuration file. This i

Entry point: start the cache server under two possible contexts: <ol> <li>With a "coherence-cache-config.xsd" compliant configuration file.</li> <

Create unique key based on the target method. @param method target method @return unique key @throws IllegalStateException if the same key alread

Create an ArrayList from the given arguments. @param aoArgs an array of Object to be added to ArrayList @return a newly created ArrayList

Finalize the construction of the Gateway as a "Primary" one.

Make a Trade object for the specified Id with random data. @param iId the Trade ID @return a new Trade object

Convert a long value to a "trint14". @param l the long value to convert to a trint14 @return the equivalent unsigned 14-bits integer value (a "tri

Returns an object-valued {@code Stream} consisting of the results of applying the given function to the elements of this stream. <p> This is an <em>in

Mark the underlying keys set as converted. @since Coherence 12.2.1.1.0

Mark the corresponding partitions as being in transition due to re-distribution. If the status has previously marked some other partitions as being in

Prepare the registered keys for selection. The caller must hold the read monitor. @param fReadable true if buffered inbound data exists

Determines if the specified {@link XmlElement} matches the path specified by the {@link DefaultDefinition}. @param element the {@link XmlElement} fo

Compare this EventRecorder to another EventRecorder. @param that another EventRecorder @return null if the recorded events match, or the key where

Returns the maximum results with a default value. <p/> This method ensures a sensible default when maxResults is 0. @return maxResults or 5 if maxRes

Filter out invalid ObjectName characters from string. @param string input string @return A valid JMX ObjectName attribute value.

Returns the model name. @return the model name or default if not set

Move the specified directory to the specified destination path. @param fileDirFrom the directory to move @param fileDirTo the destination path @

Construct a multiply processor that will multiply a property value by a specified factor, returning either the old or the new value as specified. The

Test to see if we need to construct object given a node type. @param sFunctor String representing node type @param term the Term that could resul

Returns the next element of this enumeration. @return the next element in the enumeration

Returns the next element of this enumeration. @return the next element in the enumeration

Will read nexts object metadata. You can call this method as many times as you want, with the condition that you use only {@link #metadata(String)} me

Normalize VM class names by converting slashes to dots.

Normalize and validate that the passed in address is a sensible local address. @param sAddress the address to normalize; may be <tt>null</tt> @param

Error: Statement is not reachable. @param errlist the error list to log errors to @exception CompilerException thrown if an error occurs that sho

Ensure that the delivery notification is posted if necessary.

Process this token in the context of parser p with the null denotation. A nud method typically will have no interest in the token to the left. The pro

Obtains a {@link Name} with a specific name. @param sName the name of the {@link Name} @return a {@link Name}

Obtains a {@link MachineName} for a specified name. @param name the name of the {@link MachineName} @return a {@link MachineName} for the specified n

Obtains a {@link SiteName} for a specified name. @param name the name of the {@link SiteName} @return a {@link SiteName} for the specified name

Add an offer to the statistics. @param cNanos the time taken to complete the offer (in nanos)

Returns the Ollama base URL from configuration. @return the base URL for Ollama service, defaults to {@code http://localhost:11434}

Called by a {@link FiniteStateMachine} when the {@link LifecycleAwareEvent} is initially about to be accepted for processing. @param context the {@l

Called by the publisher to indicate a series of packets which have been ack'd by a member. @param listAcknowledged a series of newly ack'd packets.

Handle an Add request. @param request the Request @param response the Response @throws IOException

Called each time an element is added to the queue.

This is the event that is executed when all the Members that were polled have responded or have left the Service.

The continuation function.

The topic has been destroyed.

Generic level for handling a Socket exception @param eException the causal exception

Handle a Get Request. @param request the Request @param response the Response @throws IOException

Handle the Response of the Get EntryProcessor. @param request the Request @param response the Response @param oReturn Object returned from the E

Specifies that a reference to a previously-identified value has been encountered in the POF stream. @param iPos context-sensitive position informati

Called when the current outtage "incident" is closed because no timed-out members remain (either due to members being disconnected, or due to communic

Logs a store load() failure. This method is intended to be overwritten if a particular store can fail and the backing map must take action based on it

A callback invoked as part of an {@link InvocableMap.EntryProcessor} to perform custom operations when the {@link Member} has joined the cluster. @re

Used for verify/inspect message received from server.

Called as part of disposing a MessageEvent. @param bufseq the pre-disposed message

Report that an octet value (a byte) has been encountered in the POF stream. @param iPos context-sensitive position information: property index

Called when this service member's view of the primary ownership has changed, and client contexts (e.g. threads) may need to be updated.

Called by a {@link FiniteStateMachine} when the {@link LifecycleAwareEvent} has been processed. @param context the {@link ExecutionContext} for the

Called by a {@link FiniteStateMachine} when the {@link LifecycleAwareEvent} is about to be processed. @param context the {@link ExecutionContext} fo

Process the result of a receive operation. @param lVersion the channel version @param result the {@link ReceiveResult} @param error

Called when recovery has completed either as a part of active persistence or snapshot recovery. Called on the service thread only. @param sSnapshot

This event occurs for each response Message from each polled Member.

Used for verify/inspect error received from server.

The default implementation of this method sets AcceptingClients to true. If the Service has not completed preparing at this point, then the Service mu

Called when the xml namespace associated with the {@link NamespaceHandler} is first encountered in an xml document. @param context the document {@li

Invoked prior to the {@link Subscriber} methods {@link #onComplete()}, {@link #onError(Throwable)} and {@link #onNext(Object)} being invoked for a {@l

Open the bus, allowing it to begin exchanging data. <p> Upon completion of the asynchronous operation a {@link Event.Type#OPEN OPEN} event will emitte

Returns the OpenAI base URL from configuration. @return the base URL for OpenAI API, defaults to {@code https://api.openai.com/v1}

Create a buffered late-value reader for the specified journal file. @param dirPartition the extent directory @param nFileId journal file id @

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

{@inheritDoc}

Perform an optimistic flush, i.e. flush only if the connection is not already being flushed. <p/> The callers need not lock the connection when callin

Test CQC on CQC

Write out the specified long in packed format. @param l the value to write @param ab the byte array to write to @param of the offset to write at @r

Parse an additive expression. AdditiveExpression: MultiplicativeExpression AdditiveExpression + MultiplicativeExpression Additive

Return the specified (0-based) attribute from the GUID. @param sGUID the GUID @param id the (0-based) attribute index @return the GUID attribut

Parse the cooperative notifier flush policy.

Helper to parse a variable declaration statement. @param outer contains the statement being parsed @return the variable declaration statement

Parses the JSON input file containing the list of features.

Parse the remainder of the method declaration and the method body if there is one. MethodDeclaratorRest: FormalParameters BracketsOpt [throws

Parse a JVM argument that may specify the platform thread stack size. @param sArg the JVM argument to parse @return the parsed stack size in bytes,

Parse a unary expression. UnaryExpression: PreIncrementExpression PreDecrementExpression + UnaryExpression - UnaryExpressio

Creates a path to a model file. @param modelName the model name @param path the path components @return the complete path to the model file

Pause the queue.

Populate the dependencies and test the getters. @param deps the DefaultInitiatorDependencies to populate @return the DefaultInitiatorDependencies t

Populate the dependencies and test the getters. @param deps the DefaultHttpAcceptorDependencies to populate @return the DefaultHttpAcceptorDependen

Populate the dependencies and test the getters. @param deps the DefaultGridDependencies to populate @return the DefaultGridDependencies that was pa

Populate the dependencies and test the getters. @param deps the DefaultRemoteServiceDependencies to populate @return the DefaultRemoteServiceDepend