1 | /* |
2 | ** $Id: lstate.c $ |
3 | ** Global State |
4 | ** See Copyright Notice in lua.h |
5 | */ |
6 | |
7 | #define lstate_c |
8 | #define LUA_CORE |
9 | |
10 | #include "lprefix.h" |
11 | |
12 | |
13 | #include <stddef.h> |
14 | #include <string.h> |
15 | |
16 | #include "lua.h" |
17 | |
18 | #include "lapi.h" |
19 | #include "ldebug.h" |
20 | #include "ldo.h" |
21 | #include "lfunc.h" |
22 | #include "lgc.h" |
23 | #include "llex.h" |
24 | #include "lmem.h" |
25 | #include "lstate.h" |
26 | #include "lstring.h" |
27 | #include "ltable.h" |
28 | #include "ltm.h" |
29 | |
30 | |
31 | |
32 | /* |
33 | ** thread state + extra space |
34 | */ |
35 | typedef struct LX { |
36 | lu_byte [LUA_EXTRASPACE]; |
37 | lua_State l; |
38 | } LX; |
39 | |
40 | |
41 | /* |
42 | ** Main thread combines a thread state and the global state |
43 | */ |
44 | typedef struct LG { |
45 | LX l; |
46 | global_State g; |
47 | } LG; |
48 | |
49 | |
50 | |
51 | #define fromstate(L) (cast(LX *, cast(lu_byte *, (L)) - offsetof(LX, l))) |
52 | |
53 | |
54 | /* |
55 | ** A macro to create a "random" seed when a state is created; |
56 | ** the seed is used to randomize string hashes. |
57 | */ |
58 | #if !defined(luai_makeseed) |
59 | |
60 | #include <time.h> |
61 | |
62 | /* |
63 | ** Compute an initial seed with some level of randomness. |
64 | ** Rely on Address Space Layout Randomization (if present) and |
65 | ** current time. |
66 | */ |
67 | #define addbuff(b,p,e) \ |
68 | { size_t t = cast_sizet(e); \ |
69 | memcpy(b + p, &t, sizeof(t)); p += sizeof(t); } |
70 | |
71 | static unsigned int luai_makeseed (lua_State *L) { |
72 | char buff[3 * sizeof(size_t)]; |
73 | unsigned int h = cast_uint(time(NULL)); |
74 | int p = 0; |
75 | addbuff(buff, p, L); /* heap variable */ |
76 | addbuff(buff, p, &h); /* local variable */ |
77 | addbuff(buff, p, &lua_newstate); /* public function */ |
78 | lua_assert(p == sizeof(buff)); |
79 | return luaS_hash(buff, p, h); |
80 | } |
81 | |
82 | #endif |
83 | |
84 | |
85 | /* |
86 | ** set GCdebt to a new value keeping the value (totalbytes + GCdebt) |
87 | ** invariant (and avoiding underflows in 'totalbytes') |
88 | */ |
89 | void luaE_setdebt (global_State *g, l_mem debt) { |
90 | l_mem tb = gettotalbytes(g); |
91 | lua_assert(tb > 0); |
92 | if (debt < tb - MAX_LMEM) |
93 | debt = tb - MAX_LMEM; /* will make 'totalbytes == MAX_LMEM' */ |
94 | g->totalbytes = tb - debt; |
95 | g->GCdebt = debt; |
96 | } |
97 | |
98 | |
99 | LUA_API int lua_setcstacklimit (lua_State *L, unsigned int limit) { |
100 | UNUSED(L); UNUSED(limit); |
101 | return LUAI_MAXCCALLS; /* warning?? */ |
102 | } |
103 | |
104 | |
105 | CallInfo *luaE_extendCI (lua_State *L) { |
106 | CallInfo *ci; |
107 | lua_assert(L->ci->next == NULL); |
108 | ci = luaM_new(L, CallInfo); |
109 | lua_assert(L->ci->next == NULL); |
110 | L->ci->next = ci; |
111 | ci->previous = L->ci; |
112 | ci->next = NULL; |
113 | ci->u.l.trap = 0; |
114 | L->nci++; |
115 | return ci; |
116 | } |
117 | |
118 | |
119 | /* |
120 | ** free all CallInfo structures not in use by a thread |
121 | */ |
122 | void luaE_freeCI (lua_State *L) { |
123 | CallInfo *ci = L->ci; |
124 | CallInfo *next = ci->next; |
125 | ci->next = NULL; |
126 | while ((ci = next) != NULL) { |
127 | next = ci->next; |
128 | luaM_free(L, ci); |
129 | L->nci--; |
130 | } |
131 | } |
132 | |
133 | |
134 | /* |
135 | ** free half of the CallInfo structures not in use by a thread, |
136 | ** keeping the first one. |
137 | */ |
138 | void luaE_shrinkCI (lua_State *L) { |
139 | CallInfo *ci = L->ci->next; /* first free CallInfo */ |
140 | CallInfo *next; |
141 | if (ci == NULL) |
142 | return; /* no extra elements */ |
143 | while ((next = ci->next) != NULL) { /* two extra elements? */ |
144 | CallInfo *next2 = next->next; /* next's next */ |
145 | ci->next = next2; /* remove next from the list */ |
146 | L->nci--; |
147 | luaM_free(L, next); /* free next */ |
148 | if (next2 == NULL) |
149 | break; /* no more elements */ |
150 | else { |
151 | next2->previous = ci; |
152 | ci = next2; /* continue */ |
153 | } |
154 | } |
155 | } |
156 | |
157 | |
158 | /* |
159 | ** Called when 'getCcalls(L)' larger or equal to LUAI_MAXCCALLS. |
160 | ** If equal, raises an overflow error. If value is larger than |
161 | ** LUAI_MAXCCALLS (which means it is handling an overflow) but |
162 | ** not much larger, does not report an error (to allow overflow |
163 | ** handling to work). |
164 | */ |
165 | void luaE_checkcstack (lua_State *L) { |
166 | if (getCcalls(L) == LUAI_MAXCCALLS) |
167 | luaG_runerror(L, "C stack overflow" ); |
168 | else if (getCcalls(L) >= (LUAI_MAXCCALLS / 10 * 11)) |
169 | luaD_throw(L, LUA_ERRERR); /* error while handing stack error */ |
170 | } |
171 | |
172 | |
173 | LUAI_FUNC void luaE_incCstack (lua_State *L) { |
174 | L->nCcalls++; |
175 | if (l_unlikely(getCcalls(L) >= LUAI_MAXCCALLS)) |
176 | luaE_checkcstack(L); |
177 | } |
178 | |
179 | |
180 | static void stack_init (lua_State *L1, lua_State *L) { |
181 | int i; CallInfo *ci; |
182 | /* initialize stack array */ |
183 | L1->stack = luaM_newvector(L, BASIC_STACK_SIZE + EXTRA_STACK, StackValue); |
184 | L1->tbclist = L1->stack; |
185 | for (i = 0; i < BASIC_STACK_SIZE + EXTRA_STACK; i++) |
186 | setnilvalue(s2v(L1->stack + i)); /* erase new stack */ |
187 | L1->top = L1->stack; |
188 | L1->stack_last = L1->stack + BASIC_STACK_SIZE; |
189 | /* initialize first ci */ |
190 | ci = &L1->base_ci; |
191 | ci->next = ci->previous = NULL; |
192 | ci->callstatus = CIST_C; |
193 | ci->func = L1->top; |
194 | ci->u.c.k = NULL; |
195 | ci->nresults = 0; |
196 | setnilvalue(s2v(L1->top)); /* 'function' entry for this 'ci' */ |
197 | L1->top++; |
198 | ci->top = L1->top + LUA_MINSTACK; |
199 | L1->ci = ci; |
200 | } |
201 | |
202 | |
203 | static void freestack (lua_State *L) { |
204 | if (L->stack == NULL) |
205 | return; /* stack not completely built yet */ |
206 | L->ci = &L->base_ci; /* free the entire 'ci' list */ |
207 | luaE_freeCI(L); |
208 | lua_assert(L->nci == 0); |
209 | luaM_freearray(L, L->stack, stacksize(L) + EXTRA_STACK); /* free stack */ |
210 | } |
211 | |
212 | |
213 | /* |
214 | ** Create registry table and its predefined values |
215 | */ |
216 | static void init_registry (lua_State *L, global_State *g) { |
217 | /* create registry */ |
218 | Table *registry = luaH_new(L); |
219 | sethvalue(L, &g->l_registry, registry); |
220 | luaH_resize(L, registry, LUA_RIDX_LAST, 0); |
221 | /* registry[LUA_RIDX_MAINTHREAD] = L */ |
222 | setthvalue(L, ®istry->array[LUA_RIDX_MAINTHREAD - 1], L); |
223 | /* registry[LUA_RIDX_GLOBALS] = new table (table of globals) */ |
224 | sethvalue(L, ®istry->array[LUA_RIDX_GLOBALS - 1], luaH_new(L)); |
225 | } |
226 | |
227 | |
228 | /* |
229 | ** open parts of the state that may cause memory-allocation errors. |
230 | */ |
231 | static void f_luaopen (lua_State *L, void *ud) { |
232 | global_State *g = G(L); |
233 | UNUSED(ud); |
234 | stack_init(L, L); /* init stack */ |
235 | init_registry(L, g); |
236 | luaS_init(L); |
237 | luaT_init(L); |
238 | luaX_init(L); |
239 | g->gcrunning = 1; /* allow gc */ |
240 | setnilvalue(&g->nilvalue); /* now state is complete */ |
241 | luai_userstateopen(L); |
242 | } |
243 | |
244 | |
245 | /* |
246 | ** preinitialize a thread with consistent values without allocating |
247 | ** any memory (to avoid errors) |
248 | */ |
249 | static void preinit_thread (lua_State *L, global_State *g) { |
250 | G(L) = g; |
251 | L->stack = NULL; |
252 | L->ci = NULL; |
253 | L->nci = 0; |
254 | L->twups = L; /* thread has no upvalues */ |
255 | L->nCcalls = 0; |
256 | L->errorJmp = NULL; |
257 | L->hook = NULL; |
258 | L->hookmask = 0; |
259 | L->basehookcount = 0; |
260 | L->allowhook = 1; |
261 | resethookcount(L); |
262 | L->openupval = NULL; |
263 | L->status = LUA_OK; |
264 | L->errfunc = 0; |
265 | L->oldpc = 0; |
266 | } |
267 | |
268 | |
269 | static void close_state (lua_State *L) { |
270 | global_State *g = G(L); |
271 | if (!completestate(g)) /* closing a partially built state? */ |
272 | luaC_freeallobjects(L); /* jucst collect its objects */ |
273 | else { /* closing a fully built state */ |
274 | luaD_closeprotected(L, 1, LUA_OK); /* close all upvalues */ |
275 | luaC_freeallobjects(L); /* collect all objects */ |
276 | luai_userstateclose(L); |
277 | } |
278 | luaM_freearray(L, G(L)->strt.hash, G(L)->strt.size); |
279 | freestack(L); |
280 | lua_assert(gettotalbytes(g) == sizeof(LG)); |
281 | (*g->frealloc)(g->ud, fromstate(L), sizeof(LG), 0); /* free main block */ |
282 | } |
283 | |
284 | |
285 | LUA_API lua_State *lua_newthread (lua_State *L) { |
286 | global_State *g; |
287 | lua_State *L1; |
288 | lua_lock(L); |
289 | g = G(L); |
290 | luaC_checkGC(L); |
291 | /* create new thread */ |
292 | L1 = &cast(LX *, luaM_newobject(L, LUA_TTHREAD, sizeof(LX)))->l; |
293 | L1->marked = luaC_white(g); |
294 | L1->tt = LUA_VTHREAD; |
295 | /* link it on list 'allgc' */ |
296 | L1->next = g->allgc; |
297 | g->allgc = obj2gco(L1); |
298 | /* anchor it on L stack */ |
299 | setthvalue2s(L, L->top, L1); |
300 | api_incr_top(L); |
301 | preinit_thread(L1, g); |
302 | L1->hookmask = L->hookmask; |
303 | L1->basehookcount = L->basehookcount; |
304 | L1->hook = L->hook; |
305 | resethookcount(L1); |
306 | /* initialize L1 extra space */ |
307 | memcpy(lua_getextraspace(L1), lua_getextraspace(g->mainthread), |
308 | LUA_EXTRASPACE); |
309 | luai_userstatethread(L, L1); |
310 | stack_init(L1, L); /* init stack */ |
311 | lua_unlock(L); |
312 | return L1; |
313 | } |
314 | |
315 | |
316 | void luaE_freethread (lua_State *L, lua_State *L1) { |
317 | LX *l = fromstate(L1); |
318 | luaF_closeupval(L1, L1->stack); /* close all upvalues */ |
319 | lua_assert(L1->openupval == NULL); |
320 | luai_userstatefree(L, L1); |
321 | freestack(L1); |
322 | luaM_free(L, l); |
323 | } |
324 | |
325 | |
326 | int luaE_resetthread (lua_State *L, int status) { |
327 | CallInfo *ci = L->ci = &L->base_ci; /* unwind CallInfo list */ |
328 | setnilvalue(s2v(L->stack)); /* 'function' entry for basic 'ci' */ |
329 | ci->func = L->stack; |
330 | ci->callstatus = CIST_C; |
331 | if (status == LUA_YIELD) |
332 | status = LUA_OK; |
333 | status = luaD_closeprotected(L, 1, status); |
334 | if (status != LUA_OK) /* errors? */ |
335 | luaD_seterrorobj(L, status, L->stack + 1); |
336 | else |
337 | L->top = L->stack + 1; |
338 | ci->top = L->top + LUA_MINSTACK; |
339 | L->status = cast_byte(status); |
340 | luaD_reallocstack(L, cast_int(ci->top - L->stack), 0); |
341 | return status; |
342 | } |
343 | |
344 | |
345 | LUA_API int lua_resetthread (lua_State *L) { |
346 | int status; |
347 | lua_lock(L); |
348 | status = luaE_resetthread(L, L->status); |
349 | lua_unlock(L); |
350 | return status; |
351 | } |
352 | |
353 | |
354 | LUA_API lua_State *lua_newstate (lua_Alloc f, void *ud) { |
355 | int i; |
356 | lua_State *L; |
357 | global_State *g; |
358 | LG *l = cast(LG *, (*f)(ud, NULL, LUA_TTHREAD, sizeof(LG))); |
359 | if (l == NULL) return NULL; |
360 | L = &l->l.l; |
361 | g = &l->g; |
362 | L->tt = LUA_VTHREAD; |
363 | g->currentwhite = bitmask(WHITE0BIT); |
364 | L->marked = luaC_white(g); |
365 | preinit_thread(L, g); |
366 | g->allgc = obj2gco(L); /* by now, only object is the main thread */ |
367 | L->next = NULL; |
368 | incnny(L); /* main thread is always non yieldable */ |
369 | g->frealloc = f; |
370 | g->ud = ud; |
371 | g->warnf = NULL; |
372 | g->ud_warn = NULL; |
373 | g->mainthread = L; |
374 | g->seed = luai_makeseed(L); |
375 | g->gcrunning = 0; /* no GC while building state */ |
376 | g->strt.size = g->strt.nuse = 0; |
377 | g->strt.hash = NULL; |
378 | setnilvalue(&g->l_registry); |
379 | g->panic = NULL; |
380 | g->gcstate = GCSpause; |
381 | g->gckind = KGC_INC; |
382 | g->gcstopem = 0; |
383 | g->gcemergency = 0; |
384 | g->finobj = g->tobefnz = g->fixedgc = NULL; |
385 | g->firstold1 = g->survival = g->old1 = g->reallyold = NULL; |
386 | g->finobjsur = g->finobjold1 = g->finobjrold = NULL; |
387 | g->sweepgc = NULL; |
388 | g->gray = g->grayagain = NULL; |
389 | g->weak = g->ephemeron = g->allweak = NULL; |
390 | g->twups = NULL; |
391 | g->totalbytes = sizeof(LG); |
392 | g->GCdebt = 0; |
393 | g->lastatomic = 0; |
394 | setivalue(&g->nilvalue, 0); /* to signal that state is not yet built */ |
395 | setgcparam(g->gcpause, LUAI_GCPAUSE); |
396 | setgcparam(g->gcstepmul, LUAI_GCMUL); |
397 | g->gcstepsize = LUAI_GCSTEPSIZE; |
398 | setgcparam(g->genmajormul, LUAI_GENMAJORMUL); |
399 | g->genminormul = LUAI_GENMINORMUL; |
400 | for (i=0; i < LUA_NUMTAGS; i++) g->mt[i] = NULL; |
401 | if (luaD_rawrunprotected(L, f_luaopen, NULL) != LUA_OK) { |
402 | /* memory allocation error: free partial state */ |
403 | close_state(L); |
404 | L = NULL; |
405 | } |
406 | return L; |
407 | } |
408 | |
409 | |
410 | LUA_API void lua_close (lua_State *L) { |
411 | lua_lock(L); |
412 | L = G(L)->mainthread; /* only the main thread can be closed */ |
413 | close_state(L); |
414 | } |
415 | |
416 | |
417 | void luaE_warning (lua_State *L, const char *msg, int tocont) { |
418 | lua_WarnFunction wf = G(L)->warnf; |
419 | if (wf != NULL) |
420 | wf(G(L)->ud_warn, msg, tocont); |
421 | } |
422 | |
423 | |
424 | /* |
425 | ** Generate a warning from an error message |
426 | */ |
427 | void luaE_warnerror (lua_State *L, const char *where) { |
428 | TValue *errobj = s2v(L->top - 1); /* error object */ |
429 | const char *msg = (ttisstring(errobj)) |
430 | ? svalue(errobj) |
431 | : "error object is not a string" ; |
432 | /* produce warning "error in %s (%s)" (where, msg) */ |
433 | luaE_warning(L, "error in " , 1); |
434 | luaE_warning(L, where, 1); |
435 | luaE_warning(L, " (" , 1); |
436 | luaE_warning(L, msg, 1); |
437 | luaE_warning(L, ")" , 0); |
438 | } |
439 | |
440 | |