node-gst/player.cpp at master · mexxik/node-gst · GitHub

1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
66
67
68
69
70
71
72
73
74
75
76
77
78
79
80
81
82
83
84
85
86
87
88
89
90
91
92
93
94
95
96
97
98
99
100
101
102
103
104
105
106
107
108
109
110
111
112
#include <gst/gst.h>
#include <glib.h>


static gboolean
bus_call(GstBus     *bus,
         GstMessage *msg,
         gpointer    data)
{
    GMainLoop *loop = (GMainLoop *) data;
    switch (GST_MESSAGE_TYPE(msg)) {
        case GST_MESSAGE_EOS:
            g_print("EOS\n");
            g_main_loop_quit(loop);
            break;

        case GST_MESSAGE_ERROR: {
            gchar  *debug;
            GError *error;

            gst_message_parse_error(msg, &error, &debug);
            g_free(debug);

            g_printerr("error: %s\n", error->message);
            g_error_free(error);

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

    return TRUE;
}

static void
on_pad_added(GstElement *element,
             GstPad     *pad,
             gpointer    data)
{
    GstPad *sinkpad;
    GstElement *decoder = (GstElement *) data;

    g_print("dynamic pad created, linking demuxer/decoder\n");

    sinkpad = gst_element_get_static_pad(decoder, "sink");
    gst_pad_link(pad, sinkpad);

    gst_object_unref(sinkpad);
}


int main(int    argc,
         char  *argv[])
{
    GMainLoop *loop;

    GstElement *pipeline, *source, *demuxer, *decoder, *conv, *sink;
    GstBus *bus;
    guint  bus_watch_id;

    gst_init(&argc, &argv);

    loop = g_main_loop_new(NULL, FALSE);

    if (argc != 2) {
        g_printerr("Usage: %s <Ogg/Vobris filename> \n", argv[0]);
        return -1;
    }

    pipeline    = gst_pipeline_new("audio-player");
    source      = gst_element_factory_make("filesrc", "file-source");
    demuxer     = gst_element_factory_make("oggdemux", "ogg-demuxer");
    decoder     = gst_element_factory_make("vorbisdec", "vobris-decoder");
    conv        = gst_element_factory_make("audioconvert", "converter");
    sink        = gst_element_factory_make("autoaudiosink", "audio_sink");

    if (!pipeline || !source || !demuxer || !decoder || !conv || !sink) {
        g_printerr("can't create element");
        return -1;
    }

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

    bus = gst_pipeline_get_bus(GST_PIPELINE(pipeline));
    bus_watch_id = gst_bus_add_watch(bus, bus_call, loop);
    gst_object_unref(bus);

    gst_bin_add_many(GST_BIN(pipeline), source, demuxer, decoder, conv, sink, NULL);

    gst_element_link(source, demuxer);
    gst_element_link_many(decoder, conv, sink, NULL);
    g_signal_connect(demuxer, "pad-added", G_CALLBACK(on_pad_added), decoder);

    g_print("playing %s\n", argv[1]);
    gst_element_set_state(pipeline, GST_STATE_PLAYING);

    g_print("running...\n");
    g_main_loop_run(loop);

    g_print("returned, stopping\n");
    gst_element_set_state(pipeline, GST_STATE_NULL);

    g_print ("Deleting pipeline\n");
    gst_object_unref (GST_OBJECT (pipeline));
    g_source_remove (bus_watch_id);
    g_main_loop_unref (loop);

    return 0;
}