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

use super::*;

impl<T: TransportPort + 'static> BACnetServer<T> {
    pub(super) fn atomic_read_file_response(
        db: &ObjectDatabase,
        invoke_id: u8,
        request: &[u8],
        budget: AtomicReadFileBudget,
        completed: impl FnOnce(ObjectIdentifier, &Result<(), Error>),
    ) -> Apdu {
        let service_choice = ConfirmedServiceChoice::ATOMIC_READ_FILE;
        let mut buf = BytesMut::new();
        match handlers::handle_atomic_read_file_observed(db, request, &mut buf, budget, completed) {
            Ok(()) => Apdu::ComplexAck(ComplexAck {
                segmented: false,
                more_follows: false,
                invoke_id,
                sequence_number: None,
                proposed_window_size: None,
                service_choice,
                service_ack: buf.freeze(),
            }),
            Err(handlers::AtomicReadFileFailure::Service(error)) => {
                Self::error_apdu_from_error(invoke_id, service_choice, &error)
            }
            Err(handlers::AtomicReadFileFailure::Budget(abort_reason)) => Apdu::Abort(AbortPdu {
                sent_by_server: true,
                invoke_id,
                abort_reason,
            }),
        }
    }
}