]> git.meshlink.io Git - catta/blobdiff - avahi-core/cache.c
* split off lookup.h and publish.h from core.h
[catta] / avahi-core / cache.c
index 924b8c958d83c84e3aa2b1a2b4b0c92f3e092bbe..6332b1258ae644da6c84be962df33ff7a4ecdc62 100644 (file)
@@ -32,7 +32,7 @@
 #include "cache.h"
 #include "log.h"
 
-#define AVAHI_MAX_CACHE_ENTRIES 200
+#define AVAHI_MAX_CACHE_ENTRIES 500
 
 static void remove_entry(AvahiCache *c, AvahiCacheEntry *e) {
     AvahiCacheEntry *t;
@@ -56,8 +56,8 @@ static void remove_entry(AvahiCache *c, AvahiCacheEntry *e) {
     if (e->time_event)
         avahi_time_event_free(e->time_event);
 
-    avahi_browser_notify(c->server, c->interface, e->record, AVAHI_BROWSER_REMOVE);
-
+    avahi_multicast_lookup_engine_notify(c->server->multicast_lookup_engine, c->interface, e->record, AVAHI_BROWSER_REMOVE);
+    
     avahi_record_unref(e->record);
     
     avahi_free(e);
@@ -204,7 +204,7 @@ static void elapse_func(AvahiTimeEvent *t, void *userdata) {
         assert(percent > 0);
 
         /* Request a cache update, if we are subscribed to this entry */
-        if (avahi_is_subscribed(e->cache->server, e->cache->interface, e->record->key)) {
+        if (avahi_querier_exists(e->cache->interface, e->record->key)) {
 /*             avahi_log_debug("Requesting cache entry update at %i%% for %s.", percent, txt);   */
             avahi_interface_post_query(e->cache->interface, e->record->key, 1);
         }
@@ -345,7 +345,7 @@ void avahi_cache_update(AvahiCache *c, AvahiRecord *r, int cache_flush, const Av
             c->n_entries++;
 
             /* Notify subscribers */
-            avahi_browser_notify(c->server, c->interface, e->record, AVAHI_BROWSER_NEW);
+            avahi_multicast_lookup_engine_notify(c->server->multicast_lookup_engine, c->interface, e->record, AVAHI_BROWSER_NEW);
         } 
         
         e->origin = *a;