timeline.go RawHistoryFolder

1// SPDX-License-Identifier: MIT
2
3package host
4
5import "time"
6
7// timeline is the per-phase timing of a job, logged on its "job finished"
8// line: durations in milliseconds (the *_ms keys) and counters. A jobRun
9// creates it once, in startJob; it is guarded by jobRun.mu.
10type timeline map[string]int64
11
12// setMs records d as the duration of a phase, in whole milliseconds.
13func (t timeline) setMs(key string, d time.Duration) { t[key] = max(0, d.Milliseconds()) }
14
15// addMs adds d to the summed duration of a phase that may run several times.
16func (t timeline) addMs(key string, d time.Duration) { t[key] += max(0, d.Milliseconds()) }
17
18// add adds n to a counter.
19func (t timeline) add(key string, n int64) { t[key] += n }
20
21// guestBootKeys are the boot phases the guest may report in its Hello: the
22// host logs these as guest_<key>_ms and ignores any other key, as it does not
23// trust the guest.
24var guestBootKeys = []string{"kernel", "setup", "containerd", "dockerd"}
25
26// addGuestBoot records the guest's boot phases: known keys with a value of
27// at least 0.
28func (t timeline) addGuestBoot(ms map[string]int64) {
29	for _, k := range guestBootKeys {
30		if v, ok := ms[k]; ok && v >= 0 {
31			t["guest_"+k+"_ms"] = v
32		}
33	}
34}
35
36func (j *jobRun) timeSet(key string, d time.Duration) {
37	j.mu.Lock()
38	defer j.mu.Unlock()
39	j.timeline.setMs(key, d)
40}
41
42// timingFields sets total_ms and returns a copy of the timeline for the log.
43func (j *jobRun) timingFields() map[string]any {
44	j.mu.Lock()
45	defer j.mu.Unlock()
46	j.timeline.setMs("total_ms", time.Since(j.receivedAt))
47	fields := make(map[string]any, len(j.timeline))
48	for k, v := range j.timeline {
49		fields[k] = v
50	}
51	return fields
52}