gstrtspsrc.h 5.82 KB
Newer Older
Wim Taymans's avatar
Wim Taymans committed
1
2
/* GStreamer
 * Copyright (C) <1999> Erik Walthinsen <omega@cse.ogi.edu>
3
 *               <2006> Wim Taymans <wim@fluendo.com>
Wim Taymans's avatar
Wim Taymans committed
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
 *
 * 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., 59 Temple Place - Suite 330,
 * Boston, MA 02111-1307, USA.
 */
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
/*
 * 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.
 */
Wim Taymans's avatar
Wim Taymans committed
43
44
45
46
47
48

#ifndef __GST_RTSPSRC_H__
#define __GST_RTSPSRC_H__

#include <gst/gst.h>

49
G_BEGIN_DECLS
Wim Taymans's avatar
Wim Taymans committed
50
51
52
53
54
55
56
57
58

#include "gstrtsp.h"
#include "rtsp.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) \
59
  (G_TYPE_CHECK_CLASS_CAST((klass),GST_TYPE_RTSPSRC,GstRTSPSrcClass))
Wim Taymans's avatar
Wim Taymans committed
60
61
#define GST_IS_RTSPSRC(obj) \
  (G_TYPE_CHECK_INSTANCE_TYPE((obj),GST_TYPE_RTSPSRC))
62
#define GST_IS_RTSPSRC_CLASS(klass) \
Wim Taymans's avatar
Wim Taymans committed
63
  (G_TYPE_CHECK_CLASS_TYPE((klass),GST_TYPE_RTSPSRC))
64
65
#define GST_RTSPSRC_CAST(obj) \
  ((GstRTSPSrc *)(obj))
Wim Taymans's avatar
Wim Taymans committed
66
67
68
69

typedef struct _GstRTSPSrc GstRTSPSrc;
typedef struct _GstRTSPSrcClass GstRTSPSrcClass;

70
71
72
73
74
75
76
#define GST_RTSP_STATE_GET_LOCK(rtsp)    (GST_RTSPSRC_CAST(rtsp)->state_rec_lock)
#define GST_RTSP_STATE_LOCK(rtsp)        (g_static_rec_mutex_lock (GST_RTSP_STATE_GET_LOCK(rtsp)))
#define GST_RTSP_STATE_UNLOCK(rtsp)      (g_static_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_static_rec_mutex_lock (GST_RTSP_STREAM_GET_LOCK(rtsp)))
#define GST_RTSP_STREAM_UNLOCK(rtsp)      (g_static_rec_mutex_unlock (GST_RTSP_STREAM_GET_LOCK(rtsp)))
77

Wim Taymans's avatar
Wim Taymans committed
78
79
typedef struct _GstRTSPStream GstRTSPStream;

80
81
#include "rtspext.h"

Wim Taymans's avatar
Wim Taymans committed
82
struct _GstRTSPStream {
83
  gint          id;
84

85
  GstRTSPSrc   *parent; /* parent, no extra ref to parent is taken */
86

87
88
  /* pad we expose or NULL when it does not have an actual pad */
  GstPad       *srcpad;
89
  GstFlowReturn last_ret;
90
  gboolean      added;
91
  gboolean      disabled;
92
93

  /* for interleaved mode */
94
  guint8        channel[2];
95
  GstCaps      *caps;
96
  GstPad       *channelpad[2];
Wim Taymans's avatar
Wim Taymans committed
97

98
99
  /* our udp sources */
  GstElement   *udpsrc[2];
100
  GstPad       *blockedpad;
Wim Taymans's avatar
Wim Taymans committed
101
102

  /* our udp sink back to the server */
103
  GstElement   *udpsink;
104
  GstPad       *rtcppad;
Wim Taymans's avatar
Wim Taymans committed
105

106
107
108
  /* state */
  gint          pt;
  gboolean      container;
109
110
111
  /* original control url */
  gchar        *control_url;
  /* fully qualified control url */
112
113
114
  gchar        *setup_url;
  guint32       ssrc; 
  guint32       seqbase;
115
  guint64       timebase;
Wim Taymans's avatar
Wim Taymans committed
116
117
118
};

struct _GstRTSPSrc {
119
  GstBin           parent;
Wim Taymans's avatar
Wim Taymans committed
120

121
122
123
124
  /* task and mutex for interleaved mode */
  gboolean         interleaved;
  GstTask         *task;
  GStaticRecMutex *stream_rec_lock;
125
126
  GstSegment       segment;
  gboolean         running;
127
  gdouble          position;
128
  gint             free_channel;
129
130
  GstEvent        *close_segment;
  GstEvent        *start_segment;
Wim Taymans's avatar
Wim Taymans committed
131

132
  /* UDP mode loop */
133
  gint             loop_cmd;
134
135
136
137
  gboolean         ignore_timeout;

  /* mutex for protecting state changes */
  GStaticRecMutex *state_rec_lock;
138

139
140
  gint             numstreams;
  GList           *streams;
141
  GstStructure    *props;
142
  gboolean         need_activate;
Wim Taymans's avatar
Wim Taymans committed
143

144
  /* properties */
145
  gchar           *location;
146
  gchar           *req_location; /* Sanitised URL to use in network requests */
147
  RTSPUrl         *url;
148
  RTSPLowerTrans   protocols;
149
150
  gboolean         debug;
  guint   	   retry;
151
152
  guint64          udp_timeout;
  GTimeVal         tcp_timeout;
153
  guint            latency;
Wim Taymans's avatar
Wim Taymans committed
154

155
  /* state */
156
  RTSPState        state;
157
158
  gchar           *content_base;
  RTSPLowerTrans   cur_protocols;
159
  gboolean         tried_url_auth;
160
  gchar           *addr;
161

162
163
  /* supported methods */
  gint             methods;
Wim Taymans's avatar
Wim Taymans committed
164

165
166
167
  /* session management */
  GstElement      *session;
  gulong           session_sig_id;
168
  gulong           session_ptmap_id;
169

170
  RTSPConnection  *connection;
171
172

  RTSPExtensionCtx *extension;
Wim Taymans's avatar
Wim Taymans committed
173
174
175
};

struct _GstRTSPSrcClass {
176
  GstBinClass parent_class;
Wim Taymans's avatar
Wim Taymans committed
177
178
179
180
};

GType gst_rtspsrc_get_type(void);

181
182
183
184
gboolean   gst_rtspsrc_send 		(GstRTSPSrc * src, RTSPMessage * request,
		   			 RTSPMessage * response, RTSPStatusCode * code);


185
G_END_DECLS
Wim Taymans's avatar
Wim Taymans committed
186
187

#endif /* __GST_RTSPSRC_H__ */