Converse

Collaboration diagram for Converse:

Converse--a parallel portability layer. More...


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: immediate.c machine-smp.c machine-smp.h machine.h pcqueue.h persist-comm.c persist_impl.h.
	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

Detailed Description

Converse--a parallel portability layer.

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 Documentation

typedef unsigned long mmulong

Definition at line 156 of file convcore.c.

Enumeration Type Documentation

anonymous enum

Enumerator:

CmiReductionID_globalOffset
CmiReductionID_requestOffset
CmiReductionID_dynamicOffset
CmiReductionID_multiplier

Definition at line 2237 of file convcore.c.

Function Documentation

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 ** )

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 )

Definition at line 4240 of file machine.c.

Referenced by CmiAlloc().

void CMI_VMI_CmiFree ( void * ptr )

Definition at line 4294 of file machine.c.

Referenced by CmiFree().

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
	)

void* LrtsAlloc	(	int	,
		int
	)

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().

int CmiGetArgDoubleDesc	(	char **	argv,
		const char *	arg,
		double *	optDest,
		const char *	desc
	)

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().

int CmiGetArgDouble	(	char **	argv,
		const char *	arg,
		double *	optDest
	)

Definition at line 394 of file convcore.c.

References CmiGetArgDoubleDesc().

int CmiGetArgIntDesc	(	char **	argv,
		const char *	arg,
		int *	optDest,
		const char *	desc
	)

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().

int CmiGetArgInt	(	char **	argv,
		const char *	arg,
		int *	optDest
	)

Definition at line 440 of file convcore.c.

References CmiGetArgIntDesc().

Referenced by ComlibManagerMain::ComlibManagerMain(), ConverseInit(), KillOnAllSigs(), and SendMsgBuf().

int CmiGetArgLongDesc	(	char **	argv,
		const char *	arg,
		CmiInt8 *	optDest,
		const char *	desc
	)

Definition at line 444 of file convcore.c.

References CmiAbort(), CmiAddCLA(), and CmiDeleteArgs().

Referenced by CmiGetArgLong(), and TraceProjections::TraceProjections().

int CmiGetArgLong	(	char **	argv,
		const char *	arg,
		CmiInt8 *	optDest
	)

Definition at line 479 of file convcore.c.

References CmiGetArgLongDesc().

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]

Definition at line 540 of file convcore.c.

Referenced by CmiBacktracePrint().

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().

int CstatMemory ( int i )

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 )

int CmiRegisterHandlerEx	(	CmiHandlerEx	h,
		void *	userPtr
	)

Definition at line 739 of file convcore.c.

References CmiNumberHandlerEx().

int CmiRegisterHandlerLocal ( CmiHandler h )

Definition at line 748 of file convcore.c.

References CmiNumberHandler().

int CmiRegisterHandlerGlobal ( CmiHandler h )

Definition at line 757 of file convcore.c.

References CmiError(), CmiMyPe(), and CmiNumberHandler().

static void _cmiZeroHandler ( void * msg ) [static]

Definition at line 769 of file convcore.c.

References CmiAbort().

Referenced by CmiHandlerInit().

static void CmiHandlerInit ( ) [static]

Definition at line 773 of file convcore.c.

References _cmiZeroHandler(), and CmiRegisterHandler().

Referenced by ConverseCommonInit().

char * CmiPrintDate ( )

Definition at line 800 of file convcore.c.

References stats::time().

CpvStaticDeclare	(	double	,
		clocktick
	)

CpvStaticDeclare	(	int	,
		inittime_wallclock
	)

CpvStaticDeclare	(	int	,
		inittime_virtual
	)

int CmiTimerIsSynchronized ( )

Definition at line 827 of file convcore.c.

Referenced by SendMsgBuf().

int CmiTimerAbsolute ( )

Definition at line 832 of file convcore.c.

Referenced by SendMsgBuf(), TraceProjectionsInit::TraceProjectionsInit(), and TraceSummary::TraceSummary().

double CmiStartTimer ( )

Definition at line 837 of file convcore.c.

Referenced by SendMsgBuf(), and traceCommonInit().

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.

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]

Definition at line 999 of file convcore.c.

References CmiAbort(), CmiLock(), CmiUnlock(), and s.

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
	)

int CmiLongSendQueue	(	int	forNode,
		int	longerThanBytes
	)

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().

void CmiSignal	(	int	sig1,
		int	sig2,
		int	sig3,
		void(*)()	handler
	)

Definition at line 1478 of file convcore.c.

References handler().

Referenced by KillOnAllSigs().

void CmiSyncVectorSend	(	int	destPE,
		int	n,
		int *	sizes,
		char **	msgs
	)

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 2171 of file convcore.c.

