edu.iu.dsc.tws.api.comms.messaging

Class ChannelMessage

java.lang.Object

edu.iu.dsc.tws.api.comms.messaging.ChannelMessage

public class ChannelMessage
extends java.lang.Object

Field Summary

Fields

Modifier and Type	Field and Description
protected boolean	complete Keep whether we have all the buffers added
protected MessageHeader	header The message header

Constructor Summary

Constructors

Constructor and Description
ChannelMessage()
ChannelMessage(int originatingId, MessageType messageType, MessageDirection messageDirection, ChannelMessageReleaseCallback releaseListener)

Method Summary

Modifier and Type	Method and Description
void	addBuffer(DataBuffer buffer)
void	addBuffers(java.util.List<DataBuffer> bufferList)
void	addOverFlowBuffers(java.util.List<DataBuffer> bufferList)
void	addToOverFlowBuffer(DataBuffer data)
boolean	doneProcessing()
int	getAcceptedExternalSends()
java.util.List<DataBuffer>	getBuffers()
MessageType	getDataType()
MessageHeader	getHeader()
int	getHeaderSize()
MessageType	getKeyType()
MessageDirection	getMessageDirection()
java.util.List<DataBuffer>	getNormalBuffers() returns the direct buffers that were allocated.
int	getOriginatingId()
java.util.List<DataBuffer>	getOverflowBuffers()
ChannelMessageReleaseCallback	getReleaseListener()
int	incrementAcceptedExternalSends()
void	incrementRefCount()
void	incrementRefCount(int count)
boolean	isComplete()
boolean	isHeaderSent()
boolean	isOutCountUpdated()
boolean	isPartial()
void	release() Release the allocated resources to this buffer.
protected void	removeAllBuffers()
void	setComplete(boolean complete)
void	setDataType(MessageType dataType)
void	setHeader(MessageHeader header)
void	setHeaderSent(boolean headerSent)
void	setHeaderSize(int headerSize)
void	setKeyType(MessageType keyType)
void	setMessageDirection(MessageDirection messageDirection)
void	setOriginatingId(int originatingId)
void	setOutCountUpdated(boolean outCountUpdated)
void	setPartial(boolean partial)
void	setReleaseListener(ChannelMessageReleaseCallback releaseListener)

Methods inherited from class java.lang.Object

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

Field Detail

header

protected MessageHeader header

The message header

complete

protected boolean complete

Keep whether we have all the buffers added

Constructor Detail

ChannelMessage

public ChannelMessage()

ChannelMessage

public ChannelMessage(int originatingId,
                      MessageType messageType,
                      MessageDirection messageDirection,
                      ChannelMessageReleaseCallback releaseListener)

Method Detail

getBuffers

public java.util.List<DataBuffer> getBuffers()

getNormalBuffers

public java.util.List<DataBuffer> getNormalBuffers()

returns the direct buffers that were allocated.

incrementRefCount

public void incrementRefCount()

incrementRefCount

public void incrementRefCount(int count)

getMessageDirection

public MessageDirection getMessageDirection()

doneProcessing

public boolean doneProcessing()

release

public void release()

Release the allocated resources to this buffer.

addBuffer

public void addBuffer(DataBuffer buffer)

addBuffers

public void addBuffers(java.util.List<DataBuffer> bufferList)

addOverFlowBuffers

public void addOverFlowBuffers(java.util.List<DataBuffer> bufferList)

removeAllBuffers

protected void removeAllBuffers()

addToOverFlowBuffer

public void addToOverFlowBuffer(DataBuffer data)

getOverflowBuffers

public java.util.List<DataBuffer> getOverflowBuffers()

getOriginatingId

public int getOriginatingId()

getHeader

public MessageHeader getHeader()

setHeader

public void setHeader(MessageHeader header)

setOriginatingId

public void setOriginatingId(int originatingId)

setMessageDirection

public void setMessageDirection(MessageDirection messageDirection)

getReleaseListener

public ChannelMessageReleaseCallback getReleaseListener()

setReleaseListener

public void setReleaseListener(ChannelMessageReleaseCallback releaseListener)

setDataType

public void setDataType(MessageType dataType)

isComplete

public boolean isComplete()

setComplete

public void setComplete(boolean complete)

getDataType

public MessageType getDataType()

setHeaderSize

public void setHeaderSize(int headerSize)

getHeaderSize

public int getHeaderSize()

setKeyType

public void setKeyType(MessageType keyType)

getKeyType

public MessageType getKeyType()

isHeaderSent

public boolean isHeaderSent()

setHeaderSent

public void setHeaderSent(boolean headerSent)

isPartial

public boolean isPartial()

setPartial

public void setPartial(boolean partial)

getAcceptedExternalSends

public int getAcceptedExternalSends()

incrementAcceptedExternalSends

public int incrementAcceptedExternalSends()

setOutCountUpdated

public void setOutCountUpdated(boolean outCountUpdated)

isOutCountUpdated

public boolean isOutCountUpdated()