bacnet-server 0.13.0

BACnet server: APDU dispatch and service handlers
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

use super::*;
use bacnet_network::layer::IssuedApdu;

impl<T: TransportPort + 'static> BACnetServer<T> {
    /// Terminal ordinary response: release the pending owner only after NPDU
    /// encoding, at local issuance. Failure/cancellation also drops ownership.
    pub(super) async fn issue_terminal_response(
        network: &NetworkLayer<T>,
        apdu: &[u8],
        source_mac: &[u8],
        source_network: Option<&NpduAddress>,
        route: &bacnet_network::response_route::ResponseRoute,
        pending: Option<PendingConfirmedRequest>,
    ) -> Result<(), Error> {
        network
            .send_response_apdu_on_issuance(
                IssuedApdu {
                    apdu,
                    next_hop: source_mac,
                    destination: source_network,
                    expecting_reply: false,
                    priority: NetworkPriority::NORMAL,
                },
                route,
                move || drop(pending),
            )
            .await
    }

    pub(super) async fn send_confirmed_response_apdu(
        network: &NetworkLayer<T>,
        apdu: &[u8],
        source_mac: &[u8],
        source_network: Option<&NpduAddress>,
        route: &bacnet_network::response_route::ResponseRoute,
    ) -> Result<(), Error> {
        Self::send_confirmed_response_apdu_expecting_reply(
            network,
            apdu,
            source_mac,
            source_network,
            route,
            false,
        )
        .await
    }

    pub(super) async fn send_confirmed_response_apdu_expecting_reply(
        network: &NetworkLayer<T>,
        apdu: &[u8],
        source_mac: &[u8],
        source_network: Option<&NpduAddress>,
        route: &bacnet_network::response_route::ResponseRoute,
        expecting_reply: bool,
    ) -> Result<(), Error> {
        network
            .send_response_apdu_on_issuance(
                IssuedApdu {
                    apdu,
                    next_hop: source_mac,
                    destination: source_network,
                    expecting_reply,
                    priority: NetworkPriority::NORMAL,
                },
                route,
                || {},
            )
            .await
    }
}