[go: up one dir, main page]

zenoh-shm 1.4.0

Internal crate for zenoh.
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

//
// Copyright (c) 2025 ZettaScale Technology
//
// This program and the accompanying materials are made available under the
// terms of the Eclipse Public License 2.0 which is available at
// http://www.eclipse.org/legal/epl-2.0, or the Apache License, Version 2.0
// which is available at https://www.apache.org/licenses/LICENSE-2.0.
//
// SPDX-License-Identifier: EPL-2.0 OR Apache-2.0
//
// Contributors:
//   ZettaScale Zenoh Team, <zenoh@zettascale.tech>
//
#![cfg(feature = "test")]
use zenoh_shm::shm::Segment;

#[test]
fn create() {
    let id = (line!() as u64) + ((std::process::id() as u64) << 32);
    let len = 1024.try_into().unwrap();
    let created_segment = Segment::create(id, len).unwrap();
    assert!(created_segment.len() >= len);
}

#[test]
fn create_concurrent() {
    let id = (line!() as u64) + ((std::process::id() as u64) << 32);
    let len = 1024.try_into().unwrap();
    let created_segment = Segment::create(id, len).unwrap();
    assert!(created_segment.len() >= len);
    assert!(Segment::create(id, len).is_err());
}

#[test]
fn create_and_open() {
    let id = (line!() as u64) + ((std::process::id() as u64) << 32);
    let len = 1024.try_into().unwrap();
    let created_segment = Segment::create(id, len).unwrap();
    let opened_segment = Segment::open(id).unwrap();
    assert!(created_segment.len() >= len);
    assert!(opened_segment.len() >= len);
}

#[test]
fn create_and_open_and_reopen() {
    let id = (line!() as u64) + ((std::process::id() as u64) << 32);
    let len = 1024.try_into().unwrap();
    let created_segment = Segment::create(id, len).unwrap();
    let opened_segment = Segment::open(id).unwrap();
    let opened_segment2 = Segment::open(id).unwrap();
    assert!(created_segment.len() >= len);
    assert!(opened_segment.len() >= len);
    assert!(opened_segment2.len() >= len);
}

#[test]
fn create_and_open_and_reopen_and_open_closed() {
    let id = (line!() as u64) + ((std::process::id() as u64) << 32);
    let len = 1024.try_into().unwrap();
    let created_segment = Segment::create(id, len).unwrap();
    let opened_segment = Segment::open(id).unwrap();
    assert!(created_segment.len() >= len);
    assert!(opened_segment.len() >= len);

    drop(created_segment);

    let opened_segment2 = Segment::open(id).unwrap();
    assert!(opened_segment2.len() >= len);
}

#[test]
fn no_persistency() {
    let id = (line!() as u64) + ((std::process::id() as u64) << 32);
    let len = 1024.try_into().unwrap();
    let created_segment = Segment::create(id, len).unwrap();
    assert!(created_segment.len() >= len);
    drop(created_segment);

    assert!(Segment::open(id).is_err());
}

#[test]
fn recreate_many_times() {
    let id = (line!() as u64) + ((std::process::id() as u64) << 32);
    let len = 1024.try_into().unwrap();

    for _ in 0..100 {
        let created_segment = Segment::create(id, len).unwrap();
        let opened_segment = Segment::open(id).unwrap();
        assert!(created_segment.len() >= len);
        assert!(opened_segment.len() >= len);
    }

    assert!(Segment::open(id).is_err());
}