|
||||||||||
PREV CLASS NEXT CLASS | FRAMES NO FRAMES | |||||||||
SUMMARY: NESTED | FIELD | CONSTR | METHOD | DETAIL: FIELD | CONSTR | METHOD |
java.lang.Object org.infinispan.transaction.xa.GlobalTransaction org.infinispan.transaction.xa.DeadlockDetectingGlobalTransaction
public class DeadlockDetectingGlobalTransaction
This class is used when deadlock detection is enabled.
Nested Class Summary | |
---|---|
static class |
DeadlockDetectingGlobalTransaction.Externalizer
|
Field Summary | |
---|---|
static boolean |
trace
|
Fields inherited from class org.infinispan.transaction.xa.GlobalTransaction |
---|
addr |
Constructor Summary | |
---|---|
DeadlockDetectingGlobalTransaction()
|
Method Summary | |
---|---|
boolean |
equals(Object o)
|
long |
getCoinToss()
|
Object |
getLockIntention()
Returns the key this transaction intends to lock. |
int |
hashCode()
|
void |
interruptProcessingThread()
Tries to interrupt the processing thread. |
boolean |
isMarkedForRollback()
Once marked for rollback, the call to interruptProcessingThread() will be ignored. |
boolean |
isReplicatingTo(Address address)
Is this global transaction replicating to the given address? |
void |
setCoinToss(long coinToss)
Sets the reandom number that defines the coin toss. |
void |
setLockIntention(Object lockIntention)
Sets the lock this transaction intends to lock. |
void |
setMarkedForRollback(boolean markedForRollback)
|
void |
setProcessingThread(Thread replicationThread)
On a node, this will set the thread that handles replicatin on the given node. |
void |
setReplicatingTo(Set<Address> targets)
Sets the set og Address objects this node is replicating to. |
boolean |
thisWillInterrupt(DeadlockDetectingGlobalTransaction globalTransaction)
Based on the coin toss, determine whether this tx will continue working or this thread will be stopped. |
String |
toString()
|
Methods inherited from class org.infinispan.transaction.xa.GlobalTransaction |
---|
clone, getAddress, getId, isRemote, setAddress, setId, setRemote |
Methods inherited from class java.lang.Object |
---|
finalize, getClass, notify, notifyAll, wait, wait, wait |
Field Detail |
---|
public static final boolean trace
Constructor Detail |
---|
public DeadlockDetectingGlobalTransaction()
Method Detail |
---|
public boolean isReplicatingTo(Address address)
public void setProcessingThread(Thread replicationThread)
public void interruptProcessingThread()
public void setReplicatingTo(Set<Address> targets)
public boolean thisWillInterrupt(DeadlockDetectingGlobalTransaction globalTransaction)
public void setCoinToss(long coinToss)
public long getCoinToss()
public boolean equals(Object o)
equals
in class GlobalTransaction
public int hashCode()
hashCode
in class GlobalTransaction
public String toString()
toString
in class GlobalTransaction
public boolean isMarkedForRollback()
interruptProcessingThread()
will be ignored.
public void setMarkedForRollback(boolean markedForRollback)
public Object getLockIntention()
public void setLockIntention(Object lockIntention)
|
Google Analytics | |||||||||
PREV CLASS NEXT CLASS | FRAMES NO FRAMES | |||||||||
SUMMARY: NESTED | FIELD | CONSTR | METHOD | DETAIL: FIELD | CONSTR | METHOD |