This file contains the infrastructure cache. More...

#include "config.h"
#include "sldns/rrdef.h"
#include "sldns/str2wire.h"
#include "sldns/sbuffer.h"
#include "sldns/wire2str.h"
#include "services/cache/infra.h"
#include "util/storage/slabhash.h"
#include "util/storage/lookup3.h"
#include "util/data/dname.h"
#include "util/log.h"
#include "util/net_help.h"
#include "util/config_file.h"
#include "iterator/iterator.h"

Functions
int	still_useful_timeout ()
	Minus 1000 because that is outside of the RTTBAND, so blacklisted servers stay blacklisted if this is chosen.

size_t	infra_sizefunc (void k, void ATTR_UNUSED(d))

int	infra_compfunc (void key1, void key2)
	compare two addresses, returns -1, 0, or +1

void	infra_delkeyfunc (void k, void ATTR_UNUSED(arg))

void	infra_deldatafunc (void d, void ATTR_UNUSED(arg))

size_t	rate_sizefunc (void k, void ATTR_UNUSED(d))

int	rate_compfunc (void key1, void key2)
	compare two names, returns -1, 0, or +1

void	rate_delkeyfunc (void k, void ATTR_UNUSED(arg))

void	rate_deldatafunc (void d, void ATTR_UNUSED(arg))

static struct domain_limit_data *	domain_limit_findcreate (struct rbtree_type domain_limits, char name)
	find or create element in domainlimit tree

static int	infra_ratelimit_cfg_insert (struct rbtree_type domain_limits, struct config_file cfg)
	insert rate limit configuration into lookup tree

int	setup_domain_limits (struct rbtree_type domain_limits, struct config_file cfg)
	setup domain limits tree (0 on failure)

static struct wait_limit_netblock_info *	wait_limit_netblock_findcreate (struct rbtree_type tree, char str)
	find or create element in wait limit netblock tree

static int	infra_wait_limit_netblock_insert (rbtree_type wait_limits_netblock, rbtree_type wait_limits_cookie_netblock, struct config_file *cfg)
	insert wait limit information into lookup tree

static int	wait_limit_netblock_default (struct rbtree_type tree, char str, int limit)
	Add a default wait limit netblock.

int	setup_wait_limits (rbtree_type wait_limits_netblock, rbtree_type wait_limits_cookie_netblock, struct config_file *cfg)
	setup wait limits tree (0 on failure)

struct infra_cache *	infra_create (struct config_file *cfg)
	Create infra cache.

static void	domain_limit_free (rbnode_type n, void ATTR_UNUSED(arg))
	delete domain_limit entries

void	domain_limits_free (struct rbtree_type *domain_limits)
	Free the domain limits tree.

static void	wait_limit_netblock_del (rbnode_type n, void ATTR_UNUSED(arg))
	delete wait_limit_netblock_info entries

void	wait_limits_free (struct rbtree_type *wait_limits_tree)
	Free the wait limits and wait cookie limits tree.

void	infra_delete (struct infra_cache *infra)
	Delete infra cache.

struct infra_cache *	infra_adjust (struct infra_cache infra, struct config_file cfg)
	Adjust infra cache to use updated configuration settings.

static hashvalue_type	hash_addr (struct sockaddr_storage *addr, socklen_t addrlen, int use_port)
	calculate the hash value for a host key set use_port to a non-0 number to use the port in the hash calculation; 0 to ignore the port.

static hashvalue_type	hash_infra (struct sockaddr_storage addr, socklen_t addrlen, uint8_t name)
	calculate infra hash for a key

struct lruhash_entry *	infra_lookup_nottl (struct infra_cache infra, struct sockaddr_storage addr, socklen_t addrlen, uint8_t *name, size_t namelen, int wr)
	lookup version that does not check host ttl (you check it)

static void	data_entry_init (struct infra_cache infra, struct lruhash_entry e, time_t timenow)
	init the data elements

