
Go to the source code of this file.
Data Structures | |
| struct | CcsDelayedReply_struct |
| struct | CcsHandlerRec |
Typedefs | |
| typedef CkHashtable_c | CcsHandlerTable |
| typedef struct CcsDelayedReply_struct | CcsDelayedReply |
| typedef void(* | CcsHandlerFn )(void *userPtr, int reqLen, const void *reqData) |
Functions | |
| CpvExtern (CcsHandlerTable, ccsTab) | |
| void | CcsRegisterHandler (const char *ccs_handlername, CmiHandler fn) |
| Backward compatability routine: register a regular converse-style handler to receive CCS requests. | |
| CcsHandlerRec * | CcsGetHandler (const char *name) |
| void | CcsRegisterHandlerFn (const char *ccs_handlername, CcsHandlerFn fn, void *userPtr) |
| Register a real Ccs handler function to receive these CCS requests. | |
| void | CcsSetMergeFn (const char *name, CmiReduceMergeFn newMerge) |
| Set the merging function for this CCS handler to newMerge. | |
| SIMPLE_REDUCTION (concat) | |
| SIMPLE_REDUCTION (logical_and) | |
| SIMPLE_REDUCTION (logical_or) | |
| SIMPLE_REDUCTION (bitvec_and) | |
| SIMPLE_POLYMORPH_REDUCTION (sum) | |
| SIMPLE_POLYMORPH_REDUCTION (product) | |
| SIMPLE_POLYMORPH_REDUCTION (max) | |
| SIMPLE_POLYMORPH_REDUCTION (min) | |
| void | CcsReleaseMessages () |
| void | CcsInit (char **argv) |
| int | CcsEnabled (void) |
| int | CcsIsRemoteRequest (void) |
| void | CcsCallerId (skt_ip_t *pip, unsigned int *pport) |
| void | CcsSendReply (int replyLen, const void *replyData) |
| void | CcsSendReplyNoError (int replyLen, const void *replyData) |
| CcsDelayedReply | CcsDelayReply (void) |
| void | CcsSendDelayedReply (CcsDelayedReply d, int replyLen, const void *replyData) |
| void | CcsNoReply () |
| void | CcsNoDelayedReply (CcsDelayedReply d) |
Variables | |
| int | _ccsHandlerIdx |
| typedef CkHashtable_c CcsHandlerTable |
Definition at line 27 of file conv-ccs.h.
| typedef void * CcsDelayedReply |
Definition at line 97 of file conv-ccs.h.
| typedef void(* CcsHandlerFn)(void *userPtr, int reqLen, const void *reqData) |
Definition at line 34 of file conv-ccs.h.
| CpvExtern | ( | CcsHandlerTable | , | |
| ccsTab | ||||
| ) |
| void CcsRegisterHandler | ( | const char * | ccs_handlername, | |
| CmiHandler | fn | |||
| ) |
Backward compatability routine: register a regular converse-style handler to receive CCS requests.
The requests will arrive as a Converse message, with a (useless) converse header.
Definition at line 52 of file conv-ccs.c.
References CkHashtablePut(), CcsHandlerRec::fnOld, initHandlerRec(), and CcsHandlerRec::name.
| CcsHandlerRec* CcsGetHandler | ( | const char * | name | ) |
| void CcsRegisterHandlerFn | ( | const char * | ccs_handlername, | |
| CcsHandlerFn | fn, | |||
| void * | userPtr | |||
| ) |
Register a real Ccs handler function to receive these CCS requests.
The requests will arrive as a flat, readonly buffer.
Definition at line 58 of file conv-ccs.c.
References CkHashtablePut(), CcsHandlerRec::fn, initHandlerRec(), CcsHandlerRec::name, and CcsHandlerRec::userPtr.
Referenced by ckcallback_group::registerCcsCallback().
| void CcsSetMergeFn | ( | const char * | name, | |
| CmiReduceMergeFn | newMerge | |||
| ) |
Set the merging function for this CCS handler to newMerge.
Definition at line 68 of file conv-ccs.c.
References CkHashtableGet(), CmiAbort(), CmiGetGlobalReduction(), CcsHandlerRec::mergeFn, and CcsHandlerRec::redID.
Referenced by CpdCharmInit(), and CpdInit().
| SIMPLE_REDUCTION | ( | concat | ) |
| SIMPLE_REDUCTION | ( | logical_and | ) |
| SIMPLE_REDUCTION | ( | logical_or | ) |
| SIMPLE_REDUCTION | ( | bitvec_and | ) |
| SIMPLE_POLYMORPH_REDUCTION | ( | sum | ) |
| SIMPLE_POLYMORPH_REDUCTION | ( | product | ) |
| SIMPLE_POLYMORPH_REDUCTION | ( | max | ) |
| SIMPLE_POLYMORPH_REDUCTION | ( | min | ) |
| void CcsReleaseMessages | ( | ) |
Definition at line 319 of file conv-ccs.c.
References free().
Referenced by CcsInit(), and CpdBgInit().
| void CcsInit | ( | char ** | argv | ) |
Definition at line 526 of file conv-ccs.c.
References CcdCallOnConditionKeep(), CcsBuiltinsInit(), CcsReleaseMessages(), CcsServer_new(), CcsServerCheck(), CkCreateHashtable_string(), CmiGetArgFlagDesc(), CmiGetArgIntDesc(), CmiGetArgStringDesc(), CmiMyPe(), CmiPrintf(), CmiRegisterHandler(), print_fw_handler(), print_fw_handler_idx, rep_fw_handler(), and req_fw_handler().
Referenced by ConverseCommonInit().
| int CcsEnabled | ( | void | ) |
| int CcsIsRemoteRequest | ( | void | ) |
Definition at line 150 of file conv-ccs.c.
References attr, and ChMessageInt().
Referenced by ccs_killport().
| void CcsSendReply | ( | int | replyLen, | |
| const void * | replyData | |||
| ) |
Definition at line 170 of file conv-ccs.c.
References CcsReply(), ChMessageInt_new(), and CmiAbort().
Referenced by ccs_getinfo(), CcsHandleRequest(), CcsImpl_netRequest(), CcsSendReplyNoError(), CpdConditional_SetupComm(), CpdDebugCallAllocationTree(), CpdDebugCallMemStat(), CpdDebugHandlerStatus(), CpdEndConditionalDeliver_master(), CpdList_ccs_list_items_fmt(), CpdList_ccs_list_items_txt(), CpdList_ccs_list_len(), CpdMachineArchitecture(), CpdRemoveAllBreakPoints(), CpdRemoveBreakPoint(), CpdSetBreakPoint(), getImageConfigHandler(), LV3D0_quit(), and LV3D0_setup().
| void CcsSendReplyNoError | ( | int | replyLen, | |
| const void * | replyData | |||
| ) |
Definition at line 179 of file conv-ccs.c.
References CcsSendReply().
Referenced by KillOnAllSigs().
| CcsDelayedReply CcsDelayReply | ( | void | ) |
Definition at line 158 of file conv-ccs.c.
References ChMessageInt(), CcsDelayedReply_struct::hdr, and malloc().
Referenced by ccsHandlerToCallback(), CpdDebugCallAllocationTree(), CpdDebugCallMemStat(), CpdSearchLeaks(), CWebHandler(), getImageHandler(), LV3D0_ClientManager_toClient::getViews(), LV3D0_qd(), LV3D0_stats(), and NetFEM_getCurrent().
| void CcsSendDelayedReply | ( | CcsDelayedReply | d, | |
| int | replyLen, | |||
| const void * | replyData | |||
| ) |
Definition at line 184 of file conv-ccs.c.
References CcsReply(), ChMessageInt_new(), free(), CcsDelayedReply_struct::hdr, and CcsImplHeader::len.
Referenced by TraceUtilizationBOC::ccsRequestSumDetailCompressed(), TraceSummaryBOC::ccsRequestSummaryDouble(), TraceSummaryBOC::ccsRequestSummaryUnsignedChar(), Ck_printclient(), CpdDebugReturnAllocationTree(), CpdDebugReturnMemStat(), CpdSearchLeaksDone(), CWeb_Deliver(), emptyDoneFn(), PythonCCS::forwardInt(), PythonCCS::forwardString(), NetFEM_state::getCurrent(), liveViz0Deposit(), PythonObject::print(), printStats(), PythonObject::replyIntValue(), CkCallback::send(), and LV3D0_ClientManager_toClient::sendReply().
| void CcsNoReply | ( | ) |
| void CcsNoDelayedReply | ( | CcsDelayedReply | d | ) |
Definition at line 200 of file conv-ccs.c.
References CcsReply(), ChMessageInt_new(), free(), CcsDelayedReply_struct::hdr, and CcsImplHeader::len.
Referenced by PythonObject::print().
Definition at line 281 of file conv-ccs.c.
1.5.5