python.pipeparts Namespace Reference

pipeparts module More...

Classes
class	AppSync
class	connect_appsink_dump_dot
class	framecpp_channeldemux_check_segments
class	framecpp_channeldemux_set_units
class	src_deferred_link
	A class that manages the task of watching for and connecting to new source pads by name. More...

Functions
def	mkgeneric (pipeline, src, elem_type_name, properties)
def	framecpp_filesink_ldas_path_handler (elem, pspec, outpath, dir_digits)
def	framecpp_filesink_cache_entry_from_mfs_message (message)
def	mkchannelgram (pipeline, src, properties)
def	mkspectrumplot (pipeline, src, properties)
def	mkhistogram (pipeline, src)
def	mksegmentsrc (pipeline, segment_list, blocksize=4096 *1 *1, invert_output=False)
	Adds a lal_segmentsrc element to a pipeline with useful default properties. More...
def	mklalcachesrc (pipeline, location, use_mmap=True, properties)
	Adds a lal_cachesrc element to a pipeline with useful default properties. More...
def	mklvshmsrc (pipeline, shm_name, properties)
def	mkframexmitsrc (pipeline, multicast_group, port, properties)
def	mkigwdparse (pipeline, src, properties)
def	mkuridecodebin (pipeline, uri, caps="application/x-igwd-frame, framed=true", properties)
	Adds a uridecodebin element to a pipeline with useful default properties. More...
def	mkframecppchanneldemux (pipeline, src, properties)
def	mkframecppchannelmux (pipeline, channel_src_map, units=None, seglists=None, properties)
def	mkframecppfilesink (pipeline, src, message_forward=True, properties)
def	mkmultifilesink (pipeline, src, next_file=0, sync=False, async=False, properties)
	Adds a multifilesink element to a pipeline with useful default properties. More...
def	mkndssrc (pipeline, host, instrument, channel_name, channel_type, blocksize=16384 *8 *1, port=31200)
def	mkcapsfilter (pipeline, src, caps)
	Adds a capsfilter element to a pipeline with useful default properties. More...
def	mkcapssetter (pipeline, src, caps, properties)
	Adds a capssetter element to a pipeline with useful default properties. More...
def	mkstatevector (pipeline, src, properties)
	Adds a lal_statevector element to a pipeline with useful default properties. More...
def	mktaginject (pipeline, src, tags)
	Adds a taginject element to a pipeline with useful default properties. More...
def	mkaudiotestsrc (pipeline, properties)
	Adds a audiotestsrc element to a pipeline with useful default properties. More...
def	mkfakesrc (pipeline, instrument, channel_name, blocksize=None, volume=1e-20, is_live=False, wave=9, rate=16384, properties)
	see documentation for mktaginject() mkcapsfilter() and mkaudiotestsrc() More...
def	mkfirfilter (pipeline, src, kernel, latency, properties)
	Adds a audiofirfilter element to a pipeline with useful default properties. More...
def	mkiirfilter (pipeline, src, a, b)
	Adds a audioiirfilter element to a pipeline with useful default properties. More...
def	mkshift (pipeline, src, properties)
	Adds a lal_shift element to a pipeline with useful default properties. More...
def	mkfakeLIGOsrc (pipeline, location=None, instrument=None, channel_name=None, blocksize=16384 *8 *1)
def	mkfakeadvLIGOsrc (pipeline, location=None, instrument=None, channel_name=None, blocksize=16384 *8 *1)
def	mkfakeadvvirgosrc (pipeline, location=None, instrument=None, channel_name=None, blocksize=16384 *8 *1)
def	mkprogressreport (pipeline, src, name)
	Adds a progress_report element to a pipeline with useful default properties. More...
def	mkinjections (pipeline, src, filename)
	Adds a lal_simulation element to a pipeline with useful default properties. More...
def	mkaudiochebband (pipeline, src, lower_frequency, upper_frequency, poles=8)
	Adds a audiochebband element to a pipeline with useful default properties. More...
def	mkaudiocheblimit (pipeline, src, cutoff, mode=0, poles=8, type=1, ripple=0.25)
	Adds a audiocheblimit element to a pipeline with useful default properties. More...
def	mkaudioamplify (pipeline, src, amplification)
	Adds a audioamplify element to a pipeline with useful default properties. More...
def	mkaudioundersample (pipeline, src)
	Adds a lal_audioundersample element to a pipeline with useful default properties. More...
