Package org.apache.jackrabbit.oak.segment.spi.persistence.split

Class SplitSegmentArchiveManager

java.lang.Object

org.apache.jackrabbit.oak.segment.spi.persistence.split.SplitSegmentArchiveManager

All Implemented Interfaces:

SegmentArchiveManager

public class SplitSegmentArchiveManager
extends Object
implements SegmentArchiveManager

Constructor Summary

Constructors

Constructor	Description
SplitSegmentArchiveManager(SegmentArchiveManager roArchiveManager, SegmentArchiveManager rwArchiveManager, String lastRoArchive)

Method Summary

Modifier and Type	Method	Description
void	backup(@NotNull String archiveName, @NotNull String backupArchiveName, @NotNull Set<UUID> recoveredEntries)	Method that is doing a backup of the archive given with archiveName into backupArchiveName.
void	copyFile(@NotNull String from, @NotNull String to)	Copies the archive with all the segments.
@NotNull SegmentArchiveWriter	create(@NotNull String archiveName)	Creates a new archive.
boolean	delete(@NotNull String archiveName)	Deletes the archive if exists.
boolean	exists(@NotNull String archiveName)	Check if archive exists.
@Nullable SegmentArchiveReader	forceOpen(String archiveName)	Opens an archive that wasn't closed correctly.
@NotNull List<String>	listArchives()	List names of the available .tar archives.
@Nullable SegmentArchiveReader	open(@NotNull String archiveName)	Opens a given archive for reading.
void	recoverEntries(@NotNull String archiveName, @NotNull LinkedHashMap<UUID,byte[]> entries)	Finds all the segments included in the archive.
boolean	renameTo(@NotNull String from, @NotNull String to)	Renames the archive.

Methods inherited from class java.lang.Object

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

Constructor Details

SplitSegmentArchiveManager

public SplitSegmentArchiveManager(SegmentArchiveManager roArchiveManager,
 SegmentArchiveManager rwArchiveManager,
 String lastRoArchive)
                           throws IOException

Throws:

IOException

Method Details

listArchives

@NotNull
public @NotNull List<String> listArchives()
                                   throws IOException

Description copied from interface: SegmentArchiveManager

List names of the available .tar archives.

Specified by:

listArchives in interface SegmentArchiveManager

Returns:

archive list

Throws:

IOException

open

@Nullable
public @Nullable SegmentArchiveReader open(@NotNull
 @NotNull String archiveName)
                                    throws IOException

Description copied from interface: SegmentArchiveManager

Opens a given archive for reading.

Specified by:

open in interface SegmentArchiveManager

Returns:

the archive reader or null if the archive doesn't exist or doesn't have a valid index

Throws:

IOException

forceOpen

@Nullable
public @Nullable SegmentArchiveReader forceOpen(String archiveName)
                                         throws IOException

Description copied from interface: SegmentArchiveManager

Opens an archive that wasn't closed correctly.

Specified by:

forceOpen in interface SegmentArchiveManager

Returns:

the archive reader or null if the implementation doesn't support opening an unclosed archive

Throws:

IOException

create

@NotNull
public @NotNull SegmentArchiveWriter create(@NotNull
 @NotNull String archiveName)
                                     throws IOException

Description copied from interface: SegmentArchiveManager

Creates a new archive.

Specified by:

create in interface SegmentArchiveManager

Returns:

the archive writer

Throws:

IOException

delete

public boolean delete(@NotNull
 @NotNull String archiveName)

Description copied from interface: SegmentArchiveManager

Deletes the archive if exists.

Specified by:

delete in interface SegmentArchiveManager

Returns:

true if the archive was removed, false otherwise

renameTo

public boolean renameTo(@NotNull
 @NotNull String from,
 @NotNull
 @NotNull String to)

Description copied from interface: SegmentArchiveManager

Renames the archive.

Specified by:

renameTo in interface SegmentArchiveManager

Parameters:

from - the existing archive

to - new name

Returns:

true if the archive was renamed, false otherwise

copyFile

public void copyFile(@NotNull
 @NotNull String from,
 @NotNull
 @NotNull String to)
              throws IOException

Description copied from interface: SegmentArchiveManager

Copies the archive with all the segments.

Specified by:

copyFile in interface SegmentArchiveManager

Parameters:

from - the existing archive

to - new name

Throws:

IOException

exists

public boolean exists(@NotNull
 @NotNull String archiveName)

Description copied from interface: SegmentArchiveManager

Check if archive exists.

Specified by:

exists in interface SegmentArchiveManager

Parameters:

archiveName - archive to check

Returns:

true if archive exists, false otherwise

recoverEntries

public void recoverEntries(@NotNull
 @NotNull String archiveName,
 @NotNull
 @NotNull LinkedHashMap<UUID,byte[]> entries)
                    throws IOException

Description copied from interface: SegmentArchiveManager

Finds all the segments included in the archive.

Specified by:

recoverEntries in interface SegmentArchiveManager

Parameters:

archiveName - archive to recover

entries - results will be put there, in the order of presence in the archive

Throws:

IOException

backup

public void backup(@NotNull
 @NotNull String archiveName,
 @NotNull
 @NotNull String backupArchiveName,
 @NotNull
 @NotNull Set<UUID> recoveredEntries)
            throws IOException

Description copied from interface: SegmentArchiveManager

Method that is doing a backup of the archive given with archiveName into backupArchiveName. In addition, set of UUIDs of recovered segments is provided which can be inspected during backup. Method is invoked during archive recovery procedure and concrete implementation can decide whether original archive should be deleted or modified.

Specified by:

backup in interface SegmentArchiveManager

Throws:

IOException