gsty4mencode.c 9.37 KB
Newer Older
1
/* GStreamer
2
 * Copyright (C) <1999> Erik Walthinsen <omega@cse.ogi.edu>
3
 * Copyright (C) <2006> Mark Nauwelaerts <mnauw@users.sourceforge.net>
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
 *
 * 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., 59 Temple Place - Suite 330,
 * Boston, MA 02111-1307, USA.
 */
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
/**
 * SECTION:element-y4menc
 *
 * <refsect2>
 * <para>
 * Creates a YU4MPEG2 raw video stream as defined by the mjpegtools project.
 * </para>
 * <title>Example launch line</title>
 * <para>
 * (write everything in one line, without the backslash characters)
 * <programlisting>
 * gst-launch-0.10 videotestsrc num-buffers=250 \
 * ! 'video/x-raw-yuv,format=(fourcc)I420,width=320,height=240,framerate=(fraction)25/1' \
 * ! y4menc ! filesink location=test.yuv
 * </programlisting>
 * </para>
 * </refsect2>
 *
 */
39

40
41
/* see mjpegtools/yuv4mpeg.h for yuv4mpeg format */

42
43
44
#ifdef HAVE_CONFIG_H
#include "config.h"
#endif
45
46
#include <string.h>
#include <gst/gst.h>
47
#include <gst/video/video.h>
48
#include "gsty4mencode.h"
49

50
static const GstElementDetails y4mencode_details =
51
GST_ELEMENT_DETAILS ("YUV4MPEG video encoder",
52
53
54
    "Codec/Encoder/Video",
    "Encodes a YUV frame into the yuv4mpeg format (mjpegtools)",
    "Wim Taymans <wim.taymans@chello.be>");
55
56
57


/* Filter signals and args */
58
59
enum
{
60
61
62
63
  /* FILL ME */
  LAST_SIGNAL
};

64
65
enum
{
66
67
68
  ARG_0
};

69
static GstStaticPadTemplate y4mencode_src_factory =
70
71
72
GST_STATIC_PAD_TEMPLATE ("src",
    GST_PAD_SRC,
    GST_PAD_ALWAYS,
73
    GST_STATIC_CAPS ("application/x-yuv4mpeg, " "y4mversion = (int) 2")
74
    );
75

76
static GstStaticPadTemplate y4mencode_sink_factory =
77
78
79
GST_STATIC_PAD_TEMPLATE ("sink",
    GST_PAD_SINK,
    GST_PAD_ALWAYS,
80
    GST_STATIC_CAPS (GST_VIDEO_CAPS_YUV ("{ IYUV, I420 }"))
81
82
83
    );


84
static void gst_y4m_encode_set_property (GObject * object,
85
    guint prop_id, const GValue * value, GParamSpec * pspec);
86
static void gst_y4m_encode_get_property (GObject * object,
87
88
    guint prop_id, GValue * value, GParamSpec * pspec);

89
static void gst_y4m_encode_reset (GstY4mEncode * filter);
90

91
92
93
94
static gboolean gst_y4m_encode_setcaps (GstPad * pad, GstCaps * vscaps);
static GstFlowReturn gst_y4m_encode_chain (GstPad * pad, GstBuffer * buf);
static GstStateChangeReturn gst_y4m_encode_change_state (GstElement * element,
    GstStateChange transition);
95

96
GST_BOILERPLATE (GstY4mEncode, gst_y4m_encode, GstElement, GST_TYPE_ELEMENT);
97

98
99

static void
100
gst_y4m_encode_base_init (gpointer g_class)
101
102
{
  GstElementClass *element_class = GST_ELEMENT_CLASS (g_class);
103
104
105
106
107

  gst_element_class_add_pad_template (element_class,
      gst_static_pad_template_get (&y4mencode_src_factory));
  gst_element_class_add_pad_template (element_class,
      gst_static_pad_template_get (&y4mencode_sink_factory));
108
109
  gst_element_class_set_details (element_class, &y4mencode_details);
}
110

111
static void
112
gst_y4m_encode_class_init (GstY4mEncodeClass * klass)
113
114
115
116
{
  GObjectClass *gobject_class;
  GstElementClass *gstelement_class;

117
118
  gobject_class = (GObjectClass *) klass;
  gstelement_class = (GstElementClass *) klass;
119

120
121
  gstelement_class->change_state =
      GST_DEBUG_FUNCPTR (gst_y4m_encode_change_state);
122

123
124
  gobject_class->set_property = gst_y4m_encode_set_property;
  gobject_class->get_property = gst_y4m_encode_get_property;
125
126
127
}

