conv-ldb/cldb.neighbor.c File Reference

Go to the source code of this file.

Data Structures
struct	CldProcInfo_s
Typedefs
typedef struct CldProcInfo_s *	CldProcInfo
Functions
void	gengraph (int, int, int, int *, int *)
	CpvStaticDeclare (CldProcInfo, CldData)
	CpvStaticDeclare (int, CldLoadResponseHandlerIndex)
	CpvStaticDeclare (int, CldAskLoadHandlerIndex)
	CpvStaticDeclare (int, MinLoad)
	CpvStaticDeclare (int, MinProc)
	CpvStaticDeclare (int, Mindex)
	CpvStaticDeclare (int, start)
	CpvStaticDeclare (loadmsg *, msgpool)
static loadmsg *	getPool ()
static void	putPool (loadmsg *msg)
void	LoadNotifyFn (int l)
char *	CldGetStrategy (void)
static void	CldBeginIdle (void *dummy)
static void	CldEndIdle (void *dummy)
static void	CldStillIdle (void *dummy, double curT)
static void	CldAskLoadHandler (requestmsg *msg)
void	CldSendLoad ()
int	CldMinAvg ()
void	CldBalance (void *dummy, double curT)
void	CldBalancePeriod (void *dummy, double curT)
void	CldLoadResponseHandler (loadmsg *msg)
void	CldBalanceHandler (void *msg)
void	CldHandler (void *msg)
void	CldEnqueueGroup (CmiGroup grp, void *msg, int infofn)
void	CldEnqueueMulti (int npes, int *pes, void *msg, int infofn)
void	CldEnqueue (int pe, void *msg, int infofn)
void	CldNodeEnqueue (int node, void *msg, int infofn)
void	CldReadNeighborData ()
static void	CldComputeNeighborData ()
static void	topo_callback ()
void	CldGraphModuleInit (char **argv)
void	CldModuleInit (char **argv)
Variables
static int	LBPeriod = PERIOD
static int	overload_threshold = MAXOVERLOAD
char *	_lbtopo
int	_lbsteal = 0

---

Typedef Documentation

typedef struct CldProcInfo_s * CldProcInfo

---

Function Documentation

void gengraph	(	int	,
		int	,
		int	,
		int *	,
		int *
	)

Referenced by CldGraphModuleInit(), LBTopo_graph_nc< dimension >::neighbors(), and LBTopo_graph::neighbors().

CpvStaticDeclare	(	CldProcInfo	,
		CldData
	)

CpvStaticDeclare	(	int	,
		CldLoadResponseHandlerIndex
	)

CpvStaticDeclare	(	int	,
		CldAskLoadHandlerIndex
	)

CpvStaticDeclare	(	int	,
		MinLoad
	)

CpvStaticDeclare	(	int	,
		MinProc
	)

CpvStaticDeclare	(	int	,
		Mindex
	)

CpvStaticDeclare	(	int	,
		start
	)

CpvStaticDeclare	(	loadmsg *	,
		msgpool
	)

static loadmsg* getPool

(

)

[inline, static]

Definition at line 48 of file cldb.neighbor.c.

References CmiAlloc(), msg, and msgpool.

Referenced by CldSendLoad(), and recv_callback().

static void putPool

(

loadmsg *

msg

)

[inline, static]

Definition at line 65 of file cldb.neighbor.c.

References msgpool.

Referenced by CldLoadResponseHandler(), drop_send_callback(), PumpEvents(), recv_callback(), and send_callback().

void LoadNotifyFn

(

int

l

)

Definition at line 73 of file cldb.neighbor.c.

References CldProcInfo_s::sent.

char* CldGetStrategy

(

void

)

Definition at line 79 of file cldb.neighbor.c.

static void CldBeginIdle

(

void *

dummy

)

[static]

Definition at line 85 of file cldb.neighbor.c.

References CmiWallTimer().

Referenced by CldGraphModuleInit(), and CldOtherInit().

static void CldEndIdle

(

void *

dummy

)

[static]

Definition at line 90 of file cldb.neighbor.c.

Referenced by CldOtherInit().

static void CldStillIdle	(	void *	dummy,
		double	curT
	)			[static]

Definition at line 95 of file cldb.neighbor.c.

References CldCountTokens(), CmiMyPe(), CmiNodeOf(), CmiRankOf(), Converse::CmiSyncMulticast(), CmiWallTimer(), requestmsg_s::from_pe, CldProcInfo_s::idleEvt, CldProcInfo_s::lastCheck, msg, CldProcInfo_s::sent, startT, requestmsg_s::to_rank, and traceUserBracketEvent().

Referenced by CldGraphModuleInit(), and CldOtherInit().

static void CldAskLoadHandler

(

requestmsg *

msg

)

[static]

Definition at line 134 of file cldb.neighbor.c.

References CldCountTokens(), CldMultipleSend(), CmiDelayImmediate(), CmiFree(), CmiMyRank(), CmiTryLock(), CmiUnlock(), CmiWallTimer(), requestmsg_s::from_pe, CldProcInfo_s::idleprocEvt, requestmsg_s::to_rank, and traceUserBracketEvent().

