doh!
[m6w6/ext-raphf] / php_raphf.c
index 50c8b4d8b08edbf9e5158c739b8d49f68153c133..1f98145ff756a09e91d3c8cf69150a9f17be5d08 100644 (file)
@@ -31,19 +31,9 @@ typedef int STATUS;
 #      define inline
 #endif
 
-static HashTable php_persistent_handle_hash;
-
-#ifdef ZTS
-#      define LOCK() tsrm_mutex_lock(php_persistent_handle_lock)
-#      define UNLOCK() tsrm_mutex_unlock(php_persistent_handle_lock)
-static MUTEX_T php_persistent_handle_lock;
-#else
-#      define LOCK()
-#      define UNLOCK()
-#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_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))
 {
        if (!f) {
                f = emalloc(sizeof(*f));
@@ -87,7 +77,8 @@ 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 *init_arg TSRMLS_DC)
+PHP_RAPHF_API void *php_resource_factory_handle_ctor(php_resource_factory_t *f,
+               void *init_arg TSRMLS_DC)
 {
        if (f->fops.ctor) {
                return f->fops.ctor(f->data, init_arg TSRMLS_CC);
@@ -95,7 +86,8 @@ 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 *handle TSRMLS_DC)
+PHP_RAPHF_API void *php_resource_factory_handle_copy(php_resource_factory_t *f,
+               void *handle TSRMLS_DC)
 {
        if (f->fops.copy) {
                return f->fops.copy(f->data, handle TSRMLS_CC);
@@ -103,14 +95,16 @@ 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 *handle TSRMLS_DC)
+PHP_RAPHF_API void php_resource_factory_handle_dtor(php_resource_factory_t *f,
+               void *handle TSRMLS_DC)
 {
        if (f->fops.dtor) {
                f->fops.dtor(f->data, handle TSRMLS_CC);
        }
 }
 
-static inline php_persistent_handle_list_t *php_persistent_handle_list_init(php_persistent_handle_list_t *list)
+static inline php_persistent_handle_list_t *php_persistent_handle_list_init(
+               php_persistent_handle_list_t *list)
 {
        int free_list;
 
@@ -130,7 +124,8 @@ static inline php_persistent_handle_list_t *php_persistent_handle_list_init(php_
        return list;
 }
 
-static int php_persistent_handle_apply_stat(void *p TSRMLS_DC, int argc, va_list argv, zend_hash_key *key)
+static int php_persistent_handle_apply_stat(void *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 *);
@@ -138,13 +133,15 @@ static int php_persistent_handle_apply_stat(void *p TSRMLS_DC, int argc, va_list
        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_long_ex(zsubentry, ZEND_STRS("free"),
+                       zend_hash_num_elements(&(*list)->free));
        add_assoc_zval_ex(zentry, key->arKey, key->nKeyLength, zsubentry);
 
        return ZEND_HASH_APPLY_KEEP;
 }
 
-static int php_persistent_handle_apply_statall(void *p TSRMLS_DC, int argc, va_list argv, zend_hash_key *key)
+static int php_persistent_handle_apply_statall(void *p TSRMLS_DC, int argc,
+               va_list argv, zend_hash_key *key)
 {
        php_persistent_handle_provider_t *provider = p;
        HashTable *ht = va_arg(argv, HashTable *);
@@ -153,8 +150,10 @@ static int php_persistent_handle_apply_statall(void *p TSRMLS_DC, int argc, va_l
        MAKE_STD_ZVAL(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);
+       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);
 
        return ZEND_HASH_APPLY_KEEP;
 }
@@ -176,7 +175,8 @@ static int php_persistent_handle_apply_cleanup(void *pp, void *arg TSRMLS_DC)
        php_resource_factory_t *rf = arg;
        php_persistent_handle_list_t **listp = pp;
 
-       zend_hash_apply_with_argument(&(*listp)->free, php_persistent_handle_apply_cleanup_ex, rf TSRMLS_CC);
+       zend_hash_apply_with_argument(&(*listp)->free,
+                       php_persistent_handle_apply_cleanup_ex, rf TSRMLS_CC);
        if ((*listp)->used) {
                return ZEND_HASH_APPLY_KEEP;
        }
@@ -189,16 +189,21 @@ static int php_persistent_handle_apply_cleanup(void *pp, void *arg TSRMLS_DC)
        return ZEND_HASH_APPLY_REMOVE;
 }
 
-static inline void php_persistent_handle_list_dtor(php_persistent_handle_list_t *list, php_persistent_handle_provider_t *provider TSRMLS_DC)
+static inline void php_persistent_handle_list_dtor(
+               php_persistent_handle_list_t *list,
+               php_persistent_handle_provider_t *provider TSRMLS_DC)
 {
 #if PHP_RAPHF_DEBUG_PHANDLES
        fprintf(stderr, "LSTDTOR: %p\n", list);
 #endif
-       zend_hash_apply_with_argument(&list->free, php_persistent_handle_apply_cleanup_ex, &provider->rf TSRMLS_CC);
+       zend_hash_apply_with_argument(&list->free,
+                       php_persistent_handle_apply_cleanup_ex, &provider->rf TSRMLS_CC);
        zend_hash_destroy(&list->free);
 }
 
-static inline void php_persistent_handle_list_free(php_persistent_handle_list_t **list, php_persistent_handle_provider_t *provider TSRMLS_DC)
+static inline void php_persistent_handle_list_free(
+               php_persistent_handle_list_t **list,
+               php_persistent_handle_provider_t *provider TSRMLS_DC)
 {
        php_persistent_handle_list_dtor(*list, provider TSRMLS_CC);
 #if PHP_RAPHF_DEBUG_PHANDLES
@@ -208,17 +213,22 @@ static inline void php_persistent_handle_list_free(php_persistent_handle_list_t
        *list = NULL;
 }
 
-static int php_persistent_handle_list_apply_dtor(void *listp, void *provider TSRMLS_DC)
+static int php_persistent_handle_list_apply_dtor(void *listp,
+               void *provider TSRMLS_DC)
 {
        php_persistent_handle_list_free(listp, provider TSRMLS_CC);
        return ZEND_HASH_APPLY_REMOVE;
 }
 
-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)
+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);
 
-       if (SUCCESS == zend_symtable_find(&provider->list.free, ident_str, ident_len + 1, (void *) &list)) {
+       if (SUCCESS == rv) {
 #if PHP_RAPHF_DEBUG_PHANDLES
                fprintf(stderr, "LSTFIND: %p\n", *list);
 #endif
@@ -226,7 +236,10 @@ static inline php_persistent_handle_list_t *php_persistent_handle_list_find(php_
        }
 
        if ((new_list = php_persistent_handle_list_init(NULL))) {
-               if (SUCCESS == zend_symtable_update(&provider->list.free, ident_str, ident_len + 1, (void *) &new_list, sizeof(php_persistent_handle_list_t *), (void *) &list)) {
+               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 PHP_RAPHF_DEBUG_PHANDLES
                        fprintf(stderr, "LSTFIND: %p (new)\n", *list);
 #endif
@@ -238,7 +251,8 @@ static inline php_persistent_handle_list_t *php_persistent_handle_list_find(php_
        return NULL;
 }
 
-static int php_persistent_handle_apply_cleanup_all(void *p TSRMLS_DC, int argc, va_list argv, zend_hash_key *key)
+static int php_persistent_handle_apply_cleanup_all(void *p TSRMLS_DC, int argc,
+               va_list argv, zend_hash_key *key)
 {
        php_persistent_handle_provider_t *provider = p;
        const char *ident_str = va_arg(argv, const char *);
@@ -246,120 +260,62 @@ static int php_persistent_handle_apply_cleanup_all(void *p TSRMLS_DC, int argc,
        php_persistent_handle_list_t *list;
 
        if (ident_str && ident_len) {
-               if ((list = php_persistent_handle_list_find(provider, ident_str, ident_len TSRMLS_CC))) {
-                       zend_hash_apply_with_argument(&list->free, php_persistent_handle_apply_cleanup_ex, &provider->rf TSRMLS_CC);
+               if ((list = php_persistent_handle_list_find(provider, ident_str,
+                               ident_len TSRMLS_CC))) {
+                       zend_hash_apply_with_argument(&list->free,
+                                       php_persistent_handle_apply_cleanup_ex,
+                                       &provider->rf TSRMLS_CC);
                }
        } else {
-               zend_hash_apply_with_argument(&provider->list.free, php_persistent_handle_apply_cleanup, &provider->rf TSRMLS_CC);
+               zend_hash_apply_with_argument(&provider->list.free,
+                               php_persistent_handle_apply_cleanup, &provider->rf TSRMLS_CC);
        }
 
        return ZEND_HASH_APPLY_KEEP;
 }
 
-static inline STATUS php_persistent_handle_do_acquire(php_persistent_handle_provider_t *provider, const char *ident_str, size_t ident_len, void *init_arg, void **handle, zend_bool *awakened TSRMLS_DC)
-{
-       ulong index;
-       void **handle_ptr;
-       php_persistent_handle_list_t *list;
-
-       if ((list = php_persistent_handle_list_find(provider, ident_str, ident_len TSRMLS_CC))) {
-               zend_hash_internal_pointer_end(&list->free);
-               if (HASH_KEY_NON_EXISTANT != zend_hash_get_current_key(&list->free, NULL, &index, 0) && SUCCESS == zend_hash_get_current_data(&list->free, (void *) &handle_ptr)) {
-                       *awakened = 1;
-                       *handle = *handle_ptr;
-                       zend_hash_index_del(&list->free, index);
-               } else {
-                       *handle = php_resource_factory_handle_ctor(&provider->rf, init_arg TSRMLS_CC);
-               }
-#if PHP_RAPHF_DEBUG_PHANDLES
-               fprintf(stderr, "CREATED: %p\n", *handle);
-#endif
-               if (*handle) {
-                       ++provider->list.used;
-                       ++list->used;
-                       return SUCCESS;
-               }
-       } else {
-               *handle = NULL;
-       }
-
-       return FAILURE;
-}
-
-static inline STATUS php_persistent_handle_do_release(php_persistent_handle_provider_t *provider, const char *ident_str, size_t ident_len, void **handle, zend_bool *retired TSRMLS_DC)
-{
-       php_persistent_handle_list_t *list;
-
-       if ((list = php_persistent_handle_list_find(provider, ident_str, ident_len TSRMLS_CC))) {
-               if (provider->list.used >= PHP_RAPHF_G->persistent_handle.limit) {
-#if PHP_RAPHF_DEBUG_PHANDLES
-                       fprintf(stderr, "DESTROY: %p\n", *handle);
-#endif
-                       php_resource_factory_handle_dtor(&provider->rf, *handle TSRMLS_CC);
-               } else {
-                       if (SUCCESS != zend_hash_next_index_insert(&list->free, (void *) handle, sizeof(void *), NULL)) {
-                               return FAILURE;
-                       }
-                       *retired = 1;
-               }
-
-               --provider->list.used;
-               --list->used;
-               return SUCCESS;
-       }
-
-       return FAILURE;
-}
-
-static inline STATUS php_persistent_handle_do_accrete(php_persistent_handle_provider_t *provider, const char *ident_str, size_t ident_len, void *old_handle, void **new_handle TSRMLS_DC)
-{
-       php_persistent_handle_list_t *list;
-
-       if ((*new_handle = php_resource_factory_handle_copy(&provider->rf, old_handle TSRMLS_CC))) {
-               if ((list = php_persistent_handle_list_find(provider, ident_str, ident_len TSRMLS_CC))) {
-                       ++list->used;
-               }
-               ++provider->list.used;
-               return SUCCESS;
-       }
-       return FAILURE;
-}
-
 static void php_persistent_handle_hash_dtor(void *p)
 {
-       php_persistent_handle_provider_t *provider = (php_persistent_handle_provider_t *) p;
+       php_persistent_handle_provider_t *provider;
        TSRMLS_FETCH();
 
-       zend_hash_apply_with_argument(&provider->list.free, php_persistent_handle_list_apply_dtor, provider TSRMLS_CC);
+       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);
 }
 
-PHP_RAPHF_API STATUS php_persistent_handle_provide(const char *name_str, size_t name_len, php_resource_factory_ops_t *fops, void *data, void (*dtor)(void *))
+PHP_RAPHF_API STATUS 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;
 
-       LOCK();
        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: %s\n", name_str);
+                       fprintf(stderr, "PROVIDE: %p %s\n", PHP_RAPHF_G, name_str);
 #endif
 
-                       if (SUCCESS == zend_symtable_update(&php_persistent_handle_hash, name_str, name_len+1, (void *) &provider, sizeof(php_persistent_handle_provider_t), NULL)) {
-                               status = SUCCESS;
-                       } else {
+                       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);
                        }
                }
        }
-       UNLOCK();
 
        return status;
 }
 
-PHP_RAPHF_API 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)
+PHP_RAPHF_API 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;
@@ -369,9 +325,8 @@ PHP_RAPHF_API php_persistent_handle_factory_t *php_persistent_handle_concede(php
        }
        memset(a, 0, sizeof(*a));
 
-       LOCK();
-       status = zend_symtable_find(&php_persistent_handle_hash, name_str, name_len+1, (void *) &a->provider);
-       UNLOCK();
+       status = zend_symtable_find(&PHP_RAPHF_G->persistent_handle.hash, name_str,
+                       name_len+1, (void *) &a->provider);
 
        if (SUCCESS == status) {
                a->ident.str = estrndup(ident_str, ident_len);
@@ -391,13 +346,15 @@ PHP_RAPHF_API php_persistent_handle_factory_t *php_persistent_handle_concede(php
        }
 
 #if PHP_RAPHF_DEBUG_PHANDLES
-       fprintf(stderr, "CONCEDE: %p (%s) (%s)\n", a ? a->provider : NULL, name_str, ident_str);
+       fprintf(stderr, "CONCEDE: %p %p (%s) (%s)\n", PHP_RAPHF_G,
+                       a ? a->provider : NULL, name_str, ident_str);
 #endif
 
        return a;
 }
 
-PHP_RAPHF_API void php_persistent_handle_abandon(php_persistent_handle_factory_t *a)
+PHP_RAPHF_API void php_persistent_handle_abandon(
+               php_persistent_handle_factory_t *a)
 {
        zend_bool f = a->free_on_abandon;
 
@@ -412,81 +369,137 @@ PHP_RAPHF_API void php_persistent_handle_abandon(php_persistent_handle_factory_t
        }
 }
 
-PHP_RAPHF_API void *php_persistent_handle_acquire(php_persistent_handle_factory_t *a, void *init_arg  TSRMLS_DC)
+PHP_RAPHF_API void *php_persistent_handle_acquire(
+               php_persistent_handle_factory_t *a, void *init_arg  TSRMLS_DC)
 {
-       void *handle = NULL;
-       zend_bool awakened = 0;
-
-       LOCK();
-       php_persistent_handle_do_acquire(a->provider, a->ident.str, a->ident.len, init_arg, &handle, &awakened TSRMLS_CC);
-       UNLOCK();
+       int key;
+       STATUS rv;
+       ulong index;
+       void **handle_ptr, *handle = NULL;
+       php_persistent_handle_list_t *list;
 
-       if (awakened && a->wakeup) {
-               a->wakeup(a, &handle TSRMLS_CC);
+       list = php_persistent_handle_list_find(a->provider, a->ident.str,
+                       a->ident.len TSRMLS_CC);
+       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;
+                       if (a->wakeup) {
+                               a->wakeup(a, &handle TSRMLS_CC);
+                       }
+                       zend_hash_index_del(&list->free, index);
+               } else {
+                       handle = php_resource_factory_handle_ctor(&a->provider->rf,
+                                       init_arg TSRMLS_CC);
+               }
+#if PHP_RAPHF_DEBUG_PHANDLES
+               fprintf(stderr, "CREATED: %p\n", *handle);
+#endif
+               if (handle) {
+                       ++a->provider->list.used;
+                       ++list->used;
+               }
        }
 
        return handle;
 }
 
-PHP_RAPHF_API void *php_persistent_handle_accrete(php_persistent_handle_factory_t *a, void *handle TSRMLS_DC)
+PHP_RAPHF_API 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;
 
-       LOCK();
-       php_persistent_handle_do_accrete(a->provider, a->ident.str, a->ident.len, handle, &new_handle TSRMLS_CC);
-       UNLOCK();
+       new_handle = php_resource_factory_handle_copy(&a->provider->rf,
+                       handle TSRMLS_CC);
+       if (handle) {
+               list = php_persistent_handle_list_find(a->provider, a->ident.str,
+                               a->ident.len TSRMLS_CC);
+               if (list) {
+                       ++list->used;
+               }
+               ++a->provider->list.used;
+       }
 
        return new_handle;
 }
 
