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

Comparing libcoro/coro.c (file contents):
Revision 1.62 by root, Mon Aug 8 22:00:18 2011 UTC vs.
Revision 1.63 by root, Wed Dec 5 01:09:12 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,
114		114
115	# endif	115	# endif
116		116
117	# if CORO_ASM	117	# if CORO_ASM
118		118
119	#if _WIN32	119	#if _WIN32 \|\| __CYGWIN__
120	#define CORO_WIN_TIB 1	120	#define CORO_WIN_TIB 1
121	#endif	121	#endif
122		122
123	asm (	123	asm (
124	"\t.text\n"	124	"\t.text\n"
		125	#if _WIN32 \|\| __CYGWIN__
		126	"\t.globl _coro_transfer\n"
		127	"_coro_transfer:\n"
		128	#else
125	"\t.globl coro_transfer\n"	129	"\t.globl coro_transfer\n"
126	"coro_transfer:\n"	130	"coro_transfer:\n"
		131	#endif
127	/* 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 */
128	/* http://blogs.msdn.com/freik/archive/2005/03/17/398200.aspx */	133	/* http://blogs.msdn.com/freik/archive/2005/03/17/398200.aspx */
129	#if __amd64	134	#if __amd64
130	#ifdef WIN32	135
131	/* TODO: xmm6..15 also would need to be saved. sigh. */	136	#if _WIN32 \|\| __CYGWIN__
132	#define NUM_SAVED 8	137	#define NUM_SAVED 29
		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"
133	"\tpushq %rsi\n"	149	"\tpushq %rsi\n"
134	"\tpushq %rdi\n"	150	"\tpushq %rdi\n"
135	"\tpushq %rbp\n"	151	"\tpushq %rbp\n"
136	"\tpushq %rbx\n"	152	"\tpushq %rbx\n"
137	"\tpushq %r12\n"	153	"\tpushq %r12\n"
…		…
156	"\tpopq %r12\n"	172	"\tpopq %r12\n"
157	"\tpopq %rbx\n"	173	"\tpopq %rbx\n"
158	"\tpopq %rbp\n"	174	"\tpopq %rbp\n"
159	"\tpopq %rdi\n"	175	"\tpopq %rdi\n"
160	"\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"
161	#else	188	#else
162	#define NUM_SAVED 6	189	#define NUM_SAVED 6
163	"\tpushq %rbp\n"	190	"\tpushq %rbp\n"
164	"\tpushq %rbx\n"	191	"\tpushq %rbx\n"
165	"\tpushq %r12\n"	192	"\tpushq %r12\n"
…		…
173	"\tpopq %r13\n"	200	"\tpopq %r13\n"
174	"\tpopq %r12\n"	201	"\tpopq %r12\n"
175	"\tpopq %rbx\n"	202	"\tpopq %rbx\n"
176	"\tpopq %rbp\n"	203	"\tpopq %rbp\n"
177	#endif	204	#endif
		205	"\tpopq %rcx\n"
		206	"\tjmpq *%rcx\n"
		207
178	#elif __i386	208	#elif __i386
		209
179	#define NUM_SAVED 4	210	#define NUM_SAVED 4
180	"\tpushl %ebp\n"	211	"\tpushl %ebp\n"
181	"\tpushl %ebx\n"	212	"\tpushl %ebx\n"
182	"\tpushl %esi\n"	213	"\tpushl %esi\n"
183	"\tpushl %edi\n"	214	"\tpushl %edi\n"
184	#if CORO_WIN_TIB	215	#if CORO_WIN_TIB
		216	#undef NUM_SAVED
		217	#define NUM_SAVED 7
185	"\tpushl %fs:0\n"	218	"\tpushl %fs:0\n"
186	"\tpushl %fs:4\n"	219	"\tpushl %fs:4\n"
187	"\tpushl %fs:8\n"	220	"\tpushl %fs:8\n"
188	#endif	221	#endif
189	"\tmovl %esp, (%eax)\n"	222	"\tmovl %esp, (%eax)\n"
…		…
195	#endif	228	#endif
196	"\tpopl %edi\n"	229	"\tpopl %edi\n"
197	"\tpopl %esi\n"	230	"\tpopl %esi\n"
198	"\tpopl %ebx\n"	231	"\tpopl %ebx\n"
199	"\tpopl %ebp\n"	232	"\tpopl %ebp\n"
		233	"\tpopl %ecx\n"
		234	"\tjmpl *%ecx\n"
		235
200	#else	236	#else
201	#error unsupported architecture	237	#error unsupported architecture
202	#endif	238	#endif
203	"\tret\n"
204	);	239	);
205		240
206	# endif	241	# endif
207		242
208	void	243	void
…		…
281	ctx->env[8] = (long) coro_init;	316	ctx->env[8] = (long) coro_init;
282	ctx->env[7] = (long) ((char *)sptr + ssize) - sizeof (long);	317	ctx->env[7] = (long) ((char *)sptr + ssize) - sizeof (long);
283	#elif __CYGWIN__ && __x86_64	318	#elif __CYGWIN__ && __x86_64
284	ctx->env[7] = (long) coro_init;	319	ctx->env[7] = (long) coro_init;
285	ctx->env[6] = (long) ((char *)sptr + ssize) - sizeof (long);	320	ctx->env[6] = (long) ((char *)sptr + ssize) - sizeof (long);
286	#elif defined(__MINGW32__)	321	#elif defined __MINGW32__
287	ctx->env[5] = (long) coro_init;	322	ctx->env[5] = (long) coro_init;
288	ctx->env[4] = (long) ((char *)sptr + ssize) - sizeof (long);	323	ctx->env[4] = (long) ((char *)sptr + ssize) - sizeof (long);
289	#elif defined(_M_IX86)	324	#elif defined _M_IX86
290	((_JUMP_BUFFER *)&ctx->env)->Eip = (long) coro_init;	325	((_JUMP_BUFFER *)&ctx->env)->Eip = (long) coro_init;
291	((_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);
292	#elif defined(_M_AMD64)	327	#elif defined _M_AMD64
293	((_JUMP_BUFFER *)&ctx->env)->Rip = (__int64) coro_init;	328	((_JUMP_BUFFER *)&ctx->env)->Rip = (__int64) coro_init;
294	((_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);
295	#elif defined(_M_IA64)	330	#elif defined _M_IA64
296	((_JUMP_BUFFER *)&ctx->env)->StIIP = (__int64) coro_init;	331	((_JUMP_BUFFER *)&ctx->env)->StIIP = (__int64) coro_init;
297	((_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);
298	#else	333	#else
299	#error "microsoft libc or architecture not supported"	334	#error "microsoft libc or architecture not supported"
300	#endif	335	#endif
…		…
465	}	500	}
466		501
467	pthread_cond_destroy (&ctx->cv);	502	pthread_cond_destroy (&ctx->cv);
468	}	503	}
469		504
		505	/*****************************************************************************/
		506	/* fiber backend */
		507	/*****************************************************************************/
		508	#elif CORO_FIBER
		509
		510	#define WIN32_LEAN_AND_MEAN
		511	#include <windows.h>
		512
		513	#include <stdio.h>//D
		514	VOID CALLBACK
		515	coro_init (PVOID arg)
		516	{
		517	coro_context ctx = (coro_context )arg;
		518
		519	ctx->coro (ctx->arg);
		520	}
		521
		522	void
		523	coro_transfer (coro_context prev, coro_context next)
		524	{
		525	if (!prev->fiber)
		526	{
		527	prev->fiber = GetCurrentFiber ();
		528
		529	if (prev->fiber == 0 \|\| prev->fiber == (void *)0x1e00)
		530	prev->fiber = ConvertThreadToFiber (0);
		531	}
		532
		533	SwitchToFiber (next->fiber);
		534	}
		535
		536	void
		537	coro_create (coro_context ctx, coro_func coro, void arg, void *sptr, long ssize)
		538	{
		539	ctx->fiber = 0;
		540	ctx->coro = coro;
		541	ctx->arg = arg;
		542
		543	if (!coro)
		544	return;
		545
		546	ctx->fiber = CreateFiber (ssize, coro_init, ctx);
		547	}
		548
		549	void
		550	coro_destroy (coro_context *ctx)
		551	{
		552	DeleteFiber (ctx->fiber);
		553	}
		554
470	#else	555	#else
471	# error unsupported backend	556	# error unsupported backend
472	#endif	557	#endif
473		558

Diff Legend

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

Comparing libcoro/coro.c (file contents): Revision 1.62 by root, Mon Aug 8 22:00:18 2011 UTC vs. Revision 1.63 by root, Wed Dec 5 01:09:12 2012 UTC

Diff Legend

Comparing libcoro/coro.c (file contents):
Revision 1.62 by root, Mon Aug 8 22:00:18 2011 UTC vs.
Revision 1.63 by root, Wed Dec 5 01:09:12 2012 UTC