Home
last modified time | relevance | path

Searched refs:cp_conn (Results 1 – 16 of 16) sorted by relevance

/Linux-v4.19/net/rds/
Dthreads.c86 cp->cp_conn, &cp->cp_conn->c_laddr, &cp->cp_conn->c_faddr); in rds_connect_path_complete()
89 set_bit(0, &cp->cp_conn->c_map_queued); in rds_connect_path_complete()
91 if (!rds_destroy_pending(cp->cp_conn)) { in rds_connect_path_complete()
126 struct rds_connection *conn = cp->cp_conn; in rds_queue_reconnect()
141 if (!rds_destroy_pending(cp->cp_conn)) in rds_queue_reconnect()
152 if (!rds_destroy_pending(cp->cp_conn)) in rds_queue_reconnect()
166 struct rds_connection *conn = cp->cp_conn; in rds_connect_worker()
170 rds_addr_cmp(&cp->cp_conn->c_laddr, &cp->cp_conn->c_faddr) >= 0) in rds_connect_worker()
201 rdsdebug("conn %p ret %d\n", cp->cp_conn, ret); in rds_send_worker()
224 ret = cp->cp_conn->c_trans->recv_path(cp); in rds_recv_worker()
[all …]
Dtcp_connect.c69 if (rds_addr_cmp(&cp->cp_conn->c_laddr, in rds_tcp_state_change()
70 &cp->cp_conn->c_faddr) >= 0 && in rds_tcp_state_change()
98 struct rds_connection *conn = cp->cp_conn; in rds_tcp_conn_path_connect()
104 if (cp->cp_index > 0 && cp->cp_conn->c_npaths < 2) in rds_tcp_conn_path_connect()
206 cp->cp_conn, tc, sock); in rds_tcp_conn_path_shutdown()
209 if (rds_destroy_pending(cp->cp_conn)) in rds_tcp_conn_path_shutdown()
Dtcp.c125 if (!tc->t_cpath->cp_conn->c_isv6) in rds_tcp_restore_callbacks()
216 if (!tc->t_cpath->cp_conn->c_isv6) in rds_tcp_set_callbacks()
257 if (tc->t_cpath->cp_conn->c_isv6) in rds_tcp_tc_info()
420 if (tc->t_cpath->cp_conn == conn) in list_has_conn()
444 if (!list_has_conn(&tmp_list, tc->t_cpath->cp_conn)) in rds_tcp_destroy_conns()
450 rds_conn_destroy(tc->t_cpath->cp_conn); in rds_tcp_destroy_conns()
601 struct net *c_net = read_pnet(&tc->t_cpath->cp_conn->c_net); in rds_tcp_kill_sock()
605 if (!list_has_conn(&tmp_list, tc->t_cpath->cp_conn)) { in rds_tcp_kill_sock()
614 rds_conn_destroy(tc->t_cpath->cp_conn); in rds_tcp_kill_sock()
659 struct net *c_net = read_pnet(&tc->t_cpath->cp_conn->c_net); in rds_tcp_sysctl_reset()
Dconnection.c114 struct rds_connection *conn = cp->cp_conn; in rds_conn_path_reset()
138 cp->cp_conn = conn; in __rds_conn_path_init()
354 struct rds_connection *conn = cp->cp_conn; in rds_conn_shutdown()
456 cp->cp_conn->c_trans->conn_free(cp->cp_transport_data); in rds_conn_path_destroy()
727 struct rds_connection *conn = cp->cp_conn; in rds_conn_info_visitor()
756 struct rds_connection *conn = cp->cp_conn; in rds6_conn_info_visitor()
870 if (!destroy && rds_destroy_pending(cp->cp_conn)) { in rds_conn_path_drop()
893 if (rds_destroy_pending(cp->cp_conn)) { in rds_conn_path_connect_if_down()
Dsend.c88 cp->cp_conn->c_map_queued = 0; in rds_send_path_reset()
139 struct rds_connection *conn = cp->cp_conn; in rds_send_xmit()
165 if (rds_destroy_pending(cp->cp_conn)) { in rds_send_xmit()
215 rm->m_inc.i_conn = cp->cp_conn; in rds_send_xmit()
447 if (rds_destroy_pending(cp->cp_conn)) in rds_send_xmit()
1342 if (rds_destroy_pending(cpath->cp_conn)) in rds_sendmsg()
1387 rm->m_daddr = cp->cp_conn->c_faddr; in rds_send_probe()
1392 ret = rds_cong_wait(cp->cp_conn->c_fcong, dport, 1, NULL); in rds_send_probe()
1400 rm->m_inc.i_conn = cp->cp_conn; in rds_send_probe()
1409 cp->cp_conn->c_trans->t_mp_capable) { in rds_send_probe()
[all …]
Dtcp_recv.c182 &cp->cp_conn->c_faddr); in rds_tcp_data_recv()
237 struct rds_connection *conn = cp->cp_conn; in rds_tcp_data_recv()
327 if (!rds_destroy_pending(cp->cp_conn)) in rds_tcp_data_ready()
Drecv.c66 inc->i_conn = cp->cp_conn; in rds_inc_path_init()
352 rds_recv_hs_exthdrs(&inc->i_hdr, cp->cp_conn); in rds_recv_incoming()
353 rds_start_mprds(cp->cp_conn); in rds_recv_incoming()
360 rds_recv_hs_exthdrs(&inc->i_hdr, cp->cp_conn); in rds_recv_incoming()
362 rds_start_mprds(cp->cp_conn); in rds_recv_incoming()
363 wake_up(&cp->cp_conn->c_hs_waitq); in rds_recv_incoming()
Dloop.c169 rds_connect_complete(cp->cp_conn); in rds_loop_conn_path_connect()
Dtcp_send.c207 !rds_destroy_pending(cp->cp_conn)) in rds_tcp_write_space()
Dtcp_listen.c235 rds_send_ping(cp->cp_conn, cp->cp_index); in rds_tcp_accept_one()
Dcong.c229 !rds_destroy_pending(cp->cp_conn)) { in rds_cong_queue_updates()
Dib_cm.c893 struct rds_connection *conn = cp->cp_conn; in rds_ib_conn_path_connect()
969 struct rds_connection *conn = cp->cp_conn; in rds_ib_conn_path_shutdown()
Drdma.c274 cp ? cp->cp_conn : NULL); in __rds_rdma_map()
Drds.h105 struct rds_connection *cp_conn; member
Dib_recv.c1022 struct rds_connection *conn = cp->cp_conn; in rds_ib_recv_path()
Dib_send.c986 struct rds_connection *conn = cp->cp_conn; in rds_ib_xmit_path_complete()