static struct lruhash_entry *	new_entry (struct infra_cache infra, struct sockaddr_storage addr, socklen_t addrlen, uint8_t *name, size_t namelen, time_t tm)
	Create and init a new entry for a host.

int	infra_host (struct infra_cache infra, struct sockaddr_storage addr, socklen_t addrlen, uint8_t nm, size_t nmlen, time_t timenow, int edns_vs, uint8_t edns_lame_known, int to)
	Find host information to send a packet.

int	infra_set_lame (struct infra_cache infra, struct sockaddr_storage addr, socklen_t addrlen, uint8_t *nm, size_t nmlen, time_t timenow, int dnsseclame, int reclame, uint16_t qtype)
	Set a host to be lame for the given zone.

void	infra_update_tcp_works (struct infra_cache infra, struct sockaddr_storage addr, socklen_t addrlen, uint8_t *nm, size_t nmlen)
	Update information for the host, store that a TCP transaction works.

int	infra_rtt_update (struct infra_cache infra, struct sockaddr_storage addr, socklen_t addrlen, uint8_t *nm, size_t nmlen, int qtype, int roundtrip, int orig_rtt, time_t timenow)
	Update rtt information for the host.

long long	infra_get_host_rto (struct infra_cache infra, struct sockaddr_storage addr, socklen_t addrlen, uint8_t nm, size_t nmlen, struct rtt_info rtt, int delay, time_t timenow, int tA, int tAAAA, int tother)
	Get additional (debug) info on timing.

int	infra_edns_update (struct infra_cache infra, struct sockaddr_storage addr, socklen_t addrlen, uint8_t *nm, size_t nmlen, int edns_version, time_t timenow)
	Update edns information for the host.

int	infra_get_lame_rtt (struct infra_cache infra, struct sockaddr_storage addr, socklen_t addrlen, uint8_t name, size_t namelen, uint16_t qtype, int lame, int dnsseclame, int reclame, int *rtt, time_t timenow)
	Get Lameness information and average RTT if host is in the cache.

int	infra_find_ratelimit (struct infra_cache infra, uint8_t name, size_t namelen)
	find the ratelimit in qps for a domain.

size_t	ip_rate_sizefunc (void k, void ATTR_UNUSED(d))

int	ip_rate_compfunc (void key1, void key2)

void	ip_rate_delkeyfunc (void k, void ATTR_UNUSED(arg))

static struct lruhash_entry *	infra_find_ratedata (struct infra_cache infra, uint8_t name, size_t namelen, int wr)
	find data item in array, for write access, caller unlocks

static struct lruhash_entry *	infra_find_ip_ratedata (struct infra_cache infra, struct sockaddr_storage addr, socklen_t addrlen, int wr)
	find data item in array for ip addresses

static void	infra_create_ratedata (struct infra_cache infra, uint8_t name, size_t namelen, time_t timenow)
	create rate data item for name, number 1 in now

static void	infra_ip_create_ratedata (struct infra_cache infra, struct sockaddr_storage addr, socklen_t addrlen, time_t timenow, int mesh_wait)
	create rate data item for ip address

static int *	infra_rate_find_second_or_none (void *data, time_t t, int should_add)
	Find the second and return its rate counter.

static int *	infra_rate_give_second (void *data, time_t t)
	find the second and return its rate counter, if none, remove oldest to accommodate

static int *	infra_rate_get_second (void *data, time_t t)
	find the second and return its rate counter only if it exists.

int	infra_rate_max (void *data, time_t now, int backoff)
	find the maximum rate stored.

int	infra_ratelimit_inc (struct infra_cache infra, uint8_t name, size_t namelen, time_t timenow, int backoff, struct query_info qinfo, struct comm_reply replylist)
	Increment the query rate counter for a delegation point.

void	infra_ratelimit_dec (struct infra_cache infra, uint8_t name, size_t namelen, time_t timenow)
	Decrement the query rate counter for a delegation point.

