git.sesse.net Git - vlc/blob - modules/services_discovery/sap.c

   1 /*****************************************************************************
   2  * sap.c :  SAP interface module
   3  *****************************************************************************
   4  * Copyright (C) 2004-2005 the VideoLAN team
   5  * $Id$
   6  *
   7  * Authors: Clément Stenac <zorglub@videolan.org>
   8  *
   9  * This program is free software; you can redistribute it and/or modify
  10  * it under the terms of the GNU General Public License as published by
  11  * the Free Software Foundation; either version 2 of the License, or
  12  * (at your option) any later version.
  13  *
  14  * This program is distributed in the hope that it will be useful,
  15  * but WITHOUT ANY WARRANTY; without even the implied warranty of
  16  * MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE.  See the
  17  * GNU General Public License for more details.
  18  *
  19  * You should have received a copy of the GNU General Public License
  20  * along with this program; if not, write to the Free Software
  21  * Foundation, Inc., 59 Temple Place - Suite 330, Boston, MA  02111, USA.
  22  *****************************************************************************/
  23
  24 /*****************************************************************************
  25  * Includes
  26  *****************************************************************************/
  27 #include <stdlib.h>                                      /* malloc(), free() */
  28
  29 #include <vlc/vlc.h>
  30 #include <vlc/intf.h>
  31
  32 #include <vlc/input.h>
  33
  34 #include "network.h"
  35 #include "charset.h"
  36
  37 #include <ctype.h>
  38 #include <errno.h>
  39
  40 #ifdef HAVE_UNISTD_H
  41 #    include <unistd.h>
  42 #endif
  43 #ifdef HAVE_SYS_TIME_H
  44 #    include <sys/time.h>
  45 #endif
  46
  47 #ifdef HAVE_ZLIB_H
  48 #   include <zlib.h>
  49 #endif
  50
  51 /************************************************************************
  52  * Macros and definitions
  53  ************************************************************************/
  54
  55 #define MAX_LINE_LENGTH 256
  56
  57 /* SAP is always on that port */
  58 #define SAP_PORT 9875
  59 /* Global-scope SAP address */
  60 #define SAP_V4_GLOBAL_ADDRESS   "224.2.127.254"
  61 /* Organization-local SAP address */
  62 #define SAP_V4_ORG_ADDRESS      "239.195.255.255"
  63 /* Local (smallest non-link-local scope) SAP address */
  64 #define SAP_V4_LOCAL_ADDRESS    "239.255.255.255"
  65 /* Link-local SAP address */
  66 #define SAP_V4_LINK_ADDRESS     "224.0.0.255"
  67 #define ADD_SESSION 1
  68
  69 #define SAP_V6_1 "FF0"
  70 /* Scope is inserted between them */
  71 #define SAP_V6_2 "::2:7FFE"
  72 /* See RFC3513 for list of valid scopes */
  73 /* FIXME: find a way to listen to link-local scope */
  74 static const char ipv6_scopes[] = "1456789ABCDE";
  75
  76
  77 /*****************************************************************************
  78  * Module descriptor
  79  *****************************************************************************/
  80 #define SAP_ADDR_TEXT N_( "SAP multicast address" )
  81 #define SAP_ADDR_LONGTEXT N_( "Listen for SAP announces on another address" )
  82 #define SAP_IPV4_TEXT N_( "IPv4-SAP listening" )
  83 #define SAP_IPV4_LONGTEXT N_( \
  84       "Set this if you want the SAP module to listen to IPv4 announces " \
  85       "on the standard address." )
  86 #define SAP_IPV6_TEXT N_( "IPv6-SAP listening" )
  87 #define SAP_IPV6_LONGTEXT N_( \
  88       "Set this if you want the SAP module to listen to IPv6 announces " \
  89       "on the standard address." )
  90 #define SAP_SCOPE_TEXT N_( "IPv6 SAP scope" )
  91 #define SAP_SCOPE_LONGTEXT N_( \
  92        "Sets the scope for IPv6 announces (default is 8)." )
  93 #define SAP_TIMEOUT_TEXT N_( "SAP timeout (seconds)" )
  94 #define SAP_TIMEOUT_LONGTEXT N_( \
  95        "Sets the time before SAP items get deleted if no new announce " \
  96        "is received." )
  97 #define SAP_PARSE_TEXT N_( "Try to parse the SAP" )
  98 #define SAP_PARSE_LONGTEXT N_( \
  99        "When SAP can it will try to parse the SAP. If you don't select " \
 100        "this, all announces will be parsed by the livedotcom module." )
 101 #define SAP_STRICT_TEXT N_( "SAP Strict mode" )
 102 #define SAP_STRICT_LONGTEXT N_( \
 103        "When this is set, the SAP parser will discard some non-compliant " \
 104        "announces." )
 105 #define SAP_CACHE_TEXT N_("Use SAP cache")
 106 #define SAP_CACHE_LONGTEXT N_( \
 107        "If this option is selected, a SAP caching mechanism will be used. " \
 108        "This will result in lower SAP startup time, but you could end up " \
 109         "with items corresponding to legacy streams." )
 110
 111 /* Callbacks */
 112     static int  Open ( vlc_object_t * );
 113     static void Close( vlc_object_t * );
 114     static int  OpenDemux ( vlc_object_t * );
 115     static void CloseDemux ( vlc_object_t * );
 116
 117 vlc_module_begin();
 118     set_shortname( _("SAP"));
 119     set_description( _("SAP announces") );
 120     set_category( CAT_PLAYLIST );
 121     set_subcategory( SUBCAT_PLAYLIST_SD );
 122
 123     add_string( "sap-addr", NULL, NULL,
 124                 SAP_ADDR_TEXT, SAP_ADDR_LONGTEXT, VLC_TRUE );
 125     add_bool( "sap-ipv4", 1 , NULL,
 126                SAP_IPV4_TEXT,SAP_IPV4_LONGTEXT, VLC_TRUE );
 127     add_bool( "sap-ipv6", 1 , NULL,
 128               SAP_IPV6_TEXT, SAP_IPV6_LONGTEXT, VLC_TRUE );
 129     add_integer( "sap-timeout", 1800, NULL,
 130                  SAP_TIMEOUT_TEXT, SAP_TIMEOUT_LONGTEXT, VLC_TRUE );
 131     add_bool( "sap-parse", 1 , NULL,
 132                SAP_PARSE_TEXT,SAP_PARSE_LONGTEXT, VLC_TRUE );
 133     add_bool( "sap-strict", 0 , NULL,
 134                SAP_STRICT_TEXT,SAP_STRICT_LONGTEXT, VLC_TRUE );
 135     add_bool( "sap-cache", 0 , NULL,
 136                SAP_CACHE_TEXT,SAP_CACHE_LONGTEXT, VLC_TRUE );
 137
 138     set_capability( "services_discovery", 0 );
 139     set_callbacks( Open, Close );
 140
 141     add_submodule();
 142         set_description( _("SDP file parser for UDP") );
 143         add_shortcut( "sdp" );
 144         set_capability( "demux2", 51 );
 145         set_callbacks( OpenDemux, CloseDemux );
 146 vlc_module_end();
 147
 148
 149 /*****************************************************************************
 150  * Local structures
 151  *****************************************************************************/
 152
 153 typedef struct sdp_t sdp_t;
 154 typedef struct attribute_t attribute_t;
 155 typedef struct sap_announce_t sap_announce_t;
 156
 157 /* The structure that contains sdp information */
 158 struct  sdp_t
 159 {
 160     char *psz_sdp;
 161
 162     /* s= field */
 163     char *psz_sessionname;
 164
 165     /* Raw m= and c= fields */
 166     char *psz_connection;
 167     char *psz_media;
 168
 169     /* o field */
 170     char *psz_username;
 171     char *psz_network_type;
 172     char *psz_address_type;
 173     char *psz_address;
 174     int64_t i_session_id;
 175
 176     /* "computed" URI */
 177     char *psz_uri;
 178
 179     int           i_in; /* IP version */
 180
 181     int           i_media;
 182     int           i_media_type;
 183
 184     int           i_attributes;
 185     attribute_t  **pp_attributes;
 186 };
 187
 188 struct attribute_t
 189 {
 190     char *psz_field;
 191     char *psz_value;
 192 };
 193
 194 struct sap_announce_t
 195 {
 196     mtime_t i_last;
 197
 198     uint16_t    i_hash;
 199     uint32_t    i_source[4];
 200
 201     /* SAP annnounces must only contain one SDP */
 202     sdp_t       *p_sdp;
 203
 204     int i_item_id;
 205 //    playlist_item_t *p_item;
 206 };
 207
 208 struct services_discovery_sys_t
 209 {
 210     /* Socket descriptors */
 211     int i_fd;
 212     int *pi_fd;
 213
 214     /* playlist node */
 215     playlist_item_t *p_node;
 216     playlist_t *p_playlist;
 217
 218     /* Table of announces */
 219     int i_announces;
 220     struct sap_announce_t **pp_announces;
 221
 222     /* Modes */
 223     vlc_bool_t  b_strict;
 224     vlc_bool_t  b_parse;
 225
 226     int i_timeout;
 227 };
 228
 229 struct demux_sys_t
 230 {
 231     sdp_t *p_sdp;
 232 };
 233
 234 /*****************************************************************************
 235  * Local prototypes
 236  *****************************************************************************/
 237
 238
 239 /* Main functions */
 240     static int Demux( demux_t *p_demux );
 241     static int Control( demux_t *, int, va_list );
 242     static void Run    ( services_discovery_t *p_sd );
 243
 244 /* Main parsing functions */
 245     static int ParseConnection( vlc_object_t *p_obj, sdp_t *p_sdp );
 246     static int ParseSAP( services_discovery_t *p_sd, uint8_t *p_buffer, int i_read );
 247     static sdp_t *  ParseSDP( vlc_object_t *p_sd, char* psz_sdp );
 248     static sap_announce_t *CreateAnnounce( services_discovery_t *, uint16_t, sdp_t * );
 249     static int RemoveAnnounce( services_discovery_t *p_sd, sap_announce_t *p_announce );
 250
 251 /* Cache */
 252     static void CacheLoad( services_discovery_t *p_sd );
 253     static void CacheSave( services_discovery_t *p_sd );
 254 /* Helper functions */
 255     static char *GetAttribute( sdp_t *p_sdp, const char *psz_search );
 256     static vlc_bool_t IsSameSession( sdp_t *p_sdp1, sdp_t *p_sdp2 );
 257     static int InitSocket( services_discovery_t *p_sd, char *psz_address, int i_port );
 258 #ifdef HAVE_ZLIB_H
 259     static int Decompress( unsigned char *psz_src, unsigned char **_dst, int i_len );
 260 #endif
 261     static void FreeSDP( sdp_t *p_sdp );
 262
 263
 264 #define FREE( p ) \
 265     if( p ) { free( p ); (p) = NULL; }
 266 /*****************************************************************************
 267  * Open: initialize and create stuff
 268  *****************************************************************************/
 269 static int Open( vlc_object_t *p_this )
 270 {
 271     services_discovery_t *p_sd = ( services_discovery_t* )p_this;
 272     services_discovery_sys_t *p_sys  = (services_discovery_sys_t *)
 273                                 malloc( sizeof( services_discovery_sys_t ) );
 274
 275     playlist_view_t     *p_view;
 276     char                *psz_addr;
 277     vlc_value_t         val;
 278
 279     p_sys->i_timeout = var_CreateGetInteger( p_sd, "sap-timeout" );
 280
 281     p_sd->pf_run = Run;
 282     p_sd->p_sys  = p_sys;
 283
 284     p_sys->pi_fd = NULL;
 285     p_sys->i_fd = 0;
 286
 287     p_sys->b_strict = var_CreateGetInteger( p_sd, "sap-strict");
 288     p_sys->b_parse = var_CreateGetInteger( p_sd, "sap-parse" );
 289
 290     if( var_CreateGetInteger( p_sd, "sap-cache" ) )
 291     {
 292         CacheLoad( p_sd );
 293     }
 294
 295     if( var_CreateGetInteger( p_sd, "sap-ipv4" ) )
 296     {
 297         InitSocket( p_sd, SAP_V4_GLOBAL_ADDRESS, SAP_PORT );
 298         InitSocket( p_sd, SAP_V4_ORG_ADDRESS, SAP_PORT );
 299         InitSocket( p_sd, SAP_V4_LOCAL_ADDRESS, SAP_PORT );
 300         InitSocket( p_sd, SAP_V4_LINK_ADDRESS, SAP_PORT );
 301     }
 302     if( var_CreateGetInteger( p_sd, "sap-ipv6" ) )
 303     {
 304         char psz_address[] = SAP_V6_1"0"SAP_V6_2;
 305         const char *c_scope;
 306
 307         for( c_scope = ipv6_scopes; *c_scope; c_scope++ )
 308         {
 309             psz_address[sizeof(SAP_V6_1) - 1] = *c_scope;
 310             InitSocket( p_sd, psz_address, SAP_PORT );
 311         }
 312     }
 313
 314     psz_addr = var_CreateGetString( p_sd, "sap-addr" );
 315     if( psz_addr && *psz_addr )
 316     {
 317         InitSocket( p_sd, psz_addr, SAP_PORT );
 318     }
 319
 320     if( p_sys->i_fd == 0 )
 321     {
 322         msg_Err( p_sd, "unable to read on any address" );
 323         return VLC_EGENERIC;
 324     }
 325
 326     /* Create our playlist node */
 327     p_sys->p_playlist = (playlist_t *)vlc_object_find( p_sd,
 328                                                        VLC_OBJECT_PLAYLIST,
 329                                                        FIND_ANYWHERE );
 330     if( !p_sys->p_playlist )
 331     {
 332         msg_Warn( p_sd, "unable to find playlist, cancelling SAP listening");
 333         return VLC_EGENERIC;
 334     }
 335
 336     p_view = playlist_ViewFind( p_sys->p_playlist, VIEW_CATEGORY );
 337     p_sys->p_node = playlist_NodeCreate( p_sys->p_playlist, VIEW_CATEGORY,
 338                                          _("SAP"), p_view->p_root );
 339     p_sys->p_node->i_flags |= PLAYLIST_RO_FLAG;
 340     p_sys->p_node->i_flags &= ~PLAYLIST_SKIP_FLAG;
 341     val.b_bool = VLC_TRUE;
 342     var_Set( p_sys->p_playlist, "intf-change", val );
 343
 344     p_sys->i_announces = 0;
 345     p_sys->pp_announces = NULL;
 346
 347     return VLC_SUCCESS;
 348 }
 349
 350 /*****************************************************************************
 351  * OpenDemux: initialize and create stuff
 352  *****************************************************************************/
 353 static int OpenDemux( vlc_object_t *p_this )
 354 {
 355     demux_t *p_demux = (demux_t *)p_this;
 356     uint8_t *p_peek;
 357     int i_max_sdp = 1024;
 358     int i_sdp = 0;
 359     char *psz_sdp = NULL;
 360     sdp_t *p_sdp = NULL;
 361
 362     if( !var_CreateGetInteger( p_demux, "sap-parse" ) )
 363     {
 364         /* We want livedotcom module to parse this SDP file */
 365         return VLC_EGENERIC;
 366     }
 367
 368     /* Probe for SDP */
 369     if( p_demux->s )
 370     {
 371         if( stream_Peek( p_demux->s, &p_peek, 7 ) < 7 ) return VLC_EGENERIC;
 372
 373         if( strncmp( (char*)p_peek, "v=0\r\n", 5 ) &&
 374             strncmp( (char*)p_peek, "v=0\n", 4 ) &&
 375             ( p_peek[0] < 'a' || p_peek[0] > 'z' || p_peek[1] != '=' ) )
 376         {
 377             return VLC_EGENERIC;
 378         }
 379     }
 380
 381     psz_sdp = (char *)malloc( i_max_sdp );
 382     if( !psz_sdp ) return VLC_EGENERIC;
 383
 384     /* Gather the complete sdp file */
 385     for( ;; )
 386     {
 387         int i_read = stream_Read( p_demux->s,
 388                                   &psz_sdp[i_sdp], i_max_sdp - i_sdp - 1 );
 389
 390         if( i_read < 0 )
 391         {
 392             msg_Err( p_demux, "failed to read SDP" );
 393             goto error;
 394         }
 395
 396         i_sdp += i_read;
 397
 398         if( i_read < i_max_sdp - i_sdp - 1 )
 399         {
 400             psz_sdp[i_sdp] = '\0';
 401             break;
 402         }
 403
 404         i_max_sdp += 1000;
 405         psz_sdp = (char *)realloc( psz_sdp, i_max_sdp );
 406     }
 407
 408     p_sdp = ParseSDP( VLC_OBJECT(p_demux), psz_sdp );
 409
 410     if( !p_sdp )
 411     {
 412         msg_Warn( p_demux, "invalid SDP");
 413         goto error;
 414     }
 415
 416     if( p_sdp->i_media > 1 )
 417     {
 418         goto error;
 419     }
 420
 421     if( ParseConnection( VLC_OBJECT( p_demux ), p_sdp ) )
 422     {
 423         p_sdp->psz_uri = NULL;
 424     }
 425     if( p_sdp->i_media_type != 33 && p_sdp->i_media_type != 32 &&
 426         p_sdp->i_media_type != 14 )
 427         goto error;
 428
 429     if( p_sdp->psz_uri == NULL ) goto error;
 430
 431     p_demux->p_sys = (demux_sys_t *)malloc( sizeof(demux_sys_t) );
 432     p_demux->p_sys->p_sdp = p_sdp;
 433     p_demux->pf_control = Control;
 434     p_demux->pf_demux = Demux;
 435
 436     free( psz_sdp );
 437     return VLC_SUCCESS;
 438
 439 error:
 440     free( psz_sdp );
 441     if( p_sdp ) FreeSDP( p_sdp );
 442     stream_Seek( p_demux->s, 0 );
 443     return VLC_EGENERIC;
 444 }
 445
 446 /*****************************************************************************
 447  * Close:
 448  *****************************************************************************/
 449 static void Close( vlc_object_t *p_this )
 450 {
 451     services_discovery_t *p_sd = ( services_discovery_t* )p_this;
 452     services_discovery_sys_t    *p_sys  = p_sd->p_sys;
 453
 454     int i;
 455
 456     for( i = p_sys->i_fd-1 ; i >= 0 ; i-- )
 457     {
 458         net_Close( p_sys->pi_fd[i] );
 459     }
 460     FREE( p_sys->pi_fd );
 461
 462     if( config_GetInt( p_sd, "sap-cache" ) )
 463     {
 464         CacheSave( p_sd );
 465     }
 466
 467     for( i = p_sys->i_announces  - 1;  i>= 0; i-- )
 468     {
 469         RemoveAnnounce( p_sd, p_sys->pp_announces[i] );
 470     }
 471     FREE( p_sys->pp_announces );
 472
 473     if( p_sys->p_playlist )
 474     {
 475         playlist_NodeDelete( p_sys->p_playlist, p_sys->p_node, VLC_TRUE,
 476                              VLC_TRUE );
 477         vlc_object_release( p_sys->p_playlist );
 478     }
 479
 480     free( p_sys );
 481 }
 482
 483 /*****************************************************************************
 484  * CloseDemux: Close the demuxer
 485  *****************************************************************************/
 486 static void CloseDemux( vlc_object_t *p_this )
 487 {
 488
 489 }
 490
 491 /*****************************************************************************
 492  * Run: main SAP thread
 493  *****************************************************************************
 494  * Listens to SAP packets, and sends them to packet_handle
 495  *****************************************************************************/
 496 #define MAX_SAP_BUFFER 5000
 497
 498 static void Run( services_discovery_t *p_sd )
 499 {
 500     int i;
 501
 502     /* read SAP packets */
 503     while( !p_sd->b_die )
 504     {
 505         int i_read;
 506         uint8_t p_buffer[MAX_SAP_BUFFER+1];
 507
 508         i_read = net_Select( p_sd, p_sd->p_sys->pi_fd, NULL,
 509                              p_sd->p_sys->i_fd, p_buffer,
 510                              MAX_SAP_BUFFER, 500000 );
 511
 512         /* Check for items that need deletion */
 513         for( i = 0; i < p_sd->p_sys->i_announces; i++ )
 514         {
 515             mtime_t i_timeout = ( mtime_t ) 1000000 * p_sd->p_sys->i_timeout;
 516
 517             if( mdate() - p_sd->p_sys->pp_announces[i]->i_last > i_timeout )
 518             {
 519                 struct sap_announce_t *p_announce;
 520                 p_announce = p_sd->p_sys->pp_announces[i];
 521
 522                 /* Remove the playlist item */
 523                 playlist_LockDelete( p_sd->p_sys->p_playlist,
 524                                      p_announce->i_item_id );
 525
 526                 /* Remove the sap_announce from the array */
 527                 REMOVE_ELEM( p_sd->p_sys->pp_announces,
 528                            p_sd->p_sys->i_announces, i );
 529
 530                 free( p_announce );
 531             }
 532         }
 533
 534         /* Minimum length is > 6 */
 535         if( i_read <= 6 )
 536         {
 537             if( i_read < 0 )
 538             {
 539                 msg_Warn( p_sd, "socket read error" );
 540             }
 541             continue;
 542         }
 543
 544         p_buffer[i_read] = '\0';
 545
 546         /* Parse the packet */
 547         ParseSAP( p_sd, p_buffer, i_read );
 548     }
 549 }
 550
 551 /**********************************************************************
 552  * Demux: reads and demuxes data packets
 553  * Return -1 if error, 0 if EOF, 1 else
 554  **********************************************************************/
 555 static int Demux( demux_t *p_demux )
 556 {
 557     sdp_t *p_sdp = p_demux->p_sys->p_sdp;
 558     playlist_t *p_playlist;
 559
 560     p_playlist = (playlist_t *)vlc_object_find( p_demux, VLC_OBJECT_PLAYLIST,
 561                                                FIND_ANYWHERE );
 562
 563     p_playlist->status.p_item->i_flags |= PLAYLIST_DEL_FLAG;
 564
 565     playlist_Add( p_playlist, p_sdp->psz_uri, p_sdp->psz_sessionname,
 566                  PLAYLIST_APPEND, PLAYLIST_END );
 567
 568     vlc_object_release( p_playlist );
 569     if( p_sdp ) FreeSDP( p_sdp );
 570
 571     return VLC_SUCCESS;
 572 }
 573
 574 static int Control( demux_t *p_demux, int i_query, va_list args )
 575 {
 576     return VLC_EGENERIC;
 577 }
 578
 579 /**************************************************************
 580  * Local functions
 581  **************************************************************/
 582
 583 /* i_read is at least > 6 */
 584 static int ParseSAP( services_discovery_t *p_sd, uint8_t *p_buffer, int i_read )
 585 {
 586     int                 i_version, i_address_type, i_hash, i;
 587     char                *psz_sdp, *psz_foo, *psz_initial_sdp;
 588     sdp_t               *p_sdp;
 589     vlc_bool_t          b_compressed;
 590     vlc_bool_t          b_need_delete = VLC_FALSE;
 591
 592     /* First, check the sap announce is correct */
 593     i_version = p_buffer[0] >> 5;
 594     if( i_version != 1 )
 595     {
 596        msg_Dbg( p_sd, "strange sap version %d found", i_version );
 597     }
 598
 599     i_address_type = p_buffer[0] & 0x10;
 600
 601     if( (p_buffer[0] & 0x08) != 0 )
 602     {
 603         msg_Dbg( p_sd, "reserved bit incorrectly set" );
 604         return VLC_EGENERIC;
 605     }
 606
 607     if( (p_buffer[0] & 0x04) != 0 )
 608     {
 609         msg_Dbg( p_sd, "session deletion packet" );
 610         b_need_delete = VLC_TRUE;
 611     }
 612
 613     if( p_buffer[0] & 0x02  )
 614     {
 615         msg_Dbg( p_sd, "encrypted packet, unsupported" );
 616         return VLC_EGENERIC;
 617     }
 618
 619     b_compressed = p_buffer[0] & 0x01;
 620
 621     i_hash = ( p_buffer[2] << 8 ) + p_buffer[3];
 622
 623     if( p_sd->p_sys->b_strict && i_hash == 0 )
 624     {
 625         msg_Dbg( p_sd, "strict mode, discarding announce with null id hash");
 626         return VLC_EGENERIC;
 627     }
 628
 629     psz_sdp  = (char *)p_buffer + 4;
 630     psz_initial_sdp = psz_sdp;
 631
 632     if( i_address_type == 0 ) /* ipv4 source address */
 633     {
 634         psz_sdp += 4;
 635         if( i_read <= 9 )
 636         {
 637             msg_Warn( p_sd, "too short SAP packet\n" );
 638             return VLC_EGENERIC;
 639         }
 640     }
 641     else /* ipv6 source address */
 642     {
 643         psz_sdp += 16;
 644         if( i_read <= 21 )
 645         {
 646             msg_Warn( p_sd, "too short SAP packet\n" );
 647             return VLC_EGENERIC;
 648         }
 649     }
 650
 651     if( b_compressed )
 652     {
 653 #ifdef HAVE_ZLIB_H
 654         uint8_t *p_decompressed_buffer = NULL;
 655         int      i_decompressed_size;
 656
 657         i_decompressed_size = Decompress( (uint8_t *)psz_sdp,
 658                    &p_decompressed_buffer, i_read - ( psz_sdp - (char *)p_buffer ) );
 659         if( i_decompressed_size > 0 && i_decompressed_size < MAX_SAP_BUFFER )
 660         {
 661             memcpy( psz_sdp, p_decompressed_buffer, i_decompressed_size );
 662             psz_sdp[i_decompressed_size] = '\0';
 663             free( p_decompressed_buffer );
 664         }
 665 #else
 666         msg_Warn( p_sd, "Ignoring compressed sap packet" );
 667         return VLC_EGENERIC;
 668 #endif
 669     }
 670
 671     /* Add the size of authentification info */
 672     if( i_read < p_buffer[1] + (psz_sdp - psz_initial_sdp ) )
 673     {
 674         msg_Warn( p_sd, "too short SAP packet\n");
 675         return VLC_EGENERIC;
 676     }
 677     psz_sdp += p_buffer[1];
 678     psz_foo = psz_sdp;
 679
 680     /* Skip payload type */
 681     /* Handle announces without \0 between SAP and SDP */
 682     while( *psz_sdp != '\0' && ( psz_sdp[0] != 'v' && psz_sdp[1] != '=' ) )
 683     {
 684         if( psz_sdp - psz_initial_sdp >= i_read - 5 )
 685         {
 686             msg_Warn( p_sd, "empty SDP ?");
 687         }
 688         psz_sdp++;
 689     }
 690
 691     if( *psz_sdp == '\0' )
 692     {
 693         psz_sdp++;
 694     }
 695     if( ( psz_sdp != psz_foo ) && strcasecmp( psz_foo, "application/sdp" ) )
 696     {
 697         msg_Dbg( p_sd, "unhandled content type: %s", psz_foo );
 698     }
 699     if( ( psz_sdp - (char *)p_buffer ) >= i_read )
 700     {
 701         msg_Warn( p_sd, "package without content" );
 702         return VLC_EGENERIC;
 703     }
 704
 705     /* Parse SDP info */
 706     p_sdp = ParseSDP( VLC_OBJECT(p_sd), psz_sdp );
 707
 708     if( p_sdp == NULL )
 709     {
 710         return VLC_EGENERIC;
 711     }
 712
 713     /* Decide whether we should add a playlist item for this SDP */
 714     /* Parse connection information (c= & m= ) */
 715     if( ParseConnection( VLC_OBJECT(p_sd), p_sdp ) )
 716     {
 717         p_sdp->psz_uri = NULL;
 718     }
 719
 720     /* Multi-media or no-parse -> pass to LIVE.COM */
 721     if( p_sdp->i_media > 1 || ( p_sdp->i_media_type != 14 &&
 722                                 p_sdp->i_media_type != 32 &&
 723                                 p_sdp->i_media_type != 33) ||
 724         p_sd->p_sys->b_parse == VLC_FALSE )
 725     {
 726         if( p_sdp->psz_uri ) free( p_sdp->psz_uri );
 727         asprintf( &p_sdp->psz_uri, "sdp://%s", p_sdp->psz_sdp );
 728     }
 729
 730     if( p_sdp->psz_uri == NULL ) return VLC_EGENERIC;
 731
 732     for( i = 0 ; i< p_sd->p_sys->i_announces ; i++ )
 733     {
 734         /* FIXME: slow */
 735         /* FIXME: we create a new announce each time the sdp changes */
 736         if( IsSameSession( p_sd->p_sys->pp_announces[i]->p_sdp, p_sdp ) )
 737         {
 738             if( b_need_delete )
 739             {
 740                 RemoveAnnounce( p_sd, p_sd->p_sys->pp_announces[i]);
 741                 return VLC_SUCCESS;
 742             }
 743             else
 744             {
 745                 p_sd->p_sys->pp_announces[i]->i_last = mdate();
 746                 FreeSDP( p_sdp );
 747                 return VLC_SUCCESS;
 748             }
 749         }
 750     }
 751     /* Add item */
 752     if( p_sdp->i_media > 1 )
 753     {
 754         msg_Dbg( p_sd, "passing to LIVE.COM" );
 755     }
 756
 757     CreateAnnounce( p_sd, i_hash, p_sdp );
 758
 759     return VLC_SUCCESS;
 760 }
 761
 762 sap_announce_t *CreateAnnounce( services_discovery_t *p_sd, uint16_t i_hash,
 763                                 sdp_t *p_sdp )
 764 {
 765     playlist_item_t     *p_item, *p_child;
 766     char *psz_value;
 767     sap_announce_t *p_sap = (sap_announce_t *)malloc(
 768                                         sizeof(sap_announce_t ) );
 769     if( p_sap == NULL )
 770         return NULL;
 771
 772     EnsureUTF8( p_sdp->psz_sessionname );
 773     p_sap->i_last = mdate();
 774     p_sap->i_hash = i_hash;
 775     p_sap->p_sdp = p_sdp;
 776     p_sap->i_item_id = -1;
 777
 778     /* Create the playlist item here */
 779     p_item = playlist_ItemNew( p_sd, p_sap->p_sdp->psz_uri,
 780                                p_sdp->psz_sessionname );
 781
 782     if( !p_item )
 783     {
 784         free( p_sap );
 785         return NULL;
 786     }
 787
 788     psz_value = GetAttribute( p_sap->p_sdp, "tool" );
 789     if( psz_value != NULL )
 790     {
 791         vlc_input_item_AddInfo( &p_item->input, _("Session"),
 792                                 _("Tool"), psz_value );
 793     }
 794     if( strcmp( p_sdp->psz_username, "-" ) )
 795     {
 796         vlc_input_item_AddInfo( &p_item->input, _("Session"),
 797                                 _("User"), p_sdp->psz_username );
 798     }
 799
 800     psz_value = GetAttribute( p_sap->p_sdp, "x-plgroup" );
 801
 802     if( psz_value == NULL )
 803     {
 804         psz_value = GetAttribute( p_sap->p_sdp, "plgroup" );
 805     }
 806
 807     if( psz_value != NULL )
 808     {
 809         EnsureUTF8( psz_value );
 810
 811         p_child = playlist_ChildSearchName( p_sd->p_sys->p_node, psz_value );
 812
 813         if( p_child == NULL )
 814         {
 815             p_child = playlist_NodeCreate( p_sd->p_sys->p_playlist,
 816                                            VIEW_CATEGORY, psz_value,
 817                                            p_sd->p_sys->p_node );
 818             p_child->i_flags &= ~PLAYLIST_SKIP_FLAG;
 819         }
 820     }
 821     else
 822     {
 823         p_child = p_sd->p_sys->p_node;
 824     }
 825
 826     p_item->i_flags &= ~PLAYLIST_SKIP_FLAG;
 827     p_item->i_flags &= ~PLAYLIST_SAVE_FLAG;
 828
 829     playlist_NodeAddItem( p_sd->p_sys->p_playlist, p_item, VIEW_CATEGORY,
 830                               p_child, PLAYLIST_APPEND, PLAYLIST_END );
 831
 832     p_sap->i_item_id = p_item->input.i_id;
 833
 834     TAB_APPEND( p_sd->p_sys->i_announces,
 835                 p_sd->p_sys->pp_announces, p_sap );
 836
 837     return p_sap;
 838 }
 839
 840 static char *GetAttribute( sdp_t *p_sdp, const char *psz_search )
 841 {
 842     int i;
 843
 844     for( i = 0 ; i< p_sdp->i_attributes; i++ )
 845     {
 846         if( !strncmp( p_sdp->pp_attributes[i]->psz_field, psz_search,
 847                       strlen( p_sdp->pp_attributes[i]->psz_field ) ) )
 848         {
 849             return p_sdp->pp_attributes[i]->psz_value;
 850         }
 851     }
 852     return NULL;
 853 }
 854
 855
 856 /* Fill p_sdp->psz_uri */
 857 static int ParseConnection( vlc_object_t *p_obj, sdp_t *p_sdp )
 858 {
 859     char *psz_eof;
 860     char *psz_parse;
 861     char *psz_uri = NULL;
 862     char *psz_proto = NULL;
 863     int i_port = 0;
 864
 865     /* Parse c= field */
 866     if( p_sdp->psz_connection )
 867     {
 868         psz_parse = p_sdp->psz_connection;
 869
 870         psz_eof = strchr( psz_parse, ' ' );
 871
 872         if( psz_eof )
 873         {
 874             *psz_eof = '\0';
 875             psz_parse = psz_eof + 1;
 876         }
 877         else
 878         {
 879             msg_Warn( p_obj, "unable to parse c field (1)");
 880             return VLC_EGENERIC;
 881         }
 882
 883         psz_eof = strchr( psz_parse, ' ' );
 884
 885         if( psz_eof )
 886         {
 887             *psz_eof = '\0';
 888             if( !strncmp( psz_parse, "IP4", 3 ) )
 889             {
 890                 p_sdp->i_in = 4;
 891             }
 892             else if( !strncmp( psz_parse, "IP6", 3 ) )
 893             {
 894                 p_sdp->i_in = 6;
 895             }
 896             else
 897             {
 898                 p_sdp->i_in = 0;
 899             }
 900             psz_parse = psz_eof + 1;
 901         }
 902         else
 903         {
 904             msg_Warn( p_obj, "unable to parse c field (2)");
 905             return VLC_EGENERIC;
 906         }
 907
 908         psz_eof = strchr( psz_parse, '/' );
 909
 910         if( psz_eof )
 911         {
 912             *psz_eof = '\0';
 913         }
 914         else
 915         {
 916             msg_Dbg( p_obj, "incorrect c field, %s", p_sdp->psz_connection );
 917         }
 918         if( p_sdp->i_in == 6 && ( isxdigit( *psz_parse ) || *psz_parse == ':' ) )
 919         {
 920             asprintf( &psz_uri, "[%s]", psz_parse );
 921         }
 922         else psz_uri = strdup( psz_parse );
 923
 924     }
 925
 926     /* Parse m= field */
 927     if( p_sdp->psz_media )
 928     {
 929         psz_parse = p_sdp->psz_media;
 930
 931         psz_eof = strchr( psz_parse, ' ' );
 932
 933         if( psz_eof )
 934         {
 935             *psz_eof = '\0';
 936
 937             if( strncmp( psz_parse, "audio", 5 )  &&
 938                 strncmp( psz_parse, "video", 5 ) )
 939             {
 940                 msg_Warn( p_obj, "unhandled media type -%s-", psz_parse );
 941                 FREE( psz_uri );
 942                 return VLC_EGENERIC;
 943             }
 944
 945             psz_parse = psz_eof + 1;
 946         }
 947         else
 948         {
 949             msg_Warn( p_obj, "unable to parse m field (1)");
 950             FREE( psz_uri );
 951             return VLC_EGENERIC;
 952         }
 953
 954         psz_eof = strchr( psz_parse, ' ' );
 955
 956         if( psz_eof )
 957         {
 958             *psz_eof = '\0';
 959
 960             /* FIXME : multiple port ! */
 961             i_port = atoi( psz_parse );
 962
 963             if( i_port <= 0 || i_port >= 65536 )
 964             {
 965                 msg_Warn( p_obj, "invalid transport port %i", i_port );
 966             }
 967
 968             psz_parse = psz_eof + 1;
 969         }
 970         else
 971         {
 972             msg_Warn( p_obj, "unable to parse m field (2)");
 973             FREE( psz_uri );
 974             return VLC_EGENERIC;
 975         }
 976
 977         psz_eof = strchr( psz_parse, ' ' );
 978
 979         if( psz_eof )
 980         {
 981             *psz_eof = '\0';
 982             psz_proto = strdup( psz_parse );
 983
 984             psz_parse = psz_eof + 1;
 985             p_sdp->i_media_type = atoi( psz_parse );
 986
 987         }
 988         else
 989         {
 990             msg_Dbg( p_obj, "incorrect m field, %s", p_sdp->psz_media );
 991             p_sdp->i_media_type = 33;
 992             psz_proto = strdup( psz_parse );
 993         }
 994     }
 995
 996     if( psz_proto && !strncmp( psz_proto, "RTP/AVP", 7 ) )
 997     {
 998         free( psz_proto );
 999         psz_proto = strdup( "rtp" );
1000     }
1001     if( psz_proto && !strncasecmp( psz_proto, "UDP", 3 ) )
1002     {
1003         free( psz_proto );
1004         psz_proto = strdup( "udp" );
1005     }
1006
1007     /* FIXME: HTTP support */
1008
1009     if( i_port == 0 )
1010     {
1011         i_port = 1234;
1012     }
1013
1014     asprintf( &p_sdp->psz_uri, "%s://@%s:%i", psz_proto, psz_uri, i_port );
1015
1016     FREE( psz_uri );
1017     FREE( psz_proto );
1018     return VLC_SUCCESS;
1019 }
1020
1021 /***********************************************************************
1022  * ParseSDP : SDP parsing
1023  * *********************************************************************
1024  * Validate SDP and parse all fields
1025  ***********************************************************************/
1026 static sdp_t *  ParseSDP( vlc_object_t *p_obj, char* psz_sdp )
1027 {
1028     sdp_t *p_sdp;
1029     vlc_bool_t b_invalid = VLC_FALSE;
1030     vlc_bool_t b_end = VLC_FALSE;
1031     if( psz_sdp == NULL )
1032     {
1033         return NULL;
1034     }
1035
1036     if( psz_sdp[0] != 'v' || psz_sdp[1] != '=' )
1037     {
1038         msg_Warn( p_obj, "Bad packet" );
1039         return NULL;
1040     }
1041
1042     p_sdp = (sdp_t *)malloc( sizeof( sdp_t ) );
1043     if( p_sdp == NULL )
1044         return NULL;
1045
1046     p_sdp->psz_sdp = strdup( psz_sdp );
1047     if( p_sdp->psz_sdp == NULL )
1048     {
1049         free( p_sdp );
1050         return NULL;
1051     }
1052
1053     p_sdp->psz_sessionname = NULL;
1054     p_sdp->psz_media       = NULL;
1055     p_sdp->psz_connection  = NULL;
1056     p_sdp->psz_uri         = NULL;
1057     p_sdp->psz_address     = NULL;
1058     p_sdp->psz_address_type= NULL;
1059
1060     p_sdp->i_media         = 0;
1061     p_sdp->i_attributes    = 0;
1062     p_sdp->pp_attributes   = NULL;
1063
1064     while( *psz_sdp != '\0' && b_end == VLC_FALSE  )
1065     {
1066         char *psz_eol;
1067         char *psz_eof;
1068         char *psz_parse;
1069         char *psz_sess_id;
1070
1071         while( *psz_sdp == '\r' || *psz_sdp == '\n' ||
1072                *psz_sdp == ' ' || *psz_sdp == '\t' )
1073         {
1074             psz_sdp++;
1075         }
1076
1077         if( ( psz_eol = strchr( psz_sdp, '\n' ) ) == NULL )
1078         {
1079             psz_eol = psz_sdp + strlen( psz_sdp );
1080             b_end = VLC_TRUE;
1081         }
1082         if( psz_eol > psz_sdp && *( psz_eol - 1 ) == '\r' )
1083         {
1084             psz_eol--;
1085         }
1086
1087         if( psz_eol <= psz_sdp )
1088         {
1089             break;
1090         }
1091         *psz_eol++ = '\0';
1092
1093         /* no space allowed between fields */
1094         if( psz_sdp[1] != '=' )
1095         {
1096             msg_Warn( p_obj, "invalid packet" ) ;
1097             FreeSDP( p_sdp );
1098             return NULL;
1099         }
1100
1101         /* Now parse each line */
1102         switch( psz_sdp[0] )
1103         {
1104             case( 'v' ):
1105                 break;
1106             case( 's' ):
1107                 p_sdp->psz_sessionname = strdup( &psz_sdp[2] );
1108                 break;
1109             case ( 'o' ):
1110             {
1111                 int i_field = 0;
1112                 /* o field is <username> <session id> <version>
1113                  *  <network type> <address type> <address> */
1114
1115 #define GET_FIELD( store ) \
1116                 psz_eof = strchr( psz_parse, ' ' ); \
1117                 if( psz_eof ) \
1118                 { \
1119                     *psz_eof=0; store = strdup( psz_parse ); \
1120                 } \
1121                 else \
1122                 { \
1123                     if( i_field != 5 ) \
1124                     { \
1125                         b_invalid = VLC_TRUE; break; \
1126                     } \
1127                     else \
1128                     { \
1129                         store = strdup( psz_parse ); \
1130                     } \
1131                 }; \
1132                 psz_parse = psz_eof + 1; i_field++;
1133
1134
1135                 psz_parse = &psz_sdp[2];
1136                 GET_FIELD( p_sdp->psz_username );
1137                 GET_FIELD( psz_sess_id );
1138
1139                 p_sdp->i_session_id = atoll( psz_sess_id );
1140
1141                 FREE( psz_sess_id );
1142
1143                 GET_FIELD( psz_sess_id );
1144                 FREE( psz_sess_id );
1145
1146                 GET_FIELD( p_sdp->psz_network_type );
1147                 GET_FIELD( p_sdp->psz_address_type );
1148                 GET_FIELD( p_sdp->psz_address );
1149
1150                 break;
1151             }
1152             case( 'i' ):
1153             case( 'u' ):
1154             case( 'e' ):
1155             case( 'p' ):
1156             case( 't' ):
1157             case( 'r' ):
1158                 break;
1159             case( 'a' ): /* attribute */
1160             {
1161                 char *psz_eon = strchr( &psz_sdp[2], ':' );
1162                 attribute_t *p_attr = malloc( sizeof( attribute_t ) );
1163
1164                 /* Attribute with value */
1165                 if( psz_eon )
1166                 {
1167                     *psz_eon++ = '\0';
1168
1169                     p_attr->psz_field = strdup( &psz_sdp[2] );
1170                     p_attr->psz_value = strdup( psz_eon );
1171                 }
1172                 else /* Attribute without value */
1173                 {
1174                     p_attr->psz_field = strdup( &psz_sdp[2] );
1175                     p_attr->psz_value = NULL;
1176                 }
1177
1178                 TAB_APPEND( p_sdp->i_attributes, p_sdp->pp_attributes, p_attr );
1179                 break;
1180             }
1181
1182             case( 'm' ): /* Media announcement */
1183             {
1184                 /* If we have several medias, we pass the announcement to
1185                  * LIVE.COM, so just count them */
1186                 p_sdp->i_media++;
1187                 if( p_sdp->i_media == 1 )
1188                 {
1189                     p_sdp->psz_media = strdup( &psz_sdp[2] );
1190                 }
1191                 break;
1192             }
1193
1194             case( 'c' ):
1195             {
1196                 if( p_sdp->i_media > 1 )
1197                     break;
1198
1199                 p_sdp->psz_connection = strdup( &psz_sdp[2] );
1200                 break;
1201             }
1202
1203             default:
1204                break;
1205         }
1206
1207         if( b_invalid )
1208         {
1209             FreeSDP( p_sdp );
1210             return NULL;
1211         }
1212
1213         psz_sdp = psz_eol;
1214     }
1215
1216     return p_sdp;
1217 }
1218
1219 static int InitSocket( services_discovery_t *p_sd, char *psz_address,
1220                        int i_port )
1221 {
1222     int i_fd = net_OpenUDP( p_sd, psz_address, i_port, "", 0 );
1223
1224     if( i_fd != -1 )
1225     {
1226         net_StopSend( i_fd );
1227         INSERT_ELEM(  p_sd->p_sys->pi_fd, p_sd->p_sys->i_fd,
1228                       p_sd->p_sys->i_fd, i_fd );
1229         return VLC_SUCCESS;
1230     }
1231
1232     return VLC_EGENERIC;
1233 }
1234
1235 #ifdef HAVE_ZLIB_H
1236 static int Decompress( unsigned char *psz_src, unsigned char **_dst, int i_len )
1237 {
1238     int i_result, i_dstsize, n;
1239     unsigned char *psz_dst;
1240     z_stream d_stream;
1241
1242     d_stream.zalloc = (alloc_func)0;
1243     d_stream.zfree = (free_func)0;
1244     d_stream.opaque = (voidpf)0;
1245
1246     i_result = inflateInit(&d_stream);
1247     if( i_result != Z_OK )
1248     {
1249         printf( "inflateInit() failed. Result: %d\n", i_result );
1250         return( -1 );
1251     }
1252 #if 0
1253     p_playlist->pp_items[p_playlist->i_index]->b_autodeletion = VLC_TRUE;
1254     i_position = p_playlist->i_index;
1255
1256     /* Gather the complete sdp file */
1257     for( ;; )
1258     {
1259         int i_read = stream_Read( p_demux->s, &p_sdp[i_sdp], i_sdp_max - i_sdp - 1 );
1260 #endif
1261     d_stream.next_in = (Bytef *)psz_src;
1262     d_stream.avail_in = i_len;
1263     n = 0;
1264
1265     psz_dst = NULL;
1266
1267     do
1268     {
1269         n++;
1270         psz_dst = (unsigned char *)realloc( psz_dst, n * 1000 );
1271         d_stream.next_out = (Bytef *)&psz_dst[(n - 1) * 1000];
1272         d_stream.avail_out = 1000;
1273
1274         i_result = inflate(&d_stream, Z_NO_FLUSH);
1275         if( ( i_result != Z_OK ) && ( i_result != Z_STREAM_END ) )
1276         {
1277             printf( "Zlib decompression failed. Result: %d\n", i_result );
1278             return( -1 );
1279         }
1280     }
1281     while( ( d_stream.avail_out == 0 ) && ( d_stream.avail_in != 0 ) &&
1282            ( i_result != Z_STREAM_END ) );
1283
1284     i_dstsize = d_stream.total_out;
1285     inflateEnd( &d_stream );
1286
1287     *_dst = (unsigned char *)realloc( psz_dst, i_dstsize );
1288
1289     return i_dstsize;
1290 }
1291 #endif
1292
1293
1294 static void FreeSDP( sdp_t *p_sdp )
1295 {
1296     int i;
1297     FREE( p_sdp->psz_sdp );
1298     FREE( p_sdp->psz_sessionname );
1299     FREE( p_sdp->psz_connection );
1300     FREE( p_sdp->psz_media );
1301     FREE( p_sdp->psz_uri );
1302     FREE( p_sdp->psz_username );
1303     FREE( p_sdp->psz_network_type );
1304
1305     FREE( p_sdp->psz_address );
1306     FREE( p_sdp->psz_address_type );
1307
1308     for( i= p_sdp->i_attributes - 1; i >= 0 ; i-- )
1309     {
1310         struct attribute_t *p_attr = p_sdp->pp_attributes[i];
1311         FREE( p_sdp->pp_attributes[i]->psz_field );
1312         FREE( p_sdp->pp_attributes[i]->psz_value );
1313         REMOVE_ELEM( p_sdp->pp_attributes, p_sdp->i_attributes, i);
1314         FREE( p_attr );
1315     }
1316     free( p_sdp );
1317 }
1318
1319 static int RemoveAnnounce( services_discovery_t *p_sd,
1320                            sap_announce_t *p_announce )
1321 {
1322     int i;
1323
1324     if( p_announce->p_sdp ) FreeSDP( p_announce->p_sdp );
1325
1326     if( p_announce->i_item_id > -1 )
1327     {
1328         playlist_LockDelete( p_sd->p_sys->p_playlist, p_announce->i_item_id );
1329     }
1330
1331     for( i = 0; i< p_sd->p_sys->i_announces; i++)
1332     {
1333         if( p_sd->p_sys->pp_announces[i] == p_announce )
1334         {
1335             REMOVE_ELEM( p_sd->p_sys->pp_announces, p_sd->p_sys->i_announces,
1336                          i);
1337             break;
1338         }
1339     }
1340
1341     free( p_announce );
1342
1343     return VLC_SUCCESS;
1344 }
1345
1346 static vlc_bool_t IsSameSession( sdp_t *p_sdp1, sdp_t *p_sdp2 )
1347 {
1348     /* A session is identified by
1349      * username, session_id, network type, address type and address */
1350     if( p_sdp1->psz_username && p_sdp2->psz_username &&
1351         p_sdp1->psz_network_type && p_sdp2->psz_network_type &&
1352         p_sdp1->psz_address_type && p_sdp2->psz_address_type &&
1353         p_sdp1->psz_address &&  p_sdp2->psz_address )
1354     {
1355         if(!strcmp( p_sdp1->psz_username , p_sdp2->psz_username ) &&
1356            !strcmp( p_sdp1->psz_network_type , p_sdp2->psz_network_type ) &&
1357            !strcmp( p_sdp1->psz_address_type , p_sdp2->psz_address_type ) &&
1358            !strcmp( p_sdp1->psz_address , p_sdp2->psz_address ) &&
1359            p_sdp1->i_session_id == p_sdp2->i_session_id )
1360         {
1361             return VLC_TRUE;
1362         }
1363         else
1364         {
1365             return VLC_FALSE;
1366         }
1367     }
1368     else
1369     {
1370         return VLC_FALSE;
1371     }
1372 }
1373
1374
1375 static void CacheLoad( services_discovery_t *p_sd )
1376 {
1377     msg_Warn( p_sd, "Cache not implemented") ;
1378 }
1379
1380 static void CacheSave( services_discovery_t *p_sd )
1381 {
1382     msg_Warn( p_sd, "Cache not implemented") ;
1383 }