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

Go to the source code of this file.

Functions
static void	readcontig_ctl_cb (void *myargs, globus_ftp_client_handle_t *handle, globus_object_t *error)
static void	readcontig_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	readdiscontig_ctl_cb (void *myargs, globus_ftp_client_handle_t *handle, globus_object_t *error)
static void	readdiscontig_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_ReadContig (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_ReadDiscontig (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_ReadStrided (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	readcontig_ctl_lock
static globus_cond_t	readcontig_ctl_cond
static globus_bool_t	readcontig_ctl_done
static globus_mutex_t	readdiscontig_ctl_lock
static globus_cond_t	readdiscontig_ctl_cond
static globus_bool_t	readdiscontig_ctl_done

---

Function Documentation

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

Definition at line 15 of file ad_gridftp_read.c.

References readcontig_ctl_cond, readcontig_ctl_done, and readcontig_ctl_lock.

Referenced by ADIOI_GRIDFTP_ReadContig().

Here is the caller graph for this function:

static void readcontig_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 29 of file ad_gridftp_read.c.

Referenced by ADIOI_GRIDFTP_ReadContig().

Here is the caller graph for this function:

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

Definition at line 65 of file ad_gridftp_read.c.

References readdiscontig_ctl_cond, readdiscontig_ctl_done, and readdiscontig_ctl_lock.

Referenced by ADIOI_GRIDFTP_ReadDiscontig().

Here is the caller graph for this function:

static void readdiscontig_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 79 of file ad_gridftp_read.c.

Referenced by ADIOI_GRIDFTP_ReadDiscontig().

Here is the caller graph for this function:

void ADIOI_GRIDFTP_ReadContig	(	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 103 of file ad_gridftp_read.c.

References ADIOI_FileD::access_mode, ADIOI_Error(), 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, readcontig_ctl_cb(), readcontig_ctl_cond, readcontig_ctl_done, readcontig_ctl_lock, and readcontig_data_cb().

Referenced by ADIOI_GRIDFTP_ReadStrided().

Here is the call graph for this function:

Here is the caller graph for this function:

void ADIOI_GRIDFTP_ReadDiscontig	(	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 189 of file ad_gridftp_read.c.

References ADIOI_FileD::access_mode, ADIOI_Datatype_iscontig(), 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, readdiscontig_ctl_cb(), readdiscontig_ctl_cond, readdiscontig_ctl_done, readdiscontig_ctl_lock, readdiscontig_data_cb(), and ADIOI_Fl_node::type.

Referenced by ADIOI_GRIDFTP_ReadStrided().

Here is the call graph for this function:

Here is the caller graph for this function:

void ADIOI_GRIDFTP_ReadStrided	(	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 380 of file ad_gridftp_read.c.

References ADIOI_Datatype_iscontig(), ADIOI_GRIDFTP_ReadContig(), ADIOI_GRIDFTP_ReadDiscontig(), ADIOI_FileD::comm, disp, ADIOI_FileD::filetype, MPI_Comm_rank, MPI_Type_size, MPI_Unpack, and myname.

Here is the call graph for this function:

---

Variable Documentation

globus_mutex_t readcontig_ctl_lock [static]

Definition at line 12 of file ad_gridftp_read.c.

Referenced by ADIOI_GRIDFTP_ReadContig(), and readcontig_ctl_cb().

globus_cond_t readcontig_ctl_cond [static]

Definition at line 13 of file ad_gridftp_read.c.

Referenced by ADIOI_GRIDFTP_ReadContig(), and readcontig_ctl_cb().

globus_bool_t readcontig_ctl_done [static]

Definition at line 14 of file ad_gridftp_read.c.

Referenced by ADIOI_GRIDFTP_ReadContig(), and readcontig_ctl_cb().

globus_mutex_t readdiscontig_ctl_lock [static]

Definition at line 62 of file ad_gridftp_read.c.

Referenced by ADIOI_GRIDFTP_ReadDiscontig(), and readdiscontig_ctl_cb().

globus_cond_t readdiscontig_ctl_cond [static]

Definition at line 63 of file ad_gridftp_read.c.

Referenced by ADIOI_GRIDFTP_ReadDiscontig(), and readdiscontig_ctl_cb().

globus_bool_t readdiscontig_ctl_done [static]

Definition at line 64 of file ad_gridftp_read.c.

Referenced by ADIOI_GRIDFTP_ReadDiscontig(), and readdiscontig_ctl_cb().