feat(graphics,egfx): add progressive RFX decode and EGFX integration

Add progressive RemoteFX decode pipeline and wire it into the EGFX
client and server:

ironrdp-graphics: Progressive decode algorithms (first-pass and
upgrade-pass coefficient reconstruction via SRL + inverse DWT),
tile state tracking for multi-pass refinement, surface-level tile
management with automatic quality progression.

ironrdp-egfx: WireToSurface2 dispatch for progressive codec in
GraphicsPipelineClient. Progressive surface state stored on the
server for multi-pass frame scheduling.

Author: lamco-office

crates/ironrdp-dvc/src/client.rs

@@ -4,14 +4,14 @@ use alloc::vec::Vec;
 use core::any::TypeId;
 use core::fmt;
 
-use crate::alloc::borrow::ToOwned as _;
 use ironrdp_core::{Decode as _, DecodeResult, ReadCursor, impl_as_any};
 use ironrdp_pdu::{self as pdu, decode_err, encode_err, pdu_other_err};
 use ironrdp_svc::{ChannelFlags, CompressionCondition, SvcClientProcessor, SvcMessage, SvcProcessor};
 use pdu::PduResult;
 use pdu::gcc::ChannelName;
 use tracing::debug;
 
+use crate::alloc::borrow::ToOwned as _;
 use crate::pdu::{
     CapabilitiesResponsePdu, CapsVersion, ClosePdu, CreateResponsePdu, CreationStatus, DrdynvcClientPdu,
     DrdynvcServerPdu,

crates/ironrdp-dvc/src/lib.rs

@@ -4,11 +4,10 @@
 
 extern crate alloc;
 
-use core::any::TypeId;
-
 use alloc::boxed::Box;
 use alloc::string::String;
 use alloc::vec::Vec;
+use core::any::TypeId;
 
 use pdu::DrdynvcDataPdu;
 

crates/ironrdp-egfx/src/decode.rs

@@ -149,9 +149,10 @@ pub trait H264Decoder: Send {
 
 #[cfg(feature = "openh264")]
 mod openh264_impl {
-    use super::{DecodedFrame, DecoderError, DecoderResult, H264Decoder};
     use tracing::warn;
 
+    use super::{DecodedFrame, DecoderError, DecoderResult, H264Decoder};
+
     /// H.264 decoder backed by Cisco's OpenH264 library
     ///
     /// This decoder converts AVC-format NAL units to Annex B format

crates/ironrdp-egfx/src/server.rs

@@ -70,9 +70,10 @@ use crate::CHANNEL_NAME;
 use crate::pdu::{
     Avc420BitmapStream, Avc420Region, Avc444BitmapStream, CacheImportOfferPdu, CacheImportReplyPdu,
     CapabilitiesAdvertisePdu, CapabilitiesConfirmPdu, CapabilitiesV8Flags, CapabilitiesV10Flags, CapabilitiesV81Flags,
-    CapabilitiesV103Flags, CapabilitiesV104Flags, CapabilitiesV107Flags, CapabilitySet, Codec1Type, CreateSurfacePdu,
-    DeleteSurfacePdu, Encoding, EndFramePdu, FrameAcknowledgePdu, GfxPdu, MapSurfaceToOutputPdu, PixelFormat,
-    QoeFrameAcknowledgePdu, ResetGraphicsPdu, StartFramePdu, Timestamp, WireToSurface1Pdu, encode_avc420_bitmap_stream,
+    CapabilitiesV103Flags, CapabilitiesV104Flags, CapabilitiesV107Flags, CapabilitySet, Codec1Type, Codec2Type,
+    CreateSurfacePdu, DeleteSurfacePdu, Encoding, EndFramePdu, FrameAcknowledgePdu, GfxPdu, MapSurfaceToOutputPdu,
+    PixelFormat, QoeFrameAcknowledgePdu, ResetGraphicsPdu, StartFramePdu, Timestamp, WireToSurface1Pdu,
+    WireToSurface2Pdu, encode_avc420_bitmap_stream,
 };
 
 // ============================================================================
@@ -1408,6 +1409,52 @@ impl GraphicsPipelineServer {
         Some(frame_id)
     }
 
+    /// Queue a RemoteFX Progressive frame for transmission.
+    ///
+    /// Progressive frames use `WireToSurface2Pdu` with a pre-encoded progressive
+    /// block stream as the bitmap payload. The `codec_context_id` associates
+    /// this data with persistent tile state on the client.
+    ///
+    /// The `progressive_data` must be a valid progressive block stream
+    /// (SYNC + CONTEXT + FRAME_BEGIN + REGION + FRAME_END) as produced by
+    /// `ironrdp_pdu::codecs::rfx::progressive::encode_progressive_stream()`.
+    ///
+    /// Returns `Some(frame_id)` if queued, `None` if not ready or backpressured.
+    pub fn send_remotefx_progressive_frame(
+        &mut self,
+        surface_id: u16,
+        codec_context_id: u32,
+        progressive_data: Vec<u8>,
+        timestamp_ms: u32,
+    ) -> Option<u32> {
+        if !self.is_ready() {
+            return None;
+        }
+        if self.should_backpressure() {
+            return None;
+        }
+
+        let surface = self.surfaces.get(surface_id)?;
+
+        let timestamp = Self::make_timestamp(timestamp_ms);
+        let frame_id = self.frames.begin_frame(timestamp);
+
+        self.output_queue
+            .push_back(GfxPdu::StartFrame(StartFramePdu { timestamp, frame_id }));
+
+        self.output_queue.push_back(GfxPdu::WireToSurface2(WireToSurface2Pdu {
+            surface_id,
+            codec_id: Codec2Type::RemoteFxProgressive,
+            codec_context_id,
+            pixel_format: surface.pixel_format,
+            bitmap_data: progressive_data,
+        }));
+
+        self.output_queue.push_back(GfxPdu::EndFrame(EndFramePdu { frame_id }));
+
+        Some(frame_id)
+    }
+
     // ========================================================================
     // Output Management
     // ========================================================================

crates/ironrdp-graphics/src/lib.rs

@@ -8,6 +8,7 @@ pub mod dwt;
 pub mod dwt_extrapolate;
 pub mod image_processing;
 pub mod pointer;
+pub mod progressive;
 pub mod quantization;
 pub mod rdp6;
 pub mod rectangle_processing;