5#include <private/qvideotexturehelper_p.h>
6#include <QtCore/qloggingcategory.h>
8#include <gst/video/video.h>
9#include <gst/video/video-frame.h>
10#include <gst/video/gstvideometa.h>
11#include <gst/pbutils/gstpluginsbaseversion.h>
13#include <common/qgstutils_p.h>
15#if QT_CONFIG(gstreamer_gl)
16# include <QtGui/rhi/qrhi.h>
17# include <QtGui/qopenglcontext.h>
18# include <QtGui/qopenglfunctions.h>
19# include <QtGui/qopengl.h>
21# include <gst/gl/gstglconfig.h>
22# include <gst/gl/gstglmemory.h>
23# include <gst/gl/gstglsyncmeta.h>
25# if QT_CONFIG(gstreamer_gl_egl)
27# include <EGL/eglext.h>
30# if QT_CONFIG(gstreamer_gl_egl) && QT_CONFIG(linux_dmabuf)
31# include <common/qgstreameregldisplay_p.h>
32# include <gst/allocators/gstdmabuf.h>
38Q_STATIC_LOGGING_CATEGORY(qLcGstVideoBuffer,
"qt.multimedia.gstreamer.videobuffer");
41#define fourcc_code(a, b, c, d) ((uint32_t)(a) | ((uint32_t)(b) << 8
) |
42 ((uint32_t)(c) << 16
) | ((uint32_t)(d) << 24
))
70 const QVideoFrameFormat &frameFormat)
78 m_type = m_memoryFormat != QGstCaps::CpuMemory ? QVideoFrame::RhiTextureHandle
79 : QVideoFrame::NoHandle;
84 Q_ASSERT(m_mode == QVideoFrame::NotMapped);
89 const GstMapFlags flags = GstMapFlags(((mode & QVideoFrame::ReadOnly) ? GST_MAP_READ : 0)
90 | ((mode & QVideoFrame::WriteOnly) ? GST_MAP_WRITE : 0));
93 if (mode == QVideoFrame::NotMapped || m_mode != QVideoFrame::NotMapped)
96 const GstVideoInfo &gstVideoInfo = m_videoInfo.gstVideoInfo;
97 if (!gstVideoInfo.finfo || gstVideoInfo.finfo->n_planes == 0) {
98 if (gst_buffer_map(m_buffer.get(), &m_frame.map[0], flags)) {
99 mapData.planeCount = 1;
100 mapData.bytesPerLine[0] = -1;
101 mapData.dataSize[0] = m_frame.map[0].size;
102 mapData.data[0] =
static_cast<uchar *>(m_frame.map[0].data);
106 }
else if (gst_video_frame_map(&m_frame, &gstVideoInfo, m_buffer.get(), flags)) {
107 mapData.planeCount = GST_VIDEO_FRAME_N_PLANES(&m_frame);
109 for (guint i = 0; i < GST_VIDEO_FRAME_N_PLANES(&m_frame); ++i) {
110 mapData.bytesPerLine[i] = GST_VIDEO_FRAME_PLANE_STRIDE(&m_frame, i);
111 mapData.data[i] =
static_cast<uchar *>(GST_VIDEO_FRAME_PLANE_DATA(&m_frame, i));
112 mapData.dataSize[i] = mapData.bytesPerLine[i]*GST_VIDEO_FRAME_COMP_HEIGHT(&m_frame, i);
122 if (m_mode != QVideoFrame::NotMapped) {
123 if (!m_videoInfo.gstVideoInfo.finfo || m_videoInfo.gstVideoInfo.finfo->n_planes == 0)
124 gst_buffer_unmap(m_buffer.get(), &m_frame.map[0]);
126 gst_video_frame_unmap(&m_frame);
128 m_mode = QVideoFrame::NotMapped;
136#if QT_CONFIG(gstreamer_gl_egl) && QT_CONFIG(linux_dmabuf)
139fourccFromGstVideoFormat(
const GstVideoFormat format,
int plane,
bool singleEGLImage)
141#if G_BYTE_ORDER == G_LITTLE_ENDIAN
142 const gint argb_fourcc = DRM_FORMAT_ARGB8888;
143 const gint rgba_fourcc = DRM_FORMAT_ABGR8888;
144 const gint rgb_fourcc = DRM_FORMAT_BGR888;
145 const gint rg_fourcc = DRM_FORMAT_GR88;
147 const gint argb_fourcc = DRM_FORMAT_BGRA8888;
148 const gint rgba_fourcc = DRM_FORMAT_RGBA8888;
149 const gint rgb_fourcc = DRM_FORMAT_RGB888;
150 const gint rg_fourcc = DRM_FORMAT_RG88;
154 case GST_VIDEO_FORMAT_RGB16:
155 case GST_VIDEO_FORMAT_BGR16:
156 return DRM_FORMAT_RGB565;
158 case GST_VIDEO_FORMAT_RGB:
159 case GST_VIDEO_FORMAT_BGR:
162 case GST_VIDEO_FORMAT_BGRx:
163 case GST_VIDEO_FORMAT_BGRA:
166 case GST_VIDEO_FORMAT_AYUV:
167 if (singleEGLImage)
return DRM_FORMAT_AYUV;
169 case GST_VIDEO_FORMAT_RGBx:
170 case GST_VIDEO_FORMAT_RGBA:
171 case GST_VIDEO_FORMAT_ARGB:
172 case GST_VIDEO_FORMAT_xRGB:
173 case GST_VIDEO_FORMAT_ABGR:
174 case GST_VIDEO_FORMAT_xBGR:
177 case GST_VIDEO_FORMAT_GRAY8:
178 return DRM_FORMAT_R8;
180 case GST_VIDEO_FORMAT_YUY2:
181 return DRM_FORMAT_YUYV;
183 case GST_VIDEO_FORMAT_UYVY:
184 return DRM_FORMAT_UYVY;
186 case GST_VIDEO_FORMAT_GRAY16_LE:
187 case GST_VIDEO_FORMAT_GRAY16_BE:
188 if (singleEGLImage)
return DRM_FORMAT_R16;
191 case GST_VIDEO_FORMAT_NV12:
192 if (singleEGLImage)
return DRM_FORMAT_NV12;
194 case GST_VIDEO_FORMAT_NV21:
195 if (singleEGLImage)
return DRM_FORMAT_NV21;
196 return plane == 0 ? DRM_FORMAT_R8 : rg_fourcc;
198 case GST_VIDEO_FORMAT_I420:
199 if (singleEGLImage)
return DRM_FORMAT_YUV420;
201 case GST_VIDEO_FORMAT_YV12:
202 if (singleEGLImage)
return DRM_FORMAT_YVU420;
204 case GST_VIDEO_FORMAT_Y41B:
205 if (singleEGLImage)
return DRM_FORMAT_YUV411;
207 case GST_VIDEO_FORMAT_Y42B:
208 if (singleEGLImage)
return DRM_FORMAT_YUV422;
210 case GST_VIDEO_FORMAT_Y444:
211 if (singleEGLImage)
return DRM_FORMAT_YUV444;
212 return DRM_FORMAT_R8;
214 case GST_VIDEO_FORMAT_BGR10A2_LE:
215 return DRM_FORMAT_BGRA1010102;
217 case GST_VIDEO_FORMAT_P010_10LE:
218 case GST_VIDEO_FORMAT_P010_10BE:
219 if (singleEGLImage)
return DRM_FORMAT_P010;
220 return plane == 0 ? DRM_FORMAT_R16 : DRM_FORMAT_RG1616;
227static void logGlAndEglErrors(
const char *context)
229 if (!qLcGstVideoBuffer().isDebugEnabled())
232 const GLenum glError = glGetError();
233 const EGLint eglError = eglGetError();
234 if (glError == GL_NO_ERROR && eglError == EGL_SUCCESS)
237 qCDebug(qLcGstVideoBuffer).nospace()
238 << context <<
": GL error 0x" << Qt::hex << glError
239 <<
", EGL error 0x" << eglError;
243#if QT_CONFIG(gstreamer_gl)
248 std::array<guint32, QVideoTextureHelper::TextureDescription::maxPlanes> names{};
251class QGstQVideoFrameTextures :
public QVideoFrameTextures
254 QGstQVideoFrameTextures(QRhi *rhi,
256 QVideoFrameFormat::PixelFormat format,
257 GlTextures &textures,
258 QGstCaps::MemoryFormat memoryFormat)
260 , m_glTextures(textures)
262 QRhiTexture::Flags textureFlags = {};
263 if (QVideoTextureHelper::forceGlTextureExternalOesIsSet()
264 && m_rhi && rhi->backend() == QRhi::OpenGLES2)
265 textureFlags = {QRhiTexture::ExternalOES};
267 bool isDmaBuf = memoryFormat == QGstCaps::DMABuf;
268 auto fallbackPolicy = isDmaBuf
269 ? QVideoTextureHelper::TextureDescription::FallbackPolicy::Disable
270 : QVideoTextureHelper::TextureDescription::FallbackPolicy::Enable;
272 auto desc = QVideoTextureHelper::textureDescription(format);
273 for (uint i = 0; i < textures.count; ++i) {
275 QSize planeSize = desc->rhiPlaneSize(size, i, isDmaBuf ?
nullptr : m_rhi);
276 QRhiTexture::Format format = desc->rhiTextureFormat(i, m_rhi, fallbackPolicy);
277 m_textures[i].reset(rhi->newTexture(format, planeSize, 1, textureFlags));
278 m_textures[i]->createFrom({textures.names[i], 0});
282 ~QGstQVideoFrameTextures() override
284 m_rhi->makeThreadLocalNativeContextCurrent();
285 auto ctx = QOpenGLContext::currentContext();
286 if (m_glTextures.owned && ctx)
287 ctx->functions()->glDeleteTextures(
int(m_glTextures.count), m_glTextures.names.data());
290 QRhiTexture *texture(uint plane)
const override
292 return plane < m_glTextures.count ? m_textures[plane].get() :
nullptr;
296 QRhi *m_rhi =
nullptr;
297 GlTextures m_glTextures;
298 std::unique_ptr<QRhiTexture> m_textures[QVideoTextureHelper::TextureDescription::maxPlanes];
301static GlTextures mapFromGlTexture(
const QGstBufferHandle &bufferHandle, GstVideoFrame &frame,
302 GstVideoInfo &videoInfo)
304 qCDebug(qLcGstVideoBuffer) <<
"Mapping textures from GL memory";
306 GstBuffer *buffer = bufferHandle.get();
307 auto *mem = GST_GL_BASE_MEMORY_CAST(gst_buffer_peek_memory(buffer, 0));
311 if (!gst_video_frame_map(&frame, &videoInfo, buffer, GstMapFlags(GST_MAP_READ|GST_MAP_GL))) {
312 qWarning() <<
"Could not map GL textures";
316 auto *sync_meta = gst_buffer_get_gl_sync_meta(buffer);
317 GstBuffer *sync_buffer =
nullptr;
319 sync_buffer = gst_buffer_new();
320 sync_meta = gst_buffer_add_gl_sync_meta(mem->context, sync_buffer);
322 gst_gl_sync_meta_set_sync_point (sync_meta, mem->context);
323 gst_gl_sync_meta_wait (sync_meta, mem->context);
325 gst_buffer_unref(sync_buffer);
328 textures.count = frame.info.finfo->n_planes;
330 for (uint i = 0; i < textures.count; ++i)
331 textures.names[i] = *(guint32 *)frame.data[i];
333 gst_video_frame_unmap(&frame);
338# if QT_CONFIG(gstreamer_gl_egl) && QT_CONFIG(linux_dmabuf)
339static GlTextures mapFromDmaBuffer(QRhi *rhi,
const QGstBufferHandle &bufferHandle,
340 const QGstVideoInfo &videoInfo, Qt::HANDLE eglDisplay,
341 QFunctionPointer eglImageTargetTexture2D)
343 qCDebug(qLcGstVideoBuffer) <<
"Importing textures from DMA buffer";
344 logGlAndEglErrors(
"mapFromDmaBuffer");
346 GstBuffer *buffer = bufferHandle.get();
348 Q_ASSERT(gst_is_dmabuf_memory(gst_buffer_peek_memory(buffer, 0)));
349 Q_ASSERT(eglDisplay);
350 Q_ASSERT(eglImageTargetTexture2D);
352 Q_ASSERT(rhi->backend() == QRhi::OpenGLES2);
354 auto *nativeHandles =
static_cast<
const QRhiGles2NativeHandles *>(rhi->nativeHandles());
355 auto glContext = nativeHandles->context;
357 qCWarning(qLcGstVideoBuffer) <<
"no GL context";
361 const GstVideoInfo &gstVideoInfo = videoInfo.gstVideoInfo;
362 if (!gstVideoInfo.finfo) {
363 qCWarning(qLcGstVideoBuffer) <<
"Missing valid GstVideoInfo for DMABuf GstBuffer";
367 if (videoInfo.dmaDrmModifier && *videoInfo.dmaDrmModifier != 0) {
368 qCWarning(qLcGstVideoBuffer) <<
"Unsupported non-linear DMABuf modifier:"
369 << Qt::hex << *videoInfo.dmaDrmModifier;
373 const GstVideoMeta *videoMeta = gst_buffer_get_video_meta(buffer);
374 const GstVideoFormat videoInfoFormat = GST_VIDEO_INFO_FORMAT(&gstVideoInfo);
375 GstVideoFormat format = videoMeta ? videoMeta->format : videoInfoFormat;
376 if (format == GST_VIDEO_FORMAT_UNKNOWN)
377 format = videoInfoFormat;
379 const int nPlanes = videoMeta ? videoMeta->n_planes : GST_VIDEO_INFO_N_PLANES(&gstVideoInfo);
380 const int nMemoryBlocks = gst_buffer_n_memory(buffer);
381 static const bool externalOes = QVideoTextureHelper::forceGlTextureExternalOesIsSet();
382 static const bool singleEGLImage =
383 externalOes || qEnvironmentVariableIntValue(
"QT_GSTREAMER_FORCE_SINGLE_EGLIMAGE") != 0;
385 qCDebug(qLcGstVideoBuffer) <<
"format:" << gst_video_format_to_string(format)
386 <<
"nPlanes:" << nPlanes
387 <<
"nMemoryBlocks:" << nMemoryBlocks
388 <<
"externalOes:" << externalOes
389 <<
"singleEGLImage:" << singleEGLImage;
391 constexpr int maxPlanes = 4;
392 Q_ASSERT(nPlanes >= 1
393 && nPlanes <= maxPlanes
394 && (nMemoryBlocks == 1 || nMemoryBlocks == nPlanes));
396 const int nEGLImages = singleEGLImage ? 1 : nPlanes;
397 std::array<EGLAttrib, maxPlanes> planeFourcc{};
398 for (
int plane = 0; plane < nEGLImages; ++plane) {
399 const int fourcc = fourccFromGstVideoFormat(format, plane, singleEGLImage);
401 qCWarning(qLcGstVideoBuffer) <<
"Unsupported format for DMABuf:"
402 << gst_video_format_to_string(format) <<
"plane:" << plane
403 <<
"singleEGLImage" << singleEGLImage;
406 planeFourcc[plane] = EGLAttrib(fourcc);
409 GlTextures textures = {};
410 textures.owned =
true;
411 textures.count = nEGLImages;
413 QOpenGLFunctions functions(glContext);
414 functions.glGenTextures(
int(textures.count), textures.names.data());
415 logGlAndEglErrors(
"glGenTextures");
417 std::array<
int, maxPlanes> fds{-1, -1, -1, -1};
418 for (
int i = 0; i < nMemoryBlocks && i < maxPlanes; ++i) {
419 fds[i] = gst_dmabuf_memory_get_fd(gst_buffer_peek_memory(buffer, i));
422 auto fdForPlane = [&](
int plane) -> EGLAttrib {
423 if (plane < 0 || plane >= maxPlanes || plane >= nMemoryBlocks)
425 return (fds[plane] >= 0) ? fds[plane] : fds[0];
428 auto compWidth = [&](
int plane) -> EGLAttrib {
429 return singleEGLImage ? GST_VIDEO_INFO_WIDTH(&gstVideoInfo)
430 : GST_VIDEO_INFO_COMP_WIDTH(&gstVideoInfo, plane);
433 auto compHeight = [&](
int plane) -> EGLAttrib {
434 return singleEGLImage ? GST_VIDEO_INFO_HEIGHT(&gstVideoInfo)
435 : GST_VIDEO_INFO_COMP_HEIGHT(&gstVideoInfo, plane);
438 auto planeOffset = [&](
int plane) -> EGLAttrib {
440 if (nPlanes == nMemoryBlocks)
443 return videoMeta->offset[plane];
444 return GST_VIDEO_INFO_PLANE_OFFSET(&gstVideoInfo, plane);
447 auto planeStride = [&](
int plane) -> EGLAttrib {
449 return videoMeta->stride[plane];
450 return GST_VIDEO_INFO_PLANE_STRIDE(&gstVideoInfo, plane);
453 for (
int plane = 0; plane < nEGLImages; ++plane) {
454 constexpr int maxAttrCount = 31;
455 std::array<EGLAttrib, maxAttrCount> attr;
458 const int width = compWidth(plane);
459 const int height = compHeight(plane);
461 attr[i++] = EGL_WIDTH;
463 attr[i++] = EGL_HEIGHT;
465 attr[i++] = EGL_LINUX_DRM_FOURCC_EXT;
466 attr[i++] = planeFourcc[plane];
468 attr[i++] = EGL_DMA_BUF_PLANE0_FD_EXT;
469 attr[i++] = fdForPlane(plane);
470 attr[i++] = EGL_DMA_BUF_PLANE0_OFFSET_EXT;
471 attr[i++] = planeOffset(plane);
472 attr[i++] = EGL_DMA_BUF_PLANE0_PITCH_EXT;
473 attr[i++] = planeStride(plane);
475 if (singleEGLImage && nPlanes > 1) {
476 attr[i++] = EGL_DMA_BUF_PLANE1_FD_EXT;
477 attr[i++] = fdForPlane(1);
478 attr[i++] = EGL_DMA_BUF_PLANE1_OFFSET_EXT;
479 attr[i++] = planeOffset(1);
480 attr[i++] = EGL_DMA_BUF_PLANE1_PITCH_EXT;
481 attr[i++] = planeStride(1);
484 if (singleEGLImage && nPlanes > 2) {
485 attr[i++] = EGL_DMA_BUF_PLANE2_FD_EXT;
486 attr[i++] = fdForPlane(2);
487 attr[i++] = EGL_DMA_BUF_PLANE2_OFFSET_EXT;
488 attr[i++] = planeOffset(2);
489 attr[i++] = EGL_DMA_BUF_PLANE2_PITCH_EXT;
490 attr[i++] = planeStride(2);
493 if (singleEGLImage && nPlanes > 3) {
494 attr[i++] = EGL_DMA_BUF_PLANE3_FD_EXT;
495 attr[i++] = fdForPlane(3);
496 attr[i++] = EGL_DMA_BUF_PLANE3_OFFSET_EXT;
497 attr[i++] = planeOffset(3);
498 attr[i++] = EGL_DMA_BUF_PLANE3_PITCH_EXT;
499 attr[i++] = planeStride(3);
502 attr[i++] = EGL_NONE;
503 Q_ASSERT(i <= maxAttrCount);
505 EGLImage image = eglCreateImage(eglDisplay,
507 EGL_LINUX_DMA_BUF_EXT,
510 if (image == EGL_NO_IMAGE_KHR) {
511 qCWarning(qLcGstVideoBuffer) <<
"could not create EGL image for plane" << plane
512 <<
", EGL error 0x" << Qt::hex << eglGetError();
515 logGlAndEglErrors(
"eglCreateImage");
517 #ifdef GL_OES_EGL_image_external
518 GLenum target = externalOes ? GL_TEXTURE_EXTERNAL_OES : GL_TEXTURE_2D;
520 GLenum target = GL_TEXTURE_2D;
522 functions.glBindTexture(target, textures.names[plane]);
524 auto EGLImageTargetTexture2D = (PFNGLEGLIMAGETARGETTEXTURE2DOESPROC)eglImageTargetTexture2D;
525 EGLImageTargetTexture2D(target, image);
526 logGlAndEglErrors(
"glEGLImageTargetTexture2DOES");
528 eglDestroyImage(eglDisplay, image);
538#if QT_CONFIG(gstreamer_gl)
539 GlTextures textures = {};
540 if (m_memoryFormat == QGstCaps::GLTexture)
541 textures = mapFromGlTexture(m_buffer, m_frame, m_videoInfo.gstVideoInfo);
543# if QT_CONFIG(gstreamer_gl_egl) && QT_CONFIG(linux_dmabuf)
544 else if (m_memoryFormat == QGstCaps::DMABuf && qGstEglCanMapDmaBuf()
545 && rhi.backend() == QRhi::OpenGLES2)
546 textures = mapFromDmaBuffer(&rhi, m_buffer, m_videoInfo, qGstEglDisplay(),
547 qGstEglImageTargetTexture2D());
550 if (textures.count > 0)
551 return std::make_unique<QGstQVideoFrameTextures>(
552 &rhi, QSize{ m_videoInfo.gstVideoInfo.width, m_videoInfo.gstVideoInfo.height },
553 m_frameFormat.pixelFormat(), textures, m_memoryFormat);
QGstVideoBuffer(QGstBufferHandle buffer, const QGstVideoInfo &videoInfo, const QVideoFrameFormat &frameFormat)
~QGstVideoBuffer() override
bool isDmaBuf() const override
QVideoFrameTexturesUPtr mapTextures(QRhi &, QVideoFrameTexturesUPtr &) override
void unmap() override
Releases the memory mapped by the map() function.
MapData map(QVideoFrame::MapMode mode) override
Maps the planes of a video buffer to memory.
Combined button and popup list for selecting options.
#define fourcc_code(a, b, c, d)