/* GStreamer

 * Copyright (C) <1999> Erik Walthinsen <omega@cse.ogi.edu>

 * Copyright (C) <2002> David A. Schleef <ds@schleef.org>

 *

 * 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.

 */

/**

 * SECTION:element-videotestsrc

 *

 * <refsect2>

 * <para>

 * The videotestsrc element is used to produce test video data in a wide variaty

 * of formats. The video test data produced can be controlled with the "pattern"

 * property.

 * </para>

 * <title>Example launch line</title>

 * <para>

 * <programlisting>

 * gst-launch -v videotestsrc pattern=snow ! ximagesink

 * </programlisting>

 * Shows random noise in an X window.

 * </para>

 * </refsect2>

 */

#ifdef HAVE_CONFIG_H

#include "config.h"

#endif

#include "gstvideotestsrc.h"

#include "videotestsrc.h"

#include <string.h>

#include <stdlib.h>

#include <gst/liboil.h>

#define USE_PEER_BUFFERALLOC

GST_DEBUG_CATEGORY_STATIC (video_test_src_debug);

#define GST_CAT_DEFAULT video_test_src_debug

static const GstElementDetails video_test_src_details =

GST_ELEMENT_DETAILS ("Video test source",

    "Source/Video",

    "Creates a test video stream",

    "David A. Schleef <ds@schleef.org>");

enum

{

  PROP_0,

  PROP_PATTERN,

  PROP_TIMESTAMP_OFFSET,

  PROP_IS_LIVE

      /* FILL ME */

};

GST_BOILERPLATE (GstVideoTestSrc, gst_video_test_src, GstPushSrc,

    GST_TYPE_PUSH_SRC);

static void gst_video_test_src_set_pattern (GstVideoTestSrc * videotestsrc,

    int pattern_type);

static void gst_video_test_src_set_property (GObject * object, guint prop_id,

    const GValue * value, GParamSpec * pspec);

static void gst_video_test_src_get_property (GObject * object, guint prop_id,

    GValue * value, GParamSpec * pspec);

static GstCaps *gst_video_test_src_getcaps (GstBaseSrc * bsrc);

static gboolean gst_video_test_src_setcaps (GstBaseSrc * bsrc, GstCaps * caps);

static void gst_video_test_src_src_fixate (GstPad * pad, GstCaps * caps);

static gboolean gst_video_test_src_is_seekable (GstBaseSrc * psrc);

static gboolean gst_video_test_src_do_seek (GstBaseSrc * bsrc,

    GstSegment * segment);

static gboolean gst_video_test_src_query (GstBaseSrc * bsrc, GstQuery * query);

static void gst_video_test_src_get_times (GstBaseSrc * basesrc,

    GstBuffer * buffer, GstClockTime * start, GstClockTime * end);

static GstFlowReturn gst_video_test_src_create (GstPushSrc * psrc,

    GstBuffer ** buffer);

static gboolean gst_video_test_src_start (GstBaseSrc * basesrc);

#define GST_TYPE_VIDEO_TEST_SRC_PATTERN (gst_video_test_src_pattern_get_type ())

static GType

gst_video_test_src_pattern_get_type (void)

{

  static GType video_test_src_pattern_type = 0;

  static const GEnumValue pattern_types[] = {

    {GST_VIDEO_TEST_SRC_SMPTE, "SMPTE 100% color bars", "smpte"},

    {GST_VIDEO_TEST_SRC_SNOW, "Random (television snow)", "snow"},

    {GST_VIDEO_TEST_SRC_BLACK, "100% Black", "black"},

    {GST_VIDEO_TEST_SRC_WHITE, "100% White", "white"},

    {GST_VIDEO_TEST_SRC_RED, "Red", "red"},

    {GST_VIDEO_TEST_SRC_GREEN, "Green", "green"},

    {GST_VIDEO_TEST_SRC_BLUE, "Blue", "blue"},

    {GST_VIDEO_TEST_SRC_CHECKERS1, "Checkers 1px", "checkers-1"},

    {GST_VIDEO_TEST_SRC_CHECKERS2, "Checkers 2px", "checkers-2"},

    {GST_VIDEO_TEST_SRC_CHECKERS4, "Checkers 4px", "checkers-4"},

    {GST_VIDEO_TEST_SRC_CHECKERS8, "Checkers 8px", "checkers-8"},

    {GST_VIDEO_TEST_SRC_CIRCULAR, "Circular", "circular"},

    {GST_VIDEO_TEST_SRC_BLINK, "Blink", "blink"},

    {0, NULL, NULL}

  };

  if (!video_test_src_pattern_type) {

    video_test_src_pattern_type =

        g_enum_register_static ("GstVideoTestSrcPattern", pattern_types);

  }

  return video_test_src_pattern_type;

}

