| /freebsd-12-stable/contrib/serf/ |
| D | outgoing.c | 34 serf_connection_t *conn = data; in clean_skt() local
37 if (conn->skt) { in clean_skt()
38 serf__log_skt(SOCK_VERBOSE, __FILE__, conn->skt, "cleanup - "); in clean_skt()
39 status = apr_socket_close(conn->skt); in clean_skt()
40 conn->skt = NULL; in clean_skt()
80 serf_connection_t *conn = data; in clean_conn() local
83 conn); in clean_conn()
84 serf_connection_close(conn); in clean_conn()
99 request_or_data_pending(serf_request_t **next_req, serf_connection_t *conn) in request_or_data_pending() argument
101 serf_request_t *request = conn->requests; in request_or_data_pending()
[all …]
|
| /freebsd-12-stable/sys/contrib/ngatm/netnatm/api/ |
| D | cc_conn.c | 70 cc_conn_set_state(struct ccconn *conn, enum conn_state ns) in cc_conn_set_state() argument
72 if (conn->state != ns) { in cc_conn_set_state()
73 if (conn->cc->log & CCLOG_CONN_STATE) in cc_conn_set_state()
74 cc_conn_log(conn, "%s -> %s", in cc_conn_set_state()
75 stab[conn->state], stab[ns]); in cc_conn_set_state()
76 conn->state = ns; in cc_conn_set_state()
93 if (party->conn->cc->log & CCLOG_PARTY_STATE) in cc_party_set_state()
104 cc_disconnect_from_user(struct ccconn *conn) in cc_disconnect_from_user() argument
107 if (conn->user == NULL) in cc_disconnect_from_user()
108 cc_conn_log(conn, "no %s", "user"); in cc_disconnect_from_user()
[all …]
|
| /freebsd-12-stable/contrib/wpa/src/tls/ |
| D | tlsv1_server_read.c | 23 static int tls_process_client_key_exchange(struct tlsv1_server *conn, u8 ct,
25 static int tls_process_change_cipher_spec(struct tlsv1_server *conn,
30 static int testing_cipher_suite_filter(struct tlsv1_server *conn, u16 suite) in testing_cipher_suite_filter() argument
33 if ((conn->test_flags & in testing_cipher_suite_filter()
49 static void tls_process_status_request_item(struct tlsv1_server *conn, in tls_process_status_request_item() argument
86 conn->status_request_multi = 1; in tls_process_status_request_item()
90 static void tls_process_status_request_v2(struct tlsv1_server *conn, in tls_process_status_request_v2() argument
95 conn->status_request_v2 = 1; in tls_process_status_request_v2()
115 tls_process_status_request_item(conn, pos, len); in tls_process_status_request_v2()
121 static int tls_process_client_hello(struct tlsv1_server *conn, u8 ct, in tls_process_client_hello() argument
[all …]
|
| D | tlsv1_client.c | 25 void tls_alert(struct tlsv1_client *conn, u8 level, u8 description) in tls_alert() argument
27 conn->alert_level = level; in tls_alert()
28 conn->alert_description = description; in tls_alert()
32 void tlsv1_client_free_dh(struct tlsv1_client *conn) in tlsv1_client_free_dh() argument
34 os_free(conn->dh_p); in tlsv1_client_free_dh()
35 os_free(conn->dh_g); in tlsv1_client_free_dh()
36 os_free(conn->dh_ys); in tlsv1_client_free_dh()
37 conn->dh_p = conn->dh_g = conn->dh_ys = NULL; in tlsv1_client_free_dh()
41 u16 tls_client_highest_ver(struct tlsv1_client *conn) in tls_client_highest_ver() argument
47 if ((conn->flags & TLS_CONN_DISABLE_TLSv1_2) && in tls_client_highest_ver()
[all …]
|
| D | tlsv1_server.c | 24 void tlsv1_server_log(struct tlsv1_server *conn, const char *fmt, ...) in tlsv1_server_log() argument
42 if (conn->log_cb) in tlsv1_server_log()
43 conn->log_cb(conn->log_cb_ctx, buf); in tlsv1_server_log()
49 void tlsv1_server_alert(struct tlsv1_server *conn, u8 level, u8 description) in tlsv1_server_alert() argument
51 conn->alert_level = level; in tlsv1_server_alert()
52 conn->alert_description = description; in tlsv1_server_alert()
56 int tlsv1_server_derive_keys(struct tlsv1_server *conn, in tlsv1_server_derive_keys() argument
68 os_memcpy(seed, conn->client_random, TLS_RANDOM_LEN); in tlsv1_server_derive_keys()
69 os_memcpy(seed + TLS_RANDOM_LEN, conn->server_random, in tlsv1_server_derive_keys()
71 if (tls_prf(conn->rl.tls_version, in tlsv1_server_derive_keys()
[all …]
|
| D | tlsv1_server_write.c | 24 static size_t tls_server_cert_chain_der_len(struct tlsv1_server *conn) in tls_server_cert_chain_der_len() argument
29 cert = conn->cred ? conn->cred->cert : NULL; in tls_server_cert_chain_der_len()
34 cert = x509_certificate_get_subject(conn->cred->trusted_certs, in tls_server_cert_chain_der_len()
42 static int tls_write_server_hello(struct tlsv1_server *conn, in tls_write_server_hello() argument
51 tlsv1_server_log(conn, "Send ServerHello"); in tls_write_server_hello()
59 WPA_PUT_BE32(conn->server_random, now.sec); in tls_write_server_hello()
60 if (random_get_bytes(conn->server_random + 4, TLS_RANDOM_LEN - 4)) { in tls_write_server_hello()
66 conn->server_random, TLS_RANDOM_LEN); in tls_write_server_hello()
68 conn->session_id_len = TLS_SESSION_ID_MAX_LEN; in tls_write_server_hello()
69 if (random_get_bytes(conn->session_id, conn->session_id_len)) { in tls_write_server_hello()
[all …]
|
| D | tlsv1_client_read.c | 22 static int tls_process_server_key_exchange(struct tlsv1_client *conn, u8 ct,
24 static int tls_process_certificate_request(struct tlsv1_client *conn, u8 ct,
26 static int tls_process_server_hello_done(struct tlsv1_client *conn, u8 ct,
30 static int tls_version_disabled(struct tlsv1_client *conn, u16 ver) in tls_version_disabled() argument
32 return (((conn->flags & TLS_CONN_DISABLE_TLSv1_0) && in tls_version_disabled()
34 ((conn->flags & TLS_CONN_DISABLE_TLSv1_1) && in tls_version_disabled()
36 ((conn->flags & TLS_CONN_DISABLE_TLSv1_2) && in tls_version_disabled()
41 static int tls_process_server_hello_extensions(struct tlsv1_client *conn, in tls_process_server_hello_extensions() argument
78 static int tls_process_server_hello(struct tlsv1_client *conn, u8 ct, in tls_process_server_hello() argument
89 tls_alert(conn, TLS_ALERT_LEVEL_FATAL, in tls_process_server_hello()
[all …]
|
| D | tlsv1_client_write.c | 24 static size_t tls_client_cert_chain_der_len(struct tlsv1_client *conn) in tls_client_cert_chain_der_len() argument
29 if (conn->cred == NULL) in tls_client_cert_chain_der_len()
32 cert = conn->cred->cert; in tls_client_cert_chain_der_len()
37 cert = x509_certificate_get_subject(conn->cred->trusted_certs, in tls_client_cert_chain_der_len()
45 u8 * tls_send_client_hello(struct tlsv1_client *conn, size_t *out_len) in tls_send_client_hello() argument
51 u16 tls_version = tls_client_highest_ver(conn); in tls_send_client_hello()
66 WPA_PUT_BE32(conn->client_random, now.sec); in tls_send_client_hello()
67 if (random_get_bytes(conn->client_random + 4, TLS_RANDOM_LEN - 4)) { in tls_send_client_hello()
73 conn->client_random, TLS_RANDOM_LEN); in tls_send_client_hello()
75 len = 150 + conn->num_cipher_suites * 2 + conn->client_hello_ext_len; in tls_send_client_hello()
[all …]
|
| /freebsd-12-stable/contrib/subversion/subversion/libsvn_ra_svn/ |
| D | marshal.c | 82 get_timeout(svn_ra_svn_conn_t *conn) in get_timeout() argument
84 return conn->block_handler ? 0 : -1; in get_timeout()
192 svn_ra_svn_conn_t *conn; in svn_ra_svn_create_conn5() local
193 void *mem = apr_palloc(result_pool, sizeof(*conn) + SVN_RA_SVN__PAGE_SIZE); in svn_ra_svn_create_conn5()
194 conn = (void*)APR_ALIGN((apr_uintptr_t)mem, SVN_RA_SVN__PAGE_SIZE); in svn_ra_svn_create_conn5()
199 conn->sock = sock; in svn_ra_svn_create_conn5()
200 conn->encrypted = FALSE; in svn_ra_svn_create_conn5()
202 conn->session = NULL; in svn_ra_svn_create_conn5()
203 conn->read_ptr = conn->read_buf; in svn_ra_svn_create_conn5()
204 conn->read_end = conn->read_buf; in svn_ra_svn_create_conn5()
[all …]
|
| /freebsd-12-stable/sbin/hastd/ |
| D | proto.c | 78 struct proto_conn *conn; in proto_alloc() local
85 conn = malloc(sizeof(*conn)); in proto_alloc()
86 if (conn != NULL) { in proto_alloc()
87 conn->pc_proto = proto; in proto_alloc()
88 conn->pc_side = side; in proto_alloc()
89 conn->pc_magic = PROTO_CONN_MAGIC; in proto_alloc()
91 return (conn); in proto_alloc()
95 proto_free(struct proto_conn *conn) in proto_free() argument
98 PJDLOG_ASSERT(conn != NULL); in proto_free()
99 PJDLOG_ASSERT(conn->pc_magic == PROTO_CONN_MAGIC); in proto_free()
[all …]
|
| /freebsd-12-stable/contrib/wpa/src/common/ |
| D | dpp_tcp.c | 62 struct dl_list conn; /* struct dpp_connection */ member
71 struct dl_list conn; /* struct dpp_connection */ member
81 static void dpp_controller_auth_success(struct dpp_connection *conn,
88 static void dpp_connection_free(struct dpp_connection *conn) in dpp_connection_free() argument
90 if (conn->sock >= 0) { in dpp_connection_free()
92 conn->sock); in dpp_connection_free()
93 eloop_unregister_sock(conn->sock, EVENT_TYPE_READ); in dpp_connection_free()
94 eloop_unregister_sock(conn->sock, EVENT_TYPE_WRITE); in dpp_connection_free()
95 close(conn->sock); in dpp_connection_free()
98 conn, NULL); in dpp_connection_free()
[all …]
|
| /freebsd-12-stable/sys/dev/mlx5/mlx5_fpga/ |
| D | mlx5fpga_conn.c | 48 static int mlx5_fpga_conn_map_buf(struct mlx5_fpga_conn *conn, in mlx5_fpga_conn_map_buf() argument
57 dma_device = &conn->fdev->mdev->pdev->dev; in mlx5_fpga_conn_map_buf()
62 mlx5_fpga_warn(conn->fdev, "DMA error on sg 0: %d\n", err); in mlx5_fpga_conn_map_buf()
74 mlx5_fpga_warn(conn->fdev, "DMA error on sg 1: %d\n", err); in mlx5_fpga_conn_map_buf()
84 static void mlx5_fpga_conn_unmap_buf(struct mlx5_fpga_conn *conn, in mlx5_fpga_conn_unmap_buf() argument
89 dma_device = &conn->fdev->mdev->pdev->dev; in mlx5_fpga_conn_unmap_buf()
99 static int mlx5_fpga_conn_post_recv(struct mlx5_fpga_conn *conn, in mlx5_fpga_conn_post_recv() argument
106 err = mlx5_fpga_conn_map_buf(conn, buf); in mlx5_fpga_conn_post_recv()
110 if (unlikely(conn->qp.rq.pc - conn->qp.rq.cc >= conn->qp.rq.size)) { in mlx5_fpga_conn_post_recv()
111 mlx5_fpga_conn_unmap_buf(conn, buf); in mlx5_fpga_conn_post_recv()
[all …]
|
| /freebsd-12-stable/contrib/openbsm/bin/auditdistd/ |
| D | proto.c | 73 struct proto_conn *conn; in proto_alloc() local
80 conn = malloc(sizeof(*conn)); in proto_alloc()
81 if (conn != NULL) { in proto_alloc()
82 conn->pc_proto = proto; in proto_alloc()
83 conn->pc_side = side; in proto_alloc()
84 conn->pc_magic = PROTO_CONN_MAGIC; in proto_alloc()
86 return (conn); in proto_alloc()
90 proto_free(struct proto_conn *conn) in proto_free() argument
93 PJDLOG_ASSERT(conn != NULL); in proto_free()
94 PJDLOG_ASSERT(conn->pc_magic == PROTO_CONN_MAGIC); in proto_free()
[all …]
|
| /freebsd-12-stable/contrib/wpa/src/crypto/ |
| D | tls_internal.c | 95 struct tls_connection *conn; in tls_connection_init() local
98 conn = os_zalloc(sizeof(*conn)); in tls_connection_init()
99 if (conn == NULL) in tls_connection_init()
101 conn->global = global; in tls_connection_init()
105 conn->client = tlsv1_client_init(); in tls_connection_init()
106 if (conn->client == NULL) { in tls_connection_init()
107 os_free(conn); in tls_connection_init()
110 tlsv1_client_set_cb(conn->client, global->event_cb, in tls_connection_init()
116 conn->server = tlsv1_server_init(global->server_cred); in tls_connection_init()
117 if (conn->server == NULL) { in tls_connection_init()
[all …]
|
| D | tls_gnutls.c | 157 struct tls_connection *conn = (struct tls_connection *) ptr; in tls_pull_func() local
159 if (conn->pull_buf == NULL) { in tls_pull_func()
164 end = wpabuf_head_u8(conn->pull_buf) + wpabuf_len(conn->pull_buf); in tls_pull_func()
165 if ((size_t) (end - conn->pull_buf_offset) < len) in tls_pull_func()
166 len = end - conn->pull_buf_offset; in tls_pull_func()
167 os_memcpy(buf, conn->pull_buf_offset, len); in tls_pull_func()
168 conn->pull_buf_offset += len; in tls_pull_func()
169 if (conn->pull_buf_offset == end) { in tls_pull_func()
171 wpabuf_free(conn->pull_buf); in tls_pull_func()
172 conn->pull_buf = NULL; in tls_pull_func()
[all …]
|
| D | tls_wolfssl.c | 298 struct tls_connection *conn; in tls_connection_init() local
302 conn = os_zalloc(sizeof(*conn)); in tls_connection_init()
303 if (!conn) in tls_connection_init()
305 conn->ssl = wolfSSL_new(ssl_ctx); in tls_connection_init()
306 if (!conn->ssl) { in tls_connection_init()
307 os_free(conn); in tls_connection_init()
311 wolfSSL_SetIOReadCtx(conn->ssl, &conn->input); in tls_connection_init()
312 wolfSSL_SetIOWriteCtx(conn->ssl, &conn->output); in tls_connection_init()
313 wolfSSL_set_ex_data(conn->ssl, 0, conn); in tls_connection_init()
314 conn->context = wolfSSL_CTX_get_ex_data(ssl_ctx, 0); in tls_connection_init()
[all …]
|
| D | tls_openssl.c | 750 struct tls_connection *conn = SSL_get_app_data((SSL *) ssl); in ssl_info_cb() local
759 conn->read_alerts++; in ssl_info_cb()
761 conn->write_alerts++; in ssl_info_cb()
763 if (conn->context->event_cb != NULL) { in ssl_info_cb()
765 struct tls_context *context = conn->context; in ssl_info_cb()
1181 static int tls_engine_init(struct tls_connection *conn, const char *engine_id, in tls_engine_init() argument
1191 conn->engine = NULL; in tls_engine_init()
1192 conn->private_key = EVP_PKEY_from_keystore(key_id); in tls_engine_init()
1193 if (!conn->private_key) { in tls_engine_init()
1213 conn->engine = ENGINE_by_id(engine_id); in tls_engine_init()
[all …]
|
| D | tls_none.c | 37 void tls_connection_deinit(void *tls_ctx, struct tls_connection *conn) in tls_connection_deinit() argument
42 int tls_connection_established(void *tls_ctx, struct tls_connection *conn) in tls_connection_established() argument
49 struct tls_connection *conn) in tls_connection_peer_serial_num() argument
55 int tls_connection_shutdown(void *tls_ctx, struct tls_connection *conn) in tls_connection_shutdown() argument
61 int tls_connection_set_params(void *tls_ctx, struct tls_connection *conn, in tls_connection_set_params() argument
81 int tls_connection_set_verify(void *tls_ctx, struct tls_connection *conn, in tls_connection_set_verify() argument
89 int tls_connection_get_random(void *tls_ctx, struct tls_connection *conn, in tls_connection_get_random() argument
96 int tls_connection_export_key(void *tls_ctx, struct tls_connection *conn, in tls_connection_export_key() argument
104 int tls_connection_get_eap_fast_key(void *tls_ctx, struct tls_connection *conn, in tls_connection_get_eap_fast_key() argument
112 struct tls_connection *conn, in tls_connection_handshake() argument
[all …]
|
| /freebsd-12-stable/usr.sbin/ctld/ |
| D | login.c | 91 login_receive(struct connection *conn, bool initial) in login_receive() argument
96 request = pdu_new(conn); in login_receive()
132 ISCSI_SNLT(ntohl(bhslr->bhslr_cmdsn), conn->conn_cmdsn)) { in login_receive()
135 "was %u, is %u", conn->conn_cmdsn, in login_receive()
139 ntohl(bhslr->bhslr_expstatsn) != conn->conn_statsn) { in login_receive()
143 conn->conn_statsn); in login_receive()
145 conn->conn_cmdsn = ntohl(bhslr->bhslr_cmdsn); in login_receive()
154 struct connection *conn; in login_new_response() local
159 conn = request->pdu_connection; in login_new_response()
168 bhslr2->bhslr_statsn = htonl(conn->conn_statsn++); in login_new_response()
[all …]
|
| /freebsd-12-stable/usr.sbin/iscsid/ |
| D | login.c | 164 kernel_modify(const struct connection *conn, const char *target_address) in kernel_modify() argument
170 ism.ism_session_id = conn->conn_session_id; in kernel_modify()
171 memcpy(&ism.ism_conf, &conn->conn_conf, sizeof(ism.ism_conf)); in kernel_modify()
174 error = ioctl(conn->conn_iscsi_fd, ISCSISMODIFY, &ism); in kernel_modify()
192 login_handle_redirection(struct connection *conn, struct pdu *response) in login_handle_redirection() argument
210 sizeof(conn->conn_conf.isc_target_addr) - 1) in login_handle_redirection()
214 kernel_modify(conn, target_address); in login_handle_redirection()
219 login_receive(struct connection *conn) in login_receive() argument
226 response = pdu_new(conn); in login_receive()
245 login_handle_redirection(conn, response); in login_receive()
[all …]
|
| D | iscsid.c | 84 resolve_addr(const struct connection *conn, const char *address, in resolve_addr() argument
95 fail(conn, "empty address"); in resolve_addr()
105 fail(conn, "malformed address"); in resolve_addr()
113 fail(conn, "malformed address"); in resolve_addr()
149 fail(conn, gai_strerror(error)); in resolve_addr()
158 struct connection *conn; in connection_new() local
167 conn = calloc(1, sizeof(*conn)); in connection_new()
168 if (conn == NULL) in connection_new()
174 conn->conn_protocol_level = 0; in connection_new()
175 conn->conn_header_digest = CONN_DIGEST_NONE; in connection_new()
[all …]
|
| /freebsd-12-stable/contrib/subversion/subversion/include/private/ |
| D | svn_ra_svn_private.h | 69 typedef svn_error_t *(*svn_ra_svn__command_handler)(svn_ra_svn_conn_t *conn,
127 svn_ra_svn__set_capabilities(svn_ra_svn_conn_t *conn,
133 svn_ra_svn__svndiff_version(svn_ra_svn_conn_t *conn);
140 svn_ra_svn__set_shim_callbacks(svn_ra_svn_conn_t *conn,
147 svn_ra_svn__get_pool(svn_ra_svn_conn_t *conn);
159 svn_ra_svn__write_number(svn_ra_svn_conn_t *conn,
168 svn_ra_svn__write_string(svn_ra_svn_conn_t *conn,
177 svn_ra_svn__write_cstring(svn_ra_svn_conn_t *conn,
186 svn_ra_svn__write_word(svn_ra_svn_conn_t *conn,
195 svn_ra_svn__write_boolean(svn_ra_svn_conn_t *conn,
[all …]
|
| /freebsd-12-stable/sbin/ggate/ggated/ |
| D | ggated.c | 308 struct ggd_connection *conn) in exports_check() argument
323 conn->c_flags |= GGATE_FLAG_RDONLY; in exports_check()
332 conn->c_flags |= GGATE_FLAG_WRONLY; in exports_check()
347 if ((conn->c_flags & GGATE_FLAG_RDONLY) != 0) in exports_check()
349 else if ((conn->c_flags & GGATE_FLAG_WRONLY) != 0) in exports_check()
353 if (conn->c_diskfd != -1) { in exports_check()
354 if (strcmp(conn->c_path, ex->e_path) != 0) { in exports_check()
357 conn->c_path, ex->e_path); in exports_check()
363 conn->c_diskfd = open(ex->e_path, flags); in exports_check()
364 if (conn->c_diskfd == -1) { in exports_check()
[all …]
|
| /freebsd-12-stable/tools/tools/netrate/tcpp/ |
| D | tcpp_server.c | 79 struct connection *conn; in tcpp_server_newconn() local
92 conn = malloc(sizeof(*conn)); in tcpp_server_newconn()
93 if (conn == NULL) in tcpp_server_newconn()
95 bzero(conn, sizeof(*conn)); in tcpp_server_newconn()
96 conn->conn_magic = CONNECTION_MAGIC; in tcpp_server_newconn()
97 conn->conn_fd = fd; in tcpp_server_newconn()
103 EV_SET(&kev, fd, EVFILT_READ, EV_ADD, 0, 0, conn); in tcpp_server_newconn()
107 return (conn); in tcpp_server_newconn()
111 tcpp_server_closeconn(struct connection *conn) in tcpp_server_closeconn() argument
121 close(conn->conn_fd); in tcpp_server_closeconn()
[all …]
|
| /freebsd-12-stable/contrib/apr-util/memcache/ |
| D | apr_memcache.c | 105 apr_memcache_conn_t* conn; member
225 static apr_status_t ms_find_conn(apr_memcache_server_t *ms, apr_memcache_conn_t **conn) in ms_find_conn() argument
232 rv = apr_reslist_acquire(ms->conns, (void **)conn); in ms_find_conn()
234 *conn = ms->conn; in ms_find_conn()
242 balloc = apr_bucket_alloc_create((*conn)->tp); in ms_find_conn()
243 (*conn)->bb = apr_brigade_create((*conn)->tp, balloc); in ms_find_conn()
244 (*conn)->tb = apr_brigade_create((*conn)->tp, balloc); in ms_find_conn()
246 e = apr_bucket_socket_create((*conn)->sock, balloc); in ms_find_conn()
247 APR_BRIGADE_INSERT_TAIL((*conn)->bb, e); in ms_find_conn()
252 static apr_status_t ms_bad_conn(apr_memcache_server_t *ms, apr_memcache_conn_t *conn) in ms_bad_conn() argument
[all …]
|