zend_ts_hash.c 8.4 KB

123456789101112131415161718192021222324252627282930313233343536373839404142434445464748495051525354555657585960616263646566676869707172737475767778798081828384858687888990919293949596979899100101102103104105106107108109110111112113114115116117118119120121122123124125126127128129130131132133134135136137138139140141142143144145146147148149150151152153154155156157158159160161162163164165166167168169170171172173174175176177178179180181182183184185186187188189190191192193194195196197198199200201202203204205206207208209210211212213214215216217218219220221222223224225226227228229230231232233234235236237238239240241242243244245246247248249250251252253254255256257258259260261262263264265266267268269270271272273274275276277278279280281282283284285286287288289290291292293294295296297298299300301302303304305306307308309310311312313314315316317318319320321322323324325326327328329330331332333334335336337338339340341342343344345346347348349350351352353354355356357358359360361362363364365366367368369370371372373374375376377378379380381382383384385
  1. /*
  2. +----------------------------------------------------------------------+
  3. | Zend Engine |
  4. +----------------------------------------------------------------------+
  5. | Copyright (c) 1998-2018 Zend Technologies Ltd. (http://www.zend.com) |
  6. +----------------------------------------------------------------------+
  7. | This source file is subject to version 2.00 of the Zend license, |
  8. | that is bundled with this package in the file LICENSE, and is |
  9. | available through the world-wide-web at the following url: |
  10. | http://www.zend.com/license/2_00.txt. |
  11. | If you did not receive a copy of the Zend license and are unable to |
  12. | obtain it through the world-wide-web, please send a note to |
  13. | license@zend.com so we can mail you a copy immediately. |
  14. +----------------------------------------------------------------------+
  15. | Authors: Harald Radi <harald.radi@nme.at> |
  16. +----------------------------------------------------------------------+
  17. */
  18. #include "zend.h"
  19. #include "zend_ts_hash.h"
  20. /* ts management functions */
  21. static void begin_read(TsHashTable *ht)
  22. {
  23. #ifdef ZTS
  24. tsrm_mutex_lock(ht->mx_reader);
  25. if ((++(ht->reader)) == 1) {
  26. tsrm_mutex_lock(ht->mx_writer);
  27. }
  28. tsrm_mutex_unlock(ht->mx_reader);
  29. #endif
  30. }
  31. static void end_read(TsHashTable *ht)
  32. {
  33. #ifdef ZTS
  34. tsrm_mutex_lock(ht->mx_reader);
  35. if ((--(ht->reader)) == 0) {
  36. tsrm_mutex_unlock(ht->mx_writer);
  37. }
  38. tsrm_mutex_unlock(ht->mx_reader);
  39. #endif
  40. }
  41. static void begin_write(TsHashTable *ht)
  42. {
  43. #ifdef ZTS
  44. tsrm_mutex_lock(ht->mx_writer);
  45. #endif
  46. }
  47. static void end_write(TsHashTable *ht)
  48. {
  49. #ifdef ZTS
  50. tsrm_mutex_unlock(ht->mx_writer);
  51. #endif
  52. }
  53. /* delegates */
  54. ZEND_API void _zend_ts_hash_init(TsHashTable *ht, uint32_t nSize, dtor_func_t pDestructor, zend_bool persistent)
  55. {
  56. #ifdef ZTS
  57. ht->mx_reader = tsrm_mutex_alloc();
  58. ht->mx_writer = tsrm_mutex_alloc();
  59. ht->reader = 0;
  60. #endif
  61. _zend_hash_init(TS_HASH(ht), nSize, pDestructor, persistent);
  62. }
  63. ZEND_API void zend_ts_hash_destroy(TsHashTable *ht)
  64. {
  65. begin_write(ht);
  66. zend_hash_destroy(TS_HASH(ht));
  67. end_write(ht);
  68. #ifdef ZTS
  69. tsrm_mutex_free(ht->mx_reader);
  70. tsrm_mutex_free(ht->mx_writer);
  71. #endif
  72. }
  73. ZEND_API void zend_ts_hash_clean(TsHashTable *ht)
  74. {
  75. ht->reader = 0;
  76. begin_write(ht);
  77. zend_hash_clean(TS_HASH(ht));
  78. end_write(ht);
  79. }
  80. ZEND_API zval *zend_ts_hash_add(TsHashTable *ht, zend_string *key, zval *pData)
  81. {
  82. zval *retval;
  83. begin_write(ht);
  84. retval = zend_hash_add(TS_HASH(ht), key, pData);
  85. end_write(ht);
  86. return retval;
  87. }
  88. ZEND_API zval *zend_ts_hash_update(TsHashTable *ht, zend_string *key, zval *pData)
  89. {
  90. zval *retval;
  91. begin_write(ht);
  92. retval = zend_hash_update(TS_HASH(ht), key, pData);
  93. end_write(ht);
  94. return retval;
  95. }
  96. ZEND_API zval *zend_ts_hash_next_index_insert(TsHashTable *ht, zval *pData)
  97. {
  98. zval *retval;
  99. begin_write(ht);
  100. retval = zend_hash_next_index_insert(TS_HASH(ht), pData);
  101. end_write(ht);
  102. return retval;
  103. }
  104. ZEND_API zval *zend_ts_hash_index_update(TsHashTable *ht, zend_ulong h, zval *pData)
  105. {
  106. zval *retval;
  107. begin_write(ht);
  108. retval = zend_hash_index_update(TS_HASH(ht), h, pData);
  109. end_write(ht);
  110. return retval;
  111. }
  112. ZEND_API zval *zend_ts_hash_add_empty_element(TsHashTable *ht, zend_string *key)
  113. {
  114. zval *retval;
  115. begin_write(ht);
  116. retval = zend_hash_add_empty_element(TS_HASH(ht), key);
  117. end_write(ht);
  118. return retval;
  119. }
  120. ZEND_API void zend_ts_hash_graceful_destroy(TsHashTable *ht)
  121. {
  122. begin_write(ht);
  123. zend_hash_graceful_destroy(TS_HASH(ht));
  124. end_write(ht);
  125. #ifdef ZTS
  126. tsrm_mutex_free(ht->mx_reader);
  127. tsrm_mutex_free(ht->mx_writer);
  128. #endif
  129. }
  130. ZEND_API void zend_ts_hash_apply(TsHashTable *ht, apply_func_t apply_func)
  131. {
  132. begin_write(ht);
  133. zend_hash_apply(TS_HASH(ht), apply_func);
  134. end_write(ht);
  135. }
  136. ZEND_API void zend_ts_hash_apply_with_argument(TsHashTable *ht, apply_func_arg_t apply_func, void *argument)
  137. {
  138. begin_write(ht);
  139. zend_hash_apply_with_argument(TS_HASH(ht), apply_func, argument);
  140. end_write(ht);
  141. }
  142. ZEND_API void zend_ts_hash_apply_with_arguments(TsHashTable *ht, apply_func_args_t apply_func, int num_args, ...)
  143. {
  144. va_list args;
  145. va_start(args, num_args);
  146. begin_write(ht);
  147. zend_hash_apply_with_arguments(TS_HASH(ht), apply_func, num_args, args);
  148. end_write(ht);
  149. va_end(args);
  150. }
  151. ZEND_API void zend_ts_hash_reverse_apply(TsHashTable *ht, apply_func_t apply_func)
  152. {
  153. begin_write(ht);
  154. zend_hash_reverse_apply(TS_HASH(ht), apply_func);
  155. end_write(ht);
  156. }
  157. ZEND_API int zend_ts_hash_del(TsHashTable *ht, zend_string *key)
  158. {
  159. int retval;
  160. begin_write(ht);
  161. retval = zend_hash_del(TS_HASH(ht), key);
  162. end_write(ht);
  163. return retval;
  164. }
  165. ZEND_API int zend_ts_hash_index_del(TsHashTable *ht, zend_ulong h)
  166. {
  167. int retval;
  168. begin_write(ht);
  169. retval = zend_hash_index_del(TS_HASH(ht), h);
  170. end_write(ht);
  171. return retval;
  172. }
  173. ZEND_API zval *zend_ts_hash_find(TsHashTable *ht, zend_string *key)
  174. {
  175. zval *retval;
  176. begin_read(ht);
  177. retval = zend_hash_find(TS_HASH(ht), key);
  178. end_read(ht);
  179. return retval;
  180. }
  181. ZEND_API zval *zend_ts_hash_index_find(TsHashTable *ht, zend_ulong h)
  182. {
  183. zval *retval;
  184. begin_read(ht);
  185. retval = zend_hash_index_find(TS_HASH(ht), h);
  186. end_read(ht);
  187. return retval;
  188. }
  189. ZEND_API int zend_ts_hash_exists(TsHashTable *ht, zend_string *key)
  190. {
  191. int retval;
  192. begin_read(ht);
  193. retval = zend_hash_exists(TS_HASH(ht), key);
  194. end_read(ht);
  195. return retval;
  196. }
  197. ZEND_API int zend_ts_hash_index_exists(TsHashTable *ht, zend_ulong h)
  198. {
  199. int retval;
  200. begin_read(ht);
  201. retval = zend_hash_index_exists(TS_HASH(ht), h);
  202. end_read(ht);
  203. return retval;
  204. }
  205. ZEND_API void zend_ts_hash_copy(TsHashTable *target, TsHashTable *source, copy_ctor_func_t pCopyConstructor)
  206. {
  207. begin_read(source);
  208. begin_write(target);
  209. zend_hash_copy(TS_HASH(target), TS_HASH(source), pCopyConstructor);
  210. end_write(target);
  211. end_read(source);
  212. }
  213. ZEND_API void zend_ts_hash_copy_to_hash(HashTable *target, TsHashTable *source, copy_ctor_func_t pCopyConstructor)
  214. {
  215. begin_read(source);
  216. zend_hash_copy(target, TS_HASH(source), pCopyConstructor);
  217. end_read(source);
  218. }
  219. ZEND_API void zend_ts_hash_merge(TsHashTable *target, TsHashTable *source, copy_ctor_func_t pCopyConstructor, int overwrite)
  220. {
  221. begin_read(source);
  222. begin_write(target);
  223. zend_hash_merge(TS_HASH(target), TS_HASH(source), pCopyConstructor, overwrite);
  224. end_write(target);
  225. end_read(source);
  226. }
  227. ZEND_API void zend_ts_hash_merge_ex(TsHashTable *target, TsHashTable *source, copy_ctor_func_t pCopyConstructor, merge_checker_func_t pMergeSource, void *pParam)
  228. {
  229. begin_read(source);
  230. begin_write(target);
  231. zend_hash_merge_ex(TS_HASH(target), TS_HASH(source), pCopyConstructor, pMergeSource, pParam);
  232. end_write(target);
  233. end_read(source);
  234. }
  235. ZEND_API int zend_ts_hash_sort(TsHashTable *ht, sort_func_t sort_func, compare_func_t compare_func, int renumber)
  236. {
  237. int retval;
  238. begin_write(ht);
  239. retval = zend_hash_sort_ex(TS_HASH(ht), sort_func, compare_func, renumber);
  240. end_write(ht);
  241. return retval;
  242. }
  243. ZEND_API int zend_ts_hash_compare(TsHashTable *ht1, TsHashTable *ht2, compare_func_t compar, zend_bool ordered)
  244. {
  245. int retval;
  246. begin_read(ht1);
  247. begin_read(ht2);
  248. retval = zend_hash_compare(TS_HASH(ht1), TS_HASH(ht2), compar, ordered);
  249. end_read(ht2);
  250. end_read(ht1);
  251. return retval;
  252. }
  253. ZEND_API zval *zend_ts_hash_minmax(TsHashTable *ht, compare_func_t compar, int flag)
  254. {
  255. zval *retval;
  256. begin_read(ht);
  257. retval = zend_hash_minmax(TS_HASH(ht), compar, flag);
  258. end_read(ht);
  259. return retval;
  260. }
  261. ZEND_API int zend_ts_hash_num_elements(TsHashTable *ht)
  262. {
  263. int retval;
  264. begin_read(ht);
  265. retval = zend_hash_num_elements(TS_HASH(ht));
  266. end_read(ht);
  267. return retval;
  268. }
  269. ZEND_API int zend_ts_hash_rehash(TsHashTable *ht)
  270. {
  271. int retval;
  272. begin_write(ht);
  273. retval = zend_hash_rehash(TS_HASH(ht));
  274. end_write(ht);
  275. return retval;
  276. }
  277. ZEND_API zval *zend_ts_hash_str_find(TsHashTable *ht, const char *key, size_t len)
  278. {
  279. zval *retval;
  280. begin_read(ht);
  281. retval = zend_hash_str_find(TS_HASH(ht), key, len);
  282. end_read(ht);
  283. return retval;
  284. }
  285. ZEND_API zval *zend_ts_hash_str_update(TsHashTable *ht, const char *key, size_t len, zval *pData)
  286. {
  287. zval *retval;
  288. begin_write(ht);
  289. retval = zend_hash_str_update(TS_HASH(ht), key, len, pData);
  290. end_write(ht);
  291. return retval;
  292. }
  293. ZEND_API zval *zend_ts_hash_str_add(TsHashTable *ht, const char *key, size_t len, zval *pData)
  294. {
  295. zval *retval;
  296. begin_write(ht);
  297. retval = zend_hash_str_add(TS_HASH(ht), key, len, pData);
  298. end_write(ht);
  299. return retval;
  300. }
  301. /*
  302. * Local variables:
  303. * tab-width: 4
  304. * c-basic-offset: 4
  305. * indent-tabs-mode: t
  306. * End:
  307. */