* woops - forgot to sed one file
This commit was SVN r2682.
Этот коммит содержится в:
родитель
15d7c000c4
Коммит
07b3693ff0
@ -17,8 +17,8 @@
|
||||
|
||||
#include <sys/types.h>
|
||||
|
||||
#ifndef MCA_PCM_BPROC_H_
|
||||
#define MCA_PCM_BPROC_H_
|
||||
#ifndef MCA_PCM_WMI_H_
|
||||
#define MCA_PCM_WMI_H_
|
||||
|
||||
#ifdef __cplusplus
|
||||
extern "C" {
|
||||
@ -27,65 +27,65 @@ extern "C" {
|
||||
/*
|
||||
* Module open / close
|
||||
*/
|
||||
int mca_pcm_bproc_component_open(void);
|
||||
int mca_pcm_bproc_component_close(void);
|
||||
int mca_pcm_wmi_component_open(void);
|
||||
int mca_pcm_wmi_component_close(void);
|
||||
|
||||
/*
|
||||
* Startup / Shutdown
|
||||
*/
|
||||
struct mca_pcm_base_module_1_0_0_t* mca_pcm_bproc_init(int *priority,
|
||||
struct mca_pcm_base_module_1_0_0_t* mca_pcm_wmi_init(int *priority,
|
||||
bool *allow_multi_user_threads,
|
||||
bool *have_hidden_threads,
|
||||
int constraints);
|
||||
int mca_pcm_bproc_finalize(struct mca_pcm_base_module_1_0_0_t* me);
|
||||
int mca_pcm_wmi_finalize(struct mca_pcm_base_module_1_0_0_t* me);
|
||||
|
||||
/*
|
||||
* Interface
|
||||
*/
|
||||
ompi_list_t* mca_pcm_bproc_allocate_resources(struct mca_pcm_base_module_1_0_0_t* me,
|
||||
ompi_list_t* mca_pcm_wmi_allocate_resources(struct mca_pcm_base_module_1_0_0_t* me,
|
||||
mca_ns_base_jobid_t jobid,
|
||||
int nodes, int procs);
|
||||
bool mca_pcm_bproc_can_spawn(struct mca_pcm_base_module_1_0_0_t* me);
|
||||
int mca_pcm_bproc_spawn_procs(struct mca_pcm_base_module_1_0_0_t* me,
|
||||
bool mca_pcm_wmi_can_spawn(struct mca_pcm_base_module_1_0_0_t* me);
|
||||
int mca_pcm_wmi_spawn_procs(struct mca_pcm_base_module_1_0_0_t* me,
|
||||
mca_ns_base_jobid_t jobid, ompi_list_t *schedule_list);
|
||||
int mca_pcm_bproc_kill_proc(struct mca_pcm_base_module_1_0_0_t* me,
|
||||
int mca_pcm_wmi_kill_proc(struct mca_pcm_base_module_1_0_0_t* me,
|
||||
ompi_process_name_t *name, int flags);
|
||||
int mca_pcm_bproc_kill_job(struct mca_pcm_base_module_1_0_0_t* me,
|
||||
int mca_pcm_wmi_kill_job(struct mca_pcm_base_module_1_0_0_t* me,
|
||||
mca_ns_base_jobid_t jobid, int flags);
|
||||
int mca_pcm_bproc_deallocate_resources(struct mca_pcm_base_module_1_0_0_t* me,
|
||||
int mca_pcm_wmi_deallocate_resources(struct mca_pcm_base_module_1_0_0_t* me,
|
||||
mca_ns_base_jobid_t jobid,
|
||||
ompi_list_t *nodelist);
|
||||
|
||||
/*
|
||||
* Job management code
|
||||
*/
|
||||
void mca_pcm_bproc_job_list_init(void);
|
||||
void mca_pcm_bproc_job_list_fini(void);
|
||||
void mca_pcm_wmi_job_list_init(void);
|
||||
void mca_pcm_wmi_job_list_fini(void);
|
||||
|
||||
int mca_pcm_bproc_add_started_pids(mca_ns_base_jobid_t jobid, pid_t child_pid,
|
||||
int mca_pcm_wmi_add_started_pids(mca_ns_base_jobid_t jobid, pid_t child_pid,
|
||||
mca_ns_base_vpid_t lower, mca_ns_base_vpid_t upper);
|
||||
pid_t mca_pcm_bproc_get_started_pid(mca_ns_base_jobid_t jobid, mca_ns_base_vpid_t vpid,
|
||||
pid_t mca_pcm_wmi_get_started_pid(mca_ns_base_jobid_t jobid, mca_ns_base_vpid_t vpid,
|
||||
bool remove_started_pid);
|
||||
int mca_pcm_bproc_get_started_pid_list(mca_ns_base_jobid_t jobid, pid_t **pids, size_t *len,
|
||||
int mca_pcm_wmi_get_started_pid_list(mca_ns_base_jobid_t jobid, pid_t **pids, size_t *len,
|
||||
bool remove_started_pids);
|
||||
int mca_pcm_bproc_remove_job(mca_ns_base_jobid_t jobid);
|
||||
int mca_pcm_wmi_remove_job(mca_ns_base_jobid_t jobid);
|
||||
|
||||
struct mca_pcm_bproc_pids_t {
|
||||
struct mca_pcm_wmi_pids_t {
|
||||
ompi_list_item_t super;
|
||||
mca_ns_base_vpid_t lower;
|
||||
mca_ns_base_vpid_t upper;
|
||||
pid_t child;
|
||||
};
|
||||
typedef struct mca_pcm_bproc_pids_t mca_pcm_bproc_pids_t;
|
||||
OBJ_CLASS_DECLARATION(mca_pcm_bproc_pids_t);
|
||||
typedef struct mca_pcm_wmi_pids_t mca_pcm_wmi_pids_t;
|
||||
OBJ_CLASS_DECLARATION(mca_pcm_wmi_pids_t);
|
||||
|
||||
struct mca_pcm_bproc_job_item_t {
|
||||
struct mca_pcm_wmi_job_item_t {
|
||||
ompi_list_item_t super;
|
||||
mca_ns_base_jobid_t jobid;
|
||||
ompi_list_t *pids;
|
||||
};
|
||||
typedef struct mca_pcm_bproc_job_item_t mca_pcm_bproc_job_item_t;
|
||||
OBJ_CLASS_DECLARATION(mca_pcm_bproc_job_item_t);
|
||||
typedef struct mca_pcm_wmi_job_item_t mca_pcm_wmi_job_item_t;
|
||||
OBJ_CLASS_DECLARATION(mca_pcm_wmi_job_item_t);
|
||||
|
||||
#ifdef __cplusplus
|
||||
}
|
||||
@ -94,7 +94,7 @@ extern "C" {
|
||||
/*
|
||||
* Module variables
|
||||
*/
|
||||
extern int mca_pcm_bproc_output;
|
||||
extern int mca_pcm_bproc_use_ns;
|
||||
extern int mca_pcm_wmi_output;
|
||||
extern int mca_pcm_wmi_use_ns;
|
||||
|
||||
#endif /* MCA_PCM_BPROC_H_ */
|
||||
#endif /* MCA_PCM_WMI_H_ */
|
||||
|
Загрузка…
x
Ссылка в новой задаче
Block a user