Changeset 1860


Ignore:
Timestamp:
Mar 11, 2008 9:38:05 PM (17 years ago)
Author:
bennylp
Message:

Ticket #479: allow media transport framework to return transport specific info (for example, to know whether SRTP is enabled)

Location:
pjproject/trunk
Files:
11 edited

Legend:

Unmodified
Added
Removed

  • pjproject/trunk/pjmedia/include/pjmedia/config.h

    r1859 r1860  
    526526 
    527527/** 
     528 * Transport info (pjmedia_transport_info) contains a socket info and list 
     529 * of transport specific info, since transports can be chained together  
     530 * (for example, SRTP transport uses UDP transport as the underlying  
     531 * transport). This constant specifies maximum number of transport specific 
     532 * infos that can be held in a transport info. 
     533 */ 
     534#ifndef PJMEDIA_TRANSPORT_SPECIFIC_INFO_MAXCNT 
     535#   define PJMEDIA_TRANSPORT_SPECIFIC_INFO_MAXCNT   4 
     536#endif 
     537 
     538 
     539/** 
     540 * Maximum size in bytes of storage buffer of a transport specific info. 
     541 */ 
     542#ifndef PJMEDIA_TRANSPORT_SPECIFIC_INFO_MAXSIZE 
     543#   define PJMEDIA_TRANSPORT_SPECIFIC_INFO_MAXSIZE  (12*sizeof(long)) 
     544#endif 
     545 
     546 
     547 
     548/** 
    528549 * @} 
    529550 */ 

  • pjproject/trunk/pjmedia/include/pjmedia/transport.h

    r1810 r1860  
    208208#include <pjmedia/sdp.h> 
    209209 
     210 
    210211/** 
    211212 * Forward declaration for media transport. 
    212213 */ 
    213214typedef struct pjmedia_transport pjmedia_transport; 
     215 
     216/** 
     217 * Forward declaration for media transport info. 
     218 */ 
     219typedef struct pjmedia_transport_info pjmedia_transport_info; 
    214220 
    215221/** 
    … …  
    229235} pjmedia_tranport_media_option; 
    230236 
     237 
    231238/** 
    232239 * This structure describes the operations for the stream transport. 
    … …  
    240247     */ 
    241248    pj_status_t (*get_info)(pjmedia_transport *tp, 
    242                             pjmedia_sock_info *info); 
     249                            pjmedia_transport_info *info); 
    243250 
    244251    /** 
    … …  
    369376 
    370377    /** Media transport using ICE */ 
    371     PJMEDIA_TRANSPORT_TYPE_ICE 
     378    PJMEDIA_TRANSPORT_TYPE_ICE, 
     379 
     380    /**  
     381     * Media transport SRTP, this transport is actually security adapter to be 
     382     * stacked with other transport to enable encryption on the underlying 
     383     * transport. 
     384     */ 
     385    PJMEDIA_TRANSPORT_TYPE_SRTP 
    372386 
    373387} pjmedia_transport_type; 
    … …  
    389403    /** Transport's "virtual" function table. */ 
    390404    pjmedia_transport_op    *op; 
     405}; 
     406 
     407/** 
     408 * This structure describes buffer storage of transport specific info. 
     409 * The actual transport specific info contents will be defined by transport 
     410 * implementation. Note that some transport implementations do not need to 
     411 * provide specific info, since the general socket info is enough. 
     412 */ 
     413typedef struct pjmedia_transport_specific_info 
     414{ 
     415    /** 
     416     * Specify media transport type. 
     417     */ 
     418    pjmedia_transport_type   type; 
     419 
     420    /** 
     421     * Specify storage buffer size of transport specific info. 
     422     */ 
     423    int                      cbsize; 
     424 
     425    /** 
     426     * Storage buffer of transport specific info. 
     427     */ 
     428    char                     buffer[PJMEDIA_TRANSPORT_SPECIFIC_INFO_MAXSIZE]; 
     429 
     430} pjmedia_transport_specific_info; 
     431 
     432 
     433/** 
     434 * This structure describes transport informations, including general  
     435 * socket information and specific information of single transport or  
     436 * stacked transports (e.g: SRTP stacked on top of UDP) 
     437 */ 
     438struct pjmedia_transport_info 
     439{ 
     440    /** 
     441     * General socket info. 
     442     */ 
     443    pjmedia_sock_info sock_info; 
     444 
     445    /** 
     446     * Specifies number of transport specific info included. 
     447     */ 
     448    int specific_info_cnt; 
     449 
     450    /** 
     451     * Buffer storage of transport specific info. 
     452     */ 
     453    pjmedia_transport_specific_info spc_info[PJMEDIA_TRANSPORT_SPECIFIC_INFO_MAXCNT]; 
     454 
    391455}; 
    392456 
    … …  
    404468 */ 
    405469PJ_INLINE(pj_status_t) pjmedia_transport_get_info(pjmedia_transport *tp, 
    406                                                   pjmedia_sock_info *info) 
     470                                                  pjmedia_transport_info *info) 
    407471{ 
    408472    if (tp->op->get_info) 

  • pjproject/trunk/pjmedia/include/pjmedia/transport_srtp.h

    r1763 r1860  
    161161 
    162162/** 
     163 * This structure specifies SRTP transport specific info. This will fit 
     164 * into \a buffer field of pjmedia_transport_specific_info. 
     165 */ 
     166typedef struct pjmedia_srtp_info 
     167{ 
     168    /** 
     169     * Specify whether the SRTP transport is active for SRTP session. 
     170     */ 
     171    pj_bool_t                   active; 
     172 
     173    /** 
     174     * Specify the policy used by the SRTP session for receive direction. 
     175     */ 
     176    pjmedia_srtp_crypto         rx_policy; 
     177 
     178    /** 
     179     * Specify the policy used by the SRTP session for transmit direction. 
     180     */ 
     181    pjmedia_srtp_crypto         tx_policy; 
     182 
     183} pjmedia_srtp_info; 
     184 
     185 
     186/** 
    163187 * Initialize SRTP setting with its default values. 
    164188 * 

  • pjproject/trunk/pjmedia/src/pjmedia/transport_ice.c

    r1810 r1860  
    5656 */ 
    5757static pj_status_t transport_get_info (pjmedia_transport *tp, 
    58                                        pjmedia_sock_info *info); 
     58                                       pjmedia_transport_info *info); 
    5959static pj_status_t transport_attach   (pjmedia_transport *tp, 
    6060                                       void *user_data, 
    … …  
    674674 
    675675static pj_status_t transport_get_info(pjmedia_transport *tp, 
    676                                       pjmedia_sock_info *info) 
     676                                      pjmedia_transport_info *info) 
    677677{ 
    678678    struct transport_ice *tp_ice = (struct transport_ice*)tp; 
    … …  
    680680    pj_ice_strans_comp *comp; 
    681681 
    682     pj_bzero(info, sizeof(*info)); 
    683     info->rtp_sock = info->rtcp_sock = PJ_INVALID_SOCKET; 
     682    pj_bzero(&info->sock_info, sizeof(info->sock_info)); 
     683    info->sock_info.rtp_sock = info->sock_info.rtcp_sock = PJ_INVALID_SOCKET; 
    684684 
    685685    /* Retrieve address of default candidate for component 1 (RTP) */ 
    686686    comp = ice_st->comp[0]; 
    687687    pj_assert(comp->default_cand >= 0); 
    688     info->rtp_sock = comp->sock; 
    689     pj_memcpy(&info->rtp_addr_name,  
     688    info->sock_info.rtp_sock = comp->sock; 
     689    pj_memcpy(&info->sock_info.rtp_addr_name,  
    690690              &comp->cand_list[comp->default_cand].addr, 
    691691              sizeof(pj_sockaddr_in)); 
    … …  
    695695        comp = ice_st->comp[1]; 
    696696        pj_assert(comp->default_cand >= 0); 
    697         info->rtp_sock = comp->sock; 
    698         pj_memcpy(&info->rtcp_addr_name,  
     697        info->sock_info.rtp_sock = comp->sock; 
     698        pj_memcpy(&info->sock_info.rtcp_addr_name,  
    699699                  &comp->cand_list[comp->default_cand].addr, 
    700700                  sizeof(pj_sockaddr_in)); 
    701701    } 
    702702 
     703    info->specific_info_cnt = 0; 
    703704 
    704705    return PJ_SUCCESS; 

  • pjproject/trunk/pjmedia/src/pjmedia/transport_srtp.c

    r1810 r1860  
    126126 */ 
    127127static pj_status_t transport_get_info (pjmedia_transport *tp, 
    128                                        pjmedia_sock_info *info); 
     128                                       pjmedia_transport_info *info); 
    129129static pj_status_t transport_attach   (pjmedia_transport *tp, 
    130130                                       void *user_data, 
    … …  
    552552 
    553553static pj_status_t transport_get_info(pjmedia_transport *tp, 
    554                                       pjmedia_sock_info *info) 
     554                                      pjmedia_transport_info *info) 
    555555{ 
    556556    transport_srtp *srtp = (transport_srtp*) tp; 
    557  
    558     /* put SRTP info as well? */ 
    559     return pjmedia_transport_get_info(srtp->real_tp, info); 
     557    pjmedia_srtp_info srtp_info; 
     558    int spc_info_idx; 
     559    pj_status_t status; 
     560 
     561    PJ_ASSERT_RETURN(tp && info, PJ_EINVAL); 
     562    PJ_ASSERT_RETURN(info->specific_info_cnt < 
     563                     PJMEDIA_TRANSPORT_SPECIFIC_INFO_MAXCNT, PJ_ETOOMANY); 
     564    PJ_ASSERT_RETURN(sizeof(pjmedia_srtp_info) <= 
     565                     PJMEDIA_TRANSPORT_SPECIFIC_INFO_MAXSIZE, PJ_ENOMEM); 
     566 
     567    status = pjmedia_transport_get_info(srtp->real_tp, info); 
     568    if (status != PJ_SUCCESS) 
     569        return status; 
     570 
     571    srtp_info.active = srtp->session_inited; 
     572    srtp_info.rx_policy = srtp->rx_policy; 
     573    srtp_info.tx_policy = srtp->tx_policy; 
     574 
     575    spc_info_idx = info->specific_info_cnt++; 
     576    info->spc_info[spc_info_idx].type = PJMEDIA_TRANSPORT_TYPE_SRTP; 
     577    info->spc_info[spc_info_idx].cbsize = sizeof(srtp_info); 
     578    pj_memcpy(&info->spc_info[spc_info_idx].buffer, &srtp_info,  
     579              sizeof(srtp_info)); 
     580 
     581    return PJ_SUCCESS; 
    560582} 
    561583 

  • pjproject/trunk/pjmedia/src/pjmedia/transport_udp.c

    r1810 r1860  
    102102 */ 
    103103static pj_status_t transport_get_info (pjmedia_transport *tp, 
    104                                        pjmedia_sock_info *info); 
     104                                       pjmedia_transport_info *info); 
    105105static pj_status_t transport_attach   (pjmedia_transport *tp, 
    106106                                       void *user_data, 
    … …  
    585585/* Called to get the transport info */ 
    586586static pj_status_t transport_get_info(pjmedia_transport *tp, 
    587                                       pjmedia_sock_info *info) 
     587                                      pjmedia_transport_info *info) 
    588588{ 
    589589    struct transport_udp *udp = (struct transport_udp*)tp; 
    590590    PJ_ASSERT_RETURN(tp && info, PJ_EINVAL); 
    591591 
    592     info->rtp_sock = udp->rtp_sock; 
    593     info->rtp_addr_name = udp->rtp_addr_name; 
    594     info->rtcp_sock = udp->rtcp_sock; 
    595     info->rtcp_addr_name = udp->rtcp_addr_name; 
     592    info->sock_info.rtp_sock = udp->rtp_sock; 
     593    info->sock_info.rtp_addr_name = udp->rtp_addr_name; 
     594    info->sock_info.rtcp_sock = udp->rtcp_sock; 
     595    info->sock_info.rtcp_addr_name = udp->rtcp_addr_name; 
     596    info->specific_info_cnt = 0; 
    596597 
    597598    return PJ_SUCCESS; 

  • pjproject/trunk/pjsip-apps/src/samples/simpleua.c

    r1851 r1860  
    8282 
    8383static pjmedia_endpt        *g_med_endpt;   /* Media endpoint.          */ 
    84 static pjmedia_sock_info     g_med_skinfo; /* Socket info for media    */ 
     84static pjmedia_transport_info g_med_tpinfo; /* Socket info for media    */ 
    8585static pjmedia_transport    *g_med_transport;/* Media stream transport  */ 
    8686 
    … …  
    302302     * the SDP). 
    303303     */ 
    304     pjmedia_transport_get_info(g_med_transport, &g_med_skinfo); 
     304    pjmedia_transport_get_info(g_med_transport, &g_med_tpinfo); 
    305305 
    306306 
    … …  
    365365                                           dlg->pool,       /* pool.            */ 
    366366                                           1,               /* # of streams     */ 
    367                                            &g_med_skinfo,   /* RTP sock info    */ 
     367                                           &g_med_tpinfo.sock_info,    
     368                                                            /* RTP sock info    */ 
    368369                                           &local_sdp);     /* the SDP result   */ 
    369370        PJ_ASSERT_RETURN(status == PJ_SUCCESS, 1); 
    … …  
    572573 
    573574    status = pjmedia_endpt_create_sdp( g_med_endpt, rdata->tp_info.pool, 1, 
    574                                        &g_med_skinfo,  
     575                                       &g_med_tpinfo.sock_info,  
    575576                                       &local_sdp); 
    576577    PJ_ASSERT_RETURN(status == PJ_SUCCESS, PJ_TRUE); 

  • pjproject/trunk/pjsip-apps/src/samples/siprtp.c

    r1780 r1860  
    10061006    pjmedia_sdp_media *m; 
    10071007    pjmedia_sdp_attr *attr; 
    1008     pjmedia_sock_info tpinfo; 
     1008    pjmedia_transport_info tpinfo; 
    10091009    struct media_stream *audio = &call->media[0]; 
    10101010 
    … …  
    10481048    /* Standard media info: */ 
    10491049    m->desc.media = pj_str("audio"); 
    1050     m->desc.port = pj_ntohs(tpinfo.rtp_addr_name.ipv4.sin_port); 
     1050    m->desc.port = pj_ntohs(tpinfo.sock_info.rtp_addr_name.ipv4.sin_port); 
    10511051    m->desc.port_count = 1; 
    10521052    m->desc.transport = pj_str("RTP/AVP"); 

  • pjproject/trunk/pjsip/src/pjsua-lib/pjsua_call.c

    r1849 r1860  
    22012201    pj_status_t status; 
    22022202    int len; 
     2203    pjmedia_transport_info tp_info; 
    22032204 
    22042205    PJ_ASSERT_RETURN(call_id>=0 && call_id<(int)pjsua_var.ua_cfg.max_calls, 
    … …  
    22572258        *p++ = '\n'; 
    22582259        *p = '\0'; 
     2260    } 
     2261 
     2262    /* Get SRTP status */ 
     2263    pjmedia_transport_get_info(call->med_tp, &tp_info); 
     2264    if (tp_info.specific_info_cnt > 0) { 
     2265        int i; 
     2266        for (i = 0; i < tp_info.specific_info_cnt; ++i) { 
     2267            if (tp_info.spc_info[i].type == PJMEDIA_TRANSPORT_TYPE_SRTP)  
     2268            { 
     2269                pjmedia_srtp_info *srtp_info =  
     2270                            (pjmedia_srtp_info*) tp_info.spc_info[i].buffer; 
     2271 
     2272                len = pj_ansi_snprintf(p, end-p,  
     2273                                       "%s  SRTP status: %s Crypto-suite: %s", 
     2274                                       indent, 
     2275                                       (srtp_info->active?"Active":"Not active"), 
     2276                                       srtp_info->tx_policy.name.ptr); 
     2277                if (len > 0 && len < end-p) { 
     2278                    p += len; 
     2279                    *p++ = '\n'; 
     2280                    *p = '\0'; 
     2281                } 
     2282                break; 
     2283            } 
     2284        } 
    22592285    } 
    22602286 
    … …  
    24432469    { 
    24442470        pjmedia_sdp_session *local_sdp; 
    2445         pjmedia_sock_info si; 
    2446  
    2447         call->med_tp->op->get_info(call->med_tp, &si); 
     2471        pjmedia_transport_info ti; 
     2472 
     2473        pjmedia_transport_get_info(call->med_tp, &ti); 
    24482474        status = pjmedia_endpt_create_sdp(pjsua_var.med_endpt, tdata->pool,  
    2449                                           1, &si, &local_sdp); 
     2475                                          1, &ti.sock_info, &local_sdp); 
    24502476        if (status == PJ_SUCCESS) { 
    24512477            pjsip_create_sdp_body(tdata->pool, local_sdp, 
    … …  
    25522578    pjmedia_sdp_conn *conn; 
    25532579    pjmedia_sdp_attr *attr; 
    2554     pjmedia_sock_info skinfo; 
     2580    pjmedia_transport_info tp_info; 
    25552581    pjmedia_sdp_session *sdp; 
    25562582 
    25572583    /* Get media socket info */ 
    2558     pjmedia_transport_get_info(call->med_tp, &skinfo); 
     2584    pjmedia_transport_get_info(call->med_tp, &tp_info); 
    25592585 
    25602586    /* Create new offer */ 
    25612587    status = pjmedia_endpt_create_sdp(pjsua_var.med_endpt, pjsua_var.pool, 1, 
    2562                                       &skinfo, &sdp); 
     2588                                      &tp_info.sock_info, &sdp); 
    25632589    if (status != PJ_SUCCESS) { 
    25642590        pjsua_perror(THIS_FILE, "Unable to create local SDP", status); 

  • pjproject/trunk/pjsip/src/pjsua-lib/pjsua_core.c

    r1855 r1860  
    261261    pjsip_tx_data *tdata; 
    262262    pjsip_response_addr res_addr; 
    263     pjmedia_sock_info skinfo; 
     263    pjmedia_transport_info tpinfo; 
    264264    pjmedia_sdp_session *sdp; 
    265265    const pjsip_hdr *cap_hdr; 
    … …  
    321321 
    322322    /* Get media socket info */ 
    323     pjmedia_transport_get_info(pjsua_var.calls[0].med_tp, &skinfo); 
     323    pjmedia_transport_get_info(pjsua_var.calls[0].med_tp, &tpinfo); 
    324324 
    325325    /* Add SDP body, using call0's RTP address */ 
    326326    status = pjmedia_endpt_create_sdp(pjsua_var.med_endpt, tdata->pool, 1, 
    327                                       &skinfo, &sdp); 
     327                                      &tpinfo.sock_info, &sdp); 
    328328    if (status == PJ_SUCCESS) { 
    329329        pjsip_create_sdp_body(tdata->pool, sdp, &tdata->msg->body); 
    … …  
    20612061    for (i=0; i<pjsua_var.ua_cfg.max_calls; ++i) { 
    20622062        pjsua_call *call = &pjsua_var.calls[i]; 
    2063         pjmedia_sock_info skinfo; 
     2063        pjmedia_transport_info tpinfo; 
    20642064        char addr_buf[80]; 
    20652065 
    2066         /* MSVC complains about skinfo not being initialized */ 
    2067         pj_bzero(&skinfo, sizeof(skinfo)); 
    2068  
    2069         pjmedia_transport_get_info(call->med_tp, &skinfo); 
     2066        /* MSVC complains about tpinfo not being initialized */ 
     2067        pj_bzero(&tpinfo, sizeof(tpinfo)); 
     2068 
     2069        pjmedia_transport_get_info(call->med_tp, &tpinfo); 
    20702070 
    20712071        PJ_LOG(3,(THIS_FILE, " %s: %s", 
    20722072                  (pjsua_var.media_cfg.enable_ice ? "ICE" : "UDP"), 
    2073                   pj_sockaddr_print(&skinfo.rtp_addr_name, addr_buf, 
     2073                  pj_sockaddr_print(&tpinfo.sock_info.rtp_addr_name, addr_buf, 
    20742074                                    sizeof(addr_buf), 3))); 
    20752075    } 

  • pjproject/trunk/pjsip/src/pjsua-lib/pjsua_media.c

    r1855 r1860  
    815815    enum { MAX_MEDIA = 1, MEDIA_IDX = 0 }; 
    816816    pjmedia_sdp_session *sdp; 
    817     pjmedia_sock_info skinfo; 
     817    pjmedia_transport_info tpinfo; 
    818818    pjsua_call *call = &pjsua_var.calls[call_id]; 
    819819    pj_status_t status; 
    … …  
    827827 
    828828    /* Get media socket info */ 
    829     pjmedia_transport_get_info(call->med_tp, &skinfo); 
     829    pjmedia_transport_get_info(call->med_tp, &tpinfo); 
    830830 
    831831    /* Create SDP */ 
    832832    status = pjmedia_endpt_create_sdp(pjsua_var.med_endpt, pool, MAX_MEDIA, 
    833                                       &skinfo, &sdp); 
     833                                      &tpinfo.sock_info, &sdp); 
    834834    if (status != PJ_SUCCESS) { 
    835835        if (sip_status_code) *sip_status_code = 500; 
Note: See TracChangeset for help on using the changeset viewer.