com.atomikos.recovery.fs

Class CachedRepository

java.lang.Object

com.atomikos.recovery.fs.CachedRepository

All Implemented Interfaces:

Repository

public class CachedRepository
extends java.lang.Object
implements Repository

Constructor Summary

Constructors

Constructor and Description
CachedRepository(InMemoryRepository inMemoryCoordinatorLogEntryRepository, Repository backupCoordinatorLogEntryRepository)

Method Summary

Modifier and Type	Method and Description
protected void	assertNotCorrupted()
protected boolean	canBeForgotten(long now, PendingTransactionRecord coordinatorLogEntry)
void	close()
java.util.Collection<PendingTransactionRecord>	findAllCommittingCoordinatorLogEntries()
PendingTransactionRecord	get(java.lang.String coordinatorId)
java.util.Collection<PendingTransactionRecord>	getAllCoordinatorLogEntries()
void	init()
void	put(java.lang.String id, PendingTransactionRecord coordinatorLogEntry)
void	writeCheckpoint(java.util.Collection<PendingTransactionRecord> checkpointContent)

Methods inherited from class java.lang.Object

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

Constructor Detail

CachedRepository

public CachedRepository(InMemoryRepository inMemoryCoordinatorLogEntryRepository,
                        Repository backupCoordinatorLogEntryRepository)

Method Detail

init

public void init()

Specified by:

init in interface Repository

put

public void put(java.lang.String id,
                PendingTransactionRecord coordinatorLogEntry)
         throws java.lang.IllegalArgumentException,
                LogWriteException

Specified by:

put in interface Repository

Throws:

java.lang.IllegalArgumentException

LogWriteException

canBeForgotten

protected boolean canBeForgotten(long now,
                                 PendingTransactionRecord coordinatorLogEntry)

get

public PendingTransactionRecord get(java.lang.String coordinatorId)
                             throws LogReadException

Specified by:

get in interface Repository

Throws:

LogReadException

assertNotCorrupted

protected void assertNotCorrupted()
                           throws LogReadException

Throws:

LogReadException

findAllCommittingCoordinatorLogEntries

public java.util.Collection<PendingTransactionRecord> findAllCommittingCoordinatorLogEntries()
                                                                                      throws LogReadException

Specified by:

findAllCommittingCoordinatorLogEntries in interface Repository

Throws:

LogReadException

close

public void close()

Specified by:

close in interface Repository

getAllCoordinatorLogEntries

public java.util.Collection<PendingTransactionRecord> getAllCoordinatorLogEntries()

Specified by:

getAllCoordinatorLogEntries in interface Repository

writeCheckpoint

public void writeCheckpoint(java.util.Collection<PendingTransactionRecord> checkpointContent)

Specified by:

writeCheckpoint in interface Repository