int	infra_ratelimit_exceeded (struct infra_cache infra, uint8_t name, size_t namelen, time_t timenow, int backoff)
	See if the query rate counter for a delegation point is exceeded.

size_t	infra_get_mem (struct infra_cache *infra)
	Get memory used by the infra cache.

static int	check_ip_ratelimit (struct sockaddr_storage addr, socklen_t addrlen, struct sldns_buffer buffer, int premax, int max, int has_cookie)

int	infra_ip_ratelimit_inc (struct infra_cache infra, struct sockaddr_storage addr, socklen_t addrlen, time_t timenow, int has_cookie, int backoff, struct sldns_buffer *buffer)
	Update query ratelimit hash and decide whether or not a query should be dropped.

int	infra_wait_limit_allowed (struct infra_cache infra, struct comm_reply rep, int cookie_valid, struct config_file *cfg)
	See if the IP address can have another reply in the wait limit.

void	infra_wait_limit_inc (struct infra_cache infra, struct comm_reply rep, time_t timenow, struct config_file *cfg)
	Increment number of waiting replies for IP.

void	infra_wait_limit_dec (struct infra_cache infra, struct comm_reply rep, struct config_file *cfg)
	Decrement number of waiting replies for IP.

Variables
int	infra_dp_ratelimit = 0
	ratelimit value for delegation point

int	infra_ip_ratelimit = 0
	ratelimit value for client ip addresses, in queries per second.

int	infra_ip_ratelimit_cookie = 0
	ratelimit value for client ip addresses, in queries per second.

Detailed Description

This file contains the infrastructure cache.

Function Documentation

◆ still_useful_timeout()

int still_useful_timeout ( )

Minus 1000 because that is outside of the RTTBAND, so blacklisted servers stay blacklisted if this is chosen.

exported for unit test

If USEFUL_SERVER_TOP_TIMEOUT is below 1000 (configured via RTT_MAX_TIMEOUT, infra-cache-max-rtt) change it to just above the RTT_BAND.

References RTT_BAND, and USEFUL_SERVER_TOP_TIMEOUT.

Referenced by infra_get_lame_rtt(), and infra_update_tcp_works().

◆ infra_create()

struct infra_cache * infra_create ( struct config_file * cfg )

Create infra cache.

Parameters

cfg	config parameters or NULL for defaults.

Returns: : new infra cache, or NULL.

References infra_cache::client_ip_rates, infra_cache::domain_limits, infra_cache::domain_rates, infra_cache::host_ttl, config_file::host_ttl, infra_cache::hosts, INFRA_BYTES_NAME, config_file::infra_cache_numhosts, config_file::infra_cache_slabs, infra_compfunc(), infra_deldatafunc(), infra_delete(), infra_delkeyfunc(), infra_dp_ratelimit, INFRA_HOST_STARTSIZE, infra_ip_ratelimit, infra_ip_ratelimit_cookie, infra_cache::infra_keep_probing, config_file::infra_keep_probing, infra_sizefunc(), config_file::ip_ratelimit, config_file::ip_ratelimit_cookie, config_file::ip_ratelimit_size, config_file::ip_ratelimit_slabs, rate_compfunc(), rate_deldatafunc(), rate_delkeyfunc(), rate_sizefunc(), config_file::ratelimit, config_file::ratelimit_size, config_file::ratelimit_slabs, setup_domain_limits(), setup_wait_limits(), slabhash_create(), infra_cache::wait_limits_cookie_netblock, and infra_cache::wait_limits_netblock.

Referenced by infra_adjust(), and infra_test().

◆ infra_delete()

void infra_delete ( struct infra_cache * infra )

Delete infra cache.

Parameters

infra infrastructure cache to delete.

References infra_cache::client_ip_rates, infra_cache::domain_limits, domain_limits_free(), infra_cache::domain_rates, infra_cache::hosts, slabhash_delete(), infra_cache::wait_limits_cookie_netblock, wait_limits_free(), and infra_cache::wait_limits_netblock.

