xref: /PHP-5.4/ext/mysqlnd/mysqlnd_block_alloc.c (revision c0d060f5)
1 /*
2   +----------------------------------------------------------------------+
3   | PHP Version 5                                                        |
4   +----------------------------------------------------------------------+
5   | Copyright (c) 2006-2014 The PHP Group                                |
6   +----------------------------------------------------------------------+
7   | This source file is subject to version 3.01 of the PHP 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.php.net/license/3_01.txt                                  |
11   | If you did not receive a copy of the PHP license and are unable to   |
12   | obtain it through the world-wide-web, please send a note to          |
13   | license@php.net so we can mail you a copy immediately.               |
14   +----------------------------------------------------------------------+
15   | Authors: Georg Richter <georg@mysql.com>                             |
16   |          Andrey Hristov <andrey@mysql.com>                           |
17   |          Ulf Wendel <uwendel@mysql.com>                              |
18   +----------------------------------------------------------------------+
19 */
20 
21 /* $Id$ */
22 
23 #include "php.h"
24 #include "mysqlnd.h"
25 #include "mysqlnd_block_alloc.h"
26 #include "mysqlnd_debug.h"
27 #include "mysqlnd_priv.h"
28 
29 
30 /* {{{ mysqlnd_mempool_free_chunk */
31 static void
mysqlnd_mempool_free_chunk(MYSQLND_MEMORY_POOL_CHUNK * chunk TSRMLS_DC)32 mysqlnd_mempool_free_chunk(MYSQLND_MEMORY_POOL_CHUNK * chunk TSRMLS_DC)
33 {
34 	MYSQLND_MEMORY_POOL * pool = chunk->pool;
35 	DBG_ENTER("mysqlnd_mempool_free_chunk");
36 	if (chunk->from_pool) {
37 		/* Try to back-off and guess if this is the last block allocated */
38 		if (chunk->ptr == (pool->arena + (pool->arena_size - pool->free_size - chunk->size))) {
39 			/*
40 				This was the last allocation. Lucky us, we can free
41 				a bit of memory from the pool. Next time we will return from the same ptr.
42 			*/
43 			pool->free_size += chunk->size;
44 		}
45 		pool->refcount--;
46 	} else {
47 		mnd_free(chunk->ptr);
48 	}
49 	mnd_free(chunk);
50 	DBG_VOID_RETURN;
51 }
52 /* }}} */
53 
54 
55 /* {{{ mysqlnd_mempool_resize_chunk */
56 static enum_func_status
mysqlnd_mempool_resize_chunk(MYSQLND_MEMORY_POOL_CHUNK * chunk,unsigned int size TSRMLS_DC)57 mysqlnd_mempool_resize_chunk(MYSQLND_MEMORY_POOL_CHUNK * chunk, unsigned int size TSRMLS_DC)
58 {
59 	DBG_ENTER("mysqlnd_mempool_resize_chunk");
60 	if (chunk->from_pool) {
61 		MYSQLND_MEMORY_POOL * pool = chunk->pool;
62 		/* Try to back-off and guess if this is the last block allocated */
63 		if (chunk->ptr == (pool->arena + (pool->arena_size - pool->free_size - chunk->size))) {
64 			/*
65 				This was the last allocation. Lucky us, we can free
66 				a bit of memory from the pool. Next time we will return from the same ptr.
67 			*/
68 			if ((chunk->size + pool->free_size) < size) {
69 				zend_uchar *new_ptr;
70 				new_ptr = mnd_malloc(size);
71 				if (!new_ptr) {
72 					DBG_RETURN(FAIL);
73 				}
74 				memcpy(new_ptr, chunk->ptr, chunk->size);
75 				chunk->ptr = new_ptr;
76 				pool->free_size += chunk->size;
77 				chunk->size = size;
78 				chunk->pool = NULL; /* now we have no pool memory */
79 				pool->refcount--;
80 			} else {
81 				/* If the chunk is > than asked size then free_memory increases, otherwise decreases*/
82 				pool->free_size += (chunk->size - size);
83 			}
84 		} else {
85 			/* Not last chunk, if the user asks for less, give it to him */
86 			if (chunk->size >= size) {
87 				; /* nop */
88 			} else {
89 				zend_uchar *new_ptr;
90 				new_ptr = mnd_malloc(size);
91 				if (!new_ptr) {
92 					DBG_RETURN(FAIL);
93 				}
94 				memcpy(new_ptr, chunk->ptr, chunk->size);
95 				chunk->ptr = new_ptr;
96 				chunk->size = size;
97 				chunk->pool = NULL; /* now we have non-pool memory */
98 				pool->refcount--;
99 			}
100 		}
101 	} else {
102 		zend_uchar *new_ptr = mnd_realloc(chunk->ptr, size);
103 		if (!new_ptr) {
104 			DBG_RETURN(FAIL);
105 		}
106 		chunk->ptr = new_ptr;
107 	}
108 	DBG_RETURN(PASS);
109 }
110 /* }}} */
111 
112 
113 /* {{{ mysqlnd_mempool_get_chunk */
114 static
mysqlnd_mempool_get_chunk(MYSQLND_MEMORY_POOL * pool,unsigned int size TSRMLS_DC)115 MYSQLND_MEMORY_POOL_CHUNK * mysqlnd_mempool_get_chunk(MYSQLND_MEMORY_POOL * pool, unsigned int size TSRMLS_DC)
116 {
117 	MYSQLND_MEMORY_POOL_CHUNK *chunk = NULL;
118 	DBG_ENTER("mysqlnd_mempool_get_chunk");
119 
120 	chunk = mnd_malloc(sizeof(MYSQLND_MEMORY_POOL_CHUNK));
121 	if (chunk) {
122 		chunk->free_chunk = mysqlnd_mempool_free_chunk;
123 		chunk->resize_chunk = mysqlnd_mempool_resize_chunk;
124 		chunk->size = size;
125 		/*
126 		  Should not go over MYSQLND_MAX_PACKET_SIZE, since we
127 		  expect non-arena memory in mysqlnd_wireprotocol.c . We
128 		  realloc the non-arena memory.
129 		*/
130 		chunk->pool = pool;
131 		if (size > pool->free_size) {
132 			chunk->from_pool = FALSE;
133 			chunk->ptr = mnd_malloc(size);
134 			if (!chunk->ptr) {
135 				chunk->free_chunk(chunk TSRMLS_CC);
136 				chunk = NULL;
137 			}
138 		} else {
139 			chunk->from_pool = TRUE;
140 			++pool->refcount;
141 			chunk->ptr = pool->arena + (pool->arena_size - pool->free_size);
142 			/* Last step, update free_size */
143 			pool->free_size -= size;
144 		}
145 	}
146 	DBG_RETURN(chunk);
147 }
148 /* }}} */
149 
150 
151 /* {{{ mysqlnd_mempool_create */
152 PHPAPI MYSQLND_MEMORY_POOL *
mysqlnd_mempool_create(size_t arena_size TSRMLS_DC)153 mysqlnd_mempool_create(size_t arena_size TSRMLS_DC)
154 {
155 	/* We calloc, because we free(). We don't mnd_calloc()  for a reason. */
156 	MYSQLND_MEMORY_POOL * ret = mnd_calloc(1, sizeof(MYSQLND_MEMORY_POOL));
157 	DBG_ENTER("mysqlnd_mempool_create");
158 	if (ret) {
159 		ret->get_chunk = mysqlnd_mempool_get_chunk;
160 		ret->free_size = ret->arena_size = arena_size ? arena_size : 0;
161 		ret->refcount = 0;
162 		/* OOM ? */
163 		ret->arena = mnd_malloc(ret->arena_size);
164 		if (!ret->arena) {
165 			mysqlnd_mempool_destroy(ret TSRMLS_CC);
166 			ret = NULL;
167 		}
168 	}
169 	DBG_RETURN(ret);
170 }
171 /* }}} */
172 
173 
174 /* {{{ mysqlnd_mempool_destroy */
175 PHPAPI void
mysqlnd_mempool_destroy(MYSQLND_MEMORY_POOL * pool TSRMLS_DC)176 mysqlnd_mempool_destroy(MYSQLND_MEMORY_POOL * pool TSRMLS_DC)
177 {
178 	DBG_ENTER("mysqlnd_mempool_destroy");
179 	/* mnd_free will reference LOCK_access and might crash, depending on the caller...*/
180 	mnd_free(pool->arena);
181 	mnd_free(pool);
182 	DBG_VOID_RETURN;
183 }
184 /* }}} */
185 
186 
187 /*
188  * Local variables:
189  * tab-width: 4
190  * c-basic-offset: 4
191  * End:
192  * vim600: noet sw=4 ts=4 fdm=marker
193  * vim<600: noet sw=4 ts=4
194  */
195