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.241 by root, Mon Jul 21 02:39:15 2008 UTC vs.
Revision 1.244 by root, Sun Sep 21 18:29:39 2008 UTC

… …
361 361
362 /* casting is fun. */ 362 /* casting is fun. */
363 while (&PL_sv_undef != (SV *)(padlist = (AV *)av_pop (av))) 363 while (&PL_sv_undef != (SV *)(padlist = (AV *)av_pop (av)))
364 free_padlist (aTHX_ padlist); 364 free_padlist (aTHX_ padlist);
365 365
366 SvREFCNT_dec (av);
367
366 return 0; 368 return 0;
367} 369}
368 370
369#define CORO_MAGIC_type_cv PERL_MAGIC_ext 371#define CORO_MAGIC_type_cv PERL_MAGIC_ext
370#define CORO_MAGIC_type_state PERL_MAGIC_ext 372#define CORO_MAGIC_type_state PERL_MAGIC_ext
… …
420 if (expect_true (mg && AvFILLp ((av = (AV *)mg->mg_obj)) >= 0)) 422 if (expect_true (mg && AvFILLp ((av = (AV *)mg->mg_obj)) >= 0))
421 CvPADLIST (cv) = (AV *)AvARRAY (av)[AvFILLp (av)--]; 423 CvPADLIST (cv) = (AV *)AvARRAY (av)[AvFILLp (av)--];
422 else 424 else
423 { 425 {
424#if CORO_PREFER_PERL_FUNCTIONS 426#if CORO_PREFER_PERL_FUNCTIONS
425 /* this is probably cleaner, but also slower? */ 427 /* this is probably cleaner? but also slower! */
428 /* in practise, it seems to be less stable */
426 CV *cp = Perl_cv_clone (cv); 429 CV *cp = Perl_cv_clone (cv);
427 CvPADLIST (cv) = CvPADLIST (cp); 430 CvPADLIST (cv) = CvPADLIST (cp);
428 CvPADLIST (cp) = 0; 431 CvPADLIST (cp) = 0;
429 SvREFCNT_dec (cp); 432 SvREFCNT_dec (cp);
430#else 433#else
… …
1623 else 1626 else
1624 coro->slot->runops = RUNOPS_DEFAULT; 1627 coro->slot->runops = RUNOPS_DEFAULT;
1625 } 1628 }
1626} 1629}
1627 1630
1631static int
1632coro_gensub_free (pTHX_ SV *sv, MAGIC *mg)
1633{
1634 AV *padlist;
1635 AV *av = (AV *)mg->mg_obj;
1636
1637 abort ();
1638
1639 return 0;
1640}
1641
1642static MGVTBL coro_gensub_vtbl = {
1643 0, 0, 0, 0,
1644 coro_gensub_free
1645};
1646
1628MODULE = Coro::State PACKAGE = Coro::State PREFIX = api_ 1647MODULE = Coro::State PACKAGE = Coro::State PREFIX = api_
1629 1648
1630PROTOTYPES: DISABLE 1649PROTOTYPES: DISABLE
1631 1650
1632BOOT: 1651BOOT:
… …
1890force_cctx () 1909force_cctx ()
1891 CODE: 1910 CODE:
1892 struct coro *coro = SvSTATE (coro_current); 1911 struct coro *coro = SvSTATE (coro_current);
1893 coro->cctx->idle_sp = 0; 1912 coro->cctx->idle_sp = 0;
1894 1913
1895MODULE = Coro::State PACKAGE = Coro
1896
1897BOOT:
1898{
1899 int i;
1900
1901 av_async_pool = coro_get_av (aTHX_ "Coro::async_pool", TRUE);
1902 sv_pool_rss = coro_get_sv (aTHX_ "Coro::POOL_RSS" , TRUE);
1903 sv_pool_size = coro_get_sv (aTHX_ "Coro::POOL_SIZE" , TRUE);
1904
1905 coro_current = coro_get_sv (aTHX_ "Coro::current", FALSE);
1906 SvREADONLY_on (coro_current);
1907
1908 coro_stash = gv_stashpv ("Coro", TRUE);
1909
1910 newCONSTSUB (coro_stash, "PRIO_MAX", newSViv (PRIO_MAX));
1911 newCONSTSUB (coro_stash, "PRIO_HIGH", newSViv (PRIO_HIGH));
1912 newCONSTSUB (coro_stash, "PRIO_NORMAL", newSViv (PRIO_NORMAL));
1913 newCONSTSUB (coro_stash, "PRIO_LOW", newSViv (PRIO_LOW));
1914 newCONSTSUB (coro_stash, "PRIO_IDLE", newSViv (PRIO_IDLE));
1915 newCONSTSUB (coro_stash, "PRIO_MIN", newSViv (PRIO_MIN));
1916
1917 for (i = PRIO_MAX - PRIO_MIN + 1; i--; )
1918 coro_ready[i] = newAV ();
1919
1920 {
1921 SV *sv = perl_get_sv ("Coro::API", TRUE);
1922 perl_get_sv ("Coro::API", TRUE); /* silence 5.10 warning */
1923
1924 coroapi.schedule = api_schedule;
1925 coroapi.cede = api_cede;
1926 coroapi.cede_notself = api_cede_notself;
1927 coroapi.ready = api_ready;
1928 coroapi.is_ready = api_is_ready;
1929 coroapi.nready = &coro_nready;
1930 coroapi.current = coro_current;
1931
1932 GCoroAPI = &coroapi;
1933 sv_setiv (sv, (IV)&coroapi);
1934 SvREADONLY_on (sv);
1935 }
1936}
1937
1938void
1939_set_current (SV *current)
1940 PROTOTYPE: $
1941 CODE:
1942 SvREFCNT_dec (SvRV (coro_current));
1943 SvRV_set (coro_current, SvREFCNT_inc (SvRV (current)));
1944
1945void
1946_set_readyhook (SV *hook)
1947 PROTOTYPE: $
1948 CODE:
1949 LOCK;
1950 SvREFCNT_dec (coro_readyhook);
1951 coro_readyhook = SvOK (hook) ? newSVsv (hook) : 0;
1952 UNLOCK;
1953
1954int
1955prio (Coro::State coro, int newprio = 0)
1956 ALIAS:
1957 nice = 1
1958 CODE:
1959{
1960 RETVAL = coro->prio;
1961
1962 if (items > 1)
1963 {
1964 if (ix)
1965 newprio = coro->prio - newprio;
1966
1967 if (newprio < PRIO_MIN) newprio = PRIO_MIN;
1968 if (newprio > PRIO_MAX) newprio = PRIO_MAX;
1969
1970 coro->prio = newprio;
1971 }
1972}
1973 OUTPUT:
1974 RETVAL
1975
1976SV *
1977ready (SV *self)
1978 PROTOTYPE: $
1979 CODE:
1980 RETVAL = boolSV (api_ready (self));
1981 OUTPUT:
1982 RETVAL
1983
1984int
1985nready (...)
1986 PROTOTYPE:
1987 CODE:
1988 RETVAL = coro_nready;
1989 OUTPUT:
1990 RETVAL
1991
1992void 1914void
1993throw (Coro::State self, SV *throw = &PL_sv_undef) 1915throw (Coro::State self, SV *throw = &PL_sv_undef)
1994 PROTOTYPE: $;$ 1916 PROTOTYPE: $;$
1995 CODE: 1917 CODE:
1996 SvREFCNT_dec (self->throw); 1918 SvREFCNT_dec (self->throw);
… …
2010 SV **dst = ix ? (SV **)&self->slot->defav : (SV **)&self->slot->defsv; 1932 SV **dst = ix ? (SV **)&self->slot->defav : (SV **)&self->slot->defsv;
2011 1933
2012 SV *tmp = *src; *src = *dst; *dst = tmp; 1934 SV *tmp = *src; *src = *dst; *dst = tmp;
2013 } 1935 }
2014 1936
1937MODULE = Coro::State PACKAGE = Coro
1938
1939BOOT:
1940{
1941 int i;
1942
1943 av_async_pool = coro_get_av (aTHX_ "Coro::async_pool", TRUE);
1944 sv_pool_rss = coro_get_sv (aTHX_ "Coro::POOL_RSS" , TRUE);
1945 sv_pool_size = coro_get_sv (aTHX_ "Coro::POOL_SIZE" , TRUE);
1946
1947 coro_current = coro_get_sv (aTHX_ "Coro::current", FALSE);
1948 SvREADONLY_on (coro_current);
1949
1950 coro_stash = gv_stashpv ("Coro", TRUE);
1951
1952 newCONSTSUB (coro_stash, "PRIO_MAX", newSViv (PRIO_MAX));
1953 newCONSTSUB (coro_stash, "PRIO_HIGH", newSViv (PRIO_HIGH));
1954 newCONSTSUB (coro_stash, "PRIO_NORMAL", newSViv (PRIO_NORMAL));
1955 newCONSTSUB (coro_stash, "PRIO_LOW", newSViv (PRIO_LOW));
1956 newCONSTSUB (coro_stash, "PRIO_IDLE", newSViv (PRIO_IDLE));
1957 newCONSTSUB (coro_stash, "PRIO_MIN", newSViv (PRIO_MIN));
1958
1959 for (i = PRIO_MAX - PRIO_MIN + 1; i--; )
1960 coro_ready[i] = newAV ();
1961
1962 {
1963 SV *sv = perl_get_sv ("Coro::API", TRUE);
1964 perl_get_sv ("Coro::API", TRUE); /* silence 5.10 warning */
1965
1966 coroapi.schedule = api_schedule;
1967 coroapi.cede = api_cede;
1968 coroapi.cede_notself = api_cede_notself;
1969 coroapi.ready = api_ready;
1970 coroapi.is_ready = api_is_ready;
1971 coroapi.nready = &coro_nready;
1972 coroapi.current = coro_current;
1973
1974 GCoroAPI = &coroapi;
1975 sv_setiv (sv, (IV)&coroapi);
1976 SvREADONLY_on (sv);
1977 }
1978}
1979
1980void
1981_set_current (SV *current)
1982 PROTOTYPE: $
1983 CODE:
1984 SvREFCNT_dec (SvRV (coro_current));
1985 SvRV_set (coro_current, SvREFCNT_inc (SvRV (current)));
1986
1987void
1988_set_readyhook (SV *hook)
1989 PROTOTYPE: $
1990 CODE:
1991 LOCK;
1992 SvREFCNT_dec (coro_readyhook);
1993 coro_readyhook = SvOK (hook) ? newSVsv (hook) : 0;
1994 UNLOCK;
1995
1996int
1997prio (Coro::State coro, int newprio = 0)
1998 ALIAS:
1999 nice = 1
2000 CODE:
2001{
2002 RETVAL = coro->prio;
2003
2004 if (items > 1)
2005 {
2006 if (ix)
2007 newprio = coro->prio - newprio;
2008
2009 if (newprio < PRIO_MIN) newprio = PRIO_MIN;
2010 if (newprio > PRIO_MAX) newprio = PRIO_MAX;
2011
2012 coro->prio = newprio;
2013 }
2014}
2015 OUTPUT:
2016 RETVAL
2017
2018SV *
2019ready (SV *self)
2020 PROTOTYPE: $
2021 CODE:
2022 RETVAL = boolSV (api_ready (self));
2023 OUTPUT:
2024 RETVAL
2025
2026int
2027nready (...)
2028 PROTOTYPE:
2029 CODE:
2030 RETVAL = coro_nready;
2031 OUTPUT:
2032 RETVAL
2033
2015# for async_pool speedup 2034# for async_pool speedup
2016void 2035void
2017_pool_1 (SV *cb) 2036_pool_1 (SV *cb)
2018 CODE: 2037 CODE:
2019{ 2038{
… …
2083 api_trace (coro_current, 0); 2102 api_trace (coro_current, 0);
2084 2103
2085 av_push (av_async_pool, newSVsv (coro_current)); 2104 av_push (av_async_pool, newSVsv (coro_current));
2086} 2105}
2087 2106
2107#if 0
2108
2109void
2110_generator_call (...)
2111 PROTOTYPE: @
2112 PPCODE:
2113 fprintf (stderr, "call %p\n", CvXSUBANY(cv).any_ptr);
2114 xxxx
2115 abort ();
2116
2117SV *
2118gensub (SV *sub, ...)
2119 PROTOTYPE: &;@
2120 CODE:
2121{
2122 struct coro *coro;
2123 MAGIC *mg;
2124 CV *xcv;
2125 CV *ncv = (CV *)newSV_type (SVt_PVCV);
2126 int i;
2127
2128 CvGV (ncv) = CvGV (cv);
2129 CvFILE (ncv) = CvFILE (cv);
2130
2131 Newz (0, coro, 1, struct coro);
2132 coro->args = newAV ();
2133 coro->flags = CF_NEW;
2134
2135 av_extend (coro->args, items - 1);
2136 for (i = 1; i < items; i++)
2137 av_push (coro->args, newSVsv (ST (i)));
2138
2139 CvISXSUB_on (ncv);
2140 CvXSUBANY (ncv).any_ptr = (void *)coro;
2141
2142 xcv = GvCV (gv_fetchpv ("Coro::_generator_call", 0, SVt_PVCV));
2143
2144 CvXSUB (ncv) = CvXSUB (xcv);
2145 CvANON_on (ncv);
2146
2147 mg = sv_magicext ((SV *)ncv, 0, CORO_MAGIC_type_state, &coro_gensub_vtbl, (char *)coro, 0);
2148 RETVAL = newRV_noinc ((SV *)ncv);
2149}
2150 OUTPUT:
2151 RETVAL
2152
2153#endif
2154
2088 2155
2089MODULE = Coro::State PACKAGE = Coro::AIO 2156MODULE = Coro::State PACKAGE = Coro::AIO
2090 2157
2091SV * 2158SV *
2092_get_state () 2159_get_state ()

Diff Legend

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