ds.funnel.data.channel

Class ChannelWriter

java.lang.Object

ds.funnel.node.task.Task<T>

ds.funnel.node.task.ScheduledTask<T>

ds.funnel.node.task.SelectableTask<java.lang.Void>

ds.funnel.data.channel.ChannelWriter

All Implemented Interfaces:

java.lang.Runnable

public class ChannelWriter
extends SelectableTask<java.lang.Void>

ChannelWriter.java: Writes bytes to a channel. This is non-blocking.

Author:

Ryan Stern

Field Summary

Fields

Modifier and Type	Field and Description
static java.util.concurrent.LinkedBlockingQueue<java.lang.Integer>	logWriter
static int	SEND_BUFFER_SIZE

Fields inherited from class ds.funnel.node.task.Task

AUTOSTART, IGNORENULL, RUNONCE

Constructor Summary

Constructors

Constructor and Description
ChannelWriter(java.nio.channels.WritableByteChannel inChannel, ChannelManager inManager) Creates a writer task for this channel.

Method Summary

Methods inherited from class ds.funnel.node.task.SelectableTask

cancel, startTaskSelect, startTaskSelectOnce

Methods inherited from class ds.funnel.node.task.ScheduledTask

startTaskAsync, startTaskLater, startTaskTimer

Methods inherited from class ds.funnel.node.task.Task

chainTask, getResult, getResult, getResultNow, isCancelled, run, startTask

Methods inherited from class java.lang.Object

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

Field Detail

SEND_BUFFER_SIZE

public static final int SEND_BUFFER_SIZE

See Also:

Constant Field Values

logWriter

public static java.util.concurrent.LinkedBlockingQueue<java.lang.Integer> logWriter

Constructor Detail

ChannelWriter

public ChannelWriter(java.nio.channels.WritableByteChannel inChannel,
                     ChannelManager inManager)

Creates a writer task for this channel.

Parameters:

inChannel - - The channel to write to.

inFormat - - The format of data being written.