diff options
Diffstat (limited to 'libthreads/cthread_internals.h')
| -rw-r--r-- | libthreads/cthread_internals.h | 324 |
1 files changed, 324 insertions, 0 deletions
diff --git a/libthreads/cthread_internals.h b/libthreads/cthread_internals.h new file mode 100644 index 00000000..81e3b91c --- /dev/null +++ b/libthreads/cthread_internals.h @@ -0,0 +1,324 @@ +/* + * Mach Operating System + * Copyright (c) 1992,1991,1990,1989 Carnegie Mellon University + * All Rights Reserved. + * + * Permission to use, copy, modify and distribute this software and its + * documentation is hereby granted, provided that both the copyright + * notice and this permission notice appear in all copies of the + * software, derivative works or modified versions, and any portions + * thereof, and that both notices appear in supporting documentation. + * + * CARNEGIE MELLON ALLOWS FREE USE OF THIS SOFTWARE IN ITS "AS IS" + * CONDITION. CARNEGIE MELLON DISCLAIMS ANY LIABILITY OF ANY KIND FOR + * ANY DAMAGES WHATSOEVER RESULTING FROM THE USE OF THIS SOFTWARE. + * + * Carnegie Mellon requests users of this software to return to + * + * Software Distribution Coordinator or Software.Distribution@CS.CMU.EDU + * School of Computer Science + * Carnegie Mellon University + * Pittsburgh PA 15213-3890 + * + * any improvements or extensions that they make and grant Carnegie Mellon + * the rights to redistribute these changes. + */ +/* + * HISTORY + * 26-Oct-94 Johannes Helander (jvh) Helsinki University of Technology + * Defined WAIT_DEBUG and initialized wait_enum + * + * $Log: cthread_internals.h,v $ + * Revision 1.6 2002/05/27 02:50:10 roland + * 2002-05-26 Roland McGrath <roland@frob.com> + * + * Changes merged from CMU MK83a version: + * * cthreads.h, options.h: Various cleanups. + * * call.c, cthread_data.c, sync.c, mig_support.c: Likewise. + * * i386/cthreads.h, i386/thread.c, i386/lock.s: Likewise. + * * cthread_internals.h: Add decls for internal functions. + * (struct cproc): Use vm_offset_t for stack_base and stack_size members. + * Use natural_t for context member. + * * cprocs.c: Use prototypes for all defns. + * * cthreads.c: Likewise. + * (cthread_exit): Cast any_t to integer_t before int. + * + * Revision 2.17 93/05/10 21:33:36 rvb + * Context is a natural_t. Assumming, that is, that on + * some future architecture one word might be enough. + * [93/05/06 09:19:35 af] + * + * Revision 2.16 93/05/10 17:51:23 rvb + * Flush stdlib + * [93/05/05 09:12:29 rvb] + * + * Revision 2.15 93/01/14 18:04:56 danner + * Added declarations for library-internal routines. + * [92/12/18 pds] + * + * Replaced malloc and mach_error declarations with includes of + * mach_error.h and stdlib.h. + * [92/06/13 pds] + * 64bit cleanup. + * [92/12/01 af] + * + * Revision 2.14 92/08/03 18:03:56 jfriedl + * Made state element of struct cproc volatile. + * [92/08/02 jfriedl] + * + * Revision 2.13 92/03/06 14:09:24 rpd + * Added yield, defined using thread_switch. + * [92/03/06 rpd] + * + * Revision 2.12 92/03/01 00:40:23 rpd + * Removed exit declaration. It conflicted with the real thing. + * [92/02/29 rpd] + * + * Revision 2.11 91/08/28 11:19:23 jsb + * Fixed MACH_CALL to allow multi-line expressions. + * [91/08/23 rpd] + * + * Revision 2.10 91/07/31 18:33:33 dbg + * Protect against redefinition of ASSERT. + * [91/07/30 17:33:21 dbg] + * + * Revision 2.9 91/05/14 17:56:24 mrt + * Correcting copyright + * + * Revision 2.8 91/02/14 14:19:42 mrt + * Added new Mach copyright + * [91/02/13 12:41:02 mrt] + * + * Revision 2.7 90/11/05 14:36:55 rpd + * Added spin_lock_t. + * [90/10/31 rwd] + * + * Revision 2.6 90/09/09 14:34:51 rpd + * Remove special field. + * [90/08/24 rwd] + * + * Revision 2.5 90/06/02 15:13:44 rpd + * Converted to new IPC. + * [90/03/20 20:52:47 rpd] + * + * Revision 2.4 90/03/14 21:12:11 rwd + * Added waiting_for field for debugging deadlocks. + * [90/03/01 rwd] + * Added list field to keep a master list of all cprocs. + * [90/03/01 rwd] + * + * Revision 2.3 90/01/19 14:37:08 rwd + * Keep track of real thread for use in thread_* substitutes. + * Add CPROC_ARUN for about to run and CPROC_HOLD to avoid holding + * spin_locks over system calls. + * [90/01/03 rwd] + * Add busy field to be used by cthread_msg calls to make sure we + * have the right number of blocked kernel threads. + * [89/12/21 rwd] + * + * Revision 2.2 89/12/08 19:53:28 rwd + * Added CPROC_CONDWAIT state + * [89/11/28 rwd] + * Added on_special field. + * [89/11/26 rwd] + * Removed MSGOPT conditionals + * [89/11/25 rwd] + * Removed old debugging code. Add wired port/flag. Add state + * for small state machine. + * [89/10/30 rwd] + * Added CPDEBUG code + * [89/10/26 rwd] + * Change TRACE to {x;} else. + * [89/10/24 rwd] + * Rewrote to work for limited number of kernel threads. This is + * basically a merge of coroutine and thread. Added + * cthread_receivce call for use by servers. + * [89/10/23 rwd] + * + */ +/* + * cthread_internals.h + * + * + * Private definitions for the C Threads implementation. + * + * The cproc structure is used for different implementations + * of the basic schedulable units that execute cthreads. + * + */ + + +#include "options.h" +#include <mach/port.h> +#include <mach/message.h> +#include <mach/thread_switch.h> + +#if !defined(__STDC__) && !defined(volatile) +# ifdef __GNUC__ +# define volatile __volatile__ +# else +# define volatile /* you lose */ +# endif +#endif + +/* Type of the TCB. */ +typedef struct +{ + void *tcb; /* Points to this structure. */ + void *dtv; /* Vector of pointers to TLS data. */ + thread_t self; /* This thread's control port. */ +} tcbhead_t; + +/* + * Low-level thread implementation. + * This structure must agree with struct ur_cthread in cthreads.h + */ +typedef struct cproc { + struct cproc *next; /* for lock, condition, and ready queues */ + cthread_t incarnation; /* for cthread_self() */ + + struct cproc *list; /* for master cproc list */ +#ifdef WAIT_DEBUG + volatile char *waiting_for; /* address of mutex/cond waiting for */ +#endif /* WAIT_DEBUG */ + +#if 0 + /* This is not needed in GNU; libc handles it. */ + mach_port_t reply_port; /* for mig_get_reply_port() */ +#endif + + natural_t context; + spin_lock_t lock; + volatile int state; /* current state */ +#define CPROC_RUNNING 0 +#define CPROC_SWITCHING 1 +#define CPROC_BLOCKED 2 +#define CPROC_CONDWAIT 4 + + mach_port_t wired; /* is cthread wired to kernel thread */ + void *busy; /* used with cthread_msg calls */ + + mach_msg_header_t msg; + + vm_offset_t stack_base; + vm_offset_t stack_size; +} *cproc_t; + +#define NO_CPROC ((cproc_t) 0) +#define cproc_self() ((cproc_t) ur_cthread_self()) + +#if 0 +/* This declaration conflicts with <stdlib.h> in GNU. */ +/* + * C Threads imports: + */ +extern char *malloc(); +#endif + +/* + * Mach imports: + */ +extern void mach_error(); + +/* + * Macro for MACH kernel calls. + */ +#ifdef CHECK_STATUS +#define MACH_CALL(expr, ret) \ + if (((ret) = (expr)) != KERN_SUCCESS) { \ + quit(1, "error in %s at %d: %s\n", __FILE__, __LINE__, \ + mach_error_string(ret)); \ + } else +#else /* CHECK_STATUS */ +#define MACH_CALL(expr, ret) (ret) = (expr) +#endif /* CHECK_STATUS */ + +#define private static +#ifndef ASSERT +#define ASSERT(x) +#endif +#define TRACE(x) + +/* + * What we do to yield the processor: + * (This depresses the thread's priority for up to 10ms.) + */ + +#define yield() \ + (void) thread_switch(MACH_PORT_NULL, SWITCH_OPTION_DEPRESS, 10) + +/* + * Functions implemented in malloc.c. + */ + +#if defined(DEBUG) +extern void print_malloc_free_list(void); +#endif /* defined(DEBUG) */ + +extern void malloc_fork_prepare(void); + +extern void malloc_fork_parent(void); + +extern void malloc_fork_child(void); + + +/* + * Functions implemented in stack.c. + */ + +extern vm_offset_t stack_init(cproc_t _cproc); + +extern void alloc_stack(cproc_t _cproc); + +extern vm_offset_t cproc_stack_base(cproc_t _cproc, int _offset); + +extern void stack_fork_child(void); + +/* + * Functions implemented in cprocs.c. + */ + +extern vm_offset_t cproc_init(void); + +extern void cproc_waiting(cproc_t _waiter); + +extern void cproc_block(void); + +extern cproc_t cproc_create(void); + +extern void cproc_fork_prepare(void); + +extern void cproc_fork_parent(void); + +extern void cproc_fork_child(void); + +/* + * Function implemented in cthreads.c. + */ + +extern void cthread_body(cproc_t _self); + +/* + * Functions from machine dependent files. + */ + +extern void cproc_switch(natural_t *_cur, const natural_t *_new, + spin_lock_t *_lock); + +extern void cproc_start_wait(natural_t *_parent, cproc_t _child, + vm_offset_t _stackp, + spin_lock_t *_lock); + +extern void cproc_prepare(cproc_t _child, + natural_t *_child_context, + vm_offset_t _stackp, + void (*cthread_body_pc)()); + +extern void cproc_setup(cproc_t _child, thread_t _mach_thread, + tcbhead_t *tcb, void (*_routine)(cproc_t)); + + +/* From glibc. */ + +/* Dynamic linker TLS allocation. */ +extern void *_dl_allocate_tls(void *); |