← Back to branch summary

~ubuntu-branches/ubuntu/wily/sflphone/wily-proposed

« back to all changes in this revision

Viewing changes to daemon/libs/pjproject-2.1.0/pjmedia/src/pjmedia/sdp.c

  • Committer: Package Import Robot
  • Author(s): Jonathan Riddell
  • Date: 2015-01-07 14:51:16 UTC
  • mfrom: (4.3.5 sid)
  • Revision ID: package-import@ubuntu.com-20150107145116-yxnafinf4lrdvrmx
Tags: 1.4.1-0.1ubuntu1
* Merge with Debian, remaining changes:
 - Drop soprano, nepomuk build-dep
* Drop ubuntu patches, now upstream

Show diffs side-by-side

added added

removed removed

Lines of Context:
daemon/libs/pjproject-2.1.0/pjmedia/src/pjmedia/sdp.c
1
 
/* $Id: sdp.c 4367 2013-02-21 20:49:19Z nanang $ */
2
 
/* 
3
 
 * Copyright (C) 2008-2011 Teluu Inc. (http://www.teluu.com)
4
 
 * Copyright (C) 2003-2008 Benny Prijono <benny@prijono.org>
5
 
 *
6
 
 * This program is free software; you can redistribute it and/or modify
7
 
 * it under the terms of the GNU General Public License as published by
8
 
 * the Free Software Foundation; either version 2 of the License, or
9
 
 * (at your option) any later version.
10
 
 *
11
 
 * This program is distributed in the hope that it will be useful,
12
 
 * but WITHOUT ANY WARRANTY; without even the implied warranty of
13
 
 * MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE.  See the
14
 
 * GNU General Public License for more details.
15
 
 *
16
 
 * You should have received a copy of the GNU General Public License
17
 
 * along with this program; if not, write to the Free Software
18
 
 * Foundation, Inc., 59 Temple Place, Suite 330, Boston, MA  02111-1307  USA 
19
 
 */
20
 
#include <pjmedia/sdp.h>
21
 
#include <pjmedia/errno.h>
22
 
#include <pjlib-util/scanner.h>
23
 
#include <pj/array.h>
24
 
#include <pj/except.h>
25
 
#include <pj/log.h>
26
 
#include <pj/os.h>
27
 
#include <pj/string.h>
28
 
#include <pj/pool.h>
29
 
#include <pj/assert.h>
30
 
#include <pj/ctype.h>
31
 
 
32
 
 
33
 
enum {
34
 
    SKIP_WS = 0,
35
 
    SYNTAX_ERROR = 1,
36
 
};
37
 
// New token definition from RFC 4566 (SDP)
38
 
#define TOKEN           "!#$%&'*+-.^_`{|}~"
39
 
//#define TOKEN         "-.!%*_=`'~"
40
 
//#define TOKEN         "'`-./:?\"#$&*;=@[]^_`{|}+~!"
41
 
#define NTP_OFFSET      ((pj_uint32_t)2208988800)
42
 
#define THIS_FILE       "sdp.c"
43
 
 
44
 
typedef struct parse_context
45
 
{ 
46
 
    pj_status_t last_error;
47
 
} parse_context;
48
 
 
49
 
 
50
 
/*
51
 
 * Prototypes for line parser.
52
 
 */
53
 
static void parse_version(pj_scanner *scanner, parse_context *ctx);
54
 
static void parse_origin(pj_scanner *scanner, pjmedia_sdp_session *ses,
55
 
                         parse_context *ctx);
56
 
static void parse_time(pj_scanner *scanner, pjmedia_sdp_session *ses,
57
 
                       parse_context *ctx);
58
 
static void parse_generic_line(pj_scanner *scanner, pj_str_t *str,
59
 
                               parse_context *ctx);
60
 
static void parse_connection_info(pj_scanner *scanner, pjmedia_sdp_conn *conn,
61
 
                                  parse_context *ctx);
62
 
static void parse_bandwidth_info(pj_scanner *scanner, pjmedia_sdp_bandw *bandw,
63
 
                                  parse_context *ctx);
64
 
static pjmedia_sdp_attr *parse_attr(pj_pool_t *pool, pj_scanner *scanner,
65
 
                                    parse_context *ctx);
66
 
static void parse_media(pj_scanner *scanner, pjmedia_sdp_media *med,
67
 
                        parse_context *ctx);
68
 
static void on_scanner_error(pj_scanner *scanner);
69
 
 
70
 
/*
71
 
 * Scanner character specification.
72
 
 */
73
 
static int is_initialized;
74
 
static pj_cis_buf_t cis_buf;
75
 
static pj_cis_t cs_digit, cs_token;
76
 
 
77
 
static void init_sdp_parser(void)
78
 
{
79
 
    if (is_initialized != 0)
80
 
        return;
81
 
 
82
 
    pj_enter_critical_section();
83
 
 
84
 
    if (is_initialized != 0) {
85
 
        pj_leave_critical_section();
86
 
        return;
87
 
    }
88
 
    
89
 
    pj_cis_buf_init(&cis_buf);
90
 
 
91
 
    pj_cis_init(&cis_buf, &cs_token);
92
 
    pj_cis_add_alpha(&cs_token);
93
 
    pj_cis_add_num(&cs_token);
94
 
    pj_cis_add_str(&cs_token, TOKEN);
95
 
 
96
 
    pj_cis_init(&cis_buf, &cs_digit);
97
 
    pj_cis_add_num(&cs_digit);
98
 
 
99
 
    is_initialized = 1;
100
 
    pj_leave_critical_section();
101
 
}
102
 
 
103
 
PJ_DEF(pjmedia_sdp_attr*) pjmedia_sdp_attr_create( pj_pool_t *pool,
104
 
                                                   const char *name,
105
 
                                                   const pj_str_t *value)
106
 
{
107
 
    pjmedia_sdp_attr *attr;
108
 
 
109
 
    PJ_ASSERT_RETURN(pool && name, NULL);
110
 
 
111
 
    attr = PJ_POOL_ALLOC_T(pool, pjmedia_sdp_attr);
112
 
    pj_strdup2(pool, &attr->name, name);
113
 
 
114
 
    if (value)
115
 
        pj_strdup_with_null(pool, &attr->value, value);
116
 
    else {
117
 
        attr->value.ptr = NULL;
118
 
        attr->value.slen = 0;
119
 
    }
120
 
 
121
 
    return attr;
122
 
}
123
 
 
124
 
PJ_DEF(pjmedia_sdp_attr*) pjmedia_sdp_attr_clone(pj_pool_t *pool, 
125
 
                                                 const pjmedia_sdp_attr *rhs)
126
 
{
127
 
    pjmedia_sdp_attr *attr;
128
 
    
129
 
    PJ_ASSERT_RETURN(pool && rhs, NULL);
130
 
 
131
 
    attr = PJ_POOL_ALLOC_T(pool, pjmedia_sdp_attr);
132
 
 
133
 
    pj_strdup(pool, &attr->name, &rhs->name);
134
 
    pj_strdup_with_null(pool, &attr->value, &rhs->value);
135
 
 
136
 
    return attr;
137
 
}
138
 
 
139
 
PJ_DEF(pjmedia_sdp_attr*) pjmedia_sdp_attr_find (unsigned count, 
140
 
                                       pjmedia_sdp_attr *const attr_array[],
141
 
                                       const pj_str_t *name,
142
 
                                       const pj_str_t *c_fmt)
143
 
{
144
 
    unsigned i;
145
 
    unsigned c_pt = 0xFFFF;
146
 
 
147
 
    if (c_fmt)
148
 
        c_pt = pj_strtoul(c_fmt);
149
 
 
150
 
    for (i=0; i<count; ++i) {
151
 
        if (pj_strcmp(&attr_array[i]->name, name) == 0) {
152
 
            const pjmedia_sdp_attr *a = attr_array[i];
153
 
            if (c_fmt) {
154
 
                unsigned pt = (unsigned) pj_strtoul2(&a->value, NULL, 10);
155
 
                if (pt == c_pt) {
156
 
                    return (pjmedia_sdp_attr*)a;
157
 
                }
158
 
            } else 
159
 
                return (pjmedia_sdp_attr*)a;
160
 
        }
161
 
    }
162
 
    return NULL;
163
 
}
164
 
 
165
 
PJ_DEF(pjmedia_sdp_attr*) pjmedia_sdp_attr_find2(unsigned count, 
166
 
                                       pjmedia_sdp_attr *const attr_array[],
167
 
                                       const char *c_name,
168
 
                                       const pj_str_t *c_fmt)
169
 
{
170
 
    pj_str_t name;
171
 
 
172
 
    name.ptr = (char*)c_name;
173
 
    name.slen = pj_ansi_strlen(c_name);
174
 
 
175
 
    return pjmedia_sdp_attr_find(count, attr_array, &name, c_fmt);
176
 
}
177
 
 
178
 
 
179
 
 
180
 
PJ_DEF(pj_status_t) pjmedia_sdp_attr_add(unsigned *count,
181
 
                                         pjmedia_sdp_attr *attr_array[],
182
 
                                         pjmedia_sdp_attr *attr)
