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	addDontAdjustHub(Hub hub) Hubs that should not be adjusted when trying to set activeObject and adjusting masterHub.AO
static void	addHubEvent(HubEvent he)
static void	addHubMergerCallback(OAThreadLocalHubMergerCallback cb)
protected static void	addHubMergerCallback(OAThreadLocal ti, OAThreadLocalHubMergerCallback cb)
static boolean	addSiblingHelper(OASiblingHelper sh)
protected static boolean	addSiblingHelper(OAThreadLocal ti, OASiblingHelper sh)
static void	clearSiblingHelpers()
static void	endCompoundUndoable()
static void	endUndoable()
protected static void	endUndoable(OAThreadLocal ti)
static String	getAllStackTraces()
static boolean	getCanAdjustHub(Hub hub)
static Object	getContext() Get the context that can be used to call OAContext.getContext
static boolean	getCreateUndoablePropertyChanges()
protected static boolean	getCreateUndoablePropertyChanges(OAThreadLocal ti)
static HubEvent	getCurrentHubEvent()
static int	getDeadlockCount()
static Hub	getFastLoadingHub()
protected static Hub	getFastLoadingHub(OAThreadLocal ti)
static int	getHubListenerTreeCount()
protected static int	getHubListenerTreeCount(OAThreadLocal ti)
static String	getIgnoreTreeListenerProperty()
static boolean	getIsAdmin()
static boolean	getIsAdmin(OAThreadLocal ti)
static Object[]	getLocks()
static OAJson	getOAJackson()
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 OAProcess	getProcess()
protected static OAProcess	getProcess(OAThreadLocal ti)
static int	getRecursiveTriggerCount()
protected static int	getRecursiveTriggerCount(OAThreadLocal ti)
static RequestInfo	getRemoteRequestInfo()
static ArrayList<OASiblingHelper>	getSiblingHelpers()
static ArrayList<OASiblingHelper>	getSiblingHelpers(OAThreadLocal ti)
static String	getThreadDump()
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 void	initialize(OAThreadLocal tl)
static boolean	isAdmin()
static boolean	isCreatingCompoundUndoable()
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	isFastLoadingHub(Hub h)
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	isRefreshing()
protected static boolean	isRefreshing(OAThreadLocal ti)
static boolean	isSendingEvent()
protected static boolean	isSendingEvent(OAThreadLocal ti)
static boolean	isSuppressCSMessages()
static boolean	isSuppressCSMessages(OAThreadLocal ti)
static boolean	isSyncThread()
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()
static void	removeDontAdjustHub(Hub hub)
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 boolean	setAdmin(boolean b)
static void	setContext(Object context) Sets the context that is being used for this Thread.
static void	setCreateUndoablePropertyChanges(boolean b) Flag to know if property changes should be adding undoable events.
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 void	setFastLoadingHub(Hub hub)
protected static void	setFastLoadingHub(OAThreadLocal ti, Hub hub)
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	setHubMergerChanging(boolean b)
protected static void	setHubMergerChanging(OAThreadLocal ti, boolean b)
static void	setIgnoreTreeListenerProperty(String prop)
static boolean	setIsAdmin(boolean b)
static boolean	setIsAdmin(OAThreadLocal ti, boolean b)
static boolean	setLoading(boolean b)
protected static boolean	setLoading(OAThreadLocal ti, boolean b)
static void	setNotifyObject(Object obj)
static OAJson	setOAJackson(OAJson jackson)
static void	setObjectCacheAddMode(int mode)
static void	setObjectSerializer(OAObjectSerializer si)
protected static void	setObjectSerializer(OAThreadLocal ti, OAObjectSerializer si)
static void	setProcess(OAProcess process)
protected static void	setProcess(OAThreadLocal ti, OAProcess process)
static void	setRecursiveTriggerCount(int x)
protected static void	setRecursiveTriggerCount(OAThreadLocal ti, int x)
static void	setRefreshing(boolean b)
protected static boolean	setRefreshing(OAThreadLocal ti, boolean b)
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 boolean	setSyncThread(boolean b)
static void	setTransaction(OATransaction t) Called by OATransaction.start() Used internally by classes that work with the transaction.
static void	startCompoundUndoable(String compoundName)
protected static void	startUndoable(OAThreadLocal ti, String compoundName)
static void	startUndoable(String compoundName) Start a compound undoable.
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)

