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 ()
void	setDebugName (const std::string &debugName)
	SonicClientBase (const edm::ParameterSet &params)
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	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

)

Definition at line 5 of file SonicClientBase.cc.

    : allowedTries_(params.getUntrackedParameter<unsigned>("allowedTries", 0)) {
  std::string modeName(params.getParameter<std::string>("mode"));
  if (modeName == "Sync")
    mode_ = SonicMode::Sync;
  else if (modeName == "Async")
    mode_ = SonicMode::Async;
  else if (modeName == "PseudoAsync")
    mode_ = SonicMode::PseudoAsync;
  else
    throw cms::Exception("Configuration") << "Unknown mode for SonicClient: " << modeName;
 
  //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_, Exception, mode_, or, CalibrationSummaryClient_cfi::params, PseudoAsync, AlCaHLTBitMon_QueryRunRegistry::string, and Sync.

~SonicClientBase()

virtual SonicClientBase::~SonicClientBase ( )

virtualdefault

Member Function Documentation

clientName()

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

inline

Definition at line 29 of file SonicClientBase.h.

{ return clientName_; }

References clientName_.

debugName()

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

inline

Definition at line 28 of file SonicClientBase.h.

{ return debugName_; }

References debugName_.

Referenced by setDebugName().

dispatch() [1/2]

virtual void SonicClientBase::dispatch ( )

inlinevirtual

Definition at line 36 of file SonicClientBase.h.

{ dispatcher_->dispatch(); }

References dispatcher_.

dispatch() [2/2]

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

inlinevirtual

Definition at line 33 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 71 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 42 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 30 of file SonicClientBase.h.

{ return mode_; }

References mode_.

reset()

virtual void SonicClientBase::reset ( void  )

inlinevirtual

Reimplemented in TritonClient.

Definition at line 39 of file SonicClientBase.h.

{}

setDebugName()

void SonicClientBase::setDebugName

(

const std::string &

debugName

)

Definition at line 24 of file SonicClientBase.cc.

                                                             {
  debugName_ = debugName;
  fullDebugName_ = debugName_;
  if (!clientName_.empty())
    fullDebugName_ += ":" + clientName_;
}

References clientName_, debugName(), debugName_, and fullDebugName_.

start() [1/2]

void SonicClientBase::start ( )

protected

Definition at line 36 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 31 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 63 of file SonicClientBase.h.

SonicDispatcherPseudoAsync

friend class SonicDispatcherPseudoAsync

friend

Definition at line 64 of file SonicClientBase.h.

Member Data Documentation

allowedTries_

unsigned SonicClientBase::allowedTries_

protected

Definition at line 56 of file SonicClientBase.h.

Referenced by finish().

clientName_

std::string SonicClientBase::clientName_

protected

Definition at line 60 of file SonicClientBase.h.

Referenced by clientName(), setDebugName(), and TritonClient::TritonClient().

debugName_

std::string SonicClientBase::debugName_

protected

Definition at line 60 of file SonicClientBase.h.

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

dispatcher_

std::unique_ptr<SonicDispatcher> SonicClientBase::dispatcher_

protected

Definition at line 55 of file SonicClientBase.h.

Referenced by dispatch(), and SonicClientBase().

fullDebugName_

std::string SonicClientBase::fullDebugName_

protected

Definition at line 60 of file SonicClientBase.h.

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

holder_

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

protected

Definition at line 57 of file SonicClientBase.h.

Referenced by finish(), and start().

mode_

SonicMode SonicClientBase::mode_

protected

Definition at line 54 of file SonicClientBase.h.

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

t0_

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

protected

Definition at line 61 of file SonicClientBase.h.

Referenced by finish(), and start().

tries_

unsigned SonicClientBase::tries_

protected

Definition at line 56 of file SonicClientBase.h.

Referenced by finish(), and start().