salsa 0.7.1
Loading...
Searching...
No Matches
TaskExecutorFake.cc
1#include "TaskExecutorFake.hh"
2#include "TaskPool.hh"
3namespace Salsa {
4TaskExecutorFake::TaskExecutorFake(TaskPool * pTaskPool) : TaskExecutor(), mpTaskPool(pTaskPool)
5{
9}
17bool TaskExecutorFake::run(std::string worker, std::string upstream)
18{
22 mWorker = worker;
23 mUpstream = upstream;
24 SPD_DEBUG("Running fake task worker [{}] upstream [{}]", mWorker, mUpstream);
25 mpTaskState->state(TaskState::EState::running);
27 return true;
28}
29bool TaskExecutorFake::handlePipe(std::vector<std::string> & extra)
30{
34
35 SPD_DEBUG("Handling pipe for fake task worker [{}] upstream [{}]", mWorker, mUpstream);
36 extra.push_back(mWorker);
37 extra.push_back(mUpstream);
38
39 return true;
40}
42{
46 return mpPointer;
47}
48
49} // namespace Salsa
virtual bool run(std::string, std::string)
Run task.
virtual void * pipe() const
TaskExecutorFake(TaskPool *pTP)
TaskPool * mpTaskPool
Fake pointer.
std::string mWorker
Worker.
Object * mpPointer
Fake pointer.
virtual bool handlePipe(std::vector< std::string > &extra)
Handle pipe.
std::string mUpstream
Upstream.
Base TaskExecutor class.
TaskState * mpTaskState
Task state.
Base salsa TaskPool class.
Definition TaskPool.hh:18
bool handlePipe(void *pPipe)
Definition TaskPool.cc:142
void state(EState s)
Definition TaskState.cc:36