Наши партнеры

Библиотека сайта rus-linux.net

Фреймворк GStreamer. Руководство разработчика плагинов. Создание тестового приложения

Оригинал: GStreamer Plugin Writer's Guide
Авторы: Richard John Boulton, Erik Walthinsen, Steve Baker, Leif Johnson, Ronald S. Bultje, Stefan Kost, Tim-Philipp Muller, Wim Taymans
Дата публикации: 19 июля 2014 г.
Перевод: А.Панин
Дата перевода: 26 июля 2014 г.

Глава 11. Создание тестового приложения

Периодически у вас будет возникать желание протестировать разрабатываемый плагин в настолько ограниченном окружении, насколько это возможно. Утилита gst-launch-1.0 обычно является неплохим первым шагом в процессе тестирования плагина. Если вы не установили ваш плагин в директорию, в которой фреймворк GStreamer осуществляет поиск плагинов, вам придется установить путь к дополнительной директории плагинов. Следует либо установить в качестве значения переменной окружения GST_PLUGIN_PATH путь к директории, содержащей ваш плагин, либо использовать параметр командной строки утилиты --gst-plugin-path для передачи этого пути. В том случае, если вы создавали свой плагин на основе шаблона gst-plugin, параметры запуска утилиты будут аналогичны следующим: gst-launch-1.0 --gst-plugin-path=$HOME/gst-template/gst-plugin/src/.libs ТЕСТОВЫЙ_КОНВЕЙЕР. Однако, обычно для отладки плагина требуется больше возможностей, чем утилита gst-launch-1.0 может предоставить, а именно, требуются функции для осуществления перемещений в мультимедийном потоке, обработки событий, интерактивного взаимодействия и другие. Разработка вашего собственного небольшого тестового приложения является простейшим способом получения доступа к упомянутым функциям. В данной главе кратко описывается методика разработки такого приложения. Если же вас интересует подробное руководство по разработке приложений, вам следует обратиться к Руководству разработчика приложений на основе фреймворка GStreamer.

Для начала вам придется инициализировать главную библиотеку фреймворка GStreamer, вызвав функцию gst_init (). Альтернативным вариантом является вызов функции gst_init_get_option_group (), которая вернет указатель на структуру типа GOptionGroup. После этого вы сможете использовать интерфейс GOption для выполнения инициализации и на этом этапе инициализация фреймворка GStreamer будет завершена.

Вы можете создать элементы с помощью функции gst_element_factory_make (), первым аргументом которой является идентификатор типа элемента, который вы хотите создать, а вторым аргументом - имя элемента в свободной форме. В примере, размещенном в конце главы, используется простой конвейер из элемента для ввода данных из файла, декодера и элемента для вывода данных с помощью звуковой карты, но вы также можете использовать специфические элементы для отладки, если это необходимо. Например, элемент для передачи данных без изменения identity может быть помещен в центре конвейера для того, чтобы он функционировал как передатчик данных к приложению. Описанный подход может использоваться для выявления некорректных попыток передачи данных или проверки корректности самих данных в ходе тестирования вашего приложения. Также вы можете использовать элемент фиктивного вывода данных fakesink в конце конвейера для вывода ваших данных в поток стандартного вывода stdout (для того, чтобы активировать соответствующий режим работы элемента, установите логическое значение TRUE свойства dump). Наконец, вы можете использовать инструмент valgrind для выявления ошибок, допущенных при ручном управлении памятью.

В процессе связывания точек соединения ваше тестовое приложение может использовать механизм фильтрации возможностей в качестве способа передачи данных определенного типа вашему элементу и приема данных определенного типа от него. Это очень простой и эффективный способ проверки возможности приема и передачи данных множества типов средствами вашего элемента.

Учтите, что в процессе работы приложения вы должны будете отслеживать появление по крайней мере сообщений об ошибках "error" и сообщений об окончании потока "eos" на шине сообщений конвейера и/или в рамках вашего плагина/элемента для проверки корректности обработки соответствующих событий. Также вам придется отправлять события по конвейеру, чтобы убедиться в том, что ваш плагин корректно обрабатывает их (с учетом значений таймеров, внутренних механизмов кэширования и.т.д.).

Никогда не забывайте об освобождении фрагментов памяти ваших плагинов или вашего тестового приложения. При переходе в отключенное состояние (NULL) ваш элемент должен освободить зарезервированную память и кэши. Также он должен разорвать все связи, установленные с возможными вспомогательными библиотеками. Ваше приложение должно использовать функцию удаления ссылки unref () по отношению к объекту конвейера и убедиться в том, что эта операция была завершена успешно.

#include <gst/gst.h>

