[gst-devel] Save a stream to different file every hour

[Juraj Kubelka]

On Thu, Jun 18, 2009 at 8:46 AM, Arnout Vandecappelle <arnout at mind.be>wrote:

> On Wednesday 17 June 2009 10:29:43 Viraj Karandikar wrote:
> > And after every hour you will have to: pause the pipeline, create new
> > filesink, disconnect old filesink, connect new filesink and close old
> > filesink.
>
>  Actually, no.  Pausing the pipeline will not (immediately) stop the
> threads
> in the source and queues.  In addition, once it's paused any new data
> coming
> in on the live source will be dropped until it plays again, which probably
> is
> not the intention.
>
>  Instead, you have to use blocking.  Below there's a piece of code that I
> use.
> See also docs/design/part-block.txt.  There should be high-level API for
> that, but nobody has bothered up to now to write it.
>
>  You need to replace the decoder and muxer as well, so the proper headers
> are
> created in the new file.  To simplify all that I put it in a bin (which can
> be unreffed as a whole).
>
> > You can do above things in another independent thread which will
> > just wait till 1 hour is complete.
>
>  Or you can use g_timeout_add_seconds (3600, ...) in your main loop.
>
>  Regards,
>  Arnout
>
> --
>
> static gboolean destroy_bin_cb (gpointer user_data)
> {
>    GstElement *oldbin = user_data;
>
>    log_message("Destroying old bin.\n");
>    if (pipeline)
>    {
>        gst_element_set_state (oldbin, GST_STATE_NULL);
>        gst_bin_remove (GST_BIN(pipeline), oldbin);
>    }
>    return FALSE;
> }
>
>
> static void replace_filesink_blocked_cb (GstPad *pad, gboolean blocked,
> gpointer user_data)
> {
>    if (blocked)
>    {
>        GstElement *oldbin;
>        GstPad *sinkpad;
>
>        log_message("Blocked filesink queue.\n");
>        g_static_rec_mutex_lock(&mutex);
>        log_message("Locked.\n");
>        oldbin = filesinkbin;
>        sinkpad = gst_element_get_static_pad(oldbin, "sink");
>        if (!sinkpad)
>        {
>            log_message("replace_filesink_blocked_cb: oldbin doesn't have
> sink
> pad.\n");
>            goto fail;
>        }
>        gst_pad_unlink(queuesrcpad, sinkpad);
>        log_message("Unlinked.\n");
>
>        /* Finalize the old tail. */
>        /* Sending EOS should be done from here (we're in the queue thread).
> */
>        gst_pad_send_event(sinkpad, gst_event_new_eos());
>        log_message("Sent event.\n");
>
>        log_message("Checked sinks.\n");
>        /* Setting state should be done from the main thread. Do it before
> the
>           pipeline has been set to PLAYING - implicitly, because that is
> also
>           done in an idle callback, but one that is started after this one.
>        */
>        g_idle_add(destroy_bin_cb, oldbin);
>
>        create_filesink_tail();
>        log_message("Created filesink.\n");
>        g_static_rec_mutex_unlock(&mutex);
>        log_message("Unlocked mutex.\n");
>
>        /* And unblock again. */
>        gst_pad_set_blocked_async(queuesrcpad, FALSE,
> replace_filesink_blocked_cb, NULL);
>
>        log_message("Done replacing filesink.\n");
>    }
>    else
>    {
>        log_message("Unblocked filesink queue.\n");
>    }
>    return;
>
> fail:
>    pipeline_terminate_async();
>    g_static_rec_mutex_unlock(&mutex);
> }
>
> static void replace_filesink()
> {
>    if (queuesrcpad == NULL)
>        log_message("replace_filesink while no queuesrcpad yet, waiting for
> it
> to appear.\n");
>    else
>        gst_pad_set_blocked_async(queuesrcpad, TRUE,
> replace_filesink_blocked_cb, NULL);
> }
>
>
Hi,

thank you a lot for your help. I did it in Python and it seams it works.
Source code is on pastebin: http://pastebin.com/f3a80ed09
(pipelineholder.py<http://pastebin.com/f3a80ed09(pipelineholder.py>)
and http://pastebin.com/f4ee27d6d (pipelinemanager). Any comments are
appreciated.

Best regards,
Jura
-------------- next part --------------
An HTML attachment was scrubbed...
URL: <http://lists.freedesktop.org/archives/gstreamer-devel/attachments/20090623/d6e3fcdd/attachment.htm>