com.j_spaces.core.transaction

Class TransactionHandler

java.lang.Object

com.j_spaces.core.transaction.TransactionHandler

public class TransactionHandler
extends Object

Handle engine transactions

Since:

6.0

Author:

anna

Field Summary

Fields

Modifier and Type	Field and Description
static long	XTN_ADDITIONAL_TIMEOUT

Constructor Summary

Constructors

Constructor and Description
TransactionHandler(SpaceConfigReader configReader, SpaceEngine engine)

Method Summary

Modifier and Type	Method and Description
void	addToPhantomGlobalXtns(ServerTransaction xtn)
void	addToPrepared2PCXtns(XtnEntry xtnEntry)
void	addTransaction(XtnEntry xtnEntry)
XtnEntry	addTransactionIfAbsent(XtnEntry xtnEntry)
XtnEntry	attachToXtnGranular(ServerTransaction txn, boolean fromReplication) Join the specified transaction, if not already joined.
void	checkTransactionDisconnection(OperationID opid, ServerTransaction txn)
XtnEntry	createTransactionEntry(ServerTransaction txn) Create new TransactionEntry and add it to the list of managed transactions
XtnEntry	createTransactionEntryIfAbsent(ServerTransaction txn, XtnEntry newXtnEntry) Create new TransactionEntry and add it to the list of managed transactions if such xtn does not exist.
static long	getBasicTimeForPreparedXtn()
static long	getExtentionTimeForPreparedXtn()
static int	getMaxNumberOfPreaparedXtnExtentions()
Map<ServerTransaction,Long>	getPhantomGlobalXtns()
Map<ServerTransaction,Prepared2PCXtnInfo>	getPrepared2PCXtns()
Map<ServerTransaction,Long>	getTimedXtns()
static long	getTimeToWaitForTm()
XtnEntry	getTransactionEntry(ServerTransaction txn) Get the transaction entry for given transaction.
Lock	getTxReadLock()
Lock	getTxWriteLock()
int	getUnusedXtnCleanTime()
Map<ServerTransaction,XtnEntry>	getXtnTable()
boolean	isLightTransaction(XtnEntry xtnEntry)
boolean	isPhantomGlobalXtn(ServerTransaction xtn)
static boolean	isSupportsPreparedXtnsExtentionTime()
boolean	lockXtnOnXtnEnd(XtnEntry xtnEntry) xtn is ending (rollbak/commit) - lock + fifo lock if fifo entries in xtn
void	removeFromPhantomGlobalXtns(ServerTransaction xtn)
void	removeFromPrepared2PCXtns(ServerTransaction xtn)
void	removeTransactionAfterEnd(XtnEntry xtnEntry) Remove given transaction from handled transactions
void	removeUnusedTransaction(XtnEntry xtnEntry, boolean needLock) Remove an unused transaction from handled transactions
void	renewTransactionLease(ServerTransaction txn, long time)
void	unlockXtnOnXtnEnd(XtnEntry xtnEntry, boolean lockedXtnTable)
boolean	waitForActiveTransactions(long timeoutInMillis)
void	xtnLockEntryOnTemplateOperation(Context context, IEntryHolder eh, ITemplateHolder th, XtnEntry alreadyLockedXtn) /** given an entry + template- perform the xtn locks and set the appropriate
void	xtnUnlockEntryOnTemplateOperation(ITemplateHolder th, XtnEntry alreadyLockedXtn)

Methods inherited from class java.lang.Object

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

Field Detail

XTN_ADDITIONAL_TIMEOUT

public static final long XTN_ADDITIONAL_TIMEOUT

Constructor Detail

TransactionHandler

public TransactionHandler(SpaceConfigReader configReader,
                          SpaceEngine engine)

Method Detail

getXtnTable

public Map<ServerTransaction,XtnEntry> getXtnTable()

Returns:

the xtnTable

getTimedXtns

public Map<ServerTransaction,Long> getTimedXtns()

Returns:

the timedLocalXtns

getPhantomGlobalXtns

public Map<ServerTransaction,Long> getPhantomGlobalXtns()

getTxWriteLock

public Lock getTxWriteLock()

getTxReadLock

public Lock getTxReadLock()

addTransaction

public void addTransaction(XtnEntry xtnEntry)

addTransactionIfAbsent

public XtnEntry addTransactionIfAbsent(XtnEntry xtnEntry)

removeTransactionAfterEnd

public void removeTransactionAfterEnd(XtnEntry xtnEntry)

Remove given transaction from handled transactions

removeUnusedTransaction

public void removeUnusedTransaction(XtnEntry xtnEntry,
                                    boolean needLock)

Remove an unused transaction from handled transactions

createTransactionEntry

public XtnEntry createTransactionEntry(ServerTransaction txn)

Create new TransactionEntry and add it to the list of managed transactions

Returns:

XtnEntry

createTransactionEntryIfAbsent

public XtnEntry createTransactionEntryIfAbsent(ServerTransaction txn,
                                               XtnEntry newXtnEntry)

Create new TransactionEntry and add it to the list of managed transactions if such xtn does not exist. if it exists=return it

Parameters:

newXtnEntry - - to be inserted if absent

Returns:

XtnEntry

renewTransactionLease

public void renewTransactionLease(ServerTransaction txn,
                                  long time)

getUnusedXtnCleanTime

public int getUnusedXtnCleanTime()

getTransactionEntry

public XtnEntry getTransactionEntry(ServerTransaction txn)
                             throws TransactionException

Get the transaction entry for given transaction. Check if transaction is valid

Returns:

XtnEntry

Throws:

TransactionException

attachToXtnGranular

public XtnEntry attachToXtnGranular(ServerTransaction txn,
                                    boolean fromReplication)
                             throws TransactionException,
                                    RemoteException

Join the specified transaction, if not already joined.

Parameters:

txn - the transaction to join

Throws:

TransactionException

RemoteException

xtnLockEntryOnTemplateOperation

public void xtnLockEntryOnTemplateOperation(Context context,
                                            IEntryHolder eh,
                                            ITemplateHolder th,
                                            XtnEntry alreadyLockedXtn)

/** given an entry + template- perform the xtn locks and set the appropriate

Parameters:

alreadyLockedXtn - - if an encapsulating xtn was already locked (for example in takemultiple)

xtnUnlockEntryOnTemplateOperation

public void xtnUnlockEntryOnTemplateOperation(ITemplateHolder th,
                                              XtnEntry alreadyLockedXtn)

lockXtnOnXtnEnd

public boolean lockXtnOnXtnEnd(XtnEntry xtnEntry)

xtn is ending (rollbak/commit) - lock + fifo lock if fifo entries in xtn

unlockXtnOnXtnEnd

public void unlockXtnOnXtnEnd(XtnEntry xtnEntry,
                              boolean lockedXtnTable)

isLightTransaction

public boolean isLightTransaction(XtnEntry xtnEntry)

isPhantomGlobalXtn

public boolean isPhantomGlobalXtn(ServerTransaction xtn)

addToPhantomGlobalXtns

public void addToPhantomGlobalXtns(ServerTransaction xtn)

removeFromPhantomGlobalXtns

public void removeFromPhantomGlobalXtns(ServerTransaction xtn)

getBasicTimeForPreparedXtn

public static long getBasicTimeForPreparedXtn()

isSupportsPreparedXtnsExtentionTime

public static boolean isSupportsPreparedXtnsExtentionTime()

getExtentionTimeForPreparedXtn

public static long getExtentionTimeForPreparedXtn()

getMaxNumberOfPreaparedXtnExtentions

public static int getMaxNumberOfPreaparedXtnExtentions()

addToPrepared2PCXtns

public void addToPrepared2PCXtns(XtnEntry xtnEntry)

removeFromPrepared2PCXtns

public void removeFromPrepared2PCXtns(ServerTransaction xtn)

getPrepared2PCXtns

public Map<ServerTransaction,Prepared2PCXtnInfo> getPrepared2PCXtns()

getTimeToWaitForTm

public static long getTimeToWaitForTm()

checkTransactionDisconnection

public void checkTransactionDisconnection(OperationID opid,
                                          ServerTransaction txn)
                                   throws TransactionException

Throws:

TransactionException

waitForActiveTransactions

public boolean waitForActiveTransactions(long timeoutInMillis)
                                  throws InterruptedException

Throws:

InterruptedException