Files
Sourcetrail/src/lib/utility/scheduling/TaskGroupSequence.cpp
T
mlangkabel a1dd1a77c9 logic: allow the user to discard an aborted indexer run
* keep old database on filesystem while indexing
* migrate old ".coatiproject" settings to new ".srctrlprj" extension when loading project
* send new errors in MessageErrorCountUpdate after injecting
* recheck filepath exist() in FileSystem's remove, rename, copy and create functions
* updated tasks to new "override" policy
2018-07-03 18:54:53 +02:00

65 lines
1.1 KiB
C++

#include "utility/scheduling/TaskGroupSequence.h"
TaskGroupSequence::TaskGroupSequence()
{
}
void TaskGroupSequence::addTask(std::shared_ptr<Task> task)
{
m_taskRunners.push_back(std::make_shared<TaskRunner>(task));
}
void TaskGroupSequence::doEnter(std::shared_ptr<Blackboard> blackboard)
{
m_taskIndex = 0;
}
Task::TaskState TaskGroupSequence::doUpdate(std::shared_ptr<Blackboard> blackboard)
{
if (m_taskIndex >= int(m_taskRunners.size()))
{
return STATE_SUCCESS;
}
else if (m_taskIndex < 0)
{
return STATE_FAILURE;
}
TaskState state = m_taskRunners[m_taskIndex]->update(blackboard);
if (state == STATE_SUCCESS)
{
m_taskIndex++;
}
else if (state == STATE_FAILURE)
{
m_taskIndex = -1;
}
else if (state == STATE_HOLD)
{
return STATE_HOLD;
}
return STATE_RUNNING;
}
void TaskGroupSequence::doExit(std::shared_ptr<Blackboard> blackboard)
{
}
void TaskGroupSequence::doReset(std::shared_ptr<Blackboard> blackboard)
{
for (size_t i = 0; i < m_taskRunners.size(); i++)
{
m_taskRunners[i]->reset();
}
}
void TaskGroupSequence::doTerminate()
{
for (size_t i = 0; i < m_taskRunners.size(); i++)
{
m_taskRunners[i]->terminate();
}
}