mirror of
https://gitlab.freedesktop.org/gstreamer/gstreamer.git
synced 2025-01-10 17:35:59 +00:00
v4l2codecs: Add VP8 decoder
This is derived from the H264 decoder, some boiler plate will be factored out in the following commits. Part-of: <https://gitlab.freedesktop.org/gstreamer/gst-plugins-bad/-/merge_requests/1216>
This commit is contained in:
parent
bfc605a666
commit
72c0b3e5ae
5 changed files with 1082 additions and 0 deletions
909
sys/v4l2codecs/gstv4l2codecvp8dec.c
Normal file
909
sys/v4l2codecs/gstv4l2codecvp8dec.c
Normal file
|
@ -0,0 +1,909 @@
|
|||
/* GStreamer
|
||||
* Copyright (C) 2020 Nicolas Dufresne <nicolas.dufresne@collabora.com>
|
||||
*
|
||||
* This library is free software; you can redistribute it and/or
|
||||
* modify it under the terms of the GNU Library General Public
|
||||
* License as published by the Free Software Foundation; either
|
||||
* version 2 of the License, or (at your option) any later version.
|
||||
*
|
||||
* This library is distributed in the hope that it will be useful,
|
||||
* but WITHOUT ANY WARRANTY; without even the implied warranty of
|
||||
* MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE. See the GNU
|
||||
* Library General Public License for more details.
|
||||
*
|
||||
* You should have received a copy of the GNU Library General Public
|
||||
* License along with this library; if not, write to the
|
||||
* Free Software Foundation, Inc., 51 Franklin St, Fifth Floor,
|
||||
* Boston, MA 02110-1301, USA.
|
||||
*/
|
||||
|
||||
#ifdef HAVE_CONFIG_H
|
||||
#include <config.h>
|
||||
#endif
|
||||
|
||||
#include "gstv4l2codecallocator.h"
|
||||
#include "gstv4l2codecvp8dec.h"
|
||||
#include "gstv4l2codecpool.h"
|
||||
#include "linux/vp8-ctrls.h"
|
||||
|
||||
GST_DEBUG_CATEGORY_STATIC (v4l2_vp8dec_debug);
|
||||
#define GST_CAT_DEFAULT v4l2_vp8dec_debug
|
||||
|
||||
enum
|
||||
{
|
||||
PROP_0,
|
||||
PROP_LAST = PROP_0
|
||||
};
|
||||
|
||||
static GstStaticPadTemplate sink_template =
|
||||
GST_STATIC_PAD_TEMPLATE (GST_VIDEO_DECODER_SINK_NAME,
|
||||
GST_PAD_SINK, GST_PAD_ALWAYS,
|
||||
GST_STATIC_CAPS ("video/x-vp8")
|
||||
);
|
||||
|
||||
static GstStaticPadTemplate src_template =
|
||||
GST_STATIC_PAD_TEMPLATE (GST_VIDEO_DECODER_SRC_NAME,
|
||||
GST_PAD_SRC, GST_PAD_ALWAYS,
|
||||
GST_STATIC_CAPS (GST_VIDEO_CAPS_MAKE ("{ NV12, YUY2 }")));
|
||||
|
||||
struct _GstV4l2CodecVp8Dec
|
||||
{
|
||||
GstVp8Decoder parent;
|
||||
GstV4l2Decoder *decoder;
|
||||
GstVideoCodecState *output_state;
|
||||
GstVideoInfo vinfo;
|
||||
gint width;
|
||||
gint height;
|
||||
|
||||
GstV4l2CodecAllocator *sink_allocator;
|
||||
GstV4l2CodecAllocator *src_allocator;
|
||||
GstV4l2CodecPool *src_pool;
|
||||
gint min_pool_size;
|
||||
gboolean has_videometa;
|
||||
gboolean need_negotiation;
|
||||
gboolean copy_frames;
|
||||
|
||||
struct v4l2_ctrl_vp8_frame_header frame_header;
|
||||
|
||||
GstMemory *bitstream;
|
||||
GstMapInfo bitstream_map;
|
||||
};
|
||||
|
||||
G_DEFINE_ABSTRACT_TYPE_WITH_CODE (GstV4l2CodecVp8Dec,
|
||||
gst_v4l2_codec_vp8_dec, GST_TYPE_VP8_DECODER,
|
||||
GST_DEBUG_CATEGORY_INIT (v4l2_vp8dec_debug, "v4l2codecs-h264dec", 0,
|
||||
"V4L2 stateless VP8 decoder"));
|
||||
#define parent_class gst_v4l2_codec_vp8_dec_parent_class
|
||||
|
||||
static gboolean
|
||||
gst_v4l2_codec_vp8_dec_open (GstVideoDecoder * decoder)
|
||||
{
|
||||
GstV4l2CodecVp8Dec *self = GST_V4L2_CODEC_VP8_DEC (decoder);
|
||||
|
||||
if (!gst_v4l2_decoder_open (self->decoder)) {
|
||||
GST_ELEMENT_ERROR (self, RESOURCE, OPEN_READ_WRITE,
|
||||
("Failed to open VP8 decoder"),
|
||||
("gst_v4l2_decoder_open() failed: %s", g_strerror (errno)));
|
||||
return FALSE;
|
||||
}
|
||||
|
||||
return TRUE;
|
||||
}
|
||||
|
||||
static gboolean
|
||||
gst_v4l2_codec_vp8_dec_close (GstVideoDecoder * decoder)
|
||||
{
|
||||
GstV4l2CodecVp8Dec *self = GST_V4L2_CODEC_VP8_DEC (decoder);
|
||||
gst_v4l2_decoder_close (self->decoder);
|
||||
return TRUE;
|
||||
}
|
||||
|
||||
static void
|
||||
gst_v4l2_codec_vp8_dec_reset_allocation (GstV4l2CodecVp8Dec * self)
|
||||
{
|
||||
if (self->sink_allocator) {
|
||||
gst_v4l2_codec_allocator_detach (self->sink_allocator);
|
||||
g_clear_object (&self->sink_allocator);
|
||||
}
|
||||
|
||||
if (self->src_allocator) {
|
||||
gst_v4l2_codec_allocator_detach (self->src_allocator);
|
||||
g_clear_object (&self->src_allocator);
|
||||
g_clear_object (&self->src_pool);
|
||||
}
|
||||
}
|
||||
|
||||
static gboolean
|
||||
gst_v4l2_codec_vp8_dec_stop (GstVideoDecoder * decoder)
|
||||
{
|
||||
GstV4l2CodecVp8Dec *self = GST_V4L2_CODEC_VP8_DEC (decoder);
|
||||
|
||||
gst_v4l2_decoder_streamoff (self->decoder, GST_PAD_SINK);
|
||||
gst_v4l2_decoder_streamoff (self->decoder, GST_PAD_SRC);
|
||||
|
||||
gst_v4l2_codec_vp8_dec_reset_allocation (self);
|
||||
|
||||
if (self->output_state)
|
||||
gst_video_codec_state_unref (self->output_state);
|
||||
self->output_state = NULL;
|
||||
|
||||
return GST_VIDEO_DECODER_CLASS (parent_class)->stop (decoder);
|
||||
}
|
||||
|
||||
static gboolean
|
||||
gst_v4l2_codec_vp8_dec_negotiate (GstVideoDecoder * decoder)
|
||||
{
|
||||
GstV4l2CodecVp8Dec *self = GST_V4L2_CODEC_VP8_DEC (decoder);
|
||||
GstVp8Decoder *vp8dec = GST_VP8_DECODER (decoder);
|
||||
/* *INDENT-OFF* */
|
||||
struct v4l2_ext_control control[] = {
|
||||
{
|
||||
.id = V4L2_CID_MPEG_VIDEO_VP8_FRAME_HEADER,
|
||||
.ptr = &self->frame_header,
|
||||
.size = sizeof (self->frame_header),
|
||||
},
|
||||
};
|
||||
/* *INDENT-ON* */
|
||||
GstCaps *filter, *caps;
|
||||
|
||||
/* Ignore downstream renegotiation request. */
|
||||
if (!self->need_negotiation)
|
||||
return TRUE;
|
||||
self->need_negotiation = FALSE;
|
||||
|
||||
GST_DEBUG_OBJECT (self, "Negotiate");
|
||||
|
||||
gst_v4l2_codec_vp8_dec_reset_allocation (self);
|
||||
|
||||
gst_v4l2_decoder_streamoff (self->decoder, GST_PAD_SINK);
|
||||
gst_v4l2_decoder_streamoff (self->decoder, GST_PAD_SRC);
|
||||
|
||||
if (!gst_v4l2_decoder_set_sink_fmt (self->decoder, V4L2_PIX_FMT_VP8_FRAME,
|
||||
self->width, self->height)) {
|
||||
GST_ELEMENT_ERROR (self, CORE, NEGOTIATION,
|
||||
("Failed to configure VP8 decoder"),
|
||||
("gst_v4l2_decoder_set_sink_fmt() failed: %s", g_strerror (errno)));
|
||||
gst_v4l2_decoder_close (self->decoder);
|
||||
return FALSE;
|
||||
}
|
||||
|
||||
if (!gst_v4l2_decoder_set_controls (self->decoder, NULL, control,
|
||||
G_N_ELEMENTS (control))) {
|
||||
GST_ELEMENT_ERROR (decoder, RESOURCE, WRITE,
|
||||
("Driver does not support the selected stream."), (NULL));
|
||||
return FALSE;
|
||||
}
|
||||
|
||||
filter = gst_v4l2_decoder_enum_src_formats (self->decoder);
|
||||
GST_DEBUG_OBJECT (self, "Supported output formats: %" GST_PTR_FORMAT, filter);
|
||||
|
||||
caps = gst_pad_peer_query_caps (decoder->srcpad, filter);
|
||||
gst_caps_unref (filter);
|
||||
GST_DEBUG_OBJECT (self, "Peer supported formats: %" GST_PTR_FORMAT, caps);
|
||||
|
||||
if (!gst_v4l2_decoder_select_src_format (self->decoder, caps, &self->vinfo)) {
|
||||
GST_ELEMENT_ERROR (self, CORE, NEGOTIATION,
|
||||
("Unsupported pixel format"),
|
||||
("No support for %ux%u format %s", self->width, self->height,
|
||||
gst_video_format_to_string (GST_VIDEO_INFO_FORMAT (&self->vinfo))));
|
||||
gst_caps_unref (caps);
|
||||
return FALSE;
|
||||
}
|
||||
gst_caps_unref (caps);
|
||||
|
||||
if (self->output_state)
|
||||
gst_video_codec_state_unref (self->output_state);
|
||||
|
||||
self->output_state =
|
||||
gst_video_decoder_set_output_state (GST_VIDEO_DECODER (self),
|
||||
self->vinfo.finfo->format, self->width,
|
||||
self->height, vp8dec->input_state);
|
||||
|
||||
self->output_state->caps = gst_video_info_to_caps (&self->output_state->info);
|
||||
|
||||
if (GST_VIDEO_DECODER_CLASS (parent_class)->negotiate (decoder)) {
|
||||
if (!gst_v4l2_decoder_streamon (self->decoder, GST_PAD_SINK)) {
|
||||
GST_ELEMENT_ERROR (self, RESOURCE, FAILED,
|
||||
("Could not enable the decoder driver."),
|
||||
("VIDIOC_STREAMON(SINK) failed: %s", g_strerror (errno)));
|
||||
return FALSE;
|
||||
}
|
||||
|
||||
if (!gst_v4l2_decoder_streamon (self->decoder, GST_PAD_SRC)) {
|
||||
GST_ELEMENT_ERROR (self, RESOURCE, FAILED,
|
||||
("Could not enable the decoder driver."),
|
||||
("VIDIOC_STREAMON(SRC) failed: %s", g_strerror (errno)));
|
||||
return FALSE;
|
||||
}
|
||||
|
||||
return TRUE;
|
||||
}
|
||||
|
||||
return FALSE;
|
||||
}
|
||||
|
||||
static gboolean
|
||||
gst_v4l2_codec_vp8_dec_decide_allocation (GstVideoDecoder * decoder,
|
||||
GstQuery * query)
|
||||
{
|
||||
GstV4l2CodecVp8Dec *self = GST_V4L2_CODEC_VP8_DEC (decoder);
|
||||
guint min = 0;
|
||||
|
||||
self->has_videometa = gst_query_find_allocation_meta (query,
|
||||
GST_VIDEO_META_API_TYPE, NULL);
|
||||
|
||||
g_clear_object (&self->src_pool);
|
||||
g_clear_object (&self->src_allocator);
|
||||
|
||||
if (gst_query_get_n_allocation_pools (query) > 0)
|
||||
gst_query_parse_nth_allocation_pool (query, 0, NULL, NULL, &min, NULL);
|
||||
|
||||
min = MAX (2, min);
|
||||
|
||||
self->sink_allocator = gst_v4l2_codec_allocator_new (self->decoder,
|
||||
GST_PAD_SINK, self->min_pool_size + 2);
|
||||
self->src_allocator = gst_v4l2_codec_allocator_new (self->decoder,
|
||||
GST_PAD_SRC, self->min_pool_size + min + 4);
|
||||
self->src_pool = gst_v4l2_codec_pool_new (self->src_allocator, &self->vinfo);
|
||||
|
||||
/* Our buffer pool is internal, we will let the base class create a video
|
||||
* pool, and use it if we are running out of buffers or if downstream does
|
||||
* not support GstVideoMeta */
|
||||
return GST_VIDEO_DECODER_CLASS (parent_class)->decide_allocation
|
||||
(decoder, query);
|
||||
}
|
||||
|
||||
static void
|
||||
gst_v4l2_codec_vp8_dec_fill_segment_header (struct v4l2_vp8_segment_header
|
||||
*segment_header, const GstVp8Segmentation * segmentation)
|
||||
{
|
||||
gint i;
|
||||
|
||||
/* *INDENT-OFF* */
|
||||
segment_header->flags =
|
||||
(segmentation->segmentation_enabled ? V4L2_VP8_SEGMENT_HEADER_FLAG_ENABLED : 0) |
|
||||
(segmentation->update_mb_segmentation_map ? V4L2_VP8_SEGMENT_HEADER_FLAG_UPDATE_MAP : 0) |
|
||||
(segmentation->update_segment_feature_data ? V4L2_VP8_SEGMENT_HEADER_FLAG_UPDATE_FEATURE_DATA : 0) |
|
||||
(segmentation->segment_feature_mode == 1 ? V4L2_VP8_SEGMENT_HEADER_FLAG_DELTA_VALUE_MODE : 0);
|
||||
/* *INDENT-ON* */
|
||||
|
||||
for (i = 0; i < 4; i++) {
|
||||
segment_header->quant_update[i] = segmentation->quantizer_update_value[i];
|
||||
segment_header->lf_update[i] = segmentation->lf_update_value[i];
|
||||
}
|
||||
|
||||
for (i = 0; i < 3; i++)
|
||||
segment_header->segment_probs[i] = segmentation->segment_prob[i];
|
||||
|
||||
segment_header->padding = 0;
|
||||
}
|
||||
|
||||
static void
|
||||
gst_v4l2_codec_vp8_dec_fill_lf_header (struct v4l2_vp8_loopfilter_header
|
||||
*lf_header, const GstVp8MbLfAdjustments * lf_adj)
|
||||
{
|
||||
gint i;
|
||||
|
||||
lf_header->flags |=
|
||||
(lf_adj->loop_filter_adj_enable ? V4L2_VP8_LF_HEADER_ADJ_ENABLE : 0) |
|
||||
(lf_adj->mode_ref_lf_delta_update ? V4L2_VP8_LF_HEADER_DELTA_UPDATE : 0);
|
||||
|
||||
for (i = 0; i < 4; i++) {
|
||||
lf_header->ref_frm_delta[i] = lf_adj->ref_frame_delta[i];
|
||||
lf_header->mb_mode_delta[i] = lf_adj->mb_mode_delta[i];
|
||||
}
|
||||
}
|
||||
|
||||
static void
|
||||
gst_v4l2_codec_vp8_dec_fill_entropy_header (struct v4l2_vp8_entropy_header
|
||||
*entropy_header, const GstVp8FrameHdr * frame_hdr)
|
||||
{
|
||||
memcpy (entropy_header->coeff_probs, frame_hdr->token_probs.prob,
|
||||
sizeof (frame_hdr->token_probs.prob));
|
||||
memcpy (entropy_header->y_mode_probs, frame_hdr->mode_probs.y_prob,
|
||||
sizeof (frame_hdr->mode_probs.y_prob));
|
||||
memcpy (entropy_header->uv_mode_probs, frame_hdr->mode_probs.uv_prob,
|
||||
sizeof (frame_hdr->mode_probs.uv_prob));
|
||||
memcpy (entropy_header->mv_probs, frame_hdr->mv_probs.prob,
|
||||
sizeof (frame_hdr->mv_probs.prob));
|
||||
}
|
||||
|
||||
static void
|
||||
gst_v4l2_codec_vp8_dec_fill_frame_header (GstV4l2CodecVp8Dec * self,
|
||||
const GstVp8FrameHdr * frame_hdr)
|
||||
{
|
||||
gint i;
|
||||
|
||||
/* *INDENT-OFF* */
|
||||
self->frame_header = (struct v4l2_ctrl_vp8_frame_header) {
|
||||
.lf_header = (struct v4l2_vp8_loopfilter_header) {
|
||||
.sharpness_level = frame_hdr->sharpness_level,
|
||||
.level = frame_hdr->loop_filter_level,
|
||||
.flags = (frame_hdr->filter_type == 1 ? V4L2_VP8_LF_FILTER_TYPE_SIMPLE : 0)
|
||||
},
|
||||
.quant_header = (struct v4l2_vp8_quantization_header) {
|
||||
.y_ac_qi = frame_hdr->quant_indices.y_ac_qi,
|
||||
.y_dc_delta = frame_hdr->quant_indices.y_dc_delta,
|
||||
.y2_dc_delta = frame_hdr->quant_indices.y2_dc_delta,
|
||||
.y2_ac_delta = frame_hdr->quant_indices.y2_ac_delta,
|
||||
.uv_dc_delta = frame_hdr->quant_indices.uv_dc_delta,
|
||||
.uv_ac_delta = frame_hdr->quant_indices.uv_ac_delta
|
||||
},
|
||||
.coder_state = (struct v4l2_vp8_entropy_coder_state) {
|
||||
.range = frame_hdr->rd_range,
|
||||
.value = frame_hdr->rd_value,
|
||||
.bit_count = frame_hdr->rd_count
|
||||
},
|
||||
|
||||
.width = frame_hdr->width,
|
||||
.height = frame_hdr->height,
|
||||
|
||||
.horizontal_scale = frame_hdr->horiz_scale_code,
|
||||
.vertical_scale = frame_hdr->vert_scale_code,
|
||||
|
||||
.prob_skip_false = frame_hdr->prob_skip_false,
|
||||
.prob_intra = frame_hdr->prob_intra,
|
||||
.prob_last = frame_hdr->prob_last,
|
||||
.prob_gf = frame_hdr->prob_gf,
|
||||
.num_dct_parts = 1 << frame_hdr->log2_nbr_of_dct_partitions,
|
||||
|
||||
.first_part_size = frame_hdr->first_part_size,
|
||||
.first_part_header_bits = frame_hdr->header_size,
|
||||
|
||||
.flags = (frame_hdr->key_frame ? V4L2_VP8_FRAME_HEADER_FLAG_KEY_FRAME : 0) |
|
||||
(frame_hdr->show_frame ? V4L2_VP8_FRAME_HEADER_FLAG_SHOW_FRAME : 0) |
|
||||
(frame_hdr->mb_no_skip_coeff ? V4L2_VP8_FRAME_HEADER_FLAG_MB_NO_SKIP_COEFF : 0) |
|
||||
(frame_hdr->sign_bias_golden ? V4L2_VP8_FRAME_HEADER_FLAG_SIGN_BIAS_GOLDEN : 0) |
|
||||
(frame_hdr->sign_bias_alternate ? V4L2_VP8_FRAME_HEADER_FLAG_SIGN_BIAS_ALT : 0),
|
||||
};
|
||||
/* *INDENT-ON* */
|
||||
|
||||
for (i = 0; i < 8; i++)
|
||||
self->frame_header.dct_part_sizes[i] = frame_hdr->partition_size[i];
|
||||
|
||||
gst_v4l2_codec_vp8_dec_fill_entropy_header (&self->
|
||||
frame_header.entropy_header, frame_hdr);
|
||||
}
|
||||
|
||||
static void
|
||||
gst_v4l2_codec_vp8_dec_fill_references (GstV4l2CodecVp8Dec * self)
|
||||
{
|
||||
GstVp8Decoder *decoder = &self->parent;
|
||||
|
||||
if (decoder->last_picture)
|
||||
self->frame_header.last_frame_ts =
|
||||
decoder->last_picture->system_frame_number * 1000;
|
||||
|
||||
if (decoder->golden_ref_picture)
|
||||
self->frame_header.golden_frame_ts =
|
||||
decoder->golden_ref_picture->system_frame_number * 1000;
|
||||
|
||||
if (decoder->alt_ref_picture)
|
||||
self->frame_header.alt_frame_ts =
|
||||
decoder->alt_ref_picture->system_frame_number * 1000;
|
||||
}
|
||||
|
||||
static gboolean
|
||||
gst_v4l2_codec_vp8_dec_new_sequence (GstVp8Decoder * decoder,
|
||||
const GstVp8FrameHdr * frame_hdr)
|
||||
{
|
||||
GstV4l2CodecVp8Dec *self = GST_V4L2_CODEC_VP8_DEC (decoder);
|
||||
gboolean negotiation_needed = FALSE;
|
||||
|
||||
if (self->vinfo.finfo->format == GST_VIDEO_FORMAT_UNKNOWN)
|
||||
negotiation_needed = TRUE;
|
||||
|
||||
/* TODO Check if current buffers are large enough, and reuse them */
|
||||
if (self->width != frame_hdr->width || self->height != frame_hdr->height) {
|
||||
self->width = frame_hdr->width;
|
||||
self->height = frame_hdr->height;
|
||||
negotiation_needed = TRUE;
|
||||
GST_INFO_OBJECT (self, "Resolution changed to %dx%d",
|
||||
self->width, self->height);
|
||||
}
|
||||
|
||||
gst_v4l2_codec_vp8_dec_fill_frame_header (self, frame_hdr);
|
||||
|
||||
if (negotiation_needed) {
|
||||
self->need_negotiation = TRUE;
|
||||
if (!gst_video_decoder_negotiate (GST_VIDEO_DECODER (self))) {
|
||||
GST_ERROR_OBJECT (self, "Failed to negotiate with downstream");
|
||||
return FALSE;
|
||||
}
|
||||
}
|
||||
|
||||
/* Check if we can zero-copy buffers */
|
||||
if (!self->has_videometa) {
|
||||
GstVideoInfo ref_vinfo;
|
||||
gint i;
|
||||
|
||||
gst_video_info_set_format (&ref_vinfo, GST_VIDEO_INFO_FORMAT (&self->vinfo),
|
||||
self->width, self->height);
|
||||
|
||||
for (i = 0; i < GST_VIDEO_INFO_N_PLANES (&self->vinfo); i++) {
|
||||
if (self->vinfo.stride[i] != ref_vinfo.stride[i] ||
|
||||
self->vinfo.offset[i] != ref_vinfo.offset[i]) {
|
||||
GST_WARNING_OBJECT (self,
|
||||
"GstVideoMeta support required, copying frames.");
|
||||
self->copy_frames = TRUE;
|
||||
break;
|
||||
}
|
||||
}
|
||||
} else {
|
||||
self->copy_frames = FALSE;
|
||||
}
|
||||
|
||||
return TRUE;
|
||||
}
|
||||
|
||||
static gboolean
|
||||
gst_v4l2_codec_vp8_dec_start_picture (GstVp8Decoder * decoder,
|
||||
GstVp8Picture * picture)
|
||||
{
|
||||
GstV4l2CodecVp8Dec *self = GST_V4L2_CODEC_VP8_DEC (decoder);
|
||||
|
||||
/* FIXME base class should not call us if negotiation failed */
|
||||
if (!self->sink_allocator)
|
||||
return FALSE;
|
||||
|
||||
/* Ensure we have a bitstream to write into */
|
||||
if (!self->bitstream) {
|
||||
self->bitstream = gst_v4l2_codec_allocator_alloc (self->sink_allocator);
|
||||
|
||||
if (!self->bitstream) {
|
||||
GST_ELEMENT_ERROR (decoder, RESOURCE, NO_SPACE_LEFT,
|
||||
("Not enough memory to decode VP8 stream."), (NULL));
|
||||
return FALSE;
|
||||
}
|
||||
|
||||
if (!gst_memory_map (self->bitstream, &self->bitstream_map, GST_MAP_WRITE)) {
|
||||
GST_ELEMENT_ERROR (decoder, RESOURCE, WRITE,
|
||||
("Could not access bitstream memory for writing"), (NULL));
|
||||
g_clear_pointer (&self->bitstream, gst_memory_unref);
|
||||
return FALSE;
|
||||
}
|
||||
}
|
||||
|
||||
/* We use this field to track how much we have written */
|
||||
self->bitstream_map.size = 0;
|
||||
|
||||
return TRUE;
|
||||
}
|
||||
|
||||
static gboolean
|
||||
gst_v4l2_codec_vp8_dec_decode_picture (GstVp8Decoder * decoder,
|
||||
GstVp8Picture * picture, GstVp8Parser * parser)
|
||||
{
|
||||
GstV4l2CodecVp8Dec *self = GST_V4L2_CODEC_VP8_DEC (decoder);
|
||||
guint8 *bitstream_data = self->bitstream_map.data;
|
||||
|
||||
if (self->bitstream_map.maxsize < picture->size) {
|
||||
GST_ELEMENT_ERROR (decoder, RESOURCE, NO_SPACE_LEFT,
|
||||
("Not enough space to send picture bitstream."), (NULL));
|
||||
return FALSE;
|
||||
}
|
||||
|
||||
gst_v4l2_codec_vp8_dec_fill_frame_header (self, &picture->frame_hdr);
|
||||
gst_v4l2_codec_vp8_dec_fill_segment_header (&self->
|
||||
frame_header.segment_header, &parser->segmentation);
|
||||
gst_v4l2_codec_vp8_dec_fill_lf_header (&self->frame_header.lf_header,
|
||||
&parser->mb_lf_adjust);
|
||||
gst_v4l2_codec_vp8_dec_fill_references (self);
|
||||
|
||||
memcpy (bitstream_data, picture->data, picture->size);
|
||||
self->bitstream_map.size = picture->size;
|
||||
|
||||
return TRUE;
|
||||
}
|
||||
|
||||
static void
|
||||
gst_v4l2_codec_vp8_dec_reset_picture (GstV4l2CodecVp8Dec * self)
|
||||
{
|
||||
if (self->bitstream) {
|
||||
if (self->bitstream_map.memory)
|
||||
gst_memory_unmap (self->bitstream, &self->bitstream_map);
|
||||
g_clear_pointer (&self->bitstream, gst_memory_unref);
|
||||
self->bitstream_map = (GstMapInfo) GST_MAP_INFO_INIT;
|
||||
}
|
||||
}
|
||||
|
||||
static gboolean
|
||||
gst_v4l2_codec_vp8_dec_end_picture (GstVp8Decoder * decoder,
|
||||
GstVp8Picture * picture)
|
||||
{
|
||||
GstV4l2CodecVp8Dec *self = GST_V4L2_CODEC_VP8_DEC (decoder);
|
||||
GstVideoCodecFrame *frame;
|
||||
GstV4l2Request *request;
|
||||
GstBuffer *buffer;
|
||||
GstFlowReturn flow_ret;
|
||||
gsize bytesused;
|
||||
|
||||
/* *INDENT-OFF* */
|
||||
struct v4l2_ext_control control[] = {
|
||||
{
|
||||
.id = V4L2_CID_MPEG_VIDEO_VP8_FRAME_HEADER,
|
||||
.ptr = &self->frame_header,
|
||||
.size = sizeof(self->frame_header),
|
||||
},
|
||||
};
|
||||
/* *INDENT-ON* */
|
||||
|
||||
request = gst_v4l2_decoder_alloc_request (self->decoder);
|
||||
if (!request) {
|
||||
GST_ELEMENT_ERROR (decoder, RESOURCE, NO_SPACE_LEFT,
|
||||
("Failed to allocate a media request object."), (NULL));
|
||||
goto fail;
|
||||
}
|
||||
|
||||
gst_vp8_picture_set_user_data (picture, request,
|
||||
(GDestroyNotify) gst_v4l2_request_free);
|
||||
|
||||
flow_ret = gst_buffer_pool_acquire_buffer (GST_BUFFER_POOL (self->src_pool),
|
||||
&buffer, NULL);
|
||||
if (flow_ret != GST_FLOW_OK) {
|
||||
if (flow_ret == GST_FLOW_FLUSHING)
|
||||
GST_DEBUG_OBJECT (self, "Frame decoding aborted, we are flushing.");
|
||||
else
|
||||
GST_ELEMENT_ERROR (decoder, RESOURCE, WRITE,
|
||||
("No more picture buffer available."), (NULL));
|
||||
goto fail;
|
||||
}
|
||||
|
||||
frame = gst_video_decoder_get_frame (GST_VIDEO_DECODER (self),
|
||||
picture->system_frame_number);
|
||||
g_return_val_if_fail (frame, FALSE);
|
||||
g_warn_if_fail (frame->output_buffer == NULL);
|
||||
frame->output_buffer = buffer;
|
||||
gst_video_codec_frame_unref (frame);
|
||||
|
||||
if (!gst_v4l2_decoder_set_controls (self->decoder, request, control,
|
||||
G_N_ELEMENTS (control))) {
|
||||
GST_ELEMENT_ERROR (decoder, RESOURCE, WRITE,
|
||||
("Driver did not accept the bitstream parameters."), (NULL));
|
||||
goto fail;
|
||||
}
|
||||
|
||||
bytesused = self->bitstream_map.size;
|
||||
gst_memory_unmap (self->bitstream, &self->bitstream_map);
|
||||
self->bitstream_map = (GstMapInfo) GST_MAP_INFO_INIT;
|
||||
|
||||
if (!gst_v4l2_decoder_queue_sink_mem (self->decoder, request, self->bitstream,
|
||||
picture->system_frame_number, bytesused)) {
|
||||
GST_ELEMENT_ERROR (decoder, RESOURCE, WRITE,
|
||||
("Driver did not accept the bitstream data."), (NULL));
|
||||
goto fail;
|
||||
}
|
||||
|
||||
|
||||
if (!gst_v4l2_decoder_queue_src_buffer (self->decoder, buffer,
|
||||
picture->system_frame_number)) {
|
||||
GST_ELEMENT_ERROR (decoder, RESOURCE, WRITE,
|
||||
("Driver did not accept the picture buffer."), (NULL));
|
||||
goto fail;
|
||||
}
|
||||
|
||||
if (!gst_v4l2_request_queue (request)) {
|
||||
GST_ELEMENT_ERROR (decoder, RESOURCE, WRITE,
|
||||
("Driver did not accept the decode request."), (NULL));
|
||||
goto fail;
|
||||
}
|
||||
|
||||
gst_v4l2_codec_vp8_dec_reset_picture (self);
|
||||
return TRUE;
|
||||
|
||||
fail:
|
||||
gst_v4l2_codec_vp8_dec_reset_picture (self);
|
||||
return FALSE;
|
||||
}
|
||||
|
||||
static gboolean
|
||||
gst_v4l2_codec_vp8_dec_copy_output_buffer (GstV4l2CodecVp8Dec * self,
|
||||
GstVideoCodecFrame * codec_frame)
|
||||
{
|
||||
GstVideoFrame src_frame;
|
||||
GstVideoFrame dest_frame;
|
||||
GstVideoInfo dest_vinfo;
|
||||
GstBuffer *buffer;
|
||||
|
||||
gst_video_info_set_format (&dest_vinfo, GST_VIDEO_INFO_FORMAT (&self->vinfo),
|
||||
self->width, self->height);
|
||||
|
||||
buffer = gst_video_decoder_allocate_output_buffer (GST_VIDEO_DECODER (self));
|
||||
if (!buffer)
|
||||
goto fail;
|
||||
|
||||
if (!gst_video_frame_map (&src_frame, &self->vinfo,
|
||||
codec_frame->output_buffer, GST_MAP_READ))
|
||||
goto fail;
|
||||
|
||||
if (!gst_video_frame_map (&dest_frame, &dest_vinfo, buffer, GST_MAP_WRITE)) {
|
||||
gst_video_frame_unmap (&dest_frame);
|
||||
goto fail;
|
||||
}
|
||||
|
||||
/* gst_video_frame_copy can crop this, but does not know, so let make it
|
||||
* think it's all right */
|
||||
GST_VIDEO_INFO_WIDTH (&src_frame.info) = self->width;
|
||||
GST_VIDEO_INFO_HEIGHT (&src_frame.info) = self->height;
|
||||
|
||||
if (!gst_video_frame_copy (&dest_frame, &src_frame)) {
|
||||
gst_video_frame_unmap (&src_frame);
|
||||
gst_video_frame_unmap (&dest_frame);
|
||||
goto fail;
|
||||
}
|
||||
|
||||
gst_video_frame_unmap (&src_frame);
|
||||
gst_video_frame_unmap (&dest_frame);
|
||||
gst_buffer_replace (&codec_frame->output_buffer, buffer);
|
||||
gst_buffer_unref (buffer);
|
||||
|
||||
return TRUE;
|
||||
|
||||
fail:
|
||||
GST_ERROR_OBJECT (self, "Failed copy output buffer.");
|
||||
return FALSE;
|
||||
}
|
||||
|
||||
static GstFlowReturn
|
||||
gst_v4l2_codec_vp8_dec_output_picture (GstVp8Decoder * decoder,
|
||||
GstVp8Picture * picture)
|
||||
{
|
||||
GstV4l2CodecVp8Dec *self = GST_V4L2_CODEC_VP8_DEC (decoder);
|
||||
GstV4l2Request *request = gst_vp8_picture_get_user_data (picture);
|
||||
gint ret;
|
||||
guint32 frame_num;
|
||||
GstVideoCodecFrame *frame, *other_frame;
|
||||
GstVp8Picture *other_pic;
|
||||
GstV4l2Request *other_request;
|
||||
|
||||
GST_DEBUG_OBJECT (self, "Output picture %u", picture->system_frame_number);
|
||||
|
||||
if (gst_v4l2_request_is_done (request))
|
||||
goto finish_frame;
|
||||
|
||||
ret = gst_v4l2_request_poll (request, GST_SECOND);
|
||||
if (ret == 0) {
|
||||
GST_ELEMENT_ERROR (self, STREAM, DECODE,
|
||||
("Decoding frame took too long"), (NULL));
|
||||
return GST_FLOW_ERROR;
|
||||
} else if (ret < 0) {
|
||||
GST_ELEMENT_ERROR (self, STREAM, DECODE,
|
||||
("Decoding request failed: %s", g_strerror (errno)), (NULL));
|
||||
return GST_FLOW_ERROR;
|
||||
}
|
||||
|
||||
while (TRUE) {
|
||||
if (!gst_v4l2_decoder_dequeue_src (self->decoder, &frame_num)) {
|
||||
GST_ELEMENT_ERROR (self, STREAM, DECODE,
|
||||
("Decoder did not produce a frame"), (NULL));
|
||||
return GST_FLOW_ERROR;
|
||||
}
|
||||
|
||||
if (frame_num == picture->system_frame_number)
|
||||
break;
|
||||
|
||||
other_frame = gst_video_decoder_get_frame (GST_VIDEO_DECODER (self),
|
||||
frame_num);
|
||||
g_return_val_if_fail (other_frame, GST_FLOW_ERROR);
|
||||
|
||||
other_pic = gst_video_codec_frame_get_user_data (other_frame);
|
||||
other_request = gst_vp8_picture_get_user_data (other_pic);
|
||||
gst_v4l2_request_set_done (other_request);
|
||||
gst_video_codec_frame_unref (other_frame);
|
||||
}
|
||||
|
||||
finish_frame:
|
||||
gst_v4l2_request_set_done (request);
|
||||
frame = gst_video_decoder_get_frame (GST_VIDEO_DECODER (self),
|
||||
picture->system_frame_number);
|
||||
g_return_val_if_fail (frame, GST_FLOW_ERROR);
|
||||
g_return_val_if_fail (frame->output_buffer, GST_FLOW_ERROR);
|
||||
|
||||
/* Hold on reference buffers for the rest of the picture lifetime */
|
||||
gst_vp8_picture_set_user_data (picture,
|
||||
gst_buffer_ref (frame->output_buffer), (GDestroyNotify) gst_buffer_unref);
|
||||
|
||||
if (self->copy_frames)
|
||||
gst_v4l2_codec_vp8_dec_copy_output_buffer (self, frame);
|
||||
|
||||
return gst_video_decoder_finish_frame (GST_VIDEO_DECODER (self), frame);
|
||||
}
|
||||
|
||||
static void
|
||||
gst_v4l2_codec_vp8_dec_set_flushing (GstV4l2CodecVp8Dec * self,
|
||||
gboolean flushing)
|
||||
{
|
||||
if (self->sink_allocator)
|
||||
gst_v4l2_codec_allocator_set_flushing (self->sink_allocator, flushing);
|
||||
if (self->src_allocator)
|
||||
gst_v4l2_codec_allocator_set_flushing (self->src_allocator, flushing);
|
||||
}
|
||||
|
||||
static gboolean
|
||||
gst_v4l2_codec_vp8_dec_flush (GstVideoDecoder * decoder)
|
||||
{
|
||||
GstV4l2CodecVp8Dec *self = GST_V4L2_CODEC_VP8_DEC (decoder);
|
||||
|
||||
GST_DEBUG_OBJECT (self, "Flushing decoder state.");
|
||||
|
||||
gst_v4l2_decoder_flush (self->decoder);
|
||||
gst_v4l2_codec_vp8_dec_set_flushing (self, FALSE);
|
||||
|
||||
return GST_VIDEO_DECODER_CLASS (parent_class)->flush (decoder);
|
||||
}
|
||||
|
||||
static gboolean
|
||||
gst_v4l2_codec_vp8_dec_sink_event (GstVideoDecoder * decoder, GstEvent * event)
|
||||
{
|
||||
GstV4l2CodecVp8Dec *self = GST_V4L2_CODEC_VP8_DEC (decoder);
|
||||
|
||||
switch (GST_EVENT_TYPE (event)) {
|
||||
case GST_EVENT_FLUSH_START:
|
||||
GST_DEBUG_OBJECT (self, "flush start");
|
||||
gst_v4l2_codec_vp8_dec_set_flushing (self, TRUE);
|
||||
break;
|
||||
default:
|
||||
break;
|
||||
}
|
||||
|
||||
return GST_VIDEO_DECODER_CLASS (parent_class)->sink_event (decoder, event);
|
||||
}
|
||||
|
||||
static GstStateChangeReturn
|
||||
gst_v4l2_codec_vp8_dec_change_state (GstElement * element,
|
||||
GstStateChange transition)
|
||||
{
|
||||
GstV4l2CodecVp8Dec *self = GST_V4L2_CODEC_VP8_DEC (element);
|
||||
|
||||
if (transition == GST_STATE_CHANGE_PAUSED_TO_READY)
|
||||
gst_v4l2_codec_vp8_dec_set_flushing (self, TRUE);
|
||||
|
||||
return GST_ELEMENT_CLASS (parent_class)->change_state (element, transition);
|
||||
}
|
||||
|
||||
static void
|
||||
gst_v4l2_codec_vp8_dec_set_property (GObject * object, guint prop_id,
|
||||
const GValue * value, GParamSpec * pspec)
|
||||
{
|
||||
GstV4l2CodecVp8Dec *self = GST_V4L2_CODEC_VP8_DEC (object);
|
||||
GObject *dec = G_OBJECT (self->decoder);
|
||||
|
||||
switch (prop_id) {
|
||||
default:
|
||||
gst_v4l2_decoder_set_property (dec, prop_id - PROP_LAST, value, pspec);
|
||||
break;
|
||||
}
|
||||
}
|
||||
|
||||
static void
|
||||
gst_v4l2_codec_vp8_dec_get_property (GObject * object, guint prop_id,
|
||||
GValue * value, GParamSpec * pspec)
|
||||
{
|
||||
GstV4l2CodecVp8Dec *self = GST_V4L2_CODEC_VP8_DEC (object);
|
||||
GObject *dec = G_OBJECT (self->decoder);
|
||||
|
||||
switch (prop_id) {
|
||||
default:
|
||||
gst_v4l2_decoder_get_property (dec, prop_id - PROP_LAST, value, pspec);
|
||||
break;
|
||||
}
|
||||
}
|
||||
|
||||
static void
|
||||
gst_v4l2_codec_vp8_dec_init (GstV4l2CodecVp8Dec * self)
|
||||
{
|
||||
}
|
||||
|
||||
static void
|
||||
gst_v4l2_codec_vp8_dec_subinit (GstV4l2CodecVp8Dec * self,
|
||||
GstV4l2CodecVp8DecClass * klass)
|
||||
{
|
||||
self->decoder = gst_v4l2_decoder_new (klass->device);
|
||||
gst_video_info_init (&self->vinfo);
|
||||
}
|
||||
|
||||
static void
|
||||
gst_v4l2_codec_vp8_dec_dispose (GObject * object)
|
||||
{
|
||||
GstV4l2CodecVp8Dec *self = GST_V4L2_CODEC_VP8_DEC (object);
|
||||
|
||||
g_clear_object (&self->decoder);
|
||||
|
||||
G_OBJECT_CLASS (parent_class)->dispose (object);
|
||||
}
|
||||
|
||||
static void
|
||||
gst_v4l2_codec_vp8_dec_class_init (GstV4l2CodecVp8DecClass * klass)
|
||||
{
|
||||
}
|
||||
|
||||
static void
|
||||
gst_v4l2_codec_vp8_dec_subclass_init (GstV4l2CodecVp8DecClass * klass,
|
||||
GstV4l2CodecDevice * device)
|
||||
{
|
||||
GObjectClass *gobject_class = G_OBJECT_CLASS (klass);
|
||||
GstElementClass *element_class = GST_ELEMENT_CLASS (klass);
|
||||
GstVideoDecoderClass *decoder_class = GST_VIDEO_DECODER_CLASS (klass);
|
||||
GstVp8DecoderClass *vp8decoder_class = GST_VP8_DECODER_CLASS (klass);
|
||||
|
||||
gobject_class->set_property = gst_v4l2_codec_vp8_dec_set_property;
|
||||
gobject_class->get_property = gst_v4l2_codec_vp8_dec_get_property;
|
||||
gobject_class->dispose = gst_v4l2_codec_vp8_dec_dispose;
|
||||
|
||||
gst_element_class_set_static_metadata (element_class,
|
||||
"V4L2 Stateless VP8 Video Decoder",
|
||||
"Codec/Decoder/Video/Hardware",
|
||||
"A V4L2 based VP8 video decoder",
|
||||
"Nicolas Dufresne <nicolas.dufresne@collabora.com>");
|
||||
|
||||
gst_element_class_add_static_pad_template (element_class, &sink_template);
|
||||
gst_element_class_add_static_pad_template (element_class, &src_template);
|
||||
element_class->change_state =
|
||||
GST_DEBUG_FUNCPTR (gst_v4l2_codec_vp8_dec_change_state);
|
||||
|
||||
decoder_class->open = GST_DEBUG_FUNCPTR (gst_v4l2_codec_vp8_dec_open);
|
||||
decoder_class->close = GST_DEBUG_FUNCPTR (gst_v4l2_codec_vp8_dec_close);
|
||||
decoder_class->stop = GST_DEBUG_FUNCPTR (gst_v4l2_codec_vp8_dec_stop);
|
||||
decoder_class->negotiate =
|
||||
GST_DEBUG_FUNCPTR (gst_v4l2_codec_vp8_dec_negotiate);
|
||||
decoder_class->decide_allocation =
|
||||
GST_DEBUG_FUNCPTR (gst_v4l2_codec_vp8_dec_decide_allocation);
|
||||
decoder_class->flush = GST_DEBUG_FUNCPTR (gst_v4l2_codec_vp8_dec_flush);
|
||||
decoder_class->sink_event =
|
||||
GST_DEBUG_FUNCPTR (gst_v4l2_codec_vp8_dec_sink_event);
|
||||
|
||||
vp8decoder_class->new_sequence =
|
||||
GST_DEBUG_FUNCPTR (gst_v4l2_codec_vp8_dec_new_sequence);
|
||||
vp8decoder_class->start_picture =
|
||||
GST_DEBUG_FUNCPTR (gst_v4l2_codec_vp8_dec_start_picture);
|
||||
vp8decoder_class->decode_picture =
|
||||
GST_DEBUG_FUNCPTR (gst_v4l2_codec_vp8_dec_decode_picture);
|
||||
vp8decoder_class->end_picture =
|
||||
GST_DEBUG_FUNCPTR (gst_v4l2_codec_vp8_dec_end_picture);
|
||||
vp8decoder_class->output_picture =
|
||||
GST_DEBUG_FUNCPTR (gst_v4l2_codec_vp8_dec_output_picture);
|
||||
|
||||
klass->device = device;
|
||||
gst_v4l2_decoder_install_properties (gobject_class, PROP_LAST, device);
|
||||
}
|
||||
|
||||
void
|
||||
gst_v4l2_codec_vp8_dec_register (GstPlugin * plugin,
|
||||
GstV4l2CodecDevice * device, guint rank)
|
||||
{
|
||||
GTypeQuery type_query;
|
||||
GTypeInfo type_info = { 0, };
|
||||
GType subtype;
|
||||
gchar *type_name;
|
||||
|
||||
g_type_query (GST_TYPE_V4L2_CODEC_VP8_DEC, &type_query);
|
||||
memset (&type_info, 0, sizeof (type_info));
|
||||
type_info.class_size = type_query.class_size;
|
||||
type_info.instance_size = type_query.instance_size;
|
||||
type_info.class_init = (GClassInitFunc) gst_v4l2_codec_vp8_dec_subclass_init;
|
||||
type_info.class_data = gst_mini_object_ref (GST_MINI_OBJECT (device));
|
||||
type_info.instance_init = (GInstanceInitFunc) gst_v4l2_codec_vp8_dec_subinit;
|
||||
GST_MINI_OBJECT_FLAG_SET (device, GST_MINI_OBJECT_FLAG_MAY_BE_LEAKED);
|
||||
|
||||
/* The first decoder to be registered should use a constant name, like
|
||||
* v4l2slvp8dec, for any additional decoders, we create unique names. Decoder
|
||||
* names may change between boots, so this should help gain stable names for
|
||||
* the most common use cases. SL stands for state-less, we differentiate
|
||||
* with v4l2vp8dec as this element may not have the same properties */
|
||||
type_name = g_strdup ("v4l2slvp8dec");
|
||||
|
||||
if (g_type_from_name (type_name) != 0) {
|
||||
gchar *basename = g_path_get_basename (device->video_device_path);
|
||||
g_free (type_name);
|
||||
type_name = g_strdup_printf ("v4l2sl%svp8dec", basename);
|
||||
g_free (basename);
|
||||
}
|
||||
|
||||
subtype = g_type_register_static (GST_TYPE_V4L2_CODEC_VP8_DEC, type_name,
|
||||
&type_info, 0);
|
||||
|
||||
if (!gst_element_register (plugin, type_name, rank, subtype))
|
||||
GST_WARNING ("Failed to register plugin '%s'", type_name);
|
||||
|
||||
g_free (type_name);
|
||||
}
|
53
sys/v4l2codecs/gstv4l2codecvp8dec.h
Normal file
53
sys/v4l2codecs/gstv4l2codecvp8dec.h
Normal file
|
@ -0,0 +1,53 @@
|
|||
/* GStreamer
|
||||
* Copyright (C) 2020 Nicolas Dufresne <nicolas.dufresne@collabora.com>
|
||||
*
|
||||
* This library is free software; you can redistribute it and/or
|
||||
* modify it under the terms of the GNU Library General Public
|
||||
* License as published by the Free Software Foundation; either
|
||||
* version 2 of the License, or (at your option) any later version.
|
||||
*
|
||||
* This library is distributed in the hope that it will be useful,
|
||||
* but WITHOUT ANY WARRANTY; without even the implied warranty of
|
||||
* MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE. See the GNU
|
||||
* Library General Public License for more details.
|
||||
*
|
||||
* You should have received a copy of the GNU Library General Public
|
||||
* License along with this library; if not, write to the
|
||||
* Free Software Foundation, Inc., 51 Franklin St, Fifth Floor,
|
||||
* Boston, MA 02110-1301, USA.
|
||||
*/
|
||||
|
||||
#ifndef __GST_V4L2_CODEC_VP8_DEC_H__
|
||||
#define __GST_V4L2_CODEC_VP8_DEC_H__
|
||||
|
||||
#define GST_USE_UNSTABLE_API
|
||||
#include <gst/codecs/gstvp8decoder.h>
|
||||
|
||||
#include "gstv4l2decoder.h"
|
||||
|
||||
G_BEGIN_DECLS
|
||||
|
||||
#define GST_TYPE_V4L2_CODEC_VP8_DEC (gst_v4l2_codec_vp8_dec_get_type())
|
||||
#define GST_V4L2_CODEC_VP8_DEC(obj) (G_TYPE_CHECK_INSTANCE_CAST((obj),GST_TYPE_V4L2_CODEC_VP8_DEC,GstV4l2CodecVp8Dec))
|
||||
#define GST_V4L2_CODEC_VP8_DEC_CLASS(klass) (G_TYPE_CHECK_CLASS_CAST((klass),GST_TYPE_V4L2_CODEC_VP8_DEC,GstV4l2CodecVp8DecClass))
|
||||
#define GST_V4L2_CODEC_VP8_DEC_GET_CLASS(obj) (G_TYPE_INSTANCE_GET_CLASS ((obj), GST_TYPE_V4L2_CODEC_VP8_DEC, GstV4l2CodecVp8DecClass))
|
||||
#define GST_IS_V4L2_CODEC_VP8_DEC(obj) (G_TYPE_CHECK_INSTANCE_TYPE((obj),GST_TYPE_V4L2_CODEC_VP8_DEC))
|
||||
#define GST_IS_V4L2_CODEC_VP8_DEC_CLASS(obj) (G_TYPE_CHECK_CLASS_TYPE((klass),GST_TYPE_V4L2_CODEC_VP8_DEC))
|
||||
|
||||
typedef struct _GstV4l2CodecVp8Dec GstV4l2CodecVp8Dec;
|
||||
typedef struct _GstV4l2CodecVp8DecClass GstV4l2CodecVp8DecClass;
|
||||
|
||||
struct _GstV4l2CodecVp8DecClass
|
||||
{
|
||||
GstVp8DecoderClass parent_class;
|
||||
GstV4l2CodecDevice *device;
|
||||
};
|
||||
|
||||
GType gst_v4l2_codec_vp8_dec_get_type (void);
|
||||
void gst_v4l2_codec_vp8_dec_register (GstPlugin * plugin,
|
||||
GstV4l2CodecDevice * device,
|
||||
guint rank);
|
||||
|
||||
G_END_DECLS
|
||||
|
||||
#endif /* __GST_V4L2_CODEC_VP8_DEC_H__ */
|
112
sys/v4l2codecs/linux/vp8-ctrls.h
Normal file
112
sys/v4l2codecs/linux/vp8-ctrls.h
Normal file
|
@ -0,0 +1,112 @@
|
|||
/* SPDX-License-Identifier: GPL-2.0 */
|
||||
/*
|
||||
* These are the VP8 state controls for use with stateless VP8
|
||||
* codec drivers.
|
||||
*
|
||||
* It turns out that these structs are not stable yet and will undergo
|
||||
* more changes. So keep them private until they are stable and ready to
|
||||
* become part of the official public API.
|
||||
*/
|
||||
|
||||
#ifndef _VP8_CTRLS_H_
|
||||
#define _VP8_CTRLS_H_
|
||||
|
||||
#include <linux/types.h>
|
||||
|
||||
#define V4L2_PIX_FMT_VP8_FRAME v4l2_fourcc('V', 'P', '8', 'F')
|
||||
|
||||
#define V4L2_CID_MPEG_VIDEO_VP8_FRAME_HEADER (V4L2_CID_MPEG_BASE + 2000)
|
||||
#define V4L2_CTRL_TYPE_VP8_FRAME_HEADER 0x301
|
||||
|
||||
#define V4L2_VP8_SEGMENT_HEADER_FLAG_ENABLED 0x01
|
||||
#define V4L2_VP8_SEGMENT_HEADER_FLAG_UPDATE_MAP 0x02
|
||||
#define V4L2_VP8_SEGMENT_HEADER_FLAG_UPDATE_FEATURE_DATA 0x04
|
||||
#define V4L2_VP8_SEGMENT_HEADER_FLAG_DELTA_VALUE_MODE 0x08
|
||||
|
||||
struct v4l2_vp8_segment_header {
|
||||
__s8 quant_update[4];
|
||||
__s8 lf_update[4];
|
||||
__u8 segment_probs[3];
|
||||
__u8 padding;
|
||||
__u32 flags;
|
||||
};
|
||||
|
||||
#define V4L2_VP8_LF_HEADER_ADJ_ENABLE 0x01
|
||||
#define V4L2_VP8_LF_HEADER_DELTA_UPDATE 0x02
|
||||
#define V4L2_VP8_LF_FILTER_TYPE_SIMPLE 0x04
|
||||
struct v4l2_vp8_loopfilter_header {
|
||||
__s8 ref_frm_delta[4];
|
||||
__s8 mb_mode_delta[4];
|
||||
__u8 sharpness_level;
|
||||
__u8 level;
|
||||
__u16 padding;
|
||||
__u32 flags;
|
||||
};
|
||||
|
||||
struct v4l2_vp8_quantization_header {
|
||||
__u8 y_ac_qi;
|
||||
__s8 y_dc_delta;
|
||||
__s8 y2_dc_delta;
|
||||
__s8 y2_ac_delta;
|
||||
__s8 uv_dc_delta;
|
||||
__s8 uv_ac_delta;
|
||||
__u16 padding;
|
||||
};
|
||||
|
||||
struct v4l2_vp8_entropy_header {
|
||||
__u8 coeff_probs[4][8][3][11];
|
||||
__u8 y_mode_probs[4];
|
||||
__u8 uv_mode_probs[3];
|
||||
__u8 mv_probs[2][19];
|
||||
__u8 padding[3];
|
||||
};
|
||||
|
||||
struct v4l2_vp8_entropy_coder_state {
|
||||
__u8 range;
|
||||
__u8 value;
|
||||
__u8 bit_count;
|
||||
__u8 padding;
|
||||
};
|
||||
|
||||
#define V4L2_VP8_FRAME_HEADER_FLAG_KEY_FRAME 0x01
|
||||
#define V4L2_VP8_FRAME_HEADER_FLAG_EXPERIMENTAL 0x02
|
||||
#define V4L2_VP8_FRAME_HEADER_FLAG_SHOW_FRAME 0x04
|
||||
#define V4L2_VP8_FRAME_HEADER_FLAG_MB_NO_SKIP_COEFF 0x08
|
||||
#define V4L2_VP8_FRAME_HEADER_FLAG_SIGN_BIAS_GOLDEN 0x10
|
||||
#define V4L2_VP8_FRAME_HEADER_FLAG_SIGN_BIAS_ALT 0x20
|
||||
|
||||
#define VP8_FRAME_IS_KEY_FRAME(hdr) \
|
||||
(!!((hdr)->flags & V4L2_VP8_FRAME_HEADER_FLAG_KEY_FRAME))
|
||||
|
||||
struct v4l2_ctrl_vp8_frame_header {
|
||||
struct v4l2_vp8_segment_header segment_header;
|
||||
struct v4l2_vp8_loopfilter_header lf_header;
|
||||
struct v4l2_vp8_quantization_header quant_header;
|
||||
struct v4l2_vp8_entropy_header entropy_header;
|
||||
struct v4l2_vp8_entropy_coder_state coder_state;
|
||||
|
||||
__u16 width;
|
||||
__u16 height;
|
||||
|
||||
__u8 horizontal_scale;
|
||||
__u8 vertical_scale;
|
||||
|
||||
__u8 version;
|
||||
__u8 prob_skip_false;
|
||||
__u8 prob_intra;
|
||||
__u8 prob_last;
|
||||
__u8 prob_gf;
|
||||
__u8 num_dct_parts;
|
||||
|
||||
__u32 first_part_size;
|
||||
__u32 first_part_header_bits;
|
||||
__u32 dct_part_sizes[8];
|
||||
|
||||
__u64 last_frame_ts;
|
||||
__u64 golden_frame_ts;
|
||||
__u64 alt_frame_ts;
|
||||
|
||||
__u64 flags;
|
||||
};
|
||||
|
||||
#endif
|
|
@ -3,6 +3,7 @@ v4l2codecs_sources = [
|
|||
'gstv4l2codecallocator.c',
|
||||
'gstv4l2codecdevice.c',
|
||||
'gstv4l2codech264dec.c',
|
||||
'gstv4l2codecvp8dec.c',
|
||||
'gstv4l2codecpool.c',
|
||||
'gstv4l2decoder.c',
|
||||
'gstv4l2format.c',
|
||||
|
|
|
@ -24,8 +24,10 @@
|
|||
|
||||
#include "gstv4l2codecdevice.h"
|
||||
#include "gstv4l2codech264dec.h"
|
||||
#include "gstv4l2codecvp8dec.h"
|
||||
#include "gstv4l2decoder.h"
|
||||
#include "linux/h264-ctrls.h"
|
||||
#include "linux/vp8-ctrls.h"
|
||||
#include "linux/media.h"
|
||||
|
||||
#define GST_CAT_DEFAULT gstv4l2codecs_debug
|
||||
|
@ -50,6 +52,11 @@ register_video_decoder (GstPlugin * plugin, GstV4l2CodecDevice * device)
|
|||
device->name);
|
||||
gst_v4l2_codec_h264_dec_register (plugin, device, GST_RANK_PRIMARY + 1);
|
||||
break;
|
||||
case V4L2_PIX_FMT_VP8_FRAME:
|
||||
GST_INFO_OBJECT (decoder, "Registering %s as VP8 Decoder",
|
||||
device->name);
|
||||
gst_v4l2_codec_vp8_dec_register (plugin, device, GST_RANK_PRIMARY + 1);
|
||||
break;
|
||||
default:
|
||||
GST_FIXME_OBJECT (decoder, "%" GST_FOURCC_FORMAT " is not supported.",
|
||||
GST_FOURCC_ARGS (fmt));
|
||||
|
|
Loading…
Reference in a new issue