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

Comparing cvsroot/libcoro/coro.c (file contents):
Revision 1.59 by root, Mon Jun 13 08:38:16 2011 UTC vs.
Revision 1.64 by root, Wed Dec 5 13:01:18 2012 UTC

…		…
1	/*	1	/*
2	* Copyright (c) 2001-2011 Marc Alexander Lehmann <schmorp@schmorp.de>	2	* Copyright (c) 2001-2011 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	*	13	*
14	* 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
15	* WARRANTIES, INCLUDING, BUT NOT LIMITED TO, THE IMPLIED WARRANTIES OF MER-	15	* WARRANTIES, INCLUDING, BUT NOT LIMITED TO, THE IMPLIED WARRANTIES OF MER-
16	* CHANTABILITY AND FITNESS FOR A PARTICULAR PURPOSE ARE DISCLAIMED. IN NO	16	* CHANTABILITY AND FITNESS FOR A PARTICULAR PURPOSE ARE DISCLAIMED. IN NO
17	* 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-
18	* CIAL, EXEMPLARY, OR CONSEQUENTIAL DAMAGES (INCLUDING, BUT NOT LIMITED TO,	18	* CIAL, EXEMPLARY, OR CONSEQUENTIAL DAMAGES (INCLUDING, BUT NOT LIMITED TO,
86	volatile coro_func func = coro_init_func;	86	volatile coro_func func = coro_init_func;
87	volatile void *arg = coro_init_arg;	87	volatile void *arg = coro_init_arg;
88		88
89	coro_transfer (new_coro, create_coro);	89	coro_transfer (new_coro, create_coro);
90		90
91	#if __linux && __amd64	91	#if __GCC_HAVE_DWARF2_CFI_ASM && __amd64
92	/* we blindly assume on any __linux with __amd64 we have a new enough gas with .cfi_undefined support */
93	asm (".cfi_undefined rip");	92	asm (".cfi_undefined rip");
94	#endif	93	#endif
95		94
96	func ((void *)arg);	95	func ((void *)arg);
97		96
…		…
115		114
116	# endif	115	# endif
117		116
118	# if CORO_ASM	117	# if CORO_ASM
119		118
		119	#if _WIN32 \|\| __CYGWIN__
		120	#define CORO_WIN_TIB 1
		121	#endif
		122