static void
128
gst_y4m_encode_init (GstY4mEncode * filter, GstY4mEncodeClass * klass)
129
{
130
  filter->sinkpad =
131
      gst_pad_new_from_static_template (&y4mencode_sink_factory, "sink");
132
  gst_element_add_pad (GST_ELEMENT (filter), filter->sinkpad);
133
134
135
136
  gst_pad_set_chain_function (filter->sinkpad,
      GST_DEBUG_FUNCPTR (gst_y4m_encode_chain));
  gst_pad_set_setcaps_function (filter->sinkpad,
      GST_DEBUG_FUNCPTR (gst_y4m_encode_setcaps));
137

138
  filter->srcpad =
139
      gst_pad_new_from_static_template (&y4mencode_src_factory, "src");
140
  gst_element_add_pad (GST_ELEMENT (filter), filter->srcpad);
141
  gst_pad_use_fixed_caps (filter->srcpad);
142

143
144
  /* init properties */
  gst_y4m_encode_reset (filter);
145
146
147
}

static void
148
149
150
151
152
153
154
155
156
gst_y4m_encode_reset (GstY4mEncode * filter)
{
  filter->width = filter->height = -1;
  filter->fps_num = filter->fps_den = 1;
  filter->par_num = filter->par_den = 1;
}

static gboolean
gst_y4m_encode_setcaps (GstPad * pad, GstCaps * vscaps)
157
{
158
  GstY4mEncode *filter;
159
  GstStructure *structure;
160
  gboolean res;
161
162
163
164
165
166
167
  gint w, h;
  const GValue *fps, *par;

  filter = GST_Y4M_ENCODE (GST_PAD_PARENT (pad));

  structure = gst_caps_get_structure (vscaps, 0);

168
169
170
171
172
173
174
  res = gst_structure_get_int (structure, "width", &w);
  res &= gst_structure_get_int (structure, "height", &h);
  res &= ((fps = gst_structure_get_value (structure, "framerate")) != NULL);

  if (!res || w <= 0 || h <= 0 || !GST_VALUE_HOLDS_FRACTION (fps))
    return FALSE;

175
176
177
178
179
180
181
182
183
184
185
186
187
188
  /* optional par info */
  par = gst_structure_get_value (structure, "pixel-aspect-ratio");

  filter->width = w;
  filter->height = h;
  filter->fps_num = gst_value_get_fraction_numerator (fps);
  filter->fps_den = gst_value_get_fraction_denominator (fps);
  if ((par != NULL) && GST_VALUE_HOLDS_FRACTION (par)) {
    filter->par_num = gst_value_get_fraction_numerator (par);
    filter->par_den = gst_value_get_fraction_denominator (par);
  } else {                      /* indicates unknown */
    filter->par_num = 0;
    filter->par_den = 0;
  }
189

190
191
  /* the template caps will do for the src pad, should always accept */
  return gst_pad_set_caps (filter->srcpad,
192
      gst_static_pad_template_get_caps (&y4mencode_src_factory));
193
}
194

195
196
197
198
199
static inline GstBuffer *
gst_y4m_encode_get_stream_header (GstY4mEncode * filter)
{
  gpointer header;
  GstBuffer *buf;
200

201
202
203
  header = g_strdup_printf ("YUV4MPEG2 W%d H%d I? F%d:%d A%d:%d\n",
      filter->width, filter->height,
      filter->fps_num, filter->fps_den, filter->par_num, filter->par_den);
204

205
206
207
208
209
210
211
  buf = gst_buffer_new ();
  gst_buffer_set_data (buf, header, strlen (header));
  /* so it gets free'd when needed */
  GST_BUFFER_MALLOCDATA (buf) = header;

  return buf;
}
212

213
214
215
216
217
static inline GstBuffer *
gst_y4m_encode_get_frame_header (GstY4mEncode * filter)
{
  gpointer header;
  GstBuffer *buf;
218

219
  header = g_strdup_printf ("FRAME\n");
220

221
222
223
224
  buf = gst_buffer_new ();
  gst_buffer_set_data (buf, header, strlen (header));
  /* so it gets free'd when needed */
  GST_BUFFER_MALLOCDATA (buf) = header;
225

226
227
228
229
230
231
232
233
  return buf;
}

