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