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
65
66
67
68
69
70
71
72
73
74
75
76
77
78
79
80
81
82
83
84
85
86
87
88
89
90
91
92
93
94
95
96
97
98
99
100
101
102
103
104
105
106
|
package event
import (
"fmt"
"ior/internal/file"
. "ior/internal/types"
"strconv"
"strings"
"sync"
)
var poolOfEventPairs = sync.Pool{
New: func() interface{} { return &Pair{} },
}
type Event interface {
String() string
GetTraceId() TraceId
GetPid() uint32
GetTid() uint32
GetTime() uint64
Recycle()
}
// Represents a pair of enter and exit events (e.g. entering the syscall + exiting it)
type Pair struct {
EnterEv, ExitEv Event
File file.File
Comm string
Duration uint64
TracepointMismatch bool
// To calculate the time difference from the previoud event.
PrevPair *Pair
durationToPrev uint64
}
func NewPair(enterEv Event) *Pair {
e := poolOfEventPairs.Get().(*Pair)
e.EnterEv = enterEv
return e
}
func (e *Pair) CalculateDurations() {
e.Duration = e.ExitEv.GetTime() - e.EnterEv.GetTime()
if e.PrevPair != nil {
e.durationToPrev = e.EnterEv.GetTime() - e.PrevPair.ExitEv.GetTime()
}
}
func (e *Pair) Is(id TraceId) bool {
return e.EnterEv.GetTraceId() == id
}
const EventStreamHeader = "durationToPrevNs,durationNs,comm,pid.tid,name,ret,notice,file"
func (e *Pair) String() string {
var sb strings.Builder
sb.WriteString(fmt.Sprintf("%08d,%08d", e.durationToPrev, e.Duration))
sb.WriteString(",")
sb.WriteString(e.Comm)
sb.WriteString(",")
sb.WriteString(strconv.FormatInt(int64(e.EnterEv.GetPid()), 10))
sb.WriteString(".")
sb.WriteString(strconv.FormatInt(int64(e.EnterEv.GetTid()), 10))
sb.WriteString(",")
sb.WriteString(e.EnterEv.GetTraceId().Name())
sb.WriteString(",")
if retEv, ok := e.ExitEv.(*RetEvent); ok {
sb.WriteString(strconv.FormatInt(int64(retEv.Ret), 10))
}
sb.WriteString(",")
sb.WriteString(e.File.String())
if e.TracepointMismatch {
sb.WriteString(",MISMATCH")
}
return sb.String()
}
func (e *Pair) Dump() string {
return fmt.Sprintf("%v with enterEv(%v) and exitEv(%v)", e, e.EnterEv, e.ExitEv)
}
func (e *Pair) Recycle() {
e.EnterEv.Recycle()
e.ExitEv.Recycle()
e.PrevPair = nil
poolOfEventPairs.Put(e)
}
// Only recycle the previous event, as the current event is the previous event of the next event!
// And the previous event is required for calculation of durationToPrev!
func (e *Pair) RecyclePrev() {
if e.PrevPair == nil {
return
}
e.PrevPair.Recycle()
}
|
