/ Hex Artifact Content
Login

Artifact 1953080d14098cd45e5bde88941567688efb72b1:


0000: 2f 2a 0a 2a 2a 20 32 30 30 31 20 53 65 70 74 65  /*.** 2001 Septe
0010: 6d 62 65 72 20 31 36 0a 2a 2a 0a 2a 2a 20 54 68  mber 16.**.** Th
0020: 65 20 61 75 74 68 6f 72 20 64 69 73 63 6c 61 69  e author disclai
0030: 6d 73 20 63 6f 70 79 72 69 67 68 74 20 74 6f 20  ms copyright to 
0040: 74 68 69 73 20 73 6f 75 72 63 65 20 63 6f 64 65  this source code
0050: 2e 20 20 49 6e 20 70 6c 61 63 65 20 6f 66 0a 2a  .  In place of.*
0060: 2a 20 61 20 6c 65 67 61 6c 20 6e 6f 74 69 63 65  * a legal notice
0070: 2c 20 68 65 72 65 20 69 73 20 61 20 62 6c 65 73  , here is a bles
0080: 73 69 6e 67 3a 0a 2a 2a 0a 2a 2a 20 20 20 20 4d  sing:.**.**    M
0090: 61 79 20 79 6f 75 20 64 6f 20 67 6f 6f 64 20 61  ay you do good a
00a0: 6e 64 20 6e 6f 74 20 65 76 69 6c 2e 0a 2a 2a 20  nd not evil..** 
00b0: 20 20 20 4d 61 79 20 79 6f 75 20 66 69 6e 64 20     May you find 
00c0: 66 6f 72 67 69 76 65 6e 65 73 73 20 66 6f 72 20  forgiveness for 
00d0: 79 6f 75 72 73 65 6c 66 20 61 6e 64 20 66 6f 72  yourself and for
00e0: 67 69 76 65 20 6f 74 68 65 72 73 2e 0a 2a 2a 20  give others..** 
00f0: 20 20 20 4d 61 79 20 79 6f 75 20 73 68 61 72 65     May you share
0100: 20 66 72 65 65 6c 79 2c 20 6e 65 76 65 72 20 74   freely, never t
0110: 61 6b 69 6e 67 20 6d 6f 72 65 20 74 68 61 6e 20  aking more than 
0120: 79 6f 75 20 67 69 76 65 2e 0a 2a 2a 0a 2a 2a 2a  you give..**.***
0130: 2a 2a 2a 2a 2a 2a 2a 2a 2a 2a 2a 2a 2a 2a 2a 2a  ****************
0140: 2a 2a 2a 2a 2a 2a 2a 2a 2a 2a 2a 2a 2a 2a 2a 2a  ****************
0150: 2a 2a 2a 2a 2a 2a 2a 2a 2a 2a 2a 2a 2a 2a 2a 2a  ****************
0160: 2a 2a 2a 2a 2a 2a 2a 2a 2a 2a 2a 2a 2a 2a 2a 2a  ****************
0170: 2a 2a 2a 2a 2a 2a 2a 2a 2a 2a 2a 0a 2a 2a 0a 2a  ***********.**.*
0180: 2a 20 54 68 69 73 20 66 69 6c 65 20 63 6f 6e 74  * This file cont
0190: 61 69 6e 73 20 63 6f 64 65 20 74 68 61 74 20 69  ains code that i
01a0: 73 20 73 70 65 63 69 66 69 63 20 74 6f 20 70 61  s specific to pa
01b0: 72 74 69 63 75 6c 61 72 20 6f 70 65 72 61 74 69  rticular operati
01c0: 6e 67 0a 2a 2a 20 73 79 73 74 65 6d 73 2e 20 20  ng.** systems.  
01d0: 54 68 65 20 70 75 72 70 6f 73 65 20 6f 66 20 74  The purpose of t
01e0: 68 69 73 20 66 69 6c 65 20 69 73 20 74 6f 20 70  his file is to p
01f0: 72 6f 76 69 64 65 20 61 20 75 6e 69 66 6f 72 6d  rovide a uniform
0200: 20 61 62 73 74 72 61 63 74 69 6f 6e 0a 2a 2a 20   abstraction.** 
0210: 6f 6e 20 77 68 69 63 68 20 74 68 65 20 72 65 73  on which the res
0220: 74 20 6f 66 20 53 51 4c 69 74 65 20 63 61 6e 20  t of SQLite can 
0230: 6f 70 65 72 61 74 65 2e 0a 2a 2f 0a 23 69 6e 63  operate..*/.#inc
0240: 6c 75 64 65 20 22 73 71 6c 69 74 65 49 6e 74 2e  lude "sqliteInt.
0250: 68 22 0a 23 69 6e 63 6c 75 64 65 20 22 6f 73 2e  h".#include "os.
0260: 68 22 0a 0a 23 69 66 6e 64 65 66 20 4f 53 5f 55  h"..#ifndef OS_U
0270: 4e 49 58 0a 23 20 69 66 6e 64 65 66 20 4f 53 5f  NIX.# ifndef OS_
0280: 57 49 4e 0a 23 20 20 69 66 20 64 65 66 69 6e 65  WIN.#  if define
0290: 64 28 5f 57 49 4e 33 32 29 20 7c 7c 20 64 65 66  d(_WIN32) || def
02a0: 69 6e 65 64 28 57 49 4e 33 32 29 20 7c 7c 20 64  ined(WIN32) || d
02b0: 65 66 69 6e 65 64 28 5f 5f 43 59 47 57 49 4e 5f  efined(__CYGWIN_
02c0: 5f 29 20 7c 7c 20 64 65 66 69 6e 65 64 28 5f 5f  _) || defined(__
02d0: 4d 49 4e 47 57 33 32 5f 5f 29 20 7c 7c 20 64 65  MINGW32__) || de
02e0: 66 69 6e 65 64 28 5f 5f 42 4f 52 4c 41 4e 44 43  fined(__BORLANDC
02f0: 5f 5f 29 0a 23 20 20 20 20 64 65 66 69 6e 65 20  __).#    define 
0300: 4f 53 5f 57 49 4e 20 31 0a 23 20 20 20 20 64 65  OS_WIN 1.#    de
0310: 66 69 6e 65 20 4f 53 5f 55 4e 49 58 20 30 0a 23  fine OS_UNIX 0.#
0320: 20 20 65 6c 73 65 0a 23 20 20 20 20 64 65 66 69    else.#    defi
0330: 6e 65 20 4f 53 5f 57 49 4e 20 30 0a 23 20 20 20  ne OS_WIN 0.#   
0340: 20 64 65 66 69 6e 65 20 4f 53 5f 55 4e 49 58 20   define OS_UNIX 
0350: 31 0a 23 20 20 65 6e 64 69 66 0a 23 20 65 6c 73  1.#  endif.# els
0360: 65 0a 23 20 20 64 65 66 69 6e 65 20 4f 53 5f 55  e.#  define OS_U
0370: 4e 49 58 20 30 0a 23 20 65 6e 64 69 66 0a 23 65  NIX 0.# endif.#e
0380: 6e 64 69 66 0a 23 69 66 6e 64 65 66 20 4f 53 5f  ndif.#ifndef OS_
0390: 57 49 4e 0a 23 20 64 65 66 69 6e 65 20 4f 53 5f  WIN.# define OS_
03a0: 57 49 4e 20 30 0a 23 65 6e 64 69 66 0a 23 69 66  WIN 0.#endif.#if
03b0: 20 4f 53 5f 55 4e 49 58 0a 23 20 69 6e 63 6c 75   OS_UNIX.# inclu
03c0: 64 65 20 3c 75 6e 69 73 74 64 2e 68 3e 0a 23 20  de <unistd.h>.# 
03d0: 69 6e 63 6c 75 64 65 20 3c 66 63 6e 74 6c 2e 68  include <fcntl.h
03e0: 3e 0a 23 20 69 6e 63 6c 75 64 65 20 3c 73 79 73  >.# include <sys
03f0: 2f 73 74 61 74 2e 68 3e 0a 23 20 69 6e 63 6c 75  /stat.h>.# inclu
0400: 64 65 20 3c 74 69 6d 65 2e 68 3e 0a 23 65 6e 64  de <time.h>.#end
0410: 69 66 0a 23 69 66 20 4f 53 5f 57 49 4e 0a 23 20  if.#if OS_WIN.# 
0420: 69 6e 63 6c 75 64 65 20 3c 77 69 6e 62 61 73 65  include <winbase
0430: 2e 68 3e 0a 23 65 6e 64 69 66 0a 0a 0a 23 69 66  .h>.#endif...#if
0440: 20 4f 53 5f 55 4e 49 58 0a 2f 2a 0a 2a 2a 20 48   OS_UNIX./*.** H
0450: 65 72 65 20 69 73 20 74 68 65 20 64 69 72 74 20  ere is the dirt 
0460: 6f 6e 20 50 4f 53 49 58 20 61 64 76 69 73 6f 72  on POSIX advisor
0470: 79 20 6c 6f 63 6b 73 3a 20 20 41 4e 53 49 20 53  y locks:  ANSI S
0480: 54 44 20 31 30 30 33 2e 31 20 28 31 39 39 36 29  TD 1003.1 (1996)
0490: 0a 2a 2a 20 73 65 63 74 69 6f 6e 20 36 2e 35 2e  .** section 6.5.
04a0: 32 2e 32 20 6c 69 6e 65 73 20 34 38 33 20 74 68  2.2 lines 483 th
04b0: 72 6f 75 67 68 20 34 39 30 20 73 70 65 63 69 66  rough 490 specif
04c0: 79 20 74 68 61 74 20 77 68 65 6e 20 61 20 70 72  y that when a pr
04d0: 6f 63 65 73 73 0a 2a 2a 20 73 65 74 73 20 6f 72  ocess.** sets or
04e0: 20 63 6c 65 61 72 73 20 61 20 6c 6f 63 6b 2c 20   clears a lock, 
04f0: 74 68 61 74 20 6f 70 65 72 61 74 69 6f 6e 20 6f  that operation o
0500: 76 65 72 72 69 64 65 73 20 61 6e 79 20 70 72 69  verrides any pri
0510: 6f 72 20 6c 6f 63 6b 73 20 73 65 74 0a 2a 2a 20  or locks set.** 
0520: 62 79 20 74 68 65 20 73 61 6d 65 20 70 72 6f 63  by the same proc
0530: 65 73 73 2e 20 20 49 74 20 64 6f 65 73 20 6e 6f  ess.  It does no
0540: 74 20 65 78 70 6c 69 63 69 74 6c 79 20 73 61 79  t explicitly say
0550: 20 73 6f 2c 20 62 75 74 20 74 68 69 73 20 69 6d   so, but this im
0560: 70 6c 69 65 73 0a 2a 2a 20 74 68 61 74 20 69 74  plies.** that it
0570: 20 6f 76 65 72 72 69 64 65 73 20 6c 6f 63 6b 73   overrides locks
0580: 20 73 65 74 20 62 79 20 74 68 65 20 73 61 6d 65   set by the same
0590: 20 70 72 6f 63 65 73 73 20 75 73 69 6e 67 20 61   process using a
05a0: 20 64 69 66 66 65 72 65 6e 74 0a 2a 2a 20 66 69   different.** fi
05b0: 6c 65 20 64 65 73 63 72 69 70 74 6f 72 2e 20 20  le descriptor.  
05c0: 43 6f 6e 73 69 64 65 72 20 74 68 69 73 20 74 65  Consider this te
05d0: 73 74 20 63 61 73 65 3a 0a 2a 2a 0a 2a 2a 20 20  st case:.**.**  
05e0: 20 20 20 20 20 69 6e 74 20 66 64 31 20 3d 20 6f       int fd1 = o
05f0: 70 65 6e 28 22 2e 2f 66 69 6c 65 31 22 2c 20 4f  pen("./file1", O
0600: 5f 52 44 57 52 7c 4f 5f 43 52 45 41 54 2c 20 30  _RDWR|O_CREAT, 0
0610: 36 34 34 29 3b 0a 2a 2a 20 20 20 20 20 20 20 69  644);.**       i
0620: 6e 74 20 66 64 32 20 3d 20 6f 70 65 6e 28 22 2e  nt fd2 = open(".
0630: 2f 66 69 6c 65 32 22 2c 20 4f 5f 52 44 57 52 7c  /file2", O_RDWR|
0640: 4f 5f 43 52 45 41 54 2c 20 30 36 34 34 29 3b 0a  O_CREAT, 0644);.
0650: 2a 2a 0a 2a 2a 20 53 75 70 70 6f 73 65 20 2e 2f  **.** Suppose ./
0660: 66 69 6c 65 31 20 61 6e 64 20 2e 2f 66 69 6c 65  file1 and ./file
0670: 32 20 61 72 65 20 72 65 61 6c 6c 79 20 62 65 20  2 are really be 
0680: 74 68 65 20 73 61 6d 65 20 66 69 6c 65 20 28 62  the same file (b
0690: 65 63 61 75 73 65 0a 2a 2a 20 6f 6e 65 20 69 73  ecause.** one is
06a0: 20 61 20 68 61 72 64 20 6f 72 20 73 79 6d 62 6f   a hard or symbo
06b0: 6c 69 63 20 6c 69 6e 6b 20 74 6f 20 74 68 65 20  lic link to the 
06c0: 6f 74 68 65 72 29 20 74 68 65 6e 20 69 66 20 79  other) then if y
06d0: 6f 75 20 73 65 74 0a 2a 2a 20 61 6e 20 65 78 63  ou set.** an exc
06e0: 6c 75 73 69 76 65 20 6c 6f 63 6b 20 6f 6e 20 66  lusive lock on f
06f0: 64 31 2c 20 74 68 65 6e 20 74 72 79 20 74 6f 20  d1, then try to 
0700: 67 65 74 20 61 6e 20 65 78 63 6c 75 73 69 76 65  get an exclusive
0710: 20 6c 6f 63 6b 0a 2a 2a 20 6f 6e 20 66 64 32 2c   lock.** on fd2,
0720: 20 69 74 20 77 6f 72 6b 73 2e 20 20 49 20 77 6f   it works.  I wo
0730: 75 6c 64 20 68 61 76 65 20 65 78 70 65 63 74 65  uld have expecte
0740: 64 20 74 68 65 20 73 65 63 6f 6e 64 20 6c 6f 63  d the second loc
0750: 6b 20 74 6f 0a 2a 2a 20 66 61 69 6c 20 73 69 6e  k to.** fail sin
0760: 63 65 20 74 68 65 72 65 20 77 61 73 20 61 6c 72  ce there was alr
0770: 65 61 64 79 20 61 20 6c 6f 63 6b 20 6f 6e 20 74  eady a lock on t
0780: 68 65 20 66 69 6c 65 20 64 75 65 20 74 6f 20 66  he file due to f
0790: 64 31 2e 0a 2a 2a 20 42 75 74 20 6e 6f 74 20 73  d1..** But not s
07a0: 6f 2e 20 20 53 69 6e 63 65 20 62 6f 74 68 20 6c  o.  Since both l
07b0: 6f 63 6b 73 20 63 61 6d 65 20 66 72 6f 6d 20 74  ocks came from t
07c0: 68 65 20 73 61 6d 65 20 70 72 6f 63 65 73 73 2c  he same process,
07d0: 20 74 68 65 0a 2a 2a 20 73 65 63 6f 6e 64 20 6f   the.** second o
07e0: 76 65 72 72 69 64 65 73 20 74 68 65 20 66 69 72  verrides the fir
07f0: 73 74 2c 20 65 76 65 6e 20 74 68 6f 75 67 68 20  st, even though 
0800: 74 68 65 79 20 77 65 72 65 20 6f 6e 20 64 69 66  they were on dif
0810: 66 65 72 65 6e 74 0a 2a 2a 20 66 69 6c 65 20 64  ferent.** file d
0820: 65 73 63 72 69 70 74 6f 72 73 20 6f 70 65 6e 65  escriptors opene
0830: 64 20 6f 6e 20 64 69 66 66 65 72 65 6e 74 20 66  d on different f
0840: 69 6c 65 20 6e 61 6d 65 73 2e 0a 2a 2a 0a 2a 2a  ile names..**.**
0850: 20 42 75 6d 6d 65 72 2e 20 20 49 66 20 79 6f 75   Bummer.  If you
0860: 20 61 73 6b 20 6d 65 2c 20 74 68 69 73 20 69 73   ask me, this is
0870: 20 62 72 6f 6b 65 6e 2e 20 20 42 61 64 6c 79 20   broken.  Badly 
0880: 62 72 6f 6b 65 6e 2e 20 20 49 74 20 6d 65 61 6e  broken.  It mean
0890: 73 0a 2a 2a 20 74 68 61 74 20 77 65 20 63 61 6e  s.** that we can
08a0: 6e 6f 74 20 75 73 65 20 50 4f 53 49 58 20 6c 6f  not use POSIX lo
08b0: 63 6b 73 20 74 6f 20 73 79 6e 63 68 72 6f 6e 69  cks to synchroni
08c0: 7a 65 20 66 69 6c 65 20 61 63 63 65 73 73 20 61  ze file access a
08d0: 6d 6f 6e 67 0a 2a 2a 20 63 6f 6d 70 65 74 69 6e  mong.** competin
08e0: 67 20 74 68 72 65 61 64 73 20 6f 66 20 74 68 65  g threads of the
08f0: 20 73 61 6d 65 20 70 72 6f 63 65 73 73 2e 20 20   same process.  
0900: 50 4f 53 49 58 20 6c 6f 63 6b 73 20 77 69 6c 6c  POSIX locks will
0910: 20 77 6f 72 6b 20 66 69 6e 65 0a 2a 2a 20 74 6f   work fine.** to
0920: 20 73 79 6e 63 68 72 6f 6e 69 7a 65 20 61 63 63   synchronize acc
0930: 65 73 73 20 66 6f 72 20 74 68 72 65 61 64 73 20  ess for threads 
0940: 69 6e 20 73 65 70 61 72 61 74 65 20 70 72 6f 63  in separate proc
0950: 65 73 73 65 73 2c 20 62 75 74 20 6e 6f 74 0a 2a  esses, but not.*
0960: 2a 20 74 68 72 65 61 64 73 20 77 69 74 68 69 6e  * threads within
0970: 20 74 68 65 20 73 61 6d 65 20 70 72 6f 63 65 73   the same proces
0980: 73 2e 0a 2a 2a 0a 2a 2a 20 54 6f 20 77 6f 72 6b  s..**.** To work
0990: 20 61 72 6f 75 6e 64 20 74 68 65 20 70 72 6f 62   around the prob
09a0: 6c 65 6d 2c 20 53 51 4c 69 74 65 20 68 61 73 20  lem, SQLite has 
09b0: 74 6f 20 6d 61 6e 61 67 65 20 66 69 6c 65 20 6c  to manage file l
09c0: 6f 63 6b 73 20 69 6e 74 65 72 6e 61 6c 6c 79 0a  ocks internally.
09d0: 2a 2a 20 6f 6e 20 69 74 73 20 6f 77 6e 2e 20 20  ** on its own.  
09e0: 57 68 65 6e 65 76 65 72 20 61 20 6e 65 77 20 64  Whenever a new d
09f0: 61 74 61 62 61 73 65 20 69 73 20 6f 70 65 6e 65  atabase is opene
0a00: 64 2c 20 77 65 20 68 61 76 65 20 74 6f 20 66 69  d, we have to fi
0a10: 6e 64 20 74 68 65 0a 2a 2a 20 73 70 65 63 69 66  nd the.** specif
0a20: 69 63 20 69 6e 6f 64 65 20 6f 66 20 74 68 65 20  ic inode of the 
0a30: 64 61 74 61 62 61 73 65 20 66 69 6c 65 20 28 74  database file (t
0a40: 68 65 20 69 6e 6f 64 65 20 69 73 20 64 65 74 65  he inode is dete
0a50: 72 6d 69 6e 65 64 20 62 79 20 74 68 65 0a 2a 2a  rmined by the.**
0a60: 20 73 74 5f 64 65 76 20 61 6e 64 20 73 74 5f 69   st_dev and st_i
0a70: 6e 6f 20 66 69 65 6c 64 73 20 6f 66 20 74 68 65  no fields of the
0a80: 20 73 74 61 74 20 73 74 72 75 63 74 75 72 65 20   stat structure 
0a90: 74 68 61 74 20 66 73 74 61 74 28 29 20 66 69 6c  that fstat() fil
0aa0: 6c 73 20 69 6e 29 0a 2a 2a 20 61 6e 64 20 63 68  ls in).** and ch
0ab0: 65 63 6b 20 66 6f 72 20 6c 6f 63 6b 73 20 61 6c  eck for locks al
0ac0: 72 65 61 64 79 20 65 78 69 73 74 69 6e 67 20 6f  ready existing o
0ad0: 6e 20 74 68 61 74 20 69 6e 6f 64 65 2e 20 20 57  n that inode.  W
0ae0: 68 65 6e 20 6c 6f 63 6b 73 20 61 72 65 0a 2a 2a  hen locks are.**
0af0: 20 63 72 65 61 74 65 64 20 6f 72 20 72 65 6d 6f   created or remo
0b00: 76 65 64 2c 20 77 65 20 68 61 76 65 20 74 6f 20  ved, we have to 
0b10: 6c 6f 6f 6b 20 61 74 20 6f 75 72 20 6f 77 6e 20  look at our own 
0b20: 69 6e 74 65 72 6e 61 6c 20 72 65 63 6f 72 64 20  internal record 
0b30: 6f 66 20 74 68 65 0a 2a 2a 20 6c 6f 63 6b 73 20  of the.** locks 
0b40: 74 6f 20 73 65 65 20 69 66 20 61 6e 6f 74 68 65  to see if anothe
0b50: 72 20 74 68 72 65 61 64 20 68 61 73 20 70 72 65  r thread has pre
0b60: 76 69 6f 75 73 6c 79 20 73 65 74 20 61 20 6c 6f  viously set a lo
0b70: 63 6b 20 6f 6e 20 74 68 61 74 20 73 61 6d 65 0a  ck on that same.
0b80: 2a 2a 20 69 6e 6f 64 65 2e 0a 2a 2a 0a 2a 2a 20  ** inode..**.** 
0b90: 54 68 65 20 4f 73 46 69 6c 65 20 73 74 72 75 63  The OsFile struc
0ba0: 74 75 72 65 20 66 6f 72 20 50 4f 53 49 58 20 69  ture for POSIX i
0bb0: 73 20 6e 6f 20 6c 6f 6e 67 65 72 20 6a 75 73 74  s no longer just
0bc0: 20 61 6e 20 69 6e 74 65 67 65 72 20 66 69 6c 65   an integer file
0bd0: 0a 2a 2a 20 64 65 73 63 72 69 70 74 6f 72 2e 20  .** descriptor. 
0be0: 20 49 74 20 69 73 20 6e 6f 77 20 61 20 73 74 72   It is now a str
0bf0: 75 63 74 75 72 65 20 74 68 61 74 20 68 6f 6c 64  ucture that hold
0c00: 73 20 74 68 65 20 69 6e 74 65 67 65 72 20 66 69  s the integer fi
0c10: 6c 65 0a 2a 2a 20 64 65 73 63 72 69 70 74 6f 72  le.** descriptor
0c20: 20 61 6e 64 20 61 20 70 6f 69 6e 74 65 72 20 74   and a pointer t
0c30: 6f 20 61 20 73 74 72 75 63 74 75 72 65 20 74 68  o a structure th
0c40: 61 74 20 64 65 73 63 72 69 62 65 73 20 74 68 65  at describes the
0c50: 20 69 6e 74 65 72 6e 61 6c 0a 2a 2a 20 6c 6f 63   internal.** loc
0c60: 6b 73 20 6f 6e 20 74 68 65 20 63 6f 72 72 65 73  ks on the corres
0c70: 70 6f 6e 64 69 6e 67 20 69 6e 6f 64 65 2e 20 20  ponding inode.  
0c80: 54 68 65 72 65 20 69 73 20 6f 6e 65 20 6c 6f 63  There is one loc
0c90: 6b 69 6e 67 20 73 74 72 75 63 74 75 72 65 0a 2a  king structure.*
0ca0: 2a 20 70 65 72 20 69 6e 6f 64 65 2c 20 73 6f 20  * per inode, so 
0cb0: 69 66 20 74 68 65 20 73 61 6d 65 20 69 6e 6f 64  if the same inod
0cc0: 65 20 69 73 20 6f 70 65 6e 65 64 20 74 77 69 63  e is opened twic
0cd0: 65 2c 20 62 6f 74 68 20 4f 73 46 69 6c 65 20 73  e, both OsFile s
0ce0: 74 72 75 63 74 75 72 65 73 0a 2a 2a 20 70 6f 69  tructures.** poi
0cf0: 6e 74 20 74 6f 20 74 68 65 20 73 61 6d 65 20 6c  nt to the same l
0d00: 6f 63 6b 69 6e 67 20 73 74 72 75 63 74 75 72 65  ocking structure
0d10: 2e 20 20 54 68 65 20 6c 6f 63 6b 69 6e 67 20 73  .  The locking s
0d20: 74 72 75 63 74 75 72 65 20 6b 65 65 70 73 0a 2a  tructure keeps.*
0d30: 2a 20 61 20 72 65 66 65 72 65 6e 63 65 20 63 6f  * a reference co
0d40: 75 6e 74 20 28 73 6f 20 77 65 20 77 69 6c 6c 20  unt (so we will 
0d50: 6b 6e 6f 77 20 77 68 65 6e 20 74 6f 20 64 65 6c  know when to del
0d60: 65 74 65 20 69 74 29 20 61 6e 64 20 61 20 22 63  ete it) and a "c
0d70: 6e 74 22 0a 2a 2a 20 66 69 65 6c 64 20 74 68 61  nt".** field tha
0d80: 74 20 74 65 6c 6c 73 20 75 73 20 69 74 73 20 69  t tells us its i
0d90: 6e 74 65 72 6e 61 6c 20 6c 6f 63 6b 20 73 74 61  nternal lock sta
0da0: 74 75 73 2e 20 20 63 6e 74 3d 3d 30 20 6d 65 61  tus.  cnt==0 mea
0db0: 6e 73 20 74 68 65 0a 2a 2a 20 66 69 6c 65 20 69  ns the.** file i
0dc0: 73 20 75 6e 6c 6f 63 6b 65 64 2e 20 20 63 6e 74  s unlocked.  cnt
0dd0: 3d 3d 2d 31 20 6d 65 61 6e 73 20 74 68 65 20 66  ==-1 means the f
0de0: 69 6c 65 20 68 61 73 20 61 6e 20 65 78 63 6c 75  ile has an exclu
0df0: 73 69 76 65 20 6c 6f 63 6b 2e 0a 2a 2a 20 63 6e  sive lock..** cn
0e00: 74 3e 30 20 6d 65 61 6e 73 20 74 68 65 72 65 20  t>0 means there 
0e10: 61 72 65 20 63 6e 74 20 73 68 61 72 65 64 20 6c  are cnt shared l
0e20: 6f 63 6b 73 20 6f 6e 20 74 68 65 20 66 69 6c 65  ocks on the file
0e30: 2e 0a 2a 2a 0a 2a 2a 20 41 6e 79 20 61 74 74 65  ..**.** Any atte
0e40: 6d 70 74 20 74 6f 20 6c 6f 63 6b 20 6f 72 20 75  mpt to lock or u
0e50: 6e 6c 6f 63 6b 20 61 20 66 69 6c 65 20 66 69 72  nlock a file fir
0e60: 73 74 20 63 68 65 63 6b 73 20 74 68 65 20 6c 6f  st checks the lo
0e70: 63 6b 69 6e 67 0a 2a 2a 20 73 74 72 75 63 74 75  cking.** structu
0e80: 72 65 2e 20 20 54 68 65 20 66 63 6e 74 6c 28 29  re.  The fcntl()
0e90: 20 73 79 73 74 65 6d 20 63 61 6c 6c 20 69 73 20   system call is 
0ea0: 6f 6e 6c 79 20 69 6e 76 6f 6b 65 64 20 74 6f 20  only invoked to 
0eb0: 73 65 74 20 61 20 0a 2a 2a 20 50 4f 53 49 58 20  set a .** POSIX 
0ec0: 6c 6f 63 6b 20 69 66 20 74 68 65 20 69 6e 74 65  lock if the inte
0ed0: 72 6e 61 6c 20 6c 6f 63 6b 20 73 74 72 75 63 74  rnal lock struct
0ee0: 75 72 65 20 74 72 61 6e 73 69 74 69 6f 6e 73 20  ure transitions 
0ef0: 62 65 74 77 65 65 6e 0a 2a 2a 20 61 20 6c 6f 63  between.** a loc
0f00: 6b 65 64 20 61 6e 64 20 61 6e 20 75 6e 6c 6f 63  ked and an unloc
0f10: 6b 65 64 20 73 74 61 74 65 2e 0a 2a 2f 0a 0a 2f  ked state..*/../
0f20: 2a 0a 2a 2a 20 41 6e 20 69 6e 73 74 61 6e 63 65  *.** An instance
0f30: 20 6f 66 20 74 68 65 20 66 6f 6c 6c 6f 77 69 6e   of the followin
0f40: 67 20 73 74 72 75 63 74 75 72 65 20 73 65 72 76  g structure serv
0f50: 65 73 20 61 73 20 74 68 65 20 6b 65 79 20 75 73  es as the key us
0f60: 65 64 0a 2a 2a 20 74 6f 20 6c 6f 63 61 74 65 20  ed.** to locate 
0f70: 61 20 70 61 72 74 69 63 75 6c 61 72 20 6c 6f 63  a particular loc
0f80: 6b 49 6e 66 6f 20 73 74 72 75 63 74 75 72 65 20  kInfo structure 
0f90: 67 69 76 65 6e 20 69 74 73 20 69 6e 6f 64 65 2e  given its inode.
0fa0: 20 0a 2a 2f 0a 73 74 72 75 63 74 20 69 6e 6f 64   .*/.struct inod
0fb0: 65 4b 65 79 20 7b 0a 20 20 64 65 76 5f 74 20 64  eKey {.  dev_t d
0fc0: 65 76 3b 20 20 20 2f 2a 20 44 65 76 69 63 65 20  ev;   /* Device 
0fd0: 6e 75 6d 62 65 72 20 2a 2f 0a 20 20 69 6e 6f 5f  number */.  ino_
0fe0: 74 20 69 6e 6f 3b 20 20 20 2f 2a 20 49 6e 6f 64  t ino;   /* Inod
0ff0: 65 20 6e 75 6d 62 65 72 20 2a 2f 0a 7d 3b 0a 0a  e number */.};..
1000: 2f 2a 0a 2a 2a 20 41 6e 20 69 6e 73 74 61 6e 63  /*.** An instanc
1010: 65 20 6f 66 20 74 68 65 20 66 6f 6c 6c 6f 77 69  e of the followi
1020: 6e 67 20 73 74 72 75 63 74 75 72 65 20 69 73 20  ng structure is 
1030: 61 6c 6c 6f 63 61 74 65 64 20 66 6f 72 20 65 61  allocated for ea
1040: 63 68 20 69 6e 6f 64 65 2e 0a 2a 2a 20 41 20 73  ch inode..** A s
1050: 69 6e 67 6c 65 20 69 6e 6f 64 65 20 63 61 6e 20  ingle inode can 
1060: 68 61 76 65 20 6d 75 6c 74 69 70 6c 65 20 66 69  have multiple fi
1070: 6c 65 20 64 65 73 63 72 69 70 74 6f 72 73 2c 20  le descriptors, 
1080: 73 6f 20 65 61 63 68 20 4f 73 46 69 6c 65 0a 2a  so each OsFile.*
1090: 2a 20 73 74 72 75 63 74 75 72 65 20 63 6f 6e 74  * structure cont
10a0: 61 69 6e 73 20 61 20 70 6f 69 6e 74 65 72 20 74  ains a pointer t
10b0: 6f 20 61 6e 20 69 6e 73 74 61 6e 63 65 20 6f 66  o an instance of
10c0: 20 74 68 69 73 20 6f 62 6a 65 63 74 20 61 6e 64   this object and
10d0: 20 74 68 69 73 0a 2a 2a 20 6f 62 6a 65 63 74 20   this.** object 
10e0: 6b 65 65 70 73 20 61 20 63 6f 75 6e 74 20 6f 66  keeps a count of
10f0: 20 74 68 65 20 6e 75 6d 62 65 72 20 6f 66 20 4f   the number of O
1100: 73 46 69 6c 65 73 20 70 6f 69 6e 74 69 6e 67 20  sFiles pointing 
1110: 74 6f 20 69 74 2e 0a 2a 2f 0a 73 74 72 75 63 74  to it..*/.struct
1120: 20 6c 6f 63 6b 49 6e 66 6f 20 7b 0a 20 20 73 74   lockInfo {.  st
1130: 72 75 63 74 20 69 6e 6f 64 65 4b 65 79 20 6b 65  ruct inodeKey ke
1140: 79 3b 20 20 2f 2a 20 54 68 65 20 6c 6f 6f 6b 75  y;  /* The looku
1150: 70 20 6b 65 79 20 2a 2f 0a 20 20 69 6e 74 20 63  p key */.  int c
1160: 6e 74 3b 20 20 20 20 20 20 20 20 20 20 20 20 20  nt;             
1170: 20 2f 2a 20 30 3a 20 75 6e 6c 6f 63 6b 65 64 2e   /* 0: unlocked.
1180: 20 20 2d 31 3a 20 77 72 69 74 65 20 6c 6f 63 6b    -1: write lock
1190: 2e 20 20 31 2e 2e 2e 3a 20 72 65 61 64 20 6c 6f  .  1...: read lo
11a0: 63 6b 2e 20 2a 2f 0a 20 20 69 6e 74 20 6e 52 65  ck. */.  int nRe
11b0: 66 3b 20 20 20 20 20 20 20 20 20 20 20 20 20 2f  f;             /
11c0: 2a 20 4e 75 6d 62 65 72 20 6f 66 20 70 6f 69 6e  * Number of poin
11d0: 74 65 72 73 20 74 6f 20 74 68 69 73 20 73 74 72  ters to this str
11e0: 75 63 74 75 72 65 20 2a 2f 0a 7d 3b 0a 0a 2f 2a  ucture */.};../*
11f0: 20 0a 2a 2a 20 54 68 69 73 20 68 61 73 68 20 74   .** This hash t
1200: 61 62 6c 65 20 6d 61 70 73 20 69 6e 6f 64 65 73  able maps inodes
1210: 20 28 69 6e 20 74 68 65 20 66 6f 72 6d 20 6f 66   (in the form of
1220: 20 69 6e 6f 64 65 4b 65 79 20 73 74 72 75 63 74   inodeKey struct
1230: 75 72 65 73 29 20 69 6e 74 6f 0a 2a 2a 20 70 6f  ures) into.** po
1240: 69 6e 74 65 72 73 20 74 6f 20 6c 6f 63 6b 49 6e  inters to lockIn
1250: 66 6f 20 73 74 72 75 63 74 75 72 65 73 2e 0a 2a  fo structures..*
1260: 2f 0a 73 74 61 74 69 63 20 48 61 73 68 20 6c 6f  /.static Hash lo
1270: 63 6b 48 61 73 68 20 3d 20 7b 20 53 51 4c 49 54  ckHash = { SQLIT
1280: 45 5f 48 41 53 48 5f 42 49 4e 41 52 59 2c 20 30  E_HASH_BINARY, 0
1290: 2c 20 30 2c 20 30 2c 20 30 2c 20 30 20 7d 3b 0a  , 0, 0, 0, 0 };.
12a0: 0a 2f 2a 0a 2a 2a 20 47 69 76 65 6e 20 61 20 66  ./*.** Given a f
12b0: 69 6c 65 20 64 65 73 63 72 69 70 74 6f 72 2c 20  ile descriptor, 
12c0: 6c 6f 63 61 74 65 20 61 20 6c 6f 63 6b 49 6e 66  locate a lockInf
12d0: 6f 20 73 74 72 75 63 74 75 72 65 20 74 68 61 74  o structure that
12e0: 20 64 65 73 63 72 69 62 65 73 0a 2a 2a 20 74 68   describes.** th
12f0: 61 74 20 66 69 6c 65 20 64 65 73 63 72 69 70 74  at file descript
1300: 6f 72 2e 20 20 43 72 65 61 74 65 20 61 20 6e 65  or.  Create a ne
1310: 77 20 6f 6e 65 20 69 66 20 6e 65 63 65 73 73 61  w one if necessa
1320: 72 79 2e 20 20 4e 55 4c 4c 20 6d 69 67 68 74 0a  ry.  NULL might.
1330: 2a 2a 20 62 65 20 72 65 74 75 72 6e 65 64 20 69  ** be returned i
1340: 66 20 6d 61 6c 6c 6f 63 28 29 20 66 61 69 6c 73  f malloc() fails
1350: 2e 0a 2a 2f 0a 73 74 61 74 69 63 20 73 74 72 75  ..*/.static stru
1360: 63 74 20 6c 6f 63 6b 49 6e 66 6f 20 2a 66 69 6e  ct lockInfo *fin
1370: 64 4c 6f 63 6b 49 6e 66 6f 28 69 6e 74 20 66 64  dLockInfo(int fd
1380: 29 7b 0a 20 20 69 6e 74 20 72 63 3b 0a 20 20 73  ){.  int rc;.  s
1390: 74 72 75 63 74 20 69 6e 6f 64 65 4b 65 79 20 6b  truct inodeKey k
13a0: 65 79 3b 0a 20 20 73 74 72 75 63 74 20 73 74 61  ey;.  struct sta
13b0: 74 20 73 74 61 74 62 75 66 3b 0a 20 20 73 74 72  t statbuf;.  str
13c0: 75 63 74 20 6c 6f 63 6b 49 6e 66 6f 20 2a 70 49  uct lockInfo *pI
13d0: 6e 66 6f 3b 0a 20 20 72 63 20 3d 20 66 73 74 61  nfo;.  rc = fsta
13e0: 74 28 66 64 2c 20 26 73 74 61 74 62 75 66 29 3b  t(fd, &statbuf);
13f0: 0a 20 20 69 66 28 20 72 63 21 3d 30 20 29 20 72  .  if( rc!=0 ) r
1400: 65 74 75 72 6e 20 30 3b 0a 20 20 6d 65 6d 73 65  eturn 0;.  memse
1410: 74 28 26 6b 65 79 2c 20 30 2c 20 73 69 7a 65 6f  t(&key, 0, sizeo
1420: 66 28 6b 65 79 29 29 3b 0a 20 20 6b 65 79 2e 64  f(key));.  key.d
1430: 65 76 20 3d 20 73 74 61 74 62 75 66 2e 73 74 5f  ev = statbuf.st_
1440: 64 65 76 3b 0a 20 20 6b 65 79 2e 69 6e 6f 20 3d  dev;.  key.ino =
1450: 20 73 74 61 74 62 75 66 2e 73 74 5f 69 6e 6f 3b   statbuf.st_ino;
1460: 0a 20 20 70 49 6e 66 6f 20 3d 20 28 73 74 72 75  .  pInfo = (stru
1470: 63 74 20 6c 6f 63 6b 49 6e 66 6f 2a 29 73 71 6c  ct lockInfo*)sql
1480: 69 74 65 48 61 73 68 46 69 6e 64 28 26 6c 6f 63  iteHashFind(&loc
1490: 6b 48 61 73 68 2c 20 26 6b 65 79 2c 20 73 69 7a  kHash, &key, siz
14a0: 65 6f 66 28 6b 65 79 29 29 3b 0a 20 20 69 66 28  eof(key));.  if(
14b0: 20 70 49 6e 66 6f 3d 3d 30 20 29 7b 0a 20 20 20   pInfo==0 ){.   
14c0: 20 73 74 72 75 63 74 20 6c 6f 63 6b 49 6e 66 6f   struct lockInfo
14d0: 20 2a 70 4f 6c 64 3b 0a 20 20 20 20 70 49 6e 66   *pOld;.    pInf
14e0: 6f 20 3d 20 73 71 6c 69 74 65 4d 61 6c 6c 6f 63  o = sqliteMalloc
14f0: 28 20 73 69 7a 65 6f 66 28 2a 70 49 6e 66 6f 29  ( sizeof(*pInfo)
1500: 20 29 3b 0a 20 20 20 20 69 66 28 20 70 49 6e 66   );.    if( pInf
1510: 6f 3d 3d 30 20 29 20 72 65 74 75 72 6e 20 30 3b  o==0 ) return 0;
1520: 0a 20 20 20 20 70 49 6e 66 6f 2d 3e 6b 65 79 20  .    pInfo->key 
1530: 3d 20 6b 65 79 3b 0a 20 20 20 20 70 49 6e 66 6f  = key;.    pInfo
1540: 2d 3e 6e 52 65 66 20 3d 20 31 3b 0a 20 20 20 20  ->nRef = 1;.    
1550: 70 49 6e 66 6f 2d 3e 63 6e 74 20 3d 20 30 3b 0a  pInfo->cnt = 0;.
1560: 20 20 20 20 70 4f 6c 64 20 3d 20 73 71 6c 69 74      pOld = sqlit
1570: 65 48 61 73 68 49 6e 73 65 72 74 28 26 6c 6f 63  eHashInsert(&loc
1580: 6b 48 61 73 68 2c 20 26 70 49 6e 66 6f 2d 3e 6b  kHash, &pInfo->k
1590: 65 79 2c 20 73 69 7a 65 6f 66 28 6b 65 79 29 2c  ey, sizeof(key),
15a0: 20 70 49 6e 66 6f 29 3b 0a 20 20 20 20 69 66 28   pInfo);.    if(
15b0: 20 70 4f 6c 64 21 3d 30 20 29 7b 0a 20 20 20 20   pOld!=0 ){.    
15c0: 20 20 61 73 73 65 72 74 28 20 70 4f 6c 64 3d 3d    assert( pOld==
15d0: 70 49 6e 66 6f 20 29 3b 0a 20 20 20 20 20 20 73  pInfo );.      s
15e0: 71 6c 69 74 65 46 72 65 65 28 70 49 6e 66 6f 29  qliteFree(pInfo)
15f0: 3b 0a 20 20 20 20 20 20 70 49 6e 66 6f 20 3d 20  ;.      pInfo = 
1600: 30 3b 0a 20 20 20 20 7d 0a 20 20 7d 65 6c 73 65  0;.    }.  }else
1610: 7b 0a 20 20 20 20 70 49 6e 66 6f 2d 3e 6e 52 65  {.    pInfo->nRe
1620: 66 2b 2b 3b 0a 20 20 7d 0a 20 20 72 65 74 75 72  f++;.  }.  retur
1630: 6e 20 70 49 6e 66 6f 3b 0a 7d 0a 0a 2f 2a 0a 2a  n pInfo;.}../*.*
1640: 2a 20 52 65 6c 65 61 73 65 20 61 20 6c 6f 63 6b  * Release a lock
1650: 49 6e 66 6f 20 73 74 72 75 63 74 75 72 65 20 70  Info structure p
1660: 72 65 76 69 6f 75 73 6c 79 20 61 6c 6c 6f 63 61  reviously alloca
1670: 74 65 64 20 62 79 20 66 69 6e 64 4c 6f 63 6b 49  ted by findLockI
1680: 6e 66 6f 28 29 2e 0a 2a 2f 0a 73 74 61 74 69 63  nfo()..*/.static
1690: 20 76 6f 69 64 20 72 65 6c 65 61 73 65 4c 6f 63   void releaseLoc
16a0: 6b 49 6e 66 6f 28 73 74 72 75 63 74 20 6c 6f 63  kInfo(struct loc
16b0: 6b 49 6e 66 6f 20 2a 70 49 6e 66 6f 29 7b 0a 20  kInfo *pInfo){. 
16c0: 20 70 49 6e 66 6f 2d 3e 6e 52 65 66 2d 2d 3b 0a   pInfo->nRef--;.
16d0: 20 20 69 66 28 20 70 49 6e 66 6f 2d 3e 6e 52 65    if( pInfo->nRe
16e0: 66 3d 3d 30 20 29 7b 0a 20 20 20 20 73 71 6c 69  f==0 ){.    sqli
16f0: 74 65 48 61 73 68 49 6e 73 65 72 74 28 26 6c 6f  teHashInsert(&lo
1700: 63 6b 48 61 73 68 2c 20 26 70 49 6e 66 6f 2d 3e  ckHash, &pInfo->
1710: 6b 65 79 2c 20 73 69 7a 65 6f 66 28 70 49 6e 66  key, sizeof(pInf
1720: 6f 2d 3e 6b 65 79 29 2c 20 30 29 3b 0a 20 20 20  o->key), 0);.   
1730: 20 73 71 6c 69 74 65 46 72 65 65 28 70 49 6e 66   sqliteFree(pInf
1740: 6f 29 3b 0a 20 20 7d 0a 7d 0a 23 65 6e 64 69 66  o);.  }.}.#endif
1750: 20 20 2f 2a 2a 20 50 4f 53 49 58 20 61 64 76 69    /** POSIX advi
1760: 73 6f 72 79 20 6c 6f 63 6b 20 77 6f 72 6b 2d 61  sory lock work-a
1770: 72 6f 75 6e 64 20 2a 2a 2f 0a 0a 2f 2a 0a 2a 2a  round **/../*.**
1780: 20 49 66 20 77 65 20 63 6f 6d 70 69 6c 65 20 77   If we compile w
1790: 69 74 68 20 74 68 65 20 53 51 4c 49 54 45 5f 54  ith the SQLITE_T
17a0: 45 53 54 20 6d 61 63 72 6f 20 73 65 74 2c 20 74  EST macro set, t
17b0: 68 65 6e 20 74 68 65 20 66 6f 6c 6c 6f 77 69 6e  hen the followin
17c0: 67 20 62 6c 6f 63 6b 0a 2a 2a 20 6f 66 20 63 6f  g block.** of co
17d0: 64 65 20 77 69 6c 6c 20 67 69 76 65 20 75 73 20  de will give us 
17e0: 74 68 65 20 61 62 69 6c 69 74 79 20 74 6f 20 73  the ability to s
17f0: 69 6d 75 6c 61 74 65 20 61 20 64 69 73 6b 20 49  imulate a disk I
1800: 2f 4f 20 65 72 72 6f 72 2e 20 20 54 68 69 73 0a  /O error.  This.
1810: 2a 2a 20 69 73 20 75 73 65 64 20 66 6f 72 20 74  ** is used for t
1820: 65 73 74 69 6e 67 20 74 68 65 20 49 2f 4f 20 72  esting the I/O r
1830: 65 63 6f 76 65 72 79 20 6c 6f 67 69 63 2e 0a 2a  ecovery logic..*
1840: 2f 0a 23 69 66 64 65 66 20 53 51 4c 49 54 45 5f  /.#ifdef SQLITE_
1850: 54 45 53 54 0a 69 6e 74 20 73 71 6c 69 74 65 5f  TEST.int sqlite_
1860: 69 6f 5f 65 72 72 6f 72 5f 70 65 6e 64 69 6e 67  io_error_pending
1870: 20 3d 20 30 3b 0a 23 64 65 66 69 6e 65 20 53 69   = 0;.#define Si
1880: 6d 75 6c 61 74 65 49 4f 45 72 72 6f 72 28 41 29  mulateIOError(A)
1890: 20 20 5c 0a 20 20 20 69 66 28 20 73 71 6c 69 74    \.   if( sqlit
18a0: 65 5f 69 6f 5f 65 72 72 6f 72 5f 70 65 6e 64 69  e_io_error_pendi
18b0: 6e 67 20 29 20 5c 0a 20 20 20 20 20 69 66 28 20  ng ) \.     if( 
18c0: 73 71 6c 69 74 65 5f 69 6f 5f 65 72 72 6f 72 5f  sqlite_io_error_
18d0: 70 65 6e 64 69 6e 67 2d 2d 20 3d 3d 20 31 20 29  pending-- == 1 )
18e0: 7b 20 6c 6f 63 61 6c 5f 69 6f 65 72 72 28 29 3b  { local_ioerr();
18f0: 20 72 65 74 75 72 6e 20 41 3b 20 7d 0a 73 74 61   return A; }.sta
1900: 74 69 63 20 76 6f 69 64 20 6c 6f 63 61 6c 5f 69  tic void local_i
1910: 6f 65 72 72 28 29 7b 0a 20 20 73 71 6c 69 74 65  oerr(){.  sqlite
1920: 5f 69 6f 5f 65 72 72 6f 72 5f 70 65 6e 64 69 6e  _io_error_pendin
1930: 67 20 3d 20 30 3b 20 20 2f 2a 20 52 65 61 6c 6c  g = 0;  /* Reall
1940: 79 20 6a 75 73 74 20 61 20 70 6c 61 63 65 20 74  y just a place t
1950: 6f 20 73 65 74 20 61 20 62 72 65 61 6b 70 6f 69  o set a breakpoi
1960: 6e 74 20 2a 2f 0a 7d 0a 23 65 6c 73 65 0a 23 64  nt */.}.#else.#d
1970: 65 66 69 6e 65 20 53 69 6d 75 6c 61 74 65 49 4f  efine SimulateIO
1980: 45 72 72 6f 72 28 41 29 0a 23 65 6e 64 69 66 0a  Error(A).#endif.
1990: 0a 0a 2f 2a 0a 2a 2a 20 44 65 6c 65 74 65 20 74  ../*.** Delete t
19a0: 68 65 20 6e 61 6d 65 64 20 66 69 6c 65 0a 2a 2f  he named file.*/
19b0: 0a 69 6e 74 20 73 71 6c 69 74 65 4f 73 44 65 6c  .int sqliteOsDel
19c0: 65 74 65 28 63 6f 6e 73 74 20 63 68 61 72 20 2a  ete(const char *
19d0: 7a 46 69 6c 65 6e 61 6d 65 29 7b 0a 23 69 66 20  zFilename){.#if 
19e0: 4f 53 5f 55 4e 49 58 0a 20 20 75 6e 6c 69 6e 6b  OS_UNIX.  unlink
19f0: 28 7a 46 69 6c 65 6e 61 6d 65 29 3b 0a 23 65 6e  (zFilename);.#en
1a00: 64 69 66 0a 23 69 66 20 4f 53 5f 57 49 4e 0a 20  dif.#if OS_WIN. 
1a10: 20 44 65 6c 65 74 65 46 69 6c 65 28 7a 46 69 6c   DeleteFile(zFil
1a20: 65 6e 61 6d 65 29 3b 0a 23 65 6e 64 69 66 0a 20  ename);.#endif. 
1a30: 20 72 65 74 75 72 6e 20 53 51 4c 49 54 45 5f 4f   return SQLITE_O
1a40: 4b 3b 0a 7d 0a 0a 2f 2a 0a 2a 2a 20 52 65 74 75  K;.}../*.** Retu
1a50: 72 6e 20 54 52 55 45 20 69 66 20 74 68 65 20 6e  rn TRUE if the n
1a60: 61 6d 65 64 20 66 69 6c 65 20 65 78 69 73 74 73  amed file exists
1a70: 2e 0a 2a 2f 0a 69 6e 74 20 73 71 6c 69 74 65 4f  ..*/.int sqliteO
1a80: 73 46 69 6c 65 45 78 69 73 74 73 28 63 6f 6e 73  sFileExists(cons
1a90: 74 20 63 68 61 72 20 2a 7a 46 69 6c 65 6e 61 6d  t char *zFilenam
1aa0: 65 29 7b 0a 23 69 66 20 4f 53 5f 55 4e 49 58 0a  e){.#if OS_UNIX.
1ab0: 20 20 72 65 74 75 72 6e 20 61 63 63 65 73 73 28    return access(
1ac0: 7a 46 69 6c 65 6e 61 6d 65 2c 20 30 29 3d 3d 30  zFilename, 0)==0
1ad0: 3b 0a 23 65 6e 64 69 66 0a 23 69 66 20 4f 53 5f  ;.#endif.#if OS_
1ae0: 57 49 4e 0a 20 20 48 41 4e 44 4c 45 20 68 3b 0a  WIN.  HANDLE h;.
1af0: 20 20 68 20 3d 20 43 72 65 61 74 65 46 69 6c 65    h = CreateFile
1b00: 28 7a 46 69 6c 65 6e 61 6d 65 2c 0a 20 20 20 20  (zFilename,.    
1b10: 47 45 4e 45 52 49 43 5f 52 45 41 44 2c 0a 20 20  GENERIC_READ,.  
1b20: 20 20 30 2c 0a 20 20 20 20 4e 55 4c 4c 2c 0a 20    0,.    NULL,. 
1b30: 20 20 20 4f 50 45 4e 5f 45 58 49 53 54 49 4e 47     OPEN_EXISTING
1b40: 2c 0a 20 20 20 20 46 49 4c 45 5f 41 54 54 52 49  ,.    FILE_ATTRI
1b50: 42 55 54 45 5f 4e 4f 52 4d 41 4c 20 7c 20 46 49  BUTE_NORMAL | FI
1b60: 4c 45 5f 46 4c 41 47 5f 52 41 4e 44 4f 4d 5f 41  LE_FLAG_RANDOM_A
1b70: 43 43 45 53 53 2c 0a 20 20 20 20 4e 55 4c 4c 0a  CCESS,.    NULL.
1b80: 20 20 29 3b 0a 20 20 69 66 28 20 68 21 3d 49 4e    );.  if( h!=IN
1b90: 56 41 4c 49 44 5f 48 41 4e 44 4c 45 5f 56 41 4c  VALID_HANDLE_VAL
1ba0: 55 45 20 29 7b 0a 20 20 20 20 43 6c 6f 73 65 48  UE ){.    CloseH
1bb0: 61 6e 64 6c 65 28 68 29 3b 0a 20 20 20 20 72 65  andle(h);.    re
1bc0: 74 75 72 6e 20 31 3b 0a 20 20 7d 0a 20 20 72 65  turn 1;.  }.  re
1bd0: 74 75 72 6e 20 30 3b 0a 23 65 6e 64 69 66 0a 7d  turn 0;.#endif.}
1be0: 0a 0a 0a 2f 2a 0a 2a 2a 20 41 74 74 65 6d 70 74  .../*.** Attempt
1bf0: 20 74 6f 20 6f 70 65 6e 20 61 20 66 69 6c 65 20   to open a file 
1c00: 66 6f 72 20 62 6f 74 68 20 72 65 61 64 69 6e 67  for both reading
1c10: 20 61 6e 64 20 77 72 69 74 69 6e 67 2e 20 20 49   and writing.  I
1c20: 66 20 74 68 61 74 0a 2a 2a 20 66 61 69 6c 73 2c  f that.** fails,
1c30: 20 74 72 79 20 6f 70 65 6e 69 6e 67 20 69 74 20   try opening it 
1c40: 72 65 61 64 2d 6f 6e 6c 79 2e 20 20 49 66 20 74  read-only.  If t
1c50: 68 65 20 66 69 6c 65 20 64 6f 65 73 20 6e 6f 74  he file does not
1c60: 20 65 78 69 73 74 2c 0a 2a 2a 20 74 72 79 20 74   exist,.** try t
1c70: 6f 20 63 72 65 61 74 65 20 69 74 2e 0a 2a 2a 0a  o create it..**.
1c80: 2a 2a 20 4f 6e 20 73 75 63 63 65 73 73 2c 20 61  ** On success, a
1c90: 20 68 61 6e 64 6c 65 20 66 6f 72 20 74 68 65 20   handle for the 
1ca0: 6f 70 65 6e 20 66 69 6c 65 20 69 73 20 77 72 69  open file is wri
1cb0: 74 74 65 6e 20 74 6f 20 2a 69 64 0a 2a 2a 20 61  tten to *id.** a
1cc0: 6e 64 20 2a 70 52 65 61 64 6f 6e 6c 79 20 69 73  nd *pReadonly is
1cd0: 20 73 65 74 20 74 6f 20 30 20 69 66 20 74 68 65   set to 0 if the
1ce0: 20 66 69 6c 65 20 77 61 73 20 6f 70 65 6e 65 64   file was opened
1cf0: 20 66 6f 72 20 72 65 61 64 69 6e 67 20 61 6e 64   for reading and
1d00: 0a 2a 2a 20 77 72 69 74 69 6e 67 20 6f 72 20 31  .** writing or 1
1d10: 20 69 66 20 74 68 65 20 66 69 6c 65 20 77 61 73   if the file was
1d20: 20 6f 70 65 6e 65 64 20 72 65 61 64 2d 6f 6e 6c   opened read-onl
1d30: 79 2e 20 20 54 68 65 20 66 75 6e 63 74 69 6f 6e  y.  The function
1d40: 20 72 65 74 75 72 6e 73 0a 2a 2a 20 53 51 4c 49   returns.** SQLI
1d50: 54 45 5f 4f 4b 2e 0a 2a 2a 0a 2a 2a 20 4f 6e 20  TE_OK..**.** On 
1d60: 66 61 69 6c 75 72 65 2c 20 74 68 65 20 66 75 6e  failure, the fun
1d70: 63 74 69 6f 6e 20 72 65 74 75 72 6e 73 20 53 51  ction returns SQ
1d80: 4c 49 54 45 5f 43 41 4e 54 4f 50 45 4e 20 61 6e  LITE_CANTOPEN an
1d90: 64 20 6c 65 61 76 65 73 0a 2a 2a 20 2a 70 52 65  d leaves.** *pRe
1da0: 73 75 6c 73 74 20 61 6e 64 20 2a 70 52 65 61 64  sulst and *pRead
1db0: 6f 6e 6c 79 20 75 6e 63 68 61 6e 67 65 64 2e 0a  only unchanged..
1dc0: 2a 2f 0a 69 6e 74 20 73 71 6c 69 74 65 4f 73 4f  */.int sqliteOsO
1dd0: 70 65 6e 52 65 61 64 57 72 69 74 65 28 0a 20 20  penReadWrite(.  
1de0: 63 6f 6e 73 74 20 63 68 61 72 20 2a 7a 46 69 6c  const char *zFil
1df0: 65 6e 61 6d 65 2c 0a 20 20 4f 73 46 69 6c 65 20  ename,.  OsFile 
1e00: 2a 69 64 2c 0a 20 20 69 6e 74 20 2a 70 52 65 61  *id,.  int *pRea
1e10: 64 6f 6e 6c 79 0a 29 7b 0a 23 69 66 20 4f 53 5f  donly.){.#if OS_
1e20: 55 4e 49 58 0a 20 20 69 64 2d 3e 66 64 20 3d 20  UNIX.  id->fd = 
1e30: 6f 70 65 6e 28 7a 46 69 6c 65 6e 61 6d 65 2c 20  open(zFilename, 
1e40: 4f 5f 52 44 57 52 7c 4f 5f 43 52 45 41 54 2c 20  O_RDWR|O_CREAT, 
1e50: 30 36 34 34 29 3b 0a 20 20 69 66 28 20 69 64 2d  0644);.  if( id-
1e60: 3e 66 64 3c 30 20 29 7b 0a 20 20 20 20 69 64 2d  >fd<0 ){.    id-
1e70: 3e 66 64 20 3d 20 6f 70 65 6e 28 7a 46 69 6c 65  >fd = open(zFile
1e80: 6e 61 6d 65 2c 20 4f 5f 52 44 4f 4e 4c 59 29 3b  name, O_RDONLY);
1e90: 0a 20 20 20 20 69 66 28 20 69 64 2d 3e 66 64 3c  .    if( id->fd<
1ea0: 30 20 29 7b 0a 20 20 20 20 20 20 72 65 74 75 72  0 ){.      retur
1eb0: 6e 20 53 51 4c 49 54 45 5f 43 41 4e 54 4f 50 45  n SQLITE_CANTOPE
1ec0: 4e 3b 20 0a 20 20 20 20 7d 0a 20 20 20 20 2a 70  N; .    }.    *p
1ed0: 52 65 61 64 6f 6e 6c 79 20 3d 20 31 3b 0a 20 20  Readonly = 1;.  
1ee0: 7d 65 6c 73 65 7b 0a 20 20 20 20 2a 70 52 65 61  }else{.    *pRea
1ef0: 64 6f 6e 6c 79 20 3d 20 30 3b 0a 20 20 7d 0a 20  donly = 0;.  }. 
1f00: 20 73 71 6c 69 74 65 4f 73 45 6e 74 65 72 4d 75   sqliteOsEnterMu
1f10: 74 65 78 28 29 3b 0a 20 20 69 64 2d 3e 70 4c 6f  tex();.  id->pLo
1f20: 63 6b 20 3d 20 66 69 6e 64 4c 6f 63 6b 49 6e 66  ck = findLockInf
1f30: 6f 28 69 64 2d 3e 66 64 29 3b 0a 20 20 73 71 6c  o(id->fd);.  sql
1f40: 69 74 65 4f 73 4c 65 61 76 65 4d 75 74 65 78 28  iteOsLeaveMutex(
1f50: 29 3b 0a 20 20 69 66 28 20 69 64 2d 3e 70 4c 6f  );.  if( id->pLo
1f60: 63 6b 3d 3d 30 20 29 7b 0a 20 20 20 20 63 6c 6f  ck==0 ){.    clo
1f70: 73 65 28 69 64 2d 3e 66 64 29 3b 0a 20 20 20 20  se(id->fd);.    
1f80: 72 65 74 75 72 6e 20 53 51 4c 49 54 45 5f 4e 4f  return SQLITE_NO
1f90: 4d 45 4d 3b 0a 20 20 7d 0a 20 20 69 64 2d 3e 6c  MEM;.  }.  id->l
1fa0: 6f 63 6b 65 64 20 3d 20 30 3b 0a 20 20 72 65 74  ocked = 0;.  ret
1fb0: 75 72 6e 20 53 51 4c 49 54 45 5f 4f 4b 3b 0a 23  urn SQLITE_OK;.#
1fc0: 65 6e 64 69 66 0a 23 69 66 20 4f 53 5f 57 49 4e  endif.#if OS_WIN
1fd0: 0a 20 20 48 41 4e 44 4c 45 20 68 20 3d 20 43 72  .  HANDLE h = Cr
1fe0: 65 61 74 65 46 69 6c 65 28 7a 46 69 6c 65 6e 61  eateFile(zFilena
1ff0: 6d 65 2c 0a 20 20 20 20 20 47 45 4e 45 52 49 43  me,.     GENERIC
2000: 5f 52 45 41 44 20 7c 20 47 45 4e 45 52 49 43 5f  _READ | GENERIC_
2010: 57 52 49 54 45 2c 0a 20 20 20 20 20 46 49 4c 45  WRITE,.     FILE
2020: 5f 53 48 41 52 45 5f 52 45 41 44 20 7c 20 46 49  _SHARE_READ | FI
2030: 4c 45 5f 53 48 41 52 45 5f 57 52 49 54 45 2c 0a  LE_SHARE_WRITE,.
2040: 20 20 20 20 20 4e 55 4c 4c 2c 0a 20 20 20 20 20       NULL,.     
2050: 4f 50 45 4e 5f 41 4c 57 41 59 53 2c 0a 20 20 20  OPEN_ALWAYS,.   
2060: 20 20 46 49 4c 45 5f 41 54 54 52 49 42 55 54 45    FILE_ATTRIBUTE
2070: 5f 4e 4f 52 4d 41 4c 20 7c 20 46 49 4c 45 5f 46  _NORMAL | FILE_F
2080: 4c 41 47 5f 52 41 4e 44 4f 4d 5f 41 43 43 45 53  LAG_RANDOM_ACCES
2090: 53 2c 0a 20 20 20 20 20 4e 55 4c 4c 0a 20 20 29  S,.     NULL.  )
20a0: 3b 0a 20 20 69 66 28 20 68 3d 3d 49 4e 56 41 4c  ;.  if( h==INVAL
20b0: 49 44 5f 48 41 4e 44 4c 45 5f 56 41 4c 55 45 20  ID_HANDLE_VALUE 
20c0: 29 7b 0a 20 20 20 20 68 20 3d 20 43 72 65 61 74  ){.    h = Creat
20d0: 65 46 69 6c 65 28 7a 46 69 6c 65 6e 61 6d 65 2c  eFile(zFilename,
20e0: 0a 20 20 20 20 20 20 20 47 45 4e 45 52 49 43 5f  .       GENERIC_
20f0: 52 45 41 44 2c 0a 20 20 20 20 20 20 20 46 49 4c  READ,.       FIL
2100: 45 5f 53 48 41 52 45 5f 52 45 41 44 2c 0a 20 20  E_SHARE_READ,.  
2110: 20 20 20 20 20 4e 55 4c 4c 2c 0a 20 20 20 20 20       NULL,.     
2120: 20 20 4f 50 45 4e 5f 41 4c 57 41 59 53 2c 0a 20    OPEN_ALWAYS,. 
2130: 20 20 20 20 20 20 46 49 4c 45 5f 41 54 54 52 49        FILE_ATTRI
2140: 42 55 54 45 5f 4e 4f 52 4d 41 4c 20 7c 20 46 49  BUTE_NORMAL | FI
2150: 4c 45 5f 46 4c 41 47 5f 52 41 4e 44 4f 4d 5f 41  LE_FLAG_RANDOM_A
2160: 43 43 45 53 53 2c 0a 20 20 20 20 20 20 20 4e 55  CCESS,.       NU
2170: 4c 4c 0a 20 20 20 20 29 3b 0a 20 20 20 20 69 66  LL.    );.    if
2180: 28 20 68 3d 3d 49 4e 56 41 4c 49 44 5f 48 41 4e  ( h==INVALID_HAN
2190: 44 4c 45 5f 56 41 4c 55 45 20 29 7b 0a 20 20 20  DLE_VALUE ){.   
21a0: 20 20 20 72 65 74 75 72 6e 20 53 51 4c 49 54 45     return SQLITE
21b0: 5f 43 41 4e 54 4f 50 45 4e 3b 0a 20 20 20 20 7d  _CANTOPEN;.    }
21c0: 0a 20 20 20 20 2a 70 52 65 61 64 6f 6e 6c 79 20  .    *pReadonly 
21d0: 3d 20 31 3b 0a 20 20 7d 65 6c 73 65 7b 0a 20 20  = 1;.  }else{.  
21e0: 20 20 2a 70 52 65 61 64 6f 6e 6c 79 20 3d 20 30    *pReadonly = 0
21f0: 3b 0a 20 20 7d 0a 20 20 69 64 2d 3e 68 20 3d 20  ;.  }.  id->h = 
2200: 68 3b 0a 20 20 69 64 2d 3e 6c 6f 63 6b 65 64 20  h;.  id->locked 
2210: 3d 20 30 3b 0a 20 20 72 65 74 75 72 6e 20 53 51  = 0;.  return SQ
2220: 4c 49 54 45 5f 4f 4b 3b 0a 23 65 6e 64 69 66 0a  LITE_OK;.#endif.
2230: 7d 0a 0a 0a 2f 2a 0a 2a 2a 20 41 74 74 65 6d 70  }.../*.** Attemp
2240: 74 20 74 6f 20 6f 70 65 6e 20 61 20 6e 65 77 20  t to open a new 
2250: 66 69 6c 65 20 66 6f 72 20 65 78 63 6c 75 73 69  file for exclusi
2260: 76 65 20 61 63 63 65 73 73 20 62 79 20 74 68 69  ve access by thi
2270: 73 20 70 72 6f 63 65 73 73 2e 0a 2a 2a 20 54 68  s process..** Th
2280: 65 20 66 69 6c 65 20 77 69 6c 6c 20 62 65 20 6f  e file will be o
2290: 70 65 6e 65 64 20 66 6f 72 20 62 6f 74 68 20 72  pened for both r
22a0: 65 61 64 69 6e 67 20 61 6e 64 20 77 72 69 74 69  eading and writi
22b0: 6e 67 2e 20 20 54 6f 20 61 76 6f 69 64 0a 2a 2a  ng.  To avoid.**
22c0: 20 61 20 70 6f 74 65 6e 74 69 61 6c 20 73 65 63   a potential sec
22d0: 75 72 69 74 79 20 70 72 6f 62 6c 65 6d 2c 20 77  urity problem, w
22e0: 65 20 64 6f 20 6e 6f 74 20 61 6c 6c 6f 77 20 74  e do not allow t
22f0: 68 65 20 66 69 6c 65 20 74 6f 20 68 61 76 65 0a  he file to have.
2300: 2a 2a 20 70 72 65 76 69 6f 75 73 6c 79 20 65 78  ** previously ex
2310: 69 73 74 65 64 2e 20 20 4e 6f 72 20 64 6f 20 77  isted.  Nor do w
2320: 65 20 61 6c 6c 6f 77 20 74 68 65 20 66 69 6c 65  e allow the file
2330: 20 74 6f 20 62 65 20 61 20 73 79 6d 62 6f 6c 69   to be a symboli
2340: 63 0a 2a 2a 20 6c 69 6e 6b 2e 0a 2a 2a 0a 2a 2a  c.** link..**.**
2350: 20 49 66 20 64 65 6c 46 6c 61 67 20 69 73 20 74   If delFlag is t
2360: 72 75 65 2c 20 74 68 65 6e 20 6d 61 6b 65 20 61  rue, then make a
2370: 72 72 61 6e 67 65 6d 65 6e 74 73 20 74 6f 20 61  rrangements to a
2380: 75 74 6f 6d 61 74 69 63 61 6c 6c 79 20 64 65 6c  utomatically del
2390: 65 74 65 0a 2a 2a 20 74 68 65 20 66 69 6c 65 20  ete.** the file 
23a0: 77 68 65 6e 20 69 74 20 69 73 20 63 6c 6f 73 65  when it is close
23b0: 64 2e 0a 2a 2a 0a 2a 2a 20 4f 6e 20 73 75 63 63  d..**.** On succ
23c0: 65 73 73 2c 20 77 72 69 74 65 20 74 68 65 20 66  ess, write the f
23d0: 69 6c 65 20 68 61 6e 64 6c 65 20 69 6e 74 6f 20  ile handle into 
23e0: 2a 69 64 20 61 6e 64 20 72 65 74 75 72 6e 20 53  *id and return S
23f0: 51 4c 49 54 45 5f 4f 4b 2e 0a 2a 2a 0a 2a 2a 20  QLITE_OK..**.** 
2400: 4f 6e 20 66 61 69 6c 75 72 65 2c 20 72 65 74 75  On failure, retu
2410: 72 6e 20 53 51 4c 49 54 45 5f 43 41 4e 54 4f 50  rn SQLITE_CANTOP
2420: 45 4e 2e 0a 2a 2f 0a 69 6e 74 20 73 71 6c 69 74  EN..*/.int sqlit
2430: 65 4f 73 4f 70 65 6e 45 78 63 6c 75 73 69 76 65  eOsOpenExclusive
2440: 28 63 6f 6e 73 74 20 63 68 61 72 20 2a 7a 46 69  (const char *zFi
2450: 6c 65 6e 61 6d 65 2c 20 4f 73 46 69 6c 65 20 2a  lename, OsFile *
2460: 69 64 2c 20 69 6e 74 20 64 65 6c 46 6c 61 67 29  id, int delFlag)
2470: 7b 0a 23 69 66 20 4f 53 5f 55 4e 49 58 0a 20 20  {.#if OS_UNIX.  
2480: 69 66 28 20 61 63 63 65 73 73 28 7a 46 69 6c 65  if( access(zFile
2490: 6e 61 6d 65 2c 20 30 29 3d 3d 30 20 29 7b 0a 20  name, 0)==0 ){. 
24a0: 20 20 20 72 65 74 75 72 6e 20 53 51 4c 49 54 45     return SQLITE
24b0: 5f 43 41 4e 54 4f 50 45 4e 3b 0a 20 20 7d 0a 23  _CANTOPEN;.  }.#
24c0: 69 66 6e 64 65 66 20 4f 5f 4e 4f 46 4f 4c 4c 4f  ifndef O_NOFOLLO
24d0: 57 0a 23 20 64 65 66 69 6e 65 20 4f 5f 4e 4f 46  W.# define O_NOF
24e0: 4f 4c 4c 4f 57 20 30 0a 23 65 6e 64 69 66 0a 20  OLLOW 0.#endif. 
24f0: 20 69 64 2d 3e 66 64 20 3d 20 6f 70 65 6e 28 7a   id->fd = open(z
2500: 46 69 6c 65 6e 61 6d 65 2c 20 4f 5f 52 44 57 52  Filename, O_RDWR
2510: 7c 4f 5f 43 52 45 41 54 7c 4f 5f 45 58 43 4c 7c  |O_CREAT|O_EXCL|
2520: 4f 5f 4e 4f 46 4f 4c 4c 4f 57 2c 20 30 36 30 30  O_NOFOLLOW, 0600
2530: 29 3b 0a 20 20 69 66 28 20 69 64 2d 3e 66 64 3c  );.  if( id->fd<
2540: 30 20 29 7b 0a 20 20 20 20 72 65 74 75 72 6e 20  0 ){.    return 
2550: 53 51 4c 49 54 45 5f 43 41 4e 54 4f 50 45 4e 3b  SQLITE_CANTOPEN;
2560: 0a 20 20 7d 0a 20 20 73 71 6c 69 74 65 4f 73 45  .  }.  sqliteOsE
2570: 6e 74 65 72 4d 75 74 65 78 28 29 3b 0a 20 20 69  nterMutex();.  i
2580: 64 2d 3e 70 4c 6f 63 6b 20 3d 20 66 69 6e 64 4c  d->pLock = findL
2590: 6f 63 6b 49 6e 66 6f 28 69 64 2d 3e 66 64 29 3b  ockInfo(id->fd);
25a0: 0a 20 20 73 71 6c 69 74 65 4f 73 4c 65 61 76 65  .  sqliteOsLeave
25b0: 4d 75 74 65 78 28 29 3b 0a 20 20 69 66 28 20 69  Mutex();.  if( i
25c0: 64 2d 3e 70 4c 6f 63 6b 3d 3d 30 20 29 7b 0a 20  d->pLock==0 ){. 
25d0: 20 20 20 63 6c 6f 73 65 28 69 64 2d 3e 66 64 29     close(id->fd)
25e0: 3b 0a 20 20 20 20 75 6e 6c 69 6e 6b 28 7a 46 69  ;.    unlink(zFi
25f0: 6c 65 6e 61 6d 65 29 3b 0a 20 20 20 20 72 65 74  lename);.    ret
2600: 75 72 6e 20 53 51 4c 49 54 45 5f 4e 4f 4d 45 4d  urn SQLITE_NOMEM
2610: 3b 0a 20 20 7d 0a 20 20 69 64 2d 3e 6c 6f 63 6b  ;.  }.  id->lock
2620: 65 64 20 3d 20 30 3b 0a 20 20 69 66 28 20 64 65  ed = 0;.  if( de
2630: 6c 46 6c 61 67 20 29 7b 0a 20 20 20 20 75 6e 6c  lFlag ){.    unl
2640: 69 6e 6b 28 7a 46 69 6c 65 6e 61 6d 65 29 3b 0a  ink(zFilename);.
2650: 20 20 7d 0a 20 20 72 65 74 75 72 6e 20 53 51 4c    }.  return SQL
2660: 49 54 45 5f 4f 4b 3b 0a 23 65 6e 64 69 66 0a 23  ITE_OK;.#endif.#
2670: 69 66 20 4f 53 5f 57 49 4e 0a 20 20 48 41 4e 44  if OS_WIN.  HAND
2680: 4c 45 20 68 3b 0a 20 20 69 6e 74 20 66 69 6c 65  LE h;.  int file
2690: 66 6c 61 67 73 3b 0a 20 20 69 66 28 20 64 65 6c  flags;.  if( del
26a0: 46 6c 61 67 20 29 7b 0a 20 20 20 20 66 69 6c 65  Flag ){.    file
26b0: 66 6c 61 67 73 20 3d 20 46 49 4c 45 5f 41 54 54  flags = FILE_ATT
26c0: 52 49 42 55 54 45 5f 54 45 4d 50 4f 52 41 52 59  RIBUTE_TEMPORARY
26d0: 20 7c 20 46 49 4c 45 5f 46 4c 41 47 5f 52 41 4e   | FILE_FLAG_RAN
26e0: 44 4f 4d 5f 41 43 43 45 53 53 20 0a 20 20 20 20  DOM_ACCESS .    
26f0: 20 20 20 20 20 20 20 20 20 20 20 20 20 20 20 20                  
2700: 20 7c 20 46 49 4c 45 5f 46 4c 41 47 5f 44 45 4c   | FILE_FLAG_DEL
2710: 45 54 45 5f 4f 4e 5f 43 4c 4f 53 45 3b 0a 20 20  ETE_ON_CLOSE;.  
2720: 7d 65 6c 73 65 7b 0a 20 20 20 20 66 69 6c 65 66  }else{.    filef
2730: 6c 61 67 73 20 3d 20 46 49 4c 45 5f 46 4c 41 47  lags = FILE_FLAG
2740: 5f 52 41 4e 44 4f 4d 5f 41 43 43 45 53 53 3b 0a  _RANDOM_ACCESS;.
2750: 20 20 7d 0a 20 20 68 20 3d 20 43 72 65 61 74 65    }.  h = Create
2760: 46 69 6c 65 28 7a 46 69 6c 65 6e 61 6d 65 2c 0a  File(zFilename,.
2770: 20 20 20 20 20 47 45 4e 45 52 49 43 5f 52 45 41       GENERIC_REA
2780: 44 20 7c 20 47 45 4e 45 52 49 43 5f 57 52 49 54  D | GENERIC_WRIT
2790: 45 2c 0a 20 20 20 20 20 30 2c 0a 20 20 20 20 20  E,.     0,.     
27a0: 4e 55 4c 4c 2c 0a 20 20 20 20 20 43 52 45 41 54  NULL,.     CREAT
27b0: 45 5f 41 4c 57 41 59 53 2c 0a 20 20 20 20 20 66  E_ALWAYS,.     f
27c0: 69 6c 65 66 6c 61 67 73 2c 0a 20 20 20 20 20 4e  ileflags,.     N
27d0: 55 4c 4c 0a 20 20 29 3b 0a 20 20 69 66 28 20 68  ULL.  );.  if( h
27e0: 3d 3d 49 4e 56 41 4c 49 44 5f 48 41 4e 44 4c 45  ==INVALID_HANDLE
27f0: 5f 56 41 4c 55 45 20 29 7b 0a 20 20 20 20 72 65  _VALUE ){.    re
2800: 74 75 72 6e 20 53 51 4c 49 54 45 5f 43 41 4e 54  turn SQLITE_CANT
2810: 4f 50 45 4e 3b 0a 20 20 7d 0a 20 20 69 64 2d 3e  OPEN;.  }.  id->
2820: 68 20 3d 20 68 3b 0a 20 20 69 64 2d 3e 6c 6f 63  h = h;.  id->loc
2830: 6b 65 64 20 3d 20 30 3b 0a 20 20 72 65 74 75 72  ked = 0;.  retur
2840: 6e 20 53 51 4c 49 54 45 5f 4f 4b 3b 0a 23 65 6e  n SQLITE_OK;.#en
2850: 64 69 66 0a 7d 0a 0a 2f 2a 0a 2a 2a 20 41 74 74  dif.}../*.** Att
2860: 65 6d 70 74 20 74 6f 20 6f 70 65 6e 20 61 20 6e  empt to open a n
2870: 65 77 20 66 69 6c 65 20 66 6f 72 20 72 65 61 64  ew file for read
2880: 2d 6f 6e 6c 79 20 61 63 63 65 73 73 2e 0a 2a 2a  -only access..**
2890: 0a 2a 2a 20 4f 6e 20 73 75 63 63 65 73 73 2c 20  .** On success, 
28a0: 77 72 69 74 65 20 74 68 65 20 66 69 6c 65 20 68  write the file h
28b0: 61 6e 64 6c 65 20 69 6e 74 6f 20 2a 69 64 20 61  andle into *id a
28c0: 6e 64 20 72 65 74 75 72 6e 20 53 51 4c 49 54 45  nd return SQLITE
28d0: 5f 4f 4b 2e 0a 2a 2a 0a 2a 2a 20 4f 6e 20 66 61  _OK..**.** On fa
28e0: 69 6c 75 72 65 2c 20 72 65 74 75 72 6e 20 53 51  ilure, return SQ
28f0: 4c 49 54 45 5f 43 41 4e 54 4f 50 45 4e 2e 0a 2a  LITE_CANTOPEN..*
2900: 2f 0a 69 6e 74 20 73 71 6c 69 74 65 4f 73 4f 70  /.int sqliteOsOp
2910: 65 6e 52 65 61 64 4f 6e 6c 79 28 63 6f 6e 73 74  enReadOnly(const
2920: 20 63 68 61 72 20 2a 7a 46 69 6c 65 6e 61 6d 65   char *zFilename
2930: 2c 20 4f 73 46 69 6c 65 20 2a 69 64 29 7b 0a 23  , OsFile *id){.#
2940: 69 66 20 4f 53 5f 55 4e 49 58 0a 20 20 69 64 2d  if OS_UNIX.  id-
2950: 3e 66 64 20 3d 20 6f 70 65 6e 28 7a 46 69 6c 65  >fd = open(zFile
2960: 6e 61 6d 65 2c 20 4f 5f 52 44 4f 4e 4c 59 29 3b  name, O_RDONLY);
2970: 0a 20 20 69 66 28 20 69 64 2d 3e 66 64 3c 30 20  .  if( id->fd<0 
2980: 29 7b 0a 20 20 20 20 72 65 74 75 72 6e 20 53 51  ){.    return SQ
2990: 4c 49 54 45 5f 43 41 4e 54 4f 50 45 4e 3b 0a 20  LITE_CANTOPEN;. 
29a0: 20 7d 0a 20 20 73 71 6c 69 74 65 4f 73 45 6e 74   }.  sqliteOsEnt
29b0: 65 72 4d 75 74 65 78 28 29 3b 0a 20 20 69 64 2d  erMutex();.  id-
29c0: 3e 70 4c 6f 63 6b 20 3d 20 66 69 6e 64 4c 6f 63  >pLock = findLoc
29d0: 6b 49 6e 66 6f 28 69 64 2d 3e 66 64 29 3b 0a 20  kInfo(id->fd);. 
29e0: 20 73 71 6c 69 74 65 4f 73 4c 65 61 76 65 4d 75   sqliteOsLeaveMu
29f0: 74 65 78 28 29 3b 0a 20 20 69 66 28 20 69 64 2d  tex();.  if( id-
2a00: 3e 70 4c 6f 63 6b 3d 3d 30 20 29 7b 0a 20 20 20  >pLock==0 ){.   
2a10: 20 63 6c 6f 73 65 28 69 64 2d 3e 66 64 29 3b 0a   close(id->fd);.
2a20: 20 20 20 20 72 65 74 75 72 6e 20 53 51 4c 49 54      return SQLIT
2a30: 45 5f 4e 4f 4d 45 4d 3b 0a 20 20 7d 0a 20 20 69  E_NOMEM;.  }.  i
2a40: 64 2d 3e 6c 6f 63 6b 65 64 20 3d 20 30 3b 0a 20  d->locked = 0;. 
2a50: 20 72 65 74 75 72 6e 20 53 51 4c 49 54 45 5f 4f   return SQLITE_O
2a60: 4b 3b 0a 23 65 6e 64 69 66 0a 23 69 66 20 4f 53  K;.#endif.#if OS
2a70: 5f 57 49 4e 0a 20 20 48 41 4e 44 4c 45 20 68 20  _WIN.  HANDLE h 
2a80: 3d 20 43 72 65 61 74 65 46 69 6c 65 28 7a 46 69  = CreateFile(zFi
2a90: 6c 65 6e 61 6d 65 2c 0a 20 20 20 20 20 47 45 4e  lename,.     GEN
2aa0: 45 52 49 43 5f 52 45 41 44 2c 0a 20 20 20 20 20  ERIC_READ,.     
2ab0: 30 2c 0a 20 20 20 20 20 4e 55 4c 4c 2c 0a 20 20  0,.     NULL,.  
2ac0: 20 20 20 4f 50 45 4e 5f 45 58 49 53 54 49 4e 47     OPEN_EXISTING
2ad0: 2c 0a 20 20 20 20 20 46 49 4c 45 5f 41 54 54 52  ,.     FILE_ATTR
2ae0: 49 42 55 54 45 5f 4e 4f 52 4d 41 4c 20 7c 20 46  IBUTE_NORMAL | F
2af0: 49 4c 45 5f 46 4c 41 47 5f 52 41 4e 44 4f 4d 5f  ILE_FLAG_RANDOM_
2b00: 41 43 43 45 53 53 2c 0a 20 20 20 20 20 4e 55 4c  ACCESS,.     NUL
2b10: 4c 0a 20 20 29 3b 0a 20 20 69 66 28 20 68 3d 3d  L.  );.  if( h==
2b20: 49 4e 56 41 4c 49 44 5f 48 41 4e 44 4c 45 5f 56  INVALID_HANDLE_V
2b30: 41 4c 55 45 20 29 7b 0a 20 20 20 20 72 65 74 75  ALUE ){.    retu
2b40: 72 6e 20 53 51 4c 49 54 45 5f 43 41 4e 54 4f 50  rn SQLITE_CANTOP
2b50: 45 4e 3b 0a 20 20 7d 0a 20 20 69 64 2d 3e 68 20  EN;.  }.  id->h 
2b60: 3d 20 68 3b 0a 20 20 69 64 2d 3e 6c 6f 63 6b 65  = h;.  id->locke
2b70: 64 20 3d 20 30 3b 0a 20 20 72 65 74 75 72 6e 20  d = 0;.  return 
2b80: 53 51 4c 49 54 45 5f 4f 4b 3b 0a 23 65 6e 64 69  SQLITE_OK;.#endi
2b90: 66 0a 7d 0a 0a 2f 2a 0a 2a 2a 20 43 72 65 61 74  f.}../*.** Creat
2ba0: 65 20 61 20 74 65 6d 70 6f 72 61 72 79 20 66 69  e a temporary fi
2bb0: 6c 65 20 6e 61 6d 65 20 69 6e 20 7a 42 75 66 2e  le name in zBuf.
2bc0: 20 20 7a 42 75 66 20 6d 75 73 74 20 62 65 20 62    zBuf must be b
2bd0: 69 67 20 65 6e 6f 75 67 68 20 74 6f 0a 2a 2a 20  ig enough to.** 
2be0: 68 6f 6c 64 20 61 74 20 6c 65 61 73 74 20 53 51  hold at least SQ
2bf0: 4c 49 54 45 5f 54 45 4d 50 4e 41 4d 45 5f 53 49  LITE_TEMPNAME_SI
2c00: 5a 45 20 63 68 61 72 61 63 74 65 72 73 2e 0a 2a  ZE characters..*
2c10: 2f 0a 69 6e 74 20 73 71 6c 69 74 65 4f 73 54 65  /.int sqliteOsTe
2c20: 6d 70 46 69 6c 65 4e 61 6d 65 28 63 68 61 72 20  mpFileName(char 
2c30: 2a 7a 42 75 66 29 7b 0a 23 69 66 20 4f 53 5f 55  *zBuf){.#if OS_U
2c40: 4e 49 58 0a 20 20 73 74 61 74 69 63 20 63 6f 6e  NIX.  static con
2c50: 73 74 20 63 68 61 72 20 2a 61 7a 44 69 72 73 5b  st char *azDirs[
2c60: 5d 20 3d 20 7b 0a 20 20 20 20 20 22 2e 22 2c 0a  ] = {.     ".",.
2c70: 20 20 20 20 20 22 2f 76 61 72 2f 74 6d 70 22 2c       "/var/tmp",
2c80: 0a 20 20 20 20 20 22 2f 75 73 72 2f 74 6d 70 22  .     "/usr/tmp"
2c90: 2c 0a 20 20 20 20 20 22 2f 74 6d 70 22 2c 0a 20  ,.     "/tmp",. 
2ca0: 20 7d 3b 0a 20 20 73 74 61 74 69 63 20 63 68 61   };.  static cha
2cb0: 72 20 7a 43 68 61 72 73 5b 5d 20 3d 0a 20 20 20  r zChars[] =.   
2cc0: 20 22 61 62 63 64 65 66 67 68 69 6a 6b 6c 6d 6e   "abcdefghijklmn
2cd0: 6f 70 71 72 73 74 75 76 77 78 79 7a 22 0a 20 20  opqrstuvwxyz".  
2ce0: 20 20 22 41 42 43 44 45 46 47 48 49 4a 4b 4c 4d    "ABCDEFGHIJKLM
2cf0: 4e 4f 50 51 52 53 54 55 56 57 58 59 5a 22 0a 20  NOPQRSTUVWXYZ". 
2d00: 20 20 20 22 30 31 32 33 34 35 36 37 38 39 22 3b     "0123456789";
2d10: 0a 20 20 69 6e 74 20 69 2c 20 6a 3b 0a 20 20 73  .  int i, j;.  s
2d20: 74 72 75 63 74 20 73 74 61 74 20 62 75 66 3b 0a  truct stat buf;.
2d30: 20 20 63 6f 6e 73 74 20 63 68 61 72 20 2a 7a 44    const char *zD
2d40: 69 72 20 3d 20 22 2e 22 3b 0a 20 20 66 6f 72 28  ir = ".";.  for(
2d50: 69 3d 30 3b 20 69 3c 73 69 7a 65 6f 66 28 61 7a  i=0; i<sizeof(az
2d60: 44 69 72 73 29 2f 73 69 7a 65 6f 66 28 61 7a 44  Dirs)/sizeof(azD
2d70: 69 72 73 5b 30 5d 29 3b 20 69 2b 2b 29 7b 0a 20  irs[0]); i++){. 
2d80: 20 20 20 69 66 28 20 73 74 61 74 28 61 7a 44 69     if( stat(azDi
2d90: 72 73 5b 69 5d 2c 20 26 62 75 66 29 20 29 20 63  rs[i], &buf) ) c
2da0: 6f 6e 74 69 6e 75 65 3b 0a 20 20 20 20 69 66 28  ontinue;.    if(
2db0: 20 21 53 5f 49 53 44 49 52 28 62 75 66 2e 73 74   !S_ISDIR(buf.st
2dc0: 5f 6d 6f 64 65 29 20 29 20 63 6f 6e 74 69 6e 75  _mode) ) continu
2dd0: 65 3b 0a 20 20 20 20 69 66 28 20 61 63 63 65 73  e;.    if( acces
2de0: 73 28 61 7a 44 69 72 73 5b 69 5d 2c 20 30 37 29  s(azDirs[i], 07)
2df0: 20 29 20 63 6f 6e 74 69 6e 75 65 3b 0a 20 20 20   ) continue;.   
2e00: 20 7a 44 69 72 20 3d 20 61 7a 44 69 72 73 5b 69   zDir = azDirs[i
2e10: 5d 3b 0a 20 20 20 20 62 72 65 61 6b 3b 0a 20 20  ];.    break;.  
2e20: 7d 0a 20 20 64 6f 7b 0a 20 20 20 20 73 70 72 69  }.  do{.    spri
2e30: 6e 74 66 28 7a 42 75 66 2c 20 22 25 73 2f 73 71  ntf(zBuf, "%s/sq
2e40: 6c 69 74 65 5f 22 2c 20 7a 44 69 72 29 3b 0a 20  lite_", zDir);. 
2e50: 20 20 20 6a 20 3d 20 73 74 72 6c 65 6e 28 7a 42     j = strlen(zB
2e60: 75 66 29 3b 0a 20 20 20 20 66 6f 72 28 69 3d 30  uf);.    for(i=0
2e70: 3b 20 69 3c 31 35 3b 20 69 2b 2b 29 7b 0a 20 20  ; i<15; i++){.  
2e80: 20 20 20 20 69 6e 74 20 6e 20 3d 20 73 71 6c 69      int n = sqli
2e90: 74 65 52 61 6e 64 6f 6d 42 79 74 65 28 29 20 25  teRandomByte() %
2ea0: 20 28 73 69 7a 65 6f 66 28 7a 43 68 61 72 73 29   (sizeof(zChars)
2eb0: 2d 31 29 3b 0a 20 20 20 20 20 20 7a 42 75 66 5b  -1);.      zBuf[
2ec0: 6a 2b 2b 5d 20 3d 20 7a 43 68 61 72 73 5b 6e 5d  j++] = zChars[n]
2ed0: 3b 0a 20 20 20 20 7d 0a 20 20 20 20 7a 42 75 66  ;.    }.    zBuf
2ee0: 5b 6a 5d 20 3d 20 30 3b 0a 20 20 7d 77 68 69 6c  [j] = 0;.  }whil
2ef0: 65 28 20 61 63 63 65 73 73 28 7a 42 75 66 2c 30  e( access(zBuf,0
2f00: 29 3d 3d 30 20 29 3b 0a 23 65 6e 64 69 66 0a 23  )==0 );.#endif.#
2f10: 69 66 20 4f 53 5f 57 49 4e 0a 20 20 73 74 61 74  if OS_WIN.  stat
2f20: 69 63 20 63 68 61 72 20 7a 43 68 61 72 73 5b 5d  ic char zChars[]
2f30: 20 3d 0a 20 20 20 20 22 61 62 63 64 65 66 67 68   =.    "abcdefgh
2f40: 69 6a 6b 6c 6d 6e 6f 70 71 72 73 74 75 76 77 78  ijklmnopqrstuvwx
2f50: 79 7a 22 0a 20 20 20 20 22 41 42 43 44 45 46 47  yz".    "ABCDEFG
2f60: 48 49 4a 4b 4c 4d 4e 4f 50 51 52 53 54 55 56 57  HIJKLMNOPQRSTUVW
2f70: 58 59 5a 22 0a 20 20 20 20 22 30 31 32 33 34 35  XYZ".    "012345
2f80: 36 37 38 39 22 3b 0a 20 20 69 6e 74 20 69 2c 20  6789";.  int i, 
2f90: 6a 3b 0a 20 20 63 68 61 72 20 7a 54 65 6d 70 50  j;.  char zTempP
2fa0: 61 74 68 5b 53 51 4c 49 54 45 5f 54 45 4d 50 4e  ath[SQLITE_TEMPN
2fb0: 41 4d 45 5f 53 49 5a 45 5d 3b 0a 20 20 47 65 74  AME_SIZE];.  Get
2fc0: 54 65 6d 70 50 61 74 68 28 53 51 4c 49 54 45 5f  TempPath(SQLITE_
2fd0: 54 45 4d 50 4e 41 4d 45 5f 53 49 5a 45 2d 33 30  TEMPNAME_SIZE-30
2fe0: 2c 20 7a 54 65 6d 70 50 61 74 68 29 3b 0a 20 20  , zTempPath);.  
2ff0: 66 6f 72 28 3b 3b 29 7b 0a 20 20 20 20 73 70 72  for(;;){.    spr
3000: 69 6e 74 66 28 7a 42 75 66 2c 20 22 25 73 2f 73  intf(zBuf, "%s/s
3010: 71 6c 69 74 65 5f 22 2c 20 7a 54 65 6d 70 50 61  qlite_", zTempPa
3020: 74 68 29 3b 0a 20 20 20 20 6a 20 3d 20 73 74 72  th);.    j = str
3030: 6c 65 6e 28 7a 42 75 66 29 3b 0a 20 20 20 20 66  len(zBuf);.    f
3040: 6f 72 28 69 3d 30 3b 20 69 3c 31 35 3b 20 69 2b  or(i=0; i<15; i+
3050: 2b 29 7b 0a 20 20 20 20 20 20 69 6e 74 20 6e 20  +){.      int n 
3060: 3d 20 73 71 6c 69 74 65 52 61 6e 64 6f 6d 42 79  = sqliteRandomBy
3070: 74 65 28 29 20 25 20 73 69 7a 65 6f 66 28 7a 43  te() % sizeof(zC
3080: 68 61 72 73 29 3b 0a 20 20 20 20 20 20 7a 42 75  hars);.      zBu
3090: 66 5b 6a 2b 2b 5d 20 3d 20 7a 43 68 61 72 73 5b  f[j++] = zChars[
30a0: 6e 5d 3b 0a 20 20 20 20 7d 0a 20 20 20 20 7a 42  n];.    }.    zB
30b0: 75 66 5b 6a 5d 20 3d 20 30 3b 0a 20 20 20 20 69  uf[j] = 0;.    i
30c0: 66 28 20 21 73 71 6c 69 74 65 4f 73 46 69 6c 65  f( !sqliteOsFile
30d0: 45 78 69 73 74 73 28 7a 42 75 66 29 20 29 20 62  Exists(zBuf) ) b
30e0: 72 65 61 6b 3b 0a 20 20 7d 0a 23 65 6e 64 69 66  reak;.  }.#endif
30f0: 0a 20 20 72 65 74 75 72 6e 20 53 51 4c 49 54 45  .  return SQLITE
3100: 5f 4f 4b 3b 20 0a 7d 0a 0a 2f 2a 0a 2a 2a 20 43  _OK; .}../*.** C
3110: 6c 6f 73 65 20 61 20 66 69 6c 65 0a 2a 2f 0a 69  lose a file.*/.i
3120: 6e 74 20 73 71 6c 69 74 65 4f 73 43 6c 6f 73 65  nt sqliteOsClose
3130: 28 4f 73 46 69 6c 65 20 2a 69 64 29 7b 0a 23 69  (OsFile *id){.#i
3140: 66 20 4f 53 5f 55 4e 49 58 0a 20 20 63 6c 6f 73  f OS_UNIX.  clos
3150: 65 28 69 64 2d 3e 66 64 29 3b 0a 20 20 73 71 6c  e(id->fd);.  sql
3160: 69 74 65 4f 73 45 6e 74 65 72 4d 75 74 65 78 28  iteOsEnterMutex(
3170: 29 3b 0a 20 20 72 65 6c 65 61 73 65 4c 6f 63 6b  );.  releaseLock
3180: 49 6e 66 6f 28 69 64 2d 3e 70 4c 6f 63 6b 29 3b  Info(id->pLock);
3190: 0a 20 20 73 71 6c 69 74 65 4f 73 4c 65 61 76 65  .  sqliteOsLeave
31a0: 4d 75 74 65 78 28 29 3b 0a 20 20 72 65 74 75 72  Mutex();.  retur
31b0: 6e 20 53 51 4c 49 54 45 5f 4f 4b 3b 0a 23 65 6e  n SQLITE_OK;.#en
31c0: 64 69 66 0a 23 69 66 20 4f 53 5f 57 49 4e 0a 20  dif.#if OS_WIN. 
31d0: 20 43 6c 6f 73 65 48 61 6e 64 6c 65 28 69 64 2d   CloseHandle(id-
31e0: 3e 68 29 3b 0a 20 20 72 65 74 75 72 6e 20 53 51  >h);.  return SQ
31f0: 4c 49 54 45 5f 4f 4b 3b 0a 23 65 6e 64 69 66 0a  LITE_OK;.#endif.
3200: 7d 0a 0a 2f 2a 0a 2a 2a 20 52 65 61 64 20 64 61  }../*.** Read da
3210: 74 61 20 66 72 6f 6d 20 61 20 66 69 6c 65 20 69  ta from a file i
3220: 6e 74 6f 20 61 20 62 75 66 66 65 72 2e 20 20 52  nto a buffer.  R
3230: 65 74 75 72 6e 20 53 51 4c 49 54 45 5f 4f 4b 20  eturn SQLITE_OK 
3240: 69 66 20 61 6c 6c 0a 2a 2a 20 62 79 74 65 73 20  if all.** bytes 
3250: 77 65 72 65 20 72 65 61 64 20 73 75 63 63 65 73  were read succes
3260: 73 66 75 6c 6c 79 20 61 6e 64 20 53 51 4c 49 54  sfully and SQLIT
3270: 45 5f 49 4f 45 52 52 20 69 66 20 61 6e 79 74 68  E_IOERR if anyth
3280: 69 6e 67 20 67 6f 65 73 0a 2a 2a 20 77 72 6f 6e  ing goes.** wron
3290: 67 2e 0a 2a 2f 0a 69 6e 74 20 73 71 6c 69 74 65  g..*/.int sqlite
32a0: 4f 73 52 65 61 64 28 4f 73 46 69 6c 65 20 2a 69  OsRead(OsFile *i
32b0: 64 2c 20 76 6f 69 64 20 2a 70 42 75 66 2c 20 69  d, void *pBuf, i
32c0: 6e 74 20 61 6d 74 29 7b 0a 23 69 66 20 4f 53 5f  nt amt){.#if OS_
32d0: 55 4e 49 58 0a 20 20 69 6e 74 20 67 6f 74 3b 0a  UNIX.  int got;.
32e0: 20 20 53 69 6d 75 6c 61 74 65 49 4f 45 72 72 6f    SimulateIOErro
32f0: 72 28 53 51 4c 49 54 45 5f 49 4f 45 52 52 29 3b  r(SQLITE_IOERR);
3300: 0a 20 20 67 6f 74 20 3d 20 72 65 61 64 28 69 64  .  got = read(id
3310: 2d 3e 66 64 2c 20 70 42 75 66 2c 20 61 6d 74 29  ->fd, pBuf, amt)
3320: 3b 0a 20 20 69 66 28 20 67 6f 74 3c 30 20 29 20  ;.  if( got<0 ) 
3330: 67 6f 74 20 3d 20 30 3b 0a 20 20 72 65 74 75 72  got = 0;.  retur
3340: 6e 20 67 6f 74 3d 3d 61 6d 74 20 3f 20 53 51 4c  n got==amt ? SQL
3350: 49 54 45 5f 4f 4b 20 3a 20 53 51 4c 49 54 45 5f  ITE_OK : SQLITE_
3360: 49 4f 45 52 52 3b 0a 23 65 6e 64 69 66 0a 23 69  IOERR;.#endif.#i
3370: 66 20 4f 53 5f 57 49 4e 0a 20 20 44 57 4f 52 44  f OS_WIN.  DWORD
3380: 20 67 6f 74 3b 0a 20 20 53 69 6d 75 6c 61 74 65   got;.  Simulate
3390: 49 4f 45 72 72 6f 72 28 53 51 4c 49 54 45 5f 49  IOError(SQLITE_I
33a0: 4f 45 52 52 29 3b 0a 20 20 69 66 28 20 21 52 65  OERR);.  if( !Re
33b0: 61 64 46 69 6c 65 28 69 64 2d 3e 68 2c 20 70 42  adFile(id->h, pB
33c0: 75 66 2c 20 61 6d 74 2c 20 26 67 6f 74 2c 20 30  uf, amt, &got, 0
33d0: 29 20 29 7b 0a 20 20 20 20 67 6f 74 20 3d 20 30  ) ){.    got = 0
33e0: 3b 0a 20 20 7d 0a 20 20 72 65 74 75 72 6e 20 67  ;.  }.  return g
33f0: 6f 74 3d 3d 61 6d 74 20 3f 20 53 51 4c 49 54 45  ot==amt ? SQLITE
3400: 5f 4f 4b 20 3a 20 53 51 4c 49 54 45 5f 49 4f 45  _OK : SQLITE_IOE
3410: 52 52 3b 0a 23 65 6e 64 69 66 0a 7d 0a 0a 2f 2a  RR;.#endif.}../*
3420: 0a 2a 2a 20 57 72 69 74 65 20 64 61 74 61 20 66  .** Write data f
3430: 72 6f 6d 20 61 20 62 75 66 66 65 72 20 69 6e 74  rom a buffer int
3440: 6f 20 61 20 66 69 6c 65 2e 20 20 52 65 74 75 72  o a file.  Retur
3450: 6e 20 53 51 4c 49 54 45 5f 4f 4b 20 6f 6e 20 73  n SQLITE_OK on s
3460: 75 63 63 65 73 73 0a 2a 2a 20 6f 72 20 73 6f 6d  uccess.** or som
3470: 65 20 6f 74 68 65 72 20 65 72 72 6f 72 20 63 6f  e other error co
3480: 64 65 20 6f 6e 20 66 61 69 6c 75 72 65 2e 0a 2a  de on failure..*
3490: 2f 0a 69 6e 74 20 73 71 6c 69 74 65 4f 73 57 72  /.int sqliteOsWr
34a0: 69 74 65 28 4f 73 46 69 6c 65 20 2a 69 64 2c 20  ite(OsFile *id, 
34b0: 63 6f 6e 73 74 20 76 6f 69 64 20 2a 70 42 75 66  const void *pBuf
34c0: 2c 20 69 6e 74 20 61 6d 74 29 7b 0a 23 69 66 20  , int amt){.#if 
34d0: 4f 53 5f 55 4e 49 58 0a 20 20 69 6e 74 20 77 72  OS_UNIX.  int wr
34e0: 6f 74 65 3b 0a 20 20 53 69 6d 75 6c 61 74 65 49  ote;.  SimulateI
34f0: 4f 45 72 72 6f 72 28 53 51 4c 49 54 45 5f 49 4f  OError(SQLITE_IO
3500: 45 52 52 29 3b 0a 20 20 77 72 6f 74 65 20 3d 20  ERR);.  wrote = 
3510: 77 72 69 74 65 28 69 64 2d 3e 66 64 2c 20 70 42  write(id->fd, pB
3520: 75 66 2c 20 61 6d 74 29 3b 0a 20 20 69 66 28 20  uf, amt);.  if( 
3530: 77 72 6f 74 65 3c 61 6d 74 20 29 20 72 65 74 75  wrote<amt ) retu
3540: 72 6e 20 53 51 4c 49 54 45 5f 46 55 4c 4c 3b 0a  rn SQLITE_FULL;.
3550: 20 20 72 65 74 75 72 6e 20 53 51 4c 49 54 45 5f    return SQLITE_
3560: 4f 4b 3b 0a 23 65 6e 64 69 66 0a 23 69 66 20 4f  OK;.#endif.#if O
3570: 53 5f 57 49 4e 0a 20 20 44 57 4f 52 44 20 77 72  S_WIN.  DWORD wr
3580: 6f 74 65 3b 0a 20 20 53 69 6d 75 6c 61 74 65 49  ote;.  SimulateI
3590: 4f 45 72 72 6f 72 28 53 51 4c 49 54 45 5f 49 4f  OError(SQLITE_IO
35a0: 45 52 52 29 3b 0a 20 20 69 66 28 20 21 57 72 69  ERR);.  if( !Wri
35b0: 74 65 46 69 6c 65 28 69 64 2d 3e 68 2c 20 70 42  teFile(id->h, pB
35c0: 75 66 2c 20 61 6d 74 2c 20 26 77 72 6f 74 65 2c  uf, amt, &wrote,
35d0: 20 30 29 20 7c 7c 20 28 69 6e 74 29 77 72 6f 74   0) || (int)wrot
35e0: 65 3c 61 6d 74 20 29 7b 0a 20 20 20 20 72 65 74  e<amt ){.    ret
35f0: 75 72 6e 20 53 51 4c 49 54 45 5f 46 55 4c 4c 3b  urn SQLITE_FULL;
3600: 0a 20 20 7d 0a 20 20 72 65 74 75 72 6e 20 53 51  .  }.  return SQ
3610: 4c 49 54 45 5f 4f 4b 3b 0a 23 65 6e 64 69 66 0a  LITE_OK;.#endif.
3620: 7d 0a 0a 2f 2a 0a 2a 2a 20 4d 6f 76 65 20 74 68  }../*.** Move th
3630: 65 20 72 65 61 64 2f 77 72 69 74 65 20 70 6f 69  e read/write poi
3640: 6e 74 65 72 20 69 6e 20 61 20 66 69 6c 65 2e 0a  nter in a file..
3650: 2a 2f 0a 69 6e 74 20 73 71 6c 69 74 65 4f 73 53  */.int sqliteOsS
3660: 65 65 6b 28 4f 73 46 69 6c 65 20 2a 69 64 2c 20  eek(OsFile *id, 
3670: 69 6e 74 20 6f 66 66 73 65 74 29 7b 0a 23 69 66  int offset){.#if
3680: 20 4f 53 5f 55 4e 49 58 0a 20 20 6c 73 65 65 6b   OS_UNIX.  lseek
3690: 28 69 64 2d 3e 66 64 2c 20 6f 66 66 73 65 74 2c  (id->fd, offset,
36a0: 20 53 45 45 4b 5f 53 45 54 29 3b 0a 20 20 72 65   SEEK_SET);.  re
36b0: 74 75 72 6e 20 53 51 4c 49 54 45 5f 4f 4b 3b 0a  turn SQLITE_OK;.
36c0: 23 65 6e 64 69 66 0a 23 69 66 20 4f 53 5f 57 49  #endif.#if OS_WI
36d0: 4e 0a 20 20 53 65 74 46 69 6c 65 50 6f 69 6e 74  N.  SetFilePoint
36e0: 65 72 28 69 64 2d 3e 68 2c 20 6f 66 66 73 65 74  er(id->h, offset
36f0: 2c 20 30 2c 20 46 49 4c 45 5f 42 45 47 49 4e 29  , 0, FILE_BEGIN)
3700: 3b 0a 20 20 72 65 74 75 72 6e 20 53 51 4c 49 54  ;.  return SQLIT
3710: 45 5f 4f 4b 3b 0a 23 65 6e 64 69 66 0a 7d 0a 0a  E_OK;.#endif.}..
3720: 2f 2a 0a 2a 2a 20 4d 61 6b 65 20 73 75 72 65 20  /*.** Make sure 
3730: 61 6c 6c 20 77 72 69 74 65 73 20 74 6f 20 61 20  all writes to a 
3740: 70 61 72 74 69 63 75 6c 61 72 20 66 69 6c 65 20  particular file 
3750: 61 72 65 20 63 6f 6d 6d 69 74 74 65 64 20 74 6f  are committed to
3760: 20 64 69 73 6b 2e 0a 2a 2f 0a 69 6e 74 20 73 71   disk..*/.int sq
3770: 6c 69 74 65 4f 73 53 79 6e 63 28 4f 73 46 69 6c  liteOsSync(OsFil
3780: 65 20 2a 69 64 29 7b 0a 20 20 53 69 6d 75 6c 61  e *id){.  Simula
3790: 74 65 49 4f 45 72 72 6f 72 28 53 51 4c 49 54 45  teIOError(SQLITE
37a0: 5f 49 4f 45 52 52 29 3b 0a 23 69 66 20 4f 53 5f  _IOERR);.#if OS_
37b0: 55 4e 49 58 0a 20 20 72 65 74 75 72 6e 20 66 73  UNIX.  return fs
37c0: 79 6e 63 28 69 64 2d 3e 66 64 29 3d 3d 30 20 3f  ync(id->fd)==0 ?
37d0: 20 53 51 4c 49 54 45 5f 4f 4b 20 3a 20 53 51 4c   SQLITE_OK : SQL
37e0: 49 54 45 5f 49 4f 45 52 52 3b 0a 23 65 6e 64 69  ITE_IOERR;.#endi
37f0: 66 0a 23 69 66 20 4f 53 5f 57 49 4e 0a 20 20 72  f.#if OS_WIN.  r
3800: 65 74 75 72 6e 20 46 6c 75 73 68 46 69 6c 65 42  eturn FlushFileB
3810: 75 66 66 65 72 73 28 69 64 2d 3e 68 29 20 3f 20  uffers(id->h) ? 
3820: 53 51 4c 49 54 45 5f 4f 4b 20 3a 20 53 51 4c 49  SQLITE_OK : SQLI
3830: 54 45 5f 49 4f 45 52 52 3b 0a 23 65 6e 64 69 66  TE_IOERR;.#endif
3840: 0a 7d 0a 0a 2f 2a 0a 2a 2a 20 54 72 75 6e 63 61  .}../*.** Trunca
3850: 74 65 20 61 6e 20 6f 70 65 6e 20 66 69 6c 65 20  te an open file 
3860: 74 6f 20 61 20 73 70 65 63 69 66 69 65 64 20 73  to a specified s
3870: 69 7a 65 0a 2a 2f 0a 69 6e 74 20 73 71 6c 69 74  ize.*/.int sqlit
3880: 65 4f 73 54 72 75 6e 63 61 74 65 28 4f 73 46 69  eOsTruncate(OsFi
3890: 6c 65 20 2a 69 64 2c 20 69 6e 74 20 6e 42 79 74  le *id, int nByt
38a0: 65 29 7b 0a 20 20 53 69 6d 75 6c 61 74 65 49 4f  e){.  SimulateIO
38b0: 45 72 72 6f 72 28 53 51 4c 49 54 45 5f 49 4f 45  Error(SQLITE_IOE
38c0: 52 52 29 3b 0a 23 69 66 20 4f 53 5f 55 4e 49 58  RR);.#if OS_UNIX
38d0: 0a 20 20 72 65 74 75 72 6e 20 66 74 72 75 6e 63  .  return ftrunc
38e0: 61 74 65 28 69 64 2d 3e 66 64 2c 20 6e 42 79 74  ate(id->fd, nByt
38f0: 65 29 3d 3d 30 20 3f 20 53 51 4c 49 54 45 5f 4f  e)==0 ? SQLITE_O
3900: 4b 20 3a 20 53 51 4c 49 54 45 5f 49 4f 45 52 52  K : SQLITE_IOERR
3910: 3b 0a 23 65 6e 64 69 66 0a 23 69 66 20 4f 53 5f  ;.#endif.#if OS_
3920: 57 49 4e 0a 20 20 53 65 74 46 69 6c 65 50 6f 69  WIN.  SetFilePoi
3930: 6e 74 65 72 28 69 64 2d 3e 68 2c 20 6e 42 79 74  nter(id->h, nByt
3940: 65 2c 20 30 2c 20 46 49 4c 45 5f 42 45 47 49 4e  e, 0, FILE_BEGIN
3950: 29 3b 0a 20 20 53 65 74 45 6e 64 4f 66 46 69 6c  );.  SetEndOfFil
3960: 65 28 69 64 2d 3e 68 29 3b 0a 20 20 72 65 74 75  e(id->h);.  retu
3970: 72 6e 20 53 51 4c 49 54 45 5f 4f 4b 3b 0a 23 65  rn SQLITE_OK;.#e
3980: 6e 64 69 66 0a 7d 0a 0a 2f 2a 0a 2a 2a 20 44 65  ndif.}../*.** De
3990: 74 65 72 6d 69 6e 65 20 74 68 65 20 63 75 72 72  termine the curr
39a0: 65 6e 74 20 73 69 7a 65 20 6f 66 20 61 20 66 69  ent size of a fi
39b0: 6c 65 20 69 6e 20 62 79 74 65 73 0a 2a 2f 0a 69  le in bytes.*/.i
39c0: 6e 74 20 73 71 6c 69 74 65 4f 73 46 69 6c 65 53  nt sqliteOsFileS
39d0: 69 7a 65 28 4f 73 46 69 6c 65 20 2a 69 64 2c 20  ize(OsFile *id, 
39e0: 69 6e 74 20 2a 70 53 69 7a 65 29 7b 0a 23 69 66  int *pSize){.#if
39f0: 20 4f 53 5f 55 4e 49 58 0a 20 20 73 74 72 75 63   OS_UNIX.  struc
3a00: 74 20 73 74 61 74 20 62 75 66 3b 0a 20 20 53 69  t stat buf;.  Si
3a10: 6d 75 6c 61 74 65 49 4f 45 72 72 6f 72 28 53 51  mulateIOError(SQ
3a20: 4c 49 54 45 5f 49 4f 45 52 52 29 3b 0a 20 20 69  LITE_IOERR);.  i
3a30: 66 28 20 66 73 74 61 74 28 69 64 2d 3e 66 64 2c  f( fstat(id->fd,
3a40: 20 26 62 75 66 29 21 3d 30 20 29 7b 0a 20 20 20   &buf)!=0 ){.   
3a50: 20 72 65 74 75 72 6e 20 53 51 4c 49 54 45 5f 49   return SQLITE_I
3a60: 4f 45 52 52 3b 0a 20 20 7d 0a 20 20 2a 70 53 69  OERR;.  }.  *pSi
3a70: 7a 65 20 3d 20 62 75 66 2e 73 74 5f 73 69 7a 65  ze = buf.st_size
3a80: 3b 0a 20 20 72 65 74 75 72 6e 20 53 51 4c 49 54  ;.  return SQLIT
3a90: 45 5f 4f 4b 3b 0a 23 65 6e 64 69 66 0a 23 69 66  E_OK;.#endif.#if
3aa0: 20 4f 53 5f 57 49 4e 0a 20 20 53 69 6d 75 6c 61   OS_WIN.  Simula
3ab0: 74 65 49 4f 45 72 72 6f 72 28 53 51 4c 49 54 45  teIOError(SQLITE
3ac0: 5f 49 4f 45 52 52 29 3b 0a 20 20 2a 70 53 69 7a  _IOERR);.  *pSiz
3ad0: 65 20 3d 20 47 65 74 46 69 6c 65 53 69 7a 65 28  e = GetFileSize(
3ae0: 69 64 2d 3e 68 2c 20 30 29 3b 0a 20 20 72 65 74  id->h, 0);.  ret
3af0: 75 72 6e 20 53 51 4c 49 54 45 5f 4f 4b 3b 0a 23  urn SQLITE_OK;.#
3b00: 65 6e 64 69 66 0a 7d 0a 0a 0a 2f 2a 0a 2a 2a 20  endif.}.../*.** 
3b10: 43 68 61 6e 67 65 20 74 68 65 20 73 74 61 74 75  Change the statu
3b20: 73 20 6f 66 20 74 68 65 20 6c 6f 63 6b 20 6f 6e  s of the lock on
3b30: 20 74 68 65 20 66 69 6c 65 20 22 69 64 22 20 74   the file "id" t
3b40: 6f 20 62 65 20 61 20 72 65 61 64 6c 6f 63 6b 2e  o be a readlock.
3b50: 0a 2a 2a 20 49 66 20 74 68 65 20 66 69 6c 65 20  .** If the file 
3b60: 77 61 73 20 77 72 69 74 65 20 6c 6f 63 6b 65 64  was write locked
3b70: 2c 20 74 68 65 6e 20 74 68 69 73 20 72 65 64 75  , then this redu
3b80: 63 65 73 20 74 68 65 20 6c 6f 63 6b 20 74 6f 20  ces the lock to 
3b90: 61 20 72 65 61 64 2e 0a 2a 2a 20 49 66 20 74 68  a read..** If th
3ba0: 65 20 66 69 6c 65 20 77 61 73 20 72 65 61 64 20  e file was read 
3bb0: 6c 6f 63 6b 65 64 2c 20 74 68 65 6e 20 74 68 69  locked, then thi
3bc0: 73 20 61 63 71 75 69 72 65 73 20 61 20 6e 65 77  s acquires a new
3bd0: 20 72 65 61 64 20 6c 6f 63 6b 2e 0a 2a 2a 0a 2a   read lock..**.*
3be0: 2a 20 52 65 74 75 72 6e 20 53 51 4c 49 54 45 5f  * Return SQLITE_
3bf0: 4f 4b 20 6f 6e 20 73 75 63 63 65 73 73 20 61 6e  OK on success an
3c00: 64 20 53 51 4c 49 54 45 5f 42 55 53 59 20 6f 6e  d SQLITE_BUSY on
3c10: 20 66 61 69 6c 75 72 65 2e 0a 2a 2f 0a 69 6e 74   failure..*/.int
3c20: 20 73 71 6c 69 74 65 4f 73 52 65 61 64 4c 6f 63   sqliteOsReadLoc
3c30: 6b 28 4f 73 46 69 6c 65 20 2a 69 64 29 7b 0a 23  k(OsFile *id){.#
3c40: 69 66 20 4f 53 5f 55 4e 49 58 0a 20 20 69 6e 74  if OS_UNIX.  int
3c50: 20 72 63 3b 0a 20 20 73 71 6c 69 74 65 4f 73 45   rc;.  sqliteOsE
3c60: 6e 74 65 72 4d 75 74 65 78 28 29 3b 0a 20 20 69  nterMutex();.  i
3c70: 66 28 20 69 64 2d 3e 70 4c 6f 63 6b 2d 3e 63 6e  f( id->pLock->cn
3c80: 74 3e 30 20 29 7b 0a 20 20 20 20 69 66 28 20 21  t>0 ){.    if( !
3c90: 69 64 2d 3e 6c 6f 63 6b 65 64 20 29 7b 0a 20 20  id->locked ){.  
3ca0: 20 20 20 20 69 64 2d 3e 70 4c 6f 63 6b 2d 3e 63      id->pLock->c
3cb0: 6e 74 2b 2b 3b 0a 20 20 20 20 20 20 69 64 2d 3e  nt++;.      id->
3cc0: 6c 6f 63 6b 65 64 20 3d 20 31 3b 0a 20 20 20 20  locked = 1;.    
3cd0: 7d 0a 20 20 20 20 72 63 20 3d 20 53 51 4c 49 54  }.    rc = SQLIT
3ce0: 45 5f 4f 4b 3b 0a 20 20 7d 65 6c 73 65 20 69 66  E_OK;.  }else if
3cf0: 28 20 69 64 2d 3e 6c 6f 63 6b 65 64 20 7c 7c 20  ( id->locked || 
3d00: 69 64 2d 3e 70 4c 6f 63 6b 2d 3e 63 6e 74 3d 3d  id->pLock->cnt==
3d10: 30 20 29 7b 0a 20 20 20 20 73 74 72 75 63 74 20  0 ){.    struct 
3d20: 66 6c 6f 63 6b 20 6c 6f 63 6b 3b 0a 20 20 20 20  flock lock;.    
3d30: 6c 6f 63 6b 2e 6c 5f 74 79 70 65 20 3d 20 46 5f  lock.l_type = F_
3d40: 52 44 4c 43 4b 3b 0a 20 20 20 20 6c 6f 63 6b 2e  RDLCK;.    lock.
3d50: 6c 5f 77 68 65 6e 63 65 20 3d 20 53 45 45 4b 5f  l_whence = SEEK_
3d60: 53 45 54 3b 0a 20 20 20 20 6c 6f 63 6b 2e 6c 5f  SET;.    lock.l_
3d70: 73 74 61 72 74 20 3d 20 6c 6f 63 6b 2e 6c 5f 6c  start = lock.l_l
3d80: 65 6e 20 3d 20 30 4c 3b 0a 20 20 20 20 69 66 28  en = 0L;.    if(
3d90: 20 66 63 6e 74 6c 28 69 64 2d 3e 66 64 2c 20 46   fcntl(id->fd, F
3da0: 5f 53 45 54 4c 4b 2c 20 26 6c 6f 63 6b 29 21 3d  _SETLK, &lock)!=
3db0: 30 20 29 7b 0a 20 20 20 20 20 20 72 63 20 3d 20  0 ){.      rc = 
3dc0: 53 51 4c 49 54 45 5f 42 55 53 59 3b 0a 20 20 20  SQLITE_BUSY;.   
3dd0: 20 7d 65 6c 73 65 7b 0a 20 20 20 20 20 20 72 63   }else{.      rc
3de0: 20 3d 20 53 51 4c 49 54 45 5f 4f 4b 3b 0a 20 20   = SQLITE_OK;.  
3df0: 20 20 20 20 69 64 2d 3e 70 4c 6f 63 6b 2d 3e 63      id->pLock->c
3e00: 6e 74 20 3d 20 31 3b 0a 20 20 20 20 20 20 69 64  nt = 1;.      id
3e10: 2d 3e 6c 6f 63 6b 65 64 20 3d 20 31 3b 0a 20 20  ->locked = 1;.  
3e20: 20 20 7d 0a 20 20 7d 65 6c 73 65 7b 0a 20 20 20    }.  }else{.   
3e30: 20 72 63 20 3d 20 53 51 4c 49 54 45 5f 42 55 53   rc = SQLITE_BUS
3e40: 59 3b 0a 20 20 7d 0a 20 20 73 71 6c 69 74 65 4f  Y;.  }.  sqliteO
3e50: 73 4c 65 61 76 65 4d 75 74 65 78 28 29 3b 0a 20  sLeaveMutex();. 
3e60: 20 72 65 74 75 72 6e 20 72 63 3b 0a 23 65 6e 64   return rc;.#end
3e70: 69 66 0a 23 69 66 20 4f 53 5f 57 49 4e 0a 20 20  if.#if OS_WIN.  
3e80: 69 6e 74 20 72 63 3b 0a 20 20 69 66 28 20 69 64  int rc;.  if( id
3e90: 2d 3e 6c 6f 63 6b 65 64 20 29 7b 0a 20 20 20 20  ->locked ){.    
3ea0: 72 63 20 3d 20 53 51 4c 49 54 45 5f 4f 4b 3b 0a  rc = SQLITE_OK;.
3eb0: 20 20 7d 65 6c 73 65 20 69 66 28 20 4c 6f 63 6b    }else if( Lock
3ec0: 46 69 6c 65 28 69 64 2d 3e 68 2c 20 30 2c 20 30  File(id->h, 0, 0
3ed0: 2c 20 31 30 32 34 2c 20 30 29 20 29 7b 0a 20 20  , 1024, 0) ){.  
3ee0: 20 20 72 63 20 3d 20 53 51 4c 49 54 45 5f 4f 4b    rc = SQLITE_OK
3ef0: 3b 0a 20 20 20 20 69 64 2d 3e 6c 6f 63 6b 65 64  ;.    id->locked
3f00: 20 3d 20 31 3b 0a 20 20 7d 65 6c 73 65 7b 0a 20   = 1;.  }else{. 
3f10: 20 20 20 72 63 20 3d 20 53 51 4c 49 54 45 5f 42     rc = SQLITE_B
3f20: 55 53 59 3b 0a 20 20 7d 0a 20 20 72 65 74 75 72  USY;.  }.  retur
3f30: 6e 20 72 63 3b 0a 23 65 6e 64 69 66 0a 7d 0a 0a  n rc;.#endif.}..
3f40: 2f 2a 0a 2a 2a 20 43 68 61 6e 67 65 20 74 68 65  /*.** Change the
3f50: 20 6c 6f 63 6b 20 73 74 61 74 75 73 20 74 6f 20   lock status to 
3f60: 62 65 20 61 6e 20 65 78 63 6c 75 73 69 76 65 20  be an exclusive 
3f70: 6f 72 20 77 72 69 74 65 20 6c 6f 63 6b 2e 20 20  or write lock.  
3f80: 52 65 74 75 72 6e 0a 2a 2a 20 53 51 4c 49 54 45  Return.** SQLITE
3f90: 5f 4f 4b 20 6f 6e 20 73 75 63 63 65 73 73 20 61  _OK on success a
3fa0: 6e 64 20 53 51 4c 49 54 45 5f 42 55 53 59 20 6f  nd SQLITE_BUSY o
3fb0: 6e 20 61 20 66 61 69 6c 75 72 65 2e 0a 2a 2f 0a  n a failure..*/.
3fc0: 69 6e 74 20 73 71 6c 69 74 65 4f 73 57 72 69 74  int sqliteOsWrit
3fd0: 65 4c 6f 63 6b 28 4f 73 46 69 6c 65 20 2a 69 64  eLock(OsFile *id
3fe0: 29 7b 0a 23 69 66 20 4f 53 5f 55 4e 49 58 0a 20  ){.#if OS_UNIX. 
3ff0: 20 69 6e 74 20 72 63 3b 0a 20 20 73 71 6c 69 74   int rc;.  sqlit
4000: 65 4f 73 45 6e 74 65 72 4d 75 74 65 78 28 29 3b  eOsEnterMutex();
4010: 0a 20 20 69 66 28 20 69 64 2d 3e 70 4c 6f 63 6b  .  if( id->pLock
4020: 2d 3e 63 6e 74 3d 3d 30 20 7c 7c 20 28 69 64 2d  ->cnt==0 || (id-
4030: 3e 70 4c 6f 63 6b 2d 3e 63 6e 74 3d 3d 31 20 26  >pLock->cnt==1 &
4040: 26 20 69 64 2d 3e 6c 6f 63 6b 65 64 3d 3d 31 29  & id->locked==1)
4050: 20 29 7b 0a 20 20 20 20 73 74 72 75 63 74 20 66   ){.    struct f
4060: 6c 6f 63 6b 20 6c 6f 63 6b 3b 0a 20 20 20 20 6c  lock lock;.    l
4070: 6f 63 6b 2e 6c 5f 74 79 70 65 20 3d 20 46 5f 57  ock.l_type = F_W
4080: 52 4c 43 4b 3b 0a 20 20 20 20 6c 6f 63 6b 2e 6c  RLCK;.    lock.l
4090: 5f 77 68 65 6e 63 65 20 3d 20 53 45 45 4b 5f 53  _whence = SEEK_S
40a0: 45 54 3b 0a 20 20 20 20 6c 6f 63 6b 2e 6c 5f 73  ET;.    lock.l_s
40b0: 74 61 72 74 20 3d 20 6c 6f 63 6b 2e 6c 5f 6c 65  tart = lock.l_le
40c0: 6e 20 3d 20 30 4c 3b 0a 20 20 20 20 69 66 28 20  n = 0L;.    if( 
40d0: 66 63 6e 74 6c 28 69 64 2d 3e 66 64 2c 20 46 5f  fcntl(id->fd, F_
40e0: 53 45 54 4c 4b 2c 20 26 6c 6f 63 6b 29 21 3d 30  SETLK, &lock)!=0
40f0: 20 29 7b 0a 20 20 20 20 20 20 72 63 20 3d 20 53   ){.      rc = S
4100: 51 4c 49 54 45 5f 42 55 53 59 3b 0a 20 20 20 20  QLITE_BUSY;.    
4110: 7d 65 6c 73 65 7b 0a 20 20 20 20 20 20 72 63 20  }else{.      rc 
4120: 3d 20 53 51 4c 49 54 45 5f 4f 4b 3b 0a 20 20 20  = SQLITE_OK;.   
4130: 20 20 20 69 64 2d 3e 70 4c 6f 63 6b 2d 3e 63 6e     id->pLock->cn
4140: 74 20 3d 20 2d 31 3b 0a 20 20 20 20 20 20 69 64  t = -1;.      id
4150: 2d 3e 6c 6f 63 6b 65 64 20 3d 20 31 3b 0a 20 20  ->locked = 1;.  
4160: 20 20 7d 0a 20 20 7d 65 6c 73 65 7b 0a 20 20 20    }.  }else{.   
4170: 20 72 63 20 3d 20 53 51 4c 49 54 45 5f 42 55 53   rc = SQLITE_BUS
4180: 59 3b 0a 20 20 7d 0a 20 20 73 71 6c 69 74 65 4f  Y;.  }.  sqliteO
4190: 73 4c 65 61 76 65 4d 75 74 65 78 28 29 3b 0a 20  sLeaveMutex();. 
41a0: 20 72 65 74 75 72 6e 20 72 63 3b 0a 23 65 6e 64   return rc;.#end
41b0: 69 66 0a 23 69 66 20 4f 53 5f 57 49 4e 0a 20 20  if.#if OS_WIN.  
41c0: 69 6e 74 20 72 63 3b 0a 20 20 69 66 28 20 69 64  int rc;.  if( id
41d0: 2d 3e 6c 6f 63 6b 65 64 20 29 7b 0a 20 20 20 20  ->locked ){.    
41e0: 72 63 20 3d 20 53 51 4c 49 54 45 5f 4f 4b 3b 0a  rc = SQLITE_OK;.
41f0: 20 20 7d 65 6c 73 65 20 69 66 28 20 4c 6f 63 6b    }else if( Lock
4200: 46 69 6c 65 28 69 64 2d 3e 68 2c 20 30 2c 20 30  File(id->h, 0, 0
4210: 2c 20 31 30 32 34 2c 20 30 29 20 29 7b 0a 20 20  , 1024, 0) ){.  
4220: 20 20 72 63 20 3d 20 53 51 4c 49 54 45 5f 4f 4b    rc = SQLITE_OK
4230: 3b 0a 20 20 20 20 69 64 2d 3e 6c 6f 63 6b 65 64  ;.    id->locked
4240: 20 3d 20 31 3b 0a 20 20 7d 65 6c 73 65 7b 0a 20   = 1;.  }else{. 
4250: 20 20 20 72 63 20 3d 20 53 51 4c 49 54 45 5f 42     rc = SQLITE_B
4260: 55 53 59 3b 0a 20 20 7d 0a 20 20 72 65 74 75 72  USY;.  }.  retur
4270: 6e 20 72 63 3b 0a 23 65 6e 64 69 66 0a 7d 0a 0a  n rc;.#endif.}..
4280: 2f 2a 0a 2a 2a 20 55 6e 6c 6f 63 6b 20 74 68 65  /*.** Unlock the
4290: 20 67 69 76 65 6e 20 66 69 6c 65 20 64 65 73 63   given file desc
42a0: 72 69 70 74 6f 72 2e 20 20 49 66 20 74 68 65 20  riptor.  If the 
42b0: 66 69 6c 65 20 64 65 73 63 72 69 70 74 6f 72 20  file descriptor 
42c0: 77 61 73 0a 2a 2a 20 6e 6f 74 20 70 72 65 76 69  was.** not previ
42d0: 6f 75 73 6c 79 20 6c 6f 63 6b 65 64 2c 20 74 68  ously locked, th
42e0: 65 6e 20 74 68 69 73 20 72 6f 75 74 69 6e 65 20  en this routine 
42f0: 69 73 20 61 20 6e 6f 2d 6f 70 2e 0a 2a 2f 0a 69  is a no-op..*/.i
4300: 6e 74 20 73 71 6c 69 74 65 4f 73 55 6e 6c 6f 63  nt sqliteOsUnloc
4310: 6b 28 4f 73 46 69 6c 65 20 2a 69 64 29 7b 0a 23  k(OsFile *id){.#
4320: 69 66 20 4f 53 5f 55 4e 49 58 0a 20 20 69 6e 74  if OS_UNIX.  int
4330: 20 72 63 3b 0a 20 20 69 66 28 20 21 69 64 2d 3e   rc;.  if( !id->
4340: 6c 6f 63 6b 65 64 20 29 20 72 65 74 75 72 6e 20  locked ) return 
4350: 53 51 4c 49 54 45 5f 4f 4b 3b 0a 20 20 73 71 6c  SQLITE_OK;.  sql
4360: 69 74 65 4f 73 45 6e 74 65 72 4d 75 74 65 78 28  iteOsEnterMutex(
4370: 29 3b 0a 20 20 61 73 73 65 72 74 28 20 69 64 2d  );.  assert( id-
4380: 3e 70 4c 6f 63 6b 2d 3e 63 6e 74 21 3d 30 20 29  >pLock->cnt!=0 )
4390: 3b 0a 20 20 69 66 28 20 69 64 2d 3e 70 4c 6f 63  ;.  if( id->pLoc
43a0: 6b 2d 3e 63 6e 74 3e 31 20 29 7b 0a 20 20 20 20  k->cnt>1 ){.    
43b0: 69 64 2d 3e 70 4c 6f 63 6b 2d 3e 63 6e 74 2d 2d  id->pLock->cnt--
43c0: 3b 0a 20 20 20 20 72 63 20 3d 20 53 51 4c 49 54  ;.    rc = SQLIT
43d0: 45 5f 4f 4b 3b 0a 20 20 7d 65 6c 73 65 7b 0a 20  E_OK;.  }else{. 
43e0: 20 20 20 73 74 72 75 63 74 20 66 6c 6f 63 6b 20     struct flock 
43f0: 6c 6f 63 6b 3b 0a 20 20 20 20 6c 6f 63 6b 2e 6c  lock;.    lock.l
4400: 5f 74 79 70 65 20 3d 20 46 5f 55 4e 4c 43 4b 3b  _type = F_UNLCK;
4410: 0a 20 20 20 20 6c 6f 63 6b 2e 6c 5f 77 68 65 6e  .    lock.l_when
4420: 63 65 20 3d 20 53 45 45 4b 5f 53 45 54 3b 0a 20  ce = SEEK_SET;. 
4430: 20 20 20 6c 6f 63 6b 2e 6c 5f 73 74 61 72 74 20     lock.l_start 
4440: 3d 20 6c 6f 63 6b 2e 6c 5f 6c 65 6e 20 3d 20 30  = lock.l_len = 0
4450: 4c 3b 0a 20 20 20 20 69 66 28 20 66 63 6e 74 6c  L;.    if( fcntl
4460: 28 69 64 2d 3e 66 64 2c 20 46 5f 53 45 54 4c 4b  (id->fd, F_SETLK
4470: 2c 20 26 6c 6f 63 6b 29 21 3d 30 20 29 7b 0a 20  , &lock)!=0 ){. 
4480: 20 20 20 20 20 72 63 20 3d 20 53 51 4c 49 54 45       rc = SQLITE
4490: 5f 42 55 53 59 3b 0a 20 20 20 20 7d 65 6c 73 65  _BUSY;.    }else
44a0: 7b 0a 20 20 20 20 20 20 72 63 20 3d 20 53 51 4c  {.      rc = SQL
44b0: 49 54 45 5f 4f 4b 3b 0a 20 20 20 20 20 20 69 64  ITE_OK;.      id
44c0: 2d 3e 70 4c 6f 63 6b 2d 3e 63 6e 74 20 3d 20 30  ->pLock->cnt = 0
44d0: 3b 0a 20 20 20 20 7d 0a 20 20 7d 0a 20 20 73 71  ;.    }.  }.  sq
44e0: 6c 69 74 65 4f 73 4c 65 61 76 65 4d 75 74 65 78  liteOsLeaveMutex
44f0: 28 29 3b 0a 20 20 69 64 2d 3e 6c 6f 63 6b 65 64  ();.  id->locked
4500: 20 3d 20 30 3b 0a 20 20 72 65 74 75 72 6e 20 72   = 0;.  return r
4510: 63 3b 0a 23 65 6e 64 69 66 0a 23 69 66 20 4f 53  c;.#endif.#if OS
4520: 5f 57 49 4e 0a 20 20 69 6e 74 20 72 63 3b 0a 20  _WIN.  int rc;. 
4530: 20 69 66 28 20 21 69 64 2d 3e 6c 6f 63 6b 65 64   if( !id->locked
4540: 20 29 7b 0a 20 20 20 20 72 63 20 3d 20 53 51 4c   ){.    rc = SQL
4550: 49 54 45 5f 4f 4b 3b 0a 20 20 7d 65 6c 73 65 20  ITE_OK;.  }else 
4560: 69 66 28 20 55 6e 6c 6f 63 6b 46 69 6c 65 28 69  if( UnlockFile(i
4570: 64 2d 3e 68 2c 20 30 2c 20 30 2c 20 31 30 32 34  d->h, 0, 0, 1024
4580: 2c 20 30 29 20 29 7b 0a 20 20 20 20 72 63 20 3d  , 0) ){.    rc =
4590: 20 53 51 4c 49 54 45 5f 4f 4b 3b 0a 20 20 20 20   SQLITE_OK;.    
45a0: 69 64 2d 3e 6c 6f 63 6b 65 64 20 3d 20 30 3b 0a  id->locked = 0;.
45b0: 20 20 7d 65 6c 73 65 7b 0a 20 20 20 20 72 63 20    }else{.    rc 
45c0: 3d 20 53 51 4c 49 54 45 5f 42 55 53 59 3b 0a 20  = SQLITE_BUSY;. 
45d0: 20 7d 0a 20 20 72 65 74 75 72 6e 20 72 63 3b 0a   }.  return rc;.
45e0: 23 65 6e 64 69 66 0a 7d 0a 0a 2f 2a 0a 2a 2a 20  #endif.}../*.** 
45f0: 47 65 74 20 69 6e 66 6f 72 6d 61 74 69 6f 6e 20  Get information 
4600: 74 6f 20 73 65 65 64 20 74 68 65 20 72 61 6e 64  to seed the rand
4610: 6f 6d 20 6e 75 6d 62 65 72 20 67 65 6e 65 72 61  om number genera
4620: 74 6f 72 2e 0a 2a 2f 0a 69 6e 74 20 73 71 6c 69  tor..*/.int sqli
4630: 74 65 4f 73 52 61 6e 64 6f 6d 53 65 65 64 28 63  teOsRandomSeed(c
4640: 68 61 72 20 2a 7a 42 75 66 29 7b 0a 20 20 73 74  har *zBuf){.  st
4650: 61 74 69 63 20 69 6e 74 20 6f 6e 63 65 20 3d 20  atic int once = 
4660: 31 3b 0a 23 69 66 20 4f 53 5f 55 4e 49 58 0a 20  1;.#if OS_UNIX. 
4670: 20 69 6e 74 20 70 69 64 3b 0a 20 20 74 69 6d 65   int pid;.  time
4680: 28 28 74 69 6d 65 5f 74 2a 29 7a 42 75 66 29 3b  ((time_t*)zBuf);
4690: 0a 20 20 70 69 64 20 3d 20 67 65 74 70 69 64 28  .  pid = getpid(
46a0: 29 3b 0a 20 20 6d 65 6d 63 70 79 28 26 7a 42 75  );.  memcpy(&zBu
46b0: 66 5b 73 69 7a 65 6f 66 28 74 69 6d 65 5f 74 29  f[sizeof(time_t)
46c0: 5d 2c 20 26 70 69 64 2c 20 73 69 7a 65 6f 66 28  ], &pid, sizeof(
46d0: 70 69 64 29 29 3b 0a 23 65 6e 64 69 66 0a 23 69  pid));.#endif.#i
46e0: 66 20 4f 53 5f 57 49 4e 0a 20 20 47 65 74 53 79  f OS_WIN.  GetSy
46f0: 73 74 65 6d 54 69 6d 65 28 28 4c 50 53 59 53 54  stemTime((LPSYST
4700: 45 4d 54 49 4d 45 29 7a 42 75 66 29 3b 0a 23 65  EMTIME)zBuf);.#e
4710: 6e 64 69 66 0a 20 20 69 66 28 20 6f 6e 63 65 20  ndif.  if( once 
4720: 29 7b 0a 20 20 20 20 69 6e 74 20 73 65 65 64 3b  ){.    int seed;
4730: 0a 20 20 20 20 6d 65 6d 63 70 79 28 26 73 65 65  .    memcpy(&see
4740: 64 2c 20 7a 42 75 66 2c 20 73 69 7a 65 6f 66 28  d, zBuf, sizeof(
4750: 73 65 65 64 29 29 3b 0a 20 20 20 20 73 72 61 6e  seed));.    sran
4760: 64 28 73 65 65 64 29 3b 0a 20 20 20 20 6f 6e 63  d(seed);.    onc
4770: 65 20 3d 20 30 3b 0a 20 20 7d 0a 20 20 72 65 74  e = 0;.  }.  ret
4780: 75 72 6e 20 53 51 4c 49 54 45 5f 4f 4b 3b 0a 7d  urn SQLITE_OK;.}
4790: 0a 0a 2f 2a 0a 2a 2a 20 53 6c 65 65 70 20 66 6f  ../*.** Sleep fo
47a0: 72 20 61 20 6c 69 74 74 6c 65 20 77 68 69 6c 65  r a little while
47b0: 2e 20 20 52 65 74 75 72 6e 20 74 68 65 20 61 6d  .  Return the am
47c0: 6f 75 6e 74 20 6f 66 20 74 69 6d 65 20 73 6c 65  ount of time sle
47d0: 70 74 2e 0a 2a 2f 0a 69 6e 74 20 73 71 6c 69 74  pt..*/.int sqlit
47e0: 65 4f 73 53 6c 65 65 70 28 69 6e 74 20 6d 73 29  eOsSleep(int ms)
47f0: 7b 0a 23 69 66 20 4f 53 5f 55 4e 49 58 0a 23 69  {.#if OS_UNIX.#i
4800: 66 20 64 65 66 69 6e 65 64 28 48 41 56 45 5f 55  f defined(HAVE_U
4810: 53 4c 45 45 50 29 20 26 26 20 48 41 56 45 5f 55  SLEEP) && HAVE_U
4820: 53 4c 45 45 50 0a 20 20 75 73 6c 65 65 70 28 6d  SLEEP.  usleep(m
4830: 73 2a 31 30 30 30 29 3b 0a 20 20 72 65 74 75 72  s*1000);.  retur
4840: 6e 20 6d 73 3b 0a 23 65 6c 73 65 0a 20 20 73 6c  n ms;.#else.  sl
4850: 65 65 70 28 28 6d 73 2b 39 39 39 29 2f 31 30 30  eep((ms+999)/100
4860: 30 29 3b 0a 20 20 72 65 74 75 72 6e 20 31 30 30  0);.  return 100
4870: 30 2a 28 28 6d 73 2b 39 39 39 29 2f 31 30 30 30  0*((ms+999)/1000
4880: 29 3b 0a 23 65 6e 64 69 66 0a 23 65 6e 64 69 66  );.#endif.#endif
4890: 0a 23 69 66 20 4f 53 5f 57 49 4e 0a 20 20 53 6c  .#if OS_WIN.  Sl
48a0: 65 65 70 28 6d 73 29 3b 0a 20 20 72 65 74 75 72  eep(ms);.  retur
48b0: 6e 20 6d 73 3b 0a 23 65 6e 64 69 66 0a 7d 0a 0a  n ms;.#endif.}..
48c0: 2f 2a 0a 2a 2a 20 4d 61 63 72 6f 73 20 75 73 65  /*.** Macros use
48d0: 64 20 74 6f 20 64 65 74 65 72 6d 69 6e 65 20 77  d to determine w
48e0: 68 65 74 68 65 72 20 6f 72 20 6e 6f 74 20 74 6f  hether or not to
48f0: 20 75 73 65 20 74 68 72 65 61 64 73 2e 20 20 54   use threads.  T
4900: 68 65 0a 2a 2a 20 53 51 4c 49 54 45 5f 55 4e 49  he.** SQLITE_UNI
4910: 58 5f 54 48 52 45 41 44 53 20 6d 61 63 72 6f 20  X_THREADS macro 
4920: 69 73 20 64 65 66 69 6e 65 64 20 69 66 20 77 65  is defined if we
4930: 20 61 72 65 20 73 79 6e 63 68 72 6f 6e 69 7a 69   are synchronizi
4940: 6e 67 20 66 6f 72 0a 2a 2a 20 50 6f 73 69 78 20  ng for.** Posix 
4950: 74 68 72 65 61 64 73 20 61 6e 64 20 53 51 4c 49  threads and SQLI
4960: 54 45 5f 57 33 32 5f 54 48 52 45 41 44 53 20 69  TE_W32_THREADS i
4970: 73 20 64 65 66 69 6e 65 64 20 69 66 20 77 65 20  s defined if we 
4980: 61 72 65 0a 2a 2a 20 73 79 6e 63 68 72 6f 6e 69  are.** synchroni
4990: 7a 69 6e 67 20 75 73 69 6e 67 20 57 69 6e 33 32  zing using Win32
49a0: 20 74 68 72 65 61 64 73 2e 0a 2a 2f 0a 23 69 66   threads..*/.#if
49b0: 20 4f 53 5f 55 4e 49 58 20 26 26 20 64 65 66 69   OS_UNIX && defi
49c0: 6e 65 64 28 54 48 52 45 41 44 53 41 46 45 29 20  ned(THREADSAFE) 
49d0: 26 26 20 54 48 52 45 41 44 53 41 46 45 0a 23 20  && THREADSAFE.# 
49e0: 69 6e 63 6c 75 64 65 20 3c 70 74 68 72 65 61 64  include <pthread
49f0: 2e 68 3e 0a 23 20 64 65 66 69 6e 65 20 53 51 4c  .h>.# define SQL
4a00: 49 54 45 5f 55 4e 49 58 5f 54 48 52 45 41 44 53  ITE_UNIX_THREADS
4a10: 20 31 0a 23 65 6e 64 69 66 0a 23 69 66 20 4f 53   1.#endif.#if OS
4a20: 5f 57 49 4e 20 26 26 20 64 65 66 69 6e 65 64 28  _WIN && defined(
4a30: 54 48 52 45 41 44 53 41 46 45 29 20 26 26 20 54  THREADSAFE) && T
4a40: 48 52 45 41 44 53 41 46 45 0a 23 20 64 65 66 69  HREADSAFE.# defi
4a50: 6e 65 20 53 51 4c 49 54 45 5f 57 33 32 5f 54 48  ne SQLITE_W32_TH
4a60: 52 45 41 44 53 20 31 0a 23 65 6e 64 69 66 0a 0a  READS 1.#endif..
4a70: 2f 2a 0a 2a 2a 20 53 74 61 74 69 63 20 76 61 72  /*.** Static var
4a80: 69 61 62 6c 65 73 20 75 73 65 64 20 66 6f 72 20  iables used for 
4a90: 74 68 72 65 61 64 20 73 79 6e 63 68 72 6f 6e 69  thread synchroni
4aa0: 7a 61 74 69 6f 6e 0a 2a 2f 0a 73 74 61 74 69 63  zation.*/.static
4ab0: 20 69 6e 74 20 69 6e 4d 75 74 65 78 20 3d 20 30   int inMutex = 0
4ac0: 3b 0a 23 69 66 64 65 66 20 53 51 4c 49 54 45 5f  ;.#ifdef SQLITE_
4ad0: 55 4e 49 58 5f 54 48 52 45 41 44 53 0a 20 20 73  UNIX_THREADS.  s
4ae0: 74 61 74 69 63 20 70 74 68 72 65 61 64 5f 6d 75  tatic pthread_mu
4af0: 74 65 78 5f 74 20 6d 75 74 65 78 20 3d 20 50 54  tex_t mutex = PT
4b00: 48 52 45 41 44 5f 4d 55 54 45 58 5f 49 4e 49 54  HREAD_MUTEX_INIT
4b10: 49 41 4c 49 5a 45 52 3b 0a 23 65 6e 64 69 66 0a  IALIZER;.#endif.
4b20: 23 69 66 64 65 66 20 53 51 4c 49 54 45 5f 57 33  #ifdef SQLITE_W3
4b30: 32 5f 54 48 52 45 41 44 53 0a 20 20 73 74 61 74  2_THREADS.  stat
4b40: 69 63 20 43 52 49 54 49 43 41 4c 5f 53 45 43 54  ic CRITICAL_SECT
4b50: 49 4f 4e 20 63 73 3b 0a 23 65 6e 64 69 66 0a 0a  ION cs;.#endif..
4b60: 2f 2a 0a 2a 2a 20 54 68 65 20 66 6f 6c 6c 6f 77  /*.** The follow
4b70: 69 6e 67 20 70 61 69 72 20 6f 66 20 72 6f 75 74  ing pair of rout
4b80: 69 6e 65 20 69 6d 70 6c 65 6d 65 6e 74 20 6d 75  ine implement mu
4b90: 74 75 61 6c 20 65 78 63 6c 75 73 69 6f 6e 20 66  tual exclusion f
4ba0: 6f 72 0a 2a 2a 20 6d 75 6c 74 69 2d 74 68 72 65  or.** multi-thre
4bb0: 61 64 65 64 20 70 72 6f 63 65 73 73 65 73 2e 20  aded processes. 
4bc0: 20 4f 6e 6c 79 20 61 20 73 69 6e 67 6c 65 20 74   Only a single t
4bd0: 68 72 65 61 64 20 69 73 20 61 6c 6c 6f 77 65 64  hread is allowed
4be0: 20 74 6f 0a 2a 2a 20 65 78 65 63 75 74 65 64 20   to.** executed 
4bf0: 63 6f 64 65 20 74 68 61 74 20 69 73 20 73 75 72  code that is sur
4c00: 72 6f 75 6e 64 65 64 20 62 79 20 45 6e 74 65 72  rounded by Enter
4c10: 4d 75 74 65 78 28 29 20 61 6e 64 20 4c 65 61 76  Mutex() and Leav
4c20: 65 4d 75 74 65 78 28 29 2e 0a 2a 2a 0a 2a 2a 20  eMutex()..**.** 
4c30: 53 51 4c 69 74 65 20 75 73 65 73 20 6f 6e 6c 79  SQLite uses only
4c40: 20 61 20 73 69 6e 67 6c 65 20 4d 75 74 65 78 2e   a single Mutex.
4c50: 20 20 54 68 65 72 65 20 69 73 20 6e 6f 74 20 6d    There is not m
4c60: 75 63 68 20 63 72 69 74 69 63 61 6c 0a 2a 2a 20  uch critical.** 
4c70: 63 6f 64 65 20 61 6e 64 20 77 68 61 74 20 6c 69  code and what li
4c80: 74 74 6c 65 20 74 68 65 72 65 20 69 73 20 65 78  ttle there is ex
4c90: 65 63 75 74 65 73 20 71 75 69 63 6b 6c 79 20 61  ecutes quickly a
4ca0: 6e 64 20 77 69 74 68 6f 75 74 20 62 6c 6f 63 6b  nd without block
4cb0: 69 6e 67 2e 0a 2a 2f 0a 76 6f 69 64 20 73 71 6c  ing..*/.void sql
4cc0: 69 74 65 4f 73 45 6e 74 65 72 4d 75 74 65 78 28  iteOsEnterMutex(
4cd0: 29 7b 0a 23 69 66 64 65 66 20 53 51 4c 49 54 45  ){.#ifdef SQLITE
4ce0: 5f 55 4e 49 58 5f 54 48 52 45 41 44 53 0a 20 20  _UNIX_THREADS.  
4cf0: 70 74 68 72 65 61 64 5f 6d 75 74 65 78 5f 6c 6f  pthread_mutex_lo
4d00: 63 6b 28 26 6d 75 74 65 78 29 3b 0a 23 65 6e 64  ck(&mutex);.#end
4d10: 69 66 0a 23 69 66 64 65 66 20 53 51 4c 49 54 45  if.#ifdef SQLITE
4d20: 5f 57 33 32 5f 54 48 52 45 41 44 53 0a 20 20 73  _W32_THREADS.  s
4d30: 74 61 74 69 63 20 69 6e 74 20 69 73 49 6e 69 74  tatic int isInit
4d40: 20 3d 20 30 3b 0a 20 20 77 68 69 6c 65 28 20 21   = 0;.  while( !
4d50: 69 73 49 6e 69 74 20 29 7b 0a 20 20 20 20 73 74  isInit ){.    st
4d60: 61 74 69 63 20 6c 6f 6e 67 20 6c 6f 63 6b 20 3d  atic long lock =
4d70: 20 30 3b 0a 20 20 20 20 69 66 28 20 49 6e 74 65   0;.    if( Inte
4d80: 72 6c 6f 63 6b 65 64 49 6e 63 72 65 6d 65 6e 74  rlockedIncrement
4d90: 28 26 6c 6f 63 6b 29 3d 3d 31 20 29 7b 0a 20 20  (&lock)==1 ){.  
4da0: 20 20 20 20 49 6e 69 74 69 61 6c 69 7a 65 43 72      InitializeCr
4db0: 69 74 69 63 61 6c 53 65 63 74 69 6f 6e 28 26 63  iticalSection(&c
4dc0: 73 29 3b 0a 20 20 20 20 20 20 69 73 49 6e 69 74  s);.      isInit
4dd0: 20 3d 20 31 3b 0a 20 20 20 20 7d 65 6c 73 65 7b   = 1;.    }else{
4de0: 0a 20 20 20 20 20 20 53 6c 65 65 70 28 31 29 3b  .      Sleep(1);
4df0: 0a 20 20 20 20 7d 0a 20 20 7d 0a 20 20 45 6e 74  .    }.  }.  Ent
4e00: 65 72 43 72 69 74 69 63 61 6c 53 65 63 74 69 6f  erCriticalSectio
4e10: 6e 28 26 63 73 29 3b 0a 23 65 6e 64 69 66 0a 20  n(&cs);.#endif. 
4e20: 20 61 73 73 65 72 74 28 20 21 69 6e 4d 75 74 65   assert( !inMute
4e30: 78 20 29 3b 0a 20 20 69 6e 4d 75 74 65 78 20 3d  x );.  inMutex =
4e40: 20 31 3b 0a 7d 0a 76 6f 69 64 20 73 71 6c 69 74   1;.}.void sqlit
4e50: 65 4f 73 4c 65 61 76 65 4d 75 74 65 78 28 29 7b  eOsLeaveMutex(){
4e60: 0a 20 20 61 73 73 65 72 74 28 20 69 6e 4d 75 74  .  assert( inMut
4e70: 65 78 20 29 3b 0a 20 20 69 6e 4d 75 74 65 78 20  ex );.  inMutex 
4e80: 3d 20 30 3b 0a 23 69 66 64 65 66 20 53 51 4c 49  = 0;.#ifdef SQLI
4e90: 54 45 5f 55 4e 49 58 5f 54 48 52 45 41 44 53 0a  TE_UNIX_THREADS.
4ea0: 20 20 70 74 68 72 65 61 64 5f 6d 75 74 65 78 5f    pthread_mutex_
4eb0: 75 6e 6c 6f 63 6b 28 26 6d 75 74 65 78 29 3b 0a  unlock(&mutex);.
4ec0: 23 65 6e 64 69 66 0a 23 69 66 64 65 66 20 53 51  #endif.#ifdef SQ
4ed0: 4c 49 54 45 5f 57 33 32 5f 54 48 52 45 41 44 53  LITE_W32_THREADS
4ee0: 0a 20 20 4c 65 61 76 65 43 72 69 74 69 63 61 6c  .  LeaveCritical
4ef0: 53 65 63 74 69 6f 6e 28 26 63 73 29 3b 0a 23 65  Section(&cs);.#e
4f00: 6e 64 69 66 0a 7d 0a                             ndif.}.