SG++-Doxygen-Documentation
Public Member Functions | Protected Member Functions | Protected Attributes | List of all members
sgpp::datadriven::clusteringmpi::MPIWorkerPackageBase< T > Class Template Referenceabstract

#include <OperationPackageBaseMPI.hpp>

Inheritance diagram for sgpp::datadriven::clusteringmpi::MPIWorkerPackageBase< T >:
sgpp::datadriven::clusteringmpi::MPIWorkerBase

Public Member Functions

 MPIWorkerPackageBase (std::string operationName, int multiplier)
 
 MPIWorkerPackageBase (std::string operationName, int multiplier, std::string ocl_conf_filename)
 
void start_worker_main (void)
 
virtual ~MPIWorkerPackageBase ()
 
- Public Member Functions inherited from sgpp::datadriven::clusteringmpi::MPIWorkerBase
 MPIWorkerBase (std::string worker_class_name)
 
 MPIWorkerBase ()
 
void release_sub_workers (void)
 
void start_sub_workers (void)
 
virtual ~MPIWorkerBase (void)
 

Protected Member Functions

virtual void begin_opencl_operation (int *workpackage)=0
 
void divide_workpackages (int *package, T *erg)
 
virtual void finalize_opencl_operation (T *result_buffer, int *workpackage)=0
 
virtual void receive_and_send_initial_data (void)=0
 

Protected Attributes

MPI_Comm & master_worker_comm
 
MPI_Datatype mpi_typ
 
size_t opencl_device = 0
 
bool opencl_node
 
size_t opencl_platform = 0
 
bool overseer_node
 
int packagesize_multiplier
 
base::OCLOperationConfiguration * parameters
 
bool prefetching
 
bool redistribute
 
int secondary_workpackage [2]
 
size_t size
 
MPI_Comm & sub_worker_comm
 
- Protected Attributes inherited from sgpp::datadriven::clusteringmpi::MPIWorkerBase
bool verbose
 

Constructor & Destructor Documentation

◆ MPIWorkerPackageBase() [1/2]

template<class T>
sgpp::datadriven::clusteringmpi::MPIWorkerPackageBase< T >::MPIWorkerPackageBase ( std::string  operationName,
int  multiplier 
)
inline

◆ MPIWorkerPackageBase() [2/2]

template<class T>
sgpp::datadriven::clusteringmpi::MPIWorkerPackageBase< T >::MPIWorkerPackageBase ( std::string  operationName,
int  multiplier,
std::string  ocl_conf_filename 
)
inline

◆ ~MPIWorkerPackageBase()

template<class T>
virtual sgpp::datadriven::clusteringmpi::MPIWorkerPackageBase< T >::~MPIWorkerPackageBase ( )
inlinevirtual

Member Function Documentation

◆ begin_opencl_operation()

template<class T>
virtual void sgpp::datadriven::clusteringmpi::MPIWorkerPackageBase< T >::begin_opencl_operation ( int *  workpackage)
protectedpure virtual

Implemented in sgpp::datadriven::clusteringmpi::DensityWorker, sgpp::datadriven::clusteringmpi::PrunedGraphCreationWorker, and sgpp::datadriven::clusteringmpi::DensityRhsWorker.

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

◆ divide_workpackages()

template<class T>
void sgpp::datadriven::clusteringmpi::MPIWorkerPackageBase< T >::divide_workpackages ( int *  package,
T *  erg 
)
inlineprotected

Referenced by sgpp::datadriven::clusteringmpi::MPIWorkerPackageBase< int >::start_worker_main().

◆ finalize_opencl_operation()

template<class T>
virtual void sgpp::datadriven::clusteringmpi::MPIWorkerPackageBase< T >::finalize_opencl_operation ( T *  result_buffer,
int *  workpackage 
)
protectedpure virtual

Implemented in sgpp::datadriven::clusteringmpi::DensityWorker, sgpp::datadriven::clusteringmpi::PrunedGraphCreationWorker, and sgpp::datadriven::clusteringmpi::DensityRhsWorker.

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

◆ receive_and_send_initial_data()

template<class T>
virtual void sgpp::datadriven::clusteringmpi::MPIWorkerPackageBase< T >::receive_and_send_initial_data ( void  )
protectedpure virtual

Implemented in sgpp::datadriven::clusteringmpi::PrunedGraphCreationWorker, sgpp::datadriven::clusteringmpi::DensityWorker, and sgpp::datadriven::clusteringmpi::DensityRhsWorker.

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

◆ start_worker_main()

template<class T>
void sgpp::datadriven::clusteringmpi::MPIWorkerPackageBase< T >::start_worker_main ( void  )
inlinevirtual

Implements sgpp::datadriven::clusteringmpi::MPIWorkerBase.

Member Data Documentation

◆ master_worker_comm

template<class T>
MPI_Comm& sgpp::datadriven::clusteringmpi::MPIWorkerPackageBase< T >::master_worker_comm
protected

◆ mpi_typ

template<class T>
MPI_Datatype sgpp::datadriven::clusteringmpi::MPIWorkerPackageBase< T >::mpi_typ
protected

◆ opencl_device

template<class T>
size_t sgpp::datadriven::clusteringmpi::MPIWorkerPackageBase< T >::opencl_device = 0
protected

◆ opencl_node

template<class T>
bool sgpp::datadriven::clusteringmpi::MPIWorkerPackageBase< T >::opencl_node
protected

◆ opencl_platform

template<class T>
size_t sgpp::datadriven::clusteringmpi::MPIWorkerPackageBase< T >::opencl_platform = 0
protected

◆ overseer_node

template<class T>
bool sgpp::datadriven::clusteringmpi::MPIWorkerPackageBase< T >::overseer_node
protected

◆ packagesize_multiplier

template<class T>
int sgpp::datadriven::clusteringmpi::MPIWorkerPackageBase< T >::packagesize_multiplier
protected

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

◆ parameters

template<class T>
base::OCLOperationConfiguration* sgpp::datadriven::clusteringmpi::MPIWorkerPackageBase< T >::parameters
protected

◆ prefetching

template<class T>
bool sgpp::datadriven::clusteringmpi::MPIWorkerPackageBase< T >::prefetching
protected

◆ redistribute

template<class T>
bool sgpp::datadriven::clusteringmpi::MPIWorkerPackageBase< T >::redistribute
protected

◆ secondary_workpackage

template<class T>
int sgpp::datadriven::clusteringmpi::MPIWorkerPackageBase< T >::secondary_workpackage[2]
protected

◆ size

template<class T>
size_t sgpp::datadriven::clusteringmpi::MPIWorkerPackageBase< T >::size
protected

Referenced by sgpp::datadriven::clusteringmpi::MPIWorkerPackageBase< int >::divide_workpackages().

◆ sub_worker_comm

template<class T>
MPI_Comm& sgpp::datadriven::clusteringmpi::MPIWorkerPackageBase< T >::sub_worker_comm
protected
The documentation for this class was generated from the following file: