bacnet-server 0.11.0

use super::*;

impl<T: TransportPort + 'static> BACnetServer<T> {
    /// Atomically admit a confirmed request before DCC, service decoding,
    /// authorization, mutation, side effects, or response construction.
    #[allow(clippy::too_many_arguments)]
    pub(in crate::server) async fn handle_confirmed_request(
        db: &Arc<RwLock<ObjectDatabase>>,
        network: &Arc<NetworkLayer<T>>,
        cov_table: &Arc<RwLock<CovSubscriptionTable>>,
        seg_ack_senders: &Arc<Mutex<HashMap<SegKey, Arc<SegmentedSendHandle>>>>,
        seg_send_permits: &Arc<Semaphore>,
        cov_in_flight: &Arc<Semaphore>,
        server_tsm: &Arc<Mutex<ServerTsm>>,
        notification_transactions: &Arc<NotificationTransactions>,
        confirmed_request_tracker: &Arc<ConfirmedRequestTracker>,
        device_bindings: &Arc<RwLock<DeviceBindingTable>>,
        comm_state: &Arc<AtomicU8>,
        dcc_timer: &Arc<Mutex<Option<JoinHandle<()>>>>,
        config: &ServerConfig,
        source_mac: &[u8],
        source_network: Option<NpduAddress>,
        req: bacnet_encoding::apdu::ConfirmedRequest,
        reply_tx: Option<tokio::sync::oneshot::Sender<Bytes>>,
    ) {
        let pending =
            match confirmed_request_tracker.begin(source_mac, source_network.as_ref(), req.clone())
            {
                ConfirmedRequestAdmission::Duplicate => return,
                ConfirmedRequestAdmission::New(pending) => pending,
            };

        Self::handle_admitted_confirmed_request(
            db,
            network,
            cov_table,
            seg_ack_senders,
            seg_send_permits,
            cov_in_flight,
            server_tsm,
            notification_transactions,
            device_bindings,
            comm_state,
            dcc_timer,
            config,
            source_mac,
            source_network,
            req,
            reply_tx,
        )
        .await;
        pending.complete();
    }
}