public final class MultiBufferedRandomAccessFile
extends java.lang.Object
implements java.io.DataInput, java.io.DataOutput, java.io.Closeable
Constructor and Description |
---|
MultiBufferedRandomAccessFile(java.io.File file,
int bufSize,
int maxBuffers)
Create a read-only random access file with the specified maximum number of buffers of the specified size.
|
MultiBufferedRandomAccessFile(java.io.File file,
int bufSize,
int maxBuffers,
boolean isWriteable)
Create a read-only or read-write random access file with the specified maximum number of buffers of the specified size.
|
MultiBufferedRandomAccessFile(java.io.File file,
int bufSize,
int maxBuffers,
boolean isWriteable,
boolean flushUnloadedBuffers)
Create a read-only or read-write random access file with the specified maximum number of buffers of the specified size.
|
MultiBufferedRandomAccessFile(java.io.File file,
int bufSize,
int maxBuffers,
boolean isWriteable,
boolean flushUnloadedBuffers,
boolean trackReloadedBlocks)
Create a read-only or read-write random access file with the specified maximum number of buffers of the specified size.
|
MultiBufferedRandomAccessFile(java.io.File file,
int bufSize,
int maxBuffers,
boolean isWriteable,
byte[] prefillPattern)
Create a read-only or read-write random access file with the specified maximum number of buffers of the specified size.
|
MultiBufferedRandomAccessFile(java.io.File file,
int bufSize,
int maxBuffers,
boolean isWriteable,
byte[] prefillPattern,
boolean trackReloadedBlocks)
Create a read-only or read-write random access file with the specified maximum number of buffers of the specified size.
|
Modifier and Type | Method and Description |
---|---|
void |
clearCache()
Clear the cache buffers.
|
void |
close()
Closes this file and releases any system resources
associated with the buffering.
|
void |
flush()
Flush all "dirty" (modified) buffers.
|
long |
getFilePointer()
Returns the current offset in this file.
|
int |
getNumConsecutiveHits()
Get number of consecutive times a read matched data already in the buffers or a write
overwrote data already in the buffers.
|
int |
getNumFlushes()
Get the number of times write-modified buffers had to be flushed to disk.
|
long |
getNumHits()
Get number of times a read matched data already in the buffers or a write
overwrote data already in the buffers.
|
long |
getNumMisses()
Get the number of times a read or write required loading a buffer from
disk.
|
int |
getNumReReads()
Get the number of times a block that had already been read into a buffer
was read again.
|
java.io.RandomAccessFile |
getRandomAccessFile()
Get the RandomAccessFile underlying this MultiBufferedRandomAccessFile.
|
int |
read()
Reads the next byte in the file at the current seek position.
|
boolean |
readBoolean()
See the general contract of the
readBoolean
method of DataInput . |
byte |
readByte()
See the general contract of the
readByte
method of DataInput . |
char |
readChar()
See the general contract of the
readChar
method of DataInput . |
double |
readDouble()
See the general contract of the
readDouble
method of DataInput . |
float |
readFloat()
See the general contract of the
readFloat
method of DataInput . |
void |
readFully(byte[] b)
See the general contract of the
readFully
method of DataInput . |
void |
readFully(byte[] b,
int off,
int len)
See the general contract of the
readFully
method of DataInput . |
int |
readInt()
See the general contract of the
readInt
method of DataInput . |
int |
readIntAt(long seekPos)
Bytes
for this operation are read from the contained
file.
|
java.lang.String |
readLine()
See the general contract of the
readLine
method of DataInput . |
long |
readLong()
See the general contract of the
readLong
method of DataInput . |
int |
readNextInt()
This is similar to
readInt() , but the caller must guarantee that no seek(long)
occurred between the last call to readInt() or readNextInt() and this one. |
short |
readShort()
See the general contract of the
readShort
method of DataInput . |
int |
readUnsignedByte()
See the general contract of the
readUnsignedByte
method of DataInput . |
int |
readUnsignedShort()
See the general contract of the
readUnsignedShort
method of DataInput . |
java.lang.String |
readUTF()
See the general contract of the
readUTF
method of DataInput . |
void |
resetOldPages()
If being used, clear the history of already-accessed pages.
|
void |
resetStatistics()
Reset the statistics counters that are reported by the toString() method.
|
void |
seek(long seekPos)
Sets the file-pointer offset, measured from the beginning of this
file, at which the next read occurs.
|
int |
skipBytes(int n)
See the general contract of the
skipBytes
method of DataInput . |
java.lang.String |
toString()
Returns a string representation of the object.
|
void |
write(byte[] b)
Writes to the output stream all the bytes in array
b . |
void |
write(byte[] b,
int off,
int len)
Writes
len bytes from array
b , in order, to
the output stream. |
void |
write(int b)
Writes to the output stream the eight
low-order bits of the argument
b . |
void |
write2Int(int v1,
int v2)
Writes 2
int values, each of which is
comprised of four bytes, to the output stream. |
void |
write2Int(long seekPos,
int v1,
int v2)
Sets the file-pointer offset, measured from the beginning of this
file, at which the next read occurs.
|
void |
writeBoolean(boolean v)
Writes a
boolean value to this output stream. |
void |
writeByte(int v)
Writes to the output stream the eight low-
order bits of the argument
v . |
void |
writeBytes(java.lang.String s)
Writes a string to the output stream.
|
void |
writeChar(int v)
Writes a
char value, which
is comprised of two bytes, to the
output stream. |
void |
writeChars(java.lang.String s)
Writes every character in the string
s ,
to the output stream, in order,
two bytes per character. |
void |
writeDouble(double v)
Writes a
double value,
which is comprised of eight bytes, to the output stream. |
void |
writeFloat(float v)
Writes a
float value,
which is comprised of four bytes, to the output stream. |
void |
writeInt(int v)
Writes an
int value, which is
comprised of four bytes, to the output stream. |
void |
writeLong(long v)
Writes a
long value, which is
comprised of eight bytes, to the output stream. |
void |
writeShort(int v)
Writes two bytes to the output
stream to represent the value of the argument.
|
void |
writeUTF(java.lang.String s)
Writes two bytes of length information
to the output stream, followed
by the modified UTF-8 representation
of every character in the string
s . |
public MultiBufferedRandomAccessFile(java.io.File file, int bufSize, int maxBuffers) throws java.io.IOException
file
- File pointing at the disk file to readbufSize
- size of each buffer in bytes (must be a power of 2)maxBuffers
- maximum number of buffers to usejava.io.IOException
- if file cannot be opened for read-only accesspublic MultiBufferedRandomAccessFile(java.io.File file, int bufSize, int maxBuffers, boolean isWriteable) throws java.io.IOException
file
- File pointing at the disk file to readbufSize
- size of each buffer in bytes (must be a power of 2)maxBuffers
- maximum number of buffers to useisWriteable
- boolean true if this file can be written tojava.io.IOException
- if file cannot be opened for the requested accesspublic MultiBufferedRandomAccessFile(java.io.File file, int bufSize, int maxBuffers, boolean isWriteable, boolean flushUnloadedBuffers) throws java.io.IOException
file
- File pointing at the disk file to readbufSize
- size of each buffer in bytes (must be a power of 2)maxBuffers
- maximum number of buffers to useisWriteable
- boolean true if this file can be written toflushUnloadedBuffers
- specify whether capable systems should flush released buffers from
kernel filesystem cache to reduce cache overgrowthjava.io.IOException
- if file cannot be opened for the requested accesspublic MultiBufferedRandomAccessFile(java.io.File file, int bufSize, int maxBuffers, boolean isWriteable, boolean flushUnloadedBuffers, boolean trackReloadedBlocks) throws java.io.IOException
file
- File pointing at the disk file to readbufSize
- size of each buffer in bytes (must be a power of 2)maxBuffers
- maximum number of buffers to useisWriteable
- boolean true if this file can be written toflushUnloadedBuffers
- specify whether capable systems should flush released buffers from
kernel filesystem cache to reduce cache overgrowthtrackReloadedBlocks
- boolean true if rereads of blocks should be tracked, false if notjava.io.IOException
- if file cannot be opened for the requested accesspublic MultiBufferedRandomAccessFile(java.io.File file, int bufSize, int maxBuffers, boolean isWriteable, byte[] prefillPattern) throws java.io.IOException
file
- File pointing at the disk file to readbufSize
- size of each buffer in bytes (must be a power of 2)maxBuffers
- maximum number of buffers to useisWriteable
- boolean true if this file can be written toprefillPattern
- byte array to iteratively write to a new buffer as a fill patternjava.io.IOException
- if file cannot be opened for the requested accesspublic MultiBufferedRandomAccessFile(java.io.File file, int bufSize, int maxBuffers, boolean isWriteable, byte[] prefillPattern, boolean trackReloadedBlocks) throws java.io.IOException
file
- File pointing at the disk file to readbufSize
- size of each buffer in bytes (must be a power of 2)maxBuffers
- maximum number of buffers to useisWriteable
- boolean true if this file can be written toprefillPattern
- byte array to iteratively write to a new buffer as a fill patterntrackReloadedBlocks
- boolean true if rereads of blocks should be tracked, false if notjava.io.IOException
- if file cannot be opened for the requested accesspublic int read() throws java.io.IOException
java.io.EOFException
- if attempt to read past the end of filejava.io.IOException
- if this input stream has been closed by
invoking its close()
method,
or an I/O error occurs.seek(long)
public boolean readBoolean() throws java.io.IOException
readBoolean
method of DataInput
.
Bytes for this operation are read from the contained file.
readBoolean
in interface java.io.DataInput
boolean
value read.java.io.EOFException
- if this input stream has reached the end.java.io.IOException
- the stream has been closed and the contained
input stream does not support reading after close, or
another I/O error occurs.public byte readByte() throws java.io.IOException
readByte
method of DataInput
.
Bytes for this operation are read from the contained file.
readByte
in interface java.io.DataInput
byte
.java.io.EOFException
- if this input stream has reached the end.java.io.IOException
- the stream has been closed and the contained
input stream does not support reading after close, or
another I/O error occurs.public char readChar() throws java.io.IOException
readChar
method of DataInput
.
Bytes for this operation are read from the contained input stream.
readChar
in interface java.io.DataInput
char
.java.io.EOFException
- if this input stream reaches the end before
reading two bytes.java.io.IOException
- the stream has been closed and the contained
input stream does not support reading after close, or
another I/O error occurs.public double readDouble() throws java.io.IOException
readDouble
method of DataInput
.
Bytes for this operation are read from the contained file.
readDouble
in interface java.io.DataInput
double
.java.io.EOFException
- if this input stream reaches the end before
reading eight bytes.java.io.IOException
- the stream has been closed and the contained
input stream does not support reading after close, or
another I/O error occurs.DataInputStream.readLong()
,
Double.longBitsToDouble(long)
public float readFloat() throws java.io.IOException
readFloat
method of DataInput
.
Bytes for this operation are read from the contained file.
readFloat
in interface java.io.DataInput
float
.java.io.EOFException
- if this input stream reaches the end before
reading four bytes.java.io.IOException
- the stream has been closed and the contained
input stream does not support reading after close, or
another I/O error occurs.DataInputStream.readInt()
,
Float.intBitsToFloat(int)
public void readFully(byte[] b) throws java.io.IOException
readFully
method of DataInput
.
Bytes for this operation are read from the contained file.
readFully
in interface java.io.DataInput
b
- the buffer into which the data is read.java.io.EOFException
- if this input stream reaches the end before
reading all the bytes.java.io.IOException
- the stream has been closed and the contained
input stream does not support reading after close, or
another I/O error occurs.public void readFully(byte[] b, int off, int len) throws java.io.IOException
readFully
method of DataInput
.
Bytes for this operation are read from the contained file.
readFully
in interface java.io.DataInput
b
- the buffer into which the data is read.off
- the start offset of the data.len
- the number of bytes to read.java.io.EOFException
- if this input stream reaches the end before
reading all the bytes.java.io.IOException
- the stream has been closed and the contained
input stream does not support reading after close, or
another I/O error occurs.public int readInt() throws java.io.IOException
readInt
method of DataInput
.
Bytes for this operation are read from the contained file.
readInt
in interface java.io.DataInput
int
.java.io.EOFException
- if this input stream reaches the end before
reading four bytes.java.io.IOException
- the stream has been closed and the contained
input stream does not support reading after close, or
another I/O error occurs.public java.lang.String readLine() throws java.io.IOException
readLine
method of DataInput
.
Bytes for this operation are read from the contained file. Note that this method only supports extended 8-bit ASCII; it does not support UTF-8 or other locale-specific character sets.
readLine
in interface java.io.DataInput
java.io.IOException
- if an I/O error occurs.public long readLong() throws java.io.IOException
readLong
method of DataInput
.
Bytes for this operation are read from the contained file.
readLong
in interface java.io.DataInput
long
.java.io.EOFException
- if this input stream reaches the end before
reading eight bytes.java.io.IOException
- the stream has been closed and the contained
input stream does not support reading after close, or
another I/O error occurs.public short readShort() throws java.io.IOException
readShort
method of DataInput
.
Bytes for this operation are read from the contained file.
readShort
in interface java.io.DataInput
java.io.EOFException
- if this input stream reaches the end before
reading two bytes.java.io.IOException
- the stream has been closed and the contained
input stream does not support reading after close, or
another I/O error occurs.public int readUnsignedByte() throws java.io.IOException
readUnsignedByte
method of DataInput
.
Bytes for this operation are read from the contained file.
readUnsignedByte
in interface java.io.DataInput
java.io.EOFException
- if this input stream has reached the end.java.io.IOException
- the stream has been closed and the contained
input stream does not support reading after close, or
another I/O error occurs.public int readUnsignedShort() throws java.io.IOException
readUnsignedShort
method of DataInput
.
Bytes for this operation are read from the contained file.
readUnsignedShort
in interface java.io.DataInput
java.io.EOFException
- if this input stream reaches the end before
reading two bytes.java.io.IOException
- the stream has been closed and the contained
input stream does not support reading after close, or
another I/O error occurs.public java.lang.String readUTF() throws java.io.IOException
readUTF
method of DataInput
.
Bytes for this operation are read from the contained file.
readUTF
in interface java.io.DataInput
java.io.EOFException
- if this input stream reaches the end before
reading all the bytes.java.io.IOException
- the stream has been closed and the contained
input stream does not support reading after close, or
another I/O error occurs.java.io.UTFDataFormatException
- if the bytes do not represent a valid
modified UTF-8 encoding of a string.public int skipBytes(int n)
skipBytes
method of DataInput
.
No actual bytes are read; the current file seek position pointer is merely updated in preparation for later I/O.
skipBytes
in interface java.io.DataInput
n
- the number of bytes to be skipped.public void seek(long seekPos)
seekPos
- the offset position, measured in bytes from the
beginning of the file, at which to set the file
pointer.public int readIntAt(long seekPos) throws java.io.IOException
seekPos
- the offset position, measured in bytes from the
beginning of the file, at which to set the file
pointer.int
.java.io.EOFException
- if this input stream reaches the end before
reading four bytes.java.io.IOException
- the stream has been closed and the contained
input stream does not support reading after close, or
another I/O error occurs.public long getFilePointer()
public void close() throws java.io.IOException
close
in interface java.io.Closeable
close
in interface java.lang.AutoCloseable
java.io.IOException
- if an I/O error occurs.public java.lang.String toString()
toString
in class java.lang.Object
public void resetStatistics()
toString()
public void resetOldPages()
public long getNumHits()
resetStatistics()
public int getNumConsecutiveHits()
resetStatistics()
public long getNumMisses()
resetStatistics()
public int getNumFlushes()
resetStatistics()
public int getNumReReads()
public int readNextInt() throws java.io.IOException
readInt()
, but the caller must guarantee that no seek(long)
occurred between the last call to readInt() or readNextInt() and this one.int
.java.io.EOFException
- if this input stream reaches the end before
reading four bytes.java.io.IOException
- the stream has been closed and the contained
input stream does not support reading after close, or
another I/O error occurs.readInt()
public void clearCache()
public void write(byte[] b) throws java.io.IOException
b
.
If b
is null
,
a NullPointerException
is thrown.
If b.length
is zero, then
no bytes are written. Otherwise, the byte
b[0]
is written first, then
b[1]
, and so on; the last byte
written is b[b.length-1]
.write
in interface java.io.DataOutput
b
- the data.java.io.IOException
- if an I/O error occurs.public void write(int b) throws java.io.IOException
b
.
The 24 high-order bits of b
are ignored.write
in interface java.io.DataOutput
b
- the byte to be written.java.io.IOException
- if an I/O error occurs.public void write(byte[] b, int off, int len) throws java.io.IOException
len
bytes from array
b
, in order, to
the output stream. If b
is null
, a NullPointerException
is thrown. If off
is negative,
or len
is negative, or off+len
is greater than the length of the array
b
, then an IndexOutOfBoundsException
is thrown. If len
is zero,
then no bytes are written. Otherwise, the
byte b[off]
is written first,
then b[off+1]
, and so on; the
last byte written is b[off+len-1]
.write
in interface java.io.DataOutput
b
- the data.off
- the start offset in the data.len
- the number of bytes to write.java.io.IOException
- if an I/O error occurs.public void writeBoolean(boolean v) throws java.io.IOException
boolean
value to this output stream.
If the argument v
is true
, the value (byte)1
is written; if v
is false
,
the value (byte)0
is written.
The byte written by this method may
be read by the readBoolean
method of interface DataInput
,
which will then return a boolean
equal to v
.writeBoolean
in interface java.io.DataOutput
v
- the boolean to be written.java.io.IOException
- if an I/O error occurs.public void writeByte(int v) throws java.io.IOException
v
.
The 24 high-order bits of v
are ignored. (This means that writeByte
does exactly the same thing as write
for an integer argument.) The byte written
by this method may be read by the readByte
method of interface DataInput
,
which will then return a byte
equal to (byte)v
.writeByte
in interface java.io.DataOutput
v
- the byte value to be written.java.io.IOException
- if an I/O error occurs.public void writeShort(int v) throws java.io.IOException
(byte)(0xff & (v >> 8))
(byte)(0xff & v)
The bytes written by this method may be
read by the readShort
method
of interface DataInput
, which
will then return a short
equal
to (short)v
.writeShort
in interface java.io.DataOutput
v
- the short
value to be written.java.io.IOException
- if an I/O error occurs.public void writeChar(int v) throws java.io.IOException
char
value, which
is comprised of two bytes, to the
output stream.
The byte values to be written, in the order
shown, are:
(byte)(0xff & (v >> 8))
(byte)(0xff & v)
The bytes written by this method may be
read by the readChar
method
of interface DataInput
, which
will then return a char
equal
to (char)v
.writeChar
in interface java.io.DataOutput
v
- the char
value to be written.java.io.IOException
- if an I/O error occurs.public void writeInt(int v) throws java.io.IOException
int
value, which is
comprised of four bytes, to the output stream.
The byte values to be written, in the order
shown, are:
(byte)(0xff & (v >> 24))
(byte)(0xff & (v >> 16))
(byte)(0xff & (v >> 8))
(byte)(0xff & v)
The bytes written by this method may be read
by the readInt
method of interface
DataInput
, which will then
return an int
equal to v
.writeInt
in interface java.io.DataOutput
v
- the int
value to be written.java.io.IOException
- if an I/O error occurs.public void write2Int(int v1, int v2) throws java.io.IOException
int
values, each of which is
comprised of four bytes, to the output stream.
The byte values to be written, in the order
shown, are:
(byte)(0xff & (v >> 24))
(byte)(0xff & (v >> 16))
(byte)(0xff & (v >> 8))
(byte)(0xff & v)
The bytes written by this method may be read
by the readInt
method of interface
DataInput
, which will then
return an int
equal to v
.v1
- the first int
value to be written.v2
- the first int
value to be written.java.io.IOException
- if an I/O error occurs.public void write2Int(long seekPos, int v1, int v2) throws java.io.IOException
int
values, each of which is
comprised of four bytes, to the output stream.
The byte values to be written, in the order
shown, are:
(byte)(0xff & (v >> 24))
(byte)(0xff & (v >> 16))
(byte)(0xff & (v >> 8))
(byte)(0xff & v)
The bytes written by this method may be read
by the readInt
method of interface
DataInput
, which will then
return an int
equal to v1
or v2
.seekPos
- the offset position, measured in bytes from the
beginning of the file, at which to set the file
pointer.v1
- the first int
value to be written.v2
- the first int
value to be written.java.io.IOException
- if an I/O error occurs.public void writeLong(long v) throws java.io.IOException
long
value, which is
comprised of eight bytes, to the output stream.
The byte values to be written, in the order
shown, are:
(byte)(0xff & (v >> 56))
(byte)(0xff & (v >> 48))
(byte)(0xff & (v >> 40))
(byte)(0xff & (v >> 32))
(byte)(0xff & (v >> 24))
(byte)(0xff & (v >> 16))
(byte)(0xff & (v >> 8))
(byte)(0xff & v)
The bytes written by this method may be
read by the readLong
method
of interface DataInput
, which
will then return a long
equal
to v
.writeLong
in interface java.io.DataOutput
v
- the long
value to be written.java.io.IOException
- if an I/O error occurs.public void writeFloat(float v) throws java.io.IOException
float
value,
which is comprised of four bytes, to the output stream.
It does this as if it first converts this
float
value to an int
in exactly the manner of the Float.floatToIntBits
method and then writes the int
value in exactly the manner of the writeInt
method. The bytes written by this method
may be read by the readFloat
method of interface DataInput
,
which will then return a float
equal to v
.writeFloat
in interface java.io.DataOutput
v
- the float
value to be written.java.io.IOException
- if an I/O error occurs.public void writeDouble(double v) throws java.io.IOException
double
value,
which is comprised of eight bytes, to the output stream.
It does this as if it first converts this
double
value to a long
in exactly the manner of the Double.doubleToLongBits
method and then writes the long
value in exactly the manner of the writeLong
method. The bytes written by this method
may be read by the readDouble
method of interface DataInput
,
which will then return a double
equal to v
.writeDouble
in interface java.io.DataOutput
v
- the double
value to be written.java.io.IOException
- if an I/O error occurs.public void writeBytes(java.lang.String s) throws java.io.IOException
s
, taken in order, one byte
is written to the output stream. If
s
is null
, a NullPointerException
is thrown. If s.length
is zero, then no bytes are written. Otherwise,
the character s[0]
is written
first, then s[1]
, and so on;
the last character written is s[s.length-1]
.
For each character, one byte is written,
the low-order byte, in exactly the manner
of the writeByte
method . The
high-order eight bits of each character
in the string are ignored.
writeBytes
in interface java.io.DataOutput
s
- the string of bytes to be written.java.io.IOException
- if an I/O error occurs.public void writeChars(java.lang.String s) throws java.io.IOException
s
,
to the output stream, in order,
two bytes per character. If s
is null
, a NullPointerException
is thrown. If s.length
is zero, then no characters are written.
Otherwise, the character s[0]
is written first, then s[1]
,
and so on; the last character written is
s[s.length-1]
. For each character,
two bytes are actually written, high-order
byte first, in exactly the manner of the
writeChar
method.writeChars
in interface java.io.DataOutput
s
- the string value to be written.java.io.IOException
- if an I/O error occurs.public void writeUTF(java.lang.String s) throws java.io.IOException
s
.
If s
is null
,
a NullPointerException
is thrown.
Each character in the string s
is converted to a group of one, two, or
three bytes, depending on the value of the
character.
If a character c
is in the range \u0001
through
\u007f
, it is represented
by one byte:
(byte)cIf a character
c
is \u0000
or is in the range \u0080
through \u07ff
, then it is
represented by two bytes, to be written
in the order shown:
(byte)(0xc0 | (0x1f & (c >> 6)))
(byte)(0x80 | (0x3f & c))
If a character
c
is in the range \u0800
through uffff
, then it is
represented by three bytes, to be written
in the order shown:
(byte)(0xe0 | (0x0f & (c >> 12)))
(byte)(0x80 | (0x3f & (c >> 6)))
(byte)(0x80 | (0x3f & c))
First,
the total number of bytes needed to represent
all the characters of s
is
calculated. If this number is larger than
65535
, then a UTFDataFormatException
is thrown. Otherwise, this length is written
to the output stream in exactly the manner
of the writeShort
method;
after this, the one-, two-, or three-byte
representation of each character in the
string s
is written.
The
bytes written by this method may be read
by the readUTF
method of interface
DataInput
, which will then
return a String
equal to s
.
writeUTF
in interface java.io.DataOutput
s
- the string value to be written.java.io.IOException
- if an I/O error occurs.public void flush() throws java.io.IOException
java.io.IOException
- if dirty buffers can't be written to diskgetNumFlushes()
public java.io.RandomAccessFile getRandomAccessFile()
OSAdapter.releaseOldPages(RandomAccessFile, long, long)