/ Hex Artifact Content
Login

Artifact bc87dd3b062cc26edfe79918de2200ccb8d41e73:


0000: 2f 2a 0a 2a 2a 20 32 30 30 37 20 41 75 67 75 73  /*.** 2007 Augus
0010: 74 20 32 37 0a 2a 2a 0a 2a 2a 20 54 68 65 20 61  t 27.**.** 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 0a 2a 2a 20 54 68 69 73 20 66  ***.**.** This f
0180: 69 6c 65 20 63 6f 6e 74 61 69 6e 73 20 63 6f 64  ile contains cod
0190: 65 20 75 73 65 64 20 74 6f 20 69 6d 70 6c 65 6d  e used to implem
01a0: 65 6e 74 20 6d 75 74 65 78 65 73 20 6f 6e 20 42  ent mutexes on B
01b0: 74 72 65 65 20 6f 62 6a 65 63 74 73 2e 0a 2a 2a  tree objects..**
01c0: 20 54 68 69 73 20 63 6f 64 65 20 72 65 61 6c 6c   This code reall
01d0: 79 20 62 65 6c 6f 6e 67 73 20 69 6e 20 62 74 72  y belongs in btr
01e0: 65 65 2e 63 2e 20 20 42 75 74 20 62 74 72 65 65  ee.c.  But btree
01f0: 2e 63 20 69 73 20 67 65 74 74 69 6e 67 20 74 6f  .c is getting to
0200: 6f 0a 2a 2a 20 62 69 67 20 61 6e 64 20 77 65 20  o.** big and we 
0210: 77 61 6e 74 20 74 6f 20 62 72 65 61 6b 20 69 74  want to break it
0220: 20 64 6f 77 6e 20 73 6f 6d 65 2e 20 20 54 68 69   down some.  Thi
0230: 73 20 70 61 63 6b 61 67 65 64 20 73 65 65 6d 65  s packaged seeme
0240: 64 20 6c 69 6b 65 0a 2a 2a 20 61 20 67 6f 6f 64  d like.** a good
0250: 20 62 72 65 61 6b 6f 75 74 2e 0a 2a 2f 0a 23 69   breakout..*/.#i
0260: 6e 63 6c 75 64 65 20 22 62 74 72 65 65 49 6e 74  nclude "btreeInt
0270: 2e 68 22 0a 23 69 66 6e 64 65 66 20 53 51 4c 49  .h".#ifndef SQLI
0280: 54 45 5f 4f 4d 49 54 5f 53 48 41 52 45 44 5f 43  TE_OMIT_SHARED_C
0290: 41 43 48 45 0a 23 69 66 20 53 51 4c 49 54 45 5f  ACHE.#if SQLITE_
02a0: 54 48 52 45 41 44 53 41 46 45 0a 0a 2f 2a 0a 2a  THREADSAFE../*.*
02b0: 2a 20 4f 62 74 61 69 6e 20 74 68 65 20 42 74 53  * Obtain the BtS
02c0: 68 61 72 65 64 20 6d 75 74 65 78 20 61 73 73 6f  hared mutex asso
02d0: 63 69 61 74 65 64 20 77 69 74 68 20 42 2d 54 72  ciated with B-Tr
02e0: 65 65 20 68 61 6e 64 6c 65 20 70 2e 20 41 6c 73  ee handle p. Als
02f0: 6f 2c 0a 2a 2a 20 73 65 74 20 42 74 53 68 61 72  o,.** set BtShar
0300: 65 64 2e 64 62 20 74 6f 20 74 68 65 20 64 61 74  ed.db to the dat
0310: 61 62 61 73 65 20 68 61 6e 64 6c 65 20 61 73 73  abase handle ass
0320: 6f 63 69 61 74 65 64 20 77 69 74 68 20 70 20 61  ociated with p a
0330: 6e 64 20 74 68 65 0a 2a 2a 20 70 2d 3e 6c 6f 63  nd the.** p->loc
0340: 6b 65 64 20 62 6f 6f 6c 65 61 6e 20 74 6f 20 74  ked boolean to t
0350: 72 75 65 2e 0a 2a 2f 0a 73 74 61 74 69 63 20 76  rue..*/.static v
0360: 6f 69 64 20 6c 6f 63 6b 42 74 72 65 65 4d 75 74  oid lockBtreeMut
0370: 65 78 28 42 74 72 65 65 20 2a 70 29 7b 0a 20 20  ex(Btree *p){.  
0380: 61 73 73 65 72 74 28 20 70 2d 3e 6c 6f 63 6b 65  assert( p->locke
0390: 64 3d 3d 30 20 29 3b 0a 20 20 61 73 73 65 72 74  d==0 );.  assert
03a0: 28 20 73 71 6c 69 74 65 33 5f 6d 75 74 65 78 5f  ( sqlite3_mutex_
03b0: 6e 6f 74 68 65 6c 64 28 70 2d 3e 70 42 74 2d 3e  notheld(p->pBt->
03c0: 6d 75 74 65 78 29 20 29 3b 0a 20 20 61 73 73 65  mutex) );.  asse
03d0: 72 74 28 20 73 71 6c 69 74 65 33 5f 6d 75 74 65  rt( sqlite3_mute
03e0: 78 5f 68 65 6c 64 28 70 2d 3e 64 62 2d 3e 6d 75  x_held(p->db->mu
03f0: 74 65 78 29 20 29 3b 0a 0a 20 20 73 71 6c 69 74  tex) );..  sqlit
0400: 65 33 5f 6d 75 74 65 78 5f 65 6e 74 65 72 28 70  e3_mutex_enter(p
0410: 2d 3e 70 42 74 2d 3e 6d 75 74 65 78 29 3b 0a 20  ->pBt->mutex);. 
0420: 20 70 2d 3e 70 42 74 2d 3e 64 62 20 3d 20 70 2d   p->pBt->db = p-
0430: 3e 64 62 3b 0a 20 20 70 2d 3e 6c 6f 63 6b 65 64  >db;.  p->locked
0440: 20 3d 20 31 3b 0a 7d 0a 0a 2f 2a 0a 2a 2a 20 52   = 1;.}../*.** R
0450: 65 6c 65 61 73 65 20 74 68 65 20 42 74 53 68 61  elease the BtSha
0460: 72 65 64 20 6d 75 74 65 78 20 61 73 73 6f 63 69  red mutex associ
0470: 61 74 65 64 20 77 69 74 68 20 42 2d 54 72 65 65  ated with B-Tree
0480: 20 68 61 6e 64 6c 65 20 70 20 61 6e 64 0a 2a 2a   handle p and.**
0490: 20 63 6c 65 61 72 20 74 68 65 20 70 2d 3e 6c 6f   clear the p->lo
04a0: 63 6b 65 64 20 62 6f 6f 6c 65 61 6e 2e 0a 2a 2f  cked boolean..*/
04b0: 0a 73 74 61 74 69 63 20 76 6f 69 64 20 53 51 4c  .static void SQL
04c0: 49 54 45 5f 4e 4f 49 4e 4c 49 4e 45 20 75 6e 6c  ITE_NOINLINE unl
04d0: 6f 63 6b 42 74 72 65 65 4d 75 74 65 78 28 42 74  ockBtreeMutex(Bt
04e0: 72 65 65 20 2a 70 29 7b 0a 20 20 42 74 53 68 61  ree *p){.  BtSha
04f0: 72 65 64 20 2a 70 42 74 20 3d 20 70 2d 3e 70 42  red *pBt = p->pB
0500: 74 3b 0a 20 20 61 73 73 65 72 74 28 20 70 2d 3e  t;.  assert( p->
0510: 6c 6f 63 6b 65 64 3d 3d 31 20 29 3b 0a 20 20 61  locked==1 );.  a
0520: 73 73 65 72 74 28 20 73 71 6c 69 74 65 33 5f 6d  ssert( sqlite3_m
0530: 75 74 65 78 5f 68 65 6c 64 28 70 42 74 2d 3e 6d  utex_held(pBt->m
0540: 75 74 65 78 29 20 29 3b 0a 20 20 61 73 73 65 72  utex) );.  asser
0550: 74 28 20 73 71 6c 69 74 65 33 5f 6d 75 74 65 78  t( sqlite3_mutex
0560: 5f 68 65 6c 64 28 70 2d 3e 64 62 2d 3e 6d 75 74  _held(p->db->mut
0570: 65 78 29 20 29 3b 0a 20 20 61 73 73 65 72 74 28  ex) );.  assert(
0580: 20 70 2d 3e 64 62 3d 3d 70 42 74 2d 3e 64 62 20   p->db==pBt->db 
0590: 29 3b 0a 0a 20 20 73 71 6c 69 74 65 33 5f 6d 75  );..  sqlite3_mu
05a0: 74 65 78 5f 6c 65 61 76 65 28 70 42 74 2d 3e 6d  tex_leave(pBt->m
05b0: 75 74 65 78 29 3b 0a 20 20 70 2d 3e 6c 6f 63 6b  utex);.  p->lock
05c0: 65 64 20 3d 20 30 3b 0a 7d 0a 0a 2f 2a 20 46 6f  ed = 0;.}../* Fo
05d0: 72 77 61 72 64 20 72 65 66 65 72 65 6e 63 65 20  rward reference 
05e0: 2a 2f 0a 73 74 61 74 69 63 20 76 6f 69 64 20 53  */.static void S
05f0: 51 4c 49 54 45 5f 4e 4f 49 4e 4c 49 4e 45 20 62  QLITE_NOINLINE b
0600: 74 72 65 65 4c 6f 63 6b 43 61 72 65 66 75 6c 6c  treeLockCarefull
0610: 79 28 42 74 72 65 65 20 2a 70 29 3b 0a 0a 2f 2a  y(Btree *p);../*
0620: 0a 2a 2a 20 45 6e 74 65 72 20 61 20 6d 75 74 65  .** Enter a mute
0630: 78 20 6f 6e 20 74 68 65 20 67 69 76 65 6e 20 42  x on the given B
0640: 54 72 65 65 20 6f 62 6a 65 63 74 2e 0a 2a 2a 0a  Tree object..**.
0650: 2a 2a 20 49 66 20 74 68 65 20 6f 62 6a 65 63 74  ** If the object
0660: 20 69 73 20 6e 6f 74 20 73 68 61 72 61 62 6c 65   is not sharable
0670: 2c 20 74 68 65 6e 20 6e 6f 20 6d 75 74 65 78 20  , then no mutex 
0680: 69 73 20 65 76 65 72 20 72 65 71 75 69 72 65 64  is ever required
0690: 0a 2a 2a 20 61 6e 64 20 74 68 69 73 20 72 6f 75  .** and this rou
06a0: 74 69 6e 65 20 69 73 20 61 20 6e 6f 2d 6f 70 2e  tine is a no-op.
06b0: 20 20 54 68 65 20 75 6e 64 65 72 6c 79 69 6e 67    The underlying
06c0: 20 6d 75 74 65 78 20 69 73 20 6e 6f 6e 2d 72 65   mutex is non-re
06d0: 63 75 72 73 69 76 65 2e 0a 2a 2a 20 42 75 74 20  cursive..** But 
06e0: 77 65 20 6b 65 65 70 20 61 20 72 65 66 65 72 65  we keep a refere
06f0: 6e 63 65 20 63 6f 75 6e 74 20 69 6e 20 42 74 72  nce count in Btr
0700: 65 65 2e 77 61 6e 74 54 6f 4c 6f 63 6b 20 73 6f  ee.wantToLock so
0710: 20 74 68 65 20 62 65 68 61 76 69 6f 72 0a 2a 2a   the behavior.**
0720: 20 6f 66 20 74 68 69 73 20 69 6e 74 65 72 66 61   of this interfa
0730: 63 65 20 69 73 20 72 65 63 75 72 73 69 76 65 2e  ce is recursive.
0740: 0a 2a 2a 0a 2a 2a 20 54 6f 20 61 76 6f 69 64 20  .**.** To avoid 
0750: 64 65 61 64 6c 6f 63 6b 73 2c 20 6d 75 6c 74 69  deadlocks, multi
0760: 70 6c 65 20 42 74 72 65 65 73 20 61 72 65 20 6c  ple Btrees are l
0770: 6f 63 6b 65 64 20 69 6e 20 74 68 65 20 73 61 6d  ocked in the sam
0780: 65 20 6f 72 64 65 72 0a 2a 2a 20 62 79 20 61 6c  e order.** by al
0790: 6c 20 64 61 74 61 62 61 73 65 20 63 6f 6e 6e 65  l database conne
07a0: 63 74 69 6f 6e 73 2e 20 20 54 68 65 20 70 2d 3e  ctions.  The p->
07b0: 70 4e 65 78 74 20 69 73 20 61 20 6c 69 73 74 20  pNext is a list 
07c0: 6f 66 20 6f 74 68 65 72 0a 2a 2a 20 42 74 72 65  of other.** Btre
07d0: 65 73 20 62 65 6c 6f 6e 67 69 6e 67 20 74 6f 20  es belonging to 
07e0: 74 68 65 20 73 61 6d 65 20 64 61 74 61 62 61 73  the same databas
07f0: 65 20 63 6f 6e 6e 65 63 74 69 6f 6e 20 61 73 20  e connection as 
0800: 74 68 65 20 70 20 42 74 72 65 65 0a 2a 2a 20 77  the p Btree.** w
0810: 68 69 63 68 20 6e 65 65 64 20 74 6f 20 62 65 20  hich need to be 
0820: 6c 6f 63 6b 65 64 20 61 66 74 65 72 20 70 2e 20  locked after p. 
0830: 20 49 66 20 77 65 20 63 61 6e 6e 6f 74 20 67 65   If we cannot ge
0840: 74 20 61 20 6c 6f 63 6b 20 6f 6e 0a 2a 2a 20 70  t a lock on.** p
0850: 2c 20 74 68 65 6e 20 66 69 72 73 74 20 75 6e 6c  , then first unl
0860: 6f 63 6b 20 61 6c 6c 20 6f 66 20 74 68 65 20 6f  ock all of the o
0870: 74 68 65 72 73 20 6f 6e 20 70 2d 3e 70 4e 65 78  thers on p->pNex
0880: 74 2c 20 74 68 65 6e 20 77 61 69 74 0a 2a 2a 20  t, then wait.** 
0890: 66 6f 72 20 74 68 65 20 6c 6f 63 6b 20 74 6f 20  for the lock to 
08a0: 62 65 63 6f 6d 65 20 61 76 61 69 6c 61 62 6c 65  become available
08b0: 20 6f 6e 20 70 2c 20 74 68 65 6e 20 72 65 6c 6f   on p, then relo
08c0: 63 6b 20 61 6c 6c 20 6f 66 20 74 68 65 0a 2a 2a  ck all of the.**
08d0: 20 73 75 62 73 65 71 75 65 6e 74 20 42 74 72 65   subsequent Btre
08e0: 65 73 20 74 68 61 74 20 64 65 73 69 72 65 20 61  es that desire a
08f0: 20 6c 6f 63 6b 2e 0a 2a 2f 0a 76 6f 69 64 20 73   lock..*/.void s
0900: 71 6c 69 74 65 33 42 74 72 65 65 45 6e 74 65 72  qlite3BtreeEnter
0910: 28 42 74 72 65 65 20 2a 70 29 7b 0a 20 20 2f 2a  (Btree *p){.  /*
0920: 20 53 6f 6d 65 20 62 61 73 69 63 20 73 61 6e 69   Some basic sani
0930: 74 79 20 63 68 65 63 6b 69 6e 67 20 6f 6e 20 74  ty checking on t
0940: 68 65 20 42 74 72 65 65 2e 20 20 54 68 65 20 6c  he Btree.  The l
0950: 69 73 74 20 6f 66 20 42 74 72 65 65 73 0a 20 20  ist of Btrees.  
0960: 2a 2a 20 63 6f 6e 6e 65 63 74 65 64 20 62 79 20  ** connected by 
0970: 70 4e 65 78 74 20 61 6e 64 20 70 50 72 65 76 20  pNext and pPrev 
0980: 73 68 6f 75 6c 64 20 62 65 20 69 6e 20 73 6f 72  should be in sor
0990: 74 65 64 20 6f 72 64 65 72 20 62 79 0a 20 20 2a  ted order by.  *
09a0: 2a 20 42 74 72 65 65 2e 70 42 74 20 76 61 6c 75  * Btree.pBt valu
09b0: 65 2e 20 41 6c 6c 20 65 6c 65 6d 65 6e 74 73 20  e. All elements 
09c0: 6f 66 20 74 68 65 20 6c 69 73 74 20 73 68 6f 75  of the list shou
09d0: 6c 64 20 62 65 6c 6f 6e 67 20 74 6f 0a 20 20 2a  ld belong to.  *
09e0: 2a 20 74 68 65 20 73 61 6d 65 20 63 6f 6e 6e 65  * the same conne
09f0: 63 74 69 6f 6e 2e 20 4f 6e 6c 79 20 73 68 61 72  ction. Only shar
0a00: 65 64 20 42 74 72 65 65 73 20 61 72 65 20 6f 6e  ed Btrees are on
0a10: 20 74 68 65 20 6c 69 73 74 2e 20 2a 2f 0a 20 20   the list. */.  
0a20: 61 73 73 65 72 74 28 20 70 2d 3e 70 4e 65 78 74  assert( p->pNext
0a30: 3d 3d 30 20 7c 7c 20 70 2d 3e 70 4e 65 78 74 2d  ==0 || p->pNext-
0a40: 3e 70 42 74 3e 70 2d 3e 70 42 74 20 29 3b 0a 20  >pBt>p->pBt );. 
0a50: 20 61 73 73 65 72 74 28 20 70 2d 3e 70 50 72 65   assert( p->pPre
0a60: 76 3d 3d 30 20 7c 7c 20 70 2d 3e 70 50 72 65 76  v==0 || p->pPrev
0a70: 2d 3e 70 42 74 3c 70 2d 3e 70 42 74 20 29 3b 0a  ->pBt<p->pBt );.
0a80: 20 20 61 73 73 65 72 74 28 20 70 2d 3e 70 4e 65    assert( p->pNe
0a90: 78 74 3d 3d 30 20 7c 7c 20 70 2d 3e 70 4e 65 78  xt==0 || p->pNex
0aa0: 74 2d 3e 64 62 3d 3d 70 2d 3e 64 62 20 29 3b 0a  t->db==p->db );.
0ab0: 20 20 61 73 73 65 72 74 28 20 70 2d 3e 70 50 72    assert( p->pPr
0ac0: 65 76 3d 3d 30 20 7c 7c 20 70 2d 3e 70 50 72 65  ev==0 || p->pPre
0ad0: 76 2d 3e 64 62 3d 3d 70 2d 3e 64 62 20 29 3b 0a  v->db==p->db );.
0ae0: 20 20 61 73 73 65 72 74 28 20 70 2d 3e 73 68 61    assert( p->sha
0af0: 72 61 62 6c 65 20 7c 7c 20 28 70 2d 3e 70 4e 65  rable || (p->pNe
0b00: 78 74 3d 3d 30 20 26 26 20 70 2d 3e 70 50 72 65  xt==0 && p->pPre
0b10: 76 3d 3d 30 29 20 29 3b 0a 0a 20 20 2f 2a 20 43  v==0) );..  /* C
0b20: 68 65 63 6b 20 66 6f 72 20 6c 6f 63 6b 69 6e 67  heck for locking
0b30: 20 63 6f 6e 73 69 73 74 65 6e 63 79 20 2a 2f 0a   consistency */.
0b40: 20 20 61 73 73 65 72 74 28 20 21 70 2d 3e 6c 6f    assert( !p->lo
0b50: 63 6b 65 64 20 7c 7c 20 70 2d 3e 77 61 6e 74 54  cked || p->wantT
0b60: 6f 4c 6f 63 6b 3e 30 20 29 3b 0a 20 20 61 73 73  oLock>0 );.  ass
0b70: 65 72 74 28 20 70 2d 3e 73 68 61 72 61 62 6c 65  ert( p->sharable
0b80: 20 7c 7c 20 70 2d 3e 77 61 6e 74 54 6f 4c 6f 63   || p->wantToLoc
0b90: 6b 3d 3d 30 20 29 3b 0a 0a 20 20 2f 2a 20 57 65  k==0 );..  /* We
0ba0: 20 73 68 6f 75 6c 64 20 61 6c 72 65 61 64 79 20   should already 
0bb0: 68 6f 6c 64 20 61 20 6c 6f 63 6b 20 6f 6e 20 74  hold a lock on t
0bc0: 68 65 20 64 61 74 61 62 61 73 65 20 63 6f 6e 6e  he database conn
0bd0: 65 63 74 69 6f 6e 20 2a 2f 0a 20 20 61 73 73 65  ection */.  asse
0be0: 72 74 28 20 73 71 6c 69 74 65 33 5f 6d 75 74 65  rt( sqlite3_mute
0bf0: 78 5f 68 65 6c 64 28 70 2d 3e 64 62 2d 3e 6d 75  x_held(p->db->mu
0c00: 74 65 78 29 20 29 3b 0a 0a 20 20 2f 2a 20 55 6e  tex) );..  /* Un
0c10: 6c 65 73 73 20 74 68 65 20 64 61 74 61 62 61 73  less the databas
0c20: 65 20 69 73 20 73 68 61 72 61 62 6c 65 20 61 6e  e is sharable an
0c30: 64 20 75 6e 6c 6f 63 6b 65 64 2c 20 74 68 65 6e  d unlocked, then
0c40: 20 42 74 53 68 61 72 65 64 2e 64 62 0a 20 20 2a   BtShared.db.  *
0c50: 2a 20 73 68 6f 75 6c 64 20 61 6c 72 65 61 64 79  * should already
0c60: 20 62 65 20 73 65 74 20 63 6f 72 72 65 63 74 6c   be set correctl
0c70: 79 2e 20 2a 2f 0a 20 20 61 73 73 65 72 74 28 20  y. */.  assert( 
0c80: 28 70 2d 3e 6c 6f 63 6b 65 64 3d 3d 30 20 26 26  (p->locked==0 &&
0c90: 20 70 2d 3e 73 68 61 72 61 62 6c 65 29 20 7c 7c   p->sharable) ||
0ca0: 20 70 2d 3e 70 42 74 2d 3e 64 62 3d 3d 70 2d 3e   p->pBt->db==p->
0cb0: 64 62 20 29 3b 0a 0a 20 20 69 66 28 20 21 70 2d  db );..  if( !p-
0cc0: 3e 73 68 61 72 61 62 6c 65 20 29 20 72 65 74 75  >sharable ) retu
0cd0: 72 6e 3b 0a 20 20 70 2d 3e 77 61 6e 74 54 6f 4c  rn;.  p->wantToL
0ce0: 6f 63 6b 2b 2b 3b 0a 20 20 69 66 28 20 70 2d 3e  ock++;.  if( p->
0cf0: 6c 6f 63 6b 65 64 20 29 20 72 65 74 75 72 6e 3b  locked ) return;
0d00: 0a 20 20 62 74 72 65 65 4c 6f 63 6b 43 61 72 65  .  btreeLockCare
0d10: 66 75 6c 6c 79 28 70 29 3b 0a 7d 0a 0a 2f 2a 20  fully(p);.}../* 
0d20: 54 68 69 73 20 69 73 20 61 20 68 65 6c 70 65 72  This is a helper
0d30: 20 66 75 6e 63 74 69 6f 6e 20 66 6f 72 20 73 71   function for sq
0d40: 6c 69 74 65 33 42 74 72 65 65 4c 6f 63 6b 28 29  lite3BtreeLock()
0d50: 2e 20 42 79 20 6d 6f 76 69 6e 67 0a 2a 2a 20 63  . By moving.** c
0d60: 6f 6d 70 6c 65 78 2c 20 62 75 74 20 73 65 6c 64  omplex, but seld
0d70: 6f 6d 20 75 73 65 64 20 6c 6f 67 69 63 2c 20 6f  om used logic, o
0d80: 75 74 20 6f 66 20 73 71 6c 69 74 65 33 42 74 72  ut of sqlite3Btr
0d90: 65 65 4c 6f 63 6b 28 29 20 61 6e 64 0a 2a 2a 20  eeLock() and.** 
0da0: 69 6e 74 6f 20 74 68 69 73 20 72 6f 75 74 69 6e  into this routin
0db0: 65 2c 20 77 65 20 61 76 6f 69 64 20 75 6e 6e 65  e, we avoid unne
0dc0: 63 65 73 73 61 72 79 20 73 74 61 63 6b 20 70 6f  cessary stack po
0dd0: 69 6e 74 65 72 20 63 68 61 6e 67 65 73 0a 2a 2a  inter changes.**
0de0: 20 61 6e 64 20 74 68 75 73 20 68 65 6c 70 20 74   and thus help t
0df0: 68 65 20 73 71 6c 69 74 65 33 42 74 72 65 65 4c  he sqlite3BtreeL
0e00: 6f 63 6b 28 29 20 72 6f 75 74 69 6e 65 20 74 6f  ock() routine to
0e10: 20 72 75 6e 20 6d 75 63 68 20 66 61 73 74 65 72   run much faster
0e20: 0a 2a 2a 20 69 6e 20 74 68 65 20 63 6f 6d 6d 6f  .** in the commo
0e30: 6e 20 63 61 73 65 2e 0a 2a 2f 0a 73 74 61 74 69  n case..*/.stati
0e40: 63 20 76 6f 69 64 20 53 51 4c 49 54 45 5f 4e 4f  c void SQLITE_NO
0e50: 49 4e 4c 49 4e 45 20 62 74 72 65 65 4c 6f 63 6b  INLINE btreeLock
0e60: 43 61 72 65 66 75 6c 6c 79 28 42 74 72 65 65 20  Carefully(Btree 
0e70: 2a 70 29 7b 0a 20 20 42 74 72 65 65 20 2a 70 4c  *p){.  Btree *pL
0e80: 61 74 65 72 3b 0a 0a 20 20 2f 2a 20 49 6e 20 6d  ater;..  /* In m
0e90: 6f 73 74 20 63 61 73 65 73 2c 20 77 65 20 73 68  ost cases, we sh
0ea0: 6f 75 6c 64 20 62 65 20 61 62 6c 65 20 74 6f 20  ould be able to 
0eb0: 61 63 71 75 69 72 65 20 74 68 65 20 6c 6f 63 6b  acquire the lock
0ec0: 20 77 65 0a 20 20 2a 2a 20 77 61 6e 74 20 77 69   we.  ** want wi
0ed0: 74 68 6f 75 74 20 68 61 76 69 6e 67 20 74 6f 20  thout having to 
0ee0: 67 6f 20 74 68 72 6f 75 67 68 20 74 68 65 20 61  go through the a
0ef0: 73 63 65 6e 64 69 6e 67 20 6c 6f 63 6b 0a 20 20  scending lock.  
0f00: 2a 2a 20 70 72 6f 63 65 64 75 72 65 20 74 68 61  ** procedure tha
0f10: 74 20 66 6f 6c 6c 6f 77 73 2e 20 20 4a 75 73 74  t follows.  Just
0f20: 20 62 65 20 73 75 72 65 20 6e 6f 74 20 74 6f 20   be sure not to 
0f30: 62 6c 6f 63 6b 2e 0a 20 20 2a 2f 0a 20 20 69 66  block..  */.  if
0f40: 28 20 73 71 6c 69 74 65 33 5f 6d 75 74 65 78 5f  ( sqlite3_mutex_
0f50: 74 72 79 28 70 2d 3e 70 42 74 2d 3e 6d 75 74 65  try(p->pBt->mute
0f60: 78 29 3d 3d 53 51 4c 49 54 45 5f 4f 4b 20 29 7b  x)==SQLITE_OK ){
0f70: 0a 20 20 20 20 70 2d 3e 70 42 74 2d 3e 64 62 20  .    p->pBt->db 
0f80: 3d 20 70 2d 3e 64 62 3b 0a 20 20 20 20 70 2d 3e  = p->db;.    p->
0f90: 6c 6f 63 6b 65 64 20 3d 20 31 3b 0a 20 20 20 20  locked = 1;.    
0fa0: 72 65 74 75 72 6e 3b 0a 20 20 7d 0a 0a 20 20 2f  return;.  }..  /
0fb0: 2a 20 54 6f 20 61 76 6f 69 64 20 64 65 61 64 6c  * To avoid deadl
0fc0: 6f 63 6b 2c 20 66 69 72 73 74 20 72 65 6c 65 61  ock, first relea
0fd0: 73 65 20 61 6c 6c 20 6c 6f 63 6b 73 20 77 69 74  se all locks wit
0fe0: 68 20 61 20 6c 61 72 67 65 72 0a 20 20 2a 2a 20  h a larger.  ** 
0ff0: 42 74 53 68 61 72 65 64 20 61 64 64 72 65 73 73  BtShared address
1000: 2e 20 20 54 68 65 6e 20 61 63 71 75 69 72 65 20  .  Then acquire 
1010: 6f 75 72 20 6c 6f 63 6b 2e 20 20 54 68 65 6e 20  our lock.  Then 
1020: 72 65 61 63 71 75 69 72 65 0a 20 20 2a 2a 20 74  reacquire.  ** t
1030: 68 65 20 6f 74 68 65 72 20 42 74 53 68 61 72 65  he other BtShare
1040: 64 20 6c 6f 63 6b 73 20 74 68 61 74 20 77 65 20  d locks that we 
1050: 75 73 65 64 20 74 6f 20 68 6f 6c 64 20 69 6e 20  used to hold in 
1060: 61 73 63 65 6e 64 69 6e 67 0a 20 20 2a 2a 20 6f  ascending.  ** o
1070: 72 64 65 72 2e 0a 20 20 2a 2f 0a 20 20 66 6f 72  rder..  */.  for
1080: 28 70 4c 61 74 65 72 3d 70 2d 3e 70 4e 65 78 74  (pLater=p->pNext
1090: 3b 20 70 4c 61 74 65 72 3b 20 70 4c 61 74 65 72  ; pLater; pLater
10a0: 3d 70 4c 61 74 65 72 2d 3e 70 4e 65 78 74 29 7b  =pLater->pNext){
10b0: 0a 20 20 20 20 61 73 73 65 72 74 28 20 70 4c 61  .    assert( pLa
10c0: 74 65 72 2d 3e 73 68 61 72 61 62 6c 65 20 29 3b  ter->sharable );
10d0: 0a 20 20 20 20 61 73 73 65 72 74 28 20 70 4c 61  .    assert( pLa
10e0: 74 65 72 2d 3e 70 4e 65 78 74 3d 3d 30 20 7c 7c  ter->pNext==0 ||
10f0: 20 70 4c 61 74 65 72 2d 3e 70 4e 65 78 74 2d 3e   pLater->pNext->
1100: 70 42 74 3e 70 4c 61 74 65 72 2d 3e 70 42 74 20  pBt>pLater->pBt 
1110: 29 3b 0a 20 20 20 20 61 73 73 65 72 74 28 20 21  );.    assert( !
1120: 70 4c 61 74 65 72 2d 3e 6c 6f 63 6b 65 64 20 7c  pLater->locked |
1130: 7c 20 70 4c 61 74 65 72 2d 3e 77 61 6e 74 54 6f  | pLater->wantTo
1140: 4c 6f 63 6b 3e 30 20 29 3b 0a 20 20 20 20 69 66  Lock>0 );.    if
1150: 28 20 70 4c 61 74 65 72 2d 3e 6c 6f 63 6b 65 64  ( pLater->locked
1160: 20 29 7b 0a 20 20 20 20 20 20 75 6e 6c 6f 63 6b   ){.      unlock
1170: 42 74 72 65 65 4d 75 74 65 78 28 70 4c 61 74 65  BtreeMutex(pLate
1180: 72 29 3b 0a 20 20 20 20 7d 0a 20 20 7d 0a 20 20  r);.    }.  }.  
1190: 6c 6f 63 6b 42 74 72 65 65 4d 75 74 65 78 28 70  lockBtreeMutex(p
11a0: 29 3b 0a 20 20 66 6f 72 28 70 4c 61 74 65 72 3d  );.  for(pLater=
11b0: 70 2d 3e 70 4e 65 78 74 3b 20 70 4c 61 74 65 72  p->pNext; pLater
11c0: 3b 20 70 4c 61 74 65 72 3d 70 4c 61 74 65 72 2d  ; pLater=pLater-
11d0: 3e 70 4e 65 78 74 29 7b 0a 20 20 20 20 69 66 28  >pNext){.    if(
11e0: 20 70 4c 61 74 65 72 2d 3e 77 61 6e 74 54 6f 4c   pLater->wantToL
11f0: 6f 63 6b 20 29 7b 0a 20 20 20 20 20 20 6c 6f 63  ock ){.      loc
1200: 6b 42 74 72 65 65 4d 75 74 65 78 28 70 4c 61 74  kBtreeMutex(pLat
1210: 65 72 29 3b 0a 20 20 20 20 7d 0a 20 20 7d 0a 7d  er);.    }.  }.}
1220: 0a 0a 0a 2f 2a 0a 2a 2a 20 45 78 69 74 20 74 68  .../*.** Exit th
1230: 65 20 72 65 63 75 72 73 69 76 65 20 6d 75 74 65  e recursive mute
1240: 78 20 6f 6e 20 61 20 42 74 72 65 65 2e 0a 2a 2f  x on a Btree..*/
1250: 0a 76 6f 69 64 20 73 71 6c 69 74 65 33 42 74 72  .void sqlite3Btr
1260: 65 65 4c 65 61 76 65 28 42 74 72 65 65 20 2a 70  eeLeave(Btree *p
1270: 29 7b 0a 20 20 61 73 73 65 72 74 28 20 73 71 6c  ){.  assert( sql
1280: 69 74 65 33 5f 6d 75 74 65 78 5f 68 65 6c 64 28  ite3_mutex_held(
1290: 70 2d 3e 64 62 2d 3e 6d 75 74 65 78 29 20 29 3b  p->db->mutex) );
12a0: 0a 20 20 69 66 28 20 70 2d 3e 73 68 61 72 61 62  .  if( p->sharab
12b0: 6c 65 20 29 7b 0a 20 20 20 20 61 73 73 65 72 74  le ){.    assert
12c0: 28 20 70 2d 3e 77 61 6e 74 54 6f 4c 6f 63 6b 3e  ( p->wantToLock>
12d0: 30 20 29 3b 0a 20 20 20 20 70 2d 3e 77 61 6e 74  0 );.    p->want
12e0: 54 6f 4c 6f 63 6b 2d 2d 3b 0a 20 20 20 20 69 66  ToLock--;.    if
12f0: 28 20 70 2d 3e 77 61 6e 74 54 6f 4c 6f 63 6b 3d  ( p->wantToLock=
1300: 3d 30 20 29 7b 0a 20 20 20 20 20 20 75 6e 6c 6f  =0 ){.      unlo
1310: 63 6b 42 74 72 65 65 4d 75 74 65 78 28 70 29 3b  ckBtreeMutex(p);
1320: 0a 20 20 20 20 7d 0a 20 20 7d 0a 7d 0a 0a 23 69  .    }.  }.}..#i
1330: 66 6e 64 65 66 20 4e 44 45 42 55 47 0a 2f 2a 0a  fndef NDEBUG./*.
1340: 2a 2a 20 52 65 74 75 72 6e 20 74 72 75 65 20 69  ** Return true i
1350: 66 20 74 68 65 20 42 74 53 68 61 72 65 64 20 6d  f the BtShared m
1360: 75 74 65 78 20 69 73 20 68 65 6c 64 20 6f 6e 20  utex is held on 
1370: 74 68 65 20 62 74 72 65 65 2c 20 6f 72 20 69 66  the btree, or if
1380: 20 74 68 65 0a 2a 2a 20 42 2d 54 72 65 65 20 69   the.** B-Tree i
1390: 73 20 6e 6f 74 20 6d 61 72 6b 65 64 20 61 73 20  s not marked as 
13a0: 73 68 61 72 61 62 6c 65 2e 0a 2a 2a 0a 2a 2a 20  sharable..**.** 
13b0: 54 68 69 73 20 72 6f 75 74 69 6e 65 20 69 73 20  This routine is 
13c0: 75 73 65 64 20 6f 6e 6c 79 20 66 72 6f 6d 20 77  used only from w
13d0: 69 74 68 69 6e 20 61 73 73 65 72 74 28 29 20 73  ithin assert() s
13e0: 74 61 74 65 6d 65 6e 74 73 2e 0a 2a 2f 0a 69 6e  tatements..*/.in
13f0: 74 20 73 71 6c 69 74 65 33 42 74 72 65 65 48 6f  t sqlite3BtreeHo
1400: 6c 64 73 4d 75 74 65 78 28 42 74 72 65 65 20 2a  ldsMutex(Btree *
1410: 70 29 7b 0a 20 20 61 73 73 65 72 74 28 20 70 2d  p){.  assert( p-
1420: 3e 73 68 61 72 61 62 6c 65 3d 3d 30 20 7c 7c 20  >sharable==0 || 
1430: 70 2d 3e 6c 6f 63 6b 65 64 3d 3d 30 20 7c 7c 20  p->locked==0 || 
1440: 70 2d 3e 77 61 6e 74 54 6f 4c 6f 63 6b 3e 30 20  p->wantToLock>0 
1450: 29 3b 0a 20 20 61 73 73 65 72 74 28 20 70 2d 3e  );.  assert( p->
1460: 73 68 61 72 61 62 6c 65 3d 3d 30 20 7c 7c 20 70  sharable==0 || p
1470: 2d 3e 6c 6f 63 6b 65 64 3d 3d 30 20 7c 7c 20 70  ->locked==0 || p
1480: 2d 3e 64 62 3d 3d 70 2d 3e 70 42 74 2d 3e 64 62  ->db==p->pBt->db
1490: 20 29 3b 0a 20 20 61 73 73 65 72 74 28 20 70 2d   );.  assert( p-
14a0: 3e 73 68 61 72 61 62 6c 65 3d 3d 30 20 7c 7c 20  >sharable==0 || 
14b0: 70 2d 3e 6c 6f 63 6b 65 64 3d 3d 30 20 7c 7c 20  p->locked==0 || 
14c0: 73 71 6c 69 74 65 33 5f 6d 75 74 65 78 5f 68 65  sqlite3_mutex_he
14d0: 6c 64 28 70 2d 3e 70 42 74 2d 3e 6d 75 74 65 78  ld(p->pBt->mutex
14e0: 29 20 29 3b 0a 20 20 61 73 73 65 72 74 28 20 70  ) );.  assert( p
14f0: 2d 3e 73 68 61 72 61 62 6c 65 3d 3d 30 20 7c 7c  ->sharable==0 ||
1500: 20 70 2d 3e 6c 6f 63 6b 65 64 3d 3d 30 20 7c 7c   p->locked==0 ||
1510: 20 73 71 6c 69 74 65 33 5f 6d 75 74 65 78 5f 68   sqlite3_mutex_h
1520: 65 6c 64 28 70 2d 3e 64 62 2d 3e 6d 75 74 65 78  eld(p->db->mutex
1530: 29 20 29 3b 0a 0a 20 20 72 65 74 75 72 6e 20 28  ) );..  return (
1540: 70 2d 3e 73 68 61 72 61 62 6c 65 3d 3d 30 20 7c  p->sharable==0 |
1550: 7c 20 70 2d 3e 6c 6f 63 6b 65 64 29 3b 0a 7d 0a  | p->locked);.}.
1560: 23 65 6e 64 69 66 0a 0a 0a 2f 2a 0a 2a 2a 20 45  #endif.../*.** E
1570: 6e 74 65 72 20 74 68 65 20 6d 75 74 65 78 20 6f  nter the mutex o
1580: 6e 20 65 76 65 72 79 20 42 74 72 65 65 20 61 73  n every Btree as
1590: 73 6f 63 69 61 74 65 64 20 77 69 74 68 20 61 20  sociated with a 
15a0: 64 61 74 61 62 61 73 65 0a 2a 2a 20 63 6f 6e 6e  database.** conn
15b0: 65 63 74 69 6f 6e 2e 20 20 54 68 69 73 20 69 73  ection.  This is
15c0: 20 6e 65 65 64 65 64 20 28 66 6f 72 20 65 78 61   needed (for exa
15d0: 6d 70 6c 65 29 20 70 72 69 6f 72 20 74 6f 20 70  mple) prior to p
15e0: 61 72 73 69 6e 67 0a 2a 2a 20 61 20 73 74 61 74  arsing.** a stat
15f0: 65 6d 65 6e 74 20 73 69 6e 63 65 20 77 65 20 77  ement since we w
1600: 69 6c 6c 20 62 65 20 63 6f 6d 70 61 72 69 6e 67  ill be comparing
1610: 20 74 61 62 6c 65 20 61 6e 64 20 63 6f 6c 75 6d   table and colum
1620: 6e 20 6e 61 6d 65 73 0a 2a 2a 20 61 67 61 69 6e  n names.** again
1630: 73 74 20 61 6c 6c 20 73 63 68 65 6d 61 73 20 61  st all schemas a
1640: 6e 64 20 77 65 20 64 6f 20 6e 6f 74 20 77 61 6e  nd we do not wan
1650: 74 20 74 68 6f 73 65 20 73 63 68 65 6d 61 73 20  t those schemas 
1660: 62 65 69 6e 67 0a 2a 2a 20 72 65 73 65 74 20 6f  being.** reset o
1670: 75 74 20 66 72 6f 6d 20 75 6e 64 65 72 20 75 73  ut from under us
1680: 2e 0a 2a 2a 0a 2a 2a 20 54 68 65 72 65 20 69 73  ..**.** There is
1690: 20 61 20 63 6f 72 72 65 73 70 6f 6e 64 69 6e 67   a corresponding
16a0: 20 6c 65 61 76 65 2d 61 6c 6c 20 70 72 6f 63 65   leave-all proce
16b0: 64 75 72 65 73 2e 0a 2a 2a 0a 2a 2a 20 45 6e 74  dures..**.** Ent
16c0: 65 72 20 74 68 65 20 6d 75 74 65 78 65 73 20 69  er the mutexes i
16d0: 6e 20 61 63 63 65 6e 64 69 6e 67 20 6f 72 64 65  n accending orde
16e0: 72 20 62 79 20 42 74 53 68 61 72 65 64 20 70 6f  r by BtShared po
16f0: 69 6e 74 65 72 20 61 64 64 72 65 73 73 0a 2a 2a  inter address.**
1700: 20 74 6f 20 61 76 6f 69 64 20 74 68 65 20 70 6f   to avoid the po
1710: 73 73 69 62 69 6c 69 74 79 20 6f 66 20 64 65 61  ssibility of dea
1720: 64 6c 6f 63 6b 20 77 68 65 6e 20 74 77 6f 20 74  dlock when two t
1730: 68 72 65 61 64 73 20 77 69 74 68 0a 2a 2a 20 74  hreads with.** t
1740: 77 6f 20 6f 72 20 6d 6f 72 65 20 62 74 72 65 65  wo or more btree
1750: 73 20 69 6e 20 63 6f 6d 6d 6f 6e 20 62 6f 74 68  s in common both
1760: 20 74 72 79 20 74 6f 20 6c 6f 63 6b 20 61 6c 6c   try to lock all
1770: 20 74 68 65 69 72 20 62 74 72 65 65 73 0a 2a 2a   their btrees.**
1780: 20 61 74 20 74 68 65 20 73 61 6d 65 20 69 6e 73   at the same ins
1790: 74 61 6e 74 2e 0a 2a 2f 0a 76 6f 69 64 20 73 71  tant..*/.void sq
17a0: 6c 69 74 65 33 42 74 72 65 65 45 6e 74 65 72 41  lite3BtreeEnterA
17b0: 6c 6c 28 73 71 6c 69 74 65 33 20 2a 64 62 29 7b  ll(sqlite3 *db){
17c0: 0a 20 20 69 6e 74 20 69 3b 0a 20 20 42 74 72 65  .  int i;.  Btre
17d0: 65 20 2a 70 3b 0a 20 20 61 73 73 65 72 74 28 20  e *p;.  assert( 
17e0: 73 71 6c 69 74 65 33 5f 6d 75 74 65 78 5f 68 65  sqlite3_mutex_he
17f0: 6c 64 28 64 62 2d 3e 6d 75 74 65 78 29 20 29 3b  ld(db->mutex) );
1800: 0a 20 20 66 6f 72 28 69 3d 30 3b 20 69 3c 64 62  .  for(i=0; i<db
1810: 2d 3e 6e 44 62 3b 20 69 2b 2b 29 7b 0a 20 20 20  ->nDb; i++){.   
1820: 20 70 20 3d 20 64 62 2d 3e 61 44 62 5b 69 5d 2e   p = db->aDb[i].
1830: 70 42 74 3b 0a 20 20 20 20 69 66 28 20 70 20 29  pBt;.    if( p )
1840: 20 73 71 6c 69 74 65 33 42 74 72 65 65 45 6e 74   sqlite3BtreeEnt
1850: 65 72 28 70 29 3b 0a 20 20 7d 0a 7d 0a 76 6f 69  er(p);.  }.}.voi
1860: 64 20 73 71 6c 69 74 65 33 42 74 72 65 65 4c 65  d sqlite3BtreeLe
1870: 61 76 65 41 6c 6c 28 73 71 6c 69 74 65 33 20 2a  aveAll(sqlite3 *
1880: 64 62 29 7b 0a 20 20 69 6e 74 20 69 3b 0a 20 20  db){.  int i;.  
1890: 42 74 72 65 65 20 2a 70 3b 0a 20 20 61 73 73 65  Btree *p;.  asse
18a0: 72 74 28 20 73 71 6c 69 74 65 33 5f 6d 75 74 65  rt( sqlite3_mute
18b0: 78 5f 68 65 6c 64 28 64 62 2d 3e 6d 75 74 65 78  x_held(db->mutex
18c0: 29 20 29 3b 0a 20 20 66 6f 72 28 69 3d 30 3b 20  ) );.  for(i=0; 
18d0: 69 3c 64 62 2d 3e 6e 44 62 3b 20 69 2b 2b 29 7b  i<db->nDb; i++){
18e0: 0a 20 20 20 20 70 20 3d 20 64 62 2d 3e 61 44 62  .    p = db->aDb
18f0: 5b 69 5d 2e 70 42 74 3b 0a 20 20 20 20 69 66 28  [i].pBt;.    if(
1900: 20 70 20 29 20 73 71 6c 69 74 65 33 42 74 72 65   p ) sqlite3Btre
1910: 65 4c 65 61 76 65 28 70 29 3b 0a 20 20 7d 0a 7d  eLeave(p);.  }.}
1920: 0a 0a 23 69 66 6e 64 65 66 20 4e 44 45 42 55 47  ..#ifndef NDEBUG
1930: 0a 2f 2a 0a 2a 2a 20 52 65 74 75 72 6e 20 74 72  ./*.** Return tr
1940: 75 65 20 69 66 20 74 68 65 20 63 75 72 72 65 6e  ue if the curren
1950: 74 20 74 68 72 65 61 64 20 68 6f 6c 64 73 20 74  t thread holds t
1960: 68 65 20 64 61 74 61 62 61 73 65 20 63 6f 6e 6e  he database conn
1970: 65 63 74 69 6f 6e 0a 2a 2a 20 6d 75 74 65 78 20  ection.** mutex 
1980: 61 6e 64 20 61 6c 6c 20 72 65 71 75 69 72 65 64  and all required
1990: 20 42 74 53 68 61 72 65 64 20 6d 75 74 65 78 65   BtShared mutexe
19a0: 73 2e 0a 2a 2a 0a 2a 2a 20 54 68 69 73 20 72 6f  s..**.** This ro
19b0: 75 74 69 6e 65 20 69 73 20 75 73 65 64 20 69 6e  utine is used in
19c0: 73 69 64 65 20 61 73 73 65 72 74 28 29 20 73 74  side assert() st
19d0: 61 74 65 6d 65 6e 74 73 20 6f 6e 6c 79 2e 0a 2a  atements only..*
19e0: 2f 0a 69 6e 74 20 73 71 6c 69 74 65 33 42 74 72  /.int sqlite3Btr
19f0: 65 65 48 6f 6c 64 73 41 6c 6c 4d 75 74 65 78 65  eeHoldsAllMutexe
1a00: 73 28 73 71 6c 69 74 65 33 20 2a 64 62 29 7b 0a  s(sqlite3 *db){.
1a10: 20 20 69 6e 74 20 69 3b 0a 20 20 69 66 28 20 21    int i;.  if( !
1a20: 73 71 6c 69 74 65 33 5f 6d 75 74 65 78 5f 68 65  sqlite3_mutex_he
1a30: 6c 64 28 64 62 2d 3e 6d 75 74 65 78 29 20 29 7b  ld(db->mutex) ){
1a40: 0a 20 20 20 20 72 65 74 75 72 6e 20 30 3b 0a 20  .    return 0;. 
1a50: 20 7d 0a 20 20 66 6f 72 28 69 3d 30 3b 20 69 3c   }.  for(i=0; i<
1a60: 64 62 2d 3e 6e 44 62 3b 20 69 2b 2b 29 7b 0a 20  db->nDb; i++){. 
1a70: 20 20 20 42 74 72 65 65 20 2a 70 3b 0a 20 20 20     Btree *p;.   
1a80: 20 70 20 3d 20 64 62 2d 3e 61 44 62 5b 69 5d 2e   p = db->aDb[i].
1a90: 70 42 74 3b 0a 20 20 20 20 69 66 28 20 70 20 26  pBt;.    if( p &
1aa0: 26 20 70 2d 3e 73 68 61 72 61 62 6c 65 20 26 26  & p->sharable &&
1ab0: 0a 20 20 20 20 20 20 20 20 20 28 70 2d 3e 77 61  .         (p->wa
1ac0: 6e 74 54 6f 4c 6f 63 6b 3d 3d 30 20 7c 7c 20 21  ntToLock==0 || !
1ad0: 73 71 6c 69 74 65 33 5f 6d 75 74 65 78 5f 68 65  sqlite3_mutex_he
1ae0: 6c 64 28 70 2d 3e 70 42 74 2d 3e 6d 75 74 65 78  ld(p->pBt->mutex
1af0: 29 29 20 29 7b 0a 20 20 20 20 20 20 72 65 74 75  )) ){.      retu
1b00: 72 6e 20 30 3b 0a 20 20 20 20 7d 0a 20 20 7d 0a  rn 0;.    }.  }.
1b10: 20 20 72 65 74 75 72 6e 20 31 3b 0a 7d 0a 23 65    return 1;.}.#e
1b20: 6e 64 69 66 20 2f 2a 20 4e 44 45 42 55 47 20 2a  ndif /* NDEBUG *
1b30: 2f 0a 0a 23 69 66 6e 64 65 66 20 4e 44 45 42 55  /..#ifndef NDEBU
1b40: 47 0a 2f 2a 0a 2a 2a 20 52 65 74 75 72 6e 20 74  G./*.** Return t
1b50: 72 75 65 20 69 66 20 74 68 65 20 63 6f 72 72 65  rue if the corre
1b60: 63 74 20 6d 75 74 65 78 65 73 20 61 72 65 20 68  ct mutexes are h
1b70: 65 6c 64 20 66 6f 72 20 61 63 63 65 73 73 69 6e  eld for accessin
1b80: 67 20 74 68 65 0a 2a 2a 20 64 62 2d 3e 61 44 62  g the.** db->aDb
1b90: 5b 69 44 62 5d 2e 70 53 63 68 65 6d 61 20 73 74  [iDb].pSchema st
1ba0: 72 75 63 74 75 72 65 2e 20 20 54 68 65 20 6d 75  ructure.  The mu
1bb0: 74 65 78 65 73 20 72 65 71 75 69 72 65 64 20 66  texes required f
1bc0: 6f 72 20 73 63 68 65 6d 61 0a 2a 2a 20 61 63 63  or schema.** acc
1bd0: 65 73 73 20 61 72 65 3a 0a 2a 2a 0a 2a 2a 20 20  ess are:.**.**  
1be0: 20 28 31 29 20 54 68 65 20 6d 75 74 65 78 20 6f   (1) The mutex o
1bf0: 6e 20 64 62 0a 2a 2a 20 20 20 28 32 29 20 69 66  n db.**   (2) if
1c00: 20 69 44 62 21 3d 31 2c 20 74 68 65 6e 20 74 68   iDb!=1, then th
1c10: 65 20 6d 75 74 65 78 20 6f 6e 20 64 62 2d 3e 61  e mutex on db->a
1c20: 44 62 5b 69 44 62 5d 2e 70 42 74 2e 0a 2a 2a 0a  Db[iDb].pBt..**.
1c30: 2a 2a 20 49 66 20 70 53 63 68 65 6d 61 20 69 73  ** If pSchema is
1c40: 20 6e 6f 74 20 4e 55 4c 4c 2c 20 74 68 65 6e 20   not NULL, then 
1c50: 69 44 62 20 69 73 20 63 6f 6d 70 75 74 65 64 20  iDb is computed 
1c60: 66 72 6f 6d 20 70 53 63 68 65 6d 61 20 61 6e 64  from pSchema and
1c70: 0a 2a 2a 20 64 62 20 75 73 69 6e 67 20 73 71 6c  .** db using sql
1c80: 69 74 65 33 53 63 68 65 6d 61 54 6f 49 6e 64 65  ite3SchemaToInde
1c90: 78 28 29 2e 0a 2a 2f 0a 69 6e 74 20 73 71 6c 69  x()..*/.int sqli
1ca0: 74 65 33 53 63 68 65 6d 61 4d 75 74 65 78 48 65  te3SchemaMutexHe
1cb0: 6c 64 28 73 71 6c 69 74 65 33 20 2a 64 62 2c 20  ld(sqlite3 *db, 
1cc0: 69 6e 74 20 69 44 62 2c 20 53 63 68 65 6d 61 20  int iDb, Schema 
1cd0: 2a 70 53 63 68 65 6d 61 29 7b 0a 20 20 42 74 72  *pSchema){.  Btr
1ce0: 65 65 20 2a 70 3b 0a 20 20 61 73 73 65 72 74 28  ee *p;.  assert(
1cf0: 20 64 62 21 3d 30 20 29 3b 0a 20 20 69 66 28 20   db!=0 );.  if( 
1d00: 70 53 63 68 65 6d 61 20 29 20 69 44 62 20 3d 20  pSchema ) iDb = 
1d10: 73 71 6c 69 74 65 33 53 63 68 65 6d 61 54 6f 49  sqlite3SchemaToI
1d20: 6e 64 65 78 28 64 62 2c 20 70 53 63 68 65 6d 61  ndex(db, pSchema
1d30: 29 3b 0a 20 20 61 73 73 65 72 74 28 20 69 44 62  );.  assert( iDb
1d40: 3e 3d 30 20 26 26 20 69 44 62 3c 64 62 2d 3e 6e  >=0 && iDb<db->n
1d50: 44 62 20 29 3b 0a 20 20 69 66 28 20 21 73 71 6c  Db );.  if( !sql
1d60: 69 74 65 33 5f 6d 75 74 65 78 5f 68 65 6c 64 28  ite3_mutex_held(
1d70: 64 62 2d 3e 6d 75 74 65 78 29 20 29 20 72 65 74  db->mutex) ) ret
1d80: 75 72 6e 20 30 3b 0a 20 20 69 66 28 20 69 44 62  urn 0;.  if( iDb
1d90: 3d 3d 31 20 29 20 72 65 74 75 72 6e 20 31 3b 0a  ==1 ) return 1;.
1da0: 20 20 70 20 3d 20 64 62 2d 3e 61 44 62 5b 69 44    p = db->aDb[iD
1db0: 62 5d 2e 70 42 74 3b 0a 20 20 61 73 73 65 72 74  b].pBt;.  assert
1dc0: 28 20 70 21 3d 30 20 29 3b 0a 20 20 72 65 74 75  ( p!=0 );.  retu
1dd0: 72 6e 20 70 2d 3e 73 68 61 72 61 62 6c 65 3d 3d  rn p->sharable==
1de0: 30 20 7c 7c 20 70 2d 3e 6c 6f 63 6b 65 64 3d 3d  0 || p->locked==
1df0: 31 3b 0a 7d 0a 23 65 6e 64 69 66 20 2f 2a 20 4e  1;.}.#endif /* N
1e00: 44 45 42 55 47 20 2a 2f 0a 0a 23 65 6c 73 65 20  DEBUG */..#else 
1e10: 2f 2a 20 53 51 4c 49 54 45 5f 54 48 52 45 41 44  /* SQLITE_THREAD
1e20: 53 41 46 45 3e 30 20 61 62 6f 76 65 2e 20 20 53  SAFE>0 above.  S
1e30: 51 4c 49 54 45 5f 54 48 52 45 41 44 53 41 46 45  QLITE_THREADSAFE
1e40: 3d 3d 30 20 62 65 6c 6f 77 20 2a 2f 0a 2f 2a 0a  ==0 below */./*.
1e50: 2a 2a 20 54 68 65 20 66 6f 6c 6c 6f 77 69 6e 67  ** The following
1e60: 20 61 72 65 20 73 70 65 63 69 61 6c 20 63 61 73   are special cas
1e70: 65 73 20 66 6f 72 20 6d 75 74 65 78 20 65 6e 74  es for mutex ent
1e80: 65 72 20 72 6f 75 74 69 6e 65 73 20 66 6f 72 20  er routines for 
1e90: 75 73 65 0a 2a 2a 20 69 6e 20 73 69 6e 67 6c 65  use.** in single
1ea0: 20 74 68 72 65 61 64 65 64 20 61 70 70 6c 69 63   threaded applic
1eb0: 61 74 69 6f 6e 73 20 74 68 61 74 20 75 73 65 20  ations that use 
1ec0: 73 68 61 72 65 64 20 63 61 63 68 65 2e 20 20 45  shared cache.  E
1ed0: 78 63 65 70 74 20 66 6f 72 0a 2a 2a 20 74 68 65  xcept for.** the
1ee0: 73 65 20 74 77 6f 20 72 6f 75 74 69 6e 65 73 2c  se two routines,
1ef0: 20 61 6c 6c 20 6d 75 74 65 78 20 6f 70 65 72 61   all mutex opera
1f00: 74 69 6f 6e 73 20 61 72 65 20 6e 6f 2d 6f 70 73  tions are no-ops
1f10: 20 69 6e 20 74 68 61 74 20 63 61 73 65 20 61 6e   in that case an
1f20: 64 0a 2a 2a 20 61 72 65 20 6e 75 6c 6c 20 23 64  d.** are null #d
1f30: 65 66 69 6e 65 73 20 69 6e 20 62 74 72 65 65 2e  efines in btree.
1f40: 68 2e 0a 2a 2a 0a 2a 2a 20 49 66 20 73 68 61 72  h..**.** If shar
1f50: 65 64 20 63 61 63 68 65 20 69 73 20 64 69 73 61  ed cache is disa
1f60: 62 6c 65 64 2c 20 74 68 65 6e 20 61 6c 6c 20 62  bled, then all b
1f70: 74 72 65 65 20 6d 75 74 65 78 20 72 6f 75 74 69  tree mutex routi
1f80: 6e 65 73 2c 20 69 6e 63 6c 75 64 69 6e 67 0a 2a  nes, including.*
1f90: 2a 20 74 68 65 20 6f 6e 65 73 20 62 65 6c 6f 77  * the ones below
1fa0: 2c 20 61 72 65 20 6e 6f 2d 6f 70 73 20 61 6e 64  , are no-ops and
1fb0: 20 61 72 65 20 6e 75 6c 6c 20 23 64 65 66 69 6e   are null #defin
1fc0: 65 73 20 69 6e 20 62 74 72 65 65 2e 68 2e 0a 2a  es in btree.h..*
1fd0: 2f 0a 0a 76 6f 69 64 20 73 71 6c 69 74 65 33 42  /..void sqlite3B
1fe0: 74 72 65 65 45 6e 74 65 72 28 42 74 72 65 65 20  treeEnter(Btree 
1ff0: 2a 70 29 7b 0a 20 20 70 2d 3e 70 42 74 2d 3e 64  *p){.  p->pBt->d
2000: 62 20 3d 20 70 2d 3e 64 62 3b 0a 7d 0a 76 6f 69  b = p->db;.}.voi
2010: 64 20 73 71 6c 69 74 65 33 42 74 72 65 65 45 6e  d sqlite3BtreeEn
2020: 74 65 72 41 6c 6c 28 73 71 6c 69 74 65 33 20 2a  terAll(sqlite3 *
2030: 64 62 29 7b 0a 20 20 69 6e 74 20 69 3b 0a 20 20  db){.  int i;.  
2040: 66 6f 72 28 69 3d 30 3b 20 69 3c 64 62 2d 3e 6e  for(i=0; i<db->n
2050: 44 62 3b 20 69 2b 2b 29 7b 0a 20 20 20 20 42 74  Db; i++){.    Bt
2060: 72 65 65 20 2a 70 20 3d 20 64 62 2d 3e 61 44 62  ree *p = db->aDb
2070: 5b 69 5d 2e 70 42 74 3b 0a 20 20 20 20 69 66 28  [i].pBt;.    if(
2080: 20 70 20 29 7b 0a 20 20 20 20 20 20 70 2d 3e 70   p ){.      p->p
2090: 42 74 2d 3e 64 62 20 3d 20 70 2d 3e 64 62 3b 0a  Bt->db = p->db;.
20a0: 20 20 20 20 7d 0a 20 20 7d 0a 7d 0a 23 65 6e 64      }.  }.}.#end
20b0: 69 66 20 2f 2a 20 69 66 20 53 51 4c 49 54 45 5f  if /* if SQLITE_
20c0: 54 48 52 45 41 44 53 41 46 45 20 2a 2f 0a 0a 23  THREADSAFE */..#
20d0: 69 66 6e 64 65 66 20 53 51 4c 49 54 45 5f 4f 4d  ifndef SQLITE_OM
20e0: 49 54 5f 49 4e 43 52 42 4c 4f 42 0a 2f 2a 0a 2a  IT_INCRBLOB./*.*
20f0: 2a 20 45 6e 74 65 72 20 61 20 6d 75 74 65 78 20  * Enter a mutex 
2100: 6f 6e 20 61 20 42 74 72 65 65 20 67 69 76 65 6e  on a Btree given
2110: 20 61 20 63 75 72 73 6f 72 20 6f 77 6e 65 64 20   a cursor owned 
2120: 62 79 20 74 68 61 74 20 42 74 72 65 65 2e 20 0a  by that Btree. .
2130: 2a 2a 0a 2a 2a 20 54 68 65 73 65 20 65 6e 74 72  **.** These entr
2140: 79 20 70 6f 69 6e 74 73 20 61 72 65 20 75 73 65  y points are use
2150: 64 20 62 79 20 69 6e 63 72 65 6d 65 6e 74 61 6c  d by incremental
2160: 20 49 2f 4f 20 6f 6e 6c 79 2e 20 45 6e 74 65 72   I/O only. Enter
2170: 28 29 20 69 73 20 72 65 71 75 69 72 65 64 20 0a  () is required .
2180: 2a 2a 20 61 6e 79 20 74 69 6d 65 20 4f 4d 49 54  ** any time OMIT
2190: 5f 53 48 41 52 45 44 5f 43 41 43 48 45 20 69 73  _SHARED_CACHE is
21a0: 20 6e 6f 74 20 64 65 66 69 6e 65 64 2c 20 72 65   not defined, re
21b0: 67 61 72 64 6c 65 73 73 20 6f 66 20 77 68 65 74  gardless of whet
21c0: 68 65 72 20 6f 72 20 6e 6f 74 20 0a 2a 2a 20 74  her or not .** t
21d0: 68 65 20 62 75 69 6c 64 20 69 73 20 74 68 72 65  he build is thre
21e0: 61 64 73 61 66 65 2e 20 4c 65 61 76 65 28 29 20  adsafe. Leave() 
21f0: 69 73 20 6f 6e 6c 79 20 72 65 71 75 69 72 65 64  is only required
2200: 20 62 79 20 74 68 72 65 61 64 73 61 66 65 20 62   by threadsafe b
2210: 75 69 6c 64 73 2e 0a 2a 2f 0a 76 6f 69 64 20 73  uilds..*/.void s
2220: 71 6c 69 74 65 33 42 74 72 65 65 45 6e 74 65 72  qlite3BtreeEnter
2230: 43 75 72 73 6f 72 28 42 74 43 75 72 73 6f 72 20  Cursor(BtCursor 
2240: 2a 70 43 75 72 29 7b 0a 20 20 73 71 6c 69 74 65  *pCur){.  sqlite
2250: 33 42 74 72 65 65 45 6e 74 65 72 28 70 43 75 72  3BtreeEnter(pCur
2260: 2d 3e 70 42 74 72 65 65 29 3b 0a 7d 0a 23 20 69  ->pBtree);.}.# i
2270: 66 20 53 51 4c 49 54 45 5f 54 48 52 45 41 44 53  f SQLITE_THREADS
2280: 41 46 45 0a 76 6f 69 64 20 73 71 6c 69 74 65 33  AFE.void sqlite3
2290: 42 74 72 65 65 4c 65 61 76 65 43 75 72 73 6f 72  BtreeLeaveCursor
22a0: 28 42 74 43 75 72 73 6f 72 20 2a 70 43 75 72 29  (BtCursor *pCur)
22b0: 7b 0a 20 20 73 71 6c 69 74 65 33 42 74 72 65 65  {.  sqlite3Btree
22c0: 4c 65 61 76 65 28 70 43 75 72 2d 3e 70 42 74 72  Leave(pCur->pBtr
22d0: 65 65 29 3b 0a 7d 0a 23 20 65 6e 64 69 66 0a 23  ee);.}.# endif.#
22e0: 65 6e 64 69 66 20 2f 2a 20 69 66 6e 64 65 66 20  endif /* ifndef 
22f0: 53 51 4c 49 54 45 5f 4f 4d 49 54 5f 49 4e 43 52  SQLITE_OMIT_INCR
2300: 42 4c 4f 42 20 2a 2f 0a 0a 23 65 6e 64 69 66 20  BLOB */..#endif 
2310: 2f 2a 20 69 66 6e 64 65 66 20 53 51 4c 49 54 45  /* ifndef SQLITE
2320: 5f 4f 4d 49 54 5f 53 48 41 52 45 44 5f 43 41 43  _OMIT_SHARED_CAC
2330: 48 45 20 2a 2f 0a                                HE */.