conv-core/cpath.c File Reference

Go to the source code of this file.

Data Structures
struct	buffer
struct	eltset
struct	single
struct	reduction
Typedefs
typedef struct buffer	buffer
typedef struct eltset *	eltset
typedef struct single *	single
typedef struct reduction *	reduction
Functions
	CpvStaticDeclare (int *, PElist)
	CpvStaticDeclare (char *, PEflags)
	CpvStaticDeclare (int, seqno)
	CpvStaticDeclare (int, CPathSendIdx)
	CpvStaticDeclare (int, CPathReduceIdx)
	CpvStaticDeclare (eltset *, EltsetTable)
	CpvStaticDeclare (int, EltsetTabsize)
	CpvStaticDeclare (single *, SingleTable)
	CpvStaticDeclare (int, SingleTabsize)
	CpvStaticDeclare (reduction *, ReduceTable)
	CpvStaticDeclare (int, ReduceTabsize)
	CtvStaticDeclare (single, thisthread)
static void *	bufalloc (buffer *b, int n)
unsigned int	CPathIndicesToEltno (int nsizes, int *sizes, int *indices)
void	CPathEltnoToIndices (int nsizes, int *sizes, unsigned int eltno, int *indices)
int	CPathMap (CPath *path, int *indices)
int	CPathRoot (CPath *path, int *indices)
void	CPathExecute (single t)
single	CPathGetSingle (CPath *path, int *indices)
eltset	CPathAllocEltset (eltset old, int nlocals)
void	CPathDecrementOdometer (int *odometer, int *sizes, int nvary, int *vary)
eltset	CPathGetEltset (CPath *path, int *indices)
void	CPathSend (int key,...)
void	CPathSendHandler (char *decoded)
void *	CPathRecv (int key,...)
void	CPathMsgDecodeBytes (void *msg, int *len, void *bytes)
void	CPathMsgDecodeReduction (void *msg, int *vecsize, int *eltsize, void *bytes)
void	CPathMsgFree (void *msg)
void	CPathMakeArray (CPath *path, int startfn, int mapfn,...)
void	CPathMergeReduction (reduction red, void *data)
void	CPathReduceMismatch ()
void	CPathCreateRedmsg (reduction red)
reduction	CPathGetReduction (eltset set, int ntags, int *tags, int vecsize, int eltsize, int reducer, CPath *dest, int desteltno)
void	CPathReduceHandler (void *decoded)
void	CPathForwardReduction (reduction red)
void	CPathReduce (int key,...)
void	CPathModuleInit ()

---

Typedef Documentation

typedef struct buffer buffer

Definition at line 14 of file cpath.c.

typedef struct eltset* eltset

Definition at line 15 of file cpath.c.

typedef struct single* single

Definition at line 16 of file cpath.c.

typedef struct reduction* reduction

Definition at line 17 of file cpath.c.

---

Function Documentation

CpvStaticDeclare	(	int *	,
		PElist
	)

CpvStaticDeclare	(	char *	,
		PEflags
	)

CpvStaticDeclare	(	int	,
		seqno
	)

CpvStaticDeclare	(	int	,
		CPathSendIdx
	)

CpvStaticDeclare	(	int	,
		CPathReduceIdx
	)

CpvStaticDeclare	(	eltset *	,
		EltsetTable
	)

CpvStaticDeclare	(	int	,
		EltsetTabsize
	)

CpvStaticDeclare	(	single *	,
		SingleTable
	)

CpvStaticDeclare	(	int	,
		SingleTabsize
	)

CpvStaticDeclare	(	reduction *	,
		ReduceTable
	)

CpvStaticDeclare	(	int	,
		ReduceTabsize
	)

CtvStaticDeclare	(	single	,
		thisthread
	)

static void* bufalloc	(	buffer *	b,
		int	n
	)			[static]

Definition at line 86 of file cpath.c.

References CmiAlloc(), CmiFree(), buffer::data, buffer::fill, and buffer::size.