120	asm (	123	asm (
121	".text\n"	124	"\t.text\n"
		125	#if _WIN32 \|\| __CYGWIN__
		126	"\t.globl _coro_transfer\n"
		127	"_coro_transfer:\n"
		128	#else
122	".globl coro_transfer\n"	129	"\t.globl coro_transfer\n"
123	".type coro_transfer, @function\n"
124	"coro_transfer:\n"	130	"coro_transfer:\n"
		131	#endif
125	/* windows, of course, gives a shit on the amd64 ABI and uses different registers */	132	/* windows, of course, gives a shit on the amd64 ABI and uses different registers */
126	/* http://blogs.msdn.com/freik/archive/2005/03/17/398200.aspx */	133	/* http://blogs.msdn.com/freik/archive/2005/03/17/398200.aspx */
127	#if __amd64	134	#if __amd64
128	#ifdef _WIN32	135
129	/* TODO: xmm6..15 also would need to be saved. sigh. */	136	#if _WIN32 \|\| __CYGWIN__
130	#define NUM_SAVED 8	137	#define NUM_SAVED 29
131	#undef CORO_WIN_TIB	138	"\tsubq $168, %rsp\t" /* one dummy qword to improve alignment */
		139	"\tmovaps %xmm6, (%rsp)\n"
		140	"\tmovaps %xmm7, 16(%rsp)\n"
		141	"\tmovaps %xmm8, 32(%rsp)\n"
		142	"\tmovaps %xmm9, 48(%rsp)\n"
		143	"\tmovaps %xmm10, 64(%rsp)\n"
		144	"\tmovaps %xmm11, 80(%rsp)\n"
		145	"\tmovaps %xmm12, 96(%rsp)\n"
		146	"\tmovaps %xmm13, 112(%rsp)\n"
		147	"\tmovaps %xmm14, 128(%rsp)\n"
		148	"\tmovaps %xmm15, 144(%rsp)\n"
132	"\tpushq %rsi\n"	149	"\tpushq %rsi\n"
133	"\tpushq %rdi\n"	150	"\tpushq %rdi\n"
134	"\tpushq %rbp\n"	151	"\tpushq %rbp\n"
135	"\tpushq %rbx\n"	152	"\tpushq %rbx\n"
136	"\tpushq %r12\n"	153	"\tpushq %r12\n"
137	"\tpushq %r13\n"	154	"\tpushq %r13\n"
138	"\tpushq %r14\n"	155	"\tpushq %r14\n"
139	"\tpushq %r15\n"	156	"\tpushq %r15\n"
		157	#if CORO_WIN_TIB
		158	"\tpushq %fs:0x0\n"
		159	"\tpushq %fs:0x8\n"
		160	"\tpushq %fs:0xc\n"
		161	#endif
140	"\tmovq %rsp, (%rcx)\n"	162	"\tmovq %rsp, (%rcx)\n"
141	"\tmovq (%rdx), %rsp\n"	163	"\tmovq (%rdx), %rsp\n"
		164	#if CORO_WIN_TIB
		165	"\tpopq %fs:0xc\n"
		166	"\tpopq %fs:0x8\n"
		167	"\tpopq %fs:0x0\n"
		168	#endif
142	"\tpopq %r15\n"	169	"\tpopq %r15\n"
143	"\tpopq %r14\n"	170	"\tpopq %r14\n"
144	"\tpopq %r13\n"	171	"\tpopq %r13\n"
145	"\tpopq %r12\n"	172	"\tpopq %r12\n"
146	"\tpopq %rbx\n"	173	"\tpopq %rbx\n"
147	"\tpopq %rbp\n"	174	"\tpopq %rbp\n"
148	"\tpopq %rdi\n"	175	"\tpopq %rdi\n"
149	"\tpopq %rsi\n"	176	"\tpopq %rsi\n"
		177	"\tmovaps (%rsp), %xmm6\n"
		178	"\tmovaps 16(%rsp), %xmm7\n"
		179	"\tmovaps 32(%rsp), %xmm8\n"
		180	"\tmovaps 48(%rsp), %xmm9\n"
		181	"\tmovaps 64(%rsp), %xmm10\n"
		182	"\tmovaps 80(%rsp), %xmm11\n"
		183	"\tmovaps 96(%rsp), %xmm12\n"
		184	"\tmovaps 112(%rsp), %xmm13\n"
		185	"\tmovaps 128(%rsp), %xmm14\n"
		186	"\tmovaps 144(%rsp), %xmm15\n"
		187	"\taddq $168, %rsp\n"
150	#else	188	#else
151	#define NUM_SAVED 6	189	#define NUM_SAVED 6
152	"\tpushq %rbp\n"	190	"\tpushq %rbp\n"
153	"\tpushq %rbx\n"	191	"\tpushq %rbx\n"
154	"\tpushq %r12\n"	192	"\tpushq %r12\n"
…		…
162	"\tpopq %r13\n"	200	"\tpopq %r13\n"
163	"\tpopq %r12\n"	201	"\tpopq %r12\n"
164	"\tpopq %rbx\n"	202	"\tpopq %rbx\n"
165	"\tpopq %rbp\n"	203	"\tpopq %rbp\n"
166	#endif	204	#endif
		205	"\tpopq %rcx\n"
		206	"\tjmpq *%rcx\n"
		207
167	#elif __i386	208	#elif __i386
		209
168	#define NUM_SAVED 4	210	#define NUM_SAVED 4
169	"\tpushl %ebp\n"	211	"\tpushl %ebp\n"
170	"\tpushl %ebx\n"	212	"\tpushl %ebx\n"
171	"\tpushl %esi\n"	213	"\tpushl %esi\n"
172	"\tpushl %edi\n"	214	"\tpushl %edi\n"
173	#if CORO_WIN_TIB	215	#if CORO_WIN_TIB
		216	#undef NUM_SAVED
		217	#define NUM_SAVED 7
174	"\tpushl %fs:0\n"	218	"\tpushl %fs:0\n"
175	"\tpushl %fs:4\n"	219	"\tpushl %fs:4\n"
176	"\tpushl %fs:8\n"	220	"\tpushl %fs:8\n"
177	#endif	221	#endif
178	"\tmovl %esp, (%eax)\n"	222	"\tmovl %esp, (%eax)\n"
…		…
184	#endif	228	#endif
185	"\tpopl %edi\n"	229	"\tpopl %edi\n"
186	"\tpopl %esi\n"	230	"\tpopl %esi\n"
187	"\tpopl %ebx\n"	231	"\tpopl %ebx\n"
188	"\tpopl %ebp\n"	232	"\tpopl %ebp\n"
		233	"\tpopl %ecx\n"
		234	"\tjmpl *%ecx\n"
		235
189	#else	236	#else
190	#error unsupported architecture	237	#error unsupported architecture
191	#endif	238	#endif
192	"\tret\n"
193	);	239	);
194		240
195	# endif	241	# endif
196		242
197	void	243	void
…		…
270	ctx->env[8] = (long) coro_init;	316	ctx->env[8] = (long) coro_init;
271	ctx->env[7] = (long) ((char *)sptr + ssize) - sizeof (long);	317	ctx->env[7] = (long) ((char *)sptr + ssize) - sizeof (long);
272	#elif __CYGWIN__ && __x86_64	318	#elif __CYGWIN__ && __x86_64
273	ctx->env[7] = (long) coro_init;	319	ctx->env[7] = (long) coro_init;
274	ctx->env[6] = (long) ((char *)sptr + ssize) - sizeof (long);	320	ctx->env[6] = (long) ((char *)sptr + ssize) - sizeof (long);
275	#elif defined(__MINGW32__)	321	#elif defined __MINGW32__
276	ctx->env[5] = (long) coro_init;	322	ctx->env[5] = (long) coro_init;
277	ctx->env[4] = (long) ((char *)sptr + ssize) - sizeof (long);	323	ctx->env[4] = (long) ((char *)sptr + ssize) - sizeof (long);
278	#elif defined(_M_IX86)	324	#elif defined _M_IX86
279	((_JUMP_BUFFER *)&ctx->env)->Eip = (long) coro_init;	325	((_JUMP_BUFFER *)&ctx->env)->Eip = (long) coro_init;
280	((_JUMP_BUFFER *)&ctx->env)->Esp = (long) STACK_ADJUST_PTR (sptr, ssize) - sizeof (long);	326	((_JUMP_BUFFER *)&ctx->env)->Esp = (long) STACK_ADJUST_PTR (sptr, ssize) - sizeof (long);
281	#elif defined(_M_AMD64)	327	#elif defined _M_AMD64
282	((_JUMP_BUFFER *)&ctx->env)->Rip = (__int64) coro_init;	328	((_JUMP_BUFFER *)&ctx->env)->Rip = (__int64) coro_init;
283	((_JUMP_BUFFER *)&ctx->env)->Rsp = (__int64) STACK_ADJUST_PTR (sptr, ssize) - sizeof (__int64);	329	((_JUMP_BUFFER *)&ctx->env)->Rsp = (__int64) STACK_ADJUST_PTR (sptr, ssize) - sizeof (__int64);
284	#elif defined(_M_IA64)	330	#elif defined _M_IA64
285	((_JUMP_BUFFER *)&ctx->env)->StIIP = (__int64) coro_init;	331	((_JUMP_BUFFER *)&ctx->env)->StIIP = (__int64) coro_init;
286	((_JUMP_BUFFER *)&ctx->env)->IntSp = (__int64) STACK_ADJUST_PTR (sptr, ssize) - sizeof (__int64);	332	((_JUMP_BUFFER *)&ctx->env)->IntSp = (__int64) STACK_ADJUST_PTR (sptr, ssize) - sizeof (__int64);
287	#else	333	#else
288	#error "microsoft libc or architecture not supported"	334	#error "microsoft libc or architecture not supported"
289	#endif	335	#endif
…		…
425		471
426	pthread_attr_init (&attr);	472	pthread_attr_init (&attr);
427	#if __UCLIBC__	473	#if __UCLIBC__
428	/* exists, but is borked */	474	/* exists, but is borked */
429	/pthread_attr_setstacksize (&attr, (size_t)ssize);/	475	/pthread_attr_setstacksize (&attr, (size_t)ssize);/
		476	#elif __CYGWIN__
		477	/* POSIX, not here */
		478	pthread_attr_setstacksize (&attr, (size_t)ssize);
430	#else	479	#else
431	pthread_attr_setstack (&attr, sptr, (size_t)ssize);	480	pthread_attr_setstack (&attr, sptr, (size_t)ssize);
432	#endif	481	#endif
433	pthread_attr_setscope (&attr, PTHREAD_SCOPE_PROCESS);	482	pthread_attr_setscope (&attr, PTHREAD_SCOPE_PROCESS);
434	pthread_create (&ctx->id, &attr, coro_init, &args);	483	pthread_create (&ctx->id, &attr, coro_init, &args);
…		…
451	}	500	}
452		501
453	pthread_cond_destroy (&ctx->cv);	502	pthread_cond_destroy (&ctx->cv);
454	}	503	}
455		504
		505	/*****************************************************************************/
		506	/* fiber backend */
		507	/*****************************************************************************/
		508	#elif CORO_FIBER
		509
		510	#define WIN32_LEAN_AND_MEAN
		511	#include <windows.h>
		512
		513	VOID CALLBACK
		514	coro_init (PVOID arg)
		515	{
		516	coro_context ctx = (coro_context )arg;
		517
		518	ctx->coro (ctx->arg);
		519	}
		520
		521	void
		522	coro_transfer (coro_context prev, coro_context next)
		523	{
		524	if (!prev->fiber)
		525	{
		526	prev->fiber = GetCurrentFiber ();
		527
		528	if (prev->fiber == 0 \|\| prev->fiber == (void *)0x1e00)
		529	prev->fiber = ConvertThreadToFiber (0);
		530	}
		531
		532	SwitchToFiber (next->fiber);
		533	}
		534
		535	void
		536	coro_create (coro_context ctx, coro_func coro, void arg, void *sptr, long ssize)
		537	{
		538	ctx->fiber = 0;
		539	ctx->coro = coro;
		540	ctx->arg = arg;
		541
		542	if (!coro)
		543	return;
		544
		545	ctx->fiber = CreateFiber (ssize, coro_init, ctx);
		546	}
		547
		548	void
		549	coro_destroy (coro_context *ctx)
		550	{
		551	DeleteFiber (ctx->fiber);
		552	}
		553
456	#else	554	#else
457	# error unsupported backend	555	# error unsupported backend
458	#endif	556	#endif
459		557

Diff Legend

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

Comparing cvsroot/libcoro/coro.c (file contents): Revision 1.59 by root, Mon Jun 13 08:38:16 2011 UTC vs. Revision 1.64 by root, Wed Dec 5 13:01:18 2012 UTC

Diff Legend

Comparing cvsroot/libcoro/coro.c (file contents):
Revision 1.59 by root, Mon Jun 13 08:38:16 2011 UTC vs.
Revision 1.64 by root, Wed Dec 5 13:01:18 2012 UTC