Package org.objectweb.howl.log.xa
Class XALogger.OpenReplayListener
java.lang.Object
org.objectweb.howl.log.xa.XALogger.OpenReplayListener
- All Implemented Interfaces:
ReplayListener
- Enclosing class:
XALogger
private class used by XALogger to replay the log during
log open processing.
As log records are replayed through onRecord method, the HashMap activeTxHashMap is updated. XACOMMIT type records are added to the activeTxHashMap, and XADONE type records remove an entry.
When the END_OF_LOG record is encountered, the activeTx table is up to date and ready for new entries to be added by the TM.
-
Field Summary
FieldsModifier and TypeFieldDescription(package private) final HashMap
Used to keep track of XACOMMIT records encountered during replay.int
int
(package private) LogRecord
int
(package private) final XALogger
(package private) LogException
(package private) final ReplayListener
ReplayListener registered by TM that instantiated this XALogger.int
-
Constructor Summary
Constructors -
Method Summary
Modifier and TypeMethodDescriptionCalled by Logger when ReplayListener is registered for replay.void
Called by Logger when an exception is encountered during replay.void
Called by Logger for each record retrieved from the log.
-
Field Details
-
lr
LogRecord lr -
parent
-
replayException
LogException replayException -
tmListener
ReplayListener registered by TM that instantiated this XALogger.During replay, non-CTRL records are returned to the TM's replayListener.
-
activeTxHashMap
Used to keep track of XACOMMIT records encountered during replay. An entry is added to the activeTxHashMap when XACOMMIT type record is replayed, and removed when XADONE type record is replayed. -
unmatchedDoneCount
public int unmatchedDoneCount -
commitCount
public int commitCount -
doneCount
public int doneCount -
movedCount
public int movedCount
-
-
Constructor Details
-
OpenReplayListener
OpenReplayListener(ReplayListener tmListener)
-
-
Method Details
-
onRecord
Description copied from interface:ReplayListener
Called by Logger for each record retrieved from the log.when the entire log has been processed, lr.type is set to LogRecordType.END_OF_LOG.
- Specified by:
onRecord
in interfaceReplayListener
- Parameters:
lr
- LogRecord to be processed
-
onError
Description copied from interface:ReplayListener
Called by Logger when an exception is encountered during replay.- Specified by:
onError
in interfaceReplayListener
- Parameters:
e
- LogException object that was thrown when the error occurred.
-
getLogRecord
Description copied from interface:ReplayListener
Called by Logger when ReplayListener is registered for replay.The Logger calls getLogRecord to obtain a LogRecord instance to be used to process log records.
The same LogRecord instance is used to return all log records to the ReplayListener.
- Specified by:
getLogRecord
in interfaceReplayListener
- Returns:
- LogRecord object to be used when calling onRecord()
-