mirrors/gstreamer
mirrors/gstreamer
1
1
Fork 0
mirror of https://gitlab.freedesktop.org/gstreamer/gstreamer.git synced 2025-01-11 01:45:33 +00:00
Code Issues 1 Projects Releases Wiki Activity

ajasrc: Improve debug output related to frame transfers

Browse source 
Part-of: <https://gitlab.freedesktop.org/gstreamer/gstreamer/-/merge_requests/6208>
This commit is contained in:
Sebastian Dröge 2024-02-23 12:21:04 +02:00 committed by GStreamer Marge Bot
parent 9ab9ceb964
commit 170bf0cc8e
1 changed files with 51 additions and 24 deletions
Show stats Download patch file Download diff file Expand all files Collapse all files

75
subprojects/gst-plugins-bad/sys/aja/gstajasrc.cpp
View file

@ -2497,21 +2497,23 @@ restart:
self->device->device->AutoCirculateGetStatus(self->channel, status); self->device->device->AutoCirculateGetStatus(self->channel, status);
GST_TRACE_OBJECT(self, GST_TRACE_OBJECT(
"Start frame %d " self,
"end frame %d " "State %d "
"active frame %d " "start frame %d "
"start time %" G_GUINT64_FORMAT "end frame %d "
" " "active frame %d "
"current time %" G_GUINT64_FORMAT "start time %" GST_TIME_FORMAT
" " " "
"frames processed %u " "current time %" GST_TIME_FORMAT
"frames dropped %u " " "
"buffer level %u", "frames processed %u "
status.acStartFrame, status.acEndFrame, "frames dropped %u "
status.acActiveFrame, status.acRDTSCStartTime, "buffer level %u",
status.acRDTSCCurrentTime, status.acFramesProcessed, status.acState, status.acStartFrame, status.acEndFrame,
status.acFramesDropped, status.acBufferLevel); status.acActiveFrame, GST_TIME_ARGS(status.acRDTSCStartTime * 100),
GST_TIME_ARGS(status.acRDTSCCurrentTime * 100),
status.acFramesProcessed, status.acFramesDropped, status.acBufferLevel);
if (frames_dropped_last == G_MAXUINT64) { if (frames_dropped_last == G_MAXUINT64) {
frames_dropped_last = status.acFramesDropped; frames_dropped_last = status.acFramesDropped;
@ -2639,6 +2641,36 @@ restart:
continue; continue;
} }
const AUTOCIRCULATE_TRANSFER_STATUS &transfer_status =
transfer.GetTransferStatus();
const FRAME_STAMP &frame_stamp = transfer_status.GetFrameStamp();
GstClockTime frame_time = frame_stamp.acFrameTime * 100;
GstClockTime now_sys = g_get_real_time() * 1000;
GstClockTime now_gst = gst_clock_get_time(clock);
GST_TRACE_OBJECT(self,
"State %d "
"transfer frame %d "
"current frame %u "
"frame time %" GST_TIME_FORMAT
" "
"current frame time %" GST_TIME_FORMAT
" "
"current time %" GST_TIME_FORMAT
" "
"frames processed %u "
"frames dropped %u "
"buffer level %u",
transfer_status.acState, transfer_status.acTransferFrame,
frame_stamp.acCurrentFrame,
GST_TIME_ARGS(frame_stamp.acFrameTime * 100),
GST_TIME_ARGS(frame_stamp.acCurrentFrameTime * 100),
GST_TIME_ARGS(frame_stamp.acCurrentTime * 100),
transfer_status.acFramesProcessed,
transfer_status.acFramesDropped,
transfer_status.acBufferLevel);
gst_buffer_set_size(audio_buffer, transfer.GetCapturedAudioByteCount()); gst_buffer_set_size(audio_buffer, transfer.GetCapturedAudioByteCount());
if (anc_buffer) if (anc_buffer)
gst_buffer_set_size(anc_buffer, gst_buffer_set_size(anc_buffer,
@ -2669,22 +2701,17 @@ restart:
} }
NTV2_RP188 time_code; NTV2_RP188 time_code;
transfer.acTransferStatus.acFrameStamp.GetInputTimeCode(time_code, frame_stamp.GetInputTimeCode(time_code, tc_index);
tc_index);
gint64 frame_time = transfer.acTransferStatus.acFrameStamp.acFrameTime; if (now_sys > frame_time) {
gint64 now_sys = g_get_real_time(); GstClockTime diff = now_sys - frame_time;
GstClockTime now_gst = gst_clock_get_time(clock);
if (now_sys * 10 > frame_time) {
GstClockTime diff = now_sys * 1000 - frame_time * 100;
if (now_gst > diff) if (now_gst > diff)
now_gst -= diff; now_gst -= diff;
else else
now_gst = 0; now_gst = 0;
} }
GstClockTime base_time = GstClockTime base_time = GST_ELEMENT_CAST(self)->base_time;
gst_element_get_base_time(GST_ELEMENT_CAST(self));
if (now_gst > base_time) if (now_gst > base_time)
now_gst -= base_time; now_gst -= base_time;
else else