| /openbmc/qemu/nbd/ |
| H A D | client-connection.c | 104 return conn; in nbd_client_connection_new()
109 if (conn->sioc) { in nbd_client_connection_do_free()
119 g_free(conn); in nbd_client_connection_do_free()
188 conn->updated_info = conn->initial_info; in connect_thread_func()
190 ret = nbd_connect(conn->sioc, conn->saddr, in connect_thread_func()
191 conn->do_negotiation ? &conn->updated_info : NULL, in connect_thread_func()
192 conn->tlscreds, conn->tlshostname, in connect_thread_func()
213 if (conn->do_retry && !conn->detached) { in connect_thread_func()
234 if (conn->wait_co) { in connect_thread_func()
253 if (!conn) { in nbd_client_connection_release()
[all …]
|
| /openbmc/linux/net/smc/ |
| H A D | smc_cdc.c | 30 struct smc_connection *conn = cdcpend->conn; in smc_cdc_tx_handler() local
36 smc = container_of(conn, struct smc_sock, conn); in smc_cdc_tx_handler()
105 pend->conn = conn; in smc_cdc_add_pending_send()
122 conn->local_tx_ctrl.seqno = conn->tx_cdc_seq; in smc_cdc_msg_send()
266 smc_curs_copy(&conn->tx_curs_fin, &conn->tx_curs_sent, conn); in smcd_cdc_msg_send()
282 struct smc_connection *conn = &smc->conn; in smc_cdc_handle_urg_data_arrival() local
286 smc_curs_copy(&conn->urg_curs, &conn->local_rx_ctrl.prod, conn); in smc_cdc_handle_urg_data_arrival()
302 struct smc_connection *conn = &smc->conn; in smc_cdc_msg_validate() local
325 struct smc_connection *conn = &smc->conn; in smc_cdc_msg_recv_action() local
417 if (!conn || conn->killed) in smcd_cdc_rx_tsklet()
[all …]
|
| H A D | smc_tx.c | 80 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 D | smc_rx.c | 62 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 …]
|
| /openbmc/linux/fs/smb/server/ |
| H A D | connection.c | 43 kfree(conn); in ksmbd_conn_free()
56 if (!conn) in ksmbd_conn_alloc()
69 conn->um = NULL; in ksmbd_conn_alloc()
95 return conn; in ksmbd_conn_alloc()
117 struct ksmbd_conn *conn = work->conn; in ksmbd_conn_enqueue_request() local
133 struct ksmbd_conn *conn = work->conn; in ksmbd_conn_try_dequeue_request() local
165 if (conn->binding || xa_load(&conn->sessions, sess_id)) in ksmbd_all_conn_set_status()
188 if (conn->binding || xa_load(&conn->sessions, sess_id)) { in ksmbd_conn_wait_idle_sess_id()
210 struct ksmbd_conn *conn = work->conn; in ksmbd_conn_write() local
248 ret = conn->transport->ops->rdma_read(conn->transport, in ksmbd_conn_rdma_read()
[all …]
|
| H A D | connection.h | 114 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);
206 WRITE_ONCE(conn->status, KSMBD_SESS_NEW); in ksmbd_conn_set_new()
211 WRITE_ONCE(conn->status, KSMBD_SESS_GOOD); in ksmbd_conn_set_good()
226 WRITE_ONCE(conn->status, KSMBD_SESS_EXITING); in ksmbd_conn_set_exiting()
[all …]
|
| /openbmc/linux/net/rxrpc/ |
| H A D | conn_object.c | 63 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()
136 return conn; in rxrpc_find_client_connection_rcu()
190 struct rxrpc_connection *conn = call->conn; in rxrpc_disconnect_call() local
233 if (conn) { in rxrpc_see_connection()
262 if (conn) { in rxrpc_get_connection_maybe()
327 conn->security->clear(conn); in rxrpc_clean_up_connection()
352 if (!conn) in rxrpc_put_connection()
[all …]
|
| H A D | conn_event.c | 32 conn->error = err; in rxrpc_set_conn_aborted()
33 conn->completion = compl; in rxrpc_set_conn_aborted()
201 _enter("{%d},%x", conn->debug_id, conn->abort_code); in rxrpc_abort_calls()
207 conn->completion, in rxrpc_abort_calls()
208 conn->abort_code, in rxrpc_abort_calls()
209 conn->error); in rxrpc_abort_calls()
243 return conn->security->respond_to_challenge(conn, skb); in rxrpc_process_event()
246 ret = conn->security->verify_response(conn, skb); in rxrpc_process_event()
251 conn, conn->key->payload.data[0]); in rxrpc_process_event()
283 if (conn->security->issue_challenge(conn) < 0) in rxrpc_secure_connection()
[all …]
|
| H A D | conn_service.c | 51 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 …]
|
| H A D | conn_client.c | 62 conn, refcount_read(&conn->ref)); in rxrpc_destroy_client_conn_ids()
155 if (!conn) in rxrpc_alloc_client_connection()
161 kfree(conn); in rxrpc_alloc_client_connection()
179 conn->service_id = conn->orig_service_id; in rxrpc_alloc_client_connection()
193 return conn; in rxrpc_alloc_client_connection()
204 if (!conn) in rxrpc_may_reuse_conn()
483 if (!conn) in rxrpc_activate_channels()
525 struct rxrpc_connection *conn = call->conn; in rxrpc_expose_client_call() local
576 conn = call->conn; in rxrpc_disconnect_client_call()
577 if (!conn) { in rxrpc_disconnect_client_call()
[all …]
|
| /openbmc/linux/drivers/target/iscsi/ |
| H A D | iscsi_target_login.c | 48 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()
924 rc = conn->sock->ops->getname(conn->sock, in iscsit_accept_np()
938 rc = conn->sock->ops->getname(conn->sock, in iscsit_accept_np()
954 rc = conn->sock->ops->getname(conn->sock, in iscsit_accept_np()
959 rc = conn->sock->ops->getname(conn->sock, in iscsit_accept_np()
1047 if (!conn) { in iscsit_alloc_conn()
1189 conn->conn_transport->iscsit_wait_conn(conn); in iscsi_target_login_sess_out()
1192 conn->conn_transport->iscsit_free_conn(conn); in iscsi_target_login_sess_out()
[all …]
|
| H A D | iscsi_target_util.c | 173 cmd->conn = conn; in iscsit_allocate_cmd()
338 struct iscsit_conn *conn = cmd->conn; in iscsit_check_unsolicited_dataout() local
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()
1055 conn->login_kworker->comm, conn->login_kworker->pid); in iscsit_login_timeout()
1180 tx_sent = conn->sock->ops->sendmsg(conn->sock, &msghdr, in iscsit_fe_sendpage_sg()
1278 if (!conn || !conn->sock || !conn->conn_ops) in rx_data()
1308 if (!conn || !conn->sock || !conn->conn_ops) in tx_data()
[all …]
|
| H A D | iscsi_target_nego.c | 356 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 D | iscsi_target_erl0.c | 34 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 D | iscsi_target.c | 843 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
2386 " for SID: %u.\n", conn->cid, conn->sess->sid); in iscsit_logout_closesession()
2640 struct iscsit_conn *conn = cmd->conn; in iscsit_handle_immediate_data() local
3130 conn->conn_transport->iscsit_get_r2t_ttt(conn, cmd, r2t); in iscsit_send_r2t()
3382 struct iscsit_conn *conn = cmd->conn; in iscsit_build_sendtargets_response() local
3836 cmd, conn); in iscsit_response_queue()
4190 conn->conn_transport->iscsit_get_rx_pdu(conn); in iscsi_target_rx_thread()
4330 conn->conn_transport->iscsit_wait_conn(conn); in iscsit_close_connection()
[all …]
|
| /openbmc/linux/net/bluetooth/ |
| H A D | hci_conn.c | 145 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()
551 hci_setup_sync(link->conn, conn->handle); in hci_sco_setup()
553 hci_add_sco(link->conn, conn->handle); in hci_sco_setup()
1636 link->conn = hci_conn_hold(conn); in hci_conn_link()
2159 conn->le_tx_phy ? conn->le_tx_phy : in hci_bind_bis()
2662 chan->conn = hci_conn_get(conn); in hci_chan_create()
[all …]
|
| H A D | hci_sysfs.c | 16 kfree(conn); in bt_link_release()
36 struct hci_dev *hdev = conn->hdev; in hci_conn_init_sysfs()
38 bt_dev_dbg(hdev, "conn %p", conn); in hci_conn_init_sysfs()
40 conn->dev.type = &bt_link; in hci_conn_init_sysfs()
41 conn->dev.class = &bt_class; in hci_conn_init_sysfs()
42 conn->dev.parent = &hdev->dev; in hci_conn_init_sysfs()
44 device_initialize(&conn->dev); in hci_conn_init_sysfs()
56 dev_set_name(&conn->dev, "%s:%d", hdev->name, conn->handle); in hci_conn_add_sysfs()
58 if (device_add(&conn->dev) < 0) in hci_conn_add_sysfs()
72 put_device(&conn->dev); in hci_conn_del_sysfs()
[all …]
|
| /openbmc/linux/drivers/net/ethernet/mellanox/mlx5/core/fpga/ |
| H A D | conn.c | 110 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 …]
|
| /openbmc/linux/fs/notify/ |
| H A D | mark.c | 207 if (!conn) in fsnotify_recalc_mask()
236 free = conn; in fsnotify_connector_destroy_workfn()
237 conn = conn->destroy_next; in fsnotify_connector_destroy_workfn()
327 if (!conn) { in fsnotify_put_mark()
572 if (!conn) in fsnotify_attach_connector_to_object()
584 conn->fsid.val[0] = conn->fsid.val[1] = 0; in fsnotify_attach_connector_to_object()
616 if (!conn) in fsnotify_grab_connector()
626 return conn; in fsnotify_grab_connector()
680 conn->fsid.val[0], conn->fsid.val[1]); in fsnotify_add_mark_list()
795 if (!conn) in fsnotify_find_mark()
[all …]
|
| /openbmc/linux/drivers/gpu/drm/bridge/ |
| H A D | display-connector.c | 47 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()
289 conn->hpd_irq = gpiod_to_irq(conn->hpd_gpio); in display_connector_probe()
300 "HPD", conn); in display_connector_probe()
352 if (conn->supply) { in display_connector_probe()
366 if (conn->hpd_gpio) in display_connector_probe()
377 conn->bridge.ops); in display_connector_probe()
388 if (conn->ddc_en) in display_connector_remove()
[all …]
|
| /openbmc/linux/net/rds/ |
| H A D | connection.c | 98 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 …]
|
| /openbmc/openbmc-tools/netboot/ |
| H A D | netboot | 26 conn.write(bytes(c, "ascii"))
31 conn = Telnet(host, port, timeout)
32 conn.encode_and_write = MethodType(encode_and_write, conn)
33 conn.expect_or_raise = MethodType(expect_or_raise, conn)
34 return conn
64 conn.encode_and_write()
65 i, m, d = conn.expect_or_raise(
86 conn.encode_and_write()
106 conn.encode_and_write(
110 conn.read_until(b"ast#")
[all …]
|
| /openbmc/linux/drivers/scsi/ |
| H A D | libiscsi.c | 149 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 …]
|
| /openbmc/linux/drivers/s390/net/ |
| H A D | netiucv.c | 484 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 …]
|
| /openbmc/qemu/hw/hyperv/ |
| H A D | hyperv_testdev.c | 119 assert(!hyperv_post_msg(conn->sint_route, &conn->msg)); in msg_retry()
147 ret = hyperv_post_msg(conn->sint_route, &conn->msg); in msg_handler()
162 TestMsgConn *conn; in msg_conn_create() local
165 assert(conn); in msg_conn_create()
169 conn->sint_route = hyperv_sint_route_new(vp_index, sint, msg_cb, conn); in msg_conn_create()
172 assert(!hyperv_set_msg_handler(conn->conn_id, msg_handler, conn)); in msg_conn_create()
179 TestMsgConn *conn; in msg_conn_destroy() local
200 assert(!hyperv_set_event_flag(conn->sint_route, conn->conn_id)); in evt_conn_handler()
206 TestEvtConn *conn; in evt_conn_create() local
209 assert(conn); in evt_conn_create()
[all …]
|