FaSTTUBe/GST-Tensordecoder-ov_ep
37
0
Fork 0
Code Issues Pull Requests Actions Packages Projects Releases Wiki Activity

hipconverter: Avoid unnecessary sync

Browse Source 
If input and output buffers are running on the same stream,
record event instead of sync

Part-of: <https://gitlab.freedesktop.org/gstreamer/gstreamer/-/merge_requests/9281>
This commit is contained in:
Seungha Yang 2025-06-15 23:09:17 +09:00 committed by GStreamer Marge Bot
parent 7d259c4224
commit c1f023baaf
1 changed files with 24 additions and 1 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

25
subprojects/gst-plugins-bad/sys/hip/gsthipconverter.cpp
View File

@ -1807,6 +1807,21 @@ gst_hip_converter_convert_frame (GstHipConverter * converter,
return FALSE;
}
auto in_hmem = (GstHipMemory *) gst_buffer_peek_memory (in_buf, 0);
auto out_hmem = (GstHipMemory *) gst_buffer_peek_memory (out_buf, 0);
auto in_stream = gst_hip_memory_get_stream (in_hmem);
auto out_stream = gst_hip_memory_get_stream (out_hmem);
gboolean set_event = FALSE;
/* Avoid sync if in/out mem use the same hip stream */
priv->stream = gst_hip_stream_get_handle (out_stream);
if (in_stream != out_stream) {
gst_hip_memory_sync (in_hmem);
} else {
set_event = TRUE;
}
priv = converter->priv;
format = priv->texture_fmt;
@ -1891,7 +1906,15 @@ gst_hip_converter_convert_frame (GstHipConverter * converter,
return FALSE;
}
HipStreamSynchronize (priv->vendor, priv->stream);
auto stream = gst_hip_device_get_stream (converter->device);
GstHipEvent *event;
if (set_event && gst_hip_stream_record_event (stream, &event)) {
auto hmem = (GstHipMemory *) gst_buffer_peek_memory (out_buf, 0);
gst_hip_memory_set_event (hmem, event);
gst_hip_event_unref (event);
} else {
HipStreamSynchronize (priv->vendor, priv->stream);
}
return TRUE;
}