SonicClientBase Class Reference

#include <SonicClientBase.h>

Inheritance diagram for SonicClientBase:

Public Member Functions
const std::string &	clientName () const
const std::string &	debugName () const
virtual void	dispatch ()
virtual void	dispatch (edm::WaitingTaskWithArenaHolder holder)
SonicMode	mode () const
virtual void	reset ()
	SonicClientBase (const edm::ParameterSet &params, const std::string &debugName, const std::string &clientName)
virtual	~SonicClientBase ()=default

Static Public Member Functions
static void	fillBasePSetDescription (edm::ParameterSetDescription &desc, bool allowRetry=true)

Protected Member Functions
virtual void	evaluate ()=0
void	finish (bool success, std::exception_ptr eptr=std::exception_ptr{})
void	setMode (SonicMode mode)
void	start ()
void	start (edm::WaitingTaskWithArenaHolder holder)

Protected Attributes
unsigned	allowedTries_
std::string	clientName_
std::string	debugName_
std::unique_ptr< SonicDispatcher >	dispatcher_
std::string	fullDebugName_
std::optional< edm::WaitingTaskWithArenaHolder >	holder_
SonicMode	mode_
std::chrono::time_point< std::chrono::high_resolution_clock >	t0_
unsigned	tries_

Friends
class	SonicDispatcher
class	SonicDispatcherPseudoAsync

Detailed Description

Definition at line 19 of file SonicClientBase.h.

Constructor & Destructor Documentation

SonicClientBase()

SonicClientBase::SonicClientBase	(	const edm::ParameterSet &	params,
		const std::string &	debugName,
		const std::string &	clientName
	)

Definition at line 5 of file SonicClientBase.cc.

    : allowedTries_(params.getUntrackedParameter<unsigned>("allowedTries", 0)),
      debugName_(debugName),
      clientName_(clientName),
      fullDebugName_(debugName_) {
  if (!clientName_.empty())
    fullDebugName_ += ":" + clientName_;
 
  std::string modeName(params.getParameter<std::string>("mode"));
  if (modeName == "Sync")
    setMode(SonicMode::Sync);
  else if (modeName == "Async")
    setMode(SonicMode::Async);
  else if (modeName == "PseudoAsync")
    setMode(SonicMode::PseudoAsync);
  else
    throw cms::Exception("Configuration") << "Unknown mode for SonicClient: " << modeName;
}

References Async, clientName_, Exception, fullDebugName_, CalibrationSummaryClient_cfi::params, PseudoAsync, setMode(), AlCaHLTBitMon_QueryRunRegistry::string, and Sync.

~SonicClientBase()

virtual SonicClientBase::~SonicClientBase ( )

virtualdefault

Member Function Documentation

clientName()

const std::string& SonicClientBase::clientName ( ) const

inline

Definition at line 28 of file SonicClientBase.h.

{ return clientName_; }

References clientName_.

debugName()

const std::string& SonicClientBase::debugName ( ) const

inline

Definition at line 27 of file SonicClientBase.h.

{ return debugName_; }

References debugName_.

dispatch() [1/2]

virtual void SonicClientBase::dispatch ( )

inlinevirtual

Definition at line 35 of file SonicClientBase.h.

{ dispatcher_->dispatch(); }

References dispatcher_.

dispatch() [2/2]

virtual void SonicClientBase::dispatch ( edm::WaitingTaskWithArenaHolder  holder )

inlinevirtual

Definition at line 32 of file SonicClientBase.h.

{ dispatcher_->dispatch(std::move(holder)); }

References dispatcher_, and eostools::move().

evaluate()

virtual void SonicClientBase::evaluate ( )

protectedpure virtual

Implemented in TritonClient.

Referenced by SonicDispatcher::dispatch(), finish(), and SonicDispatcherPseudoAsync::waitForNext().

fillBasePSetDescription()

void SonicClientBase::fillBasePSetDescription ( edm::ParameterSetDescription &  desc, bool  allowRetry = true  )

static

Definition at line 78 of file SonicClientBase.cc.

                                                                                               {
  //restrict allowed values
  desc.ifValue(edm::ParameterDescription<std::string>("mode", "PseudoAsync", true),
               edm::allowedValues<std::string>("Sync", "Async", "PseudoAsync"));
  if (allowRetry)
    desc.addUntracked<unsigned>("allowedTries", 0);
}

References submitPVResolutionJobs::desc.

Referenced by TritonClient::fillPSetDescription().

finish()

void SonicClientBase::finish ( bool  success, std::exception_ptr  eptr = std::exception_ptr{}  )

protected

Definition at line 49 of file SonicClientBase.cc.

                                                                {
  //retries are only allowed if no exception was raised
  if (!success and !eptr) {
    ++tries_;
    //if max retries has not been exceeded, call evaluate again
    if (tries_ < allowedTries_) {
      evaluate();
      //avoid calling doneWaiting() twice
      return;
    }
    //prepare an exception if exceeded
    else {
      cms::Exception ex("SonicCallFailed");
      ex << "call failed after max " << tries_ << " tries";
      eptr = make_exception_ptr(ex);
    }
  }
  if (!debugName_.empty()) {
    auto t1 = std::chrono::high_resolution_clock::now();
    edm::LogInfo(fullDebugName_) << "Client time: "
                                 << std::chrono::duration_cast<std::chrono::microseconds>(t1 - t0_).count();
  }
  if (holder_) {
    holder_->doneWaiting(eptr);
    holder_.reset();
  } else if (eptr)
    std::rethrow_exception(eptr);
}

References allowedTries_, debugName_, evaluate(), fullDebugName_, holder_, submitPVValidationJobs::now, summarizeEdmComparisonLogfiles::success, t0_, RandomServiceHelper::t1, and tries_.

Referenced by progressbar.ProgressBar::__next__(), and TritonClient::evaluate().

mode()

SonicMode SonicClientBase::mode ( void  ) const

inline

Definition at line 29 of file SonicClientBase.h.

{ return mode_; }

References mode_.

Referenced by setMode().

reset()

virtual void SonicClientBase::reset ( void  )

inlinevirtual

Reimplemented in TritonClient.

Definition at line 38 of file SonicClientBase.h.

{}

setMode()

void SonicClientBase::setMode ( SonicMode  mode )

protected

Definition at line 26 of file SonicClientBase.cc.

                                            {
  if (dispatcher_ and mode_ == mode)
    return;
  mode_ = mode;
 
  //get correct dispatcher for mode
  if (mode_ == SonicMode::Sync or mode_ == SonicMode::Async)
    dispatcher_ = std::make_unique<SonicDispatcher>(this);
  else if (mode_ == SonicMode::PseudoAsync)
    dispatcher_ = std::make_unique<SonicDispatcherPseudoAsync>(this);
}

References Async, dispatcher_, mode(), mode_, or, PseudoAsync, and Sync.

Referenced by SonicClientBase(), and TritonClient::TritonClient().

start() [1/2]

void SonicClientBase::start ( )

protected

Definition at line 43 of file SonicClientBase.cc.

                            {
  tries_ = 0;
  if (!debugName_.empty())
    t0_ = std::chrono::high_resolution_clock::now();
}

References debugName_, submitPVValidationJobs::now, t0_, and tries_.

Referenced by progressbar.ProgressBar::__next__(), and start().

start() [2/2]

void SonicClientBase::start ( edm::WaitingTaskWithArenaHolder  holder )

protected

Definition at line 38 of file SonicClientBase.cc.

                                                                {
  start();
  holder_ = std::move(holder);
}

References holder_, eostools::move(), and start().

Referenced by progressbar.ProgressBar::__next__(), SonicDispatcher::dispatch(), and SonicDispatcherPseudoAsync::dispatch().

Friends And Related Function Documentation

SonicDispatcher

friend class SonicDispatcher

friend

Definition at line 64 of file SonicClientBase.h.

SonicDispatcherPseudoAsync

friend class SonicDispatcherPseudoAsync

friend

Definition at line 65 of file SonicClientBase.h.

Member Data Documentation

allowedTries_

unsigned SonicClientBase::allowedTries_

protected

Definition at line 57 of file SonicClientBase.h.

Referenced by finish().

clientName_

std::string SonicClientBase::clientName_

protected

Definition at line 61 of file SonicClientBase.h.

Referenced by clientName(), and SonicClientBase().

debugName_

std::string SonicClientBase::debugName_

protected

Definition at line 61 of file SonicClientBase.h.

Referenced by debugName(), TritonClient::evaluate(), finish(), TritonClient::reportServerSideStats(), and start().

dispatcher_

std::unique_ptr<SonicDispatcher> SonicClientBase::dispatcher_

protected

Definition at line 56 of file SonicClientBase.h.

Referenced by dispatch(), and setMode().

fullDebugName_

std::string SonicClientBase::fullDebugName_

protected

Definition at line 61 of file SonicClientBase.h.

Referenced by TritonClient::evaluate(), finish(), TritonClient::reportServerSideStats(), TritonClient::setBatchSize(), SonicClientBase(), and TritonClient::TritonClient().

holder_

std::optional<edm::WaitingTaskWithArenaHolder> SonicClientBase::holder_

protected

Definition at line 58 of file SonicClientBase.h.

Referenced by finish(), and start().

mode_

SonicMode SonicClientBase::mode_

protected

Definition at line 55 of file SonicClientBase.h.

Referenced by TritonClient::evaluate(), mode(), and setMode().

t0_

std::chrono::time_point<std::chrono::high_resolution_clock> SonicClientBase::t0_

protected

Definition at line 62 of file SonicClientBase.h.

Referenced by finish(), and start().

tries_

unsigned SonicClientBase::tries_

protected

Definition at line 57 of file SonicClientBase.h.

Referenced by finish(), and start().