Quantcast

Playbin issue by using gstplayflags

classic Classic list List threaded Threaded
1 message Options
Reply | Threaded
Open this post in threaded view
|  
Report Content as Inappropriate

Playbin issue by using gstplayflags

pc_zhu
  I am using Playbin(gstreamer) to play rtsp://…,and I want to disable or enable audio when playing the living stream, so need to set the Gstplayflags.
Now the current situation :
1. For aac format : I can disable & enable audio successfully .
2. For g726, g711-mulaw, g711-alaw : Can not swtich successfully, but If I set audio & video flags first ,it has sound out. In addition, when playing the filesrc(file://...), I can disable & enable audio successfully too.
I have no idea about how to do, so ask for help, thanks!!!

This is my C code: Based on https://gstreamer.freedesktop.org/documentation/tutorials/playback/playbin-usage.html



#include <gst/gst.h>
#include <stdio.h>
#include <unistd.h>

#define MAX_INSTANCE 1
/* Structure to contain all our information, so we can pass it around */
typedef struct _CustomData {
  GstElement *playbin;  /* Our one and only element */
  GstElement *decode, *audioParser, *multiqueue;
  gint n_video;          /* Number of embedded video streams */
  gint n_audio;          /* Number of embedded audio streams */
  gint n_text;           /* Number of embedded subtitle streams */
  GstElement *video_sink;
  gint current_video;    /* Currently playing video stream */
  gint current_audio;    /* Currently playing audio stream */
  gint current_text;     /* Currently playing subtitle stream */
  GstBus *bus;
  //gint flags;
  GstStateChangeReturn ret;
  GMainLoop *main_loop;  /* GLib's Main Loop */
} CustomData;

/* playbin flags */
typedef enum {
  GST_PLAY_FLAG_VIDEO         = (1 << 0), /* We want video output */
  GST_PLAY_FLAG_AUDIO         = (1 << 1), /* We want audio output */
  GST_PLAY_FLAG_TEXT          = (1 << 2)  /* We want subtitle output */
} GstPlayFlags;

/* Forward definition for the message and keyboard processing functions */
static gboolean handle_message (GstBus *bus, GstMessage *msg, CustomData *data);
static gboolean handle_keyboard (GIOChannel *source, GIOCondition cond);
CustomData data[MAX_INSTANCE];
GIOChannel *io_stdin;
int main(int argc, char *argv[]) {  
  gint flags;

  /* Initialize GStreamer */
  gst_init (&argc, &argv);
  int i;
  /* Create the elements */
  for(i=0; i<MAX_INSTANCE; i++)
  {
  data[i].playbin = gst_element_factory_make ("playbin", "playbin");

if (!data[i].playbin) {
    g_printerr ("Not all elements could be created.\n");
    return -1;
  }
  /* Set the URI to play */
g_object_set (data[i].playbin, "uri", "rtsp://192.168.0.100:43794/profile1", NULL);

  /* Set flags to show Audio and Video but ignore Subtitles */
  g_object_get (data[i].playbin, "flags", &flags, NULL);
  g_print("flags0:%d\n",flags);
  flags &= ~GST_PLAY_FLAG_AUDIO;
  g_object_set (data[i].playbin, "flags", flags, NULL);
  g_print("flags0:%d\n",flags);

  /* Add a bus watch, so we get notified when a message arrives */
  data[i].bus = gst_element_get_bus (data[i].playbin);
  gst_bus_add_watch (data[i].bus, (GstBusFunc)handle_message, &data[i]);

 /* Start playing */
  data[i].ret = gst_element_set_state (data[i].playbin, GST_STATE_PLAYING);
    if (data[i].ret == GST_STATE_CHANGE_FAILURE) {
    g_printerr ("Unable to set the pipeline to the playing state.\n");
    gst_object_unref (data[i].playbin);
    return -1;
  }

}
/* Add a keyboard watch so we get notified of keystrokes */

#ifdef G_OS_WIN32
  io_stdin = g_io_channel_win32_new_fd (fileno (stdin));
#else
  io_stdin = g_io_channel_unix_new (fileno (stdin));
#endif
  g_io_add_watch (io_stdin, G_IO_IN, (GIOFunc)handle_keyboard, NULL);


for(i=0; i<MAX_INSTANCE; i++){
  /* Create a GLib Main Loop and set it to run */
  data[i].main_loop = g_main_loop_new (NULL, FALSE);
  g_main_loop_run (data[i].main_loop);
}
  return 0;
}

static void Free_resources (CustomData *data) {
  g_main_loop_unref (data->main_loop);
  gst_object_unref (data->bus);
  gst_element_set_state (data->playbin, GST_STATE_NULL);
  gst_object_unref (data->playbin);
}

/* Extract some metadata from the streams and print it on the screen */
/*
static void analyze_streams (CustomData *data) {
  gint i;
  GstTagList *tags;
  gchar *str;
  guint rate;

  /* Read some properties */
  /*
  g_object_get (data->playbin, "n-video", &data->n_video, NULL);
  g_object_get (data->playbin, "n-audio", &data->n_audio, NULL);
  g_object_get (data->playbin, "n-text", &data->n_text, NULL);

  g_print ("%d video stream(s), %d audio stream(s), %d text stream(s)\n",
    data->n_video, data->n_audio, data->n_text);

  g_print ("\n");
  for (i = 0; i < data->n_video; i++) {
    tags = NULL;
    /* Retrieve the stream's video tags */
    /*
    g_signal_emit_by_name (data->playbin, "get-video-tags", i, &tags);
    if (tags) {
      g_print ("video stream %d:\n", i);
      gst_tag_list_get_string (tags, GST_TAG_VIDEO_CODEC, &str);
      g_print ("  codec: %s\n", str ? str : "unknown");
      g_free (str);
      gst_tag_list_free (tags);
    }
  }

  g_print ("\n");
  for (i = 0; i < data->n_audio; i++) {
    tags = NULL;
    /* Retrieve the stream's audio tags */
    /*
    g_signal_emit_by_name (data->playbin, "get-audio-tags", i, &tags);
    if (tags) {
      g_print ("audio stream %d:\n", i);
      if (gst_tag_list_get_string (tags, GST_TAG_AUDIO_CODEC, &str)) {
        g_print ("  codec: %s\n", str);
        g_free (str);
      }
      if (gst_tag_list_get_string (tags, GST_TAG_LANGUAGE_CODE, &str)) {
        g_print ("  language: %s\n", str);
        g_free (str);
      }
      if (gst_tag_list_get_uint (tags, GST_TAG_BITRATE, &rate)) {
        g_print ("  bitrate: %d\n", rate);
     }
      gst_tag_list_free (tags);
    }
  }

  g_print ("\n");
  for (i = 0; i < data->n_text; i++) {
    tags = NULL;
    /* Retrieve the stream's subtitle tags */
    /*
    g_signal_emit_by_name (data->playbin, "get-text-tags", i, &tags);
    if (tags) {
      g_print ("subtitle stream %d:\n", i);
      if (gst_tag_list_get_string (tags, GST_TAG_LANGUAGE_CODE, &str)) {
        g_print ("  language: %s\n", str);
        g_free (str);
      }
      gst_tag_list_free (tags);
    }
  }

  g_object_get (data->playbin, "current-video", &data->current_video, NULL);
  g_object_get (data->playbin, "current-audio", &data->current_audio, NULL);
  g_object_get (data->playbin, "current-text", &data->current_text, NULL);

  g_print ("\n");
  g_print ("Currently playing video stream %d, audio stream %d and text stream %d\n",
    data->current_video, data->current_audio, data->current_text);
  g_print ("Type any number and hit ENTER to select a different audio stream\n");
}
*/
/* Process messages from GStreamer */
static gboolean handle_message (GstBus *bus, GstMessage *msg, CustomData *data) {
  GError *err;
  gchar *debug_info;

  switch (GST_MESSAGE_TYPE (msg)) {
    case GST_MESSAGE_ERROR:
      gst_message_parse_error (msg, &err, &debug_info);
      g_printerr ("Error received from element %s: %s\n", GST_OBJECT_NAME (msg->src), err->message);
      g_printerr ("Debugging information: %s\n", debug_info ? debug_info : "none");
      g_clear_error (&err);
      g_free (debug_info);
      g_main_loop_quit (data->main_loop);
      Free_resources(data);
      break;
    case GST_MESSAGE_EOS:
      g_print ("End-Of-Stream reached.\n");
      g_main_loop_quit (data->main_loop);
      Free_resources(data);
      break;
    case GST_MESSAGE_STATE_CHANGED: {
      GstState old_state, new_state, pending_state;
      gst_message_parse_state_changed (msg, &old_state, &new_state, &pending_state);
      /*
      if (GST_MESSAGE_SRC (msg) == GST_OBJECT (data->playbin)) {
        if (new_state == GST_STATE_PLAYING) {
          /* Once we are in the playing state, analyze the streams */
          /*
          analyze_streams (data);
        }
      }*/
    } break;
  }

  /* We want to keep receiving messages */
  return TRUE;
}
/* Process keyboard input */
static gboolean handle_keyboard (GIOChannel *source, GIOCondition cond) {
  gchar *str = NULL;
  gint flags;
  int i;
  if (g_io_channel_read_line (source, &str, NULL, NULL, NULL) == G_IO_STATUS_NORMAL) {
    int index = g_ascii_strtoull (str, NULL, 0);
    if (index == 0 ) {
      g_print ("Turn off audio!!!\n");
     
      g_object_get (data[0].playbin, "flags", &flags, NULL);
      g_print("flags1:%d\n",flags);
      flags &= ~GST_PLAY_FLAG_AUDIO;
      g_print("flags1:%d\n",flags);
      g_object_set (data[0].playbin, "flags", flags, NULL);
     
      //gst_element_set_state (data[0].playbin, GST_STATE_PLAYING);
    } else {
      g_print ("Turn on audio!!!\n");
      g_object_get (data[0].playbin, "flags", &flags, NULL);
      g_print("flags2:%d\n",flags);
      flags |=  GST_PLAY_FLAG_AUDIO;
      g_print("flags2:%d\n",flags);
      g_object_set (data[0].playbin, "flags", flags, NULL);
     
    }
  }
  g_free (str);
  return TRUE;
}
Loading...