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

fix up the context pointer

Просмотр исходного кода 
This commit was SVN r2210.
Этот коммит содержится в:
Weikuan Yu 2004-08-18 18:16:08 +00:00
родитель faebdd3404
Коммит afd504203b
2 изменённых файлов: 7 добавлений и 7 удалений
Показать статистику Скачать Patch файл Скачать Diff файл Показать все файлы Свернуть все файлы

12
src/mca/ptl/elan/src/ptl_elan_comm_init.c
Просмотреть файл

@ -114,9 +114,9 @@ mca_ptl_elan_putget_desc_contruct (
E4_Addr dst_elan4_addr, E4_Addr dst_elan4_addr,
int local /* dma_src is local */ ) int local /* dma_src is local */ )
{ {
ELAN4_CTX *ctx, ELAN4_CTX *ctx;
ctx = ptl->ptl_elan_ctx; ctx = (ELAN4_CTX *)ptl->ptl_elan_ctx;
memset(desc, 0, sizeof(desc)); memset(desc, 0, sizeof(desc));
desc->ptl = ptl; desc->ptl = ptl;
desc->req = NULL; desc->req = NULL;
@ -149,7 +149,7 @@ mca_ptl_elan_putget_desc_contruct (
mb(); mb();
} }
#define OMPI_ELAN_PUTGET_GROW(ctx, flist, frag, dp, eptr, msize, esize, local)\ #define OMPI_ELAN_PUTGET_GROW(ptl, flist, frag, dp, eptr, msize, esize, local)\
do { \ do { \
int i; \ int i; \
for (i = 0; i < flist->fl_num_per_alloc; i++) { \ for (i = 0; i < flist->fl_num_per_alloc; i++) { \
@ -158,7 +158,7 @@ do { \
frag->desc = (ompi_ptl_elan_base_desc_t *)dp; \ frag->desc = (ompi_ptl_elan_base_desc_t *)dp; \
\ \
/* Initialize some of the dma structures */ \ /* Initialize some of the dma structures */ \
mca_ptl_elan_putget_desc_contruct (ctx, dp, \ mca_ptl_elan_putget_desc_contruct (ptl, dp, \
eptr, 0, 0, local); \ eptr, 0, 0, local); \
\ \
item = (ompi_list_item_t *) frag; \ item = (ompi_list_item_t *) frag; \
@ -222,7 +222,7 @@ ompi_ptl_elan_init_putget_ctrl (mca_ptl_elan_module_t * ptl,
put_desc = (ompi_ptl_elan_putget_desc_t *) elan4_allocMain ( put_desc = (ompi_ptl_elan_putget_desc_t *) elan4_allocMain (
rail->r_alloc, main_align, main_size * inc_num); rail->r_alloc, main_align, main_size * inc_num);
OMPI_PTL_ELAN_CHECK_UNEX (put_desc, NULL, OMPI_ERROR, 0); OMPI_PTL_ELAN_CHECK_UNEX (put_desc, NULL, OMPI_ERROR, 0);
OMPI_ELAN_PUTGET_GROW(ctx, put_list, frag, put_desc, elan_ptr, OMPI_ELAN_PUTGET_GROW(ptl, put_list, frag, put_desc, elan_ptr,
main_size, elan_size, 1); main_size, elan_size, 1);
OBJ_CONSTRUCT (&putget->get_desc_free, ompi_free_list_t); OBJ_CONSTRUCT (&putget->get_desc_free, ompi_free_list_t);
@ -242,7 +242,7 @@ ompi_ptl_elan_init_putget_ctrl (mca_ptl_elan_module_t * ptl,
get_desc = (ompi_ptl_elan_putget_desc_t *) elan4_allocMain ( get_desc = (ompi_ptl_elan_putget_desc_t *) elan4_allocMain (
rail->r_alloc, main_align, main_size * inc_num); rail->r_alloc, main_align, main_size * inc_num);
OMPI_PTL_ELAN_CHECK_UNEX (get_desc, NULL, OMPI_ERROR, 0); OMPI_PTL_ELAN_CHECK_UNEX (get_desc, NULL, OMPI_ERROR, 0);
OMPI_ELAN_PUTGET_GROW(ctx, get_list, frag, get_desc, elan_ptr, OMPI_ELAN_PUTGET_GROW(ptl, get_list, frag, get_desc, elan_ptr,
main_size, elan_size, 0); main_size, elan_size, 0);
END_FUNC (PTL_ELAN_DEBUG_INIT); END_FUNC (PTL_ELAN_DEBUG_INIT);
return OMPI_SUCCESS; return OMPI_SUCCESS;

2
src/mca/ptl/elan/tests/test_util.h
Просмотреть файл

@ -9,7 +9,7 @@ static void env_init_for_elan()
setenv("OMPI_MCA_pcm_cofs_cellid", "1", 1); setenv("OMPI_MCA_pcm_cofs_cellid", "1", 1);
setenv("OMPI_MCA_pcm_cofs_jobid", "1", 1); setenv("OMPI_MCA_pcm_cofs_jobid", "1", 1);
setenv("OMPI_MCA_pcm_cofs_num_procs", "2", 1); setenv("OMPI_MCA_pcm_cofs_num_procs", "2", 1);
setenv("OMPI_MCA_ptl_base_exclude", "tcp", 1); setenv("OMPI_MCA_ptl_base_exclude", "elan", 1);
if (NULL != (rms_rank = getenv("RMS_RANK"))) { if (NULL != (rms_rank = getenv("RMS_RANK"))) {
/* RMS_JOBID:RMS_NNODES:RMS_NPROCS:RMS_NODEID:RMS_RESOURCEID */ /* RMS_JOBID:RMS_NNODES:RMS_NPROCS:RMS_NODEID:RMS_RESOURCEID */