Go to the source code of this file.
Data Structures | |
class | ckcallback_main |
class | ckcallback_group |
Typedefs | |
typedef CkHashtableT < CkHashtableAdaptorT < unsigned int >, CkCallback * > | threadCB_t |
Enumerations | |
enum | { dataMsgTag = 0x7ed2beef } |
Functions | |
void | LibCkExit () |
CpvStaticDeclare (threadCB_t *, threadCBs) | |
CpvStaticDeclare (unsigned int, nextThreadCB) | |
static void | CkCallbackSendExt (const CkCallback &cb, void *msg) |
void | ccsHandlerToCallback (void *cbPtr, int reqLen, const void *reqData) |
void | CcsRegisterHandler (const char *ccs_handlername, const CkCallback &cb) |
When a CCS request comes in from the network with this handlername, call this callback with an appropriate CkCcsRequestMsg. | |
void | CkCallbackInit () |
Variables | |
CProxy_ckcallback_group | _ckcallbackgroup |
void(* | CreateReductionTargetMsgExt )(void *, int, int, int, char **, int *) |
typedef CkHashtableT<CkHashtableAdaptorT<unsigned int>, CkCallback*> threadCB_t |
Definition at line 21 of file ckcallback.C.
anonymous enum |
void LibCkExit | ( | ) |
Definition at line 44 of file mpi-interoperate.C.
Referenced by CkCallback::send().
CpvStaticDeclare | ( | threadCB_t * | , | |
threadCBs | ||||
) |
CpvStaticDeclare | ( | unsigned | int, | |
nextThreadCB | ||||
) |
static void CkCallbackSendExt | ( | const CkCallback & | cb, | |
void * | msg | |||
) | [static] |
Definition at line 232 of file ckcallback.C.
References CkCallback::callbackData::array, CkArrayIndexBase::asChild(), CkCallback::bcastArray, CkCallback::bcastGroup, CkCallback::callbackData::chare, CkArrayExtSend_multi(), CkChareExtSend_multi(), CkFreeMsg(), CkGroupExtSend_multi(), CreateReductionTargetMsgExt, CkCallback::d, CkArrayIndexBase::dimension, CkCallback::callbackData::s_array::ep, CkCallback::callbackData::s_group::ep, CkCallback::callbackData::s_chare::ep, CkReductionMsg::getData(), CkReductionMsg::getLength(), CkReductionMsg::getReducer(), CkCallback::callbackData::group, CkCallback::callbackData::s_array::id, CkCallback::callbackData::s_group::id, CkCallback::callbackData::s_chare::id, CkCallback::callbackData::s_array::idx, _ckGroupID::idx, CkChareID::objPtr, CkCallback::callbackData::s_group::onPE, CkChareID::onPE, CkCallback::callbackData::s_array::refnum, CkCallback::callbackData::s_group::refnum, CkCallback::callbackData::s_chare::refnum, CkCallback::sendArray, CkCallback::sendChare, CkCallback::sendGroup, and CkCallback::type.
Referenced by CkCallback::send().
void ccsHandlerToCallback | ( | void * | cbPtr, | |
int | reqLen, | |||
const void * | reqData | |||
) |
Definition at line 538 of file ckcallback.C.
References cb, CcsDelayReply(), CkCcsRequestMsg::data, CkCcsRequestMsg::length, msg, CkCcsRequestMsg::reply, and CkCallback::send().
Referenced by ckcallback_group::registerCcsCallback().
void CcsRegisterHandler | ( | const char * | ccs_handlername, | |
const CkCallback & | cb | |||
) |
When a CCS request comes in from the network with this handlername, call this callback with an appropriate CkCcsRequestMsg.
You must eventually call CcsSendDelayedReply(msg->reply,...) each time this callback is activated.
Unlike the regular converse CcsRegisterHandler (in conv-ccs.h), this call need only be made once, on processor 0, and all processors will be able to respond to the CCS request.
Definition at line 555 of file ckcallback.C.
References _ckcallbackgroup.
Referenced by CcsBuiltinsInit(), CpdCharmInit(), CpdPython::CpdPython(), CWebInit(), TraceSummaryBOC::initCCS(), liveViz0Init(), liveViz0PollInit(), LV3D0_Init(), manager_init(), NetFEM_Init(), ntohl(), and TraceUtilizationInit::TraceUtilizationInit().
void CkCallbackInit | ( | ) |
Definition at line 582 of file ckcallback.C.
Referenced by _initCharm().
CProxy_ckcallback_group _ckcallbackgroup |
Definition at line 19 of file ckcallback.C.
Referenced by CcsRegisterHandler(), ckcallback_main::ckcallback_main(), invokeCallback(), and CkCallback::send().
void(* CreateReductionTargetMsgExt)(void *, int, int, int, char **, int *) |
Referenced by CkCallbackSendExt(), and registerCreateReductionTargetMsgExtCallback().