mirror of
https://github.com/php/php-src.git
synced 2025-08-15 21:48:51 +02:00
5941cdaaad
On shutdown in ZTS the following happens: - https://github.com/php/php-src/blob/master/Zend/zend.c#L1124-L1125 gets executed. This destroys global persistent resources and destroys the modules. Furthermore, the modules are unloaded too. - Further down, `ts_free_id(executor_globals_id)` gets executed, which calls `executor_globals_dtor`. This function destroys persistent resources for each thread. Notice that in the last step, the modules that the persistent resource belong to may already have been destroyed. This means that accessing globals will cause a crash (I previously fixed this with ifdef magic), or when the module is dynamically loaded we'll try jumping to a destructor that is no longer loaded in memory. These scenarios cause crashes. It's not possible to move the `ts_free_id` call upwards, because that may break assumptions of callers, and furthermore this would deallocate the executor globals structure, which means that any access to those will cause a segfault. This patch adds a new API to the TSRM that allows running a callback on a certain resource type. We use this API to destroy the persistent resources in all threads prior to the module destruction, and keep the rest of the resource dtor intact. I verified this fix on Apache with postgres, both dynamically and statically. Fixes GH-12974.
203 lines
6.5 KiB
C
203 lines
6.5 KiB
C
/*
|
|
+----------------------------------------------------------------------+
|
|
| Thread Safe Resource Manager |
|
|
+----------------------------------------------------------------------+
|
|
| Copyright (c) 1999-2011, Andi Gutmans, Sascha Schumann, Zeev Suraski |
|
|
| This source file is subject to the TSRM license, that is bundled |
|
|
| with this package in the file LICENSE |
|
|
+----------------------------------------------------------------------+
|
|
| Authors: Zeev Suraski <zeev@php.net> |
|
|
+----------------------------------------------------------------------+
|
|
*/
|
|
|
|
#ifndef TSRM_H
|
|
#define TSRM_H
|
|
|
|
#if !defined(__CYGWIN__) && defined(WIN32)
|
|
# define TSRM_WIN32
|
|
# include "Zend/zend_config.w32.h"
|
|
#else
|
|
# include "main/php_config.h"
|
|
#endif
|
|
|
|
#include <stdint.h>
|
|
#include <stdbool.h>
|
|
|
|
#ifdef TSRM_WIN32
|
|
# ifdef TSRM_EXPORTS
|
|
# define TSRM_API __declspec(dllexport)
|
|
# else
|
|
# define TSRM_API __declspec(dllimport)
|
|
# endif
|
|
#elif defined(__GNUC__) && __GNUC__ >= 4
|
|
# define TSRM_API __attribute__ ((visibility("default")))
|
|
#else
|
|
# define TSRM_API
|
|
#endif
|
|
|
|
typedef intptr_t tsrm_intptr_t;
|
|
typedef uintptr_t tsrm_uintptr_t;
|
|
|
|
/* Only compile multi-threading functions if we're in ZTS mode */
|
|
#ifdef ZTS
|
|
|
|
#ifdef TSRM_WIN32
|
|
# ifndef TSRM_INCLUDE_FULL_WINDOWS_HEADERS
|
|
# define WIN32_LEAN_AND_MEAN
|
|
# endif
|
|
#else
|
|
# include <pthread.h>
|
|
#endif
|
|
|
|
#if SIZEOF_SIZE_T == 4
|
|
# define TSRM_ALIGNED_SIZE(size) \
|
|
(((size) + INT32_C(15)) & ~INT32_C(15))
|
|
#else
|
|
# define TSRM_ALIGNED_SIZE(size) \
|
|
(((size) + INT64_C(15)) & ~INT64_C(15))
|
|
#endif
|
|
|
|
typedef int ts_rsrc_id;
|
|
|
|
/* Define THREAD_T and MUTEX_T */
|
|
#ifdef TSRM_WIN32
|
|
# define THREAD_T DWORD
|
|
# define MUTEX_T CRITICAL_SECTION *
|
|
#else
|
|
# define THREAD_T pthread_t
|
|
# define MUTEX_T pthread_mutex_t *
|
|
#endif
|
|
|
|
#include <signal.h>
|
|
|
|
typedef void (*ts_allocate_ctor)(void *);
|
|
typedef void (*ts_allocate_dtor)(void *);
|
|
|
|
#define THREAD_HASH_OF(thr,ts) (unsigned long)thr%(unsigned long)ts
|
|
|
|
#ifdef __cplusplus
|
|
extern "C" {
|
|
#endif
|
|
|
|
/* startup/shutdown */
|
|
TSRM_API bool tsrm_startup(int expected_threads, int expected_resources, int debug_level, const char *debug_filename);
|
|
TSRM_API void tsrm_shutdown(void);
|
|
|
|
/* environ lock API */
|
|
TSRM_API void tsrm_env_lock(void);
|
|
TSRM_API void tsrm_env_unlock(void);
|
|
|
|
/* allocates a new thread-safe-resource id */
|
|
TSRM_API ts_rsrc_id ts_allocate_id(ts_rsrc_id *rsrc_id, size_t size, ts_allocate_ctor ctor, ts_allocate_dtor dtor);
|
|
|
|
/* Fast resource in reserved (pre-allocated) space */
|
|
TSRM_API void tsrm_reserve(size_t size);
|
|
TSRM_API ts_rsrc_id ts_allocate_fast_id(ts_rsrc_id *rsrc_id, size_t *offset, size_t size, ts_allocate_ctor ctor, ts_allocate_dtor dtor);
|
|
|
|
/* fetches the requested resource for the current thread */
|
|
TSRM_API void *ts_resource_ex(ts_rsrc_id id, THREAD_T *th_id);
|
|
#define ts_resource(id) ts_resource_ex(id, NULL)
|
|
|
|
/* frees all resources allocated for the current thread */
|
|
TSRM_API void ts_free_thread(void);
|
|
|
|
/* deallocates all occurrences of a given id */
|
|
TSRM_API void ts_free_id(ts_rsrc_id id);
|
|
|
|
/* Runs a callback on all resources of the given id.
|
|
* The caller is responsible for ensuring the underlying resources don't data-race. */
|
|
TSRM_API void ts_apply_for_id(ts_rsrc_id id, void (*cb)(void *));
|
|
|
|
/* Debug support */
|
|
#define TSRM_ERROR_LEVEL_ERROR 1
|
|
#define TSRM_ERROR_LEVEL_CORE 2
|
|
#define TSRM_ERROR_LEVEL_INFO 3
|
|
|
|
typedef void (*tsrm_thread_begin_func_t)(THREAD_T thread_id);
|
|
typedef void (*tsrm_thread_end_func_t)(THREAD_T thread_id);
|
|
typedef void (*tsrm_shutdown_func_t)(void);
|
|
|
|
|
|
TSRM_API int tsrm_error(int level, const char *format, ...);
|
|
TSRM_API void tsrm_error_set(int level, const char *debug_filename);
|
|
|
|
/* utility functions */
|
|
TSRM_API THREAD_T tsrm_thread_id(void);
|
|
TSRM_API MUTEX_T tsrm_mutex_alloc(void);
|
|
TSRM_API void tsrm_mutex_free(MUTEX_T mutexp);
|
|
TSRM_API int tsrm_mutex_lock(MUTEX_T mutexp);
|
|
TSRM_API int tsrm_mutex_unlock(MUTEX_T mutexp);
|
|
#ifdef HAVE_SIGPROCMASK
|
|
TSRM_API int tsrm_sigmask(int how, const sigset_t *set, sigset_t *oldset);
|
|
#endif
|
|
|
|
TSRM_API void *tsrm_set_new_thread_begin_handler(tsrm_thread_begin_func_t new_thread_begin_handler);
|
|
TSRM_API void *tsrm_set_new_thread_end_handler(tsrm_thread_end_func_t new_thread_end_handler);
|
|
TSRM_API void *tsrm_set_shutdown_handler(tsrm_shutdown_func_t shutdown_handler);
|
|
|
|
TSRM_API void *tsrm_get_ls_cache(void);
|
|
TSRM_API size_t tsrm_get_ls_cache_tcb_offset(void);
|
|
TSRM_API bool tsrm_is_main_thread(void);
|
|
TSRM_API bool tsrm_is_shutdown(void);
|
|
TSRM_API const char *tsrm_api_name(void);
|
|
TSRM_API bool tsrm_is_managed_thread(void);
|
|
|
|
#ifdef TSRM_WIN32
|
|
# define TSRM_TLS __declspec(thread)
|
|
#else
|
|
# define TSRM_TLS __thread
|
|
#endif
|
|
|
|
#ifndef __has_attribute
|
|
# define __has_attribute(x) 0
|
|
#endif
|
|
|
|
#if !__has_attribute(tls_model) || defined(__FreeBSD__) || defined(__MUSL__) || defined(__HAIKU__)
|
|
# define TSRM_TLS_MODEL_ATTR
|
|
#elif __PIC__
|
|
# define TSRM_TLS_MODEL_ATTR __attribute__((tls_model("initial-exec")))
|
|
#else
|
|
# define TSRM_TLS_MODEL_ATTR __attribute__((tls_model("local-exec")))
|
|
#endif
|
|
|
|
#define TSRM_SHUFFLE_RSRC_ID(rsrc_id) ((rsrc_id)+1)
|
|
#define TSRM_UNSHUFFLE_RSRC_ID(rsrc_id) ((rsrc_id)-1)
|
|
|
|
#define TSRMG(id, type, element) (TSRMG_BULK(id, type)->element)
|
|
#define TSRMG_BULK(id, type) ((type) (*((void ***) tsrm_get_ls_cache()))[TSRM_UNSHUFFLE_RSRC_ID(id)])
|
|
#define TSRMG_FAST(offset, type, element) (TSRMG_FAST_BULK(offset, type)->element)
|
|
#define TSRMG_FAST_BULK(offset, type) ((type) (((char*) tsrm_get_ls_cache())+(offset)))
|
|
|
|
#define TSRMG_STATIC(id, type, element) (TSRMG_BULK_STATIC(id, type)->element)
|
|
#define TSRMG_BULK_STATIC(id, type) ((type) (*((void ***) TSRMLS_CACHE))[TSRM_UNSHUFFLE_RSRC_ID(id)])
|
|
#define TSRMG_FAST_STATIC(offset, type, element) (TSRMG_FAST_BULK_STATIC(offset, type)->element)
|
|
#define TSRMG_FAST_BULK_STATIC(offset, type) ((type) (((char*) TSRMLS_CACHE)+(offset)))
|
|
#define TSRMLS_MAIN_CACHE_EXTERN() extern TSRM_TLS void *TSRMLS_CACHE TSRM_TLS_MODEL_ATTR;
|
|
#define TSRMLS_MAIN_CACHE_DEFINE() TSRM_TLS void *TSRMLS_CACHE TSRM_TLS_MODEL_ATTR = NULL;
|
|
#define TSRMLS_CACHE_EXTERN() extern TSRM_TLS void *TSRMLS_CACHE;
|
|
#define TSRMLS_CACHE_DEFINE() TSRM_TLS void *TSRMLS_CACHE = NULL;
|
|
#define TSRMLS_CACHE_UPDATE() TSRMLS_CACHE = tsrm_get_ls_cache()
|
|
#define TSRMLS_CACHE _tsrm_ls_cache
|
|
|
|
#ifdef __cplusplus
|
|
}
|
|
#endif
|
|
|
|
#else /* non ZTS */
|
|
|
|
#define tsrm_env_lock()
|
|
#define tsrm_env_unlock()
|
|
|
|
#define TSRMG_STATIC(id, type, element)
|
|
#define TSRMLS_MAIN_CACHE_EXTERN()
|
|
#define TSRMLS_MAIN_CACHE_DEFINE()
|
|
#define TSRMLS_CACHE_EXTERN()
|
|
#define TSRMLS_CACHE_DEFINE()
|
|
#define TSRMLS_CACHE_UPDATE()
|
|
#define TSRMLS_CACHE
|
|
|
|
#define TSRM_TLS
|
|
|
|
#endif /* ZTS */
|
|
|
|
#endif /* TSRM_H */
|