Public Member Functions | Private Member Functions | Private Attributes | List of all members
te::vp::GroupThreadManager Class Reference

#include <GroupThreadManager.h>

Public Member Functions

void addOutput (std::vector< te::mem::DataSetItem * > &itemGroup)
 
void addWarning (const std::string &warning, const bool &appendIfExists=false)
 
te::mem::DataSetItem * createOutputItem ()
 
te::mem::DataSet * getClearOutputDataSet ()
 
te::da::DataSetType * getDataSetType ()
 
bool getNextGroup (std::vector< te::mem::DataSetItem * > &nextGroup)
 
bool getNextOutput (std::vector< te::mem::DataSetItem * > &nextOutput)
 
te::da::DataSetType * getOutputDataSetType ()
 
te::da::DataSource * getOutputDataSource ()
 
std::map< std::string, te::dt::AbstractData * > getSpecificParameters ()
 
std::vector< std::string > getWarnings ()
 
 GroupThreadManager (const std::map< std::string, std::vector< int > > &groups, te::da::DataSet *dataSet, te::da::DataSetType *dataSetType, te::mem::DataSet *outputDataSet, te::da::DataSetType *outputDataSetType, te::da::DataSource *outputDataSource, std::map< std::string, te::dt::AbstractData * > specificParams)
 
virtual ~GroupThreadManager ()
 

Private Member Functions

 GroupThreadManager (const GroupThreadManager &)
 
const GroupThreadManager & operator= (const GroupThreadManager &)
 

Private Attributes

te::da::DataSet * m_dataSet
 
te::da::DataSetType * m_dataSetType
 
std::map< std::string, std::vector< int > > m_groups
 
std::map< std::string, std::vector< int > >::iterator m_groupsIterator
 
boost::mutex m_mtx
 
boost::mutex m_mtxOutput
 
boost::mutex m_mtxWarning
 
te::mem::DataSet * m_outputDataSet
 
te::da::DataSetType * m_outputDataSetType
 
te::da::DataSource * m_outputDataSource
 
std::vector< std::vector< te::mem::DataSetItem * > > m_outputQueue
 
std::size_t m_savedCount
 
std::map< std::string, te::dt::AbstractData * > m_specificParams
 
te::common::TaskProgress m_task
 
std::vector< std::string > m_warnings
 

Detailed Description

Definition at line 67 of file GroupThreadManager.h.

Constructor & Destructor Documentation

te::vp::GroupThreadManager::GroupThreadManager ( const std::map< std::string, std::vector< int > > &  groups,
te::da::DataSet *  dataSet,
te::da::DataSetType *  dataSetType,
te::mem::DataSet *  outputDataSet,
te::da::DataSetType *  outputDataSetType,
te::da::DataSource *  outputDataSource,
std::map< std::string, te::dt::AbstractData * >  specificParams 
)

Definition at line 47 of file GroupThreadManager.cpp.

References m_groups, and m_groupsIterator.

virtual te::vp::GroupThreadManager::~GroupThreadManager ( )
inlinevirtual

Definition at line 79 of file GroupThreadManager.h.

te::vp::GroupThreadManager::GroupThreadManager ( const GroupThreadManager &  )
private

Definition at line 186 of file GroupThreadManager.cpp.

Member Function Documentation

void te::vp::GroupThreadManager::addOutput ( std::vector< te::mem::DataSetItem * > &  itemGroup)

Definition at line 159 of file GroupThreadManager.cpp.

References m_mtxOutput, and m_outputQueue.

Referenced by te::vp::Dissolve::threadUnion().

void te::vp::GroupThreadManager::addWarning ( const std::string &  warning,
const bool &  appendIfExists = false 
)

Definition at line 166 of file GroupThreadManager.cpp.

References m_mtxWarning, m_warnings, and TE_CORE_LOG_DEBUG.

Referenced by te::vp::Dissolve::threadSave(), and te::vp::Dissolve::threadUnion().

te::mem::DataSetItem * te::vp::GroupThreadManager::createOutputItem ( )

Definition at line 152 of file GroupThreadManager.cpp.

References m_outputDataSet.

Referenced by te::vp::Dissolve::threadUnion().

te::mem::DataSet * te::vp::GroupThreadManager::getClearOutputDataSet ( )

Definition at line 140 of file GroupThreadManager.cpp.

References te::mem::DataSet::clear(), and m_outputDataSet.

Referenced by te::vp::Dissolve::threadSave().

te::da::DataSetType * te::vp::GroupThreadManager::getDataSetType ( )

Definition at line 120 of file GroupThreadManager.cpp.

References m_dataSetType.

Referenced by te::vp::Dissolve::threadUnion().

bool te::vp::GroupThreadManager::getNextGroup ( std::vector< te::mem::DataSetItem * > &  nextGroup)

