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	getCPU ()
static double	getTime ()
static std::string	i2str (int i)
bool	isProcessWideService (CPU const *)
bool	isProcessWideService (DependencyGraph const *)
bool	isProcessWideService (InitRootHandlers const *)
bool	isProcessWideService (JobReportService const *)
bool	isProcessWideService (MessageLogger const *)
bool	isProcessWideService (SiteLocalConfigService const *)
bool	isProcessWideService (TFileAdaptor const *)
bool	isProcessWideService (TFileService const *)
bool	isProcessWideService (void 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 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 char	pstackName [] = "(CMSSW stack trace helper)"

Function Documentation

cmssw_stacktrace()

int edm::service::cmssw_stacktrace

(

void *

)

Definition at line 735 of file InitRootHandlers.cc.

                                  {
      set_default_signals();
 
      char* 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;
    }

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

Referenced by cmssw_stacktrace_fork().

cmssw_stacktrace_fork()

void edm::service::cmssw_stacktrace_fork ( )

static

Definition at line 704 of file InitRootHandlers.cc.

                                 {
      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");
        }
      }
    }

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

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

d2str() [1/2]

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

static

Definition at line 145 of file Timing.cc.

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

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

d2str() [2/2]

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

static

Definition at line 277 of file SimpleMemoryCheck.cc.

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

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().

getCPU()

static double edm::service::getCPU ( )

static

Definition at line 164 of file Timing.cc.

                           {
      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;
    }

References usage().

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

getTime()

static double edm::service::getTime ( )

static

Definition at line 157 of file Timing.cc.

                            {
      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);
    }

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().

i2str()

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

static

Definition at line 283 of file SimpleMemoryCheck.cc.

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

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

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

isProcessWideService() [1/9]

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

inline

Definition at line 57 of file CPU.cc.

{ return true; }

isProcessWideService() [2/9]

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

inline

Definition at line 343 of file DependencyGraph.cc.

{ return true; }

isProcessWideService() [3/9]

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

inline

Definition at line 145 of file InitRootHandlers.cc.

{ return true; }

isProcessWideService() [4/9]

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

inline

Definition at line 46 of file JobReportService.h.

{ return true; }

isProcessWideService() [5/9]

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

inline

Definition at line 188 of file MessageLogger.h.

{ 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 ( TFileAdaptor const *  )

inline

Definition at line 54 of file TFileAdaptor.h.

{ return true; }

isProcessWideService() [8/9]

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

inline

Definition at line 98 of file TFileService.h.

{ return true; }

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

isProcessWideService() [9/9]

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

inline

Definition at line 29 of file ServiceMakerBase.h.

{ return false; }

moduleTimeStack()

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

static

Definition at line 185 of file Timing.cc.

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

Referenced by popStack(), and pushStack().

operator<<() [1/2]

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

Definition at line 987 of file SimpleMemoryCheck.cc.

                                                                                        {
      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;
    }

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.

operator<<() [2/2]

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

Definition at line 997 of file SimpleMemoryCheck.cc.

                                                                                         {
      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;
    }

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.

popStack()

static double edm::service::popStack ( )

static

Definition at line 190 of file Timing.cc.

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

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

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

pushStack()

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

static

Definition at line 199 of file Timing.cc.

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

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().

ui2str()

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

static

Definition at line 151 of file Timing.cc.

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

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

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

Variable Documentation

dashC

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

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

static

Definition at line 751 of file InitRootHandlers.cc.