183
 
{
184
 
    PJ_ASSERT_RETURN(count && attr_array && attr, PJ_EINVAL);
185
 
    PJ_ASSERT_RETURN(*count < PJMEDIA_MAX_SDP_ATTR, PJ_ETOOMANY);
186
 
 
187
 
    attr_array[*count] = attr;
188
 
    (*count)++;
189
 
 
190
 
    return PJ_SUCCESS;
191
 
}
192
 
 
193
 
 
194
 
PJ_DEF(unsigned) pjmedia_sdp_attr_remove_all(unsigned *count,
195
 
                                             pjmedia_sdp_attr *attr_array[],
196
 
                                             const char *name)
197
 
{
198
 
    unsigned i, removed = 0;
199
 
    pj_str_t attr_name;
200
 
 
201
 
    PJ_ASSERT_RETURN(count && attr_array && name, PJ_EINVAL);
202
 
 
203
 
    attr_name.ptr = (char*)name;
204
 
    attr_name.slen = pj_ansi_strlen(name);
205
 
 
206
 
    for (i=0; i<*count; ) {
207
 
        if (pj_strcmp(&attr_array[i]->name, &attr_name)==0) {
208
 
            pj_array_erase(attr_array, sizeof(pjmedia_sdp_attr*),
209
 
                           *count, i);
210
 
            --(*count);
211
 
            ++removed;
212
 
        } else {
213
 
            ++i;
214
 
        }   
215
 
    }
216
 
 
217
 
    return removed;
218
 
}
219
 
 
220
 
 
221
 
PJ_DEF(pj_status_t) pjmedia_sdp_attr_remove( unsigned *count,
222
 
                                             pjmedia_sdp_attr *attr_array[],
223
 
                                             pjmedia_sdp_attr *attr )
224
 
{
225
 
    unsigned i, removed=0;
226
 
 
227
 
    PJ_ASSERT_RETURN(count && attr_array && attr, PJ_EINVAL);
228
 
 
229
 
    for (i=0; i<*count; ) {
230
 
        if (attr_array[i] == attr) {
231
 
            pj_array_erase(attr_array, sizeof(pjmedia_sdp_attr*),
232
 
                           *count, i);
233
 
            --(*count);
234
 
            ++removed;
235
 
        } else {
236
 
            ++i;
237
 
        }
238
 
    }
239
 
 
240
 
    return removed ? PJ_SUCCESS : PJ_ENOTFOUND;
241
 
}
242
 
 
243
 
 
244
 
PJ_DEF(pj_status_t) pjmedia_sdp_attr_get_rtpmap( const pjmedia_sdp_attr *attr,
245
 
                                                 pjmedia_sdp_rtpmap *rtpmap)
246
 
{
247
 
    pj_scanner scanner;
248
 
    pj_str_t token;
249
 
    pj_status_t status = -1;
250
 
    char term = 0;
251
 
    PJ_USE_EXCEPTION;
252
 
 
253
 
    PJ_ASSERT_RETURN(pj_strcmp2(&attr->name, "rtpmap")==0, PJ_EINVALIDOP);
254
 
 
255
 
    PJ_ASSERT_RETURN(attr->value.slen != 0, PJMEDIA_SDP_EINATTR);
256
 
 
257
 
    init_sdp_parser();
258
 
 
259
 
    /* Check if input is null terminated, and null terminate if
260
 
     * necessary. Unfortunately this may crash the application if
261
 
     * attribute was allocated from a read-only memory location.
262
 
     * But this shouldn't happen as attribute's value normally is
263
 
     * null terminated.
264
 
     */
265
 
    if (attr->value.ptr[attr->value.slen] != 0 &&
266
 
        attr->value.ptr[attr->value.slen] != '\r' &&
267
 
        attr->value.ptr[attr->value.slen] != '\n')
268
 
    {
269
 
        pj_assert(!"Shouldn't happen");
270
 
        term = attr->value.ptr[attr->value.slen];
271
 
        attr->value.ptr[attr->value.slen] = '\0';
272
 
    }
273
 
 
274
 
    pj_scan_init(&scanner, (char*)attr->value.ptr, attr->value.slen,
275
 
                 PJ_SCAN_AUTOSKIP_WS, &on_scanner_error);
276
 
 
277
 
    /* rtpmap sample:
278
 
     *  a=rtpmap:98 L16/16000/2.
279
 
     */
280
 
 
281
 
    /* Init */
282
 
    rtpmap->pt.slen = rtpmap->param.slen = rtpmap->enc_name.slen = 0;
283
 
    rtpmap->clock_rate = 0;
284
 
 
285
 
    /* Parse */
286
 
    PJ_TRY {
287
 
 
288
 
        /* Get payload type. */
289
 
        pj_scan_get(&scanner, &cs_token, &rtpmap->pt);
290
 
 
291
 
 
292
 
        /* Get encoding name. */
293
 
        pj_scan_get(&scanner, &cs_token, &rtpmap->enc_name);
294
 
 
295
 
        /* Expecting '/' after encoding name. */
296
 
        if (pj_scan_get_char(&scanner) != '/') {
297
 
            status = PJMEDIA_SDP_EINRTPMAP;
298
 
            goto on_return;
299
 
        }
300
 
 
301
 
 
302
 
        /* Get the clock rate. */
303
 
        pj_scan_get(&scanner, &cs_digit, &token);
304
 
        rtpmap->clock_rate = pj_strtoul(&token);
305
 
 
306
 
        /* Expecting either '/' or EOF */
307
 
        if (*scanner.curptr == '/') {
308
 
            pj_scan_get_char(&scanner);
309
 
            rtpmap->param.ptr = scanner.curptr;
310
 
            rtpmap->param.slen = scanner.end - scanner.curptr;
311
 
        } else {
312
 
            rtpmap->param.slen = 0;
313
 
        }
314
 
 
315
 
        status = PJ_SUCCESS;
316
 
    }
317
 
    PJ_CATCH_ANY {
318
 
        status = PJMEDIA_SDP_EINRTPMAP;
319
 
    }
320
 
    PJ_END;
321
 
 
322
 
 
323
 
on_return:
324
 
    pj_scan_fini(&scanner);
325
 
    if (term) {
326
 
        attr->value.ptr[attr->value.slen] = term;
327
 
    }
328
 
    return status;
329
 
}
330
 
 
331
 
PJ_DEF(pj_status_t) pjmedia_sdp_attr_get_fmtp( const pjmedia_sdp_attr *attr,
332
 
                                               pjmedia_sdp_fmtp *fmtp)
333
 
{
334
 
    const char *p = attr->value.ptr;
335
 
    const char *end = attr->value.ptr + attr->value.slen;
336
 
    pj_str_t token;
337
 
 
338
 
    PJ_ASSERT_RETURN(pj_strcmp2(&attr->name, "fmtp")==0, PJ_EINVALIDOP);
339
 
 
340
 
    /* fmtp BNF:
341
 
     *  a=fmtp:<format> <format specific parameter>
342
 
     */
343
 
 
344
 
    /* Get format. */
345
 
    token.ptr = (char*)p;
346
 
    while (pj_isdigit(*p) && p!=end)
347
 
        ++p;
348
 
    token.slen = p - token.ptr;
349
 
    if (token.slen == 0)
350
 
        return PJMEDIA_SDP_EINFMTP;
351
 
 
352
 
    fmtp->fmt = token;
353
 
 
354
 
    /* Expecting space after format. */
355
 
    if (*p != ' ') return PJMEDIA_SDP_EINFMTP;
356
 
 
357
 
    /* Get space. */
358
 
    ++p;
359
 
 
360
 
    /* Set the remaining string as fmtp format parameter. */
361
 
    fmtp->fmt_param.ptr = (char*)p;
362
 
    fmtp->fmt_param.slen = end - p;
363
 
 
364
 
    return PJ_SUCCESS;
365
 
}
366
 
 
367
 
 
368
 
PJ_DEF(pj_status_t) pjmedia_sdp_attr_get_rtcp(const pjmedia_sdp_attr *attr,
369
 
                                              pjmedia_sdp_rtcp_attr *rtcp)
370
 
