mysqlnd_alloc.c 14 KB

123456789101112131415161718192021222324252627282930313233343536373839404142434445464748495051525354555657585960616263646566676869707172737475767778798081828384858687888990919293949596979899100101102103104105106107108109110111112113114115116117118119120121122123124125126127128129130131132133134135136137138139140141142143144145146147148149150151152153154155156157158159160161162163164165166167168169170171172173174175176177178179180181182183184185186187188189190191192193194195196197198199200201202203204205206207208209210211212213214215216217218219220221222223224225226227228229230231232233234235236237238239240241242243244245246247248249250251252253254255256257258259260261262263264265266267268269270271272273274275276277278279280281282283284285286287288289290291292293294295296297298299300301302303304305306307308309310311312313314315316317318319320321322323324325326327328329330331332333334335336337338339340341342343344345346347348349350351352353354355356357358359360361362363364365366367368369370371372373374375376377378379380381382383384385386387388389390391392393394395396397398399400401402403404405406407408409410411412413414415416417418419420421422423424425426427428429430431432433434435436437438439440441442443444445446447448449450451452453454455456457458459460461462463464465466467468469470471472473474475476477478479480481482483484485486
  1. /*
  2. +----------------------------------------------------------------------+
  3. | Copyright (c) The PHP Group |
  4. +----------------------------------------------------------------------+
  5. | This source file is subject to version 3.01 of the PHP license, |
  6. | that is bundled with this package in the file LICENSE, and is |
  7. | available through the world-wide-web at the following url: |
  8. | https://www.php.net/license/3_01.txt |
  9. | If you did not receive a copy of the PHP license and are unable to |
  10. | obtain it through the world-wide-web, please send a note to |
  11. | license@php.net so we can mail you a copy immediately. |
  12. +----------------------------------------------------------------------+
  13. | Authors: Andrey Hristov <andrey@php.net> |
  14. | Ulf Wendel <uw@php.net> |
  15. +----------------------------------------------------------------------+
  16. */
  17. #include "php.h"
  18. #include "mysqlnd.h"
  19. #include "mysqlnd_priv.h"
  20. #include "mysqlnd_debug.h"
  21. #include "mysqlnd_wireprotocol.h"
  22. #include "mysqlnd_statistics.h"
  23. #define MYSQLND_DEBUG_MEMORY 1
  24. static const char mysqlnd_emalloc_name[] = "_mysqlnd_emalloc";
  25. static const char mysqlnd_pemalloc_name[] = "_mysqlnd_pemalloc";
  26. static const char mysqlnd_ecalloc_name[] = "_mysqlnd_ecalloc";
  27. static const char mysqlnd_pecalloc_name[] = "_mysqlnd_pecalloc";
  28. static const char mysqlnd_erealloc_name[] = "_mysqlnd_erealloc";
  29. static const char mysqlnd_perealloc_name[] = "_mysqlnd_perealloc";
  30. static const char mysqlnd_efree_name[] = "_mysqlnd_efree";
  31. static const char mysqlnd_pefree_name[] = "_mysqlnd_pefree";
  32. static const char mysqlnd_pememdup_name[] = "_mysqlnd_pememdup";
  33. static const char mysqlnd_pestrndup_name[] = "_mysqlnd_pestrndup";
  34. static const char mysqlnd_pestrdup_name[] = "_mysqlnd_pestrdup";
  35. PHPAPI const char * mysqlnd_debug_std_no_trace_funcs[] =
  36. {
  37. mysqlnd_emalloc_name,
  38. mysqlnd_ecalloc_name,
  39. mysqlnd_efree_name,
  40. mysqlnd_erealloc_name,
  41. mysqlnd_pemalloc_name,
  42. mysqlnd_pecalloc_name,
  43. mysqlnd_pefree_name,
  44. mysqlnd_perealloc_name,
  45. mysqlnd_pestrndup_name,
  46. mysqlnd_read_header_name,
  47. mysqlnd_read_body_name,
  48. NULL /* must be always last */
  49. };
  50. #if MYSQLND_DEBUG_MEMORY
  51. #if ZEND_DEBUG
  52. #else
  53. #define __zend_orig_filename "/unknown/unknown"
  54. #define __zend_orig_lineno 0
  55. #endif
  56. #define EXTRA_SIZE ZEND_MM_ALIGNED_SIZE(sizeof(size_t))
  57. #define REAL_SIZE(s) (collect_memory_statistics? (s) + EXTRA_SIZE : (s))
  58. #define REAL_PTR(p) (collect_memory_statistics && (p)? (((char *)(p)) - EXTRA_SIZE) : (p))
  59. #define FAKE_PTR(p) (collect_memory_statistics && (p)? (((char *)(p)) + EXTRA_SIZE) : (p))
  60. /* {{{ _mysqlnd_emalloc */
  61. static void * _mysqlnd_emalloc(size_t size MYSQLND_MEM_D)
  62. {
  63. void *ret;
  64. bool collect_memory_statistics = MYSQLND_G(collect_memory_statistics);
  65. TRACE_ALLOC_ENTER(mysqlnd_emalloc_name);
  66. ret = emalloc_rel(REAL_SIZE(size));
  67. TRACE_ALLOC_INF_FMT("size=%zu ptr=%p", size, ret);
  68. if (collect_memory_statistics) {
  69. *(size_t *) ret = size;
  70. MYSQLND_INC_GLOBAL_STATISTIC_W_VALUE2(STAT_MEM_EMALLOC_COUNT, 1, STAT_MEM_EMALLOC_AMOUNT, size);
  71. }
  72. TRACE_ALLOC_RETURN(FAKE_PTR(ret));
  73. }
  74. /* }}} */
  75. /* {{{ _mysqlnd_pemalloc */
  76. static void * _mysqlnd_pemalloc(size_t size, bool persistent MYSQLND_MEM_D)
  77. {
  78. void *ret;
  79. bool collect_memory_statistics = MYSQLND_G(collect_memory_statistics);
  80. TRACE_ALLOC_ENTER(mysqlnd_pemalloc_name);
  81. ret = pemalloc_rel(REAL_SIZE(size), persistent);
  82. TRACE_ALLOC_INF_FMT("size=%zu ptr=%p persistent=%u", size, ret, persistent);
  83. if (collect_memory_statistics) {
  84. enum mysqlnd_collected_stats s1 = persistent? STAT_MEM_MALLOC_COUNT:STAT_MEM_EMALLOC_COUNT;
  85. enum mysqlnd_collected_stats s2 = persistent? STAT_MEM_MALLOC_AMOUNT:STAT_MEM_EMALLOC_AMOUNT;
  86. *(size_t *) ret = size;
  87. MYSQLND_INC_GLOBAL_STATISTIC_W_VALUE2(s1, 1, s2, size);
  88. }
  89. TRACE_ALLOC_RETURN(FAKE_PTR(ret));
  90. }
  91. /* }}} */
  92. /* {{{ _mysqlnd_ecalloc */
  93. static void * _mysqlnd_ecalloc(unsigned int nmemb, size_t size MYSQLND_MEM_D)
  94. {
  95. void *ret;
  96. bool collect_memory_statistics = MYSQLND_G(collect_memory_statistics);
  97. TRACE_ALLOC_ENTER(mysqlnd_ecalloc_name);
  98. TRACE_ALLOC_INF_FMT("before: %zu", zend_memory_usage(FALSE));
  99. ret = ecalloc_rel(nmemb, REAL_SIZE(size));
  100. TRACE_ALLOC_INF_FMT("after : %zu", zend_memory_usage(FALSE));
  101. TRACE_ALLOC_INF_FMT("size=%zu ptr=%p", size, ret);
  102. if (collect_memory_statistics) {
  103. *(size_t *) ret = size;
  104. MYSQLND_INC_GLOBAL_STATISTIC_W_VALUE2(STAT_MEM_ECALLOC_COUNT, 1, STAT_MEM_ECALLOC_AMOUNT, size);
  105. }
  106. TRACE_ALLOC_RETURN(FAKE_PTR(ret));
  107. }
  108. /* }}} */
  109. /* {{{ _mysqlnd_pecalloc */
  110. static void * _mysqlnd_pecalloc(unsigned int nmemb, size_t size, bool persistent MYSQLND_MEM_D)
  111. {
  112. void *ret;
  113. bool collect_memory_statistics = MYSQLND_G(collect_memory_statistics);
  114. TRACE_ALLOC_ENTER(mysqlnd_pecalloc_name);
  115. ret = pecalloc_rel(nmemb, REAL_SIZE(size), persistent);
  116. TRACE_ALLOC_INF_FMT("size=%zu ptr=%p", size, ret);
  117. if (collect_memory_statistics) {
  118. enum mysqlnd_collected_stats s1 = persistent? STAT_MEM_CALLOC_COUNT:STAT_MEM_ECALLOC_COUNT;
  119. enum mysqlnd_collected_stats s2 = persistent? STAT_MEM_CALLOC_AMOUNT:STAT_MEM_ECALLOC_AMOUNT;
  120. *(size_t *) ret = size;
  121. MYSQLND_INC_GLOBAL_STATISTIC_W_VALUE2(s1, 1, s2, size);
  122. }
  123. TRACE_ALLOC_RETURN(FAKE_PTR(ret));
  124. }
  125. /* }}} */
  126. /* {{{ _mysqlnd_erealloc */
  127. static void * _mysqlnd_erealloc(void *ptr, size_t new_size MYSQLND_MEM_D)
  128. {
  129. void *ret;
  130. bool collect_memory_statistics = MYSQLND_G(collect_memory_statistics);
  131. size_t old_size = collect_memory_statistics && ptr? *(size_t *) (((char*)ptr) - sizeof(size_t)) : 0;
  132. TRACE_ALLOC_ENTER(mysqlnd_erealloc_name);
  133. TRACE_ALLOC_INF_FMT("ptr=%p old_size=%zu, new_size=%zu", ptr, old_size, new_size);
  134. ret = erealloc_rel(REAL_PTR(ptr), REAL_SIZE(new_size));
  135. TRACE_ALLOC_INF_FMT("new_ptr=%p", (char*)ret);
  136. if (collect_memory_statistics) {
  137. *(size_t *) ret = new_size;
  138. MYSQLND_INC_GLOBAL_STATISTIC_W_VALUE2(STAT_MEM_EREALLOC_COUNT, 1, STAT_MEM_EREALLOC_AMOUNT, new_size);
  139. }
  140. TRACE_ALLOC_RETURN(FAKE_PTR(ret));
  141. }
  142. /* }}} */
  143. /* {{{ _mysqlnd_perealloc */
  144. static void * _mysqlnd_perealloc(void *ptr, size_t new_size, bool persistent MYSQLND_MEM_D)
  145. {
  146. void *ret;
  147. bool collect_memory_statistics = MYSQLND_G(collect_memory_statistics);
  148. size_t old_size = collect_memory_statistics && ptr? *(size_t *) (((char*)ptr) - sizeof(size_t)) : 0;
  149. TRACE_ALLOC_ENTER(mysqlnd_perealloc_name);
  150. TRACE_ALLOC_INF_FMT("ptr=%p old_size=%zu new_size=%zu persistent=%u", ptr, old_size, new_size, persistent);
  151. ret = perealloc_rel(REAL_PTR(ptr), REAL_SIZE(new_size), persistent);
  152. TRACE_ALLOC_INF_FMT("new_ptr=%p", (char*)ret);
  153. if (collect_memory_statistics) {
  154. enum mysqlnd_collected_stats s1 = persistent? STAT_MEM_REALLOC_COUNT:STAT_MEM_EREALLOC_COUNT;
  155. enum mysqlnd_collected_stats s2 = persistent? STAT_MEM_REALLOC_AMOUNT:STAT_MEM_EREALLOC_AMOUNT;
  156. *(size_t *) ret = new_size;
  157. MYSQLND_INC_GLOBAL_STATISTIC_W_VALUE2(s1, 1, s2, new_size);
  158. }
  159. TRACE_ALLOC_RETURN(FAKE_PTR(ret));
  160. }
  161. /* }}} */
  162. /* {{{ _mysqlnd_efree */
  163. static void _mysqlnd_efree(void *ptr MYSQLND_MEM_D)
  164. {
  165. size_t free_amount = 0;
  166. bool collect_memory_statistics = MYSQLND_G(collect_memory_statistics);
  167. TRACE_ALLOC_ENTER(mysqlnd_efree_name);
  168. #if PHP_DEBUG
  169. {
  170. char * fn = strrchr(__zend_filename, PHP_DIR_SEPARATOR);
  171. TRACE_ALLOC_INF_FMT("file=%-15s line=%4d", fn? fn + 1:__zend_filename, __zend_lineno);
  172. }
  173. #endif
  174. TRACE_ALLOC_INF_FMT("ptr=%p", ptr);
  175. if (ptr) {
  176. if (collect_memory_statistics) {
  177. free_amount = *(size_t *)(((char*)ptr) - sizeof(size_t));
  178. TRACE_ALLOC_INF_FMT("ptr=%p size=%zu", ((char*)ptr) - sizeof(size_t), free_amount);
  179. }
  180. efree_rel(REAL_PTR(ptr));
  181. }
  182. if (collect_memory_statistics) {
  183. MYSQLND_INC_GLOBAL_STATISTIC_W_VALUE2(STAT_MEM_EFREE_COUNT, 1, STAT_MEM_EFREE_AMOUNT, free_amount);
  184. }
  185. TRACE_ALLOC_VOID_RETURN;
  186. }
  187. /* }}} */
  188. /* {{{ _mysqlnd_pefree */
  189. static void _mysqlnd_pefree(void *ptr, bool persistent MYSQLND_MEM_D)
  190. {
  191. size_t free_amount = 0;
  192. bool collect_memory_statistics = MYSQLND_G(collect_memory_statistics);
  193. TRACE_ALLOC_ENTER(mysqlnd_pefree_name);
  194. #if PHP_DEBUG
  195. {
  196. char * fn = strrchr(__zend_filename, PHP_DIR_SEPARATOR);
  197. TRACE_ALLOC_INF_FMT("file=%-15s line=%4d", fn? fn + 1:__zend_filename, __zend_lineno);
  198. }
  199. #endif
  200. TRACE_ALLOC_INF_FMT("ptr=%p persistent=%u", ptr, persistent);
  201. if (ptr) {
  202. if (collect_memory_statistics) {
  203. free_amount = *(size_t *)(((char*)ptr) - sizeof(size_t));
  204. TRACE_ALLOC_INF_FMT("ptr=%p size=%zu", ((char*)ptr) - sizeof(size_t), free_amount);
  205. }
  206. pefree_rel(REAL_PTR(ptr), persistent);
  207. }
  208. if (collect_memory_statistics) {
  209. MYSQLND_INC_GLOBAL_STATISTIC_W_VALUE2(persistent? STAT_MEM_FREE_COUNT:STAT_MEM_EFREE_COUNT, 1,
  210. persistent? STAT_MEM_FREE_AMOUNT:STAT_MEM_EFREE_AMOUNT, free_amount);
  211. }
  212. TRACE_ALLOC_VOID_RETURN;
  213. }
  214. /* }}} */
  215. /* {{{ _mysqlnd_pememdup */
  216. static char * _mysqlnd_pememdup(const char * const ptr, size_t length, bool persistent MYSQLND_MEM_D)
  217. {
  218. char * ret;
  219. bool collect_memory_statistics = MYSQLND_G(collect_memory_statistics);
  220. TRACE_ALLOC_ENTER(mysqlnd_pememdup_name);
  221. #if PHP_DEBUG
  222. {
  223. char * fn = strrchr(__zend_filename, PHP_DIR_SEPARATOR);
  224. TRACE_ALLOC_INF_FMT("file=%-15s line=%4d", fn? fn + 1:__zend_filename, __zend_lineno);
  225. }
  226. #endif
  227. TRACE_ALLOC_INF_FMT("ptr=%p", ptr);
  228. ret = pemalloc_rel(REAL_SIZE(length + 1), persistent);
  229. {
  230. char * dest = (char *) FAKE_PTR(ret);
  231. memcpy(dest, ptr, length);
  232. }
  233. if (collect_memory_statistics) {
  234. *(size_t *) ret = length;
  235. MYSQLND_INC_GLOBAL_STATISTIC(persistent? STAT_MEM_DUP_COUNT : STAT_MEM_EDUP_COUNT);
  236. }
  237. TRACE_ALLOC_RETURN(FAKE_PTR(ret));
  238. }
  239. /* }}} */
  240. /* {{{ _mysqlnd_pestrndup */
  241. static char * _mysqlnd_pestrndup(const char * const ptr, size_t length, bool persistent MYSQLND_MEM_D)
  242. {
  243. char * ret;
  244. bool collect_memory_statistics = MYSQLND_G(collect_memory_statistics);
  245. TRACE_ALLOC_ENTER(mysqlnd_pestrndup_name);
  246. #if PHP_DEBUG
  247. {
  248. char * fn = strrchr(__zend_filename, PHP_DIR_SEPARATOR);
  249. TRACE_ALLOC_INF_FMT("file=%-15s line=%4d", fn? fn + 1:__zend_filename, __zend_lineno);
  250. }
  251. #endif
  252. TRACE_ALLOC_INF_FMT("ptr=%p", ptr);
  253. ret = pemalloc_rel(REAL_SIZE(length + 1), persistent);
  254. {
  255. size_t l = length;
  256. char * p = (char *) ptr;
  257. char * dest = (char *) FAKE_PTR(ret);
  258. while (*p && l--) {
  259. *dest++ = *p++;
  260. }
  261. *dest = '\0';
  262. }
  263. if (collect_memory_statistics) {
  264. *(size_t *) ret = length;
  265. MYSQLND_INC_GLOBAL_STATISTIC(persistent? STAT_MEM_STRNDUP_COUNT : STAT_MEM_ESTRNDUP_COUNT);
  266. }
  267. TRACE_ALLOC_RETURN(FAKE_PTR(ret));
  268. }
  269. /* }}} */
  270. #define SMART_STR_START_SIZE 2048
  271. #define SMART_STR_PREALLOC 512
  272. #include "zend_smart_str.h"
  273. /* {{{ _mysqlnd_pestrdup */
  274. static char * _mysqlnd_pestrdup(const char * const ptr, bool persistent MYSQLND_MEM_D)
  275. {
  276. char * ret;
  277. smart_str tmp_str = {0, 0};
  278. const char * p = ptr;
  279. bool collect_memory_statistics = MYSQLND_G(collect_memory_statistics);
  280. TRACE_ALLOC_ENTER(mysqlnd_pestrdup_name);
  281. #if PHP_DEBUG
  282. {
  283. char * fn = strrchr(__zend_filename, PHP_DIR_SEPARATOR);
  284. TRACE_ALLOC_INF_FMT("file=%-15s line=%4d", fn? fn + 1:__zend_filename, __zend_lineno);
  285. }
  286. #endif
  287. TRACE_ALLOC_INF_FMT("ptr=%p", ptr);
  288. do {
  289. smart_str_appendc(&tmp_str, *p);
  290. } while (*p++);
  291. ret = pemalloc_rel(ZSTR_LEN(tmp_str.s) + sizeof(size_t), persistent);
  292. memcpy(FAKE_PTR(ret), ZSTR_VAL(tmp_str.s), ZSTR_LEN(tmp_str.s));
  293. if (ret && collect_memory_statistics) {
  294. *(size_t *) ret = ZSTR_LEN(tmp_str.s);
  295. MYSQLND_INC_GLOBAL_STATISTIC(persistent? STAT_MEM_STRDUP_COUNT : STAT_MEM_ESTRDUP_COUNT);
  296. }
  297. smart_str_free(&tmp_str);
  298. TRACE_ALLOC_RETURN(FAKE_PTR(ret));
  299. }
  300. /* }}} */
  301. #else
  302. /* {{{ mysqlnd_zend_mm_emalloc */
  303. static void * mysqlnd_zend_mm_emalloc(size_t size MYSQLND_MEM_D)
  304. {
  305. return emalloc_rel(size);
  306. }
  307. /* }}} */
  308. /* {{{ mysqlnd_zend_mm_pemalloc */
  309. static void * mysqlnd_zend_mm_pemalloc(size_t size, bool persistent MYSQLND_MEM_D)
  310. {
  311. return pemalloc_rel(size, persistent);
  312. }
  313. /* }}} */
  314. /* {{{ mysqlnd_zend_mm_ecalloc */
  315. static void * mysqlnd_zend_mm_ecalloc(unsigned int nmemb, size_t size MYSQLND_MEM_D)
  316. {
  317. return ecalloc_rel(nmemb, size);
  318. }
  319. /* }}} */
  320. /* {{{ mysqlnd_zend_mm_pecalloc */
  321. static void * mysqlnd_zend_mm_pecalloc(unsigned int nmemb, size_t size, bool persistent MYSQLND_MEM_D)
  322. {
  323. return pecalloc_rel(nmemb, size, persistent);
  324. }
  325. /* }}} */
  326. /* {{{ mysqlnd_zend_mm_erealloc */
  327. static void * mysqlnd_zend_mm_erealloc(void *ptr, size_t new_size MYSQLND_MEM_D)
  328. {
  329. return erealloc_rel(ptr, new_size);
  330. }
  331. /* }}} */
  332. /* {{{ mysqlnd_zend_mm_perealloc */
  333. static void * mysqlnd_zend_mm_perealloc(void *ptr, size_t new_size, bool persistent MYSQLND_MEM_D)
  334. {
  335. return perealloc_rel(ptr, new_size, persistent);
  336. }
  337. /* }}} */
  338. /* {{{ mysqlnd_zend_mm_efree */
  339. static void mysqlnd_zend_mm_efree(void * ptr MYSQLND_MEM_D)
  340. {
  341. efree_rel(ptr);
  342. }
  343. /* }}} */
  344. /* {{{ mysqlnd_zend_mm_pefree */
  345. static void mysqlnd_zend_mm_pefree(void * ptr, bool persistent MYSQLND_MEM_D)
  346. {
  347. pefree_rel(ptr, persistent);
  348. }
  349. /* }}} */
  350. /* {{{ mysqlnd_zend_mm_pememdup */
  351. static char * mysqlnd_zend_mm_pememdup(const char * const ptr, size_t length, bool persistent MYSQLND_MEM_D)
  352. {
  353. char * dest = pemalloc_rel(length, persistent);
  354. if (dest) {
  355. memcpy(dest, ptr, length);
  356. }
  357. return dest;
  358. }
  359. /* }}} */
  360. /* {{{ mysqlnd_zend_mm_pestrndup */
  361. static char * mysqlnd_zend_mm_pestrndup(const char * const ptr, size_t length, bool persistent MYSQLND_MEM_D)
  362. {
  363. return persistent? zend_strndup(ptr, length ) : estrndup_rel(ptr, length);
  364. }
  365. /* }}} */
  366. /* {{{ mysqlnd_zend_mm_pestrdup */
  367. static char * mysqlnd_zend_mm_pestrdup(const char * const ptr, bool persistent MYSQLND_MEM_D)
  368. {
  369. return pestrdup_rel(ptr, persistent);
  370. }
  371. /* }}} */
  372. #endif /* MYSQLND_DEBUG_MEMORY */
  373. PHPAPI struct st_mysqlnd_allocator_methods mysqlnd_allocator =
  374. {
  375. #if MYSQLND_DEBUG_MEMORY == 1
  376. _mysqlnd_emalloc,
  377. _mysqlnd_pemalloc,
  378. _mysqlnd_ecalloc,
  379. _mysqlnd_pecalloc,
  380. _mysqlnd_erealloc,
  381. _mysqlnd_perealloc,
  382. _mysqlnd_efree,
  383. _mysqlnd_pefree,
  384. _mysqlnd_pememdup,
  385. _mysqlnd_pestrndup,
  386. _mysqlnd_pestrdup
  387. #else
  388. mysqlnd_zend_mm_emalloc,
  389. mysqlnd_zend_mm_pemalloc,
  390. mysqlnd_zend_mm_ecalloc,
  391. mysqlnd_zend_mm_pecalloc,
  392. mysqlnd_zend_mm_erealloc,
  393. mysqlnd_zend_mm_perealloc,
  394. mysqlnd_zend_mm_efree,
  395. mysqlnd_zend_mm_pefree,
  396. mysqlnd_zend_mm_pememdup,
  397. mysqlnd_zend_mm_pestrndup,
  398. mysqlnd_zend_mm_pestrdup
  399. #endif
  400. };