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.237 by root, Fri May 23 00:27:06 2008 UTC vs.
Revision 1.243 by root, Sat Aug 30 03:07:46 2008 UTC

… …
683 683
684/** coroutine stack handling ************************************************/ 684/** coroutine stack handling ************************************************/
685 685
686static int (*orig_sigelem_get) (pTHX_ SV *sv, MAGIC *mg); 686static int (*orig_sigelem_get) (pTHX_ SV *sv, MAGIC *mg);
687static int (*orig_sigelem_set) (pTHX_ SV *sv, MAGIC *mg); 687static int (*orig_sigelem_set) (pTHX_ SV *sv, MAGIC *mg);
688static int (*orig_sigelem_clr) (pTHX_ SV *sv, MAGIC *mg);
689
690/* apparently < 5.8.8 */
691#ifndef MgPV_nolen_const
692#define MgPV_nolen_const(mg) (((((int)(mg)->mg_len)) == HEf_SVKEY) ? \
693 SvPV_nolen((SV*)((mg)->mg_ptr)) : \
694 (const char*)(mg)->mg_ptr)
695#endif
688 696
689/* 697/*
690 * This overrides the default magic get method of %SIG elements. 698 * This overrides the default magic get method of %SIG elements.
691 * The original one doesn't provide for reading back of PL_diehook/PL_warnhook 699 * The original one doesn't provide for reading back of PL_diehook/PL_warnhook
692 * and instead of tryign to save and restore the hash elements, we just provide 700 * and instead of tryign to save and restore the hash elements, we just provide
… …
700{ 708{
701 const char *s = MgPV_nolen_const (mg); 709 const char *s = MgPV_nolen_const (mg);
702 710
703 if (*s == '_') 711 if (*s == '_')
704 { 712 {
705 if (strEQ (s, "__DIE__" ) && PL_diehook ) return sv_setsv (sv, PL_diehook ), 0; 713 SV **svp = 0;
706 if (strEQ (s, "__WARN__") && PL_warnhook) return sv_setsv (sv, PL_warnhook), 0; 714
715 if (strEQ (s, "__DIE__" )) svp = &PL_diehook;
716 if (strEQ (s, "__WARN__")) svp = &PL_warnhook;
717
718 if (svp)
719 {
720 sv_setsv (sv, *svp ? *svp : &PL_sv_undef);
721 return 0;
722 }
707 } 723 }
708 724
709 return orig_sigelem_get ? orig_sigelem_get (aTHX_ sv, mg) : 0; 725 return orig_sigelem_get ? orig_sigelem_get (aTHX_ sv, mg) : 0;
726}
727
728static int
729coro_sigelem_clr (pTHX_ SV *sv, MAGIC *mg)
730{
731 const char *s = MgPV_nolen_const (mg);
732
733 if (*s == '_')
734 {
735 SV **svp = 0;
736
737 if (strEQ (s, "__DIE__" )) svp = &PL_diehook;
738 if (strEQ (s, "__WARN__")) svp = &PL_warnhook;
739
740 if (svp)
741 {
742 SV *old = *svp;
743 *svp = 0;
744 SvREFCNT_dec (old);
745 return 0;
746 }
747 }
748
749 return orig_sigelem_clr ? orig_sigelem_clr (aTHX_ sv, mg) : 0;
710} 750}
711 751
712static int 752static int
713coro_sigelem_set (pTHX_ SV *sv, MAGIC *mg) 753coro_sigelem_set (pTHX_ SV *sv, MAGIC *mg)
714{ 754{
… …
1583 else 1623 else
1584 coro->slot->runops = RUNOPS_DEFAULT; 1624 coro->slot->runops = RUNOPS_DEFAULT;
1585 } 1625 }
1586} 1626}
1587 1627
1628static int
1629coro_gensub_free (pTHX_ SV *sv, MAGIC *mg)
1630{
1631 AV *padlist;
1632 AV *av = (AV *)mg->mg_obj;
1633
1634 abort ();
1635
1636 return 0;
1637}
1638
1639static MGVTBL coro_gensub_vtbl = {
1640 0, 0, 0, 0,
1641 coro_gensub_free
1642};
1643
1588MODULE = Coro::State PACKAGE = Coro::State PREFIX = api_ 1644MODULE = Coro::State PACKAGE = Coro::State PREFIX = api_
1589 1645
1590PROTOTYPES: DISABLE 1646PROTOTYPES: DISABLE
1591 1647
1592BOOT: 1648BOOT:
… …
1597 BOOT_PAGESIZE; 1653 BOOT_PAGESIZE;
1598 1654
1599 irsgv = gv_fetchpv ("/" , GV_ADD|GV_NOTQUAL, SVt_PV); 1655 irsgv = gv_fetchpv ("/" , GV_ADD|GV_NOTQUAL, SVt_PV);
1600 stdoutgv = gv_fetchpv ("STDOUT", GV_ADD|GV_NOTQUAL, SVt_PVIO); 1656 stdoutgv = gv_fetchpv ("STDOUT", GV_ADD|GV_NOTQUAL, SVt_PVIO);
1601 1657
1602 orig_sigelem_get = PL_vtbl_sigelem.svt_get; 1658 orig_sigelem_get = PL_vtbl_sigelem.svt_get; PL_vtbl_sigelem.svt_get = coro_sigelem_get;
1603 PL_vtbl_sigelem.svt_get = coro_sigelem_get; 1659 orig_sigelem_set = PL_vtbl_sigelem.svt_set; PL_vtbl_sigelem.svt_set = coro_sigelem_set;
1604 orig_sigelem_set = PL_vtbl_sigelem.svt_set; 1660 orig_sigelem_clr = PL_vtbl_sigelem.svt_clear; PL_vtbl_sigelem.svt_clear = coro_sigelem_clr;
1605 PL_vtbl_sigelem.svt_set = coro_sigelem_set;
1606 1661
1607 hv_sig = coro_get_hv (aTHX_ "SIG", TRUE); 1662 hv_sig = coro_get_hv (aTHX_ "SIG", TRUE);
1608 rv_diehook = newRV_inc ((SV *)gv_fetchpv ("Coro::State::diehook" , 0, SVt_PVCV)); 1663 rv_diehook = newRV_inc ((SV *)gv_fetchpv ("Coro::State::diehook" , 0, SVt_PVCV));
1609 rv_warnhook = newRV_inc ((SV *)gv_fetchpv ("Coro::State::warnhook", 0, SVt_PVCV)); 1664 rv_warnhook = newRV_inc ((SV *)gv_fetchpv ("Coro::State::warnhook", 0, SVt_PVCV));
1610 1665
… …
1851force_cctx () 1906force_cctx ()
1852 CODE: 1907 CODE:
1853 struct coro *coro = SvSTATE (coro_current); 1908 struct coro *coro = SvSTATE (coro_current);
1854 coro->cctx->idle_sp = 0; 1909 coro->cctx->idle_sp = 0;
1855 1910
1856MODULE = Coro::State PACKAGE = Coro
1857
1858BOOT:
1859{
1860 int i;
1861
1862 av_async_pool = coro_get_av (aTHX_ "Coro::async_pool", TRUE);
1863 sv_pool_rss = coro_get_sv (aTHX_ "Coro::POOL_RSS" , TRUE);
1864 sv_pool_size = coro_get_sv (aTHX_ "Coro::POOL_SIZE" , TRUE);
1865
1866 coro_current = coro_get_sv (aTHX_ "Coro::current", FALSE);
1867 SvREADONLY_on (coro_current);
1868
1869 coro_stash = gv_stashpv ("Coro", TRUE);
1870
1871 newCONSTSUB (coro_stash, "PRIO_MAX", newSViv (PRIO_MAX));
1872 newCONSTSUB (coro_stash, "PRIO_HIGH", newSViv (PRIO_HIGH));
1873 newCONSTSUB (coro_stash, "PRIO_NORMAL", newSViv (PRIO_NORMAL));
1874 newCONSTSUB (coro_stash, "PRIO_LOW", newSViv (PRIO_LOW));
1875 newCONSTSUB (coro_stash, "PRIO_IDLE", newSViv (PRIO_IDLE));
1876 newCONSTSUB (coro_stash, "PRIO_MIN", newSViv (PRIO_MIN));
1877
1878 for (i = PRIO_MAX - PRIO_MIN + 1; i--; )
1879 coro_ready[i] = newAV ();
1880
1881 {
1882 SV *sv = perl_get_sv ("Coro::API", TRUE);
1883 perl_get_sv ("Coro::API", TRUE); /* silence 5.10 warning */
1884
1885 coroapi.schedule = api_schedule;
1886 coroapi.cede = api_cede;
1887 coroapi.cede_notself = api_cede_notself;
1888 coroapi.ready = api_ready;
1889 coroapi.is_ready = api_is_ready;
1890 coroapi.nready = &coro_nready;
1891 coroapi.current = coro_current;
1892
1893 GCoroAPI = &coroapi;
1894 sv_setiv (sv, (IV)&coroapi);
1895 SvREADONLY_on (sv);
1896 }
1897}
1898
1899void
1900_set_current (SV *current)
1901 PROTOTYPE: $
1902 CODE:
1903 SvREFCNT_dec (SvRV (coro_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;
1914
1915int
1916prio (Coro::State coro, int newprio = 0)
1917 ALIAS:
1918 nice = 1
1919 CODE:
1920{
1921 RETVAL = coro->prio;
1922
1923 if (items > 1)
1924 {
1925 if (ix)
1926 newprio = coro->prio - newprio;
1927
1928 if (newprio < PRIO_MIN) newprio = PRIO_MIN;
1929 if (newprio > PRIO_MAX) newprio = PRIO_MAX;
1930
1931 coro->prio = newprio;
1932 }
1933}
1934 OUTPUT:
1935 RETVAL
1936
1937SV *
1938ready (SV *self)
1939 PROTOTYPE: $
1940 CODE:
1941 RETVAL = boolSV (api_ready (self));
1942 OUTPUT:
1943 RETVAL
1944
1945int
1946nready (...)
1947 PROTOTYPE:
1948 CODE:
1949 RETVAL = coro_nready;
1950 OUTPUT:
1951 RETVAL
1952
1953void 1911void
1954throw (Coro::State self, SV *throw = &PL_sv_undef) 1912throw (Coro::State self, SV *throw = &PL_sv_undef)
1955 PROTOTYPE: $;$ 1913 PROTOTYPE: $;$
1956 CODE: 1914 CODE:
1957 SvREFCNT_dec (self->throw); 1915 SvREFCNT_dec (self->throw);
… …
1971 SV **dst = ix ? (SV **)&self->slot->defav : (SV **)&self->slot->defsv; 1929 SV **dst = ix ? (SV **)&self->slot->defav : (SV **)&self->slot->defsv;
1972 1930
1973 SV *tmp = *src; *src = *dst; *dst = tmp; 1931 SV *tmp = *src; *src = *dst; *dst = tmp;
1974 } 1932 }
1975 1933
1934MODULE = Coro::State PACKAGE = Coro
1935
1936BOOT:
1937{
1938 int i;
1939
1940 av_async_pool = coro_get_av (aTHX_ "Coro::async_pool", TRUE);
1941 sv_pool_rss = coro_get_sv (aTHX_ "Coro::POOL_RSS" , TRUE);
1942 sv_pool_size = coro_get_sv (aTHX_ "Coro::POOL_SIZE" , TRUE);
1943
1944 coro_current = coro_get_sv (aTHX_ "Coro::current", FALSE);
1945 SvREADONLY_on (coro_current);
1946
1947 coro_stash = gv_stashpv ("Coro", TRUE);
1948
1949 newCONSTSUB (coro_stash, "PRIO_MAX", newSViv (PRIO_MAX));
1950 newCONSTSUB (coro_stash, "PRIO_HIGH", newSViv (PRIO_HIGH));
1951 newCONSTSUB (coro_stash, "PRIO_NORMAL", newSViv (PRIO_NORMAL));
1952 newCONSTSUB (coro_stash, "PRIO_LOW", newSViv (PRIO_LOW));
1953 newCONSTSUB (coro_stash, "PRIO_IDLE", newSViv (PRIO_IDLE));
1954 newCONSTSUB (coro_stash, "PRIO_MIN", newSViv (PRIO_MIN));
1955
1956 for (i = PRIO_MAX - PRIO_MIN + 1; i--; )
1957 coro_ready[i] = newAV ();
1958
1959 {
1960 SV *sv = perl_get_sv ("Coro::API", TRUE);
1961 perl_get_sv ("Coro::API", TRUE); /* silence 5.10 warning */
1962
1963 coroapi.schedule = api_schedule;
1964 coroapi.cede = api_cede;
1965 coroapi.cede_notself = api_cede_notself;
1966 coroapi.ready = api_ready;
1967 coroapi.is_ready = api_is_ready;
1968 coroapi.nready = &coro_nready;
1969 coroapi.current = coro_current;
1970
1971 GCoroAPI = &coroapi;
1972 sv_setiv (sv, (IV)&coroapi);
1973 SvREADONLY_on (sv);
1974 }
1975}
1976
1977void
1978_set_current (SV *current)
1979 PROTOTYPE: $
1980 CODE:
1981 SvREFCNT_dec (SvRV (coro_current));
1982 SvRV_set (coro_current, SvREFCNT_inc (SvRV (current)));
1983
1984void
1985_set_readyhook (SV *hook)
1986 PROTOTYPE: $
1987 CODE:
1988 LOCK;
1989 SvREFCNT_dec (coro_readyhook);
1990 coro_readyhook = SvOK (hook) ? newSVsv (hook) : 0;
1991 UNLOCK;
1992
1993int
1994prio (Coro::State coro, int newprio = 0)
1995 ALIAS:
1996 nice = 1
1997 CODE:
1998{
1999 RETVAL = coro->prio;
2000
2001 if (items > 1)
2002 {
2003 if (ix)
2004 newprio = coro->prio - newprio;
2005
2006 if (newprio < PRIO_MIN) newprio = PRIO_MIN;
2007 if (newprio > PRIO_MAX) newprio = PRIO_MAX;
2008
2009 coro->prio = newprio;
2010 }
2011}
2012 OUTPUT:
2013 RETVAL
2014
2015SV *
2016ready (SV *self)
2017 PROTOTYPE: $
2018 CODE:
2019 RETVAL = boolSV (api_ready (self));
2020 OUTPUT:
2021 RETVAL
2022
2023int
2024nready (...)
2025 PROTOTYPE:
2026 CODE:
2027 RETVAL = coro_nready;
2028 OUTPUT:
2029 RETVAL
2030
1976# for async_pool speedup 2031# for async_pool speedup
1977void 2032void
1978_pool_1 (SV *cb) 2033_pool_1 (SV *cb)
1979 CODE: 2034 CODE:
1980{ 2035{
… …
1985 AV *invoke_av; 2040 AV *invoke_av;
1986 int i, len; 2041 int i, len;
1987 2042
1988 if (!invoke) 2043 if (!invoke)
1989 { 2044 {
1990 SvREFCNT_dec (PL_diehook); PL_diehook = 0; 2045 SV *old = PL_diehook;
2046 PL_diehook = 0;
2047 SvREFCNT_dec (old);
1991 croak ("\3async_pool terminate\2\n"); 2048 croak ("\3async_pool terminate\2\n");
1992 } 2049 }
1993 2050
1994 SvREFCNT_dec (coro->saved_deffh); 2051 SvREFCNT_dec (coro->saved_deffh);
1995 coro->saved_deffh = SvREFCNT_inc ((SV *)PL_defoutgv); 2052 coro->saved_deffh = SvREFCNT_inc ((SV *)PL_defoutgv);
… …
2024 coro->saved_deffh = 0; 2081 coro->saved_deffh = 0;
2025 2082
2026 if (coro_rss (aTHX_ coro) > SvIV (sv_pool_rss) 2083 if (coro_rss (aTHX_ coro) > SvIV (sv_pool_rss)
2027 || av_len (av_async_pool) + 1 >= SvIV (sv_pool_size)) 2084 || av_len (av_async_pool) + 1 >= SvIV (sv_pool_size))
2028 { 2085 {
2029 SvREFCNT_dec (PL_diehook); PL_diehook = 0; 2086 SV *old = PL_diehook;
2087 PL_diehook = 0;
2088 SvREFCNT_dec (old);
2030 croak ("\3async_pool terminate\2\n"); 2089 croak ("\3async_pool terminate\2\n");
2031 } 2090 }
2032 2091
2033 av_clear (GvAV (PL_defgv)); 2092 av_clear (GvAV (PL_defgv));
2034 hv_store ((HV *)SvRV (coro_current), "desc", sizeof ("desc") - 1, 2093 hv_store ((HV *)SvRV (coro_current), "desc", sizeof ("desc") - 1,
… …
2039 if (coro->cctx && (coro->cctx->flags & CC_TRACE)) 2098 if (coro->cctx && (coro->cctx->flags & CC_TRACE))
2040 api_trace (coro_current, 0); 2099 api_trace (coro_current, 0);
2041 2100
2042 av_push (av_async_pool, newSVsv (coro_current)); 2101 av_push (av_async_pool, newSVsv (coro_current));
2043} 2102}
2103
2104#if 0
2105
2106void
2107_generator_call (...)
2108 PROTOTYPE: @
2109 PPCODE:
2110 fprintf (stderr, "call %p\n", CvXSUBANY(cv).any_ptr);
2111 xxxx
2112 abort ();
2113
2114SV *
2115gensub (SV *sub, ...)
2116 PROTOTYPE: &;@
2117 CODE:
2118{
2119 struct coro *coro;
2120 MAGIC *mg;
2121 CV *xcv;
2122 CV *ncv = (CV *)newSV_type (SVt_PVCV);
2123 int i;
2124
2125 CvGV (ncv) = CvGV (cv);
2126 CvFILE (ncv) = CvFILE (cv);
2127
2128 Newz (0, coro, 1, struct coro);
2129 coro->args = newAV ();
2130 coro->flags = CF_NEW;
2131
2132 av_extend (coro->args, items - 1);
2133 for (i = 1; i < items; i++)
2134 av_push (coro->args, newSVsv (ST (i)));
2135
2136 CvISXSUB_on (ncv);
2137 CvXSUBANY (ncv).any_ptr = (void *)coro;
2138
2139 xcv = GvCV (gv_fetchpv ("Coro::_generator_call", 0, SVt_PVCV));
2140
2141 CvXSUB (ncv) = CvXSUB (xcv);
2142 CvANON_on (ncv);
2143
2144 mg = sv_magicext ((SV *)ncv, 0, CORO_MAGIC_type_state, &coro_gensub_vtbl, (char *)coro, 0);
2145 RETVAL = newRV_noinc ((SV *)ncv);
2146}
2147 OUTPUT:
2148 RETVAL
2149
2150#endif
2044 2151
2045 2152
2046MODULE = Coro::State PACKAGE = Coro::AIO 2153MODULE = Coro::State PACKAGE = Coro::AIO
2047 2154
2048SV * 2155SV *

Diff Legend

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