-PHP_RAPHF_API void php_persistent_handle_release(php_persistent_handle_factory_t *a, void *handle TSRMLS_DC)
+PHP_RAPHF_API void php_persistent_handle_release(
+               php_persistent_handle_factory_t *a, void *handle TSRMLS_DC)
 {
-       zend_bool retired = 0;
+       php_persistent_handle_list_t *list;
 
-       LOCK();
-       php_persistent_handle_do_release(a->provider, a->ident.str, a->ident.len, &handle, &retired TSRMLS_CC);
-       UNLOCK();
+       list = php_persistent_handle_list_find(a->provider, a->ident.str,
+                       a->ident.len TSRMLS_CC);
+       if (list) {
+               if (a->provider->list.used >= PHP_RAPHF_G->persistent_handle.limit) {
+#if PHP_RAPHF_DEBUG_PHANDLES
+                       fprintf(stderr, "DESTROY: %p\n", *handle);
+#endif
+                       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);
+               }
 
-       if (retired && a->retire) {
-               a->retire(a, &handle TSRMLS_CC);
+               --a->provider->list.used;
+               --list->used;
        }
 }
 
-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)
+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)
 {
        php_persistent_handle_provider_t *provider;
        php_persistent_handle_list_t *list;
+       STATUS rv;
 
-       LOCK();
        if (name_str && name_len) {
-               if (SUCCESS == zend_symtable_find(&php_persistent_handle_hash, name_str, name_len+1, (void *) &provider)) {
+               rv = zend_symtable_find(&PHP_RAPHF_G->persistent_handle.hash, name_str,
+                               name_len+1, (void *) &provider);
+
+               if (SUCCESS == rv) {
                        if (ident_str && ident_len) {
-                               if ((list = php_persistent_handle_list_find(provider, ident_str, ident_len TSRMLS_CC))) {
-                                       zend_hash_apply_with_argument(&list->free, php_persistent_handle_apply_cleanup_ex, &provider->rf TSRMLS_CC);
+                               list = php_persistent_handle_list_find(provider, ident_str,
+                                               ident_len TSRMLS_CC);
+                               if (list) {
+                                       zend_hash_apply_with_argument(&list->free,
+                                                       php_persistent_handle_apply_cleanup_ex,
+                                                       &provider->rf TSRMLS_CC);
                                }
                        } else {
-                               zend_hash_apply_with_argument(&provider->list.free, php_persistent_handle_apply_cleanup, &provider->rf TSRMLS_CC);
+                               zend_hash_apply_with_argument(&provider->list.free,
+                                               php_persistent_handle_apply_cleanup,
+                                               &provider->rf TSRMLS_CC);
                        }
                }
        } else {
-               zend_hash_apply_with_arguments(&php_persistent_handle_hash TSRMLS_CC, php_persistent_handle_apply_cleanup_all, 2, ident_str, ident_len);
+               zend_hash_apply_with_arguments(
+                               &PHP_RAPHF_G->persistent_handle.hash TSRMLS_CC,
+                               php_persistent_handle_apply_cleanup_all, 2, ident_str,
+                               ident_len);
        }
-       UNLOCK();
 }
 
 PHP_RAPHF_API HashTable *php_persistent_handle_statall(HashTable *ht TSRMLS_DC)
 {
-       LOCK();
-       if (zend_hash_num_elements(&php_persistent_handle_hash)) {
+       if (zend_hash_num_elements(&PHP_RAPHF_G->persistent_handle.hash)) {
                if (!ht) {
                        ALLOC_HASHTABLE(ht);
                        zend_hash_init(ht, 0, NULL, ZVAL_PTR_DTOR, 0);
                }
-               zend_hash_apply_with_arguments(&php_persistent_handle_hash TSRMLS_CC, php_persistent_handle_apply_statall, 1, ht);
+               zend_hash_apply_with_arguments(
+                               &PHP_RAPHF_G->persistent_handle.hash TSRMLS_CC,
+                               php_persistent_handle_apply_statall, 1, ht);
        } else if (ht) {
                ht = NULL;
        }
-       UNLOCK();
 
        return ht;
 }
@@ -497,7 +510,8 @@ 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_RAPHF_API php_resource_factory_ops_t *
+php_persistent_handle_get_resource_factory_ops(void)
 {
        return &php_persistent_handle_resource_factory_ops;
 }
@@ -525,48 +539,64 @@ static PHP_FUNCTION(raphf_clean_persistent_handles)
        char *name_str = NULL, *ident_str = NULL;
        int name_len = 0, ident_len = 0;
 
-       if (SUCCESS == zend_parse_parameters(ZEND_NUM_ARGS() TSRMLS_CC, "|s!s!", &name_str, &name_len, &ident_str, &ident_len)) {
-               php_persistent_handle_cleanup(name_str, name_len, ident_str, ident_len TSRMLS_CC);
+       if (SUCCESS == zend_parse_parameters(ZEND_NUM_ARGS() TSRMLS_CC, "|s!s!",
+                       &name_str, &name_len, &ident_str, &ident_len)) {
+               php_persistent_handle_cleanup(name_str, name_len, ident_str,
+                               ident_len TSRMLS_CC);
        }
 }
 
 static const zend_function_entry raphf_functions[] = {
-       ZEND_NS_FENTRY("raphf", stat_persistent_handles, ZEND_FN(raphf_stat_persistent_handles), ai_raphf_stat_persistent_handles, 0)
-       ZEND_NS_FENTRY("raphf", clean_persistent_handles, ZEND_FN(raphf_clean_persistent_handles), ai_raphf_clean_persistent_handles, 0)
+       ZEND_NS_FENTRY("raphf", stat_persistent_handles,
+                       ZEND_FN(raphf_stat_persistent_handles),
+                       ai_raphf_stat_persistent_handles, 0)
+       ZEND_NS_FENTRY("raphf", clean_persistent_handles,
+                       ZEND_FN(raphf_clean_persistent_handles),
+                       ai_raphf_clean_persistent_handles, 0)
        {0}
 };
 
 PHP_INI_BEGIN()
-       STD_PHP_INI_ENTRY("raphf.persistent_handle.limit", "-1", PHP_INI_SYSTEM, OnUpdateLong, persistent_handle.limit, zend_raphf_globals, raphf_globals)
+       STD_PHP_INI_ENTRY("raphf.persistent_handle.limit", "-1", PHP_INI_SYSTEM,
+                       OnUpdateLong, persistent_handle.limit, zend_raphf_globals,
+                       raphf_globals)
 PHP_INI_END()
 
-static void php_raphf_init_globals(zend_raphf_globals *raphf_globals)
+static HashTable *php_persistent_handles_global_hash;
+
+static PHP_GINIT_FUNCTION(raphf)
 {
        raphf_globals->persistent_handle.limit = -1;
+
+       zend_hash_init(&raphf_globals->persistent_handle.hash, 0, NULL,
+                       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));
+       }
+}
+
+static PHP_GSHUTDOWN_FUNCTION(raphf)
+{
+       zend_hash_destroy(&raphf_globals->persistent_handle.hash);
 }
 
 PHP_MINIT_FUNCTION(raphf)
 {
-       ZEND_INIT_MODULE_GLOBALS(raphf, php_raphf_init_globals, NULL);
-       zend_hash_init(&php_persistent_handle_hash, 0, NULL, php_persistent_handle_hash_dtor, 1);
-#ifdef ZTS
-       php_persistent_handle_lock = tsrm_mutex_alloc();
-#endif
+       php_persistent_handles_global_hash = &PHP_RAPHF_G->persistent_handle.hash;
        REGISTER_INI_ENTRIES();
        return SUCCESS;
 }
 
 PHP_MSHUTDOWN_FUNCTION(raphf)
 {
-       zend_hash_destroy(&php_persistent_handle_hash);
-#ifdef ZTS
-       tsrm_mutex_free(php_persistent_handle_lock);
-#endif
        UNREGISTER_INI_ENTRIES();
        return SUCCESS;
 }
 
-static int php_persistent_handle_apply_info_ex(void *p TSRMLS_DC, int argc, va_list argv, zend_hash_key *key)
+static int php_persistent_handle_apply_info_ex(void *p TSRMLS_DC, int argc,
+               va_list argv, zend_hash_key *key)
 {
        php_persistent_handle_list_t **list = p;
        zend_hash_key *super_key = va_arg(argv, zend_hash_key *);
@@ -580,11 +610,13 @@ static int php_persistent_handle_apply_info_ex(void *p TSRMLS_DC, int argc, va_l
        return ZEND_HASH_APPLY_KEEP;
 }
 
-static int php_persistent_handle_apply_info(void *p TSRMLS_DC, int argc, va_list argv, zend_hash_key *key)
+static int php_persistent_handle_apply_info(void *p TSRMLS_DC, int argc,
+               va_list argv, zend_hash_key *key)
 {
        php_persistent_handle_provider_t *provider = p;
 
-       zend_hash_apply_with_arguments(&provider->list.free TSRMLS_CC, php_persistent_handle_apply_info_ex, 1, key);
+       zend_hash_apply_with_arguments(&provider->list.free TSRMLS_CC,
+                       php_persistent_handle_apply_info_ex, 1, key);
 
        return ZEND_HASH_APPLY_KEEP;
 }
@@ -592,16 +624,23 @@ static int php_persistent_handle_apply_info(void *p TSRMLS_DC, int argc, va_list
 PHP_MINFO_FUNCTION(raphf)
 {
        php_info_print_table_start();
-       php_info_print_table_header(2, "Resource and persistent handle factory support", "enabled");
+       php_info_print_table_header(2,
+                       "Resource and persistent handle factory support", "enabled");
        php_info_print_table_row(2, "Extension version", PHP_RAPHF_VERSION);
        php_info_print_table_end();
 
        php_info_print_table_start();
-       php_info_print_table_colspan_header(4, "Persistent handles");
+       php_info_print_table_colspan_header(4, "Persistent handles in this "
+#ifdef ZTS
+                       "thread"
+#else
+                       "process"
+#endif
+       );
        php_info_print_table_header(4, "Provider", "Ident", "Used", "Free");
-       LOCK();
-       zend_hash_apply_with_arguments(&php_persistent_handle_hash TSRMLS_CC, php_persistent_handle_apply_info, 0);
-       UNLOCK();
+       zend_hash_apply_with_arguments(
+                       &PHP_RAPHF_G->persistent_handle.hash TSRMLS_CC,
+                       php_persistent_handle_apply_info, 0);
        php_info_print_table_end();
 
        DISPLAY_INI_ENTRIES();
@@ -617,7 +656,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
 };
 /* }}} */