1 /*****************************************************************************
2 * bonjour.c: Bonjour services discovery module
3 *****************************************************************************
4 * Copyright (C) 2005-2009 the VideoLAN team
7 * Authors: Jon Lech Johansen <jon@nanocrew.net>
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.
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.
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., 51 Franklin Street, Fifth Floor, Boston MA 02110-1301, USA.
22 *****************************************************************************/
24 /*****************************************************************************
26 *****************************************************************************/
32 #include <vlc_common.h>
33 #include <vlc_plugin.h>
34 #include <vlc_services_discovery.h>
36 #include <avahi-client/client.h>
37 #include <avahi-client/publish.h>
38 #include <avahi-client/lookup.h>
39 #include <avahi-common/thread-watch.h>
40 #include <avahi-common/malloc.h>
41 #include <avahi-common/error.h>
43 /*****************************************************************************
45 *****************************************************************************/
48 static int Open ( vlc_object_t
* );
49 static void Close( vlc_object_t
* );
51 VLC_SD_PROBE_HELPER("bonjour", "Bonjour services", SD_CAT_LAN
)
54 set_shortname( "Bonjour" )
55 set_description( N_("Bonjour services") )
56 set_category( CAT_PLAYLIST
)
57 set_subcategory( SUBCAT_PLAYLIST_SD
)
58 set_capability( "services_discovery", 0 )
59 set_callbacks( Open
, Close
)
61 VLC_SD_PROBE_SUBMODULE
64 /*****************************************************************************
66 *****************************************************************************/
68 struct services_discovery_sys_t
70 AvahiThreadedPoll
*poll
;
72 AvahiServiceBrowser
*sb
;
73 vlc_dictionary_t services_name_to_input_item
;
76 /*****************************************************************************
78 *****************************************************************************/
80 /*****************************************************************************
82 *****************************************************************************/
83 static void client_callback( AvahiClient
*c
, AvahiClientState state
,
86 services_discovery_t
*p_sd
= ( services_discovery_t
* )userdata
;
87 services_discovery_sys_t
*p_sys
= p_sd
->p_sys
;
89 if( state
== AVAHI_CLIENT_FAILURE
&&
90 (avahi_client_errno(c
) == AVAHI_ERR_DISCONNECTED
) )
92 msg_Err( p_sd
, "avahi client disconnected" );
93 avahi_threaded_poll_quit( p_sys
->poll
);
97 /*****************************************************************************
99 *****************************************************************************/
100 static void resolve_callback(
101 AvahiServiceResolver
*r
,
102 AvahiIfIndex interface
,
103 AvahiProtocol protocol
,
104 AvahiResolverEvent event
,
108 const char *host_name
,
109 const AvahiAddress
*address
,
111 AvahiStringList
*txt
,
112 AvahiLookupResultFlags flags
,
115 services_discovery_t
*p_sd
= ( services_discovery_t
* )userdata
;
116 services_discovery_sys_t
*p_sys
= p_sd
->p_sys
;
118 VLC_UNUSED(interface
); VLC_UNUSED(host_name
);
121 if( event
== AVAHI_RESOLVER_FAILURE
)
124 "failed to resolve service '%s' of type '%s' in domain '%s'",
125 name
, type
, domain
);
127 else if( event
== AVAHI_RESOLVER_FOUND
)
130 char *psz_uri
= NULL
;
131 char *psz_addr
= NULL
;
132 AvahiStringList
*asl
= NULL
;
133 input_item_t
*p_input
= NULL
;
135 msg_Dbg( p_sd
, "service '%s' of type '%s' in domain '%s'",
136 name
, type
, domain
);
138 avahi_address_snprint(a
, (sizeof(a
)/sizeof(a
[0]))-1, address
);
139 if( protocol
== AVAHI_PROTO_INET6
)
140 if( asprintf( &psz_addr
, "[%s]", a
) == -1 )
144 asl
= avahi_string_list_find( txt
, "path" );
150 if( avahi_string_list_get_pair( asl
, &key
, &value
, &size
) == 0 &&
153 if( asprintf( &psz_uri
, "http://%s:%d%s",
154 psz_addr
!= NULL
? psz_addr
: a
, port
, value
) == -1 )
161 avahi_free( (void *)key
);
163 avahi_free( (void *)value
);
167 if( asprintf( &psz_uri
, "http://%s:%d",
168 psz_addr
!= NULL
? psz_addr
: a
, port
) == -1 )
177 if( psz_uri
!= NULL
)
179 p_input
= input_item_New( p_sd
, psz_uri
, name
);
182 if( p_input
!= NULL
)
184 vlc_dictionary_insert( &p_sys
->services_name_to_input_item
,
186 services_discovery_AddItem( p_sd
, p_input
, NULL
/* no category */ );
187 vlc_gc_decref( p_input
);
191 avahi_service_resolver_free( r
);
194 /*****************************************************************************
196 *****************************************************************************/
197 static void browse_callback(
198 AvahiServiceBrowser
*b
,
199 AvahiIfIndex interface
,
200 AvahiProtocol protocol
,
201 AvahiBrowserEvent event
,
205 AvahiLookupResultFlags flags
,
210 services_discovery_t
*p_sd
= ( services_discovery_t
* )userdata
;
211 services_discovery_sys_t
*p_sys
= p_sd
->p_sys
;
212 if( event
== AVAHI_BROWSER_NEW
)
214 if( avahi_service_resolver_new( p_sys
->client
, interface
, protocol
,
215 name
, type
, domain
, AVAHI_PROTO_UNSPEC
,
217 resolve_callback
, userdata
) == NULL
)
219 msg_Err( p_sd
, "failed to resolve service '%s': %s", name
,
220 avahi_strerror( avahi_client_errno( p_sys
->client
) ) );
225 /** \todo Store the input id and search it, rather than searching the items */
226 input_item_t
*p_item
;
227 p_item
= vlc_dictionary_value_for_key(
228 &p_sys
->services_name_to_input_item
,
231 msg_Err( p_sd
, "failed to find service '%s' in playlist", name
);
234 services_discovery_RemoveItem( p_sd
, p_item
);
235 vlc_dictionary_remove_value_for_key(
236 &p_sys
->services_name_to_input_item
,
242 /*****************************************************************************
243 * Open: initialize and create stuff
244 *****************************************************************************/
245 static int Open( vlc_object_t
*p_this
)
247 services_discovery_t
*p_sd
= ( services_discovery_t
* )p_this
;
248 services_discovery_sys_t
*p_sys
;
251 p_sd
->p_sys
= p_sys
= calloc( 1, sizeof( services_discovery_sys_t
) );
255 vlc_dictionary_init( &p_sys
->services_name_to_input_item
, 1 );
257 p_sys
->poll
= avahi_threaded_poll_new();
258 if( p_sys
->poll
== NULL
)
260 msg_Err( p_sd
, "failed to create Avahi threaded poll" );
264 p_sys
->client
= avahi_client_new( avahi_threaded_poll_get(p_sys
->poll
),
265 0, client_callback
, p_sd
, &err
);
266 if( p_sys
->client
== NULL
)
268 msg_Err( p_sd
, "failed to create avahi client: %s",
269 avahi_strerror( err
) );
273 p_sys
->sb
= avahi_service_browser_new( p_sys
->client
, AVAHI_IF_UNSPEC
,
275 "_vlc-http._tcp", NULL
,
276 0, browse_callback
, p_sd
);
277 if( p_sys
->sb
== NULL
)
279 msg_Err( p_sd
, "failed to create avahi service browser" );
286 if( p_sys
->sb
!= NULL
)
287 avahi_service_browser_free( p_sys
->sb
);
288 if( p_sys
->client
!= NULL
)
289 avahi_client_free( p_sys
->client
);
290 if( p_sys
->poll
!= NULL
)
291 avahi_threaded_poll_free( p_sys
->poll
);
293 vlc_dictionary_clear( &p_sys
->services_name_to_input_item
, NULL
, NULL
);
299 /*****************************************************************************
301 *****************************************************************************/
302 static void Close( vlc_object_t
*p_this
)
304 services_discovery_t
*p_sd
= ( services_discovery_t
* )p_this
;
305 services_discovery_sys_t
*p_sys
= p_sd
->p_sys
;
307 avahi_service_browser_free( p_sys
->sb
);
308 avahi_client_free( p_sys
->client
);
309 avahi_threaded_poll_free( p_sys
->poll
);
311 vlc_dictionary_clear( &p_sys
->services_name_to_input_item
, NULL
, NULL
);