
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().

1.5.5