conv-core/threads.c File Reference

"suspend", "resume", "free", and "data" fields must all already be set. When this thread exits, l->free will be called on this listener, which should deallocate the listener memory.

Definition at line 667 of file threads.c.

References CthThreadListener::next, p, and CthThreadListener::thread.

Referenced by CkMigratable::CkAddThreadListeners(), and TraceProjections::traceAddThreadListeners().

CthThread CthPup	(	pup_er	p,
		CthThread	t
	)

Definition at line 732 of file threads.c.

References CmiAbort(), CthFree(), CthPupBase(), malloc(), pup_bytes(), pup_isDeleting(), and pup_isUnpacking().

Referenced by TCharm::pupThread().

CthCpvDeclare	(	CthProcInfo	,
		CthProc
	)

static void CthThreadInit	(	CthThread	t,
		CthVoidFn	fn,
		void *	arg
	)			`[static]`

Definition at line 763 of file threads.c.

References CthThreadStruct::base, CthThreadBaseInit(), CthThreadStruct::savedptr, CthThreadStruct::savedsize, CthThreadStruct::savedstack, CthThreadStruct::stacklen, CthThreadStruct::startarg, and CthThreadStruct::startfn.

Referenced by CthCreate(), CthCreateInner(), and CthInit().

static void CthThreadFree ( CthThread t ) [static]

Definition at line 774 of file threads.c.

References CthThreadStruct::base, CthThreadBaseFree(), free(), and CthThreadStruct::savedstack.

Referenced by CthAbortHelp(), CthClearThreads(), CthFiberBlock(), CthFree(), and CthResume1().

void CthFree ( CthThread t )

Definition at line 781 of file threads.c.

References CthThreadStruct::base, CthClearThreads(), CthSelf(), CthThreadFree(), and CthThreadBase::exiting.

Referenced by TCharm::clear(), CpmThread3(), Cpthread_exit(), CthPup(), and TCharm::~TCharm().

void CthDummy ( )

Definition at line 793 of file threads.c.

Referenced by CthInit(), and CthResume1().

void CthInit ( char ** argv )

Definition at line 795 of file threads.c.

References CmiThreadIs_flag, CthBaseInit(), CthDummy(), CthThreadInit(), malloc(), and p.

Referenced by CommunicationServer(), ConverseInit(), ConverseRunPE(), KillOnAllSigs(), and threadInit().

static void CthOnly	(	CthThread	t,
		void *	dum1,
		void *	dum2
	)			`[static]`

Definition at line 830 of file threads.c.

References CthThreadFinished(), CthThreadStruct::startarg, and CthThreadStruct::startfn.

Referenced by CthResume1().

size_t CthStackOffset	(	CthThread	t,
		char *	p
	)

Definition at line 839 of file threads.c.

References s, and CthProcInfo::stackbase.

Referenced by TCharm::UserData::UserData().

char* CthPointer	(	CthThread	t,
		size_t	pos
	)

Definition at line 845 of file threads.c.

References p, CthThreadStruct::savedsize, and CthThreadStruct::savedstack.

Referenced by TCharm::UserData::getData(), and TCharm::UserData::pup().

static void CthResume1	(	qt_t *	sp,
		CthProcInfo	proc,
		CthThread	t
	)			`[static]`

Definition at line 857 of file threads.c.

References CthThreadStruct::base, bytes, CthBaseResume(), CthDummy(), CthOnly(), CthThreadFree(), CthThreadBase::exiting, free(), malloc(), CthThreadStruct::savedptr, CthThreadStruct::savedsize, CthThreadStruct::savedstack, CthProcInfo::stackbase, and CthThreadStruct::stacklen.

Referenced by CthResume().

void CthResume ( CthThread t )

Definition at line 897 of file threads.c.

References CthThreadStruct::base, CthBaseResume(), CthFiberBlock(), CthResume1(), CthThreadBase::exiting, CthThreadStruct::fiber, CthProcInfo::switchbuf_sp, and SwitchToFiber().

