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