Remove those pesky ^M's. :-)
This commit was SVN r3170.
Этот коммит содержится в:
Jeff Squyres
родитель
418920f50f
Коммит
a965e2dd62
@ -1,418 +1,418 @@
|
|||||||
/*
|
/*
|
||||||
* $HEADER$
|
* $HEADER$
|
||||||
*
|
*
|
||||||
* $Id: tmpdir.c $
|
* $Id: tmpdir.c $
|
||||||
*
|
*
|
||||||
* Function: -
|
* Function: -
|
||||||
*/
|
*/
|
||||||
|
|
||||||
#include "ompi_config.h"
|
#include "ompi_config.h"
|
||||||
|
|
||||||
#include <stdio.h>
|
#include <stdio.h>
|
||||||
#include <pwd.h>
|
#include <pwd.h>
|
||||||
#include <stddef.h>
|
#include <stddef.h>
|
||||||
#include <stdlib.h>
|
#include <stdlib.h>
|
||||||
#include <string.h>
|
#include <string.h>
|
||||||
#include <libgen.h>
|
#include <libgen.h>
|
||||||
#include <sys/param.h>
|
#include <sys/param.h>
|
||||||
#include <sys/types.h>
|
#include <sys/types.h>
|
||||||
#include <sys/stat.h>
|
#include <sys/stat.h>
|
||||||
#include <unistd.h>
|
#include <unistd.h>
|
||||||
#include <errno.h>
|
#include <errno.h>
|
||||||
#include <dirent.h>
|
#include <dirent.h>
|
||||||
|
|
||||||
/*
|
/*
|
||||||
#include <sys/socket.h>
|
#include <sys/socket.h>
|
||||||
#include <netdb.h> MAXHOSTNAMELEN in Solaris
|
#include <netdb.h> MAXHOSTNAMELEN in Solaris
|
||||||
#include <unistd.h>
|
#include <unistd.h>
|
||||||
#include <errno.h>
|
#include <errno.h>
|
||||||
#include <dirent.h>
|
#include <dirent.h>
|
||||||
|
|
||||||
#include <ompi_debug.h>
|
#include <ompi_debug.h>
|
||||||
#include <ompi_internal.h>
|
#include <ompi_internal.h>
|
||||||
#include <terror.h>
|
#include <terror.h>
|
||||||
#include <typical.h>
|
#include <typical.h>
|
||||||
#include <etc_misc.h>
|
#include <etc_misc.h>
|
||||||
*/
|
*/
|
||||||
|
|
||||||
#include "include/constants.h"
|
#include "include/constants.h"
|
||||||
|
|
||||||
#include "util/sys_info.h"
|
#include "util/sys_info.h"
|
||||||
#include "util/proc_info.h"
|
#include "util/proc_info.h"
|
||||||
#include "util/output.h"
|
#include "util/output.h"
|
||||||
#include "util/os_path.h"
|
#include "util/os_path.h"
|
||||||
#include "util/os_create_dirpath.h"
|
#include "util/os_create_dirpath.h"
|
||||||
|
|
||||||
#include "runtime/runtime.h"
|
#include "runtime/runtime.h"
|
||||||
|
|
||||||
#include "util/session_dir.h"
|
#include "util/session_dir.h"
|
||||||
|
|
||||||
static int ompi_check_dir(bool create, char *directory);
|
static int ompi_check_dir(bool create, char *directory);
|
||||||
|
|
||||||
static void ompi_dir_empty(char *pathname);
|
static void ompi_dir_empty(char *pathname);
|
||||||
|
|
||||||
static bool ompi_is_empty(char *pathname);
|
static bool ompi_is_empty(char *pathname);
|
||||||
|
|
||||||
|
|
||||||
#define OMPI_DEFAULT_TMPDIR "tmp"
|
#define OMPI_DEFAULT_TMPDIR "tmp"
|
||||||
|
|
||||||
static int ompi_check_dir(bool create, char *directory)
|
static int ompi_check_dir(bool create, char *directory)
|
||||||
{
|
{
|
||||||
struct stat buf;
|
struct stat buf;
|
||||||
mode_t my_mode = S_IRWXU; /* at the least, I need to be able to do anything */
|
mode_t my_mode = S_IRWXU; /* at the least, I need to be able to do anything */
|
||||||
|
|
||||||
if (0 == stat(directory, &buf)) { /* exists - check access */
|
if (0 == stat(directory, &buf)) { /* exists - check access */
|
||||||
if ((buf.st_mode & my_mode) == my_mode) { /* okay, I can work here */
|
if ((buf.st_mode & my_mode) == my_mode) { /* okay, I can work here */
|
||||||
return(OMPI_SUCCESS);
|
return(OMPI_SUCCESS);
|
||||||
}
|
}
|
||||||
}
|
}
|
||||||
if (create) {
|
if (create) {
|
||||||
return(ompi_os_create_dirpath(directory, my_mode)); /* try to create it with proper mode */
|
return(ompi_os_create_dirpath(directory, my_mode)); /* try to create it with proper mode */
|
||||||
}
|
}
|
||||||
return(OMPI_ERROR); /* couldn't find it, or don't have access rights, and not asked to create it */
|
return(OMPI_ERROR); /* couldn't find it, or don't have access rights, and not asked to create it */
|
||||||
}
|
}
|
||||||
|
|
||||||
int ompi_session_dir(bool create, char *prfx, char *usr, char *hostid,
|
int ompi_session_dir(bool create, char *prfx, char *usr, char *hostid,
|
||||||
char *batchid, char *univ, char *job, char *proc)
|
char *batchid, char *univ, char *job, char *proc)
|
||||||
{
|
{
|
||||||
char *fulldirpath=NULL, *tmp=NULL, *hostname=NULL, *batchname=NULL;
|
char *fulldirpath=NULL, *tmp=NULL, *hostname=NULL, *batchname=NULL;
|
||||||
char *sessions=NULL, *frontend=NULL, *user=NULL, *universe=NULL;
|
char *sessions=NULL, *frontend=NULL, *user=NULL, *universe=NULL;
|
||||||
char *prefix=NULL, *sav=NULL;
|
char *prefix=NULL, *sav=NULL;
|
||||||
int return_code;
|
int return_code;
|
||||||
|
|
||||||
/* ensure that system info is set */
|
/* ensure that system info is set */
|
||||||
ompi_sys_info();
|
ompi_sys_info();
|
||||||
|
|
||||||
if (NULL == usr) { /* check if user set elsewhere */
|
if (NULL == usr) { /* check if user set elsewhere */
|
||||||
if (NULL == ompi_system_info.user) { /* error condition */
|
if (NULL == ompi_system_info.user) { /* error condition */
|
||||||
return OMPI_ERROR;
|
return OMPI_ERROR;
|
||||||
} else {
|
} else {
|
||||||
user = strdup(ompi_system_info.user);
|
user = strdup(ompi_system_info.user);
|
||||||
}
|
}
|
||||||
} else {
|
} else {
|
||||||
user = strdup(usr);
|
user = strdup(usr);
|
||||||
}
|
}
|
||||||
|
|
||||||
if (NULL == univ) { /* see if universe set elsewhere */
|
if (NULL == univ) { /* see if universe set elsewhere */
|
||||||
if (NULL == ompi_process_info.my_universe) { /* error condition */
|
if (NULL == ompi_process_info.my_universe) { /* error condition */
|
||||||
return OMPI_ERROR;
|
return OMPI_ERROR;
|
||||||
} else {
|
} else {
|
||||||
universe = strdup(ompi_process_info.my_universe);
|
universe = strdup(ompi_process_info.my_universe);
|
||||||
}
|
}
|
||||||
} else {
|
} else {
|
||||||
universe = strdup(univ);
|
universe = strdup(univ);
|
||||||
}
|
}
|
||||||
|
|
||||||
if (NULL == job && NULL != proc) { /* can't give a proc without a job */
|
if (NULL == job && NULL != proc) { /* can't give a proc without a job */
|
||||||
return OMPI_ERROR;
|
return OMPI_ERROR;
|
||||||
}
|
}
|
||||||
|
|
||||||
if (NULL == hostid) { /* check if hostname set elsewhere */
|
if (NULL == hostid) { /* check if hostname set elsewhere */
|
||||||
if (NULL == ompi_system_info.nodename) { /* don't have a hostname anywhere - error */
|
if (NULL == ompi_system_info.nodename) { /* don't have a hostname anywhere - error */
|
||||||
return_code = OMPI_ERROR;
|
return_code = OMPI_ERROR;
|
||||||
goto CLEANUP;
|
goto CLEANUP;
|
||||||
} else {
|
} else {
|
||||||
hostname = strdup(ompi_system_info.nodename);
|
hostname = strdup(ompi_system_info.nodename);
|
||||||
}
|
}
|
||||||
} else {
|
} else {
|
||||||
hostname = strdup(hostid);
|
hostname = strdup(hostid);
|
||||||
}
|
}
|
||||||
|
|
||||||
if (NULL == batchid) {
|
if (NULL == batchid) {
|
||||||
batchname = strdup("0");
|
batchname = strdup("0");
|
||||||
} else {
|
} else {
|
||||||
batchname = batchid;
|
batchname = batchid;
|
||||||
}
|
}
|
||||||
|
|
||||||
if (NULL == ompi_process_info.top_session_dir) {
|
if (NULL == ompi_process_info.top_session_dir) {
|
||||||
if (0 > asprintf(&frontend, "openmpi-sessions-%s@%s:%s", user, hostname, batchname)) {
|
if (0 > asprintf(&frontend, "openmpi-sessions-%s@%s:%s", user, hostname, batchname)) {
|
||||||
return_code = OMPI_ERROR;
|
return_code = OMPI_ERROR;
|
||||||
goto CLEANUP;
|
goto CLEANUP;
|
||||||
}
|
}
|
||||||
} else {
|
} else {
|
||||||
frontend = strdup(ompi_process_info.top_session_dir);
|
frontend = strdup(ompi_process_info.top_session_dir);
|
||||||
}
|
}
|
||||||
|
|
||||||
|
|
||||||
if (NULL != proc) {
|
if (NULL != proc) {
|
||||||
if (0 > asprintf(&sessions, "%s%s%s%s%s%s%s", frontend,
|
if (0 > asprintf(&sessions, "%s%s%s%s%s%s%s", frontend,
|
||||||
ompi_system_info.path_sep, universe,
|
ompi_system_info.path_sep, universe,
|
||||||
ompi_system_info.path_sep, job,
|
ompi_system_info.path_sep, job,
|
||||||
ompi_system_info.path_sep, proc)) {
|
ompi_system_info.path_sep, proc)) {
|
||||||
return_code = OMPI_ERROR;
|
return_code = OMPI_ERROR;
|
||||||
goto CLEANUP;
|
goto CLEANUP;
|
||||||
}
|
}
|
||||||
} else if (NULL != job) {
|
} else if (NULL != job) {
|
||||||
if (0 > asprintf(&sessions, "%s%s%s%s%s", frontend,
|
if (0 > asprintf(&sessions, "%s%s%s%s%s", frontend,
|
||||||
ompi_system_info.path_sep, universe,
|
ompi_system_info.path_sep, universe,
|
||||||
ompi_system_info.path_sep, job)) {
|
ompi_system_info.path_sep, job)) {
|
||||||
return_code = OMPI_ERROR;
|
return_code = OMPI_ERROR;
|
||||||
goto CLEANUP;
|
goto CLEANUP;
|
||||||
}
|
}
|
||||||
} else {
|
} else {
|
||||||
if (0 > asprintf(&sessions, "%s%s%s", frontend, ompi_system_info.path_sep, universe)) {
|
if (0 > asprintf(&sessions, "%s%s%s", frontend, ompi_system_info.path_sep, universe)) {
|
||||||
return_code = OMPI_ERROR;
|
return_code = OMPI_ERROR;
|
||||||
goto CLEANUP;
|
goto CLEANUP;
|
||||||
}
|
}
|
||||||
}
|
}
|
||||||
|
|
||||||
|
|
||||||
if (NULL != prefix) { /* if a prefix is specified, start looking here */
|
if (NULL != prefix) { /* if a prefix is specified, start looking here */
|
||||||
tmp = strdup(prefix);
|
tmp = strdup(prefix);
|
||||||
fulldirpath = strdup(ompi_os_path(false, tmp, sessions, NULL)); /* make sure it's an absolute pathname */
|
fulldirpath = strdup(ompi_os_path(false, tmp, sessions, NULL)); /* make sure it's an absolute pathname */
|
||||||
if (OMPI_SUCCESS == ompi_check_dir(create, fulldirpath)) { /* check for existence and access, or create it */
|
if (OMPI_SUCCESS == ompi_check_dir(create, fulldirpath)) { /* check for existence and access, or create it */
|
||||||
return_code = OMPI_SUCCESS;
|
return_code = OMPI_SUCCESS;
|
||||||
goto COMPLETE;
|
goto COMPLETE;
|
||||||
}
|
}
|
||||||
}
|
}
|
||||||
|
|
||||||
/* no prefix was specified, so check other options in order */
|
/* no prefix was specified, so check other options in order */
|
||||||
if (NULL != ompi_process_info.tmpdir_base) { /* stored value previously */
|
if (NULL != ompi_process_info.tmpdir_base) { /* stored value previously */
|
||||||
tmp = strdup(ompi_process_info.tmpdir_base);
|
tmp = strdup(ompi_process_info.tmpdir_base);
|
||||||
fulldirpath = strdup(ompi_os_path(false, tmp, sessions, NULL));
|
fulldirpath = strdup(ompi_os_path(false, tmp, sessions, NULL));
|
||||||
if (OMPI_SUCCESS == ompi_check_dir(create, fulldirpath)) { /* check for existence and access, or create it */
|
if (OMPI_SUCCESS == ompi_check_dir(create, fulldirpath)) { /* check for existence and access, or create it */
|
||||||
return_code = OMPI_SUCCESS;
|
return_code = OMPI_SUCCESS;
|
||||||
goto COMPLETE;
|
goto COMPLETE;
|
||||||
}
|
}
|
||||||
} else if (NULL != getenv("OMPI_PREFIX_ENV")) { /* we have prefix enviro var - try that next */
|
} else if (NULL != getenv("OMPI_PREFIX_ENV")) { /* we have prefix enviro var - try that next */
|
||||||
tmp = strdup(getenv("OMPI_PREFIX_ENV"));
|
tmp = strdup(getenv("OMPI_PREFIX_ENV"));
|
||||||
fulldirpath = strdup(ompi_os_path(false, tmp, sessions, NULL));
|
fulldirpath = strdup(ompi_os_path(false, tmp, sessions, NULL));
|
||||||
if (OMPI_SUCCESS == ompi_check_dir(create, fulldirpath)) { /* check for existence and access, or create it */
|
if (OMPI_SUCCESS == ompi_check_dir(create, fulldirpath)) { /* check for existence and access, or create it */
|
||||||
return_code = OMPI_SUCCESS;
|
return_code = OMPI_SUCCESS;
|
||||||
goto COMPLETE;
|
goto COMPLETE;
|
||||||
}
|
}
|
||||||
} else if (NULL != getenv("TMPDIR")) {
|
} else if (NULL != getenv("TMPDIR")) {
|
||||||
tmp = strdup(getenv("TMPDIR"));
|
tmp = strdup(getenv("TMPDIR"));
|
||||||
fulldirpath = strdup(ompi_os_path(false, tmp, sessions, NULL));
|
fulldirpath = strdup(ompi_os_path(false, tmp, sessions, NULL));
|
||||||
if (OMPI_SUCCESS == ompi_check_dir(create, fulldirpath)) { /* check for existence and access, or create it */
|
if (OMPI_SUCCESS == ompi_check_dir(create, fulldirpath)) { /* check for existence and access, or create it */
|
||||||
return_code = OMPI_SUCCESS;
|
return_code = OMPI_SUCCESS;
|
||||||
goto COMPLETE;
|
goto COMPLETE;
|
||||||
}
|
}
|
||||||
} else if (NULL != getenv("TMP")) {
|
} else if (NULL != getenv("TMP")) {
|
||||||
tmp = strdup(getenv("TMP"));
|
tmp = strdup(getenv("TMP"));
|
||||||
fulldirpath = strdup(ompi_os_path(false, tmp, sessions, NULL));
|
fulldirpath = strdup(ompi_os_path(false, tmp, sessions, NULL));
|
||||||
if (OMPI_SUCCESS == ompi_check_dir(create, fulldirpath)) { /* check for existence and access, or create it */
|
if (OMPI_SUCCESS == ompi_check_dir(create, fulldirpath)) { /* check for existence and access, or create it */
|
||||||
return_code = OMPI_SUCCESS;
|
return_code = OMPI_SUCCESS;
|
||||||
goto COMPLETE;
|
goto COMPLETE;
|
||||||
}
|
}
|
||||||
} else {
|
} else {
|
||||||
tmp = strdup(OMPI_DEFAULT_TMPDIR);
|
tmp = strdup(OMPI_DEFAULT_TMPDIR);
|
||||||
fulldirpath = strdup(ompi_os_path(false, tmp, sessions, NULL));
|
fulldirpath = strdup(ompi_os_path(false, tmp, sessions, NULL));
|
||||||
if (OMPI_SUCCESS == ompi_check_dir(create, fulldirpath)) { /* check for existence and access, or create it */
|
if (OMPI_SUCCESS == ompi_check_dir(create, fulldirpath)) { /* check for existence and access, or create it */
|
||||||
return_code = OMPI_SUCCESS;
|
return_code = OMPI_SUCCESS;
|
||||||
goto COMPLETE;
|
goto COMPLETE;
|
||||||
}
|
}
|
||||||
}
|
}
|
||||||
|
|
||||||
fulldirpath = strdup(ompi_os_path(false, tmp, sessions, NULL));
|
fulldirpath = strdup(ompi_os_path(false, tmp, sessions, NULL));
|
||||||
if (OMPI_SUCCESS == ompi_check_dir(create, fulldirpath)) { /* check for existence and access, or create it */
|
if (OMPI_SUCCESS == ompi_check_dir(create, fulldirpath)) { /* check for existence and access, or create it */
|
||||||
return_code = OMPI_SUCCESS;
|
return_code = OMPI_SUCCESS;
|
||||||
goto COMPLETE;
|
goto COMPLETE;
|
||||||
} else {
|
} else {
|
||||||
return_code = OMPI_ERROR;
|
return_code = OMPI_ERROR;
|
||||||
goto CLEANUP;
|
goto CLEANUP;
|
||||||
}
|
}
|
||||||
|
|
||||||
COMPLETE:
|
COMPLETE:
|
||||||
if (create) { /* if creating the dir tree, overwrite the fields */
|
if (create) { /* if creating the dir tree, overwrite the fields */
|
||||||
if (NULL != ompi_process_info.tmpdir_base) {
|
if (NULL != ompi_process_info.tmpdir_base) {
|
||||||
free(ompi_process_info.tmpdir_base);
|
free(ompi_process_info.tmpdir_base);
|
||||||
ompi_process_info.tmpdir_base = NULL;
|
ompi_process_info.tmpdir_base = NULL;
|
||||||
}
|
}
|
||||||
|
|
||||||
if (NULL != ompi_process_info.top_session_dir) {
|
if (NULL != ompi_process_info.top_session_dir) {
|
||||||
free(ompi_process_info.top_session_dir);
|
free(ompi_process_info.top_session_dir);
|
||||||
ompi_process_info.top_session_dir = NULL;
|
ompi_process_info.top_session_dir = NULL;
|
||||||
}
|
}
|
||||||
}
|
}
|
||||||
|
|
||||||
if (NULL == ompi_process_info.tmpdir_base) {
|
if (NULL == ompi_process_info.tmpdir_base) {
|
||||||
ompi_process_info.tmpdir_base = strdup(tmp); /* fill in if empty */
|
ompi_process_info.tmpdir_base = strdup(tmp); /* fill in if empty */
|
||||||
}
|
}
|
||||||
|
|
||||||
if (NULL == ompi_process_info.top_session_dir) {
|
if (NULL == ompi_process_info.top_session_dir) {
|
||||||
ompi_process_info.top_session_dir = strdup(frontend);
|
ompi_process_info.top_session_dir = strdup(frontend);
|
||||||
}
|
}
|
||||||
|
|
||||||
if (NULL != proc) {
|
if (NULL != proc) {
|
||||||
if (create) { /* overwrite if creating */
|
if (create) { /* overwrite if creating */
|
||||||
if (NULL != ompi_process_info.proc_session_dir) {
|
if (NULL != ompi_process_info.proc_session_dir) {
|
||||||
free(ompi_process_info.proc_session_dir);
|
free(ompi_process_info.proc_session_dir);
|
||||||
ompi_process_info.proc_session_dir = NULL;
|
ompi_process_info.proc_session_dir = NULL;
|
||||||
}
|
}
|
||||||
}
|
}
|
||||||
if (NULL == ompi_process_info.proc_session_dir) {
|
if (NULL == ompi_process_info.proc_session_dir) {
|
||||||
ompi_process_info.proc_session_dir = strdup(fulldirpath);
|
ompi_process_info.proc_session_dir = strdup(fulldirpath);
|
||||||
}
|
}
|
||||||
sav = strdup(fulldirpath);
|
sav = strdup(fulldirpath);
|
||||||
free(fulldirpath);
|
free(fulldirpath);
|
||||||
fulldirpath = strdup(dirname(sav));
|
fulldirpath = strdup(dirname(sav));
|
||||||
free(sav);
|
free(sav);
|
||||||
}
|
}
|
||||||
|
|
||||||
if (NULL != job) {
|
if (NULL != job) {
|
||||||
if (create) { /* overwrite if creating */
|
if (create) { /* overwrite if creating */
|
||||||
if (NULL != ompi_process_info.job_session_dir) {
|
if (NULL != ompi_process_info.job_session_dir) {
|
||||||
free(ompi_process_info.job_session_dir);
|
free(ompi_process_info.job_session_dir);
|
||||||
ompi_process_info.job_session_dir = NULL;
|
ompi_process_info.job_session_dir = NULL;
|
||||||
}
|
}
|
||||||
}
|
}
|
||||||
if (NULL == ompi_process_info.job_session_dir) {
|
if (NULL == ompi_process_info.job_session_dir) {
|
||||||
ompi_process_info.job_session_dir = strdup(fulldirpath);
|
ompi_process_info.job_session_dir = strdup(fulldirpath);
|
||||||
}
|
}
|
||||||
sav = strdup(fulldirpath);
|
sav = strdup(fulldirpath);
|
||||||
free(fulldirpath);
|
free(fulldirpath);
|
||||||
fulldirpath = strdup(dirname(sav));
|
fulldirpath = strdup(dirname(sav));
|
||||||
free(sav);
|
free(sav);
|
||||||
}
|
}
|
||||||
|
|
||||||
if (create) { /* overwrite if creating */
|
if (create) { /* overwrite if creating */
|
||||||
if (NULL != ompi_process_info.universe_session_dir) {
|
if (NULL != ompi_process_info.universe_session_dir) {
|
||||||
free(ompi_process_info.universe_session_dir);
|
free(ompi_process_info.universe_session_dir);
|
||||||
ompi_process_info.universe_session_dir = NULL;
|
ompi_process_info.universe_session_dir = NULL;
|
||||||
}
|
}
|
||||||
}
|
}
|
||||||
if (NULL == ompi_process_info.universe_session_dir) {
|
if (NULL == ompi_process_info.universe_session_dir) {
|
||||||
ompi_process_info.universe_session_dir = strdup(fulldirpath);
|
ompi_process_info.universe_session_dir = strdup(fulldirpath);
|
||||||
}
|
}
|
||||||
|
|
||||||
if (ompi_rte_debug_flag) {
|
if (ompi_rte_debug_flag) {
|
||||||
ompi_output(0, "procdir: %s", ompi_process_info.proc_session_dir);
|
ompi_output(0, "procdir: %s", ompi_process_info.proc_session_dir);
|
||||||
ompi_output(0, "jobdir: %s", ompi_process_info.job_session_dir);
|
ompi_output(0, "jobdir: %s", ompi_process_info.job_session_dir);
|
||||||
ompi_output(0, "unidir: %s", ompi_process_info.universe_session_dir);
|
ompi_output(0, "unidir: %s", ompi_process_info.universe_session_dir);
|
||||||
ompi_output(0, "top: %s", ompi_process_info.top_session_dir);
|
ompi_output(0, "top: %s", ompi_process_info.top_session_dir);
|
||||||
ompi_output(0, "tmp: %s", ompi_process_info.tmpdir_base);
|
ompi_output(0, "tmp: %s", ompi_process_info.tmpdir_base);
|
||||||
}
|
}
|
||||||
|
|
||||||
CLEANUP:
|
CLEANUP:
|
||||||
if (tmp) {
|
if (tmp) {
|
||||||
free(tmp);
|
free(tmp);
|
||||||
}
|
}
|
||||||
if (fulldirpath) {
|
if (fulldirpath) {
|
||||||
free(fulldirpath);
|
free(fulldirpath);
|
||||||
}
|
}
|
||||||
if (frontend) {
|
if (frontend) {
|
||||||
free(frontend);
|
free(frontend);
|
||||||
}
|
}
|
||||||
if (batchname) {
|
if (batchname) {
|
||||||
free(batchname);
|
free(batchname);
|
||||||
}
|
}
|
||||||
if (hostname) {
|
if (hostname) {
|
||||||
free(hostname);
|
free(hostname);
|
||||||
}
|
}
|
||||||
if (sessions) {
|
if (sessions) {
|
||||||
free(sessions);
|
free(sessions);
|
||||||
}
|
}
|
||||||
|
|
||||||
return return_code;
|
return return_code;
|
||||||
}
|
}
|
||||||
|
|
||||||
|
|
||||||
int
|
int
|
||||||
ompi_session_dir_finalize()
|
ompi_session_dir_finalize()
|
||||||
{
|
{
|
||||||
ompi_dir_empty(ompi_process_info.proc_session_dir);
|
ompi_dir_empty(ompi_process_info.proc_session_dir);
|
||||||
ompi_dir_empty(ompi_process_info.job_session_dir);
|
ompi_dir_empty(ompi_process_info.job_session_dir);
|
||||||
ompi_dir_empty(ompi_process_info.universe_session_dir);
|
ompi_dir_empty(ompi_process_info.universe_session_dir);
|
||||||
ompi_dir_empty(ompi_process_info.top_session_dir);
|
ompi_dir_empty(ompi_process_info.top_session_dir);
|
||||||
|
|
||||||
if (ompi_is_empty(ompi_process_info.proc_session_dir)) {
|
if (ompi_is_empty(ompi_process_info.proc_session_dir)) {
|
||||||
if (ompi_rte_debug_flag) {
|
if (ompi_rte_debug_flag) {
|
||||||
ompi_output(0, "sess_dir_finalize: found proc session dir empty - deleting");
|
ompi_output(0, "sess_dir_finalize: found proc session dir empty - deleting");
|
||||||
}
|
}
|
||||||
rmdir(ompi_process_info.proc_session_dir);
|
rmdir(ompi_process_info.proc_session_dir);
|
||||||
} else {
|
} else {
|
||||||
if (ompi_rte_debug_flag) {
|
if (ompi_rte_debug_flag) {
|
||||||
ompi_output(0, "sess_dir_finalize: proc session dir not empty - leaving");
|
ompi_output(0, "sess_dir_finalize: proc session dir not empty - leaving");
|
||||||
}
|
}
|
||||||
return OMPI_SUCCESS;
|
return OMPI_SUCCESS;
|
||||||
}
|
}
|
||||||
|
|
||||||
if (ompi_is_empty(ompi_process_info.job_session_dir)) {
|
if (ompi_is_empty(ompi_process_info.job_session_dir)) {
|
||||||
if (ompi_rte_debug_flag) {
|
if (ompi_rte_debug_flag) {
|
||||||
ompi_output(0, "sess_dir_finalize: found job session dir empty - deleting");
|
ompi_output(0, "sess_dir_finalize: found job session dir empty - deleting");
|
||||||
}
|
}
|
||||||
rmdir(ompi_process_info.job_session_dir);
|
rmdir(ompi_process_info.job_session_dir);
|
||||||
} else {
|
} else {
|
||||||
if (ompi_rte_debug_flag) {
|
if (ompi_rte_debug_flag) {
|
||||||
ompi_output(0, "sess_dir_finalize: job session dir not empty - leaving");
|
ompi_output(0, "sess_dir_finalize: job session dir not empty - leaving");
|
||||||
}
|
}
|
||||||
return OMPI_SUCCESS;
|
return OMPI_SUCCESS;
|
||||||
}
|
}
|
||||||
|
|
||||||
if (ompi_is_empty(ompi_process_info.universe_session_dir)) {
|
if (ompi_is_empty(ompi_process_info.universe_session_dir)) {
|
||||||
if (ompi_rte_debug_flag) {
|
if (ompi_rte_debug_flag) {
|
||||||
ompi_output(0, "sess_dir_finalize: found univ session dir empty - deleting");
|
ompi_output(0, "sess_dir_finalize: found univ session dir empty - deleting");
|
||||||
}
|
}
|
||||||
rmdir(ompi_process_info.universe_session_dir);
|
rmdir(ompi_process_info.universe_session_dir);
|
||||||
} else {
|
} else {
|
||||||
if (ompi_rte_debug_flag) {
|
if (ompi_rte_debug_flag) {
|
||||||
ompi_output(0, "sess_dir_finalize: univ session dir not empty - leaving");
|
ompi_output(0, "sess_dir_finalize: univ session dir not empty - leaving");
|
||||||
}
|
}
|
||||||
return OMPI_SUCCESS;
|
return OMPI_SUCCESS;
|
||||||
}
|
}
|
||||||
|
|
||||||
if (ompi_is_empty(ompi_process_info.top_session_dir)) {
|
if (ompi_is_empty(ompi_process_info.top_session_dir)) {
|
||||||
if (ompi_rte_debug_flag) {
|
if (ompi_rte_debug_flag) {
|
||||||
ompi_output(0, "sess_dir_finalize: found top session dir empty - deleting");
|
ompi_output(0, "sess_dir_finalize: found top session dir empty - deleting");
|
||||||
}
|
}
|
||||||
rmdir(ompi_process_info.top_session_dir);
|
rmdir(ompi_process_info.top_session_dir);
|
||||||
} else {
|
} else {
|
||||||
if (ompi_rte_debug_flag) {
|
if (ompi_rte_debug_flag) {
|
||||||
ompi_output(0, "sess_dir_finalize: top session dir not empty - leaving");
|
ompi_output(0, "sess_dir_finalize: top session dir not empty - leaving");
|
||||||
}
|
}
|
||||||
}
|
}
|
||||||
|
|
||||||
return OMPI_SUCCESS;
|
return OMPI_SUCCESS;
|
||||||
}
|
}
|
||||||
|
|
||||||
static void
|
static void
|
||||||
ompi_dir_empty(char *pathname)
|
ompi_dir_empty(char *pathname)
|
||||||
{
|
{
|
||||||
DIR *dp;
|
DIR *dp;
|
||||||
struct dirent *ep;
|
struct dirent *ep;
|
||||||
char *filenm;
|
char *filenm;
|
||||||
bool empty;
|
bool empty;
|
||||||
|
|
||||||
empty = true;
|
empty = true;
|
||||||
|
|
||||||
if (NULL != pathname) { /* protect against error */
|
if (NULL != pathname) { /* protect against error */
|
||||||
dp = opendir(pathname);
|
dp = opendir(pathname);
|
||||||
if (NULL != dp) {
|
if (NULL != dp) {
|
||||||
while ((ep = readdir(dp))) {
|
while ((ep = readdir(dp))) {
|
||||||
if ((0 != strcmp(ep->d_name, ".")) &&
|
if ((0 != strcmp(ep->d_name, ".")) &&
|
||||||
(0 != strcmp(ep->d_name, "..")) &&
|
(0 != strcmp(ep->d_name, "..")) &&
|
||||||
(DT_DIR != ep->d_type) &&
|
(DT_DIR != ep->d_type) &&
|
||||||
(0 != strncmp(ep->d_name, "output-", strlen("output-"))) &&
|
(0 != strncmp(ep->d_name, "output-", strlen("output-"))) &&
|
||||||
(0 != strcmp(ep->d_name, "universe-setup.txt"))) {
|
(0 != strcmp(ep->d_name, "universe-setup.txt"))) {
|
||||||
filenm = ompi_os_path(false, pathname, ep->d_name, NULL);
|
filenm = ompi_os_path(false, pathname, ep->d_name, NULL);
|
||||||
unlink(filenm);
|
unlink(filenm);
|
||||||
}
|
}
|
||||||
}
|
}
|
||||||
closedir(dp);
|
closedir(dp);
|
||||||
}
|
}
|
||||||
}
|
}
|
||||||
}
|
}
|
||||||
|
|
||||||
static bool ompi_is_empty(char *pathname)
|
static bool ompi_is_empty(char *pathname)
|
||||||
{
|
{
|
||||||
DIR *dp;
|
DIR *dp;
|
||||||
struct dirent *ep;
|
struct dirent *ep;
|
||||||
|
|
||||||
if (NULL != pathname) { /* protect against error */
|
if (NULL != pathname) { /* protect against error */
|
||||||
dp = opendir(pathname);
|
dp = opendir(pathname);
|
||||||
if (NULL != dp) {
|
if (NULL != dp) {
|
||||||
while ((ep = readdir(dp))) {
|
while ((ep = readdir(dp))) {
|
||||||
if ((0 != strcmp(ep->d_name, ".")) &&
|
if ((0 != strcmp(ep->d_name, ".")) &&
|
||||||
(0 != strcmp(ep->d_name, ".."))) {
|
(0 != strcmp(ep->d_name, ".."))) {
|
||||||
return false;
|
return false;
|
||||||
}
|
}
|
||||||
}
|
}
|
||||||
closedir(dp);
|
closedir(dp);
|
||||||
return true;
|
return true;
|
||||||
}
|
}
|
||||||
return false;
|
return false;
|
||||||
}
|
}
|
||||||
return false;
|
return false;
|
||||||
}
|
}
|
||||||
|
|
||||||
|
|||||||
Загрузка…
x
Ссылка в новой задаче
Block a user