1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
|
package flamegraph
import (
"context"
"fmt"
"ior/internal/event"
"ior/internal/flags"
"runtime"
"sync"
)
// TODO: Add Command in path! Make it configurable? comm/syscall/path, or path/syscall/comm, etc...
// TODO: Idea, show time spent between the syscalls (off syscalls) as well, but in a different color
type Flamegraph struct {
flags flags.Flags
Ch chan *event.Pair
Done chan struct{}
workers []worker
}
func New() Flamegraph {
f := Flamegraph{
Ch: make(chan *event.Pair, 4096),
Done: make(chan struct{}),
}
numWorkers := runtime.NumCPU() / 4
if numWorkers == 0 {
numWorkers = 1
}
for range numWorkers {
f.workers = append(f.workers, newWorker())
}
return f
}
func (f Flamegraph) Start(ctx context.Context) {
go func() {
defer close(f.Done)
var wg sync.WaitGroup
wg.Add(len(f.workers))
for i, worker := range f.workers {
fmt.Println("Starting flamegraph worker", i)
if flags.Get().FlamegraphName == "" { // Empty string means: old style collapsed
go worker.runCollapsed(ctx, &wg, f.Ch)
} else {
go worker.run(ctx, &wg, f.Ch)
}
}
wg.Wait()
// COLLAPSED: Will be removed, once migrated to iorData
if f.flags.FlamegraphName == "" { // Empty string means: old style collapsed
collapsed := f.workers[0].collapsed
if len(f.workers) > 1 {
for i, c := range f.workers[1:] {
fmt.Println("Worker", i+1, "merged", collapsed.merge(c.collapsed),
"counters =>", len(collapsed), "total counters")
}
}
collapsed.dump()
}
}()
}
|
