
|
Files | |
| file | convcore.c |
| converse main core | |
Modules | |
| Converse Machine Layer | |
| Common structures for all implementations of the machine layer The machine layer of Converse consist of few common files to all architectures, shown in this module, which are:
| |
| ConverseScheduler | |
| The portion of Converse responsible for scheduling the execution of incoming messages. | |
Data Structures | |
| struct | CLA |
| This little list of CLA's holds the argument descriptions until it's safe to print them--it's needed because the net- versions don't have printf until they're pretty well started. More... | |
| struct | GroupDef |
| struct | MultiMsg |
| struct | CmiTmpBuf_t |
| struct | CmiMultipleSendHeader |
| struct | cmi_cpu_idlerec |
Typedefs | |
| typedef unsigned long | mmulong |
Enumerations | |
| enum | { CmiReductionID_globalOffset = 0, CmiReductionID_requestOffset = 1, CmiReductionID_dynamicOffset = 2, CmiReductionID_multiplier = 3 } |
Functions | |
| CpvExtern (int, _traceCoreOn) | |
| void | CcdModuleInit (char **) |
| void | CmiMemoryInit (char **) |
| void | CldModuleInit (char **) |
| CpvDeclare (int, _curRestartPhase) | |
| CpvDeclare (int, charmLibExitFlag) | |
| CpvStaticDeclare (int, CmiMainHandlerIDP) | |
| CpvDeclare (char *, _validProcessors) | |
| CpvDeclare (mmulong, MemoryUsage) | |
| CpvDeclare (mmulong, HiWaterMark) | |
| CpvDeclare (mmulong, ReportedHiWaterMark) | |
| CpvDeclare (int, AllocCount) | |
| CpvDeclare (int, BlocksAllocated) | |
| CpvDeclare (int, expIOFlushFlag) | |
| CpvDeclare (char *, explicitIOBuffer) | |
| CpvDeclare (int, expIOBufferSize) | |
| void * | CmiGetNonLocalNodeQ () |
| CpvDeclare (void *, CsdSchedQueue) | |
| CpvDeclare (void *, CsdPrefetchQueue) | |
| CsvDeclare (void *, CsdNodeQueue) | |
| CsvDeclare (CmiNodeLock, CsdNodeQueueLock) | |
| CpvDeclare (int, CsdStopFlag) | |
| CpvDeclare (int, CsdLocalCounter) | |
| CpvDeclare (int, _urgentSend) | |
| void * | CMI_VMI_CmiAlloc (int size) |
| void | CMI_VMI_CmiFree (void *ptr) |
| void * | elan_CmiAlloc (int size) |
| void * | infi_CmiAlloc (int size) |
| void | infi_CmiFree (void *ptr) |
| void | infi_freeMultipleSend (void *ptr) |
| void | infi_unregAndFreeMeta (void *ch) |
| CpvDeclare (void *, CkGridObject) | |
| CpvDeclare (void *, CsdGridQueue) | |
| void * | LrtsAlloc (int, int) |
| void | LrtsFree (void *) |
| CpvStaticDeclare (int, cmiMyPeIdle) | |
| int | CmiIsMyNodeIdle () |
| static void | CmiAddCLA (const char *arg, const char *param, const char *desc) |
| Add this CLA. | |
| static void | CmiPrintCLAs (void) |
| Print out the stored list of CLA's. | |
| void | CmiArgInit (char **argv) |
| Determines if command-line usage information should be printed-- that is, if a "-?", "-h", or "--help" flag is present. | |
| int | CmiArgGivingUsage (void) |
| Return 1 if we're currently printing command-line usage information. | |
| void | CmiArgGroup (const char *parentName, const char *groupName) |
| Identifies the module that accepts the following command-line parameters. | |
| 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. | |
| void | CmiDeleteArgs (char **argv, int k) |
| Delete the first k argument from the given list, shifting all other arguments down by k spaces. | |
| int | CmiGetArgStringDesc (char **argv, const char *arg, char **optDest, const char *desc) |
| Find the given argment and string option in argv. | |
| int | CmiGetArgString (char **argv, const char *arg, char **optDest) |
| int | CmiGetArgDoubleDesc (char **argv, const char *arg, double *optDest, const char *desc) |
| Find the given argument and floating-point option in argv. | |
| int | CmiGetArgDouble (char **argv, const char *arg, double *optDest) |
| int | CmiGetArgIntDesc (char **argv, const char *arg, int *optDest, const char *desc) |
| Find the given argument and integer option in argv. | |
| int | CmiGetArgInt (char **argv, const char *arg, int *optDest) |
| int | CmiGetArgLongDesc (char **argv, const char *arg, CmiInt8 *optDest, const char *desc) |
| int | CmiGetArgLong (char **argv, const char *arg, CmiInt8 *optDest) |
| int | CmiGetArgFlagDesc (char **argv, const char *arg, const char *desc) |
| Find the given argument in argv. | |
| int | CmiGetArgFlag (char **argv, const char *arg) |
| static char * | _implTrimParenthesis (char *str, int trimname) |
| static const char * | _implGetBacktraceSys (const char *name) |
| void | CmiBacktracePrint (void **retPtrs, int nLevels) |
| Print out the names of these function pointers. | |
| void | CmiPrintStackTrace (int nSkip) |
| int | CmiIsFortranLibraryCall () |
| CpvDeclare (int, CstatsMaxChareQueueLength) | |
| CpvDeclare (int, CstatsMaxForChareQueueLength) | |
| CpvDeclare (int, CstatsMaxFixedChareQueueLength) | |
| CpvStaticDeclare (int, CstatPrintQueueStatsFlag) | |
| CpvStaticDeclare (int, CstatPrintMemStatsFlag) | |
| void | CstatsInit (char **argv) |
| int | CstatMemory (int i) |
| int | CstatPrintQueueStats () |
| int | CstatPrintMemStats () |
| CpvDeclare (CmiHandlerInfo *, CmiHandlerTable) | |
| CpvStaticDeclare (int, CmiHandlerCount) | |
| CpvStaticDeclare (int, CmiHandlerLocal) | |
| CpvStaticDeclare (int, CmiHandlerGlobal) | |
| CpvDeclare (int, CmiHandlerMax) | |
| static void | CmiExtendHandlerTable (int atLeastLen) |
| void | CmiNumberHandler (int n, CmiHandler h) |
| void | CmiNumberHandlerEx (int n, CmiHandlerEx h, void *userPtr) |
| int | CmiRegisterHandler (CmiHandler h) |
| int | CmiRegisterHandlerEx (CmiHandlerEx h, void *userPtr) |
| int | CmiRegisterHandlerLocal (CmiHandler h) |
| int | CmiRegisterHandlerGlobal (CmiHandler h) |
| static void | _cmiZeroHandler (void *msg) |
| static void | CmiHandlerInit () |
| char * | CmiPrintDate () |
| CpvStaticDeclare (double, clocktick) | |
| CpvStaticDeclare (int, inittime_wallclock) | |
| CpvStaticDeclare (int, inittime_virtual) | |
| int | CmiTimerIsSynchronized () |
| int | CmiTimerAbsolute () |
| double | CmiStartTimer () |
| double | CmiInitTime () |
| void | CmiTimerInit (char **argv) |
| double | CmiWallTimer () |
| double | CmiCpuTimer () |
| double | CmiTimer () |
| CpvStaticDeclare (double, inittime_virtual) | |
| static double | readMHz (void) |
| CpvStaticDeclare (double, inittime_walltime) | |
| static unsigned long long | BGLTimebase (void) |
| CpvStaticDeclare (unsigned long, inittime) | |
| CpvStaticDeclare (double, inittime_wallclock) | |
| CpvStaticDeclare (long long, inittime_wallclock) | |
| int | CmiLongSendQueue (int forNode, int longerThanBytes) |
| Return 1 if our outgoing message queue for this node is longer than this many bytes. | |
| void | CmiSignal (int sig1, int sig2, int sig3, void(*handler)()) |
| void | CmiSyncVectorSend (int destPE, int n, int *sizes, char **msgs) |
| CmiCommHandle | CmiASyncVectorSend (int destPE, int n, int *sizes, char **msgs) |
| void | CmiSyncVectorSendAndFree (int destPE, int n, int *sizes, char **msgs) |
| CpvStaticDeclare (int, CmiReductionMessageHandler) | |
| CpvStaticDeclare (int, CmiReductionDynamicRequestHandler) | |
| CpvStaticDeclare (CmiReduction **, _reduce_info) | |
| CpvStaticDeclare (int, _reduce_info_size) | |
| CpvStaticDeclare (CmiUInt2, _reduce_seqID_global) | |
| CpvStaticDeclare (CmiUInt2, _reduce_seqID_request) | |
| CpvStaticDeclare (CmiUInt2, _reduce_seqID_dynamic) | |
| CmiReduction * | CmiGetReductionCreate (int id, short int numChildren) |
| CmiReduction * | CmiGetReduction (int id) |
| void | CmiClearReduction (int id) |
| CmiReduction * | CmiGetNextReduction (short int numChildren) |
| CmiReductionID | CmiGetGlobalReduction () |
| CmiReductionID | CmiGetDynamicReduction () |
| void | CmiReductionHandleDynamicRequest (char *msg) |
| void | CmiGetDynamicReductionRemote (int handlerIdx, int pe, int dataSize, void *data) |
| void | CmiSendReduce (CmiReduction *red) |
| void * | CmiReduceMergeFn_random (int *size, void *data, void **remote, int n) |
| static void | CmiGlobalReduce (void *msg, int size, CmiReduceMergeFn mergeFn, CmiReduction *red) |
| static void | CmiGlobalReduceStruct (void *data, CmiReducePupFn pupFn, CmiReduceMergeFn mergeFn, CmiHandler dest, CmiReduceDeleteFn deleteFn, CmiReduction *red) |
| 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 *data, int size, CmiReduceMergeFn mergeFn, int redID, int numChildren, int parent) |
| void | CmiNodeReduce (void *data, int size, void *(*mergeFn)(void *, void **, int), int redID) |
| void | CmiNodeReduce (void *data, int size, void *(*mergeFn)(void *, void **, int), int numChildren, int parent) |
| void | CmiNodeReduce (void *data, int size, void *(*mergeFn)(void *, void **, int)) |
| void | CmiNodeReduceStruct (void *data, CmiReducePupFn pupFn, CmiReduceMergeFn mergeFn, CmiHandler dest, CmiReduceDeleteFn deleteFn) |
| void | CmiHandleReductionMessage (void *msg) |
| void | CmiReductionsInit () |
| CpvStaticDeclare (int, CmiGroupHandlerIndex) | |
| CpvStaticDeclare (int, CmiGroupCounter) | |
| CpvStaticDeclare (GroupDef *, CmiGroupTable) | |
| void | CmiGroupHandler (GroupDef def) |
| CmiGroup | CmiEstablishGroup (int npes, int *pes) |
| void | CmiLookupGroup (CmiGroup grp, int *npes, int **pes) |
| void | CmiGroupInit () |
| void | CmiSyncListSendFn (int npes, int *pes, int len, char *msg) |
| CmiCommHandle | CmiAsyncListSendFn (int npes, int *pes, int len, char *msg) |
| void | CmiFreeListSendFn (int npes, int *pes, int len, char *msg) |
| CpvDeclare (int, CmiMulticastHandlerIndex) | |
| void | CmiMulticastDeliver (MultiMsg msg) |
| void | CmiMulticastHandler (MultiMsg msg) |
| void | CmiSyncMulticastFn (CmiGroup grp, int len, char *msg) |
| void | CmiFreeMulticastFn (CmiGroup grp, int len, char *msg) |
| CmiCommHandle | CmiAsyncMulticastFn (CmiGroup grp, int len, char *msg) |
| void | CmiMulticastInit () |
| void * | arena_malloc (int size) |
| void | arena_free (void *blockPtr) |
| void * | CmiAlloc (int size) |
| Allocate `size` bytes of memory usable as a message buffer. | |
| static void * | CmiAllocFindEnclosing (void *blk) |
| Follow the header links out to the most enclosing block. | |
| int | CmiGetReference (void *blk) |
| void | CmiReference (void *blk) |
| Increment the reference count for this block's owner. | |
| 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. | |
| CpvDeclare (CmiTmpBuf_t, CmiTmpBuf) | |
| static void | CmiTmpSetup (CmiTmpBuf_t *b) |
| void * | CmiTmpAlloc (int size) |
| void | CmiTmpFree (void *t) |
| void | CmiTmpInit (char **argv) |
| void | CmiMkdir (const char *dirName) |
| static int | roundUpSize (unsigned int s) |
| static int | paddingSize (unsigned int s) |
| static void | _CmiMultipleSend (unsigned int destPE, int len, int sizes[], char *msgComps[], int immed) |
| void | CmiMultipleSend (unsigned int destPE, int len, int sizes[], char *msgComps[]) |
| void | CmiMultipleIsend (unsigned int destPE, int len, int sizes[], char *msgComps[]) |
| static void | CmiMultiMsgHandler (char *msgWhole) |
| void | CmiInitMultipleSend (void) |
| int | HypercubeGetBcastDestinations (int mype, int total_pes, int k, int *dest_pes) |
| CpvDeclare (int, CmiImmediateMsgHandlerIdx) | |
| static void | CmiImmediateMsgHandler (char *msg) |
| void | CmiInitImmediateMsg (void) |
| static void | on_timeout (cmi_cpu_idlerec *rec, double curWallTime) |
| static void | on_idle (cmi_cpu_idlerec *rec, double curWallTime) |
| static void | on_busy (cmi_cpu_idlerec *rec, double curWallTime) |
| static void | CIdleTimeoutInit (char **argv) |
| void | CrnInit (void) |
| void | CmiIsomallocInit (char **argv) |
| void | CmiIOInit (char **argv) |
| void | CmiInitCPUAffinityUtil () |
| static void | CmiProcessPriority (char **argv) |
| void | CommunicationServerInit () |
| static int | testEndian (void) |
| int | CmiEndianness () |
| void | ConverseCommonInit (char **argv) |
| Main Converse initialization routine. | |
| void | ConverseCommonExit (void) |
| void | register_accel_spe_funcs (void) |
| void | CmiInitCell () |
| void | CmiPrintf (const char *format,...) |
| void | CmiError (const char *format,...) |
| void | __cmi_assert (const char *expr, const char *file, int line) |
| char * | CmiCopyMsg (char *msg, int len) |
| unsigned char | computeCheckSum (unsigned char *data, int len) |
| unsigned int | CmiILog2 (unsigned int val) |
| double | CmiLog2 (double x) |
| int | CmiMyRank_ () |
| double | CmiReadSize (const char *str) |
Variables | |
| const char *const | CmiCommitID |
| CmiSwitchToPEFnPtr | CmiSwitchToPE |
| static int | CsdLocalMax = CSD_LOCAL_MAX_DEFAULT |
| int | CharmLibInterOperate = 0 |
| void(* | notify_crash_fn )(int) = NULL |
| pthread_mutex_t | prefetchLock |
| CmiNodeLock | _smp_mutex |
| static int | usageChecked = 0 |
| static int | printUsage = 0 |
| static const char * | CLAformatString = "%20s %10s %s\n" |
| static int | CLAlistLen = 0 |
| static int | CLAlistMax = 0 |
| static CLA * | CLAlist = NULL |
| static int | _absoluteTime = 0 |
| static double | inittime_wallclock = 0 |
| static double | lastT = -1.0 |
| double | _cpu_speed_factor |
| static double | clocktick |
| int | _immediateLock = 0 |
| int | _immediateFlag = 0 |
| int | _BgOutOfCoreFlag = 0 |
| int | _BgInOutOfCoreMode = 0 |
Converse is the lowest level inside the Charm++ hierarchy. It stands on top of the machine layer, and it provides all the common functionality across platforms.
One converse program is running on every processor (or node in the smp version). it manages the message transmission, and the memory allocation. Charm++, which is on top of Converse, uses its functionality for interprocess *communication.
In order to maintain multiple independent objects inside a single user space program, it uses a personalized version of threads, which can be executed, suspended, and migrated across processors.
It provides a scheduler for message delivery: methods can be registered to the scheduler, and then messages allocated through CmiAlloc can be sent to the correspondent method in a remote processor. This is done through the converse header (which has few common fields, but is architecture dependent).
| typedef unsigned long mmulong |
Definition at line 156 of file convcore.c.
| anonymous enum |
| CmiReductionID_globalOffset | |
| CmiReductionID_requestOffset | |
| CmiReductionID_dynamicOffset | |
| CmiReductionID_multiplier |
Definition at line 2237 of file convcore.c.
| CpvExtern | ( | int | , | |
| _traceCoreOn | ||||
| ) |
| void CcdModuleInit | ( | char ** | ) |
| void CmiMemoryInit | ( | char ** | argv | ) |
Definition at line 578 of file memory.c.
References CmiArgGroup(), CmiOutOfMemoryInit(), and meta_init().
Referenced by ConverseCommonInit().
| void CldModuleInit | ( | char ** | ) |
Definition at line 237 of file cldb.bluegene.c.
References peinfo::AverageHandler, CldAskLoadHandler(), CldAverageHandler(), CldBalanceHandler(), CldEnqueueHandler(), CldGraphModuleInit(), CldHandler(), CldHopHandler(), CldInitiateReduction(), CldModuleGeneralInit(), CldNodeHandler(), CldOtherInit(), CldReadytoExec(), CldReduceHandler(), CldStoreCharemsg(), CmiMyPe(), CmiNumSpanTreeChildren(), CmiRegisterHandler(), CmiSpanTreeParent(), CqsCreate(), CrnSrand(), peinfo::EnqueueHandler, HigherPriorityWork(), peinfo::HopHandler, peinfo::load_count, peinfo::load_total, msgpool, peinfo::mype, peinfo::rebalance, peinfo::ReduceHandler, peinfo::spantree_children, peinfo::spantree_parent, peinfo::spantree_root, and stats::time().
Referenced by ConverseCommonInit().
| CpvDeclare | ( | int | , | |
| _curRestartPhase | ||||
| ) |
| CpvDeclare | ( | int | , | |
| charmLibExitFlag | ||||
| ) |
| CpvStaticDeclare | ( | int | , | |
| CmiMainHandlerIDP | ||||
| ) |
| CpvDeclare | ( | char * | , | |
| _validProcessors | ||||
| ) |
| CpvDeclare | ( | mmulong | , | |
| MemoryUsage | ||||
| ) |
| CpvDeclare | ( | mmulong | , | |
| HiWaterMark | ||||
| ) |
| CpvDeclare | ( | mmulong | , | |
| ReportedHiWaterMark | ||||
| ) |
| CpvDeclare | ( | int | , | |
| AllocCount | ||||
| ) |
| CpvDeclare | ( | int | , | |
| BlocksAllocated | ||||
| ) |
| CpvDeclare | ( | int | , | |
| expIOFlushFlag | ||||
| ) |
| CpvDeclare | ( | char * | , | |
| explicitIOBuffer | ||||
| ) |
| CpvDeclare | ( | int | , | |
| expIOBufferSize | ||||
| ) |
| void * CmiGetNonLocalNodeQ | ( | void | ) |
Definition at line 984 of file machine-common-core.c.
References CmiGetState(), CmiLock(), CmiMyPe(), CmiUnlock(), CmiStateStruct::idle, PCQueueEmpty(), and PCQueuePop().
Referenced by CsdNextMessage(), and KillOnAllSigs().
| CpvDeclare | ( | void * | , | |
| CsdSchedQueue | ||||
| ) |
| CpvDeclare | ( | void * | , | |
| CsdPrefetchQueue | ||||
| ) |
| CsvDeclare | ( | void * | , | |
| CsdNodeQueue | ||||
| ) |
Referenced by KillOnAllSigs().
| CsvDeclare | ( | CmiNodeLock | , | |
| CsdNodeQueueLock | ||||
| ) |
| CpvDeclare | ( | int | , | |
| CsdStopFlag | ||||
| ) |
| CpvDeclare | ( | int | , | |
| CsdLocalCounter | ||||
| ) |
| CpvDeclare | ( | int | , | |
| _urgentSend | ||||
| ) |
| void* CMI_VMI_CmiAlloc | ( | int | size | ) |
| void CMI_VMI_CmiFree | ( | void * | ptr | ) |
| void* elan_CmiAlloc | ( | int | size | ) |
Referenced by CmiAlloc().
| void * infi_CmiAlloc | ( | int | size | ) |
Definition at line 2502 of file machine-ibverbs.c.
References CmiMemLock(), CmiMemUnlock(), getInfiCmiChunk(), getInfiCmiChunkThread(), and malloc().
Referenced by CmiAlloc().
| void infi_CmiFree | ( | void * | ptr | ) |
this is a part of a received mult message it will be freed correctly later
Definition at line 2600 of file machine-ibverbs.c.
References CmiMemLock(), CmiMemUnlock(), CmiMyRank(), infiCmiChunkPool::count, free(), infi_CmiFreeDirect(), size, and infiCmiChunkPool::startBuf.
Referenced by CmiFree().
| void infi_freeMultipleSend | ( | void * | ptr | ) |
Definition at line 3095 of file convcore.c.
References infiCmiChunkHeaderStruct::chunkHeader, infi_unregAndFreeMeta(), infiCmiChunkHeaderStruct::metaData, msg, pad, and CmiChunkHeader::size.
Referenced by CmiFree().
| void infi_unregAndFreeMeta | ( | void * | ch | ) |
Definition at line 401 of file machine-ibverbs.c.
References free().
Referenced by infi_freeMultipleSend().
| CpvDeclare | ( | void * | , | |
| CkGridObject | ||||
| ) |
| CpvDeclare | ( | void * | , | |
| CsdGridQueue | ||||
| ) |
Referenced by CmiAlloc().
| void LrtsFree | ( | void * | ) |
Referenced by CmiFree().
| CpvStaticDeclare | ( | int | , | |
| cmiMyPeIdle | ||||
| ) |
| int CmiIsMyNodeIdle | ( | ) |
Definition at line 3818 of file convcore.c.
| static void CmiAddCLA | ( | const char * | arg, | |
| const char * | param, | |||
| const char * | desc | |||
| ) | [static] |
Add this CLA.
Definition at line 253 of file convcore.c.
References CLA::arg, CLAformatString, CmiMyPe(), CmiPrintf(), CLA::desc, CLA::param, and realloc().
Referenced by CmiGetArgDoubleDesc(), CmiGetArgFlagDesc(), CmiGetArgIntDesc(), CmiGetArgLongDesc(), and CmiGetArgStringDesc().
| static void CmiPrintCLAs | ( | void | ) | [static] |
Print out the stored list of CLA's.
Definition at line 276 of file convcore.c.
References CLA::arg, c, CLAformatString, CmiMyPe(), CmiPrintf(), CLA::desc, and CLA::param.
Referenced by CmiArgInit().
| void CmiArgInit | ( | char ** | argv | ) |
Determines if command-line usage information should be printed-- that is, if a "-?", "-h", or "--help" flag is present.
Must be called after printf is setup.
Definition at line 292 of file convcore.c.
References CmiMyPe(), CmiPrintCLAs(), and free().
Referenced by ConverseCommonInit().
| int CmiArgGivingUsage | ( | void | ) |
Return 1 if we're currently printing command-line usage information.
Definition at line 314 of file convcore.c.
References CmiMyPe().
Referenced by CmiArgGroup(), cpd_memory_single_pup(), and status().
| void CmiArgGroup | ( | const char * | parentName, | |
| const char * | groupName | |||
| ) |
Identifies the module that accepts the following command-line parameters.
Definition at line 319 of file convcore.c.
References CmiArgGivingUsage(), and CmiPrintf().
Referenced by _initCharm(), _loadbalancerInit(), CkMessageWatcherInit(), CmiMemoryInit(), meta_init(), POSEreadCmdLine(), and traceCommonInit().
| int CmiGetArgc | ( | char ** | argv | ) |
Count the number of non-NULL arguments in list.
Definition at line 327 of file convcore.c.
Referenced by _initCharm(), AMPI_Init(), CkGetArgc(), CmiCopyArgs(), ConverseInit(), ConverseRunPE(), and KillOnAllSigs().
| char** CmiCopyArgs | ( | char ** | argv | ) |
Return a new, heap-allocated copy of the argv array.
Definition at line 337 of file convcore.c.
References CmiGetArgc(), and malloc().
Referenced by ConverseInit(), ConverseRunPE(), KillOnAllSigs(), and PUPfunctionpointer().
| void CmiDeleteArgs | ( | char ** | argv, | |
| int | k | |||
| ) |
Delete the first k argument from the given list, shifting all other arguments down by k spaces.
e.g., argv=={"a","b","c","d",NULL}, k==3 modifies argv={"d",NULL,"c","d",NULL}
Definition at line 352 of file convcore.c.
Referenced by CmiGetArgFlagDesc(), CmiGetArgIntDesc(), CmiGetArgLongDesc(), and CmiGetArgStringDesc().
| int CmiGetArgStringDesc | ( | char ** | argv, | |
| const char * | arg, | |||
| char ** | optDest, | |||
| const char * | desc | |||
| ) |
Find the given argment and string option in argv.
If the argument is present, set the string option and delete both from argv. If not present, return NULL. e.g., arg=="-name" returns "bob" from argv=={"a.out","foo","-name","bob","bar"}, and sets argv={"a.out","foo","bar"};
Definition at line 366 of file convcore.c.
References CmiAbort(), CmiAddCLA(), and CmiDeleteArgs().
Referenced by _initCharm(), _loadbalancerInit(), _parseCommandLineOpts(), ampiProcInit(), CcsInit(), CkMessageWatcherInit(), CldGraphModuleInit(), CmiGetArgDoubleDesc(), CmiGetArgString(), CmiInitCPUAffinity(), CmiInitMemAffinity(), controlPointMain::controlPointMain(), LV3D0_ProcInit(), TCharm::procInit(), traceCommonInit(), and TraceCounter::traceInit().
| int CmiGetArgString | ( | char ** | argv, | |
| const char * | arg, | |||
| char ** | optDest | |||
| ) |
Definition at line 380 of file convcore.c.
References CmiGetArgStringDesc().
Referenced by _parseCommandLineOpts(), ampiProcInit(), ComlibManagerMain::ComlibManagerMain(), ConfigurableRRMapLoader::haveConfiguration(), TCharm::procInit(), and TraceCounter::traceInit().
Find the given argument and floating-point option in argv.
Remove it and return 1; or return 0.
Definition at line 387 of file convcore.c.
References CmiAddCLA(), and CmiGetArgStringDesc().
Referenced by _loadbalancerInit(), CmiGetArgDouble(), controlPointMain::controlPointMain(), TraceProjectionsInit::TraceProjectionsInit(), TraceSimple::TraceSimple(), TraceSummary::TraceSummary(), and TraceTau::TraceTau().
Find the given argument and integer option in argv.
If the argument is present, parse and set the numeric option, delete both from argv, and return 1. If not present, return 0. e.g., arg=="-pack" matches argv=={...,"-pack","27",...}, argv=={...,"-pack0xf8",...}, and argv=={...,"-pack=0777",...}; but not argv=={...,"-packsize",...}.
Definition at line 405 of file convcore.c.
Referenced by _loadbalancerInit(), _parseCommandLineOpts(), ampiProcInit(), calculateNodeSizeAndRank(), CcsInit(), CIdleTimeoutInit(), CkMessageWatcherInit(), CldGraphModuleInit(), CmiGetArgInt(), CmiInitCPUAffinity(), CmiIOInit(), CmiProcessPriority(), CmiSendMessagePxshm(), CmiSendMessageXpmem(), CsdInit(), CthBaseInit(), extract_args(), initQd(), KillOnAllSigs(), meta_init(), POSEreadCmdLine(), TCharm::procInit(), TCHARM_Get_num_chunks(), TraceMemory::TraceMemory(), TraceProjectionsInit::TraceProjectionsInit(), TraceSimple::TraceSimple(), TraceSummary::TraceSummary(), and TraceTau::TraceTau().
Definition at line 440 of file convcore.c.
References CmiGetArgIntDesc().
Referenced by ComlibManagerMain::ComlibManagerMain(), ConverseInit(), KillOnAllSigs(), and SendMsgBuf().
Definition at line 444 of file convcore.c.
References CmiAbort(), CmiAddCLA(), and CmiDeleteArgs().
Referenced by CmiGetArgLong(), and TraceProjections::TraceProjections().
| int CmiGetArgFlagDesc | ( | char ** | argv, | |
| const char * | arg, | |||
| const char * | desc | |||
| ) |
Find the given argument in argv.
If present, delete it and return 1; if not present, return 0. e.g., arg=="-foo" matches argv=={...,"-foo",...} but not argv={...,"-foobar",...}.
Definition at line 488 of file convcore.c.
References CmiAddCLA(), and CmiDeleteArgs().
Referenced by _loadbalancerInit(), _parseCommandLineOpts(), ampiProcInit(), CcsInit(), CkMessageWatcherInit(), CldGraphModuleInit(), CldModuleGeneralInit(), CmiGetArgFlag(), CmiInitCPUAffinity(), CmiInitMemAffinity(), CmiIOInit(), CmiIsomallocInit(), controlPointMain::controlPointMain(), ConverseCommonInit(), cpd_memory_single_pup(), CstatsInit(), extract_args(), FEM_Init(), FTN_NAME(), CkMemCheckPT::isMaster(), KillOnAllSigs(), LrtsInitCpuTopo(), meta_init(), POSEreadCmdLine(), TCharm::procInit(), SendMsgBuf(), traceCommonInit(), TraceCounter::traceInit(), TraceMemory::TraceMemory(), TraceProjections::TraceProjections(), TraceProjectionsInit::TraceProjectionsInit(), and TraceSummary::TraceSummary().
| int CmiGetArgFlag | ( | char ** | argv, | |
| const char * | arg | |||
| ) |
Definition at line 500 of file convcore.c.
References CmiGetArgFlagDesc().
Referenced by _parseCommandLineOpts(), ampiProcInit(), ConverseInit(), SendMsgBuf(), traceCommonInit(), TraceCore::TraceCore(), and TraceCounter::traceInit().
| static char* _implTrimParenthesis | ( | char * | str, | |
| int | trimname | |||
| ) | [static] |
Definition at line 517 of file convcore.c.
Referenced by CmiBacktracePrint(), and CmiIsFortranLibraryCall().
| static const char* _implGetBacktraceSys | ( | const char * | name | ) | [static] |
| void CmiBacktracePrint | ( | void ** | retPtrs, | |
| int | nLevels | |||
| ) |
Print out the names of these function pointers.
Definition at line 553 of file convcore.c.
References _implGetBacktraceSys(), _implTrimParenthesis(), CmiBacktraceLookup(), CmiMyPe(), CmiPrintf(), free(), and print().
Referenced by CmiPrintStackTrace(), printSlot(), and slotAbort().
| void CmiPrintStackTrace | ( | int | nSkip | ) |
Definition at line 580 of file convcore.c.
References CmiBacktracePrint(), and CmiBacktraceRecord().
Referenced by KillOnAllSigs(), meta_free(), meta_malloc(), SendMsgBuf(), and TCHARM_Api_trace().
| int CmiIsFortranLibraryCall | ( | ) |
Definition at line 589 of file convcore.c.
References _implTrimParenthesis(), CmiBacktraceLookup(), CmiBacktraceRecord(), and free().
Referenced by meta_malloc(), and meta_memalign().
| CpvDeclare | ( | int | , | |
| CstatsMaxChareQueueLength | ||||
| ) |
| CpvDeclare | ( | int | , | |
| CstatsMaxForChareQueueLength | ||||
| ) |
| CpvDeclare | ( | int | , | |
| CstatsMaxFixedChareQueueLength | ||||
| ) |
| CpvStaticDeclare | ( | int | , | |
| CstatPrintQueueStatsFlag | ||||
| ) |
| CpvStaticDeclare | ( | int | , | |
| CstatPrintMemStatsFlag | ||||
| ) |
| void CstatsInit | ( | char ** | argv | ) |
Definition at line 630 of file convcore.c.
References CmiGetArgFlagDesc().
Referenced by ConverseCommonInit().
Definition at line 667 of file convcore.c.
| int CstatPrintQueueStats | ( | ) |
Definition at line 673 of file convcore.c.
| int CstatPrintMemStats | ( | ) |
Definition at line 678 of file convcore.c.
| CpvDeclare | ( | CmiHandlerInfo * | , | |
| CmiHandlerTable | ||||
| ) |
| CpvStaticDeclare | ( | int | , | |
| CmiHandlerCount | ||||
| ) |
| CpvStaticDeclare | ( | int | , | |
| CmiHandlerLocal | ||||
| ) |
| CpvStaticDeclare | ( | int | , | |
| CmiHandlerGlobal | ||||
| ) |
| CpvDeclare | ( | int | , | |
| CmiHandlerMax | ||||
| ) |
| static void CmiExtendHandlerTable | ( | int | atLeastLen | ) | [static] |
Definition at line 695 of file convcore.c.
References bytes, free(), malloc(), and max().
Referenced by CmiNumberHandler(), and CmiNumberHandlerEx().
| void CmiNumberHandler | ( | int | n, | |
| CmiHandler | h | |||
| ) |
Definition at line 710 of file convcore.c.
References CmiExtendHandlerTable(), CmiHandlerInfo::hdlr, and CmiHandlerInfo::userPtr.
Referenced by CkMessageWatcherInit(), CmiRegisterHandler(), CmiRegisterHandlerGlobal(), and CmiRegisterHandlerLocal().
| void CmiNumberHandlerEx | ( | int | n, | |
| CmiHandlerEx | h, | |||
| void * | userPtr | |||
| ) |
Definition at line 718 of file convcore.c.
References CmiExtendHandlerTable(), CmiHandlerInfo::hdlr, and CmiHandlerInfo::userPtr.
Referenced by CmiRegisterHandlerEx().
| int CmiRegisterHandler | ( | CmiHandler | h | ) |
Definition at line 732 of file convcore.c.
References CmiNumberHandler().
Referenced by CcsInit(), CfutureModuleInit(), CldGraphModuleInit(), CldModuleGeneralInit(), CldModuleInit(), CldRegisterInfoFn(), CldRegisterPackFn(), CmiGroupInit(), CmiHandlerInit(), CmiInitCPUAffinity(), CmiInitImmediateMsg(), CmiInitMultipleSend(), CmiInitNotifyCommThdScheme(), CmiMulticastInit(), CmiPersistentInit(), CmiReductionsInit(), CPathModuleInit(), CpdInit(), CpmModuleInit(), CQdInit(), CthSchedInit(), CWebInit(), init_comm(), initConvComlibManager(), initQd(), KillOnAllSigs(), LrtsInitCpuTopo(), RegisterNodeHelperHdlrs(), SendMsgBuf(), and StatTable::StatTable().
| int CmiRegisterHandlerEx | ( | CmiHandlerEx | h, | |
| void * | userPtr | |||
| ) |
| int CmiRegisterHandlerLocal | ( | CmiHandler | h | ) |
| int CmiRegisterHandlerGlobal | ( | CmiHandler | h | ) |
Definition at line 757 of file convcore.c.
References CmiError(), CmiMyPe(), and CmiNumberHandler().
| static void _cmiZeroHandler | ( | void * | msg | ) | [static] |
| static void CmiHandlerInit | ( | ) | [static] |
Definition at line 773 of file convcore.c.
References _cmiZeroHandler(), and CmiRegisterHandler().
Referenced by ConverseCommonInit().
| char * CmiPrintDate | ( | ) |
| CpvStaticDeclare | ( | int | , | |
| inittime_wallclock | ||||
| ) |
| CpvStaticDeclare | ( | int | , | |
| inittime_virtual | ||||
| ) |
| int CmiTimerIsSynchronized | ( | ) |
| int CmiTimerAbsolute | ( | ) |
Definition at line 832 of file convcore.c.
Referenced by SendMsgBuf(), TraceProjectionsInit::TraceProjectionsInit(), and TraceSummary::TraceSummary().
| double CmiStartTimer | ( | ) |
| double CmiInitTime | ( | ) |
Definition at line 842 of file convcore.c.
References inittime_wallclock.
Referenced by SendMsgBuf(), and TraceSummary::TraceSummary().
| void CmiTimerInit | ( | char ** | argv | ) |
Definition at line 847 of file convcore.c.
References clocktick, and inittime_wallclock.
Referenced by ConverseCommonInit(), and SendMsgBuf().
| double CmiWallTimer | ( | void | ) |
Definition at line 858 of file convcore.c.
Referenced by _bufferedTicketHandler(), _checkpointRequestHandler(), _ckAckEvac(), _ckEvacBcast(), _getTicket(), _handlePhase2(), _initCharm(), _initHandler(), _localMessageCopyHandler(), _messageLoggingInit(), _processTicketRequest(), _receiveLocationHandler(), _receiveMigrationNoticeAckHandler(), _recvCheckpointHandler(), _recvRestartCheckpointHandler(), _resendMessagesHandler(), _restartHandler(), _sendDetsHandler(), _sendDetsReplyHandler(), _ticketHandler(), _updateHomeAckHandler(), CkElementEvacuate::addLocation(), CkReductionMgr::ArrayReductionHandler(), PVT::beginCheckpoint(), TraceControlPoints::beginExecute(), TraceControlPoints::beginIdle(), TraceSummary::beginPack(), TraceSummary::beginUnpack(), sim::Cancel(), opt::CancelSpawn(), CcdCallBacks(), CcdCallFnAfterOnPE(), CcdModuleInit(), CcdRaiseCondition(), CcsRecvResponse(), CcsSendRequestGeneric(), CkCheckpointMgr::Checkpoint(), sim::CheckpointCommit(), CkClearAllArrayElements(), CkDecideEvacPe(), CkEvacuatedElement(), CkMlogRestart(), CldAckNoTaskHandler(), CldAskLoadHandler(), CldBalance(), CldBeginIdle(), CldLoadResponseHandler(), CldStillIdle(), CmiReleaseSentMessages(), CmiSendMessagePxshm(), CmiSendMessageSysvshm(), CmiSendMessageXpmem(), sim::Commit(), CommunicationServerSysvshm(), CkNodeReductionMgr::contributeWithCounter(), controlPointMain::controlPointMain(), controlPointTimingStamp(), CkMemCheckPT::cpFinish(), PathHistory::createPath(), criticalPath_send(), criticalPath_split(), criticalPath_start(), CkMemCheckPT::doItNow(), CkThresholdTimer::done_(), CkReductionMgr::endArrayReduction(), TraceControlPoints::endExecute(), TraceControlPoints::endIdle(), TraceSummary::endPack(), endTraceBigSim_20param(), TraceSummary::endUnpack(), PythonObject::execute(), PythonObject::executeThread(), CkReductionMgr::finishReduction(), FTN_NAME(), controlPointManager::generatePlan(), getUsage(), TraceControlPoints::idleRatio(), informLocationHome(), LBDB::batsyncer::init(), initUsage(), CkMemCheckPT::isMaster(), killLocal(), KillOnAllSigs(), TraceProjectionsBOC::kMeansDone(), OneTimeMulticastStrategy::localMulticast(), ChunkMulticastStrategy::localMulticast(), LrtsInitCpuTopo(), ChareMlogData::next_ticket(), TraceControlPoints::overheadRatio(), POSE_busy_wait(), POSE_init(), POSE_startTimer(), pose::prepExit(), processAllBufferedMsgs(), controlPointManager::processControlPoints(), processReceivedTN(), CentralLB::ProcessReceiveMigration(), PumpMsgsBlocking(), PUPbytes(), readKillFile(), OneTimeMulticastStrategy::remoteMulticast(), ChunkMulticastStrategy::remoteMulticast(), TraceControlPoints::resetAll(), TraceControlPoints::resetTimings(), PVT::resumeAfterCheckpoint(), PVT::resumeAfterLB(), LBDB::batsyncer::resumeFromSync(), retryTicketRequest(), opt::Rollback(), SendMsgBuf(), CkCheckpointMgr::SendRestartCB(), sim::SeqBeginCheckpoint(), sim::SeqResumeAfterCheckpoint(), PVT::setGVT(), CkThresholdTimer::start_(), startLoadBalancingMlog(), startMlogCheckpoint(), startTraceBigSim(), StealLoad(), sim::Step(), seq::Step(), adapt5::Step(), adapt4::Step(), adapt3::Step(), localStat::SwitchTimer(), localStat::TimerStop(), topo_callback(), TraceControlPoints::traceBegin(), traceCommonInit(), TraceControlPoints::traceEnd(), TraceProjectionsBOC::traceProjectionsParallelShutdown(), TraceControlPoints::untracedTime(), CkDiskCheckPTInfo::updateBuffer(), ScotchTopoLB::work(), ScotchLB::work(), and CkMessageRecorder::~CkMessageRecorder().
| double CmiCpuTimer | ( | void | ) |
Definition at line 869 of file convcore.c.
References clocktick.
Referenced by CmiTimer(), FTN_NAME(), LDProcessorSpeed(), and SendMsgBuf().
| double CmiTimer | ( | void | ) |
Definition at line 881 of file convcore.c.
Referenced by CldAskLoadHandler(), CldEnqueue(), CldStoreCharemsg(), HigherPriorityWork(), pollSendCq(), sendCheckpointData(), SendMsgBuf(), and startMlogCheckpoint().
| CpvStaticDeclare | ( | double | , | |
| inittime_virtual | ||||
| ) |
| static double readMHz | ( | void | ) | [static] |
| CpvStaticDeclare | ( | double | , | |
| inittime_walltime | ||||
| ) |
| static unsigned long long BGLTimebase | ( | void | ) | [inline, static] |
Definition at line 1084 of file convcore.c.
| CpvStaticDeclare | ( | unsigned | long, | |
| inittime | ||||
| ) |
| CpvStaticDeclare | ( | double | , | |
| inittime_wallclock | ||||
| ) |
| CpvStaticDeclare | ( | long | long, | |
| inittime_wallclock | ||||
| ) |
Return 1 if our outgoing message queue for this node is longer than this many bytes.
Definition at line 1471 of file convcore.c.
Referenced by LV3D0_ClientManager_toMaster::progress().
Definition at line 2160 of file convcore.c.
References CmiSyncSendAndFree().
Referenced by _CmiMultipleSend(), CmiASyncVectorSend(), CmiSyncVectorSendAndFree(), HypercubeRouter::RecvManyMsg(), DimexRouter::RecvManyMsg(), and sendMsg().
| CmiCommHandle CmiASyncVectorSend | ( | int | destPE, | |
| int | n, | |||
| int * | sizes, | |||
| char ** | msgs | |||
| ) |
Definition at line 2176 of file convcore.c.
References CmiFree(), and CmiSyncVectorSend().
Referenced by GraphRouter::sendMessages().
| CpvStaticDeclare | ( | int | , | |
| CmiReductionMessageHandler | ||||
| ) |
| CpvStaticDeclare | ( | int | , | |
| CmiReductionDynamicRequestHandler | ||||
| ) |
| CpvStaticDeclare | ( | CmiReduction ** | , | |
| _reduce_info | ||||
| ) |
| CpvStaticDeclare | ( | int | , | |
| _reduce_info_size | ||||
| ) |
| CpvStaticDeclare | ( | CmiUInt2 | , | |
| _reduce_seqID_global | ||||
| ) |
| CpvStaticDeclare | ( | CmiUInt2 | , | |
| _reduce_seqID_request | ||||
| ) |
| CpvStaticDeclare | ( | CmiUInt2 | , | |
| _reduce_seqID_dynamic | ||||
| ) |
| CmiReduction* CmiGetReductionCreate | ( | int | id, | |
| short int | numChildren | |||
| ) |
Definition at line 2244 of file convcore.c.
References CmiAbort(), CmiMyPe(), CmiPrintf(), free(), CmiReduction::localContributed, malloc(), CmiReduction::numChildren, CmiReduction::numRemoteReceived, CmiReduction::remoteData, and CmiReduction::seqID.
Referenced by CmiGetNextReduction(), CmiGetReduction(), CmiHandleReductionMessage(), CmiListReduce(), CmiListReduceStruct(), CmiReduceID(), and CmiReduceStructID().
| CmiReduction* CmiGetReduction | ( | int | id | ) |
Definition at line 2272 of file convcore.c.
References CmiGetReductionCreate().
Referenced by CmiHandleReductionMessage().
| void CmiClearReduction | ( | int | id | ) |
| CmiReduction* CmiGetNextReduction | ( | short int | numChildren | ) |
Definition at line 2282 of file convcore.c.
References CmiGetReductionCreate(), CmiReductionID_globalOffset, and CmiReductionID_multiplier.
Referenced by CmiReduce(), and CmiReduceStruct().
| CmiReductionID CmiGetGlobalReduction | ( | ) |
Definition at line 2289 of file convcore.c.
References CmiReductionID_multiplier.
Referenced by CcsSetMergeFn().
| CmiReductionID CmiGetDynamicReduction | ( | ) |
Definition at line 2293 of file convcore.c.
References CmiAbort(), CmiMyPe(), and CmiReductionID_multiplier.
Referenced by CmiReductionHandleDynamicRequest().
| void CmiReductionHandleDynamicRequest | ( | char * | msg | ) |
Definition at line 2298 of file convcore.c.
References CmiGetDynamicReduction(), CmiSyncBroadcastAllAndFree(), CmiSyncSendAndFree(), size, and values.
Referenced by CmiGetDynamicReductionRemote(), and CmiReductionsInit().
Definition at line 2311 of file convcore.c.
References CmiAlloc(), CmiMyPe(), CmiReductionHandleDynamicRequest(), CmiSyncSendAndFree(), msg, size, and values.
| void CmiSendReduce | ( | CmiReduction * | red | ) |
Definition at line 2328 of file convcore.c.
References CmiAlloc(), CmiClearReduction(), CmiFree(), CmiSyncSendAndFree(), CmiReduction::deleteFn, CmiReduction::destination, CmiReduction::localContributed, CmiReduction::localData, CmiReduction::localSize, CmiReduction::mergeFn, msg, CmiReduction::numChildren, CmiReduction::numRemoteReceived, CmiReduction::ops, p, CmiReduction::parent, pup_destroy(), pup_new_sizer(), pup_new_toMem(), pup_size(), CmiReduction::pupFn, CmiReduction::remoteData, and CmiReduction::seqID.
Referenced by CmiGlobalReduce(), CmiGlobalReduceStruct(), CmiHandleReductionMessage(), CmiListReduce(), and CmiListReduceStruct().
| static void CmiGlobalReduce | ( | void * | msg, | |
| int | size, | |||
| CmiReduceMergeFn | mergeFn, | |||
| CmiReduction * | red | |||
| ) | [static] |
Definition at line 2372 of file convcore.c.
References CmiMyPe(), CmiNumSpanTreeChildren(), CmiSendReduce(), CmiSpanTreeParent(), CmiReduction::destination, CmiReduction::localContributed, CmiReduction::localData, CmiReduction::localSize, CmiReduction::mergeFn, CmiReduction::numChildren, CmiReduction::ops, CmiReduction::parent, and CmiReduction::pupFn.
Referenced by CmiReduce(), and CmiReduceID().
| static void CmiGlobalReduceStruct | ( | void * | data, | |
| CmiReducePupFn | pupFn, | |||
| CmiReduceMergeFn | mergeFn, | |||
| CmiHandler | dest, | |||
| CmiReduceDeleteFn | deleteFn, | |||
| CmiReduction * | red | |||
| ) | [static] |
Definition at line 2386 of file convcore.c.
References CmiMyPe(), CmiNumSpanTreeChildren(), CmiSendReduce(), CmiSpanTreeParent(), CmiReduction::deleteFn, CmiReduction::destination, CmiReduction::localContributed, CmiReduction::localData, CmiReduction::localSize, CmiReduction::mergeFn, CmiReduction::numChildren, CmiReduction::ops, CmiReduction::parent, and CmiReduction::pupFn.
Referenced by CmiReduceStruct(), and CmiReduceStructID().
| void CmiReduce | ( | void * | msg, | |
| int | size, | |||
| CmiReduceMergeFn | mergeFn | |||
| ) |
Definition at line 2403 of file convcore.c.
References CmiGetNextReduction(), CmiGlobalReduce(), CmiMyPe(), and CmiNumSpanTreeChildren().
Referenced by CpdSearchLeaks(), and LrtsInitCpuTopo().
| void CmiReduceStruct | ( | void * | data, | |
| CmiReducePupFn | pupFn, | |||
| CmiReduceMergeFn | mergeFn, | |||
| CmiHandler | dest, | |||
| CmiReduceDeleteFn | deleteFn | |||
| ) |
Definition at line 2408 of file convcore.c.
References CmiGetNextReduction(), CmiGlobalReduceStruct(), CmiMyPe(), and CmiNumSpanTreeChildren().
Referenced by CpdDebugCallAllocationTree(), and CpdDebugCallMemStat().
| void CmiReduceID | ( | void * | msg, | |
| int | size, | |||
| CmiReduceMergeFn | mergeFn, | |||
| CmiReductionID | id | |||
| ) |
Definition at line 2415 of file convcore.c.
References CmiGetReductionCreate(), CmiGlobalReduce(), CmiMyPe(), and CmiNumSpanTreeChildren().
| void CmiReduceStructID | ( | void * | data, | |
| CmiReducePupFn | pupFn, | |||
| CmiReduceMergeFn | mergeFn, | |||
| CmiHandler | dest, | |||
| CmiReduceDeleteFn | deleteFn, | |||
| CmiReductionID | id | |||
| ) |
Definition at line 2420 of file convcore.c.
References CmiGetReductionCreate(), CmiGlobalReduceStruct(), CmiMyPe(), and CmiNumSpanTreeChildren().
| void CmiListReduce | ( | int | npes, | |
| int * | pes, | |||
| void * | msg, | |||
| int | size, | |||
| CmiReduceMergeFn | mergeFn, | |||
| CmiReductionID | id | |||
| ) |
Definition at line 2427 of file convcore.c.
References CmiGetReductionCreate(), CmiMyPe(), CmiNumSpanTreeChildren(), CmiSendReduce(), CmiReduction::destination, CmiReduction::localContributed, CmiReduction::localData, CmiReduction::localSize, CmiReduction::mergeFn, CmiReduction::numChildren, CmiReduction::ops, CmiReduction::parent, and CmiReduction::pupFn.
Referenced by CcsReply(), and CmiGroupReduce().
| void CmiListReduceStruct | ( | int | npes, | |
| int * | pes, | |||
| void * | data, | |||
| CmiReducePupFn | pupFn, | |||
| CmiReduceMergeFn | mergeFn, | |||
| CmiHandler | dest, | |||
| CmiReduceDeleteFn | deleteFn, | |||
| CmiReductionID | id | |||
| ) |
Definition at line 2450 of file convcore.c.
References CmiGetReductionCreate(), CmiMyPe(), CmiNumSpanTreeChildren(), CmiSendReduce(), CmiReduction::deleteFn, CmiReduction::destination, CmiReduction::localContributed, CmiReduction::localData, CmiReduction::localSize, CmiReduction::mergeFn, CmiReduction::numChildren, CmiReduction::ops, CmiReduction::parent, and CmiReduction::pupFn.
Referenced by CmiGroupReduceStruct().
| 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 * | data, | |
| int | size, | |||
| CmiReduceMergeFn | mergeFn, | |||
| int | redID, | |||
| int | numChildren, | |||
| int | parent | |||
| ) |
Definition at line 2505 of file convcore.c.
References CmiNodeFirst(), CmiNodeReduce(), CmiNodeSpanTreeParent(), and CmiNumNodeSpanTreeChildren().
Definition at line 2512 of file convcore.c.
References CmiNodeFirst(), CmiNodeReduce(), CmiNodeSpanTreeParent(), and CmiNumNodeSpanTreeChildren().
| void CmiNodeReduceStruct | ( | void * | data, | |
| CmiReducePupFn | pupFn, | |||
| CmiReduceMergeFn | mergeFn, | |||
| CmiHandler | dest, | |||
| CmiReduceDeleteFn | deleteFn | |||
| ) |
| void CmiHandleReductionMessage | ( | void * | msg | ) |
Definition at line 2535 of file convcore.c.
References CmiGetReduction(), CmiGetReductionCreate(), CmiSendReduce(), CmiReduction::numChildren, CmiReduction::numRemoteReceived, and CmiReduction::remoteData.
Referenced by CmiReductionsInit().
| void CmiReductionsInit | ( | ) |
Definition at line 2547 of file convcore.c.
References CmiHandleReductionMessage(), CmiReductionHandleDynamicRequest(), CmiReductionID_dynamicOffset, CmiReductionID_globalOffset, CmiReductionID_requestOffset, CmiRegisterHandler(), and malloc().
Referenced by ConverseCommonInit().
| CpvStaticDeclare | ( | int | , | |
| CmiGroupHandlerIndex | ||||
| ) |
| CpvStaticDeclare | ( | int | , | |
| CmiGroupCounter | ||||
| ) |
| CpvStaticDeclare | ( | GroupDef * | , | |
| CmiGroupTable | ||||
| ) |
| void CmiGroupHandler | ( | GroupDef | def | ) |
Definition at line 2592 of file convcore.c.
References GroupDef::core, and GroupDef::group.
Referenced by CmiGroupInit().
Definition at line 2603 of file convcore.c.
References CmiAlloc(), CmiMyPe(), CmiSyncBroadcastAllAndFree(), GroupDef::group, GroupDef::npes, and GroupDef::pes.
Referenced by CldComputeNeighborData(), CldReadNeighborData(), and HybridBaseLB::initTree().
Definition at line 2620 of file convcore.c.
References GroupDef::core, GroupDef::group, GroupDef::npes, and GroupDef::pes.
Referenced by CkSendMsgBranchGroup(), CldEnqueueGroup(), CmiGroupReduce(), CmiGroupReduceStruct(), and CmiMulticastDeliver().
| void CmiGroupInit | ( | ) |
Definition at line 2636 of file convcore.c.
References calloc(), CmiAbort(), CmiGroupHandler(), and CmiRegisterHandler().
Referenced by ConverseCommonInit().
Definition at line 2659 of file convcore.c.
Referenced by CmiAsyncListSendFn(), CmiFreeListSendFn(), CmiSyncListSend(), and KillOnAllSigs().
| CmiCommHandle CmiAsyncListSendFn | ( | int | npes, | |
| int * | pes, | |||
| int | len, | |||
| char * | msg | |||
| ) |
Definition at line 2685 of file convcore.c.
Referenced by CmiSyncListSendAndFree(), and KillOnAllSigs().
| CpvDeclare | ( | int | , | |
| CmiMulticastHandlerIndex | ||||
| ) |
| void CmiMulticastDeliver | ( | MultiMsg | msg | ) |
Definition at line 2722 of file convcore.c.
References CmiFree(), CmiLookupGroup(), CmiMyPe(), CmiSyncSend(), CmiSyncSendAndFree(), MultiMsg::group, MultiMsg::origlen, and MultiMsg::pos.
Referenced by CmiMulticastHandler(), and CmiSyncMulticastFn().
| void CmiMulticastHandler | ( | MultiMsg | msg | ) |
Definition at line 2760 of file convcore.c.
References CmiMulticastDeliver().
Referenced by CmiMulticastInit().
Definition at line 2765 of file convcore.c.
References CmiAlloc(), and CmiMulticastDeliver().
Referenced by CmiFreeMulticastFn(), and CmiSyncMulticast().
Definition at line 2783 of file convcore.c.
References CmiFree(), and CmiSyncMulticastFn().
Referenced by CmiSyncMulticastAndFree().
| CmiCommHandle CmiAsyncMulticastFn | ( | CmiGroup | grp, | |
| int | len, | |||
| char * | msg | |||
| ) |
| void CmiMulticastInit | ( | ) |
Definition at line 2795 of file convcore.c.
References CmiMulticastHandler(), and CmiRegisterHandler().
Referenced by ConverseCommonInit().
| void* arena_malloc | ( | int | size | ) |
Referenced by CmiAlloc().
| void arena_free | ( | void * | blockPtr | ) |
Referenced by CmiFree().
| void* CmiAlloc | ( | int | size | ) |
Allocate `size` bytes of memory usable as a message buffer.
Such memory may be in limited supply and expensive to obtain on machine layers that use registered or pinned memory when interacting with the communication hardware. Uses besides buffers in which to construct messages should prefer the malloc()/free() provided by libmemory-*.
Definition at line 2832 of file convcore.c.
References arena_malloc(), CMI_VMI_CmiAlloc(), CmiMyPe(), CmiPoolAlloc(), CmiPrintf(), elan_CmiAlloc(), infi_CmiAlloc(), LrtsAlloc(), and malloc_nomigrate().
Referenced by TokenPool::_alloc(), _bufferedLocalMessageCopyHandler(), _messageLoggingInit(), _processTicketRequest(), _recvCheckpointHandler(), _recvGlobalStepHandler(), _recvRestartCheckpointHandler(), _resendMessagesHandler(), _resendReplyHandler(), _sendDetsHandler(), _sendDetsReplyHandler(), _updateHomeAckHandler(), addBufferedDeterminant(), ElementDistributor::addLocation(), envelope::alloc(), AssembleDatagram(), bufalloc(), BufferAlloc(), callHandlerRec(), CcsImpl_ccs2converse(), CcsImpl_reply(), CcsMerge_concat(), CcsReply(), CfutureCreateBuffer(), CkArray::CkArray(), CkCopyMsg(), CProxy_ArrayBase::ckInsertIdx(), CldGraphModuleInit(), CldModuleGeneralInit(), CldOtherInit(), CldPutToken(), CldPutTokenPrio(), CMI_VMI_Distribute_Cluster_Mapping(), CMI_VMI_Eager_Long_Setup(), CMI_VMI_Eager_Short_Setup(), CMI_VMI_RDMA_Publish_Notification_Handler(), CMI_VMI_Reply_Latencies(), CMI_VMI_Stream_Notification_Handler(), CmiAmmassoOpenQueuePairs(), CmiAsyncBroadcastAllFn(), CmiAsyncSendFn(), CmiCopyMsg(), CmiCreatePersistent(), CmiDestoryPersistent(), CmiDirect_assocLocalBuffer(), CmiEstablishGroup(), CmiFreeBroadcastAllFn(), CmiGet(), CmiGetCb(), CmiGetDynamicReductionRemote(), CmiInitCPUAffinity(), CmiIOInit(), CmiPut(), CmiPutCb(), CmiSendMessagePxshm(), CmiSendMessageXpmem(), CmiSendReduce(), CmiStartQD(), BGConverse::CmiSyncBroadcast(), BGConverse::CmiSyncBroadcastAll(), CmiSyncBroadcastAllFn(), CmiSyncMulticastFn(), BGConverse::CmiSyncSend(), CmiSyncSendFn(), CmmNew(), CmmPut(), combineMessage(), ComlibNotifyMigrationDone(), copyEnvelope(), CopyMsg(), CPathCreateRedmsg(), CPathSend(), CpdGetNextMessageConditional(), CpdSearchLeaks(), cpuTopoHandler(), CqsCreate(), CqsDeqExpand(), CqsEnumerateDeq(), CqsEnumeratePrioq(), CqsEnumerateQueue(), CqsPrioqExpand(), CqsPrioqGetDeq(), CqsPrioqInit(), CqsPrioqRehash(), CWeb_Collect(), CWebHandler(), ConvComlibManager::doneCreating(), RouterStrategy::doneInserting(), StatTable::doReduction(), TreeRouter::EachToAllMulticast(), HypercubeRouter::EachToAllMulticast(), GridRouter::EachToAllMulticast(), GraphRouter::EachToAllMulticast(), DimexRouter::EachToAllMulticast(), D3GridRouter::EachToAllMulticast(), emptyRecvBuf(), EnqueueDummyPacket(), EnqueueRdmaAck(), EnqueueRdmaPacket(), PeTable::ExtractAndDeliverLocalMsgs(), PeTable::ExtractAndPack(), PeTable::ExtractAndPackAll(), PeTable::ExtractAndVectorize(), PeTable::ExtractAndVectorizeAll(), get_callback_dest(), CkMessageDetailReplay::getNext(), getPool(), GrantTokens(), GridRouter::GridRouter(), handleGetDest(), handlePutDest(), PipeBroadcastConverse::insertMessage(), CkMemCheckPT::isMaster(), KillOnAllSigs(), LrtsInitCpuTopo(), newPacket(), RouterStrategy::notifyDone(), MessageHolder::operator new(), ComlibLocalStats::operator=(), persistentRequestHandler(), PeTable::PeTable(), prepare_slotmsg(), print_node0(), processMessage(), ProcessMessage(), processRdmaRequest(), PumpMsgs(), PumpMsgsBlocking(), Event::pup(), MessageHolder::pup(), ComlibComRec::pup(), ComlibComRec::recordRecv(), ComlibComRec::recordRecvM(), ComlibComRec::recordSend(), ComlibComRec::recordSendM(), recv_callback(), HypercubeRouter::RecvManyMsg(), DimexRouter::RecvManyMsg(), CkMulticastMgr::recvPacket(), sendBufferedLocalMessageCopy(), sendCheckpointData(), Router::SendDummyMsg(), SendMsgBuf(), sendRemoveLogRequests(), sendTicketRequest(), TreeRouter::SortBufferDown(), TreeRouter::SortBufferUp(), HypercubeRouter::start_hcube(), DimexRouter::start_hcube(), startMlogCheckpoint(), PipeBroadcastConverse::store(), TokenAlloc(), and ComlibSectionInfo::unpack().
| static void* CmiAllocFindEnclosing | ( | void * | blk | ) | [static] |
Follow the header links out to the most enclosing block.
Definition at line 2882 of file convcore.c.
Referenced by CmiFree(), CmiGetReference(), and CmiReference().
| int CmiGetReference | ( | void * | blk | ) |
Definition at line 2891 of file convcore.c.
References CmiAllocFindEnclosing().
Referenced by CmiFreeBroadcastAllFn(), and processProcBcastMsg().
| void CmiReference | ( | void * | blk | ) |
Increment the reference count for this block's owner.
This call must be matched by an equivalent CmiFree.
Definition at line 2898 of file convcore.c.
References CmiAllocFindEnclosing().
Referenced by CmiMultiMsgHandler(), CmiSyncListSendFn(), CpdBeforeEp(), CpdPythonGroup::cpdCheck(), CpdDeliverMessageInt(), CpdDeliverSingleMessage(), PeTable::ExtractAndVectorize(), PeTable::ExtractAndVectorizeAll(), KillOnAllSigs(), MulticastStrategy::localMulticast(), PipeBroadcastConverse::propagate(), GridRouter::RecvManyMsg(), SendHyperCube(), GridRouter::sendRow(), and SendSpanningChildren().
| int CmiSize | ( | void * | blk | ) |
Return the size of the user portion of this block.
Definition at line 2904 of file convcore.c.
Referenced by CpdListHeader_ccs_list_items(), and getImageHandler().
| void CmiFree | ( | void * | blk | ) |
Decrement the reference count for this block.
Definition at line 2910 of file convcore.c.
References arena_free(), CMI_VMI_CmiFree(), CmiAbort(), CmiAllocFindEnclosing(), CmiPoolFree(), CmiPrintf(), free_nomigrate(), infi_CmiFree(), infi_freeMultipleSend(), and LrtsFree().
Referenced by _bufferedLocalMessageAckHandler(), _bufferedLocalMessageCopyHandler(), _bufferedTicketHandler(), _bufferedTicketRequestHandler(), _checkpointAckHandler(), _checkpointBarrierAckHandler(), _checkpointBarrierHandler(), _CldEnqueue(), _CldEnqueueGroup(), _CldEnqueueMulti(), _CldNodeEnqueue(), _discardHandler(), _dummyMigrationHandler(), _exitHandler(), TokenPool::_free(), _libExitHandler(), _localMessageAckHandler(), _noCldEnqueue(), _noCldEnqueueMulti(), _noCldNodeEnqueue(), _pingHandler(), _processDeleteVidMsg(), _processFillVidMsg(), _processRODataMsg(), _qdCommHandler(), _receivedDetDataHandler(), _receivedTNDataHandler(), _receiveLocationHandler(), _recvCheckpointHandler(), _recvGlobalStepHandler(), _recvRestartCheckpointHandler(), _removeDeterminantsHandler(), _removeProcessedLogHandler(), _resendMessagesHandler(), _sendDetsHandler(), _sendDetsReplyHandler(), _sendTriggers(), _skipCldEnqueue(), _speedHdlr(), _storeCheckpointHandler(), _storeDeterminantsHandler(), _ticketHandler(), _ticketRequestHandler(), _triggerHandler(), _updateHomeAckHandler(), addBufferedDeterminant(), bufalloc(), ccs_getinfo(), ccs_killport(), CcsMerge_concat(), CfutureDestroy(), CfutureDestroyBuffer(), CkFreeMsg(), ckinsertIdxFunc(), CldAskLoadHandler(), CldAverageHandler(), CldEnqueueGroup(), CldEnqueueMulti(), CldLoadResponseHandler(), CldMultipleSend(), CldMultipleSendPrio(), CldReduceHandler(), CldTokenHandler(), clearUpMigratedRetainedLists(), CMI_VMI_Common_Receive(), CMI_VMI_RDMA_Get_Notification_Handler(), CMI_VMI_RDMA_Put_Completion_Handler(), CMI_VMI_Stream_Completion_Handler(), CmiFreeBroadcastAllFn(), CmiFreeBroadcastFn(), CmiFreeListSendFn(), CmiFreeMulticastFn(), CmiFreeNodeBroadcastFn(), CmiFreeSendFn(), CmiMulticastDeliver(), CmiMultiMsgHandler(), CmiReleaseCommHandle(), CmiReleaseSentMessages(), CmiSendMessagePxshm(), CmiSendMessageXpmem(), CmiSendReduce(), CmiSyncBroadcastAllFn(), CmiSyncBroadcastFn(), CmiSyncVectorSendAndFree(), CmmFind(), CmmFree(), CmmFreeAll(), CmmPup(), ComlibNotifyMigrationDoneHandler(), comlibReadyHandler(), comlibTableReceivedHandler(), CPathForwardReduction(), CPathMsgFree(), cpd_memory_single_pup(), CpdAfterEp(), CpdDebugCallAllocationTree(), CpdDebugCallMemStat(), CpdDebugHandlerFreeze(), CpdDebugHandlerStatus(), CpdList_ccs_list_items_fmt(), CpdList_ccs_list_items_set(), CpdList_ccs_list_items_txt(), CpdList_ccs_list_len(), CpdMachineArchitecture(), CpdSearchLeaks(), CpdSearchLeaksDone(), CpmThread3(), cpuAffinityHandler(), cpuAffinityRecvHandler(), cpuTopoHandler(), cpuTopoRecvHandler(), CQdHandlePhase0(), CQdHandlePhase1(), CQdHandlePhase2(), CqsDelete(), CqsDeqExpand(), CqsEnumerateQueue(), CqsPrioqDequeue(), CqsPrioqExpand(), CqsPrioqRehash(), CWeb_Deliver(), CWeb_Reduce(), CharmStrategy::deliverToIndices(), HypercubeRouter::EachToAllMulticast(), DimexRouter::EachToAllMulticast(), PeTable::ExtractAndPack(), PeTable::ExtractAndPackAll(), RectMulticastStrategy::forwardMulticast(), free_remote(), GarbageCollectMsg(), getImageConfigHandler(), getImageHandler(), grab_remote(), GrantTokens(), handleGetDest(), handleGetSrc(), OneTimeMulticastStrategy::handleMessage(), ChunkMulticastStrategy::handleMessage(), RectMulticastStrategy::handleNewMulticastMessage(), MulticastStrategy::handleNewMulticastMessage(), handlePutDest(), handlePutSrc(), ChunkMulticastStrategy::insertMessage(), CkMemCheckPT::isMaster(), KillOnAllSigs(), RectMulticastStrategy::localMulticast(), MulticastStrategy::localMulticast(), ComlibArrayInfo::localMulticast(), LV3D0_flush(), LV3D0_getViews(), LV3D0_qd(), LV3D0_quit(), LV3D0_setup(), LV3D0_startbalance(), LV3D0_stats(), LV3D0_throttle0(), LV3D0_throttle1(), LV3D0_trace(), LV3D0_zero(), NetFEM_getCurrent(), MessageHolder::operator delete(), persistentDestoryHandler(), persistentReqGrantedHandler(), persistentRequestHandler(), preProcessReceivedMessage(), processBufferedBcast(), processProcBcastMsg(), PumpEvents(), PumpMsgs(), put_callback(), recv_dummy(), HypercubeRouter::RecvManyMsg(), DimexRouter::RecvManyMsg(), OneTimeMulticastStrategy::remoteMulticast(), MulticastStrategy::remoteMulticast(), ChunkMulticastStrategy::remoteMulticast(), rep_fw_handler(), req_fw_handler(), ComlibComRec::reset(), retryTicketRequest(), sendCheckpointData(), SendMsgBuf(), RectMulticastStrategy::sendRectDest(), sendRemoveLogRequests(), CkMulticastMgr::sendToSection(), TreeRouter::SortBufferDown(), TreeRouter::SortBufferUp(), HypercubeRouter::start_hcube(), DimexRouter::start_hcube(), StatTableReduction(), PipeBroadcastConverse::store(), streaming_column_handler(), StreamingHandlerFn(), PeTable::UnpackAndInsert(), PeTable::UnpackAndInsertAll(), ComlibComRec::~ComlibComRec(), GridRouter::~GridRouter(), MlogEntry::~MlogEntry(), and PeTable::~PeTable().
| CpvDeclare | ( | CmiTmpBuf_t | , | |
| CmiTmpBuf | ||||
| ) |
| static void CmiTmpSetup | ( | CmiTmpBuf_t * | b | ) | [static] |
Definition at line 2976 of file convcore.c.
References CmiTmpBuf_t::buf, CmiTmpBuf_t::cur, malloc(), and CmiTmpBuf_t::max.
Referenced by CmiTmpAlloc(), and CmiTmpInit().
| void* CmiTmpAlloc | ( | int | size | ) |
Definition at line 2982 of file convcore.c.
Referenced by _CmiMultipleSend(), PUP::fromTextFile::comment(), KillOnAllSigs(), and skt_sendV().
| void CmiTmpFree | ( | void * | t | ) |
Definition at line 3000 of file convcore.c.
Referenced by _CmiMultipleSend(), PUP::fromTextFile::comment(), KillOnAllSigs(), and skt_sendV().
| void CmiTmpInit | ( | char ** | argv | ) |
Definition at line 3016 of file convcore.c.
References CmiTmpSetup().
Referenced by ConverseCommonInit().
| void CmiMkdir | ( | const char * | dirName | ) |
Definition at line 3031 of file convcore.c.
Referenced by CkCheckpointMgr::Checkpoint(), LogPool::createFile(), StringPool::dump(), initBigSimTrace(), and NetFEM_End().
Definition at line 3081 of file convcore.c.
References roundUpSize().
Referenced by _CmiMultipleSend().
| static void _CmiMultipleSend | ( | unsigned int | destPE, | |
| int | len, | |||
| int | sizes[], | |||
| char * | msgComps[], | |||
| int | immed | |||
| ) | [static] |
Definition at line 3118 of file convcore.c.
References CmiSyncVectorSend(), CmiTmpAlloc(), CmiTmpFree(), CmiMultipleSendHeader::nMessages, CmiMultipleSendHeader::pad, pad, paddingSize(), CmiChunkHeader::ref, roundUpSize(), and CmiChunkHeader::size.
Referenced by CmiMultipleIsend(), and CmiMultipleSend().
Definition at line 3196 of file convcore.c.
References _CmiMultipleSend().
Referenced by CldMultipleSend(), and CldMultipleSendPrio().
Definition at line 3201 of file convcore.c.
References _CmiMultipleSend().
Referenced by CldMultipleSend(), and CldMultipleSendPrio().
| static void CmiMultiMsgHandler | ( | char * | msgWhole | ) | [static] |
Definition at line 3230 of file convcore.c.
References infiCmiChunkHeaderStruct::chunkHeader, CmiFree(), CmiMyPe(), CmiReference(), CmiSyncSendAndFree(), infiCmiChunkHeaderStruct::metaData, msg, CmiChunkHeader::ref, registerMultiSendMesg(), and CmiChunkHeader::size.
Referenced by CmiInitMultipleSend().
| void CmiInitMultipleSend | ( | void | ) |
Definition at line 3217 of file convcore.c.
References CmiMultiMsgHandler(), and CmiRegisterHandler().
Referenced by ConverseCommonInit().
Definition at line 3266 of file convcore.c.
Referenced by KillOnAllSigs(), and PipeBroadcastConverse::propagate().
| CpvDeclare | ( | int | , | |
| CmiImmediateMsgHandlerIdx | ||||
| ) |
| static void CmiImmediateMsgHandler | ( | char * | msg | ) | [static] |
Definition at line 3302 of file convcore.c.
References CmiHandleMessage().
Referenced by CmiInitImmediateMsg().
| void CmiInitImmediateMsg | ( | void | ) |
Definition at line 3308 of file convcore.c.
References CmiImmediateMsgHandler(), and CmiRegisterHandler().
Referenced by ConverseCommonInit().
| static void on_timeout | ( | cmi_cpu_idlerec * | rec, | |
| double | curWallTime | |||
| ) | [static] |
Definition at line 3331 of file convcore.c.
References cmi_cpu_idlerec::call_count, CmiAbort(), CmiError(), CmiMyPe(), and cmi_cpu_idlerec::is_idle.
Referenced by on_idle().
| static void on_idle | ( | cmi_cpu_idlerec * | rec, | |
| double | curWallTime | |||
| ) | [static] |
Definition at line 3339 of file convcore.c.
References cmi_cpu_idlerec::call_count, CcdCallFnAfter(), cmi_cpu_idlerec::idle_timeout, cmi_cpu_idlerec::is_idle, and on_timeout().
Referenced by CIdleTimeoutInit().
| static void on_busy | ( | cmi_cpu_idlerec * | rec, | |
| double | curWallTime | |||
| ) | [static] |
Definition at line 3345 of file convcore.c.
References cmi_cpu_idlerec::is_idle.
Referenced by CIdleTimeoutInit().
| static void CIdleTimeoutInit | ( | char ** | argv | ) | [static] |
Definition at line 3349 of file convcore.c.
References cmi_cpu_idlerec::call_count, CcdCallOnCondition(), CmiGetArgIntDesc(), cmi_cpu_idlerec::idle_timeout, cmi_cpu_idlerec::is_idle, malloc(), on_busy(), and on_idle().
Referenced by ConverseCommonInit().
| void CrnInit | ( | void | ) |
Definition at line 58 of file random.c.
References CrnInitStream().
Referenced by ConverseCommonInit().
| void CmiIsomallocInit | ( | char ** | argv | ) |
Definition at line 2518 of file isomalloc.c.
References CmiGetArgFlagDesc(), CmiMyPe(), disable_isomalloc(), init_comm(), init_map(), init_ranges(), printf(), and read_randomflag().
Referenced by ConverseCommonInit().
| void CmiIOInit | ( | char ** | argv | ) |
Definition at line 3660 of file convcore.c.
References CmiAbort(), CmiAlloc(), CmiGetArgFlagDesc(), and CmiGetArgIntDesc().
Referenced by ConverseCommonInit().
| void CmiInitCPUAffinityUtil | ( | ) |
Definition at line 767 of file cpuaffinity.c.
References _smp_mutex, CmiLock(), and CmiUnlock().
Referenced by ConverseCommonInit().
| static void CmiProcessPriority | ( | char ** | argv | ) | [static] |
Definition at line 3379 of file convcore.c.
References CmiAbort(), CmiGetArgIntDesc(), CmiMyPe(), CmiMyRank(), CmiPrintf(), errno, and status().
Referenced by ConverseCommonInit().
| void CommunicationServerInit | ( | ) |
Definition at line 3445 of file convcore.c.
References CQdCpvInit().
Referenced by call_startfn(), and KillOnAllSigs().
| static int testEndian | ( | void | ) | [static] |
| int CmiEndianness | ( | ) |
Definition at line 3467 of file convcore.c.
References testEndian().
Referenced by CqsEnqueueGeneral().
| void ConverseCommonInit | ( | char ** | argv | ) |
Main Converse initialization routine.
This routine is called by the machine file (machine.c) to set up Converse. It's "Common" because it's shared by all the machine.c files.
The main task of this routine is to set up all the Cpv's (message queues, handler tables, etc.) used during main execution.
On SMP versions, this initialization routine is called by all* processors of a node simultaniously. It's *also* called by the communication thread, which is rather strange but needed for immediate messages. Each call to this routine expects a different copy of the argv arguments, so use CmiCopyArgs(argv).
Requires:
Initialization is somewhat subtle, in that various modules won't work properly until they're initialized. For example, nobody can register handlers before calling CmiHandlerInit.
The reason to initialize this variable here: cmiArgDebugFlag is possibly accessed in CmiPrintf/CmiError etc., therefore, we have to initialize this variable before any calls to those functions (such as CmiPrintf). Otherwise, we may encounter a memory segmentation fault (bad memory access). Note, even testing CpvInitialized(cmiArgDebugFlag) doesn't help to solve this problem because the variable indicating whether cmiArgDebugFlag is initialized or not is not initialized, thus possibly causing another bad memory access. --Chao Mei
Definition at line 3500 of file convcore.c.
References _Cmi_noprocforcommthread, CcdModuleInit(), CcsInit(), CIdleTimeoutInit(), CldModuleInit(), CmiArgInit(), CmiCommitID, CmiDeliversInit(), CmiGetArgFlagDesc(), CmiGroupInit(), CmiHandlerInit(), CmiInitCell(), CmiInitCPUAffinityUtil(), CmiInitImmediateMsg(), CmiInitMultipleSend(), CmiIOInit(), CmiIsomallocInit(), CmiMemoryInit(), CmiMulticastInit(), CmiMyPe(), CmiMyRank(), CmiPersistentInit(), CmiPoolAllocInit(), CmiPrintf(), CmiProcessPriority(), CmiReductionsInit(), CmiTimerInit(), CmiTmpInit(), CpdInit(), CQdInit(), CrnInit(), CsdInit(), CstatsInit(), CthSchedInit(), initQd(), and traceInit().
Referenced by ConverseInit(), ConverseRunPE(), and KillOnAllSigs().
| void ConverseCommonExit | ( | void | ) |
Definition at line 3600 of file convcore.c.
References CcsImpl_kill(), CloseOffloadAPI(), EmergencyExit(), seedBalancerExit(), and traceClose().
Referenced by CommunicationServer(), ConverseExit(), and KillOnAllSigs().
| void register_accel_spe_funcs | ( | void | ) |
Referenced by CmiInitCell().
| void CmiInitCell | ( | ) |
Definition at line 3629 of file convcore.c.
References CcdCallOnConditionKeep(), CmiMyPe(), InitOffloadAPI(), OffloadAPIProgress(), and register_accel_spe_funcs().
Referenced by ConverseCommonInit().
| void CmiPrintf | ( | const char * | format, | |
| ... | ||||
| ) |
Definition at line 3705 of file convcore.c.
Referenced by _checkpointBarrierAckHandler(), _checkpointBarrierHandler(), _dummyMigrationHandler(), _getCheckpointHandler(), _getGlobalStepHandler(), _getRestartCheckpointHandler(), _loadbalancerInit(), _parseCommandLineOpts(), _propMapInit(), _receiveLocationHandler(), _recvGlobalStepHandler(), _resendMessagesHandler(), _updateHomeRequestHandler(), _verifyAckHandler(), _verifyAckRequestHandler(), LBDatabase::addLoadbalancer(), AllocatorCheck(), ampi::ampi(), AMPI_Alltoall(), AMPI_MemCheckpoint(), ampiInit(), ampiProcInit(), AsynchronousEventHandler(), bad_location(), CkLocRec_buffering::beenReplaced(), TraceCounter::beginExecute(), TraceCounter::beginOverview(), TraceBluegene::bgPrint(), CkArray::broadcastHomeElements(), CkMemCheckPT::BuddyPE(), HybridBaseLB::buildStats(), CcsBufferMessage(), CcsHandleRequest(), CcsImpl_netRequest(), CcsInit(), CfutureDestroy(), CfutureWait(), LBDB::ChangePredictor(), check_range(), CkCppInterpreter::CkCppInterpreter(), CkGetSectionInfo(), CkMessageWatcherInit(), CkRestartMain(), CldAskLoadHandler(), CldAverageHandler(), CldComputeNeighborData(), CldEnqueue(), CldGraphModuleInit(), CldModuleGeneralInit(), CldOtherInit(), CldPropagateLoad(), CldReadytoExec(), CldStillIdle(), CldStoreCharemsg(), CMI_VMI_Startup_CRM(), CmiAddCLA(), CmiAlloc(), CmiArgGroup(), CmiBacktracePrint(), CmiCheckGmStatus(), CmiDestoryAllPersistent(), CmiDirect_assocLocalBuffer(), CmiDirect_createHandle(), CmiDirect_put(), CmiDirect_ready(), CmiDirect_readyPollQ(), CmiExitPxshm(), CmiExitSysvshm(), CmiExitXpmem(), CmiFree(), CmiGetReductionCreate(), CmiInitCPUAffinity(), CmiInitMemAffinity(), CmiInitXpmem(), CmiMemorySweep(), CmiMXMakeConnection(), CmiPoolAllocStats(), CmiPoolPrintList(), CmiPrintCLAs(), CmiPrintCPUAffinity(), CmiProcessPriority(), CmiRegisterMemory(), CmiSendMessagePxshm(), CmiSendMessageXpmem(), CmiSetMemAffinity(), CmiUnRegisterMemory(), CMsgInvokeCallbacks(), CMsgRegisterCallback(), CombineSummary(), pupCheckRec::compare(), CkMulticastMgr::contribute(), ConverseCommonInit(), ConverseExit(), ConverseInit(), cpd_memory_single_pup(), CpdConditional_SetupComm(), CpdDebugCallAllocationTree(), CpdDebugCallMemStat(), CpdList_ccs_list_items_set(), CpdList_ccs_list_items_txt(), CpdNotify(), CpdStartGdb(), CkMemCheckPT::cpFinish(), Cpthread_once(), cpuAffinityRecvHandler(), cpuTopoHandler(), CqsRemoveSpecific(), RefinerApprox::create(), createLoadBalancer(), createShmObjectsAndSems(), LogPool::createSts(), LogPool::createTopo(), CtgInit(), CthPrintThdMagic(), CthPrintThdStack(), disable_isomalloc(), LBDBRegistry::displayLBs(), CkThresholdTimer::done_(), Router::DummyEP(), LBDB::DumpDatabase(), Router::EachToAllMulticast(), Router::EachToManyMulticast(), TraceCounter::endExecute(), TraceCounter::endOverview(), endTraceBigSim_20param(), EnqueuePacket(), errspan(), expand_ccd_heap(), fillblock(), find_largest_free_region(), CentralLB::findSimResults(), g_printGraph(), gengraph(), get_callback_dest(), ImageData::GetClippedImage(), CkMemCheckPTInfo::getCopy(), getImageConfigHandler(), getImageHandler(), getNUMANidByRank(), good_range(), LBCommTable::HashInsert(), HigherPriorityWork(), CkLocMgr::inform(), informLocationHome(), init_ranges(), initBigSimTrace(), initConvComlibManager(), initQd(), CkMemCheckPT::isMaster(), KillOnAllSigs(), KLevelTree::KLevelTree(), LBDBInit::LBDBInit(), LBTOPO_MACRO(), liveViz0Deposit(), liveViz0Init(), liveViz0PollInit(), CentralLB::LoadBalance(), TraceCore::LogEvent(), LrtsInitCpuTopo(), LV3D0_setup(), map_slots(), OrbLB::mapPartitionsToNodes(), memAbort(), memory_check(), mempool_free(), mempool_malloc(), meta_calloc(), meta_cfree(), meta_free(), meta_init(), meta_malloc(), meta_memalign(), meta_realloc(), meta_valloc(), LBDB::Migrate(), Refiner::multirefine(), NborBaseLB::NborBaseLB(), ChareMlogData::next_ticket(), TraceLogger::openLogFiles(), GridMetisLB::Partition_ClusterObjects_Into_PEs(), pollCmiDirectQ(), POSEreadCmdLine(), mCastEntry::print(), AmpiRequestList::print(), SReq::print(), ATAReq::print(), IReq::print(), PersReq::print(), AmpiRequest::print(), LBTopoVec::print(), CpuTopology::print(), LBInfo::print(), CkArrayIndex::print(), print_btree_node(), print_btree_top_down(), print_cpu_affinity(), print_list_array(), print_mem_affinity(), print_myslots(), print_thread_affinity(), LBSimulation::PrintDifferences(), TraceCounter::printHelp(), RefinerComm::printLoad(), printNetStatistics(), RecBisectBfLB::printPartitions(), printSlot(), printTotalHops(), processFutureMessages(), processMessage(), ProcessMessage(), CentralLB::ProcessReceiveMigration(), processStatusCode(), TCharm::procInit(), Router::ProcManyMsg(), PumpEvents(), PumpMsgs(), PumpMsgsBlocking(), CkLocMgr::pup(), ChareMlogData::pup(), put_callback(), OrbLB::quicksort(), CentralLB::readStatsMsgs(), OrbLB::rec_divide(), ReceiveDatagram(), recv_callback(), Router::RecvManyMsg(), CkMulticastMgr::recvRedMsg(), RefinerComm::Refine(), RefinerComm::refine(), TraceCounter::registerArg(), TraceLogger::RegisterLanguage(), CentralLB::removeNonMigratable(), ChareMlogData::searchRestoredLocalQ(), seedBalancerExit(), send_callback(), sendMlogLocation(), SendMsgBuf(), SendTasktoPe(), sendTicketRequest(), CkMulticastMgr::sendToSection(), OrbLB::setVal(), showBanner(), CentralLB::simulationRead(), CentralLB::simulationWrite(), slotAbort(), staticStartLB(), StatTableReduction(), status(), NeighborCommLB::Strategy(), TCHARM_Api_trace(), TopologyAgent::TopologyAgent(), TraceCounter::traceBegin(), TraceCounter::traceClose(), traceCommonInit(), TraceCounter::traceEnd(), TraceCounter::traceInit(), TraceMemory::TraceMemory(), TraceProjections::TraceProjections(), TraceSummary::TraceSummary(), try_largest_mmap_region(), LBDB::TurnPredictorOff(), LBDB::TurnPredictorOn(), unmap_slots(), CkObjID::updatePosition(), TraceCounter::usage(), TraceLogger::verifyFptrs(), TopoLB::work(), TopoCentLB::work(), RefineTopoLB::work(), RecBisectBfLB::work(), OrbLB::work(), CentralLB::writeStatsMsgs(), CountLogPool::writeSts(), and WSLB::WSLB().
| void CmiError | ( | const char * | format, | |
| ... | ||||
| ) |
Definition at line 3727 of file convcore.c.
Referenced by __cmi_assert(), TraceProjections::beginFunc(), CldReadNeighborData(), CmiAsyncMulticastFn(), CmiIsomalloc(), CmiRegisterHandlerGlobal(), CmiSetCPUAffinity(), CPathMakeArray(), CPathRecv(), CPathReduce(), CPathReduceMismatch(), CPathSend(), CpdList_ccs_list_items_fmt(), CpdList_ccs_list_items_txt(), CpdListLookup(), disabled_map(), FIFO_Destroy(), getImageHandler(), isomallocfn(), KillOnAllSigs(), map_failed(), on_timeout(), LogEntry::pup(), pup_checkMPIerr(), and SendMsgBuf().
| void __cmi_assert | ( | const char * | expr, | |
| const char * | file, | |||
| int | line | |||
| ) |
Definition at line 3749 of file convcore.c.
| char* CmiCopyMsg | ( | char * | msg, | |
| int | len | |||
| ) |
| unsigned char computeCheckSum | ( | unsigned char * | data, | |
| int | len | |||
| ) |
Definition at line 3764 of file convcore.c.
Referenced by EnqueueOutgoingDgram(), processMessage(), ProcessMessage(), ReceiveDatagram(), TransmitAckDatagram(), TransmitImplicitDgram(), and TransmitImplicitDgram1().
Definition at line 3777 of file convcore.c.
| int CmiMyRank_ | ( | ) |
| double CmiReadSize | ( | const char * | str | ) |
| const char* const CmiCommitID |
Referenced by ConverseCommonInit().
Definition at line 85 of file convcore.c.
Referenced by call_cblist_keep(), call_cblist_remove(), ccd_heap_update(), and QdCallback::send().
int CsdLocalMax = CSD_LOCAL_MAX_DEFAULT [static] |
Definition at line 136 of file convcore.c.
Definition at line 138 of file convcore.c.
Referenced by _exitHandler(), CharmLibInit(), CkExit(), ConverseRunPE(), and SendMsgBuf().
| void(* notify_crash_fn)(int) = NULL |
Referenced by crash_node_handle(), and CkMemCheckPT::isMaster().
| pthread_mutex_t prefetchLock |
Definition at line 185 of file convcore.c.
int usageChecked = 0 [static] |
Definition at line 235 of file convcore.c.
int printUsage = 0 [static] |
Definition at line 236 of file convcore.c.
const char* CLAformatString = "%20s %10s %s\n" [static] |
int CLAlistLen = 0 [static] |
Definition at line 248 of file convcore.c.
int CLAlistMax = 0 [static] |
Definition at line 249 of file convcore.c.
Definition at line 250 of file convcore.c.
int _absoluteTime = 0 [static] |
static timebasestruct_t inittime_wallclock = 0 [static] |
Definition at line 900 of file convcore.c.
Referenced by CmiInitTime(), CmiTimerInit(), and CmiWallTimer().
Definition at line 972 of file convcore.c.
Definition at line 1023 of file convcore.c.
Definition at line 1347 of file convcore.c.
Referenced by CmiCpuTimer(), CmiTimerInit(), and CmiWallTimer().
| int _immediateLock = 0 |
Definition at line 3296 of file convcore.c.
| int _immediateFlag = 0 |
Definition at line 3297 of file convcore.c.
| int _BgOutOfCoreFlag = 0 |
Definition at line 3773 of file convcore.c.
Referenced by LocalBarrier::AddClient(), LBDB::AddObj(), ArrayElement::ckDestroy(), CthPupBase(), CkLocMgr::flushAllRecs(), TCharm::pup(), CkLocMgr::reclaim(), LocalBarrier::RemoveClient(), CkLocMgr::restore(), LBDB::UnregisterObj(), and ampi::~ampi().
Definition at line 3774 of file convcore.c.
Referenced by AMPI_Wait(), AMPI_Waitall(), and IReq::wait().
1.5.5