1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
66
67
68
69
70
71
72
73
74
75
76
77
78
79
80
81
82
83
84
85
86
87
88
89
90
91
92
93
94
95
96
97
98
99
100
101
102
103
104
105
106
107
108
109
110
111
112
113
114
115
116
117
118
119
120
121
122
123
124
125
126
127
128
129
130
131
132
133
134
135
136
|
/*
* Farstream - Farstream RTP Stream
*
* Copyright 2007 Collabora Ltd.
* @author: Olivier Crete <olivier.crete@collabora.co.uk>
* Copyright 2007 Nokia Corp.
*
* fs-rtp-stream.h - A Farstream RTP Stream
*
* This library is free software; you can redistribute it and/or
* modify it under the terms of the GNU Lesser General Public
* License as published by the Free Software Foundation; either
* version 2.1 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
* Lesser General Public License for more details.
*
* You should have received a copy of the GNU Lesser General Public
* License along with this library; if not, write to the Free Software
* Foundation, Inc., 51 Franklin Street, Fifth Floor, Boston, MA 02110-1301 USA
*/
#ifndef __FS_RTP_STREAM_H__
#define __FS_RTP_STREAM_H__
#include <farstream/fs-stream.h>
#include <farstream/fs-stream-transmitter.h>
#include "fs-rtp-participant.h"
#include "fs-rtp-session.h"
#include "fs-rtp-substream.h"
G_BEGIN_DECLS
/* TYPE MACROS */
#define FS_TYPE_RTP_STREAM \
(fs_rtp_stream_get_type ())
#define FS_RTP_STREAM(obj) \
(G_TYPE_CHECK_INSTANCE_CAST((obj), FS_TYPE_RTP_STREAM, FsRtpStream))
#define FS_RTP_STREAM_CLASS(klass) \
(G_TYPE_CHECK_CLASS_CAST((klass), FS_TYPE_RTP_STREAM, FsRtpStreamClass))
#define FS_IS_RTP_STREAM(obj) \
(G_TYPE_CHECK_INSTANCE_TYPE((obj), FS_TYPE_RTP_STREAM))
#define FS_IS_RTP_STREAM_CLASS(klass) \
(G_TYPE_CHECK_CLASS_TYPE((klass), FS_TYPE_RTP_STREAM))
#define FS_RTP_STREAM_GET_CLASS(obj) \
(G_TYPE_INSTANCE_GET_CLASS ((obj), FS_TYPE_RTP_STREAM, FsRtpStreamClass))
#define FS_RTP_STREAM_CAST(obj) ((FsRtpStream*) (obj))
typedef struct _FsRtpStream FsRtpStream;
typedef struct _FsRtpStreamClass FsRtpStreamClass;
typedef struct _FsRtpStreamPrivate FsRtpStreamPrivate;
struct _FsRtpStreamClass
{
FsStreamClass parent_class;
};
/**
* FsRtpStream:
*
*/
struct _FsRtpStream
{
FsStream parent;
/*< private >*/
/* Can only be accessed while holding the FsRtpSession lock */
/* Dont modify, call set_remote_codecs() */
GList *remote_codecs;
GList *negotiated_codecs;
/* Same as codecs, hold FsRtpSession lock and modify by
* setting the property
*/
GList *hdrext;
/* Dont modify, call add_substream() */
GList *substreams;
FsRtpParticipant *participant;
FsRtpStreamPrivate *priv;
};
GType fs_rtp_stream_get_type (void);
typedef gboolean (*stream_new_remote_codecs_cb) (FsRtpStream *stream,
GList *codecs, GError **error, gpointer user_data);
typedef void (*stream_known_source_packet_receive_cb) (FsRtpStream *stream,
guint component, GstBuffer *buffer, gpointer user_data);
typedef void (*stream_sending_changed_locked_cb) (FsRtpStream *stream,
gboolean sending, gpointer user_data);
typedef void (*stream_ssrc_added_cb) (FsRtpStream *stream, guint32 ssrc,
gpointer user_data);
typedef FsStreamTransmitter* (*stream_get_new_stream_transmitter_cb) (
FsRtpStream *stream, FsParticipant *participant,
const gchar *transmitter_name, GParameter *parameters, guint n_parameters,
GError **error, gpointer user_data);
typedef gboolean (*stream_decrypt_clear_locked_cb) (FsRtpStream *stream,
gpointer user_data);
FsRtpStream *fs_rtp_stream_new (FsRtpSession *session,
FsRtpParticipant *participant,
FsStreamDirection direction,
stream_new_remote_codecs_cb new_remote_codecs_cb,
stream_known_source_packet_receive_cb known_source_packet_received_cb,
stream_sending_changed_locked_cb sending_changed_locked_cb,
stream_ssrc_added_cb ssrc_added_cb,
stream_get_new_stream_transmitter_cb get_new_stream_transmitter_cb,
stream_decrypt_clear_locked_cb decrypt_clear_locked_cb,
gpointer user_data_for_cb);
gboolean fs_rtp_stream_add_substream_unlock (FsRtpStream *stream,
FsRtpSubStream *substream,
GError **error);
void
fs_rtp_stream_set_negotiated_codecs_unlock (FsRtpStream *stream,
GList *codecs);
gboolean
validate_srtp_parameters (GstStructure *parameters,
gint *srtp_cipher, gint *srtcp_cipher, gint *srtp_auth, gint *srtcp_auth,
GstBuffer **key, guint *replay_window, GError **error);
GstCaps *
fs_rtp_stream_get_srtp_caps_locked (FsRtpStream *self);
G_END_DECLS
#endif /* __FS_RTP_STREAM_H__ */
|
