rd-agent-intf 2.0.0-alpha

Management agent for resctl-demo (interface library)
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 (c) Facebook, Inc. and its affiliates.
use serde::{Deserialize, Serialize};

use rd_util::*;

const OOMD_DOC: &str = "\
//
// rd-agent OOMD configurations
//
//  disable_seq: Disable OOMD if >= report::seq
//  workload.mem_pressure.disable_seq: Disable memory pressure protection in
//                                     workload.slice if >= report::seq
//  workload.mem_pressure.threshold: Pressure threshold
//  workload.mem_pressure.threshold: Pressure duration
//  workload.senpai.enable: Enable senpai in workload.slice
//  workload.senpai.*: Senpai parameters
//  system.*: The same set of parameters for system.slice
//  swap_enable: Enable swap depletion protection
//  swap_threshold: Swap depletion protection free space threshold in %
//
";

#[derive(Clone, PartialEq, Serialize, Deserialize)]
pub struct OomdSliceMemPressureKnobs {
    pub disable_seq: u64,
    pub threshold: u32,
    pub duration: u32,
}

#[derive(Clone, PartialEq, Serialize, Deserialize)]
pub struct OomdSliceSenpaiKnobs {
    pub enable: bool,
    pub min_bytes_frac: f64,
    pub max_bytes_frac: f64,
    pub interval: u32,
    pub stall_threshold: f64,
    pub max_probe: f64,
    pub max_backoff: f64,
    pub coeff_probe: f64,
    pub coeff_backoff: f64,
}

impl Default for OomdSliceSenpaiKnobs {
    fn default() -> Self {
        Self {
            enable: false,
            min_bytes_frac: 0.0,
            max_bytes_frac: 1.0,
            interval: 2,
            stall_threshold: 0.075,
            max_probe: 0.01,
            max_backoff: 1.0,
            coeff_probe: 10.0,
            coeff_backoff: 20.0,
        }
    }
}

#[derive(Clone, PartialEq, Serialize, Deserialize)]
pub struct OomdSliceKnobs {
    pub mem_pressure: OomdSliceMemPressureKnobs,
    pub senpai: OomdSliceSenpaiKnobs,
}

#[derive(Clone, PartialEq, Serialize, Deserialize)]
pub struct OomdKnobs {
    pub disable_seq: u64,
    pub workload: OomdSliceKnobs,
    pub system: OomdSliceKnobs,
    pub swap_enable: bool,
    pub swap_threshold: u32,
}

impl Default for OomdKnobs {
    fn default() -> Self {
        Self {
            disable_seq: 0,
            workload: OomdSliceKnobs {
                mem_pressure: OomdSliceMemPressureKnobs {
                    disable_seq: 0,
                    threshold: 50,
                    duration: 30,
                },
                senpai: OomdSliceSenpaiKnobs {
                    min_bytes_frac: 0.25,
                    ..Default::default()
                },
            },
            system: OomdSliceKnobs {
                mem_pressure: OomdSliceMemPressureKnobs {
                    disable_seq: 0,
                    threshold: 50,
                    duration: 30,
                },
                senpai: OomdSliceSenpaiKnobs {
                    ..Default::default()
                },
            },
            swap_enable: true,
            swap_threshold: 10,
        }
    }
}

impl JsonLoad for OomdKnobs {}

impl JsonSave for OomdKnobs {
    fn preamble() -> Option<String> {
        Some(OOMD_DOC.to_string())
    }
}