1
1
This commit was SVN r6464.
Этот коммит содержится в:
Galen Shipman 2005-07-13 21:13:30 +00:00
родитель e67650d54f
Коммит dcbda13a72
8 изменённых файлов: 32 добавлений и 30 удалений

Просмотреть файл

@ -770,7 +770,8 @@ ompi_convertor_prepare_for_send( ompi_convertor_t* convertor,
convertor->fAdvance = ompi_convertor_pack_general;
convertor->fAdvance = ompi_convertor_pack_homogeneous_with_memcpy;
convertor->fAdvance = ompi_convertor_pack_no_conversion;
convertor->fAdvance = ompi_convertor_generic_simple_pack;
if( datatype->flags & DT_FLAG_CONTIGUOUS ) {
convertor->flags |= DT_FLAG_CONTIGUOUS;
if( ((datatype->ub - datatype->lb) == (long)datatype->size)
@ -779,7 +780,7 @@ ompi_convertor_prepare_for_send( ompi_convertor_t* convertor,
else
convertor->fAdvance = ompi_convertor_pack_no_conv_contig_with_gaps;
}
convertor->fAdvance = ompi_convertor_generic_simple_pack;
return OMPI_SUCCESS;
}

Просмотреть файл

@ -186,11 +186,8 @@ int mca_btl_mvapi_free(
mca_btl_mvapi_frag_t* frag = (mca_btl_mvapi_frag_t*)des;
if(frag->size == 0) {
MCA_BTL_IB_FRAG_RETURN_FRAG(btl, frag);
OBJ_RELEASE(frag->vapi_reg);
MCA_BTL_IB_FRAG_RETURN_FRAG(btl, frag);
}
else if(frag->size == mca_btl_mvapi_component.max_send_size){
MCA_BTL_IB_FRAG_RETURN_MAX(btl, frag);
@ -349,7 +346,7 @@ mca_btl_base_descriptor_t* mca_btl_mvapi_prepare_src(
mca_mpool_mvapi_registration_t* old_reg =
(mca_mpool_mvapi_registration_t*)
opal_list_remove_last(&mvapi_btl->reg_mru_list);
opal_list_remove_first(&mvapi_btl->reg_mru_list);
if( NULL == old_reg) {
opal_output(0,"%s:%d:%s error removing item from reg_mru_list", __FILE__, __LINE__, __func__);
@ -405,7 +402,7 @@ mca_btl_base_descriptor_t* mca_btl_mvapi_prepare_src(
frag->base.des_dst = NULL;
frag->base.des_dst_cnt = 0;
frag->vapi_reg = vapi_reg;
OBJ_RETAIN(vapi_reg);
return &frag->base;
} else if (max_data+reserve <= btl->btl_eager_limit) {

Просмотреть файл

@ -122,7 +122,7 @@ int mca_btl_mvapi_component_open(void)
mca_btl_mvapi_component.ib_mem_registry_hints_log_size =
mca_btl_mvapi_param_register_int ("hints_log_size", 8);
mca_btl_mvapi_component.ib_mpool_name =
mca_btl_mvapi_param_register_string("mpool", "ib");
mca_btl_mvapi_param_register_string("mpool", "mvapi");
mca_btl_mvapi_component.ib_rr_buf_max =
mca_btl_mvapi_param_register_int("rr_buf_max", 16);
mca_btl_mvapi_component.ib_rr_buf_min =

Просмотреть файл

@ -124,7 +124,7 @@ int mca_btl_openib_component_open(void)
mca_btl_openib_component.ib_mem_registry_hints_log_size =
mca_btl_openib_param_register_int ("hints_log_size", 8);
mca_btl_openib_component.ib_mpool_name =
mca_btl_openib_param_register_string("mpool", "ib");
mca_btl_openib_param_register_string("mpool", "openib");
mca_btl_openib_component.ib_rr_buf_max =
mca_btl_openib_param_register_int("rr_buf_max", 16);
mca_btl_openib_component.ib_rr_buf_min =

Просмотреть файл

@ -144,14 +144,16 @@ int mca_mpool_base_insert(void * addr, size_t size,
OMPI_FREE_LIST_GET(&mca_mpool_base_mem_list, item, rc);
if(rc != OMPI_SUCCESS)
return rc;
memset( ((mca_mpool_base_chunk_t *) item)->mpools, 0, sizeof(mca_mpool_base_reg_mpool_t) * MCA_MPOOL_BASE_MAX_REG);
((mca_mpool_base_chunk_t *) item)->key.bottom = addr;
((mca_mpool_base_chunk_t *) item)->key.top = (void *)
((char *) addr + size - 1);
((mca_mpool_base_chunk_t *) item)->mpools[0].mpool = mpool;
((mca_mpool_base_chunk_t *) item)->mpools[0].user_data = user_data;
((mca_mpool_base_chunk_t *) item)->mpools[0].mpool_registration = registration;
OPAL_THREAD_LOCK(&mca_mpool_base_tree_lock);
rc = ompi_rb_tree_insert(&mca_mpool_base_tree,
&((mca_mpool_base_chunk_t *)item)->key, item);
@ -286,6 +288,8 @@ void * mca_mpool_base_alloc(size_t size, ompi_info_t * info)
}
OMPI_FREE_LIST_GET(&mca_mpool_base_mem_list, item, i);
memset( ((mca_mpool_base_chunk_t *) item)->mpools, 0, sizeof(mca_mpool_base_reg_mpool_t) * MCA_MPOOL_BASE_MAX_REG);
if(NULL == no_reg_function && 0 == reg_module_num)
{
free(has_reg_function);

Просмотреть файл

@ -40,14 +40,14 @@ mca_mpool_mvapi_component_t mca_mpool_mvapi_component = {
/* Indicate that we are a mpool v1.0.0 component (which also
implies a specific MCA version) */
MCA_MPOOL_BASE_VERSION_1_0_0,
"vapi", /* MCA component name */
OMPI_MAJOR_VERSION, /* MCA component major version */
OMPI_MINOR_VERSION, /* MCA component minor version */
OMPI_RELEASE_VERSION, /* MCA component release version */
mca_mpool_mvapi_open, /* component open */
NULL
MCA_MPOOL_BASE_VERSION_1_0_0,
"mvapi", /* MCA component name */
OMPI_MAJOR_VERSION, /* MCA component major version */
OMPI_MINOR_VERSION, /* MCA component minor version */
OMPI_RELEASE_VERSION, /* MCA component release version */
mca_mpool_mvapi_open, /* component open */
NULL
},
/* Next the MCA v1.0.0 component meta data */

Просмотреть файл

@ -125,7 +125,7 @@ int mca_mpool_mvapi_deregister(mca_mpool_base_module_t* mpool, void *addr, size_
opal_output(0, "%s: error unpinning vapi memory\n", __func__);
return OMPI_ERROR;
}
free(registration);
return OMPI_SUCCESS;
}

Просмотреть файл

@ -39,15 +39,15 @@ mca_mpool_openib_component_t mca_mpool_openib_component = {
{
/* Indicate that we are a mpool v1.0.0 component (which also
implies a specific MCA version) */
MCA_MPOOL_BASE_VERSION_1_0_0,
"vapi", /* MCA component name */
OMPI_MAJOR_VERSION, /* MCA component major version */
OMPI_MINOR_VERSION, /* MCA component minor version */
OMPI_RELEASE_VERSION, /* MCA component release version */
mca_mpool_openib_open, /* component open */
NULL
MCA_MPOOL_BASE_VERSION_1_0_0,
"openib", /* MCA component name */
OMPI_MAJOR_VERSION, /* MCA component major version */
OMPI_MINOR_VERSION, /* MCA component minor version */
OMPI_RELEASE_VERSION, /* MCA component release version */
mca_mpool_openib_open, /* component open */
NULL
},
/* Next the MCA v1.0.0 component meta data */