cp->cp_reconnect_drops = 0;
cp->cp_reconnect_err = 0;
cp->cp_conn->c_proposed_version = RDS_PROTOCOL_VERSION;
- cp->cp_route_resolved = 1;
INIT_DELAYED_WORK(&cp->cp_send_w, rds_send_worker);
INIT_DELAYED_WORK(&cp->cp_recv_w, rds_recv_worker);
INIT_DELAYED_WORK(&cp->cp_conn_w, rds_connect_worker);
struct ib_qp_attr qp_attr;
int err;
- if (conn->c_route_resolved == 0)
- conn->c_route_resolved = 1;
if (event->param.conn.private_data_len >= sizeof(*dp)) {
dp = event->param.conn.private_data;
return;
}
- /* Drop connection if connection state is not CONNECTING.
- Potentially connection drop from some other place like rds_conn_probe_lanes() */
- if (!rds_conn_connecting(conn)) {
- rds_rtd(RDS_RTD_CM,
- "conn is in connecting state, conn: %p, calling rds_conn_drop\n",
- conn);
- rds_conn_drop(conn, DR_IB_NOT_CONNECTING_STATE);
- return;
- }
-
ic->i_sl = ic->i_cm_id->route.path_rec->sl;
atomic_set(&ic->i_cq_quiesce, 0);
struct sockaddr_in src, dest;
int ret;
- conn->c_route_resolved = 0;
/* XXX I wonder what affect the port space has */
/* delegate cm event handler to rdma_transport */
ic->i_cm_id = rdma_create_id(rds_rdma_cm_event_handler, conn,
unsigned int cp_rdsinfo_pending;
unsigned int cp_reconnect_racing;
- unsigned int cp_route_resolved;
enum rds_conn_drop_src cp_drop_source;
#define c_base_conn c_path[0].cp_base_conn
#define c_acl_en c_path[0].cp_acl_en
#define c_reconnect_err c_path[0].cp_reconnect_err
-#define c_route_resolved c_path[0].cp_route_resolved
#define c_reject_w c_path[0].cp_reject_w
#endif /* _RDS_RDS_SINGLE_H */