com.viaoa.object

Class OAThreadLocalDelegate

java.lang.Object

com.viaoa.object.OAThreadLocalDelegate

public class OAThreadLocalDelegate
extends Object

Delegate class used to store information about the local thread. This is used internally throughout OA to set specific features for a thread. Note: it is important to make sure to call the corresponding reverse value, so that the flags and counters will be unset and the Thread will be removed from internal map.

Author:

vvia

Field Summary

Fields

Modifier and Type	Field and Description
static int	cntDeadlock
static HashMap<Object,OAThreadLocal[]>	hmLock
protected static ReentrantReadWriteLock	rwLock

Constructor Summary

Constructors

Constructor and Description
OAThreadLocalDelegate()

Method Summary

Modifier and Type	Method and Description
static void	addHubEvent(HubEvent he)
static boolean	addSiblingHelper(OASiblingHelper sh)
protected static boolean	addSiblingHelper(OAThreadLocal ti, OASiblingHelper sh)
static void	clearSiblingHelpers()
static void	endUndoable()
protected static void	endUndoable(OAThreadLocal ti)
static String	getAllStackTraces()
static boolean	getCreateUndoablePropertyChanges()
protected static boolean	getCreateUndoablePropertyChanges(OAThreadLocal ti)
static HubEvent	getCurrentHubEvent()
static int	getDeadlockCount()
static int	getHubListenerTreeCount()
protected static int	getHubListenerTreeCount(OAThreadLocal ti)
static String	getIgnoreTreeListenerProperty()
static Object[]	getLocks()
static int	getOASyncEventCount()
static OAThreadLocal	getOAThreadLocal()
static int	getObjectCacheAddMode()
protected static int	getObjectCacheAddMode(OAThreadLocal ti)
static OAObjectSerializer	getObjectSerializer() used by Serialization for the current thread.
protected static OAObjectSerializer	getObjectSerializer(OAThreadLocal ti)
static HubEvent	getOldestHubEvent()
static int	getRecursiveTriggerCount()
protected static int	getRecursiveTriggerCount(OAThreadLocal ti)
static RequestInfo	getRemoteRequestInfo()
static ArrayList<OASiblingHelper>	getSiblingHelpers()
static ArrayList<OASiblingHelper>	getSiblingHelpers(OAThreadLocal ti)
protected static OAThreadLocal	getThreadLocal(boolean bCreateIfNull)
static OATransaction	getTransaction()
static boolean	hasLock()
static boolean	hasLock(Object obj)
static boolean	hasSentCalcPropertyChange(Hub thisHub, OAObject thisObj, String propertyName)
static boolean	hasSiblingHelpers()
static void	incrOASyncEventCount()
static boolean	isDeleting() Is this thread currently deleting.
protected static boolean	isDeleting(OAThreadLocal ti, Object obj)
static boolean	isDeleting(Object obj) Is any thread currently deleting an object.
static boolean	isEditQueryEnabled()
protected static boolean	isEditQueryEnabled(OAThreadLocal ti)
protected static boolean	isFlag(OAThreadLocal ti, Object obj)
static boolean	isFlag(Object obj) getFlag ----------------------- Flag used for generic/misc purposes
static boolean	isHubMergerChanging()
protected static boolean	isHubMergerChanging(OAThreadLocal ti)
static boolean	isLoading()
protected static boolean	isLoading(OAThreadLocal ti)
static boolean	isLocked(Object object)
static boolean	isLockOwner(Object object)
static boolean	isOpenHubEvent(HubEvent he)
static boolean	isSendingEvent()
protected static boolean	isSendingEvent(OAThreadLocal ti)
static boolean	isSuppressCSMessages()
static boolean	isSuppressCSMessages(OAThreadLocal ti)
static boolean	isThreadDeleting(Object obj) Is this thread currently deleting an object/hub.
protected static void	lock(OAThreadLocal tiThis, Object thisLockObject, int maxWaitTries)
static void	lock(Object object)
static void	lock(Object object, int maxWaitTries) This locking was created to prevent deadlocks.
static void	notifyWaitingThread()
static void	releaseAllLocks()
protected static void	removeFlag(OAThreadLocal ti, Object obj)
static void	removeFlag(Object obj)
static void	removeHubEvent(HubEvent he)
static void	removeSiblingHelper(OASiblingHelper sh)
protected static void	removeSiblingHelper(OAThreadLocal ti, OASiblingHelper sh)
static void	setCreateUndoablePropertyChanges(boolean b)
protected static void	setCreateUndoablePropertyChanges(OAThreadLocal ti, boolean b)
protected static void	setDeleting(OAThreadLocal ti, Object obj, boolean b)
static void	setDeleting(Object obj, boolean b)
static boolean	setEnableEditQuery(boolean b)
protected static boolean	setEnableEditQuery(OAThreadLocal ti, boolean b)
protected static void	setFlag(OAThreadLocal ti, Object obj)
static void	setFlag(Object obj)
static void	setHubListenerTree(boolean b)
protected static void	setHubListenerTree(OAThreadLocal ti, boolean b)
static void	setHubMergerIsChanging(boolean b)
protected static void	setHubMergerIsChanging(OAThreadLocal ti, boolean b)
static void	setIgnoreTreeListenerProperty(String prop)
static boolean	setLoading(boolean b)
protected static boolean	setLoading(OAThreadLocal ti, boolean b)
static void	setNotifyObject(Object obj)
static void	setObjectCacheAddMode(int mode)
static void	setObjectSerializer(OAObjectSerializer si)
protected static void	setObjectSerializer(OAThreadLocal ti, OAObjectSerializer si)
static void	setRecursiveTriggerCount(int x)
protected static void	setRecursiveTriggerCount(OAThreadLocal ti, int x)
static void	setRemoteRequestInfo(RequestInfo ri)
static boolean	setSendMessages(boolean b) Flag that can be set to allow messages from OARemoteThread to be sent to other clients/server.
static void	setStatus(String msg)
static void	setSuppressCSMessages(boolean b)
static void	setSuppressCSMessages(OAThreadLocal ti, boolean b)
static void	setTransaction(OATransaction t) Called by OATransaction.start() Used internally by classes that work with the transaction.
protected static void	startUndoable(OAThreadLocal ti, String compoundName)
static void	startUndoable(String compoundName)
static long	throttleLOG(String msg, long msLast)
protected static void	unlock(OAThreadLocal ti, Object object)
static void	unlock(Object object)

