libs/ck-libs/ampi/romio/adio/ad_bgl/ad_bgl_wrcoll.c File Reference

??? More...

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_W_Exchange_data_alltoallv (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)
static void	ADIOI_Fill_send_buffer_nosend (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 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_BGL_WriteStridedColl (ADIO_File fd, void *buf, int count, MPI_Datatype datatype, int file_ptr_type, ADIO_Offset offset, ADIO_Status *status, int *error_code)

---

Detailed Description

???

Definition in file ad_bgl_wrcoll.c.

---

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 424 of file ad_bgl_wrcoll.c.

References ADIO_WriteContig(), ADIOI_Datatype_iscontig(), ADIOI_Flatten_datatype(), ADIOI_W_Exchange_data(), ADIOI_W_Exchange_data_alltoallv(), bglmpio_comm, 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.

Referenced by ADIOI_BGL_WriteStridedColl(), and ADIOI_GEN_WriteStridedColl().

Here is the call graph for this function:

Here is the caller 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 735 of file ad_bgl_wrcoll.c.

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

Referenced by ADIOI_Exch_and_write().

Here is the call graph for this function:

Here is the caller graph for this function:

static void ADIOI_W_Exchange_data_alltoallv	(	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 1258 of file ad_bgl_wrcoll.c.

References ADIO_ReadContig(), ADIOI_Fill_send_buffer_nosend(), ADIOI_Heap_merge(), ADIOI_FileD::comm, int, len, ADIOI_Access::lens, MPI_Alltoall, MPI_Alltoallv, MPIO_Err_create_code(), myname, rdispls, sdispls, and status.

Referenced by ADIOI_Exch_and_write().

Here is the call graph for this function:

Here is the caller 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 1030 of file ad_bgl_wrcoll.c.

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

Referenced by ADIOI_W_Exchange_data().

Here is the call graph for this function:

Here is the caller graph for this function:

static void ADIOI_Fill_send_buffer_nosend	(	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 1429 of file ad_bgl_wrcoll.c.

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

Referenced by ADIOI_W_Exchange_data_alltoallv().

Here is the call graph for this function:

Here is the caller graph for this function:

static 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
	)			[static]

Definition at line 1137 of file ad_bgl_wrcoll.c.

References PUP::a, PUP::l, ADIOI_Access::lens, ADIOI_Access::offsets, and r.

Referenced by ADIOI_LUSTRE_W_Exchange_data(), ADIOI_W_Exchange_data(), and ADIOI_W_Exchange_data_alltoallv().

Here is the caller graph for this function:

void ADIOI_BGL_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 96 of file ad_bgl_wrcoll.c.

References ADIO_WriteContig(), ADIO_WriteStrided(), ADIOI_BGL_Calc_my_req(), ADIOI_BGL_Calc_others_req(), ADIOI_BGL_GPFS_Calc_file_domains(), 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, BGLMPIO_CIO_LAST, BGLMPIO_CIO_T_DEXCH, BGLMPIO_CIO_T_MPIO_CRW, bglmpio_tuneblocking, bglmpio_tunegather, 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::fs_ptr, 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, ADIOI_Hints_struct::striping_unit, and PUP::w.

Here is the call graph for this function: