iceoryx2-cal 0.6.0

iceoryx2: [internal] high-level traits and implementations that represents OS primitives in an exchangeable fashion
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

// Copyright (c) 2024 Contributors to the Eclipse Foundation
//
// See the NOTICE file(s) distributed with this work for additional
// information regarding copyright ownership.
//
// This program and the accompanying materials are made available under the
// terms of the Apache Software License 2.0 which is available at
// https://www.apache.org/licenses/LICENSE-2.0, or the MIT license
// which is available at https://opensource.org/licenses/MIT.
//
// SPDX-License-Identifier: Apache-2.0 OR MIT

use iceoryx2_bb_lock_free::mpmc::bit_set::RelocatableBitSet;
use iceoryx2_bb_log::fail;

use super::IdTracker;
use crate::event::{NotifierNotifyError, TriggerId};

impl IdTracker for RelocatableBitSet {
    fn trigger_id_max(&self) -> TriggerId {
        TriggerId::new(self.capacity() - 1)
    }

    unsafe fn add(&self, id: TriggerId) -> Result<(), NotifierNotifyError> {
        if self.trigger_id_max() < id {
            fail!(from self, with NotifierNotifyError::TriggerIdOutOfBounds,
                "Unable to set bit {:?} since it is out of bounds (max = {:?}).",
                id, self.trigger_id_max());
        }
        self.set(id.as_value());

        Ok(())
    }

    unsafe fn acquire_all<F: FnMut(TriggerId)>(&self, mut callback: F) {
        self.reset_all(|bit_index| callback(TriggerId::new(bit_index)))
    }

    unsafe fn acquire(&self) -> Option<TriggerId> {
        self.reset_next().map(TriggerId::new)
    }
}