Definition at line 67 of file GroupThreadManager.cpp.

References te::da::DataSet::getValue(), te::da::DataSet::isNull(), m_dataSet, m_dataSetType, m_groups, m_groupsIterator, m_mtx, te::da::DataSet::move(), te::mem::DataSetItem::setValue(), and te::dt::CompositeProperty::size().

Referenced by te::vp::Dissolve::threadUnion().

bool te::vp::GroupThreadManager::getNextOutput ( std::vector< te::mem::DataSetItem * > &  nextOutput)

Definition at line 97 of file GroupThreadManager.cpp.

References m_groups, m_mtxOutput, m_outputQueue, and m_savedCount.

Referenced by te::vp::Dissolve::threadSave().

te::da::DataSetType * te::vp::GroupThreadManager::getOutputDataSetType ( )

Definition at line 130 of file GroupThreadManager.cpp.

References m_outputDataSetType.

Referenced by te::vp::Dissolve::threadSave(), and te::vp::Dissolve::threadUnion().

te::da::DataSource * te::vp::GroupThreadManager::getOutputDataSource ( )

Definition at line 125 of file GroupThreadManager.cpp.

References m_outputDataSource.

Referenced by te::vp::Dissolve::threadSave().

std::map< std::string, te::dt::AbstractData * > te::vp::GroupThreadManager::getSpecificParameters ( )

Definition at line 135 of file GroupThreadManager.cpp.

References m_specificParams.

Referenced by te::vp::Dissolve::threadUnion().

std::vector< std::string > te::vp::GroupThreadManager::getWarnings ( )

Definition at line 147 of file GroupThreadManager.cpp.

References m_warnings.

Referenced by te::vp::Dissolve::executeMemory().

const GroupThreadManager & te::vp::GroupThreadManager::operator= ( const GroupThreadManager &  )
private

Definition at line 190 of file GroupThreadManager.cpp.

Member Data Documentation

te::da::DataSet* te::vp::GroupThreadManager::m_dataSet
private

Definition at line 111 of file GroupThreadManager.h.

Referenced by getNextGroup().

te::da::DataSetType* te::vp::GroupThreadManager::m_dataSetType
private

Definition at line 112 of file GroupThreadManager.h.

Referenced by getDataSetType(), and getNextGroup().

std::map<std::string, std::vector<int> > te::vp::GroupThreadManager::m_groups
private

Definition at line 109 of file GroupThreadManager.h.

Referenced by getNextGroup(), getNextOutput(), and GroupThreadManager().

std::map<std::string, std::vector<int> >::iterator te::vp::GroupThreadManager::m_groupsIterator
private

Definition at line 120 of file GroupThreadManager.h.

Referenced by getNextGroup(), and GroupThreadManager().

boost::mutex te::vp::GroupThreadManager::m_mtx
private

Definition at line 127 of file GroupThreadManager.h.

Referenced by getNextGroup().

boost::mutex te::vp::GroupThreadManager::m_mtxOutput
private

Definition at line 128 of file GroupThreadManager.h.

Referenced by addOutput(), and getNextOutput().

boost::mutex te::vp::GroupThreadManager::m_mtxWarning
private

Definition at line 129 of file GroupThreadManager.h.

Referenced by addWarning().

te::mem::DataSet* te::vp::GroupThreadManager::m_outputDataSet
private

Definition at line 114 of file GroupThreadManager.h.

Referenced by createOutputItem(), and getClearOutputDataSet().

te::da::DataSetType* te::vp::GroupThreadManager::m_outputDataSetType
private

Definition at line 115 of file GroupThreadManager.h.

Referenced by getOutputDataSetType().

te::da::DataSource* te::vp::GroupThreadManager::m_outputDataSource
private

Definition at line 116 of file GroupThreadManager.h.

Referenced by getOutputDataSource().

std::vector< std::vector<te::mem::DataSetItem*> > te::vp::GroupThreadManager::m_outputQueue
private

Definition at line 122 of file GroupThreadManager.h.

Referenced by addOutput(), and getNextOutput().

std::size_t te::vp::GroupThreadManager::m_savedCount
private

Definition at line 110 of file GroupThreadManager.h.

Referenced by getNextOutput().

std::map<std::string, te::dt::AbstractData*> te::vp::GroupThreadManager::m_specificParams
private

Definition at line 118 of file GroupThreadManager.h.

Referenced by getSpecificParameters().

te::common::TaskProgress te::vp::GroupThreadManager::m_task
private

Definition at line 123 of file GroupThreadManager.h.

std::vector<std::string> te::vp::GroupThreadManager::m_warnings
private

Definition at line 125 of file GroupThreadManager.h.

Referenced by addWarning(), and getWarnings().

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