X-Git-Url: https://git.m6w6.name/?a=blobdiff_plain;f=php_raphf.c;h=2c785dd72c00201f2e21d4377fa7a7abf520d6ef;hb=c01edad3209f9e20c8192bf562f2a994752b25cb;hp=f9f354a2cd8503a49f2feaeec80bbc05922aec97;hpb=f706105e1df56286cfeff86c5264270a758fa8f9;p=m6w6%2Fext-raphf diff --git a/php_raphf.c b/php_raphf.c index f9f354a..2c785dd 100644 --- a/php_raphf.c +++ b/php_raphf.c @@ -19,9 +19,23 @@ #include "ext/standard/info.h" #include "php_raphf.h" -ZEND_DECLARE_MODULE_GLOBALS(raphf) +struct php_persistent_handle_globals { + ulong limit; + HashTable hash; +}; + +ZEND_BEGIN_MODULE_GLOBALS(raphf) + struct php_persistent_handle_globals persistent_handle; +ZEND_END_MODULE_GLOBALS(raphf) + +#ifdef ZTS +# define PHP_RAPHF_G ((zend_raphf_globals *) \ + (*((void ***) tsrm_ls))[TSRM_UNSHUFFLE_RSRC_ID(raphf_globals_id)]) +#else +# define PHP_RAPHF_G (&raphf_globals) +#endif -typedef int STATUS; +ZEND_DECLARE_MODULE_GLOBALS(raphf) #ifndef PHP_RAPHF_DEBUG_PHANDLES # define PHP_RAPHF_DEBUG_PHANDLES 0 @@ -31,9 +45,8 @@ typedef int STATUS; # define inline #endif -PHP_RAPHF_API php_resource_factory_t *php_resource_factory_init( - php_resource_factory_t *f, php_resource_factory_ops_t *fops, void *data, - void (*dtor)(void *data)) +php_resource_factory_t *php_resource_factory_init(php_resource_factory_t *f, + php_resource_factory_ops_t *fops, void *data, void (*dtor)(void *data)) { if (!f) { f = emalloc(sizeof(*f)); @@ -50,23 +63,21 @@ PHP_RAPHF_API php_resource_factory_t *php_resource_factory_init( return f; } -PHP_RAPHF_API unsigned php_resource_factory_addref(php_resource_factory_t *rf) +unsigned php_resource_factory_addref(php_resource_factory_t *rf) { return ++rf->refcount; } -PHP_RAPHF_API void php_resource_factory_dtor(php_resource_factory_t *f) +void php_resource_factory_dtor(php_resource_factory_t *f) { - --f->refcount; - - if (!f->refcount) { + if (!--f->refcount) { if (f->dtor) { f->dtor(f->data); } } } -PHP_RAPHF_API void php_resource_factory_free(php_resource_factory_t **f) +void php_resource_factory_free(php_resource_factory_t **f) { if (*f) { php_resource_factory_dtor(*f); @@ -77,7 +88,7 @@ PHP_RAPHF_API void php_resource_factory_free(php_resource_factory_t **f) } } -PHP_RAPHF_API void *php_resource_factory_handle_ctor(php_resource_factory_t *f, +void *php_resource_factory_handle_ctor(php_resource_factory_t *f, void *init_arg TSRMLS_DC) { if (f->fops.ctor) { @@ -86,7 +97,7 @@ PHP_RAPHF_API void *php_resource_factory_handle_ctor(php_resource_factory_t *f, return NULL; } -PHP_RAPHF_API void *php_resource_factory_handle_copy(php_resource_factory_t *f, +void *php_resource_factory_handle_copy(php_resource_factory_t *f, void *handle TSRMLS_DC) { if (f->fops.copy) { @@ -95,7 +106,7 @@ PHP_RAPHF_API void *php_resource_factory_handle_copy(php_resource_factory_t *f, return NULL; } -PHP_RAPHF_API void php_resource_factory_handle_dtor(php_resource_factory_t *f, +void php_resource_factory_handle_dtor(php_resource_factory_t *f, void *handle TSRMLS_DC) { if (f->fops.dtor) { @@ -106,86 +117,73 @@ PHP_RAPHF_API void php_resource_factory_handle_dtor(php_resource_factory_t *f, static inline php_persistent_handle_list_t *php_persistent_handle_list_init( php_persistent_handle_list_t *list) { - int free_list; - - if ((free_list = !list)) { - list = pemalloc(sizeof(php_persistent_handle_list_t), 1); + if (!list) { + list = pemalloc(sizeof(*list), 1); } - list->used = 0; - - if (SUCCESS != zend_hash_init(&list->free, 0, NULL, NULL, 1)) { - if (free_list) { - pefree(list, 1); - } - list = NULL; - } + zend_hash_init(&list->free, 0, NULL, NULL, 1); return list; } -static int php_persistent_handle_apply_stat(void *p TSRMLS_DC, int argc, +static int php_persistent_handle_apply_stat(zval *p TSRMLS_DC, int argc, va_list argv, zend_hash_key *key) { - php_persistent_handle_list_t **list = p; - zval *zsubentry, *zentry = va_arg(argv, zval *); + php_persistent_handle_list_t *list = Z_PTR_P(p); + zval zsubentry, *zentry = va_arg(argv, zval *); - MAKE_STD_ZVAL(zsubentry); - array_init(zsubentry); - add_assoc_long_ex(zsubentry, ZEND_STRS("used"), (*list)->used); - add_assoc_long_ex(zsubentry, ZEND_STRS("free"), - zend_hash_num_elements(&(*list)->free)); - add_assoc_zval_ex(zentry, key->arKey, key->nKeyLength, zsubentry); + array_init(&zsubentry); + add_assoc_long_ex(&zsubentry, ZEND_STRS("used"), list->used); + add_assoc_long_ex(&zsubentry, ZEND_STRS("free"), + zend_hash_num_elements(&list->free)); + add_assoc_zval_ex(zentry, key->key->val, key->key->len, &zsubentry); return ZEND_HASH_APPLY_KEEP; } -static int php_persistent_handle_apply_statall(void *p TSRMLS_DC, int argc, +static int php_persistent_handle_apply_statall(zval *p TSRMLS_DC, int argc, va_list argv, zend_hash_key *key) { - php_persistent_handle_provider_t *provider = p; + php_persistent_handle_provider_t *provider = Z_PTR_P(p); HashTable *ht = va_arg(argv, HashTable *); - zval *zentry; + zval zentry; - MAKE_STD_ZVAL(zentry); - array_init(zentry); + array_init(&zentry); zend_hash_apply_with_arguments(&provider->list.free TSRMLS_CC, - php_persistent_handle_apply_stat, 1, zentry); - zend_symtable_update(ht, key->arKey, key->nKeyLength, &zentry, - sizeof(zval *), NULL); + php_persistent_handle_apply_stat, 1, &zentry); + zend_symtable_update(ht, key->key, &zentry); return ZEND_HASH_APPLY_KEEP; } -static int php_persistent_handle_apply_cleanup_ex(void *pp, void *arg TSRMLS_DC) +static int php_persistent_handle_apply_cleanup_ex(zval *p, void *arg TSRMLS_DC) { php_resource_factory_t *rf = arg; - void **handle = pp; + void *handle = Z_PTR_P(p); #if PHP_RAPHF_DEBUG_PHANDLES - fprintf(stderr, "DESTROY: %p\n", *handle); + fprintf(stderr, "DESTROY: %p\n", handle); #endif - php_resource_factory_handle_dtor(rf, *handle TSRMLS_CC); + php_resource_factory_handle_dtor(rf, handle TSRMLS_CC); return ZEND_HASH_APPLY_REMOVE; } -static int php_persistent_handle_apply_cleanup(void *pp, void *arg TSRMLS_DC) +static int php_persistent_handle_apply_cleanup(zval *p, void *arg TSRMLS_DC) { php_resource_factory_t *rf = arg; - php_persistent_handle_list_t **listp = pp; + php_persistent_handle_list_t *list = Z_PTR_P(p); - zend_hash_apply_with_argument(&(*listp)->free, + zend_hash_apply_with_argument(&list->free, php_persistent_handle_apply_cleanup_ex, rf TSRMLS_CC); - if ((*listp)->used) { + if (list->used) { return ZEND_HASH_APPLY_KEEP; } - zend_hash_destroy(&(*listp)->free); + zend_hash_destroy(&list->free); #if PHP_RAPHF_DEBUG_PHANDLES - fprintf(stderr, "LSTFREE: %p\n", *listp); + fprintf(stderr, "LSTFREE: %p\n", list); #endif - pefree(*listp, 1); - *listp = NULL; + pefree(list, 1); return ZEND_HASH_APPLY_REMOVE; } @@ -213,10 +211,12 @@ static inline void php_persistent_handle_list_free( *list = NULL; } -static int php_persistent_handle_list_apply_dtor(void *listp, +static int php_persistent_handle_list_apply_dtor(zval *p, void *provider TSRMLS_DC) { - php_persistent_handle_list_free(listp, provider TSRMLS_CC); + php_persistent_handle_list_t *list = Z_PTR_P(p); + php_persistent_handle_list_free(&list, provider TSRMLS_CC); + ZVAL_PTR(p, NULL); return ZEND_HASH_APPLY_REMOVE; } @@ -224,37 +224,39 @@ static inline php_persistent_handle_list_t *php_persistent_handle_list_find( php_persistent_handle_provider_t *provider, const char *ident_str, size_t ident_len TSRMLS_DC) { - php_persistent_handle_list_t **list, *new_list; - STATUS rv = zend_symtable_find(&provider->list.free, ident_str, - ident_len + 1, (void *) &list); + php_persistent_handle_list_t *list; + + list = zend_symtable_str_find_ptr(&provider->list.free, ident_str, + ident_len + 1); - if (SUCCESS == rv) { + if (list) { #if PHP_RAPHF_DEBUG_PHANDLES - fprintf(stderr, "LSTFIND: %p\n", *list); + fprintf(stderr, "LSTFIND: %p\n", list); #endif - return *list; + return list; } - if ((new_list = php_persistent_handle_list_init(NULL))) { - rv = zend_symtable_update(&provider->list.free, ident_str, ident_len+1, - (void *) &new_list, sizeof(php_persistent_handle_list_t *), - (void *) &list); - if (SUCCESS == rv) { + if ((list = php_persistent_handle_list_init(NULL))) { + zval p; + + ZVAL_PTR(&p, list); + if (zend_symtable_str_update(&provider->list.free, ident_str, ident_len, + &p)) { #if PHP_RAPHF_DEBUG_PHANDLES - fprintf(stderr, "LSTFIND: %p (new)\n", *list); + fprintf(stderr, "LSTFIND: %p (new)\n", list); #endif - return *list; + return list; } - php_persistent_handle_list_free(&new_list, provider TSRMLS_CC); + php_persistent_handle_list_free(&list, provider TSRMLS_CC); } return NULL; } -static int php_persistent_handle_apply_cleanup_all(void *p TSRMLS_DC, int argc, +static int php_persistent_handle_apply_cleanup_all(zval *p TSRMLS_DC, int argc, va_list argv, zend_hash_key *key) { - php_persistent_handle_provider_t *provider = p; + php_persistent_handle_provider_t *provider = Z_PTR_P(p); const char *ident_str = va_arg(argv, const char *); size_t ident_len = va_arg(argv, size_t); php_persistent_handle_list_t *list; @@ -274,50 +276,50 @@ static int php_persistent_handle_apply_cleanup_all(void *p TSRMLS_DC, int argc, return ZEND_HASH_APPLY_KEEP; } -static void php_persistent_handle_hash_dtor(void *p) +static void php_persistent_handle_hash_dtor(zval *p) { - php_persistent_handle_provider_t *provider; + php_persistent_handle_provider_t *provider = Z_PTR_P(p); TSRMLS_FETCH(); - provider = (php_persistent_handle_provider_t *) p; zend_hash_apply_with_argument(&provider->list.free, php_persistent_handle_list_apply_dtor, provider TSRMLS_CC); zend_hash_destroy(&provider->list.free); php_resource_factory_dtor(&provider->rf); + pefree(provider, 1); } -PHP_RAPHF_API STATUS php_persistent_handle_provide(const char *name_str, +ZEND_RESULT_CODE php_persistent_handle_provide(const char *name_str, size_t name_len, php_resource_factory_ops_t *fops, void *data, void (*dtor)(void *) TSRMLS_DC) { - STATUS status = FAILURE; - php_persistent_handle_provider_t provider; + php_persistent_handle_provider_t *provider = pemalloc(sizeof(*provider), 1); + + if (php_persistent_handle_list_init(&provider->list)) { + if (php_resource_factory_init(&provider->rf, fops, data, dtor)) { + zval p; - if (php_persistent_handle_list_init(&provider.list)) { - if (php_resource_factory_init(&provider.rf, fops, data, dtor)) { #if PHP_RAPHF_DEBUG_PHANDLES fprintf(stderr, "PROVIDE: %p %s\n", PHP_RAPHF_G, name_str); #endif - status = zend_symtable_update(&PHP_RAPHF_G->persistent_handle.hash, - name_str, name_len+1, (void *) &provider, - sizeof(php_persistent_handle_provider_t), NULL); - if (SUCCESS != status) { - php_resource_factory_dtor(&provider.rf); + ZVAL_PTR(&p, provider); + if (zend_symtable_str_update(&PHP_RAPHF_G->persistent_handle.hash, + name_str, name_len, &p)) { + return SUCCESS; } + php_resource_factory_dtor(&provider->rf); } } - return status; + return FAILURE; } -PHP_RAPHF_API php_persistent_handle_factory_t *php_persistent_handle_concede( +php_persistent_handle_factory_t *php_persistent_handle_concede( php_persistent_handle_factory_t *a, const char *name_str, size_t name_len, const char *ident_str, size_t ident_len, php_persistent_handle_wakeup_t wakeup, php_persistent_handle_retire_t retire TSRMLS_DC) { - STATUS status = FAILURE; php_persistent_handle_factory_t *free_a = NULL; if (!a) { @@ -325,10 +327,10 @@ PHP_RAPHF_API php_persistent_handle_factory_t *php_persistent_handle_concede( } memset(a, 0, sizeof(*a)); - status = zend_symtable_find(&PHP_RAPHF_G->persistent_handle.hash, name_str, - name_len+1, (void *) &a->provider); + a->provider = zend_symtable_str_find_ptr(&PHP_RAPHF_G->persistent_handle.hash, + name_str, name_len+1); - if (SUCCESS == status) { + if (a->provider) { a->ident.str = estrndup(ident_str, ident_len); a->ident.len = ident_len; @@ -353,8 +355,7 @@ PHP_RAPHF_API php_persistent_handle_factory_t *php_persistent_handle_concede( return a; } -PHP_RAPHF_API void php_persistent_handle_abandon( - php_persistent_handle_factory_t *a) +void php_persistent_handle_abandon(php_persistent_handle_factory_t *a) { zend_bool f = a->free_on_abandon; @@ -362,20 +363,22 @@ PHP_RAPHF_API void php_persistent_handle_abandon( fprintf(stderr, "ABANDON: %p\n", a->provider); #endif - STR_FREE(a->ident.str); + if (a->ident.str) { + efree(a->ident.str); + } memset(a, 0, sizeof(*a)); if (f) { efree(a); } } -PHP_RAPHF_API void *php_persistent_handle_acquire( - php_persistent_handle_factory_t *a, void *init_arg TSRMLS_DC) +void *php_persistent_handle_acquire(php_persistent_handle_factory_t *a, + void *init_arg TSRMLS_DC) { int key; - STATUS rv; + zval *p; ulong index; - void **handle_ptr, *handle = NULL; + void *handle = NULL; php_persistent_handle_list_t *list; list = php_persistent_handle_list_find(a->provider, a->ident.str, @@ -383,9 +386,9 @@ PHP_RAPHF_API void *php_persistent_handle_acquire( if (list) { zend_hash_internal_pointer_end(&list->free); key = zend_hash_get_current_key(&list->free, NULL, &index, 0); - rv = zend_hash_get_current_data(&list->free, (void *) &handle_ptr); - if (HASH_KEY_NON_EXISTANT != key && SUCCESS == rv) { - handle = *handle_ptr; + p = zend_hash_get_current_data(&list->free); + if (p && HASH_KEY_NON_EXISTENT != key) { + handle = Z_PTR_P(p); if (a->wakeup) { a->wakeup(a, &handle TSRMLS_CC); } @@ -395,7 +398,7 @@ PHP_RAPHF_API void *php_persistent_handle_acquire( init_arg TSRMLS_CC); } #if PHP_RAPHF_DEBUG_PHANDLES - fprintf(stderr, "CREATED: %p\n", *handle); + fprintf(stderr, "CREATED: %p\n", handle); #endif if (handle) { ++a->provider->list.used; @@ -406,8 +409,8 @@ PHP_RAPHF_API void *php_persistent_handle_acquire( return handle; } -PHP_RAPHF_API void *php_persistent_handle_accrete( - php_persistent_handle_factory_t *a, void *handle TSRMLS_DC) +void *php_persistent_handle_accrete(php_persistent_handle_factory_t *a, + void *handle TSRMLS_DC) { void *new_handle = NULL; php_persistent_handle_list_t *list; @@ -426,8 +429,8 @@ PHP_RAPHF_API void *php_persistent_handle_accrete( return new_handle; } -PHP_RAPHF_API void php_persistent_handle_release( - php_persistent_handle_factory_t *a, void *handle TSRMLS_DC) +void php_persistent_handle_release(php_persistent_handle_factory_t *a, + void *handle TSRMLS_DC) { php_persistent_handle_list_t *list; @@ -436,16 +439,14 @@ PHP_RAPHF_API void php_persistent_handle_release( if (list) { if (a->provider->list.used >= PHP_RAPHF_G->persistent_handle.limit) { #if PHP_RAPHF_DEBUG_PHANDLES - fprintf(stderr, "DESTROY: %p\n", *handle); + fprintf(stderr, "DESTROY: %p\n", handle); #endif - php_resource_factory_handle_dtor(&a->provider->rf, - handle TSRMLS_CC); + php_resource_factory_handle_dtor(&a->provider->rf, handle TSRMLS_CC); } else { if (a->retire) { a->retire(a, &handle TSRMLS_CC); } - zend_hash_next_index_insert(&list->free, (void *) &handle, - sizeof(void *), NULL); + zend_hash_next_index_insert_ptr(&list->free, handle); } --a->provider->list.used; @@ -453,18 +454,17 @@ PHP_RAPHF_API void php_persistent_handle_release( } } -PHP_RAPHF_API void php_persistent_handle_cleanup(const char *name_str, - size_t name_len, const char *ident_str, size_t ident_len TSRMLS_DC) +void php_persistent_handle_cleanup(const char *name_str, size_t name_len, + const char *ident_str, size_t ident_len TSRMLS_DC) { php_persistent_handle_provider_t *provider; php_persistent_handle_list_t *list; - STATUS rv; if (name_str && name_len) { - rv = zend_symtable_find(&PHP_RAPHF_G->persistent_handle.hash, name_str, - name_len+1, (void *) &provider); + provider = zend_symtable_str_find_ptr(&PHP_RAPHF_G->persistent_handle.hash, + name_str, name_len+1); - if (SUCCESS == rv) { + if (provider) { if (ident_str && ident_len) { list = php_persistent_handle_list_find(provider, ident_str, ident_len TSRMLS_CC); @@ -487,7 +487,7 @@ PHP_RAPHF_API void php_persistent_handle_cleanup(const char *name_str, } } -PHP_RAPHF_API HashTable *php_persistent_handle_statall(HashTable *ht TSRMLS_DC) +HashTable *php_persistent_handle_statall(HashTable *ht TSRMLS_DC) { if (zend_hash_num_elements(&PHP_RAPHF_G->persistent_handle.hash)) { if (!ht) { @@ -510,8 +510,7 @@ static php_resource_factory_ops_t php_persistent_handle_resource_factory_ops = { (php_resource_factory_handle_dtor_t) php_persistent_handle_release }; -PHP_RAPHF_API php_resource_factory_ops_t * -php_persistent_handle_get_resource_factory_ops(void) +php_resource_factory_ops_t *php_persistent_handle_get_resource_factory_ops(void) { return &php_persistent_handle_resource_factory_ops; } @@ -564,7 +563,7 @@ PHP_INI_END() static HashTable *php_persistent_handles_global_hash; -static void php_raphf_globals_init(zend_raphf_globals *raphf_globals) +static PHP_GINIT_FUNCTION(raphf) { raphf_globals->persistent_handle.limit = -1; @@ -572,22 +571,18 @@ static void php_raphf_globals_init(zend_raphf_globals *raphf_globals) php_persistent_handle_hash_dtor, 1); if (php_persistent_handles_global_hash) { zend_hash_copy(&raphf_globals->persistent_handle.hash, - php_persistent_handles_global_hash, NULL, NULL, - sizeof(php_persistent_handle_provider_t)); + php_persistent_handles_global_hash, NULL); } } -static void php_raphf_globals_dtor(zend_raphf_globals *raphf_globals) +static PHP_GSHUTDOWN_FUNCTION(raphf) { zend_hash_destroy(&raphf_globals->persistent_handle.hash); } PHP_MINIT_FUNCTION(raphf) { - ZEND_INIT_MODULE_GLOBALS(raphf, php_raphf_globals_init, - php_raphf_globals_dtor); php_persistent_handles_global_hash = &PHP_RAPHF_G->persistent_handle.hash; - REGISTER_INI_ENTRIES(); return SUCCESS; } @@ -595,28 +590,29 @@ PHP_MINIT_FUNCTION(raphf) PHP_MSHUTDOWN_FUNCTION(raphf) { UNREGISTER_INI_ENTRIES(); + php_persistent_handles_global_hash = NULL; return SUCCESS; } -static int php_persistent_handle_apply_info_ex(void *p TSRMLS_DC, int argc, +static int php_persistent_handle_apply_info_ex(zval *p TSRMLS_DC, int argc, va_list argv, zend_hash_key *key) { - php_persistent_handle_list_t **list = p; + php_persistent_handle_list_t *list = Z_PTR_P(p); zend_hash_key *super_key = va_arg(argv, zend_hash_key *); char used[21], free[21]; - slprintf(used, sizeof(used), "%u", (*list)->used); - slprintf(free, sizeof(free), "%d", zend_hash_num_elements(&(*list)->free)); + slprintf(used, sizeof(used), "%u", list->used); + slprintf(free, sizeof(free), "%d", zend_hash_num_elements(&list->free)); - php_info_print_table_row(4, super_key->arKey, key->arKey, used, free); + php_info_print_table_row(4, super_key->key->val, key->key->val, used, free); return ZEND_HASH_APPLY_KEEP; } -static int php_persistent_handle_apply_info(void *p TSRMLS_DC, int argc, +static int php_persistent_handle_apply_info(zval *p TSRMLS_DC, int argc, va_list argv, zend_hash_key *key) { - php_persistent_handle_provider_t *provider = p; + php_persistent_handle_provider_t *provider = Z_PTR_P(p); zend_hash_apply_with_arguments(&provider->list.free TSRMLS_CC, php_persistent_handle_apply_info_ex, 1, key); @@ -659,7 +655,11 @@ zend_module_entry raphf_module_entry = { NULL, PHP_MINFO(raphf), PHP_RAPHF_VERSION, - STANDARD_MODULE_PROPERTIES + ZEND_MODULE_GLOBALS(raphf), + PHP_GINIT(raphf), + PHP_GSHUTDOWN(raphf), + NULL, + STANDARD_MODULE_PROPERTIES_EX }; /* }}} */