Package org.jcsp.util.filter

Class FilteredSharedChannelInputWrapper

java.lang.Object

org.jcsp.lang.ChannelInputWrapper

org.jcsp.util.filter.FilteredChannelInputWrapper

org.jcsp.util.filter.FilteredSharedChannelInputWrapper

All Implemented Interfaces:

ChannelInput, Poisonable, SharedChannelInput, FilteredChannelInput, FilteredSharedChannelInput, ReadFiltered

public class FilteredSharedChannelInputWrapper
extends FilteredChannelInputWrapper
implements FilteredSharedChannelInput

This is wrapper for a SharedChannelInput that adds read filtering. Instances of this class can be safely used by multiple concurrent processes.

Field Summary

Fields

Modifier and Type	Field	Description
private java.lang.Object	synchObject	The object used for synchronization by the methods here to protect the readers from each other when manipulating the filters and reading data.

Constructor Summary

Constructors

Constructor	Description
FilteredSharedChannelInputWrapper(SharedChannelInput in)	Constructs a new wrapper for the given channel input end.

Method Summary

Modifier and Type	Method	Description
void	addReadFilter(Filter filter)	Installs a read filter defining a transformation to be applied by the read method of the channel end.
void	addReadFilter(Filter filter, int index)	Installs a read filter defining a transformation to be applied by the read method of the channel end at a specific index.
Filter	getReadFilter(int index)	Returns the read filter installed at the given index.
int	getReadFilterCount()	Returns the number of read filters currently installed.
java.lang.Object	read()	Reads a value from the channel.
void	removeReadFilter(int index)	Removes the read filter installed at the given index.
void	removeReadFilter(Filter filter)	Removes the first read filter (lowest index) matching the filter given as a parameter.

Methods inherited from class org.jcsp.lang.ChannelInputWrapper

endRead, poison, startRead

Methods inherited from class java.lang.Object

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

Methods inherited from interface org.jcsp.lang.ChannelInput

endRead, startRead

Methods inherited from interface org.jcsp.lang.Poisonable

poison

Field Detail

synchObject

private java.lang.Object synchObject

The object used for synchronization by the methods here to protect the readers from each other when manipulating the filters and reading data.

Constructor Detail

FilteredSharedChannelInputWrapper

public FilteredSharedChannelInputWrapper(SharedChannelInput in)

Constructs a new wrapper for the given channel input end.

Parameters:

in - the existing channel end.

Method Detail

read

public java.lang.Object read()

Description copied from class: ChannelInputWrapper

Reads a value from the channel.

Specified by:

read in interface ChannelInput

Overrides:

read in class FilteredChannelInputWrapper

Returns:

the value read.

See Also:

ChannelInput

addReadFilter

public void addReadFilter(Filter filter)

Description copied from interface: ReadFiltered

Installs a read filter defining a transformation to be applied by the read method of the channel end. The filter will be appended to the end of the current list, making it the last to be applied.

Specified by:

addReadFilter in interface ReadFiltered

Overrides:

addReadFilter in class FilteredChannelInputWrapper

Parameters:

filter - the filter to be installed; may not be null.

addReadFilter

public void addReadFilter(Filter filter,
                          int index)

Description copied from interface: ReadFiltered

Installs a read filter defining a transformation to be applied by the read method of the channel end at a specific index. If there is already a filter at that index position the existing filters are shifted to make room. If the index is greater than the number of filters already installed the filter is placed at the end.

Specified by:

addReadFilter in interface ReadFiltered

Overrides:

addReadFilter in class FilteredChannelInputWrapper

Parameters:

filter - the filter to be installed; may not be null.

index - the zero based index; may not be negative.

removeReadFilter

public void removeReadFilter(Filter filter)

Description copied from interface: ReadFiltered

Removes the first read filter (lowest index) matching the filter given as a parameter. The filter removed, r, will satisfy the condition r.equals (filter). The remaining filters are shifted to close the gap in the index allocation.

Specified by:

removeReadFilter in interface ReadFiltered

Overrides:

removeReadFilter in class FilteredChannelInputWrapper

Parameters:

filter - the filter to be removed; may not be null.

removeReadFilter

public void removeReadFilter(int index)

Description copied from interface: ReadFiltered

Removes the read filter installed at the given index. The remaining filters are shifted to close the gap in the index allocation.

Specified by:

removeReadFilter in interface ReadFiltered

Overrides:

removeReadFilter in class FilteredChannelInputWrapper

Parameters:

index - zero-based index of the filter to be removed.

getReadFilter

public Filter getReadFilter(int index)

Description copied from interface: ReadFiltered

Returns the read filter installed at the given index.

Specified by:

getReadFilter in interface ReadFiltered

Overrides:

getReadFilter in class FilteredChannelInputWrapper

Parameters:

index - zero-based index of the filter to return.

Returns:

the filter at that position.

getReadFilterCount

public int getReadFilterCount()

Description copied from interface: ReadFiltered

Returns the number of read filters currently installed.

Specified by:

getReadFilterCount in interface ReadFiltered

Overrides:

getReadFilterCount in class FilteredChannelInputWrapper