libs/ck-libs/ampi/romio/adio/ad_lustre/ad_lustre_wrcoll.c File Reference

Go to the source code of this file.

Functions
static void	ADIOI_LUSTRE_Exch_and_write (ADIO_File fd, void *buf, MPI_Datatype datatype, int nprocs, int myrank, ADIOI_Access *others_req, ADIOI_Access *my_req, ADIO_Offset *offset_list, ADIO_Offset *len_list, int contig_access_count, int *striping_info, int **buf_idx, int *error_code)
static void	ADIOI_LUSTRE_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, int *striping_info, int *send_buf_idx, int *curr_to_proc, int *done_to_proc, int iter, MPI_Aint buftype_extent)
static void	ADIOI_LUSTRE_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, int *striping_info, 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)
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_LUSTRE_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_LUSTRE_Exch_and_write	(	ADIO_File	fd,
		void *	buf,
		MPI_Datatype	datatype,
		int	nprocs,
		int	myrank,
		ADIOI_Access *	others_req,
		ADIOI_Access *	my_req,
		ADIO_Offset *	offset_list,
		ADIO_Offset *	len_list,
		int	contig_access_count,
		int *	striping_info,
		int **	buf_idx,
		int *	error_code
	)			[static]

Definition at line 284 of file ad_lustre_wrcoll.c.

References ADIO_WriteContig(), ADIOI_Datatype_iscontig(), ADIOI_Flatten_datatype(), ADIOI_HINT_ENABLE, ADIOI_LUSTRE_W_Exchange_data(), ADIOI_FileD::comm, ADIOI_Access::count, count, flag, ADIOI_Hints_struct::fs_hints, ADIOI_FileD::hints, int, ADIOI_Access::lens, ADIOI_Hints_struct::lustre, PUP::m, MPI_Address, MPI_Allreduce, ADIOI_Fl_node::next, ADIOI_Access::offsets, status, and ADIOI_Fl_node::type.

Referenced by ADIOI_LUSTRE_WriteStridedColl().

Here is the call graph for this function:

Here is the caller graph for this function:

static void ADIOI_LUSTRE_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,
		int *	striping_info,
		int *	send_buf_idx,
		int *	curr_to_proc,
		int *	done_to_proc,
		int	iter,
		MPI_Aint	buftype_extent
	)			[static]

Definition at line 853 of file ad_lustre_wrcoll.c.

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

Referenced by ADIOI_LUSTRE_W_Exchange_data().

Here is the call graph for this function:

Here is the caller graph for this function:

static void ADIOI_LUSTRE_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,
		int *	striping_info,
		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 584 of file ad_lustre_wrcoll.c.

References ADIO_ReadContig(), ADIOI_Heap_merge(), ADIOI_HINT_ENABLE, ADIOI_LUSTRE_Fill_send_buffer(), ADIOI_FileD::atomicity, ADIOI_FileD::comm, int, MPI_Irecv, MPI_Isend, MPI_Type_free, MPI_Type_hindexed, MPI_Waitall, MPIO_Err_create_code(), myname, and status.

Referenced by ADIOI_LUSTRE_Exch_and_write().

Here is the call graph for this function:

Here is the caller 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
	)

Definition at line 966 of file ad_write_coll.c.

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

void ADIOI_LUSTRE_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 60 of file ad_lustre_wrcoll.c.

References ADIO_WriteContig(), ADIO_WriteStrided(), ADIOI_Calc_my_off_len(), ADIOI_Calc_others_req(), ADIOI_Datatype_iscontig(), ADIOI_Delete_flattened(), ADIOI_HINT_AUTO, ADIOI_HINT_DISABLE, ADIOI_LUSTRE_Calc_my_req(), ADIOI_LUSTRE_Docollect(), ADIOI_LUSTRE_Exch_and_write(), ADIOI_LUSTRE_Get_striping_info(), ADIOI_MPE_postwrite_a, ADIOI_MPE_postwrite_b, ADIOI_Hints_struct::cb_nodes, 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, MPI_Allgather, MPI_Allreduce, MPI_Bcast, MPI_Comm_rank, MPI_Type_size, MPIR_Status_set_bytes(), ADIOI_Hints_struct::ranklist, and size.

Here is the call graph for this function: