xux-rs 0.2.1

Binding 
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
66

use std::{marker::PhantomPinned, pin::Pin, ptr::copy_nonoverlapping};

use cyberex::{void::*, xself::*};

use crate::{
    define::{CESStreamInfo, EsPkg},
    sys::*,
};

extern "C" fn DataCallBack(
    data: *const ::std::os::raw::c_uchar,
    len: ::std::os::raw::c_int,
    info: *const ESStreamInfo,
    user: *mut ::std::os::raw::c_void,
) {
    let pkgs = opacue_to_mut::<Vec<EsPkg>>(user.cast());

    pkgs.push(EsPkg {
        payload: {
            let payload = vec![0u8; len as _];
            unsafe {
                copy_nonoverlapping(data, payload.as_ptr() as _, len as _);
            }
            payload
        },
        info: unsafe { std::ptr::read(info) },
    });
}

pub struct Dmuxer {
    ptr: HyVoid<()>,
    _pin: PhantomPinned,
}

impl Dmuxer {
    pub fn new() -> Pin<Box<Self>> {
        Box::pin(Self {
            ptr: unsafe { HyVoid::from_ptr(ffDmCreate()) },
            _pin: PhantomPinned,
        })
    }
    pub fn write(self: &mut Pin<Box<Self>>, data: &[u8], info: &CESStreamInfo) -> Vec<EsPkg> {
        let this = unsafe { self_mut_from_pinbox(self) };
        let mut pkgs = Box::<std::vec::Vec<EsPkg>>::default();

        unsafe {
            ffDmStreamInput(
                this.ptr.as_ptr(),
                data.as_ptr(),
                data.len() as i32,
                info as *const _,
                0 as _, // NO-USE just placeholder
                mut_to_opacue(pkgs.as_mut()),
                Some(DataCallBack),
                None,
            );
        }

        *pkgs
    }
}
impl Drop for Dmuxer {
    fn drop(&mut self) {
        unsafe { ffDmDestroy(self.ptr.as_ptr()) }
    }
}