static void

gst_video_test_src_base_init (gpointer g_class)

{

  GstElementClass *element_class = GST_ELEMENT_CLASS (g_class);

  gst_element_class_set_details (element_class, &video_test_src_details);

  gst_element_class_add_pad_template (element_class,

      gst_pad_template_new ("src", GST_PAD_SRC, GST_PAD_ALWAYS,

          gst_video_test_src_getcaps (NULL)));

}

static void

gst_video_test_src_class_init (GstVideoTestSrcClass * klass)

{

  GObjectClass *gobject_class;

  GstBaseSrcClass *gstbasesrc_class;

  GstPushSrcClass *gstpushsrc_class;

  gobject_class = (GObjectClass *) klass;

  gstbasesrc_class = (GstBaseSrcClass *) klass;

  gstpushsrc_class = (GstPushSrcClass *) klass;

  gobject_class->set_property = gst_video_test_src_set_property;

  gobject_class->get_property = gst_video_test_src_get_property;

  g_object_class_install_property (gobject_class, PROP_PATTERN,

      g_param_spec_enum ("pattern", "Pattern",

          "Type of test pattern to generate", GST_TYPE_VIDEO_TEST_SRC_PATTERN,

          GST_VIDEO_TEST_SRC_SMPTE, G_PARAM_READWRITE));

  g_object_class_install_property (gobject_class,

      PROP_TIMESTAMP_OFFSET, g_param_spec_int64 ("timestamp-offset",

          "Timestamp offset",

          "An offset added to timestamps set on buffers (in ns)", G_MININT64,

          G_MAXINT64, 0, G_PARAM_READWRITE));

  g_object_class_install_property (gobject_class, PROP_IS_LIVE,

      g_param_spec_boolean ("is-live", "Is Live",

          "Whether to act as a live source", FALSE, G_PARAM_READWRITE));

  gstbasesrc_class->get_caps = gst_video_test_src_getcaps;

  gstbasesrc_class->set_caps = gst_video_test_src_setcaps;

  gstbasesrc_class->is_seekable = gst_video_test_src_is_seekable;

  gstbasesrc_class->do_seek = gst_video_test_src_do_seek;

  gstbasesrc_class->query = gst_video_test_src_query;

  gstbasesrc_class->get_times = gst_video_test_src_get_times;

  gstbasesrc_class->start = gst_video_test_src_start;

  gstpushsrc_class->create = gst_video_test_src_create;

}

static void

gst_video_test_src_init (GstVideoTestSrc * src, GstVideoTestSrcClass * g_class)

{

  GstPad *pad = GST_BASE_SRC_PAD (src);

  gst_pad_set_fixatecaps_function (pad, gst_video_test_src_src_fixate);

  gst_video_test_src_set_pattern (src, GST_VIDEO_TEST_SRC_SMPTE);

  src->timestamp_offset = 0;

  /* we operate in time */

  gst_base_src_set_format (GST_BASE_SRC (src), GST_FORMAT_TIME);

  gst_base_src_set_live (GST_BASE_SRC (src), FALSE);

}

static void

gst_video_test_src_src_fixate (GstPad * pad, GstCaps * caps)

{

  GstStructure *structure;

  structure = gst_caps_get_structure (caps, 0);

  gst_structure_fixate_field_nearest_int (structure, "width", 320);

  gst_structure_fixate_field_nearest_int (structure, "height", 240);

  gst_structure_fixate_field_nearest_fraction (structure, "framerate", 30, 1);

}

static void

gst_video_test_src_set_pattern (GstVideoTestSrc * videotestsrc,

    int pattern_type)

