sbin/unwind/libunbound/services/listen_dnsport.c

2135

struct tcp_req_info*

sbin/unwind/libunbound/services/listen_dnsport.c

2138

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

sbin/unwind/libunbound/services/listen_dnsport.c

2149

tcp_req_info_delete(struct tcp_req_info* req)

sbin/unwind/libunbound/services/listen_dnsport.c

2159

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

2308

tcp_req_info_handle_writedone(struct tcp_req_info* req)

sbin/unwind/libunbound/services/listen_dnsport.c

2328

tcp_req_info_handle_readdone(struct tcp_req_info* req)

sbin/unwind/libunbound/services/listen_dnsport.c

2380

tcp_req_info_add_meshstate(struct tcp_req_info* req,

sbin/unwind/libunbound/services/listen_dnsport.c

2397

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

sbin/unwind/libunbound/services/listen_dnsport.c

2442

tcp_req_info_send_reply(struct tcp_req_info* req)

sbin/unwind/libunbound/services/listen_dnsport.h

383

struct tcp_req_info* tcp_req_info_create(struct sldns_buffer* spoolbuf);

sbin/unwind/libunbound/services/listen_dnsport.h

390

void tcp_req_info_delete(struct tcp_req_info* req);

sbin/unwind/libunbound/services/listen_dnsport.h

397

void tcp_req_info_clear(struct tcp_req_info* req);

sbin/unwind/libunbound/services/listen_dnsport.h

405

void tcp_req_info_remove_mesh_state(struct tcp_req_info* req,

sbin/unwind/libunbound/services/listen_dnsport.h

412

void tcp_req_info_handle_writedone(struct tcp_req_info* req);

sbin/unwind/libunbound/services/listen_dnsport.h

418

void tcp_req_info_handle_readdone(struct tcp_req_info* req);

sbin/unwind/libunbound/services/listen_dnsport.h

431

int tcp_req_info_add_meshstate(struct tcp_req_info* req,

sbin/unwind/libunbound/services/listen_dnsport.h

438

void tcp_req_info_send_reply(struct tcp_req_info* req);

sbin/unwind/libunbound/services/listen_dnsport.h

444

int tcp_req_info_handle_read_close(struct tcp_req_info* req);

sbin/unwind/libunbound/services/mesh.c

1844

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

sbin/unwind/libunbound/services/mesh.c

1845

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

sbin/unwind/libunbound/services/mesh.c

1850

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

sbin/unwind/libunbound/services/mesh.c

1851

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

sbin/unwind/libunbound/services/mesh.c

2624

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

sbin/unwind/libunbound/services/mesh.c

2625

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

sbin/unwind/libunbound/services/mesh.c

2628

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

sbin/unwind/libunbound/services/mesh.c

2629

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

sbin/unwind/libunbound/services/mesh.c

441

if(rep->c->tcp_req_info) {

sbin/unwind/libunbound/services/mesh.c

442

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

sbin/unwind/libunbound/services/mesh.c

551

if(rep->c->tcp_req_info) {

sbin/unwind/libunbound/services/mesh.c

552

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

sbin/unwind/libunbound/util/netevent.c

3222

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

sbin/unwind/libunbound/util/netevent.c

3353

if(c->tcp_req_info) {

sbin/unwind/libunbound/util/netevent.c

3354

tcp_req_info_handle_writedone(c->tcp_req_info);

sbin/unwind/libunbound/util/netevent.c

3380

if(c->tcp_req_info) {

sbin/unwind/libunbound/util/netevent.c

3381

tcp_req_info_handle_readdone(c->tcp_req_info);

sbin/unwind/libunbound/util/netevent.c

3618

if(c->tcp_req_info)

sbin/unwind/libunbound/util/netevent.c

3619

return tcp_req_info_handle_read_close(c->tcp_req_info);

sbin/unwind/libunbound/util/netevent.c

3686

if(c->tcp_req_info)

sbin/unwind/libunbound/util/netevent.c

3687

return tcp_req_info_handle_read_close(c->tcp_req_info);

sbin/unwind/libunbound/util/netevent.c

3747

if(c->tcp_req_info)

sbin/unwind/libunbound/util/netevent.c

3748

return tcp_req_info_handle_read_close(c->tcp_req_info);

sbin/unwind/libunbound/util/netevent.c

3797

if(c->tcp_req_info)

sbin/unwind/libunbound/util/netevent.c

3798

return tcp_req_info_handle_read_close(c->tcp_req_info);

sbin/unwind/libunbound/util/netevent.c

4039

if(c->tcp_req_info)

sbin/unwind/libunbound/util/netevent.c

4040

return tcp_req_info_handle_read_close(c->tcp_req_info);

sbin/unwind/libunbound/util/netevent.c

4084

if(c->tcp_req_info)

sbin/unwind/libunbound/util/netevent.c

4085

return tcp_req_info_handle_read_close(c->tcp_req_info);

sbin/unwind/libunbound/util/netevent.c

4123

if(c->tcp_req_info)

sbin/unwind/libunbound/util/netevent.c

4124

return tcp_req_info_handle_read_close(c->tcp_req_info);

sbin/unwind/libunbound/util/netevent.c

4156

if(c->tcp_req_info)

sbin/unwind/libunbound/util/netevent.c

4157

return tcp_req_info_handle_read_close(c->tcp_req_info);

sbin/unwind/libunbound/util/netevent.c

4543

while(c->tcp_req_info->read_again) {

sbin/unwind/libunbound/util/netevent.c

4545

c->tcp_req_info->read_again = 0;

sbin/unwind/libunbound/util/netevent.c

4657

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

sbin/unwind/libunbound/util/netevent.c

4669

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

sbin/unwind/libunbound/util/netevent.c

4678

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

sbin/unwind/libunbound/util/netevent.c

4690

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

sbin/unwind/libunbound/util/netevent.c

6038

c->tcp_req_info = tcp_req_info_create(spoolbuf);

sbin/unwind/libunbound/util/netevent.c

6039

if(!c->tcp_req_info) {

sbin/unwind/libunbound/util/netevent.c

6047

c->tcp_req_info->cp = c;

sbin/unwind/libunbound/util/netevent.c

6063

tcp_req_info_delete(c->tcp_req_info);

sbin/unwind/libunbound/util/netevent.c

6588

if(c->tcp_req_info)

sbin/unwind/libunbound/util/netevent.c

6589

tcp_req_info_clear(c->tcp_req_info);

sbin/unwind/libunbound/util/netevent.c

6643

if(c->tcp_req_info) {

sbin/unwind/libunbound/util/netevent.c

6644

tcp_req_info_delete(c->tcp_req_info);

sbin/unwind/libunbound/util/netevent.c

6681

repinfo->c->tcp_req_info?

sbin/unwind/libunbound/util/netevent.c

6682

repinfo->c->tcp_req_info->spool_buffer:repinfo->c->buffer)) {

sbin/unwind/libunbound/util/netevent.c

6719

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

sbin/unwind/libunbound/util/netevent.c

6720

?repinfo->c->tcp_req_info->spool_buffer

sbin/unwind/libunbound/util/netevent.c

6739

if(repinfo->c->tcp_req_info) {

sbin/unwind/libunbound/util/netevent.c

6740

tcp_req_info_send_reply(repinfo->c->tcp_req_info);

sbin/unwind/libunbound/util/netevent.c

6771

if(repinfo->c->tcp_req_info)

sbin/unwind/libunbound/util/netevent.c

6772

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

sbin/unwind/libunbound/util/netevent.h

407

struct tcp_req_info* tcp_req_info;

usr.sbin/unbound/daemon/worker.c

964

if(repinfo->c->tcp_req_info) {

usr.sbin/unbound/daemon/worker.c

966

repinfo->c->tcp_req_info->spool_buffer,

usr.sbin/unbound/services/listen_dnsport.c

2135

struct tcp_req_info*

usr.sbin/unbound/services/listen_dnsport.c

2138

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

usr.sbin/unbound/services/listen_dnsport.c

2149

tcp_req_info_delete(struct tcp_req_info* req)

usr.sbin/unbound/services/listen_dnsport.c

2159

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

2308

tcp_req_info_handle_writedone(struct tcp_req_info* req)

usr.sbin/unbound/services/listen_dnsport.c

2328

tcp_req_info_handle_readdone(struct tcp_req_info* req)

usr.sbin/unbound/services/listen_dnsport.c

2380

tcp_req_info_add_meshstate(struct tcp_req_info* req,

usr.sbin/unbound/services/listen_dnsport.c

2397

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

usr.sbin/unbound/services/listen_dnsport.c

2442

tcp_req_info_send_reply(struct tcp_req_info* req)

usr.sbin/unbound/services/listen_dnsport.h

383

struct tcp_req_info* tcp_req_info_create(struct sldns_buffer* spoolbuf);

usr.sbin/unbound/services/listen_dnsport.h

390

void tcp_req_info_delete(struct tcp_req_info* req);

usr.sbin/unbound/services/listen_dnsport.h

397

void tcp_req_info_clear(struct tcp_req_info* req);

usr.sbin/unbound/services/listen_dnsport.h

405

void tcp_req_info_remove_mesh_state(struct tcp_req_info* req,

usr.sbin/unbound/services/listen_dnsport.h

412

void tcp_req_info_handle_writedone(struct tcp_req_info* req);

usr.sbin/unbound/services/listen_dnsport.h

418

void tcp_req_info_handle_readdone(struct tcp_req_info* req);

usr.sbin/unbound/services/listen_dnsport.h

431

int tcp_req_info_add_meshstate(struct tcp_req_info* req,

usr.sbin/unbound/services/listen_dnsport.h

438

void tcp_req_info_send_reply(struct tcp_req_info* req);

usr.sbin/unbound/services/listen_dnsport.h

444

int tcp_req_info_handle_read_close(struct tcp_req_info* req);

usr.sbin/unbound/services/mesh.c

1844

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

usr.sbin/unbound/services/mesh.c

1845

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

usr.sbin/unbound/services/mesh.c

1850

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

usr.sbin/unbound/services/mesh.c

1851

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

usr.sbin/unbound/services/mesh.c

2624

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

usr.sbin/unbound/services/mesh.c

2625

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

usr.sbin/unbound/services/mesh.c

2628

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

usr.sbin/unbound/services/mesh.c

2629

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

usr.sbin/unbound/services/mesh.c

441

if(rep->c->tcp_req_info) {

usr.sbin/unbound/services/mesh.c

442

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

usr.sbin/unbound/services/mesh.c

551

if(rep->c->tcp_req_info) {

usr.sbin/unbound/services/mesh.c

552

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

usr.sbin/unbound/testcode/fake_event.c

1998

int tcp_req_info_add_meshstate(struct tcp_req_info* ATTR_UNUSED(req),

usr.sbin/unbound/testcode/fake_event.c

2006

tcp_req_info_remove_mesh_state(struct tcp_req_info* ATTR_UNUSED(req),

usr.sbin/unbound/util/netevent.c

3222

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

usr.sbin/unbound/util/netevent.c

3353

if(c->tcp_req_info) {

usr.sbin/unbound/util/netevent.c

3354

tcp_req_info_handle_writedone(c->tcp_req_info);

usr.sbin/unbound/util/netevent.c

3380

if(c->tcp_req_info) {

usr.sbin/unbound/util/netevent.c

3381

tcp_req_info_handle_readdone(c->tcp_req_info);

usr.sbin/unbound/util/netevent.c

3618

if(c->tcp_req_info)

usr.sbin/unbound/util/netevent.c

3619

return tcp_req_info_handle_read_close(c->tcp_req_info);

usr.sbin/unbound/util/netevent.c

3686

if(c->tcp_req_info)

usr.sbin/unbound/util/netevent.c

3687

return tcp_req_info_handle_read_close(c->tcp_req_info);

usr.sbin/unbound/util/netevent.c

3747

if(c->tcp_req_info)

usr.sbin/unbound/util/netevent.c

3748

return tcp_req_info_handle_read_close(c->tcp_req_info);

usr.sbin/unbound/util/netevent.c

3797

if(c->tcp_req_info)

usr.sbin/unbound/util/netevent.c

3798

return tcp_req_info_handle_read_close(c->tcp_req_info);

usr.sbin/unbound/util/netevent.c

4039

if(c->tcp_req_info)

usr.sbin/unbound/util/netevent.c

4040

return tcp_req_info_handle_read_close(c->tcp_req_info);

usr.sbin/unbound/util/netevent.c

4084

if(c->tcp_req_info)

usr.sbin/unbound/util/netevent.c

4085

return tcp_req_info_handle_read_close(c->tcp_req_info);

usr.sbin/unbound/util/netevent.c

4123

if(c->tcp_req_info)

usr.sbin/unbound/util/netevent.c

4124

return tcp_req_info_handle_read_close(c->tcp_req_info);

usr.sbin/unbound/util/netevent.c

4156

if(c->tcp_req_info)

usr.sbin/unbound/util/netevent.c

4157

return tcp_req_info_handle_read_close(c->tcp_req_info);

usr.sbin/unbound/util/netevent.c

4543

while(c->tcp_req_info->read_again) {

usr.sbin/unbound/util/netevent.c

4545

c->tcp_req_info->read_again = 0;

usr.sbin/unbound/util/netevent.c

4657

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

usr.sbin/unbound/util/netevent.c

4669

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

usr.sbin/unbound/util/netevent.c

4678

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

usr.sbin/unbound/util/netevent.c

4690

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

usr.sbin/unbound/util/netevent.c

6038

c->tcp_req_info = tcp_req_info_create(spoolbuf);

usr.sbin/unbound/util/netevent.c

6039

if(!c->tcp_req_info) {

usr.sbin/unbound/util/netevent.c

6047

c->tcp_req_info->cp = c;

usr.sbin/unbound/util/netevent.c

6063

tcp_req_info_delete(c->tcp_req_info);

usr.sbin/unbound/util/netevent.c

6588

if(c->tcp_req_info)

usr.sbin/unbound/util/netevent.c

6589

tcp_req_info_clear(c->tcp_req_info);

usr.sbin/unbound/util/netevent.c

6643

if(c->tcp_req_info) {

usr.sbin/unbound/util/netevent.c

6644

tcp_req_info_delete(c->tcp_req_info);

usr.sbin/unbound/util/netevent.c

6681

repinfo->c->tcp_req_info?

usr.sbin/unbound/util/netevent.c

6682

repinfo->c->tcp_req_info->spool_buffer:repinfo->c->buffer)) {

usr.sbin/unbound/util/netevent.c

6719

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

usr.sbin/unbound/util/netevent.c

6720

?repinfo->c->tcp_req_info->spool_buffer

usr.sbin/unbound/util/netevent.c

6739

if(repinfo->c->tcp_req_info) {

usr.sbin/unbound/util/netevent.c

6740

tcp_req_info_send_reply(repinfo->c->tcp_req_info);

usr.sbin/unbound/util/netevent.c

6771

if(repinfo->c->tcp_req_info)

usr.sbin/unbound/util/netevent.c

6772

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

usr.sbin/unbound/util/netevent.h

407

struct tcp_req_info* tcp_req_info;