/* GStreamer * Copyright (C) <1999> Erik Walthinsen * <2006> Wim Taymans * * This library is free software; you can redistribute it and/or * modify it under the terms of the GNU Library General Public * License as published by the Free Software Foundation; either * version 2 of the License, or (at your option) any later version. * * This library is distributed in the hope that it will be useful, * but WITHOUT ANY WARRANTY; without even the implied warranty of * MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE. See the GNU * Library General Public License for more details. * * You should have received a copy of the GNU Library General Public * License along with this library; if not, write to the * Free Software Foundation, Inc., 51 Franklin St, Fifth Floor, * Boston, MA 02110-1301, USA. */ /* * Unless otherwise indicated, Source Code is licensed under MIT license. * See further explanation attached in License Statement (distributed in the file * LICENSE). * * Permission is hereby granted, free of charge, to any person obtaining a copy of * this software and associated documentation files (the "Software"), to deal in * the Software without restriction, including without limitation the rights to * use, copy, modify, merge, publish, distribute, sublicense, and/or sell copies * of the Software, and to permit persons to whom the Software is furnished to do * so, subject to the following conditions: * * The above copyright notice and this permission notice shall be included in all * copies or substantial portions of the Software. * * THE SOFTWARE IS PROVIDED "AS IS", WITHOUT WARRANTY OF ANY KIND, EXPRESS OR * IMPLIED, INCLUDING BUT NOT LIMITED TO THE WARRANTIES OF MERCHANTABILITY, * FITNESS FOR A PARTICULAR PURPOSE AND NONINFRINGEMENT. IN NO EVENT SHALL THE * AUTHORS OR COPYRIGHT HOLDERS BE LIABLE FOR ANY CLAIM, DAMAGES OR OTHER * LIABILITY, WHETHER IN AN ACTION OF CONTRACT, TORT OR OTHERWISE, ARISING FROM, * OUT OF OR IN CONNECTION WITH THE SOFTWARE OR THE USE OR OTHER DEALINGS IN THE * SOFTWARE. */ #ifndef __GST_RTSPSRC_H__ #define __GST_RTSPSRC_H__ #include G_BEGIN_DECLS #include #include #include "gstrtspext.h" #define GST_TYPE_RTSPSRC \ (gst_rtspsrc_get_type()) #define GST_RTSPSRC(obj) \ (G_TYPE_CHECK_INSTANCE_CAST((obj),GST_TYPE_RTSPSRC,GstRTSPSrc)) #define GST_RTSPSRC_CLASS(klass) \ (G_TYPE_CHECK_CLASS_CAST((klass),GST_TYPE_RTSPSRC,GstRTSPSrcClass)) #define GST_IS_RTSPSRC(obj) \ (G_TYPE_CHECK_INSTANCE_TYPE((obj),GST_TYPE_RTSPSRC)) #define GST_IS_RTSPSRC_CLASS(klass) \ (G_TYPE_CHECK_CLASS_TYPE((klass),GST_TYPE_RTSPSRC)) #define GST_RTSPSRC_CAST(obj) \ ((GstRTSPSrc *)(obj)) typedef struct _GstRTSPSrc GstRTSPSrc; typedef struct _GstRTSPSrcClass GstRTSPSrcClass; #define GST_RTSP_STATE_GET_LOCK(rtsp) (&GST_RTSPSRC_CAST(rtsp)->state_rec_lock) #define GST_RTSP_STATE_LOCK(rtsp) (g_rec_mutex_lock (GST_RTSP_STATE_GET_LOCK(rtsp))) #define GST_RTSP_STATE_UNLOCK(rtsp) (g_rec_mutex_unlock (GST_RTSP_STATE_GET_LOCK(rtsp))) #define GST_RTSP_STREAM_GET_LOCK(rtsp) (&GST_RTSPSRC_CAST(rtsp)->stream_rec_lock) #define GST_RTSP_STREAM_LOCK(rtsp) (g_rec_mutex_lock (GST_RTSP_STREAM_GET_LOCK(rtsp))) #define GST_RTSP_STREAM_UNLOCK(rtsp) (g_rec_mutex_unlock (GST_RTSP_STREAM_GET_LOCK(rtsp))) typedef struct _GstRTSPConnInfo GstRTSPConnInfo; struct _GstRTSPConnInfo { gchar *location; GstRTSPUrl *url; gchar *url_str; GstRTSPConnection *connection; gboolean connected; gboolean flushing; }; typedef struct _GstRTSPStream GstRTSPStream; struct _GstRTSPStream { gint id; GstRTSPSrc *parent; /* parent, no extra ref to parent is taken */ /* pad we expose or NULL when it does not have an actual pad */ GstPad *srcpad; GstFlowReturn last_ret; gboolean added; gboolean setup; gboolean skipped; gboolean eos; gboolean discont; gboolean need_caps; /* for interleaved mode */ guint8 channel[2]; GstPad *channelpad[2]; /* our udp sources */ GstElement *udpsrc[2]; GstPad *blockedpad; gulong blockid; gboolean is_ipv6; /* our udp sinks back to the server */ GstElement *udpsink[2]; GstPad *rtcppad; /* fakesrc for sending dummy data */ GstElement *fakesrc; /* state */ guint port; gboolean container; gboolean is_real; guint8 default_pt; GstRTSPProfile profile; GArray *ptmap; /* original control url */ gchar *control_url; guint32 ssrc; guint32 seqbase; guint64 timebase; GstElement *srtpdec; GstCaps *srtcpparams; GstElement *srtpenc; guint32 send_ssrc; /* per stream connection */ GstRTSPConnInfo conninfo; /* session */ GObject *session; /* srtp key management */ GstMIKEYMessage *mikey; /* bandwidth */ guint as_bandwidth; guint rs_bandwidth; guint rr_bandwidth; /* destination */ gchar *destination; gboolean is_multicast; guint ttl; GstStructure *rtx_pt_map; }; /** * GstRTSPNatMethod: * @GST_RTSP_NAT_NONE: none * @GST_RTSP_NAT_DUMMY: send dummy packets * * Different methods for trying to traverse firewalls. */ typedef enum { GST_RTSP_NAT_NONE, GST_RTSP_NAT_DUMMY } GstRTSPNatMethod; struct _GstRTSPSrc { GstBin parent; /* task and mutex for interleaved mode */ gboolean interleaved; GstTask *task; GRecMutex stream_rec_lock; GstSegment segment; gboolean running; gboolean need_range; gboolean skip; gint free_channel; gboolean need_segment; GstClockTime base_time; /* UDP mode loop */ gint pending_cmd; gint busy_cmd; gboolean ignore_timeout; gboolean open_error; /* mutex for protecting state changes */ GRecMutex state_rec_lock; GstSDPMessage *sdp; gboolean from_sdp; GList *streams; GstStructure *props; gboolean need_activate; /* properties */ GstRTSPLowerTrans protocols; gboolean debug; guint retry; guint64 udp_timeout; GTimeVal tcp_timeout; GTimeVal *ptcp_timeout; guint latency; gboolean drop_on_latency; guint64 connection_speed; GstRTSPNatMethod nat_method; gboolean do_rtcp; gboolean do_rtsp_keep_alive; gchar *proxy_host; guint proxy_port; gchar *proxy_user; /* from url or property */ gchar *proxy_passwd; /* from url or property */ gchar *prop_proxy_id; /* set via property */ gchar *prop_proxy_pw; /* set via property */ guint rtp_blocksize; gchar *user_id; gchar *user_pw; gint buffer_mode; GstRTSPRange client_port_range; gint udp_buffer_size; gboolean short_header; guint probation; gboolean udp_reconnect; gchar *multi_iface; gboolean ntp_sync; gboolean use_pipeline_clock; GstStructure *sdes; GTlsCertificateFlags tls_validation_flags; GTlsDatabase *tls_database; GTlsInteraction *tls_interaction; gboolean do_retransmission; gint ntp_time_source; gchar *user_agent; GstClockTime max_rtcp_rtp_time_diff; gboolean rfc7273_sync; /* state */ GstRTSPState state; gchar *content_base; GstRTSPLowerTrans cur_protocols; gboolean tried_url_auth; gchar *addr; gboolean need_redirect; GstRTSPTimeRange *range; gchar *control; guint next_port_num; GstClock *provided_clock; /* supported methods */ gint methods; gboolean seekable; GstClockTime last_pos; /* session management */ GstElement *manager; gulong manager_sig_id; gulong manager_ptmap_id; gboolean use_buffering; GstRTSPConnInfo conninfo; /* a list of RTSP extensions as GstElement */ GstRTSPExtensionList *extensions; }; struct _GstRTSPSrcClass { GstBinClass parent_class; }; GType gst_rtspsrc_get_type(void); G_END_DECLS #endif /* __GST_RTSPSRC_H__ */