edu.iu.dsc.tws.comms.table

Class SimpleAllToAll

java.lang.Object

edu.iu.dsc.tws.comms.table.SimpleAllToAll

All Implemented Interfaces:

ChannelReceiveCallback, ChannelSendCallback

public class SimpleAllToAll
extends java.lang.Object
implements ChannelReceiveCallback, ChannelSendCallback

Constructor Summary

Constructors

Constructor and Description
SimpleAllToAll(Config cfg, IWorkerController workerController, java.util.List<java.lang.Integer> sources, java.util.List<java.lang.Integer> targets, int edgeId, ReceiveCallback callback, Allocator allocator)

Method Summary

Modifier and Type	Method and Description
void	close()
void	finish()
boolean	insert(java.nio.ByteBuffer buf, int length, int target)
boolean	insert(java.nio.ByteBuffer buf, int length, int[] header, int headerLength, int target)
boolean	isComplete()
void	receivedData(int receiveId, ChannelBuffer buffer, int length)
void	receivedHeader(int receiveId, int finished, int[] header, int headerLength)
void	sendComplete(TRequest request)
void	sendFinishComplete(TRequest request)

Methods inherited from class java.lang.Object

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

Constructor Detail

SimpleAllToAll

public SimpleAllToAll(Config cfg,
                      IWorkerController workerController,
                      java.util.List<java.lang.Integer> sources,
                      java.util.List<java.lang.Integer> targets,
                      int edgeId,
                      ReceiveCallback callback,
                      Allocator allocator)

Method Detail

insert

public boolean insert(java.nio.ByteBuffer buf,
                      int length,
                      int target)

insert

public boolean insert(java.nio.ByteBuffer buf,
                      int length,
                      int[] header,
                      int headerLength,
                      int target)

isComplete

public boolean isComplete()

finish

public void finish()

close

public void close()

receivedData

public void receivedData(int receiveId,
                         ChannelBuffer buffer,
                         int length)

Specified by:

receivedData in interface ChannelReceiveCallback

receivedHeader

public void receivedHeader(int receiveId,
                           int finished,
                           int[] header,
                           int headerLength)

Specified by:

receivedHeader in interface ChannelReceiveCallback

sendComplete

public void sendComplete(TRequest request)

Specified by:

sendComplete in interface ChannelSendCallback

sendFinishComplete

public void sendFinishComplete(TRequest request)

Specified by:

sendFinishComplete in interface ChannelSendCallback