PPL Logo

libs/ck-libs/ampi/romio/adio/ad_gridftp/ad_gridftp.h File Reference

Go to the source code of this file.

Functions

void ADIOI_GRIDFTP_Open (ADIO_File fd, int *error_code)
void ADIOI_GRIDFTP_Close (ADIO_File fd, int *error_code)
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_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_IwriteContig (ADIO_File fd, void *buf, int count, MPI_Datatype datatype, int file_ptr_type, ADIO_Offset offset, ADIO_Request *request, int *error_code)
void ADIOI_GRIDFTP_IreadContig (ADIO_File fd, void *buf, int count, MPI_Datatype datatype, int file_ptr_type, ADIO_Offset offset, ADIO_Request *request, int *error_code)
int ADIOI_GRIDFTP_ReadDone (ADIO_Request *request, ADIO_Status *status, int *error_code)
int ADIOI_GRIDFTP_WriteDone (ADIO_Request *request, ADIO_Status *status, int *error_code)
void ADIOI_GRIDFTP_ReadComplete (ADIO_Request *request, ADIO_Status *status, int *error_code)
void ADIOI_GRIDFTP_WriteComplete (ADIO_Request *request, ADIO_Status *status, int *error_code)
void ADIOI_GRIDFTP_Fcntl (ADIO_File fd, int flag, ADIO_Fcntl_t *fcntl_struct, 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)
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)
void ADIOI_GRIDFTP_WriteStridedColl (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_ReadStridedColl (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_IreadStrided (ADIO_File fd, void *buf, int count, MPI_Datatype datatype, int file_ptr_type, ADIO_Offset offset, ADIO_Request *request, int *error_code)
void ADIOI_GRIDFTP_IwriteStrided (ADIO_File fd, void *buf, int count, MPI_Datatype datatype, int file_ptr_type, ADIO_Offset offset, ADIO_Request *request, int *error_code)
void ADIOI_GRIDFTP_Flush (ADIO_File fd, int *error_code)
void ADIOI_GRIDFTP_Resize (ADIO_File fd, ADIO_Offset size, int *error_code)
void ADIOI_GRIDFTP_SetInfo (ADIO_File fd, MPI_Info users_info, int *error_code)
void ADIOI_GRIDFTP_Get_shared_fp (ADIO_File fd, int size, ADIO_Offset *shared_fp, int *error_code)
void ADIOI_GRIDFTP_Set_shared_fp (ADIO_File fd, ADIO_Offset offset, int *error_code)
void ADIOI_GRIDFTP_Delete (char *filename, int *error_code)
void globus_err_handler (const char *routine, const char *caller, globus_result_t result)

Variables

int num_gridftp_handles
globus_ftp_client_handle_t gridftp_fh [ADIO_GRIDFTP_HANDLES_MAX]
globus_ftp_client_operationattr_t oattr [ADIO_GRIDFTP_HANDLES_MAX]

Function Documentation

void ADIOI_GRIDFTP_Open ( ADIO_File  fd,
int *  error_code 
)

Definition at line 50 of file ad_gridftp_open.c.

References ADIOI_FileD::access_mode, ADIOI_FileD::comm, cond, exists_cb(), exists_done, ADIOI_FileD::fd_sys, file_exists, ADIOI_FileD::filename, globus_err_handler(), gridftp_fh, ADIOI_FileD::info, lock, MPI_Barrier, MPI_Bcast, MPI_Comm_rank, MPIO_Err_create_code(), myname, num_gridftp_handles, oattr, ADIOI_FileD::shared_fp_fname, touch_ctl_cb(), touch_ctl_done, and touch_data_cb().

Here is the call graph for this function:

void ADIOI_GRIDFTP_Close ( ADIO_File  fd,
int *  error_code 
)

Definition at line 11 of file ad_gridftp_close.c.

References ADIOI_FileD::comm, ADIOI_FileD::fd_sys, ADIOI_FileD::fp_ind, ADIOI_FileD::fp_sys_posn, globus_err_handler(), gridftp_fh, MPI_Barrier, MPIO_Err_create_code(), myname, num_gridftp_handles, and oattr.

Here is the call 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_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_IwriteContig ( ADIO_File  fd,
void *  buf,
int  count,
MPI_Datatype  datatype,
int  file_ptr_type,
ADIO_Offset  offset,
ADIO_Request *  request,
int *  error_code 
)

void ADIOI_GRIDFTP_IreadContig ( ADIO_File  fd,
void *  buf,
int  count,
MPI_Datatype  datatype,
int  file_ptr_type,
ADIO_Offset  offset,
ADIO_Request *  request,
int *  error_code 
)

int ADIOI_GRIDFTP_ReadDone ( ADIO_Request *  request,
ADIO_Status *  status,
int *  error_code 
)

int ADIOI_GRIDFTP_WriteDone ( ADIO_Request *  request,
ADIO_Status *  status,
int *  error_code 
)

void ADIOI_GRIDFTP_ReadComplete ( ADIO_Request *  request,
ADIO_Status *  status,
int *  error_code 
)

void ADIOI_GRIDFTP_WriteComplete ( ADIO_Request *  request,
ADIO_Status *  status,
int *  error_code 
)

void ADIOI_GRIDFTP_Fcntl ( ADIO_File  fd,
int  flag,
ADIO_Fcntl_t *  fcntl_struct,
int *  error_code 
)

Definition at line 29 of file ad_gridftp_fcntl.c.

References ADIOI_GEN_Prealloc(), ADIOI_FileD::comm, ADIO_Fcntl_t::diskspace, fcntl_size_cb(), fcntl_size_cond, fcntl_size_done, fcntl_size_lock, ADIOI_FileD::fd_sys, ADIOI_FileD::filename, ADIO_Fcntl_t::fsize, globus_err_handler(), gridftp_fh, MPI_Comm_rank, MPIO_Err_create_code(), myname, and oattr.

Here is the call 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:

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:

void ADIOI_GRIDFTP_WriteStridedColl ( 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_ReadStridedColl ( 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_IreadStrided ( ADIO_File  fd,
void *  buf,
int  count,
MPI_Datatype  datatype,
int  file_ptr_type,
ADIO_Offset  offset,
ADIO_Request *  request,
int *  error_code 
)

void ADIOI_GRIDFTP_IwriteStrided ( ADIO_File  fd,
void *  buf,
int  count,
MPI_Datatype  datatype,
int  file_ptr_type,
ADIO_Offset  offset,
ADIO_Request *  request,
int *  error_code 
)

void ADIOI_GRIDFTP_Flush ( ADIO_File  fd,
int *  error_code 
)

Definition at line 16 of file ad_gridftp_flush.c.

void ADIOI_GRIDFTP_Resize ( ADIO_File  fd,
ADIO_Offset  size,
int *  error_code 
)

Definition at line 55 of file ad_gridftp_resize.c.

References ADIOI_FileD::access_mode, ADIOI_Error(), ADIOI_Snprintf(), ADIOI_FileD::comm, ADIOI_FileD::fd_sys, ADIOI_FileD::filename, globus_err_handler(), gridftp_fh, MPI_Comm_rank, MPIO_Err_create_code(), myname, oattr, resize_cb(), resize_cond, resize_done, resize_lock, resize_success, and resize_wrdata_cb().

Here is the call graph for this function:

void ADIOI_GRIDFTP_SetInfo ( ADIO_File  fd,
MPI_Info  users_info,
int *  error_code 
)

Definition at line 30 of file ad_gridftp_hints.c.

References ADIOI_GEN_SetInfo(), flag, ADIOI_FileD::info, key, MPI_Info_create(), MPI_Info_dup, MPI_Info_get_nkeys, MPI_Info_get_nthkey(), MPI_Info_get_valuelen(), value, and valuelen.

Here is the call graph for this function:

void ADIOI_GRIDFTP_Get_shared_fp ( ADIO_File  fd,
int  size,
ADIO_Offset *  shared_fp,
int *  error_code 
)

void ADIOI_GRIDFTP_Set_shared_fp ( ADIO_File  fd,
ADIO_Offset  offset,
int *  error_code 
)

void ADIOI_GRIDFTP_Delete ( char *  filename,
int *  error_code 
)

Definition at line 28 of file ad_gridftp_delete.c.

References cond, delete_cb(), delete_done, delete_success, globus_err_handler(), handle, lock, MPI_Comm_rank, MPIO_Err_create_code(), and myname.

Here is the call graph for this function:

void globus_err_handler ( const char *  routine,
const char *  caller,
globus_result_t  result 
)

Definition at line 25 of file globus_routines.c.

References MPI_Comm_rank.

Referenced by ADIOI_GRIDFTP_Close(), ADIOI_GRIDFTP_Delete(), ADIOI_GRIDFTP_Fcntl(), ADIOI_GRIDFTP_Open(), ADIOI_GRIDFTP_ReadContig(), ADIOI_GRIDFTP_ReadDiscontig(), ADIOI_GRIDFTP_Resize(), ADIOI_GRIDFTP_WriteContig(), and ADIOI_GRIDFTP_WriteDiscontig().

Here is the caller graph for this function:

Variable Documentation

int num_gridftp_handles

Definition at line 17 of file globus_routines.c.

Referenced by ADIOI_GRIDFTP_Close(), and ADIOI_GRIDFTP_Open().

globus_ftp_client_handle_t gridftp_fh[ADIO_GRIDFTP_HANDLES_MAX]

Definition at line 22 of file globus_routines.c.

Referenced by ADIOI_GRIDFTP_Close(), ADIOI_GRIDFTP_Fcntl(), ADIOI_GRIDFTP_Open(), ADIOI_GRIDFTP_ReadContig(), ADIOI_GRIDFTP_ReadDiscontig(), ADIOI_GRIDFTP_Resize(), ADIOI_GRIDFTP_WriteContig(), and ADIOI_GRIDFTP_WriteDiscontig().

globus_ftp_client_operationattr_t oattr[ADIO_GRIDFTP_HANDLES_MAX]

Definition at line 23 of file globus_routines.c.

Referenced by ADIOI_GRIDFTP_Close(), ADIOI_GRIDFTP_Fcntl(), ADIOI_GRIDFTP_Open(), ADIOI_GRIDFTP_ReadContig(), ADIOI_GRIDFTP_ReadDiscontig(), ADIOI_GRIDFTP_Resize(), ADIOI_GRIDFTP_WriteContig(), and ADIOI_GRIDFTP_WriteDiscontig().

Generated on Mon Sep 21 08:04:30 2020 for Charm++ by  doxygen 1.5.5