Converse Machine Layer
[Converse]

Collaboration diagram for 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:


Files
file	machine.c
	MPI based machine layer.
file	immediate.c
	Immediate message implementation.
file	machine-smp.c
	Common function reimplementation for SMP machines OS Threads.
file	machine-smp.h
	structures for the SMP versions
file	machine.h
	common machine header
file	pcqueue.h
	Producer-Consumer Queues This queue implementation enables a producer and a consumer to communicate via a queue.
file	persist-comm.c
	Support for persistent communication setup.
file	machine.c
	VMI machine layer.
file	machine.h
	VMI machine layer.
Modules
	NET
	NET implementation of machine layer, ethernet in particular THE DATAGRAM STREAM.
Data Structures
struct	CmiIdleLock
struct	CmiStateStruct
struct	CmiNodeStateStruct
struct	CmiMemorySMPSeparation_t
	This data type is at least one cache line of padding, used to avoid cache line thrashing on SMP systems. More...
struct	CircQueueStruct
	The simple version of pcqueue has dropped the function of being expanded if the queue is full. More...
struct	PCQueueStruct
struct	_PersistentRequestMsg
struct	_PersistentReqGrantedMsg
struct	_PersistentDestoryMsg
Typedefs
typedef struct CmiStateStruct *	CmiState
typedef struct CmiNodeStateStruct	CmiNodeState
typedef struct CircQueueStruct *	CircQueue
typedef struct PCQueueStruct *	PCQueue
typedef struct _PersistentRequestMsg	PersistentRequestMsg
typedef struct _PersistentReqGrantedMsg	PersistentReqGrantedMsg
typedef struct _PersistentDestoryMsg	PersistentDestoryMsg
Functions
void	CmiPushImmediateMsg (void *msg)
void	CmiDelayImmediate ()
void	CmiHandleImmediateMessage (void *msg)
void	CmiHandleImmediate ()
void	CmiStateInit (int pe, int rank, CmiState state)
void	CommunicationServerInit ()
CmiState	CmiGetState ()
CmiNodeLock	CmiCreateLock (void)
void	CmiDestroyLock (CmiNodeLock lk)
void	CmiYield (void)
static DWORD WINAPI	call_startfn (LPVOID vindex)
void	CmiNodeBarrierCount (int nThreads)
static void	CmiStartThreads (char **argv)
static void	CmiDestoryLocks ()
void	CmiCommLock (void)
void	CmiCommUnlock (void)
static void *	call_startfn (void *vindex)
static PCQueue	PCQueueCreate (void)
static void	PCQueueDestroy (PCQueue Q)
static int	PCQueueEmpty (PCQueue Q)
static int	PCQueueLength (PCQueue Q)
static char *	PCQueueTop (PCQueue Q)
static char *	PCQueuePop (PCQueue Q)
	CpvDeclare (PersistentSendsTable *, persistentSendsTableHead)
	CpvDeclare (PersistentSendsTable *, persistentSendsTableTail)
	CpvDeclare (int, persistentSendsTableCount)
	CpvDeclare (PersistentReceivesTable *, persistentReceivesTableHead)
	CpvDeclare (PersistentReceivesTable *, persistentReceivesTableTail)
	CpvDeclare (int, persistentReceivesTableCount)
	CpvDeclare (PersistentHandle *, phs)
	CpvDeclare (int, phsSize)
	CpvDeclare (int, curphs)
void	initRecvSlot (PersistentReceivesTable *slot)
void	initSendSlot (PersistentSendsTable *slot)
void	swapSendSlotBuffers (PersistentSendsTable *slot)
void	swapRecvSlotBuffers (PersistentReceivesTable *slot)
PersistentHandle	getFreeSendSlot ()
PersistentHandle	getFreeRecvSlot ()
PersistentHandle	CmiCreatePersistent (int destPE, int maxBytes)
PersistentHandle	CmiCreateNodePersistent (int destNode, int maxBytes)
static void	persistentRequestHandler (void *env)
static void	persistentReqGrantedHandler (void *env)
PersistentReq	CmiCreateReceiverPersistent (int maxBytes)
PersistentHandle	CmiRegisterReceivePersistent (PersistentReq recvHand)
void	persistentDestoryHandler (void *env)
void	CmiDestoryPersistent (PersistentHandle h)
void	CmiDestoryAllPersistent ()
void	CmiPersistentInit ()
void	CmiUsePersistentHandle (PersistentHandle *p, int n)
void	CmiPersistentOneSend ()
Variables
int	_immediateReady = 0
int	_immRunning = 0
static void *	currentImmediateMsg = NULL
static struct CmiStateStruct	Cmi_default_state
CmiNodeLock	CmiMemLock_lock
CmiNodeLock	cmiMemoryLock
static HANDLE	comm_mutex
static DWORD	Cmi_state_key = 0xFFFFFFFF
static CmiState	Cmi_state_vector = 0
static volatile HANDLE	barrier_mutex = PTHREAD_MUTEX_INITIALIZER
static volatile int	barrier_wait [2] = {0,0}
static volatile int	barrier_which = 0
int	_Cmi_noprocforcommthread = 0
static __thread struct CmiStateStruct	Cmi_mystate
int	barrier = 0
pthread_cond_t	barrier_cond = PTHREAD_COND_INITIALIZER
static int	comm_mutex_isLocked = 0
FILE *	debugLog
int	CircQueueStruct::push
CmiMemorySMPSeparation_t	CircQueueStruct::pad1
int	CircQueueStruct::pull
CmiMemorySMPSeparation_t	CircQueueStruct::pad2
char *	CircQueueStruct::data [PCQueueSize]
CmiMemorySMPSeparation_t	PCQueueStruct::pad1
CircQueue CMK_SMP_volatile	PCQueueStruct::tail
CmiMemorySMPSeparation_t	PCQueueStruct::pad2
int	PCQueueStruct::len
CmiNodeLock	PCQueueStruct::lock
int	persistentRequestHandlerIdx
int	persistentReqGrantedHandlerIdx
int	persistentDestoryHandlerIdx
CmiNodeLock	CmiMemLock_lock
CmiNodeLock	cmiMemoryLock

Detailed Description

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:

These files describe the common characteristics of all implementations, and provide converse, and every language built on top of it the same functional interface in all machines, however different they are.

In addition to these common files, there are files called "machine.c" which are the real implementation for the different architectures. Every file is in a different directory, and get selected for compilation at compile time through the "build" script. With this implementation, only one single machine layer can be compiled into the runtime system. Changing architecture needs a different compilation.