|
||||||||||
| PREV CLASS NEXT CLASS | FRAMES NO FRAMES | |||||||||
| SUMMARY: NESTED | FIELD | CONSTR | METHOD | DETAIL: FIELD | CONSTR | METHOD | |||||||||
java.lang.Objectorg.infinispan.distribution.RemoteTransactionLoggerImpl
public class RemoteTransactionLoggerImpl
This abstraction performs RPCs and works on a TransactionLogger located on a remote node.
| Constructor Summary | |
|---|---|
RemoteTransactionLoggerImpl(CommandsFactory commandsFactory,
Address targetNode,
RpcManager rpcManager)
|
|
| Method Summary | |
|---|---|
List<WriteCommand> |
drain()
Drains the transaction log and returns a list of what has been drained. |
List<WriteCommand> |
drainAndLock(Address notUsed)
Similar to RemoteTransactionLogger.drain() except that relevant locks are acquired so that no more commands are added to the
transaction log during this process, and transaction logging is disabled after draining. |
Collection<PrepareCommand> |
getPendingPrepares()
Drains pending prepares. |
boolean |
shouldDrainWithoutLock()
Tests whether the drain() method can be called without a lock. |
void |
unlockAndDisable(Address notUsed)
Unlocks and disables the transaction logger. |
| Methods inherited from class java.lang.Object |
|---|
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait |
| Constructor Detail |
|---|
public RemoteTransactionLoggerImpl(CommandsFactory commandsFactory,
Address targetNode,
RpcManager rpcManager)
| Method Detail |
|---|
public List<WriteCommand> drain()
RemoteTransactionLogger
drain in interface RemoteTransactionLoggerpublic List<WriteCommand> drainAndLock(Address notUsed)
RemoteTransactionLoggerRemoteTransactionLogger.drain() except that relevant locks are acquired so that no more commands are added to the
transaction log during this process, and transaction logging is disabled after draining.
drainAndLock in interface RemoteTransactionLoggerpublic boolean shouldDrainWithoutLock()
RemoteTransactionLogger
shouldDrainWithoutLock in interface RemoteTransactionLoggerpublic Collection<PrepareCommand> getPendingPrepares()
RemoteTransactionLogger
getPendingPrepares in interface RemoteTransactionLoggerpublic void unlockAndDisable(Address notUsed)
RemoteTransactionLogger#drainAndLock().
unlockAndDisable in interface RemoteTransactionLogger
|
||||||||||
| PREV CLASS NEXT CLASS | FRAMES NO FRAMES | |||||||||
| SUMMARY: NESTED | FIELD | CONSTR | METHOD | DETAIL: FIELD | CONSTR | METHOD | |||||||||