feat: added demuxer module

Author: steel-bucket

src/rust/Cargo.lock

@@ -28,6 +28,7 @@ cfg-if = "1.0.0"
 num-integer = "0.1.45"
 lib_ccxr = { path = "lib_ccxr" }
 url = "2.5.2"
+libc = "0.2.169"
 
 [build-dependencies]
 bindgen = "0.64.0"

src/rust/Cargo.toml

@@ -15,6 +15,7 @@ strum = "0.26.3"
 strum_macros = "0.26.4"
 crc32fast = "1.3.2"
 num_enum = "0.6.1"
+libc = "0.2.169"
 
 [features]
 default = [

src/rust/lib_ccxr/Cargo.lock

@@ -2,9 +2,16 @@ use std::io;
 use std::io::Write;
 
 use crate::common::Options;
+use std::sync::atomic::{AtomicUsize, Ordering};
+
+pub static mut NET_ACTIVITY_GUI: AtomicUsize = AtomicUsize::new(0);
 
 pub trait ActivityExt {
     fn activity_report_version(&mut self);
+    fn activity_input_file_closed(&mut self);
+    fn activity_input_file_open(&mut self, filename: &str);
+    fn activity_report_data_read(&mut self);
+
 }
 impl ActivityExt for Options {
     fn activity_report_version(&mut self) {
@@ -15,4 +22,33 @@ impl ActivityExt for Options {
             stderr.flush().unwrap();
         }
     }
+    fn activity_input_file_closed(&mut self) {
+        if self.gui_mode_reports {
+            let mut stderr = io::stderr();
+            writeln!(stderr, "###INPUTFILECLOSED").unwrap();
+            stderr.flush().unwrap();
+        }
+    }
+
+    fn activity_input_file_open(&mut self, filename: &str) {
+        if self.gui_mode_reports {
+            let mut stderr = io::stderr();
+            writeln!(stderr, "###INPUTFILEOPEN#{}", filename).unwrap();
+            stderr.flush().unwrap();
+        }
+    }
+
+    fn activity_report_data_read(&mut self) {
+        if self.gui_mode_reports {
+            let mut stderr = io::stderr();
+            writeln!(stderr, "###DATAREAD#{}", unsafe { NET_ACTIVITY_GUI.load(Ordering::SeqCst)/ 1000 }).unwrap();
+            stderr.flush().unwrap();
+        }
+    }
+
 }
+pub fn update_net_activity_gui(value: usize) {
+    unsafe {
+        NET_ACTIVITY_GUI.store(value, Ordering::SeqCst);
+    }
+}

src/rust/lib_ccxr/Cargo.toml

@@ -0,0 +1,43 @@
+pub struct AvcCtx {
+    pub cc_count: u8,  // Number of closed caption blocks
+    pub cc_data: *mut u8,  // Pointer to buffer holding CC data
+    pub cc_databufsize: i64,  // Buffer size for CC data
+    pub cc_buffer_saved: i32,  // Was the CC buffer saved after the last update?
+
+    pub got_seq_para: i32,  // Flag indicating if sequence parameters were received
+    pub nal_ref_idc: u32,  // NAL reference ID
+    pub seq_parameter_set_id: i64,  // Sequence parameter set ID
+    pub log2_max_frame_num: i32,  // Log2 of max frame number
+    pub pic_order_cnt_type: i32,  // Picture order count type
+    pub log2_max_pic_order_cnt_lsb: i32,  // Log2 of max picture order count LSB
+    pub frame_mbs_only_flag: i32,  // Flag indicating if only frame MBs are used
+
+    // Use and throw stats for debugging (TODO: clean up later)
+    pub num_nal_unit_type_7: i64,  // Number of NAL units of type 7
+    pub num_vcl_hrd: i64,  // Number of VCL HRD parameters encountered
+    pub num_nal_hrd: i64,  // Number of NAL HRD parameters encountered
+    pub num_jump_in_frames: i64,  // Number of frame jumps detected
+    pub num_unexpected_sei_length: i64,  // Number of unexpected SEI lengths
+
+    pub ccblocks_in_avc_total: i32,  // Total CC blocks in AVC stream
+    pub ccblocks_in_avc_lost: i32,  // Lost CC blocks in AVC stream
+
+    pub frame_num: i64,  // Current frame number
+    pub lastframe_num: i64,  // Last processed frame number
+    pub currref: i32,  // Current reference index
+    pub maxidx: i32,  // Maximum index value for ordering
+    pub lastmaxidx: i32,  // Last max index
+
+    // Used to find tref zero in PTS mode
+    pub minidx: i32,  // Minimum reference index
+    pub lastminidx: i32,  // Last minimum reference index
+
+    // Used to remember the max temporal reference number (POC mode)
+    pub maxtref: i32,  // Max temporal reference
+    pub last_gop_maxtref: i32,  // Last GOP max temporal reference
+
+    // Used for PTS ordering of CC blocks
+    pub currefpts: i64,  // Current reference PTS
+    pub last_pic_order_cnt_lsb: i64,  // Last picture order count LSB
+    pub last_slice_pts: i64,  // Last slice PTS
+}

src/rust/lib_ccxr/src/activity.rs

@@ -0,0 +1 @@
+pub mod avc_functions;

src/rust/lib_ccxr/src/avc_functions/avc_functions.rs

@@ -246,6 +246,18 @@ pub enum DataSource {
     Network,
     Tcp,
 }
+impl From<u32> for DataSource {
+    fn from(value: u32) -> Self {
+        match value {
+            0 => DataSource::File,
+            1 => DataSource::Stdin,
+            2 => DataSource::Network,
+            3 => DataSource::Tcp,
+            _ => DataSource::File, // Default or fallback case
+        }
+    }
+}
+
 
 #[derive(Default, Debug, PartialEq, Eq, Clone, Copy)]
 pub enum StreamMode {
@@ -627,3 +639,8 @@ impl Language {
         }
     }
 }
+impl PartialEq for BufferdataType {
+    fn eq(&self, other: &Self) -> bool {
+        std::mem::discriminant(self) == std::mem::discriminant(other)
+    }
+}

src/rust/lib_ccxr/src/avc_functions/mod.rs

@@ -17,7 +17,7 @@
 //! | `language[NB_LANGUAGE]` | [`Language`]               |
 
 mod constants;
-mod options;
+pub mod options;
 
 pub use constants::*;
 pub use options::*;

src/rust/lib_ccxr/src/common/constants.rs

@@ -5,3 +5,4 @@ pub mod subtitle;
 pub mod teletext;
 pub mod time;
 pub mod util;
+pub mod avc_functions;