com.tangosol.net.cache

Class ContinuousQueryCache.ConverterAsynchronousProcessor

java.lang.Object

com.tangosol.util.AsynchronousAgent<T>

com.tangosol.util.processor.AbstractAsynchronousProcessor<K,V,R,Map<K,R>>

com.tangosol.util.processor.AsynchronousProcessor

com.tangosol.net.cache.ContinuousQueryCache.ConverterAsynchronousProcessor

All Implemented Interfaces:

FlowControl, InvocableMap.EntryProcessor, Serializable, Future

Enclosing class:

ContinuousQueryCache<K,V_BACK,V_FRONT>

protected class ContinuousQueryCache.ConverterAsynchronousProcessor
extends AsynchronousProcessor

Wraps an AsynchronousProcessor to ensure the result of the EntryProcessor execution is deserialized prior to passing to the provided AsynchronousProcessor.

Since:

12.2.1.4

Field Summary

Fields

Modifier and Type	Field and Description
protected Converter	f_convUp Converter to deserialize Binary values.
protected AsynchronousProcessor	f_processor The delegate AsynchronousProcessor.

Fields inherited from class com.tangosol.util.processor.AsynchronousProcessor

m_eReason, m_listResultEntries

Fields inherited from class com.tangosol.util.AsynchronousAgent

m_control, m_iOrderId

Constructor Summary

Constructors

Constructor and Description
ConverterAsynchronousProcessor(AsynchronousProcessor processor) Construct the processor to wrap the provided AsynchronousProcessor in order to ensure results are properly converted prior to return.

Method Summary

Modifier and Type	Method and Description
void	bind(FlowControl control) Bind this agent with the specified underlying FlowControl object.
boolean	cancel(boolean mayInterruptIfRunning)
boolean	checkBacklog(com.oracle.coherence.common.base.Continuation continueNormal) Check for an excessive backlog and if the underlying communication channel is indeed clogged, call the specified continuation when the backlog is back to normal or the service terminates.
long	drainBacklog(long cMillis) Check for an excessive backlog and allow blocking the calling thread for up to the specified amount of time.
void	flush() Ensure that any buffered asynchronous operations are dispatched to the underlying tier.
Object	get()
Object	get(long cTimeout, TimeUnit unit)
CompletableFuture	getCompletableFuture() Get the CompletableFuture.
Throwable	getException() Helper method that returns an exception (if completed exceptionally).
InvocableMap.EntryProcessor	getProcessor() Obtain the underlying entry processor.
Object	getResult() Helper method that calls AsynchronousAgent.get() and re-throws checked exceptions as a RuntimeException.
int	getUnitOfOrderId() Return a unit-of-order id associated with this processor.
boolean	isCancelled()
boolean	isCompletedExceptionally() Helper method to check if the operation failed.
boolean	isDone()
void	onComplete() Called after the processor has been notified about all possible partial results or failures and no more are forthcoming.
void	onException(Throwable eReason) Called if any part of the operation failed for any reason.
void	onResult(Map.Entry entry) Called when there is a partial result of the asynchronous execution.
Object	process(InvocableMap.Entry entry) Not supported.
Map	processAll(Set setEntries) Not supported.

Methods inherited from class com.tangosol.util.AsynchronousAgent

complete, completeExceptionally

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Field Detail

f_processor

protected final AsynchronousProcessor f_processor

The delegate AsynchronousProcessor.

f_convUp

protected final Converter f_convUp

Converter to deserialize Binary values.

Constructor Detail

ConverterAsynchronousProcessor

public ConverterAsynchronousProcessor(AsynchronousProcessor processor)

Construct the processor to wrap the provided AsynchronousProcessor in order to ensure results are properly converted prior to return.

Parameters:

processor - the processor to wrap

Method Detail

onResult

public void onResult(Map.Entry entry)

Description copied from class: AbstractAsynchronousProcessor

Called when there is a partial result of the asynchronous execution.

For a given request, calls to this method and AbstractAsynchronousProcessor.onException(java.lang.Throwable) may come concurrently.

For ordering guarantees across different processor invocations see AbstractAsynchronousProcessor.getUnitOfOrderId().

Note: Overriding implementations of this method must be non-blocking.

Overrides:

onResult in class AsynchronousProcessor

Parameters:

entry - an entry holding the key and a result of the operation for the given key

onException

public void onException(Throwable eReason)

Description copied from class: AbstractAsynchronousProcessor

Called if any part of the operation failed for any reason. For operations that span multiple partitions this method could be called more than once. However, unless subclasses override this method, any failure will "complete" the operation.

Note: Overriding implementations of this method must be non-blocking.

Overrides:

onException in class AsynchronousProcessor

Parameters:

eReason - the reason of failure

onComplete

public void onComplete()

Description copied from class: AbstractAsynchronousProcessor

Called after the processor has been notified about all possible partial results or failures and no more are forthcoming. As long as this processor was submitted to any of InvocableMap's methods, this method is guaranteed to be called once and only once.

Possible call back sequences are:

  cache.invoke
    ...
    onResult
    onComplete

  cache.invoke
    ...
    onException
    onComplete

  cache.invokeAll
    ...
     onResult
     onException
     onException
     onResult
     onComplete
 

For ordering guarantees across processors see AbstractAsynchronousProcessor.getUnitOfOrderId().

Note: Overriding implementations of this method must be non-blocking.

Overrides:

onComplete in class AsynchronousProcessor

getUnitOfOrderId

public int getUnitOfOrderId()

Description copied from class: AbstractAsynchronousProcessor

Return a unit-of-order id associated with this processor. By default, the unit-of-order id is assigned to the calling thread's hashCode.

