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