git.m6w6.name Git - m6w6/ext-pq/blob - src/php_pq_callback.c

   1 /*
   2     +--------------------------------------------------------------------+
   3     | PECL :: pq                                                         |
   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     +--------------------------------------------------------------------+
  11 */
  12
  13 #ifdef HAVE_CONFIG_H
  14 #       include "config.h"
  15 #endif
  16
  17 #include <php.h>
  18 #include <Zend/zend_closures.h>
  19
  20 #include "php_pq_callback.h"
  21
  22 void php_pq_callback_dtor(php_pq_callback_t *cb)
  23 {
  24         if (cb->recursion) {
  25                 php_pq_callback_dtor(cb->recursion);
  26                 efree(cb->recursion);
  27                 cb->recursion = NULL;
  28         }
  29         if (cb->fci.size > 0) {
  30                 zend_fcall_info_args_clear(&cb->fci, 1);
  31                 zval_ptr_dtor(&cb->fci.function_name);
  32                 if (cb->fci.object) {
  33                         zval tmp;
  34
  35                         ZVAL_OBJ(&tmp, cb->fci.object);
  36                         zval_ptr_dtor(&tmp);
  37                 }
  38                 cb->fci.size = 0;
  39         }
  40 }
  41
  42 void php_pq_callback_addref(php_pq_callback_t *cb)
  43 {
  44         Z_TRY_ADDREF(cb->fci.function_name);
  45         if (cb->fci.object) {
  46                 ++GC_REFCOUNT(cb->fci.object);
  47         }
  48 }
  49
  50 zval *php_pq_callback_to_zval(php_pq_callback_t *cb, zval *tmp)
  51 {
  52         php_pq_callback_addref(cb);
  53
  54         if (cb->fci.object) {
  55                 zval zo;
  56
  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);
  61
  62                 return tmp;
  63         }
  64
  65         return &cb->fci.function_name;
  66 }
  67
  68 zval *php_pq_callback_to_zval_no_addref(php_pq_callback_t *cb, zval *tmp)
  69 {
  70         if (cb->fci.object) {
  71                 zval zo;
  72
  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);
  77
  78                 return tmp;
  79         }
  80
  81         return &cb->fci.function_name;
  82 }
  83
  84 zend_bool php_pq_callback_is_locked(php_pq_callback_t *cb)
  85 {
  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);
  89
  90                 if (closure->type == ZEND_USER_FUNCTION) {
  91                         zend_execute_data *ex = EG(current_execute_data);
  92
  93                         while (ex) {
  94                                 if (ex->op_array == &closure->op_array) {
  95                                         return 1;
  96                                 }
  97                                 ex = ex->prev_execute_data;
  98                         }
  99                 }
 100         }
 101         */
 102         return 0;
 103 }
 104
 105 void php_pq_callback_recurse(php_pq_callback_t *old, php_pq_callback_t *new TSRMLS_DC)
 106 {
 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));
 114                 new->fci.size = 0;
 115         } else {
 116                 php_pq_callback_dtor(old);
 117         }
 118 }
 119
 120 /*
 121  * Local variables:
 122  * tab-width: 4
 123  * c-basic-offset: 4
 124  * End:
 125  * vim600: noet sw=4 ts=4 fdm=marker
 126  * vim<600: noet sw=4 ts=4
 127  */