edm::service Namespace Reference

Classes
class	AbstractMLscribe
class	CheckTransitions
struct	close_and_delete
class	ConcurrentModuleTimer
class	CondorStatusService
class	CPU
class	ELadministrator
class	ELdestination
class	ELlimitsTable
class	ELoutput
class	ELstatistics
class	IgProfService
class	InitRootHandlers
class	JobReportService
class	LoadAllDictionaries
class	MessageLogger
struct	MessageLoggerDefaults
class	MessageServicePSetValidation
class	PrescaleService
struct	ProcInfo
class	ProcInfoFetcher
class	ProductRegistryDumper
class	RandomNumberGeneratorService
class	ResourceEnforcer
class	SimpleMemoryCheck
class	SingleThreadMSPresence
class	SiteLocalConfigService
struct	smapsInfo
class	StallMonitor
class	SystemBounds
class	TestService
class	ThreadSafeLogMessageLoggerScribe
class	Timing
class	Tracer
class	TriggerNamesService
class	UnixSignalService

Functions
int	cmssw_stacktrace (void *)
static void	cmssw_stacktrace_fork ()
static std::string	d2str (double d)
static std::string	d2str (double d)
static double	getChildrenCPU ()
static double	getCPU ()
static double	getTime ()
static std::string	i2str (int i)
bool	isProcessWideService (void const *)
bool	isProcessWideService (JobReportService const *)
bool	isProcessWideService (TFileAdaptor const *)
bool	isProcessWideService (CPU const *)
bool	isProcessWideService (TFileService const *)
bool	isProcessWideService (SiteLocalConfigService const *)
bool	isProcessWideService (InitRootHandlers const *)
bool	isProcessWideService (MessageLogger const *)
bool	isProcessWideService (DependencyGraph const *)
static std::vector< double > &	moduleTimeStack ()
std::ostream &	operator<< (std::ostream &os, SimpleMemoryCheck::SignificantEvent const &se)
std::ostream &	operator<< (std::ostream &os, SimpleMemoryCheck::SignificantModule const &se)
static double	popStack ()
static void	pushStack (bool configuredInTopLevelProcess)
static std::string	ui2str (unsigned int i)

Variables
static constexpr char	dashC [] = "-c"
static const std::string	hereMsg = "available via this destination"
static const std::string	noosMsg = "No ostream"
static const std::string	notELoutputMsg = "This destination is not an ELoutput"
static constexpr char	pstackName [] = "(CMSSW stack trace helper)"

Function Documentation

cmssw_stacktrace()

int edm::service::cmssw_stacktrace

(

void *

)

Definition at line 735 of file InitRootHandlers.cc.

References cmsBatch::argv, and edm::service::InitRootHandlers::getPstackArgv().

Referenced by cmssw_stacktrace_fork().

                                  {
      set_default_signals();

      char const* const* argv = edm::service::InitRootHandlers::getPstackArgv();
      // NOTE: this is NOT async-signal-safe at CERN's lxplus service.
      // CERN uses LD_PRELOAD to replace execv with a function from libsnoopy which
      // calls dlsym.
#ifdef __linux__
      syscall(SYS_execve, "/bin/sh", argv, __environ);
#else
      execv("/bin/sh", argv);
#endif
      ::abort();
      return 1;
    }

cmssw_stacktrace_fork()

void edm::service::cmssw_stacktrace_fork ( )

static

Definition at line 704 of file InitRootHandlers.cc.

References clone(), cmssw_stacktrace(), and mps_update::status.

Referenced by edm::service::InitRootHandlers::stacktraceHelperThread().

                                 {
      char child_stack[4 * 1024];
      char* child_stack_ptr = child_stack + 4 * 1024;
      // On Linux, we currently use jemalloc.  This registers pthread_atfork handlers; these
      // handlers are *not* async-signal safe.  Hence, a deadlock is possible if we invoke
      // fork() from our signal handlers.  Accordingly, we use clone (not POSIX, but AS-safe)
      // as that is closer to the 'raw metal' syscall and avoids pthread_atfork handlers.
      int pid =
#ifdef __linux__
          clone(edm::service::cmssw_stacktrace, child_stack_ptr, CLONE_VM | CLONE_FS | SIGCHLD, nullptr);
#else
          fork();
      if (child_stack_ptr) {
      }  // Suppress 'unused variable' warning on non-Linux
      if (pid == 0) {
        edm::service::cmssw_stacktrace(nullptr);
      }
#endif
      if (pid == -1) {
        full_cerr_write("(Attempt to perform stack dump failed.)\n");
      } else {
        int status;
        if (waitpid(pid, &status, 0) == -1) {
          full_cerr_write("(Failed to wait on stack dump output.)\n");
        }
        if (status) {
          full_cerr_write("(GDB stack trace failed unexpectedly)\n");
        }
      }
    }

d2str() [1/2]

static std::string edm::service::d2str ( double  d )

static

Definition at line 145 of file Timing.cc.

References ztail::d, and submitPVValidationJobs::t.

                                     {
      std::stringstream t;
      t << d;
      return t.str();
    }

d2str() [2/2]

static std::string edm::service::d2str ( double  d )

