Lines Matching refs:req_msg
1339 static void cm_format_req(struct cm_req_msg *req_msg, in cm_format_req() argument
1352 cm_format_mad_ece_hdr(&req_msg->hdr, CM_REQ_ATTR_ID, in cm_format_req()
1355 IBA_SET(CM_REQ_LOCAL_COMM_ID, req_msg, in cm_format_req()
1357 IBA_SET(CM_REQ_SERVICE_ID, req_msg, be64_to_cpu(param->service_id)); in cm_format_req()
1358 IBA_SET(CM_REQ_LOCAL_CA_GUID, req_msg, in cm_format_req()
1360 IBA_SET(CM_REQ_LOCAL_QPN, req_msg, param->qp_num); in cm_format_req()
1361 IBA_SET(CM_REQ_INITIATOR_DEPTH, req_msg, param->initiator_depth); in cm_format_req()
1362 IBA_SET(CM_REQ_REMOTE_CM_RESPONSE_TIMEOUT, req_msg, in cm_format_req()
1364 cm_req_set_qp_type(req_msg, param->qp_type); in cm_format_req()
1365 IBA_SET(CM_REQ_END_TO_END_FLOW_CONTROL, req_msg, param->flow_control); in cm_format_req()
1366 IBA_SET(CM_REQ_STARTING_PSN, req_msg, param->starting_psn); in cm_format_req()
1367 IBA_SET(CM_REQ_LOCAL_CM_RESPONSE_TIMEOUT, req_msg, in cm_format_req()
1369 IBA_SET(CM_REQ_PARTITION_KEY, req_msg, in cm_format_req()
1371 IBA_SET(CM_REQ_PATH_PACKET_PAYLOAD_MTU, req_msg, in cm_format_req()
1373 IBA_SET(CM_REQ_MAX_CM_RETRIES, req_msg, param->max_cm_retries); in cm_format_req()
1376 IBA_SET(CM_REQ_RESPONDER_RESOURCES, req_msg, in cm_format_req()
1378 IBA_SET(CM_REQ_RETRY_COUNT, req_msg, param->retry_count); in cm_format_req()
1379 IBA_SET(CM_REQ_RNR_RETRY_COUNT, req_msg, in cm_format_req()
1381 IBA_SET(CM_REQ_SRQ, req_msg, param->srq); in cm_format_req()
1384 *IBA_GET_MEM_PTR(CM_REQ_PRIMARY_LOCAL_PORT_GID, req_msg) = in cm_format_req()
1386 *IBA_GET_MEM_PTR(CM_REQ_PRIMARY_REMOTE_PORT_GID, req_msg) = in cm_format_req()
1389 IBA_GET_MEM_PTR(CM_REQ_PRIMARY_LOCAL_PORT_GID, req_msg) in cm_format_req()
1392 IBA_GET_MEM_PTR(CM_REQ_PRIMARY_REMOTE_PORT_GID, req_msg) in cm_format_req()
1397 IBA_SET(CM_REQ_PRIMARY_LOCAL_PORT_LID, req_msg, in cm_format_req()
1401 IBA_SET(CM_REQ_PRIMARY_REMOTE_PORT_LID, req_msg, in cm_format_req()
1409 IBA_SET(CM_REQ_PRIMARY_LOCAL_PORT_LID, req_msg, in cm_format_req()
1412 IBA_SET(CM_REQ_PRIMARY_LOCAL_PORT_LID, req_msg, in cm_format_req()
1416 IBA_SET(CM_REQ_PRIMARY_REMOTE_PORT_LID, req_msg, in cm_format_req()
1419 IBA_SET(CM_REQ_PRIMARY_FLOW_LABEL, req_msg, in cm_format_req()
1421 IBA_SET(CM_REQ_PRIMARY_PACKET_RATE, req_msg, pri_path->rate); in cm_format_req()
1422 IBA_SET(CM_REQ_PRIMARY_TRAFFIC_CLASS, req_msg, pri_path->traffic_class); in cm_format_req()
1423 IBA_SET(CM_REQ_PRIMARY_HOP_LIMIT, req_msg, pri_path->hop_limit); in cm_format_req()
1424 IBA_SET(CM_REQ_PRIMARY_SL, req_msg, pri_path->sl); in cm_format_req()
1425 IBA_SET(CM_REQ_PRIMARY_SUBNET_LOCAL, req_msg, in cm_format_req()
1427 IBA_SET(CM_REQ_PRIMARY_LOCAL_ACK_TIMEOUT, req_msg, in cm_format_req()
1438 *IBA_GET_MEM_PTR(CM_REQ_ALTERNATE_LOCAL_PORT_GID, req_msg) = in cm_format_req()
1440 *IBA_GET_MEM_PTR(CM_REQ_ALTERNATE_REMOTE_PORT_GID, req_msg) = in cm_format_req()
1444 req_msg) in cm_format_req()
1448 req_msg) in cm_format_req()
1453 IBA_SET(CM_REQ_ALTERNATE_LOCAL_PORT_LID, req_msg, in cm_format_req()
1458 IBA_SET(CM_REQ_ALTERNATE_REMOTE_PORT_LID, req_msg, in cm_format_req()
1464 IBA_SET(CM_REQ_ALTERNATE_LOCAL_PORT_LID, req_msg, in cm_format_req()
1466 IBA_SET(CM_REQ_ALTERNATE_REMOTE_PORT_LID, req_msg, in cm_format_req()
1469 IBA_SET(CM_REQ_ALTERNATE_FLOW_LABEL, req_msg, in cm_format_req()
1471 IBA_SET(CM_REQ_ALTERNATE_PACKET_RATE, req_msg, alt_path->rate); in cm_format_req()
1472 IBA_SET(CM_REQ_ALTERNATE_TRAFFIC_CLASS, req_msg, in cm_format_req()
1474 IBA_SET(CM_REQ_ALTERNATE_HOP_LIMIT, req_msg, in cm_format_req()
1476 IBA_SET(CM_REQ_ALTERNATE_SL, req_msg, alt_path->sl); in cm_format_req()
1477 IBA_SET(CM_REQ_ALTERNATE_SUBNET_LOCAL, req_msg, in cm_format_req()
1479 IBA_SET(CM_REQ_ALTERNATE_LOCAL_ACK_TIMEOUT, req_msg, in cm_format_req()
1483 IBA_SET(CM_REQ_VENDOR_ID, req_msg, param->ece.vendor_id); in cm_format_req()
1486 IBA_SET_MEM(CM_REQ_PRIVATE_DATA, req_msg, param->private_data, in cm_format_req()
1517 struct cm_req_msg *req_msg; in ib_send_cm_req() local
1583 req_msg = (struct cm_req_msg *)msg->mad; in ib_send_cm_req()
1584 cm_format_req(req_msg, cm_id_priv, param); in ib_send_cm_req()
1585 cm_id_priv->tid = req_msg->hdr.tid; in ib_send_cm_req()
1587 cm_id_priv->local_qpn = cpu_to_be32(IBA_GET(CM_REQ_LOCAL_QPN, req_msg)); in ib_send_cm_req()
1588 cm_id_priv->rq_psn = cpu_to_be32(IBA_GET(CM_REQ_STARTING_PSN, req_msg)); in ib_send_cm_req()
1647 static bool cm_req_has_alt_path(struct cm_req_msg *req_msg) in cm_req_has_alt_path() argument
1650 IBA_GET(CM_REQ_ALTERNATE_LOCAL_PORT_LID, req_msg))) || in cm_req_has_alt_path()
1652 req_msg)))); in cm_req_has_alt_path()
1664 static void cm_format_path_lid_from_req(struct cm_req_msg *req_msg, in cm_format_path_lid_from_req() argument
1675 req_msg)); in cm_format_path_lid_from_req()
1678 CM_REQ_PRIMARY_LOCAL_PORT_GID, req_msg)); in cm_format_path_lid_from_req()
1682 CM_REQ_PRIMARY_REMOTE_PORT_GID, req_msg)); in cm_format_path_lid_from_req()
1686 if (!cm_req_has_alt_path(req_msg)) in cm_format_path_lid_from_req()
1692 req_msg)); in cm_format_path_lid_from_req()
1695 req_msg)); in cm_format_path_lid_from_req()
1698 CM_REQ_ALTERNATE_LOCAL_PORT_GID, req_msg)); in cm_format_path_lid_from_req()
1702 CM_REQ_ALTERNATE_REMOTE_PORT_GID, req_msg)); in cm_format_path_lid_from_req()
1707 static void cm_format_paths_from_req(struct cm_req_msg *req_msg, in cm_format_paths_from_req() argument
1713 *IBA_GET_MEM_PTR(CM_REQ_PRIMARY_LOCAL_PORT_GID, req_msg); in cm_format_paths_from_req()
1715 *IBA_GET_MEM_PTR(CM_REQ_PRIMARY_REMOTE_PORT_GID, req_msg); in cm_format_paths_from_req()
1717 cpu_to_be32(IBA_GET(CM_REQ_PRIMARY_FLOW_LABEL, req_msg)); in cm_format_paths_from_req()
1718 primary_path->hop_limit = IBA_GET(CM_REQ_PRIMARY_HOP_LIMIT, req_msg); in cm_format_paths_from_req()
1720 IBA_GET(CM_REQ_PRIMARY_TRAFFIC_CLASS, req_msg); in cm_format_paths_from_req()
1723 cpu_to_be16(IBA_GET(CM_REQ_PARTITION_KEY, req_msg)); in cm_format_paths_from_req()
1724 primary_path->sl = IBA_GET(CM_REQ_PRIMARY_SL, req_msg); in cm_format_paths_from_req()
1726 primary_path->mtu = IBA_GET(CM_REQ_PATH_PACKET_PAYLOAD_MTU, req_msg); in cm_format_paths_from_req()
1728 primary_path->rate = IBA_GET(CM_REQ_PRIMARY_PACKET_RATE, req_msg); in cm_format_paths_from_req()
1731 IBA_GET(CM_REQ_PRIMARY_LOCAL_ACK_TIMEOUT, req_msg); in cm_format_paths_from_req()
1734 cpu_to_be64(IBA_GET(CM_REQ_SERVICE_ID, req_msg)); in cm_format_paths_from_req()
1738 if (cm_req_has_alt_path(req_msg)) { in cm_format_paths_from_req()
1740 CM_REQ_ALTERNATE_LOCAL_PORT_GID, req_msg); in cm_format_paths_from_req()
1742 CM_REQ_ALTERNATE_REMOTE_PORT_GID, req_msg); in cm_format_paths_from_req()
1744 IBA_GET(CM_REQ_ALTERNATE_FLOW_LABEL, req_msg)); in cm_format_paths_from_req()
1746 IBA_GET(CM_REQ_ALTERNATE_HOP_LIMIT, req_msg); in cm_format_paths_from_req()
1748 IBA_GET(CM_REQ_ALTERNATE_TRAFFIC_CLASS, req_msg); in cm_format_paths_from_req()
1751 cpu_to_be16(IBA_GET(CM_REQ_PARTITION_KEY, req_msg)); in cm_format_paths_from_req()
1752 alt_path->sl = IBA_GET(CM_REQ_ALTERNATE_SL, req_msg); in cm_format_paths_from_req()
1755 IBA_GET(CM_REQ_PATH_PACKET_PAYLOAD_MTU, req_msg); in cm_format_paths_from_req()
1757 alt_path->rate = IBA_GET(CM_REQ_ALTERNATE_PACKET_RATE, req_msg); in cm_format_paths_from_req()
1760 IBA_GET(CM_REQ_ALTERNATE_LOCAL_ACK_TIMEOUT, req_msg); in cm_format_paths_from_req()
1763 cpu_to_be64(IBA_GET(CM_REQ_SERVICE_ID, req_msg)); in cm_format_paths_from_req()
1768 cm_format_path_lid_from_req(req_msg, primary_path, alt_path, wc); in cm_format_paths_from_req()
1822 struct cm_req_msg *req_msg; in cm_format_req_event() local
1825 req_msg = (struct cm_req_msg *)work->mad_recv_wc->recv_buf.mad; in cm_format_req_event()
1832 if (cm_req_has_alt_path(req_msg)) { in cm_format_req_event()
1839 cpu_to_be64(IBA_GET(CM_REQ_LOCAL_CA_GUID, req_msg)); in cm_format_req_event()
1840 param->remote_qkey = IBA_GET(CM_REQ_LOCAL_Q_KEY, req_msg); in cm_format_req_event()
1841 param->remote_qpn = IBA_GET(CM_REQ_LOCAL_QPN, req_msg); in cm_format_req_event()
1842 param->qp_type = cm_req_get_qp_type(req_msg); in cm_format_req_event()
1843 param->starting_psn = IBA_GET(CM_REQ_STARTING_PSN, req_msg); in cm_format_req_event()
1844 param->responder_resources = IBA_GET(CM_REQ_INITIATOR_DEPTH, req_msg); in cm_format_req_event()
1845 param->initiator_depth = IBA_GET(CM_REQ_RESPONDER_RESOURCES, req_msg); in cm_format_req_event()
1847 IBA_GET(CM_REQ_REMOTE_CM_RESPONSE_TIMEOUT, req_msg); in cm_format_req_event()
1848 param->flow_control = IBA_GET(CM_REQ_END_TO_END_FLOW_CONTROL, req_msg); in cm_format_req_event()
1850 IBA_GET(CM_REQ_LOCAL_CM_RESPONSE_TIMEOUT, req_msg); in cm_format_req_event()
1851 param->retry_count = IBA_GET(CM_REQ_RETRY_COUNT, req_msg); in cm_format_req_event()
1852 param->rnr_retry_count = IBA_GET(CM_REQ_RNR_RETRY_COUNT, req_msg); in cm_format_req_event()
1853 param->srq = IBA_GET(CM_REQ_SRQ, req_msg); in cm_format_req_event()
1855 param->ece.vendor_id = IBA_GET(CM_REQ_VENDOR_ID, req_msg); in cm_format_req_event()
1856 param->ece.attr_mod = be32_to_cpu(req_msg->hdr.attr_mod); in cm_format_req_event()
1859 IBA_GET_MEM_PTR(CM_REQ_PRIVATE_DATA, req_msg); in cm_format_req_event()
2006 struct cm_req_msg *req_msg; in cm_match_req() local
2008 req_msg = (struct cm_req_msg *)work->mad_recv_wc->recv_buf.mad; in cm_match_req()
2045 cpu_to_be64(IBA_GET(CM_REQ_SERVICE_ID, req_msg))); in cm_match_req()
2063 static void cm_process_routed_req(struct cm_req_msg *req_msg, struct ib_wc *wc) in cm_process_routed_req() argument
2065 if (!IBA_GET(CM_REQ_PRIMARY_SUBNET_LOCAL, req_msg)) { in cm_process_routed_req()
2067 req_msg)) == IB_LID_PERMISSIVE) { in cm_process_routed_req()
2068 IBA_SET(CM_REQ_PRIMARY_LOCAL_PORT_LID, req_msg, in cm_process_routed_req()
2070 IBA_SET(CM_REQ_PRIMARY_SL, req_msg, wc->sl); in cm_process_routed_req()
2074 req_msg)) == IB_LID_PERMISSIVE) in cm_process_routed_req()
2075 IBA_SET(CM_REQ_PRIMARY_REMOTE_PORT_LID, req_msg, in cm_process_routed_req()
2079 if (!IBA_GET(CM_REQ_ALTERNATE_SUBNET_LOCAL, req_msg)) { in cm_process_routed_req()
2081 req_msg)) == IB_LID_PERMISSIVE) { in cm_process_routed_req()
2082 IBA_SET(CM_REQ_ALTERNATE_LOCAL_PORT_LID, req_msg, in cm_process_routed_req()
2084 IBA_SET(CM_REQ_ALTERNATE_SL, req_msg, wc->sl); in cm_process_routed_req()
2088 req_msg)) == IB_LID_PERMISSIVE) in cm_process_routed_req()
2089 IBA_SET(CM_REQ_ALTERNATE_REMOTE_PORT_LID, req_msg, in cm_process_routed_req()
2097 struct cm_req_msg *req_msg; in cm_req_handler() local
2102 req_msg = (struct cm_req_msg *)work->mad_recv_wc->recv_buf.mad; in cm_req_handler()
2110 cpu_to_be32(IBA_GET(CM_REQ_LOCAL_COMM_ID, req_msg)); in cm_req_handler()
2112 cpu_to_be64(IBA_GET(CM_REQ_SERVICE_ID, req_msg)); in cm_req_handler()
2113 cm_id_priv->tid = req_msg->hdr.tid; in cm_req_handler()
2115 IBA_GET(CM_REQ_LOCAL_CM_RESPONSE_TIMEOUT, req_msg)); in cm_req_handler()
2116 cm_id_priv->max_cm_retries = IBA_GET(CM_REQ_MAX_CM_RETRIES, req_msg); in cm_req_handler()
2118 cpu_to_be32(IBA_GET(CM_REQ_LOCAL_QPN, req_msg)); in cm_req_handler()
2120 IBA_GET(CM_REQ_RESPONDER_RESOURCES, req_msg); in cm_req_handler()
2122 IBA_GET(CM_REQ_INITIATOR_DEPTH, req_msg); in cm_req_handler()
2123 cm_id_priv->path_mtu = IBA_GET(CM_REQ_PATH_PACKET_PAYLOAD_MTU, req_msg); in cm_req_handler()
2124 cm_id_priv->pkey = cpu_to_be16(IBA_GET(CM_REQ_PARTITION_KEY, req_msg)); in cm_req_handler()
2125 cm_id_priv->sq_psn = cpu_to_be32(IBA_GET(CM_REQ_STARTING_PSN, req_msg)); in cm_req_handler()
2126 cm_id_priv->retry_count = IBA_GET(CM_REQ_RETRY_COUNT, req_msg); in cm_req_handler()
2127 cm_id_priv->rnr_retry_count = IBA_GET(CM_REQ_RNR_RETRY_COUNT, req_msg); in cm_req_handler()
2128 cm_id_priv->qp_type = cm_req_get_qp_type(req_msg); in cm_req_handler()
2144 cpu_to_be64(IBA_GET(CM_REQ_LOCAL_CA_GUID, req_msg)); in cm_req_handler()
2162 if (cm_req_has_alt_path(req_msg)) in cm_req_handler()
2171 cm_process_routed_req(req_msg, work->mad_recv_wc->wc); in cm_req_handler()
2176 req_msg)); in cm_req_handler()
2178 if (cm_req_has_alt_path(req_msg)) in cm_req_handler()
2180 cm_format_paths_from_req(req_msg, &work->path[0], in cm_req_handler()
2208 IBA_GET(CM_REQ_PRIMARY_LOCAL_PORT_LID, req_msg); in cm_req_handler()
2210 if (cm_req_has_alt_path(req_msg)) { in cm_req_handler()