gstreamer-plugin 2日目: _chain() について

今日は Chapter 5. The chain funtion についてです。

※ Day13 の環境を前提にこれからお話しするので、まだDay13を見てない人は、まずはそちらで環境構築を！

やりたいことを書く _chain()

Chapter 5 にも書いているように _chain() は「プラグインでやりたいこと」を実装する場所です。「プラグイン作りたいなー」と思ってまず弄っていくのはここということになります。

バケツリレーな GStreamer の処理

Element は好きな処理をした後pad_push()するのが、 GStreamer のルールです。

上流の Element が pad_push()すると、_chain() の第3引数に GstBuffer が入ってきます。そして、なんらかの「やりたいこと」を処理したあと、GstBuffer を pad_push() します。

pad_push()されると下流の_chain()が実行され、バケツリレーの要領で_chain()が次々と実行されていきます。(まさにパイプラインです！)

パイプラインの実装は?

この動きは gstpad.cに書かれています。
下流のElementの_chain()を呼ぶのは gstpad.c のこの行なので、ここからどんどん遡っていくとgst_pad_push()に巡りあえます :)

_chain を編集してみよう

さて、pad_push() → _chain() の概念を知ったところで Boilerplate のコードに手を入れてみましょう。

※ GstBuffer についてはyashi さんの Day 12で解説されているのでここでは省きます。

ここから、ここまで を _chain()に追加したらさっそくビルドしましょう。

gstplugin.c

/* chain function
 * this function does the actual processing
 */
static GstFlowReturn
gst_plugin_template_chain(GstPad * pad, GstObject * parent, GstBuffer * buf)
{
    GstPluginTemplate *filter;

    filter = GST_PLUGIN_TEMPLATE(parent);

    if (filter->silent == FALSE)
        g_print("I'm plugged, therefore I'm in.\n");

    // ここから
    {
        GstMapInfo info;

        gst_buffer_map(buf, &info, GST_MAP_READ);
        g_print("%s", info.data);
        gst_buffer_unmap(buf, &info);
    }
    // ここまで

    /* just push out the incoming buffer without touching it */
    return gst_pad_push(filter->srcpad, buf);
}

早く動かしたい気持ちはぐっとこらえつつ、メモ帳や echo コマンドなどで、inputというファイルを作りましょう。

$ echo "hoge" > input

さあ、やっと実行です！

$ GST_PLUGIN_PATH=`pwd` gst-launch-1.0.exe filesrc location=input ! plugin silent=true ! fakesink
Setting pipeline to PAUSED ...
Pipeline is PREROLLING ...
hoge
Pipeline is PREROLLED ...
Setting pipeline to PLAYING ...
New clock: GstSystemClock
Got EOS from element "pipeline0".
Execution ended after 0:00:00.000122404
Setting pipeline to PAUSED ...
Setting pipeline to READY ...
Setting pipeline to NULL ...
Freeing pipeline ...

filesrc から input を読み込み、plugin がそれをハンドルして、hoge と表示してくれましたね！

plugin の開発というと敷居が高い感じがしますが、簡単なものはたったこれだけで作れるのです。ぜひ遊んでみてください :)