[RUST] Added XDS module

src/lib_ccx/ccx_decoders_xds.c

@@ -4,6 +4,21 @@
 #include "ccx_common_common.h"
 #include "utility.h"
 
+// declare rust implementation of process_xds_bytes (function)
+extern void ccxr_process_xds_bytes(
+    struct ccx_decoders_xds_context *ctx,
+    unsigned char hi,
+    int lo);
+
+// declare rust implementation of do_end_of_xds (function)
+extern void ccxr_do_end_of_xds(
+    struct cc_subtitle *sub,
+    struct ccx_decoders_xds_context *ctx,
+    unsigned char expected_checksum);
+
+// declare setter function for TS_START_OF_XDS from C code
+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 +253,10 @@ 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)
 {
+#ifndef DISABLE_RUST
+	ccxr_process_xds_bytes(ctx, hi, lo); // use the rust implementation
+	return;
+#endif
 	int is_new;
 	if (!ctx)
 		return;
@@ -890,6 +909,11 @@ 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)
 {
+#ifndef DISABLE_RUST
+	ccxr_set_ts_start_of_xds(ts_start_of_xds);
+	ccxr_do_end_of_xds(sub, ctx, expected_checksum); // use the rust implementation
+	return;
+#endif
 	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/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;