[ViewVC] Diff of: cvs/cvsroot/libcoro/coro.c

Comparing cvsroot/libcoro/coro.c (file contents):
Revision 1.7 by root, Mon Sep 3 03:42:13 2001 UTC vs.
Revision 1.35 by root, Mon Nov 3 16:05:38 2008 UTC

…		…
1	/*	1	/*
2	* Copyright (c) 2001 Marc Alexander Lehmann <pcg@goof.com>	2	* Copyright (c) 2001-2008 Marc Alexander Lehmann <schmorp@schmorp.de>
3	*	3	*
4	* Redistribution and use in source and binary forms, with or without modifica-	4	* Redistribution and use in source and binary forms, with or without modifica-
5	* tion, are permitted provided that the following conditions are met:	5	* tion, are permitted provided that the following conditions are met:
6	*	6	*
7	* 1. Redistributions of source code must retain the above copyright notice,	7	* 1. Redistributions of source code must retain the above copyright notice,
8	* this list of conditions and the following disclaimer.	8	* this list of conditions and the following disclaimer.
9	*	9	*
10	* 2. Redistributions in binary form must reproduce the above copyright	10	* 2. Redistributions in binary form must reproduce the above copyright
11	* notice, this list of conditions and the following disclaimer in the	11	* notice, this list of conditions and the following disclaimer in the
12	* documentation and/or other materials provided with the distribution.	12	* documentation and/or other materials provided with the distribution.
13	*
14	* 3. The name of the author may not be used to endorse or promote products
15	* derived from this software without specific prior written permission.
16	*	13	*
17	* THIS SOFTWARE IS PROVIDED BY THE AUTHOR ``AS IS'' AND ANY EXPRESS OR IMPLIED	14	* THIS SOFTWARE IS PROVIDED BY THE AUTHOR ``AS IS'' AND ANY EXPRESS OR IMPLIED
18	* WARRANTIES, INCLUDING, BUT NOT LIMITED TO, THE IMPLIED WARRANTIES OF MER-	15	* WARRANTIES, INCLUDING, BUT NOT LIMITED TO, THE IMPLIED WARRANTIES OF MER-
19	* CHANTABILITY AND FITNESS FOR A PARTICULAR PURPOSE ARE DISCLAIMED. IN NO	16	* CHANTABILITY AND FITNESS FOR A PARTICULAR PURPOSE ARE DISCLAIMED. IN NO
20	* EVENT SHALL THE AUTHOR BE LIABLE FOR ANY DIRECT, INDIRECT, INCIDENTAL, SPE-	17	* EVENT SHALL THE AUTHOR BE LIABLE FOR ANY DIRECT, INDIRECT, INCIDENTAL, SPE-
23	* OR BUSINESS INTERRUPTION) HOWEVER CAUSED AND ON ANY THEORY OF LIABILITY,	20	* OR BUSINESS INTERRUPTION) HOWEVER CAUSED AND ON ANY THEORY OF LIABILITY,
24	* WHETHER IN CONTRACT, STRICT LIABILITY, OR TORT (INCLUDING NEGLIGENCE OR OTH-	21	* WHETHER IN CONTRACT, STRICT LIABILITY, OR TORT (INCLUDING NEGLIGENCE OR OTH-
25	* ERWISE) ARISING IN ANY WAY OUT OF THE USE OF THIS SOFTWARE, EVEN IF ADVISED	22	* ERWISE) ARISING IN ANY WAY OUT OF THE USE OF THIS SOFTWARE, EVEN IF ADVISED
26	* OF THE POSSIBILITY OF SUCH DAMAGE.	23	* OF THE POSSIBILITY OF SUCH DAMAGE.
27	*	24	*
		25	* Alternatively, the contents of this file may be used under the terms of
		26	* the GNU General Public License ("GPL") version 2 or any later version,
		27	* in which case the provisions of the GPL are applicable instead of
		28	* the above. If you wish to allow the use of your version of this file
		29	* only under the terms of the GPL and not to allow others to use your
		30	* version of this file under the BSD license, indicate your decision
		31	* by deleting the provisions above and replace them with the notice
		32	* and other provisions required by the GPL. If you do not delete the
		33	* provisions above, a recipient may use your version of this file under
		34	* either the BSD or the GPL.
		35	*
28	* This library is modelled strictly after Ralf S. Engelschalls article at	36	* This library is modelled strictly after Ralf S. Engelschalls article at
29	* http://www.gnu.org/software/pth/rse-pmt.ps. So most of the credit must	37	* http://www.gnu.org/software/pth/rse-pmt.ps. So most of the credit must
30	* go to Ralf S. Engelschall <rse@engelschall.com>.	38	* go to Ralf S. Engelschall <rse@engelschall.com>.
31	*/	39	*/
32		40
33	#include "coro.h"	41	#include "coro.h"
34		42
		43	#if !defined(STACK_ADJUST_PTR)
