com.persistit

Class Management.JournalInfo

java.lang.Object

com.persistit.Management.AcquisitionTimeBase

com.persistit.Management.JournalInfo

All Implemented Interfaces:

Serializable

Enclosing interface:

Management

public static class Management.JournalInfo
extends Management.AcquisitionTimeBase

Structure that describes the current state of the journal manager.

See Also:

Serialized Form

Constructor Summary

Constructors

Constructor and Description
JournalInfo()
JournalInfo(String currentJournalFile, long currentJournalAddress, long blockSize, int pageMapSize, long currentGeneration, long baseAddress, long lastValidCheckpointTimestamp, long lastValidCheckpointSystemTime, String lastValidCheckpointJournalFile, long lastValidCheckpointJournalAddress, String recoveryJournalFile, long recoveryJournalAddress, long recoveryStatus, long journaledPageCount, long readPageCount, long copiedPageCount, long droppedPageCount, int recoveredCommittedTransactions, int recoveredAppliedTransactions, boolean closed, boolean copying, boolean flushing, boolean appendOnly, boolean fastCopying)

Method Summary

Modifier and Type	Method and Description
long	getBaseAddress() Base address is the journal address of the first record required for recovery.
long	getBlockSize() Maximum size of one journal file
long	getCopiedPageCount()
long	getCurrentJournalAddress()
String	getCurrentJournalFile()
long	getDroppedPageCount()
long	getJournaledPageCount()
long	getLastValidCheckpointAge() Convenience method to return the elapsed time since the last valid checkpoint was written.
long	getLastValidCheckpointJournalAddress()
String	getLastValidCheckpointJournalFile()
long	getLastValidCheckpointSystemTime()
long	getLastValidCheckpointTimestamp()
int	getPageMapSize()
long	getReadPageCount()
int	getRecoveredCommittedTransactions()
int	getRecoveredCompletedTransactions()
long	getRecoveryJournalAddress() Address within journal file currently being recovered during startup.
String	getRecoveryJournalFile() The current journal file being recovered during startup.
long	getRecoveryStatus() Return one of the following values: Long.MINVALUE if recovery has not begun yet -1 if recovery ended after a "dirty" (abruptly terminated) shutdown 0 if recovery completed after a "clean" (normal) shutdown N > 0 if recovery is in progress, in which case N represents the approximate number of remaining bytes of journal data to process.
boolean	isAppendOnly() The appendOnly flag suspends copying of pages to their Volume files.
boolean	isClosed()
boolean	isCopying()
boolean	isFastCopying()
boolean	isFlushing()

Methods inherited from class com.persistit.Management.AcquisitionTimeBase

getAcquisitionTime, setAcquisitionTime

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Constructor Detail

JournalInfo

public JournalInfo()

JournalInfo

@ConstructorProperties(value={"currentJournalFile","currentJournalAddress","blockSize","pageMapSize","currentGeneration","baseAddress","lastValidCheckpointTimestamp","lastValidCheckpointSystemTime","lastValidCheckpointJournalFile","lastValidCheckpointJournalAddress","recoveryJournalFile","recoveryJournalAddress","recoveryStatus","journaledPageCount","readPageCount","copiedPageCount","droppedPageCount","recoveredCommittedTransactions","recoveredAppliedTransactions","closed","copying","flushing","appendOnly","fastCopying"})
public JournalInfo(String currentJournalFile,
                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                   long currentJournalAddress,
                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                   long blockSize,
                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                   int pageMapSize,
                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                   long currentGeneration,
                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                   long baseAddress,
                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                   long lastValidCheckpointTimestamp,
                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                   long lastValidCheckpointSystemTime,
                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                   String lastValidCheckpointJournalFile,
                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                   long lastValidCheckpointJournalAddress,
                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                   String recoveryJournalFile,
                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                   long recoveryJournalAddress,
                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                   long recoveryStatus,
                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                   long journaledPageCount,
                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                   long readPageCount,
                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                   long copiedPageCount,
                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                   long droppedPageCount,
                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                   int recoveredCommittedTransactions,
                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                   int recoveredAppliedTransactions,
                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                   boolean closed,
                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                   boolean copying,
                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                   boolean flushing,
                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                   boolean appendOnly,
                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                   boolean fastCopying)

