ds.funnel.data.channel

Class ChannelManagerImpl

java.lang.Object

ds.funnel.data.channel.ChannelManagerImpl

All Implemented Interfaces:

ChannelManager

public class ChannelManagerImpl
extends java.lang.Object
implements ChannelManager

Constructor Summary

Constructors

Constructor and Description
ChannelManagerImpl(ChannelAddress inAddr, java.nio.channels.ByteChannel inChannel, ChannelProtocol inProtocol)

Method Summary

Modifier and Type	Method and Description
void	finishClose(java.lang.Object inTaskFinished) Called by tasks to indicate that they have finished reading and writing.
void	finishConnect(ChannelAddress inAddr, ChannelProtocol inProtocol) Finish the connection process by updating the address and protocol.
ChannelAddress	getAddress()
java.nio.channels.ByteChannel	getChannel()
ChannelProtocol	getProtocol()
boolean	isReadable()
boolean	isWritable()
void	kill() Kill the channel to test recovery features.
void	requestClose() Stop reader and writer tasks and close the channel.
java.lang.String	toString()
void	wakeup() Wake up reader and writer tasks.

Methods inherited from class java.lang.Object

equals, getClass, hashCode, notify, notifyAll, wait, wait, wait

Constructor Detail

ChannelManagerImpl

public ChannelManagerImpl(ChannelAddress inAddr,
                          java.nio.channels.ByteChannel inChannel,
                          ChannelProtocol inProtocol)

Method Detail

isReadable

public boolean isReadable()

Specified by:

isReadable in interface ChannelManager

Returns:

True if the channel is readable.

isWritable

public boolean isWritable()

Specified by:

isWritable in interface ChannelManager

Returns:

True if the channel is writable.

getAddress

public ChannelAddress getAddress()

Specified by:

getAddress in interface ChannelManager

Returns:

The address that the channel is connected to.

getChannel

public java.nio.channels.ByteChannel getChannel()

Specified by:

getChannel in interface ChannelManager

Returns:

The byte channel managed by this class.

getProtocol

public ChannelProtocol getProtocol()

Specified by:

getProtocol in interface ChannelManager

Returns:

The protocol used to read and write data to this channel.

finishConnect

public void finishConnect(ChannelAddress inAddr,
                          ChannelProtocol inProtocol)
                   throws ConnectException

Description copied from interface: ChannelManager

Finish the connection process by updating the address and protocol.

Specified by:

finishConnect in interface ChannelManager

Parameters:

inAddr - - The remote address.

inProtocol - - The protocol for this address.

Throws:

ConnectException

wakeup

public void wakeup()
            throws ConnectException

Description copied from interface: ChannelManager

Wake up reader and writer tasks.

Specified by:

wakeup in interface ChannelManager

Throws:

ConnectException

requestClose

public void requestClose()

Description copied from interface: ChannelManager

Stop reader and writer tasks and close the channel.

Specified by:

requestClose in interface ChannelManager

finishClose

public void finishClose(java.lang.Object inTaskFinished)

Description copied from interface: ChannelManager

Called by tasks to indicate that they have finished reading and writing.

Specified by:

finishClose in interface ChannelManager

Parameters:

inTaskFinished - - The task that has finished and is closed.

kill

public void kill()

Kill the channel to test recovery features.

toString

public java.lang.String toString()

Overrides:

toString in class java.lang.Object