Referenced by daemon_delete(), infra_adjust(), infra_create(), infra_test(), and ub_ctx_delete().

◆ infra_adjust()

struct infra_cache * infra_adjust	(	struct infra_cache *	infra,
		struct config_file *	cfg
	)

Adjust infra cache to use updated configuration settings.

This may clean the cache. Operates a bit like realloc. There may be no threading or use by other threads.

Parameters

infra	existing cache. If NULL a new infra cache is returned.
cfg	config options.

Returns: the new infra cache pointer or NULL on error.

References infra_cache::client_ip_rates, domain_limit_free(), infra_cache::domain_limits, infra_cache::domain_rates, infra_cache::host_ttl, config_file::host_ttl, infra_cache::hosts, INFRA_BYTES_NAME, config_file::infra_cache_numhosts, config_file::infra_cache_slabs, infra_create(), infra_delete(), infra_dp_ratelimit, infra_ip_ratelimit, infra_ip_ratelimit_cookie, infra_cache::infra_keep_probing, config_file::infra_keep_probing, config_file::ip_ratelimit, config_file::ip_ratelimit_cookie, config_file::ip_ratelimit_size, config_file::ip_ratelimit_slabs, config_file::ratelimit, config_file::ratelimit_size, config_file::ratelimit_slabs, setup_domain_limits(), slabhash_is_size(), and traverse_postorder().

Referenced by context_finalize(), and daemon_apply_cfg().

◆ infra_lookup_nottl()

struct lruhash_entry * infra_lookup_nottl	(	struct infra_cache *	infra,
		struct sockaddr_storage *	addr,
		socklen_t	addrlen,
		uint8_t *	name,
		size_t	namelen,
		int	wr
	)

lookup version that does not check host ttl (you check it)

Plain find infra data function (used by the other functions)

References infra_key::addr, infra_key::addrlen, lruhash_entry::data, infra_key::entry, lruhash_entry::hash, hash_infra(), infra_cache::hosts, lruhash_entry::key, infra_key::namelen, slabhash_lookup(), and infra_key::zonename.

Referenced by infra_edns_update(), infra_get_host_rto(), infra_get_lame_rtt(), infra_host(), infra_rtt_update(), infra_set_lame(), and infra_update_tcp_works().

◆ new_entry()

static struct lruhash_entry * new_entry	(	struct infra_cache *	infra,
		struct sockaddr_storage *	addr,
		socklen_t	addrlen,
		uint8_t *	name,
		size_t	namelen,
		time_t	tm
	)

static

Create and init a new entry for a host.

Parameters

infra	infra structure with config parameters.
addr	host address.
addrlen	length of addr.
name	name of zone
namelen	length of name.
tm	time now.

Returns: : the new entry or NULL on malloc failure.

References infra_key::addr, infra_key::addrlen, lruhash_entry::data, data_entry_init(), infra_key::entry, lruhash_entry::hash, hash_infra(), lruhash_entry::key, lruhash_entry::lock, memdup(), infra_key::namelen, and infra_key::zonename.

◆ infra_host()

int infra_host	(	struct infra_cache *	infra,
		struct sockaddr_storage *	addr,
		socklen_t	addrlen,
		uint8_t *	name,
		size_t	namelen,
		time_t	timenow,
		int *	edns_vs,
		uint8_t *	edns_lame_known,
		int *	to
	)

Find host information to send a packet.

Creates new entry if not found. Lameness is empty. EDNS is 0 (try with first), and rtt is returned for the first message to it. Use this to send a packet only, because it also locks out others when probing is restricted.

Parameters

infra	infrastructure cache.
addr	host address.
addrlen	length of addr.
name	domain name of zone.
namelen	length of domain name.
timenow	what time it is now.
edns_vs	edns version it supports, is returned.
edns_lame_known	if EDNS lame (EDNS is dropped in transit) has already been probed, is returned.
to	timeout to use, is returned.

