markwingerd

# Create pads for the bin.
decode_pad = decode.get_static_pad('sink')
ghost_pad = gst.GhostPad('sink', decode_pad)
ghost_pad.set_active(True)
output_bin.add_pad(ghost_pad)

# Set media_source's audio sink.
media_source.set_property('audio-sink', output_bin)

# Set our pipeline state to Playing.

markwingerd

# Request pads to manually link the tee Element.
tee_audio_pad = tee.get_request_pad('src%d')
tee_wavescope_pad = tee.get_request_pad('src%d')
tee_file_pad = tee.get_request_pad('src%d')
print 'Obtained request pad %s for audio branch.'% tee_audio_pad.get_name()
print 'Obtained request pad %s for audio branch.'% tee_wavescope_pad.get_name()
print 'Obtained request pad %s for audio branch.'% tee_file_pad.get_name()

# Manually link the tee pads to the queue pads.
queue_audio_pad = audio_queue.get_static_pad('sink')

markwingerd

# Add elements to our bin
output_bin.add(decode, convert, tee, audio_queue, audio_sink, wavescope_queue,
    wavescope_visual, wavescope_convert, wavescope_sink, file_queue, 
    file_encode, file_sink)

# Link decodebin with autoconvert when its source pad has been created.
decode.connect('new-decoded-pad', on_new_decoded_pad)

# Callback function to link decodebin to autoconvert.
def on_new_decoded_pad(dbin, pad, islast):

markwingerd

import gst

# Create the pipeline and bin
output_bin = gst.Bin('output_bin')

# Create the elements.
media_source = gst.element_factory_make('playbin2', 'media_source')
decode = gst.element_factory_make('decodebin', 'decode')
convert = gst.element_factory_make('audioconvert', 'convert')
tee = gst.element_factory_make('tee', 'tee')

markwingerd

#!/usr/bin/env python
# -*- coding:utf-8 -*-

"""
GStreamer Tutorial 3: Splitting multimedia
In this tutorial we will stream a video from a website using 
the playbin2 element, split the audio into different element 
chains where we play the audio, show a waveform visualization
of the audio, and record the audio.

markwingerd

# Create pads for the bin.
decode_pad = decode.get_static_pad('sink')
ghost_pad = gst.GhostPad('sink', decode_pad)
ghost_pad.set_active(True)
output_bin.add_pad(ghost_pad)

# Set media_source's video sink.
media_source.set_property('video-sink', output_bin)

# Set our pipeline state to Playing.

markwingerd

# Add elements to our bin
output_bin.add(decode, convert, solarize, video_sink)

# Link decodebin with autoconvert when its source pad has been created.
decode.connect('new-decoded-pad', on_new_decoded_pad)

# Callback function to link decodebin to autoconvert.
def on_new_decoded_pad(dbin, pad, islast):
    decode = pad.get_parent()
    pipeline = decode.get_parent()

markwingerd

import gst

# Create the pipeline and bin
output_bin = gst.Bin('output_bin')

# Create the elements.
media_source = gst.element_factory_make('playbin2', 'media_source')
decode = gst.element_factory_make('decodebin', 'decode')
convert = gst.element_factory_make('autoconvert', 'convert')
solarize = gst.element_factory_make('solarize', 'solarize')

markwingerd

#!/usr/bin/env python
# -*- coding:utf-8 -*-

"""
GStreamer Tutorial 2: Playbin2
In this tutorial we will stream a video from a website using 
the playbin2 element, change the video using a solarize element
and output the video.  The audio is played by playbin2.

            ---------------------output_bin--------------------------

markwingerd

# Set our pipelines state to Playing.
pipeline.set_state(gst.STATE_PLAYING)

# Wait until error or EOS.
bus = pipeline.get_bus()
msg = bus.timed_pop_filtered(gst.CLOCK_TIME_NONE,
    gst.MESSAGE_ERROR | gst.MESSAGE_EOS)
print msg

# Free resources.