fluxbench-core 0.2.0

Worker runtime for FluxBench: Bencher struct, high-precision timing (RDTSC), and memory allocation tracking
Documentation 
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22

//! Sample sink: receives each sample when the engine records it.

use fluxbench_ipc::Sample;

/// Receives each measurement sample when the engine records it.
///
/// The engine calls the sink between samples, outside every timed region.
/// The worker uses a sink to stream samples to the supervisor during measurement.
/// So a timeout or crash keeps the samples taken before it.
pub trait SampleSink: Send {
    /// Take one recorded sample.
    fn on_sample(&mut self, sample: &Sample);
}

impl<F> SampleSink for F
where
    F: FnMut(&Sample) + Send,
{
    fn on_sample(&mut self, sample: &Sample) {
        self(sample)
    }
}