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
|
#include <gst/check/gstharness.h>
#include <gst/check/gstcheck.h>
GST_START_TEST (netsim_stress)
{
GstHarness *h = gst_harness_new ("netsim");
GstCaps *caps = gst_caps_from_string ("mycaps");
GstBuffer *buf = gst_harness_create_buffer (h, 100);
GstHarnessThread *state, *push;
GstSegment segment;
gst_segment_init (&segment, GST_FORMAT_TIME);
state = gst_harness_stress_statechange_start (h);
push = gst_harness_stress_push_buffer_start (h, caps, &segment, buf);
g_usleep (G_USEC_PER_SEC * 1);
gst_harness_stress_thread_stop (state);
gst_harness_stress_thread_stop (push);
gst_caps_unref (caps);
gst_buffer_unref (buf);
gst_harness_teardown (h);
}
GST_END_TEST;
GST_START_TEST (netsim_stress_delayed)
{
GstHarness *h = gst_harness_new_parse ("netsim delay-probability=0.5");
GstCaps *caps = gst_caps_from_string ("mycaps");
GstBuffer *buf = gst_harness_create_buffer (h, 100);
GstHarnessThread *state, *push;
GstSegment segment;
gst_segment_init (&segment, GST_FORMAT_TIME);
state = gst_harness_stress_statechange_start (h);
push = gst_harness_stress_push_buffer_start (h, caps, &segment, buf);
g_usleep (G_USEC_PER_SEC * 1);
gst_harness_stress_thread_stop (state);
gst_harness_stress_thread_stop (push);
gst_caps_unref (caps);
gst_buffer_unref (buf);
gst_harness_teardown (h);
}
GST_END_TEST;
static Suite *
netsim_suite (void)
{
Suite *s = suite_create ("netsim");
TCase *tc_chain;
suite_add_tcase (s, (tc_chain = tcase_create ("general")));
tcase_add_test (tc_chain, netsim_stress);
tcase_add_test (tc_chain, netsim_stress_delayed);
return s;
}
GST_CHECK_MAIN (netsim)
|
