rename fTask to fProcessorTask for clarity and to resemble fSamplerTask name

This commit is contained in:
Alexey Rybalchenko 2014-01-22 09:50:09 +01:00
parent 2a2b1b5d96
commit f2fe26e715
2 changed files with 6 additions and 6 deletions

View File

@ -12,25 +12,25 @@
#include "FairMQLogger.h" #include "FairMQLogger.h"
FairMQProcessor::FairMQProcessor() : FairMQProcessor::FairMQProcessor() :
fTask(NULL) fProcessorTask(NULL)
{ {
} }
FairMQProcessor::~FairMQProcessor() FairMQProcessor::~FairMQProcessor()
{ {
delete fTask; delete fProcessorTask;
} }
void FairMQProcessor::SetTask(FairMQProcessorTask* task) void FairMQProcessor::SetTask(FairMQProcessorTask* task)
{ {
fTask = task; fProcessorTask = task;
} }
void FairMQProcessor::Init() void FairMQProcessor::Init()
{ {
FairMQDevice::Init(); FairMQDevice::Init();
fTask->InitTask(); fProcessorTask->InitTask();
} }
void FairMQProcessor::Run() void FairMQProcessor::Run()
@ -51,7 +51,7 @@ void FairMQProcessor::Run()
receivedMsgs++; receivedMsgs++;
if (received) { if (received) {
fTask->Exec(msg, NULL); fProcessorTask->Exec(msg, NULL);
fPayloadOutputs->at(0)->Send(msg); fPayloadOutputs->at(0)->Send(msg);
sentMsgs++; sentMsgs++;

View File

@ -22,7 +22,7 @@ class FairMQProcessor: public FairMQDevice
virtual void Init(); virtual void Init();
virtual void Run(); virtual void Run();
private: private:
FairMQProcessorTask* fTask; FairMQProcessorTask* fProcessorTask;
}; };
#endif /* FAIRMQPROCESSOR_H_ */ #endif /* FAIRMQPROCESSOR_H_ */