libs/ck-libs/ampi/romio/adio/common/ad_io_coll.c File Reference

Go to the source code of this file.

Functions
static void	Exch_data_amounts (ADIO_File fd, int nprocs, ADIO_Offset *client_comm_sz_arr, ADIO_Offset *agg_comm_sz_arr, int *client_alltoallw_counts, int *agg_alltoallw_counts, int *aggregators_done)
static void	post_aggregator_comm (MPI_Comm comm, int rw_type, int nproc, void *cb_buf, MPI_Datatype *client_comm_dtype_arr, ADIO_Offset *client_comm_sz_arr, MPI_Request **requests, int *aggregators_client_count_p)
static void	post_client_comm (ADIO_File fd, int rw_type, int agg_rank, void *buf, MPI_Datatype agg_comm_dtype, int agg_alltoallw_count, MPI_Request *request)
void	ADIOI_IOStridedColl (ADIO_File fd, void *buf, int count, int rdwr, MPI_Datatype datatype, int file_ptr_type, ADIO_Offset offset, ADIO_Status *status, int *error_code)
void	ADIOI_Calc_bounds (ADIO_File fd, int count, MPI_Datatype buftype, int file_ptr_type, ADIO_Offset offset, ADIO_Offset *st_offset, ADIO_Offset *end_offset)
void	ADIOI_IOFiletype (ADIO_File fd, void *buf, int count, MPI_Datatype datatype, int file_ptr_type, ADIO_Offset offset, MPI_Datatype custom_ftype, int rdwr, ADIO_Status *status, int *error_code)

---

Function Documentation

static void Exch_data_amounts	(	ADIO_File	fd,
		int	nprocs,
		ADIO_Offset *	client_comm_sz_arr,
		ADIO_Offset *	agg_comm_sz_arr,
		int *	client_alltoallw_counts,
		int *	agg_alltoallw_counts,
		int *	aggregators_done
	)			[static]

Definition at line 978 of file ad_io_coll.c.

References ADIOI_HINT_DISABLE, ADIOI_Hints_struct::cb_alltoall, ADIOI_Hints_struct::cb_nodes, ADIOI_FileD::comm, ADIOI_FileD::hints, ADIOI_FileD::is_agg, MPI_Alltoall, MPI_Irecv, MPI_Isend, MPI_Waitall, MPI_Waitany, ADIOI_Hints_struct::ranklist, and status.

Referenced by ADIOI_IOStridedColl().

Here is the caller graph for this function:

static void post_aggregator_comm	(	MPI_Comm	comm,
		int	rw_type,
		int	nproc,
		void *	cb_buf,
		MPI_Datatype *	client_comm_dtype_arr,
		ADIO_Offset *	client_comm_sz_arr,
		MPI_Request **	requests,
		int *	aggregators_client_count_p
	)			[static]

Definition at line 1066 of file ad_io_coll.c.

References MPI_Irecv, and MPI_Isend.

Referenced by ADIOI_IOStridedColl().

Here is the caller graph for this function:

static void post_client_comm	(	ADIO_File	fd,
		int	rw_type,
		int	agg_rank,
		void *	buf,
		MPI_Datatype	agg_comm_dtype,
		int	agg_alltoallw_count,
		MPI_Request *	request
	)			[static]

Definition at line 1114 of file ad_io_coll.c.

References ADIOI_FileD::comm, MPI_Irecv, and MPI_Isend.

Referenced by ADIOI_IOStridedColl().

Here is the caller graph for this function:

void ADIOI_IOStridedColl	(	ADIO_File	fd,
		void *	buf,
		int	count,
		int	rdwr,
		MPI_Datatype	datatype,
		int	file_ptr_type,
		ADIO_Offset	offset,
		ADIO_Status *	status,
		int *	error_code
	)

Definition at line 44 of file ad_io_coll.c.

