basic callback support
[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 = calloc(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 }
376 }
377
378 if (impl->decl->args) for (i = 0; i < impl->decl->args->count; ++i) {
379 decl_arg *darg = impl->decl->args->args[i];
380
381 if (darg->mem) {
382 psi_clean_array_struct(darg);
383 efree(darg->mem);
384 darg->mem = NULL;
385 }
386 darg->ptr = &darg->val;
387 }
388
389 if (impl->func->args->vararg.args) {
390 free_impl_args(impl->func->args->vararg.args);
391 impl->func->args->vararg.args = NULL;
392 }
393 if (impl->func->args->vararg.types) {
394 efree(impl->func->args->vararg.types);
395 impl->func->args->vararg.types = NULL;
396 }
397 if (impl->func->args->vararg.values) {
398 efree(impl->func->args->vararg.values);
399 impl->func->args->vararg.values = NULL;
400 }
401 if (impl->func->args->vararg.free_list) {
402 void **list = impl->func->args->vararg.free_list;
403
404 while (*list) {
405 efree(*list++);
406 }
407
408 efree(impl->func->args->vararg.free_list);
409 impl->func->args->vararg.free_list = NULL;
410 }
411 }
412
413
414 static inline void psi_do_args(impl *impl) {
415 size_t i;
416
417 for (i = 0; i < impl->decl->args->count; ++i) {
418 impl->decl->call.args[i] = impl->decl->args->args[i]->let->ptr;
419 }
420
421 if (!impl->decl->func->var->pointer_level) {
422 decl_type *real = real_decl_type(impl->decl->func->type);
423
424 switch (real->type) {
425 case PSI_T_STRUCT:
426 impl->decl->func->ptr = psi_array_to_struct(real->strct, NULL);
427 break;
428 }
429 }
430 }
431
432 static inline impl_vararg *psi_do_varargs(impl *impl) {
433 size_t i, j;
434 impl_vararg *va = &impl->func->args->vararg;
435 size_t vacount = va->args->count;
436
437
438 if (!vacount) {
439 return NULL;
440 }
441
442 va->types = ecalloc(vacount, sizeof(*va->types));
443 va->values = ecalloc(vacount, sizeof(*va->values));
444
445 for (i = 0, j = 0; i < vacount; ++i) {
446 impl_arg *vaarg = va->args->args[i];
447 void *to_free = NULL;
448 token_t let_fn, vatype = va->name->type->type;
449
450 if (vatype == PSI_T_MIXED) {
451 switch (Z_TYPE_P(vaarg->_zv)) {
452 case IS_TRUE:
453 case IS_FALSE: vatype = PSI_T_BOOL; break;
454 case IS_LONG: vatype = PSI_T_INT; break;
455 case IS_DOUBLE: vatype = PSI_T_FLOAT; break;
456 default: vatype = PSI_T_STRING; break;
457 }
458 }
459
460
461 switch (vatype) {
462 case PSI_T_BOOL: let_fn = PSI_T_BOOLVAL; break;
463 case PSI_T_INT: let_fn = PSI_T_INTVAL; break;
464 case PSI_T_FLOAT:
465 case PSI_T_DOUBLE: let_fn = PSI_T_FLOATVAL;break;
466 case PSI_T_STRING: let_fn = PSI_T_STRVAL; break;
467 EMPTY_SWITCH_DEFAULT_CASE();
468 }
469
470 va->types[i] = vatype;
471 /* FIXME: varargs with struct-by-value :) */
472 if (!psi_let_val(let_fn, vaarg, &va->values[i], NULL, &to_free)) {
473 return NULL;
474 }
475
476 if (to_free) {
477 if (!va->free_list) {
478 va->free_list = ecalloc(vacount - i + 1, sizeof(*va->free_list));
479 }
480 va->free_list[j++] = to_free;
481 }
482 }
483
484 return va;
485 }
486
487 void psi_call(zend_execute_data *execute_data, zval *return_value, impl *impl)
488 {
489 size_t i;
490 impl_vararg *va = NULL;
491
492 memset(impl->decl->func->ptr, 0, sizeof(impl_val));
493
494 if (SUCCESS != psi_parse_args(execute_data, impl)) {
495 return;
496 }
497
498 for (i = 0; i < impl->stmts->let.count; ++i) {
499 let_stmt *let = impl->stmts->let.list[i];
500
501 if (!psi_do_let(let)) {
502 psi_do_return(return_value, impl->stmts->ret.list[0]);
503 psi_do_clean(impl);
504 return;
505 }
506 }
507
508 if (impl->decl->args) {
509 psi_do_args(impl);
510
511 if (impl->func->args->vararg.args) {
512 va = psi_do_varargs(impl);
513 }
514 }
515
516 PSI_ContextCall(&PSI_G(context), &impl->decl->call, va);
517 psi_do_return(return_value, impl->stmts->ret.list[0]);
518
519 for (i = 0; i < impl->stmts->set.count; ++i) {
520 set_stmt *set = impl->stmts->set.list[i];
521
522 if (set->arg->_zv) {
523 psi_do_set(set->arg->_zv, set->val);
524 }
525 }
526
527 for (i = 0; i < impl->stmts->fre.count; ++i) {
528 free_stmt *fre = impl->stmts->fre.list[i];
529
530 psi_do_free(fre);
531 }
532 psi_do_clean(impl);
533 }