ports/openmpi
ports/openmpi
1
1
Форкнуть 0
Код Релизы Активность

Use memchecker_convertor_call function instead the old one. Move the function to the place that we can use convertor.

Просмотр исходного кода 
This commit was SVN r18370.
Этот коммит содержится в:
Shiqing Fan 2008-05-05 13:57:27 +00:00
родитель b8bb990acf
Коммит f35a06119c
12 изменённых файлов: 47 добавлений и 29 удалений
Показать статистику Скачать Patch файл Скачать Diff файл Показать все файлы Свернуть все файлы

13
ompi/mca/osc/pt2pt/osc_pt2pt_comm.c
Просмотреть файл

@ -23,6 +23,7 @@
#include "osc_pt2pt_sendreq.h"
#include "osc_pt2pt_header.h"
#include "osc_pt2pt_data_move.h"
#include "ompi/memchecker.h"
static int
enqueue_sendreq(ompi_osc_pt2pt_module_t *module,
@ -76,6 +77,10 @@ ompi_osc_pt2pt_module_accumulate(void *origin_addr, int origin_count,
target_dt,
P2P_MODULE(win),
&sendreq);
MEMCHECKER(
memchecker_convertor_call(&opal_memchecker_base_mem_noaccess,
&sendreq->req_origin_convertor);
);
if (OMPI_SUCCESS != ret) return ret;
sendreq->req_op_id = op->o_f_to_c_index;
@ -127,6 +132,10 @@ ompi_osc_pt2pt_module_get(void *origin_addr,
target_dt,
P2P_MODULE(win),
&sendreq);
MEMCHECKER(
memchecker_convertor_call(&opal_memchecker_base_mem_noaccess,
&sendreq->req_origin_convertor);
);
if (OMPI_SUCCESS != ret) return ret;
/* enqueue sendreq */
@ -172,6 +181,10 @@ ompi_osc_pt2pt_module_put(void *origin_addr, int origin_count,
target_dt,
P2P_MODULE(win),
&sendreq);
MEMCHECKER(
memchecker_convertor_call(&opal_memchecker_base_mem_noaccess,
&sendreq->req_origin_convertor);
);
if (OMPI_SUCCESS != ret) return ret;
/* enqueue sendreq */

13
ompi/mca/osc/rdma/osc_rdma_comm.c
Просмотреть файл

@ -25,6 +25,7 @@
#include "osc_rdma_sendreq.h"
#include "osc_rdma_header.h"
#include "osc_rdma_data_move.h"
#include "ompi/memchecker.h"
static int
enqueue_sendreq(ompi_osc_rdma_module_t *module,
@ -78,6 +79,10 @@ ompi_osc_rdma_module_accumulate(void *origin_addr, int origin_count,
target_dt,
module,
&sendreq);
MEMCHECKER(
memchecker_convertor_call(&opal_memchecker_base_mem_noaccess,
&sendreq->req_origin_convertor);
);
if (OMPI_SUCCESS != ret) return ret;
sendreq->req_op_id = op->o_f_to_c_index;
@ -148,6 +153,10 @@ ompi_osc_rdma_module_get(void *origin_addr,
target_dt,
module,
&sendreq);
MEMCHECKER(
memchecker_convertor_call(&opal_memchecker_base_mem_noaccess,
&sendreq->req_origin_convertor);
);
if (OMPI_SUCCESS != ret) return ret;
if (module->m_eager_send_active) {
@ -212,6 +221,10 @@ ompi_osc_rdma_module_put(void *origin_addr, int origin_count,
target_dt,
module,
&sendreq);
MEMCHECKER(
memchecker_convertor_call(&opal_memchecker_base_mem_noaccess,
&sendreq->req_origin_convertor);
);
if (OMPI_SUCCESS != ret) return ret;
if (module->m_eager_send_active) {

10
ompi/mca/pml/ob1/pml_ob1_irecv.c
Просмотреть файл

@ -22,6 +22,7 @@
#include "ompi/request/request.h"
#include "pml_ob1_recvreq.h"
#include "ompi/peruse/peruse-internal.h"
#include "ompi/memchecker.h"
int mca_pml_ob1_irecv_init(void *addr,
size_t count,
@ -40,7 +41,14 @@ int mca_pml_ob1_irecv_init(void *addr,
MCA_PML_OB1_RECV_REQUEST_INIT(recvreq,
addr,
count, datatype, src, tag, comm, true);
/*
* Receive request is initialized, let's start memory checking.
*/
MEMCHECKER (
memchecker_convertor_call(&opal_memchecker_base_mem_noaccess,
&recvreq->req_recv.req_base.req_convertor);
);
PERUSE_TRACE_COMM_EVENT (PERUSE_COMM_REQ_ACTIVATE,
&((recvreq)->req_recv.req_base),
PERUSE_RECV);

9
ompi/mca/pml/ob1/pml_ob1_isend.c
Просмотреть файл

@ -24,6 +24,7 @@
#include "pml_ob1_sendreq.h"
#include "pml_ob1_recvreq.h"
#include "ompi/peruse/peruse-internal.h"
#include "ompi/memchecker.h"
int mca_pml_ob1_isend_init(void *buf,
size_t count,
@ -48,6 +49,14 @@ int mca_pml_ob1_isend_init(void *buf,
dst, tag,
comm, sendmode, true);
/*
* Send request is initialized, let's start memory checking.
*/
MEMCHECKER (
memchecker_convertor_call(&opal_memchecker_base_mem_noaccess,
&sendreq->req_send.req_base.req_convertor);
);
PERUSE_TRACE_COMM_EVENT (PERUSE_COMM_REQ_ACTIVATE,
&(sendreq)->req_send.req_base,
PERUSE_SEND);

5
ompi/mpi/c/accumulate.c
Просмотреть файл

@ -221,11 +221,6 @@ int MPI_Accumulate(void *origin_addr, int origin_count, MPI_Datatype origin_data
return MPI_SUCCESS;
}
/* Set buffer to be unaccessable before sending it.
* It's set accessable again in file osc_pt2pt_data_move. */
MEMCHECKER (
memchecker_call(&opal_memchecker_base_mem_noaccess, origin_addr, origin_count, origin_datatype);
);
OPAL_CR_ENTER_LIBRARY();
rc = ompi_win->w_osc_module->osc_accumulate(origin_addr,

6
ompi/mpi/c/get.c
Просмотреть файл

@ -22,7 +22,6 @@
#include "ompi/win/win.h"
#include "ompi/mca/osc/osc.h"
#include "ompi/datatype/datatype.h"
#include "ompi/memchecker.h"
#if OMPI_HAVE_WEAK_SYMBOLS && OMPI_PROFILING_DEFINES
#pragma weak MPI_Get = PMPI_Get
@ -69,11 +68,6 @@ int MPI_Get(void *origin_addr, int origin_count,
if (MPI_PROC_NULL == target_rank) return MPI_SUCCESS;
/* Set buffer to be unaccessable before using it.
* It's set accessable again in file osc_pt2pt_data_move. */
MEMCHECKER (
memchecker_call(&opal_memchecker_base_mem_noaccess, origin_addr, origin_count, origin_datatype);
);
OPAL_CR_ENTER_LIBRARY();
rc = win->w_osc_module->osc_get(origin_addr, origin_count, origin_datatype,

1
ompi/mpi/c/irecv.c
Просмотреть файл

@ -68,7 +68,6 @@ int MPI_Irecv(void *buf, int count, MPI_Datatype type, int source,
return MPI_SUCCESS;
}
MEMCHECKER (memchecker_call(&opal_memchecker_base_mem_noaccess, buf, count, type));
OPAL_CR_ENTER_LIBRARY();
rc = MCA_PML_CALL(irecv(buf,count,type,source,tag,comm,request));

2
ompi/mpi/c/irsend.c
Просмотреть файл

@ -72,7 +72,6 @@ int MPI_Irsend(void *buf, int count, MPI_Datatype type, int dest,
return MPI_SUCCESS;
}
MEMCHECKER (memchecker_call(&opal_memchecker_base_mem_noaccess, buf, count, type));
OPAL_CR_ENTER_LIBRARY();
rc = MCA_PML_CALL(isend(buf,count,type,dest,tag,
@ -80,3 +79,4 @@ int MPI_Irsend(void *buf, int count, MPI_Datatype type, int dest,
OMPI_ERRHANDLER_RETURN(rc, comm, rc, FUNC_NAME);
}

2
ompi/mpi/c/isend.c
Просмотреть файл

@ -73,10 +73,10 @@ int MPI_Isend(void *buf, int count, MPI_Datatype type, int dest,
return MPI_SUCCESS;
}
MEMCHECKER (memchecker_call(&opal_memchecker_base_mem_noaccess, buf, count, type));
OPAL_CR_ENTER_LIBRARY();
rc = MCA_PML_CALL(isend(buf,count,type,dest,tag,MCA_PML_BASE_SEND_STANDARD,comm,request));
OMPI_ERRHANDLER_RETURN(rc, comm, rc, FUNC_NAME);
}

2
ompi/mpi/c/issend.c
Просмотреть файл

@ -70,7 +70,6 @@ int MPI_Issend(void *buf, int count, MPI_Datatype type, int dest,
return MPI_SUCCESS;
}
MEMCHECKER (memchecker_call(&opal_memchecker_base_mem_noaccess, buf, count, type));
OPAL_CR_ENTER_LIBRARY();
rc = MCA_PML_CALL(isend(buf,count,type,dest,tag,
@ -78,3 +77,4 @@ int MPI_Issend(void *buf, int count, MPI_Datatype type, int dest,
OMPI_ERRHANDLER_RETURN(rc, comm, rc, FUNC_NAME);
}

7
ompi/mpi/c/put.c
Просмотреть файл

@ -23,7 +23,6 @@
#include "ompi/win/win.h"
#include "ompi/mca/osc/osc.h"
#include "ompi/datatype/datatype.h"
#include "ompi/memchecker.h"
#if OMPI_HAVE_WEAK_SYMBOLS && OMPI_PROFILING_DEFINES
#pragma weak MPI_Put = PMPI_Put
@ -71,12 +70,6 @@ int MPI_Put(void *origin_addr, int origin_count, MPI_Datatype origin_datatype,
}
if (MPI_PROC_NULL == target_rank) return MPI_SUCCESS;
/* Set buffer to be unaccessable before using it.
* It's set accessable again in file osc_pt2pt_data_move. */
MEMCHECKER (
memchecker_call(&opal_memchecker_base_mem_noaccess, origin_addr, origin_count, origin_datatype);
);
OPAL_CR_ENTER_LIBRARY();

6
ompi/mpi/c/win_fence.c
Просмотреть файл

@ -21,7 +21,6 @@
#include "ompi/mpi/c/bindings.h"
#include "ompi/win/win.h"
#include "ompi/mca/osc/osc.h"
#include "ompi/memchecker.h"
#if OMPI_HAVE_WEAK_SYMBOLS && OMPI_PROFILING_DEFINES
#pragma weak MPI_Win_fence = PMPI_Win_fence
@ -52,11 +51,6 @@ int MPI_Win_fence(int assert, MPI_Win win)
return OMPI_ERRHANDLER_INVOKE(win, MPI_ERR_RMA_SYNC, FUNC_NAME);
}
}
MEMCHECKER (
/* First, we have to make sure it's a valid and initialised win. */
if( win->w_baseptr != NULL && win->w_size != 0 && win->w_mode != 0)
opal_memchecker_base_mem_noaccess( win->w_baseptr, win->w_size );
);
OPAL_CR_ENTER_LIBRARY();