def	mkresample (pipeline, src, properties)
	Adds a audioresample element to a pipeline with useful default properties. More...
def	mkinterpolator (pipeline, src, properties)
	Adds a lal_interpolator element to a pipeline with useful default properties. More...
def	mkwhiten (pipeline, src, psd_mode=0, zero_pad=0, fft_length=8, average_samples=64, median_samples=7, properties)
	Adds a lal_whiten element to a pipeline with useful default properties. More...
def	mktee (pipeline, src)
	Adds a tee element to a pipeline with useful default properties. More...
def	mkadder (pipeline, srcs, sync=True, mix_mode="sum", properties)
	Adds a lal_adder element to a pipeline configured for synchronous "sum" mode mixing. More...
def	mkmultiplier (pipeline, srcs, sync=True, mix_mode="product", properties)
	Adds a lal_adder element to a pipeline configured for synchronous "product" mode mixing. More...
def	mkqueue (pipeline, src, properties)
	Adds a queue element to a pipeline with useful default properties. More...
def	mkdrop (pipeline, src, drop_samples=0)
	Adds a lal_whiten element to a pipeline with useful default properties. More...
def	mknofakedisconts (pipeline, src, silent=True)
	Adds a lal_nofakedisconts element to a pipeline with useful default properties. More...
def	mkfirbank (pipeline, src, latency=None, fir_matrix=None, time_domain=None, block_stride=None)
	Adds a lal_firbank element to a pipeline with useful default properties. More...
def	mktdwhiten (pipeline, src, latency=None, kernel=None, taper_length=None)
def	mkiirbank (pipeline, src, a1, b0, delay, name=None)
def	mkcudaiirbank (pipeline, src, a1, b0, delay, name=None)
def	mkcudamultiratespiir (pipeline, src, bank_struct, bank_id=0, name=None)
def	mktrim (pipeline, src, initial_offset=None, final_offset=None, inverse=None)
def	mkmean (pipeline, src, properties)
def	mkabs (pipeline, src, properties)
def	mkpow (pipeline, src, properties)
def	mkreblock (pipeline, src, properties)
	Adds a lal_reblock element to a pipeline with useful default properties. More...
def	mksumsquares (pipeline, src, weights=None)
	Adds a lal_sumsquares element to a pipeline with useful default properties. More...
def	mkgate (pipeline, src, threshold=None, control=None, properties)
	Adds a lal_gate element to a pipeline with useful default properties. More...
def	mkbitvectorgen (pipeline, src, bit_vector, properties)
def	mkmatrixmixer (pipeline, src, matrix=None)
	Adds a lal_matrixmixer element to a pipeline with useful default properties. More...
def	mktogglecomplex (pipeline, src)
	Adds a lal_togglecomplex element to a pipeline with useful default properties. More...
def	mkautochisq (pipeline, src, autocorrelation_matrix=None, mask_matrix=None, latency=0, snr_thresh=0)
	Adds a lal_autochisq element to a pipeline with useful default properties. More...
def	mkfakesink (pipeline, src)
	Adds a fakesink element to a pipeline with useful default properties. More...
def	mkfilesink (pipeline, src, filename, sync=False, async=False)
	Adds a filesink element to a pipeline with useful default properties. More...
def	mknxydumpsink (pipeline, src, filename, segment=None)
	Adds a lal_nxydump element to a pipeline with useful default properties. More...
def	mknxydumpsinktee (pipeline, src, args, properties)
def	mkblcbctriggergen (pipeline, snr, chisq, template_bank_filename, snr_threshold, sigmasq)
def	mktriggergen (pipeline, snr, chisq, template_bank_filename, snr_threshold, sigmasq)
def	mktriggerxmlwritersink (pipeline, src, filename)
def	mkwavenc (pipeline, src)
	Adds a wavenc element to a pipeline with useful default properties. More...
def	mkvorbisenc (pipeline, src)
	Adds a vorbisenc element to a pipeline with useful default properties. More...
def	mkcolorspace (pipeline, src)
def	mktheoraenc (pipeline, src, properties)
def	mkmpeg4enc (pipeline, src, properties)
def	mkoggmux (pipeline, src)
def	mkavimux (pipeline, src)
def	mkaudioconvert (pipeline, src, caps_string=None)
	Adds a audioconvert element to a pipeline with useful default properties. More...
def	mkaudiorate (pipeline, src, properties)
	Adds a audiorate element to a pipeline with useful default properties. More...
