|
||||||||||
PREV NEXT | FRAMES NO FRAMES |
Packages that use RemoteTransactionLogger | |
---|---|
org.infinispan.distribution | Classes relating to the distributed cache mode. |
Uses of RemoteTransactionLogger in org.infinispan.distribution |
---|
Subinterfaces of RemoteTransactionLogger in org.infinispan.distribution | |
---|---|
interface |
TransactionLogger
Typically adding a command, the following pattern would be used:
if (txLogger.logIfNeeded(cmd)) {
// do NOT proceed with executing this command!
} else {
// proceed with executing this command as per normal!
}
When draining, the following pattern should be used:
List<WriteCommand> c = null;
while (txLogger.shouldDrainWithoutLock()) {
c = txLogger.drain();
applyCommands(c);
}
c = txLogger.drainAndLock();
applyCommands(c);
applyPendingPrepares(txLogger.getPendingPrepares());
txLogger.unlockAndDisable();
|
Classes in org.infinispan.distribution that implement RemoteTransactionLogger | |
---|---|
class |
RemoteTransactionLoggerImpl
This abstraction performs RPCs and works on a TransactionLogger located on a remote node. |
class |
TransactionLoggerImpl
A transaction logger to log ongoing transactions in an efficient and thread-safe manner while a rehash is going on. |
Methods in org.infinispan.distribution with parameters of type RemoteTransactionLogger | |
---|---|
void |
DistributionManagerImpl.applyState(ConsistentHash consistentHash,
Map<Object,InternalCacheValue> state,
RemoteTransactionLogger tlog,
boolean forLeave)
|
void |
DistributionManager.applyState(ConsistentHash newConsistentHash,
Map<Object,InternalCacheValue> state,
RemoteTransactionLogger transactionLogger,
boolean forLeave)
|
|
--> |