SG++-Doxygen-Documentation
Public Member Functions | Static Public Member Functions | List of all members
sgpp::datadriven::clusteringmpi::MPIEnviroment Class Reference

#include <MPIEnviroment.hpp>

Public Member Functions

 ~MPIEnviroment ()
 

Static Public Member Functions

static void connect_nodes (base::OperationConfiguration conf)
 
static base::OperationConfiguration createMPIConfiguration (int packagesize_master, int leutnant_nodes, int packagesize_leutnants, int slave_nodes_per_leutnant)
 
static base::OperationConfiguration createMPIConfiguration (int compute_nodes, int opencl_devices_per_compute_node)
 
static base::OperationConfiguration createMPIConfiguration (int compute_nodes, base::OCLOperationConfiguration node_opencl_configuration)
 Create MPI configuration file based on a number of compute nodes their OpenCL configuration file. More...
 
static MPI_Comm & get_communicator (void)
 
static base::OperationConfiguration & get_configuration (void)
 
static MPI_Comm & get_input_communicator (void)
 
static int get_node_count (void)
 
static int get_node_rank (void)
 
static int get_sub_worker_count (void)
 
static void init (int argc, char *argv[], bool verbose=false)
 
static void release (void)
 

Constructor & Destructor Documentation

◆ ~MPIEnviroment()

sgpp::datadriven::clusteringmpi::MPIEnviroment::~MPIEnviroment ( void  )

Referenced by get_input_communicator().

Member Function Documentation

◆ connect_nodes()

void sgpp::datadriven::clusteringmpi::MPIEnviroment::connect_nodes ( base::OperationConfiguration  conf)
static

References get_node_count(), and python.statsfileInfo::i.

Referenced by main().

◆ createMPIConfiguration() [1/3]

base::OperationConfiguration sgpp::datadriven::clusteringmpi::MPIEnviroment::createMPIConfiguration ( int  packagesize_master,
int  leutnant_nodes,
int  packagesize_leutnants,
int  slave_nodes_per_leutnant 
)
static

References json::DictNode::addAttribute(), json::Node::addAttribute(), json::DictNode::addIDAttr(), json::Node::addIDAttr(), and python.statsfileInfo::i.

Referenced by get_input_communicator(), and main().

◆ createMPIConfiguration() [2/3]

base::OperationConfiguration sgpp::datadriven::clusteringmpi::MPIEnviroment::createMPIConfiguration ( int  compute_nodes,
int  opencl_devices_per_compute_node 
)
static

References json::DictNode::addAttribute(), json::Node::addAttribute(), json::DictNode::addIDAttr(), json::Node::addIDAttr(), and python.statsfileInfo::i.

◆ createMPIConfiguration() [3/3]

base::OperationConfiguration sgpp::datadriven::clusteringmpi::MPIEnviroment::createMPIConfiguration ( int  compute_nodes,
base::OCLOperationConfiguration  node_opencl_configuration 
)
static

Create MPI configuration file based on a number of compute nodes their OpenCL configuration file.

Creates a MPI configuration with 3 Levels. One master node to control all other nodes, and one leutenant node on every compute node which controls all MPI nodes for this compute nodes. For each OpenCL device specified in the opencl configuration it will also create one worker. Duplicate devices will not be recognized hoewever.

Parameters
compute_nodesNumber of compute nodes
node_opencl_configurationOpenCL configuration file
Returns
Finished MPI configuration

References json::DictNode::addAttribute(), json::Node::addAttribute(), json::DictNode::addIDAttr(), json::Node::addIDAttr(), and python.statsfileInfo::i.

◆ get_communicator()

static MPI_Comm& sgpp::datadriven::clusteringmpi::MPIEnviroment::get_communicator ( void  )
inlinestatic

Referenced by sgpp::datadriven::clusteringmpi::MPIWorkerBase::MPIWorkerBase(), sgpp::datadriven::clusteringmpi::MPIWorkerBase::release_sub_workers(), sgpp::datadriven::clusteringmpi::MPIWorkerBase::start_sub_workers(), and sgpp::datadriven::clusteringmpi::MPIWorkerGraphBase::~MPIWorkerGraphBase().

◆ get_configuration()

static base::OperationConfiguration& sgpp::datadriven::clusteringmpi::MPIEnviroment::get_configuration ( void  )
inlinestatic

