| Package | Description |
|---|---|
| ds.funnel.data.channel | |
| ds.funnel.data.channel.tcp | |
| ds.funnel.data.channel.udp | |
| ds.funnel.data.msglink.protocol3 |
| Modifier and Type | Class and Description |
|---|---|
class |
ChannelManagerImpl |
| Modifier and Type | Method and Description |
|---|---|
abstract ChannelManager |
ChannelAddress.connect(java.nio.channels.ByteChannel inChannel,
ChannelProtocol inProtocol)
Completes a connection made to the node.
|
abstract ChannelManager |
ChannelAddress.connect(ChannelProtocol inProtocol)
Opens a new connection to the node.
|
ChannelManager |
ChannelEvent.getManager()
Get the channel manager associated with this event.
|
| Modifier and Type | Method and Description |
|---|---|
void |
ChannelProtocol.onClose(ChannelManager inManager)
Indicate that the channel used by this protocol has closed.
|
boolean |
ChannelProtocol.onRecvBuffer(ChannelManager inManager,
java.nio.ByteBuffer inBuffer)
Called by a channel reader task to pass received bytes to the protocol.
|
boolean |
ChannelProtocol.onSendBuffer(ChannelManager inManager,
java.nio.ByteBuffer inBuffer)
Called by a channel writer task to obtain bytes to send from the protocol.
|
| Constructor and Description |
|---|
ChannelAcceptEvent(ChannelManager inManager)
Construct this event.
|
ChannelClosedEvent(ChannelManager inManager)
Construct this event.
|
ChannelEvent(ChannelManager inManager)
Construct this event.
|
ChannelReader(java.nio.channels.ReadableByteChannel inChannel,
ChannelManager inManager)
Creates a reader task for this channel.
|
ChannelWriter(java.nio.channels.WritableByteChannel inChannel,
ChannelManager inManager)
Creates a writer task for this channel.
|
| Modifier and Type | Method and Description |
|---|---|
ChannelManager |
TCPChannelAddr.connect(java.nio.channels.ByteChannel inChannel,
ChannelProtocol inProtocol) |
ChannelManager |
TCPChannelAddr.connect(ChannelProtocol inProtocol) |
| Constructor and Description |
|---|
TCPAcceptEvent(ChannelManager inManager)
Construct this event.
|
| Modifier and Type | Method and Description |
|---|---|
ChannelManager |
UDPChannelAddr.connect(java.nio.channels.ByteChannel inChannel,
ChannelProtocol inProtocol) |
ChannelManager |
UDPChannelAddr.connect(ChannelProtocol inProtocol) |
| Constructor and Description |
|---|
UDPAcceptEvent(ChannelManager inManager)
Construct this event.
|
| Modifier and Type | Method and Description |
|---|---|
void |
MessageProtocol.onClose(ChannelManager inManager) |
boolean |
MessageProtocol.onRecvBuffer(ChannelManager inManager,
java.nio.ByteBuffer inBuffer) |
boolean |
MessageProtocol.onSendBuffer(ChannelManager inManager,
java.nio.ByteBuffer inBuffer) |