salsa  0.3.0
 All Classes Functions Variables Enumerations Pages
TaskExecutorFake.cc
1 #include "TaskExecutorFake.hh"
2 #include <TaskPool.hh>
3 namespace Salsa {
4 TaskExecutorFake::TaskExecutorFake(TaskPool * pTaskPool) : TaskExecutor(), mpTaskPool(pTaskPool)
5 {
9 }
11 {
15  delete mpPointer;
16 }
17 bool 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::State::running);
27  return true;
28 }
29 bool 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 }
41 void * TaskExecutorFake::pipe() const
42 {
46  return mpPointer;
47 }
48 
49 } // namespace Salsa
TaskPool * mpTaskPool
Fake pointer.
bool handlePipe(void *pPipe)
Definition: TaskPool.cc:142
void state(State s)
Definition: TaskState.cc:35
std::string mUpstream
Upstream.
TaskState * mpTaskState
Task state.
Definition: TaskExecutor.hh:31
virtual void * pipe() const
TaskExecutorFake(TaskPool *pTP)
virtual bool run(std::string, std::string)
Run task.
std::string mWorker
Worker.
Base TaskExecutor class.
Definition: TaskExecutor.hh:14
virtual bool handlePipe(std::vector< std::string > &extra)
Handle pipe.
Base salsa TaskPool class.
Definition: TaskPool.hh:18
Object * mpPointer
Fake pointer.