1
1

osc/ucx: Fix worker pool finalization

Signed-off-by: Artem Polyakov <artpol84@gmail.com>
Этот коммит содержится в:
Artem Polyakov 2019-06-11 13:16:29 -07:00
родитель fd27d76130
Коммит 0857742624

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

@ -141,6 +141,9 @@ static int component_init(bool enable_progress_threads, bool enable_mpi_threads)
static int component_finalize(void) { static int component_finalize(void) {
opal_common_ucx_mca_deregister(); opal_common_ucx_mca_deregister();
if (mca_osc_ucx_component.env_initialized) {
opal_common_ucx_wpool_finalize(mca_osc_ucx_component.wpool);
}
opal_common_ucx_wpool_free(mca_osc_ucx_component.wpool); opal_common_ucx_wpool_free(mca_osc_ucx_component.wpool);
return OMPI_SUCCESS; return OMPI_SUCCESS;
} }
@ -576,8 +579,6 @@ int ompi_osc_ucx_free(struct ompi_win_t *win) {
opal_common_ucx_wpctx_release(module->ctx); opal_common_ucx_wpctx_release(module->ctx);
opal_common_ucx_wpool_finalize(mca_osc_ucx_component.wpool);
if (module->disp_units) free(module->disp_units); if (module->disp_units) free(module->disp_units);
ompi_comm_free(&module->comm); ompi_comm_free(&module->comm);