com.caucho.db.io

Class StoreReadWriteImpl

java.lang.Object

com.caucho.db.io.StoreReadWriteImpl

All Implemented Interfaces:

StoreReadWrite

public class StoreReadWriteImpl
extends java.lang.Object
implements StoreReadWrite

Filesystem access for a random-access store. The store is designed around a single writer thread and multiple reader threads. When possible, it uses mmap.

Field Summary

Fields inherited from interface com.caucho.db.io.StoreReadWrite

FILE_SIZE_INCREMENT

Method Summary

Modifier and Type	Method and Description
void	close()
void	create() Creates the store.
void	fsync()
long	getChunkSize() Returns the alignment size for mmaps.
long	getFileSize() Returns the file size.
long	getMmapCloseTimeout()
void	init()
InStore	openRead(long offset, int size) Opens the underlying file to the database.
OutStore	openWrite(long offset, int size) Opens the underlying file to the database.
java.lang.String	toString()

Methods inherited from class java.lang.Object

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

Method Detail

getFileSize

public long getFileSize()

Returns the file size.

Specified by:

getFileSize in interface StoreReadWrite

getChunkSize

public long getChunkSize()

Description copied from interface: StoreReadWrite

Returns the alignment size for mmaps.

Specified by:

getChunkSize in interface StoreReadWrite

getMmapCloseTimeout

public long getMmapCloseTimeout()

Specified by:

getMmapCloseTimeout in interface StoreReadWrite

create

public void create()
            throws java.io.IOException

Creates the store.

Specified by:

create in interface StoreReadWrite

Throws:

java.io.IOException

init

public void init()
          throws java.io.IOException

Specified by:

init in interface StoreReadWrite

Throws:

java.io.IOException

openRead

public InStore openRead(long offset,
                        int size)

Opens the underlying file to the database.

Specified by:

openRead in interface StoreReadWrite

openWrite

public OutStore openWrite(long offset,
                          int size)

Opens the underlying file to the database.

Specified by:

openWrite in interface StoreReadWrite

fsync

public void fsync()

Specified by:

fsync in interface StoreReadWrite

close

public void close()

Specified by:

close in interface StoreReadWrite

toString

public java.lang.String toString()

Overrides:

toString in class java.lang.Object