#include <string.h>
#include <string>
#include <fstream>
 
#include "gh_kit.h"
#include "gh_gstsink.h"
 
GST_DEBUG_CATEGORY_STATIC (gh_gstsink_debug);
#define GST_CAT_DEFAULT gh_gstsink_debug
 
/* Enum to identify properties */
enum
{
  PROP_0,
  PROP_UNIQUE_ID
};
 
/* Default values for properties */
#define DEFAULT_UNIQUE_ID       15
#define DEFAULT_PROCESSING_WIDTH    640
#define DEFAULT_PROCESSING_HEIGHT   480
#define DEFAULT_PROCESS_FULL_FRAME  TRUE
#define DEFAULT_GPU_ID          0
 
static GstStaticPadTemplate gh_gstsink_sink_template =
GST_STATIC_PAD_TEMPLATE ("sink",
    GST_PAD_SINK,
    GST_PAD_ALWAYS,
    GST_STATIC_CAPS ("WUXI"));
 
static GstStaticPadTemplate gh_gstsink_src_template =
GST_STATIC_PAD_TEMPLATE ("src",
    GST_PAD_SRC,
    GST_PAD_ALWAYS,
    GST_STATIC_CAPS ("WUXI"));
 
/* Define our element type. Standard GObject/GStreamer boilerplate stuff */
#define gh_gstsink_parent_class parent_class
G_DEFINE_TYPE (GhGstSink, gh_gstsink, GST_TYPE_BASE_SINK);
 
static void gh_gstsink_set_property (GObject * object, guint prop_id, const GValue * value, GParamSpec * pspec);
static void gh_gstsink_get_property (GObject * object, guint prop_id, GValue * value, GParamSpec * pspec);
 
static gboolean gh_gstsink_start (   GstBaseSink * basesink);
static gboolean gh_gstsink_stop (    GstBaseSink * basesink);
 
/**
GstEvent *gst_event_new_eos (void);
Create a new EOS event. The eos event can only travel downstream synchronized with the buffer flow. Elements that receive the EOS event on a pad can return GST_FLOW_EOS as a GstFlowReturn when data after the EOS event arrives.
The EOS event will travel down to the sink elements in the pipeline which will then post the GST_MESSAGE_EOS on the bus after they have finished playing any buffered data.
When all sinks have posted an EOS message, an EOS message is forwarded to the application.
The EOS event itself will not cause any state transitions of the pipeline.
Events are usually created with gst_event_new_*() which takes event-type specific parameters as arguments. To send an event application will usually use gst_element_send_event() and elements will use gst_pad_send_event() or gst_pad_push_event(). The event should be unreffed with gst_event_unref() if it has not been sent.
gst_event_type_get_flags(), GST_EVENT_IS_UPSTREAM, GST_EVENT_IS_DOWNSTREAM, and GST_EVENT_IS_SERIALIZED. 
gst_collect_pads_event
*/
 
//所有sinks发出了EOS消息，EOS就会转发给应用。我这里发出了，为什么还没结束？
//GST_MESSAGE_EOS
static gboolean gh_gstsink_event(GstBaseSink *sink, GstEvent *event)
{
    GstElement* element = (GstElement*)sink;
    GhGstSink*  ghsink  = (GhGstSink*) sink;
 
    switch(event-> type)
    {
        case GST_EVENT_EOS:
            //GstStateChangeReturn ret = GST_STATE_CHANGE_SUCCESS;
            //parent_class->change_state(element, transition);
            GH_LOG_TEXT("GST_EVENT_EOS");
            gst_element_set_state(element, GST_STATE_NULL);
            //gst_event_new_eos();
            //gst_send_event(
            ghsink->isEOS = 1;
            gst_element_send_event(element, event);
            gst_pad_send_event ((GstPad*)element, event);
            return TRUE;
 
        case GST_EVENT_FLUSH_START:
        case GST_EVENT_FLUSH_STOP:
        default:
            break;
    }
    return TRUE;
}
 
static GstFlowReturn gh_gstsink_render(GstBaseSink *sink, GstBuffer *buffer)
{
    GhGstSink*  ghsink  = (GhGstSink*) sink;
    return ghsink->isEOS ? GST_FLOW_EOS : GST_FLOW_OK;
}
 
 
static GstStateChangeReturn gh_gstsink_change_state(GstElement* element, GstStateChange transition)
{
  GstElementClass *oclass;
  GstStateChangeReturn result = GST_STATE_CHANGE_SUCCESS;
  GhGstSink*  ghsink  = (GhGstSink*) element;
 
 
  g_return_val_if_fail (GST_IS_ELEMENT (element), GST_STATE_CHANGE_FAILURE);
 
  oclass = GST_ELEMENT_GET_CLASS (element);
 
  if (oclass->set_state && ghsink->isEOS)
  {
     (oclass->set_state) (element, GST_STATE_NULL);
  }
  
  return result;
}
 
 
/* Install properties, set sink and src pad capabilities, override the required
 * functions of the base class, These are common to all instances of the
 * element.
 */
static void gh_gstsink_class_init (GhGstSinkClass * klass)
{
  GObjectClass     *gobject_class;
  GstElementClass  *gstelement_class;
  GstBaseSinkClass *gstbasesink_class;
 
  gobject_class     = (GObjectClass *) klass;
  gstelement_class  = (GstElementClass *) klass;
  gstbasesink_class = (GstBaseSinkClass *) klass;
 
  /* Overide base class functions */
  gobject_class->set_property     = GST_DEBUG_FUNCPTR (gh_gstsink_set_property);
  gobject_class->get_property     = GST_DEBUG_FUNCPTR (gh_gstsink_get_property);
 
  gstbasesink_class->render       = GST_DEBUG_FUNCPTR (gh_gstsink_render);
  gstbasesink_class->start        = GST_DEBUG_FUNCPTR (gh_gstsink_start);
  gstbasesink_class->stop         = GST_DEBUG_FUNCPTR (gh_gstsink_stop);
  gstbasesink_class->event        = GST_DEBUG_FUNCPTR (gh_gstsink_event);
 
  //gstelement_class->change_state  = GST_DEBUG_FUNCPTR (gh_gstsink_change_state);
 
  //klass->eos                      = gh_gstsink_eos_cb;
  //guint eossignal_id = 0;
  //eossignal_id = g_signal_new ("eos", G_TYPE_FROM_CLASS(klass),
  //        G_SIGNAL_RUN_LAST,
  //        G_STRUCT_OFFSET (GhGstSinkClass, eos), NULL, NULL, NULL, G_TYPE_INT, 0, G_TYPE_NONE);
 
  //klass->signal_action  = gh_gstsink_callback;
  //eossignal_id = g_signal_new ("act", G_TYPE_FROM_CLASS (klass),
  //        G_SIGNAL_RUN_LAST | G_SIGNAL_ACTION,
  //        G_STRUCT_OFFSET (GhGstSinkClass, act), NULL, NULL, NULL, G_TYPE_INT, 0, G_TYPE_NONE);
 
  /* Install properties */
  g_object_class_install_property (gobject_class, PROP_UNIQUE_ID,
      g_param_spec_uint ("unique-id",
          "Unique ID",
          "Unique ID for the element. Can be used to identify output of the element", 0, G_MAXUINT, DEFAULT_UNIQUE_ID, (GParamFlags)
          (G_PARAM_READWRITE | G_PARAM_STATIC_STRINGS)));
 
 
  /* Set sink and src pad capabilities */
  //gst_element_class_add_pad_template (gstelement_class,
  //    gst_static_pad_template_get (&gh_gstsink_src_template));
  gst_element_class_add_pad_template (gstelement_class,
      gst_static_pad_template_get (&gh_gstsink_sink_template));
 
  /* Set metadata describing the element */
  gst_element_class_set_details_simple (gstelement_class,
      "GhGstSink plugin",
      "GhGstSink Plugin",
      "wuxi data sink",
      URL
      URL);
}
 
static void gh_gstsink_init (GhGstSink * ghsink)
{
   ghsink->isEOS = 0;
}
 
/* Function called when a property of the element is set. Standard boilerplate.
 */
static void gh_gstsink_set_property (GObject * object, guint prop_id,
    const GValue * value, GParamSpec * pspec)
{
  GhGstSink *ghsink = GST_GHGSTSINK (object);
  switch (prop_id)
  {
    case PROP_UNIQUE_ID:
      ghsink->unique_id = g_value_get_uint (value);
      break;
 
    default:
      G_OBJECT_WARN_INVALID_PROPERTY_ID (object, prop_id, pspec);
      break;
  }
}
 
/* Function called when a property of the element is requested. Standard
 * boilerplate.
 */
static void gh_gstsink_get_property (GObject * object, guint prop_id,
    GValue * value, GParamSpec * pspec)
{
  GhGstSink *ghsink = GST_GHGSTSINK (object);
 
  switch (prop_id)
  {
    case PROP_UNIQUE_ID:
      g_value_set_uint (value, ghsink->unique_id);
      break;
 
    default:
      G_OBJECT_WARN_INVALID_PROPERTY_ID (object, prop_id, pspec);
      break;
  }
}
 
/**
 * Initialize all resources and start the output thread
 */
static gboolean gh_gstsink_start (GstBaseSink * basesink)
{
  GH_LOG_HERE();
  return TRUE;
}
 
/**
 * Stop the output thread and free up all the resources
 */
static gboolean gh_gstsink_stop (GstBaseSink * basesink)
{
  GH_LOG_HERE();
  return TRUE;
}
 
/**
 * Boiler plate for registering a plugin and an element.
 */
static gboolean ghsink_plugin_init (GstPlugin * plugin)
{
  GST_DEBUG_CATEGORY_INIT (gh_gstsink_debug, GH_GSTSINK_NAME, 0,
      "ghgstsink plugin");
 
  return gst_element_register (plugin, GH_GSTSINK_NAME, GST_RANK_PRIMARY,
      GST_TYPE_GHGSTSINK);
}
 
GST_PLUGIN_DEFINE (GST_VERSION_MAJOR,
    GST_VERSION_MINOR,
    ghsink,
    DESCRIPTION, ghsink_plugin_init, VERSION, LICENSE, BINARY_PACKAGE, URL)
  GST_TYPE_GHGSTSINK);
}
 
GST_PLUGIN_DEFINE (GST_VERSION_MAJOR,
    GST_VERSION_MINOR,
    ghsink,
    DESCRIPTION, ghsink_plugin_init, VERSION, LICENSE, BINARY_PACKAGE, URL)