edm::service::AsyncService Class Reference

Inheritance diagram for edm::service::AsyncService:

Public Member Functions
	AsyncService (ParameterSet const &iConfig, ActivityRegistry &iRegistry)
Public Member Functions inherited from edm::Async
	Async ()=default
	Async (Async const &)=delete
	Async (Async &&)=delete
Async &	operator= (Async const &)=delete
Async &	operator= (Async &&)=delete
template<typename F , typename G >
void	runAsync (WaitingTaskWithArenaHolder holder, F &&func, G &&errorContextFunc)
virtual	~Async () noexcept

Static Public Member Functions
static void	fillDescriptions (ConfigurationDescriptions &descriptions)

Private Member Functions
void	ensureAllowed () const final

Private Attributes
std::atomic< bool >	allowed_ = true

Additional Inherited Members

Detailed Description

Definition at line 10 of file AsyncService.cc.

Constructor & Destructor Documentation

AsyncService()

edm::service::AsyncService::AsyncService	(	ParameterSet const &	iConfig,
		ActivityRegistry &	iRegistry
	)

Definition at line 22 of file AsyncService.cc.

References allowed_, edm::ActivityRegistry::watchPostEndJob(), edm::ActivityRegistry::watchPreGlobalEarlyTermination(), edm::ActivityRegistry::watchPreSourceEarlyTermination(), and edm::ActivityRegistry::watchPreStreamEarlyTermination().

                                                                                     {
    iRegistry.watchPreSourceEarlyTermination([this](TerminationOrigin) { allowed_ = false; });
    iRegistry.watchPreGlobalEarlyTermination([this](GlobalContext const&, TerminationOrigin) { allowed_ = false; });
    iRegistry.watchPreStreamEarlyTermination([this](StreamContext const&, TerminationOrigin) { allowed_ = false; });
    iRegistry.watchPostEndJob([this]() { allowed_ = false; });
  }

Member Function Documentation

ensureAllowed()

void edm::service::AsyncService::ensureAllowed ( ) const

finalprivatevirtual

Implements edm::Async.

Definition at line 34 of file AsyncService.cc.

References cms::Exception::addContext(), and allowed_.

                                         {
    if (not allowed_) {
      cms::Exception ex("AsyncCallNotAllowed");
      ex.addContext("Calling Async::run()");
      ex << "Framework is shutting down, further run() calls are not allowed";
      throw ex;
    }
  }

fillDescriptions()

void edm::service::AsyncService::fillDescriptions ( ConfigurationDescriptions &  descriptions )

static

Definition at line 29 of file AsyncService.cc.

References edm::ConfigurationDescriptions::addDefault(), and submitPVResolutionJobs::desc.

                                                                             {
    ParameterSetDescription desc;
    descriptions.addDefault(desc);
  }

Member Data Documentation

allowed_

std::atomic<bool> edm::service::AsyncService::allowed_ = true

private

Definition at line 19 of file AsyncService.cc.

Referenced by AsyncService(), and ensureAllowed().