Returns: : 0 on error.

References lruhash_entry::data, data_entry_init(), infra_data::edns_lame_known, infra_data::edns_version, lruhash_entry::hash, infra_cache::hosts, infra_cache::infra_keep_probing, infra_lookup_nottl(), lruhash_entry::lock, new_entry(), PROBE_MAXRTO, infra_data::probedelay, rtt_info::rto, infra_data::rtt, rtt_notimeout(), rtt_timeout(), slabhash_insert(), and USEFUL_SERVER_TOP_TIMEOUT.

Referenced by expon_timeout_backoff(), infra_test(), print_dp_details(), serviced_tcp_send(), and serviced_udp_send().

◆ infra_set_lame()

int infra_set_lame	(	struct infra_cache *	infra,
		struct sockaddr_storage *	addr,
		socklen_t	addrlen,
		uint8_t *	name,
		size_t	namelen,
		time_t	timenow,
		int	dnsseclame,
		int	reclame,
		uint16_t	qtype
	)

Set a host to be lame for the given zone.

Parameters

infra	infrastructure cache.
addr	host address.
addrlen	length of addr.
name	domain name of zone apex.
namelen	length of domain name.
timenow	what time it is now.
dnsseclame	if true the host is set dnssec lame. if false, the host is marked lame (not serving the zone).
reclame	if true host is a recursor not AA server. if false, dnsseclame or marked lame.
qtype	the query type for which it is lame.

Returns: : 0 on error.

References lruhash_entry::data, data_entry_init(), lruhash_entry::hash, infra_cache::hosts, infra_lookup_nottl(), infra_data::isdnsseclame, infra_data::lame_other, infra_data::lame_type_A, LDNS_RR_TYPE_A, lruhash_entry::lock, log_err(), new_entry(), infra_data::rec_lame, and slabhash_insert().

Referenced by infra_test(), and processQueryResponse().

◆ infra_update_tcp_works()

void infra_update_tcp_works	(	struct infra_cache *	infra,
		struct sockaddr_storage *	addr,
		socklen_t	addrlen,
		uint8_t *	name,
		size_t	namelen
	)

Update information for the host, store that a TCP transaction works.

Parameters

infra	infrastructure cache.
addr	host address.
addrlen	length of addr.
name	name of zone
namelen	length of name

References lruhash_entry::data, infra_lookup_nottl(), lruhash_entry::lock, rtt_info::rto, infra_data::rtt, RTT_MAX_TIMEOUT, and still_useful_timeout().

Referenced by serviced_tcp_callback().

◆ infra_rtt_update()

int infra_rtt_update	(	struct infra_cache *	infra,
		struct sockaddr_storage *	addr,
		socklen_t	addrlen,
		uint8_t *	name,
		size_t	namelen,
		int	qtype,
		int	roundtrip,
		int	orig_rtt,
		time_t	timenow
	)

Update rtt information for the host.

Parameters

infra	infrastructure cache.
addr	host address.
addrlen	length of addr.
name	zone name
namelen	zone name length
qtype	query type.
roundtrip	estimate of roundtrip time in milliseconds or -1 for timeout.
orig_rtt	original rtt for the query that timed out (roundtrip==-1). ignored if roundtrip != -1.
timenow	what time it is now.

Returns: : 0 on error. new rto otherwise.

References lruhash_entry::data, data_entry_init(), lruhash_entry::hash, infra_cache::hosts, infra_lookup_nottl(), LDNS_RR_TYPE_A, LDNS_RR_TYPE_AAAA, lruhash_entry::lock, new_entry(), infra_data::probedelay, rtt_info::rto, infra_data::rtt, rtt_init(), rtt_lost(), rtt_unclamped(), rtt_update(), slabhash_insert(), infra_data::timeout_A, infra_data::timeout_AAAA, TIMEOUT_COUNT_MAX, infra_data::timeout_other, and USEFUL_SERVER_TOP_TIMEOUT.

