|
CoherenceTM v3.3 Copyright© 2000-2007 by Oracle Corporation |
|||||||
PREV CLASS NEXT CLASS | FRAMES NO FRAMES | |||||||
SUMMARY: NESTED | FIELD | CONSTR | METHOD | DETAIL: FIELD | CONSTR | METHOD |
java.lang.Objectcom.tangosol.net.cache.SimpleOverflowMap.Status
protected static class SimpleOverflowMap.Status
The Status object is used to manage concurrency at the key level for the key-level operations against the Map, to track all the items in the front Map, to manage the state transition for operations occurring against the Map, and to coordinate events across multiple threads.
Field Summary | |
---|---|
protected static int |
STATE_MASK_FRONT
Bitmask for entry in front. |
protected static int |
STATE_MASK_INSYNC
Bitmask for value in front and back being in sync. |
protected static int |
STATE_MASK_RETAIN
Bitmask for fields that would indicate that the Status must not be discarded. |
protected static int |
STATE_MASK_STATUS
Bitmask for status (least significant three bits reserved). |
protected static int |
STATE_VALUE_RETAIN
Bit values for fields that would indicate that the Status can be discarded. |
protected static int |
STATUS_AVAILABLE
Status: The Status object exists and no thread is currently performing processing against the associated entry. |
protected static int |
STATUS_COMMITTING
Status: The Status object represents an Entry that was very recently being processed, and is currently finalizing the results of that processing. |
protected static int |
STATUS_INVALIDATED
Status: The Status object has been discarded. |
protected static int |
STATUS_PROCESSING
Status: The Status object represents an Entry that is currently being processed. |
protected static int |
STATUS_RESERVED
Status: The Status object has been reserved for processing by a thread but is not yet processing. |
Constructor Summary | |
---|---|
SimpleOverflowMap.Status()
Construct a Status object for a specific key. |
Method Summary | |
---|---|
MapEvent |
closeProcessing()
Finish the processing of the entry for which this Status exists and proceed to the commit phase. |
protected boolean |
commitAndMaybeInvalidate()
Finish the commit for the entry for which this Status exists. |
protected boolean |
extractFlag(int nMask)
Extract a particular masked flag from the state of the Status object. |
protected int |
extractState(int nMask)
Extract a particular masked value from the state of the Status object. |
String |
getDescription()
Assemble a human-readable description. |
protected MapEvent |
getFrontEvent()
For internal use only, return the current event from the front Map. |
Thread |
getOwnerThread()
Determine the thread that owns the Status object, if the Status object is processing or committing. |
protected int |
getState()
Determine the state of the Status object. |
protected int |
getStatus()
Determine the enumerated status of the Status object. |
boolean |
hasEvent()
Determine if an event has occurred against the Entry for which this Status exists. |
boolean |
isAvailable()
Determine if the Status object is available. |
boolean |
isBackUpToDate()
Determine if the entry for which this Status exists has the same value in the front Map as in the back Map. |
boolean |
isCommitting()
Determine if the Status object represents an Entry that has been processed and the results of that processing are being committed. |
protected boolean |
isDiscardable()
Determine if this Status object can be discarded. |
boolean |
isEntryInFront()
Determine if the entry for which this Status exists is present in the front map. |
boolean |
isOwnedByCurrentThread()
Determine if the current thread owns this Status object. |
boolean |
isProcessing()
Determine if the Status object represents an Entry that is currently being processed. |
boolean |
isReserved()
Determine if the Status object is reserved. |
boolean |
isValid()
Determine if the Status object is valid. |
protected MapEvent |
mergeEvents(MapEvent evtOld,
MapEvent evtNew)
Merge two events that have been raised in sequence from a given map. |
boolean |
registerFrontEvent(MapEvent evt)
Register a MapEvent that has been raised by the front Map against the same key for which this Status object exists. |
protected boolean |
requestReservation()
Attempt to reserve the Status by marking it as committing if it is available. |
void |
setBackUpToDate(boolean fUpToDate)
Specify that the value stored in the back Map is known to be up to date (not needing to be written to the back if evicted from the front). |
void |
setEntryInFront(boolean fEntryInFront)
Specify whether the entry for which this Status exists is present in the front map. |
protected void |
setFrontEvent(MapEvent evt)
For internal use only, store the current event from the front Map. |
protected void |
setOwnerThread(Thread thread)
Specify the thread that owns the Status object. |
protected void |
setState(int nState)
Specify the state of the Status object. |
protected void |
setStatus(int nStatus)
Determine the enumerated state of the Status object. |
MapEvent |
takeEvent()
Obtain the most recent front Map event that has occurred against the Entry for which this Status exists. |
String |
toString()
Returns a string representation of the object. |
protected void |
updateFlag(int nMask,
boolean f)
Update a particular masked flag within the state of the Status object. |
protected void |
updateState(int nMask,
int nValue)
Update a particular masked value within the state of the Status object. |
protected MapEvent |
useReservation()
After having successfully made a reservation, this method completes the reservation process by setting the status to processing for the thread that made the reservation. |
protected MapEvent |
waitForAvailable()
Wait for the Entry that this Status represents to become available. |
protected void |
waitForReservationDecision()
Wait for the Entry that this Status represents to no longer be reserved. |
Field Detail |
---|
protected static final int STATE_MASK_STATUS
protected static final int STATE_MASK_FRONT
protected static final int STATE_MASK_INSYNC
protected static final int STATUS_AVAILABLE
protected static final int STATUS_RESERVED
protected static final int STATUS_PROCESSING
protected static final int STATUS_COMMITTING
protected static final int STATUS_INVALIDATED
protected static final int STATE_MASK_RETAIN
protected static final int STATE_VALUE_RETAIN
Constructor Detail |
---|
public SimpleOverflowMap.Status()
Method Detail |
---|
protected int getStatus()
protected void setStatus(int nStatus)
nStatus
- a number corresponding to one of the enumeration
represented by the STATUS_* constantspublic boolean isValid()
public boolean isAvailable()
public boolean isReserved()
public boolean isProcessing()
public boolean isCommitting()
public Thread getOwnerThread()
protected void setOwnerThread(Thread thread)
thread
- the owning thread, or nullpublic boolean isOwnedByCurrentThread()
public boolean isEntryInFront()
public void setEntryInFront(boolean fEntryInFront)
fEntryInFront
- pass true if the entry is stored in the front
map, false if notpublic boolean isBackUpToDate()
public void setBackUpToDate(boolean fUpToDate)
protected MapEvent getFrontEvent()
protected void setFrontEvent(MapEvent evt)
evt
- the cummulative front Map event for the Entry
represented by this Status object, or null to clear
the eventpublic boolean hasEvent()
public MapEvent takeEvent()
protected boolean isDiscardable()
public String getDescription()
public String toString()
protected MapEvent waitForAvailable()
protected boolean requestReservation()
useReservation()
or commitAndMaybeInvalidate()
(to cancel the reservation).
This is an internal method.
protected void waitForReservationDecision()
protected MapEvent useReservation()
public MapEvent closeProcessing()
protected boolean commitAndMaybeInvalidate()
public boolean registerFrontEvent(MapEvent evt)
evt
- the event that has occurred against an entry in the
front Map with the same key which this Status object
represents
protected MapEvent mergeEvents(MapEvent evtOld, MapEvent evtNew)
evtOld
- the first eventevtNew
- the second event
protected int getState()
protected void setState(int nState)
nState
- the new bit-packed state for the Status objectprotected int extractState(int nMask)
nMask
- the mask identifying the value
protected void updateState(int nMask, int nValue)
nMask
- the mask of bits to store the value withinnValue
- the value to store inside that maskprotected boolean extractFlag(int nMask)
nMask
- the mask identifying the flag
protected void updateFlag(int nMask, boolean f)
nMask
- the mask of flag bit to store the flag withinf
- the boolean value to store within that mask
|
CoherenceTM v3.3 Copyright© 2000-2007 by Oracle Corporation |
|||||||
PREV CLASS NEXT CLASS | FRAMES NO FRAMES | |||||||
SUMMARY: NESTED | FIELD | CONSTR | METHOD | DETAIL: FIELD | CONSTR | METHOD |