remotia-buffer-utils 0.1.3

Buffer management utilities of remotia, an open source framework for the development of remote rendering software in pure Rust
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

use std::{collections::{hash_map::Keys, HashMap}, hash::Hash, fmt::Debug};

use crate::pool::BuffersPool;

pub struct PoolRegistry<K: Copy + PartialEq + Eq + Hash> {
    pools: HashMap<K, BuffersPool<K>>,
}

impl<K: Copy + PartialEq + Eq + Hash + Debug> PoolRegistry<K> {
    pub fn new() -> Self {
        Self {
            pools: HashMap::new(),
        }
    }

    pub async fn register(&mut self, slot_id: K, pool_size: usize, buffer_size: usize) {
        let pool = BuffersPool::new(slot_id, pool_size, buffer_size).await;
        self.pools.insert(slot_id, pool);
    }

    pub fn get(&self, slot_id: K) -> &BuffersPool<K> {
        self.pools.get(&slot_id).expect(&format!(
            "No pool with ID {:?} found in the registry",
            slot_id
        ))
    }

    /*pub fn mass_redeemer(&self, soft: bool) -> Sequential<F> {
        let mut sequential = Sequential::new();
        for (_, pool) in &self.pools {
            let redeemer = if soft {
                pool.redeemer().soft()
            } else {
                pool.redeemer()
            };
            sequential = sequential.append(redeemer)
        }

        sequential
    }

    pub fn mass_borrower(&self) -> Sequential<F> {
        let mut sequential = Sequential::new();
        for (_, pool) in &self.pools {
            sequential = sequential.append(pool.borrower())
        }

        sequential
    }*/

    pub fn get_buffer_ids(&self) -> Keys<K, BuffersPool<K>> {
        self.pools.keys()
    }
}