Struct tikv::server::load_statistics::ThreadLoadStatistics

[+] Show declaration

pub struct ThreadLoadStatistics {
    pid: pid_t,
    tids: Vec<pid_t>,
    slots: usize,
    cur_pos: usize,
    cpu_usages: Vec<f64>,
    instants: Vec<Instant>,
    thread_load: Arc<ThreadLoad>,
}

[−] Expand description

A Linux-specific ThreadLoadStatistics. It collects threads load metrics.

Fields

pid: pid_t

tids: Vec<pid_t>

slots: usize

cur_pos: usize

cpu_usages: Vec<f64>

instants: Vec<Instant>

thread_load: Arc<ThreadLoad>

Implementations

impl ThreadLoadStatistics[−]

pub fn new(slots: usize, prefix: &str, thread_load: Arc<ThreadLoad>) -> Self[−]

Create a thread load statistics for all threads with prefix. ThreadLoad is stored into thread_load. At most slots old records will be kept, to make the curve more smooth.

Note: call this after the target threads are initialized, otherwise it can’t catch them.

pub fn record(&mut self, instant: Instant)[−]

For every threads with the name prefix given in ThreadLoadStatistics::new, gather cpu usage from /proc/<pid>/task/<tid> and store it in thread_load passed in ThreadLoadStatistics::new.

Some old usages and instants (at most slots) will be kept internal to make the usage curve more smooth.