-
Notifications
You must be signed in to change notification settings - Fork 51
/
default.go
38 lines (26 loc) · 998 Bytes
/
default.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
package counters
import (
"sync/atomic"
"go.aporeto.io/trireme-lib/collector"
)
// Bad PU to hold counters for packets we know nothing about. We cant figure out context
var defaultCounters = NewCounters()
// CounterError is a convinence function which returns error as well as increments the counter.
func CounterError(t CounterType, err error) error { // nolint
atomic.AddUint32(&defaultCounters.counters[int(t)], 1)
return err
}
// IncrementCounter increments counters for a given PU
func IncrementCounter(err CounterType) {
atomic.AddUint32(&defaultCounters.counters[int(err)], 1)
}
// GetErrorCounters returns the error counters and resets the counters to zero
func GetErrorCounters() []collector.Counters {
defaultCounters.Lock()
defer defaultCounters.Unlock()
report := make([]collector.Counters, totalCounters)
for index := range defaultCounters.counters {
report[index] = collector.Counters(atomic.SwapUint32(&defaultCounters.counters[index], 0))
}
return report
}