def	mkflacenc (pipeline, src, quality=0, properties)
	Adds a flacenc element to a pipeline with useful default properties. More...
def	mkogmvideosink (pipeline, videosrc, filename, audiosrc=None, verbose=False)
def	mkvideosink (pipeline, src)
def	mkautoaudiosink (pipeline, src)
	Adds a autoaudiosink element to a pipeline with useful default properties. More...
def	mkplaybacksink (pipeline, src, amplification=0.1)
def	mkdeglitcher (pipeline, src, segment_list)
def	mkappsink (pipeline, src, max_buffers=1, drop=False, sync=False, async=False, properties)
	Adds a appsink element to a pipeline with useful default properties. More...
def	mkchecktimestamps (pipeline, src, name=None, silent=True, timestamp_fuzz=1)
def	mkpeak (pipeline, src, n)
	Adds a lal_peak element to a pipeline with useful default properties. More...
def	mkitac (pipeline, src, n, bank, autocorrelation_matrix=None, mask_matrix=None, snr_thresh=0, sigmasq=None)
def	mktrigger (pipeline, src, n, autocorrelation_matrix=None, mask_matrix=None, snr_thresh=0, sigmasq=None, max_snr=False)
def	mklatency (pipeline, src, name=None, silent=False)
def	mklhocoherentnull (pipeline, H1src, H2src, H1_impulse, H1_latency, H2_impulse, H2_latency, srate)
def	mkcomputegamma (pipeline, dctrl, exc, cos, sin, properties)
def	mkbursttriggergen (pipeline, src, properties)
def	mkodctodqv (pipeline, src, properties)
def	mktcpserversink (pipeline, src, properties)
def	audioresample_variance_gain (quality, num, den)
def	write_dump_dot (pipeline, filestem, verbose=False)

Variables
string	BYTE_ORDER = "LE"

Detailed Description

pipeparts module

Function Documentation

audioresample_variance_gain()

def python.pipeparts.audioresample_variance_gain	(		quality,
			num,
			den
	)

Calculate the output gain of GStreamer's stock audioresample element.

The audioresample element has a frequency response of unity "almost" all the
way up the Nyquist frequency.  However, for an input of unit variance
Gaussian noise, the output will have a variance very slighly less than 1.
The return value is the variance that the filter will produce for a given
"quality" setting and sample rate.

@param den The denomenator of the ratio of the input and output sample rates
@param num The numerator of the ratio of the input and output sample rates
@return The variance of the output signal for unit variance input

The following example shows how to apply the correction factor using an
audioamplify element.

>>> from gstlal.pipeutil import *
>>> from gstlal.pipeparts import audioresample_variance_gain
>>> from gstlal import pipeio
>>> import numpy
>>> nsamples = 2 ** 17
>>> num = 2
>>> den = 1
>>> def handoff_handler(element, buffer, pad, (quality, filt_len, num, den)):
...     out_latency = numpy.ceil(float(den) / num * filt_len)
...     buf = pipeio.array_from_audio_buffer(buffer).flatten()
...     std = numpy.std(buf[out_latency:-out_latency])
...     print "quality=%2d, filt_len=%3d, num=%d, den=%d, stdev=%.2f" % (
...         quality, filt_len, num, den, std)
...
>>> for quality in range(11):
...     pipeline = Gst.Pipeline()
...     correction = 1/numpy.sqrt(audioresample_variance_gain(quality, num, den))
...     elems = mkelems_in_bin(pipeline,
...         ('audiotestsrc', {'wave':'gaussian-noise','volume':1}),
...         ('capsfilter', {'caps':Gst.Caps.from_string('audio/x-raw,format=F64LE,rate=%d' % num)}),
...         ('audioresample', {'quality':quality}),
...         ('capsfilter', {'caps':Gst.Caps.from_string('audio/x-raw,width=F64LE,rate=%d' % den)}),
...         ('audioamplify', {'amplification':correction,'clipping-method':'none'}),
...         ('fakesink', {'signal-handoffs':True, 'num-buffers':1})
...     )
...     filt_len = elems[2].get_property('filter-length')
...     elems[0].set_property('samplesperbuffer', 2 * filt_len + nsamples)
...     if elems[-1].connect_after('handoff', handoff_handler, (quality, filt_len, num, den)) < 1:
...         raise RuntimeError
...     try:
...         if pipeline.set_state(Gst.State.PLAYING) is not Gst.State.CHANGE_ASYNC:
...             raise RuntimeError
...         if not pipeline.get_bus().poll(Gst.MessageType.EOS, -1):
...             raise RuntimeError
...     finally:
...         if pipeline.set_state(Gst.State.NULL) is not Gst.StateChangeReturn.SUCCESS:
...             raise RuntimeError
...
quality= 0, filt_len=  8, num=2, den=1, stdev=1.00
quality= 1, filt_len= 16, num=2, den=1, stdev=1.00
quality= 2, filt_len= 32, num=2, den=1, stdev=1.00
quality= 3, filt_len= 48, num=2, den=1, stdev=1.00
quality= 4, filt_len= 64, num=2, den=1, stdev=1.00
quality= 5, filt_len= 80, num=2, den=1, stdev=1.00
quality= 6, filt_len= 96, num=2, den=1, stdev=1.00
quality= 7, filt_len=128, num=2, den=1, stdev=1.00
quality= 8, filt_len=160, num=2, den=1, stdev=1.00
quality= 9, filt_len=192, num=2, den=1, stdev=1.00
quality=10, filt_len=256, num=2, den=1, stdev=1.00

