/ Hex Artifact Content
Login

Artifact 87bd895b69359cf01d611fa72849237087151e21:


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 73 71 6c 69 74 65 33 4d 75 74 65 78 49 6e  y sqlite3MutexIn
03d0: 69 74 28 29 20 6f 6e 6c 79 2e 20 20 49 74 20 72  it() only.  It r
03e0: 65 70 72 65 73 65 6e 74 73 20 61 6e 0a 2a 2a 20  epresents an.** 
03f0: 69 6e 76 61 6c 69 64 20 6d 75 74 65 78 20 69 6d  invalid mutex im
0400: 70 6c 65 6d 65 6e 74 61 74 69 6f 6e 20 28 69 2e  plementation (i.
0410: 65 2e 20 6f 6e 65 20 77 68 65 72 65 20 61 6c 6c  e. one where all
0420: 20 74 68 65 20 66 75 6e 63 74 69 6f 6e 20 70 6f   the function po
0430: 69 6e 74 65 72 73 0a 2a 2a 20 61 72 65 20 6e 75  inters.** are nu
0440: 6c 6c 29 2e 0a 2a 2f 0a 73 74 61 74 69 63 20 63  ll)..*/.static c
0450: 6f 6e 73 74 20 73 71 6c 69 74 65 33 5f 6d 75 74  onst sqlite3_mut
0460: 65 78 5f 6d 65 74 68 6f 64 73 20 6d 75 74 65 78  ex_methods mutex
0470: 4e 75 6c 6c 4d 65 74 68 6f 64 73 20 3d 20 7b 0a  NullMethods = {.
0480: 20 20 30 2c 20 2f 2a 20 78 4d 75 74 65 78 49 6e    0, /* xMutexIn
0490: 69 74 20 2a 2f 0a 20 20 30 2c 20 2f 2a 20 78 4d  it */.  0, /* xM
04a0: 75 74 65 78 45 6e 64 20 2a 2f 0a 20 20 30 2c 20  utexEnd */.  0, 
04b0: 2f 2a 20 78 4d 75 74 65 78 41 6c 6c 6f 63 20 2a  /* xMutexAlloc *
04c0: 2f 0a 20 20 30 2c 20 2f 2a 20 78 4d 75 74 65 78  /.  0, /* xMutex
04d0: 46 72 65 65 20 2a 2f 0a 20 20 30 2c 20 2f 2a 20  Free */.  0, /* 
04e0: 78 4d 75 74 65 78 45 6e 74 65 72 20 2a 2f 0a 20  xMutexEnter */. 
04f0: 20 30 2c 20 2f 2a 20 78 4d 75 74 65 78 54 72 79   0, /* xMutexTry
0500: 20 2a 2f 0a 20 20 30 2c 20 2f 2a 20 78 4d 75 74   */.  0, /* xMut
0510: 65 78 4c 65 61 76 65 20 2a 2f 0a 20 20 30 2c 20  exLeave */.  0, 
0520: 2f 2a 20 78 4d 75 74 65 78 48 65 6c 64 20 2a 2f  /* xMutexHeld */
0530: 0a 20 20 30 20 20 2f 2a 20 78 4d 75 74 65 78 4e  .  0  /* xMutexN
0540: 6f 74 68 65 6c 64 20 2a 2f 0a 7d 3b 0a 0a 2f 2a  otheld */.};../*
0550: 0a 2a 2a 20 52 65 74 75 72 6e 73 20 6e 6f 6e 2d  .** Returns non-
0560: 7a 65 72 6f 20 69 66 20 74 68 65 20 63 75 72 72  zero if the curr
0570: 65 6e 74 6c 79 20 63 6f 6e 66 69 67 75 72 65 64  ently configured
0580: 20 6d 75 74 65 78 20 69 6d 70 6c 65 6d 65 6e 74   mutex implement
0590: 69 6f 6e 20 69 73 0a 2a 2a 20 69 6e 76 61 6c 69  ion is.** invali
05a0: 64 20 28 69 2e 65 2e 20 61 6c 6c 20 6f 66 20 69  d (i.e. all of i
05b0: 74 73 20 66 75 6e 63 74 69 6f 6e 20 70 6f 69 6e  ts function poin
05c0: 74 65 72 73 20 61 72 65 20 6e 75 6c 6c 29 2e 0a  ters are null)..
05d0: 2a 2f 0a 73 74 61 74 69 63 20 69 6e 74 20 6d 75  */.static int mu
05e0: 74 65 78 49 73 49 6e 76 61 6c 69 64 28 76 6f 69  texIsInvalid(voi
05f0: 64 29 7b 0a 20 20 72 65 74 75 72 6e 20 6d 65 6d  d){.  return mem
0600: 63 6d 70 28 26 73 71 6c 69 74 65 33 47 6c 6f 62  cmp(&sqlite3Glob
0610: 61 6c 43 6f 6e 66 69 67 2e 6d 75 74 65 78 2c 20  alConfig.mutex, 
0620: 26 6d 75 74 65 78 4e 75 6c 6c 4d 65 74 68 6f 64  &mutexNullMethod
0630: 73 2c 0a 20 20 20 20 20 20 20 20 20 20 20 20 20  s,.             
0640: 20 20 20 73 69 7a 65 6f 66 28 73 71 6c 69 74 65     sizeof(sqlite
0650: 33 5f 6d 75 74 65 78 5f 6d 65 74 68 6f 64 73 29  3_mutex_methods)
0660: 29 3d 3d 30 3b 0a 7d 0a 0a 2f 2a 0a 2a 2a 20 43  )==0;.}../*.** C
0670: 6f 70 69 65 73 20 61 20 6d 75 74 65 78 20 69 6d  opies a mutex im
0680: 70 6c 65 6d 65 6e 74 61 74 69 6f 6e 2e 20 20 42  plementation.  B
0690: 6f 74 68 20 61 72 67 75 6d 65 6e 74 73 20 6d 75  oth arguments mu
06a0: 73 74 20 70 6f 69 6e 74 20 74 6f 20 76 61 6c 69  st point to vali
06b0: 64 0a 2a 2a 20 6d 65 6d 6f 72 79 2e 0a 2a 2f 0a  d.** memory..*/.
06c0: 73 74 61 74 69 63 20 76 6f 69 64 20 6d 75 74 65  static void mute
06d0: 78 43 6f 70 79 28 0a 20 20 73 71 6c 69 74 65 33  xCopy(.  sqlite3
06e0: 5f 6d 75 74 65 78 5f 6d 65 74 68 6f 64 73 20 2a  _mutex_methods *
06f0: 70 54 6f 2c 0a 20 20 73 71 6c 69 74 65 33 5f 6d  pTo,.  sqlite3_m
0700: 75 74 65 78 5f 6d 65 74 68 6f 64 73 20 63 6f 6e  utex_methods con
0710: 73 74 20 2a 70 46 72 6f 6d 0a 29 7b 0a 20 20 70  st *pFrom.){.  p
0720: 54 6f 2d 3e 78 4d 75 74 65 78 49 6e 69 74 20 3d  To->xMutexInit =
0730: 20 70 46 72 6f 6d 2d 3e 78 4d 75 74 65 78 49 6e   pFrom->xMutexIn
0740: 69 74 3b 0a 20 20 70 54 6f 2d 3e 78 4d 75 74 65  it;.  pTo->xMute
0750: 78 45 6e 64 20 3d 20 70 46 72 6f 6d 2d 3e 78 4d  xEnd = pFrom->xM
0760: 75 74 65 78 45 6e 64 3b 0a 20 20 70 54 6f 2d 3e  utexEnd;.  pTo->
0770: 78 4d 75 74 65 78 46 72 65 65 20 3d 20 70 46 72  xMutexFree = pFr
0780: 6f 6d 2d 3e 78 4d 75 74 65 78 46 72 65 65 3b 0a  om->xMutexFree;.
0790: 20 20 70 54 6f 2d 3e 78 4d 75 74 65 78 45 6e 74    pTo->xMutexEnt
07a0: 65 72 20 3d 20 70 46 72 6f 6d 2d 3e 78 4d 75 74  er = pFrom->xMut
07b0: 65 78 45 6e 74 65 72 3b 0a 20 20 70 54 6f 2d 3e  exEnter;.  pTo->
07c0: 78 4d 75 74 65 78 54 72 79 20 3d 20 70 46 72 6f  xMutexTry = pFro
07d0: 6d 2d 3e 78 4d 75 74 65 78 54 72 79 3b 0a 20 20  m->xMutexTry;.  
07e0: 70 54 6f 2d 3e 78 4d 75 74 65 78 4c 65 61 76 65  pTo->xMutexLeave
07f0: 20 3d 20 70 46 72 6f 6d 2d 3e 78 4d 75 74 65 78   = pFrom->xMutex
0800: 4c 65 61 76 65 3b 0a 20 20 70 54 6f 2d 3e 78 4d  Leave;.  pTo->xM
0810: 75 74 65 78 48 65 6c 64 20 3d 20 70 46 72 6f 6d  utexHeld = pFrom
0820: 2d 3e 78 4d 75 74 65 78 48 65 6c 64 3b 0a 20 20  ->xMutexHeld;.  
0830: 70 54 6f 2d 3e 78 4d 75 74 65 78 4e 6f 74 68 65  pTo->xMutexNothe
0840: 6c 64 20 3d 20 70 46 72 6f 6d 2d 3e 78 4d 75 74  ld = pFrom->xMut
0850: 65 78 4e 6f 74 68 65 6c 64 3b 0a 20 20 70 54 6f  exNotheld;.  pTo
0860: 2d 3e 78 4d 75 74 65 78 41 6c 6c 6f 63 20 3d 20  ->xMutexAlloc = 
0870: 70 46 72 6f 6d 2d 3e 78 4d 75 74 65 78 41 6c 6c  pFrom->xMutexAll
0880: 6f 63 3b 0a 7d 0a 0a 2f 2a 0a 2a 2a 20 49 6e 69  oc;.}../*.** Ini
0890: 74 69 61 6c 69 7a 65 20 74 68 65 20 6d 75 74 65  tialize the mute
08a0: 78 20 73 79 73 74 65 6d 2e 0a 2a 2f 0a 69 6e 74  x system..*/.int
08b0: 20 73 71 6c 69 74 65 33 4d 75 74 65 78 49 6e 69   sqlite3MutexIni
08c0: 74 28 76 6f 69 64 29 7b 20 0a 20 20 69 6e 74 20  t(void){ .  int 
08d0: 72 63 3b 0a 20 20 69 66 28 20 73 71 6c 69 74 65  rc;.  if( sqlite
08e0: 33 43 6f 6d 70 61 72 65 41 6e 64 53 77 61 70 28  3CompareAndSwap(
08f0: 28 76 6f 69 64 20 2a 20 76 6f 6c 61 74 69 6c 65  (void * volatile
0900: 20 2a 29 26 73 71 6c 69 74 65 33 47 6c 6f 62 61   *)&sqlite3Globa
0910: 6c 43 6f 6e 66 69 67 2e 70 4d 75 74 65 78 2c 0a  lConfig.pMutex,.
0920: 20 20 20 20 20 20 20 20 20 20 20 20 20 20 20 20                  
0930: 20 20 20 30 2c 20 26 73 71 6c 69 74 65 33 47 6c     0, &sqlite3Gl
0940: 6f 62 61 6c 43 6f 6e 66 69 67 2e 6d 75 74 65 78  obalConfig.mutex
0950: 29 3d 3d 30 20 7c 7c 20 6d 75 74 65 78 49 73 49  )==0 || mutexIsI
0960: 6e 76 61 6c 69 64 28 29 20 29 7b 0a 20 20 20 20  nvalid() ){.    
0970: 2f 2a 20 49 66 20 74 68 65 20 78 4d 75 74 65 78  /* If the xMutex
0980: 41 6c 6c 6f 63 20 6d 65 74 68 6f 64 20 68 61 73  Alloc method has
0990: 20 6e 6f 74 20 62 65 65 6e 20 73 65 74 2c 20 74   not been set, t
09a0: 68 65 6e 20 74 68 65 20 75 73 65 72 20 64 69 64  hen the user did
09b0: 20 6e 6f 74 0a 20 20 20 20 2a 2a 20 69 6e 73 74   not.    ** inst
09c0: 61 6c 6c 20 61 20 6d 75 74 65 78 20 69 6d 70 6c  all a mutex impl
09d0: 65 6d 65 6e 74 61 74 69 6f 6e 20 76 69 61 20 73  ementation via s
09e0: 71 6c 69 74 65 33 5f 63 6f 6e 66 69 67 28 29 20  qlite3_config() 
09f0: 70 72 69 6f 72 20 74 6f 20 0a 20 20 20 20 2a 2a  prior to .    **
0a00: 20 73 71 6c 69 74 65 33 5f 69 6e 69 74 69 61 6c   sqlite3_initial
0a10: 69 7a 65 28 29 20 62 65 69 6e 67 20 63 61 6c 6c  ize() being call
0a20: 65 64 2e 20 54 68 69 73 20 62 6c 6f 63 6b 20 63  ed. This block c
0a30: 6f 70 69 65 73 20 70 6f 69 6e 74 65 72 73 20 74  opies pointers t
0a40: 6f 0a 20 20 20 20 2a 2a 20 74 68 65 20 64 65 66  o.    ** the def
0a50: 61 75 6c 74 20 69 6d 70 6c 65 6d 65 6e 74 61 74  ault implementat
0a60: 69 6f 6e 20 69 6e 74 6f 20 74 68 65 20 73 71 6c  ion into the sql
0a70: 69 74 65 33 47 6c 6f 62 61 6c 43 6f 6e 66 69 67  ite3GlobalConfig
0a80: 20 73 74 72 75 63 74 75 72 65 2e 0a 20 20 20 20   structure..    
0a90: 2a 2f 0a 20 20 20 20 73 71 6c 69 74 65 33 5f 6d  */.    sqlite3_m
0aa0: 75 74 65 78 5f 6d 65 74 68 6f 64 73 20 63 6f 6e  utex_methods con
0ab0: 73 74 20 2a 70 46 72 6f 6d 3b 0a 0a 20 20 20 20  st *pFrom;..    
0ac0: 69 66 28 20 73 71 6c 69 74 65 33 47 6c 6f 62 61  if( sqlite3Globa
0ad0: 6c 43 6f 6e 66 69 67 2e 62 43 6f 72 65 4d 75 74  lConfig.bCoreMut
0ae0: 65 78 20 29 7b 0a 20 20 20 20 20 20 70 46 72 6f  ex ){.      pFro
0af0: 6d 20 3d 20 73 71 6c 69 74 65 33 44 65 66 61 75  m = sqlite3Defau
0b00: 6c 74 4d 75 74 65 78 28 29 3b 0a 20 20 20 20 7d  ltMutex();.    }
0b10: 65 6c 73 65 7b 0a 20 20 20 20 20 20 70 46 72 6f  else{.      pFro
0b20: 6d 20 3d 20 73 71 6c 69 74 65 33 4e 6f 6f 70 4d  m = sqlite3NoopM
0b30: 75 74 65 78 28 29 3b 0a 20 20 20 20 7d 0a 20 20  utex();.    }.  
0b40: 20 20 6d 75 74 65 78 43 6f 70 79 28 26 73 71 6c    mutexCopy(&sql
0b50: 69 74 65 33 47 6c 6f 62 61 6c 43 6f 6e 66 69 67  ite3GlobalConfig
0b60: 2e 6d 75 74 65 78 2c 20 70 46 72 6f 6d 29 3b 0a  .mutex, pFrom);.
0b70: 20 20 20 20 73 71 6c 69 74 65 33 4d 65 6d 6f 72      sqlite3Memor
0b80: 79 42 61 72 72 69 65 72 28 29 3b 0a 20 20 7d 0a  yBarrier();.  }.
0b90: 20 20 61 73 73 65 72 74 28 20 73 71 6c 69 74 65    assert( sqlite
0ba0: 33 47 6c 6f 62 61 6c 43 6f 6e 66 69 67 2e 6d 75  3GlobalConfig.mu
0bb0: 74 65 78 2e 78 4d 75 74 65 78 49 6e 69 74 20 29  tex.xMutexInit )
0bc0: 3b 0a 20 20 72 63 20 3d 20 73 71 6c 69 74 65 33  ;.  rc = sqlite3
0bd0: 47 6c 6f 62 61 6c 43 6f 6e 66 69 67 2e 6d 75 74  GlobalConfig.mut
0be0: 65 78 2e 78 4d 75 74 65 78 49 6e 69 74 28 29 3b  ex.xMutexInit();
0bf0: 0a 0a 23 69 66 64 65 66 20 53 51 4c 49 54 45 5f  ..#ifdef SQLITE_
0c00: 44 45 42 55 47 0a 20 20 47 4c 4f 42 41 4c 28 69  DEBUG.  GLOBAL(i
0c10: 6e 74 2c 20 6d 75 74 65 78 49 73 49 6e 69 74 29  nt, mutexIsInit)
0c20: 20 3d 20 31 3b 0a 23 65 6e 64 69 66 0a 0a 20 20   = 1;.#endif..  
0c30: 72 65 74 75 72 6e 20 72 63 3b 0a 7d 0a 0a 2f 2a  return rc;.}../*
0c40: 0a 2a 2a 20 53 68 75 74 64 6f 77 6e 20 74 68 65  .** Shutdown the
0c50: 20 6d 75 74 65 78 20 73 79 73 74 65 6d 2e 20 54   mutex system. T
0c60: 68 69 73 20 63 61 6c 6c 20 66 72 65 65 73 20 72  his call frees r
0c70: 65 73 6f 75 72 63 65 73 20 61 6c 6c 6f 63 61 74  esources allocat
0c80: 65 64 20 62 79 0a 2a 2a 20 73 71 6c 69 74 65 33  ed by.** sqlite3
0c90: 4d 75 74 65 78 49 6e 69 74 28 29 2e 0a 2a 2f 0a  MutexInit()..*/.
0ca0: 69 6e 74 20 73 71 6c 69 74 65 33 4d 75 74 65 78  int sqlite3Mutex
0cb0: 45 6e 64 28 76 6f 69 64 29 7b 0a 20 20 69 6e 74  End(void){.  int
0cc0: 20 72 63 20 3d 20 53 51 4c 49 54 45 5f 4f 4b 3b   rc = SQLITE_OK;
0cd0: 0a 20 20 69 66 28 20 73 71 6c 69 74 65 33 47 6c  .  if( sqlite3Gl
0ce0: 6f 62 61 6c 43 6f 6e 66 69 67 2e 6d 75 74 65 78  obalConfig.mutex
0cf0: 2e 78 4d 75 74 65 78 45 6e 64 20 29 7b 0a 20 20  .xMutexEnd ){.  
0d00: 20 20 72 63 20 3d 20 73 71 6c 69 74 65 33 47 6c    rc = sqlite3Gl
0d10: 6f 62 61 6c 43 6f 6e 66 69 67 2e 6d 75 74 65 78  obalConfig.mutex
0d20: 2e 78 4d 75 74 65 78 45 6e 64 28 29 3b 0a 20 20  .xMutexEnd();.  
0d30: 7d 0a 0a 23 69 66 64 65 66 20 53 51 4c 49 54 45  }..#ifdef SQLITE
0d40: 5f 44 45 42 55 47 0a 20 20 47 4c 4f 42 41 4c 28  _DEBUG.  GLOBAL(
0d50: 69 6e 74 2c 20 6d 75 74 65 78 49 73 49 6e 69 74  int, mutexIsInit
0d60: 29 20 3d 20 30 3b 0a 23 65 6e 64 69 66 0a 0a 20  ) = 0;.#endif.. 
0d70: 20 72 65 74 75 72 6e 20 72 63 3b 0a 7d 0a 0a 2f   return rc;.}../
0d80: 2a 0a 2a 2a 20 52 65 74 72 69 65 76 65 20 61 20  *.** Retrieve a 
0d90: 70 6f 69 6e 74 65 72 20 74 6f 20 61 20 73 74 61  pointer to a sta
0da0: 74 69 63 20 6d 75 74 65 78 20 6f 72 20 61 6c 6c  tic mutex or all
0db0: 6f 63 61 74 65 20 61 20 6e 65 77 20 64 79 6e 61  ocate a new dyna
0dc0: 6d 69 63 20 6f 6e 65 2e 0a 2a 2f 0a 73 71 6c 69  mic one..*/.sqli
0dd0: 74 65 33 5f 6d 75 74 65 78 20 2a 73 71 6c 69 74  te3_mutex *sqlit
0de0: 65 33 5f 6d 75 74 65 78 5f 61 6c 6c 6f 63 28 69  e3_mutex_alloc(i
0df0: 6e 74 20 69 64 29 7b 0a 23 69 66 6e 64 65 66 20  nt id){.#ifndef 
0e00: 53 51 4c 49 54 45 5f 4f 4d 49 54 5f 41 55 54 4f  SQLITE_OMIT_AUTO
0e10: 49 4e 49 54 0a 20 20 69 66 28 20 69 64 3c 3d 53  INIT.  if( id<=S
0e20: 51 4c 49 54 45 5f 4d 55 54 45 58 5f 52 45 43 55  QLITE_MUTEX_RECU
0e30: 52 53 49 56 45 20 26 26 20 73 71 6c 69 74 65 33  RSIVE && sqlite3
0e40: 5f 69 6e 69 74 69 61 6c 69 7a 65 28 29 20 29 20  _initialize() ) 
0e50: 72 65 74 75 72 6e 20 30 3b 0a 20 20 69 66 28 20  return 0;.  if( 
0e60: 69 64 3e 53 51 4c 49 54 45 5f 4d 55 54 45 58 5f  id>SQLITE_MUTEX_
0e70: 52 45 43 55 52 53 49 56 45 20 26 26 20 73 71 6c  RECURSIVE && sql
0e80: 69 74 65 33 4d 75 74 65 78 49 6e 69 74 28 29 20  ite3MutexInit() 
0e90: 29 20 72 65 74 75 72 6e 20 30 3b 0a 23 65 6e 64  ) return 0;.#end
0ea0: 69 66 0a 20 20 61 73 73 65 72 74 28 20 73 71 6c  if.  assert( sql
0eb0: 69 74 65 33 47 6c 6f 62 61 6c 43 6f 6e 66 69 67  ite3GlobalConfig
0ec0: 2e 6d 75 74 65 78 2e 78 4d 75 74 65 78 41 6c 6c  .mutex.xMutexAll
0ed0: 6f 63 20 29 3b 0a 20 20 72 65 74 75 72 6e 20 73  oc );.  return s
0ee0: 71 6c 69 74 65 33 47 6c 6f 62 61 6c 43 6f 6e 66  qlite3GlobalConf
0ef0: 69 67 2e 6d 75 74 65 78 2e 78 4d 75 74 65 78 41  ig.mutex.xMutexA
0f00: 6c 6c 6f 63 28 69 64 29 3b 0a 7d 0a 0a 73 71 6c  lloc(id);.}..sql
0f10: 69 74 65 33 5f 6d 75 74 65 78 20 2a 73 71 6c 69  ite3_mutex *sqli
0f20: 74 65 33 4d 75 74 65 78 41 6c 6c 6f 63 28 69 6e  te3MutexAlloc(in
0f30: 74 20 69 64 29 7b 0a 20 20 69 66 28 20 21 73 71  t id){.  if( !sq
0f40: 6c 69 74 65 33 47 6c 6f 62 61 6c 43 6f 6e 66 69  lite3GlobalConfi
0f50: 67 2e 62 43 6f 72 65 4d 75 74 65 78 20 29 7b 0a  g.bCoreMutex ){.
0f60: 20 20 20 20 72 65 74 75 72 6e 20 30 3b 0a 20 20      return 0;.  
0f70: 7d 0a 20 20 61 73 73 65 72 74 28 20 47 4c 4f 42  }.  assert( GLOB
0f80: 41 4c 28 69 6e 74 2c 20 6d 75 74 65 78 49 73 49  AL(int, mutexIsI
0f90: 6e 69 74 29 20 29 3b 0a 20 20 61 73 73 65 72 74  nit) );.  assert
0fa0: 28 20 73 71 6c 69 74 65 33 47 6c 6f 62 61 6c 43  ( sqlite3GlobalC
0fb0: 6f 6e 66 69 67 2e 6d 75 74 65 78 2e 78 4d 75 74  onfig.mutex.xMut
0fc0: 65 78 41 6c 6c 6f 63 20 29 3b 0a 20 20 72 65 74  exAlloc );.  ret
0fd0: 75 72 6e 20 73 71 6c 69 74 65 33 47 6c 6f 62 61  urn sqlite3Globa
0fe0: 6c 43 6f 6e 66 69 67 2e 6d 75 74 65 78 2e 78 4d  lConfig.mutex.xM
0ff0: 75 74 65 78 41 6c 6c 6f 63 28 69 64 29 3b 0a 7d  utexAlloc(id);.}
1000: 0a 0a 2f 2a 0a 2a 2a 20 46 72 65 65 20 61 20 64  ../*.** Free a d
1010: 79 6e 61 6d 69 63 20 6d 75 74 65 78 2e 0a 2a 2f  ynamic mutex..*/
1020: 0a 76 6f 69 64 20 73 71 6c 69 74 65 33 5f 6d 75  .void sqlite3_mu
1030: 74 65 78 5f 66 72 65 65 28 73 71 6c 69 74 65 33  tex_free(sqlite3
1040: 5f 6d 75 74 65 78 20 2a 70 29 7b 0a 20 20 69 66  _mutex *p){.  if
1050: 28 20 70 20 29 7b 0a 20 20 20 20 61 73 73 65 72  ( p ){.    asser
1060: 74 28 20 73 71 6c 69 74 65 33 47 6c 6f 62 61 6c  t( sqlite3Global
1070: 43 6f 6e 66 69 67 2e 6d 75 74 65 78 2e 78 4d 75  Config.mutex.xMu
1080: 74 65 78 46 72 65 65 20 29 3b 0a 20 20 20 20 73  texFree );.    s
1090: 71 6c 69 74 65 33 47 6c 6f 62 61 6c 43 6f 6e 66  qlite3GlobalConf
10a0: 69 67 2e 6d 75 74 65 78 2e 78 4d 75 74 65 78 46  ig.mutex.xMutexF
10b0: 72 65 65 28 70 29 3b 0a 20 20 7d 0a 7d 0a 0a 2f  ree(p);.  }.}../
10c0: 2a 0a 2a 2a 20 4f 62 74 61 69 6e 20 74 68 65 20  *.** Obtain the 
10d0: 6d 75 74 65 78 20 70 2e 20 49 66 20 73 6f 6d 65  mutex p. If some
10e0: 20 6f 74 68 65 72 20 74 68 72 65 61 64 20 61 6c   other thread al
10f0: 72 65 61 64 79 20 68 61 73 20 74 68 65 20 6d 75  ready has the mu
1100: 74 65 78 2c 20 62 6c 6f 63 6b 0a 2a 2a 20 75 6e  tex, block.** un
1110: 74 69 6c 20 69 74 20 63 61 6e 20 62 65 20 6f 62  til it can be ob
1120: 74 61 69 6e 65 64 2e 0a 2a 2f 0a 76 6f 69 64 20  tained..*/.void 
1130: 73 71 6c 69 74 65 33 5f 6d 75 74 65 78 5f 65 6e  sqlite3_mutex_en
1140: 74 65 72 28 73 71 6c 69 74 65 33 5f 6d 75 74 65  ter(sqlite3_mute
1150: 78 20 2a 70 29 7b 0a 20 20 69 66 28 20 70 20 29  x *p){.  if( p )
1160: 7b 0a 20 20 20 20 61 73 73 65 72 74 28 20 73 71  {.    assert( sq
1170: 6c 69 74 65 33 47 6c 6f 62 61 6c 43 6f 6e 66 69  lite3GlobalConfi
1180: 67 2e 6d 75 74 65 78 2e 78 4d 75 74 65 78 45 6e  g.mutex.xMutexEn
1190: 74 65 72 20 29 3b 0a 20 20 20 20 73 71 6c 69 74  ter );.    sqlit
11a0: 65 33 47 6c 6f 62 61 6c 43 6f 6e 66 69 67 2e 6d  e3GlobalConfig.m
11b0: 75 74 65 78 2e 78 4d 75 74 65 78 45 6e 74 65 72  utex.xMutexEnter
11c0: 28 70 29 3b 0a 20 20 7d 0a 7d 0a 0a 2f 2a 0a 2a  (p);.  }.}../*.*
11d0: 2a 20 4f 62 74 61 69 6e 20 74 68 65 20 6d 75 74  * Obtain the mut
11e0: 65 78 20 70 2e 20 49 66 20 73 75 63 63 65 73 73  ex p. If success
11f0: 66 75 6c 2c 20 72 65 74 75 72 6e 20 53 51 4c 49  ful, return SQLI
1200: 54 45 5f 4f 4b 2e 20 4f 74 68 65 72 77 69 73 65  TE_OK. Otherwise
1210: 2c 20 69 66 20 61 6e 6f 74 68 65 72 0a 2a 2a 20  , if another.** 
1220: 74 68 72 65 61 64 20 68 6f 6c 64 73 20 74 68 65  thread holds the
1230: 20 6d 75 74 65 78 20 61 6e 64 20 69 74 20 63 61   mutex and it ca
1240: 6e 6e 6f 74 20 62 65 20 6f 62 74 61 69 6e 65 64  nnot be obtained
1250: 2c 20 72 65 74 75 72 6e 20 53 51 4c 49 54 45 5f  , return SQLITE_
1260: 42 55 53 59 2e 0a 2a 2f 0a 69 6e 74 20 73 71 6c  BUSY..*/.int sql
1270: 69 74 65 33 5f 6d 75 74 65 78 5f 74 72 79 28 73  ite3_mutex_try(s
1280: 71 6c 69 74 65 33 5f 6d 75 74 65 78 20 2a 70 29  qlite3_mutex *p)
1290: 7b 0a 20 20 69 6e 74 20 72 63 20 3d 20 53 51 4c  {.  int rc = SQL
12a0: 49 54 45 5f 4f 4b 3b 0a 20 20 69 66 28 20 70 20  ITE_OK;.  if( p 
12b0: 29 7b 0a 20 20 20 20 61 73 73 65 72 74 28 20 73  ){.    assert( s
12c0: 71 6c 69 74 65 33 47 6c 6f 62 61 6c 43 6f 6e 66  qlite3GlobalConf
12d0: 69 67 2e 6d 75 74 65 78 2e 78 4d 75 74 65 78 54  ig.mutex.xMutexT
12e0: 72 79 20 29 3b 0a 20 20 20 20 72 65 74 75 72 6e  ry );.    return
12f0: 20 73 71 6c 69 74 65 33 47 6c 6f 62 61 6c 43 6f   sqlite3GlobalCo
1300: 6e 66 69 67 2e 6d 75 74 65 78 2e 78 4d 75 74 65  nfig.mutex.xMute
1310: 78 54 72 79 28 70 29 3b 0a 20 20 7d 0a 20 20 72  xTry(p);.  }.  r
1320: 65 74 75 72 6e 20 72 63 3b 0a 7d 0a 0a 2f 2a 0a  eturn rc;.}../*.
1330: 2a 2a 20 54 68 65 20 73 71 6c 69 74 65 33 5f 6d  ** The sqlite3_m
1340: 75 74 65 78 5f 6c 65 61 76 65 28 29 20 72 6f 75  utex_leave() rou
1350: 74 69 6e 65 20 65 78 69 74 73 20 61 20 6d 75 74  tine exits a mut
1360: 65 78 20 74 68 61 74 20 77 61 73 20 70 72 65 76  ex that was prev
1370: 69 6f 75 73 6c 79 0a 2a 2a 20 65 6e 74 65 72 65  iously.** entere
1380: 64 20 62 79 20 74 68 65 20 73 61 6d 65 20 74 68  d by the same th
1390: 72 65 61 64 2e 20 20 54 68 65 20 62 65 68 61 76  read.  The behav
13a0: 69 6f 72 20 69 73 20 75 6e 64 65 66 69 6e 65 64  ior is undefined
13b0: 20 69 66 20 74 68 65 20 6d 75 74 65 78 20 0a 2a   if the mutex .*
13c0: 2a 20 69 73 20 6e 6f 74 20 63 75 72 72 65 6e 74  * is not current
13d0: 6c 79 20 65 6e 74 65 72 65 64 2e 20 49 66 20 61  ly entered. If a
13e0: 20 4e 55 4c 4c 20 70 6f 69 6e 74 65 72 20 69 73   NULL pointer is
13f0: 20 70 61 73 73 65 64 20 61 73 20 61 6e 20 61 72   passed as an ar
1400: 67 75 6d 65 6e 74 0a 2a 2a 20 74 68 69 73 20 66  gument.** this f
1410: 75 6e 63 74 69 6f 6e 20 69 73 20 61 20 6e 6f 2d  unction is a no-
1420: 6f 70 2e 0a 2a 2f 0a 76 6f 69 64 20 73 71 6c 69  op..*/.void sqli
1430: 74 65 33 5f 6d 75 74 65 78 5f 6c 65 61 76 65 28  te3_mutex_leave(
1440: 73 71 6c 69 74 65 33 5f 6d 75 74 65 78 20 2a 70  sqlite3_mutex *p
1450: 29 7b 0a 20 20 69 66 28 20 70 20 29 7b 0a 20 20  ){.  if( p ){.  
1460: 20 20 61 73 73 65 72 74 28 20 73 71 6c 69 74 65    assert( sqlite
1470: 33 47 6c 6f 62 61 6c 43 6f 6e 66 69 67 2e 6d 75  3GlobalConfig.mu
1480: 74 65 78 2e 78 4d 75 74 65 78 4c 65 61 76 65 20  tex.xMutexLeave 
1490: 29 3b 0a 20 20 20 20 73 71 6c 69 74 65 33 47 6c  );.    sqlite3Gl
14a0: 6f 62 61 6c 43 6f 6e 66 69 67 2e 6d 75 74 65 78  obalConfig.mutex
14b0: 2e 78 4d 75 74 65 78 4c 65 61 76 65 28 70 29 3b  .xMutexLeave(p);
14c0: 0a 20 20 7d 0a 7d 0a 0a 23 69 66 6e 64 65 66 20  .  }.}..#ifndef 
14d0: 4e 44 45 42 55 47 0a 2f 2a 0a 2a 2a 20 54 68 65  NDEBUG./*.** The
14e0: 20 73 71 6c 69 74 65 33 5f 6d 75 74 65 78 5f 68   sqlite3_mutex_h
14f0: 65 6c 64 28 29 20 61 6e 64 20 73 71 6c 69 74 65  eld() and sqlite
1500: 33 5f 6d 75 74 65 78 5f 6e 6f 74 68 65 6c 64 28  3_mutex_notheld(
1510: 29 20 72 6f 75 74 69 6e 65 20 61 72 65 0a 2a 2a  ) routine are.**
1520: 20 69 6e 74 65 6e 64 65 64 20 66 6f 72 20 75 73   intended for us
1530: 65 20 69 6e 73 69 64 65 20 61 73 73 65 72 74 28  e inside assert(
1540: 29 20 73 74 61 74 65 6d 65 6e 74 73 2e 0a 2a 2f  ) statements..*/
1550: 0a 69 6e 74 20 73 71 6c 69 74 65 33 5f 6d 75 74  .int sqlite3_mut
1560: 65 78 5f 68 65 6c 64 28 73 71 6c 69 74 65 33 5f  ex_held(sqlite3_
1570: 6d 75 74 65 78 20 2a 70 29 7b 0a 20 20 61 73 73  mutex *p){.  ass
1580: 65 72 74 28 20 70 3d 3d 30 20 7c 7c 20 73 71 6c  ert( p==0 || sql
1590: 69 74 65 33 47 6c 6f 62 61 6c 43 6f 6e 66 69 67  ite3GlobalConfig
15a0: 2e 6d 75 74 65 78 2e 78 4d 75 74 65 78 48 65 6c  .mutex.xMutexHel
15b0: 64 20 29 3b 0a 20 20 72 65 74 75 72 6e 20 70 3d  d );.  return p=
15c0: 3d 30 20 7c 7c 20 73 71 6c 69 74 65 33 47 6c 6f  =0 || sqlite3Glo
15d0: 62 61 6c 43 6f 6e 66 69 67 2e 6d 75 74 65 78 2e  balConfig.mutex.
15e0: 78 4d 75 74 65 78 48 65 6c 64 28 70 29 3b 0a 7d  xMutexHeld(p);.}
15f0: 0a 69 6e 74 20 73 71 6c 69 74 65 33 5f 6d 75 74  .int sqlite3_mut
1600: 65 78 5f 6e 6f 74 68 65 6c 64 28 73 71 6c 69 74  ex_notheld(sqlit
1610: 65 33 5f 6d 75 74 65 78 20 2a 70 29 7b 0a 20 20  e3_mutex *p){.  
1620: 61 73 73 65 72 74 28 20 70 3d 3d 30 20 7c 7c 20  assert( p==0 || 
1630: 73 71 6c 69 74 65 33 47 6c 6f 62 61 6c 43 6f 6e  sqlite3GlobalCon
1640: 66 69 67 2e 6d 75 74 65 78 2e 78 4d 75 74 65 78  fig.mutex.xMutex
1650: 4e 6f 74 68 65 6c 64 20 29 3b 0a 20 20 72 65 74  Notheld );.  ret
1660: 75 72 6e 20 70 3d 3d 30 20 7c 7c 20 73 71 6c 69  urn p==0 || sqli
1670: 74 65 33 47 6c 6f 62 61 6c 43 6f 6e 66 69 67 2e  te3GlobalConfig.
1680: 6d 75 74 65 78 2e 78 4d 75 74 65 78 4e 6f 74 68  mutex.xMutexNoth
1690: 65 6c 64 28 70 29 3b 0a 7d 0a 23 65 6e 64 69 66  eld(p);.}.#endif
16a0: 0a 0a 23 65 6e 64 69 66 20 2f 2a 20 21 64 65 66  ..#endif /* !def
16b0: 69 6e 65 64 28 53 51 4c 49 54 45 5f 4d 55 54 45  ined(SQLITE_MUTE
16c0: 58 5f 4f 4d 49 54 29 20 2a 2f 0a                 X_OMIT) */.