Referenced by CPathSend().

unsigned int CPathIndicesToEltno	(	int	nsizes,
		int *	sizes,
		int *	indices
	)

Definition at line 113 of file cpath.c.

References size.

Referenced by CPathGetEltset(), CPathGetSingle(), and CPathReduce().

void CPathEltnoToIndices	(	int	nsizes,
		int *	sizes,
		unsigned int	eltno,
		int *	indices
	)

Definition at line 127 of file cpath.c.

References size.

Referenced by CPathExecute(), CPathReduceHandler(), and CPathSend().

int CPathMap	(	CPath *	path,
		int *	indices
	)

Definition at line 152 of file cpath.c.

References CPath::mapfn.

Referenced by CPathGetEltset(), and CPathRoot().

int CPathRoot	(	CPath *	path,
		int *	indices
	)

Definition at line 158 of file cpath.c.

References CPathMap(), CPath::nsizes, and CPath::sizes.

Referenced by CPathSend().

void CPathExecute

(

single

t

)

Definition at line 169 of file cpath.c.

References CPathEltnoToIndices(), single::eltno, CPath::nsizes, single::path, CPath::sizes, and CPath::startfn.

Referenced by CPathGetSingle().

single CPathGetSingle	(	CPath *	path,
		int *	indices
	)

Definition at line 179 of file cpath.c.

References CmmNew(), CPathExecute(), CPathIndicesToEltno(), CPath::creator, CthAwaken(), CthCreate(), single::eltno, malloc(), single::mm, single::next, CPath::nsizes, single::path, CPath::seqno, CPath::sizes, single::thread, and single::waiting.

Referenced by CPathGetEltset().

eltset CPathAllocEltset	(	eltset	old,
		int	nlocals
	)

Definition at line 207 of file cpath.c.

References realloc().

Referenced by CPathGetEltset().

void CPathDecrementOdometer	(	int *	odometer,
		int *	sizes,
		int	nvary,
		int *	vary
	)

Definition at line 212 of file cpath.c.

Referenced by CPathGetEltset().

eltset CPathGetEltset	(	CPath *	path,
		int *	indices
	)

Definition at line 222 of file cpath.c.

References eltset::child1, eltset::child2, CmiMyPe(), CPathAllocEltset(), CPathDecrementOdometer(), CPathGetSingle(), CPathIndicesToEltno(), CPathMap(), CPath::creator, eltset::eltno, eltset::inset, eltset::locals, eltset::next, eltset::nlocals, CPath::nsizes, eltset::parent, eltset::path, eltset::root, CPath::seqno, CPath::sizes, and sizes.

Referenced by CPathReduce(), CPathReduceHandler(), and CPathSendHandler().

void CPathSend	(	int	key,
			...
	)

Definition at line 347 of file cpath.c.

References bufalloc(), CmiAlloc(), CmiError(), Converse::CmiSyncSendAndFree(), CPathEltnoToIndices(), CPathRoot(), buffer::data, reduction::eltsize, buffer::fill, idx, CPath::nsizes, reduction::ntags, p, buffer::size, size, CPath::sizes, reduction::tags, and reduction::vecsize.

Referenced by CPathForwardReduction().

void CPathSendHandler

(

char *

decoded

)

Definition at line 437 of file cpath.c.

References CmiMyPe(), Converse::CmiSyncSend(), CmmPut(), CPathGetEltset(), CthAwaken(), single::mm, CPath::nsizes, reduction::ntags, p, set(), reduction::tags, single::thread, and single::waiting.

Referenced by CPathModuleInit().

void* CPathRecv	(	int	key,
			...
	)

Definition at line 467 of file cpath.c.

References CmiError(), CthSuspend(), single::mm, msg, reduction::ntags, p, reduction::tags, and single::waiting.

void CPathMsgDecodeBytes	(	void *	msg,
		int *	len,
		void *	bytes
	)

