edm::service::ProcInfoFetcher Class Reference

#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::ProcInfoFetcher

(

)

Definition at line 171 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

(

)

Definition at line 181 of file ProcInfoFetcher.cc.

References fd_.

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

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

delete

Member Function Documentation

ProcInfo ProcInfoFetcher::fetch

(

)

const

Definition at line 186 of file ProcInfoFetcher.cc.

References buf_, fd_, pg_size_, readEcalDQMStatus::read, runTheMatrix::ret, edm::service::ProcInfo::rss, and edm::service::ProcInfo::vsize.

Referenced by edm::service::ResourceEnforcer::check().

                                          {
      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 (boost::bad_lexical_cast& 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;
    }

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

delete

Member Data Documentation

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

mutableprivate

Definition at line 53 of file ProcInfoFetcher.h.

Referenced by fetch().

int edm::service::ProcInfoFetcher::fd_

private

Definition at line 52 of file ProcInfoFetcher.h.

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

double edm::service::ProcInfoFetcher::pg_size_

private

Definition at line 51 of file ProcInfoFetcher.h.

Referenced by fetch().