
#include <ckio.h>


Public Member Functions | |
| Manager () | |
| void | prepareOutput (const char *name, size_t bytes, CkCallback ready, CkCallback complete, Options opts=Options()) |
| Application-facing methods, invoked locally on the calling PE. | |
| void | write (Token token, const char *data, size_t bytes, size_t offset) |
| void | prepareInput (const char *name, CkCallback ready, Options opts=Options()) |
| void | read (Token token, void *data, size_t bytes, size_t offset, CkCallback complete) |
| void | write_forwardData (Token token, const char *data, size_t bytes, size_t offset) |
| Internal methods, used for interaction among IO managers across the system. | |
| void | write_dataWritten (Token token, size_t bytes) |
Data Fields | |
| Manager_SDAG_CODE | |
Private Member Functions | |
| int | lastActivePE (const Options &opts) |
Private Attributes | |
| int | filesOpened |
| Token | nextToken |
| std::map< Token, FileInfo > | files |
| CkCallback | nextReady |
Tokens are passed to
Definition at line 105 of file ckio.h.
| void Ck::IO::Manager::prepareOutput | ( | const char * | name, | |
| size_t | bytes, | |||
| CkCallback | ready, | |||
| CkCallback | complete, | |||
| Options | opts = Options() | |||
| ) |
| void Ck::IO::Manager::write | ( | Token | token, | |
| const char * | data, | |||
| size_t | bytes, | |||
| size_t | offset | |||
| ) |
Definition at line 18 of file ckio.C.
References Ck::IO::Options::basePE, files, min(), opts, Ck::IO::Options::peStripe, and Ck::IO::Options::skipPEs.
| void Ck::IO::Manager::prepareInput | ( | const char * | name, | |
| CkCallback | ready, | |||
| Options | opts = Options() | |||
| ) |
| void Ck::IO::Manager::read | ( | Token | token, | |
| void * | data, | |||
| size_t | bytes, | |||
| size_t | offset, | |||
| CkCallback | complete | |||
| ) |
| void Ck::IO::Manager::write_forwardData | ( | Token | token, | |
| const char * | data, | |||
| size_t | bytes, | |||
| size_t | offset | |||
| ) |
Internal methods, used for interaction among IO managers across the system.
Definition at line 31 of file ckio.C.
References Ck::IO::buffer::array, Ck::IO::buffer::bytes_filled_so_far, Converse::CkMyPe(), errno, Ck::IO::buffer::expect(), files, Ck::IO::buffer::insertData(), Ck::IO::buffer::isFull(), and min().
| void Ck::IO::Manager::write_dataWritten | ( | Token | token, | |
| size_t | bytes | |||
| ) |
Definition at line 133 of file ckio.h.
References Ck::IO::Options::activePEs, Ck::IO::Options::basePE, and Ck::IO::Options::skipPEs.
int Ck::IO::Manager::filesOpened [private] |
Token Ck::IO::Manager::nextToken [private] |
std::map<Token, FileInfo> Ck::IO::Manager::files [private] |
Definition at line 130 of file ckio.h.
Referenced by write(), write_dataWritten(), and write_forwardData().
CkCallback Ck::IO::Manager::nextReady [private] |
1.5.5