| /Linux-v5.4/net/bluetooth/ |
| D | hci_conn.c | 63 static void hci_connect_le_scan_cleanup(struct hci_conn *conn) in hci_connect_le_scan_cleanup() argument
66 struct hci_dev *hdev = conn->hdev; in hci_connect_le_scan_cleanup()
71 bdaddr = &conn->dst; in hci_connect_le_scan_cleanup()
72 bdaddr_type = conn->dst_type; in hci_connect_le_scan_cleanup()
114 static void hci_conn_cleanup(struct hci_conn *conn) in hci_conn_cleanup() argument
116 struct hci_dev *hdev = conn->hdev; in hci_conn_cleanup()
118 if (test_bit(HCI_CONN_PARAM_REMOVAL_PEND, &conn->flags)) in hci_conn_cleanup()
119 hci_conn_params_del(conn->hdev, &conn->dst, conn->dst_type); in hci_conn_cleanup()
121 hci_chan_list_flush(conn); in hci_conn_cleanup()
123 hci_conn_hash_del(hdev, conn); in hci_conn_cleanup()
[all …]
|
| D | hci_event.c | 104 struct hci_conn *conn; in hci_cc_role_discovery() local
113 conn = hci_conn_hash_lookup_handle(hdev, __le16_to_cpu(rp->handle)); in hci_cc_role_discovery()
114 if (conn) in hci_cc_role_discovery()
115 conn->role = rp->role; in hci_cc_role_discovery()
123 struct hci_conn *conn; in hci_cc_read_link_policy() local
132 conn = hci_conn_hash_lookup_handle(hdev, __le16_to_cpu(rp->handle)); in hci_cc_read_link_policy()
133 if (conn) in hci_cc_read_link_policy()
134 conn->link_policy = __le16_to_cpu(rp->policy); in hci_cc_read_link_policy()
142 struct hci_conn *conn; in hci_cc_write_link_policy() local
156 conn = hci_conn_hash_lookup_handle(hdev, __le16_to_cpu(rp->handle)); in hci_cc_write_link_policy()
[all …]
|
| /Linux-v5.4/net/smc/ |
| D | smc_cdc.c | 30 struct smc_connection *conn = cdcpend->conn; in smc_cdc_tx_handler() local
34 if (!conn) in smc_cdc_tx_handler()
38 smc = container_of(conn, struct smc_sock, conn); in smc_cdc_tx_handler()
41 diff = smc_curs_diff(cdcpend->conn->sndbuf_desc->len, in smc_cdc_tx_handler()
42 &cdcpend->conn->tx_curs_fin, in smc_cdc_tx_handler()
46 atomic_add(diff, &cdcpend->conn->sndbuf_space); in smc_cdc_tx_handler()
49 smc_curs_copy(&conn->tx_curs_fin, &cdcpend->cursor, conn); in smc_cdc_tx_handler()
55 int smc_cdc_get_free_slot(struct smc_connection *conn, in smc_cdc_get_free_slot() argument
60 struct smc_link *link = &conn->lgr->lnk[SMC_SINGLE_LINK]; in smc_cdc_get_free_slot()
66 if (!conn->alert_token_local) in smc_cdc_get_free_slot()
[all …]
|
| D | smc_tx.c | 47 if (atomic_read(&smc->conn.sndbuf_space) && sock) { in smc_tx_write_space()
77 struct smc_connection *conn = &smc->conn; in smc_tx_wait() local
89 conn->local_tx_ctrl.conn_state_flags.peer_done_writing) { in smc_tx_wait()
93 if (smc_cdc_rxed_any_close(conn)) { in smc_tx_wait()
108 if (atomic_read(&conn->sndbuf_space) && !conn->urg_tx_pend) in smc_tx_wait()
114 smc_cdc_rxed_any_close(conn) || in smc_tx_wait()
115 (atomic_read(&conn->sndbuf_space) && in smc_tx_wait()
116 !conn->urg_tx_pend), in smc_tx_wait()
137 struct smc_connection *conn = &smc->conn; in smc_tx_sendmsg() local
158 conn->local_tx_ctrl.conn_state_flags.peer_conn_abort) in smc_tx_sendmsg()
[all …]
|
| D | smc_rx.c | 56 struct smc_connection *conn = &smc->conn; in smc_rx_update_consumer() local
61 smc_curs_add(conn->rmb_desc->len, &cons, len); in smc_rx_update_consumer()
64 if (conn->urg_state == SMC_URG_VALID || conn->urg_rx_skip_pend) { in smc_rx_update_consumer()
65 diff = smc_curs_comp(conn->rmb_desc->len, &cons, in smc_rx_update_consumer()
66 &conn->urg_curs); in smc_rx_update_consumer()
71 conn->urg_state = SMC_URG_READ; in smc_rx_update_consumer()
77 smc_curs_add(conn->rmb_desc->len, &cons, 1); in smc_rx_update_consumer()
78 conn->urg_rx_skip_pend = false; in smc_rx_update_consumer()
81 conn->urg_state = SMC_URG_READ; in smc_rx_update_consumer()
85 smc_curs_copy(&conn->local_tx_ctrl.cons, &cons, conn); in smc_rx_update_consumer()
[all …]
|
| D | smc_close.c | 58 if (!smc_tx_prepared_sends(&smc->conn)) in smc_close_stream_wait()
67 !smc_tx_prepared_sends(&smc->conn) || in smc_close_stream_wait()
85 static int smc_close_wr(struct smc_connection *conn) in smc_close_wr() argument
87 conn->local_tx_ctrl.conn_state_flags.peer_done_writing = 1; in smc_close_wr()
89 return smc_cdc_get_slot_and_msg_send(conn); in smc_close_wr()
92 static int smc_close_final(struct smc_connection *conn) in smc_close_final() argument
94 if (atomic_read(&conn->bytes_to_rcv)) in smc_close_final()
95 conn->local_tx_ctrl.conn_state_flags.peer_conn_abort = 1; in smc_close_final()
97 conn->local_tx_ctrl.conn_state_flags.peer_conn_closed = 1; in smc_close_final()
99 return smc_cdc_get_slot_and_msg_send(conn); in smc_close_final()
[all …]
|
| D | smc_diag.c | 97 else if (smc->conn.lgr && smc->conn.lgr->is_smcd) in __smc_diag_dump()
111 smc->conn.alert_token_local) { in __smc_diag_dump()
112 struct smc_connection *conn = &smc->conn; in __smc_diag_dump() local
114 .token = conn->alert_token_local, in __smc_diag_dump()
115 .sndbuf_size = conn->sndbuf_desc ? in __smc_diag_dump()
116 conn->sndbuf_desc->len : 0, in __smc_diag_dump()
117 .rmbe_size = conn->rmb_desc ? conn->rmb_desc->len : 0, in __smc_diag_dump()
118 .peer_rmbe_size = conn->peer_rmbe_size, in __smc_diag_dump()
120 .rx_prod.wrap = conn->local_rx_ctrl.prod.wrap, in __smc_diag_dump()
121 .rx_prod.count = conn->local_rx_ctrl.prod.count, in __smc_diag_dump()
[all …]
|
| D | smc_cdc.h | 77 static inline bool smc_cdc_rxed_any_close(struct smc_connection *conn) in smc_cdc_rxed_any_close() argument
79 return conn->local_rx_ctrl.conn_state_flags.peer_conn_abort || in smc_cdc_rxed_any_close()
80 conn->local_rx_ctrl.conn_state_flags.peer_conn_closed; in smc_cdc_rxed_any_close()
84 struct smc_connection *conn) in smc_cdc_rxed_any_close_or_senddone() argument
86 return smc_cdc_rxed_any_close(conn) || in smc_cdc_rxed_any_close_or_senddone()
87 conn->local_rx_ctrl.conn_state_flags.peer_done_writing; in smc_cdc_rxed_any_close_or_senddone()
102 struct smc_connection *conn) in smc_curs_read() argument
108 spin_lock_irqsave(&conn->acurs_lock, flags); in smc_curs_read()
110 spin_unlock_irqrestore(&conn->acurs_lock, flags); in smc_curs_read()
120 struct smc_connection *conn) in smc_curs_copy() argument
[all …]
|
| /Linux-v5.4/net/rxrpc/ |
| D | conn_object.c | 26 struct rxrpc_connection *conn = in rxrpc_connection_timer() local
29 rxrpc_queue_conn(conn); in rxrpc_connection_timer()
37 struct rxrpc_connection *conn; in rxrpc_alloc_connection() local
41 conn = kzalloc(sizeof(struct rxrpc_connection), gfp); in rxrpc_alloc_connection()
42 if (conn) { in rxrpc_alloc_connection()
43 INIT_LIST_HEAD(&conn->cache_link); in rxrpc_alloc_connection()
44 spin_lock_init(&conn->channel_lock); in rxrpc_alloc_connection()
45 INIT_LIST_HEAD(&conn->waiting_calls); in rxrpc_alloc_connection()
46 timer_setup(&conn->timer, &rxrpc_connection_timer, 0); in rxrpc_alloc_connection()
47 INIT_WORK(&conn->processor, &rxrpc_process_connection); in rxrpc_alloc_connection()
[all …]
|
| D | conn_client.c | 100 static int rxrpc_get_client_connection_id(struct rxrpc_connection *conn, in rxrpc_get_client_connection_id() argument
103 struct rxrpc_net *rxnet = conn->params.local->rxnet; in rxrpc_get_client_connection_id()
111 id = idr_alloc_cyclic(&rxrpc_client_conn_ids, conn, in rxrpc_get_client_connection_id()
119 conn->proto.epoch = rxnet->epoch; in rxrpc_get_client_connection_id()
120 conn->proto.cid = id << RXRPC_CIDSHIFT; in rxrpc_get_client_connection_id()
121 set_bit(RXRPC_CONN_HAS_IDR, &conn->flags); in rxrpc_get_client_connection_id()
122 _leave(" [CID %x]", conn->proto.cid); in rxrpc_get_client_connection_id()
135 static void rxrpc_put_client_connection_id(struct rxrpc_connection *conn) in rxrpc_put_client_connection_id() argument
137 if (test_bit(RXRPC_CONN_HAS_IDR, &conn->flags)) { in rxrpc_put_client_connection_id()
140 conn->proto.cid >> RXRPC_CIDSHIFT); in rxrpc_put_client_connection_id()
[all …]
|
| D | conn_event.c | 22 static void rxrpc_conn_retransmit_call(struct rxrpc_connection *conn, in rxrpc_conn_retransmit_call() argument
42 _enter("%d", conn->debug_id); in rxrpc_conn_retransmit_call()
44 chan = &conn->channels[channel]; in rxrpc_conn_retransmit_call()
55 msg.msg_name = &conn->params.peer->srx.transport; in rxrpc_conn_retransmit_call()
56 msg.msg_namelen = conn->params.peer->srx.transport_len; in rxrpc_conn_retransmit_call()
68 pkt.whdr.epoch = htonl(conn->proto.epoch); in rxrpc_conn_retransmit_call()
69 pkt.whdr.cid = htonl(conn->proto.cid | channel); in rxrpc_conn_retransmit_call()
73 pkt.whdr.flags = conn->out_clientflag; in rxrpc_conn_retransmit_call()
75 pkt.whdr.securityIndex = conn->security_ix; in rxrpc_conn_retransmit_call()
77 pkt.whdr.serviceId = htons(conn->service_id); in rxrpc_conn_retransmit_call()
[all …]
|
| D | conn_service.c | 24 struct rxrpc_connection *conn = NULL; in rxrpc_find_service_conn_rcu() local
42 conn = rb_entry(p, struct rxrpc_connection, service_node); in rxrpc_find_service_conn_rcu()
44 if (conn->proto.index_key < k.index_key) in rxrpc_find_service_conn_rcu()
46 else if (conn->proto.index_key > k.index_key) in rxrpc_find_service_conn_rcu()
50 conn = NULL; in rxrpc_find_service_conn_rcu()
55 _leave(" = %d", conn ? conn->debug_id : -1); in rxrpc_find_service_conn_rcu()
56 return conn; in rxrpc_find_service_conn_rcu()
64 struct rxrpc_connection *conn) in rxrpc_publish_service_conn() argument
67 struct rxrpc_conn_proto k = conn->proto; in rxrpc_publish_service_conn()
87 rb_link_node_rcu(&conn->service_node, parent, pp); in rxrpc_publish_service_conn()
[all …]
|
| /Linux-v5.4/drivers/net/ethernet/mellanox/mlx5/core/fpga/ |
| D | 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 …]
|
| /Linux-v5.4/drivers/target/iscsi/ |
| D | iscsi_target_login.c | 37 static struct iscsi_login *iscsi_login_init_conn(struct iscsi_conn *conn) in iscsi_login_init_conn() argument
46 conn->login = login; in iscsi_login_init_conn()
47 login->conn = conn; in iscsi_login_init_conn()
62 conn->conn_login = login; in iscsi_login_init_conn()
77 int iscsi_login_setup_crypto(struct iscsi_conn *conn) in iscsi_login_setup_crypto() argument
92 conn->conn_rx_hash = ahash_request_alloc(tfm, GFP_KERNEL); in iscsi_login_setup_crypto()
93 if (!conn->conn_rx_hash) { in iscsi_login_setup_crypto()
98 ahash_request_set_callback(conn->conn_rx_hash, 0, NULL, NULL); in iscsi_login_setup_crypto()
100 conn->conn_tx_hash = ahash_request_alloc(tfm, GFP_KERNEL); in iscsi_login_setup_crypto()
101 if (!conn->conn_tx_hash) { in iscsi_login_setup_crypto()
[all …]
|
| D | iscsi_target_util.c | 78 iscsit_add_cmd_to_immediate_queue(cmd, cmd->conn, ISTATE_SEND_R2T); in iscsit_add_r2t_to_list()
172 struct iscsi_cmd *iscsit_allocate_cmd(struct iscsi_conn *conn, int state) in iscsit_allocate_cmd() argument
175 struct se_session *se_sess = conn->sess->se_sess; in iscsit_allocate_cmd()
184 size = sizeof(struct iscsi_cmd) + conn->conn_transport->priv_size; in iscsit_allocate_cmd()
190 cmd->conn = conn; in iscsit_allocate_cmd()
302 int iscsit_sequence_cmd(struct iscsi_conn *conn, struct iscsi_cmd *cmd, in iscsit_sequence_cmd() argument
309 mutex_lock(&conn->sess->cmdsn_mutex); in iscsit_sequence_cmd()
311 cmdsn_ret = iscsit_check_received_cmdsn(conn->sess, be32_to_cpu(cmdsn)); in iscsit_sequence_cmd()
315 if ((ret >= 0) && !list_empty(&conn->sess->sess_ooo_cmdsn_list)) in iscsit_sequence_cmd()
316 iscsit_execute_ooo_cmdsns(conn->sess); in iscsit_sequence_cmd()
[all …]
|
| D | iscsi_target_nego.c | 99 struct iscsi_conn *conn, in iscsi_handle_authentication() argument
106 struct iscsi_session *sess = conn->sess; in iscsi_handle_authentication()
116 se_nacl = conn->sess->se_sess->se_node_acl; in iscsi_handle_authentication()
149 strcpy(conn->sess->auth_type, "CHAP"); in iscsi_handle_authentication()
151 strcpy(conn->sess->auth_type, NONE); in iscsi_handle_authentication()
156 return chap_main_loop(conn, auth, in_buf, out_buf, in iscsi_handle_authentication()
162 static void iscsi_remove_failed_auth_entry(struct iscsi_conn *conn) in iscsi_remove_failed_auth_entry() argument
164 kfree(conn->auth_protocol); in iscsi_remove_failed_auth_entry()
168 struct iscsi_conn *conn, in iscsi_target_check_login_request() argument
184 iscsit_tx_login_rsp(conn, ISCSI_STATUS_CLS_INITIATOR_ERR, in iscsi_target_check_login_request()
[all …]
|
| D | iscsi_target_erl0.c | 34 struct iscsi_conn *conn = cmd->conn; in iscsit_set_dataout_sequence_values() local
42 conn->sess->sess_ops->FirstBurstLength); in iscsit_set_dataout_sequence_values()
46 if (!conn->sess->sess_ops->DataSequenceInOrder) in iscsit_set_dataout_sequence_values()
52 conn->sess->sess_ops->MaxBurstLength) ? in iscsit_set_dataout_sequence_values()
54 conn->sess->sess_ops->MaxBurstLength) : cmd->se_cmd.data_length; in iscsit_set_dataout_sequence_values()
58 conn->sess->sess_ops->MaxBurstLength) >= in iscsit_set_dataout_sequence_values()
61 conn->sess->sess_ops->MaxBurstLength); in iscsit_set_dataout_sequence_values()
69 struct iscsi_conn *conn = cmd->conn; in iscsit_dataout_within_command_recovery_check() local
85 if (conn->sess->sess_ops->DataSequenceInOrder) { in iscsit_dataout_within_command_recovery_check()
103 if (conn->sess->sess_ops->DataPDUInOrder) { in iscsit_dataout_within_command_recovery_check()
[all …]
|
| D | iscsi_target.c | 477 int iscsit_queue_rsp(struct iscsi_conn *conn, struct iscsi_cmd *cmd) in iscsit_queue_rsp() argument
479 return iscsit_add_cmd_to_response_queue(cmd, cmd->conn, cmd->i_state); in iscsit_queue_rsp()
483 void iscsit_aborted_task(struct iscsi_conn *conn, struct iscsi_cmd *cmd) in iscsit_aborted_task() argument
485 spin_lock_bh(&conn->cmd_lock); in iscsit_aborted_task()
489 spin_unlock_bh(&conn->cmd_lock); in iscsit_aborted_task()
500 iscsit_xmit_nondatain_pdu(struct iscsi_conn *conn, struct iscsi_cmd *cmd, in iscsit_xmit_nondatain_pdu() argument
512 if (conn->conn_ops->HeaderDigest) { in iscsit_xmit_nondatain_pdu()
515 iscsit_do_crypto_hash_buf(conn->conn_tx_hash, hdr, in iscsit_xmit_nondatain_pdu()
541 if (conn->conn_ops->DataDigest) { in iscsit_xmit_nondatain_pdu()
542 iscsit_do_crypto_hash_buf(conn->conn_tx_hash, in iscsit_xmit_nondatain_pdu()
[all …]
|
| /Linux-v5.4/fs/notify/ |
| D | mark.c | 100 static __u32 *fsnotify_conn_mask_p(struct fsnotify_mark_connector *conn) in fsnotify_conn_mask_p() argument
102 if (conn->type == FSNOTIFY_OBJ_TYPE_INODE) in fsnotify_conn_mask_p()
103 return &fsnotify_conn_inode(conn)->i_fsnotify_mask; in fsnotify_conn_mask_p()
104 else if (conn->type == FSNOTIFY_OBJ_TYPE_VFSMOUNT) in fsnotify_conn_mask_p()
105 return &fsnotify_conn_mount(conn)->mnt_fsnotify_mask; in fsnotify_conn_mask_p()
106 else if (conn->type == FSNOTIFY_OBJ_TYPE_SB) in fsnotify_conn_mask_p()
107 return &fsnotify_conn_sb(conn)->s_fsnotify_mask; in fsnotify_conn_mask_p()
111 __u32 fsnotify_conn_mask(struct fsnotify_mark_connector *conn) in fsnotify_conn_mask() argument
113 if (WARN_ON(!fsnotify_valid_obj_type(conn->type))) in fsnotify_conn_mask()
116 return *fsnotify_conn_mask_p(conn); in fsnotify_conn_mask()
[all …]
|
| /Linux-v5.4/drivers/scsi/ |
| D | libiscsi.c | 86 inline void iscsi_conn_queue_work(struct iscsi_conn *conn) in iscsi_conn_queue_work() argument
88 struct Scsi_Host *shost = conn->session->host; in iscsi_conn_queue_work()
92 queue_work(ihost->workq, &conn->xmitwork); in iscsi_conn_queue_work()
137 struct iscsi_conn *conn = task->conn; in iscsi_prep_data_out_pdu() local
151 if (left > conn->max_xmit_dlength) { in iscsi_prep_data_out_pdu()
152 hton24(hdr->dlength, conn->max_xmit_dlength); in iscsi_prep_data_out_pdu()
153 r2t->data_count = conn->max_xmit_dlength; in iscsi_prep_data_out_pdu()
160 conn->dataout_pdus_cnt++; in iscsi_prep_data_out_pdu()
210 ISCSI_DBG_SESSION(task->conn->session, in iscsi_prep_ecdb_ahs()
233 struct iscsi_conn *conn = task->conn; in iscsi_check_tmf_restrictions() local
[all …]
|
| D | iscsi_tcp.c | 83 struct iscsi_conn *conn = rd_desc->arg.data; in iscsi_sw_tcp_recv() local
87 ISCSI_SW_TCP_DBG(conn, "in %d bytes\n", skb->len - offset); in iscsi_sw_tcp_recv()
91 consumed = iscsi_tcp_recv_skb(conn, skb, offset, 0, &status); in iscsi_sw_tcp_recv()
96 ISCSI_SW_TCP_DBG(conn, "read %d bytes status %d\n", in iscsi_sw_tcp_recv()
113 struct iscsi_conn *conn = sk->sk_user_data; in iscsi_sw_sk_state_check() local
116 (conn->session->state != ISCSI_STATE_LOGGING_OUT) && in iscsi_sw_sk_state_check()
118 ISCSI_SW_TCP_DBG(conn, "TCP_CLOSE|TCP_CLOSE_WAIT\n"); in iscsi_sw_sk_state_check()
119 iscsi_conn_failure(conn, ISCSI_ERR_TCP_CONN_CLOSE); in iscsi_sw_sk_state_check()
127 struct iscsi_conn *conn; in iscsi_sw_tcp_data_ready() local
132 conn = sk->sk_user_data; in iscsi_sw_tcp_data_ready()
[all …]
|
| /Linux-v5.4/drivers/s390/net/ |
| D | netiucv.c | 203 struct iucv_connection *conn; member
214 struct iucv_connection *conn; member
282 static char *netiucv_printuser(struct iucv_connection *conn) in netiucv_printuser() argument
288 if (memcmp(conn->userdata, iucvMagic_ebcdic, 16)) { in netiucv_printuser()
291 memcpy(tmp_uid, netiucv_printname(conn->userid, 8), 8); in netiucv_printuser()
292 memcpy(tmp_udat, conn->userdata, 16); in netiucv_printuser()
298 return netiucv_printname(conn->userid, 8); in netiucv_printuser()
517 struct iucv_connection *conn = path->private; in netiucv_callback_rx() local
520 ev.conn = conn; in netiucv_callback_rx()
522 fsm_event(conn->fsm, CONN_EVENT_RX, &ev); in netiucv_callback_rx()
[all …]
|
| /Linux-v5.4/net/rds/ |
| D | connection.c | 89 struct rds_connection *conn, *ret = NULL; in rds_conn_lookup() local
91 hlist_for_each_entry_rcu(conn, head, c_hash_node) { in rds_conn_lookup()
92 if (ipv6_addr_equal(&conn->c_faddr, faddr) && in rds_conn_lookup()
93 ipv6_addr_equal(&conn->c_laddr, laddr) && in rds_conn_lookup()
94 conn->c_trans == trans && in rds_conn_lookup()
95 conn->c_tos == tos && in rds_conn_lookup()
96 net == rds_conn_net(conn) && in rds_conn_lookup()
97 conn->c_dev_if == dev_if) { in rds_conn_lookup()
98 ret = conn; in rds_conn_lookup()
115 struct rds_connection *conn = cp->cp_conn; in rds_conn_path_reset() local
[all …]
|
| D | ib_cm.c | 48 static void rds_ib_set_protocol(struct rds_connection *conn, unsigned int version) in rds_ib_set_protocol() argument
50 conn->c_version = version; in rds_ib_set_protocol()
56 static void rds_ib_set_flow_control(struct rds_connection *conn, u32 credits) in rds_ib_set_flow_control() argument
58 struct rds_ib_connection *ic = conn->c_transport_data; in rds_ib_set_flow_control()
63 rds_ib_send_add_credits(conn, credits); in rds_ib_set_flow_control()
98 void rds_ib_cm_connect_complete(struct rds_connection *conn, struct rdma_cm_event *event) in rds_ib_cm_connect_complete() argument
100 struct rds_ib_connection *ic = conn->c_transport_data; in rds_ib_cm_connect_complete()
109 dp = event->param.conn.private_data; in rds_ib_cm_connect_complete()
110 if (conn->c_isv6) { in rds_ib_cm_connect_complete()
111 if (event->param.conn.private_data_len >= in rds_ib_cm_connect_complete()
[all …]
|
| D | rdma_transport.c | 54 struct rds_connection *conn = cm_id->context; in rds_rdma_cm_event_handler_cmn() local
60 rdsdebug("conn %p id %p handling event %u (%s)\n", conn, cm_id, in rds_rdma_cm_event_handler_cmn()
68 if (conn) { in rds_rdma_cm_event_handler_cmn()
69 mutex_lock(&conn->c_cm_lock); in rds_rdma_cm_event_handler_cmn()
74 if (rds_conn_state(conn) == RDS_CONN_DISCONNECTING) { in rds_rdma_cm_event_handler_cmn()
89 rdma_set_service_type(cm_id, conn->c_tos); in rds_rdma_cm_event_handler_cmn()
99 if (conn) { in rds_rdma_cm_event_handler_cmn()
102 ibic = conn->c_transport_data; in rds_rdma_cm_event_handler_cmn()
105 TOS_TO_SL(conn->c_tos); in rds_rdma_cm_event_handler_cmn()
108 rds_conn_drop(conn); in rds_rdma_cm_event_handler_cmn()
[all …]
|
