
Go to the source code of this file.
Data Structures | |
| struct | CmiHandlerInfo |
| struct | CmiChunkHeader |
| This header goes before each chunk of memory allocated with CmiAlloc. More... | |
| struct | infiCmiChunkHeaderStruct |
| struct | CsdSchedulerState_t |
| struct | CmiReduction |
| struct | CthThreadToken |
| struct | CthThreadListener |
| struct | CmiIsomallocBlockList |
| struct | Cfuture_s |
| struct | _CmiObjId |
| struct | CmiFragmentHeader |
| struct | CmiNotifyCommThdMsg |
Typedefs | |
| typedef int | CmiNodeLock |
| typedef int | CmiImmediateLockType |
| typedef CMK_TYPEDEF_INT2 | CmiInt2 |
| typedef CMK_TYPEDEF_INT4 | CmiInt4 |
| typedef CMK_TYPEDEF_INT8 | CmiInt8 |
| typedef CMK_TYPEDEF_UINT2 | CmiUInt2 |
| typedef CMK_TYPEDEF_UINT4 | CmiUInt4 |
| typedef CMK_TYPEDEF_UINT8 | CmiUInt8 |
| typedef CMK_TYPEDEF_FLOAT4 | CmiFloat4 |
| typedef CMK_TYPEDEF_FLOAT8 | CmiFloat8 |
| typedef CmiUInt8 | CmiIntPtr |
| typedef void * | CmiCommHandle |
| typedef void(* | CmiHandler )(void *msg) |
| typedef void(* | CmiHandlerEx )(void *msg, void *userPtr) |
| typedef struct CMK_MSG_HEADER_BASIC | CmiMsgHeaderBasic |
| typedef struct CMK_MSG_HEADER_EXT | CmiMsgHeaderExt |
| typedef struct CMK_MSG_HEADER_BIGSIM_ | CmiBlueGeneMsgHeader |
| typedef struct infiCmiChunkHeaderStruct | infiCmiChunkHeader |
| typedef void(* | CmiStartFn )(int argc, char **argv) |
| typedef CMK_MULTICAST_GROUP_TYPE | CmiGroup |
| typedef void *(* | CmiReduceMergeFn )(int *, void *, void **, int) |
| typedef void(* | CmiReducePupFn )(void *, void *) |
| typedef void(* | CmiReduceDeleteFn )(void *) |
| typedef CmiUInt2 | CmiReductionID |
| typedef struct CthThreadStruct * | CthThread |
| typedef void(* | CthVoidFn )() |
| typedef void(* | CthAwkFn )(CthThreadToken *, int, int prioBits, unsigned int *prioptr) |
| typedef CthThread(* | CthThFn )() |
| typedef struct CtgGlobalStruct * | CtgGlobals |
| typedef void(* | CthThreadListener_suspend )(struct CthThreadListener *l) |
| typedef void(* | CthThreadListener_resume )(struct CthThreadListener *l) |
| typedef void(* | CthThreadListener_free )(struct CthThreadListener *l) |
| typedef struct CmiIsomallocBlockList | CmiIsomallocBlockList |
| typedef struct Cfuture_s | Cfuture |
| typedef void(* | CldPackFn )(void *msg) |
| typedef void(* | CldInfoFn )(void *msg, CldPackFn *packer, int *len, int *queueing, int *priobits, unsigned int **prioptr) |
| typedef int(* | CldEstimator )(void) |
| typedef struct CmmTableStruct * | CmmTable |
| typedef void(* | CmmPupMessageFn )(pup_er p, void **msg) |
| typedef void(* | CcdVoidFn )(void *userParam, double curWallTime) |
| typedef int(* | CmiSwitchToPEFnPtr )(int pe) |
| typedef struct _CmiObjId | CmiObjId |
| typedef void(* | CmiCommThdFnPtr )(int numParams, void *params) |
Enumerations | |
| enum | CmiBool { CmiFalse = 0, CmiTrue = 1 } |
| enum | bool { false = 0, true = 1, false = 0, true = 1 } |
Functions | |
| void | CpdSetInitializeMemory (int v) |
| void | CpdSystemEnter () |
| void | CpdSystemExit () |
| int | setMemoryChareIDFromPtr (void *p) |
| void | setMemoryChareID (int id) |
| void | setMemoryOwnedBy (void *p, int id) |
| int | CmiMyRank_ () |
| void | CmiMemLock () |
| void | CmiMemUnlock () |
| int | CmiMyPe () |
| int | CmiMyRank () |
| int | CmiNodeFirst (int node) |
| int | CmiNodeSize (int node) |
| int | CmiNodeOf (int pe) |
| int | CmiRankOf (int pe) |
| void | CmiNodeBarrier (void) |
| void | CmiNodeAllBarrier (void) |
| CmiNodeLock | CmiCreateLock () |
| void | CmiDestroyLock (CmiNodeLock lock) |
| void * | CmiSvAlloc (int) |
| void | CmiLock (CmiNodeLock lock) |
| void | CmiUnlock (CmiNodeLock lock) |
| int | CmiTryLock (CmiNodeLock lock) |
| int | CmiBarrier (void) |
| int | CmiBarrierZero (void) |
| int | CmiNumCores (void) |
| int | CmiCpuTopologyEnabled () |
| int | CmiPeOnSamePhysicalNode (int pe1, int pe2) |
| int | CmiNumPhysicalNodes () |
| int | CmiPhysicalNodeID (int pe) |
| int | CmiNumPesOnPhysicalNode (int node) |
| void | CmiGetPesOnPhysicalNode (int node, int **pelist, int *num) |
| int | CmiGetFirstPeOnPhysicalNode (int node) |
| int | CmiPhysicalRank (int pe) |
| int | CmiPrintCPUAffinity () |
| int | CmiSetCPUAffinity (int core) |
| int | CmiOnCore () |
| int | CmiLongSendQueue (int forNode, int longerThanBytes) |
| Return 1 if our outgoing message queue for this node is longer than this many bytes. | |
| CpvExtern (CmiHandlerInfo *, CmiHandlerTable) | |
| CpvExtern (int, CmiHandlerMax) | |
| CpvExtern (void *, CsdSchedQueue) | |
| CpvExtern (void *, CsdGridQueue) | |
| CpvExtern (void *, CsdObjQueue) | |
| CsvExtern (void *, CsdNodeQueue) | |
| CsvExtern (CmiNodeLock, CsdNodeQueueLock) | |
| CpvExtern (int, CsdStopFlag) | |
| CpvExtern (int, CsdLocalCount) | |
| int | CmiRegisterHandler (CmiHandler h) |
| int | CmiRegisterHandlerEx (CmiHandlerEx h, void *userPtr) |
| int | CmiRegisterHandlerLocal (CmiHandler) |
| int | CmiRegisterHandlerGlobal (CmiHandler) |
| void | CmiNumberHandler (int n, CmiHandler h) |
| void | CmiNumberHandlerEx (int n, CmiHandlerEx h, void *userPtr) |
| CpvExtern (int, _curRestartPhase) | |
| struct infiCmiChunkMetaDataStruct * | registerMultiSendMesg (char *msg, int msgSize) |
| void * | malloc_nomigrate (size_t size) |
| void * | CmiAlloc (int size) |
| Allocate `size` bytes of memory usable as a message buffer. | |
| void | CmiReference (void *blk) |
| Increment the reference count for this block's owner. | |
| int | CmiGetReference (void *blk) |
| int | CmiSize (void *blk) |
| Return the size of the user portion of this block. | |
| void | CmiFree (void *blk) |
| Decrement the reference count for this block. | |
| void * | CmiTmpAlloc (int size) |
| void | CmiTmpFree (void *) |
| void | CmiMemoryCheck (void) |
| void | CmiMemoryMark (void) |
| void | CmiMemoryMarkBlock (void *blk) |
| void | CmiMemorySweep (const char *where) |
| CMK_TYPEDEF_UINT8 | CmiMemoryUsage () |
| Return number of bytes currently allocated, if possible. | |
| CMK_TYPEDEF_UINT8 | CmiMaxMemoryUsage () |
| Return number of maximum number of bytes allocated since the last call to CmiResetMaxMemory(), if possible. | |
| void | CmiResetMaxMemory () |
| Reset the mechanism that records the highest seen (high watermark) memory usage. | |
| CMK_TYPEDEF_UINT8 | CmiMinMemoryUsage () |
| void | CmiResetMinMemory () |
| void * | CmiMallocAligned (const size_t size, const unsigned int alignment) |
| void | CmiFreeAligned (void *ptr) |
| int | CmiMemoryIs (int flag) |
| int | CmiThreadIs (int flag) |
| void | CmiMkdir (const char *dirName) |
| double | CmiCpuTimer (void) |
| static __inline__ unsigned long long int | rdtsc (void) |
| double | CmiStartTimer (void) |
| double | CmiInitTime (void) |
| void | CmiTimerInit (char **argv) |
| int | CmiTimerAbsolute () |
| double | CmiTimer (void) |
| double | CmiWallTimer (void) |
| int | CmiTimerIsSynchronized () |
| char * | CmiPrintDate () |
| void | CmiPrintf (const char *,...) |
| void | CmiError (const char *,...) |
| int | CmiScanf (const char *,...) |
| void | __cmi_assert (const char *, const char *, int) |
| CpvExtern (int, _ccd_numchecks) | |
| void | CcdCallBacks () |
| void | CsdEndIdle (void) |
| void | CsdStillIdle (void) |
| void | CsdBeginIdle (void) |
| void | CsdSchedulerState_new (CsdSchedulerState_t *state) |
| void * | CsdNextMessage (CsdSchedulerState_t *state) |
| Dequeue and return the next message from the unprocessed message queues. | |
| void * | CsdNextLocalNodeMessage (CsdSchedulerState_t *state) |
| void * | CmiGetNonLocal (void) |
| void | CmiNotifyIdle (void) |
| int | CsdScheduler (int maxmsgs) |
| void | CsdScheduleForever (void) |
| The main scheduler loop that repeatedly executes messages from a queue, forever. | |
| int | CsdScheduleCount (int maxmsgs) |
| void | CsdSchedulePoll (void) |
| void | CsdScheduleNodePoll (void) |
| int | CmiNumSpanTreeChildren (int) |
| int | CmiSpanTreeParent (int) |
| void | CmiSpanTreeChildren (int node, int *children) |
| int | CmiNumNodeSpanTreeChildren (int) |
| int | CmiNodeSpanTreeParent (int) |
| void | CmiNodeSpanTreeChildren (int node, int *children) |
| void | CmiGroupInit () |
| CmiGroup | CmiEstablishGroup (int npes, int *pes) |
| void | CmiLookupGroup (CmiGroup grp, int *npes, int **pes) |
| void | CmiPushPE (int, void *) |
| void | CmiSyncSendFn (int, int, char *) |
| CmiCommHandle | CmiAsyncSendFn (int, int, char *) |
| void | CmiFreeSendFn (int, int, char *) |
| void | CmiSyncBroadcastFn (int, char *) |
| CmiCommHandle | CmiAsyncBroadcastFn (int, char *) |
| void | CmiFreeBroadcastFn (int, char *) |
| void | CmiSyncBroadcastAllFn (int, char *) |
| CmiCommHandle | CmiAsyncBroadcastAllFn (int, char *) |
| void | CmiFreeBroadcastAllFn (int, char *) |
| void | CmiSyncListSendFn (int, int *, int, char *) |
| CmiCommHandle | CmiAsyncListSendFn (int, int *, int, char *) |
| void | CmiFreeListSendFn (int, int *, int, char *) |
| void | CmiSyncMulticastFn (CmiGroup, int, char *) |
| CmiCommHandle | CmiAsyncMulticastFn (CmiGroup, int, char *) |
| void | CmiFreeMulticastFn (CmiGroup, int, char *) |
| void * | CmiReduceMergeFn_random (int *, void *, void **, int) |
| void | CmiReduce (void *msg, int size, CmiReduceMergeFn mergeFn) |
| void | CmiReduceStruct (void *data, CmiReducePupFn pupFn, CmiReduceMergeFn mergeFn, CmiHandler dest, CmiReduceDeleteFn deleteFn) |
| void | CmiReduceID (void *msg, int size, CmiReduceMergeFn mergeFn, CmiReductionID id) |
| void | CmiReduceStructID (void *data, CmiReducePupFn pupFn, CmiReduceMergeFn mergeFn, CmiHandler dest, CmiReduceDeleteFn deleteFn, CmiReductionID id) |
| void | CmiListReduce (int npes, int *pes, void *msg, int size, CmiReduceMergeFn mergeFn, CmiReductionID id) |
| void | CmiListReduceStruct (int npes, int *pes, void *data, CmiReducePupFn pupFn, CmiReduceMergeFn mergeFn, CmiHandler dest, CmiReduceDeleteFn deleteFn, CmiReductionID id) |
| void | CmiGroupReduce (CmiGroup grp, void *msg, int size, CmiReduceMergeFn mergeFn, CmiReductionID id) |
| void | CmiGroupReduceStruct (CmiGroup grp, void *data, CmiReducePupFn pupFn, CmiReduceMergeFn mergeFn, CmiHandler dest, CmiReduceDeleteFn deleteFn, CmiReductionID id) |
| void | CmiNodeReduce (void *msg, int size, CmiReduceMergeFn mergeFn, int, int, int) |
| void | CmiNodeReduceStruct (void *data, CmiReducePupFn pupFn, CmiReduceMergeFn mergeFn, CmiHandler dest, CmiReduceDeleteFn deleteFn) |
| int | CmiGetReductionHandler () |
| CmiHandler | CmiGetReductionDestination () |
| CmiReductionID | CmiGetGlobalReduction () |
| CmiReductionID | CmiGetDynamicReduction () |
| void | CmiGetDynamicReductionRemote (int handlerIdx, int pe, int dataSize, void *data) |
| void | CmiSyncVectorSend (int, int, int *, char **) |
| CmiCommHandle | CmiAsyncVectorSend (int, int, int *, char **) |
| void | CmiSyncVectorSendAndFree (int, int, int *, char **) |
| void | CmiMultipleSend (unsigned int, int, int *, char **) |
| void | CmiMultipleIsend (unsigned int, int, int *, char **) |
| int | CmiAsyncMsgSent (CmiCommHandle) |
| void | CmiReleaseCommHandle (CmiCommHandle) |
| void | CmiSyncNodeSendFn (int, int, char *) |
| CmiCommHandle | CmiAsyncNodeSendFn (int, int, char *) |
| void | CmiFreeNodeSendFn (int, int, char *) |
| void | CmiSyncNodeBroadcastFn (int, char *) |
| CmiCommHandle | CmiAsyncNodeBroadcastFn (int, char *) |
| void | CmiFreeNodeBroadcastFn (int, char *) |
| void | CmiSyncNodeBroadcastAllFn (int, char *) |
| CmiCommHandle | CmiAsyncNodeBroadcastAllFn (int, char *) |
| void | CmiFreeNodeBroadcastAllFn (int, char *) |
| void | CmiDeliversInit () |
| int | CmiDeliverMsgs (int maxmsgs) |
| void | CmiDeliverSpecificMsg (int handler) |
| void | CmiHandleMessage (void *msg) |
| Takes a message and calls its corresponding handler. | |
| CthThreadToken * | CthGetToken (CthThread) |
| void | CthSetSerialNo (CthThread t, int no) |
| int | CthImplemented (void) |
| int | CthMigratable () |
| CthThread | CthPup (pup_er, CthThread) |
| CthThread | CthSelf (void) |
| CthThread | CthCreate (CthVoidFn, void *, int) |
| CthThread | CthCreateMigratable (CthVoidFn, void *, int) |
| void | CthResume (CthThread) |
| void | CthFree (CthThread) |
| void | CthSetSuspendable (CthThread, int) |
| int | CthIsSuspendable (CthThread) |
| void | CthPrintThdMagic (CthThread) |
| void | CthPrintThdStack (CthThread) |
| void | CthSuspend (void) |
| void | CthAwaken (CthThread) |
| void | CthAwakenPrio (CthThread, int, int, unsigned int *) |
| void | CthSetStrategy (CthThread, CthAwkFn, CthThFn) |
| void | CthSetStrategyDefault (CthThread) |
| void | CthYield (void) |
| void | CthYieldPrio (int, int, unsigned int *) |
| void | CthSetNext (CthThread t, CthThread next) |
| CthThread | CthGetNext (CthThread t) |
| void | CthSwitchThread (CthThread t) |
| switch the thread to t | |
| size_t | CthStackOffset (CthThread t, char *p) |
| char * | CthPointer (CthThread t, size_t pos) |
| void | CthAutoYield (CthThread t, int flag) |
| double | CthAutoYieldFreq (CthThread t) |
| void | CthAutoYieldBlock (void) |
| void | CthAutoYieldUnblock (void) |
| void | CtgInit (void) |
| Initialize the globals support (called on each processor). | |
| CpvExtern (int, CmiPICMethod) | |
| PIC method used: 0 = nop, 1 = elfgot, 2 = elfcopy. | |
| CtgGlobals | CtgCreate (CthThread tid) |
| Copy the current globals into this new set. | |
| void | CtgInstall (CtgGlobals g) |
| Install this set of globals. | |
| CtgGlobals | CtgPup (pup_er, CtgGlobals g) |
| PUP this (not currently installed) globals set. | |
| void | CtgFree (CtgGlobals g) |
| Delete this (not currently installed) set of globals. | |
| CtgGlobals | CtgCurrentGlobals (void) |
| Return the current global list. | |
| void | CtgInstall_var (CtgGlobals g, void *ptr) |
| void | CtgUninstall_var (CtgGlobals g, void *ptr) |
| void | CthAddListener (CthThread th, struct CthThreadListener *l) |
| This listener is about to begin receiving suspend and resume events for this thread. | |
| void | CthUserAddListeners (CthThread th) |
| This is function is inserted into .def.h after thread creation. | |
| void * | CmiIsomalloc (int sizeInBytes, CthThread tid) |
| void * | CmiIsomallocAlign (size_t align, size_t size, CthThread t) |
| void | CmiIsomallocPup (pup_er p, void **block) |
| void | CmiIsomallocFree (void *block) |
| int | CmiIsomallocEnabled () |
| void | CmiEnableIsomalloc () |
| void | CmiDisableIsomalloc () |
| CmiInt8 | CmiIsomallocLength (void *block) |
| int | CmiIsomallocInRange (void *addr) |
| CmiIsomallocBlockList * | CmiIsomallocBlockListNew (CthThread t) |
| void | CmiIsomallocBlockListPup (pup_er p, CmiIsomallocBlockList **l, CthThread tid) |
| void | CmiIsomallocBlockListDelete (CmiIsomallocBlockList *l) |
| void * | CmiIsomallocBlockListMalloc (CmiIsomallocBlockList *l, size_t nBytes) |
| void * | CmiIsomallocBlockListMallocAlign (CmiIsomallocBlockList *l, size_t align, size_t nBytes) |
| void | CmiIsomallocBlockListFree (void *doomedMallocedBlock) |
| CthCpvExtern (char *, CthData) | |
| int | CthRegister (int dataSize) |
| Allocate another size bytes of thread-local storage, and return the offset into the thread storage buffer. | |
| void | CthRegistered (int dataOffMax) |
| Make sure we have room to store up to at least maxOffset bytes of thread-local storage. | |
| char * | CthGetData (CthThread t) |
| Cfuture | CfutureCreate (void) |
| void | CfutureSet (Cfuture f, void *val, int len) |
| void * | CfutureWait (Cfuture f) |
| void | CfutureDestroy (Cfuture f) |
| void * | CfutureCreateBuffer (int bytes) |
| void | CfutureDestroyBuffer (void *val) |
| void | CfutureStoreBuffer (Cfuture f, void *value) |
| void | CfutureInit () |
| int | CldRegisterInfoFn (CldInfoFn fn) |
| int | CldRegisterPackFn (CldPackFn fn) |
| void | CldRegisterEstimator (CldEstimator fn) |
| int | CldEstimate (void) |
| char * | CldGetStrategy (void) |
| void | CldEnqueue (int pe, void *msg, int infofn) |
| void | CldEnqueueMulti (int npes, int *pes, void *msg, int infofn) |
| void | CldEnqueueGroup (CmiGroup grp, void *msg, int infofn) |
| void | CldNodeEnqueue (int node, void *msg, int infofn) |
| CmmTable | CmmPup (pup_er p, CmmTable t, CmmPupMessageFn msgpup) |
| CmmTable | CmmNew () |
| void | CmmFree (CmmTable t) |
| void | CmmFreeAll (CmmTable t) |
| void | CmmPut (CmmTable t, int ntags, int *tags, void *msg) |
| void * | CmmFind (CmmTable t, int ntags, int *tags, int *returntags, int del) |
| int | CmmEntries (CmmTable t) |
| int | CmmGetLastTag (CmmTable t, int ntags, int *tags) |
| void | ConverseInit (int, char **, CmiStartFn, int, int) |
| void | ConverseExit (void) |
| void | CmiAbort (const char *) |
| Serial version of common Charm++ routines:. | |
| void | CmiOutOfMemory (int nBytes) |
| void | CcdCallFnAfter (CcdVoidFn fnp, void *arg, double msecs) |
| Register a callback function that will be triggered after a minimum delay of deltaT. | |
| int | CcdCallOnCondition (int condnum, CcdVoidFn fnp, void *arg) |
| Register a callback function that will be triggered when the specified condition is raised the next time. | |
| int | CcdCallOnConditionKeep (int condnum, CcdVoidFn fnp, void *arg) |
| Register a callback function that will be triggered *whenever* the specified condition is raised. | |
| void | CcdCallFnAfterOnPE (CcdVoidFn fnp, void *arg, double msecs, int pe) |
| Register a callback function that will be triggered on the specified PE after a minimum delay of deltaT. | |
| int | CcdCallOnConditionOnPE (int condnum, CcdVoidFn fnp, void *arg, int pe) |
| Register a callback function that will be triggered on the specified PE when the specified condition is raised the next time. | |
| int | CcdCallOnConditionKeepOnPE (int condnum, CcdVoidFn fnp, void *arg, int pe) |
| Register a callback function that will be triggered on the specified PE *whenever* the specified condition is raised. | |
| void | CcdCancelCallOnCondition (int condnum, int idx) |
| Cancel a previously registered conditional callback. | |
| void | CcdCancelCallOnConditionKeep (int condnum, int idx) |
| Cancel a previously registered conditional callback. | |
| void | CcdRaiseCondition (int condnum) |
| Raise a condition causing all registered callbacks corresponding to that condition to be triggered. | |
| void | CmiArgGroup (const char *parentName, const char *groupName) |
| Identifies the module that accepts the following command-line parameters. | |
| int | CmiGetArgInt (char **argv, const char *arg, int *optDest) |
| int | CmiGetArgIntDesc (char **argv, const char *arg, int *optDest, const char *desc) |
| Find the given argument and integer option in argv. | |
| int | CmiGetArgLong (char **argv, const char *arg, CmiInt8 *optDest) |
| int | CmiGetArgLongDesc (char **argv, const char *arg, CmiInt8 *optDest, const char *desc) |
| int | CmiGetArgDouble (char **argv, const char *arg, double *optDest) |
| int | CmiGetArgDoubleDesc (char **argv, const char *arg, double *optDest, const char *desc) |
| Find the given argument and floating-point option in argv. | |
| int | CmiGetArgString (char **argv, const char *arg, char **optDest) |
| int | CmiGetArgStringDesc (char **argv, const char *arg, char **optDest, const char *desc) |
| Find the given argment and string option in argv. | |
| int | CmiGetArgFlag (char **argv, const char *arg) |
| int | CmiGetArgFlagDesc (char **argv, const char *arg, const char *desc) |
| Find the given argument in argv. | |
| void | CmiDeleteArgs (char **argv, int k) |
| Delete the first k argument from the given list, shifting all other arguments down by k spaces. | |
| int | CmiGetArgc (char **argv) |
| Count the number of non-NULL arguments in list. | |
| char ** | CmiCopyArgs (char **argv) |
| Return a new, heap-allocated copy of the argv array. | |
| int | CmiArgGivingUsage (void) |
| Return 1 if we're currently printing command-line usage information. | |
| void | CmiBacktraceRecord (void **retPtrs, int nSkip, int *nLevels) |
| Extract the function-return pointers listed in the stack up to this depth. | |
| char ** | CmiBacktraceLookup (void **srcPtrs, int nLevels) |
| Look up the names of these function pointers. | |
| void | CmiBacktracePrint (void **retPtrs, int nLevels) |
| Print out the names of these function pointers. | |
| void | CmiPrintStackTrace (int nSkip) |
| int | CmiIsFortranLibraryCall () |
| CpvExtern (void *, CmiLocalQueue) | |
| char * | CmiCopyMsg (char *msg, int len) |
| int | HypercubeGetBcastDestinations (int mype, int total_pes, int k, int *dest_pes) |
| CpvExtern (int, CmiImmediateMsgHandlerIdx) | |
| CpvExtern (unsigned, networkProgressCount) | |
| void | CmiMachineProgressImpl () |
| void | CmiDelayImmediate () |
| void | CmiInitCounters () |
| void | CmiStartCounters (int events[], int numEvents) |
| void | CmiStopCounters (int events[], CMK_TYPEDEF_INT8 values[], int numEvents) |
| CmiObjId * | CthGetThreadID (CthThread th) |
| void | CthSetThreadID (CthThread th, int a, int b, int c) |
| void | CthTraceResume (CthThread t) |
| CpvExtern (char *, _validProcessors) | |
| int | CmiEndianness () |
| void | setMemoryTypeChare (void *) |
| void | setMemoryTypeMessage (void *) |
| int | CmiGetCluster (int pe) |
| int | CmiGridQueueGetInterval () |
| int | CmiGridQueueGetThreshold () |
| void | CmiGridQueueRegister (int gid, int nInts, int index1, int index2, int index3) |
| void | CmiGridQueueDeregister (int gid, int nInts, int index1, int index2, int index3) |
| void | CmiGridQueueDeregisterAll () |
| int | CmiGridQueueLookup (int gid, int nInts, int index1, int index2, int index3) |
| int | CmiGridQueueLookupMsg (char *msg) |
| size_t | CmiFwrite (const void *ptr, size_t size, size_t nmemb, FILE *f) |
| FILE * | CmiFopen (const char *path, const char *mode) |
| int | CmiFclose (FILE *fp) |
| unsigned int | CmiILog2 (unsigned int) |
| double | CmiLog2 (double) |
| EXTERN CmiNotifyCommThdMsg * | CmiCreateNotifyCommThdMsg (CmiCommThdFnPtr fn, int numParams, void *params, int toKeep) |
| EXTERN void | CmiFreeNotifyCommThdMsg (CmiNotifyCommThdMsg *msg) |
| EXTERN void | CmiResetNotifyCommThdMsg (CmiNotifyCommThdMsg *msg, CmiCommThdFnPtr fn, int numParams, void *params, int toKeep) |
| EXTERN void | CmiNotifyCommThd (CmiNotifyCommThdMsg *msg) |
| int | CmiReadSize (char *str) |
Variables | |
| int | memory_status_info |
| int | memory_chare_id |
| int | _Cmi_mype |
| int | _Cmi_numpes |
| int | _Cmi_myrank |
| int | _Cmi_mynodesize |
| int | _Cmi_mynode |
| int | _Cmi_numnodes |
| int | _Cmi_noprocforcommthread |
| CmiNodeLock | CmiMemLock_lock |
| int | _immediateLock |
| int | _immediateFlag |
| CmiNodeLock | _smp_mutex |
| void * | memory_stack_top |
| double | _cpu_speed_factor |
| CmiSwitchToPEFnPtr | CmiSwitchToPE |
| int | networkProgressPeriod |
| int | _immRunning |
| CmiNodeLock | cmiMemoryLock |
| int | _BgOutOfCoreFlag |
| int | _BgInOutOfCoreMode |
| int | numMemCriticalEntries |
| int * | memCriticalEntries |
Everything in Converse is either declared here directly, or else included from here.
Routine names in Converse include a short prefix starting with "C". These generally tell you what category the routine is in:
Globally accessible variables in Converse can be shared as:
Definition in file converse.h.
| typedef HANDLE CmiNodeLock |
Definition at line 164 of file converse.h.
| typedef CmiNodeLock CmiImmediateLockType |
Definition at line 387 of file converse.h.
| typedef CMK_TYPEDEF_INT2 CmiInt2 |
Definition at line 531 of file converse.h.
| typedef CMK_TYPEDEF_INT4 CmiInt4 |
Definition at line 532 of file converse.h.
| typedef CMK_TYPEDEF_INT8 CmiInt8 |
Definition at line 533 of file converse.h.
| typedef CMK_TYPEDEF_UINT2 CmiUInt2 |
Definition at line 534 of file converse.h.
| typedef CMK_TYPEDEF_UINT4 CmiUInt4 |
Definition at line 535 of file converse.h.
| typedef CMK_TYPEDEF_UINT8 CmiUInt8 |
Definition at line 536 of file converse.h.
| typedef CMK_TYPEDEF_FLOAT4 CmiFloat4 |
Definition at line 537 of file converse.h.
| typedef CMK_TYPEDEF_FLOAT8 CmiFloat8 |
Definition at line 538 of file converse.h.
Definition at line 541 of file converse.h.
| typedef void* CmiCommHandle |
Definition at line 547 of file converse.h.
| typedef void(* CmiHandler)(void *msg) |
Definition at line 548 of file converse.h.
| typedef void(* CmiHandlerEx)(void *msg, void *userPtr) |
Definition at line 549 of file converse.h.
| typedef struct CMK_MSG_HEADER_BASIC CmiMsgHeaderBasic |
Definition at line 551 of file converse.h.
| typedef struct CMK_MSG_HEADER_EXT CmiMsgHeaderExt |
Definition at line 552 of file converse.h.
| typedef struct CMK_MSG_HEADER_BIGSIM_ CmiBlueGeneMsgHeader |
Definition at line 561 of file converse.h.
| typedef struct infiCmiChunkHeaderStruct infiCmiChunkHeader |
| typedef void(* CmiStartFn)(int argc, char **argv) |
Definition at line 880 of file converse.h.
| typedef CMK_MULTICAST_GROUP_TYPE CmiGroup |
Definition at line 974 of file converse.h.
| typedef void*(* CmiReduceMergeFn)(int *, void *, void **, int) |
Definition at line 1046 of file converse.h.
| typedef void(* CmiReducePupFn)(void *, void *) |
Definition at line 1047 of file converse.h.
| typedef void(* CmiReduceDeleteFn)(void *) |
Definition at line 1048 of file converse.h.
| typedef CmiUInt2 CmiReductionID |
Definition at line 1067 of file converse.h.
| typedef struct CthThreadStruct* CthThread |
Definition at line 1218 of file converse.h.
| typedef void(* CthVoidFn)() |
Definition at line 1230 of file converse.h.
| typedef void(* CthAwkFn)(CthThreadToken *, int, int prioBits, unsigned int *prioptr) |
Definition at line 1231 of file converse.h.
Definition at line 1233 of file converse.h.
| typedef struct CtgGlobalStruct* CtgGlobals |
Definition at line 1277 of file converse.h.
| typedef void(* CthThreadListener_suspend)(struct CthThreadListener *l) |
Definition at line 1304 of file converse.h.
| typedef void(* CthThreadListener_resume)(struct CthThreadListener *l) |
Definition at line 1305 of file converse.h.
| typedef void(* CthThreadListener_free)(struct CthThreadListener *l) |
Definition at line 1306 of file converse.h.
| typedef struct CmiIsomallocBlockList CmiIsomallocBlockList |
Definition at line 1368 of file converse.h.
Definition at line 1447 of file converse.h.
| typedef void(* CldInfoFn)(void *msg, CldPackFn *packer, int *len, int *queueing, int *priobits, unsigned int **prioptr) |
Definition at line 1449 of file converse.h.
| typedef int(* CldEstimator)(void) |
Definition at line 1456 of file converse.h.
| typedef struct CmmTableStruct* CmmTable |
Definition at line 1471 of file converse.h.
| typedef void(* CmmPupMessageFn)(pup_er p, void **msg) |
Definition at line 1475 of file converse.h.
| typedef void(* CcdVoidFn)(void *userParam, double curWallTime) |
Definition at line 1506 of file converse.h.
| typedef int(* CmiSwitchToPEFnPtr)(int pe) |
Definition at line 1544 of file converse.h.
| typedef void(* CmiCommThdFnPtr)(int numParams, void *params) |
Definition at line 1911 of file converse.h.
| enum bool |
| void CmiMemLock | ( | ) |
Definition at line 307 of file machine-common-core.c.
Referenced by CmiMemoryMark(), CmiMemoryMarkBlock(), CmiMemorySweep(), free_nomigrate(), infi_CmiAlloc(), infi_CmiFree(), KillOnAllSigs(), and malloc_nomigrate().
| void CmiMemUnlock | ( | ) |
Definition at line 308 of file machine-common-core.c.
Referenced by CmiMemoryMark(), CmiMemoryMarkBlock(), CmiMemorySweep(), free_nomigrate(), infi_CmiAlloc(), infi_CmiFree(), KillOnAllSigs(), and malloc_nomigrate().
| int CmiMyPe | ( | ) |
Definition at line 324 of file machine-common-core.c.
References CmiGetState(), and CmiStateStruct::pe.
Referenced by __cmi_assert(), _bcastQD1(), _bcastQD2(), _bufferedLocalMessageAckHandler(), _bufferedLocalMessageCopyHandler(), _callWhenIdle(), _checkpointBarrierAckHandler(), _checkpointBarrierHandler(), _createTracecounter(), _dummyMigrationHandler(), _getCheckpointHandler(), _getGlobalStepHandler(), _getRestartCheckpointHandler(), _handlePhase0(), _handlePhase1(), _handlePhase2(), _initCharm(), _initHandler(), _localMessageAckHandler(), _messageLoggingExit(), _messageLoggingInit(), _parseCommandLineOpts(), _qdCommHandler(), _qdHandler(), _receivedTNDataHandler(), _receiveLocationHandler(), _receiveMigrationNoticeAckHandler(), _recvCheckpointHandler(), _recvRestartCheckpointHandler(), _resendMessagesHandler(), _resendReplyHandler(), _storeCheckpointHandler(), _updateHomeRequestHandler(), _verifyAckHandler(), _verifyAckRequestHandler(), AllocatorCheck(), ampiInit(), askProcDataHandler(), bad_location(), CkLocRec_buffering::beenReplaced(), TraceCounter::beginExecute(), TraceCounter::beginOverview(), TraceCounter::beginPack(), TraceCounter::beginUnpack(), CkArray::broadcastHomeElements(), buddyDieHandler(), CcsImpl_reply(), CcsInit(), CfutureCreate(), CfutureDestroy(), CfutureStoreBuffer(), CfutureWait(), check_range(), CkCppInterpreter::CkCppInterpreter(), CkDieNow(), CkMemRestart(), Converse::CkMyPe(), CldAckNoTaskHandler(), CldAverageHandler(), CldBalancePeriod(), CldComputeNeighborData(), CldEnqueue(), CldGraphModuleInit(), CldMinAvg(), CldModuleGeneralInit(), CldModuleInit(), CldMoveAllSeedsAway(), CldNodeEnqueue(), CldOtherInit(), CldReadNeighborData(), CldReadytoExec(), CldSendLoad(), CldSetPEBitVector(), CldStillIdle(), clearUpMigratedRetainedLists(), CmiAddCLA(), CmiAlloc(), CmiArgGivingUsage(), CmiArgInit(), CmiBacktracePrint(), CmiCheckGmStatus(), CmiCreatePersistent(), CmiCreateReceiverPersistent(), CmiDirect_assocLocalBuffer(), CmiDirect_put(), CmiEstablishGroup(), CmiFreeSendFn(), CmiGetDynamicReduction(), CmiGetDynamicReductionRemote(), CmiGetNonLocal(), CmiGetNonLocalNodeQ(), CmiGetReductionCreate(), CmiGlobalReduce(), CmiGlobalReduceStruct(), CmiInitCell(), CmiInitCPUAffinity(), CmiInitMemAffinity(), CmiIsomalloc(), CmiIsomallocBlockListPup(), CmiIsomallocInit(), CmiListReduce(), CmiListReduceStruct(), CmiMemorySweep(), CmiMulticastDeliver(), CmiMultiMsgHandler(), CmiMXMakeConnection(), CmiNotifyStillIdle(), CmiPrintCLAs(), CmiProcessPriority(), CmiReduce(), CmiReduceID(), CmiReduceStruct(), CmiReduceStructID(), CmiRegisterHandlerGlobal(), CmiReleaseSentMessages(), CmiSyncBroadcastAllFn(), CmiSyncBroadcastFn1(), CmiSyncListSendFn(), ComlibDoneCreating(), comlibReadyHandler(), comlibTableReceivedHandler(), CkReductionMgr::contribute(), CkReductionMgr::contributeViaMessage(), converse_handlerBegin(), converse_handlerEnd(), ConverseCommonInit(), ConverseDeliver(), ConverseExit(), copyOut(), CountLogPool::CountLogPool(), CPathGetEltset(), CPathMakeArray(), CPathSendHandler(), cpd_memory_single_pup(), CpdDebugCallAllocationTree(), CpdDebugCallMemStat(), CpdDebugHandlerStatus(), CpdFreezeModeScheduler(), CpdNotify(), CpdSearchLeaks(), CpdStartGdb(), Cpthread_cond_broadcast(), Cpthread_cond_destroy(), Cpthread_cond_init(), Cpthread_cond_signal(), Cpthread_cond_wait(), Cpthread_mutex_destroy(), Cpthread_mutex_init(), Cpthread_mutex_lock(), Cpthread_mutex_trylock(), Cpthread_mutex_unlock(), cpuAffinityHandler(), cpuAffinityRecvHandler(), CQdBcastQD1(), CQdBcastQD2(), CQdHandlePhase0(), CQdHandlePhase1(), CQdHandlePhase2(), CQdStateCreate(), CthThreadBaseInit(), CWeb_Collect(), CWeb_Reduce(), CWebHandler(), disable_isomalloc(), disabled_map(), StatTable::doReduction(), drop_send_callback(), PrefixRouter::EachToManyMulticastQ(), ConvComlibManager::enableStrategy(), TraceCounter::endExecute(), TraceCounter::endOverview(), TraceCounter::endPack(), TraceCounter::endUnpack(), EnqueueMsg(), EnqueueOutgoingDgram(), expand_ccd_heap(), PeTable::ExtractAndPack(), PeTable::ExtractAndVectorize(), find_largest_free_region(), finishedCheckpointLoadBalancing(), CkReductionMgr::finishReduction(), gengraph(), getCheckPointPE(), getGlobalStep(), getNewPagetable(), getNUMANidByRank(), HigherPriorityWork(), informLocationHome(), StatTable::init(), init_ranges(), initQd(), initTraceTauBOC(), CkMemCheckPT::inmem_restore(), ampi::inorder(), ConvComlibManager::insertMessage(), isomallocfn(), KillEveryoneCode(), KillOnAllSigs(), ComlibArrayInfo::localBroadcast(), LrtsInitCpuTopo(), machine_procBusy(), machine_procIdle(), map_slots(), memAbort(), memory_check(), mempool_free(), meta_calloc(), meta_cfree(), meta_free(), meta_init(), meta_malloc(), meta_memalign(), meta_realloc(), meta_valloc(), on_timeout(), one_slotOP(), CountLogPool::openFile(), TraceLogger::openLogFiles(), GridMetisLB::Partition_ClusterObjects_Into_PEs(), pingBuddy(), pingCheckHandler(), prepare_slotmsg(), print_cpu_affinity(), print_mem_affinity(), print_myslots(), print_node0(), print_thread_affinity(), printBGP_UPC_Counters(), printSlot(), processFutureMessages(), processMessage(), ProcessMessage(), processReceivedTN(), CentralLB::ProcessReceiveMigration(), PumpMsgsBlocking(), CkLocMgr::pup(), ChareMlogData::pup(), pupArrayElementsSkip(), QdState::QdState(), readBlacklist(), CentralLB::ReceiveStats(), ampi::recv(), recv_dummy(), CkReductionMgr::ReductionStarting(), TraceCounter::registerArg(), TraceLogger::RegisterLanguage(), req_fw_handler(), ChareMlogData::searchRestoredLocalQ(), seedBalancerExit(), sendCheckpointData(), sendDummyMigrationCounts(), sendMlogLocation(), SendMsgBuf(), sendRemoveLogRequests(), CentralLB::SendStats(), SendTasktoPe(), sendTicketGroupRequest(), sendTicketRequest(), StrategyTableEntry::setDiscoveryMode(), StrategyTableEntry::setErrorMode(), StrategyTableEntry::setErrorModeServer(), slotAbort(), startLoadBalancingMlog(), startMlogCheckpoint(), CkReductionMgr::startReduction(), StatTable::StatTable(), StatTableReduction(), status(), StealLoad(), StreamingHandlerFn(), TraceCounter::switchCounters(), ConvComlibManager::tableReady(), TCharmAPIRoutine::TCharmAPIRoutine(), ticketLogLocalMessage(), TraceCounter::traceBegin(), TraceCounter::traceClose(), TraceCounter::traceEnd(), TraceCounter::traceInit(), TraceCounter::traceWriteSts(), try_largest_mmap_region(), unmap_slots(), CkObjID::updatePosition(), CountLogPool::write(), StatTable::write(), CountLogPool::writeSts(), and TCharmAPIRoutine::~TCharmAPIRoutine().
| int CmiMyRank | ( | ) |
Definition at line 327 of file machine-common-core.c.
References CmiGetState(), and CmiStateStruct::rank.
Referenced by _initCharm(), _speedHdlr(), AdvanceCommunication(), CkMemRestart(), CldAskLoadHandler(), CldBalance(), CldGraphModuleInit(), CmiBarrier(), CmiBarrierZero(), CmiDisableIsomalloc(), CmiInitCPUAffinity(), CmiInitNotifyCommThdScheme(), CmiMyRank_(), CmiOutOfMemoryInit(), CmiProcessPriority(), CmiSyncBroadcastFn1(), ConverseCommonInit(), ConverseRunPE(), Cpthread_once(), Cpthread_start_main(), CsdInit(), CWebPerformanceRegisterFunction(), EnqueueMsg(), getInfiCmiChunkThread(), infi_CmiFree(), infi_CmiFreeDirect(), init_ranges(), initConvComlibManager(), initQd(), KillOnAllSigs(), LrtsInitCpuTopo(), QdState::sendCount(), SendMsgBuf(), and traceCommonInit().
Definition at line 330 of file machine-common-core.c.
Referenced by _sendTriggers(), _speedHdlr(), CmiInitCPUAffinity(), CmiNodeReduce(), KillOnAllSigs(), LrtsNodeFirst(), MPISendOneMsg(), notify_crash(), PumpMsgs(), PumpMsgsBlocking(), QdState::sendCount(), and SendMsgBuf().
Definition at line 333 of file machine-common-core.c.
Referenced by _speedHdlr(), ccs_getinfo(), KillOnAllSigs(), and LrtsNodeSize().
Definition at line 336 of file machine-common-core.c.
Referenced by _skipCldEnqueue(), topo::impl::buildNextGen_topoUnaware(), CkGetSrcNode(), CldEnqueue(), CldHopHandler(), CldNodeEnqueue(), CldStillIdle(), CmiAsyncSendFn(), CmiFreeSendFn(), CmiInitCPUAffinity(), KillOnAllSigs(), LrtsInitCpuTopo(), LrtsNodeOf(), LrtsPeOnSameNode(), LV3D0_ClientManager_toMaster::progress(), CkNodeReductionMgr::ReductionStarting(), SendHyperCubeProc(), and CpuTopology::sort().
Definition at line 339 of file machine-common-core.c.
Referenced by CldAskLoadHandler(), CldStillIdle(), CmiFreeSendFn(), KillOnAllSigs(), LrtsRankOf(), and traceCommonInit().
| void CmiNodeBarrier | ( | void | ) |
Referenced by _initDone(), CkRestartMain(), KillOnAllSigs(), SendMsgBuf(), and topo_callback().
| void CmiNodeAllBarrier | ( | void | ) |
Referenced by _initCharm(), CmiBarrier(), CmiBarrierZero(), CmiInitCPUAffinity(), CmiInitMemAffinity(), CmiInitNotifyCommThdScheme(), ConverseRunPE(), CsdInit(), InitCallTable::enumerateInitCalls(), init_ranges(), KillOnAllSigs(), LrtsInitCpuTopo(), meta_init(), SendMsgBuf(), and TraceProjections::TraceProjections().
| void* CmiSvAlloc | ( | int | ) |
| void CmiLock | ( | CmiNodeLock | lock | ) |
Referenced by CkNodeReductionMgr::addContribution(), AsynchronousEventHandler(), CldGetToken(), CldGetTokenFromRank(), CldGetTokenFromRankAt(), CldPutToken(), CldPutTokenPrio(), CmiCommLock(), CmiGetNonLocalNodeQ(), CmiInitCPUAffinity(), CmiInitCPUAffinityUtil(), CmiPushImmediateMsg(), CmiPushNode(), CmiSendNodeSelf(), CkArrayReductionMgr::contributeArrayReduction(), ConverseExit(), cpuTopoRecvHandler(), CsdInit(), CsdNextLocalNodeMessage(), CsdNextMessage(), KillOnAllSigs(), mempool_free_thread(), mempool_malloc(), PCQueuePop(), PCQueueTop(), LBDatabase::pup(), readMHz(), CkNodeReductionMgr::RecvMsg(), CkNodeReductionMgr::ReductionStarting(), CkNodeReductionMgr::restartLocalGroupReductions(), and SendMsgBuf().
| void CmiUnlock | ( | CmiNodeLock | lock | ) |
Referenced by CkNodeReductionMgr::addContribution(), AsynchronousEventHandler(), CldAskLoadHandler(), CldGetToken(), CldGetTokenFromRank(), CldGetTokenFromRankAt(), CldPutToken(), CldPutTokenPrio(), CmiCommUnlock(), CmiGetNonLocalNodeQ(), CmiHandleImmediate(), CmiInitCPUAffinity(), CmiInitCPUAffinityUtil(), CmiPushImmediateMsg(), CmiPushNode(), CmiSendNodeSelf(), CkArrayReductionMgr::contributeArrayReduction(), ConverseExit(), cpuTopoRecvHandler(), CsdNextLocalNodeMessage(), CsdNextMessage(), KillOnAllSigs(), mempool_free_thread(), mempool_malloc(), PCQueuePop(), PCQueueTop(), LBDatabase::pup(), readMHz(), CkNodeReductionMgr::RecvMsg(), CkNodeReductionMgr::ReductionStarting(), CkNodeReductionMgr::restartLocalGroupReductions(), and SendMsgBuf().
| int CmiTryLock | ( | CmiNodeLock | lock | ) |
Referenced by CldAskLoadHandler(), and CmiHandleImmediate().
| int CmiNumCores | ( | void | ) |
Definition at line 59 of file cputopology.C.
Referenced by CmiInitCPUAffinity(), CmiSetCPUAffinity(), cpuTopoHandler(), and LrtsInitCpuTopo().
| int CmiCpuTopologyEnabled | ( | ) |
| int CmiNumPhysicalNodes | ( | ) |
Definition at line 592 of file cputopology.C.
References LrtsNumNodes().
Referenced by CkMemCheckPT::BuddyPE(), CkMemCheckPT::CkMemCheckPT(), CkMemCheckPT::finishUp(), KLevelTree::KLevelTree(), LBTOPO_MACRO(), and ThreeLevelTree::ThreeLevelTree().
Definition at line 608 of file cputopology.C.
References LrtsNodeOf().
Referenced by CkMemCheckPT::BuddyPE(), topo::impl::buildNextGen_nodeAware_minBytes(), topo::impl::buildNextGen_nodeAware_minGens(), getFirstPeOnPhysicalNodeFromList(), getNthPeOnPhysicalNodeFromList(), getOtherPesOnPhysicalNodeFromList(), getPesOnPhysicalNodeFromList(), topo::getSpanningTreeStrategy(), and LBTOPO_MACRO().
Definition at line 596 of file cputopology.C.
References LrtsNodeSize().
Referenced by topo::getSpanningTreeStrategy(), and LBTOPO_MACRO().
Definition at line 600 of file cputopology.C.
References LrtsPeOnNode().
Referenced by CkMemCheckPT::BuddyPE(), topo::impl::buildNextGen_nodeAware_minBytes(), topo::impl::buildNextGen_nodeAware_minGens(), getFirstPeOnPhysicalNodeFromList(), getNthPeOnPhysicalNodeFromList(), getOtherPesOnPhysicalNodeFromList(), getPesOnPhysicalNodeFromList(), and LBTOPO_MACRO().
Definition at line 612 of file cputopology.C.
References LrtsNodeFirst().
Referenced by KLevelTree::KLevelTree(), LBTOPO_MACRO(), and ThreeLevelTree::ThreeLevelTree().
Definition at line 604 of file cputopology.C.
References LrtsRankOf().
Referenced by CkMemCheckPT::BuddyPE(), and LBTOPO_MACRO().
| int CmiPrintCPUAffinity | ( | ) |
Definition at line 745 of file cpuaffinity.c.
References CmiPrintf(), print_cpu_affinity(), and print_thread_affinity().
Referenced by CmiInitCPUAffinity().
Definition at line 173 of file cpuaffinity.c.
References CmiAbort(), CmiError(), CmiNumCores(), set_cpu_affinity(), and set_thread_affinity().
Referenced by CmiInitCPUAffinity(), and cpuAffinityRecvHandler().
| int CmiOnCore | ( | ) |
| CpvExtern | ( | CmiHandlerInfo * | , | |
| CmiHandlerTable | ||||
| ) |
| CpvExtern | ( | int | , | |
| CmiHandlerMax | ||||
| ) |
| CpvExtern | ( | void * | , | |
| CsdSchedQueue | ||||
| ) |
| CpvExtern | ( | void * | , | |
| CsdGridQueue | ||||
| ) |
| CpvExtern | ( | void * | , | |
| CsdObjQueue | ||||
| ) |
| CsvExtern | ( | void * | , | |
| CsdNodeQueue | ||||
| ) |
| CsvExtern | ( | CmiNodeLock | , | |
| CsdNodeQueueLock | ||||
| ) |
| CpvExtern | ( | int | , | |
| CsdStopFlag | ||||
| ) |
| CpvExtern | ( | int | , | |
| CsdLocalCount | ||||
| ) |
| CpvExtern | ( | int | , | |
| _curRestartPhase | ||||
| ) |
| static __inline__ unsigned long long int rdtsc | ( | void | ) | [static] |
Definition at line 751 of file converse.h.
| int CmiScanf | ( | const char * | , | |
| ... | ||||
| ) |
| CpvExtern | ( | int | , | |
| _ccd_numchecks | ||||
| ) |
| void CcdCallBacks | ( | ) |
Definition at line 539 of file conv-conds.c.
References ccd_heap_update(), CcdRaiseCondition(), CmiWallTimer(), ccd_periodic_callbacks::lastCheck, ccd_periodic_callbacks::nextCall, ccd_periodic_callbacks::nSkip, and periodicCallInterval.
Referenced by CsdBeginIdle().
| void * CmiGetNonLocal | ( | void | ) |
In SMP mode with comm thread, it's possible a normal msg is sent from an immediate msg which is executed on comm thread. In this case, the msg is sent to the network queue of the work thread. Therefore, even there's only one worker thread, the polling of network queue is still required.
Definition at line 902 of file machine-common-core.c.
References AdvanceCommunication(), CmiGetState(), CmiMyPe(), CmiStateStruct::idle, msg, PCQueuePop(), and CmiStateStruct::recv.
Referenced by CmiDeliverSpecificMsg(), CsdNextMessage(), and KillOnAllSigs().
Referenced by CldModuleInit(), CmiGlobalReduce(), CmiGlobalReduceStruct(), CQdStateCreate(), and QdState::QdState().
Referenced by CQdStateCreate(), and QdState::QdState().
Referenced by CmiNodeReduce().
Referenced by CmiNodeReduce().
| void CmiPushPE | ( | int | rank, | |
| void * | msg | |||
| ) |
Definition at line 358 of file machine-common-core.c.
References _Cmi_noprocforcommthread, CmiGetState(), CmiPushImmediateMsg(), CmiStateStruct::idle, and CmiStateStruct::recv.
Referenced by AssembleDatagram(), CmiFreeSendFn(), CmiSendMessagePxshm(), CmiSendMessageXpmem(), handleOneRecvedMsg(), handoverMessage(), handoverSysvshmMessage(), KillOnAllSigs(), processMessage(), ProcessMessage(), processProcBcastMsg(), and SendToPeers().
Definition at line 458 of file machine-common-core.c.
References CmiFreeSendFn(), and CopyMsg().
Referenced by CmiAsyncSendFn(), CmiSyncBroadcastAllFn(), CmiSyncBroadcastFn1(), Converse::CmiSyncSend(), BroadcastStrategy::handleHypercube(), KillOnAllSigs(), and QdState::propagate().
| CmiCommHandle CmiAsyncSendFn | ( | int | destPE, | |
| int | size, | |||
| char * | msg | |||
| ) |
Definition at line 546 of file machine-common-core.c.
References _cmi_log2(), CmiNodeOf(), CmiSyncSendFn(), and LrtsSendFunc().
Referenced by KillOnAllSigs().
Definition at line 512 of file machine-common-core.c.
References CmiMyPe(), CmiNodeOf(), CmiPushPE(), CmiRankOf(), CmiSendSelf(), CQdCreate(), curphs, LrtsSendNetworkFunc(), LrtsSendPersistentMsg(), phs, and phsSize.
Referenced by CkStartQD(), Converse::CmiSyncSendAndFree(), CmiSyncSendFn(), KillOnAllSigs(), and QdState::sendCount().
| void CmiSyncBroadcastFn | ( | int | , | |
| char * | ||||
| ) |
Definition at line 234 of file machine-broadcast.c.
Referenced by CmiFreeBroadcastAllFn(), Converse::CmiSyncBroadcast(), CmiSyncBroadcastAllFn(), and KillOnAllSigs().
| CmiCommHandle CmiAsyncBroadcastFn | ( | int | , | |
| char * | ||||
| ) |
Definition at line 257 of file machine-broadcast.c.
Referenced by CmiAsyncBroadcastAllFn(), and KillOnAllSigs().
| void CmiFreeBroadcastFn | ( | int | , | |
| char * | ||||
| ) |
Definition at line 247 of file machine-broadcast.c.
Referenced by CmiFreeBroadcastAllFn(), Converse::CmiSyncBroadcastAndFree(), and KillOnAllSigs().
| void CmiSyncBroadcastAllFn | ( | int | , | |
| char * | ||||
| ) |
Definition at line 265 of file machine-broadcast.c.
Referenced by Converse::CmiSyncBroadcastAll(), and KillOnAllSigs().
| CmiCommHandle CmiAsyncBroadcastAllFn | ( | int | , | |
| char * | ||||
| ) |
| void CmiFreeBroadcastAllFn | ( | int | , | |
| char * | ||||
| ) |
Definition at line 279 of file machine-broadcast.c.
Referenced by Converse::CmiSyncBroadcastAllAndFree(), and KillOnAllSigs().
| int CmiGetReductionHandler | ( | ) |
| CmiHandler CmiGetReductionDestination | ( | ) |
| CmiCommHandle CmiAsyncVectorSend | ( | int | , | |
| int | , | |||
| int * | , | |||
| char ** | ||||
| ) |
| int CmiAsyncMsgSent | ( | CmiCommHandle | ) |
| void CmiReleaseCommHandle | ( | CmiCommHandle | ) |
Definition at line 578 of file machine-common-core.c.
References CmiFreeNodeSendFn(), and CopyMsg().
Referenced by CmiAsyncNodeSendFn(), CmiSyncNodeBroadcastAllFn(), CmiSyncNodeBroadcastFn(), and KillOnAllSigs().
| CmiCommHandle CmiAsyncNodeSendFn | ( | int | destNode, | |
| int | size, | |||
| char * | msg | |||
| ) |
Definition at line 602 of file machine-common-core.c.
References _cmi_log2(), CmiSyncNodeSendFn(), and LrtsSendFunc().
Referenced by KillOnAllSigs().
Definition at line 583 of file machine-common-core.c.
References _cmi_log2(), CmiSendNodeSelf(), CQdCreate(), and LrtsSendFunc().
Referenced by CmiSyncNodeSendFn(), and KillOnAllSigs().
| void CmiSyncNodeBroadcastFn | ( | int | , | |
| char * | ||||
| ) |
Definition at line 300 of file machine-broadcast.c.
Referenced by CmiAsyncNodeBroadcastFn(), CmiFreeNodeBroadcastAllFn(), CmiFreeNodeBroadcastFn(), CmiSyncNodeBroadcastAllFn(), and KillOnAllSigs().
| CmiCommHandle CmiAsyncNodeBroadcastFn | ( | int | , | |
| char * | ||||
| ) |
Definition at line 325 of file machine-broadcast.c.
References CmiSyncNodeBroadcastFn().
Referenced by CmiAsyncNodeBroadcastAllFn(), and KillOnAllSigs().
| void CmiFreeNodeBroadcastFn | ( | int | , | |
| char * | ||||
| ) |
| void CmiSyncNodeBroadcastAllFn | ( | int | , | |
| char * | ||||
| ) |
| CmiCommHandle CmiAsyncNodeBroadcastAllFn | ( | int | , | |
| char * | ||||
| ) |
| void CmiFreeNodeBroadcastAllFn | ( | int | , | |
| char * | ||||
| ) |
| CthThreadToken* CthGetToken | ( | CthThread | ) |
| int CthMigratable | ( | ) |
Definition at line 1295 of file threads.c.
References CmiAbort(), CthFree(), CthPupBase(), malloc(), pup_bytes(), pup_isDeleting(), and pup_isUnpacking().
Referenced by TCharm::pupThread().
| CthThread CthSelf | ( | void | ) |
Definition at line 521 of file threads.c.
Referenced by CfutureWait(), Tempo::ckTempoRecv(), CkWaitFutureID(), CmiIsomalloc(), CmiIsomallocBlockListPup(), CpmThread3(), Cpthread_cond_wait(), Cpthread_join(), Cpthread_mutex_lock(), Cpthread_mutex_trylock(), Cpthread_mutex_unlock(), CthFree(), CthOnly(), CthResumeSchedulingThread(), CthSchedInit(), CthStartThread(), PythonObject::executeThread(), FiberSetUp(), MSA_CacheGroup< ENTRY_TYPE, ENTRY_OPS_CLASS, ENTRIES_PER_PAGE >::getListener(), TCharm::getSema(), SearchGroup::getTotalSolutions(), CkCallback::impl_thread_delay(), ParFUMShadowArray::lockRegion(), mempool_free(), PUPmarshall(), TCharm::stop(), MSA_Thread_Listener::suspend(), TCharm::TCharm(), Tempo::Tempo(), CkSema::wait(), CkSema::waitN(), and waitqd_QDChare::waitQD().
Definition at line 1272 of file threads.c.
References CmiAbort(), CreateFiberEx(), CthThreadInit(), CthThreadStruct::fiber, FiberSetUp(), and malloc().
Referenced by CPathGetSingle(), CpdPythonGroup::cpdCheck(), CpmThread2(), CpmThreadSize2(), Cpthread_create3(), CthCreateMigratable(), CthSuspendSchedulingThread(), PythonObject::execute(), and TCharm::TCharm().
| void CthResume | ( | CthThread | t | ) |
Definition at line 1238 of file threads.c.
References CthThreadStruct::base, CthBaseResume(), CthFiberBlock(), CthResume1(), CthThreadBase::exiting, CthThreadStruct::fiber, CthProcInfo::switchbuf_sp, and SwitchToFiber().
Referenced by CpdPythonGroup::cpdCheck(), CthResumeNormalThread(), CthResumeNormalThreadDebug(), CthResumeSchedulingThread(), CthSuspend(), and PythonObject::execute().
| void CthFree | ( | CthThread | t | ) |
Definition at line 1193 of file threads.c.
References CthThreadStruct::base, CthClearThreads(), CthSelf(), CthThreadFree(), CthThreadBase::exiting, free(), and malloc().
Referenced by TCharm::clear(), CpmThread3(), Cpthread_exit(), CthPup(), and TCharm::~TCharm().
| void CthPrintThdMagic | ( | CthThread | ) |
Definition at line 2035 of file threads.c.
References CthThreadStruct::base, CmiPrintf(), and CthThreadBase::magic.
| void CthPrintThdStack | ( | CthThread | ) |
Definition at line 1997 of file threads.c.
References CthThreadStruct::base, CmiPrintf(), CthThreadBase::stack, and CthThreadStruct::stackp.
| void CthSuspend | ( | void | ) |
Sometimes, a CthThread is running without ever being awakened In this case, the scheduled is the initialized value "0"
Definition at line 688 of file threads.c.
References CthThreadBase::choosefn, CmiAbort(), CthNoStrategy(), CthResume(), CthThreadBase::listener, CthThreadListener::next, CthThreadBase::scheduled, CthThreadListener::suspend, CthThreadBase::suspendable, and traceSuspend().
Referenced by CfutureWait(), Tempo::ckTempoRecv(), CkWaitFutureID(), CPathRecv(), CpmThread3(), Cpthread_cond_wait(), Cpthread_exit(), Cpthread_join(), Cpthread_mutex_lock(), CthThreadFinished(), CthYield(), CthYieldPrio(), SearchGroup::getTotalSolutions(), CkCallback::impl_thread_delay(), ParFUMShadowArray::lockRegion(), TCharm::stop(), MSA_Thread_Listener::suspend(), ParFUMShadowArray::unlockRegion(), ParFUMShadowArray::unpendRegion(), CkSema::wait(), CkSema::waitN(), and waitqd_QDChare::waitQD().
| void CthAwaken | ( | CthThread | ) |
Definition at line 727 of file threads.c.
References CthNoStrategy(), and traceAwaken().
Referenced by CfutureAwaken(), SearchGroup::childCount(), CPathGetSingle(), CPathSendHandler(), CpmThread2(), CpmThreadSize2(), Cpthread_cond_broadcast(), Cpthread_cond_signal(), Cpthread_cond_wait(), Cpthread_create3(), Cpthread_exit(), Cpthread_mutex_unlock(), CthYield(), ParFUMShadowArray::lockReply(), waitqd_QDChare::onQD(), CkCallback::send(), setFuture(), MSA_Thread_Listener::signal(), CkSema::signal(), TCharm::start(), Tempo::tempoGeneric(), and ParFUMShadowArray::unlockReply().
Definition at line 755 of file threads.c.
References CthNoStrategy(), and traceAwaken().
Referenced by CthYieldPrio().
Definition at line 655 of file threads.c.
Referenced by CthSchedInit(), CthSetStrategyDefault(), and CthSuspendSchedulingThread().
| void CthYield | ( | void | ) |
Definition at line 749 of file threads.c.
References CthAwaken(), and CthSuspend().
Referenced by chunk::addRemoteEdge(), FEM_Adapt_Algs::Coarsen(), chunk::coarseningElements(), FEM_AdaptL::edge_bisect(), FEM_AdaptL::edge_contraction(), FEM_AdaptL::edge_contraction_help(), FEM_AdaptL::edge_flip(), chunk::getAccessLock(), chunk::getAdjustLock(), FEM_MUtil::idxllockLocal(), MeshStreamer< dtype >::insertData(), FEM_lock::lock(), element::lockArc(), element::lockLF(), FEM_AdaptL::lockNodes(), NetFEM_Begin(), ParFUMShadowArray::recv_splits(), FEM_Adapt_Algs::Refine(), Bulk_Adapt::Refine_h(), element::refineCP(), element::refineLE(), element::refineLF(), chunk::refiningElements(), FEM_lock::unlock(), and FEM_AdaptL::vertex_remove().
Definition at line 647 of file threads.c.
Referenced by CfutureWait(), CkWaitFutureID(), and CthResumeSchedulingThread().
Definition at line 648 of file threads.c.
Referenced by CfutureAwaken(), CthSuspendSchedulingThread(), and setFuture().
| void CthSwitchThread | ( | CthThread | t | ) |
| size_t CthStackOffset | ( | CthThread | t, | |
| char * | p | |||
| ) |
Definition at line 2003 of file threads.c.
References s, CthThreadStruct::stack, and CthProcInfo::stackbase.
Referenced by TCharm::UserData::UserData().
| char * CthPointer | ( | CthThread | t, | |
| size_t | pos | |||
| ) |
Definition at line 2015 of file threads.c.
References p, CthThreadStruct::savedsize, CthThreadStruct::savedstack, CthThreadStruct::stack, and CthProcInfo::stackbase.
Referenced by TCharm::UserData::getData(), and TCharm::UserData::pup().
| double CthAutoYieldFreq | ( | CthThread | t | ) |
| void CthAutoYieldBlock | ( | void | ) |
| void CthAutoYieldUnblock | ( | void | ) |
| void CtgInit | ( | void | ) |
Initialize the globals support (called on each processor).
Definition at line 274 of file global-elfcopy.C.
References CtgGlobalStruct::allocate(), CkGetArgv(), CmiPrintf(), CtgGlobalStruct::data_seg, CtgGlobalList::getSize(), init_symtab(), CtgGlobalList::install(), CtgGlobalList::read(), readBlacklist(), and readGlobals().
Referenced by TCharm::procInit().
| CpvExtern | ( | int | , | |
| CmiPICMethod | ||||
| ) |
PIC method used: 0 = nop, 1 = elfgot, 2 = elfcopy.
| CtgGlobals CtgCreate | ( | CthThread | tid | ) |
Copy the current globals into this new set.
Definition at line 305 of file global-elfcopy.C.
References CtgGlobalStruct::allocate(), CtgGlobalStruct::data_seg, CtgGlobalList::getSize(), printf(), and CtgGlobalList::read().
Referenced by TCharm::TCharm().
| void CtgInstall | ( | CtgGlobals | g | ) |
Install this set of globals.
If g==NULL, returns to original globals.
Definition at line 325 of file global-elfcopy.C.
References CtgCurrentGlobals(), CtgGlobalStruct::data_seg, CtgGlobalList::install(), CtgGlobalStruct::installed, printf(), and CtgGlobalList::read().
Referenced by TCharm::activateThread(), and TCharm::deactivateThread().
| CtgGlobals CtgPup | ( | pup_er | , | |
| CtgGlobals | g | |||
| ) |
PUP this (not currently installed) globals set.
Definition at line 313 of file global-elfcopy.C.
References CmiAbort(), CtgGlobalList::getSize(), CtgGlobalStruct::installed, PUP::er::isUnpacking(), p, CtgGlobalStruct::pup(), and CtgGlobalStruct::seg_size.
Referenced by TCharm::pupThread().
| void CtgFree | ( | CtgGlobals | g | ) |
Delete this (not currently installed) set of globals.
Definition at line 340 of file global-elfcopy.C.
References CmiAbort(), and CtgGlobalStruct::installed.
Referenced by TCharm::~TCharm().
| CtgGlobals CtgCurrentGlobals | ( | void | ) |
Return the current global list.
Definition at line 345 of file global-elfcopy.C.
Referenced by CtgInstall(), and TCharmAPIRoutine::TCharmAPIRoutine().
| void CtgInstall_var | ( | CtgGlobals | g, | |
| void * | ptr | |||
| ) |
Definition at line 349 of file global-elfcopy.C.
References CtgGlobalStruct::data_seg, CtgGlobalList::install_var(), and CtgGlobalList::read_var().
Referenced by TCharm::activateVariable().
| void CtgUninstall_var | ( | CtgGlobals | g, | |
| void * | ptr | |||
| ) |
Definition at line 357 of file global-elfcopy.C.
References CtgGlobalStruct::data_seg, CtgGlobalList::install_var(), and CtgGlobalList::read_var().
Referenced by TCharm::deactivateVariable().
| void CthAddListener | ( | CthThread | th, | |
| struct CthThreadListener * | l | |||
| ) |
This listener is about to begin receiving suspend and resume events for this thread.
"suspend", "resume", "free", and "data" fields must all already be set. When this thread exits, l->free will be called on this listener, which should deallocate the listener memory.
Definition at line 779 of file threads.c.
References CthThreadListener::next, p, and CthThreadListener::thread.
Referenced by CkMigratable::CkAddThreadListeners(), and TraceProjections::traceAddThreadListeners().
| void CthUserAddListeners | ( | CthThread | th | ) |
This is function is inserted into .def.h after thread creation.
It serves as an interface for the user to add the listeners as needed. User has to implement this somewhere in the system.
Definition at line 2327 of file isomalloc.c.
References block2pointer(), CmiAbort(), CmiError(), CmiMyPe(), CthSelf(), disabled_map(), errno, get_slots(), grab_slots(), isofreefn(), isomallocfn(), isomallocStart, CmiIsomallocBlock::length, length2slots(), map_failed(), map_slots(), mempool_init(), mempool_malloc(), n, printf(), s, and CmiIsomallocBlock::slot.
Referenced by _isomallocAlign(), CtgGlobalStruct::allocate(), CmiIsomallocBlockListMalloc(), CmiIsomallocBlockListNew(), and CthAllocateStack().
| void* CmiIsomallocAlign | ( | size_t | align, | |
| size_t | size, | |||
| CthThread | t | |||
| ) |
Definition at line 2390 of file isomalloc.c.
References _isomallocAlign().
Referenced by allocNewTLSSeg().
| void CmiIsomallocPup | ( | pup_er | p, | |
| void ** | block | |||
| ) |
Definition at line 2400 of file isomalloc.c.
References all_slotOP(), block2pointer(), CmiAbort(), isomallocStart, CmiIsomallocBlock::length, length, length2slots(), map_failed(), map_slots(), n, pointer2block(), pup_bytes(), pup_isDeleting(), pup_isRestarting(), pup_isUnpacking(), pup_isUserlevel(), s, CmiIsomallocBlock::slot, and unmap_slots().
Referenced by CmiIsomallocBlockListPup(), CthPupBase(), and CtgGlobalStruct::pup().
| void CmiIsomallocFree | ( | void * | block | ) |
Definition at line 2444 of file isomalloc.c.
References all_slotOP(), disabled_unmap(), isomallocStart, CmiIsomallocBlock::length, length2slots(), mempool_free_thread(), n, pointer2block(), s, CmiIsomallocBlock::slot, and unmap_slots().
Referenced by CmiIsomallocBlockListDelete(), CmiIsomallocBlockListFree(), CthThreadBaseFree(), and CtgGlobalStruct::~CtgGlobalStruct().
| int CmiIsomallocEnabled | ( | ) |
Definition at line 2395 of file isomalloc.c.
References isomallocStart.
Referenced by checkAddress().
| CmiInt8 CmiIsomallocLength | ( | void * | block | ) |
Definition at line 2464 of file isomalloc.c.
References CmiIsomallocBlock::length, and pointer2block().
Referenced by meta_realloc().
| int CmiIsomallocInRange | ( | void * | addr | ) |
Definition at line 2470 of file isomalloc.c.
References isomallocEnd, isomallocStart, pointer_ge(), and pointer_lt().
Referenced by checkAddress(), meta_free(), and meta_realloc().
| CmiIsomallocBlockList* CmiIsomallocBlockListNew | ( | CthThread | t | ) |
Definition at line 2526 of file isomalloc.c.
References CmiIsomalloc(), CmiIsomallocBlockList::next, and CmiIsomallocBlockList::prev.
Referenced by ArmciVirtualProcessor::ArmciVirtualProcessor(), and TCharm::TCharm().
| void CmiIsomallocBlockListPup | ( | pup_er | p, | |
| CmiIsomallocBlockList ** | l, | |||
| CthThread | tid | |||
| ) |
Definition at line 2649 of file isomalloc.c.
References block_header_::block_next, CmiAbort(), CmiCreateLock(), CmiIsomallocPup(), CmiMyPe(), CthSelf(), slot_header_::gnext, map_slots(), block_header_::mem_hndl, mempool_destroy(), mempool_type::mempoolLock, CmiIsomallocBlockList::next, printf(), pup_bytes(), pup_isDeleting(), pup_isUnpacking(), slot_header_::size, block_header_::size, size, slotsize, and slot_header_::status.
Referenced by ArmciVirtualProcessor::pup(), and TCharm::pupThread().
| void CmiIsomallocBlockListDelete | ( | CmiIsomallocBlockList * | l | ) |
Definition at line 2691 of file isomalloc.c.
References CmiIsomallocFree(), and CmiIsomallocBlockList::next.
Referenced by TCharm::clear(), ArmciVirtualProcessor::~ArmciVirtualProcessor(), and TCharm::~TCharm().
| void* CmiIsomallocBlockListMalloc | ( | CmiIsomallocBlockList * | l, | |
| size_t | nBytes | |||
| ) |
Definition at line 2704 of file isomalloc.c.
References CmiIsomalloc(), n, CmiIsomallocBlockList::next, CmiIsomallocBlockList::prev, and Slot_toUser().
Referenced by ArmciVirtualProcessor::BlockMalloc(), and meta_malloc().
| void* CmiIsomallocBlockListMallocAlign | ( | CmiIsomallocBlockList * | l, | |
| size_t | align, | |||
| size_t | nBytes | |||
| ) |
Definition at line 2717 of file isomalloc.c.
References _isomallocAlign(), n, CmiIsomallocBlockList::next, CmiIsomallocBlockList::prev, and Slot_toUser().
Referenced by meta_memalign().
| void CmiIsomallocBlockListFree | ( | void * | doomedMallocedBlock | ) |
Definition at line 2730 of file isomalloc.c.
References CmiAbort(), CmiIsomallocFree(), n, CmiIsomallocBlockList::next, CmiIsomallocBlockList::prev, and Slot_fmUser().
Referenced by ARMCI_Free(), ARMCI_Free_local(), and meta_free().
| CthCpvExtern | ( | char * | , | |
| CthData | ||||
| ) |
Allocate another size bytes of thread-local storage, and return the offset into the thread storage buffer.
Definition at line 362 of file threads.c.
References CthFixData(), and CthThreadBase::data.
Referenced by Cpthread_key_create().
| void CthRegistered | ( | int | dataOffMax | ) |
Make sure we have room to store up to at least maxOffset bytes of thread-local storage.
Definition at line 381 of file threads.c.
References CthFixData(), and CthThreadBase::data.
| Cfuture CfutureCreate | ( | void | ) |
Definition at line 34 of file futures.c.
References CmiMyPe(), Cfuture_s::data, data, malloc(), Cfuture_s::pe, Cfuture_data_s::ready, Cfuture_data_s::value, and Cfuture_data_s::waiters.
Definition at line 87 of file futures.c.
References CfutureCreateBuffer(), CfutureStoreBuffer(), and copy().
| void* CfutureWait | ( | Cfuture | f | ) |
Definition at line 94 of file futures.c.
References CmiMyPe(), CmiPrintf(), CthSelf(), CthSetNext(), CthSuspend(), Cfuture_s::data, data, Cfuture_s::pe, Cfuture_data_s::ready, CfutureValue_s::rest, Cfuture_data_s::value, value, and Cfuture_data_s::waiters.
| void CfutureDestroy | ( | Cfuture | f | ) |
Definition at line 112 of file futures.c.
References CmiFree(), CmiMyPe(), CmiPrintf(), Cfuture_s::data, free(), Cfuture_s::pe, Cfuture_data_s::value, and Cfuture_data_s::waiters.
| void* CfutureCreateBuffer | ( | int | bytes | ) |
| void CfutureDestroyBuffer | ( | void * | val | ) |
| void CfutureStoreBuffer | ( | Cfuture | f, | |
| void * | value | |||
| ) |
Definition at line 76 of file futures.c.
References CfutureAwaken(), CmiMyPe(), Converse::CmiSyncSendAndFree(), CfutureValue_s::data, Cfuture_s::data, Cfuture_s::pe, and CfutureValue_s::valsize.
Referenced by CfutureSet().
| void CfutureInit | ( | ) |
| void CldRegisterEstimator | ( | CldEstimator | fn | ) |
| int CldEstimate | ( | void | ) |
Definition at line 56 of file cldb.spray.c.
References CldLoad().
Referenced by CldAverageHandler(), and CldInitiateReduction().
| char* CldGetStrategy | ( | void | ) |
Definition at line 119 of file cldb.bluegene.c.
References BgMyPe(), BgNumPes(), CldCountTokens(), CldMinAvg(), CldNodeEnqueue(), CldPresentPE(), CldPutToken(), CldStoreCharemsg(), CldSwitchHandler(), CmiAbort(), CmiMyPe(), CmiNodeOf(), CmiPrintf(), Converse::CmiSyncBroadcastAllAndFree(), Converse::CmiSyncBroadcastAndFree(), Converse::CmiSyncSendAndFree(), CmiTimer(), CrnRand(), peinfo::EnqueueHandler, and peinfo::HopHandler.
Referenced by _CldEnqueue().
Definition at line 102 of file cldb.bluegene.c.
References CldSwitchHandler(), CmiFree(), Converse::CmiSyncListSendAndFree(), Converse::CmiSyncSend(), and peinfo::EnqueueHandler.
Referenced by _CldEnqueueMulti().
Definition at line 97 of file cldb.bluegene.c.
References CldSwitchHandler(), CmiAbort(), CmiFree(), CmiLookupGroup(), Converse::CmiSyncMulticastAndFree(), Converse::CmiSyncSend(), and peinfo::EnqueueHandler.
Referenced by _CldEnqueueGroup().
Definition at line 201 of file cldb.bluegene.c.
References CldCountTokens(), CldMinAvg(), CldSwitchHandler(), CmiMyPe(), CmiNodeOf(), CrnRand(), peinfo::EnqueueHandler, and peinfo::HopHandler.
Referenced by _CldNodeEnqueue(), and CldEnqueue().
| CmmTable CmmPup | ( | pup_er | p, | |
| CmmTable | t, | |||
| CmmPupMessageFn | msgpup | |||
| ) |
Definition at line 152 of file msgmgr.c.
References CmiFree(), CmmEntries(), CmmFree(), CmmNew(), CmmPut(), CmmTableStruct::first, free(), malloc(), msg, CmmEntryStruct::msg, CmmEntryStruct::next, CmmEntryStruct::ntags, pup_isDeleting(), pup_isUnpacking(), and CmmEntryStruct::tags.
Referenced by MBlockChunk::pup(), and ampi::pup().
| CmmTable CmmNew | ( | ) |
Definition at line 25 of file msgmgr.c.
References CmiAlloc(), CmmTableStruct::first, and CmmTableStruct::lasth.
Referenced by ampi::ampi(), CmiInitCPUAffinity(), CmmPup(), CPathGetSingle(), cpuTopoHandler(), MBlockChunk::MBlockChunk(), receiver::receiver(), and Tempo::Tempo().
| void CmmFree | ( | CmmTable | t | ) |
Definition at line 33 of file msgmgr.c.
References CmiAbort(), and CmiFree().
Referenced by CmmPup(), cpuAffinityHandler(), cpuTopoHandler(), ampi::~ampi(), MBlockChunk::~MBlockChunk(), and receiver::~receiver().
| void CmmFreeAll | ( | CmmTable | t | ) |
Definition at line 44 of file msgmgr.c.
References CmiFree(), CmmTableStruct::first, and CmmEntryStruct::next.
Referenced by ampi::~ampi().
Definition at line 55 of file msgmgr.c.
References CmiAlloc(), CmmEntryStruct::msg, CmmEntryStruct::next, CmmEntryStruct::ntags, and CmmEntryStruct::tags.
Referenced by AMPI_Irecv(), CmmPup(), CPathSendHandler(), cpuAffinityHandler(), cpuTopoHandler(), ampi::inorder(), receiver::irecv(), MBlockChunk::recv(), receiver::sendTo(), and Tempo::tempoGeneric().
Definition at line 89 of file msgmgr.c.
References CmiFree(), CmmTagsMatch(), CmmEntryStruct::msg, msg, CmmEntryStruct::next, CmmEntryStruct::ntags, and CmmEntryStruct::tags.
Definition at line 139 of file msgmgr.c.
References n, and CmmEntryStruct::next.
Referenced by CmmPup(), cpuTopoHandler(), and receiver::pupCmmTable().
Definition at line 121 of file msgmgr.c.
References CmmTagsMatch(), CmmEntryStruct::next, CmmEntryStruct::ntags, and CmmEntryStruct::tags.
| void ConverseInit | ( | int | argc, | |
| char ** | argv, | |||
| CmiStartFn | fn, | |||
| int | usched, | |||
| int | initret | |||
| ) |
Definition at line 620 of file machine-common-core.c.
References Cmi_argv, Cmi_argvcopy, Cmi_smp_mode_setting, Cmi_startfn, CmiAbort(), CmiCopyArgs(), CmiCreateLock(), CmiGetArgFlag(), CmiGetArgInt(), CmiInitPxshm(), CmiInitXpmem(), CmiStartThreads(), COMM_THREAD_NOT_EXIST, COMM_THREAD_ONLY_RECV, COMM_THREAD_SEND_RECV, ConverseRunPE(), LrtsInit(), and printf().
Referenced by fmain_(), KillOnAllSigs(), main(), and TCHARM_Init().
| void ConverseExit | ( | void | ) |
Definition at line 846 of file machine-common-core.c.
References Cmi_smp_mode_setting, CmiExitPxshm(), CmiExitXpmem(), CmiLock(), CmiMyPe(), CmiPrintf(), CmiUnlock(), CmiYield(), COMM_THREAD_NOT_EXIST, COMM_THREAD_ONLY_RECV, ConverseCommonExit(), LrtsDrainResources(), and LrtsExit().
Referenced by _exitHandler(), CkMessageDetailReplayDone(), ConverseInit(), ConverseRunPE(), KillOnAllSigs(), and TraceCounter::traceInit().
| void CmiAbort | ( | const char * | why | ) |
Serial version of common Charm++ routines:.
Serial version of common Charm++ routines:.
Currently only used for FEM_ALONE mode.
Orion Sky Lawlor, olawlor@acm.org, 2003/8/15
Definition at line 891 of file machine-common-core.c.
References CmiExitPxshm(), CmiExitXpmem(), and LrtsAbort().
Referenced by __cmi_assert(), _callWhenIdle(), _checkpointBarrierHandler(), _cmiZeroHandler(), _exitHandler(), _handlePhase1(), _initHandler(), _nullFn(), _ObjectQHandler(), _parseCommandLineOpts(), _processHandler(), _receiveLocationHandler(), _removeProcessedLogHandler(), _ticketHandler(), _TokenHandler(), LogPool::add(), CkReductionMgr::addContribution(), NetFEM_update::addElems(), LBDatabase::addLoadbalancer(), NetFEM_update::addNodes(), advanceNodes(), ammasso_check_err(), ammasso_check_post_err(), AMPI_MemCheckpoint(), ARMCI_Wait(), CkDelegateMgr::ArraySectionSend(), TraceProjections::beginComputation(), TraceProjections::beginExecute(), TraceCounter::beginExecute(), TraceProjections::beginExecuteLocal(), TraceCounter::beginOverview(), CkMemCheckPT::BuddyPE(), BufferAlloc(), GreedyAgentLB::BuildCpuArray(), GreedyAgentLB::BuildObjectArray(), PUP::fromTextFile::bytes(), PUP::toTextFile::bytes(), PUP::toTextUtil::bytes(), PUP::sizer::bytes(), PUP_toNetwork4_unpack::bytes(), PUP_toNetwork4_pack::bytes(), PUP_toNetwork_unpack::bytes(), PUP_toNetwork_pack::bytes(), PUP_fmt::bytes(), call_mmap_anywhere(), call_mmap_fixed(), call_munmap(), ccs_killpe(), CcsBufferMessage(), CcsImpl_ccs2converse(), CcsReply(), CcsSendReply(), CcsSetMergeFn(), checkBufferedLocalMessageCopy(), chpt< StateType >::checkpoint(), CkFindObjectPtr(), CkGetSectionInfo(), CkHashFunction_pointer(), CkMemRestart(), CkMessageWatcherInit(), CkPointer< T >::CkPointer(), CkSendMsg(), CkSendMsgBranchGroup(), CldComputeNeighborData(), CldEnqueue(), CldEnqueueGroup(), CMI_VMI_CacheEntry_From_Context(), CMI_VMI_Grid_Objects_Compare(), CMI_VMI_Read_Environment(), CmiAllAsyncMsgsSent(), CmiAmmassoOpenQueuePairs(), CmiAsyncBroadcastFn(), CmiAsyncMsgSent(), CmiCheckGmStatus(), CmiCommLock(), CmiCommUnlock(), CmiCreatePersistent(), CmiDestoryPersistent(), CmiFree(), CmiGetArgIntDesc(), CmiGetArgLongDesc(), CmiGetArgStringDesc(), CmiGetDynamicReduction(), CmiGetReductionCreate(), CmiGroupInit(), CmiInitCPUAffinity(), CmiInitMemAffinity(), CmiInitPxshm(), CmiInitSysvshm(), CmiInitXpmem(), CmiIOInit(), CmiIsomalloc(), CmiIsomallocBlockListFree(), CmiIsomallocBlockListPup(), CmiIsomallocPup(), CmiMachineExit(), CmiMachineInit(), CmiMemoryMarkBlock(), CmiMXMakeConnection(), CmiNodeReduce(), CmiNodeReduceStruct(), CmiOutOfMemory(), CmiPoolFree(), CmiProcessPriority(), CmiReleaseSentMessages(), CmiScanf(), CmiSendMessageXpmem(), CmiSetCPUAffinity(), CmiStartCounters(), CmiStopCounters(), CmiTmpAlloc(), CmiTmpFree(), CmiUsePersistentHandle(), CmmFree(), eventQueue::CommitEvents(), TopoLB::computePartitions(), TopoCentLB::computePartitions(), CkMulticastMgr::contribute(), ConverseInit(), TopoManager::coordinatesToRank(), CopyMsg(), cpd_memory_single_pup(), CpdDebugCallAllocationTree(), CpdDebugCallMemStat(), CpdFreezeModeScheduler(), CpdSearchLeaks(), cpuAffinityRecvHandler(), CQdCallWhenIdle(), CQdHandlePhase1(), CqsEnqueueGeneral(), RefinerApprox::create(), Refiner::create(), CkMemCheckPT::createEntry(), CreateLBFunc_Def(), createqp(), LogPool::createRC(), createShmObjectsAndSems(), LogPool::createSts(), TraceBluegene::creatFiles(), CtgFree(), CtgPup(), CthAliasCreate(), CthAliasEnable(), CthCreate(), CthCreateInner(), CthNoStrategy(), CthPup(), CthPupBase(), CthSuspend(), CWeb_Invalid(), CWeb_Reduce(), CWebPerformanceRegisterFunction(), Strategy::deliver(), StringPool::dump(), TraceCounter::endExecute(), TraceProjections::endExecuteLocal(), TraceCounter::endOverview(), EnqueueOutgoingDgram(), extract_args(), PeTable::ExtractAndPack(), PeTable::ExtractAndVectorize(), TopoCentLB::extractMax(), FEM_Coarsen_Operation(), CkHashtable::findEntry(), TraceMemory::flush(), PUP::fromMemBuf(), get_callback_dest(), CkMemCheckPTInfo::getCopy(), getFreeSendSlot(), MSA::MSA3D< ENTRY, ENTRY_OPS_CLASS, ENTRIES_PER_PAGE >::getInitialAccum(), MSA::MSA3D< ENTRY, ENTRY_OPS_CLASS, ENTRIES_PER_PAGE >::getInitialWrite(), NetFEM_update::getItem(), grab_slots(), Group::Group(), RouterStrategy::handleMessage(), PipeBroadcastConverse::handleMessage(), hostInfo(), liveVizConfig::init(), init_ranges(), initBigSimTrace(), initHandlerRec(), initInfiOtherNodeData(), ConvComlibManager::insertMessage(), ConvComlibManager::insertStrategy(), isomallocfn(), KillOnAllSigs(), KLevelTree::KLevelTree(), LV3D_save_init(), LV3D_save_view(), main::main(), map_failed(), match(), matchTest(), memAbort(), meta_free(), MPI_BAND(), MPI_BOR(), MPI_BXOR(), MPI_LAND(), MPI_LOR(), MPI_LXOR(), MPI_MAXLOC(), MPI_MINLOC(), MPISendOneMsg(), ArmciVirtualProcessor::msgGop(), NborBaseLB::NborBaseLB(), on_timeout(), CountLogPool::openFile(), LogPool::openLog(), TraceLogger::openLogFiles(), CkPointer< T >::operator=(), _CkOStream::output(), PUP::fromTextFile::parseError(), GridMetisLB::Partition_ClusterObjects_Into_PEs(), PCQueuePop(), pollCq(), pollRecvCq(), pollSendCq(), POSEreadCmdLine(), print_node0(), processAmmassoControlMessage(), processAsyncEvents(), processMessage(), ProcessMessage(), processRecvWC(), PipeBroadcastConverse::propagate(), PumpEvents(), PumpMsgs(), PumpMsgsBlocking(), NetFEM_update::pup(), pup_checkMPIerr(), PUP_getRegEntry(), PUPbytes(), PUP::er::pupCmiAllocBuf(), CkHashtable::put(), put_callback(), TopoManager::rankToCoordinates(), readGlobals(), readMHz(), CentralLB::readStatsMsgs(), recv_callback(), CkMemCheckPT::recvData(), CkMulticastMgr::recvRedMsg(), CkMulticastMgr::reduceFragment(), TraceCounter::registerArg(), TraceLogger::RegisterLanguage(), CkCompactVec< T >::remove(), CkVec< CkZeroPtr< T, PUP_PTR > >::remove(), Refiner::removeComputes(), chpt< StateType >::restore(), CkLocMgr::restore(), CkLocMgr::resume(), Chare::sanitycheck(), PUP::seekBlock::seek(), PUP::seekBlock::seekBlock(), CkCallback::send(), send_callback(), sendCheckpointData(), SendMsgBuf(), PrefixRouter::sendMulticast(), CkMulticastMgr::sendToSection(), FEM_Attribute::set(), PhaseTable::setEp(), PhaseEntry::setEp(), SumLogPool::setEp(), CountLogPool::setEp(), ConvComlibManager::setStrategy(), RouterStrategy::setupRouter(), OrbLB::sort_partition(), LBDB::StartLB(), PhaseTable::startPhase(), TraceCore::startPtc(), NeighborCommLB::Strategy(), strategyHandler(), SumLogPool::SumLogPool(), MSA::MSAHandle< MSA::MSA1D< ElemList, DefaultListEntry< ElemList, true >, MSA_DEFAULT_ENTRIES_PER_PAGE > >::syncRelease(), TokenAlloc(), PUP::toMemBuf(), TopologyAgent::TopologyAgent(), TraceCounter::traceInit(), TraceProjections::TraceProjections(), TraceProjector::traceRegisterUserEvent(), TraceProjections::traceRegisterUserEvent(), parallelTransfer_c::transfer(), parallelSurfaceTransfer_c::transfer(), BaseLB::turnOff(), BaseLB::turnOn(), ParFUMShadowArray::unlockSharedIdxls(), minHeap::update(), SumLogPool::updateSummaryDetail(), TopoLB::work(), TopoCentLB::work(), RotateLB::work(), RefineTopoLB::work(), RandCentLB::work(), OrbLB::work(), GreedyLB::work(), GreedyCommLB::work(), CommLB::work(), BlockLB::work(), TraceSummaryBOC::write(), SumLogPool::write(), CentralLB::writeStatsMsgs(), TraceUtilization::writeSts(), SumLogPool::writeSts(), writeSts(), CountLogPool::writeSts(), and WSLB::WSLB().
| void CcdCallFnAfter | ( | CcdVoidFn | fnp, | |
| void * | arg, | |||
| double | msecs | |||
| ) |
Register a callback function that will be triggered after a minimum delay of deltaT.
Definition at line 517 of file conv-conds.c.
References CcdCallFnAfterOnPE().
Referenced by _messageLoggingInit(), _qdHandler(), checkpointAlarm(), CkDieNow(), CldAverageHandler(), CommunicationPeriodicCaller(), CommunicationsClockCaller(), CWeb_Collect(), TCharm::evacuate(), killLocal(), KillOnAllSigs(), on_idle(), processRaiseEvacFile(), readKillFile(), MeshStreamer< dtype >::registerPeriodicProgressFunction(), retryTicketRequest(), sendLocalMessageCopy(), sendTicketRequest(), and startMlogCheckpoint().
Register a callback function that will be triggered when the specified condition is raised the next time.
Definition at line 451 of file conv-conds.c.
References append_elem().
Referenced by _initCharm(), _qdHandler(), buddyDieHandler(), CIdleTimeoutInit(), CkMemCheckPT::CkMemCheckPT(), CkMessageDetailReplay::CkMessageDetailReplay(), CldGraphModuleInit(), CQdHandler(), CQdRegisterCallback(), pingBuddy(), pingCheckHandler(), and CkMemCheckPT::pup().
Register a callback function that will be triggered *whenever* the specified condition is raised.
Definition at line 469 of file conv-conds.c.
References append_elem().
Referenced by AMPI_Install_Idle_Timer(), CcdModuleInit(), CcsInit(), CkArray::CkArray(), CldGraphModuleInit(), CldOtherInit(), CmiInitCell(), ConverseInit(), TraceSummaryBOC::initCCS(), initUsage(), KillOnAllSigs(), LV3D0_ClientManager_toMaster::LV3D0_ClientManager_toMaster(), LV3D_PerfManager::LV3D_PerfManager(), SendMsgBuf(), LBMachineUtil::StatsOn(), traceCommonInit(), and TraceUtilizationInit::TraceUtilizationInit().
Register a callback function that will be triggered on the specified PE after a minimum delay of deltaT.
Definition at line 506 of file conv-conds.c.
References ccd_heap_insert(), and CmiWallTimer().
Referenced by CcdCallFnAfter(), CldBalancePeriod(), controlPointManager::controlPointManager(), periodicDebugPrintStatus(), periodicProcessControlPoints(), and LBDB::batsyncer::resumeFromSync().
Register a callback function that will be triggered on the specified PE when the specified condition is raised the next time.
Definition at line 460 of file conv-conds.c.
References append_elem().
Register a callback function that will be triggered on the specified PE *whenever* the specified condition is raised.
Definition at line 478 of file conv-conds.c.
References append_elem().
Referenced by CkLocMgr::CkLocMgr().
Cancel a previously registered conditional callback.
Definition at line 487 of file conv-conds.c.
References remove_elem().
Cancel a previously registered conditional callback.
Definition at line 496 of file conv-conds.c.
References remove_elem().
Referenced by AMPI_Uninstall_Idle_Timer(), LBMachineUtil::StatsOff(), traceCommonInit(), and LV3D0_ClientManager_toMaster::~LV3D0_ClientManager_toMaster().
| void CcdRaiseCondition | ( | int | condnum | ) |
Raise a condition causing all registered callbacks corresponding to that condition to be triggered.
Definition at line 527 of file conv-conds.c.
References call_cblist_keep(), call_cblist_remove(), and CmiWallTimer().
Referenced by CcdCallBacks(), CQdAnnounceHandler(), CsdBeginIdle(), CsdEndIdle(), CsdStillIdle(), KillOnAllSigs(), and LrtsInitCpuTopo().
Extract the function-return pointers listed in the stack up to this depth.
nSkip is the number of enclosing functions to skip-- for example, nSkip==0 means the retPtrs[0] will be the caller of CmiBacktraceRecord. Returns retPtrs[0..*nLevels-1] stack pointers. nLevels may be decreased if not enough levels are available.
Definition at line 24 of file cmibacktrace.c.
Referenced by CmiIsFortranLibraryCall(), CmiPrintStackTrace(), CpdNotify(), and setSlot().
| char** CmiBacktraceLookup | ( | void ** | srcPtrs, | |
| int | nLevels | |||
| ) |
Look up the names of these function pointers.
Caller must free() the returned array, but not the individual strings.
Definition at line 40 of file cmibacktrace.c.
Referenced by CmiBacktracePrint(), and CmiIsFortranLibraryCall().
| CpvExtern | ( | void * | , | |
| CmiLocalQueue | ||||
| ) |
| CpvExtern | ( | int | , | |
| CmiImmediateMsgHandlerIdx | ||||
| ) |
| CpvExtern | ( | unsigned | , | |
| networkProgressCount | ||||
| ) |
| void CmiMachineProgressImpl | ( | ) |
| void CmiInitCounters | ( | ) |
Definition at line 323 of file threads.c.
Referenced by CkMigratable::CkAddThreadListeners(), Group::CkAddThreadListeners(), and Chare::CkAddThreadListeners().
| void CthTraceResume | ( | CthThread | t | ) |
Definition at line 2029 of file threads.c.
References CthThreadStruct::base, CthThreadBase::tid, and traceResume().
Referenced by CthResumeNormalThread(), CthResumeNormalThreadDebug(), CthResumeSchedulingThread(), PUPmarshall(), and ampi::recv().
| CpvExtern | ( | char * | , | |
| _validProcessors | ||||
| ) |
| int CmiGridQueueGetInterval | ( | ) |
| int CmiGridQueueGetThreshold | ( | ) |
| void CmiGridQueueDeregisterAll | ( | ) |
Definition at line 2691 of file machine.c.
Referenced by CmiGridQueueLookupMsg(), and CmiGridQueueRegister().
| int CmiGridQueueLookupMsg | ( | char * | msg | ) |
| size_t CmiFwrite | ( | const void * | ptr, | |
| size_t | size, | |||
| size_t | nmemb, | |||
| FILE * | f | |||
| ) |
Definition at line 141 of file pup_util.C.
References PUP::mem::buf, errno, and printf().
Referenced by PUP::toDisk::bytes().
| FILE* CmiFopen | ( | const char * | path, | |
| const char * | mode | |||
| ) |
Definition at line 159 of file pup_util.C.
References errno, and printf().
Referenced by CkCheckpointMgr::Checkpoint(), checkpointOne(), and CkRestartMain().
| int CmiFclose | ( | FILE * | fp | ) |
Definition at line 175 of file pup_util.C.
References errno, printf(), and status().
Referenced by CkCheckpointMgr::Checkpoint(), checkpointOne(), and CkRestartMain().
| EXTERN CmiNotifyCommThdMsg* CmiCreateNotifyCommThdMsg | ( | CmiCommThdFnPtr | fn, | |
| int | numParams, | |||
| void * | params, | |||
| int | toKeep | |||
| ) |
Definition at line 50 of file machine-commthd-util.c.
References CmiNotifyCommThdMsg::fn, malloc(), CmiNotifyCommThdMsg::numParams, CmiNotifyCommThdMsg::params, PCQueuePop(), and CmiNotifyCommThdMsg::toKeep.
| EXTERN void CmiFreeNotifyCommThdMsg | ( | CmiNotifyCommThdMsg * | msg | ) |
Definition at line 64 of file machine-commthd-util.c.
References free(), and CmiNotifyCommThdMsg::params.
Referenced by commThdHandleNotification().
| EXTERN void CmiResetNotifyCommThdMsg | ( | CmiNotifyCommThdMsg * | msg, | |
| CmiCommThdFnPtr | fn, | |||
| int | numParams, | |||
| void * | params, | |||
| int | toKeep | |||
| ) |
Definition at line 71 of file machine-commthd-util.c.
References CmiNotifyCommThdMsg::fn, CmiNotifyCommThdMsg::numParams, CmiNotifyCommThdMsg::params, and CmiNotifyCommThdMsg::toKeep.
| EXTERN void CmiNotifyCommThd | ( | CmiNotifyCommThdMsg * | msg | ) |
Definition at line 265 of file converse.h.
Referenced by CkMessageWatcherInit(), and KillOnAllSigs().
Definition at line 182 of file converse.h.
Referenced by CkMessageWatcherInit(), CmiSyncBroadcastFn1(), KillOnAllSigs(), and node_addresses_store().