{

  videotestsrc->pattern_type = pattern_type;

  GST_DEBUG_OBJECT (videotestsrc, "setting pattern to %d", pattern_type);

  switch (pattern_type) {

    case GST_VIDEO_TEST_SRC_SMPTE:

      videotestsrc->make_image = gst_video_test_src_smpte;

      break;

    case GST_VIDEO_TEST_SRC_SNOW:

      videotestsrc->make_image = gst_video_test_src_snow;

      break;

    case GST_VIDEO_TEST_SRC_BLACK:

      videotestsrc->make_image = gst_video_test_src_black;

      break;

    case GST_VIDEO_TEST_SRC_WHITE:

      videotestsrc->make_image = gst_video_test_src_white;

      break;

    case GST_VIDEO_TEST_SRC_RED:

      videotestsrc->make_image = gst_video_test_src_red;

      break;

    case GST_VIDEO_TEST_SRC_GREEN:

      videotestsrc->make_image = gst_video_test_src_green;

      break;

    case GST_VIDEO_TEST_SRC_BLUE:

      videotestsrc->make_image = gst_video_test_src_blue;

      break;

    case GST_VIDEO_TEST_SRC_CHECKERS1:

      videotestsrc->make_image = gst_video_test_src_checkers1;

      break;

    case GST_VIDEO_TEST_SRC_CHECKERS2:

      videotestsrc->make_image = gst_video_test_src_checkers2;

      break;

    case GST_VIDEO_TEST_SRC_CHECKERS4:

      videotestsrc->make_image = gst_video_test_src_checkers4;

      break;

    case GST_VIDEO_TEST_SRC_CHECKERS8:

      videotestsrc->make_image = gst_video_test_src_checkers8;

      break;

    case GST_VIDEO_TEST_SRC_CIRCULAR:

      videotestsrc->make_image = gst_video_test_src_circular;

      break;

    case GST_VIDEO_TEST_SRC_BLINK:

      videotestsrc->make_image = gst_video_test_src_black;

      break;

    default:

      g_assert_not_reached ();

  }

}

static void

gst_video_test_src_set_property (GObject * object, guint prop_id,

    const GValue * value, GParamSpec * pspec)

{

  GstVideoTestSrc *src = GST_VIDEO_TEST_SRC (object);

  switch (prop_id) {

    case PROP_PATTERN:

      gst_video_test_src_set_pattern (src, g_value_get_enum (value));

      break;

    case PROP_TIMESTAMP_OFFSET:

      src->timestamp_offset = g_value_get_int64 (value);

      break;

    case PROP_IS_LIVE:

      gst_base_src_set_live (GST_BASE_SRC (src), g_value_get_boolean (value));

      break;

    default:

      break;

  }

}

static void

gst_video_test_src_get_property (GObject * object, guint prop_id,

    GValue * value, GParamSpec * pspec)

{

  GstVideoTestSrc *src = GST_VIDEO_TEST_SRC (object);

  switch (prop_id) {

    case PROP_PATTERN:

      g_value_set_enum (value, src->pattern_type);

      break;

    case PROP_TIMESTAMP_OFFSET:

      g_value_set_int64 (value, src->timestamp_offset);

      break;

    case PROP_IS_LIVE:

      g_value_set_boolean (value, gst_base_src_is_live (GST_BASE_SRC (src)));

      break;

    default:

      G_OBJECT_WARN_INVALID_PROPERTY_ID (object, prop_id, pspec);

      break;

  }

}

/* threadsafe because this gets called as the plugin is loaded */

static GstCaps *

gst_video_test_src_getcaps (GstBaseSrc * unused)

{

  static GstCaps *capslist = NULL;

  if (!capslist) {

    GstCaps *caps;

    GstStructure *structure;

    int i;

    caps = gst_caps_new_empty ();

    for (i = 0; i < n_fourccs; i++) {

      structure = paint_get_structure (fourcc_list + i);

      gst_structure_set (structure,

          "width", GST_TYPE_INT_RANGE, 1, G_MAXINT,

          "height", GST_TYPE_INT_RANGE, 1, G_MAXINT,

          "framerate", GST_TYPE_FRACTION_RANGE, 0, 1, G_MAXINT, 1, NULL);

      gst_caps_append_structure (caps, structure);

    }

    capslist = caps;

  }

  return gst_caps_copy (capslist);

}

static gboolean

gst_video_test_src_parse_caps (const GstCaps * caps,

    gint * width, gint * height, gint * rate_numerator, gint * rate_denominator,

    struct fourcc_list_struct **fourcc)

{

  const GstStructure *structure;

  GstPadLinkReturn ret;

  const GValue *framerate;

  GST_DEBUG ("parsing caps");

  if (gst_caps_get_size (caps) < 1)

    return FALSE;

  structure = gst_caps_get_structure (caps, 0);

  if (!(*fourcc = paintinfo_find_by_structure (structure)))

    goto unknown_format;

  ret = gst_structure_get_int (structure, "width", width);

  ret &= gst_structure_get_int (structure, "height", height);

  framerate = gst_structure_get_value (structure, "framerate");

  if (framerate) {

    *rate_numerator = gst_value_get_fraction_numerator (framerate);

    *rate_denominator = gst_value_get_fraction_denominator (framerate);

  } else

    goto no_framerate;

  return ret;

  /* ERRORS */

unknown_format:

  {

    GST_DEBUG ("videotestsrc format not found");

    return FALSE;

  }

no_framerate:

  {

    GST_DEBUG ("videotestsrc no framerate given");

    return FALSE;

  }

}

static gboolean

