Merge pull request #4352 from edgargabriel/pr/sem_close_fix
sharedfp/sm: close the named semaphore
Этот коммит содержится в:
Коммит
9771c575f5
@ -231,6 +231,12 @@ int mca_sharedfp_sm_file_open (struct ompi_communicator_t *comm,
|
|||||||
|
|
||||||
comm->c_coll->coll_barrier (comm, comm->c_coll->coll_barrier_module );
|
comm->c_coll->coll_barrier (comm, comm->c_coll->coll_barrier_module );
|
||||||
|
|
||||||
|
#if defined(HAVE_SEM_OPEN)
|
||||||
|
if ( 0 == rank ) {
|
||||||
|
sem_unlink ( sm_data->sem_name);
|
||||||
|
}
|
||||||
|
#endif
|
||||||
|
|
||||||
return err;
|
return err;
|
||||||
}
|
}
|
||||||
|
|
||||||
@ -263,7 +269,7 @@ int mca_sharedfp_sm_file_close (mca_io_ompio_file_t *fh)
|
|||||||
if (file_data->sm_offset_ptr) {
|
if (file_data->sm_offset_ptr) {
|
||||||
/* destroy semaphore */
|
/* destroy semaphore */
|
||||||
#if defined(HAVE_SEM_OPEN)
|
#if defined(HAVE_SEM_OPEN)
|
||||||
sem_unlink (file_data->sem_name);
|
sem_close ( file_data->mutex);
|
||||||
free (file_data->sem_name);
|
free (file_data->sem_name);
|
||||||
#elif defined(HAVE_SEM_INIT)
|
#elif defined(HAVE_SEM_INIT)
|
||||||
sem_destroy(&file_data->sm_offset_ptr->mutex);
|
sem_destroy(&file_data->sm_offset_ptr->mutex);
|
||||||
|
Загрузка…
x
Ссылка в новой задаче
Block a user