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 ()
void	throttledCheck ()
	~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 44 of file GlobalEvFOutputModule.cc.

Constructor & Destructor Documentation

GlobalEvFOutputEventWriter()

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

inlineexplicit

Definition at line 46 of file GlobalEvFOutputModule.cc.

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

~GlobalEvFOutputEventWriter()

evf::GlobalEvFOutputEventWriter::~GlobalEvFOutputEventWriter ( )

inline

Definition at line 49 of file GlobalEvFOutputModule.cc.

{}

Member Function Documentation

close()

void evf::GlobalEvFOutputEventWriter::close ( void  )

inline

Definition at line 51 of file GlobalEvFOutputModule.cc.

References stream_writer_events_.

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

{ stream_writer_events_->close(); }

doOutputEvent()

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

inline

Definition at line 53 of file GlobalEvFOutputModule.cc.

References incAccepted(), mps_check::msg, and stream_writer_events_.

Referenced by doOutputEventAsync().

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

doOutputEventAsync()

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

inline

Definition at line 59 of file GlobalEvFOutputModule.cc.

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

                                                                                              {
      throttledCheck();
      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());
        }
      });
    }

get_adler32()

uint32 evf::GlobalEvFOutputEventWriter::get_adler32 ( ) const

inline

Definition at line 85 of file GlobalEvFOutputModule.cc.

References stream_writer_events_.

{ return stream_writer_events_->adler32(); }

getAccepted()

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

inline

Definition at line 89 of file GlobalEvFOutputModule.cc.

References accepted_.

{ return accepted_; }

getFilePath()

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

inline

Definition at line 87 of file GlobalEvFOutputModule.cc.

References filePath_.

{ return filePath_; }

incAccepted()

void evf::GlobalEvFOutputEventWriter::incAccepted ( )

inline

Definition at line 90 of file GlobalEvFOutputModule.cc.

References accepted_.

Referenced by doOutputEvent().

{ accepted_++; }

queue()

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

inline

Definition at line 92 of file GlobalEvFOutputModule.cc.

References writeQueue_.

{ return writeQueue_; }

throttledCheck()

void evf::GlobalEvFOutputEventWriter::throttledCheck ( )

inline

Definition at line 73 of file GlobalEvFOutputModule.cc.

References svgfig::load(), and edm::shutdown_flag.

Referenced by doOutputEventAsync().

                                 {
      unsigned int counter = 0;
      while (edm::Service<evf::EvFDaqDirector>()->inputThrottled()) {
        if (edm::shutdown_flag.load(std::memory_order_relaxed))
          break;
        if (!(counter % 100))
          edm::LogWarning("FedRawDataInputSource") << "Input throttled detected, writing is paused...";
        usleep(100000);
        counter++;
      }
    }

Member Data Documentation

accepted_

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

private

Definition at line 96 of file GlobalEvFOutputModule.cc.

Referenced by getAccepted(), and incAccepted().

filePath_

std::string evf::GlobalEvFOutputEventWriter::filePath_

private

Definition at line 95 of file GlobalEvFOutputModule.cc.

Referenced by getFilePath().

stream_writer_events_

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

private

Definition at line 97 of file GlobalEvFOutputModule.cc.

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

writeQueue_

edm::SerialTaskQueue evf::GlobalEvFOutputEventWriter::writeQueue_

private

Definition at line 98 of file GlobalEvFOutputModule.cc.

Referenced by doOutputEventAsync(), and queue().