[RUST] Added XDS module

src/lib_ccx/ccx_decoders_xds.c

@@ -4,6 +4,18 @@
 #include "ccx_common_common.h"
 #include "utility.h"
 
+extern void ccxr_process_xds_bytes(
+    struct ccx_decoders_xds_context *ctx,
+    unsigned char hi,
+    int lo);
+
+extern void ccxr_do_end_of_xds(
+    struct cc_subtitle *sub,
+    struct ccx_decoders_xds_context *ctx,
+    unsigned char expected_checksum);
+
+extern void ccxr_set_ts_start_of_xds(long long value);
+
 LLONG ts_start_of_xds = -1; // Time at which we switched to XDS mode, =-1 hasn't happened yet
 
 static const char *XDSclasses[] =
@@ -238,6 +250,9 @@ void clear_xds_buffer(struct ccx_decoders_xds_context *ctx, int num)
 
 void process_xds_bytes(struct ccx_decoders_xds_context *ctx, const unsigned char hi, int lo)
 {
+	ccxr_process_xds_bytes(ctx, hi, lo);
+	return; // use the rust implementation
+
 	int is_new;
 	if (!ctx)
 		return;
@@ -890,6 +905,10 @@ int xds_do_misc(struct ccx_decoders_xds_context *ctx)
 
 void do_end_of_xds(struct cc_subtitle *sub, struct ccx_decoders_xds_context *ctx, unsigned char expected_checksum)
 {
+	ccxr_set_ts_start_of_xds(ts_start_of_xds);
+	ccxr_do_end_of_xds(sub, ctx, expected_checksum);
+	return; // use the rust implementation
+
 	int cs = 0;
 	int i;
 

src/lib_ccx/lib_ccx.h

@@ -21,6 +21,8 @@
 #include "avc_functions.h"
 #include "teletext.h"
 
+#include "ccx_decoders_xds.h"
+
 #ifdef WITH_LIBCURL
 #include <curl/curl.h>
 #endif

src/rust/Cargo.toml

@@ -25,6 +25,7 @@ lib_ccxr = { path = "lib_ccxr" }
 url = "2.5.4"
 serial_test = "3.2.0"
 encoding_rs = "0.8.35"
+libc = "0.2.178"
 
 # Use CCExtractor's forked rsmpeg with FFmpeg 7
 # All platforms use ffmpeg7 feature with prebuilt bindings for API consistency

src/rust/build.rs

@@ -63,6 +63,7 @@ fn main() {
         "ccx_encoding_type",
         "ccx_decoder_608_settings",
         "ccx_decoder_608_report",
+        "ccx_decoders_xds_context",
         "ccx_gxf",
         "MXFContext",
         "demuxer_data",

src/rust/lib_ccxr/src/util/log.rs

@@ -264,6 +264,11 @@ impl<'a> CCExtractorLogger {
         self.debug_mask.is_debug_mode()
     }
 
+    /// Check if a specific debug flag is set in the current debug mask
+    pub fn has_debug_flag(&self, flag: DebugMessageFlag) -> bool {
+      self.debug_mask.mask().intersects(flag)
+    }
+
     /// Returns the currently set target for logging messages.
     pub fn target(&self) -> OutputTarget {
         self.target

src/rust/src/lib.rs

@@ -29,6 +29,7 @@ pub mod libccxr_exports;
 pub mod parser;
 pub mod track_lister;
 pub mod utils;
+pub mod xds;
 
 #[cfg(windows)]
 use std::os::windows::io::{FromRawHandle, RawHandle};

src/rust/src/libccxr_exports/time.rs

@@ -138,7 +138,7 @@ pub unsafe extern "C" fn ccxr_millis_to_time(
 /// # Safety
 ///
 /// `ctx` should not be null.
-unsafe fn generate_timing_context(ctx: *const ccx_common_timing_ctx) -> TimingContext {
+pub unsafe fn generate_timing_context(ctx: *const ccx_common_timing_ctx) -> TimingContext {
     let pts_set = match (*ctx).pts_set {
         0 => PtsSet::No,
         1 => PtsSet::Received,
@@ -206,7 +206,7 @@ unsafe fn generate_timing_context(ctx: *const ccx_common_timing_ctx) -> TimingCo
 /// # Safety
 ///
 /// `ctx` should not be null.
-unsafe fn write_back_to_common_timing_ctx(
+pub unsafe fn write_back_to_common_timing_ctx(
     ctx: *mut ccx_common_timing_ctx,
     timing_ctx: &TimingContext,
 ) {
@@ -275,7 +275,7 @@ unsafe fn write_back_to_common_timing_ctx(
 /// # Safety
 ///
 /// All the static variables should be initialized and in valid state.
-unsafe fn apply_timing_info() {
+pub(crate) unsafe fn apply_timing_info() {
     let Ok(mut timing_info) = GLOBAL_TIMING_INFO.write() else {
         // RwLock is poisoned, skip updating
         return;