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

Class TCPContext

java.lang.Object

edu.iu.dsc.tws.api.config.Context

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

public class TCPContext
extends Context

Field Summary

Fields

Modifier and Type	Field and Description
static java.lang.String	MAX_CONN_EST_TIME
static long	MAX_CONN_EST_TIME_DEFAULT
static java.lang.String	NETWORK_HOSTNAME
static java.lang.String	NETWORK_PORT
static java.lang.String	TWISTER2_MAX_PACKET_SIZE
static java.lang.String	TWISTER2_READ_SIZE
static java.lang.String	TWISTER2_READ_TIME
static java.lang.String	TWISTER2_RECV_BUFF_SIZE
static java.lang.String	TWISTER2_SEND_BUFF_SIZE
static java.lang.String	TWISTER2_WRITE_SIZE
static java.lang.String	TWISTER2_WRITE_TIME

Fields inherited from class edu.iu.dsc.tws.api.config.Context

AURORA_SCRIPT, CHECKPOINT_YAML, CLUSTER, CLUSTER_CONF, CLUSTER_HOME, CORE_YAML, DATA_YAML, defaults, GRAPH_TYPE, HOME, JAVA_HOME, JOB, JOB_ARCHIVE_DIRECTORY, JOB_ID, JOB_NAME, JOB_OBJECT, NETWORK_YAML, OPERATION_NAME, OVERRIDE_YAML, RESOURCE_SCHEDULER_YAML, STREAMING, substitutions, TASK_YAML, TWISTER2_BANDWIDTH, TWISTER2_BIN, TWISTER2_CLUSTER_TYPE, TWISTER2_COMMON_CONF_DIR, TWISTER2_CONF, TWISTER2_CONTAINER_ID, TWISTER2_DIRECT_EDGE, TWISTER2_DIST, TWISTER2_GRAPH_JOB, TWISTER2_HOME, TWISTER2_LATENCY, TWISTER2_LIB, TWISTER2_MAX_TASK_INSTANCES_PER_WORKER, TWISTER2_TASK_INSTANCE_ODD_PARALLELISM, TWISTER2_TSET_JOB, TWISTER2_WORKER_INSTANCES, TWISTER2_WORKER_INSTANCES_DEFAULT, USER_NAME, VERBOSE

Constructor Summary

Constructors

Constructor and Description
TCPContext()

Method Summary

Modifier and Type	Method and Description
static java.lang.String	getHostName(NetworkInfo networkInfo)
static int	getMaximumPacketSize(Config cfg, int def)
static int	getNetworkReadBatchSize(Config cfg, int def)
static int	getNetworkReadBatchTime(Config cfg, int def)
static int	getNetworkWriteBatchSize(Config cfg, int def)
static int	getNetworkWriteBatchTime(Config cfg, int def)
static int	getPort(NetworkInfo networkInfo)
static int	getSocketReceivedBufferSize(Config cfg, int def)
static int	getSocketSendBufferSize(Config cfg, int def)
static long	maxConnEstTime(Config cfg)

Methods inherited from class edu.iu.dsc.tws.api.config.Context

auroraScript, checkpointCofigurationFile, checkpointConfigurationFile, clusterType, commonConfDir, conf, containerId, dataConfigurationFile, distDirectory, getDefaults, getDoublePropertyValue, getIntPropertyValue, getLongPropertyValue, getStringPropertyValue, isKubernetesCluster, jobId, jobName, libDirectory, networkConfigurationFile, resourceSchedulerConfigurationFile, systemConfigurationFile, taskConfigurationFile, twister2Home, userName, verbose, workerInstances

Methods inherited from class java.lang.Object

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

Field Detail

TWISTER2_WRITE_SIZE

public static final java.lang.String TWISTER2_WRITE_SIZE

See Also:

Constant Field Values

TWISTER2_WRITE_TIME

public static final java.lang.String TWISTER2_WRITE_TIME

See Also:

Constant Field Values

TWISTER2_READ_SIZE

public static final java.lang.String TWISTER2_READ_SIZE

See Also:

Constant Field Values

TWISTER2_READ_TIME

public static final java.lang.String TWISTER2_READ_TIME

See Also:

Constant Field Values

TWISTER2_MAX_PACKET_SIZE

public static final java.lang.String TWISTER2_MAX_PACKET_SIZE

See Also:

Constant Field Values

TWISTER2_SEND_BUFF_SIZE

public static final java.lang.String TWISTER2_SEND_BUFF_SIZE

See Also:

Constant Field Values

TWISTER2_RECV_BUFF_SIZE

public static final java.lang.String TWISTER2_RECV_BUFF_SIZE

See Also:

Constant Field Values

NETWORK_HOSTNAME

public static final java.lang.String NETWORK_HOSTNAME

See Also:

Constant Field Values

NETWORK_PORT

public static final java.lang.String NETWORK_PORT

See Also:

Constant Field Values

MAX_CONN_EST_TIME

public static final java.lang.String MAX_CONN_EST_TIME

See Also:

Constant Field Values

MAX_CONN_EST_TIME_DEFAULT

public static final long MAX_CONN_EST_TIME_DEFAULT

See Also:

Constant Field Values

Constructor Detail

TCPContext

public TCPContext()

Method Detail

getNetworkWriteBatchSize

public static int getNetworkWriteBatchSize(Config cfg,
                                           int def)

getNetworkWriteBatchTime

public static int getNetworkWriteBatchTime(Config cfg,
                                           int def)

getNetworkReadBatchSize

public static int getNetworkReadBatchSize(Config cfg,
                                          int def)

getNetworkReadBatchTime

public static int getNetworkReadBatchTime(Config cfg,
                                          int def)

getSocketSendBufferSize

public static int getSocketSendBufferSize(Config cfg,
                                          int def)

getSocketReceivedBufferSize

public static int getSocketReceivedBufferSize(Config cfg,
                                              int def)

getMaximumPacketSize

public static int getMaximumPacketSize(Config cfg,
                                       int def)

getHostName

public static java.lang.String getHostName(NetworkInfo networkInfo)

getPort

public static int getPort(NetworkInfo networkInfo)

maxConnEstTime

public static long maxConnEstTime(Config cfg)