addResult(std::shared_ptr< U > result) | htgs::TaskManager< T, U > | inline |
AnyTaskManager(size_t numThreads, bool isStartTask, size_t pipelineId, size_t numPipelines, std::string address) | htgs::AnyTaskManager | inline |
AnyTaskManager(size_t numThreads, bool isStartTask, bool poll, size_t microTimeoutTime, size_t pipelineId, size_t numPipelines, std::string address) | htgs::AnyTaskManager | inline |
copy(bool deep) override | htgs::TaskManager< T, U > | inlinevirtual |
debug() | htgs::AnyTaskManager | inline |
executeTask() override | htgs::TaskManager< T, U > | inlinevirtual |
gatherProfileData(std::map< AnyTaskManager *, TaskManagerProfile *> *taskManagerProfiles) override | htgs::TaskManager< T, U > | inlinevirtual |
getAddress() | htgs::AnyTaskManager | inline |
getComputeTime() | htgs::AnyTaskManager | inline |
getDot(int flags) | htgs::AnyTaskManager | inline |
getExecuteTime() | htgs::AnyTaskManager | inline |
getInputConnector() override | htgs::TaskManager< T, U > | inlinevirtual |
getMaxQueueSize() | htgs::AnyTaskManager | inline |
getName() | htgs::AnyTaskManager | inline |
getNameWithPipelineId() | htgs::AnyTaskManager | inline |
getNumPipelines() | htgs::AnyTaskManager | inline |
getNumThreads() const | htgs::AnyTaskManager | inline |
getOutputConnector() override | htgs::TaskManager< T, U > | inlinevirtual |
getPipelineId() | htgs::AnyTaskManager | inline |
getTaskComputeTime() | htgs::AnyTaskManager | inline |
getTaskFunction() override | htgs::TaskManager< T, U > | inlinevirtual |
getThreadId() | htgs::AnyTaskManager | inline |
getThreadsRemaining() override | htgs::TaskManager< T, U > | inlinevirtual |
getTimeout() | htgs::AnyTaskManager | inline |
getWaitTime() | htgs::AnyTaskManager | inline |
incTaskComputeTime(int64_t val) | htgs::AnyTaskManager | inline |
incWaitTime(int64_t val) | htgs::AnyTaskManager | inline |
initialize() override | htgs::TaskManager< T, U > | inlinevirtual |
inputConnector | htgs::TaskManager< T, U > | private |
isAlive() | htgs::AnyTaskManager | inline |
isInitialized() | htgs::AnyTaskManager | inline |
isPoll() | htgs::AnyTaskManager | inline |
isStartTask() | htgs::AnyTaskManager | inline |
outputConnector | htgs::TaskManager< T, U > | private |
printProfile() | htgs::AnyTaskManager | inline |
resetProfile() | htgs::AnyTaskManager | inline |
runtimeThread | htgs::TaskManager< T, U > | private |
setAlive(bool val) | htgs::AnyTaskManager | inline |
setInitialized(bool val) | htgs::AnyTaskManager | inline |
setInputConnector(std::shared_ptr< AnyConnector > connector) override | htgs::TaskManager< T, U > | inlinevirtual |
setNumPipelines(size_t numPipelines) | htgs::AnyTaskManager | inline |
setOutputConnector(std::shared_ptr< AnyConnector > connector) override | htgs::TaskManager< T, U > | inlinevirtual |
setPipelineId(size_t id) | htgs::AnyTaskManager | inline |
setRuntimeThread(TaskManagerThread *runtimeThread) override | htgs::TaskManager< T, U > | inlinevirtual |
setStartTask(bool val) | htgs::AnyTaskManager | inline |
setThreadId(size_t id) | htgs::AnyTaskManager | inline |
shutdown() | htgs::AnyTaskManager | inline |
taskFunction | htgs::TaskManager< T, U > | private |
TaskManager(ITask< T, U > *taskFunction, size_t numThreads, bool isStartTask, size_t pipelineId, size_t numPipelines, std::string address) | htgs::TaskManager< T, U > | inline |
TaskManager(ITask< T, U > *taskFunction, size_t numThreads, bool isStartTask, bool poll, size_t microTimeoutTime, size_t pipelineId, size_t numPipelines, std::string address) | htgs::TaskManager< T, U > | inline |
terminateConnections() override | htgs::TaskManager< T, U > | inlinevirtual |
updateAddressAndPipelines(std::string address, size_t pipelineId, size_t numPipelines) | htgs::AnyTaskManager | inline |
~AnyTaskManager() | htgs::AnyTaskManager | inlinevirtual |
~TaskManager() override (defined in htgs::TaskManager< T, U >) | htgs::TaskManager< T, U > | inline |