games/hunt/huntd/driver.c

1118

u_int16_t query;

games/hunt/huntd/driver.c

1122

if (recvfrom(fd, &query, sizeof query, 0, &fromaddr, &fromlen) == -1)

games/hunt/huntd/driver.c

1129

fprintf(stderr, "query %d (%s) from %s:%d\n", query,

games/hunt/huntd/driver.c

1130

query == C_MESSAGE ? "C_MESSAGE" :

games/hunt/huntd/driver.c

1131

query == C_SCORES ? "C_SCORES" :

games/hunt/huntd/driver.c

1132

query == C_PLAYER ? "C_PLAYER" :

games/hunt/huntd/driver.c

1133

query == C_MONITOR ? "C_MONITOR" : "?",

games/hunt/huntd/driver.c

1138

query = ntohs(query);

games/hunt/huntd/driver.c

1140

switch (query) {

games/hunt/huntd/driver.c

1155

if (query == C_MONITOR && Nplayer <= 0)

games/hunt/huntd/driver.c

1162

logit(LOG_INFO, "unknown udp query %d", query);

games/robots/main.c

197

if (query("Another game?")) {

games/robots/move.c

174

if (query("Really quit?"))

games/robots/robots.h

116

int query(char *);

include/resolv.h

223

const unsigned char **query,

include/resolv.h

230

const unsigned char *query,

lib/libc/asr/getrrsetbyname_async.c

239

struct dns_query *query;

lib/libc/asr/getrrsetbyname_async.c

284

rrset->rri_rdclass = response->query->class;

lib/libc/asr/getrrsetbyname_async.c

285

rrset->rri_rdtype = response->query->type;

lib/libc/asr/getrrsetbyname_async.c

397

resp->query = parse_dns_qsection(answer, size, &cp,

lib/libc/asr/getrrsetbyname_async.c

399

if (resp->header.qdcount && resp->query == NULL) {

lib/libc/asr/getrrsetbyname_async.c

602

free_dns_query(p->query);

regress/lib/libc/asr/bin/common.c

564

unpack_query(struct packed *p, struct query *q)

regress/lib/libc/asr/bin/common.h

137

int unpack_query(struct packed*, struct query*);

regress/lib/libc/asr/bin/res_mkquery.c

133

struct query q;

regress/lib/libc/asr/bin/res_mkquery.c

266

print_query(struct query *q, char *buf, size_t max)

regress/lib/libc/asr/bin/res_mkquery.c

39

static char *print_query(struct query *, char *, size_t);

regress/lib/libc/asr/bin/res_query.c

169

struct query q;

regress/lib/libc/asr/bin/res_query.c

302

print_query(struct query *q, char *buf, size_t max)

regress/lib/libc/asr/bin/res_query.c

40

static char *print_query(struct query *, char *, size_t);

sbin/dump/dump.h

93

int query(char *question);

sbin/dump/optr.c

164

if (query("Do you want to abort dump?"))

sbin/dump/tape.c

208

if (!query("Do you want to restart?"))

sbin/dump/tape.c

439

while (!query("Is the new volume mounted and ready to go?"))

sbin/dump/tape.c

440

if (query("Do you want to abort?")) {

sbin/dump/tape.c

670

if (!query("Do you want to retry the open?"))

sbin/dump/traverse.c

842

if (!query("Do you want to attempt to continue?")){

sbin/unwind/frontend.c

248

udp4ev.rcviov[0].iov_base = (caddr_t)udp4ev.query;

sbin/unwind/frontend.c

249

udp4ev.rcviov[0].iov_len = sizeof(udp4ev.query);

sbin/unwind/frontend.c

255

udp6ev.rcviov[0].iov_base = (caddr_t)udp6ev.query;

sbin/unwind/frontend.c

256

udp6ev.rcviov[0].iov_len = sizeof(udp6ev.query);

sbin/unwind/frontend.c

737

sldns_buffer_write(pq->qbuf, udpev->query, len);

sbin/unwind/frontend.c

86

uint8_t query[65536];

sbin/unwind/libunbound/services/outside_network.c

1064

if(pend->query && pend->query->error_count == 0 &&

sbin/unwind/libunbound/services/outside_network.c

1065

pend->c->tcp_write_pkt == pend->query->pkt &&

sbin/unwind/libunbound/services/outside_network.c

1066

pend->c->tcp_write_pkt_len == pend->query->pkt_len) {

sbin/unwind/libunbound/services/outside_network.c

1069

if(verbosity >= VERB_CLIENT && pend->query->pkt_len > 12+2+2 &&

sbin/unwind/libunbound/services/outside_network.c

1070

LDNS_QDCOUNT(pend->query->pkt) > 0 &&

sbin/unwind/libunbound/services/outside_network.c

1071

dname_valid(pend->query->pkt+12, pend->query->pkt_len-12)) {

sbin/unwind/libunbound/services/outside_network.c

1073

dname_str(pend->query->pkt+12, buf);

sbin/unwind/libunbound/services/outside_network.c

1083

w = pend->query;

sbin/unwind/libunbound/services/outside_network.c

1084

pend->query = NULL;

sbin/unwind/libunbound/services/outside_network.c

1215

pend->query = NULL;

sbin/unwind/libunbound/services/outside_network.c

1262

pend->query = NULL;

sbin/unwind/libunbound/services/outside_network.c

1322

log_assert(pend->query->pkt == pend->c->tcp_write_pkt);

sbin/unwind/libunbound/services/outside_network.c

1323

log_assert(pend->query->pkt_len == pend->c->tcp_write_pkt_len);

sbin/unwind/libunbound/services/outside_network.c

1327

log_assert(pend->query->id_node.key);

sbin/unwind/libunbound/services/outside_network.c

1328

pend->query = NULL;

sbin/unwind/libunbound/services/outside_network.c

1337

pend->query = reuse_write_wait_pop(&pend->reuse);

sbin/unwind/libunbound/services/outside_network.c

1340

pend->query);

sbin/unwind/libunbound/services/outside_network.c

2513

if(pend->query == NULL) {

sbin/unwind/libunbound/services/outside_network.c

2517

pend->query = w;

sbin/unwind/libunbound/services/outside_network.c

3733

sldns_buffer* query, int timeout, int ssl, char* host)

sbin/unwind/libunbound/services/outside_network.c

3767

sldns_buffer_copy(cp->buffer, query);

sbin/unwind/libunbound/services/outside_network.c

3918

if(outnet->tcp_conns[i]->query)

sbin/unwind/libunbound/services/outside_network.c

3919

s += waiting_tcp_get_mem(outnet->tcp_conns[i]->query);

sbin/unwind/libunbound/services/outside_network.c

544

key_p.query = &key_w;

sbin/unwind/libunbound/services/outside_network.c

764

pend->query = w;

sbin/unwind/libunbound/services/outside_network.c

986

if(reuse->pending->query) {

sbin/unwind/libunbound/services/outside_network.c

993

reuse->pending->query = w;

sbin/unwind/libunbound/services/outside_network.h

358

struct waiting_tcp* query;

sbin/unwind/libunbound/services/outside_network.h

787

struct sldns_buffer* query, int timeout, int ssl, char* host);

sbin/unwind/libunbound/util/data/dname.c

52

query_dname_len(sldns_buffer* query)

sbin/unwind/libunbound/util/data/dname.c

57

if(sldns_buffer_remaining(query) < 1)

sbin/unwind/libunbound/util/data/dname.c

59

labellen = sldns_buffer_read_u8(query);

sbin/unwind/libunbound/util/data/dname.c

67

if(sldns_buffer_remaining(query) < labellen)

sbin/unwind/libunbound/util/data/dname.c

69

sldns_buffer_skip(query, (ssize_t)labellen);

sbin/unwind/libunbound/util/data/dname.h

59

size_t query_dname_len(struct sldns_buffer* query);

sbin/unwind/libunbound/util/data/msgreply.c

638

query_info_parse(struct query_info* m, sldns_buffer* query)

sbin/unwind/libunbound/util/data/msgreply.c

640

uint8_t* q = sldns_buffer_begin(query);

sbin/unwind/libunbound/util/data/msgreply.c

642

if(sldns_buffer_limit(query) < LDNS_HEADER_SIZE + 5)

sbin/unwind/libunbound/util/data/msgreply.c

646

sldns_buffer_position(query) != 0)

sbin/unwind/libunbound/util/data/msgreply.c

648

sldns_buffer_skip(query, LDNS_HEADER_SIZE);

sbin/unwind/libunbound/util/data/msgreply.c

649

m->qname = sldns_buffer_current(query);

sbin/unwind/libunbound/util/data/msgreply.c

650

if((m->qname_len = query_dname_len(query)) == 0)

sbin/unwind/libunbound/util/data/msgreply.c

652

if(sldns_buffer_remaining(query) < 4)

sbin/unwind/libunbound/util/data/msgreply.c

654

m->qtype = sldns_buffer_read_u16(query);

sbin/unwind/libunbound/util/data/msgreply.c

655

m->qclass = sldns_buffer_read_u16(query);

sbin/unwind/libunbound/util/data/msgreply.h

285

int query_info_parse(struct query_info* m, struct sldns_buffer* query);

sbin/vnconfig/vnconfig.c

242

query:

sbin/vnconfig/vnconfig.c

256

goto query;

sbin/vnconfig/vnconfig.c

270

goto query;

sys/dev/ic/mpi.c

1854

u_int32_t *query = buf;

sys/dev/ic/mpi.c

1886

mpi_write_db(sc, htole32(query[i]));

sys/dev/ic/ufshci.c

1017

ucd->cmd.hdr.query = 0;

sys/dev/ic/ufshci.c

1134

ucd->cmd.hdr.query = 0;

sys/dev/ic/ufshci.c

1249

ucd->cmd.hdr.query = 0;

sys/dev/ic/ufshci.c

1950

my->ucd.cmd.hdr.query = 0;

sys/dev/ic/ufshci.c

602

ucd->cmd.hdr.query = 0;

sys/dev/ic/ufshci.c

693

ucd->cmd.hdr.query = 0;

sys/dev/ic/ufshci.c

801

ucd->cmd.hdr.query = 0;

sys/dev/ic/ufshci.c

907

ucd->cmd.hdr.query = 0;

sys/dev/ic/ufshcireg.h

359

uint8_t query;

sys/dev/pci/drm/amd/amdgpu/amdgpu_kms.c

1377

DRM_DEBUG_KMS("Invalid request %d\n", info->query);

sys/dev/pci/drm/amd/amdgpu/amdgpu_kms.c

637

switch (info->query) {

sys/dev/pci/drm/amd/display/amdgpu_dm/amdgpu_dm_hdcp.c

400

struct mod_hdcp_display_query query;

sys/dev/pci/drm/amd/display/amdgpu_dm/amdgpu_dm_hdcp.c

420

query.encryption_status = MOD_HDCP_ENCRYPTION_STATUS_HDCP_OFF;

sys/dev/pci/drm/amd/display/amdgpu_dm/amdgpu_dm_hdcp.c

422

&query);

sys/dev/pci/drm/amd/display/amdgpu_dm/amdgpu_dm_hdcp.c

427

query.encryption_status,

sys/dev/pci/drm/amd/display/amdgpu_dm/amdgpu_dm_hdcp.c

430

if (query.encryption_status !=

sys/dev/pci/drm/amd/display/amdgpu_dm/amdgpu_dm_hdcp.c

434

query.encryption_status);

sys/dev/pci/drm/amd/display/amdgpu_dm/amdgpu_dm_hdcp.c

437

query.encryption_status;

sys/dev/pci/drm/amd/display/modules/hdcp/hdcp.c

486

uint8_t index, struct mod_hdcp_display_query *query)

sys/dev/pci/drm/amd/display/modules/hdcp/hdcp.c

499

query->link = &hdcp->connection.link;

sys/dev/pci/drm/amd/display/modules/hdcp/hdcp.c

500

query->display = display;

sys/dev/pci/drm/amd/display/modules/hdcp/hdcp.c

501

query->trace = &hdcp->connection.trace;

sys/dev/pci/drm/amd/display/modules/hdcp/hdcp.c

502

query->encryption_status = MOD_HDCP_ENCRYPTION_STATUS_HDCP_OFF;

sys/dev/pci/drm/amd/display/modules/hdcp/hdcp.c

506

query->encryption_status = MOD_HDCP_ENCRYPTION_STATUS_HDCP1_ON;

sys/dev/pci/drm/amd/display/modules/hdcp/hdcp.c

508

if (query->link->adjust.hdcp2.force_type == MOD_HDCP_FORCE_TYPE_0)

sys/dev/pci/drm/amd/display/modules/hdcp/hdcp.c

509

query->encryption_status = MOD_HDCP_ENCRYPTION_STATUS_HDCP2_TYPE0_ON;

sys/dev/pci/drm/amd/display/modules/hdcp/hdcp.c

510

else if (query->link->adjust.hdcp2.force_type == MOD_HDCP_FORCE_TYPE_1)

sys/dev/pci/drm/amd/display/modules/hdcp/hdcp.c

511

query->encryption_status = MOD_HDCP_ENCRYPTION_STATUS_HDCP2_TYPE1_ON;

sys/dev/pci/drm/amd/display/modules/hdcp/hdcp.c

513

query->encryption_status = MOD_HDCP_ENCRYPTION_STATUS_HDCP2_ON;

sys/dev/pci/drm/amd/display/modules/hdcp/hdcp.c

516

query->encryption_status = MOD_HDCP_ENCRYPTION_STATUS_HDCP_OFF;

sys/dev/pci/drm/amd/display/modules/inc/mod_hdcp.h

341

uint8_t index, struct mod_hdcp_display_query *query);

sys/dev/pci/drm/amd/pm/amdgpu_pm.c

1428

void *query)

sys/dev/pci/drm/amd/pm/amdgpu_pm.c

1437

r = amdgpu_dpm_read_sensor(adev, sensor, query, &size);

sys/dev/pci/drm/amd/pm/amdgpu_pm.c

3267

u32 query = 0;

sys/dev/pci/drm/amd/pm/amdgpu_pm.c

3270

r = amdgpu_pm_get_sensor_generic(adev, sensor, (void *)&query);

sys/dev/pci/drm/amd/pm/amdgpu_pm.c

3275

uw = (query >> 8) * 1000000 + (query & 0xff) * 1000;

sys/dev/pci/drm/amd/pm/amdgpu_pm.c

4818

uint32_t query = 0;

sys/dev/pci/drm/amd/pm/amdgpu_pm.c

4840

if (!amdgpu_dpm_read_sensor(adev, AMDGPU_PP_SENSOR_GPU_AVG_POWER, (void *)&query, &size)) {

sys/dev/pci/drm/amd/pm/amdgpu_pm.c

4842

seq_printf(m, "\t%u.%02u W (average SoC including CPU)\n", query >> 8, query & 0xff);

sys/dev/pci/drm/amd/pm/amdgpu_pm.c

4844

seq_printf(m, "\t%u.%02u W (average SoC)\n", query >> 8, query & 0xff);

sys/dev/pci/drm/amd/pm/amdgpu_pm.c

4847

if (!amdgpu_dpm_read_sensor(adev, AMDGPU_PP_SENSOR_GPU_INPUT_POWER, (void *)&query, &size)) {

sys/dev/pci/drm/amd/pm/amdgpu_pm.c

4849

seq_printf(m, "\t%u.%02u W (current SoC including CPU)\n", query >> 8, query & 0xff);

sys/dev/pci/drm/amd/pm/amdgpu_pm.c

4851

seq_printf(m, "\t%u.%02u W (current SoC)\n", query >> 8, query & 0xff);

sys/dev/pci/drm/amd/pm/powerplay/hwmgr/smu7_hwmgr.c

3952

static int smu7_get_gpu_power(struct pp_hwmgr *hwmgr, u32 *query)

sys/dev/pci/drm/amd/pm/powerplay/hwmgr/smu7_hwmgr.c

3958

if (!query)

sys/dev/pci/drm/amd/pm/powerplay/hwmgr/smu7_hwmgr.c

3973

*query = tmp;

sys/dev/pci/drm/amd/pm/powerplay/hwmgr/smu7_hwmgr.c

3992

*query = tmp;

sys/dev/pci/drm/amd/pm/powerplay/hwmgr/vega10_hwmgr.c

3929

uint32_t *query)

sys/dev/pci/drm/amd/pm/powerplay/hwmgr/vega10_hwmgr.c

3934

if (!query)

sys/dev/pci/drm/amd/pm/powerplay/hwmgr/vega10_hwmgr.c

3942

*query = value << 8;

sys/dev/pci/drm/amd/pm/powerplay/hwmgr/vega12_hwmgr.c

1413

static int vega12_get_gpu_power(struct pp_hwmgr *hwmgr, uint32_t *query)

sys/dev/pci/drm/amd/pm/powerplay/hwmgr/vega12_hwmgr.c

1422

*query = metrics_table.CurrSocketPower << 8;

sys/dev/pci/drm/amd/pm/powerplay/hwmgr/vega20_hwmgr.c

2144

uint32_t *query)

sys/dev/pci/drm/amd/pm/powerplay/hwmgr/vega20_hwmgr.c

2157

*query = metrics_table.AverageSocketPower << 8;

sys/dev/pci/drm/amd/pm/powerplay/hwmgr/vega20_hwmgr.c

2162

*query = metrics_table.CurrSocketPower << 8;

sys/dev/pci/drm/i915/i915_query.c

134

struct drm_i915_query_engine_info query;

sys/dev/pci/drm/i915/i915_query.c

148

ret = copy_query_item(&query, sizeof(query), len, query_item);

sys/dev/pci/drm/i915/i915_query.c

152

if (query.num_engines || query.rsvd[0] || query.rsvd[1] ||

sys/dev/pci/drm/i915/i915_query.c

153

query.rsvd[2])

sys/dev/pci/drm/i915/i915_query.c

168

query.num_engines++;

sys/dev/pci/drm/i915/i915_query.c

172

if (copy_to_user(query_ptr, &query, sizeof(query)))

sys/dev/pci/drm/i915/i915_query.c

479

struct drm_i915_query_memory_regions query;

sys/dev/pci/drm/i915/i915_query.c

487

total_length = sizeof(query);

sys/dev/pci/drm/i915/i915_query.c

495

ret = copy_query_item(&query, sizeof(query), total_length, query_item);

sys/dev/pci/drm/i915/i915_query.c

499

if (query.num_regions)

sys/dev/pci/drm/i915/i915_query.c

502

for (i = 0; i < ARRAY_SIZE(query.rsvd); i++) {

sys/dev/pci/drm/i915/i915_query.c

503

if (query.rsvd[i])

sys/dev/pci/drm/i915/i915_query.c

533

query.num_regions++;

sys/dev/pci/drm/i915/i915_query.c

537

if (__copy_to_user(query_ptr, &query, sizeof(query)))

sys/dev/pci/drm/i915/i915_query.c

567

struct drm_i915_query_item *query)

sys/dev/pci/drm/i915/i915_query.c

570

u64_to_user_ptr(query->data_ptr);

sys/dev/pci/drm/i915/i915_query.c

579

ret = copy_query_item(&ver, size, size, query);

sys/dev/pci/drm/include/uapi/drm/amdgpu_drm.h

1306

__u32 query;

sys/dev/pci/if_iwnreg.h

1513

uint32_t query;

sys/dev/pci/mpii.c

1197

u_int32_t *query = buf;

sys/dev/pci/mpii.c

1229

mpii_write_db(sc, htole32(query[i]));

sys/dev/pckbc/pms.c

1001

synaptics_query(struct pms_softc *sc, int query, int *val)

sys/dev/pckbc/pms.c

1005

if (pms_spec_cmd(sc, query) ||

usr.bin/bgplg/bgplg.c

248

char *query, *myname, *self, *cmd = NULL, *req;

usr.bin/bgplg/bgplg.c

283

if ((query = lg_getenv("QUERY_STRING", &query_length)) != NULL)

usr.bin/bgplg/bgplg.c

284

cmd = lg_getarg("cmd=", query, query_length);

usr.bin/bgplg/bgplg.c

303

if ((req = lg_getarg("req=", query, query_length)) != NULL) {

usr.bin/bgplg/bgplg.c

326

if (query == NULL)

usr.bin/dig/dig.c

175

received(unsigned int bytes, struct sockaddr_storage *from, dig_query_t *query) {

usr.bin/dig/dig.c

183

if (query->lookup->stats && !short_form) {

usr.bin/dig/dig.c

186

uelapsed(&query->time_recv, &query->time_sent));

usr.bin/dig/dig.c

189

uelapsed(&query->time_recv, &query->time_sent) /

usr.bin/dig/dig.c

191

printf(";; SERVER: %s(%s)\n", fromtext, query->servname);

usr.bin/dig/dig.c

198

if (query->lookup->doing_xfr) {

usr.bin/dig/dig.c

201

query->rr_count, query->msg_count,

usr.bin/dig/dig.c

202

query->byte_count);

usr.bin/dig/dig.c

215

} else if (query->lookup->identify && !short_form) {

usr.bin/dig/dig.c

219

query->lookup->doing_xfr

usr.bin/dig/dig.c

220

? query->byte_count

usr.bin/dig/dig.c

222

fromtext, query->userarg,

usr.bin/dig/dig.c

223

uelapsed(&query->time_recv, &query->time_sent));

usr.bin/dig/dig.c

227

query->lookup->doing_xfr

usr.bin/dig/dig.c

228

? query->byte_count

usr.bin/dig/dig.c

230

fromtext, query->userarg,

usr.bin/dig/dig.c

231

uelapsed(&query->time_recv, &query->time_sent) /

usr.bin/dig/dig.c

251

say_message(dns_rdata_t *rdata, dig_query_t *query, isc_buffer_t *buf) {

usr.bin/dig/dig.c

256

if (query->lookup->trace || query->lookup->ns_search_only) {

usr.bin/dig/dig.c

273

if (query->lookup->identify) {

usr.bin/dig/dig.c

275

ADD_STRING(buf, query->servname);

usr.bin/dig/dig.c

278

uelapsed(&query->time_recv, &query->time_sent));

usr.bin/dig/dig.c

281

uelapsed(&query->time_recv, &query->time_sent) /

usr.bin/dig/dig.c

294

isc_buffer_t *buf, dig_query_t *query)

usr.bin/dig/dig.c

321

result = say_message(&rdata, query,

usr.bin/dig/dig.c

364

printmessage(dig_query_t *query, dns_message_t *msg, int headers) {

usr.bin/dig/dig.c

373

if (query->lookup->comments)

usr.bin/dig/dig.c

409

if (query->lookup->cmdline[0] != 0) {

usr.bin/dig/dig.c

411

fputs(query->lookup->cmdline, stdout);

usr.bin/dig/dig.c

412

query->lookup->cmdline[0]=0;

usr.bin/dig/dig.c

415

query->lookup->comments ? "comments" : "nocomments",

usr.bin/dig/dig.c

423

if (onesoa && query->lookup->rdtype == dns_rdatatype_axfr)

usr.bin/dig/dig.c

424

flags |= (query->msg_count == 0) ? DNS_MESSAGETEXTFLAG_ONESOA :

usr.bin/dig/dig.c

426

if (!query->lookup->comments)

usr.bin/dig/dig.c

432

if (query->lookup->comments && !short_form) {

usr.bin/dig/dig.c

433

if (query->lookup->cmdline[0] != 0)

usr.bin/dig/dig.c

434

printf("; %s\n", query->lookup->cmdline);

usr.bin/dig/dig.c

435

if (msg == query->lookup->sendmsg)

usr.bin/dig/dig.c

477

if (msg != query->lookup->sendmsg &&

usr.bin/dig/dig.c

483

if (msg != query->lookup->sendmsg &&

usr.bin/dig/dig.c

484

query->lookup->edns != -1 && msg->opt == NULL &&

usr.bin/dig/dig.c

490

query->lookup->dnssec ? "+nodnssec ": "");

usr.bin/dig/dig.c

491

if (msg != query->lookup->sendmsg && extrabytes != 0U)

usr.bin/dig/dig.c

498

if (query->lookup->comments && headers && !short_form) {

usr.bin/dig/dig.c

501

style, flags, query->lookup->textname, buf);

usr.bin/dig/dig.c

516

if (query->lookup->section_question && headers) {

usr.bin/dig/dig.c

526

if (query->lookup->section_answer) {

usr.bin/dig/dig.c

535

result = short_answer(msg, flags, buf, query);

usr.bin/dig/dig.c

541

if (query->lookup->section_authority) {

usr.bin/dig/dig.c

551

if (query->lookup->section_additional) {

usr.bin/dig/dig.c

567

query->lookup->textname,

usr.bin/dig/dig.c

577

query->lookup->textname,

usr.bin/dig/dig.c

587

if (headers && query->lookup->comments && !short_form)

usr.bin/dig/dig.h

346

(*dighost_printmessage)(dig_query_t *query, dns_message_t *msg, int headers);

usr.bin/dig/dig.h

352

(*dighost_received)(unsigned int bytes, struct sockaddr_storage *from, dig_query_t *query);

usr.bin/dig/dighost.c

1402

clear_query(dig_query_t *query) {

usr.bin/dig/dighost.c

1405

REQUIRE(query != NULL);

usr.bin/dig/dighost.c

1407

debug("clear_query(%p)", query);

usr.bin/dig/dighost.c

1409

if (query->timer != NULL)

usr.bin/dig/dighost.c

1410

isc_timer_detach(&query->timer);

usr.bin/dig/dighost.c

1411

lookup = query->lookup;

usr.bin/dig/dighost.c

1413

if (lookup->current_query == query)

usr.bin/dig/dighost.c

1416

if (ISC_LINK_LINKED(query, link))

usr.bin/dig/dighost.c

1417

ISC_LIST_UNLINK(lookup->q, query, link);

usr.bin/dig/dighost.c

1418

if (ISC_LINK_LINKED(query, clink))

usr.bin/dig/dighost.c

1419

ISC_LIST_UNLINK(lookup->connecting, query, clink);

usr.bin/dig/dighost.c

1420

if (ISC_LINK_LINKED(&query->recvbuf, link))

usr.bin/dig/dighost.c

1421

ISC_LIST_DEQUEUE(query->recvlist, &query->recvbuf,

usr.bin/dig/dighost.c

1423

if (ISC_LINK_LINKED(&query->lengthbuf, link))

usr.bin/dig/dighost.c

1424

ISC_LIST_DEQUEUE(query->lengthlist, &query->lengthbuf,

usr.bin/dig/dighost.c

1426

INSIST(query->recvspace != NULL);

usr.bin/dig/dighost.c

1428

if (query->sock != NULL) {

usr.bin/dig/dighost.c

1429

isc_socket_detach(&query->sock);

usr.bin/dig/dighost.c

1433

free(query->recvspace);

usr.bin/dig/dighost.c

1434

isc_buffer_invalidate(&query->recvbuf);

usr.bin/dig/dighost.c

1435

isc_buffer_invalidate(&query->lengthbuf);

usr.bin/dig/dighost.c

1436

if (query->waiting_senddone)

usr.bin/dig/dighost.c

1437

query->pending_free = 1;

usr.bin/dig/dighost.c

1439

free(query);

usr.bin/dig/dighost.c

1586

followup_lookup(dns_message_t *msg, dig_query_t *query, dns_section_t section)

usr.bin/dig/dighost.c

1604

debug("following up %s", query->lookup->textname);

usr.bin/dig/dighost.c

1629

if (query->lookup->trace && !query->lookup->trace_root) {

usr.bin/dig/dighost.c

1634

domain = dns_fixedname_name(&query->lookup->fdomain);

usr.bin/dig/dighost.c

1655

if (query->lookup->trace_root &&

usr.bin/dig/dighost.c

1656

query->lookup->nsfound >= MXSERV)

usr.bin/dig/dighost.c

1661

query->lookup->nsfound++;

usr.bin/dig/dighost.c

1672

lookup = requeue_lookup(query->lookup,

usr.bin/dig/dighost.c

1674

cancel_lookup(query->lookup);

usr.bin/dig/dighost.c

1680

lookup->trace = query->lookup->trace;

usr.bin/dig/dighost.c

1682

query->lookup->ns_search_only;

usr.bin/dig/dighost.c

1711

(query->lookup->trace || query->lookup->ns_search_only))

usr.bin/dig/dighost.c

1712

return (followup_lookup(msg, query, DNS_SECTION_AUTHORITY));

usr.bin/dig/dighost.c

177

(*dighost_printmessage)(dig_query_t *query, dns_message_t *msg,

usr.bin/dig/dighost.c

181

(*dighost_received)(unsigned int bytes, struct sockaddr_storage *from, dig_query_t *query);

usr.bin/dig/dighost.c

1905

dig_query_t *query;

usr.bin/dig/dighost.c

198

send_udp(dig_query_t *query);

usr.bin/dig/dighost.c

204

launch_next_query(dig_query_t *query, int include_question);

usr.bin/dig/dighost.c

2295

query = malloc(sizeof(dig_query_t));

usr.bin/dig/dighost.c

2296

if (query == NULL)

usr.bin/dig/dighost.c

2300

query, lookup);

usr.bin/dig/dighost.c

2301

query->lookup = lookup;

usr.bin/dig/dighost.c

2302

query->timer = NULL;

usr.bin/dig/dighost.c

2303

query->waiting_connect = 0;

usr.bin/dig/dighost.c

2304

query->waiting_senddone = 0;

usr.bin/dig/dighost.c

2305

query->pending_free = 0;

usr.bin/dig/dighost.c

2306

query->recv_made = 0;

usr.bin/dig/dighost.c

2307

query->first_pass = 1;

usr.bin/dig/dighost.c

2308

query->first_soa_rcvd = 0;

usr.bin/dig/dighost.c

2309

query->second_rr_rcvd = 0;

usr.bin/dig/dighost.c

2310

query->first_repeat_rcvd = 0;

usr.bin/dig/dighost.c

2311

query->warn_id = 1;

usr.bin/dig/dighost.c

2312

query->timedout = 0;

usr.bin/dig/dighost.c

2313

query->first_rr_serial = 0;

usr.bin/dig/dighost.c

2314

query->second_rr_serial = 0;

usr.bin/dig/dighost.c

2315

query->servname = serv->servername;

usr.bin/dig/dighost.c

2316

query->userarg = serv->userarg;

usr.bin/dig/dighost.c

2317

query->rr_count = 0;

usr.bin/dig/dighost.c

2318

query->msg_count = 0;

usr.bin/dig/dighost.c

2319

query->byte_count = 0;

usr.bin/dig/dighost.c

2320

query->ixfr_axfr = 0;

usr.bin/dig/dighost.c

2321

ISC_LIST_INIT(query->recvlist);

usr.bin/dig/dighost.c

2322

ISC_LIST_INIT(query->lengthlist);

usr.bin/dig/dighost.c

2323

query->sock = NULL;

usr.bin/dig/dighost.c

2324

query->recvspace = malloc(COMMSIZE);

usr.bin/dig/dighost.c

2325

if (query->recvspace == NULL)

usr.bin/dig/dighost.c

2328

isc_buffer_init(&query->recvbuf, query->recvspace, COMMSIZE);

usr.bin/dig/dighost.c

2329

isc_buffer_init(&query->lengthbuf, query->lengthspace, 2);

usr.bin/dig/dighost.c

2330

isc_buffer_init(&query->slbuf, query->slspace, 2);

usr.bin/dig/dighost.c

2331

query->sendbuf = lookup->renderbuf;

usr.bin/dig/dighost.c

2333

ISC_LINK_INIT(query, clink);

usr.bin/dig/dighost.c

2334

ISC_LINK_INIT(query, link);

usr.bin/dig/dighost.c

2335

ISC_LIST_ENQUEUE(lookup->q, query, link);

usr.bin/dig/dighost.c

2355

dig_query_t *query, *next;

usr.bin/dig/dighost.c

2374

query = event->ev_arg;

usr.bin/dig/dighost.c

2375

query->waiting_senddone = 0;

usr.bin/dig/dighost.c

2376

l = query->lookup;

usr.bin/dig/dighost.c

2380

next = ISC_LIST_NEXT(query, link);

usr.bin/dig/dighost.c

2387

if (query->pending_free)

usr.bin/dig/dighost.c

2388

free(query);

usr.bin/dig/dighost.c

2400

dig_query_t *query, *next;

usr.bin/dig/dighost.c

2403

query = ISC_LIST_HEAD(lookup->q);

usr.bin/dig/dighost.c

2404

while (query != NULL) {

usr.bin/dig/dighost.c

2405

next = ISC_LIST_NEXT(query, link);

usr.bin/dig/dighost.c

2406

if (query->sock != NULL) {

usr.bin/dig/dighost.c

2407

isc_socket_cancel(query->sock, global_task,

usr.bin/dig/dighost.c

2411

clear_query(query);

usr.bin/dig/dighost.c

2413

query = next;

usr.bin/dig/dighost.c

2420

bringup_timer(dig_query_t *query, unsigned int default_timeout) {

usr.bin/dig/dighost.c

2431

l = query->lookup;

usr.bin/dig/dighost.c

2432

if (ISC_LINK_LINKED(query, link) && ISC_LIST_NEXT(query, link) != NULL)

usr.bin/dig/dighost.c

2443

if (query->timer != NULL)

usr.bin/dig/dighost.c

2444

isc_timer_detach(&query->timer);

usr.bin/dig/dighost.c

2447

query, &query->timer);

usr.bin/dig/dighost.c

2452

force_timeout(dig_query_t *query) {

usr.bin/dig/dighost.c

2456

event = isc_event_allocate(query, ISC_TIMEREVENT_IDLE,

usr.bin/dig/dighost.c

2457

connect_timeout, query,

usr.bin/dig/dighost.c

2471

if (query->timer != NULL)

usr.bin/dig/dighost.c

2472

isc_timer_detach(&query->timer);

usr.bin/dig/dighost.c

2484

send_tcp_connect(dig_query_t *query) {

usr.bin/dig/dighost.c

2489

debug("send_tcp_connect(%p)", query);

usr.bin/dig/dighost.c

2491

l = query->lookup;

usr.bin/dig/dighost.c

2492

query->waiting_connect = 1;

usr.bin/dig/dighost.c

2493

query->lookup->current_query = query;

usr.bin/dig/dighost.c

2494

result = get_address(query->servname, port, &query->sockaddr);

usr.bin/dig/dighost.c

2501

force_timeout(query);

usr.bin/dig/dighost.c

2506

(isc_sockaddr_pf(&query->sockaddr) !=

usr.bin/dig/dighost.c

2509

"address family\n", query->servname);

usr.bin/dig/dighost.c

2510

query->waiting_connect = 0;

usr.bin/dig/dighost.c

2511

if (ISC_LINK_LINKED(query, link))

usr.bin/dig/dighost.c

2512

next = ISC_LIST_NEXT(query, link);

usr.bin/dig/dighost.c

2515

l = query->lookup;

usr.bin/dig/dighost.c

2516

clear_query(query);

usr.bin/dig/dighost.c

2526

INSIST(query->sock == NULL);

usr.bin/dig/dighost.c

2528

if (keep != NULL && isc_sockaddr_equal(&keepaddr, &query->sockaddr)) {

usr.bin/dig/dighost.c

2530

isc_socket_attach(keep, &query->sock);

usr.bin/dig/dighost.c

2531

query->waiting_connect = 0;

usr.bin/dig/dighost.c

2532

launch_next_query(query, 1);

usr.bin/dig/dighost.c

2537

isc_sockaddr_pf(&query->sockaddr),

usr.bin/dig/dighost.c

2538

isc_sockettype_tcp, &query->sock);

usr.bin/dig/dighost.c

2543

result = isc_socket_bind(query->sock, &bind_address,

usr.bin/dig/dighost.c

2546

if ((isc_sockaddr_pf(&query->sockaddr) == AF_INET) &&

usr.bin/dig/dighost.c

2551

result = isc_socket_bind(query->sock, &bind_any, 0);

usr.bin/dig/dighost.c

2554

bringup_timer(query, TCP_TIMEOUT);

usr.bin/dig/dighost.c

2555

result = isc_socket_connect(query->sock, &query->sockaddr,

usr.bin/dig/dighost.c

2556

global_task, connect_done, query);

usr.bin/dig/dighost.c

2565

if (ISC_LINK_LINKED(query, link)) {

usr.bin/dig/dighost.c

2566

next = ISC_LIST_NEXT(query, link);

usr.bin/dig/dighost.c

2567

ISC_LIST_DEQUEUE(l->q, query, link);

usr.bin/dig/dighost.c

2570

ISC_LIST_ENQUEUE(l->connecting, query, clink);

usr.bin/dig/dighost.c

2593

send_udp(dig_query_t *query) {

usr.bin/dig/dighost.c

2598

debug("send_udp(%p)", query);

usr.bin/dig/dighost.c

2600

l = query->lookup;

usr.bin/dig/dighost.c

2601

bringup_timer(query, UDP_TIMEOUT);

usr.bin/dig/dighost.c

2602

l->current_query = query;

usr.bin/dig/dighost.c

2603

debug("working on lookup %p, query %p", query->lookup, query);

usr.bin/dig/dighost.c

2604

if (!query->recv_made) {

usr.bin/dig/dighost.c

2606

query->waiting_connect = 0;

usr.bin/dig/dighost.c

2607

result = get_address(query->servname, port, &query->sockaddr);

usr.bin/dig/dighost.c

2610

force_timeout(query);

usr.bin/dig/dighost.c

2615

isc_sockaddr_pf(&query->sockaddr),

usr.bin/dig/dighost.c

2616

isc_sockettype_udp, &query->sock);

usr.bin/dig/dighost.c

2621

result = isc_socket_bind(query->sock, &bind_address,

usr.bin/dig/dighost.c

2625

isc_sockaddr_pf(&query->sockaddr));

usr.bin/dig/dighost.c

2626

result = isc_socket_bind(query->sock, &bind_any, 0);

usr.bin/dig/dighost.c

2630

query->recv_made = 1;

usr.bin/dig/dighost.c

2631

ISC_LINK_INIT(&query->recvbuf, link);

usr.bin/dig/dighost.c

2632

ISC_LIST_ENQUEUE(query->recvlist, &query->recvbuf,

usr.bin/dig/dighost.c

2635

query->lookup, query, query->sock);

usr.bin/dig/dighost.c

2636

result = isc_socket_recvv(query->sock, &query->recvlist, 1,

usr.bin/dig/dighost.c

2637

global_task, recv_done, query);

usr.bin/dig/dighost.c

2642

ISC_LIST_INIT(query->sendlist);

usr.bin/dig/dighost.c

2643

sendbuf = clone_buffer(&query->sendbuf);

usr.bin/dig/dighost.c

2644

ISC_LIST_ENQUEUE(query->sendlist, sendbuf, link);

usr.bin/dig/dighost.c

2646

clock_gettime(CLOCK_MONOTONIC, &query->time_sent);

usr.bin/dig/dighost.c

2647

INSIST(query->sock != NULL);

usr.bin/dig/dighost.c

2648

query->waiting_senddone = 1;

usr.bin/dig/dighost.c

2649

result = isc_socket_sendtov2(query->sock, &query->sendlist,

usr.bin/dig/dighost.c

2650

global_task, send_done, query,

usr.bin/dig/dighost.c

2651

&query->sockaddr, NULL,

usr.bin/dig/dighost.c

2665

dig_query_t *query = NULL, *cq;

usr.bin/dig/dighost.c

2672

query = event->ev_arg;

usr.bin/dig/dighost.c

2673

l = query->lookup;

usr.bin/dig/dighost.c

2678

if ((query != NULL) && (query->lookup->current_query != NULL) &&

usr.bin/dig/dighost.c

2679

ISC_LINK_LINKED(query->lookup->current_query, link) &&

usr.bin/dig/dighost.c

2680

(ISC_LIST_NEXT(query->lookup->current_query, link) != NULL)) {

usr.bin/dig/dighost.c

2682

cq = query->lookup->current_query;

usr.bin/dig/dighost.c

2686

if (query->sock != NULL)

usr.bin/dig/dighost.c

2687

isc_socket_cancel(query->sock, NULL,

usr.bin/dig/dighost.c

2694

if (l->tcp_mode && query->sock != NULL) {

usr.bin/dig/dighost.c

2695

query->timedout = 1;

usr.bin/dig/dighost.c

2696

isc_socket_cancel(query->sock, NULL, ISC_SOCKCANCEL_ALL);

usr.bin/dig/dighost.c

2734

dig_query_t *query = NULL;

usr.bin/dig/dighost.c

2746

query = event->ev_arg;

usr.bin/dig/dighost.c

2752

INSIST(b == &query->lengthbuf);

usr.bin/dig/dighost.c

2757

l = query->lookup;

usr.bin/dig/dighost.c

2758

clear_query(query);

usr.bin/dig/dighost.c

2764

isc_sockaddr_format(&query->sockaddr, sockstr,

usr.bin/dig/dighost.c

2770

l = query->lookup;

usr.bin/dig/dighost.c

2771

isc_socket_detach(&query->sock);

usr.bin/dig/dighost.c

2780

clear_query(query);

usr.bin/dig/dighost.c

2788

launch_next_query(query, 0);

usr.bin/dig/dighost.c

2796

isc_buffer_invalidate(&query->recvbuf);

usr.bin/dig/dighost.c

2797

isc_buffer_init(&query->recvbuf, query->recvspace, length);

usr.bin/dig/dighost.c

2798

ENSURE(ISC_LIST_EMPTY(query->recvlist));

usr.bin/dig/dighost.c

2799

ISC_LINK_INIT(&query->recvbuf, link);

usr.bin/dig/dighost.c

2800

ISC_LIST_ENQUEUE(query->recvlist, &query->recvbuf, link);

usr.bin/dig/dighost.c

2801

debug("recving with lookup=%p, query=%p", query->lookup, query);

usr.bin/dig/dighost.c

2802

result = isc_socket_recvv(query->sock, &query->recvlist, length, task,

usr.bin/dig/dighost.c

2803

recv_done, query);

usr.bin/dig/dighost.c

2816

launch_next_query(dig_query_t *query, int include_question) {

usr.bin/dig/dighost.c

2825

if (!query->lookup->pending) {

usr.bin/dig/dighost.c

2827

isc_socket_detach(&query->sock);

usr.bin/dig/dighost.c

2831

query->waiting_connect = 0;

usr.bin/dig/dighost.c

2832

l = query->lookup;

usr.bin/dig/dighost.c

2833

clear_query(query);

usr.bin/dig/dighost.c

2838

isc_buffer_clear(&query->slbuf);

usr.bin/dig/dighost.c

2839

isc_buffer_clear(&query->lengthbuf);

usr.bin/dig/dighost.c

2840

isc_buffer_putuint16(&query->slbuf, (uint16_t) query->sendbuf.used);

usr.bin/dig/dighost.c

2841

ISC_LIST_INIT(query->sendlist);

usr.bin/dig/dighost.c

2842

ISC_LINK_INIT(&query->slbuf, link);

usr.bin/dig/dighost.c

2843

if (!query->first_soa_rcvd) {

usr.bin/dig/dighost.c

2844

buffer = clone_buffer(&query->slbuf);

usr.bin/dig/dighost.c

2845

ISC_LIST_ENQUEUE(query->sendlist, buffer, link);

usr.bin/dig/dighost.c

2847

buffer = clone_buffer(&query->sendbuf);

usr.bin/dig/dighost.c

2848

ISC_LIST_ENQUEUE(query->sendlist, buffer, link);

usr.bin/dig/dighost.c

2852

ISC_LINK_INIT(&query->lengthbuf, link);

usr.bin/dig/dighost.c

2853

ISC_LIST_ENQUEUE(query->lengthlist, &query->lengthbuf, link);

usr.bin/dig/dighost.c

2855

result = isc_socket_recvv(query->sock, &query->lengthlist, 0,

usr.bin/dig/dighost.c

2856

global_task, tcp_length_done, query);

usr.bin/dig/dighost.c

2860

if (!query->first_soa_rcvd) {

usr.bin/dig/dighost.c

2862

clock_gettime(CLOCK_MONOTONIC, &query->time_sent);

usr.bin/dig/dighost.c

2863

query->waiting_senddone = 1;

usr.bin/dig/dighost.c

2864

result = isc_socket_sendv(query->sock, &query->sendlist,

usr.bin/dig/dighost.c

2865

global_task, send_done, query);

usr.bin/dig/dighost.c

2870

query->waiting_connect = 0;

usr.bin/dig/dighost.c

2883

dig_query_t *query = NULL, *next;

usr.bin/dig/dighost.c

2894

query = sevent->ev_arg;

usr.bin/dig/dighost.c

2896

INSIST(query->waiting_connect);

usr.bin/dig/dighost.c

2898

query->waiting_connect = 0;

usr.bin/dig/dighost.c

2902

isc_sockaddr_format(&query->sockaddr, sockstr, sizeof(sockstr));

usr.bin/dig/dighost.c

2903

if (query->timedout)

usr.bin/dig/dighost.c

2905

sockstr, query->servname,

usr.bin/dig/dighost.c

2906

query->lookup->textname,

usr.bin/dig/dighost.c

2908

isc_socket_detach(&query->sock);

usr.bin/dig/dighost.c

2912

query->waiting_connect = 0;

usr.bin/dig/dighost.c

2914

l = query->lookup;

usr.bin/dig/dighost.c

2915

clear_query(query);

usr.bin/dig/dighost.c

2923

isc_sockaddr_format(&query->sockaddr, sockstr, sizeof(sockstr));

usr.bin/dig/dighost.c

2927

query->servname, query->lookup->textname,

usr.bin/dig/dighost.c

2929

isc_socket_detach(&query->sock);

usr.bin/dig/dighost.c

2936

query->waiting_connect = 0;

usr.bin/dig/dighost.c

2938

l = query->lookup;

usr.bin/dig/dighost.c

2944

clear_query(query);

usr.bin/dig/dighost.c

2955

isc_socket_attach(query->sock, &keep);

usr.bin/dig/dighost.c

2956

keepaddr = query->sockaddr;

usr.bin/dig/dighost.c

2958

launch_next_query(query, 1);

usr.bin/dig/dighost.c

2969

check_for_more_data(dig_query_t *query, dns_message_t *msg,

usr.bin/dig/dighost.c

2975

uint32_t ixfr_serial = query->lookup->ixfr_serial, serial;

usr.bin/dig/dighost.c

2977

int ixfr = query->lookup->rdtype == dns_rdatatype_ixfr;

usr.bin/dig/dighost.c

2978

int axfr = query->lookup->rdtype == dns_rdatatype_axfr;

usr.bin/dig/dighost.c

2981

axfr = query->ixfr_axfr;

usr.bin/dig/dighost.c

2994

query->msg_count++;

usr.bin/dig/dighost.c

2995

query->byte_count += sevent->n;

usr.bin/dig/dighost.c

3013

query->rr_count++;

usr.bin/dig/dighost.c

3020

if ((!query->first_soa_rcvd) &&

usr.bin/dig/dighost.c

3026

if ((!query->second_rr_rcvd) &&

usr.bin/dig/dighost.c

3028

query->second_rr_rcvd = 1;

usr.bin/dig/dighost.c

3029

query->second_rr_serial = 0;

usr.bin/dig/dighost.c

3031

axfr = query->ixfr_axfr = 1;

usr.bin/dig/dighost.c

3048

if (!query->first_soa_rcvd) {

usr.bin/dig/dighost.c

3049

query->first_soa_rcvd = 1;

usr.bin/dig/dighost.c

3050

query->first_rr_serial = serial;

usr.bin/dig/dighost.c

3065

if (!query->second_rr_rcvd) {

usr.bin/dig/dighost.c

3066

if (query->first_rr_serial == serial) {

usr.bin/dig/dighost.c

3073

query->second_rr_rcvd = 1;

usr.bin/dig/dighost.c

3074

query->second_rr_serial = serial;

usr.bin/dig/dighost.c

3082

if (query->first_rr_serial == serial) {

usr.bin/dig/dighost.c

3084

if (!query->first_repeat_rcvd) {

usr.bin/dig/dighost.c

3085

query->first_repeat_rcvd =

usr.bin/dig/dighost.c

3099

launch_next_query(query, 0);

usr.bin/dig/dighost.c

3102

dighost_received(sevent->n, &sevent->address, query);

usr.bin/dig/dighost.c

3210

dig_query_t *query = NULL;

usr.bin/dig/dighost.c

3231

query = event->ev_arg;

usr.bin/dig/dighost.c

3232

clock_gettime(CLOCK_MONOTONIC, &query->time_recv);

usr.bin/dig/dighost.c

3233

debug("lookup=%p, query=%p", query->lookup, query);

usr.bin/dig/dighost.c

3235

l = query->lookup;

usr.bin/dig/dighost.c

3241

INSIST(b == &query->recvbuf);

usr.bin/dig/dighost.c

3242

ISC_LIST_DEQUEUE(sevent->bufferlist, &query->recvbuf, link);

usr.bin/dig/dighost.c

3244

if ((l->tcp_mode) && (query->timer != NULL))

usr.bin/dig/dighost.c

3245

isc_timer_touch(query->timer);

usr.bin/dig/dighost.c

3249

query->waiting_connect = 0;

usr.bin/dig/dighost.c

3252

clear_query(query);

usr.bin/dig/dighost.c

3260

query->waiting_connect = 0;

usr.bin/dig/dighost.c

3266

isc_socket_detach(&query->sock);

usr.bin/dig/dighost.c

3276

clear_query(query);

usr.bin/dig/dighost.c

3283

!isc_sockaddr_compare(&sevent->address, &query->sockaddr,

usr.bin/dig/dighost.c

3292

if (isc_sockaddr_pf(&query->sockaddr) == AF_INET)

usr.bin/dig/dighost.c

3302

if ((!isc_sockaddr_eqaddr(&query->sockaddr, &any) &&

usr.bin/dig/dighost.c

3303

!isc_sockaddr_ismulticast(&query->sockaddr)) ||

usr.bin/dig/dighost.c

3304

isc_sockaddr_getport(&query->sockaddr) !=

usr.bin/dig/dighost.c

3308

isc_sockaddr_format(&query->sockaddr, buf2,

usr.bin/dig/dighost.c

3322

if (!query->first_soa_rcvd ||

usr.bin/dig/dighost.c

3323

query->warn_id)

usr.bin/dig/dighost.c

3326

query->first_soa_rcvd ?

usr.bin/dig/dighost.c

3329

if (query->first_soa_rcvd)

usr.bin/dig/dighost.c

3331

query->warn_id = 0;

usr.bin/dig/dighost.c

3337

clear_query(query);

usr.bin/dig/dighost.c

3393

query->waiting_connect = 0;

usr.bin/dig/dighost.c

3396

clear_query(query);

usr.bin/dig/dighost.c

3439

clear_query(query);

usr.bin/dig/dighost.c

3461

clear_query(query);

usr.bin/dig/dighost.c

3478

clear_query(query);

usr.bin/dig/dighost.c

3486

dig_query_t *next = ISC_LIST_NEXT(query, link);

usr.bin/dig/dighost.c

3487

if (l->current_query == query)

usr.bin/dig/dighost.c

3501

if ((ISC_LIST_HEAD(l->q) != query) ||

usr.bin/dig/dighost.c

3502

(ISC_LIST_NEXT(query, link) != NULL)) {

usr.bin/dig/dighost.c

3509

query->servname);

usr.bin/dig/dighost.c

3510

clear_query(query);

usr.bin/dig/dighost.c

3519

result = dns_tsig_verify(&query->recvbuf, msg);

usr.bin/dig/dighost.c

3539

l->xfr_q = query;

usr.bin/dig/dighost.c

3545

if (timeout != INT_MAX && query->timer != NULL) {

usr.bin/dig/dighost.c

3562

result = isc_timer_reset(query->timer,

usr.bin/dig/dighost.c

3577

if (!l->doing_xfr || l->xfr_q == query) {

usr.bin/dig/dighost.c

3580

if (!next_origin(query->lookup) || showsearch) {

usr.bin/dig/dighost.c

3581

dighost_printmessage(query, msg, 1);

usr.bin/dig/dighost.c

3582

dighost_received(b->used, &sevent->address, query);

usr.bin/dig/dighost.c

3585

dighost_printmessage(query, msg, 1);

usr.bin/dig/dighost.c

3592

dighost_printmessage(query, msg, 1);

usr.bin/dig/dighost.c

3598

nl = followup_lookup(msg, query,

usr.bin/dig/dighost.c

3602

nl = followup_lookup(msg, query,

usr.bin/dig/dighost.c

3616

nl = followup_lookup(msg, query,

usr.bin/dig/dighost.c

3623

dighost_printmessage(query, msg, 1);

usr.bin/dig/dighost.c

3630

if (query != l->xfr_q) {

usr.bin/dig/dighost.c

3633

query->waiting_connect = 0;

usr.bin/dig/dighost.c

3637

docancel = check_for_more_data(query, msg, sevent);

usr.bin/dig/dighost.c

3640

clear_query(query);

usr.bin/dig/dighost.c

3647

dighost_received(b->used, &sevent->address, query);

usr.bin/dig/dighost.c

3650

if (!query->lookup->ns_search_only)

usr.bin/dig/dighost.c

3651

query->lookup->pending = 0;

usr.bin/dig/dighost.c

3652

if (!query->lookup->ns_search_only ||

usr.bin/dig/dighost.c

3653

query->lookup->trace_root || docancel) {

usr.bin/dig/dighost.c

3658

clear_query(query);

usr.bin/dig/dighost.c

3668

isc_buffer_invalidate(&query->recvbuf);

usr.bin/dig/dighost.c

3669

isc_buffer_init(&query->recvbuf, query->recvspace, COMMSIZE);

usr.bin/dig/dighost.c

3670

ISC_LIST_ENQUEUE(query->recvlist, &query->recvbuf, link);

usr.bin/dig/dighost.c

3671

result = isc_socket_recvv(query->sock, &query->recvlist, 1,

usr.bin/dig/dighost.c

3672

global_task, recv_done, query);

usr.bin/dig/dighost.c

3737

dig_query_t *query;

usr.bin/dig/dighost.c

3743

query = ISC_LIST_HEAD(lookup->q);

usr.bin/dig/dighost.c

3744

if (query != NULL) {

usr.bin/dig/dighost.c

3746

send_tcp_connect(query);

usr.bin/dig/dighost.c

3748

send_udp(query);

usr.bin/dig/host.c

148

received(unsigned int bytes, struct sockaddr_storage *from, dig_query_t *query) {

usr.bin/dig/host.c

156

bytes, fromtext, uelapsed(&now, &query->time_sent)/1000);

usr.bin/dig/host.c

170

dig_query_t *query)

usr.bin/dig/host.c

190

if (query->lookup->identify_previous_line) {

usr.bin/dig/host.c

192

query->servname);

usr.bin/dig/host.c

196

if (query->lookup->identify) {

usr.bin/dig/host.c

197

printf(" on server %s", query->servname);

usr.bin/dig/host.c

205

dig_query_t *query)

usr.bin/dig/host.c

245

if (query->lookup->rdtype == dns_rdatatype_axfr &&

usr.bin/dig/host.c

289

&rdata, query);

usr.bin/dig/host.c

367

printmessage(dig_query_t *query, dns_message_t *msg, int headers) {

usr.bin/dig/host.c

386

printf("Name: %s\n", query->userarg);

usr.bin/dig/host.c

387

isc_sockaddr_format(&query->sockaddr, sockstr,

usr.bin/dig/host.c

396

dns_name_format(query->lookup->name, namestr, sizeof(namestr));

usr.bin/dig/host.c

398

if (query->lookup->identify_previous_line)

usr.bin/dig/host.c

400

query->servname,

usr.bin/dig/host.c

402

query->lookup->textname, msg->rcode,

usr.bin/dig/host.c

407

query->lookup->textname, msg->rcode,

usr.bin/dig/host.c

412

if (default_lookups && query->lookup->rdtype == dns_rdatatype_a) {

usr.bin/dig/host.c

421

dns_name_copy(query->lookup->name, name, NULL);

usr.bin/dig/host.c

424

lookup = clone_lookup(query->lookup, 0);

usr.bin/dig/host.c

434

lookup = clone_lookup(query->lookup, 0);

usr.bin/dig/host.c

500

1, query);

usr.bin/dig/host.c

508

!short_form, query);

usr.bin/dig/host.c

517

1, query);

usr.bin/dig/host.c

525

"ADDITIONAL", 1, query);

usr.bin/dig/host.c

543

dns_name_format(query->lookup->name, namestr, sizeof(namestr));

usr.bin/dig/host.c

544

dns_rdatatype_format(query->lookup->rdtype, typestr,

usr.bin/dig/lib/dns/include/dns/message.h

228

isc_region_t query;

usr.bin/dig/lib/dns/message.c

334

m->query.base = NULL;

usr.bin/dig/lib/dns/message.c

335

m->query.length = 0;

usr.bin/dig/lib/dns/message.c

536

if (msg->query.base != NULL) {

usr.bin/dig/lib/dns/message.c

538

free(msg->query.base);

usr.bin/dig/lib/dns/message.c

539

msg->query.base = NULL;

usr.bin/dig/lib/dns/message.c

540

msg->query.length = 0;

usr.bin/dig/nslookup.c

222

printsection(dig_query_t *query, dns_message_t *msg, int headers,

usr.bin/dig/nslookup.c

230

UNUSED(query);

usr.bin/dig/nslookup.c

288

detailsection(dig_query_t *query, dns_message_t *msg, int headers,

usr.bin/dig/nslookup.c

296

UNUSED(query);

usr.bin/dig/nslookup.c

374

received(unsigned int bytes, struct sockaddr_storage *from, dig_query_t *query)

usr.bin/dig/nslookup.c

378

UNUSED(query);

usr.bin/dig/nslookup.c

388

printmessage(dig_query_t *query, dns_message_t *msg, int headers) {

usr.bin/dig/nslookup.c

396

isc_sockaddr_format(&query->sockaddr, servtext, sizeof(servtext));

usr.bin/dig/nslookup.c

397

printf("Server:\t\t%s\n", query->userarg);

usr.bin/dig/nslookup.c

405

detailsection(query, msg, 1, DNS_SECTION_QUESTION);

usr.bin/dig/nslookup.c

406

detailsection(query, msg, 1, DNS_SECTION_ANSWER);

usr.bin/dig/nslookup.c

407

detailsection(query, msg, 1, DNS_SECTION_AUTHORITY);

usr.bin/dig/nslookup.c

408

detailsection(query, msg, 1, DNS_SECTION_ADDITIONAL);

usr.bin/dig/nslookup.c

414

dns_name_format(query->lookup->name,

usr.bin/dig/nslookup.c

428

printsection(query, msg, headers, DNS_SECTION_ANSWER);

usr.bin/dig/nslookup.c

431

query->lookup->textname);

usr.bin/dig/nslookup.c

434

(query->lookup->rdtype != dns_rdatatype_a)) {

usr.bin/dig/nslookup.c

436

printsection(query, msg, headers,

usr.bin/dig/nslookup.c

438

printsection(query, msg, headers,

usr.bin/less/edit.c

271

answer = query("\"%s\" may be a binary file. "

usr.bin/less/edit.c

633

answer = query("Warning: \"%s\" exists; "

usr.bin/less/edit.c

667

answer = query("Overwrite, Append, or Don't log? "

usr.bin/less/funcs.h

231

int query(const char *, PARG *);

usr.bin/mandoc/cgi.c

1009

char *query, *rp, *wp;

usr.bin/mandoc/cgi.c

1041

rp = query = mandoc_strdup(req->q.query);

usr.bin/mandoc/cgi.c

1078

free(query);

usr.bin/mandoc/cgi.c

1145

*req.q.query == '\0' || access(path, F_OK) == -1)

usr.bin/mandoc/cgi.c

1170

else if (NULL != req.q.query)

usr.bin/mandoc/cgi.c

1178

free(req.q.query);

usr.bin/mandoc/cgi.c

1207

req->q.query = mandoc_strndup(name, sec - name - 1);

usr.bin/mandoc/cgi.c

1210

req->q.query = mandoc_strdup(name);

usr.bin/mandoc/cgi.c

211

req->q.query = NULL;

usr.bin/mandoc/cgi.c

239

set_query_attr(&req->q.query, &val);

usr.bin/mandoc/cgi.c

445

if (req->q.query != NULL)

usr.bin/mandoc/cgi.c

446

html_print(req->q.query);

usr.bin/mandoc/cgi.c

53

char *query; /* unparsed query expression */

usr.bin/mandoc/cgi.c

58

struct query q;

usr.bin/openssl/ts.c

535

TS_REQ *query = NULL;

usr.bin/openssl/ts.c

544

query = d2i_TS_REQ_bio(in_bio, NULL);

usr.bin/openssl/ts.c

551

query = create_query(data_bio, digest, md,

usr.bin/openssl/ts.c

555

if (query == NULL)

usr.bin/openssl/ts.c

563

if (!TS_REQ_print_bio(out_bio, query))

usr.bin/openssl/ts.c

567

if (!i2d_TS_REQ_bio(out_bio, query))

usr.bin/openssl/ts.c

580

TS_REQ_free(query);

usr.bin/rdistd/server.c

1758

query(cp);

usr.bin/rdistd/server.c

70

static void query(char *);

usr.bin/ssh/auth.h

120

int (*query)(void *ctx, char **name, char **infotxt,

usr.bin/ssh/auth2-chall.c

226

if (kbdintctxt->device->query(kbdintctxt->ctxt,

usr.bin/whois/whois.c

162

whois(const char *query, const char *server, const char *port, int flags)

usr.bin/whois/whois.c

224

fprintf(fp, fmt, query);

usr.bin/whois/whois.c

273

error = whois(query, nhost, port, 0);

usr.sbin/httpd/server_http.c

1130

char ibuf[128], *str, *path, *query;

usr.sbin/httpd/server_http.c

1174

if ((query = url_encode(desc->http_query)) == NULL)

usr.sbin/httpd/server_http.c

1176

ret = expand_string(buf, len, "$QUERY_STRING_ENC", query);

usr.sbin/httpd/server_http.c

1177

free(query);

usr.sbin/httpd/server_http.c

1298

char *hostval, *query;

usr.sbin/httpd/server_http.c

1436

if ((query = strchr(path, '?')) != NULL) {

usr.sbin/httpd/server_http.c

1437

*query++ = '\0';

usr.sbin/httpd/server_http.c

1438

if ((desc->http_query_alias = strdup(query)) == NULL)

usr.sbin/httpd/server_http.c

1449

path, query ? query : "");

usr.sbin/httpd/server_http.c

226

char *http_version, *query;

usr.sbin/httpd/server_http.c

373

query = strchr(desc->http_path, '?');

usr.sbin/httpd/server_http.c

374

if (query != NULL) {

usr.sbin/httpd/server_http.c

375

*query++ = '\0';

usr.sbin/httpd/server_http.c

377

if ((desc->http_query = strdup(query)) == NULL)

usr.sbin/mtrace/mtrace.c

374

struct tr_query *query, *rquery;

usr.sbin/mtrace/mtrace.c

401

query = (struct tr_query *)(send_buf + MIN_IP_HEADER_LEN + IGMP_MINLEN);

usr.sbin/mtrace/mtrace.c

402

query->tr_raddr = raddr ? raddr : multicast ? resp_cast : lcl_addr;

usr.sbin/mtrace/mtrace.c

403

query->tr_rttl = rttl ? rttl :

usr.sbin/mtrace/mtrace.c

404

IN_MULTICAST(ntohl(query->tr_raddr)) ? get_ttl(save) : UNICAST_TTL;

usr.sbin/mtrace/mtrace.c

405

query->tr_src = qsrc;

usr.sbin/mtrace/mtrace.c

406

query->tr_dst = qdst;

usr.sbin/mtrace/mtrace.c

411

query->tr_raddr = resp_cast;

usr.sbin/mtrace/mtrace.c

412

if (rttl == 0) query->tr_rttl = get_ttl(save);

usr.sbin/mtrace/mtrace.c

415

query->tr_rttl += MULTICAST_TTL_INC;

usr.sbin/mtrace/mtrace.c

416

if (query->tr_rttl > MULTICAST_TTL_MAX)

usr.sbin/mtrace/mtrace.c

417

query->tr_rttl = MULTICAST_TTL_MAX;

usr.sbin/mtrace/mtrace.c

425

query->tr_qid = arc4random();

usr.sbin/mtrace/mtrace.c

530

if (rquery->tr_qid != query->tr_qid) continue;

usr.sbin/mtrace/mtrace.c

559

rquery->tr_raddr = query->tr_raddr; /* Insure these are */

usr.sbin/mtrace/mtrace.c

560

rquery->tr_rttl = query->tr_rttl; /* as we sent them */

usr.sbin/nsd/axfr.c

100

query_prepare_response(query);

usr.sbin/nsd/axfr.c

104

while (query->axfr_current_domain != NULL &&

usr.sbin/nsd/axfr.c

105

domain_is_subdomain(query->axfr_current_domain,

usr.sbin/nsd/axfr.c

106

query->axfr_zone->apex))

usr.sbin/nsd/axfr.c

108

if (!query->axfr_current_rrset) {

usr.sbin/nsd/axfr.c

109

query->axfr_current_rrset = domain_find_any_rrset(

usr.sbin/nsd/axfr.c

110

query->axfr_current_domain,

usr.sbin/nsd/axfr.c

111

query->axfr_zone);

usr.sbin/nsd/axfr.c

112

query->axfr_current_rr = 0;

usr.sbin/nsd/axfr.c

114

while (query->axfr_current_rrset) {

usr.sbin/nsd/axfr.c

115

if (query->axfr_current_rrset != query->axfr_zone->soa_rrset

usr.sbin/nsd/axfr.c

116

&& query->axfr_current_rrset->zone == query->axfr_zone)

usr.sbin/nsd/axfr.c

118

while (query->axfr_current_rr < query->axfr_current_rrset->rr_count) {

usr.sbin/nsd/axfr.c

119

size_t oldmaxlen = query->maxlen;

usr.sbin/nsd/axfr.c

122

query->maxlen = (query->tcp?TCP_MAX_MESSAGE_LEN:UDP_MAX_MESSAGE_LEN);

usr.sbin/nsd/axfr.c

124

query,

usr.sbin/nsd/axfr.c

125

query->axfr_current_domain,

usr.sbin/nsd/axfr.c

126

query->axfr_current_rrset->rrs[query->axfr_current_rr],

usr.sbin/nsd/axfr.c

127

query->axfr_current_rrset->rrs[query->axfr_current_rr]->ttl);

usr.sbin/nsd/axfr.c

129

query->maxlen = oldmaxlen;

usr.sbin/nsd/axfr.c

130

if(query_overflow(query)) {

usr.sbin/nsd/axfr.c

133

++query->axfr_current_rr;

usr.sbin/nsd/axfr.c

141

++query->axfr_current_rr;

usr.sbin/nsd/axfr.c

145

query->axfr_current_rrset = query->axfr_current_rrset->next;

usr.sbin/nsd/axfr.c

146

query->axfr_current_rr = 0;

usr.sbin/nsd/axfr.c

148

assert(query->axfr_current_domain);

usr.sbin/nsd/axfr.c

149

query->axfr_current_domain

usr.sbin/nsd/axfr.c

150

= domain_next(query->axfr_current_domain);

usr.sbin/nsd/axfr.c

154

assert(query->axfr_zone->soa_rrset->rr_count == 1);

usr.sbin/nsd/axfr.c

155

added = packet_encode_rr(query,

usr.sbin/nsd/axfr.c

156

query->axfr_zone->apex,

usr.sbin/nsd/axfr.c

157

query->axfr_zone->soa_rrset->rrs[0],

usr.sbin/nsd/axfr.c

158

query->axfr_zone->soa_rrset->rrs[0]->ttl);

usr.sbin/nsd/axfr.c

161

query->tsig_sign_it = 1; /* sign last packet */

usr.sbin/nsd/axfr.c

162

query->axfr_is_done = 1;

usr.sbin/nsd/axfr.c

166

AA_SET(query->packet);

usr.sbin/nsd/axfr.c

167

ANCOUNT_SET(query->packet, total_added);

usr.sbin/nsd/axfr.c

168

NSCOUNT_SET(query->packet, 0);

usr.sbin/nsd/axfr.c

169

ARCOUNT_SET(query->packet, 0);

usr.sbin/nsd/axfr.c

172

if(query->tsig.status == TSIG_OK) {

usr.sbin/nsd/axfr.c

174

if(query->tsig.updates_since_last_prepare >= AXFR_TSIG_SIGN_EVERY_NTH) {

usr.sbin/nsd/axfr.c

176

query->tsig_sign_it = 1;

usr.sbin/nsd/axfr.c

181

query_clear_compression_tables(query);

usr.sbin/nsd/axfr.c

186

static int axfr_ixfr_can_admit_query(struct nsd* nsd, struct query* q)

usr.sbin/nsd/axfr.c

22

query_axfr(struct nsd *nsd, struct query *query, int wstats)

usr.sbin/nsd/axfr.c

291

answer_axfr_ixfr(struct nsd *nsd, struct query *q)

usr.sbin/nsd/axfr.c

30

if (query->axfr_is_done)

usr.sbin/nsd/axfr.c

33

if (query->maxlen > AXFR_MAX_MESSAGE_LEN)

usr.sbin/nsd/axfr.c

34

query->maxlen = AXFR_MAX_MESSAGE_LEN;

usr.sbin/nsd/axfr.c

36

assert(!query_overflow(query));

usr.sbin/nsd/axfr.c

38

query->tsig_prepare_it = 0;

usr.sbin/nsd/axfr.c

39

query->tsig_update_it = 1;

usr.sbin/nsd/axfr.c

40

if(query->tsig_sign_it) {

usr.sbin/nsd/axfr.c

42

query->tsig_prepare_it = 1;

usr.sbin/nsd/axfr.c

43

query->tsig_sign_it = 0;

usr.sbin/nsd/axfr.c

46

if (query->axfr_zone == NULL) {

usr.sbin/nsd/axfr.c

53

query->qname,

usr.sbin/nsd/axfr.c

58

query->axfr_zone = domain_find_zone(nsd->db, closest_encloser);

usr.sbin/nsd/axfr.c

61

|| query->axfr_zone == NULL

usr.sbin/nsd/axfr.c

62

|| query->axfr_zone->apex != qdomain

usr.sbin/nsd/axfr.c

63

|| query->axfr_zone->soa_rrset == NULL)

usr.sbin/nsd/axfr.c

66

RCODE_SET(query->packet, RCODE_NOTAUTH);

usr.sbin/nsd/axfr.c

70

ZTATUP(nsd, query->axfr_zone, raxfr);

usr.sbin/nsd/axfr.c

73

query->axfr_current_domain = qdomain;

usr.sbin/nsd/axfr.c

74

query->axfr_current_rrset = NULL;

usr.sbin/nsd/axfr.c

75

query->axfr_current_rr = 0;

usr.sbin/nsd/axfr.c

76

if(query->tsig.status == TSIG_OK) {

usr.sbin/nsd/axfr.c

77

query->tsig_sign_it = 1; /* sign first packet in stream */

usr.sbin/nsd/axfr.c

80

query_add_compression_domain(query, qdomain, QHEADERSZ);

usr.sbin/nsd/axfr.c

82

assert(query->axfr_zone->soa_rrset->rr_count == 1);

usr.sbin/nsd/axfr.c

83

added = packet_encode_rr(query,

usr.sbin/nsd/axfr.c

84

query->axfr_zone->apex,

usr.sbin/nsd/axfr.c

85

query->axfr_zone->soa_rrset->rrs[0],

usr.sbin/nsd/axfr.c

86

query->axfr_zone->soa_rrset->rrs[0]->ttl);

usr.sbin/nsd/axfr.c

97

query->edns.status = EDNS_NOT_PRESENT;

usr.sbin/nsd/axfr.c

98

buffer_set_limit(query->packet, QHEADERSZ);

usr.sbin/nsd/axfr.c

99

QDCOUNT_SET(query->packet, 0);

usr.sbin/nsd/axfr.h

22

query_state_type answer_axfr_ixfr(struct nsd *nsd, struct query *q);

usr.sbin/nsd/axfr.h

23

query_state_type query_axfr(struct nsd *nsd, struct query *query, int wstats);

usr.sbin/nsd/dns.h

16

struct query;

usr.sbin/nsd/dns.h

342

struct query *query,

usr.sbin/nsd/edns.c

134

query_type* query, nsd_type* nsd)

usr.sbin/nsd/edns.c

183

edns, query, nsd))

usr.sbin/nsd/edns.c

84

edns_record_type* edns, struct query* query, nsd_type* nsd)

usr.sbin/nsd/edns.c

86

(void) query; /* in case edns options need the query structure */

usr.sbin/nsd/edns.h

108

void cookie_verify(struct query *q, struct nsd* nsd, uint32_t *now_p);

usr.sbin/nsd/edns.h

109

void cookie_create(struct query *q, struct nsd* nsd, uint32_t *now_p);

usr.sbin/nsd/edns.h

15

struct query;

usr.sbin/nsd/edns.h

98

struct query* q, struct nsd* nsd);

usr.sbin/nsd/ixfr.c

352

static int ixfr_write_rr_pkt(struct query* query, struct buffer* packet,

usr.sbin/nsd/ixfr.c

363

size_t oldmaxlen = query->maxlen;

usr.sbin/nsd/ixfr.c

365

query->maxlen = (query->tcp?TCP_MAX_MESSAGE_LEN:UDP_MAX_MESSAGE_LEN);

usr.sbin/nsd/ixfr.c

366

if(query_overflow(query)) {

usr.sbin/nsd/ixfr.c

367

query->maxlen = oldmaxlen;

usr.sbin/nsd/ixfr.c

370

query->maxlen = oldmaxlen;

usr.sbin/nsd/ixfr.c

373

|| query_overflow(query)) {

usr.sbin/nsd/ixfr.c

418

size_t oldmaxlen = query->maxlen;

usr.sbin/nsd/ixfr.c

419

query->maxlen = (query->tcp?TCP_MAX_MESSAGE_LEN:UDP_MAX_MESSAGE_LEN);

usr.sbin/nsd/ixfr.c

420

if(query_overflow(query)) {

usr.sbin/nsd/ixfr.c

421

query->maxlen = oldmaxlen;

usr.sbin/nsd/ixfr.c

425

query->maxlen = oldmaxlen;

usr.sbin/nsd/ixfr.c

427

if(query_overflow(query)) {

usr.sbin/nsd/ixfr.c

671

static uint16_t ixfr_copy_rrs_into_packet(struct query* query,

usr.sbin/nsd/ixfr.c

680

if(query->ixfr_count_newsoa < query->ixfr_end_data->newsoa_len) {

usr.sbin/nsd/ixfr.c

683

if(ixfr_write_rr_pkt(query, query->packet, pcomp,

usr.sbin/nsd/ixfr.c

684

query->ixfr_end_data->newsoa,

usr.sbin/nsd/ixfr.c

685

query->ixfr_end_data->newsoa_len, total_added)) {

usr.sbin/nsd/ixfr.c

686

query->ixfr_count_newsoa = query->ixfr_end_data->newsoa_len;

usr.sbin/nsd/ixfr.c

688

query->ixfr_pos_of_newsoa = buffer_position(query->packet);

usr.sbin/nsd/ixfr.c

696

if(query->ixfr_count_oldsoa < query->ixfr_data->oldsoa_len) {

usr.sbin/nsd/ixfr.c

697

if(ixfr_write_rr_pkt(query, query->packet, pcomp,

usr.sbin/nsd/ixfr.c

698

query->ixfr_data->oldsoa,

usr.sbin/nsd/ixfr.c

699

query->ixfr_data->oldsoa_len, total_added)) {

usr.sbin/nsd/ixfr.c

700

query->ixfr_count_oldsoa = query->ixfr_data->oldsoa_len;

usr.sbin/nsd/ixfr.c

709

while(query->ixfr_count_del < query->ixfr_data->del_len) {

usr.sbin/nsd/ixfr.c

710

size_t rrlen = count_rr_length(query->ixfr_data->del,

usr.sbin/nsd/ixfr.c

711

query->ixfr_data->del_len, query->ixfr_count_del);

usr.sbin/nsd/ixfr.c

712

if(rrlen && ixfr_write_rr_pkt(query, query->packet, pcomp,

usr.sbin/nsd/ixfr.c

713

query->ixfr_data->del + query->ixfr_count_del,

usr.sbin/nsd/ixfr.c

715

query->ixfr_count_del += rrlen;

usr.sbin/nsd/ixfr.c

725

while(query->ixfr_count_add < query->ixfr_data->add_len) {

usr.sbin/nsd/ixfr.c

726

size_t rrlen = count_rr_length(query->ixfr_data->add,

usr.sbin/nsd/ixfr.c

727

query->ixfr_data->add_len, query->ixfr_count_add);

usr.sbin/nsd/ixfr.c

728

if(rrlen && ixfr_write_rr_pkt(query, query->packet, pcomp,

usr.sbin/nsd/ixfr.c

729

query->ixfr_data->add + query->ixfr_count_add,

usr.sbin/nsd/ixfr.c

731

query->ixfr_count_add += rrlen;

usr.sbin/nsd/ixfr.c

742

query_state_type query_ixfr(struct nsd *nsd, struct query *query)

usr.sbin/nsd/ixfr.c

747

if (query->ixfr_is_done)

usr.sbin/nsd/ixfr.c

751

if (query->maxlen > IXFR_MAX_MESSAGE_LEN)

usr.sbin/nsd/ixfr.c

752

query->maxlen = IXFR_MAX_MESSAGE_LEN;

usr.sbin/nsd/ixfr.c

754

assert(!query_overflow(query));

usr.sbin/nsd/ixfr.c

756

query->tsig_prepare_it = 0;

usr.sbin/nsd/ixfr.c

757

query->tsig_update_it = 1;

usr.sbin/nsd/ixfr.c

758

if(query->tsig_sign_it) {

usr.sbin/nsd/ixfr.c

760

query->tsig_prepare_it = 1;

usr.sbin/nsd/ixfr.c

761

query->tsig_sign_it = 0;

usr.sbin/nsd/ixfr.c

764

if (query->ixfr_data == NULL) {

usr.sbin/nsd/ixfr.c

774

if(!parse_qserial(query->packet, &qserial, &oldpos)) {

usr.sbin/nsd/ixfr.c

775

NSCOUNT_SET(query->packet, 0);

usr.sbin/nsd/ixfr.c

776

ARCOUNT_SET(query->packet, 0);

usr.sbin/nsd/ixfr.c

777

buffer_set_position(query->packet, oldpos);

usr.sbin/nsd/ixfr.c

778

RCODE_SET(query->packet, RCODE_FORMAT);

usr.sbin/nsd/ixfr.c

781

NSCOUNT_SET(query->packet, 0);

usr.sbin/nsd/ixfr.c

782

ARCOUNT_SET(query->packet, 0);

usr.sbin/nsd/ixfr.c

783

buffer_set_position(query->packet, oldpos);

usr.sbin/nsd/ixfr.c

785

dname_to_string(query->qname, NULL), (unsigned)qserial));

usr.sbin/nsd/ixfr.c

788

zone = namedb_find_zone(nsd->db, query->qname);

usr.sbin/nsd/ixfr.c

791

RCODE_SET(query->packet, RCODE_NOTAUTH);

usr.sbin/nsd/ixfr.c

801

RCODE_SET(query->packet, RCODE_SERVFAIL);

usr.sbin/nsd/ixfr.c

804

query_add_compression_domain(query, zone->apex,

usr.sbin/nsd/ixfr.c

806

if(packet_encode_rr(query, zone->apex,

usr.sbin/nsd/ixfr.c

809

ANCOUNT_SET(query->packet, 1);

usr.sbin/nsd/ixfr.c

811

RCODE_SET(query->packet, RCODE_SERVFAIL);

usr.sbin/nsd/ixfr.c

813

AA_SET(query->packet);

usr.sbin/nsd/ixfr.c

814

query_clear_compression_tables(query);

usr.sbin/nsd/ixfr.c

815

if(query->tsig.status == TSIG_OK)

usr.sbin/nsd/ixfr.c

816

query->tsig_sign_it = 1;

usr.sbin/nsd/ixfr.c

822

if(query->tsig_prepare_it)

usr.sbin/nsd/ixfr.c

823

query->tsig_sign_it = 1;

usr.sbin/nsd/ixfr.c

825

dname_to_string(query->qname, NULL)));

usr.sbin/nsd/ixfr.c

826

return query_axfr(nsd, query, 0);

usr.sbin/nsd/ixfr.c

831

if(query->tsig_prepare_it)

usr.sbin/nsd/ixfr.c

832

query->tsig_sign_it = 1;

usr.sbin/nsd/ixfr.c

834

dname_to_string(query->qname, NULL)));

usr.sbin/nsd/ixfr.c

835

return query_axfr(nsd, query, 0);

usr.sbin/nsd/ixfr.c

841

if(query->tsig_prepare_it)

usr.sbin/nsd/ixfr.c

842

query->tsig_sign_it = 1;

usr.sbin/nsd/ixfr.c

844

dname_to_string(query->qname, NULL)));

usr.sbin/nsd/ixfr.c

845

return query_axfr(nsd, query, 0);

usr.sbin/nsd/ixfr.c

848

query->zone = zone;

usr.sbin/nsd/ixfr.c

849

query->ixfr_data = ixfr_data;

usr.sbin/nsd/ixfr.c

850

query->ixfr_is_done = 0;

usr.sbin/nsd/ixfr.c

852

query->ixfr_end_data = ixfr_data_last(zone->ixfr);

usr.sbin/nsd/ixfr.c

853

query->ixfr_count_newsoa = 0;

usr.sbin/nsd/ixfr.c

854

query->ixfr_count_oldsoa = 0;

usr.sbin/nsd/ixfr.c

855

query->ixfr_count_del = 0;

usr.sbin/nsd/ixfr.c

856

query->ixfr_count_add = 0;

usr.sbin/nsd/ixfr.c

857

query->ixfr_pos_of_newsoa = 0;

usr.sbin/nsd/ixfr.c

860

buffer_at(query->packet, QHEADERSZ),

usr.sbin/nsd/ixfr.c

861

query->qname->name_size, QHEADERSZ);

usr.sbin/nsd/ixfr.c

862

if(query->tsig.status == TSIG_OK) {

usr.sbin/nsd/ixfr.c

863

query->tsig_sign_it = 1; /* sign first packet in stream */

usr.sbin/nsd/ixfr.c

870

buffer_set_limit(query->packet, QHEADERSZ);

usr.sbin/nsd/ixfr.c

871

QDCOUNT_SET(query->packet, 0);

usr.sbin/nsd/ixfr.c

872

query_prepare_response(query);

usr.sbin/nsd/ixfr.c

875

total_added = ixfr_copy_rrs_into_packet(query, &pcomp);

usr.sbin/nsd/ixfr.c

877

while(query->ixfr_count_add >= query->ixfr_data->add_len) {

usr.sbin/nsd/ixfr.c

878

struct ixfr_data* next = ixfr_data_next(query->zone->ixfr,

usr.sbin/nsd/ixfr.c

879

query->ixfr_data);

usr.sbin/nsd/ixfr.c

883

query->ixfr_data = next;

usr.sbin/nsd/ixfr.c

886

query->ixfr_count_oldsoa = next->oldsoa_len;

usr.sbin/nsd/ixfr.c

888

query->ixfr_count_del = 0;

usr.sbin/nsd/ixfr.c

889

query->ixfr_count_add = 0;

usr.sbin/nsd/ixfr.c

890

total_added += ixfr_copy_rrs_into_packet(query, &pcomp);

usr.sbin/nsd/ixfr.c

894

query->tsig_sign_it = 1;

usr.sbin/nsd/ixfr.c

895

query->ixfr_is_done = 1;

usr.sbin/nsd/ixfr.c

901

AA_SET(query->packet);

usr.sbin/nsd/ixfr.c

902

ANCOUNT_SET(query->packet, total_added);

usr.sbin/nsd/ixfr.c

903

NSCOUNT_SET(query->packet, 0);

usr.sbin/nsd/ixfr.c

904

ARCOUNT_SET(query->packet, 0);

usr.sbin/nsd/ixfr.c

906

if(!query->tcp && !query->ixfr_is_done) {

usr.sbin/nsd/ixfr.c

907

TC_SET(query->packet);

usr.sbin/nsd/ixfr.c

908

if(query->ixfr_pos_of_newsoa) {

usr.sbin/nsd/ixfr.c

912

buffer_set_position(query->packet, query->ixfr_pos_of_newsoa);

usr.sbin/nsd/ixfr.c

913

ANCOUNT_SET(query->packet, 1);

usr.sbin/nsd/ixfr.c

915

query->ixfr_is_done = 1;

usr.sbin/nsd/ixfr.c

919

if(query->tsig.status == TSIG_OK) {

usr.sbin/nsd/ixfr.c

921

if(query->tsig.updates_since_last_prepare >= IXFR_TSIG_SIGN_EVERY_NTH) {

usr.sbin/nsd/ixfr.c

923

query->tsig_sign_it = 1;

usr.sbin/nsd/ixfr.h

93

query_state_type query_ixfr(struct nsd *nsd, struct query *query);

usr.sbin/nsd/nsec3.c

1013

nsec3_add_rrset(query, answer, AUTHORITY_SECTION,

usr.sbin/nsd/nsec3.c

1021

nsec3_add_rrset(query, answer, AUTHORITY_SECTION,

usr.sbin/nsd/nsec3.c

1034

nsec3_add_rrset(query, answer, AUTHORITY_SECTION,

usr.sbin/nsd/nsec3.c

1042

nsec3_answer_nodata(struct query* query, struct answer* answer,

usr.sbin/nsd/nsec3.c

1045

if(!query->zone->nsec3_param)

usr.sbin/nsd/nsec3.c

1048

if(query->qtype == TYPE_DS)

usr.sbin/nsd/nsec3.c

1050

if(original == query->zone->apex) {

usr.sbin/nsd/nsec3.c

1054

nsec3_add_rrset(query, answer, AUTHORITY_SECTION,

usr.sbin/nsd/nsec3.c

1059

nsec3_add_ds_proof(query, answer, original, 0);

usr.sbin/nsd/nsec3.c

1068

nsec3_add_rrset(query, answer, AUTHORITY_SECTION,

usr.sbin/nsd/nsec3.c

1081

nsec3_add_rrset(query, answer, AUTHORITY_SECTION,

usr.sbin/nsd/nsec3.c

1086

nsec3_add_rrset(query, answer, AUTHORITY_SECTION,

usr.sbin/nsd/nsec3.c

1096

nsec3_add_rrset(query, answer, AUTHORITY_SECTION,

usr.sbin/nsd/nsec3.c

1100

nsec3_add_rrset(query, answer, AUTHORITY_SECTION,

usr.sbin/nsd/nsec3.c

1109

nsec3_answer_delegation(struct query *query, struct answer *answer)

usr.sbin/nsd/nsec3.c

1111

if(!query->zone->nsec3_param)

usr.sbin/nsd/nsec3.c

1113

nsec3_add_ds_proof(query, answer, query->delegation_domain, 1);

usr.sbin/nsd/nsec3.c

1137

nsec3_answer_authoritative(struct domain** match, struct query *query,

usr.sbin/nsd/nsec3.c

1141

if(!query->zone->nsec3_param)

usr.sbin/nsd/nsec3.c

1148

query->qtype != TYPE_NSEC3 &&

usr.sbin/nsd/nsec3.c

1150

domain_has_only_NSEC3(*match, query->zone))

usr.sbin/nsd/nsec3.c

1155

if(query->zone->apex->nsec3 &&

usr.sbin/nsd/nsec3.c

1156

query->zone->apex->nsec3->nsec3_is_exact)

usr.sbin/nsd/nsec3.c

1157

nsec3_add_rrset(query, answer, AUTHORITY_SECTION,

usr.sbin/nsd/nsec3.c

1158

query->zone->apex->nsec3->nsec3_cover);

usr.sbin/nsd/nsec3.c

1161

nsec3_add_rrset(query, answer, AUTHORITY_SECTION, closest_encloser->nsec3->nsec3_cover);

usr.sbin/nsd/nsec3.c

1163

if(query->zone->apex->nsec3)

usr.sbin/nsd/nsec3.c

1164

nsec3_add_rrset(query, answer, AUTHORITY_SECTION,

usr.sbin/nsd/nsec3.c

1165

query->zone->apex->nsec3->nsec3_wcard_child_cover);

usr.sbin/nsd/nsec3.c

1166

if (domain_wildcard_child(query->zone->apex)) {

usr.sbin/nsd/nsec3.c

1169

RCODE_SET(query->packet, RCODE_SERVFAIL);

usr.sbin/nsd/nsec3.c

1172

ASSIGN_EDE_CODE_AND_STRING_LITERAL(query->edns.ede,

usr.sbin/nsd/nsec3.c

1179

query->qtype != TYPE_NSEC3 &&

usr.sbin/nsd/nsec3.c

1181

(domain_has_only_NSEC3(*match, query->zone) ||

usr.sbin/nsd/nsec3.c

1182

!domain_find_any_rrset(*match, query->zone)))

usr.sbin/nsd/nsec3.c

1185

nsec3_answer_nodata(query, answer, *match);

usr.sbin/nsd/nsec3.c

1190

nsec3_add_closest_encloser_proof(query, answer, closest_encloser,

usr.sbin/nsd/nsec3.c

1193

nsec3_add_rrset(query, answer, AUTHORITY_SECTION,

usr.sbin/nsd/nsec3.c

890

nsec3_add_rrset(struct query* query, struct answer* answer,

usr.sbin/nsd/nsec3.c

894

rrset_type* rrset = domain_find_rrset(domain, query->zone, TYPE_NSEC3);

usr.sbin/nsd/nsec3.c

902

nsec3_add_nonexist_proof(struct query* query, struct answer* answer,

usr.sbin/nsd/nsec3.c

911

to_prove = dname_partial_copy(query->region, qname,

usr.sbin/nsd/nsec3.c

914

nsec3_hash_and_store(query->zone, to_prove, hash);

usr.sbin/nsd/nsec3.c

915

if(nsec3_find_cover(query->zone, hash, sizeof(hash), &cover))

usr.sbin/nsd/nsec3.c

923

walk = query->zone->apex;

usr.sbin/nsd/nsec3.c

946

RCODE_SET(query->packet, RCODE_SERVFAIL);

usr.sbin/nsd/nsec3.c

949

ASSIGN_EDE_CODE_AND_STRING_LITERAL(query->edns.ede,

usr.sbin/nsd/nsec3.c

956

nsec3_add_rrset(query, answer, AUTHORITY_SECTION, cover);

usr.sbin/nsd/nsec3.c

962

struct query* query, struct answer* answer,

usr.sbin/nsd/nsec3.c

968

nsec3_add_nonexist_proof(query, answer, closest_encloser, qname);

usr.sbin/nsd/nsec3.c

971

nsec3_add_rrset(query, answer, AUTHORITY_SECTION,

usr.sbin/nsd/nsec3.c

976

nsec3_answer_wildcard(struct query *query, struct answer *answer,

usr.sbin/nsd/nsec3.c

981

if(!query->zone->nsec3_param)

usr.sbin/nsd/nsec3.c

983

nsec3_add_nonexist_proof(query, answer, wildcard, qname);

usr.sbin/nsd/nsec3.c

987

nsec3_add_ds_proof(struct query *query, struct answer *answer,

usr.sbin/nsd/nsec3.c

991

assert(domain != query->zone->apex);

usr.sbin/nsd/nsec3.c

994

nsec3_add_rrset(query, answer, AUTHORITY_SECTION,

usr.sbin/nsd/nsec3.c

998

query->zone)) {

usr.sbin/nsd/nsec3.c

999

nsec3_add_rrset(query, answer, AUTHORITY_SECTION,

usr.sbin/nsd/nsec3.h

19

struct query;

usr.sbin/nsd/nsec3.h

47

void nsec3_answer_wildcard(struct query* query, struct answer* answer,

usr.sbin/nsd/nsec3.h

54

void nsec3_answer_nodata(struct query *query, struct answer *answer,

usr.sbin/nsd/nsec3.h

60

void nsec3_answer_delegation(struct query *query, struct answer *answer);

usr.sbin/nsd/nsec3.h

66

void nsec3_answer_authoritative(struct domain** match, struct query *query,

usr.sbin/nsd/options.c

1945

acl_check_incoming_block_proxy(struct acl_options* acl, struct query* q,

usr.sbin/nsd/options.c

1971

acl_check_incoming(struct acl_options* acl, struct query* q,

usr.sbin/nsd/options.c

2120

acl_addr_matches(struct acl_options* acl, struct query* q)

usr.sbin/nsd/options.c

2145

acl_addr_matches_proxy(struct acl_options* acl, struct query* q)

usr.sbin/nsd/options.c

2396

acl_key_matches(struct acl_options* acl, struct query* q)

usr.sbin/nsd/options.h

19

struct query;

usr.sbin/nsd/options.h

593

int acl_check_incoming(struct acl_options* acl, struct query* q,

usr.sbin/nsd/options.h

596

int acl_addr_matches(struct acl_options* acl, struct query* q);

usr.sbin/nsd/options.h

597

int acl_addr_matches_proxy(struct acl_options* acl, struct query* q);

usr.sbin/nsd/options.h

601

int acl_key_matches(struct acl_options* acl, struct query* q);

usr.sbin/nsd/options.h

607

int acl_check_incoming_block_proxy(struct acl_options* acl, struct query* q,

usr.sbin/nsd/packet.c

121

query->qtype != TYPE_AXFR && query->qtype != TYPE_IXFR);

usr.sbin/nsd/packet.c

127

truncation_mark = buffer_position(query->packet);

usr.sbin/nsd/packet.c

133

if (packet_encode_rr(query, owner, rrset->rrs[i],

usr.sbin/nsd/packet.c

143

if (packet_encode_rr(query, owner, rrset->rrs[i],

usr.sbin/nsd/packet.c

153

query->edns.dnssec_ok &&

usr.sbin/nsd/packet.c

162

if (packet_encode_rr(query, owner,

usr.sbin/nsd/packet.c

176

if ((!all_added || buffer_position(query->packet) > minimal_respsize)

usr.sbin/nsd/packet.c

177

&& !query->tcp && minimize_response) {

usr.sbin/nsd/packet.c

179

buffer_set_position(query->packet, truncation_mark);

usr.sbin/nsd/packet.c

180

query_clear_dname_offsets(query, truncation_mark);

usr.sbin/nsd/packet.c

188

buffer_set_position(query->packet, truncation_mark);

usr.sbin/nsd/packet.c

189

query_clear_dname_offsets(query, truncation_mark);

usr.sbin/nsd/packet.c

190

TC_SET(query->packet);

usr.sbin/nsd/packet.c

94

packet_encode_rrset(query_type *query,

usr.sbin/nsd/packet.h

155

int packet_encode_rr(struct query *query,

usr.sbin/nsd/packet.h

166

int packet_encode_rrset(struct query *query,

usr.sbin/nsd/packet.h

18

struct query;

usr.sbin/nsd/query.c

100

query_clear_compression_tables(struct query *q)

usr.sbin/nsd/query.c

1004

answer_soa(struct query *query, answer_type *answer)

usr.sbin/nsd/query.c

1006

if (query->qclass != CLASS_ANY) {

usr.sbin/nsd/query.c

1007

add_rrset(query, answer,

usr.sbin/nsd/query.c

1009

query->zone->apex,

usr.sbin/nsd/query.c

1010

query->zone->soa_nx_rrset);

usr.sbin/nsd/query.c

1025

answer_nodata(struct query *query, answer_type *answer, domain_type *original)

usr.sbin/nsd/query.c

1027

answer_soa(query, answer);

usr.sbin/nsd/query.c

1030

if (query->edns.dnssec_ok && query->zone->nsec3_param) {

usr.sbin/nsd/query.c

1031

nsec3_answer_nodata(query, answer, original);

usr.sbin/nsd/query.c

1034

if (query->edns.dnssec_ok && zone_is_secure(query->zone)) {

usr.sbin/nsd/query.c

1038

nsec_domain = find_covering_nsec(original, query->zone, &nsec_rrset);

usr.sbin/nsd/query.c

1040

add_rrset(query, answer, AUTHORITY_SECTION, nsec_domain, nsec_rrset);

usr.sbin/nsd/query.c

1046

answer_nxdomain(query_type *query, answer_type *answer)

usr.sbin/nsd/query.c

1048

RCODE_SET(query->packet, RCODE_NXDOMAIN);

usr.sbin/nsd/query.c

1049

answer_soa(query, answer);

usr.sbin/nsd/query.c

1058

answer_domain(struct nsd* nsd, struct query *q, answer_type *answer,

usr.sbin/nsd/query.c

112

query_add_compression_domain(struct query *q, domain_type *domain, uint16_t offset)

usr.sbin/nsd/query.c

1172

struct query *q,

usr.sbin/nsd/query.c

130

query_error (struct query *q, nsd_rc_type rcode)

usr.sbin/nsd/query.c

1359

answer_lookup_zone(struct nsd *nsd, struct query *q, answer_type *answer,

usr.sbin/nsd/query.c

1560

answer_query(struct nsd *nsd, struct query *q)

usr.sbin/nsd/query.c

168

query_formerr (struct query *query, nsd_type* nsd)

usr.sbin/nsd/query.c

170

int opcode = OPCODE(query->packet);

usr.sbin/nsd/query.c

173

FLAGS_SET(query->packet, FLAGS(query->packet) & 0x0100U);

usr.sbin/nsd/query.c

175

OPCODE_SET(query->packet, opcode);

usr.sbin/nsd/query.c

176

return query_error(query, NSD_RC_FORMAT);

usr.sbin/nsd/query.c

182

query_type *query = (query_type *) data;

usr.sbin/nsd/query.c

183

region_destroy(query->region);

usr.sbin/nsd/query.c

190

query_type *query

usr.sbin/nsd/query.c

194

query->region = region_create_custom(xalloc, free, 16384, 16384/8, 32, 0);

usr.sbin/nsd/query.c

195

query->compressed_dname_offsets = compressed_dname_offsets;

usr.sbin/nsd/query.c

196

query->compressed_dnames = compressed_dnames;

usr.sbin/nsd/query.c

197

query->packet = buffer_create(region, QIOBUFSZ);

usr.sbin/nsd/query.c

198

region_add_cleanup(region, query_cleanup, query);

usr.sbin/nsd/query.c

199

query->compressed_dname_offsets_size = compressed_dname_size;

usr.sbin/nsd/query.c

200

tsig_create_record(&query->tsig, region);

usr.sbin/nsd/query.c

201

query->tsig_prepare_it = 1;

usr.sbin/nsd/query.c

202

query->tsig_update_it = 1;

usr.sbin/nsd/query.c

203

query->tsig_sign_it = 1;

usr.sbin/nsd/query.c

204

return query;

usr.sbin/nsd/query.c

212

query_type *query

usr.sbin/nsd/query.c

216

query->region = region_create_custom(xalloc, free, 16384, 16384/8, 32, 0);

usr.sbin/nsd/query.c

217

region_add_cleanup(region, query_cleanup, query);

usr.sbin/nsd/query.c

218

query->compressed_dname_offsets = compressed_dname_offsets;

usr.sbin/nsd/query.c

219

query->compressed_dnames = compressed_dnames;

usr.sbin/nsd/query.c

220

query->packet = buffer;

usr.sbin/nsd/query.c

221

query->compressed_dname_offsets_size = compressed_dname_size;

usr.sbin/nsd/query.c

222

tsig_create_record(&query->tsig, region);

usr.sbin/nsd/query.c

223

query->tsig_prepare_it = 1;

usr.sbin/nsd/query.c

224

query->tsig_update_it = 1;

usr.sbin/nsd/query.c

225

query->tsig_sign_it = 1;

usr.sbin/nsd/query.c

226

return query;

usr.sbin/nsd/query.c

293

query_get_tempdomain(struct query *q)

usr.sbin/nsd/query.c

306

query_addtxt(struct query *q,

usr.sbin/nsd/query.c

341

process_query_section(query_type *query)

usr.sbin/nsd/query.c

345

buffer_set_position(query->packet, QHEADERSZ);

usr.sbin/nsd/query.c

347

if(!packet_read_query_section(query->packet, qnamebuf,

usr.sbin/nsd/query.c

348

&query->qtype, &query->qclass))

usr.sbin/nsd/query.c

350

query->qname = dname_make(query->region, qnamebuf, 1);

usr.sbin/nsd/query.c

364

process_edns(nsd_type* nsd, struct query *q)

usr.sbin/nsd/query.c

416

process_tsig(struct query* q)

usr.sbin/nsd/query.c

450

answer_notify(struct nsd* nsd, struct query *query)

usr.sbin/nsd/query.c

458

dname_to_string(query->qname, NULL)));

usr.sbin/nsd/query.c

460

zone_opt = zone_options_find(nsd->options, query->qname);

usr.sbin/nsd/query.c

462

return query_error(query, NSD_RC_NXDOMAIN);

usr.sbin/nsd/query.c

465

return query_error(query, NSD_RC_SERVFAIL);

usr.sbin/nsd/query.c

467

if(!tsig_find_rr(&query->tsig, query->packet)) {

usr.sbin/nsd/query.c

469

return query_error(query, NSD_RC_FORMAT);

usr.sbin/nsd/query.c

47

static int answer_needs_ns(struct query *query);

usr.sbin/nsd/query.c

471

rc = process_tsig(query);

usr.sbin/nsd/query.c

473

return query_error(query, rc);

usr.sbin/nsd/query.c

476

if(query->is_proxied && acl_check_incoming_block_proxy(

usr.sbin/nsd/query.c

477

zone_opt->pattern->allow_notify, query, &why) == -1) {

usr.sbin/nsd/query.c

481

addr2str(&query->client_addr, address, sizeof(address));

usr.sbin/nsd/query.c

482

addr2str(&query->remote_addr, proxy, sizeof(proxy));

usr.sbin/nsd/query.c

484

dname_to_string(query->qname, NULL),

usr.sbin/nsd/query.c

49

static int add_rrset(struct query *query,

usr.sbin/nsd/query.c

493

return query_error(query, NSD_RC_REFUSE);

usr.sbin/nsd/query.c

495

if((acl_num = acl_check_incoming(zone_opt->pattern->allow_notify, query,

usr.sbin/nsd/query.c

506

zone_opt->pattern->request_xfr, query, NULL);

usr.sbin/nsd/query.c

512

dname_to_string(query->qname, NULL),

usr.sbin/nsd/query.c

516

if(buffer_limit(query->packet) > MAX_PACKET_SIZE)

usr.sbin/nsd/query.c

517

return query_error(query, NSD_RC_SERVFAIL);

usr.sbin/nsd/query.c

520

sz = buffer_limit(query->packet)

usr.sbin/nsd/query.c

524

!write_socket(s, buffer_begin(query->packet),

usr.sbin/nsd/query.c

525

buffer_limit(query->packet)) ||

usr.sbin/nsd/query.c

530

return query_error(query, NSD_RC_SERVFAIL);

usr.sbin/nsd/query.c

535

addr2str(&query->client_addr, address, sizeof(address));

usr.sbin/nsd/query.c

536

if(packet_find_notify_serial(query->packet, &serial))

usr.sbin/nsd/query.c

538

dname_to_string(query->qname, NULL), address,

usr.sbin/nsd/query.c

542

dname_to_string(query->qname, NULL), address));

usr.sbin/nsd/query.c

546

QR_SET(query->packet); /* This is an answer. */

usr.sbin/nsd/query.c

547

AA_SET(query->packet); /* we are authoritative. */

usr.sbin/nsd/query.c

548

ANCOUNT_SET(query->packet, 0);

usr.sbin/nsd/query.c

549

NSCOUNT_SET(query->packet, 0);

usr.sbin/nsd/query.c

550

ARCOUNT_SET(query->packet, 0);

usr.sbin/nsd/query.c

551

RCODE_SET(query->packet, RCODE_OK); /* Error code. */

usr.sbin/nsd/query.c

553

pos = buffer_position(query->packet);

usr.sbin/nsd/query.c

554

buffer_clear(query->packet);

usr.sbin/nsd/query.c

555

buffer_set_position(query->packet, pos);

usr.sbin/nsd/query.c

56

struct query *q,

usr.sbin/nsd/query.c

562

addr2str(&query->client_addr, address, sizeof(address));

usr.sbin/nsd/query.c

564

dname_to_string(query->qname, NULL),

usr.sbin/nsd/query.c

574

return query_error(query, NSD_RC_REFUSE);

usr.sbin/nsd/query.c

64

static void answer_lookup_zone(struct nsd *nsd, struct query *q,

usr.sbin/nsd/query.c

709

add_additional_rrsets(struct query *query, answer_type *answer,

usr.sbin/nsd/query.c

71

query_put_dname_offset(struct query *q, domain_type *domain, uint16_t offset)

usr.sbin/nsd/query.c

715

assert(query);

usr.sbin/nsd/query.c

727

if (!allow_glue && domain_is_glue(match, query->zone))

usr.sbin/nsd/query.c

740

query->region, sizeof(domain_type));

usr.sbin/nsd/query.c

758

additional, query->zone, types[j].rr_type);

usr.sbin/nsd/query.c

768

answer_needs_ns(struct query* query)

usr.sbin/nsd/query.c

770

assert(query);

usr.sbin/nsd/query.c

773

return (query->qtype != TYPE_DNSKEY && query->qtype != TYPE_DS

usr.sbin/nsd/query.c

774

&& query->qtype != TYPE_ANY);

usr.sbin/nsd/query.c

778

add_rrset(struct query *query,

usr.sbin/nsd/query.c

786

assert(query);

usr.sbin/nsd/query.c

794

query->qtype != TYPE_NS)

usr.sbin/nsd/query.c

800

add_additional_rrsets(query, answer, rrset,

usr.sbin/nsd/query.c

802

(query->client_addr.ss_family == AF_INET6)?

usr.sbin/nsd/query.c

806

add_additional_rrsets(query, answer, rrset,

usr.sbin/nsd/query.c

812

add_additional_rrsets(query, answer, rrset,

usr.sbin/nsd/query.c

817

add_additional_rrsets(query, answer, rrset,

usr.sbin/nsd/query.c

822

add_additional_rrsets(query, answer, rrset,

usr.sbin/nsd/query.c

827

add_additional_rrsets(query, answer, rrset,

usr.sbin/nsd/query.c

832

add_additional_rrsets(query, answer, rrset,

usr.sbin/nsd/query.c

849

query_synthesize_cname(struct query* q, struct answer* answer, const dname_type* from_name,

usr.sbin/nsd/query.c

88

query_clear_dname_offsets(struct query *q, size_t max_offset)

usr.sbin/nsd/query.c

966

answer_delegation(query_type *query, answer_type *answer)

usr.sbin/nsd/query.c

969

assert(query->delegation_domain);

usr.sbin/nsd/query.c

970

assert(query->delegation_rrset);

usr.sbin/nsd/query.c

972

if (query->cname_count == 0) {

usr.sbin/nsd/query.c

973

AA_CLR(query->packet);

usr.sbin/nsd/query.c

975

AA_SET(query->packet);

usr.sbin/nsd/query.c

978

add_rrset(query,

usr.sbin/nsd/query.c

981

query->delegation_domain,

usr.sbin/nsd/query.c

982

query->delegation_rrset);

usr.sbin/nsd/query.c

983

if (query->edns.dnssec_ok && zone_is_secure(query->zone)) {

usr.sbin/nsd/query.c

985

if ((rrset = domain_find_rrset(query->delegation_domain, query->zone, TYPE_DS))) {

usr.sbin/nsd/query.c

986

add_rrset(query, answer, AUTHORITY_SECTION,

usr.sbin/nsd/query.c

987

query->delegation_domain, rrset);

usr.sbin/nsd/query.c

989

} else if (query->zone->nsec3_param) {

usr.sbin/nsd/query.c

990

nsec3_answer_delegation(query, answer);

usr.sbin/nsd/query.c

992

} else if ((rrset = domain_find_rrset(query->delegation_domain, query->zone, TYPE_NSEC))) {

usr.sbin/nsd/query.c

993

add_rrset(query, answer, AUTHORITY_SECTION,

usr.sbin/nsd/query.c

994

query->delegation_domain, rrset);

usr.sbin/nsd/query.h

168

static inline int query_overflow(struct query *q);

usr.sbin/nsd/query.h

174

void query_put_dname_offset(struct query *query,

usr.sbin/nsd/query.h

183

uint16_t query_get_dname_offset(struct query *query, domain_type *domain)

usr.sbin/nsd/query.h

185

return query->compressed_dname_offsets[domain->number];

usr.sbin/nsd/query.h

194

void query_clear_dname_offsets(struct query *query, size_t max_offset);

usr.sbin/nsd/query.h

199

void query_clear_compression_tables(struct query *query);

usr.sbin/nsd/query.h

205

void query_add_compression_domain(struct query *query,

usr.sbin/nsd/query.h

236

void query_reset(query_type *query, size_t maxlen, int is_tcp);

usr.sbin/nsd/query.h

31

typedef struct query query_type;

usr.sbin/nsd/rdata.c

1037

write_generic_rdata(struct query *query, const struct rr *rr)

usr.sbin/nsd/rdata.c

1040

buffer_write(query->packet, rr->rdata, rr->rdlength);

usr.sbin/nsd/rdata.c

1385

write_compressed_name_rdata(struct query *query, const struct rr *rr)

usr.sbin/nsd/rdata.c

1390

encode_dname(query, domain);

usr.sbin/nsd/rdata.c

1394

write_uncompressed_name_rdata(struct query *query, const struct rr *rr)

usr.sbin/nsd/rdata.c

1401

buffer_write(query->packet, dname_name(dname), dname->name_size);

usr.sbin/nsd/rdata.c

1461

write_soa_rdata(struct query *query, const struct rr *rr)

usr.sbin/nsd/rdata.c

1468

encode_dname(query, primary);

usr.sbin/nsd/rdata.c

1469

encode_dname(query, mailbox);

usr.sbin/nsd/rdata.c

1470

buffer_write(query->packet, rr->rdata + (2 * sizeof(void*)), 20);

usr.sbin/nsd/rdata.c

1638

write_minfo_rdata(struct query *query, const struct rr *rr)

usr.sbin/nsd/rdata.c

1644

encode_dname(query, rmailbx);

usr.sbin/nsd/rdata.c

1645

encode_dname(query, emailbx);

usr.sbin/nsd/rdata.c

1691

write_mx_rdata(struct query *query, const struct rr *rr)

usr.sbin/nsd/rdata.c

1696

buffer_write(query->packet, rr->rdata, 2);

usr.sbin/nsd/rdata.c

1697

encode_dname(query, domain);

usr.sbin/nsd/rdata.c

1771

write_rp_rdata(struct query *query, const struct rr *rr)

usr.sbin/nsd/rdata.c

1781

buffer_write(query->packet, dname_name(mbox), mbox->name_size);

usr.sbin/nsd/rdata.c

1782

buffer_write(query->packet, dname_name(txt), txt->name_size);

usr.sbin/nsd/rdata.c

1827

write_afsdb_rdata(struct query *query, const struct rr *rr)

usr.sbin/nsd/rdata.c

1835

buffer_write(query->packet, rr->rdata, 2);

usr.sbin/nsd/rdata.c

1836

buffer_write(query->packet, dname_name(dname), dname->name_size);

usr.sbin/nsd/rdata.c

1944

write_rt_rdata(struct query *query, const struct rr *rr)

usr.sbin/nsd/rdata.c

1952

buffer_write(query->packet, rr->rdata, 2);

usr.sbin/nsd/rdata.c

1953

buffer_write(query->packet, dname_name(dname), dname->name_size);

usr.sbin/nsd/rdata.c

2028

write_px_rdata(struct query *query, const struct rr *rr)

usr.sbin/nsd/rdata.c

2037

buffer_write(query->packet, rr->rdata, 2);

usr.sbin/nsd/rdata.c

2038

buffer_write(query->packet, dname_name(map822), map822->name_size);

usr.sbin/nsd/rdata.c

2039

buffer_write(query->packet, dname_name(mapx400), mapx400->name_size);

usr.sbin/nsd/rdata.c

2248

write_nxt_rdata(struct query *query, const struct rr *rr)

usr.sbin/nsd/rdata.c

2256

buffer_write(query->packet, dname_name(dname), dname->name_size);

usr.sbin/nsd/rdata.c

2258

buffer_write(query->packet, rr->rdata + sizeof(void*),

usr.sbin/nsd/rdata.c

2335

write_srv_rdata(struct query *query, const struct rr *rr)

usr.sbin/nsd/rdata.c

2343

buffer_write(query->packet, rr->rdata, 6);

usr.sbin/nsd/rdata.c

2344

buffer_write(query->packet, dname_name(dname), dname->name_size);

usr.sbin/nsd/rdata.c

2427

write_naptr_rdata(struct query *query, const struct rr *rr)

usr.sbin/nsd/rdata.c

2438

buffer_write(query->packet, rr->rdata, length);

usr.sbin/nsd/rdata.c

2439

buffer_write(query->packet, dname_name(dname), dname->name_size);

usr.sbin/nsd/rdata.c

2496

write_kx_rdata(struct query *query, const struct rr *rr)

usr.sbin/nsd/rdata.c

2505

buffer_write(query->packet, rr->rdata, 2);

usr.sbin/nsd/rdata.c

2506

buffer_write(query->packet, dname_name(dname), dname->name_size);

usr.sbin/nsd/rdata.c

3324

write_svcb_rdata(struct query *query, const struct rr *rr)

usr.sbin/nsd/rdata.c

3333

buffer_write(query->packet, rr->rdata, 2);

usr.sbin/nsd/rdata.c

3334

buffer_write(query->packet, dname_name(target), target->name_size);

usr.sbin/nsd/rdata.c

3337

buffer_write(query->packet, rr->rdata + length,

usr.sbin/nsd/rdata.c

3504

write_lp_rdata(struct query *query, const struct rr *rr)

usr.sbin/nsd/rdata.c

3513

buffer_write(query->packet, rr->rdata, 2);

usr.sbin/nsd/rdata.c

3514

buffer_write(query->packet, dname_name(dname), dname->name_size);

usr.sbin/nsd/rdata.h

106

void write_soa_rdata(struct query *query, const struct rr *rr);

usr.sbin/nsd/rdata.h

133

void write_minfo_rdata(struct query *query, const struct rr *rr);

usr.sbin/nsd/rdata.h

143

void write_mx_rdata(struct query *query, const struct rr *rr);

usr.sbin/nsd/rdata.h

160

void write_rp_rdata(struct query *query, const struct rr *rr);

usr.sbin/nsd/rdata.h

170

void write_afsdb_rdata(struct query *query, const struct rr *rr);

usr.sbin/nsd/rdata.h

194

void write_rt_rdata(struct query *query, const struct rr *rr);

usr.sbin/nsd/rdata.h

210

void write_px_rdata(struct query *query, const struct rr *rr);

usr.sbin/nsd/rdata.h

237

void write_nxt_rdata(struct query *query, const struct rr *rr);

usr.sbin/nsd/rdata.h

253

void write_srv_rdata(struct query *query, const struct rr *rr);

usr.sbin/nsd/rdata.h

266

void write_naptr_rdata(struct query *query, const struct rr *rr);

usr.sbin/nsd/rdata.h

276

void write_kx_rdata(struct query *query, const struct rr *rr);

usr.sbin/nsd/rdata.h

412

void write_svcb_rdata(struct query *query, const struct rr *rr);

usr.sbin/nsd/rdata.h

450

void write_lp_rdata(struct query *query, const struct rr *rr);

usr.sbin/nsd/rdata.h

71

void write_generic_rdata(struct query *query, const struct rr *rr);

usr.sbin/nsd/rdata.h

81

void write_compressed_name_rdata(struct query *query, const struct rr *rr);

usr.sbin/nsd/rdata.h

92

void write_uncompressed_name_rdata(struct query *query, const struct rr *rr);

usr.sbin/nsd/rrl.c

150

static uint64_t rrl_get_source(query_type* query, uint16_t* c2)

usr.sbin/nsd/rrl.c

156

if( ((struct sockaddr_in*)&query->client_addr)->sin_family == AF_INET) {

usr.sbin/nsd/rrl.c

158

return ((struct sockaddr_in*)&query->client_addr)->

usr.sbin/nsd/rrl.c

163

memmove(&s, &((struct sockaddr_in6*)&query->client_addr)->sin6_addr,

usr.sbin/nsd/rrl.c

169

return query->client_addr.sin_addr.s_addr & htonl(0xffffffff << (32-rrl_ipv4_prefixlen));

usr.sbin/nsd/rrl.c

242

static uint16_t rrl_classify(query_type* query, const uint8_t** d,

usr.sbin/nsd/rrl.c

245

if(RCODE(query->packet) == RCODE_NXDOMAIN) {

usr.sbin/nsd/rrl.c

246

if(query->zone && query->zone->apex) {

usr.sbin/nsd/rrl.c

247

*d = dname_name(domain_dname(query->zone->apex));

usr.sbin/nsd/rrl.c

248

*d_len = domain_dname(query->zone->apex)->name_size;

usr.sbin/nsd/rrl.c

252

if(RCODE(query->packet) != RCODE_OK) {

usr.sbin/nsd/rrl.c

253

if(query->zone && query->zone->apex) {

usr.sbin/nsd/rrl.c

254

*d = dname_name(domain_dname(query->zone->apex));

usr.sbin/nsd/rrl.c

255

*d_len = domain_dname(query->zone->apex)->name_size;

usr.sbin/nsd/rrl.c

259

if(query->delegation_domain) {

usr.sbin/nsd/rrl.c

260

*d = dname_name(domain_dname(query->delegation_domain));

usr.sbin/nsd/rrl.c

261

*d_len = domain_dname(query->delegation_domain)->name_size;

usr.sbin/nsd/rrl.c

264

if(query->qtype == TYPE_ANY) {

usr.sbin/nsd/rrl.c

265

if(query->qname) {

usr.sbin/nsd/rrl.c

266

*d = dname_name(query->qname);

usr.sbin/nsd/rrl.c

267

*d_len = query->qname->name_size;

usr.sbin/nsd/rrl.c

271

if(query->qtype == TYPE_RRSIG) {

usr.sbin/nsd/rrl.c

272

if(query->qname) {

usr.sbin/nsd/rrl.c

273

*d = dname_name(query->qname);

usr.sbin/nsd/rrl.c

274

*d_len = query->qname->name_size;

usr.sbin/nsd/rrl.c

278

if(query->wildcard_domain) {

usr.sbin/nsd/rrl.c

279

*d = dname_name(domain_dname(query->wildcard_domain));

usr.sbin/nsd/rrl.c

280

*d_len = domain_dname(query->wildcard_domain)->name_size;

usr.sbin/nsd/rrl.c

283

if(ANCOUNT(query->packet) == 0) {

usr.sbin/nsd/rrl.c

284

if(query->zone && query->zone->apex) {

usr.sbin/nsd/rrl.c

285

*d = dname_name(domain_dname(query->zone->apex));

usr.sbin/nsd/rrl.c

286

*d_len = domain_dname(query->zone->apex)->name_size;

usr.sbin/nsd/rrl.c

290

if(query->qtype == TYPE_DNSKEY) {

usr.sbin/nsd/rrl.c

291

if(query->qname) {

usr.sbin/nsd/rrl.c

292

*d = dname_name(query->qname);

usr.sbin/nsd/rrl.c

293

*d_len = query->qname->name_size;

usr.sbin/nsd/rrl.c

298

if(query->qname) {

usr.sbin/nsd/rrl.c

299

*d = dname_name(query->qname);

usr.sbin/nsd/rrl.c

300

*d_len = query->qname->name_size;

usr.sbin/nsd/rrl.c

306

static void examine_query(query_type* query, uint32_t* hash, uint64_t* source,

usr.sbin/nsd/rrl.c

316

*source = rrl_get_source(query, &c2);

usr.sbin/nsd/rrl.c

317

c = rrl_classify(query, &dname, &dname_len);

usr.sbin/nsd/rrl.c

318

if(query->zone && query->zone->opts &&

usr.sbin/nsd/rrl.c

319

(query->zone->opts->pattern->rrl_whitelist & c))

usr.sbin/nsd/rrl.c

354

rrl_msg(query_type* query, const char* str)

usr.sbin/nsd/rrl.c

362

addr2str(&query->client_addr, address, sizeof(address));

usr.sbin/nsd/rrl.c

363

s = rrl_get_source(query, &c2);

usr.sbin/nsd/rrl.c

364

c = rrl_classify(query, &d, &d_len) | c2;

usr.sbin/nsd/rrl.c

365

if(query->zone && query->zone->opts &&

usr.sbin/nsd/rrl.c

366

(query->zone->opts->pattern->rrl_whitelist & c))

usr.sbin/nsd/rrl.c

371

address, rrtype_to_string(query->qtype));

usr.sbin/nsd/rrl.c

382

uint32_t rrl_update(query_type* query, uint32_t hash, uint64_t source,

usr.sbin/nsd/rrl.c

397

addr2str(&query->client_addr, address, sizeof(address));

usr.sbin/nsd/rrl.c

401

address, rrtype_to_string(query->qtype),

usr.sbin/nsd/rrl.c

421

rrl_msg(query, "unblock");

usr.sbin/nsd/rrl.c

429

rrl_msg(query, "unblock");

usr.sbin/nsd/rrl.c

435

rrl_msg(query, "unblock");

usr.sbin/nsd/rrl.c

445

rrl_msg(query, "block");

usr.sbin/nsd/rrl.c

456

int rrl_process_query(query_type* query)

usr.sbin/nsd/rrl.c

468

examine_query(query, &hash, &source, &flags, &lm);

usr.sbin/nsd/rrl.c

474

return (rrl_update(query, hash, source, flags, now, lm) >= lm);

usr.sbin/nsd/rrl.c

477

query_state_type rrl_slip(query_type* query)

usr.sbin/nsd/rrl.c

488

TC_SET(query->packet);

usr.sbin/nsd/rrl.c

489

ANCOUNT_SET(query->packet, 0);

usr.sbin/nsd/rrl.c

490

NSCOUNT_SET(query->packet, 0);

usr.sbin/nsd/rrl.c

491

ARCOUNT_SET(query->packet, 0);

usr.sbin/nsd/rrl.c

492

if(query->qname)

usr.sbin/nsd/rrl.c

494

buffer_set_position(query->packet,

usr.sbin/nsd/rrl.c

495

QHEADERSZ+4+query->qname->name_size);

usr.sbin/nsd/rrl.c

496

else buffer_set_position(query->packet, QHEADERSZ);

usr.sbin/nsd/rrl.h

67

int rrl_process_query(query_type* query);

usr.sbin/nsd/rrl.h

73

query_state_type rrl_slip(query_type* query);

usr.sbin/nsd/rrl.h

81

uint32_t rrl_update(query_type* query, uint32_t hash, uint64_t source,

usr.sbin/nsd/server.c

218

static struct query *queries[NUM_RECV_PER_SELECT];

usr.sbin/nsd/server.c

220

static struct query *xdp_queries[XDP_RX_BATCH_SIZE];

usr.sbin/nsd/server.c

253

query_type* query;

usr.sbin/nsd/server.c

3234

server_process_query(struct nsd *nsd, struct query *query, uint32_t *now_p)

usr.sbin/nsd/server.c

3236

return query_process(query, nsd, now_p);

usr.sbin/nsd/server.c

3240

server_process_query_udp(struct nsd *nsd, struct query *query, uint32_t *now_p)

usr.sbin/nsd/server.c

3243

if(query_process(query, nsd, now_p) != QUERY_DISCARDED) {

usr.sbin/nsd/server.c

3244

if(query->edns.cookie_status != COOKIE_VALID

usr.sbin/nsd/server.c

3245

&& query->edns.cookie_status != COOKIE_VALID_REUSE

usr.sbin/nsd/server.c

3246

&& rrl_process_query(query))

usr.sbin/nsd/server.c

3247

return rrl_slip(query);

usr.sbin/nsd/server.c

3252

return query_process(query, nsd, now_p);

usr.sbin/nsd/server.c

4064

consume_pp2_header(struct buffer* buf, struct query* q, int stream)

usr.sbin/nsd/server.c

4148

struct query *q;

usr.sbin/nsd/server.c

4441

if(data->query) {

usr.sbin/nsd/server.c

4442

addr2str(&data->query->remote_addr, buf, sizeof(buf));

usr.sbin/nsd/server.c

4488

query_reset(data->query, TCP_MAX_MESSAGE_LEN, 1);

usr.sbin/nsd/server.c

4498

if(buffer_remaining(data->query->packet) <

usr.sbin/nsd/server.c

4508

(void*)buffer_at(data->query->packet,

usr.sbin/nsd/server.c

4514

buffer_skip(data->query->packet, received);

usr.sbin/nsd/server.c

4522

err = pp2_read_header(buffer_begin(data->query->packet),

usr.sbin/nsd/server.c

4523

buffer_limit(data->query->packet));

usr.sbin/nsd/server.c

4529

header = (struct pp2_header*)buffer_begin(data->query->packet);

usr.sbin/nsd/server.c

4531

if(buffer_limit(data->query->packet) <

usr.sbin/nsd/server.c

4544

(void*)buffer_at(data->query->packet,

usr.sbin/nsd/server.c

4550

buffer_skip(data->query->packet, received);

usr.sbin/nsd/server.c

4562

buffer_flip(data->query->packet);

usr.sbin/nsd/server.c

4563

if(!consume_pp2_header(data->query->packet, data->query, 1)) {

usr.sbin/nsd/server.c

4571

buffer_clear(data->query->packet);

usr.sbin/nsd/server.c

4580

(char*) &data->query->tcplen + data->bytes_transmitted,

usr.sbin/nsd/server.c

4593

data->query->tcplen = ntohs(data->query->tcplen);

usr.sbin/nsd/server.c

4603

if (data->query->tcplen < QHEADERSZ + 1 + sizeof(uint16_t) + sizeof(uint16_t)) {

usr.sbin/nsd/server.c

4609

if (data->query->tcplen > data->query->maxlen) {

usr.sbin/nsd/server.c

4615

buffer_set_limit(data->query->packet, data->query->tcplen);

usr.sbin/nsd/server.c

4618

assert(buffer_remaining(data->query->packet) > 0);

usr.sbin/nsd/server.c

4621

if(!more_read_buf_tcp(fd, data, buffer_current(data->query->packet),

usr.sbin/nsd/server.c

4622

buffer_remaining(data->query->packet), &received))

usr.sbin/nsd/server.c

4625

buffer_skip(data->query->packet, received);

usr.sbin/nsd/server.c

4626

if (buffer_remaining(data->query->packet) > 0) {

usr.sbin/nsd/server.c

4634

assert(buffer_position(data->query->packet) == data->query->tcplen);

usr.sbin/nsd/server.c

4641

if (data->query->remote_addr.ss_family == AF_INET) {

usr.sbin/nsd/server.c

4643

} else if (data->query->remote_addr.ss_family == AF_INET6) {

usr.sbin/nsd/server.c

4654

buffer_flip(data->query->packet);

usr.sbin/nsd/server.c

4659

log_addr("query from client", &data->query->client_addr);

usr.sbin/nsd/server.c

4661

if(verbosity >= 6 && data->query->is_proxied)

usr.sbin/nsd/server.c

4662

log_addr("query via proxy", &data->query->remote_addr);

usr.sbin/nsd/server.c

4663

dt_collector_submit_auth_query(data->nsd, (void*)&data->socket->addr.ai_addr, &data->query->client_addr,

usr.sbin/nsd/server.c

4664

data->query->client_addrlen, data->query->tcp, data->query->packet);

usr.sbin/nsd/server.c

4666

data->query_state = server_process_query(data->nsd, data->query, &now);

usr.sbin/nsd/server.c

4670

ZTATUP(data->nsd, data->query->zone, dropped);

usr.sbin/nsd/server.c

4676

if (RCODE(data->query->packet) == RCODE_OK

usr.sbin/nsd/server.c

4677

&& !AA(data->query->packet))

usr.sbin/nsd/server.c

4680

ZTATUP(data->nsd, data->query->zone, nona);

usr.sbin/nsd/server.c

4686

ZTATUP(data->nsd, data->query->zone, ctcp);

usr.sbin/nsd/server.c

4688

if (data->query->remote_addr.ss_family == AF_INET) {

usr.sbin/nsd/server.c

4689

ZTATUP(data->nsd, data->query->zone, ctcp);

usr.sbin/nsd/server.c

4690

} else if (data->query->remote_addr.ss_family == AF_INET6) {

usr.sbin/nsd/server.c

4691

ZTATUP(data->nsd, data->query->zone, ctcp6);

usr.sbin/nsd/server.c

4696

query_add_optional(data->query, data->nsd, &now);

usr.sbin/nsd/server.c

4699

buffer_flip(data->query->packet);

usr.sbin/nsd/server.c

4700

data->query->tcplen = buffer_remaining(data->query->packet);

usr.sbin/nsd/server.c

4703

STATUP2(data->nsd, rcode, RCODE(data->query->packet));

usr.sbin/nsd/server.c

4704

ZTATUP2(data->nsd, data->query->zone, rcode, RCODE(data->query->packet));

usr.sbin/nsd/server.c

4705

if (TC(data->query->packet)) {

usr.sbin/nsd/server.c

4707

ZTATUP(data->nsd, data->query->zone, truncated);

usr.sbin/nsd/server.c

4715

log_addr("response to client", &data->query->client_addr);

usr.sbin/nsd/server.c

4716

if(verbosity >= 6 && data->query->is_proxied)

usr.sbin/nsd/server.c

4717

log_addr("response via proxy", &data->query->remote_addr);

usr.sbin/nsd/server.c

4718

dt_collector_submit_auth_response(data->nsd, (void*)&data->socket->addr.ai_addr, &data->query->client_addr,

usr.sbin/nsd/server.c

4719

data->query->client_addrlen, data->query->tcp, data->query->packet,

usr.sbin/nsd/server.c

4720

data->query->zone);

usr.sbin/nsd/server.c

4745

struct query *q = data->query;

usr.sbin/nsd/server.c

4790

if(data->query) {

usr.sbin/nsd/server.c

4791

addr2str(&data->query->client_addr, client_ip, sizeof(client_ip));

usr.sbin/nsd/server.c

4837

if(data->query) {

usr.sbin/nsd/server.c

4838

addr2str(&data->query->client_addr, client_ip, sizeof(client_ip));

usr.sbin/nsd/server.c

4872

query_add_optional(data->query, data->nsd, &now);

usr.sbin/nsd/server.c

5002

if(data->query) {

usr.sbin/nsd/server.c

5003

addr2str(&data->query->remote_addr, a, sizeof(a));

usr.sbin/nsd/server.c

5096

query_reset(data->query, TCP_MAX_MESSAGE_LEN, 1);

usr.sbin/nsd/server.c

5113

if(buffer_remaining(data->query->packet) <

usr.sbin/nsd/server.c

5123

buffer_at(data->query->packet,

usr.sbin/nsd/server.c

5129

buffer_skip(data->query->packet, received);

usr.sbin/nsd/server.c

5137

err = pp2_read_header(buffer_begin(data->query->packet),

usr.sbin/nsd/server.c

5138

buffer_limit(data->query->packet));

usr.sbin/nsd/server.c

5144

header = (struct pp2_header*)buffer_begin(data->query->packet);

usr.sbin/nsd/server.c

5146

if(buffer_limit(data->query->packet) <

usr.sbin/nsd/server.c

5159

buffer_at(data->query->packet,

usr.sbin/nsd/server.c

5165

buffer_skip(data->query->packet, received);

usr.sbin/nsd/server.c

5176

buffer_flip(data->query->packet);

usr.sbin/nsd/server.c

5177

if(!consume_pp2_header(data->query->packet, data->query, 1)) {

usr.sbin/nsd/server.c

5184

buffer_clear(data->query->packet);

usr.sbin/nsd/server.c

5192

(char *) &data->query->tcplen + data->bytes_transmitted,

usr.sbin/nsd/server.c

5206

data->query->tcplen = ntohs(data->query->tcplen);

usr.sbin/nsd/server.c

5216

if (data->query->tcplen < QHEADERSZ + 1 + sizeof(uint16_t) + sizeof(uint16_t)) {

usr.sbin/nsd/server.c

5222

if (data->query->tcplen > data->query->maxlen) {

usr.sbin/nsd/server.c

5228

buffer_set_limit(data->query->packet, data->query->tcplen);

usr.sbin/nsd/server.c

5231

assert(buffer_remaining(data->query->packet) > 0);

usr.sbin/nsd/server.c

5234

if(!more_read_buf_tls(fd, data, buffer_current(data->query->packet),

usr.sbin/nsd/server.c

5235

buffer_remaining(data->query->packet), &received))

usr.sbin/nsd/server.c

5238

buffer_skip(data->query->packet, received);

usr.sbin/nsd/server.c

5239

if (buffer_remaining(data->query->packet) > 0) {

usr.sbin/nsd/server.c

5247

assert(buffer_position(data->query->packet) == data->query->tcplen);

usr.sbin/nsd/server.c

5253

if (data->query->remote_addr.ss_family == AF_INET) {

usr.sbin/nsd/server.c

5255

} else if (data->query->remote_addr.ss_family == AF_INET6) {

usr.sbin/nsd/server.c

5265

buffer_flip(data->query->packet);

usr.sbin/nsd/server.c

5270

log_addr("query from client", &data->query->client_addr);

usr.sbin/nsd/server.c

5272

if(verbosity >= 6 && data->query->is_proxied)

usr.sbin/nsd/server.c

5273

log_addr("query via proxy", &data->query->remote_addr);

usr.sbin/nsd/server.c

5274

dt_collector_submit_auth_query(data->nsd, (void*)&data->socket->addr.ai_addr, &data->query->client_addr,

usr.sbin/nsd/server.c

5275

data->query->client_addrlen, data->query->tcp, data->query->packet);

usr.sbin/nsd/server.c

5277

data->query_state = server_process_query(data->nsd, data->query, &now);

usr.sbin/nsd/server.c

5281

ZTATUP(data->nsd, data->query->zone, dropped);

usr.sbin/nsd/server.c

5287

if (RCODE(data->query->packet) == RCODE_OK

usr.sbin/nsd/server.c

5288

&& !AA(data->query->packet))

usr.sbin/nsd/server.c

5291

ZTATUP(data->nsd, data->query->zone, nona);

usr.sbin/nsd/server.c

5297

ZTATUP(data->nsd, data->query->zone, ctls);

usr.sbin/nsd/server.c

5299

if (data->query->remote_addr.ss_family == AF_INET) {

usr.sbin/nsd/server.c

5300

ZTATUP(data->nsd, data->query->zone, ctls);

usr.sbin/nsd/server.c

5301

} else if (data->query->remote_addr.ss_family == AF_INET6) {

usr.sbin/nsd/server.c

5302

ZTATUP(data->nsd, data->query->zone, ctls6);

usr.sbin/nsd/server.c

5307

query_add_optional(data->query, data->nsd, &now);

usr.sbin/nsd/server.c

5310

buffer_flip(data->query->packet);

usr.sbin/nsd/server.c

5311

data->query->tcplen = buffer_remaining(data->query->packet);

usr.sbin/nsd/server.c

5314

STATUP2(data->nsd, rcode, RCODE(data->query->packet));

usr.sbin/nsd/server.c

5315

ZTATUP2(data->nsd, data->query->zone, rcode, RCODE(data->query->packet));

usr.sbin/nsd/server.c

5316

if (TC(data->query->packet)) {

usr.sbin/nsd/server.c

5318

ZTATUP(data->nsd, data->query->zone, truncated);

usr.sbin/nsd/server.c

5326

log_addr("response to client", &data->query->client_addr);

usr.sbin/nsd/server.c

5327

if(verbosity >= 6 && data->query->is_proxied)

usr.sbin/nsd/server.c

5328

log_addr("response via proxy", &data->query->remote_addr);

usr.sbin/nsd/server.c

5329

dt_collector_submit_auth_response(data->nsd, (void*)&data->socket->addr.ai_addr, &data->query->client_addr,

usr.sbin/nsd/server.c

5330

data->query->client_addrlen, data->query->tcp, data->query->packet,

usr.sbin/nsd/server.c

5331

data->query->zone);

usr.sbin/nsd/server.c

5347

struct query *q = data->query;

usr.sbin/nsd/server.c

5421

if(data->query) {

usr.sbin/nsd/server.c

5422

addr2str(&data->query->client_addr, client_ip, sizeof(client_ip));

usr.sbin/nsd/server.c

5461

query_add_optional(data->query, data->nsd, &now);

usr.sbin/nsd/server.c

5614

tcp_data->query = query_create(tcp_region, compressed_dname_offsets,

usr.sbin/nsd/server.c

5632

memcpy(&tcp_data->query->remote_addr, &addr, addrlen);

usr.sbin/nsd/server.c

5633

tcp_data->query->remote_addrlen = addrlen;

usr.sbin/nsd/server.c

5636

memcpy(&tcp_data->query->client_addr, &addr, addrlen);

usr.sbin/nsd/server.c

5637

tcp_data->query->client_addrlen = addrlen;

usr.sbin/nsd/server.c

5638

tcp_data->query->is_proxied = 0;

usr.sbin/nsd/server.c

5662

tcp_data->query->tls = tcp_data->tls;

usr.sbin/nsd/server.c

5673

tcp_data->query->tls_auth = tcp_data->tls_auth;

usr.sbin/nsd/xdp-server.c

175

struct query *query);

usr.sbin/nsd/xdp-server.c

190

struct query *q,

usr.sbin/nsd/xdp-server.c

692

struct query *q, sa_family_t ai_family) {

usr.sbin/nsd/xdp-server.c

740

uint32_t *len, struct query *query) {

usr.sbin/nsd/xdp-server.c

803

query_set_buffer_data(query, dnshdr, XDP_FRAME_SIZE - data_before_dnshdr_len);

usr.sbin/nsd/xdp-server.c

807

struct sockaddr_in6* sock6 = (struct sockaddr_in6*)&query->remote_addr;

usr.sbin/nsd/xdp-server.c

813

query->remote_addrlen = (socklen_t)sizeof(struct sockaddr_in6);

usr.sbin/nsd/xdp-server.c

821

struct sockaddr_in* sock4 = (struct sockaddr_in*)&query->remote_addr;

usr.sbin/nsd/xdp-server.c

825

query->remote_addrlen = (socklen_t)sizeof(struct sockaddr_in);

usr.sbin/nsd/xdp-server.c

831

query->client_addr = query->remote_addr;

usr.sbin/nsd/xdp-server.c

832

query->client_addrlen = query->remote_addrlen;

usr.sbin/nsd/xdp-server.c

833

query->is_proxied = 0;

usr.sbin/nsd/xdp-server.c

835

dnslen = parse_dns(xdp->nsd, dnslen, query, query->remote_addr.ss_family);

usr.sbin/nsd/xdp-server.h

78

struct query **queries;

usr.sbin/ntpd/client.c

102

if (p->query.fd != -1) {

usr.sbin/ntpd/client.c

103

close(p->query.fd);

usr.sbin/ntpd/client.c

104

p->query.fd = -1;

usr.sbin/ntpd/client.c

150

if (p->query.fd == -1) {

usr.sbin/ntpd/client.c

155

if ((p->query.fd = socket(p->addr->ss.ss_family, SOCK_DGRAM,

usr.sbin/ntpd/client.c

160

if (bind(p->query.fd, qa4, SA_LEN(qa4)) == -1)

usr.sbin/ntpd/client.c

164

if (bind(p->query.fd, qa6, SA_LEN(qa6)) == -1)

usr.sbin/ntpd/client.c

169

if (connect(p->query.fd, sa, SA_LEN(sa)) == -1) {

usr.sbin/ntpd/client.c

185

if (p->addr->ss.ss_family == AF_INET && setsockopt(p->query.fd,

usr.sbin/ntpd/client.c

189

if (setsockopt(p->query.fd, SOL_SOCKET, SO_TIMESTAMP,

usr.sbin/ntpd/client.c

208

p->query.msg.xmttime.int_partl = arc4random();

usr.sbin/ntpd/client.c

209

p->query.msg.xmttime.fractionl = arc4random();

usr.sbin/ntpd/client.c

210

p->query.xmttime = gettime();

usr.sbin/ntpd/client.c

212

if (ntp_sendmsg(p->query.fd, NULL, &p->query.msg) == -1) {

usr.sbin/ntpd/client.c

297

if ((size = recvmsg(p->query.fd, &somsg, 0)) == -1) {

usr.sbin/ntpd/client.c

335

if (msg.orgtime.int_partl != p->query.msg.xmttime.int_partl ||

usr.sbin/ntpd/client.c

336

msg.orgtime.fractionl != p->query.msg.xmttime.fractionl)

usr.sbin/ntpd/client.c

373

T1 = p->query.xmttime;

usr.sbin/ntpd/client.c

54

p->query.fd = -1;

usr.sbin/ntpd/client.c

55

p->query.msg.status = MODE_CLIENT | (NTP_VERSION << 3);

usr.sbin/ntpd/client.c

56

p->query.xmttime = 0;

usr.sbin/ntpd/client.c

93

p->query.fd = -1;

usr.sbin/ntpd/ntp.c

295

p->query.fd != -1) {

usr.sbin/ntpd/ntp.c

296

pfd[i].fd = p->query.fd;

usr.sbin/ntpd/ntpd.h

161

struct ntp_query query;

usr.sbin/ntpd/server.c

158

struct ntp_msg query, reply;

usr.sbin/ntpd/server.c

175

if (ntp_getmsg((struct sockaddr *)&fsa, buf, size, &query) == -1)

usr.sbin/ntpd/server.c

183

reply.status |= (query.status & VERSIONMASK);

usr.sbin/ntpd/server.c

184

if ((query.status & MODEMASK) == MODE_CLIENT)

usr.sbin/ntpd/server.c

186

else if ((query.status & MODEMASK) == MODE_SYM_ACT)

usr.sbin/ntpd/server.c

192

reply.ppoll = query.ppoll;

usr.sbin/ntpd/server.c

197

reply.orgtime = query.xmttime;

usr.sbin/radiusd/radiusd.c

1115

TAILQ_FOREACH(q, &radiusd->query, next) {

usr.sbin/radiusd/radiusd.c

157

TAILQ_INIT(&radiusd->query);

usr.sbin/radiusd/radiusd.c

510

TAILQ_FOREACH(q, &listn->radiusd->query, next) {

usr.sbin/radiusd/radiusd.c

550

TAILQ_INSERT_TAIL(&listn->radiusd->query, q, next);

usr.sbin/radiusd/radiusd.c

871

TAILQ_INSERT_TAIL(&q->radiusd->query, q_next, next);

usr.sbin/radiusd/radiusd.c

894

TAILQ_REMOVE(&q->radiusd->query, q, next);

usr.sbin/radiusd/radiusd_local.h

124

TAILQ_HEAD(,radius_query) query;

usr.sbin/relayd/relay_http.c

1469

const char *query;

usr.sbin/relayd/relay_http.c

1479

query = desc->http_query == NULL ? "" : desc->http_query;

usr.sbin/relayd/relay_http.c

1480

if (fnmatch(kv->kv_value, query, FNM_CASEFOLD) == FNM_NOMATCH)

usr.sbin/relayd/relay_http.c

818

char *query, struct kv *kv)

usr.sbin/relayd/relay_http.c

827

query == NULL ? "" : "?",

usr.sbin/relayd/relay_http.c

828

query == NULL ? "" : query) == -1) {

usr.sbin/smtpd/scheduler.c

108

r = backend->query(msgid);

usr.sbin/smtpd/scheduler.c

91

r = backend->query(evp.id);

usr.sbin/smtpd/smtpd.h

917

int (*query)(uint64_t);

usr.sbin/unbound/services/outside_network.c

1064

if(pend->query && pend->query->error_count == 0 &&

usr.sbin/unbound/services/outside_network.c

1065

pend->c->tcp_write_pkt == pend->query->pkt &&

usr.sbin/unbound/services/outside_network.c

1066

pend->c->tcp_write_pkt_len == pend->query->pkt_len) {

usr.sbin/unbound/services/outside_network.c

1069

if(verbosity >= VERB_CLIENT && pend->query->pkt_len > 12+2+2 &&

usr.sbin/unbound/services/outside_network.c

1070

LDNS_QDCOUNT(pend->query->pkt) > 0 &&

usr.sbin/unbound/services/outside_network.c

1071

dname_valid(pend->query->pkt+12, pend->query->pkt_len-12)) {

usr.sbin/unbound/services/outside_network.c

1073

dname_str(pend->query->pkt+12, buf);

usr.sbin/unbound/services/outside_network.c

1083

w = pend->query;

usr.sbin/unbound/services/outside_network.c

1084

pend->query = NULL;

usr.sbin/unbound/services/outside_network.c

1215

pend->query = NULL;

usr.sbin/unbound/services/outside_network.c

1262

pend->query = NULL;

usr.sbin/unbound/services/outside_network.c

1322

log_assert(pend->query->pkt == pend->c->tcp_write_pkt);

usr.sbin/unbound/services/outside_network.c

1323

log_assert(pend->query->pkt_len == pend->c->tcp_write_pkt_len);

usr.sbin/unbound/services/outside_network.c

1327

log_assert(pend->query->id_node.key);

usr.sbin/unbound/services/outside_network.c

1328

pend->query = NULL;

usr.sbin/unbound/services/outside_network.c

1337

pend->query = reuse_write_wait_pop(&pend->reuse);

usr.sbin/unbound/services/outside_network.c

1340

pend->query);

usr.sbin/unbound/services/outside_network.c

2513

if(pend->query == NULL) {

usr.sbin/unbound/services/outside_network.c

2517

pend->query = w;

usr.sbin/unbound/services/outside_network.c

3733

sldns_buffer* query, int timeout, int ssl, char* host)

usr.sbin/unbound/services/outside_network.c

3767

sldns_buffer_copy(cp->buffer, query);

usr.sbin/unbound/services/outside_network.c

3918

if(outnet->tcp_conns[i]->query)

usr.sbin/unbound/services/outside_network.c

3919

s += waiting_tcp_get_mem(outnet->tcp_conns[i]->query);

usr.sbin/unbound/services/outside_network.c

544

key_p.query = &key_w;

usr.sbin/unbound/services/outside_network.c

764

pend->query = w;

usr.sbin/unbound/services/outside_network.c

986

if(reuse->pending->query) {

usr.sbin/unbound/services/outside_network.c

993

reuse->pending->query = w;

usr.sbin/unbound/services/outside_network.h

358

struct waiting_tcp* query;

usr.sbin/unbound/services/outside_network.h

787

struct sldns_buffer* query, int timeout, int ssl, char* host);

usr.sbin/unbound/testcode/fake_event.c

1807

struct sldns_buffer* query, int timeout, int ATTR_UNUSED(ssl),

usr.sbin/unbound/testcode/fake_event.c

1830

pend->buffer = sldns_buffer_new(sldns_buffer_limit(query)+10);

usr.sbin/unbound/testcode/fake_event.c

1836

sldns_buffer_copy(pend->buffer, query);

usr.sbin/unbound/testcode/fake_event.c

1841

if(LDNS_QDCOUNT(sldns_buffer_begin(query)) > 0) {

usr.sbin/unbound/testcode/fake_event.c

1844

(void)sldns_wire2str_rrquestion_buf(sldns_buffer_at(query, LDNS_HEADER_SIZE), sldns_buffer_limit(query)-LDNS_HEADER_SIZE, buf, sizeof(buf));

usr.sbin/unbound/testcode/fake_event.c

1851

log_assert(sldns_buffer_limit(query)-LDNS_HEADER_SIZE >= 2);

usr.sbin/unbound/testcode/fake_event.c

1852

pend->qtype = (int)sldns_buffer_read_u16_at(query,

usr.sbin/unbound/testcode/fake_event.c

1854

dname_valid(sldns_buffer_at(query, LDNS_HEADER_SIZE),

usr.sbin/unbound/testcode/fake_event.c

1855

sldns_buffer_limit(query)-LDNS_HEADER_SIZE));

usr.sbin/unbound/testcode/unitauth.c

60

const char* query;

usr.sbin/unbound/testcode/unitauth.c

774

if((ret=sldns_str2wire_rr_question_buf(q->query, buf, &len, &dname_len,

usr.sbin/unbound/testcode/unitauth.c

776

fatal_exit("cannot parse query %s : %s", q->query,

usr.sbin/unbound/testcode/unitauth.c

966

if(vbmp) printf("query %s: %s %s\n", q->zone, q->query,

usr.sbin/unbound/util/data/dname.c

52

query_dname_len(sldns_buffer* query)

usr.sbin/unbound/util/data/dname.c

57

if(sldns_buffer_remaining(query) < 1)

usr.sbin/unbound/util/data/dname.c

59

labellen = sldns_buffer_read_u8(query);

usr.sbin/unbound/util/data/dname.c

67

if(sldns_buffer_remaining(query) < labellen)

usr.sbin/unbound/util/data/dname.c

69

sldns_buffer_skip(query, (ssize_t)labellen);

usr.sbin/unbound/util/data/dname.h

59

size_t query_dname_len(struct sldns_buffer* query);

usr.sbin/unbound/util/data/msgreply.c

638

query_info_parse(struct query_info* m, sldns_buffer* query)

usr.sbin/unbound/util/data/msgreply.c

640

uint8_t* q = sldns_buffer_begin(query);

usr.sbin/unbound/util/data/msgreply.c

642

if(sldns_buffer_limit(query) < LDNS_HEADER_SIZE + 5)

usr.sbin/unbound/util/data/msgreply.c

646

sldns_buffer_position(query) != 0)

usr.sbin/unbound/util/data/msgreply.c

648

sldns_buffer_skip(query, LDNS_HEADER_SIZE);

usr.sbin/unbound/util/data/msgreply.c

649

m->qname = sldns_buffer_current(query);

usr.sbin/unbound/util/data/msgreply.c

650

if((m->qname_len = query_dname_len(query)) == 0)

usr.sbin/unbound/util/data/msgreply.c

652

if(sldns_buffer_remaining(query) < 4)

usr.sbin/unbound/util/data/msgreply.c

654

m->qtype = sldns_buffer_read_u16(query);

usr.sbin/unbound/util/data/msgreply.c

655

m->qclass = sldns_buffer_read_u16(query);

usr.sbin/unbound/util/data/msgreply.h

285

int query_info_parse(struct query_info* m, struct sldns_buffer* query);