xref: /freebsd/contrib/unbound/util/data/msgparse.c (revision 8f76bb7dad48538c6832c2fb466a433d2a3f8cd5)
1b7579f77SDag-Erling Smørgrav /*
2b7579f77SDag-Erling Smørgrav  * util/data/msgparse.c - parse wireformat DNS messages.
3b7579f77SDag-Erling Smørgrav  *
4b7579f77SDag-Erling Smørgrav  * Copyright (c) 2007, NLnet Labs. All rights reserved.
5b7579f77SDag-Erling Smørgrav  *
6b7579f77SDag-Erling Smørgrav  * This software is open source.
7b7579f77SDag-Erling Smørgrav  *
8b7579f77SDag-Erling Smørgrav  * Redistribution and use in source and binary forms, with or without
9b7579f77SDag-Erling Smørgrav  * modification, are permitted provided that the following conditions
10b7579f77SDag-Erling Smørgrav  * are met:
11b7579f77SDag-Erling Smørgrav  *
12b7579f77SDag-Erling Smørgrav  * Redistributions of source code must retain the above copyright notice,
13b7579f77SDag-Erling Smørgrav  * this list of conditions and the following disclaimer.
14b7579f77SDag-Erling Smørgrav  *
15b7579f77SDag-Erling Smørgrav  * Redistributions in binary form must reproduce the above copyright notice,
16b7579f77SDag-Erling Smørgrav  * this list of conditions and the following disclaimer in the documentation
17b7579f77SDag-Erling Smørgrav  * and/or other materials provided with the distribution.
18b7579f77SDag-Erling Smørgrav  *
19b7579f77SDag-Erling Smørgrav  * Neither the name of the NLNET LABS nor the names of its contributors may
20b7579f77SDag-Erling Smørgrav  * be used to endorse or promote products derived from this software without
21b7579f77SDag-Erling Smørgrav  * specific prior written permission.
22b7579f77SDag-Erling Smørgrav  *
23b7579f77SDag-Erling Smørgrav  * THIS SOFTWARE IS PROVIDED BY THE COPYRIGHT HOLDERS AND CONTRIBUTORS
2417d15b25SDag-Erling Smørgrav  * "AS IS" AND ANY EXPRESS OR IMPLIED WARRANTIES, INCLUDING, BUT NOT
2517d15b25SDag-Erling Smørgrav  * LIMITED TO, THE IMPLIED WARRANTIES OF MERCHANTABILITY AND FITNESS FOR
2617d15b25SDag-Erling Smørgrav  * A PARTICULAR PURPOSE ARE DISCLAIMED. IN NO EVENT SHALL THE COPYRIGHT
2717d15b25SDag-Erling Smørgrav  * HOLDER OR CONTRIBUTORS BE LIABLE FOR ANY DIRECT, INDIRECT, INCIDENTAL,
2817d15b25SDag-Erling Smørgrav  * SPECIAL, EXEMPLARY, OR CONSEQUENTIAL DAMAGES (INCLUDING, BUT NOT LIMITED
2917d15b25SDag-Erling Smørgrav  * TO, PROCUREMENT OF SUBSTITUTE GOODS OR SERVICES; LOSS OF USE, DATA, OR
3017d15b25SDag-Erling Smørgrav  * PROFITS; OR BUSINESS INTERRUPTION) HOWEVER CAUSED AND ON ANY THEORY OF
3117d15b25SDag-Erling Smørgrav  * LIABILITY, WHETHER IN CONTRACT, STRICT LIABILITY, OR TORT (INCLUDING
3217d15b25SDag-Erling Smørgrav  * NEGLIGENCE OR OTHERWISE) ARISING IN ANY WAY OUT OF THE USE OF THIS
3317d15b25SDag-Erling Smørgrav  * SOFTWARE, EVEN IF ADVISED OF THE POSSIBILITY OF SUCH DAMAGE.
34b7579f77SDag-Erling Smørgrav  */
35b7579f77SDag-Erling Smørgrav /**
36b7579f77SDag-Erling Smørgrav  * \file
37b7579f77SDag-Erling Smørgrav  * Routines for message parsing a packet buffer to a descriptive structure.
38b7579f77SDag-Erling Smørgrav  */
39b7579f77SDag-Erling Smørgrav #include "config.h"
4024e36522SCy Schubert #include "util/config_file.h"
41b7579f77SDag-Erling Smørgrav #include "util/data/msgparse.h"
42e2d15004SDag-Erling Smørgrav #include "util/data/msgreply.h"
43b7579f77SDag-Erling Smørgrav #include "util/data/dname.h"
44b7579f77SDag-Erling Smørgrav #include "util/data/packed_rrset.h"
4524e36522SCy Schubert #include "util/netevent.h"
46b7579f77SDag-Erling Smørgrav #include "util/storage/lookup3.h"
47b7579f77SDag-Erling Smørgrav #include "util/regional.h"
48*8f76bb7dSCy Schubert #include "util/rfc_1982.h"
49*8f76bb7dSCy Schubert #include "util/edns.h"
5009a3aaf3SDag-Erling Smørgrav #include "sldns/rrdef.h"
5109a3aaf3SDag-Erling Smørgrav #include "sldns/sbuffer.h"
5209a3aaf3SDag-Erling Smørgrav #include "sldns/parseutil.h"
5309a3aaf3SDag-Erling Smørgrav #include "sldns/wire2str.h"
54b7579f77SDag-Erling Smørgrav 
55b7579f77SDag-Erling Smørgrav /** smart comparison of (compressed, valid) dnames from packet */
56b7579f77SDag-Erling Smørgrav static int
5717d15b25SDag-Erling Smørgrav smart_compare(sldns_buffer* pkt, uint8_t* dnow,
58b7579f77SDag-Erling Smørgrav 	uint8_t* dprfirst, uint8_t* dprlast)
59b7579f77SDag-Erling Smørgrav {
60b7579f77SDag-Erling Smørgrav 	if(LABEL_IS_PTR(*dnow)) {
61b7579f77SDag-Erling Smørgrav 		/* ptr points to a previous dname */
62091e9e46SCy Schubert 		uint8_t* p;
63091e9e46SCy Schubert 		if((size_t)PTR_OFFSET(dnow[0], dnow[1])
64091e9e46SCy Schubert 			>= sldns_buffer_limit(pkt))
65091e9e46SCy Schubert 			return -1;
66091e9e46SCy Schubert 		p = sldns_buffer_at(pkt, PTR_OFFSET(dnow[0], dnow[1]));
67b7579f77SDag-Erling Smørgrav 		if( p == dprfirst || p == dprlast )
68b7579f77SDag-Erling Smørgrav 			return 0;
69b7579f77SDag-Erling Smørgrav 		/* prev dname is also a ptr, both ptrs are the same. */
70b7579f77SDag-Erling Smørgrav 		if(LABEL_IS_PTR(*dprlast) &&
71b7579f77SDag-Erling Smørgrav 			dprlast[0] == dnow[0] && dprlast[1] == dnow[1])
72b7579f77SDag-Erling Smørgrav 			return 0;
73b7579f77SDag-Erling Smørgrav 	}
74b7579f77SDag-Erling Smørgrav 	return dname_pkt_compare(pkt, dnow, dprlast);
75b7579f77SDag-Erling Smørgrav }
76b7579f77SDag-Erling Smørgrav 
77b7579f77SDag-Erling Smørgrav /**
78b7579f77SDag-Erling Smørgrav  * Allocate new rrset in region, fill with data.
79b7579f77SDag-Erling Smørgrav  */
80b7579f77SDag-Erling Smørgrav static struct rrset_parse*
81b7579f77SDag-Erling Smørgrav new_rrset(struct msg_parse* msg, uint8_t* dname, size_t dnamelen,
823005e0a3SDag-Erling Smørgrav 	uint16_t type, uint16_t dclass, hashvalue_type hash,
8317d15b25SDag-Erling Smørgrav 	uint32_t rrset_flags, sldns_pkt_section section,
84b7579f77SDag-Erling Smørgrav 	struct regional* region)
85b7579f77SDag-Erling Smørgrav {
86b7579f77SDag-Erling Smørgrav 	struct rrset_parse* p = regional_alloc(region, sizeof(*p));
87b7579f77SDag-Erling Smørgrav 	if(!p) return NULL;
88b7579f77SDag-Erling Smørgrav 	p->rrset_bucket_next = msg->hashtable[hash & (PARSE_TABLE_SIZE-1)];
89b7579f77SDag-Erling Smørgrav 	msg->hashtable[hash & (PARSE_TABLE_SIZE-1)] = p;
90b7579f77SDag-Erling Smørgrav 	p->rrset_all_next = 0;
91b7579f77SDag-Erling Smørgrav 	if(msg->rrset_last)
92b7579f77SDag-Erling Smørgrav 		msg->rrset_last->rrset_all_next = p;
93b7579f77SDag-Erling Smørgrav 	else 	msg->rrset_first = p;
94b7579f77SDag-Erling Smørgrav 	msg->rrset_last = p;
95b7579f77SDag-Erling Smørgrav 	p->hash = hash;
96b7579f77SDag-Erling Smørgrav 	p->section = section;
97b7579f77SDag-Erling Smørgrav 	p->dname = dname;
98b7579f77SDag-Erling Smørgrav 	p->dname_len = dnamelen;
99b7579f77SDag-Erling Smørgrav 	p->type = type;
100b7579f77SDag-Erling Smørgrav 	p->rrset_class = dclass;
101b7579f77SDag-Erling Smørgrav 	p->flags = rrset_flags;
102b7579f77SDag-Erling Smørgrav 	p->rr_count = 0;
103b7579f77SDag-Erling Smørgrav 	p->size = 0;
104b7579f77SDag-Erling Smørgrav 	p->rr_first = 0;
105b7579f77SDag-Erling Smørgrav 	p->rr_last = 0;
106b7579f77SDag-Erling Smørgrav 	p->rrsig_count = 0;
107b7579f77SDag-Erling Smørgrav 	p->rrsig_first = 0;
108b7579f77SDag-Erling Smørgrav 	p->rrsig_last = 0;
109b7579f77SDag-Erling Smørgrav 	return p;
110b7579f77SDag-Erling Smørgrav }
111b7579f77SDag-Erling Smørgrav 
112b7579f77SDag-Erling Smørgrav /** See if next rrset is nsec at zone apex */
113b7579f77SDag-Erling Smørgrav static int
11417d15b25SDag-Erling Smørgrav nsec_at_apex(sldns_buffer* pkt)
115b7579f77SDag-Erling Smørgrav {
116b7579f77SDag-Erling Smørgrav 	/* we are at ttl position in packet. */
11717d15b25SDag-Erling Smørgrav 	size_t pos = sldns_buffer_position(pkt);
118b7579f77SDag-Erling Smørgrav 	uint16_t rdatalen;
11917d15b25SDag-Erling Smørgrav 	if(sldns_buffer_remaining(pkt) < 7) /* ttl+len+root */
120b7579f77SDag-Erling Smørgrav 		return 0; /* eek! */
12117d15b25SDag-Erling Smørgrav 	sldns_buffer_skip(pkt, 4); /* ttl */;
12217d15b25SDag-Erling Smørgrav 	rdatalen = sldns_buffer_read_u16(pkt);
12317d15b25SDag-Erling Smørgrav 	if(sldns_buffer_remaining(pkt) < rdatalen) {
12417d15b25SDag-Erling Smørgrav 		sldns_buffer_set_position(pkt, pos);
125b7579f77SDag-Erling Smørgrav 		return 0; /* parse error happens later */
126b7579f77SDag-Erling Smørgrav 	}
127b7579f77SDag-Erling Smørgrav 	/* must validate the nsec next domain name format */
128b7579f77SDag-Erling Smørgrav 	if(pkt_dname_len(pkt) == 0) {
12917d15b25SDag-Erling Smørgrav 		sldns_buffer_set_position(pkt, pos);
130b7579f77SDag-Erling Smørgrav 		return 0; /* parse error */
131b7579f77SDag-Erling Smørgrav 	}
132b7579f77SDag-Erling Smørgrav 
133b7579f77SDag-Erling Smørgrav 	/* see if SOA bit is set. */
13417d15b25SDag-Erling Smørgrav 	if(sldns_buffer_position(pkt) < pos+4+rdatalen) {
135b7579f77SDag-Erling Smørgrav 		/* nsec type bitmap contains items */
136b7579f77SDag-Erling Smørgrav 		uint8_t win, blen, bits;
137b7579f77SDag-Erling Smørgrav 		/* need: windownum, bitmap len, firstbyte */
13817d15b25SDag-Erling Smørgrav 		if(sldns_buffer_position(pkt)+3 > pos+4+rdatalen) {
13917d15b25SDag-Erling Smørgrav 			sldns_buffer_set_position(pkt, pos);
140b7579f77SDag-Erling Smørgrav 			return 0; /* malformed nsec */
141b7579f77SDag-Erling Smørgrav 		}
14217d15b25SDag-Erling Smørgrav 		win = sldns_buffer_read_u8(pkt);
14317d15b25SDag-Erling Smørgrav 		blen = sldns_buffer_read_u8(pkt);
14417d15b25SDag-Erling Smørgrav 		bits = sldns_buffer_read_u8(pkt);
145b7579f77SDag-Erling Smørgrav 		/* 0window always first window. bitlen >=1 or parse
146b7579f77SDag-Erling Smørgrav 		   error really. bit 0x2 is SOA. */
147b7579f77SDag-Erling Smørgrav 		if(win == 0 && blen >= 1 && (bits & 0x02)) {
14817d15b25SDag-Erling Smørgrav 			sldns_buffer_set_position(pkt, pos);
149b7579f77SDag-Erling Smørgrav 			return 1;
150b7579f77SDag-Erling Smørgrav 		}
151b7579f77SDag-Erling Smørgrav 	}
152b7579f77SDag-Erling Smørgrav 
15317d15b25SDag-Erling Smørgrav 	sldns_buffer_set_position(pkt, pos);
154b7579f77SDag-Erling Smørgrav 	return 0;
155b7579f77SDag-Erling Smørgrav }
156b7579f77SDag-Erling Smørgrav 
157b7579f77SDag-Erling Smørgrav /** Calculate rrset flags */
158b7579f77SDag-Erling Smørgrav static uint32_t
15917d15b25SDag-Erling Smørgrav pkt_rrset_flags(sldns_buffer* pkt, uint16_t type, sldns_pkt_section sec)
160b7579f77SDag-Erling Smørgrav {
161b7579f77SDag-Erling Smørgrav 	uint32_t f = 0;
162b7579f77SDag-Erling Smørgrav 	if(type == LDNS_RR_TYPE_NSEC && nsec_at_apex(pkt)) {
163b7579f77SDag-Erling Smørgrav 		f |= PACKED_RRSET_NSEC_AT_APEX;
164b7579f77SDag-Erling Smørgrav 	} else if(type == LDNS_RR_TYPE_SOA && sec == LDNS_SECTION_AUTHORITY) {
165b7579f77SDag-Erling Smørgrav 		f |= PACKED_RRSET_SOA_NEG;
166b7579f77SDag-Erling Smørgrav 	}
167b7579f77SDag-Erling Smørgrav 	return f;
168b7579f77SDag-Erling Smørgrav }
169b7579f77SDag-Erling Smørgrav 
1703005e0a3SDag-Erling Smørgrav hashvalue_type
17117d15b25SDag-Erling Smørgrav pkt_hash_rrset(sldns_buffer* pkt, uint8_t* dname, uint16_t type,
172b7579f77SDag-Erling Smørgrav 	uint16_t dclass, uint32_t rrset_flags)
173b7579f77SDag-Erling Smørgrav {
174b7579f77SDag-Erling Smørgrav 	/* note this MUST be identical to rrset_key_hash in packed_rrset.c */
175b7579f77SDag-Erling Smørgrav 	/* this routine handles compressed names */
1763005e0a3SDag-Erling Smørgrav 	hashvalue_type h = 0xab;
177b7579f77SDag-Erling Smørgrav 	h = dname_pkt_hash(pkt, dname, h);
178b7579f77SDag-Erling Smørgrav 	h = hashlittle(&type, sizeof(type), h);		/* host order */
179b7579f77SDag-Erling Smørgrav 	h = hashlittle(&dclass, sizeof(dclass), h);	/* netw order */
180b7579f77SDag-Erling Smørgrav 	h = hashlittle(&rrset_flags, sizeof(uint32_t), h);
181b7579f77SDag-Erling Smørgrav 	return h;
182b7579f77SDag-Erling Smørgrav }
183b7579f77SDag-Erling Smørgrav 
184b7579f77SDag-Erling Smørgrav /** create partial dname hash for rrset hash */
1853005e0a3SDag-Erling Smørgrav static hashvalue_type
18617d15b25SDag-Erling Smørgrav pkt_hash_rrset_first(sldns_buffer* pkt, uint8_t* dname)
187b7579f77SDag-Erling Smørgrav {
188b7579f77SDag-Erling Smørgrav 	/* works together with pkt_hash_rrset_rest */
189b7579f77SDag-Erling Smørgrav 	/* note this MUST be identical to rrset_key_hash in packed_rrset.c */
190b7579f77SDag-Erling Smørgrav 	/* this routine handles compressed names */
1913005e0a3SDag-Erling Smørgrav 	hashvalue_type h = 0xab;
192b7579f77SDag-Erling Smørgrav 	h = dname_pkt_hash(pkt, dname, h);
193b7579f77SDag-Erling Smørgrav 	return h;
194b7579f77SDag-Erling Smørgrav }
195b7579f77SDag-Erling Smørgrav 
196b7579f77SDag-Erling Smørgrav /** create a rrset hash from a partial dname hash */
1973005e0a3SDag-Erling Smørgrav static hashvalue_type
1983005e0a3SDag-Erling Smørgrav pkt_hash_rrset_rest(hashvalue_type dname_h, uint16_t type, uint16_t dclass,
199b7579f77SDag-Erling Smørgrav 	uint32_t rrset_flags)
200b7579f77SDag-Erling Smørgrav {
201b7579f77SDag-Erling Smørgrav 	/* works together with pkt_hash_rrset_first */
202b7579f77SDag-Erling Smørgrav 	/* note this MUST be identical to rrset_key_hash in packed_rrset.c */
2033005e0a3SDag-Erling Smørgrav 	hashvalue_type h;
204b7579f77SDag-Erling Smørgrav 	h = hashlittle(&type, sizeof(type), dname_h);	/* host order */
205b7579f77SDag-Erling Smørgrav 	h = hashlittle(&dclass, sizeof(dclass), h);	/* netw order */
206b7579f77SDag-Erling Smørgrav 	h = hashlittle(&rrset_flags, sizeof(uint32_t), h);
207b7579f77SDag-Erling Smørgrav 	return h;
208b7579f77SDag-Erling Smørgrav }
209b7579f77SDag-Erling Smørgrav 
210b7579f77SDag-Erling Smørgrav /** compare rrset_parse with data */
211b7579f77SDag-Erling Smørgrav static int
2123005e0a3SDag-Erling Smørgrav rrset_parse_equals(struct rrset_parse* p, sldns_buffer* pkt, hashvalue_type h,
213b7579f77SDag-Erling Smørgrav 	uint32_t rrset_flags, uint8_t* dname, size_t dnamelen,
214b7579f77SDag-Erling Smørgrav 	uint16_t type, uint16_t dclass)
215b7579f77SDag-Erling Smørgrav {
216b7579f77SDag-Erling Smørgrav 	if(p->hash == h && p->dname_len == dnamelen && p->type == type &&
217b7579f77SDag-Erling Smørgrav 		p->rrset_class == dclass && p->flags == rrset_flags &&
218b7579f77SDag-Erling Smørgrav 		dname_pkt_compare(pkt, dname, p->dname) == 0)
219b7579f77SDag-Erling Smørgrav 		return 1;
220b7579f77SDag-Erling Smørgrav 	return 0;
221b7579f77SDag-Erling Smørgrav }
222b7579f77SDag-Erling Smørgrav 
223b7579f77SDag-Erling Smørgrav 
224b7579f77SDag-Erling Smørgrav struct rrset_parse*
22517d15b25SDag-Erling Smørgrav msgparse_hashtable_lookup(struct msg_parse* msg, sldns_buffer* pkt,
2263005e0a3SDag-Erling Smørgrav 	hashvalue_type h, uint32_t rrset_flags, uint8_t* dname,
2273005e0a3SDag-Erling Smørgrav 	size_t dnamelen, uint16_t type, uint16_t dclass)
228b7579f77SDag-Erling Smørgrav {
229b7579f77SDag-Erling Smørgrav 	struct rrset_parse* p = msg->hashtable[h & (PARSE_TABLE_SIZE-1)];
230b7579f77SDag-Erling Smørgrav 	while(p) {
231b7579f77SDag-Erling Smørgrav 		if(rrset_parse_equals(p, pkt, h, rrset_flags, dname, dnamelen,
232b7579f77SDag-Erling Smørgrav 			type, dclass))
233b7579f77SDag-Erling Smørgrav 			return p;
234b7579f77SDag-Erling Smørgrav 		p = p->rrset_bucket_next;
235b7579f77SDag-Erling Smørgrav 	}
236b7579f77SDag-Erling Smørgrav 	return NULL;
237b7579f77SDag-Erling Smørgrav }
238b7579f77SDag-Erling Smørgrav 
239b7579f77SDag-Erling Smørgrav /** return type networkformat that rrsig in packet covers */
240b7579f77SDag-Erling Smørgrav static int
24117d15b25SDag-Erling Smørgrav pkt_rrsig_covered(sldns_buffer* pkt, uint8_t* here, uint16_t* type)
242b7579f77SDag-Erling Smørgrav {
24317d15b25SDag-Erling Smørgrav 	size_t pos = sldns_buffer_position(pkt);
24417d15b25SDag-Erling Smørgrav 	sldns_buffer_set_position(pkt, (size_t)(here-sldns_buffer_begin(pkt)));
245b7579f77SDag-Erling Smørgrav 	/* ttl + len + size of small rrsig(rootlabel, no signature) */
24617d15b25SDag-Erling Smørgrav 	if(sldns_buffer_remaining(pkt) < 4+2+19)
247b7579f77SDag-Erling Smørgrav 		return 0;
24817d15b25SDag-Erling Smørgrav 	sldns_buffer_skip(pkt, 4); /* ttl */
24917d15b25SDag-Erling Smørgrav 	if(sldns_buffer_read_u16(pkt) < 19) /* too short */ {
25017d15b25SDag-Erling Smørgrav 		sldns_buffer_set_position(pkt, pos);
251b7579f77SDag-Erling Smørgrav 		return 0;
252b7579f77SDag-Erling Smørgrav 	}
25317d15b25SDag-Erling Smørgrav 	*type = sldns_buffer_read_u16(pkt);
25417d15b25SDag-Erling Smørgrav 	sldns_buffer_set_position(pkt, pos);
255b7579f77SDag-Erling Smørgrav 	return 1;
256b7579f77SDag-Erling Smørgrav }
257b7579f77SDag-Erling Smørgrav 
258b7579f77SDag-Erling Smørgrav /** true if covered type equals prevtype */
259b7579f77SDag-Erling Smørgrav static int
26017d15b25SDag-Erling Smørgrav pkt_rrsig_covered_equals(sldns_buffer* pkt, uint8_t* here, uint16_t type)
261b7579f77SDag-Erling Smørgrav {
262b7579f77SDag-Erling Smørgrav 	uint16_t t;
263b7579f77SDag-Erling Smørgrav 	if(pkt_rrsig_covered(pkt, here, &t) && t == type)
264b7579f77SDag-Erling Smørgrav 		return 1;
265b7579f77SDag-Erling Smørgrav 	return 0;
266b7579f77SDag-Erling Smørgrav }
267b7579f77SDag-Erling Smørgrav 
268b7579f77SDag-Erling Smørgrav void
269b7579f77SDag-Erling Smørgrav msgparse_bucket_remove(struct msg_parse* msg, struct rrset_parse* rrset)
270b7579f77SDag-Erling Smørgrav {
271b7579f77SDag-Erling Smørgrav 	struct rrset_parse** p;
272b7579f77SDag-Erling Smørgrav 	p = &msg->hashtable[ rrset->hash & (PARSE_TABLE_SIZE-1) ];
273b7579f77SDag-Erling Smørgrav 	while(*p) {
274b7579f77SDag-Erling Smørgrav 		if(*p == rrset) {
275b7579f77SDag-Erling Smørgrav 			*p = rrset->rrset_bucket_next;
276b7579f77SDag-Erling Smørgrav 			return;
277b7579f77SDag-Erling Smørgrav 		}
278b7579f77SDag-Erling Smørgrav 		p = &( (*p)->rrset_bucket_next );
279b7579f77SDag-Erling Smørgrav 	}
280b7579f77SDag-Erling Smørgrav }
281b7579f77SDag-Erling Smørgrav 
282b7579f77SDag-Erling Smørgrav /** change section of rrset from previous to current section */
283b7579f77SDag-Erling Smørgrav static void
284b7579f77SDag-Erling Smørgrav change_section(struct msg_parse* msg, struct rrset_parse* rrset,
28517d15b25SDag-Erling Smørgrav 	sldns_pkt_section section)
286b7579f77SDag-Erling Smørgrav {
287b7579f77SDag-Erling Smørgrav 	struct rrset_parse *p, *prev;
288b7579f77SDag-Erling Smørgrav 	/* remove from list */
289b7579f77SDag-Erling Smørgrav 	if(section == rrset->section)
290b7579f77SDag-Erling Smørgrav 		return;
291b7579f77SDag-Erling Smørgrav 	p = msg->rrset_first;
292b7579f77SDag-Erling Smørgrav 	prev = 0;
293b7579f77SDag-Erling Smørgrav 	while(p) {
294b7579f77SDag-Erling Smørgrav 		if(p == rrset) {
295b7579f77SDag-Erling Smørgrav 			if(prev) prev->rrset_all_next = p->rrset_all_next;
296b7579f77SDag-Erling Smørgrav 			else	msg->rrset_first = p->rrset_all_next;
297b7579f77SDag-Erling Smørgrav 			if(msg->rrset_last == rrset)
298b7579f77SDag-Erling Smørgrav 				msg->rrset_last = prev;
299b7579f77SDag-Erling Smørgrav 			break;
300b7579f77SDag-Erling Smørgrav 		}
301b7579f77SDag-Erling Smørgrav 		prev = p;
302b7579f77SDag-Erling Smørgrav 		p = p->rrset_all_next;
303b7579f77SDag-Erling Smørgrav 	}
304b7579f77SDag-Erling Smørgrav 	/* remove from count */
305b7579f77SDag-Erling Smørgrav 	switch(rrset->section) {
306b7579f77SDag-Erling Smørgrav 		case LDNS_SECTION_ANSWER: msg->an_rrsets--; break;
307b7579f77SDag-Erling Smørgrav 		case LDNS_SECTION_AUTHORITY: msg->ns_rrsets--; break;
308b7579f77SDag-Erling Smørgrav 		case LDNS_SECTION_ADDITIONAL: msg->ar_rrsets--; break;
309b7579f77SDag-Erling Smørgrav 		default: log_assert(0);
310b7579f77SDag-Erling Smørgrav 	}
311b7579f77SDag-Erling Smørgrav 	/* insert at end of list */
312b7579f77SDag-Erling Smørgrav 	rrset->rrset_all_next = 0;
313b7579f77SDag-Erling Smørgrav 	if(msg->rrset_last)
314b7579f77SDag-Erling Smørgrav 		msg->rrset_last->rrset_all_next = rrset;
315b7579f77SDag-Erling Smørgrav 	else	msg->rrset_first = rrset;
316b7579f77SDag-Erling Smørgrav 	msg->rrset_last = rrset;
317b7579f77SDag-Erling Smørgrav 	/* up count of new section */
318b7579f77SDag-Erling Smørgrav 	switch(section) {
319b7579f77SDag-Erling Smørgrav 		case LDNS_SECTION_AUTHORITY: msg->ns_rrsets++; break;
320b7579f77SDag-Erling Smørgrav 		case LDNS_SECTION_ADDITIONAL: msg->ar_rrsets++; break;
321b7579f77SDag-Erling Smørgrav 		default: log_assert(0);
322b7579f77SDag-Erling Smørgrav 	}
323b7579f77SDag-Erling Smørgrav 	rrset->section = section;
324b7579f77SDag-Erling Smørgrav }
325b7579f77SDag-Erling Smørgrav 
326b7579f77SDag-Erling Smørgrav /** see if rrset of type RRSIG contains sig over given type */
327b7579f77SDag-Erling Smørgrav static int
32817d15b25SDag-Erling Smørgrav rrset_has_sigover(sldns_buffer* pkt, struct rrset_parse* rrset, uint16_t type,
329b7579f77SDag-Erling Smørgrav 	int* hasother)
330b7579f77SDag-Erling Smørgrav {
331b7579f77SDag-Erling Smørgrav 	int res = 0;
332b7579f77SDag-Erling Smørgrav 	struct rr_parse* rr = rrset->rr_first;
333b7579f77SDag-Erling Smørgrav 	log_assert( rrset->type == LDNS_RR_TYPE_RRSIG );
334b7579f77SDag-Erling Smørgrav 	while(rr) {
335b7579f77SDag-Erling Smørgrav 		if(pkt_rrsig_covered_equals(pkt, rr->ttl_data, type))
336b7579f77SDag-Erling Smørgrav 			res = 1;
337b7579f77SDag-Erling Smørgrav 		else	*hasother = 1;
338b7579f77SDag-Erling Smørgrav 		rr = rr->next;
339b7579f77SDag-Erling Smørgrav 	}
340b7579f77SDag-Erling Smørgrav 	return res;
341b7579f77SDag-Erling Smørgrav }
342b7579f77SDag-Erling Smørgrav 
343b7579f77SDag-Erling Smørgrav /** move rrsigs from sigset to dataset */
344b7579f77SDag-Erling Smørgrav static int
34517d15b25SDag-Erling Smørgrav moveover_rrsigs(sldns_buffer* pkt, struct regional* region,
346b7579f77SDag-Erling Smørgrav 	struct rrset_parse* sigset, struct rrset_parse* dataset, int duplicate)
347b7579f77SDag-Erling Smørgrav {
348b7579f77SDag-Erling Smørgrav 	struct rr_parse* sig = sigset->rr_first;
349b7579f77SDag-Erling Smørgrav 	struct rr_parse* prev = NULL;
350b7579f77SDag-Erling Smørgrav 	struct rr_parse* insert;
351b7579f77SDag-Erling Smørgrav 	struct rr_parse* nextsig;
352b7579f77SDag-Erling Smørgrav 	while(sig) {
353b7579f77SDag-Erling Smørgrav 		nextsig = sig->next;
354b7579f77SDag-Erling Smørgrav 		if(pkt_rrsig_covered_equals(pkt, sig->ttl_data,
355b7579f77SDag-Erling Smørgrav 			dataset->type)) {
356b7579f77SDag-Erling Smørgrav 			if(duplicate) {
357b7579f77SDag-Erling Smørgrav 				/* new */
358b7579f77SDag-Erling Smørgrav 				insert = (struct rr_parse*)regional_alloc(
359b7579f77SDag-Erling Smørgrav 					region, sizeof(struct rr_parse));
360b7579f77SDag-Erling Smørgrav 				if(!insert) return 0;
361b7579f77SDag-Erling Smørgrav 				insert->outside_packet = 0;
362b7579f77SDag-Erling Smørgrav 				insert->ttl_data = sig->ttl_data;
363b7579f77SDag-Erling Smørgrav 				insert->size = sig->size;
364b7579f77SDag-Erling Smørgrav 				/* prev not used */
365b7579f77SDag-Erling Smørgrav 			} else {
366b7579f77SDag-Erling Smørgrav 				/* remove from sigset */
367b7579f77SDag-Erling Smørgrav 				if(prev) prev->next = sig->next;
368b7579f77SDag-Erling Smørgrav 				else	sigset->rr_first = sig->next;
369b7579f77SDag-Erling Smørgrav 				if(sigset->rr_last == sig)
370b7579f77SDag-Erling Smørgrav 					sigset->rr_last = prev;
371b7579f77SDag-Erling Smørgrav 				sigset->rr_count--;
372b7579f77SDag-Erling Smørgrav 				sigset->size -= sig->size;
373b7579f77SDag-Erling Smørgrav 				insert = sig;
374b7579f77SDag-Erling Smørgrav 				/* prev not changed */
375b7579f77SDag-Erling Smørgrav 			}
376b7579f77SDag-Erling Smørgrav 			/* add to dataset */
377b7579f77SDag-Erling Smørgrav 			dataset->rrsig_count++;
378b7579f77SDag-Erling Smørgrav 			insert->next = 0;
379b7579f77SDag-Erling Smørgrav 			if(dataset->rrsig_last)
380b7579f77SDag-Erling Smørgrav 				dataset->rrsig_last->next = insert;
381b7579f77SDag-Erling Smørgrav 			else	dataset->rrsig_first = insert;
382b7579f77SDag-Erling Smørgrav 			dataset->rrsig_last = insert;
383b7579f77SDag-Erling Smørgrav 			dataset->size += insert->size;
384b7579f77SDag-Erling Smørgrav 		} else  {
385b7579f77SDag-Erling Smørgrav 			prev = sig;
386b7579f77SDag-Erling Smørgrav 		}
387b7579f77SDag-Erling Smørgrav 		sig = nextsig;
388b7579f77SDag-Erling Smørgrav 	}
389b7579f77SDag-Erling Smørgrav 	return 1;
390b7579f77SDag-Erling Smørgrav }
391b7579f77SDag-Erling Smørgrav 
392b7579f77SDag-Erling Smørgrav /** change an rrsig rrset for use as data rrset */
393b7579f77SDag-Erling Smørgrav static struct rrset_parse*
394b7579f77SDag-Erling Smørgrav change_rrsig_rrset(struct rrset_parse* sigset, struct msg_parse* msg,
39517d15b25SDag-Erling Smørgrav 	sldns_buffer* pkt, uint16_t datatype, uint32_t rrset_flags,
39617d15b25SDag-Erling Smørgrav 	int hasother, sldns_pkt_section section, struct regional* region)
397b7579f77SDag-Erling Smørgrav {
398b7579f77SDag-Erling Smørgrav 	struct rrset_parse* dataset = sigset;
3993005e0a3SDag-Erling Smørgrav 	hashvalue_type hash = pkt_hash_rrset(pkt, sigset->dname, datatype,
400b7579f77SDag-Erling Smørgrav 		sigset->rrset_class, rrset_flags);
401b7579f77SDag-Erling Smørgrav 	log_assert( sigset->type == LDNS_RR_TYPE_RRSIG );
402b7579f77SDag-Erling Smørgrav 	log_assert( datatype != LDNS_RR_TYPE_RRSIG );
403b7579f77SDag-Erling Smørgrav 	if(hasother) {
404b7579f77SDag-Erling Smørgrav 		/* need to make new rrset to hold data type */
405b7579f77SDag-Erling Smørgrav 		dataset = new_rrset(msg, sigset->dname, sigset->dname_len,
406b7579f77SDag-Erling Smørgrav 			datatype, sigset->rrset_class, hash, rrset_flags,
407b7579f77SDag-Erling Smørgrav 			section, region);
408b7579f77SDag-Erling Smørgrav 		if(!dataset)
409b7579f77SDag-Erling Smørgrav 			return NULL;
410b7579f77SDag-Erling Smørgrav 		switch(section) {
411b7579f77SDag-Erling Smørgrav 			case LDNS_SECTION_ANSWER: msg->an_rrsets++; break;
412b7579f77SDag-Erling Smørgrav 			case LDNS_SECTION_AUTHORITY: msg->ns_rrsets++; break;
413b7579f77SDag-Erling Smørgrav 			case LDNS_SECTION_ADDITIONAL: msg->ar_rrsets++; break;
414b7579f77SDag-Erling Smørgrav 			default: log_assert(0);
415b7579f77SDag-Erling Smørgrav 		}
416b7579f77SDag-Erling Smørgrav 		if(!moveover_rrsigs(pkt, region, sigset, dataset,
417b7579f77SDag-Erling Smørgrav 			msg->qtype == LDNS_RR_TYPE_RRSIG ||
418b7579f77SDag-Erling Smørgrav 			(msg->qtype == LDNS_RR_TYPE_ANY &&
419b7579f77SDag-Erling Smørgrav 			section != LDNS_SECTION_ANSWER) ))
420b7579f77SDag-Erling Smørgrav 			return NULL;
421b7579f77SDag-Erling Smørgrav 		return dataset;
422b7579f77SDag-Erling Smørgrav 	}
423b7579f77SDag-Erling Smørgrav 	/* changeover the type of the rrset to data set */
424b7579f77SDag-Erling Smørgrav 	msgparse_bucket_remove(msg, dataset);
425b7579f77SDag-Erling Smørgrav 	/* insert into new hash bucket */
426b7579f77SDag-Erling Smørgrav 	dataset->rrset_bucket_next = msg->hashtable[hash&(PARSE_TABLE_SIZE-1)];
427b7579f77SDag-Erling Smørgrav 	msg->hashtable[hash&(PARSE_TABLE_SIZE-1)] = dataset;
428b7579f77SDag-Erling Smørgrav 	dataset->hash = hash;
429b7579f77SDag-Erling Smørgrav 	/* use section of data item for result */
430b7579f77SDag-Erling Smørgrav 	change_section(msg, dataset, section);
431b7579f77SDag-Erling Smørgrav 	dataset->type = datatype;
432b7579f77SDag-Erling Smørgrav 	dataset->flags = rrset_flags;
433b7579f77SDag-Erling Smørgrav 	dataset->rrsig_count += dataset->rr_count;
434b7579f77SDag-Erling Smørgrav 	dataset->rr_count = 0;
435b7579f77SDag-Erling Smørgrav 	/* move sigs to end of siglist */
436b7579f77SDag-Erling Smørgrav 	if(dataset->rrsig_last)
437b7579f77SDag-Erling Smørgrav 		dataset->rrsig_last->next = dataset->rr_first;
438b7579f77SDag-Erling Smørgrav 	else	dataset->rrsig_first = dataset->rr_first;
439b7579f77SDag-Erling Smørgrav 	dataset->rrsig_last = dataset->rr_last;
440b7579f77SDag-Erling Smørgrav 	dataset->rr_first = 0;
441b7579f77SDag-Erling Smørgrav 	dataset->rr_last = 0;
442b7579f77SDag-Erling Smørgrav 	return dataset;
443b7579f77SDag-Erling Smørgrav }
444b7579f77SDag-Erling Smørgrav 
445b7579f77SDag-Erling Smørgrav /** Find rrset. If equal to previous it is fast. hash if not so.
446b7579f77SDag-Erling Smørgrav  * @param msg: the message with hash table.
447b7579f77SDag-Erling Smørgrav  * @param pkt: the packet in wireformat (needed for compression ptrs).
448b7579f77SDag-Erling Smørgrav  * @param dname: pointer to start of dname (compressed) in packet.
449b7579f77SDag-Erling Smørgrav  * @param dnamelen: uncompressed wirefmt length of dname.
450b7579f77SDag-Erling Smørgrav  * @param type: type of current rr.
451b7579f77SDag-Erling Smørgrav  * @param dclass: class of current rr.
452b7579f77SDag-Erling Smørgrav  * @param hash: hash value is returned if the rrset could not be found.
453b7579f77SDag-Erling Smørgrav  * @param rrset_flags: is returned if the rrset could not be found.
454b7579f77SDag-Erling Smørgrav  * @param prev_dname_first: dname of last seen RR. First seen dname.
455b7579f77SDag-Erling Smørgrav  * @param prev_dname_last: dname of last seen RR. Last seen dname.
456b7579f77SDag-Erling Smørgrav  * @param prev_dnamelen: dname len of last seen RR.
457b7579f77SDag-Erling Smørgrav  * @param prev_type: type of last seen RR.
458b7579f77SDag-Erling Smørgrav  * @param prev_dclass: class of last seen RR.
459b7579f77SDag-Erling Smørgrav  * @param rrset_prev: last seen RRset.
460b7579f77SDag-Erling Smørgrav  * @param section: the current section in the packet.
461b7579f77SDag-Erling Smørgrav  * @param region: used to allocate temporary parsing data.
462b7579f77SDag-Erling Smørgrav  * @return 0 on out of memory.
463b7579f77SDag-Erling Smørgrav  */
464b7579f77SDag-Erling Smørgrav static int
46517d15b25SDag-Erling Smørgrav find_rrset(struct msg_parse* msg, sldns_buffer* pkt, uint8_t* dname,
4663005e0a3SDag-Erling Smørgrav 	size_t dnamelen, uint16_t type, uint16_t dclass, hashvalue_type* hash,
467b7579f77SDag-Erling Smørgrav 	uint32_t* rrset_flags,
468b7579f77SDag-Erling Smørgrav 	uint8_t** prev_dname_first, uint8_t** prev_dname_last,
469b7579f77SDag-Erling Smørgrav 	size_t* prev_dnamelen, uint16_t* prev_type,
470b7579f77SDag-Erling Smørgrav 	uint16_t* prev_dclass, struct rrset_parse** rrset_prev,
47117d15b25SDag-Erling Smørgrav 	sldns_pkt_section section, struct regional* region)
472b7579f77SDag-Erling Smørgrav {
4733005e0a3SDag-Erling Smørgrav 	hashvalue_type dname_h = pkt_hash_rrset_first(pkt, dname);
474b7579f77SDag-Erling Smørgrav 	uint16_t covtype;
475b7579f77SDag-Erling Smørgrav 	if(*rrset_prev) {
476b7579f77SDag-Erling Smørgrav 		/* check if equal to previous item */
477b7579f77SDag-Erling Smørgrav 		if(type == *prev_type && dclass == *prev_dclass &&
478b7579f77SDag-Erling Smørgrav 			dnamelen == *prev_dnamelen &&
479b7579f77SDag-Erling Smørgrav 			smart_compare(pkt, dname, *prev_dname_first,
480b7579f77SDag-Erling Smørgrav 				*prev_dname_last) == 0 &&
481b7579f77SDag-Erling Smørgrav 			type != LDNS_RR_TYPE_RRSIG) {
482b7579f77SDag-Erling Smørgrav 			/* same as previous */
483b7579f77SDag-Erling Smørgrav 			*prev_dname_last = dname;
484b7579f77SDag-Erling Smørgrav 			return 1;
485b7579f77SDag-Erling Smørgrav 		}
486b7579f77SDag-Erling Smørgrav 		/* check if rrsig over previous item */
487b7579f77SDag-Erling Smørgrav 		if(type == LDNS_RR_TYPE_RRSIG && dclass == *prev_dclass &&
48817d15b25SDag-Erling Smørgrav 			pkt_rrsig_covered_equals(pkt, sldns_buffer_current(pkt),
489b7579f77SDag-Erling Smørgrav 				*prev_type) &&
490b7579f77SDag-Erling Smørgrav 			smart_compare(pkt, dname, *prev_dname_first,
491b7579f77SDag-Erling Smørgrav 				*prev_dname_last) == 0) {
492b7579f77SDag-Erling Smørgrav 			/* covers previous */
493b7579f77SDag-Erling Smørgrav 			*prev_dname_last = dname;
494b7579f77SDag-Erling Smørgrav 			return 1;
495b7579f77SDag-Erling Smørgrav 		}
496b7579f77SDag-Erling Smørgrav 	}
497b7579f77SDag-Erling Smørgrav 	/* find by hashing and lookup in hashtable */
498b7579f77SDag-Erling Smørgrav 	*rrset_flags = pkt_rrset_flags(pkt, type, section);
499b7579f77SDag-Erling Smørgrav 
500b7579f77SDag-Erling Smørgrav 	/* if rrsig - try to lookup matching data set first */
501b7579f77SDag-Erling Smørgrav 	if(type == LDNS_RR_TYPE_RRSIG && pkt_rrsig_covered(pkt,
50217d15b25SDag-Erling Smørgrav 		sldns_buffer_current(pkt), &covtype)) {
503b7579f77SDag-Erling Smørgrav 		*hash = pkt_hash_rrset_rest(dname_h, covtype, dclass,
504b7579f77SDag-Erling Smørgrav 			*rrset_flags);
505b7579f77SDag-Erling Smørgrav 		*rrset_prev = msgparse_hashtable_lookup(msg, pkt, *hash,
506b7579f77SDag-Erling Smørgrav 			*rrset_flags, dname, dnamelen, covtype, dclass);
507b7579f77SDag-Erling Smørgrav 		if(!*rrset_prev && covtype == LDNS_RR_TYPE_NSEC) {
508b7579f77SDag-Erling Smørgrav 			/* if NSEC try with NSEC apex bit twiddled */
509b7579f77SDag-Erling Smørgrav 			*rrset_flags ^= PACKED_RRSET_NSEC_AT_APEX;
510b7579f77SDag-Erling Smørgrav 			*hash = pkt_hash_rrset_rest(dname_h, covtype, dclass,
511b7579f77SDag-Erling Smørgrav 				*rrset_flags);
512b7579f77SDag-Erling Smørgrav 			*rrset_prev = msgparse_hashtable_lookup(msg, pkt,
513b7579f77SDag-Erling Smørgrav 				*hash, *rrset_flags, dname, dnamelen, covtype,
514b7579f77SDag-Erling Smørgrav 				dclass);
515b7579f77SDag-Erling Smørgrav 			if(!*rrset_prev) /* untwiddle if not found */
516b7579f77SDag-Erling Smørgrav 				*rrset_flags ^= PACKED_RRSET_NSEC_AT_APEX;
517b7579f77SDag-Erling Smørgrav 		}
518b7579f77SDag-Erling Smørgrav 		if(!*rrset_prev && covtype == LDNS_RR_TYPE_SOA) {
519b7579f77SDag-Erling Smørgrav 			/* if SOA try with SOA neg flag twiddled */
520b7579f77SDag-Erling Smørgrav 			*rrset_flags ^= PACKED_RRSET_SOA_NEG;
521b7579f77SDag-Erling Smørgrav 			*hash = pkt_hash_rrset_rest(dname_h, covtype, dclass,
522b7579f77SDag-Erling Smørgrav 				*rrset_flags);
523b7579f77SDag-Erling Smørgrav 			*rrset_prev = msgparse_hashtable_lookup(msg, pkt,
524b7579f77SDag-Erling Smørgrav 				*hash, *rrset_flags, dname, dnamelen, covtype,
525b7579f77SDag-Erling Smørgrav 				dclass);
526b7579f77SDag-Erling Smørgrav 			if(!*rrset_prev) /* untwiddle if not found */
527b7579f77SDag-Erling Smørgrav 				*rrset_flags ^= PACKED_RRSET_SOA_NEG;
528b7579f77SDag-Erling Smørgrav 		}
529b7579f77SDag-Erling Smørgrav 		if(*rrset_prev) {
530b7579f77SDag-Erling Smørgrav 			*prev_dname_first = (*rrset_prev)->dname;
531b7579f77SDag-Erling Smørgrav 			*prev_dname_last = dname;
532b7579f77SDag-Erling Smørgrav 			*prev_dnamelen = dnamelen;
533b7579f77SDag-Erling Smørgrav 			*prev_type = covtype;
534b7579f77SDag-Erling Smørgrav 			*prev_dclass = dclass;
535b7579f77SDag-Erling Smørgrav 			return 1;
536b7579f77SDag-Erling Smørgrav 		}
537b7579f77SDag-Erling Smørgrav 	}
538b7579f77SDag-Erling Smørgrav 	if(type != LDNS_RR_TYPE_RRSIG) {
539b7579f77SDag-Erling Smørgrav 		int hasother = 0;
540b7579f77SDag-Erling Smørgrav 		/* find matching rrsig */
541b7579f77SDag-Erling Smørgrav 		*hash = pkt_hash_rrset_rest(dname_h, LDNS_RR_TYPE_RRSIG,
542b7579f77SDag-Erling Smørgrav 			dclass, 0);
543b7579f77SDag-Erling Smørgrav 		*rrset_prev = msgparse_hashtable_lookup(msg, pkt, *hash,
544b7579f77SDag-Erling Smørgrav 			0, dname, dnamelen, LDNS_RR_TYPE_RRSIG,
545b7579f77SDag-Erling Smørgrav 			dclass);
546b7579f77SDag-Erling Smørgrav 		if(*rrset_prev && rrset_has_sigover(pkt, *rrset_prev, type,
547b7579f77SDag-Erling Smørgrav 			&hasother)) {
548b7579f77SDag-Erling Smørgrav 			/* yes! */
549b7579f77SDag-Erling Smørgrav 			*prev_dname_first = (*rrset_prev)->dname;
550b7579f77SDag-Erling Smørgrav 			*prev_dname_last = dname;
551b7579f77SDag-Erling Smørgrav 			*prev_dnamelen = dnamelen;
552b7579f77SDag-Erling Smørgrav 			*prev_type = type;
553b7579f77SDag-Erling Smørgrav 			*prev_dclass = dclass;
554b7579f77SDag-Erling Smørgrav 			*rrset_prev = change_rrsig_rrset(*rrset_prev, msg,
555b7579f77SDag-Erling Smørgrav 				pkt, type, *rrset_flags, hasother, section,
556b7579f77SDag-Erling Smørgrav 				region);
557b7579f77SDag-Erling Smørgrav 			if(!*rrset_prev) return 0;
558b7579f77SDag-Erling Smørgrav 			return 1;
559b7579f77SDag-Erling Smørgrav 		}
560b7579f77SDag-Erling Smørgrav 	}
561b7579f77SDag-Erling Smørgrav 
562b7579f77SDag-Erling Smørgrav 	*hash = pkt_hash_rrset_rest(dname_h, type, dclass, *rrset_flags);
563b7579f77SDag-Erling Smørgrav 	*rrset_prev = msgparse_hashtable_lookup(msg, pkt, *hash, *rrset_flags,
564b7579f77SDag-Erling Smørgrav 		dname, dnamelen, type, dclass);
565b7579f77SDag-Erling Smørgrav 	if(*rrset_prev)
566b7579f77SDag-Erling Smørgrav 		*prev_dname_first = (*rrset_prev)->dname;
567b7579f77SDag-Erling Smørgrav 	else 	*prev_dname_first = dname;
568b7579f77SDag-Erling Smørgrav 	*prev_dname_last = dname;
569b7579f77SDag-Erling Smørgrav 	*prev_dnamelen = dnamelen;
570b7579f77SDag-Erling Smørgrav 	*prev_type = type;
571b7579f77SDag-Erling Smørgrav 	*prev_dclass = dclass;
572b7579f77SDag-Erling Smørgrav 	return 1;
573b7579f77SDag-Erling Smørgrav }
574b7579f77SDag-Erling Smørgrav 
575b7579f77SDag-Erling Smørgrav /**
576b7579f77SDag-Erling Smørgrav  * Parse query section.
577b7579f77SDag-Erling Smørgrav  * @param pkt: packet, position at call must be at start of query section.
578b7579f77SDag-Erling Smørgrav  *	at end position is after query section.
579b7579f77SDag-Erling Smørgrav  * @param msg: store results here.
580b7579f77SDag-Erling Smørgrav  * @return: 0 if OK, or rcode on error.
581b7579f77SDag-Erling Smørgrav  */
582b7579f77SDag-Erling Smørgrav static int
58317d15b25SDag-Erling Smørgrav parse_query_section(sldns_buffer* pkt, struct msg_parse* msg)
584b7579f77SDag-Erling Smørgrav {
585b7579f77SDag-Erling Smørgrav 	if(msg->qdcount == 0)
586b7579f77SDag-Erling Smørgrav 		return 0;
587b7579f77SDag-Erling Smørgrav 	if(msg->qdcount > 1)
588b7579f77SDag-Erling Smørgrav 		return LDNS_RCODE_FORMERR;
589b7579f77SDag-Erling Smørgrav 	log_assert(msg->qdcount == 1);
59017d15b25SDag-Erling Smørgrav 	if(sldns_buffer_remaining(pkt) <= 0)
591b7579f77SDag-Erling Smørgrav 		return LDNS_RCODE_FORMERR;
59217d15b25SDag-Erling Smørgrav 	msg->qname = sldns_buffer_current(pkt);
593b7579f77SDag-Erling Smørgrav 	if((msg->qname_len = pkt_dname_len(pkt)) == 0)
594b7579f77SDag-Erling Smørgrav 		return LDNS_RCODE_FORMERR;
59517d15b25SDag-Erling Smørgrav 	if(sldns_buffer_remaining(pkt) < sizeof(uint16_t)*2)
596b7579f77SDag-Erling Smørgrav 		return LDNS_RCODE_FORMERR;
59717d15b25SDag-Erling Smørgrav 	msg->qtype = sldns_buffer_read_u16(pkt);
59817d15b25SDag-Erling Smørgrav 	msg->qclass = sldns_buffer_read_u16(pkt);
599b7579f77SDag-Erling Smørgrav 	return 0;
600b7579f77SDag-Erling Smørgrav }
601b7579f77SDag-Erling Smørgrav 
602b7579f77SDag-Erling Smørgrav size_t
60317d15b25SDag-Erling Smørgrav get_rdf_size(sldns_rdf_type rdf)
604b7579f77SDag-Erling Smørgrav {
605b7579f77SDag-Erling Smørgrav 	switch(rdf) {
606b7579f77SDag-Erling Smørgrav 		case LDNS_RDF_TYPE_CLASS:
607b7579f77SDag-Erling Smørgrav 		case LDNS_RDF_TYPE_ALG:
608b7579f77SDag-Erling Smørgrav 		case LDNS_RDF_TYPE_INT8:
609b7579f77SDag-Erling Smørgrav 			return 1;
610b7579f77SDag-Erling Smørgrav 			break;
611b7579f77SDag-Erling Smørgrav 		case LDNS_RDF_TYPE_INT16:
612b7579f77SDag-Erling Smørgrav 		case LDNS_RDF_TYPE_TYPE:
613b7579f77SDag-Erling Smørgrav 		case LDNS_RDF_TYPE_CERT_ALG:
614b7579f77SDag-Erling Smørgrav 			return 2;
615b7579f77SDag-Erling Smørgrav 			break;
616b7579f77SDag-Erling Smørgrav 		case LDNS_RDF_TYPE_INT32:
617b7579f77SDag-Erling Smørgrav 		case LDNS_RDF_TYPE_TIME:
618b7579f77SDag-Erling Smørgrav 		case LDNS_RDF_TYPE_A:
619b7579f77SDag-Erling Smørgrav 		case LDNS_RDF_TYPE_PERIOD:
620b7579f77SDag-Erling Smørgrav 			return 4;
621b7579f77SDag-Erling Smørgrav 			break;
622b7579f77SDag-Erling Smørgrav 		case LDNS_RDF_TYPE_TSIGTIME:
623b7579f77SDag-Erling Smørgrav 			return 6;
624b7579f77SDag-Erling Smørgrav 			break;
625b7579f77SDag-Erling Smørgrav 		case LDNS_RDF_TYPE_AAAA:
626b7579f77SDag-Erling Smørgrav 			return 16;
627b7579f77SDag-Erling Smørgrav 			break;
628b7579f77SDag-Erling Smørgrav 		default:
62917d15b25SDag-Erling Smørgrav 			log_assert(0); /* add type above */
630b7579f77SDag-Erling Smørgrav 			/* only types that appear before a domain  *
631b7579f77SDag-Erling Smørgrav 			 * name are needed. rest is simply copied. */
632b7579f77SDag-Erling Smørgrav 	}
633b7579f77SDag-Erling Smørgrav 	return 0;
634b7579f77SDag-Erling Smørgrav }
635b7579f77SDag-Erling Smørgrav 
636b7579f77SDag-Erling Smørgrav /** calculate the size of one rr */
637b7579f77SDag-Erling Smørgrav static int
63817d15b25SDag-Erling Smørgrav calc_size(sldns_buffer* pkt, uint16_t type, struct rr_parse* rr)
639b7579f77SDag-Erling Smørgrav {
64017d15b25SDag-Erling Smørgrav 	const sldns_rr_descriptor* desc;
641b7579f77SDag-Erling Smørgrav 	uint16_t pkt_len; /* length of rr inside the packet */
642b7579f77SDag-Erling Smørgrav 	rr->size = sizeof(uint16_t); /* the rdatalen */
64317d15b25SDag-Erling Smørgrav 	sldns_buffer_skip(pkt, 4); /* skip ttl */
64417d15b25SDag-Erling Smørgrav 	pkt_len = sldns_buffer_read_u16(pkt);
64517d15b25SDag-Erling Smørgrav 	if(sldns_buffer_remaining(pkt) < pkt_len)
646b7579f77SDag-Erling Smørgrav 		return 0;
64717d15b25SDag-Erling Smørgrav 	desc = sldns_rr_descript(type);
648b7579f77SDag-Erling Smørgrav 	if(pkt_len > 0 && desc && desc->_dname_count > 0) {
649b7579f77SDag-Erling Smørgrav 		int count = (int)desc->_dname_count;
650b7579f77SDag-Erling Smørgrav 		int rdf = 0;
651b7579f77SDag-Erling Smørgrav 		size_t len;
652b7579f77SDag-Erling Smørgrav 		size_t oldpos;
653b7579f77SDag-Erling Smørgrav 		/* skip first part. */
654b7579f77SDag-Erling Smørgrav 		while(pkt_len > 0 && count) {
655b7579f77SDag-Erling Smørgrav 			switch(desc->_wireformat[rdf]) {
656b7579f77SDag-Erling Smørgrav 			case LDNS_RDF_TYPE_DNAME:
657b7579f77SDag-Erling Smørgrav 				/* decompress every domain name */
65817d15b25SDag-Erling Smørgrav 				oldpos = sldns_buffer_position(pkt);
659b7579f77SDag-Erling Smørgrav 				if((len = pkt_dname_len(pkt)) == 0)
660b7579f77SDag-Erling Smørgrav 					return 0; /* malformed dname */
66117d15b25SDag-Erling Smørgrav 				if(sldns_buffer_position(pkt)-oldpos > pkt_len)
662b7579f77SDag-Erling Smørgrav 					return 0; /* dname exceeds rdata */
66317d15b25SDag-Erling Smørgrav 				pkt_len -= sldns_buffer_position(pkt)-oldpos;
664b7579f77SDag-Erling Smørgrav 				rr->size += len;
665b7579f77SDag-Erling Smørgrav 				count--;
666b7579f77SDag-Erling Smørgrav 				len = 0;
667b7579f77SDag-Erling Smørgrav 				break;
668b7579f77SDag-Erling Smørgrav 			case LDNS_RDF_TYPE_STR:
6698ed2b524SDag-Erling Smørgrav 				if(pkt_len < 1) {
6708ed2b524SDag-Erling Smørgrav 					/* NOTREACHED, due to 'while(>0)' */
671b7579f77SDag-Erling Smørgrav 					return 0; /* len byte exceeds rdata */
6728ed2b524SDag-Erling Smørgrav 				}
67317d15b25SDag-Erling Smørgrav 				len = sldns_buffer_current(pkt)[0] + 1;
674b7579f77SDag-Erling Smørgrav 				break;
675b7579f77SDag-Erling Smørgrav 			default:
676b7579f77SDag-Erling Smørgrav 				len = get_rdf_size(desc->_wireformat[rdf]);
677b7579f77SDag-Erling Smørgrav 			}
678b7579f77SDag-Erling Smørgrav 			if(len) {
679b7579f77SDag-Erling Smørgrav 				if(pkt_len < len)
680b7579f77SDag-Erling Smørgrav 					return 0; /* exceeds rdata */
681b7579f77SDag-Erling Smørgrav 				pkt_len -= len;
68217d15b25SDag-Erling Smørgrav 				sldns_buffer_skip(pkt, (ssize_t)len);
683b7579f77SDag-Erling Smørgrav 				rr->size += len;
684b7579f77SDag-Erling Smørgrav 			}
685b7579f77SDag-Erling Smørgrav 			rdf++;
686b7579f77SDag-Erling Smørgrav 		}
687b7579f77SDag-Erling Smørgrav 	}
688b7579f77SDag-Erling Smørgrav 	/* remaining rdata */
689b7579f77SDag-Erling Smørgrav 	rr->size += pkt_len;
69017d15b25SDag-Erling Smørgrav 	sldns_buffer_skip(pkt, (ssize_t)pkt_len);
691b7579f77SDag-Erling Smørgrav 	return 1;
692b7579f77SDag-Erling Smørgrav }
693b7579f77SDag-Erling Smørgrav 
694b7579f77SDag-Erling Smørgrav /** skip rr ttl and rdata */
695b7579f77SDag-Erling Smørgrav static int
69617d15b25SDag-Erling Smørgrav skip_ttl_rdata(sldns_buffer* pkt)
697b7579f77SDag-Erling Smørgrav {
698b7579f77SDag-Erling Smørgrav 	uint16_t rdatalen;
69917d15b25SDag-Erling Smørgrav 	if(sldns_buffer_remaining(pkt) < 6) /* ttl + rdatalen */
700b7579f77SDag-Erling Smørgrav 		return 0;
70117d15b25SDag-Erling Smørgrav 	sldns_buffer_skip(pkt, 4); /* ttl */
70217d15b25SDag-Erling Smørgrav 	rdatalen = sldns_buffer_read_u16(pkt);
70317d15b25SDag-Erling Smørgrav 	if(sldns_buffer_remaining(pkt) < rdatalen)
704b7579f77SDag-Erling Smørgrav 		return 0;
70517d15b25SDag-Erling Smørgrav 	sldns_buffer_skip(pkt, (ssize_t)rdatalen);
706b7579f77SDag-Erling Smørgrav 	return 1;
707b7579f77SDag-Erling Smørgrav }
708b7579f77SDag-Erling Smørgrav 
709b7579f77SDag-Erling Smørgrav /** see if RRSIG is a duplicate of another */
710b7579f77SDag-Erling Smørgrav static int
71117d15b25SDag-Erling Smørgrav sig_is_double(sldns_buffer* pkt, struct rrset_parse* rrset, uint8_t* ttldata)
712b7579f77SDag-Erling Smørgrav {
713b7579f77SDag-Erling Smørgrav 	uint16_t rlen, siglen;
71417d15b25SDag-Erling Smørgrav 	size_t pos = sldns_buffer_position(pkt);
715b7579f77SDag-Erling Smørgrav 	struct rr_parse* sig;
71617d15b25SDag-Erling Smørgrav 	if(sldns_buffer_remaining(pkt) < 6)
717b7579f77SDag-Erling Smørgrav 		return 0;
71817d15b25SDag-Erling Smørgrav 	sldns_buffer_skip(pkt, 4); /* ttl */
71917d15b25SDag-Erling Smørgrav 	rlen = sldns_buffer_read_u16(pkt);
72017d15b25SDag-Erling Smørgrav 	if(sldns_buffer_remaining(pkt) < rlen) {
72117d15b25SDag-Erling Smørgrav 		sldns_buffer_set_position(pkt, pos);
722b7579f77SDag-Erling Smørgrav 		return 0;
723b7579f77SDag-Erling Smørgrav 	}
72417d15b25SDag-Erling Smørgrav 	sldns_buffer_set_position(pkt, pos);
725b7579f77SDag-Erling Smørgrav 
726b7579f77SDag-Erling Smørgrav 	sig = rrset->rrsig_first;
727b7579f77SDag-Erling Smørgrav 	while(sig) {
728b7579f77SDag-Erling Smørgrav 		/* check if rdatalen is same */
729b7579f77SDag-Erling Smørgrav 		memmove(&siglen, sig->ttl_data+4, sizeof(siglen));
730b7579f77SDag-Erling Smørgrav 		siglen = ntohs(siglen);
731b7579f77SDag-Erling Smørgrav 		/* checks if data in packet is exactly the same, this means
732b7579f77SDag-Erling Smørgrav 		 * also dname in rdata is the same, but rrsig is not allowed
733b7579f77SDag-Erling Smørgrav 		 * to have compressed dnames anyway. If it is compressed anyway
734b7579f77SDag-Erling Smørgrav 		 * it will lead to duplicate rrs for qtype=RRSIG. (or ANY).
735b7579f77SDag-Erling Smørgrav 		 *
736b7579f77SDag-Erling Smørgrav 		 * Cannot use sig->size because size of the other one is not
737b7579f77SDag-Erling Smørgrav 		 * calculated yet.
738b7579f77SDag-Erling Smørgrav 		 */
739b7579f77SDag-Erling Smørgrav 		if(siglen == rlen) {
740b7579f77SDag-Erling Smørgrav 			if(siglen>0 && memcmp(sig->ttl_data+6, ttldata+6,
741b7579f77SDag-Erling Smørgrav 				siglen) == 0) {
742b7579f77SDag-Erling Smørgrav 				/* same! */
743b7579f77SDag-Erling Smørgrav 				return 1;
744b7579f77SDag-Erling Smørgrav 			}
745b7579f77SDag-Erling Smørgrav 		}
746b7579f77SDag-Erling Smørgrav 		sig = sig->next;
747b7579f77SDag-Erling Smørgrav 	}
748b7579f77SDag-Erling Smørgrav 	return 0;
749b7579f77SDag-Erling Smørgrav }
750b7579f77SDag-Erling Smørgrav 
751b7579f77SDag-Erling Smørgrav /** Add rr (from packet here) to rrset, skips rr */
752b7579f77SDag-Erling Smørgrav static int
75317d15b25SDag-Erling Smørgrav add_rr_to_rrset(struct rrset_parse* rrset, sldns_buffer* pkt,
754b7579f77SDag-Erling Smørgrav 	struct msg_parse* msg, struct regional* region,
75517d15b25SDag-Erling Smørgrav 	sldns_pkt_section section, uint16_t type)
756b7579f77SDag-Erling Smørgrav {
757b7579f77SDag-Erling Smørgrav 	struct rr_parse* rr;
758b7579f77SDag-Erling Smørgrav 	/* check section of rrset. */
759b7579f77SDag-Erling Smørgrav 	if(rrset->section != section && type != LDNS_RR_TYPE_RRSIG &&
760b7579f77SDag-Erling Smørgrav 		rrset->type != LDNS_RR_TYPE_RRSIG) {
761b7579f77SDag-Erling Smørgrav 		/* silently drop it - we drop the last part, since
762b7579f77SDag-Erling Smørgrav 		 * trust in rr data depends on the section it is in.
763b7579f77SDag-Erling Smørgrav 		 * the less trustworthy part is discarded.
764b7579f77SDag-Erling Smørgrav 		 * also the last part is more likely to be incomplete.
765b7579f77SDag-Erling Smørgrav 		 * RFC 2181: must put RRset only once in response. */
766b7579f77SDag-Erling Smørgrav 		/*
767b7579f77SDag-Erling Smørgrav 		verbose(VERB_QUERY, "Packet contains rrset data in "
768b7579f77SDag-Erling Smørgrav 			"multiple sections, dropped last part.");
769b7579f77SDag-Erling Smørgrav 		log_buf(VERB_QUERY, "packet was", pkt);
770b7579f77SDag-Erling Smørgrav 		*/
771b7579f77SDag-Erling Smørgrav 		/* forwards */
772b7579f77SDag-Erling Smørgrav 		if(!skip_ttl_rdata(pkt))
773b7579f77SDag-Erling Smørgrav 			return LDNS_RCODE_FORMERR;
774b7579f77SDag-Erling Smørgrav 		return 0;
775b7579f77SDag-Erling Smørgrav 	}
776b7579f77SDag-Erling Smørgrav 
777b7579f77SDag-Erling Smørgrav 	if( (msg->qtype == LDNS_RR_TYPE_RRSIG ||
778b7579f77SDag-Erling Smørgrav 	     msg->qtype == LDNS_RR_TYPE_ANY)
77917d15b25SDag-Erling Smørgrav 	    && sig_is_double(pkt, rrset, sldns_buffer_current(pkt))) {
780b7579f77SDag-Erling Smørgrav 		if(!skip_ttl_rdata(pkt))
781b7579f77SDag-Erling Smørgrav 			return LDNS_RCODE_FORMERR;
782b7579f77SDag-Erling Smørgrav 		return 0;
783b7579f77SDag-Erling Smørgrav 	}
784b7579f77SDag-Erling Smørgrav 
785b7579f77SDag-Erling Smørgrav 	/* create rr */
786b7579f77SDag-Erling Smørgrav 	if(!(rr = (struct rr_parse*)regional_alloc(region, sizeof(*rr))))
787b7579f77SDag-Erling Smørgrav 		return LDNS_RCODE_SERVFAIL;
788b7579f77SDag-Erling Smørgrav 	rr->outside_packet = 0;
78917d15b25SDag-Erling Smørgrav 	rr->ttl_data = sldns_buffer_current(pkt);
790b7579f77SDag-Erling Smørgrav 	rr->next = 0;
791b7579f77SDag-Erling Smørgrav 	if(type == LDNS_RR_TYPE_RRSIG && rrset->type != LDNS_RR_TYPE_RRSIG) {
792b7579f77SDag-Erling Smørgrav 		if(rrset->rrsig_last)
793b7579f77SDag-Erling Smørgrav 			rrset->rrsig_last->next = rr;
794b7579f77SDag-Erling Smørgrav 		else	rrset->rrsig_first = rr;
795b7579f77SDag-Erling Smørgrav 		rrset->rrsig_last = rr;
796b7579f77SDag-Erling Smørgrav 		rrset->rrsig_count++;
797b7579f77SDag-Erling Smørgrav 	} else {
798b7579f77SDag-Erling Smørgrav 		if(rrset->rr_last)
799b7579f77SDag-Erling Smørgrav 			rrset->rr_last->next = rr;
800b7579f77SDag-Erling Smørgrav 		else	rrset->rr_first = rr;
801b7579f77SDag-Erling Smørgrav 		rrset->rr_last = rr;
802b7579f77SDag-Erling Smørgrav 		rrset->rr_count++;
803b7579f77SDag-Erling Smørgrav 	}
804b7579f77SDag-Erling Smørgrav 
805b7579f77SDag-Erling Smørgrav 	/* calc decompressed size */
806b7579f77SDag-Erling Smørgrav 	if(!calc_size(pkt, type, rr))
807b7579f77SDag-Erling Smørgrav 		return LDNS_RCODE_FORMERR;
808b7579f77SDag-Erling Smørgrav 	rrset->size += rr->size;
809b7579f77SDag-Erling Smørgrav 
810b7579f77SDag-Erling Smørgrav 	return 0;
811b7579f77SDag-Erling Smørgrav }
812b7579f77SDag-Erling Smørgrav 
813b7579f77SDag-Erling Smørgrav /**
814b7579f77SDag-Erling Smørgrav  * Parse packet RR section, for answer, authority and additional sections.
815b7579f77SDag-Erling Smørgrav  * @param pkt: packet, position at call must be at start of section.
816b7579f77SDag-Erling Smørgrav  *	at end position is after section.
817b7579f77SDag-Erling Smørgrav  * @param msg: store results here.
818b7579f77SDag-Erling Smørgrav  * @param region: how to alloc results.
819b7579f77SDag-Erling Smørgrav  * @param section: section enum.
820b7579f77SDag-Erling Smørgrav  * @param num_rrs: how many rrs are in the section.
821b7579f77SDag-Erling Smørgrav  * @param num_rrsets: returns number of rrsets in the section.
822b7579f77SDag-Erling Smørgrav  * @return: 0 if OK, or rcode on error.
823b7579f77SDag-Erling Smørgrav  */
824b7579f77SDag-Erling Smørgrav static int
82517d15b25SDag-Erling Smørgrav parse_section(sldns_buffer* pkt, struct msg_parse* msg,
82617d15b25SDag-Erling Smørgrav 	struct regional* region, sldns_pkt_section section,
827b7579f77SDag-Erling Smørgrav 	uint16_t num_rrs, size_t* num_rrsets)
828b7579f77SDag-Erling Smørgrav {
829b7579f77SDag-Erling Smørgrav 	uint16_t i;
830b7579f77SDag-Erling Smørgrav 	uint8_t* dname, *prev_dname_f = NULL, *prev_dname_l = NULL;
831b7579f77SDag-Erling Smørgrav 	size_t dnamelen, prev_dnamelen = 0;
832b7579f77SDag-Erling Smørgrav 	uint16_t type, prev_type = 0;
833b7579f77SDag-Erling Smørgrav 	uint16_t dclass, prev_dclass = 0;
834b7579f77SDag-Erling Smørgrav 	uint32_t rrset_flags = 0;
8353005e0a3SDag-Erling Smørgrav 	hashvalue_type hash = 0;
836b7579f77SDag-Erling Smørgrav 	struct rrset_parse* rrset = NULL;
837b7579f77SDag-Erling Smørgrav 	int r;
838b7579f77SDag-Erling Smørgrav 
839b7579f77SDag-Erling Smørgrav 	if(num_rrs == 0)
840b7579f77SDag-Erling Smørgrav 		return 0;
84117d15b25SDag-Erling Smørgrav 	if(sldns_buffer_remaining(pkt) <= 0)
842b7579f77SDag-Erling Smørgrav 		return LDNS_RCODE_FORMERR;
843b7579f77SDag-Erling Smørgrav 	for(i=0; i<num_rrs; i++) {
844b7579f77SDag-Erling Smørgrav 		/* parse this RR. */
84517d15b25SDag-Erling Smørgrav 		dname = sldns_buffer_current(pkt);
846b7579f77SDag-Erling Smørgrav 		if((dnamelen = pkt_dname_len(pkt)) == 0)
847b7579f77SDag-Erling Smørgrav 			return LDNS_RCODE_FORMERR;
84817d15b25SDag-Erling Smørgrav 		if(sldns_buffer_remaining(pkt) < 10) /* type, class, ttl, len */
849b7579f77SDag-Erling Smørgrav 			return LDNS_RCODE_FORMERR;
85017d15b25SDag-Erling Smørgrav 		type = sldns_buffer_read_u16(pkt);
85117d15b25SDag-Erling Smørgrav 		sldns_buffer_read(pkt, &dclass, sizeof(dclass));
852b7579f77SDag-Erling Smørgrav 
853b7579f77SDag-Erling Smørgrav 		if(0) { /* debug show what is being parsed. */
854b7579f77SDag-Erling Smørgrav 			if(type == LDNS_RR_TYPE_RRSIG) {
855b7579f77SDag-Erling Smørgrav 				uint16_t t;
856b7579f77SDag-Erling Smørgrav 				if(pkt_rrsig_covered(pkt,
85717d15b25SDag-Erling Smørgrav 					sldns_buffer_current(pkt), &t))
858b7579f77SDag-Erling Smørgrav 					fprintf(stderr, "parse of %s(%d) [%s(%d)]",
85917d15b25SDag-Erling Smørgrav 					sldns_rr_descript(type)?
86017d15b25SDag-Erling Smørgrav 					sldns_rr_descript(type)->_name: "??",
861b7579f77SDag-Erling Smørgrav 					(int)type,
86217d15b25SDag-Erling Smørgrav 					sldns_rr_descript(t)?
86317d15b25SDag-Erling Smørgrav 					sldns_rr_descript(t)->_name: "??",
864b7579f77SDag-Erling Smørgrav 					(int)t);
865b7579f77SDag-Erling Smørgrav 			} else
866b7579f77SDag-Erling Smørgrav 			  fprintf(stderr, "parse of %s(%d)",
86717d15b25SDag-Erling Smørgrav 				sldns_rr_descript(type)?
86817d15b25SDag-Erling Smørgrav 				sldns_rr_descript(type)->_name: "??",
869b7579f77SDag-Erling Smørgrav 				(int)type);
870b7579f77SDag-Erling Smørgrav 			fprintf(stderr, " %s(%d) ",
87117d15b25SDag-Erling Smørgrav 				sldns_lookup_by_id(sldns_rr_classes,
87217d15b25SDag-Erling Smørgrav 				(int)ntohs(dclass))?sldns_lookup_by_id(
87317d15b25SDag-Erling Smørgrav 				sldns_rr_classes, (int)ntohs(dclass))->name:
874b7579f77SDag-Erling Smørgrav 				"??", (int)ntohs(dclass));
875b7579f77SDag-Erling Smørgrav 			dname_print(stderr, pkt, dname);
876b7579f77SDag-Erling Smørgrav 			fprintf(stderr, "\n");
877b7579f77SDag-Erling Smørgrav 		}
878b7579f77SDag-Erling Smørgrav 
879b7579f77SDag-Erling Smørgrav 		/* see if it is part of an existing RR set */
880b7579f77SDag-Erling Smørgrav 		if(!find_rrset(msg, pkt, dname, dnamelen, type, dclass, &hash,
881b7579f77SDag-Erling Smørgrav 			&rrset_flags, &prev_dname_f, &prev_dname_l,
882b7579f77SDag-Erling Smørgrav 			&prev_dnamelen, &prev_type, &prev_dclass, &rrset,
883b7579f77SDag-Erling Smørgrav 			section, region))
884b7579f77SDag-Erling Smørgrav 			return LDNS_RCODE_SERVFAIL;
885b7579f77SDag-Erling Smørgrav 		if(!rrset) {
886b7579f77SDag-Erling Smørgrav 			/* it is a new RR set. hash&flags already calculated.*/
887b7579f77SDag-Erling Smørgrav 			(*num_rrsets)++;
888b7579f77SDag-Erling Smørgrav 			rrset = new_rrset(msg, dname, dnamelen, type, dclass,
889b7579f77SDag-Erling Smørgrav 				hash, rrset_flags, section, region);
890b7579f77SDag-Erling Smørgrav 			if(!rrset)
891b7579f77SDag-Erling Smørgrav 				return LDNS_RCODE_SERVFAIL;
892b7579f77SDag-Erling Smørgrav 		}
893b7579f77SDag-Erling Smørgrav 		else if(0)	{
894b7579f77SDag-Erling Smørgrav 			fprintf(stderr, "is part of existing: ");
895b7579f77SDag-Erling Smørgrav 			dname_print(stderr, pkt, rrset->dname);
896b7579f77SDag-Erling Smørgrav 			fprintf(stderr, " type %s(%d)\n",
89717d15b25SDag-Erling Smørgrav 				sldns_rr_descript(rrset->type)?
89817d15b25SDag-Erling Smørgrav 				sldns_rr_descript(rrset->type)->_name: "??",
899b7579f77SDag-Erling Smørgrav 				(int)rrset->type);
900b7579f77SDag-Erling Smørgrav 		}
901b7579f77SDag-Erling Smørgrav 		/* add to rrset. */
902b7579f77SDag-Erling Smørgrav 		if((r=add_rr_to_rrset(rrset, pkt, msg, region, section,
903b7579f77SDag-Erling Smørgrav 			type)) != 0)
904b7579f77SDag-Erling Smørgrav 			return r;
905b7579f77SDag-Erling Smørgrav 	}
906b7579f77SDag-Erling Smørgrav 	return 0;
907b7579f77SDag-Erling Smørgrav }
908b7579f77SDag-Erling Smørgrav 
909b7579f77SDag-Erling Smørgrav int
91017d15b25SDag-Erling Smørgrav parse_packet(sldns_buffer* pkt, struct msg_parse* msg, struct regional* region)
911b7579f77SDag-Erling Smørgrav {
912b7579f77SDag-Erling Smørgrav 	int ret;
91317d15b25SDag-Erling Smørgrav 	if(sldns_buffer_remaining(pkt) < LDNS_HEADER_SIZE)
914b7579f77SDag-Erling Smørgrav 		return LDNS_RCODE_FORMERR;
915b7579f77SDag-Erling Smørgrav 	/* read the header */
91617d15b25SDag-Erling Smørgrav 	sldns_buffer_read(pkt, &msg->id, sizeof(uint16_t));
91717d15b25SDag-Erling Smørgrav 	msg->flags = sldns_buffer_read_u16(pkt);
91817d15b25SDag-Erling Smørgrav 	msg->qdcount = sldns_buffer_read_u16(pkt);
91917d15b25SDag-Erling Smørgrav 	msg->ancount = sldns_buffer_read_u16(pkt);
92017d15b25SDag-Erling Smørgrav 	msg->nscount = sldns_buffer_read_u16(pkt);
92117d15b25SDag-Erling Smørgrav 	msg->arcount = sldns_buffer_read_u16(pkt);
922b7579f77SDag-Erling Smørgrav 	if(msg->qdcount > 1)
923b7579f77SDag-Erling Smørgrav 		return LDNS_RCODE_FORMERR;
924b7579f77SDag-Erling Smørgrav 	if((ret = parse_query_section(pkt, msg)) != 0)
925b7579f77SDag-Erling Smørgrav 		return ret;
926b7579f77SDag-Erling Smørgrav 	if((ret = parse_section(pkt, msg, region, LDNS_SECTION_ANSWER,
927b7579f77SDag-Erling Smørgrav 		msg->ancount, &msg->an_rrsets)) != 0)
928b7579f77SDag-Erling Smørgrav 		return ret;
929b7579f77SDag-Erling Smørgrav 	if((ret = parse_section(pkt, msg, region, LDNS_SECTION_AUTHORITY,
930b7579f77SDag-Erling Smørgrav 		msg->nscount, &msg->ns_rrsets)) != 0)
931b7579f77SDag-Erling Smørgrav 		return ret;
93217d15b25SDag-Erling Smørgrav 	if(sldns_buffer_remaining(pkt) == 0 && msg->arcount == 1) {
933b7579f77SDag-Erling Smørgrav 		/* BIND accepts leniently that an EDNS record is missing.
934b7579f77SDag-Erling Smørgrav 		 * so, we do too. */
935b7579f77SDag-Erling Smørgrav 	} else if((ret = parse_section(pkt, msg, region,
936b7579f77SDag-Erling Smørgrav 		LDNS_SECTION_ADDITIONAL, msg->arcount, &msg->ar_rrsets)) != 0)
937b7579f77SDag-Erling Smørgrav 		return ret;
93817d15b25SDag-Erling Smørgrav 	/* if(sldns_buffer_remaining(pkt) > 0) { */
939b7579f77SDag-Erling Smørgrav 		/* there is spurious data at end of packet. ignore */
940b7579f77SDag-Erling Smørgrav 	/* } */
941b7579f77SDag-Erling Smørgrav 	msg->rrset_count = msg->an_rrsets + msg->ns_rrsets + msg->ar_rrsets;
942b7579f77SDag-Erling Smørgrav 	return 0;
943b7579f77SDag-Erling Smørgrav }
944b7579f77SDag-Erling Smørgrav 
945e2d15004SDag-Erling Smørgrav /** parse EDNS options from EDNS wireformat rdata */
946e2d15004SDag-Erling Smørgrav static int
94724e36522SCy Schubert parse_edns_options_from_query(uint8_t* rdata_ptr, size_t rdata_len,
94824e36522SCy Schubert 	struct edns_data* edns, struct config_file* cfg, struct comm_point* c,
949*8f76bb7dSCy Schubert 	struct comm_reply* repinfo, uint32_t now, struct regional* region)
950e2d15004SDag-Erling Smørgrav {
95124e36522SCy Schubert 	/* To respond with a Keepalive option, the client connection must have
95224e36522SCy Schubert 	 * received one message with a TCP Keepalive EDNS option, and that
95324e36522SCy Schubert 	 * option must have 0 length data. Subsequent messages sent on that
95424e36522SCy Schubert 	 * connection will have a TCP Keepalive option.
95524e36522SCy Schubert 	 *
95624e36522SCy Schubert 	 * In the if-statement below, the option is added unsolicited. This
95724e36522SCy Schubert 	 * means that the client has sent an KEEPALIVE option earlier. We know
95824e36522SCy Schubert 	 * here this is true, because c->tcp_keepalive is set.
95924e36522SCy Schubert 	 */
96024e36522SCy Schubert 	if (cfg && cfg->do_tcp_keepalive && c && c->type != comm_udp && c->tcp_keepalive) {
96124e36522SCy Schubert 		if(!edns_opt_list_append_keepalive(&edns->opt_list_out,
96224e36522SCy Schubert 					c->tcp_timeout_msec / 100, region)) {
96324e36522SCy Schubert 			log_err("out of memory");
96424e36522SCy Schubert 			return LDNS_RCODE_SERVFAIL;
96524e36522SCy Schubert 		}
96624e36522SCy Schubert 	}
96724e36522SCy Schubert 
968e2d15004SDag-Erling Smørgrav 	/* while still more options, and have code+len to read */
969e2d15004SDag-Erling Smørgrav 	/* ignores partial content (i.e. rdata len 3) */
970e2d15004SDag-Erling Smørgrav 	while(rdata_len >= 4) {
971e2d15004SDag-Erling Smørgrav 		uint16_t opt_code = sldns_read_uint16(rdata_ptr);
972e2d15004SDag-Erling Smørgrav 		uint16_t opt_len = sldns_read_uint16(rdata_ptr+2);
973*8f76bb7dSCy Schubert 		uint8_t server_cookie[40];
974*8f76bb7dSCy Schubert 		enum edns_cookie_val_status cookie_val_status;
975*8f76bb7dSCy Schubert 		int cookie_is_v4 = 1;
976*8f76bb7dSCy Schubert 
977e2d15004SDag-Erling Smørgrav 		rdata_ptr += 4;
978e2d15004SDag-Erling Smørgrav 		rdata_len -= 4;
979e2d15004SDag-Erling Smørgrav 		if(opt_len > rdata_len)
980e2d15004SDag-Erling Smørgrav 			break; /* option code partial */
98124e36522SCy Schubert 
98224e36522SCy Schubert 		/* handle parse time edns options here */
98324e36522SCy Schubert 		switch(opt_code) {
98424e36522SCy Schubert 		case LDNS_EDNS_NSID:
98524e36522SCy Schubert 			if (!cfg || !cfg->nsid)
98624e36522SCy Schubert 				break;
98724e36522SCy Schubert 			if(!edns_opt_list_append(&edns->opt_list_out,
98824e36522SCy Schubert 						LDNS_EDNS_NSID, cfg->nsid_len,
98924e36522SCy Schubert 						cfg->nsid, region)) {
990e2d15004SDag-Erling Smørgrav 				log_err("out of memory");
99124e36522SCy Schubert 				return LDNS_RCODE_SERVFAIL;
99224e36522SCy Schubert 			}
99324e36522SCy Schubert 			break;
99424e36522SCy Schubert 
99524e36522SCy Schubert 		case LDNS_EDNS_KEEPALIVE:
99624e36522SCy Schubert 			/* To respond with a Keepalive option, the client
99724e36522SCy Schubert 			 * connection must have received one message with a TCP
99824e36522SCy Schubert 			 * Keepalive EDNS option, and that option must have 0
99924e36522SCy Schubert 			 * length data. Subsequent messages sent on that
100024e36522SCy Schubert 			 * connection will have a TCP Keepalive option.
100124e36522SCy Schubert 			 *
100224e36522SCy Schubert 			 * This should be the first time the client sends this
100324e36522SCy Schubert 			 * option, so c->tcp_keepalive is not set.
100424e36522SCy Schubert 			 * Besides adding the reply KEEPALIVE option,
100524e36522SCy Schubert 			 * c->tcp_keepalive will be set so that the
100624e36522SCy Schubert 			 * option will be added unsolicited in subsequent
100724e36522SCy Schubert 			 * responses (see the comment above the if-statement
100824e36522SCy Schubert 			 * at the start of this function).
100924e36522SCy Schubert 			 */
101024e36522SCy Schubert 			if (!cfg || !cfg->do_tcp_keepalive || !c ||
101124e36522SCy Schubert 					c->type == comm_udp || c->tcp_keepalive)
101224e36522SCy Schubert 				break;
101324e36522SCy Schubert 			if(opt_len) {
101424e36522SCy Schubert 				verbose(VERB_ALGO, "query with bad edns keepalive.");
101524e36522SCy Schubert 				return LDNS_RCODE_FORMERR;
101624e36522SCy Schubert 			}
101724e36522SCy Schubert 			if(!edns_opt_list_append_keepalive(&edns->opt_list_out,
101824e36522SCy Schubert 						c->tcp_timeout_msec / 100,
101924e36522SCy Schubert 						region)) {
102024e36522SCy Schubert 				log_err("out of memory");
102124e36522SCy Schubert 				return LDNS_RCODE_SERVFAIL;
102224e36522SCy Schubert 			}
102324e36522SCy Schubert 			c->tcp_keepalive = 1;
102424e36522SCy Schubert 			break;
102524e36522SCy Schubert 
102624e36522SCy Schubert 		case LDNS_EDNS_PADDING:
102724e36522SCy Schubert 			if(!cfg || !cfg->pad_responses ||
102824e36522SCy Schubert 					!c || c->type != comm_tcp ||!c->ssl)
102924e36522SCy Schubert 				break;
103024e36522SCy Schubert 			if(!edns_opt_list_append(&edns->opt_list_out,
103124e36522SCy Schubert 						LDNS_EDNS_PADDING,
103224e36522SCy Schubert 						0, NULL, region)) {
103324e36522SCy Schubert 				log_err("out of memory");
103424e36522SCy Schubert 				return LDNS_RCODE_SERVFAIL;
103524e36522SCy Schubert 			}
103624e36522SCy Schubert 			edns->padding_block_size = cfg->pad_responses_block_size;
103724e36522SCy Schubert 			break;
103824e36522SCy Schubert 
1039*8f76bb7dSCy Schubert 		case LDNS_EDNS_COOKIE:
1040*8f76bb7dSCy Schubert 			if(!cfg || !cfg->do_answer_cookie || !repinfo)
1041*8f76bb7dSCy Schubert 				break;
1042*8f76bb7dSCy Schubert 			if(opt_len != 8 && (opt_len < 16 || opt_len > 40)) {
1043*8f76bb7dSCy Schubert 				verbose(VERB_ALGO, "worker request: "
1044*8f76bb7dSCy Schubert 					"badly formatted cookie");
1045*8f76bb7dSCy Schubert 				return LDNS_RCODE_FORMERR;
1046*8f76bb7dSCy Schubert 			}
1047*8f76bb7dSCy Schubert 			edns->cookie_present = 1;
1048*8f76bb7dSCy Schubert 
1049*8f76bb7dSCy Schubert 			/* Copy client cookie, version and timestamp for
1050*8f76bb7dSCy Schubert 			 * validation and creation purposes.
1051*8f76bb7dSCy Schubert 			 */
1052*8f76bb7dSCy Schubert 			if(opt_len >= 16) {
1053*8f76bb7dSCy Schubert 				memmove(server_cookie, rdata_ptr, 16);
1054*8f76bb7dSCy Schubert 			} else {
1055*8f76bb7dSCy Schubert 				memset(server_cookie, 0, 16);
1056*8f76bb7dSCy Schubert 				memmove(server_cookie, rdata_ptr, opt_len);
1057*8f76bb7dSCy Schubert 			}
1058*8f76bb7dSCy Schubert 
1059*8f76bb7dSCy Schubert 			/* Copy client ip for validation and creation
1060*8f76bb7dSCy Schubert 			 * purposes. It will be overwritten if (re)creation
1061*8f76bb7dSCy Schubert 			 * is needed.
1062*8f76bb7dSCy Schubert 			 */
1063*8f76bb7dSCy Schubert 			if(repinfo->remote_addr.ss_family == AF_INET) {
1064*8f76bb7dSCy Schubert 				memcpy(server_cookie + 16,
1065*8f76bb7dSCy Schubert 					&((struct sockaddr_in*)&repinfo->remote_addr)->sin_addr, 4);
1066*8f76bb7dSCy Schubert 			} else {
1067*8f76bb7dSCy Schubert 				cookie_is_v4 = 0;
1068*8f76bb7dSCy Schubert 				memcpy(server_cookie + 16,
1069*8f76bb7dSCy Schubert 					&((struct sockaddr_in6*)&repinfo->remote_addr)->sin6_addr, 16);
1070*8f76bb7dSCy Schubert 			}
1071*8f76bb7dSCy Schubert 
1072*8f76bb7dSCy Schubert 			cookie_val_status = edns_cookie_server_validate(
1073*8f76bb7dSCy Schubert 				rdata_ptr, opt_len, cfg->cookie_secret,
1074*8f76bb7dSCy Schubert 				cfg->cookie_secret_len, cookie_is_v4,
1075*8f76bb7dSCy Schubert 				server_cookie, now);
1076*8f76bb7dSCy Schubert 			switch(cookie_val_status) {
1077*8f76bb7dSCy Schubert 			case COOKIE_STATUS_VALID:
1078*8f76bb7dSCy Schubert 			case COOKIE_STATUS_VALID_RENEW:
1079*8f76bb7dSCy Schubert 				edns->cookie_valid = 1;
1080*8f76bb7dSCy Schubert 				/* Reuse cookie */
1081*8f76bb7dSCy Schubert 				if(!edns_opt_list_append(
1082*8f76bb7dSCy Schubert 					&edns->opt_list_out, LDNS_EDNS_COOKIE,
1083*8f76bb7dSCy Schubert 					opt_len, rdata_ptr, region)) {
1084*8f76bb7dSCy Schubert 					log_err("out of memory");
1085*8f76bb7dSCy Schubert 					return LDNS_RCODE_SERVFAIL;
1086*8f76bb7dSCy Schubert 				}
1087*8f76bb7dSCy Schubert 				/* Cookie to be reused added to outgoing
1088*8f76bb7dSCy Schubert 				 * options. Done!
1089*8f76bb7dSCy Schubert 				 */
1090*8f76bb7dSCy Schubert 				break;
1091*8f76bb7dSCy Schubert 			case COOKIE_STATUS_CLIENT_ONLY:
1092*8f76bb7dSCy Schubert 				edns->cookie_client = 1;
1093*8f76bb7dSCy Schubert 				/* fallthrough */
1094*8f76bb7dSCy Schubert 			case COOKIE_STATUS_FUTURE:
1095*8f76bb7dSCy Schubert 			case COOKIE_STATUS_EXPIRED:
1096*8f76bb7dSCy Schubert 			case COOKIE_STATUS_INVALID:
1097*8f76bb7dSCy Schubert 			default:
1098*8f76bb7dSCy Schubert 				edns_cookie_server_write(server_cookie,
1099*8f76bb7dSCy Schubert 					cfg->cookie_secret, cookie_is_v4, now);
1100*8f76bb7dSCy Schubert 				if(!edns_opt_list_append(&edns->opt_list_out,
1101*8f76bb7dSCy Schubert 					LDNS_EDNS_COOKIE, 24, server_cookie,
1102*8f76bb7dSCy Schubert 					region)) {
1103*8f76bb7dSCy Schubert 					log_err("out of memory");
1104*8f76bb7dSCy Schubert 					return LDNS_RCODE_SERVFAIL;
1105*8f76bb7dSCy Schubert 				}
1106*8f76bb7dSCy Schubert 				break;
1107*8f76bb7dSCy Schubert 			}
1108*8f76bb7dSCy Schubert 			break;
110924e36522SCy Schubert 		default:
111024e36522SCy Schubert 			break;
111124e36522SCy Schubert 		}
111224e36522SCy Schubert 		if(!edns_opt_list_append(&edns->opt_list_in,
111324e36522SCy Schubert 				opt_code, opt_len, rdata_ptr, region)) {
111424e36522SCy Schubert 			log_err("out of memory");
111524e36522SCy Schubert 			return LDNS_RCODE_SERVFAIL;
1116e2d15004SDag-Erling Smørgrav 		}
1117e2d15004SDag-Erling Smørgrav 		rdata_ptr += opt_len;
1118e2d15004SDag-Erling Smørgrav 		rdata_len -= opt_len;
1119e2d15004SDag-Erling Smørgrav 	}
112024e36522SCy Schubert 	return LDNS_RCODE_NOERROR;
1121e2d15004SDag-Erling Smørgrav }
1122e2d15004SDag-Erling Smørgrav 
1123b7579f77SDag-Erling Smørgrav int
112424e36522SCy Schubert parse_extract_edns_from_response_msg(struct msg_parse* msg,
112524e36522SCy Schubert 	struct edns_data* edns, struct regional* region)
1126b7579f77SDag-Erling Smørgrav {
1127b7579f77SDag-Erling Smørgrav 	struct rrset_parse* rrset = msg->rrset_first;
1128b7579f77SDag-Erling Smørgrav 	struct rrset_parse* prev = 0;
1129b7579f77SDag-Erling Smørgrav 	struct rrset_parse* found = 0;
1130b7579f77SDag-Erling Smørgrav 	struct rrset_parse* found_prev = 0;
1131e2d15004SDag-Erling Smørgrav 	size_t rdata_len;
1132e2d15004SDag-Erling Smørgrav 	uint8_t* rdata_ptr;
1133b7579f77SDag-Erling Smørgrav 	/* since the class encodes the UDP size, we cannot use hash table to
1134b7579f77SDag-Erling Smørgrav 	 * find the EDNS OPT record. Scan the packet. */
1135b7579f77SDag-Erling Smørgrav 	while(rrset) {
1136b7579f77SDag-Erling Smørgrav 		if(rrset->type == LDNS_RR_TYPE_OPT) {
1137b7579f77SDag-Erling Smørgrav 			/* only one OPT RR allowed. */
1138b7579f77SDag-Erling Smørgrav 			if(found) return LDNS_RCODE_FORMERR;
1139b7579f77SDag-Erling Smørgrav 			/* found it! */
1140b7579f77SDag-Erling Smørgrav 			found_prev = prev;
1141b7579f77SDag-Erling Smørgrav 			found = rrset;
1142b7579f77SDag-Erling Smørgrav 		}
1143b7579f77SDag-Erling Smørgrav 		prev = rrset;
1144b7579f77SDag-Erling Smørgrav 		rrset = rrset->rrset_all_next;
1145b7579f77SDag-Erling Smørgrav 	}
1146b7579f77SDag-Erling Smørgrav 	if(!found) {
1147b7579f77SDag-Erling Smørgrav 		memset(edns, 0, sizeof(*edns));
1148b7579f77SDag-Erling Smørgrav 		edns->udp_size = 512;
1149b7579f77SDag-Erling Smørgrav 		return 0;
1150b7579f77SDag-Erling Smørgrav 	}
1151b7579f77SDag-Erling Smørgrav 	/* check the found RRset */
1152b7579f77SDag-Erling Smørgrav 	/* most lenient check possible. ignore dname, use last opt */
1153b7579f77SDag-Erling Smørgrav 	if(found->section != LDNS_SECTION_ADDITIONAL)
1154b7579f77SDag-Erling Smørgrav 		return LDNS_RCODE_FORMERR;
1155b7579f77SDag-Erling Smørgrav 	if(found->rr_count == 0)
1156b7579f77SDag-Erling Smørgrav 		return LDNS_RCODE_FORMERR;
1157b7579f77SDag-Erling Smørgrav 	if(0) { /* strict checking of dname and RRcount */
1158b7579f77SDag-Erling Smørgrav 		if(found->dname_len != 1 || !found->dname
1159b7579f77SDag-Erling Smørgrav 			|| found->dname[0] != 0) return LDNS_RCODE_FORMERR;
1160b7579f77SDag-Erling Smørgrav 		if(found->rr_count != 1) return LDNS_RCODE_FORMERR;
1161b7579f77SDag-Erling Smørgrav 	}
1162b7579f77SDag-Erling Smørgrav 	log_assert(found->rr_first && found->rr_last);
1163b7579f77SDag-Erling Smørgrav 
1164b7579f77SDag-Erling Smørgrav 	/* remove from packet */
1165b7579f77SDag-Erling Smørgrav 	if(found_prev)	found_prev->rrset_all_next = found->rrset_all_next;
1166b7579f77SDag-Erling Smørgrav 	else	msg->rrset_first = found->rrset_all_next;
1167b7579f77SDag-Erling Smørgrav 	if(found == msg->rrset_last)
1168b7579f77SDag-Erling Smørgrav 		msg->rrset_last = found_prev;
1169b7579f77SDag-Erling Smørgrav 	msg->arcount --;
1170b7579f77SDag-Erling Smørgrav 	msg->ar_rrsets --;
1171b7579f77SDag-Erling Smørgrav 	msg->rrset_count --;
1172b7579f77SDag-Erling Smørgrav 
1173b7579f77SDag-Erling Smørgrav 	/* take the data ! */
1174b7579f77SDag-Erling Smørgrav 	edns->edns_present = 1;
1175b7579f77SDag-Erling Smørgrav 	edns->ext_rcode = found->rr_last->ttl_data[0];
1176b7579f77SDag-Erling Smørgrav 	edns->edns_version = found->rr_last->ttl_data[1];
117717d15b25SDag-Erling Smørgrav 	edns->bits = sldns_read_uint16(&found->rr_last->ttl_data[2]);
1178b7579f77SDag-Erling Smørgrav 	edns->udp_size = ntohs(found->rrset_class);
117924e36522SCy Schubert 	edns->opt_list_in = NULL;
118024e36522SCy Schubert 	edns->opt_list_out = NULL;
118124e36522SCy Schubert 	edns->opt_list_inplace_cb_out = NULL;
1182f44e67d1SCy Schubert 	edns->padding_block_size = 0;
1183*8f76bb7dSCy Schubert 	edns->cookie_present = 0;
1184*8f76bb7dSCy Schubert 	edns->cookie_valid = 0;
1185e2d15004SDag-Erling Smørgrav 
1186e2d15004SDag-Erling Smørgrav 	/* take the options */
1187c7f4d7adSDag-Erling Smørgrav 	rdata_len = found->rr_first->size-2;
1188e2d15004SDag-Erling Smørgrav 	rdata_ptr = found->rr_first->ttl_data+6;
1189e2d15004SDag-Erling Smørgrav 
119024e36522SCy Schubert 	/* while still more options, and have code+len to read */
119124e36522SCy Schubert 	/* ignores partial content (i.e. rdata len 3) */
119224e36522SCy Schubert 	while(rdata_len >= 4) {
119324e36522SCy Schubert 		uint16_t opt_code = sldns_read_uint16(rdata_ptr);
119424e36522SCy Schubert 		uint16_t opt_len = sldns_read_uint16(rdata_ptr+2);
119524e36522SCy Schubert 		rdata_ptr += 4;
119624e36522SCy Schubert 		rdata_len -= 4;
119724e36522SCy Schubert 		if(opt_len > rdata_len)
119824e36522SCy Schubert 			break; /* option code partial */
119924e36522SCy Schubert 
120024e36522SCy Schubert 		if(!edns_opt_list_append(&edns->opt_list_in,
120124e36522SCy Schubert 				opt_code, opt_len, rdata_ptr, region)) {
120224e36522SCy Schubert 			log_err("out of memory");
120324e36522SCy Schubert 			break;
120424e36522SCy Schubert 		}
120524e36522SCy Schubert 		rdata_ptr += opt_len;
120624e36522SCy Schubert 		rdata_len -= opt_len;
120724e36522SCy Schubert 	}
1208e2d15004SDag-Erling Smørgrav 	/* ignore rrsigs */
120924e36522SCy Schubert 	return LDNS_RCODE_NOERROR;
1210b7579f77SDag-Erling Smørgrav }
1211b7579f77SDag-Erling Smørgrav 
12120fb34990SDag-Erling Smørgrav /** skip RR in packet */
12130fb34990SDag-Erling Smørgrav static int
12140fb34990SDag-Erling Smørgrav skip_pkt_rr(sldns_buffer* pkt)
12150fb34990SDag-Erling Smørgrav {
12160fb34990SDag-Erling Smørgrav 	if(sldns_buffer_remaining(pkt) < 1) return 0;
12170fb34990SDag-Erling Smørgrav 	if(!pkt_dname_len(pkt))
12180fb34990SDag-Erling Smørgrav 		return 0;
12190fb34990SDag-Erling Smørgrav 	if(sldns_buffer_remaining(pkt) < 4) return 0;
12200fb34990SDag-Erling Smørgrav 	sldns_buffer_skip(pkt, 4); /* type and class */
12210fb34990SDag-Erling Smørgrav 	if(!skip_ttl_rdata(pkt))
12220fb34990SDag-Erling Smørgrav 		return 0;
12230fb34990SDag-Erling Smørgrav 	return 1;
12240fb34990SDag-Erling Smørgrav }
12250fb34990SDag-Erling Smørgrav 
12260fb34990SDag-Erling Smørgrav /** skip RRs from packet */
1227a39a5a69SCy Schubert int
12280fb34990SDag-Erling Smørgrav skip_pkt_rrs(sldns_buffer* pkt, int num)
12290fb34990SDag-Erling Smørgrav {
12300fb34990SDag-Erling Smørgrav 	int i;
12310fb34990SDag-Erling Smørgrav 	for(i=0; i<num; i++) {
12320fb34990SDag-Erling Smørgrav 		if(!skip_pkt_rr(pkt))
12330fb34990SDag-Erling Smørgrav 			return 0;
12340fb34990SDag-Erling Smørgrav 	}
12350fb34990SDag-Erling Smørgrav 	return 1;
12360fb34990SDag-Erling Smørgrav }
12370fb34990SDag-Erling Smørgrav 
1238b7579f77SDag-Erling Smørgrav int
123924e36522SCy Schubert parse_edns_from_query_pkt(sldns_buffer* pkt, struct edns_data* edns,
1240*8f76bb7dSCy Schubert 	struct config_file* cfg, struct comm_point* c,
1241*8f76bb7dSCy Schubert 	struct comm_reply* repinfo, time_t now, struct regional* region)
1242b7579f77SDag-Erling Smørgrav {
1243e2d15004SDag-Erling Smørgrav 	size_t rdata_len;
1244e2d15004SDag-Erling Smørgrav 	uint8_t* rdata_ptr;
124517d15b25SDag-Erling Smørgrav 	log_assert(LDNS_QDCOUNT(sldns_buffer_begin(pkt)) == 1);
12460eefd307SCy Schubert 	memset(edns, 0, sizeof(*edns));
12470fb34990SDag-Erling Smørgrav 	if(LDNS_ANCOUNT(sldns_buffer_begin(pkt)) != 0 ||
12480fb34990SDag-Erling Smørgrav 		LDNS_NSCOUNT(sldns_buffer_begin(pkt)) != 0) {
12490fb34990SDag-Erling Smørgrav 		if(!skip_pkt_rrs(pkt, ((int)LDNS_ANCOUNT(sldns_buffer_begin(pkt)))+
12500fb34990SDag-Erling Smørgrav 			((int)LDNS_NSCOUNT(sldns_buffer_begin(pkt)))))
12510eefd307SCy Schubert 			return LDNS_RCODE_FORMERR;
12520fb34990SDag-Erling Smørgrav 	}
1253b7579f77SDag-Erling Smørgrav 	/* check edns section is present */
125417d15b25SDag-Erling Smørgrav 	if(LDNS_ARCOUNT(sldns_buffer_begin(pkt)) > 1) {
1255b7579f77SDag-Erling Smørgrav 		return LDNS_RCODE_FORMERR;
1256b7579f77SDag-Erling Smørgrav 	}
125717d15b25SDag-Erling Smørgrav 	if(LDNS_ARCOUNT(sldns_buffer_begin(pkt)) == 0) {
1258b7579f77SDag-Erling Smørgrav 		edns->udp_size = 512;
1259b7579f77SDag-Erling Smørgrav 		return 0;
1260b7579f77SDag-Erling Smørgrav 	}
1261b7579f77SDag-Erling Smørgrav 	/* domain name must be the root of length 1. */
1262b7579f77SDag-Erling Smørgrav 	if(pkt_dname_len(pkt) != 1)
1263b7579f77SDag-Erling Smørgrav 		return LDNS_RCODE_FORMERR;
126417d15b25SDag-Erling Smørgrav 	if(sldns_buffer_remaining(pkt) < 10) /* type, class, ttl, rdatalen */
1265b7579f77SDag-Erling Smørgrav 		return LDNS_RCODE_FORMERR;
126617d15b25SDag-Erling Smørgrav 	if(sldns_buffer_read_u16(pkt) != LDNS_RR_TYPE_OPT)
1267b7579f77SDag-Erling Smørgrav 		return LDNS_RCODE_FORMERR;
1268b7579f77SDag-Erling Smørgrav 	edns->edns_present = 1;
126917d15b25SDag-Erling Smørgrav 	edns->udp_size = sldns_buffer_read_u16(pkt); /* class is udp size */
127017d15b25SDag-Erling Smørgrav 	edns->ext_rcode = sldns_buffer_read_u8(pkt); /* ttl used for bits */
127117d15b25SDag-Erling Smørgrav 	edns->edns_version = sldns_buffer_read_u8(pkt);
127217d15b25SDag-Erling Smørgrav 	edns->bits = sldns_buffer_read_u16(pkt);
127324e36522SCy Schubert 	edns->opt_list_in = NULL;
127424e36522SCy Schubert 	edns->opt_list_out = NULL;
127524e36522SCy Schubert 	edns->opt_list_inplace_cb_out = NULL;
1276f44e67d1SCy Schubert 	edns->padding_block_size = 0;
1277*8f76bb7dSCy Schubert 	edns->cookie_present = 0;
1278*8f76bb7dSCy Schubert 	edns->cookie_valid = 0;
1279e2d15004SDag-Erling Smørgrav 
1280e2d15004SDag-Erling Smørgrav 	/* take the options */
1281e2d15004SDag-Erling Smørgrav 	rdata_len = sldns_buffer_read_u16(pkt);
1282e2d15004SDag-Erling Smørgrav 	if(sldns_buffer_remaining(pkt) < rdata_len)
1283e2d15004SDag-Erling Smørgrav 		return LDNS_RCODE_FORMERR;
1284e2d15004SDag-Erling Smørgrav 	rdata_ptr = sldns_buffer_current(pkt);
1285e2d15004SDag-Erling Smørgrav 	/* ignore rrsigs */
128624e36522SCy Schubert 	return parse_edns_options_from_query(rdata_ptr, rdata_len, edns, cfg,
1287*8f76bb7dSCy Schubert 		c, repinfo, now, region);
1288b7579f77SDag-Erling Smørgrav }
1289bc892140SDag-Erling Smørgrav 
1290bc892140SDag-Erling Smørgrav void
1291bc892140SDag-Erling Smørgrav log_edns_opt_list(enum verbosity_value level, const char* info_str,
1292bc892140SDag-Erling Smørgrav 	struct edns_option* list)
1293bc892140SDag-Erling Smørgrav {
1294bc892140SDag-Erling Smørgrav 	if(verbosity >= level && list) {
1295bc892140SDag-Erling Smørgrav 		char str[128], *s;
1296bc892140SDag-Erling Smørgrav 		size_t slen;
1297bc892140SDag-Erling Smørgrav 		verbose(level, "%s", info_str);
1298bc892140SDag-Erling Smørgrav 		while(list) {
1299bc892140SDag-Erling Smørgrav 			s = str;
1300bc892140SDag-Erling Smørgrav 			slen = sizeof(str);
1301bc892140SDag-Erling Smørgrav 			(void)sldns_wire2str_edns_option_print(&s, &slen, list->opt_code,
1302bc892140SDag-Erling Smørgrav 				list->opt_data, list->opt_len);
1303bc892140SDag-Erling Smørgrav 			verbose(level, "  %s", str);
1304bc892140SDag-Erling Smørgrav 			list = list->next;
1305bc892140SDag-Erling Smørgrav 		}
1306bc892140SDag-Erling Smørgrav 	}
1307bc892140SDag-Erling Smørgrav }
1308a39a5a69SCy Schubert 
1309