Mercurial > audlegacy-plugins
view src/daap/xmms2-daap/daap_mdns_avahi.c @ 3052:95b34f46a231
Comment out MPEG2/MPEG4 determination using the variable id. It is not used anywhere. Code analysis run, unique ID 6nYoHM.
author | Tony Vroon <chainsaw@gentoo.org> |
---|---|
date | Sat, 18 Apr 2009 19:06:20 +0100 |
parents | 7b3290336f3b |
children |
line wrap: on
line source
/** @file daap_mdns_browse.c * Browser for DAAP servers shared via mDNS. * * Copyright (C) 2006-2007 XMMS2 Team * * This program is free software; you can redistribute it and/or * modify it under the terms of the GNU General Public License * as published by the Free Software Foundation; either version 2 * of the License, or (at your option) any later version. * * This program is distributed in the hope that it will be useful, * but WITHOUT ANY WARRANTY; without even the implied warranty of * MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE. See the * GNU General Public License for more details. */ #ifdef DAAP_MDNS_AVAHI #include "daap_mdns_browse.h" #include <string.h> #include <glib.h> #include <avahi-client/client.h> #include <avahi-client/lookup.h> #include <avahi-common/malloc.h> #include <avahi-common/error.h> #include <avahi-common/timeval.h> #include <avahi-glib/glib-watch.h> #include <avahi-glib/glib-malloc.h> #define ADDR_LEN (3 * 4 + 3 + 1) /* standard dotted-quad fmt */ typedef struct { AvahiClient *client; GMainLoop *mainloop; } browse_callback_userdata_t; static GSList *g_server_list = NULL; static GStaticMutex serv_list_mut = G_STATIC_MUTEX_INIT; static AvahiGLibPoll *gl_poll = NULL; static AvahiClient *client = NULL; static AvahiServiceBrowser *browser = NULL; static GSList * daap_mdns_serv_remove (GSList *serv_list, gchar *addr, guint port) { GSList *first = serv_list; daap_mdns_server_t *serv; for ( ; serv_list != NULL; serv_list = g_slist_next (serv_list)) { serv = (daap_mdns_server_t *) serv_list->data; if ( (port == serv->port) && (!strcmp (addr, serv->address)) ) { serv_list = g_slist_remove (first, serv); g_free (serv->server_name); g_free (serv->mdns_hostname); g_free (serv->address); g_free (serv); return serv_list; } } return NULL; } static void daap_mdns_resolve_cb (AvahiServiceResolver *resolv, AvahiIfIndex iface, AvahiProtocol proto, AvahiResolverEvent event, const gchar *name, const gchar *type, const gchar *domain, const gchar *hostname, const AvahiAddress *addr, guint16 port, AvahiStringList *text, AvahiLookupResultFlags flags, void *userdata) { gboolean *remove = userdata; gchar ad[ADDR_LEN]; daap_mdns_server_t *server; if (!resolv) { return; } switch (event) { case AVAHI_RESOLVER_FOUND: server = (daap_mdns_server_t *) g_malloc0 (sizeof (daap_mdns_server_t)); avahi_address_snprint (ad, sizeof (ad), addr); server->server_name = g_strdup (name); server->address = g_strdup (ad); server->mdns_hostname = g_strdup (hostname); server->port = port; if (*remove) { g_static_mutex_lock (&serv_list_mut); g_server_list = daap_mdns_serv_remove (g_server_list, ad, port); g_static_mutex_unlock (&serv_list_mut); } else { g_static_mutex_lock (&serv_list_mut); g_server_list = g_slist_prepend (g_server_list, server); g_static_mutex_unlock (&serv_list_mut); } g_free (remove); break; case AVAHI_RESOLVER_FAILURE: break; default: break; } avahi_service_resolver_free (resolv); } static void daap_mdns_browse_cb (AvahiServiceBrowser *browser, AvahiIfIndex iface, AvahiProtocol proto, AvahiBrowserEvent event, const gchar *name, const gchar *type, const gchar *domain, AvahiLookupResultFlags flags, void *userdata) { gboolean ok = FALSE; gboolean *b = g_malloc (sizeof (gboolean)); AvahiClient *client = ((browse_callback_userdata_t *) userdata)->client; if (!browser) { return; } switch (event) { case AVAHI_BROWSER_NEW: *b = FALSE; ok = (gboolean) avahi_service_resolver_new (client, iface, proto, name, type, domain, AVAHI_PROTO_UNSPEC, 0, daap_mdns_resolve_cb, b); break; case AVAHI_BROWSER_REMOVE: *b = TRUE; ok = (gboolean) avahi_service_resolver_new (client, iface, proto, name, type, domain, AVAHI_PROTO_UNSPEC, 0, daap_mdns_resolve_cb, b); break; case AVAHI_BROWSER_CACHE_EXHAUSTED: break; case AVAHI_BROWSER_ALL_FOR_NOW: break; default: break; } } static void daap_mdns_client_cb (AvahiClient *client, AvahiClientState state, void * userdata) { if (!client) { return; } switch (state) { case AVAHI_CLIENT_FAILURE: break; default: break; } } static void daap_mdns_timeout (AvahiTimeout *to, void *userdata) { } static gboolean daap_mdns_timeout_glib (void *userdata) { return FALSE; } gboolean daap_mdns_initialize () { const AvahiPoll *av_poll; GMainLoop *ml = NULL; gboolean ok = TRUE; gint errval; struct timeval tv; browse_callback_userdata_t *browse_userdata; if (gl_poll) { ok = FALSE; goto fail; } browse_userdata = g_malloc0 (sizeof (browse_callback_userdata_t)); avahi_set_allocator (avahi_glib_allocator ()); ml = g_main_loop_new (NULL, FALSE); gl_poll = avahi_glib_poll_new (NULL, G_PRIORITY_DEFAULT); av_poll = avahi_glib_poll_get (gl_poll); avahi_elapse_time (&tv, 2000, 0); av_poll->timeout_new (av_poll, &tv, daap_mdns_timeout, NULL); g_timeout_add (5000, daap_mdns_timeout_glib, ml); client = avahi_client_new (av_poll, 0, daap_mdns_client_cb, ml, &errval); if (!client) { ok = FALSE; goto fail; } browse_userdata->client = client; browse_userdata->mainloop = ml; browser = avahi_service_browser_new (client, AVAHI_IF_UNSPEC, AVAHI_PROTO_UNSPEC, "_daap._tcp", NULL, 0, daap_mdns_browse_cb, browse_userdata); if (!browser) { ok = FALSE; goto fail; } fail: return ok; } GSList * daap_mdns_get_server_list () { GSList * l; g_static_mutex_lock (&serv_list_mut); l = g_slist_copy (g_server_list); g_static_mutex_unlock (&serv_list_mut); return l; } void daap_mdns_destroy () { /* FIXME: deinit avahi */ } #endif