35	/* IRIX is decidedly NON-unix */	44	/* IRIX is decidedly NON-unix */
36	#if __sgi	45	# if __sgi
37	# define STACK_ADJUST(sp,ss) ((char *)(sp) + (ss) - 8)	46	# define STACK_ADJUST_PTR(sp,ss) ((char *)(sp) + (ss) - 8)
		47	# define STACK_ADJUST_SIZE(sp,ss) ((ss) - 8)
		48	# elif (__i386__ && CORO_LINUX) \|\| (_M_IX86 && CORO_LOSER)
		49	# define STACK_ADJUST_PTR(sp,ss) ((char *)(sp) + (ss))
		50	# define STACK_ADJUST_SIZE(sp,ss) (ss)
		51	# elif (__amd64__ && CORO_LINUX) \|\| ((_M_AMD64 \|\| _M_IA64) && CORO_LOSER)
		52	# define STACK_ADJUST_PTR(sp,ss) ((char *)(sp) + (ss) - 8)
		53	# define STACK_ADJUST_SIZE(sp,ss) (ss)
38	#else	54	# else
39	# define STACK_ADJUST(sp,ss) (sp)	55	# define STACK_ADJUST_PTR(sp,ss) (sp)
		56	# define STACK_ADJUST_SIZE(sp,ss) (ss)
40	#endif	57	# endif
		58	#endif
41		59
		60	#if CORO_UCONTEXT
		61	# include <stddef.h>
		62	#endif
		63
42	#if CORO_SJLJ \|\| CORO_LOOSE \|\| CORO_LINUX \|\| CORO_IRIX	64	#if CORO_SJLJ \|\| CORO_LOSER \|\| CORO_LINUX \|\| CORO_IRIX \|\| CORO_ASM
43		65
		66	#include <stdlib.h>
		67
		68	#if CORO_SJLJ
		69	# include <stdio.h>
44	#include <signal.h>	70	# include <signal.h>
		71	# include <unistd.h>
		72	#endif
45		73
46	static volatile coro_func coro_init_func;	74	static volatile coro_func coro_init_func;
47	static volatile void *coro_init_arg;	75	static volatile void *coro_init_arg;
48	static volatile coro_context new_coro, create_coro;	76	static volatile coro_context new_coro, create_coro;
49		77
		78	/* what we really want to detect here is wether we use a new-enough version of GAS */
		79	/* instead, check for gcc 3, ELF and GNU/Linux and hope for the best */
		80	#if __GNUC__ >= 3 && __ELF__ && __linux__
		81	# define HAVE_CFI 1
		82	#endif
		83