setHubMergerChanging

public static void setHubMergerChanging(boolean b)

setHubMergerChanging

protected static void setHubMergerChanging(OAThreadLocal ti,
                                           boolean b)

addHubMergerCallback

public static void addHubMergerCallback(OAThreadLocalHubMergerCallback cb)

addHubMergerCallback

protected static void addHubMergerCallback(OAThreadLocal ti,
                                           OAThreadLocalHubMergerCallback cb)

setCreateUndoablePropertyChanges

public static void setCreateUndoablePropertyChanges(boolean b)

Flag to know if property changes should be adding undoable events.

See Also:

OAUndoManager

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)

Start a compound undoable.

startCompoundUndoable

public static void startCompoundUndoable(String compoundName)

isCreatingCompoundUndoable

public static boolean isCreatingCompoundUndoable()

startUndoable

protected static void startUndoable(OAThreadLocal ti,
                                    String compoundName)

endUndoable

public static void endUndoable()

endCompoundUndoable

public static void endCompoundUndoable()

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()

getThreadDump

public static String getThreadDump()

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)

getContext

public static Object getContext()

Get the context that can be used to call OAContext.getContext

setContext

public static void setContext(Object context)

Sets the context that is being used for this Thread.

See Also:

OAContext.getContextObject()

setAdmin

public static boolean setAdmin(boolean b)

setIsAdmin

public static boolean setIsAdmin(boolean b)

setIsAdmin

public static boolean setIsAdmin(OAThreadLocal ti,
                                 boolean b)

isAdmin

public static boolean isAdmin()

getIsAdmin

public static boolean getIsAdmin()

getIsAdmin

public static boolean getIsAdmin(OAThreadLocal ti)

initialize

public static void initialize(OAThreadLocal tl)

getOAJackson

public static OAJson getOAJackson()

setOAJackson

public static OAJson setOAJackson(OAJson jackson)

addDontAdjustHub

public static void addDontAdjustHub(Hub hub)

Hubs that should not be adjusted when trying to set activeObject and adjusting masterHub.AO

removeDontAdjustHub

public static void removeDontAdjustHub(Hub hub)

getCanAdjustHub

public static boolean getCanAdjustHub(Hub hub)

isSyncThread

public static boolean isSyncThread()

setSyncThread

public static boolean setSyncThread(boolean b)

isRefreshing

public static boolean isRefreshing()

isRefreshing

protected static boolean isRefreshing(OAThreadLocal ti)

setRefreshing

public static void setRefreshing(boolean b)

setRefreshing

protected static boolean setRefreshing(OAThreadLocal ti,
                                       boolean b)

getFastLoadingHub

public static Hub getFastLoadingHub()

See Also:

OAThreadLocal#fastLoading

getFastLoadingHub

protected static Hub getFastLoadingHub(OAThreadLocal ti)

isFastLoadingHub

public static boolean isFastLoadingHub(Hub h)

setFastLoadingHub

public static void setFastLoadingHub(Hub hub)

setFastLoadingHub

protected static void setFastLoadingHub(OAThreadLocal ti,
                                        Hub hub)

getProcess

public static OAProcess getProcess()

See Also:

OAThreadLocal.process

getProcess

protected static OAProcess getProcess(OAThreadLocal ti)

setProcess

public static void setProcess(OAProcess process)

setProcess

protected static void setProcess(OAThreadLocal ti,
                                 OAProcess process)