Home
last modified time | relevance | path

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

12345678910>>...16

/linux/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()
93 pend->conn = conn; in smc_cdc_add_pending_send()
200 if (!conn->lgr || (conn->lgr->is_smcd && conn->lgr->peer_shutdown)) in smc_cdc_get_slot_and_msg_send()
253 smc_curs_copy(&conn->tx_curs_fin, &conn->tx_curs_sent, conn); in smcd_cdc_msg_send()
269 struct smc_connection *conn = &smc->conn; in smc_cdc_handle_urg_data_arrival() local
273 smc_curs_copy(&conn->urg_curs, &conn->local_rx_ctrl.prod, conn); in smc_cdc_handle_urg_data_arrival()
289 struct smc_connection *conn = &smc->conn; in smc_cdc_msg_validate() local
312 struct smc_connection *conn = &smc->conn; in smc_cdc_msg_recv_action() local
400 if (!conn || conn->killed) in smcd_cdc_rx_tsklet()
[all …]
A Dsmc_tx.c81 struct smc_connection *conn = &smc->conn; in smc_tx_wait() local
142 struct smc_connection *conn = &smc->conn; in smc_tx_sendmsg() local
197 smc_curs_copy(&prep, &conn->tx_curs_prep, conn); in smc_tx_sendmsg()
228 smc_curs_copy(&conn->tx_curs_prep, &prep, conn); in smc_tx_sendmsg()
245 queue_delayed_work(conn->lgr->tx_wq, &conn->tx_work, in smc_tx_sendmsg()
428 smc_curs_copy(&sent, &conn->tx_curs_sent, conn); in smc_tx_rdma_writes()
429 smc_curs_copy(&prep, &conn->tx_curs_prep, conn); in smc_tx_rdma_writes()
444 smc_curs_copy(&prod, &conn->local_tx_ctrl.prod, conn); in smc_tx_rdma_writes()
518 container_of(conn, struct smc_sock, conn); in smcr_tx_sndbuf_nonempty()
525 mod_delayed_work(conn->lgr->tx_wq, &conn->tx_work, in smcr_tx_sndbuf_nonempty()
[all …]
A Dsmc_rx.c58 struct smc_connection *conn = &smc->conn; in smc_rx_update_consumer() local
87 smc_curs_copy(&conn->local_tx_ctrl.cons, &cons, conn); in smc_rx_update_consumer()
98 struct smc_connection *conn = &smc->conn; in smc_rx_update_cons() local
101 smc_curs_copy(&cons, &conn->local_tx_ctrl.cons, conn); in smc_rx_update_cons()
122 conn = &smc->conn; in smc_rx_pipe_buf_release()
197 struct smc_connection *conn = &smc->conn; in smc_rx_wait() local
222 struct smc_connection *conn = &smc->conn; in smc_rx_recv_urg() local
241 smc_curs_copy(&cons, &conn->local_tx_ctrl.cons, conn); in smc_rx_recv_urg()
265 struct smc_connection *conn = &smc->conn; in smc_rx_recvmsg_data_available() local
287 struct smc_connection *conn = &smc->conn; in smc_rx_recvmsg() local
[all …]
A Dsmc_close.c69 smc->conn.killed, in smc_close_stream_wait()
98 if (conn->killed) in smc_close_final()
153 smc_conn_free(&smc->conn); in smc_close_active_abort()
164 smc_conn_free(&smc->conn); in smc_close_active_abort()
193 struct smc_connection *conn = &smc->conn; in smc_close_active() local
266 rc = smc_close_final(conn); in smc_close_active()
354 struct smc_sock *smc = container_of(conn, struct smc_sock, conn); in smc_close_passive_work()
429 smc_conn_free(conn); in smc_close_passive_work()
442 struct smc_connection *conn = &smc->conn; in smc_close_shutdown_write() local
463 rc = smc_close_wr(conn); in smc_close_shutdown_write()
[all …]
A Dsmc_diag.c92 else if (smc->conn.lgr && smc->conn.lgr->is_smcd) in __smc_diag_dump()
106 smc->conn.alert_token_local) { in __smc_diag_dump()
107 struct smc_connection *conn = &smc->conn; in __smc_diag_dump() local
111 conn->sndbuf_desc->len : 0, in __smc_diag_dump()
112 .rmbe_size = conn->rmb_desc ? conn->rmb_desc->len : 0, in __smc_diag_dump()
145 if (smc->conn.lgr && !smc->conn.lgr->is_smcd && in __smc_diag_dump()
149 .role = smc->conn.lgr->role, in __smc_diag_dump()
158 smc->conn.lnk->gid); in __smc_diag_dump()
160 smc->conn.lnk->peer_gid); in __smc_diag_dump()
165 if (smc->conn.lgr && smc->conn.lgr->is_smcd && in __smc_diag_dump()
[all …]
/linux/net/bluetooth/
A Dhci_conn.c119 hci_conn_params_del(conn->hdev, &conn->dst, conn->dst_type); in hci_conn_cleanup()
178 BT_DBG("%s hcon %p", conn->hdev->name, conn); in hci_connect_le_scan_remove()
299 for (; conn->attempt <= size; conn->attempt++) { in find_next_esco_param()
304 conn, conn->attempt); in find_next_esco_param()
592 hci_abort_conn(conn, hci_proto_disconn_ind(conn)); in hci_conn_timeout()
602 BT_DBG("hcon %p mode %d", conn, conn->mode); in hci_conn_idle()
686 conn = kzalloc(sizeof(*conn), GFP_KERNEL); in hci_conn_add()
896 mgmt_connect_failed(hdev, &conn->dst, conn->type, in hci_le_conn_failed()
1711 BT_DBG("hcon %p mode %d", conn, conn->mode); in hci_conn_enter_active_mode()
1902 chan->conn = hci_conn_get(conn); in hci_chan_create()
[all …]
A Dhci_event.c133 if (conn) in hci_cc_role_discovery()
152 if (conn) in hci_cc_read_link_policy()
176 if (conn) in hci_cc_write_link_policy()
1935 if (conn && conn->state == BT_CONNECT) { in hci_cs_create_conn()
2047 if (conn->state != BT_CONFIG || !conn->out) in hci_outgoing_auth_needed()
2958 mgmt_device_disconnected(hdev, &conn->dst, conn->type, conn->dst_type, in hci_disconn_complete_evt()
3953 conn->type, conn); in hci_num_comp_pkts_evt()
4025 conn->type, conn); in hci_num_comp_blocks_evt()
4925 conn->dst_type, conn->passkey_notify, in hci_user_passkey_notify_evt()
5589 params->conn = hci_conn_get(conn); in check_pending_le_conn()
[all …]
/linux/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/net/rxrpc/
A Dconn_object.c42 if (conn) { in rxrpc_alloc_connection()
55 _leave(" = %p{%d}", conn, conn ? conn->debug_id : 0); in rxrpc_alloc_connection()
56 return conn; in rxrpc_alloc_connection()
107 if (!conn || atomic_read(&conn->usage) == 0) in rxrpc_find_connection_rcu()
117 if (!conn || atomic_read(&conn->usage) == 0) { in rxrpc_find_connection_rcu()
208 struct rxrpc_connection *conn = call->conn; in rxrpc_disconnect_call() local
282 if (conn) { in rxrpc_see_connection()
309 if (conn) { in rxrpc_get_connection_maybe()
363 conn->security->clear(conn); in rxrpc_destroy_connection()
408 conn->debug_id, atomic_read(&conn->usage), in rxrpc_service_connection_reaper()
[all …]
A Dconn_event.c158 _enter("{%d},%x", conn->debug_id, conn->abort_code); in rxrpc_abort_calls()
164 conn->channels[i].call, in rxrpc_abort_calls()
171 conn->abort_code, in rxrpc_abort_calls()
172 conn->error); in rxrpc_abort_calls()
177 conn->abort_code, in rxrpc_abort_calls()
178 conn->error); in rxrpc_abort_calls()
210 conn->error = error; in rxrpc_abort_connection()
328 return conn->security->respond_to_challenge(conn, skb, in rxrpc_process_event()
332 ret = conn->security->verify_response(conn, skb, _abort_code); in rxrpc_process_event()
337 conn, conn->params.key->payload.data[0]); in rxrpc_process_event()
[all …]
A Dconn_service.c56 conn = NULL; in rxrpc_find_service_conn_rcu()
61 _leave(" = %d", conn ? conn->debug_id : -1); in rxrpc_find_service_conn_rcu()
62 return conn; in rxrpc_find_service_conn_rcu()
115 &conn->service_node, in rxrpc_publish_service_conn()
130 if (conn) { in rxrpc_prealloc_service_connection()
149 return conn; in rxrpc_prealloc_service_connection()
170 conn->out_clientflag = 0; in rxrpc_new_incoming_connection()
171 conn->security = sec; in rxrpc_new_incoming_connection()
172 if (conn->security_ix) in rxrpc_new_incoming_connection()
186 rxrpc_publish_service_conn(conn->params.peer, conn); in rxrpc_new_incoming_connection()
[all …]
A Dconn_client.c105 conn, atomic_read(&conn->usage)); in rxrpc_destroy_client_conn_ids()
167 if (!conn) { in rxrpc_alloc_client_connection()
177 conn->service_id = conn->params.service_id; in rxrpc_alloc_client_connection()
204 return conn; in rxrpc_alloc_client_connection()
209 kfree(conn); in rxrpc_alloc_client_connection()
222 if (!conn) in rxrpc_may_reuse_conn()
527 call->conn = rxrpc_get_connection(conn); in rxrpc_activate_one_channel()
605 if (!conn) in rxrpc_activate_channels_locked()
753 struct rxrpc_connection *conn = call->conn; in rxrpc_expose_client_call() local
803 conn = call->conn; in rxrpc_disconnect_client_call()
[all …]
/linux/drivers/target/iscsi/
A Discsi_target_login.c48 login->conn = conn; in iscsi_login_init_conn()
713 " %pISpc,%hu\n", conn->cid, &conn->login_sockaddr, in iscsi_post_login_handler()
760 conn->cid, &conn->login_sockaddr, &conn->local_sockaddr, in iscsi_post_login_handler()
964 rc = conn->sock->ops->getname(conn->sock, in iscsit_accept_np()
978 rc = conn->sock->ops->getname(conn->sock, in iscsit_accept_np()
994 rc = conn->sock->ops->getname(conn->sock, in iscsit_accept_np()
999 rc = conn->sock->ops->getname(conn->sock, in iscsit_accept_np()
1087 if (!conn) { in iscsit_alloc_conn()
1211 conn->conn_transport->iscsit_wait_conn(conn); in iscsi_target_login_sess_out()
1214 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()
545 struct iscsi_conn *conn = timeout->conn; in iscsi_target_login_timeout() local
551 conn->login_kworker->comm, conn->login_kworker->pid); in iscsi_target_login_timeout()
602 timeout.conn = conn; in iscsi_target_do_login_rx()
673 if (!conn) { in iscsi_target_sk_state_change()
681 conn); in iscsi_target_sk_state_change()
701 conn); in iscsi_target_sk_state_change()
778 conn, in iscsi_target_do_authentication()
841 conn); in iscsi_target_handle_csg_zero()
[all …]
A Discsi_target_util.c173 cmd->conn = conn; in iscsit_allocate_cmd()
338 struct iscsi_conn *conn = cmd->conn; in iscsit_check_unsolicited_dataout() local
704 if (cmd->conn) in iscsit_release_cmd()
725 struct iscsi_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 iscsi_conn *conn = cmd->conn; in iscsit_set_dataout_sequence_values() local
69 struct iscsi_conn *conn = cmd->conn; in iscsit_dataout_within_command_recovery_check() local
136 struct iscsi_conn *conn = cmd->conn; in iscsit_dataout_check_unsolicited_sequence() local
211 struct iscsi_conn *conn = cmd->conn; in iscsit_dataout_check_sequence() local
340 struct iscsi_conn *conn = cmd->conn; in iscsit_dataout_check_datasn() local
391 struct iscsi_conn *conn = cmd->conn; in iscsit_dataout_pre_datapduinorder_yes() local
537 struct iscsi_conn *conn = cmd->conn; in iscsit_dataout_post_crc_passed() local
647 struct iscsi_conn *conn = cmd->conn; in iscsit_dataout_post_crc_failed() local
686 struct iscsi_conn *conn = cmd->conn; in iscsit_check_pre_dataout() local
724 struct iscsi_conn *conn = cmd->conn; in iscsit_check_post_dataout() local
[all …]
A Discsi_target.c835 conn = cmd->conn; in iscsit_add_reject_from_cmd()
1165 conn->cid); in iscsit_setup_scsi_cmd()
1659 struct iscsi_conn *conn = cmd->conn; in iscsit_check_dataout_payload() local
2347 " for SID: %u.\n", conn->cid, conn->sess->sid); in iscsit_logout_closesession()
2601 struct iscsi_conn *conn = cmd->conn; in iscsit_handle_immediate_data() local
3091 conn->conn_transport->iscsit_get_r2t_ttt(conn, cmd, r2t); in iscsit_send_r2t()
3343 struct iscsi_conn *conn = cmd->conn; in iscsit_build_sendtargets_response() local
3723 cmd, conn); in iscsit_response_queue()
4057 conn->conn_transport->iscsit_get_rx_pdu(conn); in iscsi_target_rx_thread()
4175 conn->conn_transport->iscsit_wait_conn(conn); in iscsit_close_connection()
[all …]
/linux/fs/ksmbd/
A Dconnection.c41 kfree(conn); in ksmbd_conn_free()
54 if (!conn) in ksmbd_conn_alloc()
60 if (!conn->local_nls) in ksmbd_conn_alloc()
81 return conn; in ksmbd_conn_alloc()
103 struct ksmbd_conn *conn = work->conn; in ksmbd_conn_enqueue_request() local
121 struct ksmbd_conn *conn = work->conn; in ksmbd_conn_try_dequeue_request() local
155 wait_event(conn->req_running_q, atomic_read(&conn->req_running) < 2); in ksmbd_conn_wait_idle()
160 struct ksmbd_conn *conn = work->conn; in ksmbd_conn_write() local
193 sent = conn->transport->ops->writev(conn->transport, &iov[0], in ksmbd_conn_write()
214 ret = conn->transport->ops->rdma_read(conn->transport, in ksmbd_conn_rdma_read()
[all …]
/linux/drivers/gpu/drm/bridge/
A Ddisplay-connector.c45 if (conn->hpd_gpio) { in display_connector_detect()
52 if (conn->bridge.ddc && drm_probe_ddc(conn->bridge.ddc)) in display_connector_detect()
113 conn = devm_kzalloc(&pdev->dev, sizeof(*conn), GFP_KERNEL); in display_connector_probe()
114 if (!conn) in display_connector_probe()
193 conn->hpd_irq = gpiod_to_irq(conn->hpd_gpio); in display_connector_probe()
204 "HPD", conn); in display_connector_probe()
253 if (conn->dp_pwr) { in display_connector_probe()
265 if (conn->bridge.ddc) in display_connector_probe()
268 if (conn->hpd_gpio) in display_connector_probe()
279 conn->bridge.ops); in display_connector_probe()
[all …]
/linux/fs/notify/
A Dmark.c143 if (!conn) in fsnotify_recalc_mask()
166 free = conn; in fsnotify_connector_destroy_workfn()
167 conn = conn->destroy_next; in fsnotify_connector_destroy_workfn()
259 if (!conn) { in fsnotify_put_mark()
506 if (!conn) in fsnotify_attach_connector_to_object()
517 conn->fsid.val[0] = conn->fsid.val[1] = 0; in fsnotify_attach_connector_to_object()
555 if (!conn) in fsnotify_grab_connector()
565 return conn; in fsnotify_grab_connector()
617 conn->fsid.val[0], conn->fsid.val[1]); in fsnotify_add_mark_list()
732 if (!conn) in fsnotify_find_mark()
[all …]
/linux/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 …]
/linux/drivers/scsi/
A Dlibiscsi.c137 struct iscsi_conn *conn = task->conn; in iscsi_prep_data_out_pdu() local
304 struct iscsi_conn *conn = task->conn; in iscsi_prep_scsi_cmd_pdu() local
444 struct iscsi_conn *conn = task->conn; in iscsi_free_task() local
508 struct iscsi_conn *conn = task->conn; in iscsi_complete_task() local
542 struct iscsi_conn *conn = task->conn; in iscsi_complete_scsi_task() local
557 struct iscsi_conn *conn = task->conn; in cleanup_queued_task() local
595 struct iscsi_conn *conn = task->conn; in fail_scsi_task() local
725 task->conn = conn; in __iscsi_conn_send_pdu()
1002 struct iscsi_conn *conn = task->conn; in iscsi_nop_out_rsp() local
1499 struct iscsi_conn *conn = task->conn; in iscsi_requeue_task() local
[all …]
A Discsi_tcp.c127 struct iscsi_conn *conn; in iscsi_sw_tcp_data_ready() local
132 conn = sk->sk_user_data; in iscsi_sw_tcp_data_ready()
133 if (!conn) { in iscsi_sw_tcp_data_ready()
166 if (!conn) { in iscsi_sw_tcp_state_change()
195 if (!conn) { in iscsi_sw_tcp_write_space()
370 struct iscsi_conn *conn = task->conn; in iscsi_sw_tcp_pdu_xmit() local
422 ISCSI_SW_TCP_DBG(conn, "%s\n", conn->hdrdgst_en ? in iscsi_sw_tcp_send_hdr_prep()
466 conn->datadgst_en ? in iscsi_sw_tcp_send_data_prep()
491 ISCSI_SW_TCP_DBG(conn, "datalen=%zd %s\n", len, conn->datadgst_en ? in iscsi_sw_tcp_send_linear_data_prep()
509 struct iscsi_conn *conn = task->conn; in iscsi_sw_tcp_pdu_init() local
[all …]
/linux/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()
636 struct iucv_connection *conn = ev->conn; in conn_action_rx() local
666 netiucv_unpack_skb(conn, conn->rx_buff); in conn_action_rx()
672 struct iucv_connection *conn = ev->conn; in conn_action_txdone() local
687 if (!conn || !conn->netdev) { in conn_action_txdone()
739 conn->prof.txlen += conn->tx_buff->len; in conn_action_txdone()
772 struct iucv_connection *conn = ev->conn; in conn_action_connaccept() local
866 NULL, conn->userdata, conn); in conn_action_start()
[all …]

Completed in 897 milliseconds

12345678910>>...16