TrxShell [ mangaberri.com ]

Name	Size	Permission
fs	[ DIR ]	drwxr-xr-x
__init__.python	0 B	-rw-r--r--
biolatency.bpf	783 B	-rw-r--r--
biolatency.python	3.83 KB	-rw-r--r--
bioperpid.python	4.56 KB	-rw-r--r--
biotop.bpf	2.88 KB	-rw-r--r--
biotop.python	7.62 KB	-rw-r--r--
cachestat.bpf	487 B	-rw-r--r--
cachestat.python	4.63 KB	-rw-r--r--
execsnoop.bpf	2.95 KB	-rw-r--r--
execsnoop.python	7.39 KB	-rw-r--r--
exectop.bpf	491 B	-rw-r--r--
exectop.python	2.61 KB	-rw-r--r--
klockstat.bpf	4.9 KB	-rw-r--r--
klockstat.python	7.92 KB	-rw-r--r--
kprobe_hits.bpf	718 B	-rw-r--r--
kprobe_hits.python	12.39 KB	-rw-r--r--
netproc.bpf	2.29 KB	-rw-r--r--
netproc.python	6.78 KB	-rw-r--r--
pcpbcc.python	14.37 KB	-rw-r--r--
profile.bpf	1.84 KB	-rw-r--r--
profile.python	11.64 KB	-rw-r--r--
runqlat.python	5.64 KB	-rw-r--r--
runqlat_kp.bpf	2.92 KB	-rw-r--r--
runqlat_tp.bpf	3.15 KB	-rw-r--r--
syscount.bpf	1.44 KB	-rw-r--r--
syscount.python	9.87 KB	-rw-r--r--
sysfork.bpf	392 B	-rw-r--r--
sysfork.python	2.35 KB	-rw-r--r--
tcplife.python	8.94 KB	-rw-r--r--
tcplife_kp.bpf	4.88 KB	-rw-r--r--
tcplife_tp.bpf	4.95 KB	-rw-r--r--
tcpperpid.python	9.96 KB	-rw-r--r--
tcpretrans.python	5.03 KB	-rw-r--r--
tcpretrans_count.bpf	2.75 KB	-rw-r--r--
tcptop.bpf	3.33 KB	-rw-r--r--
tcptop.python	9.38 KB	-rw-r--r--
tracepoint_hits.bpf	214 B	-rw-r--r--
tracepoint_hits.python	6.92 KB	-rw-r--r--
ucalls.bpf	1.99 KB	-rw-r--r--
ucalls.python	8.41 KB	-rw-r--r--
uprobe_hits.bpf	223 B	-rw-r--r--
uprobe_hits.python	5.55 KB	-rw-r--r--
usdt_hits.bpf	215 B	-rw-r--r--
usdt_hits.python	6.32 KB	-rw-r--r--
usdt_jvm_threads.bpf	429 B	-rw-r--r--
usdt_jvm_threads.python	4.29 KB	-rw-r--r--
ustat.python	11.99 KB	-rw-r--r--

Code Editor : runqlat.python

#
# Copyright (C) 2018 Andreas Gerstmayr <andreas@gerstmayr.me>
# Based on the runqlat BCC tool by Brendan Gregg:
# https://github.com/iovisor/bcc/blob/master/tools/runqlat.py
#
# This program is free software; you can redistribute it and/or modify
# it under the terms of the GNU General Public License as published by
# the Free Software Foundation; either version 2 of the License, or
# (at your option) any later version.
#
# This program is distributed in the hope that it will be useful,
# but WITHOUT ANY WARRANTY; without even the implied warranty of
# MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE.  See the
# GNU General Public License for more details.
#
""" PCP BCC PMDA runqlat module """

# pylint: disable=invalid-name

from os import path

from bcc import BPF

from pcp.pmapi import pmUnits
from cpmapi import PM_TYPE_U64, PM_SEM_COUNTER, PM_TIME_USEC
from cpmda import PMDA_FETCH_NOVALUES

from modules.pcpbcc import PCPBCCBase

#
# BPF program
#
is_support_raw_tp = BPF.support_raw_tracepoint()
if is_support_raw_tp:
    bpf_src = "modules/runqlat_tp.bpf"
else:
    bpf_src = "modules/runqlat_kp.bpf"

#
# PCP BCC PMDA constants
#
MODULE = 'runqlat'
METRIC = 'runq.latency'
units_usecs = pmUnits(0, 1, 0, 0, PM_TIME_USEC, 0)

#
# PCP BCC Module
#
class PCPBCCModule(PCPBCCBase):
    """ PCP BCC runqlat module """
    def __init__(self, config, log, err, proc_refresh):
        """ Constructor """
        PCPBCCBase.__init__(self, MODULE, config, log, err)

self.pids = []
        self.proc_filter = None
        self.proc_refresh = proc_refresh

self.cache = None

for opt in self.config.options(MODULE):
            if opt == 'process':
                self.proc_filter = self.config.get(MODULE, opt)
                self.update_pids(self.get_proc_info(self.proc_filter))

self.log("Using BPF source file %s." % bpf_src)
        self.log("Initialized.")

def metrics(self):
        """ Get metric definitions """
        name = METRIC
        self.items.append(
            # Name - reserved - type - semantics - units - help
            (name, None, PM_TYPE_U64, PM_SEM_COUNTER, units_usecs, 'run queue (scheduler)'
                                                                   'latency distribution'),
        )
        return True, self.items

def reset_cache(self):
        """ Reset internal cache """
        self.cache = {}

def undef_cache(self):
        """ Undefine internal cache """
        self.cache = None

def compile(self):
        """ Compile BPF """
        try:
            if not self.pids and self.proc_filter and not self.proc_refresh:
                raise RuntimeError("No process to attach found.")

if not self.bpf_text:
                with open(path.dirname(__file__) + '/../' + bpf_src) as src:
                    self.bpf_text = src.read()

# BPF.kernel_struct_has_field requires BCC v0.23.0
                # use kernel version check as alternative
                # pylint: disable=no-member
                if (
                    hasattr(BPF, "kernel_struct_has_field")
                    and BPF.kernel_struct_has_field(b"task_struct", b"__state") == 1
                ) or self.kernel_version() >= (5, 14, 0):
                    self.bpf_text = self.bpf_text.replace('STATE_FIELD', '__state')
                else:
                    self.bpf_text = self.bpf_text.replace('STATE_FIELD', 'state')

self.bpf_text = self.bpf_text.replace("FILTER", "PID_CHECK")
                self.bpf_text = self.bpf_text.replace('FACTOR', 'delta /= 1000;')

self.bpf_text = self.bpf_text.replace('STORAGE', 'BPF_HISTOGRAM(dist);')
                self.bpf_text = self.bpf_text.replace('STORE',
                    'dist.increment(bpf_log2l(delta));')

if not self.pids and self.proc_filter and self.proc_refresh:
                self.log("No process to attach found, activation postponed.")
                return

bpf_text = self.apply_pid_filter(self.bpf_text, self.pids)

if self.debug:
                self.log("BPF to be compiled:\n" + bpf_text.strip())

self.reset_cache()
            self.bpf = BPF(text=bpf_text)
            if not is_support_raw_tp:
                self.bpf.attach_kprobe(event="ttwu_do_wakeup", fn_name="trace_ttwu_do_wakeup")
                self.bpf.attach_kprobe(event="wake_up_new_task", fn_name="trace_wake_up_new_task")
                self.bpf.attach_kprobe(event_re=r"^finish_task_switch$|^finish_task_switch\.isra\.\d$",
                                       fn_name="trace_run")
            self.log("Compiled.")
        except Exception as error: # pylint: disable=broad-except
            self.bpf = None
            self.undef_cache()
            self.err(str(error))
            self.err("Module NOT active!")
            raise

def refresh(self):
        """ Refresh BPF data """
        if self.bpf is None:
            return None

dist = self.bpf["dist"]
        self.insts = self.read_log2_histogram(dist, self.cache)
        dist.clear()

return self.insts

def bpfdata(self, item, inst):
        """ Return BPF data as PCP metric value """
        try:
            key = self.pmdaIndom.inst_name_lookup(inst)
            return [self.cache[key], 1]
        except Exception: # pylint: disable=broad-except
            return [PMDA_FETCH_NOVALUES, 0]

def label_indom(self):
        """ Instance domain labels """
        return '{"statistic":"histogram"}'

def label_instance(self, inst):
        """ Instance labels """
        key = self.pmdaIndom.inst_name_lookup(inst)
        bounds = key.split('-')
        return '{"lower_bound":%s,"upper_bound":%s}' % (bounds[0], bounds[1])

${this.title}

Code Editor : runqlat.python