References CmiSyncVectorSend().

void CmiSyncVectorSendAndFree	(	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 )

Definition at line 2276 of file convcore.c.

References free().

Referenced by CmiSendReduce().

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().

void CmiGetDynamicReductionRemote	(	int	handlerIdx,
		int	pe,
		int	dataSize,
		void *	data
	)

Definition at line 2311 of file convcore.c.

References CmiAlloc(), CmiMyPe(), CmiReductionHandleDynamicRequest(), CmiSyncSendAndFree(), msg, size, and values.

void CmiSendReduce ( CmiReduction * red )

void* CmiReduceMergeFn_random	(	int *	size,
		void *	data,
		void **	remote,
		int	n
	)

Definition at line 2368 of file convcore.c.

Referenced by CpdCharmInit(), and CpdSearchLeaks().

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
	)

Definition at line 2476 of file convcore.c.

References CmiListReduce(), and CmiLookupGroup().

void CmiGroupReduceStruct	(	CmiGroup	grp,
		void *	data,
		CmiReducePupFn	pupFn,
		CmiReduceMergeFn	mergeFn,
		CmiHandler	dest,
		CmiReduceDeleteFn	deleteFn,
		CmiReductionID	id
	)

Definition at line 2482 of file convcore.c.

References CmiListReduceStruct(), and CmiLookupGroup().

void CmiNodeReduce	(	void *	data,
		int	size,
		CmiReduceMergeFn	mergeFn,
		int	redID,
		int	numChildren,
		int	parent
	)

Definition at line 2490 of file convcore.c.

References CmiAbort().

Referenced by CmiNodeReduce().

void CmiNodeReduce	(	void *	data,
		int	size,
		void ()(void , void *, int)	mergeFn,
		int	redID
	)

Definition at line 2505 of file convcore.c.

References CmiNodeFirst(), CmiNodeReduce(), CmiNodeSpanTreeParent(), and CmiNumNodeSpanTreeChildren().

void CmiNodeReduce	(	void *	data,
		int	size,
		void ()(void , void *, int)	mergeFn,
		int	numChildren,
		int	parent
	)

Definition at line 2509 of file convcore.c.

References CmiNodeReduce().

void CmiNodeReduce	(	void *	data,
		int	size,
		void ()(void , void *, int)	mergeFn
	)

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
	)

Definition at line 2518 of file convcore.c.

References CmiAbort().

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().

CmiGroup CmiEstablishGroup	(	int	npes,
		int *	pes
	)

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().

void CmiLookupGroup	(	CmiGroup	grp,
		int *	npes,
		int **	pes
	)

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().

void CmiSyncListSendFn	(	int	npes,
		int *	pes,
		int	len,
		char *	msg
	)

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 2678 of file convcore.c.

Referenced by KillOnAllSigs().

void CmiFreeListSendFn	(	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().

void CmiSyncMulticastFn	(	CmiGroup	grp,
		int	len,
		char *	msg
	)

Definition at line 2765 of file convcore.c.

References CmiAlloc(), and CmiMulticastDeliver().

Referenced by CmiFreeMulticastFn(), and CmiSyncMulticast().

void CmiFreeMulticastFn	(	CmiGroup	grp,
		int	len,
		char *	msg
	)

Definition at line 2783 of file convcore.c.

References CmiFree(), and CmiSyncMulticastFn().

Referenced by CmiSyncMulticastAndFree().

CmiCommHandle CmiAsyncMulticastFn	(	CmiGroup	grp,
		int	len,
		char *	msg
	)

Definition at line 2789 of file convcore.c.

References CmiError().

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().

static int roundUpSize ( unsigned int s ) [static]

Definition at line 3075 of file convcore.c.

Referenced by _CmiMultipleSend(), and paddingSize().

static int paddingSize ( unsigned int s ) [static]

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().

void CmiMultipleSend	(	unsigned int	destPE,
		int	len,
		int	sizes[],
		char *	msgComps[]
	)

Definition at line 3196 of file convcore.c.

References _CmiMultipleSend().

Referenced by CldMultipleSend(), and CldMultipleSendPrio().

void CmiMultipleIsend	(	unsigned int	destPE,
		int	len,
		int	sizes[],
		char *	msgComps[]
	)

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().

int HypercubeGetBcastDestinations	(	int	mype,
		int	total_pes,
		int	k,
		int *	dest_pes
	)

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]

Definition at line 3454 of file convcore.c.

References c.

Referenced by CmiEndianness().

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:

A working network layer.
Working Cpv's and CmiNodeBarrier.
CthInit to already have been called. CthInit is called from the machine layer directly, because some machine layers (like uth) use Converse threads internally.

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().