Home
last modified time | relevance | path

Searched refs:conn (Results 1 – 25 of 114) sorted by relevance

12345

/net/smc/
A Dsmc_cdc.c31 struct smc_connection *conn = cdcpend->conn; in smc_cdc_tx_handler() local
37 smc = container_of(conn, struct smc_sock, conn); in smc_cdc_tx_handler()
106 pend->conn = conn; in smc_cdc_add_pending_send()
123 conn->local_tx_ctrl.seqno = conn->tx_cdc_seq; in smc_cdc_msg_send()
275 smc_curs_copy(&conn->tx_curs_fin, &conn->tx_curs_sent, conn); in smcd_cdc_msg_send()
291 struct smc_connection *conn = &smc->conn; in smc_cdc_handle_urg_data_arrival() local
295 smc_curs_copy(&conn->urg_curs, &conn->local_rx_ctrl.prod, conn); in smc_cdc_handle_urg_data_arrival()
311 struct smc_connection *conn = &smc->conn; in smc_cdc_msg_validate() local
334 struct smc_connection *conn = &smc->conn; in smc_cdc_msg_recv_action() local
449 if (!conn || conn->killed) in smcd_cdc_rx_tsklet()
[all …]
A Dsmc_tx.c80 struct smc_connection *conn = &smc->conn; in smc_tx_wait() local
147 struct smc_connection *conn = &smc->conn; in smc_should_autocork() local
161 struct smc_connection *conn = &smc->conn; in smc_tx_should_cork() local
185 struct smc_connection *conn = &smc->conn; in smc_tx_sendmsg() local
240 smc_curs_copy(&prep, &conn->tx_curs_prep, conn); in smc_tx_sendmsg()
270 smc_curs_copy(&conn->tx_curs_prep, &prep, conn); in smc_tx_sendmsg()
308 rc = smc_ism_write(conn->lgr->smcd, conn->peer_token, in smcd_tx_ism_write()
473 smc_curs_copy(&sent, &conn->tx_curs_sent, conn); in smc_tx_rdma_writes()
474 smc_curs_copy(&prep, &conn->tx_curs_prep, conn); in smc_tx_rdma_writes()
563 container_of(conn, struct smc_sock, conn); in smcr_tx_sndbuf_nonempty()
[all …]
A Dsmc_rx.c62 struct smc_connection *conn = &smc->conn; in smc_rx_update_consumer() local
91 smc_curs_copy(&conn->local_tx_ctrl.cons, &cons, conn); in smc_rx_update_consumer()
102 struct smc_connection *conn = &smc->conn; in smc_rx_update_cons() local
105 smc_curs_copy(&cons, &conn->local_tx_ctrl.cons, conn); in smc_rx_update_cons()
126 conn = &smc->conn; in smc_rx_pipe_buf_release()
260 struct smc_connection *conn = &smc->conn; in smc_rx_wait() local
285 struct smc_connection *conn = &smc->conn; in smc_rx_recv_urg() local
304 smc_curs_copy(&cons, &conn->local_tx_ctrl.cons, conn); in smc_rx_recv_urg()
328 struct smc_connection *conn = &smc->conn; in smc_rx_recvmsg_data_available() local
350 struct smc_connection *conn = &smc->conn; in smc_rx_recvmsg() local
[all …]
A Dsmc_close.c61 smc_tx_pending(&smc->conn); in smc_close_stream_wait()
72 smc->conn.killed, in smc_close_stream_wait()
101 if (conn->killed) in smc_close_final()
157 smc_conn_free(&smc->conn); in smc_close_active_abort()
168 smc_conn_free(&smc->conn); in smc_close_active_abort()
197 struct smc_connection *conn = &smc->conn; in smc_close_active() local
361 struct smc_sock *smc = container_of(conn, struct smc_sock, conn); in smc_close_passive_work()
436 smc_conn_free(conn); in smc_close_passive_work()
449 struct smc_connection *conn = &smc->conn; in smc_close_shutdown_write() local
470 rc = smc_close_wr(conn); in smc_close_shutdown_write()
[all …]
A Dsmc_cdc.h84 struct smc_connection *conn) in smc_cdc_rxed_any_close_or_senddone() argument
103 struct smc_connection *conn) in smc_curs_copy() argument
133 struct smc_connection *conn) in smcd_curs_copy() argument
198 struct smc_connection *conn) in smc_host_cursor_to_cdc() argument
200 smc_curs_copy(save, local, conn); in smc_host_cursor_to_cdc()
224 struct smc_connection *conn) in smc_cdc_cursor_to_host() argument
229 smc_curs_copy(&old, local, conn); in smc_cdc_cursor_to_host()
238 smc_curs_copy(local, &temp, conn); in smc_cdc_cursor_to_host()
243 struct smc_connection *conn) in smcr_cdc_msg_to_host() argument
257 struct smc_connection *conn) in smcd_cdc_msg_to_host() argument
[all …]
A Dsmc_diag.c93 else if (smc_conn_lgr_valid(&smc->conn) && smc->conn.lgr->is_smcd) in __smc_diag_dump()
107 smc->conn.alert_token_local) { in __smc_diag_dump()
108 struct smc_connection *conn = &smc->conn; in __smc_diag_dump() local
110 .token = conn->alert_token_local, in __smc_diag_dump()
112 conn->sndbuf_desc->len : 0, in __smc_diag_dump()
113 .rmbe_size = conn->rmb_desc ? conn->rmb_desc->len : 0, in __smc_diag_dump()
146 if (smc_conn_lgr_valid(&smc->conn) && !smc->conn.lgr->is_smcd && in __smc_diag_dump()
152 .role = smc->conn.lgr->role, in __smc_diag_dump()
165 if (smc_conn_lgr_valid(&smc->conn) && smc->conn.lgr->is_smcd && in __smc_diag_dump()
167 !list_empty(&smc->conn.lgr->list) && smc->conn.rmb_desc) { in __smc_diag_dump()
[all …]
A Dsmc_core.c119 rb_insert_color(&conn->alert_node, &conn->lgr->conns_all); in smc_lgr_add_alert_token()
1022 struct smc_connection *conn = &smc->conn; in smc_switch_cursor() local
1027 smc_curs_copy(&conn->tx_curs_sent, &conn->tx_curs_fin, conn); in smc_switch_cursor()
1028 smc_curs_copy(&fin, &conn->local_tx_ctrl_fin, conn); in smc_switch_cursor()
1030 smc_curs_copy(&conn->local_tx_ctrl.prod, &fin, conn); in smc_switch_cursor()
1115 smc = container_of(conn, struct smc_sock, conn); in smc_switch_conns()
1505 if (conn->lgr->is_smcd && conn->lgr->peer_shutdown) in smc_conn_kill()
1563 smc = container_of(conn, struct smc_sock, conn); in __smc_lgr_terminate()
1967 struct smc_connection *conn = &smc->conn; in smc_conn_create() local
2418 struct smc_connection *conn = &smc->conn; in __smc_buf_create() local
[all …]
/net/bluetooth/
A Dhci_conn.c145 hci_conn_params_del(conn->hdev, &conn->dst, conn->dst_type); in hci_conn_cleanup()
158 conn->cleanup(conn); in hci_conn_cleanup()
231 conn, conn->attempt); in find_next_esco_param()
286 struct hci_conn *conn = conn_handle->conn; in hci_enhanced_setup_sync() local
471 conn_handle->conn = conn; in hci_setup_sync()
553 hci_add_sco(link->conn, conn->handle); in hci_sco_setup()
1681 link->conn = hci_conn_hold(conn); in hci_conn_link()
2180 conn->le_tx_phy ? conn->le_tx_phy : in hci_bind_bis()
2708 chan->conn = hci_conn_get(conn); in hci_chan_create()
2719 struct hci_conn *conn = chan->conn; in hci_chan_del() local
[all …]
A Dhci_event.c175 if (conn) in hci_cc_role_discovery()
2258 if (conn && conn->state == BT_CONNECT) { in hci_cs_create_conn()
2369 if (conn->state != BT_CONFIG || !conn->out) in hci_outgoing_auth_needed()
2440 if (conn && (conn->state == BT_CONFIG || conn->state == BT_CONNECTED)) in hci_check_pending_name()
2747 mgmt_device_disconnected(hdev, &conn->dst, conn->type, conn->dst_type, in hci_cs_disconnect()
3380 mgmt_device_disconnected(hdev, &conn->dst, conn->type, conn->dst_type, in hci_disconn_complete_evt()
4453 conn->type, conn); in hci_num_comp_pkts_evt()
5400 conn->dst_type, conn->passkey_notify, in hci_user_passkey_notify_evt()
5454 if (!conn || !hci_conn_ssp_enabled(conn)) in hci_simple_pair_complete_evt()
5966 params->conn = hci_conn_get(conn); in check_pending_le_conn()
[all …]
A Dsco.c87 sco_pi(conn->sk)->conn = NULL; in sco_conn_free()
102 if (!conn) in sco_conn_put()
120 if (!conn) in sco_conn_hold_unless_zero()
133 if (!conn || !bt_sock_linked(&sco_sk_list, conn->sk)) in sco_sock_hold()
147 conn = sco_conn_hold_unless_zero(conn); in sco_sock_timeout()
148 if (!conn) in sco_sock_timeout()
197 conn = sco_conn_hold_unless_zero(conn); in sco_conn_add()
235 conn = sco_pi(sk)->conn; in sco_chan_del()
259 conn = sco_conn_hold_unless_zero(conn); in sco_conn_del()
288 sco_pi(sk)->conn = conn; in __sco_chan_add()
[all …]
A Dl2cap_core.c409 struct l2cap_conn *conn = chan->conn; in l2cap_chan_timeout() local
593 chan->conn = conn; in __l2cap_chan_add()
648 struct l2cap_conn *conn = chan->conn; in l2cap_chan_del() local
759 struct l2cap_conn *conn = chan->conn; in l2cap_chan_le_connect_reject() local
789 struct l2cap_conn *conn = chan->conn; in l2cap_chan_connect_reject() local
810 struct l2cap_conn *conn = chan->conn; in l2cap_chan_close() local
914 struct l2cap_conn *conn = chan->conn; in l2cap_chan_check_security() local
1227 struct l2cap_conn *conn = chan->conn; in l2cap_send_conn_req() local
1268 struct l2cap_conn *conn = chan->conn; in l2cap_le_connect() local
1336 struct l2cap_conn *conn = chan->conn; in l2cap_ecred_connect() local
[all …]
A Dhci_sysfs.c16 kfree(conn); in bt_link_release()
26 struct hci_dev *hdev = conn->hdev; in hci_conn_init_sysfs()
28 bt_dev_dbg(hdev, "conn %p", conn); in hci_conn_init_sysfs()
30 conn->dev.type = &bt_link; in hci_conn_init_sysfs()
31 conn->dev.class = &bt_class; in hci_conn_init_sysfs()
32 conn->dev.parent = &hdev->dev; in hci_conn_init_sysfs()
34 device_initialize(&conn->dev); in hci_conn_init_sysfs()
46 dev_set_name(&conn->dev, "%s:%d", hdev->name, conn->handle); in hci_conn_add_sysfs()
48 if (device_add(&conn->dev) < 0) in hci_conn_add_sysfs()
62 put_device(&conn->dev); in hci_conn_del_sysfs()
[all …]
A Diso.c104 iso_pi(conn->sk)->conn = NULL; in iso_conn_free()
119 if (!conn) in iso_conn_put()
129 if (!conn) in iso_conn_hold_unless_zero()
156 conn = iso_conn_hold_unless_zero(conn); in iso_sock_timeout()
201 conn = iso_conn_hold_unless_zero(conn); in iso_conn_add()
212 conn = kzalloc(sizeof(*conn), GFP_KERNEL); in iso_conn_add()
235 conn = iso_pi(sk)->conn; in iso_chan_del()
266 conn = iso_conn_hold_unless_zero(conn); in iso_conn_del()
295 if (iso_pi(sk)->conn == conn && conn->sk == sk) in __iso_chan_add()
303 iso_pi(sk)->conn = conn; in __iso_chan_add()
[all …]
A Dsmp.c950 struct l2cap_conn *conn = smp->conn; in smp_confirm() local
977 struct l2cap_conn *conn = smp->conn; in smp_random() local
1243 struct l2cap_conn *conn = smp->conn; in smp_distribute_keys() local
1378 struct l2cap_conn *conn = smp->conn; in smp_timeout() local
1407 smp->conn = conn; in smp_chan_create()
1484 struct l2cap_conn *conn = smp->conn; in sc_passkey_send_confirm() local
1505 struct l2cap_conn *conn = smp->conn; in sc_passkey_round() local
1592 struct l2cap_conn *conn = smp->conn; in sc_user_reply() local
1701 struct l2cap_conn *conn = smp->conn; in build_bredr_pairing_cmd() local
2030 struct l2cap_conn *conn = smp->conn; in sc_check_confirm() local
[all …]
/net/rxrpc/
A Dconn_object.c63 if (conn) { in rxrpc_alloc_connection()
82 _leave(" = %p{%d}", conn, conn ? conn->debug_id : 0); in rxrpc_alloc_connection()
83 return conn; in rxrpc_alloc_connection()
111 if (!conn || refcount_read(&conn->ref) == 0) { in rxrpc_find_client_connection_rcu()
193 struct rxrpc_connection *conn = call->conn; in rxrpc_disconnect_call() local
236 if (conn) { in rxrpc_see_connection()
265 if (conn) { in rxrpc_get_connection_maybe()
337 conn->security->clear(conn); in rxrpc_clean_up_connection()
363 if (!conn) in rxrpc_put_connection()
417 conn->debug_id, atomic_read(&conn->active), in rxrpc_service_connection_reaper()
[all …]
A Dconn_event.c32 conn->error = err; in rxrpc_set_conn_aborted()
33 conn->completion = compl; in rxrpc_set_conn_aborted()
161 if_mtu = conn->peer->if_mtu - conn->peer->hdrsize; in rxrpc_conn_retransmit_call()
216 _enter("{%d},%x", conn->debug_id, conn->abort_code); in rxrpc_abort_calls()
225 conn->error); in rxrpc_abort_calls()
259 ret = conn->security->respond_to_challenge(conn, skb); in rxrpc_process_event()
265 ret = conn->security->verify_response(conn, skb); in rxrpc_process_event()
270 conn, conn->key->payload.data[0]); in rxrpc_process_event()
304 if (conn->security->issue_challenge(conn) < 0) in rxrpc_secure_connection()
419 sp->chall.conn = in rxrpc_post_challenge()
[all …]
A Dconn_client.c62 conn, refcount_read(&conn->ref)); in rxrpc_destroy_client_conn_ids()
162 if (!conn) in rxrpc_alloc_client_connection()
168 kfree(conn); in rxrpc_alloc_client_connection()
186 conn->service_id = conn->orig_service_id; in rxrpc_alloc_client_connection()
200 return conn; in rxrpc_alloc_client_connection()
211 if (!conn) in rxrpc_may_reuse_conn()
492 if (!conn) in rxrpc_activate_channels()
536 struct rxrpc_connection *conn = call->conn; in rxrpc_expose_client_call() local
587 conn = call->conn; in rxrpc_disconnect_client_call()
588 if (!conn) { in rxrpc_disconnect_client_call()
[all …]
A Dconn_service.c51 conn = NULL; in rxrpc_find_service_conn_rcu()
56 _leave(" = %d", conn ? conn->debug_id : -1); in rxrpc_find_service_conn_rcu()
57 return conn; in rxrpc_find_service_conn_rcu()
110 &conn->service_node, in rxrpc_publish_service_conn()
125 if (conn) { in rxrpc_prealloc_service_connection()
130 refcount_set(&conn->ref, 2); in rxrpc_prealloc_service_connection()
141 return conn; in rxrpc_prealloc_service_connection()
162 conn->out_clientflag = 0; in rxrpc_new_incoming_connection()
163 conn->security = sec; in rxrpc_new_incoming_connection()
164 if (conn->security_ix) in rxrpc_new_incoming_connection()
[all …]
A Drxgk.c95 mutex_lock(&conn->security_lock); in rxgk_rekey()
240 conn->debug_id, conn->rxgk.key_number, key_serial(conn->key)); in rxgk_init_connection_security()
250 gk = rxgk_generate_transport_key(conn, token->rxgk, conn->rxgk.key_number, in rxgk_init_connection_security()
257 switch (conn->security_level) { in rxgk_init_connection_security()
642 get_random_bytes(&conn->rxgk.nonce, sizeof(conn->rxgk.nonce)); in rxgk_issue_challenge()
670 memcpy(whdr + 1, conn->rxgk.nonce, sizeof(conn->rxgk.nonce)); in rxgk_issue_challenge()
675 trace_rxrpc_tx_challenge(conn, serial, 0, *(u32 *)&conn->rxgk.nonce); in rxgk_issue_challenge()
703 if (!conn->key) { in rxgk_validate_challenge()
1006 _enter("{%d,%x}", conn->debug_id, key_serial(conn->key)); in rxgk_respond_to_challenge()
1129 if (conn->channels[i].call) in rxgk_do_verify_authenticator()
[all …]
A Drxkad.c106 _enter("{%d},{%x}", conn->debug_id, key_serial(conn->key)); in rxkad_init_connection_security()
121 switch (conn->security_level) { in rxkad_init_connection_security()
135 conn->rxkad.cipher = ci; in rxkad_init_connection_security()
203 if (!conn->key) in rxkad_prime_packet_security()
231 memcpy(&conn->rxkad.csum_iv, tmpbuf + 2, sizeof(conn->rxkad.csum_iv)); in rxkad_prime_packet_security()
654 get_random_bytes(&conn->rxkad.nonce, sizeof(conn->rxkad.nonce)); in rxkad_issue_challenge()
688 trace_rxrpc_tx_challenge(conn, serial, 0, conn->rxkad.nonce); in rxkad_issue_challenge()
765 _enter("{%d,%x}", conn->debug_id, key_serial(conn->key)); in rxkad_validate_challenge()
767 if (!conn->key) { in rxkad_validate_challenge()
870 _enter("{%d,%x}", conn->debug_id, key_serial(conn->key)); in rxkad_respond_to_challenge()
[all …]
/net/rds/
A Dconnection.c98 ret = conn; in rds_conn_lookup()
118 &conn->c_laddr, &conn->c_faddr); in rds_conn_path_reset()
177 if (conn && in __rds_conn_create()
186 parent = conn; in __rds_conn_create()
190 if (conn) in __rds_conn_create()
194 if (!conn) { in __rds_conn_create()
210 conn->c_tos = tos; in __rds_conn_create()
268 __rds_conn_path_init(conn, &conn->c_path[i], in __rds_conn_create()
331 conn = found; in __rds_conn_create()
344 return conn; in __rds_conn_create()
[all …]
A Dib_cm.c85 if (conn->c_isv6) { in rds_ib_cm_connect_complete()
115 &conn->c_laddr, &conn->c_faddr, in rds_ib_cm_connect_complete()
125 &conn->c_laddr, &conn->c_faddr, conn->c_tos, in rds_ib_cm_connect_complete()
159 conn->c_proposed_version = conn->c_version; in rds_ib_cm_connect_complete()
285 struct rds_connection *conn = ic->conn; in rds_ib_tasklet_fn_send() local
325 struct rds_connection *conn = ic->conn; in rds_ib_tasklet_fn_recv() local
369 &conn->c_laddr, &conn->c_faddr); in rds_ib_qp_event_handler()
860 conn = NULL; in rds_ib_cm_handle_connect()
922 if (conn) in rds_ib_cm_handle_connect()
1235 ic->conn = conn; in rds_ib_conn_alloc()
[all …]
A Drdma_transport.c68 if (conn) { in rds_rdma_cm_event_handler_cmn()
89 if (conn) { in rds_rdma_cm_event_handler_cmn()
102 if (conn) { in rds_rdma_cm_event_handler_cmn()
117 if (conn) in rds_rdma_cm_event_handler_cmn()
122 if (!conn) in rds_rdma_cm_event_handler_cmn()
129 &conn->c_laddr, &conn->c_faddr); in rds_rdma_cm_event_handler_cmn()
145 if (conn) in rds_rdma_cm_event_handler_cmn()
150 if (!conn) in rds_rdma_cm_event_handler_cmn()
159 if (conn) { in rds_rdma_cm_event_handler_cmn()
161 &conn->c_laddr, &conn->c_faddr); in rds_rdma_cm_event_handler_cmn()
[all …]
A Dloop.c85 rds_cong_map_updated(conn->c_fcong, ~(u64) 0); in rds_loop_xmit()
92 rds_inc_init(&rm->m_inc, conn, &conn->c_laddr); in rds_loop_xmit()
96 rds_recv_incoming(conn, &conn->c_laddr, &conn->c_faddr, &rm->m_inc, in rds_loop_xmit()
126 struct rds_connection *conn; member
145 lc->conn = conn; in rds_loop_conn_alloc()
146 conn->c_transport_data = lc; in rds_loop_conn_alloc()
191 WARN_ON(lc->conn->c_passive); in rds_loop_exit()
192 rds_conn_destroy(lc->conn); in rds_loop_exit()
203 struct net *c_net = read_pnet(&lc->conn->c_net); in rds_loop_kill_conns()
212 WARN_ON(lc->conn->c_passive); in rds_loop_kill_conns()
[all …]
/net/netfilter/
A Dnf_conncount.c91 list_del(&conn->node); in conn_free()
105 found = nf_conntrack_find_get(net, &conn->zone, &conn->tuple); in find_or_evict()
108 b = conn->jiffies32; in find_or_evict()
118 conn_free(list, conn); in find_or_evict()
148 nf_ct_zone_id(&conn->zone, conn->zone.dir) == in __nf_conncount_add()
188 if (conn == NULL) in __nf_conncount_add()
191 conn->tuple = *tuple; in __nf_conncount_add()
192 conn->zone = *zone; in __nf_conncount_add()
373 if (conn == NULL) { in insert_tree()
378 conn->tuple = *tuple; in insert_tree()
[all …]

Completed in 807 milliseconds

12345