Home
last modified time | relevance | path

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

/linux/net/rds/
H A 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()
96 cp->cp_conn->c_proposed_version = RDS_PROTOCOL_VERSION; in rds_connect_path_complete()
127 struct rds_connection *conn = cp->cp_conn; in rds_queue_reconnect()
142 if (!rds_destroy_pending(cp->cp_conn)) in rds_queue_reconnect()
153 if (!rds_destroy_pending(cp->cp_conn)) in rds_queue_reconnect()
167 struct rds_connection *conn = cp->cp_conn; in rds_connect_worker()
[all...]
H A 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()
109 struct rds_connection *conn = cp->cp_conn; in rds_tcp_conn_path_connect()
115 if (cp->cp_index > 0 && cp->cp_conn->c_npaths < 2) in rds_tcp_conn_path_connect()
241 cp->cp_conn, tc, sock);
245 if (rds_destroy_pending(cp->cp_conn))
H A Dtcp.c281 if (tc->t_cpath->cp_conn->c_isv6) in rds_tcp_tc_info()
283 if (!net_eq(rds_conn_net(tc->t_cpath->cp_conn), net)) in rds_tcp_tc_info()
296 if (tc->t_cpath->cp_conn->c_isv6) in rds_tcp_tc_info()
299 if (!net_eq(rds_conn_net(tc->t_cpath->cp_conn), net)) in rds_tcp_tc_info()
312 tsinfo.tos = tc->t_cpath->cp_conn->c_tos; in rds_tcp_tc_info()
346 if (!net_eq(rds_conn_net(tc->t_cpath->cp_conn), net)) in rds6_tcp_tc_info()
361 if (!net_eq(rds_conn_net(tc->t_cpath->cp_conn), net)) in rds6_tcp_tc_info()
489 if (tc->t_cpath->cp_conn == conn) in list_has_conn()
513 if (!list_has_conn(&tmp_list, tc->t_cpath->cp_conn)) in rds_tcp_destroy_conns()
519 rds_conn_destroy(tc->t_cpath->cp_conn); in rds_tcp_destroy_conns()
[all …]
H A Dconnection.c118 struct rds_connection *conn = cp->cp_conn; in rds_conn_path_reset()
151 cp->cp_conn = conn; in __rds_conn_path_init()
155 cp->cp_conn->c_proposed_version = RDS_PROTOCOL_VERSION; in __rds_conn_path_init()
400 struct rds_connection *conn = cp->cp_conn; in rds_conn_shutdown()
562 cp->cp_conn->c_trans->conn_free(cp->cp_transport_data); in rds_conn_path_destroy()
860 struct rds_connection *conn = cp->cp_conn; in rds_conn_info_visitor()
889 struct rds_connection *conn = cp->cp_conn; in rds6_conn_info_visitor()
1000 if (!destroy && rds_destroy_pending(cp->cp_conn)) { in rds_conn_path_drop()
1023 if (rds_destroy_pending(cp->cp_conn)) { in rds_conn_path_connect_if_down()
H A Dsend.c88 cp->cp_conn->c_map_queued = 0; in rds_send_path_reset()
194 struct rds_connection *conn = cp->cp_conn; in rds_send_xmit()
229 if (rds_destroy_pending(cp->cp_conn)) { in rds_send_xmit()
293 rm->m_inc.i_conn = cp->cp_conn; in rds_send_xmit()
545 if (rds_destroy_pending(cp->cp_conn)) in rds_send_xmit()
1456 if (rds_destroy_pending(cpath->cp_conn)) in rds_sendmsg()
1512 rm->m_daddr = cp->cp_conn->c_faddr; in rds_send_probe()
1517 ret = rds_cong_wait(cp->cp_conn->c_fcong, dport, 1, NULL); in rds_send_probe()
1525 rm->m_inc.i_conn = cp->cp_conn; in rds_send_probe()
1534 cp->cp_conn->c_trans->t_mp_capable) { in rds_send_probe()
[all …]
H A Dtcp_recv.c183 &cp->cp_conn->c_faddr); in rds_tcp_data_recv()
238 struct rds_connection *conn = cp->cp_conn; in rds_tcp_data_recv()
333 if (!rds_destroy_pending(cp->cp_conn)) in rds_tcp_data_ready()
H A Drecv.c64 inc->i_conn = cp->cp_conn; in rds_inc_path_init()
384 rds_recv_hs_exthdrs(&inc->i_hdr, cp->cp_conn); in rds_recv_incoming()
385 rds_start_mprds(cp->cp_conn); in rds_recv_incoming()
392 rds_recv_hs_exthdrs(&inc->i_hdr, cp->cp_conn); in rds_recv_incoming()
394 rds_start_mprds(cp->cp_conn); in rds_recv_incoming()
395 wake_up(&cp->cp_conn->c_hs_waitq); in rds_recv_incoming()
H A Dloop.c173 rds_connect_complete(cp->cp_conn); in rds_loop_conn_path_connect()
H A Dtcp_send.c203 !rds_destroy_pending(cp->cp_conn)) in rds_tcp_write_space()
H A Dcong.c229 !rds_destroy_pending(cp->cp_conn)) { in rds_cong_queue_updates()
H A Dib_cm.c977 struct rds_connection *conn = cp->cp_conn; in rds_ib_conn_path_connect()
1048 struct rds_connection *conn = cp->cp_conn; in rds_ib_conn_path_shutdown_check_wait()
1066 struct rds_connection *conn = cp->cp_conn; in rds_ib_conn_path_shutdown()
H A Dtcp_listen.c329 rds_send_ping(cp->cp_conn, cp->cp_index); in rds_tcp_accept_one()
H A Drdma.c296 sg, nents, rs, &mr->r_key, cp ? cp->cp_conn : NULL, in __rds_rdma_map()
311 rds_conn_connect_if_down(cp->cp_conn); in __rds_rdma_map()
H A Drds.h103 struct rds_connection *cp_conn; member
H A Dib_recv.c1045 struct rds_connection *conn = cp->cp_conn; in rds_ib_recv_path()
H A Dib_send.c1039 struct rds_connection *conn = cp->cp_conn;