Symbol: doq_stream
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
3725
struct doq_stream* c = (struct doq_stream*)key1;
sbin/unwind/libunbound/services/listen_dnsport.c
3726
struct doq_stream* d = (struct doq_stream*)key2;
sbin/unwind/libunbound/services/listen_dnsport.c
3840
doq_conn_add_stream(struct doq_conn* conn, struct doq_stream* stream)
sbin/unwind/libunbound/services/listen_dnsport.c
3847
doq_conn_del_stream(struct doq_conn* conn, struct doq_stream* stream)
sbin/unwind/libunbound/services/listen_dnsport.c
3853
static struct doq_stream*
sbin/unwind/libunbound/services/listen_dnsport.c
3856
struct doq_stream* stream = calloc(1, sizeof(*stream));
sbin/unwind/libunbound/services/listen_dnsport.c
3864
void doq_stream_delete(struct doq_stream* stream)
sbin/unwind/libunbound/services/listen_dnsport.c
3873
struct doq_stream*
sbin/unwind/libunbound/services/listen_dnsport.c
3877
struct doq_stream key;
sbin/unwind/libunbound/services/listen_dnsport.c
3882
return (struct doq_stream*)node->key;
sbin/unwind/libunbound/services/listen_dnsport.c
3888
doq_stream_on_write_list(struct doq_conn* conn, struct doq_stream* stream)
sbin/unwind/libunbound/services/listen_dnsport.c
3904
doq_stream_off_write_list(struct doq_conn* conn, struct doq_stream* stream)
sbin/unwind/libunbound/services/listen_dnsport.c
3921
doq_stream_remove_in_buffer(struct doq_stream* stream, struct doq_table* table)
sbin/unwind/libunbound/services/listen_dnsport.c
3933
doq_stream_remove_out_buffer(struct doq_stream* stream,
sbin/unwind/libunbound/services/listen_dnsport.c
3945
doq_stream_close(struct doq_conn* conn, struct doq_stream* stream,
sbin/unwind/libunbound/services/listen_dnsport.c
3981
doq_stream_pickup_answer(struct doq_stream* stream, struct sldns_buffer* buf)
sbin/unwind/libunbound/services/listen_dnsport.c
4004
doq_stream_send_reply(struct doq_conn* conn, struct doq_stream* stream,
sbin/unwind/libunbound/services/listen_dnsport.c
4028
doq_stream_datalen_complete(struct doq_stream* stream, struct doq_table* table)
sbin/unwind/libunbound/services/listen_dnsport.c
4047
doq_stream_data_complete(struct doq_conn* conn, struct doq_stream* stream)
sbin/unwind/libunbound/services/listen_dnsport.c
4095
doq_stream_recv_data(struct doq_stream* stream, const uint8_t* data,
sbin/unwind/libunbound/services/listen_dnsport.c
4167
doq_stream_recv_fin(struct doq_conn* conn, struct doq_stream* stream, int
sbin/unwind/libunbound/services/listen_dnsport.c
4328
struct doq_stream* stream;
sbin/unwind/libunbound/services/listen_dnsport.c
4372
struct doq_stream* stream;
sbin/unwind/libunbound/services/listen_dnsport.c
4418
struct doq_stream* stream;
sbin/unwind/libunbound/services/listen_dnsport.c
4447
struct doq_stream* stream;
sbin/unwind/libunbound/services/listen_dnsport.c
4470
struct doq_stream* stream;
sbin/unwind/libunbound/services/listen_dnsport.c
5338
doq_stream_write_is_done(struct doq_conn* conn, struct doq_stream* stream)
sbin/unwind/libunbound/services/listen_dnsport.c
5348
struct doq_stream* stream = conn->stream_write_first;
sbin/unwind/libunbound/services/listen_dnsport.h
631
struct doq_stream* stream_write_first, *stream_write_last;
sbin/unwind/libunbound/services/listen_dnsport.h
693
struct doq_stream* write_prev, *write_next;
sbin/unwind/libunbound/services/listen_dnsport.h
777
void doq_stream_delete(struct doq_stream* stream);
sbin/unwind/libunbound/services/listen_dnsport.h
785
struct doq_stream* doq_stream_find(struct doq_conn* conn, int64_t stream_id);
sbin/unwind/libunbound/services/listen_dnsport.h
788
int doq_stream_close(struct doq_conn* conn, struct doq_stream* stream,
sbin/unwind/libunbound/services/listen_dnsport.h
792
int doq_stream_send_reply(struct doq_conn* conn, struct doq_stream* stream,
sbin/unwind/libunbound/util/netevent.c
2013
+ sizeof(struct doq_stream)
sbin/unwind/libunbound/util/netevent.c
2825
struct doq_conn** conn, struct doq_stream** stream)
sbin/unwind/libunbound/util/netevent.c
2870
struct doq_stream* stream;
sbin/unwind/libunbound/util/netevent.c
2901
struct doq_stream* 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
3725
struct doq_stream* c = (struct doq_stream*)key1;
usr.sbin/unbound/services/listen_dnsport.c
3726
struct doq_stream* d = (struct doq_stream*)key2;
usr.sbin/unbound/services/listen_dnsport.c
3840
doq_conn_add_stream(struct doq_conn* conn, struct doq_stream* stream)
usr.sbin/unbound/services/listen_dnsport.c
3847
doq_conn_del_stream(struct doq_conn* conn, struct doq_stream* stream)
usr.sbin/unbound/services/listen_dnsport.c
3853
static struct doq_stream*
usr.sbin/unbound/services/listen_dnsport.c
3856
struct doq_stream* stream = calloc(1, sizeof(*stream));
usr.sbin/unbound/services/listen_dnsport.c
3864
void doq_stream_delete(struct doq_stream* stream)
usr.sbin/unbound/services/listen_dnsport.c
3873
struct doq_stream*
usr.sbin/unbound/services/listen_dnsport.c
3877
struct doq_stream key;
usr.sbin/unbound/services/listen_dnsport.c
3882
return (struct doq_stream*)node->key;
usr.sbin/unbound/services/listen_dnsport.c
3888
doq_stream_on_write_list(struct doq_conn* conn, struct doq_stream* stream)
usr.sbin/unbound/services/listen_dnsport.c
3904
doq_stream_off_write_list(struct doq_conn* conn, struct doq_stream* stream)
usr.sbin/unbound/services/listen_dnsport.c
3921
doq_stream_remove_in_buffer(struct doq_stream* stream, struct doq_table* table)
usr.sbin/unbound/services/listen_dnsport.c
3933
doq_stream_remove_out_buffer(struct doq_stream* stream,
usr.sbin/unbound/services/listen_dnsport.c
3945
doq_stream_close(struct doq_conn* conn, struct doq_stream* stream,
usr.sbin/unbound/services/listen_dnsport.c
3981
doq_stream_pickup_answer(struct doq_stream* stream, struct sldns_buffer* buf)
usr.sbin/unbound/services/listen_dnsport.c
4004
doq_stream_send_reply(struct doq_conn* conn, struct doq_stream* stream,
usr.sbin/unbound/services/listen_dnsport.c
4028
doq_stream_datalen_complete(struct doq_stream* stream, struct doq_table* table)
usr.sbin/unbound/services/listen_dnsport.c
4047
doq_stream_data_complete(struct doq_conn* conn, struct doq_stream* stream)
usr.sbin/unbound/services/listen_dnsport.c
4095
doq_stream_recv_data(struct doq_stream* stream, const uint8_t* data,
usr.sbin/unbound/services/listen_dnsport.c
4167
doq_stream_recv_fin(struct doq_conn* conn, struct doq_stream* stream, int
usr.sbin/unbound/services/listen_dnsport.c
4328
struct doq_stream* stream;
usr.sbin/unbound/services/listen_dnsport.c
4372
struct doq_stream* stream;
usr.sbin/unbound/services/listen_dnsport.c
4418
struct doq_stream* stream;
usr.sbin/unbound/services/listen_dnsport.c
4447
struct doq_stream* stream;
usr.sbin/unbound/services/listen_dnsport.c
4470
struct doq_stream* stream;
usr.sbin/unbound/services/listen_dnsport.c
5338
doq_stream_write_is_done(struct doq_conn* conn, struct doq_stream* stream)
usr.sbin/unbound/services/listen_dnsport.c
5348
struct doq_stream* stream = conn->stream_write_first;
usr.sbin/unbound/services/listen_dnsport.h
631
struct doq_stream* stream_write_first, *stream_write_last;
usr.sbin/unbound/services/listen_dnsport.h
693
struct doq_stream* write_prev, *write_next;
usr.sbin/unbound/services/listen_dnsport.h
777
void doq_stream_delete(struct doq_stream* stream);
usr.sbin/unbound/services/listen_dnsport.h
785
struct doq_stream* doq_stream_find(struct doq_conn* conn, int64_t stream_id);
usr.sbin/unbound/services/listen_dnsport.h
788
int doq_stream_close(struct doq_conn* conn, struct doq_stream* stream,
usr.sbin/unbound/services/listen_dnsport.h
792
int doq_stream_send_reply(struct doq_conn* conn, struct doq_stream* stream,
usr.sbin/unbound/testcode/unitdoq.c
64
size_t stream_size = sizeof(struct doq_stream);
usr.sbin/unbound/util/netevent.c
2013
+ sizeof(struct doq_stream)
usr.sbin/unbound/util/netevent.c
2825
struct doq_conn** conn, struct doq_stream** stream)
usr.sbin/unbound/util/netevent.c
2870
struct doq_stream* stream;
usr.sbin/unbound/util/netevent.c
2901
struct doq_stream* stream;