edu.iu.dsc.tws.comms.dfw

Class OutMessage

java.lang.Object

edu.iu.dsc.tws.comms.dfw.OutMessage

public class OutMessage
extends java.lang.Object

Keep track of a message while it is transitioning through the send phases

Nested Class Summary

Nested Classes

Modifier and Type	Class and Description
static class	OutMessage.SendState

Constructor Summary

Constructors

Constructor and Description
OutMessage(int src, int edge, int path, int target, int flags, java.util.List<java.lang.Integer> intSends, java.util.List<java.lang.Integer> extSends, MessageType dataType, MessageType keyType, ChannelMessageReleaseCallback releaseCallback, java.lang.Object data)

Method Summary

Modifier and Type	Method and Description
int	getAcceptedInternalSends()
java.util.Queue<ChannelMessage>	getChannelMessages()
java.lang.Object	getData()
MessageType	getDataType()
int	getEdge()
java.util.List<java.lang.Integer>	getExternalSends()
int	getFlags()
MessageHeader	getHeader()
java.util.List<java.lang.Integer>	getInternalSends()
MessageType	getKeyType()
int	getPath()
ChannelMessageReleaseCallback	getReleaseCallback()
OutMessage.SendState	getSendState()
SerializeState	getSerializationState()
int	getSource()
int	getTarget()
void	incrementAcceptedInternalSends()
boolean	isComplete()
void	setComplete(boolean complete)
void	setHeader(MessageHeader header)
void	setSendState(OutMessage.SendState sendState)
void	setSerializationState(SerializeState serializationState)

Methods inherited from class java.lang.Object

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

Constructor Detail

OutMessage

public OutMessage(int src,
                  int edge,
                  int path,
                  int target,
                  int flags,
                  java.util.List<java.lang.Integer> intSends,
                  java.util.List<java.lang.Integer> extSends,
                  MessageType dataType,
                  MessageType keyType,
                  ChannelMessageReleaseCallback releaseCallback,
                  java.lang.Object data)

Method Detail

getData

public java.lang.Object getData()

getSendState

public OutMessage.SendState getSendState()

setSendState

public void setSendState(OutMessage.SendState sendState)

setSerializationState

public void setSerializationState(SerializeState serializationState)

getSerializationState

public SerializeState getSerializationState()

isComplete

public boolean isComplete()

setComplete

public void setComplete(boolean complete)

getSource

public int getSource()

getEdge

public int getEdge()

getPath

public int getPath()

getTarget

public int getTarget()

getInternalSends

public java.util.List<java.lang.Integer> getInternalSends()

getExternalSends

public java.util.List<java.lang.Integer> getExternalSends()

getAcceptedInternalSends

public int getAcceptedInternalSends()

incrementAcceptedInternalSends

public void incrementAcceptedInternalSends()

getFlags

public int getFlags()

getChannelMessages

public java.util.Queue<ChannelMessage> getChannelMessages()

getDataType

public MessageType getDataType()

getKeyType

public MessageType getKeyType()

getReleaseCallback

public ChannelMessageReleaseCallback getReleaseCallback()

getHeader

public MessageHeader getHeader()

setHeader

public void setHeader(MessageHeader header)