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         psz_uri = strdup( psz_parse );
 919
 920     }
 921
 922     /* Parse m= field */
 923     if( p_sdp->psz_media )
 924     {
 925         psz_parse = p_sdp->psz_media;
 926
 927         psz_eof = strchr( psz_parse, ' ' );
 928
 929         if( psz_eof )
 930         {
 931             *psz_eof = '\0';
 932
 933             if( strncmp( psz_parse, "audio", 5 )  &&
 934                 strncmp( psz_parse, "video",5 ) )
 935             {
 936                 msg_Warn( p_obj, "unhandled media type -%s-", psz_parse );
 937                 FREE( psz_uri );
 938                 return VLC_EGENERIC;
 939             }
 940
 941             psz_parse = psz_eof + 1;
 942         }
 943         else
 944         {
 945             msg_Warn( p_obj, "unable to parse m field (1)");
 946             FREE( psz_uri );
 947             return VLC_EGENERIC;
 948         }
 949
 950         psz_eof = strchr( psz_parse, ' ' );
 951
 952         if( psz_eof )
 953         {
 954             *psz_eof = '\0';
 955
 956             /* FIXME : multiple port ! */
 957             i_port = atoi( psz_parse );
 958
 959             if( i_port <= 0 || i_port >= 65536 )
 960             {
 961                 msg_Warn( p_obj, "invalid transport port %i", i_port );
 962             }
 963
 964             psz_parse = psz_eof + 1;
 965         }
 966         else
 967         {
 968             msg_Warn( p_obj, "unable to parse m field (2)");
 969             FREE( psz_uri );
 970             return VLC_EGENERIC;
 971         }
 972
 973         psz_eof = strchr( psz_parse, ' ' );
 974
 975         if( psz_eof )
 976         {
 977             *psz_eof = '\0';
 978             psz_proto = strdup( psz_parse );
 979
 980             psz_parse = psz_eof + 1;
 981             p_sdp->i_media_type = atoi( psz_parse );
 982
 983         }
 984         else
 985         {
 986             msg_Dbg( p_obj, "incorrect m field, %s", p_sdp->psz_media );
 987             p_sdp->i_media_type = 33;
 988             psz_proto = strdup( psz_parse );
 989         }
 990     }
 991
 992     if( psz_proto && !strncmp( psz_proto, "RTP/AVP", 7 ) )
 993     {
 994         free( psz_proto );
 995         psz_proto = strdup( "rtp" );
 996     }
 997     if( psz_proto && !strncasecmp( psz_proto, "UDP", 3 ) )
 998     {
 999         free( psz_proto );
1000         psz_proto = strdup( "udp" );
1001     }
1002
1003     /* FIXME: HTTP support */
1004
1005     if( i_port == 0 )
1006     {
1007         i_port = 1234;
1008     }
1009
1010     if( net_AddressIsMulticast( p_obj, psz_uri ) )
1011     {
1012         asprintf( &p_sdp->psz_uri, "%s://@%s:%i", psz_proto, psz_uri, i_port );
1013     }
1014     else
1015     {
1016         asprintf( &p_sdp->psz_uri, "%s://%s:%i", psz_proto, psz_uri, i_port );
1017     }
1018     FREE( psz_uri );
1019     FREE( psz_proto );
1020     return VLC_SUCCESS;
1021 }
1022
1023 /***********************************************************************
1024  * ParseSDP : SDP parsing
1025  * *********************************************************************
1026  * Validate SDP and parse all fields
1027  ***********************************************************************/
1028 static sdp_t *  ParseSDP( vlc_object_t *p_obj, char* psz_sdp )
1029 {
1030     sdp_t *p_sdp;
1031     vlc_bool_t b_invalid = VLC_FALSE;
1032     vlc_bool_t b_end = VLC_FALSE;
1033     if( psz_sdp == NULL )
1034     {
1035         return NULL;
1036     }
1037
1038     if( psz_sdp[0] != 'v' || psz_sdp[1] != '=' )
1039     {
1040         msg_Warn( p_obj, "Bad packet" );
1041         return NULL;
1042     }
1043
1044     p_sdp = (sdp_t *)malloc( sizeof( sdp_t ) );
1045     if( p_sdp == NULL )
1046         return NULL;
1047
1048     p_sdp->psz_sdp = strdup( psz_sdp );
1049     if( p_sdp->psz_sdp == NULL )
1050     {
1051         free( p_sdp );
1052         return NULL;
1053     }
1054
1055     p_sdp->psz_sessionname = NULL;
1056     p_sdp->psz_media       = NULL;
1057     p_sdp->psz_connection  = NULL;
1058     p_sdp->psz_uri         = NULL;
1059     p_sdp->psz_address     = NULL;
1060     p_sdp->psz_address_type= NULL;
1061
1062     p_sdp->i_media         = 0;
1063     p_sdp->i_attributes    = 0;
1064     p_sdp->pp_attributes   = NULL;
1065
1066     while( *psz_sdp != '\0' && b_end == VLC_FALSE  )
1067     {
1068         char *psz_eol;
1069         char *psz_eof;
1070         char *psz_parse;
1071         char *psz_sess_id;
1072
1073         while( *psz_sdp == '\r' || *psz_sdp == '\n' ||
1074                *psz_sdp == ' ' || *psz_sdp == '\t' )
1075         {
1076             psz_sdp++;
1077         }
1078
1079         if( ( psz_eol = strchr( psz_sdp, '\n' ) ) == NULL )
1080         {
1081             psz_eol = psz_sdp + strlen( psz_sdp );
1082             b_end = VLC_TRUE;
1083         }
1084         if( psz_eol > psz_sdp && *( psz_eol - 1 ) == '\r' )
1085         {
1086             psz_eol--;
1087         }
1088
1089         if( psz_eol <= psz_sdp )
1090         {
1091             break;
1092         }
1093         *psz_eol++ = '\0';
1094
1095         /* no space allowed between fields */
1096         if( psz_sdp[1] != '=' )
1097         {
1098             msg_Warn( p_obj, "invalid packet" ) ;
1099             FreeSDP( p_sdp );
1100             return NULL;
1101         }
1102
1103         /* Now parse each line */
1104         switch( psz_sdp[0] )
1105         {
1106             case( 'v' ):
1107                 break;
1108             case( 's' ):
1109                 p_sdp->psz_sessionname = strdup( &psz_sdp[2] );
1110                 break;
1111             case ( 'o' ):
1112             {
1113                 int i_field = 0;
1114                 /* o field is <username> <session id> <version>
1115                  *  <network type> <address type> <address> */
1116
1117 #define GET_FIELD( store ) \
1118                 psz_eof = strchr( psz_parse, ' ' ); \
1119                 if( psz_eof ) \
1120                 { \
1121                     *psz_eof=0; store = strdup( psz_parse ); \
1122                 } \
1123                 else \
1124                 { \
1125                     if( i_field != 5 ) \
1126                     { \
1127                         b_invalid = VLC_TRUE; break; \
1128                     } \
1129                     else \
1130                     { \
1131                         store = strdup( psz_parse ); \
1132                     } \
1133                 }; \
1134                 psz_parse = psz_eof + 1; i_field++;
1135
1136
1137                 psz_parse = &psz_sdp[2];
1138                 GET_FIELD( p_sdp->psz_username );
1139                 GET_FIELD( psz_sess_id );
1140
1141                 p_sdp->i_session_id = atoll( psz_sess_id );
1142
1143                 FREE( psz_sess_id );
1144
1145                 GET_FIELD( psz_sess_id );
1146                 FREE( psz_sess_id );
1147
1148                 GET_FIELD( p_sdp->psz_network_type );
1149                 GET_FIELD( p_sdp->psz_address_type );
1150                 GET_FIELD( p_sdp->psz_address );
1151
1152                 break;
1153             }
1154             case( 'i' ):
1155             case( 'u' ):
1156             case( 'e' ):
1157             case( 'p' ):
1158             case( 't' ):
1159             case( 'r' ):
1160                 break;
1161             case( 'a' ): /* attribute */
1162             {
1163                 char *psz_eon = strchr( &psz_sdp[2], ':' );
1164                 attribute_t *p_attr = malloc( sizeof( attribute_t ) );
1165
1166                 /* Attribute with value */
1167                 if( psz_eon )
1168                 {
1169                     *psz_eon++ = '\0';
1170
1171                     p_attr->psz_field = strdup( &psz_sdp[2] );
1172                     p_attr->psz_value = strdup( psz_eon );
1173                 }
1174                 else /* Attribute without value */
1175                 {
1176                     p_attr->psz_field = strdup( &psz_sdp[2] );
1177                     p_attr->psz_value = NULL;
1178                 }
1179
1180                 TAB_APPEND( p_sdp->i_attributes, p_sdp->pp_attributes, p_attr );
1181                 break;
1182             }
1183
1184             case( 'm' ): /* Media announcement */
1185             {
1186                 /* If we have several medias, we pass the announcement to
1187                  * LIVE.COM, so just count them */
1188                 p_sdp->i_media++;
1189                 if( p_sdp->i_media == 1 )
1190                 {
1191                     p_sdp->psz_media = strdup( &psz_sdp[2] );
1192                 }
1193                 break;
1194             }
1195
1196             case( 'c' ):
1197             {
1198                 if( p_sdp->i_media > 1 )
1199                     break;
1200
1201                 p_sdp->psz_connection = strdup( &psz_sdp[2] );
1202                 break;
1203             }
1204
1205             default:
1206                break;
1207         }
1208
1209         if( b_invalid )
1210         {
1211             FreeSDP( p_sdp );
1212             return NULL;
1213         }
1214
1215         psz_sdp = psz_eol;
1216     }
1217
1218     return p_sdp;
1219 }
1220
1221 static int InitSocket( services_discovery_t *p_sd, char *psz_address,
1222                        int i_port )
1223 {
1224     int i_fd = net_OpenUDP( p_sd, psz_address, i_port, "", 0 );
1225
1226     if( i_fd != -1 )
1227     {
1228         net_StopSend( i_fd );
1229         INSERT_ELEM(  p_sd->p_sys->pi_fd, p_sd->p_sys->i_fd,
1230                       p_sd->p_sys->i_fd, i_fd );
1231         return VLC_SUCCESS;
1232     }
1233
1234     return VLC_EGENERIC;
1235 }
1236
1237 #ifdef HAVE_ZLIB_H
1238 static int Decompress( unsigned char *psz_src, unsigned char **_dst, int i_len )
1239 {
1240     int i_result, i_dstsize, n;
1241     unsigned char *psz_dst;
1242     z_stream d_stream;
1243
1244     d_stream.zalloc = (alloc_func)0;
1245     d_stream.zfree = (free_func)0;
1246     d_stream.opaque = (voidpf)0;
1247
1248     i_result = inflateInit(&d_stream);
1249     if( i_result != Z_OK )
1250     {
1251         printf( "inflateInit() failed. Result: %d\n", i_result );
1252         return( -1 );
1253     }
1254 #if 0
1255     p_playlist->pp_items[p_playlist->i_index]->b_autodeletion = VLC_TRUE;
1256     i_position = p_playlist->i_index;
1257
1258     /* Gather the complete sdp file */
1259     for( ;; )
1260     {
1261         int i_read = stream_Read( p_demux->s, &p_sdp[i_sdp], i_sdp_max - i_sdp - 1 );
1262 #endif
1263     d_stream.next_in = (Bytef *)psz_src;
1264     d_stream.avail_in = i_len;
1265     n = 0;
1266
1267     psz_dst = NULL;
1268
1269     do
1270     {
1271         n++;
1272         psz_dst = (unsigned char *)realloc( psz_dst, n * 1000 );
1273         d_stream.next_out = (Bytef *)&psz_dst[(n - 1) * 1000];
1274         d_stream.avail_out = 1000;
1275
1276         i_result = inflate(&d_stream, Z_NO_FLUSH);
1277         if( ( i_result != Z_OK ) && ( i_result != Z_STREAM_END ) )
1278         {
1279             printf( "Zlib decompression failed. Result: %d\n", i_result );
1280             return( -1 );
1281         }
1282     }
1283     while( ( d_stream.avail_out == 0 ) && ( d_stream.avail_in != 0 ) &&
1284            ( i_result != Z_STREAM_END ) );
1285
1286     i_dstsize = d_stream.total_out;
1287     inflateEnd( &d_stream );
1288
1289     *_dst = (unsigned char *)realloc( psz_dst, i_dstsize );
1290
1291     return i_dstsize;
1292 }
1293 #endif
1294
1295
1296 static void FreeSDP( sdp_t *p_sdp )
1297 {
1298     int i;
1299     FREE( p_sdp->psz_sdp );
1300     FREE( p_sdp->psz_sessionname );
1301     FREE( p_sdp->psz_connection );
1302     FREE( p_sdp->psz_media );
1303     FREE( p_sdp->psz_uri );
1304     FREE( p_sdp->psz_username );
1305     FREE( p_sdp->psz_network_type );
1306
1307     FREE( p_sdp->psz_address );
1308     FREE( p_sdp->psz_address_type );
1309
1310     for( i= p_sdp->i_attributes - 1; i >= 0 ; i-- )
1311     {
1312         struct attribute_t *p_attr = p_sdp->pp_attributes[i];
1313         FREE( p_sdp->pp_attributes[i]->psz_field );
1314         FREE( p_sdp->pp_attributes[i]->psz_value );
1315         REMOVE_ELEM( p_sdp->pp_attributes, p_sdp->i_attributes, i);
1316         FREE( p_attr );
1317     }
1318     free( p_sdp );
1319 }
1320
1321 static int RemoveAnnounce( services_discovery_t *p_sd,
1322                            sap_announce_t *p_announce )
1323 {
1324     int i;
1325
1326     if( p_announce->p_sdp ) FreeSDP( p_announce->p_sdp );
1327
1328     if( p_announce->i_item_id > -1 )
1329     {
1330         playlist_LockDelete( p_sd->p_sys->p_playlist, p_announce->i_item_id );
1331     }
1332
1333     for( i = 0; i< p_sd->p_sys->i_announces; i++)
1334     {
1335         if( p_sd->p_sys->pp_announces[i] == p_announce )
1336         {
1337             REMOVE_ELEM( p_sd->p_sys->pp_announces, p_sd->p_sys->i_announces,
1338                          i);
1339             break;
1340         }
1341     }
1342
1343     free( p_announce );
1344
1345     return VLC_SUCCESS;
1346 }
1347
1348 static vlc_bool_t IsSameSession( sdp_t *p_sdp1, sdp_t *p_sdp2 )
1349 {
1350     /* A session is identified by
1351      * username, session_id, network type, address type and address */
1352     if( p_sdp1->psz_username && p_sdp2->psz_username &&
1353         p_sdp1->psz_network_type && p_sdp2->psz_network_type &&
1354         p_sdp1->psz_address_type && p_sdp2->psz_address_type &&
1355         p_sdp1->psz_address &&  p_sdp2->psz_address )
1356     {
1357         if(!strcmp( p_sdp1->psz_username , p_sdp2->psz_username ) &&
1358            !strcmp( p_sdp1->psz_network_type , p_sdp2->psz_network_type ) &&
1359            !strcmp( p_sdp1->psz_address_type , p_sdp2->psz_address_type ) &&
1360            !strcmp( p_sdp1->psz_address , p_sdp2->psz_address ) &&
1361            p_sdp1->i_session_id == p_sdp2->i_session_id )
1362         {
1363             return VLC_TRUE;
1364         }
1365         else
1366         {
1367             return VLC_FALSE;
1368         }
1369     }
1370     else
1371     {
1372         return VLC_FALSE;
1373     }
1374 }
1375
1376
1377 static void CacheLoad( services_discovery_t *p_sd )
1378 {
1379     msg_Warn( p_sd, "Cache not implemented") ;
1380 }
1381
1382 static void CacheSave( services_discovery_t *p_sd )
1383 {
1384     msg_Warn( p_sd, "Cache not implemented") ;
1385 }