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

Go to the source code of this file.

Functions
static void	ADIOI_Exch_and_write (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_W_Exchange_data (ADIO_File fd, void *buf, char *write_buf, ADIOI_Flatlist_node *flat_buf, ADIO_Offset *offset_list, ADIO_Offset *len_list, int *send_size, int *recv_size, ADIO_Offset off, int size, int *count, int *start_pos, int *partial_recv, int *sent_to_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 *send_buf_idx, int *curr_to_proc, int *done_to_proc, int *hole, int iter, MPI_Aint buftype_extent, int *buf_idx, int *error_code)
static void	ADIOI_Fill_send_buffer (ADIO_File fd, void *buf, ADIOI_Flatlist_node *flat_buf, char **send_buf, ADIO_Offset *offset_list, ADIO_Offset *len_list, int *send_size, MPI_Request *requests, int *sent_to_proc, int nprocs, int myrank, int contig_access_count, ADIO_Offset min_st_offset, ADIO_Offset fd_size, ADIO_Offset *fd_start, ADIO_Offset *fd_end, int *send_buf_idx, int *curr_to_proc, int *done_to_proc, int iter, MPI_Aint buftype_extent)
void	ADIOI_Heap_merge (ADIOI_Access *others_req, int *count, ADIO_Offset *srt_off, int *srt_len, int *start_pos, int nprocs, int nprocs_recv, int total_elements)
void	ADIOI_GEN_WriteStridedColl (ADIO_File fd, void *buf, int count, MPI_Datatype datatype, int file_ptr_type, ADIO_Offset offset, ADIO_Status *status, int *error_code)

---

Function Documentation

static void ADIOI_Exch_and_write	(	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 292 of file ad_write_coll.c.

References ADIO_WriteContig(), ADIOI_Datatype_iscontig(), ADIOI_Flatten_datatype(), ADIOI_W_Exchange_data(), ADIOI_FileD::comm, ADIOI_Access::count, count, CpuTopoDetails::done, flag, ADIOI_FileD::info, int, ADIOI_Access::lens, PUP::m, MPI_Address, MPI_Allreduce, MPIO_Err_create_code(), myname, ADIOI_Fl_node::next, ADIOI_Access::offsets, size, status, ADIOI_Fl_node::type, and value.

Here is the call graph for this function:

static void ADIOI_W_Exchange_data	(	ADIO_File	fd,
		void *	buf,
		char *	write_buf,
		ADIOI_Flatlist_node *	flat_buf,
		ADIO_Offset *	offset_list,
		ADIO_Offset *	len_list,
		int *	send_size,
		int *	recv_size,
		ADIO_Offset	off,
		int	size,
		int *	count,
		int *	start_pos,
		int *	partial_recv,
		int *	sent_to_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 *	send_buf_idx,
		int *	curr_to_proc,
		int *	done_to_proc,
		int *	hole,
		int	iter,
		MPI_Aint	buftype_extent,
		int *	buf_idx,
		int *	error_code
	)			[static]

Definition at line 560 of file ad_write_coll.c.

References ADIO_ReadContig(), ADIOI_Fill_send_buffer(), ADIOI_Heap_merge(), ADIOI_FileD::atomicity, ADIOI_FileD::comm, ADIOI_Access::lens, MPI_Alltoall, MPI_Irecv, MPI_Isend, MPI_Type_free, MPI_Type_hindexed, MPI_Waitall, MPIO_Err_create_code(), myname, and status.

Here is the call graph for this function:

static void ADIOI_Fill_send_buffer	(	ADIO_File	fd,
		void *	buf,
		ADIOI_Flatlist_node *	flat_buf,
		char **	send_buf,
		ADIO_Offset *	offset_list,
		ADIO_Offset *	len_list,
		int *	send_size,
		MPI_Request *	requests,
		int *	sent_to_proc,
		int	nprocs,
		int	myrank,
		int	contig_access_count,
		ADIO_Offset	min_st_offset,
		ADIO_Offset	fd_size,
		ADIO_Offset *	fd_start,
		ADIO_Offset *	fd_end,
		int *	send_buf_idx,
		int *	curr_to_proc,
		int *	done_to_proc,
		int	iter,
		MPI_Aint	buftype_extent
	)			[static]

Definition at line 859 of file ad_write_coll.c.

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

Here is the call graph for this function:

void ADIOI_Heap_merge	(	ADIOI_Access *	others_req,
		int *	count,
		ADIO_Offset *	srt_off,
		int *	srt_len,
		int *	start_pos,
		int	nprocs,
		int	nprocs_recv,
		int	total_elements
	)

void ADIOI_GEN_WriteStridedColl	(	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 54 of file ad_write_coll.c.

References ADIO_WriteContig(), ADIO_WriteStrided(), ADIOI_Calc_file_domains(), ADIOI_Calc_my_off_len(), ADIOI_Calc_my_req(), ADIOI_Calc_others_req(), ADIOI_Datatype_iscontig(), ADIOI_Delete_flattened(), ADIOI_Exch_and_write(), ADIOI_HINT_AUTO, ADIOI_HINT_DISABLE, ADIOI_IOStridedColl(), ADIOI_MPE_postwrite_a, ADIOI_MPE_postwrite_b, ADIOI_Hints_struct::cb_nodes, ADIOI_Hints_struct::cb_pfr, ADIOI_Hints_struct::cb_write, 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_Allreduce, MPI_Bcast, MPI_Comm_rank, MPI_Type_size, MPIR_Status_set_bytes(), ADIOI_Hints_struct::ranklist, size, and ADIOI_Hints_struct::striping_unit.

Referenced by ADIOI_TESTFS_WriteStridedColl(), and uses_generic_write().

Here is the call graph for this function:

Here is the caller graph for this function: