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 54 72 75 6e 63 61 74 65 20 61 6e 20 6f 70 * Truncate an op
4ca0: 65 6e 20 66 69 6c 65 20 74 6f 20 61 20 73 70 65 en file to a spe
4cb0: 63 69 66 69 65 64 20 73 69 7a 65 0a 2a 2f 0a 69 cified size.*/.i
4cc0: 6e 74 20 73 71 6c 69 74 65 33 4f 73 54 72 75 6e nt sqlite3OsTrun
4cd0: 63 61 74 65 28 4f 73 46 69 6c 65 20 2a 69 64 2c cate(OsFile *id,
4ce0: 20 6f 66 66 5f 74 20 6e 42 79 74 65 29 7b 0a 20 off_t nByte){.
4cf0: 20 53 69 6d 75 6c 61 74 65 49 4f 45 72 72 6f 72 SimulateIOError
4d00: 28 53 51 4c 49 54 45 5f 49 4f 45 52 52 29 3b 0a (SQLITE_IOERR);.
4d10: 20 20 72 65 74 75 72 6e 20 66 74 72 75 6e 63 61 return ftrunca
4d20: 74 65 28 69 64 2d 3e 68 2c 20 6e 42 79 74 65 29 te(id->h, nByte)
4d30: 3d 3d 30 20 3f 20 53 51 4c 49 54 45 5f 4f 4b 20 ==0 ? SQLITE_OK
4d40: 3a 20 53 51 4c 49 54 45 5f 49 4f 45 52 52 3b 0a : SQLITE_IOERR;.
4d50: 7d 0a 0a 2f 2a 0a 2a 2a 20 44 65 74 65 72 6d 69 }../*.** Determi
4d60: 6e 65 20 74 68 65 20 63 75 72 72 65 6e 74 20 73 ne the current s
4d70: 69 7a 65 20 6f 66 20 61 20 66 69 6c 65 20 69 6e ize of a file in
4d80: 20 62 79 74 65 73 0a 2a 2f 0a 69 6e 74 20 73 71 bytes.*/.int sq
4d90: 6c 69 74 65 33 4f 73 46 69 6c 65 53 69 7a 65 28 lite3OsFileSize(
4da0: 4f 73 46 69 6c 65 20 2a 69 64 2c 20 6f 66 66 5f OsFile *id, off_
4db0: 74 20 2a 70 53 69 7a 65 29 7b 0a 20 20 73 74 72 t *pSize){. str
4dc0: 75 63 74 20 73 74 61 74 20 62 75 66 3b 0a 20 20 uct stat buf;.
4dd0: 53 69 6d 75 6c 61 74 65 49 4f 45 72 72 6f 72 28 SimulateIOError(
4de0: 53 51 4c 49 54 45 5f 49 4f 45 52 52 29 3b 0a 20 SQLITE_IOERR);.
4df0: 20 69 66 28 20 66 73 74 61 74 28 69 64 2d 3e 68 if( fstat(id->h
4e00: 2c 20 26 62 75 66 29 21 3d 30 20 29 7b 0a 20 20 , &buf)!=0 ){.
4e10: 20 20 72 65 74 75 72 6e 20 53 51 4c 49 54 45 5f return SQLITE_
4e20: 49 4f 45 52 52 3b 0a 20 20 7d 0a 20 20 2a 70 53 IOERR;. }. *pS
4e30: 69 7a 65 20 3d 20 62 75 66 2e 73 74 5f 73 69 7a ize = buf.st_siz
4e40: 65 3b 0a 20 20 72 65 74 75 72 6e 20 53 51 4c 49 e;. return SQLI
4e50: 54 45 5f 4f 4b 3b 0a 7d 0a 0a 2f 2a 0a 2a 2a 20 TE_OK;.}../*.**
4e60: 54 68 69 73 20 72 6f 75 74 69 6e 65 20 63 68 65 This routine che
4e70: 63 6b 73 20 69 66 20 74 68 65 72 65 20 69 73 20 cks if there is
4e80: 61 20 52 45 53 45 52 56 45 44 20 6c 6f 63 6b 20 a RESERVED lock
4e90: 68 65 6c 64 20 6f 6e 20 74 68 65 20 73 70 65 63 held on the spec
4ea0: 69 66 69 65 64 0a 2a 2a 20 66 69 6c 65 20 62 79 ified.** file by
4eb0: 20 74 68 69 73 20 6f 72 20 61 6e 79 20 6f 74 68 this or any oth
4ec0: 65 72 20 70 72 6f 63 65 73 73 2e 20 49 66 20 73 er process. If s
4ed0: 75 63 68 20 61 20 6c 6f 63 6b 20 69 73 20 68 65 uch a lock is he
4ee0: 6c 64 2c 20 72 65 74 75 72 6e 0a 2a 2a 20 6e 6f ld, return.** no
4ef0: 6e 2d 7a 65 72 6f 2e 20 20 49 66 20 74 68 65 20 n-zero. If the
4f00: 66 69 6c 65 20 69 73 20 75 6e 6c 6f 63 6b 65 64 file is unlocked
4f10: 20 6f 72 20 68 6f 6c 64 73 20 6f 6e 6c 79 20 53 or holds only S
4f20: 48 41 52 45 44 20 6c 6f 63 6b 73 2c 20 74 68 65 HARED locks, the
4f30: 6e 0a 2a 2a 20 72 65 74 75 72 6e 20 7a 65 72 6f n.** return zero
4f40: 2e 0a 2a 2f 0a 69 6e 74 20 73 71 6c 69 74 65 33 ..*/.int sqlite3
4f50: 4f 73 43 68 65 63 6b 52 65 73 65 72 76 65 64 4c OsCheckReservedL
4f60: 6f 63 6b 28 4f 73 46 69 6c 65 20 2a 69 64 29 7b ock(OsFile *id){
4f70: 0a 20 20 69 6e 74 20 72 20 3d 20 30 3b 0a 0a 20 . int r = 0;..
4f80: 20 73 71 6c 69 74 65 33 4f 73 45 6e 74 65 72 4d sqlite3OsEnterM
4f90: 75 74 65 78 28 29 3b 20 2f 2a 20 4e 65 65 64 65 utex(); /* Neede
4fa0: 64 20 62 65 63 61 75 73 65 20 69 64 2d 3e 70 4c d because id->pL
4fb0: 6f 63 6b 20 69 73 20 73 68 61 72 65 64 20 61 63 ock is shared ac
4fc0: 72 6f 73 73 20 74 68 72 65 61 64 73 20 2a 2f 0a ross threads */.
4fd0: 0a 20 20 2f 2a 20 43 68 65 63 6b 20 69 66 20 61 . /* Check if a
4fe0: 20 74 68 72 65 61 64 20 69 6e 20 74 68 69 73 20 thread in this
4ff0: 70 72 6f 63 65 73 73 20 68 6f 6c 64 73 20 73 75 process holds su
5000: 63 68 20 61 20 6c 6f 63 6b 20 2a 2f 0a 20 20 69 ch a lock */. i
5010: 66 28 20 69 64 2d 3e 70 4c 6f 63 6b 2d 3e 6c 6f f( id->pLock->lo
5020: 63 6b 74 79 70 65 3e 53 48 41 52 45 44 5f 4c 4f cktype>SHARED_LO
5030: 43 4b 20 29 7b 0a 20 20 20 20 72 20 3d 20 31 3b CK ){. r = 1;
5040: 0a 20 20 7d 0a 0a 20 20 2f 2a 20 4f 74 68 65 72 . }.. /* Other
5050: 77 69 73 65 20 73 65 65 20 69 66 20 73 6f 6d 65 wise see if some
5060: 20 6f 74 68 65 72 20 70 72 6f 63 65 73 73 20 68 other process h
5070: 6f 6c 64 73 20 69 74 2e 0a 20 20 2a 2f 0a 20 20 olds it.. */.
5080: 69 66 28 20 21 72 20 29 7b 0a 20 20 20 20 73 74 if( !r ){. st
5090: 72 75 63 74 20 66 6c 6f 63 6b 20 6c 6f 63 6b 3b ruct flock lock;
50a0: 0a 20 20 20 20 6c 6f 63 6b 2e 6c 5f 77 68 65 6e . lock.l_when
50b0: 63 65 20 3d 20 53 45 45 4b 5f 53 45 54 3b 0a 20 ce = SEEK_SET;.
50c0: 20 20 20 6c 6f 63 6b 2e 6c 5f 73 74 61 72 74 20 lock.l_start
50d0: 3d 20 52 45 53 45 52 56 45 44 5f 42 59 54 45 3b = RESERVED_BYTE;
50e0: 0a 20 20 20 20 6c 6f 63 6b 2e 6c 5f 6c 65 6e 20 . lock.l_len
50f0: 3d 20 31 3b 0a 20 20 20 20 6c 6f 63 6b 2e 6c 5f = 1;. lock.l_
5100: 74 79 70 65 20 3d 20 46 5f 57 52 4c 43 4b 3b 0a type = F_WRLCK;.
5110: 20 20 20 20 66 63 6e 74 6c 28 69 64 2d 3e 68 2c fcntl(id->h,
5120: 20 46 5f 47 45 54 4c 4b 2c 20 26 6c 6f 63 6b 29 F_GETLK, &lock)
5130: 3b 0a 20 20 20 20 69 66 28 20 6c 6f 63 6b 2e 6c ;. if( lock.l
5140: 5f 74 79 70 65 21 3d 46 5f 55 4e 4c 43 4b 20 29 _type!=F_UNLCK )
5150: 7b 0a 20 20 20 20 20 20 72 20 3d 20 31 3b 0a 20 {. r = 1;.
5160: 20 20 20 7d 0a 20 20 7d 0a 20 20 0a 20 20 73 71 }. }. . sq
5170: 6c 69 74 65 33 4f 73 4c 65 61 76 65 4d 75 74 65 lite3OsLeaveMute
5180: 78 28 29 3b 0a 20 20 54 52 41 43 45 33 28 22 54 x();. TRACE3("T
5190: 45 53 54 20 57 52 2d 4c 4f 43 4b 20 25 64 20 25 EST WR-LOCK %d %
51a0: 64 5c 6e 22 2c 20 69 64 2d 3e 68 2c 20 72 29 3b d\n", id->h, r);
51b0: 0a 0a 20 20 72 65 74 75 72 6e 20 72 3b 0a 7d 0a .. return r;.}.
51c0: 0a 2f 2a 0a 2a 2a 20 4c 6f 63 6b 20 74 68 65 20 ./*.** Lock the
51d0: 66 69 6c 65 20 77 69 74 68 20 74 68 65 20 6c 6f file with the lo
51e0: 63 6b 20 73 70 65 63 69 66 69 65 64 20 62 79 20 ck specified by
51f0: 70 61 72 61 6d 65 74 65 72 20 6c 6f 63 6b 74 79 parameter lockty
5200: 70 65 20 2d 20 6f 6e 65 0a 2a 2a 20 6f 66 20 74 pe - one.** of t
5210: 68 65 20 66 6f 6c 6c 6f 77 69 6e 67 3a 0a 2a 2a he following:.**
5220: 0a 2a 2a 20 20 20 20 20 28 31 29 20 53 48 41 52 .** (1) SHAR
5230: 45 44 5f 4c 4f 43 4b 0a 2a 2a 20 20 20 20 20 28 ED_LOCK.** (
5240: 32 29 20 52 45 53 45 52 56 45 44 5f 4c 4f 43 4b 2) RESERVED_LOCK
5250: 0a 2a 2a 20 20 20 20 20 28 33 29 20 50 45 4e 44 .** (3) PEND
5260: 49 4e 47 5f 4c 4f 43 4b 0a 2a 2a 20 20 20 20 20 ING_LOCK.**
5270: 28 34 29 20 45 58 43 4c 55 53 49 56 45 5f 4c 4f (4) EXCLUSIVE_LO
5280: 43 4b 0a 2a 2a 0a 2a 2a 20 53 6f 6d 65 74 69 6d CK.**.** Sometim
5290: 65 73 20 77 68 65 6e 20 72 65 71 75 65 73 74 69 es when requesti
52a0: 6e 67 20 6f 6e 65 20 6c 6f 63 6b 20 73 74 61 74 ng one lock stat
52b0: 65 2c 20 61 64 64 69 74 69 6f 6e 61 6c 20 6c 6f e, additional lo
52c0: 63 6b 20 73 74 61 74 65 73 0a 2a 2a 20 61 72 65 ck states.** are
52d0: 20 69 6e 73 65 72 74 65 64 20 69 6e 20 62 65 74 inserted in bet
52e0: 77 65 65 6e 2e 20 20 54 68 65 20 6c 6f 63 6b 69 ween. The locki
52f0: 6e 67 20 6d 69 67 68 74 20 66 61 69 6c 20 6f 6e ng might fail on
5300: 20 6f 6e 65 20 6f 66 20 74 68 65 20 6c 61 74 65 one of the late
5310: 72 0a 2a 2a 20 74 72 61 6e 73 69 74 69 6f 6e 73 r.** transitions
5320: 20 6c 65 61 76 69 6e 67 20 74 68 65 20 6c 6f 63 leaving the loc
5330: 6b 20 73 74 61 74 65 20 64 69 66 66 65 72 65 6e k state differen
5340: 74 20 66 72 6f 6d 20 77 68 61 74 20 69 74 20 73 t from what it s
5350: 74 61 72 74 65 64 20 62 75 74 0a 2a 2a 20 73 74 tarted but.** st
5360: 69 6c 6c 20 73 68 6f 72 74 20 6f 66 20 69 74 73 ill short of its
5370: 20 67 6f 61 6c 2e 20 20 54 68 65 20 66 6f 6c 6c goal. The foll
5380: 6f 77 69 6e 67 20 63 68 61 72 74 20 73 68 6f 77 owing chart show
5390: 73 20 74 68 65 20 61 6c 6c 6f 77 65 64 0a 2a 2a s the allowed.**
53a0: 20 74 72 61 6e 73 69 74 69 6f 6e 73 20 61 6e 64 transitions and
53b0: 20 74 68 65 20 69 6e 73 65 72 74 65 64 20 69 6e the inserted in
53c0: 74 65 72 6d 65 64 69 61 74 65 20 73 74 61 74 65 termediate state
53d0: 73 3a 0a 2a 2a 0a 2a 2a 20 20 20 20 55 4e 4c 4f s:.**.** UNLO
53e0: 43 4b 45 44 20 2d 3e 20 53 48 41 52 45 44 0a 2a CKED -> SHARED.*
53f0: 2a 20 20 20 20 53 48 41 52 45 44 20 2d 3e 20 52 * SHARED -> R
5400: 45 53 45 52 56 45 44 0a 2a 2a 20 20 20 20 53 48 ESERVED.** SH
5410: 41 52 45 44 20 2d 3e 20 28 50 45 4e 44 49 4e 47 ARED -> (PENDING
5420: 29 20 2d 3e 20 45 58 43 4c 55 53 49 56 45 0a 2a ) -> EXCLUSIVE.*
5430: 2a 20 20 20 20 52 45 53 45 52 56 45 44 20 2d 3e * RESERVED ->
5440: 20 28 50 45 4e 44 49 4e 47 29 20 2d 3e 20 45 58 (PENDING) -> EX
5450: 43 4c 55 53 49 56 45 0a 2a 2a 20 20 20 20 50 45 CLUSIVE.** PE
5460: 4e 44 49 4e 47 20 2d 3e 20 45 58 43 4c 55 53 49 NDING -> EXCLUSI
5470: 56 45 0a 2a 2a 0a 2a 2a 20 54 68 69 73 20 72 6f VE.**.** This ro
5480: 75 74 69 6e 65 20 77 69 6c 6c 20 6f 6e 6c 79 20 utine will only
5490: 69 6e 63 72 65 61 73 65 20 61 20 6c 6f 63 6b 2e increase a lock.
54a0: 20 20 55 73 65 20 74 68 65 20 73 71 6c 69 74 65 Use the sqlite
54b0: 33 4f 73 55 6e 6c 6f 63 6b 28 29 0a 2a 2a 20 72 3OsUnlock().** r
54c0: 6f 75 74 69 6e 65 20 74 6f 20 6c 6f 77 65 72 20 outine to lower
54d0: 61 20 6c 6f 63 6b 69 6e 67 20 6c 65 76 65 6c 2e a locking level.
54e0: 0a 2a 2f 0a 69 6e 74 20 73 71 6c 69 74 65 33 4f .*/.int sqlite3O
54f0: 73 4c 6f 63 6b 28 4f 73 46 69 6c 65 20 2a 69 64 sLock(OsFile *id
5500: 2c 20 69 6e 74 20 6c 6f 63 6b 74 79 70 65 29 7b , int locktype){
5510: 0a 20 20 69 6e 74 20 72 63 20 3d 20 53 51 4c 49 . int rc = SQLI
5520: 54 45 5f 4f 4b 3b 0a 20 20 73 74 72 75 63 74 20 TE_OK;. struct
5530: 6c 6f 63 6b 49 6e 66 6f 20 2a 70 4c 6f 63 6b 20 lockInfo *pLock
5540: 3d 20 69 64 2d 3e 70 4c 6f 63 6b 3b 0a 20 20 73 = id->pLock;. s
5550: 74 72 75 63 74 20 66 6c 6f 63 6b 20 6c 6f 63 6b truct flock lock
5560: 3b 0a 20 20 69 6e 74 20 73 3b 0a 0a 20 20 54 52 ;. int s;.. TR
5570: 41 43 45 36 28 22 4c 4f 43 4b 20 25 64 20 25 64 ACE6("LOCK %d %d
5580: 20 77 61 73 20 25 64 28 25 64 2c 25 64 29 5c 6e was %d(%d,%d)\n
5590: 22 2c 0a 20 20 20 20 20 20 20 20 20 20 69 64 2d ",. id-
55a0: 3e 68 2c 20 6c 6f 63 6b 74 79 70 65 2c 20 69 64 >h, locktype, id
55b0: 2d 3e 6c 6f 63 6b 74 79 70 65 2c 20 70 4c 6f 63 ->locktype, pLoc
55c0: 6b 2d 3e 6c 6f 63 6b 74 79 70 65 2c 20 70 4c 6f k->locktype, pLo
55d0: 63 6b 2d 3e 63 6e 74 29 3b 0a 0a 20 20 2f 2a 20 ck->cnt);.. /*
55e0: 49 66 20 74 68 65 72 65 20 69 73 20 61 6c 72 65 If there is alre
55f0: 61 64 79 20 61 20 6c 6f 63 6b 20 6f 66 20 74 68 ady a lock of th
5600: 69 73 20 74 79 70 65 20 6f 72 20 6d 6f 72 65 20 is type or more
5610: 72 65 73 74 72 69 63 74 69 76 65 20 6f 6e 20 74 restrictive on t
5620: 68 65 0a 20 20 2a 2a 20 4f 73 46 69 6c 65 2c 20 he. ** OsFile,
5630: 64 6f 20 6e 6f 74 68 69 6e 67 2e 20 44 6f 6e 27 do nothing. Don'
5640: 74 20 75 73 65 20 74 68 65 20 65 6e 64 5f 6c 6f t use the end_lo
5650: 63 6b 3a 20 65 78 69 74 20 70 61 74 68 2c 20 61 ck: exit path, a
5660: 73 0a 20 20 2a 2a 20 73 71 6c 69 74 65 33 4f 73 s. ** sqlite3Os
5670: 45 6e 74 65 72 4d 75 74 65 78 28 29 20 68 61 73 EnterMutex() has
5680: 6e 27 74 20 62 65 65 6e 20 63 61 6c 6c 65 64 20 n't been called
5690: 79 65 74 2e 0a 20 20 2a 2f 0a 20 20 69 66 28 20 yet.. */. if(
56a0: 69 64 2d 3e 6c 6f 63 6b 74 79 70 65 3e 3d 6c 6f id->locktype>=lo
56b0: 63 6b 74 79 70 65 20 29 7b 0a 20 20 20 20 72 65 cktype ){. re
56c0: 74 75 72 6e 20 53 51 4c 49 54 45 5f 4f 4b 3b 0a turn SQLITE_OK;.
56d0: 20 20 7d 0a 0a 20 20 2f 2a 20 4d 61 6b 65 20 73 }.. /* Make s
56e0: 75 72 65 20 74 68 65 20 6c 6f 63 6b 69 6e 67 20 ure the locking
56f0: 73 65 71 75 65 6e 63 65 20 69 73 20 63 6f 72 72 sequence is corr
5700: 65 63 74 0a 20 20 2a 2f 0a 20 20 61 73 73 65 72 ect. */. asser
5710: 74 28 20 69 64 2d 3e 6c 6f 63 6b 74 79 70 65 21 t( id->locktype!
5720: 3d 4e 4f 5f 4c 4f 43 4b 20 7c 7c 20 6c 6f 63 6b =NO_LOCK || lock
5730: 74 79 70 65 3d 3d 53 48 41 52 45 44 5f 4c 4f 43 type==SHARED_LOC
5740: 4b 20 29 3b 0a 20 20 61 73 73 65 72 74 28 20 6c K );. assert( l
5750: 6f 63 6b 74 79 70 65 21 3d 50 45 4e 44 49 4e 47 ocktype!=PENDING
5760: 5f 4c 4f 43 4b 20 29 3b 0a 20 20 61 73 73 65 72 _LOCK );. asser
5770: 74 28 20 6c 6f 63 6b 74 79 70 65 21 3d 52 45 53 t( locktype!=RES
5780: 45 52 56 45 44 5f 4c 4f 43 4b 20 7c 7c 20 69 64 ERVED_LOCK || id
5790: 2d 3e 6c 6f 63 6b 74 79 70 65 3d 3d 53 48 41 52 ->locktype==SHAR
57a0: 45 44 5f 4c 4f 43 4b 20 29 3b 0a 0a 20 20 2f 2a ED_LOCK );.. /*
57b0: 20 54 68 69 73 20 6d 75 74 65 78 20 69 73 20 6e This mutex is n
57c0: 65 65 64 65 64 20 62 65 63 61 75 73 65 20 69 64 eeded because id
57d0: 2d 3e 70 4c 6f 63 6b 20 69 73 20 73 68 61 72 65 ->pLock is share
57e0: 64 20 61 63 72 6f 73 73 20 74 68 72 65 61 64 73 d across threads
57f0: 0a 20 20 2a 2f 0a 20 20 73 71 6c 69 74 65 33 4f . */. sqlite3O
5800: 73 45 6e 74 65 72 4d 75 74 65 78 28 29 3b 0a 0a sEnterMutex();..
5810: 20 20 2f 2a 20 49 66 20 73 6f 6d 65 20 74 68 72 /* If some thr
5820: 65 61 64 20 75 73 69 6e 67 20 74 68 69 73 20 50 ead using this P
5830: 49 44 20 68 61 73 20 61 20 6c 6f 63 6b 20 76 69 ID has a lock vi
5840: 61 20 61 20 64 69 66 66 65 72 65 6e 74 20 4f 73 a a different Os
5850: 46 69 6c 65 2a 0a 20 20 2a 2a 20 68 61 6e 64 6c File*. ** handl
5860: 65 20 74 68 61 74 20 70 72 65 63 6c 75 64 65 73 e that precludes
5870: 20 74 68 65 20 72 65 71 75 65 73 74 65 64 20 6c the requested l
5880: 6f 63 6b 2c 20 72 65 74 75 72 6e 20 42 55 53 59 ock, return BUSY
5890: 2e 0a 20 20 2a 2f 0a 20 20 69 66 28 20 28 69 64 .. */. if( (id
58a0: 2d 3e 6c 6f 63 6b 74 79 70 65 21 3d 70 4c 6f 63 ->locktype!=pLoc
58b0: 6b 2d 3e 6c 6f 63 6b 74 79 70 65 20 26 26 20 0a k->locktype && .
58c0: 20 20 20 20 20 20 20 20 20 20 28 70 4c 6f 63 6b (pLock
58d0: 2d 3e 6c 6f 63 6b 74 79 70 65 3e 3d 50 45 4e 44 ->locktype>=PEND
58e0: 49 4e 47 5f 4c 4f 43 4b 20 7c 7c 20 6c 6f 63 6b ING_LOCK || lock
58f0: 74 79 70 65 3e 53 48 41 52 45 44 5f 4c 4f 43 4b type>SHARED_LOCK
5900: 29 29 0a 20 20 29 7b 0a 20 20 20 20 72 63 20 3d )). ){. rc =
5910: 20 53 51 4c 49 54 45 5f 42 55 53 59 3b 0a 20 20 SQLITE_BUSY;.
5920: 20 20 67 6f 74 6f 20 65 6e 64 5f 6c 6f 63 6b 3b goto end_lock;
5930: 0a 20 20 7d 0a 0a 20 20 2f 2a 20 49 66 20 61 20 . }.. /* If a
5940: 53 48 41 52 45 44 20 6c 6f 63 6b 20 69 73 20 72 SHARED lock is r
5950: 65 71 75 65 73 74 65 64 2c 20 61 6e 64 20 73 6f equested, and so
5960: 6d 65 20 74 68 72 65 61 64 20 75 73 69 6e 67 20 me thread using
5970: 74 68 69 73 20 50 49 44 20 61 6c 72 65 61 64 79 this PID already
5980: 0a 20 20 2a 2a 20 68 61 73 20 61 20 53 48 41 52 . ** has a SHAR
5990: 45 44 20 6f 72 20 52 45 53 45 52 56 45 44 20 6c ED or RESERVED l
59a0: 6f 63 6b 2c 20 74 68 65 6e 20 69 6e 63 72 65 6d ock, then increm
59b0: 65 6e 74 20 72 65 66 65 72 65 6e 63 65 20 63 6f ent reference co
59c0: 75 6e 74 73 20 61 6e 64 0a 20 20 2a 2a 20 72 65 unts and. ** re
59d0: 74 75 72 6e 20 53 51 4c 49 54 45 5f 4f 4b 2e 0a turn SQLITE_OK..
59e0: 20 20 2a 2f 0a 20 20 69 66 28 20 6c 6f 63 6b 74 */. if( lockt
59f0: 79 70 65 3d 3d 53 48 41 52 45 44 5f 4c 4f 43 4b ype==SHARED_LOCK
5a00: 20 26 26 20 0a 20 20 20 20 20 20 28 70 4c 6f 63 && . (pLoc
5a10: 6b 2d 3e 6c 6f 63 6b 74 79 70 65 3d 3d 53 48 41 k->locktype==SHA
5a20: 52 45 44 5f 4c 4f 43 4b 20 7c 7c 20 70 4c 6f 63 RED_LOCK || pLoc
5a30: 6b 2d 3e 6c 6f 63 6b 74 79 70 65 3d 3d 52 45 53 k->locktype==RES
5a40: 45 52 56 45 44 5f 4c 4f 43 4b 29 20 29 7b 0a 20 ERVED_LOCK) ){.
5a50: 20 20 20 61 73 73 65 72 74 28 20 6c 6f 63 6b 74 assert( lockt
5a60: 79 70 65 3d 3d 53 48 41 52 45 44 5f 4c 4f 43 4b ype==SHARED_LOCK
5a70: 20 29 3b 0a 20 20 20 20 61 73 73 65 72 74 28 20 );. assert(
5a80: 69 64 2d 3e 6c 6f 63 6b 74 79 70 65 3d 3d 30 20 id->locktype==0
5a90: 29 3b 0a 20 20 20 20 61 73 73 65 72 74 28 20 70 );. assert( p
5aa0: 4c 6f 63 6b 2d 3e 63 6e 74 3e 30 20 29 3b 0a 20 Lock->cnt>0 );.
5ab0: 20 20 20 69 64 2d 3e 6c 6f 63 6b 74 79 70 65 20 id->locktype
5ac0: 3d 20 53 48 41 52 45 44 5f 4c 4f 43 4b 3b 0a 20 = SHARED_LOCK;.
5ad0: 20 20 20 70 4c 6f 63 6b 2d 3e 63 6e 74 2b 2b 3b pLock->cnt++;
5ae0: 0a 20 20 20 20 69 64 2d 3e 70 4f 70 65 6e 2d 3e . id->pOpen->
5af0: 6e 4c 6f 63 6b 2b 2b 3b 0a 20 20 20 20 67 6f 74 nLock++;. got
5b00: 6f 20 65 6e 64 5f 6c 6f 63 6b 3b 0a 20 20 7d 0a o end_lock;. }.
5b10: 0a 20 20 6c 6f 63 6b 2e 6c 5f 6c 65 6e 20 3d 20 . lock.l_len =
5b20: 31 4c 3b 0a 20 20 6c 6f 63 6b 2e 6c 5f 77 68 65 1L;. lock.l_whe
5b30: 6e 63 65 20 3d 20 53 45 45 4b 5f 53 45 54 3b 0a nce = SEEK_SET;.
5b40: 0a 20 20 2f 2a 20 41 20 50 45 4e 44 49 4e 47 20 . /* A PENDING
5b50: 6c 6f 63 6b 20 69 73 20 6e 65 65 64 65 64 20 62 lock is needed b
5b60: 65 66 6f 72 65 20 61 63 71 75 69 72 69 6e 67 20 efore acquiring
5b70: 61 20 53 48 41 52 45 44 20 6c 6f 63 6b 20 61 6e a SHARED lock an
5b80: 64 20 62 65 66 6f 72 65 0a 20 20 2a 2a 20 61 63 d before. ** ac
5b90: 71 75 69 72 69 6e 67 20 61 6e 20 45 58 43 4c 55 quiring an EXCLU
5ba0: 53 49 56 45 20 6c 6f 63 6b 2e 20 20 46 6f 72 20 SIVE lock. For
5bb0: 74 68 65 20 53 48 41 52 45 44 20 6c 6f 63 6b 2c the SHARED lock,
5bc0: 20 74 68 65 20 50 45 4e 44 49 4e 47 20 77 69 6c the PENDING wil
5bd0: 6c 0a 20 20 2a 2a 20 62 65 20 72 65 6c 65 61 73 l. ** be releas
5be0: 65 64 2e 0a 20 20 2a 2f 0a 20 20 69 66 28 20 6c ed.. */. if( l
5bf0: 6f 63 6b 74 79 70 65 3d 3d 53 48 41 52 45 44 5f ocktype==SHARED_
5c00: 4c 4f 43 4b 20 0a 20 20 20 20 20 20 7c 7c 20 28 LOCK . || (
5c10: 6c 6f 63 6b 74 79 70 65 3d 3d 45 58 43 4c 55 53 locktype==EXCLUS
5c20: 49 56 45 5f 4c 4f 43 4b 20 26 26 20 69 64 2d 3e IVE_LOCK && id->
5c30: 6c 6f 63 6b 74 79 70 65 3c 50 45 4e 44 49 4e 47 locktype<PENDING
5c40: 5f 4c 4f 43 4b 29 0a 20 20 29 7b 0a 20 20 20 20 _LOCK). ){.
5c50: 6c 6f 63 6b 2e 6c 5f 74 79 70 65 20 3d 20 46 5f lock.l_type = F_
5c60: 52 44 4c 43 4b 3b 0a 20 20 20 20 6c 6f 63 6b 2e RDLCK;. lock.
5c70: 6c 5f 73 74 61 72 74 20 3d 20 50 45 4e 44 49 4e l_start = PENDIN
5c80: 47 5f 42 59 54 45 3b 0a 20 20 20 20 73 20 3d 20 G_BYTE;. s =
5c90: 66 63 6e 74 6c 28 69 64 2d 3e 68 2c 20 46 5f 53 fcntl(id->h, F_S
5ca0: 45 54 4c 4b 2c 20 26 6c 6f 63 6b 29 3b 0a 20 20 ETLK, &lock);.
5cb0: 20 20 69 66 28 20 73 20 29 7b 0a 20 20 20 20 20 if( s ){.
5cc0: 20 72 63 20 3d 20 28 65 72 72 6e 6f 3d 3d 45 49 rc = (errno==EI
5cd0: 4e 56 41 4c 29 20 3f 20 53 51 4c 49 54 45 5f 4e NVAL) ? SQLITE_N
5ce0: 4f 4c 46 53 20 3a 20 53 51 4c 49 54 45 5f 42 55 OLFS : SQLITE_BU
5cf0: 53 59 3b 0a 20 20 20 20 20 20 67 6f 74 6f 20 65 SY;. goto e
5d00: 6e 64 5f 6c 6f 63 6b 3b 0a 20 20 20 20 7d 0a 20 nd_lock;. }.
5d10: 20 7d 0a 0a 0a 20 20 2f 2a 20 49 66 20 63 6f 6e }... /* If con
5d20: 74 72 6f 6c 20 67 65 74 73 20 74 6f 20 74 68 69 trol gets to thi
5d30: 73 20 70 6f 69 6e 74 2c 20 74 68 65 6e 20 61 63 s point, then ac
5d40: 74 75 61 6c 6c 79 20 67 6f 20 61 68 65 61 64 20 tually go ahead
5d50: 61 6e 64 20 6d 61 6b 65 0a 20 20 2a 2a 20 6f 70 and make. ** op
5d60: 65 72 61 74 69 6e 67 20 73 79 73 74 65 6d 20 63 erating system c
5d70: 61 6c 6c 73 20 66 6f 72 20 74 68 65 20 73 70 65 alls for the spe
5d80: 63 69 66 69 65 64 20 6c 6f 63 6b 2e 0a 20 20 2a cified lock.. *
5d90: 2f 0a 20 20 69 66 28 20 6c 6f 63 6b 74 79 70 65 /. if( locktype
5da0: 3d 3d 53 48 41 52 45 44 5f 4c 4f 43 4b 20 29 7b ==SHARED_LOCK ){
5db0: 0a 20 20 20 20 61 73 73 65 72 74 28 20 70 4c 6f . assert( pLo
5dc0: 63 6b 2d 3e 63 6e 74 3d 3d 30 20 29 3b 0a 20 20 ck->cnt==0 );.
5dd0: 20 20 61 73 73 65 72 74 28 20 70 4c 6f 63 6b 2d assert( pLock-
5de0: 3e 6c 6f 63 6b 74 79 70 65 3d 3d 30 20 29 3b 0a >locktype==0 );.
5df0: 0a 20 20 20 20 2f 2a 20 4e 6f 77 20 67 65 74 20 . /* Now get
5e00: 74 68 65 20 72 65 61 64 2d 6c 6f 63 6b 20 2a 2f the read-lock */
5e10: 0a 20 20 20 20 6c 6f 63 6b 2e 6c 5f 73 74 61 72 . lock.l_star
5e20: 74 20 3d 20 53 48 41 52 45 44 5f 46 49 52 53 54 t = SHARED_FIRST
5e30: 3b 0a 20 20 20 20 6c 6f 63 6b 2e 6c 5f 6c 65 6e ;. lock.l_len
5e40: 20 3d 20 53 48 41 52 45 44 5f 53 49 5a 45 3b 0a = SHARED_SIZE;.
5e50: 20 20 20 20 73 20 3d 20 66 63 6e 74 6c 28 69 64 s = fcntl(id
5e60: 2d 3e 68 2c 20 46 5f 53 45 54 4c 4b 2c 20 26 6c ->h, F_SETLK, &l
5e70: 6f 63 6b 29 3b 0a 0a 20 20 20 20 2f 2a 20 44 72 ock);.. /* Dr
5e80: 6f 70 20 74 68 65 20 74 65 6d 70 6f 72 61 72 79 op the temporary
5e90: 20 50 45 4e 44 49 4e 47 20 6c 6f 63 6b 20 2a 2f PENDING lock */
5ea0: 0a 20 20 20 20 6c 6f 63 6b 2e 6c 5f 73 74 61 72 . lock.l_star
5eb0: 74 20 3d 20 50 45 4e 44 49 4e 47 5f 42 59 54 45 t = PENDING_BYTE
5ec0: 3b 0a 20 20 20 20 6c 6f 63 6b 2e 6c 5f 6c 65 6e ;. lock.l_len
5ed0: 20 3d 20 31 4c 3b 0a 20 20 20 20 6c 6f 63 6b 2e = 1L;. lock.
5ee0: 6c 5f 74 79 70 65 20 3d 20 46 5f 55 4e 4c 43 4b l_type = F_UNLCK
5ef0: 3b 0a 20 20 20 20 66 63 6e 74 6c 28 69 64 2d 3e ;. fcntl(id->
5f00: 68 2c 20 46 5f 53 45 54 4c 4b 2c 20 26 6c 6f 63 h, F_SETLK, &loc
5f10: 6b 29 3b 0a 20 20 20 20 69 66 28 20 73 20 29 7b k);. if( s ){
5f20: 0a 20 20 20 20 20 20 72 63 20 3d 20 28 65 72 72 . rc = (err
5f30: 6e 6f 3d 3d 45 49 4e 56 41 4c 29 20 3f 20 53 51 no==EINVAL) ? SQ
5f40: 4c 49 54 45 5f 4e 4f 4c 46 53 20 3a 20 53 51 4c LITE_NOLFS : SQL
5f50: 49 54 45 5f 42 55 53 59 3b 0a 20 20 20 20 7d 65 ITE_BUSY;. }e
5f60: 6c 73 65 7b 0a 20 20 20 20 20 20 69 64 2d 3e 6c lse{. id->l
5f70: 6f 63 6b 74 79 70 65 20 3d 20 53 48 41 52 45 44 ocktype = SHARED
5f80: 5f 4c 4f 43 4b 3b 0a 20 20 20 20 20 20 69 64 2d _LOCK;. id-
5f90: 3e 70 4f 70 65 6e 2d 3e 6e 4c 6f 63 6b 2b 2b 3b >pOpen->nLock++;
5fa0: 0a 20 20 20 20 20 20 70 4c 6f 63 6b 2d 3e 63 6e . pLock->cn
5fb0: 74 20 3d 20 31 3b 0a 20 20 20 20 7d 0a 20 20 7d t = 1;. }. }
5fc0: 65 6c 73 65 20 69 66 28 20 6c 6f 63 6b 74 79 70 else if( locktyp
5fd0: 65 3d 3d 45 58 43 4c 55 53 49 56 45 5f 4c 4f 43 e==EXCLUSIVE_LOC
5fe0: 4b 20 26 26 20 70 4c 6f 63 6b 2d 3e 63 6e 74 3e K && pLock->cnt>
5ff0: 31 20 29 7b 0a 20 20 20 20 2f 2a 20 57 65 20 61 1 ){. /* We a
6000: 72 65 20 74 72 79 69 6e 67 20 66 6f 72 20 61 6e re trying for an
6010: 20 65 78 63 6c 75 73 69 76 65 20 6c 6f 63 6b 20 exclusive lock
6020: 62 75 74 20 61 6e 6f 74 68 65 72 20 74 68 72 65 but another thre
6030: 61 64 20 69 6e 20 74 68 69 73 0a 20 20 20 20 2a ad in this. *
6040: 2a 20 73 61 6d 65 20 70 72 6f 63 65 73 73 20 69 * same process i
6050: 73 20 73 74 69 6c 6c 20 68 6f 6c 64 69 6e 67 20 s still holding
6060: 61 20 73 68 61 72 65 64 20 6c 6f 63 6b 2e 20 2a a shared lock. *
6070: 2f 0a 20 20 20 20 72 63 20 3d 20 53 51 4c 49 54 /. rc = SQLIT
6080: 45 5f 42 55 53 59 3b 0a 20 20 7d 65 6c 73 65 7b E_BUSY;. }else{
6090: 0a 20 20 20 20 2f 2a 20 54 68 65 20 72 65 71 75 . /* The requ
60a0: 65 73 74 20 77 61 73 20 66 6f 72 20 61 20 52 45 est was for a RE
60b0: 53 45 52 56 45 44 20 6f 72 20 45 58 43 4c 55 53 SERVED or EXCLUS
60c0: 49 56 45 20 6c 6f 63 6b 2e 20 20 49 74 20 69 73 IVE lock. It is
60d0: 0a 20 20 20 20 2a 2a 20 61 73 73 75 6d 65 64 20 . ** assumed
60e0: 74 68 61 74 20 74 68 65 72 65 20 69 73 20 61 20 that there is a
60f0: 53 48 41 52 45 44 20 6f 72 20 67 72 65 61 74 65 SHARED or greate
6100: 72 20 6c 6f 63 6b 20 6f 6e 20 74 68 65 20 66 69 r lock on the fi
6110: 6c 65 0a 20 20 20 20 2a 2a 20 61 6c 72 65 61 64 le. ** alread
6120: 79 2e 0a 20 20 20 20 2a 2f 0a 20 20 20 20 61 73 y.. */. as
6130: 73 65 72 74 28 20 30 21 3d 69 64 2d 3e 6c 6f 63 sert( 0!=id->loc
6140: 6b 74 79 70 65 20 29 3b 0a 20 20 20 20 6c 6f 63 ktype );. loc
6150: 6b 2e 6c 5f 74 79 70 65 20 3d 20 46 5f 57 52 4c k.l_type = F_WRL
6160: 43 4b 3b 0a 20 20 20 20 73 77 69 74 63 68 28 20 CK;. switch(
6170: 6c 6f 63 6b 74 79 70 65 20 29 7b 0a 20 20 20 20 locktype ){.
6180: 20 20 63 61 73 65 20 52 45 53 45 52 56 45 44 5f case RESERVED_
6190: 4c 4f 43 4b 3a 0a 20 20 20 20 20 20 20 20 6c 6f LOCK:. lo
61a0: 63 6b 2e 6c 5f 73 74 61 72 74 20 3d 20 52 45 53 ck.l_start = RES
61b0: 45 52 56 45 44 5f 42 59 54 45 3b 0a 20 20 20 20 ERVED_BYTE;.
61c0: 20 20 20 20 62 72 65 61 6b 3b 0a 20 20 20 20 20 break;.
61d0: 20 63 61 73 65 20 45 58 43 4c 55 53 49 56 45 5f case EXCLUSIVE_
61e0: 4c 4f 43 4b 3a 0a 20 20 20 20 20 20 20 20 6c 6f LOCK:. lo
61f0: 63 6b 2e 6c 5f 73 74 61 72 74 20 3d 20 53 48 41 ck.l_start = SHA
6200: 52 45 44 5f 46 49 52 53 54 3b 0a 20 20 20 20 20 RED_FIRST;.
6210: 20 20 20 6c 6f 63 6b 2e 6c 5f 6c 65 6e 20 3d 20 lock.l_len =
6220: 53 48 41 52 45 44 5f 53 49 5a 45 3b 0a 20 20 20 SHARED_SIZE;.
6230: 20 20 20 20 20 62 72 65 61 6b 3b 0a 20 20 20 20 break;.
6240: 20 20 64 65 66 61 75 6c 74 3a 0a 20 20 20 20 20 default:.
6250: 20 20 20 61 73 73 65 72 74 28 30 29 3b 0a 20 20 assert(0);.
6260: 20 20 7d 0a 20 20 20 20 73 20 3d 20 66 63 6e 74 }. s = fcnt
6270: 6c 28 69 64 2d 3e 68 2c 20 46 5f 53 45 54 4c 4b l(id->h, F_SETLK
6280: 2c 20 26 6c 6f 63 6b 29 3b 0a 20 20 20 20 69 66 , &lock);. if
6290: 28 20 73 20 29 7b 0a 20 20 20 20 20 20 72 63 20 ( s ){. rc
62a0: 3d 20 28 65 72 72 6e 6f 3d 3d 45 49 4e 56 41 4c = (errno==EINVAL
62b0: 29 20 3f 20 53 51 4c 49 54 45 5f 4e 4f 4c 46 53 ) ? SQLITE_NOLFS
62c0: 20 3a 20 53 51 4c 49 54 45 5f 42 55 53 59 3b 0a : SQLITE_BUSY;.
62d0: 20 20 20 20 7d 0a 20 20 7d 0a 20 20 0a 20 20 69 }. }. . i
62e0: 66 28 20 72 63 3d 3d 53 51 4c 49 54 45 5f 4f 4b f( rc==SQLITE_OK
62f0: 20 29 7b 0a 20 20 20 20 69 64 2d 3e 6c 6f 63 6b ){. id->lock
6300: 74 79 70 65 20 3d 20 6c 6f 63 6b 74 79 70 65 3b type = locktype;
6310: 0a 20 20 20 20 70 4c 6f 63 6b 2d 3e 6c 6f 63 6b . pLock->lock
6320: 74 79 70 65 20 3d 20 6c 6f 63 6b 74 79 70 65 3b type = locktype;
6330: 0a 20 20 7d 65 6c 73 65 20 69 66 28 20 6c 6f 63 . }else if( loc
6340: 6b 74 79 70 65 3d 3d 45 58 43 4c 55 53 49 56 45 ktype==EXCLUSIVE
6350: 5f 4c 4f 43 4b 20 29 7b 0a 20 20 20 20 69 64 2d _LOCK ){. id-
6360: 3e 6c 6f 63 6b 74 79 70 65 20 3d 20 50 45 4e 44 >locktype = PEND
6370: 49 4e 47 5f 4c 4f 43 4b 3b 0a 20 20 20 20 70 4c ING_LOCK;. pL
6380: 6f 63 6b 2d 3e 6c 6f 63 6b 74 79 70 65 20 3d 20 ock->locktype =
6390: 50 45 4e 44 49 4e 47 5f 4c 4f 43 4b 3b 0a 20 20 PENDING_LOCK;.
63a0: 7d 0a 0a 65 6e 64 5f 6c 6f 63 6b 3a 0a 20 20 73 }..end_lock:. s
63b0: 71 6c 69 74 65 33 4f 73 4c 65 61 76 65 4d 75 74 qlite3OsLeaveMut
63c0: 65 78 28 29 3b 0a 20 20 54 52 41 43 45 34 28 22 ex();. TRACE4("
63d0: 4c 4f 43 4b 20 25 64 20 25 64 20 25 73 5c 6e 22 LOCK %d %d %s\n"
63e0: 2c 20 69 64 2d 3e 68 2c 20 6c 6f 63 6b 74 79 70 , id->h, locktyp
63f0: 65 2c 20 72 63 3d 3d 53 51 4c 49 54 45 5f 4f 4b e, rc==SQLITE_OK
6400: 20 3f 20 22 6f 6b 22 20 3a 20 22 66 61 69 6c 65 ? "ok" : "faile
6410: 64 22 29 3b 0a 20 20 72 65 74 75 72 6e 20 72 63 d");. return rc
6420: 3b 0a 7d 0a 0a 2f 2a 0a 2a 2a 20 4c 6f 77 65 72 ;.}../*.** Lower
6430: 20 74 68 65 20 6c 6f 63 6b 69 6e 67 20 6c 65 76 the locking lev
6440: 65 6c 20 6f 6e 20 66 69 6c 65 20 64 65 73 63 72 el on file descr
6450: 69 70 74 6f 72 20 69 64 20 74 6f 20 6c 6f 63 6b iptor id to lock
6460: 74 79 70 65 2e 20 20 6c 6f 63 6b 74 79 70 65 0a type. locktype.
6470: 2a 2a 20 6d 75 73 74 20 62 65 20 65 69 74 68 65 ** must be eithe
6480: 72 20 4e 4f 5f 4c 4f 43 4b 20 6f 72 20 53 48 41 r NO_LOCK or SHA
6490: 52 45 44 5f 4c 4f 43 4b 2e 0a 2a 2a 0a 2a 2a 20 RED_LOCK..**.**
64a0: 49 66 20 74 68 65 20 6c 6f 63 6b 69 6e 67 20 6c If the locking l
64b0: 65 76 65 6c 20 6f 66 20 74 68 65 20 66 69 6c 65 evel of the file
64c0: 20 64 65 73 63 72 69 70 74 6f 72 20 69 73 20 61 descriptor is a
64d0: 6c 72 65 61 64 79 20 61 74 20 6f 72 20 62 65 6c lready at or bel
64e0: 6f 77 0a 2a 2a 20 74 68 65 20 72 65 71 75 65 73 ow.** the reques
64f0: 74 65 64 20 6c 6f 63 6b 69 6e 67 20 6c 65 76 65 ted locking leve
6500: 6c 2c 20 74 68 69 73 20 72 6f 75 74 69 6e 65 20 l, this routine
6510: 69 73 20 61 20 6e 6f 2d 6f 70 2e 0a 2a 2a 0a 2a is a no-op..**.*
6520: 2a 20 49 74 20 69 73 20 6e 6f 74 20 70 6f 73 73 * It is not poss
6530: 69 62 6c 65 20 66 6f 72 20 74 68 69 73 20 72 6f ible for this ro
6540: 75 74 69 6e 65 20 74 6f 20 66 61 69 6c 2e 0a 2a utine to fail..*
6550: 2f 0a 69 6e 74 20 73 71 6c 69 74 65 33 4f 73 55 /.int sqlite3OsU
6560: 6e 6c 6f 63 6b 28 4f 73 46 69 6c 65 20 2a 69 64 nlock(OsFile *id
6570: 2c 20 69 6e 74 20 6c 6f 63 6b 74 79 70 65 29 7b , int locktype){
6580: 0a 20 20 73 74 72 75 63 74 20 6c 6f 63 6b 49 6e . struct lockIn
6590: 66 6f 20 2a 70 4c 6f 63 6b 3b 0a 20 20 73 74 72 fo *pLock;. str
65a0: 75 63 74 20 66 6c 6f 63 6b 20 6c 6f 63 6b 3b 0a uct flock lock;.
65b0: 0a 20 20 54 52 41 43 45 36 28 22 55 4e 4c 4f 43 . TRACE6("UNLOC
65c0: 4b 20 25 64 20 25 64 20 77 61 73 20 25 64 28 25 K %d %d was %d(%
65d0: 64 2c 25 64 29 5c 6e 22 2c 0a 20 20 20 20 20 20 d,%d)\n",.
65e0: 20 20 20 20 69 64 2d 3e 68 2c 20 6c 6f 63 6b 74 id->h, lockt
65f0: 79 70 65 2c 20 69 64 2d 3e 6c 6f 63 6b 74 79 70 ype, id->locktyp
6600: 65 2c 20 69 64 2d 3e 70 4c 6f 63 6b 2d 3e 6c 6f e, id->pLock->lo
6610: 63 6b 74 79 70 65 2c 20 69 64 2d 3e 70 4c 6f 63 cktype, id->pLoc
6620: 6b 2d 3e 63 6e 74 29 3b 0a 0a 20 20 61 73 73 65 k->cnt);.. asse
6630: 72 74 28 20 6c 6f 63 6b 74 79 70 65 3c 3d 53 48 rt( locktype<=SH
6640: 41 52 45 44 5f 4c 4f 43 4b 20 29 3b 0a 20 20 69 ARED_LOCK );. i
6650: 66 28 20 69 64 2d 3e 6c 6f 63 6b 74 79 70 65 3c f( id->locktype<
6660: 3d 6c 6f 63 6b 74 79 70 65 20 29 7b 0a 20 20 20 =locktype ){.
6670: 20 72 65 74 75 72 6e 20 53 51 4c 49 54 45 5f 4f return SQLITE_O
6680: 4b 3b 0a 20 20 7d 0a 20 20 73 71 6c 69 74 65 33 K;. }. sqlite3
6690: 4f 73 45 6e 74 65 72 4d 75 74 65 78 28 29 3b 0a OsEnterMutex();.
66a0: 20 20 70 4c 6f 63 6b 20 3d 20 69 64 2d 3e 70 4c pLock = id->pL
66b0: 6f 63 6b 3b 0a 20 20 61 73 73 65 72 74 28 20 70 ock;. assert( p
66c0: 4c 6f 63 6b 2d 3e 63 6e 74 21 3d 30 20 29 3b 0a Lock->cnt!=0 );.
66d0: 20 20 69 66 28 20 69 64 2d 3e 6c 6f 63 6b 74 79 if( id->lockty
66e0: 70 65 3e 53 48 41 52 45 44 5f 4c 4f 43 4b 20 29 pe>SHARED_LOCK )
66f0: 7b 0a 20 20 20 20 61 73 73 65 72 74 28 20 70 4c {. assert( pL
6700: 6f 63 6b 2d 3e 6c 6f 63 6b 74 79 70 65 3d 3d 69 ock->locktype==i
6710: 64 2d 3e 6c 6f 63 6b 74 79 70 65 20 29 3b 0a 20 d->locktype );.
6720: 20 20 20 6c 6f 63 6b 2e 6c 5f 74 79 70 65 20 3d lock.l_type =
6730: 20 46 5f 55 4e 4c 43 4b 3b 0a 20 20 20 20 6c 6f F_UNLCK;. lo
6740: 63 6b 2e 6c 5f 77 68 65 6e 63 65 20 3d 20 53 45 ck.l_whence = SE
6750: 45 4b 5f 53 45 54 3b 0a 20 20 20 20 6c 6f 63 6b EK_SET;. lock
6760: 2e 6c 5f 73 74 61 72 74 20 3d 20 50 45 4e 44 49 .l_start = PENDI
6770: 4e 47 5f 42 59 54 45 3b 0a 20 20 20 20 6c 6f 63 NG_BYTE;. loc
6780: 6b 2e 6c 5f 6c 65 6e 20 3d 20 32 4c 3b 20 20 61 k.l_len = 2L; a
6790: 73 73 65 72 74 28 20 50 45 4e 44 49 4e 47 5f 42 ssert( PENDING_B
67a0: 59 54 45 2b 31 3d 3d 52 45 53 45 52 56 45 44 5f YTE+1==RESERVED_
67b0: 42 59 54 45 20 29 3b 0a 20 20 20 20 66 63 6e 74 BYTE );. fcnt
67c0: 6c 28 69 64 2d 3e 68 2c 20 46 5f 53 45 54 4c 4b l(id->h, F_SETLK
67d0: 2c 20 26 6c 6f 63 6b 29 3b 0a 20 20 20 20 70 4c , &lock);. pL
67e0: 6f 63 6b 2d 3e 6c 6f 63 6b 74 79 70 65 20 3d 20 ock->locktype =
67f0: 53 48 41 52 45 44 5f 4c 4f 43 4b 3b 0a 20 20 7d SHARED_LOCK;. }
6800: 0a 20 20 69 66 28 20 6c 6f 63 6b 74 79 70 65 3d . if( locktype=
6810: 3d 4e 4f 5f 4c 4f 43 4b 20 29 7b 0a 20 20 20 20 =NO_LOCK ){.
6820: 73 74 72 75 63 74 20 6f 70 65 6e 43 6e 74 20 2a struct openCnt *
6830: 70 4f 70 65 6e 3b 0a 0a 20 20 20 20 2f 2a 20 44 pOpen;.. /* D
6840: 65 63 72 65 6d 65 6e 74 20 74 68 65 20 73 68 61 ecrement the sha
6850: 72 65 64 20 6c 6f 63 6b 20 63 6f 75 6e 74 65 72 red lock counter
6860: 2e 20 20 52 65 6c 65 61 73 65 20 74 68 65 20 6c . Release the l
6870: 6f 63 6b 20 75 73 69 6e 67 20 61 6e 0a 20 20 20 ock using an.
6880: 20 2a 2a 20 4f 53 20 63 61 6c 6c 20 6f 6e 6c 79 ** OS call only
6890: 20 77 68 65 6e 20 61 6c 6c 20 74 68 72 65 61 64 when all thread
68a0: 73 20 69 6e 20 74 68 69 73 20 73 61 6d 65 20 70 s in this same p
68b0: 72 6f 63 65 73 73 20 68 61 76 65 20 72 65 6c 65 rocess have rele
68c0: 61 73 65 64 0a 20 20 20 20 2a 2a 20 74 68 65 20 ased. ** the
68d0: 6c 6f 63 6b 2e 0a 20 20 20 20 2a 2f 0a 20 20 20 lock.. */.
68e0: 20 70 4c 6f 63 6b 2d 3e 63 6e 74 2d 2d 3b 0a 20 pLock->cnt--;.
68f0: 20 20 20 69 66 28 20 70 4c 6f 63 6b 2d 3e 63 6e if( pLock->cn
6900: 74 3d 3d 30 20 29 7b 0a 20 20 20 20 20 20 6c 6f t==0 ){. lo
6910: 63 6b 2e 6c 5f 74 79 70 65 20 3d 20 46 5f 55 4e ck.l_type = F_UN
6920: 4c 43 4b 3b 0a 20 20 20 20 20 20 6c 6f 63 6b 2e LCK;. lock.
6930: 6c 5f 77 68 65 6e 63 65 20 3d 20 53 45 45 4b 5f l_whence = SEEK_
6940: 53 45 54 3b 0a 20 20 20 20 20 20 6c 6f 63 6b 2e SET;. lock.
6950: 6c 5f 73 74 61 72 74 20 3d 20 6c 6f 63 6b 2e 6c l_start = lock.l
6960: 5f 6c 65 6e 20 3d 20 30 4c 3b 0a 20 20 20 20 20 _len = 0L;.
6970: 20 66 63 6e 74 6c 28 69 64 2d 3e 68 2c 20 46 5f fcntl(id->h, F_
6980: 53 45 54 4c 4b 2c 20 26 6c 6f 63 6b 29 3b 0a 20 SETLK, &lock);.
6990: 20 20 20 20 20 70 4c 6f 63 6b 2d 3e 6c 6f 63 6b pLock->lock
69a0: 74 79 70 65 20 3d 20 4e 4f 5f 4c 4f 43 4b 3b 0a type = NO_LOCK;.
69b0: 20 20 20 20 7d 0a 0a 20 20 20 20 2f 2a 20 44 65 }.. /* De
69c0: 63 72 65 6d 65 6e 74 20 74 68 65 20 63 6f 75 6e crement the coun
69d0: 74 20 6f 66 20 6c 6f 63 6b 73 20 61 67 61 69 6e t of locks again
69e0: 73 74 20 74 68 69 73 20 73 61 6d 65 20 66 69 6c st this same fil
69f0: 65 2e 20 20 57 68 65 6e 20 74 68 65 0a 20 20 20 e. When the.
6a00: 20 2a 2a 20 63 6f 75 6e 74 20 72 65 61 63 68 65 ** count reache
6a10: 73 20 7a 65 72 6f 2c 20 63 6c 6f 73 65 20 61 6e s zero, close an
6a20: 79 20 6f 74 68 65 72 20 66 69 6c 65 20 64 65 73 y other file des
6a30: 63 72 69 70 74 6f 72 73 20 77 68 6f 73 65 20 63 criptors whose c
6a40: 6c 6f 73 65 0a 20 20 20 20 2a 2a 20 77 61 73 20 lose. ** was
6a50: 64 65 66 65 72 72 65 64 20 62 65 63 61 75 73 65 deferred because
6a60: 20 6f 66 20 6f 75 74 73 74 61 6e 64 69 6e 67 20 of outstanding
6a70: 6c 6f 63 6b 73 2e 0a 20 20 20 20 2a 2f 0a 20 20 locks.. */.
6a80: 20 20 70 4f 70 65 6e 20 3d 20 69 64 2d 3e 70 4f pOpen = id->pO
6a90: 70 65 6e 3b 0a 20 20 20 20 70 4f 70 65 6e 2d 3e pen;. pOpen->
6aa0: 6e 4c 6f 63 6b 2d 2d 3b 0a 20 20 20 20 61 73 73 nLock--;. ass
6ab0: 65 72 74 28 20 70 4f 70 65 6e 2d 3e 6e 4c 6f 63 ert( pOpen->nLoc
6ac0: 6b 3e 3d 30 20 29 3b 0a 20 20 20 20 69 66 28 20 k>=0 );. if(
6ad0: 70 4f 70 65 6e 2d 3e 6e 4c 6f 63 6b 3d 3d 30 20 pOpen->nLock==0
6ae0: 26 26 20 70 4f 70 65 6e 2d 3e 6e 50 65 6e 64 69 && pOpen->nPendi
6af0: 6e 67 3e 30 20 29 7b 0a 20 20 20 20 20 20 69 6e ng>0 ){. in
6b00: 74 20 69 3b 0a 20 20 20 20 20 20 66 6f 72 28 69 t i;. for(i
6b10: 3d 30 3b 20 69 3c 70 4f 70 65 6e 2d 3e 6e 50 65 =0; i<pOpen->nPe
6b20: 6e 64 69 6e 67 3b 20 69 2b 2b 29 7b 0a 20 20 20 nding; i++){.
6b30: 20 20 20 20 20 63 6c 6f 73 65 28 70 4f 70 65 6e close(pOpen
6b40: 2d 3e 61 50 65 6e 64 69 6e 67 5b 69 5d 29 3b 0a ->aPending[i]);.
6b50: 20 20 20 20 20 20 7d 0a 20 20 20 20 20 20 73 71 }. sq
6b60: 6c 69 74 65 46 72 65 65 28 70 4f 70 65 6e 2d 3e liteFree(pOpen->
6b70: 61 50 65 6e 64 69 6e 67 29 3b 0a 20 20 20 20 20 aPending);.
6b80: 20 70 4f 70 65 6e 2d 3e 6e 50 65 6e 64 69 6e 67 pOpen->nPending
6b90: 20 3d 20 30 3b 0a 20 20 20 20 20 20 70 4f 70 65 = 0;. pOpe
6ba0: 6e 2d 3e 61 50 65 6e 64 69 6e 67 20 3d 20 30 3b n->aPending = 0;
6bb0: 0a 20 20 20 20 7d 0a 20 20 7d 0a 20 20 73 71 6c . }. }. sql
6bc0: 69 74 65 33 4f 73 4c 65 61 76 65 4d 75 74 65 78 ite3OsLeaveMutex
6bd0: 28 29 3b 0a 20 20 69 64 2d 3e 6c 6f 63 6b 74 79 ();. id->lockty
6be0: 70 65 20 3d 20 6c 6f 63 6b 74 79 70 65 3b 0a 20 pe = locktype;.
6bf0: 20 72 65 74 75 72 6e 20 53 51 4c 49 54 45 5f 4f return SQLITE_O
6c00: 4b 3b 0a 7d 0a 0a 2f 2a 0a 2a 2a 20 47 65 74 20 K;.}../*.** Get
6c10: 69 6e 66 6f 72 6d 61 74 69 6f 6e 20 74 6f 20 73 information to s
6c20: 65 65 64 20 74 68 65 20 72 61 6e 64 6f 6d 20 6e eed the random n
6c30: 75 6d 62 65 72 20 67 65 6e 65 72 61 74 6f 72 2e umber generator.
6c40: 20 20 54 68 65 20 73 65 65 64 0a 2a 2a 20 69 73 The seed.** is
6c50: 20 77 72 69 74 74 65 6e 20 69 6e 74 6f 20 74 68 written into th
6c60: 65 20 62 75 66 66 65 72 20 7a 42 75 66 5b 32 35 e buffer zBuf[25
6c70: 36 5d 2e 20 20 54 68 65 20 63 61 6c 6c 69 6e 67 6]. The calling
6c80: 20 66 75 6e 63 74 69 6f 6e 20 6d 75 73 74 0a 2a function must.*
6c90: 2a 20 73 75 70 70 6c 79 20 61 20 73 75 66 66 69 * supply a suffi
6ca0: 63 69 65 6e 74 6c 79 20 6c 61 72 67 65 20 62 75 ciently large bu
6cb0: 66 66 65 72 2e 0a 2a 2f 0a 69 6e 74 20 73 71 6c ffer..*/.int sql
6cc0: 69 74 65 33 4f 73 52 61 6e 64 6f 6d 53 65 65 64 ite3OsRandomSeed
6cd0: 28 63 68 61 72 20 2a 7a 42 75 66 29 7b 0a 20 20 (char *zBuf){.
6ce0: 2f 2a 20 57 65 20 68 61 76 65 20 74 6f 20 69 6e /* We have to in
6cf0: 69 74 69 61 6c 69 7a 65 20 7a 42 75 66 20 74 6f itialize zBuf to
6d00: 20 70 72 65 76 65 6e 74 20 76 61 6c 67 72 69 6e prevent valgrin
6d10: 64 20 66 72 6f 6d 20 72 65 70 6f 72 74 69 6e 67 d from reporting
6d20: 0a 20 20 2a 2a 20 65 72 72 6f 72 73 2e 20 20 54 . ** errors. T
6d30: 68 65 20 72 65 70 6f 72 74 73 20 69 73 73 75 65 he reports issue
6d40: 64 20 62 79 20 76 61 6c 67 72 69 6e 64 20 61 72 d by valgrind ar
6d50: 65 20 69 6e 63 6f 72 72 65 63 74 20 2d 20 77 65 e incorrect - we
6d60: 20 77 6f 75 6c 64 0a 20 20 2a 2a 20 70 72 65 66 would. ** pref
6d70: 65 72 20 74 68 61 74 20 74 68 65 20 72 61 6e 64 er that the rand
6d80: 6f 6d 6e 65 73 73 20 62 65 20 69 6e 63 72 65 61 omness be increa
6d90: 73 65 64 20 62 79 20 6d 61 6b 69 6e 67 20 75 73 sed by making us
6da0: 65 20 6f 66 20 74 68 65 0a 20 20 2a 2a 20 75 6e e of the. ** un
6db0: 69 6e 69 74 69 61 6c 69 7a 65 64 20 73 70 61 63 initialized spac
6dc0: 65 20 69 6e 20 7a 42 75 66 20 2d 20 62 75 74 20 e in zBuf - but
6dd0: 76 61 6c 67 72 69 6e 64 20 65 72 72 6f 72 73 20 valgrind errors
6de0: 74 65 6e 64 20 74 6f 20 77 6f 72 72 79 0a 20 20 tend to worry.
6df0: 2a 2a 20 73 6f 6d 65 20 75 73 65 72 73 2e 20 20 ** some users.
6e00: 52 61 74 68 65 72 20 74 68 61 6e 20 61 72 67 75 Rather than argu
6e10: 65 2c 20 69 74 20 73 65 65 6d 73 20 65 61 73 69 e, it seems easi
6e20: 65 72 20 6a 75 73 74 20 74 6f 20 69 6e 69 74 69 er just to initi
6e30: 61 6c 69 7a 65 0a 20 20 2a 2a 20 74 68 65 20 77 alize. ** the w
6e40: 68 6f 6c 65 20 61 72 72 61 79 20 61 6e 64 20 73 hole array and s
6e50: 69 6c 65 6e 63 65 20 76 61 6c 67 72 69 6e 64 2c ilence valgrind,
6e60: 20 65 76 65 6e 20 69 66 20 74 68 61 74 20 6d 65 even if that me
6e70: 61 6e 73 20 6c 65 73 73 20 72 61 6e 64 6f 6d 6e ans less randomn
6e80: 65 73 73 0a 20 20 2a 2a 20 69 6e 20 74 68 65 20 ess. ** in the
6e90: 72 61 6e 64 6f 6d 20 73 65 65 64 2e 0a 20 20 2a random seed.. *
6ea0: 2a 0a 20 20 2a 2a 20 57 68 65 6e 20 74 65 73 74 *. ** When test
6eb0: 69 6e 67 2c 20 69 6e 69 74 69 61 6c 69 7a 69 6e ing, initializin
6ec0: 67 20 7a 42 75 66 5b 5d 20 74 6f 20 7a 65 72 6f g zBuf[] to zero
6ed0: 20 69 73 20 61 6c 6c 20 77 65 20 64 6f 2e 20 20 is all we do.
6ee0: 54 68 61 74 20 6d 65 61 6e 73 0a 20 20 2a 2a 20 That means. **
6ef0: 74 68 61 74 20 77 65 20 61 6c 77 61 79 73 20 75 that we always u
6f00: 73 65 20 74 68 65 20 73 61 6d 65 20 72 61 6e 64 se the same rand
6f10: 6f 6d 20 6e 75 6d 62 65 72 20 73 65 71 75 65 6e om number sequen
6f20: 63 65 2e 2a 20 54 68 69 73 20 6d 61 6b 65 73 20 ce.* This makes
6f30: 74 68 65 0a 20 20 2a 2a 20 74 65 73 74 73 20 72 the. ** tests r
6f40: 65 70 65 61 74 61 62 6c 65 2e 0a 20 20 2a 2f 0a epeatable.. */.
6f50: 20 20 6d 65 6d 73 65 74 28 7a 42 75 66 2c 20 30 memset(zBuf, 0
6f60: 2c 20 32 35 36 29 3b 0a 23 69 66 20 21 64 65 66 , 256);.#if !def
6f70: 69 6e 65 64 28 53 51 4c 49 54 45 5f 54 45 53 54 ined(SQLITE_TEST
6f80: 29 0a 20 20 7b 0a 20 20 20 20 69 6e 74 20 70 69 ). {. int pi
6f90: 64 3b 0a 20 20 20 20 74 69 6d 65 28 28 74 69 6d d;. time((tim
6fa0: 65 5f 74 2a 29 7a 42 75 66 29 3b 0a 20 20 20 20 e_t*)zBuf);.
6fb0: 70 69 64 20 3d 20 67 65 74 70 69 64 28 29 3b 0a pid = getpid();.
6fc0: 20 20 20 20 6d 65 6d 63 70 79 28 26 7a 42 75 66 memcpy(&zBuf
6fd0: 5b 73 69 7a 65 6f 66 28 74 69 6d 65 5f 74 29 5d [sizeof(time_t)]
6fe0: 2c 20 26 70 69 64 2c 20 73 69 7a 65 6f 66 28 70 , &pid, sizeof(p
6ff0: 69 64 29 29 3b 0a 20 20 7d 0a 23 65 6e 64 69 66 id));. }.#endif
7000: 0a 20 20 72 65 74 75 72 6e 20 53 51 4c 49 54 45 . return SQLITE
7010: 5f 4f 4b 3b 0a 7d 0a 0a 2f 2a 0a 2a 2a 20 53 6c _OK;.}../*.** Sl
7020: 65 65 70 20 66 6f 72 20 61 20 6c 69 74 74 6c 65 eep for a little
7030: 20 77 68 69 6c 65 2e 20 20 52 65 74 75 72 6e 20 while. Return
7040: 74 68 65 20 61 6d 6f 75 6e 74 20 6f 66 20 74 69 the amount of ti
7050: 6d 65 20 73 6c 65 70 74 2e 0a 2a 2f 0a 69 6e 74 me slept..*/.int
7060: 20 73 71 6c 69 74 65 33 4f 73 53 6c 65 65 70 28 sqlite3OsSleep(
7070: 69 6e 74 20 6d 73 29 7b 0a 23 69 66 20 64 65 66 int ms){.#if def
7080: 69 6e 65 64 28 48 41 56 45 5f 55 53 4c 45 45 50 ined(HAVE_USLEEP
7090: 29 20 26 26 20 48 41 56 45 5f 55 53 4c 45 45 50 ) && HAVE_USLEEP
70a0: 0a 20 20 75 73 6c 65 65 70 28 6d 73 2a 31 30 30 . usleep(ms*100
70b0: 30 29 3b 0a 20 20 72 65 74 75 72 6e 20 6d 73 3b 0);. return ms;
70c0: 0a 23 65 6c 73 65 0a 20 20 73 6c 65 65 70 28 28 .#else. sleep((
70d0: 6d 73 2b 39 39 39 29 2f 31 30 30 30 29 3b 0a 20 ms+999)/1000);.
70e0: 20 72 65 74 75 72 6e 20 31 30 30 30 2a 28 28 6d return 1000*((m
70f0: 73 2b 39 39 39 29 2f 31 30 30 30 29 3b 0a 23 65 s+999)/1000);.#e
7100: 6e 64 69 66 0a 7d 0a 0a 2f 2a 0a 2a 2a 20 53 74 ndif.}../*.** St
7110: 61 74 69 63 20 76 61 72 69 61 62 6c 65 73 20 75 atic variables u
7120: 73 65 64 20 66 6f 72 20 74 68 72 65 61 64 20 73 sed for thread s
7130: 79 6e 63 68 72 6f 6e 69 7a 61 74 69 6f 6e 0a 2a ynchronization.*
7140: 2f 0a 73 74 61 74 69 63 20 69 6e 74 20 69 6e 4d /.static int inM
7150: 75 74 65 78 20 3d 20 30 3b 0a 23 69 66 64 65 66 utex = 0;.#ifdef
7160: 20 53 51 4c 49 54 45 5f 55 4e 49 58 5f 54 48 52 SQLITE_UNIX_THR
7170: 45 41 44 53 0a 73 74 61 74 69 63 20 70 74 68 72 EADS.static pthr
7180: 65 61 64 5f 6d 75 74 65 78 5f 74 20 6d 75 74 65 ead_mutex_t mute
7190: 78 20 3d 20 50 54 48 52 45 41 44 5f 4d 55 54 45 x = PTHREAD_MUTE
71a0: 58 5f 49 4e 49 54 49 41 4c 49 5a 45 52 3b 0a 23 X_INITIALIZER;.#
71b0: 65 6e 64 69 66 0a 0a 2f 2a 0a 2a 2a 20 54 68 65 endif../*.** The
71c0: 20 66 6f 6c 6c 6f 77 69 6e 67 20 70 61 69 72 20 following pair
71d0: 6f 66 20 72 6f 75 74 69 6e 65 20 69 6d 70 6c 65 of routine imple
71e0: 6d 65 6e 74 20 6d 75 74 75 61 6c 20 65 78 63 6c ment mutual excl
71f0: 75 73 69 6f 6e 20 66 6f 72 0a 2a 2a 20 6d 75 6c usion for.** mul
7200: 74 69 2d 74 68 72 65 61 64 65 64 20 70 72 6f 63 ti-threaded proc
7210: 65 73 73 65 73 2e 20 20 4f 6e 6c 79 20 61 20 73 esses. Only a s
7220: 69 6e 67 6c 65 20 74 68 72 65 61 64 20 69 73 20 ingle thread is
7230: 61 6c 6c 6f 77 65 64 20 74 6f 0a 2a 2a 20 65 78 allowed to.** ex
7240: 65 63 75 74 65 64 20 63 6f 64 65 20 74 68 61 74 ecuted code that
7250: 20 69 73 20 73 75 72 72 6f 75 6e 64 65 64 20 62 is surrounded b
7260: 79 20 45 6e 74 65 72 4d 75 74 65 78 28 29 20 61 y EnterMutex() a
7270: 6e 64 20 4c 65 61 76 65 4d 75 74 65 78 28 29 2e nd LeaveMutex().
7280: 0a 2a 2a 0a 2a 2a 20 53 51 4c 69 74 65 20 75 73 .**.** SQLite us
7290: 65 73 20 6f 6e 6c 79 20 61 20 73 69 6e 67 6c 65 es only a single
72a0: 20 4d 75 74 65 78 2e 20 20 54 68 65 72 65 20 69 Mutex. There i
72b0: 73 20 6e 6f 74 20 6d 75 63 68 20 63 72 69 74 69 s not much criti
72c0: 63 61 6c 0a 2a 2a 20 63 6f 64 65 20 61 6e 64 20 cal.** code and
72d0: 77 68 61 74 20 6c 69 74 74 6c 65 20 74 68 65 72 what little ther
72e0: 65 20 69 73 20 65 78 65 63 75 74 65 73 20 71 75 e is executes qu
72f0: 69 63 6b 6c 79 20 61 6e 64 20 77 69 74 68 6f 75 ickly and withou
7300: 74 20 62 6c 6f 63 6b 69 6e 67 2e 0a 2a 2f 0a 76 t blocking..*/.v
7310: 6f 69 64 20 73 71 6c 69 74 65 33 4f 73 45 6e 74 oid sqlite3OsEnt
7320: 65 72 4d 75 74 65 78 28 29 7b 0a 23 69 66 64 65 erMutex(){.#ifde
7330: 66 20 53 51 4c 49 54 45 5f 55 4e 49 58 5f 54 48 f SQLITE_UNIX_TH
7340: 52 45 41 44 53 0a 20 20 70 74 68 72 65 61 64 5f READS. pthread_
7350: 6d 75 74 65 78 5f 6c 6f 63 6b 28 26 6d 75 74 65 mutex_lock(&mute
7360: 78 29 3b 0a 23 65 6e 64 69 66 0a 20 20 61 73 73 x);.#endif. ass
7370: 65 72 74 28 20 21 69 6e 4d 75 74 65 78 20 29 3b ert( !inMutex );
7380: 0a 20 20 69 6e 4d 75 74 65 78 20 3d 20 31 3b 0a . inMutex = 1;.
7390: 7d 0a 76 6f 69 64 20 73 71 6c 69 74 65 33 4f 73 }.void sqlite3Os
73a0: 4c 65 61 76 65 4d 75 74 65 78 28 29 7b 0a 20 20 LeaveMutex(){.
73b0: 61 73 73 65 72 74 28 20 69 6e 4d 75 74 65 78 20 assert( inMutex
73c0: 29 3b 0a 20 20 69 6e 4d 75 74 65 78 20 3d 20 30 );. inMutex = 0
73d0: 3b 0a 23 69 66 64 65 66 20 53 51 4c 49 54 45 5f ;.#ifdef SQLITE_
73e0: 55 4e 49 58 5f 54 48 52 45 41 44 53 0a 20 20 70 UNIX_THREADS. p
73f0: 74 68 72 65 61 64 5f 6d 75 74 65 78 5f 75 6e 6c thread_mutex_unl
7400: 6f 63 6b 28 26 6d 75 74 65 78 29 3b 0a 23 65 6e ock(&mutex);.#en
7410: 64 69 66 0a 7d 0a 0a 2f 2a 0a 2a 2a 20 54 75 72 dif.}../*.** Tur
7420: 6e 20 61 20 72 65 6c 61 74 69 76 65 20 70 61 74 n a relative pat
7430: 68 6e 61 6d 65 20 69 6e 74 6f 20 61 20 66 75 6c hname into a ful
7440: 6c 20 70 61 74 68 6e 61 6d 65 2e 20 20 52 65 74 l pathname. Ret
7450: 75 72 6e 20 61 20 70 6f 69 6e 74 65 72 0a 2a 2a urn a pointer.**
7460: 20 74 6f 20 74 68 65 20 66 75 6c 6c 20 70 61 74 to the full pat
7470: 68 6e 61 6d 65 20 73 74 6f 72 65 64 20 69 6e 20 hname stored in
7480: 73 70 61 63 65 20 6f 62 74 61 69 6e 65 64 20 66 space obtained f
7490: 72 6f 6d 20 73 71 6c 69 74 65 4d 61 6c 6c 6f 63 rom sqliteMalloc
74a0: 28 29 2e 0a 2a 2a 20 54 68 65 20 63 61 6c 6c 69 ()..** The calli
74b0: 6e 67 20 66 75 6e 63 74 69 6f 6e 20 69 73 20 72 ng function is r
74c0: 65 73 70 6f 6e 73 69 62 6c 65 20 66 6f 72 20 66 esponsible for f
74d0: 72 65 65 69 6e 67 20 74 68 69 73 20 73 70 61 63 reeing this spac
74e0: 65 20 6f 6e 63 65 20 69 74 0a 2a 2a 20 69 73 20 e once it.** is
74f0: 6e 6f 20 6c 6f 6e 67 65 72 20 6e 65 65 64 65 64 no longer needed
7500: 2e 0a 2a 2f 0a 63 68 61 72 20 2a 73 71 6c 69 74 ..*/.char *sqlit
7510: 65 33 4f 73 46 75 6c 6c 50 61 74 68 6e 61 6d 65 e3OsFullPathname
7520: 28 63 6f 6e 73 74 20 63 68 61 72 20 2a 7a 52 65 (const char *zRe
7530: 6c 61 74 69 76 65 29 7b 0a 20 20 63 68 61 72 20 lative){. char
7540: 2a 7a 46 75 6c 6c 20 3d 20 30 3b 0a 20 20 69 66 *zFull = 0;. if
7550: 28 20 7a 52 65 6c 61 74 69 76 65 5b 30 5d 3d 3d ( zRelative[0]==
7560: 27 2f 27 20 29 7b 0a 20 20 20 20 73 71 6c 69 74 '/' ){. sqlit
7570: 65 33 53 65 74 53 74 72 69 6e 67 28 26 7a 46 75 e3SetString(&zFu
7580: 6c 6c 2c 20 7a 52 65 6c 61 74 69 76 65 2c 20 28 ll, zRelative, (
7590: 63 68 61 72 2a 29 30 29 3b 0a 20 20 7d 65 6c 73 char*)0);. }els
75a0: 65 7b 0a 20 20 20 20 63 68 61 72 20 7a 42 75 66 e{. char zBuf
75b0: 5b 35 30 30 30 5d 3b 0a 20 20 20 20 73 71 6c 69 [5000];. sqli
75c0: 74 65 33 53 65 74 53 74 72 69 6e 67 28 26 7a 46 te3SetString(&zF
75d0: 75 6c 6c 2c 20 67 65 74 63 77 64 28 7a 42 75 66 ull, getcwd(zBuf
75e0: 2c 20 73 69 7a 65 6f 66 28 7a 42 75 66 29 29 2c , sizeof(zBuf)),
75f0: 20 22 2f 22 2c 20 7a 52 65 6c 61 74 69 76 65 2c "/", zRelative,
7600: 0a 20 20 20 20 20 20 20 20 20 20 20 20 20 20 20 .
7610: 20 20 20 20 20 28 63 68 61 72 2a 29 30 29 3b 0a (char*)0);.
7620: 20 20 7d 0a 20 20 72 65 74 75 72 6e 20 7a 46 75 }. return zFu
7630: 6c 6c 3b 0a 7d 0a 0a 2f 2a 0a 2a 2a 20 54 68 65 ll;.}../*.** The
7640: 20 66 6f 6c 6c 6f 77 69 6e 67 20 76 61 72 69 61 following varia
7650: 62 6c 65 2c 20 69 66 20 73 65 74 20 74 6f 20 61 ble, if set to a
7660: 20 6e 6f 6e 2d 7a 65 72 6f 20 76 61 6c 75 65 2c non-zero value,
7670: 20 62 65 63 6f 6d 65 73 20 74 68 65 20 72 65 73 becomes the res
7680: 75 6c 74 0a 2a 2a 20 72 65 74 75 72 6e 65 64 20 ult.** returned
7690: 66 72 6f 6d 20 73 71 6c 69 74 65 33 4f 73 43 75 from sqlite3OsCu
76a0: 72 72 65 6e 74 54 69 6d 65 28 29 2e 20 20 54 68 rrentTime(). Th
76b0: 69 73 20 69 73 20 75 73 65 64 20 66 6f 72 20 74 is is used for t
76c0: 65 73 74 69 6e 67 2e 0a 2a 2f 0a 23 69 66 64 65 esting..*/.#ifde
76d0: 66 20 53 51 4c 49 54 45 5f 54 45 53 54 0a 69 6e f SQLITE_TEST.in
76e0: 74 20 73 71 6c 69 74 65 33 5f 63 75 72 72 65 6e t sqlite3_curren
76f0: 74 5f 74 69 6d 65 20 3d 20 30 3b 0a 23 65 6e 64 t_time = 0;.#end
7700: 69 66 0a 0a 2f 2a 0a 2a 2a 20 46 69 6e 64 20 74 if../*.** Find t
7710: 68 65 20 63 75 72 72 65 6e 74 20 74 69 6d 65 20 he current time
7720: 28 69 6e 20 55 6e 69 76 65 72 73 61 6c 20 43 6f (in Universal Co
7730: 6f 72 64 69 6e 61 74 65 64 20 54 69 6d 65 29 2e ordinated Time).
7740: 20 20 57 72 69 74 65 20 74 68 65 0a 2a 2a 20 63 Write the.** c
7750: 75 72 72 65 6e 74 20 74 69 6d 65 20 61 6e 64 20 urrent time and
7760: 64 61 74 65 20 61 73 20 61 20 4a 75 6c 69 61 6e date as a Julian
7770: 20 44 61 79 20 6e 75 6d 62 65 72 20 69 6e 74 6f Day number into
7780: 20 2a 70 72 4e 6f 77 20 61 6e 64 0a 2a 2a 20 72 *prNow and.** r
7790: 65 74 75 72 6e 20 30 2e 20 20 52 65 74 75 72 6e eturn 0. Return
77a0: 20 31 20 69 66 20 74 68 65 20 74 69 6d 65 20 61 1 if the time a
77b0: 6e 64 20 64 61 74 65 20 63 61 6e 6e 6f 74 20 62 nd date cannot b
77c0: 65 20 66 6f 75 6e 64 2e 0a 2a 2f 0a 69 6e 74 20 e found..*/.int
77d0: 73 71 6c 69 74 65 33 4f 73 43 75 72 72 65 6e 74 sqlite3OsCurrent
77e0: 54 69 6d 65 28 64 6f 75 62 6c 65 20 2a 70 72 4e Time(double *prN
77f0: 6f 77 29 7b 0a 20 20 74 69 6d 65 5f 74 20 74 3b ow){. time_t t;
7800: 0a 20 20 74 69 6d 65 28 26 74 29 3b 0a 20 20 2a . time(&t);. *
7810: 70 72 4e 6f 77 20 3d 20 74 2f 38 36 34 30 30 2e prNow = t/86400.
7820: 30 20 2b 20 32 34 34 30 35 38 37 2e 35 3b 0a 23 0 + 2440587.5;.#
7830: 69 66 64 65 66 20 53 51 4c 49 54 45 5f 54 45 53 ifdef SQLITE_TES
7840: 54 0a 20 20 69 66 28 20 73 71 6c 69 74 65 33 5f T. if( sqlite3_
7850: 63 75 72 72 65 6e 74 5f 74 69 6d 65 20 29 7b 0a current_time ){.
7860: 20 20 20 20 2a 70 72 4e 6f 77 20 3d 20 73 71 6c *prNow = sql
7870: 69 74 65 33 5f 63 75 72 72 65 6e 74 5f 74 69 6d ite3_current_tim
7880: 65 2f 38 36 34 30 30 2e 30 20 2b 20 32 34 34 30 e/86400.0 + 2440
7890: 35 38 37 2e 35 3b 0a 20 20 7d 0a 23 65 6e 64 69 587.5;. }.#endi
78a0: 66 0a 20 20 72 65 74 75 72 6e 20 30 3b 0a 7d 0a f. return 0;.}.
78b0: 0a 23 65 6e 64 69 66 20 2f 2a 20 4f 53 5f 55 4e .#endif /* OS_UN
78c0: 49 58 20 2a 2f 0a IX */.