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
|
// Copyright Yahoo. Licensed under the terms of the Apache 2.0 license. See LICENSE in the project root.
package com.yahoo.vespa.hosted.node.admin.cgroup;
import com.yahoo.collections.Pair;
import com.yahoo.vespa.hosted.node.admin.component.TaskContext;
import java.util.Arrays;
import java.util.Map;
import java.util.Optional;
import java.util.stream.Collectors;
import static java.lang.Integer.parseInt;
/**
* Represents a cgroup v2 CPU controller, i.e. all cpu.* files.
*
* @author hakonhall
*/
public class CpuController {
private final Cgroup cgroup;
CpuController(Cgroup cgroup) {
this.cgroup = cgroup;
}
/**
* The maximum bandwidth limit of the format "QUOTA PERIOD", which indicates that the cgroup may consume
* up to QUOTA in each PERIOD duration. A quota of "max" indicates no limit.
*/
public record Max(Size quota, int period) {
public String toFileContent() { return quota + " " + period + '\n'; }
}
/**
* Returns the maximum CPU usage, or empty if cgroup is not found.
*
* @see Max
*/
public Optional<Max> readMax() {
return cgroup.readIfExists("cpu.max")
.map(content -> {
String[] parts = content.strip().split(" ");
return new Max(Size.from(parts[0]), parseInt(parts[1]));
});
}
/**
* Update CPU quota and period for the given container ID. Set quota to -1 value for unlimited.
*
* @see #readMax()
* @see Max
*/
public boolean updateMax(TaskContext context, int quota, int period) {
Max max = new Max(quota < 0 ? Size.max() : Size.from(quota), period);
return cgroup.convergeFileContent(context, "cpu.max", max.toFileContent(), true);
}
/** @return The weight in the range [1, 10000], or empty if not found. */
private Optional<Integer> readWeight() {
return cgroup.readIntIfExists("cpu.weight");
}
/** @return The number of shares allocated to this cgroup for purposes of CPU time scheduling, or empty if not found. */
public Optional<Integer> readShares() {
return readWeight().map(CpuController::weightToShares);
}
public boolean updateShares(TaskContext context, int shares) {
return cgroup.convergeFileContent(context, "cpu.weight", sharesToWeight(shares) + "\n", true);
}
// Must be same as in crun: https://github.com/containers/crun/blob/72c6e60ade0e4716fe2d8353f0d97d72cc8d1510/src/libcrun/cgroup.c#L3061
// TODO: Migrate to weights
public static int sharesToWeight(int shares) { return (int) (1 + ((shares - 2L) * 9999) / 262142); }
public static int weightToShares(int weight) { return (int) (2 + ((weight - 1L) * 262142) / 9999); }
public enum StatField {
TOTAL_USAGE_USEC("usage_usec"),
USER_USAGE_USEC("user_usec"),
SYSTEM_USAGE_USEC("system_usec"),
TOTAL_PERIODS("nr_periods"),
THROTTLED_PERIODS("nr_throttled"),
THROTTLED_TIME_USEC("throttled_usec");
private final String name;
StatField(String name) {
this.name = name;
}
long parseValue(String value) {
return Long.parseLong(value);
}
static Optional<StatField> fromField(String fieldName) {
return Arrays.stream(values())
.filter(field -> fieldName.equals(field.name))
.findFirst();
}
}
public Map<StatField, Long> readStats() {
return cgroup.readLines("cpu.stat")
.stream()
.map(line -> line.split("\\s+"))
.filter(parts -> parts.length == 2)
.flatMap(parts -> StatField.fromField(parts[0]).stream().map(field -> new Pair<>(field, field.parseValue(parts[1]))))
.collect(Collectors.toMap(Pair::getFirst, Pair::getSecond));
}
}
|
