mirrors/gstreamer
mirrors/gstreamer
1
1
Fork 0
mirror of https://gitlab.freedesktop.org/gstreamer/gstreamer.git synced 2024-12-29 19:50:40 +00:00
Code Issues 1 Projects Releases Wiki Activity

tests: rtspserver: Add shared media test case for TCP

Browse source
This commit is contained in:
Patricia Muscalu 2018-11-17 16:11:53 +01:00
parent 185385924d
commit d4a8834ffe
1 changed files with 36 additions and 8 deletions
Show stats Download patch file Download diff file Expand all files Collapse all files

42
tests/check/gst/rtspserver.c
View file

@ -192,7 +192,7 @@ start_server (gboolean set_shared_factory)
} }
static void static void
start_tcp_server (void) start_tcp_server (gboolean set_shared_factory)
{ {
GstRTSPMountPoints *mounts; GstRTSPMountPoints *mounts;
gchar *service; gchar *service;
@ -206,6 +206,7 @@ start_tcp_server (void)
gst_rtsp_media_factory_set_launch (factory, gst_rtsp_media_factory_set_launch (factory,
"( " VIDEO_PIPELINE " " AUDIO_PIPELINE " )"); "( " VIDEO_PIPELINE " " AUDIO_PIPELINE " )");
gst_rtsp_mount_points_add_factory (mounts, TEST_MOUNT_POINT, factory); gst_rtsp_mount_points_add_factory (mounts, TEST_MOUNT_POINT, factory);
gst_rtsp_media_factory_set_shared (factory, set_shared_factory);
g_object_unref (mounts); g_object_unref (mounts);
/* set port to any */ /* set port to any */
@ -1236,7 +1237,7 @@ GST_START_TEST (test_play_tcp)
GstRTSPTransport *video_transport = NULL; GstRTSPTransport *video_transport = NULL;
GstRTSPTransport *audio_transport = NULL; GstRTSPTransport *audio_transport = NULL;
start_tcp_server (); start_tcp_server (FALSE);
conn = connect_to_server (test_port, TEST_MOUNT_POINT); conn = connect_to_server (test_port, TEST_MOUNT_POINT);
@ -1910,7 +1911,7 @@ GST_END_TEST;
GST_START_TEST (test_play_smpte_range_tcp) GST_START_TEST (test_play_smpte_range_tcp)
{ {
start_tcp_server (); start_tcp_server (FALSE);
do_test_play_tcp_full ("npt=5-"); do_test_play_tcp_full ("npt=5-");
do_test_play_tcp_full ("smpte=0:00:00-"); do_test_play_tcp_full ("smpte=0:00:00-");
@ -1925,14 +1926,21 @@ GST_START_TEST (test_play_smpte_range_tcp)
GST_END_TEST; GST_END_TEST;
static gpointer static gpointer
thread_func (gpointer data) thread_func_udp (gpointer data)
{ {
do_test_play_full (NULL, GST_RTSP_LOWER_TRANS_UDP, (GMutex *) data); do_test_play_full (NULL, GST_RTSP_LOWER_TRANS_UDP, (GMutex *) data);
return NULL; return NULL;
} }
/* Test adding and removing clients to a 'Shared' media. */ static gpointer
GST_START_TEST (test_shared) thread_func_tcp (gpointer data)
{
do_test_play_tcp_full (NULL);
return NULL;
}
static void
test_shared (gpointer (thread_func) (gpointer data))
{ {
GMutex lock1, lock2, lock3, lock4; GMutex lock1, lock2, lock3, lock4;
GThread *thread1, *thread2, *thread3, *thread4; GThread *thread1, *thread2, *thread3, *thread4;
@ -1944,6 +1952,9 @@ GST_START_TEST (test_shared)
g_mutex_init (&lock3); g_mutex_init (&lock3);
g_mutex_init (&lock4); g_mutex_init (&lock4);
if (thread_func == thread_func_tcp)
start_tcp_server (TRUE);
else
start_server (TRUE); start_server (TRUE);
/* Start the first receiver thread. */ /* Start the first receiver thread. */
@ -1981,6 +1992,22 @@ GST_START_TEST (test_shared)
iterate (); iterate ();
} }
/* Test adding and removing clients to a 'Shared' media.
* CASE: unicast UDP */
GST_START_TEST (test_shared_udp)
{
test_shared (thread_func_udp);
}
GST_END_TEST;
/* Test adding and removing clients to a 'Shared' media.
* CASE: unicast TCP */
GST_START_TEST (test_shared_tcp)
{
test_shared (thread_func_tcp);
}
GST_END_TEST; GST_END_TEST;
GST_START_TEST (test_announce_without_sdp) GST_START_TEST (test_announce_without_sdp)
@ -2407,7 +2434,8 @@ rtspserver_suite (void)
tcase_add_test (tc, test_play_specific_server_port); tcase_add_test (tc, test_play_specific_server_port);
tcase_add_test (tc, test_play_smpte_range); tcase_add_test (tc, test_play_smpte_range);
tcase_add_test (tc, test_play_smpte_range_tcp); tcase_add_test (tc, test_play_smpte_range_tcp);
tcase_add_test (tc, test_shared); tcase_add_test (tc, test_shared_udp);
tcase_add_test (tc, test_shared_tcp);
tcase_add_test (tc, test_announce_without_sdp); tcase_add_test (tc, test_announce_without_sdp);
tcase_add_test (tc, test_record_tcp); tcase_add_test (tc, test_record_tcp);
tcase_add_test (tc, test_multiple_transports); tcase_add_test (tc, test_multiple_transports);