If two consecutive "invoke" calls are made using AsynchronousProcessors with the same order id and the same key set, then the corresponding execution and calls to AbstractAsynchronousProcessor.onResult(java.util.Map.Entry<K, R>) are going to happen in the exact same order.

If two consecutive "invoke" calls are made using AsynchronousProcessors with the same order id and the same partition set, then the the corresponding execution and calls to AbstractAsynchronousProcessor.onComplete() are going to happen in the exact same order.

Note 1: The ordering guarantee is respected between AsynchronousProcessors and AsynchronousAggregators with the same unit-of-order id.
Note 2: There is no ordering guarantees between asynchronous and synchronous operations.

Overrides:

getUnitOfOrderId in class AbstractAsynchronousProcessor

Returns:

the unit-of-order id associated with this processor

See Also:

AbstractAsynchronousAggregator.getUnitOfOrderId(), AbstractAsynchronousProcessor.getUnitOfOrderId()

getProcessor

public InvocableMap.EntryProcessor getProcessor()

Description copied from class: AbstractAsynchronousProcessor

Obtain the underlying entry processor.

Overrides:

getProcessor in class AbstractAsynchronousProcessor

Returns:

the underlying entry processor

process

public Object process(InvocableMap.Entry entry)

Description copied from class: AbstractAsynchronousProcessor

Not supported.

Specified by:

process in interface InvocableMap.EntryProcessor

Overrides:

process in class AbstractAsynchronousProcessor

Parameters:

entry - the Entry to process

Returns:

the result of the processing, if any

processAll

public Map processAll(Set setEntries)

Description copied from class: AbstractAsynchronousProcessor

Not supported.

Specified by:

processAll in interface InvocableMap.EntryProcessor

Overrides:

processAll in class AbstractAsynchronousProcessor

Parameters:

setEntries - a Set of InvocableMap.Entry objects to process

Returns:

a Map containing the results of the processing, up to one entry for each InvocableMap.Entry that was processed, keyed by the keys of the Map that were processed, with a corresponding value being the result of the processing for each key

bind

public void bind(FlowControl control)

Description copied from class: AsynchronousAgent

Bind this agent with the specified underlying FlowControl object. This method is to be used only internally by the service.

Overrides:

bind in class AsynchronousAgent

Parameters:

control - the underlying FlowControl

flush

public void flush()

Description copied from interface: FlowControl

Ensure that any buffered asynchronous operations are dispatched to the underlying tier.

Note: this is a non-blocking call.

Specified by:

flush in interface FlowControl

Overrides:

flush in class AsynchronousAgent

checkBacklog

public boolean checkBacklog(com.oracle.coherence.common.base.Continuation continueNormal)

Description copied from interface: FlowControl

Check for an excessive backlog and if the underlying communication channel is indeed clogged, call the specified continuation when the backlog is back to normal or the service terminates. It's important to remember that:

1. The continuation could be called on any thread; concurrently with the calling thread or on the calling thread itself.
2. The continuation is called if and only if this method returns true.
3. The continuation must not make any blocking calls.

Specified by:

checkBacklog in interface FlowControl

Overrides:

checkBacklog in class AsynchronousAgent

Parameters:

continueNormal - (optional) Continuation to be called when the backlog has been reduced back to normal

Returns:

true if the underlying communication channel is backlogged; false otherwise

drainBacklog

public long drainBacklog(long cMillis)

Description copied from interface: FlowControl

Check for an excessive backlog and allow blocking the calling thread for up to the specified amount of time.

Specified by:

drainBacklog in interface FlowControl

Overrides:

drainBacklog in class AsynchronousAgent

Parameters:

cMillis - the maximum amount of time to wait (in milliseconds), or zero for infinite wait

Returns:

the remaining timeout or a negative value if timeout has occurred (the return of zero is only allowed for infinite timeout and indicates that the backlog is no longer excessive)

cancel

public boolean cancel(boolean mayInterruptIfRunning)

Specified by:

cancel in interface Future

Overrides:

cancel in class AsynchronousAgent

isCancelled

public boolean isCancelled()

Specified by:

isCancelled in interface Future

Overrides:

isCancelled in class AsynchronousAgent

isDone

public boolean isDone()

Specified by:

isDone in interface Future

Overrides:

isDone in class AsynchronousAgent

get

public Object get()
           throws InterruptedException,
                  ExecutionException

Specified by:

get in interface Future

Overrides:

get in class AsynchronousAgent

Throws:

InterruptedException

ExecutionException

get

public Object get(long cTimeout,
                  TimeUnit unit)
           throws InterruptedException,
                  ExecutionException,
                  TimeoutException

Specified by:

get in interface Future

Overrides:

get in class AsynchronousAgent

Throws:

InterruptedException

ExecutionException

TimeoutException

getResult

public Object getResult()

Description copied from class: AsynchronousAgent

Helper method that calls AsynchronousAgent.get() and re-throws checked exceptions as a RuntimeException.

Overrides:

getResult in class AsynchronousAgent

Returns:

the result value

getException

public Throwable getException()

Description copied from class: AsynchronousAgent

Helper method that returns an exception (if completed exceptionally).

Overrides:

getException in class AsynchronousAgent

Returns:

the exception or null if the operation completed successfully

isCompletedExceptionally

public boolean isCompletedExceptionally()

Description copied from class: AsynchronousAgent

Helper method to check if the operation failed.

Overrides:

isCompletedExceptionally in class AsynchronousAgent

Returns:

true if the operation failed

getCompletableFuture

public CompletableFuture getCompletableFuture()

Description copied from class: AsynchronousAgent

Get the CompletableFuture.

Overrides:

getCompletableFuture in class AsynchronousAgent

Returns:

CompletableFuture