org.apache.mina.filter.errorgenerating

Class ErrorGeneratingFilter

java.lang.Object

org.apache.mina.core.filterchain.IoFilterAdapter

org.apache.mina.filter.errorgenerating.ErrorGeneratingFilter

All Implemented Interfaces:

IoFilter

public class ErrorGeneratingFilter
extends IoFilterAdapter

An IoFilter implementation generating random bytes and PDU modification in your communication streams. It's quite simple to use : ErrorGeneratingFilter egf = new ErrorGeneratingFilter(); For activate the change of some bytes in your IoBuffer, for a probability of 200 out of 1000 IoBuffer processed : egf.setChangeByteProbability(200); For activate the insertion of some bytes in your IoBuffer, for a probability of 200 out of 1000 : egf.setInsertByteProbability(200); And for the removing of some bytes : egf.setRemoveByteProbability(200); You can activate the error generation for write or read with the following methods : egf.setManipulateReads(true); egf.setManipulateWrites(true);

Nested Class Summary

Nested classes/interfaces inherited from interface org.apache.mina.core.filterchain.IoFilter

IoFilter.NextFilter

Field Summary

Fields

Modifier and Type	Field and Description
private int	changeByteProbability
private int	duplicatePduProbability
private int	insertByteProbability
private org.slf4j.Logger	logger
private boolean	manipulateReads
private boolean	manipulateWrites
private int	maxInsertByte
private int	removeByteProbability
private int	removePduProbability
private int	resendPduLasterProbability
private java.util.Random	rng

Constructor Summary

Constructors

Constructor and Description
ErrorGeneratingFilter()

Method Summary

Modifier and Type	Method and Description
void	filterWrite(IoFilter.NextFilter nextFilter, IoSession session, WriteRequest writeRequest) Filters IoSession.write(Object) method invocation.
int	getChangeByteProbability()
int	getDuplicatePduProbability()
int	getInsertByteProbability()
int	getMaxInsertByte()
int	getRemoveByteProbability()
int	getRemovePduProbability()
int	getResendPduLasterProbability()
private IoBuffer	insertBytesToNewIoBuffer(IoSession session, IoBuffer buffer)
boolean	isManipulateReads()
boolean	isManipulateWrites()
private void	manipulateIoBuffer(IoSession session, IoBuffer buffer)
void	messageReceived(IoFilter.NextFilter nextFilter, IoSession session, java.lang.Object message) Filters IoHandler.messageReceived(IoSession,Object) event.
void	setChangeByteProbability(int changeByteProbability) Set the probability for the change byte error.
void	setDuplicatePduProbability(int duplicatePduProbability) not functional ATM
void	setInsertByteProbability(int insertByteProbability) Set the probability for the insert byte error.
void	setManipulateReads(boolean manipulateReads) Set to true if you want to apply error to the read IoBuffer
void	setManipulateWrites(boolean manipulateWrites) Set to true if you want to apply error to the written IoBuffer
void	setMaxInsertByte(int maxInsertByte) Set the maximum number of byte the filter can insert in a IoBuffer.
void	setRemoveByteProbability(int removeByteProbability) Set the probability for the remove byte error.
void	setRemovePduProbability(int removePduProbability) not functional ATM
void	setResendPduLasterProbability(int resendPduLasterProbability) not functional ATM

Methods inherited from class org.apache.mina.core.filterchain.IoFilterAdapter

destroy, exceptionCaught, filterClose, init, inputClosed, messageSent, onPostAdd, onPostRemove, onPreAdd, onPreRemove, sessionClosed, sessionCreated, sessionIdle, sessionOpened, toString

Methods inherited from class java.lang.Object

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

Field Detail

removeByteProbability

private int removeByteProbability

insertByteProbability

private int insertByteProbability

changeByteProbability

private int changeByteProbability

removePduProbability

private int removePduProbability

duplicatePduProbability

private int duplicatePduProbability

resendPduLasterProbability

private int resendPduLasterProbability

maxInsertByte

private int maxInsertByte

manipulateWrites

private boolean manipulateWrites

manipulateReads

private boolean manipulateReads

rng

