IB/SA: Add OPA path record type
authorDasaratharaman Chandramouli <dasaratharaman.chandramouli@intel.com>
Thu, 27 Apr 2017 23:06:01 +0000 (19:06 -0400)
committerDoug Ledford <dledford@redhat.com>
Mon, 1 May 2017 18:39:02 +0000 (14:39 -0400)
Add opa_sa_path_rec to sa_path_rec data structure.
The 'type' field in sa_path_rec identifies the
type of the path record.

Reviewed-by: Don Hiatt <don.hiatt@intel.com>
Reviewed-by: Ira Weiny <ira.weiny@intel.com>
Signed-off-by: Dasaratharaman Chandramouli <dasaratharaman.chandramouli@intel.com>
Signed-off-by: Doug Ledford <dledford@redhat.com>
drivers/infiniband/core/cm.c
drivers/infiniband/core/sa_query.c
drivers/infiniband/core/ucma.c
drivers/infiniband/core/uverbs_marshall.c
drivers/infiniband/ulp/ipoib/ipoib_fs.c
drivers/infiniband/ulp/ipoib/ipoib_main.c
drivers/infiniband/ulp/srp/ib_srp.c
include/rdma/ib_sa.h

index ca742e84e68bfb99acb8e4cd4788545cbe45f3f3..1844770f3ae838bd63f3837bc0f475b0c8b5f1b1 100644 (file)
@@ -1203,8 +1203,10 @@ static void cm_format_req(struct cm_req_msg *req_msg,
        }
 
        if (pri_path->hop_limit <= 1) {
-               req_msg->primary_local_lid = sa_path_get_slid(pri_path);
-               req_msg->primary_remote_lid = sa_path_get_dlid(pri_path);
+               req_msg->primary_local_lid =
+                       htons(ntohl(sa_path_get_slid(pri_path)));
+               req_msg->primary_remote_lid =
+                       htons(ntohl(sa_path_get_dlid(pri_path)));
        } else {
                /* Work-around until there's a way to obtain remote LID info */
                req_msg->primary_local_lid = IB_LID_PERMISSIVE;
@@ -1224,8 +1226,10 @@ static void cm_format_req(struct cm_req_msg *req_msg,
 
        if (alt_path) {
                if (alt_path->hop_limit <= 1) {
-                       req_msg->alt_local_lid = sa_path_get_slid(alt_path);
-                       req_msg->alt_remote_lid = sa_path_get_dlid(alt_path);
+                       req_msg->alt_local_lid =
+                               htons(ntohl(sa_path_get_slid(alt_path)));
+                       req_msg->alt_remote_lid =
+                               htons(ntohl(sa_path_get_dlid(alt_path)));
                } else {
                        req_msg->alt_local_lid = IB_LID_PERMISSIVE;
                        req_msg->alt_remote_lid = IB_LID_PERMISSIVE;
@@ -1407,8 +1411,10 @@ static void cm_format_paths_from_req(struct cm_req_msg *req_msg,
 {
        primary_path->dgid = req_msg->primary_local_gid;
        primary_path->sgid = req_msg->primary_remote_gid;
-       sa_path_set_dlid(primary_path, req_msg->primary_local_lid);
-       sa_path_set_slid(primary_path, req_msg->primary_remote_lid);
+       sa_path_set_dlid(primary_path,
+                        htonl(ntohs(req_msg->primary_local_lid)));
+       sa_path_set_slid(primary_path,
+                        htonl(ntohs(req_msg->primary_remote_lid)));
        primary_path->flow_label = cm_req_get_primary_flow_label(req_msg);
        primary_path->hop_limit = req_msg->primary_hop_limit;
        primary_path->traffic_class = req_msg->primary_traffic_class;
@@ -1428,8 +1434,10 @@ static void cm_format_paths_from_req(struct cm_req_msg *req_msg,
        if (req_msg->alt_local_lid) {
                alt_path->dgid = req_msg->alt_local_gid;
                alt_path->sgid = req_msg->alt_remote_gid;
-               sa_path_set_dlid(alt_path, req_msg->alt_local_lid);
-               sa_path_set_slid(alt_path, req_msg->alt_remote_lid);
+               sa_path_set_dlid(alt_path,
+                                htonl(ntohs(req_msg->alt_local_lid)));
+               sa_path_set_slid(alt_path,
+                                htonl(ntohs(req_msg->alt_remote_lid)));
                alt_path->flow_label = cm_req_get_alt_flow_label(req_msg);
                alt_path->hop_limit = req_msg->alt_hop_limit;
                alt_path->traffic_class = req_msg->alt_traffic_class;
@@ -2842,8 +2850,10 @@ static void cm_format_lap(struct cm_lap_msg *lap_msg,
        cm_lap_set_remote_qpn(lap_msg, cm_id_priv->remote_qpn);
        /* todo: need remote CM response timeout */
        cm_lap_set_remote_resp_timeout(lap_msg, 0x1F);
-       lap_msg->alt_local_lid = sa_path_get_slid(alternate_path);
-       lap_msg->alt_remote_lid = sa_path_get_dlid(alternate_path);
+       lap_msg->alt_local_lid =
+               htons(ntohl(sa_path_get_slid(alternate_path)));
+       lap_msg->alt_remote_lid =
+               htons(ntohl(sa_path_get_dlid(alternate_path)));
        lap_msg->alt_local_gid = alternate_path->sgid;
        lap_msg->alt_remote_gid = alternate_path->dgid;
        cm_lap_set_flow_label(lap_msg, alternate_path->flow_label);
@@ -2922,8 +2932,8 @@ static void cm_format_path_from_lap(struct cm_id_private *cm_id_priv,
        path->rec_type = SA_PATH_REC_TYPE_IB;
        path->dgid = lap_msg->alt_local_gid;
        path->sgid = lap_msg->alt_remote_gid;
-       sa_path_set_dlid(path, lap_msg->alt_local_lid);
-       sa_path_set_slid(path, lap_msg->alt_remote_lid);
+       sa_path_set_dlid(path, htonl(ntohs(lap_msg->alt_local_lid)));
+       sa_path_set_slid(path, htonl(ntohs(lap_msg->alt_remote_lid)));
        path->flow_label = cm_lap_get_flow_label(lap_msg);
        path->hop_limit = lap_msg->alt_hop_limit;
        path->traffic_class = cm_lap_get_traffic_class(lap_msg);
index 88361c164d7392386073a3bc0d236484cd202747..249247609b60a5c9dd9afb14b1bc52bf8eecf975 100644 (file)
@@ -1110,9 +1110,9 @@ int ib_init_ah_from_path(struct ib_device *device, u8 port_num,
        memset(ah_attr, 0, sizeof *ah_attr);
        ah_attr->type = rdma_ah_find_type(device, port_num);
 
-       rdma_ah_set_dlid(ah_attr, be16_to_cpu(sa_path_get_dlid(rec)));
+       rdma_ah_set_dlid(ah_attr, be32_to_cpu(sa_path_get_dlid(rec)));
        rdma_ah_set_sl(ah_attr, rec->sl);
-       rdma_ah_set_path_bits(ah_attr, be16_to_cpu(sa_path_get_slid(rec)) &
+       rdma_ah_set_path_bits(ah_attr, be32_to_cpu(sa_path_get_slid(rec)) &
                              get_src_path_mask(device, port_num));
        rdma_ah_set_port_num(ah_attr, port_num);
        rdma_ah_set_static_rate(ah_attr, rec->rate);
index 2beff90f4bbb72eda883b24d9d61cd4c54b5b443..276f0ef835bdd9d1af9137e12da5ca2452bff87f 100644 (file)
@@ -898,11 +898,18 @@ static ssize_t ucma_query_path(struct ucma_context *ctx,
        for (i = 0, out_len -= sizeof(*resp);
             i < resp->num_paths && out_len > sizeof(struct ib_path_rec_data);
             i++, out_len -= sizeof(struct ib_path_rec_data)) {
+               struct sa_path_rec *rec = &ctx->cm_id->route.path_rec[i];
 
                resp->path_data[i].flags = IB_PATH_GMP | IB_PATH_PRIMARY |
                                           IB_PATH_BIDIRECTIONAL;
-               ib_sa_pack_path(&ctx->cm_id->route.path_rec[i],
-                               &resp->path_data[i].path_rec);
+               if (rec->rec_type == SA_PATH_REC_TYPE_IB) {
+                       ib_sa_pack_path(rec, &resp->path_data[i].path_rec);
+               } else {
+                       struct sa_path_rec ib;
+
+                       sa_convert_path_opa_to_ib(&ib, rec);
+                       ib_sa_pack_path(&ib, &resp->path_data[i].path_rec);
+               }
        }
 
        if (copy_to_user(response, resp,
@@ -1215,8 +1222,17 @@ static int ucma_set_ib_path(struct ucma_context *ctx,
 
        memset(&sa_path, 0, sizeof(sa_path));
 
+       sa_path.rec_type = SA_PATH_REC_TYPE_IB;
        ib_sa_unpack_path(path_data->path_rec, &sa_path);
-       ret = rdma_set_ib_paths(ctx->cm_id, &sa_path, 1);
+
+       if (rdma_cap_opa_ah(ctx->cm_id->device, ctx->cm_id->port_num)) {
+               struct sa_path_rec opa;
+
+               sa_convert_path_ib_to_opa(&opa, &sa_path);
+               ret = rdma_set_ib_paths(ctx->cm_id, &opa, 1);
+       } else {
+               ret = rdma_set_ib_paths(ctx->cm_id, &sa_path, 1);
+       }
        if (ret)
                return ret;
 
index 50575b63905cd0d3af561a250f7864511e675858..8b9587fe23033fd69708dd60c7e76b18eb2e23ff 100644 (file)
@@ -96,14 +96,14 @@ void ib_copy_qp_attr_to_user(struct ib_uverbs_qp_attr *dst,
 }
 EXPORT_SYMBOL(ib_copy_qp_attr_to_user);
 
-void ib_copy_path_rec_to_user(struct ib_user_path_rec *dst,
-                             struct sa_path_rec *src)
+void __ib_copy_path_rec_to_user(struct ib_user_path_rec *dst,
+                               struct sa_path_rec *src)
 {
        memcpy(dst->dgid, src->dgid.raw, sizeof src->dgid);
        memcpy(dst->sgid, src->sgid.raw, sizeof src->sgid);
 
-       dst->dlid               = sa_path_get_dlid(src);
-       dst->slid               = sa_path_get_slid(src);
+       dst->dlid               = htons(ntohl(sa_path_get_dlid(src)));
+       dst->slid               = htons(ntohl(sa_path_get_slid(src)));
        dst->raw_traffic        = sa_path_get_raw_traffic(src);
        dst->flow_label         = src->flow_label;
        dst->hop_limit          = src->hop_limit;
@@ -120,17 +120,42 @@ void ib_copy_path_rec_to_user(struct ib_user_path_rec *dst,
        dst->preference         = src->preference;
        dst->packet_life_time_selector = src->packet_life_time_selector;
 }
+
+void ib_copy_path_rec_to_user(struct ib_user_path_rec *dst,
+                             struct sa_path_rec *src)
+{
+       struct sa_path_rec rec;
+
+       if (src->rec_type == SA_PATH_REC_TYPE_OPA) {
+               sa_convert_path_opa_to_ib(&rec, src);
+               __ib_copy_path_rec_to_user(dst, &rec);
+               return;
+       }
+       __ib_copy_path_rec_to_user(dst, src);
+}
 EXPORT_SYMBOL(ib_copy_path_rec_to_user);
 
 void ib_copy_path_rec_from_user(struct sa_path_rec *dst,
                                struct ib_user_path_rec *src)
 {
+       __be32 slid, dlid;
+
+       memset(dst, 0, sizeof(*dst));
+       if ((ib_is_opa_gid((union ib_gid *)src->sgid)) ||
+           (ib_is_opa_gid((union ib_gid *)src->dgid))) {
+               dst->rec_type = SA_PATH_REC_TYPE_OPA;
+               slid = htonl(opa_get_lid_from_gid((union ib_gid *)src->sgid));
+               dlid = htonl(opa_get_lid_from_gid((union ib_gid *)src->dgid));
+       } else {
+               dst->rec_type = SA_PATH_REC_TYPE_IB;
+               slid = htonl(ntohs(src->slid));
+               dlid = htonl(ntohs(src->dlid));
+       }
        memcpy(dst->dgid.raw, src->dgid, sizeof dst->dgid);
        memcpy(dst->sgid.raw, src->sgid, sizeof dst->sgid);
 
-       dst->rec_type = SA_PATH_REC_TYPE_IB;
-       sa_path_set_dlid(dst, src->dlid);
-       sa_path_set_slid(dst, src->slid);
+       sa_path_set_dlid(dst, dlid);
+       sa_path_set_slid(dst, slid);
        sa_path_set_raw_traffic(dst, src->raw_traffic);
        dst->flow_label         = src->flow_label;
        dst->hop_limit          = src->hop_limit;
@@ -147,6 +172,7 @@ void ib_copy_path_rec_from_user(struct sa_path_rec *dst,
        dst->preference         = src->preference;
        dst->packet_life_time_selector = src->packet_life_time_selector;
 
+       /* TODO: No need to set this */
        sa_path_set_dmac_zero(dst);
        sa_path_set_ndev(dst, NULL);
        sa_path_set_ifindex(dst, 0);
index ba7dd530fb468978023569635c80122a0ce37567..11f74cbe6660bbe0aa33fc7db2bac09bb2f7ad9e 100644 (file)
@@ -219,7 +219,7 @@ static int ipoib_path_seq_show(struct seq_file *file, void *iter_ptr)
                           "  DLID:     0x%04x\n"
                           "  SL: %12d\n"
                           "  rate: %8d.%d Gb/sec\n",
-                          be16_to_cpu(sa_path_get_dlid(&path.pathrec)),
+                          be32_to_cpu(sa_path_get_dlid(&path.pathrec)),
                           path.pathrec.sl,
                           rate / 1000, rate % 1000);
        }
index f4c25271253cfc3342e454e582f8ba4c667d5536..2aab637f9d0a4071ee0a5400a06a25db4b4d1831 100644 (file)
@@ -668,9 +668,9 @@ void ipoib_mark_paths_invalid(struct net_device *dev)
        spin_lock_irq(&priv->lock);
 
        list_for_each_entry_safe(path, tp, &priv->path_list, list) {
-               ipoib_dbg(priv, "mark path LID 0x%04x GID %pI6 invalid\n",
-                       be16_to_cpu(sa_path_get_dlid(&path->pathrec)),
-                       path->pathrec.dgid.raw);
+               ipoib_dbg(priv, "mark path LID 0x%08x GID %pI6 invalid\n",
+                         be32_to_cpu(sa_path_get_dlid(&path->pathrec)),
+                         path->pathrec.dgid.raw);
                path->valid =  0;
        }
 
@@ -731,7 +731,7 @@ static void path_rec_completion(int status,
 
        if (!status)
                ipoib_dbg(priv, "PathRec LID 0x%04x for GID %pI6\n",
-                         be16_to_cpu(sa_path_get_dlid(pathrec)),
+                         be32_to_cpu(sa_path_get_dlid(pathrec)),
                          pathrec->dgid.raw);
        else
                ipoib_dbg(priv, "PathRec status %d for GID %pI6\n",
@@ -755,7 +755,7 @@ static void path_rec_completion(int status,
                path->ah = ah;
 
                ipoib_dbg(priv, "created address handle %p for LID 0x%04x, SL %d\n",
-                         ah, be16_to_cpu(sa_path_get_dlid(pathrec)),
+                         ah, be32_to_cpu(sa_path_get_dlid(pathrec)),
                          pathrec->sl);
 
                while ((skb = __skb_dequeue(&path->queue)))
@@ -1000,8 +1000,8 @@ static void unicast_arp_send(struct sk_buff *skb, struct net_device *dev,
        }
 
        if (path->ah) {
-               ipoib_dbg(priv, "Send unicast ARP to %04x\n",
-                         be16_to_cpu(sa_path_get_dlid(&path->pathrec)));
+               ipoib_dbg(priv, "Send unicast ARP to %08x\n",
+                         be32_to_cpu(sa_path_get_dlid(&path->pathrec)));
 
                spin_unlock_irqrestore(&priv->lock, flags);
                path->ah->last_send = rn->send(dev, skb, path->ah->ah,
index 89341dde9e5be370651fa578cc4edf9025ba7996..07877a88475d602d048610df32085446909e2abd 100644 (file)
@@ -2400,7 +2400,7 @@ static void srp_cm_rej_handler(struct ib_cm_id *cm_id,
        switch (event->param.rej_rcvd.reason) {
        case IB_CM_REJ_PORT_CM_REDIRECT:
                cpi = event->param.rej_rcvd.ari;
-               sa_path_set_dlid(&ch->path, cpi->redirect_lid);
+               sa_path_set_dlid(&ch->path, htonl(ntohs(cpi->redirect_lid)));
                ch->path.pkey = cpi->redirect_pkey;
                cm_id->remote_cm_qpn = be32_to_cpu(cpi->redirect_qp) & 0x00ffffff;
                memcpy(ch->path.dgid.raw, cpi->redirect_gid, 16);
index c72c9494961762572163d7f87003840058b3b355..f5f70e345318151356e022ce46b623a357031920 100644 (file)
@@ -44,6 +44,7 @@
 #include <rdma/ib_verbs.h>
 #include <rdma/ib_mad.h>
 #include <rdma/ib_addr.h>
+#include <rdma/opa_addr.h>
 
 enum {
        IB_SA_CLASS_VERSION             = 2,    /* IB spec version 1.1/1.2 */
@@ -152,7 +153,8 @@ enum ib_sa_mc_join_states {
 enum sa_path_rec_type {
        SA_PATH_REC_TYPE_IB,
        SA_PATH_REC_TYPE_ROCE_V1,
-       SA_PATH_REC_TYPE_ROCE_V2
+       SA_PATH_REC_TYPE_ROCE_V2,
+       SA_PATH_REC_TYPE_OPA
 };
 
 struct sa_path_rec_ib {
@@ -171,6 +173,19 @@ struct sa_path_rec_roce {
 
 };
 
+struct sa_path_rec_opa {
+       __be64       service_id;
+       __be32       dlid;
+       __be32       slid;
+       u8           raw_traffic;
+       u8           l2_8B;
+       u8           l2_10B;
+       u8           l2_9B;
+       u8           l2_16B;
+       u8           qos_type;
+       u8           qos_priority;
+};
+
 struct sa_path_rec {
        union ib_gid dgid;
        union ib_gid sgid;
@@ -193,6 +208,7 @@ struct sa_path_rec {
        union {
                struct sa_path_rec_ib ib;
                struct sa_path_rec_roce roce;
+               struct sa_path_rec_opa opa;
        };
        enum sa_path_rec_type rec_type;
 };
@@ -223,6 +239,77 @@ static inline enum sa_path_rec_type
        }
 }
 
+static inline void path_conv_opa_to_ib(struct sa_path_rec *ib,
+                                      struct sa_path_rec *opa)
+{
+       if ((be32_to_cpu(opa->opa.dlid) >=
+            be16_to_cpu(IB_MULTICAST_LID_BASE)) ||
+           (be32_to_cpu(opa->opa.slid) >=
+            be16_to_cpu(IB_MULTICAST_LID_BASE))) {
+               /* Create OPA GID and zero out the LID */
+               ib->dgid.global.interface_id
+                               = OPA_MAKE_ID(be32_to_cpu(opa->opa.dlid));
+               ib->dgid.global.subnet_prefix
+                               = opa->dgid.global.subnet_prefix;
+               ib->sgid.global.interface_id
+                               = OPA_MAKE_ID(be32_to_cpu(opa->opa.slid));
+               ib->dgid.global.subnet_prefix
+                               = opa->dgid.global.subnet_prefix;
+               ib->ib.dlid     = 0;
+
+               ib->ib.slid     = 0;
+       } else {
+               ib->ib.dlid     = htons(ntohl(opa->opa.dlid));
+               ib->ib.slid     = htons(ntohl(opa->opa.slid));
+       }
+       ib->ib.service_id       = opa->opa.service_id;
+       ib->ib.raw_traffic      = opa->opa.raw_traffic;
+}
+
+static inline void path_conv_ib_to_opa(struct sa_path_rec *opa,
+                                      struct sa_path_rec *ib)
+{
+       __be32 slid, dlid;
+
+       if ((ib_is_opa_gid(&ib->sgid)) ||
+           (ib_is_opa_gid(&ib->dgid))) {
+               slid = htonl(opa_get_lid_from_gid(&ib->sgid));
+               dlid = htonl(opa_get_lid_from_gid(&ib->dgid));
+       } else {
+               slid = htonl(ntohs(ib->ib.slid));
+               dlid = htonl(ntohs(ib->ib.dlid));
+       }
+       opa->opa.slid           = slid;
+       opa->opa.dlid           = dlid;
+       opa->opa.service_id     = ib->ib.service_id;
+       opa->opa.raw_traffic    = ib->ib.raw_traffic;
+}
+
+/* Convert from OPA to IB path record */
+static inline void sa_convert_path_opa_to_ib(struct sa_path_rec *dest,
+                                            struct sa_path_rec *src)
+{
+       if (src->rec_type != SA_PATH_REC_TYPE_OPA)
+               return;
+
+       *dest = *src;
+       dest->rec_type = SA_PATH_REC_TYPE_IB;
+       path_conv_opa_to_ib(dest, src);
+}
+
+/* Convert from IB to OPA path record */
+static inline void sa_convert_path_ib_to_opa(struct sa_path_rec *dest,
+                                            struct sa_path_rec *src)
+{
+       if (src->rec_type != SA_PATH_REC_TYPE_IB)
+               return;
+
+       /* Do a structure copy and overwrite the relevant fields */
+       *dest = *src;
+       dest->rec_type = SA_PATH_REC_TYPE_OPA;
+       path_conv_ib_to_opa(dest, src);
+}
+
 #define IB_SA_MCMEMBER_REC_MGID                                IB_SA_COMP_MASK( 0)
 #define IB_SA_MCMEMBER_REC_PORT_GID                    IB_SA_COMP_MASK( 1)
 #define IB_SA_MCMEMBER_REC_QKEY                                IB_SA_COMP_MASK( 2)
@@ -509,18 +596,24 @@ static inline void sa_path_set_service_id(struct sa_path_rec *rec,
 {
        if (rec->rec_type == SA_PATH_REC_TYPE_IB)
                rec->ib.service_id = service_id;
+       else if (rec->rec_type == SA_PATH_REC_TYPE_OPA)
+               rec->opa.service_id = service_id;
 }
 
-static inline void sa_path_set_slid(struct sa_path_rec *rec, __be16 slid)
+static inline void sa_path_set_slid(struct sa_path_rec *rec, __be32 slid)
 {
        if (rec->rec_type == SA_PATH_REC_TYPE_IB)
-               rec->ib.slid = slid;
+               rec->ib.slid = htons(ntohl(slid));
+       else if (rec->rec_type == SA_PATH_REC_TYPE_OPA)
+               rec->opa.slid = slid;
 }
 
-static inline void sa_path_set_dlid(struct sa_path_rec *rec, __be16 dlid)
+static inline void sa_path_set_dlid(struct sa_path_rec *rec, __be32 dlid)
 {
        if (rec->rec_type == SA_PATH_REC_TYPE_IB)
-               rec->ib.dlid = dlid;
+               rec->ib.dlid = htons(ntohl(dlid));
+       else if (rec->rec_type == SA_PATH_REC_TYPE_OPA)
+               rec->opa.dlid = dlid;
 }
 
 static inline void sa_path_set_raw_traffic(struct sa_path_rec *rec,
@@ -528,26 +621,34 @@ static inline void sa_path_set_raw_traffic(struct sa_path_rec *rec,
 {
        if (rec->rec_type == SA_PATH_REC_TYPE_IB)
                rec->ib.raw_traffic = raw_traffic;
+       else if (rec->rec_type == SA_PATH_REC_TYPE_OPA)
+               rec->opa.raw_traffic = raw_traffic;
 }
 
 static inline __be64 sa_path_get_service_id(struct sa_path_rec *rec)
 {
        if (rec->rec_type == SA_PATH_REC_TYPE_IB)
                return rec->ib.service_id;
+       else if (rec->rec_type == SA_PATH_REC_TYPE_OPA)
+               return rec->opa.service_id;
        return 0;
 }
 
-static inline __be16 sa_path_get_slid(struct sa_path_rec *rec)
+static inline __be32 sa_path_get_slid(struct sa_path_rec *rec)
 {
        if (rec->rec_type == SA_PATH_REC_TYPE_IB)
-               return rec->ib.slid;
+               return htonl(ntohs(rec->ib.slid));
+       else if (rec->rec_type == SA_PATH_REC_TYPE_OPA)
+               return rec->opa.slid;
        return 0;
 }
 
-static inline __be16 sa_path_get_dlid(struct sa_path_rec *rec)
+static inline __be32 sa_path_get_dlid(struct sa_path_rec *rec)
 {
        if (rec->rec_type == SA_PATH_REC_TYPE_IB)
-               return rec->ib.dlid;
+               return htonl(ntohs(rec->ib.dlid));
+       else if (rec->rec_type == SA_PATH_REC_TYPE_OPA)
+               return rec->opa.dlid;
        return 0;
 }
 
@@ -555,6 +656,8 @@ static inline u8 sa_path_get_raw_traffic(struct sa_path_rec *rec)
 {
        if (rec->rec_type == SA_PATH_REC_TYPE_IB)
                return rec->ib.raw_traffic;
+       else if (rec->rec_type == SA_PATH_REC_TYPE_OPA)
+               return rec->opa.raw_traffic;
        return 0;
 }