Definition at line 999 of file __init__.py.

framecpp_filesink_cache_entry_from_mfs_message()

def python.pipeparts.framecpp_filesink_cache_entry_from_mfs_message

(

message

)

Translate an element message posted by the multifilesink element
inside a framecpp_filesink bin into a lal.utils.CacheEntry object
describing the file being written by the multifilesink element.

Definition at line 291 of file __init__.py.

framecpp_filesink_ldas_path_handler()

def python.pipeparts.framecpp_filesink_ldas_path_handler	(		elem,
			pspec,
			outpath,
			dir_digits
	)

Example:

>>> filesinkelem.connect("notify::timestamp", framecpp_filesink_ldas_path_handler, (".", 5))

Definition at line 268 of file __init__.py.

mkadder()

def python.pipeparts.mkadder	(		pipeline,
			srcs,
			sync = True,
			mix_mode = "sum",
			properties
	)

Adds a lal_adder element to a pipeline configured for synchronous "sum" mode mixing.

Definition at line 522 of file __init__.py.

mkappsink()

def python.pipeparts.mkappsink	(		pipeline,
			src,
			max_buffers = 1,
			drop = False,
			sync = False,
			async = False,
			properties
	)

Adds a appsink element to a pipeline with useful default properties.

Definition at line 805 of file __init__.py.

mkaudioamplify()

def python.pipeparts.mkaudioamplify	(		pipeline,
			src,
			amplification
	)

Adds a audioamplify element to a pipeline with useful default properties.

Definition at line 492 of file __init__.py.

mkaudiochebband()

def python.pipeparts.mkaudiochebband	(		pipeline,
			src,
			lower_frequency,
			upper_frequency,
			poles = 8
	)

Adds a audiochebband element to a pipeline with useful default properties.

Definition at line 482 of file __init__.py.

mkaudiocheblimit()

def python.pipeparts.mkaudiocheblimit	(		pipeline,
			src,
			cutoff,
			mode = 0,
			poles = 8,
			type = 1,
			ripple = 0.25
	)

Adds a audiocheblimit element to a pipeline with useful default properties.

Definition at line 487 of file __init__.py.

mkaudioconvert()

def python.pipeparts.mkaudioconvert	(		pipeline,
			src,
			caps_string = None
	)

Adds a audioconvert element to a pipeline with useful default properties.

Definition at line 744 of file __init__.py.

mkaudiorate()

def python.pipeparts.mkaudiorate	(		pipeline,
			src,
			properties
	)

Adds a audiorate element to a pipeline with useful default properties.

Definition at line 752 of file __init__.py.

mkaudiotestsrc()

def python.pipeparts.mkaudiotestsrc	(		pipeline,
			properties
	)

Adds a audiotestsrc element to a pipeline with useful default properties.

Definition at line 419 of file __init__.py.

mkaudioundersample()

def python.pipeparts.mkaudioundersample	(		pipeline,
			src
	)

Adds a lal_audioundersample element to a pipeline with useful default properties.

Definition at line 497 of file __init__.py.

mkautoaudiosink()

def python.pipeparts.mkautoaudiosink	(		pipeline,
			src
	)

Adds a autoaudiosink element to a pipeline with useful default properties.

Definition at line 778 of file __init__.py.

mkautochisq()

def python.pipeparts.mkautochisq	(		pipeline,
			src,
			autocorrelation_matrix = None,
			mask_matrix = None,
			latency = 0,
			snr_thresh = 0
	)

