| Index: base/process_util_freebsd.cc
|
| diff --git a/base/process_util_freebsd.cc b/base/process_util_freebsd.cc
|
| new file mode 100644
|
| index 0000000000000000000000000000000000000000..1157fb282c9fe12347b1fd70b1906ebba8e4b2fc
|
| --- /dev/null
|
| +++ b/base/process_util_freebsd.cc
|
| @@ -0,0 +1,293 @@
|
| +// Copyright (c) 2011 The Chromium Authors. All rights reserved.
|
| +// Use of this source code is governed by a BSD-style license that can be
|
| +// found in the LICENSE file.
|
| +
|
| +#include "base/process_util.h"
|
| +
|
| +#include <ctype.h>
|
| +#include <dirent.h>
|
| +#include <dlfcn.h>
|
| +#include <errno.h>
|
| +#include <fcntl.h>
|
| +#include <sys/time.h>
|
| +#include <sys/types.h>
|
| +#include <sys/wait.h>
|
| +#include <sys/sysctl.h>
|
| +#include <sys/user.h>
|
| +#include <time.h>
|
| +#include <unistd.h>
|
| +
|
| +#include "base/file_util.h"
|
| +#include "base/logging.h"
|
| +#include "base/string_number_conversions.h"
|
| +#include "base/string_split.h"
|
| +#include "base/string_tokenizer.h"
|
| +#include "base/string_util.h"
|
| +#include "base/sys_info.h"
|
| +
|
| +namespace base {
|
| +
|
| +ProcessId GetParentProcessId(ProcessHandle process) {
|
| + struct kinfo_proc info;
|
| + size_t length;
|
| + int mib[] = { CTL_KERN, KERN_PROC, KERN_PROC_PID, process };
|
| +
|
| + if (sysctl(mib, arraysize(mib), &info, &length, NULL, 0) < 0)
|
| + return -1;
|
| +
|
| + return info.ki_ppid;
|
| +}
|
| +
|
| +FilePath GetProcessExecutablePath(ProcessHandle process) {
|
| + char pathname[PATH_MAX];
|
| + size_t length;
|
| + int mib[] = { CTL_KERN, KERN_PROC, KERN_PROC_PATHNAME, process };
|
| +
|
| + length = sizeof(pathname);
|
| +
|
| + if (sysctl(mib, arraysize(mib), pathname, &length, NULL, 0) < 0 ||
|
| + length == 0) {
|
| + return FilePath();
|
| + }
|
| +
|
| + return FilePath(std::string(pathname));
|
| +}
|
| +
|
| +ProcessIterator::ProcessIterator(const ProcessFilter* filter)
|
| + : index_of_kinfo_proc_(),
|
| + filter_(filter) {
|
| +
|
| + int mib[] = { CTL_KERN, KERN_PROC, KERN_PROC_UID, getuid() };
|
| +
|
| + bool done = false;
|
| + int try_num = 1;
|
| + const int max_tries = 10;
|
| +
|
| + do {
|
| + size_t len = 0;
|
| + if (sysctl(mib, arraysize(mib), NULL, &len, NULL, 0) <0 ){
|
| + LOG(ERROR) << "failed to get the size needed for the process list";
|
| + kinfo_procs_.resize(0);
|
| + done = true;
|
| + } else {
|
| + size_t num_of_kinfo_proc = len / sizeof(struct kinfo_proc);
|
| + // Leave some spare room for process table growth (more could show up
|
| + // between when we check and now)
|
| + num_of_kinfo_proc += 16;
|
| + kinfo_procs_.resize(num_of_kinfo_proc);
|
| + len = num_of_kinfo_proc * sizeof(struct kinfo_proc);
|
| + if (sysctl(mib, arraysize(mib), &kinfo_procs_[0], &len, NULL, 0) <0) {
|
| + // If we get a mem error, it just means we need a bigger buffer, so
|
| + // loop around again. Anything else is a real error and give up.
|
| + if (errno != ENOMEM) {
|
| + LOG(ERROR) << "failed to get the process list";
|
| + kinfo_procs_.resize(0);
|
| + done = true;
|
| + }
|
| + } else {
|
| + // Got the list, just make sure we're sized exactly right
|
| + size_t num_of_kinfo_proc = len / sizeof(struct kinfo_proc);
|
| + kinfo_procs_.resize(num_of_kinfo_proc);
|
| + done = true;
|
| + }
|
| + }
|
| + } while (!done && (try_num++ < max_tries));
|
| +
|
| + if (!done) {
|
| + LOG(ERROR) << "failed to collect the process list in a few tries";
|
| + kinfo_procs_.resize(0);
|
| + }
|
| +}
|
| +
|
| +ProcessIterator::~ProcessIterator() {
|
| +}
|
| +
|
| +bool ProcessIterator::CheckForNextProcess() {
|
| + std::string data;
|
| +
|
| + for (; index_of_kinfo_proc_ < kinfo_procs_.size(); ++ index_of_kinfo_proc_) {
|
| + size_t length;
|
| + struct kinfo_proc kinfo = kinfo_procs_[index_of_kinfo_proc_];
|
| + int mib[] = { CTL_KERN, KERN_PROC_ARGS, kinfo.ki_pid };
|
| +
|
| + if ((kinfo.ki_pid > 0) && (kinfo.ki_stat == SZOMB))
|
| + continue;
|
| +
|
| + length = 0;
|
| + if (sysctl(mib, arraysize(mib), NULL, &length, NULL, 0) < 0) {
|
| + LOG(ERROR) << "failed to figure out the buffer size for a command line";
|
| + continue;
|
| + }
|
| +
|
| + data.resize(length);
|
| +
|
| + if (sysctl(mib, arraysize(mib), &data[0], &length, NULL, 0) < 0) {
|
| + LOG(ERROR) << "failed to fetch a commandline";
|
| + continue;
|
| + }
|
| +
|
| + std::string delimiters;
|
| + delimiters.push_back('\0');
|
| + Tokenize(data, delimiters, &entry_.cmd_line_args_);
|
| +
|
| + size_t exec_name_end = data.find('\0');
|
| + if (exec_name_end == std::string::npos) {
|
| + LOG(ERROR) << "command line data didn't match expected format";
|
| + continue;
|
| + }
|
| +
|
| + entry_.pid_ = kinfo.ki_pid;
|
| + entry_.ppid_ = kinfo.ki_ppid;
|
| + entry_.gid_ = kinfo.ki_pgid;
|
| +
|
| + size_t last_slash = data.rfind('/', exec_name_end);
|
| + if (last_slash == std::string::npos) {
|
| + entry_.exe_file_.assign(data, 0, exec_name_end);
|
| + } else {
|
| + entry_.exe_file_.assign(data, last_slash + 1,
|
| + exec_name_end - last_slash - 1);
|
| + }
|
| +
|
| + // Start w/ the next entry next time through
|
| + ++index_of_kinfo_proc_;
|
| +
|
| + return true;
|
| + }
|
| + return false;
|
| +}
|
| +
|
| +bool NamedProcessIterator::IncludeEntry() {
|
| + if(executable_name_ != entry().exe_file())
|
| + return false;
|
| +
|
| + return ProcessIterator::IncludeEntry();
|
| +}
|
| +
|
| +
|
| +ProcessMetrics::ProcessMetrics(ProcessHandle process)
|
| + : process_(process),
|
| + last_time_(0),
|
| + last_system_time_(0),
|
| + last_cpu_(0) {
|
| + processor_count_ = base::SysInfo::NumberOfProcessors();
|
| +}
|
| +
|
| +// static
|
| +ProcessMetrics* ProcessMetrics::CreateProcessMetrics(ProcessHandle process) {
|
| + return new ProcessMetrics(process);
|
| +}
|
| +
|
| +size_t ProcessMetrics::GetPagefileUsage() const {
|
| + struct kinfo_proc info;
|
| + int mib[] = { CTL_KERN, KERN_PROC, KERN_PROC_PID, process_ };
|
| + size_t length = sizeof(info);
|
| +
|
| + if (sysctl(mib, arraysize(mib), &info, &length, NULL, 0) < 0)
|
| + return 0;
|
| +
|
| + return info.ki_size;
|
| +}
|
| +
|
| +size_t ProcessMetrics::GetPeakPagefileUsage() const {
|
| + return 0;
|
| +}
|
| +
|
| +size_t ProcessMetrics::GetWorkingSetSize() const {
|
| + struct kinfo_proc info;
|
| + int mib[] = { CTL_KERN, KERN_PROC, KERN_PROC_PID, process_ };
|
| + size_t length = sizeof(info);
|
| +
|
| + if (sysctl(mib, arraysize(mib), &info, &length, NULL, 0) < 0)
|
| + return 0;
|
| +
|
| + return info.ki_rssize * getpagesize();
|
| +}
|
| +
|
| +size_t ProcessMetrics::GetPeakWorkingSetSize() const {
|
| + return 0;
|
| +}
|
| +
|
| +bool ProcessMetrics::GetMemoryBytes(size_t* private_bytes,
|
| + size_t* shared_bytes) {
|
| + WorkingSetKBytes ws_usage;
|
| + if (!GetWorkingSetKBytes(&ws_usage))
|
| + return false;
|
| +
|
| + if (private_bytes)
|
| + *private_bytes = ws_usage.priv << 10;
|
| +
|
| + if (shared_bytes)
|
| + *shared_bytes = ws_usage.shared * 1024;
|
| +
|
| + return true;
|
| +}
|
| +
|
| +bool ProcessMetrics::GetWorkingSetKBytes(WorkingSetKBytes* ws_usage) const {
|
| +// TODO(bapt) be sure we can't be precise
|
| + size_t priv = GetWorkingSetSize();
|
| + if (!priv)
|
| + return false;
|
| + ws_usage->priv = priv / 1024;
|
| + ws_usage->shareable = 0;
|
| + ws_usage->shared = 0;
|
| +
|
| + return true;
|
| +}
|
| +
|
| +bool ProcessMetrics::GetIOCounters(IoCounters* io_counters) const {
|
| + return false;
|
| +}
|
| +
|
| +double ProcessMetrics::GetCPUUsage() {
|
| + struct kinfo_proc info;
|
| + int mib[] = { CTL_KERN, KERN_PROC, KERN_PROC_PID, process_ };
|
| + size_t length = sizeof(info);
|
| +
|
| + struct timeval now;
|
| + int retval = gettimeofday(&now, NULL);
|
| + if (retval)
|
| + return 0;
|
| +
|
| + if (sysctl(mib, arraysize(mib), &info, &length, NULL, 0) < 0)
|
| + return 0;
|
| +
|
| + return (info.ki_pctcpu / FSCALE) * 100.0;
|
| +}
|
| +
|
| +size_t GetSystemCommitCharge() {
|
| + int mib[2], pagesize;
|
| + unsigned long mem_total, mem_free, mem_inactive;
|
| + size_t length = sizeof(mem_total);
|
| +
|
| + if (sysctl(mib, arraysize(mib), &mem_total, &length, NULL, 0) < 0)
|
| + return 0;
|
| +
|
| + length = sizeof(mem_free);
|
| + if (sysctlbyname("vm.stats.vm.v_free_count", &mem_free, &length, NULL, 0) < 0)
|
| + return 0;
|
| +
|
| + length = sizeof(mem_inactive);
|
| + if (sysctlbyname("vm.stats.vm.v_inactive_count", &mem_inactive, &length,
|
| + NULL, 0) < 0) {
|
| + return 0;
|
| + }
|
| +
|
| + pagesize = getpagesize();
|
| +
|
| + return mem_total - (mem_free*pagesize) - (mem_inactive*pagesize);
|
| +}
|
| +
|
| +void EnableTerminationOnOutOfMemory() {
|
| + DLOG(WARNING) << "Not feasible.";
|
| +}
|
| +
|
| +void EnableTerminationOnHeapCorruption() {
|
| + // Nothing to do.
|
| +}
|
| +
|
| +bool AdjustOOMScore(ProcessId process, int score) {
|
| + NOTIMPLEMENTED();
|
| + return false;
|
| +}
|
| +
|
| +} // namespace base
|
|
|