Skip navigation links

com.tangosol.net.cache
Class AbstractBinaryEntryBundler.Bundle

java.lang.Object
com.tangosol.util.Base
com.tangosol.net.cache.AbstractBundler.Bundle
com.tangosol.net.cache.AbstractBinaryEntryBundler.Bundle

Enclosing class:

AbstractBinaryEntryBundler

protected class AbstractBinaryEntryBundler.Bundle

extends AbstractBundler.Bundle

Field Summary

Fields inherited from class com.tangosol.net.cache.AbstractBundler.Bundle

STATUS_EXCEPTION, STATUS_OPEN, STATUS_PENDING, STATUS_PROCESSED

Constructor Summary

protected

AbstractBinaryEntryBundler.Bundle() Default constructor.

Method Summary

protected boolean	add(BinaryEntry binEntry) Add the specified binary entry to the Bundle.
protected boolean	addAll(java.util.Set setEntries) Add the specified set of binary entries to the Bundle.
protected void	ensureResults() Obtain results of the bundled requests.
protected int	getBundleSize() Obtain this bundle size.
protected void	process(boolean fBurst, BinaryEntry binEntry) Process the specified binary entry according to this Bundle state.
protected void	processAll(boolean fBurst, java.util.Set setEntries) Process the specified set of binary entries according to this Bundle state.
protected boolean	releaseThread() Release all bundle resources associated with the current thread.

Methods inherited from class com.tangosol.net.cache.AbstractBundler.Bundle

ensureResults, formatStatusName, isException, isMaster, isOpen, isPending, isProcessed, resetStatistics, setMaster, setStatus, toString, waitForResults

Constructor Detail

AbstractBinaryEntryBundler.Bundle

protected AbstractBinaryEntryBundler.Bundle()

Default constructor.

Method Detail

add

protected boolean add(BinaryEntry binEntry)

Add the specified binary entry to the Bundle.

Note: a call to this method must be externally synchronized for this Bundle object.

Parameters:

binEntry - the binary entry

Returns:

true if this Bundle was empty prior to this call

addAll

protected boolean addAll(java.util.Set setEntries)

Add the specified set of binary entries to the Bundle.

Note: a call to this method must be externally synchronized for this Bundle object.

Parameters:

setEntries - the set of binary entries

Returns:

true if this Bundle was empty prior to this call

process

protected void process(boolean fBurst,
                       BinaryEntry binEntry)

Process the specified binary entry according to this Bundle state.

Parameters:

fBurst - true if this thread is supposed to perform an actual bundled operation (burst); false otherwise

binEntry - the binary entry

processAll

protected void processAll(boolean fBurst,
                          java.util.Set setEntries)

Process the specified set of binary entries according to this Bundle state.

Parameters:

fBurst - true if this thread is supposed to perform an actual bundled operation (burst); false otherwise

setEntries - the set of entries

getBundleSize

protected int getBundleSize()

Obtain this bundle size. The return value should be expressed in the same units as the value returned by the getSizeThreshold method.

Overrides:

getBundleSize in class AbstractBundler.Bundle

Returns:

the bundle size

ensureResults

protected void ensureResults()

Obtain results of the bundled requests. This method should be implemented by concrete Bundle implementations using the most efficient mechanism.

Specified by:

ensureResults in class AbstractBundler.Bundle

releaseThread

protected boolean releaseThread()

Release all bundle resources associated with the current thread.

Overrides:

releaseThread in class AbstractBundler.Bundle

Returns:

true iff all entered threads have released

Skip navigation links