ViewVC Help
View File | Revision Log | Show Annotations | Download File
/cvs/Coro/Coro/State.xs
(Generate patch)

Comparing Coro/Coro/State.xs (file contents):
Revision 1.357 by root, Sat Jun 27 14:09:28 2009 UTC vs.
Revision 1.358 by root, Mon Jun 29 04:30:25 2009 UTC

… …
159# if CORO_PTHREAD 159# if CORO_PTHREAD
160static void *coro_thx; 160static void *coro_thx;
161# endif 161# endif
162#endif 162#endif
163 163
164#ifdef __linux
165# include <time.h> /* for timespec */
166# include <syscall.h> /* for SYS_* */
167# ifdef SYS_clock_gettime
168# define coro_clock_gettime(id, ts) syscall (SYS_clock_gettime, (id), (ts))
169# define CORO_CLOCK_MONOTONIC 1
170# define CORO_CLOCK_THREAD_CPUTIME_ID 3
171# endif
172#endif
173
164static double (*nvtime)(); /* so why doesn't it take void? */ 174static double (*nvtime)(); /* so why doesn't it take void? */
165 175
166/* we hijack an hopefully unused CV flag for our purposes */ 176/* we hijack an hopefully unused CV flag for our purposes */
167#define CVf_SLF 0x4000 177#define CVf_SLF 0x4000
168static OP *pp_slf (pTHX); 178static OP *pp_slf (pTHX);
… …
307/* the mainr easonw e don't support windows process emulation */ 317/* the mainr easonw e don't support windows process emulation */
308static struct CoroSLF slf_frame; /* the current slf frame */ 318static struct CoroSLF slf_frame; /* the current slf frame */
309 319
310/** Coro ********************************************************************/ 320/** Coro ********************************************************************/
311 321
312#define PRIO_MAX 3 322#define CORO_PRIO_MAX 3
313#define PRIO_HIGH 1 323#define CORO_PRIO_HIGH 1
314#define PRIO_NORMAL 0 324#define CORO_PRIO_NORMAL 0
315#define PRIO_LOW -1 325#define CORO_PRIO_LOW -1
316#define PRIO_IDLE -3 326#define CORO_PRIO_IDLE -3
317#define PRIO_MIN -4 327#define CORO_PRIO_MIN -4
318 328
319/* for Coro.pm */ 329/* for Coro.pm */
320static SV *coro_current; 330static SV *coro_current;
321static SV *coro_readyhook; 331static SV *coro_readyhook;
322static struct coro *coro_ready [PRIO_MAX - PRIO_MIN + 1][2]; /* head|tail */ 332static struct coro *coro_ready [CORO_PRIO_MAX - CORO_PRIO_MIN + 1][2]; /* head|tail */
323static CV *cv_coro_run, *cv_coro_terminate; 333static CV *cv_coro_run, *cv_coro_terminate;
324static struct coro *coro_first; 334static struct coro *coro_first;
325#define coro_nready coroapi.nready 335#define coro_nready coroapi.nready
326 336
327/** lowlevel stuff **********************************************************/ 337/** lowlevel stuff **********************************************************/
… …
475static int 485static int
476coro_cv_free (pTHX_ SV *sv, MAGIC *mg) 486coro_cv_free (pTHX_ SV *sv, MAGIC *mg)
477{ 487{
478 AV *padlist; 488 AV *padlist;
479 AV *av = (AV *)mg->mg_obj; 489 AV *av = (AV *)mg->mg_obj;
490
491 /* perl manages to free our internal AV and _then_ call us */
492 if (IN_DESTRUCT)
493 return;
480 494
481 /* casting is fun. */ 495 /* casting is fun. */
482 while (&PL_sv_undef != (SV *)(padlist = (AV *)av_pop (av))) 496 while (&PL_sv_undef != (SV *)(padlist = (AV *)av_pop (av)))
483 free_padlist (aTHX_ padlist); 497 free_padlist (aTHX_ padlist);
484 498
… …
1622/** Coro ********************************************************************/ 1636/** Coro ********************************************************************/
1623 1637
1624INLINE void 1638INLINE void
1625coro_enq (pTHX_ struct coro *coro) 1639coro_enq (pTHX_ struct coro *coro)
1626{ 1640{
1627 struct coro **ready = coro_ready [coro->prio - PRIO_MIN]; 1641 struct coro **ready = coro_ready [coro->prio - CORO_PRIO_MIN];
1628 1642
1629 SvREFCNT_inc_NN (coro->hv); 1643 SvREFCNT_inc_NN (coro->hv);
1630 1644
1631 coro->next_ready = 0; 1645 coro->next_ready = 0;
1632 *(ready [0] ? &ready [1]->next_ready : &ready [0]) = coro; 1646 *(ready [0] ? &ready [1]->next_ready : &ready [0]) = coro;
… …
1636INLINE struct coro * 1650INLINE struct coro *
1637coro_deq (pTHX) 1651coro_deq (pTHX)
1638{ 1652{
1639 int prio; 1653 int prio;
1640 1654
1641 for (prio = PRIO_MAX - PRIO_MIN + 1; --prio >= 0; ) 1655 for (prio = CORO_PRIO_MAX - CORO_PRIO_MIN + 1; --prio >= 0; )
1642 { 1656 {
1643 struct coro **ready = coro_ready [prio]; 1657 struct coro **ready = coro_ready [prio];
1644 1658
1645 if (ready [0]) 1659 if (ready [0])
1646 { 1660 {
… …
2967 if (!SvIOK (*svp)) croak ("Time::NVtime isn't a function pointer"); 2981 if (!SvIOK (*svp)) croak ("Time::NVtime isn't a function pointer");
2968 2982
2969 nvtime = INT2PTR (double (*)(), SvIV (*svp)); 2983 nvtime = INT2PTR (double (*)(), SvIV (*svp));
2970 } 2984 }
2971 2985
2972 assert (("PRIO_NORMAL must be 0", !PRIO_NORMAL)); 2986 assert (("PRIO_NORMAL must be 0", !CORO_PRIO_NORMAL));
2973} 2987}
2974 2988
2975SV * 2989SV *
2976new (char *klass, ...) 2990new (char *klass, ...)
2977 ALIAS: 2991 ALIAS:
… …
3269 cv_pool_handler = get_cv ("Coro::pool_handler", GV_ADD); SvREADONLY_on (cv_pool_handler); 3283 cv_pool_handler = get_cv ("Coro::pool_handler", GV_ADD); SvREADONLY_on (cv_pool_handler);
3270 cv_coro_state_new = get_cv ("Coro::State::new", 0); SvREADONLY_on (cv_coro_state_new); 3284 cv_coro_state_new = get_cv ("Coro::State::new", 0); SvREADONLY_on (cv_coro_state_new);
3271 3285
3272 coro_stash = gv_stashpv ("Coro", TRUE); 3286 coro_stash = gv_stashpv ("Coro", TRUE);
3273 3287
3274 newCONSTSUB (coro_stash, "PRIO_MAX", newSViv (PRIO_MAX)); 3288 newCONSTSUB (coro_stash, "PRIO_MAX", newSViv (CORO_PRIO_MAX));
3275 newCONSTSUB (coro_stash, "PRIO_HIGH", newSViv (PRIO_HIGH)); 3289 newCONSTSUB (coro_stash, "PRIO_HIGH", newSViv (CORO_PRIO_HIGH));
3276 newCONSTSUB (coro_stash, "PRIO_NORMAL", newSViv (PRIO_NORMAL)); 3290 newCONSTSUB (coro_stash, "PRIO_NORMAL", newSViv (CORO_PRIO_NORMAL));
3277 newCONSTSUB (coro_stash, "PRIO_LOW", newSViv (PRIO_LOW)); 3291 newCONSTSUB (coro_stash, "PRIO_LOW", newSViv (CORO_PRIO_LOW));
3278 newCONSTSUB (coro_stash, "PRIO_IDLE", newSViv (PRIO_IDLE)); 3292 newCONSTSUB (coro_stash, "PRIO_IDLE", newSViv (CORO_PRIO_IDLE));
3279 newCONSTSUB (coro_stash, "PRIO_MIN", newSViv (PRIO_MIN)); 3293 newCONSTSUB (coro_stash, "PRIO_MIN", newSViv (CORO_PRIO_MIN));
3280 3294
3281 { 3295 {
3282 SV *sv = coro_get_sv (aTHX_ "Coro::API", TRUE); 3296 SV *sv = coro_get_sv (aTHX_ "Coro::API", TRUE);
3283 3297
3284 coroapi.schedule = api_schedule; 3298 coroapi.schedule = api_schedule;

Diff Legend

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