conv-core/futures.c File Reference

Go to the source code of this file.

Data Structures
struct	Cfuture_data_s
struct	CfutureValue_s
Typedefs
typedef struct Cfuture_data_s *	futdata
typedef struct CfutureValue_s *	CfutureValue
Functions
	CpvDeclare (int, CfutureStoreIndex)
Cfuture	CfutureCreate ()
static void	CfutureAwaken (futdata data, CfutureValue val)
static void	CfutureStore (CfutureValue m)
void *	CfutureCreateBuffer (int bytes)
void	CfutureDestroyBuffer (void *v)
void	CfutureStoreBuffer (Cfuture f, void *value)
void	CfutureSet (Cfuture f, void *value, int len)
void *	CfutureWait (Cfuture f)
void	CfutureDestroy (Cfuture f)
void	CfutureModuleInit ()

---

Typedef Documentation

typedef struct Cfuture_data_s * futdata

typedef struct CfutureValue_s * CfutureValue

---

Function Documentation

CpvDeclare	(	int	,
		CfutureStoreIndex
	)

Cfuture CfutureCreate

(

void

)

Definition at line 27 of file futures.c.

References CmiMyPe(), Cfuture_s::data, data, malloc(), Cfuture_s::pe, Cfuture_data_s::ready, Cfuture_data_s::value, and Cfuture_data_s::waiters.

static void CfutureAwaken	(	futdata	data,
		CfutureValue	val
	)			[static]

Definition at line 40 of file futures.c.

References CthAwaken(), CthGetNext(), Cfuture_data_s::ready, Cfuture_data_s::value, and Cfuture_data_s::waiters.

Referenced by CfutureStore(), and CfutureStoreBuffer().

static void CfutureStore

(

CfutureValue

m

)

[static]

Definition at line 50 of file futures.c.

References CfutureAwaken(), and CfutureValue_s::data.

Referenced by CfutureModuleInit().

void* CfutureCreateBuffer

(

int

bytes

)

Definition at line 55 of file futures.c.

References CmiAlloc().

Referenced by CfutureSet().

void CfutureDestroyBuffer

(

void *

v

)

Definition at line 64 of file futures.c.

References CmiFree().

void CfutureStoreBuffer	(	Cfuture	f,
		void *	value
	)

Definition at line 69 of file futures.c.

References CfutureAwaken(), CmiMyPe(), Converse::CmiSyncSendAndFree(), CfutureValue_s::data, Cfuture_s::data, Cfuture_s::pe, and CfutureValue_s::valsize.

Referenced by CfutureSet().

void CfutureSet	(	Cfuture	f,
		void *	value,
		int	len
	)

Definition at line 80 of file futures.c.

References CfutureCreateBuffer(), CfutureStoreBuffer(), and copy().

void* CfutureWait

(

Cfuture

f

)

Definition at line 87 of file futures.c.

References CmiMyPe(), CmiPrintf(), CthSelf(), CthSetNext(), CthSuspend(), Cfuture_s::data, data, Cfuture_s::pe, Cfuture_data_s::ready, CfutureValue_s::rest, Cfuture_data_s::value, value, and Cfuture_data_s::waiters.

void CfutureDestroy

(

Cfuture

f

)

Definition at line 105 of file futures.c.

References CmiFree(), CmiMyPe(), CmiPrintf(), Cfuture_s::data, free(), Cfuture_s::pe, Cfuture_data_s::value, and Cfuture_data_s::waiters.

void CfutureModuleInit

(

)

Definition at line 119 of file futures.c.

References CfutureStore(), and CmiRegisterHandler().