X-Git-Url: http://git.meshlink.io/?a=blobdiff_plain;f=avahi-core%2Fcache.h;h=49ba9b9c4d92bae42843eb49d19334862efc082b;hb=530fbb59abafb970ef1dd8f61571b13fb0918b23;hp=fa723e9d68125c1d165c0a978bac03fce91a75a8;hpb=4f0a5e7572a4257894b4bfede42c26d65152609e;p=catta diff --git a/avahi-core/cache.h b/avahi-core/cache.h index fa723e9..49ba9b9 100644 --- a/avahi-core/cache.h +++ b/avahi-core/cache.h @@ -1,21 +1,19 @@ #ifndef foocachehfoo #define foocachehfoo -/* $Id$ */ - /*** This file is part of avahi. - + avahi is free software; you can redistribute it and/or modify it under the terms of the GNU Lesser General Public License as published by the Free Software Foundation; either version 2.1 of the License, or (at your option) any later version. - + avahi 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 Lesser General Public License for more details. - + You should have received a copy of the GNU Lesser General Public License along with avahi; if not, write to the Free Software Foundation, Inc., 59 Temple Place, Suite 330, Boston, MA 02111-1307 @@ -26,7 +24,7 @@ typedef struct AvahiCache AvahiCache; #include #include "prioq.h" -#include "server.h" +#include "internal.h" #include "timeeventq.h" #include "hashmap.h" @@ -35,7 +33,11 @@ typedef enum { AVAHI_CACHE_EXPIRY1, AVAHI_CACHE_EXPIRY2, AVAHI_CACHE_EXPIRY3, - AVAHI_CACHE_FINAL + AVAHI_CACHE_EXPIRY_FINAL, + AVAHI_CACHE_POOF, /* Passive observation of failure */ + AVAHI_CACHE_POOF_FINAL, + AVAHI_CACHE_GOODBYE_FINAL, + AVAHI_CACHE_REPLACE_FINAL } AvahiCacheEntryState; typedef struct AvahiCacheEntry AvahiCacheEntry; @@ -44,36 +46,40 @@ struct AvahiCacheEntry { AvahiCache *cache; AvahiRecord *record; struct timeval timestamp; + struct timeval poof_timestamp; struct timeval expiry; int cache_flush; - + int poof_num; + AvahiAddress origin; AvahiCacheEntryState state; AvahiTimeEvent *time_event; + AvahiAddress poof_address; + AVAHI_LLIST_FIELDS(AvahiCacheEntry, by_key); AVAHI_LLIST_FIELDS(AvahiCacheEntry, entry); }; struct AvahiCache { AvahiServer *server; - + AvahiInterface *interface; - + AvahiHashmap *hashmap; AVAHI_LLIST_HEAD(AvahiCacheEntry, entries); unsigned n_entries; + + int last_rand; + time_t last_rand_timestamp; }; AvahiCache *avahi_cache_new(AvahiServer *server, AvahiInterface *interface); void avahi_cache_free(AvahiCache *c); -AvahiCacheEntry *avahi_cache_lookup_key(AvahiCache *c, AvahiKey *k); -AvahiCacheEntry *avahi_cache_lookup_record(AvahiCache *c, AvahiRecord *r); - void avahi_cache_update(AvahiCache *c, AvahiRecord *r, int cache_flush, const AvahiAddress *a); int avahi_cache_dump(AvahiCache *c, AvahiDumpCallback callback, void* userdata); @@ -83,6 +89,13 @@ void* avahi_cache_walk(AvahiCache *c, AvahiKey *pattern, AvahiCacheWalkCallback int avahi_cache_entry_half_ttl(AvahiCache *c, AvahiCacheEntry *e); +/** Start the "Passive observation of Failure" algorithm for all + * records of the specified key. The specified address is */ +void avahi_cache_start_poof(AvahiCache *c, AvahiKey *key, const AvahiAddress *a); + +/* Stop a previously started POOF algorithm for a record. (Used for response suppresions records */ +void avahi_cache_stop_poof(AvahiCache *c, AvahiRecord *record, const AvahiAddress *a); + void avahi_cache_flush(AvahiCache *c); #endif