edu.iu.dsc.tws.api.comms

Class Communicator

java.lang.Object

edu.iu.dsc.tws.api.comms.Communicator

public class Communicator
extends java.lang.Object

Communicator that keeps the information about.

Constructor Summary

Constructors

Modifier	Constructor and Description
	Communicator(Config cfg, TWSChannel ch)
protected	Communicator(Config config, TWSChannel channel, EdgeGenerator edgeGenerator, TaskIdGenerator idGenerator, java.util.List<java.lang.String> persistentDirectories)
	Communicator(Config config, TWSChannel ch, java.util.List<java.lang.String> persDirs)
	Communicator(Config config, TWSChannel ch, java.lang.String persDir)

Method Summary

Modifier and Type	Method and Description
void	close() Terminate the communicator
TWSChannel	getChannel()
Config	getConfig()
java.util.List<java.lang.String>	getPersistentDirectories()
java.lang.String	getPersistentDirectory(int requesterId)
Communicator	newWithConfig(java.util.Map<java.lang.String,java.lang.Object> newConfig) Create a communicator with new configuration
int	nextEdge()
int	nextId()
void	reInit()
void	updateConfig(java.util.Map<java.lang.String,java.lang.Object> newConfigs) Update the configs with new configurations

Methods inherited from class java.lang.Object

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

Constructor Detail

Communicator

public Communicator(Config cfg,
                    TWSChannel ch)

Communicator

public Communicator(Config config,
                    TWSChannel ch,
                    java.util.List<java.lang.String> persDirs)

Communicator

public Communicator(Config config,
                    TWSChannel ch,
                    java.lang.String persDir)

Communicator

protected Communicator(Config config,
                       TWSChannel channel,
                       EdgeGenerator edgeGenerator,
                       TaskIdGenerator idGenerator,
                       java.util.List<java.lang.String> persistentDirectories)

Method Detail

reInit

public void reInit()

getChannel

public TWSChannel getChannel()

getConfig

public Config getConfig()

nextEdge

public int nextEdge()

nextId

public int nextId()

getPersistentDirectory

public java.lang.String getPersistentDirectory(int requesterId)

getPersistentDirectories

public java.util.List<java.lang.String> getPersistentDirectories()

close

public void close()

Terminate the communicator

updateConfig

public void updateConfig(java.util.Map<java.lang.String,java.lang.Object> newConfigs)

Update the configs with new configurations

Parameters:

newConfigs - the new configurations

newWithConfig

public Communicator newWithConfig(java.util.Map<java.lang.String,java.lang.Object> newConfig)

Create a communicator with new configuration

Parameters:

newConfig - the new configuration

Returns:

communicator