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
|
package util
import (
"fmt"
"github.com/mndrix/tap-go"
rspec "github.com/opencontainers/runtime-spec/specs-go"
"github.com/opencontainers/runtime-tools/cgroups"
)
// ValidateLinuxResourcesBlockIO validates linux.resources.blockIO.
func ValidateLinuxResourcesBlockIO(config *rspec.Spec, t *tap.T, state *rspec.State) error {
cg, err := cgroups.FindCgroup()
t.Ok((err == nil), "find blkio cgroup")
if err != nil {
t.Diagnostic(err.Error())
return nil
}
lbd, err := cg.GetBlockIOData(state.Pid, config.Linux.CgroupsPath)
t.Ok((err == nil), "get blkio cgroup data")
if err != nil {
t.Diagnostic(err.Error())
return nil
}
if lbd.Weight == nil || config.Linux.Resources.BlockIO.Weight == nil {
t.Diagnostic(fmt.Sprintf("unable to get weight: lbd.Weight == %v, config.Linux.Resources.BlockIO.Weight == %v", lbd.Weight, config.Linux.Resources.BlockIO.Weight))
return nil
}
t.Ok(*lbd.Weight == *config.Linux.Resources.BlockIO.Weight, "blkio weight is set correctly")
t.Diagnosticf("expect: %d, actual: %d", *config.Linux.Resources.BlockIO.Weight, *lbd.Weight)
if lbd.LeafWeight == nil || config.Linux.Resources.BlockIO.LeafWeight == nil {
t.Diagnostic(fmt.Sprintf("unable to get leafWeight: lbd.LeafWeight == %v, config.Linux.Resources.BlockIO.LeafWeight == %v", lbd.LeafWeight, config.Linux.Resources.BlockIO.LeafWeight))
return nil
}
t.Ok(*lbd.LeafWeight == *config.Linux.Resources.BlockIO.LeafWeight, "blkio leafWeight is set correctly")
t.Diagnosticf("expect: %d, actual: %d", *config.Linux.Resources.BlockIO.LeafWeight, *lbd.LeafWeight)
for _, device := range config.Linux.Resources.BlockIO.WeightDevice {
found := false
for _, wd := range lbd.WeightDevice {
if wd.Major == device.Major && wd.Minor == device.Minor {
found = true
t.Ok(*wd.Weight == *device.Weight, fmt.Sprintf("blkio weight for %d:%d is set correctly", device.Major, device.Minor))
t.Diagnosticf("expect: %d, actual: %d", *device.Weight, *wd.Weight)
t.Ok(*wd.LeafWeight == *device.LeafWeight, fmt.Sprintf("blkio leafWeight for %d:%d is set correctly", device.Major, device.Minor))
t.Diagnosticf("expect: %d, actual: %d", *device.LeafWeight, *wd.LeafWeight)
}
}
t.Ok(found, fmt.Sprintf("blkio weightDevice for %d:%d found", device.Major, device.Minor))
}
for _, device := range config.Linux.Resources.BlockIO.ThrottleReadBpsDevice {
found := false
for _, trbd := range lbd.ThrottleReadBpsDevice {
if trbd.Major == device.Major && trbd.Minor == device.Minor {
found = true
t.Ok(trbd.Rate == device.Rate, fmt.Sprintf("blkio read bps for %d:%d is set correctly", device.Major, device.Minor))
t.Diagnosticf("expect: %d, actual: %d", device.Rate, trbd.Rate)
}
}
t.Ok(found, fmt.Sprintf("blkio read bps for %d:%d found", device.Major, device.Minor))
}
for _, device := range config.Linux.Resources.BlockIO.ThrottleWriteBpsDevice {
found := false
for _, twbd := range lbd.ThrottleWriteBpsDevice {
if twbd.Major == device.Major && twbd.Minor == device.Minor {
found = true
t.Ok(twbd.Rate == device.Rate, fmt.Sprintf("blkio write bps for %d:%d is set correctly", device.Major, device.Minor))
t.Diagnosticf("expect: %d, actual: %d", device.Rate, twbd.Rate)
}
}
t.Ok(found, fmt.Sprintf("blkio write bps for %d:%d found", device.Major, device.Minor))
}
for _, device := range config.Linux.Resources.BlockIO.ThrottleReadIOPSDevice {
found := false
for _, trid := range lbd.ThrottleReadIOPSDevice {
if trid.Major == device.Major && trid.Minor == device.Minor {
found = true
t.Ok(trid.Rate == device.Rate, fmt.Sprintf("blkio read iops for %d:%d is set correctly", device.Major, device.Minor))
t.Diagnosticf("expect: %d, actual: %d", device.Rate, trid.Rate)
}
}
t.Ok(found, fmt.Sprintf("blkio read iops for %d:%d found", device.Major, device.Minor))
}
for _, device := range config.Linux.Resources.BlockIO.ThrottleWriteIOPSDevice {
found := false
for _, twid := range lbd.ThrottleWriteIOPSDevice {
if twid.Major == device.Major && twid.Minor == device.Minor {
found = true
t.Ok(twid.Rate == device.Rate, fmt.Sprintf("blkio write iops for %d:%d is set correctly", device.Major, device.Minor))
t.Diagnosticf("expect: %d, actual: %d", device.Rate, twid.Rate)
}
}
t.Ok(found, fmt.Sprintf("blkio write iops for %d:%d found", device.Major, device.Minor))
}
return nil
}
|
