Package com.tangosol.net.cache

Class ReadWriteBackingMap.NonBlockingEntryStoreWrapper.LoadOperationObserver

java.lang.Object

com.tangosol.net.cache.ReadWriteBackingMap.NonBlockingEntryStoreWrapper.LoadOperationObserver

All Implemented Interfaces:

StoreObserver

Enclosing class:

ReadWriteBackingMap.NonBlockingEntryStoreWrapper

public class ReadWriteBackingMap.NonBlockingEntryStoreWrapper.LoadOperationObserver
extends Object
implements StoreObserver

Callbacks invoked by NonBlockingEntryStore implementation to handle the result of load operations.

Constructor Summary

Constructors

Constructor	Description
LoadOperationObserver()	Default constructor
LoadOperationObserver(int cEntries)	Constructor for loadAll() code path.

Method Summary

Modifier and Type	Method	Description
protected Set	getProcessedEntries()	Set of entries successfully processed in loadAll().
void	onComplete()	Complete the current operation.
void	onError(BinaryEntry binEntry, Exception exception)	Indicate that the corresponding entry is in error, due to the given exception.
void	onNext(BinaryEntry binEntry)	Indicates the associated operation (load or store) has completed successfully and applied to the provided BinaryEntry.
protected void	waitForCompleted()	Synchronize loadInternal or loadAllInternal with responses.

Methods inherited from class java.lang.Object

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

Constructor Detail

LoadOperationObserver

public LoadOperationObserver()

Default constructor

LoadOperationObserver

public LoadOperationObserver(int cEntries)

Constructor for loadAll() code path.

Parameters:

cEntries - countdown gate for synchronization

Method Detail

onNext

public void onNext(BinaryEntry binEntry)

Indicates the associated operation (load or store) has completed successfully and applied to the provided BinaryEntry.

Specified by:

onNext in interface StoreObserver

Parameters:

binEntry - the associated entry

onError

public void onError(BinaryEntry binEntry,
                    Exception exception)

Indicate that the corresponding entry is in error, due to the given exception.

Specified by:

onError in interface StoreObserver

Parameters:

binEntry - the associated entry

exception - exception providing error details

onComplete

public void onComplete()

Complete the current operation. This is the last call to make on an observer, to signify that no further processing is necessary.

Specified by:

onComplete in interface StoreObserver

waitForCompleted

protected void waitForCompleted()

Synchronize loadInternal or loadAllInternal with responses.

Throws:

RuntimeException - upon interruption

getProcessedEntries

protected Set getProcessedEntries()

Set of entries successfully processed in loadAll().

Returns:

set of good entries