Referenced by CmiNext(), CthResumeNormalThread(), CthResumeSchedulingThread(), CthSuspend(), and PythonObject::execute().

CthThread CthCreate	(	CthVoidFn	fn,
		void *	arg,
		int	size
	)

CthThread CthCreateMigratable	(	CthVoidFn	fn,
		void *	arg,
		int	size
	)

Definition at line 911 of file threads.c.

References CthCreate(), and size.

Referenced by TCharm::TCharm().

WINBASEAPI LPVOID WINAPI CreateFiber	(	DWORD	dwStackSize,
		LPFIBER_START_ROUTINE	lpStartAddress,
		LPVOID	lpParameter
	)

Referenced by CthCreate().

WINBASEAPI VOID WINAPI DeleteFiber ( LPVOID lpFiber )

WINBASEAPI LPVOID WINAPI ConvertThreadToFiber ( LPVOID lpParameter )

WINBASEAPI VOID WINAPI SwitchToFiber ( LPVOID lpFiber )

Referenced by CthFiberBlock(), and CthResume().

WINBASEAPI BOOL WINAPI SwitchToThread ( VOID )

CthCpvStatic	(	CthThread	,
		CthPrevious
	)

CthCpvStatic	(	threadTable	,
		exitThreads
	)

CthCpvStatic	(	int	,
		nExit
	)

static void CthThreadInit ( CthThread t ) [static]

Definition at line 991 of file threads.c.

References CthThreadStruct::base, and CthThreadBaseInit().

static void CthClearThreads ( ) [static]

Definition at line 1025 of file threads.c.

References CthThreadFree(), n, and p.

Referenced by CthFree(), and FiberSetUp().

void CthFiberBlock ( CthThread t )

Definition at line 1071 of file threads.c.

References CthThreadFree(), CthThreadStruct::fiber, and SwitchToFiber().

Referenced by CthResume().

VOID CALLBACK FiberSetUp ( PVOID fiberData )

Definition at line 1101 of file threads.c.

References CthClearThreads(), CthSelf(), CthThreadFinished(), and ptr.

Referenced by CthCreate().


Data Structures
struct	CthThreadBase
struct	CthThreadStruct
struct	CthProcInfo
struct	CthThreadStruct
struct	CthThreadStruct
struct	CthThreadStruct
struct	CthThreadStruct
Typedefs
typedef CthProcInfo *	CthProcInfo
typedef VOID(WINAPI *)	PFIBER_START_ROUTINE (LPVOID lpFiberParameter)
typedef PFIBER_START_ROUTINE	LPFIBER_START_ROUTINE
typedef CthThread	threadTable [100]
typedef void(*)	uJcontext_fn_t (void)
Functions
int	CmiThreadIs (int flag)
CthThreadToken *	CthGetToken (CthThread t)
int	CthAliasCreate (int stackSize)
	Create an aliasable area of this size.
void	CthAliasFree (int fd)
void	CthAliasEnable (CthThreadBase *t)
	CthCpvStatic (CthThread, CthCurrent)
	CthCpvDeclare (char *, CthData)
	CthCpvStatic (int, CthDatasize)
void	CthSetThreadID (CthThread th, int a, int b, int c)
CmiObjId *	CthGetThreadID (CthThread th)
char *	CthGetData (CthThread t)
static void	CthFixData (CthThread t)
int	CthRegister (int size)
	Allocate another size bytes of thread-local storage, and return the offset into the thread storage buffer.
void	CthRegistered (int maxOffset)
	Make sure we have room to store up to at least maxOffset bytes of thread-local storage.
	CthCpvStatic (int, _defaultStackSize)
static void	CthThreadBaseInit (CthThreadBase *th)
static void *	CthAllocateStack (CthThreadBase th, int stackSize, int useMigratable)
static void	CthThreadBaseFree (CthThreadBase *th)
	CpvDeclare (int, _numSwitches)