Adds a lal_autochisq element to a pipeline with useful default properties.

Definition at line 655 of file __init__.py.

mkcapsfilter()

def python.pipeparts.mkcapsfilter	(		pipeline,
			src,
			caps
	)

Adds a capsfilter element to a pipeline with useful default properties.

Definition at line 399 of file __init__.py.

mkcapssetter()

def python.pipeparts.mkcapssetter	(		pipeline,
			src,
			caps,
			properties
	)

Adds a capssetter element to a pipeline with useful default properties.

Definition at line 404 of file __init__.py.

mkdrop()

def python.pipeparts.mkdrop	(		pipeline,
			src,
			drop_samples = 0
	)

Adds a lal_whiten element to a pipeline with useful default properties.

Definition at line 541 of file __init__.py.

mkfakesink()

def python.pipeparts.mkfakesink	(		pipeline,
			src
	)

Adds a fakesink element to a pipeline with useful default properties.

Definition at line 669 of file __init__.py.

mkfakesrc()

def python.pipeparts.mkfakesrc	(		pipeline,
			instrument,
			channel_name,
			blocksize = None,
			volume = 1e-20,
			is_live = False,
			wave = 9,
			rate = 16384,
			properties
	)

see documentation for mktaginject() mkcapsfilter() and mkaudiotestsrc()

Definition at line 424 of file __init__.py.

mkfilesink()

def python.pipeparts.mkfilesink	(		pipeline,
			src,
			filename,
			sync = False,
			async = False
	)

Adds a filesink element to a pipeline with useful default properties.

Definition at line 674 of file __init__.py.

mkfirbank()

def python.pipeparts.mkfirbank	(		pipeline,
			src,
			latency = None,
			fir_matrix = None,
			time_domain = None,
			block_stride = None
	)

Adds a lal_firbank element to a pipeline with useful default properties.

Definition at line 551 of file __init__.py.

mkfirfilter()

def python.pipeparts.mkfirfilter	(		pipeline,
			src,
			kernel,
			latency,
			properties
	)

Adds a audiofirfilter element to a pipeline with useful default properties.

Definition at line 433 of file __init__.py.

mkflacenc()

def python.pipeparts.mkflacenc	(		pipeline,
			src,
			quality = 0,
			properties
	)

Adds a flacenc element to a pipeline with useful default properties.

Definition at line 757 of file __init__.py.

mkgate()

def python.pipeparts.mkgate	(		pipeline,
			src,
			threshold = None,
			control = None,
			properties
	)

Adds a lal_gate element to a pipeline with useful default properties.

Definition at line 624 of file __init__.py.

mkiirfilter()

def python.pipeparts.mkiirfilter	(		pipeline,
			src,
			a,
			b
	)

Adds a audioiirfilter element to a pipeline with useful default properties.

Definition at line 439 of file __init__.py.

mkinjections()

def python.pipeparts.mkinjections	(		pipeline,
			src,
			filename
	)

Adds a lal_simulation element to a pipeline with useful default properties.

Definition at line 477 of file __init__.py.

mkinterpolator()

def python.pipeparts.mkinterpolator	(		pipeline,
			src,
			properties
	)

Adds a lal_interpolator element to a pipeline with useful default properties.

Definition at line 507 of file __init__.py.

mklalcachesrc()

def python.pipeparts.mklalcachesrc	(		pipeline,
			location,
			use_mmap = True,
			properties
	)

Adds a lal_cachesrc element to a pipeline with useful default properties.

Definition at line 338 of file __init__.py.

mkmatrixmixer()

def python.pipeparts.mkmatrixmixer	(		pipeline,
			src,
			matrix = None
	)

Adds a lal_matrixmixer element to a pipeline with useful default properties.

Definition at line 642 of file __init__.py.

mkmultifilesink()

def python.pipeparts.mkmultifilesink	(		pipeline,
			src,
			next_file = 0,
			sync = False,
			async = False,
			properties
	)

Adds a multifilesink element to a pipeline with useful default properties.

Definition at line 388 of file __init__.py.

mkmultiplier()

def python.pipeparts.mkmultiplier	(		pipeline,
			srcs,
			sync = True,
			mix_mode = "product",
			properties
	)

Adds a lal_adder element to a pipeline configured for synchronous "product" mode mixing.

Definition at line 531 of file __init__.py.

mknofakedisconts()