{
371
 
    pj_scanner scanner;
372
 
    pj_str_t token;
373
 
    pj_status_t status = -1;
374
 
    PJ_USE_EXCEPTION;
375
 
 
376
 
    PJ_ASSERT_RETURN(pj_strcmp2(&attr->name, "rtcp")==0, PJ_EINVALIDOP);
377
 
 
378
 
    init_sdp_parser();
379
 
 
380
 
    /* fmtp BNF:
381
 
     *  a=rtcp:<port> [nettype addrtype address]
382
 
     */
383
 
 
384
 
    pj_scan_init(&scanner, (char*)attr->value.ptr, attr->value.slen,
385
 
                 PJ_SCAN_AUTOSKIP_WS, &on_scanner_error);
386
 
 
387
 
    /* Init */
388
 
    rtcp->net_type.slen = rtcp->addr_type.slen = rtcp->addr.slen = 0;
389
 
 
390
 
    /* Parse */
391
 
    PJ_TRY {
392
 
 
393
 
        /* Get the port */
394
 
        pj_scan_get(&scanner, &cs_token, &token);
395
 
        rtcp->port = pj_strtoul(&token);
396
 
 
397
 
        /* Have address? */
398
 
        if (!pj_scan_is_eof(&scanner)) {
399
 
 
400
 
            /* Get network type */
401
 
            pj_scan_get(&scanner, &cs_token, &rtcp->net_type);
402
 
 
403
 
            /* Get address type */
404
 
            pj_scan_get(&scanner, &cs_token, &rtcp->addr_type);
405
 
 
406
 
            /* Get the address */
407
 
            pj_scan_get(&scanner, &cs_token, &rtcp->addr);
408
 
 
409
 
        }
410
 
 
411
 
        status = PJ_SUCCESS;
412
 
 
413
 
    }
414
 
    PJ_CATCH_ANY {
415
 
        status = PJMEDIA_SDP_EINRTCP;
416
 
    }
417
 
    PJ_END;
418
 
 
419
 
    pj_scan_fini(&scanner);
420
 
    return status;
421
 
}
422
 
 
423
 
 
424
 
PJ_DEF(pjmedia_sdp_attr*) pjmedia_sdp_attr_create_rtcp(pj_pool_t *pool,
425
 
                                                       const pj_sockaddr *a)
426
 
{
427
 
    enum {
428
 
        ATTR_LEN = PJ_INET6_ADDRSTRLEN+16
429
 
    };
430
 
    pjmedia_sdp_attr *attr;
431
 
 
432
 
    attr = PJ_POOL_ALLOC_T(pool, pjmedia_sdp_attr);
433
 
    attr->name = pj_str("rtcp");
434
 
    attr->value.ptr = (char*) pj_pool_alloc(pool, ATTR_LEN);
435
 
    if (a->addr.sa_family == pj_AF_INET()) {
436
 
        attr->value.slen = 
437
 
            pj_ansi_snprintf(attr->value.ptr, ATTR_LEN,
438
 
                            "%u IN IP4 %s",
439
 
                            pj_ntohs(a->ipv4.sin_port),
440
 
                            pj_inet_ntoa(a->ipv4.sin_addr));
441
 
    } else if (a->addr.sa_family == pj_AF_INET6()) {
442
 
        char tmp_addr[PJ_INET6_ADDRSTRLEN];
443
 
        attr->value.slen = 
444
 
            pj_ansi_snprintf(attr->value.ptr, ATTR_LEN,
445
 
                            "%u IN IP6 %s",
446
 
                            pj_sockaddr_get_port(a),
447
 
                            pj_sockaddr_print(a, tmp_addr, 
448
 
                                              sizeof(tmp_addr), 0));
449
 
 
450
 
    } else {
451
 
        pj_assert(!"Unsupported address family");
452
 
        return NULL;
453
 
    }
454
 
 
455
 
    return attr;
456
 
}
457
 
 
458
 
 
459
 
PJ_DEF(pj_status_t) pjmedia_sdp_attr_to_rtpmap(pj_pool_t *pool,
460
 
                                               const pjmedia_sdp_attr *attr,
461
 
                                               pjmedia_sdp_rtpmap **p_rtpmap)
462
 
{
463
 
    PJ_ASSERT_RETURN(pool && attr && p_rtpmap, PJ_EINVAL);
464
 
 
465
 
    *p_rtpmap = PJ_POOL_ALLOC_T(pool, pjmedia_sdp_rtpmap);
466
 
    PJ_ASSERT_RETURN(*p_rtpmap, PJ_ENOMEM);
467
 
 
468
 
    return pjmedia_sdp_attr_get_rtpmap(attr, *p_rtpmap);
469
 
}
470
 
 
471
 
 
472
 
PJ_DEF(pj_status_t) pjmedia_sdp_rtpmap_to_attr(pj_pool_t *pool,
473
 
                                               const pjmedia_sdp_rtpmap *rtpmap,
474
 
                                               pjmedia_sdp_attr **p_attr)
475
 
{
476
 
    pjmedia_sdp_attr *attr;
477
 
    char tempbuf[128];
478
 
    int len;
479
 
 
480
 
    /* Check arguments. */
481
 
    PJ_ASSERT_RETURN(pool && rtpmap && p_attr, PJ_EINVAL);
482
 
 
483
 
    /* Check that mandatory attributes are specified. */
484
 
    PJ_ASSERT_RETURN(rtpmap->enc_name.slen && rtpmap->clock_rate,
485
 
                     PJMEDIA_SDP_EINRTPMAP);
486
 
 
487
 
 
488
 
    attr = PJ_POOL_ALLOC_T(pool, pjmedia_sdp_attr);
489
 
    PJ_ASSERT_RETURN(attr != NULL, PJ_ENOMEM);
490
 
 
491
 
    attr->name.ptr = "rtpmap";
492
 
    attr->name.slen = 6;
493
 
 
494
 
    /* Format: ":pt enc_name/clock_rate[/param]" */
495
 
    len = pj_ansi_snprintf(tempbuf, sizeof(tempbuf), 
496
 
                           "%.*s %.*s/%u%s%.*s",
497
 
                           (int)rtpmap->pt.slen,
498
 
                           rtpmap->pt.ptr,
499
 
                           (int)rtpmap->enc_name.slen,
500
 
                           rtpmap->enc_name.ptr,
501
 
                           rtpmap->clock_rate,
502
 
                           (rtpmap->param.slen ? "/" : ""),
503
 
                           (int)rtpmap->param.slen,
504
 
                           rtpmap->param.ptr);
505
 
 
506
 
    if (len < 1 || len > (int)sizeof(tempbuf))
507
 
        return PJMEDIA_SDP_ERTPMAPTOOLONG;
508
 
 
509
 
    attr->value.slen = len;
510
 
    attr->value.ptr = (char*) pj_pool_alloc(pool, attr->value.slen+1);
511
 
    pj_memcpy(attr->value.ptr, tempbuf, attr->value.slen+1);
512
 
 
513
 
    *p_attr = attr;
514
 
    return PJ_SUCCESS;
515
 
}
516
 
 
517
 
 
518
 
static int print_connection_info( pjmedia_sdp_conn *c, char *buf, int len)
519
 
{
520
 
    int printed;
521
 
 
522
 
    printed = pj_ansi_snprintf(buf, len, "c=%.*s %.*s %.*s\r\n",
523
 
                               (int)c->net_type.slen,
524
 
                               c->net_type.ptr,
525
 
                               (int)c->addr_type.slen,
526
 
                               c->addr_type.ptr,
527
 
                               (int)c->addr.slen,
528
 
                               c->addr.ptr);
529
 
    if (printed < 1 || printed > len)
530
 
        return -1;
531
 
 
532
 
    return printed;
533
 
}
534
 
 
535
 
 
536
 
PJ_DEF(pjmedia_sdp_conn*) pjmedia_sdp_conn_clone (pj_pool_t *pool, 
537
 
                                                  const pjmedia_sdp_conn *rhs)
538
 
{
539
 
    pjmedia_sdp_conn *c = PJ_POOL_ALLOC_T(pool, pjmedia_sdp_conn);
540
 
    if (!c) return NULL;
541
 
 
542
 
    if (!pj_strdup (pool, &c->net_type, &rhs->net_type)) return NULL;
543
 
    if (!pj_strdup (pool, &c->addr_type, &rhs->addr_type)) return NULL;
544
 
    if (!pj_strdup (pool, &c->addr, &rhs->addr)) return NULL;
545
 
 
546
 
    return c;
547
 
}
548
 
 
549
 
PJ_DEF(pjmedia_sdp_bandw*)
550
 
pjmedia_sdp_bandw_clone (pj_pool_t *pool, 
551
 
                         const pjmedia_sdp_bandw *rhs)
552
 
{
553
 
    pjmedia_sdp_bandw *b = PJ_POOL_ALLOC_T(pool, pjmedia_sdp_bandw);
554
 
    if (!b) return NULL;
555
 
 
556
 
    if (!pj_strdup (pool, &b->modifier, &rhs->modifier)) return NULL;
557
 
    b->value = rhs->value;
558
 
 
559
 
    return b;
560
 
}
561
 
 
562
 
static pj_ssize_t print_bandw(const pjmedia_sdp_bandw *bandw,
563
 
                              char *buf, pj_size_t len)
564
 
{
565
 
    char *p = buf;
566
 
 
567
 
    if ((int)len < bandw->modifier.slen + 10 + 5)
568
 
        return -1;
569
 
 
570
 
    *p++ = 'b';
571
 
    *p++ = '=';
572
 
    pj_memcpy(p, bandw->modifier.ptr, bandw->modifier.slen);
573
 
    p += bandw->modifier.slen;
574
 
    *p++ = ':';
575
 
    p += pj_utoa(bandw->value, p);
576
 
 
577
 
    *p++ = '\r';
578
 
    *p++ = '\n';
579
 
    return p-buf;
580
 
}
581
 
 
582
 
static pj_ssize_t print_attr(const pjmedia_sdp_attr *attr, 
583
 
                             char *buf, pj_size_t len)
584
 
