corpus-ipc 0.1.0

Inter-Process Communication (IPC) library for bridging Rust to external compute engines via ZeroMQ.
Documentation 
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

// SPDX-License-Identifier: MIT OR Apache-2.0

use super::*;

#[test]
fn stimulus_values_accept_exact_max() {
    let limits = limits();
    let stimulus = StimulusBatch {
        values: vec![0.0; limits.max_channel_values],
        ..Default::default()
    };
    stimulus.validate_with(limits).expect("channel max");
}

#[test]
fn stimulus_values_reject_max_plus_one() {
    let limits = limits();
    let mut stimulus = StimulusBatch {
        values: vec![0.0; limits.max_channel_values],
        ..Default::default()
    };
    stimulus.values.push(0.0);
    let err = stimulus.validate_with(limits).unwrap_err();
    assert_limit_exceeded(&err, "values");
    assert_eq!(
        err.actual,
        Some(ValidationMeasure::Count(
            u64::try_from(limits.max_channel_values + 1).unwrap()
        ))
    );
    assert_eq!(
        err.limit,
        Some(ValidationMeasure::Count(
            u64::try_from(limits.max_channel_values).unwrap()
        ))
    );
}

#[test]
fn mask_value_length_mismatch_is_typed() {
    let batch = StimulusBatch {
        values: vec![0.0, 1.0],
        valid_mask: Some(vec![true]),
        ..Default::default()
    };
    let err = batch.validate().unwrap_err();
    assert_eq!(err.kind, ValidationKind::LengthMismatch);
    assert_eq!(err.actual, Some(ValidationMeasure::Count(1)));
    assert_eq!(err.limit, Some(ValidationMeasure::Count(2)));
}