sdlz.c revision 1.1.1.3 1 1.1 christos /* $NetBSD: sdlz.c,v 1.1.1.3 2019/04/27 23:47:29 christos Exp $ */
2 1.1 christos
3 1.1 christos /*
4 1.1 christos * Portions Copyright (C) Internet Systems Consortium, Inc. ("ISC")
5 1.1 christos *
6 1.1 christos * This Source Code Form is subject to the terms of the Mozilla Public
7 1.1 christos * License, v. 2.0. If a copy of the MPL was not distributed with this
8 1.1 christos * file, You can obtain one at http://mozilla.org/MPL/2.0/.
9 1.1 christos *
10 1.1 christos * See the COPYRIGHT file distributed with this work for additional
11 1.1 christos * information regarding copyright ownership.
12 1.1 christos */
13 1.1 christos
14 1.1 christos /*
15 1.1 christos * Copyright (C) 2002 Stichting NLnet, Netherlands, stichting (at) nlnet.nl.
16 1.1 christos *
17 1.1 christos * Permission to use, copy, modify, and distribute this software for any
18 1.1 christos * purpose with or without fee is hereby granted, provided that the
19 1.1 christos * above copyright notice and this permission notice appear in all
20 1.1 christos * copies.
21 1.1 christos *
22 1.1 christos * THE SOFTWARE IS PROVIDED "AS IS" AND STICHTING NLNET
23 1.1 christos * DISCLAIMS ALL WARRANTIES WITH REGARD TO THIS SOFTWARE INCLUDING ALL
24 1.1 christos * IMPLIED WARRANTIES OF MERCHANTABILITY AND FITNESS. IN NO EVENT SHALL
25 1.1 christos * STICHTING NLNET BE LIABLE FOR ANY SPECIAL, DIRECT, INDIRECT, OR
26 1.1 christos * CONSEQUENTIAL DAMAGES OR ANY DAMAGES WHATSOEVER RESULTING FROM LOSS
27 1.1 christos * OF USE, DATA OR PROFITS, WHETHER IN AN ACTION OF CONTRACT, NEGLIGENCE
28 1.1 christos * OR OTHER TORTIOUS ACTION, ARISING OUT OF OR IN CONNECTION WITH THE
29 1.1 christos * USE OR PERFORMANCE OF THIS SOFTWARE.
30 1.1 christos *
31 1.1 christos * The development of Dynamically Loadable Zones (DLZ) for Bind 9 was
32 1.1 christos * conceived and contributed by Rob Butler.
33 1.1 christos *
34 1.1 christos * Permission to use, copy, modify, and distribute this software for any
35 1.1 christos * purpose with or without fee is hereby granted, provided that the
36 1.1 christos * above copyright notice and this permission notice appear in all
37 1.1 christos * copies.
38 1.1 christos *
39 1.1 christos * THE SOFTWARE IS PROVIDED "AS IS" AND ROB BUTLER
40 1.1 christos * DISCLAIMS ALL WARRANTIES WITH REGARD TO THIS SOFTWARE INCLUDING ALL
41 1.1 christos * IMPLIED WARRANTIES OF MERCHANTABILITY AND FITNESS. IN NO EVENT SHALL
42 1.1 christos * ROB BUTLER BE LIABLE FOR ANY SPECIAL, DIRECT, INDIRECT, OR
43 1.1 christos * CONSEQUENTIAL DAMAGES OR ANY DAMAGES WHATSOEVER RESULTING FROM LOSS
44 1.1 christos * OF USE, DATA OR PROFITS, WHETHER IN AN ACTION OF CONTRACT, NEGLIGENCE
45 1.1 christos * OR OTHER TORTIOUS ACTION, ARISING OUT OF OR IN CONNECTION WITH THE
46 1.1 christos * USE OR PERFORMANCE OF THIS SOFTWARE.
47 1.1 christos */
48 1.1 christos
49 1.1 christos /*! \file */
50 1.1 christos
51 1.1 christos #include <config.h>
52 1.1.1.2 christos
53 1.1.1.2 christos #include <inttypes.h>
54 1.1.1.2 christos #include <stdbool.h>
55 1.1 christos #include <string.h>
56 1.1 christos
57 1.1 christos #include <isc/buffer.h>
58 1.1 christos #include <isc/lex.h>
59 1.1 christos #include <isc/log.h>
60 1.1 christos #include <isc/rwlock.h>
61 1.1 christos #include <isc/string.h>
62 1.1 christos #include <isc/util.h>
63 1.1 christos #include <isc/magic.h>
64 1.1 christos #include <isc/mem.h>
65 1.1 christos #include <isc/once.h>
66 1.1 christos #include <isc/print.h>
67 1.1 christos #include <isc/region.h>
68 1.1 christos
69 1.1 christos #include <dns/callbacks.h>
70 1.1 christos #include <dns/db.h>
71 1.1 christos #include <dns/dbiterator.h>
72 1.1 christos #include <dns/dlz.h>
73 1.1 christos #include <dns/fixedname.h>
74 1.1 christos #include <dns/log.h>
75 1.1 christos #include <dns/rdata.h>
76 1.1 christos #include <dns/rdatalist.h>
77 1.1 christos #include <dns/rdataset.h>
78 1.1 christos #include <dns/rdatasetiter.h>
79 1.1 christos #include <dns/rdatatype.h>
80 1.1 christos #include <dns/result.h>
81 1.1 christos #include <dns/master.h>
82 1.1 christos #include <dns/sdlz.h>
83 1.1 christos #include <dns/types.h>
84 1.1 christos
85 1.1 christos #include "rdatalist_p.h"
86 1.1 christos
87 1.1 christos /*
88 1.1 christos * Private Types
89 1.1 christos */
90 1.1 christos
91 1.1 christos struct dns_sdlzimplementation {
92 1.1 christos const dns_sdlzmethods_t *methods;
93 1.1 christos isc_mem_t *mctx;
94 1.1 christos void *driverarg;
95 1.1 christos unsigned int flags;
96 1.1 christos isc_mutex_t driverlock;
97 1.1 christos dns_dlzimplementation_t *dlz_imp;
98 1.1 christos };
99 1.1 christos
100 1.1 christos struct dns_sdlz_db {
101 1.1 christos /* Unlocked */
102 1.1 christos dns_db_t common;
103 1.1 christos void *dbdata;
104 1.1 christos dns_sdlzimplementation_t *dlzimp;
105 1.1 christos isc_mutex_t refcnt_lock;
106 1.1 christos /* Locked */
107 1.1 christos unsigned int references;
108 1.1 christos dns_dbversion_t *future_version;
109 1.1 christos int dummy_version;
110 1.1 christos };
111 1.1 christos
112 1.1 christos struct dns_sdlzlookup {
113 1.1 christos /* Unlocked */
114 1.1 christos unsigned int magic;
115 1.1 christos dns_sdlz_db_t *sdlz;
116 1.1 christos ISC_LIST(dns_rdatalist_t) lists;
117 1.1 christos ISC_LIST(isc_buffer_t) buffers;
118 1.1 christos dns_name_t *name;
119 1.1 christos ISC_LINK(dns_sdlzlookup_t) link;
120 1.1 christos isc_mutex_t lock;
121 1.1 christos dns_rdatacallbacks_t callbacks;
122 1.1 christos /* Locked */
123 1.1 christos unsigned int references;
124 1.1 christos };
125 1.1 christos
126 1.1 christos typedef struct dns_sdlzlookup dns_sdlznode_t;
127 1.1 christos
128 1.1 christos struct dns_sdlzallnodes {
129 1.1 christos dns_dbiterator_t common;
130 1.1 christos ISC_LIST(dns_sdlznode_t) nodelist;
131 1.1 christos dns_sdlznode_t *current;
132 1.1 christos dns_sdlznode_t *origin;
133 1.1 christos };
134 1.1 christos
135 1.1 christos typedef dns_sdlzallnodes_t sdlz_dbiterator_t;
136 1.1 christos
137 1.1 christos typedef struct sdlz_rdatasetiter {
138 1.1 christos dns_rdatasetiter_t common;
139 1.1 christos dns_rdatalist_t *current;
140 1.1 christos } sdlz_rdatasetiter_t;
141 1.1 christos
142 1.1 christos
143 1.1 christos #define SDLZDB_MAGIC ISC_MAGIC('D', 'L', 'Z', 'S')
144 1.1 christos
145 1.1 christos /*
146 1.1 christos * Note that "impmagic" is not the first four bytes of the struct, so
147 1.1 christos * ISC_MAGIC_VALID cannot be used.
148 1.1 christos */
149 1.1 christos
150 1.1 christos #define VALID_SDLZDB(sdlzdb) ((sdlzdb) != NULL && \
151 1.1 christos (sdlzdb)->common.impmagic == SDLZDB_MAGIC)
152 1.1 christos
153 1.1 christos #define SDLZLOOKUP_MAGIC ISC_MAGIC('D','L','Z','L')
154 1.1 christos #define VALID_SDLZLOOKUP(sdlzl) ISC_MAGIC_VALID(sdlzl, SDLZLOOKUP_MAGIC)
155 1.1 christos #define VALID_SDLZNODE(sdlzn) VALID_SDLZLOOKUP(sdlzn)
156 1.1 christos
157 1.1 christos /* These values are taken from RFC 1537 */
158 1.1 christos #define SDLZ_DEFAULT_REFRESH 28800U /* 8 hours */
159 1.1 christos #define SDLZ_DEFAULT_RETRY 7200U /* 2 hours */
160 1.1 christos #define SDLZ_DEFAULT_EXPIRE 604800U /* 7 days */
161 1.1 christos #define SDLZ_DEFAULT_MINIMUM 86400U /* 1 day */
162 1.1 christos
163 1.1 christos /* This is a reasonable value */
164 1.1 christos #define SDLZ_DEFAULT_TTL (60 * 60 * 24)
165 1.1 christos
166 1.1 christos #ifdef __COVERITY__
167 1.1 christos #define MAYBE_LOCK(imp) LOCK(&imp->driverlock)
168 1.1 christos #define MAYBE_UNLOCK(imp) UNLOCK(&imp->driverlock)
169 1.1 christos #else
170 1.1 christos #define MAYBE_LOCK(imp) \
171 1.1 christos do { \
172 1.1 christos unsigned int flags = imp->flags; \
173 1.1 christos if ((flags & DNS_SDLZFLAG_THREADSAFE) == 0) \
174 1.1 christos LOCK(&imp->driverlock); \
175 1.1 christos } while (0)
176 1.1 christos
177 1.1 christos #define MAYBE_UNLOCK(imp) \
178 1.1 christos do { \
179 1.1 christos unsigned int flags = imp->flags; \
180 1.1 christos if ((flags & DNS_SDLZFLAG_THREADSAFE) == 0) \
181 1.1 christos UNLOCK(&imp->driverlock); \
182 1.1 christos } while (0)
183 1.1 christos #endif
184 1.1 christos
185 1.1 christos /*
186 1.1 christos * Forward references.
187 1.1 christos */
188 1.1 christos static isc_result_t getnodedata(dns_db_t *db, const dns_name_t *name,
189 1.1.1.2 christos bool create, unsigned int options,
190 1.1 christos dns_clientinfomethods_t *methods,
191 1.1 christos dns_clientinfo_t *clientinfo,
192 1.1 christos dns_dbnode_t **nodep);
193 1.1 christos
194 1.1 christos static void list_tordataset(dns_rdatalist_t *rdatalist,
195 1.1 christos dns_db_t *db, dns_dbnode_t *node,
196 1.1 christos dns_rdataset_t *rdataset);
197 1.1 christos
198 1.1 christos static void detachnode(dns_db_t *db, dns_dbnode_t **targetp);
199 1.1 christos
200 1.1 christos static void dbiterator_destroy(dns_dbiterator_t **iteratorp);
201 1.1 christos static isc_result_t dbiterator_first(dns_dbiterator_t *iterator);
202 1.1 christos static isc_result_t dbiterator_last(dns_dbiterator_t *iterator);
203 1.1 christos static isc_result_t dbiterator_seek(dns_dbiterator_t *iterator,
204 1.1 christos const dns_name_t *name);
205 1.1 christos static isc_result_t dbiterator_prev(dns_dbiterator_t *iterator);
206 1.1 christos static isc_result_t dbiterator_next(dns_dbiterator_t *iterator);
207 1.1 christos static isc_result_t dbiterator_current(dns_dbiterator_t *iterator,
208 1.1 christos dns_dbnode_t **nodep,
209 1.1 christos dns_name_t *name);
210 1.1 christos static isc_result_t dbiterator_pause(dns_dbiterator_t *iterator);
211 1.1 christos static isc_result_t dbiterator_origin(dns_dbiterator_t *iterator,
212 1.1 christos dns_name_t *name);
213 1.1 christos
214 1.1 christos static dns_dbiteratormethods_t dbiterator_methods = {
215 1.1 christos dbiterator_destroy,
216 1.1 christos dbiterator_first,
217 1.1 christos dbiterator_last,
218 1.1 christos dbiterator_seek,
219 1.1 christos dbiterator_prev,
220 1.1 christos dbiterator_next,
221 1.1 christos dbiterator_current,
222 1.1 christos dbiterator_pause,
223 1.1 christos dbiterator_origin
224 1.1 christos };
225 1.1 christos
226 1.1 christos /*
227 1.1 christos * Utility functions
228 1.1 christos */
229 1.1 christos
230 1.1 christos /*
231 1.1 christos * Log a message at the given level
232 1.1 christos */
233 1.1 christos static void
234 1.1 christos sdlz_log(int level, const char *fmt, ...) {
235 1.1 christos va_list ap;
236 1.1 christos va_start(ap, fmt);
237 1.1 christos isc_log_vwrite(dns_lctx, DNS_LOGCATEGORY_DATABASE,
238 1.1 christos DNS_LOGMODULE_DLZ, ISC_LOG_DEBUG(level),
239 1.1 christos fmt, ap);
240 1.1 christos va_end(ap);
241 1.1 christos }
242 1.1 christos
243 1.1 christos /*% Converts the input string to lowercase, in place. */
244 1.1 christos static void
245 1.1 christos dns_sdlz_tolower(char *str) {
246 1.1 christos unsigned int len = strlen(str);
247 1.1 christos unsigned int i;
248 1.1 christos
249 1.1 christos for (i = 0; i < len; i++) {
250 1.1 christos if (str[i] >= 'A' && str[i] <= 'Z')
251 1.1 christos str[i] += 32;
252 1.1 christos }
253 1.1 christos }
254 1.1 christos
255 1.1 christos static inline unsigned int
256 1.1 christos initial_size(const char *data) {
257 1.1 christos unsigned int len = (strlen(data) / 64) + 1;
258 1.1 christos return (len * 64 + 64);
259 1.1 christos }
260 1.1 christos
261 1.1 christos /*
262 1.1 christos * Rdataset Iterator Methods. These methods were "borrowed" from the SDB
263 1.1 christos * driver interface. See the SDB driver interface documentation for more info.
264 1.1 christos */
265 1.1 christos
266 1.1 christos static void
267 1.1 christos rdatasetiter_destroy(dns_rdatasetiter_t **iteratorp) {
268 1.1 christos sdlz_rdatasetiter_t *sdlziterator =
269 1.1 christos (sdlz_rdatasetiter_t *)(*iteratorp);
270 1.1 christos
271 1.1 christos detachnode(sdlziterator->common.db, &sdlziterator->common.node);
272 1.1 christos isc_mem_put(sdlziterator->common.db->mctx, sdlziterator,
273 1.1 christos sizeof(sdlz_rdatasetiter_t));
274 1.1 christos *iteratorp = NULL;
275 1.1 christos }
276 1.1 christos
277 1.1 christos static isc_result_t
278 1.1 christos rdatasetiter_first(dns_rdatasetiter_t *iterator) {
279 1.1 christos sdlz_rdatasetiter_t *sdlziterator = (sdlz_rdatasetiter_t *)iterator;
280 1.1 christos dns_sdlznode_t *sdlznode = (dns_sdlznode_t *)iterator->node;
281 1.1 christos
282 1.1 christos if (ISC_LIST_EMPTY(sdlznode->lists))
283 1.1 christos return (ISC_R_NOMORE);
284 1.1 christos sdlziterator->current = ISC_LIST_HEAD(sdlznode->lists);
285 1.1 christos return (ISC_R_SUCCESS);
286 1.1 christos }
287 1.1 christos
288 1.1 christos static isc_result_t
289 1.1 christos rdatasetiter_next(dns_rdatasetiter_t *iterator) {
290 1.1 christos sdlz_rdatasetiter_t *sdlziterator = (sdlz_rdatasetiter_t *)iterator;
291 1.1 christos
292 1.1 christos sdlziterator->current = ISC_LIST_NEXT(sdlziterator->current, link);
293 1.1 christos if (sdlziterator->current == NULL)
294 1.1 christos return (ISC_R_NOMORE);
295 1.1 christos else
296 1.1 christos return (ISC_R_SUCCESS);
297 1.1 christos }
298 1.1 christos
299 1.1 christos static void
300 1.1 christos rdatasetiter_current(dns_rdatasetiter_t *iterator, dns_rdataset_t *rdataset) {
301 1.1 christos sdlz_rdatasetiter_t *sdlziterator = (sdlz_rdatasetiter_t *)iterator;
302 1.1 christos
303 1.1 christos list_tordataset(sdlziterator->current, iterator->db, iterator->node,
304 1.1 christos rdataset);
305 1.1 christos }
306 1.1 christos
307 1.1 christos static dns_rdatasetitermethods_t rdatasetiter_methods = {
308 1.1 christos rdatasetiter_destroy,
309 1.1 christos rdatasetiter_first,
310 1.1 christos rdatasetiter_next,
311 1.1 christos rdatasetiter_current
312 1.1 christos };
313 1.1 christos
314 1.1 christos /*
315 1.1 christos * DB routines. These methods were "borrowed" from the SDB driver interface.
316 1.1 christos * See the SDB driver interface documentation for more info.
317 1.1 christos */
318 1.1 christos
319 1.1 christos static void
320 1.1 christos attach(dns_db_t *source, dns_db_t **targetp) {
321 1.1 christos dns_sdlz_db_t *sdlz = (dns_sdlz_db_t *) source;
322 1.1 christos
323 1.1 christos REQUIRE(VALID_SDLZDB(sdlz));
324 1.1 christos
325 1.1 christos LOCK(&sdlz->refcnt_lock);
326 1.1 christos REQUIRE(sdlz->references > 0);
327 1.1 christos sdlz->references++;
328 1.1 christos UNLOCK(&sdlz->refcnt_lock);
329 1.1 christos
330 1.1 christos *targetp = source;
331 1.1 christos }
332 1.1 christos
333 1.1 christos static void
334 1.1 christos destroy(dns_sdlz_db_t *sdlz) {
335 1.1 christos isc_mem_t *mctx;
336 1.1 christos mctx = sdlz->common.mctx;
337 1.1 christos
338 1.1 christos sdlz->common.magic = 0;
339 1.1 christos sdlz->common.impmagic = 0;
340 1.1 christos
341 1.1.1.2 christos isc_mutex_destroy(&sdlz->refcnt_lock);
342 1.1 christos
343 1.1 christos dns_name_free(&sdlz->common.origin, mctx);
344 1.1 christos
345 1.1 christos isc_mem_put(mctx, sdlz, sizeof(dns_sdlz_db_t));
346 1.1 christos isc_mem_detach(&mctx);
347 1.1 christos }
348 1.1 christos
349 1.1 christos static void
350 1.1 christos detach(dns_db_t **dbp) {
351 1.1 christos dns_sdlz_db_t *sdlz = (dns_sdlz_db_t *)(*dbp);
352 1.1.1.2 christos bool need_destroy = false;
353 1.1 christos
354 1.1 christos REQUIRE(VALID_SDLZDB(sdlz));
355 1.1 christos LOCK(&sdlz->refcnt_lock);
356 1.1 christos REQUIRE(sdlz->references > 0);
357 1.1 christos sdlz->references--;
358 1.1 christos if (sdlz->references == 0)
359 1.1.1.2 christos need_destroy = true;
360 1.1 christos UNLOCK(&sdlz->refcnt_lock);
361 1.1 christos
362 1.1 christos if (need_destroy)
363 1.1 christos destroy(sdlz);
364 1.1 christos
365 1.1 christos *dbp = NULL;
366 1.1 christos }
367 1.1 christos
368 1.1 christos static isc_result_t
369 1.1 christos beginload(dns_db_t *db, dns_rdatacallbacks_t *callbacks) {
370 1.1 christos UNUSED(db);
371 1.1 christos UNUSED(callbacks);
372 1.1 christos return (ISC_R_NOTIMPLEMENTED);
373 1.1 christos }
374 1.1 christos
375 1.1 christos static isc_result_t
376 1.1 christos endload(dns_db_t *db, dns_rdatacallbacks_t *callbacks) {
377 1.1 christos UNUSED(db);
378 1.1 christos UNUSED(callbacks);
379 1.1 christos return (ISC_R_NOTIMPLEMENTED);
380 1.1 christos }
381 1.1 christos
382 1.1 christos static isc_result_t
383 1.1 christos dump(dns_db_t *db, dns_dbversion_t *version, const char *filename,
384 1.1 christos dns_masterformat_t masterformat)
385 1.1 christos {
386 1.1 christos UNUSED(db);
387 1.1 christos UNUSED(version);
388 1.1 christos UNUSED(filename);
389 1.1 christos UNUSED(masterformat);
390 1.1 christos return (ISC_R_NOTIMPLEMENTED);
391 1.1 christos }
392 1.1 christos
393 1.1 christos static void
394 1.1 christos currentversion(dns_db_t *db, dns_dbversion_t **versionp) {
395 1.1 christos dns_sdlz_db_t *sdlz = (dns_sdlz_db_t *)db;
396 1.1 christos REQUIRE(VALID_SDLZDB(sdlz));
397 1.1 christos REQUIRE(versionp != NULL && *versionp == NULL);
398 1.1 christos
399 1.1 christos *versionp = (void *) &sdlz->dummy_version;
400 1.1 christos return;
401 1.1 christos }
402 1.1 christos
403 1.1 christos static isc_result_t
404 1.1 christos newversion(dns_db_t *db, dns_dbversion_t **versionp) {
405 1.1 christos dns_sdlz_db_t *sdlz = (dns_sdlz_db_t *)db;
406 1.1 christos char origin[DNS_NAME_MAXTEXT + 1];
407 1.1 christos isc_result_t result;
408 1.1 christos
409 1.1 christos REQUIRE(VALID_SDLZDB(sdlz));
410 1.1 christos
411 1.1 christos if (sdlz->dlzimp->methods->newversion == NULL)
412 1.1 christos return (ISC_R_NOTIMPLEMENTED);
413 1.1 christos
414 1.1 christos dns_name_format(&sdlz->common.origin, origin, sizeof(origin));
415 1.1 christos
416 1.1 christos result = sdlz->dlzimp->methods->newversion(origin,
417 1.1 christos sdlz->dlzimp->driverarg,
418 1.1 christos sdlz->dbdata, versionp);
419 1.1 christos if (result != ISC_R_SUCCESS) {
420 1.1 christos sdlz_log(ISC_LOG_ERROR,
421 1.1 christos "sdlz newversion on origin %s failed : %s",
422 1.1 christos origin, isc_result_totext(result));
423 1.1 christos return (result);
424 1.1 christos }
425 1.1 christos
426 1.1 christos sdlz->future_version = *versionp;
427 1.1 christos return (ISC_R_SUCCESS);
428 1.1 christos }
429 1.1 christos
430 1.1 christos static void
431 1.1 christos attachversion(dns_db_t *db, dns_dbversion_t *source, dns_dbversion_t **targetp)
432 1.1 christos {
433 1.1 christos dns_sdlz_db_t *sdlz = (dns_sdlz_db_t *)db;
434 1.1 christos
435 1.1 christos REQUIRE(VALID_SDLZDB(sdlz));
436 1.1 christos REQUIRE(source != NULL && source == (void *)&sdlz->dummy_version);
437 1.1 christos
438 1.1 christos *targetp = source;
439 1.1 christos }
440 1.1 christos
441 1.1 christos static void
442 1.1.1.2 christos closeversion(dns_db_t *db, dns_dbversion_t **versionp, bool commit) {
443 1.1 christos dns_sdlz_db_t *sdlz = (dns_sdlz_db_t *)db;
444 1.1 christos char origin[DNS_NAME_MAXTEXT + 1];
445 1.1 christos
446 1.1 christos REQUIRE(VALID_SDLZDB(sdlz));
447 1.1 christos REQUIRE(versionp != NULL);
448 1.1 christos
449 1.1 christos if (*versionp == (void *)&sdlz->dummy_version) {
450 1.1 christos *versionp = NULL;
451 1.1 christos return;
452 1.1 christos }
453 1.1 christos
454 1.1 christos REQUIRE(*versionp == sdlz->future_version);
455 1.1 christos REQUIRE(sdlz->dlzimp->methods->closeversion != NULL);
456 1.1 christos
457 1.1 christos dns_name_format(&sdlz->common.origin, origin, sizeof(origin));
458 1.1 christos
459 1.1 christos sdlz->dlzimp->methods->closeversion(origin, commit,
460 1.1 christos sdlz->dlzimp->driverarg,
461 1.1 christos sdlz->dbdata, versionp);
462 1.1 christos if (*versionp != NULL)
463 1.1 christos sdlz_log(ISC_LOG_ERROR,
464 1.1 christos "sdlz closeversion on origin %s failed", origin);
465 1.1 christos
466 1.1 christos sdlz->future_version = NULL;
467 1.1 christos }
468 1.1 christos
469 1.1 christos static isc_result_t
470 1.1 christos createnode(dns_sdlz_db_t *sdlz, dns_sdlznode_t **nodep) {
471 1.1 christos dns_sdlznode_t *node;
472 1.1 christos
473 1.1 christos node = isc_mem_get(sdlz->common.mctx, sizeof(dns_sdlznode_t));
474 1.1 christos if (node == NULL)
475 1.1 christos return (ISC_R_NOMEMORY);
476 1.1 christos
477 1.1 christos node->sdlz = NULL;
478 1.1 christos attach((dns_db_t *)sdlz, (dns_db_t **)&node->sdlz);
479 1.1 christos ISC_LIST_INIT(node->lists);
480 1.1 christos ISC_LIST_INIT(node->buffers);
481 1.1 christos ISC_LINK_INIT(node, link);
482 1.1 christos node->name = NULL;
483 1.1.1.2 christos isc_mutex_init(&node->lock);
484 1.1 christos dns_rdatacallbacks_init(&node->callbacks);
485 1.1 christos node->references = 1;
486 1.1 christos node->magic = SDLZLOOKUP_MAGIC;
487 1.1 christos
488 1.1 christos *nodep = node;
489 1.1 christos return (ISC_R_SUCCESS);
490 1.1 christos }
491 1.1 christos
492 1.1 christos static void
493 1.1 christos destroynode(dns_sdlznode_t *node) {
494 1.1 christos dns_rdatalist_t *list;
495 1.1 christos dns_rdata_t *rdata;
496 1.1 christos isc_buffer_t *b;
497 1.1 christos dns_sdlz_db_t *sdlz;
498 1.1 christos dns_db_t *db;
499 1.1 christos isc_mem_t *mctx;
500 1.1 christos
501 1.1 christos sdlz = node->sdlz;
502 1.1 christos mctx = sdlz->common.mctx;
503 1.1 christos
504 1.1 christos while (!ISC_LIST_EMPTY(node->lists)) {
505 1.1 christos list = ISC_LIST_HEAD(node->lists);
506 1.1 christos while (!ISC_LIST_EMPTY(list->rdata)) {
507 1.1 christos rdata = ISC_LIST_HEAD(list->rdata);
508 1.1 christos ISC_LIST_UNLINK(list->rdata, rdata, link);
509 1.1 christos isc_mem_put(mctx, rdata, sizeof(dns_rdata_t));
510 1.1 christos }
511 1.1 christos ISC_LIST_UNLINK(node->lists, list, link);
512 1.1 christos isc_mem_put(mctx, list, sizeof(dns_rdatalist_t));
513 1.1 christos }
514 1.1 christos
515 1.1 christos while (!ISC_LIST_EMPTY(node->buffers)) {
516 1.1 christos b = ISC_LIST_HEAD(node->buffers);
517 1.1 christos ISC_LIST_UNLINK(node->buffers, b, link);
518 1.1 christos isc_buffer_free(&b);
519 1.1 christos }
520 1.1 christos
521 1.1 christos if (node->name != NULL) {
522 1.1 christos dns_name_free(node->name, mctx);
523 1.1 christos isc_mem_put(mctx, node->name, sizeof(dns_name_t));
524 1.1 christos }
525 1.1.1.2 christos isc_mutex_destroy(&node->lock);
526 1.1 christos node->magic = 0;
527 1.1 christos isc_mem_put(mctx, node, sizeof(dns_sdlznode_t));
528 1.1 christos db = &sdlz->common;
529 1.1 christos detach(&db);
530 1.1 christos }
531 1.1 christos
532 1.1 christos static isc_result_t
533 1.1.1.2 christos getnodedata(dns_db_t *db, const dns_name_t *name, bool create,
534 1.1 christos unsigned int options, dns_clientinfomethods_t *methods,
535 1.1 christos dns_clientinfo_t *clientinfo, dns_dbnode_t **nodep)
536 1.1 christos {
537 1.1 christos dns_sdlz_db_t *sdlz = (dns_sdlz_db_t *)db;
538 1.1 christos dns_sdlznode_t *node = NULL;
539 1.1 christos isc_result_t result;
540 1.1 christos isc_buffer_t b;
541 1.1 christos char namestr[DNS_NAME_MAXTEXT + 1];
542 1.1 christos isc_buffer_t b2;
543 1.1 christos char zonestr[DNS_NAME_MAXTEXT + 1];
544 1.1.1.2 christos bool isorigin;
545 1.1 christos dns_sdlzauthorityfunc_t authority;
546 1.1 christos
547 1.1 christos REQUIRE(VALID_SDLZDB(sdlz));
548 1.1 christos REQUIRE(nodep != NULL && *nodep == NULL);
549 1.1 christos
550 1.1 christos if (sdlz->dlzimp->methods->newversion == NULL) {
551 1.1.1.2 christos REQUIRE(create == false);
552 1.1 christos }
553 1.1 christos
554 1.1 christos isc_buffer_init(&b, namestr, sizeof(namestr));
555 1.1 christos if ((sdlz->dlzimp->flags & DNS_SDLZFLAG_RELATIVEOWNER) != 0) {
556 1.1 christos dns_name_t relname;
557 1.1 christos unsigned int labels;
558 1.1 christos
559 1.1 christos labels = dns_name_countlabels(name) -
560 1.1 christos dns_name_countlabels(&sdlz->common.origin);
561 1.1 christos dns_name_init(&relname, NULL);
562 1.1 christos dns_name_getlabelsequence(name, 0, labels, &relname);
563 1.1.1.2 christos result = dns_name_totext(&relname, true, &b);
564 1.1 christos if (result != ISC_R_SUCCESS)
565 1.1 christos return (result);
566 1.1 christos } else {
567 1.1.1.2 christos result = dns_name_totext(name, true, &b);
568 1.1 christos if (result != ISC_R_SUCCESS)
569 1.1 christos return (result);
570 1.1 christos }
571 1.1 christos isc_buffer_putuint8(&b, 0);
572 1.1 christos
573 1.1 christos isc_buffer_init(&b2, zonestr, sizeof(zonestr));
574 1.1.1.2 christos result = dns_name_totext(&sdlz->common.origin, true, &b2);
575 1.1 christos if (result != ISC_R_SUCCESS)
576 1.1 christos return (result);
577 1.1 christos isc_buffer_putuint8(&b2, 0);
578 1.1 christos
579 1.1 christos result = createnode(sdlz, &node);
580 1.1 christos if (result != ISC_R_SUCCESS)
581 1.1 christos return (result);
582 1.1 christos
583 1.1 christos isorigin = dns_name_equal(name, &sdlz->common.origin);
584 1.1 christos
585 1.1 christos /* make sure strings are always lowercase */
586 1.1 christos dns_sdlz_tolower(zonestr);
587 1.1 christos dns_sdlz_tolower(namestr);
588 1.1 christos
589 1.1 christos MAYBE_LOCK(sdlz->dlzimp);
590 1.1 christos
591 1.1 christos /* try to lookup the host (namestr) */
592 1.1 christos result = sdlz->dlzimp->methods->lookup(zonestr, namestr,
593 1.1 christos sdlz->dlzimp->driverarg,
594 1.1 christos sdlz->dbdata, node,
595 1.1 christos methods, clientinfo);
596 1.1 christos
597 1.1 christos /*
598 1.1 christos * If the name was not found and DNS_DBFIND_NOWILD is not
599 1.1 christos * set, then we try to find a wildcard entry.
600 1.1 christos *
601 1.1 christos * If DNS_DBFIND_NOZONECUT is set and there are multiple
602 1.1 christos * levels between the host and the zone origin, we also look
603 1.1 christos * for wildcards at each level.
604 1.1 christos */
605 1.1 christos if (result == ISC_R_NOTFOUND && !create &&
606 1.1 christos (options & DNS_DBFIND_NOWILD) == 0)
607 1.1 christos {
608 1.1 christos unsigned int i, dlabels, nlabels;
609 1.1 christos
610 1.1 christos nlabels = dns_name_countlabels(name);
611 1.1 christos dlabels = nlabels - dns_name_countlabels(&sdlz->common.origin);
612 1.1 christos for (i = 0; i < dlabels; i++) {
613 1.1 christos char wildstr[DNS_NAME_MAXTEXT + 1];
614 1.1 christos dns_fixedname_t fixed;
615 1.1 christos const dns_name_t *wild;
616 1.1 christos
617 1.1 christos dns_fixedname_init(&fixed);
618 1.1.1.3 christos if (i == dlabels - 1) {
619 1.1 christos wild = dns_wildcardname;
620 1.1.1.3 christos } else {
621 1.1 christos dns_name_t *fname;
622 1.1 christos fname = dns_fixedname_name(&fixed);
623 1.1 christos dns_name_getlabelsequence(name, i + 1,
624 1.1 christos dlabels - i - 1,
625 1.1 christos fname);
626 1.1 christos result = dns_name_concatenate(dns_wildcardname,
627 1.1 christos fname, fname,
628 1.1 christos NULL);
629 1.1.1.3 christos if (result != ISC_R_SUCCESS) {
630 1.1.1.3 christos MAYBE_UNLOCK(sdlz->dlzimp);
631 1.1 christos return (result);
632 1.1.1.3 christos }
633 1.1 christos wild = fname;
634 1.1 christos }
635 1.1 christos
636 1.1 christos isc_buffer_init(&b, wildstr, sizeof(wildstr));
637 1.1.1.2 christos result = dns_name_totext(wild, true, &b);
638 1.1.1.3 christos if (result != ISC_R_SUCCESS) {
639 1.1.1.3 christos MAYBE_UNLOCK(sdlz->dlzimp);
640 1.1 christos return (result);
641 1.1.1.3 christos }
642 1.1 christos isc_buffer_putuint8(&b, 0);
643 1.1 christos
644 1.1 christos result = sdlz->dlzimp->methods->lookup(zonestr, wildstr,
645 1.1 christos sdlz->dlzimp->driverarg,
646 1.1 christos sdlz->dbdata, node,
647 1.1 christos methods, clientinfo);
648 1.1 christos if (result == ISC_R_SUCCESS)
649 1.1 christos break;
650 1.1 christos }
651 1.1 christos }
652 1.1 christos
653 1.1 christos MAYBE_UNLOCK(sdlz->dlzimp);
654 1.1 christos
655 1.1 christos if (result == ISC_R_NOTFOUND && (isorigin || create))
656 1.1 christos result = ISC_R_SUCCESS;
657 1.1 christos
658 1.1 christos if (result != ISC_R_SUCCESS) {
659 1.1 christos destroynode(node);
660 1.1 christos return (result);
661 1.1 christos }
662 1.1 christos
663 1.1 christos if (isorigin && sdlz->dlzimp->methods->authority != NULL) {
664 1.1 christos MAYBE_LOCK(sdlz->dlzimp);
665 1.1 christos authority = sdlz->dlzimp->methods->authority;
666 1.1 christos result = (*authority)(zonestr, sdlz->dlzimp->driverarg,
667 1.1 christos sdlz->dbdata, node);
668 1.1 christos MAYBE_UNLOCK(sdlz->dlzimp);
669 1.1 christos if (result != ISC_R_SUCCESS &&
670 1.1 christos result != ISC_R_NOTIMPLEMENTED)
671 1.1 christos {
672 1.1 christos destroynode(node);
673 1.1 christos return (result);
674 1.1 christos }
675 1.1 christos }
676 1.1 christos
677 1.1 christos if (node->name == NULL) {
678 1.1 christos node->name = isc_mem_get(sdlz->common.mctx,
679 1.1 christos sizeof(dns_name_t));
680 1.1 christos if (node->name == NULL) {
681 1.1 christos destroynode(node);
682 1.1 christos return (ISC_R_NOMEMORY);
683 1.1 christos }
684 1.1 christos dns_name_init(node->name, NULL);
685 1.1 christos result = dns_name_dup(name, sdlz->common.mctx, node->name);
686 1.1 christos if (result != ISC_R_SUCCESS) {
687 1.1 christos isc_mem_put(sdlz->common.mctx, node->name,
688 1.1 christos sizeof(dns_name_t));
689 1.1 christos destroynode(node);
690 1.1 christos return (result);
691 1.1 christos }
692 1.1 christos }
693 1.1 christos
694 1.1 christos *nodep = node;
695 1.1 christos return (ISC_R_SUCCESS);
696 1.1 christos }
697 1.1 christos
698 1.1 christos static isc_result_t
699 1.1.1.2 christos findnodeext(dns_db_t *db, const dns_name_t *name, bool create,
700 1.1 christos dns_clientinfomethods_t *methods, dns_clientinfo_t *clientinfo,
701 1.1 christos dns_dbnode_t **nodep)
702 1.1 christos {
703 1.1 christos return (getnodedata(db, name, create, 0, methods, clientinfo, nodep));
704 1.1 christos }
705 1.1 christos
706 1.1 christos static isc_result_t
707 1.1.1.2 christos findnode(dns_db_t *db, const dns_name_t *name, bool create,
708 1.1 christos dns_dbnode_t **nodep)
709 1.1 christos {
710 1.1 christos return (getnodedata(db, name, create, 0, NULL, NULL, nodep));
711 1.1 christos }
712 1.1 christos
713 1.1 christos static isc_result_t
714 1.1 christos findzonecut(dns_db_t *db, const dns_name_t *name, unsigned int options,
715 1.1 christos isc_stdtime_t now, dns_dbnode_t **nodep, dns_name_t *foundname,
716 1.1.1.2 christos dns_name_t *dcname, dns_rdataset_t *rdataset,
717 1.1.1.2 christos dns_rdataset_t *sigrdataset)
718 1.1 christos {
719 1.1 christos UNUSED(db);
720 1.1 christos UNUSED(name);
721 1.1 christos UNUSED(options);
722 1.1 christos UNUSED(now);
723 1.1 christos UNUSED(nodep);
724 1.1 christos UNUSED(foundname);
725 1.1.1.2 christos UNUSED(dcname);
726 1.1 christos UNUSED(rdataset);
727 1.1 christos UNUSED(sigrdataset);
728 1.1 christos
729 1.1 christos return (ISC_R_NOTIMPLEMENTED);
730 1.1 christos }
731 1.1 christos
732 1.1 christos static void
733 1.1 christos attachnode(dns_db_t *db, dns_dbnode_t *source, dns_dbnode_t **targetp) {
734 1.1 christos dns_sdlz_db_t *sdlz = (dns_sdlz_db_t *)db;
735 1.1 christos dns_sdlznode_t *node = (dns_sdlznode_t *)source;
736 1.1 christos
737 1.1 christos REQUIRE(VALID_SDLZDB(sdlz));
738 1.1 christos
739 1.1 christos UNUSED(sdlz);
740 1.1 christos
741 1.1 christos LOCK(&node->lock);
742 1.1 christos INSIST(node->references > 0);
743 1.1 christos node->references++;
744 1.1 christos INSIST(node->references != 0); /* Catch overflow. */
745 1.1 christos UNLOCK(&node->lock);
746 1.1 christos
747 1.1 christos *targetp = source;
748 1.1 christos }
749 1.1 christos
750 1.1 christos static void
751 1.1 christos detachnode(dns_db_t *db, dns_dbnode_t **targetp) {
752 1.1 christos dns_sdlz_db_t *sdlz = (dns_sdlz_db_t *)db;
753 1.1 christos dns_sdlznode_t *node;
754 1.1.1.2 christos bool need_destroy = false;
755 1.1 christos
756 1.1 christos REQUIRE(VALID_SDLZDB(sdlz));
757 1.1 christos REQUIRE(targetp != NULL && *targetp != NULL);
758 1.1 christos
759 1.1 christos UNUSED(sdlz);
760 1.1 christos
761 1.1 christos node = (dns_sdlznode_t *)(*targetp);
762 1.1 christos
763 1.1 christos LOCK(&node->lock);
764 1.1 christos INSIST(node->references > 0);
765 1.1 christos node->references--;
766 1.1 christos if (node->references == 0)
767 1.1.1.2 christos need_destroy = true;
768 1.1 christos UNLOCK(&node->lock);
769 1.1 christos
770 1.1 christos if (need_destroy)
771 1.1 christos destroynode(node);
772 1.1 christos
773 1.1 christos *targetp = NULL;
774 1.1 christos }
775 1.1 christos
776 1.1 christos static isc_result_t
777 1.1 christos expirenode(dns_db_t *db, dns_dbnode_t *node, isc_stdtime_t now) {
778 1.1 christos UNUSED(db);
779 1.1 christos UNUSED(node);
780 1.1 christos UNUSED(now);
781 1.1 christos INSIST(0);
782 1.1.1.2 christos ISC_UNREACHABLE();
783 1.1 christos }
784 1.1 christos
785 1.1 christos static void
786 1.1 christos printnode(dns_db_t *db, dns_dbnode_t *node, FILE *out) {
787 1.1 christos UNUSED(db);
788 1.1 christos UNUSED(node);
789 1.1 christos UNUSED(out);
790 1.1 christos return;
791 1.1 christos }
792 1.1 christos
793 1.1 christos static isc_result_t
794 1.1 christos createiterator(dns_db_t *db, unsigned int options, dns_dbiterator_t **iteratorp)
795 1.1 christos {
796 1.1 christos dns_sdlz_db_t *sdlz = (dns_sdlz_db_t *)db;
797 1.1 christos sdlz_dbiterator_t *sdlziter;
798 1.1 christos isc_result_t result;
799 1.1 christos isc_buffer_t b;
800 1.1 christos char zonestr[DNS_NAME_MAXTEXT + 1];
801 1.1 christos
802 1.1 christos REQUIRE(VALID_SDLZDB(sdlz));
803 1.1 christos
804 1.1 christos if (sdlz->dlzimp->methods->allnodes == NULL)
805 1.1 christos return (ISC_R_NOTIMPLEMENTED);
806 1.1 christos
807 1.1 christos if ((options & DNS_DB_NSEC3ONLY) != 0 ||
808 1.1 christos (options & DNS_DB_NONSEC3) != 0)
809 1.1 christos return (ISC_R_NOTIMPLEMENTED);
810 1.1 christos
811 1.1 christos isc_buffer_init(&b, zonestr, sizeof(zonestr));
812 1.1.1.2 christos result = dns_name_totext(&sdlz->common.origin, true, &b);
813 1.1 christos if (result != ISC_R_SUCCESS)
814 1.1 christos return (result);
815 1.1 christos isc_buffer_putuint8(&b, 0);
816 1.1 christos
817 1.1 christos sdlziter = isc_mem_get(sdlz->common.mctx, sizeof(sdlz_dbiterator_t));
818 1.1 christos if (sdlziter == NULL)
819 1.1 christos return (ISC_R_NOMEMORY);
820 1.1 christos
821 1.1 christos sdlziter->common.methods = &dbiterator_methods;
822 1.1 christos sdlziter->common.db = NULL;
823 1.1 christos dns_db_attach(db, &sdlziter->common.db);
824 1.1.1.2 christos sdlziter->common.relative_names =
825 1.1.1.2 christos ((options & DNS_DB_RELATIVENAMES) != 0);
826 1.1 christos sdlziter->common.magic = DNS_DBITERATOR_MAGIC;
827 1.1 christos ISC_LIST_INIT(sdlziter->nodelist);
828 1.1 christos sdlziter->current = NULL;
829 1.1 christos sdlziter->origin = NULL;
830 1.1 christos
831 1.1 christos /* make sure strings are always lowercase */
832 1.1 christos dns_sdlz_tolower(zonestr);
833 1.1 christos
834 1.1 christos MAYBE_LOCK(sdlz->dlzimp);
835 1.1 christos result = sdlz->dlzimp->methods->allnodes(zonestr,
836 1.1 christos sdlz->dlzimp->driverarg,
837 1.1 christos sdlz->dbdata, sdlziter);
838 1.1 christos MAYBE_UNLOCK(sdlz->dlzimp);
839 1.1 christos if (result != ISC_R_SUCCESS) {
840 1.1 christos dns_dbiterator_t *iter = &sdlziter->common;
841 1.1 christos dbiterator_destroy(&iter);
842 1.1 christos return (result);
843 1.1 christos }
844 1.1 christos
845 1.1 christos if (sdlziter->origin != NULL) {
846 1.1 christos ISC_LIST_UNLINK(sdlziter->nodelist, sdlziter->origin, link);
847 1.1 christos ISC_LIST_PREPEND(sdlziter->nodelist, sdlziter->origin, link);
848 1.1 christos }
849 1.1 christos
850 1.1 christos *iteratorp = (dns_dbiterator_t *)sdlziter;
851 1.1 christos
852 1.1 christos return (ISC_R_SUCCESS);
853 1.1 christos }
854 1.1 christos
855 1.1 christos static isc_result_t
856 1.1 christos findrdataset(dns_db_t *db, dns_dbnode_t *node, dns_dbversion_t *version,
857 1.1 christos dns_rdatatype_t type, dns_rdatatype_t covers,
858 1.1 christos isc_stdtime_t now, dns_rdataset_t *rdataset,
859 1.1 christos dns_rdataset_t *sigrdataset)
860 1.1 christos {
861 1.1 christos dns_rdatalist_t *list;
862 1.1 christos dns_sdlznode_t *sdlznode = (dns_sdlznode_t *)node;
863 1.1 christos
864 1.1 christos REQUIRE(VALID_SDLZNODE(node));
865 1.1 christos
866 1.1 christos UNUSED(db);
867 1.1 christos UNUSED(version);
868 1.1 christos UNUSED(covers);
869 1.1 christos UNUSED(now);
870 1.1 christos UNUSED(sigrdataset);
871 1.1 christos
872 1.1 christos if (type == dns_rdatatype_sig || type == dns_rdatatype_rrsig)
873 1.1 christos return (ISC_R_NOTIMPLEMENTED);
874 1.1 christos
875 1.1 christos list = ISC_LIST_HEAD(sdlznode->lists);
876 1.1 christos while (list != NULL) {
877 1.1 christos if (list->type == type)
878 1.1 christos break;
879 1.1 christos list = ISC_LIST_NEXT(list, link);
880 1.1 christos }
881 1.1 christos if (list == NULL)
882 1.1 christos return (ISC_R_NOTFOUND);
883 1.1 christos
884 1.1 christos list_tordataset(list, db, node, rdataset);
885 1.1 christos
886 1.1 christos return (ISC_R_SUCCESS);
887 1.1 christos }
888 1.1 christos
889 1.1 christos static isc_result_t
890 1.1 christos findext(dns_db_t *db, const dns_name_t *name, dns_dbversion_t *version,
891 1.1 christos dns_rdatatype_t type, unsigned int options, isc_stdtime_t now,
892 1.1 christos dns_dbnode_t **nodep, dns_name_t *foundname,
893 1.1 christos dns_clientinfomethods_t *methods, dns_clientinfo_t *clientinfo,
894 1.1 christos dns_rdataset_t *rdataset, dns_rdataset_t *sigrdataset)
895 1.1 christos {
896 1.1 christos dns_sdlz_db_t *sdlz = (dns_sdlz_db_t *)db;
897 1.1 christos dns_dbnode_t *node = NULL;
898 1.1 christos dns_fixedname_t fname;
899 1.1 christos dns_rdataset_t xrdataset;
900 1.1 christos dns_name_t *xname;
901 1.1 christos unsigned int nlabels, olabels;
902 1.1 christos isc_result_t result;
903 1.1 christos unsigned int i;
904 1.1 christos
905 1.1 christos REQUIRE(VALID_SDLZDB(sdlz));
906 1.1 christos REQUIRE(nodep == NULL || *nodep == NULL);
907 1.1 christos REQUIRE(version == NULL ||
908 1.1 christos version == (void*)&sdlz->dummy_version ||
909 1.1 christos version == sdlz->future_version);
910 1.1 christos
911 1.1 christos UNUSED(sdlz);
912 1.1 christos
913 1.1 christos if (!dns_name_issubdomain(name, &db->origin))
914 1.1 christos return (DNS_R_NXDOMAIN);
915 1.1 christos
916 1.1 christos olabels = dns_name_countlabels(&db->origin);
917 1.1 christos nlabels = dns_name_countlabels(name);
918 1.1 christos
919 1.1 christos xname = dns_fixedname_initname(&fname);
920 1.1 christos
921 1.1 christos if (rdataset == NULL) {
922 1.1 christos dns_rdataset_init(&xrdataset);
923 1.1 christos rdataset = &xrdataset;
924 1.1 christos }
925 1.1 christos
926 1.1 christos result = DNS_R_NXDOMAIN;
927 1.1 christos
928 1.1 christos /*
929 1.1 christos * If we're not walking down searching for zone
930 1.1 christos * cuts, we can cut straight to the chase
931 1.1 christos */
932 1.1 christos if ((options & DNS_DBFIND_NOZONECUT) != 0) {
933 1.1 christos i = nlabels;
934 1.1 christos goto search;
935 1.1 christos }
936 1.1 christos
937 1.1 christos for (i = olabels; i <= nlabels; i++) {
938 1.1 christos search:
939 1.1 christos /*
940 1.1 christos * Look up the next label.
941 1.1 christos */
942 1.1 christos dns_name_getlabelsequence(name, nlabels - i, i, xname);
943 1.1.1.2 christos result = getnodedata(db, xname, false, options,
944 1.1 christos methods, clientinfo, &node);
945 1.1 christos if (result == ISC_R_NOTFOUND) {
946 1.1 christos result = DNS_R_NXDOMAIN;
947 1.1 christos continue;
948 1.1 christos } else if (result != ISC_R_SUCCESS)
949 1.1 christos break;
950 1.1 christos
951 1.1 christos /*
952 1.1 christos * Look for a DNAME at the current label, unless this is
953 1.1 christos * the qname.
954 1.1 christos */
955 1.1 christos if (i < nlabels) {
956 1.1 christos result = findrdataset(db, node, version,
957 1.1 christos dns_rdatatype_dname, 0, now,
958 1.1 christos rdataset, sigrdataset);
959 1.1 christos if (result == ISC_R_SUCCESS) {
960 1.1 christos result = DNS_R_DNAME;
961 1.1 christos break;
962 1.1 christos }
963 1.1 christos }
964 1.1 christos
965 1.1 christos /*
966 1.1 christos * Look for an NS at the current label, unless this is the
967 1.1 christos * origin, glue is ok, or there are known to be no zone cuts.
968 1.1 christos */
969 1.1 christos if (i != olabels && (options & DNS_DBFIND_GLUEOK) == 0 &&
970 1.1 christos (options & DNS_DBFIND_NOZONECUT) == 0)
971 1.1 christos {
972 1.1 christos result = findrdataset(db, node, version,
973 1.1 christos dns_rdatatype_ns, 0, now,
974 1.1 christos rdataset, sigrdataset);
975 1.1 christos
976 1.1 christos if (result == ISC_R_SUCCESS &&
977 1.1 christos i == nlabels && type == dns_rdatatype_any)
978 1.1 christos {
979 1.1 christos result = DNS_R_ZONECUT;
980 1.1 christos dns_rdataset_disassociate(rdataset);
981 1.1 christos if (sigrdataset != NULL &&
982 1.1 christos dns_rdataset_isassociated(sigrdataset))
983 1.1 christos dns_rdataset_disassociate(sigrdataset);
984 1.1 christos break;
985 1.1 christos } else if (result == ISC_R_SUCCESS) {
986 1.1 christos result = DNS_R_DELEGATION;
987 1.1 christos break;
988 1.1 christos }
989 1.1 christos }
990 1.1 christos
991 1.1 christos /*
992 1.1 christos * If the current name is not the qname, add another label
993 1.1 christos * and try again.
994 1.1 christos */
995 1.1 christos if (i < nlabels) {
996 1.1 christos destroynode(node);
997 1.1 christos node = NULL;
998 1.1 christos continue;
999 1.1 christos }
1000 1.1 christos
1001 1.1 christos /*
1002 1.1 christos * If we're looking for ANY, we're done.
1003 1.1 christos */
1004 1.1 christos if (type == dns_rdatatype_any) {
1005 1.1 christos result = ISC_R_SUCCESS;
1006 1.1 christos break;
1007 1.1 christos }
1008 1.1 christos
1009 1.1 christos /*
1010 1.1 christos * Look for the qtype.
1011 1.1 christos */
1012 1.1 christos result = findrdataset(db, node, version, type, 0, now,
1013 1.1 christos rdataset, sigrdataset);
1014 1.1 christos if (result == ISC_R_SUCCESS)
1015 1.1 christos break;
1016 1.1 christos
1017 1.1 christos /*
1018 1.1 christos * Look for a CNAME
1019 1.1 christos */
1020 1.1 christos if (type != dns_rdatatype_cname) {
1021 1.1 christos result = findrdataset(db, node, version,
1022 1.1 christos dns_rdatatype_cname, 0, now,
1023 1.1 christos rdataset, sigrdataset);
1024 1.1 christos if (result == ISC_R_SUCCESS) {
1025 1.1 christos result = DNS_R_CNAME;
1026 1.1 christos break;
1027 1.1 christos }
1028 1.1 christos }
1029 1.1 christos
1030 1.1 christos result = DNS_R_NXRRSET;
1031 1.1 christos break;
1032 1.1 christos }
1033 1.1 christos
1034 1.1 christos if (rdataset == &xrdataset && dns_rdataset_isassociated(rdataset))
1035 1.1 christos dns_rdataset_disassociate(rdataset);
1036 1.1 christos
1037 1.1 christos if (foundname != NULL) {
1038 1.1 christos isc_result_t xresult;
1039 1.1 christos
1040 1.1 christos xresult = dns_name_copy(xname, foundname, NULL);
1041 1.1 christos if (xresult != ISC_R_SUCCESS) {
1042 1.1 christos if (node != NULL)
1043 1.1 christos destroynode(node);
1044 1.1 christos if (dns_rdataset_isassociated(rdataset))
1045 1.1 christos dns_rdataset_disassociate(rdataset);
1046 1.1 christos return (DNS_R_BADDB);
1047 1.1 christos }
1048 1.1 christos }
1049 1.1 christos
1050 1.1 christos if (nodep != NULL)
1051 1.1 christos *nodep = node;
1052 1.1 christos else if (node != NULL)
1053 1.1 christos detachnode(db, &node);
1054 1.1 christos
1055 1.1 christos return (result);
1056 1.1 christos }
1057 1.1 christos
1058 1.1 christos static isc_result_t
1059 1.1 christos find(dns_db_t *db, const dns_name_t *name, dns_dbversion_t *version,
1060 1.1 christos dns_rdatatype_t type, unsigned int options, isc_stdtime_t now,
1061 1.1 christos dns_dbnode_t **nodep, dns_name_t *foundname,
1062 1.1 christos dns_rdataset_t *rdataset, dns_rdataset_t *sigrdataset)
1063 1.1 christos {
1064 1.1 christos return (findext(db, name, version, type, options, now, nodep,
1065 1.1 christos foundname, NULL, NULL, rdataset, sigrdataset));
1066 1.1 christos }
1067 1.1 christos
1068 1.1 christos static isc_result_t
1069 1.1 christos allrdatasets(dns_db_t *db, dns_dbnode_t *node, dns_dbversion_t *version,
1070 1.1 christos isc_stdtime_t now, dns_rdatasetiter_t **iteratorp)
1071 1.1 christos {
1072 1.1 christos dns_sdlz_db_t *sdlz = (dns_sdlz_db_t *) db;
1073 1.1 christos sdlz_rdatasetiter_t *iterator;
1074 1.1 christos
1075 1.1 christos REQUIRE(VALID_SDLZDB(sdlz));
1076 1.1 christos
1077 1.1 christos REQUIRE(version == NULL ||
1078 1.1 christos version == (void*)&sdlz->dummy_version ||
1079 1.1 christos version == sdlz->future_version);
1080 1.1 christos
1081 1.1 christos UNUSED(version);
1082 1.1 christos UNUSED(now);
1083 1.1 christos
1084 1.1 christos iterator = isc_mem_get(db->mctx, sizeof(sdlz_rdatasetiter_t));
1085 1.1 christos if (iterator == NULL)
1086 1.1 christos return (ISC_R_NOMEMORY);
1087 1.1 christos
1088 1.1 christos iterator->common.magic = DNS_RDATASETITER_MAGIC;
1089 1.1 christos iterator->common.methods = &rdatasetiter_methods;
1090 1.1 christos iterator->common.db = db;
1091 1.1 christos iterator->common.node = NULL;
1092 1.1 christos attachnode(db, node, &iterator->common.node);
1093 1.1 christos iterator->common.version = version;
1094 1.1 christos iterator->common.now = now;
1095 1.1 christos
1096 1.1 christos *iteratorp = (dns_rdatasetiter_t *)iterator;
1097 1.1 christos
1098 1.1 christos return (ISC_R_SUCCESS);
1099 1.1 christos }
1100 1.1 christos
1101 1.1 christos static isc_result_t
1102 1.1 christos modrdataset(dns_db_t *db, dns_dbnode_t *node, dns_dbversion_t *version,
1103 1.1 christos dns_rdataset_t *rdataset, unsigned int options,
1104 1.1 christos dns_sdlzmodrdataset_t mod_function)
1105 1.1 christos {
1106 1.1 christos dns_sdlz_db_t *sdlz = (dns_sdlz_db_t *)db;
1107 1.1 christos dns_master_style_t *style = NULL;
1108 1.1 christos isc_result_t result;
1109 1.1 christos isc_buffer_t *buffer = NULL;
1110 1.1 christos isc_mem_t *mctx;
1111 1.1 christos dns_sdlznode_t *sdlznode;
1112 1.1 christos char *rdatastr = NULL;
1113 1.1 christos char name[DNS_NAME_MAXTEXT + 1];
1114 1.1 christos
1115 1.1 christos REQUIRE(VALID_SDLZDB(sdlz));
1116 1.1 christos
1117 1.1 christos if (mod_function == NULL)
1118 1.1 christos return (ISC_R_NOTIMPLEMENTED);
1119 1.1 christos
1120 1.1 christos sdlznode = (dns_sdlznode_t *)node;
1121 1.1 christos
1122 1.1 christos UNUSED(options);
1123 1.1 christos
1124 1.1 christos dns_name_format(sdlznode->name, name, sizeof(name));
1125 1.1 christos
1126 1.1 christos mctx = sdlz->common.mctx;
1127 1.1 christos
1128 1.1 christos result = isc_buffer_allocate(mctx, &buffer, 1024);
1129 1.1 christos if (result != ISC_R_SUCCESS)
1130 1.1 christos return (result);
1131 1.1 christos
1132 1.1.1.2 christos result = dns_master_stylecreate(&style, 0, 0, 0, 0, 0, 0, 1,
1133 1.1.1.2 christos 0xffffffff, mctx);
1134 1.1 christos if (result != ISC_R_SUCCESS)
1135 1.1 christos goto cleanup;
1136 1.1 christos
1137 1.1 christos result = dns_master_rdatasettotext(sdlznode->name, rdataset,
1138 1.1 christos style, buffer);
1139 1.1 christos if (result != ISC_R_SUCCESS)
1140 1.1 christos goto cleanup;
1141 1.1 christos
1142 1.1 christos if (isc_buffer_usedlength(buffer) < 1) {
1143 1.1 christos result = ISC_R_BADADDRESSFORM;
1144 1.1 christos goto cleanup;
1145 1.1 christos }
1146 1.1 christos
1147 1.1 christos rdatastr = isc_buffer_base(buffer);
1148 1.1 christos if (rdatastr == NULL) {
1149 1.1 christos result = ISC_R_NOMEMORY;
1150 1.1 christos goto cleanup;
1151 1.1 christos }
1152 1.1 christos rdatastr[isc_buffer_usedlength(buffer) - 1] = 0;
1153 1.1 christos
1154 1.1 christos MAYBE_LOCK(sdlz->dlzimp);
1155 1.1 christos result = mod_function(name, rdatastr, sdlz->dlzimp->driverarg,
1156 1.1 christos sdlz->dbdata, version);
1157 1.1 christos MAYBE_UNLOCK(sdlz->dlzimp);
1158 1.1 christos
1159 1.1 christos cleanup:
1160 1.1 christos isc_buffer_free(&buffer);
1161 1.1 christos if (style != NULL)
1162 1.1 christos dns_master_styledestroy(&style, mctx);
1163 1.1 christos
1164 1.1 christos return (result);
1165 1.1 christos }
1166 1.1 christos
1167 1.1 christos static isc_result_t
1168 1.1 christos addrdataset(dns_db_t *db, dns_dbnode_t *node, dns_dbversion_t *version,
1169 1.1 christos isc_stdtime_t now, dns_rdataset_t *rdataset, unsigned int options,
1170 1.1 christos dns_rdataset_t *addedrdataset)
1171 1.1 christos {
1172 1.1 christos dns_sdlz_db_t *sdlz = (dns_sdlz_db_t *)db;
1173 1.1 christos isc_result_t result;
1174 1.1 christos
1175 1.1 christos UNUSED(now);
1176 1.1 christos UNUSED(addedrdataset);
1177 1.1 christos REQUIRE(VALID_SDLZDB(sdlz));
1178 1.1 christos
1179 1.1 christos if (sdlz->dlzimp->methods->addrdataset == NULL)
1180 1.1 christos return (ISC_R_NOTIMPLEMENTED);
1181 1.1 christos
1182 1.1 christos result = modrdataset(db, node, version, rdataset, options,
1183 1.1 christos sdlz->dlzimp->methods->addrdataset);
1184 1.1 christos return (result);
1185 1.1 christos }
1186 1.1 christos
1187 1.1 christos
1188 1.1 christos static isc_result_t
1189 1.1 christos subtractrdataset(dns_db_t *db, dns_dbnode_t *node, dns_dbversion_t *version,
1190 1.1 christos dns_rdataset_t *rdataset, unsigned int options,
1191 1.1 christos dns_rdataset_t *newrdataset)
1192 1.1 christos {
1193 1.1 christos dns_sdlz_db_t *sdlz = (dns_sdlz_db_t *)db;
1194 1.1 christos isc_result_t result;
1195 1.1 christos
1196 1.1 christos UNUSED(newrdataset);
1197 1.1 christos REQUIRE(VALID_SDLZDB(sdlz));
1198 1.1 christos
1199 1.1 christos if (sdlz->dlzimp->methods->subtractrdataset == NULL) {
1200 1.1 christos return (ISC_R_NOTIMPLEMENTED);
1201 1.1 christos }
1202 1.1 christos
1203 1.1 christos result = modrdataset(db, node, version, rdataset, options,
1204 1.1 christos sdlz->dlzimp->methods->subtractrdataset);
1205 1.1 christos return (result);
1206 1.1 christos }
1207 1.1 christos
1208 1.1 christos static isc_result_t
1209 1.1 christos deleterdataset(dns_db_t *db, dns_dbnode_t *node, dns_dbversion_t *version,
1210 1.1 christos dns_rdatatype_t type, dns_rdatatype_t covers)
1211 1.1 christos {
1212 1.1 christos dns_sdlz_db_t *sdlz = (dns_sdlz_db_t *)db;
1213 1.1 christos char name[DNS_NAME_MAXTEXT + 1];
1214 1.1 christos char b_type[DNS_RDATATYPE_FORMATSIZE];
1215 1.1 christos dns_sdlznode_t *sdlznode;
1216 1.1 christos isc_result_t result;
1217 1.1 christos
1218 1.1 christos UNUSED(covers);
1219 1.1 christos
1220 1.1 christos REQUIRE(VALID_SDLZDB(sdlz));
1221 1.1 christos
1222 1.1 christos if (sdlz->dlzimp->methods->delrdataset == NULL)
1223 1.1 christos return (ISC_R_NOTIMPLEMENTED);
1224 1.1 christos
1225 1.1 christos sdlznode = (dns_sdlznode_t *)node;
1226 1.1 christos dns_name_format(sdlznode->name, name, sizeof(name));
1227 1.1 christos dns_rdatatype_format(type, b_type, sizeof(b_type));
1228 1.1 christos
1229 1.1 christos MAYBE_LOCK(sdlz->dlzimp);
1230 1.1 christos result = sdlz->dlzimp->methods->delrdataset(name, b_type,
1231 1.1 christos sdlz->dlzimp->driverarg,
1232 1.1 christos sdlz->dbdata, version);
1233 1.1 christos MAYBE_UNLOCK(sdlz->dlzimp);
1234 1.1 christos
1235 1.1 christos return (result);
1236 1.1 christos }
1237 1.1 christos
1238 1.1.1.2 christos static bool
1239 1.1 christos issecure(dns_db_t *db) {
1240 1.1 christos UNUSED(db);
1241 1.1 christos
1242 1.1.1.2 christos return (false);
1243 1.1 christos }
1244 1.1 christos
1245 1.1 christos static unsigned int
1246 1.1 christos nodecount(dns_db_t *db) {
1247 1.1 christos UNUSED(db);
1248 1.1 christos
1249 1.1 christos return (0);
1250 1.1 christos }
1251 1.1 christos
1252 1.1.1.2 christos static bool
1253 1.1 christos ispersistent(dns_db_t *db) {
1254 1.1 christos UNUSED(db);
1255 1.1.1.2 christos return (true);
1256 1.1 christos }
1257 1.1 christos
1258 1.1 christos static void
1259 1.1.1.2 christos overmem(dns_db_t *db, bool over) {
1260 1.1 christos UNUSED(db);
1261 1.1 christos UNUSED(over);
1262 1.1 christos }
1263 1.1 christos
1264 1.1 christos static void
1265 1.1 christos settask(dns_db_t *db, isc_task_t *task) {
1266 1.1 christos UNUSED(db);
1267 1.1 christos UNUSED(task);
1268 1.1 christos }
1269 1.1 christos
1270 1.1 christos /*
1271 1.1 christos * getoriginnode() is used by the update code to find the
1272 1.1 christos * dns_rdatatype_dnskey record for a zone
1273 1.1 christos */
1274 1.1 christos static isc_result_t
1275 1.1 christos getoriginnode(dns_db_t *db, dns_dbnode_t **nodep) {
1276 1.1 christos dns_sdlz_db_t *sdlz = (dns_sdlz_db_t *)db;
1277 1.1 christos isc_result_t result;
1278 1.1 christos
1279 1.1 christos REQUIRE(VALID_SDLZDB(sdlz));
1280 1.1 christos if (sdlz->dlzimp->methods->newversion == NULL)
1281 1.1 christos return (ISC_R_NOTIMPLEMENTED);
1282 1.1 christos
1283 1.1.1.2 christos result = getnodedata(db, &sdlz->common.origin, false,
1284 1.1 christos 0, NULL, NULL, nodep);
1285 1.1 christos if (result != ISC_R_SUCCESS)
1286 1.1 christos sdlz_log(ISC_LOG_ERROR, "sdlz getoriginnode failed: %s",
1287 1.1 christos isc_result_totext(result));
1288 1.1 christos return (result);
1289 1.1 christos }
1290 1.1 christos
1291 1.1 christos static dns_dbmethods_t sdlzdb_methods = {
1292 1.1 christos attach,
1293 1.1 christos detach,
1294 1.1 christos beginload,
1295 1.1 christos endload,
1296 1.1 christos NULL, /* serialize */
1297 1.1 christos dump,
1298 1.1 christos currentversion,
1299 1.1 christos newversion,
1300 1.1 christos attachversion,
1301 1.1 christos closeversion,
1302 1.1 christos findnode,
1303 1.1 christos find,
1304 1.1 christos findzonecut,
1305 1.1 christos attachnode,
1306 1.1 christos detachnode,
1307 1.1 christos expirenode,
1308 1.1 christos printnode,
1309 1.1 christos createiterator,
1310 1.1 christos findrdataset,
1311 1.1 christos allrdatasets,
1312 1.1 christos addrdataset,
1313 1.1 christos subtractrdataset,
1314 1.1 christos deleterdataset,
1315 1.1 christos issecure,
1316 1.1 christos nodecount,
1317 1.1 christos ispersistent,
1318 1.1 christos overmem,
1319 1.1 christos settask,
1320 1.1 christos getoriginnode,
1321 1.1 christos NULL, /* transfernode */
1322 1.1 christos NULL, /* getnsec3parameters */
1323 1.1 christos NULL, /* findnsec3node */
1324 1.1 christos NULL, /* setsigningtime */
1325 1.1 christos NULL, /* getsigningtime */
1326 1.1 christos NULL, /* resigned */
1327 1.1 christos NULL, /* isdnssec */
1328 1.1 christos NULL, /* getrrsetstats */
1329 1.1 christos NULL, /* rpz_attach */
1330 1.1 christos NULL, /* rpz_ready */
1331 1.1 christos findnodeext,
1332 1.1 christos findext,
1333 1.1 christos NULL, /* setcachestats */
1334 1.1 christos NULL, /* hashsize */
1335 1.1 christos NULL, /* nodefullname */
1336 1.1 christos NULL, /* getsize */
1337 1.1 christos NULL, /* setservestalettl */
1338 1.1 christos NULL, /* getservestalettl */
1339 1.1 christos NULL /* setgluecachestats */
1340 1.1 christos };
1341 1.1 christos
1342 1.1 christos /*
1343 1.1 christos * Database Iterator Methods. These methods were "borrowed" from the SDB
1344 1.1 christos * driver interface. See the SDB driver interface documentation for more info.
1345 1.1 christos */
1346 1.1 christos
1347 1.1 christos static void
1348 1.1 christos dbiterator_destroy(dns_dbiterator_t **iteratorp) {
1349 1.1 christos sdlz_dbiterator_t *sdlziter = (sdlz_dbiterator_t *)(*iteratorp);
1350 1.1 christos dns_sdlz_db_t *sdlz = (dns_sdlz_db_t *)sdlziter->common.db;
1351 1.1 christos
1352 1.1 christos while (!ISC_LIST_EMPTY(sdlziter->nodelist)) {
1353 1.1 christos dns_sdlznode_t *node;
1354 1.1 christos node = ISC_LIST_HEAD(sdlziter->nodelist);
1355 1.1 christos ISC_LIST_UNLINK(sdlziter->nodelist, node, link);
1356 1.1 christos destroynode(node);
1357 1.1 christos }
1358 1.1 christos
1359 1.1 christos dns_db_detach(&sdlziter->common.db);
1360 1.1 christos isc_mem_put(sdlz->common.mctx, sdlziter, sizeof(sdlz_dbiterator_t));
1361 1.1 christos
1362 1.1 christos *iteratorp = NULL;
1363 1.1 christos }
1364 1.1 christos
1365 1.1 christos static isc_result_t
1366 1.1 christos dbiterator_first(dns_dbiterator_t *iterator) {
1367 1.1 christos sdlz_dbiterator_t *sdlziter = (sdlz_dbiterator_t *)iterator;
1368 1.1 christos
1369 1.1 christos sdlziter->current = ISC_LIST_HEAD(sdlziter->nodelist);
1370 1.1 christos if (sdlziter->current == NULL)
1371 1.1 christos return (ISC_R_NOMORE);
1372 1.1 christos else
1373 1.1 christos return (ISC_R_SUCCESS);
1374 1.1 christos }
1375 1.1 christos
1376 1.1 christos static isc_result_t
1377 1.1 christos dbiterator_last(dns_dbiterator_t *iterator) {
1378 1.1 christos sdlz_dbiterator_t *sdlziter = (sdlz_dbiterator_t *)iterator;
1379 1.1 christos
1380 1.1 christos sdlziter->current = ISC_LIST_TAIL(sdlziter->nodelist);
1381 1.1 christos if (sdlziter->current == NULL)
1382 1.1 christos return (ISC_R_NOMORE);
1383 1.1 christos else
1384 1.1 christos return (ISC_R_SUCCESS);
1385 1.1 christos }
1386 1.1 christos
1387 1.1 christos static isc_result_t
1388 1.1 christos dbiterator_seek(dns_dbiterator_t *iterator, const dns_name_t *name) {
1389 1.1 christos sdlz_dbiterator_t *sdlziter = (sdlz_dbiterator_t *)iterator;
1390 1.1 christos
1391 1.1 christos sdlziter->current = ISC_LIST_HEAD(sdlziter->nodelist);
1392 1.1 christos while (sdlziter->current != NULL) {
1393 1.1 christos if (dns_name_equal(sdlziter->current->name, name))
1394 1.1 christos return (ISC_R_SUCCESS);
1395 1.1 christos sdlziter->current = ISC_LIST_NEXT(sdlziter->current, link);
1396 1.1 christos }
1397 1.1 christos return (ISC_R_NOTFOUND);
1398 1.1 christos }
1399 1.1 christos
1400 1.1 christos static isc_result_t
1401 1.1 christos dbiterator_prev(dns_dbiterator_t *iterator) {
1402 1.1 christos sdlz_dbiterator_t *sdlziter = (sdlz_dbiterator_t *)iterator;
1403 1.1 christos
1404 1.1 christos sdlziter->current = ISC_LIST_PREV(sdlziter->current, link);
1405 1.1 christos if (sdlziter->current == NULL)
1406 1.1 christos return (ISC_R_NOMORE);
1407 1.1 christos else
1408 1.1 christos return (ISC_R_SUCCESS);
1409 1.1 christos }
1410 1.1 christos
1411 1.1 christos static isc_result_t
1412 1.1 christos dbiterator_next(dns_dbiterator_t *iterator) {
1413 1.1 christos sdlz_dbiterator_t *sdlziter = (sdlz_dbiterator_t *)iterator;
1414 1.1 christos
1415 1.1 christos sdlziter->current = ISC_LIST_NEXT(sdlziter->current, link);
1416 1.1 christos if (sdlziter->current == NULL)
1417 1.1 christos return (ISC_R_NOMORE);
1418 1.1 christos else
1419 1.1 christos return (ISC_R_SUCCESS);
1420 1.1 christos }
1421 1.1 christos
1422 1.1 christos static isc_result_t
1423 1.1 christos dbiterator_current(dns_dbiterator_t *iterator, dns_dbnode_t **nodep,
1424 1.1 christos dns_name_t *name)
1425 1.1 christos {
1426 1.1 christos sdlz_dbiterator_t *sdlziter = (sdlz_dbiterator_t *)iterator;
1427 1.1 christos
1428 1.1 christos attachnode(iterator->db, sdlziter->current, nodep);
1429 1.1 christos if (name != NULL)
1430 1.1 christos return (dns_name_copy(sdlziter->current->name, name, NULL));
1431 1.1 christos return (ISC_R_SUCCESS);
1432 1.1 christos }
1433 1.1 christos
1434 1.1 christos static isc_result_t
1435 1.1 christos dbiterator_pause(dns_dbiterator_t *iterator) {
1436 1.1 christos UNUSED(iterator);
1437 1.1 christos return (ISC_R_SUCCESS);
1438 1.1 christos }
1439 1.1 christos
1440 1.1 christos static isc_result_t
1441 1.1 christos dbiterator_origin(dns_dbiterator_t *iterator, dns_name_t *name) {
1442 1.1 christos UNUSED(iterator);
1443 1.1 christos return (dns_name_copy(dns_rootname, name, NULL));
1444 1.1 christos }
1445 1.1 christos
1446 1.1 christos /*
1447 1.1 christos * Rdataset Methods. These methods were "borrowed" from the SDB driver
1448 1.1 christos * interface. See the SDB driver interface documentation for more info.
1449 1.1 christos */
1450 1.1 christos
1451 1.1 christos static void
1452 1.1 christos disassociate(dns_rdataset_t *rdataset) {
1453 1.1 christos dns_dbnode_t *node = rdataset->private5;
1454 1.1 christos dns_sdlznode_t *sdlznode = (dns_sdlznode_t *) node;
1455 1.1 christos dns_db_t *db = (dns_db_t *) sdlznode->sdlz;
1456 1.1 christos
1457 1.1 christos detachnode(db, &node);
1458 1.1 christos isc__rdatalist_disassociate(rdataset);
1459 1.1 christos }
1460 1.1 christos
1461 1.1 christos static void
1462 1.1 christos rdataset_clone(dns_rdataset_t *source, dns_rdataset_t *target) {
1463 1.1 christos dns_dbnode_t *node = source->private5;
1464 1.1 christos dns_sdlznode_t *sdlznode = (dns_sdlznode_t *) node;
1465 1.1 christos dns_db_t *db = (dns_db_t *) sdlznode->sdlz;
1466 1.1 christos dns_dbnode_t *tempdb = NULL;
1467 1.1 christos
1468 1.1 christos isc__rdatalist_clone(source, target);
1469 1.1 christos attachnode(db, node, &tempdb);
1470 1.1 christos source->private5 = tempdb;
1471 1.1 christos }
1472 1.1 christos
1473 1.1 christos static dns_rdatasetmethods_t rdataset_methods = {
1474 1.1 christos disassociate,
1475 1.1 christos isc__rdatalist_first,
1476 1.1 christos isc__rdatalist_next,
1477 1.1 christos isc__rdatalist_current,
1478 1.1 christos rdataset_clone,
1479 1.1 christos isc__rdatalist_count,
1480 1.1 christos isc__rdatalist_addnoqname,
1481 1.1 christos isc__rdatalist_getnoqname,
1482 1.1 christos NULL, /* addclosest */
1483 1.1 christos NULL, /* getclosest */
1484 1.1 christos NULL, /* settrust */
1485 1.1 christos NULL, /* expire */
1486 1.1 christos NULL, /* clearprefetch */
1487 1.1 christos NULL, /* setownercase */
1488 1.1 christos NULL, /* getownercase */
1489 1.1 christos NULL /* addglue */
1490 1.1 christos };
1491 1.1 christos
1492 1.1 christos static void
1493 1.1 christos list_tordataset(dns_rdatalist_t *rdatalist,
1494 1.1 christos dns_db_t *db, dns_dbnode_t *node,
1495 1.1 christos dns_rdataset_t *rdataset)
1496 1.1 christos {
1497 1.1 christos /*
1498 1.1 christos * The sdlz rdataset is an rdatalist with some additions.
1499 1.1 christos * - private1 & private2 are used by the rdatalist.
1500 1.1 christos * - private3 & private 4 are unused.
1501 1.1 christos * - private5 is the node.
1502 1.1 christos */
1503 1.1 christos
1504 1.1 christos /* This should never fail. */
1505 1.1 christos RUNTIME_CHECK(dns_rdatalist_tordataset(rdatalist, rdataset) ==
1506 1.1 christos ISC_R_SUCCESS);
1507 1.1 christos
1508 1.1 christos rdataset->methods = &rdataset_methods;
1509 1.1 christos dns_db_attachnode(db, node, &rdataset->private5);
1510 1.1 christos }
1511 1.1 christos
1512 1.1 christos /*
1513 1.1 christos * SDLZ core methods. This is the core of the new DLZ functionality.
1514 1.1 christos */
1515 1.1 christos
1516 1.1 christos /*%
1517 1.1 christos * Build a 'bind' database driver structure to be returned by
1518 1.1 christos * either the find zone or the allow zone transfer method.
1519 1.1 christos * This method is only available in this source file, it is
1520 1.1 christos * not made available anywhere else.
1521 1.1 christos */
1522 1.1 christos
1523 1.1 christos static isc_result_t
1524 1.1 christos dns_sdlzcreateDBP(isc_mem_t *mctx, void *driverarg, void *dbdata,
1525 1.1 christos const dns_name_t *name, dns_rdataclass_t rdclass,
1526 1.1 christos dns_db_t **dbp)
1527 1.1 christos {
1528 1.1 christos isc_result_t result;
1529 1.1 christos dns_sdlz_db_t *sdlzdb;
1530 1.1 christos dns_sdlzimplementation_t *imp;
1531 1.1 christos
1532 1.1 christos /* check that things are as we expect */
1533 1.1 christos REQUIRE(dbp != NULL && *dbp == NULL);
1534 1.1 christos REQUIRE(name != NULL);
1535 1.1 christos
1536 1.1 christos imp = (dns_sdlzimplementation_t *) driverarg;
1537 1.1 christos
1538 1.1 christos /* allocate and zero memory for driver structure */
1539 1.1 christos sdlzdb = isc_mem_get(mctx, sizeof(dns_sdlz_db_t));
1540 1.1 christos if (sdlzdb == NULL)
1541 1.1 christos return (ISC_R_NOMEMORY);
1542 1.1 christos memset(sdlzdb, 0, sizeof(dns_sdlz_db_t));
1543 1.1 christos
1544 1.1 christos /* initialize and set origin */
1545 1.1 christos dns_name_init(&sdlzdb->common.origin, NULL);
1546 1.1 christos result = dns_name_dupwithoffsets(name, mctx, &sdlzdb->common.origin);
1547 1.1 christos if (result != ISC_R_SUCCESS)
1548 1.1 christos goto mem_cleanup;
1549 1.1 christos
1550 1.1 christos /* initialize the reference count mutex */
1551 1.1.1.2 christos isc_mutex_init(&sdlzdb->refcnt_lock);
1552 1.1 christos
1553 1.1 christos /* set the rest of the database structure attributes */
1554 1.1 christos sdlzdb->dlzimp = imp;
1555 1.1 christos sdlzdb->common.methods = &sdlzdb_methods;
1556 1.1 christos sdlzdb->common.attributes = 0;
1557 1.1 christos sdlzdb->common.rdclass = rdclass;
1558 1.1 christos sdlzdb->common.mctx = NULL;
1559 1.1 christos sdlzdb->dbdata = dbdata;
1560 1.1 christos sdlzdb->references = 1;
1561 1.1 christos
1562 1.1 christos /* attach to the memory context */
1563 1.1 christos isc_mem_attach(mctx, &sdlzdb->common.mctx);
1564 1.1 christos
1565 1.1 christos /* mark structure as valid */
1566 1.1 christos sdlzdb->common.magic = DNS_DB_MAGIC;
1567 1.1 christos sdlzdb->common.impmagic = SDLZDB_MAGIC;
1568 1.1 christos *dbp = (dns_db_t *) sdlzdb;
1569 1.1 christos
1570 1.1 christos return (result);
1571 1.1 christos mem_cleanup:
1572 1.1 christos isc_mem_put(mctx, sdlzdb, sizeof(dns_sdlz_db_t));
1573 1.1 christos return (result);
1574 1.1 christos }
1575 1.1 christos
1576 1.1 christos static isc_result_t
1577 1.1 christos dns_sdlzallowzonexfr(void *driverarg, void *dbdata, isc_mem_t *mctx,
1578 1.1 christos dns_rdataclass_t rdclass, const dns_name_t *name,
1579 1.1 christos const isc_sockaddr_t *clientaddr, dns_db_t **dbp)
1580 1.1 christos {
1581 1.1 christos isc_buffer_t b;
1582 1.1 christos isc_buffer_t b2;
1583 1.1 christos char namestr[DNS_NAME_MAXTEXT + 1];
1584 1.1 christos char clientstr[(sizeof "xxxx:xxxx:xxxx:xxxx:xxxx:xxxx:255.255.255.255")
1585 1.1 christos + 1];
1586 1.1 christos isc_netaddr_t netaddr;
1587 1.1 christos isc_result_t result;
1588 1.1 christos dns_sdlzimplementation_t *imp;
1589 1.1 christos
1590 1.1 christos /*
1591 1.1 christos * Perform checks to make sure data is as we expect it to be.
1592 1.1 christos */
1593 1.1 christos REQUIRE(driverarg != NULL);
1594 1.1 christos REQUIRE(name != NULL);
1595 1.1 christos REQUIRE(clientaddr != NULL);
1596 1.1 christos REQUIRE(dbp != NULL && *dbp == NULL);
1597 1.1 christos
1598 1.1 christos imp = (dns_sdlzimplementation_t *) driverarg;
1599 1.1 christos
1600 1.1 christos /* Convert DNS name to ascii text */
1601 1.1 christos isc_buffer_init(&b, namestr, sizeof(namestr));
1602 1.1.1.2 christos result = dns_name_totext(name, true, &b);
1603 1.1 christos if (result != ISC_R_SUCCESS)
1604 1.1 christos return (result);
1605 1.1 christos isc_buffer_putuint8(&b, 0);
1606 1.1 christos
1607 1.1 christos /* convert client address to ascii text */
1608 1.1 christos isc_buffer_init(&b2, clientstr, sizeof(clientstr));
1609 1.1 christos isc_netaddr_fromsockaddr(&netaddr, clientaddr);
1610 1.1 christos result = isc_netaddr_totext(&netaddr, &b2);
1611 1.1 christos if (result != ISC_R_SUCCESS)
1612 1.1 christos return (result);
1613 1.1 christos isc_buffer_putuint8(&b2, 0);
1614 1.1 christos
1615 1.1 christos /* make sure strings are always lowercase */
1616 1.1 christos dns_sdlz_tolower(namestr);
1617 1.1 christos dns_sdlz_tolower(clientstr);
1618 1.1 christos
1619 1.1 christos /* Call SDLZ driver's find zone method */
1620 1.1 christos if (imp->methods->allowzonexfr != NULL) {
1621 1.1 christos MAYBE_LOCK(imp);
1622 1.1 christos result = imp->methods->allowzonexfr(imp->driverarg, dbdata,
1623 1.1 christos namestr, clientstr);
1624 1.1 christos MAYBE_UNLOCK(imp);
1625 1.1 christos /*
1626 1.1 christos * if zone is supported and transfers allowed build a 'bind'
1627 1.1 christos * database driver
1628 1.1 christos */
1629 1.1 christos if (result == ISC_R_SUCCESS)
1630 1.1 christos result = dns_sdlzcreateDBP(mctx, driverarg, dbdata,
1631 1.1 christos name, rdclass, dbp);
1632 1.1 christos return (result);
1633 1.1 christos }
1634 1.1 christos
1635 1.1 christos return (ISC_R_NOTIMPLEMENTED);
1636 1.1 christos }
1637 1.1 christos
1638 1.1 christos static isc_result_t
1639 1.1 christos dns_sdlzcreate(isc_mem_t *mctx, const char *dlzname, unsigned int argc,
1640 1.1 christos char *argv[], void *driverarg, void **dbdata)
1641 1.1 christos {
1642 1.1 christos dns_sdlzimplementation_t *imp;
1643 1.1 christos isc_result_t result = ISC_R_NOTFOUND;
1644 1.1 christos
1645 1.1 christos /* Write debugging message to log */
1646 1.1 christos sdlz_log(ISC_LOG_DEBUG(2), "Loading SDLZ driver.");
1647 1.1 christos
1648 1.1 christos /*
1649 1.1 christos * Performs checks to make sure data is as we expect it to be.
1650 1.1 christos */
1651 1.1 christos REQUIRE(driverarg != NULL);
1652 1.1 christos REQUIRE(dlzname != NULL);
1653 1.1 christos REQUIRE(dbdata != NULL);
1654 1.1 christos UNUSED(mctx);
1655 1.1 christos
1656 1.1 christos imp = driverarg;
1657 1.1 christos
1658 1.1 christos /* If the create method exists, call it. */
1659 1.1 christos if (imp->methods->create != NULL) {
1660 1.1 christos MAYBE_LOCK(imp);
1661 1.1 christos result = imp->methods->create(dlzname, argc, argv,
1662 1.1 christos imp->driverarg, dbdata);
1663 1.1 christos MAYBE_UNLOCK(imp);
1664 1.1 christos }
1665 1.1 christos
1666 1.1 christos /* Write debugging message to log */
1667 1.1 christos if (result == ISC_R_SUCCESS) {
1668 1.1 christos sdlz_log(ISC_LOG_DEBUG(2), "SDLZ driver loaded successfully.");
1669 1.1 christos } else {
1670 1.1 christos sdlz_log(ISC_LOG_ERROR, "SDLZ driver failed to load.");
1671 1.1 christos }
1672 1.1 christos
1673 1.1 christos return (result);
1674 1.1 christos }
1675 1.1 christos
1676 1.1 christos static void
1677 1.1 christos dns_sdlzdestroy(void *driverdata, void **dbdata) {
1678 1.1 christos dns_sdlzimplementation_t *imp;
1679 1.1 christos
1680 1.1 christos /* Write debugging message to log */
1681 1.1 christos sdlz_log(ISC_LOG_DEBUG(2), "Unloading SDLZ driver.");
1682 1.1 christos
1683 1.1 christos imp = driverdata;
1684 1.1 christos
1685 1.1 christos /* If the destroy method exists, call it. */
1686 1.1 christos if (imp->methods->destroy != NULL) {
1687 1.1 christos MAYBE_LOCK(imp);
1688 1.1 christos imp->methods->destroy(imp->driverarg, dbdata);
1689 1.1 christos MAYBE_UNLOCK(imp);
1690 1.1 christos }
1691 1.1 christos }
1692 1.1 christos
1693 1.1 christos static isc_result_t
1694 1.1 christos dns_sdlzfindzone(void *driverarg, void *dbdata, isc_mem_t *mctx,
1695 1.1 christos dns_rdataclass_t rdclass, const dns_name_t *name,
1696 1.1 christos dns_clientinfomethods_t *methods,
1697 1.1 christos dns_clientinfo_t *clientinfo,
1698 1.1 christos dns_db_t **dbp)
1699 1.1 christos {
1700 1.1 christos isc_buffer_t b;
1701 1.1 christos char namestr[DNS_NAME_MAXTEXT + 1];
1702 1.1 christos isc_result_t result;
1703 1.1 christos dns_sdlzimplementation_t *imp;
1704 1.1 christos
1705 1.1 christos /*
1706 1.1 christos * Perform checks to make sure data is as we expect it to be.
1707 1.1 christos */
1708 1.1 christos REQUIRE(driverarg != NULL);
1709 1.1 christos REQUIRE(name != NULL);
1710 1.1 christos REQUIRE(dbp != NULL && *dbp == NULL);
1711 1.1 christos
1712 1.1 christos imp = (dns_sdlzimplementation_t *) driverarg;
1713 1.1 christos
1714 1.1 christos /* Convert DNS name to ascii text */
1715 1.1 christos isc_buffer_init(&b, namestr, sizeof(namestr));
1716 1.1.1.2 christos result = dns_name_totext(name, true, &b);
1717 1.1 christos if (result != ISC_R_SUCCESS)
1718 1.1 christos return (result);
1719 1.1 christos isc_buffer_putuint8(&b, 0);
1720 1.1 christos
1721 1.1 christos /* make sure strings are always lowercase */
1722 1.1 christos dns_sdlz_tolower(namestr);
1723 1.1 christos
1724 1.1 christos /* Call SDLZ driver's find zone method */
1725 1.1 christos MAYBE_LOCK(imp);
1726 1.1 christos result = imp->methods->findzone(imp->driverarg, dbdata, namestr,
1727 1.1 christos methods, clientinfo);
1728 1.1 christos MAYBE_UNLOCK(imp);
1729 1.1 christos
1730 1.1 christos /*
1731 1.1 christos * if zone is supported build a 'bind' database driver
1732 1.1 christos * structure to return
1733 1.1 christos */
1734 1.1 christos if (result == ISC_R_SUCCESS)
1735 1.1 christos result = dns_sdlzcreateDBP(mctx, driverarg, dbdata, name,
1736 1.1 christos rdclass, dbp);
1737 1.1 christos
1738 1.1 christos return (result);
1739 1.1 christos }
1740 1.1 christos
1741 1.1 christos
1742 1.1 christos static isc_result_t
1743 1.1 christos dns_sdlzconfigure(void *driverarg, void *dbdata,
1744 1.1 christos dns_view_t *view, dns_dlzdb_t *dlzdb)
1745 1.1 christos {
1746 1.1 christos isc_result_t result;
1747 1.1 christos dns_sdlzimplementation_t *imp;
1748 1.1 christos
1749 1.1 christos REQUIRE(driverarg != NULL);
1750 1.1 christos
1751 1.1 christos imp = (dns_sdlzimplementation_t *) driverarg;
1752 1.1 christos
1753 1.1 christos /* Call SDLZ driver's configure method */
1754 1.1 christos if (imp->methods->configure != NULL) {
1755 1.1 christos MAYBE_LOCK(imp);
1756 1.1 christos result = imp->methods->configure(view, dlzdb,
1757 1.1 christos imp->driverarg, dbdata);
1758 1.1 christos MAYBE_UNLOCK(imp);
1759 1.1 christos } else {
1760 1.1 christos result = ISC_R_SUCCESS;
1761 1.1 christos }
1762 1.1 christos
1763 1.1 christos return (result);
1764 1.1 christos }
1765 1.1 christos
1766 1.1.1.2 christos static bool
1767 1.1 christos dns_sdlzssumatch(const dns_name_t *signer, const dns_name_t *name,
1768 1.1 christos const isc_netaddr_t *tcpaddr, dns_rdatatype_t type,
1769 1.1 christos const dst_key_t *key, void *driverarg, void *dbdata)
1770 1.1 christos {
1771 1.1 christos dns_sdlzimplementation_t *imp;
1772 1.1 christos char b_signer[DNS_NAME_FORMATSIZE];
1773 1.1 christos char b_name[DNS_NAME_FORMATSIZE];
1774 1.1 christos char b_addr[ISC_NETADDR_FORMATSIZE];
1775 1.1 christos char b_type[DNS_RDATATYPE_FORMATSIZE];
1776 1.1 christos char b_key[DST_KEY_FORMATSIZE];
1777 1.1 christos isc_buffer_t *tkey_token = NULL;
1778 1.1 christos isc_region_t token_region = { NULL, 0 };
1779 1.1.1.2 christos uint32_t token_len = 0;
1780 1.1.1.2 christos bool ret;
1781 1.1 christos
1782 1.1 christos REQUIRE(driverarg != NULL);
1783 1.1 christos
1784 1.1 christos imp = (dns_sdlzimplementation_t *) driverarg;
1785 1.1 christos if (imp->methods->ssumatch == NULL)
1786 1.1.1.2 christos return (false);
1787 1.1 christos
1788 1.1 christos /*
1789 1.1 christos * Format the request elements. sdlz operates on strings, not
1790 1.1 christos * structures
1791 1.1 christos */
1792 1.1 christos if (signer != NULL)
1793 1.1 christos dns_name_format(signer, b_signer, sizeof(b_signer));
1794 1.1 christos else
1795 1.1 christos b_signer[0] = 0;
1796 1.1 christos
1797 1.1 christos dns_name_format(name, b_name, sizeof(b_name));
1798 1.1 christos
1799 1.1 christos if (tcpaddr != NULL)
1800 1.1 christos isc_netaddr_format(tcpaddr, b_addr, sizeof(b_addr));
1801 1.1 christos else
1802 1.1 christos b_addr[0] = 0;
1803 1.1 christos
1804 1.1 christos dns_rdatatype_format(type, b_type, sizeof(b_type));
1805 1.1 christos
1806 1.1 christos if (key != NULL) {
1807 1.1 christos dst_key_format(key, b_key, sizeof(b_key));
1808 1.1 christos tkey_token = dst_key_tkeytoken(key);
1809 1.1 christos } else
1810 1.1 christos b_key[0] = 0;
1811 1.1 christos
1812 1.1 christos if (tkey_token != NULL) {
1813 1.1 christos isc_buffer_region(tkey_token, &token_region);
1814 1.1 christos token_len = token_region.length;
1815 1.1 christos }
1816 1.1 christos
1817 1.1 christos MAYBE_LOCK(imp);
1818 1.1 christos ret = imp->methods->ssumatch(b_signer, b_name, b_addr, b_type, b_key,
1819 1.1 christos token_len,
1820 1.1 christos token_len != 0 ? token_region.base : NULL,
1821 1.1 christos imp->driverarg, dbdata);
1822 1.1 christos MAYBE_UNLOCK(imp);
1823 1.1 christos return (ret);
1824 1.1 christos }
1825 1.1 christos
1826 1.1 christos static dns_dlzmethods_t sdlzmethods = {
1827 1.1 christos dns_sdlzcreate,
1828 1.1 christos dns_sdlzdestroy,
1829 1.1 christos dns_sdlzfindzone,
1830 1.1 christos dns_sdlzallowzonexfr,
1831 1.1 christos dns_sdlzconfigure,
1832 1.1 christos dns_sdlzssumatch
1833 1.1 christos };
1834 1.1 christos
1835 1.1 christos /*
1836 1.1 christos * Public functions.
1837 1.1 christos */
1838 1.1 christos
1839 1.1 christos isc_result_t
1840 1.1 christos dns_sdlz_putrr(dns_sdlzlookup_t *lookup, const char *type, dns_ttl_t ttl,
1841 1.1 christos const char *data)
1842 1.1 christos {
1843 1.1 christos dns_rdatalist_t *rdatalist;
1844 1.1 christos dns_rdata_t *rdata;
1845 1.1 christos dns_rdatatype_t typeval;
1846 1.1 christos isc_consttextregion_t r;
1847 1.1 christos isc_buffer_t b;
1848 1.1 christos isc_buffer_t *rdatabuf = NULL;
1849 1.1 christos isc_lex_t *lex;
1850 1.1 christos isc_result_t result;
1851 1.1 christos unsigned int size;
1852 1.1 christos isc_mem_t *mctx;
1853 1.1 christos const dns_name_t *origin;
1854 1.1 christos
1855 1.1 christos REQUIRE(VALID_SDLZLOOKUP(lookup));
1856 1.1 christos REQUIRE(type != NULL);
1857 1.1 christos REQUIRE(data != NULL);
1858 1.1 christos
1859 1.1 christos mctx = lookup->sdlz->common.mctx;
1860 1.1 christos
1861 1.1 christos r.base = type;
1862 1.1 christos r.length = strlen(type);
1863 1.1 christos result = dns_rdatatype_fromtext(&typeval, (void *) &r);
1864 1.1 christos if (result != ISC_R_SUCCESS)
1865 1.1 christos return (result);
1866 1.1 christos
1867 1.1 christos rdatalist = ISC_LIST_HEAD(lookup->lists);
1868 1.1 christos while (rdatalist != NULL) {
1869 1.1 christos if (rdatalist->type == typeval)
1870 1.1 christos break;
1871 1.1 christos rdatalist = ISC_LIST_NEXT(rdatalist, link);
1872 1.1 christos }
1873 1.1 christos
1874 1.1 christos if (rdatalist == NULL) {
1875 1.1 christos rdatalist = isc_mem_get(mctx, sizeof(dns_rdatalist_t));
1876 1.1 christos if (rdatalist == NULL)
1877 1.1 christos return (ISC_R_NOMEMORY);
1878 1.1 christos dns_rdatalist_init(rdatalist);
1879 1.1 christos rdatalist->rdclass = lookup->sdlz->common.rdclass;
1880 1.1 christos rdatalist->type = typeval;
1881 1.1 christos rdatalist->ttl = ttl;
1882 1.1 christos ISC_LIST_APPEND(lookup->lists, rdatalist, link);
1883 1.1 christos } else
1884 1.1 christos if (rdatalist->ttl > ttl) {
1885 1.1 christos /*
1886 1.1 christos * BIND9 doesn't enforce all RRs in an RRset
1887 1.1 christos * having the same TTL, as per RFC 2136,
1888 1.1 christos * section 7.12. If a DLZ backend has
1889 1.1 christos * different TTLs, then the best
1890 1.1 christos * we can do is return the lowest.
1891 1.1 christos */
1892 1.1 christos rdatalist->ttl = ttl;
1893 1.1 christos }
1894 1.1 christos
1895 1.1 christos rdata = isc_mem_get(mctx, sizeof(dns_rdata_t));
1896 1.1 christos if (rdata == NULL)
1897 1.1 christos return (ISC_R_NOMEMORY);
1898 1.1 christos dns_rdata_init(rdata);
1899 1.1 christos
1900 1.1 christos if ((lookup->sdlz->dlzimp->flags & DNS_SDLZFLAG_RELATIVERDATA) != 0)
1901 1.1 christos origin = &lookup->sdlz->common.origin;
1902 1.1 christos else
1903 1.1 christos origin = dns_rootname;
1904 1.1 christos
1905 1.1 christos lex = NULL;
1906 1.1 christos result = isc_lex_create(mctx, 64, &lex);
1907 1.1 christos if (result != ISC_R_SUCCESS)
1908 1.1 christos goto failure;
1909 1.1 christos
1910 1.1 christos size = initial_size(data);
1911 1.1 christos do {
1912 1.1 christos isc_buffer_constinit(&b, data, strlen(data));
1913 1.1 christos isc_buffer_add(&b, strlen(data));
1914 1.1 christos
1915 1.1 christos result = isc_lex_openbuffer(lex, &b);
1916 1.1 christos if (result != ISC_R_SUCCESS)
1917 1.1 christos goto failure;
1918 1.1 christos
1919 1.1 christos rdatabuf = NULL;
1920 1.1 christos result = isc_buffer_allocate(mctx, &rdatabuf, size);
1921 1.1 christos if (result != ISC_R_SUCCESS)
1922 1.1 christos goto failure;
1923 1.1 christos
1924 1.1 christos result = dns_rdata_fromtext(rdata, rdatalist->rdclass,
1925 1.1 christos rdatalist->type, lex,
1926 1.1.1.2 christos origin, false,
1927 1.1 christos mctx, rdatabuf,
1928 1.1 christos &lookup->callbacks);
1929 1.1.1.2 christos if (result != ISC_R_SUCCESS) {
1930 1.1 christos isc_buffer_free(&rdatabuf);
1931 1.1.1.2 christos result = DNS_R_SERVFAIL;
1932 1.1.1.2 christos }
1933 1.1 christos if (size >= 65535)
1934 1.1 christos break;
1935 1.1 christos size *= 2;
1936 1.1 christos if (size >= 65535)
1937 1.1 christos size = 65535;
1938 1.1 christos } while (result == ISC_R_NOSPACE);
1939 1.1 christos
1940 1.1 christos if (result != ISC_R_SUCCESS)
1941 1.1 christos goto failure;
1942 1.1 christos
1943 1.1 christos ISC_LIST_APPEND(rdatalist->rdata, rdata, link);
1944 1.1 christos ISC_LIST_APPEND(lookup->buffers, rdatabuf, link);
1945 1.1 christos
1946 1.1 christos if (lex != NULL)
1947 1.1 christos isc_lex_destroy(&lex);
1948 1.1 christos
1949 1.1 christos return (ISC_R_SUCCESS);
1950 1.1 christos
1951 1.1 christos failure:
1952 1.1 christos if (rdatabuf != NULL)
1953 1.1 christos isc_buffer_free(&rdatabuf);
1954 1.1 christos if (lex != NULL)
1955 1.1 christos isc_lex_destroy(&lex);
1956 1.1 christos isc_mem_put(mctx, rdata, sizeof(dns_rdata_t));
1957 1.1 christos
1958 1.1 christos return (result);
1959 1.1 christos }
1960 1.1 christos
1961 1.1 christos isc_result_t
1962 1.1 christos dns_sdlz_putnamedrr(dns_sdlzallnodes_t *allnodes, const char *name,
1963 1.1 christos const char *type, dns_ttl_t ttl, const char *data)
1964 1.1 christos {
1965 1.1 christos dns_name_t *newname;
1966 1.1 christos const dns_name_t *origin;
1967 1.1 christos dns_fixedname_t fnewname;
1968 1.1 christos dns_sdlz_db_t *sdlz = (dns_sdlz_db_t *)allnodes->common.db;
1969 1.1 christos dns_sdlznode_t *sdlznode;
1970 1.1 christos isc_mem_t *mctx = sdlz->common.mctx;
1971 1.1 christos isc_buffer_t b;
1972 1.1 christos isc_result_t result;
1973 1.1 christos
1974 1.1 christos newname = dns_fixedname_initname(&fnewname);
1975 1.1 christos
1976 1.1 christos if ((sdlz->dlzimp->flags & DNS_SDLZFLAG_RELATIVERDATA) != 0)
1977 1.1 christos origin = &sdlz->common.origin;
1978 1.1 christos else
1979 1.1 christos origin = dns_rootname;
1980 1.1 christos isc_buffer_constinit(&b, name, strlen(name));
1981 1.1 christos isc_buffer_add(&b, strlen(name));
1982 1.1 christos
1983 1.1 christos result = dns_name_fromtext(newname, &b, origin, 0, NULL);
1984 1.1 christos if (result != ISC_R_SUCCESS)
1985 1.1 christos return (result);
1986 1.1 christos
1987 1.1 christos if (allnodes->common.relative_names) {
1988 1.1 christos /* All names are relative to the root */
1989 1.1 christos unsigned int nlabels = dns_name_countlabels(newname);
1990 1.1 christos dns_name_getlabelsequence(newname, 0, nlabels - 1, newname);
1991 1.1 christos }
1992 1.1 christos
1993 1.1 christos sdlznode = ISC_LIST_HEAD(allnodes->nodelist);
1994 1.1 christos if (sdlznode == NULL || !dns_name_equal(sdlznode->name, newname)) {
1995 1.1 christos sdlznode = NULL;
1996 1.1 christos result = createnode(sdlz, &sdlznode);
1997 1.1 christos if (result != ISC_R_SUCCESS)
1998 1.1 christos return (result);
1999 1.1 christos sdlznode->name = isc_mem_get(mctx, sizeof(dns_name_t));
2000 1.1 christos if (sdlznode->name == NULL) {
2001 1.1 christos destroynode(sdlznode);
2002 1.1 christos return (ISC_R_NOMEMORY);
2003 1.1 christos }
2004 1.1 christos dns_name_init(sdlznode->name, NULL);
2005 1.1 christos result = dns_name_dup(newname, mctx, sdlznode->name);
2006 1.1 christos if (result != ISC_R_SUCCESS) {
2007 1.1 christos isc_mem_put(mctx, sdlznode->name, sizeof(dns_name_t));
2008 1.1 christos destroynode(sdlznode);
2009 1.1 christos return (result);
2010 1.1 christos }
2011 1.1 christos ISC_LIST_PREPEND(allnodes->nodelist, sdlznode, link);
2012 1.1 christos if (allnodes->origin == NULL &&
2013 1.1 christos dns_name_equal(newname, &sdlz->common.origin))
2014 1.1 christos allnodes->origin = sdlznode;
2015 1.1 christos }
2016 1.1 christos return (dns_sdlz_putrr(sdlznode, type, ttl, data));
2017 1.1 christos
2018 1.1 christos }
2019 1.1 christos
2020 1.1 christos isc_result_t
2021 1.1 christos dns_sdlz_putsoa(dns_sdlzlookup_t *lookup, const char *mname, const char *rname,
2022 1.1.1.2 christos uint32_t serial)
2023 1.1 christos {
2024 1.1 christos char str[2 * DNS_NAME_MAXTEXT + 5 * (sizeof("2147483647")) + 7];
2025 1.1 christos int n;
2026 1.1 christos
2027 1.1 christos REQUIRE(mname != NULL);
2028 1.1 christos REQUIRE(rname != NULL);
2029 1.1 christos
2030 1.1 christos n = snprintf(str, sizeof str, "%s %s %u %u %u %u %u",
2031 1.1 christos mname, rname, serial,
2032 1.1 christos SDLZ_DEFAULT_REFRESH, SDLZ_DEFAULT_RETRY,
2033 1.1 christos SDLZ_DEFAULT_EXPIRE, SDLZ_DEFAULT_MINIMUM);
2034 1.1 christos if (n >= (int)sizeof(str) || n < 0)
2035 1.1 christos return (ISC_R_NOSPACE);
2036 1.1 christos return (dns_sdlz_putrr(lookup, "SOA", SDLZ_DEFAULT_TTL, str));
2037 1.1 christos }
2038 1.1 christos
2039 1.1 christos isc_result_t
2040 1.1 christos dns_sdlzregister(const char *drivername, const dns_sdlzmethods_t *methods,
2041 1.1 christos void *driverarg, unsigned int flags, isc_mem_t *mctx,
2042 1.1 christos dns_sdlzimplementation_t **sdlzimp)
2043 1.1 christos {
2044 1.1 christos
2045 1.1 christos dns_sdlzimplementation_t *imp;
2046 1.1 christos isc_result_t result;
2047 1.1 christos
2048 1.1 christos /*
2049 1.1 christos * Performs checks to make sure data is as we expect it to be.
2050 1.1 christos */
2051 1.1 christos REQUIRE(drivername != NULL);
2052 1.1 christos REQUIRE(methods != NULL);
2053 1.1 christos REQUIRE(methods->findzone != NULL);
2054 1.1 christos REQUIRE(methods->lookup != NULL);
2055 1.1 christos REQUIRE(mctx != NULL);
2056 1.1 christos REQUIRE(sdlzimp != NULL && *sdlzimp == NULL);
2057 1.1 christos REQUIRE((flags & ~(DNS_SDLZFLAG_RELATIVEOWNER |
2058 1.1 christos DNS_SDLZFLAG_RELATIVERDATA |
2059 1.1 christos DNS_SDLZFLAG_THREADSAFE)) == 0);
2060 1.1 christos
2061 1.1 christos /* Write debugging message to log */
2062 1.1 christos sdlz_log(ISC_LOG_DEBUG(2), "Registering SDLZ driver '%s'", drivername);
2063 1.1 christos
2064 1.1 christos /*
2065 1.1 christos * Allocate memory for a sdlz_implementation object. Error if
2066 1.1 christos * we cannot.
2067 1.1 christos */
2068 1.1 christos imp = isc_mem_get(mctx, sizeof(dns_sdlzimplementation_t));
2069 1.1 christos if (imp == NULL)
2070 1.1 christos return (ISC_R_NOMEMORY);
2071 1.1 christos
2072 1.1 christos /* Make sure memory region is set to all 0's */
2073 1.1 christos memset(imp, 0, sizeof(dns_sdlzimplementation_t));
2074 1.1 christos
2075 1.1 christos /* Store the data passed into this method */
2076 1.1 christos imp->methods = methods;
2077 1.1 christos imp->driverarg = driverarg;
2078 1.1 christos imp->flags = flags;
2079 1.1 christos imp->mctx = NULL;
2080 1.1 christos
2081 1.1 christos /* attach the new sdlz_implementation object to a memory context */
2082 1.1 christos isc_mem_attach(mctx, &imp->mctx);
2083 1.1 christos
2084 1.1 christos /*
2085 1.1 christos * initialize the driver lock, error if we cannot
2086 1.1 christos * (used if a driver does not support multiple threads)
2087 1.1 christos */
2088 1.1.1.2 christos isc_mutex_init(&imp->driverlock);
2089 1.1 christos
2090 1.1 christos imp->dlz_imp = NULL;
2091 1.1 christos
2092 1.1 christos /*
2093 1.1 christos * register the DLZ driver. Pass in our "extra" sdlz information as
2094 1.1 christos * a driverarg. (that's why we stored the passed in driver arg in our
2095 1.1 christos * sdlz_implementation structure) Also, store the dlz_implementation
2096 1.1 christos * structure in our sdlz_implementation.
2097 1.1 christos */
2098 1.1 christos result = dns_dlzregister(drivername, &sdlzmethods, imp, mctx,
2099 1.1 christos &imp->dlz_imp);
2100 1.1 christos
2101 1.1 christos /* if registration fails, cleanup and get outta here. */
2102 1.1 christos if (result != ISC_R_SUCCESS)
2103 1.1 christos goto cleanup_mutex;
2104 1.1 christos
2105 1.1 christos *sdlzimp = imp;
2106 1.1 christos
2107 1.1 christos return (ISC_R_SUCCESS);
2108 1.1 christos
2109 1.1 christos cleanup_mutex:
2110 1.1 christos /* destroy the driver lock, we don't need it anymore */
2111 1.1.1.2 christos isc_mutex_destroy(&imp->driverlock);
2112 1.1 christos
2113 1.1 christos /*
2114 1.1 christos * return the memory back to the available memory pool and
2115 1.1 christos * remove it from the memory context.
2116 1.1 christos */
2117 1.1 christos isc_mem_put(mctx, imp, sizeof(dns_sdlzimplementation_t));
2118 1.1 christos isc_mem_detach(&mctx);
2119 1.1 christos return (result);
2120 1.1 christos }
2121 1.1 christos
2122 1.1 christos void
2123 1.1 christos dns_sdlzunregister(dns_sdlzimplementation_t **sdlzimp) {
2124 1.1 christos dns_sdlzimplementation_t *imp;
2125 1.1 christos isc_mem_t *mctx;
2126 1.1 christos
2127 1.1 christos /* Write debugging message to log */
2128 1.1 christos sdlz_log(ISC_LOG_DEBUG(2), "Unregistering SDLZ driver.");
2129 1.1 christos
2130 1.1 christos /*
2131 1.1 christos * Performs checks to make sure data is as we expect it to be.
2132 1.1 christos */
2133 1.1 christos REQUIRE(sdlzimp != NULL && *sdlzimp != NULL);
2134 1.1 christos
2135 1.1 christos imp = *sdlzimp;
2136 1.1 christos
2137 1.1 christos /* Unregister the DLZ driver implementation */
2138 1.1 christos dns_dlzunregister(&imp->dlz_imp);
2139 1.1 christos
2140 1.1 christos /* destroy the driver lock, we don't need it anymore */
2141 1.1.1.2 christos isc_mutex_destroy(&imp->driverlock);
2142 1.1 christos
2143 1.1 christos mctx = imp->mctx;
2144 1.1 christos
2145 1.1 christos /*
2146 1.1 christos * return the memory back to the available memory pool and
2147 1.1 christos * remove it from the memory context.
2148 1.1 christos */
2149 1.1 christos isc_mem_put(mctx, imp, sizeof(dns_sdlzimplementation_t));
2150 1.1 christos isc_mem_detach(&mctx);
2151 1.1 christos
2152 1.1 christos *sdlzimp = NULL;
2153 1.1 christos }
2154 1.1 christos
2155 1.1 christos
2156 1.1 christos isc_result_t
2157 1.1 christos dns_sdlz_setdb(dns_dlzdb_t *dlzdatabase, dns_rdataclass_t rdclass,
2158 1.1 christos const dns_name_t *name, dns_db_t **dbp)
2159 1.1 christos {
2160 1.1 christos isc_result_t result;
2161 1.1 christos
2162 1.1 christos result = dns_sdlzcreateDBP(dlzdatabase->mctx,
2163 1.1 christos dlzdatabase->implementation->driverarg,
2164 1.1 christos dlzdatabase->dbdata, name, rdclass, dbp);
2165 1.1 christos return (result);
2166 1.1 christos }
2167