Package com.intellij.util.io.storage

Class AbstractStorage

java.lang.Object

com.intellij.util.io.storage.AbstractStorage

All Implemented Interfaces:

Disposable, Forceable

Direct Known Subclasses:

LocalHistoryStorage, RefCountingStorage, Storage

public abstract class AbstractStorage
extends java.lang.Object
implements Disposable, Forceable

Nested Class Summary

Nested Classes

Modifier and Type	Class and Description
class	AbstractStorage.AppenderStream
static class	AbstractStorage.StorageDataOutput

Nested classes/interfaces inherited from interface com.intellij.openapi.Disposable

Disposable.Parent

Field Summary

Fields

Modifier and Type	Field and Description
static java.lang.String	DATA_EXTENSION
static java.lang.String	INDEX_EXTENSION
protected static Logger	LOG
protected com.intellij.util.io.storage.DataTable	myDataTable
protected java.lang.Object	myLock
protected PagePool	myPool
protected AbstractRecordsTable	myRecordsTable

Constructor Summary

Constructors

Modifier	Constructor and Description
protected	AbstractStorage(java.lang.String storageFilePath)
protected	AbstractStorage(java.lang.String storageFilePath, CapacityAllocationPolicy capacityAllocationPolicy)
protected	AbstractStorage(java.lang.String storageFilePath, PagePool pool)
protected	AbstractStorage(java.lang.String storageFilePath, PagePool pool, CapacityAllocationPolicy capacityAllocationPolicy)

Method Summary

Modifier and Type	Method and Description
protected void	appendBytes(int record, ByteArraySequence bytes)
AbstractStorage.AppenderStream	appendStream(int record)
void	checkSanity(int record)
RecordIdIterator	createRecordIdIterator()
protected abstract AbstractRecordsTable	createRecordsTable(PagePool pool, java.io.File recordsFile)
static boolean	deleteFiles(java.lang.String storageFilePath)
void	dispose() Usually not invoked directly, see class javadoc.
protected void	doDeleteRecord(int record)
boolean	flushSome()
void	force()
int	getLiveRecordsCount()
int	getVersion()
boolean	isDirty()
protected byte[]	readBytes(int record)
java.io.DataInputStream	readStream(int record)
void	replaceBytes(int record, int offset, ByteArraySequence bytes)
void	setVersion(int expectedVersion)
void	writeBytes(int record, ByteArraySequence bytes, boolean fixedSize)
AbstractStorage.StorageDataOutput	writeStream(int record)
AbstractStorage.StorageDataOutput	writeStream(int record, boolean fixedSize)

Methods inherited from class java.lang.Object

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

Field Detail

LOG

protected static final Logger LOG

INDEX_EXTENSION

public static final java.lang.String INDEX_EXTENSION

See Also:

Constant Field Values

DATA_EXTENSION

public static final java.lang.String DATA_EXTENSION

See Also:

Constant Field Values

myLock

protected final java.lang.Object myLock

myRecordsTable

protected AbstractRecordsTable myRecordsTable

myDataTable

protected com.intellij.util.io.storage.DataTable myDataTable

myPool

protected PagePool myPool

Constructor Detail

AbstractStorage

protected AbstractStorage(java.lang.String storageFilePath)
                   throws java.io.IOException

Throws:

java.io.IOException

AbstractStorage

protected AbstractStorage(java.lang.String storageFilePath,
                          PagePool pool)
                   throws java.io.IOException

Throws:

java.io.IOException

AbstractStorage

protected AbstractStorage(java.lang.String storageFilePath,
                          CapacityAllocationPolicy capacityAllocationPolicy)
                   throws java.io.IOException

Throws:

java.io.IOException

AbstractStorage

protected AbstractStorage(java.lang.String storageFilePath,
                          PagePool pool,
                          CapacityAllocationPolicy capacityAllocationPolicy)
                   throws java.io.IOException

Throws:

java.io.IOException

Method Detail

deleteFiles

public static boolean deleteFiles(java.lang.String storageFilePath)

createRecordsTable

protected abstract AbstractRecordsTable createRecordsTable(PagePool pool,
                                                           java.io.File recordsFile)
                                                    throws java.io.IOException

Throws:

java.io.IOException

getVersion

public int getVersion()

setVersion

public void setVersion(int expectedVersion)

force

public void force()

Specified by:

force in interface Forceable

flushSome

public boolean flushSome()

isDirty

public boolean isDirty()

Specified by:

isDirty in interface Forceable

getLiveRecordsCount

public int getLiveRecordsCount()
                        throws java.io.IOException

Throws:

java.io.IOException

createRecordIdIterator

public RecordIdIterator createRecordIdIterator()
                                        throws java.io.IOException

Throws:

java.io.IOException

writeStream

public AbstractStorage.StorageDataOutput writeStream(int record)

writeStream

public AbstractStorage.StorageDataOutput writeStream(int record,
                                                     boolean fixedSize)

appendStream

public AbstractStorage.AppenderStream appendStream(int record)

readStream

public java.io.DataInputStream readStream(int record)
                                   throws java.io.IOException

Throws:

java.io.IOException

readBytes

protected byte[] readBytes(int record)
                    throws java.io.IOException

Throws:

java.io.IOException

appendBytes

protected void appendBytes(int record,
                           ByteArraySequence bytes)
                    throws java.io.IOException

Throws:

java.io.IOException

writeBytes

public void writeBytes(int record,
                       ByteArraySequence bytes,
                       boolean fixedSize)
                throws java.io.IOException

Throws:

java.io.IOException

doDeleteRecord

protected void doDeleteRecord(int record)
                       throws java.io.IOException

Throws:

java.io.IOException

dispose

public void dispose()

Description copied from interface: Disposable

Usually not invoked directly, see class javadoc.

Specified by:

dispose in interface Disposable

checkSanity

public void checkSanity(int record)

replaceBytes

public void replaceBytes(int record,
                         int offset,
                         ByteArraySequence bytes)
                  throws java.io.IOException

Throws:

java.io.IOException