ducatividdec: delay flushing till the end of the codec processing
[glsdk/gst-plugin-ducati.git] / src / gstducatividdec.h
1 /*
2  * GStreamer
3  * Copyright (c) 2010, Texas Instruments Incorporated
4  *
5  * This library is free software; you can redistribute it and/or
6  * modify it under the terms of the GNU Lesser General Public
7  * License as published by the Free Software Foundation
8  * version 2.1 of the License.
9  *
10  * This library is distributed in the hope that it will be useful,
11  * but WITHOUT ANY WARRANTY; without even the implied warranty of
12  * MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE. See the GNU
13  * Lesser General Public License for more details.
14  *
15  * You should have received a copy of the GNU Lesser General Public
16  * License along with this library; if not, write to the Free Software
17  * Foundation, Inc., 51 Franklin Street, Fifth Floor, Boston, MA  02110-1301  USA
18  */
20 #ifndef __GST_DUCATIVIDDEC_H__
21 #define __GST_DUCATIVIDDEC_H__
23 #include <stdint.h>
24 #include <stddef.h>
25 #include <omap_drm.h>
26 #include <omap_drmif.h>
28 #include "gstducati.h"
29 #include "gstducatibufferpriv.h"
31 #include <gst/drm/gstdrmbufferpool.h>
32 #include <gst/video/video.h>
33 #include <gst/video/video-crop.h>
35 G_BEGIN_DECLS
37 #define GST_TYPE_DUCATIVIDDEC               (gst_ducati_viddec_get_type())
38 #define GST_DUCATIVIDDEC(obj)               (G_TYPE_CHECK_INSTANCE_CAST((obj), GST_TYPE_DUCATIVIDDEC, GstDucatiVidDec))
39 #define GST_DUCATIVIDDEC_CLASS(klass)       (G_TYPE_CHECK_CLASS_CAST((klass), GST_TYPE_DUCATIVIDDEC, GstDucatiVidDecClass))
40 #define GST_IS_DUCATIVIDDEC(obj)            (G_TYPE_CHECK_INSTANCE_TYPE((obj), GST_TYPE_DUCATIVIDDEC))
41 #define GST_IS_DUCATIVIDDEC_CLASS(klass)    (G_TYPE_CHECK_CLASS_TYPE((klass), GST_TYPE_DUCATIVIDDEC))
42 #define GST_DUCATIVIDDEC_GET_CLASS(obj)     (G_TYPE_INSTANCE_GET_CLASS((obj), GST_TYPE_DUCATIVIDDEC, GstDucatiVidDecClass))
44 typedef struct _GstDucatiVidDec      GstDucatiVidDec;
45 typedef struct _GstDucatiVidDecClass GstDucatiVidDecClass;
47 struct _GstDucatiVidDec
48 {
49   GstElement parent;
51   GstPad *sinkpad, *srcpad;
53   GstDRMBufferPool *pool;
55   /* minimum output size required by the codec: */
56   gint outsize;
58   /* minimum number of buffers required by the codec: */
59   gint min_buffers;
61   /* input (unpadded, unaligned) size of video: */
62   gint input_width, input_height;
64   /* input (unpadded, aligned to MB) size of video: */
65   gint width, height;
67   gint fps_n, fps_d;
69   /* output (padded) size including any codec padding: */
70   gint padded_width, padded_height;
72   /* output stride (>= padded_width) */
73   gint stride;
75   gboolean interlaced;
77   struct omap_bo *input_bo;
78   /* input buffer, allocated when codec is created: */
79   guint8 *input;
81   /* number of bytes pushed to input on current frame: */
82   gint in_size;
84   /* the crop to attach to output buffers: */
85   GstVideoCrop *crop;
87   /* on first output buffer, we need to send crop info to sink.. and some
88    * operations like flushing should be avoided if we haven't sent any
89    * input buffers:
90    */
91   gboolean first_out_buffer, first_in_buffer;
92   gboolean send_crop_event;
94   GstSegment segment;
95   gdouble qos_proportion;
96   GstClockTime qos_earliest_time;
98   gboolean need_out_buf;
100   /* by default, codec_data from sinkpad is prepended to first buffer: */
101   GstBuffer *codec_data;
103   /* workaround enabled to indicate that timestamp from demuxer is PTS,
104    * not DTS (cough, cough.. avi):
105    */
106   gboolean ts_is_pts;
108   /* auto-detection for ts_is_pts workaround.. if we detect out of order
109    * timestamps from demuxer/parser, then the ts is definitely DTS,
110    * otherwise it may be PTS and out of order timestamps out of decoder
111    * will trigger the ts_is_pts workaround.
112    */
113   gboolean ts_may_be_pts;
115   gboolean wait_keyframe;
117   gboolean needs_flushing;
119 #define NDTS 32
120   GstClockTime dts_queue[NDTS];
121   gint dts_ridx, dts_widx;
122   GstClockTime last_dts, last_pts;
124   Engine_Handle           engine;
125   VIDDEC3_Handle          codec;
126   VIDDEC3_Params         *params;
127   VIDDEC3_DynamicParams  *dynParams;
128   VIDDEC3_Status         *status;
129   XDM2_BufDesc           *inBufs;
130   XDM2_BufDesc           *outBufs;
131   VIDDEC3_InArgs         *inArgs;
132   VIDDEC3_OutArgs        *outArgs;
134   XDAS_Int16 pageMemType;
135   struct omap_device *device;
136 };
138 struct _GstDucatiVidDecClass
140   GstElementClass parent_class;
142   const gchar *codec_name;
144   /**
145    * Parse codec specific fields the given caps structure.  The base-
146    * class implementation of this method handles standard stuff like
147    * width/height/framerate/codec_data.
148    */
149   gboolean (*parse_caps) (GstDucatiVidDec * self, GstStructure * s);
151   /**
152    * Called when the input buffer size changes, to recalculate codec required
153    * output buffer size and minimum count
154    */
155   void (*update_buffer_size) (GstDucatiVidDec * self);
157   /**
158    * Called to allocate/initialize  params/dynParams/status/inArgs/outArgs
159    */
160   gboolean (*allocate_params) (GstDucatiVidDec * self, gint params_sz,
161       gint dynparams_sz, gint status_sz, gint inargs_sz, gint outargs_sz);
163   /**
164    * Push input data into codec's input buffer, returning a sub-buffer of
165    * any remaining data, or NULL if none.  Consumes reference to 'buf'
166    */
167   GstBuffer * (*push_input) (GstDucatiVidDec * self, GstBuffer * buf);
169   /**
170    * Called to handle errors returned by VIDDEC3_process.
171    */
172   gint (*handle_error) (GstDucatiVidDec * self, gint ret, gint extended_error,
173       gint status_extended_error);
175   /**
176    * Called to check whether it's a good idea to drop buf or not.
177    */
178   gboolean (*drop_frame) (GstDucatiVidDec * self, GstBuffer * buf, gint64 diff);
180   gboolean (*query) (GstDucatiVidDec * self, GstPad * pad, GstQuery * query,
181       gboolean * forward);
182 };
184 GType gst_ducati_viddec_get_type (void);
186 /* helper methods for derived classes: */
188 static inline void
189 push_input (GstDucatiVidDec * self, const guint8 *in, gint sz)
191   GST_DEBUG_OBJECT (self, "push: %d bytes)", sz);
192   memcpy (self->input + self->in_size, in, sz);
193   self->in_size += sz;
196 static inline int
197 check_start_code (const guint8 *sc, gint scsize,
198     const guint8 *inbuf, gint insize)
200   if (insize < scsize)
201     return FALSE;
203   while (scsize) {
204     if (*sc != *inbuf)
205       return FALSE;
206     scsize--;
207     sc++;
208     inbuf++;
209   }
211   return TRUE;
214 static inline int
215 find_start_code (const guint8 *sc, gint scsize,
216     const guint8 *inbuf, gint insize)
218   gint size = 0;
219   while (insize) {
220     if (check_start_code (sc, scsize, inbuf, insize))
221       break;
222     insize--;
223     size++;
224     inbuf++;
225   }
226   return size;
229 gboolean
230 gst_ducati_viddec_codec_flush (GstDucatiVidDec * self, gboolean eos);
232 G_END_DECLS
234 #endif /* __GST_DUCATIVIDDEC_H__ */