Fix warnings from progress thread patch.
This commit was SVN r12434.
Этот коммит содержится в:
родитель
82f7c0dd69
Коммит
b4fd2d7d50
@ -771,8 +771,6 @@ int mca_btl_openib_get( mca_btl_base_module_t* btl,
|
|||||||
*/
|
*/
|
||||||
int mca_btl_openib_create_cq_srq(mca_btl_openib_module_t *openib_btl)
|
int mca_btl_openib_create_cq_srq(mca_btl_openib_module_t *openib_btl)
|
||||||
{
|
{
|
||||||
int rc;
|
|
||||||
|
|
||||||
/* Allocate Protection Domain */
|
/* Allocate Protection Domain */
|
||||||
openib_btl->poll_cq = false;
|
openib_btl->poll_cq = false;
|
||||||
|
|
||||||
@ -882,6 +880,7 @@ int mca_btl_openib_create_cq_srq(mca_btl_openib_module_t *openib_btl)
|
|||||||
}
|
}
|
||||||
OPAL_THREAD_LOCK(&openib_btl->hca->hca_lock);
|
OPAL_THREAD_LOCK(&openib_btl->hca->hca_lock);
|
||||||
if (!openib_btl->hca->progress){
|
if (!openib_btl->hca->progress){
|
||||||
|
int rc;
|
||||||
openib_btl->hca->progress = true;
|
openib_btl->hca->progress = true;
|
||||||
if(OPAL_SUCCESS != (rc = opal_thread_start(&openib_btl->hca->thread))) {
|
if(OPAL_SUCCESS != (rc = opal_thread_start(&openib_btl->hca->thread))) {
|
||||||
BTL_ERROR(("Unable to create progress thread, retval=%d", rc));
|
BTL_ERROR(("Unable to create progress thread, retval=%d", rc));
|
||||||
|
@ -453,8 +453,8 @@ static int init_one_hca(opal_list_t *btl_list, struct ibv_device* ib_dev)
|
|||||||
|
|
||||||
#if OMPI_ENABLE_PROGRESS_THREADS == 1
|
#if OMPI_ENABLE_PROGRESS_THREADS == 1
|
||||||
ibv_destroy_comp_channel(hca->ib_channel);
|
ibv_destroy_comp_channel(hca->ib_channel);
|
||||||
#endif
|
|
||||||
mpool_destroy:
|
mpool_destroy:
|
||||||
|
#endif
|
||||||
mca_mpool_base_module_destroy(hca->mpool);
|
mca_mpool_base_module_destroy(hca->mpool);
|
||||||
dealloc_pd:
|
dealloc_pd:
|
||||||
ibv_dealloc_pd(hca->ib_pd);
|
ibv_dealloc_pd(hca->ib_pd);
|
||||||
@ -1038,13 +1038,10 @@ void* mca_btl_openib_progress_thread(opal_object_t* arg)
|
|||||||
*/
|
*/
|
||||||
static int btl_openib_component_progress(void)
|
static int btl_openib_component_progress(void)
|
||||||
{
|
{
|
||||||
static char *qp_name[] = {"HP", "LP"};
|
int i, j, c;
|
||||||
int i, j, c, qp;
|
int count = 0, ret;
|
||||||
int count = 0,ne = 0, ret;
|
|
||||||
mca_btl_openib_frag_t* frag;
|
mca_btl_openib_frag_t* frag;
|
||||||
mca_btl_openib_endpoint_t* endpoint;
|
mca_btl_openib_endpoint_t* endpoint;
|
||||||
struct ibv_wc wc;
|
|
||||||
mca_btl_openib_module_t* openib_btl;
|
|
||||||
|
|
||||||
/* Poll for RDMA completions - if any succeed, we don't process the slower
|
/* Poll for RDMA completions - if any succeed, we don't process the slower
|
||||||
* queues.
|
* queues.
|
||||||
@ -1101,14 +1098,16 @@ static int btl_openib_component_progress(void)
|
|||||||
if(count) return count;
|
if(count) return count;
|
||||||
|
|
||||||
for(i = 0; i < mca_btl_openib_component.ib_num_btls; i++) {
|
for(i = 0; i < mca_btl_openib_component.ib_num_btls; i++) {
|
||||||
return btl_openib_module_progress(&mca_btl_openib_component.openib_btls[i]);
|
count += btl_openib_module_progress(&mca_btl_openib_component.openib_btls[i]);
|
||||||
}
|
}
|
||||||
|
|
||||||
|
return count;
|
||||||
}
|
}
|
||||||
|
|
||||||
static int btl_openib_module_progress(mca_btl_openib_module_t* openib_btl)
|
static int btl_openib_module_progress(mca_btl_openib_module_t* openib_btl)
|
||||||
{
|
{
|
||||||
static char *qp_name[] = {"HP", "LP"};
|
static char *qp_name[] = {"HP", "LP"};
|
||||||
int i, j, c, qp;
|
int qp;
|
||||||
int count = 0,ne = 0, ret;
|
int count = 0,ne = 0, ret;
|
||||||
mca_btl_openib_frag_t* frag;
|
mca_btl_openib_frag_t* frag;
|
||||||
mca_btl_openib_endpoint_t* endpoint;
|
mca_btl_openib_endpoint_t* endpoint;
|
||||||
|
@ -1238,7 +1238,6 @@ void mca_btl_openib_endpoint_connect_eager_rdma(
|
|||||||
return;
|
return;
|
||||||
}
|
}
|
||||||
|
|
||||||
cleanup:
|
|
||||||
openib_btl->super.btl_mpool->mpool_free(openib_btl->super.btl_mpool,
|
openib_btl->super.btl_mpool->mpool_free(openib_btl->super.btl_mpool,
|
||||||
buf, (mca_mpool_base_registration_t*)endpoint->eager_rdma_local.reg);
|
buf, (mca_mpool_base_registration_t*)endpoint->eager_rdma_local.reg);
|
||||||
unlock_rdma_local:
|
unlock_rdma_local:
|
||||||
|
Загрузка…
x
Ссылка в новой задаче
Block a user