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, int *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, int *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, int *len_list, int *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, int **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,
		int *	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 451 of file ad_read_coll.c.

References ADIO_ReadContig(), ADIOI_Datatype_iscontig(), ADIOI_Flatlist, ADIOI_Flatten_datatype(), ADIOI_R_Exchange_data(), ADIOI_Hints_struct::cb_buffer_size, ADIOI_FileD::comm, ADIOI_Access::count, done, ADIOI_FileD::hints, ADIOI_Access::lens, MPI_Address(), MPI_Allreduce(), MPI_BYTE, MPI_Comm_rank(), MPI_INT, MPI_MAX, MPI_SUCCESS, MPI_Type_extent(), ADIOI_Fl_node::next, ADIOI_Access::offsets, size, status(), and ADIOI_Fl_node::type.

Referenced by ADIOI_GEN_ReadStridedColl().

static void ADIOI_R_Exchange_data	(	ADIO_File	fd,
		void *	buf,
		ADIOI_Flatlist_node *	flat_buf,
		ADIO_Offset *	offset_list,
		int *	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 743 of file ad_read_coll.c.

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

Referenced by ADIOI_Read_and_exch().

static void ADIOI_Fill_user_buffer	(	ADIO_File	fd,
		void *	buf,
		ADIOI_Flatlist_node *	flat_buf,
		char **	recv_buf,
		ADIO_Offset *	offset_list,
		int *	len_list,
		int *	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 916 of file ad_read_coll.c.

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

Referenced by ADIOI_R_Exchange_data().

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 52 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_Read_and_exch(), ADIOI_Hints_struct::cb_nodes, 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, MPI_Allgather(), MPI_Comm_rank(), MPI_Comm_size(), MPI_Type_size(), MPIR_Status_set_bytes(), and size.

Referenced by ADIOI_HFS_ReadStridedColl(), ADIOI_NFS_ReadStridedColl(), ADIOI_NTFS_ReadStridedColl(), ADIOI_PFS_ReadStridedColl(), ADIOI_PIOFS_ReadStridedColl(), ADIOI_PVFS_ReadStridedColl(), ADIOI_SFS_ReadStridedColl(), ADIOI_TESTFS_ReadStridedColl(), ADIOI_UFS_ReadStridedColl(), ADIOI_Uses_generic_read(), and ADIOI_XFS_ReadStridedColl().

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,
		int **	len_list_ptr,
		ADIO_Offset *	start_offset_ptr,
		ADIO_Offset *	end_offset_ptr,
		int *	contig_access_count_ptr
	)

Definition at line 259 of file ad_read_coll.c.

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

Referenced by ADIOI_GEN_ReadStridedColl(), and ADIOI_GEN_WriteStridedColl().