org.apache.hadoop.hbase.regionserver

Class TestHStore.FaultyOutputStream

java.lang.Object

java.io.OutputStream

java.io.FilterOutputStream

java.io.DataOutputStream

org.apache.hadoop.fs.FSDataOutputStream

org.apache.hadoop.hbase.regionserver.TestHStore.FaultyOutputStream

All Implemented Interfaces:

Closeable, DataOutput, Flushable, AutoCloseable, org.apache.hadoop.fs.CanSetDropBehind, org.apache.hadoop.fs.StreamCapabilities, org.apache.hadoop.fs.Syncable

Enclosing class:

TestHStore

static class TestHStore.FaultyOutputStream
extends org.apache.hadoop.fs.FSDataOutputStream

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 and Description
private AtomicBoolean	fault
(package private) long	faultPos

Fields inherited from class java.io.DataOutputStream

written

Fields inherited from class java.io.FilterOutputStream

out

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

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

Constructor Summary

Constructors

Constructor and Description
FaultyOutputStream(org.apache.hadoop.fs.FSDataOutputStream out, long faultPos, AtomicBoolean fault)

Method Summary

Modifier and Type	Method and Description
private void	injectFault()
void	write(byte[] buf, int offset, int length)

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

close, getPos, getWrappedStream, hasCapability, hflush, hsync, setDropBehind, sync

Methods inherited from class java.io.DataOutputStream

flush, size, write, writeBoolean, writeByte, writeBytes, writeChar, writeChars, writeDouble, writeFloat, writeInt, writeLong, writeShort, writeUTF

Methods inherited from class java.io.FilterOutputStream

write

Methods inherited from class java.lang.Object

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

Methods inherited from interface java.io.DataOutput

write

Field Detail

faultPos

volatile long faultPos

fault

private final AtomicBoolean fault

Constructor Detail

FaultyOutputStream

public FaultyOutputStream(org.apache.hadoop.fs.FSDataOutputStream out,
                          long faultPos,
                          AtomicBoolean fault)
                   throws IOException

Throws:

IOException

Method Detail

write

public void write(byte[] buf,
                  int offset,
                  int length)
           throws IOException

Specified by:

write in interface DataOutput

Overrides:

write in class DataOutputStream

Throws:

IOException

injectFault

private void injectFault()
                  throws IOException

Throws:

IOException