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
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
112
113
114
115
116
117
118
119
120
121
122
123
124
125
126
127
128
129
130
131
132
133
134
135
136
137
138
139
140

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

use super::*;

#[test]
fn serde_rejects_inf_in_stimulus() {
    let inf = serde_json::json!(1e39);
    assert_serde_kind::<StimulusBatch>(
        serde_json::json!({
            "session_id": null,
            "batch_id": 0,
            "timestamp": 0,
            "values": [inf],
            "valid_mask": null,
            "metadata": null
        }),
        ValidationKind::NonFinite,
    );
}

#[test]
fn serde_rejects_inf_in_spike_event() {
    let inf = serde_json::json!(1e39);
    assert_serde_kind::<SpikeEvent>(
        serde_json::json!({"channel": 0, "time": 0, "strength": inf}),
        ValidationKind::NonFinite,
    );
}

#[test]
fn serde_rejects_inf_in_embedding() {
    let inf = serde_json::json!(1e39);
    assert_serde_kind::<EmbeddingBatch>(
        serde_json::json!({
            "session_id": null,
            "batch_id": 0,
            "embedding": [inf],
            "sequence_length": 1
        }),
        ValidationKind::NonFinite,
    );
}

#[test]
fn serde_rejects_inf_in_trace_and_gradient() {
    let inf = serde_json::json!(1e39);
    assert_serde_kind::<TraceData>(
        serde_json::json!({
            "channel_id": 1,
            "trace_value": inf,
            "last_spike_time": 0
        }),
        ValidationKind::NonFinite,
    );
    assert_serde_kind::<GradientUpdate>(
        serde_json::json!({
            "layer_id": "l0",
            "gradients": [inf]
        }),
        ValidationKind::NonFinite,
    );
}

#[test]
fn serde_rejects_inf_in_loss() {
    let inf = serde_json::json!(1e39);
    assert_serde_kind::<IpcMessage>(serde_json::json!({"Loss": inf}), ValidationKind::NonFinite);
}

#[test]
fn serde_rejects_oversize_session_id() {
    let too_long = oversize_string(limits().max_string_bytes);
    assert_serde_kind::<SpikeBatch>(
        serde_json::json!({
            "session_id": too_long,
            "batch_id": 0,
            "timestamp": 0,
            "spikes": [],
            "metadata": null
        }),
        ValidationKind::LimitExceeded,
    );
}

#[test]
fn serde_rejects_oversize_stimulus_values() {
    let extra_value = vec![0.0; limits().max_channel_values + 1];
    assert_serde_kind::<StimulusBatch>(
        serde_json::json!({
            "session_id": null,
            "batch_id": 0,
            "timestamp": 0,
            "values": extra_value,
            "valid_mask": null,
            "metadata": null
        }),
        ValidationKind::LimitExceeded,
    );
}

#[test]
fn serde_rejects_mismatched_mask() {
    assert_serde_kind::<StimulusBatch>(
        serde_json::json!({
            "session_id": null,
            "batch_id": 0,
            "timestamp": 0,
            "values": [0.0, 1.0],
            "valid_mask": [true],
            "metadata": null
        }),
        ValidationKind::LengthMismatch,
    );
}

#[test]
fn serde_and_direct_construction_share_range_checks() {
    let json = serde_json::json!({
        "tick": 1,
        "dopamine": 0.5,
        "cortisol": 0.5,
        "acetylcholine": 0.5,
        "tempo": 3.0
    });
    assert_serde_kind::<NeuromodulatorSnapshot>(json, ValidationKind::OutOfRange);

    let mut snap = NeuromodulatorSnapshot {
        tick: 1,
        dopamine: 0.5,
        cortisol: 0.5,
        acetylcholine: 0.5,
        tempo: 3.0,
    };
    assert_eq!(
        snap.validate().unwrap_err().kind,
        ValidationKind::OutOfRange
    );
    snap.tempo = 1.0;
    snap.validate().unwrap();
}