Methods inherited from class java.lang.Object

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

Field Detail

hmLock

public static final HashMap<Object,OAThreadLocal[]> hmLock

rwLock

protected static ReentrantReadWriteLock rwLock

cntDeadlock

public static int cntDeadlock

Constructor Detail

OAThreadLocalDelegate

public OAThreadLocalDelegate()

Method Detail

getThreadLocal

protected static OAThreadLocal getThreadLocal(boolean bCreateIfNull)

setTransaction

public static void setTransaction(OATransaction t)

Called by OATransaction.start() Used internally by classes that work with the transaction. Use OATransaction instead of calling directly.

getTransaction

public static OATransaction getTransaction()

isLoading

public static boolean isLoading()

See Also:

OAThreadLocal.loading

isLoading

protected static boolean isLoading(OAThreadLocal ti)

setLoading

public static boolean setLoading(boolean b)

setLoading

protected static boolean setLoading(OAThreadLocal ti,
                                    boolean b)

getObjectCacheAddMode

public static int getObjectCacheAddMode()

setObjectCacheAddMode

public static void setObjectCacheAddMode(int mode)

getObjectCacheAddMode

protected static int getObjectCacheAddMode(OAThreadLocal ti)

getObjectSerializer

public static OAObjectSerializer getObjectSerializer()

used by Serialization for the current thread. OAObjectSerializeInterface is called to return the type of serialization to perform. SERIALIZE_STRIP_NONE or SERIALIZE_STRIP_REFERENCES

