Lines Matching refs:conn
49 static void rds_ib_set_protocol(struct rds_connection *conn, unsigned int version) in rds_ib_set_protocol() argument
51 conn->c_version = version; in rds_ib_set_protocol()
57 static void rds_ib_set_flow_control(struct rds_connection *conn, u32 credits) in rds_ib_set_flow_control() argument
59 struct rds_ib_connection *ic = conn->c_transport_data; in rds_ib_set_flow_control()
64 rds_ib_send_add_credits(conn, credits); in rds_ib_set_flow_control()
74 void rds_ib_cm_connect_complete(struct rds_connection *conn, struct rdma_cm_event *event) in rds_ib_cm_connect_complete() argument
76 struct rds_ib_connection *ic = conn->c_transport_data; in rds_ib_cm_connect_complete()
84 dp = event->param.conn.private_data; in rds_ib_cm_connect_complete()
85 if (conn->c_isv6) { in rds_ib_cm_connect_complete()
86 if (event->param.conn.private_data_len >= in rds_ib_cm_connect_complete()
98 } else if (event->param.conn.private_data_len >= in rds_ib_cm_connect_complete()
108 rds_ib_set_protocol(conn, RDS_PROTOCOL(major, minor)); in rds_ib_cm_connect_complete()
109 rds_ib_set_flow_control(conn, be32_to_cpu(credit)); in rds_ib_cm_connect_complete()
112 if (conn->c_version < RDS_PROTOCOL_VERSION) { in rds_ib_cm_connect_complete()
113 if (conn->c_version != RDS_PROTOCOL_COMPAT_VERSION) { in rds_ib_cm_connect_complete()
115 &conn->c_laddr, &conn->c_faddr, in rds_ib_cm_connect_complete()
116 RDS_PROTOCOL_MAJOR(conn->c_version), in rds_ib_cm_connect_complete()
117 RDS_PROTOCOL_MINOR(conn->c_version)); in rds_ib_cm_connect_complete()
118 rds_conn_destroy(conn); in rds_ib_cm_connect_complete()
125 &conn->c_laddr, &conn->c_faddr, conn->c_tos, in rds_ib_cm_connect_complete()
126 RDS_PROTOCOL_MAJOR(conn->c_version), in rds_ib_cm_connect_complete()
127 RDS_PROTOCOL_MINOR(conn->c_version), in rds_ib_cm_connect_complete()
143 rds_ib_recv_refill(conn, 1, GFP_KERNEL); in rds_ib_cm_connect_complete()
146 err = rds_ib_update_ipaddr(ic->rds_ibdev, &conn->c_laddr); in rds_ib_cm_connect_complete()
155 rds_send_drop_acked(conn, be64_to_cpu(ack_seq), in rds_ib_cm_connect_complete()
159 conn->c_proposed_version = conn->c_version; in rds_ib_cm_connect_complete()
160 rds_connect_complete(conn); in rds_ib_cm_connect_complete()
163 static void rds_ib_cm_fill_conn_param(struct rds_connection *conn, in rds_ib_cm_fill_conn_param() argument
171 struct rds_ib_connection *ic = conn->c_transport_data; in rds_ib_cm_fill_conn_param()
186 dp->ricp_v6.dp_saddr = conn->c_laddr; in rds_ib_cm_fill_conn_param()
187 dp->ricp_v6.dp_daddr = conn->c_faddr; in rds_ib_cm_fill_conn_param()
196 dp->ricp_v6.dp_cmn.ricpc_dp_toss = conn->c_tos; in rds_ib_cm_fill_conn_param()
201 dp->ricp_v4.dp_saddr = conn->c_laddr.s6_addr32[3]; in rds_ib_cm_fill_conn_param()
202 dp->ricp_v4.dp_daddr = conn->c_faddr.s6_addr32[3]; in rds_ib_cm_fill_conn_param()
211 dp->ricp_v4.dp_cmn.ricpc_dp_toss = conn->c_tos; in rds_ib_cm_fill_conn_param()
249 struct rds_connection *conn = context; in rds_ib_cq_comp_handler_recv() local
250 struct rds_ib_connection *ic = conn->c_transport_data; in rds_ib_cq_comp_handler_recv()
252 rdsdebug("conn %p cq %p\n", conn, cq); in rds_ib_cq_comp_handler_recv()
285 struct rds_connection *conn = ic->conn; in rds_ib_tasklet_fn_send() local
297 if (rds_conn_up(conn) && in rds_ib_tasklet_fn_send()
298 (!test_bit(RDS_LL_SEND_FULL, &conn->c_flags) || in rds_ib_tasklet_fn_send()
299 test_bit(0, &conn->c_map_queued))) in rds_ib_tasklet_fn_send()
300 rds_send_xmit(&ic->conn->c_path[0]); in rds_ib_tasklet_fn_send()
325 struct rds_connection *conn = ic->conn; in rds_ib_tasklet_fn_recv() local
330 rds_conn_drop(conn); in rds_ib_tasklet_fn_recv()
346 rds_send_drop_acked(conn, state.ack_recv, NULL); in rds_ib_tasklet_fn_recv()
350 if (rds_conn_up(conn)) in rds_ib_tasklet_fn_recv()
356 struct rds_connection *conn = data; in rds_ib_qp_event_handler() local
357 struct rds_ib_connection *ic = conn->c_transport_data; in rds_ib_qp_event_handler()
359 rdsdebug("conn %p ic %p event %u (%s)\n", conn, ic, event->event, in rds_ib_qp_event_handler()
369 &conn->c_laddr, &conn->c_faddr); in rds_ib_qp_event_handler()
370 rds_conn_drop(conn); in rds_ib_qp_event_handler()
377 struct rds_connection *conn = context; in rds_ib_cq_comp_handler_send() local
378 struct rds_ib_connection *ic = conn->c_transport_data; in rds_ib_cq_comp_handler_send()
380 rdsdebug("conn %p cq %p\n", conn, cq); in rds_ib_cq_comp_handler_send()
502 static int rds_ib_setup_qp(struct rds_connection *conn) in rds_ib_setup_qp() argument
504 struct rds_ib_connection *ic = conn->c_transport_data; in rds_ib_setup_qp()
527 rds_ib_add_conn(rds_ibdev, conn); in rds_ib_setup_qp()
546 rds_ib_cq_event_handler, conn, in rds_ib_setup_qp()
560 rds_ib_cq_event_handler, conn, in rds_ib_setup_qp()
585 attr.qp_context = conn; in rds_ib_setup_qp()
652 rdsdebug("conn %p pd %p cq %p %p\n", conn, ic->i_pd, in rds_ib_setup_qp()
686 rds_ib_remove_conn(rds_ibdev, conn); in rds_ib_setup_qp()
695 const union rds_ib_conn_priv *dp = event->param.conn.private_data; in rds_ib_protocol_compatible()
712 if (!event->param.conn.private_data_len) { in rds_ib_protocol_compatible()
731 if (event->param.conn.private_data_len < data_len || major == 0) in rds_ib_protocol_compatible()
788 struct rds_connection *conn = NULL; in rds_ib_cm_handle_connect() local
809 dp = event->param.conn.private_data; in rds_ib_cm_handle_connect()
855 conn = rds_conn_create(&init_net, daddr6, saddr6, in rds_ib_cm_handle_connect()
858 if (IS_ERR(conn)) { in rds_ib_cm_handle_connect()
859 rdsdebug("rds_conn_create failed (%ld)\n", PTR_ERR(conn)); in rds_ib_cm_handle_connect()
860 conn = NULL; in rds_ib_cm_handle_connect()
871 mutex_lock(&conn->c_cm_lock); in rds_ib_cm_handle_connect()
872 if (!rds_conn_transition(conn, RDS_CONN_DOWN, RDS_CONN_CONNECTING)) { in rds_ib_cm_handle_connect()
873 if (rds_conn_state(conn) == RDS_CONN_UP) { in rds_ib_cm_handle_connect()
875 rds_conn_drop(conn); in rds_ib_cm_handle_connect()
878 if (rds_conn_state(conn) == RDS_CONN_CONNECTING) { in rds_ib_cm_handle_connect()
885 ic = conn->c_transport_data; in rds_ib_cm_handle_connect()
887 rds_ib_set_protocol(conn, version); in rds_ib_cm_handle_connect()
888 rds_ib_set_flow_control(conn, be32_to_cpu(dp_cmn->ricpc_credit)); in rds_ib_cm_handle_connect()
893 rds_send_drop_acked(conn, be64_to_cpu(dp_cmn->ricpc_ack_seq), in rds_ib_cm_handle_connect()
900 cm_id->context = conn; in rds_ib_cm_handle_connect()
906 err = rds_ib_setup_qp(conn); in rds_ib_cm_handle_connect()
908 rds_ib_conn_error(conn, "rds_ib_setup_qp failed (%d)\n", err); in rds_ib_cm_handle_connect()
912 rds_ib_cm_fill_conn_param(conn, &conn_param, &dp_rep, version, in rds_ib_cm_handle_connect()
913 event->param.conn.responder_resources, in rds_ib_cm_handle_connect()
914 event->param.conn.initiator_depth, isv6); in rds_ib_cm_handle_connect()
919 rds_ib_conn_error(conn, "rdma_accept failed\n"); in rds_ib_cm_handle_connect()
922 if (conn) in rds_ib_cm_handle_connect()
923 mutex_unlock(&conn->c_cm_lock); in rds_ib_cm_handle_connect()
933 struct rds_connection *conn = cm_id->context; in rds_ib_cm_initiate_connect() local
934 struct rds_ib_connection *ic = conn->c_transport_data; in rds_ib_cm_initiate_connect()
941 rds_ib_set_protocol(conn, RDS_PROTOCOL_4_1); in rds_ib_cm_initiate_connect()
944 ret = rds_ib_setup_qp(conn); in rds_ib_cm_initiate_connect()
946 rds_ib_conn_error(conn, "rds_ib_setup_qp failed (%d)\n", ret); in rds_ib_cm_initiate_connect()
950 rds_ib_cm_fill_conn_param(conn, &conn_param, &dp, in rds_ib_cm_initiate_connect()
951 conn->c_proposed_version, in rds_ib_cm_initiate_connect()
955 rds_ib_conn_error(conn, "rdma_connect_locked failed (%d)\n", in rds_ib_cm_initiate_connect()
972 struct rds_connection *conn = cp->cp_conn; in rds_ib_conn_path_connect() local
978 ic = conn->c_transport_data; in rds_ib_conn_path_connect()
983 if (conn->c_isv6) in rds_ib_conn_path_connect()
988 ic->i_cm_id = rdma_create_id(&init_net, handler, conn, in rds_ib_conn_path_connect()
997 rdsdebug("created cm id %p for conn %p\n", ic->i_cm_id, conn); in rds_ib_conn_path_connect()
999 if (ipv6_addr_v4mapped(&conn->c_faddr)) { in rds_ib_conn_path_connect()
1004 sin->sin_addr.s_addr = conn->c_laddr.s6_addr32[3]; in rds_ib_conn_path_connect()
1009 sin->sin_addr.s_addr = conn->c_faddr.s6_addr32[3]; in rds_ib_conn_path_connect()
1016 sin6->sin6_addr = conn->c_laddr; in rds_ib_conn_path_connect()
1018 sin6->sin6_scope_id = conn->c_dev_if; in rds_ib_conn_path_connect()
1022 sin6->sin6_addr = conn->c_faddr; in rds_ib_conn_path_connect()
1024 sin6->sin6_scope_id = conn->c_dev_if; in rds_ib_conn_path_connect()
1048 struct rds_connection *conn = cp->cp_conn; in rds_ib_conn_path_shutdown() local
1049 struct rds_ib_connection *ic = conn->c_transport_data; in rds_ib_conn_path_shutdown()
1152 rds_ib_remove_conn(ic->rds_ibdev, conn); in rds_ib_conn_path_shutdown()
1199 int rds_ib_conn_alloc(struct rds_connection *conn, gfp_t gfp) in rds_ib_conn_alloc() argument
1235 ic->conn = conn; in rds_ib_conn_alloc()
1236 conn->c_transport_data = ic; in rds_ib_conn_alloc()
1243 rdsdebug("conn %p conn ic %p\n", conn, conn->c_transport_data); in rds_ib_conn_alloc()
1278 __rds_ib_conn_error(struct rds_connection *conn, const char *fmt, ...) in __rds_ib_conn_error() argument
1282 rds_conn_drop(conn); in __rds_ib_conn_error()