evf::GlobalEvFOutputEventWriter Class Reference

Public Member Functions
void	close ()
void	doOutputEvent (EventMsgBuilder const &msg)
void	doOutputEventAsync (std::unique_ptr< EventMsgBuilder > msg, edm::WaitingTaskHolder iHolder)
uint32	get_adler32 () const
unsigned long	getAccepted () const
std::string const &	getFilePath () const
	GlobalEvFOutputEventWriter (std::string const &filePath)
void	incAccepted ()
edm::SerialTaskQueue &	queue ()
	~GlobalEvFOutputEventWriter ()

Private Attributes
std::atomic< unsigned long >	accepted_
std::string	filePath_
edm::propagate_const < std::unique_ptr < StreamerOutputFile > >	stream_writer_events_
edm::SerialTaskQueue	writeQueue_

Detailed Description

Definition at line 43 of file GlobalEvFOutputModule.cc.

Constructor & Destructor Documentation

evf::GlobalEvFOutputEventWriter::GlobalEvFOutputEventWriter ( std::string const &  filePath )

inlineexplicit

Definition at line 45 of file GlobalEvFOutputModule.cc.

        : filePath_(filePath), accepted_(0), stream_writer_events_(new StreamerOutputFile(filePath)) {}

evf::GlobalEvFOutputEventWriter::~GlobalEvFOutputEventWriter ( )

inline

Definition at line 48 of file GlobalEvFOutputModule.cc.

{}

Member Function Documentation

void evf::GlobalEvFOutputEventWriter::close ( void  )

inline

Definition at line 50 of file GlobalEvFOutputModule.cc.

References stream_writer_events_.

Referenced by esMonitoring.AsyncLineReaderMixin::handle_close(), and esMonitoring.FDJsonServer::handle_close().

{ stream_writer_events_->close(); }

void evf::GlobalEvFOutputEventWriter::doOutputEvent ( EventMsgBuilder const &  msg )

inline

Definition at line 52 of file GlobalEvFOutputModule.cc.

References incAccepted(), EventMsgBuilder::startAddress(), and stream_writer_events_.

Referenced by doOutputEventAsync().

                                                   {
      EventMsgView eview(msg.startAddress());
      stream_writer_events_->write(eview);
      incAccepted();
    }

void evf::GlobalEvFOutputEventWriter::doOutputEventAsync ( std::unique_ptr< EventMsgBuilder >  msg, edm::WaitingTaskHolder  iHolder  )

inline

Definition at line 58 of file GlobalEvFOutputModule.cc.

References doOutputEvent(), edm::WaitingTaskHolder::group(), watchdog::group, eostools::move(), edm::SerialTaskQueue::push(), createJobs::tmp, and writeQueue_.

                                                                                              {
      auto group = iHolder.group();
      writeQueue_.push(*group, [holder = std::move(iHolder), msg = msg.release(), this]() {
        try {
          std::unique_ptr<EventMsgBuilder> own(msg);
          doOutputEvent(*msg);  //msg is written and discarded at this point
        } catch (...) {
          auto tmp = holder;
          tmp.doneWaiting(std::current_exception());
        }
      });
    }

uint32 evf::GlobalEvFOutputEventWriter::get_adler32 ( ) const

inline

Definition at line 71 of file GlobalEvFOutputModule.cc.

References stream_writer_events_.

{ return stream_writer_events_->adler32(); }

unsigned long evf::GlobalEvFOutputEventWriter::getAccepted ( ) const

inline

Definition at line 75 of file GlobalEvFOutputModule.cc.

References accepted_.

{ return accepted_; }

std::string const& evf::GlobalEvFOutputEventWriter::getFilePath ( ) const

inline

Definition at line 73 of file GlobalEvFOutputModule.cc.

References filePath_.

{ return filePath_; }

void evf::GlobalEvFOutputEventWriter::incAccepted ( )

inline

Definition at line 76 of file GlobalEvFOutputModule.cc.

References accepted_.

Referenced by doOutputEvent().

{ accepted_++; }

edm::SerialTaskQueue& evf::GlobalEvFOutputEventWriter::queue ( )

inline

Definition at line 78 of file GlobalEvFOutputModule.cc.

References writeQueue_.

{ return writeQueue_; }

Member Data Documentation

std::atomic<unsigned long> evf::GlobalEvFOutputEventWriter::accepted_

private

Definition at line 82 of file GlobalEvFOutputModule.cc.

Referenced by getAccepted(), and incAccepted().

std::string evf::GlobalEvFOutputEventWriter::filePath_

private

Definition at line 81 of file GlobalEvFOutputModule.cc.

Referenced by getFilePath().

edm::propagate_const<std::unique_ptr<StreamerOutputFile> > evf::GlobalEvFOutputEventWriter::stream_writer_events_

private

Definition at line 83 of file GlobalEvFOutputModule.cc.

Referenced by close(), doOutputEvent(), and get_adler32().

edm::SerialTaskQueue evf::GlobalEvFOutputEventWriter::writeQueue_

private

Definition at line 84 of file GlobalEvFOutputModule.cc.

Referenced by doOutputEventAsync(), and queue().