games/hunt/huntd/answer.c
123
FILE *conn;
games/hunt/huntd/answer.c
206
conn = fdopen(sp->fd, "w");
games/hunt/huntd/answer.c
216
fprintf(conn, "Too many monitors\n");
games/hunt/huntd/answer.c
217
fflush(conn);
games/hunt/huntd/answer.c
227
fprintf(conn, "Too many players\n");
games/hunt/huntd/answer.c
228
fflush(conn);
games/hunt/huntd/answer.c
238
pp->p_output = conn;
libexec/login_ldap/login_ldap.c
208
if (!conn(&ctx)) {
libexec/login_ldap/login_ldap.h
66
int conn(struct auth_ctx *);
sbin/isakmpd/connection.c
100
for (conn = TAILQ_FIRST(&conns->fields); conn;
sbin/isakmpd/connection.c
101
conn = TAILQ_NEXT(conn, link)) {
sbin/isakmpd/connection.c
102
if (connection_setup(conn->field))
sbin/isakmpd/connection.c
104
"\"%s\"", conn->field);
sbin/isakmpd/connection.c
113
attrs = conf_get_list(conn->field, "Flags");
sbin/isakmpd/connection.c
121
if (connection_record_passive(conn->field))
sbin/isakmpd/connection.c
124
conn->field);
sbin/isakmpd/connection.c
133
for (conn = TAILQ_FIRST(&conns->fields); conn;
sbin/isakmpd/connection.c
134
conn = TAILQ_NEXT(conn, link))
sbin/isakmpd/connection.c
135
if (connection_record_passive(conn->field))
sbin/isakmpd/connection.c
137
"passive connection \"%s\"", conn->field);
sbin/isakmpd/connection.c
147
struct connection *conn = vconn;
sbin/isakmpd/connection.c
153
conn->ev = timer_add_event("connection_checker",
sbin/isakmpd/connection.c
154
connection_checker, conn, &now);
sbin/isakmpd/connection.c
155
if (!conn->ev)
sbin/isakmpd/connection.c
160
name = strdup(conn->name);
sbin/isakmpd/connection.c
162
log_print("%s: strdup (\"%s\") failed", __func__, conn->name);
sbin/isakmpd/connection.c
172
struct connection *conn;
sbin/isakmpd/connection.c
174
for (conn = TAILQ_FIRST(&connections); conn;
sbin/isakmpd/connection.c
175
conn = TAILQ_NEXT(conn, link))
sbin/isakmpd/connection.c
176
if (strcasecmp(conn->name, name) == 0)
sbin/isakmpd/connection.c
177
return conn;
sbin/isakmpd/connection.c
192
struct connection_passive *conn;
sbin/isakmpd/connection.c
194
for (conn = TAILQ_FIRST(&connections_passive); conn;
sbin/isakmpd/connection.c
195
conn = TAILQ_NEXT(conn, link))
sbin/isakmpd/connection.c
196
if (strcasecmp(conn->name, name) == 0)
sbin/isakmpd/connection.c
197
return conn;
sbin/isakmpd/connection.c
221
struct connection_passive *conn;
sbin/isakmpd/connection.c
223
for (conn = TAILQ_FIRST(&connections_passive); conn;
sbin/isakmpd/connection.c
224
conn = TAILQ_NEXT(conn, link)) {
sbin/isakmpd/connection.c
225
if (!conn->remote_id)
sbin/isakmpd/connection.c
232
if ((compare_ids(id1, conn->local_id, conn->local_sz) == 0 &&
sbin/isakmpd/connection.c
233
compare_ids(id2, conn->remote_id, conn->remote_sz) == 0) ||
sbin/isakmpd/connection.c
234
(compare_ids(id1, conn->remote_id, conn->remote_sz) == 0 &&
sbin/isakmpd/connection.c
235
compare_ids(id2, conn->local_id, conn->local_sz) == 0)) {
sbin/isakmpd/connection.c
238
"returned \"%s\"", conn->name));
sbin/isakmpd/connection.c
239
return conn->name;
sbin/isakmpd/connection.c
247
for (conn = TAILQ_FIRST(&connections_passive); conn;
sbin/isakmpd/connection.c
248
conn = TAILQ_NEXT(conn, link)) {
sbin/isakmpd/connection.c
249
if (!conn->remote_id)
sbin/isakmpd/connection.c
252
if (compare_ids(id1, conn->local_id, conn->local_sz) == 0 ||
sbin/isakmpd/connection.c
253
compare_ids(id2, conn->local_id, conn->local_sz) == 0) {
sbin/isakmpd/connection.c
256
" only matched local id", conn->name));
sbin/isakmpd/connection.c
257
return conn->name;
sbin/isakmpd/connection.c
273
struct connection *conn = 0;
sbin/isakmpd/connection.c
282
conn = calloc(1, sizeof *conn);
sbin/isakmpd/connection.c
283
if (!conn) {
sbin/isakmpd/connection.c
285
(unsigned long)sizeof *conn);
sbin/isakmpd/connection.c
288
conn->name = strdup(name);
sbin/isakmpd/connection.c
289
if (!conn->name) {
sbin/isakmpd/connection.c
294
conn->ev = timer_add_event("connection_checker", connection_checker,
sbin/isakmpd/connection.c
295
conn, &now);
sbin/isakmpd/connection.c
296
if (!conn->ev) {
sbin/isakmpd/connection.c
300
TAILQ_INSERT_TAIL(&connections, conn, link);
sbin/isakmpd/connection.c
304
if (conn) {
sbin/isakmpd/connection.c
305
free(conn->name);
sbin/isakmpd/connection.c
306
free(conn);
sbin/isakmpd/connection.c
314
struct connection_passive *conn;
sbin/isakmpd/connection.c
332
conn = calloc(1, sizeof *conn);
sbin/isakmpd/connection.c
333
if (!conn) {
sbin/isakmpd/connection.c
335
(unsigned long)sizeof *conn);
sbin/isakmpd/connection.c
338
conn->name = strdup(name);
sbin/isakmpd/connection.c
339
if (!conn->name) {
sbin/isakmpd/connection.c
345
conn->local_id = ipsec_build_id(local_id, &conn->local_sz);
sbin/isakmpd/connection.c
346
if (!conn->local_id)
sbin/isakmpd/connection.c
350
conn->remote_id = ipsec_build_id(remote_id, &conn->remote_sz);
sbin/isakmpd/connection.c
351
if (!conn->remote_id)
sbin/isakmpd/connection.c
354
conn->remote_id = 0;
sbin/isakmpd/connection.c
356
TAILQ_INSERT_TAIL(&connections_passive, conn, link);
sbin/isakmpd/connection.c
360
conn->name));
sbin/isakmpd/connection.c
364
free(conn->local_id);
sbin/isakmpd/connection.c
365
free(conn->name);
sbin/isakmpd/connection.c
366
free(conn);
sbin/isakmpd/connection.c
374
struct connection *conn;
sbin/isakmpd/connection.c
376
conn = connection_lookup(name);
sbin/isakmpd/connection.c
377
if (!conn)
sbin/isakmpd/connection.c
380
TAILQ_REMOVE(&connections, conn, link);
sbin/isakmpd/connection.c
381
timer_remove_event(conn->ev);
sbin/isakmpd/connection.c
382
free(conn->name);
sbin/isakmpd/connection.c
383
free(conn);
sbin/isakmpd/connection.c
390
struct connection_passive *conn;
sbin/isakmpd/connection.c
392
conn = connection_passive_lookup_by_name(name);
sbin/isakmpd/connection.c
393
if (!conn)
sbin/isakmpd/connection.c
396
TAILQ_REMOVE(&connections_passive, conn, link);
sbin/isakmpd/connection.c
397
free(conn->name);
sbin/isakmpd/connection.c
398
free(conn->local_id);
sbin/isakmpd/connection.c
399
free(conn->remote_id);
sbin/isakmpd/connection.c
400
free(conn);
sbin/isakmpd/connection.c
406
struct connection *conn;
sbin/isakmpd/connection.c
412
for (conn = TAILQ_FIRST(&connections); conn;
sbin/isakmpd/connection.c
413
conn = TAILQ_NEXT(conn, link))
sbin/isakmpd/connection.c
416
(conn->name ? conn->name : "<unnamed>"),
sbin/isakmpd/connection.c
417
(long long)(conn->ev->expiration.tv_sec - now.tv_sec)));
sbin/isakmpd/connection.c
431
struct connection *conn, *next;
sbin/isakmpd/connection.c
438
for (conn = TAILQ_FIRST(&connections); conn; conn = next) {
sbin/isakmpd/connection.c
439
next = TAILQ_NEXT(conn, link);
sbin/isakmpd/connection.c
440
connection_teardown(conn->name);
sbin/isakmpd/connection.c
88
struct conf_list_node *conn, *attr = NULL;
sbin/isakmpd/pf_key_v2.c
1875
char conn[22];
sbin/isakmpd/pf_key_v2.c
1885
snprintf(conn, sizeof conn, "%d", num + 1);
sbin/isakmpd/pf_key_v2.c
1886
conf_set(af, section, "Refcount", conn, 1, 0);
sbin/isakmpd/pf_key_v2.c
1897
char conn[22];
sbin/isakmpd/pf_key_v2.c
1908
snprintf(conn, sizeof conn, "%d", num - 1);
sbin/isakmpd/pf_key_v2.c
1909
conf_set(af, section, "Refcount", conn, 1, 0);
sbin/isakmpd/pf_key_v2.c
2139
char *conn = vconn;
sbin/isakmpd/pf_key_v2.c
2143
sa = sa_lookup_by_name(conn, 2);
sbin/isakmpd/pf_key_v2.c
2152
pf_key_v2_remove_conf(conn);
sbin/isakmpd/pf_key_v2.c
2153
pf_key_v2_remove_conf(conn);
sbin/isakmpd/pf_key_v2.c
2155
free(conn);
sbin/isakmpd/pf_key_v2.c
2160
pf_key_v2_connection_check(char *conn)
sbin/isakmpd/pf_key_v2.c
2162
if (!sa_lookup_by_name(conn, 2)) {
sbin/isakmpd/pf_key_v2.c
2164
"pf_key_v2_connection_check: SA for %s missing", conn));
sbin/isakmpd/pf_key_v2.c
2165
exchange_establish(conn, pf_key_v2_stayalive, conn, 0);
sbin/isakmpd/pf_key_v2.c
2168
"SA for %s exists", conn));
sbin/isakmpd/pf_key_v2.c
2169
free(conn);
sbin/isakmpd/pf_key_v2.c
2342
char confname[120], *conn = 0;
sbin/isakmpd/pf_key_v2.c
2362
conn = malloc(connlen);
sbin/isakmpd/pf_key_v2.c
2363
if (!conn) {
sbin/isakmpd/pf_key_v2.c
2373
free(conn);
sbin/isakmpd/pf_key_v2.c
2909
snprintf(conn, connlen, "Connection-%u", connection_seq);
sbin/isakmpd/pf_key_v2.c
2912
if (!conf_get_str(conn, "Phase"))
sbin/isakmpd/pf_key_v2.c
2950
if (conf_set(af, conn, "Phase", "2", 0, 0) ||
sbin/isakmpd/pf_key_v2.c
2951
conf_set(af, conn, "Flags", "__ondemand", 0, 0) ||
sbin/isakmpd/pf_key_v2.c
2952
conf_set(af, conn, "Refcount", "2", 0, 0) ||
sbin/isakmpd/pf_key_v2.c
2953
conf_set(af, conn, "ISAKMP-peer", peer, 0, 0)) {
sbin/isakmpd/pf_key_v2.c
2959
if (conf_set(af, conn, "Acquire-ID", lname, 0, 0)) {
sbin/isakmpd/pf_key_v2.c
2973
if (conf_set(af, conn, "Local-ID", lname, 0, 0)) {
sbin/isakmpd/pf_key_v2.c
3024
if (conf_set(af, conn, "Remote-ID", dname, 0, 0)) {
sbin/isakmpd/pf_key_v2.c
3079
if (conf_set(af, conn, "Configuration", configname, 0, 0)) {
sbin/isakmpd/pf_key_v2.c
3164
connection_record_passive(conn);
sbin/isakmpd/pf_key_v2.c
3165
pf_key_v2_connection_check(conn);
sbin/isakmpd/pf_key_v2.c
3166
conn = 0;
sbin/isakmpd/pf_key_v2.c
3177
free(conn);
sbin/pfctl/pfctl_parser.c
694
sn->conn, sn->conn_rate.count / 1000,
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
3360
if(conn->timer.timer_in_list) {
sbin/unwind/libunbound/services/listen_dnsport.c
3364
doq_timer_list_remove(conn->table, &conn->timer);
sbin/unwind/libunbound/services/listen_dnsport.c
3366
if(conn->timer.timer_in_tree)
sbin/unwind/libunbound/services/listen_dnsport.c
3367
doq_timer_tree_remove(conn->table, &conn->timer);
sbin/unwind/libunbound/services/listen_dnsport.c
3368
doq_table_quic_size_subtract(table, sizeof(*conn)+conn->key.dcidlen);
sbin/unwind/libunbound/services/listen_dnsport.c
3369
doq_conn_delete(conn, table);
sbin/unwind/libunbound/services/listen_dnsport.c
3515
if(verbosity >= VERB_ALGO && timer->conn) {
sbin/unwind/libunbound/services/listen_dnsport.c
3518
addr_to_str((void*)&timer->conn->key.paddr.addr,
sbin/unwind/libunbound/services/listen_dnsport.c
3519
timer->conn->key.paddr.addrlen, a, sizeof(a));
sbin/unwind/libunbound/services/listen_dnsport.c
3555
struct doq_conn* conn = calloc(1, sizeof(*conn));
sbin/unwind/libunbound/services/listen_dnsport.c
3556
if(!conn)
sbin/unwind/libunbound/services/listen_dnsport.c
3558
conn->node.key = conn;
sbin/unwind/libunbound/services/listen_dnsport.c
3559
conn->doq_socket = c->doq_socket;
sbin/unwind/libunbound/services/listen_dnsport.c
3560
conn->table = c->doq_socket->table;
sbin/unwind/libunbound/services/listen_dnsport.c
3561
memmove(&conn->key.paddr.addr, &paddr->addr, paddr->addrlen);
sbin/unwind/libunbound/services/listen_dnsport.c
3562
conn->key.paddr.addrlen = paddr->addrlen;
sbin/unwind/libunbound/services/listen_dnsport.c
3563
memmove(&conn->key.paddr.localaddr, &paddr->localaddr,
sbin/unwind/libunbound/services/listen_dnsport.c
3565
conn->key.paddr.localaddrlen = paddr->localaddrlen;
sbin/unwind/libunbound/services/listen_dnsport.c
3566
conn->key.paddr.ifindex = paddr->ifindex;
sbin/unwind/libunbound/services/listen_dnsport.c
3567
conn->key.dcid = memdup((void*)dcid, dcidlen);
sbin/unwind/libunbound/services/listen_dnsport.c
3568
if(!conn->key.dcid) {
sbin/unwind/libunbound/services/listen_dnsport.c
3569
free(conn);
sbin/unwind/libunbound/services/listen_dnsport.c
3572
conn->key.dcidlen = dcidlen;
sbin/unwind/libunbound/services/listen_dnsport.c
3573
conn->version = version;
sbin/unwind/libunbound/services/listen_dnsport.c
3575
ngtcp2_ccerr_default(&conn->ccerr);
sbin/unwind/libunbound/services/listen_dnsport.c
3577
ngtcp2_connection_close_error_default(&conn->last_error);
sbin/unwind/libunbound/services/listen_dnsport.c
3579
rbtree_init(&conn->stream_tree, &doq_stream_cmp);
sbin/unwind/libunbound/services/listen_dnsport.c
3580
conn->timer.conn = conn;
sbin/unwind/libunbound/services/listen_dnsport.c
3581
lock_basic_init(&conn->lock);
sbin/unwind/libunbound/services/listen_dnsport.c
3582
lock_protect(&conn->lock, &conn->key, sizeof(conn->key));
sbin/unwind/libunbound/services/listen_dnsport.c
3583
lock_protect(&conn->lock, &conn->doq_socket, sizeof(conn->doq_socket));
sbin/unwind/libunbound/services/listen_dnsport.c
3584
lock_protect(&conn->lock, &conn->table, sizeof(conn->table));
sbin/unwind/libunbound/services/listen_dnsport.c
3585
lock_protect(&conn->lock, &conn->is_deleted, sizeof(conn->is_deleted));
sbin/unwind/libunbound/services/listen_dnsport.c
3586
lock_protect(&conn->lock, &conn->version, sizeof(conn->version));
sbin/unwind/libunbound/services/listen_dnsport.c
3587
lock_protect(&conn->lock, &conn->conn, sizeof(conn->conn));
sbin/unwind/libunbound/services/listen_dnsport.c
3588
lock_protect(&conn->lock, &conn->conid_list, sizeof(conn->conid_list));
sbin/unwind/libunbound/services/listen_dnsport.c
3590
lock_protect(&conn->lock, &conn->ccerr, sizeof(conn->ccerr));
sbin/unwind/libunbound/services/listen_dnsport.c
3592
lock_protect(&conn->lock, &conn->last_error, sizeof(conn->last_error));
sbin/unwind/libunbound/services/listen_dnsport.c
3594
lock_protect(&conn->lock, &conn->tls_alert, sizeof(conn->tls_alert));
sbin/unwind/libunbound/services/listen_dnsport.c
3595
lock_protect(&conn->lock, &conn->ssl, sizeof(conn->ssl));
sbin/unwind/libunbound/services/listen_dnsport.c
3596
lock_protect(&conn->lock, &conn->close_pkt, sizeof(conn->close_pkt));
sbin/unwind/libunbound/services/listen_dnsport.c
3597
lock_protect(&conn->lock, &conn->close_pkt_len, sizeof(conn->close_pkt_len));
sbin/unwind/libunbound/services/listen_dnsport.c
3598
lock_protect(&conn->lock, &conn->close_ecn, sizeof(conn->close_ecn));
sbin/unwind/libunbound/services/listen_dnsport.c
3599
lock_protect(&conn->lock, &conn->stream_tree, sizeof(conn->stream_tree));
sbin/unwind/libunbound/services/listen_dnsport.c
3600
lock_protect(&conn->lock, &conn->stream_write_first, sizeof(conn->stream_write_first));
sbin/unwind/libunbound/services/listen_dnsport.c
3601
lock_protect(&conn->lock, &conn->stream_write_last, sizeof(conn->stream_write_last));
sbin/unwind/libunbound/services/listen_dnsport.c
3602
lock_protect(&conn->lock, &conn->write_interest, sizeof(conn->write_interest));
sbin/unwind/libunbound/services/listen_dnsport.c
3603
lock_protect(&conn->lock, &conn->on_write_list, sizeof(conn->on_write_list));
sbin/unwind/libunbound/services/listen_dnsport.c
3604
lock_protect(&conn->lock, &conn->write_prev, sizeof(conn->write_prev));
sbin/unwind/libunbound/services/listen_dnsport.c
3605
lock_protect(&conn->lock, &conn->write_next, sizeof(conn->write_next));
sbin/unwind/libunbound/services/listen_dnsport.c
3606
return 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
3629
if(!conn)
sbin/unwind/libunbound/services/listen_dnsport.c
3631
lock_basic_destroy(&conn->lock);
sbin/unwind/libunbound/services/listen_dnsport.c
3632
lock_rw_wrlock(&conn->table->conid_lock);
sbin/unwind/libunbound/services/listen_dnsport.c
3633
doq_conn_clear_conids(conn);
sbin/unwind/libunbound/services/listen_dnsport.c
3634
lock_rw_unlock(&conn->table->conid_lock);
sbin/unwind/libunbound/services/listen_dnsport.c
3637
SSL_set_app_data(conn->ssl, NULL);
sbin/unwind/libunbound/services/listen_dnsport.c
3638
if(conn->stream_tree.count != 0) {
sbin/unwind/libunbound/services/listen_dnsport.c
3639
traverse_postorder(&conn->stream_tree, stream_tree_del, table);
sbin/unwind/libunbound/services/listen_dnsport.c
3641
free(conn->key.dcid);
sbin/unwind/libunbound/services/listen_dnsport.c
3642
SSL_free(conn->ssl);
sbin/unwind/libunbound/services/listen_dnsport.c
3644
ngtcp2_crypto_ossl_ctx_del(conn->ossl_ctx);
sbin/unwind/libunbound/services/listen_dnsport.c
3646
ngtcp2_conn_del(conn->conn);
sbin/unwind/libunbound/services/listen_dnsport.c
3647
free(conn->close_pkt);
sbin/unwind/libunbound/services/listen_dnsport.c
3648
free(conn);
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
3842
(void)rbtree_insert(&conn->stream_tree, &stream->node);
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
3849
(void)rbtree_delete(&conn->stream_tree, &stream->node);
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
3880
node = rbtree_search(&conn->stream_tree, &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
3892
stream->write_prev = conn->stream_write_last;
sbin/unwind/libunbound/services/listen_dnsport.c
3893
if(conn->stream_write_last)
sbin/unwind/libunbound/services/listen_dnsport.c
3894
conn->stream_write_last->write_next = stream;
sbin/unwind/libunbound/services/listen_dnsport.c
3896
conn->stream_write_first = stream;
sbin/unwind/libunbound/services/listen_dnsport.c
3897
conn->stream_write_last = 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
3910
else conn->stream_write_last = stream->write_prev;
sbin/unwind/libunbound/services/listen_dnsport.c
3913
else conn->stream_write_first = stream->write_next;
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
3952
doq_stream_off_write_list(conn, stream);
sbin/unwind/libunbound/services/listen_dnsport.c
3956
ret = ngtcp2_conn_shutdown_stream(conn->conn,
sbin/unwind/libunbound/services/listen_dnsport.c
3966
doq_conn_write_enable(conn);
sbin/unwind/libunbound/services/listen_dnsport.c
3969
ngtcp2_conn_extend_max_streams_bidi(conn->conn, 1);
sbin/unwind/libunbound/services/listen_dnsport.c
3970
doq_conn_write_enable(conn);
sbin/unwind/libunbound/services/listen_dnsport.c
3971
doq_stream_remove_in_buffer(stream, conn->doq_socket->table);
sbin/unwind/libunbound/services/listen_dnsport.c
3972
doq_stream_remove_out_buffer(stream, conn->doq_socket->table);
sbin/unwind/libunbound/services/listen_dnsport.c
3973
doq_table_quic_size_subtract(conn->doq_socket->table, sizeof(*stream));
sbin/unwind/libunbound/services/listen_dnsport.c
3974
doq_conn_del_stream(conn, 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
4015
doq_table_quic_size_subtract(conn->doq_socket->table,
sbin/unwind/libunbound/services/listen_dnsport.c
4019
doq_table_quic_size_add(conn->doq_socket->table, stream->outlen);
sbin/unwind/libunbound/services/listen_dnsport.c
4020
doq_stream_on_write_list(conn, stream);
sbin/unwind/libunbound/services/listen_dnsport.c
4021
doq_conn_write_enable(conn);
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
4053
addr_to_str((void*)&conn->key.paddr.addr,
sbin/unwind/libunbound/services/listen_dnsport.c
4054
conn->key.paddr.addrlen, a, sizeof(a));
sbin/unwind/libunbound/services/listen_dnsport.c
4060
c = conn->doq_socket->cp;
sbin/unwind/libunbound/services/listen_dnsport.c
4073
if(!doq_conn_key_store_repinfo(&conn->key, &c->repinfo)) {
sbin/unwind/libunbound/services/listen_dnsport.c
4079
conn->doq_socket->current_conn = conn;
sbin/unwind/libunbound/services/listen_dnsport.c
4082
conn->doq_socket->current_conn = NULL;
sbin/unwind/libunbound/services/listen_dnsport.c
4083
if(!doq_stream_send_reply(conn, stream, c->buffer)) {
sbin/unwind/libunbound/services/listen_dnsport.c
4089
conn->doq_socket->current_conn = NULL;
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
4174
if(!doq_stream_close(conn, stream, 1))
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
4196
doq_fill_rand(conn->doq_socket->rnd, data, datalen);
sbin/unwind/libunbound/services/listen_dnsport.c
4197
if(!doq_conid_find(conn->table, data, datalen)) {
sbin/unwind/libunbound/services/listen_dnsport.c
4219
doq_get_new_connection_id_cb(ngtcp2_conn* ATTR_UNUSED(conn), ngtcp2_cid* cid,
sbin/unwind/libunbound/services/listen_dnsport.c
4248
doq_remove_connection_id_cb(ngtcp2_conn* ATTR_UNUSED(conn),
sbin/unwind/libunbound/services/listen_dnsport.c
4260
doq_submit_new_token(struct doq_conn* conn)
sbin/unwind/libunbound/services/listen_dnsport.c
4265
const ngtcp2_path* path = ngtcp2_conn_get_path(conn->conn);
sbin/unwind/libunbound/services/listen_dnsport.c
4269
conn->doq_socket->static_secret,
sbin/unwind/libunbound/services/listen_dnsport.c
4270
conn->doq_socket->static_secret_len, path->remote.addr,
sbin/unwind/libunbound/services/listen_dnsport.c
4278
ret = ngtcp2_conn_submit_new_token(conn->conn, token, tokenlen);
sbin/unwind/libunbound/services/listen_dnsport.c
4289
doq_handshake_completed_cb(ngtcp2_conn* ATTR_UNUSED(conn), void* 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
4324
doq_stream_open_cb(ngtcp2_conn* ATTR_UNUSED(conn), int64_t stream_id,
sbin/unwind/libunbound/services/listen_dnsport.c
4342
rv = ngtcp2_conn_shutdown_stream(doq_conn->conn,
sbin/unwind/libunbound/services/listen_dnsport.c
4366
doq_recv_stream_data_cb(ngtcp2_conn* ATTR_UNUSED(conn), uint32_t flags,
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
4413
doq_stream_close_cb(ngtcp2_conn* ATTR_UNUSED(conn), uint32_t flags,
sbin/unwind/libunbound/services/listen_dnsport.c
4442
doq_stream_reset_cb(ngtcp2_conn* ATTR_UNUSED(conn), int64_t stream_id,
sbin/unwind/libunbound/services/listen_dnsport.c
4465
doq_acked_stream_data_offset_cb(ngtcp2_conn* ATTR_UNUSED(conn),
sbin/unwind/libunbound/services/listen_dnsport.c
4507
doq_application_tx_key_cb(struct doq_conn* conn)
sbin/unwind/libunbound/services/listen_dnsport.c
4513
(int)ngtcp2_conn_get_max_data_left(conn->conn));
sbin/unwind/libunbound/services/listen_dnsport.c
4516
(int)ngtcp2_conn_get_max_local_streams_uni(conn->conn));
sbin/unwind/libunbound/services/listen_dnsport.c
4519
(int)ngtcp2_conn_get_streams_uni_left(conn->conn));
sbin/unwind/libunbound/services/listen_dnsport.c
4521
(int)ngtcp2_conn_get_streams_bidi_left(conn->conn));
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
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
4745
struct doq_conn* conn = (struct doq_conn*)conn_ref->user_data;
sbin/unwind/libunbound/services/listen_dnsport.c
4746
return conn->conn;
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
4762
if((ret=ngtcp2_crypto_ossl_ctx_new(&conn->ossl_ctx, NULL)) != 0) {
sbin/unwind/libunbound/services/listen_dnsport.c
4768
ngtcp2_crypto_ossl_ctx_set_ssl(conn->ossl_ctx, ssl);
sbin/unwind/libunbound/services/listen_dnsport.c
4776
conn->conn_ref.get_conn = &doq_conn_ref_get_conn;
sbin/unwind/libunbound/services/listen_dnsport.c
4777
conn->conn_ref.user_data = conn;
sbin/unwind/libunbound/services/listen_dnsport.c
4778
SSL_set_app_data(ssl, &conn->conn_ref);
sbin/unwind/libunbound/services/listen_dnsport.c
4780
SSL_set_app_data(ssl, 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
4810
ngtcp2_cid_init(&dcid, conn->key.dcid, conn->key.dcidlen);
sbin/unwind/libunbound/services/listen_dnsport.c
4812
path.remote.addr = (struct sockaddr*)&conn->key.paddr.addr;
sbin/unwind/libunbound/services/listen_dnsport.c
4813
path.remote.addrlen = conn->key.paddr.addrlen;
sbin/unwind/libunbound/services/listen_dnsport.c
4814
path.local.addr = (struct sockaddr*)&conn->key.paddr.localaddr;
sbin/unwind/libunbound/services/listen_dnsport.c
4815
path.local.addrlen = conn->key.paddr.localaddrlen;
sbin/unwind/libunbound/services/listen_dnsport.c
4844
settings.rand_ctx.native_handle = conn->doq_socket->rnd;
sbin/unwind/libunbound/services/listen_dnsport.c
4857
params.max_idle_timeout = conn->doq_socket->idle_timeout;
sbin/unwind/libunbound/services/listen_dnsport.c
4869
ngtcp2_cid_init(¶ms.retry_scid, conn->key.dcid,
sbin/unwind/libunbound/services/listen_dnsport.c
4870
conn->key.dcidlen);
sbin/unwind/libunbound/services/listen_dnsport.c
4873
ngtcp2_cid_init(¶ms.original_dcid, conn->key.dcid,
sbin/unwind/libunbound/services/listen_dnsport.c
4874
conn->key.dcidlen);
sbin/unwind/libunbound/services/listen_dnsport.c
4879
doq_fill_rand(conn->doq_socket->rnd, params.stateless_reset_token,
sbin/unwind/libunbound/services/listen_dnsport.c
4881
sv_scid.datalen = conn->doq_socket->sv_scidlen;
sbin/unwind/libunbound/services/listen_dnsport.c
4882
lock_rw_wrlock(&conn->table->conid_lock);
sbin/unwind/libunbound/services/listen_dnsport.c
4883
if(!doq_conn_generate_new_conid(conn, sv_scid.data, sv_scid.datalen)) {
sbin/unwind/libunbound/services/listen_dnsport.c
4884
lock_rw_unlock(&conn->table->conid_lock);
sbin/unwind/libunbound/services/listen_dnsport.c
4888
rv = ngtcp2_conn_server_new(&conn->conn, &scid_cid, &sv_scid, &path,
sbin/unwind/libunbound/services/listen_dnsport.c
4889
conn->version, &callbacks, &settings, ¶ms, NULL, conn);
sbin/unwind/libunbound/services/listen_dnsport.c
4891
lock_rw_unlock(&conn->table->conid_lock);
sbin/unwind/libunbound/services/listen_dnsport.c
4896
if(!doq_conn_setup_conids(conn)) {
sbin/unwind/libunbound/services/listen_dnsport.c
4897
lock_rw_unlock(&conn->table->conid_lock);
sbin/unwind/libunbound/services/listen_dnsport.c
4901
lock_rw_unlock(&conn->table->conid_lock);
sbin/unwind/libunbound/services/listen_dnsport.c
4902
conn->ssl = doq_ssl_server_setup((SSL_CTX*)conn->doq_socket->ctx,
sbin/unwind/libunbound/services/listen_dnsport.c
4903
conn);
sbin/unwind/libunbound/services/listen_dnsport.c
4904
if(!conn->ssl) {
sbin/unwind/libunbound/services/listen_dnsport.c
4909
ngtcp2_conn_set_tls_native_handle(conn->conn, conn->ossl_ctx);
sbin/unwind/libunbound/services/listen_dnsport.c
4911
ngtcp2_conn_set_tls_native_handle(conn->conn, conn->ssl);
sbin/unwind/libunbound/services/listen_dnsport.c
4913
doq_conn_write_enable(conn);
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
4936
conid->next = conn->conid_list;
sbin/unwind/libunbound/services/listen_dnsport.c
4937
if(conn->conid_list)
sbin/unwind/libunbound/services/listen_dnsport.c
4938
conn->conid_list->prev = conid;
sbin/unwind/libunbound/services/listen_dnsport.c
4939
conn->conid_list = 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
4948
else conn->conid_list = conid->next;
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
4992
if(conid->key.dcidlen == conn->key.dcidlen &&
sbin/unwind/libunbound/services/listen_dnsport.c
4993
memcmp(conid->key.dcid, conn->key.dcid, conid->key.dcidlen)==0
sbin/unwind/libunbound/services/listen_dnsport.c
4994
&& conid->key.paddr.addrlen == conn->key.paddr.addrlen &&
sbin/unwind/libunbound/services/listen_dnsport.c
4995
memcmp(&conid->key.paddr.addr, &conn->key.paddr.addr,
sbin/unwind/libunbound/services/listen_dnsport.c
4997
conid->key.paddr.localaddrlen == conn->key.paddr.localaddrlen &&
sbin/unwind/libunbound/services/listen_dnsport.c
4998
memcmp(&conid->key.paddr.localaddr, &conn->key.paddr.localaddr,
sbin/unwind/libunbound/services/listen_dnsport.c
5000
conid->key.paddr.ifindex == conn->key.paddr.ifindex)
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
5009
conid = doq_conid_find(conn->table, data, datalen);
sbin/unwind/libunbound/services/listen_dnsport.c
5010
if(conid && !conid_is_for_conn(conn, conid)) {
sbin/unwind/libunbound/services/listen_dnsport.c
5023
conid = doq_conid_create(data, datalen, &conn->key);
sbin/unwind/libunbound/services/listen_dnsport.c
5026
doq_conid_list_insert(conn, conid);
sbin/unwind/libunbound/services/listen_dnsport.c
5027
(void)rbtree_insert(conn->table->conid_tree, &conid->node);
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
5036
conid = doq_conid_find(conn->table, data, datalen);
sbin/unwind/libunbound/services/listen_dnsport.c
5037
if(conid && !conid_is_for_conn(conn, conid))
sbin/unwind/libunbound/services/listen_dnsport.c
5040
(void)rbtree_delete(conn->table->conid_tree,
sbin/unwind/libunbound/services/listen_dnsport.c
5042
doq_conid_list_remove(conn, conid);
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
5055
if(!doq_conn_associate_conid(conn, scids[i].data,
sbin/unwind/libunbound/services/listen_dnsport.c
5059
if(!doq_conn_associate_conid(conn, conn->key.dcid, conn->key.dcidlen))
sbin/unwind/libunbound/services/listen_dnsport.c
5065
doq_conn_setup_conids(struct doq_conn* conn)
sbin/unwind/libunbound/services/listen_dnsport.c
5069
ngtcp2_conn_get_scid(conn->conn, NULL);
sbin/unwind/libunbound/services/listen_dnsport.c
5071
ngtcp2_conn_get_num_scid(conn->conn);
sbin/unwind/libunbound/services/listen_dnsport.c
5077
ngtcp2_conn_get_scid(conn->conn, ids);
sbin/unwind/libunbound/services/listen_dnsport.c
5078
return doq_conn_setup_id_array_and_dcid(conn, ids, num_scid);
sbin/unwind/libunbound/services/listen_dnsport.c
5084
ngtcp2_conn_get_scid(conn->conn, scids);
sbin/unwind/libunbound/services/listen_dnsport.c
5085
if(!doq_conn_setup_id_array_and_dcid(conn, scids, num_scid)) {
sbin/unwind/libunbound/services/listen_dnsport.c
5095
doq_conn_clear_conids(struct doq_conn* conn)
sbin/unwind/libunbound/services/listen_dnsport.c
5098
if(!conn)
sbin/unwind/libunbound/services/listen_dnsport.c
5100
p = conn->conid_list;
sbin/unwind/libunbound/services/listen_dnsport.c
5103
(void)rbtree_delete(conn->table->conid_tree, p->node.key);
sbin/unwind/libunbound/services/listen_dnsport.c
5107
conn->conid_list = NULL;
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
5138
if(!conn)
sbin/unwind/libunbound/services/listen_dnsport.c
5142
ngtcp2_conn_in_closing_period(conn->conn)
sbin/unwind/libunbound/services/listen_dnsport.c
5144
ngtcp2_conn_is_in_closing_period(conn->conn)
sbin/unwind/libunbound/services/listen_dnsport.c
5150
ngtcp2_conn_in_draining_period(conn->conn)
sbin/unwind/libunbound/services/listen_dnsport.c
5152
ngtcp2_conn_is_in_draining_period(conn->conn)
sbin/unwind/libunbound/services/listen_dnsport.c
5155
doq_conn_write_disable(conn);
sbin/unwind/libunbound/services/listen_dnsport.c
5162
ret = ngtcp2_conn_write_connection_close(conn->conn, &ps.path,
sbin/unwind/libunbound/services/listen_dnsport.c
5166
&conn->ccerr
sbin/unwind/libunbound/services/listen_dnsport.c
5168
&conn->last_error
sbin/unwind/libunbound/services/listen_dnsport.c
5184
conn->close_pkt = memdup(sldns_buffer_begin(c->doq_socket->pkt_buf),
sbin/unwind/libunbound/services/listen_dnsport.c
5186
if(!conn->close_pkt) {
sbin/unwind/libunbound/services/listen_dnsport.c
5190
conn->close_pkt_len = sldns_buffer_limit(c->doq_socket->pkt_buf);
sbin/unwind/libunbound/services/listen_dnsport.c
5191
conn->close_ecn = pi.ecn;
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
5199
if(!conn)
sbin/unwind/libunbound/services/listen_dnsport.c
5201
if(!conn->close_pkt)
sbin/unwind/libunbound/services/listen_dnsport.c
5203
if(conn->close_pkt_len > sldns_buffer_capacity(c->doq_socket->pkt_buf))
sbin/unwind/libunbound/services/listen_dnsport.c
5206
sldns_buffer_write(c->doq_socket->pkt_buf, conn->close_pkt, conn->close_pkt_len);
sbin/unwind/libunbound/services/listen_dnsport.c
5209
doq_send_pkt(c, &conn->key.paddr, conn->close_ecn);
sbin/unwind/libunbound/services/listen_dnsport.c
5210
doq_conn_write_disable(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
5220
if(conn->ccerr.type == NGTCP2_CCERR_TYPE_IDLE_CLOSE)
sbin/unwind/libunbound/services/listen_dnsport.c
5223
if(conn->last_error.type ==
sbin/unwind/libunbound/services/listen_dnsport.c
5227
if(!doq_conn_start_closing_period(c, conn))
sbin/unwind/libunbound/services/listen_dnsport.c
5231
ngtcp2_conn_in_draining_period(conn->conn)
sbin/unwind/libunbound/services/listen_dnsport.c
5233
ngtcp2_conn_is_in_draining_period(conn->conn)
sbin/unwind/libunbound/services/listen_dnsport.c
5236
doq_conn_write_disable(conn);
sbin/unwind/libunbound/services/listen_dnsport.c
5239
doq_conn_write_enable(conn);
sbin/unwind/libunbound/services/listen_dnsport.c
5240
if(!doq_conn_send_close(c, 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
5260
ret = ngtcp2_conn_read_pkt(conn->conn, &path, pi,
sbin/unwind/libunbound/services/listen_dnsport.c
5271
doq_conn_write_disable(conn);
sbin/unwind/libunbound/services/listen_dnsport.c
5290
!conn->ccerr.error_code
sbin/unwind/libunbound/services/listen_dnsport.c
5292
!conn->last_error.error_code
sbin/unwind/libunbound/services/listen_dnsport.c
5299
ngtcp2_ccerr_set_tls_alert(&conn->ccerr,
sbin/unwind/libunbound/services/listen_dnsport.c
5300
conn->tls_alert, NULL, 0);
sbin/unwind/libunbound/services/listen_dnsport.c
5303
&conn->last_error, conn->tls_alert,
sbin/unwind/libunbound/services/listen_dnsport.c
5310
!conn->ccerr.error_code
sbin/unwind/libunbound/services/listen_dnsport.c
5312
!conn->last_error.error_code
sbin/unwind/libunbound/services/listen_dnsport.c
5316
ngtcp2_ccerr_set_liberr(&conn->ccerr, ret,
sbin/unwind/libunbound/services/listen_dnsport.c
5320
&conn->last_error, ret, NULL, 0);
sbin/unwind/libunbound/services/listen_dnsport.c
5326
if(!doq_conn_close_error(c, conn)) {
sbin/unwind/libunbound/services/listen_dnsport.c
5332
doq_conn_write_enable(conn);
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
5341
doq_stream_off_write_list(conn, 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
5348
struct doq_stream* stream = conn->stream_write_first;
sbin/unwind/libunbound/services/listen_dnsport.c
5400
ret = ngtcp2_conn_writev_stream(conn->conn, &ps.path, &pi,
sbin/unwind/libunbound/services/listen_dnsport.c
5412
conn, stream);
sbin/unwind/libunbound/services/listen_dnsport.c
5420
&conn->ccerr, -1, NULL, 0);
sbin/unwind/libunbound/services/listen_dnsport.c
5422
ngtcp2_connection_close_error_set_application_error(&conn->last_error, -1, NULL, 0);
sbin/unwind/libunbound/services/listen_dnsport.c
5426
if(!doq_conn_close_error(c, conn)) {
sbin/unwind/libunbound/services/listen_dnsport.c
5435
&conn->ccerr, -1, NULL, 0);
sbin/unwind/libunbound/services/listen_dnsport.c
5437
ngtcp2_connection_close_error_set_application_error(&conn->last_error, -1, NULL, 0);
sbin/unwind/libunbound/services/listen_dnsport.c
5441
if(!doq_conn_close_error(c, conn)) {
sbin/unwind/libunbound/services/listen_dnsport.c
5451
ngtcp2_ccerr_set_liberr(&conn->ccerr, ret, NULL, 0);
sbin/unwind/libunbound/services/listen_dnsport.c
5454
&conn->last_error, ret, NULL, 0);
sbin/unwind/libunbound/services/listen_dnsport.c
5458
if(!doq_conn_close_error(c, conn)) {
sbin/unwind/libunbound/services/listen_dnsport.c
5470
doq_stream_write_is_done(conn, stream);
sbin/unwind/libunbound/services/listen_dnsport.c
5474
doq_conn_write_disable(conn);
sbin/unwind/libunbound/services/listen_dnsport.c
5475
ngtcp2_conn_update_pkt_tx_time(conn->conn, ts);
sbin/unwind/libunbound/services/listen_dnsport.c
5480
doq_send_pkt(c, &conn->key.paddr, pi.ecn);
sbin/unwind/libunbound/services/listen_dnsport.c
5489
ngtcp2_conn_update_pkt_tx_time(conn->conn, ts);
sbin/unwind/libunbound/services/listen_dnsport.c
5494
doq_conn_write_enable(struct doq_conn* conn)
sbin/unwind/libunbound/services/listen_dnsport.c
5496
conn->write_interest = 1;
sbin/unwind/libunbound/services/listen_dnsport.c
5500
doq_conn_write_disable(struct doq_conn* conn)
sbin/unwind/libunbound/services/listen_dnsport.c
5502
conn->write_interest = 0;
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
5509
if(conn->on_write_list)
sbin/unwind/libunbound/services/listen_dnsport.c
5511
conn->write_prev = table->write_list_last;
sbin/unwind/libunbound/services/listen_dnsport.c
5513
table->write_list_last->write_next = conn;
sbin/unwind/libunbound/services/listen_dnsport.c
5514
else table->write_list_first = conn;
sbin/unwind/libunbound/services/listen_dnsport.c
5515
conn->write_next = NULL;
sbin/unwind/libunbound/services/listen_dnsport.c
5516
table->write_list_last = conn;
sbin/unwind/libunbound/services/listen_dnsport.c
5517
conn->on_write_list = 1;
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
5523
if(!conn->on_write_list)
sbin/unwind/libunbound/services/listen_dnsport.c
5525
if(conn->write_next)
sbin/unwind/libunbound/services/listen_dnsport.c
5526
conn->write_next->write_prev = conn->write_prev;
sbin/unwind/libunbound/services/listen_dnsport.c
5527
else table->write_list_last = conn->write_prev;
sbin/unwind/libunbound/services/listen_dnsport.c
5528
if(conn->write_prev)
sbin/unwind/libunbound/services/listen_dnsport.c
5529
conn->write_prev->write_next = conn->write_next;
sbin/unwind/libunbound/services/listen_dnsport.c
5530
else table->write_list_first = conn->write_next;
sbin/unwind/libunbound/services/listen_dnsport.c
5531
conn->write_prev = NULL;
sbin/unwind/libunbound/services/listen_dnsport.c
5532
conn->write_next = NULL;
sbin/unwind/libunbound/services/listen_dnsport.c
5533
conn->on_write_list = 0;
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
5539
if(conn->write_interest && conn->on_write_list)
sbin/unwind/libunbound/services/listen_dnsport.c
5541
if(!conn->write_interest && !conn->on_write_list)
sbin/unwind/libunbound/services/listen_dnsport.c
5543
if(conn->write_interest)
sbin/unwind/libunbound/services/listen_dnsport.c
5544
doq_conn_write_list_append(table, conn);
sbin/unwind/libunbound/services/listen_dnsport.c
5545
else doq_conn_write_list_remove(table, conn);
sbin/unwind/libunbound/services/listen_dnsport.c
5551
struct doq_conn* conn = table->write_list_first;
sbin/unwind/libunbound/services/listen_dnsport.c
5552
if(!conn)
sbin/unwind/libunbound/services/listen_dnsport.c
5554
lock_basic_lock(&conn->lock);
sbin/unwind/libunbound/services/listen_dnsport.c
5555
table->write_list_first = conn->write_next;
sbin/unwind/libunbound/services/listen_dnsport.c
5556
if(conn->write_next)
sbin/unwind/libunbound/services/listen_dnsport.c
5557
conn->write_next->write_prev = NULL;
sbin/unwind/libunbound/services/listen_dnsport.c
5559
conn->write_next = NULL;
sbin/unwind/libunbound/services/listen_dnsport.c
5560
conn->write_prev = NULL;
sbin/unwind/libunbound/services/listen_dnsport.c
5561
conn->on_write_list = 0;
sbin/unwind/libunbound/services/listen_dnsport.c
5562
return conn;
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
5568
ngtcp2_tstamp expiry = ngtcp2_conn_get_expiry(conn->conn);
sbin/unwind/libunbound/services/listen_dnsport.c
5589
if(conn->timer.timer_in_tree || conn->timer.timer_in_list) {
sbin/unwind/libunbound/services/listen_dnsport.c
5590
if(conn->timer.time.tv_sec == tv->tv_sec &&
sbin/unwind/libunbound/services/listen_dnsport.c
5591
conn->timer.time.tv_usec == tv->tv_usec)
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
5602
addr_to_str((void*)&conn->key.paddr.addr, conn->key.paddr.addrlen,
sbin/unwind/libunbound/services/listen_dnsport.c
5604
addr_to_str((void*)&conn->key.paddr.localaddr,
sbin/unwind/libunbound/services/listen_dnsport.c
5605
conn->key.paddr.localaddrlen, localstr, sizeof(localstr));
sbin/unwind/libunbound/services/listen_dnsport.c
5610
doq_conn_handle_timeout(struct doq_conn* conn)
sbin/unwind/libunbound/services/listen_dnsport.c
5616
doq_conn_log_line(conn, "timeout");
sbin/unwind/libunbound/services/listen_dnsport.c
5618
rv = ngtcp2_conn_handle_expiry(conn->conn, now);
sbin/unwind/libunbound/services/listen_dnsport.c
5623
ngtcp2_ccerr_set_liberr(&conn->ccerr, rv, NULL, 0);
sbin/unwind/libunbound/services/listen_dnsport.c
5626
&conn->last_error, rv, NULL, 0);
sbin/unwind/libunbound/services/listen_dnsport.c
5628
if(!doq_conn_close_error(conn->doq_socket->cp, conn)) {
sbin/unwind/libunbound/services/listen_dnsport.c
5634
doq_conn_write_enable(conn);
sbin/unwind/libunbound/services/listen_dnsport.c
5635
if(!doq_conn_write_streams(conn->doq_socket->cp, conn, NULL)) {
sbin/unwind/libunbound/services/listen_dnsport.h
556
struct doq_conn* conn;
sbin/unwind/libunbound/services/listen_dnsport.h
596
struct ngtcp2_conn* conn;
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
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
1672
struct doq_conn* conn;
sbin/unwind/libunbound/util/netevent.c
1682
conn = doq_conn_find(table, &key.paddr.addr,
sbin/unwind/libunbound/util/netevent.c
1686
if(!conn) {
sbin/unwind/libunbound/util/netevent.c
1693
lock_basic_lock(&conn->lock);
sbin/unwind/libunbound/util/netevent.c
1694
if(conn->is_deleted) {
sbin/unwind/libunbound/util/netevent.c
1696
lock_basic_unlock(&conn->lock);
sbin/unwind/libunbound/util/netevent.c
1700
return conn;
sbin/unwind/libunbound/util/netevent.c
1711
struct doq_conn* conn;
sbin/unwind/libunbound/util/netevent.c
1713
conn = doq_conn_find(table, &paddr->addr, paddr->addrlen,
sbin/unwind/libunbound/util/netevent.c
1716
if(conn && conn->is_deleted) {
sbin/unwind/libunbound/util/netevent.c
1717
conn = NULL;
sbin/unwind/libunbound/util/netevent.c
1719
if(conn) {
sbin/unwind/libunbound/util/netevent.c
1720
lock_basic_lock(&conn->lock);
sbin/unwind/libunbound/util/netevent.c
1725
conn = doq_conn_find_by_id(table, dcid, dcidlen);
sbin/unwind/libunbound/util/netevent.c
1726
if(conn) {
sbin/unwind/libunbound/util/netevent.c
1730
return conn;
sbin/unwind/libunbound/util/netevent.c
1737
struct doq_pkt_addr* paddr, struct doq_conn** conn)
sbin/unwind/libunbound/util/netevent.c
1799
*conn = doq_conn_find_by_addr_or_cid(c->doq_socket->table, paddr,
sbin/unwind/libunbound/util/netevent.c
1806
if(*conn)
sbin/unwind/libunbound/util/netevent.c
1807
(*conn)->doq_socket = c->doq_socket;
sbin/unwind/libunbound/util/netevent.c
1958
doq_delete_connection(struct comm_point* c, struct doq_conn* conn)
sbin/unwind/libunbound/util/netevent.c
1963
if(!conn)
sbin/unwind/libunbound/util/netevent.c
1966
conn->is_deleted = 1;
sbin/unwind/libunbound/util/netevent.c
1967
doq_conn_write_disable(conn);
sbin/unwind/libunbound/util/netevent.c
1968
copy.key = conn->key;
sbin/unwind/libunbound/util/netevent.c
1969
log_assert(conn->key.dcidlen <= NGTCP2_MAX_CIDLEN);
sbin/unwind/libunbound/util/netevent.c
1970
memcpy(cid, conn->key.dcid, conn->key.dcidlen);
sbin/unwind/libunbound/util/netevent.c
1973
lock_basic_unlock(&conn->lock);
sbin/unwind/libunbound/util/netevent.c
1979
conn = (struct doq_conn*)node->key;
sbin/unwind/libunbound/util/netevent.c
1980
lock_basic_lock(&conn->lock);
sbin/unwind/libunbound/util/netevent.c
1981
doq_conn_write_list_remove(c->doq_socket->table, conn);
sbin/unwind/libunbound/util/netevent.c
1982
if(conn->timer.timer_in_list) {
sbin/unwind/libunbound/util/netevent.c
1988
&conn->timer);
sbin/unwind/libunbound/util/netevent.c
1990
if(conn->timer.timer_in_tree)
sbin/unwind/libunbound/util/netevent.c
1992
&conn->timer);
sbin/unwind/libunbound/util/netevent.c
1996
lock_basic_unlock(&conn->lock);
sbin/unwind/libunbound/util/netevent.c
1998
sizeof(*conn)+conn->key.dcidlen);
sbin/unwind/libunbound/util/netevent.c
1999
doq_conn_delete(conn, c->doq_socket->table);
sbin/unwind/libunbound/util/netevent.c
2010
struct doq_conn* conn;
sbin/unwind/libunbound/util/netevent.c
2012
c->doq_socket->cfg, sizeof(*conn)+hd->dcid.datalen
sbin/unwind/libunbound/util/netevent.c
2021
conn = doq_conn_create(c, paddr, hd->dcid.data, hd->dcid.datalen,
sbin/unwind/libunbound/util/netevent.c
2023
if(!conn) {
sbin/unwind/libunbound/util/netevent.c
2028
lock_basic_lock(&conn->lock);
sbin/unwind/libunbound/util/netevent.c
2029
if(!rbtree_insert(c->doq_socket->table->conn_tree, &conn->node)) {
sbin/unwind/libunbound/util/netevent.c
2033
lock_basic_unlock(&conn->lock);
sbin/unwind/libunbound/util/netevent.c
2034
doq_conn_delete(conn, c->doq_socket->table);
sbin/unwind/libunbound/util/netevent.c
2039
sizeof(*conn)+conn->key.dcidlen);
sbin/unwind/libunbound/util/netevent.c
2045
if(!doq_conn_setup(conn, hd->scid.data, hd->scid.datalen,
sbin/unwind/libunbound/util/netevent.c
2054
doq_delete_connection(c, conn);
sbin/unwind/libunbound/util/netevent.c
2057
return conn;
sbin/unwind/libunbound/util/netevent.c
2126
struct doq_conn** conn, struct ngtcp2_pkt_info* pi)
sbin/unwind/libunbound/util/netevent.c
2154
*conn = doq_setup_new_conn(c, paddr, &hd, pocid);
sbin/unwind/libunbound/util/netevent.c
2155
if(!*conn)
sbin/unwind/libunbound/util/netevent.c
2157
(*conn)->doq_socket = c->doq_socket;
sbin/unwind/libunbound/util/netevent.c
2158
if(!doq_conn_recv(c, paddr, *conn, pi, &err_retry, NULL)) {
sbin/unwind/libunbound/util/netevent.c
2161
doq_delete_connection(c, *conn);
sbin/unwind/libunbound/util/netevent.c
2162
*conn = NULL;
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
2220
conn->doq_socket = NULL;
sbin/unwind/libunbound/util/netevent.c
2222
if(doq_conn_check_timer(conn, &new_tv))
sbin/unwind/libunbound/util/netevent.c
2224
if( (conn->write_interest && !conn->on_write_list) ||
sbin/unwind/libunbound/util/netevent.c
2225
(!conn->write_interest && conn->on_write_list))
sbin/unwind/libunbound/util/netevent.c
2230
lock_basic_unlock(&conn->lock);
sbin/unwind/libunbound/util/netevent.c
2237
copy.key = conn->key;
sbin/unwind/libunbound/util/netevent.c
2238
log_assert(conn->key.dcidlen <= NGTCP2_MAX_CIDLEN);
sbin/unwind/libunbound/util/netevent.c
2239
memcpy(cid, conn->key.dcid, conn->key.dcidlen);
sbin/unwind/libunbound/util/netevent.c
2242
lock_basic_unlock(&conn->lock);
sbin/unwind/libunbound/util/netevent.c
2251
conn = (struct doq_conn*)node->key;
sbin/unwind/libunbound/util/netevent.c
2252
lock_basic_lock(&conn->lock);
sbin/unwind/libunbound/util/netevent.c
2253
if(conn->is_deleted) {
sbin/unwind/libunbound/util/netevent.c
2256
lock_basic_unlock(&conn->lock);
sbin/unwind/libunbound/util/netevent.c
2264
doq_conn_set_write_list(c->doq_socket->table, conn);
sbin/unwind/libunbound/util/netevent.c
2267
doq_timer_set(c->doq_socket->table, &conn->timer,
sbin/unwind/libunbound/util/netevent.c
2271
lock_basic_unlock(&conn->lock);
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
2284
conn->doq_socket = NULL;
sbin/unwind/libunbound/util/netevent.c
2286
if( (conn->write_interest && conn->on_write_list) ||
sbin/unwind/libunbound/util/netevent.c
2287
(!conn->write_interest && !conn->on_write_list)) {
sbin/unwind/libunbound/util/netevent.c
2290
lock_basic_unlock(&conn->lock);
sbin/unwind/libunbound/util/netevent.c
2296
copy.key = conn->key;
sbin/unwind/libunbound/util/netevent.c
2297
log_assert(conn->key.dcidlen <= NGTCP2_MAX_CIDLEN);
sbin/unwind/libunbound/util/netevent.c
2298
memcpy(cid, conn->key.dcid, conn->key.dcidlen);
sbin/unwind/libunbound/util/netevent.c
2301
lock_basic_unlock(&conn->lock);
sbin/unwind/libunbound/util/netevent.c
2310
conn = (struct doq_conn*)node->key;
sbin/unwind/libunbound/util/netevent.c
2311
lock_basic_lock(&conn->lock);
sbin/unwind/libunbound/util/netevent.c
2312
if(conn->is_deleted) {
sbin/unwind/libunbound/util/netevent.c
2315
lock_basic_unlock(&conn->lock);
sbin/unwind/libunbound/util/netevent.c
2322
doq_conn_set_write_list(c->doq_socket->table, conn);
sbin/unwind/libunbound/util/netevent.c
2324
lock_basic_unlock(&conn->lock);
sbin/unwind/libunbound/util/netevent.c
2332
struct doq_conn* conn;
sbin/unwind/libunbound/util/netevent.c
2334
conn = c->doq_socket->table->write_list_first;
sbin/unwind/libunbound/util/netevent.c
2335
while(conn) {
sbin/unwind/libunbound/util/netevent.c
2337
conn = conn->write_next;
sbin/unwind/libunbound/util/netevent.c
2347
struct doq_conn* conn;
sbin/unwind/libunbound/util/netevent.c
2349
conn = doq_table_pop_first(c->doq_socket->table);
sbin/unwind/libunbound/util/netevent.c
2350
while(conn && conn->is_deleted) {
sbin/unwind/libunbound/util/netevent.c
2351
lock_basic_unlock(&conn->lock);
sbin/unwind/libunbound/util/netevent.c
2352
conn = doq_table_pop_first(c->doq_socket->table);
sbin/unwind/libunbound/util/netevent.c
2355
if(conn)
sbin/unwind/libunbound/util/netevent.c
2356
conn->doq_socket = c->doq_socket;
sbin/unwind/libunbound/util/netevent.c
2357
return 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
2366
doq_delete_connection(c, conn);
sbin/unwind/libunbound/util/netevent.c
2369
doq_done_setup_timer_and_write(c, conn);
sbin/unwind/libunbound/util/netevent.c
2436
struct doq_conn* conn = NULL;
sbin/unwind/libunbound/util/netevent.c
2442
conn = t->conn;
sbin/unwind/libunbound/util/netevent.c
2450
lock_basic_lock(&conn->lock);
sbin/unwind/libunbound/util/netevent.c
2451
conn->doq_socket = doq_socket;
sbin/unwind/libunbound/util/netevent.c
2456
return conn;
sbin/unwind/libunbound/util/netevent.c
2479
struct doq_conn* conn;
sbin/unwind/libunbound/util/netevent.c
2484
while((conn = doq_timer_timeout_conn(doq_socket)) != NULL) {
sbin/unwind/libunbound/util/netevent.c
2485
if(conn->is_deleted ||
sbin/unwind/libunbound/util/netevent.c
2487
ngtcp2_conn_in_closing_period(conn->conn) ||
sbin/unwind/libunbound/util/netevent.c
2489
ngtcp2_conn_is_in_closing_period(conn->conn) ||
sbin/unwind/libunbound/util/netevent.c
2492
ngtcp2_conn_in_draining_period(conn->conn)
sbin/unwind/libunbound/util/netevent.c
2494
ngtcp2_conn_is_in_draining_period(conn->conn)
sbin/unwind/libunbound/util/netevent.c
2499
addr_to_str((void*)&conn->key.paddr.addr,
sbin/unwind/libunbound/util/netevent.c
2500
conn->key.paddr.addrlen, remotestr,
sbin/unwind/libunbound/util/netevent.c
2505
doq_delete_connection(doq_socket->cp, conn);
sbin/unwind/libunbound/util/netevent.c
2508
if(!doq_conn_handle_timeout(conn))
sbin/unwind/libunbound/util/netevent.c
2509
doq_delete_connection(doq_socket->cp, conn);
sbin/unwind/libunbound/util/netevent.c
2510
else doq_done_setup_timer_and_write(doq_socket->cp, conn);
sbin/unwind/libunbound/util/netevent.c
2525
struct doq_conn* conn;
sbin/unwind/libunbound/util/netevent.c
2555
while((conn = doq_pop_write_conn(c)) != NULL) {
sbin/unwind/libunbound/util/netevent.c
2556
if(conn->is_deleted ||
sbin/unwind/libunbound/util/netevent.c
2558
ngtcp2_conn_in_closing_period(conn->conn) ||
sbin/unwind/libunbound/util/netevent.c
2560
ngtcp2_conn_is_in_closing_period(conn->conn) ||
sbin/unwind/libunbound/util/netevent.c
2563
ngtcp2_conn_in_draining_period(conn->conn)
sbin/unwind/libunbound/util/netevent.c
2565
ngtcp2_conn_is_in_draining_period(conn->conn)
sbin/unwind/libunbound/util/netevent.c
2568
conn->doq_socket = NULL;
sbin/unwind/libunbound/util/netevent.c
2569
lock_basic_unlock(&conn->lock);
sbin/unwind/libunbound/util/netevent.c
2582
addr_to_str((void*)&conn->key.paddr.addr,
sbin/unwind/libunbound/util/netevent.c
2583
conn->key.paddr.addrlen, remotestr,
sbin/unwind/libunbound/util/netevent.c
2587
&conn->key.paddr.addr));
sbin/unwind/libunbound/util/netevent.c
2589
if(doq_conn_write_streams(c, conn, &err_drop))
sbin/unwind/libunbound/util/netevent.c
2591
doq_done_with_write_cb(c, conn, err_drop);
sbin/unwind/libunbound/util/netevent.c
2651
conn = NULL;
sbin/unwind/libunbound/util/netevent.c
2652
if(!doq_decode_pkt_header_negotiate(c, &paddr, &conn))
sbin/unwind/libunbound/util/netevent.c
2654
if(!conn) {
sbin/unwind/libunbound/util/netevent.c
2655
if(!doq_accept(c, &paddr, &conn, &pi))
sbin/unwind/libunbound/util/netevent.c
2657
if(!doq_conn_write_streams(c, conn, NULL)) {
sbin/unwind/libunbound/util/netevent.c
2658
doq_delete_connection(c, conn);
sbin/unwind/libunbound/util/netevent.c
2661
doq_done_setup_timer_and_write(c, conn);
sbin/unwind/libunbound/util/netevent.c
2666
ngtcp2_conn_in_closing_period(conn->conn)
sbin/unwind/libunbound/util/netevent.c
2668
ngtcp2_conn_is_in_closing_period(conn->conn)
sbin/unwind/libunbound/util/netevent.c
2671
if(!doq_conn_send_close(c, conn)) {
sbin/unwind/libunbound/util/netevent.c
2672
doq_delete_connection(c, conn);
sbin/unwind/libunbound/util/netevent.c
2674
doq_done_setup_timer_and_write(c, conn);
sbin/unwind/libunbound/util/netevent.c
2680
ngtcp2_conn_in_draining_period(conn->conn)
sbin/unwind/libunbound/util/netevent.c
2682
ngtcp2_conn_is_in_draining_period(conn->conn)
sbin/unwind/libunbound/util/netevent.c
2685
doq_done_setup_timer_and_write(c, conn);
sbin/unwind/libunbound/util/netevent.c
2688
if(!doq_conn_recv(c, &paddr, conn, &pi, NULL, &err_drop)) {
sbin/unwind/libunbound/util/netevent.c
2693
doq_delete_connection(c, conn);
sbin/unwind/libunbound/util/netevent.c
2695
doq_done_setup_timer_and_write(c, conn);
sbin/unwind/libunbound/util/netevent.c
2699
if(!doq_conn_write_streams(c, conn, &err_drop)) {
sbin/unwind/libunbound/util/netevent.c
2701
doq_delete_connection(c, conn);
sbin/unwind/libunbound/util/netevent.c
2703
doq_done_setup_timer_and_write(c, conn);
sbin/unwind/libunbound/util/netevent.c
2707
doq_done_setup_timer_and_write(c, conn);
sbin/unwind/libunbound/util/netevent.c
2805
struct doq_conn* conn;
sbin/unwind/libunbound/util/netevent.c
2809
conn = doq_conn_find(table, &key.paddr.addr,
sbin/unwind/libunbound/util/netevent.c
2813
if(conn) {
sbin/unwind/libunbound/util/netevent.c
2814
lock_basic_lock(&conn->lock);
sbin/unwind/libunbound/util/netevent.c
2816
return conn;
sbin/unwind/libunbound/util/netevent.c
2825
struct doq_conn** conn, struct doq_stream** stream)
sbin/unwind/libunbound/util/netevent.c
2829
*conn = c->doq_socket->current_conn;
sbin/unwind/libunbound/util/netevent.c
2831
*conn = doq_lookup_repinfo(c->doq_socket->table, repinfo);
sbin/unwind/libunbound/util/netevent.c
2832
if((*conn) && (*conn)->is_deleted) {
sbin/unwind/libunbound/util/netevent.c
2833
lock_basic_unlock(&(*conn)->lock);
sbin/unwind/libunbound/util/netevent.c
2834
*conn = NULL;
sbin/unwind/libunbound/util/netevent.c
2836
if(*conn) {
sbin/unwind/libunbound/util/netevent.c
2837
(*conn)->doq_socket = c->doq_socket;
sbin/unwind/libunbound/util/netevent.c
2840
if(!*conn) {
sbin/unwind/libunbound/util/netevent.c
2844
*stream = doq_stream_find(*conn, repinfo->doq_streamid);
sbin/unwind/libunbound/util/netevent.c
2849
lock_basic_unlock(&(*conn)->lock);
sbin/unwind/libunbound/util/netevent.c
2858
lock_basic_unlock(&(*conn)->lock);
sbin/unwind/libunbound/util/netevent.c
2869
struct doq_conn* conn;
sbin/unwind/libunbound/util/netevent.c
2872
if(!doq_lookup_conn_stream(repinfo, repinfo->c, &conn, &stream)) {
sbin/unwind/libunbound/util/netevent.c
2874
(conn?"stream":"connection"));
sbin/unwind/libunbound/util/netevent.c
2879
if(!doq_stream_send_reply(conn, stream, repinfo->c->buffer))
sbin/unwind/libunbound/util/netevent.c
2880
doq_stream_close(conn, stream, 1);
sbin/unwind/libunbound/util/netevent.c
2884
doq_done_with_conn_cb(repinfo->c, conn);
sbin/unwind/libunbound/util/netevent.c
2900
struct doq_conn* conn;
sbin/unwind/libunbound/util/netevent.c
2903
if(!doq_lookup_conn_stream(repinfo, repinfo->c, &conn, &stream)) {
sbin/unwind/libunbound/util/netevent.c
2905
(conn?"stream":"connection"));
sbin/unwind/libunbound/util/netevent.c
2909
doq_stream_close(conn, stream, 1);
sbin/unwind/libunbound/util/netevent.c
2913
doq_done_with_conn_cb(repinfo->c, conn);
sys/dev/acpi/dsdt.c
2585
aml_rwgpio(struct aml_value *conn, int bpos, int blen, struct aml_value *val,
sys/dev/acpi/dsdt.c
2588
union acpi_resource *crs = (union acpi_resource *)conn->v_buffer;
sys/dev/acpi/dsdt.c
2593
if (conn->type != AML_OBJTYPE_BUFFER || conn->length < 5 ||
sys/dev/acpi/dsdt.c
2594
AML_CRSTYPE(crs) != LR_GPIO || AML_CRSLEN(crs) > conn->length)
sys/dev/acpi/dsdt.c
2599
node = aml_searchname(conn->node,
sys/dev/acpi/dsdt.c
2618
aml_rwgsb(struct aml_value *conn, int len, int bpos, int blen,
sys/dev/acpi/dsdt.c
2621
union acpi_resource *crs = (union acpi_resource *)conn->v_buffer;
sys/dev/acpi/dsdt.c
2631
if (conn->type != AML_OBJTYPE_BUFFER || conn->length < 5 ||
sys/dev/acpi/dsdt.c
2632
AML_CRSTYPE(crs) != LR_SERBUS || AML_CRSLEN(crs) > conn->length ||
sys/dev/acpi/dsdt.c
2638
node = aml_searchname(conn->node,
sys/dev/acpi/dsdt.c
2739
aml_rwgsb(struct aml_value *conn, int len, int bpos, int blen,
sys/dev/acpi/dsdt.c
2969
struct aml_value *conn = NULL;
sys/dev/acpi/dsdt.c
2991
conn = aml_parse(mscope, 'o', "Connection");
sys/dev/acpi/dsdt.c
2992
if (conn == NULL)
sys/dev/acpi/dsdt.c
2994
conn->node = mscope->node;
sys/dev/acpi/dsdt.c
3008
conn ? conn : index, indexval, flags);
sys/dev/ic/elink3.c
456
int conn, i;
sys/dev/ic/elink3.c
459
conn = 0;
sys/dev/ic/elink3.c
467
if (conn)
sys/dev/ic/elink3.c
470
conn |= epm->epm_conn;
sys/dev/ic/elink3.c
473
sc->ep_connectors = conn;
sys/dev/ic/elink3.c
508
u_int config1, conn;
sys/dev/ic/elink3.c
524
conn = 0;
sys/dev/ic/elink3.c
529
if (conn)
sys/dev/ic/elink3.c
532
conn |= epm->epm_conn;
sys/dev/ic/elink3.c
537
sc->ep_connectors = conn;
sys/dev/pci/azalia.c
2209
int i, j, err, fspkr, conn;
sys/dev/pci/azalia.c
2228
conn = conv = -1;
sys/dev/pci/azalia.c
2240
conn = i;
sys/dev/pci/azalia.c
2255
conn = j;
sys/dev/pci/azalia.c
2261
if (conn != -1 && conv != -1) {
sys/dev/pci/azalia.c
2263
CORB_SET_CONNECTION_SELECT_CONTROL, conn, 0);
sys/dev/pci/azalia.c
2266
w->selected = conn;
sys/dev/pci/azalia.c
2276
conn = conv = -1;
sys/dev/pci/azalia.c
2283
conn = i;
sys/dev/pci/azalia.c
2287
conn = i;
sys/dev/pci/azalia.c
2291
if (conn != -1) {
sys/dev/pci/azalia.c
2293
CORB_SET_CONNECTION_SELECT_CONTROL, conn, 0);
sys/dev/pci/azalia.c
2296
w->selected = conn;
sys/dev/pci/azalia.c
3364
int length, nconn, bits, conn, last;
sys/dev/pci/azalia.c
3396
conn = (result >> (k * bits)) & ((1 << bits) - 1);
sys/dev/pci/azalia.c
3400
if ((nconn > 0) && (conn & (1 << (bits - 1))))
sys/dev/pci/azalia.c
3401
nconn += (conn & ~(1 << (bits - 1))) - last;
sys/dev/pci/azalia.c
3404
last = conn;
sys/dev/pci/azalia.c
3420
conn = (result >> (k * bits)) & ((1 << bits) - 1);
sys/dev/pci/azalia.c
3424
if ((i > 0) && (conn & (1 << (bits - 1)))) {
sys/dev/pci/azalia.c
3425
for (j = 1; i < nconn && j <= conn - last; j++)
sys/dev/pci/azalia.c
3428
this->connections[i++] = conn;
sys/dev/pci/azalia.c
3430
last = conn;
sys/dev/pci/drm/amd/display/amdgpu_dm/amdgpu_dm.c
8104
amdgpu_dm_connector_atomic_check(struct drm_connector *conn,
sys/dev/pci/drm/amd/display/amdgpu_dm/amdgpu_dm.c
8108
drm_atomic_get_new_connector_state(state, conn);
sys/dev/pci/drm/amd/display/amdgpu_dm/amdgpu_dm.c
8110
drm_atomic_get_old_connector_state(state, conn);
sys/dev/pci/drm/amd/display/amdgpu_dm/amdgpu_dm.c
8113
struct amdgpu_dm_connector *aconn = to_amdgpu_dm_connector(conn);
sys/dev/pci/drm/amd/display/amdgpu_dm/amdgpu_dm.c
8121
if (conn->connector_type == DRM_MODE_CONNECTOR_DisplayPort) {
sys/dev/pci/drm/amd/display/modules/hdcp/hdcp1_transition.c
157
struct mod_hdcp_connection *conn = &hdcp->connection;
sys/dev/pci/drm/amd/display/modules/hdcp/hdcp1_transition.c
229
} else if ((!conn->is_repeater && input->encryption != PASS) ||
sys/dev/pci/drm/amd/display/modules/hdcp/hdcp1_transition.c
230
(!conn->is_repeater && is_dp_mst_hdcp(hdcp) && input->stream_encryption_dp != PASS)) {
sys/dev/pci/drm/amd/display/modules/hdcp/hdcp1_transition.c
233
} else if (conn->hdcp1_retry_count < conn->link.adjust.hdcp1.min_auth_retries_wa) {
sys/dev/pci/drm/amd/display/modules/hdcp/hdcp1_transition.c
237
if (conn->is_repeater) {
sys/dev/pci/drm/amd/display/modules/hdcp/hdcp1_transition.c
34
struct mod_hdcp_connection *conn = &hdcp->connection;
sys/dev/pci/drm/amd/display/modules/hdcp/hdcp1_transition.c
81
} else if (!conn->is_repeater && input->encryption != PASS) {
sys/dev/pci/drm/amd/display/modules/hdcp/hdcp1_transition.c
85
if (conn->is_repeater) {
sys/dev/pci/drm/amd/display/modules/hdcp/hdcp2_transition.c
226
if (conn->is_repeater) {
sys/dev/pci/drm/amd/display/modules/hdcp/hdcp2_transition.c
247
} else if (event_ctx->rx_id_list_ready && conn->is_repeater) {
sys/dev/pci/drm/amd/display/modules/hdcp/hdcp2_transition.c
264
} else if (event_ctx->rx_id_list_ready && conn->is_repeater) {
sys/dev/pci/drm/amd/display/modules/hdcp/hdcp2_transition.c
319
} else if (event_ctx->rx_id_list_ready && conn->is_repeater) {
sys/dev/pci/drm/amd/display/modules/hdcp/hdcp2_transition.c
337
} else if (event_ctx->rx_id_list_ready && conn->is_repeater) {
sys/dev/pci/drm/amd/display/modules/hdcp/hdcp2_transition.c
34
struct mod_hdcp_connection *conn = &hdcp->connection;
sys/dev/pci/drm/amd/display/modules/hdcp/hdcp2_transition.c
387
struct mod_hdcp_connection *conn = &hdcp->connection;
sys/dev/pci/drm/amd/display/modules/hdcp/hdcp2_transition.c
427
if (conn->is_km_stored &&
sys/dev/pci/drm/amd/display/modules/hdcp/hdcp2_transition.c
547
if (conn->is_repeater) {
sys/dev/pci/drm/amd/display/modules/hdcp/hdcp2_transition.c
576
} else if (event_ctx->rx_id_list_ready && conn->is_repeater) {
sys/dev/pci/drm/amd/display/modules/hdcp/hdcp2_transition.c
598
} else if (event_ctx->rx_id_list_ready && conn->is_repeater) {
sys/dev/pci/drm/amd/display/modules/hdcp/hdcp2_transition.c
90
if (conn->is_km_stored &&
sys/dev/pci/drm/amd/pm/amdgpu_dpm_internal.c
37
struct amdgpu_connector *conn;
sys/dev/pci/drm/amd/pm/amdgpu_dpm_internal.c
52
conn = to_amdgpu_connector(amdgpu_crtc->connector);
sys/dev/pci/drm/amd/pm/amdgpu_dpm_internal.c
89
display_cfg->pixel_clock = conn->pixelclock_for_modeset;
sys/dev/pci/drm/drm_atomic.c
1480
struct drm_connector *conn;
sys/dev/pci/drm/drm_atomic.c
1511
for_each_new_connector_in_state(state, conn, conn_state, i) {
sys/dev/pci/drm/drm_atomic.c
1512
ret = drm_atomic_connector_check(conn, conn_state);
sys/dev/pci/drm/drm_atomic.c
1515
conn->base.id, conn->name);
sys/dev/pci/drm/drm_atomic_helper.c
2519
struct drm_connector *conn;
sys/dev/pci/drm/drm_atomic_helper.c
2577
for_each_oldnew_connector_in_state(state, conn, old_conn_state, new_conn_state, i) {
sys/dev/pci/drm/drm_atomic_helper.c
2584
drm_dbg_atomic(conn->dev,
sys/dev/pci/drm/drm_atomic_helper.c
2586
conn->base.id, conn->name);
sys/dev/pci/drm/drm_atomic_helper.c
2646
struct drm_connector *conn;
sys/dev/pci/drm/drm_atomic_helper.c
2659
for_each_old_connector_in_state(state, conn, old_conn_state, i) {
sys/dev/pci/drm/drm_atomic_helper.c
2662
drm_err(conn->dev,
sys/dev/pci/drm/drm_atomic_helper.c
2664
conn->base.id, conn->name);
sys/dev/pci/drm/drm_atomic_helper.c
3551
struct drm_connector *conn;
sys/dev/pci/drm/drm_atomic_helper.c
3586
for_each_new_connector_in_state(state, conn, conn_state, i) {
sys/dev/pci/drm/drm_atomic_helper.c
3715
struct drm_connector *conn;
sys/dev/pci/drm/drm_atomic_helper.c
3749
drm_for_each_connector_iter(conn, &conn_iter) {
sys/dev/pci/drm/drm_atomic_helper.c
3752
conn_state = drm_atomic_get_connector_state(state, conn);
sys/dev/pci/drm/drm_atomic_uapi.c
1207
struct drm_connector *conn;
sys/dev/pci/drm/drm_atomic_uapi.c
1284
for_each_new_connector_in_state(state, conn, conn_state, i) {
sys/dev/pci/drm/drm_atomic_uapi.c
1293
fence_ptr = get_out_fence_for_connector(state, conn);
sys/dev/pci/drm/drm_atomic_uapi.c
1317
wb_conn = drm_connector_to_writeback(conn);
sys/dev/pci/drm/drm_atomic_uapi.c
653
struct drm_connector *conn = conn_state->connector;
sys/dev/pci/drm/drm_atomic_uapi.c
660
drm_dbg_atomic(conn->dev,
sys/dev/pci/drm/drm_atomic_uapi.c
664
drm_dbg_atomic(conn->dev,
sys/dev/pci/drm/drm_bridge.c
1078
struct drm_connector *conn = conn_state->connector;
sys/dev/pci/drm/drm_bridge.c
1116
if (conn->display_info.num_bus_formats &&
sys/dev/pci/drm/drm_bridge.c
1117
conn->display_info.bus_formats)
sys/dev/pci/drm/drm_bridge.c
1118
out_bus_fmts[0] = conn->display_info.bus_formats[0];
sys/dev/pci/drm/drm_bridge.c
1137
struct drm_connector *conn,
sys/dev/pci/drm/drm_bridge.c
1163
output_flags = conn->display_info.bus_flags;
sys/dev/pci/drm/drm_bridge.c
1205
struct drm_connector *conn = conn_state->connector;
sys/dev/pci/drm/drm_bridge.c
1229
drm_atomic_bridge_propagate_bus_flags(iter, conn,
sys/dev/pci/drm/drm_connector.c
1059
iter->conn = NULL;
sys/dev/pci/drm/drm_connector.c
1070
__drm_connector_put_safe(struct drm_connector *conn)
sys/dev/pci/drm/drm_connector.c
1072
struct drm_mode_config *config = &conn->dev->mode_config;
sys/dev/pci/drm/drm_connector.c
1076
if (!refcount_dec_and_test(&conn->base.refcount.refcount))
sys/dev/pci/drm/drm_connector.c
1079
llist_add(&conn->free_node, &config->connector_free_list);
sys/dev/pci/drm/drm_connector.c
1093
struct drm_connector *old_conn = iter->conn;
sys/dev/pci/drm/drm_connector.c
1103
iter->conn = NULL;
sys/dev/pci/drm/drm_connector.c
1108
iter->conn = list_entry(lhead, struct drm_connector, head);
sys/dev/pci/drm/drm_connector.c
1111
} while (!kref_get_unless_zero(&iter->conn->base.refcount));
sys/dev/pci/drm/drm_connector.c
1117
return iter->conn;
sys/dev/pci/drm/drm_connector.c
1136
if (iter->conn) {
sys/dev/pci/drm/drm_connector.c
1138
__drm_connector_put_safe(iter->conn);
sys/dev/pci/drm/drm_framebuffer.c
1009
struct drm_connector *conn __maybe_unused;
sys/dev/pci/drm/drm_framebuffer.c
1076
for_each_new_connector_in_state(state, conn, conn_state, i) {
sys/dev/pci/drm/drm_self_refresh_helper.c
106
for_each_new_connector_in_state(state, conn, conn_state, i) {
sys/dev/pci/drm/drm_self_refresh_helper.c
77
struct drm_connector *conn;
sys/dev/pci/drm/i915/display/g4x_hdmi.c
600
struct drm_connector *conn;
sys/dev/pci/drm/i915/display/g4x_hdmi.c
622
drm_for_each_connector_iter(conn, &conn_iter) {
sys/dev/pci/drm/i915/display/g4x_hdmi.c
627
if (!connector_is_hdmi(conn))
sys/dev/pci/drm/i915/display/g4x_hdmi.c
631
conn->base.id, conn->name);
sys/dev/pci/drm/i915/display/g4x_hdmi.c
633
conn_state = drm_atomic_get_connector_state(state, conn);
sys/dev/pci/drm/i915/display/intel_atomic.c
114
int intel_digital_connector_atomic_check(struct drm_connector *conn,
sys/dev/pci/drm/i915/display/intel_atomic.c
118
drm_atomic_get_new_connector_state(state, conn);
sys/dev/pci/drm/i915/display/intel_atomic.c
122
drm_atomic_get_old_connector_state(state, conn);
sys/dev/pci/drm/i915/display/intel_atomic.c
127
intel_hdcp_atomic_check(conn, old_state, new_state);
sys/dev/pci/drm/i915/display/intel_atomic.h
31
int intel_digital_connector_atomic_check(struct drm_connector *conn,
sys/dev/pci/drm/i915/display/intel_ddi.c
3330
struct drm_connector *conn;
sys/dev/pci/drm/i915/display/intel_ddi.c
3336
for_each_new_connector_in_state(&state->base, conn, conn_state, i) {
sys/dev/pci/drm/i915/display/intel_display.c
1348
struct drm_connector *conn;
sys/dev/pci/drm/i915/display/intel_display.c
1351
for_each_new_connector_in_state(&state->base, conn, conn_state, i) {
sys/dev/pci/drm/i915/display/intel_display.c
1370
struct drm_connector *conn;
sys/dev/pci/drm/i915/display/intel_display.c
1373
for_each_new_connector_in_state(&state->base, conn, conn_state, i) {
sys/dev/pci/drm/i915/display/intel_display.c
1392
struct drm_connector *conn;
sys/dev/pci/drm/i915/display/intel_display.c
1395
for_each_new_connector_in_state(&state->base, conn, conn_state, i) {
sys/dev/pci/drm/i915/display/intel_display.c
1415
struct drm_connector *conn;
sys/dev/pci/drm/i915/display/intel_display.c
1418
for_each_old_connector_in_state(&state->base, conn, old_conn_state, i) {
sys/dev/pci/drm/i915/display/intel_display.c
1438
struct drm_connector *conn;
sys/dev/pci/drm/i915/display/intel_display.c
1441
for_each_old_connector_in_state(&state->base, conn, old_conn_state, i) {
sys/dev/pci/drm/i915/display/intel_display.c
1460
struct drm_connector *conn;
sys/dev/pci/drm/i915/display/intel_display.c
1463
for_each_old_connector_in_state(&state->base, conn, old_conn_state, i) {
sys/dev/pci/drm/i915/display/intel_display.c
1482
struct drm_connector *conn;
sys/dev/pci/drm/i915/display/intel_display.c
1485
for_each_new_connector_in_state(&state->base, conn, conn_state, i) {
sys/dev/pci/drm/i915/display/intel_display.c
907
struct drm_connector *conn;
sys/dev/pci/drm/i915/display/intel_display.c
910
for_each_new_connector_in_state(&state->base, conn, conn_state, i) {
sys/dev/pci/drm/i915/display/intel_display.c
928
struct drm_connector *conn;
sys/dev/pci/drm/i915/display/intel_display.c
931
for_each_old_connector_in_state(&state->base, conn, old_conn_state, i) {
sys/dev/pci/drm/i915/display/intel_psr.c
3185
struct drm_connector *conn;
sys/dev/pci/drm/i915/display/intel_psr.c
3199
drm_for_each_connector_iter(conn, &conn_iter) {
sys/dev/pci/drm/i915/display/intel_psr.c
3203
if (conn->connector_type != DRM_MODE_CONNECTOR_eDP)
sys/dev/pci/drm/i915/display/intel_psr.c
3206
conn_state = drm_atomic_get_connector_state(state, conn);
sys/dev/pci/drm/i915/display/intel_sdvo.c
2514
static int intel_sdvo_atomic_check(struct drm_connector *conn,
sys/dev/pci/drm/i915/display/intel_sdvo.c
2518
drm_atomic_get_new_connector_state(state, conn);
sys/dev/pci/drm/i915/display/intel_sdvo.c
2520
drm_atomic_get_old_connector_state(state, conn);
sys/dev/pci/drm/i915/display/intel_sdvo.c
2536
return intel_digital_connector_atomic_check(conn, state);
sys/dev/pci/drm/include/drm/drm_connector.h
2451
void drm_connector_attach_tv_margin_properties(struct drm_connector *conn);
sys/dev/pci/drm/include/drm/drm_connector.h
2492
void drm_connector_create_privacy_screen_properties(struct drm_connector *conn);
sys/dev/pci/drm/include/drm/drm_connector.h
2493
void drm_connector_attach_privacy_screen_properties(struct drm_connector *conn);
sys/dev/pci/drm/include/drm/drm_connector.h
2539
struct drm_connector *conn;
sys/net/pf.c
2057
--sni->sn->conn;
sys/net/pf.c
763
sn->conn++;
sys/net/pf.c
768
(*stp)->rule.ptr->max_src_conn < sn->conn) {
sys/net/pfvar.h
661
u_int32_t conn;
usr.bin/openssl/s_time.c
343
BIO *conn;
usr.bin/openssl/s_time.c
347
if ((conn = BIO_new(BIO_s_connect())) == NULL)
usr.bin/openssl/s_time.c
349
BIO_set_conn_hostname(conn, cfg.host);
usr.bin/openssl/s_time.c
351
SSL_set_bio(scon, conn, conn);
usr.bin/ssh/scp.c
1027
if (remin == -1 || conn == NULL) {
usr.bin/ssh/scp.c
1029
sftp_free(conn);
usr.bin/ssh/scp.c
1030
conn = do_sftp_connect(thost, tuser,
usr.bin/ssh/scp.c
1033
if (conn == NULL) {
usr.bin/ssh/scp.c
1057
throughlocal_sftp(conn2, conn, src, targ);
usr.bin/ssh/scp.c
1137
sftp_free(conn);
usr.bin/ssh/scp.c
1138
conn = do_sftp_connect(thost, tuser,
usr.bin/ssh/scp.c
1141
if (conn == NULL) {
usr.bin/ssh/scp.c
1148
source_sftp(1, argv[i], targ, conn);
usr.bin/ssh/scp.c
1173
sftp_free(conn);
usr.bin/ssh/scp.c
1182
struct sftp_conn *conn = NULL;
usr.bin/ssh/scp.c
1220
sftp_free(conn);
usr.bin/ssh/scp.c
1221
conn = do_sftp_connect(host, suser, sport,
usr.bin/ssh/scp.c
1223
if (conn == NULL) {
usr.bin/ssh/scp.c
1230
sink_sftp(1, argv[argc - 1], src, conn);
usr.bin/ssh/scp.c
1255
sftp_free(conn);
usr.bin/ssh/scp.c
1260
prepare_remote_path(struct sftp_conn *conn, const char *path)
usr.bin/ssh/scp.c
1274
if (sftp_can_expand_path(conn))
usr.bin/ssh/scp.c
1275
return sftp_expand_path(conn, path);
usr.bin/ssh/scp.c
1283
source_sftp(int argc, char *src, char *targ, struct sftp_conn *conn)
usr.bin/ssh/scp.c
1305
if ((target = prepare_remote_path(conn, targ)) == NULL)
usr.bin/ssh/scp.c
1307
target_is_dir = sftp_remote_is_dir(conn, target);
usr.bin/ssh/scp.c
1312
if (sftp_mkdir(conn, target, &a, 1) != 0)
usr.bin/ssh/scp.c
1325
if (sftp_upload_dir(conn, src, abs_dst, pflag,
usr.bin/ssh/scp.c
1330
} else if (sftp_upload(conn, src, abs_dst, pflag, 0, 0, 1) != 0) {
usr.bin/ssh/scp.c
1501
sink_sftp(int argc, char *dst, const char *src, struct sftp_conn *conn)
usr.bin/ssh/scp.c
1516
if ((abs_src = prepare_remote_path(conn, src)) == NULL) {
usr.bin/ssh/scp.c
1522
if ((r = sftp_glob(conn, abs_src, GLOB_NOCHECK|GLOB_MARK,
usr.bin/ssh/scp.c
1539
if (sftp_stat(conn, g.gl_pathv[0], 1, NULL) != 0) {
usr.bin/ssh/scp.c
1585
if (sftp_download_dir(conn, g.gl_pathv[i], abs_dst,
usr.bin/ssh/scp.c
1589
if (sftp_download(conn, g.gl_pathv[i], abs_dst, NULL,
usr.bin/ssh/scp.c
982
struct sftp_conn *conn = NULL, *conn2 = NULL;
usr.bin/ssh/sftp-client.c
1007
send_msg(conn, msg);
usr.bin/ssh/sftp-client.c
1010
send_string_request(conn, id, SSH2_FXP_REALPATH,
usr.bin/ssh/sftp-client.c
1013
get_msg(conn, msg);
usr.bin/ssh/sftp-client.c
102
get_handle(struct sftp_conn *conn, u_int expected_id, size_t *len,
usr.bin/ssh/sftp-client.c
1057
sftp_realpath(struct sftp_conn *conn, const char *path)
usr.bin/ssh/sftp-client.c
1059
return sftp_realpath_expand(conn, path, 0);
usr.bin/ssh/sftp-client.c
1063
sftp_can_expand_path(struct sftp_conn *conn)
usr.bin/ssh/sftp-client.c
1065
return (conn->exts & SFTP_EXT_PATH_EXPAND) != 0;
usr.bin/ssh/sftp-client.c
1069
sftp_expand_path(struct sftp_conn *conn, const char *path)
usr.bin/ssh/sftp-client.c
1071
if (!sftp_can_expand_path(conn)) {
usr.bin/ssh/sftp-client.c
1073
return sftp_realpath_expand(conn, path, 0);
usr.bin/ssh/sftp-client.c
1075
return sftp_realpath_expand(conn, path, 1);
usr.bin/ssh/sftp-client.c
1079
sftp_copy(struct sftp_conn *conn, const char *oldpath, const char *newpath)
usr.bin/ssh/sftp-client.c
1089
if ((conn->exts & SFTP_EXT_COPY_DATA) == 0) {
usr.bin/ssh/sftp-client.c
1095
if (sftp_stat(conn, oldpath, 0, &attr) != 0)
usr.bin/ssh/sftp-client.c
1122
id = conn->msg_id++;
usr.bin/ssh/sftp-client.c
1129
send_msg(conn, msg);
usr.bin/ssh/sftp-client.c
1134
old_handle = get_handle(conn, id, &old_handle_len,
usr.bin/ssh/sftp-client.c
1142
id = conn->msg_id++;
usr.bin/ssh/sftp-client.c
1150
send_msg(conn, msg);
usr.bin/ssh/sftp-client.c
1155
new_handle = get_handle(conn, id, &new_handle_len,
usr.bin/ssh/sftp-client.c
1164
id = conn->msg_id++;
usr.bin/ssh/sftp-client.c
1174
send_msg(conn, msg);
usr.bin/ssh/sftp-client.c
1178
status = get_status(conn, id);
usr.bin/ssh/sftp-client.c
1185
sftp_close(conn, old_handle, old_handle_len);
usr.bin/ssh/sftp-client.c
1186
sftp_close(conn, new_handle, new_handle_len);
usr.bin/ssh/sftp-client.c
1194
sftp_rename(struct sftp_conn *conn, const char *oldpath, const char *newpath,
usr.bin/ssh/sftp-client.c
1199
int r, use_ext = (conn->exts & SFTP_EXT_POSIX_RENAME) && !force_legacy;
usr.bin/ssh/sftp-client.c
1205
id = conn->msg_id++;
usr.bin/ssh/sftp-client.c
1224
send_msg(conn, msg);
usr.bin/ssh/sftp-client.c
1230
status = get_status(conn, id);
usr.bin/ssh/sftp-client.c
1239
sftp_hardlink(struct sftp_conn *conn, const char *oldpath, const char *newpath)
usr.bin/ssh/sftp-client.c
1245
if ((conn->exts & SFTP_EXT_HARDLINK) == 0) {
usr.bin/ssh/sftp-client.c
1256
id = conn->msg_id++;
usr.bin/ssh/sftp-client.c
1263
send_msg(conn, msg);
usr.bin/ssh/sftp-client.c
1268
status = get_status(conn, id);
usr.bin/ssh/sftp-client.c
1277
sftp_symlink(struct sftp_conn *conn, const char *oldpath, const char *newpath)
usr.bin/ssh/sftp-client.c
1283
if (conn->version < 3) {
usr.bin/ssh/sftp-client.c
1293
id = conn->msg_id++;
usr.bin/ssh/sftp-client.c
1299
send_msg(conn, msg);
usr.bin/ssh/sftp-client.c
1304
status = get_status(conn, id);
usr.bin/ssh/sftp-client.c
1313
sftp_fsync(struct sftp_conn *conn, u_char *handle, u_int handle_len)
usr.bin/ssh/sftp-client.c
1320
if ((conn->exts & SFTP_EXT_FSYNC) == 0)
usr.bin/ssh/sftp-client.c
1327
id = conn->msg_id++;
usr.bin/ssh/sftp-client.c
1333
send_msg(conn, msg);
usr.bin/ssh/sftp-client.c
1337
status = get_status(conn, id);
usr.bin/ssh/sftp-client.c
1346
sftp_readlink(struct sftp_conn *conn, const char *path)
usr.bin/ssh/sftp-client.c
1357
expected_id = id = conn->msg_id++;
usr.bin/ssh/sftp-client.c
1358
send_string_request(conn, id, SSH2_FXP_READLINK, path, strlen(path));
usr.bin/ssh/sftp-client.c
1363
get_msg(conn, msg);
usr.bin/ssh/sftp-client.c
1404
sftp_statvfs(struct sftp_conn *conn, const char *path, struct sftp_statvfs *st,
usr.bin/ssh/sftp-client.c
1411
if ((conn->exts & SFTP_EXT_STATVFS) == 0) {
usr.bin/ssh/sftp-client.c
1418
id = conn->msg_id++;
usr.bin/ssh/sftp-client.c
1427
send_msg(conn, msg);
usr.bin/ssh/sftp-client.c
143
send_msg(struct sftp_conn *conn, struct sshbuf *m)
usr.bin/ssh/sftp-client.c
1430
return get_decode_statvfs(conn, st, id, quiet);
usr.bin/ssh/sftp-client.c
1435
sftp_fstatvfs(struct sftp_conn *conn, const u_char *handle, u_int handle_len,
usr.bin/ssh/sftp-client.c
1441
if ((conn->exts & SFTP_EXT_FSTATVFS) == 0) {
usr.bin/ssh/sftp-client.c
1448
id = conn->msg_id++;
usr.bin/ssh/sftp-client.c
1457
send_msg(conn, msg);
usr.bin/ssh/sftp-client.c
1460
return get_decode_statvfs(conn, st, id, quiet);
usr.bin/ssh/sftp-client.c
1465
sftp_lsetstat(struct sftp_conn *conn, const char *path, Attrib *a)
usr.bin/ssh/sftp-client.c
1471
if ((conn->exts & SFTP_EXT_LSETSTAT) == 0) {
usr.bin/ssh/sftp-client.c
1478
id = conn->msg_id++;
usr.bin/ssh/sftp-client.c
1487
send_msg(conn, msg);
usr.bin/ssh/sftp-client.c
1490
status = get_status(conn, id);
usr.bin/ssh/sftp-client.c
1498
send_read_request(struct sftp_conn *conn, u_int id, uint64_t offset,
usr.bin/ssh/sftp-client.c
1512
send_msg(conn, msg);
usr.bin/ssh/sftp-client.c
1517
send_open(struct sftp_conn *conn, const char *path, const char *tag,
usr.bin/ssh/sftp-client.c
1539
id = conn->msg_id++;
usr.bin/ssh/sftp-client.c
1546
send_msg(conn, msg);
usr.bin/ssh/sftp-client.c
1550
if ((handle = get_handle(conn, id, &handle_len,
usr.bin/ssh/sftp-client.c
1573
sftp_download(struct sftp_conn *conn, const char *remote_path,
usr.bin/ssh/sftp-client.c
158
if (atomiciov6(writev, conn->fd_out, iov, 2, sftpio,
usr.bin/ssh/sftp-client.c
159
conn->limit_kbps > 0 ? &conn->bwlimit_out : NULL) !=
usr.bin/ssh/sftp-client.c
1597
if (sftp_stat(conn, remote_path, 0, &attr) != 0)
usr.bin/ssh/sftp-client.c
1619
buflen = conn->download_buflen;
usr.bin/ssh/sftp-client.c
1622
if (send_open(conn, remote_path, "remote", SSH2_FXF_READ, NULL,
usr.bin/ssh/sftp-client.c
1646
sftp_close(conn, handle, handle_len);
usr.bin/ssh/sftp-client.c
167
get_msg_extended(struct sftp_conn *conn, struct sshbuf *m, int initial)
usr.bin/ssh/sftp-client.c
1688
req = request_enqueue(&requests, conn->msg_id++,
usr.bin/ssh/sftp-client.c
1692
send_read_request(conn, req->id, req->offset,
usr.bin/ssh/sftp-client.c
1697
get_msg(conn, msg);
usr.bin/ssh/sftp-client.c
176
if (atomicio6(read, conn->fd_in, p, 4, sftpio,
usr.bin/ssh/sftp-client.c
1763
req->id = conn->msg_id++;
usr.bin/ssh/sftp-client.c
1766
send_read_request(conn, req->id,
usr.bin/ssh/sftp-client.c
177
conn->limit_kbps > 0 ? &conn->bwlimit_in : NULL) != 4) {
usr.bin/ssh/sftp-client.c
1780
} else if (max_req < conn->num_requests) {
usr.bin/ssh/sftp-client.c
1821
sftp_close(conn, handle, handle_len);
usr.bin/ssh/sftp-client.c
1826
sftp_close(conn, handle, handle_len);
usr.bin/ssh/sftp-client.c
1828
if (sftp_close(conn, handle, handle_len) != 0 || interrupted)
usr.bin/ssh/sftp-client.c
1863
download_dir_internal(struct sftp_conn *conn, const char *src, const char *dst,
usr.bin/ssh/sftp-client.c
1881
if (sftp_stat(conn, src, 1, &ldirattrib) != 0) {
usr.bin/ssh/sftp-client.c
1907
if (sftp_readdir(conn, src, &dir_entries) == -1) {
usr.bin/ssh/sftp-client.c
1928
if (sftp_stat(conn, new_src, 1, &lsym) != 0) {
usr.bin/ssh/sftp-client.c
1940
if (download_dir_internal(conn, new_src, new_dst,
usr.bin/ssh/sftp-client.c
1946
if (sftp_download(conn, new_src, new_dst, a,
usr.bin/ssh/sftp-client.c
195
if (atomicio6(read, conn->fd_in, p, msg_len, sftpio,
usr.bin/ssh/sftp-client.c
196
conn->limit_kbps > 0 ? &conn->bwlimit_in : NULL)
usr.bin/ssh/sftp-client.c
1984
sftp_download_dir(struct sftp_conn *conn, const char *src, const char *dst,
usr.bin/ssh/sftp-client.c
1991
if ((src_canon = sftp_realpath(conn, src)) == NULL) {
usr.bin/ssh/sftp-client.c
1996
ret = download_dir_internal(conn, src_canon, dst, 0,
usr.bin/ssh/sftp-client.c
2004
sftp_upload(struct sftp_conn *conn, const char *local_path,
usr.bin/ssh/sftp-client.c
2050
if (sftp_stat(conn, remote_path, 0, &c) != 0) {
usr.bin/ssh/sftp-client.c
206
get_msg(struct sftp_conn *conn, struct sshbuf *m)
usr.bin/ssh/sftp-client.c
2076
if (send_open(conn, remote_path, "dest", openmode, &a,
usr.bin/ssh/sftp-client.c
208
get_msg_extended(conn, m, 0);
usr.bin/ssh/sftp-client.c
2082
id = conn->msg_id;
usr.bin/ssh/sftp-client.c
2084
data = xmalloc(conn->upload_buflen);
usr.bin/ssh/sftp-client.c
2107
len = read(local_fd, data, conn->upload_buflen);
usr.bin/ssh/sftp-client.c
212
send_string_request(struct sftp_conn *conn, u_int id, u_int code, const char *s,
usr.bin/ssh/sftp-client.c
2123
send_msg(conn, msg);
usr.bin/ssh/sftp-client.c
2133
id - ackid >= conn->num_requests) {
usr.bin/ssh/sftp-client.c
2137
get_msg(conn, msg);
usr.bin/ssh/sftp-client.c
2200
sftp_fsetstat(conn, handle, handle_len, &t);
usr.bin/ssh/sftp-client.c
2210
sftp_fsetstat(conn, handle, handle_len, &a);
usr.bin/ssh/sftp-client.c
2213
(void)sftp_fsync(conn, handle, handle_len);
usr.bin/ssh/sftp-client.c
2215
if (sftp_close(conn, handle, handle_len) != 0)
usr.bin/ssh/sftp-client.c
2224
upload_dir_internal(struct sftp_conn *conn, const char *src, const char *dst,
usr.bin/ssh/sftp-client.c
224
send_msg(conn, msg);
usr.bin/ssh/sftp-client.c
225
debug3("Sent message fd %d T:%u I:%u", conn->fd_out, code, id);
usr.bin/ssh/sftp-client.c
2269
if (sftp_mkdir(conn, dst, &a, 0) == 0)
usr.bin/ssh/sftp-client.c
2272
if (sftp_stat(conn, dst, 0, &dirattrib) != 0)
usr.bin/ssh/sftp-client.c
230
send_string_attrs_request(struct sftp_conn *conn, u_int id, u_int code,
usr.bin/ssh/sftp-client.c
2317
if (upload_dir_internal(conn, new_src, new_dst,
usr.bin/ssh/sftp-client.c
2322
if (sftp_upload(conn, new_src, new_dst,
usr.bin/ssh/sftp-client.c
2336
sftp_setstat(conn, dst, &a);
usr.bin/ssh/sftp-client.c
2343
sftp_upload_dir(struct sftp_conn *conn, const char *src, const char *dst,
usr.bin/ssh/sftp-client.c
2350
if ((dst_canon = sftp_realpath(conn, dst)) == NULL) {
usr.bin/ssh/sftp-client.c
2355
ret = upload_dir_internal(conn, src, dst_canon, 0, preserve_flag,
usr.bin/ssh/sftp-client.c
243
send_msg(conn, msg);
usr.bin/ssh/sftp-client.c
245
conn->fd_out, code, id, a->flags, a->perm);
usr.bin/ssh/sftp-client.c
250
get_status(struct sftp_conn *conn, u_int expected_id)
usr.bin/ssh/sftp-client.c
259
get_msg(conn, msg);
usr.bin/ssh/sftp-client.c
280
get_handle(struct sftp_conn *conn, u_int expected_id, size_t *len,
usr.bin/ssh/sftp-client.c
2821
sftp_can_get_users_groups_by_id(struct sftp_conn *conn)
usr.bin/ssh/sftp-client.c
2823
return (conn->exts & SFTP_EXT_GETUSERSGROUPS_BY_ID) != 0;
usr.bin/ssh/sftp-client.c
2827
sftp_get_users_groups_by_id(struct sftp_conn *conn,
usr.bin/ssh/sftp-client.c
2839
if (!sftp_can_get_users_groups_by_id(conn))
usr.bin/ssh/sftp-client.c
2846
expected_id = id = conn->msg_id++;
usr.bin/ssh/sftp-client.c
2863
send_msg(conn, msg);
usr.bin/ssh/sftp-client.c
2864
get_msg(conn, msg);
usr.bin/ssh/sftp-client.c
2968
sftp_remote_is_dir(struct sftp_conn *conn, const char *path)
usr.bin/ssh/sftp-client.c
2973
if (sftp_stat(conn, path, 1, &a) != 0)
usr.bin/ssh/sftp-client.c
298
get_msg(conn, msg);
usr.bin/ssh/sftp-client.c
325
get_decode_stat(struct sftp_conn *conn, u_int expected_id, int quiet, Attrib *a)
usr.bin/ssh/sftp-client.c
337
get_msg(conn, msg);
usr.bin/ssh/sftp-client.c
376
get_decode_statvfs(struct sftp_conn *conn, struct sftp_statvfs *st,
usr.bin/ssh/sftp-client.c
387
get_msg(conn, msg);
usr.bin/ssh/sftp-client.c
583
sftp_free(struct sftp_conn *conn)
usr.bin/ssh/sftp-client.c
585
if (conn == NULL)
usr.bin/ssh/sftp-client.c
587
freezero(conn, sizeof(*conn));
usr.bin/ssh/sftp-client.c
591
sftp_proto_version(struct sftp_conn *conn)
usr.bin/ssh/sftp-client.c
593
return conn->version;
usr.bin/ssh/sftp-client.c
597
sftp_get_limits(struct sftp_conn *conn, struct sftp_limits *limits)
usr.bin/ssh/sftp-client.c
604
if ((conn->exts & SFTP_EXT_LIMITS) == 0) {
usr.bin/ssh/sftp-client.c
612
id = conn->msg_id++;
usr.bin/ssh/sftp-client.c
617
send_msg(conn, msg);
usr.bin/ssh/sftp-client.c
620
get_msg(conn, msg);
usr.bin/ssh/sftp-client.c
633
conn->exts &= ~SFTP_EXT_LIMITS;
usr.bin/ssh/sftp-client.c
651
sftp_close(struct sftp_conn *conn, const u_char *handle, u_int handle_len)
usr.bin/ssh/sftp-client.c
660
id = conn->msg_id++;
usr.bin/ssh/sftp-client.c
665
send_msg(conn, msg);
usr.bin/ssh/sftp-client.c
668
status = get_status(conn, id);
usr.bin/ssh/sftp-client.c
679
sftp_lsreaddir(struct sftp_conn *conn, const char *path, int print_flag,
usr.bin/ssh/sftp-client.c
692
id = conn->msg_id++;
usr.bin/ssh/sftp-client.c
700
send_msg(conn, msg);
usr.bin/ssh/sftp-client.c
702
handle = get_handle(conn, id, &handle_len,
usr.bin/ssh/sftp-client.c
716
id = expected_id = conn->msg_id++;
usr.bin/ssh/sftp-client.c
725
send_msg(conn, msg);
usr.bin/ssh/sftp-client.c
729
get_msg(conn, msg);
usr.bin/ssh/sftp-client.c
804
sftp_close(conn, handle, handle_len);
usr.bin/ssh/sftp-client.c
822
sftp_readdir(struct sftp_conn *conn, const char *path, SFTP_DIRENT ***dir)
usr.bin/ssh/sftp-client.c
824
return sftp_lsreaddir(conn, path, 0, dir);
usr.bin/ssh/sftp-client.c
842
sftp_rm(struct sftp_conn *conn, const char *path)
usr.bin/ssh/sftp-client.c
848
id = conn->msg_id++;
usr.bin/ssh/sftp-client.c
849
send_string_request(conn, id, SSH2_FXP_REMOVE, path, strlen(path));
usr.bin/ssh/sftp-client.c
850
status = get_status(conn, id);
usr.bin/ssh/sftp-client.c
857
sftp_mkdir(struct sftp_conn *conn, const char *path, Attrib *a, int print_flag)
usr.bin/ssh/sftp-client.c
863
id = conn->msg_id++;
usr.bin/ssh/sftp-client.c
864
send_string_attrs_request(conn, id, SSH2_FXP_MKDIR, path,
usr.bin/ssh/sftp-client.c
867
status = get_status(conn, id);
usr.bin/ssh/sftp-client.c
875
sftp_rmdir(struct sftp_conn *conn, const char *path)
usr.bin/ssh/sftp-client.c
881
id = conn->msg_id++;
usr.bin/ssh/sftp-client.c
882
send_string_request(conn, id, SSH2_FXP_RMDIR, path,
usr.bin/ssh/sftp-client.c
885
status = get_status(conn, id);
usr.bin/ssh/sftp-client.c
893
sftp_stat(struct sftp_conn *conn, const char *path, int quiet, Attrib *a)
usr.bin/ssh/sftp-client.c
899
id = conn->msg_id++;
usr.bin/ssh/sftp-client.c
901
send_string_request(conn, id,
usr.bin/ssh/sftp-client.c
902
conn->version == 0 ? SSH2_FXP_STAT_VERSION_0 : SSH2_FXP_STAT,
usr.bin/ssh/sftp-client.c
905
return get_decode_stat(conn, id, quiet, a);
usr.bin/ssh/sftp-client.c
909
sftp_lstat(struct sftp_conn *conn, const char *path, int quiet, Attrib *a)
usr.bin/ssh/sftp-client.c
913
if (conn->version == 0) {
usr.bin/ssh/sftp-client.c
916
return sftp_stat(conn, path, quiet, a);
usr.bin/ssh/sftp-client.c
919
id = conn->msg_id++;
usr.bin/ssh/sftp-client.c
920
send_string_request(conn, id, SSH2_FXP_LSTAT, path,
usr.bin/ssh/sftp-client.c
923
return get_decode_stat(conn, id, quiet, a);
usr.bin/ssh/sftp-client.c
928
sftp_fstat(struct sftp_conn *conn, const u_char *handle, u_int handle_len,
usr.bin/ssh/sftp-client.c
935
id = conn->msg_id++;
usr.bin/ssh/sftp-client.c
936
send_string_request(conn, id, SSH2_FXP_FSTAT, handle,
usr.bin/ssh/sftp-client.c
939
return get_decode_stat(conn, id, quiet, a);
usr.bin/ssh/sftp-client.c
944
sftp_setstat(struct sftp_conn *conn, const char *path, Attrib *a)
usr.bin/ssh/sftp-client.c
950
id = conn->msg_id++;
usr.bin/ssh/sftp-client.c
951
send_string_attrs_request(conn, id, SSH2_FXP_SETSTAT, path,
usr.bin/ssh/sftp-client.c
954
status = get_status(conn, id);
usr.bin/ssh/sftp-client.c
962
sftp_fsetstat(struct sftp_conn *conn, const u_char *handle, u_int handle_len,
usr.bin/ssh/sftp-client.c
969
id = conn->msg_id++;
usr.bin/ssh/sftp-client.c
970
send_string_attrs_request(conn, id, SSH2_FXP_FSETSTAT, handle,
usr.bin/ssh/sftp-client.c
973
status = get_status(conn, id);
usr.bin/ssh/sftp-client.c
982
sftp_realpath_expand(struct sftp_conn *conn, const char *path, int expand)
usr.bin/ssh/sftp-client.c
997
expected_id = id = conn->msg_id++;
usr.bin/ssh/sftp-client.h
106
int sftp_lsetstat(struct sftp_conn *conn, const char *path, Attrib *a);
usr.bin/ssh/sftp-client.h
133
int sftp_fsync(struct sftp_conn *conn, u_char *, u_int);
usr.bin/ssh/sftp-client.h
183
int sftp_can_get_users_groups_by_id(struct sftp_conn *conn);
usr.bin/ssh/sftp-client.h
184
int sftp_get_users_groups_by_id(struct sftp_conn *conn,
usr.bin/ssh/sftp-client.h
197
int sftp_remote_is_dir(struct sftp_conn *conn, const char *path);
usr.bin/ssh/sftp-glob.c
101
if (sftp_stat(cur.conn, path, 1, &a) != 0)
usr.bin/ssh/sftp-glob.c
110
sftp_glob(struct sftp_conn *conn, const char *pattern, int flags,
usr.bin/ssh/sftp-glob.c
125
cur.conn = conn;
usr.bin/ssh/sftp-glob.c
41
struct sftp_conn *conn;
usr.bin/ssh/sftp-glob.c
51
if (sftp_readdir(cur.conn, path, &r->dir)) {
usr.bin/ssh/sftp-glob.c
88
if (sftp_lstat(cur.conn, path, 1, &a) != 0)
usr.bin/ssh/sftp-usergroup.c
101
lookup_and_record(struct sftp_conn *conn,
usr.bin/ssh/sftp-usergroup.c
108
if ((r = sftp_get_users_groups_by_id(conn, uids, nuids, gids, ngids,
usr.bin/ssh/sftp-usergroup.c
174
get_remote_user_groups_from_glob(struct sftp_conn *conn, glob_t *g)
usr.bin/ssh/sftp-usergroup.c
178
if (!sftp_can_get_users_groups_by_id(conn))
usr.bin/ssh/sftp-usergroup.c
183
lookup_and_record(conn, uids, nuids, gids, ngids);
usr.bin/ssh/sftp-usergroup.c
213
get_remote_user_groups_from_dirents(struct sftp_conn *conn, SFTP_DIRENT **d)
usr.bin/ssh/sftp-usergroup.c
217
if (!sftp_can_get_users_groups_by_id(conn))
usr.bin/ssh/sftp-usergroup.c
222
lookup_and_record(conn, uids, nuids, gids, ngids);
usr.bin/ssh/sftp-usergroup.h
20
void get_remote_user_groups_from_glob(struct sftp_conn *conn, glob_t *g);
usr.bin/ssh/sftp-usergroup.h
21
void get_remote_user_groups_from_dirents(struct sftp_conn *conn, SFTP_DIRENT **d);
usr.bin/ssh/sftp.c
1021
get_remote_user_groups_from_glob(conn, &g);
usr.bin/ssh/sftp.c
1060
do_df(struct sftp_conn *conn, const char *path, int hflag, int iflag)
usr.bin/ssh/sftp.c
1067
if (sftp_statvfs(conn, path, &st, 1) == -1)
usr.bin/ssh/sftp.c
1531
parse_dispatch_command(struct sftp_conn *conn, const char *cmd, char **pwd,
usr.bin/ssh/sftp.c
1571
err = process_get(conn, path1, path2, *pwd, pflag,
usr.bin/ssh/sftp.c
1578
err = process_put(conn, path1, path2, *pwd, pflag,
usr.bin/ssh/sftp.c
1584
err = sftp_copy(conn, path1, path2);
usr.bin/ssh/sftp.c
1589
err = sftp_rename(conn, path1, path2, lflag);
usr.bin/ssh/sftp.c
1598
err = (sflag ? sftp_symlink : sftp_hardlink)(conn,
usr.bin/ssh/sftp.c
1603
sftp_glob(conn, path1, GLOB_NOCHECK, NULL, &g);
usr.bin/ssh/sftp.c
1607
err = sftp_rm(conn, g.gl_pathv[i]);
usr.bin/ssh/sftp.c
1617
err = sftp_mkdir(conn, path1, &a, 1);
usr.bin/ssh/sftp.c
1621
err = sftp_rmdir(conn, path1);
usr.bin/ssh/sftp.c
1627
if ((tmp = sftp_realpath(conn, path1)) == NULL) {
usr.bin/ssh/sftp.c
1631
if (sftp_stat(conn, tmp, 0, &aa) != 0) {
usr.bin/ssh/sftp.c
1654
do_ls_dir(conn, *pwd, *pwd, lflag);
usr.bin/ssh/sftp.c
1664
err = do_globbed_ls(conn, path1, tmp, lflag);
usr.bin/ssh/sftp.c
1671
err = do_df(conn, path1, hflag, iflag);
usr.bin/ssh/sftp.c
1707
sftp_glob(conn, path1, GLOB_NOCHECK, NULL, &g);
usr.bin/ssh/sftp.c
1712
err = (hflag ? sftp_lsetstat : sftp_setstat)(conn,
usr.bin/ssh/sftp.c
1721
sftp_glob(conn, path1, GLOB_NOCHECK, NULL, &g);
usr.bin/ssh/sftp.c
1723
if ((hflag ? sftp_lstat : sftp_stat)(conn,
usr.bin/ssh/sftp.c
1752
err = (hflag ? sftp_lsetstat : sftp_setstat)(conn,
usr.bin/ssh/sftp.c
1776
printf("SFTP protocol version %u\n", sftp_proto_version(conn));
usr.bin/ssh/sftp.c
1995
complete_match(EditLine *el, struct sftp_conn *conn, char *remote_path,
usr.bin/ssh/sftp.c
2016
sftp_glob(conn, tmp, GLOB_DOOFFS|GLOB_MARK, NULL, &g);
usr.bin/ssh/sftp.c
2191
complete_match(el, complete_ctx->conn,
usr.bin/ssh/sftp.c
2202
interactive_loop(struct sftp_conn *conn, char *file1, char *file2)
usr.bin/ssh/sftp.c
2232
complete_ctx.conn = conn;
usr.bin/ssh/sftp.c
2249
if ((remote_path = sftp_realpath(conn, ".")) == NULL)
usr.bin/ssh/sftp.c
2257
if (sftp_remote_is_dir(conn, dir) && file2 == NULL) {
usr.bin/ssh/sftp.c
2261
if (parse_dispatch_command(conn, cmd,
usr.bin/ssh/sftp.c
2266
free(conn);
usr.bin/ssh/sftp.c
2275
err = parse_dispatch_command(conn, cmd,
usr.bin/ssh/sftp.c
2280
free(conn);
usr.bin/ssh/sftp.c
2337
err = parse_dispatch_command(conn, cmd, &remote_path,
usr.bin/ssh/sftp.c
2345
free(conn);
usr.bin/ssh/sftp.c
2432
struct sftp_conn *conn;
usr.bin/ssh/sftp.c
2653
conn = sftp_init(in, out, copy_buffer_len, num_requests, limit_kbps);
usr.bin/ssh/sftp.c
2654
if (conn == NULL)
usr.bin/ssh/sftp.c
2664
err = interactive_loop(conn, file1, file2);
usr.bin/ssh/sftp.c
628
process_get(struct sftp_conn *conn, const char *src, const char *dst,
usr.bin/ssh/sftp.c
639
if ((r = sftp_glob(conn, abs_src, GLOB_MARK, NULL, &g)) != 0) {
usr.bin/ssh/sftp.c
696
if (sftp_download_dir(conn, g.gl_pathv[i], abs_dst,
usr.bin/ssh/sftp.c
701
if (sftp_download(conn, g.gl_pathv[i], abs_dst, NULL,
usr.bin/ssh/sftp.c
717
process_put(struct sftp_conn *conn, const char *src, const char *dst,
usr.bin/ssh/sftp.c
743
dst_is_dir = sftp_remote_is_dir(conn, tmp_dst);
usr.bin/ssh/sftp.c
796
if (sftp_upload_dir(conn, g.gl_pathv[i], abs_dst,
usr.bin/ssh/sftp.c
801
if (sftp_upload(conn, g.gl_pathv[i], abs_dst,
usr.bin/ssh/sftp.c
835
do_ls_dir(struct sftp_conn *conn, const char *path,
usr.bin/ssh/sftp.c
842
if ((n = sftp_readdir(conn, path, &d)) != 0)
usr.bin/ssh/sftp.c
877
get_remote_user_groups_from_dirents(conn, d);
usr.bin/ssh/sftp.c
890
sftp_can_get_users_groups_by_id(conn)) {
usr.bin/ssh/sftp.c
90
struct sftp_conn *conn;
usr.bin/ssh/sftp.c
950
do_globbed_ls(struct sftp_conn *conn, const char *path,
usr.bin/ssh/sftp.c
962
if ((r = sftp_glob(conn, path,
usr.bin/ssh/sftp.c
985
err = do_ls_dir(conn, g.gl_pathv[0], strip_path, lflag);
usr.sbin/acme-client/netproc.c
176
nreq(struct conn *c, const char *addr)
usr.sbin/acme-client/netproc.c
255
sreq(struct conn *c, const char *addr, int kid, const char *req, char **loc)
usr.sbin/acme-client/netproc.c
411
donewacc(struct conn *c, const struct capaths *p, const char *contact)
usr.sbin/acme-client/netproc.c
458
dochkacc(struct conn *c, const struct capaths *p, const char *contact)
usr.sbin/acme-client/netproc.c
495
doneworder(struct conn *c, struct domain_c *domain, struct order *order,
usr.sbin/acme-client/netproc.c
530
doupdorder(struct conn *c, struct order *order)
usr.sbin/acme-client/netproc.c
560
dochngreq(struct conn *c, const char *auth, struct chng *chng)
usr.sbin/acme-client/netproc.c
589
dochngresp(struct conn *c, const struct chng *chng)
usr.sbin/acme-client/netproc.c
612
docert(struct conn *c, const char *uri, const char *csr)
usr.sbin/acme-client/netproc.c
641
dogetcert(struct conn *c, const char *uri)
usr.sbin/acme-client/netproc.c
664
dorevoke(struct conn *c, const char *addr, const char *cert)
usr.sbin/acme-client/netproc.c
694
dodirs(struct conn *c, const char *addr, struct capaths *paths)
usr.sbin/acme-client/netproc.c
731
struct conn c;
usr.sbin/acme-client/netproc.c
738
memset(&c, 0, sizeof(struct conn));
usr.sbin/iscsid/connection.c
76
c->sev.conn = c;
usr.sbin/iscsid/iscsid.h
234
struct connection *conn;
usr.sbin/iscsid/session.c
280
struct connection *c = sev->conn;
usr.sbin/iscsid/session.c
283
if (sev->conn == NULL) {
usr.sbin/iscsid/session.c
326
struct connection *c = sev->conn;
usr.sbin/ldapd/auth.c
114
authorized(struct conn *conn, struct namespace *ns, int rights, char *dn,
usr.sbin/ldapd/auth.c
121
if (conn->binddn != NULL) {
usr.sbin/ldapd/auth.c
123
strcasecmp(conn->binddn, conf->rootdn) == 0)
usr.sbin/ldapd/auth.c
126
strcasecmp(conn->binddn, ns->rootdn) == 0)
usr.sbin/ldapd/auth.c
139
conn->binddn ? conn->binddn : "any",
usr.sbin/ldapd/auth.c
143
if (aci_matches(aci, conn, ns, dn, rights,
usr.sbin/ldapd/auth.c
159
if (aci_matches(aci, conn, ns, dn, rights,
usr.sbin/ldapd/auth.c
190
auth_req.fd = req->conn->fd;
usr.sbin/ldapd/auth.c
197
req->conn->bind_req = req;
usr.sbin/ldapd/auth.c
268
if ((req->conn->s_flags & F_SECURE) == 0) {
usr.sbin/ldapd/auth.c
289
free(req->conn->binddn);
usr.sbin/ldapd/auth.c
290
req->conn->binddn = NULL;
usr.sbin/ldapd/auth.c
291
if ((req->conn->pending_binddn = strdup(authcid)) == NULL)
usr.sbin/ldapd/auth.c
307
free(req->conn->binddn); /* anonymous bind */
usr.sbin/ldapd/auth.c
308
req->conn->binddn = NULL;
usr.sbin/ldapd/auth.c
313
if ((req->conn->s_flags & F_SECURE) == 0) {
usr.sbin/ldapd/auth.c
336
if (!authorized(req->conn, ns, ACI_BIND, binddn,
usr.sbin/ldapd/auth.c
35
aci_matches(struct aci *aci, struct conn *conn, struct namespace *ns,
usr.sbin/ldapd/auth.c
362
free(req->conn->binddn);
usr.sbin/ldapd/auth.c
363
req->conn->binddn = NULL;
usr.sbin/ldapd/auth.c
366
if ((req->conn->binddn = strdup(binddn)) == NULL)
usr.sbin/ldapd/auth.c
369
req->conn->binddn);
usr.sbin/ldapd/auth.c
372
if ((req->conn->pending_binddn = strdup(binddn)) == NULL)
usr.sbin/ldapd/auth.c
382
ldap_bind_continue(struct conn *conn, int ok)
usr.sbin/ldapd/auth.c
388
conn->binddn = conn->pending_binddn;
usr.sbin/ldapd/auth.c
389
log_debug("successfully authenticated as %s", conn->binddn);
usr.sbin/ldapd/auth.c
392
free(conn->pending_binddn);
usr.sbin/ldapd/auth.c
394
conn->pending_binddn = NULL;
usr.sbin/ldapd/auth.c
396
ldap_respond(conn->bind_req, rc);
usr.sbin/ldapd/auth.c
397
conn->bind_req = NULL;
usr.sbin/ldapd/auth.c
415
if (req->conn->bind_req) {
usr.sbin/ldapd/auth.c
417
req->conn->bind_req->msgid);
usr.sbin/ldapd/auth.c
418
request_free(req->conn->bind_req);
usr.sbin/ldapd/auth.c
419
req->conn->bind_req = NULL;
usr.sbin/ldapd/auth.c
92
if (conn->binddn == NULL)
usr.sbin/ldapd/auth.c
95
if (strcmp(dn, conn->binddn) != 0)
usr.sbin/ldapd/auth.c
97
} else if (strcmp(aci->subject, conn->binddn) != 0)
usr.sbin/ldapd/conn.c
121
if (req->conn->bind_req != NULL && req->type != LDAP_REQ_BIND) {
usr.sbin/ldapd/conn.c
141
conn_dispatch(struct conn *conn)
usr.sbin/ldapd/conn.c
151
conn_disconnect(conn);
usr.sbin/ldapd/conn.c
155
req->conn = conn;
usr.sbin/ldapd/conn.c
156
rptr = conn->ber.br_rptr; /* save where we start reading */
usr.sbin/ldapd/conn.c
158
if ((req->root = ober_read_elements(&conn->ber, NULL)) == NULL) {
usr.sbin/ldapd/conn.c
161
hexdump(rptr, conn->ber.br_rend - rptr,
usr.sbin/ldapd/conn.c
163
conn->ber.br_rend - rptr);
usr.sbin/ldapd/conn.c
164
conn_disconnect(conn);
usr.sbin/ldapd/conn.c
169
log_debug("consumed %ld bytes", conn->ber.br_rptr - rptr);
usr.sbin/ldapd/conn.c
177
"received invalid request on fd %d", conn->fd);
usr.sbin/ldapd/conn.c
178
conn_disconnect(conn);
usr.sbin/ldapd/conn.c
184
"received request on fd %d", conn->fd);
usr.sbin/ldapd/conn.c
195
struct conn *conn = data;
usr.sbin/ldapd/conn.c
199
ober_set_readbuf(&conn->ber,
usr.sbin/ldapd/conn.c
202
while (conn->ber.br_rend - conn->ber.br_rptr > 0) {
usr.sbin/ldapd/conn.c
203
if (conn_dispatch(conn) == 0)
usr.sbin/ldapd/conn.c
204
nused = conn->ber.br_rptr - conn->ber.br_rbuf;
usr.sbin/ldapd/conn.c
216
struct conn *conn = data;
usr.sbin/ldapd/conn.c
221
for (search = TAILQ_FIRST(&conn->searches); search; search = next) {
usr.sbin/ldapd/conn.c
226
if (conn->disconnect)
usr.sbin/ldapd/conn.c
227
conn_close(conn);
usr.sbin/ldapd/conn.c
228
else if (conn->s_flags & F_STARTTLS) {
usr.sbin/ldapd/conn.c
229
conn->s_flags &= ~F_STARTTLS;
usr.sbin/ldapd/conn.c
230
if (conn_tls_init(conn) == -1)
usr.sbin/ldapd/conn.c
231
conn_close(conn);
usr.sbin/ldapd/conn.c
238
struct conn *conn = data;
usr.sbin/ldapd/conn.c
241
log_debug("end-of-file on connection %d", conn->fd);
usr.sbin/ldapd/conn.c
243
log_debug("timeout on connection %d", conn->fd);
usr.sbin/ldapd/conn.c
246
why & EVBUFFER_WRITE ? "write" : "read", conn->fd);
usr.sbin/ldapd/conn.c
248
conn_close(conn);
usr.sbin/ldapd/conn.c
256
struct conn *conn;
usr.sbin/ldapd/conn.c
29
int conn_dispatch(struct conn *conn);
usr.sbin/ldapd/conn.c
296
if ((conn = calloc(1, sizeof(*conn))) == NULL) {
usr.sbin/ldapd/conn.c
30
int conn_tls_init(struct conn *);
usr.sbin/ldapd/conn.c
300
ober_set_application(&conn->ber, ldap_application);
usr.sbin/ldapd/conn.c
301
conn->fd = afd;
usr.sbin/ldapd/conn.c
302
conn->listener = l;
usr.sbin/ldapd/conn.c
304
conn->bev = bufferevent_new(afd, conn_read, conn_write,
usr.sbin/ldapd/conn.c
305
conn_err, conn);
usr.sbin/ldapd/conn.c
306
if (conn->bev == NULL) {
usr.sbin/ldapd/conn.c
308
free(conn);
usr.sbin/ldapd/conn.c
311
bufferevent_enable(conn->bev, EV_READ);
usr.sbin/ldapd/conn.c
312
bufferevent_settimeout(conn->bev, 0, 60);
usr.sbin/ldapd/conn.c
314
if (conn_tls_init(conn) == -1) {
usr.sbin/ldapd/conn.c
315
conn_close(conn);
usr.sbin/ldapd/conn.c
319
TAILQ_INIT(&conn->searches);
usr.sbin/ldapd/conn.c
320
TAILQ_INSERT_HEAD(&conn_list, conn, next);
usr.sbin/ldapd/conn.c
323
conn->s_flags |= F_SECURE;
usr.sbin/ldapd/conn.c
336
struct conn *
usr.sbin/ldapd/conn.c
339
struct conn *conn;
usr.sbin/ldapd/conn.c
341
TAILQ_FOREACH(conn, &conn_list, next) {
usr.sbin/ldapd/conn.c
342
if (conn->fd == fd)
usr.sbin/ldapd/conn.c
343
return conn;
usr.sbin/ldapd/conn.c
351
struct conn *conn;
usr.sbin/ldapd/conn.c
354
TAILQ_FOREACH_REVERSE(conn, &conn_list, conn_list, next) {
usr.sbin/ldapd/conn.c
355
if (namespace_conn_queue_count(conn) == 0) {
usr.sbin/ldapd/conn.c
356
conn_close(conn);
usr.sbin/ldapd/conn.c
362
conn = TAILQ_LAST(&conn_list, conn_list);
usr.sbin/ldapd/conn.c
363
if (conn != NULL) {
usr.sbin/ldapd/conn.c
364
conn_close(conn);
usr.sbin/ldapd/conn.c
372
conn_tls_init(struct conn *conn)
usr.sbin/ldapd/conn.c
374
struct listener *l = conn->listener;
usr.sbin/ldapd/conn.c
381
if (tls_accept_socket(l->tls, &conn->tls, conn->fd) < 0) {
usr.sbin/ldapd/conn.c
386
conn->s_flags |= F_SECURE;
usr.sbin/ldapd/conn.c
387
buffertls_set(&conn->buftls, conn->bev, conn->tls, conn->fd);
usr.sbin/ldapd/conn.c
388
buffertls_accept(&conn->buftls, conn->fd);
usr.sbin/ldapd/conn.c
50
conn_close(struct conn *conn)
usr.sbin/ldapd/conn.c
53
struct listener *l = conn->listener;
usr.sbin/ldapd/conn.c
55
log_debug("closing connection %d", conn->fd);
usr.sbin/ldapd/conn.c
58
for (search = TAILQ_FIRST(&conn->searches); search; search = next) {
usr.sbin/ldapd/conn.c
64
namespace_cancel_conn(conn);
usr.sbin/ldapd/conn.c
66
tls_free(conn->tls);
usr.sbin/ldapd/conn.c
68
TAILQ_REMOVE(&conn_list, conn, next);
usr.sbin/ldapd/conn.c
69
ober_free(&conn->ber);
usr.sbin/ldapd/conn.c
70
if (conn->bev != NULL)
usr.sbin/ldapd/conn.c
71
bufferevent_free(conn->bev);
usr.sbin/ldapd/conn.c
72
close(conn->fd);
usr.sbin/ldapd/conn.c
80
free(conn->binddn);
usr.sbin/ldapd/conn.c
81
free(conn->pending_binddn);
usr.sbin/ldapd/conn.c
82
free(conn);
usr.sbin/ldapd/conn.c
91
conn_disconnect(struct conn *conn)
usr.sbin/ldapd/conn.c
93
conn->disconnect = 1;
usr.sbin/ldapd/conn.c
94
bufferevent_enable(conn->bev, EV_WRITE);
usr.sbin/ldapd/ldapd.h
180
struct conn *conn;
usr.sbin/ldapd/ldapd.h
216
TAILQ_ENTRY(conn) next;
usr.sbin/ldapd/ldapd.h
232
TAILQ_HEAD(conn_list, conn);
usr.sbin/ldapd/ldapd.h
341
struct conn *conn_by_fd(int fd);
usr.sbin/ldapd/ldapd.h
346
void conn_close(struct conn *conn);
usr.sbin/ldapd/ldapd.h
348
void conn_disconnect(struct conn *conn);
usr.sbin/ldapd/ldapd.h
359
void send_ldap_result(struct conn *conn, int msgid,
usr.sbin/ldapd/ldapd.h
399
void namespace_cancel_conn(struct conn *conn);
usr.sbin/ldapd/ldapd.h
400
int namespace_conn_queue_count(struct conn *conn);
usr.sbin/ldapd/ldapd.h
452
void ldap_bind_continue(struct conn *conn, int ok);
usr.sbin/ldapd/ldapd.h
453
int authorized(struct conn *conn, struct namespace *ns,
usr.sbin/ldapd/ldapd.h
59
struct conn;
usr.sbin/ldapd/ldapd.h
89
struct conn *conn;
usr.sbin/ldapd/ldape.c
101
ober_get_writebuf(&conn->ber, &buf);
usr.sbin/ldapd/ldape.c
102
if (bufferevent_write(conn->bev, buf, rc) != 0)
usr.sbin/ldapd/ldape.c
167
rc = ober_write_elements(&req->conn->ber, root);
usr.sbin/ldapd/ldape.c
173
ober_get_writebuf(&req->conn->ber, &buf);
usr.sbin/ldapd/ldape.c
174
if (bufferevent_write(req->conn->bev, buf, rc) != 0)
usr.sbin/ldapd/ldape.c
189
send_ldap_result(struct conn *conn, int msgid, unsigned int type,
usr.sbin/ldapd/ldape.c
192
send_ldap_extended_response(conn, msgid, type, result_code, NULL);
usr.sbin/ldapd/ldape.c
199
send_ldap_result(req->conn, req->msgid, req->type + 1, code);
usr.sbin/ldapd/ldape.c
215
TAILQ_FOREACH(search, &req->conn->searches, next) {
usr.sbin/ldapd/ldape.c
230
req->conn->binddn == NULL ? "" : req->conn->binddn);
usr.sbin/ldapd/ldape.c
231
conn_disconnect(req->conn);
usr.sbin/ldapd/ldape.c
293
if ((req->conn->listener->flags & F_STARTTLS) == 0) {
usr.sbin/ldapd/ldape.c
298
req->conn->s_flags |= F_STARTTLS;
usr.sbin/ldapd/ldape.c
332
send_ldap_extended_response(req->conn, req->msgid, LDAP_RES_EXTENDED,
usr.sbin/ldapd/ldape.c
44
void send_ldap_extended_response(struct conn *conn,
usr.sbin/ldapd/ldape.c
533
struct conn *conn;
usr.sbin/ldapd/ldape.c
538
conn = conn_by_fd(ares->fd);
usr.sbin/ldapd/ldape.c
539
if (conn->bind_req != NULL && conn->bind_req->msgid == ares->msgid)
usr.sbin/ldapd/ldape.c
540
ldap_bind_continue(conn, ares->ok);
usr.sbin/ldapd/ldape.c
72
send_ldap_extended_response(struct conn *conn, int msgid, unsigned int type,
usr.sbin/ldapd/ldape.c
93
ldap_debug_elements(root, type, "sending response on fd %d", conn->fd);
usr.sbin/ldapd/ldape.c
95
rc = ober_write_elements(&conn->ber, root);
usr.sbin/ldapd/modify.c
106
!authorized(req->conn, ns, ACI_WRITE, dn, s,
usr.sbin/ldapd/modify.c
155
if (!authorized(req->conn, ns, ACI_WRITE, dn, NULL, LDAP_SCOPE_BASE))
usr.sbin/ldapd/modify.c
164
if (!authorized(req->conn, ns, ACI_WRITE, dn, s,
usr.sbin/ldapd/modify.c
196
if (ober_add_string(set, req->conn->binddn ? req->conn->binddn : "") == NULL)
usr.sbin/ldapd/modify.c
271
if (!authorized(req->conn, ns, ACI_WRITE, dn, attr,
usr.sbin/ldapd/modify.c
368
ober_add_string(set, req->conn->binddn ? req->conn->binddn : "");
usr.sbin/ldapd/modify.c
58
if (!authorized(req->conn, ns, ACI_WRITE, dn, NULL, LDAP_SCOPE_BASE))
usr.sbin/ldapd/namespace.c
212
struct conn *conn;
usr.sbin/ldapd/namespace.c
229
TAILQ_FOREACH(conn, &conn_list, next) {
usr.sbin/ldapd/namespace.c
230
for (search = TAILQ_FIRST(&conn->searches); search != NULL;
usr.sbin/ldapd/namespace.c
527
namespace_cancel_conn(struct conn *conn)
usr.sbin/ldapd/namespace.c
537
if (req->conn == conn) {
usr.sbin/ldapd/namespace.c
546
namespace_conn_queue_count(struct conn *conn)
usr.sbin/ldapd/namespace.c
554
if (req->conn == conn)
usr.sbin/ldapd/search.c
1006
bufferevent_enable(req->conn->bev, EV_WRITE);
usr.sbin/ldapd/search.c
101
struct conn *conn = search->conn;
usr.sbin/ldapd/search.c
1010
send_ldap_result(req->conn, req->msgid, LDAP_RES_SEARCH_RESULT, reason);
usr.sbin/ldapd/search.c
125
if (authorized(search->conn, search->ns, ACI_READ,
usr.sbin/ldapd/search.c
149
"sending search entry on fd %d", conn->fd);
usr.sbin/ldapd/search.c
151
rc = ober_write_elements(&conn->ber, root);
usr.sbin/ldapd/search.c
159
ober_get_writebuf(&conn->ber, &buf);
usr.sbin/ldapd/search.c
160
if (bufferevent_write(conn->bev, buf, rc) != 0) {
usr.sbin/ldapd/search.c
195
TAILQ_REMOVE(&search->conn->searches, search, next);
usr.sbin/ldapd/search.c
236
if (!authorized(search->conn, search->ns, ACI_READ, dn0,
usr.sbin/ldapd/search.c
300
struct conn *conn;
usr.sbin/ldapd/search.c
304
conn = search->conn;
usr.sbin/ldapd/search.c
457
search->conn->fd, search->req->msgid,
usr.sbin/ldapd/search.c
469
search->conn->fd, search->req->msgid,
usr.sbin/ldapd/search.c
477
bufferevent_enable(search->conn->bev, EV_WRITE);
usr.sbin/ldapd/search.c
481
send_ldap_result(conn, search->req->msgid,
usr.sbin/ldapd/search.c
531
if ((search->conn->s_flags & F_SECURE) == F_SECURE) {
usr.sbin/ldapd/search.c
540
send_ldap_result(search->conn, search->req->msgid,
usr.sbin/ldapd/search.c
627
send_ldap_result(search->conn, search->req->msgid,
usr.sbin/ldapd/search.c
867
search->conn = req->conn;
usr.sbin/ldapd/search.c
870
TAILQ_INSERT_HEAD(&req->conn->searches, search, next);
usr.sbin/ldapd/search.c
892
if (!authorized(req->conn, NULL, ACI_READ, "",
usr.sbin/ldapd/search.c
909
if (!authorized(req->conn, NULL, ACI_READ,
usr.sbin/ldapd/search.c
938
if (!authorized(req->conn, search->ns, ACI_READ,
usr.sbin/lpd/frontend.c
119
struct conn key, *conn;
usr.sbin/lpd/frontend.c
122
conn = SPLAY_FIND(conntree, &conns, &key);
usr.sbin/lpd/frontend.c
123
if (conn == NULL)
usr.sbin/lpd/frontend.c
126
l = conn->listener;
usr.sbin/lpd/frontend.c
129
log_debug("%08x close %s", conn->id,
usr.sbin/lpd/frontend.c
132
SPLAY_REMOVE(conntree, &conns, conn);
usr.sbin/lpd/frontend.c
133
free(conn);
usr.sbin/lpd/frontend.c
197
struct conn *conn;
usr.sbin/lpd/frontend.c
206
conn = calloc(1, sizeof(*conn));
usr.sbin/lpd/frontend.c
207
if (conn == NULL)
usr.sbin/lpd/frontend.c
219
free(conn);
usr.sbin/lpd/frontend.c
223
if (conn == NULL) {
usr.sbin/lpd/frontend.c
228
while (conn->id == 0 || SPLAY_FIND(conntree, &conns, conn))
usr.sbin/lpd/frontend.c
229
conn->id = arc4random();
usr.sbin/lpd/frontend.c
230
SPLAY_INSERT(conntree, &conns, conn);
usr.sbin/lpd/frontend.c
231
conn->listener = l;
usr.sbin/lpd/frontend.c
234
log_debug("%08x accept %s %s", conn->id,
usr.sbin/lpd/frontend.c
235
log_fmt_proto(conn->listener->proto),
usr.sbin/lpd/frontend.c
240
lpr_conn(conn->id, l, sock, sa);
usr.sbin/lpd/frontend.c
43
SPLAY_ENTRY(conn) entry;
usr.sbin/lpd/frontend.c
48
static int conn_cmp(struct conn *, struct conn *);
usr.sbin/lpd/frontend.c
50
SPLAY_HEAD(conntree, conn);
usr.sbin/lpd/frontend.c
51
SPLAY_PROTOTYPE(conntree, conn, entry, conn_cmp);
usr.sbin/lpd/frontend.c
57
conn_cmp(struct conn *a, struct conn *b)
usr.sbin/lpd/frontend.c
66
SPLAY_GENERATE(conntree, conn, entry, conn_cmp);
usr.sbin/lpd/frontend_lpr.c
108
struct lpr_conn *conn;
usr.sbin/lpd/frontend_lpr.c
110
if ((conn = calloc(1, sizeof(*conn))) == NULL) {
usr.sbin/lpd/frontend_lpr.c
116
conn->id = connid;
usr.sbin/lpd/frontend_lpr.c
117
conn->ifd = -1;
usr.sbin/lpd/frontend_lpr.c
118
conn->io = io_new();
usr.sbin/lpd/frontend_lpr.c
119
if (conn->io == NULL) {
usr.sbin/lpd/frontend_lpr.c
121
free(conn);
usr.sbin/lpd/frontend_lpr.c
126
SPLAY_INSERT(lpr_conn_tree, &conns, conn);
usr.sbin/lpd/frontend_lpr.c
127
io_set_callback(conn->io, lpr_io_dispatch, conn);
usr.sbin/lpd/frontend_lpr.c
128
io_set_timeout(conn->io, CLIENT_TIMEOUT);
usr.sbin/lpd/frontend_lpr.c
129
io_set_write(conn->io);
usr.sbin/lpd/frontend_lpr.c
130
io_attach(conn->io, sock);
usr.sbin/lpd/frontend_lpr.c
132
conn->state = STATE_READ_COMMAND;
usr.sbin/lpd/frontend_lpr.c
133
m_create(p_engine, IMSG_LPR_ALLOWEDHOST, conn->id, 0, -1);
usr.sbin/lpd/frontend_lpr.c
141
struct lpr_conn *conn = NULL, key;
usr.sbin/lpd/frontend_lpr.c
148
conn = SPLAY_FIND(lpr_conn_tree, &conns, &key);
usr.sbin/lpd/frontend_lpr.c
149
if (conn == NULL) {
usr.sbin/lpd/frontend_lpr.c
160
lpr_on_allowedhost(conn, hostname, reject);
usr.sbin/lpd/frontend_lpr.c
166
lpr_on_recvjob(conn, ack);
usr.sbin/lpd/frontend_lpr.c
175
lpr_on_recvjob_file(conn, ack, sz, cf, imsg_get_fd(imsg));
usr.sbin/lpd/frontend_lpr.c
183
lpr_on_request(conn, imsg_get_fd(imsg), hostname, cmd);
usr.sbin/lpd/frontend_lpr.c
193
lpr_on_allowedhost(struct lpr_conn *conn, const char *hostname,
usr.sbin/lpd/frontend_lpr.c
196
strlcpy(conn->hostname, hostname, sizeof(conn->hostname));
usr.sbin/lpd/frontend_lpr.c
198
lpr_reply(conn, reject);
usr.sbin/lpd/frontend_lpr.c
200
io_set_read(conn->io);
usr.sbin/lpd/frontend_lpr.c
204
lpr_on_recvjob(struct lpr_conn *conn, int ack)
usr.sbin/lpd/frontend_lpr.c
207
conn->recvjob = 1;
usr.sbin/lpd/frontend_lpr.c
209
log_debug("%08x recvjob failed", conn->id);
usr.sbin/lpd/frontend_lpr.c
210
lpr_ack(conn, ack);
usr.sbin/lpd/frontend_lpr.c
214
lpr_on_recvjob_file(struct lpr_conn *conn, int ack, size_t sz, int cf, int fd)
usr.sbin/lpd/frontend_lpr.c
217
lpr_ack(conn, ack);
usr.sbin/lpd/frontend_lpr.c
223
lpr_ack(conn, LPR_NACK);
usr.sbin/lpd/frontend_lpr.c
227
conn->ofp = fdopen(fd, "w");
usr.sbin/lpd/frontend_lpr.c
228
if (conn->ofp == NULL) {
usr.sbin/lpd/frontend_lpr.c
231
lpr_ack(conn, LPR_NACK);
usr.sbin/lpd/frontend_lpr.c
235
conn->expect = sz;
usr.sbin/lpd/frontend_lpr.c
237
conn->recvcf = cf;
usr.sbin/lpd/frontend_lpr.c
238
conn->state = STATE_READ_FILE;
usr.sbin/lpd/frontend_lpr.c
240
lpr_ack(conn, LPR_ACK);
usr.sbin/lpd/frontend_lpr.c
244
lpr_on_request(struct lpr_conn *conn, int fd, const char *hostname,
usr.sbin/lpd/frontend_lpr.c
251
lpr_close(conn);
usr.sbin/lpd/frontend_lpr.c
255
log_debug("%08x stream init", conn->id);
usr.sbin/lpd/frontend_lpr.c
256
conn->ifd = fd;
usr.sbin/lpd/frontend_lpr.c
260
log_debug("%08x forwarding to %s: \\%d%s", conn->id, hostname,
usr.sbin/lpd/frontend_lpr.c
262
conn->cmd = strdup(cmd);
usr.sbin/lpd/frontend_lpr.c
263
if (conn->cmd == NULL)
usr.sbin/lpd/frontend_lpr.c
268
conn->flags |= F_WAITADDRINFO;
usr.sbin/lpd/frontend_lpr.c
274
lpr_on_getaddrinfo, conn);
usr.sbin/lpd/frontend_lpr.c
278
lpr_stream(conn);
usr.sbin/lpd/frontend_lpr.c
284
struct lpr_conn *conn = arg;
usr.sbin/lpd/frontend_lpr.c
286
conn->flags &= ~F_WAITADDRINFO;
usr.sbin/lpd/frontend_lpr.c
287
if (conn->flags & F_ZOMBIE) {
usr.sbin/lpd/frontend_lpr.c
290
lpr_free(conn);
usr.sbin/lpd/frontend_lpr.c
293
conn->ai_done = 1;
usr.sbin/lpd/frontend_lpr.c
294
conn->ai = ai;
usr.sbin/lpd/frontend_lpr.c
295
lpr_forward(conn);
usr.sbin/lpd/frontend_lpr.c
302
struct lpr_conn *conn = arg;
usr.sbin/lpd/frontend_lpr.c
307
switch(conn->state) {
usr.sbin/lpd/frontend_lpr.c
309
r = lpr_readcommand(conn);
usr.sbin/lpd/frontend_lpr.c
312
r = lpr_readfile(conn);
usr.sbin/lpd/frontend_lpr.c
315
fatal("%s: unexpected state %d", __func__, conn->state);
usr.sbin/lpd/frontend_lpr.c
319
io_set_write(conn->io);
usr.sbin/lpd/frontend_lpr.c
323
if (conn->recvjob)
usr.sbin/lpd/frontend_lpr.c
324
io_set_read(conn->io);
usr.sbin/lpd/frontend_lpr.c
325
else if (conn->ifd != -1)
usr.sbin/lpd/frontend_lpr.c
326
lpr_stream(conn);
usr.sbin/lpd/frontend_lpr.c
327
else if (conn->cmd == NULL)
usr.sbin/lpd/frontend_lpr.c
328
lpr_close(conn);
usr.sbin/lpd/frontend_lpr.c
332
log_debug("%08x disconnected", conn->id);
usr.sbin/lpd/frontend_lpr.c
338
if (conn->recvcf && conn->state == STATE_READ_COMMAND) {
usr.sbin/lpd/frontend_lpr.c
343
m_compose(p_engine, IMSG_LPR_RECVJOB_COMMIT, conn->id,
usr.sbin/lpd/frontend_lpr.c
345
conn->recvjob = 0;
usr.sbin/lpd/frontend_lpr.c
350
log_debug("%08x timeout", conn->id);
usr.sbin/lpd/frontend_lpr.c
354
log_debug("%08x io-error", conn->id);
usr.sbin/lpd/frontend_lpr.c
361
lpr_close(conn);
usr.sbin/lpd/frontend_lpr.c
365
lpr_readcommand(struct lpr_conn *conn)
usr.sbin/lpd/frontend_lpr.c
373
line = io_getline(conn->io, NULL);
usr.sbin/lpd/frontend_lpr.c
375
if (io_datalen(conn->io) >= LPR_MAXCMDLEN) {
usr.sbin/lpd/frontend_lpr.c
376
lpr_reply(conn, "Request line too long");
usr.sbin/lpd/frontend_lpr.c
386
lpr_reply(conn, "No command");
usr.sbin/lpd/frontend_lpr.c
390
log_debug("%08x cmd \\%d", conn->id, cmd);
usr.sbin/lpd/frontend_lpr.c
401
lpr_reply(conn, "Argument list too long");
usr.sbin/lpd/frontend_lpr.c
406
lpr_reply(conn, "No queue specified");
usr.sbin/lpd/frontend_lpr.c
413
if (conn->recvjob)
usr.sbin/lpd/frontend_lpr.c
420
lpr_ack(conn, LPR_ACK);
usr.sbin/lpd/frontend_lpr.c
424
m_create(p_engine, IMSG_LPR_RECVJOB, conn->id, 0, -1);
usr.sbin/lpd/frontend_lpr.c
425
m_add_string(p_engine, conn->hostname);
usr.sbin/lpd/frontend_lpr.c
432
if (lpr_parsejobfilter(conn, &jf, argc - 1, argv + 1) == -1)
usr.sbin/lpd/frontend_lpr.c
435
m_create(p_engine, IMSG_LPR_DISPLAYQ, conn->id, 0, -1);
usr.sbin/lpd/frontend_lpr.c
437
m_add_string(p_engine, conn->hostname);
usr.sbin/lpd/frontend_lpr.c
450
lpr_reply(conn, "No agent specified");
usr.sbin/lpd/frontend_lpr.c
453
if (lpr_parsejobfilter(conn, &jf, argc - 2, argv + 2) == -1)
usr.sbin/lpd/frontend_lpr.c
456
m_create(p_engine, IMSG_LPR_RMJOB, conn->id, 0, -1);
usr.sbin/lpd/frontend_lpr.c
457
m_add_string(p_engine, conn->hostname);
usr.sbin/lpd/frontend_lpr.c
470
m_compose(p_engine, IMSG_LPR_RECVJOB_CLEAR, conn->id, 0, -1,
usr.sbin/lpd/frontend_lpr.c
472
conn->recvcf = 0;
usr.sbin/lpd/frontend_lpr.c
473
lpr_ack(conn, LPR_ACK);
usr.sbin/lpd/frontend_lpr.c
479
log_debug("%08x invalid number of argument", conn->id);
usr.sbin/lpd/frontend_lpr.c
480
lpr_ack(conn, LPR_NACK);
usr.sbin/lpd/frontend_lpr.c
486
log_debug("%08x invalid file size: %s", conn->id,
usr.sbin/lpd/frontend_lpr.c
488
lpr_ack(conn, LPR_NACK);
usr.sbin/lpd/frontend_lpr.c
493
if (conn->recvcf) {
usr.sbin/lpd/frontend_lpr.c
495
conn->id);
usr.sbin/lpd/frontend_lpr.c
496
lpr_ack(conn, LPR_NACK);
usr.sbin/lpd/frontend_lpr.c
499
m_create(p_engine, IMSG_LPR_RECVJOB_CF, conn->id, 0,
usr.sbin/lpd/frontend_lpr.c
503
m_create(p_engine, IMSG_LPR_RECVJOB_DF, conn->id, 0,
usr.sbin/lpd/frontend_lpr.c
511
if (conn->recvjob)
usr.sbin/lpd/frontend_lpr.c
512
lpr_reply(conn, "Protocol error");
usr.sbin/lpd/frontend_lpr.c
514
lpr_reply(conn, "Illegal service request");
usr.sbin/lpd/frontend_lpr.c
520
lpr_readfile(struct lpr_conn *conn)
usr.sbin/lpd/frontend_lpr.c
525
if (conn->expect) {
usr.sbin/lpd/frontend_lpr.c
527
data = io_data(conn->io);
usr.sbin/lpd/frontend_lpr.c
528
len = io_datalen(conn->io);
usr.sbin/lpd/frontend_lpr.c
529
if (len > conn->expect)
usr.sbin/lpd/frontend_lpr.c
530
len = conn->expect;
usr.sbin/lpd/frontend_lpr.c
532
log_debug("%08x %zu bytes received", conn->id, len);
usr.sbin/lpd/frontend_lpr.c
534
w = fwrite(data, 1, len, conn->ofp);
usr.sbin/lpd/frontend_lpr.c
537
lpr_close(conn);
usr.sbin/lpd/frontend_lpr.c
540
io_drop(conn->io, w);
usr.sbin/lpd/frontend_lpr.c
541
conn->expect -= w;
usr.sbin/lpd/frontend_lpr.c
542
if (conn->expect)
usr.sbin/lpd/frontend_lpr.c
545
fclose(conn->ofp);
usr.sbin/lpd/frontend_lpr.c
546
conn->ofp = NULL;
usr.sbin/lpd/frontend_lpr.c
548
log_debug("%08x file received", conn->id);
usr.sbin/lpd/frontend_lpr.c
552
len = io_datalen(conn->io);
usr.sbin/lpd/frontend_lpr.c
555
data = io_data(conn->io);
usr.sbin/lpd/frontend_lpr.c
556
io_drop(conn->io, 1);
usr.sbin/lpd/frontend_lpr.c
558
log_debug("%08x eof %d", conn->id, (int)*data);
usr.sbin/lpd/frontend_lpr.c
561
lpr_close(conn);
usr.sbin/lpd/frontend_lpr.c
565
conn->state = STATE_READ_COMMAND;
usr.sbin/lpd/frontend_lpr.c
566
lpr_ack(conn, LPR_ACK);
usr.sbin/lpd/frontend_lpr.c
571
lpr_parsejobfilter(struct lpr_conn *conn, struct lp_jobfilter *jf, int argc,
usr.sbin/lpd/frontend_lpr.c
584
lpr_reply(conn, "Too many requests");
usr.sbin/lpd/frontend_lpr.c
590
lpr_reply(conn, "Invalid job number");
usr.sbin/lpd/frontend_lpr.c
597
lpr_reply(conn, "Too many users");
usr.sbin/lpd/frontend_lpr.c
608
lpr_free(struct lpr_conn *conn)
usr.sbin/lpd/frontend_lpr.c
610
if ((conn->flags & F_WAITADDRINFO) == 0)
usr.sbin/lpd/frontend_lpr.c
611
free(conn);
usr.sbin/lpd/frontend_lpr.c
615
lpr_close(struct lpr_conn *conn)
usr.sbin/lpd/frontend_lpr.c
617
uint32_t connid = conn->id;
usr.sbin/lpd/frontend_lpr.c
619
SPLAY_REMOVE(lpr_conn_tree, &conns, conn);
usr.sbin/lpd/frontend_lpr.c
621
if (conn->recvjob)
usr.sbin/lpd/frontend_lpr.c
622
m_compose(p_engine, IMSG_LPR_RECVJOB_ROLLBACK, conn->id, 0, -1,
usr.sbin/lpd/frontend_lpr.c
625
io_free(conn->io);
usr.sbin/lpd/frontend_lpr.c
626
free(conn->cmd);
usr.sbin/lpd/frontend_lpr.c
627
if (conn->ofp)
usr.sbin/lpd/frontend_lpr.c
628
fclose(conn->ofp);
usr.sbin/lpd/frontend_lpr.c
629
if (conn->ifd != -1)
usr.sbin/lpd/frontend_lpr.c
630
close(conn->ifd);
usr.sbin/lpd/frontend_lpr.c
631
if (conn->ai)
usr.sbin/lpd/frontend_lpr.c
632
freeaddrinfo(conn->ai);
usr.sbin/lpd/frontend_lpr.c
633
if (conn->iofwd)
usr.sbin/lpd/frontend_lpr.c
634
io_free(conn->iofwd);
usr.sbin/lpd/frontend_lpr.c
636
conn->flags |= F_ZOMBIE;
usr.sbin/lpd/frontend_lpr.c
637
lpr_free(conn);
usr.sbin/lpd/frontend_lpr.c
643
lpr_ack(struct lpr_conn *conn, char c)
usr.sbin/lpd/frontend_lpr.c
646
log_debug("%08x ack", conn->id);
usr.sbin/lpd/frontend_lpr.c
648
log_debug("%08x nack %d", conn->id, (int)c);
usr.sbin/lpd/frontend_lpr.c
650
io_write(conn->io, &c, 1);
usr.sbin/lpd/frontend_lpr.c
654
lpr_reply(struct lpr_conn *conn, const char *s)
usr.sbin/lpd/frontend_lpr.c
656
log_debug("%08x reply: %s", conn->id, s);
usr.sbin/lpd/frontend_lpr.c
658
io_printf(conn->io, "%s\n", s);
usr.sbin/lpd/frontend_lpr.c
665
lpr_stream(struct lpr_conn *conn)
usr.sbin/lpd/frontend_lpr.c
671
if (io_queued(conn->io) > 65536)
usr.sbin/lpd/frontend_lpr.c
674
r = read(conn->ifd, buf, sizeof(buf));
usr.sbin/lpd/frontend_lpr.c
683
log_debug("%08x stream done", conn->id);
usr.sbin/lpd/frontend_lpr.c
686
log_debug("%08x stream %zu bytes", conn->id, r);
usr.sbin/lpd/frontend_lpr.c
688
if (io_write(conn->io, buf, r) == -1) {
usr.sbin/lpd/frontend_lpr.c
694
close(conn->ifd);
usr.sbin/lpd/frontend_lpr.c
695
conn->ifd = -1;
usr.sbin/lpd/frontend_lpr.c
697
if (conn->cmd)
usr.sbin/lpd/frontend_lpr.c
698
lpr_forward(conn);
usr.sbin/lpd/frontend_lpr.c
700
else if (io_queued(conn->io) == 0)
usr.sbin/lpd/frontend_lpr.c
701
lpr_close(conn);
usr.sbin/lpd/frontend_lpr.c
708
lpr_forward(struct lpr_conn *conn)
usr.sbin/lpd/frontend_lpr.c
714
if (!conn->ai_done || conn->ifd == -1)
usr.sbin/lpd/frontend_lpr.c
717
if (conn->ai == NULL) {
usr.sbin/lpd/frontend_lpr.c
718
if (io_queued(conn->io) == 0)
usr.sbin/lpd/frontend_lpr.c
719
lpr_close(conn);
usr.sbin/lpd/frontend_lpr.c
723
log_debug("%08x forward start", conn->id);
usr.sbin/lpd/frontend_lpr.c
725
conn->iofwd = io_new();
usr.sbin/lpd/frontend_lpr.c
726
if (conn->iofwd == NULL) {
usr.sbin/lpd/frontend_lpr.c
728
if (io_queued(conn->io) == 0)
usr.sbin/lpd/frontend_lpr.c
729
lpr_close(conn);
usr.sbin/lpd/frontend_lpr.c
732
io_set_callback(conn->iofwd, lpr_iofwd_dispatch, conn);
usr.sbin/lpd/frontend_lpr.c
733
io_set_timeout(conn->io, SERVER_TIMEOUT);
usr.sbin/lpd/frontend_lpr.c
734
io_connect(conn->iofwd, conn->ai);
usr.sbin/lpd/frontend_lpr.c
735
conn->ai = NULL;
usr.sbin/lpd/frontend_lpr.c
741
struct lpr_conn *conn = arg;
usr.sbin/lpd/frontend_lpr.c
745
log_debug("%08x forward connected", conn->id);
usr.sbin/lpd/frontend_lpr.c
747
io_print(io, conn->cmd);
usr.sbin/lpd/frontend_lpr.c
754
io_write(conn->io, io_data(io), io_datalen(io));
usr.sbin/lpd/frontend_lpr.c
767
log_debug("%08x forward disconnected", conn->id);
usr.sbin/lpd/frontend_lpr.c
771
log_debug("%08x forward timeout", conn->id);
usr.sbin/lpd/frontend_lpr.c
775
log_debug("%08x forward io-error", conn->id);
usr.sbin/lpd/frontend_lpr.c
782
log_debug("%08x forward done", conn->id);
usr.sbin/lpd/frontend_lpr.c
785
free(conn->cmd);
usr.sbin/lpd/frontend_lpr.c
786
conn->cmd = NULL;
usr.sbin/lpd/frontend_lpr.c
787
conn->iofwd = NULL;
usr.sbin/lpd/frontend_lpr.c
788
if (io_queued(conn->io) == 0)
usr.sbin/lpd/frontend_lpr.c
789
lpr_close(conn);
usr.sbin/nsd/ipc.h
40
struct xfrd_tcp *conn;
usr.sbin/nsd/server.c
1718
((struct ipc_handler_conn_data*)nsd->xfrd_listener->user_data)->conn =
usr.sbin/nsd/server.c
1835
data->conn->is_reading = 0;
usr.sbin/nsd/server.c
3066
->conn->is_reading = 0;
usr.sbin/nsd/server.c
3630
user_data->conn = xfrd_tcp_create(server_region, QIOBUFSZ);
usr.sbin/nsd/xfrd-tcp.c
1685
int conn = zone->tcp_conn;
usr.sbin/nsd/xfrd-tcp.c
1686
struct xfrd_tcp_pipeline* tp = set->tcp_state[conn];
usr.sbin/nsd/xfrd-tcp.c
1715
zone->tcp_conn = conn;
usr.sbin/nsd/xfrd-tcp.c
1728
xfrd_tcp_pipe_release(set, tp, conn);
usr.sbin/nsd/xfrd-tcp.c
1733
int conn)
usr.sbin/nsd/xfrd-tcp.c
1768
zone->tcp_conn = conn;
usr.sbin/nsd/xfrd-tcp.c
718
int conn = -1;
usr.sbin/nsd/xfrd-tcp.c
727
conn = zone->tcp_conn;
usr.sbin/nsd/xfrd-tcp.c
736
assert(conn != -1);
usr.sbin/nsd/xfrd-tcp.c
738
xfrd_tcp_pipe_release(xfrd->tcp_set, tp, conn);
usr.sbin/nsd/xfrd-tcp.c
910
int fd, family, conn;
usr.sbin/nsd/xfrd-tcp.c
982
conn = connect(fd, (struct sockaddr*)&tp->key.ip, tp->key.ip_len);
usr.sbin/nsd/xfrd-tcp.c
983
if (conn == -1 && errno != EINPROGRESS) {
usr.sbin/nsd/xfrd-tcp.h
192
struct xfrd_tcp_pipeline* tp, int conn);
usr.sbin/nsd/xfrd-tcp.h
215
int conn_read(struct xfrd_tcp* conn);
usr.sbin/nsd/xfrd-tcp.h
223
int conn_write(struct xfrd_tcp* conn);
usr.sbin/rpki-client/http.c
1000
conn->events = POLLOUT;
usr.sbin/rpki-client/http.c
1003
errx(1, "%s: unexpected function return", conn_info(conn));
usr.sbin/rpki-client/http.c
1011
http_connect_done(struct http_connection *conn)
usr.sbin/rpki-client/http.c
1014
return proxy_connect(conn);
usr.sbin/rpki-client/http.c
1015
return http_tls_connect(conn);
usr.sbin/rpki-client/http.c
1022
http_connect(struct http_connection *conn)
usr.sbin/rpki-client/http.c
1027
assert(conn->fd == -1);
usr.sbin/rpki-client/http.c
1028
conn->state = STATE_CONNECT;
usr.sbin/rpki-client/http.c
1031
if (conn->res == NULL)
usr.sbin/rpki-client/http.c
1032
conn->res = conn->res0;
usr.sbin/rpki-client/http.c
1034
conn->res = conn->res->ai_next;
usr.sbin/rpki-client/http.c
1035
for (; conn->res != NULL; conn->res = conn->res->ai_next) {
usr.sbin/rpki-client/http.c
1038
res = conn->res;
usr.sbin/rpki-client/http.c
1045
conn->fd = fd;
usr.sbin/rpki-client/http.c
1048
if (bind(conn->fd, (struct sockaddr *)&http_bindaddr,
usr.sbin/rpki-client/http.c
1051
close(conn->fd);
usr.sbin/rpki-client/http.c
1052
conn->fd = -1;
usr.sbin/rpki-client/http.c
1059
if (connect(conn->fd, res->ai_addr, res->ai_addrlen) == -1) {
usr.sbin/rpki-client/http.c
1065
close(conn->fd);
usr.sbin/rpki-client/http.c
1066
conn->fd = -1;
usr.sbin/rpki-client/http.c
1076
if (conn->fd == -1) {
usr.sbin/rpki-client/http.c
1078
conn->res = res;
usr.sbin/rpki-client/http.c
1079
warn("%s: %s", conn_info(conn), cause);
usr.sbin/rpki-client/http.c
1081
return http_failed(conn);
usr.sbin/rpki-client/http.c
1084
return http_connect_done(conn);
usr.sbin/rpki-client/http.c
1091
http_finish_connect(struct http_connection *conn)
usr.sbin/rpki-client/http.c
1097
if (getsockopt(conn->fd, SOL_SOCKET, SO_ERROR, &error, &len) == -1) {
usr.sbin/rpki-client/http.c
1098
warn("%s: getsockopt SO_ERROR", conn_info(conn));
usr.sbin/rpki-client/http.c
1099
return http_connect_failed(conn);
usr.sbin/rpki-client/http.c
1103
warn("%s: connect", conn_info(conn));
usr.sbin/rpki-client/http.c
1104
return http_connect_failed(conn);
usr.sbin/rpki-client/http.c
1107
return http_connect_done(conn);
usr.sbin/rpki-client/http.c
1114
http_tls_connect(struct http_connection *conn)
usr.sbin/rpki-client/http.c
1116
assert(conn->state == STATE_CONNECT);
usr.sbin/rpki-client/http.c
1117
conn->state = STATE_TLSCONNECT;
usr.sbin/rpki-client/http.c
1119
if ((conn->tls = tls_client()) == NULL) {
usr.sbin/rpki-client/http.c
1121
return http_failed(conn);
usr.sbin/rpki-client/http.c
1123
if (tls_configure(conn->tls, tls_config) == -1) {
usr.sbin/rpki-client/http.c
1124
warnx("%s: TLS configuration: %s", conn_info(conn),
usr.sbin/rpki-client/http.c
1125
tls_error(conn->tls));
usr.sbin/rpki-client/http.c
1126
return http_failed(conn);
usr.sbin/rpki-client/http.c
1128
if (tls_connect_socket(conn->tls, conn->fd, conn->host) == -1) {
usr.sbin/rpki-client/http.c
1129
warnx("%s: TLS connect: %s", conn_info(conn),
usr.sbin/rpki-client/http.c
1130
tls_error(conn->tls));
usr.sbin/rpki-client/http.c
1131
return http_failed(conn);
usr.sbin/rpki-client/http.c
1134
return http_tls_handshake(conn);
usr.sbin/rpki-client/http.c
1141
http_tls_handshake(struct http_connection *conn)
usr.sbin/rpki-client/http.c
1143
switch (tls_handshake(conn->tls)) {
usr.sbin/rpki-client/http.c
1145
warnx("%s: TLS handshake: %s", conn_info(conn),
usr.sbin/rpki-client/http.c
1146
tls_error(conn->tls));
usr.sbin/rpki-client/http.c
1147
return http_failed(conn);
usr.sbin/rpki-client/http.c
1154
return http_request(conn);
usr.sbin/rpki-client/http.c
1158
proxy_connect(struct http_connection *conn)
usr.sbin/rpki-client/http.c
1163
assert(conn->state == STATE_CONNECT);
usr.sbin/rpki-client/http.c
1164
conn->state = STATE_PROXY_REQUEST;
usr.sbin/rpki-client/http.c
1167
if (strchr(conn->host, ':')) {
usr.sbin/rpki-client/http.c
1168
if (asprintf(&host, "[%s]:%s", conn->host, conn->port) == -1)
usr.sbin/rpki-client/http.c
1172
if (asprintf(&host, "%s:%s", conn->host, conn->port) == -1)
usr.sbin/rpki-client/http.c
1176
free(conn->buf);
usr.sbin/rpki-client/http.c
1177
conn->bufpos = 0;
usr.sbin/rpki-client/http.c
1179
if ((r = asprintf(&conn->buf, "CONNECT %s HTTP/1.1\r\n"
usr.sbin/rpki-client/http.c
1184
conn->bufsz = r;
usr.sbin/rpki-client/http.c
1188
return proxy_write(conn);
usr.sbin/rpki-client/http.c
1195
http_request(struct http_connection *conn)
usr.sbin/rpki-client/http.c
1200
assert(conn->state == STATE_IDLE || conn->state == STATE_TLSCONNECT);
usr.sbin/rpki-client/http.c
1201
conn->state = STATE_REQUEST;
usr.sbin/rpki-client/http.c
1208
if (strcmp(conn->port, "443") != 0)
usr.sbin/rpki-client/http.c
1212
if (strchr(conn->host, ':')) {
usr.sbin/rpki-client/http.c
1213
if (asprintf(&host, "[%s]%s%s", conn->host,
usr.sbin/rpki-client/http.c
1214
with_port ? ":" : "", with_port ? conn->port : "") == -1)
usr.sbin/rpki-client/http.c
1218
if (asprintf(&host, "%s%s%s", conn->host,
usr.sbin/rpki-client/http.c
1219
with_port ? ":" : "", with_port ? conn->port : "") == -1)
usr.sbin/rpki-client/http.c
1226
epath = url_encode(conn->req->path);
usr.sbin/rpki-client/http.c
1229
if (conn->req->modified_since != NULL) {
usr.sbin/rpki-client/http.c
1231
conn->req->modified_since) == -1)
usr.sbin/rpki-client/http.c
1235
free(conn->buf);
usr.sbin/rpki-client/http.c
1236
conn->bufpos = 0;
usr.sbin/rpki-client/http.c
1237
if ((r = asprintf(&conn->buf,
usr.sbin/rpki-client/http.c
1247
conn->bufsz = r;
usr.sbin/rpki-client/http.c
1253
return http_write(conn);
usr.sbin/rpki-client/http.c
1265
http_parse_status(struct http_connection *conn, char *buf)
usr.sbin/rpki-client/http.c
1275
conn->keep_alive = 1;
usr.sbin/rpki-client/http.c
1279
warnx("Improper response from %s", conn_info(conn));
usr.sbin/rpki-client/http.c
1288
warnx("Error retrieving %s: %s", conn_info(conn),
usr.sbin/rpki-client/http.c
1299
if (conn->req->redirect_loop++ > 10) {
usr.sbin/rpki-client/http.c
1301
conn_info(conn));
usr.sbin/rpki-client/http.c
1311
conn->status = status;
usr.sbin/rpki-client/http.c
1315
warnx("Error retrieving %s: %s", conn_info(conn),
usr.sbin/rpki-client/http.c
1327
http_isredirect(struct http_connection *conn)
usr.sbin/rpki-client/http.c
1329
if ((conn->status >= 301 && conn->status <= 303) ||
usr.sbin/rpki-client/http.c
1330
conn->status == 307 || conn->status == 308)
usr.sbin/rpki-client/http.c
1336
http_isok(struct http_connection *conn)
usr.sbin/rpki-client/http.c
1338
if (conn->status >= 200 && conn->status < 300)
usr.sbin/rpki-client/http.c
1344
http_redirect(struct http_connection *conn)
usr.sbin/rpki-client/http.c
1350
outfd = conn->req->outfd;
usr.sbin/rpki-client/http.c
1351
conn->req->outfd = -1;
usr.sbin/rpki-client/http.c
1353
uri = conn->redir_uri;
usr.sbin/rpki-client/http.c
1354
conn->redir_uri = NULL;
usr.sbin/rpki-client/http.c
1356
if (conn->req->modified_since)
usr.sbin/rpki-client/http.c
1357
if ((mod_since = strdup(conn->req->modified_since)) == NULL)
usr.sbin/rpki-client/http.c
1361
http_req_new(conn->req->id, uri, mod_since, conn->req->redirect_loop,
usr.sbin/rpki-client/http.c
1365
http_req_free(conn->req);
usr.sbin/rpki-client/http.c
1366
conn->req = NULL;
usr.sbin/rpki-client/http.c
1370
http_parse_header(struct http_connection *conn, char *buf)
usr.sbin/rpki-client/http.c
1386
if (http_isredirect(conn) && conn->redir_uri == NULL) {
usr.sbin/rpki-client/http.c
1387
warnx("%s: redirect with no location", conn->req->uri);
usr.sbin/rpki-client/http.c
1394
conn->iosz = strtonum(cp, 0, MAX_CONTENTLEN, &errstr);
usr.sbin/rpki-client/http.c
1397
conn_info(conn), errstr);
usr.sbin/rpki-client/http.c
1400
} else if (http_isredirect(conn) &&
usr.sbin/rpki-client/http.c
1414
locbase = strdup(conn->req->path);
usr.sbin/rpki-client/http.c
1432
(int)(conn->req->path - conn->req->uri),
usr.sbin/rpki-client/http.c
1433
conn->req->uri, locbase ? locbase : "", cp) == -1)
usr.sbin/rpki-client/http.c
1441
conn->redir_uri = redirurl;
usr.sbin/rpki-client/http.c
1442
if (!valid_origin(redirurl, conn->req->uri)) {
usr.sbin/rpki-client/http.c
1443
warnx("%s: cross origin redirect to %s", conn->req->uri,
usr.sbin/rpki-client/http.c
1452
conn->chunked = 1;
usr.sbin/rpki-client/http.c
1459
if (http_inflate_new(conn) == -1)
usr.sbin/rpki-client/http.c
1461
conn->gzipped = 1;
usr.sbin/rpki-client/http.c
1467
conn->keep_alive = 0;
usr.sbin/rpki-client/http.c
1469
conn->keep_alive = 1;
usr.sbin/rpki-client/http.c
1474
free(conn->last_modified);
usr.sbin/rpki-client/http.c
1475
if ((conn->last_modified = strdup(cp)) == NULL)
usr.sbin/rpki-client/http.c
1489
http_get_line(struct http_connection *conn)
usr.sbin/rpki-client/http.c
1494
end = memchr(conn->buf, '\n', conn->bufpos);
usr.sbin/rpki-client/http.c
1498
len = end - conn->buf;
usr.sbin/rpki-client/http.c
1499
while (len > 0 && (conn->buf[len - 1] == '\r' ||
usr.sbin/rpki-client/http.c
1500
conn->buf[len - 1] == ' ' || conn->buf[len - 1] == '\t'))
usr.sbin/rpki-client/http.c
1503
if ((line = strndup(conn->buf, len)) == NULL)
usr.sbin/rpki-client/http.c
1508
conn->bufpos -= end - conn->buf;
usr.sbin/rpki-client/http.c
1509
memmove(conn->buf, end, conn->bufpos);
usr.sbin/rpki-client/http.c
1520
http_parse_chunked(struct http_connection *conn, char *buf)
usr.sbin/rpki-client/http.c
1534
conn->iosz = chunksize;
usr.sbin/rpki-client/http.c
1539
http_read(struct http_connection *conn)
usr.sbin/rpki-client/http.c
1545
if (conn->bufpos > 0)
usr.sbin/rpki-client/http.c
1549
assert(conn->bufpos < conn->bufsz);
usr.sbin/rpki-client/http.c
1550
s = tls_read(conn->tls, conn->buf + conn->bufpos,
usr.sbin/rpki-client/http.c
1551
conn->bufsz - conn->bufpos);
usr.sbin/rpki-client/http.c
1553
warnx("%s: TLS read: %s", conn_info(conn),
usr.sbin/rpki-client/http.c
1554
tls_error(conn->tls));
usr.sbin/rpki-client/http.c
1555
return http_failed(conn);
usr.sbin/rpki-client/http.c
1563
if (conn->req)
usr.sbin/rpki-client/http.c
1565
conn_info(conn));
usr.sbin/rpki-client/http.c
1566
return http_failed(conn);
usr.sbin/rpki-client/http.c
1569
conn->bufpos += s;
usr.sbin/rpki-client/http.c
1572
switch (conn->state) {
usr.sbin/rpki-client/http.c
1574
buf = http_get_line(conn);
usr.sbin/rpki-client/http.c
1577
if (http_parse_status(conn, buf) == -1) {
usr.sbin/rpki-client/http.c
1579
return http_failed(conn);
usr.sbin/rpki-client/http.c
1582
conn->state = STATE_PROXY_RESPONSE;
usr.sbin/rpki-client/http.c
1586
buf = http_get_line(conn);
usr.sbin/rpki-client/http.c
1597
if (conn->status == 200) {
usr.sbin/rpki-client/http.c
1598
conn->state = STATE_CONNECT;
usr.sbin/rpki-client/http.c
1599
return http_tls_connect(conn);
usr.sbin/rpki-client/http.c
1601
return http_failed(conn);
usr.sbin/rpki-client/http.c
1603
buf = http_get_line(conn);
usr.sbin/rpki-client/http.c
1607
if (http_parse_status(conn, buf) == -1) {
usr.sbin/rpki-client/http.c
1609
return http_failed(conn);
usr.sbin/rpki-client/http.c
1612
conn->state = STATE_RESPONSE_HEADER;
usr.sbin/rpki-client/http.c
1619
buf = http_get_line(conn);
usr.sbin/rpki-client/http.c
1623
rv = http_parse_header(conn, buf);
usr.sbin/rpki-client/http.c
1627
return http_failed(conn);
usr.sbin/rpki-client/http.c
1632
conn->totalsz = 0;
usr.sbin/rpki-client/http.c
1635
if (http_isok(conn) || http_isredirect(conn)) {
usr.sbin/rpki-client/http.c
1636
if (http_isredirect(conn))
usr.sbin/rpki-client/http.c
1637
http_redirect(conn);
usr.sbin/rpki-client/http.c
1639
if (conn->chunked)
usr.sbin/rpki-client/http.c
1640
conn->state = STATE_RESPONSE_CHUNKED_HEADER;
usr.sbin/rpki-client/http.c
1642
conn->state = STATE_RESPONSE_DATA;
usr.sbin/rpki-client/http.c
1644
} else if (conn->status == 100 || conn->status == 103) {
usr.sbin/rpki-client/http.c
1645
conn->state = STATE_RESPONSE_STATUS;
usr.sbin/rpki-client/http.c
1646
} else if (conn->status == 304) {
usr.sbin/rpki-client/http.c
1647
return http_done(conn, HTTP_NOT_MOD);
usr.sbin/rpki-client/http.c
1650
return http_failed(conn);
usr.sbin/rpki-client/http.c
1652
if (conn->bufpos != conn->bufsz &&
usr.sbin/rpki-client/http.c
1653
conn->iosz > conn->bufpos)
usr.sbin/rpki-client/http.c
1657
if (conn->req == NULL) {
usr.sbin/rpki-client/http.c
1661
if (conn->iosz < conn->bufpos) {
usr.sbin/rpki-client/http.c
1662
conn->bufpos -= conn->iosz;
usr.sbin/rpki-client/http.c
1663
conn->iosz = 0;
usr.sbin/rpki-client/http.c
1665
conn->iosz -= conn->bufpos;
usr.sbin/rpki-client/http.c
1666
conn->bufpos = 0;
usr.sbin/rpki-client/http.c
1668
if (conn->chunked)
usr.sbin/rpki-client/http.c
1669
conn->state = STATE_RESPONSE_CHUNKED_CRLF;
usr.sbin/rpki-client/http.c
1671
conn->state = STATE_RESPONSE_DATA;
usr.sbin/rpki-client/http.c
1675
conn->state = STATE_WRITE_DATA;
usr.sbin/rpki-client/http.c
1678
assert(conn->iosz == 0);
usr.sbin/rpki-client/http.c
1680
buf = http_get_line(conn);
usr.sbin/rpki-client/http.c
1683
if (http_parse_chunked(conn, buf) != 0) {
usr.sbin/rpki-client/http.c
1684
warnx("%s: bad chunk encoding", conn_info(conn));
usr.sbin/rpki-client/http.c
1686
return http_failed(conn);
usr.sbin/rpki-client/http.c
1694
if (conn->iosz == 0)
usr.sbin/rpki-client/http.c
1695
conn->state = STATE_RESPONSE_CHUNKED_TRAILER;
usr.sbin/rpki-client/http.c
1697
conn->state = STATE_RESPONSE_DATA;
usr.sbin/rpki-client/http.c
1700
buf = http_get_line(conn);
usr.sbin/rpki-client/http.c
1705
warnx("%s: bad chunk encoding", conn_info(conn));
usr.sbin/rpki-client/http.c
1707
return http_failed(conn);
usr.sbin/rpki-client/http.c
1710
conn->state = STATE_RESPONSE_CHUNKED_HEADER;
usr.sbin/rpki-client/http.c
1713
buf = http_get_line(conn);
usr.sbin/rpki-client/http.c
1722
conn->chunked = 0;
usr.sbin/rpki-client/http.c
1723
return http_done(conn, HTTP_OK);
usr.sbin/rpki-client/http.c
1733
http_write(struct http_connection *conn)
usr.sbin/rpki-client/http.c
1737
assert(conn->state == STATE_REQUEST);
usr.sbin/rpki-client/http.c
1739
while (conn->bufpos < conn->bufsz) {
usr.sbin/rpki-client/http.c
1740
s = tls_write(conn->tls, conn->buf + conn->bufpos,
usr.sbin/rpki-client/http.c
1741
conn->bufsz - conn->bufpos);
usr.sbin/rpki-client/http.c
1743
warnx("%s: TLS write: %s", conn_info(conn),
usr.sbin/rpki-client/http.c
1744
tls_error(conn->tls));
usr.sbin/rpki-client/http.c
1745
return http_failed(conn);
usr.sbin/rpki-client/http.c
1752
conn->bufpos += s;
usr.sbin/rpki-client/http.c
1756
conn->state = STATE_RESPONSE_STATUS;
usr.sbin/rpki-client/http.c
1759
free(conn->buf);
usr.sbin/rpki-client/http.c
1760
conn->bufpos = 0;
usr.sbin/rpki-client/http.c
1761
conn->bufsz = HTTP_BUF_SIZE;
usr.sbin/rpki-client/http.c
1762
if ((conn->buf = malloc(conn->bufsz)) == NULL)
usr.sbin/rpki-client/http.c
1765
return http_read(conn);
usr.sbin/rpki-client/http.c
1769
proxy_read(struct http_connection *conn)
usr.sbin/rpki-client/http.c
1775
assert(conn->bufpos < conn->bufsz);
usr.sbin/rpki-client/http.c
1776
s = read(conn->fd, conn->buf + conn->bufpos,
usr.sbin/rpki-client/http.c
1777
conn->bufsz - conn->bufpos);
usr.sbin/rpki-client/http.c
1779
warn("%s: read", conn_info(conn));
usr.sbin/rpki-client/http.c
1780
return http_failed(conn);
usr.sbin/rpki-client/http.c
1784
if (conn->req)
usr.sbin/rpki-client/http.c
1786
conn_info(conn));
usr.sbin/rpki-client/http.c
1787
return http_failed(conn);
usr.sbin/rpki-client/http.c
1790
conn->bufpos += s;
usr.sbin/rpki-client/http.c
1793
switch (conn->state) {
usr.sbin/rpki-client/http.c
1795
buf = http_get_line(conn);
usr.sbin/rpki-client/http.c
1798
if (http_parse_status(conn, buf) == -1) {
usr.sbin/rpki-client/http.c
1800
return http_failed(conn);
usr.sbin/rpki-client/http.c
1803
conn->state = STATE_PROXY_RESPONSE;
usr.sbin/rpki-client/http.c
1808
buf = http_get_line(conn);
usr.sbin/rpki-client/http.c
1817
if (conn->status == 200) {
usr.sbin/rpki-client/http.c
1818
conn->state = STATE_CONNECT;
usr.sbin/rpki-client/http.c
1819
return http_tls_connect(conn);
usr.sbin/rpki-client/http.c
1821
return http_failed(conn);
usr.sbin/rpki-client/http.c
1831
proxy_write(struct http_connection *conn)
usr.sbin/rpki-client/http.c
1835
assert(conn->state == STATE_PROXY_REQUEST);
usr.sbin/rpki-client/http.c
1837
assert(conn->bufpos < conn->bufsz);
usr.sbin/rpki-client/http.c
1838
s = write(conn->fd, conn->buf + conn->bufpos,
usr.sbin/rpki-client/http.c
1839
conn->bufsz - conn->bufpos);
usr.sbin/rpki-client/http.c
1841
warn("%s: write", conn_info(conn));
usr.sbin/rpki-client/http.c
1842
return http_failed(conn);
usr.sbin/rpki-client/http.c
1844
conn->bufpos += s;
usr.sbin/rpki-client/http.c
1845
if (conn->bufpos < conn->bufsz)
usr.sbin/rpki-client/http.c
1849
conn->state = STATE_PROXY_STATUS;
usr.sbin/rpki-client/http.c
1852
free(conn->buf);
usr.sbin/rpki-client/http.c
1853
conn->bufpos = 0;
usr.sbin/rpki-client/http.c
1854
conn->bufsz = HTTP_BUF_SIZE;
usr.sbin/rpki-client/http.c
1855
if ((conn->buf = malloc(conn->bufsz)) == NULL)
usr.sbin/rpki-client/http.c
1865
http_close(struct http_connection *conn)
usr.sbin/rpki-client/http.c
1867
assert(conn->state == STATE_IDLE || conn->state == STATE_CLOSE);
usr.sbin/rpki-client/http.c
1869
conn->state = STATE_CLOSE;
usr.sbin/rpki-client/http.c
1870
LIST_REMOVE(conn, entry);
usr.sbin/rpki-client/http.c
1871
LIST_INSERT_HEAD(&active, conn, entry);
usr.sbin/rpki-client/http.c
1873
if (conn->tls != NULL) {
usr.sbin/rpki-client/http.c
1874
switch (tls_close(conn->tls)) {
usr.sbin/rpki-client/http.c
1885
conn->state = STATE_FREE;
usr.sbin/rpki-client/http.c
1894
data_write(struct http_connection *conn)
usr.sbin/rpki-client/http.c
1897
size_t bsz = conn->bufpos;
usr.sbin/rpki-client/http.c
1899
assert(conn->state == STATE_WRITE_DATA);
usr.sbin/rpki-client/http.c
1901
if (conn->iosz < bsz)
usr.sbin/rpki-client/http.c
1902
bsz = conn->iosz;
usr.sbin/rpki-client/http.c
1904
s = write(conn->req->outfd, conn->buf, bsz);
usr.sbin/rpki-client/http.c
1906
warn("%s: data write", conn_info(conn));
usr.sbin/rpki-client/http.c
1907
return http_failed(conn);
usr.sbin/rpki-client/http.c
1910
conn->totalsz += s;
usr.sbin/rpki-client/http.c
1911
if (conn->totalsz > MAX_CONTENTLEN) {
usr.sbin/rpki-client/http.c
1912
warn("%s: too much data offered", conn_info(conn));
usr.sbin/rpki-client/http.c
1913
return http_failed(conn);
usr.sbin/rpki-client/http.c
1916
conn->bufpos -= s;
usr.sbin/rpki-client/http.c
1917
conn->iosz -= s;
usr.sbin/rpki-client/http.c
1918
memmove(conn->buf, conn->buf + s, conn->bufpos);
usr.sbin/rpki-client/http.c
1921
if (!conn->chunked && conn->iosz == 0) {
usr.sbin/rpki-client/http.c
1922
if (conn->bufpos != 0) {
usr.sbin/rpki-client/http.c
1924
conn_info(conn));
usr.sbin/rpki-client/http.c
1925
return http_failed(conn);
usr.sbin/rpki-client/http.c
1927
return http_done(conn, HTTP_OK);
usr.sbin/rpki-client/http.c
1931
if (conn->bufpos == 0 || conn->iosz == 0) {
usr.sbin/rpki-client/http.c
1932
if (conn->chunked && conn->iosz == 0)
usr.sbin/rpki-client/http.c
1933
conn->state = STATE_RESPONSE_CHUNKED_CRLF;
usr.sbin/rpki-client/http.c
1935
conn->state = STATE_RESPONSE_DATA;
usr.sbin/rpki-client/http.c
1936
return http_read(conn);
usr.sbin/rpki-client/http.c
1950
data_inflate_write(struct http_connection *conn)
usr.sbin/rpki-client/http.c
1952
struct http_zlib *zctx = conn->zlibctx;
usr.sbin/rpki-client/http.c
1955
assert(conn->state == STATE_WRITE_DATA);
usr.sbin/rpki-client/http.c
1959
if (http_inflate_data(conn) == -1)
usr.sbin/rpki-client/http.c
1960
return http_failed(conn);
usr.sbin/rpki-client/http.c
1962
s = write(conn->req->outfd, zctx->zbuf, zctx->zbufpos);
usr.sbin/rpki-client/http.c
1964
warn("%s: data write", conn_info(conn));
usr.sbin/rpki-client/http.c
1965
return http_failed(conn);
usr.sbin/rpki-client/http.c
1968
conn->totalsz += s;
usr.sbin/rpki-client/http.c
1969
if (conn->totalsz > MAX_CONTENTLEN) {
usr.sbin/rpki-client/http.c
1970
warn("%s: too much decompressed data offered", conn_info(conn));
usr.sbin/rpki-client/http.c
1971
return http_failed(conn);
usr.sbin/rpki-client/http.c
1980
return http_inflate_advance(conn);
usr.sbin/rpki-client/http.c
1993
http_handle(struct http_connection *conn)
usr.sbin/rpki-client/http.c
1995
assert(conn->pfd != NULL && conn->pfd->revents != 0);
usr.sbin/rpki-client/http.c
1997
conn->io_time = 0;
usr.sbin/rpki-client/http.c
1999
switch (conn->state) {
usr.sbin/rpki-client/http.c
2001
return http_finish_connect(conn);
usr.sbin/rpki-client/http.c
2003
return http_tls_handshake(conn);
usr.sbin/rpki-client/http.c
2005
return http_write(conn);
usr.sbin/rpki-client/http.c
2007
return proxy_write(conn);
usr.sbin/rpki-client/http.c
2010
return proxy_read(conn);
usr.sbin/rpki-client/http.c
2017
return http_read(conn);
usr.sbin/rpki-client/http.c
2019
if (conn->gzipped)
usr.sbin/rpki-client/http.c
2020
return data_inflate_write(conn);
usr.sbin/rpki-client/http.c
2022
return data_write(conn);
usr.sbin/rpki-client/http.c
2024
return http_close(conn);
usr.sbin/rpki-client/http.c
2026
conn->state = STATE_RESPONSE_HEADER;
usr.sbin/rpki-client/http.c
2027
LIST_REMOVE(conn, entry);
usr.sbin/rpki-client/http.c
2028
LIST_INSERT_HEAD(&active, conn, entry);
usr.sbin/rpki-client/http.c
2029
return http_read(conn);
usr.sbin/rpki-client/http.c
2075
struct http_connection *conn, *nc;
usr.sbin/rpki-client/http.c
2117
LIST_FOREACH(conn, &active, entry) {
usr.sbin/rpki-client/http.c
2121
if (conn->io_time == 0) {
usr.sbin/rpki-client/http.c
2122
if (conn->state == STATE_CONNECT)
usr.sbin/rpki-client/http.c
2123
conn->io_time = now + MAX_CONN_TIMEOUT;
usr.sbin/rpki-client/http.c
2125
conn->io_time = now + MAX_IO_TIMEOUT;
usr.sbin/rpki-client/http.c
2128
if (conn->io_time <= now)
usr.sbin/rpki-client/http.c
2131
int diff = conn->io_time - now;
usr.sbin/rpki-client/http.c
2136
if (conn->state == STATE_WRITE_DATA)
usr.sbin/rpki-client/http.c
2137
pfds[i].fd = conn->req->outfd;
usr.sbin/rpki-client/http.c
2139
pfds[i].fd = conn->fd;
usr.sbin/rpki-client/http.c
2141
pfds[i].events = conn->events;
usr.sbin/rpki-client/http.c
2142
conn->pfd = &pfds[i];
usr.sbin/rpki-client/http.c
2145
LIST_FOREACH(conn, &idle, entry) {
usr.sbin/rpki-client/http.c
2149
if (conn->idle_time <= now)
usr.sbin/rpki-client/http.c
2152
int diff = conn->idle_time - now;
usr.sbin/rpki-client/http.c
2157
pfds[i].fd = conn->fd;
usr.sbin/rpki-client/http.c
2159
conn->pfd = &pfds[i];
usr.sbin/rpki-client/http.c
2206
LIST_FOREACH_SAFE(conn, &idle, entry, nc) {
usr.sbin/rpki-client/http.c
2207
if (conn->pfd != NULL && conn->pfd->revents != 0)
usr.sbin/rpki-client/http.c
2208
http_do(conn, http_handle);
usr.sbin/rpki-client/http.c
2209
else if (conn->idle_time <= now) {
usr.sbin/rpki-client/http.c
2210
conn->io_time = 0;
usr.sbin/rpki-client/http.c
2211
http_do(conn, http_close);
usr.sbin/rpki-client/http.c
2214
if (conn->state == STATE_FREE)
usr.sbin/rpki-client/http.c
2215
http_free(conn);
usr.sbin/rpki-client/http.c
2219
LIST_FOREACH_SAFE(conn, &active, entry, nc) {
usr.sbin/rpki-client/http.c
2221
if (conn->pfd != NULL && conn->pfd->revents != 0)
usr.sbin/rpki-client/http.c
2222
http_do(conn, http_handle);
usr.sbin/rpki-client/http.c
2223
else if (conn->io_time != 0 && conn->io_time <= now) {
usr.sbin/rpki-client/http.c
2224
conn->io_time = 0;
usr.sbin/rpki-client/http.c
2225
if (conn->state == STATE_CONNECT) {
usr.sbin/rpki-client/http.c
2227
conn_info(conn));
usr.sbin/rpki-client/http.c
2228
http_do(conn, http_connect_failed);
usr.sbin/rpki-client/http.c
2231
conn_info(conn));
usr.sbin/rpki-client/http.c
2232
http_do(conn, http_failed);
usr.sbin/rpki-client/http.c
2236
if (conn->state == STATE_FREE)
usr.sbin/rpki-client/http.c
2237
http_free(conn);
usr.sbin/rpki-client/http.c
237
ip_info(const struct http_connection *conn)
usr.sbin/rpki-client/http.c
241
if (conn->res == NULL)
usr.sbin/rpki-client/http.c
244
if (getnameinfo(conn->res->ai_addr, conn->res->ai_addrlen, ipbuf,
usr.sbin/rpki-client/http.c
252
conn_info(const struct http_connection *conn)
usr.sbin/rpki-client/http.c
257
if (conn->req == NULL)
usr.sbin/rpki-client/http.c
258
uri = conn->host;
usr.sbin/rpki-client/http.c
260
uri = conn->req->uri;
usr.sbin/rpki-client/http.c
262
snprintf(buf, sizeof(buf), "%s (%s)", http_info(uri), ip_info(conn));
usr.sbin/rpki-client/http.c
655
struct http_connection *conn;
usr.sbin/rpki-client/http.c
660
LIST_FOREACH(conn, &idle, entry) {
usr.sbin/rpki-client/http.c
661
if (strcmp(conn->host, req->host) != 0)
usr.sbin/rpki-client/http.c
663
if (strcmp(conn->port, req->port) != 0)
usr.sbin/rpki-client/http.c
666
LIST_REMOVE(conn, entry);
usr.sbin/rpki-client/http.c
667
LIST_INSERT_HEAD(&active, conn, entry);
usr.sbin/rpki-client/http.c
670
conn->req = req;
usr.sbin/rpki-client/http.c
671
conn->idle_time = 0;
usr.sbin/rpki-client/http.c
674
http_do(conn, http_request);
usr.sbin/rpki-client/http.c
675
if (conn->state == STATE_FREE)
usr.sbin/rpki-client/http.c
676
http_free(conn);
usr.sbin/rpki-client/http.c
695
http_inflate_new(struct http_connection *conn)
usr.sbin/rpki-client/http.c
699
if (conn->zlibctx != NULL)
usr.sbin/rpki-client/http.c
709
conn->zlibctx = zctx;
usr.sbin/rpki-client/http.c
713
warnx("%s: decompression initialisation failed", conn_info(conn));
usr.sbin/rpki-client/http.c
722
http_inflate_free(struct http_connection *conn)
usr.sbin/rpki-client/http.c
724
if (conn->zlibctx == NULL)
usr.sbin/rpki-client/http.c
726
inflateEnd(&conn->zlibctx->zs);
usr.sbin/rpki-client/http.c
727
free(conn->zlibctx->zbuf);
usr.sbin/rpki-client/http.c
728
free(conn->zlibctx);
usr.sbin/rpki-client/http.c
729
conn->zlibctx = NULL;
usr.sbin/rpki-client/http.c
734
http_inflate_done(struct http_connection *conn)
usr.sbin/rpki-client/http.c
736
if (inflateReset(&conn->zlibctx->zs) != Z_OK)
usr.sbin/rpki-client/http.c
737
http_inflate_free(conn);
usr.sbin/rpki-client/http.c
746
http_inflate_data(struct http_connection *conn)
usr.sbin/rpki-client/http.c
748
struct http_zlib *zctx = conn->zlibctx;
usr.sbin/rpki-client/http.c
749
size_t bsz = conn->bufpos;
usr.sbin/rpki-client/http.c
752
if (conn->iosz < bsz)
usr.sbin/rpki-client/http.c
753
bsz = conn->iosz;
usr.sbin/rpki-client/http.c
758
zctx->zs.next_in = conn->buf;
usr.sbin/rpki-client/http.c
771
warnx("%s: inflate failed: %s", conn_info(conn),
usr.sbin/rpki-client/http.c
774
warnx("%s: inflate failed error %d", conn_info(conn),
usr.sbin/rpki-client/http.c
789
http_inflate_advance(struct http_connection *conn)
usr.sbin/rpki-client/http.c
791
struct http_zlib *zctx = conn->zlibctx;
usr.sbin/rpki-client/http.c
795
conn->bufpos -= bsz;
usr.sbin/rpki-client/http.c
796
conn->iosz -= bsz;
usr.sbin/rpki-client/http.c
797
memmove(conn->buf, conn->buf + bsz, conn->bufpos);
usr.sbin/rpki-client/http.c
801
conn->gzipped = 0;
usr.sbin/rpki-client/http.c
802
http_inflate_done(conn);
usr.sbin/rpki-client/http.c
803
conn->was_gzipped = 1;
usr.sbin/rpki-client/http.c
805
if (conn->iosz == 0) {
usr.sbin/rpki-client/http.c
806
if (!conn->chunked) {
usr.sbin/rpki-client/http.c
807
if (conn->bufpos != 0) {
usr.sbin/rpki-client/http.c
810
conn_info(conn));
usr.sbin/rpki-client/http.c
811
return http_failed(conn);
usr.sbin/rpki-client/http.c
813
return http_done(conn, HTTP_OK);
usr.sbin/rpki-client/http.c
815
conn->state = STATE_RESPONSE_CHUNKED_CRLF;
usr.sbin/rpki-client/http.c
816
return http_read(conn);
usr.sbin/rpki-client/http.c
820
conn_info(conn));
usr.sbin/rpki-client/http.c
821
return http_failed(conn);
usr.sbin/rpki-client/http.c
825
if (conn->chunked && conn->iosz == 0)
usr.sbin/rpki-client/http.c
826
conn->state = STATE_RESPONSE_CHUNKED_CRLF;
usr.sbin/rpki-client/http.c
828
conn->state = STATE_RESPONSE_DATA;
usr.sbin/rpki-client/http.c
829
return http_read(conn);
usr.sbin/rpki-client/http.c
839
struct http_connection *conn;
usr.sbin/rpki-client/http.c
841
if ((conn = calloc(1, sizeof(*conn))) == NULL)
usr.sbin/rpki-client/http.c
844
conn->fd = -1;
usr.sbin/rpki-client/http.c
845
conn->req = req;
usr.sbin/rpki-client/http.c
846
if ((conn->host = strdup(req->host)) == NULL)
usr.sbin/rpki-client/http.c
848
if ((conn->port = strdup(req->port)) == NULL)
usr.sbin/rpki-client/http.c
851
LIST_INSERT_HEAD(&active, conn, entry);
usr.sbin/rpki-client/http.c
855
if (http_resolv(&conn->res0, proxy.proxyhost,
usr.sbin/rpki-client/http.c
858
http_free(conn);
usr.sbin/rpki-client/http.c
862
if (http_resolv(&conn->res0, conn->host, conn->port) == -1) {
usr.sbin/rpki-client/http.c
864
http_free(conn);
usr.sbin/rpki-client/http.c
870
http_do(conn, http_connect);
usr.sbin/rpki-client/http.c
871
if (conn->state == STATE_FREE)
usr.sbin/rpki-client/http.c
872
http_free(conn);
usr.sbin/rpki-client/http.c
880
http_free(struct http_connection *conn)
usr.sbin/rpki-client/http.c
882
assert(conn->state == STATE_FREE);
usr.sbin/rpki-client/http.c
884
LIST_REMOVE(conn, entry);
usr.sbin/rpki-client/http.c
887
http_req_free(conn->req);
usr.sbin/rpki-client/http.c
888
http_inflate_free(conn);
usr.sbin/rpki-client/http.c
889
free(conn->host);
usr.sbin/rpki-client/http.c
890
free(conn->port);
usr.sbin/rpki-client/http.c
891
free(conn->last_modified);
usr.sbin/rpki-client/http.c
892
free(conn->redir_uri);
usr.sbin/rpki-client/http.c
893
free(conn->buf);
usr.sbin/rpki-client/http.c
895
if (conn->res0 != NULL)
usr.sbin/rpki-client/http.c
896
freeaddrinfo(conn->res0);
usr.sbin/rpki-client/http.c
898
tls_free(conn->tls);
usr.sbin/rpki-client/http.c
900
if (conn->fd != -1)
usr.sbin/rpki-client/http.c
901
close(conn->fd);
usr.sbin/rpki-client/http.c
902
free(conn);
usr.sbin/rpki-client/http.c
912
http_done(struct http_connection *conn, enum http_result res)
usr.sbin/rpki-client/http.c
914
assert(conn->bufpos == 0);
usr.sbin/rpki-client/http.c
915
assert(conn->iosz == 0);
usr.sbin/rpki-client/http.c
916
assert(conn->chunked == 0);
usr.sbin/rpki-client/http.c
917
assert(conn->redir_uri == NULL);
usr.sbin/rpki-client/http.c
919
if (conn->gzipped) {
usr.sbin/rpki-client/http.c
920
conn->gzipped = 0;
usr.sbin/rpki-client/http.c
921
http_inflate_done(conn);
usr.sbin/rpki-client/http.c
922
conn->was_gzipped = 1;
usr.sbin/rpki-client/http.c
925
if (!conn->was_gzipped && conn->totalsz > (1024 * 1024))
usr.sbin/rpki-client/http.c
927
"compression", conn_info(conn), conn->totalsz);
usr.sbin/rpki-client/http.c
929
conn->state = STATE_IDLE;
usr.sbin/rpki-client/http.c
930
conn->idle_time = getmonotime() + HTTP_IDLE_TIMEOUT;
usr.sbin/rpki-client/http.c
932
if (conn->req) {
usr.sbin/rpki-client/http.c
933
http_req_done(conn->req->id, res, conn->last_modified);
usr.sbin/rpki-client/http.c
934
http_req_free(conn->req);
usr.sbin/rpki-client/http.c
935
conn->req = NULL;
usr.sbin/rpki-client/http.c
938
if (!conn->keep_alive)
usr.sbin/rpki-client/http.c
939
return http_close(conn);
usr.sbin/rpki-client/http.c
941
LIST_REMOVE(conn, entry);
usr.sbin/rpki-client/http.c
942
LIST_INSERT_HEAD(&idle, conn, entry);
usr.sbin/rpki-client/http.c
945
conn->totalsz = 0;
usr.sbin/rpki-client/http.c
946
conn->was_gzipped = 0;
usr.sbin/rpki-client/http.c
947
conn->status = 0;
usr.sbin/rpki-client/http.c
948
conn->keep_alive = 0;
usr.sbin/rpki-client/http.c
959
http_failed(struct http_connection *conn)
usr.sbin/rpki-client/http.c
961
conn->state = STATE_FREE;
usr.sbin/rpki-client/http.c
963
if (conn->req) {
usr.sbin/rpki-client/http.c
964
http_req_fail(conn->req->id);
usr.sbin/rpki-client/http.c
965
http_req_free(conn->req);
usr.sbin/rpki-client/http.c
966
conn->req = NULL;
usr.sbin/rpki-client/http.c
976
http_connect_failed(struct http_connection *conn)
usr.sbin/rpki-client/http.c
978
assert(conn->state == STATE_CONNECT);
usr.sbin/rpki-client/http.c
979
close(conn->fd);
usr.sbin/rpki-client/http.c
980
conn->fd = -1;
usr.sbin/rpki-client/http.c
982
return http_connect(conn);
usr.sbin/rpki-client/http.c
990
http_do(struct http_connection *conn, enum res (*f)(struct http_connection *))
usr.sbin/rpki-client/http.c
992
switch (f(conn)) {
usr.sbin/rpki-client/http.c
994
conn->events = 0;
usr.sbin/rpki-client/http.c
997
conn->events = POLLIN;
usr.sbin/smtpd/mail.lmtp.c
110
conn = lmtp_connect(destination);
usr.sbin/smtpd/mail.lmtp.c
111
lmtp_engine(conn, &session);
usr.sbin/smtpd/mail.lmtp.c
318
stream_file(FILE *conn)
usr.sbin/smtpd/mail.lmtp.c
326
fprintf(conn, ".");
usr.sbin/smtpd/mail.lmtp.c
327
fprintf(conn, "%s\r\n", line);
usr.sbin/smtpd/mail.lmtp.c
57
int conn;
usr.sbin/snmpd/application_agentx.c
182
struct appl_agentx_connection *conn, *tconn;
usr.sbin/snmpd/application_agentx.c
184
RB_FOREACH_SAFE(conn, appl_agentx_conns, &appl_agentx_conns, tconn)
usr.sbin/snmpd/application_agentx.c
185
appl_agentx_free(conn, APPL_CLOSE_REASONSHUTDOWN);
usr.sbin/snmpd/application_agentx.c
195
struct appl_agentx_connection *conn = NULL;
usr.sbin/snmpd/application_agentx.c
202
if ((conn = malloc(sizeof(*conn))) == NULL) {
usr.sbin/snmpd/application_agentx.c
207
conn->conn_backend = 0;
usr.sbin/snmpd/application_agentx.c
208
TAILQ_INIT(&(conn->conn_sessions));
usr.sbin/snmpd/application_agentx.c
209
if ((conn->conn_ax = ax_new(fd)) == NULL) {
usr.sbin/snmpd/application_agentx.c
215
conn->conn_id = arc4random();
usr.sbin/snmpd/application_agentx.c
217
&appl_agentx_conns, conn) != NULL);
usr.sbin/snmpd/application_agentx.c
219
event_set(&(conn->conn_rev), fd, EV_READ | EV_PERSIST,
usr.sbin/snmpd/application_agentx.c
220
appl_agentx_recv, conn);
usr.sbin/snmpd/application_agentx.c
221
event_add(&(conn->conn_rev), NULL);
usr.sbin/snmpd/application_agentx.c
222
event_set(&(conn->conn_wev), fd, EV_WRITE, appl_agentx_send, conn);
usr.sbin/snmpd/application_agentx.c
223
log_info("AgentX(%"PRIu32"): new connection", conn->conn_id);
usr.sbin/snmpd/application_agentx.c
228
free(conn);
usr.sbin/snmpd/application_agentx.c
234
struct appl_agentx_connection *conn;
usr.sbin/snmpd/application_agentx.c
236
if ((conn = malloc(sizeof(*conn))) == NULL)
usr.sbin/snmpd/application_agentx.c
239
conn->conn_backend = 1;
usr.sbin/snmpd/application_agentx.c
240
TAILQ_INIT(&(conn->conn_sessions));
usr.sbin/snmpd/application_agentx.c
241
if ((conn->conn_ax = ax_new(fd)) == NULL)
usr.sbin/snmpd/application_agentx.c
245
conn->conn_id = arc4random();
usr.sbin/snmpd/application_agentx.c
247
&appl_agentx_conns, conn) != NULL);
usr.sbin/snmpd/application_agentx.c
249
event_set(&(conn->conn_rev), fd, EV_READ | EV_PERSIST,
usr.sbin/snmpd/application_agentx.c
250
appl_agentx_recv, conn);
usr.sbin/snmpd/application_agentx.c
251
event_add(&(conn->conn_rev), NULL);
usr.sbin/snmpd/application_agentx.c
252
event_set(&(conn->conn_wev), fd, EV_WRITE, appl_agentx_send, conn);
usr.sbin/snmpd/application_agentx.c
256
appl_agentx_free(struct appl_agentx_connection *conn,
usr.sbin/snmpd/application_agentx.c
261
while ((session = TAILQ_FIRST(&(conn->conn_sessions))) != NULL) {
usr.sbin/snmpd/application_agentx.c
262
if (conn->conn_ax == NULL)
usr.sbin/snmpd/application_agentx.c
269
event_del(&(conn->conn_rev));
usr.sbin/snmpd/application_agentx.c
270
event_del(&(conn->conn_wev));
usr.sbin/snmpd/application_agentx.c
272
RB_REMOVE(appl_agentx_conns, &appl_agentx_conns, conn);
usr.sbin/snmpd/application_agentx.c
273
if (conn->conn_ax != NULL)
usr.sbin/snmpd/application_agentx.c
274
(void)ax_send(conn->conn_ax);
usr.sbin/snmpd/application_agentx.c
275
ax_free(conn->conn_ax);
usr.sbin/snmpd/application_agentx.c
276
if (conn->conn_backend)
usr.sbin/snmpd/application_agentx.c
278
conn->conn_id);
usr.sbin/snmpd/application_agentx.c
279
free(conn);
usr.sbin/snmpd/application_agentx.c
285
struct appl_agentx_connection *conn = cookie;
usr.sbin/snmpd/application_agentx.c
291
snprintf(name, sizeof(name), "AgentX(%"PRIu32")", conn->conn_id);
usr.sbin/snmpd/application_agentx.c
292
if ((pdu = ax_recv(conn->conn_ax)) == NULL) {
usr.sbin/snmpd/application_agentx.c
301
ax_free(conn->conn_ax);
usr.sbin/snmpd/application_agentx.c
302
conn->conn_ax = NULL;
usr.sbin/snmpd/application_agentx.c
304
appl_agentx_free(conn, errno == EPROTO ?
usr.sbin/snmpd/application_agentx.c
309
conn->conn_ax->ax_byteorder = pdu->ap_header.aph_flags &
usr.sbin/snmpd/application_agentx.c
314
TAILQ_FOREACH(session, &(conn->conn_sessions),
usr.sbin/snmpd/application_agentx.c
390
appl_agentx_open(conn, pdu);
usr.sbin/snmpd/application_agentx.c
424
ax_response(conn->conn_ax, pdu->ap_header.aph_sessionid,
usr.sbin/snmpd/application_agentx.c
429
event_add(&(conn->conn_wev), NULL);
usr.sbin/snmpd/application_agentx.c
435
ax_response(conn->conn_ax, pdu->ap_header.aph_sessionid,
usr.sbin/snmpd/application_agentx.c
442
event_add(&(conn->conn_wev), NULL);
usr.sbin/snmpd/application_agentx.c
458
ax_response(conn->conn_ax, pdu->ap_header.aph_sessionid,
usr.sbin/snmpd/application_agentx.c
462
event_add(&(conn->conn_wev), NULL);
usr.sbin/snmpd/application_agentx.c
470
if (TAILQ_EMPTY(&(conn->conn_sessions)))
usr.sbin/snmpd/application_agentx.c
471
appl_agentx_free(conn, APPL_CLOSE_REASONOTHER);
usr.sbin/snmpd/application_agentx.c
475
appl_agentx_open(struct appl_agentx_connection *conn, struct ax_pdu *pdu)
usr.sbin/snmpd/application_agentx.c
489
session->sess_conn = conn;
usr.sbin/snmpd/application_agentx.c
502
conn->conn_id);
usr.sbin/snmpd/application_agentx.c
509
"Failed", conn->conn_id);
usr.sbin/snmpd/application_agentx.c
523
"Open Failed", conn->conn_id);
usr.sbin/snmpd/application_agentx.c
536
conn->conn_id);
usr.sbin/snmpd/application_agentx.c
550
conn->conn_id, session->sess_id) == -1) {
usr.sbin/snmpd/application_agentx.c
552
conn->conn_id);
usr.sbin/snmpd/application_agentx.c
561
TAILQ_INSERT_TAIL(&(conn->conn_sessions), session, sess_conn_entry);
usr.sbin/snmpd/application_agentx.c
568
ax_response(conn->conn_ax, session->sess_id,
usr.sbin/snmpd/application_agentx.c
571
event_add(&(conn->conn_wev), NULL);
usr.sbin/snmpd/application_agentx.c
575
ax_response(conn->conn_ax, 0, pdu->ap_header.aph_transactionid,
usr.sbin/snmpd/application_agentx.c
578
event_add(&(conn->conn_wev), NULL);
usr.sbin/snmpd/application_agentx.c
587
struct appl_agentx_connection *conn = session->sess_conn;
usr.sbin/snmpd/application_agentx.c
601
ax_response(conn->conn_ax, pdu->ap_header.aph_sessionid,
usr.sbin/snmpd/application_agentx.c
604
event_add(&(conn->conn_wev), NULL);
usr.sbin/snmpd/application_agentx.c
610
if (TAILQ_EMPTY(&(conn->conn_sessions)))
usr.sbin/snmpd/application_agentx.c
611
appl_agentx_free(conn, APPL_CLOSE_REASONOTHER);
usr.sbin/snmpd/application_agentx.c
635
struct appl_agentx_connection *conn = session->sess_conn;
usr.sbin/snmpd/application_agentx.c
640
TAILQ_REMOVE(&(conn->conn_sessions), session, sess_conn_entry);
usr.sbin/snmpd/application_agentx.c
923
struct appl_agentx_connection *conn = cookie;
usr.sbin/snmpd/application_agentx.c
925
switch (ax_send(conn->conn_ax)) {
usr.sbin/snmpd/application_agentx.c
929
log_warn("AgentX(%"PRIu32")", conn->conn_id);
usr.sbin/snmpd/application_agentx.c
930
ax_free(conn->conn_ax);
usr.sbin/snmpd/application_agentx.c
931
conn->conn_ax = NULL;
usr.sbin/snmpd/application_agentx.c
932
appl_agentx_free(conn, APPL_CLOSE_REASONOTHER);
usr.sbin/snmpd/application_agentx.c
939
event_add(&(conn->conn_wev), NULL);
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
3360
if(conn->timer.timer_in_list) {
usr.sbin/unbound/services/listen_dnsport.c
3364
doq_timer_list_remove(conn->table, &conn->timer);
usr.sbin/unbound/services/listen_dnsport.c
3366
if(conn->timer.timer_in_tree)
usr.sbin/unbound/services/listen_dnsport.c
3367
doq_timer_tree_remove(conn->table, &conn->timer);
usr.sbin/unbound/services/listen_dnsport.c
3368
doq_table_quic_size_subtract(table, sizeof(*conn)+conn->key.dcidlen);
usr.sbin/unbound/services/listen_dnsport.c
3369
doq_conn_delete(conn, table);
usr.sbin/unbound/services/listen_dnsport.c
3515
if(verbosity >= VERB_ALGO && timer->conn) {
usr.sbin/unbound/services/listen_dnsport.c
3518
addr_to_str((void*)&timer->conn->key.paddr.addr,
usr.sbin/unbound/services/listen_dnsport.c
3519
timer->conn->key.paddr.addrlen, a, sizeof(a));
usr.sbin/unbound/services/listen_dnsport.c
3555
struct doq_conn* conn = calloc(1, sizeof(*conn));
usr.sbin/unbound/services/listen_dnsport.c
3556
if(!conn)
usr.sbin/unbound/services/listen_dnsport.c
3558
conn->node.key = conn;
usr.sbin/unbound/services/listen_dnsport.c
3559
conn->doq_socket = c->doq_socket;
usr.sbin/unbound/services/listen_dnsport.c
3560
conn->table = c->doq_socket->table;
usr.sbin/unbound/services/listen_dnsport.c
3561
memmove(&conn->key.paddr.addr, &paddr->addr, paddr->addrlen);
usr.sbin/unbound/services/listen_dnsport.c
3562
conn->key.paddr.addrlen = paddr->addrlen;
usr.sbin/unbound/services/listen_dnsport.c
3563
memmove(&conn->key.paddr.localaddr, &paddr->localaddr,
usr.sbin/unbound/services/listen_dnsport.c
3565
conn->key.paddr.localaddrlen = paddr->localaddrlen;
usr.sbin/unbound/services/listen_dnsport.c
3566
conn->key.paddr.ifindex = paddr->ifindex;
usr.sbin/unbound/services/listen_dnsport.c
3567
conn->key.dcid = memdup((void*)dcid, dcidlen);
usr.sbin/unbound/services/listen_dnsport.c
3568
if(!conn->key.dcid) {
usr.sbin/unbound/services/listen_dnsport.c
3569
free(conn);
usr.sbin/unbound/services/listen_dnsport.c
3572
conn->key.dcidlen = dcidlen;
usr.sbin/unbound/services/listen_dnsport.c
3573
conn->version = version;
usr.sbin/unbound/services/listen_dnsport.c
3575
ngtcp2_ccerr_default(&conn->ccerr);
usr.sbin/unbound/services/listen_dnsport.c
3577
ngtcp2_connection_close_error_default(&conn->last_error);
usr.sbin/unbound/services/listen_dnsport.c
3579
rbtree_init(&conn->stream_tree, &doq_stream_cmp);
usr.sbin/unbound/services/listen_dnsport.c
3580
conn->timer.conn = conn;
usr.sbin/unbound/services/listen_dnsport.c
3581
lock_basic_init(&conn->lock);
usr.sbin/unbound/services/listen_dnsport.c
3582
lock_protect(&conn->lock, &conn->key, sizeof(conn->key));
usr.sbin/unbound/services/listen_dnsport.c
3583
lock_protect(&conn->lock, &conn->doq_socket, sizeof(conn->doq_socket));
usr.sbin/unbound/services/listen_dnsport.c
3584
lock_protect(&conn->lock, &conn->table, sizeof(conn->table));
usr.sbin/unbound/services/listen_dnsport.c
3585
lock_protect(&conn->lock, &conn->is_deleted, sizeof(conn->is_deleted));
usr.sbin/unbound/services/listen_dnsport.c
3586
lock_protect(&conn->lock, &conn->version, sizeof(conn->version));
usr.sbin/unbound/services/listen_dnsport.c
3587
lock_protect(&conn->lock, &conn->conn, sizeof(conn->conn));
usr.sbin/unbound/services/listen_dnsport.c
3588
lock_protect(&conn->lock, &conn->conid_list, sizeof(conn->conid_list));
usr.sbin/unbound/services/listen_dnsport.c
3590
lock_protect(&conn->lock, &conn->ccerr, sizeof(conn->ccerr));
usr.sbin/unbound/services/listen_dnsport.c
3592
lock_protect(&conn->lock, &conn->last_error, sizeof(conn->last_error));
usr.sbin/unbound/services/listen_dnsport.c
3594
lock_protect(&conn->lock, &conn->tls_alert, sizeof(conn->tls_alert));
usr.sbin/unbound/services/listen_dnsport.c
3595
lock_protect(&conn->lock, &conn->ssl, sizeof(conn->ssl));
usr.sbin/unbound/services/listen_dnsport.c
3596
lock_protect(&conn->lock, &conn->close_pkt, sizeof(conn->close_pkt));
usr.sbin/unbound/services/listen_dnsport.c
3597
lock_protect(&conn->lock, &conn->close_pkt_len, sizeof(conn->close_pkt_len));
usr.sbin/unbound/services/listen_dnsport.c
3598
lock_protect(&conn->lock, &conn->close_ecn, sizeof(conn->close_ecn));
usr.sbin/unbound/services/listen_dnsport.c
3599
lock_protect(&conn->lock, &conn->stream_tree, sizeof(conn->stream_tree));
usr.sbin/unbound/services/listen_dnsport.c
3600
lock_protect(&conn->lock, &conn->stream_write_first, sizeof(conn->stream_write_first));
usr.sbin/unbound/services/listen_dnsport.c
3601
lock_protect(&conn->lock, &conn->stream_write_last, sizeof(conn->stream_write_last));
usr.sbin/unbound/services/listen_dnsport.c
3602
lock_protect(&conn->lock, &conn->write_interest, sizeof(conn->write_interest));
usr.sbin/unbound/services/listen_dnsport.c
3603
lock_protect(&conn->lock, &conn->on_write_list, sizeof(conn->on_write_list));
usr.sbin/unbound/services/listen_dnsport.c
3604
lock_protect(&conn->lock, &conn->write_prev, sizeof(conn->write_prev));
usr.sbin/unbound/services/listen_dnsport.c
3605
lock_protect(&conn->lock, &conn->write_next, sizeof(conn->write_next));
usr.sbin/unbound/services/listen_dnsport.c
3606
return 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
3629
if(!conn)
usr.sbin/unbound/services/listen_dnsport.c
3631
lock_basic_destroy(&conn->lock);
usr.sbin/unbound/services/listen_dnsport.c
3632
lock_rw_wrlock(&conn->table->conid_lock);
usr.sbin/unbound/services/listen_dnsport.c
3633
doq_conn_clear_conids(conn);
usr.sbin/unbound/services/listen_dnsport.c
3634
lock_rw_unlock(&conn->table->conid_lock);
usr.sbin/unbound/services/listen_dnsport.c
3637
SSL_set_app_data(conn->ssl, NULL);
usr.sbin/unbound/services/listen_dnsport.c
3638
if(conn->stream_tree.count != 0) {
usr.sbin/unbound/services/listen_dnsport.c
3639
traverse_postorder(&conn->stream_tree, stream_tree_del, table);
usr.sbin/unbound/services/listen_dnsport.c
3641
free(conn->key.dcid);
usr.sbin/unbound/services/listen_dnsport.c
3642
SSL_free(conn->ssl);
usr.sbin/unbound/services/listen_dnsport.c
3644
ngtcp2_crypto_ossl_ctx_del(conn->ossl_ctx);
usr.sbin/unbound/services/listen_dnsport.c
3646
ngtcp2_conn_del(conn->conn);
usr.sbin/unbound/services/listen_dnsport.c
3647
free(conn->close_pkt);
usr.sbin/unbound/services/listen_dnsport.c
3648
free(conn);
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
3842
(void)rbtree_insert(&conn->stream_tree, &stream->node);
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
3849
(void)rbtree_delete(&conn->stream_tree, &stream->node);
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
3880
node = rbtree_search(&conn->stream_tree, &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
3892
stream->write_prev = conn->stream_write_last;
usr.sbin/unbound/services/listen_dnsport.c
3893
if(conn->stream_write_last)
usr.sbin/unbound/services/listen_dnsport.c
3894
conn->stream_write_last->write_next = stream;
usr.sbin/unbound/services/listen_dnsport.c
3896
conn->stream_write_first = stream;
usr.sbin/unbound/services/listen_dnsport.c
3897
conn->stream_write_last = 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
3910
else conn->stream_write_last = stream->write_prev;
usr.sbin/unbound/services/listen_dnsport.c
3913
else conn->stream_write_first = stream->write_next;
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
3952
doq_stream_off_write_list(conn, stream);
usr.sbin/unbound/services/listen_dnsport.c
3956
ret = ngtcp2_conn_shutdown_stream(conn->conn,
usr.sbin/unbound/services/listen_dnsport.c
3966
doq_conn_write_enable(conn);
usr.sbin/unbound/services/listen_dnsport.c
3969
ngtcp2_conn_extend_max_streams_bidi(conn->conn, 1);
usr.sbin/unbound/services/listen_dnsport.c
3970
doq_conn_write_enable(conn);
usr.sbin/unbound/services/listen_dnsport.c
3971
doq_stream_remove_in_buffer(stream, conn->doq_socket->table);
usr.sbin/unbound/services/listen_dnsport.c
3972
doq_stream_remove_out_buffer(stream, conn->doq_socket->table);
usr.sbin/unbound/services/listen_dnsport.c
3973
doq_table_quic_size_subtract(conn->doq_socket->table, sizeof(*stream));
usr.sbin/unbound/services/listen_dnsport.c
3974
doq_conn_del_stream(conn, 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
4015
doq_table_quic_size_subtract(conn->doq_socket->table,
usr.sbin/unbound/services/listen_dnsport.c
4019
doq_table_quic_size_add(conn->doq_socket->table, stream->outlen);
usr.sbin/unbound/services/listen_dnsport.c
4020
doq_stream_on_write_list(conn, stream);
usr.sbin/unbound/services/listen_dnsport.c
4021
doq_conn_write_enable(conn);
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
4053
addr_to_str((void*)&conn->key.paddr.addr,
usr.sbin/unbound/services/listen_dnsport.c
4054
conn->key.paddr.addrlen, a, sizeof(a));
usr.sbin/unbound/services/listen_dnsport.c
4060
c = conn->doq_socket->cp;
usr.sbin/unbound/services/listen_dnsport.c
4073
if(!doq_conn_key_store_repinfo(&conn->key, &c->repinfo)) {
usr.sbin/unbound/services/listen_dnsport.c
4079
conn->doq_socket->current_conn = conn;
usr.sbin/unbound/services/listen_dnsport.c
4082
conn->doq_socket->current_conn = NULL;
usr.sbin/unbound/services/listen_dnsport.c
4083
if(!doq_stream_send_reply(conn, stream, c->buffer)) {
usr.sbin/unbound/services/listen_dnsport.c
4089
conn->doq_socket->current_conn = NULL;
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
4174
if(!doq_stream_close(conn, stream, 1))
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
4196
doq_fill_rand(conn->doq_socket->rnd, data, datalen);
usr.sbin/unbound/services/listen_dnsport.c
4197
if(!doq_conid_find(conn->table, data, datalen)) {
usr.sbin/unbound/services/listen_dnsport.c
4219
doq_get_new_connection_id_cb(ngtcp2_conn* ATTR_UNUSED(conn), ngtcp2_cid* cid,
usr.sbin/unbound/services/listen_dnsport.c
4248
doq_remove_connection_id_cb(ngtcp2_conn* ATTR_UNUSED(conn),
usr.sbin/unbound/services/listen_dnsport.c
4260
doq_submit_new_token(struct doq_conn* conn)
usr.sbin/unbound/services/listen_dnsport.c
4265
const ngtcp2_path* path = ngtcp2_conn_get_path(conn->conn);
usr.sbin/unbound/services/listen_dnsport.c
4269
conn->doq_socket->static_secret,
usr.sbin/unbound/services/listen_dnsport.c
4270
conn->doq_socket->static_secret_len, path->remote.addr,
usr.sbin/unbound/services/listen_dnsport.c
4278
ret = ngtcp2_conn_submit_new_token(conn->conn, token, tokenlen);
usr.sbin/unbound/services/listen_dnsport.c
4289
doq_handshake_completed_cb(ngtcp2_conn* ATTR_UNUSED(conn), void* 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
4324
doq_stream_open_cb(ngtcp2_conn* ATTR_UNUSED(conn), int64_t stream_id,
usr.sbin/unbound/services/listen_dnsport.c
4342
rv = ngtcp2_conn_shutdown_stream(doq_conn->conn,
usr.sbin/unbound/services/listen_dnsport.c
4366
doq_recv_stream_data_cb(ngtcp2_conn* ATTR_UNUSED(conn), uint32_t flags,
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
4413
doq_stream_close_cb(ngtcp2_conn* ATTR_UNUSED(conn), uint32_t flags,
usr.sbin/unbound/services/listen_dnsport.c
4442
doq_stream_reset_cb(ngtcp2_conn* ATTR_UNUSED(conn), int64_t stream_id,
usr.sbin/unbound/services/listen_dnsport.c
4465
doq_acked_stream_data_offset_cb(ngtcp2_conn* ATTR_UNUSED(conn),
usr.sbin/unbound/services/listen_dnsport.c
4507
doq_application_tx_key_cb(struct doq_conn* conn)
usr.sbin/unbound/services/listen_dnsport.c
4513
(int)ngtcp2_conn_get_max_data_left(conn->conn));
usr.sbin/unbound/services/listen_dnsport.c
4516
(int)ngtcp2_conn_get_max_local_streams_uni(conn->conn));
usr.sbin/unbound/services/listen_dnsport.c
4519
(int)ngtcp2_conn_get_streams_uni_left(conn->conn));
usr.sbin/unbound/services/listen_dnsport.c
4521
(int)ngtcp2_conn_get_streams_bidi_left(conn->conn));
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
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
4745
struct doq_conn* conn = (struct doq_conn*)conn_ref->user_data;
usr.sbin/unbound/services/listen_dnsport.c
4746
return conn->conn;
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
4762
if((ret=ngtcp2_crypto_ossl_ctx_new(&conn->ossl_ctx, NULL)) != 0) {
usr.sbin/unbound/services/listen_dnsport.c
4768
ngtcp2_crypto_ossl_ctx_set_ssl(conn->ossl_ctx, ssl);
usr.sbin/unbound/services/listen_dnsport.c
4776
conn->conn_ref.get_conn = &doq_conn_ref_get_conn;
usr.sbin/unbound/services/listen_dnsport.c
4777
conn->conn_ref.user_data = conn;
usr.sbin/unbound/services/listen_dnsport.c
4778
SSL_set_app_data(ssl, &conn->conn_ref);
usr.sbin/unbound/services/listen_dnsport.c
4780
SSL_set_app_data(ssl, 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
4810
ngtcp2_cid_init(&dcid, conn->key.dcid, conn->key.dcidlen);
usr.sbin/unbound/services/listen_dnsport.c
4812
path.remote.addr = (struct sockaddr*)&conn->key.paddr.addr;
usr.sbin/unbound/services/listen_dnsport.c
4813
path.remote.addrlen = conn->key.paddr.addrlen;
usr.sbin/unbound/services/listen_dnsport.c
4814
path.local.addr = (struct sockaddr*)&conn->key.paddr.localaddr;
usr.sbin/unbound/services/listen_dnsport.c
4815
path.local.addrlen = conn->key.paddr.localaddrlen;
usr.sbin/unbound/services/listen_dnsport.c
4844
settings.rand_ctx.native_handle = conn->doq_socket->rnd;
usr.sbin/unbound/services/listen_dnsport.c
4857
params.max_idle_timeout = conn->doq_socket->idle_timeout;
usr.sbin/unbound/services/listen_dnsport.c
4869
ngtcp2_cid_init(¶ms.retry_scid, conn->key.dcid,
usr.sbin/unbound/services/listen_dnsport.c
4870
conn->key.dcidlen);
usr.sbin/unbound/services/listen_dnsport.c
4873
ngtcp2_cid_init(¶ms.original_dcid, conn->key.dcid,
usr.sbin/unbound/services/listen_dnsport.c
4874
conn->key.dcidlen);
usr.sbin/unbound/services/listen_dnsport.c
4879
doq_fill_rand(conn->doq_socket->rnd, params.stateless_reset_token,
usr.sbin/unbound/services/listen_dnsport.c
4881
sv_scid.datalen = conn->doq_socket->sv_scidlen;
usr.sbin/unbound/services/listen_dnsport.c
4882
lock_rw_wrlock(&conn->table->conid_lock);
usr.sbin/unbound/services/listen_dnsport.c
4883
if(!doq_conn_generate_new_conid(conn, sv_scid.data, sv_scid.datalen)) {
usr.sbin/unbound/services/listen_dnsport.c
4884
lock_rw_unlock(&conn->table->conid_lock);
usr.sbin/unbound/services/listen_dnsport.c
4888
rv = ngtcp2_conn_server_new(&conn->conn, &scid_cid, &sv_scid, &path,
usr.sbin/unbound/services/listen_dnsport.c
4889
conn->version, &callbacks, &settings, ¶ms, NULL, conn);
usr.sbin/unbound/services/listen_dnsport.c
4891
lock_rw_unlock(&conn->table->conid_lock);
usr.sbin/unbound/services/listen_dnsport.c
4896
if(!doq_conn_setup_conids(conn)) {
usr.sbin/unbound/services/listen_dnsport.c
4897
lock_rw_unlock(&conn->table->conid_lock);
usr.sbin/unbound/services/listen_dnsport.c
4901
lock_rw_unlock(&conn->table->conid_lock);
usr.sbin/unbound/services/listen_dnsport.c
4902
conn->ssl = doq_ssl_server_setup((SSL_CTX*)conn->doq_socket->ctx,
usr.sbin/unbound/services/listen_dnsport.c
4903
conn);
usr.sbin/unbound/services/listen_dnsport.c
4904
if(!conn->ssl) {
usr.sbin/unbound/services/listen_dnsport.c
4909
ngtcp2_conn_set_tls_native_handle(conn->conn, conn->ossl_ctx);
usr.sbin/unbound/services/listen_dnsport.c
4911
ngtcp2_conn_set_tls_native_handle(conn->conn, conn->ssl);
usr.sbin/unbound/services/listen_dnsport.c
4913
doq_conn_write_enable(conn);
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
4936
conid->next = conn->conid_list;
usr.sbin/unbound/services/listen_dnsport.c
4937
if(conn->conid_list)
usr.sbin/unbound/services/listen_dnsport.c
4938
conn->conid_list->prev = conid;
usr.sbin/unbound/services/listen_dnsport.c
4939
conn->conid_list = 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
4948
else conn->conid_list = conid->next;
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
4992
if(conid->key.dcidlen == conn->key.dcidlen &&
usr.sbin/unbound/services/listen_dnsport.c
4993
memcmp(conid->key.dcid, conn->key.dcid, conid->key.dcidlen)==0
usr.sbin/unbound/services/listen_dnsport.c
4994
&& conid->key.paddr.addrlen == conn->key.paddr.addrlen &&
usr.sbin/unbound/services/listen_dnsport.c
4995
memcmp(&conid->key.paddr.addr, &conn->key.paddr.addr,
usr.sbin/unbound/services/listen_dnsport.c
4997
conid->key.paddr.localaddrlen == conn->key.paddr.localaddrlen &&
usr.sbin/unbound/services/listen_dnsport.c
4998
memcmp(&conid->key.paddr.localaddr, &conn->key.paddr.localaddr,
usr.sbin/unbound/services/listen_dnsport.c
5000
conid->key.paddr.ifindex == conn->key.paddr.ifindex)
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
5009
conid = doq_conid_find(conn->table, data, datalen);
usr.sbin/unbound/services/listen_dnsport.c
5010
if(conid && !conid_is_for_conn(conn, conid)) {
usr.sbin/unbound/services/listen_dnsport.c
5023
conid = doq_conid_create(data, datalen, &conn->key);
usr.sbin/unbound/services/listen_dnsport.c
5026
doq_conid_list_insert(conn, conid);
usr.sbin/unbound/services/listen_dnsport.c
5027
(void)rbtree_insert(conn->table->conid_tree, &conid->node);
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
5036
conid = doq_conid_find(conn->table, data, datalen);
usr.sbin/unbound/services/listen_dnsport.c
5037
if(conid && !conid_is_for_conn(conn, conid))
usr.sbin/unbound/services/listen_dnsport.c
5040
(void)rbtree_delete(conn->table->conid_tree,
usr.sbin/unbound/services/listen_dnsport.c
5042
doq_conid_list_remove(conn, conid);
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
5055
if(!doq_conn_associate_conid(conn, scids[i].data,
usr.sbin/unbound/services/listen_dnsport.c
5059
if(!doq_conn_associate_conid(conn, conn->key.dcid, conn->key.dcidlen))
usr.sbin/unbound/services/listen_dnsport.c
5065
doq_conn_setup_conids(struct doq_conn* conn)
usr.sbin/unbound/services/listen_dnsport.c
5069
ngtcp2_conn_get_scid(conn->conn, NULL);
usr.sbin/unbound/services/listen_dnsport.c
5071
ngtcp2_conn_get_num_scid(conn->conn);
usr.sbin/unbound/services/listen_dnsport.c
5077
ngtcp2_conn_get_scid(conn->conn, ids);
usr.sbin/unbound/services/listen_dnsport.c
5078
return doq_conn_setup_id_array_and_dcid(conn, ids, num_scid);
usr.sbin/unbound/services/listen_dnsport.c
5084
ngtcp2_conn_get_scid(conn->conn, scids);
usr.sbin/unbound/services/listen_dnsport.c
5085
if(!doq_conn_setup_id_array_and_dcid(conn, scids, num_scid)) {
usr.sbin/unbound/services/listen_dnsport.c
5095
doq_conn_clear_conids(struct doq_conn* conn)
usr.sbin/unbound/services/listen_dnsport.c
5098
if(!conn)
usr.sbin/unbound/services/listen_dnsport.c
5100
p = conn->conid_list;
usr.sbin/unbound/services/listen_dnsport.c
5103
(void)rbtree_delete(conn->table->conid_tree, p->node.key);
usr.sbin/unbound/services/listen_dnsport.c
5107
conn->conid_list = NULL;
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
5138
if(!conn)
usr.sbin/unbound/services/listen_dnsport.c
5142
ngtcp2_conn_in_closing_period(conn->conn)
usr.sbin/unbound/services/listen_dnsport.c
5144
ngtcp2_conn_is_in_closing_period(conn->conn)
usr.sbin/unbound/services/listen_dnsport.c
5150
ngtcp2_conn_in_draining_period(conn->conn)
usr.sbin/unbound/services/listen_dnsport.c
5152
ngtcp2_conn_is_in_draining_period(conn->conn)
usr.sbin/unbound/services/listen_dnsport.c
5155
doq_conn_write_disable(conn);
usr.sbin/unbound/services/listen_dnsport.c
5162
ret = ngtcp2_conn_write_connection_close(conn->conn, &ps.path,
usr.sbin/unbound/services/listen_dnsport.c
5166
&conn->ccerr
usr.sbin/unbound/services/listen_dnsport.c
5168
&conn->last_error
usr.sbin/unbound/services/listen_dnsport.c
5184
conn->close_pkt = memdup(sldns_buffer_begin(c->doq_socket->pkt_buf),
usr.sbin/unbound/services/listen_dnsport.c
5186
if(!conn->close_pkt) {
usr.sbin/unbound/services/listen_dnsport.c
5190
conn->close_pkt_len = sldns_buffer_limit(c->doq_socket->pkt_buf);
usr.sbin/unbound/services/listen_dnsport.c
5191
conn->close_ecn = pi.ecn;
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
5199
if(!conn)
usr.sbin/unbound/services/listen_dnsport.c
5201
if(!conn->close_pkt)
usr.sbin/unbound/services/listen_dnsport.c
5203
if(conn->close_pkt_len > sldns_buffer_capacity(c->doq_socket->pkt_buf))
usr.sbin/unbound/services/listen_dnsport.c
5206
sldns_buffer_write(c->doq_socket->pkt_buf, conn->close_pkt, conn->close_pkt_len);
usr.sbin/unbound/services/listen_dnsport.c
5209
doq_send_pkt(c, &conn->key.paddr, conn->close_ecn);
usr.sbin/unbound/services/listen_dnsport.c
5210
doq_conn_write_disable(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
5220
if(conn->ccerr.type == NGTCP2_CCERR_TYPE_IDLE_CLOSE)
usr.sbin/unbound/services/listen_dnsport.c
5223
if(conn->last_error.type ==
usr.sbin/unbound/services/listen_dnsport.c
5227
if(!doq_conn_start_closing_period(c, conn))
usr.sbin/unbound/services/listen_dnsport.c
5231
ngtcp2_conn_in_draining_period(conn->conn)
usr.sbin/unbound/services/listen_dnsport.c
5233
ngtcp2_conn_is_in_draining_period(conn->conn)
usr.sbin/unbound/services/listen_dnsport.c
5236
doq_conn_write_disable(conn);
usr.sbin/unbound/services/listen_dnsport.c
5239
doq_conn_write_enable(conn);
usr.sbin/unbound/services/listen_dnsport.c
5240
if(!doq_conn_send_close(c, 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
5260
ret = ngtcp2_conn_read_pkt(conn->conn, &path, pi,
usr.sbin/unbound/services/listen_dnsport.c
5271
doq_conn_write_disable(conn);
usr.sbin/unbound/services/listen_dnsport.c
5290
!conn->ccerr.error_code
usr.sbin/unbound/services/listen_dnsport.c
5292
!conn->last_error.error_code
usr.sbin/unbound/services/listen_dnsport.c
5299
ngtcp2_ccerr_set_tls_alert(&conn->ccerr,
usr.sbin/unbound/services/listen_dnsport.c
5300
conn->tls_alert, NULL, 0);
usr.sbin/unbound/services/listen_dnsport.c
5303
&conn->last_error, conn->tls_alert,
usr.sbin/unbound/services/listen_dnsport.c
5310
!conn->ccerr.error_code
usr.sbin/unbound/services/listen_dnsport.c
5312
!conn->last_error.error_code
usr.sbin/unbound/services/listen_dnsport.c
5316
ngtcp2_ccerr_set_liberr(&conn->ccerr, ret,
usr.sbin/unbound/services/listen_dnsport.c
5320
&conn->last_error, ret, NULL, 0);
usr.sbin/unbound/services/listen_dnsport.c
5326
if(!doq_conn_close_error(c, conn)) {
usr.sbin/unbound/services/listen_dnsport.c
5332
doq_conn_write_enable(conn);
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
5341
doq_stream_off_write_list(conn, 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
5348
struct doq_stream* stream = conn->stream_write_first;
usr.sbin/unbound/services/listen_dnsport.c
5400
ret = ngtcp2_conn_writev_stream(conn->conn, &ps.path, &pi,
usr.sbin/unbound/services/listen_dnsport.c
5412
conn, stream);
usr.sbin/unbound/services/listen_dnsport.c
5420
&conn->ccerr, -1, NULL, 0);
usr.sbin/unbound/services/listen_dnsport.c
5422
ngtcp2_connection_close_error_set_application_error(&conn->last_error, -1, NULL, 0);
usr.sbin/unbound/services/listen_dnsport.c
5426
if(!doq_conn_close_error(c, conn)) {
usr.sbin/unbound/services/listen_dnsport.c
5435
&conn->ccerr, -1, NULL, 0);
usr.sbin/unbound/services/listen_dnsport.c
5437
ngtcp2_connection_close_error_set_application_error(&conn->last_error, -1, NULL, 0);
usr.sbin/unbound/services/listen_dnsport.c
5441
if(!doq_conn_close_error(c, conn)) {
usr.sbin/unbound/services/listen_dnsport.c
5451
ngtcp2_ccerr_set_liberr(&conn->ccerr, ret, NULL, 0);
usr.sbin/unbound/services/listen_dnsport.c
5454
&conn->last_error, ret, NULL, 0);
usr.sbin/unbound/services/listen_dnsport.c
5458
if(!doq_conn_close_error(c, conn)) {
usr.sbin/unbound/services/listen_dnsport.c
5470
doq_stream_write_is_done(conn, stream);
usr.sbin/unbound/services/listen_dnsport.c
5474
doq_conn_write_disable(conn);
usr.sbin/unbound/services/listen_dnsport.c
5475
ngtcp2_conn_update_pkt_tx_time(conn->conn, ts);
usr.sbin/unbound/services/listen_dnsport.c
5480
doq_send_pkt(c, &conn->key.paddr, pi.ecn);
usr.sbin/unbound/services/listen_dnsport.c
5489
ngtcp2_conn_update_pkt_tx_time(conn->conn, ts);
usr.sbin/unbound/services/listen_dnsport.c
5494
doq_conn_write_enable(struct doq_conn* conn)
usr.sbin/unbound/services/listen_dnsport.c
5496
conn->write_interest = 1;
usr.sbin/unbound/services/listen_dnsport.c
5500
doq_conn_write_disable(struct doq_conn* conn)
usr.sbin/unbound/services/listen_dnsport.c
5502
conn->write_interest = 0;
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
5509
if(conn->on_write_list)
usr.sbin/unbound/services/listen_dnsport.c
5511
conn->write_prev = table->write_list_last;
usr.sbin/unbound/services/listen_dnsport.c
5513
table->write_list_last->write_next = conn;
usr.sbin/unbound/services/listen_dnsport.c
5514
else table->write_list_first = conn;
usr.sbin/unbound/services/listen_dnsport.c
5515
conn->write_next = NULL;
usr.sbin/unbound/services/listen_dnsport.c
5516
table->write_list_last = conn;
usr.sbin/unbound/services/listen_dnsport.c
5517
conn->on_write_list = 1;
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
5523
if(!conn->on_write_list)
usr.sbin/unbound/services/listen_dnsport.c
5525
if(conn->write_next)
usr.sbin/unbound/services/listen_dnsport.c
5526
conn->write_next->write_prev = conn->write_prev;
usr.sbin/unbound/services/listen_dnsport.c
5527
else table->write_list_last = conn->write_prev;
usr.sbin/unbound/services/listen_dnsport.c
5528
if(conn->write_prev)
usr.sbin/unbound/services/listen_dnsport.c
5529
conn->write_prev->write_next = conn->write_next;
usr.sbin/unbound/services/listen_dnsport.c
5530
else table->write_list_first = conn->write_next;
usr.sbin/unbound/services/listen_dnsport.c
5531
conn->write_prev = NULL;
usr.sbin/unbound/services/listen_dnsport.c
5532
conn->write_next = NULL;
usr.sbin/unbound/services/listen_dnsport.c
5533
conn->on_write_list = 0;
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
5539
if(conn->write_interest && conn->on_write_list)
usr.sbin/unbound/services/listen_dnsport.c
5541
if(!conn->write_interest && !conn->on_write_list)
usr.sbin/unbound/services/listen_dnsport.c
5543
if(conn->write_interest)
usr.sbin/unbound/services/listen_dnsport.c
5544
doq_conn_write_list_append(table, conn);
usr.sbin/unbound/services/listen_dnsport.c
5545
else doq_conn_write_list_remove(table, conn);
usr.sbin/unbound/services/listen_dnsport.c
5551
struct doq_conn* conn = table->write_list_first;
usr.sbin/unbound/services/listen_dnsport.c
5552
if(!conn)
usr.sbin/unbound/services/listen_dnsport.c
5554
lock_basic_lock(&conn->lock);
usr.sbin/unbound/services/listen_dnsport.c
5555
table->write_list_first = conn->write_next;
usr.sbin/unbound/services/listen_dnsport.c
5556
if(conn->write_next)
usr.sbin/unbound/services/listen_dnsport.c
5557
conn->write_next->write_prev = NULL;
usr.sbin/unbound/services/listen_dnsport.c
5559
conn->write_next = NULL;
usr.sbin/unbound/services/listen_dnsport.c
5560
conn->write_prev = NULL;
usr.sbin/unbound/services/listen_dnsport.c
5561
conn->on_write_list = 0;
usr.sbin/unbound/services/listen_dnsport.c
5562
return conn;
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
5568
ngtcp2_tstamp expiry = ngtcp2_conn_get_expiry(conn->conn);
usr.sbin/unbound/services/listen_dnsport.c
5589
if(conn->timer.timer_in_tree || conn->timer.timer_in_list) {
usr.sbin/unbound/services/listen_dnsport.c
5590
if(conn->timer.time.tv_sec == tv->tv_sec &&
usr.sbin/unbound/services/listen_dnsport.c
5591
conn->timer.time.tv_usec == tv->tv_usec)
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
5602
addr_to_str((void*)&conn->key.paddr.addr, conn->key.paddr.addrlen,
usr.sbin/unbound/services/listen_dnsport.c
5604
addr_to_str((void*)&conn->key.paddr.localaddr,
usr.sbin/unbound/services/listen_dnsport.c
5605
conn->key.paddr.localaddrlen, localstr, sizeof(localstr));
usr.sbin/unbound/services/listen_dnsport.c
5610
doq_conn_handle_timeout(struct doq_conn* conn)
usr.sbin/unbound/services/listen_dnsport.c
5616
doq_conn_log_line(conn, "timeout");
usr.sbin/unbound/services/listen_dnsport.c
5618
rv = ngtcp2_conn_handle_expiry(conn->conn, now);
usr.sbin/unbound/services/listen_dnsport.c
5623
ngtcp2_ccerr_set_liberr(&conn->ccerr, rv, NULL, 0);
usr.sbin/unbound/services/listen_dnsport.c
5626
&conn->last_error, rv, NULL, 0);
usr.sbin/unbound/services/listen_dnsport.c
5628
if(!doq_conn_close_error(conn->doq_socket->cp, conn)) {
usr.sbin/unbound/services/listen_dnsport.c
5634
doq_conn_write_enable(conn);
usr.sbin/unbound/services/listen_dnsport.c
5635
if(!doq_conn_write_streams(conn->doq_socket->cp, conn, NULL)) {
usr.sbin/unbound/services/listen_dnsport.h
556
struct doq_conn* conn;
usr.sbin/unbound/services/listen_dnsport.h
596
struct ngtcp2_conn* conn;
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
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/doqclient.c
1073
struct ngtcp2_conn* conn = NULL;
usr.sbin/unbound/testcode/doqclient.c
1136
rv = ngtcp2_conn_client_new(&conn, &dcid, &scid, &path,
usr.sbin/unbound/testcode/doqclient.c
1140
if(!conn) fatal_exit("could not ngtcp2_conn_client_new: %s",
usr.sbin/unbound/testcode/doqclient.c
1143
return conn;
usr.sbin/unbound/testcode/doqclient.c
1190
ngtcp2_ssize len = ngtcp2_conn_encode_0rtt_transport_params(data->conn,
usr.sbin/unbound/testcode/doqclient.c
1214
ngtcp2_conn_get_remote_transport_params(data->conn, ¶ms);
usr.sbin/unbound/testcode/doqclient.c
1228
(int)ngtcp2_conn_get_max_data_left(data->conn));
usr.sbin/unbound/testcode/doqclient.c
1231
(int)ngtcp2_conn_get_max_local_streams_uni(data->conn));
usr.sbin/unbound/testcode/doqclient.c
1234
(int)ngtcp2_conn_get_streams_uni_left(data->conn));
usr.sbin/unbound/testcode/doqclient.c
1236
(int)ngtcp2_conn_get_streams_bidi_left(data->conn));
usr.sbin/unbound/testcode/doqclient.c
1263
if(ngtcp2_crypto_derive_and_install_rx_key(data->conn, NULL,
usr.sbin/unbound/testcode/doqclient.c
1275
if(ngtcp2_crypto_derive_and_install_tx_key(data->conn, NULL,
usr.sbin/unbound/testcode/doqclient.c
1303
rv = ngtcp2_conn_submit_crypto_data(doqdata->conn, level, data, len);
usr.sbin/unbound/testcode/doqclient.c
1307
ngtcp2_conn_set_tls_error(doqdata->conn, rv);
usr.sbin/unbound/testcode/doqclient.c
1553
if(!data->conn ||
usr.sbin/unbound/testcode/doqclient.c
1555
ngtcp2_conn_in_closing_period(data->conn) ||
usr.sbin/unbound/testcode/doqclient.c
1557
ngtcp2_conn_is_in_closing_period(data->conn) ||
usr.sbin/unbound/testcode/doqclient.c
1560
ngtcp2_conn_in_draining_period(data->conn)
usr.sbin/unbound/testcode/doqclient.c
1562
ngtcp2_conn_is_in_draining_period(data->conn)
usr.sbin/unbound/testcode/doqclient.c
1587
data->conn, &ps.path, &pi, sldns_buffer_begin(data->pkt_buf),
usr.sbin/unbound/testcode/doqclient.c
1626
rv = ngtcp2_conn_handle_expiry(data->conn, now);
usr.sbin/unbound/testcode/doqclient.c
1647
ngtcp2_tstamp expiry = ngtcp2_conn_get_expiry(data->conn);
usr.sbin/unbound/testcode/doqclient.c
1724
rv = ngtcp2_conn_read_pkt(data->conn, &path, &pi,
usr.sbin/unbound/testcode/doqclient.c
1793
size_t send_quantum = ngtcp2_conn_get_send_quantum(data->conn);
usr.sbin/unbound/testcode/doqclient.c
1878
ngtcp2_conn_update_pkt_tx_time(data->conn, ts);
usr.sbin/unbound/testcode/doqclient.c
1923
ret = ngtcp2_conn_writev_stream(data->conn, &ps.path, &pi,
usr.sbin/unbound/testcode/doqclient.c
1959
ngtcp2_conn_update_pkt_tx_time(data->conn, ts);
usr.sbin/unbound/testcode/doqclient.c
1977
ngtcp2_conn_update_pkt_tx_time(data->conn, ts);
usr.sbin/unbound/testcode/doqclient.c
1993
ngtcp2_conn_update_pkt_tx_time(data->conn, ts);
usr.sbin/unbound/testcode/doqclient.c
2016
ngtcp2_conn_update_pkt_tx_time(data->conn, ts);
usr.sbin/unbound/testcode/doqclient.c
2024
ngtcp2_conn_update_pkt_tx_time(data->conn, ts);
usr.sbin/unbound/testcode/doqclient.c
2038
ngtcp2_conn_in_closing_period(data->conn)
usr.sbin/unbound/testcode/doqclient.c
2040
ngtcp2_conn_is_in_closing_period(data->conn)
usr.sbin/unbound/testcode/doqclient.c
2178
rv = ngtcp2_conn_decode_and_set_0rtt_transport_params(data->conn,
usr.sbin/unbound/testcode/doqclient.c
219
return data->conn;
usr.sbin/unbound/testcode/doqclient.c
2216
ngtcp2_conn_set_early_remote_transport_params(data->conn, ¶ms);
usr.sbin/unbound/testcode/doqclient.c
2277
data->conn = conn_client_setup(data);
usr.sbin/unbound/testcode/doqclient.c
2298
ngtcp2_conn_set_tls_native_handle(data->conn, data->ossl_ctx);
usr.sbin/unbound/testcode/doqclient.c
2300
ngtcp2_conn_set_tls_native_handle(data->conn, data->ssl);
usr.sbin/unbound/testcode/doqclient.c
2331
if(data->conn && data->dest_addr_len != 0) {
usr.sbin/unbound/testcode/doqclient.c
2334
const struct ngtcp2_path* path6 = ngtcp2_conn_get_path(data->conn);
usr.sbin/unbound/testcode/doqclient.c
2340
const struct ngtcp2_path* path = ngtcp2_conn_get_path(data->conn);
usr.sbin/unbound/testcode/doqclient.c
2354
ngtcp2_conn_del(data->conn);
usr.sbin/unbound/testcode/doqclient.c
765
rv = ngtcp2_conn_open_bidi_stream(data->conn, &stream_id,
usr.sbin/unbound/testcode/doqclient.c
815
static int get_new_connection_id_cb(struct ngtcp2_conn* ATTR_UNUSED(conn),
usr.sbin/unbound/testcode/doqclient.c
833
rv = ngtcp2_conn_tls_early_data_rejected(data->conn);
usr.sbin/unbound/testcode/doqclient.c
835
rv = ngtcp2_conn_early_data_rejected(data->conn);
usr.sbin/unbound/testcode/doqclient.c
868
handshake_completed(ngtcp2_conn* ATTR_UNUSED(conn), void* user_data)
usr.sbin/unbound/testcode/doqclient.c
873
(int)ngtcp2_conn_get_max_data_left(data->conn));
usr.sbin/unbound/testcode/doqclient.c
876
(int)ngtcp2_conn_get_max_local_streams_uni(data->conn));
usr.sbin/unbound/testcode/doqclient.c
879
(int)ngtcp2_conn_get_streams_uni_left(data->conn));
usr.sbin/unbound/testcode/doqclient.c
881
(int)ngtcp2_conn_get_streams_bidi_left(data->conn));
usr.sbin/unbound/testcode/doqclient.c
915
extend_max_local_streams_bidi(ngtcp2_conn* ATTR_UNUSED(conn),
usr.sbin/unbound/testcode/doqclient.c
92
struct ngtcp2_conn* conn;
usr.sbin/unbound/testcode/doqclient.c
922
(int)ngtcp2_conn_get_max_data_left(data->conn));
usr.sbin/unbound/testcode/doqclient.c
925
(int)ngtcp2_conn_get_max_local_streams_uni(data->conn));
usr.sbin/unbound/testcode/doqclient.c
928
(int)ngtcp2_conn_get_streams_uni_left(data->conn));
usr.sbin/unbound/testcode/doqclient.c
930
(int)ngtcp2_conn_get_streams_bidi_left(data->conn));
usr.sbin/unbound/testcode/doqclient.c
937
recv_stream_data(ngtcp2_conn* ATTR_UNUSED(conn), uint32_t flags,
usr.sbin/unbound/testcode/doqclient.c
969
ngtcp2_conn_extend_max_stream_offset(doqdata->conn, stream_id, datalen);
usr.sbin/unbound/testcode/doqclient.c
970
ngtcp2_conn_extend_max_offset(doqdata->conn, datalen);
usr.sbin/unbound/testcode/doqclient.c
976
stream_reset(ngtcp2_conn* ATTR_UNUSED(conn), int64_t stream_id,
usr.sbin/unbound/util/netevent.c
1672
struct doq_conn* conn;
usr.sbin/unbound/util/netevent.c
1682
conn = doq_conn_find(table, &key.paddr.addr,
usr.sbin/unbound/util/netevent.c
1686
if(!conn) {
usr.sbin/unbound/util/netevent.c
1693
lock_basic_lock(&conn->lock);
usr.sbin/unbound/util/netevent.c
1694
if(conn->is_deleted) {
usr.sbin/unbound/util/netevent.c
1696
lock_basic_unlock(&conn->lock);
usr.sbin/unbound/util/netevent.c
1700
return conn;
usr.sbin/unbound/util/netevent.c
1711
struct doq_conn* conn;
usr.sbin/unbound/util/netevent.c
1713
conn = doq_conn_find(table, &paddr->addr, paddr->addrlen,
usr.sbin/unbound/util/netevent.c
1716
if(conn && conn->is_deleted) {
usr.sbin/unbound/util/netevent.c
1717
conn = NULL;
usr.sbin/unbound/util/netevent.c
1719
if(conn) {
usr.sbin/unbound/util/netevent.c
1720
lock_basic_lock(&conn->lock);
usr.sbin/unbound/util/netevent.c
1725
conn = doq_conn_find_by_id(table, dcid, dcidlen);
usr.sbin/unbound/util/netevent.c
1726
if(conn) {
usr.sbin/unbound/util/netevent.c
1730
return conn;
usr.sbin/unbound/util/netevent.c
1737
struct doq_pkt_addr* paddr, struct doq_conn** conn)
usr.sbin/unbound/util/netevent.c
1799
*conn = doq_conn_find_by_addr_or_cid(c->doq_socket->table, paddr,
usr.sbin/unbound/util/netevent.c
1806
if(*conn)
usr.sbin/unbound/util/netevent.c
1807
(*conn)->doq_socket = c->doq_socket;
usr.sbin/unbound/util/netevent.c
1958
doq_delete_connection(struct comm_point* c, struct doq_conn* conn)
usr.sbin/unbound/util/netevent.c
1963
if(!conn)
usr.sbin/unbound/util/netevent.c
1966
conn->is_deleted = 1;
usr.sbin/unbound/util/netevent.c
1967
doq_conn_write_disable(conn);
usr.sbin/unbound/util/netevent.c
1968
copy.key = conn->key;
usr.sbin/unbound/util/netevent.c
1969
log_assert(conn->key.dcidlen <= NGTCP2_MAX_CIDLEN);
usr.sbin/unbound/util/netevent.c
1970
memcpy(cid, conn->key.dcid, conn->key.dcidlen);
usr.sbin/unbound/util/netevent.c
1973
lock_basic_unlock(&conn->lock);
usr.sbin/unbound/util/netevent.c
1979
conn = (struct doq_conn*)node->key;
usr.sbin/unbound/util/netevent.c
1980
lock_basic_lock(&conn->lock);
usr.sbin/unbound/util/netevent.c
1981
doq_conn_write_list_remove(c->doq_socket->table, conn);
usr.sbin/unbound/util/netevent.c
1982
if(conn->timer.timer_in_list) {
usr.sbin/unbound/util/netevent.c
1988
&conn->timer);
usr.sbin/unbound/util/netevent.c
1990
if(conn->timer.timer_in_tree)
usr.sbin/unbound/util/netevent.c
1992
&conn->timer);
usr.sbin/unbound/util/netevent.c
1996
lock_basic_unlock(&conn->lock);
usr.sbin/unbound/util/netevent.c
1998
sizeof(*conn)+conn->key.dcidlen);
usr.sbin/unbound/util/netevent.c
1999
doq_conn_delete(conn, c->doq_socket->table);
usr.sbin/unbound/util/netevent.c
2010
struct doq_conn* conn;
usr.sbin/unbound/util/netevent.c
2012
c->doq_socket->cfg, sizeof(*conn)+hd->dcid.datalen
usr.sbin/unbound/util/netevent.c
2021
conn = doq_conn_create(c, paddr, hd->dcid.data, hd->dcid.datalen,
usr.sbin/unbound/util/netevent.c
2023
if(!conn) {
usr.sbin/unbound/util/netevent.c
2028
lock_basic_lock(&conn->lock);
usr.sbin/unbound/util/netevent.c
2029
if(!rbtree_insert(c->doq_socket->table->conn_tree, &conn->node)) {
usr.sbin/unbound/util/netevent.c
2033
lock_basic_unlock(&conn->lock);
usr.sbin/unbound/util/netevent.c
2034
doq_conn_delete(conn, c->doq_socket->table);
usr.sbin/unbound/util/netevent.c
2039
sizeof(*conn)+conn->key.dcidlen);
usr.sbin/unbound/util/netevent.c
2045
if(!doq_conn_setup(conn, hd->scid.data, hd->scid.datalen,
usr.sbin/unbound/util/netevent.c
2054
doq_delete_connection(c, conn);
usr.sbin/unbound/util/netevent.c
2057
return conn;
usr.sbin/unbound/util/netevent.c
2126
struct doq_conn** conn, struct ngtcp2_pkt_info* pi)
usr.sbin/unbound/util/netevent.c
2154
*conn = doq_setup_new_conn(c, paddr, &hd, pocid);
usr.sbin/unbound/util/netevent.c
2155
if(!*conn)
usr.sbin/unbound/util/netevent.c
2157
(*conn)->doq_socket = c->doq_socket;
usr.sbin/unbound/util/netevent.c
2158
if(!doq_conn_recv(c, paddr, *conn, pi, &err_retry, NULL)) {
usr.sbin/unbound/util/netevent.c
2161
doq_delete_connection(c, *conn);
usr.sbin/unbound/util/netevent.c
2162
*conn = NULL;
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
2220
conn->doq_socket = NULL;
usr.sbin/unbound/util/netevent.c
2222
if(doq_conn_check_timer(conn, &new_tv))
usr.sbin/unbound/util/netevent.c
2224
if( (conn->write_interest && !conn->on_write_list) ||
usr.sbin/unbound/util/netevent.c
2225
(!conn->write_interest && conn->on_write_list))
usr.sbin/unbound/util/netevent.c
2230
lock_basic_unlock(&conn->lock);
usr.sbin/unbound/util/netevent.c
2237
copy.key = conn->key;
usr.sbin/unbound/util/netevent.c
2238
log_assert(conn->key.dcidlen <= NGTCP2_MAX_CIDLEN);
usr.sbin/unbound/util/netevent.c
2239
memcpy(cid, conn->key.dcid, conn->key.dcidlen);
usr.sbin/unbound/util/netevent.c
2242
lock_basic_unlock(&conn->lock);
usr.sbin/unbound/util/netevent.c
2251
conn = (struct doq_conn*)node->key;
usr.sbin/unbound/util/netevent.c
2252
lock_basic_lock(&conn->lock);
usr.sbin/unbound/util/netevent.c
2253
if(conn->is_deleted) {
usr.sbin/unbound/util/netevent.c
2256
lock_basic_unlock(&conn->lock);
usr.sbin/unbound/util/netevent.c
2264
doq_conn_set_write_list(c->doq_socket->table, conn);
usr.sbin/unbound/util/netevent.c
2267
doq_timer_set(c->doq_socket->table, &conn->timer,
usr.sbin/unbound/util/netevent.c
2271
lock_basic_unlock(&conn->lock);
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
2284
conn->doq_socket = NULL;
usr.sbin/unbound/util/netevent.c
2286
if( (conn->write_interest && conn->on_write_list) ||
usr.sbin/unbound/util/netevent.c
2287
(!conn->write_interest && !conn->on_write_list)) {
usr.sbin/unbound/util/netevent.c
2290
lock_basic_unlock(&conn->lock);
usr.sbin/unbound/util/netevent.c
2296
copy.key = conn->key;
usr.sbin/unbound/util/netevent.c
2297
log_assert(conn->key.dcidlen <= NGTCP2_MAX_CIDLEN);
usr.sbin/unbound/util/netevent.c
2298
memcpy(cid, conn->key.dcid, conn->key.dcidlen);
usr.sbin/unbound/util/netevent.c
2301
lock_basic_unlock(&conn->lock);
usr.sbin/unbound/util/netevent.c
2310
conn = (struct doq_conn*)node->key;
usr.sbin/unbound/util/netevent.c
2311
lock_basic_lock(&conn->lock);
usr.sbin/unbound/util/netevent.c
2312
if(conn->is_deleted) {
usr.sbin/unbound/util/netevent.c
2315
lock_basic_unlock(&conn->lock);
usr.sbin/unbound/util/netevent.c
2322
doq_conn_set_write_list(c->doq_socket->table, conn);
usr.sbin/unbound/util/netevent.c
2324
lock_basic_unlock(&conn->lock);
usr.sbin/unbound/util/netevent.c
2332
struct doq_conn* conn;
usr.sbin/unbound/util/netevent.c
2334
conn = c->doq_socket->table->write_list_first;
usr.sbin/unbound/util/netevent.c
2335
while(conn) {
usr.sbin/unbound/util/netevent.c
2337
conn = conn->write_next;
usr.sbin/unbound/util/netevent.c
2347
struct doq_conn* conn;
usr.sbin/unbound/util/netevent.c
2349
conn = doq_table_pop_first(c->doq_socket->table);
usr.sbin/unbound/util/netevent.c
2350
while(conn && conn->is_deleted) {
usr.sbin/unbound/util/netevent.c
2351
lock_basic_unlock(&conn->lock);
usr.sbin/unbound/util/netevent.c
2352
conn = doq_table_pop_first(c->doq_socket->table);
usr.sbin/unbound/util/netevent.c
2355
if(conn)
usr.sbin/unbound/util/netevent.c
2356
conn->doq_socket = c->doq_socket;
usr.sbin/unbound/util/netevent.c
2357
return 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
2366
doq_delete_connection(c, conn);
usr.sbin/unbound/util/netevent.c
2369
doq_done_setup_timer_and_write(c, conn);
usr.sbin/unbound/util/netevent.c
2436
struct doq_conn* conn = NULL;
usr.sbin/unbound/util/netevent.c
2442
conn = t->conn;
usr.sbin/unbound/util/netevent.c
2450
lock_basic_lock(&conn->lock);
usr.sbin/unbound/util/netevent.c
2451
conn->doq_socket = doq_socket;
usr.sbin/unbound/util/netevent.c
2456
return conn;
usr.sbin/unbound/util/netevent.c
2479
struct doq_conn* conn;
usr.sbin/unbound/util/netevent.c
2484
while((conn = doq_timer_timeout_conn(doq_socket)) != NULL) {
usr.sbin/unbound/util/netevent.c
2485
if(conn->is_deleted ||
usr.sbin/unbound/util/netevent.c
2487
ngtcp2_conn_in_closing_period(conn->conn) ||
usr.sbin/unbound/util/netevent.c
2489
ngtcp2_conn_is_in_closing_period(conn->conn) ||
usr.sbin/unbound/util/netevent.c
2492
ngtcp2_conn_in_draining_period(conn->conn)
usr.sbin/unbound/util/netevent.c
2494
ngtcp2_conn_is_in_draining_period(conn->conn)
usr.sbin/unbound/util/netevent.c
2499
addr_to_str((void*)&conn->key.paddr.addr,
usr.sbin/unbound/util/netevent.c
2500
conn->key.paddr.addrlen, remotestr,
usr.sbin/unbound/util/netevent.c
2505
doq_delete_connection(doq_socket->cp, conn);
usr.sbin/unbound/util/netevent.c
2508
if(!doq_conn_handle_timeout(conn))
usr.sbin/unbound/util/netevent.c
2509
doq_delete_connection(doq_socket->cp, conn);
usr.sbin/unbound/util/netevent.c
2510
else doq_done_setup_timer_and_write(doq_socket->cp, conn);
usr.sbin/unbound/util/netevent.c
2525
struct doq_conn* conn;
usr.sbin/unbound/util/netevent.c
2555
while((conn = doq_pop_write_conn(c)) != NULL) {
usr.sbin/unbound/util/netevent.c
2556
if(conn->is_deleted ||
usr.sbin/unbound/util/netevent.c
2558
ngtcp2_conn_in_closing_period(conn->conn) ||
usr.sbin/unbound/util/netevent.c
2560
ngtcp2_conn_is_in_closing_period(conn->conn) ||
usr.sbin/unbound/util/netevent.c
2563
ngtcp2_conn_in_draining_period(conn->conn)
usr.sbin/unbound/util/netevent.c
2565
ngtcp2_conn_is_in_draining_period(conn->conn)
usr.sbin/unbound/util/netevent.c
2568
conn->doq_socket = NULL;
usr.sbin/unbound/util/netevent.c
2569
lock_basic_unlock(&conn->lock);
usr.sbin/unbound/util/netevent.c
2582
addr_to_str((void*)&conn->key.paddr.addr,
usr.sbin/unbound/util/netevent.c
2583
conn->key.paddr.addrlen, remotestr,
usr.sbin/unbound/util/netevent.c
2587
&conn->key.paddr.addr));
usr.sbin/unbound/util/netevent.c
2589
if(doq_conn_write_streams(c, conn, &err_drop))
usr.sbin/unbound/util/netevent.c
2591
doq_done_with_write_cb(c, conn, err_drop);
usr.sbin/unbound/util/netevent.c
2651
conn = NULL;
usr.sbin/unbound/util/netevent.c
2652
if(!doq_decode_pkt_header_negotiate(c, &paddr, &conn))
usr.sbin/unbound/util/netevent.c
2654
if(!conn) {
usr.sbin/unbound/util/netevent.c
2655
if(!doq_accept(c, &paddr, &conn, &pi))
usr.sbin/unbound/util/netevent.c
2657
if(!doq_conn_write_streams(c, conn, NULL)) {
usr.sbin/unbound/util/netevent.c
2658
doq_delete_connection(c, conn);
usr.sbin/unbound/util/netevent.c
2661
doq_done_setup_timer_and_write(c, conn);
usr.sbin/unbound/util/netevent.c
2666
ngtcp2_conn_in_closing_period(conn->conn)
usr.sbin/unbound/util/netevent.c
2668
ngtcp2_conn_is_in_closing_period(conn->conn)
usr.sbin/unbound/util/netevent.c
2671
if(!doq_conn_send_close(c, conn)) {
usr.sbin/unbound/util/netevent.c
2672
doq_delete_connection(c, conn);
usr.sbin/unbound/util/netevent.c
2674
doq_done_setup_timer_and_write(c, conn);
usr.sbin/unbound/util/netevent.c
2680
ngtcp2_conn_in_draining_period(conn->conn)
usr.sbin/unbound/util/netevent.c
2682
ngtcp2_conn_is_in_draining_period(conn->conn)
usr.sbin/unbound/util/netevent.c
2685
doq_done_setup_timer_and_write(c, conn);
usr.sbin/unbound/util/netevent.c
2688
if(!doq_conn_recv(c, &paddr, conn, &pi, NULL, &err_drop)) {
usr.sbin/unbound/util/netevent.c
2693
doq_delete_connection(c, conn);
usr.sbin/unbound/util/netevent.c
2695
doq_done_setup_timer_and_write(c, conn);
usr.sbin/unbound/util/netevent.c
2699
if(!doq_conn_write_streams(c, conn, &err_drop)) {
usr.sbin/unbound/util/netevent.c
2701
doq_delete_connection(c, conn);
usr.sbin/unbound/util/netevent.c
2703
doq_done_setup_timer_and_write(c, conn);
usr.sbin/unbound/util/netevent.c
2707
doq_done_setup_timer_and_write(c, conn);
usr.sbin/unbound/util/netevent.c
2805
struct doq_conn* conn;
usr.sbin/unbound/util/netevent.c
2809
conn = doq_conn_find(table, &key.paddr.addr,
usr.sbin/unbound/util/netevent.c
2813
if(conn) {
usr.sbin/unbound/util/netevent.c
2814
lock_basic_lock(&conn->lock);
usr.sbin/unbound/util/netevent.c
2816
return conn;
usr.sbin/unbound/util/netevent.c
2825
struct doq_conn** conn, struct doq_stream** stream)
usr.sbin/unbound/util/netevent.c
2829
*conn = c->doq_socket->current_conn;
usr.sbin/unbound/util/netevent.c
2831
*conn = doq_lookup_repinfo(c->doq_socket->table, repinfo);
usr.sbin/unbound/util/netevent.c
2832
if((*conn) && (*conn)->is_deleted) {
usr.sbin/unbound/util/netevent.c
2833
lock_basic_unlock(&(*conn)->lock);
usr.sbin/unbound/util/netevent.c
2834
*conn = NULL;
usr.sbin/unbound/util/netevent.c
2836
if(*conn) {
usr.sbin/unbound/util/netevent.c
2837
(*conn)->doq_socket = c->doq_socket;
usr.sbin/unbound/util/netevent.c
2840
if(!*conn) {
usr.sbin/unbound/util/netevent.c
2844
*stream = doq_stream_find(*conn, repinfo->doq_streamid);
usr.sbin/unbound/util/netevent.c
2849
lock_basic_unlock(&(*conn)->lock);
usr.sbin/unbound/util/netevent.c
2858
lock_basic_unlock(&(*conn)->lock);
usr.sbin/unbound/util/netevent.c
2869
struct doq_conn* conn;
usr.sbin/unbound/util/netevent.c
2872
if(!doq_lookup_conn_stream(repinfo, repinfo->c, &conn, &stream)) {
usr.sbin/unbound/util/netevent.c
2874
(conn?"stream":"connection"));
usr.sbin/unbound/util/netevent.c
2879
if(!doq_stream_send_reply(conn, stream, repinfo->c->buffer))
usr.sbin/unbound/util/netevent.c
2880
doq_stream_close(conn, stream, 1);
usr.sbin/unbound/util/netevent.c
2884
doq_done_with_conn_cb(repinfo->c, conn);
usr.sbin/unbound/util/netevent.c
2900
struct doq_conn* conn;
usr.sbin/unbound/util/netevent.c
2903
if(!doq_lookup_conn_stream(repinfo, repinfo->c, &conn, &stream)) {
usr.sbin/unbound/util/netevent.c
2905
(conn?"stream":"connection"));
usr.sbin/unbound/util/netevent.c
2909
doq_stream_close(conn, stream, 1);
usr.sbin/unbound/util/netevent.c
2913
doq_done_with_conn_cb(repinfo->c, conn);
usr.sbin/vmd/vm_agentx.c
264
static struct conn *conn;
usr.sbin/vmd/vm_agentx.c
279
if (conn != NULL) {
usr.sbin/vmd/vm_agentx.c
280
agentx_free(conn->agentx);
usr.sbin/vmd/vm_agentx.c
281
conn = NULL;
usr.sbin/vmd/vm_agentx.c
289
if (strcmp(curpath, vmd_agentx->ax_path) != 0 || conn == NULL) {
usr.sbin/vmd/vm_agentx.c
290
if (conn != NULL) {
usr.sbin/vmd/vm_agentx.c
291
agentx_free(conn->agentx);
usr.sbin/vmd/vm_agentx.c
292
conn = NULL;
usr.sbin/vmd/vm_agentx.c
298
if ((conn = malloc(sizeof(*conn))) == NULL)
usr.sbin/vmd/vm_agentx.c
301
evtimer_set(&conn->ev, vm_agentx_tryconnect, conn);
usr.sbin/vmd/vm_agentx.c
303
if (agentx(vm_agentx_nofd, conn) == NULL)
usr.sbin/vmd/vm_agentx.c
305
sess = agentx_session(conn->agentx, NULL, 0, "vmd", 0);
usr.sbin/vmd/vm_agentx.c
374
struct conn *conn = cookie;
usr.sbin/vmd/vm_agentx.c
376
conn->agentx = agentx;
usr.sbin/vmd/vm_agentx.c
377
event_del(&conn->ev);
usr.sbin/vmd/vm_agentx.c
379
free(conn);
usr.sbin/vmd/vm_agentx.c
381
vm_agentx_tryconnect(-1, 0, conn);
usr.sbin/vmd/vm_agentx.c
389
struct conn *conn = cookie;
usr.sbin/vmd/vm_agentx.c
402
agentx_connect(conn->agentx, fd);
usr.sbin/vmd/vm_agentx.c
404
event_set(&conn->ev, fd, EV_READ|EV_PERSIST, vm_agentx_read, conn);
usr.sbin/vmd/vm_agentx.c
405
event_add(&conn->ev, NULL);
usr.sbin/vmd/vm_agentx.c
409
evtimer_set(&conn->ev, vm_agentx_tryconnect, conn);
usr.sbin/vmd/vm_agentx.c
410
evtimer_add(&conn->ev, &timeout);
usr.sbin/vmd/vm_agentx.c
416
struct conn *conn = cookie;
usr.sbin/vmd/vm_agentx.c
418
agentx_read(conn->agentx);
