Data Structures | |
class | SessionCommitMsg |
struct | Options |
Note: The values in options are not currently a stable or working interface. More... | |
class | File |
class | FileReadyMsg |
class | Session |
class | SessionReadyMsg |
Namespaces | |
namespace | impl |
Functions | |
void | open (string name, CkCallback opened, Options opts) |
void | startSession (File file, size_t bytes, size_t offset, CkCallback ready, CkCallback complete) |
Prepare to write data into the file described by token, in the window defined by the offset and byte length. | |
void | startSession (File file, size_t bytes, size_t offset, CkCallback ready, const char *commitData, size_t commitBytes, size_t commitOffset, CkCallback complete) |
Prepare to write data into. | |
void | write (Session session, const char *data, size_t bytes, size_t offset) |
Write the given data into the file to which session is attached. | |
void | close (File file, CkCallback closed) |
Close a previously-opened file. | |
void | open (std::string name, CkCallback opened, Options opts) |
Open the named file on the selected subset of PEs, and send a FileReadyMsg to the opened callback when the system is ready to accept session requests on that file. |
void Ck::IO::open | ( | string | name, | |
CkCallback | opened, | |||
Options | opts | |||
) |
void Ck::IO::startSession | ( | File | file, | |
size_t | bytes, | |||
size_t | offset, | |||
CkCallback | ready, | |||
CkCallback | complete | |||
) |
Prepare to write data into the file described by token, in the window defined by the offset and byte length.
When the session is set up, a SessionReadyMsg will be sent to the ready callback. When all of the data has been written and synced, a message will be sent to the complete callback.
Definition at line 410 of file ckio.C.
References Ck::IO::impl::director, and Ck::IO::File::token.
void Ck::IO::startSession | ( | File | file, | |
size_t | bytes, | |||
size_t | offset, | |||
CkCallback | ready, | |||
const char * | commitData, | |||
size_t | commitBytes, | |||
size_t | commitOffset, | |||
CkCallback | complete | |||
) |
Prepare to write data into.
Definition at line 414 of file ckio.C.
References Ck::IO::impl::director, and Ck::IO::File::token.
Write the given data into the file to which session is attached.
The offset is relative to the file as a whole, not to the session's offset.
Definition at line 422 of file ckio.C.
Referenced by ADIOI_BGL_Get_shared_fp(), ADIOI_BGL_Set_shared_fp(), ADIOI_BGL_WriteContig(), ADIOI_BGL_WriteStrided(), ADIOI_GEN_WriteContig(), ADIOI_HFS_WriteContig(), ADIOI_LUSTRE_IOContig(), ADIOI_NFS_Get_shared_fp(), ADIOI_NFS_Set_shared_fp(), ADIOI_NFS_WriteContig(), ADIOI_NFS_WriteStrided(), ADIOI_NOLOCK_WriteStrided(), ADIOI_PANFS_WriteContig(), ADIOI_PIOFS_WriteContig(), ADIOI_PIOFS_WriteStrided(), arg_init(), CcsReply(), CmiSendMessageXpmem(), CthAliasCreate(), init_ranges(), ntohl(), and printStats().
void Ck::IO::close | ( | File | file, | |
CkCallback | closed | |||
) |
Close a previously-opened file.
All sessions on that file must have already signalled that they are complete.
Definition at line 427 of file ckio.C.
References Ck::IO::impl::director, and Ck::IO::File::token.
Referenced by ADIOI_BGL_Close(), ADIOI_GEN_Close(), ADIOI_LUSTRE_SetInfo(), ADIOI_PANFS_Open(), ADIOI_PFS_SetInfo(), ADIOI_process_system_hints(), ADIOI_XFS_Open(), arg_init(), CCS_RAND_new(), CmiInitCma(), CmiSendMessagePxshm(), CmiSendMessageXpmem(), CpdConditional_SetupComm(), CpdEndConditionalDeliver_master(), CthAliasFree(), Ck::IO::impl::Manager::doClose(), getRSS(), init_mparams(), init_ranges(), and main().
void Ck::IO::open | ( | std::string | name, | |
CkCallback | opened, | |||
Options | opts | |||
) |
Open the named file on the selected subset of PEs, and send a FileReadyMsg to the opened callback when the system is ready to accept session requests on that file.
Note: The values in options are not currently a stable or working interface. Users should not set anything in them.
Referenced by ADIOI_BGL_Open(), ADIOI_LUSTRE_Open(), ADIOI_LUSTRE_SetInfo(), ADIOI_NFS_Open(), ADIOI_PANFS_Open(), ADIOI_PFS_Open(), ADIOI_PFS_SetInfo(), ADIOI_PIOFS_Open(), ADIOI_SFS_Open(), ADIOI_UFS_Open(), ADIOI_XFS_Open(), arg_init(), CCS_RAND_new(), CmiInitCma(), CmiInitXpmem(), CmiOpen(), CmiSendMessageXpmem(), find_file(), getRSS(), gk_graph_ComputeBestFOrdering0(), init_mparams(), init_ranges(), main(), and StartCharmExt().