0000: 2f 2a 0a 2a 2a 20 32 30 30 38 20 41 75 67 75 73 /*.** 2008 Augus
0010: 74 20 30 35 0a 2a 2a 0a 2a 2a 20 54 68 65 20 61 t 05.**.** The a
0020: 75 74 68 6f 72 20 64 69 73 63 6c 61 69 6d 73 20 uthor disclaims
0030: 63 6f 70 79 72 69 67 68 74 20 74 6f 20 74 68 69 copyright to thi
0040: 73 20 73 6f 75 72 63 65 20 63 6f 64 65 2e 20 20 s source code.
0050: 49 6e 20 70 6c 61 63 65 20 6f 66 0a 2a 2a 20 61 In place of.** a
0060: 20 6c 65 67 61 6c 20 6e 6f 74 69 63 65 2c 20 68 legal notice, h
0070: 65 72 65 20 69 73 20 61 20 62 6c 65 73 73 69 6e ere is a blessin
0080: 67 3a 0a 2a 2a 0a 2a 2a 20 20 20 20 4d 61 79 20 g:.**.** May
0090: 79 6f 75 20 64 6f 20 67 6f 6f 64 20 61 6e 64 20 you do good and
00a0: 6e 6f 74 20 65 76 69 6c 2e 0a 2a 2a 20 20 20 20 not evil..**
00b0: 4d 61 79 20 79 6f 75 20 66 69 6e 64 20 66 6f 72 May you find for
00c0: 67 69 76 65 6e 65 73 73 20 66 6f 72 20 79 6f 75 giveness for you
00d0: 72 73 65 6c 66 20 61 6e 64 20 66 6f 72 67 69 76 rself and forgiv
00e0: 65 20 6f 74 68 65 72 73 2e 0a 2a 2a 20 20 20 20 e others..**
00f0: 4d 61 79 20 79 6f 75 20 73 68 61 72 65 20 66 72 May you share fr
0100: 65 65 6c 79 2c 20 6e 65 76 65 72 20 74 61 6b 69 eely, never taki
0110: 6e 67 20 6d 6f 72 65 20 74 68 61 6e 20 79 6f 75 ng more than you
0120: 20 67 69 76 65 2e 0a 2a 2a 0a 2a 2a 2a 2a 2a 2a 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 0a 2a 2a 20 54 68 69 73 20 66 69 6c 65 ***.** This file
0180: 20 69 6d 70 6c 65 6d 65 6e 74 73 20 74 68 61 74 implements that
0190: 20 70 61 67 65 20 63 61 63 68 65 2e 0a 2a 2a 0a page cache..**.
01a0: 2a 2a 20 40 28 23 29 20 24 49 64 3a 20 70 63 61 ** @(#) $Id: pca
01b0: 63 68 65 2e 63 2c 76 20 31 2e 34 30 20 32 30 30 che.c,v 1.40 200
01c0: 39 2f 30 31 2f 31 36 20 31 35 3a 32 31 3a 30 36 9/01/16 15:21:06
01d0: 20 64 61 6e 69 65 6c 6b 31 39 37 37 20 45 78 70 danielk1977 Exp
01e0: 20 24 0a 2a 2f 0a 23 69 6e 63 6c 75 64 65 20 22 $.*/.#include "
01f0: 73 71 6c 69 74 65 49 6e 74 2e 68 22 0a 0a 2f 2a sqliteInt.h"../*
0200: 0a 2a 2a 20 41 20 63 6f 6d 70 6c 65 74 65 20 70 .** A complete p
0210: 61 67 65 20 63 61 63 68 65 20 69 73 20 61 6e 20 age cache is an
0220: 69 6e 73 74 61 6e 63 65 20 6f 66 20 74 68 69 73 instance of this
0230: 20 73 74 72 75 63 74 75 72 65 2e 0a 2a 2f 0a 73 structure..*/.s
0240: 74 72 75 63 74 20 50 43 61 63 68 65 20 7b 0a 20 truct PCache {.
0250: 20 50 67 48 64 72 20 2a 70 44 69 72 74 79 2c 20 PgHdr *pDirty,
0260: 2a 70 44 69 72 74 79 54 61 69 6c 3b 20 20 20 20 *pDirtyTail;
0270: 20 20 20 20 20 2f 2a 20 4c 69 73 74 20 6f 66 20 /* List of
0280: 64 69 72 74 79 20 70 61 67 65 73 20 69 6e 20 4c dirty pages in L
0290: 52 55 20 6f 72 64 65 72 20 2a 2f 0a 20 20 50 67 RU order */. Pg
02a0: 48 64 72 20 2a 70 53 79 6e 63 65 64 3b 20 20 20 Hdr *pSynced;
02b0: 20 20 20 20 20 20 20 20 20 20 20 20 20 20 20 20
02c0: 20 20 2f 2a 20 4c 61 73 74 20 73 79 6e 63 65 64 /* Last synced
02d0: 20 70 61 67 65 20 69 6e 20 64 69 72 74 79 20 70 page in dirty p
02e0: 61 67 65 20 6c 69 73 74 20 2a 2f 0a 20 20 69 6e age list */. in
02f0: 74 20 6e 52 65 66 3b 20 20 20 20 20 20 20 20 20 t nRef;
0300: 20 20 20 20 20 20 20 20 20 20 20 20 20 20 20 20
0310: 20 20 2f 2a 20 4e 75 6d 62 65 72 20 6f 66 20 72 /* Number of r
0320: 65 66 65 72 65 6e 63 65 64 20 70 61 67 65 73 20 eferenced pages
0330: 2a 2f 0a 20 20 69 6e 74 20 6e 4d 61 78 3b 20 20 */. int nMax;
0340: 20 20 20 20 20 20 20 20 20 20 20 20 20 20 20 20
0350: 20 20 20 20 20 20 20 20 20 2f 2a 20 43 6f 6e 66 /* Conf
0360: 69 67 75 72 65 64 20 63 61 63 68 65 20 73 69 7a igured cache siz
0370: 65 20 2a 2f 0a 20 20 69 6e 74 20 6e 4d 69 6e 3b e */. int nMin;
0380: 20 20 20 20 20 20 20 20 20 20 20 20 20 20 20 20
0390: 20 20 20 20 20 20 20 20 20 20 20 2f 2a 20 43 6f /* Co
03a0: 6e 66 69 67 75 72 65 64 20 6d 69 6e 69 6d 75 6d nfigured minimum
03b0: 20 63 61 63 68 65 20 73 69 7a 65 20 2a 2f 0a 20 cache size */.
03c0: 20 69 6e 74 20 73 7a 50 61 67 65 3b 20 20 20 20 int szPage;
03d0: 20 20 20 20 20 20 20 20 20 20 20 20 20 20 20 20
03e0: 20 20 20 20 20 2f 2a 20 53 69 7a 65 20 6f 66 20 /* Size of
03f0: 65 76 65 72 79 20 70 61 67 65 20 69 6e 20 74 68 every page in th
0400: 69 73 20 63 61 63 68 65 20 2a 2f 0a 20 20 69 6e is cache */. in
0410: 74 20 73 7a 45 78 74 72 61 3b 20 20 20 20 20 20 t szExtra;
0420: 20 20 20 20 20 20 20 20 20 20 20 20 20 20 20 20
0430: 20 20 2f 2a 20 53 69 7a 65 20 6f 66 20 65 78 74 /* Size of ext
0440: 72 61 20 73 70 61 63 65 20 66 6f 72 20 65 61 63 ra space for eac
0450: 68 20 70 61 67 65 20 2a 2f 0a 20 20 69 6e 74 20 h page */. int
0460: 62 50 75 72 67 65 61 62 6c 65 3b 20 20 20 20 20 bPurgeable;
0470: 20 20 20 20 20 20 20 20 20 20 20 20 20 20 20 20
0480: 2f 2a 20 54 72 75 65 20 69 66 20 70 61 67 65 73 /* True if pages
0490: 20 61 72 65 20 6f 6e 20 62 61 63 6b 69 6e 67 20 are on backing
04a0: 73 74 6f 72 65 20 2a 2f 0a 20 20 69 6e 74 20 28 store */. int (
04b0: 2a 78 53 74 72 65 73 73 29 28 76 6f 69 64 2a 2c *xStress)(void*,
04c0: 50 67 48 64 72 2a 29 3b 20 20 20 20 20 20 20 2f PgHdr*); /
04d0: 2a 20 43 61 6c 6c 20 74 6f 20 74 72 79 20 6d 61 * Call to try ma
04e0: 6b 65 20 61 20 70 61 67 65 20 63 6c 65 61 6e 20 ke a page clean
04f0: 2a 2f 0a 20 20 76 6f 69 64 20 2a 70 53 74 72 65 */. void *pStre
0500: 73 73 3b 20 20 20 20 20 20 20 20 20 20 20 20 20 ss;
0510: 20 20 20 20 20 20 20 20 20 2f 2a 20 41 72 67 75 /* Argu
0520: 6d 65 6e 74 20 74 6f 20 78 53 74 72 65 73 73 20 ment to xStress
0530: 2a 2f 0a 20 20 73 71 6c 69 74 65 33 5f 70 63 61 */. sqlite3_pca
0540: 63 68 65 20 2a 70 43 61 63 68 65 3b 20 20 20 20 che *pCache;
0550: 20 20 20 20 20 20 20 20 20 2f 2a 20 50 6c 75 67 /* Plug
0560: 67 61 62 6c 65 20 63 61 63 68 65 20 6d 6f 64 75 gable cache modu
0570: 6c 65 20 2a 2f 0a 20 20 50 67 48 64 72 20 2a 70 le */. PgHdr *p
0580: 50 61 67 65 31 3b 0a 7d 3b 0a 0a 2f 2a 0a 2a 2a Page1;.};../*.**
0590: 20 53 6f 6d 65 20 6f 66 20 74 68 65 20 61 73 73 Some of the ass
05a0: 65 72 74 28 29 20 6d 61 63 72 6f 73 20 69 6e 20 ert() macros in
05b0: 74 68 69 73 20 63 6f 64 65 20 61 72 65 20 74 6f this code are to
05c0: 6f 20 65 78 70 65 6e 73 69 76 65 20 74 6f 20 72 o expensive to r
05d0: 75 6e 0a 2a 2a 20 65 76 65 6e 20 64 75 72 69 6e un.** even durin
05e0: 67 20 6e 6f 72 6d 61 6c 20 64 65 62 75 67 67 69 g normal debuggi
05f0: 6e 67 2e 20 20 55 73 65 20 74 68 65 6d 20 6f 6e ng. Use them on
0600: 6c 79 20 72 61 72 65 6c 79 20 6f 6e 20 6c 6f 6e ly rarely on lon
0610: 67 2d 72 75 6e 6e 69 6e 67 0a 2a 2a 20 74 65 73 g-running.** tes
0620: 74 73 2e 20 20 45 6e 61 62 6c 65 20 74 68 65 20 ts. Enable the
0630: 65 78 70 65 6e 73 69 76 65 20 61 73 73 65 72 74 expensive assert
0640: 73 20 75 73 69 6e 67 20 74 68 65 0a 2a 2a 20 2d s using the.** -
0650: 44 53 51 4c 49 54 45 5f 45 4e 41 42 4c 45 5f 45 DSQLITE_ENABLE_E
0660: 58 50 45 4e 53 49 56 45 5f 41 53 53 45 52 54 3d XPENSIVE_ASSERT=
0670: 31 20 63 6f 6d 70 69 6c 65 2d 74 69 6d 65 20 6f 1 compile-time o
0680: 70 74 69 6f 6e 2e 0a 2a 2f 0a 23 69 66 64 65 66 ption..*/.#ifdef
0690: 20 53 51 4c 49 54 45 5f 45 4e 41 42 4c 45 5f 45 SQLITE_ENABLE_E
06a0: 58 50 45 4e 53 49 56 45 5f 41 53 53 45 52 54 0a XPENSIVE_ASSERT.
06b0: 23 20 64 65 66 69 6e 65 20 65 78 70 65 6e 73 69 # define expensi
06c0: 76 65 5f 61 73 73 65 72 74 28 58 29 20 20 61 73 ve_assert(X) as
06d0: 73 65 72 74 28 58 29 0a 23 65 6c 73 65 0a 23 20 sert(X).#else.#
06e0: 64 65 66 69 6e 65 20 65 78 70 65 6e 73 69 76 65 define expensive
06f0: 5f 61 73 73 65 72 74 28 58 29 0a 23 65 6e 64 69 _assert(X).#endi
0700: 66 0a 0a 2f 2a 2a 2a 2a 2a 2a 2a 2a 2a 2a 2a 2a f../************
0710: 2a 2a 2a 2a 2a 2a 2a 2a 2a 2a 2a 2a 2a 2a 2a 2a ****************
0720: 2a 2a 2a 2a 2a 2a 20 4c 69 6e 6b 65 64 20 4c 69 ****** Linked Li
0730: 73 74 20 4d 61 6e 61 67 65 6d 65 6e 74 20 2a 2a st Management **
0740: 2a 2a 2a 2a 2a 2a 2a 2a 2a 2a 2a 2a 2a 2a 2a 2a ****************
0750: 2a 2a 2f 0a 0a 23 69 66 20 21 64 65 66 69 6e 65 **/..#if !define
0760: 64 28 4e 44 45 42 55 47 29 20 26 26 20 64 65 66 d(NDEBUG) && def
0770: 69 6e 65 64 28 53 51 4c 49 54 45 5f 45 4e 41 42 ined(SQLITE_ENAB
0780: 4c 45 5f 45 58 50 45 4e 53 49 56 45 5f 41 53 53 LE_EXPENSIVE_ASS
0790: 45 52 54 29 0a 2f 2a 0a 2a 2a 20 43 68 65 63 6b ERT)./*.** Check
07a0: 20 74 68 61 74 20 74 68 65 20 70 43 61 63 68 65 that the pCache
07b0: 2d 3e 70 53 79 6e 63 65 64 20 76 61 72 69 61 62 ->pSynced variab
07c0: 6c 65 20 69 73 20 73 65 74 20 63 6f 72 72 65 63 le is set correc
07d0: 74 6c 79 2e 20 49 66 20 69 74 0a 2a 2a 20 69 73 tly. If it.** is
07e0: 20 6e 6f 74 2c 20 65 69 74 68 65 72 20 66 61 69 not, either fai
07f0: 6c 20 61 6e 20 61 73 73 65 72 74 20 6f 72 20 72 l an assert or r
0800: 65 74 75 72 6e 20 7a 65 72 6f 2e 20 4f 74 68 65 eturn zero. Othe
0810: 72 77 69 73 65 2c 20 72 65 74 75 72 6e 0a 2a 2a rwise, return.**
0820: 20 6e 6f 6e 2d 7a 65 72 6f 2e 20 54 68 69 73 20 non-zero. This
0830: 69 73 20 6f 6e 6c 79 20 75 73 65 64 20 69 6e 20 is only used in
0840: 64 65 62 75 67 67 69 6e 67 20 62 75 69 6c 64 73 debugging builds
0850: 2c 20 61 73 20 66 6f 6c 6c 6f 77 73 3a 0a 2a 2a , as follows:.**
0860: 0a 2a 2a 20 20 20 65 78 70 65 6e 73 69 76 65 5f .** expensive_
0870: 61 73 73 65 72 74 28 20 70 63 61 63 68 65 43 68 assert( pcacheCh
0880: 65 63 6b 53 79 6e 63 65 64 28 70 43 61 63 68 65 eckSynced(pCache
0890: 29 20 29 3b 0a 2a 2f 0a 73 74 61 74 69 63 20 69 ) );.*/.static i
08a0: 6e 74 20 70 63 61 63 68 65 43 68 65 63 6b 53 79 nt pcacheCheckSy
08b0: 6e 63 65 64 28 50 43 61 63 68 65 20 2a 70 43 61 nced(PCache *pCa
08c0: 63 68 65 29 7b 0a 20 20 50 67 48 64 72 20 2a 70 che){. PgHdr *p
08d0: 3b 0a 20 20 66 6f 72 28 70 3d 70 43 61 63 68 65 ;. for(p=pCache
08e0: 2d 3e 70 44 69 72 74 79 54 61 69 6c 3b 20 70 21 ->pDirtyTail; p!
08f0: 3d 70 43 61 63 68 65 2d 3e 70 53 79 6e 63 65 64 =pCache->pSynced
0900: 3b 20 70 3d 70 2d 3e 70 44 69 72 74 79 50 72 65 ; p=p->pDirtyPre
0910: 76 29 7b 0a 20 20 20 20 61 73 73 65 72 74 28 20 v){. assert(
0920: 70 2d 3e 6e 52 65 66 20 7c 7c 20 28 70 2d 3e 66 p->nRef || (p->f
0930: 6c 61 67 73 26 50 47 48 44 52 5f 4e 45 45 44 5f lags&PGHDR_NEED_
0940: 53 59 4e 43 29 20 29 3b 0a 20 20 7d 0a 20 20 72 SYNC) );. }. r
0950: 65 74 75 72 6e 20 28 70 3d 3d 30 20 7c 7c 20 70 eturn (p==0 || p
0960: 2d 3e 6e 52 65 66 20 7c 7c 20 28 70 2d 3e 66 6c ->nRef || (p->fl
0970: 61 67 73 26 50 47 48 44 52 5f 4e 45 45 44 5f 53 ags&PGHDR_NEED_S
0980: 59 4e 43 29 3d 3d 30 29 3b 0a 7d 0a 23 65 6e 64 YNC)==0);.}.#end
0990: 69 66 20 2f 2a 20 21 4e 44 45 42 55 47 20 26 26 if /* !NDEBUG &&
09a0: 20 53 51 4c 49 54 45 5f 45 4e 41 42 4c 45 5f 45 SQLITE_ENABLE_E
09b0: 58 50 45 4e 53 49 56 45 5f 41 53 53 45 52 54 20 XPENSIVE_ASSERT
09c0: 2a 2f 0a 0a 2f 2a 0a 2a 2a 20 52 65 6d 6f 76 65 */../*.** Remove
09d0: 20 70 61 67 65 20 70 50 61 67 65 20 66 72 6f 6d page pPage from
09e0: 20 74 68 65 20 6c 69 73 74 20 6f 66 20 64 69 72 the list of dir
09f0: 74 79 20 70 61 67 65 73 2e 0a 2a 2f 0a 73 74 61 ty pages..*/.sta
0a00: 74 69 63 20 76 6f 69 64 20 70 63 61 63 68 65 52 tic void pcacheR
0a10: 65 6d 6f 76 65 46 72 6f 6d 44 69 72 74 79 4c 69 emoveFromDirtyLi
0a20: 73 74 28 50 67 48 64 72 20 2a 70 50 61 67 65 29 st(PgHdr *pPage)
0a30: 7b 0a 20 20 50 43 61 63 68 65 20 2a 70 20 3d 20 {. PCache *p =
0a40: 70 50 61 67 65 2d 3e 70 43 61 63 68 65 3b 0a 0a pPage->pCache;..
0a50: 20 20 61 73 73 65 72 74 28 20 70 50 61 67 65 2d assert( pPage-
0a60: 3e 70 44 69 72 74 79 4e 65 78 74 20 7c 7c 20 70 >pDirtyNext || p
0a70: 50 61 67 65 3d 3d 70 2d 3e 70 44 69 72 74 79 54 Page==p->pDirtyT
0a80: 61 69 6c 20 29 3b 0a 20 20 61 73 73 65 72 74 28 ail );. assert(
0a90: 20 70 50 61 67 65 2d 3e 70 44 69 72 74 79 50 72 pPage->pDirtyPr
0aa0: 65 76 20 7c 7c 20 70 50 61 67 65 3d 3d 70 2d 3e ev || pPage==p->
0ab0: 70 44 69 72 74 79 20 29 3b 0a 0a 20 20 2f 2a 20 pDirty );.. /*
0ac0: 55 70 64 61 74 65 20 74 68 65 20 50 43 61 63 68 Update the PCach
0ad0: 65 31 2e 70 53 79 6e 63 65 64 20 76 61 72 69 61 e1.pSynced varia
0ae0: 62 6c 65 20 69 66 20 6e 65 63 65 73 73 61 72 79 ble if necessary
0af0: 2e 20 2a 2f 0a 20 20 69 66 28 20 70 2d 3e 70 53 . */. if( p->pS
0b00: 79 6e 63 65 64 3d 3d 70 50 61 67 65 20 29 7b 0a ynced==pPage ){.
0b10: 20 20 20 20 50 67 48 64 72 20 2a 70 53 79 6e 63 PgHdr *pSync
0b20: 65 64 20 3d 20 70 50 61 67 65 2d 3e 70 44 69 72 ed = pPage->pDir
0b30: 74 79 50 72 65 76 3b 0a 20 20 20 20 77 68 69 6c tyPrev;. whil
0b40: 65 28 20 70 53 79 6e 63 65 64 20 26 26 20 28 70 e( pSynced && (p
0b50: 53 79 6e 63 65 64 2d 3e 66 6c 61 67 73 26 50 47 Synced->flags&PG
0b60: 48 44 52 5f 4e 45 45 44 5f 53 59 4e 43 29 20 29 HDR_NEED_SYNC) )
0b70: 7b 0a 20 20 20 20 20 20 70 53 79 6e 63 65 64 20 {. pSynced
0b80: 3d 20 70 53 79 6e 63 65 64 2d 3e 70 44 69 72 74 = pSynced->pDirt
0b90: 79 50 72 65 76 3b 0a 20 20 20 20 7d 0a 20 20 20 yPrev;. }.
0ba0: 20 70 2d 3e 70 53 79 6e 63 65 64 20 3d 20 70 53 p->pSynced = pS
0bb0: 79 6e 63 65 64 3b 0a 20 20 7d 0a 0a 20 20 69 66 ynced;. }.. if
0bc0: 28 20 70 50 61 67 65 2d 3e 70 44 69 72 74 79 4e ( pPage->pDirtyN
0bd0: 65 78 74 20 29 7b 0a 20 20 20 20 70 50 61 67 65 ext ){. pPage
0be0: 2d 3e 70 44 69 72 74 79 4e 65 78 74 2d 3e 70 44 ->pDirtyNext->pD
0bf0: 69 72 74 79 50 72 65 76 20 3d 20 70 50 61 67 65 irtyPrev = pPage
0c00: 2d 3e 70 44 69 72 74 79 50 72 65 76 3b 0a 20 20 ->pDirtyPrev;.
0c10: 7d 65 6c 73 65 7b 0a 20 20 20 20 61 73 73 65 72 }else{. asser
0c20: 74 28 20 70 50 61 67 65 3d 3d 70 2d 3e 70 44 69 t( pPage==p->pDi
0c30: 72 74 79 54 61 69 6c 20 29 3b 0a 20 20 20 20 70 rtyTail );. p
0c40: 2d 3e 70 44 69 72 74 79 54 61 69 6c 20 3d 20 70 ->pDirtyTail = p
0c50: 50 61 67 65 2d 3e 70 44 69 72 74 79 50 72 65 76 Page->pDirtyPrev
0c60: 3b 0a 20 20 7d 0a 20 20 69 66 28 20 70 50 61 67 ;. }. if( pPag
0c70: 65 2d 3e 70 44 69 72 74 79 50 72 65 76 20 29 7b e->pDirtyPrev ){
0c80: 0a 20 20 20 20 70 50 61 67 65 2d 3e 70 44 69 72 . pPage->pDir
0c90: 74 79 50 72 65 76 2d 3e 70 44 69 72 74 79 4e 65 tyPrev->pDirtyNe
0ca0: 78 74 20 3d 20 70 50 61 67 65 2d 3e 70 44 69 72 xt = pPage->pDir
0cb0: 74 79 4e 65 78 74 3b 0a 20 20 7d 65 6c 73 65 7b tyNext;. }else{
0cc0: 0a 20 20 20 20 61 73 73 65 72 74 28 20 70 50 61 . assert( pPa
0cd0: 67 65 3d 3d 70 2d 3e 70 44 69 72 74 79 20 29 3b ge==p->pDirty );
0ce0: 0a 20 20 20 20 70 2d 3e 70 44 69 72 74 79 20 3d . p->pDirty =
0cf0: 20 70 50 61 67 65 2d 3e 70 44 69 72 74 79 4e 65 pPage->pDirtyNe
0d00: 78 74 3b 0a 20 20 7d 0a 20 20 70 50 61 67 65 2d xt;. }. pPage-
0d10: 3e 70 44 69 72 74 79 4e 65 78 74 20 3d 20 30 3b >pDirtyNext = 0;
0d20: 0a 20 20 70 50 61 67 65 2d 3e 70 44 69 72 74 79 . pPage->pDirty
0d30: 50 72 65 76 20 3d 20 30 3b 0a 0a 20 20 65 78 70 Prev = 0;.. exp
0d40: 65 6e 73 69 76 65 5f 61 73 73 65 72 74 28 20 70 ensive_assert( p
0d50: 63 61 63 68 65 43 68 65 63 6b 53 79 6e 63 65 64 cacheCheckSynced
0d60: 28 70 29 20 29 3b 0a 7d 0a 0a 2f 2a 0a 2a 2a 20 (p) );.}../*.**
0d70: 41 64 64 20 70 61 67 65 20 70 50 61 67 65 20 74 Add page pPage t
0d80: 6f 20 74 68 65 20 68 65 61 64 20 6f 66 20 74 68 o the head of th
0d90: 65 20 64 69 72 74 79 20 6c 69 73 74 20 28 50 43 e dirty list (PC
0da0: 61 63 68 65 31 2e 70 44 69 72 74 79 20 69 73 20 ache1.pDirty is
0db0: 73 65 74 20 74 6f 0a 2a 2a 20 70 50 61 67 65 29 set to.** pPage)
0dc0: 2e 0a 2a 2f 0a 73 74 61 74 69 63 20 76 6f 69 64 ..*/.static void
0dd0: 20 70 63 61 63 68 65 41 64 64 54 6f 44 69 72 74 pcacheAddToDirt
0de0: 79 4c 69 73 74 28 50 67 48 64 72 20 2a 70 50 61 yList(PgHdr *pPa
0df0: 67 65 29 7b 0a 20 20 50 43 61 63 68 65 20 2a 70 ge){. PCache *p
0e00: 20 3d 20 70 50 61 67 65 2d 3e 70 43 61 63 68 65 = pPage->pCache
0e10: 3b 0a 0a 20 20 61 73 73 65 72 74 28 20 70 50 61 ;.. assert( pPa
0e20: 67 65 2d 3e 70 44 69 72 74 79 4e 65 78 74 3d 3d ge->pDirtyNext==
0e30: 30 20 26 26 20 70 50 61 67 65 2d 3e 70 44 69 72 0 && pPage->pDir
0e40: 74 79 50 72 65 76 3d 3d 30 20 26 26 20 70 2d 3e tyPrev==0 && p->
0e50: 70 44 69 72 74 79 21 3d 70 50 61 67 65 20 29 3b pDirty!=pPage );
0e60: 0a 0a 20 20 70 50 61 67 65 2d 3e 70 44 69 72 74 .. pPage->pDirt
0e70: 79 4e 65 78 74 20 3d 20 70 2d 3e 70 44 69 72 74 yNext = p->pDirt
0e80: 79 3b 0a 20 20 69 66 28 20 70 50 61 67 65 2d 3e y;. if( pPage->
0e90: 70 44 69 72 74 79 4e 65 78 74 20 29 7b 0a 20 20 pDirtyNext ){.
0ea0: 20 20 61 73 73 65 72 74 28 20 70 50 61 67 65 2d assert( pPage-
0eb0: 3e 70 44 69 72 74 79 4e 65 78 74 2d 3e 70 44 69 >pDirtyNext->pDi
0ec0: 72 74 79 50 72 65 76 3d 3d 30 20 29 3b 0a 20 20 rtyPrev==0 );.
0ed0: 20 20 70 50 61 67 65 2d 3e 70 44 69 72 74 79 4e pPage->pDirtyN
0ee0: 65 78 74 2d 3e 70 44 69 72 74 79 50 72 65 76 20 ext->pDirtyPrev
0ef0: 3d 20 70 50 61 67 65 3b 0a 20 20 7d 0a 20 20 70 = pPage;. }. p
0f00: 2d 3e 70 44 69 72 74 79 20 3d 20 70 50 61 67 65 ->pDirty = pPage
0f10: 3b 0a 20 20 69 66 28 20 21 70 2d 3e 70 44 69 72 ;. if( !p->pDir
0f20: 74 79 54 61 69 6c 20 29 7b 0a 20 20 20 20 70 2d tyTail ){. p-
0f30: 3e 70 44 69 72 74 79 54 61 69 6c 20 3d 20 70 50 >pDirtyTail = pP
0f40: 61 67 65 3b 0a 20 20 7d 0a 20 20 69 66 28 20 21 age;. }. if( !
0f50: 70 2d 3e 70 53 79 6e 63 65 64 20 26 26 20 30 3d p->pSynced && 0=
0f60: 3d 28 70 50 61 67 65 2d 3e 66 6c 61 67 73 26 50 =(pPage->flags&P
0f70: 47 48 44 52 5f 4e 45 45 44 5f 53 59 4e 43 29 20 GHDR_NEED_SYNC)
0f80: 29 7b 0a 20 20 20 20 70 2d 3e 70 53 79 6e 63 65 ){. p->pSynce
0f90: 64 20 3d 20 70 50 61 67 65 3b 0a 20 20 7d 0a 20 d = pPage;. }.
0fa0: 20 65 78 70 65 6e 73 69 76 65 5f 61 73 73 65 72 expensive_asser
0fb0: 74 28 20 70 63 61 63 68 65 43 68 65 63 6b 53 79 t( pcacheCheckSy
0fc0: 6e 63 65 64 28 70 29 20 29 3b 0a 7d 0a 0a 2f 2a nced(p) );.}../*
0fd0: 0a 2a 2a 20 57 72 61 70 70 65 72 20 61 72 6f 75 .** Wrapper arou
0fe0: 6e 64 20 74 68 65 20 70 6c 75 67 67 61 62 6c 65 nd the pluggable
0ff0: 20 63 61 63 68 65 73 20 78 55 6e 70 69 6e 20 6d caches xUnpin m
1000: 65 74 68 6f 64 2e 20 49 66 20 74 68 65 20 63 61 ethod. If the ca
1010: 63 68 65 20 69 73 0a 2a 2a 20 62 65 69 6e 67 20 che is.** being
1020: 75 73 65 64 20 66 6f 72 20 61 6e 20 69 6e 2d 6d used for an in-m
1030: 65 6d 6f 72 79 20 64 61 74 61 62 61 73 65 2c 20 emory database,
1040: 74 68 69 73 20 66 75 6e 63 74 69 6f 6e 20 69 73 this function is
1050: 20 61 20 6e 6f 2d 6f 70 2e 0a 2a 2f 0a 73 74 61 a no-op..*/.sta
1060: 74 69 63 20 76 6f 69 64 20 70 63 61 63 68 65 55 tic void pcacheU
1070: 6e 70 69 6e 28 50 67 48 64 72 20 2a 70 29 7b 0a npin(PgHdr *p){.
1080: 20 20 50 43 61 63 68 65 20 2a 70 43 61 63 68 65 PCache *pCache
1090: 20 3d 20 70 2d 3e 70 43 61 63 68 65 3b 0a 20 20 = p->pCache;.
10a0: 69 66 28 20 70 43 61 63 68 65 2d 3e 62 50 75 72 if( pCache->bPur
10b0: 67 65 61 62 6c 65 20 29 7b 0a 20 20 20 20 69 66 geable ){. if
10c0: 28 20 70 2d 3e 70 67 6e 6f 3d 3d 31 20 29 7b 0a ( p->pgno==1 ){.
10d0: 20 20 20 20 20 20 70 43 61 63 68 65 2d 3e 70 50 pCache->pP
10e0: 61 67 65 31 20 3d 20 30 3b 0a 20 20 20 20 7d 0a age1 = 0;. }.
10f0: 20 20 20 20 73 71 6c 69 74 65 33 47 6c 6f 62 61 sqlite3Globa
1100: 6c 43 6f 6e 66 69 67 2e 70 63 61 63 68 65 2e 78 lConfig.pcache.x
1110: 55 6e 70 69 6e 28 70 43 61 63 68 65 2d 3e 70 43 Unpin(pCache->pC
1120: 61 63 68 65 2c 20 70 2c 20 30 29 3b 0a 20 20 7d ache, p, 0);. }
1130: 0a 7d 0a 0a 2f 2a 2a 2a 2a 2a 2a 2a 2a 2a 2a 2a .}../***********
1140: 2a 2a 2a 2a 2a 2a 2a 2a 2a 2a 2a 2a 2a 2a 2a 2a ****************
1150: 2a 2a 2a 2a 2a 2a 2a 2a 2a 2a 2a 2a 2a 2a 2a 2a ****************
1160: 2a 2a 2a 2a 2a 2a 2a 2a 20 47 65 6e 65 72 61 6c ******** General
1170: 20 49 6e 74 65 72 66 61 63 65 73 20 2a 2a 2a 2a Interfaces ****
1180: 2a 2a 0a 2a 2a 0a 2a 2a 20 49 6e 69 74 69 61 6c **.**.** Initial
1190: 69 7a 65 20 61 6e 64 20 73 68 75 74 64 6f 77 6e ize and shutdown
11a0: 20 74 68 65 20 70 61 67 65 20 63 61 63 68 65 20 the page cache
11b0: 73 75 62 73 79 73 74 65 6d 2e 20 4e 65 69 74 68 subsystem. Neith
11c0: 65 72 20 6f 66 20 74 68 65 73 65 20 0a 2a 2a 20 er of these .**
11d0: 66 75 6e 63 74 69 6f 6e 73 20 61 72 65 20 74 68 functions are th
11e0: 72 65 61 64 73 61 66 65 2e 0a 2a 2f 0a 69 6e 74 readsafe..*/.int
11f0: 20 73 71 6c 69 74 65 33 50 63 61 63 68 65 49 6e sqlite3PcacheIn
1200: 69 74 69 61 6c 69 7a 65 28 76 6f 69 64 29 7b 0a itialize(void){.
1210: 20 20 69 66 28 20 73 71 6c 69 74 65 33 47 6c 6f if( sqlite3Glo
1220: 62 61 6c 43 6f 6e 66 69 67 2e 70 63 61 63 68 65 balConfig.pcache
1230: 2e 78 49 6e 69 74 3d 3d 30 20 29 7b 0a 20 20 20 .xInit==0 ){.
1240: 20 73 71 6c 69 74 65 33 50 43 61 63 68 65 53 65 sqlite3PCacheSe
1250: 74 44 65 66 61 75 6c 74 28 29 3b 0a 20 20 7d 0a tDefault();. }.
1260: 20 20 72 65 74 75 72 6e 20 73 71 6c 69 74 65 33 return sqlite3
1270: 47 6c 6f 62 61 6c 43 6f 6e 66 69 67 2e 70 63 61 GlobalConfig.pca
1280: 63 68 65 2e 78 49 6e 69 74 28 73 71 6c 69 74 65 che.xInit(sqlite
1290: 33 47 6c 6f 62 61 6c 43 6f 6e 66 69 67 2e 70 63 3GlobalConfig.pc
12a0: 61 63 68 65 2e 70 41 72 67 29 3b 0a 7d 0a 76 6f ache.pArg);.}.vo
12b0: 69 64 20 73 71 6c 69 74 65 33 50 63 61 63 68 65 id sqlite3Pcache
12c0: 53 68 75 74 64 6f 77 6e 28 76 6f 69 64 29 7b 0a Shutdown(void){.
12d0: 20 20 69 66 28 20 73 71 6c 69 74 65 33 47 6c 6f if( sqlite3Glo
12e0: 62 61 6c 43 6f 6e 66 69 67 2e 70 63 61 63 68 65 balConfig.pcache
12f0: 2e 78 53 68 75 74 64 6f 77 6e 20 29 7b 0a 20 20 .xShutdown ){.
1300: 20 20 73 71 6c 69 74 65 33 47 6c 6f 62 61 6c 43 sqlite3GlobalC
1310: 6f 6e 66 69 67 2e 70 63 61 63 68 65 2e 78 53 68 onfig.pcache.xSh
1320: 75 74 64 6f 77 6e 28 73 71 6c 69 74 65 33 47 6c utdown(sqlite3Gl
1330: 6f 62 61 6c 43 6f 6e 66 69 67 2e 70 63 61 63 68 obalConfig.pcach
1340: 65 2e 70 41 72 67 29 3b 0a 20 20 7d 0a 7d 0a 0a e.pArg);. }.}..
1350: 2f 2a 0a 2a 2a 20 52 65 74 75 72 6e 20 74 68 65 /*.** Return the
1360: 20 73 69 7a 65 20 69 6e 20 62 79 74 65 73 20 6f size in bytes o
1370: 66 20 61 20 50 43 61 63 68 65 20 6f 62 6a 65 63 f a PCache objec
1380: 74 2e 0a 2a 2f 0a 69 6e 74 20 73 71 6c 69 74 65 t..*/.int sqlite
1390: 33 50 63 61 63 68 65 53 69 7a 65 28 76 6f 69 64 3PcacheSize(void
13a0: 29 7b 20 72 65 74 75 72 6e 20 73 69 7a 65 6f 66 ){ return sizeof
13b0: 28 50 43 61 63 68 65 29 3b 20 7d 0a 0a 2f 2a 0a (PCache); }../*.
13c0: 2a 2a 20 43 72 65 61 74 65 20 61 20 6e 65 77 20 ** Create a new
13d0: 50 43 61 63 68 65 20 6f 62 6a 65 63 74 2e 20 53 PCache object. S
13e0: 74 6f 72 61 67 65 20 73 70 61 63 65 20 74 6f 20 torage space to
13f0: 68 6f 6c 64 20 74 68 65 20 6f 62 6a 65 63 74 0a hold the object.
1400: 2a 2a 20 68 61 73 20 61 6c 72 65 61 64 79 20 62 ** has already b
1410: 65 65 6e 20 61 6c 6c 6f 63 61 74 65 64 20 61 6e een allocated an
1420: 64 20 69 73 20 70 61 73 73 65 64 20 69 6e 20 61 d is passed in a
1430: 73 20 74 68 65 20 70 20 70 6f 69 6e 74 65 72 2e s the p pointer.
1440: 20 0a 2a 2a 20 54 68 65 20 63 61 6c 6c 65 72 20 .** The caller
1450: 64 69 73 63 6f 76 65 72 73 20 68 6f 77 20 6d 75 discovers how mu
1460: 63 68 20 73 70 61 63 65 20 6e 65 65 64 73 20 74 ch space needs t
1470: 6f 20 62 65 20 61 6c 6c 6f 63 61 74 65 64 20 62 o be allocated b
1480: 79 20 0a 2a 2a 20 63 61 6c 6c 69 6e 67 20 73 71 y .** calling sq
1490: 6c 69 74 65 33 50 63 61 63 68 65 53 69 7a 65 28 lite3PcacheSize(
14a0: 29 2e 0a 2a 2f 0a 76 6f 69 64 20 73 71 6c 69 74 )..*/.void sqlit
14b0: 65 33 50 63 61 63 68 65 4f 70 65 6e 28 0a 20 20 e3PcacheOpen(.
14c0: 69 6e 74 20 73 7a 50 61 67 65 2c 20 20 20 20 20 int szPage,
14d0: 20 20 20 20 20 20 20 20 20 20 20 20 20 2f 2a 20 /*
14e0: 53 69 7a 65 20 6f 66 20 65 76 65 72 79 20 70 61 Size of every pa
14f0: 67 65 20 2a 2f 0a 20 20 69 6e 74 20 73 7a 45 78 ge */. int szEx
1500: 74 72 61 2c 20 20 20 20 20 20 20 20 20 20 20 20 tra,
1510: 20 20 20 20 20 2f 2a 20 45 78 74 72 61 20 73 70 /* Extra sp
1520: 61 63 65 20 61 73 73 6f 63 69 61 74 65 64 20 77 ace associated w
1530: 69 74 68 20 65 61 63 68 20 70 61 67 65 20 2a 2f ith each page */
1540: 0a 20 20 69 6e 74 20 62 50 75 72 67 65 61 62 6c . int bPurgeabl
1550: 65 2c 20 20 20 20 20 20 20 20 20 20 20 20 20 20 e,
1560: 2f 2a 20 54 72 75 65 20 69 66 20 70 61 67 65 73 /* True if pages
1570: 20 61 72 65 20 6f 6e 20 62 61 63 6b 69 6e 67 20 are on backing
1580: 73 74 6f 72 65 20 2a 2f 0a 20 20 69 6e 74 20 28 store */. int (
1590: 2a 78 53 74 72 65 73 73 29 28 76 6f 69 64 2a 2c *xStress)(void*,
15a0: 50 67 48 64 72 2a 29 2c 2f 2a 20 43 61 6c 6c 20 PgHdr*),/* Call
15b0: 74 6f 20 74 72 79 20 74 6f 20 6d 61 6b 65 20 70 to try to make p
15c0: 61 67 65 73 20 63 6c 65 61 6e 20 2a 2f 0a 20 20 ages clean */.
15d0: 76 6f 69 64 20 2a 70 53 74 72 65 73 73 2c 20 20 void *pStress,
15e0: 20 20 20 20 20 20 20 20 20 20 20 20 20 2f 2a 20 /*
15f0: 41 72 67 75 6d 65 6e 74 20 74 6f 20 78 53 74 72 Argument to xStr
1600: 65 73 73 20 2a 2f 0a 20 20 50 43 61 63 68 65 20 ess */. PCache
1610: 2a 70 20 20 20 20 20 20 20 20 20 20 20 20 20 20 *p
1620: 20 20 20 20 20 20 2f 2a 20 50 72 65 61 6c 6c 6f /* Preallo
1630: 63 61 74 65 64 20 73 70 61 63 65 20 66 6f 72 20 cated space for
1640: 74 68 65 20 50 43 61 63 68 65 20 2a 2f 0a 29 7b the PCache */.){
1650: 0a 20 20 6d 65 6d 73 65 74 28 70 2c 20 30 2c 20 . memset(p, 0,
1660: 73 69 7a 65 6f 66 28 50 43 61 63 68 65 29 29 3b sizeof(PCache));
1670: 0a 20 20 70 2d 3e 73 7a 50 61 67 65 20 3d 20 73 . p->szPage = s
1680: 7a 50 61 67 65 3b 0a 20 20 70 2d 3e 73 7a 45 78 zPage;. p->szEx
1690: 74 72 61 20 3d 20 73 7a 45 78 74 72 61 3b 0a 20 tra = szExtra;.
16a0: 20 70 2d 3e 62 50 75 72 67 65 61 62 6c 65 20 3d p->bPurgeable =
16b0: 20 62 50 75 72 67 65 61 62 6c 65 3b 0a 20 20 70 bPurgeable;. p
16c0: 2d 3e 78 53 74 72 65 73 73 20 3d 20 78 53 74 72 ->xStress = xStr
16d0: 65 73 73 3b 0a 20 20 70 2d 3e 70 53 74 72 65 73 ess;. p->pStres
16e0: 73 20 3d 20 70 53 74 72 65 73 73 3b 0a 20 20 70 s = pStress;. p
16f0: 2d 3e 6e 4d 61 78 20 3d 20 31 30 30 3b 0a 20 20 ->nMax = 100;.
1700: 70 2d 3e 6e 4d 69 6e 20 3d 20 31 30 3b 0a 7d 0a p->nMin = 10;.}.
1710: 0a 2f 2a 0a 2a 2a 20 43 68 61 6e 67 65 20 74 68 ./*.** Change th
1720: 65 20 70 61 67 65 20 73 69 7a 65 20 66 6f 72 20 e page size for
1730: 50 43 61 63 68 65 20 6f 62 6a 65 63 74 2e 20 54 PCache object. T
1740: 68 65 20 63 61 6c 6c 65 72 20 6d 75 73 74 20 65 he caller must e
1750: 6e 73 75 72 65 20 74 68 61 74 20 74 68 65 72 65 nsure that there
1760: 0a 2a 2a 20 61 72 65 20 6e 6f 20 6f 75 74 73 74 .** are no outst
1770: 61 6e 64 69 6e 67 20 70 61 67 65 20 72 65 66 65 anding page refe
1780: 72 65 6e 63 65 73 20 77 68 65 6e 20 74 68 69 73 rences when this
1790: 20 66 75 6e 63 74 69 6f 6e 20 69 73 20 63 61 6c function is cal
17a0: 6c 65 64 2e 0a 2a 2f 0a 76 6f 69 64 20 73 71 6c led..*/.void sql
17b0: 69 74 65 33 50 63 61 63 68 65 53 65 74 50 61 67 ite3PcacheSetPag
17c0: 65 53 69 7a 65 28 50 43 61 63 68 65 20 2a 70 43 eSize(PCache *pC
17d0: 61 63 68 65 2c 20 69 6e 74 20 73 7a 50 61 67 65 ache, int szPage
17e0: 29 7b 0a 20 20 61 73 73 65 72 74 28 20 70 43 61 ){. assert( pCa
17f0: 63 68 65 2d 3e 6e 52 65 66 3d 3d 30 20 26 26 20 che->nRef==0 &&
1800: 70 43 61 63 68 65 2d 3e 70 44 69 72 74 79 3d 3d pCache->pDirty==
1810: 30 20 29 3b 0a 20 20 69 66 28 20 70 43 61 63 68 0 );. if( pCach
1820: 65 2d 3e 70 43 61 63 68 65 20 29 7b 0a 20 20 20 e->pCache ){.
1830: 20 73 71 6c 69 74 65 33 47 6c 6f 62 61 6c 43 6f sqlite3GlobalCo
1840: 6e 66 69 67 2e 70 63 61 63 68 65 2e 78 44 65 73 nfig.pcache.xDes
1850: 74 72 6f 79 28 70 43 61 63 68 65 2d 3e 70 43 61 troy(pCache->pCa
1860: 63 68 65 29 3b 0a 20 20 20 20 70 43 61 63 68 65 che);. pCache
1870: 2d 3e 70 43 61 63 68 65 20 3d 20 30 3b 0a 20 20 ->pCache = 0;.
1880: 7d 0a 20 20 70 43 61 63 68 65 2d 3e 73 7a 50 61 }. pCache->szPa
1890: 67 65 20 3d 20 73 7a 50 61 67 65 3b 0a 7d 0a 0a ge = szPage;.}..
18a0: 2f 2a 0a 2a 2a 20 54 72 79 20 74 6f 20 6f 62 74 /*.** Try to obt
18b0: 61 69 6e 20 61 20 70 61 67 65 20 66 72 6f 6d 20 ain a page from
18c0: 74 68 65 20 63 61 63 68 65 2e 0a 2a 2f 0a 69 6e the cache..*/.in
18d0: 74 20 73 71 6c 69 74 65 33 50 63 61 63 68 65 46 t sqlite3PcacheF
18e0: 65 74 63 68 28 0a 20 20 50 43 61 63 68 65 20 2a etch(. PCache *
18f0: 70 43 61 63 68 65 2c 20 20 20 20 20 20 20 2f 2a pCache, /*
1900: 20 4f 62 74 61 69 6e 20 74 68 65 20 70 61 67 65 Obtain the page
1910: 20 66 72 6f 6d 20 74 68 69 73 20 63 61 63 68 65 from this cache
1920: 20 2a 2f 0a 20 20 50 67 6e 6f 20 70 67 6e 6f 2c */. Pgno pgno,
1930: 20 20 20 20 20 20 20 20 20 20 20 20 2f 2a 20 50 /* P
1940: 61 67 65 20 6e 75 6d 62 65 72 20 74 6f 20 6f 62 age number to ob
1950: 74 61 69 6e 20 2a 2f 0a 20 20 69 6e 74 20 63 72 tain */. int cr
1960: 65 61 74 65 46 6c 61 67 2c 20 20 20 20 20 20 20 eateFlag,
1970: 2f 2a 20 49 66 20 74 72 75 65 2c 20 63 72 65 61 /* If true, crea
1980: 74 65 20 70 61 67 65 20 69 66 20 69 74 20 64 6f te page if it do
1990: 65 73 20 6e 6f 74 20 65 78 69 73 74 20 61 6c 72 es not exist alr
19a0: 65 61 64 79 20 2a 2f 0a 20 20 50 67 48 64 72 20 eady */. PgHdr
19b0: 2a 2a 70 70 50 61 67 65 20 20 20 20 20 20 20 20 **ppPage
19c0: 2f 2a 20 57 72 69 74 65 20 74 68 65 20 70 61 67 /* Write the pag
19d0: 65 20 68 65 72 65 20 2a 2f 0a 29 7b 0a 20 20 50 e here */.){. P
19e0: 67 48 64 72 20 2a 70 50 61 67 65 20 3d 20 30 3b gHdr *pPage = 0;
19f0: 0a 20 20 69 6e 74 20 65 43 72 65 61 74 65 3b 0a . int eCreate;.
1a00: 0a 20 20 61 73 73 65 72 74 28 20 70 43 61 63 68 . assert( pCach
1a10: 65 21 3d 30 20 29 3b 0a 20 20 61 73 73 65 72 74 e!=0 );. assert
1a20: 28 20 70 67 6e 6f 3e 30 20 29 3b 0a 0a 20 20 2f ( pgno>0 );.. /
1a30: 2a 20 49 66 20 74 68 65 20 70 6c 75 67 67 61 62 * If the pluggab
1a40: 6c 65 20 63 61 63 68 65 20 28 73 71 6c 69 74 65 le cache (sqlite
1a50: 33 5f 70 63 61 63 68 65 2a 29 20 68 61 73 20 6e 3_pcache*) has n
1a60: 6f 74 20 62 65 65 6e 20 61 6c 6c 6f 63 61 74 65 ot been allocate
1a70: 64 2c 0a 20 20 2a 2a 20 61 6c 6c 6f 63 61 74 65 d,. ** allocate
1a80: 20 69 74 20 6e 6f 77 2e 0a 20 20 2a 2f 0a 20 20 it now.. */.
1a90: 69 66 28 20 21 70 43 61 63 68 65 2d 3e 70 43 61 if( !pCache->pCa
1aa0: 63 68 65 20 26 26 20 63 72 65 61 74 65 46 6c 61 che && createFla
1ab0: 67 20 29 7b 0a 20 20 20 20 73 71 6c 69 74 65 33 g ){. sqlite3
1ac0: 5f 70 63 61 63 68 65 20 2a 70 3b 0a 20 20 20 20 _pcache *p;.
1ad0: 69 6e 74 20 6e 42 79 74 65 3b 0a 20 20 20 20 6e int nByte;. n
1ae0: 42 79 74 65 20 3d 20 70 43 61 63 68 65 2d 3e 73 Byte = pCache->s
1af0: 7a 50 61 67 65 20 2b 20 70 43 61 63 68 65 2d 3e zPage + pCache->
1b00: 73 7a 45 78 74 72 61 20 2b 20 73 69 7a 65 6f 66 szExtra + sizeof
1b10: 28 50 67 48 64 72 29 3b 0a 20 20 20 20 70 20 3d (PgHdr);. p =
1b20: 20 73 71 6c 69 74 65 33 47 6c 6f 62 61 6c 43 6f sqlite3GlobalCo
1b30: 6e 66 69 67 2e 70 63 61 63 68 65 2e 78 43 72 65 nfig.pcache.xCre
1b40: 61 74 65 28 6e 42 79 74 65 2c 20 70 43 61 63 68 ate(nByte, pCach
1b50: 65 2d 3e 62 50 75 72 67 65 61 62 6c 65 29 3b 0a e->bPurgeable);.
1b60: 20 20 20 20 69 66 28 20 21 70 20 29 7b 0a 20 20 if( !p ){.
1b70: 20 20 20 20 72 65 74 75 72 6e 20 53 51 4c 49 54 return SQLIT
1b80: 45 5f 4e 4f 4d 45 4d 3b 0a 20 20 20 20 7d 0a 20 E_NOMEM;. }.
1b90: 20 20 20 73 71 6c 69 74 65 33 47 6c 6f 62 61 6c sqlite3Global
1ba0: 43 6f 6e 66 69 67 2e 70 63 61 63 68 65 2e 78 43 Config.pcache.xC
1bb0: 61 63 68 65 73 69 7a 65 28 70 2c 20 70 43 61 63 achesize(p, pCac
1bc0: 68 65 2d 3e 6e 4d 61 78 29 3b 0a 20 20 20 20 70 he->nMax);. p
1bd0: 43 61 63 68 65 2d 3e 70 43 61 63 68 65 20 3d 20 Cache->pCache =
1be0: 70 3b 0a 20 20 7d 0a 0a 20 20 65 43 72 65 61 74 p;. }.. eCreat
1bf0: 65 20 3d 20 63 72 65 61 74 65 46 6c 61 67 20 3f e = createFlag ?
1c00: 20 31 20 3a 20 30 3b 0a 20 20 69 66 28 20 65 43 1 : 0;. if( eC
1c10: 72 65 61 74 65 20 26 26 20 28 21 70 43 61 63 68 reate && (!pCach
1c20: 65 2d 3e 62 50 75 72 67 65 61 62 6c 65 20 7c 7c e->bPurgeable ||
1c30: 20 21 70 43 61 63 68 65 2d 3e 70 44 69 72 74 79 !pCache->pDirty
1c40: 29 20 29 7b 0a 20 20 20 20 65 43 72 65 61 74 65 ) ){. eCreate
1c50: 20 3d 20 32 3b 0a 20 20 7d 0a 20 20 69 66 28 20 = 2;. }. if(
1c60: 70 43 61 63 68 65 2d 3e 70 43 61 63 68 65 20 29 pCache->pCache )
1c70: 7b 0a 20 20 20 20 70 50 61 67 65 20 3d 20 73 71 {. pPage = sq
1c80: 6c 69 74 65 33 47 6c 6f 62 61 6c 43 6f 6e 66 69 lite3GlobalConfi
1c90: 67 2e 70 63 61 63 68 65 2e 78 46 65 74 63 68 28 g.pcache.xFetch(
1ca0: 70 43 61 63 68 65 2d 3e 70 43 61 63 68 65 2c 20 pCache->pCache,
1cb0: 70 67 6e 6f 2c 20 65 43 72 65 61 74 65 29 3b 0a pgno, eCreate);.
1cc0: 20 20 7d 0a 0a 20 20 69 66 28 20 21 70 50 61 67 }.. if( !pPag
1cd0: 65 20 26 26 20 65 43 72 65 61 74 65 3d 3d 31 20 e && eCreate==1
1ce0: 29 7b 0a 20 20 20 20 50 67 48 64 72 20 2a 70 50 ){. PgHdr *pP
1cf0: 67 3b 0a 0a 20 20 20 20 2f 2a 20 46 69 6e 64 20 g;.. /* Find
1d00: 61 20 64 69 72 74 79 20 70 61 67 65 20 74 6f 20 a dirty page to
1d10: 77 72 69 74 65 2d 6f 75 74 20 61 6e 64 20 72 65 write-out and re
1d20: 63 79 63 6c 65 2e 20 46 69 72 73 74 20 74 72 79 cycle. First try
1d30: 20 74 6f 20 66 69 6e 64 20 61 20 0a 20 20 20 20 to find a .
1d40: 2a 2a 20 70 61 67 65 20 74 68 61 74 20 64 6f 65 ** page that doe
1d50: 73 20 6e 6f 74 20 72 65 71 75 69 72 65 20 61 20 s not require a
1d60: 6a 6f 75 72 6e 61 6c 2d 73 79 6e 63 20 28 6f 6e journal-sync (on
1d70: 65 20 77 69 74 68 20 50 47 48 44 52 5f 4e 45 45 e with PGHDR_NEE
1d80: 44 5f 53 59 4e 43 0a 20 20 20 20 2a 2a 20 63 6c D_SYNC. ** cl
1d90: 65 61 72 65 64 29 2c 20 62 75 74 20 69 66 20 74 eared), but if t
1da0: 68 61 74 20 69 73 20 6e 6f 74 20 70 6f 73 73 69 hat is not possi
1db0: 62 6c 65 20 73 65 74 74 6c 65 20 66 6f 72 20 61 ble settle for a
1dc0: 6e 79 20 6f 74 68 65 72 20 0a 20 20 20 20 2a 2a ny other . **
1dd0: 20 75 6e 72 65 66 65 72 65 6e 63 65 64 20 64 69 unreferenced di
1de0: 72 74 79 20 70 61 67 65 2e 0a 20 20 20 20 2a 2f rty page.. */
1df0: 0a 20 20 20 20 65 78 70 65 6e 73 69 76 65 5f 61 . expensive_a
1e00: 73 73 65 72 74 28 20 70 63 61 63 68 65 43 68 65 ssert( pcacheChe
1e10: 63 6b 53 79 6e 63 65 64 28 70 43 61 63 68 65 29 ckSynced(pCache)
1e20: 20 29 3b 0a 20 20 20 20 66 6f 72 28 70 50 67 3d );. for(pPg=
1e30: 70 43 61 63 68 65 2d 3e 70 53 79 6e 63 65 64 3b pCache->pSynced;
1e40: 20 0a 20 20 20 20 20 20 20 20 70 50 67 20 26 26 . pPg &&
1e50: 20 28 70 50 67 2d 3e 6e 52 65 66 20 7c 7c 20 28 (pPg->nRef || (
1e60: 70 50 67 2d 3e 66 6c 61 67 73 26 50 47 48 44 52 pPg->flags&PGHDR
1e70: 5f 4e 45 45 44 5f 53 59 4e 43 29 29 3b 20 0a 20 _NEED_SYNC)); .
1e80: 20 20 20 20 20 20 20 70 50 67 3d 70 50 67 2d 3e pPg=pPg->
1e90: 70 44 69 72 74 79 50 72 65 76 0a 20 20 20 20 29 pDirtyPrev. )
1ea0: 3b 0a 20 20 20 20 69 66 28 20 21 70 50 67 20 29 ;. if( !pPg )
1eb0: 7b 0a 20 20 20 20 20 20 66 6f 72 28 70 50 67 3d {. for(pPg=
1ec0: 70 43 61 63 68 65 2d 3e 70 44 69 72 74 79 54 61 pCache->pDirtyTa
1ed0: 69 6c 3b 20 70 50 67 20 26 26 20 70 50 67 2d 3e il; pPg && pPg->
1ee0: 6e 52 65 66 3b 20 70 50 67 3d 70 50 67 2d 3e 70 nRef; pPg=pPg->p
1ef0: 44 69 72 74 79 50 72 65 76 29 3b 0a 20 20 20 20 DirtyPrev);.
1f00: 7d 0a 20 20 20 20 69 66 28 20 70 50 67 20 29 7b }. if( pPg ){
1f10: 0a 20 20 20 20 20 20 69 6e 74 20 72 63 3b 0a 20 . int rc;.
1f20: 20 20 20 20 20 72 63 20 3d 20 70 43 61 63 68 65 rc = pCache
1f30: 2d 3e 78 53 74 72 65 73 73 28 70 43 61 63 68 65 ->xStress(pCache
1f40: 2d 3e 70 53 74 72 65 73 73 2c 20 70 50 67 29 3b ->pStress, pPg);
1f50: 0a 20 20 20 20 20 20 69 66 28 20 72 63 21 3d 53 . if( rc!=S
1f60: 51 4c 49 54 45 5f 4f 4b 20 26 26 20 72 63 21 3d QLITE_OK && rc!=
1f70: 53 51 4c 49 54 45 5f 42 55 53 59 20 29 7b 0a 20 SQLITE_BUSY ){.
1f80: 20 20 20 20 20 20 20 72 65 74 75 72 6e 20 72 63 return rc
1f90: 3b 0a 20 20 20 20 20 20 7d 0a 20 20 20 20 7d 0a ;. }. }.
1fa0: 0a 20 20 20 20 70 50 61 67 65 20 3d 20 73 71 6c . pPage = sql
1fb0: 69 74 65 33 47 6c 6f 62 61 6c 43 6f 6e 66 69 67 ite3GlobalConfig
1fc0: 2e 70 63 61 63 68 65 2e 78 46 65 74 63 68 28 70 .pcache.xFetch(p
1fd0: 43 61 63 68 65 2d 3e 70 43 61 63 68 65 2c 20 70 Cache->pCache, p
1fe0: 67 6e 6f 2c 20 32 29 3b 0a 20 20 7d 0a 0a 20 20 gno, 2);. }..
1ff0: 69 66 28 20 70 50 61 67 65 20 29 7b 0a 20 20 20 if( pPage ){.
2000: 20 69 66 28 20 30 3d 3d 70 50 61 67 65 2d 3e 6e if( 0==pPage->n
2010: 52 65 66 20 29 7b 0a 20 20 20 20 20 20 70 43 61 Ref ){. pCa
2020: 63 68 65 2d 3e 6e 52 65 66 2b 2b 3b 0a 20 20 20 che->nRef++;.
2030: 20 7d 0a 20 20 20 20 70 50 61 67 65 2d 3e 6e 52 }. pPage->nR
2040: 65 66 2b 2b 3b 0a 20 20 20 20 70 50 61 67 65 2d ef++;. pPage-
2050: 3e 70 44 61 74 61 20 3d 20 28 76 6f 69 64 2a 29 >pData = (void*)
2060: 26 70 50 61 67 65 5b 31 5d 3b 0a 20 20 20 20 70 &pPage[1];. p
2070: 50 61 67 65 2d 3e 70 45 78 74 72 61 20 3d 20 28 Page->pExtra = (
2080: 76 6f 69 64 2a 29 26 28 28 63 68 61 72 2a 29 70 void*)&((char*)p
2090: 50 61 67 65 2d 3e 70 44 61 74 61 29 5b 70 43 61 Page->pData)[pCa
20a0: 63 68 65 2d 3e 73 7a 50 61 67 65 5d 3b 0a 20 20 che->szPage];.
20b0: 20 20 70 50 61 67 65 2d 3e 70 43 61 63 68 65 20 pPage->pCache
20c0: 3d 20 70 43 61 63 68 65 3b 0a 20 20 20 20 70 50 = pCache;. pP
20d0: 61 67 65 2d 3e 70 67 6e 6f 20 3d 20 70 67 6e 6f age->pgno = pgno
20e0: 3b 0a 20 20 20 20 69 66 28 20 70 67 6e 6f 3d 3d ;. if( pgno==
20f0: 31 20 29 7b 0a 20 20 20 20 20 20 70 43 61 63 68 1 ){. pCach
2100: 65 2d 3e 70 50 61 67 65 31 20 3d 20 70 50 61 67 e->pPage1 = pPag
2110: 65 3b 0a 20 20 20 20 7d 0a 20 20 7d 0a 20 20 2a e;. }. }. *
2120: 70 70 50 61 67 65 20 3d 20 70 50 61 67 65 3b 0a ppPage = pPage;.
2130: 20 20 72 65 74 75 72 6e 20 28 70 50 61 67 65 3d return (pPage=
2140: 3d 30 20 26 26 20 65 43 72 65 61 74 65 29 20 3f =0 && eCreate) ?
2150: 20 53 51 4c 49 54 45 5f 4e 4f 4d 45 4d 20 3a 20 SQLITE_NOMEM :
2160: 53 51 4c 49 54 45 5f 4f 4b 3b 0a 7d 0a 0a 2f 2a SQLITE_OK;.}../*
2170: 0a 2a 2a 20 44 65 63 72 65 6d 65 6e 74 20 74 68 .** Decrement th
2180: 65 20 72 65 66 65 72 65 6e 63 65 20 63 6f 75 6e e reference coun
2190: 74 20 6f 6e 20 61 20 70 61 67 65 2e 20 49 66 20 t on a page. If
21a0: 74 68 65 20 70 61 67 65 20 69 73 20 63 6c 65 61 the page is clea
21b0: 6e 20 61 6e 64 20 74 68 65 0a 2a 2a 20 72 65 66 n and the.** ref
21c0: 65 72 65 6e 63 65 20 63 6f 75 6e 74 20 64 72 6f erence count dro
21d0: 70 73 20 74 6f 20 30 2c 20 74 68 65 6e 20 69 74 ps to 0, then it
21e0: 20 69 73 20 6d 61 64 65 20 65 6c 69 62 6c 65 20 is made elible
21f0: 66 6f 72 20 72 65 63 79 63 6c 69 6e 67 2e 0a 2a for recycling..*
2200: 2f 0a 76 6f 69 64 20 73 71 6c 69 74 65 33 50 63 /.void sqlite3Pc
2210: 61 63 68 65 52 65 6c 65 61 73 65 28 50 67 48 64 acheRelease(PgHd
2220: 72 20 2a 70 29 7b 0a 20 20 61 73 73 65 72 74 28 r *p){. assert(
2230: 20 70 2d 3e 6e 52 65 66 3e 30 20 29 3b 0a 20 20 p->nRef>0 );.
2240: 70 2d 3e 6e 52 65 66 2d 2d 3b 0a 20 20 69 66 28 p->nRef--;. if(
2250: 20 70 2d 3e 6e 52 65 66 3d 3d 30 20 29 7b 0a 20 p->nRef==0 ){.
2260: 20 20 20 50 43 61 63 68 65 20 2a 70 43 61 63 68 PCache *pCach
2270: 65 20 3d 20 70 2d 3e 70 43 61 63 68 65 3b 0a 20 e = p->pCache;.
2280: 20 20 20 70 43 61 63 68 65 2d 3e 6e 52 65 66 2d pCache->nRef-
2290: 2d 3b 0a 20 20 20 20 69 66 28 20 28 70 2d 3e 66 -;. if( (p->f
22a0: 6c 61 67 73 26 50 47 48 44 52 5f 44 49 52 54 59 lags&PGHDR_DIRTY
22b0: 29 3d 3d 30 20 29 7b 0a 20 20 20 20 20 20 70 63 )==0 ){. pc
22c0: 61 63 68 65 55 6e 70 69 6e 28 70 29 3b 0a 20 20 acheUnpin(p);.
22d0: 20 20 7d 65 6c 73 65 7b 0a 20 20 20 20 20 20 2f }else{. /
22e0: 2a 20 4d 6f 76 65 20 74 68 65 20 70 61 67 65 20 * Move the page
22f0: 74 6f 20 74 68 65 20 68 65 61 64 20 6f 66 20 74 to the head of t
2300: 68 65 20 64 69 72 74 79 20 6c 69 73 74 2e 20 2a he dirty list. *
2310: 2f 0a 20 20 20 20 20 20 70 63 61 63 68 65 52 65 /. pcacheRe
2320: 6d 6f 76 65 46 72 6f 6d 44 69 72 74 79 4c 69 73 moveFromDirtyLis
2330: 74 28 70 29 3b 0a 20 20 20 20 20 20 70 63 61 63 t(p);. pcac
2340: 68 65 41 64 64 54 6f 44 69 72 74 79 4c 69 73 74 heAddToDirtyList
2350: 28 70 29 3b 0a 20 20 20 20 7d 0a 20 20 7d 0a 7d (p);. }. }.}
2360: 0a 0a 2f 2a 0a 2a 2a 20 49 6e 63 72 65 61 73 65 ../*.** Increase
2370: 20 74 68 65 20 72 65 66 65 72 65 6e 63 65 20 63 the reference c
2380: 6f 75 6e 74 20 6f 66 20 61 20 73 75 70 70 6c 69 ount of a suppli
2390: 65 64 20 70 61 67 65 20 62 79 20 31 2e 0a 2a 2f ed page by 1..*/
23a0: 0a 76 6f 69 64 20 73 71 6c 69 74 65 33 50 63 61 .void sqlite3Pca
23b0: 63 68 65 52 65 66 28 50 67 48 64 72 20 2a 70 29 cheRef(PgHdr *p)
23c0: 7b 0a 20 20 61 73 73 65 72 74 28 70 2d 3e 6e 52 {. assert(p->nR
23d0: 65 66 3e 30 29 3b 0a 20 20 70 2d 3e 6e 52 65 66 ef>0);. p->nRef
23e0: 2b 2b 3b 0a 7d 0a 0a 2f 2a 0a 2a 2a 20 44 72 6f ++;.}../*.** Dro
23f0: 70 20 61 20 70 61 67 65 20 66 72 6f 6d 20 74 68 p a page from th
2400: 65 20 63 61 63 68 65 2e 20 54 68 65 72 65 20 6d e cache. There m
2410: 75 73 74 20 62 65 20 65 78 61 63 74 6c 79 20 6f ust be exactly o
2420: 6e 65 20 72 65 66 65 72 65 6e 63 65 20 74 6f 20 ne reference to
2430: 74 68 65 0a 2a 2a 20 70 61 67 65 2e 20 54 68 69 the.** page. Thi
2440: 73 20 66 75 6e 63 74 69 6f 6e 20 64 65 6c 65 74 s function delet
2450: 65 73 20 74 68 61 74 20 72 65 66 65 72 65 6e 63 es that referenc
2460: 65 2c 20 73 6f 20 61 66 74 65 72 20 69 74 20 72 e, so after it r
2470: 65 74 75 72 6e 73 20 74 68 65 0a 2a 2a 20 70 61 eturns the.** pa
2480: 67 65 20 70 6f 69 6e 74 65 64 20 74 6f 20 62 79 ge pointed to by
2490: 20 70 20 69 73 20 69 6e 76 61 6c 69 64 2e 0a 2a p is invalid..*
24a0: 2f 0a 76 6f 69 64 20 73 71 6c 69 74 65 33 50 63 /.void sqlite3Pc
24b0: 61 63 68 65 44 72 6f 70 28 50 67 48 64 72 20 2a acheDrop(PgHdr *
24c0: 70 29 7b 0a 20 20 50 43 61 63 68 65 20 2a 70 43 p){. PCache *pC
24d0: 61 63 68 65 3b 0a 20 20 61 73 73 65 72 74 28 20 ache;. assert(
24e0: 70 2d 3e 6e 52 65 66 3d 3d 31 20 29 3b 0a 20 20 p->nRef==1 );.
24f0: 69 66 28 20 70 2d 3e 66 6c 61 67 73 26 50 47 48 if( p->flags&PGH
2500: 44 52 5f 44 49 52 54 59 20 29 7b 0a 20 20 20 20 DR_DIRTY ){.
2510: 70 63 61 63 68 65 52 65 6d 6f 76 65 46 72 6f 6d pcacheRemoveFrom
2520: 44 69 72 74 79 4c 69 73 74 28 70 29 3b 0a 20 20 DirtyList(p);.
2530: 7d 0a 20 20 70 43 61 63 68 65 20 3d 20 70 2d 3e }. pCache = p->
2540: 70 43 61 63 68 65 3b 0a 20 20 70 43 61 63 68 65 pCache;. pCache
2550: 2d 3e 6e 52 65 66 2d 2d 3b 0a 20 20 69 66 28 20 ->nRef--;. if(
2560: 70 2d 3e 70 67 6e 6f 3d 3d 31 20 29 7b 0a 20 20 p->pgno==1 ){.
2570: 20 20 70 43 61 63 68 65 2d 3e 70 50 61 67 65 31 pCache->pPage1
2580: 20 3d 20 30 3b 0a 20 20 7d 0a 20 20 73 71 6c 69 = 0;. }. sqli
2590: 74 65 33 47 6c 6f 62 61 6c 43 6f 6e 66 69 67 2e te3GlobalConfig.
25a0: 70 63 61 63 68 65 2e 78 55 6e 70 69 6e 28 70 43 pcache.xUnpin(pC
25b0: 61 63 68 65 2d 3e 70 43 61 63 68 65 2c 20 70 2c ache->pCache, p,
25c0: 20 31 29 3b 0a 7d 0a 0a 2f 2a 0a 2a 2a 20 4d 61 1);.}../*.** Ma
25d0: 6b 65 20 73 75 72 65 20 74 68 65 20 70 61 67 65 ke sure the page
25e0: 20 69 73 20 6d 61 72 6b 65 64 20 61 73 20 64 69 is marked as di
25f0: 72 74 79 2e 20 49 66 20 69 74 20 69 73 6e 27 74 rty. If it isn't
2600: 20 64 69 72 74 79 20 61 6c 72 65 61 64 79 2c 0a dirty already,.
2610: 2a 2a 20 6d 61 6b 65 20 69 74 20 73 6f 2e 0a 2a ** make it so..*
2620: 2f 0a 76 6f 69 64 20 73 71 6c 69 74 65 33 50 63 /.void sqlite3Pc
2630: 61 63 68 65 4d 61 6b 65 44 69 72 74 79 28 50 67 acheMakeDirty(Pg
2640: 48 64 72 20 2a 70 29 7b 0a 20 20 50 43 61 63 68 Hdr *p){. PCach
2650: 65 20 2a 70 43 61 63 68 65 3b 0a 20 20 70 2d 3e e *pCache;. p->
2660: 66 6c 61 67 73 20 26 3d 20 7e 50 47 48 44 52 5f flags &= ~PGHDR_
2670: 44 4f 4e 54 5f 57 52 49 54 45 3b 0a 20 20 61 73 DONT_WRITE;. as
2680: 73 65 72 74 28 20 70 2d 3e 6e 52 65 66 3e 30 20 sert( p->nRef>0
2690: 29 3b 0a 20 20 69 66 28 20 30 3d 3d 28 70 2d 3e );. if( 0==(p->
26a0: 66 6c 61 67 73 20 26 20 50 47 48 44 52 5f 44 49 flags & PGHDR_DI
26b0: 52 54 59 29 20 29 7b 0a 20 20 20 20 70 43 61 63 RTY) ){. pCac
26c0: 68 65 20 3d 20 70 2d 3e 70 43 61 63 68 65 3b 0a he = p->pCache;.
26d0: 20 20 20 20 70 2d 3e 66 6c 61 67 73 20 7c 3d 20 p->flags |=
26e0: 50 47 48 44 52 5f 44 49 52 54 59 3b 0a 20 20 20 PGHDR_DIRTY;.
26f0: 20 70 63 61 63 68 65 41 64 64 54 6f 44 69 72 74 pcacheAddToDirt
2700: 79 4c 69 73 74 28 20 70 29 3b 0a 20 20 7d 0a 7d yList( p);. }.}
2710: 0a 0a 2f 2a 0a 2a 2a 20 4d 61 6b 65 20 73 75 72 ../*.** Make sur
2720: 65 20 74 68 65 20 70 61 67 65 20 69 73 20 6d 61 e the page is ma
2730: 72 6b 65 64 20 61 73 20 63 6c 65 61 6e 2e 20 49 rked as clean. I
2740: 66 20 69 74 20 69 73 6e 27 74 20 63 6c 65 61 6e f it isn't clean
2750: 20 61 6c 72 65 61 64 79 2c 0a 2a 2a 20 6d 61 6b already,.** mak
2760: 65 20 69 74 20 73 6f 2e 0a 2a 2f 0a 76 6f 69 64 e it so..*/.void
2770: 20 73 71 6c 69 74 65 33 50 63 61 63 68 65 4d 61 sqlite3PcacheMa
2780: 6b 65 43 6c 65 61 6e 28 50 67 48 64 72 20 2a 70 keClean(PgHdr *p
2790: 29 7b 0a 20 20 69 66 28 20 28 70 2d 3e 66 6c 61 ){. if( (p->fla
27a0: 67 73 20 26 20 50 47 48 44 52 5f 44 49 52 54 59 gs & PGHDR_DIRTY
27b0: 29 20 29 7b 0a 20 20 20 20 70 63 61 63 68 65 52 ) ){. pcacheR
27c0: 65 6d 6f 76 65 46 72 6f 6d 44 69 72 74 79 4c 69 emoveFromDirtyLi
27d0: 73 74 28 70 29 3b 0a 20 20 20 20 70 2d 3e 66 6c st(p);. p->fl
27e0: 61 67 73 20 26 3d 20 7e 28 50 47 48 44 52 5f 44 ags &= ~(PGHDR_D
27f0: 49 52 54 59 7c 50 47 48 44 52 5f 4e 45 45 44 5f IRTY|PGHDR_NEED_
2800: 53 59 4e 43 29 3b 0a 20 20 20 20 69 66 28 20 70 SYNC);. if( p
2810: 2d 3e 6e 52 65 66 3d 3d 30 20 29 7b 0a 20 20 20 ->nRef==0 ){.
2820: 20 20 20 70 63 61 63 68 65 55 6e 70 69 6e 28 70 pcacheUnpin(p
2830: 29 3b 0a 20 20 20 20 7d 0a 20 20 7d 0a 7d 0a 0a );. }. }.}..
2840: 2f 2a 0a 2a 2a 20 4d 61 6b 65 20 65 76 65 72 79 /*.** Make every
2850: 20 70 61 67 65 20 69 6e 20 74 68 65 20 63 61 63 page in the cac
2860: 68 65 20 63 6c 65 61 6e 2e 0a 2a 2f 0a 76 6f 69 he clean..*/.voi
2870: 64 20 73 71 6c 69 74 65 33 50 63 61 63 68 65 43 d sqlite3PcacheC
2880: 6c 65 61 6e 41 6c 6c 28 50 43 61 63 68 65 20 2a leanAll(PCache *
2890: 70 43 61 63 68 65 29 7b 0a 20 20 50 67 48 64 72 pCache){. PgHdr
28a0: 20 2a 70 3b 0a 20 20 77 68 69 6c 65 28 20 28 70 *p;. while( (p
28b0: 20 3d 20 70 43 61 63 68 65 2d 3e 70 44 69 72 74 = pCache->pDirt
28c0: 79 29 21 3d 30 20 29 7b 0a 20 20 20 20 73 71 6c y)!=0 ){. sql
28d0: 69 74 65 33 50 63 61 63 68 65 4d 61 6b 65 43 6c ite3PcacheMakeCl
28e0: 65 61 6e 28 70 29 3b 0a 20 20 7d 0a 7d 0a 0a 2f ean(p);. }.}../
28f0: 2a 0a 2a 2a 20 43 6c 65 61 72 20 74 68 65 20 50 *.** Clear the P
2900: 47 48 44 52 5f 4e 45 45 44 5f 53 59 4e 43 20 66 GHDR_NEED_SYNC f
2910: 6c 61 67 20 66 72 6f 6d 20 61 6c 6c 20 64 69 72 lag from all dir
2920: 74 79 20 70 61 67 65 73 2e 0a 2a 2f 0a 76 6f 69 ty pages..*/.voi
2930: 64 20 73 71 6c 69 74 65 33 50 63 61 63 68 65 43 d sqlite3PcacheC
2940: 6c 65 61 72 53 79 6e 63 46 6c 61 67 73 28 50 43 learSyncFlags(PC
2950: 61 63 68 65 20 2a 70 43 61 63 68 65 29 7b 0a 20 ache *pCache){.
2960: 20 50 67 48 64 72 20 2a 70 3b 0a 20 20 66 6f 72 PgHdr *p;. for
2970: 28 70 3d 70 43 61 63 68 65 2d 3e 70 44 69 72 74 (p=pCache->pDirt
2980: 79 3b 20 70 3b 20 70 3d 70 2d 3e 70 44 69 72 74 y; p; p=p->pDirt
2990: 79 4e 65 78 74 29 7b 0a 20 20 20 20 70 2d 3e 66 yNext){. p->f
29a0: 6c 61 67 73 20 26 3d 20 7e 50 47 48 44 52 5f 4e lags &= ~PGHDR_N
29b0: 45 45 44 5f 53 59 4e 43 3b 0a 20 20 7d 0a 20 20 EED_SYNC;. }.
29c0: 70 43 61 63 68 65 2d 3e 70 53 79 6e 63 65 64 20 pCache->pSynced
29d0: 3d 20 70 43 61 63 68 65 2d 3e 70 44 69 72 74 79 = pCache->pDirty
29e0: 54 61 69 6c 3b 0a 7d 0a 0a 2f 2a 0a 2a 2a 20 43 Tail;.}../*.** C
29f0: 68 61 6e 67 65 20 74 68 65 20 70 61 67 65 20 6e hange the page n
2a00: 75 6d 62 65 72 20 6f 66 20 70 61 67 65 20 70 20 umber of page p
2a10: 74 6f 20 6e 65 77 50 67 6e 6f 2e 20 0a 2a 2f 0a to newPgno. .*/.
2a20: 76 6f 69 64 20 73 71 6c 69 74 65 33 50 63 61 63 void sqlite3Pcac
2a30: 68 65 4d 6f 76 65 28 50 67 48 64 72 20 2a 70 2c heMove(PgHdr *p,
2a40: 20 50 67 6e 6f 20 6e 65 77 50 67 6e 6f 29 7b 0a Pgno newPgno){.
2a50: 20 20 50 43 61 63 68 65 20 2a 70 43 61 63 68 65 PCache *pCache
2a60: 20 3d 20 70 2d 3e 70 43 61 63 68 65 3b 0a 20 20 = p->pCache;.
2a70: 61 73 73 65 72 74 28 20 70 2d 3e 6e 52 65 66 3e assert( p->nRef>
2a80: 30 20 29 3b 0a 20 20 61 73 73 65 72 74 28 20 6e 0 );. assert( n
2a90: 65 77 50 67 6e 6f 3e 30 20 29 3b 0a 20 20 73 71 ewPgno>0 );. sq
2aa0: 6c 69 74 65 33 47 6c 6f 62 61 6c 43 6f 6e 66 69 lite3GlobalConfi
2ab0: 67 2e 70 63 61 63 68 65 2e 78 52 65 6b 65 79 28 g.pcache.xRekey(
2ac0: 70 43 61 63 68 65 2d 3e 70 43 61 63 68 65 2c 20 pCache->pCache,
2ad0: 70 2c 20 70 2d 3e 70 67 6e 6f 2c 20 6e 65 77 50 p, p->pgno, newP
2ae0: 67 6e 6f 29 3b 0a 20 20 70 2d 3e 70 67 6e 6f 20 gno);. p->pgno
2af0: 3d 20 6e 65 77 50 67 6e 6f 3b 0a 20 20 69 66 28 = newPgno;. if(
2b00: 20 28 70 2d 3e 66 6c 61 67 73 26 50 47 48 44 52 (p->flags&PGHDR
2b10: 5f 44 49 52 54 59 29 20 26 26 20 28 70 2d 3e 66 _DIRTY) && (p->f
2b20: 6c 61 67 73 26 50 47 48 44 52 5f 4e 45 45 44 5f lags&PGHDR_NEED_
2b30: 53 59 4e 43 29 20 29 7b 0a 20 20 20 20 70 63 61 SYNC) ){. pca
2b40: 63 68 65 52 65 6d 6f 76 65 46 72 6f 6d 44 69 72 cheRemoveFromDir
2b50: 74 79 4c 69 73 74 28 70 29 3b 0a 20 20 20 20 70 tyList(p);. p
2b60: 63 61 63 68 65 41 64 64 54 6f 44 69 72 74 79 4c cacheAddToDirtyL
2b70: 69 73 74 28 70 29 3b 0a 20 20 7d 0a 7d 0a 0a 2f ist(p);. }.}../
2b80: 2a 0a 2a 2a 20 44 72 6f 70 20 65 76 65 72 79 20 *.** Drop every
2b90: 63 61 63 68 65 20 65 6e 74 72 79 20 77 68 6f 73 cache entry whos
2ba0: 65 20 70 61 67 65 20 6e 75 6d 62 65 72 20 69 73 e page number is
2bb0: 20 67 72 65 61 74 65 72 20 74 68 61 6e 20 22 70 greater than "p
2bc0: 67 6e 6f 22 2e 20 54 68 65 0a 2a 2a 20 63 61 6c gno". The.** cal
2bd0: 6c 65 72 20 6d 75 73 74 20 65 6e 73 75 72 65 20 ler must ensure
2be0: 74 68 61 74 20 74 68 65 72 65 20 61 72 65 20 6e that there are n
2bf0: 6f 20 6f 75 74 73 74 61 6e 64 69 6e 67 20 72 65 o outstanding re
2c00: 66 65 72 65 6e 63 65 73 20 74 6f 20 61 6e 79 20 ferences to any
2c10: 70 61 67 65 73 0a 2a 2a 20 6f 74 68 65 72 20 74 pages.** other t
2c20: 68 61 6e 20 70 61 67 65 20 31 20 77 69 74 68 20 han page 1 with
2c30: 61 20 70 61 67 65 20 6e 75 6d 62 65 72 20 67 72 a page number gr
2c40: 65 61 74 65 72 20 74 68 61 6e 20 70 67 6e 6f 2e eater than pgno.
2c50: 0a 2a 2a 0a 2a 2a 20 49 66 20 74 68 65 72 65 20 .**.** If there
2c60: 69 73 20 61 20 72 65 66 65 72 65 6e 63 65 20 74 is a reference t
2c70: 6f 20 70 61 67 65 20 31 20 61 6e 64 20 74 68 65 o page 1 and the
2c80: 20 70 67 6e 6f 20 70 61 72 61 6d 65 74 65 72 20 pgno parameter
2c90: 70 61 73 73 65 64 20 74 6f 20 74 68 69 73 0a 2a passed to this.*
2ca0: 2a 20 66 75 6e 63 74 69 6f 6e 20 69 73 20 30 2c * function is 0,
2cb0: 20 74 68 65 6e 20 74 68 65 20 64 61 74 61 20 61 then the data a
2cc0: 72 65 61 20 61 73 73 6f 63 69 61 74 65 64 20 77 rea associated w
2cd0: 69 74 68 20 70 61 67 65 20 31 20 69 73 20 7a 65 ith page 1 is ze
2ce0: 72 6f 65 64 2c 20 62 75 74 0a 2a 2a 20 74 68 65 roed, but.** the
2cf0: 20 70 61 67 65 20 6f 62 6a 65 63 74 20 69 73 20 page object is
2d00: 6e 6f 74 20 64 72 6f 70 70 65 64 2e 0a 2a 2f 0a not dropped..*/.
2d10: 76 6f 69 64 20 73 71 6c 69 74 65 33 50 63 61 63 void sqlite3Pcac
2d20: 68 65 54 72 75 6e 63 61 74 65 28 50 43 61 63 68 heTruncate(PCach
2d30: 65 20 2a 70 43 61 63 68 65 2c 20 50 67 6e 6f 20 e *pCache, Pgno
2d40: 70 67 6e 6f 29 7b 0a 20 20 69 66 28 20 70 43 61 pgno){. if( pCa
2d50: 63 68 65 2d 3e 70 43 61 63 68 65 20 29 7b 0a 20 che->pCache ){.
2d60: 20 20 20 50 67 48 64 72 20 2a 70 3b 0a 20 20 20 PgHdr *p;.
2d70: 20 50 67 48 64 72 20 2a 70 4e 65 78 74 3b 0a 20 PgHdr *pNext;.
2d80: 20 20 20 66 6f 72 28 70 3d 70 43 61 63 68 65 2d for(p=pCache-
2d90: 3e 70 44 69 72 74 79 3b 20 70 3b 20 70 3d 70 4e >pDirty; p; p=pN
2da0: 65 78 74 29 7b 0a 20 20 20 20 20 20 70 4e 65 78 ext){. pNex
2db0: 74 20 3d 20 70 2d 3e 70 44 69 72 74 79 4e 65 78 t = p->pDirtyNex
2dc0: 74 3b 0a 20 20 20 20 20 20 69 66 28 20 70 2d 3e t;. if( p->
2dd0: 70 67 6e 6f 3e 70 67 6e 6f 20 29 7b 0a 20 20 20 pgno>pgno ){.
2de0: 20 20 20 20 20 61 73 73 65 72 74 28 20 70 2d 3e assert( p->
2df0: 66 6c 61 67 73 26 50 47 48 44 52 5f 44 49 52 54 flags&PGHDR_DIRT
2e00: 59 20 29 3b 0a 20 20 20 20 20 20 20 20 73 71 6c Y );. sql
2e10: 69 74 65 33 50 63 61 63 68 65 4d 61 6b 65 43 6c ite3PcacheMakeCl
2e20: 65 61 6e 28 70 29 3b 0a 20 20 20 20 20 20 7d 0a ean(p);. }.
2e30: 20 20 20 20 7d 0a 20 20 20 20 69 66 28 20 70 67 }. if( pg
2e40: 6e 6f 3d 3d 30 20 26 26 20 70 43 61 63 68 65 2d no==0 && pCache-
2e50: 3e 70 50 61 67 65 31 20 29 7b 0a 20 20 20 20 20 >pPage1 ){.
2e60: 20 6d 65 6d 73 65 74 28 70 43 61 63 68 65 2d 3e memset(pCache->
2e70: 70 50 61 67 65 31 2d 3e 70 44 61 74 61 2c 20 30 pPage1->pData, 0
2e80: 2c 20 70 43 61 63 68 65 2d 3e 73 7a 50 61 67 65 , pCache->szPage
2e90: 29 3b 0a 20 20 20 20 20 20 70 67 6e 6f 20 3d 20 );. pgno =
2ea0: 31 3b 0a 20 20 20 20 7d 0a 20 20 20 20 73 71 6c 1;. }. sql
2eb0: 69 74 65 33 47 6c 6f 62 61 6c 43 6f 6e 66 69 67 ite3GlobalConfig
2ec0: 2e 70 63 61 63 68 65 2e 78 54 72 75 6e 63 61 74 .pcache.xTruncat
2ed0: 65 28 70 43 61 63 68 65 2d 3e 70 43 61 63 68 65 e(pCache->pCache
2ee0: 2c 20 70 67 6e 6f 2b 31 29 3b 0a 20 20 7d 0a 7d , pgno+1);. }.}
2ef0: 0a 0a 2f 2a 0a 2a 2a 20 43 6c 6f 73 65 20 61 20 ../*.** Close a
2f00: 63 61 63 68 65 2e 0a 2a 2f 0a 76 6f 69 64 20 73 cache..*/.void s
2f10: 71 6c 69 74 65 33 50 63 61 63 68 65 43 6c 6f 73 qlite3PcacheClos
2f20: 65 28 50 43 61 63 68 65 20 2a 70 43 61 63 68 65 e(PCache *pCache
2f30: 29 7b 0a 20 20 69 66 28 20 70 43 61 63 68 65 2d ){. if( pCache-
2f40: 3e 70 43 61 63 68 65 20 29 7b 0a 20 20 20 20 73 >pCache ){. s
2f50: 71 6c 69 74 65 33 47 6c 6f 62 61 6c 43 6f 6e 66 qlite3GlobalConf
2f60: 69 67 2e 70 63 61 63 68 65 2e 78 44 65 73 74 72 ig.pcache.xDestr
2f70: 6f 79 28 70 43 61 63 68 65 2d 3e 70 43 61 63 68 oy(pCache->pCach
2f80: 65 29 3b 0a 20 20 7d 0a 7d 0a 0a 2f 2a 20 0a 2a e);. }.}../* .*
2f90: 2a 20 44 69 73 63 61 72 64 20 74 68 65 20 63 6f * Discard the co
2fa0: 6e 74 65 6e 74 73 20 6f 66 20 74 68 65 20 63 61 ntents of the ca
2fb0: 63 68 65 2e 0a 2a 2f 0a 76 6f 69 64 20 73 71 6c che..*/.void sql
2fc0: 69 74 65 33 50 63 61 63 68 65 43 6c 65 61 72 28 ite3PcacheClear(
2fd0: 50 43 61 63 68 65 20 2a 70 43 61 63 68 65 29 7b PCache *pCache){
2fe0: 0a 20 20 73 71 6c 69 74 65 33 50 63 61 63 68 65 . sqlite3Pcache
2ff0: 54 72 75 6e 63 61 74 65 28 70 43 61 63 68 65 2c Truncate(pCache,
3000: 20 30 29 3b 0a 7d 0a 0a 2f 2a 0a 2a 2a 20 4d 65 0);.}../*.** Me
3010: 72 67 65 20 74 77 6f 20 6c 69 73 74 73 20 6f 66 rge two lists of
3020: 20 70 61 67 65 73 20 63 6f 6e 6e 65 63 74 65 64 pages connected
3030: 20 62 79 20 70 44 69 72 74 79 20 61 6e 64 20 69 by pDirty and i
3040: 6e 20 70 67 6e 6f 20 6f 72 64 65 72 2e 0a 2a 2a n pgno order..**
3050: 20 44 6f 20 6e 6f 74 20 62 6f 74 68 20 66 69 78 Do not both fix
3060: 69 6e 67 20 74 68 65 20 70 44 69 72 74 79 50 72 ing the pDirtyPr
3070: 65 76 20 70 6f 69 6e 74 65 72 73 2e 0a 2a 2f 0a ev pointers..*/.
3080: 73 74 61 74 69 63 20 50 67 48 64 72 20 2a 70 63 static PgHdr *pc
3090: 61 63 68 65 4d 65 72 67 65 44 69 72 74 79 4c 69 acheMergeDirtyLi
30a0: 73 74 28 50 67 48 64 72 20 2a 70 41 2c 20 50 67 st(PgHdr *pA, Pg
30b0: 48 64 72 20 2a 70 42 29 7b 0a 20 20 50 67 48 64 Hdr *pB){. PgHd
30c0: 72 20 72 65 73 75 6c 74 2c 20 2a 70 54 61 69 6c r result, *pTail
30d0: 3b 0a 20 20 70 54 61 69 6c 20 3d 20 26 72 65 73 ;. pTail = &res
30e0: 75 6c 74 3b 0a 20 20 77 68 69 6c 65 28 20 70 41 ult;. while( pA
30f0: 20 26 26 20 70 42 20 29 7b 0a 20 20 20 20 69 66 && pB ){. if
3100: 28 20 70 41 2d 3e 70 67 6e 6f 3c 70 42 2d 3e 70 ( pA->pgno<pB->p
3110: 67 6e 6f 20 29 7b 0a 20 20 20 20 20 20 70 54 61 gno ){. pTa
3120: 69 6c 2d 3e 70 44 69 72 74 79 20 3d 20 70 41 3b il->pDirty = pA;
3130: 0a 20 20 20 20 20 20 70 54 61 69 6c 20 3d 20 70 . pTail = p
3140: 41 3b 0a 20 20 20 20 20 20 70 41 20 3d 20 70 41 A;. pA = pA
3150: 2d 3e 70 44 69 72 74 79 3b 0a 20 20 20 20 7d 65 ->pDirty;. }e
3160: 6c 73 65 7b 0a 20 20 20 20 20 20 70 54 61 69 6c lse{. pTail
3170: 2d 3e 70 44 69 72 74 79 20 3d 20 70 42 3b 0a 20 ->pDirty = pB;.
3180: 20 20 20 20 20 70 54 61 69 6c 20 3d 20 70 42 3b pTail = pB;
3190: 0a 20 20 20 20 20 20 70 42 20 3d 20 70 42 2d 3e . pB = pB->
31a0: 70 44 69 72 74 79 3b 0a 20 20 20 20 7d 0a 20 20 pDirty;. }.
31b0: 7d 0a 20 20 69 66 28 20 70 41 20 29 7b 0a 20 20 }. if( pA ){.
31c0: 20 20 70 54 61 69 6c 2d 3e 70 44 69 72 74 79 20 pTail->pDirty
31d0: 3d 20 70 41 3b 0a 20 20 7d 65 6c 73 65 20 69 66 = pA;. }else if
31e0: 28 20 70 42 20 29 7b 0a 20 20 20 20 70 54 61 69 ( pB ){. pTai
31f0: 6c 2d 3e 70 44 69 72 74 79 20 3d 20 70 42 3b 0a l->pDirty = pB;.
3200: 20 20 7d 65 6c 73 65 7b 0a 20 20 20 20 70 54 61 }else{. pTa
3210: 69 6c 2d 3e 70 44 69 72 74 79 20 3d 20 30 3b 0a il->pDirty = 0;.
3220: 20 20 7d 0a 20 20 72 65 74 75 72 6e 20 72 65 73 }. return res
3230: 75 6c 74 2e 70 44 69 72 74 79 3b 0a 7d 0a 0a 2f ult.pDirty;.}../
3240: 2a 0a 2a 2a 20 53 6f 72 74 20 74 68 65 20 6c 69 *.** Sort the li
3250: 73 74 20 6f 66 20 70 61 67 65 73 20 69 6e 20 61 st of pages in a
3260: 63 63 65 6e 64 69 6e 67 20 6f 72 64 65 72 20 62 ccending order b
3270: 79 20 70 67 6e 6f 2e 20 20 50 61 67 65 73 20 61 y pgno. Pages a
3280: 72 65 0a 2a 2a 20 63 6f 6e 6e 65 63 74 65 64 20 re.** connected
3290: 62 79 20 70 44 69 72 74 79 20 70 6f 69 6e 74 65 by pDirty pointe
32a0: 72 73 2e 20 20 54 68 65 20 70 44 69 72 74 79 50 rs. The pDirtyP
32b0: 72 65 76 20 70 6f 69 6e 74 65 72 73 20 61 72 65 rev pointers are
32c0: 0a 2a 2a 20 63 6f 72 72 75 70 74 65 64 20 62 79 .** corrupted by
32d0: 20 74 68 69 73 20 73 6f 72 74 2e 0a 2a 2f 0a 23 this sort..*/.#
32e0: 64 65 66 69 6e 65 20 4e 5f 53 4f 52 54 5f 42 55 define N_SORT_BU
32f0: 43 4b 45 54 5f 41 4c 4c 4f 43 20 32 35 0a 23 64 CKET_ALLOC 25.#d
3300: 65 66 69 6e 65 20 4e 5f 53 4f 52 54 5f 42 55 43 efine N_SORT_BUC
3310: 4b 45 54 20 20 20 20 20 20 20 32 35 0a 23 69 66 KET 25.#if
3320: 64 65 66 20 53 51 4c 49 54 45 5f 54 45 53 54 0a def SQLITE_TEST.
3330: 20 20 69 6e 74 20 73 71 6c 69 74 65 33 5f 70 61 int sqlite3_pa
3340: 67 65 72 5f 6e 5f 73 6f 72 74 5f 62 75 63 6b 65 ger_n_sort_bucke
3350: 74 20 3d 20 30 3b 0a 20 20 23 75 6e 64 65 66 20 t = 0;. #undef
3360: 4e 5f 53 4f 52 54 5f 42 55 43 4b 45 54 0a 20 20 N_SORT_BUCKET.
3370: 23 64 65 66 69 6e 65 20 4e 5f 53 4f 52 54 5f 42 #define N_SORT_B
3380: 55 43 4b 45 54 20 5c 0a 20 20 20 28 73 71 6c 69 UCKET \. (sqli
3390: 74 65 33 5f 70 61 67 65 72 5f 6e 5f 73 6f 72 74 te3_pager_n_sort
33a0: 5f 62 75 63 6b 65 74 3f 73 71 6c 69 74 65 33 5f _bucket?sqlite3_
33b0: 70 61 67 65 72 5f 6e 5f 73 6f 72 74 5f 62 75 63 pager_n_sort_buc
33c0: 6b 65 74 3a 4e 5f 53 4f 52 54 5f 42 55 43 4b 45 ket:N_SORT_BUCKE
33d0: 54 5f 41 4c 4c 4f 43 29 0a 23 65 6e 64 69 66 0a T_ALLOC).#endif.
33e0: 73 74 61 74 69 63 20 50 67 48 64 72 20 2a 70 63 static PgHdr *pc
33f0: 61 63 68 65 53 6f 72 74 44 69 72 74 79 4c 69 73 acheSortDirtyLis
3400: 74 28 50 67 48 64 72 20 2a 70 49 6e 29 7b 0a 20 t(PgHdr *pIn){.
3410: 20 50 67 48 64 72 20 2a 61 5b 4e 5f 53 4f 52 54 PgHdr *a[N_SORT
3420: 5f 42 55 43 4b 45 54 5f 41 4c 4c 4f 43 5d 2c 20 _BUCKET_ALLOC],
3430: 2a 70 3b 0a 20 20 69 6e 74 20 69 3b 0a 20 20 6d *p;. int i;. m
3440: 65 6d 73 65 74 28 61 2c 20 30 2c 20 73 69 7a 65 emset(a, 0, size
3450: 6f 66 28 61 29 29 3b 0a 20 20 77 68 69 6c 65 28 of(a));. while(
3460: 20 70 49 6e 20 29 7b 0a 20 20 20 20 70 20 3d 20 pIn ){. p =
3470: 70 49 6e 3b 0a 20 20 20 20 70 49 6e 20 3d 20 70 pIn;. pIn = p
3480: 2d 3e 70 44 69 72 74 79 3b 0a 20 20 20 20 70 2d ->pDirty;. p-
3490: 3e 70 44 69 72 74 79 20 3d 20 30 3b 0a 20 20 20 >pDirty = 0;.
34a0: 20 66 6f 72 28 69 3d 30 3b 20 69 3c 4e 5f 53 4f for(i=0; i<N_SO
34b0: 52 54 5f 42 55 43 4b 45 54 2d 31 3b 20 69 2b 2b RT_BUCKET-1; i++
34c0: 29 7b 0a 20 20 20 20 20 20 69 66 28 20 61 5b 69 ){. if( a[i
34d0: 5d 3d 3d 30 20 29 7b 0a 20 20 20 20 20 20 20 20 ]==0 ){.
34e0: 61 5b 69 5d 20 3d 20 70 3b 0a 20 20 20 20 20 20 a[i] = p;.
34f0: 20 20 62 72 65 61 6b 3b 0a 20 20 20 20 20 20 7d break;. }
3500: 65 6c 73 65 7b 0a 20 20 20 20 20 20 20 20 70 20 else{. p
3510: 3d 20 70 63 61 63 68 65 4d 65 72 67 65 44 69 72 = pcacheMergeDir
3520: 74 79 4c 69 73 74 28 61 5b 69 5d 2c 20 70 29 3b tyList(a[i], p);
3530: 0a 20 20 20 20 20 20 20 20 61 5b 69 5d 20 3d 20 . a[i] =
3540: 30 3b 0a 20 20 20 20 20 20 7d 0a 20 20 20 20 7d 0;. }. }
3550: 0a 20 20 20 20 69 66 28 20 69 3d 3d 4e 5f 53 4f . if( i==N_SO
3560: 52 54 5f 42 55 43 4b 45 54 2d 31 20 29 7b 0a 20 RT_BUCKET-1 ){.
3570: 20 20 20 20 20 2f 2a 20 43 6f 76 65 72 61 67 65 /* Coverage
3580: 3a 20 54 6f 20 67 65 74 20 68 65 72 65 2c 20 74 : To get here, t
3590: 68 65 72 65 20 6e 65 65 64 20 74 6f 20 62 65 20 here need to be
35a0: 32 5e 28 4e 5f 53 4f 52 54 5f 42 55 43 4b 45 54 2^(N_SORT_BUCKET
35b0: 29 20 0a 20 20 20 20 20 20 2a 2a 20 65 6c 65 6d ) . ** elem
35c0: 65 6e 74 73 20 69 6e 20 74 68 65 20 69 6e 70 75 ents in the inpu
35d0: 74 20 6c 69 73 74 2e 20 54 68 69 73 20 69 73 20 t list. This is
35e0: 70 6f 73 73 69 62 6c 65 2c 20 62 75 74 20 69 6d possible, but im
35f0: 70 72 61 63 74 69 63 61 6c 2e 0a 20 20 20 20 20 practical..
3600: 20 2a 2a 20 54 65 73 74 69 6e 67 20 74 68 69 73 ** Testing this
3610: 20 6c 69 6e 65 20 69 73 20 74 68 65 20 70 6f 69 line is the poi
3620: 6e 74 20 6f 66 20 67 6c 6f 62 61 6c 20 76 61 72 nt of global var
3630: 69 61 62 6c 65 0a 20 20 20 20 20 20 2a 2a 20 73 iable. ** s
3640: 71 6c 69 74 65 33 5f 70 61 67 65 72 5f 6e 5f 73 qlite3_pager_n_s
3650: 6f 72 74 5f 62 75 63 6b 65 74 2e 0a 20 20 20 20 ort_bucket..
3660: 20 20 2a 2f 0a 20 20 20 20 20 20 61 5b 69 5d 20 */. a[i]
3670: 3d 20 70 63 61 63 68 65 4d 65 72 67 65 44 69 72 = pcacheMergeDir
3680: 74 79 4c 69 73 74 28 61 5b 69 5d 2c 20 70 29 3b tyList(a[i], p);
3690: 0a 20 20 20 20 7d 0a 20 20 7d 0a 20 20 70 20 3d . }. }. p =
36a0: 20 61 5b 30 5d 3b 0a 20 20 66 6f 72 28 69 3d 31 a[0];. for(i=1
36b0: 3b 20 69 3c 4e 5f 53 4f 52 54 5f 42 55 43 4b 45 ; i<N_SORT_BUCKE
36c0: 54 3b 20 69 2b 2b 29 7b 0a 20 20 20 20 70 20 3d T; i++){. p =
36d0: 20 70 63 61 63 68 65 4d 65 72 67 65 44 69 72 74 pcacheMergeDirt
36e0: 79 4c 69 73 74 28 70 2c 20 61 5b 69 5d 29 3b 0a yList(p, a[i]);.
36f0: 20 20 7d 0a 20 20 72 65 74 75 72 6e 20 70 3b 0a }. return p;.
3700: 7d 0a 0a 2f 2a 0a 2a 2a 20 52 65 74 75 72 6e 20 }../*.** Return
3710: 61 20 6c 69 73 74 20 6f 66 20 61 6c 6c 20 64 69 a list of all di
3720: 72 74 79 20 70 61 67 65 73 20 69 6e 20 74 68 65 rty pages in the
3730: 20 63 61 63 68 65 2c 20 73 6f 72 74 65 64 20 62 cache, sorted b
3740: 79 20 70 61 67 65 20 6e 75 6d 62 65 72 2e 0a 2a y page number..*
3750: 2f 0a 50 67 48 64 72 20 2a 73 71 6c 69 74 65 33 /.PgHdr *sqlite3
3760: 50 63 61 63 68 65 44 69 72 74 79 4c 69 73 74 28 PcacheDirtyList(
3770: 50 43 61 63 68 65 20 2a 70 43 61 63 68 65 29 7b PCache *pCache){
3780: 0a 20 20 50 67 48 64 72 20 2a 70 3b 0a 20 20 66 . PgHdr *p;. f
3790: 6f 72 28 70 3d 70 43 61 63 68 65 2d 3e 70 44 69 or(p=pCache->pDi
37a0: 72 74 79 3b 20 70 3b 20 70 3d 70 2d 3e 70 44 69 rty; p; p=p->pDi
37b0: 72 74 79 4e 65 78 74 29 7b 0a 20 20 20 20 70 2d rtyNext){. p-
37c0: 3e 70 44 69 72 74 79 20 3d 20 70 2d 3e 70 44 69 >pDirty = p->pDi
37d0: 72 74 79 4e 65 78 74 3b 0a 20 20 7d 0a 20 20 72 rtyNext;. }. r
37e0: 65 74 75 72 6e 20 70 63 61 63 68 65 53 6f 72 74 eturn pcacheSort
37f0: 44 69 72 74 79 4c 69 73 74 28 70 43 61 63 68 65 DirtyList(pCache
3800: 2d 3e 70 44 69 72 74 79 29 3b 0a 7d 0a 0a 2f 2a ->pDirty);.}../*
3810: 20 0a 2a 2a 20 52 65 74 75 72 6e 20 74 68 65 20 .** Return the
3820: 74 6f 74 61 6c 20 6e 75 6d 62 65 72 20 6f 66 20 total number of
3830: 72 65 66 65 72 65 6e 63 65 64 20 70 61 67 65 73 referenced pages
3840: 20 68 65 6c 64 20 62 79 20 74 68 65 20 63 61 63 held by the cac
3850: 68 65 2e 0a 2a 2f 0a 69 6e 74 20 73 71 6c 69 74 he..*/.int sqlit
3860: 65 33 50 63 61 63 68 65 52 65 66 43 6f 75 6e 74 e3PcacheRefCount
3870: 28 50 43 61 63 68 65 20 2a 70 43 61 63 68 65 29 (PCache *pCache)
3880: 7b 0a 20 20 72 65 74 75 72 6e 20 70 43 61 63 68 {. return pCach
3890: 65 2d 3e 6e 52 65 66 3b 0a 7d 0a 0a 2f 2a 0a 2a e->nRef;.}../*.*
38a0: 2a 20 52 65 74 75 72 6e 20 74 68 65 20 6e 75 6d * Return the num
38b0: 62 65 72 20 6f 66 20 72 65 66 65 72 65 6e 63 65 ber of reference
38c0: 73 20 74 6f 20 74 68 65 20 70 61 67 65 20 73 75 s to the page su
38d0: 70 70 6c 69 65 64 20 61 73 20 61 6e 20 61 72 67 pplied as an arg
38e0: 75 6d 65 6e 74 2e 0a 2a 2f 0a 69 6e 74 20 73 71 ument..*/.int sq
38f0: 6c 69 74 65 33 50 63 61 63 68 65 50 61 67 65 52 lite3PcachePageR
3900: 65 66 63 6f 75 6e 74 28 50 67 48 64 72 20 2a 70 efcount(PgHdr *p
3910: 29 7b 0a 20 20 72 65 74 75 72 6e 20 70 2d 3e 6e ){. return p->n
3920: 52 65 66 3b 0a 7d 0a 0a 2f 2a 20 0a 2a 2a 20 52 Ref;.}../* .** R
3930: 65 74 75 72 6e 20 74 68 65 20 74 6f 74 61 6c 20 eturn the total
3940: 6e 75 6d 62 65 72 20 6f 66 20 70 61 67 65 73 20 number of pages
3950: 69 6e 20 74 68 65 20 63 61 63 68 65 2e 0a 2a 2f in the cache..*/
3960: 0a 69 6e 74 20 73 71 6c 69 74 65 33 50 63 61 63 .int sqlite3Pcac
3970: 68 65 50 61 67 65 63 6f 75 6e 74 28 50 43 61 63 hePagecount(PCac
3980: 68 65 20 2a 70 43 61 63 68 65 29 7b 0a 20 20 69 he *pCache){. i
3990: 6e 74 20 6e 50 61 67 65 20 3d 20 30 3b 0a 20 20 nt nPage = 0;.
39a0: 69 66 28 20 70 43 61 63 68 65 2d 3e 70 43 61 63 if( pCache->pCac
39b0: 68 65 20 29 7b 0a 20 20 20 20 6e 50 61 67 65 20 he ){. nPage
39c0: 3d 20 73 71 6c 69 74 65 33 47 6c 6f 62 61 6c 43 = sqlite3GlobalC
39d0: 6f 6e 66 69 67 2e 70 63 61 63 68 65 2e 78 50 61 onfig.pcache.xPa
39e0: 67 65 63 6f 75 6e 74 28 70 43 61 63 68 65 2d 3e gecount(pCache->
39f0: 70 43 61 63 68 65 29 3b 0a 20 20 7d 0a 20 20 72 pCache);. }. r
3a00: 65 74 75 72 6e 20 6e 50 61 67 65 3b 0a 7d 0a 0a eturn nPage;.}..
3a10: 23 69 66 64 65 66 20 53 51 4c 49 54 45 5f 54 45 #ifdef SQLITE_TE
3a20: 53 54 0a 2f 2a 0a 2a 2a 20 47 65 74 20 74 68 65 ST./*.** Get the
3a30: 20 73 75 67 67 65 73 74 65 64 20 63 61 63 68 65 suggested cache
3a40: 2d 73 69 7a 65 20 76 61 6c 75 65 2e 0a 2a 2f 0a -size value..*/.
3a50: 69 6e 74 20 73 71 6c 69 74 65 33 50 63 61 63 68 int sqlite3Pcach
3a60: 65 47 65 74 43 61 63 68 65 73 69 7a 65 28 50 43 eGetCachesize(PC
3a70: 61 63 68 65 20 2a 70 43 61 63 68 65 29 7b 0a 20 ache *pCache){.
3a80: 20 72 65 74 75 72 6e 20 70 43 61 63 68 65 2d 3e return pCache->
3a90: 6e 4d 61 78 3b 0a 7d 0a 23 65 6e 64 69 66 0a 0a nMax;.}.#endif..
3aa0: 2f 2a 0a 2a 2a 20 53 65 74 20 74 68 65 20 73 75 /*.** Set the su
3ab0: 67 67 65 73 74 65 64 20 63 61 63 68 65 2d 73 69 ggested cache-si
3ac0: 7a 65 20 76 61 6c 75 65 2e 0a 2a 2f 0a 76 6f 69 ze value..*/.voi
3ad0: 64 20 73 71 6c 69 74 65 33 50 63 61 63 68 65 53 d sqlite3PcacheS
3ae0: 65 74 43 61 63 68 65 73 69 7a 65 28 50 43 61 63 etCachesize(PCac
3af0: 68 65 20 2a 70 43 61 63 68 65 2c 20 69 6e 74 20 he *pCache, int
3b00: 6d 78 50 61 67 65 29 7b 0a 20 20 70 43 61 63 68 mxPage){. pCach
3b10: 65 2d 3e 6e 4d 61 78 20 3d 20 6d 78 50 61 67 65 e->nMax = mxPage
3b20: 3b 0a 20 20 69 66 28 20 70 43 61 63 68 65 2d 3e ;. if( pCache->
3b30: 70 43 61 63 68 65 20 29 7b 0a 20 20 20 20 73 71 pCache ){. sq
3b40: 6c 69 74 65 33 47 6c 6f 62 61 6c 43 6f 6e 66 69 lite3GlobalConfi
3b50: 67 2e 70 63 61 63 68 65 2e 78 43 61 63 68 65 73 g.pcache.xCaches
3b60: 69 7a 65 28 70 43 61 63 68 65 2d 3e 70 43 61 63 ize(pCache->pCac
3b70: 68 65 2c 20 6d 78 50 61 67 65 29 3b 0a 20 20 7d he, mxPage);. }
3b80: 0a 7d 0a 0a 23 69 66 64 65 66 20 53 51 4c 49 54 .}..#ifdef SQLIT
3b90: 45 5f 43 48 45 43 4b 5f 50 41 47 45 53 0a 2f 2a E_CHECK_PAGES./*
3ba0: 0a 2a 2a 20 46 6f 72 20 61 6c 6c 20 64 69 72 74 .** For all dirt
3bb0: 79 20 70 61 67 65 73 20 63 75 72 72 65 6e 74 6c y pages currentl
3bc0: 79 20 69 6e 20 74 68 65 20 63 61 63 68 65 2c 20 y in the cache,
3bd0: 69 6e 76 6f 6b 65 20 74 68 65 20 73 70 65 63 69 invoke the speci
3be0: 66 69 65 64 0a 2a 2a 20 63 61 6c 6c 62 61 63 6b fied.** callback
3bf0: 2e 20 54 68 69 73 20 69 73 20 6f 6e 6c 79 20 75 . This is only u
3c00: 73 65 64 20 69 66 20 74 68 65 20 53 51 4c 49 54 sed if the SQLIT
3c10: 45 5f 43 48 45 43 4b 5f 50 41 47 45 53 20 6d 61 E_CHECK_PAGES ma
3c20: 63 72 6f 20 69 73 0a 2a 2a 20 64 65 66 69 6e 65 cro is.** define
3c30: 64 2e 0a 2a 2f 0a 76 6f 69 64 20 73 71 6c 69 74 d..*/.void sqlit
3c40: 65 33 50 63 61 63 68 65 49 74 65 72 61 74 65 44 e3PcacheIterateD
3c50: 69 72 74 79 28 50 43 61 63 68 65 20 2a 70 43 61 irty(PCache *pCa
3c60: 63 68 65 2c 20 76 6f 69 64 20 28 2a 78 49 74 65 che, void (*xIte
3c70: 72 29 28 50 67 48 64 72 20 2a 29 29 7b 0a 20 20 r)(PgHdr *)){.
3c80: 50 67 48 64 72 20 2a 70 44 69 72 74 79 3b 0a 20 PgHdr *pDirty;.
3c90: 20 66 6f 72 28 70 44 69 72 74 79 3d 70 43 61 63 for(pDirty=pCac
3ca0: 68 65 2d 3e 70 44 69 72 74 79 3b 20 70 44 69 72 he->pDirty; pDir
3cb0: 74 79 3b 20 70 44 69 72 74 79 3d 70 44 69 72 74 ty; pDirty=pDirt
3cc0: 79 2d 3e 70 44 69 72 74 79 4e 65 78 74 29 7b 0a y->pDirtyNext){.
3cd0: 20 20 20 20 78 49 74 65 72 28 70 44 69 72 74 79 xIter(pDirty
3ce0: 29 3b 0a 20 20 7d 0a 7d 0a 23 65 6e 64 69 66 0a );. }.}.#endif.