File indexing completed on 2025-02-23 10:12:56
0001
0002
0003
0004
0005
0006
0007
0008
0009
0010
0011
0012
0013
0014
0015
0016
0017
0018
0019
0020
0021
0022
0023
0024
0025 #ifndef PRTE_FILEM_BASE_H
0026 #define PRTE_FILEM_BASE_H
0027
0028 #include "prte_config.h"
0029
0030 #include "src/mca/filem/filem.h"
0031 #include "src/rml/rml.h"
0032 #include "src/pmix/pmix-internal.h"
0033 #include "src/util/pmix_printf.h"
0034
0035 BEGIN_C_DECLS
0036
0037
0038
0039
0040 PRTE_EXPORT extern pmix_mca_base_framework_t prte_filem_base_framework;
0041
0042
0043
0044 PRTE_EXPORT int prte_filem_base_select(void);
0045
0046
0047
0048
0049 typedef uint8_t prte_filem_cmd_flag_t;
0050 #define PRTE_FILEM_CMD PMIX_UINT8
0051 #define PRTE_FILEM_GET_PROC_NODE_NAME_CMD 1
0052 #define PRTE_FILEM_GET_REMOTE_PATH_CMD 2
0053
0054
0055
0056
0057 PRTE_EXPORT extern prte_filem_base_module_t prte_filem;
0058 PRTE_EXPORT extern bool prte_filem_base_is_active;
0059
0060
0061
0062
0063
0064
0065 int prte_filem_base_module_init(void);
0066 int prte_filem_base_module_finalize(void);
0067
0068 PRTE_EXPORT int prte_filem_base_none_put(prte_filem_base_request_t *request);
0069 PRTE_EXPORT int prte_filem_base_none_put_nb(prte_filem_base_request_t *request);
0070 PRTE_EXPORT int prte_filem_base_none_get(prte_filem_base_request_t *request);
0071 PRTE_EXPORT int prte_filem_base_none_get_nb(prte_filem_base_request_t *request);
0072 PRTE_EXPORT int prte_filem_base_none_rm(prte_filem_base_request_t *request);
0073 PRTE_EXPORT int prte_filem_base_none_rm_nb(prte_filem_base_request_t *request);
0074 PRTE_EXPORT int prte_filem_base_none_wait(prte_filem_base_request_t *request);
0075 PRTE_EXPORT int prte_filem_base_none_wait_all(pmix_list_t *request_list);
0076 int prte_filem_base_none_preposition_files(prte_job_t *jdata, prte_filem_completion_cbfunc_t cbfunc,
0077 void *cbdata);
0078 int prte_filem_base_none_link_local_files(prte_job_t *jdata, prte_app_context_t *app);
0079
0080
0081
0082
0083
0084 PRTE_EXPORT int prte_filem_base_comm_start(void);
0085 PRTE_EXPORT int prte_filem_base_comm_stop(void);
0086 PRTE_EXPORT void prte_filem_base_recv(int status, pmix_proc_t *sender, pmix_data_buffer_t *buffer,
0087 prte_rml_tag_t tag, void *cbdata);
0088
0089 END_C_DECLS
0090
0091 #endif