static gboolean
bus_call (GstBus     *bus,
	  GstMessage *msg,
	  gpointer    data)
{
  GMainLoop *loop = data;

switch (GST_MESSAGE_TYPE (msg)) {
    case GST_MESSAGE_EOS:
      g_print ("Окончание потока (End-of-stream)\n");
      g_main_loop_quit (loop);
      break;
    case GST_MESSAGE_ERROR: {
      gchar *debug = NULL;
      GError *err = NULL;

gst_message_parse_error (msg, &err, &debug);

g_print ("Ошибка: %s\n", err->message);
      g_error_free (err);

if (debug) {
        g_print ("Подробная информация для отладки: %s\n", debug);
        g_free (debug);
      }

g_main_loop_quit (loop);
      break;
    }
    default:
      break;
  }

return TRUE;
}

gint
main (gint   argc,
      gchar *argv[])
{
  GstStateChangeReturn ret;
  GstElement *pipeline, *filesrc, *decoder, *filter, *sink;
  GstElement *convert1, *convert2, *resample;
  GMainLoop *loop;
  GstBus *bus;
  guint watch_id;

/* Инициализация */
  gst_init (&argc, &argv);
  loop = g_main_loop_new (NULL, FALSE);
  if (argc != 2) {
    g_print ("Использование: %s <имя файла формата mp3>\n", argv[0]);
    return 01;
  }

/* Создание элементов */
  pipeline = gst_pipeline_new ("my_pipeline");

/* Отслеживание сообщений на шине сообщений конвейера (учтите, что этот механизм 
   * будет работать только в случае запуска главного цикла обработки событий GLib) */
  bus = gst_pipeline_get_bus (GST_PIPELINE (pipeline));
  watch_id = gst_bus_add_watch (bus, bus_call, loop);
  gst_object_unref (bus);

filesrc  = gst_element_factory_make ("filesrc", "my_filesource");
  decoder  = gst_element_factory_make ("mad", "my_decoder");

/* Размещение элемента преобразования аудиоформата audioconvert для преобразования 
   * выводимых декодером данных в формат, который может обработать элемент my_filter
   * (хотя мы предполагаем, что элемент сможет обработать любую частоту дискретизации) */
  convert1 = gst_element_factory_make ("audioconvert", "audioconvert1");

/* Использование элемента передачи данных в качестве фильтра, не выполняющего преобразований */
  filter   = gst_element_factory_make ("my_filter", "my_filter");

/* Элементы преобразования формата потока audioconvert и audioresample всегда должны
   * находиться перед элементом для вывода аудиопотока, так как возможности последнего 
   * обычно варьируются в зависимости от окружения (параметров вывода, звуковой карты, драйвера и.т.д.) */
  convert2 = gst_element_factory_make ("audioconvert", "audioconvert2");
  resample = gst_element_factory_make ("audioresample", "audioresample");
  sink     = gst_element_factory_make ("pulsesink", "audiosink");

if (!sink || !decoder) {
    g_print ("Элемент декодера или элемент для вывода данных не найден - проверьте корректность установки фреймворка\n");
    return -1;
  } else if (!convert1 || !convert2 || !resample) {
    g_print ("Не удалось создать элемент для изменения параметров аудиопотока (audioconvert или audioresample), "
             "проверьте корректность установки фреймворка\n");
    return -1;
  } else if (!filter) {
    g_print ("Ваш элемент фильтра на найден. Убедитесь в том, что он корректно "
             " установлен в директорию $(libdir)/gstreamer-1.0/ или ~/.gstreamer-1.0/plugins/, "
             " а также в том, что утилита gst-inspect-1.0 сообщает о его наличии. "
             "Если это не так, используйте команду 'GST_DEBUG=*:2 gst-inspect-1.0' "
             "для установления причины, по которой он не был загружен.");
    return -1;
  }

g_object_set (G_OBJECT (filesrc), "location", argv[1], NULL);

gst_bin_add_many (GST_BIN (pipeline), filesrc, decoder, convert1, filter,
                    convert2, resample, sink, NULL);

/* Связывание всех элементов */
  if (!gst_element_link_many (filesrc, decoder, convert1, filter, convert2,
                              resample, sink, NULL)) {
    g_print ("Не удалось связать один или более элементов!\n");
    return -1;
  }

/* Запуск конвейера */
  ret = gst_element_set_state (pipeline, GST_STATE_PLAYING);
  if (ret == GST_STATE_CHANGE_FAILURE) {
    GstMessage *msg;

g_print ("Не удалось запустить конвейер!\n");

/* Проверка наличия сообщения об ошибке с подробной информацией на шине  сообщений */
    msg = gst_bus_poll (bus, GST_MESSAGE_ERROR, 0);
    if (msg) {
      GError *err = NULL;

gst_message_parse_error (msg, &err, NULL);
      g_print ("ОШИБКА: %s\n", err->message);
      g_error_free (err);
      gst_message_unref (msg);
    }
    return -1;
  }

g_main_loop_run (loop);

/* Освобождение ресурсов */
  gst_element_set_state (pipeline, GST_STATE_NULL);
  gst_object_unref (pipeline);
  g_source_remove (watch_id);
  g_main_loop_unref (loop);

return 0;
}

Следующий раздел : Создаваемые по запросу и не постоянно доступные точки соединения.