edu.iu.dsc.tws.api.config

Class MPIContext

java.lang.Object

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

edu.iu.dsc.tws.api.config.SchedulerContext

edu.iu.dsc.tws.api.config.MPIContext

public class MPIContext
extends SchedulerContext

Field Summary

Fields

Modifier and Type	Field and Description
static java.lang.String	FILE_SYSTEM_MOUNT
static java.lang.String	MODE
static java.lang.String	MPI_MAP_BY
static java.lang.String	MPI_MAP_BY_PE
static java.lang.String	MPI_PARAMS
static java.lang.String	MPI_SHELL_SCRIPT
static java.lang.String	MPIRUN_FILE
static java.lang.String	NODES_FILE
static java.lang.String	NODES_ON_SHARED_FS
static java.lang.String	PARTITION
static java.lang.String	SLURM_JOB_ID
static java.lang.String	SLURM_PARAMS
static java.lang.String	WORKING_DIRECTORY

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

ADDITIONAL_PORTS, CLUSTER_TYPE, CONFIG_DIR, COPY_SYSTEM_PACKAGE, CORE_PACKAGE_FILENAME, CORE_PACKAGE_FILENAME_DEFAULT, CORE_PACKAGE_URL, DATACENTER_LABEL_KEY, DATACENTERS_LIST, DEBUG, DOWNLOAD_METHOD, DRIVER_CLASS, JOB_ARCHIVE_TEMP_DIR, JOB_DESCRIPTION_FILE_CMD_VAR, JOB_MASTER_PROVIDED_IP, JOB_PACKAGE_FILENAME, JOB_PACKAGE_FILENAME_DEFAULT, JOB_PACKAGE_URI, JOB_PACKAGE_URL, K8S_CHECK_PODS_REACHABLE, K8S_CHECK_PODS_REACHABLE_DEFAULT, LAUNCHER_CLASS, NETWORK_INTERFACES, NFS_SERVER_ADDRESS, NFS_SERVER_PATH, PERSISTENT_VOLUME_PER_WORKER, PERSISTENT_VOLUME_PER_WORKER_DEFAULT, RACK_LABEL_KEY, RACKS_LIST, SYSTEM_PACKAGE_URI, TEMPORARY_PACKAGES_PATH, THREADS_PER_WORKER, TWISTER_2_HOME, TWISTER2_PACKAGES_PATH, UPLOADER_CLASS, USER_JOB_FILE, USER_JOB_TYPE, WORKER_CLASS, WORKER_COMPUTE_RESOURCES

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
MPIContext()

Method Summary

Modifier and Type	Method and Description
static void	addRuntimeObject(java.lang.String name, java.lang.Object value)
static java.lang.String	fileSystemMount(Config cfg)
static java.lang.Object	getRuntimeObject(java.lang.String name)
static boolean	isSharedFs(Config cfg)
static java.lang.String	jobIdFile(Config config)
static java.lang.String	mpiMapBy(Config cfg, int cpusPerProc)
static java.lang.String	mpiMode(Config cfg)
static java.lang.String	mpiParams(Config cfg)
static java.lang.String	mpiRunFile(Config cfg)
static java.lang.String	mpiScriptWithPath(Config config)
static java.lang.String	mpiShellScript(Config config)
static java.lang.String	nodesFile(Config cfg)
static java.lang.String	partition(Config cfg)
static java.lang.String	slurmParams(Config cfg)
static java.lang.String	workingDirectory(Config config)

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

additionalPorts, checkPodsReachable, copySystemPackage, corePackageFileName, corePackageUrl, createJobDescriptionFileName, downloadMethod, driverClass, getJobMasterProvidedIp, getNodeInfo, isLocalFileSystemUploader, jobArchiveTempDirectory, jobPackageFileName, jobPackageUri, jobPackageUrl, launcherClass, networkInterfaces, nfsServerAddress, nfsServerPath, numberOfAdditionalPorts, packagesPath, persistentVolumePerWorker, persistentVolumeRequested, systemPackageUrl, temporaryPackagesPath, uploaderClass, useOpenMPI, userJobJarFile, userJobType, workerClass, workerEndSyncWaitTime

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

WORKING_DIRECTORY

public static final java.lang.String WORKING_DIRECTORY

See Also:

Constant Field Values

SLURM_JOB_ID

public static final java.lang.String SLURM_JOB_ID

See Also:

Constant Field Values

MPI_SHELL_SCRIPT

public static final java.lang.String MPI_SHELL_SCRIPT

See Also:

Constant Field Values

PARTITION

public static final java.lang.String PARTITION

See Also:

Constant Field Values

MODE

public static final java.lang.String MODE

See Also:

Constant Field Values

NODES_FILE

public static final java.lang.String NODES_FILE

See Also:

Constant Field Values

MPIRUN_FILE

public static final java.lang.String MPIRUN_FILE

See Also:

Constant Field Values

MPI_MAP_BY

public static final java.lang.String MPI_MAP_BY

See Also:

Constant Field Values

MPI_MAP_BY_PE

public static final java.lang.String MPI_MAP_BY_PE

See Also:

Constant Field Values

MPI_PARAMS

public static final java.lang.String MPI_PARAMS

See Also:

Constant Field Values

SLURM_PARAMS

public static final java.lang.String SLURM_PARAMS

See Also:

Constant Field Values

NODES_ON_SHARED_FS

public static final java.lang.String NODES_ON_SHARED_FS

See Also:

Constant Field Values

FILE_SYSTEM_MOUNT

public static final java.lang.String FILE_SYSTEM_MOUNT

See Also:

Constant Field Values

Constructor Detail

MPIContext

public MPIContext()

Method Detail

workingDirectory

public static java.lang.String workingDirectory(Config config)

jobIdFile

public static java.lang.String jobIdFile(Config config)

mpiShellScript

public static java.lang.String mpiShellScript(Config config)

mpiScriptWithPath

public static java.lang.String mpiScriptWithPath(Config config)

mpiParams

public static java.lang.String mpiParams(Config cfg)

slurmParams

public static java.lang.String slurmParams(Config cfg)

partition

public static java.lang.String partition(Config cfg)

mpiMode

public static java.lang.String mpiMode(Config cfg)

nodesFile

public static java.lang.String nodesFile(Config cfg)

mpiRunFile

public static java.lang.String mpiRunFile(Config cfg)

mpiMapBy

public static java.lang.String mpiMapBy(Config cfg,
                                        int cpusPerProc)

isSharedFs

public static boolean isSharedFs(Config cfg)

fileSystemMount

public static java.lang.String fileSystemMount(Config cfg)

addRuntimeObject

public static void addRuntimeObject(java.lang.String name,
                                    java.lang.Object value)

getRuntimeObject

public static java.lang.Object getRuntimeObject(java.lang.String name)