Referenced by CldGraphModuleInit(), and CldModuleInit().

void CldSendLoad

(

)

Definition at line 178 of file cldb.neighbor.c.

References CldCountTokens(), CmiMyPe(), Converse::CmiSyncMulticast(), Converse::CmiSyncSendAndFree(), getPool(), and msg.

Referenced by CldBalance().

int CldMinAvg

(

)

Definition at line 221 of file cldb.neighbor.c.

References CldCountTokens(), CldLoadRank(), and CmiMyPe().

Referenced by CldBalance(), CldEnqueue(), and CldNodeEnqueue().

void CldBalance	(	void *	dummy,
		double	curT
	)

Definition at line 260 of file cldb.neighbor.c.

References CldCountTokens(), CldMinAvg(), CldMultipleSend(), CldSendLoad(), CldSimpleMultipleSend(), CmiMyRank(), CmiWallTimer(), startT, and traceUserBracketEvent().

Referenced by CldBalancePeriod().

void CldBalancePeriod	(	void *	dummy,
		double	curT
	)

Definition at line 319 of file cldb.neighbor.c.

References CcdCallFnAfterOnPE(), CldBalance(), and CmiMyPe().

Referenced by topo_callback().

void CldLoadResponseHandler

(

loadmsg *

msg

)

Definition at line 326 of file cldb.neighbor.c.

References CmiFree(), CmiWallTimer(), putPool(), startT, and traceUserBracketEvent().

Referenced by CldGraphModuleInit().

void CldBalanceHandler

(

void *

msg

)

Definition at line 360 of file cldb.neighbor.c.

References CldPutToken(), and CldRestoreHandler().

void CldHandler

(

void *

msg

)

Definition at line 366 of file cldb.neighbor.c.

References CldRestoreHandler().

void CldEnqueueGroup	(	CmiGroup	grp,
		void *	msg,
		int	infofn
	)

Definition at line 378 of file cldb.neighbor.c.

References CldSwitchHandler(), and Converse::CmiSyncMulticastAndFree().

void CldEnqueueMulti	(	int	npes,
		int *	pes,
		void *	msg,
		int	infofn
	)

Definition at line 394 of file cldb.neighbor.c.

References CldSwitchHandler(), and Converse::CmiSyncListSendAndFree().

void CldEnqueue	(	int	pe,
		void *	msg,
		int	infofn
	)

Definition at line 415 of file cldb.neighbor.c.

References CldCountTokens(), CldMinAvg(), CldNodeEnqueue(), CldPutToken(), CldSwitchHandler(), CmiMyPe(), CmiNodeOf(), Converse::CmiSyncBroadcastAllAndFree(), Converse::CmiSyncBroadcastAndFree(), and Converse::CmiSyncSendAndFree().

void CldNodeEnqueue	(	int	node,
		void *	msg,
		int	infofn
	)

Definition at line 475 of file cldb.neighbor.c.

References CldCountTokens(), CldMinAvg(), CldSwitchHandler(), CmiMyPe(), and CmiNodeOf().

void CldReadNeighborData

(

)

Definition at line 525 of file cldb.neighbor.c.

References calloc(), CmiError(), CmiEstablishGroup(), CmiMyPe(), and CldNeighborData::pe.

Referenced by CldGraphModuleInit().

static void CldComputeNeighborData

(

)

[static]

Definition at line 553 of file cldb.neighbor.c.

References _lbtopo, calloc(), CmiAbort(), CmiEstablishGroup(), CmiMyPe(), CmiPrintf(), free(), getTopoMaxNeighbors(), getTopoNeighbors(), LBTopoLookup(), malloc(), printoutTopo(), and ptr.

Referenced by topo_callback().

static void topo_callback

(

)

[static]

Definition at line 601 of file cldb.neighbor.c.

References CldBalancePeriod(), CldComputeNeighborData(), CmiNodeBarrier(), and CmiWallTimer().

Referenced by CldGraphModuleInit().

void CldGraphModuleInit

(

char **

argv

)

Definition at line 610 of file cldb.neighbor.c.

References _lbtopo, CcdCallOnCondition(), CcdCallOnConditionKeep(), CldAskLoadHandler(), CldBalanceHandler(), CldBeginIdle(), CldLoadResponseHandler(), CldReadNeighborData(), CldStillIdle(), CmiAlloc(), CmiGetArgFlagDesc(), CmiGetArgIntDesc(), CmiGetArgStringDesc(), CmiMyPe(), CmiMyRank(), CmiPrintf(), CmiRegisterHandler(), gengraph(), topo_callback(), and traceRegisterUserEvent().

Referenced by CldModuleInit().

---

Variable Documentation

int LBPeriod = PERIOD [static]

Definition at line 16 of file cldb.neighbor.c.

int overload_threshold = MAXOVERLOAD [static]

Definition at line 17 of file cldb.neighbor.c.

int _lbsteal = 0

Definition at line 29 of file cldb.neighbor.c.