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

Class FixedBufferChannel

java.lang.Object

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

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

public class FixedBufferChannel
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
FixedBufferChannel(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

FixedBufferChannel

public FixedBufferChannel(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: