0000: 2f 2a 0a 2a 2a 20 32 30 30 34 20 4d 61 79 20 32 /*.** 2004 May 2
0010: 32 0a 2a 2a 0a 2a 2a 20 54 68 65 20 61 75 74 68 2.**.** The auth
0020: 6f 72 20 64 69 73 63 6c 61 69 6d 73 20 63 6f 70 or disclaims cop
0030: 79 72 69 67 68 74 20 74 6f 20 74 68 69 73 20 73 yright to this s
0040: 6f 75 72 63 65 20 63 6f 64 65 2e 20 20 49 6e 20 ource code. In
0050: 70 6c 61 63 65 20 6f 66 0a 2a 2a 20 61 20 6c 65 place of.** a le
0060: 67 61 6c 20 6e 6f 74 69 63 65 2c 20 68 65 72 65 gal notice, here
0070: 20 69 73 20 61 20 62 6c 65 73 73 69 6e 67 3a 0a is a blessing:.
0080: 2a 2a 0a 2a 2a 20 20 20 20 4d 61 79 20 79 6f 75 **.** May you
0090: 20 64 6f 20 67 6f 6f 64 20 61 6e 64 20 6e 6f 74 do good and not
00a0: 20 65 76 69 6c 2e 0a 2a 2a 20 20 20 20 4d 61 79 evil..** May
00b0: 20 79 6f 75 20 66 69 6e 64 20 66 6f 72 67 69 76 you find forgiv
00c0: 65 6e 65 73 73 20 66 6f 72 20 79 6f 75 72 73 65 eness for yourse
00d0: 6c 66 20 61 6e 64 20 66 6f 72 67 69 76 65 20 6f lf and forgive o
00e0: 74 68 65 72 73 2e 0a 2a 2a 20 20 20 20 4d 61 79 thers..** May
00f0: 20 79 6f 75 20 73 68 61 72 65 20 66 72 65 65 6c you share freel
0100: 79 2c 20 6e 65 76 65 72 20 74 61 6b 69 6e 67 20 y, never taking
0110: 6d 6f 72 65 20 74 68 61 6e 20 79 6f 75 20 67 69 more than you gi
0120: 76 65 2e 0a 2a 2a 0a 2a 2a 2a 2a 2a 2a 2a 2a 2a ve..**.*********
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 0a 2a 2a 0a 2a 2a 20 54 68 69 73 *****.**.** This
0180: 20 66 69 6c 65 20 63 6f 6e 74 61 69 6e 73 20 63 file contains c
0190: 6f 64 65 20 74 68 61 74 20 69 73 20 73 70 65 63 ode that is spec
01a0: 69 66 69 63 20 74 6f 20 55 6e 69 78 20 73 79 73 ific to Unix sys
01b0: 74 65 6d 73 2e 0a 2a 2f 0a 23 69 6e 63 6c 75 64 tems..*/.#includ
01c0: 65 20 22 6f 73 2e 68 22 20 20 20 20 20 20 20 20 e "os.h"
01d0: 20 20 2f 2a 20 4d 75 73 74 20 62 65 20 66 69 72 /* Must be fir
01e0: 73 74 20 74 6f 20 65 6e 61 62 6c 65 20 6c 61 72 st to enable lar
01f0: 67 65 20 66 69 6c 65 20 73 75 70 70 6f 72 74 20 ge file support
0200: 2a 2f 0a 23 69 66 20 4f 53 5f 55 4e 49 58 20 20 */.#if OS_UNIX
0210: 20 20 20 20 20 20 20 20 20 20 20 20 2f 2a 20 54 /* T
0220: 68 69 73 20 66 69 6c 65 20 69 73 20 75 73 65 64 his file is used
0230: 20 6f 6e 20 75 6e 69 78 20 6f 6e 6c 79 20 2a 2f on unix only */
0240: 0a 23 69 6e 63 6c 75 64 65 20 22 73 71 6c 69 74 .#include "sqlit
0250: 65 49 6e 74 2e 68 22 0a 0a 0a 23 69 6e 63 6c 75 eInt.h"...#inclu
0260: 64 65 20 3c 74 69 6d 65 2e 68 3e 0a 23 69 6e 63 de <time.h>.#inc
0270: 6c 75 64 65 20 3c 65 72 72 6e 6f 2e 68 3e 0a 23 lude <errno.h>.#
0280: 69 6e 63 6c 75 64 65 20 3c 75 6e 69 73 74 64 2e include <unistd.
0290: 68 3e 0a 23 69 66 6e 64 65 66 20 4f 5f 4c 41 52 h>.#ifndef O_LAR
02a0: 47 45 46 49 4c 45 0a 23 20 64 65 66 69 6e 65 20 GEFILE.# define
02b0: 4f 5f 4c 41 52 47 45 46 49 4c 45 20 30 0a 23 65 O_LARGEFILE 0.#e
02c0: 6e 64 69 66 0a 23 69 66 64 65 66 20 53 51 4c 49 ndif.#ifdef SQLI
02d0: 54 45 5f 44 49 53 41 42 4c 45 5f 4c 46 53 0a 23 TE_DISABLE_LFS.#
02e0: 20 75 6e 64 65 66 20 4f 5f 4c 41 52 47 45 46 49 undef O_LARGEFI
02f0: 4c 45 0a 23 20 64 65 66 69 6e 65 20 4f 5f 4c 41 LE.# define O_LA
0300: 52 47 45 46 49 4c 45 20 30 0a 23 65 6e 64 69 66 RGEFILE 0.#endif
0310: 0a 23 69 66 6e 64 65 66 20 4f 5f 4e 4f 46 4f 4c .#ifndef O_NOFOL
0320: 4c 4f 57 0a 23 20 64 65 66 69 6e 65 20 4f 5f 4e LOW.# define O_N
0330: 4f 46 4f 4c 4c 4f 57 20 30 0a 23 65 6e 64 69 66 OFOLLOW 0.#endif
0340: 0a 23 69 66 6e 64 65 66 20 4f 5f 42 49 4e 41 52 .#ifndef O_BINAR
0350: 59 0a 23 20 64 65 66 69 6e 65 20 4f 5f 42 49 4e Y.# define O_BIN
0360: 41 52 59 20 30 0a 23 65 6e 64 69 66 0a 0a 2f 2a ARY 0.#endif../*
0370: 0a 2a 2a 20 54 68 65 20 44 4a 47 50 50 20 63 6f .** The DJGPP co
0380: 6d 70 69 6c 65 72 20 65 6e 76 69 72 6f 6e 6d 65 mpiler environme
0390: 6e 74 20 6c 6f 6f 6b 73 20 6d 6f 73 74 6c 79 20 nt looks mostly
03a0: 6c 69 6b 65 20 55 6e 69 78 2c 20 62 75 74 20 69 like Unix, but i
03b0: 74 0a 2a 2a 20 6c 61 63 6b 73 20 74 68 65 20 66 t.** lacks the f
03c0: 63 6e 74 6c 28 29 20 73 79 73 74 65 6d 20 63 61 cntl() system ca
03d0: 6c 6c 2e 20 20 53 6f 20 72 65 64 65 66 69 6e 65 ll. So redefine
03e0: 20 66 63 6e 74 6c 28 29 20 74 6f 20 62 65 20 73 fcntl() to be s
03f0: 6f 6d 65 74 68 69 6e 67 0a 2a 2a 20 74 68 61 74 omething.** that
0400: 20 61 6c 77 61 79 73 20 73 75 63 63 65 65 64 73 always succeeds
0410: 2e 20 20 54 68 69 73 20 6d 65 61 6e 73 20 74 68 . This means th
0420: 61 74 20 6c 6f 63 6b 69 6e 67 20 64 6f 65 73 20 at locking does
0430: 6e 6f 74 20 6f 63 63 75 72 20 75 6e 64 65 72 0a not occur under.
0440: 2a 2a 20 44 4a 47 50 50 2e 20 20 42 75 74 20 69 ** DJGPP. But i
0450: 74 73 20 44 4f 53 20 2d 20 77 68 61 74 20 64 69 ts DOS - what di
0460: 64 20 79 6f 75 20 65 78 70 65 63 74 3f 0a 2a 2f d you expect?.*/
0470: 0a 23 69 66 64 65 66 20 5f 5f 44 4a 47 50 50 5f .#ifdef __DJGPP_
0480: 5f 0a 23 20 64 65 66 69 6e 65 20 66 63 6e 74 6c _.# define fcntl
0490: 28 41 2c 42 2c 43 29 20 30 0a 23 65 6e 64 69 66 (A,B,C) 0.#endif
04a0: 0a 0a 2f 2a 0a 2a 2a 20 4d 61 63 72 6f 73 20 75 ../*.** Macros u
04b0: 73 65 64 20 74 6f 20 64 65 74 65 72 6d 69 6e 65 sed to determine
04c0: 20 77 68 65 74 68 65 72 20 6f 72 20 6e 6f 74 20 whether or not
04d0: 74 6f 20 75 73 65 20 74 68 72 65 61 64 73 2e 20 to use threads.
04e0: 20 54 68 65 0a 2a 2a 20 53 51 4c 49 54 45 5f 55 The.** SQLITE_U
04f0: 4e 49 58 5f 54 48 52 45 41 44 53 20 6d 61 63 72 NIX_THREADS macr
0500: 6f 20 69 73 20 64 65 66 69 6e 65 64 20 69 66 20 o is defined if
0510: 77 65 20 61 72 65 20 73 79 6e 63 68 72 6f 6e 69 we are synchroni
0520: 7a 69 6e 67 20 66 6f 72 0a 2a 2a 20 50 6f 73 69 zing for.** Posi
0530: 78 20 74 68 72 65 61 64 73 20 61 6e 64 20 53 51 x threads and SQ
0540: 4c 49 54 45 5f 57 33 32 5f 54 48 52 45 41 44 53 LITE_W32_THREADS
0550: 20 69 73 20 64 65 66 69 6e 65 64 20 69 66 20 77 is defined if w
0560: 65 20 61 72 65 0a 2a 2a 20 73 79 6e 63 68 72 6f e are.** synchro
0570: 6e 69 7a 69 6e 67 20 75 73 69 6e 67 20 57 69 6e nizing using Win
0580: 33 32 20 74 68 72 65 61 64 73 2e 0a 2a 2f 0a 23 32 threads..*/.#
0590: 69 66 20 64 65 66 69 6e 65 64 28 54 48 52 45 41 if defined(THREA
05a0: 44 53 41 46 45 29 20 26 26 20 54 48 52 45 41 44 DSAFE) && THREAD
05b0: 53 41 46 45 0a 23 20 69 6e 63 6c 75 64 65 20 3c SAFE.# include <
05c0: 70 74 68 72 65 61 64 2e 68 3e 0a 23 20 64 65 66 pthread.h>.# def
05d0: 69 6e 65 20 53 51 4c 49 54 45 5f 55 4e 49 58 5f ine SQLITE_UNIX_
05e0: 54 48 52 45 41 44 53 20 31 0a 23 65 6e 64 69 66 THREADS 1.#endif
05f0: 0a 0a 0a 2f 2a 0a 2a 2a 20 49 6e 63 6c 75 64 65 .../*.** Include
0600: 20 63 6f 64 65 20 74 68 61 74 20 69 73 20 63 6f code that is co
0610: 6d 6d 6f 6e 20 74 6f 20 61 6c 6c 20 6f 73 5f 2a mmon to all os_*
0620: 2e 63 20 66 69 6c 65 73 0a 2a 2f 0a 23 69 6e 63 .c files.*/.#inc
0630: 6c 75 64 65 20 22 6f 73 5f 63 6f 6d 6d 6f 6e 2e lude "os_common.
0640: 68 22 0a 0a 23 69 66 20 64 65 66 69 6e 65 64 28 h"..#if defined(
0650: 54 48 52 45 41 44 53 41 46 45 29 20 26 26 20 64 THREADSAFE) && d
0660: 65 66 69 6e 65 64 28 5f 5f 6c 69 6e 75 78 5f 5f efined(__linux__
0670: 29 0a 23 64 65 66 69 6e 65 20 67 65 74 70 69 64 ).#define getpid
0680: 20 70 74 68 72 65 61 64 5f 73 65 6c 66 0a 23 65 pthread_self.#e
0690: 6e 64 69 66 0a 0a 2f 2a 0a 2a 2a 20 48 65 72 65 ndif../*.** Here
06a0: 20 69 73 20 74 68 65 20 64 69 72 74 20 6f 6e 20 is the dirt on
06b0: 50 4f 53 49 58 20 61 64 76 69 73 6f 72 79 20 6c POSIX advisory l
06c0: 6f 63 6b 73 3a 20 20 41 4e 53 49 20 53 54 44 20 ocks: ANSI STD
06d0: 31 30 30 33 2e 31 20 28 31 39 39 36 29 0a 2a 2a 1003.1 (1996).**
06e0: 20 73 65 63 74 69 6f 6e 20 36 2e 35 2e 32 2e 32 section 6.5.2.2
06f0: 20 6c 69 6e 65 73 20 34 38 33 20 74 68 72 6f 75 lines 483 throu
0700: 67 68 20 34 39 30 20 73 70 65 63 69 66 79 20 74 gh 490 specify t
0710: 68 61 74 20 77 68 65 6e 20 61 20 70 72 6f 63 65 hat when a proce
0720: 73 73 0a 2a 2a 20 73 65 74 73 20 6f 72 20 63 6c ss.** sets or cl
0730: 65 61 72 73 20 61 20 6c 6f 63 6b 2c 20 74 68 61 ears a lock, tha
0740: 74 20 6f 70 65 72 61 74 69 6f 6e 20 6f 76 65 72 t operation over
0750: 72 69 64 65 73 20 61 6e 79 20 70 72 69 6f 72 20 rides any prior
0760: 6c 6f 63 6b 73 20 73 65 74 0a 2a 2a 20 62 79 20 locks set.** by
0770: 74 68 65 20 73 61 6d 65 20 70 72 6f 63 65 73 73 the same process
0780: 2e 20 20 49 74 20 64 6f 65 73 20 6e 6f 74 20 65 . It does not e
0790: 78 70 6c 69 63 69 74 6c 79 20 73 61 79 20 73 6f xplicitly say so
07a0: 2c 20 62 75 74 20 74 68 69 73 20 69 6d 70 6c 69 , but this impli
07b0: 65 73 0a 2a 2a 20 74 68 61 74 20 69 74 20 6f 76 es.** that it ov
07c0: 65 72 72 69 64 65 73 20 6c 6f 63 6b 73 20 73 65 errides locks se
07d0: 74 20 62 79 20 74 68 65 20 73 61 6d 65 20 70 72 t by the same pr
07e0: 6f 63 65 73 73 20 75 73 69 6e 67 20 61 20 64 69 ocess using a di
07f0: 66 66 65 72 65 6e 74 0a 2a 2a 20 66 69 6c 65 20 fferent.** file
0800: 64 65 73 63 72 69 70 74 6f 72 2e 20 20 43 6f 6e descriptor. Con
0810: 73 69 64 65 72 20 74 68 69 73 20 74 65 73 74 20 sider this test
0820: 63 61 73 65 3a 0a 2a 2a 0a 2a 2a 20 20 20 20 20 case:.**.**
0830: 20 20 69 6e 74 20 66 64 31 20 3d 20 6f 70 65 6e int fd1 = open
0840: 28 22 2e 2f 66 69 6c 65 31 22 2c 20 4f 5f 52 44 ("./file1", O_RD
0850: 57 52 7c 4f 5f 43 52 45 41 54 2c 20 30 36 34 34 WR|O_CREAT, 0644
0860: 29 3b 0a 2a 2a 20 20 20 20 20 20 20 69 6e 74 20 );.** int
0870: 66 64 32 20 3d 20 6f 70 65 6e 28 22 2e 2f 66 69 fd2 = open("./fi
0880: 6c 65 32 22 2c 20 4f 5f 52 44 57 52 7c 4f 5f 43 le2", O_RDWR|O_C
0890: 52 45 41 54 2c 20 30 36 34 34 29 3b 0a 2a 2a 0a REAT, 0644);.**.
08a0: 2a 2a 20 53 75 70 70 6f 73 65 20 2e 2f 66 69 6c ** Suppose ./fil
08b0: 65 31 20 61 6e 64 20 2e 2f 66 69 6c 65 32 20 61 e1 and ./file2 a
08c0: 72 65 20 72 65 61 6c 6c 79 20 74 68 65 20 73 61 re really the sa
08d0: 6d 65 20 66 69 6c 65 20 28 62 65 63 61 75 73 65 me file (because
08e0: 0a 2a 2a 20 6f 6e 65 20 69 73 20 61 20 68 61 72 .** one is a har
08f0: 64 20 6f 72 20 73 79 6d 62 6f 6c 69 63 20 6c 69 d or symbolic li
0900: 6e 6b 20 74 6f 20 74 68 65 20 6f 74 68 65 72 29 nk to the other)
0910: 20 74 68 65 6e 20 69 66 20 79 6f 75 20 73 65 74 then if you set
0920: 0a 2a 2a 20 61 6e 20 65 78 63 6c 75 73 69 76 65 .** an exclusive
0930: 20 6c 6f 63 6b 20 6f 6e 20 66 64 31 2c 20 74 68 lock on fd1, th
0940: 65 6e 20 74 72 79 20 74 6f 20 67 65 74 20 61 6e en try to get an
0950: 20 65 78 63 6c 75 73 69 76 65 20 6c 6f 63 6b 0a exclusive lock.
0960: 2a 2a 20 6f 6e 20 66 64 32 2c 20 69 74 20 77 6f ** on fd2, it wo
0970: 72 6b 73 2e 20 20 49 20 77 6f 75 6c 64 20 68 61 rks. I would ha
0980: 76 65 20 65 78 70 65 63 74 65 64 20 74 68 65 20 ve expected the
0990: 73 65 63 6f 6e 64 20 6c 6f 63 6b 20 74 6f 0a 2a second lock to.*
09a0: 2a 20 66 61 69 6c 20 73 69 6e 63 65 20 74 68 65 * fail since the
09b0: 72 65 20 77 61 73 20 61 6c 72 65 61 64 79 20 61 re was already a
09c0: 20 6c 6f 63 6b 20 6f 6e 20 74 68 65 20 66 69 6c lock on the fil
09d0: 65 20 64 75 65 20 74 6f 20 66 64 31 2e 0a 2a 2a e due to fd1..**
09e0: 20 42 75 74 20 6e 6f 74 20 73 6f 2e 20 20 53 69 But not so. Si
09f0: 6e 63 65 20 62 6f 74 68 20 6c 6f 63 6b 73 20 63 nce both locks c
0a00: 61 6d 65 20 66 72 6f 6d 20 74 68 65 20 73 61 6d ame from the sam
0a10: 65 20 70 72 6f 63 65 73 73 2c 20 74 68 65 0a 2a e process, the.*
0a20: 2a 20 73 65 63 6f 6e 64 20 6f 76 65 72 72 69 64 * second overrid
0a30: 65 73 20 74 68 65 20 66 69 72 73 74 2c 20 65 76 es the first, ev
0a40: 65 6e 20 74 68 6f 75 67 68 20 74 68 65 79 20 77 en though they w
0a50: 65 72 65 20 6f 6e 20 64 69 66 66 65 72 65 6e 74 ere on different
0a60: 0a 2a 2a 20 66 69 6c 65 20 64 65 73 63 72 69 70 .** file descrip
0a70: 74 6f 72 73 20 6f 70 65 6e 65 64 20 6f 6e 20 64 tors opened on d
0a80: 69 66 66 65 72 65 6e 74 20 66 69 6c 65 20 6e 61 ifferent file na
0a90: 6d 65 73 2e 0a 2a 2a 0a 2a 2a 20 42 75 6d 6d 65 mes..**.** Bumme
0aa0: 72 2e 20 20 49 66 20 79 6f 75 20 61 73 6b 20 6d r. If you ask m
0ab0: 65 2c 20 74 68 69 73 20 69 73 20 62 72 6f 6b 65 e, this is broke
0ac0: 6e 2e 20 20 42 61 64 6c 79 20 62 72 6f 6b 65 6e n. Badly broken
0ad0: 2e 20 20 49 74 20 6d 65 61 6e 73 0a 2a 2a 20 74 . It means.** t
0ae0: 68 61 74 20 77 65 20 63 61 6e 6e 6f 74 20 75 73 hat we cannot us
0af0: 65 20 50 4f 53 49 58 20 6c 6f 63 6b 73 20 74 6f e POSIX locks to
0b00: 20 73 79 6e 63 68 72 6f 6e 69 7a 65 20 66 69 6c synchronize fil
0b10: 65 20 61 63 63 65 73 73 20 61 6d 6f 6e 67 0a 2a e access among.*
0b20: 2a 20 63 6f 6d 70 65 74 69 6e 67 20 74 68 72 65 * competing thre
0b30: 61 64 73 20 6f 66 20 74 68 65 20 73 61 6d 65 20 ads of the same
0b40: 70 72 6f 63 65 73 73 2e 20 20 50 4f 53 49 58 20 process. POSIX
0b50: 6c 6f 63 6b 73 20 77 69 6c 6c 20 77 6f 72 6b 20 locks will work
0b60: 66 69 6e 65 0a 2a 2a 20 74 6f 20 73 79 6e 63 68 fine.** to synch
0b70: 72 6f 6e 69 7a 65 20 61 63 63 65 73 73 20 66 6f ronize access fo
0b80: 72 20 74 68 72 65 61 64 73 20 69 6e 20 73 65 70 r threads in sep
0b90: 61 72 61 74 65 20 70 72 6f 63 65 73 73 65 73 2c arate processes,
0ba0: 20 62 75 74 20 6e 6f 74 0a 2a 2a 20 74 68 72 65 but not.** thre
0bb0: 61 64 73 20 77 69 74 68 69 6e 20 74 68 65 20 73 ads within the s
0bc0: 61 6d 65 20 70 72 6f 63 65 73 73 2e 0a 2a 2a 0a ame process..**.
0bd0: 2a 2a 20 54 6f 20 77 6f 72 6b 20 61 72 6f 75 6e ** To work aroun
0be0: 64 20 74 68 65 20 70 72 6f 62 6c 65 6d 2c 20 53 d the problem, S
0bf0: 51 4c 69 74 65 20 68 61 73 20 74 6f 20 6d 61 6e QLite has to man
0c00: 61 67 65 20 66 69 6c 65 20 6c 6f 63 6b 73 20 69 age file locks i
0c10: 6e 74 65 72 6e 61 6c 6c 79 0a 2a 2a 20 6f 6e 20 nternally.** on
0c20: 69 74 73 20 6f 77 6e 2e 20 20 57 68 65 6e 65 76 its own. Whenev
0c30: 65 72 20 61 20 6e 65 77 20 64 61 74 61 62 61 73 er a new databas
0c40: 65 20 69 73 20 6f 70 65 6e 65 64 2c 20 77 65 20 e is opened, we
0c50: 68 61 76 65 20 74 6f 20 66 69 6e 64 20 74 68 65 have to find the
0c60: 0a 2a 2a 20 73 70 65 63 69 66 69 63 20 69 6e 6f .** specific ino
0c70: 64 65 20 6f 66 20 74 68 65 20 64 61 74 61 62 61 de of the databa
0c80: 73 65 20 66 69 6c 65 20 28 74 68 65 20 69 6e 6f se file (the ino
0c90: 64 65 20 69 73 20 64 65 74 65 72 6d 69 6e 65 64 de is determined
0ca0: 20 62 79 20 74 68 65 0a 2a 2a 20 73 74 5f 64 65 by the.** st_de
0cb0: 76 20 61 6e 64 20 73 74 5f 69 6e 6f 20 66 69 65 v and st_ino fie
0cc0: 6c 64 73 20 6f 66 20 74 68 65 20 73 74 61 74 20 lds of the stat
0cd0: 73 74 72 75 63 74 75 72 65 20 74 68 61 74 20 66 structure that f
0ce0: 73 74 61 74 28 29 20 66 69 6c 6c 73 20 69 6e 29 stat() fills in)
0cf0: 0a 2a 2a 20 61 6e 64 20 63 68 65 63 6b 20 66 6f .** and check fo
0d00: 72 20 6c 6f 63 6b 73 20 61 6c 72 65 61 64 79 20 r locks already
0d10: 65 78 69 73 74 69 6e 67 20 6f 6e 20 74 68 61 74 existing on that
0d20: 20 69 6e 6f 64 65 2e 20 20 57 68 65 6e 20 6c 6f inode. When lo
0d30: 63 6b 73 20 61 72 65 0a 2a 2a 20 63 72 65 61 74 cks are.** creat
0d40: 65 64 20 6f 72 20 72 65 6d 6f 76 65 64 2c 20 77 ed or removed, w
0d50: 65 20 68 61 76 65 20 74 6f 20 6c 6f 6f 6b 20 61 e have to look a
0d60: 74 20 6f 75 72 20 6f 77 6e 20 69 6e 74 65 72 6e t our own intern
0d70: 61 6c 20 72 65 63 6f 72 64 20 6f 66 20 74 68 65 al record of the
0d80: 0a 2a 2a 20 6c 6f 63 6b 73 20 74 6f 20 73 65 65 .** locks to see
0d90: 20 69 66 20 61 6e 6f 74 68 65 72 20 74 68 72 65 if another thre
0da0: 61 64 20 68 61 73 20 70 72 65 76 69 6f 75 73 6c ad has previousl
0db0: 79 20 73 65 74 20 61 20 6c 6f 63 6b 20 6f 6e 20 y set a lock on
0dc0: 74 68 61 74 20 73 61 6d 65 0a 2a 2a 20 69 6e 6f that same.** ino
0dd0: 64 65 2e 0a 2a 2a 0a 2a 2a 20 54 68 65 20 4f 73 de..**.** The Os
0de0: 46 69 6c 65 20 73 74 72 75 63 74 75 72 65 20 66 File structure f
0df0: 6f 72 20 50 4f 53 49 58 20 69 73 20 6e 6f 20 6c or POSIX is no l
0e00: 6f 6e 67 65 72 20 6a 75 73 74 20 61 6e 20 69 6e onger just an in
0e10: 74 65 67 65 72 20 66 69 6c 65 0a 2a 2a 20 64 65 teger file.** de
0e20: 73 63 72 69 70 74 6f 72 2e 20 20 49 74 20 69 73 scriptor. It is
0e30: 20 6e 6f 77 20 61 20 73 74 72 75 63 74 75 72 65 now a structure
0e40: 20 74 68 61 74 20 68 6f 6c 64 73 20 74 68 65 20 that holds the
0e50: 69 6e 74 65 67 65 72 20 66 69 6c 65 0a 2a 2a 20 integer file.**
0e60: 64 65 73 63 72 69 70 74 6f 72 20 61 6e 64 20 61 descriptor and a
0e70: 20 70 6f 69 6e 74 65 72 20 74 6f 20 61 20 73 74 pointer to a st
0e80: 72 75 63 74 75 72 65 20 74 68 61 74 20 64 65 73 ructure that des
0e90: 63 72 69 62 65 73 20 74 68 65 20 69 6e 74 65 72 cribes the inter
0ea0: 6e 61 6c 0a 2a 2a 20 6c 6f 63 6b 73 20 6f 6e 20 nal.** locks on
0eb0: 74 68 65 20 63 6f 72 72 65 73 70 6f 6e 64 69 6e the correspondin
0ec0: 67 20 69 6e 6f 64 65 2e 20 20 54 68 65 72 65 20 g inode. There
0ed0: 69 73 20 6f 6e 65 20 6c 6f 63 6b 69 6e 67 20 73 is one locking s
0ee0: 74 72 75 63 74 75 72 65 0a 2a 2a 20 70 65 72 20 tructure.** per
0ef0: 69 6e 6f 64 65 2c 20 73 6f 20 69 66 20 74 68 65 inode, so if the
0f00: 20 73 61 6d 65 20 69 6e 6f 64 65 20 69 73 20 6f same inode is o
0f10: 70 65 6e 65 64 20 74 77 69 63 65 2c 20 62 6f 74 pened twice, bot
0f20: 68 20 4f 73 46 69 6c 65 20 73 74 72 75 63 74 75 h OsFile structu
0f30: 72 65 73 0a 2a 2a 20 70 6f 69 6e 74 20 74 6f 20 res.** point to
0f40: 74 68 65 20 73 61 6d 65 20 6c 6f 63 6b 69 6e 67 the same locking
0f50: 20 73 74 72 75 63 74 75 72 65 2e 20 20 54 68 65 structure. The
0f60: 20 6c 6f 63 6b 69 6e 67 20 73 74 72 75 63 74 75 locking structu
0f70: 72 65 20 6b 65 65 70 73 0a 2a 2a 20 61 20 72 65 re keeps.** a re
0f80: 66 65 72 65 6e 63 65 20 63 6f 75 6e 74 20 28 73 ference count (s
0f90: 6f 20 77 65 20 77 69 6c 6c 20 6b 6e 6f 77 20 77 o we will know w
0fa0: 68 65 6e 20 74 6f 20 64 65 6c 65 74 65 20 69 74 hen to delete it
0fb0: 29 20 61 6e 64 20 61 20 22 63 6e 74 22 0a 2a 2a ) and a "cnt".**
0fc0: 20 66 69 65 6c 64 20 74 68 61 74 20 74 65 6c 6c field that tell
0fd0: 73 20 75 73 20 69 74 73 20 69 6e 74 65 72 6e 61 s us its interna
0fe0: 6c 20 6c 6f 63 6b 20 73 74 61 74 75 73 2e 20 20 l lock status.
0ff0: 63 6e 74 3d 3d 30 20 6d 65 61 6e 73 20 74 68 65 cnt==0 means the
1000: 0a 2a 2a 20 66 69 6c 65 20 69 73 20 75 6e 6c 6f .** file is unlo
1010: 63 6b 65 64 2e 20 20 63 6e 74 3d 3d 2d 31 20 6d cked. cnt==-1 m
1020: 65 61 6e 73 20 74 68 65 20 66 69 6c 65 20 68 61 eans the file ha
1030: 73 20 61 6e 20 65 78 63 6c 75 73 69 76 65 20 6c s an exclusive l
1040: 6f 63 6b 2e 0a 2a 2a 20 63 6e 74 3e 30 20 6d 65 ock..** cnt>0 me
1050: 61 6e 73 20 74 68 65 72 65 20 61 72 65 20 63 6e ans there are cn
1060: 74 20 73 68 61 72 65 64 20 6c 6f 63 6b 73 20 6f t shared locks o
1070: 6e 20 74 68 65 20 66 69 6c 65 2e 0a 2a 2a 0a 2a n the file..**.*
1080: 2a 20 41 6e 79 20 61 74 74 65 6d 70 74 20 74 6f * Any attempt to
1090: 20 6c 6f 63 6b 20 6f 72 20 75 6e 6c 6f 63 6b 20 lock or unlock
10a0: 61 20 66 69 6c 65 20 66 69 72 73 74 20 63 68 65 a file first che
10b0: 63 6b 73 20 74 68 65 20 6c 6f 63 6b 69 6e 67 0a cks the locking.
10c0: 2a 2a 20 73 74 72 75 63 74 75 72 65 2e 20 20 54 ** structure. T
10d0: 68 65 20 66 63 6e 74 6c 28 29 20 73 79 73 74 65 he fcntl() syste
10e0: 6d 20 63 61 6c 6c 20 69 73 20 6f 6e 6c 79 20 69 m call is only i
10f0: 6e 76 6f 6b 65 64 20 74 6f 20 73 65 74 20 61 20 nvoked to set a
1100: 0a 2a 2a 20 50 4f 53 49 58 20 6c 6f 63 6b 20 69 .** POSIX lock i
1110: 66 20 74 68 65 20 69 6e 74 65 72 6e 61 6c 20 6c f the internal l
1120: 6f 63 6b 20 73 74 72 75 63 74 75 72 65 20 74 72 ock structure tr
1130: 61 6e 73 69 74 69 6f 6e 73 20 62 65 74 77 65 65 ansitions betwee
1140: 6e 0a 2a 2a 20 61 20 6c 6f 63 6b 65 64 20 61 6e n.** a locked an
1150: 64 20 61 6e 20 75 6e 6c 6f 63 6b 65 64 20 73 74 d an unlocked st
1160: 61 74 65 2e 0a 2a 2a 0a 2a 2a 20 32 30 30 34 2d ate..**.** 2004-
1170: 4a 61 6e 2d 31 31 3a 0a 2a 2a 20 4d 6f 72 65 20 Jan-11:.** More
1180: 72 65 63 65 6e 74 20 64 69 73 63 6f 76 65 72 69 recent discoveri
1190: 65 73 20 61 62 6f 75 74 20 50 4f 53 49 58 20 61 es about POSIX a
11a0: 64 76 69 73 6f 72 79 20 6c 6f 63 6b 73 2e 20 20 dvisory locks.
11b0: 28 54 68 65 20 6d 6f 72 65 0a 2a 2a 20 49 20 64 (The more.** I d
11c0: 69 73 63 6f 76 65 72 2c 20 74 68 65 20 6d 6f 72 iscover, the mor
11d0: 65 20 49 20 72 65 61 6c 69 7a 65 20 74 68 65 20 e I realize the
11e0: 61 20 50 4f 53 49 58 20 61 64 76 69 73 6f 72 79 a POSIX advisory
11f0: 20 6c 6f 63 6b 73 20 61 72 65 0a 2a 2a 20 61 6e locks are.** an
1200: 20 61 62 6f 6d 69 6e 61 74 69 6f 6e 2e 29 0a 2a abomination.).*
1210: 2a 0a 2a 2a 20 49 66 20 79 6f 75 20 63 6c 6f 73 *.** If you clos
1220: 65 20 61 20 66 69 6c 65 20 64 65 73 63 72 69 70 e a file descrip
1230: 74 6f 72 20 74 68 61 74 20 70 6f 69 6e 74 73 20 tor that points
1240: 74 6f 20 61 20 66 69 6c 65 20 74 68 61 74 20 68 to a file that h
1250: 61 73 20 6c 6f 63 6b 73 2c 0a 2a 2a 20 61 6c 6c as locks,.** all
1260: 20 6c 6f 63 6b 73 20 6f 6e 20 74 68 61 74 20 66 locks on that f
1270: 69 6c 65 20 74 68 61 74 20 61 72 65 20 6f 77 6e ile that are own
1280: 65 64 20 62 79 20 74 68 65 20 63 75 72 72 65 6e ed by the curren
1290: 74 20 70 72 6f 63 65 73 73 20 61 72 65 0a 2a 2a t process are.**
12a0: 20 72 65 6c 65 61 73 65 64 2e 20 20 54 6f 20 77 released. To w
12b0: 6f 72 6b 20 61 72 6f 75 6e 64 20 74 68 69 73 20 ork around this
12c0: 70 72 6f 62 6c 65 6d 2c 20 65 61 63 68 20 4f 73 problem, each Os
12d0: 46 69 6c 65 20 73 74 72 75 63 74 75 72 65 20 63 File structure c
12e0: 6f 6e 74 61 69 6e 73 0a 2a 2a 20 61 20 70 6f 69 ontains.** a poi
12f0: 6e 74 65 72 20 74 6f 20 61 6e 20 6f 70 65 6e 43 nter to an openC
1300: 6e 74 20 73 74 72 75 63 74 75 72 65 2e 20 20 54 nt structure. T
1310: 68 65 72 65 20 69 73 20 6f 6e 65 20 6f 70 65 6e here is one open
1320: 43 6e 74 20 73 74 72 75 63 74 75 72 65 0a 2a 2a Cnt structure.**
1330: 20 70 65 72 20 6f 70 65 6e 20 69 6e 6f 64 65 2c per open inode,
1340: 20 77 68 69 63 68 20 6d 65 61 6e 73 20 74 68 61 which means tha
1350: 74 20 6d 75 6c 74 69 70 6c 65 20 4f 73 46 69 6c t multiple OsFil
1360: 65 73 20 63 61 6e 20 70 6f 69 6e 74 20 74 6f 20 es can point to
1370: 61 20 73 69 6e 67 6c 65 0a 2a 2a 20 6f 70 65 6e a single.** open
1380: 43 6e 74 2e 20 20 57 68 65 6e 20 61 6e 20 61 74 Cnt. When an at
1390: 74 65 6d 70 74 20 69 73 20 6d 61 64 65 20 74 6f tempt is made to
13a0: 20 63 6c 6f 73 65 20 61 6e 20 4f 73 46 69 6c 65 close an OsFile
13b0: 2c 20 69 66 20 74 68 65 72 65 20 61 72 65 0a 2a , if there are.*
13c0: 2a 20 6f 74 68 65 72 20 4f 73 46 69 6c 65 73 20 * other OsFiles
13d0: 6f 70 65 6e 20 6f 6e 20 74 68 65 20 73 61 6d 65 open on the same
13e0: 20 69 6e 6f 64 65 20 74 68 61 74 20 61 72 65 20 inode that are
13f0: 68 6f 6c 64 69 6e 67 20 6c 6f 63 6b 73 2c 20 74 holding locks, t
1400: 68 65 20 63 61 6c 6c 0a 2a 2a 20 74 6f 20 63 6c he call.** to cl
1410: 6f 73 65 28 29 20 74 68 65 20 66 69 6c 65 20 64 ose() the file d
1420: 65 73 63 72 69 70 74 6f 72 20 69 73 20 64 65 66 escriptor is def
1430: 65 72 72 65 64 20 75 6e 74 69 6c 20 61 6c 6c 20 erred until all
1440: 6f 66 20 74 68 65 20 6c 6f 63 6b 73 20 63 6c 65 of the locks cle
1450: 61 72 2e 0a 2a 2a 20 54 68 65 20 6f 70 65 6e 43 ar..** The openC
1460: 6e 74 20 73 74 72 75 63 74 75 72 65 20 6b 65 65 nt structure kee
1470: 70 73 20 61 20 6c 69 73 74 20 6f 66 20 66 69 6c ps a list of fil
1480: 65 20 64 65 73 63 72 69 70 74 6f 72 73 20 74 68 e descriptors th
1490: 61 74 20 6e 65 65 64 20 74 6f 0a 2a 2a 20 62 65 at need to.** be
14a0: 20 63 6c 6f 73 65 64 20 61 6e 64 20 74 68 61 74 closed and that
14b0: 20 6c 69 73 74 20 69 73 20 77 61 6c 6b 65 64 20 list is walked
14c0: 28 61 6e 64 20 63 6c 65 61 72 65 64 29 20 77 68 (and cleared) wh
14d0: 65 6e 20 74 68 65 20 6c 61 73 74 20 6c 6f 63 6b en the last lock
14e0: 0a 2a 2a 20 63 6c 65 61 72 73 2e 0a 2a 2a 0a 2a .** clears..**.*
14f0: 2a 20 46 69 72 73 74 2c 20 75 6e 64 65 72 20 4c * First, under L
1500: 69 6e 75 78 20 74 68 72 65 61 64 73 2c 20 62 65 inux threads, be
1510: 63 61 75 73 65 20 65 61 63 68 20 74 68 72 65 61 cause each threa
1520: 64 20 68 61 73 20 61 20 73 65 70 61 72 61 74 65 d has a separate
1530: 0a 2a 2a 20 70 72 6f 63 65 73 73 20 49 44 2c 20 .** process ID,
1540: 6c 6f 63 6b 20 6f 70 65 72 61 74 69 6f 6e 73 20 lock operations
1550: 69 6e 20 6f 6e 65 20 74 68 72 65 61 64 20 64 6f in one thread do
1560: 20 6e 6f 74 20 6f 76 65 72 72 69 64 65 20 6c 6f not override lo
1570: 63 6b 73 0a 2a 2a 20 74 6f 20 74 68 65 20 73 61 cks.** to the sa
1580: 6d 65 20 66 69 6c 65 20 69 6e 20 6f 74 68 65 72 me file in other
1590: 20 74 68 72 65 61 64 73 2e 20 20 4c 69 6e 75 78 threads. Linux
15a0: 20 74 68 72 65 61 64 73 20 62 65 68 61 76 65 20 threads behave
15b0: 6c 69 6b 65 0a 2a 2a 20 73 65 70 61 72 61 74 65 like.** separate
15c0: 20 70 72 6f 63 65 73 73 65 73 20 69 6e 20 74 68 processes in th
15d0: 69 73 20 72 65 73 70 65 63 74 2e 20 20 42 75 74 is respect. But
15e0: 2c 20 69 66 20 79 6f 75 20 63 6c 6f 73 65 20 61 , if you close a
15f0: 20 66 69 6c 65 0a 2a 2a 20 64 65 73 63 72 69 70 file.** descrip
1600: 74 6f 72 20 69 6e 20 6c 69 6e 75 78 20 74 68 72 tor in linux thr
1610: 65 61 64 73 2c 20 61 6c 6c 20 6c 6f 63 6b 73 20 eads, all locks
1620: 61 72 65 20 63 6c 65 61 72 65 64 2c 20 65 76 65 are cleared, eve
1630: 6e 20 6c 6f 63 6b 73 0a 2a 2a 20 6f 6e 20 6f 74 n locks.** on ot
1640: 68 65 72 20 74 68 72 65 61 64 73 20 61 6e 64 20 her threads and
1650: 65 76 65 6e 20 74 68 6f 75 67 68 20 74 68 65 20 even though the
1660: 6f 74 68 65 72 20 74 68 72 65 61 64 73 20 68 61 other threads ha
1670: 76 65 20 64 69 66 66 65 72 65 6e 74 0a 2a 2a 20 ve different.**
1680: 70 72 6f 63 65 73 73 20 49 44 73 2e 20 20 4c 69 process IDs. Li
1690: 6e 75 78 20 74 68 72 65 61 64 73 20 69 73 20 69 nux threads is i
16a0: 6e 63 6f 6e 73 69 73 74 65 6e 74 20 69 6e 20 74 nconsistent in t
16b0: 68 69 73 20 72 65 73 70 65 63 74 2e 0a 2a 2a 20 his respect..**
16c0: 28 49 27 6d 20 62 65 67 69 6e 6e 69 6e 67 20 74 (I'm beginning t
16d0: 6f 20 74 68 69 6e 6b 20 74 68 61 74 20 6c 69 6e o think that lin
16e0: 75 78 20 74 68 72 65 61 64 73 20 69 73 20 61 6e ux threads is an
16f0: 20 61 62 6f 6d 69 6e 61 74 69 6f 6e 20 74 6f 6f abomination too
1700: 2e 29 0a 2a 2a 20 54 68 65 20 63 6f 6e 73 65 71 .).** The conseq
1710: 75 65 6e 63 65 20 6f 66 20 74 68 69 73 20 61 6c uence of this al
1720: 6c 20 69 73 20 74 68 61 74 20 74 68 65 20 68 61 l is that the ha
1730: 73 68 20 74 61 62 6c 65 20 66 6f 72 20 74 68 65 sh table for the
1740: 20 6c 6f 63 6b 49 6e 66 6f 0a 2a 2a 20 73 74 72 lockInfo.** str
1750: 75 63 74 75 72 65 20 68 61 73 20 74 6f 20 69 6e ucture has to in
1760: 63 6c 75 64 65 20 74 68 65 20 70 72 6f 63 65 73 clude the proces
1770: 73 20 69 64 20 61 73 20 70 61 72 74 20 6f 66 20 s id as part of
1780: 69 74 73 20 6b 65 79 20 62 65 63 61 75 73 65 0a its key because.
1790: 2a 2a 20 6c 6f 63 6b 73 20 69 6e 20 64 69 66 66 ** locks in diff
17a0: 65 72 65 6e 74 20 74 68 72 65 61 64 73 20 61 72 erent threads ar
17b0: 65 20 74 72 65 61 74 65 64 20 61 73 20 64 69 73 e treated as dis
17c0: 74 69 6e 63 74 2e 20 20 42 75 74 20 74 68 65 20 tinct. But the
17d0: 0a 2a 2a 20 6f 70 65 6e 43 6e 74 20 73 74 72 75 .** openCnt stru
17e0: 63 74 75 72 65 20 73 68 6f 75 6c 64 20 6e 6f 74 cture should not
17f0: 20 69 6e 63 6c 75 64 65 20 74 68 65 20 70 72 6f include the pro
1800: 63 65 73 73 20 69 64 20 69 6e 20 69 74 73 0a 2a cess id in its.*
1810: 2a 20 6b 65 79 20 62 65 63 61 75 73 65 20 63 6c * key because cl
1820: 6f 73 65 28 29 20 63 6c 65 61 72 73 20 6c 6f 63 ose() clears loc
1830: 6b 20 6f 6e 20 61 6c 6c 20 74 68 72 65 61 64 73 k on all threads
1840: 2c 20 6e 6f 74 20 6a 75 73 74 20 74 68 65 20 63 , not just the c
1850: 75 72 72 65 6e 74 0a 2a 2a 20 74 68 72 65 61 64 urrent.** thread
1860: 2e 20 20 57 65 72 65 20 69 74 20 6e 6f 74 20 66 . Were it not f
1870: 6f 72 20 74 68 69 73 20 67 6f 6f 66 69 6e 65 73 or this goofines
1880: 73 20 69 6e 20 6c 69 6e 75 78 20 74 68 72 65 61 s in linux threa
1890: 64 73 2c 20 77 65 20 63 6f 75 6c 64 0a 2a 2a 20 ds, we could.**
18a0: 63 6f 6d 62 69 6e 65 20 74 68 65 20 6c 6f 63 6b combine the lock
18b0: 49 6e 66 6f 20 61 6e 64 20 6f 70 65 6e 43 6e 74 Info and openCnt
18c0: 20 73 74 72 75 63 74 75 72 65 73 20 69 6e 74 6f structures into
18d0: 20 61 20 73 69 6e 67 6c 65 20 73 74 72 75 63 74 a single struct
18e0: 75 72 65 2e 0a 2a 2f 0a 0a 2f 2a 0a 2a 2a 20 41 ure..*/../*.** A
18f0: 6e 20 69 6e 73 74 61 6e 63 65 20 6f 66 20 74 68 n instance of th
1900: 65 20 66 6f 6c 6c 6f 77 69 6e 67 20 73 74 72 75 e following stru
1910: 63 74 75 72 65 20 73 65 72 76 65 73 20 61 73 20 cture serves as
1920: 74 68 65 20 6b 65 79 20 75 73 65 64 0a 2a 2a 20 the key used.**
1930: 74 6f 20 6c 6f 63 61 74 65 20 61 20 70 61 72 74 to locate a part
1940: 69 63 75 6c 61 72 20 6c 6f 63 6b 49 6e 66 6f 20 icular lockInfo
1950: 73 74 72 75 63 74 75 72 65 20 67 69 76 65 6e 20 structure given
1960: 69 74 73 20 69 6e 6f 64 65 2e 20 20 4e 6f 74 65 its inode. Note
1970: 0a 2a 2a 20 74 68 61 74 20 77 65 20 68 61 76 65 .** that we have
1980: 20 74 6f 20 69 6e 63 6c 75 64 65 20 74 68 65 20 to include the
1990: 70 72 6f 63 65 73 73 20 49 44 20 61 73 20 70 61 process ID as pa
19a0: 72 74 20 6f 66 20 74 68 65 20 6b 65 79 2e 20 20 rt of the key.
19b0: 4f 6e 20 73 6f 6d 65 0a 2a 2a 20 74 68 72 65 61 On some.** threa
19c0: 64 69 6e 67 20 69 6d 70 6c 65 6d 65 6e 74 61 74 ding implementat
19d0: 69 6f 6e 73 20 28 65 78 3a 20 6c 69 6e 75 78 29 ions (ex: linux)
19e0: 2c 20 65 61 63 68 20 74 68 72 65 61 64 20 68 61 , each thread ha
19f0: 73 20 61 20 73 65 70 61 72 61 74 65 0a 2a 2a 20 s a separate.**
1a00: 70 72 6f 63 65 73 73 20 49 44 2e 0a 2a 2f 0a 73 process ID..*/.s
1a10: 74 72 75 63 74 20 6c 6f 63 6b 4b 65 79 20 7b 0a truct lockKey {.
1a20: 20 20 64 65 76 5f 74 20 64 65 76 3b 20 20 20 2f dev_t dev; /
1a30: 2a 20 44 65 76 69 63 65 20 6e 75 6d 62 65 72 20 * Device number
1a40: 2a 2f 0a 20 20 69 6e 6f 5f 74 20 69 6e 6f 3b 20 */. ino_t ino;
1a50: 20 20 2f 2a 20 49 6e 6f 64 65 20 6e 75 6d 62 65 /* Inode numbe
1a60: 72 20 2a 2f 0a 20 20 70 69 64 5f 74 20 70 69 64 r */. pid_t pid
1a70: 3b 20 20 20 2f 2a 20 50 72 6f 63 65 73 73 20 49 ; /* Process I
1a80: 44 20 2a 2f 0a 7d 3b 0a 0a 2f 2a 0a 2a 2a 20 41 D */.};../*.** A
1a90: 6e 20 69 6e 73 74 61 6e 63 65 20 6f 66 20 74 68 n instance of th
1aa0: 65 20 66 6f 6c 6c 6f 77 69 6e 67 20 73 74 72 75 e following stru
1ab0: 63 74 75 72 65 20 69 73 20 61 6c 6c 6f 63 61 74 cture is allocat
1ac0: 65 64 20 66 6f 72 20 65 61 63 68 20 6f 70 65 6e ed for each open
1ad0: 0a 2a 2a 20 69 6e 6f 64 65 20 6f 6e 20 65 61 63 .** inode on eac
1ae0: 68 20 74 68 72 65 61 64 20 77 69 74 68 20 61 20 h thread with a
1af0: 64 69 66 66 65 72 65 6e 74 20 70 72 6f 63 65 73 different proces
1b00: 73 20 49 44 2e 20 20 28 54 68 72 65 61 64 73 20 s ID. (Threads
1b10: 68 61 76 65 0a 2a 2a 20 64 69 66 66 65 72 65 6e have.** differen
1b20: 74 20 70 72 6f 63 65 73 73 20 49 44 73 20 6f 6e t process IDs on
1b30: 20 6c 69 6e 75 78 2c 20 62 75 74 20 6e 6f 74 20 linux, but not
1b40: 6f 6e 20 6d 6f 73 74 20 6f 74 68 65 72 20 75 6e on most other un
1b50: 69 78 65 73 2e 29 0a 2a 2a 0a 2a 2a 20 41 20 73 ixes.).**.** A s
1b60: 69 6e 67 6c 65 20 69 6e 6f 64 65 20 63 61 6e 20 ingle inode can
1b70: 68 61 76 65 20 6d 75 6c 74 69 70 6c 65 20 66 69 have multiple fi
1b80: 6c 65 20 64 65 73 63 72 69 70 74 6f 72 73 2c 20 le descriptors,
1b90: 73 6f 20 65 61 63 68 20 4f 73 46 69 6c 65 0a 2a so each OsFile.*
1ba0: 2a 20 73 74 72 75 63 74 75 72 65 20 63 6f 6e 74 * structure cont
1bb0: 61 69 6e 73 20 61 20 70 6f 69 6e 74 65 72 20 74 ains a pointer t
1bc0: 6f 20 61 6e 20 69 6e 73 74 61 6e 63 65 20 6f 66 o an instance of
1bd0: 20 74 68 69 73 20 6f 62 6a 65 63 74 20 61 6e 64 this object and
1be0: 20 74 68 69 73 0a 2a 2a 20 6f 62 6a 65 63 74 20 this.** object
1bf0: 6b 65 65 70 73 20 61 20 63 6f 75 6e 74 20 6f 66 keeps a count of
1c00: 20 74 68 65 20 6e 75 6d 62 65 72 20 6f 66 20 4f the number of O
1c10: 73 46 69 6c 65 73 20 70 6f 69 6e 74 69 6e 67 20 sFiles pointing
1c20: 74 6f 20 69 74 2e 0a 2a 2f 0a 73 74 72 75 63 74 to it..*/.struct
1c30: 20 6c 6f 63 6b 49 6e 66 6f 20 7b 0a 20 20 73 74 lockInfo {. st
1c40: 72 75 63 74 20 6c 6f 63 6b 4b 65 79 20 6b 65 79 ruct lockKey key
1c50: 3b 20 20 2f 2a 20 54 68 65 20 6c 6f 6f 6b 75 70 ; /* The lookup
1c60: 20 6b 65 79 20 2a 2f 0a 20 20 69 6e 74 20 63 6e key */. int cn
1c70: 74 3b 20 20 20 20 20 20 20 20 20 20 20 20 20 2f t; /
1c80: 2a 20 4e 75 6d 62 65 72 20 6f 66 20 53 48 41 52 * Number of SHAR
1c90: 45 44 20 6c 6f 63 6b 73 20 68 65 6c 64 20 2a 2f ED locks held */
1ca0: 0a 20 20 69 6e 74 20 6c 6f 63 6b 74 79 70 65 3b . int locktype;
1cb0: 20 20 20 20 20 20 20 20 2f 2a 20 4f 6e 65 20 6f /* One o
1cc0: 66 20 53 48 41 52 45 44 5f 4c 4f 43 4b 2c 20 52 f SHARED_LOCK, R
1cd0: 45 53 45 52 56 45 44 5f 4c 4f 43 4b 20 65 74 63 ESERVED_LOCK etc
1ce0: 2e 20 2a 2f 0a 20 20 69 6e 74 20 6e 52 65 66 3b . */. int nRef;
1cf0: 20 20 20 20 20 20 20 20 20 20 20 20 2f 2a 20 4e /* N
1d00: 75 6d 62 65 72 20 6f 66 20 70 6f 69 6e 74 65 72 umber of pointer
1d10: 73 20 74 6f 20 74 68 69 73 20 73 74 72 75 63 74 s to this struct
1d20: 75 72 65 20 2a 2f 0a 7d 3b 0a 0a 2f 2a 0a 2a 2a ure */.};../*.**
1d30: 20 41 6e 20 69 6e 73 74 61 6e 63 65 20 6f 66 20 An instance of
1d40: 74 68 65 20 66 6f 6c 6c 6f 77 69 6e 67 20 73 74 the following st
1d50: 72 75 63 74 75 72 65 20 73 65 72 76 65 73 20 61 ructure serves a
1d60: 73 20 74 68 65 20 6b 65 79 20 75 73 65 64 0a 2a s the key used.*
1d70: 2a 20 74 6f 20 6c 6f 63 61 74 65 20 61 20 70 61 * to locate a pa
1d80: 72 74 69 63 75 6c 61 72 20 6f 70 65 6e 43 6e 74 rticular openCnt
1d90: 20 73 74 72 75 63 74 75 72 65 20 67 69 76 65 6e structure given
1da0: 20 69 74 73 20 69 6e 6f 64 65 2e 20 20 54 68 69 its inode. Thi
1db0: 73 0a 2a 2a 20 69 73 20 74 68 65 20 73 61 6d 65 s.** is the same
1dc0: 20 61 73 20 74 68 65 20 6c 6f 63 6b 4b 65 79 20 as the lockKey
1dd0: 65 78 63 65 70 74 20 74 68 61 74 20 74 68 65 20 except that the
1de0: 70 72 6f 63 65 73 73 20 49 44 20 69 73 20 6f 6d process ID is om
1df0: 69 74 74 65 64 2e 0a 2a 2f 0a 73 74 72 75 63 74 itted..*/.struct
1e00: 20 6f 70 65 6e 4b 65 79 20 7b 0a 20 20 64 65 76 openKey {. dev
1e10: 5f 74 20 64 65 76 3b 20 20 20 2f 2a 20 44 65 76 _t dev; /* Dev
1e20: 69 63 65 20 6e 75 6d 62 65 72 20 2a 2f 0a 20 20 ice number */.
1e30: 69 6e 6f 5f 74 20 69 6e 6f 3b 20 20 20 2f 2a 20 ino_t ino; /*
1e40: 49 6e 6f 64 65 20 6e 75 6d 62 65 72 20 2a 2f 0a Inode number */.
1e50: 7d 3b 0a 0a 2f 2a 0a 2a 2a 20 41 6e 20 69 6e 73 };../*.** An ins
1e60: 74 61 6e 63 65 20 6f 66 20 74 68 65 20 66 6f 6c tance of the fol
1e70: 6c 6f 77 69 6e 67 20 73 74 72 75 63 74 75 72 65 lowing structure
1e80: 20 69 73 20 61 6c 6c 6f 63 61 74 65 64 20 66 6f is allocated fo
1e90: 72 20 65 61 63 68 20 6f 70 65 6e 0a 2a 2a 20 69 r each open.** i
1ea0: 6e 6f 64 65 2e 20 20 54 68 69 73 20 73 74 72 75 node. This stru
1eb0: 63 74 75 72 65 20 6b 65 65 70 73 20 74 72 61 63 cture keeps trac
1ec0: 6b 20 6f 66 20 74 68 65 20 6e 75 6d 62 65 72 20 k of the number
1ed0: 6f 66 20 6c 6f 63 6b 73 20 6f 6e 20 74 68 61 74 of locks on that
1ee0: 0a 2a 2a 20 69 6e 6f 64 65 2e 20 20 49 66 20 61 .** inode. If a
1ef0: 20 63 6c 6f 73 65 20 69 73 20 61 74 74 65 6d 70 close is attemp
1f00: 74 65 64 20 61 67 61 69 6e 73 74 20 61 6e 20 69 ted against an i
1f10: 6e 6f 64 65 20 74 68 61 74 20 69 73 20 68 6f 6c node that is hol
1f20: 64 69 6e 67 0a 2a 2a 20 6c 6f 63 6b 73 2c 20 74 ding.** locks, t
1f30: 68 65 20 63 6c 6f 73 65 20 69 73 20 64 65 66 65 he close is defe
1f40: 72 72 65 64 20 75 6e 74 69 6c 20 61 6c 6c 20 6c rred until all l
1f50: 6f 63 6b 73 20 63 6c 65 61 72 20 62 79 20 61 64 ocks clear by ad
1f60: 64 69 6e 67 20 74 68 65 0a 2a 2a 20 66 69 6c 65 ding the.** file
1f70: 20 64 65 73 63 72 69 70 74 6f 72 20 74 6f 20 62 descriptor to b
1f80: 65 20 63 6c 6f 73 65 64 20 74 6f 20 74 68 65 20 e closed to the
1f90: 70 65 6e 64 69 6e 67 20 6c 69 73 74 2e 0a 2a 2f pending list..*/
1fa0: 0a 73 74 72 75 63 74 20 6f 70 65 6e 43 6e 74 20 .struct openCnt
1fb0: 7b 0a 20 20 73 74 72 75 63 74 20 6f 70 65 6e 4b {. struct openK
1fc0: 65 79 20 6b 65 79 3b 20 20 20 2f 2a 20 54 68 65 ey key; /* The
1fd0: 20 6c 6f 6f 6b 75 70 20 6b 65 79 20 2a 2f 0a 20 lookup key */.
1fe0: 20 69 6e 74 20 6e 52 65 66 3b 20 20 20 20 20 20 int nRef;
1ff0: 20 20 20 20 20 20 20 2f 2a 20 4e 75 6d 62 65 72 /* Number
2000: 20 6f 66 20 70 6f 69 6e 74 65 72 73 20 74 6f 20 of pointers to
2010: 74 68 69 73 20 73 74 72 75 63 74 75 72 65 20 2a this structure *
2020: 2f 0a 20 20 69 6e 74 20 6e 4c 6f 63 6b 3b 20 20 /. int nLock;
2030: 20 20 20 20 20 20 20 20 20 20 2f 2a 20 4e 75 6d /* Num
2040: 62 65 72 20 6f 66 20 6f 75 74 73 74 61 6e 64 69 ber of outstandi
2050: 6e 67 20 6c 6f 63 6b 73 20 2a 2f 0a 20 20 69 6e ng locks */. in
2060: 74 20 6e 50 65 6e 64 69 6e 67 3b 20 20 20 20 20 t nPending;
2070: 20 20 20 20 2f 2a 20 4e 75 6d 62 65 72 20 6f 66 /* Number of
2080: 20 70 65 6e 64 69 6e 67 20 63 6c 6f 73 65 28 29 pending close()
2090: 20 6f 70 65 72 61 74 69 6f 6e 73 20 2a 2f 0a 20 operations */.
20a0: 20 69 6e 74 20 2a 61 50 65 6e 64 69 6e 67 3b 20 int *aPending;
20b0: 20 20 20 20 20 20 20 2f 2a 20 4d 61 6c 6c 6f 63 /* Malloc
20c0: 65 64 20 73 70 61 63 65 20 68 6f 6c 64 69 6e 67 ed space holding
20d0: 20 66 64 27 73 20 61 77 61 69 74 69 6e 67 20 61 fd's awaiting a
20e0: 20 63 6c 6f 73 65 28 29 20 2a 2f 0a 7d 3b 0a 0a close() */.};..
20f0: 2f 2a 20 0a 2a 2a 20 54 68 65 73 65 20 68 61 73 /* .** These has
2100: 68 20 74 61 62 6c 65 20 6d 61 70 73 20 69 6e 6f h table maps ino
2110: 64 65 73 20 61 6e 64 20 70 72 6f 63 65 73 73 20 des and process
2120: 49 44 73 20 69 6e 74 6f 20 6c 6f 63 6b 49 6e 66 IDs into lockInf
2130: 6f 20 61 6e 64 20 6f 70 65 6e 43 6e 74 0a 2a 2a o and openCnt.**
2140: 20 73 74 72 75 63 74 75 72 65 73 2e 20 20 41 63 structures. Ac
2150: 63 65 73 73 20 74 6f 20 74 68 65 73 65 20 68 61 cess to these ha
2160: 73 68 20 74 61 62 6c 65 73 20 6d 75 73 74 20 62 sh tables must b
2170: 65 20 70 72 6f 74 65 63 74 65 64 20 62 79 20 61 e protected by a
2180: 20 6d 75 74 65 78 2e 0a 2a 2f 0a 73 74 61 74 69 mutex..*/.stati
2190: 63 20 48 61 73 68 20 6c 6f 63 6b 48 61 73 68 20 c Hash lockHash
21a0: 3d 20 7b 20 53 51 4c 49 54 45 5f 48 41 53 48 5f = { SQLITE_HASH_
21b0: 42 49 4e 41 52 59 2c 20 30 2c 20 30 2c 20 30 2c BINARY, 0, 0, 0,
21c0: 20 30 2c 20 30 20 7d 3b 0a 73 74 61 74 69 63 20 0, 0 };.static
21d0: 48 61 73 68 20 6f 70 65 6e 48 61 73 68 20 3d 20 Hash openHash =
21e0: 7b 20 53 51 4c 49 54 45 5f 48 41 53 48 5f 42 49 { SQLITE_HASH_BI
21f0: 4e 41 52 59 2c 20 30 2c 20 30 2c 20 30 2c 20 30 NARY, 0, 0, 0, 0
2200: 2c 20 30 20 7d 3b 0a 0a 2f 2a 0a 2a 2a 20 52 65 , 0 };../*.** Re
2210: 6c 65 61 73 65 20 61 20 6c 6f 63 6b 49 6e 66 6f lease a lockInfo
2220: 20 73 74 72 75 63 74 75 72 65 20 70 72 65 76 69 structure previ
2230: 6f 75 73 6c 79 20 61 6c 6c 6f 63 61 74 65 64 20 ously allocated
2240: 62 79 20 66 69 6e 64 4c 6f 63 6b 49 6e 66 6f 28 by findLockInfo(
2250: 29 2e 0a 2a 2f 0a 73 74 61 74 69 63 20 76 6f 69 )..*/.static voi
2260: 64 20 72 65 6c 65 61 73 65 4c 6f 63 6b 49 6e 66 d releaseLockInf
2270: 6f 28 73 74 72 75 63 74 20 6c 6f 63 6b 49 6e 66 o(struct lockInf
2280: 6f 20 2a 70 4c 6f 63 6b 29 7b 0a 20 20 70 4c 6f o *pLock){. pLo
2290: 63 6b 2d 3e 6e 52 65 66 2d 2d 3b 0a 20 20 69 66 ck->nRef--;. if
22a0: 28 20 70 4c 6f 63 6b 2d 3e 6e 52 65 66 3d 3d 30 ( pLock->nRef==0
22b0: 20 29 7b 0a 20 20 20 20 73 71 6c 69 74 65 33 48 ){. sqlite3H
22c0: 61 73 68 49 6e 73 65 72 74 28 26 6c 6f 63 6b 48 ashInsert(&lockH
22d0: 61 73 68 2c 20 26 70 4c 6f 63 6b 2d 3e 6b 65 79 ash, &pLock->key
22e0: 2c 20 73 69 7a 65 6f 66 28 70 4c 6f 63 6b 2d 3e , sizeof(pLock->
22f0: 6b 65 79 29 2c 20 30 29 3b 0a 20 20 20 20 73 71 key), 0);. sq
2300: 6c 69 74 65 46 72 65 65 28 70 4c 6f 63 6b 29 3b liteFree(pLock);
2310: 0a 20 20 7d 0a 7d 0a 0a 2f 2a 0a 2a 2a 20 52 65 . }.}../*.** Re
2320: 6c 65 61 73 65 20 61 20 6f 70 65 6e 43 6e 74 20 lease a openCnt
2330: 73 74 72 75 63 74 75 72 65 20 70 72 65 76 69 6f structure previo
2340: 75 73 6c 79 20 61 6c 6c 6f 63 61 74 65 64 20 62 usly allocated b
2350: 79 20 66 69 6e 64 4c 6f 63 6b 49 6e 66 6f 28 29 y findLockInfo()
2360: 2e 0a 2a 2f 0a 73 74 61 74 69 63 20 76 6f 69 64 ..*/.static void
2370: 20 72 65 6c 65 61 73 65 4f 70 65 6e 43 6e 74 28 releaseOpenCnt(
2380: 73 74 72 75 63 74 20 6f 70 65 6e 43 6e 74 20 2a struct openCnt *
2390: 70 4f 70 65 6e 29 7b 0a 20 20 70 4f 70 65 6e 2d pOpen){. pOpen-
23a0: 3e 6e 52 65 66 2d 2d 3b 0a 20 20 69 66 28 20 70 >nRef--;. if( p
23b0: 4f 70 65 6e 2d 3e 6e 52 65 66 3d 3d 30 20 29 7b Open->nRef==0 ){
23c0: 0a 20 20 20 20 73 71 6c 69 74 65 33 48 61 73 68 . sqlite3Hash
23d0: 49 6e 73 65 72 74 28 26 6f 70 65 6e 48 61 73 68 Insert(&openHash
23e0: 2c 20 26 70 4f 70 65 6e 2d 3e 6b 65 79 2c 20 73 , &pOpen->key, s
23f0: 69 7a 65 6f 66 28 70 4f 70 65 6e 2d 3e 6b 65 79 izeof(pOpen->key
2400: 29 2c 20 30 29 3b 0a 20 20 20 20 73 71 6c 69 74 ), 0);. sqlit
2410: 65 46 72 65 65 28 70 4f 70 65 6e 2d 3e 61 50 65 eFree(pOpen->aPe
2420: 6e 64 69 6e 67 29 3b 0a 20 20 20 20 73 71 6c 69 nding);. sqli
2430: 74 65 46 72 65 65 28 70 4f 70 65 6e 29 3b 0a 20 teFree(pOpen);.
2440: 20 7d 0a 7d 0a 0a 2f 2a 0a 2a 2a 20 47 69 76 65 }.}../*.** Give
2450: 6e 20 61 20 66 69 6c 65 20 64 65 73 63 72 69 70 n a file descrip
2460: 74 6f 72 2c 20 6c 6f 63 61 74 65 20 6c 6f 63 6b tor, locate lock
2470: 49 6e 66 6f 20 61 6e 64 20 6f 70 65 6e 43 6e 74 Info and openCnt
2480: 20 73 74 72 75 63 74 75 72 65 73 20 74 68 61 74 structures that
2490: 0a 2a 2a 20 64 65 73 63 72 69 62 65 73 20 74 68 .** describes th
24a0: 61 74 20 66 69 6c 65 20 64 65 73 63 72 69 70 74 at file descript
24b0: 6f 72 2e 20 20 43 72 65 61 74 65 20 61 20 6e 65 or. Create a ne
24c0: 77 20 6f 6e 65 73 20 69 66 20 6e 65 63 65 73 73 w ones if necess
24d0: 61 72 79 2e 20 20 54 68 65 0a 2a 2a 20 72 65 74 ary. The.** ret
24e0: 75 72 6e 20 76 61 6c 75 65 73 20 6d 69 67 68 74 urn values might
24f0: 20 62 65 20 75 6e 73 65 74 20 69 66 20 61 6e 20 be unset if an
2500: 65 72 72 6f 72 20 6f 63 63 75 72 73 2e 0a 2a 2a error occurs..**
2510: 0a 2a 2a 20 52 65 74 75 72 6e 20 74 68 65 20 6e .** Return the n
2520: 75 6d 62 65 72 20 6f 66 20 65 72 72 6f 72 73 2e umber of errors.
2530: 0a 2a 2f 0a 69 6e 74 20 66 69 6e 64 4c 6f 63 6b .*/.int findLock
2540: 49 6e 66 6f 28 0a 20 20 69 6e 74 20 66 64 2c 20 Info(. int fd,
2550: 20 20 20 20 20 20 20 20 20 20 20 20 20 20 20 20
2560: 20 20 20 20 20 2f 2a 20 54 68 65 20 66 69 6c 65 /* The file
2570: 20 64 65 73 63 72 69 70 74 6f 72 20 75 73 65 64 descriptor used
2580: 20 69 6e 20 74 68 65 20 6b 65 79 20 2a 2f 0a 20 in the key */.
2590: 20 73 74 72 75 63 74 20 6c 6f 63 6b 49 6e 66 6f struct lockInfo
25a0: 20 2a 2a 70 70 4c 6f 63 6b 2c 20 20 20 20 2f 2a **ppLock, /*
25b0: 20 52 65 74 75 72 6e 20 74 68 65 20 6c 6f 63 6b Return the lock
25c0: 49 6e 66 6f 20 73 74 72 75 63 74 75 72 65 20 68 Info structure h
25d0: 65 72 65 20 2a 2f 0a 20 20 73 74 72 75 63 74 20 ere */. struct
25e0: 6f 70 65 6e 43 6e 74 20 2a 2a 70 70 4f 70 65 6e openCnt **ppOpen
25f0: 20 20 20 2f 2a 20 52 65 74 75 72 6e 20 74 68 65 /* Return the
2600: 20 6f 70 65 6e 43 6e 74 20 73 74 72 75 63 74 75 openCnt structu
2610: 72 65 20 68 65 72 65 20 2a 2f 0a 29 7b 0a 20 20 re here */.){.
2620: 69 6e 74 20 72 63 3b 0a 20 20 73 74 72 75 63 74 int rc;. struct
2630: 20 6c 6f 63 6b 4b 65 79 20 6b 65 79 31 3b 0a 20 lockKey key1;.
2640: 20 73 74 72 75 63 74 20 6f 70 65 6e 4b 65 79 20 struct openKey
2650: 6b 65 79 32 3b 0a 20 20 73 74 72 75 63 74 20 73 key2;. struct s
2660: 74 61 74 20 73 74 61 74 62 75 66 3b 0a 20 20 73 tat statbuf;. s
2670: 74 72 75 63 74 20 6c 6f 63 6b 49 6e 66 6f 20 2a truct lockInfo *
2680: 70 4c 6f 63 6b 3b 0a 20 20 73 74 72 75 63 74 20 pLock;. struct
2690: 6f 70 65 6e 43 6e 74 20 2a 70 4f 70 65 6e 3b 0a openCnt *pOpen;.
26a0: 20 20 72 63 20 3d 20 66 73 74 61 74 28 66 64 2c rc = fstat(fd,
26b0: 20 26 73 74 61 74 62 75 66 29 3b 0a 20 20 69 66 &statbuf);. if
26c0: 28 20 72 63 21 3d 30 20 29 20 72 65 74 75 72 6e ( rc!=0 ) return
26d0: 20 31 3b 0a 20 20 6d 65 6d 73 65 74 28 26 6b 65 1;. memset(&ke
26e0: 79 31 2c 20 30 2c 20 73 69 7a 65 6f 66 28 6b 65 y1, 0, sizeof(ke
26f0: 79 31 29 29 3b 0a 20 20 6b 65 79 31 2e 64 65 76 y1));. key1.dev
2700: 20 3d 20 73 74 61 74 62 75 66 2e 73 74 5f 64 65 = statbuf.st_de
2710: 76 3b 0a 20 20 6b 65 79 31 2e 69 6e 6f 20 3d 20 v;. key1.ino =
2720: 73 74 61 74 62 75 66 2e 73 74 5f 69 6e 6f 3b 0a statbuf.st_ino;.
2730: 20 20 6b 65 79 31 2e 70 69 64 20 3d 20 67 65 74 key1.pid = get
2740: 70 69 64 28 29 3b 0a 20 20 6d 65 6d 73 65 74 28 pid();. memset(
2750: 26 6b 65 79 32 2c 20 30 2c 20 73 69 7a 65 6f 66 &key2, 0, sizeof
2760: 28 6b 65 79 32 29 29 3b 0a 20 20 6b 65 79 32 2e (key2));. key2.
2770: 64 65 76 20 3d 20 73 74 61 74 62 75 66 2e 73 74 dev = statbuf.st
2780: 5f 64 65 76 3b 0a 20 20 6b 65 79 32 2e 69 6e 6f _dev;. key2.ino
2790: 20 3d 20 73 74 61 74 62 75 66 2e 73 74 5f 69 6e = statbuf.st_in
27a0: 6f 3b 0a 20 20 70 4c 6f 63 6b 20 3d 20 28 73 74 o;. pLock = (st
27b0: 72 75 63 74 20 6c 6f 63 6b 49 6e 66 6f 2a 29 73 ruct lockInfo*)s
27c0: 71 6c 69 74 65 33 48 61 73 68 46 69 6e 64 28 26 qlite3HashFind(&
27d0: 6c 6f 63 6b 48 61 73 68 2c 20 26 6b 65 79 31 2c lockHash, &key1,
27e0: 20 73 69 7a 65 6f 66 28 6b 65 79 31 29 29 3b 0a sizeof(key1));.
27f0: 20 20 69 66 28 20 70 4c 6f 63 6b 3d 3d 30 20 29 if( pLock==0 )
2800: 7b 0a 20 20 20 20 73 74 72 75 63 74 20 6c 6f 63 {. struct loc
2810: 6b 49 6e 66 6f 20 2a 70 4f 6c 64 3b 0a 20 20 20 kInfo *pOld;.
2820: 20 70 4c 6f 63 6b 20 3d 20 73 71 6c 69 74 65 4d pLock = sqliteM
2830: 61 6c 6c 6f 63 52 61 77 28 20 73 69 7a 65 6f 66 allocRaw( sizeof
2840: 28 2a 70 4c 6f 63 6b 29 20 29 3b 0a 20 20 20 20 (*pLock) );.
2850: 69 66 28 20 70 4c 6f 63 6b 3d 3d 30 20 29 20 72 if( pLock==0 ) r
2860: 65 74 75 72 6e 20 31 3b 0a 20 20 20 20 70 4c 6f eturn 1;. pLo
2870: 63 6b 2d 3e 6b 65 79 20 3d 20 6b 65 79 31 3b 0a ck->key = key1;.
2880: 20 20 20 20 70 4c 6f 63 6b 2d 3e 6e 52 65 66 20 pLock->nRef
2890: 3d 20 31 3b 0a 20 20 20 20 70 4c 6f 63 6b 2d 3e = 1;. pLock->
28a0: 63 6e 74 20 3d 20 30 3b 0a 20 20 20 20 70 4c 6f cnt = 0;. pLo
28b0: 63 6b 2d 3e 6c 6f 63 6b 74 79 70 65 20 3d 20 30 ck->locktype = 0
28c0: 3b 0a 20 20 20 20 70 4f 6c 64 20 3d 20 73 71 6c ;. pOld = sql
28d0: 69 74 65 33 48 61 73 68 49 6e 73 65 72 74 28 26 ite3HashInsert(&
28e0: 6c 6f 63 6b 48 61 73 68 2c 20 26 70 4c 6f 63 6b lockHash, &pLock
28f0: 2d 3e 6b 65 79 2c 20 73 69 7a 65 6f 66 28 6b 65 ->key, sizeof(ke
2900: 79 31 29 2c 20 70 4c 6f 63 6b 29 3b 0a 20 20 20 y1), pLock);.
2910: 20 69 66 28 20 70 4f 6c 64 21 3d 30 20 29 7b 0a if( pOld!=0 ){.
2920: 20 20 20 20 20 20 61 73 73 65 72 74 28 20 70 4f assert( pO
2930: 6c 64 3d 3d 70 4c 6f 63 6b 20 29 3b 0a 20 20 20 ld==pLock );.
2940: 20 20 20 73 71 6c 69 74 65 46 72 65 65 28 70 4c sqliteFree(pL
2950: 6f 63 6b 29 3b 0a 20 20 20 20 20 20 72 65 74 75 ock);. retu
2960: 72 6e 20 31 3b 0a 20 20 20 20 7d 0a 20 20 7d 65 rn 1;. }. }e
2970: 6c 73 65 7b 0a 20 20 20 20 70 4c 6f 63 6b 2d 3e lse{. pLock->
2980: 6e 52 65 66 2b 2b 3b 0a 20 20 7d 0a 20 20 2a 70 nRef++;. }. *p
2990: 70 4c 6f 63 6b 20 3d 20 70 4c 6f 63 6b 3b 0a 20 pLock = pLock;.
29a0: 20 70 4f 70 65 6e 20 3d 20 28 73 74 72 75 63 74 pOpen = (struct
29b0: 20 6f 70 65 6e 43 6e 74 2a 29 73 71 6c 69 74 65 openCnt*)sqlite
29c0: 33 48 61 73 68 46 69 6e 64 28 26 6f 70 65 6e 48 3HashFind(&openH
29d0: 61 73 68 2c 20 26 6b 65 79 32 2c 20 73 69 7a 65 ash, &key2, size
29e0: 6f 66 28 6b 65 79 32 29 29 3b 0a 20 20 69 66 28 of(key2));. if(
29f0: 20 70 4f 70 65 6e 3d 3d 30 20 29 7b 0a 20 20 20 pOpen==0 ){.
2a00: 20 73 74 72 75 63 74 20 6f 70 65 6e 43 6e 74 20 struct openCnt
2a10: 2a 70 4f 6c 64 3b 0a 20 20 20 20 70 4f 70 65 6e *pOld;. pOpen
2a20: 20 3d 20 73 71 6c 69 74 65 4d 61 6c 6c 6f 63 52 = sqliteMallocR
2a30: 61 77 28 20 73 69 7a 65 6f 66 28 2a 70 4f 70 65 aw( sizeof(*pOpe
2a40: 6e 29 20 29 3b 0a 20 20 20 20 69 66 28 20 70 4f n) );. if( pO
2a50: 70 65 6e 3d 3d 30 20 29 7b 0a 20 20 20 20 20 20 pen==0 ){.
2a60: 72 65 6c 65 61 73 65 4c 6f 63 6b 49 6e 66 6f 28 releaseLockInfo(
2a70: 70 4c 6f 63 6b 29 3b 0a 20 20 20 20 20 20 72 65 pLock);. re
2a80: 74 75 72 6e 20 31 3b 0a 20 20 20 20 7d 0a 20 20 turn 1;. }.
2a90: 20 20 70 4f 70 65 6e 2d 3e 6b 65 79 20 3d 20 6b pOpen->key = k
2aa0: 65 79 32 3b 0a 20 20 20 20 70 4f 70 65 6e 2d 3e ey2;. pOpen->
2ab0: 6e 52 65 66 20 3d 20 31 3b 0a 20 20 20 20 70 4f nRef = 1;. pO
2ac0: 70 65 6e 2d 3e 6e 4c 6f 63 6b 20 3d 20 30 3b 0a pen->nLock = 0;.
2ad0: 20 20 20 20 70 4f 70 65 6e 2d 3e 6e 50 65 6e 64 pOpen->nPend
2ae0: 69 6e 67 20 3d 20 30 3b 0a 20 20 20 20 70 4f 70 ing = 0;. pOp
2af0: 65 6e 2d 3e 61 50 65 6e 64 69 6e 67 20 3d 20 30 en->aPending = 0
2b00: 3b 0a 20 20 20 20 70 4f 6c 64 20 3d 20 73 71 6c ;. pOld = sql
2b10: 69 74 65 33 48 61 73 68 49 6e 73 65 72 74 28 26 ite3HashInsert(&
2b20: 6f 70 65 6e 48 61 73 68 2c 20 26 70 4f 70 65 6e openHash, &pOpen
2b30: 2d 3e 6b 65 79 2c 20 73 69 7a 65 6f 66 28 6b 65 ->key, sizeof(ke
2b40: 79 32 29 2c 20 70 4f 70 65 6e 29 3b 0a 20 20 20 y2), pOpen);.
2b50: 20 69 66 28 20 70 4f 6c 64 21 3d 30 20 29 7b 0a if( pOld!=0 ){.
2b60: 20 20 20 20 20 20 61 73 73 65 72 74 28 20 70 4f assert( pO
2b70: 6c 64 3d 3d 70 4f 70 65 6e 20 29 3b 0a 20 20 20 ld==pOpen );.
2b80: 20 20 20 73 71 6c 69 74 65 46 72 65 65 28 70 4f sqliteFree(pO
2b90: 70 65 6e 29 3b 0a 20 20 20 20 20 20 72 65 6c 65 pen);. rele
2ba0: 61 73 65 4c 6f 63 6b 49 6e 66 6f 28 70 4c 6f 63 aseLockInfo(pLoc
2bb0: 6b 29 3b 0a 20 20 20 20 20 20 72 65 74 75 72 6e k);. return
2bc0: 20 31 3b 0a 20 20 20 20 7d 0a 20 20 7d 65 6c 73 1;. }. }els
2bd0: 65 7b 0a 20 20 20 20 70 4f 70 65 6e 2d 3e 6e 52 e{. pOpen->nR
2be0: 65 66 2b 2b 3b 0a 20 20 7d 0a 20 20 2a 70 70 4f ef++;. }. *ppO
2bf0: 70 65 6e 20 3d 20 70 4f 70 65 6e 3b 0a 20 20 72 pen = pOpen;. r
2c00: 65 74 75 72 6e 20 30 3b 0a 7d 0a 0a 2f 2a 0a 2a eturn 0;.}../*.*
2c10: 2a 20 44 65 6c 65 74 65 20 74 68 65 20 6e 61 6d * Delete the nam
2c20: 65 64 20 66 69 6c 65 0a 2a 2f 0a 69 6e 74 20 73 ed file.*/.int s
2c30: 71 6c 69 74 65 33 4f 73 44 65 6c 65 74 65 28 63 qlite3OsDelete(c
2c40: 6f 6e 73 74 20 63 68 61 72 20 2a 7a 46 69 6c 65 onst char *zFile
2c50: 6e 61 6d 65 29 7b 0a 20 20 75 6e 6c 69 6e 6b 28 name){. unlink(
2c60: 7a 46 69 6c 65 6e 61 6d 65 29 3b 0a 20 20 72 65 zFilename);. re
2c70: 74 75 72 6e 20 53 51 4c 49 54 45 5f 4f 4b 3b 0a turn SQLITE_OK;.
2c80: 7d 0a 0a 2f 2a 0a 2a 2a 20 52 65 74 75 72 6e 20 }../*.** Return
2c90: 54 52 55 45 20 69 66 20 74 68 65 20 6e 61 6d 65 TRUE if the name
2ca0: 64 20 66 69 6c 65 20 65 78 69 73 74 73 2e 0a 2a d file exists..*
2cb0: 2f 0a 69 6e 74 20 73 71 6c 69 74 65 33 4f 73 46 /.int sqlite3OsF
2cc0: 69 6c 65 45 78 69 73 74 73 28 63 6f 6e 73 74 20 ileExists(const
2cd0: 63 68 61 72 20 2a 7a 46 69 6c 65 6e 61 6d 65 29 char *zFilename)
2ce0: 7b 0a 20 20 72 65 74 75 72 6e 20 61 63 63 65 73 {. return acces
2cf0: 73 28 7a 46 69 6c 65 6e 61 6d 65 2c 20 30 29 3d s(zFilename, 0)=
2d00: 3d 30 3b 0a 7d 0a 0a 2f 2a 0a 2a 2a 20 41 74 74 =0;.}../*.** Att
2d10: 65 6d 70 74 20 74 6f 20 6f 70 65 6e 20 61 20 66 empt to open a f
2d20: 69 6c 65 20 66 6f 72 20 62 6f 74 68 20 72 65 61 ile for both rea
2d30: 64 69 6e 67 20 61 6e 64 20 77 72 69 74 69 6e 67 ding and writing
2d40: 2e 20 20 49 66 20 74 68 61 74 0a 2a 2a 20 66 61 . If that.** fa
2d50: 69 6c 73 2c 20 74 72 79 20 6f 70 65 6e 69 6e 67 ils, try opening
2d60: 20 69 74 20 72 65 61 64 2d 6f 6e 6c 79 2e 20 20 it read-only.
2d70: 49 66 20 74 68 65 20 66 69 6c 65 20 64 6f 65 73 If the file does
2d80: 20 6e 6f 74 20 65 78 69 73 74 2c 0a 2a 2a 20 74 not exist,.** t
2d90: 72 79 20 74 6f 20 63 72 65 61 74 65 20 69 74 2e ry to create it.
2da0: 0a 2a 2a 0a 2a 2a 20 4f 6e 20 73 75 63 63 65 73 .**.** On succes
2db0: 73 2c 20 61 20 68 61 6e 64 6c 65 20 66 6f 72 20 s, a handle for
2dc0: 74 68 65 20 6f 70 65 6e 20 66 69 6c 65 20 69 73 the open file is
2dd0: 20 77 72 69 74 74 65 6e 20 74 6f 20 2a 69 64 0a written to *id.
2de0: 2a 2a 20 61 6e 64 20 2a 70 52 65 61 64 6f 6e 6c ** and *pReadonl
2df0: 79 20 69 73 20 73 65 74 20 74 6f 20 30 20 69 66 y is set to 0 if
2e00: 20 74 68 65 20 66 69 6c 65 20 77 61 73 20 6f 70 the file was op
2e10: 65 6e 65 64 20 66 6f 72 20 72 65 61 64 69 6e 67 ened for reading
2e20: 20 61 6e 64 0a 2a 2a 20 77 72 69 74 69 6e 67 20 and.** writing
2e30: 6f 72 20 31 20 69 66 20 74 68 65 20 66 69 6c 65 or 1 if the file
2e40: 20 77 61 73 20 6f 70 65 6e 65 64 20 72 65 61 64 was opened read
2e50: 2d 6f 6e 6c 79 2e 20 20 54 68 65 20 66 75 6e 63 -only. The func
2e60: 74 69 6f 6e 20 72 65 74 75 72 6e 73 0a 2a 2a 20 tion returns.**
2e70: 53 51 4c 49 54 45 5f 4f 4b 2e 0a 2a 2a 0a 2a 2a SQLITE_OK..**.**
2e80: 20 4f 6e 20 66 61 69 6c 75 72 65 2c 20 74 68 65 On failure, the
2e90: 20 66 75 6e 63 74 69 6f 6e 20 72 65 74 75 72 6e function return
2ea0: 73 20 53 51 4c 49 54 45 5f 43 41 4e 54 4f 50 45 s SQLITE_CANTOPE
2eb0: 4e 20 61 6e 64 20 6c 65 61 76 65 73 0a 2a 2a 20 N and leaves.**
2ec0: 2a 69 64 20 61 6e 64 20 2a 70 52 65 61 64 6f 6e *id and *pReadon
2ed0: 6c 79 20 75 6e 63 68 61 6e 67 65 64 2e 0a 2a 2f ly unchanged..*/
2ee0: 0a 69 6e 74 20 73 71 6c 69 74 65 33 4f 73 4f 70 .int sqlite3OsOp
2ef0: 65 6e 52 65 61 64 57 72 69 74 65 28 0a 20 20 63 enReadWrite(. c
2f00: 6f 6e 73 74 20 63 68 61 72 20 2a 7a 46 69 6c 65 onst char *zFile
2f10: 6e 61 6d 65 2c 0a 20 20 4f 73 46 69 6c 65 20 2a name,. OsFile *
2f20: 69 64 2c 0a 20 20 69 6e 74 20 2a 70 52 65 61 64 id,. int *pRead
2f30: 6f 6e 6c 79 0a 29 7b 0a 20 20 69 6e 74 20 72 63 only.){. int rc
2f40: 3b 0a 20 20 69 64 2d 3e 64 69 72 66 64 20 3d 20 ;. id->dirfd =
2f50: 2d 31 3b 0a 20 20 69 64 2d 3e 68 20 3d 20 6f 70 -1;. id->h = op
2f60: 65 6e 28 7a 46 69 6c 65 6e 61 6d 65 2c 20 4f 5f en(zFilename, O_
2f70: 52 44 57 52 7c 4f 5f 43 52 45 41 54 7c 4f 5f 4c RDWR|O_CREAT|O_L
2f80: 41 52 47 45 46 49 4c 45 7c 4f 5f 42 49 4e 41 52 ARGEFILE|O_BINAR
2f90: 59 2c 20 30 36 34 34 29 3b 0a 20 20 69 66 28 20 Y, 0644);. if(
2fa0: 69 64 2d 3e 68 3c 30 20 29 7b 0a 20 20 20 20 69 id->h<0 ){. i
2fb0: 64 2d 3e 68 20 3d 20 6f 70 65 6e 28 7a 46 69 6c d->h = open(zFil
2fc0: 65 6e 61 6d 65 2c 20 4f 5f 52 44 4f 4e 4c 59 7c ename, O_RDONLY|
2fd0: 4f 5f 4c 41 52 47 45 46 49 4c 45 7c 4f 5f 42 49 O_LARGEFILE|O_BI
2fe0: 4e 41 52 59 29 3b 0a 20 20 20 20 69 66 28 20 69 NARY);. if( i
2ff0: 64 2d 3e 68 3c 30 20 29 7b 0a 20 20 20 20 20 20 d->h<0 ){.
3000: 72 65 74 75 72 6e 20 53 51 4c 49 54 45 5f 43 41 return SQLITE_CA
3010: 4e 54 4f 50 45 4e 3b 20 0a 20 20 20 20 7d 0a 20 NTOPEN; . }.
3020: 20 20 20 2a 70 52 65 61 64 6f 6e 6c 79 20 3d 20 *pReadonly =
3030: 31 3b 0a 20 20 7d 65 6c 73 65 7b 0a 20 20 20 20 1;. }else{.
3040: 2a 70 52 65 61 64 6f 6e 6c 79 20 3d 20 30 3b 0a *pReadonly = 0;.
3050: 20 20 7d 0a 20 20 73 71 6c 69 74 65 33 4f 73 45 }. sqlite3OsE
3060: 6e 74 65 72 4d 75 74 65 78 28 29 3b 0a 20 20 72 nterMutex();. r
3070: 63 20 3d 20 66 69 6e 64 4c 6f 63 6b 49 6e 66 6f c = findLockInfo
3080: 28 69 64 2d 3e 68 2c 20 26 69 64 2d 3e 70 4c 6f (id->h, &id->pLo
3090: 63 6b 2c 20 26 69 64 2d 3e 70 4f 70 65 6e 29 3b ck, &id->pOpen);
30a0: 0a 20 20 73 71 6c 69 74 65 33 4f 73 4c 65 61 76 . sqlite3OsLeav
30b0: 65 4d 75 74 65 78 28 29 3b 0a 20 20 69 66 28 20 eMutex();. if(
30c0: 72 63 20 29 7b 0a 20 20 20 20 63 6c 6f 73 65 28 rc ){. close(
30d0: 69 64 2d 3e 68 29 3b 0a 20 20 20 20 72 65 74 75 id->h);. retu
30e0: 72 6e 20 53 51 4c 49 54 45 5f 4e 4f 4d 45 4d 3b rn SQLITE_NOMEM;
30f0: 0a 20 20 7d 0a 20 20 69 64 2d 3e 6c 6f 63 6b 74 . }. id->lockt
3100: 79 70 65 20 3d 20 30 3b 0a 20 20 54 52 41 43 45 ype = 0;. TRACE
3110: 33 28 22 4f 50 45 4e 20 20 20 20 25 2d 33 64 20 3("OPEN %-3d
3120: 25 73 5c 6e 22 2c 20 69 64 2d 3e 68 2c 20 7a 46 %s\n", id->h, zF
3130: 69 6c 65 6e 61 6d 65 29 3b 0a 20 20 4f 70 65 6e ilename);. Open
3140: 43 6f 75 6e 74 65 72 28 2b 31 29 3b 0a 20 20 72 Counter(+1);. r
3150: 65 74 75 72 6e 20 53 51 4c 49 54 45 5f 4f 4b 3b eturn SQLITE_OK;
3160: 0a 7d 0a 0a 0a 2f 2a 0a 2a 2a 20 41 74 74 65 6d .}.../*.** Attem
3170: 70 74 20 74 6f 20 6f 70 65 6e 20 61 20 6e 65 77 pt to open a new
3180: 20 66 69 6c 65 20 66 6f 72 20 65 78 63 6c 75 73 file for exclus
3190: 69 76 65 20 61 63 63 65 73 73 20 62 79 20 74 68 ive access by th
31a0: 69 73 20 70 72 6f 63 65 73 73 2e 0a 2a 2a 20 54 is process..** T
31b0: 68 65 20 66 69 6c 65 20 77 69 6c 6c 20 62 65 20 he file will be
31c0: 6f 70 65 6e 65 64 20 66 6f 72 20 62 6f 74 68 20 opened for both
31d0: 72 65 61 64 69 6e 67 20 61 6e 64 20 77 72 69 74 reading and writ
31e0: 69 6e 67 2e 20 20 54 6f 20 61 76 6f 69 64 0a 2a ing. To avoid.*
31f0: 2a 20 61 20 70 6f 74 65 6e 74 69 61 6c 20 73 65 * a potential se
3200: 63 75 72 69 74 79 20 70 72 6f 62 6c 65 6d 2c 20 curity problem,
3210: 77 65 20 64 6f 20 6e 6f 74 20 61 6c 6c 6f 77 20 we do not allow
3220: 74 68 65 20 66 69 6c 65 20 74 6f 20 68 61 76 65 the file to have
3230: 0a 2a 2a 20 70 72 65 76 69 6f 75 73 6c 79 20 65 .** previously e
3240: 78 69 73 74 65 64 2e 20 20 4e 6f 72 20 64 6f 20 xisted. Nor do
3250: 77 65 20 61 6c 6c 6f 77 20 74 68 65 20 66 69 6c we allow the fil
3260: 65 20 74 6f 20 62 65 20 61 20 73 79 6d 62 6f 6c e to be a symbol
3270: 69 63 0a 2a 2a 20 6c 69 6e 6b 2e 0a 2a 2a 0a 2a ic.** link..**.*
3280: 2a 20 49 66 20 64 65 6c 46 6c 61 67 20 69 73 20 * If delFlag is
3290: 74 72 75 65 2c 20 74 68 65 6e 20 6d 61 6b 65 20 true, then make
32a0: 61 72 72 61 6e 67 65 6d 65 6e 74 73 20 74 6f 20 arrangements to
32b0: 61 75 74 6f 6d 61 74 69 63 61 6c 6c 79 20 64 65 automatically de
32c0: 6c 65 74 65 0a 2a 2a 20 74 68 65 20 66 69 6c 65 lete.** the file
32d0: 20 77 68 65 6e 20 69 74 20 69 73 20 63 6c 6f 73 when it is clos
32e0: 65 64 2e 0a 2a 2a 0a 2a 2a 20 4f 6e 20 73 75 63 ed..**.** On suc
32f0: 63 65 73 73 2c 20 77 72 69 74 65 20 74 68 65 20 cess, write the
3300: 66 69 6c 65 20 68 61 6e 64 6c 65 20 69 6e 74 6f file handle into
3310: 20 2a 69 64 20 61 6e 64 20 72 65 74 75 72 6e 20 *id and return
3320: 53 51 4c 49 54 45 5f 4f 4b 2e 0a 2a 2a 0a 2a 2a SQLITE_OK..**.**
3330: 20 4f 6e 20 66 61 69 6c 75 72 65 2c 20 72 65 74 On failure, ret
3340: 75 72 6e 20 53 51 4c 49 54 45 5f 43 41 4e 54 4f urn SQLITE_CANTO
3350: 50 45 4e 2e 0a 2a 2f 0a 69 6e 74 20 73 71 6c 69 PEN..*/.int sqli
3360: 74 65 33 4f 73 4f 70 65 6e 45 78 63 6c 75 73 69 te3OsOpenExclusi
3370: 76 65 28 63 6f 6e 73 74 20 63 68 61 72 20 2a 7a ve(const char *z
3380: 46 69 6c 65 6e 61 6d 65 2c 20 4f 73 46 69 6c 65 Filename, OsFile
3390: 20 2a 69 64 2c 20 69 6e 74 20 64 65 6c 46 6c 61 *id, int delFla
33a0: 67 29 7b 0a 20 20 69 6e 74 20 72 63 3b 0a 20 20 g){. int rc;.
33b0: 69 66 28 20 61 63 63 65 73 73 28 7a 46 69 6c 65 if( access(zFile
33c0: 6e 61 6d 65 2c 20 30 29 3d 3d 30 20 29 7b 0a 20 name, 0)==0 ){.
33d0: 20 20 20 72 65 74 75 72 6e 20 53 51 4c 49 54 45 return SQLITE
33e0: 5f 43 41 4e 54 4f 50 45 4e 3b 0a 20 20 7d 0a 20 _CANTOPEN;. }.
33f0: 20 69 64 2d 3e 64 69 72 66 64 20 3d 20 2d 31 3b id->dirfd = -1;
3400: 0a 20 20 69 64 2d 3e 68 20 3d 20 6f 70 65 6e 28 . id->h = open(
3410: 7a 46 69 6c 65 6e 61 6d 65 2c 0a 20 20 20 20 20 zFilename,.
3420: 20 20 20 20 20 20 20 20 20 20 20 4f 5f 52 44 57 O_RDW
3430: 52 7c 4f 5f 43 52 45 41 54 7c 4f 5f 45 58 43 4c R|O_CREAT|O_EXCL
3440: 7c 4f 5f 4e 4f 46 4f 4c 4c 4f 57 7c 4f 5f 4c 41 |O_NOFOLLOW|O_LA
3450: 52 47 45 46 49 4c 45 7c 4f 5f 42 49 4e 41 52 59 RGEFILE|O_BINARY
3460: 2c 20 30 36 30 30 29 3b 0a 20 20 69 66 28 20 69 , 0600);. if( i
3470: 64 2d 3e 68 3c 30 20 29 7b 0a 20 20 20 20 72 65 d->h<0 ){. re
3480: 74 75 72 6e 20 53 51 4c 49 54 45 5f 43 41 4e 54 turn SQLITE_CANT
3490: 4f 50 45 4e 3b 0a 20 20 7d 0a 20 20 73 71 6c 69 OPEN;. }. sqli
34a0: 74 65 33 4f 73 45 6e 74 65 72 4d 75 74 65 78 28 te3OsEnterMutex(
34b0: 29 3b 0a 20 20 72 63 20 3d 20 66 69 6e 64 4c 6f );. rc = findLo
34c0: 63 6b 49 6e 66 6f 28 69 64 2d 3e 68 2c 20 26 69 ckInfo(id->h, &i
34d0: 64 2d 3e 70 4c 6f 63 6b 2c 20 26 69 64 2d 3e 70 d->pLock, &id->p
34e0: 4f 70 65 6e 29 3b 0a 20 20 73 71 6c 69 74 65 33 Open);. sqlite3
34f0: 4f 73 4c 65 61 76 65 4d 75 74 65 78 28 29 3b 0a OsLeaveMutex();.
3500: 20 20 69 66 28 20 72 63 20 29 7b 0a 20 20 20 20 if( rc ){.
3510: 63 6c 6f 73 65 28 69 64 2d 3e 68 29 3b 0a 20 20 close(id->h);.
3520: 20 20 75 6e 6c 69 6e 6b 28 7a 46 69 6c 65 6e 61 unlink(zFilena
3530: 6d 65 29 3b 0a 20 20 20 20 72 65 74 75 72 6e 20 me);. return
3540: 53 51 4c 49 54 45 5f 4e 4f 4d 45 4d 3b 0a 20 20 SQLITE_NOMEM;.
3550: 7d 0a 20 20 69 64 2d 3e 6c 6f 63 6b 74 79 70 65 }. id->locktype
3560: 20 3d 20 30 3b 0a 20 20 69 66 28 20 64 65 6c 46 = 0;. if( delF
3570: 6c 61 67 20 29 7b 0a 20 20 20 20 75 6e 6c 69 6e lag ){. unlin
3580: 6b 28 7a 46 69 6c 65 6e 61 6d 65 29 3b 0a 20 20 k(zFilename);.
3590: 7d 0a 20 20 54 52 41 43 45 33 28 22 4f 50 45 4e }. TRACE3("OPEN
35a0: 2d 45 58 20 25 2d 33 64 20 25 73 5c 6e 22 2c 20 -EX %-3d %s\n",
35b0: 69 64 2d 3e 68 2c 20 7a 46 69 6c 65 6e 61 6d 65 id->h, zFilename
35c0: 29 3b 0a 20 20 4f 70 65 6e 43 6f 75 6e 74 65 72 );. OpenCounter
35d0: 28 2b 31 29 3b 0a 20 20 72 65 74 75 72 6e 20 53 (+1);. return S
35e0: 51 4c 49 54 45 5f 4f 4b 3b 0a 7d 0a 0a 2f 2a 0a QLITE_OK;.}../*.
35f0: 2a 2a 20 41 74 74 65 6d 70 74 20 74 6f 20 6f 70 ** Attempt to op
3600: 65 6e 20 61 20 6e 65 77 20 66 69 6c 65 20 66 6f en a new file fo
3610: 72 20 72 65 61 64 2d 6f 6e 6c 79 20 61 63 63 65 r read-only acce
3620: 73 73 2e 0a 2a 2a 0a 2a 2a 20 4f 6e 20 73 75 63 ss..**.** On suc
3630: 63 65 73 73 2c 20 77 72 69 74 65 20 74 68 65 20 cess, write the
3640: 66 69 6c 65 20 68 61 6e 64 6c 65 20 69 6e 74 6f file handle into
3650: 20 2a 69 64 20 61 6e 64 20 72 65 74 75 72 6e 20 *id and return
3660: 53 51 4c 49 54 45 5f 4f 4b 2e 0a 2a 2a 0a 2a 2a SQLITE_OK..**.**
3670: 20 4f 6e 20 66 61 69 6c 75 72 65 2c 20 72 65 74 On failure, ret
3680: 75 72 6e 20 53 51 4c 49 54 45 5f 43 41 4e 54 4f urn SQLITE_CANTO
3690: 50 45 4e 2e 0a 2a 2f 0a 69 6e 74 20 73 71 6c 69 PEN..*/.int sqli
36a0: 74 65 33 4f 73 4f 70 65 6e 52 65 61 64 4f 6e 6c te3OsOpenReadOnl
36b0: 79 28 63 6f 6e 73 74 20 63 68 61 72 20 2a 7a 46 y(const char *zF
36c0: 69 6c 65 6e 61 6d 65 2c 20 4f 73 46 69 6c 65 20 ilename, OsFile
36d0: 2a 69 64 29 7b 0a 20 20 69 6e 74 20 72 63 3b 0a *id){. int rc;.
36e0: 20 20 69 64 2d 3e 64 69 72 66 64 20 3d 20 2d 31 id->dirfd = -1
36f0: 3b 0a 20 20 69 64 2d 3e 68 20 3d 20 6f 70 65 6e ;. id->h = open
3700: 28 7a 46 69 6c 65 6e 61 6d 65 2c 20 4f 5f 52 44 (zFilename, O_RD
3710: 4f 4e 4c 59 7c 4f 5f 4c 41 52 47 45 46 49 4c 45 ONLY|O_LARGEFILE
3720: 7c 4f 5f 42 49 4e 41 52 59 29 3b 0a 20 20 69 66 |O_BINARY);. if
3730: 28 20 69 64 2d 3e 68 3c 30 20 29 7b 0a 20 20 20 ( id->h<0 ){.
3740: 20 72 65 74 75 72 6e 20 53 51 4c 49 54 45 5f 43 return SQLITE_C
3750: 41 4e 54 4f 50 45 4e 3b 0a 20 20 7d 0a 20 20 73 ANTOPEN;. }. s
3760: 71 6c 69 74 65 33 4f 73 45 6e 74 65 72 4d 75 74 qlite3OsEnterMut
3770: 65 78 28 29 3b 0a 20 20 72 63 20 3d 20 66 69 6e ex();. rc = fin
3780: 64 4c 6f 63 6b 49 6e 66 6f 28 69 64 2d 3e 68 2c dLockInfo(id->h,
3790: 20 26 69 64 2d 3e 70 4c 6f 63 6b 2c 20 26 69 64 &id->pLock, &id
37a0: 2d 3e 70 4f 70 65 6e 29 3b 0a 20 20 73 71 6c 69 ->pOpen);. sqli
37b0: 74 65 33 4f 73 4c 65 61 76 65 4d 75 74 65 78 28 te3OsLeaveMutex(
37c0: 29 3b 0a 20 20 69 66 28 20 72 63 20 29 7b 0a 20 );. if( rc ){.
37d0: 20 20 20 63 6c 6f 73 65 28 69 64 2d 3e 68 29 3b close(id->h);
37e0: 0a 20 20 20 20 72 65 74 75 72 6e 20 53 51 4c 49 . return SQLI
37f0: 54 45 5f 4e 4f 4d 45 4d 3b 0a 20 20 7d 0a 20 20 TE_NOMEM;. }.
3800: 69 64 2d 3e 6c 6f 63 6b 74 79 70 65 20 3d 20 30 id->locktype = 0
3810: 3b 0a 20 20 54 52 41 43 45 33 28 22 4f 50 45 4e ;. TRACE3("OPEN
3820: 2d 52 4f 20 25 2d 33 64 20 25 73 5c 6e 22 2c 20 -RO %-3d %s\n",
3830: 69 64 2d 3e 68 2c 20 7a 46 69 6c 65 6e 61 6d 65 id->h, zFilename
3840: 29 3b 0a 20 20 4f 70 65 6e 43 6f 75 6e 74 65 72 );. OpenCounter
3850: 28 2b 31 29 3b 0a 20 20 72 65 74 75 72 6e 20 53 (+1);. return S
3860: 51 4c 49 54 45 5f 4f 4b 3b 0a 7d 0a 0a 2f 2a 0a QLITE_OK;.}../*.
3870: 2a 2a 20 41 74 74 65 6d 70 74 20 74 6f 20 6f 70 ** Attempt to op
3880: 65 6e 20 61 20 66 69 6c 65 20 64 65 73 63 72 69 en a file descri
3890: 70 74 6f 72 20 66 6f 72 20 74 68 65 20 64 69 72 ptor for the dir
38a0: 65 63 74 6f 72 79 20 74 68 61 74 20 63 6f 6e 74 ectory that cont
38b0: 61 69 6e 73 20 61 0a 2a 2a 20 66 69 6c 65 2e 20 ains a.** file.
38c0: 20 54 68 69 73 20 66 69 6c 65 20 64 65 73 63 72 This file descr
38d0: 69 70 74 6f 72 20 63 61 6e 20 62 65 20 75 73 65 iptor can be use
38e0: 64 20 74 6f 20 66 73 79 6e 63 28 29 20 74 68 65 d to fsync() the
38f0: 20 64 69 72 65 63 74 6f 72 79 0a 2a 2a 20 69 6e directory.** in
3900: 20 6f 72 64 65 72 20 74 6f 20 6d 61 6b 65 20 73 order to make s
3910: 75 72 65 20 74 68 65 20 63 72 65 61 74 69 6f 6e ure the creation
3920: 20 6f 66 20 61 20 6e 65 77 20 66 69 6c 65 20 69 of a new file i
3930: 73 20 61 63 74 75 61 6c 6c 79 20 77 72 69 74 74 s actually writt
3940: 65 6e 0a 2a 2a 20 74 6f 20 64 69 73 6b 2e 0a 2a en.** to disk..*
3950: 2a 0a 2a 2a 20 54 68 69 73 20 72 6f 75 74 69 6e *.** This routin
3960: 65 20 69 73 20 6f 6e 6c 79 20 6d 65 61 6e 69 6e e is only meanin
3970: 67 66 75 6c 20 66 6f 72 20 55 6e 69 78 2e 20 20 gful for Unix.
3980: 49 74 20 69 73 20 61 20 6e 6f 2d 6f 70 20 75 6e It is a no-op un
3990: 64 65 72 0a 2a 2a 20 77 69 6e 64 6f 77 73 20 73 der.** windows s
39a0: 69 6e 63 65 20 77 69 6e 64 6f 77 73 20 64 6f 65 ince windows doe
39b0: 73 20 6e 6f 74 20 73 75 70 70 6f 72 74 20 68 61 s not support ha
39c0: 72 64 20 6c 69 6e 6b 73 2e 0a 2a 2a 0a 2a 2a 20 rd links..**.**
39d0: 4f 6e 20 73 75 63 63 65 73 73 2c 20 61 20 68 61 On success, a ha
39e0: 6e 64 6c 65 20 66 6f 72 20 61 20 70 72 65 76 69 ndle for a previ
39f0: 6f 75 73 6c 79 20 6f 70 65 6e 20 66 69 6c 65 20 ously open file
3a00: 69 73 20 61 74 20 2a 69 64 20 69 73 0a 2a 2a 20 is at *id is.**
3a10: 75 70 64 61 74 65 64 20 77 69 74 68 20 74 68 65 updated with the
3a20: 20 6e 65 77 20 64 69 72 65 63 74 6f 72 79 20 66 new directory f
3a30: 69 6c 65 20 64 65 73 63 72 69 70 74 6f 72 20 61 ile descriptor a
3a40: 6e 64 20 53 51 4c 49 54 45 5f 4f 4b 20 69 73 0a nd SQLITE_OK is.
3a50: 2a 2a 20 72 65 74 75 72 6e 65 64 2e 0a 2a 2a 0a ** returned..**.
3a60: 2a 2a 20 4f 6e 20 66 61 69 6c 75 72 65 2c 20 74 ** On failure, t
3a70: 68 65 20 66 75 6e 63 74 69 6f 6e 20 72 65 74 75 he function retu
3a80: 72 6e 73 20 53 51 4c 49 54 45 5f 43 41 4e 54 4f rns SQLITE_CANTO
3a90: 50 45 4e 20 61 6e 64 20 6c 65 61 76 65 73 0a 2a PEN and leaves.*
3aa0: 2a 20 2a 69 64 20 75 6e 63 68 61 6e 67 65 64 2e * *id unchanged.
3ab0: 0a 2a 2f 0a 69 6e 74 20 73 71 6c 69 74 65 33 4f .*/.int sqlite3O
3ac0: 73 4f 70 65 6e 44 69 72 65 63 74 6f 72 79 28 0a sOpenDirectory(.
3ad0: 20 20 63 6f 6e 73 74 20 63 68 61 72 20 2a 7a 44 const char *zD
3ae0: 69 72 6e 61 6d 65 2c 0a 20 20 4f 73 46 69 6c 65 irname,. OsFile
3af0: 20 2a 69 64 0a 29 7b 0a 20 20 69 66 28 20 69 64 *id.){. if( id
3b00: 2d 3e 68 3c 30 20 29 7b 0a 20 20 20 20 2f 2a 20 ->h<0 ){. /*
3b10: 44 6f 20 6e 6f 74 20 6f 70 65 6e 20 74 68 65 20 Do not open the
3b20: 64 69 72 65 63 74 6f 72 79 20 69 66 20 74 68 65 directory if the
3b30: 20 63 6f 72 72 65 73 70 6f 6e 64 69 6e 67 20 66 corresponding f
3b40: 69 6c 65 20 69 73 20 6e 6f 74 20 61 6c 72 65 61 ile is not alrea
3b50: 64 79 0a 20 20 20 20 2a 2a 20 6f 70 65 6e 2e 20 dy. ** open.
3b60: 2a 2f 0a 20 20 20 20 72 65 74 75 72 6e 20 53 51 */. return SQ
3b70: 4c 49 54 45 5f 43 41 4e 54 4f 50 45 4e 3b 0a 20 LITE_CANTOPEN;.
3b80: 20 7d 0a 20 20 61 73 73 65 72 74 28 20 69 64 2d }. assert( id-
3b90: 3e 64 69 72 66 64 3c 30 20 29 3b 0a 20 20 69 64 >dirfd<0 );. id
3ba0: 2d 3e 64 69 72 66 64 20 3d 20 6f 70 65 6e 28 7a ->dirfd = open(z
3bb0: 44 69 72 6e 61 6d 65 2c 20 4f 5f 52 44 4f 4e 4c Dirname, O_RDONL
3bc0: 59 7c 4f 5f 42 49 4e 41 52 59 2c 20 30 36 34 34 Y|O_BINARY, 0644
3bd0: 29 3b 0a 20 20 69 66 28 20 69 64 2d 3e 64 69 72 );. if( id->dir
3be0: 66 64 3c 30 20 29 7b 0a 20 20 20 20 72 65 74 75 fd<0 ){. retu
3bf0: 72 6e 20 53 51 4c 49 54 45 5f 43 41 4e 54 4f 50 rn SQLITE_CANTOP
3c00: 45 4e 3b 20 0a 20 20 7d 0a 20 20 54 52 41 43 45 EN; . }. TRACE
3c10: 33 28 22 4f 50 45 4e 44 49 52 20 25 2d 33 64 20 3("OPENDIR %-3d
3c20: 25 73 5c 6e 22 2c 20 69 64 2d 3e 64 69 72 66 64 %s\n", id->dirfd
3c30: 2c 20 7a 44 69 72 6e 61 6d 65 29 3b 0a 20 20 72 , zDirname);. r
3c40: 65 74 75 72 6e 20 53 51 4c 49 54 45 5f 4f 4b 3b eturn SQLITE_OK;
3c50: 0a 7d 0a 0a 2f 2a 0a 2a 2a 20 43 72 65 61 74 65 .}../*.** Create
3c60: 20 61 20 74 65 6d 70 6f 72 61 72 79 20 66 69 6c a temporary fil
3c70: 65 20 6e 61 6d 65 20 69 6e 20 7a 42 75 66 2e 20 e name in zBuf.
3c80: 20 7a 42 75 66 20 6d 75 73 74 20 62 65 20 62 69 zBuf must be bi
3c90: 67 20 65 6e 6f 75 67 68 20 74 6f 0a 2a 2a 20 68 g enough to.** h
3ca0: 6f 6c 64 20 61 74 20 6c 65 61 73 74 20 53 51 4c old at least SQL
3cb0: 49 54 45 5f 54 45 4d 50 4e 41 4d 45 5f 53 49 5a ITE_TEMPNAME_SIZ
3cc0: 45 20 63 68 61 72 61 63 74 65 72 73 2e 0a 2a 2f E characters..*/
3cd0: 0a 69 6e 74 20 73 71 6c 69 74 65 33 4f 73 54 65 .int sqlite3OsTe
3ce0: 6d 70 46 69 6c 65 4e 61 6d 65 28 63 68 61 72 20 mpFileName(char
3cf0: 2a 7a 42 75 66 29 7b 0a 20 20 73 74 61 74 69 63 *zBuf){. static
3d00: 20 63 6f 6e 73 74 20 63 68 61 72 20 2a 61 7a 44 const char *azD
3d10: 69 72 73 5b 5d 20 3d 20 7b 0a 20 20 20 20 20 22 irs[] = {. "
3d20: 2f 76 61 72 2f 74 6d 70 22 2c 0a 20 20 20 20 20 /var/tmp",.
3d30: 22 2f 75 73 72 2f 74 6d 70 22 2c 0a 20 20 20 20 "/usr/tmp",.
3d40: 20 22 2f 74 6d 70 22 2c 0a 20 20 20 20 20 22 2e "/tmp",. ".
3d50: 22 2c 0a 20 20 7d 3b 0a 20 20 73 74 61 74 69 63 ",. };. static
3d60: 20 75 6e 73 69 67 6e 65 64 20 63 68 61 72 20 7a unsigned char z
3d70: 43 68 61 72 73 5b 5d 20 3d 0a 20 20 20 20 22 61 Chars[] =. "a
3d80: 62 63 64 65 66 67 68 69 6a 6b 6c 6d 6e 6f 70 71 bcdefghijklmnopq
3d90: 72 73 74 75 76 77 78 79 7a 22 0a 20 20 20 20 22 rstuvwxyz". "
3da0: 41 42 43 44 45 46 47 48 49 4a 4b 4c 4d 4e 4f 50 ABCDEFGHIJKLMNOP
3db0: 51 52 53 54 55 56 57 58 59 5a 22 0a 20 20 20 20 QRSTUVWXYZ".
3dc0: 22 30 31 32 33 34 35 36 37 38 39 22 3b 0a 20 20 "0123456789";.
3dd0: 69 6e 74 20 69 2c 20 6a 3b 0a 20 20 73 74 72 75 int i, j;. stru
3de0: 63 74 20 73 74 61 74 20 62 75 66 3b 0a 20 20 63 ct stat buf;. c
3df0: 6f 6e 73 74 20 63 68 61 72 20 2a 7a 44 69 72 20 onst char *zDir
3e00: 3d 20 22 2e 22 3b 0a 20 20 66 6f 72 28 69 3d 30 = ".";. for(i=0
3e10: 3b 20 69 3c 73 69 7a 65 6f 66 28 61 7a 44 69 72 ; i<sizeof(azDir
3e20: 73 29 2f 73 69 7a 65 6f 66 28 61 7a 44 69 72 73 s)/sizeof(azDirs
3e30: 5b 30 5d 29 3b 20 69 2b 2b 29 7b 0a 20 20 20 20 [0]); i++){.
3e40: 69 66 28 20 73 74 61 74 28 61 7a 44 69 72 73 5b if( stat(azDirs[
3e50: 69 5d 2c 20 26 62 75 66 29 20 29 20 63 6f 6e 74 i], &buf) ) cont
3e60: 69 6e 75 65 3b 0a 20 20 20 20 69 66 28 20 21 53 inue;. if( !S
3e70: 5f 49 53 44 49 52 28 62 75 66 2e 73 74 5f 6d 6f _ISDIR(buf.st_mo
3e80: 64 65 29 20 29 20 63 6f 6e 74 69 6e 75 65 3b 0a de) ) continue;.
3e90: 20 20 20 20 69 66 28 20 61 63 63 65 73 73 28 61 if( access(a
3ea0: 7a 44 69 72 73 5b 69 5d 2c 20 30 37 29 20 29 20 zDirs[i], 07) )
3eb0: 63 6f 6e 74 69 6e 75 65 3b 0a 20 20 20 20 7a 44 continue;. zD
3ec0: 69 72 20 3d 20 61 7a 44 69 72 73 5b 69 5d 3b 0a ir = azDirs[i];.
3ed0: 20 20 20 20 62 72 65 61 6b 3b 0a 20 20 7d 0a 20 break;. }.
3ee0: 20 64 6f 7b 0a 20 20 20 20 73 70 72 69 6e 74 66 do{. sprintf
3ef0: 28 7a 42 75 66 2c 20 22 25 73 2f 22 54 45 4d 50 (zBuf, "%s/"TEMP
3f00: 5f 46 49 4c 45 5f 50 52 45 46 49 58 2c 20 7a 44 _FILE_PREFIX, zD
3f10: 69 72 29 3b 0a 20 20 20 20 6a 20 3d 20 73 74 72 ir);. j = str
3f20: 6c 65 6e 28 7a 42 75 66 29 3b 0a 20 20 20 20 73 len(zBuf);. s
3f30: 71 6c 69 74 65 33 52 61 6e 64 6f 6d 6e 65 73 73 qlite3Randomness
3f40: 28 31 35 2c 20 26 7a 42 75 66 5b 6a 5d 29 3b 0a (15, &zBuf[j]);.
3f50: 20 20 20 20 66 6f 72 28 69 3d 30 3b 20 69 3c 31 for(i=0; i<1
3f60: 35 3b 20 69 2b 2b 2c 20 6a 2b 2b 29 7b 0a 20 20 5; i++, j++){.
3f70: 20 20 20 20 7a 42 75 66 5b 6a 5d 20 3d 20 28 63 zBuf[j] = (c
3f80: 68 61 72 29 7a 43 68 61 72 73 5b 20 28 28 75 6e har)zChars[ ((un
3f90: 73 69 67 6e 65 64 20 63 68 61 72 29 7a 42 75 66 signed char)zBuf
3fa0: 5b 6a 5d 29 25 28 73 69 7a 65 6f 66 28 7a 43 68 [j])%(sizeof(zCh
3fb0: 61 72 73 29 2d 31 29 20 5d 3b 0a 20 20 20 20 7d ars)-1) ];. }
3fc0: 0a 20 20 20 20 7a 42 75 66 5b 6a 5d 20 3d 20 30 . zBuf[j] = 0
3fd0: 3b 0a 20 20 7d 77 68 69 6c 65 28 20 61 63 63 65 ;. }while( acce
3fe0: 73 73 28 7a 42 75 66 2c 30 29 3d 3d 30 20 29 3b ss(zBuf,0)==0 );
3ff0: 0a 20 20 72 65 74 75 72 6e 20 53 51 4c 49 54 45 . return SQLITE
4000: 5f 4f 4b 3b 20 0a 7d 0a 0a 2f 2a 0a 2a 2a 20 43 _OK; .}../*.** C
4010: 6c 6f 73 65 20 61 20 66 69 6c 65 2e 0a 2a 2f 0a lose a file..*/.
4020: 69 6e 74 20 73 71 6c 69 74 65 33 4f 73 43 6c 6f int sqlite3OsClo
4030: 73 65 28 4f 73 46 69 6c 65 20 2a 69 64 29 7b 0a se(OsFile *id){.
4040: 20 20 73 71 6c 69 74 65 33 4f 73 55 6e 6c 6f 63 sqlite3OsUnloc
4050: 6b 28 69 64 2c 20 4e 4f 5f 4c 4f 43 4b 29 3b 0a k(id, NO_LOCK);.
4060: 20 20 69 66 28 20 69 64 2d 3e 64 69 72 66 64 3e if( id->dirfd>
4070: 3d 30 20 29 20 63 6c 6f 73 65 28 69 64 2d 3e 64 =0 ) close(id->d
4080: 69 72 66 64 29 3b 0a 20 20 69 64 2d 3e 64 69 72 irfd);. id->dir
4090: 66 64 20 3d 20 2d 31 3b 0a 20 20 73 71 6c 69 74 fd = -1;. sqlit
40a0: 65 33 4f 73 45 6e 74 65 72 4d 75 74 65 78 28 29 e3OsEnterMutex()
40b0: 3b 0a 20 20 69 66 28 20 69 64 2d 3e 70 4f 70 65 ;. if( id->pOpe
40c0: 6e 2d 3e 6e 4c 6f 63 6b 20 29 7b 0a 20 20 20 20 n->nLock ){.
40d0: 2f 2a 20 49 66 20 74 68 65 72 65 20 61 72 65 20 /* If there are
40e0: 6f 75 74 73 74 61 6e 64 69 6e 67 20 6c 6f 63 6b outstanding lock
40f0: 73 2c 20 64 6f 20 6e 6f 74 20 61 63 74 75 61 6c s, do not actual
4100: 6c 79 20 63 6c 6f 73 65 20 74 68 65 20 66 69 6c ly close the fil
4110: 65 20 6a 75 73 74 0a 20 20 20 20 2a 2a 20 79 65 e just. ** ye
4120: 74 20 62 65 63 61 75 73 65 20 74 68 61 74 20 77 t because that w
4130: 6f 75 6c 64 20 63 6c 65 61 72 20 74 68 6f 73 65 ould clear those
4140: 20 6c 6f 63 6b 73 2e 20 20 49 6e 73 74 65 61 64 locks. Instead
4150: 2c 20 61 64 64 20 74 68 65 20 66 69 6c 65 0a 20 , add the file.
4160: 20 20 20 2a 2a 20 64 65 73 63 72 69 70 74 6f 72 ** descriptor
4170: 20 74 6f 20 70 4f 70 65 6e 2d 3e 61 50 65 6e 64 to pOpen->aPend
4180: 69 6e 67 2e 20 20 49 74 20 77 69 6c 6c 20 62 65 ing. It will be
4190: 20 61 75 74 6f 6d 61 74 69 63 61 6c 6c 79 20 63 automatically c
41a0: 6c 6f 73 65 64 20 77 68 65 6e 0a 20 20 20 20 2a losed when. *
41b0: 2a 20 74 68 65 20 6c 61 73 74 20 6c 6f 63 6b 20 * the last lock
41c0: 69 73 20 63 6c 65 61 72 65 64 2e 0a 20 20 20 20 is cleared..
41d0: 2a 2f 0a 20 20 20 20 69 6e 74 20 2a 61 4e 65 77 */. int *aNew
41e0: 3b 0a 20 20 20 20 73 74 72 75 63 74 20 6f 70 65 ;. struct ope
41f0: 6e 43 6e 74 20 2a 70 4f 70 65 6e 20 3d 20 69 64 nCnt *pOpen = id
4200: 2d 3e 70 4f 70 65 6e 3b 0a 20 20 20 20 70 4f 70 ->pOpen;. pOp
4210: 65 6e 2d 3e 6e 50 65 6e 64 69 6e 67 2b 2b 3b 0a en->nPending++;.
4220: 20 20 20 20 61 4e 65 77 20 3d 20 73 71 6c 69 74 aNew = sqlit
4230: 65 52 65 61 6c 6c 6f 63 28 20 70 4f 70 65 6e 2d eRealloc( pOpen-
4240: 3e 61 50 65 6e 64 69 6e 67 2c 20 70 4f 70 65 6e >aPending, pOpen
4250: 2d 3e 6e 50 65 6e 64 69 6e 67 2a 73 69 7a 65 6f ->nPending*sizeo
4260: 66 28 69 6e 74 29 20 29 3b 0a 20 20 20 20 69 66 f(int) );. if
4270: 28 20 61 4e 65 77 3d 3d 30 20 29 7b 0a 20 20 20 ( aNew==0 ){.
4280: 20 20 20 2f 2a 20 49 66 20 61 20 6d 61 6c 6c 6f /* If a mallo
4290: 63 20 66 61 69 6c 73 2c 20 6a 75 73 74 20 6c 65 c fails, just le
42a0: 61 6b 20 74 68 65 20 66 69 6c 65 20 64 65 73 63 ak the file desc
42b0: 72 69 70 74 6f 72 20 2a 2f 0a 20 20 20 20 7d 65 riptor */. }e
42c0: 6c 73 65 7b 0a 20 20 20 20 20 20 70 4f 70 65 6e lse{. pOpen
42d0: 2d 3e 61 50 65 6e 64 69 6e 67 20 3d 20 61 4e 65 ->aPending = aNe
42e0: 77 3b 0a 20 20 20 20 20 20 70 4f 70 65 6e 2d 3e w;. pOpen->
42f0: 61 50 65 6e 64 69 6e 67 5b 70 4f 70 65 6e 2d 3e aPending[pOpen->
4300: 6e 50 65 6e 64 69 6e 67 2d 31 5d 20 3d 20 69 64 nPending-1] = id
4310: 2d 3e 68 3b 0a 20 20 20 20 7d 0a 20 20 7d 65 6c ->h;. }. }el
4320: 73 65 7b 0a 20 20 20 20 2f 2a 20 54 68 65 72 65 se{. /* There
4330: 20 61 72 65 20 6e 6f 20 6f 75 74 73 74 61 6e 64 are no outstand
4340: 69 6e 67 20 6c 6f 63 6b 73 20 73 6f 20 77 65 20 ing locks so we
4350: 63 61 6e 20 63 6c 6f 73 65 20 74 68 65 20 66 69 can close the fi
4360: 6c 65 20 69 6d 6d 65 64 69 61 74 65 6c 79 20 2a le immediately *
4370: 2f 0a 20 20 20 20 63 6c 6f 73 65 28 69 64 2d 3e /. close(id->
4380: 68 29 3b 0a 20 20 7d 0a 20 20 72 65 6c 65 61 73 h);. }. releas
4390: 65 4c 6f 63 6b 49 6e 66 6f 28 69 64 2d 3e 70 4c eLockInfo(id->pL
43a0: 6f 63 6b 29 3b 0a 20 20 72 65 6c 65 61 73 65 4f ock);. releaseO
43b0: 70 65 6e 43 6e 74 28 69 64 2d 3e 70 4f 70 65 6e penCnt(id->pOpen
43c0: 29 3b 0a 20 20 73 71 6c 69 74 65 33 4f 73 4c 65 );. sqlite3OsLe
43d0: 61 76 65 4d 75 74 65 78 28 29 3b 0a 20 20 54 52 aveMutex();. TR
43e0: 41 43 45 32 28 22 43 4c 4f 53 45 20 20 20 25 2d ACE2("CLOSE %-
43f0: 33 64 5c 6e 22 2c 20 69 64 2d 3e 68 29 3b 0a 20 3d\n", id->h);.
4400: 20 4f 70 65 6e 43 6f 75 6e 74 65 72 28 2d 31 29 OpenCounter(-1)
4410: 3b 0a 20 20 72 65 74 75 72 6e 20 53 51 4c 49 54 ;. return SQLIT
4420: 45 5f 4f 4b 3b 0a 7d 0a 0a 2f 2a 0a 2a 2a 20 52 E_OK;.}../*.** R
4430: 65 61 64 20 64 61 74 61 20 66 72 6f 6d 20 61 20 ead data from a
4440: 66 69 6c 65 20 69 6e 74 6f 20 61 20 62 75 66 66 file into a buff
4450: 65 72 2e 20 20 52 65 74 75 72 6e 20 53 51 4c 49 er. Return SQLI
4460: 54 45 5f 4f 4b 20 69 66 20 61 6c 6c 0a 2a 2a 20 TE_OK if all.**
4470: 62 79 74 65 73 20 77 65 72 65 20 72 65 61 64 20 bytes were read
4480: 73 75 63 63 65 73 73 66 75 6c 6c 79 20 61 6e 64 successfully and
4490: 20 53 51 4c 49 54 45 5f 49 4f 45 52 52 20 69 66 SQLITE_IOERR if
44a0: 20 61 6e 79 74 68 69 6e 67 20 67 6f 65 73 0a 2a anything goes.*
44b0: 2a 20 77 72 6f 6e 67 2e 0a 2a 2f 0a 69 6e 74 20 * wrong..*/.int
44c0: 73 71 6c 69 74 65 33 4f 73 52 65 61 64 28 4f 73 sqlite3OsRead(Os
44d0: 46 69 6c 65 20 2a 69 64 2c 20 76 6f 69 64 20 2a File *id, void *
44e0: 70 42 75 66 2c 20 69 6e 74 20 61 6d 74 29 7b 0a pBuf, int amt){.
44f0: 20 20 69 6e 74 20 67 6f 74 3b 0a 20 20 53 69 6d int got;. Sim
4500: 75 6c 61 74 65 49 4f 45 72 72 6f 72 28 53 51 4c ulateIOError(SQL
4510: 49 54 45 5f 49 4f 45 52 52 29 3b 0a 20 20 54 49 ITE_IOERR);. TI
4520: 4d 45 52 5f 53 54 41 52 54 3b 0a 20 20 67 6f 74 MER_START;. got
4530: 20 3d 20 72 65 61 64 28 69 64 2d 3e 68 2c 20 70 = read(id->h, p
4540: 42 75 66 2c 20 61 6d 74 29 3b 0a 20 20 54 49 4d Buf, amt);. TIM
4550: 45 52 5f 45 4e 44 3b 0a 20 20 54 52 41 43 45 34 ER_END;. TRACE4
4560: 28 22 52 45 41 44 20 20 20 20 25 2d 33 64 20 25 ("READ %-3d %
4570: 37 64 20 25 64 5c 6e 22 2c 20 69 64 2d 3e 68 2c 7d %d\n", id->h,
4580: 20 6c 61 73 74 5f 70 61 67 65 2c 20 65 6c 61 70 last_page, elap
4590: 73 65 29 3b 0a 20 20 53 45 45 4b 28 30 29 3b 0a se);. SEEK(0);.
45a0: 20 20 2f 2a 20 69 66 28 20 67 6f 74 3c 30 20 29 /* if( got<0 )
45b0: 20 67 6f 74 20 3d 20 30 3b 20 2a 2f 0a 20 20 69 got = 0; */. i
45c0: 66 28 20 67 6f 74 3d 3d 61 6d 74 20 29 7b 0a 20 f( got==amt ){.
45d0: 20 20 20 72 65 74 75 72 6e 20 53 51 4c 49 54 45 return SQLITE
45e0: 5f 4f 4b 3b 0a 20 20 7d 65 6c 73 65 7b 0a 20 20 _OK;. }else{.
45f0: 20 20 72 65 74 75 72 6e 20 53 51 4c 49 54 45 5f return SQLITE_
4600: 49 4f 45 52 52 3b 0a 20 20 7d 0a 7d 0a 0a 2f 2a IOERR;. }.}../*
4610: 0a 2a 2a 20 57 72 69 74 65 20 64 61 74 61 20 66 .** Write data f
4620: 72 6f 6d 20 61 20 62 75 66 66 65 72 20 69 6e 74 rom a buffer int
4630: 6f 20 61 20 66 69 6c 65 2e 20 20 52 65 74 75 72 o a file. Retur
4640: 6e 20 53 51 4c 49 54 45 5f 4f 4b 20 6f 6e 20 73 n SQLITE_OK on s
4650: 75 63 63 65 73 73 0a 2a 2a 20 6f 72 20 73 6f 6d uccess.** or som
4660: 65 20 6f 74 68 65 72 20 65 72 72 6f 72 20 63 6f e other error co
4670: 64 65 20 6f 6e 20 66 61 69 6c 75 72 65 2e 0a 2a de on failure..*
4680: 2f 0a 69 6e 74 20 73 71 6c 69 74 65 33 4f 73 57 /.int sqlite3OsW
4690: 72 69 74 65 28 4f 73 46 69 6c 65 20 2a 69 64 2c rite(OsFile *id,
46a0: 20 63 6f 6e 73 74 20 76 6f 69 64 20 2a 70 42 75 const void *pBu
46b0: 66 2c 20 69 6e 74 20 61 6d 74 29 7b 0a 20 20 69 f, int amt){. i
46c0: 6e 74 20 77 72 6f 74 65 20 3d 20 30 3b 0a 20 20 nt wrote = 0;.
46d0: 53 69 6d 75 6c 61 74 65 49 4f 45 72 72 6f 72 28 SimulateIOError(
46e0: 53 51 4c 49 54 45 5f 49 4f 45 52 52 29 3b 0a 20 SQLITE_IOERR);.
46f0: 20 54 49 4d 45 52 5f 53 54 41 52 54 3b 0a 20 20 TIMER_START;.
4700: 77 68 69 6c 65 28 20 61 6d 74 3e 30 20 26 26 20 while( amt>0 &&
4710: 28 77 72 6f 74 65 20 3d 20 77 72 69 74 65 28 69 (wrote = write(i
4720: 64 2d 3e 68 2c 20 70 42 75 66 2c 20 61 6d 74 29 d->h, pBuf, amt)
4730: 29 3e 30 20 29 7b 0a 20 20 20 20 61 6d 74 20 2d )>0 ){. amt -
4740: 3d 20 77 72 6f 74 65 3b 0a 20 20 20 20 70 42 75 = wrote;. pBu
4750: 66 20 3d 20 26 28 28 63 68 61 72 2a 29 70 42 75 f = &((char*)pBu
4760: 66 29 5b 77 72 6f 74 65 5d 3b 0a 20 20 7d 0a 20 f)[wrote];. }.
4770: 20 54 49 4d 45 52 5f 45 4e 44 3b 0a 20 20 54 52 TIMER_END;. TR
4780: 41 43 45 34 28 22 57 52 49 54 45 20 20 20 25 2d ACE4("WRITE %-
4790: 33 64 20 25 37 64 20 25 64 5c 6e 22 2c 20 69 64 3d %7d %d\n", id
47a0: 2d 3e 68 2c 20 6c 61 73 74 5f 70 61 67 65 2c 20 ->h, last_page,
47b0: 65 6c 61 70 73 65 29 3b 0a 20 20 53 45 45 4b 28 elapse);. SEEK(
47c0: 30 29 3b 0a 20 20 69 66 28 20 61 6d 74 3e 30 20 0);. if( amt>0
47d0: 29 7b 0a 20 20 20 20 72 65 74 75 72 6e 20 53 51 ){. return SQ
47e0: 4c 49 54 45 5f 46 55 4c 4c 3b 0a 20 20 7d 0a 20 LITE_FULL;. }.
47f0: 20 72 65 74 75 72 6e 20 53 51 4c 49 54 45 5f 4f return SQLITE_O
4800: 4b 3b 0a 7d 0a 0a 2f 2a 0a 2a 2a 20 4d 6f 76 65 K;.}../*.** Move
4810: 20 74 68 65 20 72 65 61 64 2f 77 72 69 74 65 20 the read/write
4820: 70 6f 69 6e 74 65 72 20 69 6e 20 61 20 66 69 6c pointer in a fil
4830: 65 2e 0a 2a 2f 0a 69 6e 74 20 73 71 6c 69 74 65 e..*/.int sqlite
4840: 33 4f 73 53 65 65 6b 28 4f 73 46 69 6c 65 20 2a 3OsSeek(OsFile *
4850: 69 64 2c 20 6f 66 66 5f 74 20 6f 66 66 73 65 74 id, off_t offset
4860: 29 7b 0a 20 20 53 45 45 4b 28 6f 66 66 73 65 74 ){. SEEK(offset
4870: 2f 31 30 32 34 20 2b 20 31 29 3b 0a 20 20 6c 73 /1024 + 1);. ls
4880: 65 65 6b 28 69 64 2d 3e 68 2c 20 6f 66 66 73 65 eek(id->h, offse
4890: 74 2c 20 53 45 45 4b 5f 53 45 54 29 3b 0a 20 20 t, SEEK_SET);.
48a0: 72 65 74 75 72 6e 20 53 51 4c 49 54 45 5f 4f 4b return SQLITE_OK
48b0: 3b 0a 7d 0a 0a 2f 2a 0a 2a 2a 20 4d 61 6b 65 20 ;.}../*.** Make
48c0: 73 75 72 65 20 61 6c 6c 20 77 72 69 74 65 73 20 sure all writes
48d0: 74 6f 20 61 20 70 61 72 74 69 63 75 6c 61 72 20 to a particular
48e0: 66 69 6c 65 20 61 72 65 20 63 6f 6d 6d 69 74 74 file are committ
48f0: 65 64 20 74 6f 20 64 69 73 6b 2e 0a 2a 2a 0a 2a ed to disk..**.*
4900: 2a 20 55 6e 64 65 72 20 55 6e 69 78 2c 20 61 6c * Under Unix, al
4910: 73 6f 20 6d 61 6b 65 20 73 75 72 65 20 74 68 61 so make sure tha
4920: 74 20 74 68 65 20 64 69 72 65 63 74 6f 72 79 20 t the directory
4930: 65 6e 74 72 79 20 66 6f 72 20 74 68 65 20 66 69 entry for the fi
4940: 6c 65 0a 2a 2a 20 68 61 73 20 62 65 65 6e 20 63 le.** has been c
4950: 72 65 61 74 65 64 20 62 79 20 66 73 79 6e 63 2d reated by fsync-
4960: 69 6e 67 20 74 68 65 20 64 69 72 65 63 74 6f 72 ing the director
4970: 79 20 74 68 61 74 20 63 6f 6e 74 61 69 6e 73 20 y that contains
4980: 74 68 65 20 66 69 6c 65 2e 0a 2a 2a 20 49 66 20 the file..** If
4990: 77 65 20 64 6f 20 6e 6f 74 20 64 6f 20 74 68 69 we do not do thi
49a0: 73 20 61 6e 64 20 77 65 20 65 6e 63 6f 75 6e 74 s and we encount
49b0: 65 72 20 61 20 70 6f 77 65 72 20 66 61 69 6c 75 er a power failu
49c0: 72 65 2c 20 74 68 65 20 64 69 72 65 63 74 6f 72 re, the director
49d0: 79 0a 2a 2a 20 65 6e 74 72 79 20 66 6f 72 20 74 y.** entry for t
49e0: 68 65 20 6a 6f 75 72 6e 61 6c 20 6d 69 67 68 74 he journal might
49f0: 20 6e 6f 74 20 65 78 69 73 74 20 61 66 74 65 72 not exist after
4a00: 20 77 65 20 72 65 62 6f 6f 74 2e 20 20 54 68 65 we reboot. The
4a10: 20 6e 65 78 74 0a 2a 2a 20 53 51 4c 69 74 65 20 next.** SQLite
4a20: 74 6f 20 61 63 63 65 73 73 20 74 68 65 20 66 69 to access the fi
4a30: 6c 65 20 77 69 6c 6c 20 6e 6f 74 20 6b 6e 6f 77 le will not know
4a40: 20 74 68 61 74 20 74 68 65 20 6a 6f 75 72 6e 61 that the journa
4a50: 6c 20 65 78 69 73 74 73 20 28 62 65 63 61 75 73 l exists (becaus
4a60: 65 0a 2a 2a 20 74 68 65 20 64 69 72 65 63 74 6f e.** the directo
4a70: 72 79 20 65 6e 74 72 79 20 66 6f 72 20 74 68 65 ry entry for the
4a80: 20 6a 6f 75 72 6e 61 6c 20 77 61 73 20 6e 65 76 journal was nev
4a90: 65 72 20 63 72 65 61 74 65 64 29 20 61 6e 64 20 er created) and
4aa0: 74 68 65 20 74 72 61 6e 73 61 63 74 69 6f 6e 0a the transaction.
4ab0: 2a 2a 20 77 69 6c 6c 20 6e 6f 74 20 72 6f 6c 6c ** will not roll
4ac0: 20 62 61 63 6b 20 2d 20 70 6f 73 73 69 62 6c 79 back - possibly
4ad0: 20 6c 65 61 64 69 6e 67 20 74 6f 20 64 61 74 61 leading to data
4ae0: 62 61 73 65 20 63 6f 72 72 75 70 74 69 6f 6e 2e base corruption.
4af0: 0a 2a 2f 0a 69 6e 74 20 73 71 6c 69 74 65 33 4f .*/.int sqlite3O
4b00: 73 53 79 6e 63 28 4f 73 46 69 6c 65 20 2a 69 64 sSync(OsFile *id
4b10: 29 7b 0a 20 20 53 69 6d 75 6c 61 74 65 49 4f 45 ){. SimulateIOE
4b20: 72 72 6f 72 28 53 51 4c 49 54 45 5f 49 4f 45 52 rror(SQLITE_IOER
4b30: 52 29 3b 0a 20 20 54 52 41 43 45 32 28 22 53 59 R);. TRACE2("SY
4b40: 4e 43 20 20 20 20 25 2d 33 64 5c 6e 22 2c 20 69 NC %-3d\n", i
4b50: 64 2d 3e 68 29 3b 0a 20 20 69 66 28 20 66 73 79 d->h);. if( fsy
4b60: 6e 63 28 69 64 2d 3e 68 29 20 29 7b 0a 20 20 20 nc(id->h) ){.
4b70: 20 72 65 74 75 72 6e 20 53 51 4c 49 54 45 5f 49 return SQLITE_I
4b80: 4f 45 52 52 3b 0a 20 20 7d 65 6c 73 65 7b 0a 20 OERR;. }else{.
4b90: 20 20 20 69 66 28 20 69 64 2d 3e 64 69 72 66 64 if( id->dirfd
4ba0: 3e 3d 30 20 29 7b 0a 20 20 20 20 20 20 54 52 41 >=0 ){. TRA
4bb0: 43 45 32 28 22 44 49 52 53 59 4e 43 20 25 2d 33 CE2("DIRSYNC %-3
4bc0: 64 5c 6e 22 2c 20 69 64 2d 3e 64 69 72 66 64 29 d\n", id->dirfd)
4bd0: 3b 0a 20 20 20 20 20 20 66 73 79 6e 63 28 69 64 ;. fsync(id
4be0: 2d 3e 64 69 72 66 64 29 3b 0a 20 20 20 20 20 20 ->dirfd);.
4bf0: 63 6c 6f 73 65 28 69 64 2d 3e 64 69 72 66 64 29 close(id->dirfd)
4c00: 3b 20 20 2f 2a 20 4f 6e 6c 79 20 6e 65 65 64 20 ; /* Only need
4c10: 74 6f 20 73 79 6e 63 20 6f 6e 63 65 2c 20 73 6f to sync once, so
4c20: 20 63 6c 6f 73 65 20 74 68 65 20 64 69 72 65 63 close the direc
4c30: 74 6f 72 79 20 2a 2f 0a 20 20 20 20 20 20 69 64 tory */. id
4c40: 2d 3e 64 69 72 66 64 20 3d 20 2d 31 3b 20 20 20 ->dirfd = -1;
4c50: 20 2f 2a 20 77 68 65 6e 20 77 65 20 61 72 65 20 /* when we are
4c60: 64 6f 6e 65 2e 20 2a 2f 0a 20 20 20 20 7d 0a 20 done. */. }.
4c70: 20 20 20 72 65 74 75 72 6e 20 53 51 4c 49 54 45 return SQLITE
4c80: 5f 4f 4b 3b 0a 20 20 7d 0a 7d 0a 0a 2f 2a 0a 2a _OK;. }.}../*.*
4c90: 2a 20 53 79 6e 63 20 74 68 65 20 64 69 72 65 63 * Sync the direc
4ca0: 74 6f 72 79 20 7a 44 69 72 6e 61 6d 65 2e 20 54 tory zDirname. T
4cb0: 68 69 73 20 69 73 20 61 20 6e 6f 2d 6f 70 20 6f his is a no-op o
4cc0: 6e 20 6f 70 65 72 61 74 69 6e 67 20 73 79 73 74 n operating syst
4cd0: 65 6d 73 20 6f 74 68 65 72 0a 2a 2a 20 74 68 61 ems other.** tha
4ce0: 6e 20 55 4e 49 58 2e 0a 2a 2f 0a 69 6e 74 20 73 n UNIX..*/.int s
4cf0: 71 6c 69 74 65 33 4f 73 53 79 6e 63 44 69 72 65 qlite3OsSyncDire
4d00: 63 74 6f 72 79 28 63 6f 6e 73 74 20 63 68 61 72 ctory(const char
4d10: 20 2a 7a 44 69 72 6e 61 6d 65 29 7b 0a 20 20 69 *zDirname){. i
4d20: 6e 74 20 66 64 3b 0a 20 20 69 6e 74 20 72 3b 0a nt fd;. int r;.
4d30: 20 20 66 64 20 3d 20 6f 70 65 6e 28 7a 44 69 72 fd = open(zDir
4d40: 6e 61 6d 65 2c 20 4f 5f 52 44 4f 4e 4c 59 7c 4f name, O_RDONLY|O
4d50: 5f 42 49 4e 41 52 59 2c 20 30 36 34 34 29 3b 0a _BINARY, 0644);.
4d60: 20 20 69 66 28 20 66 64 3c 30 20 29 7b 0a 20 20 if( fd<0 ){.
4d70: 20 20 72 65 74 75 72 6e 20 53 51 4c 49 54 45 5f return SQLITE_
4d80: 43 41 4e 54 4f 50 45 4e 3b 20 0a 20 20 7d 0a 20 CANTOPEN; . }.
4d90: 20 72 20 3d 20 66 73 79 6e 63 28 66 64 29 3b 0a r = fsync(fd);.
4da0: 20 20 63 6c 6f 73 65 28 66 64 29 3b 0a 20 20 72 close(fd);. r
4db0: 65 74 75 72 6e 20 28 28 72 3d 3d 30 29 3f 53 51 eturn ((r==0)?SQ
4dc0: 4c 49 54 45 5f 4f 4b 3a 53 51 4c 49 54 45 5f 49 LITE_OK:SQLITE_I
4dd0: 4f 45 52 52 29 3b 0a 7d 0a 0a 2f 2a 0a 2a 2a 20 OERR);.}../*.**
4de0: 54 72 75 6e 63 61 74 65 20 61 6e 20 6f 70 65 6e Truncate an open
4df0: 20 66 69 6c 65 20 74 6f 20 61 20 73 70 65 63 69 file to a speci
4e00: 66 69 65 64 20 73 69 7a 65 0a 2a 2f 0a 69 6e 74 fied size.*/.int
4e10: 20 73 71 6c 69 74 65 33 4f 73 54 72 75 6e 63 61 sqlite3OsTrunca
4e20: 74 65 28 4f 73 46 69 6c 65 20 2a 69 64 2c 20 6f te(OsFile *id, o
4e30: 66 66 5f 74 20 6e 42 79 74 65 29 7b 0a 20 20 53 ff_t nByte){. S
4e40: 69 6d 75 6c 61 74 65 49 4f 45 72 72 6f 72 28 53 imulateIOError(S
4e50: 51 4c 49 54 45 5f 49 4f 45 52 52 29 3b 0a 20 20 QLITE_IOERR);.
4e60: 72 65 74 75 72 6e 20 66 74 72 75 6e 63 61 74 65 return ftruncate
4e70: 28 69 64 2d 3e 68 2c 20 6e 42 79 74 65 29 3d 3d (id->h, nByte)==
4e80: 30 20 3f 20 53 51 4c 49 54 45 5f 4f 4b 20 3a 20 0 ? SQLITE_OK :
4e90: 53 51 4c 49 54 45 5f 49 4f 45 52 52 3b 0a 7d 0a SQLITE_IOERR;.}.
4ea0: 0a 2f 2a 0a 2a 2a 20 44 65 74 65 72 6d 69 6e 65 ./*.** Determine
4eb0: 20 74 68 65 20 63 75 72 72 65 6e 74 20 73 69 7a the current siz
4ec0: 65 20 6f 66 20 61 20 66 69 6c 65 20 69 6e 20 62 e of a file in b
4ed0: 79 74 65 73 0a 2a 2f 0a 69 6e 74 20 73 71 6c 69 ytes.*/.int sqli
4ee0: 74 65 33 4f 73 46 69 6c 65 53 69 7a 65 28 4f 73 te3OsFileSize(Os
4ef0: 46 69 6c 65 20 2a 69 64 2c 20 6f 66 66 5f 74 20 File *id, off_t
4f00: 2a 70 53 69 7a 65 29 7b 0a 20 20 73 74 72 75 63 *pSize){. struc
4f10: 74 20 73 74 61 74 20 62 75 66 3b 0a 20 20 53 69 t stat buf;. Si
4f20: 6d 75 6c 61 74 65 49 4f 45 72 72 6f 72 28 53 51 mulateIOError(SQ
4f30: 4c 49 54 45 5f 49 4f 45 52 52 29 3b 0a 20 20 69 LITE_IOERR);. i
4f40: 66 28 20 66 73 74 61 74 28 69 64 2d 3e 68 2c 20 f( fstat(id->h,
4f50: 26 62 75 66 29 21 3d 30 20 29 7b 0a 20 20 20 20 &buf)!=0 ){.
4f60: 72 65 74 75 72 6e 20 53 51 4c 49 54 45 5f 49 4f return SQLITE_IO
4f70: 45 52 52 3b 0a 20 20 7d 0a 20 20 2a 70 53 69 7a ERR;. }. *pSiz
4f80: 65 20 3d 20 62 75 66 2e 73 74 5f 73 69 7a 65 3b e = buf.st_size;
4f90: 0a 20 20 72 65 74 75 72 6e 20 53 51 4c 49 54 45 . return SQLITE
4fa0: 5f 4f 4b 3b 0a 7d 0a 0a 2f 2a 0a 2a 2a 20 54 68 _OK;.}../*.** Th
4fb0: 69 73 20 72 6f 75 74 69 6e 65 20 63 68 65 63 6b is routine check
4fc0: 73 20 69 66 20 74 68 65 72 65 20 69 73 20 61 20 s if there is a
4fd0: 52 45 53 45 52 56 45 44 20 6c 6f 63 6b 20 68 65 RESERVED lock he
4fe0: 6c 64 20 6f 6e 20 74 68 65 20 73 70 65 63 69 66 ld on the specif
4ff0: 69 65 64 0a 2a 2a 20 66 69 6c 65 20 62 79 20 74 ied.** file by t
5000: 68 69 73 20 6f 72 20 61 6e 79 20 6f 74 68 65 72 his or any other
5010: 20 70 72 6f 63 65 73 73 2e 20 49 66 20 73 75 63 process. If suc
5020: 68 20 61 20 6c 6f 63 6b 20 69 73 20 68 65 6c 64 h a lock is held
5030: 2c 20 72 65 74 75 72 6e 0a 2a 2a 20 6e 6f 6e 2d , return.** non-
5040: 7a 65 72 6f 2e 20 20 49 66 20 74 68 65 20 66 69 zero. If the fi
5050: 6c 65 20 69 73 20 75 6e 6c 6f 63 6b 65 64 20 6f le is unlocked o
5060: 72 20 68 6f 6c 64 73 20 6f 6e 6c 79 20 53 48 41 r holds only SHA
5070: 52 45 44 20 6c 6f 63 6b 73 2c 20 74 68 65 6e 0a RED locks, then.
5080: 2a 2a 20 72 65 74 75 72 6e 20 7a 65 72 6f 2e 0a ** return zero..
5090: 2a 2f 0a 69 6e 74 20 73 71 6c 69 74 65 33 4f 73 */.int sqlite3Os
50a0: 43 68 65 63 6b 52 65 73 65 72 76 65 64 4c 6f 63 CheckReservedLoc
50b0: 6b 28 4f 73 46 69 6c 65 20 2a 69 64 29 7b 0a 20 k(OsFile *id){.
50c0: 20 69 6e 74 20 72 20 3d 20 30 3b 0a 0a 20 20 73 int r = 0;.. s
50d0: 71 6c 69 74 65 33 4f 73 45 6e 74 65 72 4d 75 74 qlite3OsEnterMut
50e0: 65 78 28 29 3b 20 2f 2a 20 4e 65 65 64 65 64 20 ex(); /* Needed
50f0: 62 65 63 61 75 73 65 20 69 64 2d 3e 70 4c 6f 63 because id->pLoc
5100: 6b 20 69 73 20 73 68 61 72 65 64 20 61 63 72 6f k is shared acro
5110: 73 73 20 74 68 72 65 61 64 73 20 2a 2f 0a 0a 20 ss threads */..
5120: 20 2f 2a 20 43 68 65 63 6b 20 69 66 20 61 20 74 /* Check if a t
5130: 68 72 65 61 64 20 69 6e 20 74 68 69 73 20 70 72 hread in this pr
5140: 6f 63 65 73 73 20 68 6f 6c 64 73 20 73 75 63 68 ocess holds such
5150: 20 61 20 6c 6f 63 6b 20 2a 2f 0a 20 20 69 66 28 a lock */. if(
5160: 20 69 64 2d 3e 70 4c 6f 63 6b 2d 3e 6c 6f 63 6b id->pLock->lock
5170: 74 79 70 65 3e 53 48 41 52 45 44 5f 4c 4f 43 4b type>SHARED_LOCK
5180: 20 29 7b 0a 20 20 20 20 72 20 3d 20 31 3b 0a 20 ){. r = 1;.
5190: 20 7d 0a 0a 20 20 2f 2a 20 4f 74 68 65 72 77 69 }.. /* Otherwi
51a0: 73 65 20 73 65 65 20 69 66 20 73 6f 6d 65 20 6f se see if some o
51b0: 74 68 65 72 20 70 72 6f 63 65 73 73 20 68 6f 6c ther process hol
51c0: 64 73 20 69 74 2e 0a 20 20 2a 2f 0a 20 20 69 66 ds it.. */. if
51d0: 28 20 21 72 20 29 7b 0a 20 20 20 20 73 74 72 75 ( !r ){. stru
51e0: 63 74 20 66 6c 6f 63 6b 20 6c 6f 63 6b 3b 0a 20 ct flock lock;.
51f0: 20 20 20 6c 6f 63 6b 2e 6c 5f 77 68 65 6e 63 65 lock.l_whence
5200: 20 3d 20 53 45 45 4b 5f 53 45 54 3b 0a 20 20 20 = SEEK_SET;.
5210: 20 6c 6f 63 6b 2e 6c 5f 73 74 61 72 74 20 3d 20 lock.l_start =
5220: 52 45 53 45 52 56 45 44 5f 42 59 54 45 3b 0a 20 RESERVED_BYTE;.
5230: 20 20 20 6c 6f 63 6b 2e 6c 5f 6c 65 6e 20 3d 20 lock.l_len =
5240: 31 3b 0a 20 20 20 20 6c 6f 63 6b 2e 6c 5f 74 79 1;. lock.l_ty
5250: 70 65 20 3d 20 46 5f 57 52 4c 43 4b 3b 0a 20 20 pe = F_WRLCK;.
5260: 20 20 66 63 6e 74 6c 28 69 64 2d 3e 68 2c 20 46 fcntl(id->h, F
5270: 5f 47 45 54 4c 4b 2c 20 26 6c 6f 63 6b 29 3b 0a _GETLK, &lock);.
5280: 20 20 20 20 69 66 28 20 6c 6f 63 6b 2e 6c 5f 74 if( lock.l_t
5290: 79 70 65 21 3d 46 5f 55 4e 4c 43 4b 20 29 7b 0a ype!=F_UNLCK ){.
52a0: 20 20 20 20 20 20 72 20 3d 20 31 3b 0a 20 20 20 r = 1;.
52b0: 20 7d 0a 20 20 7d 0a 20 20 0a 20 20 73 71 6c 69 }. }. . sqli
52c0: 74 65 33 4f 73 4c 65 61 76 65 4d 75 74 65 78 28 te3OsLeaveMutex(
52d0: 29 3b 0a 20 20 54 52 41 43 45 33 28 22 54 45 53 );. TRACE3("TES
52e0: 54 20 57 52 2d 4c 4f 43 4b 20 25 64 20 25 64 5c T WR-LOCK %d %d\
52f0: 6e 22 2c 20 69 64 2d 3e 68 2c 20 72 29 3b 0a 0a n", id->h, r);..
5300: 20 20 72 65 74 75 72 6e 20 72 3b 0a 7d 0a 0a 2f return r;.}../
5310: 2a 0a 2a 2a 20 4c 6f 63 6b 20 74 68 65 20 66 69 *.** Lock the fi
5320: 6c 65 20 77 69 74 68 20 74 68 65 20 6c 6f 63 6b le with the lock
5330: 20 73 70 65 63 69 66 69 65 64 20 62 79 20 70 61 specified by pa
5340: 72 61 6d 65 74 65 72 20 6c 6f 63 6b 74 79 70 65 rameter locktype
5350: 20 2d 20 6f 6e 65 0a 2a 2a 20 6f 66 20 74 68 65 - one.** of the
5360: 20 66 6f 6c 6c 6f 77 69 6e 67 3a 0a 2a 2a 0a 2a following:.**.*
5370: 2a 20 20 20 20 20 28 31 29 20 53 48 41 52 45 44 * (1) SHARED
5380: 5f 4c 4f 43 4b 0a 2a 2a 20 20 20 20 20 28 32 29 _LOCK.** (2)
5390: 20 52 45 53 45 52 56 45 44 5f 4c 4f 43 4b 0a 2a RESERVED_LOCK.*
53a0: 2a 20 20 20 20 20 28 33 29 20 50 45 4e 44 49 4e * (3) PENDIN
53b0: 47 5f 4c 4f 43 4b 0a 2a 2a 20 20 20 20 20 28 34 G_LOCK.** (4
53c0: 29 20 45 58 43 4c 55 53 49 56 45 5f 4c 4f 43 4b ) EXCLUSIVE_LOCK
53d0: 0a 2a 2a 0a 2a 2a 20 53 6f 6d 65 74 69 6d 65 73 .**.** Sometimes
53e0: 20 77 68 65 6e 20 72 65 71 75 65 73 74 69 6e 67 when requesting
53f0: 20 6f 6e 65 20 6c 6f 63 6b 20 73 74 61 74 65 2c one lock state,
5400: 20 61 64 64 69 74 69 6f 6e 61 6c 20 6c 6f 63 6b additional lock
5410: 20 73 74 61 74 65 73 0a 2a 2a 20 61 72 65 20 69 states.** are i
5420: 6e 73 65 72 74 65 64 20 69 6e 20 62 65 74 77 65 nserted in betwe
5430: 65 6e 2e 20 20 54 68 65 20 6c 6f 63 6b 69 6e 67 en. The locking
5440: 20 6d 69 67 68 74 20 66 61 69 6c 20 6f 6e 20 6f might fail on o
5450: 6e 65 20 6f 66 20 74 68 65 20 6c 61 74 65 72 0a ne of the later.
5460: 2a 2a 20 74 72 61 6e 73 69 74 69 6f 6e 73 20 6c ** transitions l
5470: 65 61 76 69 6e 67 20 74 68 65 20 6c 6f 63 6b 20 eaving the lock
5480: 73 74 61 74 65 20 64 69 66 66 65 72 65 6e 74 20 state different
5490: 66 72 6f 6d 20 77 68 61 74 20 69 74 20 73 74 61 from what it sta
54a0: 72 74 65 64 20 62 75 74 0a 2a 2a 20 73 74 69 6c rted but.** stil
54b0: 6c 20 73 68 6f 72 74 20 6f 66 20 69 74 73 20 67 l short of its g
54c0: 6f 61 6c 2e 20 20 54 68 65 20 66 6f 6c 6c 6f 77 oal. The follow
54d0: 69 6e 67 20 63 68 61 72 74 20 73 68 6f 77 73 20 ing chart shows
54e0: 74 68 65 20 61 6c 6c 6f 77 65 64 0a 2a 2a 20 74 the allowed.** t
54f0: 72 61 6e 73 69 74 69 6f 6e 73 20 61 6e 64 20 74 ransitions and t
5500: 68 65 20 69 6e 73 65 72 74 65 64 20 69 6e 74 65 he inserted inte
5510: 72 6d 65 64 69 61 74 65 20 73 74 61 74 65 73 3a rmediate states:
5520: 0a 2a 2a 0a 2a 2a 20 20 20 20 55 4e 4c 4f 43 4b .**.** UNLOCK
5530: 45 44 20 2d 3e 20 53 48 41 52 45 44 0a 2a 2a 20 ED -> SHARED.**
5540: 20 20 20 53 48 41 52 45 44 20 2d 3e 20 52 45 53 SHARED -> RES
5550: 45 52 56 45 44 0a 2a 2a 20 20 20 20 53 48 41 52 ERVED.** SHAR
5560: 45 44 20 2d 3e 20 28 50 45 4e 44 49 4e 47 29 20 ED -> (PENDING)
5570: 2d 3e 20 45 58 43 4c 55 53 49 56 45 0a 2a 2a 20 -> EXCLUSIVE.**
5580: 20 20 20 52 45 53 45 52 56 45 44 20 2d 3e 20 28 RESERVED -> (
5590: 50 45 4e 44 49 4e 47 29 20 2d 3e 20 45 58 43 4c PENDING) -> EXCL
55a0: 55 53 49 56 45 0a 2a 2a 20 20 20 20 50 45 4e 44 USIVE.** PEND
55b0: 49 4e 47 20 2d 3e 20 45 58 43 4c 55 53 49 56 45 ING -> EXCLUSIVE
55c0: 0a 2a 2a 0a 2a 2a 20 54 68 69 73 20 72 6f 75 74 .**.** This rout
55d0: 69 6e 65 20 77 69 6c 6c 20 6f 6e 6c 79 20 69 6e ine will only in
55e0: 63 72 65 61 73 65 20 61 20 6c 6f 63 6b 2e 20 20 crease a lock.
55f0: 55 73 65 20 74 68 65 20 73 71 6c 69 74 65 33 4f Use the sqlite3O
5600: 73 55 6e 6c 6f 63 6b 28 29 0a 2a 2a 20 72 6f 75 sUnlock().** rou
5610: 74 69 6e 65 20 74 6f 20 6c 6f 77 65 72 20 61 20 tine to lower a
5620: 6c 6f 63 6b 69 6e 67 20 6c 65 76 65 6c 2e 0a 2a locking level..*
5630: 2f 0a 69 6e 74 20 73 71 6c 69 74 65 33 4f 73 4c /.int sqlite3OsL
5640: 6f 63 6b 28 4f 73 46 69 6c 65 20 2a 69 64 2c 20 ock(OsFile *id,
5650: 69 6e 74 20 6c 6f 63 6b 74 79 70 65 29 7b 0a 20 int locktype){.
5660: 20 69 6e 74 20 72 63 20 3d 20 53 51 4c 49 54 45 int rc = SQLITE
5670: 5f 4f 4b 3b 0a 20 20 73 74 72 75 63 74 20 6c 6f _OK;. struct lo
5680: 63 6b 49 6e 66 6f 20 2a 70 4c 6f 63 6b 20 3d 20 ckInfo *pLock =
5690: 69 64 2d 3e 70 4c 6f 63 6b 3b 0a 20 20 73 74 72 id->pLock;. str
56a0: 75 63 74 20 66 6c 6f 63 6b 20 6c 6f 63 6b 3b 0a uct flock lock;.
56b0: 20 20 69 6e 74 20 73 3b 0a 0a 20 20 54 52 41 43 int s;.. TRAC
56c0: 45 36 28 22 4c 4f 43 4b 20 25 64 20 25 64 20 77 E6("LOCK %d %d w
56d0: 61 73 20 25 64 28 25 64 2c 25 64 29 5c 6e 22 2c as %d(%d,%d)\n",
56e0: 0a 20 20 20 20 20 20 20 20 20 20 69 64 2d 3e 68 . id->h
56f0: 2c 20 6c 6f 63 6b 74 79 70 65 2c 20 69 64 2d 3e , locktype, id->
5700: 6c 6f 63 6b 74 79 70 65 2c 20 70 4c 6f 63 6b 2d locktype, pLock-
5710: 3e 6c 6f 63 6b 74 79 70 65 2c 20 70 4c 6f 63 6b >locktype, pLock
5720: 2d 3e 63 6e 74 29 3b 0a 0a 20 20 2f 2a 20 49 66 ->cnt);.. /* If
5730: 20 74 68 65 72 65 20 69 73 20 61 6c 72 65 61 64 there is alread
5740: 79 20 61 20 6c 6f 63 6b 20 6f 66 20 74 68 69 73 y a lock of this
5750: 20 74 79 70 65 20 6f 72 20 6d 6f 72 65 20 72 65 type or more re
5760: 73 74 72 69 63 74 69 76 65 20 6f 6e 20 74 68 65 strictive on the
5770: 0a 20 20 2a 2a 20 4f 73 46 69 6c 65 2c 20 64 6f . ** OsFile, do
5780: 20 6e 6f 74 68 69 6e 67 2e 20 44 6f 6e 27 74 20 nothing. Don't
5790: 75 73 65 20 74 68 65 20 65 6e 64 5f 6c 6f 63 6b use the end_lock
57a0: 3a 20 65 78 69 74 20 70 61 74 68 2c 20 61 73 0a : exit path, as.
57b0: 20 20 2a 2a 20 73 71 6c 69 74 65 33 4f 73 45 6e ** sqlite3OsEn
57c0: 74 65 72 4d 75 74 65 78 28 29 20 68 61 73 6e 27 terMutex() hasn'
57d0: 74 20 62 65 65 6e 20 63 61 6c 6c 65 64 20 79 65 t been called ye
57e0: 74 2e 0a 20 20 2a 2f 0a 20 20 69 66 28 20 69 64 t.. */. if( id
57f0: 2d 3e 6c 6f 63 6b 74 79 70 65 3e 3d 6c 6f 63 6b ->locktype>=lock
5800: 74 79 70 65 20 29 7b 0a 20 20 20 20 72 65 74 75 type ){. retu
5810: 72 6e 20 53 51 4c 49 54 45 5f 4f 4b 3b 0a 20 20 rn SQLITE_OK;.
5820: 7d 0a 0a 20 20 2f 2a 20 4d 61 6b 65 20 73 75 72 }.. /* Make sur
5830: 65 20 74 68 65 20 6c 6f 63 6b 69 6e 67 20 73 65 e the locking se
5840: 71 75 65 6e 63 65 20 69 73 20 63 6f 72 72 65 63 quence is correc
5850: 74 0a 20 20 2a 2f 0a 20 20 61 73 73 65 72 74 28 t. */. assert(
5860: 20 69 64 2d 3e 6c 6f 63 6b 74 79 70 65 21 3d 4e id->locktype!=N
5870: 4f 5f 4c 4f 43 4b 20 7c 7c 20 6c 6f 63 6b 74 79 O_LOCK || lockty
5880: 70 65 3d 3d 53 48 41 52 45 44 5f 4c 4f 43 4b 20 pe==SHARED_LOCK
5890: 29 3b 0a 20 20 61 73 73 65 72 74 28 20 6c 6f 63 );. assert( loc
58a0: 6b 74 79 70 65 21 3d 50 45 4e 44 49 4e 47 5f 4c ktype!=PENDING_L
58b0: 4f 43 4b 20 29 3b 0a 20 20 61 73 73 65 72 74 28 OCK );. assert(
58c0: 20 6c 6f 63 6b 74 79 70 65 21 3d 52 45 53 45 52 locktype!=RESER
58d0: 56 45 44 5f 4c 4f 43 4b 20 7c 7c 20 69 64 2d 3e VED_LOCK || id->
58e0: 6c 6f 63 6b 74 79 70 65 3d 3d 53 48 41 52 45 44 locktype==SHARED
58f0: 5f 4c 4f 43 4b 20 29 3b 0a 0a 20 20 2f 2a 20 54 _LOCK );.. /* T
5900: 68 69 73 20 6d 75 74 65 78 20 69 73 20 6e 65 65 his mutex is nee
5910: 64 65 64 20 62 65 63 61 75 73 65 20 69 64 2d 3e ded because id->
5920: 70 4c 6f 63 6b 20 69 73 20 73 68 61 72 65 64 20 pLock is shared
5930: 61 63 72 6f 73 73 20 74 68 72 65 61 64 73 0a 20 across threads.
5940: 20 2a 2f 0a 20 20 73 71 6c 69 74 65 33 4f 73 45 */. sqlite3OsE
5950: 6e 74 65 72 4d 75 74 65 78 28 29 3b 0a 0a 20 20 nterMutex();..
5960: 2f 2a 20 49 66 20 73 6f 6d 65 20 74 68 72 65 61 /* If some threa
5970: 64 20 75 73 69 6e 67 20 74 68 69 73 20 50 49 44 d using this PID
5980: 20 68 61 73 20 61 20 6c 6f 63 6b 20 76 69 61 20 has a lock via
5990: 61 20 64 69 66 66 65 72 65 6e 74 20 4f 73 46 69 a different OsFi
59a0: 6c 65 2a 0a 20 20 2a 2a 20 68 61 6e 64 6c 65 20 le*. ** handle
59b0: 74 68 61 74 20 70 72 65 63 6c 75 64 65 73 20 74 that precludes t
59c0: 68 65 20 72 65 71 75 65 73 74 65 64 20 6c 6f 63 he requested loc
59d0: 6b 2c 20 72 65 74 75 72 6e 20 42 55 53 59 2e 0a k, return BUSY..
59e0: 20 20 2a 2f 0a 20 20 69 66 28 20 28 69 64 2d 3e */. if( (id->
59f0: 6c 6f 63 6b 74 79 70 65 21 3d 70 4c 6f 63 6b 2d locktype!=pLock-
5a00: 3e 6c 6f 63 6b 74 79 70 65 20 26 26 20 0a 20 20 >locktype && .
5a10: 20 20 20 20 20 20 20 20 28 70 4c 6f 63 6b 2d 3e (pLock->
5a20: 6c 6f 63 6b 74 79 70 65 3e 3d 50 45 4e 44 49 4e locktype>=PENDIN
5a30: 47 5f 4c 4f 43 4b 20 7c 7c 20 6c 6f 63 6b 74 79 G_LOCK || lockty
5a40: 70 65 3e 53 48 41 52 45 44 5f 4c 4f 43 4b 29 29 pe>SHARED_LOCK))
5a50: 0a 20 20 29 7b 0a 20 20 20 20 72 63 20 3d 20 53 . ){. rc = S
5a60: 51 4c 49 54 45 5f 42 55 53 59 3b 0a 20 20 20 20 QLITE_BUSY;.
5a70: 67 6f 74 6f 20 65 6e 64 5f 6c 6f 63 6b 3b 0a 20 goto end_lock;.
5a80: 20 7d 0a 0a 20 20 2f 2a 20 49 66 20 61 20 53 48 }.. /* If a SH
5a90: 41 52 45 44 20 6c 6f 63 6b 20 69 73 20 72 65 71 ARED lock is req
5aa0: 75 65 73 74 65 64 2c 20 61 6e 64 20 73 6f 6d 65 uested, and some
5ab0: 20 74 68 72 65 61 64 20 75 73 69 6e 67 20 74 68 thread using th
5ac0: 69 73 20 50 49 44 20 61 6c 72 65 61 64 79 0a 20 is PID already.
5ad0: 20 2a 2a 20 68 61 73 20 61 20 53 48 41 52 45 44 ** has a SHARED
5ae0: 20 6f 72 20 52 45 53 45 52 56 45 44 20 6c 6f 63 or RESERVED loc
5af0: 6b 2c 20 74 68 65 6e 20 69 6e 63 72 65 6d 65 6e k, then incremen
5b00: 74 20 72 65 66 65 72 65 6e 63 65 20 63 6f 75 6e t reference coun
5b10: 74 73 20 61 6e 64 0a 20 20 2a 2a 20 72 65 74 75 ts and. ** retu
5b20: 72 6e 20 53 51 4c 49 54 45 5f 4f 4b 2e 0a 20 20 rn SQLITE_OK..
5b30: 2a 2f 0a 20 20 69 66 28 20 6c 6f 63 6b 74 79 70 */. if( locktyp
5b40: 65 3d 3d 53 48 41 52 45 44 5f 4c 4f 43 4b 20 26 e==SHARED_LOCK &
5b50: 26 20 0a 20 20 20 20 20 20 28 70 4c 6f 63 6b 2d & . (pLock-
5b60: 3e 6c 6f 63 6b 74 79 70 65 3d 3d 53 48 41 52 45 >locktype==SHARE
5b70: 44 5f 4c 4f 43 4b 20 7c 7c 20 70 4c 6f 63 6b 2d D_LOCK || pLock-
5b80: 3e 6c 6f 63 6b 74 79 70 65 3d 3d 52 45 53 45 52 >locktype==RESER
5b90: 56 45 44 5f 4c 4f 43 4b 29 20 29 7b 0a 20 20 20 VED_LOCK) ){.
5ba0: 20 61 73 73 65 72 74 28 20 6c 6f 63 6b 74 79 70 assert( locktyp
5bb0: 65 3d 3d 53 48 41 52 45 44 5f 4c 4f 43 4b 20 29 e==SHARED_LOCK )
5bc0: 3b 0a 20 20 20 20 61 73 73 65 72 74 28 20 69 64 ;. assert( id
5bd0: 2d 3e 6c 6f 63 6b 74 79 70 65 3d 3d 30 20 29 3b ->locktype==0 );
5be0: 0a 20 20 20 20 61 73 73 65 72 74 28 20 70 4c 6f . assert( pLo
5bf0: 63 6b 2d 3e 63 6e 74 3e 30 20 29 3b 0a 20 20 20 ck->cnt>0 );.
5c00: 20 69 64 2d 3e 6c 6f 63 6b 74 79 70 65 20 3d 20 id->locktype =
5c10: 53 48 41 52 45 44 5f 4c 4f 43 4b 3b 0a 20 20 20 SHARED_LOCK;.
5c20: 20 70 4c 6f 63 6b 2d 3e 63 6e 74 2b 2b 3b 0a 20 pLock->cnt++;.
5c30: 20 20 20 69 64 2d 3e 70 4f 70 65 6e 2d 3e 6e 4c id->pOpen->nL
5c40: 6f 63 6b 2b 2b 3b 0a 20 20 20 20 67 6f 74 6f 20 ock++;. goto
5c50: 65 6e 64 5f 6c 6f 63 6b 3b 0a 20 20 7d 0a 0a 20 end_lock;. }..
5c60: 20 6c 6f 63 6b 2e 6c 5f 6c 65 6e 20 3d 20 31 4c lock.l_len = 1L
5c70: 3b 0a 20 20 6c 6f 63 6b 2e 6c 5f 77 68 65 6e 63 ;. lock.l_whenc
5c80: 65 20 3d 20 53 45 45 4b 5f 53 45 54 3b 0a 0a 20 e = SEEK_SET;..
5c90: 20 2f 2a 20 41 20 50 45 4e 44 49 4e 47 20 6c 6f /* A PENDING lo
5ca0: 63 6b 20 69 73 20 6e 65 65 64 65 64 20 62 65 66 ck is needed bef
5cb0: 6f 72 65 20 61 63 71 75 69 72 69 6e 67 20 61 20 ore acquiring a
5cc0: 53 48 41 52 45 44 20 6c 6f 63 6b 20 61 6e 64 20 SHARED lock and
5cd0: 62 65 66 6f 72 65 0a 20 20 2a 2a 20 61 63 71 75 before. ** acqu
5ce0: 69 72 69 6e 67 20 61 6e 20 45 58 43 4c 55 53 49 iring an EXCLUSI
5cf0: 56 45 20 6c 6f 63 6b 2e 20 20 46 6f 72 20 74 68 VE lock. For th
5d00: 65 20 53 48 41 52 45 44 20 6c 6f 63 6b 2c 20 74 e SHARED lock, t
5d10: 68 65 20 50 45 4e 44 49 4e 47 20 77 69 6c 6c 0a he PENDING will.
5d20: 20 20 2a 2a 20 62 65 20 72 65 6c 65 61 73 65 64 ** be released
5d30: 2e 0a 20 20 2a 2f 0a 20 20 69 66 28 20 6c 6f 63 .. */. if( loc
5d40: 6b 74 79 70 65 3d 3d 53 48 41 52 45 44 5f 4c 4f ktype==SHARED_LO
5d50: 43 4b 20 0a 20 20 20 20 20 20 7c 7c 20 28 6c 6f CK . || (lo
5d60: 63 6b 74 79 70 65 3d 3d 45 58 43 4c 55 53 49 56 cktype==EXCLUSIV
5d70: 45 5f 4c 4f 43 4b 20 26 26 20 69 64 2d 3e 6c 6f E_LOCK && id->lo
5d80: 63 6b 74 79 70 65 3c 50 45 4e 44 49 4e 47 5f 4c cktype<PENDING_L
5d90: 4f 43 4b 29 0a 20 20 29 7b 0a 20 20 20 20 6c 6f OCK). ){. lo
5da0: 63 6b 2e 6c 5f 74 79 70 65 20 3d 20 46 5f 52 44 ck.l_type = F_RD
5db0: 4c 43 4b 3b 0a 20 20 20 20 6c 6f 63 6b 2e 6c 5f LCK;. lock.l_
5dc0: 73 74 61 72 74 20 3d 20 50 45 4e 44 49 4e 47 5f start = PENDING_
5dd0: 42 59 54 45 3b 0a 20 20 20 20 73 20 3d 20 66 63 BYTE;. s = fc
5de0: 6e 74 6c 28 69 64 2d 3e 68 2c 20 46 5f 53 45 54 ntl(id->h, F_SET
5df0: 4c 4b 2c 20 26 6c 6f 63 6b 29 3b 0a 20 20 20 20 LK, &lock);.
5e00: 69 66 28 20 73 20 29 7b 0a 20 20 20 20 20 20 72 if( s ){. r
5e10: 63 20 3d 20 28 65 72 72 6e 6f 3d 3d 45 49 4e 56 c = (errno==EINV
5e20: 41 4c 29 20 3f 20 53 51 4c 49 54 45 5f 4e 4f 4c AL) ? SQLITE_NOL
5e30: 46 53 20 3a 20 53 51 4c 49 54 45 5f 42 55 53 59 FS : SQLITE_BUSY
5e40: 3b 0a 20 20 20 20 20 20 67 6f 74 6f 20 65 6e 64 ;. goto end
5e50: 5f 6c 6f 63 6b 3b 0a 20 20 20 20 7d 0a 20 20 7d _lock;. }. }
5e60: 0a 0a 0a 20 20 2f 2a 20 49 66 20 63 6f 6e 74 72 ... /* If contr
5e70: 6f 6c 20 67 65 74 73 20 74 6f 20 74 68 69 73 20 ol gets to this
5e80: 70 6f 69 6e 74 2c 20 74 68 65 6e 20 61 63 74 75 point, then actu
5e90: 61 6c 6c 79 20 67 6f 20 61 68 65 61 64 20 61 6e ally go ahead an
5ea0: 64 20 6d 61 6b 65 0a 20 20 2a 2a 20 6f 70 65 72 d make. ** oper
5eb0: 61 74 69 6e 67 20 73 79 73 74 65 6d 20 63 61 6c ating system cal
5ec0: 6c 73 20 66 6f 72 20 74 68 65 20 73 70 65 63 69 ls for the speci
5ed0: 66 69 65 64 20 6c 6f 63 6b 2e 0a 20 20 2a 2f 0a fied lock.. */.
5ee0: 20 20 69 66 28 20 6c 6f 63 6b 74 79 70 65 3d 3d if( locktype==
5ef0: 53 48 41 52 45 44 5f 4c 4f 43 4b 20 29 7b 0a 20 SHARED_LOCK ){.
5f00: 20 20 20 61 73 73 65 72 74 28 20 70 4c 6f 63 6b assert( pLock
5f10: 2d 3e 63 6e 74 3d 3d 30 20 29 3b 0a 20 20 20 20 ->cnt==0 );.
5f20: 61 73 73 65 72 74 28 20 70 4c 6f 63 6b 2d 3e 6c assert( pLock->l
5f30: 6f 63 6b 74 79 70 65 3d 3d 30 20 29 3b 0a 0a 20 ocktype==0 );..
5f40: 20 20 20 2f 2a 20 4e 6f 77 20 67 65 74 20 74 68 /* Now get th
5f50: 65 20 72 65 61 64 2d 6c 6f 63 6b 20 2a 2f 0a 20 e read-lock */.
5f60: 20 20 20 6c 6f 63 6b 2e 6c 5f 73 74 61 72 74 20 lock.l_start
5f70: 3d 20 53 48 41 52 45 44 5f 46 49 52 53 54 3b 0a = SHARED_FIRST;.
5f80: 20 20 20 20 6c 6f 63 6b 2e 6c 5f 6c 65 6e 20 3d lock.l_len =
5f90: 20 53 48 41 52 45 44 5f 53 49 5a 45 3b 0a 20 20 SHARED_SIZE;.
5fa0: 20 20 73 20 3d 20 66 63 6e 74 6c 28 69 64 2d 3e s = fcntl(id->
5fb0: 68 2c 20 46 5f 53 45 54 4c 4b 2c 20 26 6c 6f 63 h, F_SETLK, &loc
5fc0: 6b 29 3b 0a 0a 20 20 20 20 2f 2a 20 44 72 6f 70 k);.. /* Drop
5fd0: 20 74 68 65 20 74 65 6d 70 6f 72 61 72 79 20 50 the temporary P
5fe0: 45 4e 44 49 4e 47 20 6c 6f 63 6b 20 2a 2f 0a 20 ENDING lock */.
5ff0: 20 20 20 6c 6f 63 6b 2e 6c 5f 73 74 61 72 74 20 lock.l_start
6000: 3d 20 50 45 4e 44 49 4e 47 5f 42 59 54 45 3b 0a = PENDING_BYTE;.
6010: 20 20 20 20 6c 6f 63 6b 2e 6c 5f 6c 65 6e 20 3d lock.l_len =
6020: 20 31 4c 3b 0a 20 20 20 20 6c 6f 63 6b 2e 6c 5f 1L;. lock.l_
6030: 74 79 70 65 20 3d 20 46 5f 55 4e 4c 43 4b 3b 0a type = F_UNLCK;.
6040: 20 20 20 20 66 63 6e 74 6c 28 69 64 2d 3e 68 2c fcntl(id->h,
6050: 20 46 5f 53 45 54 4c 4b 2c 20 26 6c 6f 63 6b 29 F_SETLK, &lock)
6060: 3b 0a 20 20 20 20 69 66 28 20 73 20 29 7b 0a 20 ;. if( s ){.
6070: 20 20 20 20 20 72 63 20 3d 20 28 65 72 72 6e 6f rc = (errno
6080: 3d 3d 45 49 4e 56 41 4c 29 20 3f 20 53 51 4c 49 ==EINVAL) ? SQLI
6090: 54 45 5f 4e 4f 4c 46 53 20 3a 20 53 51 4c 49 54 TE_NOLFS : SQLIT
60a0: 45 5f 42 55 53 59 3b 0a 20 20 20 20 7d 65 6c 73 E_BUSY;. }els
60b0: 65 7b 0a 20 20 20 20 20 20 69 64 2d 3e 6c 6f 63 e{. id->loc
60c0: 6b 74 79 70 65 20 3d 20 53 48 41 52 45 44 5f 4c ktype = SHARED_L
60d0: 4f 43 4b 3b 0a 20 20 20 20 20 20 69 64 2d 3e 70 OCK;. id->p
60e0: 4f 70 65 6e 2d 3e 6e 4c 6f 63 6b 2b 2b 3b 0a 20 Open->nLock++;.
60f0: 20 20 20 20 20 70 4c 6f 63 6b 2d 3e 63 6e 74 20 pLock->cnt
6100: 3d 20 31 3b 0a 20 20 20 20 7d 0a 20 20 7d 65 6c = 1;. }. }el
6110: 73 65 20 69 66 28 20 6c 6f 63 6b 74 79 70 65 3d se if( locktype=
6120: 3d 45 58 43 4c 55 53 49 56 45 5f 4c 4f 43 4b 20 =EXCLUSIVE_LOCK
6130: 26 26 20 70 4c 6f 63 6b 2d 3e 63 6e 74 3e 31 20 && pLock->cnt>1
6140: 29 7b 0a 20 20 20 20 2f 2a 20 57 65 20 61 72 65 ){. /* We are
6150: 20 74 72 79 69 6e 67 20 66 6f 72 20 61 6e 20 65 trying for an e
6160: 78 63 6c 75 73 69 76 65 20 6c 6f 63 6b 20 62 75 xclusive lock bu
6170: 74 20 61 6e 6f 74 68 65 72 20 74 68 72 65 61 64 t another thread
6180: 20 69 6e 20 74 68 69 73 0a 20 20 20 20 2a 2a 20 in this. **
6190: 73 61 6d 65 20 70 72 6f 63 65 73 73 20 69 73 20 same process is
61a0: 73 74 69 6c 6c 20 68 6f 6c 64 69 6e 67 20 61 20 still holding a
61b0: 73 68 61 72 65 64 20 6c 6f 63 6b 2e 20 2a 2f 0a shared lock. */.
61c0: 20 20 20 20 72 63 20 3d 20 53 51 4c 49 54 45 5f rc = SQLITE_
61d0: 42 55 53 59 3b 0a 20 20 7d 65 6c 73 65 7b 0a 20 BUSY;. }else{.
61e0: 20 20 20 2f 2a 20 54 68 65 20 72 65 71 75 65 73 /* The reques
61f0: 74 20 77 61 73 20 66 6f 72 20 61 20 52 45 53 45 t was for a RESE
6200: 52 56 45 44 20 6f 72 20 45 58 43 4c 55 53 49 56 RVED or EXCLUSIV
6210: 45 20 6c 6f 63 6b 2e 20 20 49 74 20 69 73 0a 20 E lock. It is.
6220: 20 20 20 2a 2a 20 61 73 73 75 6d 65 64 20 74 68 ** assumed th
6230: 61 74 20 74 68 65 72 65 20 69 73 20 61 20 53 48 at there is a SH
6240: 41 52 45 44 20 6f 72 20 67 72 65 61 74 65 72 20 ARED or greater
6250: 6c 6f 63 6b 20 6f 6e 20 74 68 65 20 66 69 6c 65 lock on the file
6260: 0a 20 20 20 20 2a 2a 20 61 6c 72 65 61 64 79 2e . ** already.
6270: 0a 20 20 20 20 2a 2f 0a 20 20 20 20 61 73 73 65 . */. asse
6280: 72 74 28 20 30 21 3d 69 64 2d 3e 6c 6f 63 6b 74 rt( 0!=id->lockt
6290: 79 70 65 20 29 3b 0a 20 20 20 20 6c 6f 63 6b 2e ype );. lock.
62a0: 6c 5f 74 79 70 65 20 3d 20 46 5f 57 52 4c 43 4b l_type = F_WRLCK
62b0: 3b 0a 20 20 20 20 73 77 69 74 63 68 28 20 6c 6f ;. switch( lo
62c0: 63 6b 74 79 70 65 20 29 7b 0a 20 20 20 20 20 20 cktype ){.
62d0: 63 61 73 65 20 52 45 53 45 52 56 45 44 5f 4c 4f case RESERVED_LO
62e0: 43 4b 3a 0a 20 20 20 20 20 20 20 20 6c 6f 63 6b CK:. lock
62f0: 2e 6c 5f 73 74 61 72 74 20 3d 20 52 45 53 45 52 .l_start = RESER
6300: 56 45 44 5f 42 59 54 45 3b 0a 20 20 20 20 20 20 VED_BYTE;.
6310: 20 20 62 72 65 61 6b 3b 0a 20 20 20 20 20 20 63 break;. c
6320: 61 73 65 20 45 58 43 4c 55 53 49 56 45 5f 4c 4f ase EXCLUSIVE_LO
6330: 43 4b 3a 0a 20 20 20 20 20 20 20 20 6c 6f 63 6b CK:. lock
6340: 2e 6c 5f 73 74 61 72 74 20 3d 20 53 48 41 52 45 .l_start = SHARE
6350: 44 5f 46 49 52 53 54 3b 0a 20 20 20 20 20 20 20 D_FIRST;.
6360: 20 6c 6f 63 6b 2e 6c 5f 6c 65 6e 20 3d 20 53 48 lock.l_len = SH
6370: 41 52 45 44 5f 53 49 5a 45 3b 0a 20 20 20 20 20 ARED_SIZE;.
6380: 20 20 20 62 72 65 61 6b 3b 0a 20 20 20 20 20 20 break;.
6390: 64 65 66 61 75 6c 74 3a 0a 20 20 20 20 20 20 20 default:.
63a0: 20 61 73 73 65 72 74 28 30 29 3b 0a 20 20 20 20 assert(0);.
63b0: 7d 0a 20 20 20 20 73 20 3d 20 66 63 6e 74 6c 28 }. s = fcntl(
63c0: 69 64 2d 3e 68 2c 20 46 5f 53 45 54 4c 4b 2c 20 id->h, F_SETLK,
63d0: 26 6c 6f 63 6b 29 3b 0a 20 20 20 20 69 66 28 20 &lock);. if(
63e0: 73 20 29 7b 0a 20 20 20 20 20 20 72 63 20 3d 20 s ){. rc =
63f0: 28 65 72 72 6e 6f 3d 3d 45 49 4e 56 41 4c 29 20 (errno==EINVAL)
6400: 3f 20 53 51 4c 49 54 45 5f 4e 4f 4c 46 53 20 3a ? SQLITE_NOLFS :
6410: 20 53 51 4c 49 54 45 5f 42 55 53 59 3b 0a 20 20 SQLITE_BUSY;.
6420: 20 20 7d 0a 20 20 7d 0a 20 20 0a 20 20 69 66 28 }. }. . if(
6430: 20 72 63 3d 3d 53 51 4c 49 54 45 5f 4f 4b 20 29 rc==SQLITE_OK )
6440: 7b 0a 20 20 20 20 69 64 2d 3e 6c 6f 63 6b 74 79 {. id->lockty
6450: 70 65 20 3d 20 6c 6f 63 6b 74 79 70 65 3b 0a 20 pe = locktype;.
6460: 20 20 20 70 4c 6f 63 6b 2d 3e 6c 6f 63 6b 74 79 pLock->lockty
6470: 70 65 20 3d 20 6c 6f 63 6b 74 79 70 65 3b 0a 20 pe = locktype;.
6480: 20 7d 65 6c 73 65 20 69 66 28 20 6c 6f 63 6b 74 }else if( lockt
6490: 79 70 65 3d 3d 45 58 43 4c 55 53 49 56 45 5f 4c ype==EXCLUSIVE_L
64a0: 4f 43 4b 20 29 7b 0a 20 20 20 20 69 64 2d 3e 6c OCK ){. id->l
64b0: 6f 63 6b 74 79 70 65 20 3d 20 50 45 4e 44 49 4e ocktype = PENDIN
64c0: 47 5f 4c 4f 43 4b 3b 0a 20 20 20 20 70 4c 6f 63 G_LOCK;. pLoc
64d0: 6b 2d 3e 6c 6f 63 6b 74 79 70 65 20 3d 20 50 45 k->locktype = PE
64e0: 4e 44 49 4e 47 5f 4c 4f 43 4b 3b 0a 20 20 7d 0a NDING_LOCK;. }.
64f0: 0a 65 6e 64 5f 6c 6f 63 6b 3a 0a 20 20 73 71 6c .end_lock:. sql
6500: 69 74 65 33 4f 73 4c 65 61 76 65 4d 75 74 65 78 ite3OsLeaveMutex
6510: 28 29 3b 0a 20 20 54 52 41 43 45 34 28 22 4c 4f ();. TRACE4("LO
6520: 43 4b 20 25 64 20 25 64 20 25 73 5c 6e 22 2c 20 CK %d %d %s\n",
6530: 69 64 2d 3e 68 2c 20 6c 6f 63 6b 74 79 70 65 2c id->h, locktype,
6540: 20 72 63 3d 3d 53 51 4c 49 54 45 5f 4f 4b 20 3f rc==SQLITE_OK ?
6550: 20 22 6f 6b 22 20 3a 20 22 66 61 69 6c 65 64 22 "ok" : "failed"
6560: 29 3b 0a 20 20 72 65 74 75 72 6e 20 72 63 3b 0a );. return rc;.
6570: 7d 0a 0a 2f 2a 0a 2a 2a 20 4c 6f 77 65 72 20 74 }../*.** Lower t
6580: 68 65 20 6c 6f 63 6b 69 6e 67 20 6c 65 76 65 6c he locking level
6590: 20 6f 6e 20 66 69 6c 65 20 64 65 73 63 72 69 70 on file descrip
65a0: 74 6f 72 20 69 64 20 74 6f 20 6c 6f 63 6b 74 79 tor id to lockty
65b0: 70 65 2e 20 20 6c 6f 63 6b 74 79 70 65 0a 2a 2a pe. locktype.**
65c0: 20 6d 75 73 74 20 62 65 20 65 69 74 68 65 72 20 must be either
65d0: 4e 4f 5f 4c 4f 43 4b 20 6f 72 20 53 48 41 52 45 NO_LOCK or SHARE
65e0: 44 5f 4c 4f 43 4b 2e 0a 2a 2a 0a 2a 2a 20 49 66 D_LOCK..**.** If
65f0: 20 74 68 65 20 6c 6f 63 6b 69 6e 67 20 6c 65 76 the locking lev
6600: 65 6c 20 6f 66 20 74 68 65 20 66 69 6c 65 20 64 el of the file d
6610: 65 73 63 72 69 70 74 6f 72 20 69 73 20 61 6c 72 escriptor is alr
6620: 65 61 64 79 20 61 74 20 6f 72 20 62 65 6c 6f 77 eady at or below
6630: 0a 2a 2a 20 74 68 65 20 72 65 71 75 65 73 74 65 .** the requeste
6640: 64 20 6c 6f 63 6b 69 6e 67 20 6c 65 76 65 6c 2c d locking level,
6650: 20 74 68 69 73 20 72 6f 75 74 69 6e 65 20 69 73 this routine is
6660: 20 61 20 6e 6f 2d 6f 70 2e 0a 2a 2a 0a 2a 2a 20 a no-op..**.**
6670: 49 74 20 69 73 20 6e 6f 74 20 70 6f 73 73 69 62 It is not possib
6680: 6c 65 20 66 6f 72 20 74 68 69 73 20 72 6f 75 74 le for this rout
6690: 69 6e 65 20 74 6f 20 66 61 69 6c 2e 0a 2a 2f 0a ine to fail..*/.
66a0: 69 6e 74 20 73 71 6c 69 74 65 33 4f 73 55 6e 6c int sqlite3OsUnl
66b0: 6f 63 6b 28 4f 73 46 69 6c 65 20 2a 69 64 2c 20 ock(OsFile *id,
66c0: 69 6e 74 20 6c 6f 63 6b 74 79 70 65 29 7b 0a 20 int locktype){.
66d0: 20 73 74 72 75 63 74 20 6c 6f 63 6b 49 6e 66 6f struct lockInfo
66e0: 20 2a 70 4c 6f 63 6b 3b 0a 20 20 73 74 72 75 63 *pLock;. struc
66f0: 74 20 66 6c 6f 63 6b 20 6c 6f 63 6b 3b 0a 0a 20 t flock lock;..
6700: 20 54 52 41 43 45 36 28 22 55 4e 4c 4f 43 4b 20 TRACE6("UNLOCK
6710: 25 64 20 25 64 20 77 61 73 20 25 64 28 25 64 2c %d %d was %d(%d,
6720: 25 64 29 5c 6e 22 2c 0a 20 20 20 20 20 20 20 20 %d)\n",.
6730: 20 20 69 64 2d 3e 68 2c 20 6c 6f 63 6b 74 79 70 id->h, locktyp
6740: 65 2c 20 69 64 2d 3e 6c 6f 63 6b 74 79 70 65 2c e, id->locktype,
6750: 20 69 64 2d 3e 70 4c 6f 63 6b 2d 3e 6c 6f 63 6b id->pLock->lock
6760: 74 79 70 65 2c 20 69 64 2d 3e 70 4c 6f 63 6b 2d type, id->pLock-
6770: 3e 63 6e 74 29 3b 0a 0a 20 20 61 73 73 65 72 74 >cnt);.. assert
6780: 28 20 6c 6f 63 6b 74 79 70 65 3c 3d 53 48 41 52 ( locktype<=SHAR
6790: 45 44 5f 4c 4f 43 4b 20 29 3b 0a 20 20 69 66 28 ED_LOCK );. if(
67a0: 20 69 64 2d 3e 6c 6f 63 6b 74 79 70 65 3c 3d 6c id->locktype<=l
67b0: 6f 63 6b 74 79 70 65 20 29 7b 0a 20 20 20 20 72 ocktype ){. r
67c0: 65 74 75 72 6e 20 53 51 4c 49 54 45 5f 4f 4b 3b eturn SQLITE_OK;
67d0: 0a 20 20 7d 0a 20 20 73 71 6c 69 74 65 33 4f 73 . }. sqlite3Os
67e0: 45 6e 74 65 72 4d 75 74 65 78 28 29 3b 0a 20 20 EnterMutex();.
67f0: 70 4c 6f 63 6b 20 3d 20 69 64 2d 3e 70 4c 6f 63 pLock = id->pLoc
6800: 6b 3b 0a 20 20 61 73 73 65 72 74 28 20 70 4c 6f k;. assert( pLo
6810: 63 6b 2d 3e 63 6e 74 21 3d 30 20 29 3b 0a 20 20 ck->cnt!=0 );.
6820: 69 66 28 20 69 64 2d 3e 6c 6f 63 6b 74 79 70 65 if( id->locktype
6830: 3e 53 48 41 52 45 44 5f 4c 4f 43 4b 20 29 7b 0a >SHARED_LOCK ){.
6840: 20 20 20 20 61 73 73 65 72 74 28 20 70 4c 6f 63 assert( pLoc
6850: 6b 2d 3e 6c 6f 63 6b 74 79 70 65 3d 3d 69 64 2d k->locktype==id-
6860: 3e 6c 6f 63 6b 74 79 70 65 20 29 3b 0a 20 20 20 >locktype );.
6870: 20 6c 6f 63 6b 2e 6c 5f 74 79 70 65 20 3d 20 46 lock.l_type = F
6880: 5f 55 4e 4c 43 4b 3b 0a 20 20 20 20 6c 6f 63 6b _UNLCK;. lock
6890: 2e 6c 5f 77 68 65 6e 63 65 20 3d 20 53 45 45 4b .l_whence = SEEK
68a0: 5f 53 45 54 3b 0a 20 20 20 20 6c 6f 63 6b 2e 6c _SET;. lock.l
68b0: 5f 73 74 61 72 74 20 3d 20 50 45 4e 44 49 4e 47 _start = PENDING
68c0: 5f 42 59 54 45 3b 0a 20 20 20 20 6c 6f 63 6b 2e _BYTE;. lock.
68d0: 6c 5f 6c 65 6e 20 3d 20 32 4c 3b 20 20 61 73 73 l_len = 2L; ass
68e0: 65 72 74 28 20 50 45 4e 44 49 4e 47 5f 42 59 54 ert( PENDING_BYT
68f0: 45 2b 31 3d 3d 52 45 53 45 52 56 45 44 5f 42 59 E+1==RESERVED_BY
6900: 54 45 20 29 3b 0a 20 20 20 20 66 63 6e 74 6c 28 TE );. fcntl(
6910: 69 64 2d 3e 68 2c 20 46 5f 53 45 54 4c 4b 2c 20 id->h, F_SETLK,
6920: 26 6c 6f 63 6b 29 3b 0a 20 20 20 20 70 4c 6f 63 &lock);. pLoc
6930: 6b 2d 3e 6c 6f 63 6b 74 79 70 65 20 3d 20 53 48 k->locktype = SH
6940: 41 52 45 44 5f 4c 4f 43 4b 3b 0a 20 20 7d 0a 20 ARED_LOCK;. }.
6950: 20 69 66 28 20 6c 6f 63 6b 74 79 70 65 3d 3d 4e if( locktype==N
6960: 4f 5f 4c 4f 43 4b 20 29 7b 0a 20 20 20 20 73 74 O_LOCK ){. st
6970: 72 75 63 74 20 6f 70 65 6e 43 6e 74 20 2a 70 4f ruct openCnt *pO
6980: 70 65 6e 3b 0a 0a 20 20 20 20 2f 2a 20 44 65 63 pen;.. /* Dec
6990: 72 65 6d 65 6e 74 20 74 68 65 20 73 68 61 72 65 rement the share
69a0: 64 20 6c 6f 63 6b 20 63 6f 75 6e 74 65 72 2e 20 d lock counter.
69b0: 20 52 65 6c 65 61 73 65 20 74 68 65 20 6c 6f 63 Release the loc
69c0: 6b 20 75 73 69 6e 67 20 61 6e 0a 20 20 20 20 2a k using an. *
69d0: 2a 20 4f 53 20 63 61 6c 6c 20 6f 6e 6c 79 20 77 * OS call only w
69e0: 68 65 6e 20 61 6c 6c 20 74 68 72 65 61 64 73 20 hen all threads
69f0: 69 6e 20 74 68 69 73 20 73 61 6d 65 20 70 72 6f in this same pro
6a00: 63 65 73 73 20 68 61 76 65 20 72 65 6c 65 61 73 cess have releas
6a10: 65 64 0a 20 20 20 20 2a 2a 20 74 68 65 20 6c 6f ed. ** the lo
6a20: 63 6b 2e 0a 20 20 20 20 2a 2f 0a 20 20 20 20 70 ck.. */. p
6a30: 4c 6f 63 6b 2d 3e 63 6e 74 2d 2d 3b 0a 20 20 20 Lock->cnt--;.
6a40: 20 69 66 28 20 70 4c 6f 63 6b 2d 3e 63 6e 74 3d if( pLock->cnt=
6a50: 3d 30 20 29 7b 0a 20 20 20 20 20 20 6c 6f 63 6b =0 ){. lock
6a60: 2e 6c 5f 74 79 70 65 20 3d 20 46 5f 55 4e 4c 43 .l_type = F_UNLC
6a70: 4b 3b 0a 20 20 20 20 20 20 6c 6f 63 6b 2e 6c 5f K;. lock.l_
6a80: 77 68 65 6e 63 65 20 3d 20 53 45 45 4b 5f 53 45 whence = SEEK_SE
6a90: 54 3b 0a 20 20 20 20 20 20 6c 6f 63 6b 2e 6c 5f T;. lock.l_
6aa0: 73 74 61 72 74 20 3d 20 6c 6f 63 6b 2e 6c 5f 6c start = lock.l_l
6ab0: 65 6e 20 3d 20 30 4c 3b 0a 20 20 20 20 20 20 66 en = 0L;. f
6ac0: 63 6e 74 6c 28 69 64 2d 3e 68 2c 20 46 5f 53 45 cntl(id->h, F_SE
6ad0: 54 4c 4b 2c 20 26 6c 6f 63 6b 29 3b 0a 20 20 20 TLK, &lock);.
6ae0: 20 20 20 70 4c 6f 63 6b 2d 3e 6c 6f 63 6b 74 79 pLock->lockty
6af0: 70 65 20 3d 20 4e 4f 5f 4c 4f 43 4b 3b 0a 20 20 pe = NO_LOCK;.
6b00: 20 20 7d 0a 0a 20 20 20 20 2f 2a 20 44 65 63 72 }.. /* Decr
6b10: 65 6d 65 6e 74 20 74 68 65 20 63 6f 75 6e 74 20 ement the count
6b20: 6f 66 20 6c 6f 63 6b 73 20 61 67 61 69 6e 73 74 of locks against
6b30: 20 74 68 69 73 20 73 61 6d 65 20 66 69 6c 65 2e this same file.
6b40: 20 20 57 68 65 6e 20 74 68 65 0a 20 20 20 20 2a When the. *
6b50: 2a 20 63 6f 75 6e 74 20 72 65 61 63 68 65 73 20 * count reaches
6b60: 7a 65 72 6f 2c 20 63 6c 6f 73 65 20 61 6e 79 20 zero, close any
6b70: 6f 74 68 65 72 20 66 69 6c 65 20 64 65 73 63 72 other file descr
6b80: 69 70 74 6f 72 73 20 77 68 6f 73 65 20 63 6c 6f iptors whose clo
6b90: 73 65 0a 20 20 20 20 2a 2a 20 77 61 73 20 64 65 se. ** was de
6ba0: 66 65 72 72 65 64 20 62 65 63 61 75 73 65 20 6f ferred because o
6bb0: 66 20 6f 75 74 73 74 61 6e 64 69 6e 67 20 6c 6f f outstanding lo
6bc0: 63 6b 73 2e 0a 20 20 20 20 2a 2f 0a 20 20 20 20 cks.. */.
6bd0: 70 4f 70 65 6e 20 3d 20 69 64 2d 3e 70 4f 70 65 pOpen = id->pOpe
6be0: 6e 3b 0a 20 20 20 20 70 4f 70 65 6e 2d 3e 6e 4c n;. pOpen->nL
6bf0: 6f 63 6b 2d 2d 3b 0a 20 20 20 20 61 73 73 65 72 ock--;. asser
6c00: 74 28 20 70 4f 70 65 6e 2d 3e 6e 4c 6f 63 6b 3e t( pOpen->nLock>
6c10: 3d 30 20 29 3b 0a 20 20 20 20 69 66 28 20 70 4f =0 );. if( pO
6c20: 70 65 6e 2d 3e 6e 4c 6f 63 6b 3d 3d 30 20 26 26 pen->nLock==0 &&
6c30: 20 70 4f 70 65 6e 2d 3e 6e 50 65 6e 64 69 6e 67 pOpen->nPending
6c40: 3e 30 20 29 7b 0a 20 20 20 20 20 20 69 6e 74 20 >0 ){. int
6c50: 69 3b 0a 20 20 20 20 20 20 66 6f 72 28 69 3d 30 i;. for(i=0
6c60: 3b 20 69 3c 70 4f 70 65 6e 2d 3e 6e 50 65 6e 64 ; i<pOpen->nPend
6c70: 69 6e 67 3b 20 69 2b 2b 29 7b 0a 20 20 20 20 20 ing; i++){.
6c80: 20 20 20 63 6c 6f 73 65 28 70 4f 70 65 6e 2d 3e close(pOpen->
6c90: 61 50 65 6e 64 69 6e 67 5b 69 5d 29 3b 0a 20 20 aPending[i]);.
6ca0: 20 20 20 20 7d 0a 20 20 20 20 20 20 73 71 6c 69 }. sqli
6cb0: 74 65 46 72 65 65 28 70 4f 70 65 6e 2d 3e 61 50 teFree(pOpen->aP
6cc0: 65 6e 64 69 6e 67 29 3b 0a 20 20 20 20 20 20 70 ending);. p
6cd0: 4f 70 65 6e 2d 3e 6e 50 65 6e 64 69 6e 67 20 3d Open->nPending =
6ce0: 20 30 3b 0a 20 20 20 20 20 20 70 4f 70 65 6e 2d 0;. pOpen-
6cf0: 3e 61 50 65 6e 64 69 6e 67 20 3d 20 30 3b 0a 20 >aPending = 0;.
6d00: 20 20 20 7d 0a 20 20 7d 0a 20 20 73 71 6c 69 74 }. }. sqlit
6d10: 65 33 4f 73 4c 65 61 76 65 4d 75 74 65 78 28 29 e3OsLeaveMutex()
6d20: 3b 0a 20 20 69 64 2d 3e 6c 6f 63 6b 74 79 70 65 ;. id->locktype
6d30: 20 3d 20 6c 6f 63 6b 74 79 70 65 3b 0a 20 20 72 = locktype;. r
6d40: 65 74 75 72 6e 20 53 51 4c 49 54 45 5f 4f 4b 3b eturn SQLITE_OK;
6d50: 0a 7d 0a 0a 2f 2a 0a 2a 2a 20 47 65 74 20 69 6e .}../*.** Get in
6d60: 66 6f 72 6d 61 74 69 6f 6e 20 74 6f 20 73 65 65 formation to see
6d70: 64 20 74 68 65 20 72 61 6e 64 6f 6d 20 6e 75 6d d the random num
6d80: 62 65 72 20 67 65 6e 65 72 61 74 6f 72 2e 20 20 ber generator.
6d90: 54 68 65 20 73 65 65 64 0a 2a 2a 20 69 73 20 77 The seed.** is w
6da0: 72 69 74 74 65 6e 20 69 6e 74 6f 20 74 68 65 20 ritten into the
6db0: 62 75 66 66 65 72 20 7a 42 75 66 5b 32 35 36 5d buffer zBuf[256]
6dc0: 2e 20 20 54 68 65 20 63 61 6c 6c 69 6e 67 20 66 . The calling f
6dd0: 75 6e 63 74 69 6f 6e 20 6d 75 73 74 0a 2a 2a 20 unction must.**
6de0: 73 75 70 70 6c 79 20 61 20 73 75 66 66 69 63 69 supply a suffici
6df0: 65 6e 74 6c 79 20 6c 61 72 67 65 20 62 75 66 66 ently large buff
6e00: 65 72 2e 0a 2a 2f 0a 69 6e 74 20 73 71 6c 69 74 er..*/.int sqlit
6e10: 65 33 4f 73 52 61 6e 64 6f 6d 53 65 65 64 28 63 e3OsRandomSeed(c
6e20: 68 61 72 20 2a 7a 42 75 66 29 7b 0a 20 20 2f 2a har *zBuf){. /*
6e30: 20 57 65 20 68 61 76 65 20 74 6f 20 69 6e 69 74 We have to init
6e40: 69 61 6c 69 7a 65 20 7a 42 75 66 20 74 6f 20 70 ialize zBuf to p
6e50: 72 65 76 65 6e 74 20 76 61 6c 67 72 69 6e 64 20 revent valgrind
6e60: 66 72 6f 6d 20 72 65 70 6f 72 74 69 6e 67 0a 20 from reporting.
6e70: 20 2a 2a 20 65 72 72 6f 72 73 2e 20 20 54 68 65 ** errors. The
6e80: 20 72 65 70 6f 72 74 73 20 69 73 73 75 65 64 20 reports issued
6e90: 62 79 20 76 61 6c 67 72 69 6e 64 20 61 72 65 20 by valgrind are
6ea0: 69 6e 63 6f 72 72 65 63 74 20 2d 20 77 65 20 77 incorrect - we w
6eb0: 6f 75 6c 64 0a 20 20 2a 2a 20 70 72 65 66 65 72 ould. ** prefer
6ec0: 20 74 68 61 74 20 74 68 65 20 72 61 6e 64 6f 6d that the random
6ed0: 6e 65 73 73 20 62 65 20 69 6e 63 72 65 61 73 65 ness be increase
6ee0: 64 20 62 79 20 6d 61 6b 69 6e 67 20 75 73 65 20 d by making use
6ef0: 6f 66 20 74 68 65 0a 20 20 2a 2a 20 75 6e 69 6e of the. ** unin
6f00: 69 74 69 61 6c 69 7a 65 64 20 73 70 61 63 65 20 itialized space
6f10: 69 6e 20 7a 42 75 66 20 2d 20 62 75 74 20 76 61 in zBuf - but va
6f20: 6c 67 72 69 6e 64 20 65 72 72 6f 72 73 20 74 65 lgrind errors te
6f30: 6e 64 20 74 6f 20 77 6f 72 72 79 0a 20 20 2a 2a nd to worry. **
6f40: 20 73 6f 6d 65 20 75 73 65 72 73 2e 20 20 52 61 some users. Ra
6f50: 74 68 65 72 20 74 68 61 6e 20 61 72 67 75 65 2c ther than argue,
6f60: 20 69 74 20 73 65 65 6d 73 20 65 61 73 69 65 72 it seems easier
6f70: 20 6a 75 73 74 20 74 6f 20 69 6e 69 74 69 61 6c just to initial
6f80: 69 7a 65 0a 20 20 2a 2a 20 74 68 65 20 77 68 6f ize. ** the who
6f90: 6c 65 20 61 72 72 61 79 20 61 6e 64 20 73 69 6c le array and sil
6fa0: 65 6e 63 65 20 76 61 6c 67 72 69 6e 64 2c 20 65 ence valgrind, e
6fb0: 76 65 6e 20 69 66 20 74 68 61 74 20 6d 65 61 6e ven if that mean
6fc0: 73 20 6c 65 73 73 20 72 61 6e 64 6f 6d 6e 65 73 s less randomnes
6fd0: 73 0a 20 20 2a 2a 20 69 6e 20 74 68 65 20 72 61 s. ** in the ra
6fe0: 6e 64 6f 6d 20 73 65 65 64 2e 0a 20 20 2a 2a 0a ndom seed.. **.
6ff0: 20 20 2a 2a 20 57 68 65 6e 20 74 65 73 74 69 6e ** When testin
7000: 67 2c 20 69 6e 69 74 69 61 6c 69 7a 69 6e 67 20 g, initializing
7010: 7a 42 75 66 5b 5d 20 74 6f 20 7a 65 72 6f 20 69 zBuf[] to zero i
7020: 73 20 61 6c 6c 20 77 65 20 64 6f 2e 20 20 54 68 s all we do. Th
7030: 61 74 20 6d 65 61 6e 73 0a 20 20 2a 2a 20 74 68 at means. ** th
7040: 61 74 20 77 65 20 61 6c 77 61 79 73 20 75 73 65 at we always use
7050: 20 74 68 65 20 73 61 6d 65 20 72 61 6e 64 6f 6d the same random
7060: 20 6e 75 6d 62 65 72 20 73 65 71 75 65 6e 63 65 number sequence
7070: 2e 2a 20 54 68 69 73 20 6d 61 6b 65 73 20 74 68 .* This makes th
7080: 65 0a 20 20 2a 2a 20 74 65 73 74 73 20 72 65 70 e. ** tests rep
7090: 65 61 74 61 62 6c 65 2e 0a 20 20 2a 2f 0a 20 20 eatable.. */.
70a0: 6d 65 6d 73 65 74 28 7a 42 75 66 2c 20 30 2c 20 memset(zBuf, 0,
70b0: 32 35 36 29 3b 0a 23 69 66 20 21 64 65 66 69 6e 256);.#if !defin
70c0: 65 64 28 53 51 4c 49 54 45 5f 54 45 53 54 29 0a ed(SQLITE_TEST).
70d0: 20 20 7b 0a 20 20 20 20 69 6e 74 20 70 69 64 3b {. int pid;
70e0: 0a 20 20 20 20 74 69 6d 65 28 28 74 69 6d 65 5f . time((time_
70f0: 74 2a 29 7a 42 75 66 29 3b 0a 20 20 20 20 70 69 t*)zBuf);. pi
7100: 64 20 3d 20 67 65 74 70 69 64 28 29 3b 0a 20 20 d = getpid();.
7110: 20 20 6d 65 6d 63 70 79 28 26 7a 42 75 66 5b 73 memcpy(&zBuf[s
7120: 69 7a 65 6f 66 28 74 69 6d 65 5f 74 29 5d 2c 20 izeof(time_t)],
7130: 26 70 69 64 2c 20 73 69 7a 65 6f 66 28 70 69 64 &pid, sizeof(pid
7140: 29 29 3b 0a 20 20 7d 0a 23 65 6e 64 69 66 0a 20 ));. }.#endif.
7150: 20 72 65 74 75 72 6e 20 53 51 4c 49 54 45 5f 4f return SQLITE_O
7160: 4b 3b 0a 7d 0a 0a 2f 2a 0a 2a 2a 20 53 6c 65 65 K;.}../*.** Slee
7170: 70 20 66 6f 72 20 61 20 6c 69 74 74 6c 65 20 77 p for a little w
7180: 68 69 6c 65 2e 20 20 52 65 74 75 72 6e 20 74 68 hile. Return th
7190: 65 20 61 6d 6f 75 6e 74 20 6f 66 20 74 69 6d 65 e amount of time
71a0: 20 73 6c 65 70 74 2e 0a 2a 2f 0a 69 6e 74 20 73 slept..*/.int s
71b0: 71 6c 69 74 65 33 4f 73 53 6c 65 65 70 28 69 6e qlite3OsSleep(in
71c0: 74 20 6d 73 29 7b 0a 23 69 66 20 64 65 66 69 6e t ms){.#if defin
71d0: 65 64 28 48 41 56 45 5f 55 53 4c 45 45 50 29 20 ed(HAVE_USLEEP)
71e0: 26 26 20 48 41 56 45 5f 55 53 4c 45 45 50 0a 20 && HAVE_USLEEP.
71f0: 20 75 73 6c 65 65 70 28 6d 73 2a 31 30 30 30 29 usleep(ms*1000)
7200: 3b 0a 20 20 72 65 74 75 72 6e 20 6d 73 3b 0a 23 ;. return ms;.#
7210: 65 6c 73 65 0a 20 20 73 6c 65 65 70 28 28 6d 73 else. sleep((ms
7220: 2b 39 39 39 29 2f 31 30 30 30 29 3b 0a 20 20 72 +999)/1000);. r
7230: 65 74 75 72 6e 20 31 30 30 30 2a 28 28 6d 73 2b eturn 1000*((ms+
7240: 39 39 39 29 2f 31 30 30 30 29 3b 0a 23 65 6e 64 999)/1000);.#end
7250: 69 66 0a 7d 0a 0a 2f 2a 0a 2a 2a 20 53 74 61 74 if.}../*.** Stat
7260: 69 63 20 76 61 72 69 61 62 6c 65 73 20 75 73 65 ic variables use
7270: 64 20 66 6f 72 20 74 68 72 65 61 64 20 73 79 6e d for thread syn
7280: 63 68 72 6f 6e 69 7a 61 74 69 6f 6e 0a 2a 2f 0a chronization.*/.
7290: 73 74 61 74 69 63 20 69 6e 74 20 69 6e 4d 75 74 static int inMut
72a0: 65 78 20 3d 20 30 3b 0a 23 69 66 64 65 66 20 53 ex = 0;.#ifdef S
72b0: 51 4c 49 54 45 5f 55 4e 49 58 5f 54 48 52 45 41 QLITE_UNIX_THREA
72c0: 44 53 0a 73 74 61 74 69 63 20 70 74 68 72 65 61 DS.static pthrea
72d0: 64 5f 6d 75 74 65 78 5f 74 20 6d 75 74 65 78 20 d_mutex_t mutex
72e0: 3d 20 50 54 48 52 45 41 44 5f 4d 55 54 45 58 5f = PTHREAD_MUTEX_
72f0: 49 4e 49 54 49 41 4c 49 5a 45 52 3b 0a 23 65 6e INITIALIZER;.#en
7300: 64 69 66 0a 0a 2f 2a 0a 2a 2a 20 54 68 65 20 66 dif../*.** The f
7310: 6f 6c 6c 6f 77 69 6e 67 20 70 61 69 72 20 6f 66 ollowing pair of
7320: 20 72 6f 75 74 69 6e 65 20 69 6d 70 6c 65 6d 65 routine impleme
7330: 6e 74 20 6d 75 74 75 61 6c 20 65 78 63 6c 75 73 nt mutual exclus
7340: 69 6f 6e 20 66 6f 72 0a 2a 2a 20 6d 75 6c 74 69 ion for.** multi
7350: 2d 74 68 72 65 61 64 65 64 20 70 72 6f 63 65 73 -threaded proces
7360: 73 65 73 2e 20 20 4f 6e 6c 79 20 61 20 73 69 6e ses. Only a sin
7370: 67 6c 65 20 74 68 72 65 61 64 20 69 73 20 61 6c gle thread is al
7380: 6c 6f 77 65 64 20 74 6f 0a 2a 2a 20 65 78 65 63 lowed to.** exec
7390: 75 74 65 64 20 63 6f 64 65 20 74 68 61 74 20 69 uted code that i
73a0: 73 20 73 75 72 72 6f 75 6e 64 65 64 20 62 79 20 s surrounded by
73b0: 45 6e 74 65 72 4d 75 74 65 78 28 29 20 61 6e 64 EnterMutex() and
73c0: 20 4c 65 61 76 65 4d 75 74 65 78 28 29 2e 0a 2a LeaveMutex()..*
73d0: 2a 0a 2a 2a 20 53 51 4c 69 74 65 20 75 73 65 73 *.** SQLite uses
73e0: 20 6f 6e 6c 79 20 61 20 73 69 6e 67 6c 65 20 4d only a single M
73f0: 75 74 65 78 2e 20 20 54 68 65 72 65 20 69 73 20 utex. There is
7400: 6e 6f 74 20 6d 75 63 68 20 63 72 69 74 69 63 61 not much critica
7410: 6c 0a 2a 2a 20 63 6f 64 65 20 61 6e 64 20 77 68 l.** code and wh
7420: 61 74 20 6c 69 74 74 6c 65 20 74 68 65 72 65 20 at little there
7430: 69 73 20 65 78 65 63 75 74 65 73 20 71 75 69 63 is executes quic
7440: 6b 6c 79 20 61 6e 64 20 77 69 74 68 6f 75 74 20 kly and without
7450: 62 6c 6f 63 6b 69 6e 67 2e 0a 2a 2f 0a 76 6f 69 blocking..*/.voi
7460: 64 20 73 71 6c 69 74 65 33 4f 73 45 6e 74 65 72 d sqlite3OsEnter
7470: 4d 75 74 65 78 28 29 7b 0a 23 69 66 64 65 66 20 Mutex(){.#ifdef
7480: 53 51 4c 49 54 45 5f 55 4e 49 58 5f 54 48 52 45 SQLITE_UNIX_THRE
7490: 41 44 53 0a 20 20 70 74 68 72 65 61 64 5f 6d 75 ADS. pthread_mu
74a0: 74 65 78 5f 6c 6f 63 6b 28 26 6d 75 74 65 78 29 tex_lock(&mutex)
74b0: 3b 0a 23 65 6e 64 69 66 0a 20 20 61 73 73 65 72 ;.#endif. asser
74c0: 74 28 20 21 69 6e 4d 75 74 65 78 20 29 3b 0a 20 t( !inMutex );.
74d0: 20 69 6e 4d 75 74 65 78 20 3d 20 31 3b 0a 7d 0a inMutex = 1;.}.
74e0: 76 6f 69 64 20 73 71 6c 69 74 65 33 4f 73 4c 65 void sqlite3OsLe
74f0: 61 76 65 4d 75 74 65 78 28 29 7b 0a 20 20 61 73 aveMutex(){. as
7500: 73 65 72 74 28 20 69 6e 4d 75 74 65 78 20 29 3b sert( inMutex );
7510: 0a 20 20 69 6e 4d 75 74 65 78 20 3d 20 30 3b 0a . inMutex = 0;.
7520: 23 69 66 64 65 66 20 53 51 4c 49 54 45 5f 55 4e #ifdef SQLITE_UN
7530: 49 58 5f 54 48 52 45 41 44 53 0a 20 20 70 74 68 IX_THREADS. pth
7540: 72 65 61 64 5f 6d 75 74 65 78 5f 75 6e 6c 6f 63 read_mutex_unloc
7550: 6b 28 26 6d 75 74 65 78 29 3b 0a 23 65 6e 64 69 k(&mutex);.#endi
7560: 66 0a 7d 0a 0a 2f 2a 0a 2a 2a 20 54 75 72 6e 20 f.}../*.** Turn
7570: 61 20 72 65 6c 61 74 69 76 65 20 70 61 74 68 6e a relative pathn
7580: 61 6d 65 20 69 6e 74 6f 20 61 20 66 75 6c 6c 20 ame into a full
7590: 70 61 74 68 6e 61 6d 65 2e 20 20 52 65 74 75 72 pathname. Retur
75a0: 6e 20 61 20 70 6f 69 6e 74 65 72 0a 2a 2a 20 74 n a pointer.** t
75b0: 6f 20 74 68 65 20 66 75 6c 6c 20 70 61 74 68 6e o the full pathn
75c0: 61 6d 65 20 73 74 6f 72 65 64 20 69 6e 20 73 70 ame stored in sp
75d0: 61 63 65 20 6f 62 74 61 69 6e 65 64 20 66 72 6f ace obtained fro
75e0: 6d 20 73 71 6c 69 74 65 4d 61 6c 6c 6f 63 28 29 m sqliteMalloc()
75f0: 2e 0a 2a 2a 20 54 68 65 20 63 61 6c 6c 69 6e 67 ..** The calling
7600: 20 66 75 6e 63 74 69 6f 6e 20 69 73 20 72 65 73 function is res
7610: 70 6f 6e 73 69 62 6c 65 20 66 6f 72 20 66 72 65 ponsible for fre
7620: 65 69 6e 67 20 74 68 69 73 20 73 70 61 63 65 20 eing this space
7630: 6f 6e 63 65 20 69 74 0a 2a 2a 20 69 73 20 6e 6f once it.** is no
7640: 20 6c 6f 6e 67 65 72 20 6e 65 65 64 65 64 2e 0a longer needed..
7650: 2a 2f 0a 63 68 61 72 20 2a 73 71 6c 69 74 65 33 */.char *sqlite3
7660: 4f 73 46 75 6c 6c 50 61 74 68 6e 61 6d 65 28 63 OsFullPathname(c
7670: 6f 6e 73 74 20 63 68 61 72 20 2a 7a 52 65 6c 61 onst char *zRela
7680: 74 69 76 65 29 7b 0a 20 20 63 68 61 72 20 2a 7a tive){. char *z
7690: 46 75 6c 6c 20 3d 20 30 3b 0a 20 20 69 66 28 20 Full = 0;. if(
76a0: 7a 52 65 6c 61 74 69 76 65 5b 30 5d 3d 3d 27 2f zRelative[0]=='/
76b0: 27 20 29 7b 0a 20 20 20 20 73 71 6c 69 74 65 33 ' ){. sqlite3
76c0: 53 65 74 53 74 72 69 6e 67 28 26 7a 46 75 6c 6c SetString(&zFull
76d0: 2c 20 7a 52 65 6c 61 74 69 76 65 2c 20 28 63 68 , zRelative, (ch
76e0: 61 72 2a 29 30 29 3b 0a 20 20 7d 65 6c 73 65 7b ar*)0);. }else{
76f0: 0a 20 20 20 20 63 68 61 72 20 7a 42 75 66 5b 35 . char zBuf[5
7700: 30 30 30 5d 3b 0a 20 20 20 20 73 71 6c 69 74 65 000];. sqlite
7710: 33 53 65 74 53 74 72 69 6e 67 28 26 7a 46 75 6c 3SetString(&zFul
7720: 6c 2c 20 67 65 74 63 77 64 28 7a 42 75 66 2c 20 l, getcwd(zBuf,
7730: 73 69 7a 65 6f 66 28 7a 42 75 66 29 29 2c 20 22 sizeof(zBuf)), "
7740: 2f 22 2c 20 7a 52 65 6c 61 74 69 76 65 2c 0a 20 /", zRelative,.
7750: 20 20 20 20 20 20 20 20 20 20 20 20 20 20 20 20
7760: 20 20 20 28 63 68 61 72 2a 29 30 29 3b 0a 20 20 (char*)0);.
7770: 7d 0a 20 20 72 65 74 75 72 6e 20 7a 46 75 6c 6c }. return zFull
7780: 3b 0a 7d 0a 0a 2f 2a 0a 2a 2a 20 54 68 65 20 66 ;.}../*.** The f
7790: 6f 6c 6c 6f 77 69 6e 67 20 76 61 72 69 61 62 6c ollowing variabl
77a0: 65 2c 20 69 66 20 73 65 74 20 74 6f 20 61 20 6e e, if set to a n
77b0: 6f 6e 2d 7a 65 72 6f 20 76 61 6c 75 65 2c 20 62 on-zero value, b
77c0: 65 63 6f 6d 65 73 20 74 68 65 20 72 65 73 75 6c ecomes the resul
77d0: 74 0a 2a 2a 20 72 65 74 75 72 6e 65 64 20 66 72 t.** returned fr
77e0: 6f 6d 20 73 71 6c 69 74 65 33 4f 73 43 75 72 72 om sqlite3OsCurr
77f0: 65 6e 74 54 69 6d 65 28 29 2e 20 20 54 68 69 73 entTime(). This
7800: 20 69 73 20 75 73 65 64 20 66 6f 72 20 74 65 73 is used for tes
7810: 74 69 6e 67 2e 0a 2a 2f 0a 23 69 66 64 65 66 20 ting..*/.#ifdef
7820: 53 51 4c 49 54 45 5f 54 45 53 54 0a 69 6e 74 20 SQLITE_TEST.int
7830: 73 71 6c 69 74 65 33 5f 63 75 72 72 65 6e 74 5f sqlite3_current_
7840: 74 69 6d 65 20 3d 20 30 3b 0a 23 65 6e 64 69 66 time = 0;.#endif
7850: 0a 0a 2f 2a 0a 2a 2a 20 46 69 6e 64 20 74 68 65 ../*.** Find the
7860: 20 63 75 72 72 65 6e 74 20 74 69 6d 65 20 28 69 current time (i
7870: 6e 20 55 6e 69 76 65 72 73 61 6c 20 43 6f 6f 72 n Universal Coor
7880: 64 69 6e 61 74 65 64 20 54 69 6d 65 29 2e 20 20 dinated Time).
7890: 57 72 69 74 65 20 74 68 65 0a 2a 2a 20 63 75 72 Write the.** cur
78a0: 72 65 6e 74 20 74 69 6d 65 20 61 6e 64 20 64 61 rent time and da
78b0: 74 65 20 61 73 20 61 20 4a 75 6c 69 61 6e 20 44 te as a Julian D
78c0: 61 79 20 6e 75 6d 62 65 72 20 69 6e 74 6f 20 2a ay number into *
78d0: 70 72 4e 6f 77 20 61 6e 64 0a 2a 2a 20 72 65 74 prNow and.** ret
78e0: 75 72 6e 20 30 2e 20 20 52 65 74 75 72 6e 20 31 urn 0. Return 1
78f0: 20 69 66 20 74 68 65 20 74 69 6d 65 20 61 6e 64 if the time and
7900: 20 64 61 74 65 20 63 61 6e 6e 6f 74 20 62 65 20 date cannot be
7910: 66 6f 75 6e 64 2e 0a 2a 2f 0a 69 6e 74 20 73 71 found..*/.int sq
7920: 6c 69 74 65 33 4f 73 43 75 72 72 65 6e 74 54 69 lite3OsCurrentTi
7930: 6d 65 28 64 6f 75 62 6c 65 20 2a 70 72 4e 6f 77 me(double *prNow
7940: 29 7b 0a 20 20 74 69 6d 65 5f 74 20 74 3b 0a 20 ){. time_t t;.
7950: 20 74 69 6d 65 28 26 74 29 3b 0a 20 20 2a 70 72 time(&t);. *pr
7960: 4e 6f 77 20 3d 20 74 2f 38 36 34 30 30 2e 30 20 Now = t/86400.0
7970: 2b 20 32 34 34 30 35 38 37 2e 35 3b 0a 23 69 66 + 2440587.5;.#if
7980: 64 65 66 20 53 51 4c 49 54 45 5f 54 45 53 54 0a def SQLITE_TEST.
7990: 20 20 69 66 28 20 73 71 6c 69 74 65 33 5f 63 75 if( sqlite3_cu
79a0: 72 72 65 6e 74 5f 74 69 6d 65 20 29 7b 0a 20 20 rrent_time ){.
79b0: 20 20 2a 70 72 4e 6f 77 20 3d 20 73 71 6c 69 74 *prNow = sqlit
79c0: 65 33 5f 63 75 72 72 65 6e 74 5f 74 69 6d 65 2f e3_current_time/
79d0: 38 36 34 30 30 2e 30 20 2b 20 32 34 34 30 35 38 86400.0 + 244058
79e0: 37 2e 35 3b 0a 20 20 7d 0a 23 65 6e 64 69 66 0a 7.5;. }.#endif.
79f0: 20 20 72 65 74 75 72 6e 20 30 3b 0a 7d 0a 0a 23 return 0;.}..#
7a00: 65 6e 64 69 66 20 2f 2a 20 4f 53 5f 55 4e 49 58 endif /* OS_UNIX
7a10: 20 2a 2f 0a */.