diff options
| author | Roberto Ierusalimschy <roberto@inf.puc-rio.br> | 2010-12-20 16:17:46 -0200 |
|---|---|---|
| committer | Roberto Ierusalimschy <roberto@inf.puc-rio.br> | 2010-12-20 16:17:46 -0200 |
| commit | 737f119187aca3c8f6743ec6e3cfc04e83723180 (patch) | |
| tree | 4e1bfb4b2bef35dd2acfe2915ab51481cd9ebc16 | |
| parent | 8980c630bf40e05dad71ded377e3d0f0a17b076c (diff) | |
| download | lua-737f119187aca3c8f6743ec6e3cfc04e83723180.tar.gz lua-737f119187aca3c8f6743ec6e3cfc04e83723180.tar.bz2 lua-737f119187aca3c8f6743ec6e3cfc04e83723180.zip | |
better control for GC running or stopped
| -rw-r--r-- | lapi.c | 14 | ||||
| -rw-r--r-- | lgc.c | 21 | ||||
| -rw-r--r-- | lgc.h | 6 | ||||
| -rw-r--r-- | lmem.c | 13 | ||||
| -rw-r--r-- | lstate.c | 5 | ||||
| -rw-r--r-- | lstate.h | 3 |
6 files changed, 31 insertions, 31 deletions
| @@ -1,5 +1,5 @@ | |||
| 1 | /* | 1 | /* |
| 2 | ** $Id: lapi.c,v 2.141 2010/11/18 19:15:00 roberto Exp roberto $ | 2 | ** $Id: lapi.c,v 2.141 2010/11/26 14:32:31 roberto Exp roberto $ |
| 3 | ** Lua API | 3 | ** Lua API |
| 4 | ** See Copyright Notice in lua.h | 4 | ** See Copyright Notice in lua.h |
| 5 | */ | 5 | */ |
| @@ -960,14 +960,16 @@ LUA_API int lua_gc (lua_State *L, int what, int data) { | |||
| 960 | g = G(L); | 960 | g = G(L); |
| 961 | switch (what) { | 961 | switch (what) { |
| 962 | case LUA_GCSTOP: { | 962 | case LUA_GCSTOP: { |
| 963 | stopgc(g); | 963 | g->gcrunning = 0; |
| 964 | break; | 964 | break; |
| 965 | } | 965 | } |
| 966 | case LUA_GCRESTART: { | 966 | case LUA_GCRESTART: { |
| 967 | g->GCdebt = 0; | 967 | g->GCdebt = 0; |
| 968 | g->gcrunning = 1; | ||
| 968 | break; | 969 | break; |
| 969 | } | 970 | } |
| 970 | case LUA_GCCOLLECT: { | 971 | case LUA_GCCOLLECT: { |
| 972 | g->gcrunning = 1; /* restart collector if stopped ?? */ | ||
| 971 | luaC_fullgc(L, 0); | 973 | luaC_fullgc(L, 0); |
| 972 | break; | 974 | break; |
| 973 | } | 975 | } |
| @@ -981,7 +983,8 @@ LUA_API int lua_gc (lua_State *L, int what, int data) { | |||
| 981 | break; | 983 | break; |
| 982 | } | 984 | } |
| 983 | case LUA_GCSTEP: { | 985 | case LUA_GCSTEP: { |
| 984 | int stopped = gcstopped(g); | 986 | int running = g->gcrunning; |
| 987 | g->gcrunning = 1; /* allow steps */ | ||
| 985 | if (g->gckind == KGC_GEN) { /* generational mode? */ | 988 | if (g->gckind == KGC_GEN) { /* generational mode? */ |
| 986 | res = (g->lastmajormem == 0); /* 1 if will do major collection */ | 989 | res = (g->lastmajormem == 0); /* 1 if will do major collection */ |
| 987 | luaC_step(L); /* do a single step */ | 990 | luaC_step(L); /* do a single step */ |
| @@ -995,8 +998,7 @@ LUA_API int lua_gc (lua_State *L, int what, int data) { | |||
| 995 | } | 998 | } |
| 996 | } | 999 | } |
| 997 | } | 1000 | } |
| 998 | if (stopped) /* collector was stopped? */ | 1001 | g->gcrunning = running; /* restore previous state */ |
| 999 | stopgc(g); /* keep it that way */ | ||
| 1000 | break; | 1002 | break; |
| 1001 | } | 1003 | } |
| 1002 | case LUA_GCSETPAUSE: { | 1004 | case LUA_GCSETPAUSE: { |
| @@ -1015,7 +1017,7 @@ LUA_API int lua_gc (lua_State *L, int what, int data) { | |||
| 1015 | break; | 1017 | break; |
| 1016 | } | 1018 | } |
| 1017 | case LUA_GCISRUNNING: { | 1019 | case LUA_GCISRUNNING: { |
| 1018 | res = !gcstopped(g); | 1020 | res = g->gcrunning; |
| 1019 | break; | 1021 | break; |
| 1020 | } | 1022 | } |
| 1021 | case LUA_GCGEN: { /* change collector to generational mode */ | 1023 | case LUA_GCGEN: { /* change collector to generational mode */ |
| @@ -1,5 +1,5 @@ | |||
| 1 | /* | 1 | /* |
| 2 | ** $Id: lgc.c,v 2.104 2010/11/26 14:32:31 roberto Exp roberto $ | 2 | ** $Id: lgc.c,v 2.105 2010/12/03 11:48:25 roberto Exp roberto $ |
| 3 | ** Garbage Collector | 3 | ** Garbage Collector |
| 4 | ** See Copyright Notice in lua.h | 4 | ** See Copyright Notice in lua.h |
| 5 | */ | 5 | */ |
| @@ -715,15 +715,15 @@ static void GCTM (lua_State *L, int propagateerrors) { | |||
| 715 | if (tm != NULL && ttisfunction(tm)) { /* is there a finalizer? */ | 715 | if (tm != NULL && ttisfunction(tm)) { /* is there a finalizer? */ |
| 716 | int status; | 716 | int status; |
| 717 | lu_byte oldah = L->allowhook; | 717 | lu_byte oldah = L->allowhook; |
| 718 | lu_mem oldd = g->GCdebt; | 718 | int running = g->gcrunning; |
| 719 | L->allowhook = 0; /* stop debug hooks during GC tag method */ | 719 | L->allowhook = 0; /* stop debug hooks during GC tag method */ |
| 720 | stopgc(g); /* avoid GC steps */ | 720 | g->gcrunning = 0; /* avoid GC steps */ |
| 721 | setobj2s(L, L->top, tm); /* push finalizer... */ | 721 | setobj2s(L, L->top, tm); /* push finalizer... */ |
| 722 | setobj2s(L, L->top + 1, &v); /* ... and its argument */ | 722 | setobj2s(L, L->top + 1, &v); /* ... and its argument */ |
| 723 | L->top += 2; /* and (next line) call the finalizer */ | 723 | L->top += 2; /* and (next line) call the finalizer */ |
| 724 | status = luaD_pcall(L, dothecall, NULL, savestack(L, L->top - 2), 0); | 724 | status = luaD_pcall(L, dothecall, NULL, savestack(L, L->top - 2), 0); |
| 725 | L->allowhook = oldah; /* restore hooks */ | 725 | L->allowhook = oldah; /* restore hooks */ |
| 726 | g->GCdebt = oldd; /* restore threshold */ | 726 | g->gcrunning = running; /* restore state */ |
| 727 | if (status != LUA_OK && propagateerrors) { /* error while running __gc? */ | 727 | if (status != LUA_OK && propagateerrors) { /* error while running __gc? */ |
| 728 | if (status == LUA_ERRRUN) { /* is there an error msg.? */ | 728 | if (status == LUA_ERRRUN) { /* is there an error msg.? */ |
| 729 | luaO_pushfstring(L, "error in __gc tag method (%s)", | 729 | luaO_pushfstring(L, "error in __gc tag method (%s)", |
| @@ -984,11 +984,14 @@ static void step (lua_State *L) { | |||
| 984 | 984 | ||
| 985 | 985 | ||
| 986 | void luaC_step (lua_State *L) { | 986 | void luaC_step (lua_State *L) { |
| 987 | int i; | 987 | global_State *g = G(L); |
| 988 | if (isgenerational(G(L))) generationalcollection(L); | 988 | if (g->gcrunning) { |
| 989 | else step(L); | 989 | int i; |
| 990 | for (i = 0; i < GCFINALIZENUM && G(L)->tobefnz; i++) | 990 | if (isgenerational(g)) generationalcollection(L); |
| 991 | GCTM(L, 1); /* Call a few pending finalizers */ | 991 | else step(L); |
| 992 | for (i = 0; i < GCFINALIZENUM && g->tobefnz; i++) | ||
| 993 | GCTM(L, 1); /* Call a few pending finalizers */ | ||
| 994 | } | ||
| 992 | } | 995 | } |
| 993 | 996 | ||
| 994 | 997 | ||
| @@ -1,5 +1,5 @@ | |||
| 1 | /* | 1 | /* |
| 2 | ** $Id: lgc.h,v 2.46 2010/12/02 19:51:15 roberto Exp roberto $ | 2 | ** $Id: lgc.h,v 2.47 2010/12/17 12:02:29 roberto Exp roberto $ |
| 3 | ** Garbage Collector | 3 | ** Garbage Collector |
| 4 | ** See Copyright Notice in lua.h | 4 | ** See Copyright Notice in lua.h |
| 5 | */ | 5 | */ |
| @@ -52,10 +52,6 @@ | |||
| 52 | #define keepinvariant(g) (isgenerational(g) || g->gcstate <= GCSatomic) | 52 | #define keepinvariant(g) (isgenerational(g) || g->gcstate <= GCSatomic) |
| 53 | 53 | ||
| 54 | 54 | ||
| 55 | #define gcstopped(g) ((g)->GCdebt == MIN_LMEM) | ||
| 56 | #define stopgc(g) ((g)->GCdebt = MIN_LMEM) | ||
| 57 | |||
| 58 | |||
| 59 | /* | 55 | /* |
| 60 | ** some useful bit tricks | 56 | ** some useful bit tricks |
| 61 | */ | 57 | */ |
| @@ -1,5 +1,5 @@ | |||
| 1 | /* | 1 | /* |
| 2 | ** $Id: lmem.c,v 1.78 2010/05/04 18:10:02 roberto Exp roberto $ | 2 | ** $Id: lmem.c,v 1.79 2010/05/05 18:49:56 roberto Exp roberto $ |
| 3 | ** Interface to Memory Manager | 3 | ** Interface to Memory Manager |
| 4 | ** See Copyright Notice in lua.h | 4 | ** See Copyright Notice in lua.h |
| 5 | */ | 5 | */ |
| @@ -79,14 +79,14 @@ void *luaM_realloc_ (lua_State *L, void *block, size_t osize, size_t nsize) { | |||
| 79 | size_t realosize = (block) ? osize : 0; | 79 | size_t realosize = (block) ? osize : 0; |
| 80 | lua_assert((realosize == 0) == (block == NULL)); | 80 | lua_assert((realosize == 0) == (block == NULL)); |
| 81 | #if defined(HARDMEMTESTS) | 81 | #if defined(HARDMEMTESTS) |
| 82 | if (nsize > realosize && !gcstopped(g)) | 82 | if (nsize > realosize && g->gcrunning) |
| 83 | luaC_fullgc(L, 1); /* force a GC whenever possible */ | 83 | luaC_fullgc(L, 1); /* force a GC whenever possible */ |
| 84 | #endif | 84 | #endif |
| 85 | newblock = (*g->frealloc)(g->ud, block, osize, nsize); | 85 | newblock = (*g->frealloc)(g->ud, block, osize, nsize); |
| 86 | if (newblock == NULL && nsize > 0) { | 86 | if (newblock == NULL && nsize > 0) { |
| 87 | api_check(L, nsize > realosize, | 87 | api_check(L, nsize > realosize, |
| 88 | "realloc cannot fail when shrinking a block"); | 88 | "realloc cannot fail when shrinking a block"); |
| 89 | if (!gcstopped(g)) { | 89 | if (g->gcrunning) { |
| 90 | luaC_fullgc(L, 1); /* try to free some memory... */ | 90 | luaC_fullgc(L, 1); /* try to free some memory... */ |
| 91 | newblock = (*g->frealloc)(g->ud, block, osize, nsize); /* try again */ | 91 | newblock = (*g->frealloc)(g->ud, block, osize, nsize); /* try again */ |
| 92 | } | 92 | } |
| @@ -95,8 +95,7 @@ void *luaM_realloc_ (lua_State *L, void *block, size_t osize, size_t nsize) { | |||
| 95 | } | 95 | } |
| 96 | lua_assert((nsize == 0) == (newblock == NULL)); | 96 | lua_assert((nsize == 0) == (newblock == NULL)); |
| 97 | g->totalbytes = (g->totalbytes - realosize) + nsize; | 97 | g->totalbytes = (g->totalbytes - realosize) + nsize; |
| 98 | if (!gcstopped(g)) | 98 | g->GCdebt += nsize; /* give some credit to garbage collector */ |
| 99 | g->GCdebt += nsize; /* give some credit to garbage collector */ | ||
| 100 | #if defined(TRACEMEM) | 99 | #if defined(TRACEMEM) |
| 101 | { /* auxiliary patch to monitor garbage collection. | 100 | { /* auxiliary patch to monitor garbage collection. |
| 102 | ** To plot, gnuplot with following command: | 101 | ** To plot, gnuplot with following command: |
| @@ -108,9 +107,7 @@ void *luaM_realloc_ (lua_State *L, void *block, size_t osize, size_t nsize) { | |||
| 108 | if ((total % 200) == 0) { | 107 | if ((total % 200) == 0) { |
| 109 | if (f == NULL) f = fopen(TRACEMEM, "w"); | 108 | if (f == NULL) f = fopen(TRACEMEM, "w"); |
| 110 | fprintf(f, "%lu %u %d %d\n", total, | 109 | fprintf(f, "%lu %u %d %d\n", total, |
| 111 | g->totalbytes, | 110 | g->totalbytes, g->GCdebt, g->gcstate * 1000); |
| 112 | gcstopped(g) ? 0 : g->GCdebt, | ||
| 113 | g->gcstate * 1000); | ||
| 114 | } | 111 | } |
| 115 | } | 112 | } |
| 116 | #endif | 113 | #endif |
| @@ -1,5 +1,5 @@ | |||
| 1 | /* | 1 | /* |
| 2 | ** $Id: lstate.c,v 2.86 2010/09/03 14:14:01 roberto Exp roberto $ | 2 | ** $Id: lstate.c,v 2.87 2010/11/26 14:32:31 roberto Exp roberto $ |
| 3 | ** Global State | 3 | ** Global State |
| 4 | ** See Copyright Notice in lua.h | 4 | ** See Copyright Notice in lua.h |
| 5 | */ | 5 | */ |
| @@ -155,6 +155,7 @@ static void f_luaopen (lua_State *L, void *ud) { | |||
| 155 | g->memerrmsg = luaS_newliteral(L, MEMERRMSG); | 155 | g->memerrmsg = luaS_newliteral(L, MEMERRMSG); |
| 156 | luaS_fix(g->memerrmsg); /* it should never be collected */ | 156 | luaS_fix(g->memerrmsg); /* it should never be collected */ |
| 157 | g->GCdebt = 0; | 157 | g->GCdebt = 0; |
| 158 | g->gcrunning = 1; /* allow gc */ | ||
| 158 | } | 159 | } |
| 159 | 160 | ||
| 160 | 161 | ||
| @@ -241,7 +242,7 @@ LUA_API lua_State *lua_newstate (lua_Alloc f, void *ud) { | |||
| 241 | g->mainthread = L; | 242 | g->mainthread = L; |
| 242 | g->uvhead.u.l.prev = &g->uvhead; | 243 | g->uvhead.u.l.prev = &g->uvhead; |
| 243 | g->uvhead.u.l.next = &g->uvhead; | 244 | g->uvhead.u.l.next = &g->uvhead; |
| 244 | stopgc(g); /* no GC while building state */ | 245 | g->gcrunning = 0; /* no GC while building state */ |
| 245 | g->lastmajormem = 0; | 246 | g->lastmajormem = 0; |
| 246 | g->strt.size = 0; | 247 | g->strt.size = 0; |
| 247 | g->strt.nuse = 0; | 248 | g->strt.nuse = 0; |
| @@ -1,5 +1,5 @@ | |||
| 1 | /* | 1 | /* |
| 2 | ** $Id: lstate.h,v 2.68 2010/10/29 17:52:46 roberto Exp roberto $ | 2 | ** $Id: lstate.h,v 2.69 2010/11/26 14:32:31 roberto Exp roberto $ |
| 3 | ** Global State | 3 | ** Global State |
| 4 | ** See Copyright Notice in lua.h | 4 | ** See Copyright Notice in lua.h |
| 5 | */ | 5 | */ |
| @@ -123,6 +123,7 @@ typedef struct global_State { | |||
| 123 | lu_byte currentwhite; | 123 | lu_byte currentwhite; |
| 124 | lu_byte gcstate; /* state of garbage collector */ | 124 | lu_byte gcstate; /* state of garbage collector */ |
| 125 | lu_byte gckind; /* kind of GC running */ | 125 | lu_byte gckind; /* kind of GC running */ |
| 126 | lu_byte gcrunning; /* true if GC is running */ | ||
| 126 | int sweepstrgc; /* position of sweep in `strt' */ | 127 | int sweepstrgc; /* position of sweep in `strt' */ |
| 127 | GCObject *allgc; /* list of all collectable objects */ | 128 | GCObject *allgc; /* list of all collectable objects */ |
| 128 | GCObject *finobj; /* list of collectable objects with finalizers */ | 129 | GCObject *finobj; /* list of collectable objects with finalizers */ |