{
585
 
    char *p = buf;
586
 
 
587
 
    if ((int)len < attr->name.slen + attr->value.slen + 10)
588
 
        return -1;
589
 
 
590
 
    *p++ = 'a';
591
 
    *p++ = '=';
592
 
    pj_memcpy(p, attr->name.ptr, attr->name.slen);
593
 
    p += attr->name.slen;
594
 
    
595
 
 
596
 
    if (attr->value.slen) {
597
 
        *p++ = ':';
598
 
        pj_memcpy(p, attr->value.ptr, attr->value.slen);
599
 
        p += attr->value.slen;
600
 
    }
601
 
 
602
 
    *p++ = '\r';
603
 
    *p++ = '\n';
604
 
    return p-buf;
605
 
}
606
 
 
607
 
static int print_media_desc( pjmedia_sdp_media *m, char *buf, int len)
608
 
{
609
 
    char *p = buf;
610
 
    char *end = buf+len;
611
 
    unsigned i;
612
 
    int printed;
613
 
 
614
 
    /* check length for the "m=" line. */
615
 
    if (len < m->desc.media.slen+m->desc.transport.slen+12+24) {
616
 
        return -1;
617
 
    }
618
 
    *p++ = 'm';     /* m= */
619
 
    *p++ = '=';
620
 
    pj_memcpy(p, m->desc.media.ptr, m->desc.media.slen);
621
 
    p += m->desc.media.slen;
622
 
    *p++ = ' ';
623
 
    printed = pj_utoa(m->desc.port, p);
624
 
    p += printed;
625
 
    if (m->desc.port_count > 1) {
626
 
        *p++ = '/';
627
 
        printed = pj_utoa(m->desc.port_count, p);
628
 
        p += printed;
629
 
    }
630
 
    *p++ = ' ';
631
 
    pj_memcpy(p, m->desc.transport.ptr, m->desc.transport.slen);
632
 
    p += m->desc.transport.slen;
633
 
    for (i=0; i<m->desc.fmt_count; ++i) {
634
 
        *p++ = ' ';
635
 
        pj_memcpy(p, m->desc.fmt[i].ptr, m->desc.fmt[i].slen);
636
 
        p += m->desc.fmt[i].slen;
637
 
    }
638
 
    *p++ = '\r';
639
 
    *p++ = '\n';
640
 
 
641
 
    /* print connection info, if present. */
642
 
    if (m->conn) {
643
 
        printed = print_connection_info(m->conn, p, end-p);
644
 
        if (printed < 0) {
645
 
            return -1;
646
 
        }
647
 
        p += printed;
648
 
    }
649
 
    
650
 
    /* print optional bandwidth info. */
651
 
    for (i=0; i<m->bandw_count; ++i) {
652
 
        printed = print_bandw(m->bandw[i], p, end-p);
653
 
        if (printed < 0) {
654
 
            return -1;
655
 
        }
656
 
        p += printed;
657
 
    }
658
 
 
659
 
    /* print attributes. */
660
 
    for (i=0; i<m->attr_count; ++i) {
661
 
        printed = print_attr(m->attr[i], p, end-p);
662
 
        if (printed < 0) {
663
 
            return -1;
664
 
        }
665
 
        p += printed;
666
 
    }
667
 
 
668
 
    return p-buf;
669
 
}
670
 
 
671
 
PJ_DEF(pjmedia_sdp_media*) pjmedia_sdp_media_clone(
672
 
                                                 pj_pool_t *pool, 
673
 
                                                 const pjmedia_sdp_media *rhs)
674
 
{
675
 
    unsigned int i;
676
 
    pjmedia_sdp_media *m = PJ_POOL_ALLOC_T(pool, pjmedia_sdp_media);
677
 
    PJ_ASSERT_RETURN(m != NULL, NULL);
678
 
 
679
 
    pj_strdup (pool, &m->desc.media, &rhs->desc.media);
680
 
    m->desc.port = rhs->desc.port;
681
 
    m->desc.port_count = rhs->desc.port_count;
682
 
    pj_strdup (pool, &m->desc.transport, &rhs->desc.transport);
683
 
    m->desc.fmt_count = rhs->desc.fmt_count;
684
 
    for (i=0; i<rhs->desc.fmt_count; ++i)
685
 
        pj_strdup(pool, &m->desc.fmt[i], &rhs->desc.fmt[i]);
686
 
 
687
 
    if (rhs->conn) {
688
 
        m->conn = pjmedia_sdp_conn_clone (pool, rhs->conn);
689
 
        PJ_ASSERT_RETURN(m->conn != NULL, NULL);
690
 
    } else {
691
 
        m->conn = NULL;
692
 
    }
693
 
 
694
 
    m->bandw_count = rhs->bandw_count;
695
 
    for (i=0; i < rhs->bandw_count; ++i) {
696
 
        m->bandw[i] = pjmedia_sdp_bandw_clone (pool, rhs->bandw[i]);
697
 
        PJ_ASSERT_RETURN(m->bandw[i] != NULL, NULL);
698
 
    }
699
 
 
700
 
    m->attr_count = rhs->attr_count;
701
 
    for (i=0; i < rhs->attr_count; ++i) {
702
 
        m->attr[i] = pjmedia_sdp_attr_clone (pool, rhs->attr[i]);
703
 
        PJ_ASSERT_RETURN(m->attr[i] != NULL, NULL);
704
 
    }
705
 
 
706
 
    return m;
707
 
}
708
 
 
709
 
PJ_DEF(pjmedia_sdp_attr*) pjmedia_sdp_media_find_attr(
710
 
                                const pjmedia_sdp_media *m,
711
 
                                const pj_str_t *name, const pj_str_t *fmt)
712
 
{
713
 
    PJ_ASSERT_RETURN(m && name, NULL);
714
 
    return pjmedia_sdp_attr_find(m->attr_count, m->attr, name, fmt);
715
 
}
716
 
 
717
 
 
718
 
 
719
 
PJ_DEF(pjmedia_sdp_attr*) pjmedia_sdp_media_find_attr2(
720
 
                                const pjmedia_sdp_media *m,
721
 
                                const char *name, const pj_str_t *fmt)
722
 
{
723
 
    PJ_ASSERT_RETURN(m && name, NULL);
724
 
    return pjmedia_sdp_attr_find2(m->attr_count, m->attr, name, fmt);
725
 
}
726
 
 
727
 
 
728
 
PJ_DEF(pj_status_t) pjmedia_sdp_media_add_attr( pjmedia_sdp_media *m,
729
 
                                                pjmedia_sdp_attr *attr)
730
 
{
731
 
    return pjmedia_sdp_attr_add(&m->attr_count, m->attr, attr);
732
 
}
733
 
 
734
 
PJ_DEF(pj_status_t) pjmedia_sdp_session_add_attr(pjmedia_sdp_session *s,
735
 
                                                 pjmedia_sdp_attr *attr)
736
 
{
737
 
    return pjmedia_sdp_attr_add(&s->attr_count, s->attr, attr);
738
 
}
739
 
 
740
 
PJ_DEF(unsigned) pjmedia_sdp_media_remove_all_attr(pjmedia_sdp_media *m,
741
 
                                                   const char *name)
742
 
{
743
 
    return pjmedia_sdp_attr_remove_all(&m->attr_count, m->attr, name);
744
 
}
745
 
 
746
 
PJ_DEF(pj_status_t) pjmedia_sdp_media_remove_attr(pjmedia_sdp_media *m,
747
 
                                                  pjmedia_sdp_attr *attr)
748
 
{
749
 
    return pjmedia_sdp_attr_remove(&m->attr_count, m->attr, attr);
750
 
}
751
 
 
752
 
static int print_session(const pjmedia_sdp_session *ses, 
753
 
                         char *buf, pj_ssize_t len)
754
 
{
755
 
    char *p = buf;
756
 
    char *end = buf+len;
757
 
    unsigned i;
758
 
    int printed;
759
 
 
760
 
    /* Check length for v= and o= lines. */
761
 
    if (len < 5+ 
762
 
              2+ses->origin.user.slen+18+
763
 
              ses->origin.net_type.slen+ses->origin.addr.slen + 2)
764
 
    {
765
 
        return -1;
766
 
    }
767
 
 
768
 
    /* SDP version (v= line) */
769
 
    pj_memcpy(p, "v=0\r\n", 5);
770
 
    p += 5;
771
 
 
772
 
    /* Owner (o=) line. */
773
 
    *p++ = 'o';
774
 
    *p++ = '=';
775
 
    pj_memcpy(p, ses->origin.user.ptr, ses->origin.user.slen);
776
 
    p += ses->origin.user.slen;
777
 
    *p++ = ' ';
778
 
    printed = pj_utoa(ses->origin.id, p);
779
 
    p += printed;
780
 
    *p++ = ' ';
781
 
    printed = pj_utoa(ses->origin.version, p);
782
 
    p += printed;
783
 
    *p++ = ' ';
784
 
    pj_memcpy(p, ses->origin.net_type.ptr, ses->origin.net_type.slen);
785
 
    p += ses->origin.net_type.slen;
786
 
    *p++ = ' ';
787
 
    pj_memcpy(p, ses->origin.addr_type.ptr, ses->origin.addr_type.slen);
788
 
    p += ses->origin.addr_type.slen;
789
 
    *p++ = ' ';
790
 
    pj_memcpy(p, ses->origin.addr.ptr, ses->origin.addr.slen);
791
 
    p += ses->origin.addr.slen;
792
 
    *p++ = '\r';
793
 
    *p++ = '\n';
794
 
 
795
 
    /* Session name (s=) line. */
796
 
    if ((end-p)  < 8+ses->name.slen) {
797
 
        return -1;
798
 
    }
799
 
    *p++ = 's';
800
 
    *p++ = '=';
801
 
    pj_memcpy(p, ses->name.ptr, ses->name.slen);
802
 
    p += ses->name.slen;
803
 
    *p++ = '\r';
804
 
    *p++ = '\n';
805
 
 
806
 
    /* Connection line (c=) if exist. */
807
 
    if (ses->conn) {
808
 
        printed = print_connection_info(ses->conn, p, end-p);
809
 
        if (printed < 1) {
810
 
            return -1;
811
 
        }
812
 
        p += printed;
813
 
    }
814
 
 
815
 
    /* print optional bandwidth info. */
816
 
    for (i=0; i<ses->bandw_count; ++i) {
817
 
        printed = print_bandw(ses->bandw[i], p, end-p);
818
 
        if (printed < 1) {
819
 
            return -1;
820
 
        }
821
 
        p += printed;
822
 
    }
823
 
 
824
 
    /* Time */
825
 
    if ((end-p) < 24) {
826
 
        return -1;
827
 
    }
828
 
    *p++ = 't';
829
 
    *p++ = '=';
830
 
    printed = pj_utoa(ses->time.start, p);
831
 
    p += printed;
832
 
    *p++ = ' ';
833
 
    printed = pj_utoa(ses->time.stop, p);
834
 
    p += printed;
835
 
    *p++ = '\r';
836
 
    *p++ = '\n';
837
 
 
838
 
    /* Print all attribute (a=) lines. */
839
 
    for (i=0; i<ses->attr_count; ++i) {
840
 
        printed = print_attr(ses->attr[i], p, end-p);
841
 
        if (printed < 0) {
842
 
            return -1;
843
 
        }
844
 
        p += printed;
845
 
    }
846
 
 
847
 
    /* Print media (m=) lines. */
848
 
    for (i=0; i<ses->media_count; ++i) {
849
 
        printed = print_media_desc(ses->media[i], p, end-p);
850
 
        if (printed < 0) {
851
 
            return -1;
852
 
        }
853
 
        p += printed;
854
 
    }
855
 
 
856
 
    return p-buf;
857
 
}
858
 
 
859
 
/******************************************************************************
860
 
 * PARSERS
861
 
 */
862
 
 
863
 
static void parse_version(pj_scanner *scanner, parse_context *ctx)
864
 
{
865
 
    ctx->last_error = PJMEDIA_SDP_EINVER;
866
 
 
867
 
    /* check equal sign */
868
 
    if (*(scanner->curptr+1) != '=') {
869
 
        on_scanner_error(scanner);
870
 
        return;
871
 
    }
872
 
 
873
 
    /* check version is 0 */
874
 
    if (*(scanner->curptr+2) != '0') {
875
 
        on_scanner_error(scanner);
876
 
        return;
877
 
    }
878
 
 
879
 
    /* We've got what we're looking for, skip anything until newline */
880
 
    pj_scan_skip_line(scanner);
881
 
}
882
 
 
883
 
static void parse_origin(pj_scanner *scanner, pjmedia_sdp_session *ses,
884
 
                         parse_context *ctx)
885
 
{
886
 
    pj_str_t str;
887
 
 
888
 
    ctx->last_error = PJMEDIA_SDP_EINORIGIN;
889
 
 
890
 
    /* check equal sign */
891
 
    if (*(scanner->curptr+1) != '=') {
892
 
        on_scanner_error(scanner);
893
 
        return;
894
 
    }
895
 
 
896
 
    /* o= */
897
 
    pj_scan_advance_n(scanner, 2, SKIP_WS);
898
 
 
899
 
    /* username. */
900
 
    pj_scan_get_until_ch(scanner, ' ', &ses->origin.user);
901
 
    pj_scan_get_char(scanner);
902
 
 
903
 
    /* id */
904
 
    pj_scan_get_until_ch(scanner, ' ', &str);
905
 
    ses->origin.id = pj_strtoul(&str);
906
 
    pj_scan_get_char(scanner);
907
 
 
908
 
    /* version */
909
 
    pj_scan_get_until_ch(scanner, ' ', &str);
910
 
    ses->origin.version = pj_strtoul(&str);
911
 
    pj_scan_get_char(scanner);
912
 
 
913
 
    /* network-type */
914
 
    pj_scan_get_until_ch(scanner, ' ', &ses->origin.net_type);
915
 
    pj_scan_get_char(scanner);
916
 
 
917
 
    /* addr-type */
918
 
    pj_scan_get_until_ch(scanner, ' ', &ses->origin.addr_type);
919
 
    pj_scan_get_char(scanner);
920
 
 
921
 
    /* address */
922
 
    pj_scan_get_until_chr(scanner, " \t\r\n", &ses->origin.addr);
923
 
 
924
 
    /* We've got what we're looking for, skip anything until newline */
925
 
    pj_scan_skip_line(scanner);
926
 
 
927
 
}
928
 
 
929
 
static void parse_time(pj_scanner *scanner, pjmedia_sdp_session *ses,
930
 
                       parse_context *ctx)
931
 
{
932
 
    pj_str_t str;
933
 
 
934
 
    ctx->last_error = PJMEDIA_SDP_EINTIME;
935
 
 
936
 
    /* check equal sign */
937
 
    if (*(scanner->curptr+1) != '=') {
938
 
        on_scanner_error(scanner);
939
 
        return;
940
 
    }
941
 
 
942
 
    /* t= */
943
 
    pj_scan_advance_n(scanner, 2, SKIP_WS);
944
 
 
945
 
    /* start time */
946
 
    pj_scan_get_until_ch(scanner, ' ', &str);
947
 
    ses->time.start = pj_strtoul(&str);
948
 
 
949
 
    pj_scan_get_char(scanner);
950
 
 
951
 
    /* stop time */
952
 
    pj_scan_get_until_chr(scanner, " \t\r\n", &str);
953
 
    ses->time.stop = pj_strtoul(&str);
954
 
 
955
 
    /* We've got what we're looking for, skip anything until newline */
956
 
    pj_scan_skip_line(scanner);
957
 
}
958
 
 
959
 
static void parse_generic_line(pj_scanner *scanner, pj_str_t *str,
960
 
                               parse_context *ctx)
961
 
{
962
 
    ctx->last_error = PJMEDIA_SDP_EINSDP;
963
 
 
964
 
    /* check equal sign */
965
 
    if (*(scanner->curptr+1) != '=') {
966
 
        on_scanner_error(scanner);
967
 
        return;
968
 
    }
969
 
 
970
 
    /* x= */
971
 
    pj_scan_advance_n(scanner, 2, SKIP_WS);
972
 
 
973
 
    /* get anything until newline (including whitespaces). */
974
 
    pj_scan_get_until_chr(scanner, "\r\n", str);
975
 
 
976
 
    /* newline. */
977
 
    pj_scan_get_newline(scanner);
978
 
}
979
 
 
980
 
static void parse_connection_info(pj_scanner *scanner, pjmedia_sdp_conn *conn,
981
 
                                  parse_context *ctx)
982
 
{
983
 
    ctx->last_error = PJMEDIA_SDP_EINCONN;
984
 
 
985
 
    /* c= */
986
 
    pj_scan_advance_n(scanner, 2, SKIP_WS);
987
 
 
988
 
    /* network-type */
989
 
    pj_scan_get_until_ch(scanner, ' ', &conn->net_type);
990
 
    pj_scan_get_char(scanner);
991
 
 
992
 
    /* addr-type */
993
 
    pj_scan_get_until_ch(scanner, ' ', &conn->addr_type);
994
 
    pj_scan_get_char(scanner);
995
 
 
996
 
    /* address. */
997
 
    pj_scan_get_until_chr(scanner, "/ \t\r\n", &conn->addr);
998
 
    PJ_TODO(PARSE_SDP_CONN_ADDRESS_SUBFIELDS);
999
 
 
1000
 
    /* We've got what we're looking for, skip anything until newline */
1001
 
    pj_scan_skip_line(scanner);
1002
 
}
1003
 
 
1004
 
static void parse_bandwidth_info(pj_scanner *scanner, pjmedia_sdp_bandw *bandw,
1005
 
                                  parse_context *ctx)
1006
 
