Home
last modified time | relevance | path

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

12345678910>>...16

/linux-6.3-rc2/net/smc/
A Dsmc_cdc.c30 struct smc_connection *conn = cdcpend->conn; in smc_cdc_tx_handler() local
34 smc = container_of(conn, struct smc_sock, conn); in smc_cdc_tx_handler()
103 pend->conn = conn; in smc_cdc_add_pending_send()
120 conn->local_tx_ctrl.seqno = conn->tx_cdc_seq; in smc_cdc_msg_send()
264 smc_curs_copy(&conn->tx_curs_fin, &conn->tx_curs_sent, conn); in smcd_cdc_msg_send()
280 struct smc_connection *conn = &smc->conn; in smc_cdc_handle_urg_data_arrival() local
284 smc_curs_copy(&conn->urg_curs, &conn->local_rx_ctrl.prod, conn); in smc_cdc_handle_urg_data_arrival()
300 struct smc_connection *conn = &smc->conn; in smc_cdc_msg_validate() local
323 struct smc_connection *conn = &smc->conn; in smc_cdc_msg_recv_action() local
415 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
186 struct smc_connection *conn = &smc->conn; in smc_tx_sendmsg() local
241 smc_curs_copy(&prep, &conn->tx_curs_prep, conn); in smc_tx_sendmsg()
271 smc_curs_copy(&conn->tx_curs_prep, &prep, conn); in smc_tx_sendmsg()
325 rc = smc_ism_write(conn->lgr->smcd, conn->peer_token, in smcd_tx_ism_write()
490 smc_curs_copy(&sent, &conn->tx_curs_sent, conn); in smc_tx_rdma_writes()
491 smc_curs_copy(&prep, &conn->tx_curs_prep, conn); in smc_tx_rdma_writes()
580 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()
259 struct smc_connection *conn = &smc->conn; in smc_rx_wait() local
284 struct smc_connection *conn = &smc->conn; in smc_rx_recv_urg() local
303 smc_curs_copy(&cons, &conn->local_tx_ctrl.cons, conn); in smc_rx_recv_urg()
327 struct smc_connection *conn = &smc->conn; in smc_rx_recvmsg_data_available() local
349 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()
156 smc_conn_free(&smc->conn); in smc_close_active_abort()
167 smc_conn_free(&smc->conn); in smc_close_active_abort()
196 struct smc_connection *conn = &smc->conn; in smc_close_active() local
360 struct smc_sock *smc = container_of(conn, struct smc_sock, conn); in smc_close_passive_work()
435 smc_conn_free(conn); in smc_close_passive_work()
448 struct smc_connection *conn = &smc->conn; in smc_close_shutdown_write() local
469 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 …]
/linux-6.3-rc2/net/rxrpc/
A Dconn_object.c63 if (conn) { in rxrpc_alloc_connection()
79 _leave(" = %p{%d}", conn, conn ? conn->debug_id : 0); in rxrpc_alloc_connection()
80 return conn; in rxrpc_alloc_connection()
108 if (!conn || refcount_read(&conn->ref) == 0) { in rxrpc_find_client_connection_rcu()
141 return conn; in rxrpc_find_client_connection_rcu()
195 struct rxrpc_connection *conn = call->conn; in rxrpc_disconnect_call() local
238 if (conn) { in rxrpc_see_connection()
267 if (conn) { in rxrpc_get_connection_maybe()
332 conn->security->clear(conn); in rxrpc_clean_up_connection()
357 if (!conn) in rxrpc_put_connection()
[all …]
A Dconn_event.c32 conn->error = err; in rxrpc_set_conn_aborted()
33 conn->completion = compl; in rxrpc_set_conn_aborted()
193 _enter("{%d},%x", conn->debug_id, conn->abort_code); in rxrpc_abort_calls()
199 conn->completion, in rxrpc_abort_calls()
200 conn->abort_code, in rxrpc_abort_calls()
201 conn->error); in rxrpc_abort_calls()
235 return conn->security->respond_to_challenge(conn, skb); in rxrpc_process_event()
238 ret = conn->security->verify_response(conn, skb); in rxrpc_process_event()
243 conn, conn->key->payload.data[0]); in rxrpc_process_event()
275 if (conn->security->issue_challenge(conn) < 0) in rxrpc_secure_connection()
[all …]
A Dconn_service.c50 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()
109 &conn->service_node, in rxrpc_publish_service_conn()
124 if (conn) { in rxrpc_prealloc_service_connection()
129 refcount_set(&conn->ref, 2); in rxrpc_prealloc_service_connection()
140 return conn; in rxrpc_prealloc_service_connection()
161 conn->out_clientflag = 0; in rxrpc_new_incoming_connection()
162 conn->security = sec; in rxrpc_new_incoming_connection()
163 if (conn->security_ix) in rxrpc_new_incoming_connection()
[all …]
A Dconn_client.c62 conn, refcount_read(&conn->ref)); in rxrpc_destroy_client_conn_ids()
152 if (!conn) in rxrpc_alloc_client_connection()
158 kfree(conn); in rxrpc_alloc_client_connection()
176 conn->service_id = conn->orig_service_id; in rxrpc_alloc_client_connection()
190 return conn; in rxrpc_alloc_client_connection()
201 if (!conn) in rxrpc_may_reuse_conn()
482 if (!conn) in rxrpc_activate_channels()
523 struct rxrpc_connection *conn = call->conn; in rxrpc_expose_client_call() local
574 conn = call->conn; in rxrpc_disconnect_client_call()
575 if (!conn) { in rxrpc_disconnect_client_call()
[all …]
/linux-6.3-rc2/fs/ksmbd/
A Dconnection.c42 kfree(conn); in ksmbd_conn_free()
55 if (!conn) in ksmbd_conn_alloc()
68 conn->um = NULL; in ksmbd_conn_alloc()
90 return conn; in ksmbd_conn_alloc()
112 struct ksmbd_conn *conn = work->conn; in ksmbd_conn_enqueue_request() local
130 struct ksmbd_conn *conn = work->conn; in ksmbd_conn_try_dequeue_request() local
169 struct ksmbd_conn *conn = work->conn; in ksmbd_conn_write() local
201 sent = conn->transport->ops->writev(conn->transport, &iov[0], in ksmbd_conn_write()
223 ret = conn->transport->ops->rdma_read(conn->transport, in ksmbd_conn_rdma_read()
237 ret = conn->transport->ops->rdma_write(conn->transport, in ksmbd_conn_rdma_write()
[all …]
/linux-6.3-rc2/drivers/net/ethernet/mellanox/mlx5/core/fpga/
A Dconn.c110 if (unlikely(conn->qp.rq.pc - conn->qp.rq.cc >= conn->qp.rq.size)) { in mlx5_fpga_conn_post_recv()
115 ix = conn->qp.rq.pc & (conn->qp.rq.size - 1); in mlx5_fpga_conn_post_recv()
135 *conn->qp.wq.sq.db = cpu_to_be32(conn->qp.sq.pc); in mlx5_fpga_conn_notify_hw()
149 ix = conn->qp.sq.pc & (conn->qp.sq.size - 1); in mlx5_fpga_conn_post_send()
191 if (conn->qp.sq.pc - conn->qp.sq.cc >= conn->qp.sq.size) { in mlx5_fpga_conn_send()
279 conn->recv_cb(conn->cb_arg, buf); in mlx5_fpga_conn_rq_cqe()
326 buf->complete(conn, conn->fdev, buf, status); in mlx5_fpga_conn_sq_cqe()
472 conn->cq.mcq.set_ci_db = conn->cq.wq_ctrl.db.db; in mlx5_fpga_conn_create_cq()
536 conn->qp.rq.bufs = kvcalloc(conn->qp.rq.size, in mlx5_fpga_conn_create_qp()
544 conn->qp.sq.bufs = kvcalloc(conn->qp.sq.size, in mlx5_fpga_conn_create_qp()
[all …]
/linux-6.3-rc2/drivers/target/iscsi/
A Discsi_target_login.c48 login->conn = conn; in iscsi_login_init_conn()
726 " %pISpc,%hu\n", conn->cid, &conn->login_sockaddr, in iscsi_post_login_handler()
773 conn->cid, &conn->login_sockaddr, &conn->local_sockaddr, in iscsi_post_login_handler()
977 rc = conn->sock->ops->getname(conn->sock, in iscsit_accept_np()
991 rc = conn->sock->ops->getname(conn->sock, in iscsit_accept_np()
1007 rc = conn->sock->ops->getname(conn->sock, in iscsit_accept_np()
1012 rc = conn->sock->ops->getname(conn->sock, in iscsit_accept_np()
1100 if (!conn) { in iscsit_alloc_conn()
1232 conn->conn_transport->iscsit_wait_conn(conn); in iscsi_target_login_sess_out()
1235 conn->conn_transport->iscsit_free_conn(conn); in iscsi_target_login_sess_out()
[all …]
A Discsi_target_nego.c366 if (conn->rx_thread && conn->rx_thread_active) { in iscsi_target_do_tx_login_io()
371 if (conn->tx_thread && conn->tx_thread_active) { in iscsi_target_do_tx_login_io()
546 struct iscsit_conn *conn = timeout->conn; in iscsi_target_login_timeout() local
552 conn->login_kworker->comm, conn->login_kworker->pid); in iscsi_target_login_timeout()
603 timeout.conn = conn; in iscsi_target_do_login_rx()
674 if (!conn) { in iscsi_target_sk_state_change()
682 conn); in iscsi_target_sk_state_change()
702 conn); in iscsi_target_sk_state_change()
779 conn, in iscsi_target_do_authentication()
878 conn); in iscsi_target_handle_csg_zero()
[all …]
A Discsi_target_util.c173 cmd->conn = conn; in iscsit_allocate_cmd()
338 struct iscsit_conn *conn = cmd->conn; in iscsit_check_unsolicited_dataout() local
704 if (cmd->conn) in iscsit_release_cmd()
725 struct iscsit_conn *conn = cmd->conn; in __iscsit_free_cmd() local
741 if (conn && conn->conn_transport->iscsit_unmap_cmd) in __iscsit_free_cmd()
742 conn->conn_transport->iscsit_unmap_cmd(conn, cmd); in __iscsit_free_cmd()
857 if (!conn->conn_usage_count && conn->conn_waiting_on_uc) in iscsit_dec_conn_usage_count()
1124 tx_sent = conn->sock->ops->sendpage(conn->sock, in iscsit_fe_sendpage_sg()
1224 if (!conn || !conn->sock || !conn->conn_ops) in rx_data()
1254 if (!conn || !conn->sock || !conn->conn_ops) in tx_data()
[all …]
A Discsi_target_erl0.c34 struct iscsit_conn *conn = cmd->conn; in iscsit_set_dataout_sequence_values() local
69 struct iscsit_conn *conn = cmd->conn; in iscsit_dataout_within_command_recovery_check() local
136 struct iscsit_conn *conn = cmd->conn; in iscsit_dataout_check_unsolicited_sequence() local
211 struct iscsit_conn *conn = cmd->conn; in iscsit_dataout_check_sequence() local
340 struct iscsit_conn *conn = cmd->conn; in iscsit_dataout_check_datasn() local
391 struct iscsit_conn *conn = cmd->conn; in iscsit_dataout_pre_datapduinorder_yes() local
537 struct iscsit_conn *conn = cmd->conn; in iscsit_dataout_post_crc_passed() local
647 struct iscsit_conn *conn = cmd->conn; in iscsit_dataout_post_crc_failed() local
686 struct iscsit_conn *conn = cmd->conn; in iscsit_check_pre_dataout() local
724 struct iscsit_conn *conn = cmd->conn; in iscsit_check_post_dataout() local
[all …]
A Discsi_target.c844 conn = cmd->conn; in iscsit_add_reject_from_cmd()
1200 conn->cid); in iscsit_setup_scsi_cmd()
1697 struct iscsit_conn *conn = cmd->conn; in iscsit_check_dataout_payload() local
2385 " for SID: %u.\n", conn->cid, conn->sess->sid); in iscsit_logout_closesession()
2639 struct iscsit_conn *conn = cmd->conn; in iscsit_handle_immediate_data() local
3129 conn->conn_transport->iscsit_get_r2t_ttt(conn, cmd, r2t); in iscsit_send_r2t()
3381 struct iscsit_conn *conn = cmd->conn; in iscsit_build_sendtargets_response() local
3835 cmd, conn); in iscsit_response_queue()
4189 conn->conn_transport->iscsit_get_rx_pdu(conn); in iscsi_target_rx_thread()
4307 conn->conn_transport->iscsit_wait_conn(conn); in iscsit_close_connection()
[all …]
/linux-6.3-rc2/net/bluetooth/
A Dhci_conn.c127 hci_conn_params_del(conn->hdev, &conn->dst, conn->dst_type); in hci_conn_cleanup()
137 conn->cleanup(conn); in hci_conn_cleanup()
192 BT_DBG("%s hcon %p", conn->hdev->name, conn); in hci_connect_le_scan_remove()
318 conn, conn->attempt); in find_next_esco_param()
366 struct hci_conn *conn = conn_handle->conn; in hci_enhanced_setup_sync() local
550 conn_handle->conn = conn; in hci_setup_sync()
675 BT_DBG("hcon %p mode %d", conn, conn->mode); in hci_conn_idle()
962 conn = kzalloc(sizeof(*conn), GFP_KERNEL); in hci_conn_add()
2147 conn->le_tx_phy ? conn->le_tx_phy : in hci_connect_bis()
2600 chan->conn = hci_conn_get(conn); in hci_chan_create()
[all …]
A Dhci_event.c180 if (conn) in hci_cc_role_discovery()
202 if (conn) in hci_cc_read_link_policy()
2319 if (conn && conn->state == BT_CONNECT) { in hci_cs_create_conn()
2431 if (conn->state != BT_CONFIG || !conn->out) in hci_outgoing_auth_needed()
2821 mgmt_device_disconnected(hdev, &conn->dst, conn->type, conn->dst_type, in hci_cs_disconnect()
3421 mgmt_device_disconnected(hdev, &conn->dst, conn->type, conn->dst_type, in hci_disconn_complete_evt()
3848 conn->handle, conn->link); in hci_cc_le_set_cig_params()
4445 conn->type, conn); in hci_num_comp_pkts_evt()
4517 conn->type, conn); in hci_num_comp_blocks_evt()
6169 params->conn = hci_conn_get(conn); in check_pending_le_conn()
[all …]
A Dhci_sysfs.c14 kfree(conn); in bt_link_release()
34 struct hci_dev *hdev = conn->hdev; in hci_conn_init_sysfs()
36 BT_DBG("conn %p", conn); in hci_conn_init_sysfs()
38 conn->dev.type = &bt_link; in hci_conn_init_sysfs()
39 conn->dev.class = bt_class; in hci_conn_init_sysfs()
40 conn->dev.parent = &hdev->dev; in hci_conn_init_sysfs()
42 device_initialize(&conn->dev); in hci_conn_init_sysfs()
49 BT_DBG("conn %p", conn); in hci_conn_add_sysfs()
54 dev_set_name(&conn->dev, "%s:%d", hdev->name, conn->handle); in hci_conn_add_sysfs()
56 if (device_add(&conn->dev) < 0) { in hci_conn_add_sysfs()
[all …]
/linux-6.3-rc2/fs/notify/
A Dmark.c187 if (!conn) in fsnotify_recalc_mask()
210 free = conn; in fsnotify_connector_destroy_workfn()
211 conn = conn->destroy_next; in fsnotify_connector_destroy_workfn()
301 if (!conn) { in fsnotify_put_mark()
546 if (!conn) in fsnotify_attach_connector_to_object()
558 conn->fsid.val[0] = conn->fsid.val[1] = 0; in fsnotify_attach_connector_to_object()
590 if (!conn) in fsnotify_grab_connector()
600 return conn; in fsnotify_grab_connector()
654 conn->fsid.val[0], conn->fsid.val[1]); in fsnotify_add_mark_list()
769 if (!conn) in fsnotify_find_mark()
[all …]
/linux-6.3-rc2/drivers/gpu/drm/bridge/
A Ddisplay-connector.c48 if (conn->hpd_gpio) { in display_connector_detect()
55 if (conn->bridge.ddc && drm_probe_ddc(conn->bridge.ddc)) in display_connector_detect()
201 conn = devm_kzalloc(&pdev->dev, sizeof(*conn), GFP_KERNEL); in display_connector_probe()
202 if (!conn) in display_connector_probe()
281 conn->hpd_irq = gpiod_to_irq(conn->hpd_gpio); in display_connector_probe()
292 "HPD", conn); in display_connector_probe()
341 if (conn->dp_pwr) { in display_connector_probe()
367 if (conn->hpd_gpio) in display_connector_probe()
378 conn->bridge.ops); in display_connector_probe()
389 if (conn->ddc_en) in display_connector_remove()
[all …]
/linux-6.3-rc2/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 …]
/linux-6.3-rc2/drivers/scsi/
A Dlibiscsi.c149 struct iscsi_conn *conn = task->conn; in iscsi_prep_data_out_pdu() local
316 struct iscsi_conn *conn = task->conn; in iscsi_prep_scsi_cmd_pdu() local
456 struct iscsi_conn *conn = task->conn; in iscsi_free_task() local
527 struct iscsi_conn *conn = task->conn; in iscsi_complete_task() local
561 struct iscsi_conn *conn = task->conn; in iscsi_complete_scsi_task() local
576 struct iscsi_conn *conn = task->conn; in cleanup_queued_task() local
617 struct iscsi_conn *conn = task->conn; in __fail_scsi_task() local
759 task->conn = conn; in iscsi_alloc_mgmt_task()
806 struct iscsi_conn *conn = task->conn; in iscsi_send_mgmt_task() local
1072 struct iscsi_conn *conn = task->conn; in iscsi_nop_out_rsp() local
[all …]
A Discsi_tcp.c143 rd_desc.arg.data = conn; in iscsi_sw_tcp_recv_data()
178 if (!conn) { in iscsi_sw_tcp_data_ready()
201 if (!conn) { in iscsi_sw_tcp_state_change()
230 if (!conn) { in iscsi_sw_tcp_write_space()
408 struct iscsi_conn *conn = task->conn; in iscsi_sw_tcp_pdu_xmit() local
460 ISCSI_SW_TCP_DBG(conn, "%s\n", conn->hdrdgst_en ? in iscsi_sw_tcp_send_hdr_prep()
504 conn->datadgst_en ? in iscsi_sw_tcp_send_data_prep()
512 if (conn->datadgst_en) in iscsi_sw_tcp_send_data_prep()
529 ISCSI_SW_TCP_DBG(conn, "datalen=%zd %s\n", len, conn->datadgst_en ? in iscsi_sw_tcp_send_linear_data_prep()
547 struct iscsi_conn *conn = task->conn; in iscsi_sw_tcp_pdu_init() local
[all …]
/linux-6.3-rc2/drivers/s390/net/
A Dnetiucv.c484 ev.conn = conn; in netiucv_callback_rx()
495 ev.conn = conn; in netiucv_callback_txdone()
527 ev.conn = conn; in netiucv_callback_connreq()
632 struct iucv_connection *conn = ev->conn; in conn_action_rx() local
662 netiucv_unpack_skb(conn, conn->rx_buff); in conn_action_rx()
668 struct iucv_connection *conn = ev->conn; in conn_action_txdone() local
683 if (!conn || !conn->netdev) { in conn_action_txdone()
735 conn->prof.txlen += conn->tx_buff->len; in conn_action_txdone()
768 struct iucv_connection *conn = ev->conn; in conn_action_connaccept() local
862 NULL, conn->userdata, conn); in conn_action_start()
[all …]

Completed in 108 milliseconds

12345678910>>...16