]>
code.delx.au - pulseaudio/blob - src/modules/rtp/sdp.c
2 This file is part of PulseAudio.
4 Copyright 2006 Lennart Poettering
6 PulseAudio is free software; you can redistribute it and/or modify
7 it under the terms of the GNU Lesser General Public License as published
8 by the Free Software Foundation; either version 2 of the License,
9 or (at your option) any later version.
11 PulseAudio is distributed in the hope that it will be useful, but
12 WITHOUT ANY WARRANTY; without even the implied warranty of
13 MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE. See the GNU
14 General Public License for more details.
16 You should have received a copy of the GNU Lesser General Public License
17 along with PulseAudio; if not, write to the Free Software
18 Foundation, Inc., 59 Temple Place, Suite 330, Boston, MA 02111-1307
28 #include <sys/types.h>
29 #include <sys/socket.h>
30 #include <netinet/in.h>
31 #include <arpa/inet.h>
34 #include <pulse/xmalloc.h>
35 #include <pulse/util.h>
37 #include <pulsecore/core-util.h>
38 #include <pulsecore/log.h>
39 #include <pulsecore/macro.h>
44 char *pa_sdp_build(int af
, const void *src
, const void *dst
, const char *name
, uint16_t port
, uint8_t payload
, const pa_sample_spec
*ss
) {
46 char buf_src
[64], buf_dst
[64], un
[64];
53 pa_assert(af
== AF_INET
|| af
== AF_INET6
);
55 pa_assert(af
== AF_INET
);
58 pa_assert_se(f
= pa_rtp_format_to_string(ss
->format
));
60 if (!(u
= pa_get_user_name(un
, sizeof(un
))))
63 ntp
= (uint32_t) time(NULL
) + 2208988800U;
65 pa_assert_se(inet_ntop(af
, src
, buf_src
, sizeof(buf_src
)));
66 pa_assert_se(inet_ntop(af
, dst
, buf_dst
, sizeof(buf_dst
)));
68 return pa_sprintf_malloc(
70 "o=%s %lu 0 IN %s %s\n"
75 "m=audio %u RTP/AVP %i\n"
76 "a=rtpmap:%i %s/%u/%u\n"
78 u
, (unsigned long) ntp
, af
== AF_INET
? "IP4" : "IP6", buf_src
,
80 af
== AF_INET
? "IP4" : "IP6", buf_dst
,
83 payload
, f
, ss
->rate
, ss
->channels
);
86 static pa_sample_spec
*parse_sdp_sample_spec(pa_sample_spec
*ss
, char *c
) {
87 unsigned rate
, channels
;
91 if (pa_startswith(c
, "L16/")) {
92 ss
->format
= PA_SAMPLE_S16BE
;
94 } else if (pa_startswith(c
, "L8/")) {
95 ss
->format
= PA_SAMPLE_U8
;
97 } else if (pa_startswith(c
, "PCMA/")) {
98 ss
->format
= PA_SAMPLE_ALAW
;
100 } else if (pa_startswith(c
, "PCMU/")) {
101 ss
->format
= PA_SAMPLE_ULAW
;
106 if (sscanf(c
, "%u/%u", &rate
, &channels
) == 2) {
107 ss
->rate
= (uint32_t) rate
;
108 ss
->channels
= (uint8_t) channels
;
109 } else if (sscanf(c
, "%u", &rate
) == 2) {
110 ss
->rate
= (uint32_t) rate
;
115 if (!pa_sample_spec_valid(ss
))
121 pa_sdp_info
*pa_sdp_parse(const char *t
, pa_sdp_info
*i
, int is_goodbye
) {
123 pa_bool_t ss_valid
= FALSE
;
128 i
->origin
= i
->session_name
= NULL
;
132 if (!pa_startswith(t
, PA_SDP_HEADER
)) {
133 pa_log("Failed to parse SDP data: invalid header.");
137 t
+= sizeof(PA_SDP_HEADER
)-1;
142 l
= strcspn(t
, "\n");
145 pa_log("Failed to parse SDP data: line too short: >%s<.", t
);
149 if (pa_startswith(t
, "o="))
150 i
->origin
= pa_xstrndup(t
+2, l
-2);
151 else if (pa_startswith(t
, "s="))
152 i
->session_name
= pa_xstrndup(t
+2, l
-2);
153 else if (pa_startswith(t
, "c=IN IP4 ")) {
157 k
= l
-8 > sizeof(a
) ? sizeof(a
) : l
-8;
159 pa_strlcpy(a
, t
+9, k
);
160 a
[strcspn(a
, "/")] = 0;
162 if (inet_pton(AF_INET
, a
, &((struct sockaddr_in
*) &i
->sa
)->sin_addr
) <= 0) {
163 pa_log("Failed to parse SDP data: bad address: >%s<.", a
);
167 ((struct sockaddr_in
*) &i
->sa
)->sin_family
= AF_INET
;
168 ((struct sockaddr_in
*) &i
->sa
)->sin_port
= 0;
169 i
->salen
= sizeof(struct sockaddr_in
);
171 } else if (pa_startswith(t
, "c=IN IP6 ")) {
175 k
= l
-8 > sizeof(a
) ? sizeof(a
) : l
-8;
177 pa_strlcpy(a
, t
+9, k
);
178 a
[strcspn(a
, "/")] = 0;
180 if (inet_pton(AF_INET6
, a
, &((struct sockaddr_in6
*) &i
->sa
)->sin6_addr
) <= 0) {
181 pa_log("Failed to parse SDP data: bad address: >%s<.", a
);
185 ((struct sockaddr_in6
*) &i
->sa
)->sin6_family
= AF_INET6
;
186 ((struct sockaddr_in6
*) &i
->sa
)->sin6_port
= 0;
187 i
->salen
= sizeof(struct sockaddr_in6
);
189 } else if (pa_startswith(t
, "m=audio ")) {
191 if (i
->payload
> 127) {
194 if (sscanf(t
+8, "%i RTP/AVP %i", &_port
, &_payload
) == 2) {
196 if (_port
<= 0 || _port
> 0xFFFF) {
197 pa_log("Failed to parse SDP data: invalid port %i.", _port
);
201 if (_payload
< 0 || _payload
> 127) {
202 pa_log("Failed to parse SDP data: invalid payload %i.", _payload
);
206 port
= (uint16_t) _port
;
207 i
->payload
= (uint8_t) _payload
;
209 if (pa_rtp_sample_spec_from_payload(i
->payload
, &i
->sample_spec
))
213 } else if (pa_startswith(t
, "a=rtpmap:")) {
215 if (i
->payload
<= 127) {
219 if (sscanf(t
+9, "%i %64c", &_payload
, c
) == 2) {
221 if (_payload
< 0 || _payload
> 127) {
222 pa_log("Failed to parse SDP data: invalid payload %i.", _payload
);
225 if (_payload
== i
->payload
) {
227 c
[strcspn(c
, "\n")] = 0;
229 if (parse_sdp_sample_spec(&i
->sample_spec
, c
))
242 if (!i
->origin
|| (!is_goodbye
&& (!i
->salen
|| i
->payload
> 127 || !ss_valid
|| port
== 0))) {
243 pa_log("Failed to parse SDP data: missing data.");
247 if (((struct sockaddr
*) &i
->sa
)->sa_family
== AF_INET
)
248 ((struct sockaddr_in
*) &i
->sa
)->sin_port
= htons(port
);
250 ((struct sockaddr_in6
*) &i
->sa
)->sin6_port
= htons(port
);
256 pa_xfree(i
->session_name
);
261 void pa_sdp_info_destroy(pa_sdp_info
*i
) {
265 pa_xfree(i
->session_name
);