{
1007
 
    pj_str_t str;
1008
 
 
1009
 
    ctx->last_error = PJMEDIA_SDP_EINBANDW;
1010
 
 
1011
 
    /* b= */
1012
 
    pj_scan_advance_n(scanner, 2, SKIP_WS);
1013
 
 
1014
 
    /* modifier */
1015
 
    pj_scan_get_until_ch(scanner, ':', &bandw->modifier);
1016
 
    pj_scan_get_char(scanner);
1017
 
 
1018
 
    /* value */
1019
 
    pj_scan_get_until_chr(scanner, " \t\r\n", &str);
1020
 
    bandw->value = pj_strtoul(&str);
1021
 
 
1022
 
    /* We've got what we're looking for, skip anything until newline */
1023
 
    pj_scan_skip_line(scanner);
1024
 
}
1025
 
 
1026
 
static void parse_media(pj_scanner *scanner, pjmedia_sdp_media *med,
1027
 
                        parse_context *ctx)
1028
 
{
1029
 
    pj_str_t str;
1030
 
 
1031
 
    ctx->last_error = PJMEDIA_SDP_EINMEDIA;
1032
 
 
1033
 
    /* check the equal sign */
1034
 
    if (*(scanner->curptr+1) != '=') {
1035
 
        on_scanner_error(scanner);
1036
 
        return;
1037
 
    }
1038
 
 
1039
 
    /* m= */
1040
 
    pj_scan_advance_n(scanner, 2, SKIP_WS);
1041
 
 
1042
 
    /* type */
1043
 
    pj_scan_get_until_ch(scanner, ' ', &med->desc.media);
1044
 
    pj_scan_get_char(scanner);
1045
 
 
1046
 
    /* port */
1047
 
    pj_scan_get(scanner, &cs_token, &str);
1048
 
    med->desc.port = (unsigned short)pj_strtoul(&str);
1049
 
    if (*scanner->curptr == '/') {
1050
 
        /* port count */
1051
 
        pj_scan_get_char(scanner);
1052
 
        pj_scan_get(scanner, &cs_token, &str);
1053
 
        med->desc.port_count = pj_strtoul(&str);
1054
 
 
1055
 
    } else {
1056
 
        med->desc.port_count = 0;
1057
 
    }
1058
 
 
1059
 
    if (pj_scan_get_char(scanner) != ' ') {
1060
 
        PJ_THROW(SYNTAX_ERROR);
1061
 
    }
1062
 
 
1063
 
    /* transport */
1064
 
    pj_scan_get_until_chr(scanner, " \t\r\n", &med->desc.transport);
1065
 
 
1066
 
    /* format list */
1067
 
    med->desc.fmt_count = 0;
1068
 
    while (*scanner->curptr == ' ') {
1069
 
        pj_str_t fmt;
1070
 
 
1071
 
        pj_scan_get_char(scanner);
1072
 
 
1073
 
        /* Check again for the end of the line */
1074
 
        if ((*scanner->curptr == '\r') || (*scanner->curptr == '\n'))
1075
 
                break;
1076
 
 
1077
 
        pj_scan_get(scanner, &cs_token, &fmt);
1078
 
        if (med->desc.fmt_count < PJMEDIA_MAX_SDP_FMT)
1079
 
            med->desc.fmt[med->desc.fmt_count++] = fmt;
1080
 
        else
1081
 
            PJ_PERROR(2,(THIS_FILE, PJ_ETOOMANY, 
1082
 
                         "Error adding SDP media format %.*s, "
1083
 
                         "format is ignored",
1084
 
                         (int)fmt.slen, fmt.ptr));
1085
 
    }
1086
 
 
1087
 
    /* We've got what we're looking for, skip anything until newline */
1088
 
    pj_scan_skip_line(scanner);
1089
 
}
1090
 
 
1091
 
static void on_scanner_error(pj_scanner *scanner)
1092
 
{
1093
 
    PJ_UNUSED_ARG(scanner);
1094
 
 
1095
 
    PJ_THROW(SYNTAX_ERROR);
1096
 
}
1097
 
 
1098
 
static pjmedia_sdp_attr *parse_attr( pj_pool_t *pool, pj_scanner *scanner,
1099
 
                                    parse_context *ctx)
1100
 
{
1101
 
    pjmedia_sdp_attr *attr;
1102
 
 
1103
 
    ctx->last_error = PJMEDIA_SDP_EINATTR;
1104
 
 
1105
 
    attr = PJ_POOL_ALLOC_T(pool, pjmedia_sdp_attr);
1106
 
 
1107
 
    /* check equal sign */
1108
 
    if (*(scanner->curptr+1) != '=') {
1109
 
        on_scanner_error(scanner);
1110
 
        return NULL;
1111
 
    }
1112
 
 
1113
 
    /* skip a= */
1114
 
    pj_scan_advance_n(scanner, 2, SKIP_WS);
1115
 
    
1116
 
    /* get attr name. */
1117
 
    pj_scan_get(scanner, &cs_token, &attr->name);
1118
 
 
1119
 
    if (*scanner->curptr && *scanner->curptr != '\r' && 
1120
 
        *scanner->curptr != '\n') 
1121
 
    {
1122
 
        /* skip ':' if present. */
1123
 
        if (*scanner->curptr == ':')
1124
 
            pj_scan_get_char(scanner);
1125
 
 
1126
 
        /* get value */
1127
 
        if (*scanner->curptr != '\r' && *scanner->curptr != '\n') {
1128
 
            pj_scan_get_until_chr(scanner, "\r\n", &attr->value);
1129
 
        } else {
1130
 
            attr->value.ptr = NULL;
1131
 
            attr->value.slen = 0;
1132
 
        }
1133
 
 
1134
 
    } else {
1135
 
        attr->value.ptr = NULL;
1136
 
        attr->value.slen = 0;
1137
 
    }
1138
 
 
1139
 
    /* We've got what we're looking for, skip anything until newline */
1140
 
    pj_scan_skip_line(scanner);
1141
 
 
1142
 
    return attr;
1143
 
}
1144
 
 
1145
 
 
1146
 
/*
1147
 
 * Apply direction attribute in session to all media.
1148
 
 */
1149
 
static void apply_media_direction(pjmedia_sdp_session *sdp)
1150
 
{
1151
 
    pjmedia_sdp_attr *dir_attr = NULL;
1152
 
    unsigned i;
1153
 
 
1154
 
    const pj_str_t inactive = { "inactive", 8 };
1155
 
    const pj_str_t sendonly = { "sendonly", 8 };
1156
 
    const pj_str_t recvonly = { "recvonly", 8 };
1157
 
    const pj_str_t sendrecv = { "sendrecv", 8 };
1158
 
 
1159
 
    /* Find direction attribute in session, don't need to find default 
1160
 
     * direction "sendrecv".
1161
 
     */
1162
 
    for (i = 0; i < sdp->attr_count && !dir_attr; ++i) {
1163
 
        if (!pj_strcmp(&sdp->attr[i]->name, &sendonly) ||
1164
 
            !pj_strcmp(&sdp->attr[i]->name, &recvonly) ||
1165
 
            !pj_strcmp(&sdp->attr[i]->name, &inactive)) 
1166
 
        {
1167
 
            dir_attr = sdp->attr[i];
1168
 
        }
1169
 
    }
1170
 
 
1171
 
    /* Found the direction attribute */
1172
 
    if (dir_attr) {
1173
 
        /* Remove the direction attribute in session */
1174
 
        pjmedia_sdp_attr_remove(&sdp->attr_count, sdp->attr, dir_attr);
1175
 
 
1176
 
        /* Apply the direction attribute to all media, but not overriding it
1177
 
         * if media already has direction attribute.
1178
 
         */
1179
 
        for (i = 0; i < sdp->media_count; ++i) {
1180
 
            pjmedia_sdp_media *m;
1181
 
            unsigned j;
1182
 
 
1183
 
            /* Find direction attribute in this media */
1184
 
            m = sdp->media[i];
1185
 
            for (j = 0; j < m->attr_count; ++j) {
1186
 
                if (!pj_strcmp(&m->attr[j]->name, &sendrecv) ||
1187
 
                    !pj_strcmp(&m->attr[j]->name, &sendonly) ||
1188
 
                    !pj_strcmp(&m->attr[j]->name, &recvonly) ||
1189
 
                    !pj_strcmp(&m->attr[j]->name, &inactive)) 
1190
 
                {
1191
 
                    break;
1192
 
                }
1193
 
            }
1194
 
 
1195
 
            /* Not found, apply direction attribute from session */
1196
 
            if (j == m->attr_count)
1197
 
                pjmedia_sdp_media_add_attr(m, dir_attr);
1198
 
        }
1199
 
    }
1200
 
}
1201
 
 
1202
 
 
1203
 
/*
1204
 
 * Parse SDP message.
1205
 
 */
1206
 
PJ_DEF(pj_status_t) pjmedia_sdp_parse( pj_pool_t *pool,
1207
 
                                       char *buf, pj_size_t len, 
1208
 
                                       pjmedia_sdp_session **p_sdp)
1209
 
