Package org.iq80.leveldb.impl

Class DbImpl

java.lang.Object

org.iq80.leveldb.impl.DbImpl

All Implemented Interfaces:

Closeable, AutoCloseable, Iterable<Map.Entry<byte[],byte[]>>, DB

public class DbImpl
extends Object
implements DB

Nested Class Summary

Nested Classes

Modifier and Type	Class	Description
static class	DbImpl.BackgroundProcessingException
private static class	DbImpl.CompactionState
static class	DbImpl.DatabaseShutdownException
private static class	DbImpl.InsertIntoHandler
private static class	DbImpl.ManualCompaction

Field Summary

Fields

Modifier and Type	Field	Description
private Future<?>	backgroundCompaction
private final Condition	backgroundCondition
private Throwable	backgroundException
private final ExecutorService	compactionExecutor
private final File	databaseDir
private final DbLock	dbLock
private MemTable	immutableMemTable
private final InternalKeyComparator	internalKeyComparator
private LogWriter	log
private DbImpl.ManualCompaction	manualCompaction
private MemTable	memTable
private final ReentrantLock	mutex
private final Options	options
private final List<Long>	pendingOutputs
private final AtomicBoolean	shuttingDown
private int	suspensionCounter
private final Object	suspensionMutex
private final TableCache	tableCache
private final VersionSet	versions

Constructor Summary

Constructors

Constructor	Description
DbImpl(Options options, File databaseDir)

Method Summary

Modifier and Type	Method	Description
private void	backgroundCall()
private void	backgroundCompaction()
private FileMetaData	buildTable(SeekingIterable<InternalKey,Slice> data, long fileNumber)
void	checkBackgroundException()
private void	cleanupCompaction(DbImpl.CompactionState compactionState)
void	close()
void	compactMemTable()
private void	compactMemTableInternal()
void	compactRange(byte[] begin, byte[] end)	Force a compaction of the specified key range.
void	compactRange(int level, Slice start, Slice end)
WriteBatch	createWriteBatch()
void	delete(byte[] key)
Snapshot	delete(byte[] key, WriteOptions options)
private void	deleteObsoleteFiles()
private void	doCompactionWork(DbImpl.CompactionState compactionState)
private void	finishCompactionOutputFile(DbImpl.CompactionState compactionState)
void	flushMemTable()
byte[]	get(byte[] key)
byte[]	get(byte[] key, ReadOptions options)
long	getApproximateSizes(Range range)
long[]	getApproximateSizes(Range... ranges)
long	getMaxNextLevelOverlappingBytes()
String	getProperty(String name)
Snapshot	getSnapshot()
private SnapshotImpl	getSnapshot(ReadOptions options)
private void	installCompactionResults(DbImpl.CompactionState compact)
(package private) SeekingIterable<InternalKey,Slice>	internalIterable()
(package private) DbIterator	internalIterator()
SeekingIteratorAdapter	iterator()
SeekingIteratorAdapter	iterator(ReadOptions options)
private void	makeRoomForWrite(boolean force)
private void	maybeScheduleCompaction()
(package private) int	numberOfFilesInLevel(int level)
private void	openCompactionOutputFile(DbImpl.CompactionState compactionState)
void	put(byte[] key, byte[] value)
Snapshot	put(byte[] key, byte[] value, WriteOptions options)
private WriteBatchImpl	readWriteBatch(SliceInput record, int updateSize)
private long	recoverLogFile(long fileNumber, VersionEdit edit)
void	resumeCompactions()	Resumes the background compaction threads.
void	suspendCompactions()	Suspends any background compaction threads.
void	write(WriteBatch updates)
Snapshot	write(WriteBatch updates, WriteOptions options)
Snapshot	writeInternal(WriteBatchImpl updates, WriteOptions options)
private void	writeLevel0Table(MemTable mem, VersionEdit edit, Version base)
private Slice	writeWriteBatch(WriteBatchImpl updates, long sequenceBegin)

Methods inherited from class java.lang.Object

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

Methods inherited from interface java.lang.Iterable

forEach, spliterator

Field Details

options

private final Options options

databaseDir

private final File databaseDir

tableCache

private final TableCache tableCache

dbLock

private final DbLock dbLock

versions

private final VersionSet versions

shuttingDown

private final AtomicBoolean shuttingDown

mutex

private final ReentrantLock mutex

backgroundCondition

private final Condition backgroundCondition

pendingOutputs

private final List<Long> pendingOutputs

log

private LogWriter log

memTable

private MemTable memTable

immutableMemTable

private MemTable immutableMemTable

internalKeyComparator

private final InternalKeyComparator internalKeyComparator

backgroundException

private volatile Throwable backgroundException

compactionExecutor

private final ExecutorService compactionExecutor

backgroundCompaction

private Future<?> backgroundCompaction

manualCompaction

private DbImpl.ManualCompaction manualCompaction

suspensionMutex

private final Object suspensionMutex

suspensionCounter

private int suspensionCounter

Constructor Details

DbImpl

public DbImpl(Options options,
 File databaseDir)
       throws IOException

Throws:

IOException

Method Details

close

public void close()

Specified by:

close in interface AutoCloseable

Specified by:

close in interface Closeable

getProperty

public String getProperty(String name)

Specified by:

getProperty in interface DB

deleteObsoleteFiles

private void deleteObsoleteFiles()