static

Definition at line 275 of file SimpleMemoryCheck.cc.

References ztail::d, and submitPVValidationJobs::t.

Referenced by edm::service::SimpleMemoryCheck::eventStatOutput(), edm::service::CPU::postEndJob(), edm::service::Timing::postEndJob(), and edm::service::SimpleMemoryCheck::postEndJob().

                                     {
      std::ostringstream t;
      t << d;
      return t.str();
    }

getChildrenCPU()

static double edm::service::getChildrenCPU ( )

static

Definition at line 164 of file Timing.cc.

References usage().

Referenced by edm::service::Timing::postEndJob().

                                   {
      struct rusage usage;

      getrusage(RUSAGE_CHILDREN, &usage);
      double totalCPUTime = (double)usage.ru_utime.tv_sec + (double(usage.ru_utime.tv_usec) * 1E-6);
      totalCPUTime += (double)usage.ru_stime.tv_sec + (double(usage.ru_stime.tv_usec) * 1E-6);

      return totalCPUTime;
    }

getCPU()

static double edm::service::getCPU ( )

static

Definition at line 174 of file Timing.cc.

References usage().

Referenced by edm::service::Timing::getTotalCPU(), edm::service::Timing::postBeginJob(), and edm::service::Timing::postEndJob().

                           {
      struct rusage usage;
      getrusage(RUSAGE_SELF, &usage);

      double totalCPUTime = 0.0;
      // User code
      totalCPUTime = (double)usage.ru_utime.tv_sec + (double(usage.ru_utime.tv_usec) * 1E-6);
      // System functions
      totalCPUTime += (double)usage.ru_stime.tv_sec + (double(usage.ru_stime.tv_usec) * 1E-6);

      // Additionally, add in CPU usage from our child processes.
      getrusage(RUSAGE_CHILDREN, &usage);
      totalCPUTime += (double)usage.ru_utime.tv_sec + (double(usage.ru_utime.tv_usec) * 1E-6);
      totalCPUTime += (double)usage.ru_stime.tv_sec + (double(usage.ru_stime.tv_usec) * 1E-6);

      return totalCPUTime;
    }

getTime()

static double edm::service::getTime ( )

static

Definition at line 157 of file Timing.cc.

References Exception, and submitPVValidationJobs::t.

Referenced by edm::service::Timing::accumulateTimeBegin(), edm::service::Timing::accumulateTimeEnd(), popStack(), edm::service::Timing::postBeginJob(), edm::service::Timing::postEndJob(), edm::service::Timing::postEvent(), edm::service::Timing::preEvent(), and pushStack().

                            {
      struct timeval t;
      if (gettimeofday(&t, nullptr) < 0)
        throw cms::Exception("SysCallFailed", "Failed call to gettimeofday");
      return static_cast<double>(t.tv_sec) + (static_cast<double>(t.tv_usec) * 1E-6);
    }

i2str()

static std::string edm::service::i2str ( int  i )

static

Definition at line 281 of file SimpleMemoryCheck.cc.

References mps_fire::i, and submitPVValidationJobs::t.

Referenced by edm::service::SimpleMemoryCheck::eventStatOutput(), edm::service::CPU::postEndJob(), and edm::service::SimpleMemoryCheck::postEndJob().

                                  {
      std::ostringstream t;
      t << i;
      return t.str();
    }

isProcessWideService() [1/9]

bool edm::service::isProcessWideService ( void const *  )

inline

Definition at line 29 of file ServiceMakerBase.h.

{ return false; }

isProcessWideService() [2/9]

bool edm::service::isProcessWideService ( JobReportService const *  )

inline

Definition at line 46 of file JobReportService.h.

{ return true; }

isProcessWideService() [3/9]

bool edm::service::isProcessWideService ( TFileAdaptor const *  )

inline

Definition at line 54 of file TFileAdaptor.h.

{ return true; }

isProcessWideService() [4/9]

bool edm::service::isProcessWideService ( CPU const *  )

inline

Definition at line 57 of file CPU.cc.

{ return true; }

isProcessWideService() [5/9]

bool edm::service::isProcessWideService ( TFileService const *  )

inline

Definition at line 98 of file TFileService.h.

Referenced by edm::serviceregistry::ServiceMaker< T, TMaker >::processWideService().

{ return true; }

isProcessWideService() [6/9]

bool edm::service::isProcessWideService ( SiteLocalConfigService const *  )

inline

Definition at line 99 of file SiteLocalConfigService.h.

{ return true; }

isProcessWideService() [7/9]

bool edm::service::isProcessWideService ( InitRootHandlers const *  )

inline

Definition at line 145 of file InitRootHandlers.cc.

{ return true; }

isProcessWideService() [8/9]

bool edm::service::isProcessWideService ( MessageLogger const *  )

inline

Definition at line 195 of file MessageLogger.h.

{ return true; }

isProcessWideService() [9/9]

bool edm::service::isProcessWideService ( DependencyGraph const *  )

inline

Definition at line 343 of file DependencyGraph.cc.

{ return true; }

moduleTimeStack()

static std::vector<double>& edm::service::moduleTimeStack ( )

