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

Class BaseNetworkChannel

java.lang.Object

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

Direct Known Subclasses:

DynamicBufferChannel, FixedBufferChannel

public abstract class BaseNetworkChannel
extends java.lang.Object

Base network channel

Field Summary

Fields

Modifier and Type	Field and Description
protected ChannelHandler	channelHandler
protected Progress	looper
protected java.util.Map<java.lang.Integer,java.util.concurrent.BlockingQueue<TCPMessage>>	pendingReceives
protected java.util.concurrent.BlockingQueue<TCPMessage>	pendingSends
protected int	readEdge
protected java.nio.ByteBuffer	readHeader
protected TCPMessage	readingRequest
protected int	readMessageSize
protected DataStatus	readStatus
protected SelectHandler	selectHandler
protected java.nio.channels.SocketChannel	socketChannel
protected java.nio.ByteBuffer	writeHeader
protected DataStatus	writeStatus

Method Summary

Modifier and Type	Method and Description
boolean	addReadRequest(TCPMessage request)
boolean	addWriteRequest(TCPMessage request)
void	clear()
void	disableReading()
void	disableWriting()
void	enableReading()
void	enableWriting()
void	forceFlush()
boolean	isPending()
void	read()
abstract TCPMessage	readRequest(java.nio.channels.SocketChannel channel)
void	write()

Methods inherited from class java.lang.Object

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

Field Detail

pendingSends

protected java.util.concurrent.BlockingQueue<TCPMessage> pendingSends

pendingReceives

protected java.util.Map<java.lang.Integer,java.util.concurrent.BlockingQueue<TCPMessage>> pendingReceives

socketChannel

protected final java.nio.channels.SocketChannel socketChannel

looper

protected Progress looper

selectHandler

protected SelectHandler selectHandler

readHeader

protected java.nio.ByteBuffer readHeader

writeHeader

protected java.nio.ByteBuffer writeHeader

readingRequest

protected TCPMessage readingRequest

readEdge

protected int readEdge

readMessageSize

protected int readMessageSize

readStatus

protected DataStatus readStatus

writeStatus

protected DataStatus writeStatus

channelHandler

protected ChannelHandler channelHandler

Method Detail

read

public void read()

readRequest

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

clear

public void clear()

addReadRequest

public boolean addReadRequest(TCPMessage request)

addWriteRequest

public boolean addWriteRequest(TCPMessage request)

write

public void write()

forceFlush

public void forceFlush()

isPending

public boolean isPending()

enableReading

public void enableReading()

disableReading

public void disableReading()

enableWriting

public void enableWriting()

disableWriting

public void disableWriting()