#include <ProcInfoFetcher.h>

Public Member Functions
ProcInfo	fetch () const

ProcInfoFetcher &	operator= (ProcInfoFetcher const &)=delete

	ProcInfoFetcher ()

	ProcInfoFetcher (ProcInfoFetcher const &)=delete

	~ProcInfoFetcher ()

Private Attributes
char	buf_ [500]

int	fd_

double	pg_size_

Detailed Description

Definition at line 41 of file ProcInfoFetcher.h.

Constructor & Destructor Documentation

◆ ProcInfoFetcher() [1/2]

ProcInfoFetcher::ProcInfoFetcher ( )

Definition at line 170 of file ProcInfoFetcher.cc.

References edm::errors::Configuration, Exception, and fd_.

                                      : pg_size_(sysconf(_SC_PAGESIZE)) {
 #ifdef __linux__
       std::ostringstream ost;
       ost << "/proc/" << getpid() << "/stat";
 
       if ((fd_ = open(ost.str().c_str(), O_RDONLY)) < 0) {
         throw Exception(errors::Configuration) << "Failed to open " << ost.str() << std::endl;
       }
 #endif
     }

◆ ~ProcInfoFetcher()

ProcInfoFetcher::~ProcInfoFetcher ( )

Definition at line 180 of file ProcInfoFetcher.cc.

References fd_.

                                       {
 #ifdef LINUX
       close(fd_);
 #endif
     }

◆ ProcInfoFetcher() [2/2]

edm::service::ProcInfoFetcher::ProcInfoFetcher ( ProcInfoFetcher const & )

delete

Member Function Documentation

◆ fetch()

ProcInfo ProcInfoFetcher::fetch ( ) const

Definition at line 185 of file ProcInfoFetcher.cc.

References buf_, cppFunctionSkipper::exception, fd_, pg_size_, fileinputsource_cfi::read, and runTheMatrix::ret.

Referenced by edm::service::ResourceEnforcer::check(), and edm::service::SimpleMemoryCheck::fetch().

                                           {
       ProcInfo ret;
 
 #ifdef __linux__
       double pr_size = 0.0, pr_rssize = 0.0;
 
       linux_proc pinfo;
       int cnt;
 
       lseek(fd_, 0, SEEK_SET);
 
       if ((cnt = read(fd_, buf_, sizeof(buf_) - 1)) < 0) {
         perror("Read of Proc file failed:");
         return ProcInfo();
       }
 
       if (cnt > 0) {
         buf_[cnt] = '\0';
 
         try {
           Fetcher fetcher(buf_);
           fetcher >> pinfo.pid >> pinfo.comm >> pinfo.state >> pinfo.ppid >> pinfo.pgrp >> pinfo.session >> pinfo.tty >>
               pinfo.tpgid >> pinfo.flags >> pinfo.minflt >> pinfo.cminflt >> pinfo.majflt >> pinfo.cmajflt >>
               pinfo.utime >> pinfo.stime >> pinfo.cutime >> pinfo.cstime >> pinfo.priority >> pinfo.nice >>
               pinfo.num_threads >> pinfo.itrealvalue >> pinfo.starttime >> pinfo.vsize >> pinfo.rss >> pinfo.rlim >>
               pinfo.startcode >> pinfo.endcode >> pinfo.startstack >> pinfo.kstkesp >> pinfo.kstkeip >> pinfo.signal >>
               pinfo.blocked >> pinfo.sigignore >> pinfo.sigcatch >> pinfo.wchan;
         } catch (const std::exception& iE) {
           LogWarning("ProcInfoFetcher") << "Parsing of Prof file failed:" << iE.what() << std::endl;
           return ProcInfo();
         }
 
         // resident set size in pages
         pr_size = (double)pinfo.vsize;
         pr_rssize = (double)pinfo.rss;
 
         ret.vsize = pr_size / (1024.0 * 1024.0);
         ret.rss = (pr_rssize * pg_size_) / (1024.0 * 1024.0);
       }
 #else
       ret.vsize = 0;
       ret.rss = 0;
 #endif
       return ret;
     }

◆ operator=()

ProcInfoFetcher& edm::service::ProcInfoFetcher::operator= ( ProcInfoFetcher const & )

delete

Member Data Documentation

◆ buf_

char edm::service::ProcInfoFetcher::buf_[500]

mutableprivate

Definition at line 53 of file ProcInfoFetcher.h.

Referenced by fetch().

◆ fd_

int edm::service::ProcInfoFetcher::fd_

private

Definition at line 52 of file ProcInfoFetcher.h.

Referenced by fetch(), ProcInfoFetcher(), and ~ProcInfoFetcher().

◆ pg_size_

double edm::service::ProcInfoFetcher::pg_size_