diff options
author | Benny Prijono <bennylp@teluu.com> | 2006-02-07 12:34:58 +0000 |
---|---|---|
committer | Benny Prijono <bennylp@teluu.com> | 2006-02-07 12:34:58 +0000 |
commit | da1de0865a23a7eb5cde2b4160979164dbc08a39 (patch) | |
tree | 743e536bd0159318ba904b471d574fdd9dd9f521 /pjmedia/src | |
parent | 9cded7c4883dc2eccfddf1b74b8175ac179d5703 (diff) |
Added STATE_REMOTE_OFFER state in negotiator
git-svn-id: http://svn.pjsip.org/repos/pjproject/trunk@140 74dad513-b988-da41-8d7b-12977e46ad98
Diffstat (limited to 'pjmedia/src')
-rw-r--r-- | pjmedia/src/pjmedia/errno.c | 3 | ||||
-rw-r--r-- | pjmedia/src/pjmedia/sdp.c | 3 | ||||
-rw-r--r-- | pjmedia/src/pjmedia/sdp_neg.c | 140 |
3 files changed, 108 insertions, 38 deletions
diff --git a/pjmedia/src/pjmedia/errno.c b/pjmedia/src/pjmedia/errno.c index ccf5c8d8..e42b5444 100644 --- a/pjmedia/src/pjmedia/errno.c +++ b/pjmedia/src/pjmedia/errno.c @@ -53,11 +53,14 @@ static const struct /* SDP negotiator errors. */ { PJMEDIA_SDPNEG_EINSTATE, "Invalid SDP negotiator state for operation" }, + { PJMEDIA_SDPNEG_ENOINITIAL, "No initial local SDP in SDP negotiator" }, { PJMEDIA_SDPNEG_ENOACTIVE, "No active SDP in SDP negotiator" }, + { PJMEDIA_SDPNEG_ENONEG, "No current local/remote offer/answer" }, { PJMEDIA_SDPNEG_EMISMEDIA, "SDP media count mismatch in offer/answer" }, { PJMEDIA_SDPNEG_EINVANSMEDIA, "SDP media type mismatch in offer/answer" }, { PJMEDIA_SDPNEG_EINVANSTP, "SDP media transport type mismatch in offer/answer" }, { PJMEDIA_SDPNEG_EANSNOMEDIA, "No common SDP media payload in answer" }, + { PJMEDIA_SDPNEG_ENOMEDIA, "No active media stream after negotiation" }, /* SDP comparison results */ { PJMEDIA_SDP_EMEDIANOTEQUAL, "SDP media descriptor not equal" }, diff --git a/pjmedia/src/pjmedia/sdp.c b/pjmedia/src/pjmedia/sdp.c index 2f6dcfe3..edd83aa5 100644 --- a/pjmedia/src/pjmedia/sdp.c +++ b/pjmedia/src/pjmedia/sdp.c @@ -1093,6 +1093,7 @@ static pj_status_t validate_sdp_conn(const pjmedia_sdp_conn *c) PJ_DEF(pj_status_t) pjmedia_sdp_validate(const pjmedia_sdp_session *sdp) { unsigned i; + const pj_str_t STR_RTPMAP = { "rtpmap", 6 }; CHECK( sdp != NULL, PJ_EINVAL); @@ -1155,7 +1156,7 @@ PJ_DEF(pj_status_t) pjmedia_sdp_validate(const pjmedia_sdp_session *sdp) if (m->desc.port != 0 && pt >= 96) { const pjmedia_sdp_attr *a; - a = pjmedia_sdp_media_find_attr2(m, "rtpmap", &m->desc.fmt[j]); + a = pjmedia_sdp_media_find_attr(m,&STR_RTPMAP,&m->desc.fmt[j]); CHECK( a != NULL, PJMEDIA_SDP_EMISSINGRTPMAP); } } diff --git a/pjmedia/src/pjmedia/sdp_neg.c b/pjmedia/src/pjmedia/sdp_neg.c index 313fff99..37cf5f9c 100644 --- a/pjmedia/src/pjmedia/sdp_neg.c +++ b/pjmedia/src/pjmedia/sdp_neg.c @@ -77,7 +77,7 @@ pjmedia_sdp_neg_create_w_local_offer( pj_pool_t *pool, */ PJ_DEF(pj_status_t) pjmedia_sdp_neg_create_w_remote_offer(pj_pool_t *pool, - const pjmedia_sdp_session *local, + const pjmedia_sdp_session *initial, const pjmedia_sdp_session *remote, pjmedia_sdp_neg **p_neg) { @@ -85,29 +85,35 @@ pjmedia_sdp_neg_create_w_remote_offer(pj_pool_t *pool, pj_status_t status; /* Check arguments are valid. */ - PJ_ASSERT_RETURN(pool && local && remote && p_neg, PJ_EINVAL); + PJ_ASSERT_RETURN(pool && remote && p_neg, PJ_EINVAL); *p_neg = NULL; - /* Validate remote offer and local answer */ + /* Validate remote offer and initial answer */ status = pjmedia_sdp_validate(remote); if (status != PJ_SUCCESS) return status; - PJ_ASSERT_RETURN((status=pjmedia_sdp_validate(local))==PJ_SUCCESS, status); /* Create and initialize negotiator. */ neg = pj_pool_zalloc(pool, sizeof(pjmedia_sdp_neg)); PJ_ASSERT_RETURN(neg != NULL, PJ_ENOMEM); - neg->state = PJMEDIA_SDP_NEG_STATE_WAIT_NEGO; - neg->initial_sdp = pjmedia_sdp_session_clone(pool, local); - PJ_ASSERT_RETURN((status=pjmedia_sdp_validate(neg->initial_sdp))==PJ_SUCCESS, - status); - - neg->neg_local_sdp = pjmedia_sdp_session_clone(pool, local); neg->neg_remote_sdp = pjmedia_sdp_session_clone(pool, remote); - PJ_ASSERT_RETURN((status=pjmedia_sdp_validate(neg->neg_remote_sdp))==PJ_SUCCESS, - status); + + if (initial) { + PJ_ASSERT_RETURN((status=pjmedia_sdp_validate(initial))==PJ_SUCCESS, + status); + + neg->initial_sdp = pjmedia_sdp_session_clone(pool, initial); + neg->neg_local_sdp = pjmedia_sdp_session_clone(pool, initial); + + neg->state = PJMEDIA_SDP_NEG_STATE_WAIT_NEGO; + + } else { + + neg->state = PJMEDIA_SDP_NEG_STATE_REMOTE_OFFER; + + } *p_neg = neg; return PJ_SUCCESS; @@ -126,8 +132,8 @@ pjmedia_sdp_neg_get_state( pjmedia_sdp_neg *neg ) PJ_DEF(pj_status_t) -pjmedia_sdp_neg_get_local( pjmedia_sdp_neg *neg, - const pjmedia_sdp_session **local) +pjmedia_sdp_neg_get_active_local( pjmedia_sdp_neg *neg, + const pjmedia_sdp_session **local) { PJ_ASSERT_RETURN(neg && local, PJ_EINVAL); PJ_ASSERT_RETURN(neg->active_local_sdp, PJMEDIA_SDPNEG_ENOACTIVE); @@ -138,8 +144,8 @@ pjmedia_sdp_neg_get_local( pjmedia_sdp_neg *neg, PJ_DEF(pj_status_t) -pjmedia_sdp_neg_get_remote( pjmedia_sdp_neg *neg, - const pjmedia_sdp_session **remote) +pjmedia_sdp_neg_get_active_remote( pjmedia_sdp_neg *neg, + const pjmedia_sdp_session **remote) { PJ_ASSERT_RETURN(neg && remote, PJ_EINVAL); PJ_ASSERT_RETURN(neg->active_remote_sdp, PJMEDIA_SDPNEG_ENOACTIVE); @@ -148,6 +154,28 @@ pjmedia_sdp_neg_get_remote( pjmedia_sdp_neg *neg, return PJ_SUCCESS; } +PJ_DEF(pj_status_t) +pjmedia_sdp_neg_get_neg_remote( pjmedia_sdp_neg *neg, + const pjmedia_sdp_session **remote) +{ + PJ_ASSERT_RETURN(neg && remote, PJ_EINVAL); + PJ_ASSERT_RETURN(neg->neg_remote_sdp, PJMEDIA_SDPNEG_ENONEG); + + *remote = neg->neg_remote_sdp; + return PJ_SUCCESS; +} + +PJ_DEF(pj_status_t) +pjmedia_sdp_neg_get_neg_local( pjmedia_sdp_neg *neg, + const pjmedia_sdp_session **local) +{ + PJ_ASSERT_RETURN(neg && local, PJ_EINVAL); + PJ_ASSERT_RETURN(neg->neg_local_sdp, PJMEDIA_SDPNEG_ENONEG); + + *local = neg->neg_local_sdp; + return PJ_SUCCESS; +} + /* * Modify local SDP and wait for remote answer. @@ -174,9 +202,9 @@ pjmedia_sdp_neg_modify_local_offer( pj_pool_t *pool, PJ_DEF(pj_status_t) -pjmedia_sdp_neg_tx_local_offer( pj_pool_t *pool, - pjmedia_sdp_neg *neg, - const pjmedia_sdp_session **offer) +pjmedia_sdp_neg_send_local_offer( pj_pool_t *pool, + pjmedia_sdp_neg *neg, + const pjmedia_sdp_session **offer) { /* Check arguments are valid. */ PJ_ASSERT_RETURN(neg && offer, PJ_EINVAL); @@ -210,47 +238,74 @@ pjmedia_sdp_neg_tx_local_offer( pj_pool_t *pool, PJ_DEF(pj_status_t) -pjmedia_sdp_neg_rx_remote_offer( pj_pool_t *pool, - pjmedia_sdp_neg *neg, - const pjmedia_sdp_session *remote) +pjmedia_sdp_neg_set_remote_answer( pj_pool_t *pool, + pjmedia_sdp_neg *neg, + const pjmedia_sdp_session *remote) { /* Check arguments are valid. */ PJ_ASSERT_RETURN(pool && neg && remote, PJ_EINVAL); - /* Can only do this in STATE_DONE. - * If we already provide local offer, then rx_remote_answer() should + /* Can only do this in STATE_LOCAL_OFFER. + * If we haven't provided local offer, then rx_remote_offer() should * be called instead of this function. */ - PJ_ASSERT_RETURN(neg->state == PJMEDIA_SDP_NEG_STATE_DONE, + PJ_ASSERT_RETURN(neg->state == PJMEDIA_SDP_NEG_STATE_LOCAL_OFFER, PJMEDIA_SDPNEG_EINSTATE); /* We're ready to negotiate. */ neg->state = PJMEDIA_SDP_NEG_STATE_WAIT_NEGO; + neg->has_remote_answer = 1; neg->neg_remote_sdp = pjmedia_sdp_session_clone(pool, remote); - + return PJ_SUCCESS; } PJ_DEF(pj_status_t) -pjmedia_sdp_neg_rx_remote_answer( pj_pool_t *pool, +pjmedia_sdp_neg_set_remote_offer( pj_pool_t *pool, pjmedia_sdp_neg *neg, const pjmedia_sdp_session *remote) { /* Check arguments are valid. */ PJ_ASSERT_RETURN(pool && neg && remote, PJ_EINVAL); - /* Can only do this in STATE_LOCAL_OFFER. - * If we haven't provided local offer, then rx_remote_offer() should + /* Can only do this in STATE_DONE. + * If we already provide local offer, then rx_remote_answer() should * be called instead of this function. */ - PJ_ASSERT_RETURN(neg->state == PJMEDIA_SDP_NEG_STATE_LOCAL_OFFER, + PJ_ASSERT_RETURN(neg->state == PJMEDIA_SDP_NEG_STATE_DONE, PJMEDIA_SDPNEG_EINSTATE); - /* We're ready to negotiate. */ - neg->state = PJMEDIA_SDP_NEG_STATE_WAIT_NEGO; - neg->has_remote_answer = 1; + /* State now is STATE_REMOTE_OFFER. */ + neg->state = PJMEDIA_SDP_NEG_STATE_REMOTE_OFFER; neg->neg_remote_sdp = pjmedia_sdp_session_clone(pool, remote); - + + return PJ_SUCCESS; +} + +PJ_DEF(pj_status_t) +pjmedia_sdp_neg_set_local_answer( pj_pool_t *pool, + pjmedia_sdp_neg *neg, + const pjmedia_sdp_session *local) +{ + /* Check arguments are valid. */ + PJ_ASSERT_RETURN(pool && neg && local, PJ_EINVAL); + + /* Can only do this in STATE_REMOTE_OFFER. + * If we already provide local offer, then rx_remote_answer() should + * be called instead of this function. + */ + PJ_ASSERT_RETURN(neg->state == PJMEDIA_SDP_NEG_STATE_REMOTE_OFFER, + PJMEDIA_SDPNEG_EINSTATE); + + /* State now is STATE_WAIT_NEGO. */ + neg->state = PJMEDIA_SDP_NEG_STATE_WAIT_NEGO; + if (local) + neg->neg_local_sdp = pjmedia_sdp_session_clone(pool, local); + else { + PJ_ASSERT_RETURN(neg->initial_sdp, PJMEDIA_SDPNEG_ENOINITIAL); + neg->neg_local_sdp = pjmedia_sdp_session_clone(pool, neg->initial_sdp); + } + return PJ_SUCCESS; } @@ -463,6 +518,7 @@ static pj_status_t process_answer(pj_pool_t *pool, pjmedia_sdp_session **p_active) { unsigned mi; + pj_bool_t has_active = PJ_FALSE; pj_status_t status; /* Check arguments. */ @@ -478,10 +534,14 @@ static pj_status_t process_answer(pj_pool_t *pool, allow_asym); if (status != PJ_SUCCESS) return status; + + if (offer->media[mi]->desc.port != 0) + has_active = PJ_TRUE; } *p_active = offer; - return PJ_SUCCESS; + + return has_active ? PJ_SUCCESS : PJMEDIA_SDPNEG_ENOMEDIA; } /* Try to match offer with answer. */ @@ -674,6 +734,7 @@ static pj_status_t create_answer( pj_pool_t *pool, pjmedia_sdp_session **p_answer) { pj_status_t status; + pj_bool_t has_active = PJ_FALSE; pjmedia_sdp_session *answer; char media_used[PJSDP_MAX_MEDIA]; unsigned i; @@ -748,10 +809,15 @@ static pj_status_t create_answer( pj_pool_t *pool, /* Add the media answer */ answer->media[answer->media_count++] = am; + + /* Check if this media is active.*/ + if (am->desc.port != 0) + has_active = PJ_TRUE; } *p_answer = answer; - return PJ_SUCCESS; + + return has_active ? PJ_SUCCESS : PJMEDIA_SDPNEG_ENOMEDIA; } /* The best bit: SDP negotiation function! */ @@ -784,7 +850,7 @@ PJ_DEF(pj_status_t) pjmedia_sdp_neg_negotiate( pj_pool_t *pool, } else { pjmedia_sdp_session *answer; - status = create_answer(pool, neg->initial_sdp, neg->neg_remote_sdp, + status = create_answer(pool, neg->neg_local_sdp, neg->neg_remote_sdp, &answer); if (status == PJ_SUCCESS) { pj_uint32_t active_ver; |