}
static gboolean
+test_setup_response_461 (GstRTSPClient * client,
+ GstRTSPMessage * response, gboolean close, gpointer user_data)
+{
+ GstRTSPStatusCode code;
+ const gchar *reason;
+ GstRTSPVersion version;
+ gchar *str;
+
+ fail_unless (expected_transport == NULL);
+
+ fail_unless (gst_rtsp_message_get_type (response) ==
+ GST_RTSP_MESSAGE_RESPONSE);
+
+ fail_unless (gst_rtsp_message_parse_response (response, &code, &reason,
+ &version)
+ == GST_RTSP_OK);
+ fail_unless (code == GST_RTSP_STS_UNSUPPORTED_TRANSPORT);
+ fail_unless (g_str_equal (reason, "Unsupported transport"));
+ fail_unless (version == GST_RTSP_VERSION_1_0);
+
+ fail_unless (gst_rtsp_message_get_header (response, GST_RTSP_HDR_CSEQ, &str,
+ 0) == GST_RTSP_OK);
+ fail_unless (atoi (str) == cseq++);
+
+
+ return TRUE;
+}
+
+static gboolean
test_teardown_response_200 (GstRTSPClient * client,
GstRTSPMessage * response, gboolean close, gpointer user_data)
{
}
static GstRTSPClient *
-setup_multicast_client (void)
+setup_multicast_client (guint max_ttl)
{
GstRTSPClient *client;
GstRTSPSessionPool *session_pool;
"media.factory.construct", G_TYPE_BOOLEAN, TRUE, NULL);
gst_rtsp_mount_points_add_factory (mount_points, "/test", factory);
gst_rtsp_client_set_mount_points (client, mount_points);
+ gst_rtsp_media_factory_set_max_mcast_ttl (factory, max_ttl);
thread_pool = gst_rtsp_thread_pool_new ();
gst_rtsp_client_set_thread_pool (client, thread_pool);
GstRTSPMessage request = { 0, };
gchar *str;
- client = setup_multicast_client ();
+ client = setup_multicast_client (1);
/* simple SETUP for non-existing url */
fail_unless (gst_rtsp_message_init_request (&request, GST_RTSP_SETUP,
GstRTSPMessage request = { 0, };
gchar *str;
- client = setup_multicast_client ();
+ client = setup_multicast_client (1);
expected_session_timeout = 20;
g_signal_connect (G_OBJECT (client), "new-session",
GstRTSPMessage request = { 0, };
gchar *str;
- client = setup_multicast_client ();
+ client = setup_multicast_client (1);
/* simple SETUP with a valid URI and multicast and a specific dest,
* but ignore it */
GstRTSPSessionPool *session_pool;
GstRTSPContext ctx = { NULL };
- client = setup_multicast_client ();
+ client = setup_multicast_client (1);
ctx.client = client;
ctx.auth = gst_rtsp_auth_new ();
GST_END_TEST;
static void
-mcast_transport_specific_two_clients (gboolean shared)
+mcast_transport_specific_two_clients (gboolean shared, const gchar * transport1,
+ const gchar * expected_transport1, const gchar * transport2,
+ const gchar * expected_transport2)
{
- GstRTSPClient *client, *client2;
+ GstRTSPClient *client1, *client2;
GstRTSPMessage request = { 0, };
gchar *str;
GstRTSPSessionPool *session_pool;
thread_pool = gst_rtsp_thread_pool_new ();
/* first multicast client with transport specific request */
- client = gst_rtsp_client_new ();
- gst_rtsp_client_set_session_pool (client, session_pool);
- gst_rtsp_client_set_mount_points (client, mount_points);
- gst_rtsp_client_set_thread_pool (client, thread_pool);
+ client1 = gst_rtsp_client_new ();
+ gst_rtsp_client_set_session_pool (client1, session_pool);
+ gst_rtsp_client_set_mount_points (client1, mount_points);
+ gst_rtsp_client_set_thread_pool (client1, thread_pool);
- ctx.client = client;
+ ctx.client = client1;
ctx.auth = gst_rtsp_auth_new ();
ctx.token =
gst_rtsp_token_new (GST_RTSP_TOKEN_TRANSPORT_CLIENT_SETTINGS,
"user", NULL);
gst_rtsp_context_push_current (&ctx);
- expected_transport = "RTP/AVP;multicast;destination=233.252.0.1;"
- "ttl=1;port=5000-5001;mode=\"PLAY\"";
+ expected_transport = expected_transport1;
/* send SETUP request */
fail_unless (gst_rtsp_message_init_request (&request, GST_RTSP_SETUP,
"rtsp://localhost/test/stream=0") == GST_RTSP_OK);
str = g_strdup_printf ("%d", cseq);
gst_rtsp_message_take_header (&request, GST_RTSP_HDR_CSEQ, str);
- gst_rtsp_message_add_header (&request, GST_RTSP_HDR_TRANSPORT,
- expected_transport);
+ gst_rtsp_message_add_header (&request, GST_RTSP_HDR_TRANSPORT, transport1);
- gst_rtsp_client_set_send_func (client, test_setup_response_200_multicast,
+ gst_rtsp_client_set_send_func (client1, test_setup_response_200_multicast,
NULL, NULL);
- fail_unless (gst_rtsp_client_handle_message (client,
+ fail_unless (gst_rtsp_client_handle_message (client1,
&request) == GST_RTSP_OK);
gst_rtsp_message_unset (&request);
expected_transport = NULL;
str = g_strdup_printf ("%d", cseq);
gst_rtsp_message_take_header (&request, GST_RTSP_HDR_CSEQ, str);
gst_rtsp_message_add_header (&request, GST_RTSP_HDR_SESSION, session_id);
- gst_rtsp_client_set_send_func (client, test_response_200, NULL, NULL);
- fail_unless (gst_rtsp_client_handle_message (client,
+ gst_rtsp_client_set_send_func (client1, test_response_200, NULL, NULL);
+ fail_unless (gst_rtsp_client_handle_message (client1,
&request) == GST_RTSP_OK);
gst_rtsp_message_unset (&request);
gst_rtsp_context_pop_current (&ctx);
"user", NULL);
gst_rtsp_context_push_current (&ctx2);
- expected_transport = "RTP/AVP;multicast;destination=233.252.0.2;"
- "ttl=1;port=5002-5003;mode=\"PLAY\"";
+ expected_transport = expected_transport2;
/* send SETUP request */
fail_unless (gst_rtsp_message_init_request (&request, GST_RTSP_SETUP,
"rtsp://localhost/test/stream=0") == GST_RTSP_OK);
str = g_strdup_printf ("%d", cseq);
gst_rtsp_message_take_header (&request, GST_RTSP_HDR_CSEQ, str);
- gst_rtsp_message_add_header (&request, GST_RTSP_HDR_TRANSPORT,
- expected_transport);
+ gst_rtsp_message_add_header (&request, GST_RTSP_HDR_TRANSPORT, transport2);
gst_rtsp_client_set_send_func (client2, test_setup_response_200_multicast,
NULL, NULL);
gst_rtsp_context_push_current (&ctx);
session_id = session_id1;
- send_teardown (client);
+ send_teardown (client1);
gst_rtsp_context_pop_current (&ctx);
- teardown_client (client);
+ teardown_client (client1);
teardown_client (client2);
g_object_unref (ctx.auth);
g_object_unref (ctx2.auth);
* CASE: media is shared */
GST_START_TEST
(test_client_multicast_transport_specific_two_clients_shared_media) {
- mcast_transport_specific_two_clients (TRUE);
+ const gchar *transport_client_1 = "RTP/AVP;multicast;destination=233.252.0.1;"
+ "ttl=1;port=5000-5001;mode=\"PLAY\"";
+ const gchar *expected_transport_1 = transport_client_1;
+
+ const gchar *transport_client_2 = "RTP/AVP;multicast;destination=233.252.0.2;"
+ "ttl=1;port=5002-5003;mode=\"PLAY\"";
+ const gchar *expected_transport_2 = transport_client_2;
+
+ mcast_transport_specific_two_clients (TRUE, transport_client_1,
+ expected_transport_1, transport_client_2, expected_transport_2);
}
GST_END_TEST;
* CASE: media is not shared */
GST_START_TEST (test_client_multicast_transport_specific_two_clients)
{
- mcast_transport_specific_two_clients (FALSE);
+ const gchar *transport_client_1 = "RTP/AVP;multicast;destination=233.252.0.1;"
+ "ttl=1;port=5000-5001;mode=\"PLAY\"";
+ const gchar *expected_transport_1 = transport_client_1;
+
+ const gchar *transport_client_2 = "RTP/AVP;multicast;destination=233.252.0.2;"
+ "ttl=1;port=5002-5003;mode=\"PLAY\"";
+ const gchar *expected_transport_2 = transport_client_2;
+
+ mcast_transport_specific_two_clients (FALSE, transport_client_1,
+ expected_transport_1, transport_client_2, expected_transport_2);
+}
+
+GST_END_TEST;
+
+/* test if the maximum ttl multicast value is chosen by the server
+ * CASE: the first client provides the highest ttl value */
+GST_START_TEST (test_client_multicast_max_ttl_first_client)
+{
+ const gchar *transport_client_1 = "RTP/AVP;multicast;destination=233.252.0.1;"
+ "ttl=3;port=5000-5001;mode=\"PLAY\"";
+ const gchar *expected_transport_1 = transport_client_1;
+
+ const gchar *transport_client_2 = "RTP/AVP;multicast;destination=233.252.0.2;"
+ "ttl=1;port=5002-5003;mode=\"PLAY\"";
+ const gchar *expected_transport_2 =
+ "RTP/AVP;multicast;destination=233.252.0.2;"
+ "ttl=3;port=5002-5003;mode=\"PLAY\"";
+
+ mcast_transport_specific_two_clients (TRUE, transport_client_1,
+ expected_transport_1, transport_client_2, expected_transport_2);
+}
+
+GST_END_TEST;
+
+/* test if the maximum ttl multicast value is chosen by the server
+ * CASE: the second client provides the highest ttl value */
+GST_START_TEST (test_client_multicast_max_ttl_second_client)
+{
+ const gchar *transport_client_1 = "RTP/AVP;multicast;destination=233.252.0.1;"
+ "ttl=2;port=5000-5001;mode=\"PLAY\"";
+ const gchar *expected_transport_1 = transport_client_1;
+
+ const gchar *transport_client_2 = "RTP/AVP;multicast;destination=233.252.0.2;"
+ "ttl=4;port=5002-5003;mode=\"PLAY\"";
+ const gchar *expected_transport_2 = transport_client_2;
+
+ mcast_transport_specific_two_clients (TRUE, transport_client_1,
+ expected_transport_1, transport_client_2, expected_transport_2);
+}
+
+GST_END_TEST;
+GST_START_TEST (test_client_multicast_invalid_ttl)
+{
+ GstRTSPClient *client;
+ GstRTSPMessage request = { 0, };
+ gchar *str;
+ GstRTSPSessionPool *session_pool;
+ GstRTSPContext ctx = { NULL };
+
+ client = setup_multicast_client (3);
+
+ ctx.client = client;
+ ctx.auth = gst_rtsp_auth_new ();
+ ctx.token =
+ gst_rtsp_token_new (GST_RTSP_TOKEN_TRANSPORT_CLIENT_SETTINGS,
+ G_TYPE_BOOLEAN, TRUE, GST_RTSP_TOKEN_MEDIA_FACTORY_ROLE, G_TYPE_STRING,
+ "user", NULL);
+ gst_rtsp_context_push_current (&ctx);
+
+ /* simple SETUP with an invalid ttl=0 */
+ fail_unless (gst_rtsp_message_init_request (&request, GST_RTSP_SETUP,
+ "rtsp://localhost/test/stream=0") == GST_RTSP_OK);
+ str = g_strdup_printf ("%d", cseq);
+ gst_rtsp_message_take_header (&request, GST_RTSP_HDR_CSEQ, str);
+ gst_rtsp_message_add_header (&request, GST_RTSP_HDR_TRANSPORT,
+ "RTP/AVP;multicast;destination=233.252.0.1;ttl=0;port=5000-5001;");
+
+ gst_rtsp_client_set_send_func (client, test_setup_response_461, NULL, NULL);
+ fail_unless (gst_rtsp_client_handle_message (client,
+ &request) == GST_RTSP_OK);
+ gst_rtsp_message_unset (&request);
+
+ session_pool = gst_rtsp_client_get_session_pool (client);
+ fail_unless (session_pool != NULL);
+ fail_unless (gst_rtsp_session_pool_get_n_sessions (session_pool) == 0);
+ g_object_unref (session_pool);
+
+ teardown_client (client);
+ g_object_unref (ctx.auth);
+ gst_rtsp_token_unref (ctx.token);
+ gst_rtsp_context_pop_current (&ctx);
}
GST_END_TEST;
tcase_add_test (tc, test_client_multicast_transport_specific_two_clients);
tcase_add_test (tc,
test_client_multicast_transport_specific_no_address_in_pool);
+ tcase_add_test (tc, test_client_multicast_max_ttl_first_client);
+ tcase_add_test (tc, test_client_multicast_max_ttl_second_client);
+ tcase_add_test (tc, test_client_multicast_invalid_ttl);
return s;
}
projects / platform / upstream / gstreamer.git / blobdiff