1 #ifndef foointernalhfoo
2 #define foointernalhfoo
5 This file is part of catta.
7 catta is free software; you can redistribute it and/or modify it
8 under the terms of the GNU Lesser General Public License as
9 published by the Free Software Foundation; either version 2.1 of the
10 License, or (at your option) any later version.
12 catta is distributed in the hope that it will be useful, but WITHOUT
13 ANY WARRANTY; without even the implied warranty of MERCHANTABILITY
14 or FITNESS FOR A PARTICULAR PURPOSE. See the GNU Lesser General
15 Public License for more details.
17 You should have received a copy of the GNU Lesser General Public
18 License along with catta; if not, write to the Free Software
19 Foundation, Inc., 59 Temple Place, Suite 330, Boston, MA 02111-1307
23 /** A locally registered DNS resource record */
24 typedef struct CattaEntry CattaEntry;
26 #include <catta/llist.h>
27 #include <catta/watch.h>
28 #include <catta/timeval.h>
29 #include <catta/core.h>
33 #include "timeeventq.h"
39 #include "wide-area.h"
40 #include "multicast-lookup.h"
41 #include "dns-srv-rr.h"
43 #define CATTA_LEGACY_UNICAST_REFLECT_SLOTS_MAX 100
45 #define CATTA_FLAGS_VALID(flags, max) (!((flags) & ~(max)))
47 #define CATTA_RR_HOLDOFF_MSEC 1000
48 #define CATTA_RR_HOLDOFF_MSEC_RATE_LIMIT 20000
49 #define CATTA_RR_RATE_LIMIT_COUNT 15
52 #define closesocket close
53 #define winsock_init()
54 #define winsock_exit()
55 #define errnostrsocket() strerror(errno)
58 typedef struct CattaLegacyUnicastReflectSlot CattaLegacyUnicastReflectSlot;
60 struct CattaLegacyUnicastReflectSlot {
63 uint16_t id, original_id;
67 struct timeval elapse_time;
68 CattaTimeEvent *time_event;
73 CattaSEntryGroup *group;
77 CattaPublishFlags flags;
80 CattaProtocol protocol;
82 CATTA_LLIST_FIELDS(CattaEntry, entries);
83 CATTA_LLIST_FIELDS(CattaEntry, by_key);
84 CATTA_LLIST_FIELDS(CattaEntry, by_group);
86 CATTA_LLIST_HEAD(CattaAnnouncer, announcers);
89 struct CattaSEntryGroup {
93 CattaEntryGroupState state;
95 CattaSEntryGroupCallback callback;
99 unsigned n_register_try;
100 struct timeval register_time;
101 CattaTimeEvent *register_time_event;
103 struct timeval established_at;
105 CATTA_LLIST_FIELDS(CattaSEntryGroup, groups);
106 CATTA_LLIST_HEAD(CattaEntry, entries);
110 const CattaPoll *poll_api;
112 CattaInterfaceMonitor *monitor;
113 CattaServerConfig config;
115 CATTA_LLIST_HEAD(CattaEntry, entries);
116 CattaHashmap *entries_by_key;
118 CATTA_LLIST_HEAD(CattaSEntryGroup, groups);
120 CATTA_LLIST_HEAD(CattaSRecordBrowser, record_browsers);
121 CattaHashmap *record_browser_hashmap;
122 CATTA_LLIST_HEAD(CattaSHostNameResolver, host_name_resolvers);
123 CATTA_LLIST_HEAD(CattaSAddressResolver, address_resolvers);
124 CATTA_LLIST_HEAD(CattaSDomainBrowser, domain_browsers);
125 CATTA_LLIST_HEAD(CattaSServiceTypeBrowser, service_type_browsers);
126 CATTA_LLIST_HEAD(CattaSServiceBrowser, service_browsers);
127 CATTA_LLIST_HEAD(CattaSServiceResolver, service_resolvers);
128 CATTA_LLIST_HEAD(CattaSDNSServerBrowser, dns_server_browsers);
130 int need_entry_cleanup, need_group_cleanup, need_browser_cleanup;
132 /* Used for scheduling RR cleanup */
133 CattaTimeEvent *cleanup_time_event;
135 CattaTimeEventQueue *time_event_queue;
137 char *host_name, *host_name_fqdn, *domain_name;
139 int fd_ipv4, fd_ipv6,
140 /* The following two sockets two are used for reflection only */
141 fd_legacy_unicast_ipv4, fd_legacy_unicast_ipv6;
143 CattaWatch *watch_ipv4, *watch_ipv6,
144 *watch_legacy_unicast_ipv4, *watch_legacy_unicast_ipv6;
146 CattaServerState state;
147 CattaServerCallback callback;
150 CattaSEntryGroup *hinfo_entry_group;
151 CattaSEntryGroup *browse_domain_entry_group;
152 unsigned n_host_rr_pending;
154 /* Used for assembling responses */
155 CattaRecordList *record_list;
157 /* Used for reflection of legacy unicast packets */
158 CattaLegacyUnicastReflectSlot **legacy_unicast_reflect_slots;
159 uint16_t legacy_unicast_reflect_id;
161 /* The last error code */
164 /* The local service cookie */
165 uint32_t local_service_cookie;
167 CattaMulticastLookupEngine *multicast_lookup_engine;
168 CattaWideAreaLookupEngine *wide_area_lookup_engine;
171 void catta_entry_free(CattaServer*s, CattaEntry *e);
172 void catta_entry_group_free(CattaServer *s, CattaSEntryGroup *g);
174 void catta_cleanup_dead_entries(CattaServer *s);
176 void catta_server_prepare_response(CattaServer *s, CattaInterface *i, CattaEntry *e, int unicast_response, int auxiliary);
177 void catta_server_prepare_matching_responses(CattaServer *s, CattaInterface *i, CattaKey *k, int unicast_response);
178 void catta_server_generate_response(CattaServer *s, CattaInterface *i, CattaDnsPacket *p, const CattaAddress *a, uint16_t port, int legacy_unicast, int is_probe);
180 void catta_s_entry_group_change_state(CattaSEntryGroup *g, CattaEntryGroupState state);
182 int catta_entry_is_commited(CattaEntry *e);
184 void catta_server_enumerate_aux_records(CattaServer *s, CattaInterface *i, CattaRecord *r, void (*callback)(CattaServer *s, CattaRecord *r, int flush_cache, void* userdata), void* userdata);
186 void catta_host_rr_entry_group_callback(CattaServer *s, CattaSEntryGroup *g, CattaEntryGroupState state, void *userdata);
188 void catta_server_decrease_host_rr_pending(CattaServer *s);
190 int catta_server_set_errno(CattaServer *s, int error);
192 int catta_server_is_service_local(CattaServer *s, CattaIfIndex iface, CattaProtocol protocol, const char *name);
193 int catta_server_is_record_local(CattaServer *s, CattaIfIndex iface, CattaProtocol protocol, CattaRecord *record);
195 int catta_server_add_ptr(
199 CattaProtocol protocol,
200 CattaPublishFlags flags,
205 #define CATTA_CHECK_VALIDITY(server, expression, error) { \
207 return catta_server_set_errno((server), (error)); \
210 #define CATTA_CHECK_VALIDITY_RETURN_NULL(server, expression, error) { \
211 if (!(expression)) { \
212 catta_server_set_errno((server), (error)); \
217 #define CATTA_CHECK_VALIDITY_SET_RET_GOTO_FAIL(server, expression, error) {\
218 if (!(expression)) { \
219 ret = catta_server_set_errno((server), (error)); \
224 #define CATTA_ASSERT_TRUE(expression) { \
225 int __tmp = !!(expression); \
229 #define CATTA_ASSERT_SUCCESS(expression) { \
230 int __tmp = (expression); \
231 assert(__tmp == 0); \