openmpi  3.1.6
About: Open MPI is a high performance Message Passing Interface (MPI) library project combining technologies and resources from several other projects (FT-MPI, LA-MPI, LAM/MPI, and PACX-MPI) in order to build the best MPI library available. 3.x series.
  Fossies Dox: openmpi-3.1.6.tar.bz2  ("unofficial" and yet experimental doxygen-generated source code documentation)  

dfs_app.c File Reference
#include "orte_config.h"
#include <sys/types.h>
#include <string.h>
#include <sys/stat.h>
#include "opal/util/if.h"
#include "opal/util/output.h"
#include "opal/util/uri.h"
#include "opal/dss/dss.h"
#include "opal/mca/pmix/pmix.h"
#include "orte/util/error_strings.h"
#include "orte/util/name_fns.h"
#include "orte/util/proc_info.h"
#include "orte/util/show_help.h"
#include "orte/util/threads.h"
#include "orte/runtime/orte_globals.h"
#include "orte/mca/errmgr/errmgr.h"
#include "orte/mca/rml/rml.h"
#include "orte/mca/dfs/base/base.h"
#include "dfs_app.h"
Include dependency graph for dfs_app.c:

Go to the source code of this file.

Functions

static int init (void)
 
static int finalize (void)
 
static void dfs_open (char *uri, orte_dfs_open_callback_fn_t cbfunc, void *cbdata)
 
static void dfs_close (int fd, orte_dfs_close_callback_fn_t cbfunc, void *cbdata)
 
static void dfs_get_file_size (int fd, orte_dfs_size_callback_fn_t cbfunc, void *cbdata)
 
static void dfs_seek (int fd, long offset, int whence, orte_dfs_seek_callback_fn_t cbfunc, void *cbdata)
 
static void dfs_read (int fd, uint8_t *buffer, long length, orte_dfs_read_callback_fn_t cbfunc, void *cbdata)
 
static void dfs_post_file_map (opal_buffer_t *bo, orte_dfs_post_callback_fn_t cbfunc, void *cbdata)
 
static void dfs_get_file_map (orte_process_name_t *target, orte_dfs_fm_callback_fn_t cbfunc, void *cbdata)
 
static void dfs_load_file_maps (orte_jobid_t jobid, opal_buffer_t *bo, orte_dfs_load_callback_fn_t cbfunc, void *cbdata)
 
static void dfs_purge_file_maps (orte_jobid_t jobid, orte_dfs_purge_callback_fn_t cbfunc, void *cbdata)
 
static void recv_dfs (int status, orte_process_name_t *sender, opal_buffer_t *buffer, orte_rml_tag_t tag, void *cbdata)
 
static void open_local_file (orte_dfs_request_t *dfs)
 
static void process_opens (int fd, short args, void *cbdata)
 
static void process_close (int fd, short args, void *cbdata)
 
static void process_sizes (int fd, short args, void *cbdata)
 
static void process_seeks (int fd, short args, void *cbdata)
 
static void process_reads (int fd, short args, void *cbdata)
 
static void process_posts (int fd, short args, void *cbdata)
 
static void process_getfm (int fd, short args, void *cbdata)
 

Variables

orte_dfs_base_module_t orte_dfs_app_module
 APP module. More...
 
static opal_list_t requests
 
static opal_list_t active_files
 
static int local_fd = 0
 
static uint64_t req_id = 0
 

Function Documentation

◆ dfs_close()

◆ dfs_get_file_map()

static void dfs_get_file_map ( orte_process_name_t target,
orte_dfs_fm_callback_fn_t  cbfunc,
void *  cbdata 
)
static

◆ dfs_get_file_size()

◆ dfs_load_file_maps()

static void dfs_load_file_maps ( orte_jobid_t  jobid,
opal_buffer_t bo,
orte_dfs_load_callback_fn_t  cbfunc,
void *  cbdata 
)
static

Definition at line 1296 of file dfs_app.c.

References cbfunc(), and NULL.

◆ dfs_open()

◆ dfs_post_file_map()

static void dfs_post_file_map ( opal_buffer_t bo,
orte_dfs_post_callback_fn_t  cbfunc,
void *  cbdata 
)
static

◆ dfs_purge_file_maps()

static void dfs_purge_file_maps ( orte_jobid_t  jobid,
orte_dfs_purge_callback_fn_t  cbfunc,
void *  cbdata 
)
static

Definition at line 1307 of file dfs_app.c.

References cbfunc(), and NULL.

◆ dfs_read()

static void dfs_read ( int  fd,
uint8_t *  buffer,
long  length,
orte_dfs_read_callback_fn_t  cbfunc,
void *  cbdata 
)
static

◆ dfs_seek()

◆ finalize()

◆ init()

◆ open_local_file()

◆ process_close()

◆ process_getfm()

◆ process_opens()

◆ process_posts()

◆ process_reads()

◆ process_seeks()

◆ process_sizes()

◆ recv_dfs()

Variable Documentation

◆ active_files

opal_list_t active_files
static

◆ local_fd

int local_fd = 0
static

Definition at line 98 of file dfs_app.c.

