Public Member Functions | |
Director (CkArgMsg *m) | |
Director (CkMigrateMessage *m) | |
void | pup (PUP::er &p) |
void | openFile (string name, CkCallback opened, Options opts) |
void | fileOpened (FileToken file) |
void | prepareWriteSession_helper (FileToken file, size_t bytes, size_t offset, CkCallback ready, CkCallback complete) |
void | sessionComplete (FileToken token) |
void | close (FileToken token, CkCallback closed) |
Private Attributes | |
int | filesOpened |
map< FileToken, impl::FileInfo > | files |
CProxy_Manager | managers |
int | opnum |
int | sessionID |
Definition at line 64 of file ckio.C.
Ck::IO::impl::Director::Director | ( | CkArgMsg * | m | ) | [inline] |
Ck::IO::impl::Director::Director | ( | CkMigrateMessage * | m | ) | [inline] |
void Ck::IO::impl::Director::pup | ( | PUP::er & | p | ) | [inline] |
void Ck::IO::impl::Director::openFile | ( | string | name, | |
CkCallback | opened, | |||
Options | opts | |||
) | [inline] |
Definition at line 93 of file ckio.C.
References Ck::IO::Options::activePEs, Ck::IO::Options::basePE, CkGetFileStripeSize(), BGConverse::CkMyNodeSize(), Converse::CkNumPes(), files, filesOpened, managers, min(), opnum, Ck::IO::Options::peStripe, Ck::IO::Options::skipPEs, and Ck::IO::Options::writeStripe.
void Ck::IO::impl::Director::fileOpened | ( | FileToken | file | ) | [inline] |
void Ck::IO::impl::Director::prepareWriteSession_helper | ( | FileToken | file, | |
size_t | bytes, | |||
size_t | offset, | |||
CkCallback | ready, | |||
CkCallback | complete | |||
) | [inline] |
Definition at line 113 of file ckio.C.
References files, CkCallback::isInvalid(), Ck::IO::Options::peStripe, sessionID, CkArrayOptions::setInitCallback(), CkCallback::setRefnum(), and CkArrayOptions::setStaticInsertion().
void Ck::IO::impl::Director::sessionComplete | ( | FileToken | token | ) | [inline] |
Definition at line 143 of file ckio.C.
References CkReductionMsg::buildNew(), files, CkCallback::invalid, CkReduction::nop, and session.
void Ck::IO::impl::Director::close | ( | FileToken | token, | |
CkCallback | closed | |||
) | [inline] |
int Ck::IO::impl::Director::filesOpened [private] |
map<FileToken, impl::FileInfo> Ck::IO::impl::Director::files [private] |
Definition at line 66 of file ckio.C.
Referenced by close(), fileOpened(), openFile(), prepareWriteSession_helper(), pup(), and sessionComplete().
CProxy_Manager Ck::IO::impl::Director::managers [private] |
int Ck::IO::impl::Director::opnum [private] |
int Ck::IO::impl::Director::sessionID [private] |