Symbol: doq_conn
sbin/unwind/libunbound/services/listen_dnsport.c
3356
struct doq_conn* conn;
sbin/unwind/libunbound/services/listen_dnsport.c
3359
conn = (struct doq_conn*)node->key;
sbin/unwind/libunbound/services/listen_dnsport.c
3551
struct doq_conn*
sbin/unwind/libunbound/services/listen_dnsport.c
3555
struct doq_conn* conn = calloc(1, sizeof(*conn));
sbin/unwind/libunbound/services/listen_dnsport.c
3627
doq_conn_delete(struct doq_conn* conn, struct doq_table* table)
sbin/unwind/libunbound/services/listen_dnsport.c
3654
struct doq_conn* c = (struct doq_conn*)key1;
sbin/unwind/libunbound/services/listen_dnsport.c
3655
struct doq_conn* d = (struct doq_conn*)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
3874
doq_stream_find(struct doq_conn* conn, int64_t stream_id)
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
3945
doq_stream_close(struct doq_conn* conn, struct doq_stream* stream,
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
4047
doq_stream_data_complete(struct doq_conn* conn, struct doq_stream* stream)
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
4190
doq_conn_generate_new_conid(struct doq_conn* conn, uint8_t* data,
sbin/unwind/libunbound/services/listen_dnsport.c
4222
struct doq_conn* doq_conn = (struct doq_conn*)user_data;
sbin/unwind/libunbound/services/listen_dnsport.c
4226
lock_rw_wrlock(&doq_conn->table->conid_lock);
sbin/unwind/libunbound/services/listen_dnsport.c
4227
if(!doq_conn_generate_new_conid(doq_conn, cid->data, cidlen)) {
sbin/unwind/libunbound/services/listen_dnsport.c
4228
lock_rw_unlock(&doq_conn->table->conid_lock);
sbin/unwind/libunbound/services/listen_dnsport.c
4233
doq_conn->doq_socket->static_secret,
sbin/unwind/libunbound/services/listen_dnsport.c
4234
doq_conn->doq_socket->static_secret_len, cid) != 0) {
sbin/unwind/libunbound/services/listen_dnsport.c
4235
lock_rw_unlock(&doq_conn->table->conid_lock);
sbin/unwind/libunbound/services/listen_dnsport.c
4238
if(!doq_conn_associate_conid(doq_conn, cid->data, cid->datalen)) {
sbin/unwind/libunbound/services/listen_dnsport.c
4239
lock_rw_unlock(&doq_conn->table->conid_lock);
sbin/unwind/libunbound/services/listen_dnsport.c
4242
lock_rw_unlock(&doq_conn->table->conid_lock);
sbin/unwind/libunbound/services/listen_dnsport.c
4251
struct doq_conn* doq_conn = (struct doq_conn*)user_data;
sbin/unwind/libunbound/services/listen_dnsport.c
4252
lock_rw_wrlock(&doq_conn->table->conid_lock);
sbin/unwind/libunbound/services/listen_dnsport.c
4253
doq_conn_dissociate_conid(doq_conn, cid->data, cid->datalen);
sbin/unwind/libunbound/services/listen_dnsport.c
4254
lock_rw_unlock(&doq_conn->table->conid_lock);
sbin/unwind/libunbound/services/listen_dnsport.c
4260
doq_submit_new_token(struct doq_conn* conn)
sbin/unwind/libunbound/services/listen_dnsport.c
4291
struct doq_conn* doq_conn = (struct doq_conn*)user_data;
sbin/unwind/libunbound/services/listen_dnsport.c
4294
(int)ngtcp2_conn_get_max_data_left(doq_conn->conn));
sbin/unwind/libunbound/services/listen_dnsport.c
4297
(int)ngtcp2_conn_get_max_local_streams_uni(doq_conn->conn));
sbin/unwind/libunbound/services/listen_dnsport.c
4300
(int)ngtcp2_conn_get_streams_uni_left(doq_conn->conn));
sbin/unwind/libunbound/services/listen_dnsport.c
4302
(int)ngtcp2_conn_get_streams_bidi_left(doq_conn->conn));
sbin/unwind/libunbound/services/listen_dnsport.c
4304
SSL_get_cipher_name(doq_conn->ssl));
sbin/unwind/libunbound/services/listen_dnsport.c
4309
SSL_get0_alpn_selected(doq_conn->ssl, &alpn, &alpnlen);
sbin/unwind/libunbound/services/listen_dnsport.c
4317
if(!doq_submit_new_token(doq_conn))
sbin/unwind/libunbound/services/listen_dnsport.c
4327
struct doq_conn* doq_conn = (struct doq_conn*)user_data;
sbin/unwind/libunbound/services/listen_dnsport.c
4330
if(doq_stream_find(doq_conn, stream_id)) {
sbin/unwind/libunbound/services/listen_dnsport.c
4335
!doq_table_quic_size_available(doq_conn->doq_socket->table,
sbin/unwind/libunbound/services/listen_dnsport.c
4336
doq_conn->doq_socket->cfg, sizeof(*stream)
sbin/unwind/libunbound/services/listen_dnsport.c
4342
rv = ngtcp2_conn_shutdown_stream(doq_conn->conn,
sbin/unwind/libunbound/services/listen_dnsport.c
4359
doq_table_quic_size_add(doq_conn->doq_socket->table, sizeof(*stream));
sbin/unwind/libunbound/services/listen_dnsport.c
4360
doq_conn_add_stream(doq_conn, stream);
sbin/unwind/libunbound/services/listen_dnsport.c
4371
struct doq_conn* doq_conn = (struct doq_conn*)user_data;
sbin/unwind/libunbound/services/listen_dnsport.c
4382
stream = doq_stream_find(doq_conn, stream_id);
sbin/unwind/libunbound/services/listen_dnsport.c
4394
doq_conn->doq_socket->table))
sbin/unwind/libunbound/services/listen_dnsport.c
4398
if(!doq_stream_recv_fin(doq_conn, stream, recv_done))
sbin/unwind/libunbound/services/listen_dnsport.c
4401
ngtcp2_conn_extend_max_stream_offset(doq_conn->conn, stream_id,
sbin/unwind/libunbound/services/listen_dnsport.c
4403
ngtcp2_conn_extend_max_offset(doq_conn->conn, datalen);
sbin/unwind/libunbound/services/listen_dnsport.c
4405
if(!doq_stream_data_complete(doq_conn, stream))
sbin/unwind/libunbound/services/listen_dnsport.c
4417
struct doq_conn* doq_conn = (struct doq_conn*)user_data;
sbin/unwind/libunbound/services/listen_dnsport.c
4429
stream = doq_stream_find(doq_conn, stream_id);
sbin/unwind/libunbound/services/listen_dnsport.c
4435
if(!doq_stream_close(doq_conn, stream, 0))
sbin/unwind/libunbound/services/listen_dnsport.c
4446
struct doq_conn* doq_conn = (struct doq_conn*)user_data;
sbin/unwind/libunbound/services/listen_dnsport.c
4452
stream = doq_stream_find(doq_conn, stream_id);
sbin/unwind/libunbound/services/listen_dnsport.c
4458
if(!doq_stream_close(doq_conn, stream, 0))
sbin/unwind/libunbound/services/listen_dnsport.c
4469
struct doq_conn* doq_conn = (struct doq_conn*)user_data;
sbin/unwind/libunbound/services/listen_dnsport.c
4474
stream = doq_stream_find(doq_conn, stream_id);
sbin/unwind/libunbound/services/listen_dnsport.c
4485
doq_conn->doq_socket->table);
sbin/unwind/libunbound/services/listen_dnsport.c
4487
doq_conn->doq_socket->table);
sbin/unwind/libunbound/services/listen_dnsport.c
4507
doq_application_tx_key_cb(struct doq_conn* conn)
sbin/unwind/libunbound/services/listen_dnsport.c
4531
struct doq_conn* doq_conn = (struct doq_conn*)SSL_get_app_data(ssl);
sbin/unwind/libunbound/services/listen_dnsport.c
4548
if(ngtcp2_crypto_derive_and_install_rx_key(doq_conn->conn,
sbin/unwind/libunbound/services/listen_dnsport.c
4559
if(ngtcp2_crypto_derive_and_install_tx_key(doq_conn->conn,
sbin/unwind/libunbound/services/listen_dnsport.c
4567
if(!doq_application_tx_key_cb(doq_conn))
sbin/unwind/libunbound/services/listen_dnsport.c
4579
struct doq_conn* doq_conn = (struct doq_conn*)SSL_get_app_data(ssl);
sbin/unwind/libunbound/services/listen_dnsport.c
4597
rv = ngtcp2_conn_submit_crypto_data(doq_conn->conn, level, data, len);
sbin/unwind/libunbound/services/listen_dnsport.c
4601
ngtcp2_conn_set_tls_error(doq_conn->conn, rv);
sbin/unwind/libunbound/services/listen_dnsport.c
4619
struct doq_conn* doq_conn = (struct doq_conn*)SSL_get_app_data(ssl);
sbin/unwind/libunbound/services/listen_dnsport.c
4620
doq_conn->tls_alert = alert;
sbin/unwind/libunbound/services/listen_dnsport.c
4745
struct doq_conn* conn = (struct doq_conn*)conn_ref->user_data;
sbin/unwind/libunbound/services/listen_dnsport.c
4751
doq_ssl_server_setup(SSL_CTX* ctx, struct doq_conn* conn)
sbin/unwind/libunbound/services/listen_dnsport.c
4792
doq_conn_setup(struct doq_conn* conn, uint8_t* scid, size_t scidlen,
sbin/unwind/libunbound/services/listen_dnsport.c
4933
doq_conid_list_insert(struct doq_conn* conn, struct doq_conid* conid)
sbin/unwind/libunbound/services/listen_dnsport.c
4944
doq_conid_list_remove(struct doq_conn* conn, struct doq_conid* conid)
sbin/unwind/libunbound/services/listen_dnsport.c
4990
conid_is_for_conn(struct doq_conn* conn, struct doq_conid* conid)
sbin/unwind/libunbound/services/listen_dnsport.c
5006
doq_conn_associate_conid(struct doq_conn* conn, uint8_t* data, size_t datalen)
sbin/unwind/libunbound/services/listen_dnsport.c
5032
doq_conn_dissociate_conid(struct doq_conn* conn, const uint8_t* data,
sbin/unwind/libunbound/services/listen_dnsport.c
5050
doq_conn_setup_id_array_and_dcid(struct doq_conn* conn,
sbin/unwind/libunbound/services/listen_dnsport.c
5065
doq_conn_setup_conids(struct doq_conn* conn)
sbin/unwind/libunbound/services/listen_dnsport.c
5095
doq_conn_clear_conids(struct doq_conn* conn)
sbin/unwind/libunbound/services/listen_dnsport.c
5133
doq_conn_start_closing_period(struct comm_point* c, struct doq_conn* conn)
sbin/unwind/libunbound/services/listen_dnsport.c
5197
doq_conn_send_close(struct comm_point* c, struct doq_conn* conn)
sbin/unwind/libunbound/services/listen_dnsport.c
5217
doq_conn_close_error(struct comm_point* c, struct doq_conn* conn)
sbin/unwind/libunbound/services/listen_dnsport.c
5247
struct doq_conn* conn, struct ngtcp2_pkt_info* pi, int* err_retry,
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
5345
doq_conn_write_streams(struct comm_point* c, struct doq_conn* conn,
sbin/unwind/libunbound/services/listen_dnsport.c
5494
doq_conn_write_enable(struct doq_conn* conn)
sbin/unwind/libunbound/services/listen_dnsport.c
5500
doq_conn_write_disable(struct doq_conn* conn)
sbin/unwind/libunbound/services/listen_dnsport.c
5507
doq_conn_write_list_append(struct doq_table* table, struct doq_conn* conn)
sbin/unwind/libunbound/services/listen_dnsport.c
5521
doq_conn_write_list_remove(struct doq_table* table, struct doq_conn* conn)
sbin/unwind/libunbound/services/listen_dnsport.c
5537
doq_conn_set_write_list(struct doq_table* table, struct doq_conn* conn)
sbin/unwind/libunbound/services/listen_dnsport.c
5548
struct doq_conn*
sbin/unwind/libunbound/services/listen_dnsport.c
5551
struct doq_conn* conn = table->write_list_first;
sbin/unwind/libunbound/services/listen_dnsport.c
5566
doq_conn_check_timer(struct doq_conn* conn, struct timeval* tv)
sbin/unwind/libunbound/services/listen_dnsport.c
5599
doq_conn_log_line(struct doq_conn* conn, char* s)
sbin/unwind/libunbound/services/listen_dnsport.c
5610
doq_conn_handle_timeout(struct doq_conn* conn)
sbin/unwind/libunbound/services/listen_dnsport.h
508
struct doq_conn* write_list_first, *write_list_last;
sbin/unwind/libunbound/services/listen_dnsport.h
556
struct doq_conn* conn;
sbin/unwind/libunbound/services/listen_dnsport.h
637
struct doq_conn* write_prev, *write_next;
sbin/unwind/libunbound/services/listen_dnsport.h
709
struct doq_conn* doq_conn_create(struct comm_point* c,
sbin/unwind/libunbound/services/listen_dnsport.h
718
void doq_conn_delete(struct doq_conn* conn, struct doq_table* table);
sbin/unwind/libunbound/services/listen_dnsport.h
733
int doq_conn_setup(struct doq_conn* conn, uint8_t* scid, size_t scidlen,
sbin/unwind/libunbound/services/listen_dnsport.h
744
int doq_conn_associate_conid(struct doq_conn* conn, uint8_t* data,
sbin/unwind/libunbound/services/listen_dnsport.h
749
void doq_conn_dissociate_conid(struct doq_conn* conn, const uint8_t* data,
sbin/unwind/libunbound/services/listen_dnsport.h
753
int doq_conn_setup_conids(struct doq_conn* conn);
sbin/unwind/libunbound/services/listen_dnsport.h
757
void doq_conn_clear_conids(struct doq_conn* conn);
sbin/unwind/libunbound/services/listen_dnsport.h
766
struct doq_conn* conn, struct ngtcp2_pkt_info* pi, int* err_retry,
sbin/unwind/libunbound/services/listen_dnsport.h
770
int doq_conn_write_streams(struct comm_point* c, struct doq_conn* conn,
sbin/unwind/libunbound/services/listen_dnsport.h
774
int doq_conn_send_close(struct comm_point* c, struct doq_conn* conn);
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/services/listen_dnsport.h
796
void doq_conn_write_enable(struct doq_conn* conn);
sbin/unwind/libunbound/services/listen_dnsport.h
799
void doq_conn_write_disable(struct doq_conn* conn);
sbin/unwind/libunbound/services/listen_dnsport.h
802
void doq_conn_set_write_list(struct doq_table* table, struct doq_conn* conn);
sbin/unwind/libunbound/services/listen_dnsport.h
806
struct doq_conn* conn);
sbin/unwind/libunbound/services/listen_dnsport.h
810
struct doq_conn* doq_table_pop_first(struct doq_table* table);
sbin/unwind/libunbound/services/listen_dnsport.h
819
int doq_conn_check_timer(struct doq_conn* conn, struct timeval* tv);
sbin/unwind/libunbound/services/listen_dnsport.h
840
int doq_conn_handle_timeout(struct doq_conn* conn);
sbin/unwind/libunbound/util/netevent.c
1639
static struct doq_conn*
sbin/unwind/libunbound/util/netevent.c
1646
struct doq_conn key;
sbin/unwind/libunbound/util/netevent.c
1658
return (struct doq_conn*)node->key;
sbin/unwind/libunbound/util/netevent.c
1663
static struct doq_conn*
sbin/unwind/libunbound/util/netevent.c
1672
struct doq_conn* conn;
sbin/unwind/libunbound/util/netevent.c
1707
static struct doq_conn*
sbin/unwind/libunbound/util/netevent.c
1711
struct doq_conn* conn;
sbin/unwind/libunbound/util/netevent.c
1737
struct doq_pkt_addr* paddr, struct doq_conn** conn)
sbin/unwind/libunbound/util/netevent.c
1958
doq_delete_connection(struct comm_point* c, struct doq_conn* conn)
sbin/unwind/libunbound/util/netevent.c
1960
struct doq_conn copy;
sbin/unwind/libunbound/util/netevent.c
1979
conn = (struct doq_conn*)node->key;
sbin/unwind/libunbound/util/netevent.c
2006
static struct doq_conn*
sbin/unwind/libunbound/util/netevent.c
2010
struct doq_conn* conn;
sbin/unwind/libunbound/util/netevent.c
2126
struct doq_conn** conn, struct ngtcp2_pkt_info* pi)
sbin/unwind/libunbound/util/netevent.c
2210
doq_done_setup_timer_and_write(struct comm_point* c, struct doq_conn* conn)
sbin/unwind/libunbound/util/netevent.c
2212
struct doq_conn copy;
sbin/unwind/libunbound/util/netevent.c
2251
conn = (struct doq_conn*)node->key;
sbin/unwind/libunbound/util/netevent.c
2276
doq_done_with_conn_cb(struct comm_point* c, struct doq_conn* conn)
sbin/unwind/libunbound/util/netevent.c
2278
struct doq_conn copy;
sbin/unwind/libunbound/util/netevent.c
2310
conn = (struct doq_conn*)node->key;
sbin/unwind/libunbound/util/netevent.c
2332
struct doq_conn* conn;
sbin/unwind/libunbound/util/netevent.c
2344
static struct doq_conn*
sbin/unwind/libunbound/util/netevent.c
2347
struct doq_conn* conn;
sbin/unwind/libunbound/util/netevent.c
2362
doq_done_with_write_cb(struct comm_point* c, struct doq_conn* conn,
sbin/unwind/libunbound/util/netevent.c
2433
static struct doq_conn*
sbin/unwind/libunbound/util/netevent.c
2436
struct doq_conn* conn = NULL;
sbin/unwind/libunbound/util/netevent.c
2479
struct doq_conn* conn;
sbin/unwind/libunbound/util/netevent.c
2525
struct doq_conn* conn;
sbin/unwind/libunbound/util/netevent.c
2802
static struct doq_conn*
sbin/unwind/libunbound/util/netevent.c
2805
struct doq_conn* conn;
sbin/unwind/libunbound/util/netevent.c
2825
struct doq_conn** conn, struct doq_stream** stream)
sbin/unwind/libunbound/util/netevent.c
2869
struct doq_conn* conn;
sbin/unwind/libunbound/util/netevent.c
2900
struct doq_conn* conn;
sbin/unwind/libunbound/util/netevent.h
1079
struct doq_conn* current_conn;
sbin/unwind/libunbound/util/netevent.h
80
struct doq_conn;
usr.sbin/unbound/services/listen_dnsport.c
3356
struct doq_conn* conn;
usr.sbin/unbound/services/listen_dnsport.c
3359
conn = (struct doq_conn*)node->key;
usr.sbin/unbound/services/listen_dnsport.c
3551
struct doq_conn*
usr.sbin/unbound/services/listen_dnsport.c
3555
struct doq_conn* conn = calloc(1, sizeof(*conn));
usr.sbin/unbound/services/listen_dnsport.c
3627
doq_conn_delete(struct doq_conn* conn, struct doq_table* table)
usr.sbin/unbound/services/listen_dnsport.c
3654
struct doq_conn* c = (struct doq_conn*)key1;
usr.sbin/unbound/services/listen_dnsport.c
3655
struct doq_conn* d = (struct doq_conn*)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
3874
doq_stream_find(struct doq_conn* conn, int64_t stream_id)
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
3945
doq_stream_close(struct doq_conn* conn, struct doq_stream* stream,
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
4047
doq_stream_data_complete(struct doq_conn* conn, struct doq_stream* stream)
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
4190
doq_conn_generate_new_conid(struct doq_conn* conn, uint8_t* data,
usr.sbin/unbound/services/listen_dnsport.c
4222
struct doq_conn* doq_conn = (struct doq_conn*)user_data;
usr.sbin/unbound/services/listen_dnsport.c
4226
lock_rw_wrlock(&doq_conn->table->conid_lock);
usr.sbin/unbound/services/listen_dnsport.c
4227
if(!doq_conn_generate_new_conid(doq_conn, cid->data, cidlen)) {
usr.sbin/unbound/services/listen_dnsport.c
4228
lock_rw_unlock(&doq_conn->table->conid_lock);
usr.sbin/unbound/services/listen_dnsport.c
4233
doq_conn->doq_socket->static_secret,
usr.sbin/unbound/services/listen_dnsport.c
4234
doq_conn->doq_socket->static_secret_len, cid) != 0) {
usr.sbin/unbound/services/listen_dnsport.c
4235
lock_rw_unlock(&doq_conn->table->conid_lock);
usr.sbin/unbound/services/listen_dnsport.c
4238
if(!doq_conn_associate_conid(doq_conn, cid->data, cid->datalen)) {
usr.sbin/unbound/services/listen_dnsport.c
4239
lock_rw_unlock(&doq_conn->table->conid_lock);
usr.sbin/unbound/services/listen_dnsport.c
4242
lock_rw_unlock(&doq_conn->table->conid_lock);
usr.sbin/unbound/services/listen_dnsport.c
4251
struct doq_conn* doq_conn = (struct doq_conn*)user_data;
usr.sbin/unbound/services/listen_dnsport.c
4252
lock_rw_wrlock(&doq_conn->table->conid_lock);
usr.sbin/unbound/services/listen_dnsport.c
4253
doq_conn_dissociate_conid(doq_conn, cid->data, cid->datalen);
usr.sbin/unbound/services/listen_dnsport.c
4254
lock_rw_unlock(&doq_conn->table->conid_lock);
usr.sbin/unbound/services/listen_dnsport.c
4260
doq_submit_new_token(struct doq_conn* conn)
usr.sbin/unbound/services/listen_dnsport.c
4291
struct doq_conn* doq_conn = (struct doq_conn*)user_data;
usr.sbin/unbound/services/listen_dnsport.c
4294
(int)ngtcp2_conn_get_max_data_left(doq_conn->conn));
usr.sbin/unbound/services/listen_dnsport.c
4297
(int)ngtcp2_conn_get_max_local_streams_uni(doq_conn->conn));
usr.sbin/unbound/services/listen_dnsport.c
4300
(int)ngtcp2_conn_get_streams_uni_left(doq_conn->conn));
usr.sbin/unbound/services/listen_dnsport.c
4302
(int)ngtcp2_conn_get_streams_bidi_left(doq_conn->conn));
usr.sbin/unbound/services/listen_dnsport.c
4304
SSL_get_cipher_name(doq_conn->ssl));
usr.sbin/unbound/services/listen_dnsport.c
4309
SSL_get0_alpn_selected(doq_conn->ssl, &alpn, &alpnlen);
usr.sbin/unbound/services/listen_dnsport.c
4317
if(!doq_submit_new_token(doq_conn))
usr.sbin/unbound/services/listen_dnsport.c
4327
struct doq_conn* doq_conn = (struct doq_conn*)user_data;
usr.sbin/unbound/services/listen_dnsport.c
4330
if(doq_stream_find(doq_conn, stream_id)) {
usr.sbin/unbound/services/listen_dnsport.c
4335
!doq_table_quic_size_available(doq_conn->doq_socket->table,
usr.sbin/unbound/services/listen_dnsport.c
4336
doq_conn->doq_socket->cfg, sizeof(*stream)
usr.sbin/unbound/services/listen_dnsport.c
4342
rv = ngtcp2_conn_shutdown_stream(doq_conn->conn,
usr.sbin/unbound/services/listen_dnsport.c
4359
doq_table_quic_size_add(doq_conn->doq_socket->table, sizeof(*stream));
usr.sbin/unbound/services/listen_dnsport.c
4360
doq_conn_add_stream(doq_conn, stream);
usr.sbin/unbound/services/listen_dnsport.c
4371
struct doq_conn* doq_conn = (struct doq_conn*)user_data;
usr.sbin/unbound/services/listen_dnsport.c
4382
stream = doq_stream_find(doq_conn, stream_id);
usr.sbin/unbound/services/listen_dnsport.c
4394
doq_conn->doq_socket->table))
usr.sbin/unbound/services/listen_dnsport.c
4398
if(!doq_stream_recv_fin(doq_conn, stream, recv_done))
usr.sbin/unbound/services/listen_dnsport.c
4401
ngtcp2_conn_extend_max_stream_offset(doq_conn->conn, stream_id,
usr.sbin/unbound/services/listen_dnsport.c
4403
ngtcp2_conn_extend_max_offset(doq_conn->conn, datalen);
usr.sbin/unbound/services/listen_dnsport.c
4405
if(!doq_stream_data_complete(doq_conn, stream))
usr.sbin/unbound/services/listen_dnsport.c
4417
struct doq_conn* doq_conn = (struct doq_conn*)user_data;
usr.sbin/unbound/services/listen_dnsport.c
4429
stream = doq_stream_find(doq_conn, stream_id);
usr.sbin/unbound/services/listen_dnsport.c
4435
if(!doq_stream_close(doq_conn, stream, 0))
usr.sbin/unbound/services/listen_dnsport.c
4446
struct doq_conn* doq_conn = (struct doq_conn*)user_data;
usr.sbin/unbound/services/listen_dnsport.c
4452
stream = doq_stream_find(doq_conn, stream_id);
usr.sbin/unbound/services/listen_dnsport.c
4458
if(!doq_stream_close(doq_conn, stream, 0))
usr.sbin/unbound/services/listen_dnsport.c
4469
struct doq_conn* doq_conn = (struct doq_conn*)user_data;
usr.sbin/unbound/services/listen_dnsport.c
4474
stream = doq_stream_find(doq_conn, stream_id);
usr.sbin/unbound/services/listen_dnsport.c
4485
doq_conn->doq_socket->table);
usr.sbin/unbound/services/listen_dnsport.c
4487
doq_conn->doq_socket->table);
usr.sbin/unbound/services/listen_dnsport.c
4507
doq_application_tx_key_cb(struct doq_conn* conn)
usr.sbin/unbound/services/listen_dnsport.c
4531
struct doq_conn* doq_conn = (struct doq_conn*)SSL_get_app_data(ssl);
usr.sbin/unbound/services/listen_dnsport.c
4548
if(ngtcp2_crypto_derive_and_install_rx_key(doq_conn->conn,
usr.sbin/unbound/services/listen_dnsport.c
4559
if(ngtcp2_crypto_derive_and_install_tx_key(doq_conn->conn,
usr.sbin/unbound/services/listen_dnsport.c
4567
if(!doq_application_tx_key_cb(doq_conn))
usr.sbin/unbound/services/listen_dnsport.c
4579
struct doq_conn* doq_conn = (struct doq_conn*)SSL_get_app_data(ssl);
usr.sbin/unbound/services/listen_dnsport.c
4597
rv = ngtcp2_conn_submit_crypto_data(doq_conn->conn, level, data, len);
usr.sbin/unbound/services/listen_dnsport.c
4601
ngtcp2_conn_set_tls_error(doq_conn->conn, rv);
usr.sbin/unbound/services/listen_dnsport.c
4619
struct doq_conn* doq_conn = (struct doq_conn*)SSL_get_app_data(ssl);
usr.sbin/unbound/services/listen_dnsport.c
4620
doq_conn->tls_alert = alert;
usr.sbin/unbound/services/listen_dnsport.c
4745
struct doq_conn* conn = (struct doq_conn*)conn_ref->user_data;
usr.sbin/unbound/services/listen_dnsport.c
4751
doq_ssl_server_setup(SSL_CTX* ctx, struct doq_conn* conn)
usr.sbin/unbound/services/listen_dnsport.c
4792
doq_conn_setup(struct doq_conn* conn, uint8_t* scid, size_t scidlen,
usr.sbin/unbound/services/listen_dnsport.c
4933
doq_conid_list_insert(struct doq_conn* conn, struct doq_conid* conid)
usr.sbin/unbound/services/listen_dnsport.c
4944
doq_conid_list_remove(struct doq_conn* conn, struct doq_conid* conid)
usr.sbin/unbound/services/listen_dnsport.c
4990
conid_is_for_conn(struct doq_conn* conn, struct doq_conid* conid)
usr.sbin/unbound/services/listen_dnsport.c
5006
doq_conn_associate_conid(struct doq_conn* conn, uint8_t* data, size_t datalen)
usr.sbin/unbound/services/listen_dnsport.c
5032
doq_conn_dissociate_conid(struct doq_conn* conn, const uint8_t* data,
usr.sbin/unbound/services/listen_dnsport.c
5050
doq_conn_setup_id_array_and_dcid(struct doq_conn* conn,
usr.sbin/unbound/services/listen_dnsport.c
5065
doq_conn_setup_conids(struct doq_conn* conn)
usr.sbin/unbound/services/listen_dnsport.c
5095
doq_conn_clear_conids(struct doq_conn* conn)
usr.sbin/unbound/services/listen_dnsport.c
5133
doq_conn_start_closing_period(struct comm_point* c, struct doq_conn* conn)
usr.sbin/unbound/services/listen_dnsport.c
5197
doq_conn_send_close(struct comm_point* c, struct doq_conn* conn)
usr.sbin/unbound/services/listen_dnsport.c
5217
doq_conn_close_error(struct comm_point* c, struct doq_conn* conn)
usr.sbin/unbound/services/listen_dnsport.c
5247
struct doq_conn* conn, struct ngtcp2_pkt_info* pi, int* err_retry,
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
5345
doq_conn_write_streams(struct comm_point* c, struct doq_conn* conn,
usr.sbin/unbound/services/listen_dnsport.c
5494
doq_conn_write_enable(struct doq_conn* conn)
usr.sbin/unbound/services/listen_dnsport.c
5500
doq_conn_write_disable(struct doq_conn* conn)
usr.sbin/unbound/services/listen_dnsport.c
5507
doq_conn_write_list_append(struct doq_table* table, struct doq_conn* conn)
usr.sbin/unbound/services/listen_dnsport.c
5521
doq_conn_write_list_remove(struct doq_table* table, struct doq_conn* conn)
usr.sbin/unbound/services/listen_dnsport.c
5537
doq_conn_set_write_list(struct doq_table* table, struct doq_conn* conn)
usr.sbin/unbound/services/listen_dnsport.c
5548
struct doq_conn*
usr.sbin/unbound/services/listen_dnsport.c
5551
struct doq_conn* conn = table->write_list_first;
usr.sbin/unbound/services/listen_dnsport.c
5566
doq_conn_check_timer(struct doq_conn* conn, struct timeval* tv)
usr.sbin/unbound/services/listen_dnsport.c
5599
doq_conn_log_line(struct doq_conn* conn, char* s)
usr.sbin/unbound/services/listen_dnsport.c
5610
doq_conn_handle_timeout(struct doq_conn* conn)
usr.sbin/unbound/services/listen_dnsport.h
508
struct doq_conn* write_list_first, *write_list_last;
usr.sbin/unbound/services/listen_dnsport.h
556
struct doq_conn* conn;
usr.sbin/unbound/services/listen_dnsport.h
637
struct doq_conn* write_prev, *write_next;
usr.sbin/unbound/services/listen_dnsport.h
709
struct doq_conn* doq_conn_create(struct comm_point* c,
usr.sbin/unbound/services/listen_dnsport.h
718
void doq_conn_delete(struct doq_conn* conn, struct doq_table* table);
usr.sbin/unbound/services/listen_dnsport.h
733
int doq_conn_setup(struct doq_conn* conn, uint8_t* scid, size_t scidlen,
usr.sbin/unbound/services/listen_dnsport.h
744
int doq_conn_associate_conid(struct doq_conn* conn, uint8_t* data,
usr.sbin/unbound/services/listen_dnsport.h
749
void doq_conn_dissociate_conid(struct doq_conn* conn, const uint8_t* data,
usr.sbin/unbound/services/listen_dnsport.h
753
int doq_conn_setup_conids(struct doq_conn* conn);
usr.sbin/unbound/services/listen_dnsport.h
757
void doq_conn_clear_conids(struct doq_conn* conn);
usr.sbin/unbound/services/listen_dnsport.h
766
struct doq_conn* conn, struct ngtcp2_pkt_info* pi, int* err_retry,
usr.sbin/unbound/services/listen_dnsport.h
770
int doq_conn_write_streams(struct comm_point* c, struct doq_conn* conn,
usr.sbin/unbound/services/listen_dnsport.h
774
int doq_conn_send_close(struct comm_point* c, struct doq_conn* conn);
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/services/listen_dnsport.h
796
void doq_conn_write_enable(struct doq_conn* conn);
usr.sbin/unbound/services/listen_dnsport.h
799
void doq_conn_write_disable(struct doq_conn* conn);
usr.sbin/unbound/services/listen_dnsport.h
802
void doq_conn_set_write_list(struct doq_table* table, struct doq_conn* conn);
usr.sbin/unbound/services/listen_dnsport.h
806
struct doq_conn* conn);
usr.sbin/unbound/services/listen_dnsport.h
810
struct doq_conn* doq_table_pop_first(struct doq_table* table);
usr.sbin/unbound/services/listen_dnsport.h
819
int doq_conn_check_timer(struct doq_conn* conn, struct timeval* tv);
usr.sbin/unbound/services/listen_dnsport.h
840
int doq_conn_handle_timeout(struct doq_conn* conn);
usr.sbin/unbound/testcode/unitdoq.c
62
size_t conn_size = sizeof(struct doq_conn);
usr.sbin/unbound/util/netevent.c
1639
static struct doq_conn*
usr.sbin/unbound/util/netevent.c
1646
struct doq_conn key;
usr.sbin/unbound/util/netevent.c
1658
return (struct doq_conn*)node->key;
usr.sbin/unbound/util/netevent.c
1663
static struct doq_conn*
usr.sbin/unbound/util/netevent.c
1672
struct doq_conn* conn;
usr.sbin/unbound/util/netevent.c
1707
static struct doq_conn*
usr.sbin/unbound/util/netevent.c
1711
struct doq_conn* conn;
usr.sbin/unbound/util/netevent.c
1737
struct doq_pkt_addr* paddr, struct doq_conn** conn)
usr.sbin/unbound/util/netevent.c
1958
doq_delete_connection(struct comm_point* c, struct doq_conn* conn)
usr.sbin/unbound/util/netevent.c
1960
struct doq_conn copy;
usr.sbin/unbound/util/netevent.c
1979
conn = (struct doq_conn*)node->key;
usr.sbin/unbound/util/netevent.c
2006
static struct doq_conn*
usr.sbin/unbound/util/netevent.c
2010
struct doq_conn* conn;
usr.sbin/unbound/util/netevent.c
2126
struct doq_conn** conn, struct ngtcp2_pkt_info* pi)
usr.sbin/unbound/util/netevent.c
2210
doq_done_setup_timer_and_write(struct comm_point* c, struct doq_conn* conn)
usr.sbin/unbound/util/netevent.c
2212
struct doq_conn copy;
usr.sbin/unbound/util/netevent.c
2251
conn = (struct doq_conn*)node->key;
usr.sbin/unbound/util/netevent.c
2276
doq_done_with_conn_cb(struct comm_point* c, struct doq_conn* conn)
usr.sbin/unbound/util/netevent.c
2278
struct doq_conn copy;
usr.sbin/unbound/util/netevent.c
2310
conn = (struct doq_conn*)node->key;
usr.sbin/unbound/util/netevent.c
2332
struct doq_conn* conn;
usr.sbin/unbound/util/netevent.c
2344
static struct doq_conn*
usr.sbin/unbound/util/netevent.c
2347
struct doq_conn* conn;
usr.sbin/unbound/util/netevent.c
2362
doq_done_with_write_cb(struct comm_point* c, struct doq_conn* conn,
usr.sbin/unbound/util/netevent.c
2433
static struct doq_conn*
usr.sbin/unbound/util/netevent.c
2436
struct doq_conn* conn = NULL;
usr.sbin/unbound/util/netevent.c
2479
struct doq_conn* conn;
usr.sbin/unbound/util/netevent.c
2525
struct doq_conn* conn;
usr.sbin/unbound/util/netevent.c
2802
static struct doq_conn*
usr.sbin/unbound/util/netevent.c
2805
struct doq_conn* conn;
usr.sbin/unbound/util/netevent.c
2825
struct doq_conn** conn, struct doq_stream** stream)
usr.sbin/unbound/util/netevent.c
2869
struct doq_conn* conn;
usr.sbin/unbound/util/netevent.c
2900
struct doq_conn* conn;
usr.sbin/unbound/util/netevent.h
1079
struct doq_conn* current_conn;
usr.sbin/unbound/util/netevent.h
80
struct doq_conn;