15821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles)/* 25821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles)** 2008 Jan 22 35821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles)** 45821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles)** The author disclaims copyright to this source code. In place of 55821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles)** a legal notice, here is a blessing: 65821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles)** 75821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles)** May you do good and not evil. 85821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles)** May you find forgiveness for yourself and forgive others. 95821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles)** May you share freely, never taking more than you give. 105821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles)** 115821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles)****************************************************************************** 125821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles)** 135821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles)** This file contains code for a VFS layer that acts as a wrapper around 145821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles)** an existing VFS. The code in this file attempts to verify that SQLite 155821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles)** correctly populates and syncs a journal file before writing to a 165821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles)** corresponding database file. 175821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles)*/ 185821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles)#if SQLITE_TEST /* This file is used for testing only */ 195821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) 205821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles)#include "sqlite3.h" 215821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles)#include "sqliteInt.h" 225821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) 235821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles)/* 245821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles)** INTERFACE 255821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles)** 265821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles)** The public interface to this wrapper VFS is two functions: 275821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles)** 285821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles)** jt_register() 295821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles)** jt_unregister() 305821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles)** 315821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles)** See header comments associated with those two functions below for 325821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles)** details. 335821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles)** 345821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles)** LIMITATIONS 355821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles)** 365821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles)** This wrapper will not work if "PRAGMA synchronous = off" is used. 375821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles)** 385821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles)** OPERATION 395821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles)** 405821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles)** Starting a Transaction: 415821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles)** 425821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles)** When a write-transaction is started, the contents of the database is 435821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles)** inspected and the following data stored as part of the database file 445821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles)** handle (type struct jt_file): 455821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles)** 465821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles)** a) The page-size of the database file. 475821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles)** b) The number of pages that are in the database file. 485821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles)** c) The set of page numbers corresponding to free-list leaf pages. 495821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles)** d) A check-sum for every page in the database file. 505821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles)** 515821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles)** The start of a write-transaction is deemed to have occurred when a 525821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles)** 28-byte journal header is written to byte offset 0 of the journal 535821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles)** file. 545821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles)** 555821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles)** Syncing the Journal File: 565821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles)** 575821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles)** Whenever the xSync method is invoked to sync a journal-file, the 585821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles)** contents of the journal file are read. For each page written to 595821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles)** the journal file, a check-sum is calculated and compared to the 605821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles)** check-sum calculated for the corresponding database page when the 615821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles)** write-transaction was initialized. The success of the comparison 625821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles)** is assert()ed. So if SQLite has written something other than the 635821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles)** original content to the database file, an assert() will fail. 645821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles)** 655821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles)** Additionally, the set of page numbers for which records exist in 665821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles)** the journal file is added to (unioned with) the set of page numbers 675821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles)** corresponding to free-list leaf pages collected when the 685821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles)** write-transaction was initialized. This set comprises the page-numbers 695821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles)** corresponding to those pages that SQLite may now safely modify. 705821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles)** 715821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles)** Writing to the Database File: 725821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles)** 735821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles)** When a block of data is written to a database file, the following 745821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles)** invariants are asserted: 755821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles)** 765821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles)** a) That the block of data is an aligned block of page-size bytes. 775821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles)** 785821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles)** b) That if the page being written did not exist when the 795821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles)** transaction was started (i.e. the database file is growing), then 805821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles)** the journal-file must have been synced at least once since 815821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles)** the start of the transaction. 825821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles)** 835821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles)** c) That if the page being written did exist when the transaction 845821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles)** was started, then the page must have either been a free-list 855821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles)** leaf page at the start of the transaction, or else must have 865821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles)** been stored in the journal file prior to the most recent sync. 875821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles)** 885821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles)** Closing a Transaction: 895821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles)** 905821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles)** When a transaction is closed, all data collected at the start of 915821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles)** the transaction, or following an xSync of a journal-file, is 925821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles)** discarded. The end of a transaction is recognized when any one 935821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles)** of the following occur: 945821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles)** 955821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles)** a) A block of zeroes (or anything else that is not a valid 965821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles)** journal-header) is written to the start of the journal file. 975821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles)** 985821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles)** b) A journal file is truncated to zero bytes in size using xTruncate. 995821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles)** 1005821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles)** c) The journal file is deleted using xDelete. 1015821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles)*/ 1025821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) 1035821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles)/* 1045821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles)** Maximum pathname length supported by the jt backend. 1055821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles)*/ 1065821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles)#define JT_MAX_PATHNAME 512 1075821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) 1085821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles)/* 1095821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles)** Name used to identify this VFS. 1105821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles)*/ 1115821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles)#define JT_VFS_NAME "jt" 1125821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) 1135821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles)typedef struct jt_file jt_file; 1145821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles)struct jt_file { 1155821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) sqlite3_file base; 1165821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) const char *zName; /* Name of open file */ 1175821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) int flags; /* Flags the file was opened with */ 1185821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) 1195821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) /* The following are only used by database file file handles */ 1205821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) int eLock; /* Current lock held on the file */ 1215821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) u32 nPage; /* Size of file in pages when transaction started */ 1225821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) u32 nPagesize; /* Page size when transaction started */ 1235821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) Bitvec *pWritable; /* Bitvec of pages that may be written to the file */ 1245821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) u32 *aCksum; /* Checksum for first nPage pages */ 1255821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) int nSync; /* Number of times journal file has been synced */ 1265821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) 1275821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) /* Only used by journal file-handles */ 1285821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) sqlite3_int64 iMaxOff; /* Maximum offset written to this transaction */ 1295821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) 1305821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) jt_file *pNext; /* All files are stored in a linked list */ 1315821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) sqlite3_file *pReal; /* The file handle for the underlying vfs */ 1325821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles)}; 1335821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) 1345821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles)/* 1355821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles)** Method declarations for jt_file. 1365821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles)*/ 1375821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles)static int jtClose(sqlite3_file*); 1385821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles)static int jtRead(sqlite3_file*, void*, int iAmt, sqlite3_int64 iOfst); 1395821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles)static int jtWrite(sqlite3_file*,const void*,int iAmt, sqlite3_int64 iOfst); 1405821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles)static int jtTruncate(sqlite3_file*, sqlite3_int64 size); 1415821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles)static int jtSync(sqlite3_file*, int flags); 1425821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles)static int jtFileSize(sqlite3_file*, sqlite3_int64 *pSize); 1435821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles)static int jtLock(sqlite3_file*, int); 1445821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles)static int jtUnlock(sqlite3_file*, int); 1455821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles)static int jtCheckReservedLock(sqlite3_file*, int *); 1465821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles)static int jtFileControl(sqlite3_file*, int op, void *pArg); 1475821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles)static int jtSectorSize(sqlite3_file*); 1485821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles)static int jtDeviceCharacteristics(sqlite3_file*); 1495821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) 1505821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles)/* 1515821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles)** Method declarations for jt_vfs. 1525821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles)*/ 1535821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles)static int jtOpen(sqlite3_vfs*, const char *, sqlite3_file*, int , int *); 1545821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles)static int jtDelete(sqlite3_vfs*, const char *zName, int syncDir); 1555821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles)static int jtAccess(sqlite3_vfs*, const char *zName, int flags, int *); 1565821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles)static int jtFullPathname(sqlite3_vfs*, const char *zName, int, char *zOut); 1575821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles)static void *jtDlOpen(sqlite3_vfs*, const char *zFilename); 1585821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles)static void jtDlError(sqlite3_vfs*, int nByte, char *zErrMsg); 1595821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles)static void (*jtDlSym(sqlite3_vfs*,void*, const char *zSymbol))(void); 1605821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles)static void jtDlClose(sqlite3_vfs*, void*); 1615821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles)static int jtRandomness(sqlite3_vfs*, int nByte, char *zOut); 1625821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles)static int jtSleep(sqlite3_vfs*, int microseconds); 1635821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles)static int jtCurrentTime(sqlite3_vfs*, double*); 1645821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles)static int jtCurrentTimeInt64(sqlite3_vfs*, sqlite3_int64*); 1655821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) 1665821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles)static sqlite3_vfs jt_vfs = { 1675821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) 2, /* iVersion */ 1685821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) sizeof(jt_file), /* szOsFile */ 1695821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) JT_MAX_PATHNAME, /* mxPathname */ 1705821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) 0, /* pNext */ 1715821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) JT_VFS_NAME, /* zName */ 1725821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) 0, /* pAppData */ 1735821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) jtOpen, /* xOpen */ 1745821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) jtDelete, /* xDelete */ 1755821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) jtAccess, /* xAccess */ 1765821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) jtFullPathname, /* xFullPathname */ 1775821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) jtDlOpen, /* xDlOpen */ 1785821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) jtDlError, /* xDlError */ 1795821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) jtDlSym, /* xDlSym */ 1805821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) jtDlClose, /* xDlClose */ 1815821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) jtRandomness, /* xRandomness */ 1825821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) jtSleep, /* xSleep */ 1835821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) jtCurrentTime, /* xCurrentTime */ 1845821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) 0, /* xGetLastError */ 1855821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) jtCurrentTimeInt64 /* xCurrentTimeInt64 */ 1865821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles)}; 1875821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) 1885821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles)static sqlite3_io_methods jt_io_methods = { 1895821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) 1, /* iVersion */ 1905821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) jtClose, /* xClose */ 1915821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) jtRead, /* xRead */ 1925821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) jtWrite, /* xWrite */ 1935821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) jtTruncate, /* xTruncate */ 1945821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) jtSync, /* xSync */ 1955821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) jtFileSize, /* xFileSize */ 1965821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) jtLock, /* xLock */ 1975821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) jtUnlock, /* xUnlock */ 1985821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) jtCheckReservedLock, /* xCheckReservedLock */ 1995821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) jtFileControl, /* xFileControl */ 2005821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) jtSectorSize, /* xSectorSize */ 2015821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) jtDeviceCharacteristics /* xDeviceCharacteristics */ 2025821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles)}; 2035821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) 2045821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles)struct JtGlobal { 2055821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) sqlite3_vfs *pVfs; /* Parent VFS */ 2065821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) jt_file *pList; /* List of all open files */ 2075821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles)}; 2085821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles)static struct JtGlobal g = {0, 0}; 2095821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) 2105821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles)/* 2115821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles)** Functions to obtain and relinquish a mutex to protect g.pList. The 2125821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles)** STATIC_PRNG mutex is reused, purely for the sake of convenience. 2135821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles)*/ 2145821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles)static void enterJtMutex(void){ 2155821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) sqlite3_mutex_enter(sqlite3_mutex_alloc(SQLITE_MUTEX_STATIC_PRNG)); 2165821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles)} 2175821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles)static void leaveJtMutex(void){ 2185821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) sqlite3_mutex_leave(sqlite3_mutex_alloc(SQLITE_MUTEX_STATIC_PRNG)); 2195821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles)} 2205821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) 2215821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles)extern int sqlite3_io_error_pending; 2225821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles)extern int sqlite3_io_error_hit; 2235821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles)static void stop_ioerr_simulation(int *piSave, int *piSave2){ 2245821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) *piSave = sqlite3_io_error_pending; 2255821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) *piSave2 = sqlite3_io_error_hit; 2265821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) sqlite3_io_error_pending = -1; 2275821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) sqlite3_io_error_hit = 0; 2285821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles)} 2295821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles)static void start_ioerr_simulation(int iSave, int iSave2){ 2305821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) sqlite3_io_error_pending = iSave; 2315821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) sqlite3_io_error_hit = iSave2; 2325821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles)} 2335821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) 2345821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles)/* 2355821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles)** The jt_file pointed to by the argument may or may not be a file-handle 2365821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles)** open on a main database file. If it is, and a transaction is currently 2375821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles)** opened on the file, then discard all transaction related data. 2385821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles)*/ 2395821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles)static void closeTransaction(jt_file *p){ 2405821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) sqlite3BitvecDestroy(p->pWritable); 2415821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) sqlite3_free(p->aCksum); 2425821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) p->pWritable = 0; 2435821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) p->aCksum = 0; 2445821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) p->nSync = 0; 2455821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles)} 2465821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) 2475821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles)/* 2485821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles)** Close an jt-file. 2495821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles)*/ 2505821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles)static int jtClose(sqlite3_file *pFile){ 2515821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) jt_file **pp; 2525821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) jt_file *p = (jt_file *)pFile; 2535821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) 2545821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) closeTransaction(p); 2555821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) enterJtMutex(); 2565821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) if( p->zName ){ 2575821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) for(pp=&g.pList; *pp!=p; pp=&(*pp)->pNext); 2585821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) *pp = p->pNext; 2595821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) } 2605821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) leaveJtMutex(); 2615821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) return sqlite3OsClose(p->pReal); 2625821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles)} 2635821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) 2645821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles)/* 2655821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles)** Read data from an jt-file. 2665821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles)*/ 2675821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles)static int jtRead( 2685821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) sqlite3_file *pFile, 2695821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) void *zBuf, 2705821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) int iAmt, 2715821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) sqlite_int64 iOfst 2725821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles)){ 2735821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) jt_file *p = (jt_file *)pFile; 2745821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) return sqlite3OsRead(p->pReal, zBuf, iAmt, iOfst); 2755821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles)} 2765821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) 2775821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles)/* 2785821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles)** Parameter zJournal is the name of a journal file that is currently 2795821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles)** open. This function locates and returns the handle opened on the 2805821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles)** corresponding database file by the pager that currently has the 2815821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles)** journal file opened. This file-handle is identified by the 2825821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles)** following properties: 2835821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles)** 2845821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles)** a) SQLITE_OPEN_MAIN_DB was specified when the file was opened. 2855821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles)** 2865821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles)** b) The file-name specified when the file was opened matches 2875821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles)** all but the final 8 characters of the journal file name. 2885821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles)** 2895821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles)** c) There is currently a reserved lock on the file. 2905821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles)**/ 2915821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles)static jt_file *locateDatabaseHandle(const char *zJournal){ 2925821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) jt_file *pMain = 0; 2935821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) enterJtMutex(); 2945821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) for(pMain=g.pList; pMain; pMain=pMain->pNext){ 2955821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) int nName = strlen(zJournal) - strlen("-journal"); 2965821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) if( (pMain->flags&SQLITE_OPEN_MAIN_DB) 2975821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) && (strlen(pMain->zName)==nName) 2985821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) && 0==memcmp(pMain->zName, zJournal, nName) 2995821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) && (pMain->eLock>=SQLITE_LOCK_RESERVED) 3005821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) ){ 3015821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) break; 3025821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) } 3035821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) } 3045821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) leaveJtMutex(); 3055821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) return pMain; 3065821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles)} 3075821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) 3085821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles)/* 3095821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles)** Parameter z points to a buffer of 4 bytes in size containing a 3105821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles)** unsigned 32-bit integer stored in big-endian format. Decode the 3115821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles)** integer and return its value. 3125821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles)*/ 3135821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles)static u32 decodeUint32(const unsigned char *z){ 3145821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) return (z[0]<<24) + (z[1]<<16) + (z[2]<<8) + z[3]; 3155821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles)} 3165821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) 3175821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles)/* 3185821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles)** Calculate a checksum from the buffer of length n bytes pointed to 3195821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles)** by parameter z. 3205821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles)*/ 3215821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles)static u32 genCksum(const unsigned char *z, int n){ 3225821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) int i; 3235821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) u32 cksum = 0; 3245821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) for(i=0; i<n; i++){ 3255821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) cksum = cksum + z[i] + (cksum<<3); 3265821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) } 3275821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) return cksum; 3285821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles)} 3295821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) 3305821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles)/* 3315821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles)** The first argument, zBuf, points to a buffer containing a 28 byte 3325821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles)** serialized journal header. This function deserializes four of the 3335821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles)** integer fields contained in the journal header and writes their 3345821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles)** values to the output variables. 3355821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles)** 3365821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles)** SQLITE_OK is returned if the journal-header is successfully 3375821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles)** decoded. Otherwise, SQLITE_ERROR. 3385821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles)*/ 3395821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles)static int decodeJournalHdr( 3405821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) const unsigned char *zBuf, /* Input: 28 byte journal header */ 3415821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) u32 *pnRec, /* Out: Number of journalled records */ 3425821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) u32 *pnPage, /* Out: Original database page count */ 3435821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) u32 *pnSector, /* Out: Sector size in bytes */ 3445821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) u32 *pnPagesize /* Out: Page size in bytes */ 3455821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles)){ 3465821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) unsigned char aMagic[] = { 0xd9, 0xd5, 0x05, 0xf9, 0x20, 0xa1, 0x63, 0xd7 }; 3475821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) if( memcmp(aMagic, zBuf, 8) ) return SQLITE_ERROR; 3485821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) if( pnRec ) *pnRec = decodeUint32(&zBuf[8]); 3495821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) if( pnPage ) *pnPage = decodeUint32(&zBuf[16]); 3505821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) if( pnSector ) *pnSector = decodeUint32(&zBuf[20]); 3515821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) if( pnPagesize ) *pnPagesize = decodeUint32(&zBuf[24]); 3525821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) return SQLITE_OK; 3535821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles)} 3545821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) 3555821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles)/* 3565821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles)** This function is called when a new transaction is opened, just after 3575821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles)** the first journal-header is written to the journal file. 3585821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles)*/ 3595821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles)static int openTransaction(jt_file *pMain, jt_file *pJournal){ 3605821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) unsigned char *aData; 3615821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) sqlite3_file *p = pMain->pReal; 3625821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) int rc = SQLITE_OK; 3635821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) 3645821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) closeTransaction(pMain); 3655821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) aData = sqlite3_malloc(pMain->nPagesize); 3665821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) pMain->pWritable = sqlite3BitvecCreate(pMain->nPage); 3675821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) pMain->aCksum = sqlite3_malloc(sizeof(u32) * (pMain->nPage + 1)); 3685821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) pJournal->iMaxOff = 0; 3695821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) 3705821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) if( !pMain->pWritable || !pMain->aCksum || !aData ){ 3715821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) rc = SQLITE_IOERR_NOMEM; 3725821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) }else if( pMain->nPage>0 ){ 3735821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) u32 iTrunk; 3745821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) int iSave; 3755821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) int iSave2; 3765821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) 3775821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) stop_ioerr_simulation(&iSave, &iSave2); 3785821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) 3795821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) /* Read the database free-list. Add the page-number for each free-list 3805821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) ** leaf to the jt_file.pWritable bitvec. 3815821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) */ 3825821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) rc = sqlite3OsRead(p, aData, pMain->nPagesize, 0); 3835821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) if( rc==SQLITE_OK ){ 3845821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) u32 nDbsize = decodeUint32(&aData[28]); 3855821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) if( nDbsize>0 && memcmp(&aData[24], &aData[92], 4)==0 ){ 3865821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) u32 iPg; 3875821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) for(iPg=nDbsize+1; iPg<=pMain->nPage; iPg++){ 3885821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) sqlite3BitvecSet(pMain->pWritable, iPg); 3895821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) } 3905821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) } 3915821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) } 3925821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) iTrunk = decodeUint32(&aData[32]); 3935821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) while( rc==SQLITE_OK && iTrunk>0 ){ 3945821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) u32 nLeaf; 3955821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) u32 iLeaf; 3965821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) sqlite3_int64 iOff = (iTrunk-1)*pMain->nPagesize; 3975821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) rc = sqlite3OsRead(p, aData, pMain->nPagesize, iOff); 3985821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) nLeaf = decodeUint32(&aData[4]); 3995821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) for(iLeaf=0; rc==SQLITE_OK && iLeaf<nLeaf; iLeaf++){ 4005821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) u32 pgno = decodeUint32(&aData[8+4*iLeaf]); 4015821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) sqlite3BitvecSet(pMain->pWritable, pgno); 4025821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) } 4035821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) iTrunk = decodeUint32(aData); 4045821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) } 4055821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) 4065821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) /* Calculate and store a checksum for each page in the database file. */ 4075821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) if( rc==SQLITE_OK ){ 4085821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) int ii; 4095821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) for(ii=0; rc==SQLITE_OK && ii<pMain->nPage; ii++){ 4105821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) i64 iOff = (i64)(pMain->nPagesize) * (i64)ii; 4115821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) if( iOff==PENDING_BYTE ) continue; 4125821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) rc = sqlite3OsRead(pMain->pReal, aData, pMain->nPagesize, iOff); 4135821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) pMain->aCksum[ii] = genCksum(aData, pMain->nPagesize); 4145821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) } 4155821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) } 4165821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) 4175821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) start_ioerr_simulation(iSave, iSave2); 4185821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) } 4195821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) 4205821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) sqlite3_free(aData); 4215821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) return rc; 4225821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles)} 4235821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) 4245821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles)/* 4255821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles)** The first argument to this function is a handle open on a journal file. 4265821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles)** This function reads the journal file and adds the page number for each 4275821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles)** page in the journal to the Bitvec object passed as the second argument. 4285821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles)*/ 4295821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles)static int readJournalFile(jt_file *p, jt_file *pMain){ 4305821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) int rc = SQLITE_OK; 4315821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) unsigned char zBuf[28]; 4325821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) sqlite3_file *pReal = p->pReal; 4335821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) sqlite3_int64 iOff = 0; 4345821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) sqlite3_int64 iSize = p->iMaxOff; 4355821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) unsigned char *aPage; 4365821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) int iSave; 4375821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) int iSave2; 4385821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) 4395821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) aPage = sqlite3_malloc(pMain->nPagesize); 4405821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) if( !aPage ){ 4415821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) return SQLITE_IOERR_NOMEM; 4425821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) } 4435821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) 4445821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) stop_ioerr_simulation(&iSave, &iSave2); 4455821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) 4465821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) while( rc==SQLITE_OK && iOff<iSize ){ 4475821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) u32 nRec, nPage, nSector, nPagesize; 4485821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) u32 ii; 4495821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) 4505821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) /* Read and decode the next journal-header from the journal file. */ 4515821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) rc = sqlite3OsRead(pReal, zBuf, 28, iOff); 4525821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) if( rc!=SQLITE_OK 4535821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) || decodeJournalHdr(zBuf, &nRec, &nPage, &nSector, &nPagesize) 4545821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) ){ 4555821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) goto finish_rjf; 4565821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) } 4575821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) iOff += nSector; 4585821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) 4595821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) if( nRec==0 ){ 4605821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) /* A trick. There might be another journal-header immediately 4615821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) ** following this one. In this case, 0 records means 0 records, 4625821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) ** not "read until the end of the file". See also ticket #2565. 4635821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) */ 4645821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) if( iSize>=(iOff+nSector) ){ 4655821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) rc = sqlite3OsRead(pReal, zBuf, 28, iOff); 4665821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) if( rc!=SQLITE_OK || 0==decodeJournalHdr(zBuf, 0, 0, 0, 0) ){ 4675821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) continue; 4685821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) } 4695821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) } 4705821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) nRec = (iSize-iOff) / (pMain->nPagesize+8); 4715821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) } 4725821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) 4735821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) /* Read all the records that follow the journal-header just read. */ 4745821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) for(ii=0; rc==SQLITE_OK && ii<nRec && iOff<iSize; ii++){ 4755821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) u32 pgno; 4765821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) rc = sqlite3OsRead(pReal, zBuf, 4, iOff); 4775821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) if( rc==SQLITE_OK ){ 4785821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) pgno = decodeUint32(zBuf); 4795821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) if( pgno>0 && pgno<=pMain->nPage ){ 4805821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) if( 0==sqlite3BitvecTest(pMain->pWritable, pgno) ){ 4815821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) rc = sqlite3OsRead(pReal, aPage, pMain->nPagesize, iOff+4); 4825821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) if( rc==SQLITE_OK ){ 4835821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) u32 cksum = genCksum(aPage, pMain->nPagesize); 4845821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) assert( cksum==pMain->aCksum[pgno-1] ); 4855821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) } 4865821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) } 4875821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) sqlite3BitvecSet(pMain->pWritable, pgno); 4885821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) } 4895821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) iOff += (8 + pMain->nPagesize); 4905821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) } 4915821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) } 4925821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) 4935821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) iOff = ((iOff + (nSector-1)) / nSector) * nSector; 4945821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) } 4955821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) 4965821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles)finish_rjf: 4975821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) start_ioerr_simulation(iSave, iSave2); 4985821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) sqlite3_free(aPage); 4995821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) if( rc==SQLITE_IOERR_SHORT_READ ){ 5005821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) rc = SQLITE_OK; 5015821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) } 5025821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) return rc; 5035821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles)} 5045821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) 5055821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles)/* 5065821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles)** Write data to an jt-file. 5075821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles)*/ 5085821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles)static int jtWrite( 5095821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) sqlite3_file *pFile, 5105821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) const void *zBuf, 5115821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) int iAmt, 5125821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) sqlite_int64 iOfst 5135821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles)){ 5145821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) int rc; 5155821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) jt_file *p = (jt_file *)pFile; 5165821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) if( p->flags&SQLITE_OPEN_MAIN_JOURNAL ){ 5175821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) if( iOfst==0 ){ 5185821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) jt_file *pMain = locateDatabaseHandle(p->zName); 5195821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) assert( pMain ); 5205821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) 5215821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) if( iAmt==28 ){ 5225821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) /* Zeroing the first journal-file header. This is the end of a 5235821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) ** transaction. */ 5245821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) closeTransaction(pMain); 5255821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) }else if( iAmt!=12 ){ 5265821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) /* Writing the first journal header to a journal file. This happens 5275821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) ** when a transaction is first started. */ 5285821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) u8 *z = (u8 *)zBuf; 5295821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) pMain->nPage = decodeUint32(&z[16]); 5305821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) pMain->nPagesize = decodeUint32(&z[24]); 5315821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) if( SQLITE_OK!=(rc=openTransaction(pMain, p)) ){ 5325821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) return rc; 5335821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) } 5345821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) } 5355821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) } 5365821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) if( p->iMaxOff<(iOfst + iAmt) ){ 5375821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) p->iMaxOff = iOfst + iAmt; 5385821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) } 5395821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) } 5405821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) 5415821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) if( p->flags&SQLITE_OPEN_MAIN_DB && p->pWritable ){ 5425821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) if( iAmt<p->nPagesize 5435821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) && p->nPagesize%iAmt==0 5445821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) && iOfst>=(PENDING_BYTE+512) 5455821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) && iOfst+iAmt<=PENDING_BYTE+p->nPagesize 5465821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) ){ 5475821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) /* No-op. This special case is hit when the backup code is copying a 5485821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) ** to a database with a larger page-size than the source database and 5495821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) ** it needs to fill in the non-locking-region part of the original 5505821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) ** pending-byte page. 5515821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) */ 5525821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) }else{ 5535821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) u32 pgno = iOfst/p->nPagesize + 1; 5545821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) assert( (iAmt==1||iAmt==p->nPagesize) && ((iOfst+iAmt)%p->nPagesize)==0 ); 5555821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) assert( pgno<=p->nPage || p->nSync>0 ); 5565821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) assert( pgno>p->nPage || sqlite3BitvecTest(p->pWritable, pgno) ); 5575821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) } 5585821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) } 5595821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) 5605821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) rc = sqlite3OsWrite(p->pReal, zBuf, iAmt, iOfst); 5615821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) if( (p->flags&SQLITE_OPEN_MAIN_JOURNAL) && iAmt==12 ){ 5625821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) jt_file *pMain = locateDatabaseHandle(p->zName); 5635821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) int rc2 = readJournalFile(p, pMain); 5645821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) if( rc==SQLITE_OK ) rc = rc2; 5655821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) } 5665821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) return rc; 5675821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles)} 5685821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) 5695821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles)/* 5705821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles)** Truncate an jt-file. 5715821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles)*/ 5725821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles)static int jtTruncate(sqlite3_file *pFile, sqlite_int64 size){ 5735821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) jt_file *p = (jt_file *)pFile; 5745821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) if( p->flags&SQLITE_OPEN_MAIN_JOURNAL && size==0 ){ 5755821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) /* Truncating a journal file. This is the end of a transaction. */ 5765821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) jt_file *pMain = locateDatabaseHandle(p->zName); 5775821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) closeTransaction(pMain); 5785821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) } 5795821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) if( p->flags&SQLITE_OPEN_MAIN_DB && p->pWritable ){ 5805821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) u32 pgno; 5815821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) u32 locking_page = (u32)(PENDING_BYTE/p->nPagesize+1); 5825821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) for(pgno=size/p->nPagesize+1; pgno<=p->nPage; pgno++){ 5835821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) assert( pgno==locking_page || sqlite3BitvecTest(p->pWritable, pgno) ); 5845821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) } 5855821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) } 5865821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) return sqlite3OsTruncate(p->pReal, size); 5875821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles)} 5885821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) 5895821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles)/* 5905821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles)** Sync an jt-file. 5915821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles)*/ 5925821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles)static int jtSync(sqlite3_file *pFile, int flags){ 5935821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) jt_file *p = (jt_file *)pFile; 5945821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) 5955821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) if( p->flags&SQLITE_OPEN_MAIN_JOURNAL ){ 5965821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) int rc; 5975821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) jt_file *pMain; /* The associated database file */ 5985821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) 5995821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) /* The journal file is being synced. At this point, we inspect the 6005821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) ** contents of the file up to this point and set each bit in the 6015821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) ** jt_file.pWritable bitvec of the main database file associated with 6025821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) ** this journal file. 6035821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) */ 6045821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) pMain = locateDatabaseHandle(p->zName); 6055821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) assert(pMain); 6065821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) 6075821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) /* Set the bitvec values */ 6085821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) if( pMain->pWritable ){ 6095821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) pMain->nSync++; 6105821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) rc = readJournalFile(p, pMain); 6115821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) if( rc!=SQLITE_OK ){ 6125821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) return rc; 6135821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) } 6145821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) } 6155821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) } 6165821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) 6175821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) return sqlite3OsSync(p->pReal, flags); 6185821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles)} 6195821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) 6205821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles)/* 6215821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles)** Return the current file-size of an jt-file. 6225821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles)*/ 6235821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles)static int jtFileSize(sqlite3_file *pFile, sqlite_int64 *pSize){ 6245821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) jt_file *p = (jt_file *)pFile; 6255821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) return sqlite3OsFileSize(p->pReal, pSize); 6265821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles)} 6275821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) 6285821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles)/* 6295821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles)** Lock an jt-file. 6305821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles)*/ 6315821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles)static int jtLock(sqlite3_file *pFile, int eLock){ 6325821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) int rc; 6335821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) jt_file *p = (jt_file *)pFile; 6345821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) rc = sqlite3OsLock(p->pReal, eLock); 6355821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) if( rc==SQLITE_OK && eLock>p->eLock ){ 6365821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) p->eLock = eLock; 6375821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) } 6385821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) return rc; 6395821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles)} 6405821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) 6415821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles)/* 6425821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles)** Unlock an jt-file. 6435821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles)*/ 6445821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles)static int jtUnlock(sqlite3_file *pFile, int eLock){ 6455821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) int rc; 6465821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) jt_file *p = (jt_file *)pFile; 6475821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) rc = sqlite3OsUnlock(p->pReal, eLock); 6485821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) if( rc==SQLITE_OK && eLock<p->eLock ){ 6495821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) p->eLock = eLock; 6505821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) } 6515821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) return rc; 6525821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles)} 6535821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) 6545821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles)/* 6555821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles)** Check if another file-handle holds a RESERVED lock on an jt-file. 6565821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles)*/ 6575821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles)static int jtCheckReservedLock(sqlite3_file *pFile, int *pResOut){ 6585821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) jt_file *p = (jt_file *)pFile; 6595821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) return sqlite3OsCheckReservedLock(p->pReal, pResOut); 6605821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles)} 6615821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) 6625821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles)/* 6635821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles)** File control method. For custom operations on an jt-file. 6645821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles)*/ 6655821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles)static int jtFileControl(sqlite3_file *pFile, int op, void *pArg){ 6665821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) jt_file *p = (jt_file *)pFile; 6675821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) return sqlite3OsFileControl(p->pReal, op, pArg); 6685821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles)} 6695821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) 6705821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles)/* 6715821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles)** Return the sector-size in bytes for an jt-file. 6725821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles)*/ 6735821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles)static int jtSectorSize(sqlite3_file *pFile){ 6745821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) jt_file *p = (jt_file *)pFile; 6755821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) return sqlite3OsSectorSize(p->pReal); 6765821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles)} 6775821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) 6785821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles)/* 6795821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles)** Return the device characteristic flags supported by an jt-file. 6805821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles)*/ 6815821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles)static int jtDeviceCharacteristics(sqlite3_file *pFile){ 6825821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) jt_file *p = (jt_file *)pFile; 6835821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) return sqlite3OsDeviceCharacteristics(p->pReal); 6845821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles)} 6855821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) 6865821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles)/* 6875821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles)** Open an jt file handle. 6885821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles)*/ 6895821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles)static int jtOpen( 6905821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) sqlite3_vfs *pVfs, 6915821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) const char *zName, 6925821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) sqlite3_file *pFile, 6935821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) int flags, 6945821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) int *pOutFlags 6955821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles)){ 6965821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) int rc; 6975821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) jt_file *p = (jt_file *)pFile; 6985821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) pFile->pMethods = 0; 6995821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) p->pReal = (sqlite3_file *)&p[1]; 7005821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) p->pReal->pMethods = 0; 7015821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) rc = sqlite3OsOpen(g.pVfs, zName, p->pReal, flags, pOutFlags); 7025821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) assert( rc==SQLITE_OK || p->pReal->pMethods==0 ); 7035821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) if( rc==SQLITE_OK ){ 7045821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) pFile->pMethods = &jt_io_methods; 7055821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) p->eLock = 0; 7065821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) p->zName = zName; 7075821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) p->flags = flags; 7085821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) p->pNext = 0; 7095821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) p->pWritable = 0; 7105821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) p->aCksum = 0; 7115821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) enterJtMutex(); 7125821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) if( zName ){ 7135821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) p->pNext = g.pList; 7145821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) g.pList = p; 7155821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) } 7165821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) leaveJtMutex(); 7175821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) } 7185821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) return rc; 7195821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles)} 7205821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) 7215821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles)/* 7225821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles)** Delete the file located at zPath. If the dirSync argument is true, 7235821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles)** ensure the file-system modifications are synced to disk before 7245821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles)** returning. 7255821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles)*/ 7265821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles)static int jtDelete(sqlite3_vfs *pVfs, const char *zPath, int dirSync){ 7275821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) int nPath = strlen(zPath); 7285821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) if( nPath>8 && 0==strcmp("-journal", &zPath[nPath-8]) ){ 7295821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) /* Deleting a journal file. The end of a transaction. */ 7305821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) jt_file *pMain = locateDatabaseHandle(zPath); 7315821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) if( pMain ){ 7325821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) closeTransaction(pMain); 7335821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) } 7345821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) } 7355821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) 7365821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) return sqlite3OsDelete(g.pVfs, zPath, dirSync); 7375821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles)} 7385821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) 7395821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles)/* 7405821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles)** Test for access permissions. Return true if the requested permission 7415821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles)** is available, or false otherwise. 7425821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles)*/ 7435821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles)static int jtAccess( 7445821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) sqlite3_vfs *pVfs, 7455821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) const char *zPath, 7465821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) int flags, 7475821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) int *pResOut 7485821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles)){ 7495821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) return sqlite3OsAccess(g.pVfs, zPath, flags, pResOut); 7505821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles)} 7515821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) 7525821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles)/* 7535821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles)** Populate buffer zOut with the full canonical pathname corresponding 7545821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles)** to the pathname in zPath. zOut is guaranteed to point to a buffer 7555821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles)** of at least (JT_MAX_PATHNAME+1) bytes. 7565821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles)*/ 7575821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles)static int jtFullPathname( 7585821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) sqlite3_vfs *pVfs, 7595821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) const char *zPath, 7605821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) int nOut, 7615821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) char *zOut 7625821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles)){ 7635821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) return sqlite3OsFullPathname(g.pVfs, zPath, nOut, zOut); 7645821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles)} 7655821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) 7665821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles)/* 7675821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles)** Open the dynamic library located at zPath and return a handle. 7685821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles)*/ 7695821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles)static void *jtDlOpen(sqlite3_vfs *pVfs, const char *zPath){ 7705821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) return g.pVfs->xDlOpen(g.pVfs, zPath); 7715821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles)} 7725821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) 7735821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles)/* 7745821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles)** Populate the buffer zErrMsg (size nByte bytes) with a human readable 7755821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles)** utf-8 string describing the most recent error encountered associated 7765821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles)** with dynamic libraries. 7775821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles)*/ 7785821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles)static void jtDlError(sqlite3_vfs *pVfs, int nByte, char *zErrMsg){ 7795821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) g.pVfs->xDlError(g.pVfs, nByte, zErrMsg); 7805821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles)} 7815821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) 7825821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles)/* 7835821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles)** Return a pointer to the symbol zSymbol in the dynamic library pHandle. 7845821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles)*/ 7855821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles)static void (*jtDlSym(sqlite3_vfs *pVfs, void *p, const char *zSym))(void){ 7865821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) return g.pVfs->xDlSym(g.pVfs, p, zSym); 7875821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles)} 7885821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) 7895821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles)/* 7905821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles)** Close the dynamic library handle pHandle. 7915821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles)*/ 7925821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles)static void jtDlClose(sqlite3_vfs *pVfs, void *pHandle){ 7935821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) g.pVfs->xDlClose(g.pVfs, pHandle); 7945821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles)} 7955821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) 7965821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles)/* 7975821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles)** Populate the buffer pointed to by zBufOut with nByte bytes of 7985821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles)** random data. 7995821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles)*/ 8005821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles)static int jtRandomness(sqlite3_vfs *pVfs, int nByte, char *zBufOut){ 8015821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) return sqlite3OsRandomness(g.pVfs, nByte, zBufOut); 8025821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles)} 8035821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) 8045821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles)/* 8055821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles)** Sleep for nMicro microseconds. Return the number of microseconds 8065821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles)** actually slept. 8075821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles)*/ 8085821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles)static int jtSleep(sqlite3_vfs *pVfs, int nMicro){ 8095821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) return sqlite3OsSleep(g.pVfs, nMicro); 8105821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles)} 8115821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) 8125821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles)/* 8135821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles)** Return the current time as a Julian Day number in *pTimeOut. 8145821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles)*/ 8155821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles)static int jtCurrentTime(sqlite3_vfs *pVfs, double *pTimeOut){ 8165821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) return g.pVfs->xCurrentTime(g.pVfs, pTimeOut); 8175821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles)} 8185821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles)/* 8195821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles)** Return the current time as a Julian Day number in *pTimeOut. 8205821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles)*/ 8215821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles)static int jtCurrentTimeInt64(sqlite3_vfs *pVfs, sqlite3_int64 *pTimeOut){ 8225821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) return g.pVfs->xCurrentTimeInt64(g.pVfs, pTimeOut); 8235821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles)} 8245821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) 8255821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles)/************************************************************************** 8265821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles)** Start of public API. 8275821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles)*/ 8285821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) 8295821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles)/* 8305821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles)** Configure the jt VFS as a wrapper around the VFS named by parameter 8315821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles)** zWrap. If the isDefault parameter is true, then the jt VFS is installed 8325821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles)** as the new default VFS for SQLite connections. If isDefault is not 8335821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles)** true, then the jt VFS is installed as non-default. In this case it 8345821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles)** is available via its name, "jt". 8355821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles)*/ 8365821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles)int jt_register(char *zWrap, int isDefault){ 8375821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) g.pVfs = sqlite3_vfs_find(zWrap); 8385821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) if( g.pVfs==0 ){ 8395821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) return SQLITE_ERROR; 8405821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) } 8415821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) jt_vfs.szOsFile = sizeof(jt_file) + g.pVfs->szOsFile; 8425821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) if( g.pVfs->iVersion==1 ){ 8435821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) jt_vfs.iVersion = 1; 8445821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) }else if( g.pVfs->xCurrentTimeInt64==0 ){ 8455821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) jt_vfs.xCurrentTimeInt64 = 0; 8465821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) } 8475821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) sqlite3_vfs_register(&jt_vfs, isDefault); 8485821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) return SQLITE_OK; 8495821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles)} 8505821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) 8515821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles)/* 8525821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles)** Uninstall the jt VFS, if it is installed. 8535821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles)*/ 8545821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles)void jt_unregister(void){ 8555821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) sqlite3_vfs_unregister(&jt_vfs); 8565821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles)} 8575821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) 8585821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles)#endif 859