Referenced by do_infra_rtt(), expon_timeout_backoff(), infra_test(), serviced_tcp_callback(), and serviced_udp_callback().

◆ infra_get_host_rto()

long long infra_get_host_rto	(	struct infra_cache *	infra,
		struct sockaddr_storage *	addr,
		socklen_t	addrlen,
		uint8_t *	name,
		size_t	namelen,
		struct rtt_info *	rtt,
		int *	delay,
		time_t	timenow,
		int *	tA,
		int *	tAAAA,
		int *	tother
	)

Get additional (debug) info on timing.

Parameters

infra	infra cache.
addr	host address.
addrlen	length of addr.
name	zone name
namelen	zone name length
rtt	the rtt_info is copied into here (caller alloced return struct).
delay	probe delay (if any).
timenow	what time it is now.
tA	timeout counter on type A.
tAAAA	timeout counter on type AAAA.
tother	timeout counter on type other.

Returns: TTL the infra host element is valid for. If -1: not found in cache. TTL -2: found but expired.

References lruhash_entry::data, infra_lookup_nottl(), lruhash_entry::lock, infra_data::probedelay, infra_data::rtt, infra_data::timeout_A, infra_data::timeout_AAAA, infra_data::timeout_other, and infra_data::ttl.

Referenced by print_dp_details().

◆ infra_edns_update()

int infra_edns_update	(	struct infra_cache *	infra,
		struct sockaddr_storage *	addr,
		socklen_t	addrlen,
		uint8_t *	name,
		size_t	namelen,
		int	edns_version,
		time_t	timenow
	)

Update edns information for the host.

Parameters

infra	infrastructure cache.
addr	host address.
addrlen	length of addr.
name	name of zone
namelen	length of name
edns_version	the version that it publishes. If it is known to support EDNS then no-EDNS is not stored over it.
timenow	what time it is now.

Returns: : 0 on error.

References lruhash_entry::data, data_entry_init(), infra_data::edns_lame_known, infra_data::edns_version, lruhash_entry::hash, infra_cache::hosts, infra_lookup_nottl(), lruhash_entry::lock, new_entry(), and slabhash_insert().

Referenced by infra_test(), serviced_tcp_callback(), and serviced_udp_callback().

◆ infra_get_lame_rtt()

int infra_get_lame_rtt	(	struct infra_cache *	infra,
		struct sockaddr_storage *	addr,
		socklen_t	addrlen,
		uint8_t *	name,
		size_t	namelen,
		uint16_t	qtype,
		int *	lame,
		int *	dnsseclame,
		int *	reclame,
		int *	rtt,
		time_t	timenow
	)

Get Lameness information and average RTT if host is in the cache.

This information is to be used for server selection.

Parameters

infra	infrastructure cache.
addr	host address.
addrlen	length of addr.
name	zone name.
namelen	zone name length.
qtype	the query to be made.
lame	if function returns true, this returns lameness of the zone.
dnsseclame	if function returns true, this returns if the zone is dnssec-lame.
reclame	if function returns true, this is if it is recursion lame.
rtt	if function returns true, this returns avg rtt of the server. The rtt value is unclamped and reflects recent timeouts.
timenow	what time it is now.

Returns: if found in cache, or false if not (or TTL bad).

References lruhash_entry::data, infra_cache::infra_keep_probing, infra_lookup_nottl(), infra_data::isdnsseclame, infra_data::lame_other, infra_data::lame_type_A, LDNS_RR_TYPE_A, LDNS_RR_TYPE_AAAA, lruhash_entry::lock, PROBE_MAXRTO, infra_data::probedelay, infra_data::rec_lame, rtt_info::rto, infra_data::rtt, rtt_notimeout(), rtt_unclamped(), still_useful_timeout(), infra_data::timeout_A, infra_data::timeout_AAAA, TIMEOUT_COUNT_MAX, infra_data::timeout_other, infra_data::ttl, and USEFUL_SERVER_TOP_TIMEOUT.

