/ Hex Artifact Content
Login

Artifact a5c7d63f595ef4e2c7411fc627f1f6e3e8ee089b:


0000: 2f 2a 0a 2a 2a 20 32 30 30 37 20 41 75 67 75 73  /*.** 2007 Augus
0010: 74 20 31 34 0a 2a 2a 0a 2a 2a 20 54 68 65 20 61  t 14.**.** 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 63 6f 6e 74 61 69 6e 73 20 74 68 65 20 43 20   contains the C 
0190: 66 75 6e 63 74 69 6f 6e 73 20 74 68 61 74 20 69  functions that i
01a0: 6d 70 6c 65 6d 65 6e 74 20 6d 75 74 65 78 65 73  mplement mutexes
01b0: 2e 0a 2a 2a 0a 2a 2a 20 54 68 69 73 20 66 69 6c  ..**.** This fil
01c0: 65 20 63 6f 6e 74 61 69 6e 73 20 63 6f 64 65 20  e contains code 
01d0: 74 68 61 74 20 69 73 20 63 6f 6d 6d 6f 6e 20 61  that is common a
01e0: 63 72 6f 73 73 20 61 6c 6c 20 6d 75 74 65 78 20  cross all mutex 
01f0: 69 6d 70 6c 65 6d 65 6e 74 61 74 69 6f 6e 73 2e  implementations.
0200: 0a 2a 2f 0a 23 69 6e 63 6c 75 64 65 20 22 73 71  .*/.#include "sq
0210: 6c 69 74 65 49 6e 74 2e 68 22 0a 0a 23 69 66 20  liteInt.h"..#if 
0220: 64 65 66 69 6e 65 64 28 53 51 4c 49 54 45 5f 44  defined(SQLITE_D
0230: 45 42 55 47 29 20 26 26 20 21 64 65 66 69 6e 65  EBUG) && !define
0240: 64 28 53 51 4c 49 54 45 5f 4d 55 54 45 58 5f 4f  d(SQLITE_MUTEX_O
0250: 4d 49 54 29 0a 2f 2a 0a 2a 2a 20 46 6f 72 20 64  MIT)./*.** For d
0260: 65 62 75 67 67 69 6e 67 20 70 75 72 70 6f 73 65  ebugging purpose
0270: 73 2c 20 72 65 63 6f 72 64 20 77 68 65 6e 20 74  s, record when t
0280: 68 65 20 6d 75 74 65 78 20 73 75 62 73 79 73 74  he mutex subsyst
0290: 65 6d 20 69 73 20 69 6e 69 74 69 61 6c 69 7a 65  em is initialize
02a0: 64 0a 2a 2a 20 61 6e 64 20 75 6e 69 6e 69 74 69  d.** and uniniti
02b0: 61 6c 69 7a 65 64 20 73 6f 20 74 68 61 74 20 77  alized so that w
02c0: 65 20 63 61 6e 20 61 73 73 65 72 74 28 29 20 69  e can assert() i
02d0: 66 20 74 68 65 72 65 20 69 73 20 61 6e 20 61 74  f there is an at
02e0: 74 65 6d 70 74 20 74 6f 0a 2a 2a 20 61 6c 6c 6f  tempt to.** allo
02f0: 63 61 74 65 20 61 20 6d 75 74 65 78 20 77 68 69  cate a mutex whi
0300: 6c 65 20 74 68 65 20 73 79 73 74 65 6d 20 69 73  le the system is
0310: 20 75 6e 69 6e 69 74 69 61 6c 69 7a 65 64 2e 0a   uninitialized..
0320: 2a 2f 0a 73 74 61 74 69 63 20 53 51 4c 49 54 45  */.static SQLITE
0330: 5f 57 53 44 20 69 6e 74 20 6d 75 74 65 78 49 73  _WSD int mutexIs
0340: 49 6e 69 74 20 3d 20 30 3b 0a 23 65 6e 64 69 66  Init = 0;.#endif
0350: 20 2f 2a 20 53 51 4c 49 54 45 5f 44 45 42 55 47   /* SQLITE_DEBUG
0360: 20 26 26 20 21 64 65 66 69 6e 65 64 28 53 51 4c   && !defined(SQL
0370: 49 54 45 5f 4d 55 54 45 58 5f 4f 4d 49 54 29 20  ITE_MUTEX_OMIT) 
0380: 2a 2f 0a 0a 0a 23 69 66 6e 64 65 66 20 53 51 4c  */...#ifndef SQL
0390: 49 54 45 5f 4d 55 54 45 58 5f 4f 4d 49 54 0a 2f  ITE_MUTEX_OMIT./
03a0: 2a 0a 2a 2a 20 54 68 69 73 20 73 74 72 75 63 74  *.** This struct
03b0: 75 72 65 20 69 73 20 66 6f 72 20 75 73 65 20 62  ure is for use b
03c0: 79 20 6d 75 74 65 78 49 73 49 6e 76 61 6c 69 64  y mutexIsInvalid
03d0: 28 29 20 6f 6e 6c 79 2e 20 20 49 74 20 72 65 70  () only.  It rep
03e0: 72 65 73 65 6e 74 73 20 61 6e 0a 2a 2a 20 69 6e  resents an.** in
03f0: 76 61 6c 69 64 20 6d 75 74 65 78 20 69 6d 70 6c  valid mutex impl
0400: 65 6d 65 6e 74 61 74 69 6f 6e 20 28 69 2e 65 2e  ementation (i.e.
0410: 20 6f 6e 65 20 77 68 65 72 65 20 61 6c 6c 20 74   one where all t
0420: 68 65 20 66 75 6e 63 74 69 6f 6e 20 70 6f 69 6e  he function poin
0430: 74 65 72 73 0a 2a 2a 20 61 72 65 20 6e 75 6c 6c  ters.** are null
0440: 29 2e 0a 2a 2f 0a 73 74 61 74 69 63 20 63 6f 6e  )..*/.static con
0450: 73 74 20 73 71 6c 69 74 65 33 5f 6d 75 74 65 78  st sqlite3_mutex
0460: 5f 6d 65 74 68 6f 64 73 20 6d 75 74 65 78 4e 75  _methods mutexNu
0470: 6c 6c 4d 65 74 68 6f 64 73 20 3d 20 7b 0a 20 20  llMethods = {.  
0480: 30 2c 20 2f 2a 20 78 4d 75 74 65 78 49 6e 69 74  0, /* xMutexInit
0490: 20 2a 2f 0a 20 20 30 2c 20 2f 2a 20 78 4d 75 74   */.  0, /* xMut
04a0: 65 78 45 6e 64 20 2a 2f 0a 20 20 30 2c 20 2f 2a  exEnd */.  0, /*
04b0: 20 78 4d 75 74 65 78 41 6c 6c 6f 63 20 2a 2f 0a   xMutexAlloc */.
04c0: 20 20 30 2c 20 2f 2a 20 78 4d 75 74 65 78 46 72    0, /* xMutexFr
04d0: 65 65 20 2a 2f 0a 20 20 30 2c 20 2f 2a 20 78 4d  ee */.  0, /* xM
04e0: 75 74 65 78 45 6e 74 65 72 20 2a 2f 0a 20 20 30  utexEnter */.  0
04f0: 2c 20 2f 2a 20 78 4d 75 74 65 78 54 72 79 20 2a  , /* xMutexTry *
0500: 2f 0a 20 20 30 2c 20 2f 2a 20 78 4d 75 74 65 78  /.  0, /* xMutex
0510: 4c 65 61 76 65 20 2a 2f 0a 20 20 30 2c 20 2f 2a  Leave */.  0, /*
0520: 20 78 4d 75 74 65 78 48 65 6c 64 20 2a 2f 0a 20   xMutexHeld */. 
0530: 20 30 20 20 2f 2a 20 78 4d 75 74 65 78 4e 6f 74   0  /* xMutexNot
0540: 68 65 6c 64 20 2a 2f 0a 7d 3b 0a 0a 2f 2a 0a 2a  held */.};../*.*
0550: 2a 20 52 65 74 75 72 6e 73 20 6e 6f 6e 2d 7a 65  * Returns non-ze
0560: 72 6f 20 69 66 20 74 68 65 20 63 75 72 72 65 6e  ro if the curren
0570: 74 6c 79 20 63 6f 6e 66 69 67 75 72 65 64 20 6d  tly configured m
0580: 75 74 65 78 20 69 6d 70 6c 65 6d 65 6e 74 69 6f  utex implementio
0590: 6e 20 69 73 0a 2a 2a 20 69 6e 76 61 6c 69 64 20  n is.** invalid 
05a0: 28 69 2e 65 2e 20 61 6c 6c 20 6f 66 20 69 74 73  (i.e. all of its
05b0: 20 66 75 6e 63 74 69 6f 6e 20 70 6f 69 6e 74 65   function pointe
05c0: 72 73 20 61 72 65 20 6e 75 6c 6c 29 2e 0a 2a 2f  rs are null)..*/
05d0: 0a 73 74 61 74 69 63 20 69 6e 74 20 6d 75 74 65  .static int mute
05e0: 78 49 73 49 6e 76 61 6c 69 64 28 76 6f 69 64 29  xIsInvalid(void)
05f0: 7b 0a 20 20 72 65 74 75 72 6e 20 6d 65 6d 63 6d  {.  return memcm
0600: 70 28 26 73 71 6c 69 74 65 33 47 6c 6f 62 61 6c  p(&sqlite3Global
0610: 43 6f 6e 66 69 67 2e 6d 75 74 65 78 2c 20 26 6d  Config.mutex, &m
0620: 75 74 65 78 4e 75 6c 6c 4d 65 74 68 6f 64 73 2c  utexNullMethods,
0630: 0a 20 20 20 20 20 20 20 20 20 20 20 20 20 20 20  .               
0640: 20 73 69 7a 65 6f 66 28 73 71 6c 69 74 65 33 5f   sizeof(sqlite3_
0650: 6d 75 74 65 78 5f 6d 65 74 68 6f 64 73 29 29 3d  mutex_methods))=
0660: 3d 30 3b 0a 7d 0a 0a 2f 2a 0a 2a 2a 20 43 6f 70  =0;.}../*.** Cop
0670: 69 65 73 20 61 20 6d 75 74 65 78 20 69 6d 70 6c  ies a mutex impl
0680: 65 6d 65 6e 74 61 74 69 6f 6e 2e 20 20 42 6f 74  ementation.  Bot
0690: 68 20 61 72 67 75 6d 65 6e 74 73 20 6d 75 73 74  h arguments must
06a0: 20 70 6f 69 6e 74 20 74 6f 20 76 61 6c 69 64 0a   point to valid.
06b0: 2a 2a 20 6d 65 6d 6f 72 79 2e 0a 2a 2f 0a 73 74  ** memory..*/.st
06c0: 61 74 69 63 20 76 6f 69 64 20 6d 75 74 65 78 43  atic void mutexC
06d0: 6f 70 79 28 0a 20 20 73 71 6c 69 74 65 33 5f 6d  opy(.  sqlite3_m
06e0: 75 74 65 78 5f 6d 65 74 68 6f 64 73 20 2a 70 54  utex_methods *pT
06f0: 6f 2c 0a 20 20 73 71 6c 69 74 65 33 5f 6d 75 74  o,.  sqlite3_mut
0700: 65 78 5f 6d 65 74 68 6f 64 73 20 63 6f 6e 73 74  ex_methods const
0710: 20 2a 70 46 72 6f 6d 0a 29 7b 0a 20 20 70 54 6f   *pFrom.){.  pTo
0720: 2d 3e 78 4d 75 74 65 78 49 6e 69 74 20 3d 20 70  ->xMutexInit = p
0730: 46 72 6f 6d 2d 3e 78 4d 75 74 65 78 49 6e 69 74  From->xMutexInit
0740: 3b 0a 20 20 70 54 6f 2d 3e 78 4d 75 74 65 78 45  ;.  pTo->xMutexE
0750: 6e 64 20 3d 20 70 46 72 6f 6d 2d 3e 78 4d 75 74  nd = pFrom->xMut
0760: 65 78 45 6e 64 3b 0a 20 20 70 54 6f 2d 3e 78 4d  exEnd;.  pTo->xM
0770: 75 74 65 78 46 72 65 65 20 3d 20 70 46 72 6f 6d  utexFree = pFrom
0780: 2d 3e 78 4d 75 74 65 78 46 72 65 65 3b 0a 20 20  ->xMutexFree;.  
0790: 70 54 6f 2d 3e 78 4d 75 74 65 78 45 6e 74 65 72  pTo->xMutexEnter
07a0: 20 3d 20 70 46 72 6f 6d 2d 3e 78 4d 75 74 65 78   = pFrom->xMutex
07b0: 45 6e 74 65 72 3b 0a 20 20 70 54 6f 2d 3e 78 4d  Enter;.  pTo->xM
07c0: 75 74 65 78 54 72 79 20 3d 20 70 46 72 6f 6d 2d  utexTry = pFrom-
07d0: 3e 78 4d 75 74 65 78 54 72 79 3b 0a 20 20 70 54  >xMutexTry;.  pT
07e0: 6f 2d 3e 78 4d 75 74 65 78 4c 65 61 76 65 20 3d  o->xMutexLeave =
07f0: 20 70 46 72 6f 6d 2d 3e 78 4d 75 74 65 78 4c 65   pFrom->xMutexLe
0800: 61 76 65 3b 0a 20 20 70 54 6f 2d 3e 78 4d 75 74  ave;.  pTo->xMut
0810: 65 78 48 65 6c 64 20 3d 20 70 46 72 6f 6d 2d 3e  exHeld = pFrom->
0820: 78 4d 75 74 65 78 48 65 6c 64 3b 0a 20 20 70 54  xMutexHeld;.  pT
0830: 6f 2d 3e 78 4d 75 74 65 78 4e 6f 74 68 65 6c 64  o->xMutexNotheld
0840: 20 3d 20 70 46 72 6f 6d 2d 3e 78 4d 75 74 65 78   = pFrom->xMutex
0850: 4e 6f 74 68 65 6c 64 3b 0a 20 20 70 54 6f 2d 3e  Notheld;.  pTo->
0860: 78 4d 75 74 65 78 41 6c 6c 6f 63 20 3d 20 70 46  xMutexAlloc = pF
0870: 72 6f 6d 2d 3e 78 4d 75 74 65 78 41 6c 6c 6f 63  rom->xMutexAlloc
0880: 3b 0a 7d 0a 0a 2f 2a 0a 2a 2a 20 49 6e 69 74 69  ;.}../*.** Initi
0890: 61 6c 69 7a 65 20 74 68 65 20 6d 75 74 65 78 20  alize the mutex 
08a0: 73 79 73 74 65 6d 2e 0a 2a 2f 0a 69 6e 74 20 73  system..*/.int s
08b0: 71 6c 69 74 65 33 4d 75 74 65 78 49 6e 69 74 28  qlite3MutexInit(
08c0: 76 6f 69 64 29 7b 20 0a 20 20 69 6e 74 20 72 63  void){ .  int rc
08d0: 3b 0a 20 20 69 66 28 20 73 71 6c 69 74 65 33 43  ;.  if( sqlite3C
08e0: 6f 6d 70 61 72 65 41 6e 64 53 77 61 70 28 28 76  ompareAndSwap((v
08f0: 6f 69 64 20 2a 20 76 6f 6c 61 74 69 6c 65 20 2a  oid * volatile *
0900: 29 26 73 71 6c 69 74 65 33 47 6c 6f 62 61 6c 43  )&sqlite3GlobalC
0910: 6f 6e 66 69 67 2e 70 4d 75 74 65 78 2c 0a 20 20  onfig.pMutex,.  
0920: 20 20 20 20 20 20 20 20 20 20 20 20 20 20 20 20                  
0930: 20 30 2c 20 26 73 71 6c 69 74 65 33 47 6c 6f 62   0, &sqlite3Glob
0940: 61 6c 43 6f 6e 66 69 67 2e 6d 75 74 65 78 29 3d  alConfig.mutex)=
0950: 3d 30 20 7c 7c 20 6d 75 74 65 78 49 73 49 6e 76  =0 || mutexIsInv
0960: 61 6c 69 64 28 29 20 29 7b 0a 20 20 20 20 2f 2a  alid() ){.    /*
0970: 20 49 66 20 74 68 65 20 6d 75 74 65 78 20 69 6d   If the mutex im
0980: 70 6c 65 6d 65 6e 74 61 74 69 6f 6e 20 70 6f 69  plementation poi
0990: 6e 74 65 72 20 68 61 73 20 6e 6f 74 20 62 65 65  nter has not bee
09a0: 6e 20 73 65 74 2c 20 74 68 65 6e 20 74 68 65 20  n set, then the 
09b0: 75 73 65 72 0a 20 20 20 20 2a 2a 20 64 69 64 20  user.    ** did 
09c0: 6e 6f 74 20 69 6e 73 74 61 6c 6c 20 61 20 6d 75  not install a mu
09d0: 74 65 78 20 69 6d 70 6c 65 6d 65 6e 74 61 74 69  tex implementati
09e0: 6f 6e 20 76 69 61 20 73 71 6c 69 74 65 33 5f 63  on via sqlite3_c
09f0: 6f 6e 66 69 67 28 29 20 70 72 69 6f 72 20 74 6f  onfig() prior to
0a00: 0a 20 20 20 20 2a 2a 20 73 71 6c 69 74 65 33 5f  .    ** sqlite3_
0a10: 69 6e 69 74 69 61 6c 69 7a 65 28 29 20 62 65 69  initialize() bei
0a20: 6e 67 20 63 61 6c 6c 65 64 2e 20 20 54 68 69 73  ng called.  This
0a30: 20 62 6c 6f 63 6b 20 63 6f 70 69 65 73 20 74 68   block copies th
0a40: 65 20 70 6f 69 6e 74 65 72 73 0a 20 20 20 20 2a  e pointers.    *
0a50: 2a 20 66 6f 72 20 74 68 65 20 64 65 66 61 75 6c  * for the defaul
0a60: 74 20 69 6d 70 6c 65 6d 65 6e 74 61 74 69 6f 6e  t implementation
0a70: 20 69 6e 74 6f 20 74 68 65 20 73 71 6c 69 74 65   into the sqlite
0a80: 33 47 6c 6f 62 61 6c 43 6f 6e 66 69 67 20 73 74  3GlobalConfig st
0a90: 72 75 63 74 75 72 65 2e 0a 20 20 20 20 2a 2f 0a  ructure..    */.
0aa0: 20 20 20 20 73 71 6c 69 74 65 33 5f 6d 75 74 65      sqlite3_mute
0ab0: 78 5f 6d 65 74 68 6f 64 73 20 63 6f 6e 73 74 20  x_methods const 
0ac0: 2a 70 46 72 6f 6d 3b 0a 0a 20 20 20 20 69 66 28  *pFrom;..    if(
0ad0: 20 73 71 6c 69 74 65 33 47 6c 6f 62 61 6c 43 6f   sqlite3GlobalCo
0ae0: 6e 66 69 67 2e 62 43 6f 72 65 4d 75 74 65 78 20  nfig.bCoreMutex 
0af0: 29 7b 0a 20 20 20 20 20 20 70 46 72 6f 6d 20 3d  ){.      pFrom =
0b00: 20 73 71 6c 69 74 65 33 44 65 66 61 75 6c 74 4d   sqlite3DefaultM
0b10: 75 74 65 78 28 29 3b 0a 20 20 20 20 7d 65 6c 73  utex();.    }els
0b20: 65 7b 0a 20 20 20 20 20 20 70 46 72 6f 6d 20 3d  e{.      pFrom =
0b30: 20 73 71 6c 69 74 65 33 4e 6f 6f 70 4d 75 74 65   sqlite3NoopMute
0b40: 78 28 29 3b 0a 20 20 20 20 7d 0a 20 20 20 20 6d  x();.    }.    m
0b50: 75 74 65 78 43 6f 70 79 28 26 73 71 6c 69 74 65  utexCopy(&sqlite
0b60: 33 47 6c 6f 62 61 6c 43 6f 6e 66 69 67 2e 6d 75  3GlobalConfig.mu
0b70: 74 65 78 2c 20 70 46 72 6f 6d 29 3b 0a 20 20 20  tex, pFrom);.   
0b80: 20 73 71 6c 69 74 65 33 4d 65 6d 6f 72 79 42 61   sqlite3MemoryBa
0b90: 72 72 69 65 72 28 29 3b 0a 20 20 7d 0a 20 20 61  rrier();.  }.  a
0ba0: 73 73 65 72 74 28 20 73 71 6c 69 74 65 33 47 6c  ssert( sqlite3Gl
0bb0: 6f 62 61 6c 43 6f 6e 66 69 67 2e 6d 75 74 65 78  obalConfig.mutex
0bc0: 2e 78 4d 75 74 65 78 49 6e 69 74 20 29 3b 0a 20  .xMutexInit );. 
0bd0: 20 72 63 20 3d 20 73 71 6c 69 74 65 33 47 6c 6f   rc = sqlite3Glo
0be0: 62 61 6c 43 6f 6e 66 69 67 2e 6d 75 74 65 78 2e  balConfig.mutex.
0bf0: 78 4d 75 74 65 78 49 6e 69 74 28 29 3b 0a 0a 23  xMutexInit();..#
0c00: 69 66 64 65 66 20 53 51 4c 49 54 45 5f 44 45 42  ifdef SQLITE_DEB
0c10: 55 47 0a 20 20 47 4c 4f 42 41 4c 28 69 6e 74 2c  UG.  GLOBAL(int,
0c20: 20 6d 75 74 65 78 49 73 49 6e 69 74 29 20 3d 20   mutexIsInit) = 
0c30: 31 3b 0a 23 65 6e 64 69 66 0a 0a 20 20 72 65 74  1;.#endif..  ret
0c40: 75 72 6e 20 72 63 3b 0a 7d 0a 0a 2f 2a 0a 2a 2a  urn rc;.}../*.**
0c50: 20 53 68 75 74 64 6f 77 6e 20 74 68 65 20 6d 75   Shutdown the mu
0c60: 74 65 78 20 73 79 73 74 65 6d 2e 20 54 68 69 73  tex system. This
0c70: 20 63 61 6c 6c 20 66 72 65 65 73 20 72 65 73 6f   call frees reso
0c80: 75 72 63 65 73 20 61 6c 6c 6f 63 61 74 65 64 20  urces allocated 
0c90: 62 79 0a 2a 2a 20 73 71 6c 69 74 65 33 4d 75 74  by.** sqlite3Mut
0ca0: 65 78 49 6e 69 74 28 29 2e 0a 2a 2f 0a 69 6e 74  exInit()..*/.int
0cb0: 20 73 71 6c 69 74 65 33 4d 75 74 65 78 45 6e 64   sqlite3MutexEnd
0cc0: 28 76 6f 69 64 29 7b 0a 20 20 69 6e 74 20 72 63  (void){.  int rc
0cd0: 20 3d 20 53 51 4c 49 54 45 5f 4f 4b 3b 0a 20 20   = SQLITE_OK;.  
0ce0: 69 66 28 20 73 71 6c 69 74 65 33 47 6c 6f 62 61  if( sqlite3Globa
0cf0: 6c 43 6f 6e 66 69 67 2e 6d 75 74 65 78 2e 78 4d  lConfig.mutex.xM
0d00: 75 74 65 78 45 6e 64 20 29 7b 0a 20 20 20 20 72  utexEnd ){.    r
0d10: 63 20 3d 20 73 71 6c 69 74 65 33 47 6c 6f 62 61  c = sqlite3Globa
0d20: 6c 43 6f 6e 66 69 67 2e 6d 75 74 65 78 2e 78 4d  lConfig.mutex.xM
0d30: 75 74 65 78 45 6e 64 28 29 3b 0a 20 20 7d 0a 0a  utexEnd();.  }..
0d40: 23 69 66 64 65 66 20 53 51 4c 49 54 45 5f 44 45  #ifdef SQLITE_DE
0d50: 42 55 47 0a 20 20 47 4c 4f 42 41 4c 28 69 6e 74  BUG.  GLOBAL(int
0d60: 2c 20 6d 75 74 65 78 49 73 49 6e 69 74 29 20 3d  , mutexIsInit) =
0d70: 20 30 3b 0a 23 65 6e 64 69 66 0a 0a 20 20 72 65   0;.#endif..  re
0d80: 74 75 72 6e 20 72 63 3b 0a 7d 0a 0a 2f 2a 0a 2a  turn rc;.}../*.*
0d90: 2a 20 52 65 74 72 69 65 76 65 20 61 20 70 6f 69  * Retrieve a poi
0da0: 6e 74 65 72 20 74 6f 20 61 20 73 74 61 74 69 63  nter to a static
0db0: 20 6d 75 74 65 78 20 6f 72 20 61 6c 6c 6f 63 61   mutex or alloca
0dc0: 74 65 20 61 20 6e 65 77 20 64 79 6e 61 6d 69 63  te a new dynamic
0dd0: 20 6f 6e 65 2e 0a 2a 2f 0a 73 71 6c 69 74 65 33   one..*/.sqlite3
0de0: 5f 6d 75 74 65 78 20 2a 73 71 6c 69 74 65 33 5f  _mutex *sqlite3_
0df0: 6d 75 74 65 78 5f 61 6c 6c 6f 63 28 69 6e 74 20  mutex_alloc(int 
0e00: 69 64 29 7b 0a 23 69 66 6e 64 65 66 20 53 51 4c  id){.#ifndef SQL
0e10: 49 54 45 5f 4f 4d 49 54 5f 41 55 54 4f 49 4e 49  ITE_OMIT_AUTOINI
0e20: 54 0a 20 20 69 66 28 20 69 64 3c 3d 53 51 4c 49  T.  if( id<=SQLI
0e30: 54 45 5f 4d 55 54 45 58 5f 52 45 43 55 52 53 49  TE_MUTEX_RECURSI
0e40: 56 45 20 26 26 20 73 71 6c 69 74 65 33 5f 69 6e  VE && sqlite3_in
0e50: 69 74 69 61 6c 69 7a 65 28 29 20 29 20 72 65 74  itialize() ) ret
0e60: 75 72 6e 20 30 3b 0a 20 20 69 66 28 20 69 64 3e  urn 0;.  if( id>
0e70: 53 51 4c 49 54 45 5f 4d 55 54 45 58 5f 52 45 43  SQLITE_MUTEX_REC
0e80: 55 52 53 49 56 45 20 26 26 20 73 71 6c 69 74 65  URSIVE && sqlite
0e90: 33 4d 75 74 65 78 49 6e 69 74 28 29 20 29 20 72  3MutexInit() ) r
0ea0: 65 74 75 72 6e 20 30 3b 0a 23 65 6e 64 69 66 0a  eturn 0;.#endif.
0eb0: 20 20 61 73 73 65 72 74 28 20 73 71 6c 69 74 65    assert( sqlite
0ec0: 33 47 6c 6f 62 61 6c 43 6f 6e 66 69 67 2e 6d 75  3GlobalConfig.mu
0ed0: 74 65 78 2e 78 4d 75 74 65 78 41 6c 6c 6f 63 20  tex.xMutexAlloc 
0ee0: 29 3b 0a 20 20 72 65 74 75 72 6e 20 73 71 6c 69  );.  return sqli
0ef0: 74 65 33 47 6c 6f 62 61 6c 43 6f 6e 66 69 67 2e  te3GlobalConfig.
0f00: 6d 75 74 65 78 2e 78 4d 75 74 65 78 41 6c 6c 6f  mutex.xMutexAllo
0f10: 63 28 69 64 29 3b 0a 7d 0a 0a 73 71 6c 69 74 65  c(id);.}..sqlite
0f20: 33 5f 6d 75 74 65 78 20 2a 73 71 6c 69 74 65 33  3_mutex *sqlite3
0f30: 4d 75 74 65 78 41 6c 6c 6f 63 28 69 6e 74 20 69  MutexAlloc(int i
0f40: 64 29 7b 0a 20 20 69 66 28 20 21 73 71 6c 69 74  d){.  if( !sqlit
0f50: 65 33 47 6c 6f 62 61 6c 43 6f 6e 66 69 67 2e 62  e3GlobalConfig.b
0f60: 43 6f 72 65 4d 75 74 65 78 20 29 7b 0a 20 20 20  CoreMutex ){.   
0f70: 20 72 65 74 75 72 6e 20 30 3b 0a 20 20 7d 0a 20   return 0;.  }. 
0f80: 20 61 73 73 65 72 74 28 20 47 4c 4f 42 41 4c 28   assert( GLOBAL(
0f90: 69 6e 74 2c 20 6d 75 74 65 78 49 73 49 6e 69 74  int, mutexIsInit
0fa0: 29 20 29 3b 0a 20 20 61 73 73 65 72 74 28 20 73  ) );.  assert( s
0fb0: 71 6c 69 74 65 33 47 6c 6f 62 61 6c 43 6f 6e 66  qlite3GlobalConf
0fc0: 69 67 2e 6d 75 74 65 78 2e 78 4d 75 74 65 78 41  ig.mutex.xMutexA
0fd0: 6c 6c 6f 63 20 29 3b 0a 20 20 72 65 74 75 72 6e  lloc );.  return
0fe0: 20 73 71 6c 69 74 65 33 47 6c 6f 62 61 6c 43 6f   sqlite3GlobalCo
0ff0: 6e 66 69 67 2e 6d 75 74 65 78 2e 78 4d 75 74 65  nfig.mutex.xMute
1000: 78 41 6c 6c 6f 63 28 69 64 29 3b 0a 7d 0a 0a 2f  xAlloc(id);.}../
1010: 2a 0a 2a 2a 20 46 72 65 65 20 61 20 64 79 6e 61  *.** Free a dyna
1020: 6d 69 63 20 6d 75 74 65 78 2e 0a 2a 2f 0a 76 6f  mic mutex..*/.vo
1030: 69 64 20 73 71 6c 69 74 65 33 5f 6d 75 74 65 78  id sqlite3_mutex
1040: 5f 66 72 65 65 28 73 71 6c 69 74 65 33 5f 6d 75  _free(sqlite3_mu
1050: 74 65 78 20 2a 70 29 7b 0a 20 20 69 66 28 20 70  tex *p){.  if( p
1060: 20 29 7b 0a 20 20 20 20 61 73 73 65 72 74 28 20   ){.    assert( 
1070: 73 71 6c 69 74 65 33 47 6c 6f 62 61 6c 43 6f 6e  sqlite3GlobalCon
1080: 66 69 67 2e 6d 75 74 65 78 2e 78 4d 75 74 65 78  fig.mutex.xMutex
1090: 46 72 65 65 20 29 3b 0a 20 20 20 20 73 71 6c 69  Free );.    sqli
10a0: 74 65 33 47 6c 6f 62 61 6c 43 6f 6e 66 69 67 2e  te3GlobalConfig.
10b0: 6d 75 74 65 78 2e 78 4d 75 74 65 78 46 72 65 65  mutex.xMutexFree
10c0: 28 70 29 3b 0a 20 20 7d 0a 7d 0a 0a 2f 2a 0a 2a  (p);.  }.}../*.*
10d0: 2a 20 4f 62 74 61 69 6e 20 74 68 65 20 6d 75 74  * Obtain the mut
10e0: 65 78 20 70 2e 20 49 66 20 73 6f 6d 65 20 6f 74  ex p. If some ot
10f0: 68 65 72 20 74 68 72 65 61 64 20 61 6c 72 65 61  her thread alrea
1100: 64 79 20 68 61 73 20 74 68 65 20 6d 75 74 65 78  dy has the mutex
1110: 2c 20 62 6c 6f 63 6b 0a 2a 2a 20 75 6e 74 69 6c  , block.** until
1120: 20 69 74 20 63 61 6e 20 62 65 20 6f 62 74 61 69   it can be obtai
1130: 6e 65 64 2e 0a 2a 2f 0a 76 6f 69 64 20 73 71 6c  ned..*/.void sql
1140: 69 74 65 33 5f 6d 75 74 65 78 5f 65 6e 74 65 72  ite3_mutex_enter
1150: 28 73 71 6c 69 74 65 33 5f 6d 75 74 65 78 20 2a  (sqlite3_mutex *
1160: 70 29 7b 0a 20 20 69 66 28 20 70 20 29 7b 0a 20  p){.  if( p ){. 
1170: 20 20 20 61 73 73 65 72 74 28 20 73 71 6c 69 74     assert( sqlit
1180: 65 33 47 6c 6f 62 61 6c 43 6f 6e 66 69 67 2e 6d  e3GlobalConfig.m
1190: 75 74 65 78 2e 78 4d 75 74 65 78 45 6e 74 65 72  utex.xMutexEnter
11a0: 20 29 3b 0a 20 20 20 20 73 71 6c 69 74 65 33 47   );.    sqlite3G
11b0: 6c 6f 62 61 6c 43 6f 6e 66 69 67 2e 6d 75 74 65  lobalConfig.mute
11c0: 78 2e 78 4d 75 74 65 78 45 6e 74 65 72 28 70 29  x.xMutexEnter(p)
11d0: 3b 0a 20 20 7d 0a 7d 0a 0a 2f 2a 0a 2a 2a 20 4f  ;.  }.}../*.** O
11e0: 62 74 61 69 6e 20 74 68 65 20 6d 75 74 65 78 20  btain the mutex 
11f0: 70 2e 20 49 66 20 73 75 63 63 65 73 73 66 75 6c  p. If successful
1200: 2c 20 72 65 74 75 72 6e 20 53 51 4c 49 54 45 5f  , return SQLITE_
1210: 4f 4b 2e 20 4f 74 68 65 72 77 69 73 65 2c 20 69  OK. Otherwise, i
1220: 66 20 61 6e 6f 74 68 65 72 0a 2a 2a 20 74 68 72  f another.** thr
1230: 65 61 64 20 68 6f 6c 64 73 20 74 68 65 20 6d 75  ead holds the mu
1240: 74 65 78 20 61 6e 64 20 69 74 20 63 61 6e 6e 6f  tex and it canno
1250: 74 20 62 65 20 6f 62 74 61 69 6e 65 64 2c 20 72  t be obtained, r
1260: 65 74 75 72 6e 20 53 51 4c 49 54 45 5f 42 55 53  eturn SQLITE_BUS
1270: 59 2e 0a 2a 2f 0a 69 6e 74 20 73 71 6c 69 74 65  Y..*/.int sqlite
1280: 33 5f 6d 75 74 65 78 5f 74 72 79 28 73 71 6c 69  3_mutex_try(sqli
1290: 74 65 33 5f 6d 75 74 65 78 20 2a 70 29 7b 0a 20  te3_mutex *p){. 
12a0: 20 69 6e 74 20 72 63 20 3d 20 53 51 4c 49 54 45   int rc = SQLITE
12b0: 5f 4f 4b 3b 0a 20 20 69 66 28 20 70 20 29 7b 0a  _OK;.  if( p ){.
12c0: 20 20 20 20 61 73 73 65 72 74 28 20 73 71 6c 69      assert( sqli
12d0: 74 65 33 47 6c 6f 62 61 6c 43 6f 6e 66 69 67 2e  te3GlobalConfig.
12e0: 6d 75 74 65 78 2e 78 4d 75 74 65 78 54 72 79 20  mutex.xMutexTry 
12f0: 29 3b 0a 20 20 20 20 72 65 74 75 72 6e 20 73 71  );.    return sq
1300: 6c 69 74 65 33 47 6c 6f 62 61 6c 43 6f 6e 66 69  lite3GlobalConfi
1310: 67 2e 6d 75 74 65 78 2e 78 4d 75 74 65 78 54 72  g.mutex.xMutexTr
1320: 79 28 70 29 3b 0a 20 20 7d 0a 20 20 72 65 74 75  y(p);.  }.  retu
1330: 72 6e 20 72 63 3b 0a 7d 0a 0a 2f 2a 0a 2a 2a 20  rn rc;.}../*.** 
1340: 54 68 65 20 73 71 6c 69 74 65 33 5f 6d 75 74 65  The sqlite3_mute
1350: 78 5f 6c 65 61 76 65 28 29 20 72 6f 75 74 69 6e  x_leave() routin
1360: 65 20 65 78 69 74 73 20 61 20 6d 75 74 65 78 20  e exits a mutex 
1370: 74 68 61 74 20 77 61 73 20 70 72 65 76 69 6f 75  that was previou
1380: 73 6c 79 0a 2a 2a 20 65 6e 74 65 72 65 64 20 62  sly.** entered b
1390: 79 20 74 68 65 20 73 61 6d 65 20 74 68 72 65 61  y the same threa
13a0: 64 2e 20 20 54 68 65 20 62 65 68 61 76 69 6f 72  d.  The behavior
13b0: 20 69 73 20 75 6e 64 65 66 69 6e 65 64 20 69 66   is undefined if
13c0: 20 74 68 65 20 6d 75 74 65 78 20 0a 2a 2a 20 69   the mutex .** i
13d0: 73 20 6e 6f 74 20 63 75 72 72 65 6e 74 6c 79 20  s not currently 
13e0: 65 6e 74 65 72 65 64 2e 20 49 66 20 61 20 4e 55  entered. If a NU
13f0: 4c 4c 20 70 6f 69 6e 74 65 72 20 69 73 20 70 61  LL pointer is pa
1400: 73 73 65 64 20 61 73 20 61 6e 20 61 72 67 75 6d  ssed as an argum
1410: 65 6e 74 0a 2a 2a 20 74 68 69 73 20 66 75 6e 63  ent.** this func
1420: 74 69 6f 6e 20 69 73 20 61 20 6e 6f 2d 6f 70 2e  tion is a no-op.
1430: 0a 2a 2f 0a 76 6f 69 64 20 73 71 6c 69 74 65 33  .*/.void sqlite3
1440: 5f 6d 75 74 65 78 5f 6c 65 61 76 65 28 73 71 6c  _mutex_leave(sql
1450: 69 74 65 33 5f 6d 75 74 65 78 20 2a 70 29 7b 0a  ite3_mutex *p){.
1460: 20 20 69 66 28 20 70 20 29 7b 0a 20 20 20 20 61    if( p ){.    a
1470: 73 73 65 72 74 28 20 73 71 6c 69 74 65 33 47 6c  ssert( sqlite3Gl
1480: 6f 62 61 6c 43 6f 6e 66 69 67 2e 6d 75 74 65 78  obalConfig.mutex
1490: 2e 78 4d 75 74 65 78 4c 65 61 76 65 20 29 3b 0a  .xMutexLeave );.
14a0: 20 20 20 20 73 71 6c 69 74 65 33 47 6c 6f 62 61      sqlite3Globa
14b0: 6c 43 6f 6e 66 69 67 2e 6d 75 74 65 78 2e 78 4d  lConfig.mutex.xM
14c0: 75 74 65 78 4c 65 61 76 65 28 70 29 3b 0a 20 20  utexLeave(p);.  
14d0: 7d 0a 7d 0a 0a 23 69 66 6e 64 65 66 20 4e 44 45  }.}..#ifndef NDE
14e0: 42 55 47 0a 2f 2a 0a 2a 2a 20 54 68 65 20 73 71  BUG./*.** The sq
14f0: 6c 69 74 65 33 5f 6d 75 74 65 78 5f 68 65 6c 64  lite3_mutex_held
1500: 28 29 20 61 6e 64 20 73 71 6c 69 74 65 33 5f 6d  () and sqlite3_m
1510: 75 74 65 78 5f 6e 6f 74 68 65 6c 64 28 29 20 72  utex_notheld() r
1520: 6f 75 74 69 6e 65 20 61 72 65 0a 2a 2a 20 69 6e  outine are.** in
1530: 74 65 6e 64 65 64 20 66 6f 72 20 75 73 65 20 69  tended for use i
1540: 6e 73 69 64 65 20 61 73 73 65 72 74 28 29 20 73  nside assert() s
1550: 74 61 74 65 6d 65 6e 74 73 2e 0a 2a 2f 0a 69 6e  tatements..*/.in
1560: 74 20 73 71 6c 69 74 65 33 5f 6d 75 74 65 78 5f  t sqlite3_mutex_
1570: 68 65 6c 64 28 73 71 6c 69 74 65 33 5f 6d 75 74  held(sqlite3_mut
1580: 65 78 20 2a 70 29 7b 0a 20 20 61 73 73 65 72 74  ex *p){.  assert
1590: 28 20 70 3d 3d 30 20 7c 7c 20 73 71 6c 69 74 65  ( p==0 || sqlite
15a0: 33 47 6c 6f 62 61 6c 43 6f 6e 66 69 67 2e 6d 75  3GlobalConfig.mu
15b0: 74 65 78 2e 78 4d 75 74 65 78 48 65 6c 64 20 29  tex.xMutexHeld )
15c0: 3b 0a 20 20 72 65 74 75 72 6e 20 70 3d 3d 30 20  ;.  return p==0 
15d0: 7c 7c 20 73 71 6c 69 74 65 33 47 6c 6f 62 61 6c  || sqlite3Global
15e0: 43 6f 6e 66 69 67 2e 6d 75 74 65 78 2e 78 4d 75  Config.mutex.xMu
15f0: 74 65 78 48 65 6c 64 28 70 29 3b 0a 7d 0a 69 6e  texHeld(p);.}.in
1600: 74 20 73 71 6c 69 74 65 33 5f 6d 75 74 65 78 5f  t sqlite3_mutex_
1610: 6e 6f 74 68 65 6c 64 28 73 71 6c 69 74 65 33 5f  notheld(sqlite3_
1620: 6d 75 74 65 78 20 2a 70 29 7b 0a 20 20 61 73 73  mutex *p){.  ass
1630: 65 72 74 28 20 70 3d 3d 30 20 7c 7c 20 73 71 6c  ert( p==0 || sql
1640: 69 74 65 33 47 6c 6f 62 61 6c 43 6f 6e 66 69 67  ite3GlobalConfig
1650: 2e 6d 75 74 65 78 2e 78 4d 75 74 65 78 4e 6f 74  .mutex.xMutexNot
1660: 68 65 6c 64 20 29 3b 0a 20 20 72 65 74 75 72 6e  held );.  return
1670: 20 70 3d 3d 30 20 7c 7c 20 73 71 6c 69 74 65 33   p==0 || sqlite3
1680: 47 6c 6f 62 61 6c 43 6f 6e 66 69 67 2e 6d 75 74  GlobalConfig.mut
1690: 65 78 2e 78 4d 75 74 65 78 4e 6f 74 68 65 6c 64  ex.xMutexNotheld
16a0: 28 70 29 3b 0a 7d 0a 23 65 6e 64 69 66 0a 0a 23  (p);.}.#endif..#
16b0: 65 6e 64 69 66 20 2f 2a 20 21 64 65 66 69 6e 65  endif /* !define
16c0: 64 28 53 51 4c 49 54 45 5f 4d 55 54 45 58 5f 4f  d(SQLITE_MUTEX_O
16d0: 4d 49 54 29 20 2a 2f 0a                          MIT) */.