50	static void	84	static void
51	coro_init (void)	85	coro_init (void)
52	{	86	{
53	volatile coro_func func = coro_init_func;	87	volatile coro_func func = coro_init_func;
54	volatile void *arg = coro_init_arg;	88	volatile void *arg = coro_init_arg;
…		…
65		99
66	static volatile int trampoline_count;	100	static volatile int trampoline_count;
67		101
68	/* trampoline signal handler */	102	/* trampoline signal handler */
69	static void	103	static void
70	trampoline(int sig)	104	trampoline (int sig)
71	{	105	{
72	if (setjmp (((coro_context *)new_coro)->env))	106	if (setjmp (((coro_context *)new_coro)->env))
		107	{
		108	#if HAVE_CFI
		109	asm (".cfi_startproc");
		110	#endif
73	coro_init (); /* start it */	111	coro_init (); /* start it */
		112	#if HAVE_CFI
		113	asm (".cfi_endproc");
		114	#endif
		115	}
74	else	116	else
75	trampoline_count++;	117	trampoline_count++;
76	}	118	}
77		119
78	# endif	120	# endif
79		121
80	#endif	122	#endif
81		123
		124	#if CORO_ASM
		125	asm (
		126	".text\n"
		127	".globl coro_transfer\n"
		128	".type coro_transfer, @function\n"
		129	"coro_transfer:\n"
		130	#if __amd64
		131	# define NUM_SAVED 5
		132	"\tpush %rbx\n"
		133	"\tpush %r12\n"
		134	"\tpush %r13\n"
		135	"\tpush %r14\n"
		136	"\tpush %r15\n"
		137	"\tmov %rsp, (%rdi)\n"
		138	"\tmov (%rsi), %rsp\n"
		139	"\tpop %r15\n"
		140	"\tpop %r14\n"
		141	"\tpop %r13\n"
		142	"\tpop %r12\n"
		143	"\tpop %rbx\n"
		144	#elif __i386
		145	# define NUM_SAVED 4
		146	"\tpush %ebx\n"
		147	"\tpush %esi\n"
		148	"\tpush %edi\n"
		149	"\tpush %ebp\n"
		150	"\tmov %esp, (%eax)\n"
		151	"\tmov (%edx), %esp\n"
		152	"\tpop %ebp\n"
		153	"\tpop %edi\n"
		154	"\tpop %esi\n"
		155	"\tpop %ebx\n"
		156	#else
		157	# error unsupported architecture
		158	#endif
		159	"\tret\n"
		160	);
		161	#endif
		162
		163	#if CORO_PTHREAD
		164
		165	struct coro_init_args {
		166	coro_func func;
		167	void *arg;
		168	coro_context self, main;
		169	};
		170
		171	pthread_mutex_t coro_mutex = PTHREAD_MUTEX_INITIALIZER;
		172
		173	static void *
		174	trampoline (void *args_)
		175	{
		176	struct coro_init_args args = (struct coro_init_args )args_;
		177	coro_func func = args->func;
		178	void *arg = args->arg;
		179
		180	pthread_mutex_lock (&coro_mutex);
		181	pthread_cond_destroy (&args->self->c);
		182	coro_transfer (args->self, args->main);
		183	func (arg);
		184	pthread_mutex_unlock (&coro_mutex);
		185
		186	return 0;
		187	}
		188
		189	asm("");
		190
		191	void coro_transfer(coro_context prev, coro_context next)
		192	{
		193	pthread_cond_init (&prev->c, 0);
		194	pthread_cond_signal (&next->c);
		195	pthread_cond_wait (&prev->c, &coro_mutex);
		196	pthread_cond_destroy (&prev->c);
		197	}
		198
		199	#endif
		200
82	/* initialize a machine state */	201	/* initialize a machine state */
83	void coro_create(coro_context *ctx,	202	void coro_create (coro_context *ctx,
84	coro_func coro, void *arg,	203	coro_func coro, void *arg,
85	void *sptr, long ssize)	204	void *sptr, long ssize)
86	{	205	{
87	#if CORO_UCONTEXT	206	#if CORO_UCONTEXT
88		207
89	getcontext (&(ctx->uc));	208	getcontext (&(ctx->uc));
90		209
91	ctx->uc.uc_link = 0;	210	ctx->uc.uc_link = 0;
92	ctx->uc.uc_stack.ss_sp = STACK_ADJUST(sptr,ssize);	211	ctx->uc.uc_stack.ss_sp = STACK_ADJUST_PTR (sptr,ssize);
93	ctx->uc.uc_stack.ss_size = (size_t) ssize;	212	ctx->uc.uc_stack.ss_size = (size_t) STACK_ADJUST_SIZE (sptr,ssize);
94	ctx->uc.uc_stack.ss_flags = 0;	213	ctx->uc.uc_stack.ss_flags = 0;
95		214
96	makecontext (&(ctx->uc), (void (*)()) coro, 1, arg);	215	makecontext (&(ctx->uc), (void (*)()) coro, 1, arg);
97		216
98	#elif CORO_SJLJ \|\| CORO_LOOSE \|\| CORO_LINUX \|\| CORO_IRIX	217	#elif CORO_SJLJ \|\| CORO_LOSER \|\| CORO_LINUX \|\| CORO_IRIX \|\| CORO_ASM
99		218
100	# if CORO_SJLJ	219	# if CORO_SJLJ
101	stack_t ostk, nstk;	220	stack_t ostk, nstk;
102	struct sigaction osa, nsa;	221	struct sigaction osa, nsa;
103	sigset_t nsig, osig;	222	sigset_t nsig, osig;
…		…
120	nsa.sa_handler = trampoline;	239	nsa.sa_handler = trampoline;
121	sigemptyset (&nsa.sa_mask);	240	sigemptyset (&nsa.sa_mask);
122	nsa.sa_flags = SA_ONSTACK;	241	nsa.sa_flags = SA_ONSTACK;
123		242
124	if (sigaction (SIGUSR2, &nsa, &osa))	243	if (sigaction (SIGUSR2, &nsa, &osa))
		244	{
125	perror ("sigaction");	245	perror ("sigaction");
		246	abort ();
		247	}
126		248
127	/* set the new stack */	249	/* set the new stack */
128	nstk.ss_sp = STACK_ADJUST(sptr,ssize); /* yes, some platforms (IRIX) get this wrong. */	250	nstk.ss_sp = STACK_ADJUST_PTR (sptr,ssize); /* yes, some platforms (IRIX) get this wrong. */
129	nstk.ss_size = ssize;	251	nstk.ss_size = STACK_ADJUST_SIZE (sptr,ssize);
130	nstk.ss_flags = 0;	252	nstk.ss_flags = 0;
131		253
132	if (sigaltstack (&nstk, &ostk) < 0)	254	if (sigaltstack (&nstk, &ostk) < 0)
		255	{
133	perror ("sigaltstack");	256	perror ("sigaltstack");
		257	abort ();
		258	}
134		259
135	trampoline_count = 0;	260	trampoline_count = 0;
136	kill (getpid (), SIGUSR2);	261	kill (getpid (), SIGUSR2);
137	sigfillset (&nsig); sigdelset (&nsig, SIGUSR2);	262	sigfillset (&nsig); sigdelset (&nsig, SIGUSR2);
138		263
…		…
149	abort ();	274	abort ();
150		275
151	if (~ostk.ss_flags & SS_DISABLE)	276	if (~ostk.ss_flags & SS_DISABLE)
152	sigaltstack (&ostk, 0);	277	sigaltstack (&ostk, 0);
153		278
154	sigaction (SIGUSR1, &osa, 0);	279	sigaction (SIGUSR2, &osa, 0);
155		280
156	sigprocmask (SIG_SETMASK, &osig, 0);	281	sigprocmask (SIG_SETMASK, &osig, 0);
157		282
158	# elif CORO_LOOSE	283	# elif CORO_LOSER
159		284
160	setjmp (ctx->env);	285	setjmp (ctx->env);
		286	#if __CYGWIN__
161	ctx->env[7] = (int)((char *)sptr + ssize);	287	ctx->env[7] = (long)((char *)sptr + ssize);
162	ctx->env[8] = (int)coro_init;	288	ctx->env[8] = (long)coro_init;
		289	#elif defined(_M_IX86)
		290	((_JUMP_BUFFER *)&ctx->env)->Eip = (long)coro_init;
		291	((_JUMP_BUFFER *)&ctx->env)->Esp = (long)STACK_ADJUST_PTR (sptr, ssize);
		292	#elif defined(_M_AMD64)
		293	((_JUMP_BUFFER *)&ctx->env)->Rip = (__int64)coro_init;
		294	((_JUMP_BUFFER *)&ctx->env)->Rsp = (__int64)STACK_ADJUST_PTR (sptr, ssize);
		295	#elif defined(_M_IA64)
		296	((_JUMP_BUFFER *)&ctx->env)->StIIP = (__int64)coro_init;
		297	((_JUMP_BUFFER *)&ctx->env)->IntSp = (__int64)STACK_ADJUST_PTR (sptr, ssize);
		298	#else
		299	# error "microsoft libc or architecture not supported"
		300	#endif
163		301
164	# elif CORO_LINUX	302	# elif CORO_LINUX
165		303
166	setjmp (ctx->env);	304	_setjmp (ctx->env);
167	#if defined(__GLIBC__) && defined(__GLIBC_MINOR__) \
168	&& __GLIBC__ >= 2 && __GLIBC_MINOR__ >= 0 && defined(JB_PC) && defined(JB_SP)	305	#if __GLIBC__ >= 2 && __GLIBC_MINOR__ >= 0 && defined (JB_PC) && defined (JB_SP)
169	ctx->env[0].__jmpbuf[JB_PC] = (int)coro_init;	306	ctx->env[0].__jmpbuf[JB_PC] = (long)coro_init;
170	ctx->env[0].__jmpbuf[JB_SP] = (int)((char *)sptr + ssize);	307	ctx->env[0].__jmpbuf[JB_SP] = (long)STACK_ADJUST_PTR (sptr, ssize);
171	#elif defined(__GLIBC__) && defined(__GLIBC_MINOR__) \
172	&& __GLIBC__ >= 2 && __GLIBC_MINOR__ >= 0 && defined(__mc68000__)	308	#elif __GLIBC__ >= 2 && __GLIBC_MINOR__ >= 0 && defined (__mc68000__)
173	ctx->env[0].__jmpbuf[0].__aregs[0] = (long int)coro_init;	309	ctx->env[0].__jmpbuf[0].__aregs[0] = (long int)coro_init;
174	ctx->env[0].__jmpbuf[0].__sp = (int )((char )sptr + ssize);	310	ctx->env[0].__jmpbuf[0].__sp = (int )((char )sptr + ssize);
175	#elif defined(__GNU_LIBRARY__) && defined(__i386__)	311	#elif defined (__GNU_LIBRARY__) && defined (__i386__)
176	ctx->env[0].__jmpbuf[0].__pc = (char *)coro_init;	312	ctx->env[0].__jmpbuf[0].__pc = (char *)coro_init;
177	ctx->env[0].__jmpbuf[0].__sp = (void )((char )sptr + ssize);	313	ctx->env[0].__jmpbuf[0].__sp = (void )((char )sptr + ssize);
		314	#elif defined (__GNU_LIBRARY__) && defined (__amd64__)
		315	ctx->env[0].__jmpbuf[JB_PC] = (long)coro_init;
		316	ctx->env[0].__jmpbuf[JB_RSP] = (long)STACK_ADJUST_PTR (sptr, ssize);
178	#else	317	#else
179	#error "linux libc or architecture not supported"	318	# error "linux libc or architecture not supported"
180	#endif	319	#endif
181		320
182	# elif CORO_IRIX	321	# elif CORO_IRIX
183		322
184	setjmp (ctx->env);	323	setjmp (ctx->env);
185	ctx->env[JB_PC] = (__uint64_t)coro_init;	324	ctx->env[JB_PC] = (__uint64_t)coro_init;
186	ctx->env[JB_SP] = (__uint64_t)STACK_ADJUST(sptr,ssize);	325	ctx->env[JB_SP] = (__uint64_t)STACK_ADJUST_PTR (sptr, ssize);
		326
		327	# elif CORO_ASM
		328
		329	ctx->sp = (volatile void *)(ssize + (char )sptr);
		330	/* we try to allow for both functions with and without frame pointers */
		331	--ctx->sp = (void )coro_init;
		332	{
		333	int i;
		334	for (i = NUM_SAVED; i--; )
		335	*--ctx->sp = 0;
		336	}
187		337
188	# endif	338	# endif
189		339
190	coro_transfer ((coro_context )create_coro, (coro_context )new_coro);	340	coro_transfer ((coro_context )create_coro, (coro_context )new_coro);
191		341
		342	# elif CORO_PTHREAD
		343
		344	pthread_t id;
		345	pthread_attr_t attr;
		346	coro_context nctx;
		347	struct coro_init_args args;
		348	static int once;
		349
		350	if (!once)
		351	{
		352	pthread_mutex_lock (&coro_mutex);
		353	once = 1;
		354	}
		355
		356	args.func = coro;
		357	args.arg = arg;
		358	args.self = ctx;
		359	args.main = &nctx;
		360
		361	pthread_attr_init (&attr);
		362	pthread_attr_setdetachstate (&attr, PTHREAD_CREATE_DETACHED);
		363	pthread_attr_setstack (&attr, sptr, (size_t)ssize);
		364	pthread_create (&id, &attr, trampoline, &args);
		365
		366	pthread_cond_init (&args.self->c, 0);
		367	coro_transfer (args.main, args.self);
		368
192	#else	369	#else
193	error unsupported architecture	370	# error unsupported backend
194	#endif	371	#endif
195	}	372	}
196		373

Diff Legend

-–
+Removed lines
-+
+Added lines
-<
+Changed lines
->
+Changed lines

Comparing cvsroot/libcoro/coro.c (file contents): Revision 1.7 by root, Mon Sep 3 03:42:13 2001 UTC vs. Revision 1.35 by root, Mon Nov 3 16:05:38 2008 UTC

Diff Legend

Comparing cvsroot/libcoro/coro.c (file contents):
Revision 1.7 by root, Mon Sep 3 03:42:13 2001 UTC vs.
Revision 1.35 by root, Mon Nov 3 16:05:38 2008 UTC