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.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

Enclosing class:

TestFSErrorsExposed

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

Field Summary

Fields

Modifier and Type	Field and Description
(package private) boolean	faultsStarted

Fields inherited from class java.io.FilterInputStream

in

Constructor Summary

Constructors

Constructor and Description
FaultyInputStream(InputStream in)

Method Summary

Modifier and Type	Method and 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, read, read, read, readFully, readFully, releaseBuffer, seek, seekToNewSource, setDropBehind, setReadahead, 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, toString, wait, wait, wait

Field Detail

faultsStarted

boolean faultsStarted

Constructor Detail

FaultyInputStream

public FaultyInputStream(InputStream in)
                  throws IOException

Throws:

IOException

Method Detail

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