static

Definition at line 195 of file Timing.cc.

Referenced by popStack(), and pushStack().

                                                {
      static thread_local std::vector<double> s_stack;
      return s_stack;
    }

operator<<() [1/2]

std::ostream & edm::service::operator<<	(	std::ostream &	os,
		SimpleMemoryCheck::SignificantEvent const &	se
	)

Definition at line 963 of file SimpleMemoryCheck.cc.

References edm::service::SimpleMemoryCheck::SignificantEvent::count, edm::service::SimpleMemoryCheck::SignificantEvent::deltaRss, edm::service::SimpleMemoryCheck::SignificantEvent::deltaVsize, edm::service::SimpleMemoryCheck::SignificantEvent::event, edm::service::SimpleMemoryCheck::SignificantEvent::monitorPssAndPrivate, edm::service::SimpleMemoryCheck::SignificantEvent::privateSize, edm::service::SimpleMemoryCheck::SignificantEvent::pss, edm::service::SimpleMemoryCheck::SignificantEvent::rss, and edm::service::SimpleMemoryCheck::SignificantEvent::vsize.

                                                                                        {
      os << "[" << se.count << "] " << se.event << "  vsize = " << se.vsize << " deltaVsize = " << se.deltaVsize
         << " rss = " << se.rss << " delta = " << se.deltaRss;

      if (se.monitorPssAndPrivate) {
        os << " private = " << se.privateSize << " pss = " << se.pss;
      }
      return os;
    }

operator<<() [2/2]

std::ostream & edm::service::operator<<	(	std::ostream &	os,
		SimpleMemoryCheck::SignificantModule const &	se
	)

Definition at line 973 of file SimpleMemoryCheck.cc.

References edm::service::SimpleMemoryCheck::SignificantModule::eventMaxDeltaV, edm::service::SimpleMemoryCheck::SignificantModule::maxDeltaVsize, edm::service::SimpleMemoryCheck::SignificantModule::maxEarlyVsize, edm::service::SimpleMemoryCheck::SignificantModule::postEarlyCount, edm::service::SimpleMemoryCheck::SignificantModule::totalDeltaVsize, and edm::service::SimpleMemoryCheck::SignificantModule::totalEarlyVsize.

                                                                                         {
      if (sm.postEarlyCount > 0) {
        os << "\nPost Early Events:  TotalDeltaVsize: " << sm.totalDeltaVsize
           << " (avg: " << sm.totalDeltaVsize / sm.postEarlyCount << "; max: " << sm.maxDeltaVsize << " during "
           << sm.eventMaxDeltaV << ")";
      }
      if (sm.totalEarlyVsize > 0) {
        os << "\n     Early Events:  TotalDeltaVsize: " << sm.totalEarlyVsize << " (max: " << sm.maxEarlyVsize << ")";
      }

      return os;
    }

popStack()

static double edm::service::popStack ( )

static

Definition at line 200 of file Timing.cc.

References cms::cuda::assert(), getTime(), moduleTimeStack(), and submitPVValidationJobs::t.

Referenced by edm::service::Timing::postCommon().

                             {
      auto& modStack = moduleTimeStack();
      assert(!modStack.empty());
      double curr_module_time = modStack.back();
      modStack.pop_back();
      double t = getTime() - curr_module_time;
      return t;
    }

pushStack()

static void edm::service::pushStack ( bool  configuredInTopLevelProcess )

static

Definition at line 209 of file Timing.cc.

References getTime(), and moduleTimeStack().

Referenced by edm::service::Timing::preModule(), edm::service::Timing::preModuleGlobal(), edm::service::Timing::preModuleStream(), edm::service::Timing::preOpenFile(), edm::service::Timing::preSourceEvent(), edm::service::Timing::preSourceLumi(), and edm::service::Timing::preSourceRun().

                                                            {
      if (!configuredInTopLevelProcess) {
        return;
      }
      auto& modStack = moduleTimeStack();
      modStack.push_back(getTime());
    }

ui2str()

static std::string edm::service::ui2str ( unsigned int  i )

static

Definition at line 151 of file Timing.cc.

References mps_fire::i, and submitPVValidationJobs::t.

Referenced by edm::service::Timing::postEndJob().

                                            {
      std::stringstream t;
      t << i;
      return t.str();
    }

Variable Documentation

dashC

constexpr char edm::service::dashC[] = "-c"

static

Definition at line 752 of file InitRootHandlers.cc.

hereMsg

const std::string edm::service::hereMsg = "available via this destination"

static

Definition at line 83 of file ELdestination.cc.

noosMsg

const std::string edm::service::noosMsg = "No ostream"

static

Definition at line 84 of file ELdestination.cc.

Referenced by edm::service::ELdestination::changeFile(), and edm::service::ELdestination::flush().

notELoutputMsg

const std::string edm::service::notELoutputMsg = "This destination is not an ELoutput"

static

Definition at line 85 of file ELdestination.cc.

Referenced by edm::service::ELdestination::changeFile().

pstackName

constexpr char edm::service::pstackName[] = "(CMSSW stack trace helper)"

static

Definition at line 751 of file InitRootHandlers.cc.