{
1210
 
    pj_scanner scanner;
1211
 
    pjmedia_sdp_session *session;
1212
 
    pjmedia_sdp_media *media = NULL;
1213
 
    pjmedia_sdp_attr *attr;
1214
 
    pjmedia_sdp_conn *conn;
1215
 
    pjmedia_sdp_bandw *bandw;
1216
 
    pj_str_t dummy;
1217
 
    int cur_name = 254;
1218
 
    parse_context ctx;
1219
 
    PJ_USE_EXCEPTION;
1220
 
 
1221
 
    ctx.last_error = PJ_SUCCESS;
1222
 
 
1223
 
    init_sdp_parser();
1224
 
 
1225
 
    pj_scan_init(&scanner, buf, len, 0, &on_scanner_error);
1226
 
    session = PJ_POOL_ZALLOC_T(pool, pjmedia_sdp_session);
1227
 
    PJ_ASSERT_RETURN(session != NULL, PJ_ENOMEM);
1228
 
 
1229
 
    /* Ignore leading newlines */
1230
 
    while (*scanner.curptr=='\r' || *scanner.curptr=='\n')
1231
 
        pj_scan_get_char(&scanner);
1232
 
 
1233
 
    PJ_TRY {
1234
 
        while (!pj_scan_is_eof(&scanner)) {
1235
 
                cur_name = *scanner.curptr;
1236
 
                switch (cur_name) {
1237
 
                case 'a':
1238
 
                    attr = parse_attr(pool, &scanner, &ctx);
1239
 
                    if (attr) {
1240
 
                        if (media) {
1241
 
                            pjmedia_sdp_media_add_attr(media, attr);
1242
 
                        } else {
1243
 
                            pjmedia_sdp_session_add_attr(session, attr);
1244
 
                        }
1245
 
                    }
1246
 
                    break;
1247
 
                case 'o':
1248
 
                    parse_origin(&scanner, session, &ctx);
1249
 
                    break;
1250
 
                case 's':
1251
 
                    parse_generic_line(&scanner, &session->name, &ctx);
1252
 
                    break;
1253
 
                case 'c':
1254
 
                    conn = PJ_POOL_ZALLOC_T(pool, pjmedia_sdp_conn);
1255
 
                    parse_connection_info(&scanner, conn, &ctx);
1256
 
                    if (media) {
1257
 
                        media->conn = conn;
1258
 
                    } else {
1259
 
                        session->conn = conn;
1260
 
                    }
1261
 
                    break;
1262
 
                case 't':
1263
 
                    parse_time(&scanner, session, &ctx);
1264
 
                    break;
1265
 
                case 'm':
1266
 
                    media = PJ_POOL_ZALLOC_T(pool, pjmedia_sdp_media);
1267
 
                    parse_media(&scanner, media, &ctx);
1268
 
                    if (session->media_count < PJMEDIA_MAX_SDP_MEDIA)
1269
 
                        session->media[ session->media_count++ ] = media;
1270
 
                    else
1271
 
                        PJ_PERROR(2,(THIS_FILE, PJ_ETOOMANY,
1272
 
                                     "Error adding media, media is ignored"));
1273
 
                    break;
1274
 
                case 'v':
1275
 
                    parse_version(&scanner, &ctx);
1276
 
                    break;
1277
 
                case 13:
1278
 
                case 10:
1279
 
                    pj_scan_get_char(&scanner);
1280
 
                    /* Allow empty newlines at the end of the message */
1281
 
                    while (!pj_scan_is_eof(&scanner)) {
1282
 
                        if (*scanner.curptr != 13 && *scanner.curptr != 10) {
1283
 
                            ctx.last_error = PJMEDIA_SDP_EINSDP;
1284
 
                            on_scanner_error(&scanner);
1285
 
                        }
1286
 
                        pj_scan_get_char(&scanner);
1287
 
                    }
1288
 
                    break;
1289
 
                case 'b':
1290
 
                    bandw = PJ_POOL_ZALLOC_T(pool, pjmedia_sdp_bandw);
1291
 
                    parse_bandwidth_info(&scanner, bandw, &ctx);
1292
 
                    if (media) {
1293
 
                        media->bandw[media->bandw_count++] = bandw;
1294
 
                    } else {
1295
 
                        session->bandw[session->bandw_count++] = bandw;
1296
 
                    }
1297
 
                    break;
1298
 
                default:
1299
 
                    if (cur_name >= 'a' && cur_name <= 'z')
1300
 
                        parse_generic_line(&scanner, &dummy, &ctx);
1301
 
                    else  {
1302
 
                        ctx.last_error = PJMEDIA_SDP_EINSDP;
1303
 
                        on_scanner_error(&scanner);
1304
 
                    }
1305
 
                    break;
1306
 
                }
1307
 
        }
1308
 
 
1309
 
        ctx.last_error = PJ_SUCCESS;
1310
 
 
1311
 
    }
1312
 
    PJ_CATCH_ANY {
1313
 
        
1314
 
        char errmsg[PJ_ERR_MSG_SIZE];
1315
 
        pj_strerror(ctx.last_error, errmsg, sizeof(errmsg));
1316
 
 
1317
 
        PJ_LOG(4, (THIS_FILE, "Error parsing SDP in line %d col %d: %s",
1318
 
                   scanner.line, pj_scan_get_col(&scanner),
1319
 
                   errmsg));
1320
 
 
1321
 
        session = NULL;
1322
 
 
1323
 
        pj_assert(ctx.last_error != PJ_SUCCESS);
1324
 
    }
1325
 
    PJ_END;
1326
 
 
1327
 
    pj_scan_fini(&scanner);
1328
 
 
1329
 
    if (session)
1330
 
        apply_media_direction(session);
1331
 
 
1332
 
    *p_sdp = session;
1333
 
    return ctx.last_error;
1334
 
}
1335
 
 
1336
 
/*
1337
 
 * Print SDP description.
1338
 
 */
1339
 
PJ_DEF(int) pjmedia_sdp_print( const pjmedia_sdp_session *desc, 
1340
 
                               char *buf, pj_size_t size)
1341
 
{
1342
 
    return print_session(desc, buf, size);
1343
 
}
1344
 
 
1345
 
 
1346
 
/*
1347
 
 * Clone session
1348
 
 */
1349
 
PJ_DEF(pjmedia_sdp_session*) pjmedia_sdp_session_clone( pj_pool_t *pool,
1350
 
                                                const pjmedia_sdp_session *rhs)
1351
 
{
1352
 
    pjmedia_sdp_session *sess;
1353
 
    unsigned i;
1354
 
 
1355
 
    PJ_ASSERT_RETURN(pool && rhs, NULL);
1356
 
 
1357
 
    sess = PJ_POOL_ZALLOC_T(pool, pjmedia_sdp_session);
1358
 
    PJ_ASSERT_RETURN(sess != NULL, NULL);
1359
 
 
1360
 
    /* Clone origin line. */
1361
 
    pj_strdup(pool, &sess->origin.user, &rhs->origin.user);
1362
 
    sess->origin.id = rhs->origin.id;
1363
 
    sess->origin.version = rhs->origin.version;
1364
 
    pj_strdup(pool, &sess->origin.net_type, &rhs->origin.net_type);
1365
 
    pj_strdup(pool, &sess->origin.addr_type, &rhs->origin.addr_type);
1366
 
    pj_strdup(pool, &sess->origin.addr, &rhs->origin.addr);
1367
 
 
1368
 
    /* Clone subject line. */
1369
 
    pj_strdup(pool, &sess->name, &rhs->name);
1370
 
 
1371
 
    /* Clone connection line */
1372
 
    if (rhs->conn) {
1373
 
        sess->conn = pjmedia_sdp_conn_clone(pool, rhs->conn);
1374
 
        PJ_ASSERT_RETURN(sess->conn != NULL, NULL);
1375
 
    }
1376
 
 
1377
 
    /* Duplicate bandwidth info */
1378
 
    sess->bandw_count = rhs->bandw_count;
1379
 
    for (i=0; i<rhs->bandw_count; ++i) {
1380
 
        sess->bandw[i] = pjmedia_sdp_bandw_clone(pool, rhs->bandw[i]);
1381
 
    }
1382
 
 
1383
 
    /* Clone time line. */
1384
 
    sess->time.start = rhs->time.start;
1385
 
    sess->time.stop = rhs->time.stop;
1386
 
 
1387
 
    /* Duplicate session attributes. */
1388
 
    sess->attr_count = rhs->attr_count;
1389
 
    for (i=0; i<rhs->attr_count; ++i) {
1390
 
        sess->attr[i] = pjmedia_sdp_attr_clone(pool, rhs->attr[i]);
1391
 
    }
1392
 
 
1393
 
    /* Duplicate media descriptors. */
1394
 
    sess->media_count = rhs->media_count;
1395
 
    for (i=0; i<rhs->media_count; ++i) {
1396
 
        sess->media[i] = pjmedia_sdp_media_clone(pool, rhs->media[i]);
1397
 
    }
1398
 
 
1399
 
    return sess;
1400
 
}
1401
 
 
1402
 
 
1403
 
#define CHECK(exp,ret)  do {                    \
1404
 
                            /*pj_assert(exp);*/ \
1405
 
                            if (!(exp))         \
1406
 
                                return ret;     \
1407
 
                        } while (0)
1408
 
 
1409
 
/* Validate SDP connetion info. */
1410
 
static pj_status_t validate_sdp_conn(const pjmedia_sdp_conn *c)
1411
 
