2 +--------------------------------------------------------------------+
4 +--------------------------------------------------------------------+
5 | Redistribution and use in source and binary forms, with or without |
6 | modification, are permitted provided that the conditions mentioned |
7 | in the accompanying LICENSE file are met. |
8 +--------------------------------------------------------------------+
9 | Copyright (c) 2013, Michael Wallner <mike@php.net> |
10 +--------------------------------------------------------------------+
18 #include <Zend/zend_closures.h>
20 #include "php_pq_callback.h"
22 void php_pq_callback_dtor(php_pq_callback_t
*cb
)
25 php_pq_callback_dtor(cb
->recursion
);
29 if (cb
->fci
.size
> 0) {
30 zend_fcall_info_args_clear(&cb
->fci
, 1);
31 zval_ptr_dtor(&cb
->fci
.function_name
);
35 ZVAL_OBJ(&tmp
, cb
->fci
.object
);
42 void php_pq_callback_addref(php_pq_callback_t
*cb
)
44 Z_TRY_ADDREF(cb
->fci
.function_name
);
46 ++GC_REFCOUNT(cb
->fci
.object
);
50 zval
*php_pq_callback_to_zval(php_pq_callback_t
*cb
, zval
*tmp
)
52 php_pq_callback_addref(cb
);
57 array_init_size(tmp
, 2);
58 ZVAL_OBJ(&zo
, cb
->fci
.object
);
59 add_next_index_zval(tmp
, &zo
);
60 add_next_index_zval(tmp
, &cb
->fci
.function_name
);
65 return &cb
->fci
.function_name
;
68 zval
*php_pq_callback_to_zval_no_addref(php_pq_callback_t
*cb
, zval
*tmp
)
73 array_init_size(tmp
, 2);
74 ZVAL_OBJ(&zo
, cb
->fci
.object
);
75 add_next_index_zval(tmp
, &zo
);
76 add_next_index_zval(tmp
, &cb
->fci
.function_name
);
81 return &cb
->fci
.function_name
;
84 zend_bool
php_pq_callback_is_locked(php_pq_callback_t
*cb
)
86 /* TODO: fixed in php7?
87 if (cb->fci.size > 0 && Z_TYPE_P(cb->fci.function_name) == IS_OBJECT) {
88 const zend_function *closure = zend_get_closure_method_def(cb->fci.function_name);
90 if (closure->type == ZEND_USER_FUNCTION) {
91 zend_execute_data *ex = EG(current_execute_data);
94 if (ex->op_array == &closure->op_array) {
97 ex = ex->prev_execute_data;
105 void php_pq_callback_recurse(php_pq_callback_t
*old
, php_pq_callback_t
*new TSRMLS_DC
)
107 if (new && new->fci
.size
> 0 && php_pq_callback_is_locked(old TSRMLS_CC
)) {
108 new->recursion
= emalloc(sizeof(*old
));
109 memcpy(new->recursion
, old
, sizeof(*old
));
110 } else if (new && new->fci
.size
> 0) {
111 php_pq_callback_dtor(old
);
112 php_pq_callback_addref(new);
113 memcpy(old
, new, sizeof(*old
));
116 php_pq_callback_dtor(old
);
125 * vim600: noet sw=4 ts=4 fdm=marker
126 * vim<600: noet sw=4 ts=4