fix leaks
[m6w6/ext-psi] / src / engine.c
1 #ifdef HAVE_CONFIG_H
2 # include "config.h"
3 #endif
4
5 #include "php.h"
6 #include "php_psi.h"
7
8 #include "zend_exceptions.h"
9
10 #include "parser.h"
11 #include "engine.h"
12 #include "calc.h"
13 #include "marshal.h"
14
15 size_t psi_t_alignment(token_t t)
16 {
17 #define PSI_ALIGNOF(T) case PSI_T_## T: return ALIGNOF_## T ##_T;
18 switch (t) {
19 PSI_ALIGNOF(INT8);
20 PSI_ALIGNOF(UINT8);
21 PSI_ALIGNOF(INT16);
22 PSI_ALIGNOF(UINT16);
23 PSI_ALIGNOF(INT32);
24 PSI_ALIGNOF(UINT32);
25 PSI_ALIGNOF(INT64);
26 PSI_ALIGNOF(UINT64);
27 case PSI_T_FLOAT:
28 return ALIGNOF_FLOAT;
29 case PSI_T_DOUBLE:
30 return ALIGNOF_DOUBLE;
31 case PSI_T_POINTER:
32 case PSI_T_FUNCTION:
33 return ALIGNOF_VOID_P;
34 case PSI_T_ENUM:
35 return ALIGNOF_INT;
36 EMPTY_SWITCH_DEFAULT_CASE();
37 }
38 return 0;
39 }
40
41 size_t psi_t_size(token_t t)
42 {
43 #define PSI_SIZEOF(T) case PSI_T_## T : return SIZEOF_## T ##_T;
44 switch (t) {
45 PSI_SIZEOF(INT8);
46 PSI_SIZEOF(UINT8);
47 PSI_SIZEOF(INT16);
48 PSI_SIZEOF(UINT16);
49 PSI_SIZEOF(INT32);
50 PSI_SIZEOF(UINT32);
51 PSI_SIZEOF(INT64);
52 PSI_SIZEOF(UINT64);
53 case PSI_T_FLOAT:
54 return SIZEOF_FLOAT;
55 case PSI_T_DOUBLE:
56 return SIZEOF_DOUBLE;
57 case PSI_T_POINTER:
58 case PSI_T_FUNCTION:
59 return SIZEOF_VOID_P;
60 case PSI_T_ENUM:
61 return SIZEOF_INT;
62 EMPTY_SWITCH_DEFAULT_CASE();
63 }
64 return 0;
65 }
66
67 int psi_internal_type(impl_type *type)
68 {
69 switch (type->type) {
70 case PSI_T_BOOL:
71 return _IS_BOOL;
72 case PSI_T_INT:
73 return IS_LONG;
74 case PSI_T_FLOAT:
75 case PSI_T_DOUBLE:
76 return IS_DOUBLE;
77 case PSI_T_STRING:
78 return IS_STRING;
79 case PSI_T_ARRAY:
80 return IS_ARRAY;
81 default:
82 return 0;
83 }
84 }
85
86 zend_internal_arg_info *psi_internal_arginfo(impl *impl)
87 {
88 size_t i;
89 zend_internal_arg_info *aip;
90 zend_internal_function_info *fi;
91
92 aip = calloc(impl->func->args->count + 1 + !!impl->func->args->vararg.name, sizeof(*aip));
93
94 fi = (zend_internal_function_info *) &aip[0];
95 fi->allow_null = 1;
96 fi->required_num_args = psi_num_min_args(impl);
97 fi->return_reference = impl->func->return_reference;
98 fi->type_hint = psi_internal_type(impl->func->return_type);
99
100 if (impl->func->args->vararg.name) {
101 impl_arg *vararg = impl->func->args->vararg.name;
102 zend_internal_arg_info *ai = &aip[impl->func->args->count];
103
104 ai->name = vararg->var->name;
105 ai->allow_null = 1;
106 ai->type_hint = psi_internal_type(vararg->type);
107 if (vararg->var->reference) {
108 ai->pass_by_reference = 1;
109 }
110 ai->is_variadic = 1;
111 }
112
113 for (i = 0; i < impl->func->args->count; ++i) {
114 impl_arg *iarg = impl->func->args->args[i];
115 zend_internal_arg_info *ai = &aip[i+1];
116
117 ai->name = iarg->var->name;
118 ai->type_hint = psi_internal_type(iarg->type);
119 if (iarg->var->reference) {
120 ai->pass_by_reference = 1;
121 }
122 //if (iarg->var->reference || (iarg->def && iarg->def->type == PSI_T_NULL)) {
123 ai->allow_null = 1;
124 //}
125 }
126
127 return aip;
128 }
129
130 size_t psi_num_min_args(impl *impl)
131 {
132 size_t i, n = impl->func->args->count;
133
134 for (i = 0; i < impl->func->args->count; ++i) {
135 if (impl->func->args->args[i]->def) {
136 --n;
137 }
138 }
139 return n;
140 }
141
142
143 static inline ZEND_RESULT_CODE psi_parse_args(zend_execute_data *execute_data, impl *impl)
144 {
145 size_t i;
146 impl_arg *iarg;
147 zend_error_handling zeh;
148
149 zend_replace_error_handling(EH_THROW, zend_exception_get_default(), &zeh);
150
151 if (!impl->func->args->count) {
152 ZEND_RESULT_CODE rv;
153
154 rv = zend_parse_parameters_none();
155 zend_restore_error_handling(&zeh);
156 return rv;
157 }
158
159 ZEND_PARSE_PARAMETERS_START(psi_num_min_args(impl), impl->func->args->vararg.name ? -1 : impl->func->args->count)
160 nextarg:
161 if (impl->func->args->vararg.name && _i >= impl->func->args->count) {
162 impl_arg *varg = impl->func->args->vararg.name;
163 iarg = init_impl_arg(
164 init_impl_type(varg->type->type, varg->type->name),
165 init_impl_var(varg->var->name, varg->var->reference),
166 NULL);
167
168 Z_PARAM_OPTIONAL;
169 if (_i == impl->func->args->count) {
170 impl->func->args->vararg.args = init_impl_args(iarg);
171 } else {
172 add_impl_arg(impl->func->args->vararg.args, iarg);
173 }
174 } else {
175 iarg = impl->func->args->args[_i];
176 if (iarg->def) {
177 Z_PARAM_OPTIONAL;
178 }
179 }
180 if (PSI_T_BOOL == iarg->type->type) {
181 Z_PARAM_BOOL(iarg->val.zend.bval);
182 } else if (PSI_T_INT == iarg->type->type) {
183 Z_PARAM_LONG(iarg->val.zend.lval);
184 } else if (PSI_T_FLOAT == iarg->type->type || PSI_T_DOUBLE == iarg->type->type) {
185 Z_PARAM_DOUBLE(iarg->val.dval);
186 } else if (PSI_T_STRING == iarg->type->type) {
187 Z_PARAM_STR_EX(iarg->val.zend.str, 1, iarg->var->reference);
188 if (iarg->val.zend.str) {
189 zend_string_addref(iarg->val.zend.str);
190 }
191 } else if (PSI_T_ARRAY == iarg->type->type) {
192 Z_PARAM_PROLOGUE(0);
193 } else if (PSI_T_OBJECT == iarg->type->type) {
194 Z_PARAM_PROLOGUE(0);
195 } else if (PSI_T_MIXED == iarg->type->type) {
196 Z_PARAM_PROLOGUE(0);
197 } else if (PSI_T_CALLABLE == iarg->type->type) {
198 zend_fcall_info fci;
199 zend_fcall_info_cache fcc;
200
201 Z_PARAM_FUNC_EX(fci, fcc, 1, 0);
202
203 if (fci.size) {
204 iarg->val.zend.cb = ecalloc(1, sizeof(zend_fcall));
205 iarg->val.zend.cb->fci = fci;
206 iarg->val.zend.cb->fcc = fcc;
207 }
208 } else {
209 error_code = ZPP_ERROR_FAILURE;
210 break;
211 }
212 iarg->_zv = _arg;
213 ZVAL_DEREF(iarg->_zv);
214 if (_i < _num_args) {
215 goto nextarg;
216 }
217 ZEND_PARSE_PARAMETERS_END_EX(
218 zend_restore_error_handling(&zeh);
219 return FAILURE
220 );
221
222 /* set up defaults */
223 for (i = 0; i < impl->func->args->count; ++i) {
224 if (i >= EX_NUM_ARGS() && iarg->def) {
225 iarg = impl->func->args->args[i];
226
227 switch (iarg->type->type) {
228 case PSI_T_BOOL:
229 iarg->val.zend.bval = iarg->def->type == PSI_T_TRUE ? 1 : 0;
230 break;
231 case PSI_T_INT:
232 iarg->val.zend.lval = zend_atol(iarg->def->text, strlen(iarg->def->text));
233 break;
234 case PSI_T_FLOAT:
235 case PSI_T_DOUBLE:
236 iarg->val.dval = zend_strtod(iarg->def->text, NULL);
237 break;
238 case PSI_T_STRING:
239 /* FIXME */
240 iarg->val.zend.str = zend_string_init(&iarg->def->text[1], strlen(iarg->def->text) - 2, 0);
241 break;
242 }
243 }
244 }
245
246 zend_restore_error_handling(&zeh);
247 return SUCCESS;
248 }
249
250 static inline void *psi_do_calloc(let_calloc *alloc)
251 {
252 zend_long n = psi_long_num_exp(alloc->nmemb, NULL), s = psi_long_num_exp(alloc->size, NULL);
253 void *mem = safe_emalloc(n, s, sizeof(void *));
254 memset(mem, 0, n * s + sizeof(void *));
255 #if 0
256 fprintf(stderr, "calloc: %p\n", mem);
257 #endif
258 return mem;
259 }
260
261 static inline impl_val *psi_let_val(token_t let_func, impl_arg *iarg, impl_val *arg_val, decl_struct *strct, void **to_free)
262 {
263 abort();
264 return arg_val;
265 }
266
267 static inline impl_val *psi_let_func(let_func *func, decl_arg *darg) {
268 return darg->ptr = func->handler(darg->ptr, darg->type, func->var->arg, &darg->mem);
269 }
270
271 static inline void *psi_do_let(let_stmt *let)
272 {
273 decl_arg *darg = let->var->arg;
274 impl_val *arg_val = darg->ptr;
275
276 switch (let->val ? let->val->kind : PSI_LET_NULL) {
277 case PSI_LET_TMP:
278 memcpy(arg_val, deref_impl_val(let->val->data.var->arg->let->ptr, let->val->data.var), sizeof(*arg_val));
279 #if 0
280 fprintf(stderr, "LET TMP: %p -> %p\n",
281 let->val->data.var->arg->let->ptr,
282 arg_val->ptr);
283 #endif
284 break;
285 case PSI_LET_NULL:
286 if (darg->var->array_size) {
287 arg_val->ptr = ecalloc(darg->var->array_size, sizeof(*arg_val));
288 darg->mem = arg_val->ptr;
289 } else {
290 memset(arg_val, 0, sizeof(*arg_val));
291 }
292 break;
293 case PSI_LET_CALLOC:
294 arg_val->ptr = psi_do_calloc(let->val->data.alloc);
295 darg->mem = arg_val->ptr;
296 break;
297 case PSI_LET_CALLBACK:
298 arg_val->ptr = let->val->data.callback->decl->call.sym;
299 break;
300 case PSI_LET_NUMEXP:
301 arg_val->zend.lval = psi_long_num_exp(let->val->data.num, NULL);
302 break;
303 case PSI_LET_FUNC:
304 if (!psi_let_func(let->val->data.func, darg)) {
305 return NULL;
306 }
307 break;
308 }
309
310 if (let->val && let->val->flags.one.is_reference) {
311 return let->ptr = &darg->ptr;
312 } else {
313 return let->ptr = darg->ptr;
314 }
315 }
316
317 static inline void psi_do_return(zval *return_value, return_stmt *ret)
318 {
319 ret->set->func->handler(return_value, ret->set, ret->set->vars->vars[0]->arg->ptr);
320 }
321
322 static inline void psi_do_free(free_stmt *fre)
323 {
324 size_t i, j;
325
326 for (i = 0; i < fre->calls->count; ++i) {
327 free_call *f = fre->calls->list[i];
328
329 for (j = 0; j < f->vars->count; ++j) {
330 decl_var *dvar = f->vars->vars[j];
331 decl_arg *darg = dvar->arg;
332 impl_val *fval = darg->let ? darg->let->ptr : darg->ptr;
333
334 f->decl->call.args[j] = deref_impl_val(fval, dvar);
335 }
336
337 /* FIXME: check in validate_* that free functions return scalar */
338 PSI_ContextCall(&PSI_G(context), &f->decl->call, NULL);
339 }
340 }
341
342 static inline void psi_clean_array_struct(decl_arg *darg) {
343 if (darg->let
344 && darg->let->val->kind == PSI_LET_FUNC
345 && darg->let->val->data.func->type == PSI_T_ARRVAL) {
346 decl_type *type = real_decl_type(darg->type);
347
348 if (type->type == PSI_T_STRUCT) {
349 void **ptr = (void **) ((char *) darg->mem + type->strct->size);
350
351 while (*ptr) {
352 efree(*ptr++);
353 }
354 }
355 }
356 }
357
358 static inline void psi_do_clean(impl *impl)
359 {
360 size_t i;
361
362 if (impl->decl->func->ptr != &impl->decl->func->val) {
363 efree(impl->decl->func->ptr);
364 impl->decl->func->ptr = &impl->decl->func->val;
365 }
366 for (i = 0; i < impl->func->args->count; ++i ) {
367 impl_arg *iarg = impl->func->args->args[i];
368
369 switch (iarg->type->type) {
370 case PSI_T_STRING:
371 if (iarg->val.zend.str) {
372 zend_string_release(iarg->val.zend.str);
373 }
374 break;
375 case PSI_T_CALLABLE:
376 if (iarg->val.zend.cb) {
377 if (iarg->val.zend.cb->fci.size) {
378 zend_fcall_info_args_clear(&iarg->val.zend.cb->fci, 1);
379 }
380 efree(iarg->val.zend.cb);
381 }
382 break;
383 }
384 }
385
386 if (impl->decl->args) for (i = 0; i < impl->decl->args->count; ++i) {
387 decl_arg *darg = impl->decl->args->args[i];
388
389 if (darg->mem) {
390 psi_clean_array_struct(darg);
391 efree(darg->mem);
392 darg->mem = NULL;
393 }
394 darg->ptr = &darg->val;
395 }
396
397 if (impl->func->args->vararg.args) {
398 free_impl_args(impl->func->args->vararg.args);
399 impl->func->args->vararg.args = NULL;
400 }
401 if (impl->func->args->vararg.types) {
402 efree(impl->func->args->vararg.types);
403 impl->func->args->vararg.types = NULL;
404 }
405 if (impl->func->args->vararg.values) {
406 efree(impl->func->args->vararg.values);
407 impl->func->args->vararg.values = NULL;
408 }
409 if (impl->func->args->vararg.free_list) {
410 void **list = impl->func->args->vararg.free_list;
411
412 while (*list) {
413 efree(*list++);
414 }
415
416 efree(impl->func->args->vararg.free_list);
417 impl->func->args->vararg.free_list = NULL;
418 }
419 }
420
421
422 static inline void psi_do_args(impl *impl) {
423 size_t i;
424
425 for (i = 0; i < impl->decl->args->count; ++i) {
426 impl->decl->call.args[i] = impl->decl->args->args[i]->let->ptr;
427 }
428
429 if (!impl->decl->func->var->pointer_level) {
430 decl_type *real = real_decl_type(impl->decl->func->type);
431
432 switch (real->type) {
433 case PSI_T_STRUCT:
434 impl->decl->func->ptr = psi_array_to_struct(real->strct, NULL);
435 break;
436 }
437 }
438 }
439
440 static inline impl_vararg *psi_do_varargs(impl *impl) {
441 size_t i, j;
442 impl_vararg *va = &impl->func->args->vararg;
443 size_t vacount = va->args->count;
444
445
446 if (!vacount) {
447 return NULL;
448 }
449
450 va->types = ecalloc(vacount, sizeof(*va->types));
451 va->values = ecalloc(vacount, sizeof(*va->values));
452
453 for (i = 0, j = 0; i < vacount; ++i) {
454 impl_arg *vaarg = va->args->args[i];
455 void *to_free = NULL;
456 token_t let_fn, vatype = va->name->type->type;
457
458 if (vatype == PSI_T_MIXED) {
459 switch (Z_TYPE_P(vaarg->_zv)) {
460 case IS_TRUE:
461 case IS_FALSE: vatype = PSI_T_BOOL; break;
462 case IS_LONG: vatype = PSI_T_INT; break;
463 case IS_DOUBLE: vatype = PSI_T_FLOAT; break;
464 default: vatype = PSI_T_STRING; break;
465 }
466 }
467
468
469 switch (vatype) {
470 case PSI_T_BOOL: let_fn = PSI_T_BOOLVAL; break;
471 case PSI_T_INT: let_fn = PSI_T_INTVAL; break;
472 case PSI_T_FLOAT:
473 case PSI_T_DOUBLE: let_fn = PSI_T_FLOATVAL;break;
474 case PSI_T_STRING: let_fn = PSI_T_STRVAL; break;
475 EMPTY_SWITCH_DEFAULT_CASE();
476 }
477
478 va->types[i] = vatype;
479 /* FIXME: varargs with struct-by-value :) */
480 if (!psi_let_val(let_fn, vaarg, &va->values[i], NULL, &to_free)) {
481 return NULL;
482 }
483
484 if (to_free) {
485 if (!va->free_list) {
486 va->free_list = ecalloc(vacount - i + 1, sizeof(*va->free_list));
487 }
488 va->free_list[j++] = to_free;
489 }
490 }
491
492 return va;
493 }
494
495 void psi_call(zend_execute_data *execute_data, zval *return_value, impl *impl)
496 {
497 size_t i;
498 impl_vararg *va = NULL;
499
500 memset(impl->decl->func->ptr, 0, sizeof(impl_val));
501
502 if (SUCCESS != psi_parse_args(execute_data, impl)) {
503 return;
504 }
505
506 for (i = 0; i < impl->stmts->let.count; ++i) {
507 let_stmt *let = impl->stmts->let.list[i];
508
509 if (!psi_do_let(let)) {
510 psi_do_return(return_value, impl->stmts->ret.list[0]);
511 psi_do_clean(impl);
512 return;
513 }
514 }
515
516 if (impl->decl->args) {
517 psi_do_args(impl);
518
519 if (impl->func->args->vararg.args) {
520 va = psi_do_varargs(impl);
521 }
522 }
523
524 PSI_ContextCall(&PSI_G(context), &impl->decl->call, va);
525 psi_do_return(return_value, impl->stmts->ret.list[0]);
526
527 for (i = 0; i < impl->stmts->set.count; ++i) {
528 set_stmt *set = impl->stmts->set.list[i];
529
530 if (set->arg->_zv) {
531 psi_do_set(set->arg->_zv, set->val);
532 }
533 }
534
535 for (i = 0; i < impl->stmts->fre.count; ++i) {
536 free_stmt *fre = impl->stmts->fre.list[i];
537
538 psi_do_free(fre);
539 }
540 psi_do_clean(impl);
541 }