edm::service Namespace Reference

Namespaces
	monitor_file_utilities
	tracer

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	JeProfService
class	JobReportService
class	LoadAllDictionaries
class	MessageLogger
struct	MessageLoggerDefaults
class	MessageServicePSetValidation
class	PrescaleService
struct	ProcInfo
class	ProcInfoFetcher
class	ProductRegistryDumper
class	RandomNumberGeneratorService
class	ResourceEnforcer
class	ResourceInformationService
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 std::chrono::steady_clock::time_point	getTime ()
static std::string	i2str (int i)
bool	isProcessWideService (void const *)
bool	isProcessWideService (JobReportService const *)
bool	isProcessWideService (TFileAdaptor const *)
bool	isProcessWideService (ZombieKillerService const *)
bool	isProcessWideService (CPU const *)
bool	isProcessWideService (ResourceInformationService const *)
bool	isProcessWideService (CondorStatusService const *)
bool	isProcessWideService (IgProfService const *)
bool	isProcessWideService (JeProfService const *)
bool	isProcessWideService (TFileService const *)
bool	isProcessWideService (SiteLocalConfigService const *)
bool	isProcessWideService (InitRootHandlers const *)
bool	isProcessWideService (MessageLogger const *)
bool	isProcessWideService (DependencyGraph const *)
bool	isProcessWideService (ROCmService const *)
bool	isProcessWideService (CUDAService const *)
static std::vector< std::chrono::steady_clock::time_point > &	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 741 of file InitRootHandlers.cc.

References GCPpyPlots::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 710 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 148 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::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 162 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 172 of file Timing.cc.

References usage().

Referenced by edm::service::Timing::beginProcessing(), edm::service::Timing::getTotalCPU(), 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 std::chrono::steady_clock::time_point edm::service::getTime ( )

static

Definition at line 160 of file Timing.cc.

References submitPVValidationJobs::now.

Referenced by edm::service::Timing::beginProcessing(), popStack(), edm::service::Timing::postEndJob(), edm::service::Timing::postEvent(), edm::service::Timing::preEvent(), pushStack(), and edm::service::Timing::runningTasksChanged().

{ return std::chrono::steady_clock::now(); }

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(), and edm::service::SimpleMemoryCheck::postEndJob().

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

isProcessWideService() [1/16]

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

inline

Definition at line 29 of file ServiceMakerBase.h.

{ return false; }

isProcessWideService() [2/16]

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

inline

Definition at line 46 of file JobReportService.h.

{ return true; }

isProcessWideService() [3/16]

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

inline

Definition at line 54 of file TFileAdaptor.h.

{ return true; }

isProcessWideService() [4/16]

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

inline

Definition at line 55 of file ZombieKillerService.cc.

{ return true; }

isProcessWideService() [5/16]

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

inline

Definition at line 71 of file CPU.cc.

{ return true; }

isProcessWideService() [6/16]

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

inline

Definition at line 77 of file ResourceInformationService.cc.

{ return true; }

isProcessWideService() [7/16]

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

inline

Definition at line 86 of file CondorStatusUpdater.cc.

{ return true; }

isProcessWideService() [8/16]

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

inline

Definition at line 94 of file IgProfService.h.

{ return true; }

isProcessWideService() [9/16]

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

inline

Definition at line 95 of file JeProfService.cc.

{ return true; }

isProcessWideService() [10/16]

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() [11/16]

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

inline

Definition at line 110 of file SiteLocalConfigService.h.

{ return true; }

isProcessWideService() [12/16]

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

inline

Definition at line 145 of file InitRootHandlers.cc.

{ return true; }

isProcessWideService() [13/16]

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

inline

Definition at line 195 of file MessageLogger.h.

{ return true; }

isProcessWideService() [14/16]

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

inline

Definition at line 343 of file DependencyGraph.cc.

{ return true; }

isProcessWideService() [15/16]

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

inline

Definition at line 390 of file ROCmService.cc.

{ return true; }

isProcessWideService() [16/16]

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

inline

Definition at line 482 of file CUDAService.cc.

{ return true; }

moduleTimeStack()

static std::vector<std::chrono::steady_clock::time_point>& edm::service::moduleTimeStack ( )

static

Definition at line 193 of file Timing.cc.

Referenced by popStack(), and pushStack().

                                                                         {
      static thread_local std::vector<std::chrono::steady_clock::time_point> s_stack;
      return s_stack;
    }

operator<<() [1/2]

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

Definition at line 976 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 986 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 198 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());
      auto curr_module_time = modStack.back();
      modStack.pop_back();
      std::chrono::duration<double, std::ratio<1, 1>> t = getTime() - curr_module_time;
      return t.count();
    }

pushStack()

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

static

Definition at line 207 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 154 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 758 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 757 of file InitRootHandlers.cc.