ds.funnel.data.channel

Interface ChannelManager

All Known Implementing Classes:

ChannelManagerImpl

public interface ChannelManager

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 inAddress, 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	requestClose() Stop reader and writer tasks and close the channel.
void	wakeup() Wake up reader and writer tasks.

Method Detail

isReadable

boolean isReadable()

Returns:

True if the channel is readable.

isWritable

boolean isWritable()

Returns:

True if the channel is writable.

getAddress

ChannelAddress getAddress()

Returns:

The address that the channel is connected to.

getChannel

java.nio.channels.ByteChannel getChannel()

Returns:

The byte channel managed by this class.

getProtocol

ChannelProtocol getProtocol()

Returns:

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

finishConnect

void finishConnect(ChannelAddress inAddress,
                   ChannelProtocol inProtocol)
            throws ConnectException

Finish the connection process by updating the address and protocol.

Parameters:

inAddress - - The remote address.

inProtocol - - The protocol for this address.

Throws:

java.io.IOException

ConnectException

wakeup

void wakeup()
     throws ConnectException

Wake up reader and writer tasks.

Throws:

java.io.IOException

ConnectException

requestClose

void requestClose()

Stop reader and writer tasks and close the channel.

finishClose

void finishClose(java.lang.Object inTaskFinished)

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

Parameters:

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