getObjectSerializer

protected static OAObjectSerializer getObjectSerializer(OAThreadLocal ti)

setObjectSerializer

public static void setObjectSerializer(OAObjectSerializer si)

setObjectSerializer

protected static void setObjectSerializer(OAThreadLocal ti,
                                          OAObjectSerializer si)

isSuppressCSMessages

public static boolean isSuppressCSMessages()

isSuppressCSMessages

public static boolean isSuppressCSMessages(OAThreadLocal ti)

setSuppressCSMessages

public static void setSuppressCSMessages(boolean b)

setSuppressCSMessages

public static void setSuppressCSMessages(OAThreadLocal ti,
                                         boolean b)

isDeleting

public static boolean isDeleting()

Is this thread currently deleting.

isDeleting

public static boolean isDeleting(Object obj)

Is any thread currently deleting an object.

isThreadDeleting

public static boolean isThreadDeleting(Object obj)

Is this thread currently deleting an object/hub.

isDeleting

protected static boolean isDeleting(OAThreadLocal ti,
                                    Object obj)

setDeleting

public static void setDeleting(Object obj,
                               boolean b)

setDeleting

protected static void setDeleting(OAThreadLocal ti,
                                  Object obj,
                                  boolean b)

isFlag

public static boolean isFlag(Object obj)

getFlag ----------------------- Flag used for generic/misc purposes

isFlag

protected static boolean isFlag(OAThreadLocal ti,
                                Object obj)

setFlag

public static void setFlag(Object obj)

setFlag

protected static void setFlag(OAThreadLocal ti,
                              Object obj)

removeFlag

public static void removeFlag(Object obj)

removeFlag

protected static void removeFlag(OAThreadLocal ti,
                                 Object obj)

lock

public static void lock(Object object,
                        int maxWaitTries)

This locking was created to prevent deadlocks. If a thread is waiting on an object, and the thread already has a lock, then it can be allowed to also have the lock - after waiting a set amount of time. Each Object that is locked keeps track of the threadLocals that are using it. The first threadLocal in the array is the owner. Once it is done (unlocked), it will notify the next threadLocal, etc. Ideally, only one threadLocal at a time will have access to the Object - while the other threads wait. If another thread already has lock(s) on other objects, then it can also be allowed to use the object - after waiting a certain amount of time, and still not given the lock.

Parameters:

maxWaitTries - (default=10) max number of waits (each 50 ms) to wait before taking the lock - 0 to wait until notified. This will only be used if the current threadLocal has 1+ locks already and object is locked by another threadLocal.

lock

public static void lock(Object object)

hasLock

public static boolean hasLock()

hasLock

public static boolean hasLock(Object obj)

getLocks

public static Object[] getLocks()

isLocked

public static boolean isLocked(Object object)

isLockOwner

public static boolean isLockOwner(Object object)

getOAThreadLocal

public static OAThreadLocal getOAThreadLocal()

lock

protected static void lock(OAThreadLocal tiThis,
                           Object thisLockObject,
                           int maxWaitTries)

getDeadlockCount

public static int getDeadlockCount()

releaseAllLocks

public static void releaseAllLocks()

unlock

public static void unlock(Object object)

unlock

protected static void unlock(OAThreadLocal ti,
                             Object object)

isHubMergerChanging

public static boolean isHubMergerChanging()

isHubMergerChanging

protected static boolean isHubMergerChanging(OAThreadLocal ti)

setHubMergerIsChanging

public static void setHubMergerIsChanging(boolean b)

setHubMergerIsChanging

protected static void setHubMergerIsChanging(OAThreadLocal ti,
                                             boolean b)

setCreateUndoablePropertyChanges

public static void setCreateUndoablePropertyChanges(boolean b)

setCreateUndoablePropertyChanges

protected static void setCreateUndoablePropertyChanges(OAThreadLocal ti,
                                                       boolean b)

getCreateUndoablePropertyChanges

