Go to the source code of this file.
Functions | |
void | ADIOI_LUSTRE_Open (ADIO_File fd, int *error_code) |
void | ADIOI_LUSTRE_Close (ADIO_File fd, int *error_code) |
void | ADIOI_LUSTRE_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_LUSTRE_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_LUSTRE_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_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) |
void | ADIOI_LUSTRE_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_LUSTRE_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_LUSTRE_Fcntl (ADIO_File fd, int flag, ADIO_Fcntl_t *fcntl_struct, int *error_code) |
void | ADIOI_LUSTRE_SetInfo (ADIO_File fd, MPI_Info users_info, int *error_code) |
int | ADIOI_LUSTRE_Docollect (ADIO_File fd, int contig_access_count, ADIO_Offset *len_list, int nprocs) |
void | ADIOI_LUSTRE_Get_striping_info (ADIO_File fd, int **striping_info_ptr, int mode) |
void | ADIOI_LUSTRE_Calc_my_req (ADIO_File fd, ADIO_Offset *offset_list, ADIO_Offset *len_list, int contig_access_count, int *striping_info, int nprocs, int *count_my_req_procs_ptr, int **count_my_req_per_proc_ptr, ADIOI_Access **my_req_ptr, int ***buf_idx_ptr) |
int | ADIOI_LUSTRE_Calc_aggregator (ADIO_File fd, ADIO_Offset off, ADIO_Offset *len, int *striping_info) |
Definition at line 18 of file ad_lustre_open.c.
References ADIOI_FileD::access_mode, ADIOI_FileD::d_mem, ADIOI_FileD::d_miniosz, ADIOI_FileD::direct_read, ADIOI_FileD::direct_write, ADIOI_FileD::fd_direct, ADIOI_FileD::fd_sys, ADIOI_FileD::filename, ADIOI_FileD::fp_ind, ADIOI_FileD::fp_sys_posn, ADIOI_Hints_struct::fs_hints, ADIOI_FileD::hints, ADIOI_FileD::info, ADIOI_Hints_struct::lustre, MPIO_Err_create_code(), myname, Ck::IO::open(), ADIOI_FileD::perm, perm, ADIOI_Hints_struct::striping_factor, ADIOI_Hints_struct::striping_unit, and value.
void ADIOI_LUSTRE_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 195 of file ad_lustre_rwcontig.c.
References ADIOI_LUSTRE_IOContig().
void ADIOI_LUSTRE_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 187 of file ad_lustre_rwcontig.c.
References ADIOI_LUSTRE_IOContig().
void ADIOI_LUSTRE_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 147 of file ad_lustre_wrstr.c.
References ADIO_WriteContig(), ADIOI_Datatype_iscontig(), ADIOI_Delete_flattened(), ADIOI_Flatten_datatype(), ADIOI_GEN_WriteStrided_naive(), ADIOI_HINT_DISABLE, ADIOI_FileD::atomicity, ADIOI_Fl_node::blocklens, ADIOI_Fl_node::count, ADIOI_FileD::disp, disp, ADIOI_Hints_struct::ds_write, ADIOI_FileD::etype_size, ADIOI_FileD::filetype, ADIOI_FileD::fp_ind, ADIOI_FileD::fp_sys_posn, ADIOI_FileD::hints, ADIOI_Fl_node::indices, MPI_Type_size, MPIR_Status_set_bytes(), myname, ADIOI_Fl_node::next, size, ADIOI_Hints_struct::striping_unit, and ADIOI_Fl_node::type.
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.
void ADIOI_LUSTRE_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_LUSTRE_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_LUSTRE_Fcntl | ( | ADIO_File | fd, | |
int | flag, | |||
ADIO_Fcntl_t * | fcntl_struct, | |||
int * | error_code | |||
) |
Definition at line 12 of file ad_lustre_fcntl.c.
References ADIO_ReadContig(), ADIO_WriteContig(), ADIO_Fcntl_t::atomicity, ADIOI_FileD::atomicity, buf, ADIO_Fcntl_t::diskspace, CpuTopoDetails::done, ADIOI_FileD::fd_sys, ADIOI_FileD::fp_sys_posn, ADIO_Fcntl_t::fsize, len, MPI_Abort, MPIO_Err_create_code(), myname, size, and status.
Definition at line 14 of file ad_lustre_hints.c.
References ADIOI_FileD::access_mode, ADIOI_Direct_read, ADIOI_Direct_write, ADIOI_GEN_SetInfo(), ADIOI_HINT_DISABLE, ADIOI_HINT_ENABLE, Ck::IO::close(), ADIOI_FileD::comm, ADIOI_FileD::direct_read, ADIOI_FileD::direct_write, ADIOI_FileD::filename, flag, ADIOI_Hints_struct::fs_hints, ADIOI_FileD::hints, ADIOI_FileD::info, ADIOI_Hints_struct::lustre, MPI_Abort, MPI_Barrier, MPI_Bcast, MPI_Comm_rank, MPI_Info_create(), myname, Ck::IO::open(), ADIOI_FileD::perm, perm, and value.
int ADIOI_LUSTRE_Docollect | ( | ADIO_File | fd, | |
int | contig_access_count, | |||
ADIO_Offset * | len_list, | |||
int | nprocs | |||
) |
Definition at line 293 of file ad_lustre_aggregate.c.
References ADIOI_FileD::comm, ADIOI_Hints_struct::fs_hints, ADIOI_FileD::hints, int, ADIOI_Hints_struct::lustre, and MPI_Allreduce.
Referenced by ADIOI_LUSTRE_WriteStridedColl().
Definition at line 16 of file ad_lustre_aggregate.c.
References ADIOI_Hints_struct::cb_nodes, ADIOI_Hints_struct::fs_hints, ADIOI_FileD::hints, ADIOI_Hints_struct::lustre, ADIOI_Hints_struct::striping_factor, and ADIOI_Hints_struct::striping_unit.
Referenced by ADIOI_LUSTRE_WriteStridedColl().
void ADIOI_LUSTRE_Calc_my_req | ( | ADIO_File | fd, | |
ADIO_Offset * | offset_list, | |||
ADIO_Offset * | len_list, | |||
int | contig_access_count, | |||
int * | striping_info, | |||
int | nprocs, | |||
int * | count_my_req_procs_ptr, | |||
int ** | count_my_req_per_proc_ptr, | |||
ADIOI_Access ** | my_req_ptr, | |||
int *** | buf_idx_ptr | |||
) |
Definition at line 137 of file ad_lustre_aggregate.c.
References ADIOI_LUSTRE_Calc_aggregator(), count, ADIOI_Access::count, int, PUP::l, ADIOI_Access::lens, and ADIOI_Access::offsets.
Referenced by ADIOI_LUSTRE_WriteStridedColl().
int ADIOI_LUSTRE_Calc_aggregator | ( | ADIO_File | fd, | |
ADIO_Offset | off, | |||
ADIO_Offset * | len, | |||
int * | striping_info | |||
) |
Definition at line 100 of file ad_lustre_aggregate.c.
References ADIOI_Hints_struct::cb_nodes, ADIOI_FileD::hints, int, MPI_Abort, rank, and ADIOI_Hints_struct::ranklist.
Referenced by ADIOI_LUSTRE_Calc_my_req(), and ADIOI_LUSTRE_Fill_send_buffer().