Definition at line 509 of file cpath.c.

References CPath::nsizes, reduction::ntags, and reduction::tags.

void CPathMsgDecodeReduction	(	void *	msg,
		int *	vecsize,
		int *	eltsize,
		void *	bytes
	)

Definition at line 521 of file cpath.c.

References CPath::nsizes, reduction::ntags, size, and reduction::tags.

void CPathMsgFree

(

void *

msg

)

Definition at line 535 of file cpath.c.

References CmiFree().

void CPathMakeArray	(	CPath *	path,
		int	startfn,
		int	mapfn,
			...
	)

Definition at line 545 of file cpath.c.

References CmiError(), CmiMyPe(), CPath::creator, CPath::mapfn, CPath::nsizes, p, CPath::seqno, size, CPath::sizes, and CPath::startfn.

void CPathMergeReduction	(	reduction	red,
		void *	data
	)

Definition at line 716 of file cpath.c.

References reduction::anydata, CPathForwardReduction(), reduction::eltsize, reduction::msg_data, reduction::reducer, reduction::vecsize, and reduction::waitcount.

Referenced by CPathReduce(), and CPathReduceHandler().

void CPathReduceMismatch

(

)

Definition at line 579 of file cpath.c.

References CmiError().

Referenced by CPathGetReduction().

void CPathCreateRedmsg

(

reduction

red

)

Definition at line 585 of file cpath.c.

References CmiAlloc(), reduction::dest, reduction::desteltno, eltset::eltno, reduction::eltsize, msg, reduction::msg_begin, reduction::msg_data, reduction::msg_end, reduction::ntags, reduction::over, eltset::path, reduction::reducer, reduction::tags, and reduction::vecsize.

Referenced by CPathGetReduction().

reduction CPathGetReduction	(	eltset	set,
		int	ntags,
		int *	tags,
		int	vecsize,
		int	eltsize,
		int	reducer,
		CPath *	dest,
		int	desteltno
	)

Definition at line 618 of file cpath.c.

References reduction::anydata, CPathCreateRedmsg(), CPathReduceMismatch(), CPath::creator, reduction::dest, reduction::desteltno, reduction::eltsize, malloc(), reduction::next, reduction::ntags, reduction::over, reduction::reducer, CPath::seqno, set(), reduction::tags, reduction::vecsize, and reduction::waitcount.

Referenced by CPathReduce(), and CPathReduceHandler().

void CPathReduceHandler

(

void *

decoded

)

Definition at line 664 of file cpath.c.

References CPathEltnoToIndices(), CPathGetEltset(), CPathGetReduction(), CPathMergeReduction(), data, dest, reduction::desteltno, reduction::eltsize, CPath::nsizes, reduction::ntags, reduction::over, reduction::reducer, CPath::sizes, reduction::tags, and reduction::vecsize.

Referenced by CPathModuleInit().

void CPathForwardReduction

(

reduction

red

)

Definition at line 692 of file cpath.c.

References CmiFree(), Converse::CmiSyncSendAndFree(), CPathSend(), reduction::dest, reduction::desteltno, reduction::eltsize, free(), reduction::msg_begin, reduction::msg_data, reduction::msg_end, reduction::next, reduction::ntags, reduction::over, eltset::parent, reduction::tags, and reduction::vecsize.

Referenced by CPathMergeReduction().

void CPathReduce	(	int	key,
			...
	)

Definition at line 728 of file cpath.c.

References CmiError(), CPathGetEltset(), CPathGetReduction(), CPathIndicesToEltno(), CPathMergeReduction(), data, dest, reduction::desteltno, reduction::eltsize, CPath::nsizes, reduction::ntags, reduction::over, p, reduction::reducer, CPath::sizes, reduction::tags, and reduction::vecsize.

void CPathModuleInit

(

)

Definition at line 792 of file cpath.c.

References calloc(), CmiRegisterHandler(), CPathReduceHandler(), CPathSendHandler(), and malloc().