Lines Matching defs:req_msg
997 static void cm_format_req(struct cm_req_msg *req_msg,
1004 cm_format_mad_hdr(&req_msg->hdr, CM_REQ_ATTR_ID,
1007 req_msg->local_comm_id = cm_id_priv->id.local_id;
1008 req_msg->service_id = param->service_id;
1009 req_msg->local_ca_guid = cm_id_priv->id.device->node_guid;
1010 cm_req_set_local_qpn(req_msg, cpu_to_be32(param->qp_num));
1011 cm_req_set_resp_res(req_msg, param->responder_resources);
1012 cm_req_set_init_depth(req_msg, param->initiator_depth);
1013 cm_req_set_remote_resp_timeout(req_msg,
1015 cm_req_set_qp_type(req_msg, param->qp_type);
1016 cm_req_set_flow_ctrl(req_msg, param->flow_control);
1017 cm_req_set_starting_psn(req_msg, cpu_to_be32(param->starting_psn));
1018 cm_req_set_local_resp_timeout(req_msg,
1020 cm_req_set_retry_count(req_msg, param->retry_count);
1021 req_msg->pkey = param->primary_path->pkey;
1022 cm_req_set_path_mtu(req_msg, param->primary_path->mtu);
1023 cm_req_set_rnr_retry_count(req_msg, param->rnr_retry_count);
1024 cm_req_set_max_cm_retries(req_msg, param->max_cm_retries);
1025 cm_req_set_srq(req_msg, param->srq);
1028 req_msg->primary_local_lid = pri_path->slid;
1029 req_msg->primary_remote_lid = pri_path->dlid;
1031 req_msg->primary_local_lid = IB_LID_PERMISSIVE;
1032 req_msg->primary_remote_lid = IB_LID_PERMISSIVE;
1034 req_msg->primary_local_gid = pri_path->sgid;
1035 req_msg->primary_remote_gid = pri_path->dgid;
1036 cm_req_set_primary_flow_label(req_msg, pri_path->flow_label);
1037 cm_req_set_primary_packet_rate(req_msg, pri_path->rate);
1038 req_msg->primary_traffic_class = pri_path->traffic_class;
1039 req_msg->primary_hop_limit = pri_path->hop_limit;
1040 cm_req_set_primary_sl(req_msg, pri_path->sl);
1041 cm_req_set_primary_subnet_local(req_msg, (pri_path->hop_limit <= 1));
1042 cm_req_set_primary_local_ack_timeout(req_msg,
1048 req_msg->alt_local_lid = alt_path->slid;
1049 req_msg->alt_remote_lid = alt_path->dlid;
1051 req_msg->alt_local_lid = IB_LID_PERMISSIVE;
1052 req_msg->alt_remote_lid = IB_LID_PERMISSIVE;
1054 req_msg->alt_local_gid = alt_path->sgid;
1055 req_msg->alt_remote_gid = alt_path->dgid;
1056 cm_req_set_alt_flow_label(req_msg,
1058 cm_req_set_alt_packet_rate(req_msg, alt_path->rate);
1059 req_msg->alt_traffic_class = alt_path->traffic_class;
1060 req_msg->alt_hop_limit = alt_path->hop_limit;
1061 cm_req_set_alt_sl(req_msg, alt_path->sl);
1062 cm_req_set_alt_subnet_local(req_msg, (alt_path->hop_limit <= 1));
1063 cm_req_set_alt_local_ack_timeout(req_msg,
1069 memcpy(req_msg->private_data, param->private_data,
1101 struct cm_req_msg *req_msg;
1153 req_msg = (struct cm_req_msg *) cm_id_priv->msg->mad;
1154 cm_format_req(req_msg, cm_id_priv, param);
1155 cm_id_priv->tid = req_msg->hdr.tid;
1159 cm_id_priv->local_qpn = cm_req_get_local_qpn(req_msg);
1160 cm_id_priv->rq_psn = cm_req_get_starting_psn(req_msg);
1223 static void cm_format_paths_from_req(struct cm_req_msg *req_msg,
1228 primary_path->dgid = req_msg->primary_local_gid;
1229 primary_path->sgid = req_msg->primary_remote_gid;
1230 primary_path->dlid = req_msg->primary_local_lid;
1231 primary_path->slid = req_msg->primary_remote_lid;
1232 primary_path->flow_label = cm_req_get_primary_flow_label(req_msg);
1233 primary_path->hop_limit = req_msg->primary_hop_limit;
1234 primary_path->traffic_class = req_msg->primary_traffic_class;
1236 primary_path->pkey = req_msg->pkey;
1237 primary_path->sl = cm_req_get_primary_sl(req_msg);
1239 primary_path->mtu = cm_req_get_path_mtu(req_msg);
1241 primary_path->rate = cm_req_get_primary_packet_rate(req_msg);
1244 cm_req_get_primary_local_ack_timeout(req_msg);
1247 if (req_msg->alt_local_lid) {
1249 alt_path->dgid = req_msg->alt_local_gid;
1250 alt_path->sgid = req_msg->alt_remote_gid;
1251 alt_path->dlid = req_msg->alt_local_lid;
1252 alt_path->slid = req_msg->alt_remote_lid;
1253 alt_path->flow_label = cm_req_get_alt_flow_label(req_msg);
1254 alt_path->hop_limit = req_msg->alt_hop_limit;
1255 alt_path->traffic_class = req_msg->alt_traffic_class;
1257 alt_path->pkey = req_msg->pkey;
1258 alt_path->sl = cm_req_get_alt_sl(req_msg);
1260 alt_path->mtu = cm_req_get_path_mtu(req_msg);
1262 alt_path->rate = cm_req_get_alt_packet_rate(req_msg);
1265 cm_req_get_alt_local_ack_timeout(req_msg);
1274 struct cm_req_msg *req_msg;
1277 req_msg = (struct cm_req_msg *)work->mad_recv_wc->recv_buf.mad;
1282 if (req_msg->alt_local_lid)
1286 param->remote_ca_guid = req_msg->local_ca_guid;
1287 param->remote_qkey = be32_to_cpu(req_msg->local_qkey);
1288 param->remote_qpn = be32_to_cpu(cm_req_get_local_qpn(req_msg));
1289 param->qp_type = cm_req_get_qp_type(req_msg);
1290 param->starting_psn = be32_to_cpu(cm_req_get_starting_psn(req_msg));
1291 param->responder_resources = cm_req_get_init_depth(req_msg);
1292 param->initiator_depth = cm_req_get_resp_res(req_msg);
1294 cm_req_get_remote_resp_timeout(req_msg);
1295 param->flow_control = cm_req_get_flow_ctrl(req_msg);
1297 cm_req_get_local_resp_timeout(req_msg);
1298 param->retry_count = cm_req_get_retry_count(req_msg);
1299 param->rnr_retry_count = cm_req_get_rnr_retry_count(req_msg);
1300 param->srq = cm_req_get_srq(req_msg);
1301 work->cm_event.private_data = &req_msg->private_data;
1431 struct cm_req_msg *req_msg;
1433 req_msg = (struct cm_req_msg *)work->mad_recv_wc->recv_buf.mad;
1462 req_msg->service_id,
1463 req_msg->private_data);
1481 static void cm_process_routed_req(struct cm_req_msg *req_msg, struct ib_wc *wc)
1483 if (!cm_req_get_primary_subnet_local(req_msg)) {
1484 if (req_msg->primary_local_lid == IB_LID_PERMISSIVE) {
1485 req_msg->primary_local_lid = cpu_to_be16(wc->slid);
1486 cm_req_set_primary_sl(req_msg, wc->sl);
1489 if (req_msg->primary_remote_lid == IB_LID_PERMISSIVE)
1490 req_msg->primary_remote_lid = cpu_to_be16(wc->dlid_path_bits);
1493 if (!cm_req_get_alt_subnet_local(req_msg)) {
1494 if (req_msg->alt_local_lid == IB_LID_PERMISSIVE) {
1495 req_msg->alt_local_lid = cpu_to_be16(wc->slid);
1496 cm_req_set_alt_sl(req_msg, wc->sl);
1499 if (req_msg->alt_remote_lid == IB_LID_PERMISSIVE)
1500 req_msg->alt_remote_lid = cpu_to_be16(wc->dlid_path_bits);
1508 struct cm_req_msg *req_msg;
1511 req_msg = (struct cm_req_msg *)work->mad_recv_wc->recv_buf.mad;
1518 cm_id_priv->id.remote_id = req_msg->local_comm_id;
1528 cm_id_priv->timewait_info->work.remote_id = req_msg->local_comm_id;
1529 cm_id_priv->timewait_info->remote_ca_guid = req_msg->local_ca_guid;
1530 cm_id_priv->timewait_info->remote_qpn = cm_req_get_local_qpn(req_msg);
1541 cm_id_priv->id.service_id = req_msg->service_id;
1544 cm_process_routed_req(req_msg, work->mad_recv_wc->wc);
1545 cm_format_paths_from_req(req_msg, &work->path[0], &work->path[1]);
1555 if (req_msg->alt_local_lid) {
1564 cm_id_priv->tid = req_msg->hdr.tid;
1566 cm_req_get_local_resp_timeout(req_msg));
1567 cm_id_priv->max_cm_retries = cm_req_get_max_cm_retries(req_msg);
1568 cm_id_priv->remote_qpn = cm_req_get_local_qpn(req_msg);
1569 cm_id_priv->initiator_depth = cm_req_get_resp_res(req_msg);
1570 cm_id_priv->responder_resources = cm_req_get_init_depth(req_msg);
1571 cm_id_priv->path_mtu = cm_req_get_path_mtu(req_msg);
1572 cm_id_priv->pkey = req_msg->pkey;
1573 cm_id_priv->sq_psn = cm_req_get_starting_psn(req_msg);
1574 cm_id_priv->retry_count = cm_req_get_retry_count(req_msg);
1575 cm_id_priv->rnr_retry_count = cm_req_get_rnr_retry_count(req_msg);
1576 cm_id_priv->qp_type = cm_req_get_qp_type(req_msg);