def python.pipeparts.mknofakedisconts	(		pipeline,
			src,
			silent = True
	)

Adds a lal_nofakedisconts element to a pipeline with useful default properties.

Definition at line 546 of file __init__.py.

mknxydumpsink()

def python.pipeparts.mknxydumpsink	(		pipeline,
			src,
			filename,
			segment = None
	)

Adds a lal_nxydump element to a pipeline with useful default properties.

Definition at line 679 of file __init__.py.

mkpeak()

def python.pipeparts.mkpeak	(		pipeline,
			src,
			n
	)

Adds a lal_peak element to a pipeline with useful default properties.

Definition at line 934 of file __init__.py.

mkprogressreport()

def python.pipeparts.mkprogressreport	(		pipeline,
			src,
			name
	)

Adds a progress_report element to a pipeline with useful default properties.

Definition at line 472 of file __init__.py.

mkqueue()

def python.pipeparts.mkqueue	(		pipeline,
			src,
			properties
	)

Adds a queue element to a pipeline with useful default properties.

Definition at line 536 of file __init__.py.

mkreblock()

def python.pipeparts.mkreblock	(		pipeline,
			src,
			properties
	)

Adds a lal_reblock element to a pipeline with useful default properties.

Definition at line 611 of file __init__.py.

mkresample()

def python.pipeparts.mkresample	(		pipeline,
			src,
			properties
	)

Adds a audioresample element to a pipeline with useful default properties.

Definition at line 502 of file __init__.py.

mksegmentsrc()

def python.pipeparts.mksegmentsrc	(		pipeline,
			segment_list,
			blocksize = 4096 * 1 * 1,
			invert_output = False
	)

Adds a lal_segmentsrc element to a pipeline with useful default properties.

Definition at line 331 of file __init__.py.

mkshift()

def python.pipeparts.mkshift	(		pipeline,
			src,
			properties
	)

Adds a lal_shift element to a pipeline with useful default properties.

Definition at line 446 of file __init__.py.

mkstatevector()

def python.pipeparts.mkstatevector	(		pipeline,
			src,
			properties
	)

Adds a lal_statevector element to a pipeline with useful default properties.

Definition at line 409 of file __init__.py.

mksumsquares()

def python.pipeparts.mksumsquares	(		pipeline,
			src,
			weights = None
	)

Adds a lal_sumsquares element to a pipeline with useful default properties.

Definition at line 616 of file __init__.py.

mktaginject()

def python.pipeparts.mktaginject	(		pipeline,
			src,
			tags
	)

Adds a taginject element to a pipeline with useful default properties.

Definition at line 414 of file __init__.py.

mktee()

def python.pipeparts.mktee	(		pipeline,
			src
	)

Adds a tee element to a pipeline with useful default properties.

Definition at line 517 of file __init__.py.

mktogglecomplex()

def python.pipeparts.mktogglecomplex	(		pipeline,
			src
	)

Adds a lal_togglecomplex element to a pipeline with useful default properties.

Definition at line 650 of file __init__.py.

mkuridecodebin()

def python.pipeparts.mkuridecodebin	(		pipeline,
			uri,
			caps = "application/x-igwd-frame,
			framed = true",
			properties
	)

Adds a uridecodebin element to a pipeline with useful default properties.

Definition at line 355 of file __init__.py.

mkvorbisenc()

def python.pipeparts.mkvorbisenc	(		pipeline,
			src
	)

Adds a vorbisenc element to a pipeline with useful default properties.

Definition at line 719 of file __init__.py.

mkwavenc()

def python.pipeparts.mkwavenc	(		pipeline,
			src
	)

Adds a wavenc element to a pipeline with useful default properties.

Definition at line 714 of file __init__.py.

mkwhiten()

def python.pipeparts.mkwhiten	(		pipeline,
			src,
			psd_mode = 0,
			zero_pad = 0,
			fft_length = 8,
			average_samples = 64,
			median_samples = 7,
			properties
	)

Adds a lal_whiten element to a pipeline with useful default properties.

Definition at line 512 of file __init__.py.

write_dump_dot()

def python.pipeparts.write_dump_dot	(		pipeline,
			filestem,
			verbose = False
	)

This function needs the environment variable GST_DEBUG_DUMP_DOT_DIR
to be set.   The filename will be

os.path.join($GST_DEBUG_DUMP_DOT_DIR, filestem + ".dot")

If verbose is True, a message will be written to stderr.

Definition at line 1109 of file __init__.py.