Referenced by iter_filter_unsuitable(), and print_dp_details().

◆ infra_find_ratelimit()

int infra_find_ratelimit	(	struct infra_cache *	infra,
		uint8_t *	name,
		size_t	namelen
	)

find the ratelimit in qps for a domain.

0 if no limit for domain.

References domain_limit_data::below, dname_count_labels(), infra_cache::domain_limits, infra_dp_ratelimit, name_tree_node::labs, LDNS_RR_CLASS_IN, domain_limit_data::lim, name_tree_lookup(), domain_limit_data::node, and name_tree_node::parent.

Referenced by infra_ratelimit_exceeded(), infra_ratelimit_inc(), and rate_list().

◆ infra_rate_find_second_or_none()

static int * infra_rate_find_second_or_none	(	void *	data,
		time_t	t,
		int	should_add
	)

static

Find the second and return its rate counter.

If none and should_add, remove oldest to accommodate. Else return none.

References rate_data::qps, RATE_WINDOW, and rate_data::timestamp.

Referenced by infra_rate_get_second(), and infra_rate_give_second().

◆ infra_rate_get_second()

static int * infra_rate_get_second	(	void *	data,
		time_t	t
	)

static

find the second and return its rate counter only if it exists.

Caller should check for NULL return value

References infra_rate_find_second_or_none().

Referenced by infra_ratelimit_dec().

◆ infra_rate_max()

int infra_rate_max	(	void *	data,
		time_t	now,
		int	backoff
	)

find the maximum rate stored.

0 if no information. When backoff is enabled look for the maximum in the whole RATE_WINDOW.

References rate_data::qps, RATE_WINDOW, and rate_data::timestamp.

Referenced by infra_ip_ratelimit_inc(), infra_ratelimit_exceeded(), infra_ratelimit_inc(), ip_rate_list(), and rate_list().

◆ infra_ratelimit_inc()

int infra_ratelimit_inc	(	struct infra_cache *	infra,
		uint8_t *	name,
		size_t	namelen,
		time_t	timenow,
		int	backoff,
		struct query_info *	qinfo,
		struct comm_reply *	replylist
	)

Increment the query rate counter for a delegation point.

Parameters

infra	infra cache.
name	zone name
namelen	zone name length
timenow	what time it is now.
backoff	if backoff is enabled.
qinfo	for logging, query name.
replylist	for logging, querier's address (if any).

Returns: 1 if it could be incremented. 0 if the increment overshot the ratelimit or if in the previous second the ratelimit was exceeded. Failures like alloc failures are not returned (probably as 1).

References addr_to_str(), dname_str(), infra_create_ratedata(), infra_dp_ratelimit, infra_find_ratedata(), infra_find_ratelimit(), infra_rate_give_second(), infra_rate_max(), LDNS_MAX_DOMAINLEN, query_info::qclass, query_info::qname, query_info::qtype, comm_reply::remote_addr, comm_reply::remote_addrlen, sldns_wire2str_class_buf(), sldns_wire2str_type_buf(), VERB_OPS, and verbose().

Referenced by outnet_serviced_query().

◆ infra_ratelimit_dec()

void infra_ratelimit_dec	(	struct infra_cache *	infra,
		uint8_t *	name,
		size_t	namelen,
		time_t	timenow
	)

Decrement the query rate counter for a delegation point.

Because the reply received for the delegation point was pleasant, we do not charge this delegation point with it (i.e. it was a referral). Should call it with same second as when inc() was called.

Parameters

infra	infra cache.
name	zone name
namelen	zone name length
timenow	what time it is now.

References infra_dp_ratelimit, infra_find_ratedata(), and infra_rate_get_second().

Referenced by outnet_serviced_query().

