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 (php_pq_callback_is_enabled(cb)) {
88 const zend_function *closure;
89 const zend_execute_data *ex;
91 if (Z_TYPE_P(cb->fci.function_name) != IS_OBJECT) {
95 closure = zend_get_closure_method_def(cb->fci.function_name);
96 if (closure->type != ZEND_USER_FUNCTION) {
100 for (ex = EG(current_execute_data); ex; ex = ex->prev_execute_data) {
101 if (ex->op_array == &closure->op_array) {
106 if (!php_pq_callback_is_recurrent(cb)) {
109 return php_pq_callback_is_locked(cb->recursion);
114 void php_pq_callback_recurse(php_pq_callback_t
*old
, php_pq_callback_t
*new)
116 if (php_pq_callback_is_locked(old
)) {
117 php_pq_callback_recurse_ex(old
, new);
119 php_pq_callback_dtor(old
);
120 if (php_pq_callback_is_enabled(new)) {
121 php_pq_callback_addref(new);
122 memcpy(old
, new, sizeof(*old
));
128 extern zend_bool
php_pq_callback_is_enabled(php_pq_callback_t
*cb
)
130 return cb
&& cb
->fci
.size
> 0;
133 extern zend_bool
php_pq_callback_is_recurrent(php_pq_callback_t
*cb
)
135 return cb
&& cb
->recursion
!= NULL
;
138 extern void php_pq_callback_disable(php_pq_callback_t
*cb
)
140 if (php_pq_callback_is_enabled(cb
)) {
141 php_pq_callback_recurse_ex(cb
, NULL
);
145 extern void php_pq_callback_recurse_ex(php_pq_callback_t
*old
, php_pq_callback_t
*new)
147 php_pq_callback_t
*tmp
= emalloc(sizeof(*tmp
));
150 memcpy(tmp
, old
, sizeof(*tmp
));
151 memcpy(old
, new, sizeof(*old
));
152 old
->recursion
= tmp
;
154 php_pq_callback_addref(old
);
155 php_pq_callback_disable(tmp
);
157 memcpy(tmp
, old
, sizeof(*tmp
));
158 memset(old
, 0, sizeof(*old
));
159 old
->recursion
= tmp
;
168 * vim600: noet sw=4 ts=4 fdm=marker
169 * vim<600: noet sw=4 ts=4