evf::GlobalEvFOutputEventWriter Class Reference

Public Member Functions
bool	close ()
void	discardedCheck ()
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, unsigned int ls)
void	incAccepted ()
edm::SerialTaskQueue &	queue ()
void	throttledCheck ()
	~GlobalEvFOutputEventWriter ()

Private Attributes
std::atomic< unsigned long >	accepted_
bool	discarded_ = false
std::string	filePath_
const unsigned	ls_
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, unsigned int  ls  )

inlineexplicit

Definition at line 46 of file GlobalEvFOutputModule.cc.

        : filePath_(filePath), ls_(ls), 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()

bool evf::GlobalEvFOutputEventWriter::close ( void  )

inline

Definition at line 51 of file GlobalEvFOutputModule.cc.

References discarded_, ls_, and stream_writer_events_.

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 98 of file GlobalEvFOutputModule.cc.

References discarded_, and ls_.

Referenced by doOutputEventAsync().

                                 {
      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 )

inline

Definition at line 56 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 62 of file GlobalEvFOutputModule.cc.

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

                                                                                              {
      throttledCheck();
      discardedCheck();
      if (discarded_) {
        incAccepted();
        msg.reset();
        return;
      }
      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 105 of file GlobalEvFOutputModule.cc.

References stream_writer_events_.

{ return stream_writer_events_->adler32(); }

getAccepted()

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

inline

Definition at line 109 of file GlobalEvFOutputModule.cc.

References accepted_.

{ return accepted_; }

getFilePath()

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

inline

Definition at line 107 of file GlobalEvFOutputModule.cc.

References filePath_.

{ return filePath_; }

incAccepted()

void evf::GlobalEvFOutputEventWriter::incAccepted ( )

inline

Definition at line 110 of file GlobalEvFOutputModule.cc.

References accepted_.

Referenced by doOutputEvent(), and doOutputEventAsync().

{ accepted_++; }

queue()

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

inline

Definition at line 112 of file GlobalEvFOutputModule.cc.

References writeQueue_.

{ return writeQueue_; }

throttledCheck()

void evf::GlobalEvFOutputEventWriter::throttledCheck ( )

inline

Definition at line 82 of file GlobalEvFOutputModule.cc.

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

Referenced by doOutputEventAsync().

                                 {
      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 117 of file GlobalEvFOutputModule.cc.

Referenced by getAccepted(), and incAccepted().

discarded_

bool evf::GlobalEvFOutputEventWriter::discarded_ = false

private

Definition at line 120 of file GlobalEvFOutputModule.cc.

Referenced by close(), discardedCheck(), doOutputEventAsync(), and throttledCheck().

filePath_

std::string evf::GlobalEvFOutputEventWriter::filePath_

private

Definition at line 115 of file GlobalEvFOutputModule.cc.

Referenced by getFilePath().

ls_

const unsigned evf::GlobalEvFOutputEventWriter::ls_

private

Definition at line 116 of file GlobalEvFOutputModule.cc.

Referenced by close(), discardedCheck(), and throttledCheck().

stream_writer_events_

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

private

Definition at line 118 of file GlobalEvFOutputModule.cc.

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

writeQueue_

edm::SerialTaskQueue evf::GlobalEvFOutputEventWriter::writeQueue_

private

Definition at line 119 of file GlobalEvFOutputModule.cc.

Referenced by doOutputEventAsync(), and queue().