private java.util.Random rng

logger

private final org.slf4j.Logger logger

Constructor Detail

ErrorGeneratingFilter

public ErrorGeneratingFilter()

Method Detail

filterWrite

public void filterWrite(IoFilter.NextFilter nextFilter,
                        IoSession session,
                        WriteRequest writeRequest)
                 throws java.lang.Exception

Description copied from class: IoFilterAdapter

Filters IoSession.write(Object) method invocation.

Specified by:

filterWrite in interface IoFilter

Overrides:

filterWrite in class IoFilterAdapter

Parameters:

nextFilter - the IoFilter.NextFilter for this filter. You can reuse this object until this filter is removed from the chain.

session - The IoSession which has to process this invocation

writeRequest - The WriteRequest to process

Throws:

java.lang.Exception

messageReceived

public void messageReceived(IoFilter.NextFilter nextFilter,
                            IoSession session,
                            java.lang.Object message)
                     throws java.lang.Exception

Description copied from class: IoFilterAdapter

Filters IoHandler.messageReceived(IoSession,Object) event.

Specified by:

messageReceived in interface IoFilter

Overrides:

messageReceived in class IoFilterAdapter

Parameters:

nextFilter - the IoFilter.NextFilter for this filter. You can reuse this object until this filter is removed from the chain.

session - The IoSession which has received this event

message - The received message

Throws:

java.lang.Exception

insertBytesToNewIoBuffer

private IoBuffer insertBytesToNewIoBuffer(IoSession session,
                                          IoBuffer buffer)

manipulateIoBuffer

private void manipulateIoBuffer(IoSession session,
                                IoBuffer buffer)

getChangeByteProbability

public int getChangeByteProbability()

setChangeByteProbability

public void setChangeByteProbability(int changeByteProbability)

Set the probability for the change byte error. If this probability is > 0 the filter will modify a random number of byte of the processed IoBuffer.

Parameters:

changeByteProbability - probability of modifying an IoBuffer out of 1000 processed IoBuffer

getDuplicatePduProbability

public int getDuplicatePduProbability()

setDuplicatePduProbability

public void setDuplicatePduProbability(int duplicatePduProbability)

not functional ATM

Parameters:

duplicatePduProbability -

getInsertByteProbability

public int getInsertByteProbability()

setInsertByteProbability

public void setInsertByteProbability(int insertByteProbability)

Set the probability for the insert byte error. If this probability is > 0 the filter will insert a random number of byte in the processed IoBuffer.

Parameters:

insertByteProbability - probability of inserting in IoBuffer out of 1000 processed IoBuffer

isManipulateReads

public boolean isManipulateReads()

setManipulateReads

public void setManipulateReads(boolean manipulateReads)

Set to true if you want to apply error to the read IoBuffer

Parameters:

manipulateReads -

isManipulateWrites

public boolean isManipulateWrites()

setManipulateWrites

public void setManipulateWrites(boolean manipulateWrites)

Set to true if you want to apply error to the written IoBuffer

Parameters:

manipulateWrites -

getRemoveByteProbability

public int getRemoveByteProbability()

setRemoveByteProbability

public void setRemoveByteProbability(int removeByteProbability)

Set the probability for the remove byte error. If this probability is > 0 the filter will remove a random number of byte in the processed IoBuffer.

Parameters:

removeByteProbability - probability of modifying an IoBuffer out of 1000 processed IoBuffer

getRemovePduProbability

public int getRemovePduProbability()

setRemovePduProbability

public void setRemovePduProbability(int removePduProbability)

not functional ATM

Parameters:

removePduProbability -

getResendPduLasterProbability

public int getResendPduLasterProbability()

setResendPduLasterProbability

public void setResendPduLasterProbability(int resendPduLasterProbability)

not functional ATM

Parameters:

resendPduLasterProbability -

getMaxInsertByte

public int getMaxInsertByte()

setMaxInsertByte

public void setMaxInsertByte(int maxInsertByte)

Set the maximum number of byte the filter can insert in a IoBuffer. The default value is 10.

Parameters:

maxInsertByte - maximum bytes inserted in a IoBuffer