static class TestFSErrorsExposed.FaultyInputStream extends org.apache.hadoop.fs.FSDataInputStream
| Modifier and Type | Field and Description |
|---|---|
(package private) boolean |
faultsStarted |
in| Constructor and Description |
|---|
FaultyInputStream(InputStream in) |
| Modifier and Type | Method and Description |
|---|---|
private void |
injectFault() |
int |
read(long position,
byte[] buffer,
int offset,
int length) |
void |
startFaults() |
getFileDescriptor, getPos, getWrappedStream, hasCapability, read, read, read, read, readFully, readFully, releaseBuffer, seek, seekToNewSource, setDropBehind, setReadahead, toString, unbufferread, read, readBoolean, readByte, readChar, readDouble, readFloat, readFully, readFully, readInt, readLine, readLong, readShort, readUnsignedByte, readUnsignedShort, readUTF, readUTF, skipBytesavailable, close, mark, markSupported, read, reset, skipboolean faultsStarted
public FaultyInputStream(InputStream in) throws IOException
IOExceptionpublic void startFaults()
public int read(long position, byte[] buffer, int offset, int length) throws IOException
read in interface org.apache.hadoop.fs.PositionedReadableread in class org.apache.hadoop.fs.FSDataInputStreamIOExceptionprivate void injectFault() throws IOException
IOExceptionCopyright © 2007–2020 The Apache Software Foundation. All rights reserved.