sdlz.c revision 1.3 1 1.2 christos /* $NetBSD: sdlz.c,v 1.3 2019/01/09 16:55:12 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.3 christos
53 1.3 christos #include <inttypes.h>
54 1.3 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.2 christos } while (/*CONSTCOND*/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.2 christos } while (/*CONSTCOND*/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.3 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.3 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.3 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.3 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.3 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.2 christos void *sdlzv, *tdlzv;
473 1.1 christos
474 1.1 christos node = isc_mem_get(sdlz->common.mctx, sizeof(dns_sdlznode_t));
475 1.1 christos if (node == NULL)
476 1.1 christos return (ISC_R_NOMEMORY);
477 1.1 christos
478 1.1 christos node->sdlz = NULL;
479 1.2 christos sdlzv = sdlz;
480 1.2 christos tdlzv = &node->sdlz;
481 1.2 christos attach(sdlzv, tdlzv);
482 1.1 christos ISC_LIST_INIT(node->lists);
483 1.1 christos ISC_LIST_INIT(node->buffers);
484 1.1 christos ISC_LINK_INIT(node, link);
485 1.1 christos node->name = NULL;
486 1.3 christos isc_mutex_init(&node->lock);
487 1.1 christos dns_rdatacallbacks_init(&node->callbacks);
488 1.1 christos node->references = 1;
489 1.1 christos node->magic = SDLZLOOKUP_MAGIC;
490 1.1 christos
491 1.1 christos *nodep = node;
492 1.1 christos return (ISC_R_SUCCESS);
493 1.1 christos }
494 1.1 christos
495 1.1 christos static void
496 1.1 christos destroynode(dns_sdlznode_t *node) {
497 1.1 christos dns_rdatalist_t *list;
498 1.1 christos dns_rdata_t *rdata;
499 1.1 christos isc_buffer_t *b;
500 1.1 christos dns_sdlz_db_t *sdlz;
501 1.1 christos dns_db_t *db;
502 1.1 christos isc_mem_t *mctx;
503 1.1 christos
504 1.1 christos sdlz = node->sdlz;
505 1.1 christos mctx = sdlz->common.mctx;
506 1.1 christos
507 1.1 christos while (!ISC_LIST_EMPTY(node->lists)) {
508 1.1 christos list = ISC_LIST_HEAD(node->lists);
509 1.1 christos while (!ISC_LIST_EMPTY(list->rdata)) {
510 1.1 christos rdata = ISC_LIST_HEAD(list->rdata);
511 1.1 christos ISC_LIST_UNLINK(list->rdata, rdata, link);
512 1.1 christos isc_mem_put(mctx, rdata, sizeof(dns_rdata_t));
513 1.1 christos }
514 1.1 christos ISC_LIST_UNLINK(node->lists, list, link);
515 1.1 christos isc_mem_put(mctx, list, sizeof(dns_rdatalist_t));
516 1.1 christos }
517 1.1 christos
518 1.1 christos while (!ISC_LIST_EMPTY(node->buffers)) {
519 1.1 christos b = ISC_LIST_HEAD(node->buffers);
520 1.1 christos ISC_LIST_UNLINK(node->buffers, b, link);
521 1.1 christos isc_buffer_free(&b);
522 1.1 christos }
523 1.1 christos
524 1.1 christos if (node->name != NULL) {
525 1.1 christos dns_name_free(node->name, mctx);
526 1.1 christos isc_mem_put(mctx, node->name, sizeof(dns_name_t));
527 1.1 christos }
528 1.3 christos isc_mutex_destroy(&node->lock);
529 1.1 christos node->magic = 0;
530 1.1 christos isc_mem_put(mctx, node, sizeof(dns_sdlznode_t));
531 1.1 christos db = &sdlz->common;
532 1.1 christos detach(&db);
533 1.1 christos }
534 1.1 christos
535 1.1 christos static isc_result_t
536 1.3 christos getnodedata(dns_db_t *db, const dns_name_t *name, bool create,
537 1.1 christos unsigned int options, dns_clientinfomethods_t *methods,
538 1.1 christos dns_clientinfo_t *clientinfo, dns_dbnode_t **nodep)
539 1.1 christos {
540 1.1 christos dns_sdlz_db_t *sdlz = (dns_sdlz_db_t *)db;
541 1.1 christos dns_sdlznode_t *node = NULL;
542 1.1 christos isc_result_t result;
543 1.1 christos isc_buffer_t b;
544 1.1 christos char namestr[DNS_NAME_MAXTEXT + 1];
545 1.1 christos isc_buffer_t b2;
546 1.1 christos char zonestr[DNS_NAME_MAXTEXT + 1];
547 1.3 christos bool isorigin;
548 1.1 christos dns_sdlzauthorityfunc_t authority;
549 1.1 christos
550 1.1 christos REQUIRE(VALID_SDLZDB(sdlz));
551 1.1 christos REQUIRE(nodep != NULL && *nodep == NULL);
552 1.1 christos
553 1.1 christos if (sdlz->dlzimp->methods->newversion == NULL) {
554 1.3 christos REQUIRE(create == false);
555 1.1 christos }
556 1.1 christos
557 1.1 christos isc_buffer_init(&b, namestr, sizeof(namestr));
558 1.1 christos if ((sdlz->dlzimp->flags & DNS_SDLZFLAG_RELATIVEOWNER) != 0) {
559 1.1 christos dns_name_t relname;
560 1.1 christos unsigned int labels;
561 1.1 christos
562 1.1 christos labels = dns_name_countlabels(name) -
563 1.1 christos dns_name_countlabels(&sdlz->common.origin);
564 1.1 christos dns_name_init(&relname, NULL);
565 1.1 christos dns_name_getlabelsequence(name, 0, labels, &relname);
566 1.3 christos result = dns_name_totext(&relname, true, &b);
567 1.1 christos if (result != ISC_R_SUCCESS)
568 1.1 christos return (result);
569 1.1 christos } else {
570 1.3 christos result = dns_name_totext(name, true, &b);
571 1.1 christos if (result != ISC_R_SUCCESS)
572 1.1 christos return (result);
573 1.1 christos }
574 1.1 christos isc_buffer_putuint8(&b, 0);
575 1.1 christos
576 1.1 christos isc_buffer_init(&b2, zonestr, sizeof(zonestr));
577 1.3 christos result = dns_name_totext(&sdlz->common.origin, true, &b2);
578 1.1 christos if (result != ISC_R_SUCCESS)
579 1.1 christos return (result);
580 1.1 christos isc_buffer_putuint8(&b2, 0);
581 1.1 christos
582 1.1 christos result = createnode(sdlz, &node);
583 1.1 christos if (result != ISC_R_SUCCESS)
584 1.1 christos return (result);
585 1.1 christos
586 1.1 christos isorigin = dns_name_equal(name, &sdlz->common.origin);
587 1.1 christos
588 1.1 christos /* make sure strings are always lowercase */
589 1.1 christos dns_sdlz_tolower(zonestr);
590 1.1 christos dns_sdlz_tolower(namestr);
591 1.1 christos
592 1.1 christos MAYBE_LOCK(sdlz->dlzimp);
593 1.1 christos
594 1.1 christos /* try to lookup the host (namestr) */
595 1.1 christos result = sdlz->dlzimp->methods->lookup(zonestr, namestr,
596 1.1 christos sdlz->dlzimp->driverarg,
597 1.1 christos sdlz->dbdata, node,
598 1.1 christos methods, clientinfo);
599 1.1 christos
600 1.1 christos /*
601 1.1 christos * If the name was not found and DNS_DBFIND_NOWILD is not
602 1.1 christos * set, then we try to find a wildcard entry.
603 1.1 christos *
604 1.1 christos * If DNS_DBFIND_NOZONECUT is set and there are multiple
605 1.1 christos * levels between the host and the zone origin, we also look
606 1.1 christos * for wildcards at each level.
607 1.1 christos */
608 1.1 christos if (result == ISC_R_NOTFOUND && !create &&
609 1.1 christos (options & DNS_DBFIND_NOWILD) == 0)
610 1.1 christos {
611 1.1 christos unsigned int i, dlabels, nlabels;
612 1.1 christos
613 1.1 christos nlabels = dns_name_countlabels(name);
614 1.1 christos dlabels = nlabels - dns_name_countlabels(&sdlz->common.origin);
615 1.1 christos for (i = 0; i < dlabels; i++) {
616 1.1 christos char wildstr[DNS_NAME_MAXTEXT + 1];
617 1.1 christos dns_fixedname_t fixed;
618 1.1 christos const dns_name_t *wild;
619 1.1 christos
620 1.1 christos dns_fixedname_init(&fixed);
621 1.1 christos if (i == dlabels)
622 1.1 christos wild = dns_wildcardname;
623 1.1 christos else {
624 1.1 christos dns_name_t *fname;
625 1.1 christos fname = dns_fixedname_name(&fixed);
626 1.1 christos dns_name_getlabelsequence(name, i + 1,
627 1.1 christos dlabels - i - 1,
628 1.1 christos fname);
629 1.1 christos result = dns_name_concatenate(dns_wildcardname,
630 1.1 christos fname, fname,
631 1.1 christos NULL);
632 1.1 christos if (result != ISC_R_SUCCESS)
633 1.1 christos return (result);
634 1.1 christos wild = fname;
635 1.1 christos }
636 1.1 christos
637 1.1 christos isc_buffer_init(&b, wildstr, sizeof(wildstr));
638 1.3 christos result = dns_name_totext(wild, true, &b);
639 1.1 christos if (result != ISC_R_SUCCESS)
640 1.1 christos return (result);
641 1.1 christos isc_buffer_putuint8(&b, 0);
642 1.1 christos
643 1.1 christos result = sdlz->dlzimp->methods->lookup(zonestr, wildstr,
644 1.1 christos sdlz->dlzimp->driverarg,
645 1.1 christos sdlz->dbdata, node,
646 1.1 christos methods, clientinfo);
647 1.1 christos if (result == ISC_R_SUCCESS)
648 1.1 christos break;
649 1.1 christos }
650 1.1 christos }
651 1.1 christos
652 1.1 christos MAYBE_UNLOCK(sdlz->dlzimp);
653 1.1 christos
654 1.1 christos if (result == ISC_R_NOTFOUND && (isorigin || create))
655 1.1 christos result = ISC_R_SUCCESS;
656 1.1 christos
657 1.1 christos if (result != ISC_R_SUCCESS) {
658 1.1 christos destroynode(node);
659 1.1 christos return (result);
660 1.1 christos }
661 1.1 christos
662 1.1 christos if (isorigin && sdlz->dlzimp->methods->authority != NULL) {
663 1.1 christos MAYBE_LOCK(sdlz->dlzimp);
664 1.1 christos authority = sdlz->dlzimp->methods->authority;
665 1.1 christos result = (*authority)(zonestr, sdlz->dlzimp->driverarg,
666 1.1 christos sdlz->dbdata, node);
667 1.1 christos MAYBE_UNLOCK(sdlz->dlzimp);
668 1.1 christos if (result != ISC_R_SUCCESS &&
669 1.1 christos result != ISC_R_NOTIMPLEMENTED)
670 1.1 christos {
671 1.1 christos destroynode(node);
672 1.1 christos return (result);
673 1.1 christos }
674 1.1 christos }
675 1.1 christos
676 1.1 christos if (node->name == NULL) {
677 1.1 christos node->name = isc_mem_get(sdlz->common.mctx,
678 1.1 christos sizeof(dns_name_t));
679 1.1 christos if (node->name == NULL) {
680 1.1 christos destroynode(node);
681 1.1 christos return (ISC_R_NOMEMORY);
682 1.1 christos }
683 1.1 christos dns_name_init(node->name, NULL);
684 1.1 christos result = dns_name_dup(name, sdlz->common.mctx, node->name);
685 1.1 christos if (result != ISC_R_SUCCESS) {
686 1.1 christos isc_mem_put(sdlz->common.mctx, node->name,
687 1.1 christos sizeof(dns_name_t));
688 1.1 christos destroynode(node);
689 1.1 christos return (result);
690 1.1 christos }
691 1.1 christos }
692 1.1 christos
693 1.1 christos *nodep = node;
694 1.1 christos return (ISC_R_SUCCESS);
695 1.1 christos }
696 1.1 christos
697 1.1 christos static isc_result_t
698 1.3 christos findnodeext(dns_db_t *db, const dns_name_t *name, bool create,
699 1.1 christos dns_clientinfomethods_t *methods, dns_clientinfo_t *clientinfo,
700 1.1 christos dns_dbnode_t **nodep)
701 1.1 christos {
702 1.1 christos return (getnodedata(db, name, create, 0, methods, clientinfo, nodep));
703 1.1 christos }
704 1.1 christos
705 1.1 christos static isc_result_t
706 1.3 christos findnode(dns_db_t *db, const dns_name_t *name, bool create,
707 1.1 christos dns_dbnode_t **nodep)
708 1.1 christos {
709 1.1 christos return (getnodedata(db, name, create, 0, NULL, NULL, nodep));
710 1.1 christos }
711 1.1 christos
712 1.1 christos static isc_result_t
713 1.1 christos findzonecut(dns_db_t *db, const dns_name_t *name, unsigned int options,
714 1.1 christos isc_stdtime_t now, dns_dbnode_t **nodep, dns_name_t *foundname,
715 1.3 christos dns_name_t *dcname, dns_rdataset_t *rdataset,
716 1.3 christos dns_rdataset_t *sigrdataset)
717 1.1 christos {
718 1.1 christos UNUSED(db);
719 1.1 christos UNUSED(name);
720 1.1 christos UNUSED(options);
721 1.1 christos UNUSED(now);
722 1.1 christos UNUSED(nodep);
723 1.1 christos UNUSED(foundname);
724 1.3 christos UNUSED(dcname);
725 1.1 christos UNUSED(rdataset);
726 1.1 christos UNUSED(sigrdataset);
727 1.1 christos
728 1.1 christos return (ISC_R_NOTIMPLEMENTED);
729 1.1 christos }
730 1.1 christos
731 1.1 christos static void
732 1.1 christos attachnode(dns_db_t *db, dns_dbnode_t *source, dns_dbnode_t **targetp) {
733 1.1 christos dns_sdlz_db_t *sdlz = (dns_sdlz_db_t *)db;
734 1.1 christos dns_sdlznode_t *node = (dns_sdlznode_t *)source;
735 1.1 christos
736 1.1 christos REQUIRE(VALID_SDLZDB(sdlz));
737 1.1 christos
738 1.1 christos UNUSED(sdlz);
739 1.1 christos
740 1.1 christos LOCK(&node->lock);
741 1.1 christos INSIST(node->references > 0);
742 1.1 christos node->references++;
743 1.1 christos INSIST(node->references != 0); /* Catch overflow. */
744 1.1 christos UNLOCK(&node->lock);
745 1.1 christos
746 1.1 christos *targetp = source;
747 1.1 christos }
748 1.1 christos
749 1.1 christos static void
750 1.1 christos detachnode(dns_db_t *db, dns_dbnode_t **targetp) {
751 1.1 christos dns_sdlz_db_t *sdlz = (dns_sdlz_db_t *)db;
752 1.1 christos dns_sdlznode_t *node;
753 1.3 christos bool need_destroy = false;
754 1.1 christos
755 1.1 christos REQUIRE(VALID_SDLZDB(sdlz));
756 1.1 christos REQUIRE(targetp != NULL && *targetp != NULL);
757 1.1 christos
758 1.1 christos UNUSED(sdlz);
759 1.1 christos
760 1.1 christos node = (dns_sdlznode_t *)(*targetp);
761 1.1 christos
762 1.1 christos LOCK(&node->lock);
763 1.1 christos INSIST(node->references > 0);
764 1.1 christos node->references--;
765 1.1 christos if (node->references == 0)
766 1.3 christos need_destroy = true;
767 1.1 christos UNLOCK(&node->lock);
768 1.1 christos
769 1.1 christos if (need_destroy)
770 1.1 christos destroynode(node);
771 1.1 christos
772 1.1 christos *targetp = NULL;
773 1.1 christos }
774 1.1 christos
775 1.1 christos static isc_result_t
776 1.1 christos expirenode(dns_db_t *db, dns_dbnode_t *node, isc_stdtime_t now) {
777 1.1 christos UNUSED(db);
778 1.1 christos UNUSED(node);
779 1.1 christos UNUSED(now);
780 1.1 christos INSIST(0);
781 1.3 christos ISC_UNREACHABLE();
782 1.1 christos }
783 1.1 christos
784 1.1 christos static void
785 1.1 christos printnode(dns_db_t *db, dns_dbnode_t *node, FILE *out) {
786 1.1 christos UNUSED(db);
787 1.1 christos UNUSED(node);
788 1.1 christos UNUSED(out);
789 1.1 christos return;
790 1.1 christos }
791 1.1 christos
792 1.1 christos static isc_result_t
793 1.1 christos createiterator(dns_db_t *db, unsigned int options, dns_dbiterator_t **iteratorp)
794 1.1 christos {
795 1.1 christos dns_sdlz_db_t *sdlz = (dns_sdlz_db_t *)db;
796 1.1 christos sdlz_dbiterator_t *sdlziter;
797 1.1 christos isc_result_t result;
798 1.1 christos isc_buffer_t b;
799 1.1 christos char zonestr[DNS_NAME_MAXTEXT + 1];
800 1.1 christos
801 1.1 christos REQUIRE(VALID_SDLZDB(sdlz));
802 1.1 christos
803 1.1 christos if (sdlz->dlzimp->methods->allnodes == NULL)
804 1.1 christos return (ISC_R_NOTIMPLEMENTED);
805 1.1 christos
806 1.1 christos if ((options & DNS_DB_NSEC3ONLY) != 0 ||
807 1.1 christos (options & DNS_DB_NONSEC3) != 0)
808 1.1 christos return (ISC_R_NOTIMPLEMENTED);
809 1.1 christos
810 1.1 christos isc_buffer_init(&b, zonestr, sizeof(zonestr));
811 1.3 christos result = dns_name_totext(&sdlz->common.origin, true, &b);
812 1.1 christos if (result != ISC_R_SUCCESS)
813 1.1 christos return (result);
814 1.1 christos isc_buffer_putuint8(&b, 0);
815 1.1 christos
816 1.1 christos sdlziter = isc_mem_get(sdlz->common.mctx, sizeof(sdlz_dbiterator_t));
817 1.1 christos if (sdlziter == NULL)
818 1.1 christos return (ISC_R_NOMEMORY);
819 1.1 christos
820 1.1 christos sdlziter->common.methods = &dbiterator_methods;
821 1.1 christos sdlziter->common.db = NULL;
822 1.1 christos dns_db_attach(db, &sdlziter->common.db);
823 1.3 christos sdlziter->common.relative_names =
824 1.3 christos ((options & DNS_DB_RELATIVENAMES) != 0);
825 1.1 christos sdlziter->common.magic = DNS_DBITERATOR_MAGIC;
826 1.1 christos ISC_LIST_INIT(sdlziter->nodelist);
827 1.1 christos sdlziter->current = NULL;
828 1.1 christos sdlziter->origin = NULL;
829 1.1 christos
830 1.1 christos /* make sure strings are always lowercase */
831 1.1 christos dns_sdlz_tolower(zonestr);
832 1.1 christos
833 1.1 christos MAYBE_LOCK(sdlz->dlzimp);
834 1.1 christos result = sdlz->dlzimp->methods->allnodes(zonestr,
835 1.1 christos sdlz->dlzimp->driverarg,
836 1.1 christos sdlz->dbdata, sdlziter);
837 1.1 christos MAYBE_UNLOCK(sdlz->dlzimp);
838 1.1 christos if (result != ISC_R_SUCCESS) {
839 1.1 christos dns_dbiterator_t *iter = &sdlziter->common;
840 1.1 christos dbiterator_destroy(&iter);
841 1.1 christos return (result);
842 1.1 christos }
843 1.1 christos
844 1.1 christos if (sdlziter->origin != NULL) {
845 1.1 christos ISC_LIST_UNLINK(sdlziter->nodelist, sdlziter->origin, link);
846 1.1 christos ISC_LIST_PREPEND(sdlziter->nodelist, sdlziter->origin, link);
847 1.1 christos }
848 1.1 christos
849 1.1 christos *iteratorp = (dns_dbiterator_t *)sdlziter;
850 1.1 christos
851 1.1 christos return (ISC_R_SUCCESS);
852 1.1 christos }
853 1.1 christos
854 1.1 christos static isc_result_t
855 1.1 christos findrdataset(dns_db_t *db, dns_dbnode_t *node, dns_dbversion_t *version,
856 1.1 christos dns_rdatatype_t type, dns_rdatatype_t covers,
857 1.1 christos isc_stdtime_t now, dns_rdataset_t *rdataset,
858 1.1 christos dns_rdataset_t *sigrdataset)
859 1.1 christos {
860 1.1 christos dns_rdatalist_t *list;
861 1.1 christos dns_sdlznode_t *sdlznode = (dns_sdlznode_t *)node;
862 1.1 christos
863 1.1 christos REQUIRE(VALID_SDLZNODE(node));
864 1.1 christos
865 1.1 christos UNUSED(db);
866 1.1 christos UNUSED(version);
867 1.1 christos UNUSED(covers);
868 1.1 christos UNUSED(now);
869 1.1 christos UNUSED(sigrdataset);
870 1.1 christos
871 1.1 christos if (type == dns_rdatatype_sig || type == dns_rdatatype_rrsig)
872 1.1 christos return (ISC_R_NOTIMPLEMENTED);
873 1.1 christos
874 1.1 christos list = ISC_LIST_HEAD(sdlznode->lists);
875 1.1 christos while (list != NULL) {
876 1.1 christos if (list->type == type)
877 1.1 christos break;
878 1.1 christos list = ISC_LIST_NEXT(list, link);
879 1.1 christos }
880 1.1 christos if (list == NULL)
881 1.1 christos return (ISC_R_NOTFOUND);
882 1.1 christos
883 1.1 christos list_tordataset(list, db, node, rdataset);
884 1.1 christos
885 1.1 christos return (ISC_R_SUCCESS);
886 1.1 christos }
887 1.1 christos
888 1.1 christos static isc_result_t
889 1.1 christos findext(dns_db_t *db, const dns_name_t *name, dns_dbversion_t *version,
890 1.1 christos dns_rdatatype_t type, unsigned int options, isc_stdtime_t now,
891 1.1 christos dns_dbnode_t **nodep, dns_name_t *foundname,
892 1.1 christos dns_clientinfomethods_t *methods, dns_clientinfo_t *clientinfo,
893 1.1 christos dns_rdataset_t *rdataset, dns_rdataset_t *sigrdataset)
894 1.1 christos {
895 1.1 christos dns_sdlz_db_t *sdlz = (dns_sdlz_db_t *)db;
896 1.1 christos dns_dbnode_t *node = NULL;
897 1.1 christos dns_fixedname_t fname;
898 1.1 christos dns_rdataset_t xrdataset;
899 1.1 christos dns_name_t *xname;
900 1.1 christos unsigned int nlabels, olabels;
901 1.1 christos isc_result_t result;
902 1.1 christos unsigned int i;
903 1.1 christos
904 1.1 christos REQUIRE(VALID_SDLZDB(sdlz));
905 1.1 christos REQUIRE(nodep == NULL || *nodep == NULL);
906 1.1 christos REQUIRE(version == NULL ||
907 1.1 christos version == (void*)&sdlz->dummy_version ||
908 1.1 christos version == sdlz->future_version);
909 1.1 christos
910 1.1 christos UNUSED(sdlz);
911 1.1 christos
912 1.1 christos if (!dns_name_issubdomain(name, &db->origin))
913 1.1 christos return (DNS_R_NXDOMAIN);
914 1.1 christos
915 1.1 christos olabels = dns_name_countlabels(&db->origin);
916 1.1 christos nlabels = dns_name_countlabels(name);
917 1.1 christos
918 1.1 christos xname = dns_fixedname_initname(&fname);
919 1.1 christos
920 1.1 christos if (rdataset == NULL) {
921 1.1 christos dns_rdataset_init(&xrdataset);
922 1.1 christos rdataset = &xrdataset;
923 1.1 christos }
924 1.1 christos
925 1.1 christos result = DNS_R_NXDOMAIN;
926 1.1 christos
927 1.1 christos /*
928 1.1 christos * If we're not walking down searching for zone
929 1.1 christos * cuts, we can cut straight to the chase
930 1.1 christos */
931 1.1 christos if ((options & DNS_DBFIND_NOZONECUT) != 0) {
932 1.1 christos i = nlabels;
933 1.1 christos goto search;
934 1.1 christos }
935 1.1 christos
936 1.1 christos for (i = olabels; i <= nlabels; i++) {
937 1.1 christos search:
938 1.1 christos /*
939 1.1 christos * Look up the next label.
940 1.1 christos */
941 1.1 christos dns_name_getlabelsequence(name, nlabels - i, i, xname);
942 1.3 christos result = getnodedata(db, xname, false, options,
943 1.1 christos methods, clientinfo, &node);
944 1.1 christos if (result == ISC_R_NOTFOUND) {
945 1.1 christos result = DNS_R_NXDOMAIN;
946 1.1 christos continue;
947 1.1 christos } else if (result != ISC_R_SUCCESS)
948 1.1 christos break;
949 1.1 christos
950 1.1 christos /*
951 1.1 christos * Look for a DNAME at the current label, unless this is
952 1.1 christos * the qname.
953 1.1 christos */
954 1.1 christos if (i < nlabels) {
955 1.1 christos result = findrdataset(db, node, version,
956 1.1 christos dns_rdatatype_dname, 0, now,
957 1.1 christos rdataset, sigrdataset);
958 1.1 christos if (result == ISC_R_SUCCESS) {
959 1.1 christos result = DNS_R_DNAME;
960 1.1 christos break;
961 1.1 christos }
962 1.1 christos }
963 1.1 christos
964 1.1 christos /*
965 1.1 christos * Look for an NS at the current label, unless this is the
966 1.1 christos * origin, glue is ok, or there are known to be no zone cuts.
967 1.1 christos */
968 1.1 christos if (i != olabels && (options & DNS_DBFIND_GLUEOK) == 0 &&
969 1.1 christos (options & DNS_DBFIND_NOZONECUT) == 0)
970 1.1 christos {
971 1.1 christos result = findrdataset(db, node, version,
972 1.1 christos dns_rdatatype_ns, 0, now,
973 1.1 christos rdataset, sigrdataset);
974 1.1 christos
975 1.1 christos if (result == ISC_R_SUCCESS &&
976 1.1 christos i == nlabels && type == dns_rdatatype_any)
977 1.1 christos {
978 1.1 christos result = DNS_R_ZONECUT;
979 1.1 christos dns_rdataset_disassociate(rdataset);
980 1.1 christos if (sigrdataset != NULL &&
981 1.1 christos dns_rdataset_isassociated(sigrdataset))
982 1.1 christos dns_rdataset_disassociate(sigrdataset);
983 1.1 christos break;
984 1.1 christos } else if (result == ISC_R_SUCCESS) {
985 1.1 christos result = DNS_R_DELEGATION;
986 1.1 christos break;
987 1.1 christos }
988 1.1 christos }
989 1.1 christos
990 1.1 christos /*
991 1.1 christos * If the current name is not the qname, add another label
992 1.1 christos * and try again.
993 1.1 christos */
994 1.1 christos if (i < nlabels) {
995 1.1 christos destroynode(node);
996 1.1 christos node = NULL;
997 1.1 christos continue;
998 1.1 christos }
999 1.1 christos
1000 1.1 christos /*
1001 1.1 christos * If we're looking for ANY, we're done.
1002 1.1 christos */
1003 1.1 christos if (type == dns_rdatatype_any) {
1004 1.1 christos result = ISC_R_SUCCESS;
1005 1.1 christos break;
1006 1.1 christos }
1007 1.1 christos
1008 1.1 christos /*
1009 1.1 christos * Look for the qtype.
1010 1.1 christos */
1011 1.1 christos result = findrdataset(db, node, version, type, 0, now,
1012 1.1 christos rdataset, sigrdataset);
1013 1.1 christos if (result == ISC_R_SUCCESS)
1014 1.1 christos break;
1015 1.1 christos
1016 1.1 christos /*
1017 1.1 christos * Look for a CNAME
1018 1.1 christos */
1019 1.1 christos if (type != dns_rdatatype_cname) {
1020 1.1 christos result = findrdataset(db, node, version,
1021 1.1 christos dns_rdatatype_cname, 0, now,
1022 1.1 christos rdataset, sigrdataset);
1023 1.1 christos if (result == ISC_R_SUCCESS) {
1024 1.1 christos result = DNS_R_CNAME;
1025 1.1 christos break;
1026 1.1 christos }
1027 1.1 christos }
1028 1.1 christos
1029 1.1 christos result = DNS_R_NXRRSET;
1030 1.1 christos break;
1031 1.1 christos }
1032 1.1 christos
1033 1.1 christos if (rdataset == &xrdataset && dns_rdataset_isassociated(rdataset))
1034 1.1 christos dns_rdataset_disassociate(rdataset);
1035 1.1 christos
1036 1.1 christos if (foundname != NULL) {
1037 1.1 christos isc_result_t xresult;
1038 1.1 christos
1039 1.1 christos xresult = dns_name_copy(xname, foundname, NULL);
1040 1.1 christos if (xresult != ISC_R_SUCCESS) {
1041 1.1 christos if (node != NULL)
1042 1.1 christos destroynode(node);
1043 1.1 christos if (dns_rdataset_isassociated(rdataset))
1044 1.1 christos dns_rdataset_disassociate(rdataset);
1045 1.1 christos return (DNS_R_BADDB);
1046 1.1 christos }
1047 1.1 christos }
1048 1.1 christos
1049 1.1 christos if (nodep != NULL)
1050 1.1 christos *nodep = node;
1051 1.1 christos else if (node != NULL)
1052 1.1 christos detachnode(db, &node);
1053 1.1 christos
1054 1.1 christos return (result);
1055 1.1 christos }
1056 1.1 christos
1057 1.1 christos static isc_result_t
1058 1.1 christos find(dns_db_t *db, const dns_name_t *name, dns_dbversion_t *version,
1059 1.1 christos dns_rdatatype_t type, unsigned int options, isc_stdtime_t now,
1060 1.1 christos dns_dbnode_t **nodep, dns_name_t *foundname,
1061 1.1 christos dns_rdataset_t *rdataset, dns_rdataset_t *sigrdataset)
1062 1.1 christos {
1063 1.1 christos return (findext(db, name, version, type, options, now, nodep,
1064 1.1 christos foundname, NULL, NULL, rdataset, sigrdataset));
1065 1.1 christos }
1066 1.1 christos
1067 1.1 christos static isc_result_t
1068 1.1 christos allrdatasets(dns_db_t *db, dns_dbnode_t *node, dns_dbversion_t *version,
1069 1.1 christos isc_stdtime_t now, dns_rdatasetiter_t **iteratorp)
1070 1.1 christos {
1071 1.1 christos dns_sdlz_db_t *sdlz = (dns_sdlz_db_t *) db;
1072 1.1 christos sdlz_rdatasetiter_t *iterator;
1073 1.1 christos
1074 1.1 christos REQUIRE(VALID_SDLZDB(sdlz));
1075 1.1 christos
1076 1.1 christos REQUIRE(version == NULL ||
1077 1.1 christos version == (void*)&sdlz->dummy_version ||
1078 1.1 christos version == sdlz->future_version);
1079 1.1 christos
1080 1.1 christos UNUSED(version);
1081 1.1 christos UNUSED(now);
1082 1.1 christos
1083 1.1 christos iterator = isc_mem_get(db->mctx, sizeof(sdlz_rdatasetiter_t));
1084 1.1 christos if (iterator == NULL)
1085 1.1 christos return (ISC_R_NOMEMORY);
1086 1.1 christos
1087 1.1 christos iterator->common.magic = DNS_RDATASETITER_MAGIC;
1088 1.1 christos iterator->common.methods = &rdatasetiter_methods;
1089 1.1 christos iterator->common.db = db;
1090 1.1 christos iterator->common.node = NULL;
1091 1.1 christos attachnode(db, node, &iterator->common.node);
1092 1.1 christos iterator->common.version = version;
1093 1.1 christos iterator->common.now = now;
1094 1.1 christos
1095 1.1 christos *iteratorp = (dns_rdatasetiter_t *)iterator;
1096 1.1 christos
1097 1.1 christos return (ISC_R_SUCCESS);
1098 1.1 christos }
1099 1.1 christos
1100 1.1 christos static isc_result_t
1101 1.1 christos modrdataset(dns_db_t *db, dns_dbnode_t *node, dns_dbversion_t *version,
1102 1.1 christos dns_rdataset_t *rdataset, unsigned int options,
1103 1.1 christos dns_sdlzmodrdataset_t mod_function)
1104 1.1 christos {
1105 1.1 christos dns_sdlz_db_t *sdlz = (dns_sdlz_db_t *)db;
1106 1.1 christos dns_master_style_t *style = NULL;
1107 1.1 christos isc_result_t result;
1108 1.1 christos isc_buffer_t *buffer = NULL;
1109 1.1 christos isc_mem_t *mctx;
1110 1.1 christos dns_sdlznode_t *sdlznode;
1111 1.1 christos char *rdatastr = NULL;
1112 1.1 christos char name[DNS_NAME_MAXTEXT + 1];
1113 1.1 christos
1114 1.1 christos REQUIRE(VALID_SDLZDB(sdlz));
1115 1.1 christos
1116 1.1 christos if (mod_function == NULL)
1117 1.1 christos return (ISC_R_NOTIMPLEMENTED);
1118 1.1 christos
1119 1.1 christos sdlznode = (dns_sdlznode_t *)node;
1120 1.1 christos
1121 1.1 christos UNUSED(options);
1122 1.1 christos
1123 1.1 christos dns_name_format(sdlznode->name, name, sizeof(name));
1124 1.1 christos
1125 1.1 christos mctx = sdlz->common.mctx;
1126 1.1 christos
1127 1.1 christos result = isc_buffer_allocate(mctx, &buffer, 1024);
1128 1.1 christos if (result != ISC_R_SUCCESS)
1129 1.1 christos return (result);
1130 1.1 christos
1131 1.3 christos result = dns_master_stylecreate(&style, 0, 0, 0, 0, 0, 0, 1,
1132 1.3 christos 0xffffffff, mctx);
1133 1.1 christos if (result != ISC_R_SUCCESS)
1134 1.1 christos goto cleanup;
1135 1.1 christos
1136 1.1 christos result = dns_master_rdatasettotext(sdlznode->name, rdataset,
1137 1.1 christos style, buffer);
1138 1.1 christos if (result != ISC_R_SUCCESS)
1139 1.1 christos goto cleanup;
1140 1.1 christos
1141 1.1 christos if (isc_buffer_usedlength(buffer) < 1) {
1142 1.1 christos result = ISC_R_BADADDRESSFORM;
1143 1.1 christos goto cleanup;
1144 1.1 christos }
1145 1.1 christos
1146 1.1 christos rdatastr = isc_buffer_base(buffer);
1147 1.1 christos if (rdatastr == NULL) {
1148 1.1 christos result = ISC_R_NOMEMORY;
1149 1.1 christos goto cleanup;
1150 1.1 christos }
1151 1.1 christos rdatastr[isc_buffer_usedlength(buffer) - 1] = 0;
1152 1.1 christos
1153 1.1 christos MAYBE_LOCK(sdlz->dlzimp);
1154 1.1 christos result = mod_function(name, rdatastr, sdlz->dlzimp->driverarg,
1155 1.1 christos sdlz->dbdata, version);
1156 1.1 christos MAYBE_UNLOCK(sdlz->dlzimp);
1157 1.1 christos
1158 1.1 christos cleanup:
1159 1.1 christos isc_buffer_free(&buffer);
1160 1.1 christos if (style != NULL)
1161 1.1 christos dns_master_styledestroy(&style, mctx);
1162 1.1 christos
1163 1.1 christos return (result);
1164 1.1 christos }
1165 1.1 christos
1166 1.1 christos static isc_result_t
1167 1.1 christos addrdataset(dns_db_t *db, dns_dbnode_t *node, dns_dbversion_t *version,
1168 1.1 christos isc_stdtime_t now, dns_rdataset_t *rdataset, unsigned int options,
1169 1.1 christos dns_rdataset_t *addedrdataset)
1170 1.1 christos {
1171 1.1 christos dns_sdlz_db_t *sdlz = (dns_sdlz_db_t *)db;
1172 1.1 christos isc_result_t result;
1173 1.1 christos
1174 1.1 christos UNUSED(now);
1175 1.1 christos UNUSED(addedrdataset);
1176 1.1 christos REQUIRE(VALID_SDLZDB(sdlz));
1177 1.1 christos
1178 1.1 christos if (sdlz->dlzimp->methods->addrdataset == NULL)
1179 1.1 christos return (ISC_R_NOTIMPLEMENTED);
1180 1.1 christos
1181 1.1 christos result = modrdataset(db, node, version, rdataset, options,
1182 1.1 christos sdlz->dlzimp->methods->addrdataset);
1183 1.1 christos return (result);
1184 1.1 christos }
1185 1.1 christos
1186 1.1 christos
1187 1.1 christos static isc_result_t
1188 1.1 christos subtractrdataset(dns_db_t *db, dns_dbnode_t *node, dns_dbversion_t *version,
1189 1.1 christos dns_rdataset_t *rdataset, unsigned int options,
1190 1.1 christos dns_rdataset_t *newrdataset)
1191 1.1 christos {
1192 1.1 christos dns_sdlz_db_t *sdlz = (dns_sdlz_db_t *)db;
1193 1.1 christos isc_result_t result;
1194 1.1 christos
1195 1.1 christos UNUSED(newrdataset);
1196 1.1 christos REQUIRE(VALID_SDLZDB(sdlz));
1197 1.1 christos
1198 1.1 christos if (sdlz->dlzimp->methods->subtractrdataset == NULL) {
1199 1.1 christos return (ISC_R_NOTIMPLEMENTED);
1200 1.1 christos }
1201 1.1 christos
1202 1.1 christos result = modrdataset(db, node, version, rdataset, options,
1203 1.1 christos sdlz->dlzimp->methods->subtractrdataset);
1204 1.1 christos return (result);
1205 1.1 christos }
1206 1.1 christos
1207 1.1 christos static isc_result_t
1208 1.1 christos deleterdataset(dns_db_t *db, dns_dbnode_t *node, dns_dbversion_t *version,
1209 1.1 christos dns_rdatatype_t type, dns_rdatatype_t covers)
1210 1.1 christos {
1211 1.1 christos dns_sdlz_db_t *sdlz = (dns_sdlz_db_t *)db;
1212 1.1 christos char name[DNS_NAME_MAXTEXT + 1];
1213 1.1 christos char b_type[DNS_RDATATYPE_FORMATSIZE];
1214 1.1 christos dns_sdlznode_t *sdlznode;
1215 1.1 christos isc_result_t result;
1216 1.1 christos
1217 1.1 christos UNUSED(covers);
1218 1.1 christos
1219 1.1 christos REQUIRE(VALID_SDLZDB(sdlz));
1220 1.1 christos
1221 1.1 christos if (sdlz->dlzimp->methods->delrdataset == NULL)
1222 1.1 christos return (ISC_R_NOTIMPLEMENTED);
1223 1.1 christos
1224 1.1 christos sdlznode = (dns_sdlznode_t *)node;
1225 1.1 christos dns_name_format(sdlznode->name, name, sizeof(name));
1226 1.1 christos dns_rdatatype_format(type, b_type, sizeof(b_type));
1227 1.1 christos
1228 1.1 christos MAYBE_LOCK(sdlz->dlzimp);
1229 1.1 christos result = sdlz->dlzimp->methods->delrdataset(name, b_type,
1230 1.1 christos sdlz->dlzimp->driverarg,
1231 1.1 christos sdlz->dbdata, version);
1232 1.1 christos MAYBE_UNLOCK(sdlz->dlzimp);
1233 1.1 christos
1234 1.1 christos return (result);
1235 1.1 christos }
1236 1.1 christos
1237 1.3 christos static bool
1238 1.1 christos issecure(dns_db_t *db) {
1239 1.1 christos UNUSED(db);
1240 1.1 christos
1241 1.3 christos return (false);
1242 1.1 christos }
1243 1.1 christos
1244 1.1 christos static unsigned int
1245 1.1 christos nodecount(dns_db_t *db) {
1246 1.1 christos UNUSED(db);
1247 1.1 christos
1248 1.1 christos return (0);
1249 1.1 christos }
1250 1.1 christos
1251 1.3 christos static bool
1252 1.1 christos ispersistent(dns_db_t *db) {
1253 1.1 christos UNUSED(db);
1254 1.3 christos return (true);
1255 1.1 christos }
1256 1.1 christos
1257 1.1 christos static void
1258 1.3 christos overmem(dns_db_t *db, bool over) {
1259 1.1 christos UNUSED(db);
1260 1.1 christos UNUSED(over);
1261 1.1 christos }
1262 1.1 christos
1263 1.1 christos static void
1264 1.1 christos settask(dns_db_t *db, isc_task_t *task) {
1265 1.1 christos UNUSED(db);
1266 1.1 christos UNUSED(task);
1267 1.1 christos }
1268 1.1 christos
1269 1.1 christos /*
1270 1.1 christos * getoriginnode() is used by the update code to find the
1271 1.1 christos * dns_rdatatype_dnskey record for a zone
1272 1.1 christos */
1273 1.1 christos static isc_result_t
1274 1.1 christos getoriginnode(dns_db_t *db, dns_dbnode_t **nodep) {
1275 1.1 christos dns_sdlz_db_t *sdlz = (dns_sdlz_db_t *)db;
1276 1.1 christos isc_result_t result;
1277 1.1 christos
1278 1.1 christos REQUIRE(VALID_SDLZDB(sdlz));
1279 1.1 christos if (sdlz->dlzimp->methods->newversion == NULL)
1280 1.1 christos return (ISC_R_NOTIMPLEMENTED);
1281 1.1 christos
1282 1.3 christos result = getnodedata(db, &sdlz->common.origin, false,
1283 1.1 christos 0, NULL, NULL, nodep);
1284 1.1 christos if (result != ISC_R_SUCCESS)
1285 1.1 christos sdlz_log(ISC_LOG_ERROR, "sdlz getoriginnode failed: %s",
1286 1.1 christos isc_result_totext(result));
1287 1.1 christos return (result);
1288 1.1 christos }
1289 1.1 christos
1290 1.1 christos static dns_dbmethods_t sdlzdb_methods = {
1291 1.1 christos attach,
1292 1.1 christos detach,
1293 1.1 christos beginload,
1294 1.1 christos endload,
1295 1.1 christos NULL, /* serialize */
1296 1.1 christos dump,
1297 1.1 christos currentversion,
1298 1.1 christos newversion,
1299 1.1 christos attachversion,
1300 1.1 christos closeversion,
1301 1.1 christos findnode,
1302 1.1 christos find,
1303 1.1 christos findzonecut,
1304 1.1 christos attachnode,
1305 1.1 christos detachnode,
1306 1.1 christos expirenode,
1307 1.1 christos printnode,
1308 1.1 christos createiterator,
1309 1.1 christos findrdataset,
1310 1.1 christos allrdatasets,
1311 1.1 christos addrdataset,
1312 1.1 christos subtractrdataset,
1313 1.1 christos deleterdataset,
1314 1.1 christos issecure,
1315 1.1 christos nodecount,
1316 1.1 christos ispersistent,
1317 1.1 christos overmem,
1318 1.1 christos settask,
1319 1.1 christos getoriginnode,
1320 1.1 christos NULL, /* transfernode */
1321 1.1 christos NULL, /* getnsec3parameters */
1322 1.1 christos NULL, /* findnsec3node */
1323 1.1 christos NULL, /* setsigningtime */
1324 1.1 christos NULL, /* getsigningtime */
1325 1.1 christos NULL, /* resigned */
1326 1.1 christos NULL, /* isdnssec */
1327 1.1 christos NULL, /* getrrsetstats */
1328 1.1 christos NULL, /* rpz_attach */
1329 1.1 christos NULL, /* rpz_ready */
1330 1.1 christos findnodeext,
1331 1.1 christos findext,
1332 1.1 christos NULL, /* setcachestats */
1333 1.1 christos NULL, /* hashsize */
1334 1.1 christos NULL, /* nodefullname */
1335 1.1 christos NULL, /* getsize */
1336 1.1 christos NULL, /* setservestalettl */
1337 1.1 christos NULL, /* getservestalettl */
1338 1.1 christos NULL /* setgluecachestats */
1339 1.1 christos };
1340 1.1 christos
1341 1.1 christos /*
1342 1.1 christos * Database Iterator Methods. These methods were "borrowed" from the SDB
1343 1.1 christos * driver interface. See the SDB driver interface documentation for more info.
1344 1.1 christos */
1345 1.1 christos
1346 1.1 christos static void
1347 1.1 christos dbiterator_destroy(dns_dbiterator_t **iteratorp) {
1348 1.1 christos sdlz_dbiterator_t *sdlziter = (sdlz_dbiterator_t *)(*iteratorp);
1349 1.1 christos dns_sdlz_db_t *sdlz = (dns_sdlz_db_t *)sdlziter->common.db;
1350 1.1 christos
1351 1.1 christos while (!ISC_LIST_EMPTY(sdlziter->nodelist)) {
1352 1.1 christos dns_sdlznode_t *node;
1353 1.1 christos node = ISC_LIST_HEAD(sdlziter->nodelist);
1354 1.1 christos ISC_LIST_UNLINK(sdlziter->nodelist, node, link);
1355 1.1 christos destroynode(node);
1356 1.1 christos }
1357 1.1 christos
1358 1.1 christos dns_db_detach(&sdlziter->common.db);
1359 1.1 christos isc_mem_put(sdlz->common.mctx, sdlziter, sizeof(sdlz_dbiterator_t));
1360 1.1 christos
1361 1.1 christos *iteratorp = NULL;
1362 1.1 christos }
1363 1.1 christos
1364 1.1 christos static isc_result_t
1365 1.1 christos dbiterator_first(dns_dbiterator_t *iterator) {
1366 1.1 christos sdlz_dbiterator_t *sdlziter = (sdlz_dbiterator_t *)iterator;
1367 1.1 christos
1368 1.1 christos sdlziter->current = ISC_LIST_HEAD(sdlziter->nodelist);
1369 1.1 christos if (sdlziter->current == NULL)
1370 1.1 christos return (ISC_R_NOMORE);
1371 1.1 christos else
1372 1.1 christos return (ISC_R_SUCCESS);
1373 1.1 christos }
1374 1.1 christos
1375 1.1 christos static isc_result_t
1376 1.1 christos dbiterator_last(dns_dbiterator_t *iterator) {
1377 1.1 christos sdlz_dbiterator_t *sdlziter = (sdlz_dbiterator_t *)iterator;
1378 1.1 christos
1379 1.1 christos sdlziter->current = ISC_LIST_TAIL(sdlziter->nodelist);
1380 1.1 christos if (sdlziter->current == NULL)
1381 1.1 christos return (ISC_R_NOMORE);
1382 1.1 christos else
1383 1.1 christos return (ISC_R_SUCCESS);
1384 1.1 christos }
1385 1.1 christos
1386 1.1 christos static isc_result_t
1387 1.1 christos dbiterator_seek(dns_dbiterator_t *iterator, const dns_name_t *name) {
1388 1.1 christos sdlz_dbiterator_t *sdlziter = (sdlz_dbiterator_t *)iterator;
1389 1.1 christos
1390 1.1 christos sdlziter->current = ISC_LIST_HEAD(sdlziter->nodelist);
1391 1.1 christos while (sdlziter->current != NULL) {
1392 1.1 christos if (dns_name_equal(sdlziter->current->name, name))
1393 1.1 christos return (ISC_R_SUCCESS);
1394 1.1 christos sdlziter->current = ISC_LIST_NEXT(sdlziter->current, link);
1395 1.1 christos }
1396 1.1 christos return (ISC_R_NOTFOUND);
1397 1.1 christos }
1398 1.1 christos
1399 1.1 christos static isc_result_t
1400 1.1 christos dbiterator_prev(dns_dbiterator_t *iterator) {
1401 1.1 christos sdlz_dbiterator_t *sdlziter = (sdlz_dbiterator_t *)iterator;
1402 1.1 christos
1403 1.1 christos sdlziter->current = ISC_LIST_PREV(sdlziter->current, link);
1404 1.1 christos if (sdlziter->current == NULL)
1405 1.1 christos return (ISC_R_NOMORE);
1406 1.1 christos else
1407 1.1 christos return (ISC_R_SUCCESS);
1408 1.1 christos }
1409 1.1 christos
1410 1.1 christos static isc_result_t
1411 1.1 christos dbiterator_next(dns_dbiterator_t *iterator) {
1412 1.1 christos sdlz_dbiterator_t *sdlziter = (sdlz_dbiterator_t *)iterator;
1413 1.1 christos
1414 1.1 christos sdlziter->current = ISC_LIST_NEXT(sdlziter->current, link);
1415 1.1 christos if (sdlziter->current == NULL)
1416 1.1 christos return (ISC_R_NOMORE);
1417 1.1 christos else
1418 1.1 christos return (ISC_R_SUCCESS);
1419 1.1 christos }
1420 1.1 christos
1421 1.1 christos static isc_result_t
1422 1.1 christos dbiterator_current(dns_dbiterator_t *iterator, dns_dbnode_t **nodep,
1423 1.1 christos dns_name_t *name)
1424 1.1 christos {
1425 1.1 christos sdlz_dbiterator_t *sdlziter = (sdlz_dbiterator_t *)iterator;
1426 1.1 christos
1427 1.1 christos attachnode(iterator->db, sdlziter->current, nodep);
1428 1.1 christos if (name != NULL)
1429 1.1 christos return (dns_name_copy(sdlziter->current->name, name, NULL));
1430 1.1 christos return (ISC_R_SUCCESS);
1431 1.1 christos }
1432 1.1 christos
1433 1.1 christos static isc_result_t
1434 1.1 christos dbiterator_pause(dns_dbiterator_t *iterator) {
1435 1.1 christos UNUSED(iterator);
1436 1.1 christos return (ISC_R_SUCCESS);
1437 1.1 christos }
1438 1.1 christos
1439 1.1 christos static isc_result_t
1440 1.1 christos dbiterator_origin(dns_dbiterator_t *iterator, dns_name_t *name) {
1441 1.1 christos UNUSED(iterator);
1442 1.1 christos return (dns_name_copy(dns_rootname, name, NULL));
1443 1.1 christos }
1444 1.1 christos
1445 1.1 christos /*
1446 1.1 christos * Rdataset Methods. These methods were "borrowed" from the SDB driver
1447 1.1 christos * interface. See the SDB driver interface documentation for more info.
1448 1.1 christos */
1449 1.1 christos
1450 1.1 christos static void
1451 1.1 christos disassociate(dns_rdataset_t *rdataset) {
1452 1.1 christos dns_dbnode_t *node = rdataset->private5;
1453 1.1 christos dns_sdlznode_t *sdlznode = (dns_sdlznode_t *) node;
1454 1.1 christos dns_db_t *db = (dns_db_t *) sdlznode->sdlz;
1455 1.1 christos
1456 1.1 christos detachnode(db, &node);
1457 1.1 christos isc__rdatalist_disassociate(rdataset);
1458 1.1 christos }
1459 1.1 christos
1460 1.1 christos static void
1461 1.1 christos rdataset_clone(dns_rdataset_t *source, dns_rdataset_t *target) {
1462 1.1 christos dns_dbnode_t *node = source->private5;
1463 1.1 christos dns_sdlznode_t *sdlznode = (dns_sdlznode_t *) node;
1464 1.1 christos dns_db_t *db = (dns_db_t *) sdlznode->sdlz;
1465 1.1 christos dns_dbnode_t *tempdb = NULL;
1466 1.1 christos
1467 1.1 christos isc__rdatalist_clone(source, target);
1468 1.1 christos attachnode(db, node, &tempdb);
1469 1.1 christos source->private5 = tempdb;
1470 1.1 christos }
1471 1.1 christos
1472 1.1 christos static dns_rdatasetmethods_t rdataset_methods = {
1473 1.1 christos disassociate,
1474 1.1 christos isc__rdatalist_first,
1475 1.1 christos isc__rdatalist_next,
1476 1.1 christos isc__rdatalist_current,
1477 1.1 christos rdataset_clone,
1478 1.1 christos isc__rdatalist_count,
1479 1.1 christos isc__rdatalist_addnoqname,
1480 1.1 christos isc__rdatalist_getnoqname,
1481 1.1 christos NULL, /* addclosest */
1482 1.1 christos NULL, /* getclosest */
1483 1.1 christos NULL, /* settrust */
1484 1.1 christos NULL, /* expire */
1485 1.1 christos NULL, /* clearprefetch */
1486 1.1 christos NULL, /* setownercase */
1487 1.1 christos NULL, /* getownercase */
1488 1.1 christos NULL /* addglue */
1489 1.1 christos };
1490 1.1 christos
1491 1.1 christos static void
1492 1.1 christos list_tordataset(dns_rdatalist_t *rdatalist,
1493 1.1 christos dns_db_t *db, dns_dbnode_t *node,
1494 1.1 christos dns_rdataset_t *rdataset)
1495 1.1 christos {
1496 1.1 christos /*
1497 1.1 christos * The sdlz rdataset is an rdatalist with some additions.
1498 1.1 christos * - private1 & private2 are used by the rdatalist.
1499 1.1 christos * - private3 & private 4 are unused.
1500 1.1 christos * - private5 is the node.
1501 1.1 christos */
1502 1.1 christos
1503 1.1 christos /* This should never fail. */
1504 1.1 christos RUNTIME_CHECK(dns_rdatalist_tordataset(rdatalist, rdataset) ==
1505 1.1 christos ISC_R_SUCCESS);
1506 1.1 christos
1507 1.1 christos rdataset->methods = &rdataset_methods;
1508 1.1 christos dns_db_attachnode(db, node, &rdataset->private5);
1509 1.1 christos }
1510 1.1 christos
1511 1.1 christos /*
1512 1.1 christos * SDLZ core methods. This is the core of the new DLZ functionality.
1513 1.1 christos */
1514 1.1 christos
1515 1.1 christos /*%
1516 1.1 christos * Build a 'bind' database driver structure to be returned by
1517 1.1 christos * either the find zone or the allow zone transfer method.
1518 1.1 christos * This method is only available in this source file, it is
1519 1.1 christos * not made available anywhere else.
1520 1.1 christos */
1521 1.1 christos
1522 1.1 christos static isc_result_t
1523 1.1 christos dns_sdlzcreateDBP(isc_mem_t *mctx, void *driverarg, void *dbdata,
1524 1.1 christos const dns_name_t *name, dns_rdataclass_t rdclass,
1525 1.1 christos dns_db_t **dbp)
1526 1.1 christos {
1527 1.1 christos isc_result_t result;
1528 1.1 christos dns_sdlz_db_t *sdlzdb;
1529 1.1 christos dns_sdlzimplementation_t *imp;
1530 1.1 christos
1531 1.1 christos /* check that things are as we expect */
1532 1.1 christos REQUIRE(dbp != NULL && *dbp == NULL);
1533 1.1 christos REQUIRE(name != NULL);
1534 1.1 christos
1535 1.1 christos imp = (dns_sdlzimplementation_t *) driverarg;
1536 1.1 christos
1537 1.1 christos /* allocate and zero memory for driver structure */
1538 1.1 christos sdlzdb = isc_mem_get(mctx, sizeof(dns_sdlz_db_t));
1539 1.1 christos if (sdlzdb == NULL)
1540 1.1 christos return (ISC_R_NOMEMORY);
1541 1.1 christos memset(sdlzdb, 0, sizeof(dns_sdlz_db_t));
1542 1.1 christos
1543 1.1 christos /* initialize and set origin */
1544 1.1 christos dns_name_init(&sdlzdb->common.origin, NULL);
1545 1.1 christos result = dns_name_dupwithoffsets(name, mctx, &sdlzdb->common.origin);
1546 1.1 christos if (result != ISC_R_SUCCESS)
1547 1.1 christos goto mem_cleanup;
1548 1.1 christos
1549 1.1 christos /* initialize the reference count mutex */
1550 1.3 christos isc_mutex_init(&sdlzdb->refcnt_lock);
1551 1.1 christos
1552 1.1 christos /* set the rest of the database structure attributes */
1553 1.1 christos sdlzdb->dlzimp = imp;
1554 1.1 christos sdlzdb->common.methods = &sdlzdb_methods;
1555 1.1 christos sdlzdb->common.attributes = 0;
1556 1.1 christos sdlzdb->common.rdclass = rdclass;
1557 1.1 christos sdlzdb->common.mctx = NULL;
1558 1.1 christos sdlzdb->dbdata = dbdata;
1559 1.1 christos sdlzdb->references = 1;
1560 1.1 christos
1561 1.1 christos /* attach to the memory context */
1562 1.1 christos isc_mem_attach(mctx, &sdlzdb->common.mctx);
1563 1.1 christos
1564 1.1 christos /* mark structure as valid */
1565 1.1 christos sdlzdb->common.magic = DNS_DB_MAGIC;
1566 1.1 christos sdlzdb->common.impmagic = SDLZDB_MAGIC;
1567 1.1 christos *dbp = (dns_db_t *) sdlzdb;
1568 1.1 christos
1569 1.1 christos return (result);
1570 1.1 christos mem_cleanup:
1571 1.1 christos isc_mem_put(mctx, sdlzdb, sizeof(dns_sdlz_db_t));
1572 1.1 christos return (result);
1573 1.1 christos }
1574 1.1 christos
1575 1.1 christos static isc_result_t
1576 1.1 christos dns_sdlzallowzonexfr(void *driverarg, void *dbdata, isc_mem_t *mctx,
1577 1.1 christos dns_rdataclass_t rdclass, const dns_name_t *name,
1578 1.1 christos const isc_sockaddr_t *clientaddr, dns_db_t **dbp)
1579 1.1 christos {
1580 1.1 christos isc_buffer_t b;
1581 1.1 christos isc_buffer_t b2;
1582 1.1 christos char namestr[DNS_NAME_MAXTEXT + 1];
1583 1.1 christos char clientstr[(sizeof "xxxx:xxxx:xxxx:xxxx:xxxx:xxxx:255.255.255.255")
1584 1.1 christos + 1];
1585 1.1 christos isc_netaddr_t netaddr;
1586 1.1 christos isc_result_t result;
1587 1.1 christos dns_sdlzimplementation_t *imp;
1588 1.1 christos
1589 1.1 christos /*
1590 1.1 christos * Perform checks to make sure data is as we expect it to be.
1591 1.1 christos */
1592 1.1 christos REQUIRE(driverarg != NULL);
1593 1.1 christos REQUIRE(name != NULL);
1594 1.1 christos REQUIRE(clientaddr != NULL);
1595 1.1 christos REQUIRE(dbp != NULL && *dbp == NULL);
1596 1.1 christos
1597 1.1 christos imp = (dns_sdlzimplementation_t *) driverarg;
1598 1.1 christos
1599 1.1 christos /* Convert DNS name to ascii text */
1600 1.1 christos isc_buffer_init(&b, namestr, sizeof(namestr));
1601 1.3 christos result = dns_name_totext(name, true, &b);
1602 1.1 christos if (result != ISC_R_SUCCESS)
1603 1.1 christos return (result);
1604 1.1 christos isc_buffer_putuint8(&b, 0);
1605 1.1 christos
1606 1.1 christos /* convert client address to ascii text */
1607 1.1 christos isc_buffer_init(&b2, clientstr, sizeof(clientstr));
1608 1.1 christos isc_netaddr_fromsockaddr(&netaddr, clientaddr);
1609 1.1 christos result = isc_netaddr_totext(&netaddr, &b2);
1610 1.1 christos if (result != ISC_R_SUCCESS)
1611 1.1 christos return (result);
1612 1.1 christos isc_buffer_putuint8(&b2, 0);
1613 1.1 christos
1614 1.1 christos /* make sure strings are always lowercase */
1615 1.1 christos dns_sdlz_tolower(namestr);
1616 1.1 christos dns_sdlz_tolower(clientstr);
1617 1.1 christos
1618 1.1 christos /* Call SDLZ driver's find zone method */
1619 1.1 christos if (imp->methods->allowzonexfr != NULL) {
1620 1.1 christos MAYBE_LOCK(imp);
1621 1.1 christos result = imp->methods->allowzonexfr(imp->driverarg, dbdata,
1622 1.1 christos namestr, clientstr);
1623 1.1 christos MAYBE_UNLOCK(imp);
1624 1.1 christos /*
1625 1.1 christos * if zone is supported and transfers allowed build a 'bind'
1626 1.1 christos * database driver
1627 1.1 christos */
1628 1.1 christos if (result == ISC_R_SUCCESS)
1629 1.1 christos result = dns_sdlzcreateDBP(mctx, driverarg, dbdata,
1630 1.1 christos name, rdclass, dbp);
1631 1.1 christos return (result);
1632 1.1 christos }
1633 1.1 christos
1634 1.1 christos return (ISC_R_NOTIMPLEMENTED);
1635 1.1 christos }
1636 1.1 christos
1637 1.1 christos static isc_result_t
1638 1.1 christos dns_sdlzcreate(isc_mem_t *mctx, const char *dlzname, unsigned int argc,
1639 1.1 christos char *argv[], void *driverarg, void **dbdata)
1640 1.1 christos {
1641 1.1 christos dns_sdlzimplementation_t *imp;
1642 1.1 christos isc_result_t result = ISC_R_NOTFOUND;
1643 1.1 christos
1644 1.1 christos /* Write debugging message to log */
1645 1.1 christos sdlz_log(ISC_LOG_DEBUG(2), "Loading SDLZ driver.");
1646 1.1 christos
1647 1.1 christos /*
1648 1.1 christos * Performs checks to make sure data is as we expect it to be.
1649 1.1 christos */
1650 1.1 christos REQUIRE(driverarg != NULL);
1651 1.1 christos REQUIRE(dlzname != NULL);
1652 1.1 christos REQUIRE(dbdata != NULL);
1653 1.1 christos UNUSED(mctx);
1654 1.1 christos
1655 1.1 christos imp = driverarg;
1656 1.1 christos
1657 1.1 christos /* If the create method exists, call it. */
1658 1.1 christos if (imp->methods->create != NULL) {
1659 1.1 christos MAYBE_LOCK(imp);
1660 1.1 christos result = imp->methods->create(dlzname, argc, argv,
1661 1.1 christos imp->driverarg, dbdata);
1662 1.1 christos MAYBE_UNLOCK(imp);
1663 1.1 christos }
1664 1.1 christos
1665 1.1 christos /* Write debugging message to log */
1666 1.1 christos if (result == ISC_R_SUCCESS) {
1667 1.1 christos sdlz_log(ISC_LOG_DEBUG(2), "SDLZ driver loaded successfully.");
1668 1.1 christos } else {
1669 1.1 christos sdlz_log(ISC_LOG_ERROR, "SDLZ driver failed to load.");
1670 1.1 christos }
1671 1.1 christos
1672 1.1 christos return (result);
1673 1.1 christos }
1674 1.1 christos
1675 1.1 christos static void
1676 1.1 christos dns_sdlzdestroy(void *driverdata, void **dbdata) {
1677 1.1 christos dns_sdlzimplementation_t *imp;
1678 1.1 christos
1679 1.1 christos /* Write debugging message to log */
1680 1.1 christos sdlz_log(ISC_LOG_DEBUG(2), "Unloading SDLZ driver.");
1681 1.1 christos
1682 1.1 christos imp = driverdata;
1683 1.1 christos
1684 1.1 christos /* If the destroy method exists, call it. */
1685 1.1 christos if (imp->methods->destroy != NULL) {
1686 1.1 christos MAYBE_LOCK(imp);
1687 1.1 christos imp->methods->destroy(imp->driverarg, dbdata);
1688 1.1 christos MAYBE_UNLOCK(imp);
1689 1.1 christos }
1690 1.1 christos }
1691 1.1 christos
1692 1.1 christos static isc_result_t
1693 1.1 christos dns_sdlzfindzone(void *driverarg, void *dbdata, isc_mem_t *mctx,
1694 1.1 christos dns_rdataclass_t rdclass, const dns_name_t *name,
1695 1.1 christos dns_clientinfomethods_t *methods,
1696 1.1 christos dns_clientinfo_t *clientinfo,
1697 1.1 christos dns_db_t **dbp)
1698 1.1 christos {
1699 1.1 christos isc_buffer_t b;
1700 1.1 christos char namestr[DNS_NAME_MAXTEXT + 1];
1701 1.1 christos isc_result_t result;
1702 1.1 christos dns_sdlzimplementation_t *imp;
1703 1.1 christos
1704 1.1 christos /*
1705 1.1 christos * Perform checks to make sure data is as we expect it to be.
1706 1.1 christos */
1707 1.1 christos REQUIRE(driverarg != NULL);
1708 1.1 christos REQUIRE(name != NULL);
1709 1.1 christos REQUIRE(dbp != NULL && *dbp == NULL);
1710 1.1 christos
1711 1.1 christos imp = (dns_sdlzimplementation_t *) driverarg;
1712 1.1 christos
1713 1.1 christos /* Convert DNS name to ascii text */
1714 1.1 christos isc_buffer_init(&b, namestr, sizeof(namestr));
1715 1.3 christos result = dns_name_totext(name, true, &b);
1716 1.1 christos if (result != ISC_R_SUCCESS)
1717 1.1 christos return (result);
1718 1.1 christos isc_buffer_putuint8(&b, 0);
1719 1.1 christos
1720 1.1 christos /* make sure strings are always lowercase */
1721 1.1 christos dns_sdlz_tolower(namestr);
1722 1.1 christos
1723 1.1 christos /* Call SDLZ driver's find zone method */
1724 1.1 christos MAYBE_LOCK(imp);
1725 1.1 christos result = imp->methods->findzone(imp->driverarg, dbdata, namestr,
1726 1.1 christos methods, clientinfo);
1727 1.1 christos MAYBE_UNLOCK(imp);
1728 1.1 christos
1729 1.1 christos /*
1730 1.1 christos * if zone is supported build a 'bind' database driver
1731 1.1 christos * structure to return
1732 1.1 christos */
1733 1.1 christos if (result == ISC_R_SUCCESS)
1734 1.1 christos result = dns_sdlzcreateDBP(mctx, driverarg, dbdata, name,
1735 1.1 christos rdclass, dbp);
1736 1.1 christos
1737 1.1 christos return (result);
1738 1.1 christos }
1739 1.1 christos
1740 1.1 christos
1741 1.1 christos static isc_result_t
1742 1.1 christos dns_sdlzconfigure(void *driverarg, void *dbdata,
1743 1.1 christos dns_view_t *view, dns_dlzdb_t *dlzdb)
1744 1.1 christos {
1745 1.1 christos isc_result_t result;
1746 1.1 christos dns_sdlzimplementation_t *imp;
1747 1.1 christos
1748 1.1 christos REQUIRE(driverarg != NULL);
1749 1.1 christos
1750 1.1 christos imp = (dns_sdlzimplementation_t *) driverarg;
1751 1.1 christos
1752 1.1 christos /* Call SDLZ driver's configure method */
1753 1.1 christos if (imp->methods->configure != NULL) {
1754 1.1 christos MAYBE_LOCK(imp);
1755 1.1 christos result = imp->methods->configure(view, dlzdb,
1756 1.1 christos imp->driverarg, dbdata);
1757 1.1 christos MAYBE_UNLOCK(imp);
1758 1.1 christos } else {
1759 1.1 christos result = ISC_R_SUCCESS;
1760 1.1 christos }
1761 1.1 christos
1762 1.1 christos return (result);
1763 1.1 christos }
1764 1.1 christos
1765 1.3 christos static bool
1766 1.1 christos dns_sdlzssumatch(const dns_name_t *signer, const dns_name_t *name,
1767 1.1 christos const isc_netaddr_t *tcpaddr, dns_rdatatype_t type,
1768 1.1 christos const dst_key_t *key, void *driverarg, void *dbdata)
1769 1.1 christos {
1770 1.1 christos dns_sdlzimplementation_t *imp;
1771 1.1 christos char b_signer[DNS_NAME_FORMATSIZE];
1772 1.1 christos char b_name[DNS_NAME_FORMATSIZE];
1773 1.1 christos char b_addr[ISC_NETADDR_FORMATSIZE];
1774 1.1 christos char b_type[DNS_RDATATYPE_FORMATSIZE];
1775 1.1 christos char b_key[DST_KEY_FORMATSIZE];
1776 1.1 christos isc_buffer_t *tkey_token = NULL;
1777 1.1 christos isc_region_t token_region = { NULL, 0 };
1778 1.3 christos uint32_t token_len = 0;
1779 1.3 christos bool ret;
1780 1.1 christos
1781 1.1 christos REQUIRE(driverarg != NULL);
1782 1.1 christos
1783 1.1 christos imp = (dns_sdlzimplementation_t *) driverarg;
1784 1.1 christos if (imp->methods->ssumatch == NULL)
1785 1.3 christos return (false);
1786 1.1 christos
1787 1.1 christos /*
1788 1.1 christos * Format the request elements. sdlz operates on strings, not
1789 1.1 christos * structures
1790 1.1 christos */
1791 1.1 christos if (signer != NULL)
1792 1.1 christos dns_name_format(signer, b_signer, sizeof(b_signer));
1793 1.1 christos else
1794 1.1 christos b_signer[0] = 0;
1795 1.1 christos
1796 1.1 christos dns_name_format(name, b_name, sizeof(b_name));
1797 1.1 christos
1798 1.1 christos if (tcpaddr != NULL)
1799 1.1 christos isc_netaddr_format(tcpaddr, b_addr, sizeof(b_addr));
1800 1.1 christos else
1801 1.1 christos b_addr[0] = 0;
1802 1.1 christos
1803 1.1 christos dns_rdatatype_format(type, b_type, sizeof(b_type));
1804 1.1 christos
1805 1.1 christos if (key != NULL) {
1806 1.1 christos dst_key_format(key, b_key, sizeof(b_key));
1807 1.1 christos tkey_token = dst_key_tkeytoken(key);
1808 1.1 christos } else
1809 1.1 christos b_key[0] = 0;
1810 1.1 christos
1811 1.1 christos if (tkey_token != NULL) {
1812 1.1 christos isc_buffer_region(tkey_token, &token_region);
1813 1.1 christos token_len = token_region.length;
1814 1.1 christos }
1815 1.1 christos
1816 1.1 christos MAYBE_LOCK(imp);
1817 1.1 christos ret = imp->methods->ssumatch(b_signer, b_name, b_addr, b_type, b_key,
1818 1.1 christos token_len,
1819 1.1 christos token_len != 0 ? token_region.base : NULL,
1820 1.1 christos imp->driverarg, dbdata);
1821 1.1 christos MAYBE_UNLOCK(imp);
1822 1.1 christos return (ret);
1823 1.1 christos }
1824 1.1 christos
1825 1.1 christos static dns_dlzmethods_t sdlzmethods = {
1826 1.1 christos dns_sdlzcreate,
1827 1.1 christos dns_sdlzdestroy,
1828 1.1 christos dns_sdlzfindzone,
1829 1.1 christos dns_sdlzallowzonexfr,
1830 1.1 christos dns_sdlzconfigure,
1831 1.1 christos dns_sdlzssumatch
1832 1.1 christos };
1833 1.1 christos
1834 1.1 christos /*
1835 1.1 christos * Public functions.
1836 1.1 christos */
1837 1.1 christos
1838 1.1 christos isc_result_t
1839 1.1 christos dns_sdlz_putrr(dns_sdlzlookup_t *lookup, const char *type, dns_ttl_t ttl,
1840 1.1 christos const char *data)
1841 1.1 christos {
1842 1.1 christos dns_rdatalist_t *rdatalist;
1843 1.1 christos dns_rdata_t *rdata;
1844 1.1 christos dns_rdatatype_t typeval;
1845 1.1 christos isc_consttextregion_t r;
1846 1.1 christos isc_buffer_t b;
1847 1.1 christos isc_buffer_t *rdatabuf = NULL;
1848 1.1 christos isc_lex_t *lex;
1849 1.1 christos isc_result_t result;
1850 1.1 christos unsigned int size;
1851 1.1 christos isc_mem_t *mctx;
1852 1.1 christos const dns_name_t *origin;
1853 1.1 christos
1854 1.1 christos REQUIRE(VALID_SDLZLOOKUP(lookup));
1855 1.1 christos REQUIRE(type != NULL);
1856 1.1 christos REQUIRE(data != NULL);
1857 1.1 christos
1858 1.1 christos mctx = lookup->sdlz->common.mctx;
1859 1.1 christos
1860 1.1 christos r.base = type;
1861 1.1 christos r.length = strlen(type);
1862 1.1 christos result = dns_rdatatype_fromtext(&typeval, (void *) &r);
1863 1.1 christos if (result != ISC_R_SUCCESS)
1864 1.1 christos return (result);
1865 1.1 christos
1866 1.1 christos rdatalist = ISC_LIST_HEAD(lookup->lists);
1867 1.1 christos while (rdatalist != NULL) {
1868 1.1 christos if (rdatalist->type == typeval)
1869 1.1 christos break;
1870 1.1 christos rdatalist = ISC_LIST_NEXT(rdatalist, link);
1871 1.1 christos }
1872 1.1 christos
1873 1.1 christos if (rdatalist == NULL) {
1874 1.1 christos rdatalist = isc_mem_get(mctx, sizeof(dns_rdatalist_t));
1875 1.1 christos if (rdatalist == NULL)
1876 1.1 christos return (ISC_R_NOMEMORY);
1877 1.1 christos dns_rdatalist_init(rdatalist);
1878 1.1 christos rdatalist->rdclass = lookup->sdlz->common.rdclass;
1879 1.1 christos rdatalist->type = typeval;
1880 1.1 christos rdatalist->ttl = ttl;
1881 1.1 christos ISC_LIST_APPEND(lookup->lists, rdatalist, link);
1882 1.1 christos } else
1883 1.1 christos if (rdatalist->ttl > ttl) {
1884 1.1 christos /*
1885 1.1 christos * BIND9 doesn't enforce all RRs in an RRset
1886 1.1 christos * having the same TTL, as per RFC 2136,
1887 1.1 christos * section 7.12. If a DLZ backend has
1888 1.1 christos * different TTLs, then the best
1889 1.1 christos * we can do is return the lowest.
1890 1.1 christos */
1891 1.1 christos rdatalist->ttl = ttl;
1892 1.1 christos }
1893 1.1 christos
1894 1.1 christos rdata = isc_mem_get(mctx, sizeof(dns_rdata_t));
1895 1.1 christos if (rdata == NULL)
1896 1.1 christos return (ISC_R_NOMEMORY);
1897 1.1 christos dns_rdata_init(rdata);
1898 1.1 christos
1899 1.1 christos if ((lookup->sdlz->dlzimp->flags & DNS_SDLZFLAG_RELATIVERDATA) != 0)
1900 1.1 christos origin = &lookup->sdlz->common.origin;
1901 1.1 christos else
1902 1.1 christos origin = dns_rootname;
1903 1.1 christos
1904 1.1 christos lex = NULL;
1905 1.1 christos result = isc_lex_create(mctx, 64, &lex);
1906 1.1 christos if (result != ISC_R_SUCCESS)
1907 1.1 christos goto failure;
1908 1.1 christos
1909 1.1 christos size = initial_size(data);
1910 1.1 christos do {
1911 1.1 christos isc_buffer_constinit(&b, data, strlen(data));
1912 1.1 christos isc_buffer_add(&b, strlen(data));
1913 1.1 christos
1914 1.1 christos result = isc_lex_openbuffer(lex, &b);
1915 1.1 christos if (result != ISC_R_SUCCESS)
1916 1.1 christos goto failure;
1917 1.1 christos
1918 1.1 christos rdatabuf = NULL;
1919 1.1 christos result = isc_buffer_allocate(mctx, &rdatabuf, size);
1920 1.1 christos if (result != ISC_R_SUCCESS)
1921 1.1 christos goto failure;
1922 1.1 christos
1923 1.1 christos result = dns_rdata_fromtext(rdata, rdatalist->rdclass,
1924 1.1 christos rdatalist->type, lex,
1925 1.3 christos origin, false,
1926 1.1 christos mctx, rdatabuf,
1927 1.1 christos &lookup->callbacks);
1928 1.3 christos if (result != ISC_R_SUCCESS) {
1929 1.1 christos isc_buffer_free(&rdatabuf);
1930 1.3 christos result = DNS_R_SERVFAIL;
1931 1.3 christos }
1932 1.1 christos if (size >= 65535)
1933 1.1 christos break;
1934 1.1 christos size *= 2;
1935 1.1 christos if (size >= 65535)
1936 1.1 christos size = 65535;
1937 1.1 christos } while (result == ISC_R_NOSPACE);
1938 1.1 christos
1939 1.1 christos if (result != ISC_R_SUCCESS)
1940 1.1 christos goto failure;
1941 1.1 christos
1942 1.1 christos ISC_LIST_APPEND(rdatalist->rdata, rdata, link);
1943 1.1 christos ISC_LIST_APPEND(lookup->buffers, rdatabuf, link);
1944 1.1 christos
1945 1.1 christos if (lex != NULL)
1946 1.1 christos isc_lex_destroy(&lex);
1947 1.1 christos
1948 1.1 christos return (ISC_R_SUCCESS);
1949 1.1 christos
1950 1.1 christos failure:
1951 1.1 christos if (rdatabuf != NULL)
1952 1.1 christos isc_buffer_free(&rdatabuf);
1953 1.1 christos if (lex != NULL)
1954 1.1 christos isc_lex_destroy(&lex);
1955 1.1 christos isc_mem_put(mctx, rdata, sizeof(dns_rdata_t));
1956 1.1 christos
1957 1.1 christos return (result);
1958 1.1 christos }
1959 1.1 christos
1960 1.1 christos isc_result_t
1961 1.1 christos dns_sdlz_putnamedrr(dns_sdlzallnodes_t *allnodes, const char *name,
1962 1.1 christos const char *type, dns_ttl_t ttl, const char *data)
1963 1.1 christos {
1964 1.1 christos dns_name_t *newname;
1965 1.1 christos const dns_name_t *origin;
1966 1.1 christos dns_fixedname_t fnewname;
1967 1.1 christos dns_sdlz_db_t *sdlz = (dns_sdlz_db_t *)allnodes->common.db;
1968 1.1 christos dns_sdlznode_t *sdlznode;
1969 1.1 christos isc_mem_t *mctx = sdlz->common.mctx;
1970 1.1 christos isc_buffer_t b;
1971 1.1 christos isc_result_t result;
1972 1.1 christos
1973 1.1 christos newname = dns_fixedname_initname(&fnewname);
1974 1.1 christos
1975 1.1 christos if ((sdlz->dlzimp->flags & DNS_SDLZFLAG_RELATIVERDATA) != 0)
1976 1.1 christos origin = &sdlz->common.origin;
1977 1.1 christos else
1978 1.1 christos origin = dns_rootname;
1979 1.1 christos isc_buffer_constinit(&b, name, strlen(name));
1980 1.1 christos isc_buffer_add(&b, strlen(name));
1981 1.1 christos
1982 1.1 christos result = dns_name_fromtext(newname, &b, origin, 0, NULL);
1983 1.1 christos if (result != ISC_R_SUCCESS)
1984 1.1 christos return (result);
1985 1.1 christos
1986 1.1 christos if (allnodes->common.relative_names) {
1987 1.1 christos /* All names are relative to the root */
1988 1.1 christos unsigned int nlabels = dns_name_countlabels(newname);
1989 1.1 christos dns_name_getlabelsequence(newname, 0, nlabels - 1, newname);
1990 1.1 christos }
1991 1.1 christos
1992 1.1 christos sdlznode = ISC_LIST_HEAD(allnodes->nodelist);
1993 1.1 christos if (sdlznode == NULL || !dns_name_equal(sdlznode->name, newname)) {
1994 1.1 christos sdlznode = NULL;
1995 1.1 christos result = createnode(sdlz, &sdlznode);
1996 1.1 christos if (result != ISC_R_SUCCESS)
1997 1.1 christos return (result);
1998 1.1 christos sdlznode->name = isc_mem_get(mctx, sizeof(dns_name_t));
1999 1.1 christos if (sdlznode->name == NULL) {
2000 1.1 christos destroynode(sdlznode);
2001 1.1 christos return (ISC_R_NOMEMORY);
2002 1.1 christos }
2003 1.1 christos dns_name_init(sdlznode->name, NULL);
2004 1.1 christos result = dns_name_dup(newname, mctx, sdlznode->name);
2005 1.1 christos if (result != ISC_R_SUCCESS) {
2006 1.1 christos isc_mem_put(mctx, sdlznode->name, sizeof(dns_name_t));
2007 1.1 christos destroynode(sdlznode);
2008 1.1 christos return (result);
2009 1.1 christos }
2010 1.1 christos ISC_LIST_PREPEND(allnodes->nodelist, sdlznode, link);
2011 1.1 christos if (allnodes->origin == NULL &&
2012 1.1 christos dns_name_equal(newname, &sdlz->common.origin))
2013 1.1 christos allnodes->origin = sdlznode;
2014 1.1 christos }
2015 1.1 christos return (dns_sdlz_putrr(sdlznode, type, ttl, data));
2016 1.1 christos
2017 1.1 christos }
2018 1.1 christos
2019 1.1 christos isc_result_t
2020 1.1 christos dns_sdlz_putsoa(dns_sdlzlookup_t *lookup, const char *mname, const char *rname,
2021 1.3 christos uint32_t serial)
2022 1.1 christos {
2023 1.1 christos char str[2 * DNS_NAME_MAXTEXT + 5 * (sizeof("2147483647")) + 7];
2024 1.1 christos int n;
2025 1.1 christos
2026 1.1 christos REQUIRE(mname != NULL);
2027 1.1 christos REQUIRE(rname != NULL);
2028 1.1 christos
2029 1.1 christos n = snprintf(str, sizeof str, "%s %s %u %u %u %u %u",
2030 1.1 christos mname, rname, serial,
2031 1.1 christos SDLZ_DEFAULT_REFRESH, SDLZ_DEFAULT_RETRY,
2032 1.1 christos SDLZ_DEFAULT_EXPIRE, SDLZ_DEFAULT_MINIMUM);
2033 1.1 christos if (n >= (int)sizeof(str) || n < 0)
2034 1.1 christos return (ISC_R_NOSPACE);
2035 1.1 christos return (dns_sdlz_putrr(lookup, "SOA", SDLZ_DEFAULT_TTL, str));
2036 1.1 christos }
2037 1.1 christos
2038 1.1 christos isc_result_t
2039 1.1 christos dns_sdlzregister(const char *drivername, const dns_sdlzmethods_t *methods,
2040 1.1 christos void *driverarg, unsigned int flags, isc_mem_t *mctx,
2041 1.1 christos dns_sdlzimplementation_t **sdlzimp)
2042 1.1 christos {
2043 1.1 christos
2044 1.1 christos dns_sdlzimplementation_t *imp;
2045 1.1 christos isc_result_t result;
2046 1.1 christos
2047 1.1 christos /*
2048 1.1 christos * Performs checks to make sure data is as we expect it to be.
2049 1.1 christos */
2050 1.1 christos REQUIRE(drivername != NULL);
2051 1.1 christos REQUIRE(methods != NULL);
2052 1.1 christos REQUIRE(methods->findzone != NULL);
2053 1.1 christos REQUIRE(methods->lookup != NULL);
2054 1.1 christos REQUIRE(mctx != NULL);
2055 1.1 christos REQUIRE(sdlzimp != NULL && *sdlzimp == NULL);
2056 1.1 christos REQUIRE((flags & ~(DNS_SDLZFLAG_RELATIVEOWNER |
2057 1.1 christos DNS_SDLZFLAG_RELATIVERDATA |
2058 1.1 christos DNS_SDLZFLAG_THREADSAFE)) == 0);
2059 1.1 christos
2060 1.1 christos /* Write debugging message to log */
2061 1.1 christos sdlz_log(ISC_LOG_DEBUG(2), "Registering SDLZ driver '%s'", drivername);
2062 1.1 christos
2063 1.1 christos /*
2064 1.1 christos * Allocate memory for a sdlz_implementation object. Error if
2065 1.1 christos * we cannot.
2066 1.1 christos */
2067 1.1 christos imp = isc_mem_get(mctx, sizeof(dns_sdlzimplementation_t));
2068 1.1 christos if (imp == NULL)
2069 1.1 christos return (ISC_R_NOMEMORY);
2070 1.1 christos
2071 1.1 christos /* Make sure memory region is set to all 0's */
2072 1.1 christos memset(imp, 0, sizeof(dns_sdlzimplementation_t));
2073 1.1 christos
2074 1.1 christos /* Store the data passed into this method */
2075 1.1 christos imp->methods = methods;
2076 1.1 christos imp->driverarg = driverarg;
2077 1.1 christos imp->flags = flags;
2078 1.1 christos imp->mctx = NULL;
2079 1.1 christos
2080 1.1 christos /* attach the new sdlz_implementation object to a memory context */
2081 1.1 christos isc_mem_attach(mctx, &imp->mctx);
2082 1.1 christos
2083 1.1 christos /*
2084 1.1 christos * initialize the driver lock, error if we cannot
2085 1.1 christos * (used if a driver does not support multiple threads)
2086 1.1 christos */
2087 1.3 christos isc_mutex_init(&imp->driverlock);
2088 1.1 christos
2089 1.1 christos imp->dlz_imp = NULL;
2090 1.1 christos
2091 1.1 christos /*
2092 1.1 christos * register the DLZ driver. Pass in our "extra" sdlz information as
2093 1.1 christos * a driverarg. (that's why we stored the passed in driver arg in our
2094 1.1 christos * sdlz_implementation structure) Also, store the dlz_implementation
2095 1.1 christos * structure in our sdlz_implementation.
2096 1.1 christos */
2097 1.1 christos result = dns_dlzregister(drivername, &sdlzmethods, imp, mctx,
2098 1.1 christos &imp->dlz_imp);
2099 1.1 christos
2100 1.1 christos /* if registration fails, cleanup and get outta here. */
2101 1.1 christos if (result != ISC_R_SUCCESS)
2102 1.1 christos goto cleanup_mutex;
2103 1.1 christos
2104 1.1 christos *sdlzimp = imp;
2105 1.1 christos
2106 1.1 christos return (ISC_R_SUCCESS);
2107 1.1 christos
2108 1.1 christos cleanup_mutex:
2109 1.1 christos /* destroy the driver lock, we don't need it anymore */
2110 1.3 christos isc_mutex_destroy(&imp->driverlock);
2111 1.1 christos
2112 1.1 christos /*
2113 1.1 christos * return the memory back to the available memory pool and
2114 1.1 christos * remove it from the memory context.
2115 1.1 christos */
2116 1.1 christos isc_mem_put(mctx, imp, sizeof(dns_sdlzimplementation_t));
2117 1.1 christos isc_mem_detach(&mctx);
2118 1.1 christos return (result);
2119 1.1 christos }
2120 1.1 christos
2121 1.1 christos void
2122 1.1 christos dns_sdlzunregister(dns_sdlzimplementation_t **sdlzimp) {
2123 1.1 christos dns_sdlzimplementation_t *imp;
2124 1.1 christos isc_mem_t *mctx;
2125 1.1 christos
2126 1.1 christos /* Write debugging message to log */
2127 1.1 christos sdlz_log(ISC_LOG_DEBUG(2), "Unregistering SDLZ driver.");
2128 1.1 christos
2129 1.1 christos /*
2130 1.1 christos * Performs checks to make sure data is as we expect it to be.
2131 1.1 christos */
2132 1.1 christos REQUIRE(sdlzimp != NULL && *sdlzimp != NULL);
2133 1.1 christos
2134 1.1 christos imp = *sdlzimp;
2135 1.1 christos
2136 1.1 christos /* Unregister the DLZ driver implementation */
2137 1.1 christos dns_dlzunregister(&imp->dlz_imp);
2138 1.1 christos
2139 1.1 christos /* destroy the driver lock, we don't need it anymore */
2140 1.3 christos isc_mutex_destroy(&imp->driverlock);
2141 1.1 christos
2142 1.1 christos mctx = imp->mctx;
2143 1.1 christos
2144 1.1 christos /*
2145 1.1 christos * return the memory back to the available memory pool and
2146 1.1 christos * remove it from the memory context.
2147 1.1 christos */
2148 1.1 christos isc_mem_put(mctx, imp, sizeof(dns_sdlzimplementation_t));
2149 1.1 christos isc_mem_detach(&mctx);
2150 1.1 christos
2151 1.1 christos *sdlzimp = NULL;
2152 1.1 christos }
2153 1.1 christos
2154 1.1 christos
2155 1.1 christos isc_result_t
2156 1.1 christos dns_sdlz_setdb(dns_dlzdb_t *dlzdatabase, dns_rdataclass_t rdclass,
2157 1.1 christos const dns_name_t *name, dns_db_t **dbp)
2158 1.1 christos {
2159 1.1 christos isc_result_t result;
2160 1.1 christos
2161 1.1 christos result = dns_sdlzcreateDBP(dlzdatabase->mctx,
2162 1.1 christos dlzdatabase->implementation->driverarg,
2163 1.1 christos dlzdatabase->dbdata, name, rdclass, dbp);
2164 1.1 christos return (result);
2165 1.1 christos }
2166