static GstFlowReturn
gst_y4m_encode_chain (GstPad * pad, GstBuffer * buf)
{
  GstY4mEncode *filter = GST_Y4M_ENCODE (GST_PAD_PARENT (pad));
  GstBuffer *outbuf;
234
  GstClockTime timestamp;
235
236
237
238
239
240
241
242
243

  /* check we got some decent info from caps */
  if (filter->width < 0) {
    GST_ELEMENT_ERROR ("filter", CORE, NEGOTIATION, (NULL),
        ("format wasn't negotiated before chain function"));
    gst_buffer_unref (buf);
    return GST_FLOW_NOT_NEGOTIATED;
  }

244
245
  timestamp = GST_BUFFER_TIMESTAMP (buf);

246
247
248
249
250
251
252
253
254
255
256
257
  if (G_UNLIKELY (!filter->header)) {
    outbuf = gst_y4m_encode_get_stream_header (filter);
    filter->header = TRUE;
    outbuf = gst_buffer_join (outbuf, gst_y4m_encode_get_frame_header (filter));
  } else {
    outbuf = gst_y4m_encode_get_frame_header (filter);
  }
  /* join with data */
  outbuf = gst_buffer_join (outbuf, buf);
  /* decorate */
  gst_buffer_make_metadata_writable (outbuf);
  gst_buffer_set_caps (outbuf, GST_PAD_CAPS (filter->srcpad));
258
259
260

  GST_BUFFER_TIMESTAMP (outbuf) = timestamp;

261
  return gst_pad_push (filter->srcpad, outbuf);
262
263
264
}

static void
265
gst_y4m_encode_set_property (GObject * object, guint prop_id,
266
    const GValue * value, GParamSpec * pspec)
267
{
268
  GstY4mEncode *filter;
269

270
271
  g_return_if_fail (GST_IS_Y4M_ENCODE (object));
  filter = GST_Y4M_ENCODE (object);
272
273
274
275
276
277
278
279

  switch (prop_id) {
    default:
      break;
  }
}

static void
280
gst_y4m_encode_get_property (GObject * object, guint prop_id, GValue * value,
281
    GParamSpec * pspec)
282
{
283
  GstY4mEncode *filter;
284

285
286
  g_return_if_fail (GST_IS_Y4M_ENCODE (object));
  filter = GST_Y4M_ENCODE (object);
287
288
289
290
291
292
293
294

  switch (prop_id) {
    default:
      G_OBJECT_WARN_INVALID_PROPERTY_ID (object, prop_id, pspec);
      break;
  }
}

295
static GstStateChangeReturn
296
gst_y4m_encode_change_state (GstElement * element, GstStateChange transition)
297
{
298
299
  GstY4mEncode *filter = GST_Y4M_ENCODE (element);
  GstStateChangeReturn ret;
300

301
302
303
304
305
306
307
  switch (transition) {
    case GST_STATE_CHANGE_NULL_TO_READY:
    case GST_STATE_CHANGE_READY_TO_PAUSED:
      break;
    default:
      break;
  }
308

309
310
311
312
  ret = GST_CALL_PARENT_WITH_DEFAULT (GST_ELEMENT_CLASS, change_state,
      (element, transition), GST_STATE_CHANGE_SUCCESS);
  if (ret != GST_STATE_CHANGE_SUCCESS)
    return ret;
313

314
315
316
317
318
319
  switch (transition) {
    case GST_STATE_CHANGE_PAUSED_TO_READY:
      gst_y4m_encode_reset (filter);
      break;
    default:
      break;
320
321
  }

322
  return GST_STATE_CHANGE_SUCCESS;
323
324
325
}

static gboolean
326
plugin_init (GstPlugin * plugin)
327
{
328
  return gst_element_register (plugin, "y4menc", GST_RANK_NONE,
329
      GST_TYPE_Y4M_ENCODE);
330
331
}

332
333
334
335
GST_PLUGIN_DEFINE (GST_VERSION_MAJOR,
    GST_VERSION_MINOR,
    "y4menc",
    "Encodes a YUV frame into the yuv4mpeg format (mjpegtools)",
336
    plugin_init, VERSION, GST_LICENSE, GST_PACKAGE_NAME, GST_PACKAGE_ORIGIN)