unbound/services/mesh.c

150 	return query_info_compare(&a->s.qinfo, &b->s.qinfo);
258 				m->s.qinfo.qname, m->s.qinfo.qtype,
259 				m->s.qinfo.qclass);
271 			/* restore the query - note that the qinfo ptr to
281 void mesh_new_client(struct mesh_area* mesh, struct query_info* qinfo,
285 	struct mesh_state* s = mesh_area_find(mesh, qinfo, qflags&(BIT_RD|BIT_CD), 0, 0);
315 		s = mesh_state_create(mesh->env, qinfo, qflags&(BIT_RD|BIT_CD), 0, 0);
319 				qinfo, qid, qflags, edns);
339 	if(!mesh_state_add_reply(s, edns, rep, qid, qflags, qinfo->qname)) {
342 				qinfo, qid, qflags, edns);
375 mesh_new_callback(struct mesh_area* mesh, struct query_info* qinfo,
379 	struct mesh_state* s = mesh_area_find(mesh, qinfo, qflags&(BIT_RD|BIT_CD), 0, 0);
390 		s = mesh_state_create(mesh->env, qinfo, qflags&(BIT_RD|BIT_CD), 0, 0);
429 void mesh_new_prefetch(struct mesh_area* mesh, struct query_info* qinfo,
432 	struct mesh_state* s = mesh_area_find(mesh, qinfo, qflags&(BIT_RD|BIT_CD), 0, 0);
451 	s = mesh_state_create(mesh->env, qinfo, qflags&(BIT_RD|BIT_CD), 0, 0);
499 mesh_state_create(struct module_env* env, struct query_info* qinfo,
525 	mstate->s.qinfo.qtype = qinfo->qtype;
526 	mstate->s.qinfo.qclass = qinfo->qclass;
527 	mstate->s.qinfo.qname_len = qinfo->qname_len;
528 	mstate->s.qinfo.qname = regional_alloc_init(region, qinfo->qname,
529 		qinfo->qname_len);
530 	if(!mstate->s.qinfo.qname) {
683 int mesh_attach_sub(struct module_qstate* qstate, struct query_info* qinfo,
688 	struct mesh_state* sub = mesh_area_find(mesh, qinfo, qflags, prime,
700 		sub = mesh_state_create(qstate->env, qinfo, qflags, prime,
812 		if(!reply_info_answer_encode(&m->s.qinfo, rep, r->qid,
870 			r->qname, m->s.qinfo.qname_len);
873 		m->s.qinfo.qname = r->qname;
874 		error_encode(r->query_reply.c->buffer, rcode, &m->s.qinfo,
883 		m->s.qinfo.qname = r->qname;
884 		if(!reply_info_answer_encode(&m->s.qinfo, rep, r->qid,
890 				LDNS_RCODE_SERVFAIL, &m->s.qinfo, r->qid,
948 	struct query_info* qinfo, uint16_t qflags, int prime, int valrec)
956 	key.s.qinfo = *qinfo;
998 		s->s.qinfo.qname_len);
1030 			&mstate->s.qinfo);
1039 				&mstate->s.qinfo);
1125 		log_query_info(VERB_ALGO, buf, &m->s.qinfo);
1186 mesh_detect_cycle(struct module_qstate* qstate, struct query_info* qinfo,
1190 	struct mesh_state* dep_m = mesh_area_find(mesh, qinfo, flags, prime,