static void	CthBaseInit (char **argv)
int	CthImplemented ()
CthThread	CthSelf ()
void	CthPupBase (pup_er p, CthThreadBase *t, int useMigratable)
static void	CthThreadFinished (CthThread t)
void	CthSetSuspendable (CthThread t, int val)
int	CthIsSuspendable (CthThread t)
void	CthSetNext (CthThread t, CthThread v)
CthThread	CthGetNext (CthThread t)
static void	CthNoStrategy (void)
void	CthSetStrategy (CthThread t, CthAwkFn awkfn, CthThFn chsfn)
static void	CthBaseResume (CthThread t)
void	CthSwitchThread (CthThread t)
	switch the thread to t
void	CthSuspend (void)
void	CthAwaken (CthThread th)
void	CthYield ()
void	CthAwakenPrio (CthThread th, int s, int pb, unsigned int *prio)
void	CthYieldPrio (int s, int pb, unsigned int *prio)
void	CthAddListener (CthThread t, struct CthThreadListener *l)
	This listener is about to begin receiving suspend and resume events for this thread.
CthThread	CthPup (pup_er p, CthThread t)
	CthCpvDeclare (CthProcInfo, CthProc)
static void	CthThreadInit (CthThread t, CthVoidFn fn, void *arg)
static void	CthThreadFree (CthThread t)
void	CthFree (CthThread t)
void	CthDummy ()
void	CthInit (char **argv)
static void	CthOnly (CthThread t, void dum1, void dum2)
size_t	CthStackOffset (CthThread t, char *p)
char *	CthPointer (CthThread t, size_t pos)
static void	CthResume1 (qt_t *sp, CthProcInfo proc, CthThread t)
void	CthResume (CthThread t)
CthThread	CthCreate (CthVoidFn fn, void *arg, int size)
CthThread	CthCreateMigratable (CthVoidFn fn, void *arg, int size)
WINBASEAPI LPVOID WINAPI	CreateFiber (DWORD dwStackSize, LPFIBER_START_ROUTINE lpStartAddress, LPVOID lpParameter)
WINBASEAPI VOID WINAPI	DeleteFiber (LPVOID lpFiber)
WINBASEAPI LPVOID WINAPI	ConvertThreadToFiber (LPVOID lpParameter)
WINBASEAPI VOID WINAPI	SwitchToFiber (LPVOID lpFiber)
WINBASEAPI BOOL WINAPI	SwitchToThread (VOID)
	CthCpvStatic (CthThread, CthPrevious)
	CthCpvStatic (threadTable, exitThreads)
	CthCpvStatic (int, nExit)
static void	CthThreadInit (CthThread t)
static void	CthClearThreads ()
void	CthFiberBlock (CthThread t)
VOID CALLBACK	FiberSetUp (PVOID fiberData)
	CthCpvStatic (pthread_mutex_t, sched_mutex)
	The sched_mutex is the current token of execution.
static void *	CthOnly (void *arg)
	CpvStaticDeclare (CthThread, doomedThreadPool)
void	CthStartThread (CmiUInt4 fn1, CmiUInt4 fn2, CmiUInt4 arg1, CmiUInt4 arg2)
void	CthStartThread (qt_userf_t fn, void *arg)
int	ptrDiffLen (const void a, const void b)
static CthThread	CthCreateInner (CthVoidFn fn, void *arg, int size, int migratable)
void	setProtection (char , char , int, int)
static CthThread	CthThreadInit (void)
static void *	CthAbortHelp (qt_t sp, CthThread old, void null)
static void *	CthBlockHelp (qt_t sp, CthThread old, void null)
static void	CthOnly (void arg, void vt, qt_userf_t fn)
void	CthTraceResume (CthThread t)
Variables
static int	CmiThreadIs_flag = 0
CthThreadBase *	_curMappedStack = 0
	CthAliasEnable brings this thread's stack into memory.