bacnet-server 0.14.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

use super::*;

#[cfg(test)]
#[path = "dcc_disable_rate_tests.rs"]
mod rate_tests;

/// Answer one DeviceCommunicationControl request. `local_network` is this
/// network's number as read for the request (#1458), and `audit` reports
/// the change it carries out (#1387).
pub(super) async fn response<T: TransportPort + 'static>(
    services: &RequestServices<T>,
    req: &ConfirmedRequestPdu,
    source_mac: &[u8],
    source: Option<&NpduAddress>,
    local_network: Option<u16>,
    request_tasks: &super::super::request_tasks::RequestTaskSpawner,
    audit: &mut super::super::audit_reporter::WriteAudit<'_, T>,
) -> Apdu {
    let RequestServices {
        dcc_outcomes: outcomes,
        cov_table,
        ..
    } = services;
    let cov_resume = cov_table.read().await.timed().clone();
    let result = super::super::dcc_timer::replace(
        services,
        super::super::dcc_timer::DccRequest {
            service_data: &req.service_request,
            source_mac,
            source,
            local_network,
        },
        request_tasks,
        &cov_resume,
        audit,
    )
    .await;
    // No await between validation failure/live commit and completion telemetry.
    // The counter and event happen before constructing either response.
    match result {
        Ok(metadata) => {
            outcomes.record(
                dcc_outcomes::DccOutcome::Accepted,
                metadata,
                req.invoke_id,
                source_mac,
                source,
            );
            Apdu::SimpleAck(SimpleAck {
                invoke_id: req.invoke_id,
                service_choice: req.service_choice,
            })
        }
        Err(failure) => {
            outcomes.record(
                failure.outcome,
                failure.metadata,
                req.invoke_id,
                source_mac,
                source,
            );
            BACnetServer::<T>::error_apdu_from_error(
                req.invoke_id,
                req.service_choice,
                &failure.error,
            )
        }
    }
}