add sleep depending on MPI rank to avoid all ranks calling daos_fini()
at once (issue with PSM2). Signed-off-by: Mohamad Chaarawi <mohamad.chaarawi@intel.com>master
parent
1320aa279c
commit
b3663bd29a
|
@ -17,6 +17,8 @@
|
||||||
* This file implements the abstract I/O interface for DAOS Array API.
|
* This file implements the abstract I/O interface for DAOS Array API.
|
||||||
*/
|
*/
|
||||||
|
|
||||||
|
#define _BSD_SOURCE
|
||||||
|
|
||||||
#ifdef HAVE_CONFIG_H
|
#ifdef HAVE_CONFIG_H
|
||||||
#include "config.h"
|
#include "config.h"
|
||||||
#endif
|
#endif
|
||||||
|
@ -320,6 +322,9 @@ DAOS_Fini()
|
||||||
rc = daos_pool_disconnect(poh, NULL);
|
rc = daos_pool_disconnect(poh, NULL);
|
||||||
DCHECK(rc, "Failed to disconnect from pool %s", o.pool);
|
DCHECK(rc, "Failed to disconnect from pool %s", o.pool);
|
||||||
|
|
||||||
|
MPI_CHECK(MPI_Barrier(MPI_COMM_WORLD), "barrier error");
|
||||||
|
usleep(20000 * rank);
|
||||||
|
|
||||||
rc = daos_fini();
|
rc = daos_fini();
|
||||||
DCHECK(rc, "Failed to finalize daos");
|
DCHECK(rc, "Failed to finalize daos");
|
||||||
|
|
||||||
|
|
|
@ -16,6 +16,8 @@
|
||||||
* This file implements the abstract I/O interface for DAOS FS API.
|
* This file implements the abstract I/O interface for DAOS FS API.
|
||||||
*/
|
*/
|
||||||
|
|
||||||
|
#define _BSD_SOURCE
|
||||||
|
|
||||||
#ifdef HAVE_CONFIG_H
|
#ifdef HAVE_CONFIG_H
|
||||||
#include "config.h"
|
#include "config.h"
|
||||||
#endif
|
#endif
|
||||||
|
@ -471,6 +473,9 @@ DFS_Finalize()
|
||||||
daos_pool_disconnect(poh, NULL);
|
daos_pool_disconnect(poh, NULL);
|
||||||
DCHECK(rc, "Failed to disconnect from pool");
|
DCHECK(rc, "Failed to disconnect from pool");
|
||||||
|
|
||||||
|
MPI_CHECK(MPI_Barrier(MPI_COMM_WORLD), "barrier error");
|
||||||
|
usleep(20000 * rank);
|
||||||
|
|
||||||
rc = daos_fini();
|
rc = daos_fini();
|
||||||
DCHECK(rc, "Failed to finalize DAOS");
|
DCHECK(rc, "Failed to finalize DAOS");
|
||||||
}
|
}
|
||||||
|
|
Loading…
Reference in New Issue