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
34
35
36
37
38
39

use super::*;

impl<T: TransportPort + 'static> BACnetServer<T> {
    pub(super) fn atomic_write_file_response(
        db: &mut ObjectDatabase,
        invoke_id: u8,
        request: &[u8],
        budget: AtomicWriteFileBudget,
        audit: &mut super::super::audit_reporter::WriteAudit<'_, T>,
    ) -> Apdu {
        let service_choice = ConfirmedServiceChoice::ATOMIC_WRITE_FILE;
        let mut buf = BytesMut::new();
        match handlers::handle_atomic_write_file_observed(
            db,
            request,
            &mut buf,
            budget,
            |db, target, result| audit.file_completed(db, target, result),
        ) {
            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::AtomicWriteFileFailure::Service(error)) => {
                Self::error_apdu_from_error(invoke_id, service_choice, &error)
            }
            Err(handlers::AtomicWriteFileFailure::Budget) => Apdu::Abort(AbortPdu {
                sent_by_server: true,
                invoke_id,
                abort_reason: AbortReason::OUT_OF_RESOURCES,
            }),
        }
    }
}