Package org.apache.bookkeeper.bookie

Class LedgerDirsManager

java.lang.Object

org.apache.bookkeeper.bookie.LedgerDirsManager

public class LedgerDirsManager
extends Object

This class manages ledger directories used by the bookie.

Nested Class Summary

Nested Classes

Modifier and Type	Class	Description
static interface	LedgerDirsManager.LedgerDirsListener	Listener for the disk check events will be notified from the LedgerDirsManager whenever disk full/failure detected.
static class	LedgerDirsManager.NoWritableLedgerDirException	Indicates All configured ledger directories are full.

Constructor Summary

Constructors

Constructor	Description
LedgerDirsManager(ServerConfiguration conf, File[] dirs, DiskChecker diskChecker)
LedgerDirsManager(ServerConfiguration conf, File[] dirs, DiskChecker diskChecker, StatsLogger statsLogger)

Method Summary

Modifier and Type	Method	Description
void	addLedgerDirsListener(LedgerDirsManager.LedgerDirsListener listener)
void	addToFilledDirs(File dir)	Add the dir to filled dirs list.
void	addToWritableDirs(File dir, boolean underWarnThreshold)	Add the dir to writable dirs list.
List<File>	getAllLedgerDirs()	Get all ledger dirs configured.
(package private) List<File>	getDirsAboveUsableThresholdSize(long thresholdSize, boolean loggingNoWritable)
DiskChecker	getDiskChecker()
ConcurrentMap<File,Float>	getDiskUsages()	Get disk usages map.
List<File>	getFullFilledLedgerDirs()
List<LedgerDirsManager.LedgerDirsListener>	getListeners()	Get all dir listeners.
long	getTotalDiskSpace(List<File> dirs)	Calculate the total amount of disk space in all of the ledger directories put together.
long	getTotalFreeSpace(List<File> dirs)	Calculate the total amount of free space available in all of the ledger directories put together.
List<File>	getWritableLedgerDirs()	Get only writable ledger dirs.
List<File>	getWritableLedgerDirsForNewLog()
boolean	hasWritableLedgerDirs()
boolean	isDirFull(File dir)	Get dirs, which are full more than threshold.
(package private) boolean	isDirWritableForNewIndexFile(File indexDir)
(package private) File	pickRandomDir(File excludedDir)	Return one dir from all dirs, regardless writable or not.
(package private) File	pickRandomDir(List<File> dirs, File excludedDir)
(package private) File	pickRandomWritableDir()	Returns one of the ledger dir from writable dirs list randomly.
(package private) File	pickRandomWritableDir(File excludedDir)	Pick up a writable dir from available dirs list randomly.
(package private) File	pickRandomWritableDirForNewIndexFile(File excludedDir)	Pick up a dir randomly from writableLedgerDirectories.

Methods inherited from class java.lang.Object

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

Constructor Details

LedgerDirsManager

public LedgerDirsManager(ServerConfiguration conf,
 File[] dirs,
 DiskChecker diskChecker)
                  throws IOException

Throws:

IOException

LedgerDirsManager

public LedgerDirsManager(ServerConfiguration conf,
 File[] dirs,
 DiskChecker diskChecker,
 StatsLogger statsLogger)
                  throws IOException

Throws:

IOException

Method Details

getAllLedgerDirs

public List<File> getAllLedgerDirs()

Get all ledger dirs configured.

getListeners

public List<LedgerDirsManager.LedgerDirsListener> getListeners()

Get all dir listeners.

Returns:

list of listeners

getTotalFreeSpace

public long getTotalFreeSpace(List<File> dirs)
                       throws IOException

Calculate the total amount of free space available in all of the ledger directories put together.

Returns:

freeDiskSpace in bytes

Throws:

IOException

getTotalDiskSpace

public long getTotalDiskSpace(List<File> dirs)
                       throws IOException

Calculate the total amount of disk space in all of the ledger directories put together.

Returns:

totalDiskSpace in bytes

Throws:

IOException

getDiskUsages

public ConcurrentMap<File,Float> getDiskUsages()

Get disk usages map.

Returns:

disk usages map

getWritableLedgerDirs

public List<File> getWritableLedgerDirs()
                                 throws LedgerDirsManager.NoWritableLedgerDirException

Get only writable ledger dirs.

Throws:

LedgerDirsManager.NoWritableLedgerDirException

hasWritableLedgerDirs

public boolean hasWritableLedgerDirs()

Returns:

true if the writableLedgerDirs list has entries

getWritableLedgerDirsForNewLog

public List<File> getWritableLedgerDirsForNewLog()
                                          throws LedgerDirsManager.NoWritableLedgerDirException

Throws:

LedgerDirsManager.NoWritableLedgerDirException

getDirsAboveUsableThresholdSize

List<File> getDirsAboveUsableThresholdSize(long thresholdSize,
 boolean loggingNoWritable)
                                    throws LedgerDirsManager.NoWritableLedgerDirException

Throws:

LedgerDirsManager.NoWritableLedgerDirException

getFullFilledLedgerDirs

public List<File> getFullFilledLedgerDirs()

Returns:

full-filled ledger dirs.

isDirFull

public boolean isDirFull(File dir)

Get dirs, which are full more than threshold.

addToFilledDirs

public void addToFilledDirs(File dir)

Add the dir to filled dirs list.

addToWritableDirs

public void addToWritableDirs(File dir,
 boolean underWarnThreshold)

Add the dir to writable dirs list.

Parameters:

dir - Dir

pickRandomWritableDir

File pickRandomWritableDir()
                    throws LedgerDirsManager.NoWritableLedgerDirException

Returns one of the ledger dir from writable dirs list randomly.

Throws:

LedgerDirsManager.NoWritableLedgerDirException

pickRandomWritableDir

File pickRandomWritableDir(File excludedDir)
                    throws LedgerDirsManager.NoWritableLedgerDirException

Pick up a writable dir from available dirs list randomly. The excludedDir will not be pickedup.

Parameters:

excludedDir - The directory to exclude during pickup.

Throws:

LedgerDirsManager.NoWritableLedgerDirException - if there is no writable dir available.

pickRandomWritableDirForNewIndexFile

File pickRandomWritableDirForNewIndexFile(File excludedDir)
                                   throws LedgerDirsManager.NoWritableLedgerDirException

Pick up a dir randomly from writableLedgerDirectories. If writableLedgerDirectories is empty then pick up a dir randomly from the ledger/indexdirs which have usable space more than minUsableSizeForIndexFileCreation.

Parameters:

excludedDir - The directory to exclude during pickup.

Returns:

Throws:

LedgerDirsManager.NoWritableLedgerDirException - if there is no dir available.

isDirWritableForNewIndexFile

boolean isDirWritableForNewIndexFile(File indexDir)

pickRandomDir

File pickRandomDir(File excludedDir)
            throws LedgerDirsManager.NoWritableLedgerDirException

Return one dir from all dirs, regardless writable or not.

Throws:

LedgerDirsManager.NoWritableLedgerDirException

pickRandomDir

File pickRandomDir(List<File> dirs,
 File excludedDir)
            throws LedgerDirsManager.NoWritableLedgerDirException

Throws:

LedgerDirsManager.NoWritableLedgerDirException

addLedgerDirsListener

public void addLedgerDirsListener(LedgerDirsManager.LedgerDirsListener listener)

getDiskChecker

public DiskChecker getDiskChecker()