/
activators.go
205 lines (180 loc) · 6.53 KB
/
activators.go
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
107
108
109
110
111
112
113
114
115
116
117
118
119
120
121
122
123
124
125
126
127
128
129
130
131
132
133
134
135
136
137
138
139
140
141
142
143
144
145
146
147
148
149
150
151
152
153
154
155
156
157
158
159
160
161
162
163
164
165
166
167
168
169
170
171
172
173
174
175
176
177
178
179
180
181
182
183
184
185
186
187
188
189
190
191
192
193
194
195
196
197
198
199
200
201
202
203
204
205
//go:build linux && amd64
// +build linux,amd64
package intel_pmu
import (
"errors"
"fmt"
ia "github.com/intel/iaevents"
)
type placementMaker interface {
makeCorePlacements(cores []int, factory ia.PlacementFactory) ([]ia.PlacementProvider, error)
makeUncorePlacements(socket int, factory ia.PlacementFactory) ([]ia.PlacementProvider, error)
}
type iaPlacementMaker struct{}
func (iaPlacementMaker) makeCorePlacements(cores []int, factory ia.PlacementFactory) ([]ia.PlacementProvider, error) {
var err error
var corePlacements []ia.PlacementProvider
switch len(cores) {
case 0:
return nil, errors.New("no cores provided")
case 1:
corePlacements, err = ia.NewCorePlacements(factory, cores[0])
if err != nil {
return nil, err
}
default:
corePlacements, err = ia.NewCorePlacements(factory, cores[0], cores[1:]...)
if err != nil {
return nil, err
}
}
return corePlacements, nil
}
func (iaPlacementMaker) makeUncorePlacements(socket int, factory ia.PlacementFactory) ([]ia.PlacementProvider, error) {
return ia.NewUncoreAllPlacements(factory, socket)
}
type eventsActivator interface {
activateEvent(ia.Activator, ia.PlacementProvider, ia.Options) (*ia.ActiveEvent, error)
activateGroup(ia.PlacementProvider, []ia.CustomizableEvent) (*ia.ActiveEventGroup, error)
activateMulti(ia.MultiActivator, []ia.PlacementProvider, ia.Options) (*ia.ActiveMultiEvent, error)
}
type iaEventsActivator struct{}
func (iaEventsActivator) activateEvent(a ia.Activator, p ia.PlacementProvider, o ia.Options) (*ia.ActiveEvent, error) {
return a.Activate(p, ia.NewEventTargetProcess(-1, 0), o)
}
func (iaEventsActivator) activateGroup(p ia.PlacementProvider, e []ia.CustomizableEvent) (*ia.ActiveEventGroup, error) {
return ia.ActivateGroup(p, ia.NewEventTargetProcess(-1, 0), e)
}
func (iaEventsActivator) activateMulti(a ia.MultiActivator, p []ia.PlacementProvider, o ia.Options) (*ia.ActiveMultiEvent, error) {
return a.ActivateMulti(p, ia.NewEventTargetProcess(-1, 0), o)
}
type entitiesActivator interface {
activateEntities(coreEntities []*CoreEventEntity, uncoreEntities []*UncoreEventEntity) error
}
type iaEntitiesActivator struct {
placementMaker placementMaker
perfActivator eventsActivator
}
func (ea *iaEntitiesActivator) activateEntities(coreEntities []*CoreEventEntity, uncoreEntities []*UncoreEventEntity) error {
for _, coreEventsEntity := range coreEntities {
err := ea.activateCoreEvents(coreEventsEntity)
if err != nil {
return fmt.Errorf("failed to activate core events `%s`: %v", coreEventsEntity.EventsTag, err)
}
}
for _, uncoreEventsEntity := range uncoreEntities {
err := ea.activateUncoreEvents(uncoreEventsEntity)
if err != nil {
return fmt.Errorf("failed to activate uncore events `%s`: %v", uncoreEventsEntity.EventsTag, err)
}
}
return nil
}
func (ea *iaEntitiesActivator) activateCoreEvents(entity *CoreEventEntity) error {
if entity == nil {
return fmt.Errorf("core events entity is nil")
}
if ea.placementMaker == nil {
return fmt.Errorf("placement maker is nil")
}
if entity.PerfGroup {
err := ea.activateCoreEventsGroup(entity)
if err != nil {
return fmt.Errorf("failed to activate core events group: %v", err)
}
} else {
for _, event := range entity.parsedEvents {
if event == nil {
return fmt.Errorf("core parsed event is nil")
}
placements, err := ea.placementMaker.makeCorePlacements(entity.parsedCores, event.custom.Event)
if err != nil {
return fmt.Errorf("failed to create core placements for event `%s`: %v", event.name, err)
}
activeEvent, err := ea.activateEventForPlacements(event, placements)
if err != nil {
return fmt.Errorf("failed to activate core event `%s`: %v", event.name, err)
}
entity.activeEvents = append(entity.activeEvents, activeEvent...)
}
}
return nil
}
func (ea *iaEntitiesActivator) activateUncoreEvents(entity *UncoreEventEntity) error {
if entity == nil {
return fmt.Errorf("uncore events entity is nil")
}
if ea.perfActivator == nil || ea.placementMaker == nil {
return fmt.Errorf("events activator or placement maker is nil")
}
for _, event := range entity.parsedEvents {
if event == nil {
return fmt.Errorf("uncore parsed event is nil")
}
perfEvent := event.custom.Event
if perfEvent == nil {
return fmt.Errorf("perf event of `%s` event is nil", event.name)
}
options := event.custom.Options
for _, socket := range entity.parsedSockets {
placements, err := ea.placementMaker.makeUncorePlacements(socket, perfEvent)
if err != nil {
return fmt.Errorf("failed to create uncore placements for event `%s`: %v", event.name, err)
}
activeMultiEvent, err := ea.perfActivator.activateMulti(perfEvent, placements, options)
if err != nil {
return fmt.Errorf("failed to activate multi event `%s`: %v", event.name, err)
}
events := activeMultiEvent.Events()
entity.activeMultiEvents = append(entity.activeMultiEvents, multiEvent{events, perfEvent, socket})
}
}
return nil
}
func (ea *iaEntitiesActivator) activateCoreEventsGroup(entity *CoreEventEntity) error {
if ea.perfActivator == nil || ea.placementMaker == nil {
return fmt.Errorf("missing perf activator or placement maker")
}
if entity == nil || len(entity.parsedEvents) < 1 {
return fmt.Errorf("missing parsed events")
}
var events []ia.CustomizableEvent
for _, event := range entity.parsedEvents {
if event == nil {
return fmt.Errorf("core event is nil")
}
events = append(events, event.custom)
}
leader := entity.parsedEvents[0].custom
placements, err := ea.placementMaker.makeCorePlacements(entity.parsedCores, leader.Event)
if err != nil {
return fmt.Errorf("failed to make core placements: %v", err)
}
for _, plc := range placements {
activeGroup, err := ea.perfActivator.activateGroup(plc, events)
if err != nil {
return err
}
entity.activeEvents = append(entity.activeEvents, activeGroup.Events()...)
}
return nil
}
func (ea *iaEntitiesActivator) activateEventForPlacements(event *eventWithQuals, placements []ia.PlacementProvider) ([]*ia.ActiveEvent, error) {
if event == nil {
return nil, fmt.Errorf("core event is nil")
}
if ea.perfActivator == nil {
return nil, fmt.Errorf("missing perf activator")
}
var activeEvents []*ia.ActiveEvent
for _, placement := range placements {
perfEvent := event.custom.Event
options := event.custom.Options
activeEvent, err := ea.perfActivator.activateEvent(perfEvent, placement, options)
if err != nil {
return nil, fmt.Errorf("failed to activate event `%s`: %v", event.name, err)
}
activeEvents = append(activeEvents, activeEvent)
}
return activeEvents, nil
}