edu.iu.dsc.tws.comms.dfw

Class ControlledChannelOperation

java.lang.Object

edu.iu.dsc.tws.comms.dfw.ControlledChannelOperation

All Implemented Interfaces:

ChannelListener, ChannelMessageReleaseCallback

public class ControlledChannelOperation
extends java.lang.Object
implements ChannelListener, ChannelMessageReleaseCallback

Method Summary

Modifier and Type	Method and Description
void	close()
Config	getConfig()
LogicalPlan	getInstancePlan()
boolean	isComplete() Weather we have more data to complete, we only check the sends and
void	onReceiveComplete(int id, int e, DataBuffer buffer) After a receive is complete this function gets called
void	onSendComplete(int id, int messageStream, ChannelMessage message) After a send is complete this function gets called
void	progress() Progress the serializations and receives, this method must be called by threads to send messages through this communication
void	receiveDeserializeProgress(int receiveId) Progress deserialize
void	receiveProgress(int receiveId) Progress the receive
void	release(ChannelMessage message)
boolean	sendMessage(int source, java.lang.Object message, int target, int flags, RoutingParameters routingParameters) Sends a message from a originating location
void	sendProgress(int sendId) Go through the out messages, create channel messages by using the serializer send them
void	setKeyType(MessageType keyType)
void	setupReceiveGroups(java.util.List<IntArrayList> receivingIds) Start receiving from the next set of ids
void	startGroup(int receiveGroup, int sendGroup, java.util.Map<java.lang.Integer,java.lang.Integer> expectedReceives) Start receiving from the next receiveGroup

Methods inherited from class java.lang.Object

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

Method Detail

setupReceiveGroups

public void setupReceiveGroups(java.util.List<IntArrayList> receivingIds)

Start receiving from the next set of ids

startGroup

public void startGroup(int receiveGroup,
                       int sendGroup,
                       java.util.Map<java.lang.Integer,java.lang.Integer> expectedReceives)

Start receiving from the next receiveGroup

Parameters:

receiveGroup - the next receiveGroup

sendMessage

public boolean sendMessage(int source,
                           java.lang.Object message,
                           int target,
                           int flags,
                           RoutingParameters routingParameters)

Sends a message from a originating location

Parameters:

source - source id

message - the actual message

target - an specific target

flags - message flags

routingParameters - routing parameter

Returns:

true if the message is accepted

onReceiveComplete

public void onReceiveComplete(int id,
                              int e,
                              DataBuffer buffer)

Description copied from interface: ChannelListener

After a receive is complete this function gets called

Specified by:

onReceiveComplete in interface ChannelListener

Parameters:

id - the rank from which the receive happens

isComplete

public boolean isComplete()

Weather we have more data to complete, we only check the sends and

progress

public void progress()

Progress the serializations and receives, this method must be called by threads to send messages through this communication

sendProgress

public void sendProgress(int sendId)

Go through the out messages, create channel messages by using the serializer send them

Parameters:

sendId - send target

receiveDeserializeProgress

public void receiveDeserializeProgress(int receiveId)

Progress deserialize

Parameters:

receiveId -

receiveProgress

public void receiveProgress(int receiveId)

Progress the receive

Parameters:

receiveId -

release

public void release(ChannelMessage message)

Specified by:

release in interface ChannelMessageReleaseCallback

onSendComplete

public void onSendComplete(int id,
                           int messageStream,
                           ChannelMessage message)

Description copied from interface: ChannelListener

After a send is complete this function gets called

Specified by:

onSendComplete in interface ChannelListener

Parameters:

id - the rank from which the receive happens

message - message

getInstancePlan

public LogicalPlan getInstancePlan()

getConfig

public Config getConfig()

setKeyType

public void setKeyType(MessageType keyType)

close

public void close()