Home | History | Annotate | Line # | Download | only in dns
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