Class: LogStash::Instrument::PeriodicPoller::Cgroup

Inherits:

Object

• Object
• LogStash::Instrument::PeriodicPoller::Cgroup

Includes:

Util::Loggable

Defined in:

lib/logstash/instrument/periodic_poller/cgroup.rb

Defined Under Namespace

Modules: ControllerResource Classes: CGroupResources, CpuAcctResource, CpuResource, CpuStats, Override, UnimplementedResource

Constant Summary

CGROUP_FILE =

/proc/self/cgroup contents look like this 5:cpu,cpuacct:/ 4:cpuset:/ 2:net_cls,net_prio:/ 0::/user.slice/user-1000.slice/session-932.scope e.g. N:controller:/path-to-info we find the controller and path we skip the line without a controller e.g. 0::/path we assume there are these symlinks: /sys/fs/cgroup/cpu -> /sys/fs/cgroup/cpu,cpuacct /sys/fs/cgroup/cpuacct->/sys/fs/cgroup/cpu,cpuacct

"/proc/self/cgroup"

CPUACCT_DIR =

"/sys/fs/cgroup/cpuacct"

CPU_DIR =

"/sys/fs/cgroup/cpu"

CRITICAL_PATHS =

[CGROUP_FILE, CPUACCT_DIR, CPU_DIR]

CONTROLLER_CPUACCT_LABEL =

"cpuacct"

CONTROLLER_CPU_LABEL =

"cpu"

CGROUP_RESOURCES =

CGroupResources.new

Class Method Summary

• .get ⇒ Object
• .get_all ⇒ Object

Class Method Details

.get ⇒ Object

# File 'lib/logstash/instrument/periodic_poller/cgroup.rb', line 214

def get
  get_all
end

.get_all ⇒ Object

# File 'lib/logstash/instrument/periodic_poller/cgroup.rb', line 190

def get_all
  unless CGROUP_RESOURCES.cgroup_available?
    logger.debug("One or more required cgroup files or directories not found: #{CRITICAL_PATHS.join(', ')}")
    return
  end

  groups = CGROUP_RESOURCES.controller_groups

  if groups.empty?
    logger.debug("The main cgroup file did not have any controllers: #{CGROUP_FILE}")
    return
  end

  cgroups_stats = {}
  groups.each do |name, controller|
    next unless controller.implemented?
    cgroups_stats[name.to_sym] = controller.to_hash
  end
  cgroups_stats
rescue => e
  logger.debug("Error, cannot retrieve cgroups information", :exception => e.class.name, :message => e.message, :backtrace => e.backtrace.take(4)) if logger.debug?
  nil
end