1 #ifndef FACT_DataProcessorImp 2 #define FACT_DataProcessorImp 23 return fMsg.Write(time, txt,
qos);
31 DataProcessorImp(
const std::string &path, uint64_t night, uint32_t
id,
MessageImp &imp) : fPath(path), fNight(night), fRunId(id), fMsg(imp) { }
34 virtual bool Open(
const RUN_HEAD &h,
const FAD::RunDescription &desc) = 0;
35 virtual bool WriteEvt(
const EVT_CTRL2 &) = 0;
36 virtual bool Close(
const EVT_CTRL2 &) = 0;
40 std::string
GetPath()
const {
return fPath; }
44 static std::string FormFileName(
const std::string &path, uint64_t night, uint32_t runid,
const std::string &extension);
47 return FormFileName(fPath, fNight, fRunId, extension);
60 bool Open(
const RUN_HEAD &h,
const FAD::RunDescription &d);
std::string FormFileName(const std::string &extension)
The base implementation of a distributed messaging system.
Adds some functionality to boost::posix_time::ptime for our needs.
uint32_t GetRunId() const
std::string GetPath() const
DataDebug(const std::string &path, uint64_t night, uint32_t id, MessageImp &imp)
DataDump(const std::string &path, uint64_t night, uint32_t id, MessageImp &imp)
Warning because the service this data corrsponds to might have been last updated longer ago than Local time
uint32_t GetNight() const
virtual ~DataProcessorImp()
DataProcessorImp(const std::string &path, uint64_t night, uint32_t id, MessageImp &imp)
int Write(const Time &time, const std::string &txt, int qos=kMessage)
const std::string & GetFileName() const