|
sl@0
|
1 |
/*
|
|
sl@0
|
2 |
** 2008 July 24
|
|
sl@0
|
3 |
**
|
|
sl@0
|
4 |
** The author disclaims copyright to this source code. In place of
|
|
sl@0
|
5 |
** a legal notice, here is a blessing:
|
|
sl@0
|
6 |
**
|
|
sl@0
|
7 |
** May you do good and not evil.
|
|
sl@0
|
8 |
** May you find forgiveness for yourself and forgive others.
|
|
sl@0
|
9 |
** May you share freely, never taking more than you give.
|
|
sl@0
|
10 |
**
|
|
sl@0
|
11 |
*************************************************************************
|
|
sl@0
|
12 |
**
|
|
sl@0
|
13 |
** This file contains an alternative memory allocation system for SQLite.
|
|
sl@0
|
14 |
** This system is implemented as a wrapper around the system provided
|
|
sl@0
|
15 |
** by the operating system - vanilla malloc(), realloc() and free().
|
|
sl@0
|
16 |
**
|
|
sl@0
|
17 |
** This system differentiates between requests for "small" allocations
|
|
sl@0
|
18 |
** (by default those of 128 bytes or less) and "large" allocations (all
|
|
sl@0
|
19 |
** others). The 256 byte threshhold is configurable at runtime.
|
|
sl@0
|
20 |
**
|
|
sl@0
|
21 |
** All requests for large allocations are passed through to the
|
|
sl@0
|
22 |
** default system.
|
|
sl@0
|
23 |
**
|
|
sl@0
|
24 |
** Requests for small allocations are met by allocating space within
|
|
sl@0
|
25 |
** one or more larger "chunks" of memory obtained from the default
|
|
sl@0
|
26 |
** memory allocation system. Chunks of memory are usually 64KB or
|
|
sl@0
|
27 |
** larger. The algorithm used to manage space within each chunk is
|
|
sl@0
|
28 |
** the same as that used by mem5.c.
|
|
sl@0
|
29 |
**
|
|
sl@0
|
30 |
** This strategy is designed to prevent the default memory allocation
|
|
sl@0
|
31 |
** system (usually the system malloc) from suffering from heap
|
|
sl@0
|
32 |
** fragmentation. On some systems, heap fragmentation can cause a
|
|
sl@0
|
33 |
** significant real-time slowdown.
|
|
sl@0
|
34 |
**
|
|
sl@0
|
35 |
** $Id: mem6.c,v 1.7 2008/07/28 19:34:53 drh Exp $
|
|
sl@0
|
36 |
*/
|
|
sl@0
|
37 |
|
|
sl@0
|
38 |
#ifdef SQLITE_ENABLE_MEMSYS6
|
|
sl@0
|
39 |
|
|
sl@0
|
40 |
#include "sqliteInt.h"
|
|
sl@0
|
41 |
|
|
sl@0
|
42 |
/*
|
|
sl@0
|
43 |
** Maximum size of any "small" allocation is ((1<<LOGMAX)*Mem6Chunk.nAtom).
|
|
sl@0
|
44 |
** Mem6Chunk.nAtom is always at least 8, so this is not a practical
|
|
sl@0
|
45 |
** limitation
|
|
sl@0
|
46 |
*/
|
|
sl@0
|
47 |
#define LOGMAX 30
|
|
sl@0
|
48 |
|
|
sl@0
|
49 |
/*
|
|
sl@0
|
50 |
** Default value for the "small" allocation size threshold.
|
|
sl@0
|
51 |
*/
|
|
sl@0
|
52 |
#define SMALL_MALLOC_DEFAULT_THRESHOLD 256
|
|
sl@0
|
53 |
|
|
sl@0
|
54 |
/*
|
|
sl@0
|
55 |
** Minimum size for a memory chunk.
|
|
sl@0
|
56 |
*/
|
|
sl@0
|
57 |
#define MIN_CHUNKSIZE (1<<16)
|
|
sl@0
|
58 |
|
|
sl@0
|
59 |
#define LOG2_MINALLOC 4
|
|
sl@0
|
60 |
|
|
sl@0
|
61 |
|
|
sl@0
|
62 |
typedef struct Mem6Chunk Mem6Chunk;
|
|
sl@0
|
63 |
typedef struct Mem6Link Mem6Link;
|
|
sl@0
|
64 |
|
|
sl@0
|
65 |
/*
|
|
sl@0
|
66 |
** A minimum allocation is an instance of the following structure.
|
|
sl@0
|
67 |
** Larger allocations are an array of these structures where the
|
|
sl@0
|
68 |
** size of the array is a power of 2.
|
|
sl@0
|
69 |
*/
|
|
sl@0
|
70 |
struct Mem6Link {
|
|
sl@0
|
71 |
int next; /* Index of next free chunk */
|
|
sl@0
|
72 |
int prev; /* Index of previous free chunk */
|
|
sl@0
|
73 |
};
|
|
sl@0
|
74 |
|
|
sl@0
|
75 |
/*
|
|
sl@0
|
76 |
** Masks used for mem5.aCtrl[] elements.
|
|
sl@0
|
77 |
*/
|
|
sl@0
|
78 |
#define CTRL_LOGSIZE 0x1f /* Log2 Size of this block relative to POW2_MIN */
|
|
sl@0
|
79 |
#define CTRL_FREE 0x20 /* True if not checked out */
|
|
sl@0
|
80 |
|
|
sl@0
|
81 |
struct Mem6Chunk {
|
|
sl@0
|
82 |
Mem6Chunk *pNext;
|
|
sl@0
|
83 |
|
|
sl@0
|
84 |
/*
|
|
sl@0
|
85 |
** Lists of free blocks of various sizes.
|
|
sl@0
|
86 |
*/
|
|
sl@0
|
87 |
int aiFreelist[LOGMAX+1];
|
|
sl@0
|
88 |
|
|
sl@0
|
89 |
int nCheckedOut; /* Number of currently outstanding allocations */
|
|
sl@0
|
90 |
|
|
sl@0
|
91 |
/*
|
|
sl@0
|
92 |
** Space for tracking which blocks are checked out and the size
|
|
sl@0
|
93 |
** of each block. One byte per block.
|
|
sl@0
|
94 |
*/
|
|
sl@0
|
95 |
u8 *aCtrl;
|
|
sl@0
|
96 |
|
|
sl@0
|
97 |
/*
|
|
sl@0
|
98 |
** Memory available for allocation
|
|
sl@0
|
99 |
*/
|
|
sl@0
|
100 |
int nAtom; /* Smallest possible allocation in bytes */
|
|
sl@0
|
101 |
int nBlock; /* Number of nAtom sized blocks in zPool */
|
|
sl@0
|
102 |
u8 *zPool; /* Pointer to memory chunk from which allocations are made */
|
|
sl@0
|
103 |
};
|
|
sl@0
|
104 |
|
|
sl@0
|
105 |
#define MEM6LINK(idx) ((Mem6Link *)(&pChunk->zPool[(idx)*pChunk->nAtom]))
|
|
sl@0
|
106 |
|
|
sl@0
|
107 |
struct Mem6Global {
|
|
sl@0
|
108 |
int nMinAlloc; /* Minimum allowed allocation size */
|
|
sl@0
|
109 |
int nThreshold; /* Allocs larger than this go to malloc() */
|
|
sl@0
|
110 |
int nLogThreshold; /* log2 of (nThreshold/nMinAlloc) */
|
|
sl@0
|
111 |
sqlite3_mutex *mutex;
|
|
sl@0
|
112 |
Mem6Chunk *pChunk; /* Singly linked list of all memory chunks */
|
|
sl@0
|
113 |
} mem6;
|
|
sl@0
|
114 |
|
|
sl@0
|
115 |
/*
|
|
sl@0
|
116 |
** Unlink the chunk at pChunk->aPool[i] from list it is currently
|
|
sl@0
|
117 |
** on. It should be found on pChunk->aiFreelist[iLogsize].
|
|
sl@0
|
118 |
*/
|
|
sl@0
|
119 |
static void memsys6Unlink(Mem6Chunk *pChunk, int i, int iLogsize){
|
|
sl@0
|
120 |
int next, prev;
|
|
sl@0
|
121 |
assert( i>=0 && i<pChunk->nBlock );
|
|
sl@0
|
122 |
assert( iLogsize>=0 && iLogsize<=mem6.nLogThreshold );
|
|
sl@0
|
123 |
assert( (pChunk->aCtrl[i] & CTRL_LOGSIZE)==iLogsize );
|
|
sl@0
|
124 |
|
|
sl@0
|
125 |
next = MEM6LINK(i)->next;
|
|
sl@0
|
126 |
prev = MEM6LINK(i)->prev;
|
|
sl@0
|
127 |
if( prev<0 ){
|
|
sl@0
|
128 |
pChunk->aiFreelist[iLogsize] = next;
|
|
sl@0
|
129 |
}else{
|
|
sl@0
|
130 |
MEM6LINK(prev)->next = next;
|
|
sl@0
|
131 |
}
|
|
sl@0
|
132 |
if( next>=0 ){
|
|
sl@0
|
133 |
MEM6LINK(next)->prev = prev;
|
|
sl@0
|
134 |
}
|
|
sl@0
|
135 |
}
|
|
sl@0
|
136 |
|
|
sl@0
|
137 |
/*
|
|
sl@0
|
138 |
** Link the chunk at mem5.aPool[i] so that is on the iLogsize
|
|
sl@0
|
139 |
** free list.
|
|
sl@0
|
140 |
*/
|
|
sl@0
|
141 |
static void memsys6Link(Mem6Chunk *pChunk, int i, int iLogsize){
|
|
sl@0
|
142 |
int x;
|
|
sl@0
|
143 |
assert( i>=0 && i<pChunk->nBlock );
|
|
sl@0
|
144 |
assert( iLogsize>=0 && iLogsize<=mem6.nLogThreshold );
|
|
sl@0
|
145 |
assert( (pChunk->aCtrl[i] & CTRL_LOGSIZE)==iLogsize );
|
|
sl@0
|
146 |
|
|
sl@0
|
147 |
x = MEM6LINK(i)->next = pChunk->aiFreelist[iLogsize];
|
|
sl@0
|
148 |
MEM6LINK(i)->prev = -1;
|
|
sl@0
|
149 |
if( x>=0 ){
|
|
sl@0
|
150 |
assert( x<pChunk->nBlock );
|
|
sl@0
|
151 |
MEM6LINK(x)->prev = i;
|
|
sl@0
|
152 |
}
|
|
sl@0
|
153 |
pChunk->aiFreelist[iLogsize] = i;
|
|
sl@0
|
154 |
}
|
|
sl@0
|
155 |
|
|
sl@0
|
156 |
|
|
sl@0
|
157 |
/*
|
|
sl@0
|
158 |
** Find the first entry on the freelist iLogsize. Unlink that
|
|
sl@0
|
159 |
** entry and return its index.
|
|
sl@0
|
160 |
*/
|
|
sl@0
|
161 |
static int memsys6UnlinkFirst(Mem6Chunk *pChunk, int iLogsize){
|
|
sl@0
|
162 |
int i;
|
|
sl@0
|
163 |
int iFirst;
|
|
sl@0
|
164 |
|
|
sl@0
|
165 |
assert( iLogsize>=0 && iLogsize<=mem6.nLogThreshold );
|
|
sl@0
|
166 |
i = iFirst = pChunk->aiFreelist[iLogsize];
|
|
sl@0
|
167 |
assert( iFirst>=0 );
|
|
sl@0
|
168 |
memsys6Unlink(pChunk, iFirst, iLogsize);
|
|
sl@0
|
169 |
return iFirst;
|
|
sl@0
|
170 |
}
|
|
sl@0
|
171 |
|
|
sl@0
|
172 |
static int roundupLog2(int n){
|
|
sl@0
|
173 |
static const char LogTable256[256] = {
|
|
sl@0
|
174 |
0, /* 1 */
|
|
sl@0
|
175 |
1, /* 2 */
|
|
sl@0
|
176 |
2, 2, /* 3..4 */
|
|
sl@0
|
177 |
3, 3, 3, 3, /* 5..8 */
|
|
sl@0
|
178 |
4, 4, 4, 4, 4, 4, 4, 4, /* 9..16 */
|
|
sl@0
|
179 |
5, 5, 5, 5, 5, 5, 5, 5, 5, 5, 5, 5, 5, 5, 5, 5, /* 17..32 */
|
|
sl@0
|
180 |
6, 6, 6, 6, 6, 6, 6, 6, 6, 6, 6, 6, 6, 6, 6, 6,
|
|
sl@0
|
181 |
6, 6, 6, 6, 6, 6, 6, 6, 6, 6, 6, 6, 6, 6, 6, 6, /* 33..64 */
|
|
sl@0
|
182 |
7, 7, 7, 7, 7, 7, 7, 7, 7, 7, 7, 7, 7, 7, 7, 7,
|
|
sl@0
|
183 |
7, 7, 7, 7, 7, 7, 7, 7, 7, 7, 7, 7, 7, 7, 7, 7,
|
|
sl@0
|
184 |
7, 7, 7, 7, 7, 7, 7, 7, 7, 7, 7, 7, 7, 7, 7, 7,
|
|
sl@0
|
185 |
7, 7, 7, 7, 7, 7, 7, 7, 7, 7, 7, 7, 7, 7, 7, 7, /* 65..128 */
|
|
sl@0
|
186 |
8, 8, 8, 8, 8, 8, 8, 8, 8, 8, 8, 8, 8, 8, 8, 8,
|
|
sl@0
|
187 |
8, 8, 8, 8, 8, 8, 8, 8, 8, 8, 8, 8, 8, 8, 8, 8,
|
|
sl@0
|
188 |
8, 8, 8, 8, 8, 8, 8, 8, 8, 8, 8, 8, 8, 8, 8, 8,
|
|
sl@0
|
189 |
8, 8, 8, 8, 8, 8, 8, 8, 8, 8, 8, 8, 8, 8, 8, 8,
|
|
sl@0
|
190 |
8, 8, 8, 8, 8, 8, 8, 8, 8, 8, 8, 8, 8, 8, 8, 8,
|
|
sl@0
|
191 |
8, 8, 8, 8, 8, 8, 8, 8, 8, 8, 8, 8, 8, 8, 8, 8,
|
|
sl@0
|
192 |
8, 8, 8, 8, 8, 8, 8, 8, 8, 8, 8, 8, 8, 8, 8, 8,
|
|
sl@0
|
193 |
8, 8, 8, 8, 8, 8, 8, 8, 8, 8, 8, 8, 8, 8, 8, 8, /* 129..256 */
|
|
sl@0
|
194 |
};
|
|
sl@0
|
195 |
|
|
sl@0
|
196 |
assert(n<=(1<<16) && n>0);
|
|
sl@0
|
197 |
if( n<=256 ) return LogTable256[n-1];
|
|
sl@0
|
198 |
return LogTable256[(n>>8) - ((n&0xFF)?0:1)] + 8;
|
|
sl@0
|
199 |
}
|
|
sl@0
|
200 |
|
|
sl@0
|
201 |
/*
|
|
sl@0
|
202 |
** Allocate and return a block of (pChunk->nAtom << iLogsize) bytes from chunk
|
|
sl@0
|
203 |
** pChunk. If the allocation request cannot be satisfied, return 0.
|
|
sl@0
|
204 |
*/
|
|
sl@0
|
205 |
static void *chunkMalloc(Mem6Chunk *pChunk, int iLogsize){
|
|
sl@0
|
206 |
int i; /* Index of a mem5.aPool[] slot */
|
|
sl@0
|
207 |
int iBin; /* Index into mem5.aiFreelist[] */
|
|
sl@0
|
208 |
|
|
sl@0
|
209 |
/* Make sure mem5.aiFreelist[iLogsize] contains at least one free
|
|
sl@0
|
210 |
** block. If not, then split a block of the next larger power of
|
|
sl@0
|
211 |
** two in order to create a new free block of size iLogsize.
|
|
sl@0
|
212 |
*/
|
|
sl@0
|
213 |
for(iBin=iLogsize; pChunk->aiFreelist[iBin]<0 && iBin<=mem6.nLogThreshold; iBin++){}
|
|
sl@0
|
214 |
if( iBin>mem6.nLogThreshold ) return 0;
|
|
sl@0
|
215 |
i = memsys6UnlinkFirst(pChunk, iBin);
|
|
sl@0
|
216 |
while( iBin>iLogsize ){
|
|
sl@0
|
217 |
int newSize;
|
|
sl@0
|
218 |
iBin--;
|
|
sl@0
|
219 |
newSize = 1 << iBin;
|
|
sl@0
|
220 |
pChunk->aCtrl[i+newSize] = CTRL_FREE | iBin;
|
|
sl@0
|
221 |
memsys6Link(pChunk, i+newSize, iBin);
|
|
sl@0
|
222 |
}
|
|
sl@0
|
223 |
pChunk->aCtrl[i] = iLogsize;
|
|
sl@0
|
224 |
|
|
sl@0
|
225 |
/* Return a pointer to the allocated memory. */
|
|
sl@0
|
226 |
pChunk->nCheckedOut++;
|
|
sl@0
|
227 |
return (void*)&pChunk->zPool[i*pChunk->nAtom];
|
|
sl@0
|
228 |
}
|
|
sl@0
|
229 |
|
|
sl@0
|
230 |
/*
|
|
sl@0
|
231 |
** Free the allocation pointed to by p, which is guaranteed to be non-zero
|
|
sl@0
|
232 |
** and a part of chunk object pChunk.
|
|
sl@0
|
233 |
*/
|
|
sl@0
|
234 |
static void chunkFree(Mem6Chunk *pChunk, void *pOld){
|
|
sl@0
|
235 |
u32 size, iLogsize;
|
|
sl@0
|
236 |
int iBlock;
|
|
sl@0
|
237 |
|
|
sl@0
|
238 |
/* Set iBlock to the index of the block pointed to by pOld in
|
|
sl@0
|
239 |
** the array of pChunk->nAtom byte blocks pointed to by pChunk->zPool.
|
|
sl@0
|
240 |
*/
|
|
sl@0
|
241 |
iBlock = ((u8 *)pOld-pChunk->zPool)/pChunk->nAtom;
|
|
sl@0
|
242 |
|
|
sl@0
|
243 |
/* Check that the pointer pOld points to a valid, non-free block. */
|
|
sl@0
|
244 |
assert( iBlock>=0 && iBlock<pChunk->nBlock );
|
|
sl@0
|
245 |
assert( ((u8 *)pOld-pChunk->zPool)%pChunk->nAtom==0 );
|
|
sl@0
|
246 |
assert( (pChunk->aCtrl[iBlock] & CTRL_FREE)==0 );
|
|
sl@0
|
247 |
|
|
sl@0
|
248 |
iLogsize = pChunk->aCtrl[iBlock] & CTRL_LOGSIZE;
|
|
sl@0
|
249 |
size = 1<<iLogsize;
|
|
sl@0
|
250 |
assert( iBlock+size-1<pChunk->nBlock );
|
|
sl@0
|
251 |
|
|
sl@0
|
252 |
pChunk->aCtrl[iBlock] |= CTRL_FREE;
|
|
sl@0
|
253 |
pChunk->aCtrl[iBlock+size-1] |= CTRL_FREE;
|
|
sl@0
|
254 |
|
|
sl@0
|
255 |
pChunk->aCtrl[iBlock] = CTRL_FREE | iLogsize;
|
|
sl@0
|
256 |
while( iLogsize<mem6.nLogThreshold ){
|
|
sl@0
|
257 |
int iBuddy;
|
|
sl@0
|
258 |
if( (iBlock>>iLogsize) & 1 ){
|
|
sl@0
|
259 |
iBuddy = iBlock - size;
|
|
sl@0
|
260 |
}else{
|
|
sl@0
|
261 |
iBuddy = iBlock + size;
|
|
sl@0
|
262 |
}
|
|
sl@0
|
263 |
assert( iBuddy>=0 );
|
|
sl@0
|
264 |
if( (iBuddy+(1<<iLogsize))>pChunk->nBlock ) break;
|
|
sl@0
|
265 |
if( pChunk->aCtrl[iBuddy]!=(CTRL_FREE | iLogsize) ) break;
|
|
sl@0
|
266 |
memsys6Unlink(pChunk, iBuddy, iLogsize);
|
|
sl@0
|
267 |
iLogsize++;
|
|
sl@0
|
268 |
if( iBuddy<iBlock ){
|
|
sl@0
|
269 |
pChunk->aCtrl[iBuddy] = CTRL_FREE | iLogsize;
|
|
sl@0
|
270 |
pChunk->aCtrl[iBlock] = 0;
|
|
sl@0
|
271 |
iBlock = iBuddy;
|
|
sl@0
|
272 |
}else{
|
|
sl@0
|
273 |
pChunk->aCtrl[iBlock] = CTRL_FREE | iLogsize;
|
|
sl@0
|
274 |
pChunk->aCtrl[iBuddy] = 0;
|
|
sl@0
|
275 |
}
|
|
sl@0
|
276 |
size *= 2;
|
|
sl@0
|
277 |
}
|
|
sl@0
|
278 |
pChunk->nCheckedOut--;
|
|
sl@0
|
279 |
memsys6Link(pChunk, iBlock, iLogsize);
|
|
sl@0
|
280 |
}
|
|
sl@0
|
281 |
|
|
sl@0
|
282 |
/*
|
|
sl@0
|
283 |
** Return the actual size of the block pointed to by p, which is guaranteed
|
|
sl@0
|
284 |
** to have been allocated from chunk pChunk.
|
|
sl@0
|
285 |
*/
|
|
sl@0
|
286 |
static int chunkSize(Mem6Chunk *pChunk, void *p){
|
|
sl@0
|
287 |
int iSize = 0;
|
|
sl@0
|
288 |
if( p ){
|
|
sl@0
|
289 |
int i = ((u8 *)p-pChunk->zPool)/pChunk->nAtom;
|
|
sl@0
|
290 |
assert( i>=0 && i<pChunk->nBlock );
|
|
sl@0
|
291 |
iSize = pChunk->nAtom * (1 << (pChunk->aCtrl[i]&CTRL_LOGSIZE));
|
|
sl@0
|
292 |
}
|
|
sl@0
|
293 |
return iSize;
|
|
sl@0
|
294 |
}
|
|
sl@0
|
295 |
|
|
sl@0
|
296 |
/*
|
|
sl@0
|
297 |
** Return true if there are currently no outstanding allocations.
|
|
sl@0
|
298 |
*/
|
|
sl@0
|
299 |
static int chunkIsEmpty(Mem6Chunk *pChunk){
|
|
sl@0
|
300 |
return (pChunk->nCheckedOut==0);
|
|
sl@0
|
301 |
}
|
|
sl@0
|
302 |
|
|
sl@0
|
303 |
/*
|
|
sl@0
|
304 |
** Initialize the buffer zChunk, which is nChunk bytes in size, as
|
|
sl@0
|
305 |
** an Mem6Chunk object. Return a copy of the zChunk pointer.
|
|
sl@0
|
306 |
*/
|
|
sl@0
|
307 |
static Mem6Chunk *chunkInit(u8 *zChunk, int nChunk, int nMinAlloc){
|
|
sl@0
|
308 |
int ii;
|
|
sl@0
|
309 |
int iOffset;
|
|
sl@0
|
310 |
Mem6Chunk *pChunk = (Mem6Chunk *)zChunk;
|
|
sl@0
|
311 |
|
|
sl@0
|
312 |
assert( nChunk>sizeof(Mem6Chunk) );
|
|
sl@0
|
313 |
assert( nMinAlloc>sizeof(Mem6Link) );
|
|
sl@0
|
314 |
|
|
sl@0
|
315 |
memset(pChunk, 0, sizeof(Mem6Chunk));
|
|
sl@0
|
316 |
pChunk->nAtom = nMinAlloc;
|
|
sl@0
|
317 |
pChunk->nBlock = ((nChunk-sizeof(Mem6Chunk)) / (pChunk->nAtom+sizeof(u8)));
|
|
sl@0
|
318 |
|
|
sl@0
|
319 |
pChunk->zPool = (u8 *)&pChunk[1];
|
|
sl@0
|
320 |
pChunk->aCtrl = &pChunk->zPool[pChunk->nBlock*pChunk->nAtom];
|
|
sl@0
|
321 |
|
|
sl@0
|
322 |
for(ii=0; ii<=mem6.nLogThreshold; ii++){
|
|
sl@0
|
323 |
pChunk->aiFreelist[ii] = -1;
|
|
sl@0
|
324 |
}
|
|
sl@0
|
325 |
|
|
sl@0
|
326 |
iOffset = 0;
|
|
sl@0
|
327 |
for(ii=mem6.nLogThreshold; ii>=0; ii--){
|
|
sl@0
|
328 |
int nAlloc = (1<<ii);
|
|
sl@0
|
329 |
while( (iOffset+nAlloc)<=pChunk->nBlock ){
|
|
sl@0
|
330 |
pChunk->aCtrl[iOffset] = ii | CTRL_FREE;
|
|
sl@0
|
331 |
memsys6Link(pChunk, iOffset, ii);
|
|
sl@0
|
332 |
iOffset += nAlloc;
|
|
sl@0
|
333 |
}
|
|
sl@0
|
334 |
}
|
|
sl@0
|
335 |
|
|
sl@0
|
336 |
return pChunk;
|
|
sl@0
|
337 |
}
|
|
sl@0
|
338 |
|
|
sl@0
|
339 |
|
|
sl@0
|
340 |
static void mem6Enter(void){
|
|
sl@0
|
341 |
sqlite3_mutex_enter(mem6.mutex);
|
|
sl@0
|
342 |
}
|
|
sl@0
|
343 |
|
|
sl@0
|
344 |
static void mem6Leave(void){
|
|
sl@0
|
345 |
sqlite3_mutex_leave(mem6.mutex);
|
|
sl@0
|
346 |
}
|
|
sl@0
|
347 |
|
|
sl@0
|
348 |
/*
|
|
sl@0
|
349 |
** Based on the number and size of the currently allocated chunks, return
|
|
sl@0
|
350 |
** the size of the next chunk to allocate, in bytes.
|
|
sl@0
|
351 |
*/
|
|
sl@0
|
352 |
static int nextChunkSize(void){
|
|
sl@0
|
353 |
int iTotal = MIN_CHUNKSIZE;
|
|
sl@0
|
354 |
Mem6Chunk *p;
|
|
sl@0
|
355 |
for(p=mem6.pChunk; p; p=p->pNext){
|
|
sl@0
|
356 |
iTotal = iTotal*2;
|
|
sl@0
|
357 |
}
|
|
sl@0
|
358 |
return iTotal;
|
|
sl@0
|
359 |
}
|
|
sl@0
|
360 |
|
|
sl@0
|
361 |
static void freeChunk(Mem6Chunk *pChunk){
|
|
sl@0
|
362 |
Mem6Chunk **pp = &mem6.pChunk;
|
|
sl@0
|
363 |
for( pp=&mem6.pChunk; *pp!=pChunk; pp = &(*pp)->pNext );
|
|
sl@0
|
364 |
*pp = (*pp)->pNext;
|
|
sl@0
|
365 |
free(pChunk);
|
|
sl@0
|
366 |
}
|
|
sl@0
|
367 |
|
|
sl@0
|
368 |
static void *memsys6Malloc(int nByte){
|
|
sl@0
|
369 |
Mem6Chunk *pChunk;
|
|
sl@0
|
370 |
void *p = 0;
|
|
sl@0
|
371 |
int nTotal = nByte+8;
|
|
sl@0
|
372 |
int iOffset = 0;
|
|
sl@0
|
373 |
|
|
sl@0
|
374 |
if( nTotal>mem6.nThreshold ){
|
|
sl@0
|
375 |
p = malloc(nTotal);
|
|
sl@0
|
376 |
}else{
|
|
sl@0
|
377 |
int iLogsize = 0;
|
|
sl@0
|
378 |
if( nTotal>(1<<LOG2_MINALLOC) ){
|
|
sl@0
|
379 |
iLogsize = roundupLog2(nTotal) - LOG2_MINALLOC;
|
|
sl@0
|
380 |
}
|
|
sl@0
|
381 |
mem6Enter();
|
|
sl@0
|
382 |
for(pChunk=mem6.pChunk; pChunk; pChunk=pChunk->pNext){
|
|
sl@0
|
383 |
p = chunkMalloc(pChunk, iLogsize);
|
|
sl@0
|
384 |
if( p ){
|
|
sl@0
|
385 |
break;
|
|
sl@0
|
386 |
}
|
|
sl@0
|
387 |
}
|
|
sl@0
|
388 |
if( !p ){
|
|
sl@0
|
389 |
int iSize = nextChunkSize();
|
|
sl@0
|
390 |
p = malloc(iSize);
|
|
sl@0
|
391 |
if( p ){
|
|
sl@0
|
392 |
pChunk = chunkInit((u8 *)p, iSize, mem6.nMinAlloc);
|
|
sl@0
|
393 |
pChunk->pNext = mem6.pChunk;
|
|
sl@0
|
394 |
mem6.pChunk = pChunk;
|
|
sl@0
|
395 |
p = chunkMalloc(pChunk, iLogsize);
|
|
sl@0
|
396 |
assert(p);
|
|
sl@0
|
397 |
}
|
|
sl@0
|
398 |
}
|
|
sl@0
|
399 |
iOffset = ((u8*)p - (u8*)pChunk);
|
|
sl@0
|
400 |
mem6Leave();
|
|
sl@0
|
401 |
}
|
|
sl@0
|
402 |
|
|
sl@0
|
403 |
if( !p ){
|
|
sl@0
|
404 |
return 0;
|
|
sl@0
|
405 |
}
|
|
sl@0
|
406 |
((u32 *)p)[0] = iOffset;
|
|
sl@0
|
407 |
((u32 *)p)[1] = nByte;
|
|
sl@0
|
408 |
return &((u32 *)p)[2];
|
|
sl@0
|
409 |
}
|
|
sl@0
|
410 |
|
|
sl@0
|
411 |
static int memsys6Size(void *pPrior){
|
|
sl@0
|
412 |
if( pPrior==0 ) return 0;
|
|
sl@0
|
413 |
return ((u32*)pPrior)[-1];
|
|
sl@0
|
414 |
}
|
|
sl@0
|
415 |
|
|
sl@0
|
416 |
static void memsys6Free(void *pPrior){
|
|
sl@0
|
417 |
int iSlot;
|
|
sl@0
|
418 |
void *p = &((u32 *)pPrior)[-2];
|
|
sl@0
|
419 |
iSlot = ((u32 *)p)[0];
|
|
sl@0
|
420 |
if( iSlot ){
|
|
sl@0
|
421 |
Mem6Chunk *pChunk;
|
|
sl@0
|
422 |
mem6Enter();
|
|
sl@0
|
423 |
pChunk = (Mem6Chunk *)(&((u8 *)p)[-1 * iSlot]);
|
|
sl@0
|
424 |
chunkFree(pChunk, p);
|
|
sl@0
|
425 |
if( chunkIsEmpty(pChunk) ){
|
|
sl@0
|
426 |
freeChunk(pChunk);
|
|
sl@0
|
427 |
}
|
|
sl@0
|
428 |
mem6Leave();
|
|
sl@0
|
429 |
}else{
|
|
sl@0
|
430 |
free(p);
|
|
sl@0
|
431 |
}
|
|
sl@0
|
432 |
}
|
|
sl@0
|
433 |
|
|
sl@0
|
434 |
static void *memsys6Realloc(void *p, int nByte){
|
|
sl@0
|
435 |
void *p2;
|
|
sl@0
|
436 |
|
|
sl@0
|
437 |
if( p && nByte<=memsys6Size(p) ){
|
|
sl@0
|
438 |
p2 = p;
|
|
sl@0
|
439 |
}else{
|
|
sl@0
|
440 |
p2 = memsys6Malloc(nByte);
|
|
sl@0
|
441 |
if( p && p2 ){
|
|
sl@0
|
442 |
memcpy(p2, p, memsys6Size(p));
|
|
sl@0
|
443 |
memsys6Free(p);
|
|
sl@0
|
444 |
}
|
|
sl@0
|
445 |
}
|
|
sl@0
|
446 |
|
|
sl@0
|
447 |
return p2;
|
|
sl@0
|
448 |
}
|
|
sl@0
|
449 |
|
|
sl@0
|
450 |
static int memsys6Roundup(int n){
|
|
sl@0
|
451 |
if( n>mem6.nThreshold ){
|
|
sl@0
|
452 |
return n;
|
|
sl@0
|
453 |
}else{
|
|
sl@0
|
454 |
return (1<<roundupLog2(n));
|
|
sl@0
|
455 |
}
|
|
sl@0
|
456 |
}
|
|
sl@0
|
457 |
|
|
sl@0
|
458 |
static int memsys6Init(void *pCtx){
|
|
sl@0
|
459 |
u8 bMemstat = sqlite3Config.bMemstat;
|
|
sl@0
|
460 |
mem6.nMinAlloc = (1 << LOG2_MINALLOC);
|
|
sl@0
|
461 |
mem6.pChunk = 0;
|
|
sl@0
|
462 |
mem6.nThreshold = sqlite3Config.nSmall;
|
|
sl@0
|
463 |
if( mem6.nThreshold<=0 ){
|
|
sl@0
|
464 |
mem6.nThreshold = SMALL_MALLOC_DEFAULT_THRESHOLD;
|
|
sl@0
|
465 |
}
|
|
sl@0
|
466 |
mem6.nLogThreshold = roundupLog2(mem6.nThreshold) - LOG2_MINALLOC;
|
|
sl@0
|
467 |
if( !bMemstat ){
|
|
sl@0
|
468 |
mem6.mutex = sqlite3MutexAlloc(SQLITE_MUTEX_STATIC_MEM);
|
|
sl@0
|
469 |
}
|
|
sl@0
|
470 |
return SQLITE_OK;
|
|
sl@0
|
471 |
}
|
|
sl@0
|
472 |
|
|
sl@0
|
473 |
static void memsys6Shutdown(void *pCtx){
|
|
sl@0
|
474 |
memset(&mem6, 0, sizeof(mem6));
|
|
sl@0
|
475 |
}
|
|
sl@0
|
476 |
|
|
sl@0
|
477 |
/*
|
|
sl@0
|
478 |
** This routine is the only routine in this file with external
|
|
sl@0
|
479 |
** linkage. It returns a pointer to a static sqlite3_mem_methods
|
|
sl@0
|
480 |
** struct populated with the memsys6 methods.
|
|
sl@0
|
481 |
*/
|
|
sl@0
|
482 |
const sqlite3_mem_methods *sqlite3MemGetMemsys6(void){
|
|
sl@0
|
483 |
static const sqlite3_mem_methods memsys6Methods = {
|
|
sl@0
|
484 |
memsys6Malloc,
|
|
sl@0
|
485 |
memsys6Free,
|
|
sl@0
|
486 |
memsys6Realloc,
|
|
sl@0
|
487 |
memsys6Size,
|
|
sl@0
|
488 |
memsys6Roundup,
|
|
sl@0
|
489 |
memsys6Init,
|
|
sl@0
|
490 |
memsys6Shutdown,
|
|
sl@0
|
491 |
0
|
|
sl@0
|
492 |
};
|
|
sl@0
|
493 |
return &memsys6Methods;
|
|
sl@0
|
494 |
}
|
|
sl@0
|
495 |
|
|
sl@0
|
496 |
#endif
|