Skip to content

Commit 6a5a87f

Browse files
committed
sessions: fix hetero builds
related to open-mpi#9097 related to open-mpi#9972 Signed-off-by: Howard Pritchard <[email protected]>
1 parent 02020f3 commit 6a5a87f

File tree

2 files changed

+21
-18
lines changed

2 files changed

+21
-18
lines changed

ompi/mca/pml/ob1/pml_ob1.c

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -789,7 +789,7 @@ int mca_pml_ob1_send_cid (ompi_proc_t *proc, ompi_communicator_t *comm)
789789
mca_pml_ob1_cid_hdr_t cid;
790790

791791
mca_pml_ob1_cid_hdr_prepare (&cid, comm);
792-
ob1_hdr_hton ((mca_pml_ob1_hdr_t *) &cid, cid->hdr_common.hdr_type, proc);
792+
ob1_hdr_hton ((mca_pml_ob1_hdr_t *) &cid, cid.hdr_common.hdr_type, proc);
793793

794794
return mca_pml_ob1_send_control_any (proc, MCA_BTL_NO_ORDER, (mca_pml_ob1_hdr_t *) &cid, sizeof (cid), true);
795795
}

ompi/mca/pml/ob1/pml_ob1_hdr.h

Lines changed: 20 additions & 17 deletions
Original file line numberDiff line numberDiff line change
@@ -97,21 +97,6 @@ static inline void mca_pml_ob1_cid_hdr_prepare (mca_pml_ob1_cid_hdr_t *hdr, ompi
9797
hdr->hdr_src = ompi_comm_rank (comm);
9898
}
9999

100-
#define MCA_PML_OB1_EXT_CID_HDR_HTON(h) \
101-
do { \
102-
MCA_PML_OB1_COMMON_HDR_HTON((h).hdr_common); \
103-
(h).hdr_src_comm_index = htons((h).hdr_src_comm_index); \
104-
ompi_comm_cid_hton(&(h).hdr_cid); \
105-
} while (0)
106-
107-
#define MCA_PML_OB1_EXT_CID_HDR_NTOH(h) \
108-
do { \
109-
MCA_PML_OB1_COMMON_HDR_NTOH((h).hdr_common); \
110-
(h).hdr_src_comm_index = ntonh((h).hdr_src_comm_index); \
111-
ompi_comm_cid_ntoh(&(h).hdr_cid); \
112-
} while (0)
113-
114-
115100
/**
116101
* Header definition for the first fragment, contains the
117102
* attributes required to match the corresponding posted receive.
@@ -166,6 +151,24 @@ do { \
166151
(h).hdr_seq = htons((h).hdr_seq); \
167152
} while (0)
168153

154+
#define MCA_PML_OB1_EXT_MATCH_HDR_NTOH(h) \
155+
do {\
156+
MCA_PML_OB1_COMMON_HDR_NTOH((h).hdr_common); \
157+
(h).hdr_cid.cid_base = ntoh64((h).hdr_cid.cid_base); \
158+
(h).hdr_cid.cid_sub.u64 = ntoh64((h).hdr_cid.cid_sub.u64); \
159+
(h).hdr_src_comm_index = ntohs((h).hdr_src_comm_index); \
160+
(h).hdr_src = ntohl((h).hdr_src); \
161+
} while (0)
162+
163+
#define MCA_PML_OB1_EXT_MATCH_HDR_HTON(h) \
164+
do {\
165+
MCA_PML_OB1_COMMON_HDR_HTON((h).hdr_common); \
166+
(h).hdr_cid.cid_base = hton64((h).hdr_cid.cid_base); \
167+
(h).hdr_cid.cid_sub.u64 = hton64((h).hdr_cid.cid_sub.u64); \
168+
(h).hdr_src_comm_index = htons((h).hdr_src_comm_index); \
169+
(h).hdr_src = htonl((h).hdr_src); \
170+
} while (0)
171+
169172
struct mca_pml_ob1_ext_match_hdr_t {
170173
mca_pml_ob1_cid_hdr_t hdr_ext_cid;
171174

@@ -531,7 +534,7 @@ ob1_hdr_ntoh(mca_pml_ob1_hdr_t *hdr, const uint8_t hdr_type)
531534

532535
MCA_PML_OB1_EXT_MATCH_HDR_NTOH(hdr->hdr_cid);
533536
/* now swap the real header */
534-
ob1_hdr_ntoh (next_hdr, hext_hdr->hdr_common.hdr_type);
537+
ob1_hdr_ntoh (next_hdr, next_hdr->hdr_common.hdr_type);
535538
break;
536539
}
537540
default:
@@ -586,7 +589,7 @@ ob1_hdr_hton_intr(mca_pml_ob1_hdr_t *hdr, const uint8_t hdr_type,
586589

587590
MCA_PML_OB1_EXT_MATCH_HDR_HTON(hdr->hdr_cid);
588591
/* now swap the real header */
589-
ob1_hdr_hton (next_hdr, hext_hdr->hdr_common.hdr_type, proc);
592+
ob1_hdr_hton (next_hdr, next_hdr->hdr_common.hdr_type, proc);
590593
break;
591594
}
592595
default:

0 commit comments

Comments
 (0)