sbin/unwind/libunbound/services/listen_dnsport.c

3614

struct doq_stream* stream;

sbin/unwind/libunbound/services/listen_dnsport.c

3617

stream = (struct doq_stream*)node;

sbin/unwind/libunbound/services/listen_dnsport.c

3730

struct doq_stream* c = (struct doq_stream*)key1;

sbin/unwind/libunbound/services/listen_dnsport.c

3731

struct doq_stream* d = (struct doq_stream*)key2;

sbin/unwind/libunbound/services/listen_dnsport.c

3845

doq_conn_add_stream(struct doq_conn* conn, struct doq_stream* stream)

sbin/unwind/libunbound/services/listen_dnsport.c

3852

doq_conn_del_stream(struct doq_conn* conn, struct doq_stream* stream)

sbin/unwind/libunbound/services/listen_dnsport.c

3858

static struct doq_stream*

sbin/unwind/libunbound/services/listen_dnsport.c

3861

struct doq_stream* stream = calloc(1, sizeof(*stream));

sbin/unwind/libunbound/services/listen_dnsport.c

3869

void doq_stream_delete(struct doq_stream* stream)

sbin/unwind/libunbound/services/listen_dnsport.c

3878

struct doq_stream*

sbin/unwind/libunbound/services/listen_dnsport.c

3882

struct doq_stream key;

sbin/unwind/libunbound/services/listen_dnsport.c

3887

return (struct doq_stream*)node->key;

sbin/unwind/libunbound/services/listen_dnsport.c

3893

doq_stream_on_write_list(struct doq_conn* conn, struct doq_stream* stream)

sbin/unwind/libunbound/services/listen_dnsport.c

3909

doq_stream_off_write_list(struct doq_conn* conn, struct doq_stream* stream)

sbin/unwind/libunbound/services/listen_dnsport.c

3926

doq_stream_remove_in_buffer(struct doq_stream* stream, struct doq_table* table)

sbin/unwind/libunbound/services/listen_dnsport.c

3938