flushMemTable

public void flushMemTable()

compactRange

public void compactRange(int level,
 Slice start,
 Slice end)

maybeScheduleCompaction

private void maybeScheduleCompaction()

checkBackgroundException

public void checkBackgroundException()

backgroundCall

private void backgroundCall()
                     throws IOException

Throws:

IOException

backgroundCompaction

private void backgroundCompaction()
                           throws IOException

Throws:

IOException

cleanupCompaction

private void cleanupCompaction(DbImpl.CompactionState compactionState)

recoverLogFile

private long recoverLogFile(long fileNumber,
 VersionEdit edit)
                     throws IOException

Throws:

IOException

get

public byte[] get(byte[] key)
           throws DBException

Specified by:

get in interface DB

Throws:

DBException

get

public byte[] get(byte[] key,
 ReadOptions options)
           throws DBException

Specified by:

get in interface DB

Throws:

DBException

put

public void put(byte[] key,
 byte[] value)
         throws DBException

Specified by:

put in interface DB

Throws:

DBException

put

public Snapshot put(byte[] key,
 byte[] value,
 WriteOptions options)
             throws DBException

Specified by:

put in interface DB

Returns:

null if options.isSnapshot()==false otherwise returns a snapshot of the DB after this operation.

Throws:

DBException

delete

public void delete(byte[] key)
            throws DBException

Specified by:

delete in interface DB

Throws:

DBException

delete

public Snapshot delete(byte[] key,
 WriteOptions options)
                throws DBException

Specified by:

delete in interface DB

Returns:

null if options.isSnapshot()==false otherwise returns a snapshot of the DB after this operation.

Throws:

DBException

write

public void write(WriteBatch updates)
           throws DBException

Specified by:

write in interface DB

Throws:

DBException

write

public Snapshot write(WriteBatch updates,
 WriteOptions options)
               throws DBException

Specified by:

write in interface DB

Returns:

null if options.isSnapshot()==false otherwise returns a snapshot of the DB after this operation.

Throws:

DBException

writeInternal

public Snapshot writeInternal(WriteBatchImpl updates,
 WriteOptions options)
                       throws DBException

Throws:

DBException

createWriteBatch

public WriteBatch createWriteBatch()

Specified by:

createWriteBatch in interface DB

iterator

public SeekingIteratorAdapter iterator()

Specified by:

iterator in interface DB

Specified by:

iterator in interface Iterable<Map.Entry<byte[],byte[]>>

iterator

public SeekingIteratorAdapter iterator(ReadOptions options)

Specified by:

iterator in interface DB

internalIterable

SeekingIterable<InternalKey,Slice> internalIterable()

internalIterator

DbIterator internalIterator()

getSnapshot

public Snapshot getSnapshot()

Specified by:

getSnapshot in interface DB

getSnapshot

private SnapshotImpl getSnapshot(ReadOptions options)

makeRoomForWrite

private void makeRoomForWrite(boolean force)

compactMemTable

public void compactMemTable()
                     throws IOException

Throws:

IOException

compactMemTableInternal

private void compactMemTableInternal()
                              throws IOException

Throws:

IOException

writeLevel0Table

private void writeLevel0Table(MemTable mem,
 VersionEdit edit,
 Version base)
                       throws IOException

Throws:

IOException

buildTable

private FileMetaData buildTable(SeekingIterable<InternalKey,Slice> data,
 long fileNumber)
                         throws IOException

Throws:

IOException

doCompactionWork

private void doCompactionWork(DbImpl.CompactionState compactionState)
                       throws IOException

Throws:

IOException

openCompactionOutputFile

private void openCompactionOutputFile(DbImpl.CompactionState compactionState)
                               throws FileNotFoundException

Throws:

FileNotFoundException

finishCompactionOutputFile

private void finishCompactionOutputFile(DbImpl.CompactionState compactionState)
                                 throws IOException

Throws:

IOException

installCompactionResults

private void installCompactionResults(DbImpl.CompactionState compact)
                               throws IOException

Throws:

IOException

numberOfFilesInLevel

int numberOfFilesInLevel(int level)

getApproximateSizes

public long[] getApproximateSizes(Range... ranges)

Specified by:

getApproximateSizes in interface DB

getApproximateSizes

public long getApproximateSizes(Range range)

getMaxNextLevelOverlappingBytes

public long getMaxNextLevelOverlappingBytes()

readWriteBatch

private WriteBatchImpl readWriteBatch(SliceInput record,
 int updateSize)
                               throws IOException

Throws:

IOException

writeWriteBatch

private Slice writeWriteBatch(WriteBatchImpl updates,
 long sequenceBegin)

suspendCompactions

public void suspendCompactions()
                        throws InterruptedException

Description copied from interface: DB

Suspends any background compaction threads. This methods returns once the background compactions are suspended.

Specified by:

suspendCompactions in interface DB

Throws:

InterruptedException

resumeCompactions

public void resumeCompactions()

Description copied from interface: DB

Resumes the background compaction threads.

Specified by:

resumeCompactions in interface DB

compactRange

public void compactRange(byte[] begin,
 byte[] end)
                  throws DBException

Description copied from interface: DB

Force a compaction of the specified key range.

Specified by:

compactRange in interface DB

Parameters:

begin - if null then compaction start from the first key

end - if null then compaction ends at the last key

Throws:

DBException