Fix and "fix".
gint i;
mfactory =
- start_record_server ("( rtppcmadepay name=depay0 ! appsink name=sink async=false )");
+ start_record_server
+ ("( rtppcmadepay name=depay0 ! appsink name=sink async=false )");
g_signal_connect (mfactory, "media-constructed",
G_CALLBACK (media_constructed_cb), &server_sink);
return NULL;
}
type = gst_rtsp_message_get_type (response);
- fail_unless (type == GST_RTSP_MESSAGE_RESPONSE || type == GST_RTSP_MESSAGE_DATA);
+ fail_unless (type == GST_RTSP_MESSAGE_RESPONSE
+ || type == GST_RTSP_MESSAGE_DATA);
return response;
}
{
GstRTSPMessage *message;
fail_unless (gst_rtsp_message_new (&message) == GST_RTSP_OK);
- fail_unless (gst_rtsp_connection_receive (conn, message, NULL) == GST_RTSP_OK);
+ fail_unless (gst_rtsp_connection_receive (conn, message,
+ NULL) == GST_RTSP_OK);
fail_unless (gst_rtsp_message_get_type (message) == GST_RTSP_MESSAGE_DATA);
gst_rtsp_message_free (message);
}
/* send PLAY request and check that we get 200 OK */
fail_unless (do_simple_request (conn, GST_RTSP_PLAY,
- session)== GST_RTSP_STS_OK);
+ session) == GST_RTSP_STS_OK);
/* send TEARDOWN request and check that we get 200 OK */
fail_unless (do_simple_request (conn, GST_RTSP_TEARDOWN,
{
GstRTSPMessage *message;
fail_unless (gst_rtsp_message_new (&message) == GST_RTSP_OK);
- fail_unless (gst_rtsp_connection_receive (conn2, message, NULL) == GST_RTSP_OK);
+ fail_unless (gst_rtsp_connection_receive (conn2, message,
+ NULL) == GST_RTSP_OK);
fail_unless (gst_rtsp_message_get_type (message) == GST_RTSP_MESSAGE_DATA);
gst_rtsp_message_free (message);
}
GST_START_TEST (test_multiple_transports)
{
start_server (TRUE);
- do_test_multiple_transports (GST_RTSP_LOWER_TRANS_UDP, GST_RTSP_LOWER_TRANS_TCP);
+ do_test_multiple_transports (GST_RTSP_LOWER_TRANS_UDP,
+ GST_RTSP_LOWER_TRANS_TCP);
stop_server ();
}
{
Responses responses = {
- {session1, session2, session3},
- {GST_RTSP_FILTER_KEEP, GST_RTSP_FILTER_KEEP, GST_RTSP_FILTER_KEEP},
+ {session1, session2, session3}
+ ,
+ {GST_RTSP_FILTER_KEEP, GST_RTSP_FILTER_KEEP, GST_RTSP_FILTER_KEEP}
+ ,
};
list = gst_rtsp_session_pool_filter (pool, filter_func, &responses);
{
Responses responses = {
- {session1, session2, session3},
- {GST_RTSP_FILTER_REF, GST_RTSP_FILTER_KEEP, GST_RTSP_FILTER_KEEP},
+ {session1, session2, session3}
+ ,
+ {GST_RTSP_FILTER_REF, GST_RTSP_FILTER_KEEP, GST_RTSP_FILTER_KEEP}
+ ,
};
list = gst_rtsp_session_pool_filter (pool, filter_func, &responses);
{
Responses responses = {
- {session1, session2, session3},
- {GST_RTSP_FILTER_KEEP, GST_RTSP_FILTER_KEEP, GST_RTSP_FILTER_REMOVE},
+ {session1, session2, session3}
+ ,
+ {GST_RTSP_FILTER_KEEP, GST_RTSP_FILTER_KEEP, GST_RTSP_FILTER_REMOVE}
+ ,
};
list = gst_rtsp_session_pool_filter (pool, filter_func, &responses);
/* allocate ports */
fail_unless (gst_rtsp_stream_allocate_udp_sockets (stream,
- socket_family, transport, FALSE));
+ socket_family, transport, FALSE));
fail_unless (gst_rtsp_stream_complete_stream (stream, transport));
fail_unless (gst_rtsp_transport_free (transport) == GST_RTSP_OK);
fail_unless (gst_rtsp_transport_new (&transport) == GST_RTSP_OK);
transport->lower_transport = GST_RTSP_LOWER_TRANS_UDP_MCAST;
fail_if (gst_rtsp_stream_allocate_udp_sockets (stream, G_SOCKET_FAMILY_IPV4,
- transport, FALSE));
+ transport, FALSE));
fail_unless (gst_rtsp_transport_free (transport) == GST_RTSP_OK);
g_object_unref (pool);