edu.iu.dsc.tws.common.net.tcp

Class DynamicBufferChannel

java.lang.Object

edu.iu.dsc.tws.common.net.tcp.BaseNetworkChannel

edu.iu.dsc.tws.common.net.tcp.DynamicBufferChannel

public class DynamicBufferChannel
extends BaseNetworkChannel

Field Summary

Fields inherited from class edu.iu.dsc.tws.common.net.tcp.BaseNetworkChannel

channelHandler, looper, pendingReceives, pendingSends, readEdge, readHeader, readingRequest, readMessageSize, readStatus, selectHandler, socketChannel, writeHeader, writeStatus

Constructor Summary

Constructors

Constructor and Description
DynamicBufferChannel(Config cfg, Progress progress, SelectHandler handler, java.nio.channels.SocketChannel channel, ChannelHandler msgHandler)

Method Summary

Modifier and Type	Method and Description
boolean	addReadRequest(TCPMessage request)
void	read()
TCPMessage	readRequest(java.nio.channels.SocketChannel channel) Read the request

Methods inherited from class edu.iu.dsc.tws.common.net.tcp.BaseNetworkChannel

addWriteRequest, clear, disableReading, disableWriting, enableReading, enableWriting, forceFlush, isPending, write

Methods inherited from class java.lang.Object

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

Constructor Detail

DynamicBufferChannel

public DynamicBufferChannel(Config cfg,
                            Progress progress,
                            SelectHandler handler,
                            java.nio.channels.SocketChannel channel,
                            ChannelHandler msgHandler)

Method Detail

read

public void read()

Overrides:

read in class BaseNetworkChannel

addReadRequest

public boolean addReadRequest(TCPMessage request)

Overrides:

addReadRequest in class BaseNetworkChannel

readRequest

public TCPMessage readRequest(java.nio.channels.SocketChannel channel)

Read the request

Specified by:

readRequest in class BaseNetworkChannel

Parameters:

channel -

Returns: