edu.iu.dsc.tws.common.net.tcp

Class TCPChannel

java.lang.Object

edu.iu.dsc.tws.common.net.tcp.TCPChannel

public class TCPChannel
extends java.lang.Object

A channel implementation, that supports iSend and iRecv semantics.

Field Summary

Fields

Modifier and Type	Field and Description
protected <any>	clientChannels client channels with workerIDs
protected <any>	serverChannels server channels with workerIDs

Constructor Summary

Constructors

Constructor and Description
TCPChannel(Config cfg, NetworkInfo info) Start the channel with the given network information

Method Summary

Modifier and Type	Method and Description
void	closeConnection(int workerID)
TCPMessage	iRecv(java.nio.ByteBuffer buffer, int size, int workerID, int edge) Receive a message
TCPMessage	iSend(java.nio.ByteBuffer buffer, int size, int workerID, int edge) Send a buffer
void	progress() Progress the communication
void	startConnections(java.util.List<NetworkInfo> workerInfos) Start the connections to the servers
void	startListening() Start listening
void	stop() Stop all the connections
void	waitForConnections(long timeLimit) Wait for handshakes to happen between servers and clients

Methods inherited from class java.lang.Object

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

Field Detail

clientChannels

protected <any> clientChannels

client channels with workerIDs

serverChannels

protected <any> serverChannels

server channels with workerIDs

Constructor Detail

TCPChannel

public TCPChannel(Config cfg,
                  NetworkInfo info)

Start the channel with the given network information

Parameters:

cfg - configuration

info - network information

Method Detail

startListening

public void startListening()

Start listening

startConnections

public void startConnections(java.util.List<NetworkInfo> workerInfos)

Start the connections to the servers

Parameters:

workerInfos - information about all the workers

iSend

public TCPMessage iSend(java.nio.ByteBuffer buffer,
                        int size,
                        int workerID,
                        int edge)

Send a buffer

Parameters:

buffer - buffer

size - size of the buffer, we assume start from 0th position

workerID - the worker id

edge - the edg

Returns:

the reference message created

iRecv

public TCPMessage iRecv(java.nio.ByteBuffer buffer,
                        int size,
                        int workerID,
                        int edge)

Receive a message

Parameters:

buffer - buffer

size - size of the buffer, we assume start from 0th position

workerID - the worker id

edge - the edg

Returns:

the reference message created

progress

public void progress()

Progress the communication

stop

public void stop()

Stop all the connections

waitForConnections

public void waitForConnections(long timeLimit)

Wait for handshakes to happen between servers and clients

closeConnection

public void closeConnection(int workerID)