4 This file is part of avahi.
6 avahi is free software; you can redistribute it and/or modify it
7 under the terms of the GNU Lesser General Public License as
8 published by the Free Software Foundation; either version 2.1 of the
9 License, or (at your option) any later version.
11 avahi is distributed in the hope that it will be useful, but WITHOUT
12 ANY WARRANTY; without even the implied warranty of MERCHANTABILITY
13 or FITNESS FOR A PARTICULAR PURPOSE. See the GNU Lesser General
14 Public License for more details.
16 You should have received a copy of the GNU Lesser General Public
17 License along with avahi; if not, write to the Free Software
18 Foundation, Inc., 59 Temple Place, Suite 330, Boston, MA 02111-1307
26 #include <avahi-common/malloc.h>
27 #include <avahi-common/timeval.h>
34 #include "multicast-lookup.h"
36 struct AvahiMulticastLookup {
37 AvahiMulticastLookupEngine *engine;
40 AvahiKey *key, *cname_key;
42 AvahiMulticastLookupCallback callback;
45 AvahiIfIndex interface;
46 AvahiProtocol protocol;
50 AvahiTimeEvent *all_for_now_event;
52 AVAHI_LLIST_FIELDS(AvahiMulticastLookup, lookups);
53 AVAHI_LLIST_FIELDS(AvahiMulticastLookup, by_key);
56 struct AvahiMulticastLookupEngine {
60 AVAHI_LLIST_HEAD(AvahiMulticastLookup, lookups);
61 AvahiHashmap *lookups_by_key;
66 static void all_for_now_callback(AvahiTimeEvent *e, void* userdata) {
67 AvahiMulticastLookup *l = userdata;
72 avahi_time_event_free(l->all_for_now_event);
73 l->all_for_now_event = NULL;
75 l->callback(l->engine, l->interface, l->protocol, AVAHI_BROWSER_ALL_FOR_NOW, AVAHI_LOOKUP_RESULT_MULTICAST, NULL, l->userdata);
78 AvahiMulticastLookup *avahi_multicast_lookup_new(
79 AvahiMulticastLookupEngine *e,
80 AvahiIfIndex interface,
81 AvahiProtocol protocol,
83 AvahiMulticastLookupCallback callback,
86 AvahiMulticastLookup *l, *t;
90 assert(AVAHI_IF_VALID(interface));
91 assert(AVAHI_PROTO_VALID(protocol));
95 l = avahi_new(AvahiMulticastLookup, 1);
98 l->key = avahi_key_ref(key);
99 l->cname_key = avahi_key_new_cname(l->key);
100 l->callback = callback;
101 l->userdata = userdata;
102 l->interface = interface;
103 l->protocol = protocol;
104 l->all_for_now_event = NULL;
105 l->queriers_added = 0;
107 t = avahi_hashmap_lookup(e->lookups_by_key, l->key);
108 AVAHI_LLIST_PREPEND(AvahiMulticastLookup, by_key, t, l);
109 avahi_hashmap_replace(e->lookups_by_key, avahi_key_ref(l->key), t);
111 AVAHI_LLIST_PREPEND(AvahiMulticastLookup, lookups, e->lookups, l);
113 avahi_querier_add_for_all(e->server, interface, protocol, l->key, &tv);
114 l->queriers_added = 1;
117 avahi_timeval_add(&tv, 1000000);
119 l->all_for_now_event = avahi_time_event_new(e->server->time_event_queue, &tv, all_for_now_callback, l);
124 static void lookup_stop(AvahiMulticastLookup *l) {
129 if (l->queriers_added) {
130 avahi_querier_remove_for_all(l->engine->server, l->interface, l->protocol, l->key);
131 l->queriers_added = 0;
134 if (l->all_for_now_event) {
135 avahi_time_event_free(l->all_for_now_event);
136 l->all_for_now_event = NULL;
140 static void lookup_destroy(AvahiMulticastLookup *l) {
141 AvahiMulticastLookup *t;
146 t = avahi_hashmap_lookup(l->engine->lookups_by_key, l->key);
147 AVAHI_LLIST_REMOVE(AvahiMulticastLookup, by_key, t, l);
149 avahi_hashmap_replace(l->engine->lookups_by_key, avahi_key_ref(l->key), t);
151 avahi_hashmap_remove(l->engine->lookups_by_key, l->key);
153 AVAHI_LLIST_REMOVE(AvahiMulticastLookup, lookups, l->engine->lookups, l);
156 avahi_key_unref(l->key);
159 avahi_key_unref(l->cname_key);
164 void avahi_multicast_lookup_free(AvahiMulticastLookup *l) {
171 l->engine->cleanup_dead = 1;
175 void avahi_multicast_lookup_engine_cleanup(AvahiMulticastLookupEngine *e) {
176 AvahiMulticastLookup *l, *n;
179 while (e->cleanup_dead) {
182 for (l = e->lookups; l; l = n) {
192 AvahiMulticastLookupEngine *engine;
193 AvahiMulticastLookupCallback callback;
195 AvahiKey *key, *cname_key;
196 AvahiInterface *interface;
200 static void* scan_cache_callback(AvahiCache *c, AvahiKey *pattern, AvahiCacheEntry *e, void* userdata) {
201 struct cbdata *cbdata = userdata;
210 cbdata->interface->hardware->index,
211 cbdata->interface->protocol,
213 AVAHI_LOOKUP_RESULT_CACHED|AVAHI_LOOKUP_RESULT_MULTICAST,
222 static void scan_interface_callback(AvahiInterfaceMonitor *m, AvahiInterface *i, void* userdata) {
223 struct cbdata *cbdata = userdata;
229 cbdata->interface = i;
231 avahi_cache_walk(i->cache, cbdata->key, scan_cache_callback, cbdata);
233 if (cbdata->cname_key)
234 avahi_cache_walk(i->cache, cbdata->cname_key, scan_cache_callback, cbdata);
236 cbdata->interface = NULL;
239 unsigned avahi_multicast_lookup_engine_scan_cache(
240 AvahiMulticastLookupEngine *e,
241 AvahiIfIndex interface,
242 AvahiProtocol protocol,
244 AvahiMulticastLookupCallback callback,
247 struct cbdata cbdata;
253 assert(AVAHI_IF_VALID(interface));
254 assert(AVAHI_PROTO_VALID(protocol));
258 cbdata.cname_key = avahi_key_new_cname(key);
259 cbdata.callback = callback;
260 cbdata.userdata = userdata;
261 cbdata.interface = NULL;
264 avahi_interface_monitor_walk(e->server->monitor, interface, protocol, scan_interface_callback, &cbdata);
266 if (cbdata.cname_key)
267 avahi_key_unref(cbdata.cname_key);
269 return cbdata.n_found;
272 void avahi_multicast_lookup_engine_new_interface(AvahiMulticastLookupEngine *e, AvahiInterface *i) {
273 AvahiMulticastLookup *l;
278 for (l = e->lookups; l; l = l->lookups_next) {
280 if (l->dead || !l->callback)
283 if (l->queriers_added && avahi_interface_match(i, l->interface, l->protocol))
284 avahi_querier_add(i, l->key, NULL);
288 void avahi_multicast_lookup_engine_notify(AvahiMulticastLookupEngine *e, AvahiInterface *i, AvahiRecord *record, AvahiBrowserEvent event) {
289 AvahiMulticastLookup *l;
295 for (l = avahi_hashmap_lookup(e->lookups_by_key, record->key); l; l = l->by_key_next) {
296 if (l->dead || !l->callback)
299 if (avahi_interface_match(i, l->interface, l->protocol))
300 l->callback(e, i->hardware->index, i->protocol, event, AVAHI_LOOKUP_RESULT_MULTICAST, record, l->userdata);
304 if (record->key->clazz == AVAHI_DNS_CLASS_IN && record->key->type == AVAHI_DNS_TYPE_CNAME) {
305 /* It's a CNAME record, so we have to scan the all lookups to see if one matches */
307 for (l = e->lookups; l; l = l->lookups_next) {
310 if (l->dead || !l->callback)
313 if ((key = avahi_key_new_cname(l->key))) {
314 if (avahi_key_equal(record->key, key))
315 l->callback(e, i->hardware->index, i->protocol, event, AVAHI_LOOKUP_RESULT_MULTICAST, record, l->userdata);
317 avahi_key_unref(key);
323 AvahiMulticastLookupEngine *avahi_multicast_lookup_engine_new(AvahiServer *s) {
324 AvahiMulticastLookupEngine *e;
328 e = avahi_new(AvahiMulticastLookupEngine, 1);
332 /* Initialize lookup list */
333 e->lookups_by_key = avahi_hashmap_new((AvahiHashFunc) avahi_key_hash, (AvahiEqualFunc) avahi_key_equal, (AvahiFreeFunc) avahi_key_unref, NULL);
334 AVAHI_LLIST_HEAD_INIT(AvahiWideAreaLookup, e->lookups);
339 void avahi_multicast_lookup_engine_free(AvahiMulticastLookupEngine *e) {
343 lookup_destroy(e->lookups);
345 avahi_hashmap_free(e->lookups_by_key);