use consistent macros for csum
This commit was SVN r9294.
Этот коммит содержится в:
родитель
9e958f727f
Коммит
178d8ea905
@ -34,6 +34,7 @@
|
|||||||
#include "ompi/mca/pml/base/pml_base_sendreq.h"
|
#include "ompi/mca/pml/base/pml_base_sendreq.h"
|
||||||
#include "ompi/mca/btl/btl.h"
|
#include "ompi/mca/btl/btl.h"
|
||||||
#include "ompi/datatype/datatype.h"
|
#include "ompi/datatype/datatype.h"
|
||||||
|
#include "ompi/datatype/datatype_internal.h"
|
||||||
|
|
||||||
#if defined(c_plusplus) || defined(__cplusplus)
|
#if defined(c_plusplus) || defined(__cplusplus)
|
||||||
extern "C" {
|
extern "C" {
|
||||||
@ -251,6 +252,5 @@ extern int mca_pml_dr_start(
|
|||||||
MCA_BML_BASE_BTL_DES_ALLOC(bml_btl, des, \
|
MCA_BML_BASE_BTL_DES_ALLOC(bml_btl, des, \
|
||||||
sizeof(mca_pml_dr_hdr_t) + (sizeof(mca_btl_base_segment_t) << 4), size)
|
sizeof(mca_pml_dr_hdr_t) + (sizeof(mca_btl_base_segment_t) << 4), size)
|
||||||
|
|
||||||
#define MCA_PML_DR_CSUM_ZERO 1
|
|
||||||
#endif
|
#endif
|
||||||
|
|
||||||
|
@ -574,8 +574,7 @@ rematch:
|
|||||||
mca_pml_dr_recv_request_progress(match,btl,segments,num_segments);
|
mca_pml_dr_recv_request_progress(match,btl,segments,num_segments);
|
||||||
} else {
|
} else {
|
||||||
size_t hdr_size = mca_pml_dr_hdr_size(hdr->hdr_common.hdr_type);
|
size_t hdr_size = mca_pml_dr_hdr_size(hdr->hdr_common.hdr_type);
|
||||||
COMPUTE_SPECIFIC_CHECKSUM((void*)((unsigned char*)segments->seg_addr.pval + hdr_size),
|
csum = OMPI_CSUM((void*)((unsigned char*)segments->seg_addr.pval + hdr_size), segments->seg_len - hdr_size);
|
||||||
segments->seg_len - hdr_size, csum);
|
|
||||||
assert(csum == hdr->hdr_csum);
|
assert(csum == hdr->hdr_csum);
|
||||||
mca_pml_dr_recv_frag_unmatched_ack(hdr,
|
mca_pml_dr_recv_frag_unmatched_ack(hdr,
|
||||||
ompi_proc,
|
ompi_proc,
|
||||||
|
@ -279,7 +279,7 @@ do {
|
|||||||
csum = request->req_recv.req_convertor.checksum; \
|
csum = request->req_recv.req_convertor.checksum; \
|
||||||
} else { \
|
} else { \
|
||||||
bytes_delivered = 0; \
|
bytes_delivered = 0; \
|
||||||
csum = MCA_PML_DR_CSUM_ZERO; \
|
csum = OMPI_CSUM_ZERO; \
|
||||||
} \
|
} \
|
||||||
} while (0)
|
} while (0)
|
||||||
|
|
||||||
|
@ -426,7 +426,7 @@ int mca_pml_dr_send_request_start_copy(
|
|||||||
hdr->hdr_match.hdr_src = sendreq->req_send.req_base.req_comm->c_my_rank;
|
hdr->hdr_match.hdr_src = sendreq->req_send.req_base.req_comm->c_my_rank;
|
||||||
hdr->hdr_match.hdr_tag = sendreq->req_send.req_base.req_tag;
|
hdr->hdr_match.hdr_tag = sendreq->req_send.req_base.req_tag;
|
||||||
hdr->hdr_match.hdr_seq = sendreq->req_send.req_base.req_sequence;
|
hdr->hdr_match.hdr_seq = sendreq->req_send.req_base.req_sequence;
|
||||||
hdr->hdr_match.hdr_csum = size > 0 ? sendreq->req_send.req_convertor.checksum : MCA_PML_DR_CSUM_ZERO;
|
hdr->hdr_match.hdr_csum = size > 0 ? sendreq->req_send.req_convertor.checksum : OMPI_CSUM_ZERO;
|
||||||
hdr->hdr_match.hdr_src_ptr.pval = &sendreq->req_vfrag0;
|
hdr->hdr_match.hdr_src_ptr.pval = &sendreq->req_vfrag0;
|
||||||
hdr->hdr_match.hdr_vid = sendreq->req_vfrag0.vf_id;
|
hdr->hdr_match.hdr_vid = sendreq->req_vfrag0.vf_id;
|
||||||
hdr->hdr_common.hdr_csum = opal_csum(hdr, sizeof(mca_pml_dr_match_hdr_t));
|
hdr->hdr_common.hdr_csum = opal_csum(hdr, sizeof(mca_pml_dr_match_hdr_t));
|
||||||
@ -494,7 +494,7 @@ int mca_pml_dr_send_request_start_prepare(
|
|||||||
hdr->hdr_match.hdr_src = sendreq->req_send.req_base.req_comm->c_my_rank;
|
hdr->hdr_match.hdr_src = sendreq->req_send.req_base.req_comm->c_my_rank;
|
||||||
hdr->hdr_match.hdr_tag = sendreq->req_send.req_base.req_tag;
|
hdr->hdr_match.hdr_tag = sendreq->req_send.req_base.req_tag;
|
||||||
hdr->hdr_match.hdr_seq = sendreq->req_send.req_base.req_sequence;
|
hdr->hdr_match.hdr_seq = sendreq->req_send.req_base.req_sequence;
|
||||||
hdr->hdr_match.hdr_csum = size > 0 ? sendreq->req_send.req_convertor.checksum : MCA_PML_DR_CSUM_ZERO;
|
hdr->hdr_match.hdr_csum = size > 0 ? sendreq->req_send.req_convertor.checksum : OMPI_CSUM_ZERO;
|
||||||
hdr->hdr_match.hdr_src_ptr.pval = &sendreq->req_vfrag0;
|
hdr->hdr_match.hdr_src_ptr.pval = &sendreq->req_vfrag0;
|
||||||
hdr->hdr_match.hdr_vid = sendreq->req_vfrag0.vf_id;
|
hdr->hdr_match.hdr_vid = sendreq->req_vfrag0.vf_id;
|
||||||
hdr->hdr_common.hdr_csum = opal_csum(hdr, sizeof(mca_pml_dr_match_hdr_t));
|
hdr->hdr_common.hdr_csum = opal_csum(hdr, sizeof(mca_pml_dr_match_hdr_t));
|
||||||
@ -566,7 +566,7 @@ int mca_pml_dr_send_request_start_rndv(
|
|||||||
hdr->hdr_match.hdr_tag = sendreq->req_send.req_base.req_tag;
|
hdr->hdr_match.hdr_tag = sendreq->req_send.req_base.req_tag;
|
||||||
hdr->hdr_match.hdr_seq = sendreq->req_send.req_base.req_sequence;
|
hdr->hdr_match.hdr_seq = sendreq->req_send.req_base.req_sequence;
|
||||||
hdr->hdr_match.hdr_src_ptr.pval = &sendreq->req_vfrag0;
|
hdr->hdr_match.hdr_src_ptr.pval = &sendreq->req_vfrag0;
|
||||||
hdr->hdr_match.hdr_csum = size > 0 ? sendreq->req_send.req_convertor.checksum : MCA_PML_DR_CSUM_ZERO;
|
hdr->hdr_match.hdr_csum = size > 0 ? sendreq->req_send.req_convertor.checksum : OMPI_CSUM_ZERO;
|
||||||
hdr->hdr_match.hdr_vid = sendreq->req_vfrag0.vf_id;
|
hdr->hdr_match.hdr_vid = sendreq->req_vfrag0.vf_id;
|
||||||
hdr->hdr_rndv.hdr_msg_length = sendreq->req_send.req_bytes_packed;
|
hdr->hdr_rndv.hdr_msg_length = sendreq->req_send.req_bytes_packed;
|
||||||
hdr->hdr_common.hdr_csum = opal_csum(hdr, sizeof(mca_pml_dr_rendezvous_hdr_t));
|
hdr->hdr_common.hdr_csum = opal_csum(hdr, sizeof(mca_pml_dr_rendezvous_hdr_t));
|
||||||
|
Загрузка…
x
Ссылка в новой задаче
Block a user