sbin/unwind/libunbound/services/listen_dnsport.c

2136

struct tcp_req_info*

sbin/unwind/libunbound/services/listen_dnsport.c

2139

struct tcp_req_info* req = (struct tcp_req_info*)malloc(sizeof(*req));

sbin/unwind/libunbound/services/listen_dnsport.c

2150

tcp_req_info_delete(struct tcp_req_info* req)

sbin/unwind/libunbound/services/listen_dnsport.c

2160

void tcp_req_info_clear(struct tcp_req_info* req)

sbin/unwind/libunbound/services/listen_dnsport.c

2195

tcp_req_info_remove_mesh_state(struct tcp_req_info* req, struct mesh_state* m)

sbin/unwind/libunbound/services/listen_dnsport.c

2221

tcp_req_info_setup_listen(struct tcp_req_info* req)

sbin/unwind/libunbound/services/listen_dnsport.c

2260

tcp_req_info_pop_done(struct tcp_req_info* req)

sbin/unwind/libunbound/services/listen_dnsport.c

2275

tcp_req_info_start_write_buf(struct tcp_req_info* req, uint8_t* buf,

sbin/unwind/libunbound/services/listen_dnsport.c

2287

tcp_req_pickup_next_result(struct tcp_req_info* req)

sbin/unwind/libunbound/services/listen_dnsport.c

2300

tcp_req_info_handle_read_close(struct tcp_req_info* req)

sbin/unwind/libunbound/services/listen_dnsport.c

2321

tcp_req_info_handle_writedone(struct tcp_req_info* req)

sbin/unwind/libunbound/services/listen_dnsport.c

2341

tcp_req_info_handle_readdone(struct tcp_req_info* req)

sbin/unwind/libunbound/services/listen_dnsport.c

2393

tcp_req_info_add_meshstate(struct tcp_req_info* req,

sbin/unwind/libunbound/services/listen_dnsport.c

2410

tcp_req_info_add_result(struct tcp_req_info* req, uint8_t* buf, size_t len)

sbin/unwind/libunbound/services/listen_dnsport.c

2455

tcp_req_info_send_reply(struct tcp_req_info* req)

sbin/unwind/libunbound/services/listen_dnsport.h

381

struct tcp_req_info* tcp_req_info_create(struct sldns_buffer* spoolbuf);

sbin/unwind/libunbound/services/listen_dnsport.h

388

void tcp_req_info_delete(struct tcp_req_info* req);

sbin/unwind/libunbound/services/listen_dnsport.h

395

void tcp_req_info_clear(struct tcp_req_info* req);

sbin/unwind/libunbound/services/listen_dnsport.h

403

void tcp_req_info_remove_mesh_state(struct tcp_req_info* req,

sbin/unwind/libunbound/services/listen_dnsport.h

410

void tcp_req_info_handle_writedone(struct tcp_req_info* req);

sbin/unwind/libunbound/services/listen_dnsport.h

416

void tcp_req_info_handle_readdone(struct tcp_req_info* req);

sbin/unwind/libunbound/services/listen_dnsport.h

429

int tcp_req_info_add_meshstate(struct tcp_req_info* req,

sbin/unwind/libunbound/services/listen_dnsport.h

436

void tcp_req_info_send_reply(struct tcp_req_info* req);

sbin/unwind/libunbound/services/listen_dnsport.h

442

int tcp_req_info_handle_read_close(struct tcp_req_info* req);

sbin/unwind/libunbound/services/mesh.c

1787

if(r->query_reply.c->tcp_req_info) {

sbin/unwind/libunbound/services/mesh.c

1788

r_buffer = r->query_reply.c->tcp_req_info->spool_buffer;

sbin/unwind/libunbound/services/mesh.c

1793

if(r->query_reply.c->tcp_req_info) {

sbin/unwind/libunbound/services/mesh.c

1794

tcp_req_info_remove_mesh_state(r->query_reply.c->tcp_req_info, mstate);

sbin/unwind/libunbound/services/mesh.c

2540

if(r->query_reply.c->tcp_req_info)

sbin/unwind/libunbound/services/mesh.c

2541

r_buffer = r->query_reply.c->tcp_req_info->spool_buffer;

sbin/unwind/libunbound/services/mesh.c

2544

if(r->query_reply.c->tcp_req_info)

sbin/unwind/libunbound/services/mesh.c

2545

tcp_req_info_remove_mesh_state(r->query_reply.c->tcp_req_info, mstate);

sbin/unwind/libunbound/services/mesh.c

438

if(rep->c->tcp_req_info) {

sbin/unwind/libunbound/services/mesh.c

439

r_buffer = rep->c->tcp_req_info->spool_buffer;

sbin/unwind/libunbound/services/mesh.c

531

if(rep->c->tcp_req_info) {

sbin/unwind/libunbound/services/mesh.c

532

if(!tcp_req_info_add_meshstate(rep->c->tcp_req_info, mesh, s)) {

sbin/unwind/libunbound/util/netevent.c

3228

if((c_hdl->type == comm_tcp && c_hdl->tcp_req_info) ||

sbin/unwind/libunbound/util/netevent.c

3359

if(c->tcp_req_info) {

sbin/unwind/libunbound/util/netevent.c

3360

tcp_req_info_handle_writedone(c->tcp_req_info);

sbin/unwind/libunbound/util/netevent.c

3386

if(c->tcp_req_info) {

sbin/unwind/libunbound/util/netevent.c

3387

tcp_req_info_handle_readdone(c->tcp_req_info);

sbin/unwind/libunbound/util/netevent.c

3624

if(c->tcp_req_info)

sbin/unwind/libunbound/util/netevent.c

3625

return tcp_req_info_handle_read_close(c->tcp_req_info);

sbin/unwind/libunbound/util/netevent.c

3692

if(c->tcp_req_info)

sbin/unwind/libunbound/util/netevent.c

3693

return tcp_req_info_handle_read_close(c->tcp_req_info);

sbin/unwind/libunbound/util/netevent.c

3753

if(c->tcp_req_info)

sbin/unwind/libunbound/util/netevent.c

3754

return tcp_req_info_handle_read_close(c->tcp_req_info);

sbin/unwind/libunbound/util/netevent.c

3803

if(c->tcp_req_info)

sbin/unwind/libunbound/util/netevent.c

3804

return tcp_req_info_handle_read_close(c->tcp_req_info);

sbin/unwind/libunbound/util/netevent.c

4045

if(c->tcp_req_info)

sbin/unwind/libunbound/util/netevent.c

4046

return tcp_req_info_handle_read_close(c->tcp_req_info);

sbin/unwind/libunbound/util/netevent.c

4090

if(c->tcp_req_info)

sbin/unwind/libunbound/util/netevent.c

4091

return tcp_req_info_handle_read_close(c->tcp_req_info);

sbin/unwind/libunbound/util/netevent.c

4129

if(c->tcp_req_info)

sbin/unwind/libunbound/util/netevent.c

4130

return tcp_req_info_handle_read_close(c->tcp_req_info);

sbin/unwind/libunbound/util/netevent.c

4162

if(c->tcp_req_info)

sbin/unwind/libunbound/util/netevent.c

4163

return tcp_req_info_handle_read_close(c->tcp_req_info);

sbin/unwind/libunbound/util/netevent.c

4549

while(c->tcp_req_info->read_again) {

sbin/unwind/libunbound/util/netevent.c

4551

c->tcp_req_info->read_again = 0;

sbin/unwind/libunbound/util/netevent.c

4663

int has_tcpq = (c->tcp_req_info != NULL);

sbin/unwind/libunbound/util/netevent.c

4675

if(has_tcpq && c->tcp_req_info && c->tcp_req_info->read_again) {

sbin/unwind/libunbound/util/netevent.c

4684

int has_tcpq = (c->tcp_req_info != NULL);

sbin/unwind/libunbound/util/netevent.c

4696

if(has_tcpq && c->tcp_req_info && c->tcp_req_info->read_again) {

sbin/unwind/libunbound/util/netevent.c

6028

c->tcp_req_info = tcp_req_info_create(spoolbuf);

sbin/unwind/libunbound/util/netevent.c

6029

if(!c->tcp_req_info) {

sbin/unwind/libunbound/util/netevent.c

6037

c->tcp_req_info->cp = c;

sbin/unwind/libunbound/util/netevent.c

6053

tcp_req_info_delete(c->tcp_req_info);

sbin/unwind/libunbound/util/netevent.c

6578

if(c->tcp_req_info)

sbin/unwind/libunbound/util/netevent.c

6579

tcp_req_info_clear(c->tcp_req_info);

sbin/unwind/libunbound/util/netevent.c

6633

if(c->tcp_req_info) {

sbin/unwind/libunbound/util/netevent.c

6634

tcp_req_info_delete(c->tcp_req_info);

sbin/unwind/libunbound/util/netevent.c

6707

struct sldns_buffer* dtbuffer = repinfo->c->tcp_req_info

sbin/unwind/libunbound/util/netevent.c

6708

?repinfo->c->tcp_req_info->spool_buffer

sbin/unwind/libunbound/util/netevent.c

6727

if(repinfo->c->tcp_req_info) {

sbin/unwind/libunbound/util/netevent.c

6728

tcp_req_info_send_reply(repinfo->c->tcp_req_info);

sbin/unwind/libunbound/util/netevent.c

6760

if(repinfo->c->tcp_req_info)

sbin/unwind/libunbound/util/netevent.c

6761

repinfo->c->tcp_req_info->is_drop = 1;

sbin/unwind/libunbound/util/netevent.h

405

struct tcp_req_info* tcp_req_info;

usr.sbin/unbound/daemon/worker.c

926

if(repinfo->c->tcp_req_info) {

usr.sbin/unbound/daemon/worker.c

928

repinfo->c->tcp_req_info->spool_buffer,

usr.sbin/unbound/services/listen_dnsport.c

2136

struct tcp_req_info*

usr.sbin/unbound/services/listen_dnsport.c

2139

struct tcp_req_info* req = (struct tcp_req_info*)malloc(sizeof(*req));

usr.sbin/unbound/services/listen_dnsport.c

2150

tcp_req_info_delete(struct tcp_req_info* req)

usr.sbin/unbound/services/listen_dnsport.c

2160

void tcp_req_info_clear(struct tcp_req_info* req)

usr.sbin/unbound/services/listen_dnsport.c

2195

tcp_req_info_remove_mesh_state(struct tcp_req_info* req, struct mesh_state* m)

usr.sbin/unbound/services/listen_dnsport.c

2221

tcp_req_info_setup_listen(struct tcp_req_info* req)

usr.sbin/unbound/services/listen_dnsport.c

2260

tcp_req_info_pop_done(struct tcp_req_info* req)

usr.sbin/unbound/services/listen_dnsport.c

2275

tcp_req_info_start_write_buf(struct tcp_req_info* req, uint8_t* buf,

usr.sbin/unbound/services/listen_dnsport.c

2287

tcp_req_pickup_next_result(struct tcp_req_info* req)

usr.sbin/unbound/services/listen_dnsport.c

2300

tcp_req_info_handle_read_close(struct tcp_req_info* req)

usr.sbin/unbound/services/listen_dnsport.c

2321

tcp_req_info_handle_writedone(struct tcp_req_info* req)

usr.sbin/unbound/services/listen_dnsport.c

2341

tcp_req_info_handle_readdone(struct tcp_req_info* req)

usr.sbin/unbound/services/listen_dnsport.c

2393

tcp_req_info_add_meshstate(struct tcp_req_info* req,

usr.sbin/unbound/services/listen_dnsport.c

2410

tcp_req_info_add_result(struct tcp_req_info* req, uint8_t* buf, size_t len)

usr.sbin/unbound/services/listen_dnsport.c

2455

tcp_req_info_send_reply(struct tcp_req_info* req)

usr.sbin/unbound/services/listen_dnsport.h

381

struct tcp_req_info* tcp_req_info_create(struct sldns_buffer* spoolbuf);

usr.sbin/unbound/services/listen_dnsport.h

388

void tcp_req_info_delete(struct tcp_req_info* req);

usr.sbin/unbound/services/listen_dnsport.h

395

void tcp_req_info_clear(struct tcp_req_info* req);

usr.sbin/unbound/services/listen_dnsport.h

403

void tcp_req_info_remove_mesh_state(struct tcp_req_info* req,

usr.sbin/unbound/services/listen_dnsport.h

410

void tcp_req_info_handle_writedone(struct tcp_req_info* req);

usr.sbin/unbound/services/listen_dnsport.h

416

void tcp_req_info_handle_readdone(struct tcp_req_info* req);

usr.sbin/unbound/services/listen_dnsport.h

429

int tcp_req_info_add_meshstate(struct tcp_req_info* req,

usr.sbin/unbound/services/listen_dnsport.h

436

void tcp_req_info_send_reply(struct tcp_req_info* req);

usr.sbin/unbound/services/listen_dnsport.h

442

int tcp_req_info_handle_read_close(struct tcp_req_info* req);

usr.sbin/unbound/services/mesh.c

1787

if(r->query_reply.c->tcp_req_info) {

usr.sbin/unbound/services/mesh.c

1788

r_buffer = r->query_reply.c->tcp_req_info->spool_buffer;

usr.sbin/unbound/services/mesh.c

1793

if(r->query_reply.c->tcp_req_info) {

usr.sbin/unbound/services/mesh.c

1794

tcp_req_info_remove_mesh_state(r->query_reply.c->tcp_req_info, mstate);

usr.sbin/unbound/services/mesh.c

2540

if(r->query_reply.c->tcp_req_info)

usr.sbin/unbound/services/mesh.c

2541

r_buffer = r->query_reply.c->tcp_req_info->spool_buffer;

usr.sbin/unbound/services/mesh.c

2544

if(r->query_reply.c->tcp_req_info)

usr.sbin/unbound/services/mesh.c

2545

tcp_req_info_remove_mesh_state(r->query_reply.c->tcp_req_info, mstate);

usr.sbin/unbound/services/mesh.c

438

if(rep->c->tcp_req_info) {

usr.sbin/unbound/services/mesh.c

439

r_buffer = rep->c->tcp_req_info->spool_buffer;

usr.sbin/unbound/services/mesh.c

531

if(rep->c->tcp_req_info) {

usr.sbin/unbound/services/mesh.c

532

if(!tcp_req_info_add_meshstate(rep->c->tcp_req_info, mesh, s)) {

usr.sbin/unbound/testcode/fake_event.c

1983

int tcp_req_info_add_meshstate(struct tcp_req_info* ATTR_UNUSED(req),

usr.sbin/unbound/testcode/fake_event.c

1991

tcp_req_info_remove_mesh_state(struct tcp_req_info* ATTR_UNUSED(req),

usr.sbin/unbound/util/netevent.c

3228

if((c_hdl->type == comm_tcp && c_hdl->tcp_req_info) ||

usr.sbin/unbound/util/netevent.c

3359

if(c->tcp_req_info) {

usr.sbin/unbound/util/netevent.c

3360

tcp_req_info_handle_writedone(c->tcp_req_info);

usr.sbin/unbound/util/netevent.c

3386

if(c->tcp_req_info) {

usr.sbin/unbound/util/netevent.c

3387

tcp_req_info_handle_readdone(c->tcp_req_info);

usr.sbin/unbound/util/netevent.c

3624

if(c->tcp_req_info)

usr.sbin/unbound/util/netevent.c

3625

return tcp_req_info_handle_read_close(c->tcp_req_info);

usr.sbin/unbound/util/netevent.c

3692

if(c->tcp_req_info)

usr.sbin/unbound/util/netevent.c

3693

return tcp_req_info_handle_read_close(c->tcp_req_info);

usr.sbin/unbound/util/netevent.c

3753

if(c->tcp_req_info)

usr.sbin/unbound/util/netevent.c

3754

return tcp_req_info_handle_read_close(c->tcp_req_info);

usr.sbin/unbound/util/netevent.c

3803

if(c->tcp_req_info)

usr.sbin/unbound/util/netevent.c

3804

return tcp_req_info_handle_read_close(c->tcp_req_info);

usr.sbin/unbound/util/netevent.c

4045

if(c->tcp_req_info)

usr.sbin/unbound/util/netevent.c

4046

return tcp_req_info_handle_read_close(c->tcp_req_info);

usr.sbin/unbound/util/netevent.c

4090

if(c->tcp_req_info)

usr.sbin/unbound/util/netevent.c

4091

return tcp_req_info_handle_read_close(c->tcp_req_info);

usr.sbin/unbound/util/netevent.c

4129

if(c->tcp_req_info)

usr.sbin/unbound/util/netevent.c

4130

return tcp_req_info_handle_read_close(c->tcp_req_info);

usr.sbin/unbound/util/netevent.c

4162

if(c->tcp_req_info)

usr.sbin/unbound/util/netevent.c

4163

return tcp_req_info_handle_read_close(c->tcp_req_info);

usr.sbin/unbound/util/netevent.c

4549

while(c->tcp_req_info->read_again) {

usr.sbin/unbound/util/netevent.c

4551

c->tcp_req_info->read_again = 0;

usr.sbin/unbound/util/netevent.c

4663

int has_tcpq = (c->tcp_req_info != NULL);

usr.sbin/unbound/util/netevent.c

4675

if(has_tcpq && c->tcp_req_info && c->tcp_req_info->read_again) {

usr.sbin/unbound/util/netevent.c

4684

int has_tcpq = (c->tcp_req_info != NULL);

usr.sbin/unbound/util/netevent.c

4696

if(has_tcpq && c->tcp_req_info && c->tcp_req_info->read_again) {

usr.sbin/unbound/util/netevent.c

6028

c->tcp_req_info = tcp_req_info_create(spoolbuf);

usr.sbin/unbound/util/netevent.c

6029

if(!c->tcp_req_info) {

usr.sbin/unbound/util/netevent.c

6037

c->tcp_req_info->cp = c;

usr.sbin/unbound/util/netevent.c

6053

tcp_req_info_delete(c->tcp_req_info);

usr.sbin/unbound/util/netevent.c

6578

if(c->tcp_req_info)

usr.sbin/unbound/util/netevent.c

6579

tcp_req_info_clear(c->tcp_req_info);

usr.sbin/unbound/util/netevent.c

6633

if(c->tcp_req_info) {

usr.sbin/unbound/util/netevent.c

6634

tcp_req_info_delete(c->tcp_req_info);

usr.sbin/unbound/util/netevent.c

6707

struct sldns_buffer* dtbuffer = repinfo->c->tcp_req_info

usr.sbin/unbound/util/netevent.c

6708

?repinfo->c->tcp_req_info->spool_buffer

usr.sbin/unbound/util/netevent.c

6727

if(repinfo->c->tcp_req_info) {

usr.sbin/unbound/util/netevent.c

6728

tcp_req_info_send_reply(repinfo->c->tcp_req_info);

usr.sbin/unbound/util/netevent.c

6760

if(repinfo->c->tcp_req_info)

usr.sbin/unbound/util/netevent.c

6761

repinfo->c->tcp_req_info->is_drop = 1;

usr.sbin/unbound/util/netevent.h

405

struct tcp_req_info* tcp_req_info;