com.alipay.sofa.jraft.storage.io

Class LocalDirReader

java.lang.Object

com.alipay.sofa.jraft.storage.io.LocalDirReader

All Implemented Interfaces:

FileReader

Direct Known Subclasses:

SnapshotFileReader

public class LocalDirReader
extends Object
implements FileReader

Read a file data form local dir by fileName.

Author:

boyan (boyan@alibaba-inc.com) 2018-Apr-06 9:25:12 PM

Field Summary

Fields inherited from interface com.alipay.sofa.jraft.storage.io.FileReader

EOF

Constructor Summary

Constructors

Constructor and Description
LocalDirReader(String path)

Method Summary

Modifier and Type	Method and Description
String	getPath() Get the file path.
int	readFile(ByteBufferCollector buf, String fileName, long offset, long maxCount) Read file into buf starts from offset at most maxCount.
protected int	readFileWithMeta(ByteBufferCollector buf, String fileName, com.google.protobuf.Message fileMeta, long offset, long maxCount)

Methods inherited from class java.lang.Object

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

Constructor Detail

LocalDirReader

public LocalDirReader(String path)

Method Detail

getPath

public String getPath()

Description copied from interface: FileReader

Get the file path.

Specified by:

getPath in interface FileReader

Returns:

path of the file

readFile

public int readFile(ByteBufferCollector buf,
                    String fileName,
                    long offset,
                    long maxCount)
             throws IOException,
                    RetryAgainException

Description copied from interface: FileReader

Read file into buf starts from offset at most maxCount.

Specified by:

readFile in interface FileReader

Parameters:

buf - read bytes into this buf

fileName - file name

offset - the offset of file

maxCount - max read bytes

Returns:

-1 if reaches end, else return read count.

Throws:

IOException - if some I/O error occurs

RetryAgainException - if it's not allowed to read partly or it's allowed but throughput is throttled to 0, try again.

readFileWithMeta

protected int readFileWithMeta(ByteBufferCollector buf,
                               String fileName,
                               com.google.protobuf.Message fileMeta,
                               long offset,
                               long maxCount)
                        throws IOException,
                               RetryAgainException

Throws:

IOException

RetryAgainException