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	MainThreadMLscribe
class	MessageLogger
struct	MessageLoggerDefaults
class	MessageLoggerScribe
class	MessageServicePresence
class	MessageServicePSetValidation
class	PrescaleService
struct	ProcInfo
class	ProcInfoFetcher
class	ProductRegistryDumper
class	RandomNumberGeneratorService
class	ResourceEnforcer
class	SilentMLscribe
class	SimpleMemoryCheck
class	SingleThreadMSPresence
class	SiteLocalConfigService
struct	smapsInfo
class	StallMonitor
class	SystemBounds
class	ThreadQueue
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 ELstring	formatTime (const time_t t)
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	summarizeContext (const std::string &c)
static std::string	ui2str (unsigned int i)

Variables
static char	dashC [] = "-c"
static const ELstring	hereMsg = "available via this destination"
static const ELstring	noosMsg = "No ostream"
static const ELstring	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 718 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 687 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 157 of file Timing.cc.

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

References ztail::d, and OrderedSet::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 OrderedSet::t.

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

formatTime()

static ELstring edm::service::formatTime ( const time_t  t )

static

Definition at line 98 of file ELoutput.cc.

                                               {  // Change log 7
 
      static char const dummy[] = "dd-Mon-yyyy hh:mm:ss TZN     ";  // Change log 7 for length only
      char ts[sizeof(dummy)];                                       // Change log 7
 
      struct tm timebuf;  // Change log 7
 
      strftime(ts, sizeof(dummy), "%d-%b-%Y %H:%M:%S %Z", localtime_r(&t, &timebuf));  // Change log 7
                                                                                       // mf 4-9-04
 
#ifdef STRIP_TRAILING_BLANKS_IN_TIMEZONE
      // strip trailing blanks that would come when the time zone is not as
      // long as the maximum allowed - probably not worth the time
      unsigned int b = strlen(ts);
      while (ts[--b] == ' ') {
        ts[b] = 0;
      }
#endif
 
      ELstring result(ts);  // Change log 7
      return result;        // Change log 7
    }                       // formatTime()

References b, mps_fire::result, and OrderedSet::t.

Referenced by edm::service::ELoutput::changeFile(), Vx3DHLTAnalyzer::dqmEndLuminosityBlock(), edm::service::ELoutput::ELoutput(), edm::service::ELoutput::log(), Vx3DHLTAnalyzer::reset(), and Vx3DHLTAnalyzer::writeToFile().

getCPU()

static double edm::service::getCPU ( )

static

Definition at line 176 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 169 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 OrderedSet::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 OrderedSet::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 132 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 173 of file MessageLogger.h.

{ return true; }

isProcessWideService() [6/9]

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

inline

Definition at line 93 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 197 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 202 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 OrderedSet::t.

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

pushStack()

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

static

Definition at line 211 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().

summarizeContext()

static std::string edm::service::summarizeContext ( const std::string &  c )

static

Definition at line 127 of file ELstatistics.cc.

                                                          {
      if (c.substr(0, 4) != "Run:")
        return c;
      std::istringstream is(c);
      std::string runWord;
      int run;
      is >> runWord >> run;
      if (!is)
        return c;
      if (runWord != "Run:")
        return c;
      std::string eventWord;
      int event;
      is >> eventWord >> event;
      if (!is)
        return c;
      if (eventWord != "Event:")
        return c;
      std::ostringstream os;
      os << run << "/" << event;
      return os.str();
    }

References HltBtagPostValidation_cff::c, event(), writedatasetfile::run, and AlCaHLTBitMon_QueryRunRegistry::string.

Referenced by edm::service::ELstatistics::log().

ui2str()

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

static

Definition at line 163 of file Timing.cc.

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

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

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

Variable Documentation

dashC

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

static

Definition at line 735 of file InitRootHandlers.cc.

hereMsg

const ELstring edm::service::hereMsg = "available via this destination"

static

Definition at line 82 of file ELdestination.cc.

noosMsg

const ELstring edm::service::noosMsg = "No ostream"

static

Definition at line 83 of file ELdestination.cc.

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

notELoutputMsg

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

static

Definition at line 84 of file ELdestination.cc.

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

pstackName

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

static

Definition at line 734 of file InitRootHandlers.cc.