gst_video_test_src_setcaps (GstBaseSrc * bsrc, GstCaps * caps)

{

  gboolean res;

  gint width, height, rate_denominator, rate_numerator;

  struct fourcc_list_struct *fourcc;

  GstVideoTestSrc *videotestsrc;

  videotestsrc = GST_VIDEO_TEST_SRC (bsrc);

  res = gst_video_test_src_parse_caps (caps, &width, &height,

      &rate_numerator, &rate_denominator, &fourcc);

  if (res) {

    /* looks ok here */

    videotestsrc->fourcc = fourcc;

    videotestsrc->width = width;

    videotestsrc->height = height;

    videotestsrc->rate_numerator = rate_numerator;

    videotestsrc->rate_denominator = rate_denominator;

    videotestsrc->bpp = videotestsrc->fourcc->bitspp;

    GST_DEBUG_OBJECT (videotestsrc, "size %dx%d, %d/%d fps",

        videotestsrc->width, videotestsrc->height,

        videotestsrc->rate_numerator, videotestsrc->rate_denominator);

  }

  return res;

}

static gboolean

gst_video_test_src_query (GstBaseSrc * bsrc, GstQuery * query)

{

  gboolean res;

  GstVideoTestSrc *src;

  src = GST_VIDEO_TEST_SRC (bsrc);

  switch (GST_QUERY_TYPE (query)) {

    case GST_QUERY_CONVERT:

    {

      GstFormat src_fmt, dest_fmt;

      gint64 src_val, dest_val;

      gst_query_parse_convert (query, &src_fmt, &src_val, &dest_fmt, &dest_val);

      if (src_fmt == dest_fmt) {

        dest_val = src_val;

        goto done;

      }

      switch (src_fmt) {

        case GST_FORMAT_DEFAULT:

          switch (dest_fmt) {

            case GST_FORMAT_TIME:

              /* frames to time */

              if (src->rate_numerator) {

                dest_val = gst_util_uint64_scale (src_val,

                    src->rate_denominator * GST_SECOND, src->rate_numerator);

              } else {

                dest_val = 0;

              }

              break;

            default:

              goto error;

          }

          break;

        case GST_FORMAT_TIME:

          switch (dest_fmt) {

            case GST_FORMAT_DEFAULT:

              /* time to frames */

              if (src->rate_numerator) {

                dest_val = gst_util_uint64_scale (src_val,

                    src->rate_numerator, src->rate_denominator * GST_SECOND);

              } else {

                dest_val = 0;

              }

              break;

            default:

              goto error;

          }

          break;

        default:

          goto error;

      }

    done:

      gst_query_set_convert (query, src_fmt, src_val, dest_fmt, dest_val);

      res = TRUE;

      break;

    }

    default:

      res = GST_BASE_SRC_CLASS (parent_class)->query (bsrc, query);

  }

  return res;

  /* ERROR */

error:

  {

    GST_DEBUG_OBJECT (src, "query failed");

    return FALSE;

  }

}

static void

gst_video_test_src_get_times (GstBaseSrc * basesrc, GstBuffer * buffer,

    GstClockTime * start, GstClockTime * end)

{

  /* for live sources, sync on the timestamp of the buffer */

  if (gst_base_src_is_live (basesrc)) {

    GstClockTime timestamp = GST_BUFFER_TIMESTAMP (buffer);

    if (GST_CLOCK_TIME_IS_VALID (timestamp)) {

      /* get duration to calculate end time */

      GstClockTime duration = GST_BUFFER_DURATION (buffer);

      if (GST_CLOCK_TIME_IS_VALID (duration)) {

        *end = timestamp + duration;

      }

      *start = timestamp;

    }

  } else {

    *start = -1;

    *end = -1;

  }

}

static gboolean

gst_video_test_src_do_seek (GstBaseSrc * bsrc, GstSegment * segment)

{

  GstClockTime time;

  GstVideoTestSrc *src;

  src = GST_VIDEO_TEST_SRC (bsrc);

  segment->time = segment->start;

  time = segment->last_stop;

  /* now move to the time indicated */

  if (src->rate_numerator) {

    src->n_frames = gst_util_uint64_scale (time,

        src->rate_numerator, src->rate_denominator * GST_SECOND);

  } else {

    src->n_frames = 0;

  }

  if (src->rate_numerator) {

    src->running_time = gst_util_uint64_scale (src->n_frames,

        src->rate_denominator * GST_SECOND, src->rate_numerator);

  } else {

    /* FIXME : Not sure what to set here */

    src->running_time = 0;

  }

  g_assert (src->running_time <= time);

  return TRUE;

}

static gboolean

gst_video_test_src_is_seekable (GstBaseSrc * psrc)