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.232 by root, Thu Apr 24 12:40:38 2008 UTC vs.
Revision 1.237 by root, Fri May 23 00:27:06 2008 UTC

… …
171/* async_pool helper stuff */ 171/* async_pool helper stuff */
172static SV *sv_pool_rss; 172static SV *sv_pool_rss;
173static SV *sv_pool_size; 173static SV *sv_pool_size;
174static AV *av_async_pool; 174static AV *av_async_pool;
175 175
176/* Coro::AnyEvent */
177static SV *sv_activity;
178
176static struct coro_cctx *cctx_first; 179static struct coro_cctx *cctx_first;
177static int cctx_count, cctx_idle; 180static int cctx_count, cctx_idle;
178 181
179enum { 182enum {
180 CC_MAPPED = 0x01, 183 CC_MAPPED = 0x01,
… …
265#define PRIO_IDLE -3 268#define PRIO_IDLE -3
266#define PRIO_MIN -4 269#define PRIO_MIN -4
267 270
268/* for Coro.pm */ 271/* for Coro.pm */
269static SV *coro_current; 272static SV *coro_current;
273static SV *coro_readyhook;
270static AV *coro_ready [PRIO_MAX-PRIO_MIN+1]; 274static AV *coro_ready [PRIO_MAX-PRIO_MIN+1];
271static int coro_nready; 275static int coro_nready;
272static struct coro *coro_first; 276static struct coro *coro_first;
273 277
274/** lowlevel stuff **********************************************************/ 278/** lowlevel stuff **********************************************************/
… …
510 514
511 if (expect_true (CvDEPTH (cv))) 515 if (expect_true (CvDEPTH (cv)))
512 { 516 {
513 EXTEND (SP, 3); 517 EXTEND (SP, 3);
514 PUSHs ((SV *)CvPADLIST (cv)); 518 PUSHs ((SV *)CvPADLIST (cv));
515 PUSHs (INT2PTR (SV *, CvDEPTH (cv))); 519 PUSHs (INT2PTR (SV *, (IV)CvDEPTH (cv)));
516 PUSHs ((SV *)cv); 520 PUSHs ((SV *)cv);
517 521
518 CvDEPTH (cv) = 0; 522 CvDEPTH (cv) = 0;
519 get_padlist (aTHX_ cv); 523 get_padlist (aTHX_ cv);
520 } 524 }
… …
1379static int 1383static int
1380api_ready (SV *coro_sv) 1384api_ready (SV *coro_sv)
1381{ 1385{
1382 dTHX; 1386 dTHX;
1383 struct coro *coro; 1387 struct coro *coro;
1388 SV *sv_hook;
1389 void (*xs_hook)(void);
1384 1390
1385 if (SvROK (coro_sv)) 1391 if (SvROK (coro_sv))
1386 coro_sv = SvRV (coro_sv); 1392 coro_sv = SvRV (coro_sv);
1387 1393
1388 coro = SvSTATE (coro_sv); 1394 coro = SvSTATE (coro_sv);
… …
1391 return 0; 1397 return 0;
1392 1398
1393 coro->flags |= CF_READY; 1399 coro->flags |= CF_READY;
1394 1400
1395 LOCK; 1401 LOCK;
1402
1403 sv_hook = coro_nready ? 0 : coro_readyhook;
1404 xs_hook = coro_nready ? 0 : coroapi.readyhook;
1405
1396 coro_enq (aTHX_ SvREFCNT_inc (coro_sv)); 1406 coro_enq (aTHX_ SvREFCNT_inc (coro_sv));
1397 ++coro_nready; 1407 ++coro_nready;
1408
1398 UNLOCK; 1409 UNLOCK;
1410
1411 if (sv_hook)
1412 {
1413 dSP;
1414
1415 ENTER;
1416 SAVETMPS;
1417
1418 PUSHMARK (SP);
1419 PUTBACK;
1420 call_sv (sv_hook, G_DISCARD);
1421 SPAGAIN;
1422
1423 FREETMPS;
1424 LEAVE;
1425 }
1426
1427 if (xs_hook)
1428 xs_hook ();
1399 1429
1400 return 1; 1430 return 1;
1401} 1431}
1402 1432
1403static int 1433static int
… …
1589 main_top_env = PL_top_env; 1619 main_top_env = PL_top_env;
1590 1620
1591 while (main_top_env->je_prev) 1621 while (main_top_env->je_prev)
1592 main_top_env = main_top_env->je_prev; 1622 main_top_env = main_top_env->je_prev;
1593 1623
1594 coroapi.ver = CORO_API_VERSION; 1624 coroapi.ver = CORO_API_VERSION;
1595 coroapi.rev = CORO_API_REVISION; 1625 coroapi.rev = CORO_API_REVISION;
1596 coroapi.transfer = api_transfer; 1626 coroapi.transfer = api_transfer;
1597 1627
1598 assert (("PRIO_NORMAL must be 0", !PRIO_NORMAL)); 1628 assert (("PRIO_NORMAL must be 0", !PRIO_NORMAL));
1599} 1629}
1600 1630
1601SV * 1631SV *
… …
1685 RETVAL = coro_state_destroy (aTHX_ SvSTATE (coro_sv)); 1715 RETVAL = coro_state_destroy (aTHX_ SvSTATE (coro_sv));
1686 OUTPUT: 1716 OUTPUT:
1687 RETVAL 1717 RETVAL
1688 1718
1689void 1719void
1690_exit (code) 1720_exit (int code)
1691 int code
1692 PROTOTYPE: $ 1721 PROTOTYPE: $
1693 CODE: 1722 CODE:
1694 _exit (code); 1723 _exit (code);
1695 1724
1696int 1725int
… …
1787 1816
1788void 1817void
1789api_trace (SV *coro, int flags = CC_TRACE | CC_TRACE_SUB) 1818api_trace (SV *coro, int flags = CC_TRACE | CC_TRACE_SUB)
1790 1819
1791SV * 1820SV *
1792has_stack (Coro::State coro) 1821has_cctx (Coro::State coro)
1793 PROTOTYPE: $ 1822 PROTOTYPE: $
1794 CODE: 1823 CODE:
1795 RETVAL = boolSV (!!coro->cctx); 1824 RETVAL = boolSV (!!coro->cctx);
1796 OUTPUT: 1825 OUTPUT:
1797 RETVAL 1826 RETVAL
… …
1828 1857
1829BOOT: 1858BOOT:
1830{ 1859{
1831 int i; 1860 int i;
1832 1861
1862 av_async_pool = coro_get_av (aTHX_ "Coro::async_pool", TRUE);
1833 sv_pool_rss = coro_get_sv (aTHX_ "Coro::POOL_RSS" , TRUE); 1863 sv_pool_rss = coro_get_sv (aTHX_ "Coro::POOL_RSS" , TRUE);
1834 sv_pool_size = coro_get_sv (aTHX_ "Coro::POOL_SIZE" , TRUE); 1864 sv_pool_size = coro_get_sv (aTHX_ "Coro::POOL_SIZE" , TRUE);
1835 av_async_pool = coro_get_av (aTHX_ "Coro::async_pool", TRUE);
1836 1865
1837 coro_current = coro_get_sv (aTHX_ "Coro::current", FALSE); 1866 coro_current = coro_get_sv (aTHX_ "Coro::current", FALSE);
1838 SvREADONLY_on (coro_current); 1867 SvREADONLY_on (coro_current);
1839 1868
1840 coro_stash = gv_stashpv ("Coro", TRUE); 1869 coro_stash = gv_stashpv ("Coro", TRUE);
… …
1871_set_current (SV *current) 1900_set_current (SV *current)
1872 PROTOTYPE: $ 1901 PROTOTYPE: $
1873 CODE: 1902 CODE:
1874 SvREFCNT_dec (SvRV (coro_current)); 1903 SvREFCNT_dec (SvRV (coro_current));
1875 SvRV_set (coro_current, SvREFCNT_inc (SvRV (current))); 1904 SvRV_set (coro_current, SvREFCNT_inc (SvRV (current)));
1905
1906void
1907_set_readyhook (SV *hook)
1908 PROTOTYPE: $
1909 CODE:
1910 LOCK;
1911 SvREFCNT_dec (coro_readyhook);
1912 coro_readyhook = SvOK (hook) ? newSVsv (hook) : 0;
1913 UNLOCK;
1876 1914
1877int 1915int
1878prio (Coro::State coro, int newprio = 0) 1916prio (Coro::State coro, int newprio = 0)
1879 ALIAS: 1917 ALIAS:
1880 nice = 1 1918 nice = 1
… …
2037 PL_laststype = data->laststype; 2075 PL_laststype = data->laststype;
2038 PL_laststatval = data->laststatval; 2076 PL_laststatval = data->laststatval;
2039 PL_statcache = data->statcache; 2077 PL_statcache = data->statcache;
2040} 2078}
2041 2079
2080
2081MODULE = Coro::State PACKAGE = Coro::AnyEvent
2082
2083BOOT:
2084 sv_activity = coro_get_sv (aTHX_ "Coro::AnyEvent::ACTIVITY", TRUE);
2085
2086SV *
2087_schedule (...)
2088 PROTOTYPE: @
2089 CODE:
2090{
2091 static int incede;
2092
2093 api_cede_notself ();
2094
2095 ++incede;
2096 while (coro_nready >= incede && api_cede ())
2097 ;
2098
2099 sv_setsv (sv_activity, &PL_sv_undef);
2100 if (coro_nready >= incede)
2101 {
2102 PUSHMARK (SP);
2103 PUTBACK;
2104 call_pv ("Coro::AnyEvent::_activity", G_DISCARD | G_EVAL);
2105 SPAGAIN;
2106 }
2107
2108 --incede;
2109}
2110

Diff Legend

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