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.240 by root, Sun Jun 29 00:28:17 2008 UTC vs.
Revision 1.242 by root, Thu Aug 14 12:48:20 2008 UTC

… …
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); 688static int (*orig_sigelem_clr) (pTHX_ SV *sv, MAGIC *mg);
689 689
690/* apparently < 5.8.8 */ 690/* apparently < 5.8.8 */
691#undef MgPV_nolen_const
692#ifndef MgPV_nolen_const 691#ifndef MgPV_nolen_const
693#define MgPV_nolen_const(mg) (((((int)(mg)->mg_len)) == HEf_SVKEY) ? \ 692#define MgPV_nolen_const(mg) (((((int)(mg)->mg_len)) == HEf_SVKEY) ? \
694 SvPV_nolen_const((SV*)((mg)->mg_ptr)) : \ 693 SvPV_nolen((SV*)((mg)->mg_ptr)) : \
695 (const char*)(mg)->mg_ptr) 694 (const char*)(mg)->mg_ptr)
696#endif 695#endif
697 696
698/* 697/*
699 * This overrides the default magic get method of %SIG elements. 698 * This overrides the default magic get method of %SIG elements.
… …
1891force_cctx () 1890force_cctx ()
1892 CODE: 1891 CODE:
1893 struct coro *coro = SvSTATE (coro_current); 1892 struct coro *coro = SvSTATE (coro_current);
1894 coro->cctx->idle_sp = 0; 1893 coro->cctx->idle_sp = 0;
1895 1894
1896MODULE = Coro::State PACKAGE = Coro
1897
1898BOOT:
1899{
1900 int i;
1901
1902 av_async_pool = coro_get_av (aTHX_ "Coro::async_pool", TRUE);
1903 sv_pool_rss = coro_get_sv (aTHX_ "Coro::POOL_RSS" , TRUE);
1904 sv_pool_size = coro_get_sv (aTHX_ "Coro::POOL_SIZE" , TRUE);
1905
1906 coro_current = coro_get_sv (aTHX_ "Coro::current", FALSE);
1907 SvREADONLY_on (coro_current);
1908
1909 coro_stash = gv_stashpv ("Coro", TRUE);
1910
1911 newCONSTSUB (coro_stash, "PRIO_MAX", newSViv (PRIO_MAX));
1912 newCONSTSUB (coro_stash, "PRIO_HIGH", newSViv (PRIO_HIGH));
1913 newCONSTSUB (coro_stash, "PRIO_NORMAL", newSViv (PRIO_NORMAL));
1914 newCONSTSUB (coro_stash, "PRIO_LOW", newSViv (PRIO_LOW));
1915 newCONSTSUB (coro_stash, "PRIO_IDLE", newSViv (PRIO_IDLE));
1916 newCONSTSUB (coro_stash, "PRIO_MIN", newSViv (PRIO_MIN));
1917
1918 for (i = PRIO_MAX - PRIO_MIN + 1; i--; )
1919 coro_ready[i] = newAV ();
1920
1921 {
1922 SV *sv = perl_get_sv ("Coro::API", TRUE);
1923 perl_get_sv ("Coro::API", TRUE); /* silence 5.10 warning */
1924
1925 coroapi.schedule = api_schedule;
1926 coroapi.cede = api_cede;
1927 coroapi.cede_notself = api_cede_notself;
1928 coroapi.ready = api_ready;
1929 coroapi.is_ready = api_is_ready;
1930 coroapi.nready = &coro_nready;
1931 coroapi.current = coro_current;
1932
1933 GCoroAPI = &coroapi;
1934 sv_setiv (sv, (IV)&coroapi);
1935 SvREADONLY_on (sv);
1936 }
1937}
1938
1939void
1940_set_current (SV *current)
1941 PROTOTYPE: $
1942 CODE:
1943 SvREFCNT_dec (SvRV (coro_current));
1944 SvRV_set (coro_current, SvREFCNT_inc (SvRV (current)));
1945
1946void
1947_set_readyhook (SV *hook)
1948 PROTOTYPE: $
1949 CODE:
1950 LOCK;
1951 SvREFCNT_dec (coro_readyhook);
1952 coro_readyhook = SvOK (hook) ? newSVsv (hook) : 0;
1953 UNLOCK;
1954
1955int
1956prio (Coro::State coro, int newprio = 0)
1957 ALIAS:
1958 nice = 1
1959 CODE:
1960{
1961 RETVAL = coro->prio;
1962
1963 if (items > 1)
1964 {
1965 if (ix)
1966 newprio = coro->prio - newprio;
1967
1968 if (newprio < PRIO_MIN) newprio = PRIO_MIN;
1969 if (newprio > PRIO_MAX) newprio = PRIO_MAX;
1970
1971 coro->prio = newprio;
1972 }
1973}
1974 OUTPUT:
1975 RETVAL
1976
1977SV *
1978ready (SV *self)
1979 PROTOTYPE: $
1980 CODE:
1981 RETVAL = boolSV (api_ready (self));
1982 OUTPUT:
1983 RETVAL
1984
1985int
1986nready (...)
1987 PROTOTYPE:
1988 CODE:
1989 RETVAL = coro_nready;
1990 OUTPUT:
1991 RETVAL
1992
1993void 1895void
1994throw (Coro::State self, SV *throw = &PL_sv_undef) 1896throw (Coro::State self, SV *throw = &PL_sv_undef)
1995 PROTOTYPE: $;$ 1897 PROTOTYPE: $;$
1996 CODE: 1898 CODE:
1997 SvREFCNT_dec (self->throw); 1899 SvREFCNT_dec (self->throw);
… …
2011 SV **dst = ix ? (SV **)&self->slot->defav : (SV **)&self->slot->defsv; 1913 SV **dst = ix ? (SV **)&self->slot->defav : (SV **)&self->slot->defsv;
2012 1914
2013 SV *tmp = *src; *src = *dst; *dst = tmp; 1915 SV *tmp = *src; *src = *dst; *dst = tmp;
2014 } 1916 }
2015 1917
1918MODULE = Coro::State PACKAGE = Coro
1919
1920BOOT:
1921{
1922 int i;
1923
1924 av_async_pool = coro_get_av (aTHX_ "Coro::async_pool", TRUE);
1925 sv_pool_rss = coro_get_sv (aTHX_ "Coro::POOL_RSS" , TRUE);
1926 sv_pool_size = coro_get_sv (aTHX_ "Coro::POOL_SIZE" , TRUE);
1927
1928 coro_current = coro_get_sv (aTHX_ "Coro::current", FALSE);
1929 SvREADONLY_on (coro_current);
1930
1931 coro_stash = gv_stashpv ("Coro", TRUE);
1932
1933 newCONSTSUB (coro_stash, "PRIO_MAX", newSViv (PRIO_MAX));
1934 newCONSTSUB (coro_stash, "PRIO_HIGH", newSViv (PRIO_HIGH));
1935 newCONSTSUB (coro_stash, "PRIO_NORMAL", newSViv (PRIO_NORMAL));
1936 newCONSTSUB (coro_stash, "PRIO_LOW", newSViv (PRIO_LOW));
1937 newCONSTSUB (coro_stash, "PRIO_IDLE", newSViv (PRIO_IDLE));
1938 newCONSTSUB (coro_stash, "PRIO_MIN", newSViv (PRIO_MIN));
1939
1940 for (i = PRIO_MAX - PRIO_MIN + 1; i--; )
1941 coro_ready[i] = newAV ();
1942
1943 {
1944 SV *sv = perl_get_sv ("Coro::API", TRUE);
1945 perl_get_sv ("Coro::API", TRUE); /* silence 5.10 warning */
1946
1947 coroapi.schedule = api_schedule;
1948 coroapi.cede = api_cede;
1949 coroapi.cede_notself = api_cede_notself;
1950 coroapi.ready = api_ready;
1951 coroapi.is_ready = api_is_ready;
1952 coroapi.nready = &coro_nready;
1953 coroapi.current = coro_current;
1954
1955 GCoroAPI = &coroapi;
1956 sv_setiv (sv, (IV)&coroapi);
1957 SvREADONLY_on (sv);
1958 }
1959}
1960
1961void
1962_set_current (SV *current)
1963 PROTOTYPE: $
1964 CODE:
1965 SvREFCNT_dec (SvRV (coro_current));
1966 SvRV_set (coro_current, SvREFCNT_inc (SvRV (current)));
1967
1968void
1969_set_readyhook (SV *hook)
1970 PROTOTYPE: $
1971 CODE:
1972 LOCK;
1973 SvREFCNT_dec (coro_readyhook);
1974 coro_readyhook = SvOK (hook) ? newSVsv (hook) : 0;
1975 UNLOCK;
1976
1977int
1978prio (Coro::State coro, int newprio = 0)
1979 ALIAS:
1980 nice = 1
1981 CODE:
1982{
1983 RETVAL = coro->prio;
1984
1985 if (items > 1)
1986 {
1987 if (ix)
1988 newprio = coro->prio - newprio;
1989
1990 if (newprio < PRIO_MIN) newprio = PRIO_MIN;
1991 if (newprio > PRIO_MAX) newprio = PRIO_MAX;
1992
1993 coro->prio = newprio;
1994 }
1995}
1996 OUTPUT:
1997 RETVAL
1998
1999SV *
2000ready (SV *self)
2001 PROTOTYPE: $
2002 CODE:
2003 RETVAL = boolSV (api_ready (self));
2004 OUTPUT:
2005 RETVAL
2006
2007int
2008nready (...)
2009 PROTOTYPE:
2010 CODE:
2011 RETVAL = coro_nready;
2012 OUTPUT:
2013 RETVAL
2014
2016# for async_pool speedup 2015# for async_pool speedup
2017void 2016void
2018_pool_1 (SV *cb) 2017_pool_1 (SV *cb)
2019 CODE: 2018 CODE:
2020{ 2019{

Diff Legend

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