|
||||||||||
| 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)
|
|
||||||||||
| PREV NEXT | FRAMES NO FRAMES | |||||||||