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