org.fusesource.hawtdb.internal.io

Class MemoryMappedFile

java.lang.Object

org.fusesource.hawtdb.internal.io.MemoryMappedFile

public final class MemoryMappedFile
extends Object

Provides Memory Mapped access to a file. It manages pooling the direct buffers which mapped to the files. Multiple direct buffers are used to deal with OS and Java restrictions.

Author:

Hiram Chirino

Nested Class Summary

Nested Classes

Modifier and Type	Class and Description
static class	MemoryMappedFile.ChannelTransfer

Constructor Summary

Constructors

Constructor and Description
MemoryMappedFile(File file, int bufferSize, boolean readOnly)

Method Summary

Modifier and Type	Method and Description
void	close()
void	read(long position, org.fusesource.hawtbuf.Buffer data)
void	read(long position, byte[] data)
void	read(long position, byte[] data, int offset, int length)
ByteBuffer	read(long position, int length)
MemoryMappedFile.ChannelTransfer	readChannelTansfer(int position, int length)
ByteBuffer	slice(boolean readOnly, long position, int length)
void	sync()
void	unslice(ByteBuffer buffer)
void	write(long position, org.fusesource.hawtbuf.Buffer data)
void	write(long position, byte[] data)
void	write(long position, byte[] data, int offset, int length)
void	write(long position, ByteBuffer data)
void	writeChannelTansfer(long position, MemoryMappedFile.ChannelTransfer transfer)

Methods inherited from class java.lang.Object

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

Constructor Detail

MemoryMappedFile

public MemoryMappedFile(File file,
                        int bufferSize,
                        boolean readOnly)
                 throws IOException

Throws:

IOException

Method Detail

read

public void read(long position,
                 byte[] data)
          throws IOPagingException

Throws:

IOPagingException

read

public void read(long position,
                 org.fusesource.hawtbuf.Buffer data)
          throws IOPagingException

Throws:

IOPagingException

read

public void read(long position,
                 byte[] data,
                 int offset,
                 int length)
          throws IOPagingException

Throws:

IOPagingException

read

public ByteBuffer read(long position,
                       int length)
                throws IOPagingException

Throws:

IOPagingException

slice

public ByteBuffer slice(boolean readOnly,
                        long position,
                        int length)

unslice

public void unslice(ByteBuffer buffer)

readChannelTansfer

public MemoryMappedFile.ChannelTransfer readChannelTansfer(int position,
                                                           int length)
                                                    throws IOPagingException

Throws:

IOPagingException

writeChannelTansfer

public void writeChannelTansfer(long position,
                                MemoryMappedFile.ChannelTransfer transfer)
                         throws IOPagingException

Throws:

IOPagingException

write

public void write(long position,
                  byte[] data)
           throws IOPagingException

Throws:

IOPagingException

write

public void write(long position,
                  org.fusesource.hawtbuf.Buffer data)
           throws IOPagingException

Throws:

IOPagingException

write

public void write(long position,
                  ByteBuffer data)
           throws IOPagingException

Throws:

IOPagingException

write

public void write(long position,
                  byte[] data,
                  int offset,
                  int length)
           throws IOPagingException

Throws:

IOPagingException

sync

public void sync()
          throws IOPagingException

Throws:

IOPagingException

close

public void close()
           throws IOPagingException

Throws:

IOPagingException