rs-matter 0.1.0

Native Rust implementation of the Matter (Smart-Home) ecosystem
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

/*
 *
 *    Copyright (c) 2020-2022 Project CHIP Authors
 *
 *    Licensed under the Apache License, Version 2.0 (the "License");
 *    you may not use this file except in compliance with the License.
 *    You may obtain a copy of the License at
 *
 *        http://www.apache.org/licenses/LICENSE-2.0
 *
 *    Unless required by applicable law or agreed to in writing, software
 *    distributed under the License is distributed on an "AS IS" BASIS,
 *    WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
 *    See the License for the specific language governing permissions and
 *    limitations under the License.
 */

use embassy_sync::{blocking_mutex::raw::NoopRawMutex, mutex::Mutex};

use crate::utils::select::Notification;

use super::network::Address;

#[derive(Copy, Clone, Eq, PartialEq, Debug)]
pub struct Chunk {
    pub start: usize,
    pub end: usize,
    pub addr: Address,
}

pub struct PipeData<'a> {
    pub buf: &'a mut [u8],
    pub chunk: Option<Chunk>,
}

pub struct Pipe<'a> {
    pub data: Mutex<NoopRawMutex, PipeData<'a>>,
    pub data_supplied_notification: Notification,
    pub data_consumed_notification: Notification,
}

impl<'a> Pipe<'a> {
    #[inline(always)]
    pub fn new(buf: &'a mut [u8]) -> Self {
        Self {
            data: Mutex::new(PipeData { buf, chunk: None }),
            data_supplied_notification: Notification::new(),
            data_consumed_notification: Notification::new(),
        }
    }

    pub async fn recv(&self, buf: &mut [u8]) -> (usize, Address) {
        loop {
            {
                let mut data = self.data.lock().await;

                if let Some(chunk) = data.chunk {
                    buf[..chunk.end - chunk.start]
                        .copy_from_slice(&data.buf[chunk.start..chunk.end]);
                    data.chunk = None;

                    self.data_consumed_notification.signal(());

                    return (chunk.end - chunk.start, chunk.addr);
                }
            }

            self.data_supplied_notification.wait().await
        }
    }

    pub async fn send(&self, addr: Address, buf: &[u8]) {
        loop {
            {
                let mut data = self.data.lock().await;

                if data.chunk.is_none() {
                    data.buf[..buf.len()].copy_from_slice(buf);
                    data.chunk = Some(Chunk {
                        start: 0,
                        end: buf.len(),
                        addr,
                    });

                    self.data_supplied_notification.signal(());

                    break;
                }
            }

            self.data_consumed_notification.wait().await
        }
    }
}