Referenced by open_local_file(), and recv_dfs().

◆ orte_dfs_app_module

◆ req_id

uint64_t req_id = 0
static

◆ requests

opal_list_t requests
static

Definition at line 97 of file dfs_app.c.

Referenced by ADIOI_Calc_others_req(), ADIOI_Fill_send_buffer(), ADIOI_Fill_user_buffer(), ADIOI_LUSTRE_Fill_send_buffer(), ADIOI_LUSTRE_W_Exchange_data(), ADIOI_R_Exchange_data(), ADIOI_R_Exchange_data_alltoallv(), ADIOI_W_Exchange_data(), coord_request_wait_all(), evhttp_connection_cb_cleanup(), finalize(), init(), Java_mpi_Request_testAll(), Java_mpi_Request_testAllStatus(), Java_mpi_Request_testAny(), Java_mpi_Request_testAnyStatus(), Java_mpi_Request_testSome(), Java_mpi_Request_testSomeStatus(), Java_mpi_Request_waitAll(), Java_mpi_Request_waitAllStatus(), Java_mpi_Request_waitAny(), Java_mpi_Request_waitAnyStatus(), Java_mpi_Request_waitSome(), Java_mpi_Request_waitSomeStatus(), mca_fcoll_two_phase_calc_others_requests(), mca_pml_cm_start(), mca_pml_crcpw_start(), mca_pml_monitoring_start(), mca_pml_ob1_start(), mca_pml_ucx_start(), mca_pml_yalla_start(), mca_vprotocol_pessimist_start(), mca_vprotocol_pessimist_test_all(), mca_vprotocol_pessimist_test_any(), mca_vprotocol_pessimist_test_some(), mca_vprotocol_pessimist_wait_any(), mca_vprotocol_pessimist_wait_some(), MPI_Startall(), MPI_Testall(), MPI_Testany(), MPI_Testsome(), MPI_Waitall(), MPI_Waitany(), MPI_Waitsome(), MPIO_Testall(), MPIO_Testany(), MPIO_Testsome(), MPIO_Waitall(), MPIO_Waitany(), MPIO_Waitsome(), ompi_coll_base_barrier_intra_basic_linear(), ompi_comm_allgather_pml(), ompi_comm_bcast_pml(), ompi_crcp_bkmrk_pml_start(), ompi_errhandler_request_invoke(), ompi_request_default_test_all(), ompi_request_default_test_any(), ompi_request_default_test_some(), ompi_request_default_wait_all(), ompi_request_default_wait_any(), ompi_request_default_wait_some(), post_aggregator_comm(), process_getfm(), process_opens(), process_posts(), process_reads(), process_seeks(), process_sizes(), recv_dfs(), mpi.Prequest::startAll(), mpi.Request::testAll(), mpi.Request::testAllStatus(), mpi.Request::testAny(), mpi.Request::testAnyStatus(), mpi.Request::testSome(), mpi.Request::testSomeStatus(), two_phase_exchage_data(), two_phase_exchange_data(), two_phase_fill_send_buffer(), mpi.Request::waitAll(), mpi.Request::waitAllStatus(), mpi.Request::waitAny(), mpi.Request::waitAnyStatus(), mpi.Request::waitSome(), and mpi.Request::waitSomeStatus().

finalize
static int finalize(void)
Definition: dfs_app.c:116
dfs_purge_file_maps
static void dfs_purge_file_maps(orte_jobid_t jobid, orte_dfs_purge_callback_fn_t cbfunc, void *cbdata)
Definition: dfs_app.c:1307
dfs_close
static void dfs_close(int fd, orte_dfs_close_callback_fn_t cbfunc, void *cbdata)
Definition: dfs_app.c:748
dfs_seek
static void dfs_seek(int fd, long offset, int whence, orte_dfs_seek_callback_fn_t cbfunc, void *cbdata)
Definition: dfs_app.c:1028
dfs_read
static void dfs_read(int fd, uint8_t *buffer, long length, orte_dfs_read_callback_fn_t cbfunc, void *cbdata)
Definition: dfs_app.c:1143
init
static int init(void)
Definition: dfs_app.c:104
dfs_open
static void dfs_open(char *uri, orte_dfs_open_callback_fn_t cbfunc, void *cbdata)
Definition: dfs_app.c:649
dfs_get_file_map
static void dfs_get_file_map(orte_process_name_t *target, orte_dfs_fm_callback_fn_t cbfunc, void *cbdata)
Definition: dfs_app.c:1279
dfs_load_file_maps
static void dfs_load_file_maps(orte_jobid_t jobid, opal_buffer_t *bo, orte_dfs_load_callback_fn_t cbfunc, void *cbdata)
Definition: dfs_app.c:1296
dfs_get_file_size
static void dfs_get_file_size(int fd, orte_dfs_size_callback_fn_t cbfunc, void *cbdata)
Definition: dfs_app.c:874
dfs_post_file_map
static void dfs_post_file_map(opal_buffer_t *bo, orte_dfs_post_callback_fn_t cbfunc, void *cbdata)
Definition: dfs_app.c:1215