X-Git-Url: https://git.sesse.net/?a=blobdiff_plain;f=modules%2Fservices_discovery%2Fsap.c;h=23b8c946238a85387737fb9b505ce951f5f1d5a7;hb=6ee1e193fd896ab9a4729fde14f009d9ce629815;hp=aec836f71130c7723d15367b1c6288db2f469724;hpb=73c881f96557036a5cb17ee8a50301f5710fb89e;p=vlc diff --git a/modules/services_discovery/sap.c b/modules/services_discovery/sap.c index aec836f711..23b8c94623 100644 --- a/modules/services_discovery/sap.c +++ b/modules/services_discovery/sap.c @@ -2,9 +2,11 @@ * sap.c : SAP interface module ***************************************************************************** * Copyright (C) 2004-2005 the VideoLAN team + * Copyright © 2007 Rémi Denis-Courmont * $Id$ * * Authors: Clément Stenac + * Rémi Denis-Courmont * * This program is free software; you can redistribute it and/or modify * it under the terms of the GNU General Public License as published by @@ -24,15 +26,14 @@ /***************************************************************************** * Includes *****************************************************************************/ -#define _GNU_SOURCE -#include /* malloc(), free() */ - #include -#include -#include +#include + +#include +#include -#include -#include +#include +#include #include #include @@ -48,6 +49,10 @@ # include #endif +#ifndef WIN32 +# include +#endif + /************************************************************************ * Macros and definitions ************************************************************************/ @@ -66,14 +71,6 @@ #define SAP_V4_LINK_ADDRESS "224.0.0.255" #define ADD_SESSION 1 -#define SAP_V6_1 "FF0" -/* Scope is inserted between them */ -#define SAP_V6_2 "::2:7FFE" -/* See RFC3513 for list of valid scopes */ -/* FIXME: find a way to listen to link-local scope */ -static const char ipv6_scopes[] = "1456789ABCDE"; - - /***************************************************************************** * Module descriptor *****************************************************************************/ @@ -83,12 +80,10 @@ static const char ipv6_scopes[] = "1456789ABCDE"; "can specify a specific address." ) #define SAP_IPV4_TEXT N_( "IPv4 SAP" ) #define SAP_IPV4_LONGTEXT N_( \ - "Listen to IPv4 announcements " \ - "on the standard address." ) + "Listen to IPv4 announcements on the standard addresses." ) #define SAP_IPV6_TEXT N_( "IPv6 SAP" ) #define SAP_IPV6_LONGTEXT N_( \ - "Listen to IPv6 announcements " \ - "on the standard addresses." ) + "Listen to IPv6 announcements on the standard addresses." ) #define SAP_SCOPE_TEXT N_( "IPv6 SAP scope" ) #define SAP_SCOPE_LONGTEXT N_( \ "Scope for IPv6 announcements (default is 8)." ) @@ -149,7 +144,7 @@ vlc_module_begin(); set_callbacks( Open, Close ); add_submodule(); - set_description( _("SDP file parser for UDP") ); + set_description( _("SDP Descriptions parser") ); add_shortcut( "sdp" ); set_capability( "demux2", 51 ); set_callbacks( OpenDemux, CloseDemux ); @@ -164,41 +159,52 @@ typedef struct sdp_t sdp_t; typedef struct attribute_t attribute_t; typedef struct sap_announce_t sap_announce_t; + +struct sdp_media_t +{ + struct sdp_t *parent; + char *fmt; + struct sockaddr_storage addr; + socklen_t addrlen; + unsigned n_addr; + int i_attributes; + attribute_t **pp_attributes; +}; + + /* The structure that contains sdp information */ struct sdp_t { - char *psz_sdp; + const char *psz_sdp; + + /* o field */ + char username[64]; + uint64_t session_id; + uint64_t session_version; + unsigned orig_ip_version; + char orig_host[1024]; /* s= field */ char *psz_sessionname; - /* Raw m= and c= fields */ - char *psz_connection; - char *psz_media; - - /* o field */ - char *psz_username; - char *psz_network_type; - char *psz_address_type; - char *psz_address; - int64_t i_session_id; - + /* old cruft */ /* "computed" URI */ char *psz_uri; - - int i_in; /* IP version */ - - int i_media; int i_media_type; + /* a= global attributes */ int i_attributes; attribute_t **pp_attributes; + + /* medias (well, we only support one atm) */ + unsigned mediac; + struct sdp_media_t *mediav; }; struct attribute_t { - char *psz_field; - char *psz_value; + const char *value; + char name[0]; }; struct sap_announce_t @@ -212,8 +218,6 @@ struct sap_announce_t sdp_t *p_sdp; int i_input_id; - int i_item_id_cat; - int i_item_id_one; }; struct services_discovery_sys_t @@ -222,10 +226,6 @@ struct services_discovery_sys_t int i_fd; int *pi_fd; - /* playlist node */ - playlist_item_t *p_node_cat; - playlist_item_t *p_node_one; - /* Table of announces */ int i_announces; struct sap_announce_t **pp_announces; @@ -261,7 +261,12 @@ struct demux_sys_t static int RemoveAnnounce( services_discovery_t *p_sd, sap_announce_t *p_announce ); /* Helper functions */ - static char *GetAttribute( sdp_t *p_sdp, const char *psz_search ); + static inline attribute_t *MakeAttribute (const char *str); + static const char *GetAttribute (attribute_t **tab, unsigned n, const char *name); + static inline void FreeAttribute (attribute_t *a); + static const char *FindAttribute (const sdp_t *sdp, unsigned media, + const char *name); + static vlc_bool_t IsSameSession( sdp_t *p_sdp1, sdp_t *p_sdp2 ); static int InitSocket( services_discovery_t *p_sd, const char *psz_address, int i_port ); static int Decompress( const unsigned char *psz_src, unsigned char **_dst, int i_len ); @@ -295,15 +300,10 @@ static int Open( vlc_object_t *p_this ) #endif /* Cache sap_timeshift value */ - p_sys->b_timeshift = var_CreateGetInteger( p_sd, "sap-timeshift" ) - ? VLC_TRUE : VLC_FALSE; + p_sys->b_timeshift = var_CreateGetInteger( p_sd, "sap-timeshift" ); - /* Create our playlist node */ - pl_Yield( p_sd ); - - playlist_NodesPairCreate( pl_Get( p_sd ), _("SAP sessions"), - &p_sys->p_node_cat, &p_sys->p_node_one, - VLC_TRUE ); + /* Set our name */ + services_discovery_SetLocalizedName( p_sd, _("SAP") ); p_sys->i_announces = 0; p_sys->pp_announces = NULL; @@ -317,11 +317,11 @@ static int Open( vlc_object_t *p_this ) static int OpenDemux( vlc_object_t *p_this ) { demux_t *p_demux = (demux_t *)p_this; - uint8_t *p_peek; - int i_max_sdp = 1024; - int i_sdp = 0; + const uint8_t *p_peek; char *psz_sdp = NULL; sdp_t *p_sdp = NULL; + int errval = VLC_EGENERIC; + size_t i_len; if( !var_CreateGetInteger( p_demux, "sap-parse" ) ) { @@ -329,44 +329,40 @@ static int OpenDemux( vlc_object_t *p_this ) return VLC_EGENERIC; } - /* Probe for SDP */ - if( p_demux->s ) - { - if( stream_Peek( p_demux->s, &p_peek, 7 ) < 7 ) return VLC_EGENERIC; + assert( p_demux->s ); /* this is NOT an access_demux */ - if( strncmp( (char*)p_peek, "v=0\r\n", 5 ) && - strncmp( (char*)p_peek, "v=0\n", 4 ) && - ( p_peek[0] < 'a' || p_peek[0] > 'z' || p_peek[1] != '=' ) ) - { - return VLC_EGENERIC; - } - } + /* Probe for SDP */ + if( stream_Peek( p_demux->s, &p_peek, 7 ) < 7 ) + return VLC_EGENERIC; - psz_sdp = (char *)malloc( i_max_sdp ); - if( !psz_sdp ) return VLC_EGENERIC; + if( memcmp( p_peek, "v=0\r\no=", 7 ) && memcmp( p_peek, "v=0\no=", 6 ) ) + return VLC_EGENERIC; /* Gather the complete sdp file */ - for( ;; ) + for( i_len = 0, psz_sdp = NULL; i_len < 65536; ) { - int i_read = stream_Read( p_demux->s, - &psz_sdp[i_sdp], i_max_sdp - i_sdp - 1 ); - - if( i_read < 0 ) + const int i_read_max = 1024; + char *psz_sdp_new = realloc( psz_sdp, i_len + i_read_max ); + size_t i_read; + if( psz_sdp_new == NULL ) { - msg_Err( p_demux, "failed to read SDP" ); + errval = VLC_ENOMEM; goto error; } + psz_sdp = psz_sdp_new; - i_sdp += i_read; - - if( i_read < i_max_sdp - i_sdp - 1 ) + i_read = stream_Read( p_demux->s, &psz_sdp[i_len], i_read_max ); + if( i_read < 0 ) { - psz_sdp[i_sdp] = '\0'; - break; + msg_Err( p_demux, "cannot read SDP" ); + goto error; } + i_len += i_read; + + psz_sdp[i_len] = '\0'; - i_max_sdp += 1000; - psz_sdp = (char *)realloc( psz_sdp, i_max_sdp ); + if( i_read < i_read_max ) + break; // EOF } p_sdp = ParseSDP( VLC_OBJECT(p_demux), psz_sdp ); @@ -377,11 +373,6 @@ static int OpenDemux( vlc_object_t *p_this ) goto error; } - if( p_sdp->i_media > 1 ) - { - goto error; - } - if( ParseConnection( VLC_OBJECT( p_demux ), p_sdp ) ) { p_sdp->psz_uri = NULL; @@ -404,7 +395,7 @@ error: FREENULL( psz_sdp ); if( p_sdp ) FreeSDP( p_sdp ); p_sdp = NULL; stream_Seek( p_demux->s, 0 ); - return VLC_EGENERIC; + return errval; } /***************************************************************************** @@ -436,10 +427,6 @@ static void Close( vlc_object_t *p_this ) } FREENULL( p_sys->pp_announces ); - playlist_NodeDelete( pl_Get(p_sd), p_sys->p_node_cat, VLC_TRUE, - VLC_TRUE ); - playlist_NodeDelete( pl_Get(p_sd), p_sys->p_node_one, VLC_TRUE, - VLC_TRUE ); pl_Release( p_sd ); free( p_sys ); } @@ -484,12 +471,50 @@ static void Run( services_discovery_t *p_sd ) } if( var_CreateGetInteger( p_sd, "sap-ipv6" ) ) { - char psz_address[] = SAP_V6_1"0"SAP_V6_2; - const char *c_scope; + char psz_address[NI_MAXNUMERICHOST] = "ff02::2:7ffe%"; - for( c_scope = ipv6_scopes; *c_scope; c_scope++ ) +#ifndef WIN32 + struct if_nameindex *l = if_nameindex (); + if (l != NULL) { - psz_address[sizeof(SAP_V6_1) - 1] = *c_scope; + char *ptr = strchr (psz_address, '%') + 1; + for (unsigned i = 0; l[i].if_index; i++) + { + strcpy (ptr, l[i].if_name); + InitSocket (p_sd, psz_address, SAP_PORT); + } + if_freenameindex (l); + } +#else + /* this is the Winsock2 equivalant of SIOCGIFCONF on BSD stacks, + which if_nameindex uses internally anyway */ + + // first create a dummy socket to pin down the protocol family + SOCKET s = socket(PF_INET6, SOCK_DGRAM, IPPROTO_UDP); + if( s != INVALID_SOCKET ) + { + INTERFACE_INFO ifaces[10]; // Assume there will be no more than 10 IP interfaces + size_t len = sizeof(ifaces); + + if( SOCKET_ERROR != WSAIoctl(s, SIO_GET_INTERFACE_LIST, NULL, 0, &ifaces, len, &len, NULL, NULL) ) + { + unsigned ifcount = len/sizeof(INTERFACE_INFO); + char *ptr = strchr (psz_address, '%') + 1; + for(unsigned i = 1; i<=ifcount; ++i ) + { + // append link-local zone identifier + sprintf(ptr, "%d", i); + } + } + closesocket(s); + } +#endif + *strchr (psz_address, '%') = '\0'; + + static const char ipv6_scopes[] = "1456789ABCDE"; + for (const char *c_scope = ipv6_scopes; *c_scope; c_scope++) + { + psz_address[3] = *c_scope; InitSocket( p_sd, psz_address, SAP_PORT ); } } @@ -513,9 +538,9 @@ static void Run( services_discovery_t *p_sd ) int i_read; uint8_t p_buffer[MAX_SAP_BUFFER+1]; - i_read = net_Select( p_sd, p_sd->p_sys->pi_fd, NULL, + i_read = net_Select( p_sd, p_sd->p_sys->pi_fd, p_sd->p_sys->i_fd, p_buffer, - MAX_SAP_BUFFER, 500000 ); + MAX_SAP_BUFFER ); /* Check for items that need deletion */ for( i = 0; i < p_sd->p_sys->i_announces; i++ ) @@ -565,19 +590,19 @@ static int Demux( demux_t *p_demux ) return VLC_EGENERIC; } - p_parent_input = p_input->input.p_item; + p_parent_input = input_GetItem( p_input ); + + input_item_SetURI( p_parent_input, p_sdp->psz_uri ); + input_item_SetName( p_parent_input, p_sdp->psz_sessionname ); vlc_mutex_lock( &p_parent_input->lock ); - FREENULL( p_parent_input->psz_uri ); - p_parent_input->psz_uri = strdup( p_sdp->psz_uri ); - FREENULL( p_parent_input->psz_name ); - p_parent_input->psz_name = strdup( EnsureUTF8( p_sdp->psz_sessionname ) ); + p_parent_input->i_type = ITEM_TYPE_NET; if( p_playlist->status.p_item && p_playlist->status.p_item->p_input == p_parent_input ) { - playlist_Control( p_playlist, PLAYLIST_VIEWPLAY, + playlist_Control( p_playlist, PLAYLIST_VIEWPLAY, VLC_TRUE, p_playlist->status.p_node, p_playlist->status.p_item ); } @@ -647,13 +672,12 @@ static int ParseSAP( services_discovery_t *p_sd, const uint8_t *buf, int newsize = Decompress (buf, &decomp, end - buf); if (newsize < 0) { - msg_Warn( p_sd, "decompression of sap packet failed" ); + msg_Dbg( p_sd, "decompression of SAP packet failed" ); return VLC_EGENERIC; } decomp = realloc (decomp, newsize + 1); decomp[newsize] = '\0'; - psz_sdp = (const char *)decomp; len = newsize; } @@ -690,25 +714,24 @@ static int ParseSAP( services_discovery_t *p_sd, const uint8_t *buf, p_sdp = ParseSDP( VLC_OBJECT(p_sd), psz_sdp ); if( p_sdp == NULL ) - { return VLC_EGENERIC; - } + + p_sdp->psz_sdp = psz_sdp; /* Decide whether we should add a playlist item for this SDP */ /* Parse connection information (c= & m= ) */ if( ParseConnection( VLC_OBJECT(p_sd), p_sdp ) ) - { p_sdp->psz_uri = NULL; - } /* Multi-media or no-parse -> pass to LIVE.COM */ - if( p_sdp->i_media > 1 || ( p_sdp->i_media_type != 14 && - p_sdp->i_media_type != 32 && - p_sdp->i_media_type != 33) || - p_sd->p_sys->b_parse == VLC_FALSE ) + if( ( p_sdp->i_media_type != 14 + && p_sdp->i_media_type != 32 + && p_sdp->i_media_type != 33) + || p_sd->p_sys->b_parse == VLC_FALSE ) { - if( p_sdp->psz_uri ) free( p_sdp->psz_uri ); - asprintf( &p_sdp->psz_uri, "sdp://%s", p_sdp->psz_sdp ); + free( p_sdp->psz_uri ); + if (asprintf( &p_sdp->psz_uri, "sdp://%s", p_sdp->psz_sdp ) == -1) + p_sdp->psz_uri = NULL; } if( p_sdp->psz_uri == NULL ) return VLC_EGENERIC; @@ -731,11 +754,6 @@ static int ParseSAP( services_discovery_t *p_sd, const uint8_t *buf, return VLC_SUCCESS; } } - /* Add item */ - if( p_sdp->i_media > 1 ) - { - msg_Dbg( p_sd, "passing to liveMedia" ); - } CreateAnnounce( p_sd, i_hash, p_sdp ); @@ -747,8 +765,7 @@ sap_announce_t *CreateAnnounce( services_discovery_t *p_sd, uint16_t i_hash, sdp_t *p_sdp ) { input_item_t *p_input; - playlist_item_t *p_item, *p_child; - char *psz_value; + const char *psz_value; sap_announce_t *p_sap = (sap_announce_t *)malloc( sizeof(sap_announce_t ) ); services_discovery_sys_t *p_sys; @@ -757,7 +774,6 @@ sap_announce_t *CreateAnnounce( services_discovery_t *p_sd, uint16_t i_hash, p_sys = p_sd->p_sys; - EnsureUTF8( p_sdp->psz_sessionname ); p_sap->i_last = mdate(); p_sap->i_hash = i_hash; p_sap->p_sdp = p_sdp; @@ -777,231 +793,258 @@ sap_announce_t *CreateAnnounce( services_discovery_t *p_sd, uint16_t i_hash, if( p_sys->b_timeshift ) input_ItemAddOption( p_input, ":access-filter=timeshift" ); - psz_value = GetAttribute( p_sap->p_sdp, "tool" ); + psz_value = GetAttribute( p_sap->p_sdp->pp_attributes, p_sap->p_sdp->i_attributes, "tool" ); if( psz_value != NULL ) { - input_ItemAddInfo( p_input, _("Session"),_("Tool"), psz_value ); + input_ItemAddInfo( p_input, _("Session"), _("Tool"), "%s", + psz_value ); } - if( strcmp( p_sdp->psz_username, "-" ) ) + if( strcmp( p_sdp->username, "-" ) ) { - input_ItemAddInfo( p_input, _("Session"), - _("User"), p_sdp->psz_username ); + input_ItemAddInfo( p_input, _("Session"), _("User"), "%s", + p_sdp->username ); } /* Handle group */ - psz_value = GetAttribute( p_sap->p_sdp, "x-plgroup" ); - if( psz_value == NULL ) - psz_value = GetAttribute( p_sap->p_sdp, "plgroup" ); - - if( psz_value != NULL ) - { - EnsureUTF8( psz_value ); - - p_child = playlist_ChildSearchName( p_sys->p_node_cat, psz_value ); - - if( p_child == NULL ) - { - p_child = playlist_NodeCreate( pl_Get( p_sd ), psz_value, - p_sys->p_node_cat ); - p_child->i_flags &= ~PLAYLIST_SKIP_FLAG; - } - } + if (p_sap->p_sdp->mediac >= 1) + psz_value = FindAttribute (p_sap->p_sdp, 0, "x-plgroup"); else - { - p_child = p_sys->p_node_cat; - } - - p_item = playlist_NodeAddInput( pl_Get( p_sd ), p_input, p_child, - PLAYLIST_APPEND, PLAYLIST_END ); - p_item->i_flags &= ~PLAYLIST_SKIP_FLAG; - p_item->i_flags &= ~PLAYLIST_SAVE_FLAG; - p_sap->i_item_id_cat = p_item->i_id; + psz_value = GetAttribute( p_sap->p_sdp->pp_attributes, p_sap->p_sdp->i_attributes, "x-plgroup" ); - p_item = playlist_NodeAddInput( pl_Get( p_sd ), p_input, - p_sys->p_node_one, PLAYLIST_APPEND, PLAYLIST_END ); - p_item->i_flags &= ~PLAYLIST_SKIP_FLAG; - p_item->i_flags &= ~PLAYLIST_SAVE_FLAG; - p_sap->i_item_id_one = p_item->i_id; + services_discovery_AddItem( p_sd, p_input, psz_value /* category name */ ); TAB_APPEND( p_sys->i_announces, p_sys->pp_announces, p_sap ); return p_sap; } -static char *GetAttribute( sdp_t *p_sdp, const char *psz_search ) -{ - int i; - for( i = 0 ; i< p_sdp->i_attributes; i++ ) - { - if( !strncmp( p_sdp->pp_attributes[i]->psz_field, psz_search, - strlen( p_sdp->pp_attributes[i]->psz_field ) ) ) - { - return p_sdp->pp_attributes[i]->psz_value; - } - } - return NULL; +static const char *FindAttribute (const sdp_t *sdp, unsigned media, + const char *name) +{ + /* Look for media attribute, and fallback to session */ + return GetAttribute (sdp->mediav[media].pp_attributes, + sdp->mediav[media].i_attributes, name) + ?: GetAttribute (sdp->pp_attributes, sdp->i_attributes, name); } /* Fill p_sdp->psz_uri */ static int ParseConnection( vlc_object_t *p_obj, sdp_t *p_sdp ) { - char *psz_eof = NULL; - char *psz_parse = NULL; - char psz_uri[1026]; - char *psz_proto = NULL; - int i_port = 0; - - /* Parse c= field */ - if( p_sdp->psz_connection ) + if (p_sdp->mediac == 0) { - char hostname[1024]; - int ipv; + msg_Dbg (p_obj, "Ignoring SDP with no media"); + return VLC_EGENERIC; + } - /* - * NOTE: we ignore the TTL parameter on-purpose, as some SAP - * advertisers don't include it (and it is utterly useless). - */ - if (sscanf (p_sdp->psz_connection, "IN IP%d %1023[^/]", &ipv, - hostname) != 2) + for (unsigned i = 1; i < p_sdp->mediac; i++) + { + if ((p_sdp->mediav[i].n_addr != p_sdp->mediav->n_addr) + || (p_sdp->mediav[i].addrlen != p_sdp->mediav->addrlen) + || memcmp (&p_sdp->mediav[i].addr, &p_sdp->mediav->addr, + p_sdp->mediav->addrlen)) { - msg_Warn (p_obj, "unable to parse c field: \"%s\"", - p_sdp->psz_connection); + msg_Dbg (p_obj, "Multiple media ports not supported -> live555"); return VLC_EGENERIC; } + } - switch (ipv) - { - case 4: - case 6: - break; + if (p_sdp->mediav->n_addr != 1) + { + msg_Dbg (p_obj, "Layered encoding not supported -> live555"); + return VLC_EGENERIC; + } - default: - msg_Warn (p_obj, "unknown IP version %d", ipv); - return VLC_EGENERIC; - } + char psz_uri[1026]; + const char *host; + int port; + + psz_uri[0] = '['; + if (vlc_getnameinfo ((struct sockaddr *)&(p_sdp->mediav->addr), + p_sdp->mediav->addrlen, psz_uri + 1, + sizeof (psz_uri) - 2, &port, NI_NUMERICHOST)) + return VLC_EGENERIC; - if (strchr (hostname, ':') != NULL) - sprintf (psz_uri, "[%s]", hostname); - else - strcpy (psz_uri, hostname); + if (strchr (psz_uri + 1, ':')) + { + host = psz_uri; + psz_uri[strlen (psz_uri)] = ']'; } + else + host = psz_uri + 1; /* Parse m= field */ - if( p_sdp->psz_media ) + char *sdp_proto = strdup (p_sdp->mediav[0].fmt); + if (sdp_proto == NULL) + return VLC_ENOMEM; + + char *subtype = strchr (sdp_proto, ' '); + if (subtype == NULL) + { + msg_Dbg (p_obj, "missing SDP media subtype: %s", sdp_proto); + p_sdp->i_media_type = 0; + } + else + { + *subtype++ = '\0'; + p_sdp->i_media_type = atoi (subtype); + } + if (p_sdp->i_media_type == 0) + p_sdp->i_media_type = 33; + + /* RTP protocol, nul, VLC shortcut, nul, flags byte as follow: + * 0x1: Connection-Oriented media. */ + static const char proto_match[] = + "udp\0" "udp\0\0" + "RTP/AVP\0" "rtp\0\0" + "UDPLite/RTP/AVP\0" "udplite\0\0" + "DCCP/RTP/AVP\0" "dccp\0\1" + "TCP/RTP/AVP\0" "rtptcp\0\1" + "\0"; + + const char *vlc_proto = NULL; + uint8_t flags = 0; + for (const char *proto = proto_match; *proto;) { - psz_parse = p_sdp->psz_media; + if (strcasecmp (proto, sdp_proto) == 0) + { + vlc_proto = proto + strlen (proto) + 1; + flags = vlc_proto[strlen (vlc_proto) + 1]; + break; + } + proto += strlen (proto) + 1; + proto += strlen (proto) + 2; + } - psz_eof = strchr( psz_parse, ' ' ); + free (sdp_proto); + if (vlc_proto == NULL) + { + msg_Dbg (p_obj, "unknown SDP media protocol: %s", + p_sdp->mediav[0].fmt); + return VLC_EGENERIC; + } - if( psz_eof ) - { - *psz_eof = '\0'; - - /* - * That's ugly. We should go through every media, and make sure - * at least one of them is audio or video. In the mean time, I - * need to accept data too. - */ - if( strncmp( psz_parse, "audio", 5 ) - && strncmp( psz_parse, "video", 5 ) - && strncmp( psz_parse, "data", 4 ) ) - { - msg_Warn( p_obj, "unhandled media type \"%s\"", psz_parse ); - return VLC_EGENERIC; - } + if (flags & 1) + { + /* Connection-oriented media */ + const char *setup = FindAttribute (p_sdp, 0, "setup"); + if (setup == NULL) + setup = "active"; /* default value */ - psz_parse = psz_eof + 1; - } - else + if (strcmp (setup, "actpass") && strcmp (setup, "passive")) { - msg_Warn( p_obj, "unable to parse m field (1)"); + msg_Dbg (p_obj, "unsupported COMEDIA mode: %s", setup); return VLC_EGENERIC; } - psz_eof = strchr( psz_parse, ' ' ); + if (asprintf (&p_sdp->psz_uri, "%s://%s:%d", vlc_proto, + host, port) == -1) + return VLC_ENOMEM; + } + else + { + /* Non-connected (normally multicast) media */ - if( psz_eof ) + char psz_source[258] = ""; + const char *sfilter = FindAttribute (p_sdp, 0, "source-filter"); + if (sfilter != NULL) { - *psz_eof = '\0'; - - /* FIXME : multiple port ! */ - i_port = atoi( psz_parse ); + char psz_source_ip[256]; + unsigned ipv; - if( i_port <= 0 || i_port >= 65536 ) + if (sscanf (sfilter, " incl IN IP%u %*s %255s ", &ipv, + psz_source_ip) == 2) { - msg_Warn( p_obj, "invalid transport port %i", i_port ); + /* According to RFC4570, FQDNs can be used for source-filters, + * but -seriously- this is impractical */ + switch (ipv) + { +#ifdef AF_INET6 + case 6: + { + struct in6_addr addr; + if ((inet_pton (AF_INET6, psz_source_ip, &addr) > 0) + && (inet_ntop (AF_INET6, &addr, psz_source + 1, + sizeof (psz_source) - 2) != NULL)) + { + psz_source[0] = '['; + psz_source[strlen (psz_source)] = ']'; + } + break; + } +#endif + case 4: + { + struct in_addr addr; + if ((inet_pton (AF_INET, psz_source_ip, &addr) > 0) + && (inet_ntop (AF_INET, &addr, psz_source, + sizeof (psz_source)) == NULL)) + *psz_source = '\0'; + break; + } + } } - - psz_parse = psz_eof + 1; - } - else - { - msg_Warn( p_obj, "unable to parse m field (2)"); - return VLC_EGENERIC; } - psz_eof = strchr( psz_parse, ' ' ); - - if( psz_eof ) - { - *psz_eof = '\0'; - psz_proto = strdup( psz_parse ); + if (asprintf (&p_sdp->psz_uri, "%s://%s@%s:%i", vlc_proto, psz_source, + host, port) == -1) + return VLC_ENOMEM; + } - psz_parse = psz_eof + 1; - p_sdp->i_media_type = atoi( psz_parse ); + return VLC_SUCCESS; +} - } - else - { - msg_Dbg( p_obj, "incorrect m field, %s", p_sdp->psz_media ); - p_sdp->i_media_type = 33; - psz_proto = strdup( psz_parse ); - } - } - if( psz_proto && !strncmp( psz_proto, "RTP/AVP", 7 ) ) - { - free( psz_proto ); - psz_proto = strdup( "rtp" ); - } - if( psz_proto && !strncasecmp( psz_proto, "UDP", 3 ) ) - { - free( psz_proto ); - psz_proto = strdup( "udp" ); - } +static int ParseSDPConnection (const char *str, struct sockaddr_storage *addr, + socklen_t *addrlen, unsigned *number) +{ + char host[60]; + unsigned fam, n1, n2; - /* FIXME: HTTP support */ + int res = sscanf (str, "IN IP%u %59[^/]/%u/%u", &fam, host, &n1, &n2); + if (res < 2) + return -1; - if( i_port == 0 ) + switch (fam) { - i_port = 1234; - } +#ifdef AF_INET6 + case 6: + addr->ss_family = AF_INET6; +# ifdef HAVE_SA_LEN + addr->ss_len = +# endif + *addrlen = sizeof (struct sockaddr_in6); + + if (inet_pton (AF_INET6, host, + &((struct sockaddr_in6 *)addr)->sin6_addr) <= 0) + return -1; + + *number = (res >= 3) ? n1 : 1; + break; +#endif - /* handle SSM case */ - psz_parse = GetAttribute( p_sdp, "source-filter" ); - char psz_source[258] = ""; - if (psz_parse != NULL) - { - char psz_source_ip[256]; + case 4: + addr->ss_family = AF_INET; +# ifdef HAVE_SA_LEN + addr->ss_len = +# endif + *addrlen = sizeof (struct sockaddr_in); - if (sscanf (psz_parse, " incl IN IP%*c %*s %255s ", psz_source_ip) == 1) - { - if (strchr (psz_source_ip, ':') != NULL) - sprintf (psz_source, "[%s]", psz_source_ip); - else - strcpy (psz_source, psz_source_ip); - } - } + if (inet_pton (AF_INET, host, + &((struct sockaddr_in *)addr)->sin_addr) <= 0) + return -1; - asprintf( &p_sdp->psz_uri, "%s://%s@%s:%i", psz_proto, psz_source, - psz_uri, i_port ); + *number = (res >= 4) ? n2 : 1; + break; - FREENULL( psz_proto ); - return VLC_SUCCESS; + default: + return -1; + } + return 0; } + /*********************************************************************** * ParseSDP : SDP parsing * ********************************************************************* @@ -1009,187 +1052,291 @@ static int ParseConnection( vlc_object_t *p_obj, sdp_t *p_sdp ) ***********************************************************************/ static sdp_t *ParseSDP (vlc_object_t *p_obj, const char *psz_sdp) { - sdp_t *p_sdp; - vlc_bool_t b_invalid = VLC_FALSE; - vlc_bool_t b_end = VLC_FALSE; if( psz_sdp == NULL ) - { return NULL; - } - if( psz_sdp[0] != 'v' || psz_sdp[1] != '=' ) - { - msg_Warn( p_obj, "bad packet" ); - return NULL; - } - - p_sdp = (sdp_t *)malloc( sizeof( sdp_t ) ); - if( p_sdp == NULL ) + sdp_t *p_sdp = calloc (1, sizeof (*p_sdp)); + if (p_sdp == NULL) return NULL; - /* init to 0 */ - memset( p_sdp, 0, sizeof( sdp_t ) ); - - p_sdp->psz_sdp = strdup( psz_sdp ); - if( p_sdp->psz_sdp == NULL ) - { - free( p_sdp ); - return NULL; - } + char expect = 'V'; + struct sockaddr_storage glob_addr; + memset (&glob_addr, 0, sizeof (glob_addr)); + socklen_t glob_len = 0; + unsigned glob_count = 1; + int port = 0; - while( *psz_sdp != '\0' && b_end == VLC_FALSE ) + /* TODO: use iconv and charset attribute instead of EnsureUTF8 */ + while (*psz_sdp) { - char *psz_eol = NULL; - char *psz_eof = NULL; - char *psz_parse = NULL; - char *psz_sess_id = NULL; - - while( *psz_sdp == '\r' || *psz_sdp == '\n' || - *psz_sdp == ' ' || *psz_sdp == '\t' ) + /* Extract one line */ + char *eol = strchr (psz_sdp, '\n'); + size_t linelen = eol ? (size_t)(eol - psz_sdp) : strlen (psz_sdp); + char line[linelen + 1]; + memcpy (line, psz_sdp, linelen); + line[linelen] = '\0'; + + psz_sdp += linelen + 1; + + /* Remove carriage return if present */ + eol = strchr (line, '\r'); + if (eol != NULL) { - psz_sdp++; + linelen = eol - line; + line[linelen] = '\0'; } - if( ( psz_eol = strchr( psz_sdp, '\n' ) ) == NULL ) - { - psz_eol = (char *)psz_sdp + strlen( psz_sdp ); - b_end = VLC_TRUE; - } - if( psz_eol > psz_sdp && *( psz_eol - 1 ) == '\r' ) + /* Validate line */ + char cat = line[0], *data = line + 2; + if (!cat || (strchr ("vosiuepcbtrzkam", cat) == NULL)) { - psz_eol--; + /* MUST ignore SDP with unknown line type */ + msg_Dbg (p_obj, "unknown SDP line type: 0x%02x", (int)cat); + goto error; } - - if( psz_eol <= psz_sdp ) + if (line[1] != '=') { - break; + msg_Dbg (p_obj, "invalid SDP line: %s", line); + goto error; } - *psz_eol++ = '\0'; - /* no space allowed between fields */ - if( psz_sdp[1] != '=' ) - { - msg_Warn( p_obj, "invalid packet" ) ; - FreeSDP( p_sdp ); p_sdp = NULL; - return NULL; - } + assert (linelen >= 2); - /* Now parse each line */ - switch( psz_sdp[0] ) + /* SDP parsing state machine + * We INTERNALLY use uppercase for session, lowercase for media + */ + switch (expect) { - case( 'v' ): - break; - case( 's' ): - p_sdp->psz_sessionname = strdup( &psz_sdp[2] ); + /* Session description */ + case 'V': + expect = 'O'; + if (cat != 'v') + { + msg_Dbg (p_obj, "missing SDP version"); + goto error; + } + if (strcmp (data, "0")) + { + msg_Dbg (p_obj, "unknown SDP version: %s", data); + goto error; + } break; - case ( 'o' ): + + case 'O': { - int i_field = 0; - /* o field is - *
*/ - -#define GET_FIELD( store ) \ - psz_eof = strchr( psz_parse, ' ' ); \ - if( psz_eof ) \ - { \ - *psz_eof=0; store = strdup( psz_parse ); \ - } \ - else \ - { \ - if( i_field != 5 ) \ - { \ - b_invalid = VLC_TRUE; break; \ - } \ - else \ - { \ - store = strdup( psz_parse ); \ - } \ - }; \ - psz_parse = psz_eof + 1; i_field++; - - - psz_parse = (char *)&psz_sdp[2]; - GET_FIELD( p_sdp->psz_username ); - GET_FIELD( psz_sess_id ); - - p_sdp->i_session_id = atoll( psz_sess_id ); - - FREENULL( psz_sess_id ); - - GET_FIELD( psz_sess_id ); - FREENULL( psz_sess_id ); - - GET_FIELD( p_sdp->psz_network_type ); - GET_FIELD( p_sdp->psz_address_type ); - GET_FIELD( p_sdp->psz_address ); + expect = 'S'; + if (cat != 'o') + { + msg_Dbg (p_obj, "missing SDP originator"); + goto error; + } + if ((sscanf (data, "%63s "I64Fu" "I64Fu" IN IP%u %1023s", + p_sdp->username, &p_sdp->session_id, + &p_sdp->session_version, &p_sdp->orig_ip_version, + p_sdp->orig_host) != 5) + || ((p_sdp->orig_ip_version != 4) + && (p_sdp->orig_ip_version != 6))) + { + msg_Dbg (p_obj, "SDP origin not supported: %s\n", data); + /* Or maybe out-of-range, but this looks suspicious */ + return NULL; + } + EnsureUTF8 (p_sdp->orig_host); break; } - case( 'i' ): - case( 'u' ): - case( 'e' ): - case( 'p' ): - case( 't' ): - case( 'r' ): - break; - case( 'a' ): /* attribute */ - { - char *psz_eon = strchr( &psz_sdp[2], ':' ); - attribute_t *p_attr = malloc( sizeof( attribute_t ) ); - /* Attribute with value */ - if( psz_eon ) + case 'S': + { + expect = 'I'; + if ((cat != 's') || !*data) { - *psz_eon++ = '\0'; + /* MUST be present AND non-empty */ + msg_Dbg (p_obj, "missing SDP session name"); + goto error; + } + assert (p_sdp->psz_sessionname == NULL); // no memleak here + p_sdp->psz_sessionname = strdup (data); + EnsureUTF8 (p_sdp->psz_sessionname); + if (p_sdp->psz_sessionname == NULL) + goto error; + break; + } - p_attr->psz_field = strdup( &psz_sdp[2] ); - p_attr->psz_value = strdup( psz_eon ); + case 'I': + expect = 'U'; + if (cat == 'i') + break; + case 'U': + expect = 'E'; + if (cat == 'u') + break; + case 'E': + expect = 'E'; + if (cat == 'e') + break; + case 'P': + expect = 'P'; + if (cat == 'p') + break; + case 'C': + expect = 'B'; + if (cat == 'c') + { + if (ParseSDPConnection (data, &glob_addr, &glob_len, + &glob_count)) + { + msg_Dbg (p_obj, "SDP connection infos not supported: " + "%s", data); + goto error; + } + break; } - else /* Attribute without value */ + case 'B': + assert (expect == 'B'); + if (cat == 'b') + break; + case 'T': + expect = 'R'; + if (cat != 't') { - p_attr->psz_field = strdup( &psz_sdp[2] ); - p_attr->psz_value = NULL; + msg_Dbg (p_obj, "missing SDP time description"); + goto error; } - - TAB_APPEND( p_sdp->i_attributes, p_sdp->pp_attributes, p_attr ); break; - } - case( 'm' ): /* Media announcement */ + case 'R': + if ((cat == 't') || (cat == 'r')) + break; + + case 'Z': + expect = 'K'; + if (cat == 'z') + break; + case 'K': + expect = 'A'; + if (cat == 'k') + break; + case 'A': + //expect = 'A'; + if (cat == 'a') + { + attribute_t *p_attr = MakeAttribute (data); + TAB_APPEND( p_sdp->i_attributes, p_sdp->pp_attributes, p_attr ); + break; + } + + /* Media description */ + case 'm': + media: { - /* If we have several medias, we pass the announcement to - * LIVE.COM, so just count them */ - p_sdp->i_media++; - if( p_sdp->i_media == 1 ) + expect = 'i'; + if (cat != 'm') { - p_sdp->psz_media = strdup( &psz_sdp[2] ); + msg_Dbg (p_obj, "missing SDP media description"); + goto error; } + struct sdp_media_t *m; + m = realloc (p_sdp->mediav, (p_sdp->mediac + 1) * sizeof (*m)); + if (m == NULL) + goto error; + + p_sdp->mediav = m; + m += p_sdp->mediac; + p_sdp->mediac++; + + memset (m, 0, sizeof (*m)); + memcpy (&m->addr, &glob_addr, m->addrlen = glob_len); + m->n_addr = glob_count; + + /* TODO: remember media type (if we need multiple medias) */ + data = strchr (data, ' '); + if (data == NULL) + { + msg_Dbg (p_obj, "missing SDP media port"); + goto error; + } + port = atoi (++data); + if (port <= 0 || port >= 65536) + { + msg_Dbg (p_obj, "invalid transport port %d", port); + goto error; + } + net_SetPort ((struct sockaddr *)&m->addr, htons (port)); + + data = strchr (data, ' '); + if (data == NULL) + { + msg_Dbg (p_obj, "missing SDP media format"); + goto error; + } + m->fmt = strdup (++data); + if (m->fmt == NULL) + goto error; + break; } + case 'i': + expect = 'c'; + if (cat == 'i') + break; + case 'c': + expect = 'b'; + if (cat == 'c') + { + struct sdp_media_t *m = p_sdp->mediav + p_sdp->mediac - 1; + if (ParseSDPConnection (data, &m->addr, &m->addrlen, + &m->n_addr)) + { + msg_Dbg (p_obj, "SDP connection infos not supported: " + "%s", data); + goto error; + } + net_SetPort ((struct sockaddr *)&m->addr, htons (port)); + break; + } + case 'b': + expect = 'b'; + if (cat == 'b') + break; + case 'k': + expect = 'a'; + if (cat == 'k') + break; + case 'a': + assert (expect == 'a'); + if (cat == 'a') + { + attribute_t *p_attr = MakeAttribute (data); + if (p_attr == NULL) + goto error; - case( 'c' ): - { - if( p_sdp->psz_connection != NULL ) // FIXME + TAB_APPEND (p_sdp->mediav[p_sdp->mediac - 1].i_attributes, + p_sdp->mediav[p_sdp->mediac - 1].pp_attributes, p_attr); break; + } + + if (cat == 'm') + goto media; - p_sdp->psz_connection = strdup( &psz_sdp[2] ); + if (cat != 'm') + { + msg_Dbg (p_obj, "unexpected SDP line: 0x%02x", (int)cat); + goto error; + } break; - } default: - break; - } - - if( b_invalid ) - { - FreeSDP( p_sdp ); p_sdp = NULL; - return NULL; + msg_Err (p_obj, "*** BUG in SDP parser! ***"); + goto error; } - - psz_sdp = psz_eol; } return p_sdp; + +error: + FreeSDP (p_sdp); + return NULL; } static int InitSocket( services_discovery_t *p_sd, const char *psz_address, @@ -1199,7 +1346,7 @@ static int InitSocket( services_discovery_t *p_sd, const char *psz_address, if (i_fd == -1) return VLC_EGENERIC; - net_StopSend( i_fd ); + shutdown( i_fd, SHUT_WR ); INSERT_ELEM (p_sd->p_sys->pi_fd, p_sd->p_sys->i_fd, p_sd->p_sys->i_fd, i_fd); return VLC_SUCCESS; @@ -1208,13 +1355,11 @@ static int InitSocket( services_discovery_t *p_sd, const char *psz_address, static int Decompress( const unsigned char *psz_src, unsigned char **_dst, int i_len ) { #ifdef HAVE_ZLIB_H - int i_result, i_dstsize, n; - unsigned char *psz_dst; + int i_result, i_dstsize, n = 0; + unsigned char *psz_dst = NULL; z_stream d_stream; - d_stream.zalloc = (alloc_func)0; - d_stream.zfree = (free_func)0; - d_stream.opaque = (voidpf)0; + memset (&d_stream, 0, sizeof (d_stream)); i_result = inflateInit(&d_stream); if( i_result != Z_OK ) @@ -1222,9 +1367,6 @@ static int Decompress( const unsigned char *psz_src, unsigned char **_dst, int i d_stream.next_in = (Bytef *)psz_src; d_stream.avail_in = i_len; - n = 0; - - psz_dst = NULL; do { @@ -1235,7 +1377,10 @@ static int Decompress( const unsigned char *psz_src, unsigned char **_dst, int i i_result = inflate(&d_stream, Z_NO_FLUSH); if( ( i_result != Z_OK ) && ( i_result != Z_STREAM_END ) ) + { + inflateEnd( &d_stream ); return( -1 ); + } } while( ( d_stream.avail_out == 0 ) && ( d_stream.avail_in != 0 ) && ( i_result != Z_STREAM_END ) ); @@ -1257,27 +1402,23 @@ static int Decompress( const unsigned char *psz_src, unsigned char **_dst, int i static void FreeSDP( sdp_t *p_sdp ) { - int i; - FREENULL( p_sdp->psz_sdp ); - FREENULL( p_sdp->psz_sessionname ); - FREENULL( p_sdp->psz_connection ); - FREENULL( p_sdp->psz_media ); - FREENULL( p_sdp->psz_uri ); - FREENULL( p_sdp->psz_username ); - FREENULL( p_sdp->psz_network_type ); - - FREENULL( p_sdp->psz_address ); - FREENULL( p_sdp->psz_address_type ); - - for( i= p_sdp->i_attributes - 1; i >= 0 ; i-- ) + free( p_sdp->psz_sessionname ); + free( p_sdp->psz_uri ); + + for (unsigned j = 0; j < p_sdp->mediac; j++) { - struct attribute_t *p_attr = p_sdp->pp_attributes[i]; - FREENULL( p_sdp->pp_attributes[i]->psz_field ); - FREENULL( p_sdp->pp_attributes[i]->psz_value ); - REMOVE_ELEM( p_sdp->pp_attributes, p_sdp->i_attributes, i); - FREENULL( p_attr ); + free (p_sdp->mediav[j].fmt); + for (int i = 0; i < p_sdp->mediav[j].i_attributes; i++) + FreeAttribute (p_sdp->mediav[j].pp_attributes[i]); + free (p_sdp->mediav[j].pp_attributes); } - FREENULL( p_sdp ); + free (p_sdp->mediav); + + for (int i = 0; i < p_sdp->i_attributes; i++) + FreeAttribute (p_sdp->pp_attributes[i]); + + free (p_sdp->pp_attributes); + free (p_sdp); } static int RemoveAnnounce( services_discovery_t *p_sd, @@ -1292,7 +1433,7 @@ static int RemoveAnnounce( services_discovery_t *p_sd, } if( p_announce->i_input_id > -1 ) - playlist_LockDeleteAllFromInput( pl_Get(p_sd), p_announce->i_input_id ); + playlist_DeleteFromInput( pl_Get(p_sd), p_announce->i_input_id, VLC_FALSE ); for( i = 0; i< p_sd->p_sys->i_announces; i++) { @@ -1312,27 +1453,53 @@ static int RemoveAnnounce( services_discovery_t *p_sd, static vlc_bool_t IsSameSession( sdp_t *p_sdp1, sdp_t *p_sdp2 ) { /* A session is identified by - * username, session_id, network type, address type and address */ - if( p_sdp1->psz_username && p_sdp2->psz_username && - p_sdp1->psz_network_type && p_sdp2->psz_network_type && - p_sdp1->psz_address_type && p_sdp2->psz_address_type && - p_sdp1->psz_address && p_sdp2->psz_address ) + * - username, + * - session_id, + * - network type (which is always IN), + * - address type (currently, this means IP version), + * - and hostname. + */ + if (strcmp (p_sdp1->username, p_sdp2->username) + || (p_sdp1->session_id != p_sdp2->session_id) + || (p_sdp1->orig_ip_version != p_sdp2->orig_ip_version) + || strcmp (p_sdp1->orig_host, p_sdp2->orig_host)) + return VLC_FALSE; + + return VLC_TRUE; +} + + +static inline attribute_t *MakeAttribute (const char *str) +{ + attribute_t *a = malloc (sizeof (*a) + strlen (str) + 1); + if (a == NULL) + return NULL; + + strcpy (a->name, str); + EnsureUTF8 (a->name); + char *value = strchr (a->name, ':'); + if (value != NULL) { - if(!strcmp( p_sdp1->psz_username , p_sdp2->psz_username ) && - !strcmp( p_sdp1->psz_network_type , p_sdp2->psz_network_type ) && - !strcmp( p_sdp1->psz_address_type , p_sdp2->psz_address_type ) && - !strcmp( p_sdp1->psz_address , p_sdp2->psz_address ) && - p_sdp1->i_session_id == p_sdp2->i_session_id ) - { - return VLC_TRUE; - } - else - { - return VLC_FALSE; - } + *value++ = '\0'; + a->value = value; } else - { - return VLC_FALSE; - } + a->value = ""; + return a; +} + + +static const char *GetAttribute (attribute_t **tab, unsigned n, + const char *name) +{ + for (unsigned i = 0; i < n; i++) + if (strcasecmp (tab[i]->name, name) == 0) + return tab[i]->value; + return NULL; +} + + +static inline void FreeAttribute (attribute_t *a) +{ + free (a); }