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

Go to the source code of this file.

Functions
static void	ADIOI_Read_and_exch (ADIO_File fd, void *buf, MPI_Datatype datatype, int nprocs, int myrank, ADIOI_Access *others_req, ADIO_Offset *offset_list, ADIO_Offset *len_list, int contig_access_count, ADIO_Offset min_st_offset, ADIO_Offset fd_size, ADIO_Offset *fd_start, ADIO_Offset *fd_end, int *buf_idx, int *error_code)
static void	ADIOI_R_Exchange_data (ADIO_File fd, void *buf, ADIOI_Flatlist_node *flat_buf, ADIO_Offset *offset_list, ADIO_Offset *len_list, int *send_size, int *recv_size, int *count, int *start_pos, int *partial_send, int *recd_from_proc, int nprocs, int myrank, int buftype_is_contig, int contig_access_count, ADIO_Offset min_st_offset, ADIO_Offset fd_size, ADIO_Offset *fd_start, ADIO_Offset *fd_end, ADIOI_Access *others_req, int iter, MPI_Aint buftype_extent, int *buf_idx)
static void	ADIOI_Fill_user_buffer (ADIO_File fd, void *buf, ADIOI_Flatlist_node *flat_buf, char **recv_buf, ADIO_Offset *offset_list, ADIO_Offset *len_list, unsigned *recv_size, MPI_Request *requests, MPI_Status *statuses, int *recd_from_proc, int nprocs, int contig_access_count, ADIO_Offset min_st_offset, ADIO_Offset fd_size, ADIO_Offset *fd_start, ADIO_Offset *fd_end, MPI_Aint buftype_extent)
void	ADIOI_GEN_ReadStridedColl (ADIO_File fd, void *buf, int count, MPI_Datatype datatype, int file_ptr_type, ADIO_Offset offset, ADIO_Status *status, int *error_code)
void	ADIOI_Calc_my_off_len (ADIO_File fd, int bufcount, MPI_Datatype datatype, int file_ptr_type, ADIO_Offset offset, ADIO_Offset **offset_list_ptr, ADIO_Offset **len_list_ptr, ADIO_Offset *start_offset_ptr, ADIO_Offset *end_offset_ptr, int *contig_access_count_ptr)

---

Function Documentation

static void ADIOI_Read_and_exch	(	ADIO_File	fd,
		void *	buf,
		MPI_Datatype	datatype,
		int	nprocs,
		int	myrank,
		ADIOI_Access *	others_req,
		ADIO_Offset *	offset_list,
		ADIO_Offset *	len_list,
		int	contig_access_count,
		ADIO_Offset	min_st_offset,
		ADIO_Offset	fd_size,
		ADIO_Offset *	fd_start,
		ADIO_Offset *	fd_end,
		int *	buf_idx,
		int *	error_code
	)			[static]

Definition at line 498 of file ad_read_coll.c.

References ADIO_ReadContig(), ADIOI_Datatype_iscontig(), ADIOI_Flatten_datatype(), ADIOI_R_Exchange_data(), ADIOI_Hints_struct::cb_buffer_size, ADIOI_FileD::comm, ADIOI_Access::count, count, CpuTopoDetails::done, flag, ADIOI_FileD::hints, int, ADIOI_Access::lens, PUP::m, MPI_Address, MPI_Allreduce, MPI_Comm_rank, ADIOI_Fl_node::next, ADIOI_Access::offsets, rank, size, status, and ADIOI_Fl_node::type.

Here is the call graph for this function:

static void ADIOI_R_Exchange_data	(	ADIO_File	fd,
		void *	buf,
		ADIOI_Flatlist_node *	flat_buf,
		ADIO_Offset *	offset_list,
		ADIO_Offset *	len_list,
		int *	send_size,
		int *	recv_size,
		int *	count,
		int *	start_pos,
		int *	partial_send,
		int *	recd_from_proc,
		int	nprocs,
		int	myrank,
		int	buftype_is_contig,
		int	contig_access_count,
		ADIO_Offset	min_st_offset,
		ADIO_Offset	fd_size,
		ADIO_Offset *	fd_start,
		ADIO_Offset *	fd_end,
		ADIOI_Access *	others_req,
		int	iter,
		MPI_Aint	buftype_extent,
		int *	buf_idx
	)			[static]

Definition at line 775 of file ad_read_coll.c.

References ADIOI_Fill_user_buffer(), ADIOI_FileD::comm, ADIOI_Access::lens, MPI_Alltoall, MPI_Irecv, MPI_Isend, MPI_Type_free, MPI_Type_hindexed, and MPI_Waitall.

Here is the call graph for this function:

static void ADIOI_Fill_user_buffer	(	ADIO_File	fd,
		void *	buf,
		ADIOI_Flatlist_node *	flat_buf,
		char **	recv_buf,
		ADIO_Offset *	offset_list,
		ADIO_Offset *	len_list,
		unsigned *	recv_size,
		MPI_Request *	requests,
		MPI_Status *	statuses,
		int *	recd_from_proc,
		int	nprocs,
		int	contig_access_count,
		ADIO_Offset	min_st_offset,
		ADIO_Offset	fd_size,
		ADIO_Offset *	fd_start,
		ADIO_Offset *	fd_end,
		MPI_Aint	buftype_extent
	)			[static]

Definition at line 957 of file ad_read_coll.c.

References ADIOI_Calc_aggregator(), ADIOI_Fl_node::blocklens, ADIOI_Fl_node::indices, len, p, and size.

Here is the call graph for this function:

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

Definition at line 55 of file ad_read_coll.c.

References ADIO_ReadContig(), ADIO_ReadStrided(), ADIOI_Calc_file_domains(), ADIOI_Calc_my_off_len(), ADIOI_Calc_my_req(), ADIOI_Calc_others_req(), ADIOI_Datatype_iscontig(), ADIOI_Delete_flattened(), ADIOI_HINT_AUTO, ADIOI_HINT_DISABLE, ADIOI_IOStridedColl(), ADIOI_Read_and_exch(), ADIOI_Hints_struct::cb_nodes, ADIOI_Hints_struct::cb_pfr, ADIOI_Hints_struct::cb_read, ADIOI_FileD::comm, ADIOI_FileD::disp, ADIOI_FileD::etype_size, ADIOI_FileD::filetype, ADIOI_FileD::fp_ind, ADIOI_FileD::fp_sys_posn, ADIOI_FileD::hints, ADIOI_Hints_struct::min_fdomain_size, MPI_Allgather, MPI_Comm_rank, MPI_Type_size, MPIR_Status_set_bytes(), size, and ADIOI_Hints_struct::striping_unit.

Referenced by ADIOI_TESTFS_ReadStridedColl(), and uses_generic_read().

Here is the call graph for this function:

Here is the caller graph for this function:

void ADIOI_Calc_my_off_len	(	ADIO_File	fd,
		int	bufcount,
		MPI_Datatype	datatype,
		int	file_ptr_type,
		ADIO_Offset	offset,
		ADIO_Offset **	offset_list_ptr,
		ADIO_Offset **	len_list_ptr,
		ADIO_Offset *	start_offset_ptr,
		ADIO_Offset *	end_offset_ptr,
		int *	contig_access_count_ptr
	)

Definition at line 277 of file ad_read_coll.c.

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

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

Here is the call graph for this function:

Here is the caller graph for this function: