|
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.OverflowMap.Status
protected static class OverflowMap.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_BACK
Bitmask for entry in back. |
protected static int |
STATE_MASK_EXISTS
Bitmask for fields that would indicate that the Status represents an existent entry in the OverflowMap. |
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 |
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. |
Constructor Summary | |
---|---|
OverflowMap.Status()
Construct a Status object. |
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. |
protected MapEvent |
getBackEvent()
For internal use only, return the current event from the back Map. |
String |
getDescription()
Assemble a human-readable description. |
long |
getExpiry()
Determine the expiry for the entry represented by this Status. |
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 |
hasExpiry()
Determine if this Status represents an entry that will automatically expire. |
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 |
isEntryExistent()
Determine if the entry for which this Status exists is present in the front map or the back map. |
boolean |
isEntryInBack()
Determine if the entry for which this Status exists is present in the back map. |
boolean |
isEntryInFront()
Determine if the entry for which this Status exists is present in the front map. |
boolean |
isExpired()
Determine if this Status represents an entry that will automatically expire. |
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 |
isValid()
Determine if the Status object is valid. |
boolean |
registerBackEvent(MapEvent evt)
Register a MapEvent that has been raised by the back Map against the same key for which this Status object exists. |
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 void |
setBackEvent(MapEvent evt)
For internal use only, store the current event from the back Map. |
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 |
setEntryInBack(boolean fEntryInBack)
Specify whether the entry for which this Status exists is present in the back map. |
void |
setEntryInFront(boolean fEntryInFront)
Specify whether the entry for which this Status exists is present in the front map. |
void |
setExpiry(long ldtExpires)
Specify the expiry for the entry represented by this Status. |
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 |
takeBackEvent()
Obtain the most recent back Map event that has occurred against the Entry for which this Status exists. |
MapEvent |
takeEvent()
Obtain the most recent event that has occurred against the Entry for which this Status exists. |
MapEvent |
takeFrontEvent()
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 |
waitForAvailable()
Wait for the Entry that this Status represents to become available. |
Field Detail |
---|
protected static final int STATE_MASK_STATUS
protected static final int STATE_MASK_FRONT
protected static final int STATE_MASK_BACK
protected static final int STATE_MASK_INSYNC
protected static final int STATE_MASK_EXISTS
protected static final int STATE_MASK_RETAIN
protected static final int STATUS_AVAILABLE
protected static final int STATUS_PROCESSING
protected static final int STATUS_COMMITTING
protected static final int STATUS_INVALIDATED
Constructor Detail |
---|
public OverflowMap.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 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 isEntryInBack()
public void setEntryInBack(boolean fEntryInBack)
fEntryInBack
- pass true if the entry is stored in the back
map, false if notpublic boolean isEntryExistent()
public 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 eventprotected MapEvent getBackEvent()
protected void setBackEvent(MapEvent evt)
evt
- the cummulative back Map event for the Entry
represented by this Status object, or null to clear
the eventpublic boolean hasEvent()
public MapEvent takeFrontEvent()
public MapEvent takeBackEvent()
public MapEvent takeEvent()
public long getExpiry()
public void setExpiry(long ldtExpires)
ldtExpires
- the expiry, or 0L if the entry should not expirepublic boolean hasExpiry()
public boolean isExpired()
protected boolean isDiscardable()
public String getDescription()
public String toString()
protected MapEvent waitForAvailable()
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
public boolean registerBackEvent(MapEvent evt)
evt
- the event that has occurred against an entry in the
back Map with the same key which this Status object
represents
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 |