0000: 2f 2a 0a 2a 2a 20 32 30 30 38 20 4e 6f 76 65 6d /*.** 2008 Novem
0010: 62 65 72 20 30 35 0a 2a 2a 0a 2a 2a 20 54 68 65 ber 05.**.** The
0020: 20 61 75 74 68 6f 72 20 64 69 73 63 6c 61 69 6d author disclaim
0030: 73 20 63 6f 70 79 72 69 67 68 74 20 74 6f 20 74 s copyright to t
0040: 68 69 73 20 73 6f 75 72 63 65 20 63 6f 64 65 2e his source code.
0050: 20 20 49 6e 20 70 6c 61 63 65 20 6f 66 0a 2a 2a In place of.**
0060: 20 61 20 6c 65 67 61 6c 20 6e 6f 74 69 63 65 2c a legal notice,
0070: 20 68 65 72 65 20 69 73 20 61 20 62 6c 65 73 73 here is a bless
0080: 69 6e 67 3a 0a 2a 2a 0a 2a 2a 20 20 20 20 4d 61 ing:.**.** Ma
0090: 79 20 79 6f 75 20 64 6f 20 67 6f 6f 64 20 61 6e y you do good an
00a0: 64 20 6e 6f 74 20 65 76 69 6c 2e 0a 2a 2a 20 20 d not evil..**
00b0: 20 20 4d 61 79 20 79 6f 75 20 66 69 6e 64 20 66 May you find f
00c0: 6f 72 67 69 76 65 6e 65 73 73 20 66 6f 72 20 79 orgiveness for y
00d0: 6f 75 72 73 65 6c 66 20 61 6e 64 20 66 6f 72 67 ourself and forg
00e0: 69 76 65 20 6f 74 68 65 72 73 2e 0a 2a 2a 20 20 ive others..**
00f0: 20 20 4d 61 79 20 79 6f 75 20 73 68 61 72 65 20 May you share
0100: 66 72 65 65 6c 79 2c 20 6e 65 76 65 72 20 74 61 freely, never ta
0110: 6b 69 6e 67 20 6d 6f 72 65 20 74 68 61 6e 20 79 king more than y
0120: 6f 75 20 67 69 76 65 2e 0a 2a 2a 0a 2a 2a 2a 2a ou give..**.****
0130: 2a 2a 2a 2a 2a 2a 2a 2a 2a 2a 2a 2a 2a 2a 2a 2a ****************
0140: 2a 2a 2a 2a 2a 2a 2a 2a 2a 2a 2a 2a 2a 2a 2a 2a ****************
0150: 2a 2a 2a 2a 2a 2a 2a 2a 2a 2a 2a 2a 2a 2a 2a 2a ****************
0160: 2a 2a 2a 2a 2a 2a 2a 2a 2a 2a 2a 2a 2a 2a 2a 2a ****************
0170: 2a 2a 2a 2a 2a 0a 2a 2a 0a 2a 2a 20 54 68 69 73 *****.**.** This
0180: 20 66 69 6c 65 20 69 6d 70 6c 65 6d 65 6e 74 73 file implements
0190: 20 74 68 65 20 64 65 66 61 75 6c 74 20 70 61 67 the default pag
01a0: 65 20 63 61 63 68 65 20 69 6d 70 6c 65 6d 65 6e e cache implemen
01b0: 74 61 74 69 6f 6e 20 28 74 68 65 0a 2a 2a 20 73 tation (the.** s
01c0: 71 6c 69 74 65 33 5f 70 63 61 63 68 65 20 69 6e qlite3_pcache in
01d0: 74 65 72 66 61 63 65 29 2e 20 49 74 20 61 6c 73 terface). It als
01e0: 6f 20 63 6f 6e 74 61 69 6e 73 20 70 61 72 74 20 o contains part
01f0: 6f 66 20 74 68 65 20 69 6d 70 6c 65 6d 65 6e 74 of the implement
0200: 61 74 69 6f 6e 0a 2a 2a 20 6f 66 20 74 68 65 20 ation.** of the
0210: 53 51 4c 49 54 45 5f 43 4f 4e 46 49 47 5f 50 41 SQLITE_CONFIG_PA
0220: 47 45 43 41 43 48 45 20 61 6e 64 20 73 71 6c 69 GECACHE and sqli
0230: 74 65 33 5f 72 65 6c 65 61 73 65 5f 6d 65 6d 6f te3_release_memo
0240: 72 79 28 29 20 66 65 61 74 75 72 65 73 2e 0a 2a ry() features..*
0250: 2a 20 49 66 20 74 68 65 20 64 65 66 61 75 6c 74 * If the default
0260: 20 70 61 67 65 20 63 61 63 68 65 20 69 6d 70 6c page cache impl
0270: 65 6d 65 6e 74 61 74 69 6f 6e 20 69 73 20 6f 76 ementation is ov
0280: 65 72 72 69 64 65 6e 2c 20 74 68 65 6e 20 6e 65 erriden, then ne
0290: 69 74 68 65 72 20 6f 66 0a 2a 2a 20 74 68 65 73 ither of.** thes
02a0: 65 20 74 77 6f 20 66 65 61 74 75 72 65 73 20 61 e two features a
02b0: 72 65 20 61 76 61 69 6c 61 62 6c 65 2e 0a 2a 2a re available..**
02c0: 0a 2a 2a 20 40 28 23 29 20 24 49 64 3a 20 70 63 .** @(#) $Id: pc
02d0: 61 63 68 65 31 2e 63 2c 76 20 31 2e 39 20 32 30 ache1.c,v 1.9 20
02e0: 30 39 2f 30 33 2f 30 35 20 31 34 3a 35 39 3a 34 09/03/05 14:59:4
02f0: 30 20 64 61 6e 69 65 6c 6b 31 39 37 37 20 45 78 0 danielk1977 Ex
0300: 70 20 24 0a 2a 2f 0a 0a 23 69 6e 63 6c 75 64 65 p $.*/..#include
0310: 20 22 73 71 6c 69 74 65 49 6e 74 2e 68 22 0a 0a "sqliteInt.h"..
0320: 74 79 70 65 64 65 66 20 73 74 72 75 63 74 20 50 typedef struct P
0330: 43 61 63 68 65 31 20 50 43 61 63 68 65 31 3b 0a Cache1 PCache1;.
0340: 74 79 70 65 64 65 66 20 73 74 72 75 63 74 20 50 typedef struct P
0350: 67 48 64 72 31 20 50 67 48 64 72 31 3b 0a 74 79 gHdr1 PgHdr1;.ty
0360: 70 65 64 65 66 20 73 74 72 75 63 74 20 50 67 46 pedef struct PgF
0370: 72 65 65 73 6c 6f 74 20 50 67 46 72 65 65 73 6c reeslot PgFreesl
0380: 6f 74 3b 0a 0a 2f 2a 20 50 6f 69 6e 74 65 72 73 ot;../* Pointers
0390: 20 74 6f 20 73 74 72 75 63 74 75 72 65 73 20 6f to structures o
03a0: 66 20 74 68 69 73 20 74 79 70 65 20 61 72 65 20 f this type are
03b0: 63 61 73 74 20 61 6e 64 20 72 65 74 75 72 6e 65 cast and returne
03c0: 64 20 61 73 20 0a 2a 2a 20 6f 70 61 71 75 65 20 d as .** opaque
03d0: 73 71 6c 69 74 65 33 5f 70 63 61 63 68 65 2a 20 sqlite3_pcache*
03e0: 68 61 6e 64 6c 65 73 0a 2a 2f 0a 73 74 72 75 63 handles.*/.struc
03f0: 74 20 50 43 61 63 68 65 31 20 7b 0a 20 20 2f 2a t PCache1 {. /*
0400: 20 43 61 63 68 65 20 63 6f 6e 66 69 67 75 72 61 Cache configura
0410: 74 69 6f 6e 20 70 61 72 61 6d 65 74 65 72 73 2e tion parameters.
0420: 20 50 61 67 65 20 73 69 7a 65 20 28 73 7a 50 61 Page size (szPa
0430: 67 65 29 20 61 6e 64 20 74 68 65 20 70 75 72 67 ge) and the purg
0440: 65 61 62 6c 65 0a 20 20 2a 2a 20 66 6c 61 67 20 eable. ** flag
0450: 28 62 50 75 72 67 65 61 62 6c 65 29 20 61 72 65 (bPurgeable) are
0460: 20 73 65 74 20 77 68 65 6e 20 74 68 65 20 63 61 set when the ca
0470: 63 68 65 20 69 73 20 63 72 65 61 74 65 64 2e 20 che is created.
0480: 6e 4d 61 78 20 6d 61 79 20 62 65 20 0a 20 20 2a nMax may be . *
0490: 2a 20 6d 6f 64 69 66 69 65 64 20 61 74 20 61 6e * modified at an
04a0: 79 20 74 69 6d 65 20 62 79 20 61 20 63 61 6c 6c y time by a call
04b0: 20 74 6f 20 74 68 65 20 70 63 61 63 68 65 31 43 to the pcache1C
04c0: 61 63 68 65 53 69 7a 65 28 29 20 6d 65 74 68 6f acheSize() metho
04d0: 64 2e 0a 20 20 2a 2a 20 54 68 65 20 67 6c 6f 62 d.. ** The glob
04e0: 61 6c 20 6d 75 74 65 78 20 6d 75 73 74 20 62 65 al mutex must be
04f0: 20 68 65 6c 64 20 77 68 65 6e 20 61 63 63 65 73 held when acces
0500: 73 69 6e 67 20 6e 4d 61 78 2e 0a 20 20 2a 2f 0a sing nMax.. */.
0510: 20 20 69 6e 74 20 73 7a 50 61 67 65 3b 20 20 20 int szPage;
0520: 20 20 20 20 20 20 20 20 20 20 20 20 20 20 20 20
0530: 20 20 20 20 20 20 2f 2a 20 53 69 7a 65 20 6f 66 /* Size of
0540: 20 61 6c 6c 6f 63 61 74 65 64 20 70 61 67 65 73 allocated pages
0550: 20 69 6e 20 62 79 74 65 73 20 2a 2f 0a 20 20 69 in bytes */. i
0560: 6e 74 20 62 50 75 72 67 65 61 62 6c 65 3b 20 20 nt bPurgeable;
0570: 20 20 20 20 20 20 20 20 20 20 20 20 20 20 20 20
0580: 20 20 20 2f 2a 20 54 72 75 65 20 69 66 20 63 61 /* True if ca
0590: 63 68 65 20 69 73 20 70 75 72 67 65 61 62 6c 65 che is purgeable
05a0: 20 2a 2f 0a 20 20 75 6e 73 69 67 6e 65 64 20 69 */. unsigned i
05b0: 6e 74 20 6e 4d 69 6e 3b 20 20 20 20 20 20 20 20 nt nMin;
05c0: 20 20 20 20 20 20 20 20 20 20 2f 2a 20 4d 69 6e /* Min
05d0: 69 6d 75 6d 20 6e 75 6d 62 65 72 20 6f 66 20 70 imum number of p
05e0: 61 67 65 73 20 72 65 73 65 72 76 65 64 20 2a 2f ages reserved */
05f0: 0a 20 20 75 6e 73 69 67 6e 65 64 20 69 6e 74 20 . unsigned int
0600: 6e 4d 61 78 3b 20 20 20 20 20 20 20 20 20 20 20 nMax;
0610: 20 20 20 20 20 20 20 2f 2a 20 43 6f 6e 66 69 67 /* Config
0620: 75 72 65 64 20 22 63 61 63 68 65 5f 73 69 7a 65 ured "cache_size
0630: 22 20 76 61 6c 75 65 20 2a 2f 0a 0a 20 20 2f 2a " value */.. /*
0640: 20 48 61 73 68 20 74 61 62 6c 65 20 6f 66 20 61 Hash table of a
0650: 6c 6c 20 70 61 67 65 73 2e 20 54 68 65 20 66 6f ll pages. The fo
0660: 6c 6c 6f 77 69 6e 67 20 76 61 72 69 61 62 6c 65 llowing variable
0670: 73 20 6d 61 79 20 6f 6e 6c 79 20 62 65 20 61 63 s may only be ac
0680: 63 65 73 73 65 64 0a 20 20 2a 2a 20 77 68 65 6e cessed. ** when
0690: 20 74 68 65 20 61 63 63 65 73 73 6f 72 20 69 73 the accessor is
06a0: 20 68 6f 6c 64 69 6e 67 20 74 68 65 20 67 6c 6f holding the glo
06b0: 62 61 6c 20 6d 75 74 65 78 20 28 73 65 65 20 70 bal mutex (see p
06c0: 63 61 63 68 65 31 45 6e 74 65 72 4d 75 74 65 78 cache1EnterMutex
06d0: 28 29 20 0a 20 20 2a 2a 20 61 6e 64 20 70 63 61 () . ** and pca
06e0: 63 68 65 31 4c 65 61 76 65 4d 75 74 65 78 28 29 che1LeaveMutex()
06f0: 29 2e 0a 20 20 2a 2f 0a 20 20 75 6e 73 69 67 6e ).. */. unsign
0700: 65 64 20 69 6e 74 20 6e 52 65 63 79 63 6c 61 62 ed int nRecyclab
0710: 6c 65 3b 20 20 20 20 20 20 20 20 20 20 20 2f 2a le; /*
0720: 20 4e 75 6d 62 65 72 20 6f 66 20 70 61 67 65 73 Number of pages
0730: 20 69 6e 20 74 68 65 20 4c 52 55 20 6c 69 73 74 in the LRU list
0740: 20 2a 2f 0a 20 20 75 6e 73 69 67 6e 65 64 20 69 */. unsigned i
0750: 6e 74 20 6e 50 61 67 65 3b 20 20 20 20 20 20 20 nt nPage;
0760: 20 20 20 20 20 20 20 20 20 20 2f 2a 20 54 6f 74 /* Tot
0770: 61 6c 20 6e 75 6d 62 65 72 20 6f 66 20 70 61 67 al number of pag
0780: 65 73 20 69 6e 20 61 70 48 61 73 68 20 2a 2f 0a es in apHash */.
0790: 20 20 75 6e 73 69 67 6e 65 64 20 69 6e 74 20 6e unsigned int n
07a0: 48 61 73 68 3b 20 20 20 20 20 20 20 20 20 20 20 Hash;
07b0: 20 20 20 20 20 20 2f 2a 20 4e 75 6d 62 65 72 20 /* Number
07c0: 6f 66 20 73 6c 6f 74 73 20 69 6e 20 61 70 48 61 of slots in apHa
07d0: 73 68 5b 5d 20 2a 2f 0a 20 20 50 67 48 64 72 31 sh[] */. PgHdr1
07e0: 20 2a 2a 61 70 48 61 73 68 3b 20 20 20 20 20 20 **apHash;
07f0: 20 20 20 20 20 20 20 20 20 20 20 20 20 20 2f 2a /*
0800: 20 48 61 73 68 20 74 61 62 6c 65 20 66 6f 72 20 Hash table for
0810: 66 61 73 74 20 6c 6f 6f 6b 75 70 20 62 79 20 6b fast lookup by k
0820: 65 79 20 2a 2f 0a 0a 20 20 75 6e 73 69 67 6e 65 ey */.. unsigne
0830: 64 20 69 6e 74 20 69 4d 61 78 4b 65 79 3b 20 20 d int iMaxKey;
0840: 20 20 20 20 20 20 20 20 20 20 20 20 20 2f 2a 20 /*
0850: 4c 61 72 67 65 73 74 20 6b 65 79 20 73 65 65 6e Largest key seen
0860: 20 73 69 6e 63 65 20 78 54 72 75 6e 63 61 74 65 since xTruncate
0870: 28 29 20 2a 2f 0a 7d 3b 0a 0a 2f 2a 0a 2a 2a 20 () */.};../*.**
0880: 45 61 63 68 20 63 61 63 68 65 20 65 6e 74 72 79 Each cache entry
0890: 20 69 73 20 72 65 70 72 65 73 65 6e 74 65 64 20 is represented
08a0: 62 79 20 61 6e 20 69 6e 73 74 61 6e 63 65 20 6f by an instance o
08b0: 66 20 74 68 65 20 66 6f 6c 6c 6f 77 69 6e 67 20 f the following
08c0: 0a 2a 2a 20 73 74 72 75 63 74 75 72 65 2e 20 41 .** structure. A
08d0: 20 62 75 66 66 65 72 20 6f 66 20 50 67 48 64 72 buffer of PgHdr
08e0: 31 2e 70 43 61 63 68 65 2d 3e 73 7a 50 61 67 65 1.pCache->szPage
08f0: 20 62 79 74 65 73 20 69 73 20 61 6c 6c 6f 63 61 bytes is alloca
0900: 74 65 64 20 0a 2a 2a 20 64 69 72 65 63 74 6c 79 ted .** directly
0910: 20 61 66 74 65 72 20 74 68 65 20 73 74 72 75 63 after the struc
0920: 74 75 72 65 20 69 6e 20 6d 65 6d 6f 72 79 20 28 ture in memory (
0930: 73 65 65 20 74 68 65 20 50 47 48 44 52 31 5f 54 see the PGHDR1_T
0940: 4f 5f 50 41 47 45 28 29 20 0a 2a 2a 20 6d 61 63 O_PAGE() .** mac
0950: 72 6f 20 62 65 6c 6f 77 29 2e 0a 2a 2f 0a 73 74 ro below)..*/.st
0960: 72 75 63 74 20 50 67 48 64 72 31 20 7b 0a 20 20 ruct PgHdr1 {.
0970: 75 6e 73 69 67 6e 65 64 20 69 6e 74 20 69 4b 65 unsigned int iKe
0980: 79 3b 20 20 20 20 20 20 20 20 20 20 20 20 20 2f y; /
0990: 2a 20 4b 65 79 20 76 61 6c 75 65 20 28 70 61 67 * Key value (pag
09a0: 65 20 6e 75 6d 62 65 72 29 20 2a 2f 0a 20 20 50 e number) */. P
09b0: 67 48 64 72 31 20 2a 70 4e 65 78 74 3b 20 20 20 gHdr1 *pNext;
09c0: 20 20 20 20 20 20 20 20 20 20 20 20 20 20 2f 2a /*
09d0: 20 4e 65 78 74 20 69 6e 20 68 61 73 68 20 74 61 Next in hash ta
09e0: 62 6c 65 20 63 68 61 69 6e 20 2a 2f 0a 20 20 50 ble chain */. P
09f0: 43 61 63 68 65 31 20 2a 70 43 61 63 68 65 3b 20 Cache1 *pCache;
0a00: 20 20 20 20 20 20 20 20 20 20 20 20 20 20 2f 2a /*
0a10: 20 43 61 63 68 65 20 74 68 61 74 20 63 75 72 72 Cache that curr
0a20: 65 6e 74 6c 79 20 6f 77 6e 73 20 74 68 69 73 20 ently owns this
0a30: 70 61 67 65 20 2a 2f 0a 20 20 50 67 48 64 72 31 page */. PgHdr1
0a40: 20 2a 70 4c 72 75 4e 65 78 74 3b 20 20 20 20 20 *pLruNext;
0a50: 20 20 20 20 20 20 20 20 20 2f 2a 20 4e 65 78 74 /* Next
0a60: 20 69 6e 20 4c 52 55 20 6c 69 73 74 20 6f 66 20 in LRU list of
0a70: 75 6e 70 69 6e 6e 65 64 20 70 61 67 65 73 20 2a unpinned pages *
0a80: 2f 0a 20 20 50 67 48 64 72 31 20 2a 70 4c 72 75 /. PgHdr1 *pLru
0a90: 50 72 65 76 3b 20 20 20 20 20 20 20 20 20 20 20 Prev;
0aa0: 20 20 20 2f 2a 20 50 72 65 76 69 6f 75 73 20 69 /* Previous i
0ab0: 6e 20 4c 52 55 20 6c 69 73 74 20 6f 66 20 75 6e n LRU list of un
0ac0: 70 69 6e 6e 65 64 20 70 61 67 65 73 20 2a 2f 0a pinned pages */.
0ad0: 7d 3b 0a 0a 2f 2a 0a 2a 2a 20 46 72 65 65 20 73 };../*.** Free s
0ae0: 6c 6f 74 73 20 69 6e 20 74 68 65 20 61 6c 6c 6f lots in the allo
0af0: 63 61 74 6f 72 20 75 73 65 64 20 74 6f 20 64 69 cator used to di
0b00: 76 69 64 65 20 75 70 20 74 68 65 20 62 75 66 66 vide up the buff
0b10: 65 72 20 70 72 6f 76 69 64 65 64 20 75 73 69 6e er provided usin
0b20: 67 0a 2a 2a 20 74 68 65 20 53 51 4c 49 54 45 5f g.** the SQLITE_
0b30: 43 4f 4e 46 49 47 5f 50 41 47 45 43 41 43 48 45 CONFIG_PAGECACHE
0b40: 20 6d 65 63 68 61 6e 69 73 6d 2e 0a 2a 2f 0a 73 mechanism..*/.s
0b50: 74 72 75 63 74 20 50 67 46 72 65 65 73 6c 6f 74 truct PgFreeslot
0b60: 20 7b 0a 20 20 50 67 46 72 65 65 73 6c 6f 74 20 {. PgFreeslot
0b70: 2a 70 4e 65 78 74 3b 20 20 2f 2a 20 4e 65 78 74 *pNext; /* Next
0b80: 20 66 72 65 65 20 73 6c 6f 74 20 2a 2f 0a 7d 3b free slot */.};
0b90: 0a 0a 2f 2a 0a 2a 2a 20 47 6c 6f 62 61 6c 20 64 ../*.** Global d
0ba0: 61 74 61 20 75 73 65 64 20 62 79 20 74 68 69 73 ata used by this
0bb0: 20 63 61 63 68 65 2e 0a 2a 2f 0a 73 74 61 74 69 cache..*/.stati
0bc0: 63 20 53 51 4c 49 54 45 5f 57 53 44 20 73 74 72 c SQLITE_WSD str
0bd0: 75 63 74 20 50 43 61 63 68 65 47 6c 6f 62 61 6c uct PCacheGlobal
0be0: 20 7b 0a 20 20 73 71 6c 69 74 65 33 5f 6d 75 74 {. sqlite3_mut
0bf0: 65 78 20 2a 6d 75 74 65 78 3b 20 20 20 20 20 20 ex *mutex;
0c00: 20 20 20 20 20 20 20 20 20 2f 2a 20 73 74 61 74 /* stat
0c10: 69 63 20 6d 75 74 65 78 20 4d 55 54 45 58 5f 53 ic mutex MUTEX_S
0c20: 54 41 54 49 43 5f 4c 52 55 20 2a 2f 0a 0a 20 20 TATIC_LRU */..
0c30: 69 6e 74 20 6e 4d 61 78 50 61 67 65 3b 20 20 20 int nMaxPage;
0c40: 20 20 20 20 20 20 20 20 20 20 20 20 20 20 20 20
0c50: 20 20 20 20 2f 2a 20 53 75 6d 20 6f 66 20 6e 4d /* Sum of nM
0c60: 61 78 50 61 67 65 20 66 6f 72 20 70 75 72 67 65 axPage for purge
0c70: 61 62 6c 65 20 63 61 63 68 65 73 20 2a 2f 0a 20 able caches */.
0c80: 20 69 6e 74 20 6e 4d 69 6e 50 61 67 65 3b 20 20 int nMinPage;
0c90: 20 20 20 20 20 20 20 20 20 20 20 20 20 20 20 20
0ca0: 20 20 20 20 20 2f 2a 20 53 75 6d 20 6f 66 20 6e /* Sum of n
0cb0: 4d 69 6e 50 61 67 65 20 66 6f 72 20 70 75 72 67 MinPage for purg
0cc0: 65 61 62 6c 65 20 63 61 63 68 65 73 20 2a 2f 0a eable caches */.
0cd0: 20 20 69 6e 74 20 6e 43 75 72 72 65 6e 74 50 61 int nCurrentPa
0ce0: 67 65 3b 20 20 20 20 20 20 20 20 20 20 20 20 20 ge;
0cf0: 20 20 20 20 20 20 2f 2a 20 4e 75 6d 62 65 72 20 /* Number
0d00: 6f 66 20 70 75 72 67 65 61 62 6c 65 20 70 61 67 of purgeable pag
0d10: 65 73 20 61 6c 6c 6f 63 61 74 65 64 20 2a 2f 0a es allocated */.
0d20: 20 20 50 67 48 64 72 31 20 2a 70 4c 72 75 48 65 PgHdr1 *pLruHe
0d30: 61 64 2c 20 2a 70 4c 72 75 54 61 69 6c 3b 20 20 ad, *pLruTail;
0d40: 20 20 20 20 20 20 2f 2a 20 4c 52 55 20 6c 69 73 /* LRU lis
0d50: 74 20 6f 66 20 75 6e 70 69 6e 6e 65 64 20 70 61 t of unpinned pa
0d60: 67 65 73 20 2a 2f 0a 0a 20 20 2f 2a 20 56 61 72 ges */.. /* Var
0d70: 69 61 62 6c 65 73 20 72 65 6c 61 74 65 64 20 74 iables related t
0d80: 6f 20 53 51 4c 49 54 45 5f 43 4f 4e 46 49 47 5f o SQLITE_CONFIG_
0d90: 50 41 47 45 43 41 43 48 45 20 73 65 74 74 69 6e PAGECACHE settin
0da0: 67 73 2e 20 2a 2f 0a 20 20 69 6e 74 20 73 7a 53 gs. */. int szS
0db0: 6c 6f 74 3b 20 20 20 20 20 20 20 20 20 20 20 20 lot;
0dc0: 20 20 20 20 20 20 20 20 20 20 20 20 20 2f 2a 20 /*
0dd0: 53 69 7a 65 20 6f 66 20 65 61 63 68 20 66 72 65 Size of each fre
0de0: 65 20 73 6c 6f 74 20 2a 2f 0a 20 20 76 6f 69 64 e slot */. void
0df0: 20 2a 70 53 74 61 72 74 2c 20 2a 70 45 6e 64 3b *pStart, *pEnd;
0e00: 20 20 20 20 20 20 20 20 20 20 20 20 20 20 20 20
0e10: 2f 2a 20 42 6f 75 6e 64 73 20 6f 66 20 70 61 67 /* Bounds of pag
0e20: 65 63 61 63 68 65 20 6d 61 6c 6c 6f 63 20 72 61 ecache malloc ra
0e30: 6e 67 65 20 2a 2f 0a 20 20 50 67 46 72 65 65 73 nge */. PgFrees
0e40: 6c 6f 74 20 2a 70 46 72 65 65 3b 20 20 20 20 20 lot *pFree;
0e50: 20 20 20 20 20 20 20 20 20 20 20 20 20 2f 2a 20 /*
0e60: 46 72 65 65 20 70 61 67 65 20 62 6c 6f 63 6b 73 Free page blocks
0e70: 20 2a 2f 0a 7d 20 70 63 61 63 68 65 31 5f 67 3b */.} pcache1_g;
0e80: 0a 0a 2f 2a 0a 2a 2a 20 41 6c 6c 20 63 6f 64 65 ../*.** All code
0e90: 20 69 6e 20 74 68 69 73 20 66 69 6c 65 20 73 68 in this file sh
0ea0: 6f 75 6c 64 20 61 63 63 65 73 73 20 74 68 65 20 ould access the
0eb0: 67 6c 6f 62 61 6c 20 73 74 72 75 63 74 75 72 65 global structure
0ec0: 20 61 62 6f 76 65 20 76 69 61 20 74 68 65 0a 2a above via the.*
0ed0: 2a 20 61 6c 69 61 73 20 22 70 63 61 63 68 65 31 * alias "pcache1
0ee0: 22 2e 20 54 68 69 73 20 65 6e 73 75 72 65 73 20 ". This ensures
0ef0: 74 68 61 74 20 74 68 65 20 57 53 44 20 65 6d 75 that the WSD emu
0f00: 6c 61 74 69 6f 6e 20 69 73 20 75 73 65 64 20 77 lation is used w
0f10: 68 65 6e 0a 2a 2a 20 63 6f 6d 70 69 6c 69 6e 67 hen.** compiling
0f20: 20 66 6f 72 20 73 79 73 74 65 6d 73 20 74 68 61 for systems tha
0f30: 74 20 64 6f 20 6e 6f 74 20 73 75 70 70 6f 72 74 t do not support
0f40: 20 72 65 61 6c 20 57 53 44 2e 0a 2a 2f 0a 23 64 real WSD..*/.#d
0f50: 65 66 69 6e 65 20 70 63 61 63 68 65 31 20 28 47 efine pcache1 (G
0f60: 4c 4f 42 41 4c 28 73 74 72 75 63 74 20 50 43 61 LOBAL(struct PCa
0f70: 63 68 65 47 6c 6f 62 61 6c 2c 20 70 63 61 63 68 cheGlobal, pcach
0f80: 65 31 5f 67 29 29 0a 0a 2f 2a 0a 2a 2a 20 57 68 e1_g))../*.** Wh
0f90: 65 6e 20 61 20 50 67 48 64 72 31 20 73 74 72 75 en a PgHdr1 stru
0fa0: 63 74 75 72 65 20 69 73 20 61 6c 6c 6f 63 61 74 cture is allocat
0fb0: 65 64 2c 20 74 68 65 20 61 73 73 6f 63 69 61 74 ed, the associat
0fc0: 65 64 20 50 43 61 63 68 65 31 2e 73 7a 50 61 67 ed PCache1.szPag
0fd0: 65 0a 2a 2a 20 62 79 74 65 73 20 6f 66 20 64 61 e.** bytes of da
0fe0: 74 61 20 61 72 65 20 6c 6f 63 61 74 65 64 20 64 ta are located d
0ff0: 69 72 65 63 74 6c 79 20 61 66 74 65 72 20 69 74 irectly after it
1000: 20 69 6e 20 6d 65 6d 6f 72 79 20 28 69 2e 65 2e in memory (i.e.
1010: 20 74 68 65 20 74 6f 74 61 6c 0a 2a 2a 20 73 69 the total.** si
1020: 7a 65 20 6f 66 20 74 68 65 20 61 6c 6c 6f 63 61 ze of the alloca
1030: 74 69 6f 6e 20 69 73 20 73 69 7a 65 6f 66 28 50 tion is sizeof(P
1040: 67 48 64 72 31 29 2b 50 43 61 63 68 65 31 2e 73 gHdr1)+PCache1.s
1050: 7a 50 61 67 65 20 62 79 74 65 29 2e 20 54 68 65 zPage byte). The
1060: 0a 2a 2a 20 50 47 48 44 52 31 5f 54 4f 5f 50 41 .** PGHDR1_TO_PA
1070: 47 45 28 29 20 6d 61 63 72 6f 20 74 61 6b 65 73 GE() macro takes
1080: 20 61 20 70 6f 69 6e 74 65 72 20 74 6f 20 61 20 a pointer to a
1090: 50 67 48 64 72 31 20 73 74 72 75 63 74 75 72 65 PgHdr1 structure
10a0: 20 61 73 0a 2a 2a 20 61 6e 20 61 72 67 75 6d 65 as.** an argume
10b0: 6e 74 20 61 6e 64 20 72 65 74 75 72 6e 73 20 61 nt and returns a
10c0: 20 70 6f 69 6e 74 65 72 20 74 6f 20 74 68 65 20 pointer to the
10d0: 61 73 73 6f 63 69 61 74 65 64 20 62 6c 6f 63 6b associated block
10e0: 20 6f 66 20 73 7a 50 61 67 65 0a 2a 2a 20 62 79 of szPage.** by
10f0: 74 65 73 2e 20 54 68 65 20 50 41 47 45 5f 54 4f tes. The PAGE_TO
1100: 5f 50 47 48 44 52 31 28 29 20 6d 61 63 72 6f 20 _PGHDR1() macro
1110: 64 6f 65 73 20 74 68 65 20 6f 70 70 6f 73 69 74 does the opposit
1120: 65 3a 20 69 74 73 20 61 72 67 75 6d 65 6e 74 20 e: its argument
1130: 69 73 0a 2a 2a 20 61 20 70 6f 69 6e 74 65 72 20 is.** a pointer
1140: 74 6f 20 61 20 62 6c 6f 63 6b 20 6f 66 20 73 7a to a block of sz
1150: 50 61 67 65 20 62 79 74 65 73 20 6f 66 20 64 61 Page bytes of da
1160: 74 61 20 61 6e 64 20 74 68 65 20 72 65 74 75 72 ta and the retur
1170: 6e 20 76 61 6c 75 65 20 69 73 0a 2a 2a 20 61 20 n value is.** a
1180: 70 6f 69 6e 74 65 72 20 74 6f 20 74 68 65 20 61 pointer to the a
1190: 73 73 6f 63 69 61 74 65 64 20 50 67 48 64 72 31 ssociated PgHdr1
11a0: 20 73 74 72 75 63 74 75 72 65 2e 0a 2a 2a 0a 2a structure..**.*
11b0: 2a 20 20 20 61 73 73 65 72 74 28 20 50 47 48 44 * assert( PGHD
11c0: 52 31 5f 54 4f 5f 50 41 47 45 28 50 41 47 45 5f R1_TO_PAGE(PAGE_
11d0: 54 4f 5f 50 47 48 44 52 31 28 58 29 29 3d 3d 58 TO_PGHDR1(X))==X
11e0: 20 29 3b 0a 2a 2f 0a 23 64 65 66 69 6e 65 20 50 );.*/.#define P
11f0: 47 48 44 52 31 5f 54 4f 5f 50 41 47 45 28 70 29 GHDR1_TO_PAGE(p)
1200: 20 28 76 6f 69 64 20 2a 29 28 26 28 28 75 6e 73 (void *)(&((uns
1210: 69 67 6e 65 64 20 63 68 61 72 20 2a 29 70 29 5b igned char *)p)[
1220: 73 69 7a 65 6f 66 28 50 67 48 64 72 31 29 5d 29 sizeof(PgHdr1)])
1230: 0a 23 64 65 66 69 6e 65 20 50 41 47 45 5f 54 4f .#define PAGE_TO
1240: 5f 50 47 48 44 52 31 28 70 29 20 28 50 67 48 64 _PGHDR1(p) (PgHd
1250: 72 31 20 2a 29 28 26 28 28 75 6e 73 69 67 6e 65 r1 *)(&((unsigne
1260: 64 20 63 68 61 72 20 2a 29 70 29 5b 2d 31 2a 28 d char *)p)[-1*(
1270: 69 6e 74 29 73 69 7a 65 6f 66 28 50 67 48 64 72 int)sizeof(PgHdr
1280: 31 29 5d 29 0a 0a 2f 2a 0a 2a 2a 20 4d 61 63 72 1)])../*.** Macr
1290: 6f 73 20 74 6f 20 65 6e 74 65 72 20 61 6e 64 20 os to enter and
12a0: 6c 65 61 76 65 20 74 68 65 20 67 6c 6f 62 61 6c leave the global
12b0: 20 4c 52 55 20 6d 75 74 65 78 2e 0a 2a 2f 0a 23 LRU mutex..*/.#
12c0: 64 65 66 69 6e 65 20 70 63 61 63 68 65 31 45 6e define pcache1En
12d0: 74 65 72 4d 75 74 65 78 28 29 20 73 71 6c 69 74 terMutex() sqlit
12e0: 65 33 5f 6d 75 74 65 78 5f 65 6e 74 65 72 28 70 e3_mutex_enter(p
12f0: 63 61 63 68 65 31 2e 6d 75 74 65 78 29 0a 23 64 cache1.mutex).#d
1300: 65 66 69 6e 65 20 70 63 61 63 68 65 31 4c 65 61 efine pcache1Lea
1310: 76 65 4d 75 74 65 78 28 29 20 73 71 6c 69 74 65 veMutex() sqlite
1320: 33 5f 6d 75 74 65 78 5f 6c 65 61 76 65 28 70 63 3_mutex_leave(pc
1330: 61 63 68 65 31 2e 6d 75 74 65 78 29 0a 0a 2f 2a ache1.mutex)../*
1340: 2a 2a 2a 2a 2a 2a 2a 2a 2a 2a 2a 2a 2a 2a 2a 2a ****************
1350: 2a 2a 2a 2a 2a 2a 2a 2a 2a 2a 2a 2a 2a 2a 2a 2a ****************
1360: 2a 2a 2a 2a 2a 2a 2a 2a 2a 2a 2a 2a 2a 2a 2a 2a ****************
1370: 2a 2a 2a 2a 2a 2a 2a 2a 2a 2a 2a 2a 2a 2a 2a 2a ****************
1380: 2a 2a 2a 2a 2a 2a 2a 2a 2a 2a 2a 2a 2a 2f 0a 2f *************/./
1390: 2a 2a 2a 2a 2a 2a 2a 2a 20 50 61 67 65 20 41 6c ******** Page Al
13a0: 6c 6f 63 61 74 69 6f 6e 2f 53 51 4c 49 54 45 5f location/SQLITE_
13b0: 43 4f 4e 46 49 47 5f 50 43 41 43 48 45 20 52 65 CONFIG_PCACHE Re
13c0: 6c 61 74 65 64 20 46 75 6e 63 74 69 6f 6e 73 20 lated Functions
13d0: 2a 2a 2a 2a 2a 2a 2a 2a 2a 2a 2a 2a 2a 2a 2f 0a **************/.
13e0: 0a 2f 2a 0a 2a 2a 20 54 68 69 73 20 66 75 6e 63 ./*.** This func
13f0: 74 69 6f 6e 20 69 73 20 63 61 6c 6c 65 64 20 64 tion is called d
1400: 75 72 69 6e 67 20 69 6e 69 74 69 61 6c 69 7a 61 uring initializa
1410: 74 69 6f 6e 20 69 66 20 61 20 73 74 61 74 69 63 tion if a static
1420: 20 62 75 66 66 65 72 20 69 73 20 0a 2a 2a 20 73 buffer is .** s
1430: 75 70 70 6c 69 65 64 20 74 6f 20 75 73 65 20 66 upplied to use f
1440: 6f 72 20 74 68 65 20 70 61 67 65 2d 63 61 63 68 or the page-cach
1450: 65 20 62 79 20 70 61 73 73 69 6e 67 20 74 68 65 e by passing the
1460: 20 53 51 4c 49 54 45 5f 43 4f 4e 46 49 47 5f 50 SQLITE_CONFIG_P
1470: 41 47 45 43 41 43 48 45 0a 2a 2a 20 76 65 72 62 AGECACHE.** verb
1480: 20 74 6f 20 73 71 6c 69 74 65 33 5f 63 6f 6e 66 to sqlite3_conf
1490: 69 67 28 29 2e 20 50 61 72 61 6d 65 74 65 72 20 ig(). Parameter
14a0: 70 42 75 66 20 70 6f 69 6e 74 73 20 74 6f 20 61 pBuf points to a
14b0: 6e 20 61 6c 6c 6f 63 61 74 69 6f 6e 20 6c 61 72 n allocation lar
14c0: 67 65 0a 2a 2a 20 65 6e 6f 75 67 68 20 74 6f 20 ge.** enough to
14d0: 63 6f 6e 74 61 69 6e 20 27 6e 27 20 62 75 66 66 contain 'n' buff
14e0: 65 72 73 20 6f 66 20 27 73 7a 27 20 62 79 74 65 ers of 'sz' byte
14f0: 73 20 65 61 63 68 2e 0a 2a 2f 0a 76 6f 69 64 20 s each..*/.void
1500: 73 71 6c 69 74 65 33 50 43 61 63 68 65 42 75 66 sqlite3PCacheBuf
1510: 66 65 72 53 65 74 75 70 28 76 6f 69 64 20 2a 70 ferSetup(void *p
1520: 42 75 66 2c 20 69 6e 74 20 73 7a 2c 20 69 6e 74 Buf, int sz, int
1530: 20 6e 29 7b 0a 20 20 50 67 46 72 65 65 73 6c 6f n){. PgFreeslo
1540: 74 20 2a 70 3b 0a 20 20 73 7a 20 26 3d 20 7e 37 t *p;. sz &= ~7
1550: 3b 0a 20 20 70 63 61 63 68 65 31 2e 73 7a 53 6c ;. pcache1.szSl
1560: 6f 74 20 3d 20 73 7a 3b 0a 20 20 70 63 61 63 68 ot = sz;. pcach
1570: 65 31 2e 70 53 74 61 72 74 20 3d 20 70 42 75 66 e1.pStart = pBuf
1580: 3b 0a 20 20 70 63 61 63 68 65 31 2e 70 46 72 65 ;. pcache1.pFre
1590: 65 20 3d 20 30 3b 0a 20 20 77 68 69 6c 65 28 20 e = 0;. while(
15a0: 6e 2d 2d 20 29 7b 0a 20 20 20 20 70 20 3d 20 28 n-- ){. p = (
15b0: 50 67 46 72 65 65 73 6c 6f 74 2a 29 70 42 75 66 PgFreeslot*)pBuf
15c0: 3b 0a 20 20 20 20 70 2d 3e 70 4e 65 78 74 20 3d ;. p->pNext =
15d0: 20 70 63 61 63 68 65 31 2e 70 46 72 65 65 3b 0a pcache1.pFree;.
15e0: 20 20 20 20 70 63 61 63 68 65 31 2e 70 46 72 65 pcache1.pFre
15f0: 65 20 3d 20 70 3b 0a 20 20 20 20 70 42 75 66 20 e = p;. pBuf
1600: 3d 20 28 76 6f 69 64 2a 29 26 28 28 63 68 61 72 = (void*)&((char
1610: 2a 29 70 42 75 66 29 5b 73 7a 5d 3b 0a 20 20 7d *)pBuf)[sz];. }
1620: 0a 20 20 70 63 61 63 68 65 31 2e 70 45 6e 64 20 . pcache1.pEnd
1630: 3d 20 70 42 75 66 3b 0a 7d 0a 0a 2f 2a 0a 2a 2a = pBuf;.}../*.**
1640: 20 4d 61 6c 6c 6f 63 20 66 75 6e 63 74 69 6f 6e Malloc function
1650: 20 75 73 65 64 20 77 69 74 68 69 6e 20 74 68 69 used within thi
1660: 73 20 66 69 6c 65 20 74 6f 20 61 6c 6c 6f 63 61 s file to alloca
1670: 74 65 20 73 70 61 63 65 20 66 72 6f 6d 20 74 68 te space from th
1680: 65 20 62 75 66 66 65 72 0a 2a 2a 20 63 6f 6e 66 e buffer.** conf
1690: 69 67 75 72 65 64 20 75 73 69 6e 67 20 73 71 6c igured using sql
16a0: 69 74 65 33 5f 63 6f 6e 66 69 67 28 53 51 4c 49 ite3_config(SQLI
16b0: 54 45 5f 43 4f 4e 46 49 47 5f 50 41 47 45 43 41 TE_CONFIG_PAGECA
16c0: 43 48 45 29 20 6f 70 74 69 6f 6e 2e 20 49 66 20 CHE) option. If
16d0: 6e 6f 20 0a 2a 2a 20 73 75 63 68 20 62 75 66 66 no .** such buff
16e0: 65 72 20 65 78 69 73 74 73 20 6f 72 20 74 68 65 er exists or the
16f0: 72 65 20 69 73 20 6e 6f 20 73 70 61 63 65 20 6c re is no space l
1700: 65 66 74 20 69 6e 20 69 74 2c 20 74 68 69 73 20 eft in it, this
1710: 66 75 6e 63 74 69 6f 6e 20 66 61 6c 6c 73 20 0a function falls .
1720: 2a 2a 20 62 61 63 6b 20 74 6f 20 73 71 6c 69 74 ** back to sqlit
1730: 65 33 4d 61 6c 6c 6f 63 28 29 2e 0a 2a 2f 0a 73 e3Malloc()..*/.s
1740: 74 61 74 69 63 20 76 6f 69 64 20 2a 70 63 61 63 tatic void *pcac
1750: 68 65 31 41 6c 6c 6f 63 28 69 6e 74 20 6e 42 79 he1Alloc(int nBy
1760: 74 65 29 7b 0a 20 20 76 6f 69 64 20 2a 70 3b 0a te){. void *p;.
1770: 20 20 61 73 73 65 72 74 28 20 73 71 6c 69 74 65 assert( sqlite
1780: 33 5f 6d 75 74 65 78 5f 68 65 6c 64 28 70 63 61 3_mutex_held(pca
1790: 63 68 65 31 2e 6d 75 74 65 78 29 20 29 3b 0a 20 che1.mutex) );.
17a0: 20 69 66 28 20 6e 42 79 74 65 3c 3d 70 63 61 63 if( nByte<=pcac
17b0: 68 65 31 2e 73 7a 53 6c 6f 74 20 26 26 20 70 63 he1.szSlot && pc
17c0: 61 63 68 65 31 2e 70 46 72 65 65 20 29 7b 0a 20 ache1.pFree ){.
17d0: 20 20 20 70 20 3d 20 28 50 67 48 64 72 31 20 2a p = (PgHdr1 *
17e0: 29 70 63 61 63 68 65 31 2e 70 46 72 65 65 3b 0a )pcache1.pFree;.
17f0: 20 20 20 20 70 63 61 63 68 65 31 2e 70 46 72 65 pcache1.pFre
1800: 65 20 3d 20 70 63 61 63 68 65 31 2e 70 46 72 65 e = pcache1.pFre
1810: 65 2d 3e 70 4e 65 78 74 3b 0a 20 20 20 20 73 71 e->pNext;. sq
1820: 6c 69 74 65 33 53 74 61 74 75 73 53 65 74 28 53 lite3StatusSet(S
1830: 51 4c 49 54 45 5f 53 54 41 54 55 53 5f 50 41 47 QLITE_STATUS_PAG
1840: 45 43 41 43 48 45 5f 53 49 5a 45 2c 20 6e 42 79 ECACHE_SIZE, nBy
1850: 74 65 29 3b 0a 20 20 20 20 73 71 6c 69 74 65 33 te);. sqlite3
1860: 53 74 61 74 75 73 41 64 64 28 53 51 4c 49 54 45 StatusAdd(SQLITE
1870: 5f 53 54 41 54 55 53 5f 50 41 47 45 43 41 43 48 _STATUS_PAGECACH
1880: 45 5f 55 53 45 44 2c 20 31 29 3b 0a 20 20 7d 65 E_USED, 1);. }e
1890: 6c 73 65 7b 0a 0a 20 20 20 20 2f 2a 20 41 6c 6c lse{.. /* All
18a0: 6f 63 61 74 65 20 61 20 6e 65 77 20 62 75 66 66 ocate a new buff
18b0: 65 72 20 75 73 69 6e 67 20 73 71 6c 69 74 65 33 er using sqlite3
18c0: 4d 61 6c 6c 6f 63 2e 20 42 65 66 6f 72 65 20 64 Malloc. Before d
18d0: 6f 69 6e 67 20 73 6f 2c 20 65 78 69 74 20 74 68 oing so, exit th
18e0: 65 0a 20 20 20 20 2a 2a 20 67 6c 6f 62 61 6c 20 e. ** global
18f0: 70 63 61 63 68 65 20 6d 75 74 65 78 20 61 6e 64 pcache mutex and
1900: 20 75 6e 6c 6f 63 6b 20 74 68 65 20 70 61 67 65 unlock the page
1910: 72 2d 63 61 63 68 65 20 6f 62 6a 65 63 74 20 70 r-cache object p
1920: 43 61 63 68 65 2e 20 54 68 69 73 20 69 73 20 0a Cache. This is .
1930: 20 20 20 20 2a 2a 20 73 6f 20 74 68 61 74 20 69 ** so that i
1940: 66 20 74 68 65 20 61 74 74 65 6d 70 74 20 74 6f f the attempt to
1950: 20 61 6c 6c 6f 63 61 74 65 20 61 20 6e 65 77 20 allocate a new
1960: 62 75 66 66 65 72 20 63 61 75 73 65 73 20 74 68 buffer causes th
1970: 65 20 74 68 65 20 0a 20 20 20 20 2a 2a 20 63 6f e the . ** co
1980: 6e 66 69 67 75 72 65 64 20 73 6f 66 74 2d 68 65 nfigured soft-he
1990: 61 70 2d 6c 69 6d 69 74 20 74 6f 20 62 65 20 62 ap-limit to be b
19a0: 72 65 61 63 68 65 64 2c 20 69 74 20 77 69 6c 6c reached, it will
19b0: 20 62 65 20 70 6f 73 73 69 62 6c 65 20 74 6f 0a be possible to.
19c0: 20 20 20 20 2a 2a 20 72 65 63 6c 61 69 6d 20 6d ** reclaim m
19d0: 65 6d 6f 72 79 20 66 72 6f 6d 20 74 68 69 73 20 emory from this
19e0: 70 61 67 65 72 2d 63 61 63 68 65 2e 0a 20 20 20 pager-cache..
19f0: 20 2a 2f 0a 20 20 20 20 70 63 61 63 68 65 31 4c */. pcache1L
1a00: 65 61 76 65 4d 75 74 65 78 28 29 3b 0a 20 20 20 eaveMutex();.
1a10: 20 70 20 3d 20 73 71 6c 69 74 65 33 4d 61 6c 6c p = sqlite3Mall
1a20: 6f 63 28 6e 42 79 74 65 29 3b 0a 20 20 20 20 70 oc(nByte);. p
1a30: 63 61 63 68 65 31 45 6e 74 65 72 4d 75 74 65 78 cache1EnterMutex
1a40: 28 29 3b 0a 20 20 20 20 69 66 28 20 70 20 29 7b ();. if( p ){
1a50: 0a 20 20 20 20 20 20 69 6e 74 20 73 7a 20 3d 20 . int sz =
1a60: 73 71 6c 69 74 65 33 4d 61 6c 6c 6f 63 53 69 7a sqlite3MallocSiz
1a70: 65 28 70 29 3b 0a 20 20 20 20 20 20 73 71 6c 69 e(p);. sqli
1a80: 74 65 33 53 74 61 74 75 73 41 64 64 28 53 51 4c te3StatusAdd(SQL
1a90: 49 54 45 5f 53 54 41 54 55 53 5f 50 41 47 45 43 ITE_STATUS_PAGEC
1aa0: 41 43 48 45 5f 4f 56 45 52 46 4c 4f 57 2c 20 73 ACHE_OVERFLOW, s
1ab0: 7a 29 3b 0a 20 20 20 20 7d 0a 20 20 7d 0a 20 20 z);. }. }.
1ac0: 72 65 74 75 72 6e 20 70 3b 0a 7d 0a 0a 2f 2a 0a return p;.}../*.
1ad0: 2a 2a 20 46 72 65 65 20 61 6e 20 61 6c 6c 6f 63 ** Free an alloc
1ae0: 61 74 65 64 20 62 75 66 66 65 72 20 6f 62 74 61 ated buffer obta
1af0: 69 6e 65 64 20 66 72 6f 6d 20 70 63 61 63 68 65 ined from pcache
1b00: 31 41 6c 6c 6f 63 28 29 2e 0a 2a 2f 0a 73 74 61 1Alloc()..*/.sta
1b10: 74 69 63 20 76 6f 69 64 20 70 63 61 63 68 65 31 tic void pcache1
1b20: 46 72 65 65 28 76 6f 69 64 20 2a 70 29 7b 0a 20 Free(void *p){.
1b30: 20 61 73 73 65 72 74 28 20 73 71 6c 69 74 65 33 assert( sqlite3
1b40: 5f 6d 75 74 65 78 5f 68 65 6c 64 28 70 63 61 63 _mutex_held(pcac
1b50: 68 65 31 2e 6d 75 74 65 78 29 20 29 3b 0a 20 20 he1.mutex) );.
1b60: 69 66 28 20 70 3d 3d 30 20 29 20 72 65 74 75 72 if( p==0 ) retur
1b70: 6e 3b 0a 20 20 69 66 28 20 70 3e 3d 70 63 61 63 n;. if( p>=pcac
1b80: 68 65 31 2e 70 53 74 61 72 74 20 26 26 20 70 3c he1.pStart && p<
1b90: 70 63 61 63 68 65 31 2e 70 45 6e 64 20 29 7b 0a pcache1.pEnd ){.
1ba0: 20 20 20 20 50 67 46 72 65 65 73 6c 6f 74 20 2a PgFreeslot *
1bb0: 70 53 6c 6f 74 3b 0a 20 20 20 20 73 71 6c 69 74 pSlot;. sqlit
1bc0: 65 33 53 74 61 74 75 73 41 64 64 28 53 51 4c 49 e3StatusAdd(SQLI
1bd0: 54 45 5f 53 54 41 54 55 53 5f 50 41 47 45 43 41 TE_STATUS_PAGECA
1be0: 43 48 45 5f 55 53 45 44 2c 20 2d 31 29 3b 0a 20 CHE_USED, -1);.
1bf0: 20 20 20 70 53 6c 6f 74 20 3d 20 28 50 67 46 72 pSlot = (PgFr
1c00: 65 65 73 6c 6f 74 2a 29 70 3b 0a 20 20 20 20 70 eeslot*)p;. p
1c10: 53 6c 6f 74 2d 3e 70 4e 65 78 74 20 3d 20 70 63 Slot->pNext = pc
1c20: 61 63 68 65 31 2e 70 46 72 65 65 3b 0a 20 20 20 ache1.pFree;.
1c30: 20 70 63 61 63 68 65 31 2e 70 46 72 65 65 20 3d pcache1.pFree =
1c40: 20 70 53 6c 6f 74 3b 0a 20 20 7d 65 6c 73 65 7b pSlot;. }else{
1c50: 0a 20 20 20 20 69 6e 74 20 69 53 69 7a 65 20 3d . int iSize =
1c60: 20 73 71 6c 69 74 65 33 4d 61 6c 6c 6f 63 53 69 sqlite3MallocSi
1c70: 7a 65 28 70 29 3b 0a 20 20 20 20 73 71 6c 69 74 ze(p);. sqlit
1c80: 65 33 53 74 61 74 75 73 41 64 64 28 53 51 4c 49 e3StatusAdd(SQLI
1c90: 54 45 5f 53 54 41 54 55 53 5f 50 41 47 45 43 41 TE_STATUS_PAGECA
1ca0: 43 48 45 5f 4f 56 45 52 46 4c 4f 57 2c 20 2d 69 CHE_OVERFLOW, -i
1cb0: 53 69 7a 65 29 3b 0a 20 20 20 20 73 71 6c 69 74 Size);. sqlit
1cc0: 65 33 5f 66 72 65 65 28 70 29 3b 0a 20 20 7d 0a e3_free(p);. }.
1cd0: 7d 0a 0a 2f 2a 0a 2a 2a 20 41 6c 6c 6f 63 61 74 }../*.** Allocat
1ce0: 65 20 61 20 6e 65 77 20 70 61 67 65 20 6f 62 6a e a new page obj
1cf0: 65 63 74 20 69 6e 69 74 69 61 6c 6c 79 20 61 73 ect initially as
1d00: 73 6f 63 69 61 74 65 64 20 77 69 74 68 20 63 61 sociated with ca
1d10: 63 68 65 20 70 43 61 63 68 65 2e 0a 2a 2f 0a 73 che pCache..*/.s
1d20: 74 61 74 69 63 20 50 67 48 64 72 31 20 2a 70 63 tatic PgHdr1 *pc
1d30: 61 63 68 65 31 41 6c 6c 6f 63 50 61 67 65 28 50 ache1AllocPage(P
1d40: 43 61 63 68 65 31 20 2a 70 43 61 63 68 65 29 7b Cache1 *pCache){
1d50: 0a 20 20 69 6e 74 20 6e 42 79 74 65 20 3d 20 73 . int nByte = s
1d60: 69 7a 65 6f 66 28 50 67 48 64 72 31 29 20 2b 20 izeof(PgHdr1) +
1d70: 70 43 61 63 68 65 2d 3e 73 7a 50 61 67 65 3b 0a pCache->szPage;.
1d80: 20 20 50 67 48 64 72 31 20 2a 70 20 3d 20 28 50 PgHdr1 *p = (P
1d90: 67 48 64 72 31 20 2a 29 70 63 61 63 68 65 31 41 gHdr1 *)pcache1A
1da0: 6c 6c 6f 63 28 6e 42 79 74 65 29 3b 0a 20 20 69 lloc(nByte);. i
1db0: 66 28 20 70 20 29 7b 0a 20 20 20 20 69 66 28 20 f( p ){. if(
1dc0: 70 43 61 63 68 65 2d 3e 62 50 75 72 67 65 61 62 pCache->bPurgeab
1dd0: 6c 65 20 29 7b 0a 20 20 20 20 20 20 70 63 61 63 le ){. pcac
1de0: 68 65 31 2e 6e 43 75 72 72 65 6e 74 50 61 67 65 he1.nCurrentPage
1df0: 2b 2b 3b 0a 20 20 20 20 7d 0a 20 20 7d 0a 20 20 ++;. }. }.
1e00: 72 65 74 75 72 6e 20 70 3b 0a 7d 0a 0a 2f 2a 0a return p;.}../*.
1e10: 2a 2a 20 46 72 65 65 20 61 20 70 61 67 65 20 6f ** Free a page o
1e20: 62 6a 65 63 74 20 61 6c 6c 6f 63 61 74 65 64 20 bject allocated
1e30: 62 79 20 70 63 61 63 68 65 31 41 6c 6c 6f 63 50 by pcache1AllocP
1e40: 61 67 65 28 29 2e 0a 2a 2f 0a 73 74 61 74 69 63 age()..*/.static
1e50: 20 76 6f 69 64 20 70 63 61 63 68 65 31 46 72 65 void pcache1Fre
1e60: 65 50 61 67 65 28 50 67 48 64 72 31 20 2a 70 29 ePage(PgHdr1 *p)
1e70: 7b 0a 20 20 69 66 28 20 70 20 29 7b 0a 20 20 20 {. if( p ){.
1e80: 20 69 66 28 20 70 2d 3e 70 43 61 63 68 65 2d 3e if( p->pCache->
1e90: 62 50 75 72 67 65 61 62 6c 65 20 29 7b 0a 20 20 bPurgeable ){.
1ea0: 20 20 20 20 70 63 61 63 68 65 31 2e 6e 43 75 72 pcache1.nCur
1eb0: 72 65 6e 74 50 61 67 65 2d 2d 3b 0a 20 20 20 20 rentPage--;.
1ec0: 7d 0a 20 20 20 20 70 63 61 63 68 65 31 46 72 65 }. pcache1Fre
1ed0: 65 28 70 29 3b 0a 20 20 7d 0a 7d 0a 0a 2f 2a 0a e(p);. }.}../*.
1ee0: 2a 2a 20 4d 61 6c 6c 6f 63 20 66 75 6e 63 74 69 ** Malloc functi
1ef0: 6f 6e 20 75 73 65 64 20 62 79 20 53 51 4c 69 74 on used by SQLit
1f00: 65 20 74 6f 20 6f 62 74 61 69 6e 20 73 70 61 63 e to obtain spac
1f10: 65 20 66 72 6f 6d 20 74 68 65 20 62 75 66 66 65 e from the buffe
1f20: 72 20 63 6f 6e 66 69 67 75 72 65 64 0a 2a 2a 20 r configured.**
1f30: 75 73 69 6e 67 20 73 71 6c 69 74 65 33 5f 63 6f using sqlite3_co
1f40: 6e 66 69 67 28 53 51 4c 49 54 45 5f 43 4f 4e 46 nfig(SQLITE_CONF
1f50: 49 47 5f 50 41 47 45 43 41 43 48 45 29 20 6f 70 IG_PAGECACHE) op
1f60: 74 69 6f 6e 2e 20 49 66 20 6e 6f 20 73 75 63 68 tion. If no such
1f70: 20 62 75 66 66 65 72 0a 2a 2a 20 65 78 69 73 74 buffer.** exist
1f80: 73 2c 20 74 68 69 73 20 66 75 6e 63 74 69 6f 6e s, this function
1f90: 20 66 61 6c 6c 73 20 62 61 63 6b 20 74 6f 20 73 falls back to s
1fa0: 71 6c 69 74 65 33 4d 61 6c 6c 6f 63 28 29 2e 0a qlite3Malloc()..
1fb0: 2a 2f 0a 76 6f 69 64 20 2a 73 71 6c 69 74 65 33 */.void *sqlite3
1fc0: 50 61 67 65 4d 61 6c 6c 6f 63 28 69 6e 74 20 73 PageMalloc(int s
1fd0: 7a 29 7b 0a 20 20 76 6f 69 64 20 2a 70 3b 0a 20 z){. void *p;.
1fe0: 20 70 63 61 63 68 65 31 45 6e 74 65 72 4d 75 74 pcache1EnterMut
1ff0: 65 78 28 29 3b 0a 20 20 70 20 3d 20 70 63 61 63 ex();. p = pcac
2000: 68 65 31 41 6c 6c 6f 63 28 73 7a 29 3b 0a 20 20 he1Alloc(sz);.
2010: 70 63 61 63 68 65 31 4c 65 61 76 65 4d 75 74 65 pcache1LeaveMute
2020: 78 28 29 3b 0a 20 20 72 65 74 75 72 6e 20 70 3b x();. return p;
2030: 0a 7d 0a 0a 2f 2a 0a 2a 2a 20 46 72 65 65 20 61 .}../*.** Free a
2040: 6e 20 61 6c 6c 6f 63 61 74 65 64 20 62 75 66 66 n allocated buff
2050: 65 72 20 6f 62 74 61 69 6e 65 64 20 66 72 6f 6d er obtained from
2060: 20 73 71 6c 69 74 65 33 50 61 67 65 4d 61 6c 6c sqlite3PageMall
2070: 6f 63 28 29 2e 0a 2a 2f 0a 76 6f 69 64 20 73 71 oc()..*/.void sq
2080: 6c 69 74 65 33 50 61 67 65 46 72 65 65 28 76 6f lite3PageFree(vo
2090: 69 64 20 2a 70 29 7b 0a 20 20 70 63 61 63 68 65 id *p){. pcache
20a0: 31 45 6e 74 65 72 4d 75 74 65 78 28 29 3b 0a 20 1EnterMutex();.
20b0: 20 70 63 61 63 68 65 31 46 72 65 65 28 70 29 3b pcache1Free(p);
20c0: 0a 20 20 70 63 61 63 68 65 31 4c 65 61 76 65 4d . pcache1LeaveM
20d0: 75 74 65 78 28 29 3b 0a 7d 0a 0a 2f 2a 2a 2a 2a utex();.}../****
20e0: 2a 2a 2a 2a 2a 2a 2a 2a 2a 2a 2a 2a 2a 2a 2a 2a ****************
20f0: 2a 2a 2a 2a 2a 2a 2a 2a 2a 2a 2a 2a 2a 2a 2a 2a ****************
2100: 2a 2a 2a 2a 2a 2a 2a 2a 2a 2a 2a 2a 2a 2a 2a 2a ****************
2110: 2a 2a 2a 2a 2a 2a 2a 2a 2a 2a 2a 2a 2a 2a 2a 2a ****************
2120: 2a 2a 2a 2a 2a 2a 2a 2a 2a 2a 2f 0a 2f 2a 2a 2a **********/./***
2130: 2a 2a 2a 2a 2a 20 47 65 6e 65 72 61 6c 20 49 6d ***** General Im
2140: 70 6c 65 6d 65 6e 74 61 74 69 6f 6e 20 46 75 6e plementation Fun
2150: 63 74 69 6f 6e 73 20 2a 2a 2a 2a 2a 2a 2a 2a 2a ctions *********
2160: 2a 2a 2a 2a 2a 2a 2a 2a 2a 2a 2a 2a 2a 2a 2a 2a ****************
2170: 2a 2a 2a 2a 2a 2a 2a 2a 2a 2a 2a 2f 0a 0a 2f 2a ***********/../*
2180: 0a 2a 2a 20 54 68 69 73 20 66 75 6e 63 74 69 6f .** This functio
2190: 6e 20 69 73 20 75 73 65 64 20 74 6f 20 72 65 73 n is used to res
21a0: 69 7a 65 20 74 68 65 20 68 61 73 68 20 74 61 62 ize the hash tab
21b0: 6c 65 20 75 73 65 64 20 62 79 20 74 68 65 20 63 le used by the c
21c0: 61 63 68 65 20 70 61 73 73 65 64 0a 2a 2a 20 61 ache passed.** a
21d0: 73 20 74 68 65 20 66 69 72 73 74 20 61 72 67 75 s the first argu
21e0: 6d 65 6e 74 2e 0a 2a 2a 0a 2a 2a 20 54 68 65 20 ment..**.** The
21f0: 67 6c 6f 62 61 6c 20 6d 75 74 65 78 20 6d 75 73 global mutex mus
2200: 74 20 62 65 20 68 65 6c 64 20 77 68 65 6e 20 74 t be held when t
2210: 68 69 73 20 66 75 6e 63 74 69 6f 6e 20 69 73 20 his function is
2220: 63 61 6c 6c 65 64 2e 0a 2a 2f 0a 73 74 61 74 69 called..*/.stati
2230: 63 20 69 6e 74 20 70 63 61 63 68 65 31 52 65 73 c int pcache1Res
2240: 69 7a 65 48 61 73 68 28 50 43 61 63 68 65 31 20 izeHash(PCache1
2250: 2a 70 29 7b 0a 20 20 50 67 48 64 72 31 20 2a 2a *p){. PgHdr1 **
2260: 61 70 4e 65 77 3b 0a 20 20 75 6e 73 69 67 6e 65 apNew;. unsigne
2270: 64 20 69 6e 74 20 6e 4e 65 77 3b 0a 20 20 75 6e d int nNew;. un
2280: 73 69 67 6e 65 64 20 69 6e 74 20 69 3b 0a 0a 20 signed int i;..
2290: 20 61 73 73 65 72 74 28 20 73 71 6c 69 74 65 33 assert( sqlite3
22a0: 5f 6d 75 74 65 78 5f 68 65 6c 64 28 70 63 61 63 _mutex_held(pcac
22b0: 68 65 31 2e 6d 75 74 65 78 29 20 29 3b 0a 0a 20 he1.mutex) );..
22c0: 20 6e 4e 65 77 20 3d 20 70 2d 3e 6e 48 61 73 68 nNew = p->nHash
22d0: 2a 32 3b 0a 20 20 69 66 28 20 6e 4e 65 77 3c 32 *2;. if( nNew<2
22e0: 35 36 20 29 7b 0a 20 20 20 20 6e 4e 65 77 20 3d 56 ){. nNew =
22f0: 20 32 35 36 3b 0a 20 20 7d 0a 0a 20 20 70 63 61 256;. }.. pca
2300: 63 68 65 31 4c 65 61 76 65 4d 75 74 65 78 28 29 che1LeaveMutex()
2310: 3b 0a 20 20 69 66 28 20 70 2d 3e 6e 48 61 73 68 ;. if( p->nHash
2320: 20 29 7b 20 73 71 6c 69 74 65 33 42 65 67 69 6e ){ sqlite3Begin
2330: 42 65 6e 69 67 6e 4d 61 6c 6c 6f 63 28 29 3b 20 BenignMalloc();
2340: 7d 0a 20 20 61 70 4e 65 77 20 3d 20 28 50 67 48 }. apNew = (PgH
2350: 64 72 31 20 2a 2a 29 73 71 6c 69 74 65 33 5f 6d dr1 **)sqlite3_m
2360: 61 6c 6c 6f 63 28 73 69 7a 65 6f 66 28 50 67 48 alloc(sizeof(PgH
2370: 64 72 31 20 2a 29 2a 6e 4e 65 77 29 3b 0a 20 20 dr1 *)*nNew);.
2380: 69 66 28 20 70 2d 3e 6e 48 61 73 68 20 29 7b 20 if( p->nHash ){
2390: 73 71 6c 69 74 65 33 45 6e 64 42 65 6e 69 67 6e sqlite3EndBenign
23a0: 4d 61 6c 6c 6f 63 28 29 3b 20 7d 0a 20 20 70 63 Malloc(); }. pc
23b0: 61 63 68 65 31 45 6e 74 65 72 4d 75 74 65 78 28 ache1EnterMutex(
23c0: 29 3b 0a 20 20 69 66 28 20 61 70 4e 65 77 20 29 );. if( apNew )
23d0: 7b 0a 20 20 20 20 6d 65 6d 73 65 74 28 61 70 4e {. memset(apN
23e0: 65 77 2c 20 30 2c 20 73 69 7a 65 6f 66 28 50 67 ew, 0, sizeof(Pg
23f0: 48 64 72 31 20 2a 29 2a 6e 4e 65 77 29 3b 0a 20 Hdr1 *)*nNew);.
2400: 20 20 20 66 6f 72 28 69 3d 30 3b 20 69 3c 70 2d for(i=0; i<p-
2410: 3e 6e 48 61 73 68 3b 20 69 2b 2b 29 7b 0a 20 20 >nHash; i++){.
2420: 20 20 20 20 50 67 48 64 72 31 20 2a 70 50 61 67 PgHdr1 *pPag
2430: 65 3b 0a 20 20 20 20 20 20 50 67 48 64 72 31 20 e;. PgHdr1
2440: 2a 70 4e 65 78 74 20 3d 20 70 2d 3e 61 70 48 61 *pNext = p->apHa
2450: 73 68 5b 69 5d 3b 0a 20 20 20 20 20 20 77 68 69 sh[i];. whi
2460: 6c 65 28 20 28 70 50 61 67 65 20 3d 20 70 4e 65 le( (pPage = pNe
2470: 78 74 29 21 3d 30 20 29 7b 0a 20 20 20 20 20 20 xt)!=0 ){.
2480: 20 20 75 6e 73 69 67 6e 65 64 20 69 6e 74 20 68 unsigned int h
2490: 20 3d 20 70 50 61 67 65 2d 3e 69 4b 65 79 20 25 = pPage->iKey %
24a0: 20 6e 4e 65 77 3b 0a 20 20 20 20 20 20 20 20 70 nNew;. p
24b0: 4e 65 78 74 20 3d 20 70 50 61 67 65 2d 3e 70 4e Next = pPage->pN
24c0: 65 78 74 3b 0a 20 20 20 20 20 20 20 20 70 50 61 ext;. pPa
24d0: 67 65 2d 3e 70 4e 65 78 74 20 3d 20 61 70 4e 65 ge->pNext = apNe
24e0: 77 5b 68 5d 3b 0a 20 20 20 20 20 20 20 20 61 70 w[h];. ap
24f0: 4e 65 77 5b 68 5d 20 3d 20 70 50 61 67 65 3b 0a New[h] = pPage;.
2500: 20 20 20 20 20 20 7d 0a 20 20 20 20 7d 0a 20 20 }. }.
2510: 20 20 73 71 6c 69 74 65 33 5f 66 72 65 65 28 70 sqlite3_free(p
2520: 2d 3e 61 70 48 61 73 68 29 3b 0a 20 20 20 20 70 ->apHash);. p
2530: 2d 3e 61 70 48 61 73 68 20 3d 20 61 70 4e 65 77 ->apHash = apNew
2540: 3b 0a 20 20 20 20 70 2d 3e 6e 48 61 73 68 20 3d ;. p->nHash =
2550: 20 6e 4e 65 77 3b 0a 20 20 7d 0a 0a 20 20 72 65 nNew;. }.. re
2560: 74 75 72 6e 20 28 70 2d 3e 61 70 48 61 73 68 20 turn (p->apHash
2570: 3f 20 53 51 4c 49 54 45 5f 4f 4b 20 3a 20 53 51 ? SQLITE_OK : SQ
2580: 4c 49 54 45 5f 4e 4f 4d 45 4d 29 3b 0a 7d 0a 0a LITE_NOMEM);.}..
2590: 2f 2a 0a 2a 2a 20 54 68 69 73 20 66 75 6e 63 74 /*.** This funct
25a0: 69 6f 6e 20 69 73 20 75 73 65 64 20 69 6e 74 65 ion is used inte
25b0: 72 6e 61 6c 6c 79 20 74 6f 20 72 65 6d 6f 76 65 rnally to remove
25c0: 20 74 68 65 20 70 61 67 65 20 70 50 61 67 65 20 the page pPage
25d0: 66 72 6f 6d 20 74 68 65 20 0a 2a 2a 20 67 6c 6f from the .** glo
25e0: 62 61 6c 20 4c 52 55 20 6c 69 73 74 2c 20 69 66 bal LRU list, if
25f0: 20 69 73 20 70 61 72 74 20 6f 66 20 69 74 2e 20 is part of it.
2600: 49 66 20 70 50 61 67 65 20 69 73 20 6e 6f 74 20 If pPage is not
2610: 70 61 72 74 20 6f 66 20 74 68 65 20 67 6c 6f 62 part of the glob
2620: 61 6c 0a 2a 2a 20 4c 52 55 20 6c 69 73 74 2c 20 al.** LRU list,
2630: 74 68 65 6e 20 74 68 69 73 20 66 75 6e 63 74 69 then this functi
2640: 6f 6e 20 69 73 20 61 20 6e 6f 2d 6f 70 2e 0a 2a on is a no-op..*
2650: 2a 0a 2a 2a 20 54 68 65 20 67 6c 6f 62 61 6c 20 *.** The global
2660: 6d 75 74 65 78 20 6d 75 73 74 20 62 65 20 68 65 mutex must be he
2670: 6c 64 20 77 68 65 6e 20 74 68 69 73 20 66 75 6e ld when this fun
2680: 63 74 69 6f 6e 20 69 73 20 63 61 6c 6c 65 64 2e ction is called.
2690: 0a 2a 2f 0a 73 74 61 74 69 63 20 76 6f 69 64 20 .*/.static void
26a0: 70 63 61 63 68 65 31 50 69 6e 50 61 67 65 28 50 pcache1PinPage(P
26b0: 67 48 64 72 31 20 2a 70 50 61 67 65 29 7b 0a 20 gHdr1 *pPage){.
26c0: 20 61 73 73 65 72 74 28 20 73 71 6c 69 74 65 33 assert( sqlite3
26d0: 5f 6d 75 74 65 78 5f 68 65 6c 64 28 70 63 61 63 _mutex_held(pcac
26e0: 68 65 31 2e 6d 75 74 65 78 29 20 29 3b 0a 20 20 he1.mutex) );.
26f0: 69 66 28 20 70 50 61 67 65 20 26 26 20 28 70 50 if( pPage && (pP
2700: 61 67 65 2d 3e 70 4c 72 75 4e 65 78 74 20 7c 7c age->pLruNext ||
2710: 20 70 50 61 67 65 3d 3d 70 63 61 63 68 65 31 2e pPage==pcache1.
2720: 70 4c 72 75 54 61 69 6c 29 20 29 7b 0a 20 20 20 pLruTail) ){.
2730: 20 69 66 28 20 70 50 61 67 65 2d 3e 70 4c 72 75 if( pPage->pLru
2740: 50 72 65 76 20 29 7b 0a 20 20 20 20 20 20 70 50 Prev ){. pP
2750: 61 67 65 2d 3e 70 4c 72 75 50 72 65 76 2d 3e 70 age->pLruPrev->p
2760: 4c 72 75 4e 65 78 74 20 3d 20 70 50 61 67 65 2d LruNext = pPage-
2770: 3e 70 4c 72 75 4e 65 78 74 3b 0a 20 20 20 20 7d >pLruNext;. }
2780: 0a 20 20 20 20 69 66 28 20 70 50 61 67 65 2d 3e . if( pPage->
2790: 70 4c 72 75 4e 65 78 74 20 29 7b 0a 20 20 20 20 pLruNext ){.
27a0: 20 20 70 50 61 67 65 2d 3e 70 4c 72 75 4e 65 78 pPage->pLruNex
27b0: 74 2d 3e 70 4c 72 75 50 72 65 76 20 3d 20 70 50 t->pLruPrev = pP
27c0: 61 67 65 2d 3e 70 4c 72 75 50 72 65 76 3b 0a 20 age->pLruPrev;.
27d0: 20 20 20 7d 0a 20 20 20 20 69 66 28 20 70 63 61 }. if( pca
27e0: 63 68 65 31 2e 70 4c 72 75 48 65 61 64 3d 3d 70 che1.pLruHead==p
27f0: 50 61 67 65 20 29 7b 0a 20 20 20 20 20 20 70 63 Page ){. pc
2800: 61 63 68 65 31 2e 70 4c 72 75 48 65 61 64 20 3d ache1.pLruHead =
2810: 20 70 50 61 67 65 2d 3e 70 4c 72 75 4e 65 78 74 pPage->pLruNext
2820: 3b 0a 20 20 20 20 7d 0a 20 20 20 20 69 66 28 20 ;. }. if(
2830: 70 63 61 63 68 65 31 2e 70 4c 72 75 54 61 69 6c pcache1.pLruTail
2840: 3d 3d 70 50 61 67 65 20 29 7b 0a 20 20 20 20 20 ==pPage ){.
2850: 20 70 63 61 63 68 65 31 2e 70 4c 72 75 54 61 69 pcache1.pLruTai
2860: 6c 20 3d 20 70 50 61 67 65 2d 3e 70 4c 72 75 50 l = pPage->pLruP
2870: 72 65 76 3b 0a 20 20 20 20 7d 0a 20 20 20 20 70 rev;. }. p
2880: 50 61 67 65 2d 3e 70 4c 72 75 4e 65 78 74 20 3d Page->pLruNext =
2890: 20 30 3b 0a 20 20 20 20 70 50 61 67 65 2d 3e 70 0;. pPage->p
28a0: 4c 72 75 50 72 65 76 20 3d 20 30 3b 0a 20 20 20 LruPrev = 0;.
28b0: 20 70 50 61 67 65 2d 3e 70 43 61 63 68 65 2d 3e pPage->pCache->
28c0: 6e 52 65 63 79 63 6c 61 62 6c 65 2d 2d 3b 0a 20 nRecyclable--;.
28d0: 20 7d 0a 7d 0a 0a 0a 2f 2a 0a 2a 2a 20 52 65 6d }.}.../*.** Rem
28e0: 6f 76 65 20 74 68 65 20 70 61 67 65 20 73 75 70 ove the page sup
28f0: 70 6c 69 65 64 20 61 73 20 61 6e 20 61 72 67 75 plied as an argu
2900: 6d 65 6e 74 20 66 72 6f 6d 20 74 68 65 20 68 61 ment from the ha
2910: 73 68 20 74 61 62 6c 65 20 0a 2a 2a 20 28 50 43 sh table .** (PC
2920: 61 63 68 65 31 2e 61 70 48 61 73 68 20 73 74 72 ache1.apHash str
2930: 75 63 74 75 72 65 29 20 74 68 61 74 20 69 74 20 ucture) that it
2940: 69 73 20 63 75 72 72 65 6e 74 6c 79 20 73 74 6f is currently sto
2950: 72 65 64 20 69 6e 2e 0a 2a 2a 0a 2a 2a 20 54 68 red in..**.** Th
2960: 65 20 67 6c 6f 62 61 6c 20 6d 75 74 65 78 20 6d e global mutex m
2970: 75 73 74 20 62 65 20 68 65 6c 64 20 77 68 65 6e ust be held when
2980: 20 74 68 69 73 20 66 75 6e 63 74 69 6f 6e 20 69 this function i
2990: 73 20 63 61 6c 6c 65 64 2e 0a 2a 2f 0a 73 74 61 s called..*/.sta
29a0: 74 69 63 20 76 6f 69 64 20 70 63 61 63 68 65 31 tic void pcache1
29b0: 52 65 6d 6f 76 65 46 72 6f 6d 48 61 73 68 28 50 RemoveFromHash(P
29c0: 67 48 64 72 31 20 2a 70 50 61 67 65 29 7b 0a 20 gHdr1 *pPage){.
29d0: 20 75 6e 73 69 67 6e 65 64 20 69 6e 74 20 68 3b unsigned int h;
29e0: 0a 20 20 50 43 61 63 68 65 31 20 2a 70 43 61 63 . PCache1 *pCac
29f0: 68 65 20 3d 20 70 50 61 67 65 2d 3e 70 43 61 63 he = pPage->pCac
2a00: 68 65 3b 0a 20 20 50 67 48 64 72 31 20 2a 2a 70 he;. PgHdr1 **p
2a10: 70 3b 0a 0a 20 20 68 20 3d 20 70 50 61 67 65 2d p;.. h = pPage-
2a20: 3e 69 4b 65 79 20 25 20 70 43 61 63 68 65 2d 3e >iKey % pCache->
2a30: 6e 48 61 73 68 3b 0a 20 20 66 6f 72 28 70 70 3d nHash;. for(pp=
2a40: 26 70 43 61 63 68 65 2d 3e 61 70 48 61 73 68 5b &pCache->apHash[
2a50: 68 5d 3b 20 28 2a 70 70 29 21 3d 70 50 61 67 65 h]; (*pp)!=pPage
2a60: 3b 20 70 70 3d 26 28 2a 70 70 29 2d 3e 70 4e 65 ; pp=&(*pp)->pNe
2a70: 78 74 29 3b 0a 20 20 2a 70 70 20 3d 20 28 2a 70 xt);. *pp = (*p
2a80: 70 29 2d 3e 70 4e 65 78 74 3b 0a 0a 20 20 70 43 p)->pNext;.. pC
2a90: 61 63 68 65 2d 3e 6e 50 61 67 65 2d 2d 3b 0a 7d ache->nPage--;.}
2aa0: 0a 0a 2f 2a 0a 2a 2a 20 49 66 20 74 68 65 72 65 ../*.** If there
2ab0: 20 61 72 65 20 63 75 72 72 65 6e 74 6c 79 20 6d are currently m
2ac0: 6f 72 65 20 74 68 61 6e 20 70 63 61 63 68 65 2e ore than pcache.
2ad0: 6e 4d 61 78 50 61 67 65 20 70 61 67 65 73 20 61 nMaxPage pages a
2ae0: 6c 6c 6f 63 61 74 65 64 2c 20 74 72 79 0a 2a 2a llocated, try.**
2af0: 20 74 6f 20 72 65 63 79 63 6c 65 20 70 61 67 65 to recycle page
2b00: 73 20 74 6f 20 72 65 64 75 63 65 20 74 68 65 20 s to reduce the
2b10: 6e 75 6d 62 65 72 20 61 6c 6c 6f 63 61 74 65 64 number allocated
2b20: 20 74 6f 20 70 63 61 63 68 65 2e 6e 4d 61 78 50 to pcache.nMaxP
2b30: 61 67 65 2e 0a 2a 2f 0a 73 74 61 74 69 63 20 76 age..*/.static v
2b40: 6f 69 64 20 70 63 61 63 68 65 31 45 6e 66 6f 72 oid pcache1Enfor
2b50: 63 65 4d 61 78 50 61 67 65 28 76 6f 69 64 29 7b ceMaxPage(void){
2b60: 0a 20 20 61 73 73 65 72 74 28 20 73 71 6c 69 74 . assert( sqlit
2b70: 65 33 5f 6d 75 74 65 78 5f 68 65 6c 64 28 70 63 e3_mutex_held(pc
2b80: 61 63 68 65 31 2e 6d 75 74 65 78 29 20 29 3b 0a ache1.mutex) );.
2b90: 20 20 77 68 69 6c 65 28 20 70 63 61 63 68 65 31 while( pcache1
2ba0: 2e 6e 43 75 72 72 65 6e 74 50 61 67 65 3e 70 63 .nCurrentPage>pc
2bb0: 61 63 68 65 31 2e 6e 4d 61 78 50 61 67 65 20 26 ache1.nMaxPage &
2bc0: 26 20 70 63 61 63 68 65 31 2e 70 4c 72 75 54 61 & pcache1.pLruTa
2bd0: 69 6c 20 29 7b 0a 20 20 20 20 50 67 48 64 72 31 il ){. PgHdr1
2be0: 20 2a 70 20 3d 20 70 63 61 63 68 65 31 2e 70 4c *p = pcache1.pL
2bf0: 72 75 54 61 69 6c 3b 0a 20 20 20 20 70 63 61 63 ruTail;. pcac
2c00: 68 65 31 50 69 6e 50 61 67 65 28 70 29 3b 0a 20 he1PinPage(p);.
2c10: 20 20 20 70 63 61 63 68 65 31 52 65 6d 6f 76 65 pcache1Remove
2c20: 46 72 6f 6d 48 61 73 68 28 70 29 3b 0a 20 20 20 FromHash(p);.
2c30: 20 70 63 61 63 68 65 31 46 72 65 65 50 61 67 65 pcache1FreePage
2c40: 28 70 29 3b 0a 20 20 7d 0a 7d 0a 0a 2f 2a 0a 2a (p);. }.}../*.*
2c50: 2a 20 44 69 73 63 61 72 64 20 61 6c 6c 20 70 61 * Discard all pa
2c60: 67 65 73 20 66 72 6f 6d 20 63 61 63 68 65 20 70 ges from cache p
2c70: 43 61 63 68 65 20 77 69 74 68 20 61 20 70 61 67 Cache with a pag
2c80: 65 20 6e 75 6d 62 65 72 20 28 6b 65 79 20 76 61 e number (key va
2c90: 6c 75 65 29 20 0a 2a 2a 20 67 72 65 61 74 65 72 lue) .** greater
2ca0: 20 74 68 61 6e 20 6f 72 20 65 71 75 61 6c 20 74 than or equal t
2cb0: 6f 20 69 4c 69 6d 69 74 2e 20 41 6e 79 20 70 69 o iLimit. Any pi
2cc0: 6e 6e 65 64 20 70 61 67 65 73 20 74 68 61 74 20 nned pages that
2cd0: 6d 65 65 74 20 74 68 69 73 20 0a 2a 2a 20 63 72 meet this .** cr
2ce0: 69 74 65 72 69 61 20 61 72 65 20 75 6e 70 69 6e iteria are unpin
2cf0: 6e 65 64 20 62 65 66 6f 72 65 20 74 68 65 79 20 ned before they
2d00: 61 72 65 20 64 69 73 63 61 72 64 65 64 2e 0a 2a are discarded..*
2d10: 2a 0a 2a 2a 20 54 68 65 20 67 6c 6f 62 61 6c 20 *.** The global
2d20: 6d 75 74 65 78 20 6d 75 73 74 20 62 65 20 68 65 mutex must be he
2d30: 6c 64 20 77 68 65 6e 20 74 68 69 73 20 66 75 6e ld when this fun
2d40: 63 74 69 6f 6e 20 69 73 20 63 61 6c 6c 65 64 2e ction is called.
2d50: 0a 2a 2f 0a 73 74 61 74 69 63 20 76 6f 69 64 20 .*/.static void
2d60: 70 63 61 63 68 65 31 54 72 75 6e 63 61 74 65 55 pcache1TruncateU
2d70: 6e 73 61 66 65 28 0a 20 20 50 43 61 63 68 65 31 nsafe(. PCache1
2d80: 20 2a 70 43 61 63 68 65 2c 20 0a 20 20 75 6e 73 *pCache, . uns
2d90: 69 67 6e 65 64 20 69 6e 74 20 69 4c 69 6d 69 74 igned int iLimit
2da0: 20 0a 29 7b 0a 20 20 75 6e 73 69 67 6e 65 64 20 .){. unsigned
2db0: 69 6e 74 20 68 3b 0a 20 20 61 73 73 65 72 74 28 int h;. assert(
2dc0: 20 73 71 6c 69 74 65 33 5f 6d 75 74 65 78 5f 68 sqlite3_mutex_h
2dd0: 65 6c 64 28 70 63 61 63 68 65 31 2e 6d 75 74 65 eld(pcache1.mute
2de0: 78 29 20 29 3b 0a 20 20 66 6f 72 28 68 3d 30 3b x) );. for(h=0;
2df0: 20 68 3c 70 43 61 63 68 65 2d 3e 6e 48 61 73 68 h<pCache->nHash
2e00: 3b 20 68 2b 2b 29 7b 0a 20 20 20 20 50 67 48 64 ; h++){. PgHd
2e10: 72 31 20 2a 2a 70 70 20 3d 20 26 70 43 61 63 68 r1 **pp = &pCach
2e20: 65 2d 3e 61 70 48 61 73 68 5b 68 5d 3b 20 0a 20 e->apHash[h]; .
2e30: 20 20 20 50 67 48 64 72 31 20 2a 70 50 61 67 65 PgHdr1 *pPage
2e40: 3b 0a 20 20 20 20 77 68 69 6c 65 28 20 28 70 50 ;. while( (pP
2e50: 61 67 65 20 3d 20 2a 70 70 29 21 3d 30 20 29 7b age = *pp)!=0 ){
2e60: 0a 20 20 20 20 20 20 69 66 28 20 70 50 61 67 65 . if( pPage
2e70: 2d 3e 69 4b 65 79 3e 3d 69 4c 69 6d 69 74 20 29 ->iKey>=iLimit )
2e80: 7b 0a 20 20 20 20 20 20 20 20 70 63 61 63 68 65 {. pcache
2e90: 31 50 69 6e 50 61 67 65 28 70 50 61 67 65 29 3b 1PinPage(pPage);
2ea0: 0a 20 20 20 20 20 20 20 20 2a 70 70 20 3d 20 70 . *pp = p
2eb0: 50 61 67 65 2d 3e 70 4e 65 78 74 3b 0a 20 20 20 Page->pNext;.
2ec0: 20 20 20 20 20 70 63 61 63 68 65 31 46 72 65 65 pcache1Free
2ed0: 50 61 67 65 28 70 50 61 67 65 29 3b 0a 20 20 20 Page(pPage);.
2ee0: 20 20 20 7d 65 6c 73 65 7b 0a 20 20 20 20 20 20 }else{.
2ef0: 20 20 70 70 20 3d 20 26 70 50 61 67 65 2d 3e 70 pp = &pPage->p
2f00: 4e 65 78 74 3b 0a 20 20 20 20 20 20 7d 0a 20 20 Next;. }.
2f10: 20 20 7d 0a 20 20 7d 0a 7d 0a 0a 2f 2a 2a 2a 2a }. }.}../****
2f20: 2a 2a 2a 2a 2a 2a 2a 2a 2a 2a 2a 2a 2a 2a 2a 2a ****************
2f30: 2a 2a 2a 2a 2a 2a 2a 2a 2a 2a 2a 2a 2a 2a 2a 2a ****************
2f40: 2a 2a 2a 2a 2a 2a 2a 2a 2a 2a 2a 2a 2a 2a 2a 2a ****************
2f50: 2a 2a 2a 2a 2a 2a 2a 2a 2a 2a 2a 2a 2a 2a 2a 2a ****************
2f60: 2a 2a 2a 2a 2a 2a 2a 2a 2a 2a 2f 0a 2f 2a 2a 2a **********/./***
2f70: 2a 2a 2a 2a 2a 20 73 71 6c 69 74 65 33 5f 70 63 ***** sqlite3_pc
2f80: 61 63 68 65 20 4d 65 74 68 6f 64 73 20 2a 2a 2a ache Methods ***
2f90: 2a 2a 2a 2a 2a 2a 2a 2a 2a 2a 2a 2a 2a 2a 2a 2a ****************
2fa0: 2a 2a 2a 2a 2a 2a 2a 2a 2a 2a 2a 2a 2a 2a 2a 2a ****************
2fb0: 2a 2a 2a 2a 2a 2a 2a 2a 2a 2a 2a 2f 0a 0a 2f 2a ***********/../*
2fc0: 0a 2a 2a 20 49 6d 70 6c 65 6d 65 6e 74 61 74 69 .** Implementati
2fd0: 6f 6e 20 6f 66 20 74 68 65 20 73 71 6c 69 74 65 on of the sqlite
2fe0: 33 5f 70 63 61 63 68 65 2e 78 49 6e 69 74 20 6d 3_pcache.xInit m
2ff0: 65 74 68 6f 64 2e 0a 2a 2f 0a 73 74 61 74 69 63 ethod..*/.static
3000: 20 69 6e 74 20 70 63 61 63 68 65 31 49 6e 69 74 int pcache1Init
3010: 28 76 6f 69 64 20 2a 4e 6f 74 55 73 65 64 29 7b (void *NotUsed){
3020: 0a 20 20 55 4e 55 53 45 44 5f 50 41 52 41 4d 45 . UNUSED_PARAME
3030: 54 45 52 28 4e 6f 74 55 73 65 64 29 3b 0a 20 20 TER(NotUsed);.
3040: 6d 65 6d 73 65 74 28 26 70 63 61 63 68 65 31 2c memset(&pcache1,
3050: 20 30 2c 20 73 69 7a 65 6f 66 28 70 63 61 63 68 0, sizeof(pcach
3060: 65 31 29 29 3b 0a 20 20 69 66 28 20 73 71 6c 69 e1));. if( sqli
3070: 74 65 33 47 6c 6f 62 61 6c 43 6f 6e 66 69 67 2e te3GlobalConfig.
3080: 62 43 6f 72 65 4d 75 74 65 78 20 29 7b 0a 20 20 bCoreMutex ){.
3090: 20 20 70 63 61 63 68 65 31 2e 6d 75 74 65 78 20 pcache1.mutex
30a0: 3d 20 73 71 6c 69 74 65 33 5f 6d 75 74 65 78 5f = sqlite3_mutex_
30b0: 61 6c 6c 6f 63 28 53 51 4c 49 54 45 5f 4d 55 54 alloc(SQLITE_MUT
30c0: 45 58 5f 53 54 41 54 49 43 5f 4c 52 55 29 3b 0a EX_STATIC_LRU);.
30d0: 20 20 7d 0a 20 20 72 65 74 75 72 6e 20 53 51 4c }. return SQL
30e0: 49 54 45 5f 4f 4b 3b 0a 7d 0a 0a 2f 2a 0a 2a 2a ITE_OK;.}../*.**
30f0: 20 49 6d 70 6c 65 6d 65 6e 74 61 74 69 6f 6e 20 Implementation
3100: 6f 66 20 74 68 65 20 73 71 6c 69 74 65 33 5f 70 of the sqlite3_p
3110: 63 61 63 68 65 2e 78 53 68 75 74 64 6f 77 6e 20 cache.xShutdown
3120: 6d 65 74 68 6f 64 2e 0a 2a 2f 0a 73 74 61 74 69 method..*/.stati
3130: 63 20 76 6f 69 64 20 70 63 61 63 68 65 31 53 68 c void pcache1Sh
3140: 75 74 64 6f 77 6e 28 76 6f 69 64 20 2a 4e 6f 74 utdown(void *Not
3150: 55 73 65 64 29 7b 0a 20 20 55 4e 55 53 45 44 5f Used){. UNUSED_
3160: 50 41 52 41 4d 45 54 45 52 28 4e 6f 74 55 73 65 PARAMETER(NotUse
3170: 64 29 3b 0a 20 20 2f 2a 20 6e 6f 2d 6f 70 20 2a d);. /* no-op *
3180: 2f 0a 7d 0a 0a 2f 2a 0a 2a 2a 20 49 6d 70 6c 65 /.}../*.** Imple
3190: 6d 65 6e 74 61 74 69 6f 6e 20 6f 66 20 74 68 65 mentation of the
31a0: 20 73 71 6c 69 74 65 33 5f 70 63 61 63 68 65 2e sqlite3_pcache.
31b0: 78 43 72 65 61 74 65 20 6d 65 74 68 6f 64 2e 0a xCreate method..
31c0: 2a 2a 0a 2a 2a 20 41 6c 6c 6f 63 61 74 65 20 61 **.** Allocate a
31d0: 20 6e 65 77 20 63 61 63 68 65 2e 0a 2a 2f 0a 73 new cache..*/.s
31e0: 74 61 74 69 63 20 73 71 6c 69 74 65 33 5f 70 63 tatic sqlite3_pc
31f0: 61 63 68 65 20 2a 70 63 61 63 68 65 31 43 72 65 ache *pcache1Cre
3200: 61 74 65 28 69 6e 74 20 73 7a 50 61 67 65 2c 20 ate(int szPage,
3210: 69 6e 74 20 62 50 75 72 67 65 61 62 6c 65 29 7b int bPurgeable){
3220: 0a 20 20 50 43 61 63 68 65 31 20 2a 70 43 61 63 . PCache1 *pCac
3230: 68 65 3b 0a 0a 20 20 70 43 61 63 68 65 20 3d 20 he;.. pCache =
3240: 28 50 43 61 63 68 65 31 20 2a 29 73 71 6c 69 74 (PCache1 *)sqlit
3250: 65 33 5f 6d 61 6c 6c 6f 63 28 73 69 7a 65 6f 66 e3_malloc(sizeof
3260: 28 50 43 61 63 68 65 31 29 29 3b 0a 20 20 69 66 (PCache1));. if
3270: 28 20 70 43 61 63 68 65 20 29 7b 0a 20 20 20 20 ( pCache ){.
3280: 6d 65 6d 73 65 74 28 70 43 61 63 68 65 2c 20 30 memset(pCache, 0
3290: 2c 20 73 69 7a 65 6f 66 28 50 43 61 63 68 65 31 , sizeof(PCache1
32a0: 29 29 3b 0a 20 20 20 20 70 43 61 63 68 65 2d 3e ));. pCache->
32b0: 73 7a 50 61 67 65 20 3d 20 73 7a 50 61 67 65 3b szPage = szPage;
32c0: 0a 20 20 20 20 70 43 61 63 68 65 2d 3e 62 50 75 . pCache->bPu
32d0: 72 67 65 61 62 6c 65 20 3d 20 28 62 50 75 72 67 rgeable = (bPurg
32e0: 65 61 62 6c 65 20 3f 20 31 20 3a 20 30 29 3b 0a eable ? 1 : 0);.
32f0: 20 20 20 20 69 66 28 20 62 50 75 72 67 65 61 62 if( bPurgeab
3300: 6c 65 20 29 7b 0a 20 20 20 20 20 20 70 43 61 63 le ){. pCac
3310: 68 65 2d 3e 6e 4d 69 6e 20 3d 20 31 30 3b 0a 20 he->nMin = 10;.
3320: 20 20 20 20 20 70 63 61 63 68 65 31 45 6e 74 65 pcache1Ente
3330: 72 4d 75 74 65 78 28 29 3b 0a 20 20 20 20 20 20 rMutex();.
3340: 70 63 61 63 68 65 31 2e 6e 4d 69 6e 50 61 67 65 pcache1.nMinPage
3350: 20 2b 3d 20 70 43 61 63 68 65 2d 3e 6e 4d 69 6e += pCache->nMin
3360: 3b 0a 20 20 20 20 20 20 70 63 61 63 68 65 31 4c ;. pcache1L
3370: 65 61 76 65 4d 75 74 65 78 28 29 3b 0a 20 20 20 eaveMutex();.
3380: 20 7d 0a 20 20 7d 0a 20 20 72 65 74 75 72 6e 20 }. }. return
3390: 28 73 71 6c 69 74 65 33 5f 70 63 61 63 68 65 20 (sqlite3_pcache
33a0: 2a 29 70 43 61 63 68 65 3b 0a 7d 0a 0a 2f 2a 0a *)pCache;.}../*.
33b0: 2a 2a 20 49 6d 70 6c 65 6d 65 6e 74 61 74 69 6f ** Implementatio
33c0: 6e 20 6f 66 20 74 68 65 20 73 71 6c 69 74 65 33 n of the sqlite3
33d0: 5f 70 63 61 63 68 65 2e 78 43 61 63 68 65 73 69 _pcache.xCachesi
33e0: 7a 65 20 6d 65 74 68 6f 64 2e 20 0a 2a 2a 0a 2a ze method. .**.*
33f0: 2a 20 43 6f 6e 66 69 67 75 72 65 20 74 68 65 20 * Configure the
3400: 63 61 63 68 65 5f 73 69 7a 65 20 6c 69 6d 69 74 cache_size limit
3410: 20 66 6f 72 20 61 20 63 61 63 68 65 2e 0a 2a 2f for a cache..*/
3420: 0a 73 74 61 74 69 63 20 76 6f 69 64 20 70 63 61 .static void pca
3430: 63 68 65 31 43 61 63 68 65 73 69 7a 65 28 73 71 che1Cachesize(sq
3440: 6c 69 74 65 33 5f 70 63 61 63 68 65 20 2a 70 2c lite3_pcache *p,
3450: 20 69 6e 74 20 6e 4d 61 78 29 7b 0a 20 20 50 43 int nMax){. PC
3460: 61 63 68 65 31 20 2a 70 43 61 63 68 65 20 3d 20 ache1 *pCache =
3470: 28 50 43 61 63 68 65 31 20 2a 29 70 3b 0a 20 20 (PCache1 *)p;.
3480: 69 66 28 20 70 43 61 63 68 65 2d 3e 62 50 75 72 if( pCache->bPur
3490: 67 65 61 62 6c 65 20 29 7b 0a 20 20 20 20 70 63 geable ){. pc
34a0: 61 63 68 65 31 45 6e 74 65 72 4d 75 74 65 78 28 ache1EnterMutex(
34b0: 29 3b 0a 20 20 20 20 70 63 61 63 68 65 31 2e 6e );. pcache1.n
34c0: 4d 61 78 50 61 67 65 20 2b 3d 20 28 6e 4d 61 78 MaxPage += (nMax
34d0: 20 2d 20 70 43 61 63 68 65 2d 3e 6e 4d 61 78 29 - pCache->nMax)
34e0: 3b 0a 20 20 20 20 70 43 61 63 68 65 2d 3e 6e 4d ;. pCache->nM
34f0: 61 78 20 3d 20 6e 4d 61 78 3b 0a 20 20 20 20 70 ax = nMax;. p
3500: 63 61 63 68 65 31 45 6e 66 6f 72 63 65 4d 61 78 cache1EnforceMax
3510: 50 61 67 65 28 29 3b 0a 20 20 20 20 70 63 61 63 Page();. pcac
3520: 68 65 31 4c 65 61 76 65 4d 75 74 65 78 28 29 3b he1LeaveMutex();
3530: 0a 20 20 7d 0a 7d 0a 0a 2f 2a 0a 2a 2a 20 49 6d . }.}../*.** Im
3540: 70 6c 65 6d 65 6e 74 61 74 69 6f 6e 20 6f 66 20 plementation of
3550: 74 68 65 20 73 71 6c 69 74 65 33 5f 70 63 61 63 the sqlite3_pcac
3560: 68 65 2e 78 50 61 67 65 63 6f 75 6e 74 20 6d 65 he.xPagecount me
3570: 74 68 6f 64 2e 20 0a 2a 2f 0a 73 74 61 74 69 63 thod. .*/.static
3580: 20 69 6e 74 20 70 63 61 63 68 65 31 50 61 67 65 int pcache1Page
3590: 63 6f 75 6e 74 28 73 71 6c 69 74 65 33 5f 70 63 count(sqlite3_pc
35a0: 61 63 68 65 20 2a 70 29 7b 0a 20 20 69 6e 74 20 ache *p){. int
35b0: 6e 3b 0a 20 20 70 63 61 63 68 65 31 45 6e 74 65 n;. pcache1Ente
35c0: 72 4d 75 74 65 78 28 29 3b 0a 20 20 6e 20 3d 20 rMutex();. n =
35d0: 28 28 50 43 61 63 68 65 31 20 2a 29 70 29 2d 3e ((PCache1 *)p)->
35e0: 6e 50 61 67 65 3b 0a 20 20 70 63 61 63 68 65 31 nPage;. pcache1
35f0: 4c 65 61 76 65 4d 75 74 65 78 28 29 3b 0a 20 20 LeaveMutex();.
3600: 72 65 74 75 72 6e 20 6e 3b 0a 7d 0a 0a 2f 2a 0a return n;.}../*.
3610: 2a 2a 20 49 6d 70 6c 65 6d 65 6e 74 61 74 69 6f ** Implementatio
3620: 6e 20 6f 66 20 74 68 65 20 73 71 6c 69 74 65 33 n of the sqlite3
3630: 5f 70 63 61 63 68 65 2e 78 46 65 74 63 68 20 6d _pcache.xFetch m
3640: 65 74 68 6f 64 2e 20 0a 2a 2a 0a 2a 2a 20 46 65 ethod. .**.** Fe
3650: 74 63 68 20 61 20 70 61 67 65 20 62 79 20 6b 65 tch a page by ke
3660: 79 20 76 61 6c 75 65 2e 0a 2a 2a 0a 2a 2a 20 57 y value..**.** W
3670: 68 65 74 68 65 72 20 6f 72 20 6e 6f 74 20 61 20 hether or not a
3680: 6e 65 77 20 70 61 67 65 20 6d 61 79 20 62 65 20 new page may be
3690: 61 6c 6c 6f 63 61 74 65 64 20 62 79 20 74 68 69 allocated by thi
36a0: 73 20 66 75 6e 63 74 69 6f 6e 20 64 65 70 65 6e s function depen
36b0: 64 73 20 6f 6e 0a 2a 2a 20 74 68 65 20 76 61 6c ds on.** the val
36c0: 75 65 20 6f 66 20 74 68 65 20 63 72 65 61 74 65 ue of the create
36d0: 46 6c 61 67 20 61 72 67 75 6d 65 6e 74 2e 0a 2a Flag argument..*
36e0: 2a 0a 2a 2a 20 54 68 65 72 65 20 61 72 65 20 74 *.** There are t
36f0: 68 72 65 65 20 64 69 66 66 65 72 65 6e 74 20 61 hree different a
3700: 70 70 72 6f 61 63 68 65 73 20 74 6f 20 6f 62 74 pproaches to obt
3710: 61 69 6e 69 6e 67 20 73 70 61 63 65 20 66 6f 72 aining space for
3720: 20 61 20 70 61 67 65 2c 0a 2a 2a 20 64 65 70 65 a page,.** depe
3730: 6e 64 69 6e 67 20 6f 6e 20 74 68 65 20 76 61 6c nding on the val
3740: 75 65 20 6f 66 20 70 61 72 61 6d 65 74 65 72 20 ue of parameter
3750: 63 72 65 61 74 65 46 6c 61 67 20 28 77 68 69 63 createFlag (whic
3760: 68 20 6d 61 79 20 62 65 20 30 2c 20 31 20 6f 72 h may be 0, 1 or
3770: 20 32 29 2e 0a 2a 2a 0a 2a 2a 20 20 20 31 2e 20 2)..**.** 1.
3780: 52 65 67 61 72 64 6c 65 73 73 20 6f 66 20 74 68 Regardless of th
3790: 65 20 76 61 6c 75 65 20 6f 66 20 63 72 65 61 74 e value of creat
37a0: 65 46 6c 61 67 2c 20 74 68 65 20 63 61 63 68 65 eFlag, the cache
37b0: 20 69 73 20 73 65 61 72 63 68 65 64 20 66 6f 72 is searched for
37c0: 20 61 20 0a 2a 2a 20 20 20 20 20 20 63 6f 70 79 a .** copy
37d0: 20 6f 66 20 74 68 65 20 72 65 71 75 65 73 74 65 of the requeste
37e0: 64 20 70 61 67 65 2e 20 49 66 20 6f 6e 65 20 69 d page. If one i
37f0: 73 20 66 6f 75 6e 64 2c 20 69 74 20 69 73 20 72 s found, it is r
3800: 65 74 75 72 6e 65 64 2e 0a 2a 2a 0a 2a 2a 20 20 eturned..**.**
3810: 20 32 2e 20 49 66 20 63 72 65 61 74 65 46 6c 61 2. If createFla
3820: 67 3d 3d 30 20 61 6e 64 20 74 68 65 20 70 61 67 g==0 and the pag
3830: 65 20 69 73 20 6e 6f 74 20 61 6c 72 65 61 64 79 e is not already
3840: 20 69 6e 20 74 68 65 20 63 61 63 68 65 2c 20 4e in the cache, N
3850: 55 4c 4c 20 69 73 0a 2a 2a 20 20 20 20 20 20 72 ULL is.** r
3860: 65 74 75 72 6e 65 64 2e 0a 2a 2a 0a 2a 2a 20 20 eturned..**.**
3870: 20 33 2e 20 49 66 20 63 72 65 61 74 65 46 6c 61 3. If createFla
3880: 67 20 69 73 20 31 2c 20 74 68 65 20 63 61 63 68 g is 1, the cach
3890: 65 20 69 73 20 6d 61 72 6b 65 64 20 61 73 20 70 e is marked as p
38a0: 75 72 67 65 61 62 6c 65 20 61 6e 64 20 74 68 65 urgeable and the
38b0: 20 70 61 67 65 20 69 73 20 0a 2a 2a 20 20 20 20 page is .**
38c0: 20 20 6e 6f 74 20 61 6c 72 65 61 64 79 20 69 6e not already in
38d0: 20 74 68 65 20 63 61 63 68 65 2c 20 61 6e 64 20 the cache, and
38e0: 69 66 20 65 69 74 68 65 72 20 6f 66 20 74 68 65 if either of the
38f0: 20 66 6f 6c 6c 6f 77 69 6e 67 20 61 72 65 20 74 following are t
3900: 72 75 65 2c 20 0a 2a 2a 20 20 20 20 20 20 72 65 rue, .** re
3910: 74 75 72 6e 20 4e 55 4c 4c 3a 0a 2a 2a 0a 2a 2a turn NULL:.**.**
3920: 20 20 20 20 20 20 20 28 61 29 20 74 68 65 20 6e (a) the n
3930: 75 6d 62 65 72 20 6f 66 20 70 61 67 65 73 20 70 umber of pages p
3940: 69 6e 6e 65 64 20 62 79 20 74 68 65 20 63 61 63 inned by the cac
3950: 68 65 20 69 73 20 67 72 65 61 74 65 72 20 74 68 he is greater th
3960: 61 6e 0a 2a 2a 20 20 20 20 20 20 20 20 20 20 20 an.**
3970: 50 43 61 63 68 65 31 2e 6e 4d 61 78 2c 20 6f 72 PCache1.nMax, or
3980: 0a 2a 2a 20 20 20 20 20 20 20 28 62 29 20 74 68 .** (b) th
3990: 65 20 6e 75 6d 62 65 72 20 6f 66 20 70 61 67 65 e number of page
39a0: 73 20 70 69 6e 6e 65 64 20 62 79 20 74 68 65 20 s pinned by the
39b0: 63 61 63 68 65 20 69 73 20 67 72 65 61 74 65 72 cache is greater
39c0: 20 74 68 61 6e 0a 2a 2a 20 20 20 20 20 20 20 20 than.**
39d0: 20 20 20 74 68 65 20 73 75 6d 20 6f 66 20 6e 4d the sum of nM
39e0: 61 78 20 66 6f 72 20 61 6c 6c 20 70 75 72 67 65 ax for all purge
39f0: 61 62 6c 65 20 63 61 63 68 65 73 2c 20 6c 65 73 able caches, les
3a00: 73 20 74 68 65 20 73 75 6d 20 6f 66 20 0a 2a 2a s the sum of .**
3a10: 20 20 20 20 20 20 20 20 20 20 20 6e 4d 69 6e 20 nMin
3a20: 66 6f 72 20 61 6c 6c 20 6f 74 68 65 72 20 70 75 for all other pu
3a30: 72 67 65 61 62 6c 65 20 63 61 63 68 65 73 2e 20 rgeable caches.
3a40: 0a 2a 2a 0a 2a 2a 20 20 20 34 2e 20 49 66 20 6e .**.** 4. If n
3a50: 6f 6e 65 20 6f 66 20 74 68 65 20 66 69 72 73 74 one of the first
3a60: 20 74 68 72 65 65 20 63 6f 6e 64 69 74 69 6f 6e three condition
3a70: 73 20 61 70 70 6c 79 20 61 6e 64 20 74 68 65 20 s apply and the
3a80: 63 61 63 68 65 20 69 73 20 6d 61 72 6b 65 64 0a cache is marked.
3a90: 2a 2a 20 20 20 20 20 20 61 73 20 70 75 72 67 65 ** as purge
3aa0: 61 62 6c 65 2c 20 61 6e 64 20 69 66 20 6f 6e 65 able, and if one
3ab0: 20 6f 66 20 74 68 65 20 66 6f 6c 6c 6f 77 69 6e of the followin
3ac0: 67 20 69 73 20 74 72 75 65 3a 0a 2a 2a 0a 2a 2a g is true:.**.**
3ad0: 20 20 20 20 20 20 20 28 61 29 20 54 68 65 20 6e (a) The n
3ae0: 75 6d 62 65 72 20 6f 66 20 70 61 67 65 73 20 61 umber of pages a
3af0: 6c 6c 6f 63 61 74 65 64 20 66 6f 72 20 74 68 65 llocated for the
3b00: 20 63 61 63 68 65 20 69 73 20 61 6c 72 65 61 64 cache is alread
3b10: 79 20 0a 2a 2a 20 20 20 20 20 20 20 20 20 20 20 y .**
3b20: 50 43 61 63 68 65 31 2e 6e 4d 61 78 2c 20 6f 72 PCache1.nMax, or
3b30: 0a 2a 2a 0a 2a 2a 20 20 20 20 20 20 20 28 62 29 .**.** (b)
3b40: 20 54 68 65 20 6e 75 6d 62 65 72 20 6f 66 20 70 The number of p
3b50: 61 67 65 73 20 61 6c 6c 6f 63 61 74 65 64 20 66 ages allocated f
3b60: 6f 72 20 61 6c 6c 20 70 75 72 67 65 61 62 6c 65 or all purgeable
3b70: 20 63 61 63 68 65 73 20 69 73 0a 2a 2a 20 20 20 caches is.**
3b80: 20 20 20 20 20 20 20 20 61 6c 72 65 61 64 79 20 already
3b90: 65 71 75 61 6c 20 74 6f 20 6f 72 20 67 72 65 61 equal to or grea
3ba0: 74 65 72 20 74 68 61 6e 20 74 68 65 20 73 75 6d ter than the sum
3bb0: 20 6f 66 20 6e 4d 61 78 20 66 6f 72 20 61 6c 6c of nMax for all
3bc0: 0a 2a 2a 20 20 20 20 20 20 20 20 20 20 20 70 75 .** pu
3bd0: 72 67 65 61 62 6c 65 20 63 61 63 68 65 73 2c 0a rgeable caches,.
3be0: 2a 2a 0a 2a 2a 20 20 20 20 20 20 74 68 65 6e 20 **.** then
3bf0: 61 74 74 65 6d 70 74 20 74 6f 20 72 65 63 79 63 attempt to recyc
3c00: 6c 65 20 61 20 70 61 67 65 20 66 72 6f 6d 20 74 le a page from t
3c10: 68 65 20 4c 52 55 20 6c 69 73 74 2e 20 49 66 20 he LRU list. If
3c20: 69 74 20 69 73 20 74 68 65 20 72 69 67 68 74 0a it is the right.
3c30: 2a 2a 20 20 20 20 20 20 73 69 7a 65 2c 20 72 65 ** size, re
3c40: 74 75 72 6e 20 74 68 65 20 72 65 63 79 63 6c 65 turn the recycle
3c50: 64 20 62 75 66 66 65 72 2e 20 4f 74 68 65 72 77 d buffer. Otherw
3c60: 69 73 65 2c 20 66 72 65 65 20 74 68 65 20 62 75 ise, free the bu
3c70: 66 66 65 72 20 61 6e 64 0a 2a 2a 20 20 20 20 20 ffer and.**
3c80: 20 70 72 6f 63 65 65 64 20 74 6f 20 73 74 65 70 proceed to step
3c90: 20 35 2e 20 0a 2a 2a 0a 2a 2a 20 20 20 35 2e 20 5. .**.** 5.
3ca0: 4f 74 68 65 72 77 69 73 65 2c 20 61 6c 6c 6f 63 Otherwise, alloc
3cb0: 61 74 65 20 61 6e 64 20 72 65 74 75 72 6e 20 61 ate and return a
3cc0: 20 6e 65 77 20 70 61 67 65 20 62 75 66 66 65 72 new page buffer
3cd0: 2e 0a 2a 2f 0a 73 74 61 74 69 63 20 76 6f 69 64 ..*/.static void
3ce0: 20 2a 70 63 61 63 68 65 31 46 65 74 63 68 28 73 *pcache1Fetch(s
3cf0: 71 6c 69 74 65 33 5f 70 63 61 63 68 65 20 2a 70 qlite3_pcache *p
3d00: 2c 20 75 6e 73 69 67 6e 65 64 20 69 6e 74 20 69 , unsigned int i
3d10: 4b 65 79 2c 20 69 6e 74 20 63 72 65 61 74 65 46 Key, int createF
3d20: 6c 61 67 29 7b 0a 20 20 75 6e 73 69 67 6e 65 64 lag){. unsigned
3d30: 20 69 6e 74 20 6e 50 69 6e 6e 65 64 3b 0a 20 20 int nPinned;.
3d40: 50 43 61 63 68 65 31 20 2a 70 43 61 63 68 65 20 PCache1 *pCache
3d50: 3d 20 28 50 43 61 63 68 65 31 20 2a 29 70 3b 0a = (PCache1 *)p;.
3d60: 20 20 50 67 48 64 72 31 20 2a 70 50 61 67 65 20 PgHdr1 *pPage
3d70: 3d 20 30 3b 0a 0a 20 20 70 63 61 63 68 65 31 45 = 0;.. pcache1E
3d80: 6e 74 65 72 4d 75 74 65 78 28 29 3b 0a 20 20 69 nterMutex();. i
3d90: 66 28 20 63 72 65 61 74 65 46 6c 61 67 3d 3d 31 f( createFlag==1
3da0: 20 29 20 73 71 6c 69 74 65 33 42 65 67 69 6e 42 ) sqlite3BeginB
3db0: 65 6e 69 67 6e 4d 61 6c 6c 6f 63 28 29 3b 0a 0a enignMalloc();..
3dc0: 20 20 2f 2a 20 53 65 61 72 63 68 20 74 68 65 20 /* Search the
3dd0: 68 61 73 68 20 74 61 62 6c 65 20 66 6f 72 20 61 hash table for a
3de0: 6e 20 65 78 69 73 74 69 6e 67 20 65 6e 74 72 79 n existing entry
3df0: 2e 20 2a 2f 0a 20 20 69 66 28 20 70 43 61 63 68 . */. if( pCach
3e00: 65 2d 3e 6e 48 61 73 68 3e 30 20 29 7b 0a 20 20 e->nHash>0 ){.
3e10: 20 20 75 6e 73 69 67 6e 65 64 20 69 6e 74 20 68 unsigned int h
3e20: 20 3d 20 69 4b 65 79 20 25 20 70 43 61 63 68 65 = iKey % pCache
3e30: 2d 3e 6e 48 61 73 68 3b 0a 20 20 20 20 66 6f 72 ->nHash;. for
3e40: 28 70 50 61 67 65 3d 70 43 61 63 68 65 2d 3e 61 (pPage=pCache->a
3e50: 70 48 61 73 68 5b 68 5d 3b 20 70 50 61 67 65 26 pHash[h]; pPage&
3e60: 26 70 50 61 67 65 2d 3e 69 4b 65 79 21 3d 69 4b &pPage->iKey!=iK
3e70: 65 79 3b 20 70 50 61 67 65 3d 70 50 61 67 65 2d ey; pPage=pPage-
3e80: 3e 70 4e 65 78 74 29 3b 0a 20 20 7d 0a 0a 20 20 >pNext);. }..
3e90: 69 66 28 20 70 50 61 67 65 20 7c 7c 20 63 72 65 if( pPage || cre
3ea0: 61 74 65 46 6c 61 67 3d 3d 30 20 29 7b 0a 20 20 ateFlag==0 ){.
3eb0: 20 20 70 63 61 63 68 65 31 50 69 6e 50 61 67 65 pcache1PinPage
3ec0: 28 70 50 61 67 65 29 3b 0a 20 20 20 20 67 6f 74 (pPage);. got
3ed0: 6f 20 66 65 74 63 68 5f 6f 75 74 3b 0a 20 20 7d o fetch_out;. }
3ee0: 0a 0a 20 20 2f 2a 20 53 74 65 70 20 33 20 6f 66 .. /* Step 3 of
3ef0: 20 68 65 61 64 65 72 20 63 6f 6d 6d 65 6e 74 2e header comment.
3f00: 20 2a 2f 0a 20 20 6e 50 69 6e 6e 65 64 20 3d 20 */. nPinned =
3f10: 70 43 61 63 68 65 2d 3e 6e 50 61 67 65 20 2d 20 pCache->nPage -
3f20: 70 43 61 63 68 65 2d 3e 6e 52 65 63 79 63 6c 61 pCache->nRecycla
3f30: 62 6c 65 3b 0a 20 20 69 66 28 20 63 72 65 61 74 ble;. if( creat
3f40: 65 46 6c 61 67 3d 3d 31 20 26 26 20 70 43 61 63 eFlag==1 && pCac
3f50: 68 65 2d 3e 62 50 75 72 67 65 61 62 6c 65 20 26 he->bPurgeable &
3f60: 26 20 28 0a 20 20 20 20 20 20 20 20 6e 50 69 6e & (. nPin
3f70: 6e 65 64 3e 3d 28 70 63 61 63 68 65 31 2e 6e 4d ned>=(pcache1.nM
3f80: 61 78 50 61 67 65 2b 70 43 61 63 68 65 2d 3e 6e axPage+pCache->n
3f90: 4d 69 6e 2d 70 63 61 63 68 65 31 2e 6e 4d 69 6e Min-pcache1.nMin
3fa0: 50 61 67 65 29 0a 20 20 20 20 20 7c 7c 20 6e 50 Page). || nP
3fb0: 69 6e 6e 65 64 3e 3d 28 70 43 61 63 68 65 2d 3e inned>=(pCache->
3fc0: 6e 4d 61 78 20 2a 20 39 20 2f 20 31 30 29 0a 20 nMax * 9 / 10).
3fd0: 20 29 29 7b 0a 20 20 20 20 67 6f 74 6f 20 66 65 )){. goto fe
3fe0: 74 63 68 5f 6f 75 74 3b 0a 20 20 7d 0a 0a 20 20 tch_out;. }..
3ff0: 69 66 28 20 70 43 61 63 68 65 2d 3e 6e 50 61 67 if( pCache->nPag
4000: 65 3e 3d 70 43 61 63 68 65 2d 3e 6e 48 61 73 68 e>=pCache->nHash
4010: 20 26 26 20 70 63 61 63 68 65 31 52 65 73 69 7a && pcache1Resiz
4020: 65 48 61 73 68 28 70 43 61 63 68 65 29 20 29 7b eHash(pCache) ){
4030: 0a 20 20 20 20 67 6f 74 6f 20 66 65 74 63 68 5f . goto fetch_
4040: 6f 75 74 3b 0a 20 20 7d 0a 0a 20 20 2f 2a 20 53 out;. }.. /* S
4050: 74 65 70 20 34 2e 20 54 72 79 20 74 6f 20 72 65 tep 4. Try to re
4060: 63 79 63 6c 65 20 61 20 70 61 67 65 20 62 75 66 cycle a page buf
4070: 66 65 72 20 69 66 20 61 70 70 72 6f 70 72 69 61 fer if appropria
4080: 74 65 2e 20 2a 2f 0a 20 20 69 66 28 20 70 43 61 te. */. if( pCa
4090: 63 68 65 2d 3e 62 50 75 72 67 65 61 62 6c 65 20 che->bPurgeable
40a0: 26 26 20 70 63 61 63 68 65 31 2e 70 4c 72 75 54 && pcache1.pLruT
40b0: 61 69 6c 20 26 26 20 28 0a 20 20 20 20 20 20 70 ail && (. p
40c0: 43 61 63 68 65 2d 3e 6e 50 61 67 65 3e 3d 70 43 Cache->nPage>=pC
40d0: 61 63 68 65 2d 3e 6e 4d 61 78 2d 31 20 7c 7c 20 ache->nMax-1 ||
40e0: 70 63 61 63 68 65 31 2e 6e 43 75 72 72 65 6e 74 pcache1.nCurrent
40f0: 50 61 67 65 3e 3d 70 63 61 63 68 65 31 2e 6e 4d Page>=pcache1.nM
4100: 61 78 50 61 67 65 0a 20 20 29 29 7b 0a 20 20 20 axPage. )){.
4110: 20 70 50 61 67 65 20 3d 20 70 63 61 63 68 65 31 pPage = pcache1
4120: 2e 70 4c 72 75 54 61 69 6c 3b 0a 20 20 20 20 70 .pLruTail;. p
4130: 63 61 63 68 65 31 52 65 6d 6f 76 65 46 72 6f 6d cache1RemoveFrom
4140: 48 61 73 68 28 70 50 61 67 65 29 3b 0a 20 20 20 Hash(pPage);.
4150: 20 70 63 61 63 68 65 31 50 69 6e 50 61 67 65 28 pcache1PinPage(
4160: 70 50 61 67 65 29 3b 0a 20 20 20 20 69 66 28 20 pPage);. if(
4170: 70 50 61 67 65 2d 3e 70 43 61 63 68 65 2d 3e 73 pPage->pCache->s
4180: 7a 50 61 67 65 21 3d 70 43 61 63 68 65 2d 3e 73 zPage!=pCache->s
4190: 7a 50 61 67 65 20 29 7b 0a 20 20 20 20 20 20 70 zPage ){. p
41a0: 63 61 63 68 65 31 46 72 65 65 50 61 67 65 28 70 cache1FreePage(p
41b0: 50 61 67 65 29 3b 0a 20 20 20 20 20 20 70 50 61 Page);. pPa
41c0: 67 65 20 3d 20 30 3b 0a 20 20 20 20 7d 65 6c 73 ge = 0;. }els
41d0: 65 7b 0a 20 20 20 20 20 20 70 63 61 63 68 65 31 e{. pcache1
41e0: 2e 6e 43 75 72 72 65 6e 74 50 61 67 65 20 2d 3d .nCurrentPage -=
41f0: 20 28 70 50 61 67 65 2d 3e 70 43 61 63 68 65 2d (pPage->pCache-
4200: 3e 62 50 75 72 67 65 61 62 6c 65 20 2d 20 70 43 >bPurgeable - pC
4210: 61 63 68 65 2d 3e 62 50 75 72 67 65 61 62 6c 65 ache->bPurgeable
4220: 29 3b 0a 20 20 20 20 7d 0a 20 20 7d 0a 0a 20 20 );. }. }..
4230: 2f 2a 20 53 74 65 70 20 35 2e 20 49 66 20 61 20 /* Step 5. If a
4240: 75 73 61 62 6c 65 20 70 61 67 65 20 62 75 66 66 usable page buff
4250: 65 72 20 68 61 73 20 73 74 69 6c 6c 20 6e 6f 74 er has still not
4260: 20 62 65 65 6e 20 66 6f 75 6e 64 2c 20 0a 20 20 been found, .
4270: 2a 2a 20 61 74 74 65 6d 70 74 20 74 6f 20 61 6c ** attempt to al
4280: 6c 6f 63 61 74 65 20 61 20 6e 65 77 20 6f 6e 65 locate a new one
4290: 2e 20 0a 20 20 2a 2f 0a 20 20 69 66 28 20 21 70 . . */. if( !p
42a0: 50 61 67 65 20 29 7b 0a 20 20 20 20 70 50 61 67 Page ){. pPag
42b0: 65 20 3d 20 70 63 61 63 68 65 31 41 6c 6c 6f 63 e = pcache1Alloc
42c0: 50 61 67 65 28 70 43 61 63 68 65 29 3b 0a 20 20 Page(pCache);.
42d0: 7d 0a 0a 20 20 69 66 28 20 70 50 61 67 65 20 29 }.. if( pPage )
42e0: 7b 0a 20 20 20 20 75 6e 73 69 67 6e 65 64 20 69 {. unsigned i
42f0: 6e 74 20 68 20 3d 20 69 4b 65 79 20 25 20 70 43 nt h = iKey % pC
4300: 61 63 68 65 2d 3e 6e 48 61 73 68 3b 0a 20 20 20 ache->nHash;.
4310: 20 2a 28 76 6f 69 64 20 2a 2a 29 28 50 47 48 44 *(void **)(PGHD
4320: 52 31 5f 54 4f 5f 50 41 47 45 28 70 50 61 67 65 R1_TO_PAGE(pPage
4330: 29 29 20 3d 20 30 3b 0a 20 20 20 20 70 43 61 63 )) = 0;. pCac
4340: 68 65 2d 3e 6e 50 61 67 65 2b 2b 3b 0a 20 20 20 he->nPage++;.
4350: 20 70 50 61 67 65 2d 3e 69 4b 65 79 20 3d 20 69 pPage->iKey = i
4360: 4b 65 79 3b 0a 20 20 20 20 70 50 61 67 65 2d 3e Key;. pPage->
4370: 70 4e 65 78 74 20 3d 20 70 43 61 63 68 65 2d 3e pNext = pCache->
4380: 61 70 48 61 73 68 5b 68 5d 3b 0a 20 20 20 20 70 apHash[h];. p
4390: 50 61 67 65 2d 3e 70 43 61 63 68 65 20 3d 20 70 Page->pCache = p
43a0: 43 61 63 68 65 3b 0a 20 20 20 20 70 50 61 67 65 Cache;. pPage
43b0: 2d 3e 70 4c 72 75 50 72 65 76 20 3d 20 30 3b 0a ->pLruPrev = 0;.
43c0: 20 20 20 20 70 50 61 67 65 2d 3e 70 4c 72 75 4e pPage->pLruN
43d0: 65 78 74 20 3d 20 30 3b 0a 20 20 20 20 70 43 61 ext = 0;. pCa
43e0: 63 68 65 2d 3e 61 70 48 61 73 68 5b 68 5d 20 3d che->apHash[h] =
43f0: 20 70 50 61 67 65 3b 0a 20 20 7d 0a 0a 66 65 74 pPage;. }..fet
4400: 63 68 5f 6f 75 74 3a 0a 20 20 69 66 28 20 70 50 ch_out:. if( pP
4410: 61 67 65 20 26 26 20 69 4b 65 79 3e 70 43 61 63 age && iKey>pCac
4420: 68 65 2d 3e 69 4d 61 78 4b 65 79 20 29 7b 0a 20 he->iMaxKey ){.
4430: 20 20 20 70 43 61 63 68 65 2d 3e 69 4d 61 78 4b pCache->iMaxK
4440: 65 79 20 3d 20 69 4b 65 79 3b 0a 20 20 7d 0a 20 ey = iKey;. }.
4450: 20 69 66 28 20 63 72 65 61 74 65 46 6c 61 67 3d if( createFlag=
4460: 3d 31 20 29 20 73 71 6c 69 74 65 33 45 6e 64 42 =1 ) sqlite3EndB
4470: 65 6e 69 67 6e 4d 61 6c 6c 6f 63 28 29 3b 0a 20 enignMalloc();.
4480: 20 70 63 61 63 68 65 31 4c 65 61 76 65 4d 75 74 pcache1LeaveMut
4490: 65 78 28 29 3b 0a 20 20 72 65 74 75 72 6e 20 28 ex();. return (
44a0: 70 50 61 67 65 20 3f 20 50 47 48 44 52 31 5f 54 pPage ? PGHDR1_T
44b0: 4f 5f 50 41 47 45 28 70 50 61 67 65 29 20 3a 20 O_PAGE(pPage) :
44c0: 30 29 3b 0a 7d 0a 0a 0a 2f 2a 0a 2a 2a 20 49 6d 0);.}.../*.** Im
44d0: 70 6c 65 6d 65 6e 74 61 74 69 6f 6e 20 6f 66 20 plementation of
44e0: 74 68 65 20 73 71 6c 69 74 65 33 5f 70 63 61 63 the sqlite3_pcac
44f0: 68 65 2e 78 55 6e 70 69 6e 20 6d 65 74 68 6f 64 he.xUnpin method
4500: 2e 0a 2a 2a 0a 2a 2a 20 4d 61 72 6b 20 61 20 70 ..**.** Mark a p
4510: 61 67 65 20 61 73 20 75 6e 70 69 6e 6e 65 64 20 age as unpinned
4520: 28 65 6c 69 67 69 62 6c 65 20 66 6f 72 20 61 73 (eligible for as
4530: 79 6e 63 68 72 6f 6e 6f 75 73 20 72 65 63 79 63 ynchronous recyc
4540: 6c 69 6e 67 29 2e 0a 2a 2f 0a 73 74 61 74 69 63 ling)..*/.static
4550: 20 76 6f 69 64 20 70 63 61 63 68 65 31 55 6e 70 void pcache1Unp
4560: 69 6e 28 73 71 6c 69 74 65 33 5f 70 63 61 63 68 in(sqlite3_pcach
4570: 65 20 2a 70 2c 20 76 6f 69 64 20 2a 70 50 67 2c e *p, void *pPg,
4580: 20 69 6e 74 20 72 65 75 73 65 55 6e 6c 69 6b 65 int reuseUnlike
4590: 6c 79 29 7b 0a 20 20 50 43 61 63 68 65 31 20 2a ly){. PCache1 *
45a0: 70 43 61 63 68 65 20 3d 20 28 50 43 61 63 68 65 pCache = (PCache
45b0: 31 20 2a 29 70 3b 0a 20 20 50 67 48 64 72 31 20 1 *)p;. PgHdr1
45c0: 2a 70 50 61 67 65 20 3d 20 50 41 47 45 5f 54 4f *pPage = PAGE_TO
45d0: 5f 50 47 48 44 52 31 28 70 50 67 29 3b 0a 0a 20 _PGHDR1(pPg);..
45e0: 20 70 63 61 63 68 65 31 45 6e 74 65 72 4d 75 74 pcache1EnterMut
45f0: 65 78 28 29 3b 0a 0a 20 20 2f 2a 20 49 74 20 69 ex();.. /* It i
4600: 73 20 61 6e 20 65 72 72 6f 72 20 74 6f 20 63 61 s an error to ca
4610: 6c 6c 20 74 68 69 73 20 66 75 6e 63 74 69 6f 6e ll this function
4620: 20 69 66 20 74 68 65 20 70 61 67 65 20 69 73 20 if the page is
4630: 61 6c 72 65 61 64 79 20 0a 20 20 2a 2a 20 70 61 already . ** pa
4640: 72 74 20 6f 66 20 74 68 65 20 67 6c 6f 62 61 6c rt of the global
4650: 20 4c 52 55 20 6c 69 73 74 2e 0a 20 20 2a 2f 0a LRU list.. */.
4660: 20 20 61 73 73 65 72 74 28 20 70 50 61 67 65 2d assert( pPage-
4670: 3e 70 4c 72 75 50 72 65 76 3d 3d 30 20 26 26 20 >pLruPrev==0 &&
4680: 70 50 61 67 65 2d 3e 70 4c 72 75 4e 65 78 74 3d pPage->pLruNext=
4690: 3d 30 20 29 3b 0a 20 20 61 73 73 65 72 74 28 20 =0 );. assert(
46a0: 70 63 61 63 68 65 31 2e 70 4c 72 75 48 65 61 64 pcache1.pLruHead
46b0: 21 3d 70 50 61 67 65 20 26 26 20 70 63 61 63 68 !=pPage && pcach
46c0: 65 31 2e 70 4c 72 75 54 61 69 6c 21 3d 70 50 61 e1.pLruTail!=pPa
46d0: 67 65 20 29 3b 0a 0a 20 20 69 66 28 20 72 65 75 ge );.. if( reu
46e0: 73 65 55 6e 6c 69 6b 65 6c 79 20 7c 7c 20 70 63 seUnlikely || pc
46f0: 61 63 68 65 31 2e 6e 43 75 72 72 65 6e 74 50 61 ache1.nCurrentPa
4700: 67 65 3e 70 63 61 63 68 65 31 2e 6e 4d 61 78 50 ge>pcache1.nMaxP
4710: 61 67 65 20 29 7b 0a 20 20 20 20 70 63 61 63 68 age ){. pcach
4720: 65 31 52 65 6d 6f 76 65 46 72 6f 6d 48 61 73 68 e1RemoveFromHash
4730: 28 70 50 61 67 65 29 3b 0a 20 20 20 20 70 63 61 (pPage);. pca
4740: 63 68 65 31 46 72 65 65 50 61 67 65 28 70 50 61 che1FreePage(pPa
4750: 67 65 29 3b 0a 20 20 7d 65 6c 73 65 7b 0a 20 20 ge);. }else{.
4760: 20 20 2f 2a 20 41 64 64 20 74 68 65 20 70 61 67 /* Add the pag
4770: 65 20 74 6f 20 74 68 65 20 67 6c 6f 62 61 6c 20 e to the global
4780: 4c 52 55 20 6c 69 73 74 2e 20 4e 6f 72 6d 61 6c LRU list. Normal
4790: 6c 79 2c 20 74 68 65 20 70 61 67 65 20 69 73 20 ly, the page is
47a0: 61 64 64 65 64 20 74 6f 0a 20 20 20 20 2a 2a 20 added to. **
47b0: 74 68 65 20 68 65 61 64 20 6f 66 20 74 68 65 20 the head of the
47c0: 6c 69 73 74 20 28 6c 61 73 74 20 70 61 67 65 20 list (last page
47d0: 74 6f 20 62 65 20 72 65 63 79 63 6c 65 64 29 2e to be recycled).
47e0: 20 48 6f 77 65 76 65 72 2c 20 69 66 20 74 68 65 However, if the
47f0: 20 0a 20 20 20 20 2a 2a 20 72 65 75 73 65 55 6e . ** reuseUn
4800: 6c 69 6b 65 6c 79 20 66 6c 61 67 20 70 61 73 73 likely flag pass
4810: 65 64 20 74 6f 20 74 68 69 73 20 66 75 6e 63 74 ed to this funct
4820: 69 6f 6e 20 69 73 20 74 72 75 65 2c 20 74 68 65 ion is true, the
4830: 20 70 61 67 65 20 69 73 20 61 64 64 65 64 0a 20 page is added.
4840: 20 20 20 2a 2a 20 74 6f 20 74 68 65 20 74 61 69 ** to the tai
4850: 6c 20 6f 66 20 74 68 65 20 6c 69 73 74 20 28 66 l of the list (f
4860: 69 72 73 74 20 70 61 67 65 20 74 6f 20 62 65 20 irst page to be
4870: 72 65 63 79 63 6c 65 64 29 2e 0a 20 20 20 20 2a recycled).. *
4880: 2f 0a 20 20 20 20 69 66 28 20 70 63 61 63 68 65 /. if( pcache
4890: 31 2e 70 4c 72 75 48 65 61 64 20 29 7b 0a 20 20 1.pLruHead ){.
48a0: 20 20 20 20 70 63 61 63 68 65 31 2e 70 4c 72 75 pcache1.pLru
48b0: 48 65 61 64 2d 3e 70 4c 72 75 50 72 65 76 20 3d Head->pLruPrev =
48c0: 20 70 50 61 67 65 3b 0a 20 20 20 20 20 20 70 50 pPage;. pP
48d0: 61 67 65 2d 3e 70 4c 72 75 4e 65 78 74 20 3d 20 age->pLruNext =
48e0: 70 63 61 63 68 65 31 2e 70 4c 72 75 48 65 61 64 pcache1.pLruHead
48f0: 3b 0a 20 20 20 20 20 20 70 63 61 63 68 65 31 2e ;. pcache1.
4900: 70 4c 72 75 48 65 61 64 20 3d 20 70 50 61 67 65 pLruHead = pPage
4910: 3b 0a 20 20 20 20 7d 65 6c 73 65 7b 0a 20 20 20 ;. }else{.
4920: 20 20 20 70 63 61 63 68 65 31 2e 70 4c 72 75 54 pcache1.pLruT
4930: 61 69 6c 20 3d 20 70 50 61 67 65 3b 0a 20 20 20 ail = pPage;.
4940: 20 20 20 70 63 61 63 68 65 31 2e 70 4c 72 75 48 pcache1.pLruH
4950: 65 61 64 20 3d 20 70 50 61 67 65 3b 0a 20 20 20 ead = pPage;.
4960: 20 7d 0a 20 20 20 20 70 43 61 63 68 65 2d 3e 6e }. pCache->n
4970: 52 65 63 79 63 6c 61 62 6c 65 2b 2b 3b 0a 20 20 Recyclable++;.
4980: 7d 0a 0a 20 20 70 63 61 63 68 65 31 4c 65 61 76 }.. pcache1Leav
4990: 65 4d 75 74 65 78 28 29 3b 0a 7d 0a 0a 2f 2a 0a eMutex();.}../*.
49a0: 2a 2a 20 49 6d 70 6c 65 6d 65 6e 74 61 74 69 6f ** Implementatio
49b0: 6e 20 6f 66 20 74 68 65 20 73 71 6c 69 74 65 33 n of the sqlite3
49c0: 5f 70 63 61 63 68 65 2e 78 52 65 6b 65 79 20 6d _pcache.xRekey m
49d0: 65 74 68 6f 64 2e 20 0a 2a 2f 0a 73 74 61 74 69 ethod. .*/.stati
49e0: 63 20 76 6f 69 64 20 70 63 61 63 68 65 31 52 65 c void pcache1Re
49f0: 6b 65 79 28 0a 20 20 73 71 6c 69 74 65 33 5f 70 key(. sqlite3_p
4a00: 63 61 63 68 65 20 2a 70 2c 0a 20 20 76 6f 69 64 cache *p,. void
4a10: 20 2a 70 50 67 2c 0a 20 20 75 6e 73 69 67 6e 65 *pPg,. unsigne
4a20: 64 20 69 6e 74 20 69 4f 6c 64 2c 0a 20 20 75 6e d int iOld,. un
4a30: 73 69 67 6e 65 64 20 69 6e 74 20 69 4e 65 77 0a signed int iNew.
4a40: 29 7b 0a 20 20 50 43 61 63 68 65 31 20 2a 70 43 ){. PCache1 *pC
4a50: 61 63 68 65 20 3d 20 28 50 43 61 63 68 65 31 20 ache = (PCache1
4a60: 2a 29 70 3b 0a 20 20 50 67 48 64 72 31 20 2a 70 *)p;. PgHdr1 *p
4a70: 50 61 67 65 20 3d 20 50 41 47 45 5f 54 4f 5f 50 Page = PAGE_TO_P
4a80: 47 48 44 52 31 28 70 50 67 29 3b 0a 20 20 50 67 GHDR1(pPg);. Pg
4a90: 48 64 72 31 20 2a 2a 70 70 3b 0a 20 20 75 6e 73 Hdr1 **pp;. uns
4aa0: 69 67 6e 65 64 20 69 6e 74 20 68 3b 20 0a 20 20 igned int h; .
4ab0: 61 73 73 65 72 74 28 20 70 50 61 67 65 2d 3e 69 assert( pPage->i
4ac0: 4b 65 79 3d 3d 69 4f 6c 64 20 29 3b 0a 0a 20 20 Key==iOld );..
4ad0: 70 63 61 63 68 65 31 45 6e 74 65 72 4d 75 74 65 pcache1EnterMute
4ae0: 78 28 29 3b 0a 0a 20 20 68 20 3d 20 69 4f 6c 64 x();.. h = iOld
4af0: 25 70 43 61 63 68 65 2d 3e 6e 48 61 73 68 3b 0a %pCache->nHash;.
4b00: 20 20 70 70 20 3d 20 26 70 43 61 63 68 65 2d 3e pp = &pCache->
4b10: 61 70 48 61 73 68 5b 68 5d 3b 0a 20 20 77 68 69 apHash[h];. whi
4b20: 6c 65 28 20 28 2a 70 70 29 21 3d 70 50 61 67 65 le( (*pp)!=pPage
4b30: 20 29 7b 0a 20 20 20 20 70 70 20 3d 20 26 28 2a ){. pp = &(*
4b40: 70 70 29 2d 3e 70 4e 65 78 74 3b 0a 20 20 7d 0a pp)->pNext;. }.
4b50: 20 20 2a 70 70 20 3d 20 70 50 61 67 65 2d 3e 70 *pp = pPage->p
4b60: 4e 65 78 74 3b 0a 0a 20 20 68 20 3d 20 69 4e 65 Next;.. h = iNe
4b70: 77 25 70 43 61 63 68 65 2d 3e 6e 48 61 73 68 3b w%pCache->nHash;
4b80: 0a 20 20 70 50 61 67 65 2d 3e 69 4b 65 79 20 3d . pPage->iKey =
4b90: 20 69 4e 65 77 3b 0a 20 20 70 50 61 67 65 2d 3e iNew;. pPage->
4ba0: 70 4e 65 78 74 20 3d 20 70 43 61 63 68 65 2d 3e pNext = pCache->
4bb0: 61 70 48 61 73 68 5b 68 5d 3b 0a 20 20 70 43 61 apHash[h];. pCa
4bc0: 63 68 65 2d 3e 61 70 48 61 73 68 5b 68 5d 20 3d che->apHash[h] =
4bd0: 20 70 50 61 67 65 3b 0a 0a 20 20 69 66 28 20 69 pPage;.. if( i
4be0: 4e 65 77 3e 70 43 61 63 68 65 2d 3e 69 4d 61 78 New>pCache->iMax
4bf0: 4b 65 79 20 29 7b 0a 20 20 20 20 70 43 61 63 68 Key ){. pCach
4c00: 65 2d 3e 69 4d 61 78 4b 65 79 20 3d 20 69 4e 65 e->iMaxKey = iNe
4c10: 77 3b 0a 20 20 7d 0a 0a 20 20 70 63 61 63 68 65 w;. }.. pcache
4c20: 31 4c 65 61 76 65 4d 75 74 65 78 28 29 3b 0a 7d 1LeaveMutex();.}
4c30: 0a 0a 2f 2a 0a 2a 2a 20 49 6d 70 6c 65 6d 65 6e ../*.** Implemen
4c40: 74 61 74 69 6f 6e 20 6f 66 20 74 68 65 20 73 71 tation of the sq
4c50: 6c 69 74 65 33 5f 70 63 61 63 68 65 2e 78 54 72 lite3_pcache.xTr
4c60: 75 6e 63 61 74 65 20 6d 65 74 68 6f 64 2e 20 0a uncate method. .
4c70: 2a 2a 0a 2a 2a 20 44 69 73 63 61 72 64 20 61 6c **.** Discard al
4c80: 6c 20 75 6e 70 69 6e 6e 65 64 20 70 61 67 65 73 l unpinned pages
4c90: 20 69 6e 20 74 68 65 20 63 61 63 68 65 20 77 69 in the cache wi
4ca0: 74 68 20 61 20 70 61 67 65 20 6e 75 6d 62 65 72 th a page number
4cb0: 20 65 71 75 61 6c 20 74 6f 0a 2a 2a 20 6f 72 20 equal to.** or
4cc0: 67 72 65 61 74 65 72 20 74 68 61 6e 20 70 61 72 greater than par
4cd0: 61 6d 65 74 65 72 20 69 4c 69 6d 69 74 2e 20 41 ameter iLimit. A
4ce0: 6e 79 20 70 69 6e 6e 65 64 20 70 61 67 65 73 20 ny pinned pages
4cf0: 77 69 74 68 20 61 20 70 61 67 65 20 6e 75 6d 62 with a page numb
4d00: 65 72 0a 2a 2a 20 65 71 75 61 6c 20 74 6f 20 6f er.** equal to o
4d10: 72 20 67 72 65 61 74 65 72 20 74 68 61 6e 20 69 r greater than i
4d20: 4c 69 6d 69 74 20 61 72 65 20 69 6d 70 6c 69 63 Limit are implic
4d30: 69 74 6c 79 20 75 6e 70 69 6e 6e 65 64 2e 0a 2a itly unpinned..*
4d40: 2f 0a 73 74 61 74 69 63 20 76 6f 69 64 20 70 63 /.static void pc
4d50: 61 63 68 65 31 54 72 75 6e 63 61 74 65 28 73 71 ache1Truncate(sq
4d60: 6c 69 74 65 33 5f 70 63 61 63 68 65 20 2a 70 2c lite3_pcache *p,
4d70: 20 75 6e 73 69 67 6e 65 64 20 69 6e 74 20 69 4c unsigned int iL
4d80: 69 6d 69 74 29 7b 0a 20 20 50 43 61 63 68 65 31 imit){. PCache1
4d90: 20 2a 70 43 61 63 68 65 20 3d 20 28 50 43 61 63 *pCache = (PCac
4da0: 68 65 31 20 2a 29 70 3b 0a 20 20 70 63 61 63 68 he1 *)p;. pcach
4db0: 65 31 45 6e 74 65 72 4d 75 74 65 78 28 29 3b 0a e1EnterMutex();.
4dc0: 20 20 69 66 28 20 69 4c 69 6d 69 74 3c 3d 70 43 if( iLimit<=pC
4dd0: 61 63 68 65 2d 3e 69 4d 61 78 4b 65 79 20 29 7b ache->iMaxKey ){
4de0: 0a 20 20 20 20 70 63 61 63 68 65 31 54 72 75 6e . pcache1Trun
4df0: 63 61 74 65 55 6e 73 61 66 65 28 70 43 61 63 68 cateUnsafe(pCach
4e00: 65 2c 20 69 4c 69 6d 69 74 29 3b 0a 20 20 20 20 e, iLimit);.
4e10: 70 43 61 63 68 65 2d 3e 69 4d 61 78 4b 65 79 20 pCache->iMaxKey
4e20: 3d 20 69 4c 69 6d 69 74 2d 31 3b 0a 20 20 7d 0a = iLimit-1;. }.
4e30: 20 20 70 63 61 63 68 65 31 4c 65 61 76 65 4d 75 pcache1LeaveMu
4e40: 74 65 78 28 29 3b 0a 7d 0a 0a 2f 2a 0a 2a 2a 20 tex();.}../*.**
4e50: 49 6d 70 6c 65 6d 65 6e 74 61 74 69 6f 6e 20 6f Implementation o
4e60: 66 20 74 68 65 20 73 71 6c 69 74 65 33 5f 70 63 f the sqlite3_pc
4e70: 61 63 68 65 2e 78 44 65 73 74 72 6f 79 20 6d 65 ache.xDestroy me
4e80: 74 68 6f 64 2e 20 0a 2a 2a 0a 2a 2a 20 44 65 73 thod. .**.** Des
4e90: 74 72 6f 79 20 61 20 63 61 63 68 65 20 61 6c 6c troy a cache all
4ea0: 6f 63 61 74 65 64 20 75 73 69 6e 67 20 70 63 61 ocated using pca
4eb0: 63 68 65 31 43 72 65 61 74 65 28 29 2e 0a 2a 2f che1Create()..*/
4ec0: 0a 73 74 61 74 69 63 20 76 6f 69 64 20 70 63 61 .static void pca
4ed0: 63 68 65 31 44 65 73 74 72 6f 79 28 73 71 6c 69 che1Destroy(sqli
4ee0: 74 65 33 5f 70 63 61 63 68 65 20 2a 70 29 7b 0a te3_pcache *p){.
4ef0: 20 20 50 43 61 63 68 65 31 20 2a 70 43 61 63 68 PCache1 *pCach
4f00: 65 20 3d 20 28 50 43 61 63 68 65 31 20 2a 29 70 e = (PCache1 *)p
4f10: 3b 0a 20 20 70 63 61 63 68 65 31 45 6e 74 65 72 ;. pcache1Enter
4f20: 4d 75 74 65 78 28 29 3b 0a 20 20 70 63 61 63 68 Mutex();. pcach
4f30: 65 31 54 72 75 6e 63 61 74 65 55 6e 73 61 66 65 e1TruncateUnsafe
4f40: 28 70 43 61 63 68 65 2c 20 30 29 3b 0a 20 20 70 (pCache, 0);. p
4f50: 63 61 63 68 65 31 2e 6e 4d 61 78 50 61 67 65 20 cache1.nMaxPage
4f60: 2d 3d 20 70 43 61 63 68 65 2d 3e 6e 4d 61 78 3b -= pCache->nMax;
4f70: 0a 20 20 70 63 61 63 68 65 31 2e 6e 4d 69 6e 50 . pcache1.nMinP
4f80: 61 67 65 20 2d 3d 20 70 43 61 63 68 65 2d 3e 6e age -= pCache->n
4f90: 4d 69 6e 3b 0a 20 20 70 63 61 63 68 65 31 45 6e Min;. pcache1En
4fa0: 66 6f 72 63 65 4d 61 78 50 61 67 65 28 29 3b 0a forceMaxPage();.
4fb0: 20 20 70 63 61 63 68 65 31 4c 65 61 76 65 4d 75 pcache1LeaveMu
4fc0: 74 65 78 28 29 3b 0a 20 20 73 71 6c 69 74 65 33 tex();. sqlite3
4fd0: 5f 66 72 65 65 28 70 43 61 63 68 65 2d 3e 61 70 _free(pCache->ap
4fe0: 48 61 73 68 29 3b 0a 20 20 73 71 6c 69 74 65 33 Hash);. sqlite3
4ff0: 5f 66 72 65 65 28 70 43 61 63 68 65 29 3b 0a 7d _free(pCache);.}
5000: 0a 0a 2f 2a 0a 2a 2a 20 54 68 69 73 20 66 75 6e ../*.** This fun
5010: 63 74 69 6f 6e 20 69 73 20 63 61 6c 6c 65 64 20 ction is called
5020: 64 75 72 69 6e 67 20 69 6e 69 74 69 61 6c 69 7a during initializ
5030: 61 74 69 6f 6e 20 28 73 71 6c 69 74 65 33 5f 69 ation (sqlite3_i
5040: 6e 69 74 69 61 6c 69 7a 65 28 29 29 20 74 6f 0a nitialize()) to.
5050: 2a 2a 20 69 6e 73 74 61 6c 6c 20 74 68 65 20 64 ** install the d
5060: 65 66 61 75 6c 74 20 70 6c 75 67 67 61 62 6c 65 efault pluggable
5070: 20 63 61 63 68 65 20 6d 6f 64 75 6c 65 2c 20 61 cache module, a
5080: 73 73 75 6d 69 6e 67 20 74 68 65 20 75 73 65 72 ssuming the user
5090: 20 68 61 73 20 6e 6f 74 0a 2a 2a 20 61 6c 72 65 has not.** alre
50a0: 61 64 79 20 70 72 6f 76 69 64 65 64 20 61 6e 20 ady provided an
50b0: 61 6c 74 65 72 6e 61 74 69 76 65 2e 0a 2a 2f 0a alternative..*/.
50c0: 76 6f 69 64 20 73 71 6c 69 74 65 33 50 43 61 63 void sqlite3PCac
50d0: 68 65 53 65 74 44 65 66 61 75 6c 74 28 76 6f 69 heSetDefault(voi
50e0: 64 29 7b 0a 20 20 73 74 61 74 69 63 20 73 71 6c d){. static sql
50f0: 69 74 65 33 5f 70 63 61 63 68 65 5f 6d 65 74 68 ite3_pcache_meth
5100: 6f 64 73 20 64 65 66 61 75 6c 74 4d 65 74 68 6f ods defaultMetho
5110: 64 73 20 3d 20 7b 0a 20 20 20 20 30 2c 20 20 20 ds = {. 0,
5120: 20 20 20 20 20 20 20 20 20 20 20 20 20 20 20 20
5130: 20 20 20 20 2f 2a 20 70 41 72 67 20 2a 2f 0a 20 /* pArg */.
5140: 20 20 20 70 63 61 63 68 65 31 49 6e 69 74 2c 20 pcache1Init,
5150: 20 20 20 20 20 20 20 20 20 20 20 20 2f 2a 20 78 /* x
5160: 49 6e 69 74 20 2a 2f 0a 20 20 20 20 70 63 61 63 Init */. pcac
5170: 68 65 31 53 68 75 74 64 6f 77 6e 2c 20 20 20 20 he1Shutdown,
5180: 20 20 20 20 20 2f 2a 20 78 53 68 75 74 64 6f 77 /* xShutdow
5190: 6e 20 2a 2f 0a 20 20 20 20 70 63 61 63 68 65 31 n */. pcache1
51a0: 43 72 65 61 74 65 2c 20 20 20 20 20 20 20 20 20 Create,
51b0: 20 20 2f 2a 20 78 43 72 65 61 74 65 20 2a 2f 0a /* xCreate */.
51c0: 20 20 20 20 70 63 61 63 68 65 31 43 61 63 68 65 pcache1Cache
51d0: 73 69 7a 65 2c 20 20 20 20 20 20 20 20 2f 2a 20 size, /*
51e0: 78 43 61 63 68 65 73 69 7a 65 20 2a 2f 0a 20 20 xCachesize */.
51f0: 20 20 70 63 61 63 68 65 31 50 61 67 65 63 6f 75 pcache1Pagecou
5200: 6e 74 2c 20 20 20 20 20 20 20 20 2f 2a 20 78 50 nt, /* xP
5210: 61 67 65 63 6f 75 6e 74 20 2a 2f 0a 20 20 20 20 agecount */.
5220: 70 63 61 63 68 65 31 46 65 74 63 68 2c 20 20 20 pcache1Fetch,
5230: 20 20 20 20 20 20 20 20 20 2f 2a 20 78 46 65 74 /* xFet
5240: 63 68 20 2a 2f 0a 20 20 20 20 70 63 61 63 68 65 ch */. pcache
5250: 31 55 6e 70 69 6e 2c 20 20 20 20 20 20 20 20 20 1Unpin,
5260: 20 20 20 2f 2a 20 78 55 6e 70 69 6e 20 2a 2f 0a /* xUnpin */.
5270: 20 20 20 20 70 63 61 63 68 65 31 52 65 6b 65 79 pcache1Rekey
5280: 2c 20 20 20 20 20 20 20 20 20 20 20 20 2f 2a 20 , /*
5290: 78 52 65 6b 65 79 20 2a 2f 0a 20 20 20 20 70 63 xRekey */. pc
52a0: 61 63 68 65 31 54 72 75 6e 63 61 74 65 2c 20 20 ache1Truncate,
52b0: 20 20 20 20 20 20 20 2f 2a 20 78 54 72 75 6e 63 /* xTrunc
52c0: 61 74 65 20 2a 2f 0a 20 20 20 20 70 63 61 63 68 ate */. pcach
52d0: 65 31 44 65 73 74 72 6f 79 20 20 20 20 20 20 20 e1Destroy
52e0: 20 20 20 20 2f 2a 20 78 44 65 73 74 72 6f 79 20 /* xDestroy
52f0: 2a 2f 0a 20 20 7d 3b 0a 20 20 73 71 6c 69 74 65 */. };. sqlite
5300: 33 5f 63 6f 6e 66 69 67 28 53 51 4c 49 54 45 5f 3_config(SQLITE_
5310: 43 4f 4e 46 49 47 5f 50 43 41 43 48 45 2c 20 26 CONFIG_PCACHE, &
5320: 64 65 66 61 75 6c 74 4d 65 74 68 6f 64 73 29 3b defaultMethods);
5330: 0a 7d 0a 0a 23 69 66 64 65 66 20 53 51 4c 49 54 .}..#ifdef SQLIT
5340: 45 5f 45 4e 41 42 4c 45 5f 4d 45 4d 4f 52 59 5f E_ENABLE_MEMORY_
5350: 4d 41 4e 41 47 45 4d 45 4e 54 0a 2f 2a 0a 2a 2a MANAGEMENT./*.**
5360: 20 54 68 69 73 20 66 75 6e 63 74 69 6f 6e 20 69 This function i
5370: 73 20 63 61 6c 6c 65 64 20 74 6f 20 66 72 65 65 s called to free
5380: 20 73 75 70 65 72 66 6c 75 6f 75 73 20 64 79 6e superfluous dyn
5390: 61 6d 69 63 61 6c 6c 79 20 61 6c 6c 6f 63 61 74 amically allocat
53a0: 65 64 20 6d 65 6d 6f 72 79 0a 2a 2a 20 68 65 6c ed memory.** hel
53b0: 64 20 62 79 20 74 68 65 20 70 61 67 65 72 20 73 d by the pager s
53c0: 79 73 74 65 6d 2e 20 4d 65 6d 6f 72 79 20 69 6e ystem. Memory in
53d0: 20 75 73 65 20 62 79 20 61 6e 79 20 53 51 4c 69 use by any SQLi
53e0: 74 65 20 70 61 67 65 72 20 61 6c 6c 6f 63 61 74 te pager allocat
53f0: 65 64 0a 2a 2a 20 62 79 20 74 68 65 20 63 75 72 ed.** by the cur
5400: 72 65 6e 74 20 74 68 72 65 61 64 20 6d 61 79 20 rent thread may
5410: 62 65 20 73 71 6c 69 74 65 33 5f 66 72 65 65 28 be sqlite3_free(
5420: 29 65 64 2e 0a 2a 2a 0a 2a 2a 20 6e 52 65 71 20 )ed..**.** nReq
5430: 69 73 20 74 68 65 20 6e 75 6d 62 65 72 20 6f 66 is the number of
5440: 20 62 79 74 65 73 20 6f 66 20 6d 65 6d 6f 72 79 bytes of memory
5450: 20 72 65 71 75 69 72 65 64 2e 20 4f 6e 63 65 20 required. Once
5460: 74 68 69 73 20 6d 75 63 68 20 68 61 73 0a 2a 2a this much has.**
5470: 20 62 65 65 6e 20 72 65 6c 65 61 73 65 64 2c 20 been released,
5480: 74 68 65 20 66 75 6e 63 74 69 6f 6e 20 72 65 74 the function ret
5490: 75 72 6e 73 2e 20 54 68 65 20 72 65 74 75 72 6e urns. The return
54a0: 20 76 61 6c 75 65 20 69 73 20 74 68 65 20 74 6f value is the to
54b0: 74 61 6c 20 6e 75 6d 62 65 72 20 0a 2a 2a 20 6f tal number .** o
54c0: 66 20 62 79 74 65 73 20 6f 66 20 6d 65 6d 6f 72 f bytes of memor
54d0: 79 20 72 65 6c 65 61 73 65 64 2e 0a 2a 2f 0a 69 y released..*/.i
54e0: 6e 74 20 73 71 6c 69 74 65 33 50 63 61 63 68 65 nt sqlite3Pcache
54f0: 52 65 6c 65 61 73 65 4d 65 6d 6f 72 79 28 69 6e ReleaseMemory(in
5500: 74 20 6e 52 65 71 29 7b 0a 20 20 69 6e 74 20 6e t nReq){. int n
5510: 46 72 65 65 20 3d 20 30 3b 0a 20 20 69 66 28 20 Free = 0;. if(
5520: 70 63 61 63 68 65 31 2e 70 53 74 61 72 74 3d 3d pcache1.pStart==
5530: 30 20 29 7b 0a 20 20 20 20 50 67 48 64 72 31 20 0 ){. PgHdr1
5540: 2a 70 3b 0a 20 20 20 20 70 63 61 63 68 65 31 45 *p;. pcache1E
5550: 6e 74 65 72 4d 75 74 65 78 28 29 3b 0a 20 20 20 nterMutex();.
5560: 20 77 68 69 6c 65 28 20 28 6e 52 65 71 3c 30 20 while( (nReq<0
5570: 7c 7c 20 6e 46 72 65 65 3c 6e 52 65 71 29 20 26 || nFree<nReq) &
5580: 26 20 28 70 3d 70 63 61 63 68 65 31 2e 70 4c 72 & (p=pcache1.pLr
5590: 75 54 61 69 6c 29 20 29 7b 0a 20 20 20 20 20 20 uTail) ){.
55a0: 6e 46 72 65 65 20 2b 3d 20 73 71 6c 69 74 65 33 nFree += sqlite3
55b0: 4d 61 6c 6c 6f 63 53 69 7a 65 28 70 29 3b 0a 20 MallocSize(p);.
55c0: 20 20 20 20 20 70 63 61 63 68 65 31 50 69 6e 50 pcache1PinP
55d0: 61 67 65 28 70 29 3b 0a 20 20 20 20 20 20 70 63 age(p);. pc
55e0: 61 63 68 65 31 52 65 6d 6f 76 65 46 72 6f 6d 48 ache1RemoveFromH
55f0: 61 73 68 28 70 29 3b 0a 20 20 20 20 20 20 70 63 ash(p);. pc
5600: 61 63 68 65 31 46 72 65 65 50 61 67 65 28 70 29 ache1FreePage(p)
5610: 3b 0a 20 20 20 20 7d 0a 20 20 20 20 70 63 61 63 ;. }. pcac
5620: 68 65 31 4c 65 61 76 65 4d 75 74 65 78 28 29 3b he1LeaveMutex();
5630: 0a 20 20 7d 0a 20 20 72 65 74 75 72 6e 20 6e 46 . }. return nF
5640: 72 65 65 3b 0a 7d 0a 23 65 6e 64 69 66 20 2f 2a ree;.}.#endif /*
5650: 20 53 51 4c 49 54 45 5f 45 4e 41 42 4c 45 5f 4d SQLITE_ENABLE_M
5660: 45 4d 4f 52 59 5f 4d 41 4e 41 47 45 4d 45 4e 54 EMORY_MANAGEMENT
5670: 20 2a 2f 0a 0a 23 69 66 64 65 66 20 53 51 4c 49 */..#ifdef SQLI
5680: 54 45 5f 54 45 53 54 0a 2f 2a 0a 2a 2a 20 54 68 TE_TEST./*.** Th
5690: 69 73 20 66 75 6e 63 74 69 6f 6e 20 69 73 20 75 is function is u
56a0: 73 65 64 20 62 79 20 74 65 73 74 20 70 72 6f 63 sed by test proc
56b0: 65 64 75 72 65 73 20 74 6f 20 69 6e 73 70 65 63 edures to inspec
56c0: 74 20 74 68 65 20 69 6e 74 65 72 6e 61 6c 20 73 t the internal s
56d0: 74 61 74 65 0a 2a 2a 20 6f 66 20 74 68 65 20 67 tate.** of the g
56e0: 6c 6f 62 61 6c 20 63 61 63 68 65 2e 0a 2a 2f 0a lobal cache..*/.
56f0: 76 6f 69 64 20 73 71 6c 69 74 65 33 50 63 61 63 void sqlite3Pcac
5700: 68 65 53 74 61 74 73 28 0a 20 20 69 6e 74 20 2a heStats(. int *
5710: 70 6e 43 75 72 72 65 6e 74 2c 20 20 20 20 20 20 pnCurrent,
5720: 2f 2a 20 4f 55 54 3a 20 54 6f 74 61 6c 20 6e 75 /* OUT: Total nu
5730: 6d 62 65 72 20 6f 66 20 70 61 67 65 73 20 63 61 mber of pages ca
5740: 63 68 65 64 20 2a 2f 0a 20 20 69 6e 74 20 2a 70 ched */. int *p
5750: 6e 4d 61 78 2c 20 20 20 20 20 20 20 20 20 20 2f nMax, /
5760: 2a 20 4f 55 54 3a 20 47 6c 6f 62 61 6c 20 6d 61 * OUT: Global ma
5770: 78 69 6d 75 6d 20 63 61 63 68 65 20 73 69 7a 65 ximum cache size
5780: 20 2a 2f 0a 20 20 69 6e 74 20 2a 70 6e 4d 69 6e */. int *pnMin
5790: 2c 20 20 20 20 20 20 20 20 20 20 2f 2a 20 4f 55 , /* OU
57a0: 54 3a 20 53 75 6d 20 6f 66 20 50 43 61 63 68 65 T: Sum of PCache
57b0: 31 2e 6e 4d 69 6e 20 66 6f 72 20 70 75 72 67 65 1.nMin for purge
57c0: 61 62 6c 65 20 63 61 63 68 65 73 20 2a 2f 0a 20 able caches */.
57d0: 20 69 6e 74 20 2a 70 6e 52 65 63 79 63 6c 61 62 int *pnRecyclab
57e0: 6c 65 20 20 20 20 2f 2a 20 4f 55 54 3a 20 54 6f le /* OUT: To
57f0: 74 61 6c 20 6e 75 6d 62 65 72 20 6f 66 20 70 61 tal number of pa
5800: 67 65 73 20 61 76 61 69 6c 61 62 6c 65 20 66 6f ges available fo
5810: 72 20 72 65 63 79 63 6c 69 6e 67 20 2a 2f 0a 29 r recycling */.)
5820: 7b 0a 20 20 50 67 48 64 72 31 20 2a 70 3b 0a 20 {. PgHdr1 *p;.
5830: 20 69 6e 74 20 6e 52 65 63 79 63 6c 61 62 6c 65 int nRecyclable
5840: 20 3d 20 30 3b 0a 20 20 66 6f 72 28 70 3d 70 63 = 0;. for(p=pc
5850: 61 63 68 65 31 2e 70 4c 72 75 48 65 61 64 3b 20 ache1.pLruHead;
5860: 70 3b 20 70 3d 70 2d 3e 70 4c 72 75 4e 65 78 74 p; p=p->pLruNext
5870: 29 7b 0a 20 20 20 20 6e 52 65 63 79 63 6c 61 62 ){. nRecyclab
5880: 6c 65 2b 2b 3b 0a 20 20 7d 0a 20 20 2a 70 6e 43 le++;. }. *pnC
5890: 75 72 72 65 6e 74 20 3d 20 70 63 61 63 68 65 31 urrent = pcache1
58a0: 2e 6e 43 75 72 72 65 6e 74 50 61 67 65 3b 0a 20 .nCurrentPage;.
58b0: 20 2a 70 6e 4d 61 78 20 3d 20 70 63 61 63 68 65 *pnMax = pcache
58c0: 31 2e 6e 4d 61 78 50 61 67 65 3b 0a 20 20 2a 70 1.nMaxPage;. *p
58d0: 6e 4d 69 6e 20 3d 20 70 63 61 63 68 65 31 2e 6e nMin = pcache1.n
58e0: 4d 69 6e 50 61 67 65 3b 0a 20 20 2a 70 6e 52 65 MinPage;. *pnRe
58f0: 63 79 63 6c 61 62 6c 65 20 3d 20 6e 52 65 63 79 cyclable = nRecy
5900: 63 6c 61 62 6c 65 3b 0a 7d 0a 23 65 6e 64 69 66 clable;.}.#endif
5910: 0a .