libs/ck-libs/ampi/romio/adio/ad_gridftp/ad_gridftp_write.c File Reference

Go to the source code of this file.

Functions
static void	writecontig_ctl_cb (void *myargs, globus_ftp_client_handle_t *handle, globus_object_t *error)
static void	writecontig_data_cb (void *myargs, globus_ftp_client_handle_t *handle, globus_object_t *error, globus_byte_t *buffer, globus_size_t length, globus_off_t offset, globus_bool_t eof)
static void	writediscontig_ctl_cb (void *myargs, globus_ftp_client_handle_t *handle, globus_object_t *error)
static void	writediscontig_data_cb (void *myargs, globus_ftp_client_handle_t *handle, globus_object_t *error, globus_byte_t *buffer, globus_size_t length, globus_off_t offset, globus_bool_t eof)
void	ADIOI_GRIDFTP_WriteContig (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_GRIDFTP_WriteDiscontig (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_GRIDFTP_WriteStrided (ADIO_File fd, void *buf, int count, MPI_Datatype datatype, int file_ptr_type, ADIO_Offset offset, ADIO_Status *status, int *error_code)
Variables
static globus_mutex_t	writecontig_ctl_lock
static globus_cond_t	writecontig_ctl_cond
static globus_bool_t	writecontig_ctl_done
static globus_mutex_t	writediscontig_ctl_lock
static globus_cond_t	writediscontig_ctl_cond
static globus_bool_t	writediscontig_ctl_done

---

Function Documentation

static void writecontig_ctl_cb	(	void *	myargs,
		globus_ftp_client_handle_t *	handle,
		globus_object_t *	error
	)			[static]

Definition at line 15 of file ad_gridftp_write.c.

References writecontig_ctl_cond, writecontig_ctl_done, and writecontig_ctl_lock.

Referenced by ADIOI_GRIDFTP_WriteContig().

Here is the caller graph for this function:

static void writecontig_data_cb	(	void *	myargs,
		globus_ftp_client_handle_t *	handle,
		globus_object_t *	error,
		globus_byte_t *	buffer,
		globus_size_t	length,
		globus_off_t	offset,
		globus_bool_t	eof
	)			[static]

Definition at line 32 of file ad_gridftp_write.c.

Referenced by ADIOI_GRIDFTP_WriteContig().

Here is the caller graph for this function:

static void writediscontig_ctl_cb	(	void *	myargs,
		globus_ftp_client_handle_t *	handle,
		globus_object_t *	error
	)			[static]

Definition at line 67 of file ad_gridftp_write.c.

References writediscontig_ctl_cond, writediscontig_ctl_done, and writediscontig_ctl_lock.

Referenced by ADIOI_GRIDFTP_WriteDiscontig().

Here is the caller graph for this function:

static void writediscontig_data_cb	(	void *	myargs,
		globus_ftp_client_handle_t *	handle,
		globus_object_t *	error,
		globus_byte_t *	buffer,
		globus_size_t	length,
		globus_off_t	offset,
		globus_bool_t	eof
	)			[static]

Definition at line 81 of file ad_gridftp_write.c.

Referenced by ADIOI_GRIDFTP_WriteDiscontig().

Here is the caller graph for this function:

void ADIOI_GRIDFTP_WriteContig	(	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 109 of file ad_gridftp_write.c.

References ADIOI_FileD::access_mode, ADIOI_FileD::comm, ADIOI_FileD::fd_sys, ADIOI_FileD::filename, ADIOI_FileD::fp_ind, ADIOI_FileD::fp_sys_posn, globus_err_handler(), gridftp_fh, len, MPI_Comm_rank, MPI_Type_size, MPIO_Err_create_code(), MPIR_Status_set_bytes(), myname, oattr, writecontig_ctl_cb(), writecontig_ctl_cond, writecontig_ctl_done, writecontig_ctl_lock, and writecontig_data_cb().

Referenced by ADIOI_GRIDFTP_WriteStrided().

Here is the call graph for this function:

Here is the caller graph for this function:

void ADIOI_GRIDFTP_WriteDiscontig	(	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 202 of file ad_gridftp_write.c.

References ADIOI_Datatype_iscontig(), ADIOI_Error(), ADIOI_Flatten_datatype(), ADIOI_Fl_node::blocklens, ADIOI_FileD::comm, ADIOI_Fl_node::count, ADIOI_FileD::etype_size, ADIOI_FileD::fd_sys, ADIOI_FileD::filename, ADIOI_FileD::filetype, ADIOI_FileD::fp_ind, ADIOI_FileD::fp_sys_posn, globus_err_handler(), gridftp_fh, ADIOI_Fl_node::indices, MAX(), MPI_Comm_rank, MPI_Type_size, MPIO_Err_create_code(), MPIR_Status_set_bytes(), myname, ADIOI_Fl_node::next, oattr, ADIOI_Fl_node::type, writediscontig_ctl_cb(), writediscontig_ctl_cond, writediscontig_ctl_done, writediscontig_ctl_lock, and writediscontig_data_cb().

Referenced by ADIOI_GRIDFTP_WriteStrided().

Here is the call graph for this function:

Here is the caller graph for this function:

void ADIOI_GRIDFTP_WriteStrided	(	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 375 of file ad_gridftp_write.c.

References ADIOI_FileD::access_mode, ADIOI_Datatype_iscontig(), ADIOI_GEN_WriteStrided(), ADIOI_GRIDFTP_WriteContig(), ADIOI_GRIDFTP_WriteDiscontig(), ADIOI_FileD::comm, ADIOI_FileD::filetype, MPI_Comm_rank, MPI_Type_size, and myname.

Here is the call graph for this function:

---

Variable Documentation

globus_mutex_t writecontig_ctl_lock [static]

Definition at line 12 of file ad_gridftp_write.c.

Referenced by ADIOI_GRIDFTP_WriteContig(), and writecontig_ctl_cb().

globus_cond_t writecontig_ctl_cond [static]

Definition at line 13 of file ad_gridftp_write.c.

Referenced by ADIOI_GRIDFTP_WriteContig(), and writecontig_ctl_cb().

globus_bool_t writecontig_ctl_done [static]

Definition at line 14 of file ad_gridftp_write.c.

Referenced by ADIOI_GRIDFTP_WriteContig(), and writecontig_ctl_cb().

globus_mutex_t writediscontig_ctl_lock [static]

Definition at line 64 of file ad_gridftp_write.c.

Referenced by ADIOI_GRIDFTP_WriteDiscontig(), and writediscontig_ctl_cb().

globus_cond_t writediscontig_ctl_cond [static]

Definition at line 65 of file ad_gridftp_write.c.

Referenced by ADIOI_GRIDFTP_WriteDiscontig(), and writediscontig_ctl_cb().

globus_bool_t writediscontig_ctl_done [static]

Definition at line 66 of file ad_gridftp_write.c.

Referenced by ADIOI_GRIDFTP_WriteDiscontig(), and writediscontig_ctl_cb().