ConverseScheduler
[Converse]

Collaboration diagram for ConverseScheduler:

The portion of Converse responsible for scheduling the execution of incoming messages. More...


Files
file	convcore.c
	converse main core
file	converse.h
	Main Converse header file.
file	conv-lists.C
	Declarations of CdsFifo* routines.
file	conv-lists.h
	Definitions of CdsFifo routines.
Typedefs
typedef CkQ< void * >	_Fifo
typedef void *	CdsFifo
Functions
void	CsdBeginIdle (void)
void	CsdStillIdle (void)
void	CsdEndIdle (void)
void	CmiHandleMessage (void *msg)
	Takes a message and calls its corresponding handler.
void	CmiDeliversInit ()
int	CmiDeliverMsgs (int maxmsgs)
	CpvDeclare (void *, CsdObjQueue)
void	CsdSchedulerState_new (CsdSchedulerState_t *s)
void *	CsdNextMessage (CsdSchedulerState_t *s)
	Dequeue and return the next message from the message queue.
int	CsdScheduler (int maxmsgs)
void	CkClearAllArrayElements ()
void	machine_OffloadAPIProgress ()
void	CsdScheduleForever (void)
	The main scheduler loop that repeatedly executes messages from a queue, forever.
int	CsdScheduleCount (int maxmsgs)
void	CsdSchedulePoll (void)
void	CmiDeliverSpecificMsg (int handler)
	CpvStaticDeclare (CthThread, CthMainThread)
	CpvStaticDeclare (CthThread, CthSchedulingThread)
	CpvStaticDeclare (CthThread, CthSleepingStandins)
	CpvStaticDeclare (int, CthResumeNormalThreadIdx)
	CpvStaticDeclare (int, CthResumeSchedulingThreadIdx)
void	CthStandinCode ()
static CthThread	CthSuspendNormalThread ()
void	CthEnqueueSchedulingThread (CthThreadToken token, int, int, unsigned int )
CthThread	CthSuspendSchedulingThread ()
void	CthResumeNormalThread (CthThreadToken *token)
void	CthResumeSchedulingThread (CthThreadToken *token)
void	CthEnqueueNormalThread (CthThreadToken token, int s, int pb, unsigned int prio)
void	CthSetStrategyDefault (CthThread t)
void	CthSchedInit ()
void	CsdInit (char **argv)
CdsFifo	CdsFifo_Create (void)
CdsFifo	CdsFifo_Create_len (int len)
void	CdsFifo_Enqueue (CdsFifo q, void *elt)
void *	CdsFifo_Dequeue (CdsFifo q)
void	CdsFifo_Push (CdsFifo q, void *elt)
void *	CdsFifo_Pop (CdsFifo q)
void	CdsFifo_Destroy (CdsFifo q)
void **	CdsFifo_Enumerate (CdsFifo q)
int	CdsFifo_Empty (CdsFifo q)
void *	CdsFifo_Peek (CdsFifo q)
int	CdsFifo_Length (CdsFifo q)
Variables
int	_exitHandlerIdx

Detailed Description

The portion of Converse responsible for scheduling the execution of incoming messages.

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

In converse the CsdScheduleForever() routine will run an infinite while loop that looks for available messages to processes from the message queue. Messages in the queue are dequeued by the CsdNextMessage() routine. When a message is taken from the queue it is then passed into CmiHandleMessage() which calls the handler associated with the message.

Incoming messages that are destined for Charm++ will be passed to the charm scheduling routines.