doq_stream_remove_out_buffer(struct doq_stream* stream,

sbin/unwind/libunbound/services/listen_dnsport.c

3950

doq_stream_close(struct doq_conn* conn, struct doq_stream* stream,

sbin/unwind/libunbound/services/listen_dnsport.c

3991

doq_stream_pickup_answer(struct doq_conn* conn, struct doq_stream* stream,

sbin/unwind/libunbound/services/listen_dnsport.c

4020

doq_stream_send_reply(struct doq_conn* conn, struct doq_stream* stream,

sbin/unwind/libunbound/services/listen_dnsport.c

4043

doq_stream_add_meshstate(struct doq_stream* stream,

sbin/unwind/libunbound/services/listen_dnsport.c

4055

doq_stream_remove_mesh_state(struct doq_stream* stream)

sbin/unwind/libunbound/services/listen_dnsport.c

4070

doq_stream_datalen_complete(struct doq_conn* conn, struct doq_stream* stream,

sbin/unwind/libunbound/services/listen_dnsport.c

4095

doq_stream_data_complete(struct doq_conn* conn, struct doq_stream* stream)

sbin/unwind/libunbound/services/listen_dnsport.c

4127

c->repinfo.doq_stream = stream;

sbin/unwind/libunbound/services/listen_dnsport.c

4144

doq_stream_recv_data(struct doq_conn* conn, struct doq_stream* stream,

sbin/unwind/libunbound/services/listen_dnsport.c

4217

doq_stream_recv_fin(struct doq_conn* conn, struct doq_stream* stream, int

sbin/unwind/libunbound/services/listen_dnsport.c

4377

struct doq_stream* stream;

sbin/unwind/libunbound/services/listen_dnsport.c

4420

struct doq_stream* stream;

sbin/unwind/libunbound/services/listen_dnsport.c

4466

struct doq_stream* stream;

sbin/unwind/libunbound/services/listen_dnsport.c

4495

struct doq_stream* stream;

sbin/unwind/libunbound/services/listen_dnsport.c

4517

struct doq_stream* stream;

sbin/unwind/libunbound/services/listen_dnsport.c

4541

struct doq_stream* stream;

sbin/unwind/libunbound/services/listen_dnsport.c

5417

doq_stream_write_is_done(struct doq_conn* conn, struct doq_stream* stream)

sbin/unwind/libunbound/services/listen_dnsport.c

5427

struct doq_stream* stream = conn->stream_write_first;

sbin/unwind/libunbound/services/listen_dnsport.h

636

struct doq_stream* stream_write_first, *stream_write_last;

sbin/unwind/libunbound/services/listen_dnsport.h

703

struct doq_stream* write_prev, *write_next;

sbin/unwind/libunbound/services/listen_dnsport.h

787

void doq_stream_delete(struct doq_stream* stream);

sbin/unwind/libunbound/services/listen_dnsport.h

795

struct doq_stream* doq_stream_find(struct doq_conn* conn, int64_t stream_id);

sbin/unwind/libunbound/services/listen_dnsport.h

798

int doq_stream_close(struct doq_conn* conn, struct doq_stream* stream,

sbin/unwind/libunbound/services/listen_dnsport.h

802

int doq_stream_send_reply(struct doq_conn* conn, struct doq_stream* stream,

sbin/unwind/libunbound/services/listen_dnsport.h

807

void doq_stream_add_meshstate(struct doq_stream* stream,

sbin/unwind/libunbound/services/listen_dnsport.h

811

void doq_stream_remove_mesh_state(struct doq_stream* stream);

sbin/unwind/libunbound/services/mesh.c

1500

} else if(r->query_reply.doq_stream) {

sbin/unwind/libunbound/services/mesh.c

1501

r->query_reply.doq_stream->mesh_state = NULL;

sbin/unwind/libunbound/services/mesh.c

1796

else if(r->query_reply.doq_stream)

sbin/unwind/libunbound/services/mesh.c

1797

doq_stream_remove_mesh_state(r->query_reply.doq_stream);

sbin/unwind/libunbound/services/mesh.c

1835

} else if(r->query_reply.doq_stream) {

sbin/unwind/libunbound/services/mesh.c

1836

doq_stream_remove_mesh_state(r->query_reply.doq_stream);

sbin/unwind/libunbound/services/mesh.c

2033

r->query_reply.doq_stream = NULL;

sbin/unwind/libunbound/services/mesh.c

2391

struct comm_point* cp, struct doq_stream* doq_stream)

sbin/unwind/libunbound/services/mesh.c

2400

&& (!doq_stream || n->query_reply.doq_stream == doq_stream)) {

sbin/unwind/libunbound/services/mesh.c

2414

if(n->query_reply.doq_stream)

sbin/unwind/libunbound/services/mesh.c

2415

n->query_reply.doq_stream->mesh_state = NULL;

sbin/unwind/libunbound/services/mesh.c

2590

else if(r->query_reply.doq_stream)

sbin/unwind/libunbound/services/mesh.c

2591

doq_stream_remove_mesh_state(r->query_reply.doq_stream);

sbin/unwind/libunbound/services/mesh.c

470

else if(rep->c->type == comm_doq && rep->doq_stream)

sbin/unwind/libunbound/services/mesh.c

471

doq_stream_remove_mesh_state(rep->doq_stream);

sbin/unwind/libunbound/services/mesh.c

485

else if(rep->c->type == comm_doq && rep->doq_stream)

sbin/unwind/libunbound/services/mesh.c

486

doq_stream_remove_mesh_state(rep->doq_stream);

sbin/unwind/libunbound/services/mesh.c

559

} else if(rep->c->type == comm_doq && rep->doq_stream) {

sbin/unwind/libunbound/services/mesh.c

560

doq_stream_add_meshstate(rep->doq_stream, mesh, s);

sbin/unwind/libunbound/services/mesh.c

614

else if(rep->c->type == comm_doq && rep->doq_stream)

sbin/unwind/libunbound/services/mesh.c

615

doq_stream_remove_mesh_state(rep->doq_stream);

sbin/unwind/libunbound/services/mesh.h

690

struct comm_point* cp, struct doq_stream* doq_stream);

sbin/unwind/libunbound/util/netevent.c

2006

+ sizeof(struct doq_stream)

sbin/unwind/libunbound/util/netevent.c

2819

struct doq_conn** conn, struct doq_stream** stream)

sbin/unwind/libunbound/util/netevent.c

2864

struct doq_stream* stream;

sbin/unwind/libunbound/util/netevent.c

2895

struct doq_stream* stream;

sbin/unwind/libunbound/util/netevent.h

191

struct doq_stream* doq_stream;

usr.sbin/unbound/services/listen_dnsport.c

3614

struct doq_stream* stream;

usr.sbin/unbound/services/listen_dnsport.c

3617

stream = (struct doq_stream*)node;

usr.sbin/unbound/services/listen_dnsport.c

3730

struct doq_stream* c = (struct doq_stream*)key1;

usr.sbin/unbound/services/listen_dnsport.c

3731

struct doq_stream* d = (struct doq_stream*)key2;

usr.sbin/unbound/services/listen_dnsport.c

3845

doq_conn_add_stream(struct doq_conn* conn, struct doq_stream* stream)

usr.sbin/unbound/services/listen_dnsport.c

3852

doq_conn_del_stream(struct doq_conn* conn, struct doq_stream* stream)

usr.sbin/unbound/services/listen_dnsport.c

3858

static struct doq_stream*

usr.sbin/unbound/services/listen_dnsport.c

3861

struct doq_stream* stream = calloc(1, sizeof(*stream));

usr.sbin/unbound/services/listen_dnsport.c

3869

void doq_stream_delete(struct doq_stream* stream)

usr.sbin/unbound/services/listen_dnsport.c

3878

struct doq_stream*

usr.sbin/unbound/services/listen_dnsport.c

3882

struct doq_stream key;

usr.sbin/unbound/services/listen_dnsport.c

3887

return (struct doq_stream*)node->key;

usr.sbin/unbound/services/listen_dnsport.c

3893

doq_stream_on_write_list(struct doq_conn* conn, struct doq_stream* stream)

usr.sbin/unbound/services/listen_dnsport.c

3909

doq_stream_off_write_list(struct doq_conn* conn, struct doq_stream* stream)

usr.sbin/unbound/services/listen_dnsport.c

3926

doq_stream_remove_in_buffer(struct doq_stream* stream, struct doq_table* table)

usr.sbin/unbound/services/listen_dnsport.c

3938

doq_stream_remove_out_buffer(struct doq_stream* stream,

usr.sbin/unbound/services/listen_dnsport.c

3950

doq_stream_close(struct doq_conn* conn, struct doq_stream* stream,

usr.sbin/unbound/services/listen_dnsport.c

3991

doq_stream_pickup_answer(struct doq_conn* conn, struct doq_stream* stream,

usr.sbin/unbound/services/listen_dnsport.c

4020

doq_stream_send_reply(struct doq_conn* conn, struct doq_stream* stream,

usr.sbin/unbound/services/listen_dnsport.c

4043

doq_stream_add_meshstate(struct doq_stream* stream,

usr.sbin/unbound/services/listen_dnsport.c

4055

doq_stream_remove_mesh_state(struct doq_stream* stream)

usr.sbin/unbound/services/listen_dnsport.c

4070

doq_stream_datalen_complete(struct doq_conn* conn, struct doq_stream* stream,

usr.sbin/unbound/services/listen_dnsport.c

4095

doq_stream_data_complete(struct doq_conn* conn, struct doq_stream* stream)

usr.sbin/unbound/services/listen_dnsport.c

4127

c->repinfo.doq_stream = stream;

usr.sbin/unbound/services/listen_dnsport.c

4144

doq_stream_recv_data(struct doq_conn* conn, struct doq_stream* stream,

usr.sbin/unbound/services/listen_dnsport.c

4217

doq_stream_recv_fin(struct doq_conn* conn, struct doq_stream* stream, int

usr.sbin/unbound/services/listen_dnsport.c

4377

struct doq_stream* stream;

usr.sbin/unbound/services/listen_dnsport.c

4420

struct doq_stream* stream;

usr.sbin/unbound/services/listen_dnsport.c

4466

struct doq_stream* stream;

usr.sbin/unbound/services/listen_dnsport.c

4495

struct doq_stream* stream;

usr.sbin/unbound/services/listen_dnsport.c

4517

struct doq_stream* stream;

usr.sbin/unbound/services/listen_dnsport.c

4541

struct doq_stream* stream;

usr.sbin/unbound/services/listen_dnsport.c

5417

doq_stream_write_is_done(struct doq_conn* conn, struct doq_stream* stream)

usr.sbin/unbound/services/listen_dnsport.c

5427

struct doq_stream* stream = conn->stream_write_first;

usr.sbin/unbound/services/listen_dnsport.h

636

struct doq_stream* stream_write_first, *stream_write_last;

usr.sbin/unbound/services/listen_dnsport.h

703

struct doq_stream* write_prev, *write_next;

usr.sbin/unbound/services/listen_dnsport.h

787

void doq_stream_delete(struct doq_stream* stream);

usr.sbin/unbound/services/listen_dnsport.h

795

struct doq_stream* doq_stream_find(struct doq_conn* conn, int64_t stream_id);

usr.sbin/unbound/services/listen_dnsport.h

798

int doq_stream_close(struct doq_conn* conn, struct doq_stream* stream,

usr.sbin/unbound/services/listen_dnsport.h

802

int doq_stream_send_reply(struct doq_conn* conn, struct doq_stream* stream,

usr.sbin/unbound/services/listen_dnsport.h

807

void doq_stream_add_meshstate(struct doq_stream* stream,

usr.sbin/unbound/services/listen_dnsport.h

811

void doq_stream_remove_mesh_state(struct doq_stream* stream);

usr.sbin/unbound/services/mesh.c

1500

} else if(r->query_reply.doq_stream) {

usr.sbin/unbound/services/mesh.c

1501

r->query_reply.doq_stream->mesh_state = NULL;

usr.sbin/unbound/services/mesh.c

1796

else if(r->query_reply.doq_stream)

usr.sbin/unbound/services/mesh.c

1797

doq_stream_remove_mesh_state(r->query_reply.doq_stream);

usr.sbin/unbound/services/mesh.c

1835

} else if(r->query_reply.doq_stream) {

usr.sbin/unbound/services/mesh.c

1836

doq_stream_remove_mesh_state(r->query_reply.doq_stream);

usr.sbin/unbound/services/mesh.c

2033

r->query_reply.doq_stream = NULL;

usr.sbin/unbound/services/mesh.c

2391

struct comm_point* cp, struct doq_stream* doq_stream)

usr.sbin/unbound/services/mesh.c

2400

&& (!doq_stream || n->query_reply.doq_stream == doq_stream)) {

usr.sbin/unbound/services/mesh.c

2414

if(n->query_reply.doq_stream)

usr.sbin/unbound/services/mesh.c

2415

n->query_reply.doq_stream->mesh_state = NULL;

usr.sbin/unbound/services/mesh.c

2590

else if(r->query_reply.doq_stream)

usr.sbin/unbound/services/mesh.c

2591

doq_stream_remove_mesh_state(r->query_reply.doq_stream);

usr.sbin/unbound/services/mesh.c

470

else if(rep->c->type == comm_doq && rep->doq_stream)

usr.sbin/unbound/services/mesh.c

471

doq_stream_remove_mesh_state(rep->doq_stream);

usr.sbin/unbound/services/mesh.c

485

else if(rep->c->type == comm_doq && rep->doq_stream)

usr.sbin/unbound/services/mesh.c

486

doq_stream_remove_mesh_state(rep->doq_stream);

usr.sbin/unbound/services/mesh.c

559

} else if(rep->c->type == comm_doq && rep->doq_stream) {

usr.sbin/unbound/services/mesh.c

560

doq_stream_add_meshstate(rep->doq_stream, mesh, s);

usr.sbin/unbound/services/mesh.c

614

else if(rep->c->type == comm_doq && rep->doq_stream)

usr.sbin/unbound/services/mesh.c

615

doq_stream_remove_mesh_state(rep->doq_stream);

usr.sbin/unbound/services/mesh.h

690

struct comm_point* cp, struct doq_stream* doq_stream);

usr.sbin/unbound/testcode/fake_event.c

2039

void doq_stream_add_meshstate(struct doq_stream* ATTR_UNUSED(stream),

usr.sbin/unbound/testcode/fake_event.c

2044

void doq_stream_remove_mesh_state(struct doq_stream* ATTR_UNUSED(stream))

usr.sbin/unbound/testcode/unitdoq.c

64

size_t stream_size = sizeof(struct doq_stream);

usr.sbin/unbound/util/netevent.c

2006

+ sizeof(struct doq_stream)

usr.sbin/unbound/util/netevent.c

2819

struct doq_conn** conn, struct doq_stream** stream)

usr.sbin/unbound/util/netevent.c

2864

struct doq_stream* stream;

usr.sbin/unbound/util/netevent.c

2895

struct doq_stream* stream;

usr.sbin/unbound/util/netevent.h

191

struct doq_stream* doq_stream;