◆ infra_ratelimit_exceeded()

int infra_ratelimit_exceeded	(	struct infra_cache *	infra,
		uint8_t *	name,
		size_t	namelen,
		time_t	timenow,
		int	backoff
	)

See if the query rate counter for a delegation point is exceeded.

So, no queries are going to be allowed.

Parameters

infra	infra cache.
name	zone name
namelen	zone name length
timenow	what time it is now.
backoff	if backoff is enabled.

Returns: true if exceeded.

References infra_dp_ratelimit, infra_find_ratedata(), infra_find_ratelimit(), and infra_rate_max().

◆ infra_get_mem()

size_t infra_get_mem ( struct infra_cache * infra )

Get memory used by the infra cache.

Parameters

infra infrastructure cache.

Returns: memory in use in bytes.

References infra_cache::client_ip_rates, infra_cache::domain_rates, infra_cache::hosts, and slabhash_get_mem().

Referenced by worker_mem_report().

◆ infra_ip_ratelimit_inc()

int infra_ip_ratelimit_inc	(	struct infra_cache *	infra,
		struct sockaddr_storage *	addr,
		socklen_t	addrlen,
		time_t	timenow,
		int	has_cookie,
		int	backoff,
		struct sldns_buffer *	buffer
	)

Update query ratelimit hash and decide whether or not a query should be dropped.

Parameters

infra	infra cache
addr	client address
addrlen	client address length
timenow	what time it is now.
has_cookie	if the request came with a DNS Cookie.
backoff	if backoff is enabled.
buffer	with query for logging.

Returns: 1 if it could be incremented. 0 if the increment overshot the ratelimit and the query should be dropped.

References infra_find_ip_ratedata(), infra_ip_create_ratedata(), infra_ip_ratelimit, infra_rate_give_second(), and infra_rate_max().

Variable Documentation

◆ infra_dp_ratelimit

int infra_dp_ratelimit = 0

ratelimit value for delegation point

ratelimit, unless overridden by domain_limits, 0 is off

Referenced by config_set_option(), do_ratelimit_list(), fr_adjust_infra(), infra_adjust(), infra_create(), infra_find_ratelimit(), infra_ratelimit_dec(), infra_ratelimit_exceeded(), and infra_ratelimit_inc().

◆ infra_ip_ratelimit

int infra_ip_ratelimit = 0

ratelimit value for client ip addresses, in queries per second.

ip ratelimit, 0 is off

Referenced by config_set_option(), do_ip_ratelimit_list(), fr_adjust_infra(), infra_adjust(), infra_create(), infra_ip_ratelimit_inc(), and ip_rate_list().

◆ infra_ip_ratelimit_cookie

int infra_ip_ratelimit_cookie = 0

ratelimit value for client ip addresses, in queries per second.

ip ratelimit for DNS Cookie clients, 0 is off

For clients with a valid DNS Cookie.

Referenced by config_set_option(), fr_adjust_infra(), infra_adjust(), and infra_create().

Functions

Variables

Detailed Description

Function Documentation

◆ still_useful_timeout()

◆ infra_create()

◆ infra_delete()

◆ infra_adjust()

◆ infra_lookup_nottl()

◆ new_entry()

◆ infra_host()

◆ infra_set_lame()

◆ infra_update_tcp_works()

◆ infra_rtt_update()

◆ infra_get_host_rto()

◆ infra_edns_update()

◆ infra_get_lame_rtt()

◆ infra_find_ratelimit()

◆ infra_rate_find_second_or_none()

◆ infra_rate_get_second()

◆ infra_rate_max()

◆ infra_ratelimit_inc()

◆ infra_ratelimit_dec()

◆ infra_ratelimit_exceeded()

◆ infra_get_mem()

◆ infra_ip_ratelimit_inc()

Variable Documentation

◆ infra_dp_ratelimit

◆ infra_ip_ratelimit

◆ infra_ip_ratelimit_cookie