mirror of
https://gitlab.freedesktop.org/gstreamer/gst-plugins-rs.git
synced 2024-12-29 13:30:34 +00:00
Refactor logic to get initial timestamp
This commit is contained in:
Daniel Vilar
parent
79fc47b41f
commit
1cabad0092
2 changed files with 141 additions and 100 deletions
|
|
@ -228,6 +228,30 @@ impl NdiAudioSrc {
|
|||
|
||||
// Virtual methods of gst::Element. We override none
|
||||
impl ElementImpl<BaseSrc> for NdiAudioSrc {
|
||||
fn change_state(&self, element: &BaseSrc, transition: gst::StateChange) -> gst::StateChangeReturn {
|
||||
if transition == gst::StateChange::PausedToPlaying{
|
||||
let receivers = hashmap_receivers.lock().unwrap();
|
||||
let settings = self.settings.lock().unwrap();
|
||||
|
||||
let receiver = receivers.get(&settings.id_receiver).unwrap();
|
||||
let recv = &receiver.ndi_instance;
|
||||
let pNDI_recv = recv.recv;
|
||||
|
||||
let audio_frame: NDIlib_audio_frame_v2_t = Default::default();
|
||||
|
||||
let mut frame_type: NDIlib_frame_type_e = NDIlib_frame_type_e::NDIlib_frame_type_none;
|
||||
unsafe{
|
||||
while frame_type != NDIlib_frame_type_e::NDIlib_frame_type_audio{
|
||||
frame_type = NDIlib_recv_capture_v2(pNDI_recv, ptr::null(), &audio_frame, ptr::null(), 1000);
|
||||
}
|
||||
|
||||
if ndi_struct.initial_timestamp <= audio_frame.timestamp as u64 || ndi_struct.initial_timestamp == 0{
|
||||
ndi_struct.initial_timestamp = audio_frame.timestamp as u64;
|
||||
}
|
||||
}
|
||||
}
|
||||
element.parent_change_state(transition)
|
||||
}
|
||||
}
|
||||
|
||||
// Virtual methods of gst_base::BaseSrc
|
||||
|
|
@ -281,54 +305,55 @@ impl NdiAudioSrc {
|
|||
true
|
||||
}
|
||||
|
||||
// fn query(&self, element: &BaseSrc, query: &mut gst::QueryRef) -> bool {
|
||||
// use gst::QueryView;
|
||||
//
|
||||
// match query.view_mut() {
|
||||
// // We only work in Push mode. In Pull mode, create() could be called with
|
||||
// // arbitrary offsets and we would have to produce for that specific offset
|
||||
// QueryView::Scheduling(ref mut q) => {
|
||||
// q.set(gst::SchedulingFlags::SEQUENTIAL, 1, -1, 0);
|
||||
// q.add_scheduling_modes(&[gst::PadMode::Push]);
|
||||
// return true;
|
||||
// }
|
||||
// // In Live mode we will have a latency equal to the number of samples in each buffer.
|
||||
// // We can't output samples before they were produced, and the last sample of a buffer
|
||||
// // is produced that much after the beginning, leading to this latency calculation
|
||||
// QueryView::Latency(ref mut q) => {
|
||||
// let settings = &*self.settings.lock().unwrap();
|
||||
// let state = self.state.lock().unwrap();
|
||||
//
|
||||
// if let Some(ref _info) = state.info {
|
||||
// // let latency = gst::SECOND
|
||||
// // .mul_div_floor(1024 as u64, _info.rate() as u64)
|
||||
// // .unwrap();
|
||||
// let latency = gst::SECOND.mul_div_floor(3 as u64, 2 as u64).unwrap();
|
||||
// // let latency = gst::SECOND
|
||||
// // .mul_div_floor(1 as u64, 30 as u64)
|
||||
// // .unwrap();
|
||||
// // gst_debug!(self.cat, obj: element, "Returning latency {}", latency);
|
||||
// let max = latency * 1843200;
|
||||
// // println!("{:?}", latency);
|
||||
// // println!("{:?}",max);
|
||||
// q.set(true, latency, max);
|
||||
// return true;
|
||||
// } else {
|
||||
// return false;
|
||||
// }
|
||||
// }
|
||||
// _ => (),
|
||||
// }
|
||||
// BaseSrcBase::parent_query(element, query)
|
||||
// }
|
||||
fn query(&self, element: &BaseSrc, query: &mut gst::QueryRef) -> bool {
|
||||
use gst::QueryView;
|
||||
|
||||
match query.view_mut() {
|
||||
// We only work in Push mode. In Pull mode, create() could be called with
|
||||
// arbitrary offsets and we would have to produce for that specific offset
|
||||
QueryView::Scheduling(ref mut q) => {
|
||||
q.set(gst::SchedulingFlags::SEQUENTIAL, 1, -1, 0);
|
||||
q.add_scheduling_modes(&[gst::PadMode::Push]);
|
||||
return true;
|
||||
}
|
||||
// In Live mode we will have a latency equal to the number of samples in each buffer.
|
||||
// We can't output samples before they were produced, and the last sample of a buffer
|
||||
// is produced that much after the beginning, leading to this latency calculation
|
||||
// QueryView::Latency(ref mut q) => {
|
||||
// let settings = &*self.settings.lock().unwrap();
|
||||
// let state = self.state.lock().unwrap();
|
||||
//
|
||||
// if let Some(ref _info) = state.info {
|
||||
// // let latency = gst::SECOND
|
||||
// // .mul_div_floor(1024 as u64, _info.rate() as u64)
|
||||
// // .unwrap();
|
||||
// let latency = gst::SECOND.mul_div_floor(3 as u64, 2 as u64).unwrap();
|
||||
// // let latency = gst::SECOND
|
||||
// // .mul_div_floor(1 as u64, 30 as u64)
|
||||
// // .unwrap();
|
||||
// // gst_debug!(self.cat, obj: element, "Returning latency {}", latency);
|
||||
// let max = latency * 1843200;
|
||||
// // println!("{:?}", latency);
|
||||
// // println!("{:?}",max);
|
||||
// q.set(true, latency, max);
|
||||
// return true;
|
||||
// } else {
|
||||
// return false;
|
||||
// }
|
||||
// }
|
||||
_ => (),
|
||||
}
|
||||
BaseSrcBase::parent_query(element, query)
|
||||
}
|
||||
|
||||
fn fixate(&self, element: &BaseSrc, caps: gst::Caps) -> gst::Caps {
|
||||
//We need to set the correct caps resolution and framerate
|
||||
unsafe{
|
||||
let mut receivers = hashmap_receivers.lock().unwrap();
|
||||
let receivers = hashmap_receivers.lock().unwrap();
|
||||
let settings = self.settings.lock().unwrap();
|
||||
|
||||
let receiver = receivers.get_mut(&settings.id_receiver).unwrap();
|
||||
let receiver = receivers.get(&settings.id_receiver).unwrap();
|
||||
|
||||
let recv = &receiver.ndi_instance;
|
||||
let pNDI_recv = recv.recv;
|
||||
|
||||
|
|
@ -339,10 +364,6 @@ impl NdiAudioSrc {
|
|||
frame_type = NDIlib_recv_capture_v2(pNDI_recv, ptr::null(), &audio_frame, ptr::null(), 1000);
|
||||
}
|
||||
|
||||
if ndi_struct.initial_timestamp <= audio_frame.timestamp as u64 || ndi_struct.initial_timestamp == 0{
|
||||
ndi_struct.initial_timestamp = audio_frame.timestamp as u64;
|
||||
}
|
||||
|
||||
let mut caps = gst::Caps::truncate(caps);
|
||||
{
|
||||
let caps = caps.make_mut();
|
||||
|
|
|
|||
|
|
@ -236,8 +236,33 @@ impl NdiVideoSrc {
|
|||
|
||||
// Virtual methods of gst::Element. We override none
|
||||
impl ElementImpl<BaseSrc> for NdiVideoSrc {
|
||||
fn change_state(&self, element: &BaseSrc, transition: gst::StateChange) -> gst::StateChangeReturn {
|
||||
if transition == gst::StateChange::PausedToPlaying{
|
||||
let receivers = hashmap_receivers.lock().unwrap();
|
||||
let settings = self.settings.lock().unwrap();
|
||||
|
||||
let receiver = receivers.get(&settings.id_receiver).unwrap();
|
||||
let recv = &receiver.ndi_instance;
|
||||
let pNDI_recv = recv.recv;
|
||||
|
||||
let video_frame: NDIlib_video_frame_v2_t = Default::default();
|
||||
|
||||
let mut frame_type: NDIlib_frame_type_e = NDIlib_frame_type_e::NDIlib_frame_type_none;
|
||||
unsafe{
|
||||
while frame_type != NDIlib_frame_type_e::NDIlib_frame_type_video{
|
||||
frame_type = NDIlib_recv_capture_v2(pNDI_recv, &video_frame, ptr::null(), ptr::null(), 1000);
|
||||
}
|
||||
|
||||
if ndi_struct.initial_timestamp <= video_frame.timestamp as u64 || ndi_struct.initial_timestamp == 0{
|
||||
ndi_struct.initial_timestamp = video_frame.timestamp as u64;
|
||||
}
|
||||
}
|
||||
}
|
||||
element.parent_change_state(transition)
|
||||
}
|
||||
}
|
||||
|
||||
|
||||
// Virtual methods of gst_base::BaseSrc
|
||||
impl BaseSrcImpl<BaseSrc> for NdiVideoSrc {
|
||||
// Called whenever the input/output caps are changing, i.e. in the very beginning before data
|
||||
|
|
@ -290,62 +315,61 @@ impl NdiVideoSrc {
|
|||
}
|
||||
|
||||
|
||||
// fn query(&self, element: &BaseSrc, query: &mut gst::QueryRef) -> bool {
|
||||
// use gst::QueryView;
|
||||
// println!("****************************************Dentro de query");
|
||||
// match query.view_mut() {
|
||||
// // We only work in Push mode. In Pull mode, create() could be called with
|
||||
// // arbitrary offsets and we would have to produce for that specific offset
|
||||
// QueryView::Scheduling(ref mut q) => {
|
||||
// q.set(gst::SchedulingFlags::SEQUENTIAL, 1, -1, 0);
|
||||
// q.add_scheduling_modes(&[gst::PadMode::Push]);
|
||||
// return true;
|
||||
// }
|
||||
// // In Live mode we will have a latency equal to the number of samples in each buffer.
|
||||
// // We can't output samples before they were produced, and the last sample of a buffer
|
||||
// // is produced that much after the beginning, leading to this latency calculation
|
||||
// QueryView::Latency(ref mut q) => {
|
||||
// let settings = self.settings.lock().unwrap();
|
||||
// let state = self.state.lock().unwrap();
|
||||
// println!("Dentro de query");
|
||||
//
|
||||
// if let Some(ref _info) = state.info {
|
||||
// // let latency = gst::SECOND
|
||||
// // .mul_div_floor(settings.samples_per_buffer as u64, info.rate() as u64)
|
||||
// // .unwrap();
|
||||
// let latency = gst::SECOND.mul_div_floor(3 as u64, 2 as u64).unwrap();
|
||||
// let mut latency = gst::SECOND.mul_div_floor(settings.latency, 1000).unwrap();
|
||||
// // if settings.latency > 2000{
|
||||
// // println!("{:?}", element.get_name());
|
||||
// // latency = gst::SECOND * 0;
|
||||
// // }
|
||||
// let latency = gst::SECOND * 0;
|
||||
// // .mul_div_floor(1 as u64, 30 as u64)
|
||||
// // .unwrap();
|
||||
// // gst_debug!(self.cat, obj: element, "Returning latency {}", latency);
|
||||
// let max = gst::SECOND * 120 * 1843200;
|
||||
// // println!("{:?}", latency2);
|
||||
// println!("{:?}", latency);
|
||||
// println!("{:?}", (settings.latency / 1000));
|
||||
// // println!("{:?}",max);
|
||||
// q.set(true, latency, max);
|
||||
// return true;
|
||||
// } else {
|
||||
// return false;
|
||||
// }
|
||||
// }
|
||||
// _ => (),
|
||||
// }
|
||||
// BaseSrcBase::parent_query(element, query)
|
||||
// }
|
||||
fn query(&self, element: &BaseSrc, query: &mut gst::QueryRef) -> bool {
|
||||
use gst::QueryView;
|
||||
match query.view_mut() {
|
||||
// We only work in Push mode. In Pull mode, create() could be called with
|
||||
// arbitrary offsets and we would have to produce for that specific offset
|
||||
QueryView::Scheduling(ref mut q) => {
|
||||
q.set(gst::SchedulingFlags::SEQUENTIAL, 1, -1, 0);
|
||||
q.add_scheduling_modes(&[gst::PadMode::Push]);
|
||||
return true;
|
||||
}
|
||||
// In Live mode we will have a latency equal to the number of samples in each buffer.
|
||||
// We can't output samples before they were produced, and the last sample of a buffer
|
||||
// is produced that much after the beginning, leading to this latency calculation
|
||||
// QueryView::Latency(ref mut q) => {
|
||||
// let settings = self.settings.lock().unwrap();
|
||||
// let state = self.state.lock().unwrap();
|
||||
// println!("Dentro de query");
|
||||
//
|
||||
// if let Some(ref _info) = state.info {
|
||||
// // let latency = gst::SECOND
|
||||
// // .mul_div_floor(settings.samples_per_buffer as u64, info.rate() as u64)
|
||||
// // .unwrap();
|
||||
// let latency = gst::SECOND.mul_div_floor(3 as u64, 2 as u64).unwrap();
|
||||
// let mut latency = gst::SECOND.mul_div_floor(settings.latency, 1000).unwrap();
|
||||
// // if settings.latency > 2000{
|
||||
// // println!("{:?}", element.get_name());
|
||||
// // latency = gst::SECOND * 0;
|
||||
// // }
|
||||
// let latency = gst::SECOND * 0;
|
||||
// // .mul_div_floor(1 as u64, 30 as u64)
|
||||
// // .unwrap();
|
||||
// // gst_debug!(self.cat, obj: element, "Returning latency {}", latency);
|
||||
// let max = gst::SECOND * 120 * 1843200;
|
||||
// // println!("{:?}", latency2);
|
||||
// println!("{:?}", latency);
|
||||
// println!("{:?}", (settings.latency / 1000));
|
||||
// // println!("{:?}",max);
|
||||
// q.set(true, latency, max);
|
||||
// return true;
|
||||
// } else {
|
||||
// return false;
|
||||
// }
|
||||
// }
|
||||
_ => (),
|
||||
}
|
||||
BaseSrcBase::parent_query(element, query)
|
||||
}
|
||||
|
||||
fn fixate(&self, element: &BaseSrc, caps: gst::Caps) -> gst::Caps {
|
||||
//We need to set the correct caps resolution and framerate
|
||||
unsafe{
|
||||
let mut receivers = hashmap_receivers.lock().unwrap();
|
||||
let receivers = hashmap_receivers.lock().unwrap();
|
||||
let settings = self.settings.lock().unwrap();
|
||||
|
||||
let receiver = receivers.get_mut(&settings.id_receiver).unwrap();
|
||||
let receiver = receivers.get(&settings.id_receiver).unwrap();
|
||||
let recv = &receiver.ndi_instance;
|
||||
let pNDI_recv = recv.recv;
|
||||
|
||||
|
|
@ -356,10 +380,6 @@ impl NdiVideoSrc {
|
|||
frame_type = NDIlib_recv_capture_v2(pNDI_recv, &video_frame, ptr::null(), ptr::null(), 1000);
|
||||
}
|
||||
|
||||
if ndi_struct.initial_timestamp <= video_frame.timestamp as u64 || ndi_struct.initial_timestamp == 0{
|
||||
ndi_struct.initial_timestamp = video_frame.timestamp as u64;
|
||||
}
|
||||
|
||||
let mut caps = gst::Caps::truncate(caps);
|
||||
{
|
||||
let caps = caps.make_mut();
|
||||
|
|
|
|||
Loading…
Reference in a new issue