Home
last modified time | relevance | path

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

12345678910>>...18

/linux-6.15/fs/smb/server/
H A Dconnection.c44 kfree(conn); in ksmbd_conn_free()
58 if (!conn) in ksmbd_conn_alloc()
96 return conn; in ksmbd_conn_alloc()
118 struct ksmbd_conn *conn = work->conn; in ksmbd_conn_enqueue_request() local
134 struct ksmbd_conn *conn = work->conn; in ksmbd_conn_try_dequeue_request() local
169 if (conn->binding || xa_load(&conn->sessions, sess_id)) in ksmbd_all_conn_set_status()
192 if (conn->binding || xa_load(&conn->sessions, sess_id)) { in ksmbd_conn_wait_idle_sess_id()
214 struct ksmbd_conn *conn = work->conn; in ksmbd_conn_write() local
252 ret = conn->transport->ops->rdma_read(conn->transport, in ksmbd_conn_rdma_read()
266 ret = conn->transport->ops->rdma_write(conn->transport, in ksmbd_conn_rdma_write()
[all …]
H A Dconnection.h114 int (*process_fn)(struct ksmbd_conn *conn);
115 int (*terminate_fn)(struct ksmbd_conn *conn);
138 struct ksmbd_conn *conn; member
149 bool ksmbd_conn_alive(struct ksmbd_conn *conn);
153 void ksmbd_conn_free(struct ksmbd_conn *conn);
170 void ksmbd_conn_lock(struct ksmbd_conn *conn);
171 void ksmbd_conn_unlock(struct ksmbd_conn *conn);
213 WRITE_ONCE(conn->status, KSMBD_SESS_NEW); in ksmbd_conn_set_new()
218 WRITE_ONCE(conn->status, KSMBD_SESS_GOOD); in ksmbd_conn_set_good()
238 WRITE_ONCE(conn->status, KSMBD_SESS_EXITING); in ksmbd_conn_set_exiting()
[all …]
/linux-6.15/net/smc/
H 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 …]
H 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 …]
H 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 …]
/linux-6.15/net/rxrpc/
H A Dconn_object.c63 if (conn) { in rxrpc_alloc_connection()
81 _leave(" = %p{%d}", conn, conn ? conn->debug_id : 0); in rxrpc_alloc_connection()
82 return conn; in rxrpc_alloc_connection()
110 if (!conn || refcount_read(&conn->ref) == 0) { in rxrpc_find_client_connection_rcu()
138 return conn; in rxrpc_find_client_connection_rcu()
192 struct rxrpc_connection *conn = call->conn; in rxrpc_disconnect_call() local
235 if (conn) { in rxrpc_see_connection()
264 if (conn) { in rxrpc_get_connection_maybe()
335 conn->security->clear(conn); in rxrpc_clean_up_connection()
361 if (!conn) in rxrpc_put_connection()
[all …]
H A Dconn_event.c32 conn->error = err; in rxrpc_set_conn_aborted()
33 conn->completion = compl; in rxrpc_set_conn_aborted()
153 if_mtu = conn->peer->if_mtu - conn->peer->hdrsize; in rxrpc_conn_retransmit_call()
208 _enter("{%d},%x", conn->debug_id, conn->abort_code); in rxrpc_abort_calls()
215 conn->completion, in rxrpc_abort_calls()
217 conn->error); in rxrpc_abort_calls()
251 return conn->security->respond_to_challenge(conn, skb); in rxrpc_process_event()
254 ret = conn->security->verify_response(conn, skb); in rxrpc_process_event()
259 conn, conn->key->payload.data[0]); in rxrpc_process_event()
273 sp->conn = rxrpc_get_connection(conn, rxrpc_conn_get_poke_secured); in rxrpc_process_event()
[all …]
H 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 …]
H 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 …]
/linux-6.15/net/bluetooth/
H 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()
1671 link->conn = hci_conn_hold(conn); in hci_conn_link()
2165 conn->le_tx_phy ? conn->le_tx_phy : in hci_bind_bis()
2678 chan->conn = hci_conn_get(conn); in hci_chan_create()
2689 struct hci_conn *conn = chan->conn; in hci_chan_del() local
[all …]
H A Dhci_event.c175 if (conn) in hci_cc_role_discovery()
197 if (conn) in hci_cc_read_link_policy()
2292 if (conn && conn->state == BT_CONNECT) { in hci_cs_create_conn()
2403 if (conn->state != BT_CONFIG || !conn->out) in hci_outgoing_auth_needed()
2474 if (conn && (conn->state == BT_CONFIG || conn->state == BT_CONNECTED)) in hci_check_pending_name()
2781 mgmt_device_disconnected(hdev, &conn->dst, conn->type, conn->dst_type, in hci_cs_disconnect()
3414 mgmt_device_disconnected(hdev, &conn->dst, conn->type, conn->dst_type, in hci_disconn_complete_evt()
4488 conn->type, conn); in hci_num_comp_pkts_evt()
5489 if (!conn || !hci_conn_ssp_enabled(conn)) in hci_simple_pair_complete_evt()
6001 params->conn = hci_conn_get(conn); in check_pending_le_conn()
[all …]
H 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()
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()
208 if (!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 …]
/linux-6.15/drivers/target/iscsi/
H A Discsi_target_login.c47 login->conn = conn; in iscsi_login_init_conn()
685 " %pISpc,%hu\n", conn->cid, &conn->login_sockaddr, in iscsi_post_login_handler()
732 conn->cid, &conn->login_sockaddr, &conn->local_sockaddr, in iscsi_post_login_handler()
883 rc = conn->sock->ops->getname(conn->sock, in iscsit_accept_np()
897 rc = conn->sock->ops->getname(conn->sock, in iscsit_accept_np()
913 rc = conn->sock->ops->getname(conn->sock, in iscsit_accept_np()
918 rc = conn->sock->ops->getname(conn->sock, in iscsit_accept_np()
1006 if (!conn) { in iscsit_alloc_conn()
1139 conn->conn_transport->iscsit_wait_conn(conn); in iscsi_target_login_sess_out()
1142 conn->conn_transport->iscsit_free_conn(conn); in iscsi_target_login_sess_out()
[all …]
H A Discsi_target_util.c173 cmd->conn = conn; in iscsit_allocate_cmd()
660 if (cmd->conn) in iscsit_release_cmd()
681 struct iscsit_conn *conn = cmd->conn; in __iscsit_free_cmd() local
697 if (conn && conn->conn_transport->iscsit_unmap_cmd) in __iscsit_free_cmd()
698 conn->conn_transport->iscsit_unmap_cmd(conn, cmd); in __iscsit_free_cmd()
813 if (!conn->conn_usage_count && conn->conn_waiting_on_uc) in iscsit_dec_conn_usage_count()
1011 conn->login_kworker->comm, conn->login_kworker->pid); in iscsit_login_timeout()
1136 tx_sent = conn->sock->ops->sendmsg(conn->sock, &msghdr, in iscsit_fe_sendpage_sg()
1220 if (!conn || !conn->sock || !conn->conn_ops) in rx_data()
1250 if (!conn || !conn->sock || !conn->conn_ops) in tx_data()
[all …]
H A Discsi_target_nego.c356 if (conn->conn_transport->iscsit_put_login_tx(conn, login, in iscsi_target_do_tx_login_io()
366 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()
429 if (!conn->sock) in iscsi_target_set_sock_callbacks()
592 rc = conn->conn_transport->iscsit_get_login_rx(conn, login); in iscsi_target_do_login_rx()
666 if (!conn) { in iscsi_target_sk_state_change()
674 conn); in iscsi_target_sk_state_change()
694 conn); in iscsi_target_sk_state_change()
771 conn, in iscsi_target_do_authentication()
870 conn); in iscsi_target_handle_csg_zero()
[all …]
H 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 …]
H A Discsi_target.c833 conn = cmd->conn; in iscsit_add_reject_from_cmd()
1190 conn->cid); in iscsit_setup_scsi_cmd()
1646 struct iscsit_conn *conn = cmd->conn; in iscsit_check_dataout_payload() local
2330 " for SID: %u.\n", conn->cid, conn->sess->sid); in iscsit_logout_closesession()
2584 struct iscsit_conn *conn = cmd->conn; in iscsit_handle_immediate_data() local
3072 conn->conn_transport->iscsit_get_r2t_ttt(conn, cmd, r2t); in iscsit_send_r2t()
3324 struct iscsit_conn *conn = cmd->conn; in iscsit_build_sendtargets_response() local
3778 cmd, conn); in iscsit_response_queue()
4130 conn->conn_transport->iscsit_get_rx_pdu(conn); in iscsi_target_rx_thread()
4270 conn->conn_transport->iscsit_wait_conn(conn); in iscsit_close_connection()
[all …]
/linux-6.15/drivers/net/ethernet/mellanox/mlx5/core/fpga/
H 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.15/fs/notify/
H A Dmark.c179 if (conn->obj) in fsnotify_update_sb_watchers()
295 if (!conn) in fsnotify_recalc_mask()
324 free = conn; in fsnotify_connector_destroy_workfn()
325 conn = conn->destroy_next; in fsnotify_connector_destroy_workfn()
395 if (!conn) { in fsnotify_put_mark()
664 if (!conn) in fsnotify_attach_connector_to_object()
698 if (!conn) in fsnotify_grab_connector()
708 return conn; in fsnotify_grab_connector()
744 if (!conn) { in fsnotify_add_mark_list()
867 if (!conn) in fsnotify_find_mark()
[all …]
/linux-6.15/drivers/gpu/drm/bridge/
H A Ddisplay-connector.c47 if (conn->hpd_gpio) { in display_connector_detect()
54 if (conn->bridge.ddc && drm_probe_ddc(conn->bridge.ddc)) in display_connector_detect()
212 conn = devm_kzalloc(&pdev->dev, sizeof(*conn), GFP_KERNEL); in display_connector_probe()
213 if (!conn) in display_connector_probe()
293 conn->hpd_irq = gpiod_to_irq(conn->hpd_gpio); in display_connector_probe()
304 "HPD", conn); in display_connector_probe()
356 if (conn->supply) { in display_connector_probe()
370 if (conn->hpd_gpio) in display_connector_probe()
381 conn->bridge.ops); in display_connector_probe()
392 if (conn->ddc_en) in display_connector_remove()
[all …]
/linux-6.15/net/rds/
H 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.15/drivers/scsi/
H 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 …]
H A Discsi_tcp.c142 rd_desc.arg.data = conn; in iscsi_sw_tcp_recv_data()
177 if (!conn) { in iscsi_sw_tcp_data_ready()
200 if (!conn) { in iscsi_sw_tcp_state_change()
229 if (!conn) { in iscsi_sw_tcp_write_space()
404 struct iscsi_conn *conn = task->conn; in iscsi_sw_tcp_pdu_xmit() local
456 ISCSI_SW_TCP_DBG(conn, "%s\n", conn->hdrdgst_en ? in iscsi_sw_tcp_send_hdr_prep()
499 conn->datadgst_en ? in iscsi_sw_tcp_send_data_prep()
507 if (conn->datadgst_en) in iscsi_sw_tcp_send_data_prep()
523 ISCSI_SW_TCP_DBG(conn, "datalen=%zd %s\n", len, conn->datadgst_en ? in iscsi_sw_tcp_send_linear_data_prep()
541 struct iscsi_conn *conn = task->conn; in iscsi_sw_tcp_pdu_init() local
[all …]
/linux-6.15/drivers/s390/net/
H 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 …]
/linux-6.15/drivers/gpu/drm/nouveau/nvif/
H A Dconn.c35 struct nvif_conn_event_v0 conn; in nvif_conn_event_ctor() member
39 args.conn.version = 0; in nvif_conn_event_ctor()
40 args.conn.types = types; in nvif_conn_event_ctor()
42 ret = nvif_event_ctor_(&conn->object, name ?: "nvifConnHpd", nvif_conn_id(conn), in nvif_conn_event_ctor()
44 NVIF_DEBUG(&conn->object, "[NEW EVENT:HPD types:%02x]", types); in nvif_conn_event_ctor()
49 nvif_conn_dtor(struct nvif_conn *conn) in nvif_conn_dtor() argument
51 nvif_object_dtor(&conn->object); in nvif_conn_dtor()
64 &args, sizeof(args), &conn->object); in nvif_conn_ctor()
69 conn->id = id; in nvif_conn_ctor()
73 case NVIF_CONN_V0_TV : conn->info.type = NVIF_CONN_TV; break; in nvif_conn_ctor()
[all …]

12345678910>>...18