edu.iu.dsc.tws.comms.dfw

Class ChannelDataFlowOperation

java.lang.Object

edu.iu.dsc.tws.comms.dfw.ChannelDataFlowOperation

All Implemented Interfaces:

ChannelListener, ChannelMessageReleaseCallback

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

Method Summary

Modifier and Type	Method and Description
void	close()
Config	getConfig()
LogicalPlan	getInstancePlan()
void	init(Config cfg, MessageType messageType, LogicalPlan plan, int graphEdge, java.util.Set<java.lang.Integer> recvExecutors, ChannelReceiver msgReceiver, java.util.Map<java.lang.Integer,java.util.concurrent.ArrayBlockingQueue<OutMessage>> pendingSendPerSource, java.util.Map<java.lang.Integer,java.util.Queue<InMessage>> pRMPS, java.util.Map<java.lang.Integer,java.util.Queue<InMessage>> pendingReceiveDesrialize, java.util.Map<java.lang.Integer,MessageSerializer> serializer, java.util.Map<java.lang.Integer,MessageDeSerializer> deSerializer, boolean keyed)
void	init(Config cfg, MessageType messageType, MessageType recvMessageType, LogicalPlan plan, int graphEdge, java.util.Set<java.lang.Integer> recvExecutors, ChannelReceiver msgReceiver, java.util.Map<java.lang.Integer,java.util.concurrent.ArrayBlockingQueue<OutMessage>> pendingSendPerSource, java.util.Map<java.lang.Integer,java.util.Queue<InMessage>> pRMPS, java.util.Map<java.lang.Integer,java.util.Queue<InMessage>> pendingReceiveDesrialize, java.util.Map<java.lang.Integer,MessageSerializer> serializer, java.util.Map<java.lang.Integer,MessageDeSerializer> deSerializer, boolean keyed)
void	init(Config cfg, MessageType messageType, MessageType rcvDataType, MessageType kType, MessageType rcvKeyType, LogicalPlan plan, int graphEdge, java.util.Set<java.lang.Integer> recvExecutors, ChannelReceiver msgReceiver, java.util.Map<java.lang.Integer,java.util.concurrent.ArrayBlockingQueue<OutMessage>> pendingSendPerSource, java.util.Map<java.lang.Integer,java.util.Queue<InMessage>> pRMPS, java.util.Map<java.lang.Integer,java.util.Queue<InMessage>> pendingReceiveDesrialize, java.util.Map<java.lang.Integer,MessageSerializer> serializer, java.util.Map<java.lang.Integer,MessageDeSerializer> deSerializer, boolean keyed)
boolean	isComplete() Weather we have more data to complete
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	release(ChannelMessage message)
boolean	sendMessage(int source, java.lang.Object message, int target, int flags, RoutingParameters routingParameters) Sends a message from a originating location
protected boolean	sendMessagePartial(int source, java.lang.Object message, int target, int flags, RoutingParameters routingParameters) Sends a message from a partial location
void	setKeyType(MessageType keyType)

Methods inherited from class java.lang.Object

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

Method Detail

init

public void init(Config cfg,
                 MessageType messageType,
                 MessageType rcvDataType,
                 MessageType kType,
                 MessageType rcvKeyType,
                 LogicalPlan plan,
                 int graphEdge,
                 java.util.Set<java.lang.Integer> recvExecutors,
                 ChannelReceiver msgReceiver,
                 java.util.Map<java.lang.Integer,java.util.concurrent.ArrayBlockingQueue<OutMessage>> pendingSendPerSource,
                 java.util.Map<java.lang.Integer,java.util.Queue<InMessage>> pRMPS,
                 java.util.Map<java.lang.Integer,java.util.Queue<InMessage>> pendingReceiveDesrialize,
                 java.util.Map<java.lang.Integer,MessageSerializer> serializer,
                 java.util.Map<java.lang.Integer,MessageDeSerializer> deSerializer,
                 boolean keyed)

init

public void init(Config cfg,
                 MessageType messageType,
                 LogicalPlan plan,
                 int graphEdge,
                 java.util.Set<java.lang.Integer> recvExecutors,
                 ChannelReceiver msgReceiver,
                 java.util.Map<java.lang.Integer,java.util.concurrent.ArrayBlockingQueue<OutMessage>> pendingSendPerSource,
                 java.util.Map<java.lang.Integer,java.util.Queue<InMessage>> pRMPS,
                 java.util.Map<java.lang.Integer,java.util.Queue<InMessage>> pendingReceiveDesrialize,
                 java.util.Map<java.lang.Integer,MessageSerializer> serializer,
                 java.util.Map<java.lang.Integer,MessageDeSerializer> deSerializer,
                 boolean keyed)

init

public void init(Config cfg,
                 MessageType messageType,
                 MessageType recvMessageType,
                 LogicalPlan plan,
                 int graphEdge,
                 java.util.Set<java.lang.Integer> recvExecutors,
                 ChannelReceiver msgReceiver,
                 java.util.Map<java.lang.Integer,java.util.concurrent.ArrayBlockingQueue<OutMessage>> pendingSendPerSource,
                 java.util.Map<java.lang.Integer,java.util.Queue<InMessage>> pRMPS,
                 java.util.Map<java.lang.Integer,java.util.Queue<InMessage>> pendingReceiveDesrialize,
                 java.util.Map<java.lang.Integer,MessageSerializer> serializer,
                 java.util.Map<java.lang.Integer,MessageDeSerializer> deSerializer,
                 boolean keyed)

sendMessagePartial

protected boolean sendMessagePartial(int source,
                                     java.lang.Object message,
                                     int target,
                                     int flags,
                                     RoutingParameters routingParameters)

Sends a message from a partial 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

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

progress

public void progress()

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

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()