edu.iu.dsc.tws.comms.table.channel

Class MPIChannel

java.lang.Object

edu.iu.dsc.tws.comms.table.channel.MPIChannel

public class MPIChannel
extends java.lang.Object

Field Summary

Fields

Modifier and Type	Field and Description
static int	TWISTERX_CHANNEL_USER_HEADER

Constructor Summary

Constructors

Constructor and Description
MPIChannel(Config config, IWorkerController wController, int ed, java.util.List<java.lang.Integer> srcs, java.util.List<java.lang.Integer> tgts, ChannelReceiveCallback recvCallback, ChannelSendCallback sCallback, Allocator allocator)

Method Summary

Modifier and Type	Method and Description
void	close() Close the channel and clear any allocated memory by the channel
void	progressReceives() This method needs to be called to progress the receives
void	progressSends() This method needs to be called to progress the send
int	send(TRequest request) Send the request
int	sendFin(TRequest request) Inform the finish to the target

Methods inherited from class java.lang.Object

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

Field Detail

TWISTERX_CHANNEL_USER_HEADER

public static final int TWISTERX_CHANNEL_USER_HEADER

See Also:

Constant Field Values

Constructor Detail

MPIChannel

public MPIChannel(Config config,
                  IWorkerController wController,
                  int ed,
                  java.util.List<java.lang.Integer> srcs,
                  java.util.List<java.lang.Integer> tgts,
                  ChannelReceiveCallback recvCallback,
                  ChannelSendCallback sCallback,
                  Allocator allocator)

Method Detail

send

public int send(TRequest request)

Send the request

Parameters:

request - the request containing buffer, destination etc

Returns:

if the request is accepted to be sent

sendFin

public int sendFin(TRequest request)

Inform the finish to the target

Parameters:

request - the request

Returns:

-1 if not accepted, 1 if accepted

progressSends

public void progressSends()

This method needs to be called to progress the send

progressReceives

public void progressReceives()

This method needs to be called to progress the receives

close

public void close()

Close the channel and clear any allocated memory by the channel