conv-ccs/middle-ccs.C File Reference

Go to the source code of this file.

Typedefs
typedef int	pid_t
Functions
void	CcsHandleRequest (CcsImplHeader *hdr, const char *reqData)
void	req_fw_handler (char *msg)
size_t	write (int fd, const void *buf, size_t count)
int	CcsReply (CcsImplHeader *rep, int repLen, const void *repData)
	Decide if the reply is ready to be forwarded to the waiting client, or if combination is required (for broadcast/multicast CCS requests.
void	ccs_getinfo (char *msg)
	CpvDeclare (void *, debugQueue)
	CpvDeclare (int, freezeModeFlag)
void	CpdFreeze (void)
void	CpdUnFreeze (void)
int	CpdIsFrozen (void)
void	BgProcessMessageFreezeMode (threadInfo *t, char *msg)
void	PrintDebugStackTrace (void *)
void *	MemoryToSlot (void *ptr)
int	Slot_StackTrace (void *s, void ***stack)
int	Slot_ChareOwner (void *s)
void	CpdNotify (int type,...)
Variables
int	rep_fw_handler_idx

---

Typedef Documentation

typedef int pid_t

Definition at line 115 of file middle-ccs.C.

---

Function Documentation

void CcsHandleRequest	(	CcsImplHeader *	hdr,
		const char *	reqData
	)

Definition at line 219 of file conv-ccs.c.

References _conditionalDelivery, bytes, callHandlerRec(), CcsSendReply(), ChMessageInt(), CkHashtableGet(), CmiPrintf(), conditionalPipe, CpdEndConditionalDeliver_master(), free(), CcsImplHeader::handler, CcsImplHeader::len, and malloc().

Referenced by req_fw_handler().

void req_fw_handler

(

char *

msg

)

Definition at line 13 of file middle-ccs.C.

References CcsHandleRequest(), ChMessageInt(), CmiFree(), CmiMyPe(), Converse::CmiSyncBroadcast(), and Converse::CmiSyncSend().

Referenced by CcsInit(), and CpdBgInit().

size_t write	(	int	fd,
		const void *	buf,
		size_t	count
	)

Referenced by ADIOI_HFS_WriteContig(), ADIOI_NFS_Get_shared_fp(), ADIOI_NFS_Set_shared_fp(), ADIOI_NFS_WriteContig(), ADIOI_NFS_WriteStrided(), ADIOI_PIOFS_WriteContig(), ADIOI_PIOFS_WriteStrided(), ADIOI_SFS_WriteContig(), ADIOI_UFS_WriteContig(), arg_init(), CcsReply(), CmiSendMessageXpmem(), CpdFreezeModeScheduler(), CthAliasCreate(), init_ranges(), KillOnAllSigs(), printStats(), and writeCheckpointToDisk().

int CcsReply	(	CcsImplHeader *	rep,
		int	repLen,
		const void *	repData
	)

Decide if the reply is ready to be forwarded to the waiting client, or if combination is required (for broadcast/multicast CCS requests.

Definition at line 56 of file middle-ccs.C.

References _conditionalDelivery, CcsGetHandler(), CcsImpl_reply(), ChMessageInt(), ChMessageInt_new(), BGConverse::CkReduce(), CmiAbort(), CmiAlloc(), CmiListReduce(), conditionalPipe, CcsImplHeader::handler, CcsImplHeader::len, CcsHandlerRec::mergeFn, msg, CcsImplHeader::pe, CcsHandlerRec::redID, and write().

Referenced by CcsNoDelayedReply(), CcsNoReply(), CcsSendDelayedReply(), and CcsSendReply().

void ccs_getinfo

(

char *

msg

)

Definition at line 98 of file middle-ccs.C.

References CcsSendReply(), ChMessageInt_new(), CmiFree(), CmiNodeSize(), free(), malloc(), and n.

Referenced by CcsBuiltinsInit().

CpvDeclare	(	void *	,
		debugQueue
	)

CpvDeclare	(	int	,
		freezeModeFlag
	)

void CpdUnFreeze

(

void

)

Definition at line 141 of file middle-ccs.C.

Referenced by CpdContinueFromBreakPoint().

int CpdIsFrozen

(

void

)

Definition at line 146 of file middle-ccs.C.

Referenced by CpdDebugHandlerStatus(), and CpdDeliverSingleMessage().

void BgProcessMessageFreezeMode	(	threadInfo *	t,
		char *	msg
	)

Definition at line 154 of file middle-ccs.C.

References CdsFifo_Dequeue(), CdsFifo_Empty(), CdsFifo_Enqueue(), and CpdIsDebugMessage.

Referenced by CpdBgInit().

void PrintDebugStackTrace

(

void *

)

void CpdNotify	(	int	type,
			...
	)

Definition at line 180 of file middle-ccs.C.

References CmiBacktraceRecord(), CmiMyPe(), CmiPrintf(), CPD_ABORT, CPD_BREAKPOINT, CPD_CROSSCORRUPTION, CPD_FREEZE, CPD_SIGNAL, integer, list, MemoryToSlot(), ptr, Slot_ChareOwner(), and Slot_StackTrace().

Referenced by _call_freeze_on_break_point(), cpd_memory_single_pup(), CpdFreeze(), KillOnAllSigs(), and SendMsgBuf().

---

Variable Documentation

int rep_fw_handler_idx

Definition at line 51 of file middle-ccs.C.