mirror of
https://gitlab.isc.org/isc-projects/bind9
synced 2025-08-22 18:19:42 +00:00
Add an options parameter to control what rdatasets are returned when iteratating over the node. Specific modes will be added later.
822 lines
20 KiB
C
822 lines
20 KiB
C
/*
|
|
* Copyright (C) Internet Systems Consortium, Inc. ("ISC")
|
|
*
|
|
* SPDX-License-Identifier: MPL-2.0
|
|
*
|
|
* This Source Code Form is subject to the terms of the Mozilla Public
|
|
* License, v. 2.0. If a copy of the MPL was not distributed with this
|
|
* file, you can obtain one at https://mozilla.org/MPL/2.0/.
|
|
*
|
|
* See the COPYRIGHT file distributed with this work for additional
|
|
* information regarding copyright ownership.
|
|
*/
|
|
|
|
/*! \file */
|
|
|
|
#include <inttypes.h>
|
|
#include <stdbool.h>
|
|
|
|
#include <isc/loop.h>
|
|
#include <isc/mem.h>
|
|
#include <isc/print.h>
|
|
#include <isc/refcount.h>
|
|
#include <isc/result.h>
|
|
#include <isc/stats.h>
|
|
#include <isc/string.h>
|
|
#include <isc/time.h>
|
|
#include <isc/timer.h>
|
|
#include <isc/util.h>
|
|
|
|
#include <dns/cache.h>
|
|
#include <dns/db.h>
|
|
#include <dns/dbiterator.h>
|
|
#include <dns/log.h>
|
|
#include <dns/masterdump.h>
|
|
#include <dns/rdata.h>
|
|
#include <dns/rdataset.h>
|
|
#include <dns/rdatasetiter.h>
|
|
#include <dns/stats.h>
|
|
|
|
#ifdef HAVE_JSON_C
|
|
#include <json_object.h>
|
|
#endif /* HAVE_JSON_C */
|
|
|
|
#ifdef HAVE_LIBXML2
|
|
#include <libxml/xmlwriter.h>
|
|
#define ISC_XMLCHAR (const xmlChar *)
|
|
#endif /* HAVE_LIBXML2 */
|
|
|
|
#include "rbtdb.h"
|
|
|
|
#define CACHE_MAGIC ISC_MAGIC('$', '$', '$', '$')
|
|
#define VALID_CACHE(cache) ISC_MAGIC_VALID(cache, CACHE_MAGIC)
|
|
|
|
/*
|
|
* DNS_CACHE_MINSIZE is how many bytes is the floor for
|
|
* dns_cache_setcachesize().
|
|
*/
|
|
#define DNS_CACHE_MINSIZE 2097152U /*%< Bytes. 2097152 = 2 MB */
|
|
|
|
/***
|
|
*** Types
|
|
***/
|
|
|
|
/*%
|
|
* The actual cache object.
|
|
*/
|
|
|
|
struct dns_cache {
|
|
/* Unlocked. */
|
|
unsigned int magic;
|
|
isc_mutex_t lock;
|
|
isc_mem_t *mctx; /* Main cache memory */
|
|
isc_mem_t *hmctx; /* Heap memory */
|
|
char *name;
|
|
isc_refcount_t references;
|
|
|
|
/* Locked by 'lock'. */
|
|
dns_rdataclass_t rdclass;
|
|
dns_db_t *db;
|
|
size_t size;
|
|
dns_ttl_t serve_stale_ttl;
|
|
dns_ttl_t serve_stale_refresh;
|
|
isc_stats_t *stats;
|
|
bool overmem;
|
|
};
|
|
|
|
/***
|
|
*** Functions
|
|
***/
|
|
|
|
static isc_result_t
|
|
cache_create_db(dns_cache_t *cache, dns_db_t **db) {
|
|
isc_result_t result;
|
|
char *argv[1] = { 0 };
|
|
|
|
/*
|
|
* For databases of type "rbt" (which is the only cache
|
|
* implementation currently in existence) we pass hmctx to
|
|
* dns_db_create() via argv[0].
|
|
*/
|
|
argv[0] = (char *)cache->hmctx;
|
|
result = dns_db_create(cache->mctx, "rbt", dns_rootname,
|
|
dns_dbtype_cache, cache->rdclass, 1, argv, db);
|
|
if (result == ISC_R_SUCCESS) {
|
|
dns_db_setservestalettl(*db, cache->serve_stale_ttl);
|
|
}
|
|
return (result);
|
|
}
|
|
|
|
isc_result_t
|
|
dns_cache_create(isc_loopmgr_t *loopmgr, dns_rdataclass_t rdclass,
|
|
const char *cachename, dns_cache_t **cachep) {
|
|
isc_result_t result;
|
|
dns_cache_t *cache = NULL;
|
|
isc_mem_t *mctx = NULL, *hmctx = NULL;
|
|
|
|
REQUIRE(loopmgr != NULL);
|
|
REQUIRE(cachename != NULL);
|
|
REQUIRE(cachep != NULL && *cachep == NULL);
|
|
|
|
/*
|
|
* This will be the main cache memory context, which is subject
|
|
* to cleaning when the configured memory limits are exceeded.
|
|
*/
|
|
isc_mem_create(&mctx);
|
|
isc_mem_setname(mctx, "cache");
|
|
|
|
/*
|
|
* This will be passed to RBTDB to use for heaps. This is separate
|
|
* from the main cache memory because it can grow quite large under
|
|
* heavy load and could otherwise cause the cache to be cleaned too
|
|
* aggressively.
|
|
*/
|
|
isc_mem_create(&hmctx);
|
|
isc_mem_setname(hmctx, "cache_heap");
|
|
|
|
cache = isc_mem_get(mctx, sizeof(*cache));
|
|
*cache = (dns_cache_t){
|
|
.mctx = mctx,
|
|
.hmctx = hmctx,
|
|
.rdclass = rdclass,
|
|
.name = isc_mem_strdup(mctx, cachename),
|
|
};
|
|
|
|
isc_mutex_init(&cache->lock);
|
|
|
|
isc_refcount_init(&cache->references, 1);
|
|
|
|
result = isc_stats_create(mctx, &cache->stats,
|
|
dns_cachestatscounter_max);
|
|
if (result != ISC_R_SUCCESS) {
|
|
goto cleanup_lock;
|
|
}
|
|
|
|
/*
|
|
* Create the database
|
|
*/
|
|
result = cache_create_db(cache, &cache->db);
|
|
if (result != ISC_R_SUCCESS) {
|
|
goto cleanup_stats;
|
|
}
|
|
|
|
dns_db_setloop(cache->db, isc_loop_main(loopmgr));
|
|
cache->magic = CACHE_MAGIC;
|
|
|
|
/*
|
|
* RBT-type cache DB has its own mechanism of cache cleaning and
|
|
* doesn't need the control of the generic cleaner.
|
|
*/
|
|
result = dns_db_setcachestats(cache->db, cache->stats);
|
|
if (result != ISC_R_SUCCESS) {
|
|
goto cleanup_db;
|
|
}
|
|
|
|
*cachep = cache;
|
|
return (ISC_R_SUCCESS);
|
|
|
|
cleanup_db:
|
|
dns_db_detach(&cache->db);
|
|
cleanup_stats:
|
|
isc_stats_detach(&cache->stats);
|
|
cleanup_lock:
|
|
isc_mutex_destroy(&cache->lock);
|
|
isc_mem_free(mctx, cache->name);
|
|
isc_mem_detach(&cache->hmctx);
|
|
isc_mem_putanddetach(&cache->mctx, cache, sizeof(*cache));
|
|
return (result);
|
|
}
|
|
|
|
static void
|
|
cache_free(dns_cache_t *cache) {
|
|
REQUIRE(VALID_CACHE(cache));
|
|
|
|
isc_refcount_destroy(&cache->references);
|
|
|
|
isc_mem_clearwater(cache->mctx);
|
|
dns_db_detach(&cache->db);
|
|
isc_mem_free(cache->mctx, cache->name);
|
|
isc_stats_detach(&cache->stats);
|
|
|
|
isc_mutex_destroy(&cache->lock);
|
|
|
|
cache->magic = 0;
|
|
isc_mem_detach(&cache->hmctx);
|
|
isc_mem_putanddetach(&cache->mctx, cache, sizeof(*cache));
|
|
}
|
|
|
|
void
|
|
dns_cache_attach(dns_cache_t *cache, dns_cache_t **targetp) {
|
|
REQUIRE(VALID_CACHE(cache));
|
|
REQUIRE(targetp != NULL && *targetp == NULL);
|
|
|
|
isc_refcount_increment(&cache->references);
|
|
|
|
*targetp = cache;
|
|
}
|
|
|
|
void
|
|
dns_cache_detach(dns_cache_t **cachep) {
|
|
dns_cache_t *cache;
|
|
|
|
REQUIRE(cachep != NULL);
|
|
cache = *cachep;
|
|
*cachep = NULL;
|
|
REQUIRE(VALID_CACHE(cache));
|
|
|
|
if (isc_refcount_decrement(&cache->references) == 1) {
|
|
cache_free(cache);
|
|
}
|
|
}
|
|
|
|
void
|
|
dns_cache_attachdb(dns_cache_t *cache, dns_db_t **dbp) {
|
|
REQUIRE(VALID_CACHE(cache));
|
|
REQUIRE(dbp != NULL && *dbp == NULL);
|
|
REQUIRE(cache->db != NULL);
|
|
|
|
LOCK(&cache->lock);
|
|
dns_db_attach(cache->db, dbp);
|
|
UNLOCK(&cache->lock);
|
|
}
|
|
|
|
const char *
|
|
dns_cache_getname(dns_cache_t *cache) {
|
|
REQUIRE(VALID_CACHE(cache));
|
|
|
|
return (cache->name);
|
|
}
|
|
|
|
static void
|
|
water(void *arg, int mark) {
|
|
dns_cache_t *cache = arg;
|
|
bool overmem = (mark == ISC_MEM_HIWATER);
|
|
|
|
REQUIRE(VALID_CACHE(cache));
|
|
|
|
LOCK(&cache->lock);
|
|
if (overmem != cache->overmem) {
|
|
dns_db_overmem(cache->db, overmem);
|
|
cache->overmem = overmem;
|
|
isc_mem_waterack(cache->mctx, mark);
|
|
}
|
|
UNLOCK(&cache->lock);
|
|
}
|
|
|
|
void
|
|
dns_cache_setcachesize(dns_cache_t *cache, size_t size) {
|
|
size_t hiwater, lowater;
|
|
|
|
REQUIRE(VALID_CACHE(cache));
|
|
|
|
/*
|
|
* Impose a minimum cache size; pathological things happen if there
|
|
* is too little room.
|
|
*/
|
|
if (size != 0U && size < DNS_CACHE_MINSIZE) {
|
|
size = DNS_CACHE_MINSIZE;
|
|
}
|
|
|
|
LOCK(&cache->lock);
|
|
cache->size = size;
|
|
UNLOCK(&cache->lock);
|
|
|
|
hiwater = size - (size >> 3); /* Approximately 7/8ths. */
|
|
lowater = size - (size >> 2); /* Approximately 3/4ths. */
|
|
|
|
/*
|
|
* If the cache was overmem and cleaning, but now with the new limits
|
|
* it is no longer in an overmem condition, then the next
|
|
* isc_mem_put for cache memory will do the right thing and trigger
|
|
* water().
|
|
*/
|
|
|
|
if (size == 0U || hiwater == 0U || lowater == 0U) {
|
|
/*
|
|
* Disable cache memory limiting.
|
|
*/
|
|
isc_mem_clearwater(cache->mctx);
|
|
} else {
|
|
/*
|
|
* Establish new cache memory limits (either for the first
|
|
* time, or replacing other limits).
|
|
*/
|
|
isc_mem_setwater(cache->mctx, water, cache, hiwater, lowater);
|
|
}
|
|
}
|
|
|
|
size_t
|
|
dns_cache_getcachesize(dns_cache_t *cache) {
|
|
size_t size;
|
|
|
|
REQUIRE(VALID_CACHE(cache));
|
|
|
|
LOCK(&cache->lock);
|
|
size = cache->size;
|
|
UNLOCK(&cache->lock);
|
|
|
|
return (size);
|
|
}
|
|
|
|
void
|
|
dns_cache_setservestalettl(dns_cache_t *cache, dns_ttl_t ttl) {
|
|
REQUIRE(VALID_CACHE(cache));
|
|
|
|
LOCK(&cache->lock);
|
|
cache->serve_stale_ttl = ttl;
|
|
UNLOCK(&cache->lock);
|
|
|
|
(void)dns_db_setservestalettl(cache->db, ttl);
|
|
}
|
|
|
|
dns_ttl_t
|
|
dns_cache_getservestalettl(dns_cache_t *cache) {
|
|
dns_ttl_t ttl;
|
|
isc_result_t result;
|
|
|
|
REQUIRE(VALID_CACHE(cache));
|
|
|
|
/*
|
|
* Could get it straight from the dns_cache_t, but use db
|
|
* to confirm the value that the db is really using.
|
|
*/
|
|
result = dns_db_getservestalettl(cache->db, &ttl);
|
|
return (result == ISC_R_SUCCESS ? ttl : 0);
|
|
}
|
|
|
|
void
|
|
dns_cache_setservestalerefresh(dns_cache_t *cache, dns_ttl_t interval) {
|
|
REQUIRE(VALID_CACHE(cache));
|
|
|
|
LOCK(&cache->lock);
|
|
cache->serve_stale_refresh = interval;
|
|
UNLOCK(&cache->lock);
|
|
|
|
(void)dns_db_setservestalerefresh(cache->db, interval);
|
|
}
|
|
|
|
dns_ttl_t
|
|
dns_cache_getservestalerefresh(dns_cache_t *cache) {
|
|
isc_result_t result;
|
|
dns_ttl_t interval;
|
|
|
|
REQUIRE(VALID_CACHE(cache));
|
|
|
|
result = dns_db_getservestalerefresh(cache->db, &interval);
|
|
return (result == ISC_R_SUCCESS ? interval : 0);
|
|
}
|
|
|
|
isc_result_t
|
|
dns_cache_flush(dns_cache_t *cache) {
|
|
dns_db_t *db = NULL, *olddb;
|
|
isc_result_t result;
|
|
|
|
result = cache_create_db(cache, &db);
|
|
if (result != ISC_R_SUCCESS) {
|
|
return (result);
|
|
}
|
|
|
|
LOCK(&cache->lock);
|
|
olddb = cache->db;
|
|
cache->db = db;
|
|
dns_db_setcachestats(cache->db, cache->stats);
|
|
UNLOCK(&cache->lock);
|
|
|
|
dns_db_detach(&olddb);
|
|
|
|
return (ISC_R_SUCCESS);
|
|
}
|
|
|
|
static isc_result_t
|
|
clearnode(dns_db_t *db, dns_dbnode_t *node) {
|
|
isc_result_t result;
|
|
dns_rdatasetiter_t *iter = NULL;
|
|
|
|
result = dns_db_allrdatasets(db, node, NULL, 0, (isc_stdtime_t)0,
|
|
&iter);
|
|
if (result != ISC_R_SUCCESS) {
|
|
return (result);
|
|
}
|
|
|
|
for (result = dns_rdatasetiter_first(iter); result == ISC_R_SUCCESS;
|
|
result = dns_rdatasetiter_next(iter))
|
|
{
|
|
dns_rdataset_t rdataset;
|
|
dns_rdataset_init(&rdataset);
|
|
|
|
dns_rdatasetiter_current(iter, &rdataset);
|
|
result = dns_db_deleterdataset(db, node, NULL, rdataset.type,
|
|
rdataset.covers);
|
|
dns_rdataset_disassociate(&rdataset);
|
|
if (result != ISC_R_SUCCESS && result != DNS_R_UNCHANGED) {
|
|
break;
|
|
}
|
|
}
|
|
|
|
if (result == ISC_R_NOMORE) {
|
|
result = ISC_R_SUCCESS;
|
|
}
|
|
|
|
dns_rdatasetiter_destroy(&iter);
|
|
return (result);
|
|
}
|
|
|
|
static isc_result_t
|
|
cleartree(dns_db_t *db, const dns_name_t *name) {
|
|
isc_result_t result, answer = ISC_R_SUCCESS;
|
|
dns_dbiterator_t *iter = NULL;
|
|
dns_dbnode_t *node = NULL, *top = NULL;
|
|
dns_fixedname_t fnodename;
|
|
dns_name_t *nodename;
|
|
|
|
/*
|
|
* Create the node if it doesn't exist so dns_dbiterator_seek()
|
|
* can find it. We will continue even if this fails.
|
|
*/
|
|
(void)dns_db_findnode(db, name, true, &top);
|
|
|
|
nodename = dns_fixedname_initname(&fnodename);
|
|
|
|
result = dns_db_createiterator(db, 0, &iter);
|
|
if (result != ISC_R_SUCCESS) {
|
|
goto cleanup;
|
|
}
|
|
|
|
result = dns_dbiterator_seek(iter, name);
|
|
if (result == DNS_R_PARTIALMATCH) {
|
|
result = dns_dbiterator_next(iter);
|
|
}
|
|
if (result != ISC_R_SUCCESS) {
|
|
goto cleanup;
|
|
}
|
|
|
|
while (result == ISC_R_SUCCESS) {
|
|
result = dns_dbiterator_current(iter, &node, nodename);
|
|
if (result == DNS_R_NEWORIGIN) {
|
|
result = ISC_R_SUCCESS;
|
|
}
|
|
if (result != ISC_R_SUCCESS) {
|
|
goto cleanup;
|
|
}
|
|
/*
|
|
* Are we done?
|
|
*/
|
|
if (!dns_name_issubdomain(nodename, name)) {
|
|
goto cleanup;
|
|
}
|
|
|
|
/*
|
|
* If clearnode fails record and move onto the next node.
|
|
*/
|
|
result = clearnode(db, node);
|
|
if (result != ISC_R_SUCCESS && answer == ISC_R_SUCCESS) {
|
|
answer = result;
|
|
}
|
|
dns_db_detachnode(db, &node);
|
|
result = dns_dbiterator_next(iter);
|
|
}
|
|
|
|
cleanup:
|
|
if (result == ISC_R_NOMORE || result == ISC_R_NOTFOUND) {
|
|
result = ISC_R_SUCCESS;
|
|
}
|
|
if (result != ISC_R_SUCCESS && answer == ISC_R_SUCCESS) {
|
|
answer = result;
|
|
}
|
|
if (node != NULL) {
|
|
dns_db_detachnode(db, &node);
|
|
}
|
|
if (iter != NULL) {
|
|
dns_dbiterator_destroy(&iter);
|
|
}
|
|
if (top != NULL) {
|
|
dns_db_detachnode(db, &top);
|
|
}
|
|
|
|
return (answer);
|
|
}
|
|
|
|
isc_result_t
|
|
dns_cache_flushname(dns_cache_t *cache, const dns_name_t *name) {
|
|
return (dns_cache_flushnode(cache, name, false));
|
|
}
|
|
|
|
isc_result_t
|
|
dns_cache_flushnode(dns_cache_t *cache, const dns_name_t *name, bool tree) {
|
|
isc_result_t result;
|
|
dns_dbnode_t *node = NULL;
|
|
dns_db_t *db = NULL;
|
|
|
|
if (tree && dns_name_equal(name, dns_rootname)) {
|
|
return (dns_cache_flush(cache));
|
|
}
|
|
|
|
LOCK(&cache->lock);
|
|
if (cache->db != NULL) {
|
|
dns_db_attach(cache->db, &db);
|
|
}
|
|
UNLOCK(&cache->lock);
|
|
if (db == NULL) {
|
|
return (ISC_R_SUCCESS);
|
|
}
|
|
|
|
if (tree) {
|
|
result = cleartree(cache->db, name);
|
|
} else {
|
|
result = dns_db_findnode(cache->db, name, false, &node);
|
|
if (result == ISC_R_NOTFOUND) {
|
|
result = ISC_R_SUCCESS;
|
|
goto cleanup_db;
|
|
}
|
|
if (result != ISC_R_SUCCESS) {
|
|
goto cleanup_db;
|
|
}
|
|
result = clearnode(cache->db, node);
|
|
dns_db_detachnode(cache->db, &node);
|
|
}
|
|
|
|
cleanup_db:
|
|
dns_db_detach(&db);
|
|
return (result);
|
|
}
|
|
|
|
isc_stats_t *
|
|
dns_cache_getstats(dns_cache_t *cache) {
|
|
REQUIRE(VALID_CACHE(cache));
|
|
return (cache->stats);
|
|
}
|
|
|
|
void
|
|
dns_cache_updatestats(dns_cache_t *cache, isc_result_t result) {
|
|
REQUIRE(VALID_CACHE(cache));
|
|
if (cache->stats == NULL) {
|
|
return;
|
|
}
|
|
|
|
switch (result) {
|
|
case ISC_R_SUCCESS:
|
|
case DNS_R_NCACHENXDOMAIN:
|
|
case DNS_R_NCACHENXRRSET:
|
|
case DNS_R_CNAME:
|
|
case DNS_R_DNAME:
|
|
case DNS_R_GLUE:
|
|
case DNS_R_ZONECUT:
|
|
case DNS_R_COVERINGNSEC:
|
|
isc_stats_increment(cache->stats,
|
|
dns_cachestatscounter_queryhits);
|
|
break;
|
|
default:
|
|
isc_stats_increment(cache->stats,
|
|
dns_cachestatscounter_querymisses);
|
|
}
|
|
}
|
|
|
|
/*
|
|
* XXX: Much of the following code has been copied in from statschannel.c.
|
|
* We should refactor this into a generic function in stats.c that can be
|
|
* called from both places.
|
|
*/
|
|
typedef struct cache_dumparg {
|
|
isc_statsformat_t type;
|
|
void *arg; /* type dependent argument */
|
|
int ncounters; /* for general statistics */
|
|
int *counterindices; /* for general statistics */
|
|
uint64_t *countervalues; /* for general statistics */
|
|
isc_result_t result;
|
|
} cache_dumparg_t;
|
|
|
|
static void
|
|
getcounter(isc_statscounter_t counter, uint64_t val, void *arg) {
|
|
cache_dumparg_t *dumparg = arg;
|
|
|
|
REQUIRE(counter < dumparg->ncounters);
|
|
dumparg->countervalues[counter] = val;
|
|
}
|
|
|
|
static void
|
|
getcounters(isc_stats_t *stats, isc_statsformat_t type, int ncounters,
|
|
int *indices, uint64_t *values) {
|
|
cache_dumparg_t dumparg;
|
|
|
|
memset(values, 0, sizeof(values[0]) * ncounters);
|
|
|
|
dumparg.type = type;
|
|
dumparg.ncounters = ncounters;
|
|
dumparg.counterindices = indices;
|
|
dumparg.countervalues = values;
|
|
|
|
isc_stats_dump(stats, getcounter, &dumparg, ISC_STATSDUMP_VERBOSE);
|
|
}
|
|
|
|
void
|
|
dns_cache_dumpstats(dns_cache_t *cache, FILE *fp) {
|
|
int indices[dns_cachestatscounter_max];
|
|
uint64_t values[dns_cachestatscounter_max];
|
|
|
|
REQUIRE(VALID_CACHE(cache));
|
|
|
|
getcounters(cache->stats, isc_statsformat_file,
|
|
dns_cachestatscounter_max, indices, values);
|
|
|
|
fprintf(fp, "%20" PRIu64 " %s\n", values[dns_cachestatscounter_hits],
|
|
"cache hits");
|
|
fprintf(fp, "%20" PRIu64 " %s\n", values[dns_cachestatscounter_misses],
|
|
"cache misses");
|
|
fprintf(fp, "%20" PRIu64 " %s\n",
|
|
values[dns_cachestatscounter_queryhits],
|
|
"cache hits (from query)");
|
|
fprintf(fp, "%20" PRIu64 " %s\n",
|
|
values[dns_cachestatscounter_querymisses],
|
|
"cache misses (from query)");
|
|
fprintf(fp, "%20" PRIu64 " %s\n",
|
|
values[dns_cachestatscounter_deletelru],
|
|
"cache records deleted due to memory exhaustion");
|
|
fprintf(fp, "%20" PRIu64 " %s\n",
|
|
values[dns_cachestatscounter_deletettl],
|
|
"cache records deleted due to TTL expiration");
|
|
fprintf(fp, "%20" PRIu64 " %s\n",
|
|
values[dns_cachestatscounter_coveringnsec],
|
|
"covering nsec returned");
|
|
fprintf(fp, "%20u %s\n", dns_db_nodecount(cache->db, dns_dbtree_main),
|
|
"cache database nodes");
|
|
fprintf(fp, "%20u %s\n", dns_db_nodecount(cache->db, dns_dbtree_nsec),
|
|
"cache NSEC auxiliary database nodes");
|
|
fprintf(fp, "%20" PRIu64 " %s\n", (uint64_t)dns_db_hashsize(cache->db),
|
|
"cache database hash buckets");
|
|
|
|
fprintf(fp, "%20" PRIu64 " %s\n", (uint64_t)isc_mem_total(cache->mctx),
|
|
"cache tree memory total");
|
|
fprintf(fp, "%20" PRIu64 " %s\n", (uint64_t)isc_mem_inuse(cache->mctx),
|
|
"cache tree memory in use");
|
|
fprintf(fp, "%20" PRIu64 " %s\n",
|
|
(uint64_t)isc_mem_maxinuse(cache->mctx),
|
|
"cache tree highest memory in use");
|
|
|
|
fprintf(fp, "%20" PRIu64 " %s\n", (uint64_t)isc_mem_total(cache->hmctx),
|
|
"cache heap memory total");
|
|
fprintf(fp, "%20" PRIu64 " %s\n", (uint64_t)isc_mem_inuse(cache->hmctx),
|
|
"cache heap memory in use");
|
|
fprintf(fp, "%20" PRIu64 " %s\n",
|
|
(uint64_t)isc_mem_maxinuse(cache->hmctx),
|
|
"cache heap highest memory in use");
|
|
}
|
|
|
|
#ifdef HAVE_LIBXML2
|
|
#define TRY0(a) \
|
|
do { \
|
|
xmlrc = (a); \
|
|
if (xmlrc < 0) \
|
|
goto error; \
|
|
} while (0)
|
|
static int
|
|
renderstat(const char *name, uint64_t value, xmlTextWriterPtr writer) {
|
|
int xmlrc;
|
|
|
|
TRY0(xmlTextWriterStartElement(writer, ISC_XMLCHAR "counter"));
|
|
TRY0(xmlTextWriterWriteAttribute(writer, ISC_XMLCHAR "name",
|
|
ISC_XMLCHAR name));
|
|
TRY0(xmlTextWriterWriteFormatString(writer, "%" PRIu64 "", value));
|
|
TRY0(xmlTextWriterEndElement(writer)); /* counter */
|
|
|
|
error:
|
|
return (xmlrc);
|
|
}
|
|
|
|
int
|
|
dns_cache_renderxml(dns_cache_t *cache, void *writer0) {
|
|
int indices[dns_cachestatscounter_max];
|
|
uint64_t values[dns_cachestatscounter_max];
|
|
int xmlrc;
|
|
xmlTextWriterPtr writer = (xmlTextWriterPtr)writer0;
|
|
|
|
REQUIRE(VALID_CACHE(cache));
|
|
|
|
getcounters(cache->stats, isc_statsformat_file,
|
|
dns_cachestatscounter_max, indices, values);
|
|
TRY0(renderstat("CacheHits", values[dns_cachestatscounter_hits],
|
|
writer));
|
|
TRY0(renderstat("CacheMisses", values[dns_cachestatscounter_misses],
|
|
writer));
|
|
TRY0(renderstat("QueryHits", values[dns_cachestatscounter_queryhits],
|
|
writer));
|
|
TRY0(renderstat("QueryMisses",
|
|
values[dns_cachestatscounter_querymisses], writer));
|
|
TRY0(renderstat("DeleteLRU", values[dns_cachestatscounter_deletelru],
|
|
writer));
|
|
TRY0(renderstat("DeleteTTL", values[dns_cachestatscounter_deletettl],
|
|
writer));
|
|
TRY0(renderstat("CoveringNSEC",
|
|
values[dns_cachestatscounter_coveringnsec], writer));
|
|
|
|
TRY0(renderstat("CacheNodes",
|
|
dns_db_nodecount(cache->db, dns_dbtree_main), writer));
|
|
TRY0(renderstat("CacheNSECNodes",
|
|
dns_db_nodecount(cache->db, dns_dbtree_nsec), writer));
|
|
TRY0(renderstat("CacheBuckets", dns_db_hashsize(cache->db), writer));
|
|
|
|
TRY0(renderstat("TreeMemTotal", isc_mem_total(cache->mctx), writer));
|
|
TRY0(renderstat("TreeMemInUse", isc_mem_inuse(cache->mctx), writer));
|
|
TRY0(renderstat("TreeMemMax", isc_mem_maxinuse(cache->mctx), writer));
|
|
|
|
TRY0(renderstat("HeapMemTotal", isc_mem_total(cache->hmctx), writer));
|
|
TRY0(renderstat("HeapMemInUse", isc_mem_inuse(cache->hmctx), writer));
|
|
TRY0(renderstat("HeapMemMax", isc_mem_maxinuse(cache->hmctx), writer));
|
|
error:
|
|
return (xmlrc);
|
|
}
|
|
#endif /* ifdef HAVE_LIBXML2 */
|
|
|
|
#ifdef HAVE_JSON_C
|
|
#define CHECKMEM(m) \
|
|
do { \
|
|
if (m == NULL) { \
|
|
result = ISC_R_NOMEMORY; \
|
|
goto error; \
|
|
} \
|
|
} while (0)
|
|
|
|
isc_result_t
|
|
dns_cache_renderjson(dns_cache_t *cache, void *cstats0) {
|
|
isc_result_t result = ISC_R_SUCCESS;
|
|
int indices[dns_cachestatscounter_max];
|
|
uint64_t values[dns_cachestatscounter_max];
|
|
json_object *obj;
|
|
json_object *cstats = (json_object *)cstats0;
|
|
|
|
REQUIRE(VALID_CACHE(cache));
|
|
|
|
getcounters(cache->stats, isc_statsformat_file,
|
|
dns_cachestatscounter_max, indices, values);
|
|
|
|
obj = json_object_new_int64(values[dns_cachestatscounter_hits]);
|
|
CHECKMEM(obj);
|
|
json_object_object_add(cstats, "CacheHits", obj);
|
|
|
|
obj = json_object_new_int64(values[dns_cachestatscounter_misses]);
|
|
CHECKMEM(obj);
|
|
json_object_object_add(cstats, "CacheMisses", obj);
|
|
|
|
obj = json_object_new_int64(values[dns_cachestatscounter_queryhits]);
|
|
CHECKMEM(obj);
|
|
json_object_object_add(cstats, "QueryHits", obj);
|
|
|
|
obj = json_object_new_int64(values[dns_cachestatscounter_querymisses]);
|
|
CHECKMEM(obj);
|
|
json_object_object_add(cstats, "QueryMisses", obj);
|
|
|
|
obj = json_object_new_int64(values[dns_cachestatscounter_deletelru]);
|
|
CHECKMEM(obj);
|
|
json_object_object_add(cstats, "DeleteLRU", obj);
|
|
|
|
obj = json_object_new_int64(values[dns_cachestatscounter_deletettl]);
|
|
CHECKMEM(obj);
|
|
json_object_object_add(cstats, "DeleteTTL", obj);
|
|
|
|
obj = json_object_new_int64(values[dns_cachestatscounter_coveringnsec]);
|
|
CHECKMEM(obj);
|
|
json_object_object_add(cstats, "CoveringNSEC", obj);
|
|
|
|
obj = json_object_new_int64(
|
|
dns_db_nodecount(cache->db, dns_dbtree_main));
|
|
CHECKMEM(obj);
|
|
json_object_object_add(cstats, "CacheNodes", obj);
|
|
|
|
obj = json_object_new_int64(
|
|
dns_db_nodecount(cache->db, dns_dbtree_nsec));
|
|
CHECKMEM(obj);
|
|
json_object_object_add(cstats, "CacheNSECNodes", obj);
|
|
|
|
obj = json_object_new_int64(dns_db_hashsize(cache->db));
|
|
CHECKMEM(obj);
|
|
json_object_object_add(cstats, "CacheBuckets", obj);
|
|
|
|
obj = json_object_new_int64(isc_mem_total(cache->mctx));
|
|
CHECKMEM(obj);
|
|
json_object_object_add(cstats, "TreeMemTotal", obj);
|
|
|
|
obj = json_object_new_int64(isc_mem_inuse(cache->mctx));
|
|
CHECKMEM(obj);
|
|
json_object_object_add(cstats, "TreeMemInUse", obj);
|
|
|
|
obj = json_object_new_int64(isc_mem_maxinuse(cache->mctx));
|
|
CHECKMEM(obj);
|
|
json_object_object_add(cstats, "TreeMemMax", obj);
|
|
|
|
obj = json_object_new_int64(isc_mem_total(cache->hmctx));
|
|
CHECKMEM(obj);
|
|
json_object_object_add(cstats, "HeapMemTotal", obj);
|
|
|
|
obj = json_object_new_int64(isc_mem_inuse(cache->hmctx));
|
|
CHECKMEM(obj);
|
|
json_object_object_add(cstats, "HeapMemInUse", obj);
|
|
|
|
obj = json_object_new_int64(isc_mem_maxinuse(cache->hmctx));
|
|
CHECKMEM(obj);
|
|
json_object_object_add(cstats, "HeapMemMax", obj);
|
|
|
|
result = ISC_R_SUCCESS;
|
|
error:
|
|
return (result);
|
|
}
|
|
#endif /* ifdef HAVE_JSON_C */
|