ringfire 0.5.2

Zero-copy lock-free inter-process communication (IPC) ring buffer and shared memory bus in Rust, with ring mirroring across hosts
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

#!/usr/bin/env python3
"""Reject incomplete/lossy benchmark smoke logs (never judge performance thresholds)."""
import re
import sys
from pathlib import Path


def require(ok, context):
    if not ok:
        raise ValueError(context)


def summaries(text, expected, context):
    rows = re.findall(
        r"received (\d+) of (\d+) \(lost (\d+)\), duplicates (\d+), "
        r"out of order (\d+), out of range (\d+)", text
    )
    want = [(n, n, 0, 0, 0, 0) for n in expected]
    require([tuple(map(int, row)) for row in rows] == want, context + ': delivery counters')
    for key in ('lapped', 'gaps', 'echo_errors'):
        require(not re.search(rf'\b{key}[= ]+[1-9]\d*', text), context + ': ' + key)


def verify(root):
    def read(name):
        return (root / (name + '.log')).read_text()

    for transport in ('tcp', 'multicast'):
        name = 'latency-' + transport
        text = read(name)
        summaries(text, [1000, 10000], name)
        require(re.search(r'\bn=1000\b', text), name + ': sample count')
        name = 'ping-' + transport
        text = read(name)
        require(re.search(
            r'500 pings after 100 warm-up.*: measured 0 lost .*?, 0 late, 0 unexpected '
            r'\(warm-up: \d+ lost, \d+ late, \d+ unexpected\), reader lapped 0',
            text), name + ': measured reply counters')
        require(re.search(r'\brtt n=500\b', text), name + ': sample count')
    for transport in ('tcp', 'multicast', 'unicast'):
        name = 'stress-' + transport
        text = read(name)
        require(re.search(
            r'pushed 10000 .*echoed 10000 .*lost 0, duplicates 0, disorder 0, reader lapped 0',
            text), name + ': delivery counters')
        require(re.search(r'\brtt n=10000\b', text), name + ': sample count')
        summaries(read('master-' + transport), [1000, 1000], 'master-' + transport)
        summaries(read('slave-' + transport), [1000], 'slave-' + transport)
        require(len(re.findall(r'\bn=1000\b', read('master-' + transport))) == 2,
                'master-' + transport + ': sample count')
        require(re.search(r'\bn=1000\b', read('slave-' + transport)),
                'slave-' + transport + ': sample count')


if __name__ == '__main__':
    try:
        verify(Path(sys.argv[1]))
    except (OSError, ValueError) as error:
        sys.exit(f'benchmark smoke failed: {error}')
    print('All measured smoke phases delivered every expected record exactly once.')