A touch more cleanup. Also, bring over the peruse cleanups from r20844
This commit was SVN r20849. The following SVN revision numbers were found above: r20844 --> open-mpi/ompi@daba352af4
Этот коммит содержится в:
родитель
78323fd6b2
Коммит
d88df53a86
@ -28,11 +28,23 @@
|
|||||||
#include <string.h>
|
#include <string.h>
|
||||||
|
|
||||||
#include "opal/class/opal_bitmap.h"
|
#include "opal/class/opal_bitmap.h"
|
||||||
|
#include "opal/util/crc.h"
|
||||||
|
#include "opal/util/output.h"
|
||||||
|
|
||||||
|
#include "orte/mca/errmgr/errmgr.h"
|
||||||
|
#include "orte/mca/grpcomm/grpcomm.h"
|
||||||
|
#include "orte/util/name_fns.h"
|
||||||
|
#include "orte/runtime/orte_globals.h"
|
||||||
|
|
||||||
#include "ompi/mca/pml/pml.h"
|
#include "ompi/mca/pml/pml.h"
|
||||||
#include "ompi/mca/pml/base/base.h"
|
#include "ompi/mca/pml/base/base.h"
|
||||||
#include "ompi/mca/btl/btl.h"
|
#include "ompi/mca/btl/btl.h"
|
||||||
#include "ompi/mca/pml/base/base.h"
|
#include "ompi/mca/pml/base/base.h"
|
||||||
#include "ompi/mca/btl/base/base.h"
|
#include "ompi/mca/btl/base/base.h"
|
||||||
|
#include "ompi/mca/bml/base/base.h"
|
||||||
|
#include "ompi/runtime/ompi_cr.h"
|
||||||
|
#include "ompi/runtime/ompi_module_exchange.h"
|
||||||
|
|
||||||
#include "pml_csum.h"
|
#include "pml_csum.h"
|
||||||
#include "pml_csum_component.h"
|
#include "pml_csum_component.h"
|
||||||
#include "pml_csum_comm.h"
|
#include "pml_csum_comm.h"
|
||||||
@ -41,14 +53,6 @@
|
|||||||
#include "pml_csum_sendreq.h"
|
#include "pml_csum_sendreq.h"
|
||||||
#include "pml_csum_recvreq.h"
|
#include "pml_csum_recvreq.h"
|
||||||
#include "pml_csum_rdmafrag.h"
|
#include "pml_csum_rdmafrag.h"
|
||||||
#include "ompi/mca/bml/base/base.h"
|
|
||||||
#include "orte/mca/errmgr/errmgr.h"
|
|
||||||
#include "orte/mca/grpcomm/grpcomm.h"
|
|
||||||
#include "orte/util/name_fns.h"
|
|
||||||
#include "orte/runtime/orte_globals.h"
|
|
||||||
#include "opal/util/crc.h"
|
|
||||||
#include "ompi/runtime/ompi_cr.h"
|
|
||||||
#include "ompi/runtime/ompi_module_exchange.h"
|
|
||||||
|
|
||||||
mca_pml_csum_t mca_pml_csum = {
|
mca_pml_csum_t mca_pml_csum = {
|
||||||
{
|
{
|
||||||
@ -450,7 +454,8 @@ int mca_pml_csum_send_fin( ompi_proc_t* proc,
|
|||||||
hdr->hdr_common.hdr_csum = (do_csum ?
|
hdr->hdr_common.hdr_csum = (do_csum ?
|
||||||
opal_csum16(hdr, sizeof(mca_pml_csum_fin_hdr_t)) : OPAL_CSUM_ZERO);
|
opal_csum16(hdr, sizeof(mca_pml_csum_fin_hdr_t)) : OPAL_CSUM_ZERO);
|
||||||
if(do_csum) {
|
if(do_csum) {
|
||||||
OPAL_OUTPUT_VERBOSE((0, "%s: Sending \'FIN\' with header csum:0x%04x\n",
|
OPAL_OUTPUT_VERBOSE((0, mca_pml_base_output,
|
||||||
|
"%s: Sending \'FIN\' with header csum:0x%04x\n",
|
||||||
ORTE_NAME_PRINT(ORTE_PROC_MY_NAME), hdr->hdr_common.hdr_csum));
|
ORTE_NAME_PRINT(ORTE_PROC_MY_NAME), hdr->hdr_common.hdr_csum));
|
||||||
}
|
}
|
||||||
|
|
||||||
|
@ -515,7 +515,6 @@ void mca_pml_csum_recv_request_progress_rget( mca_pml_csum_recv_request_t* recvr
|
|||||||
|
|
||||||
MCA_PML_CSUM_RECV_REQUEST_MATCHED(recvreq, &hdr->hdr_rndv.hdr_match);
|
MCA_PML_CSUM_RECV_REQUEST_MATCHED(recvreq, &hdr->hdr_rndv.hdr_match);
|
||||||
|
|
||||||
|
|
||||||
/* if receive buffer is not contiguous we can't just RDMA read into it, so
|
/* if receive buffer is not contiguous we can't just RDMA read into it, so
|
||||||
* fall back to copy in/out protocol. It is a pity because buffer on the
|
* fall back to copy in/out protocol. It is a pity because buffer on the
|
||||||
* sender side is already registered. We need to be smarter here, perhaps
|
* sender side is already registered. We need to be smarter here, perhaps
|
||||||
@ -1068,10 +1067,11 @@ void mca_pml_csum_recv_req_start(mca_pml_csum_recv_request_t *req)
|
|||||||
PERUSE_TRACE_COMM_EVENT(PERUSE_COMM_REQ_MATCH_UNEX,
|
PERUSE_TRACE_COMM_EVENT(PERUSE_COMM_REQ_MATCH_UNEX,
|
||||||
&(req->req_recv.req_base), PERUSE_RECV);
|
&(req->req_recv.req_base), PERUSE_RECV);
|
||||||
|
|
||||||
|
hdr = (mca_pml_csum_hdr_t*)frag->segments->seg_addr.pval;
|
||||||
PERUSE_TRACE_MSG_EVENT(PERUSE_COMM_MSG_REMOVE_FROM_UNEX_Q,
|
PERUSE_TRACE_MSG_EVENT(PERUSE_COMM_MSG_REMOVE_FROM_UNEX_Q,
|
||||||
req->req_recv.req_base.req_comm,
|
req->req_recv.req_base.req_comm,
|
||||||
req->req_recv.req_base.req_ompi.req_status.MPI_SOURCE,
|
hdr->hdr_match.hdr_src,
|
||||||
req->req_recv.req_base.req_ompi.req_status.MPI_TAG,
|
hdr->hdr_match.hdr_tag,
|
||||||
PERUSE_RECV);
|
PERUSE_RECV);
|
||||||
|
|
||||||
PERUSE_TRACE_COMM_EVENT(PERUSE_COMM_SEARCH_UNEX_Q_END,
|
PERUSE_TRACE_COMM_EVENT(PERUSE_COMM_SEARCH_UNEX_Q_END,
|
||||||
@ -1081,7 +1081,6 @@ void mca_pml_csum_recv_req_start(mca_pml_csum_recv_request_t *req)
|
|||||||
(opal_list_item_t*)frag);
|
(opal_list_item_t*)frag);
|
||||||
OPAL_THREAD_UNLOCK(&comm->matching_lock);
|
OPAL_THREAD_UNLOCK(&comm->matching_lock);
|
||||||
|
|
||||||
hdr = (mca_pml_csum_hdr_t*)frag->segments->seg_addr.pval;
|
|
||||||
switch(hdr->hdr_common.hdr_type) {
|
switch(hdr->hdr_common.hdr_type) {
|
||||||
case MCA_PML_CSUM_HDR_TYPE_MATCH:
|
case MCA_PML_CSUM_HDR_TYPE_MATCH:
|
||||||
mca_pml_csum_recv_request_progress_match(req, frag->btl, frag->segments,
|
mca_pml_csum_recv_request_progress_match(req, frag->btl, frag->segments,
|
||||||
|
Загрузка…
x
Ссылка в новой задаче
Block a user