feat(egfx)!: surface total_frames_decoded on the frame-ack callback (#1345)

Author: glamberson

crates/ironrdp-egfx/src/server.rs

@@ -767,7 +767,14 @@ pub trait GraphicsPipelineHandler: Send {
     fn on_ready(&mut self, negotiated: &CapabilitySet);
 
     /// Called when a frame has been acknowledged by the client
-    fn on_frame_ack(&mut self, _frame_id: u32, _queue_depth: u32) {}
+    ///
+    /// `total_frames_decoded` is the client's running decoded-frame count
+    /// (MS-RDPEGFX 2.2.2.13), for decode-backlog flow control.
+    fn on_frame_ack(&mut self, frame_id: u32, queue_depth: u32, total_frames_decoded: u32) {
+        let _ = frame_id;
+        let _ = queue_depth;
+        let _ = total_frames_decoded;
+    }
 
     /// Called when QoE metrics are received from client (V10+)
     fn on_qoe_metrics(&mut self, _metrics: QoeMetrics) {}
@@ -1685,7 +1692,8 @@ impl GraphicsPipelineServer {
             trace!(frame_id = pdu.frame_id, latency = ?rtt);
         }
 
-        self.handler.on_frame_ack(pdu.frame_id, queue_depth);
+        self.handler
+            .on_frame_ack(pdu.frame_id, queue_depth, pdu.total_frames_decoded);
     }
 
     fn handle_qoe_frame_acknowledge(&mut self, pdu: QoeFrameAcknowledgePdu) {

crates/ironrdp-testsuite-core/tests/egfx/server.rs

@@ -13,7 +13,7 @@ use ironrdp_egfx::server::{GraphicsPipelineHandler, GraphicsPipelineServer, QoeM
 struct TestHandler {
     ready_called: bool,
     negotiated: Option<CapabilitySet>,
-    frame_acks: Vec<(u32, u32)>,
+    frame_acks: Vec<(u32, u32, u32)>,
     surfaces_created: Vec<u16>,
     surfaces_deleted: Vec<u16>,
 }
@@ -38,8 +38,8 @@ impl GraphicsPipelineHandler for TestHandler {
         self.negotiated = Some(negotiated.clone());
     }
 
-    fn on_frame_ack(&mut self, frame_id: u32, queue_depth: u32) {
-        self.frame_acks.push((frame_id, queue_depth));
+    fn on_frame_ack(&mut self, frame_id: u32, queue_depth: u32, total_frames_decoded: u32) {
+        self.frame_acks.push((frame_id, queue_depth, total_frames_decoded));
     }
 
     fn on_qoe_metrics(&mut self, _metrics: QoeMetrics) {}