References ADIO_ReadContig(), ADIO_ReadStrided(), ADIO_WriteContig(), ADIO_WriteStrided(), ADIOI_Build_agg_reqs(), ADIOI_Build_client_pre_req(), ADIOI_Build_client_req(), ADIOI_Build_client_reqs(), ADIOI_Calc_bounds(), ADIOI_Calc_file_realms(), ADIOI_Datatype_iscontig(), ADIOI_Delete_flattened(), ADIOI_Exch_file_views(), ADIOI_HINT_AUTO, ADIOI_HINT_DISABLE, ADIOI_HINT_ENABLE, ADIOI_IOFiletype(), assert, ADIOI_Hints_struct::cb_alltoall, ADIOI_Hints_struct::cb_buffer_size, ADIOI_Hints_struct::cb_nodes, ADIOI_Hints_struct::cb_pfr, ADIOI_Hints_struct::cb_read, ADIOI_Hints_struct::cb_write, ADIOI_FileD::comm, ADIOI_FileD::disp, ADIOI_FileD::etype_size, Exch_data_amounts(), ADIOI_FileD::file_realm_st_offs, ADIOI_FileD::file_realm_types, ADIOI_FileD::filetype, ADIOI_FileD::fp_ind, ADIOI_FileD::fp_sys_posn, ADIOI_FileD::hints, ADIOI_FileD::is_agg, MPI_Allgather, MPI_Alltoallw, MPI_Comm_rank, MPI_Type_free, MPI_Type_size, MPI_Waitall, MPIR_Status_set_bytes(), post_aggregator_comm(), post_client_comm(), ADIOI_Hints_struct::ranklist, and size.

Referenced by ADIOI_BGL_ReadStridedColl(), ADIOI_BGL_WriteStridedColl(), ADIOI_GEN_ReadStridedColl(), and ADIOI_GEN_WriteStridedColl().

Here is the call graph for this function:

Here is the caller graph for this function:

void ADIOI_Calc_bounds	(	ADIO_File	fd,
		int	count,
		MPI_Datatype	buftype,
		int	file_ptr_type,
		ADIO_Offset	offset,
		ADIO_Offset *	st_offset,
		ADIO_Offset *	end_offset
	)

Definition at line 695 of file ad_io_coll.c.

References ADIOI_Datatype_iscontig(), assert, ADIOI_Fl_node::blocklens, ADIOI_Fl_node::count, ADIOI_FileD::disp, ADIOI_FileD::etype, ADIOI_FileD::filetype, ADIOI_FileD::fp_ind, ADIOI_Fl_node::indices, MPI_Type_size, ADIOI_Fl_node::next, and ADIOI_Fl_node::type.

Referenced by ADIOI_IOStridedColl(), and run_test().

Here is the call graph for this function:

Here is the caller graph for this function:

void ADIOI_IOFiletype	(	ADIO_File	fd,
		void *	buf,
		int	count,
		MPI_Datatype	datatype,
		int	file_ptr_type,
		ADIO_Offset	offset,
		MPI_Datatype	custom_ftype,
		int	rdwr,
		ADIO_Status *	status,
		int *	error_code
	)

Definition at line 871 of file ad_io_coll.c.

References ADIO_ReadContig(), ADIO_ReadStrided(), ADIO_WriteContig(), ADIO_WriteStrided(), ADIOI_Datatype_iscontig(), ADIOI_Delete_flattened(), ADIOI_Flatten_datatype(), ADIOI_HINT_DISABLE, ADIOI_HINT_ENABLE, ADIOI_Hints_struct::cb_buffer_size, ADIOI_Hints_struct::cb_ds_threshold, ADIOI_FileD::disp, ADIOI_Hints_struct::ds_read, ADIOI_Hints_struct::ds_write, ADIOI_FileD::etype, ADIOI_FileD::filetype, ADIOI_FileD::hints, ADIOI_Hints_struct::ind_rd_buffer_size, ADIOI_Hints_struct::ind_wr_buffer_size, and MPI_Type_size.

Referenced by ADIOI_IOStridedColl().

Here is the call graph for this function:

Here is the caller graph for this function: