HTGS  v2.0
The Hybrid Task Graph Scheduler
htgs::ExecutionPipeline< T, U > Member List

This is the complete list of members for htgs::ExecutionPipeline< T, U >, including all inherited members.

addInputRule(IRule< T, T > *rule)htgs::ExecutionPipeline< T, U >inline
addInputRule(std::shared_ptr< IRule< T, T >> rule)htgs::ExecutionPipeline< T, U >inline
addResult(std::shared_ptr< U > result)htgs::ITask< T, U >inline
addResult(U *result)htgs::ITask< T, U >inline
AnyITask()htgs::AnyITaskinline
AnyITask(size_t numThreads)htgs::AnyITaskinline
AnyITask(size_t numThreads, bool isStartTask, bool poll, size_t microTimeoutTime)htgs::AnyITaskinline
attachMemoryEdge(std::string name, std::shared_ptr< AnyConnector > getMemoryConnector, std::shared_ptr< AnyConnector > releaseMemoryConnector, MMType type)htgs::AnyITaskinline
canTerminate(std::shared_ptr< AnyConnector > inputConnector) overridehtgs::ITask< T, U >inlinevirtual
cleanupVisualization(TaskGraphConf< T, U > *graph, std::string str)htgs::ExecutionPipeline< T, U >inlineprivate
copy()htgs::ExecutionPipeline< T, U >inlinevirtual
copyITask(bool deep) overridehtgs::ITask< T, U >inlinevirtual
copyMemoryEdges(AnyITask *iTaskCopy)htgs::AnyITaskinline
debug()htgs::ExecutionPipeline< T, U >inlinevirtual
debugDotNode()htgs::AnyITaskinlinevirtual
executeTask(std::shared_ptr< T > data)htgs::ExecutionPipeline< T, U >inlinevirtual
executeTaskFinal() overridehtgs::ITask< T, U >inlinevirtual
ExecutionPipeline(size_t numPipelines, TaskGraphConf< T, U > *graph, std::string name="Execution Pipeline", bool waitForInit=true)htgs::ExecutionPipeline< T, U >inline
ExecutionPipeline(size_t numPipelines, TaskGraphConf< T, U > *graph, std::shared_ptr< IRuleList< T, T >> rules, std::string name="Execution Pipeline", bool waitForInit=true)htgs::ExecutionPipeline< T, U >inline
gatherProfileData(std::map< AnyTaskManager *, TaskManagerProfile *> *taskManagerProfiles) overridehtgs::ExecutionPipeline< T, U >inlinevirtual
genCustomDot(ProfileUtils *profileUtils, int colorFlag) overridehtgs::ExecutionPipeline< T, U >inlinevirtual
genDot(int flags, std::string dotId, std::shared_ptr< AnyConnector > input, std::shared_ptr< AnyConnector > output) overridehtgs::ExecutionPipeline< T, U >inline
htgs::ITask::genDot(int flags, std::string dotId, std::shared_ptr< htgs::AnyConnector > input, std::shared_ptr< htgs::AnyConnector > output)htgs::AnyITaskinlinevirtual
htgs::ITask::genDot(int flags, std::string dotId)htgs::AnyITaskinlinevirtual
htgs::ITask::genDot(int flags, std::shared_ptr< AnyConnector > input, std::shared_ptr< AnyConnector > output)htgs::AnyITaskinline
genDotConsumerEdgeFromConnector(std::shared_ptr< AnyConnector > connector, int flags) override (defined in htgs::ExecutionPipeline< T, U >)htgs::ExecutionPipeline< T, U >inlinevirtual
genDotProducerEdgeFromConnector(std::shared_ptr< AnyConnector > connector, int flags) (defined in htgs::ExecutionPipeline< T, U >)htgs::ExecutionPipeline< T, U >inlinevirtual
genDotProducerEdgeToTask(std::map< std::shared_ptr< AnyConnector >, AnyITask *> &inputConnectorDotMap, int dotFlags) override (defined in htgs::ExecutionPipeline< T, U >)htgs::ExecutionPipeline< T, U >inlinevirtual
getAddress() override finalhtgs::ITask< T, U >inlinevirtual
getConsumerDotIds() override (defined in htgs::ExecutionPipeline< T, U >)htgs::ExecutionPipeline< T, U >inlinevirtual
getDotCustomProfile() overridehtgs::ITask< T, U >inlinevirtual
getDotFillColor() overridehtgs::ITask< T, U >inlinevirtual
getDotId()htgs::AnyITaskinline
getDotLabelName() overridehtgs::ITask< T, U >inlinevirtual
getDotShape() overridehtgs::ITask< T, U >inlinevirtual
getDotShapeColor() overridehtgs::ITask< T, U >inlinevirtual
getDynamicMemory(std::string name, IMemoryReleaseRule *releaseRule, size_t numElems)htgs::ITask< T, U >inline
getMemory(std::string name, IMemoryReleaseRule *releaseRule)htgs::ITask< T, U >inline
getMemoryEdges() consthtgs::AnyITaskinline
getMemoryWaitTime() consthtgs::AnyITaskinline
getMicroTimeoutTime() consthtgs::AnyITaskinline
getName()htgs::ExecutionPipeline< T, U >inlinevirtual
getNameWithPipelineId()htgs::AnyITaskinline
getNumGraphsSpawned() overridehtgs::ExecutionPipeline< T, U >inlinevirtual
getNumPipelines() consthtgs::AnyITaskinline
getNumThreads() consthtgs::AnyITaskinline
getOwnerTaskManager()htgs::ITask< T, U >inline
getPipelineId()htgs::AnyITaskinline
getProducerDotIds() (defined in htgs::AnyITask)htgs::AnyITaskinlinevirtual
getReleaseMemoryEdges() consthtgs::AnyITaskinline
getTaskComputeTime() consthtgs::ITask< T, U >inline
getThreadID()htgs::ITask< T, U >inline
graphhtgs::ExecutionPipeline< T, U >private
graphshtgs::ExecutionPipeline< T, U >private
hasMemoryEdge(std::string name)htgs::AnyITaskinline
incMemoryWaitTime(unsigned long long int val)htgs::AnyITaskinline
initialize()htgs::ExecutionPipeline< T, U >inlinevirtual
htgs::ITask::initialize(size_t pipelineId, size_t numPipeline, TaskManager< T, U > *ownerTask)htgs::ITask< T, U >inline
htgs::AnyITask::initialize(size_t pipelineId, size_t numPipeline)htgs::AnyITaskinline
inputBkhtgs::ExecutionPipeline< T, U >private
inputRuleshtgs::ExecutionPipeline< T, U >private
inTypeName() override finalhtgs::ITask< T, U >inlinevirtual
isPoll() consthtgs::AnyITaskinline
isStartTask() consthtgs::AnyITaskinline
ITask()htgs::ITask< T, U >inline
ITask(size_t numThreads)htgs::ITask< T, U >inline
ITask(size_t numThreads, bool isStartTask, bool poll, size_t microTimeoutTime)htgs::ITask< T, U >inline
namehtgs::ExecutionPipeline< T, U >private
numPipelinesExechtgs::ExecutionPipeline< T, U >private
outTypeName() override finalhtgs::ITask< T, U >inlinevirtual
printProfile() overridehtgs::ExecutionPipeline< T, U >inlinevirtual
profile()htgs::AnyITaskinlinevirtual
profileITask()htgs::AnyITaskinline
profileStr()htgs::AnyITaskinlinevirtual
releaseMemory(m_data_t< V > memory)htgs::ITask< T, U >inline
resetProfile()htgs::ITask< T, U >inline
runtimeshtgs::ExecutionPipeline< T, U >private
setNumPipelines(size_t numPipelines)htgs::AnyITaskinline
setPipelineId(size_t pipelineId)htgs::AnyITaskinline
setTaskManager(TaskManager< T, U > *ownerTask)htgs::ITask< T, U >inline
shutdown()htgs::ExecutionPipeline< T, U >inlinevirtual
shutdownParallel(int id)htgs::ExecutionPipeline< T, U >inline
waitForInithtgs::ExecutionPipeline< T, U >private
~AnyITask()htgs::AnyITaskinlinevirtual
~ExecutionPipeline()htgs::ExecutionPipeline< T, U >inline
~ITask() override (defined in htgs::ITask< T, U >)htgs::ITask< T, U >inlinevirtual