public static boolean getCreateUndoablePropertyChanges()

getCreateUndoablePropertyChanges

protected static boolean getCreateUndoablePropertyChanges(OAThreadLocal ti)

startUndoable

public static void startUndoable(String compoundName)

startUndoable

protected static void startUndoable(OAThreadLocal ti,
                                    String compoundName)

endUndoable

public static void endUndoable()

endUndoable

protected static void endUndoable(OAThreadLocal ti)

addSiblingHelper

public static boolean addSiblingHelper(OASiblingHelper sh)

removeSiblingHelper

public static void removeSiblingHelper(OASiblingHelper sh)

getSiblingHelpers

public static ArrayList<OASiblingHelper> getSiblingHelpers()

getSiblingHelpers

public static ArrayList<OASiblingHelper> getSiblingHelpers(OAThreadLocal ti)

hasSiblingHelpers

public static boolean hasSiblingHelpers()

clearSiblingHelpers

public static void clearSiblingHelpers()

addSiblingHelper

protected static boolean addSiblingHelper(OAThreadLocal ti,
                                          OASiblingHelper sh)

removeSiblingHelper

protected static void removeSiblingHelper(OAThreadLocal ti,
                                          OASiblingHelper sh)

throttleLOG

public static long throttleLOG(String msg,
                               long msLast)

getAllStackTraces

public static String getAllStackTraces()

setStatus

public static void setStatus(String msg)

setRemoteRequestInfo

public static void setRemoteRequestInfo(RequestInfo ri)

getRemoteRequestInfo

public static RequestInfo getRemoteRequestInfo()

setSendMessages

public static boolean setSendMessages(boolean b)

Flag that can be set to allow messages from OARemoteThread to be sent to other clients/server.

setNotifyObject

public static void setNotifyObject(Object obj)

notifyWaitingThread

public static void notifyWaitingThread()

getRecursiveTriggerCount

public static int getRecursiveTriggerCount()

getRecursiveTriggerCount

protected static int getRecursiveTriggerCount(OAThreadLocal ti)

setRecursiveTriggerCount

public static void setRecursiveTriggerCount(int x)

setRecursiveTriggerCount

protected static void setRecursiveTriggerCount(OAThreadLocal ti,
                                               int x)

getHubListenerTreeCount

public static int getHubListenerTreeCount()

getHubListenerTreeCount

protected static int getHubListenerTreeCount(OAThreadLocal ti)

setHubListenerTree

public static void setHubListenerTree(boolean b)

setHubListenerTree

protected static void setHubListenerTree(OAThreadLocal ti,
                                         boolean b)

setIgnoreTreeListenerProperty

public static void setIgnoreTreeListenerProperty(String prop)

getIgnoreTreeListenerProperty

public static String getIgnoreTreeListenerProperty()

getOASyncEventCount

public static int getOASyncEventCount()

incrOASyncEventCount

public static void incrOASyncEventCount()

getCurrentHubEvent

public static HubEvent getCurrentHubEvent()

isOpenHubEvent

public static boolean isOpenHubEvent(HubEvent he)

getOldestHubEvent

public static HubEvent getOldestHubEvent()

addHubEvent

public static void addHubEvent(HubEvent he)

removeHubEvent

public static void removeHubEvent(HubEvent he)

isSendingEvent

public static boolean isSendingEvent()

isSendingEvent

protected static boolean isSendingEvent(OAThreadLocal ti)

hasSentCalcPropertyChange

public static boolean hasSentCalcPropertyChange(Hub thisHub,
                                                OAObject thisObj,
                                                String propertyName)

isEditQueryEnabled

public static boolean isEditQueryEnabled()

isEditQueryEnabled

protected static boolean isEditQueryEnabled(OAThreadLocal ti)

setEnableEditQuery

public static boolean setEnableEditQuery(boolean b)

setEnableEditQuery

protected static boolean setEnableEditQuery(OAThreadLocal ti,
                                            boolean b)