Struct gstreamer_check::harness::Harness [−][src]
pub struct Harness(_);
Expand description
Harness
is meant to make writing unit test for GStreamer much easier.
It can be thought of as a way of treating a gst::Element
as a black box,
deterministically feeding it data, and controlling what data it outputs.
The basic structure of Harness
is two “floating” GstPads
that connect
to the harnessed gst::Element
src and sink GstPads
like so:
#include <gst/gst.h>
#include <gst/check/gstharness.h>
GstHarness *h;
GstBuffer *in_buf;
GstBuffer *out_buf;
// attach the harness to the src and sink pad of GstQueue
h = gst_harness_new ("queue");
// we must specify a caps before pushing buffers
gst_harness_set_src_caps_str (h, "mycaps");
// create a buffer of size 42
in_buf = gst_harness_create_buffer (h, 42);
// push the buffer into the queue
gst_harness_push (h, in_buf);
// pull the buffer from the queue
out_buf = gst_harness_pull (h);
// validate the buffer in is the same as buffer out
fail_unless (in_buf == out_buf);
// cleanup
gst_buffer_unref (out_buf);
gst_harness_teardown (h);
]|
Another main feature of the #GstHarness is its integration with the
#GstTestClock. Operating the #GstTestClock can be very challenging, but
#GstHarness simplifies some of the most desired actions a lot, like wanting
to manually advance the clock while at the same time releasing a #GstClockID
that is waiting, with functions like gst_harness_crank_single_clock_wait().
#GstHarness also supports sub-harnesses, as a way of generating and
validating data. A sub-harness is another #GstHarness that is managed by
the "parent" harness, and can either be created by using the standard
gst_harness_new type functions directly on the (GstHarness *)->src_harness,
or using the much more convenient gst_harness_add_src() or
gst_harness_add_sink_parse(). If you have a decoder-element you want to test,
(like vp8dec) it can be very useful to add a src-harness with both a
src-element (videotestsrc) and an encoder (vp8enc) to feed the decoder data
with different configurations, by simply doing:
|[<!-- language="C" -->
GstHarness * h = gst_harness_new (h, "vp8dec");
gst_harness_add_src_parse (h, "videotestsrc is-live=1 ! vp8enc", TRUE);
and then feeding it data with:
gst_harness_push_from_src (h);
Implementations
pub fn add_element_full<P: IsA<Element>>(
&mut self,
element: &P,
hsrc: Option<&StaticPadTemplate>,
element_sinkpad_name: Option<&str>,
hsink: Option<&StaticPadTemplate>,
element_srcpad_name: Option<&str>
)
[src]
pub fn add_element_full<P: IsA<Element>>(
&mut self,
element: &P,
hsrc: Option<&StaticPadTemplate>,
element_sinkpad_name: Option<&str>,
hsink: Option<&StaticPadTemplate>,
element_srcpad_name: Option<&str>
)
[src]Adds a gst::Element
to an empty Harness
MT safe.
element
a gst::Element
to add to the harness (transfer none)
hsrc
a gst::StaticPadTemplate
describing the harness srcpad.
None
will not create a harness srcpad.
element_sinkpad_name
a gchar
with the name of the element
sinkpad that is then linked to the harness srcpad. Can be a static or request
or a sometimes pad that has been added. None
will not get/request a sinkpad
from the element. (Like if the element is a src.)
hsink
a gst::StaticPadTemplate
describing the harness sinkpad.
None
will not create a harness sinkpad.
element_srcpad_name
a gchar
with the name of the element
srcpad that is then linked to the harness sinkpad, similar to the
element_sinkpad_name
.
Parses the launchline
and puts that in a gst::Bin
,
and then attches the supplied Harness
to the bin.
MT safe.
launchline
a gchar
describing a gst-launch type line
pub fn add_probe<F>(
&mut self,
element_name: &str,
pad_name: &str,
mask: PadProbeType,
func: F
) where
F: Fn(&Pad, &mut PadProbeInfo<'_>) -> PadProbeReturn + Send + Sync + 'static,
[src]
pub fn add_probe<F>(
&mut self,
element_name: &str,
pad_name: &str,
mask: PadProbeType,
func: F
) where
F: Fn(&Pad, &mut PadProbeInfo<'_>) -> PadProbeReturn + Send + Sync + 'static,
[src]A convenience function to allows you to call gst_pad_add_probe on a
gst::Pad
of a gst::Element
that are residing inside the Harness
,
by using normal gst_pad_add_probe syntax
MT safe.
element_name
a gchar
with a gst::ElementFactory
name
pad_name
a gchar
with the name of the pad to attach the probe to
mask
a gst::PadProbeType
(see gst_pad_add_probe)
callback
a GstPadProbeCallback
(see gst_pad_add_probe)
destroy_data
a GDestroyNotify
(see gst_pad_add_probe)
This is supported on crate feature v1_16
only.
v1_16
only.Similar to gst_harness_add_sink_harness, this is a convenience to
directly create a sink-harness using the sink_element_name
name specified.
MT safe.
sink_element_name
a gchar
with the name of a gst::Element
Similar to gst_harness_add_src, this allows you to send the data coming out
of your harnessed gst::Element
to a sink-element, allowing to test different
responses the element output might create in sink elements. An example might
be an existing sink providing some analytical data on the input it receives that
can be useful to your testing. If the goal is to test a sink-element itself,
this is better achieved using gst_harness_new directly on the sink.
If a sink-harness already exists it will be replaced.
MT safe.
sink_harness
a Harness
to be added as a sink-harness.
Similar to gst_harness_add_sink, this allows you to specify a launch-line instead of just an element name. See gst_harness_add_src_parse for details.
MT safe.
launchline
a gchar
with the name of a gst::Element
Similar to gst_harness_add_src_harness, this is a convenience to
directly create a src-harness using the src_element_name
name specified.
MT safe.
src_element_name
a gchar
with the name of a gst::Element
has_clock_wait
a gboolean
specifying if the gst::Element
uses
gst_clock_wait_id internally.
A src-harness is a great way of providing the Harness
with data.
By adding a src-type gst::Element
, it is then easy to use functions like
gst_harness_push_from_src or gst_harness_src_crank_and_push_many
to provide your harnessed element with input. The has_clock_wait
variable
is a great way to control you src-element with, in that you can have it
produce a buffer for you by simply cranking the clock, and not have it
spin out of control producing buffers as fast as possible.
If a src-harness already exists it will be replaced.
MT safe.
src_harness
a Harness
to be added as a src-harness.
has_clock_wait
a gboolean
specifying if the gst::Element
uses
gst_clock_wait_id internally.
Similar to gst_harness_add_src, this allows you to specify a launch-line,
which can be useful for both having more then one gst::Element
acting as your
src (Like a src producing raw buffers, and then an encoder, providing encoded
data), but also by allowing you to set properties like “is-live” directly on
the elements.
MT safe.
launchline
a gchar
describing a gst-launch type line
has_clock_wait
a gboolean
specifying if the gst::Element
uses
gst_clock_wait_id internally.
Similar to crank_single_clock_wait()
, this is the function to use
if your harnessed element(s) are using more then one gst_clock_id_wait.
Failing to do so can (and will) make it racy which GstClockID
you actually
are releasing, where as this function will process all the waits at the
same time, ensuring that one thread can’t register another wait before
both are released.
MT safe.
waits
a guint
describing the number of GstClockIDs
to crank
Returns
a gboolean
true
if the “crank” was successful, false
if not.
A “crank” consists of three steps:
1: Wait for a GstClockID
to be registered with the TestClock
.
2: Advance the TestClock
to the time the GstClockID
is waiting for.
3: Release the GstClockID
wait.
Together, this provides an easy way to not have to think about the details
around clocks and time, but still being able to write deterministic tests
that are dependent on this. A “crank” can be though of as the notion of
manually driving the clock forward to its next logical step.
MT safe.
Returns
a gboolean
true
if the “crank” was successful, false
if not.
Allocates a buffer using a gst::BufferPool
if present, or else using the
configured gst::Allocator
and gst::AllocationParams
MT safe.
size
a gsize
specifying the size of the buffer
Returns
a gst::Buffer
of size size
Most useful in conjunction with gst_harness_new_parse, this will scan the
GstElements
inside the Harness
, and check if any of them matches
element_name
. Typical usecase being that you need to access one of the
harnessed elements for properties and/or signals.
MT safe.
element_name
a gchar
with a gst::ElementFactory
name
Returns
a gst::Element
or None
if not found
Get the timestamp of the last gst::Buffer
pushed on the Harness
srcpad,
typically with gst_harness_push or gst_harness_push_from_src.
MT safe.
Returns
a GstClockTime
with the timestamp or GST_CLOCK_TIME_NONE
if no
gst::Buffer
has been pushed on the Harness
srcpad
This will set the harnessed gst::Element
to gst::State::Playing
.
GstElements
without a sink-gst::Pad
and with the gst::ElementFlags::SOURCE
flag set is considered a src gst::Element
Non-src GstElements
(like sinks and filters) are automatically set to
playing by the Harness
, but src GstElements
are not to avoid them
starting to produce buffers.
Hence, for src gst::Element
you must call play()
explicitly.
MT safe.
Pulls a gst::Buffer
from the GAsyncQueue
on the Harness
sinkpad. The pull
will timeout in 60 seconds. This is the standard way of getting a buffer
from a harnessed gst::Element
.
MT safe.
Returns
a gst::Buffer
or None
if timed out.
This is supported on crate feature v1_18
only.
v1_18
only.Pulls a gst::Buffer
from the GAsyncQueue
on the Harness
sinkpad. The pull
will block until an EOS event is received, or timeout in 60 seconds.
MT safe.
Returns
true
on success, false
on timeout.
buf
A gst::Buffer
, or None
if EOS or timeout occures
first.
Pulls an gst::Event
from the GAsyncQueue
on the Harness
sinkpad.
Timeouts after 60 seconds similar to gst_harness_pull.
MT safe.
Returns
a gst::Event
or None
if timed out.
Pulls an gst::Event
from the GAsyncQueue
on the Harness
srcpad.
Timeouts after 60 seconds similar to gst_harness_pull.
MT safe.
Returns
a gst::Event
or None
if timed out.
Pushes a gst::Buffer
on the Harness
srcpad. The standard way of
interacting with an harnessed element.
MT safe.
buffer
a gst::Buffer
to push
Returns
a gst::FlowReturn
with the result from the push
Basically a gst_harness_push and a gst_harness_pull in one line. Reflects the fact that you often want to do exactly this in your test: Push one buffer in, and inspect the outcome.
MT safe.
buffer
a gst::Buffer
to push
Returns
a gst::Buffer
or None
if timed out.
Pushes an gst::Event
on the Harness
srcpad.
MT safe.
event
a gst::Event
to push
Returns
a gboolean
with the result from the push
Transfer data from the src-Harness
to the main-Harness
. It consists
of 4 steps:
1: Make sure the src is started. (see: gst_harness_play)
2: Crank the clock (see: gst_harness_crank_single_clock_wait)
3: Pull a gst::Buffer
from the src-Harness
(see: gst_harness_pull)
4: Push the same gst::Buffer
into the main-Harness
(see: gst_harness_push)
MT safe.
Returns
a gst::FlowReturn
with the result of the push
Transfer one gst::Buffer
from the main-Harness
to the sink-Harness
.
See gst_harness_push_from_src for details.
MT safe.
Returns
a gst::FlowReturn
with the result of the push
Pushes an gst::Event
on the Harness
sinkpad.
MT safe.
event
a gst::Event
to push
Returns
a gboolean
with the result from the push
Get the min latency reported by any harnessed gst::Element
.
MT safe.
Returns
a GstClockTime
with min latency
Setting this will make the harness block in the chain-function, and
then release when pull()
or try_pull()
is called.
Can be useful when wanting to control a src-element that is not implementing
gst_clock_id_wait()
so it can’t be controlled by the TestClock
, since
it otherwise would produce buffers as fast as possible.
MT safe.
When set to true
, instead of placing the buffers arriving from the harnessed
gst::Element
inside the sinkpads GAsyncQueue
, they are instead unreffed.
MT safe.
drop_buffers
a gboolean
specifying to drop outgoing buffers or not
As a convenience, a src-harness will forward gst::EventType::StreamStart
,
gst::EventType::Caps
and gst::EventType::Segment
to the main-harness if forwarding
is enabled, and forward any sticky-events from the main-harness to
the sink-harness. It will also forward the GST_QUERY_ALLOCATION
.
If forwarding is disabled, the user will have to either manually push
these events from the src-harness using src_push_event()
, or
create and push them manually. While this will allow full control and
inspection of these events, for the most cases having forwarding enabled
will be sufficient when writing a test where the src-harness’ main function
is providing data for the main-harness.
Forwarding is enabled by default.
MT safe.
forwarding
a gboolean
to enable/disable forwarding
This is supported on crate feature v1_20
only.
v1_20
only.Convenience that calls gst_harness_push_to_sink pushes
number of times.
Will abort the pushing if any one push fails.
MT safe.
pushes
a gint
with the number of calls to gst_harness_push_to_sink
Returns
a gst::FlowReturn
with the result of the push
pub fn src_crank_and_push_many(
&mut self,
cranks: u32,
pushes: u32
) -> Result<FlowSuccess, FlowError>
[src]
pub fn src_crank_and_push_many(
&mut self,
cranks: u32,
pushes: u32
) -> Result<FlowSuccess, FlowError>
[src]Transfer data from the src-Harness
to the main-Harness
. Similar to
gst_harness_push_from_src, this variant allows you to specify how many cranks
and how many pushes to perform. This can be useful for both moving a lot
of data at the same time, as well as cases when one crank does not equal one
buffer to push and v.v.
MT safe.
cranks
a gint
with the number of calls to gst_harness_crank_single_clock_wait
pushes
a gint
with the number of calls to gst_harness_push
Returns
a gst::FlowReturn
with the result of the push
Similar to what gst_harness_src_push does with GstBuffers
, this transfers
a gst::Event
from the src-Harness
to the main-Harness
. Note that
some GstEvents
are being transferred automagically. Look at sink_forward_pad
for details.
MT safe.
Returns
a gboolean
with the result of the push
This is supported on crate feature v1_14
only.
v1_14
only.Pulls all pending data from the harness and returns it as a single buffer.
Returns
the data as a buffer. Unref with gst_buffer_unref()
when no longer needed.
This is supported on crate feature v1_14
only.
v1_14
only.Pulls all pending data from the harness and returns it as a single glib::Bytes
.
Returns
a pointer to the data, newly allocated. Free
with g_free()
when no longer needed.
Pulls a gst::Buffer
from the GAsyncQueue
on the Harness
sinkpad. Unlike
gst_harness_pull this will not wait for any buffers if not any are present,
and return None
straight away.
MT safe.
Returns
a gst::Buffer
or None
if no buffers are present in the GAsyncQueue
Pulls an gst::Event
from the GAsyncQueue
on the Harness
sinkpad.
See gst_harness_try_pull for details.
MT safe.
Returns
a gst::Event
or None
if no buffers are present in the GAsyncQueue
Pulls an gst::Event
from the GAsyncQueue
on the Harness
srcpad.
See gst_harness_try_pull for details.
MT safe.
Returns
a gst::Event
or None
if no buffers are present in the GAsyncQueue
Sets the system gst::Clock
on the Harness
gst::Element
MT safe.
Sets the TestClock
on the Harness
gst::Element
MT safe.
Waits for timeout
seconds until waits
number of GstClockID
waits is
registered with the TestClock
. Useful for writing deterministic tests,
where you want to make sure that an expected number of waits have been
reached.
MT safe.
waits
a guint
describing the numbers of GstClockID
registered with
the TestClock
timeout
a guint
describing how many seconds to wait for waits
to be true
Returns
a gboolean
true
if the waits have been registered, false
if not.
(Could be that it timed out waiting or that more waits than waits was found)
Creates a new harness. Works like with_padnames()
, except it
assumes the gst::Element
sinkpad is named “sink” and srcpad is named “src”
MT safe.
element_name
a gchar
describing the gst::Element
name
Returns
Creates a new harness.
MT safe.
element
a gst::Element
to attach the harness to (transfer none)
hsrc
a gst::StaticPadTemplate
describing the harness srcpad.
None
will not create a harness srcpad.
element_sinkpad_name
a gchar
with the name of the element
sinkpad that is then linked to the harness srcpad. Can be a static or request
or a sometimes pad that has been added. None
will not get/request a sinkpad
from the element. (Like if the element is a src.)
hsink
a gst::StaticPadTemplate
describing the harness sinkpad.
None
will not create a harness sinkpad.
element_srcpad_name
a gchar
with the name of the element
srcpad that is then linked to the harness sinkpad, similar to the
element_sinkpad_name
.
Returns
Creates a new harness, parsing the launchline
and putting that in a gst::Bin
,
and then attches the harness to the bin.
MT safe.
launchline
a gchar
describing a gst-launch type line
Returns
Creates a new harness. Works in the same way as new_full()
, only
that generic padtemplates are used for the harness src and sinkpads, which
will be sufficient in most usecases.
MT safe.
element
a gst::Element
to attach the harness to (transfer none)
element_sinkpad_name
a gchar
with the name of the element
sinkpad that is then linked to the harness srcpad. None
does not attach a
sinkpad
element_srcpad_name
a gchar
with the name of the element
srcpad that is then linked to the harness sinkpad. None
does not attach a
srcpad
Returns
Creates a new harness. Works like with_element()
,
except you specify the factoryname of the gst::Element
MT safe.
element_name
a gchar
describing the gst::Element
name
element_sinkpad_name
a gchar
with the name of the element
sinkpad that is then linked to the harness srcpad. None
does not attach a
sinkpad
element_srcpad_name
a gchar
with the name of the element
srcpad that is then linked to the harness sinkpad. None
does not attach a
srcpad
Returns
pub fn with_templates(
element_name: &str,
hsrc: Option<&StaticPadTemplate>,
hsink: Option<&StaticPadTemplate>
) -> Harness
[src]