{
1412
 
    CHECK( c, PJ_EINVAL);
1413
 
    CHECK( pj_strcmp2(&c->net_type, "IN")==0, PJMEDIA_SDP_EINCONN);
1414
 
    CHECK( pj_strcmp2(&c->addr_type, "IP4")==0 ||
1415
 
           pj_strcmp2(&c->addr_type, "IP6")==0, 
1416
 
           PJMEDIA_SDP_EINCONN);
1417
 
    CHECK( c->addr.slen != 0, PJMEDIA_SDP_EINCONN);
1418
 
 
1419
 
    return PJ_SUCCESS;
1420
 
}
1421
 
 
1422
 
 
1423
 
/* Validate SDP session descriptor. */
1424
 
PJ_DEF(pj_status_t) pjmedia_sdp_validate(const pjmedia_sdp_session *sdp)
1425
 
{
1426
 
    return pjmedia_sdp_validate2(sdp, PJ_TRUE);
1427
 
}
1428
 
 
1429
 
 
1430
 
/* Validate SDP session descriptor. */
1431
 
PJ_DEF(pj_status_t) pjmedia_sdp_validate2(const pjmedia_sdp_session *sdp,
1432
 
                                          pj_bool_t strict)
1433
 
{
1434
 
    unsigned i;
1435
 
    const pj_str_t STR_RTPMAP = { "rtpmap", 6 };
1436
 
 
1437
 
    CHECK( sdp != NULL, PJ_EINVAL);
1438
 
 
1439
 
    /* Validate origin line. */
1440
 
    CHECK( sdp->origin.user.slen != 0, PJMEDIA_SDP_EINORIGIN);
1441
 
    CHECK( pj_strcmp2(&sdp->origin.net_type, "IN")==0, 
1442
 
           PJMEDIA_SDP_EINORIGIN);
1443
 
    CHECK( pj_strcmp2(&sdp->origin.addr_type, "IP4")==0 ||
1444
 
           pj_strcmp2(&sdp->origin.addr_type, "IP6")==0, 
1445
 
           PJMEDIA_SDP_EINORIGIN);
1446
 
    CHECK( sdp->origin.addr.slen != 0, PJMEDIA_SDP_EINORIGIN);
1447
 
 
1448
 
    /* Validate subject line. */
1449
 
    CHECK( sdp->name.slen != 0, PJMEDIA_SDP_EINNAME);
1450
 
 
1451
 
    /* Ignore start and stop time. */
1452
 
 
1453
 
    /* If session level connection info is present, validate it. */
1454
 
    if (sdp->conn) {
1455
 
        pj_status_t status = validate_sdp_conn(sdp->conn);
1456
 
        if (status != PJ_SUCCESS)
1457
 
            return status;
1458
 
    }
1459
 
 
1460
 
    /* Validate each media. */
1461
 
    for (i=0; i<sdp->media_count; ++i) {
1462
 
        const pjmedia_sdp_media *m = sdp->media[i];
1463
 
        unsigned j;
1464
 
 
1465
 
        /* Validate the m= line. */
1466
 
        CHECK( m->desc.media.slen != 0, PJMEDIA_SDP_EINMEDIA);
1467
 
        CHECK( m->desc.transport.slen != 0, PJMEDIA_SDP_EINMEDIA);
1468
 
        CHECK( m->desc.fmt_count != 0 || m->desc.port==0, PJMEDIA_SDP_ENOFMT);
1469
 
 
1470
 
        /* If media level connection info is present, validate it. */
1471
 
        if (m->conn) {
1472
 
            pj_status_t status = validate_sdp_conn(m->conn);
1473
 
            if (status != PJ_SUCCESS)
1474
 
                return status;
1475
 
        }
1476
 
 
1477
 
        /* If media doesn't have connection info, then connection info
1478
 
         * must be present in the session.
1479
 
         */
1480
 
        if (m->conn == NULL) {
1481
 
            if (sdp->conn == NULL)
1482
 
                if (strict || m->desc.port != 0)
1483
 
                    return PJMEDIA_SDP_EMISSINGCONN;
1484
 
        }
1485
 
 
1486
 
        /* Verify payload type. */
1487
 
        for (j=0; j<m->desc.fmt_count; ++j) {
1488
 
 
1489
 
            /* Arrgh noo!! Payload type can be non-numeric!!
1490
 
             * RTC based programs sends "null" for instant messaging!
1491
 
             */
1492
 
            if (pj_isdigit(*m->desc.fmt[j].ptr)) {
1493
 
                unsigned pt = pj_strtoul(&m->desc.fmt[j]);
1494
 
 
1495
 
                /* Payload type is between 0 and 127. 
1496
 
                 */
1497
 
                CHECK( pt <= 127, PJMEDIA_SDP_EINPT);
1498
 
 
1499
 
                /* If port is not zero, then for each dynamic payload type, an
1500
 
                 * rtpmap attribute must be specified.
1501
 
                 */
1502
 
                if (m->desc.port != 0 && pt >= 96) {
1503
 
                    const pjmedia_sdp_attr *a;
1504
 
 
1505
 
                    a = pjmedia_sdp_media_find_attr(m, &STR_RTPMAP, 
1506
 
                                                    &m->desc.fmt[j]);
1507
 
                    CHECK( a != NULL, PJMEDIA_SDP_EMISSINGRTPMAP);
1508
 
                }
1509
 
            }
1510
 
        }
1511
 
    }
1512
 
 
1513
 
    /* Looks good. */
1514
 
    return PJ_SUCCESS;
1515
 
}
1516
 
 
1517
 
 
1518
 
PJ_DEF(pj_status_t) pjmedia_sdp_transport_cmp( const pj_str_t *t1,
1519
 
                                               const pj_str_t *t2)
1520
 
{
1521
 
    static const pj_str_t ID_RTP_AVP  = { "RTP/AVP", 7 };
1522
 
    static const pj_str_t ID_RTP_SAVP = { "RTP/SAVP", 8 };
1523
 
 
1524
 
    /* Exactly equal? */
1525
 
    if (pj_stricmp(t1, t2) == 0)
1526
 
        return PJ_SUCCESS;
1527
 
 
1528
 
    /* Compatible? */
1529
 
    if ((!pj_stricmp(t1, &ID_RTP_AVP) || !pj_stricmp(t1, &ID_RTP_SAVP)) &&
1530
 
        (!pj_stricmp(t2, &ID_RTP_AVP) || !pj_stricmp(t2, &ID_RTP_SAVP)))
1531
 
        return PJ_SUCCESS;
1532
 
 
1533
 
    return PJMEDIA_SDP_ETPORTNOTEQUAL;
1534
 
}
1535
 
 
1536
 
 
1537
 
PJ_DEF(pj_status_t) pjmedia_sdp_media_deactivate(pj_pool_t *pool,
1538
 
                                                 pjmedia_sdp_media *m)
1539
 
{
1540
 
    PJ_ASSERT_RETURN(m, PJ_EINVAL);
1541
 
    PJ_UNUSED_ARG(pool);
1542
 
 
1543
 
    /* Set port to zero */
1544
 
    m->desc.port = 0;
1545
 
 
1546
 
    /* And remove attributes */
1547
 
    m->attr_count = 0;
1548
 
 
1549
 
    return PJ_SUCCESS;
1550
 
}
1551
 
 
1552
 
 
1553
 
PJ_DEF(pjmedia_sdp_media*) pjmedia_sdp_media_clone_deactivate(
1554
 
                                                pj_pool_t *pool,
1555
 
                                                const pjmedia_sdp_media *rhs)
1556
 
{
1557
 
    unsigned int i;
1558
 
    pjmedia_sdp_media *m;
1559
 
 
1560
 
    PJ_ASSERT_RETURN(pool && rhs, NULL);
1561
 
 
1562
 
    m = PJ_POOL_ZALLOC_T(pool, pjmedia_sdp_media);
1563
 
    pj_memcpy(m, rhs, sizeof(*m));
1564
 
 
1565
 
    /* Clone the media line only */
1566
 
    pj_strdup (pool, &m->desc.media, &rhs->desc.media);
1567
 
    pj_strdup (pool, &m->desc.transport, &rhs->desc.transport);
1568
 
    for (i=0; i<rhs->desc.fmt_count; ++i)
1569
 
        pj_strdup(pool, &m->desc.fmt[i], &rhs->desc.fmt[i]);
1570
 
 
1571
 
    if (rhs->conn) {
1572
 
        m->conn = pjmedia_sdp_conn_clone (pool, rhs->conn);
1573
 
        PJ_ASSERT_RETURN(m->conn != NULL, NULL);
1574
 
    }
1575
 
 
1576
 
    m->bandw_count = rhs->bandw_count;
1577
 
    for (i=0; i < rhs->bandw_count; ++i) {
1578
 
        m->bandw[i] = pjmedia_sdp_bandw_clone (pool, rhs->bandw[i]);
1579
 
        PJ_ASSERT_RETURN(m->bandw[i] != NULL, NULL);
1580
 
    }
1581
 
 
1582
 
    /* And deactivate it */
1583
 
    pjmedia_sdp_media_deactivate(pool, m);
1584
 
 
1585
 
    return m;
1586
 
}