Referenced by sgpp::datadriven::clusteringmpi::GraphCreationWorker::divide_workpackages(), sgpp::datadriven::clusteringmpi::MPIWorkerBase::MPIWorkerBase(), and sgpp::datadriven::clusteringmpi::MPIWorkerPackageBase< int >::MPIWorkerPackageBase().

◆ get_input_communicator()

static MPI_Comm& sgpp::datadriven::clusteringmpi::MPIEnviroment::get_input_communicator ( void  )
inlinestatic

References createMPIConfiguration(), and ~MPIEnviroment().

Referenced by sgpp::datadriven::clusteringmpi::MPIWorkerGraphBase::~MPIWorkerGraphBase().

◆ get_node_count()

int sgpp::datadriven::clusteringmpi::MPIEnviroment::get_node_count ( void  )
static

Referenced by connect_nodes().

◆ get_node_rank()

int sgpp::datadriven::clusteringmpi::MPIEnviroment::get_node_rank ( void  )
static

Referenced by sgpp::datadriven::clusteringmpi::DensityWorker::DensityWorker(), sgpp::datadriven::clusteringmpi::GraphCreationWorker::divide_workpackages(), sgpp::datadriven::clusteringmpi::MPIWorkerPackageBase< int >::divide_workpackages(), main(), sgpp::datadriven::clusteringmpi::MPIWorkerBase::MPIWorkerBase(), sgpp::datadriven::clusteringmpi::MPIWorkerGraphBase::MPIWorkerGraphBase(), sgpp::datadriven::clusteringmpi::MPIWorkerPackageBase< int >::MPIWorkerPackageBase(), sgpp::datadriven::clusteringmpi::DensityWorker::receive_and_send_initial_data(), sgpp::datadriven::clusteringmpi::GraphCreationWorker::start_worker_main(), sgpp::datadriven::clusteringmpi::MPIWorkerPackageBase< int >::start_worker_main(), sgpp::datadriven::clusteringmpi::WorkerDummy::WorkerDummy(), and sgpp::datadriven::clusteringmpi::MPIWorkerGraphBase::~MPIWorkerGraphBase().

◆ get_sub_worker_count()

static int sgpp::datadriven::clusteringmpi::MPIEnviroment::get_sub_worker_count ( void  )
inlinestatic

Referenced by sgpp::datadriven::clusteringmpi::OperationPrunedGraphCreationMPI::create_graph(), sgpp::datadriven::clusteringmpi::OperationGraphCreationMPI::create_graph(), sgpp::datadriven::clusteringmpi::DensityWorker::DensityWorker(), sgpp::datadriven::clusteringmpi::GraphCreationWorker::divide_workpackages(), sgpp::datadriven::clusteringmpi::MPIWorkerPackageBase< int >::divide_workpackages(), sgpp::datadriven::clusteringmpi::OperationDensityRhsMPI::generate_b(), sgpp::datadriven::clusteringmpi::GraphCreationWorker::GraphCreationWorker(), sgpp::datadriven::clusteringmpi::MPIWorkerBase::MPIWorkerBase(), sgpp::datadriven::clusteringmpi::MPIWorkerPackageBase< int >::MPIWorkerPackageBase(), sgpp::datadriven::clusteringmpi::OperationDensityMultMPI::mult(), sgpp::datadriven::clusteringmpi::PrunedGraphCreationWorker::PrunedGraphCreationWorker(), sgpp::datadriven::clusteringmpi::MPIWorkerBase::release_sub_workers(), sgpp::datadriven::clusteringmpi::DensityWorker::send_alpha(), sgpp::datadriven::clusteringmpi::MPIWorkerBase::start_sub_workers(), sgpp::datadriven::clusteringmpi::GraphCreationWorker::start_worker_main(), sgpp::datadriven::clusteringmpi::MPIWorkerPackageBase< int >::start_worker_main(), and sgpp::datadriven::clusteringmpi::MPIWorkerGraphBase::~MPIWorkerGraphBase().

◆ init()

void sgpp::datadriven::clusteringmpi::MPIEnviroment::init ( int  argc,
char *  argv[],
bool  verbose = false 
)
static

Referenced by main().

◆ release()

void sgpp::datadriven::clusteringmpi::MPIEnviroment::release ( void  )
static

References python.statsfileInfo::i.

Referenced by main().

The documentation for this class was generated from the following files: