mirror of
https://github.com/weaveworks/scope.git
synced 2026-05-05 16:59:36 +00:00
560cf66454
- Move pidtree to its own module and disaggregate it into tree, walker and reporter. - Extend testing for probe/process - Extend process metadata; add command line & # threads.
62 lines
1.3 KiB
Go
62 lines
1.3 KiB
Go
package process
|
|
|
|
import (
|
|
"strconv"
|
|
|
|
"github.com/weaveworks/scope/probe/tag"
|
|
"github.com/weaveworks/scope/report"
|
|
)
|
|
|
|
// We use these keys in node metadata
|
|
const (
|
|
PID = "pid"
|
|
Comm = "comm"
|
|
PPID = "ppid"
|
|
Cmdline = "cmdline"
|
|
Threads = "threads"
|
|
)
|
|
|
|
// Reporter generate Reports containing the Process topology
|
|
type reporter struct {
|
|
procRoot string
|
|
scope string
|
|
}
|
|
|
|
// NewReporter makes a new Reporter
|
|
func NewReporter(procRoot, scope string) tag.Reporter {
|
|
return &reporter{
|
|
procRoot: procRoot,
|
|
scope: scope,
|
|
}
|
|
}
|
|
|
|
// Report generates a Report containing the Process topology
|
|
func (r *reporter) Report() (report.Report, error) {
|
|
result := report.MakeReport()
|
|
processes, err := r.processTopology()
|
|
if err != nil {
|
|
return result, err
|
|
}
|
|
result.Process.Merge(processes)
|
|
return result, nil
|
|
}
|
|
|
|
func (r *reporter) processTopology() (report.Topology, error) {
|
|
t := report.NewTopology()
|
|
err := Walk(r.procRoot, func(p *Process) {
|
|
pidstr := strconv.Itoa(p.PID)
|
|
nodeID := report.MakeProcessNodeID(r.scope, pidstr)
|
|
t.NodeMetadatas[nodeID] = report.NodeMetadata{
|
|
PID: pidstr,
|
|
Comm: p.Comm,
|
|
Cmdline: p.Cmdline,
|
|
Threads: strconv.Itoa(p.Threads),
|
|
}
|
|
if p.PPID > 0 {
|
|
t.NodeMetadatas[nodeID][PPID] = strconv.Itoa(p.PPID)
|
|
}
|
|
})
|
|
|
|
return t, err
|
|
}
|