gstreamer/subprojects/gst-plugins-good/tests/examples/rtsp/test-onvif.c

#include <gst/gst.h>

static GMainLoop *loop = NULL;
static GstElement *backpipe = NULL;
static gint stream_id = -1;

static GstFlowReturn
new_sample (GstElement * appsink, GstElement * rtspsrc)
{
  GstSample *sample;
  GstFlowReturn ret = GST_FLOW_OK;

  g_assert (stream_id != -1);

  /* get the sample from appsink */
  g_signal_emit_by_name (appsink, "pull-sample", &sample);

  if (!sample)
    goto nosample;

  g_signal_emit_by_name (rtspsrc, "push-backchannel-sample", stream_id, sample,
      &ret);

  /* Action signal callbacks don't take ownership of the arguments passed, so we must unref the sample here.
   * (The "push-backchannel-buffer" callback unrefs the sample, which is wrong and doesn't work with bindings
   * but could not be changed, hence the new "push-backchannel-sample" callback that behaves correctly.)  */
  gst_sample_unref (sample);

nosample:
  return ret;
}

static void
setup_backchannel_shoveler (GstElement * rtspsrc, GstCaps * caps)
{
  GstElement *appsink;

  gst_println ("Have audio backchannel caps %" GST_PTR_FORMAT "\n", caps);

  const GstStructure *s = gst_caps_get_structure (caps, 0);

  const gchar *encoding = gst_structure_get_string (s, "encoding-name");
  if (encoding == NULL) {
    g_error
        ("Could not setup backchannel pipeline: Missing encoding-name field");
    g_main_loop_quit (loop);
  }

  GError *error = NULL;

  if (g_str_equal (encoding, "PCMU")) {
    backpipe =
        gst_parse_launch
        ("audiotestsrc is-live=true wave=red-noise ! capsfilter name=ratefilter ! "
        "rtppcmupay ! appsink name=out", &error);
  } else if (g_str_equal (encoding, "MPEG4-GENERIC")) {
    backpipe =
        gst_parse_launch
        ("audiotestsrc is-live=true wave=red-noise ! capsfilter name=ratefilter ! "
        "voaacenc ! aacparse ! rtpmp4gpay ! appsink name=out", &error);
  } else {
    g_error ("Could not setup backchannel pipeline: Unsupported encoding %s",
        encoding);
    g_main_loop_quit (loop);
  }

  if (!backpipe) {
    g_error ("Could not setup backchannel pipeline");
    if (error != NULL) {
      g_error ("Error: %s", error->message);
      g_clear_error (&error);
    }
    g_main_loop_quit (loop);
  }

  gint rate = 32000;
  if (!gst_structure_get_int (s, "clock-rate", &rate)) {
    g_error ("Could not setup backchannel pipeline: Missing clock-rate field");
    g_main_loop_quit (loop);
  }

  GstElement *rate_filter =
      gst_bin_get_by_name (GST_BIN (backpipe), "ratefilter");
  g_assert (rate_filter != NULL);

  GstCaps *rate_caps =
      gst_caps_new_simple ("audio/x-raw", "rate", G_TYPE_INT, rate, NULL);
  g_object_set (G_OBJECT (rate_filter), "caps", rate_caps, NULL);
  gst_caps_unref (rate_caps);

  gst_object_unref (GST_OBJECT (rate_filter));

  appsink = gst_bin_get_by_name (GST_BIN (backpipe), "out");
  g_object_set (G_OBJECT (appsink), "caps", caps, "emit-signals", TRUE, NULL);

  g_signal_connect (appsink, "new-sample", G_CALLBACK (new_sample), rtspsrc);

  g_print ("Playing backchannel shoveler\n");
  gst_element_set_state (backpipe, GST_STATE_PLAYING);
}

static gboolean
remove_extra_fields (const GstIdStr * fieldname, GValue * value G_GNUC_UNUSED,
    gpointer user_data G_GNUC_UNUSED)
{
  return !g_str_has_prefix (gst_id_str_as_str (fieldname), "a-");
}

static gboolean
find_backchannel (GstElement * rtspsrc, guint idx, GstCaps * caps,
    gpointer user_data G_GNUC_UNUSED)
{
  GstStructure *s;
  gchar *caps_str = gst_caps_to_string (caps);
  g_print ("Selecting stream idx %u, caps %s\n", idx, caps_str);
  g_free (caps_str);

  s = gst_caps_get_structure (caps, 0);
  if (gst_structure_has_field (s, "a-sendonly")) {
    stream_id = idx;
    caps = gst_caps_new_empty ();
    s = gst_structure_copy (s);
    gst_structure_set_name (s, "application/x-rtp");
    gst_structure_filter_and_map_in_place_id_str (s, remove_extra_fields, NULL);
    gst_caps_append_structure (caps, s);
    setup_backchannel_shoveler (rtspsrc, caps);
  }

  return TRUE;
}

int
main (int argc, char *argv[])
{
  GstElement *pipeline, *rtspsrc;
  const gchar *location;

  gst_init (&argc, &argv);

  if (argc >= 2)
    location = argv[1];
  else
    location = "rtsp://127.0.0.1:8554/test";

  loop = g_main_loop_new (NULL, FALSE);

  pipeline = gst_parse_launch ("rtspsrc backchannel=onvif debug=true name=r "
      "r. ! queue ! decodebin ! queue ! xvimagesink async=false "
      "r. ! queue ! decodebin ! queue ! pulsesink async=false ", NULL);
  if (!pipeline)
    g_error ("Failed to parse pipeline");

  rtspsrc = gst_bin_get_by_name (GST_BIN (pipeline), "r");
  g_object_set (G_OBJECT (rtspsrc), "location", location, NULL);
  g_signal_connect (rtspsrc, "select-stream", G_CALLBACK (find_backchannel),
      NULL);

  gst_element_set_state (pipeline, GST_STATE_PLAYING);

  g_main_loop_run (loop);
  return 0;
}