evf::GlobalEvFOutputEventWriter Class Reference

Public Member Functions
bool	close ()
void	discardedCheck ()
void	doOutputEvent (EventMsgBuilder const &msg, bool inc)
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, unsigned int ls, std::shared_ptr< MetaDataCache const > iMetaData)
void	incAccepted ()
edm::SerialTaskQueue &	queue ()
void	setMetaCache (std::shared_ptr< MetaDataCache const > iMetaData)
void	throttledCheck ()
	~GlobalEvFOutputEventWriter ()

Private Attributes
std::atomic< unsigned long >	accepted_
bool	discarded_ = false
std::string	filePath_
const unsigned	ls_
std::shared_ptr< MetaDataCache const >	meta_
edm::propagate_const< std::unique_ptr< StreamerOutputFile > >	stream_writer_events_
edm::SerialTaskQueue	writeQueue_

Detailed Description

Definition at line 59 of file GlobalEvFOutputModule.cc.

Constructor & Destructor Documentation

GlobalEvFOutputEventWriter()

evf::GlobalEvFOutputEventWriter::GlobalEvFOutputEventWriter ( std::string const &  filePath, unsigned int  ls, std::shared_ptr< MetaDataCache const >  iMetaData  )

inlineexplicit

Definition at line 61 of file GlobalEvFOutputModule.cc.

        : filePath_(filePath),
          ls_(ls),
          accepted_(0),
          stream_writer_events_(new StreamerOutputFile(filePath)),
          meta_(std::move(iMetaData)) {}

~GlobalEvFOutputEventWriter()

evf::GlobalEvFOutputEventWriter::~GlobalEvFOutputEventWriter ( )

inline

Definition at line 70 of file GlobalEvFOutputModule.cc.

{}

Member Function Documentation

close()

bool evf::GlobalEvFOutputEventWriter::close ( void  )

inline

Definition at line 74 of file GlobalEvFOutputModule.cc.

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

                 {
      stream_writer_events_->close();
      return (discarded_ || edm::Service<evf::EvFDaqDirector>()->lumisectionDiscarded(ls_));
    }

discardedCheck()

void evf::GlobalEvFOutputEventWriter::discardedCheck ( )

inline

Definition at line 127 of file GlobalEvFOutputModule.cc.

                                 {
      if (!discarded_ && edm::Service<evf::EvFDaqDirector>()->lumisectionDiscarded(ls_)) {
        edm::LogWarning("FedRawDataInputSource") << "Detected that the lumisection is discarded -: " << ls_;
        discarded_ = true;
      }
    }

doOutputEvent()

void evf::GlobalEvFOutputEventWriter::doOutputEvent ( EventMsgBuilder const &  msg, bool  inc  )

inline

Definition at line 79 of file GlobalEvFOutputModule.cc.

References mps_check::msg.

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

doOutputEventAsync()

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

inline

Definition at line 86 of file GlobalEvFOutputModule.cc.

References cms::cuda::assert(), edm::WaitingTaskHolder::group(), watchdog::group, visualization-live-secondInstance_cfg::m, eostools::move(), mps_check::msg, and createJobs::tmp.

                                                                                              {
      throttledCheck();
      discardedCheck();
      if (discarded_) {
        incAccepted();
        msg.reset();
        return;
      }
      auto group = iHolder.group();
      writeQueue_.push(*group, [holder = std::move(iHolder), msg = msg.release(), this]() mutable {
        try {
          std::unique_ptr<EventMsgBuilder> own(msg);
          if (meta_) {
            auto m = std::move(meta_);
            assert(m->builder_);
            doOutputEvent(*m->builder_, false);
          }
          doOutputEvent(*msg, true);  //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 134 of file GlobalEvFOutputModule.cc.

{ return stream_writer_events_->adler32(); }

getAccepted()

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

inline

Definition at line 138 of file GlobalEvFOutputModule.cc.

{ return accepted_; }

getFilePath()

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

inline

Definition at line 136 of file GlobalEvFOutputModule.cc.

{ return filePath_; }

incAccepted()

void evf::GlobalEvFOutputEventWriter::incAccepted ( )

inline

Definition at line 139 of file GlobalEvFOutputModule.cc.

{ accepted_++; }

queue()

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

inline

Definition at line 141 of file GlobalEvFOutputModule.cc.

{ return writeQueue_; }

setMetaCache()

void evf::GlobalEvFOutputEventWriter::setMetaCache ( std::shared_ptr< MetaDataCache const >  iMetaData )

inline

Definition at line 72 of file GlobalEvFOutputModule.cc.

References eostools::move().

{ meta_ = std::move(iMetaData); }

throttledCheck()

void evf::GlobalEvFOutputEventWriter::throttledCheck ( )

inline

Definition at line 111 of file GlobalEvFOutputModule.cc.

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

                                 {
      unsigned int counter = 0;
      while (edm::Service<evf::EvFDaqDirector>()->inputThrottled() && !discarded_) {
        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++;
        if (edm::Service<evf::EvFDaqDirector>()->lumisectionDiscarded(ls_)) {
          edm::LogWarning("FedRawDataInputSource") << "Detected that the lumisection is discarded -: " << ls_;
          discarded_ = true;
        }
      }
    }

Member Data Documentation

accepted_

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

private

Definition at line 146 of file GlobalEvFOutputModule.cc.

discarded_

bool evf::GlobalEvFOutputEventWriter::discarded_ = false

private

Definition at line 150 of file GlobalEvFOutputModule.cc.

filePath_

std::string evf::GlobalEvFOutputEventWriter::filePath_

private

Definition at line 144 of file GlobalEvFOutputModule.cc.

ls_

const unsigned evf::GlobalEvFOutputEventWriter::ls_

private

Definition at line 145 of file GlobalEvFOutputModule.cc.

meta_

std::shared_ptr<MetaDataCache const> evf::GlobalEvFOutputEventWriter::meta_

private

Definition at line 148 of file GlobalEvFOutputModule.cc.

stream_writer_events_

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

private

Definition at line 147 of file GlobalEvFOutputModule.cc.

writeQueue_

edm::SerialTaskQueue evf::GlobalEvFOutputEventWriter::writeQueue_

private

Definition at line 149 of file GlobalEvFOutputModule.cc.