#include "flx.h"
#include "iface.h"
+#include "prioq.h"
+#include "llist.h"
+#include "timeeventq.h"
+#include "announce.h"
+#include "subscribe.h"
-struct _flxEntry;
-typedef struct _flxEntry flxEntry;
struct _flxEntry {
- flxRecord rr;
- gint id;
+ flxServer *server;
+ flxEntryGroup *group;
+
+ gboolean dead;
+
+ flxEntryFlags flags;
+ flxRecord *record;
gint interface;
guchar protocol;
- gboolean unique;
-
- flxEntry *next, *prev;
- flxEntry *next_by_name, *prev_by_name;
- flxEntry *next_by_id, *prev_by_id;
+ FLX_LLIST_FIELDS(flxEntry, entries);
+ FLX_LLIST_FIELDS(flxEntry, by_key);
+ FLX_LLIST_FIELDS(flxEntry, by_group);
+
+ FLX_LLIST_HEAD(flxAnnouncement, announcements);
};
-typedef struct _flxQueryJob {
- gint ref;
- flxQuery query;
-} flxQueryJob;
+struct _flxEntryGroup {
+ flxServer *server;
+ gboolean dead;
-struct _flxQueryJobInstance;
-typedef struct _flxQueryJobInstance flxQueryJobInstance;
-struct _flxQueryJobInstance {
- flxQueryJob *job;
- gint interface;
- guchar protocol;
- flxQueryJobInstance *next, *prev;
-};
+ flxEntryGroupStatus status;
+ gpointer userdata;
+ flxEntryGroupCallback callback;
-typedef struct _flxResponseJob {
- gint ref;
- flxRecord response;
-} flxResponseJob;
-
-struct _flxResponseJobInstance;
-typedef struct _flxResponseJobInstance flxResponseJobInstance;
-struct _flxResponseJobInstance {
- flxResponseJob *job;
- gint interface;
- guchar protocol;
- flxResponseJob *next, *prev;
+ guint n_probing;
+
+ FLX_LLIST_FIELDS(flxEntryGroup, groups);
+ FLX_LLIST_HEAD(flxEntry, entries);
};
struct _flxServer {
GMainContext *context;
flxInterfaceMonitor *monitor;
- gint current_id;
+ FLX_LLIST_HEAD(flxEntry, entries);
+ GHashTable *entries_by_key;
+
+ FLX_LLIST_HEAD(flxEntryGroup, groups);
+
+ FLX_LLIST_HEAD(flxSubscription, subscriptions);
+ GHashTable *subscription_hashtable;
+
+ gboolean need_entry_cleanup, need_group_cleanup;
+
+ flxTimeEventQueue *time_event_queue;
- GHashTable *rrset_by_id;
- GHashTable *rrset_by_name;
+ gchar *hostname;
- flxEntry *entries;
+ gint fd_ipv4, fd_ipv6;
- flxResponseJobInstance *first_response_job, *last_response_job;
- flxQueryJobInstance *first_query_job, *last_query_job;
-};
+ GPollFD pollfd_ipv4, pollfd_ipv6;
+ GSource *source;
-flxQueryJob* flx_query_job_new(void);
-flxQueryJob* flx_query_job_ref(flxQueryJob *job);
-void flx_query_job_unref(flxQueryJob *job);
+ gboolean ignore_bad_ttl;
+};
-void flx_server_post_query_job(flxServer *s, gint interface, guchar protocol, const flxQuery *q);
-void flx_server_drop_query_job(flxServer *s, gint interface, guchar protocol, const flxQuery *q);
+gboolean flx_server_entry_match_interface(flxEntry *e, flxInterface *i);
-void flx_server_remove_query_job_instance(flxServer *s, flxQueryJobInstance *i);
+void flx_server_post_query(flxServer *s, gint interface, guchar protocol, flxKey *key);
+void flx_server_post_response(flxServer *s, gint interface, guchar protocol, flxRecord *record, gboolean flush_cache);
-gboolean flx_query_equal(const flxQuery *a, const flxQuery *b);
+void flx_entry_group_run_callback(flxEntryGroup *g, flxEntryGroupStatus state);
+gboolean flx_entry_commited(flxEntry *e);
#endif