Package org.apache.hadoop.hbase.regionserver

Class TestFSErrorsExposed.FaultyInputStream

java.lang.Object

java.io.InputStream

java.io.FilterInputStream

java.io.DataInputStream

org.apache.hadoop.fs.FSDataInputStream

org.apache.hadoop.hbase.regionserver.TestFSErrorsExposed.FaultyInputStream

All Implemented Interfaces:

Closeable, DataInput, AutoCloseable, org.apache.hadoop.fs.ByteBufferPositionedReadable, org.apache.hadoop.fs.ByteBufferReadable, org.apache.hadoop.fs.CanSetDropBehind, org.apache.hadoop.fs.CanSetReadahead, org.apache.hadoop.fs.CanUnbuffer, org.apache.hadoop.fs.HasEnhancedByteBufferAccess, org.apache.hadoop.fs.HasFileDescriptor, org.apache.hadoop.fs.PositionedReadable, org.apache.hadoop.fs.Seekable, org.apache.hadoop.fs.StreamCapabilities

Enclosing class:

TestFSErrorsExposed

static class TestFSErrorsExposed.FaultyInputStream
extends org.apache.hadoop.fs.FSDataInputStream

Nested Class Summary

Nested classes/interfaces inherited from interface org.apache.hadoop.fs.StreamCapabilities

org.apache.hadoop.fs.StreamCapabilities.StreamCapability

Field Summary

Fields

Modifier and Type	Field	Description
(package private) boolean	faultsStarted

Fields inherited from class java.io.FilterInputStream

in

Fields inherited from interface org.apache.hadoop.fs.StreamCapabilities

DROPBEHIND, HFLUSH, HSYNC, PREADBYTEBUFFER, READAHEAD, READBYTEBUFFER, UNBUFFER

Constructor Summary

Constructors

Constructor	Description
FaultyInputStream(InputStream in)

Method Summary

Modifier and Type	Method	Description
private void	injectFault()
int	read(long position, byte[] buffer, int offset, int length)
void	startFaults()

Methods inherited from class org.apache.hadoop.fs.FSDataInputStream

getFileDescriptor, getPos, getWrappedStream, hasCapability, read, read, read, read, readFully, readFully, releaseBuffer, seek, seekToNewSource, setDropBehind, setReadahead, toString, unbuffer

Methods inherited from class java.io.DataInputStream

read, read, readBoolean, readByte, readChar, readDouble, readFloat, readFully, readFully, readInt, readLine, readLong, readShort, readUnsignedByte, readUnsignedShort, readUTF, readUTF, skipBytes

Methods inherited from class java.io.FilterInputStream

available, close, mark, markSupported, read, reset, skip

Methods inherited from class java.lang.Object

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

Field Details

faultsStarted

boolean faultsStarted

Constructor Details

FaultyInputStream

public FaultyInputStream(InputStream in)
                  throws IOException

Throws:

IOException

Method Details

startFaults

public void startFaults()

read

public int read(long position,
 byte[] buffer,
 int offset,
 int length)
         throws IOException

Specified by:

read in interface org.apache.hadoop.fs.PositionedReadable

Overrides:

read in class org.apache.hadoop.fs.FSDataInputStream

Throws:

IOException

injectFault

private void injectFault()
                  throws IOException

Throws:

IOException