Method Detail

getCurrentJournalFile

public String getCurrentJournalFile()

Returns:

the current Journal file name

getCurrentJournalAddress

public long getCurrentJournalAddress()

Returns:

the current Journal file address

getBlockSize

public long getBlockSize()

Maximum size of one journal file

Returns:

the Journal file size

getPageMapSize

public int getPageMapSize()

Returns:

the pageMap size

getBaseAddress

public long getBaseAddress()

Base address is the journal address of the first record required for recovery.

Returns:

the start generation

getLastValidCheckpointTimestamp

public long getLastValidCheckpointTimestamp()

Returns:

the time stamp of latest valid Checkpoint

getLastValidCheckpointSystemTime

public long getLastValidCheckpointSystemTime()

Returns:

the system time (in millis) of the latest valid Checkpoint

getLastValidCheckpointAge

public long getLastValidCheckpointAge()

Convenience method to return the elapsed time since the last valid checkpoint was written.

Returns:

the elapsed time in seconds since the latest valid Checkpoint

getLastValidCheckpointJournalFile

public String getLastValidCheckpointJournalFile()

Returns:

the name of the journal file to which the last valid checkpoint record was written

getLastValidCheckpointJournalAddress

public long getLastValidCheckpointJournalAddress()

Returns:

the file address of the last valid checkpoint record

getRecoveryJournalFile

public String getRecoveryJournalFile()

The current journal file being recovered during startup. After recovery is compete, the name of the last journal file used during recovery.

Returns:

the journal file from which a recovery operation was last performed.

getRecoveryJournalAddress

public long getRecoveryJournalAddress()

Address within journal file currently being recovered during startup. After recovery is complete, the address after the last recovered record.

Returns:

the current recovery file address.

getRecoveryStatus

public long getRecoveryStatus()

Return one of the following values:

Long.MINVALUE	if recovery has not begun yet
-1	if recovery ended after a "dirty" (abruptly terminated) shutdown
0	if recovery completed after a "clean" (normal) shutdown
N > 0	if recovery is in progress, in which case N represents the approximate number of remaining bytes of journal data to process.

Returns:

the recovery status.

getJournaledPageCount

public long getJournaledPageCount()

Returns:

the total number of pages written to the journal

getCopiedPageCount

public long getCopiedPageCount()

Returns:

the total number of pages copied from the journal back to their Volumes.

getDroppedPageCount

public long getDroppedPageCount()

Returns:

the total number of pages dropped from the journal due the existence of newer versions

getReadPageCount

public long getReadPageCount()

Returns:

the total number of pages read from the journal back into buffer pool.

getRecoveredCompletedTransactions

public int getRecoveredCompletedTransactions()

Returns:

the count of recovered uncommitted transactions

getRecoveredCommittedTransactions

public int getRecoveredCommittedTransactions()

Returns:

the count of recovered committed Transactions

isClosed

public boolean isClosed()

Returns:

true iff the journal has been closed

isCopying

public boolean isCopying()

Returns:

true iff the JOURNALCOPIER task is currently copying pages to their Volume files.

isFlushing

public boolean isFlushing()

Returns:

true iff the JOURNALFLUSHER task is currently forcing file modifications to disk.

isAppendOnly

public boolean isAppendOnly()

The appendOnly flag suspends copying of pages to their Volume files.

Returns:

true if the appendOnly flag is set.

isFastCopying

public boolean isFastCopying()

Returns:

true if fast page copying is enabled. Fast copying copies pages as fast as possible without regard to disk utilization.