Index: third_party/sqlite/sqlite-src-3080704/src/test_superlock.c |
diff --git a/third_party/sqlite/sqlite-src-3080704/src/test_superlock.c b/third_party/sqlite/sqlite-src-3080704/src/test_superlock.c |
deleted file mode 100644 |
index 936fcad0c56f6bc85809742f6ae1c1eeb8b7d2f1..0000000000000000000000000000000000000000 |
--- a/third_party/sqlite/sqlite-src-3080704/src/test_superlock.c |
+++ /dev/null |
@@ -1,356 +0,0 @@ |
-/* |
-** 2010 November 19 |
-** |
-** The author disclaims copyright to this source code. In place of |
-** a legal notice, here is a blessing: |
-** |
-** May you do good and not evil. |
-** May you find forgiveness for yourself and forgive others. |
-** May you share freely, never taking more than you give. |
-** |
-************************************************************************* |
-** Example code for obtaining an exclusive lock on an SQLite database |
-** file. This method is complicated, but works for both WAL and rollback |
-** mode database files. The interface to the example code in this file |
-** consists of the following two functions: |
-** |
-** sqlite3demo_superlock() |
-** sqlite3demo_superunlock() |
-*/ |
- |
-#include <sqlite3.h> |
-#include <string.h> /* memset(), strlen() */ |
-#include <assert.h> /* assert() */ |
- |
-/* |
-** A structure to collect a busy-handler callback and argument and a count |
-** of the number of times it has been invoked. |
-*/ |
-struct SuperlockBusy { |
- int (*xBusy)(void*,int); /* Pointer to busy-handler function */ |
- void *pBusyArg; /* First arg to pass to xBusy */ |
- int nBusy; /* Number of times xBusy has been invoked */ |
-}; |
-typedef struct SuperlockBusy SuperlockBusy; |
- |
-/* |
-** An instance of the following structure is allocated for each active |
-** superlock. The opaque handle returned by sqlite3demo_superlock() is |
-** actually a pointer to an instance of this structure. |
-*/ |
-struct Superlock { |
- sqlite3 *db; /* Database handle used to lock db */ |
- int bWal; /* True if db is a WAL database */ |
-}; |
-typedef struct Superlock Superlock; |
- |
-/* |
-** The pCtx pointer passed to this function is actually a pointer to a |
-** SuperlockBusy structure. Invoke the busy-handler function encapsulated |
-** by the structure and return the result. |
-*/ |
-static int superlockBusyHandler(void *pCtx, int UNUSED){ |
- SuperlockBusy *pBusy = (SuperlockBusy *)pCtx; |
- if( pBusy->xBusy==0 ) return 0; |
- return pBusy->xBusy(pBusy->pBusyArg, pBusy->nBusy++); |
-} |
- |
-/* |
-** This function is used to determine if the main database file for |
-** connection db is open in WAL mode or not. If no error occurs and the |
-** database file is in WAL mode, set *pbWal to true and return SQLITE_OK. |
-** If it is not in WAL mode, set *pbWal to false. |
-** |
-** If an error occurs, return an SQLite error code. The value of *pbWal |
-** is undefined in this case. |
-*/ |
-static int superlockIsWal(Superlock *pLock){ |
- int rc; /* Return Code */ |
- sqlite3_stmt *pStmt; /* Compiled PRAGMA journal_mode statement */ |
- |
- rc = sqlite3_prepare(pLock->db, "PRAGMA main.journal_mode", -1, &pStmt, 0); |
- if( rc!=SQLITE_OK ) return rc; |
- |
- pLock->bWal = 0; |
- if( SQLITE_ROW==sqlite3_step(pStmt) ){ |
- const char *zMode = (const char *)sqlite3_column_text(pStmt, 0); |
- if( zMode && strlen(zMode)==3 && sqlite3_strnicmp("wal", zMode, 3)==0 ){ |
- pLock->bWal = 1; |
- } |
- } |
- |
- return sqlite3_finalize(pStmt); |
-} |
- |
-/* |
-** Obtain an exclusive shm-lock on nByte bytes starting at offset idx |
-** of the file fd. If the lock cannot be obtained immediately, invoke |
-** the busy-handler until either it is obtained or the busy-handler |
-** callback returns 0. |
-*/ |
-static int superlockShmLock( |
- sqlite3_file *fd, /* Database file handle */ |
- int idx, /* Offset of shm-lock to obtain */ |
- int nByte, /* Number of consective bytes to lock */ |
- SuperlockBusy *pBusy /* Busy-handler wrapper object */ |
-){ |
- int rc; |
- int (*xShmLock)(sqlite3_file*, int, int, int) = fd->pMethods->xShmLock; |
- do { |
- rc = xShmLock(fd, idx, nByte, SQLITE_SHM_LOCK|SQLITE_SHM_EXCLUSIVE); |
- }while( rc==SQLITE_BUSY && superlockBusyHandler((void *)pBusy, 0) ); |
- return rc; |
-} |
- |
-/* |
-** Obtain the extra locks on the database file required for WAL databases. |
-** Invoke the supplied busy-handler as required. |
-*/ |
-static int superlockWalLock( |
- sqlite3 *db, /* Database handle open on WAL database */ |
- SuperlockBusy *pBusy /* Busy handler wrapper object */ |
-){ |
- int rc; /* Return code */ |
- sqlite3_file *fd = 0; /* Main database file handle */ |
- void volatile *p = 0; /* Pointer to first page of shared memory */ |
- |
- /* Obtain a pointer to the sqlite3_file object open on the main db file. */ |
- rc = sqlite3_file_control(db, "main", SQLITE_FCNTL_FILE_POINTER, (void *)&fd); |
- if( rc!=SQLITE_OK ) return rc; |
- |
- /* Obtain the "recovery" lock. Normally, this lock is only obtained by |
- ** clients running database recovery. |
- */ |
- rc = superlockShmLock(fd, 2, 1, pBusy); |
- if( rc!=SQLITE_OK ) return rc; |
- |
- /* Zero the start of the first shared-memory page. This means that any |
- ** clients that open read or write transactions from this point on will |
- ** have to run recovery before proceeding. Since they need the "recovery" |
- ** lock that this process is holding to do that, no new read or write |
- ** transactions may now be opened. Nor can a checkpoint be run, for the |
- ** same reason. |
- */ |
- rc = fd->pMethods->xShmMap(fd, 0, 32*1024, 1, &p); |
- if( rc!=SQLITE_OK ) return rc; |
- memset((void *)p, 0, 32); |
- |
- /* Obtain exclusive locks on all the "read-lock" slots. Once these locks |
- ** are held, it is guaranteed that there are no active reader, writer or |
- ** checkpointer clients. |
- */ |
- rc = superlockShmLock(fd, 3, SQLITE_SHM_NLOCK-3, pBusy); |
- return rc; |
-} |
- |
-/* |
-** Release a superlock held on a database file. The argument passed to |
-** this function must have been obtained from a successful call to |
-** sqlite3demo_superlock(). |
-*/ |
-void sqlite3demo_superunlock(void *pLock){ |
- Superlock *p = (Superlock *)pLock; |
- if( p->bWal ){ |
- int rc; /* Return code */ |
- int flags = SQLITE_SHM_UNLOCK | SQLITE_SHM_EXCLUSIVE; |
- sqlite3_file *fd = 0; |
- rc = sqlite3_file_control(p->db, "main", SQLITE_FCNTL_FILE_POINTER, (void *)&fd); |
- if( rc==SQLITE_OK ){ |
- fd->pMethods->xShmLock(fd, 2, 1, flags); |
- fd->pMethods->xShmLock(fd, 3, SQLITE_SHM_NLOCK-3, flags); |
- } |
- } |
- sqlite3_close(p->db); |
- sqlite3_free(p); |
-} |
- |
-/* |
-** Obtain a superlock on the database file identified by zPath, using the |
-** locking primitives provided by VFS zVfs. If successful, SQLITE_OK is |
-** returned and output variable *ppLock is populated with an opaque handle |
-** that may be used with sqlite3demo_superunlock() to release the lock. |
-** |
-** If an error occurs, *ppLock is set to 0 and an SQLite error code |
-** (e.g. SQLITE_BUSY) is returned. |
-** |
-** If a required lock cannot be obtained immediately and the xBusy parameter |
-** to this function is not NULL, then xBusy is invoked in the same way |
-** as a busy-handler registered with SQLite (using sqlite3_busy_handler()) |
-** until either the lock can be obtained or the busy-handler function returns |
-** 0 (indicating "give up"). |
-*/ |
-int sqlite3demo_superlock( |
- const char *zPath, /* Path to database file to lock */ |
- const char *zVfs, /* VFS to use to access database file */ |
- int (*xBusy)(void*,int), /* Busy handler callback */ |
- void *pBusyArg, /* Context arg for busy handler */ |
- void **ppLock /* OUT: Context to pass to superunlock() */ |
-){ |
- SuperlockBusy busy = {0, 0, 0}; /* Busy handler wrapper object */ |
- int rc; /* Return code */ |
- Superlock *pLock; |
- |
- pLock = sqlite3_malloc(sizeof(Superlock)); |
- if( !pLock ) return SQLITE_NOMEM; |
- memset(pLock, 0, sizeof(Superlock)); |
- |
- /* Open a database handle on the file to superlock. */ |
- rc = sqlite3_open_v2( |
- zPath, &pLock->db, SQLITE_OPEN_READWRITE|SQLITE_OPEN_CREATE, zVfs |
- ); |
- |
- /* Install a busy-handler and execute a BEGIN EXCLUSIVE. If this is not |
- ** a WAL database, this is all we need to do. |
- ** |
- ** A wrapper function is used to invoke the busy-handler instead of |
- ** registering the busy-handler function supplied by the user directly |
- ** with SQLite. This is because the same busy-handler function may be |
- ** invoked directly later on when attempting to obtain the extra locks |
- ** required in WAL mode. By using the wrapper, we are able to guarantee |
- ** that the "nBusy" integer parameter passed to the users busy-handler |
- ** represents the total number of busy-handler invocations made within |
- ** this call to sqlite3demo_superlock(), including any made during the |
- ** "BEGIN EXCLUSIVE". |
- */ |
- if( rc==SQLITE_OK ){ |
- busy.xBusy = xBusy; |
- busy.pBusyArg = pBusyArg; |
- sqlite3_busy_handler(pLock->db, superlockBusyHandler, (void *)&busy); |
- rc = sqlite3_exec(pLock->db, "BEGIN EXCLUSIVE", 0, 0, 0); |
- } |
- |
- /* If the BEGIN EXCLUSIVE was executed successfully and this is a WAL |
- ** database, call superlockWalLock() to obtain the extra locks required |
- ** to prevent readers, writers and/or checkpointers from accessing the |
- ** db while this process is holding the superlock. |
- ** |
- ** Before attempting any WAL locks, commit the transaction started above |
- ** to drop the WAL read and write locks currently held. Otherwise, the |
- ** new WAL locks may conflict with the old. |
- */ |
- if( rc==SQLITE_OK ){ |
- if( SQLITE_OK==(rc = superlockIsWal(pLock)) && pLock->bWal ){ |
- rc = sqlite3_exec(pLock->db, "COMMIT", 0, 0, 0); |
- if( rc==SQLITE_OK ){ |
- rc = superlockWalLock(pLock->db, &busy); |
- } |
- } |
- } |
- |
- if( rc!=SQLITE_OK ){ |
- sqlite3demo_superunlock(pLock); |
- *ppLock = 0; |
- }else{ |
- *ppLock = pLock; |
- } |
- |
- return rc; |
-} |
- |
-/* |
-** End of example code. Everything below here is the test harness. |
-************************************************************************** |
-************************************************************************** |
-*************************************************************************/ |
- |
- |
-#ifdef SQLITE_TEST |
- |
-#include <tcl.h> |
- |
-struct InterpAndScript { |
- Tcl_Interp *interp; |
- Tcl_Obj *pScript; |
-}; |
-typedef struct InterpAndScript InterpAndScript; |
- |
-static void superunlock_del(ClientData cd){ |
- sqlite3demo_superunlock((void *)cd); |
-} |
- |
-static int superunlock_cmd( |
- ClientData cd, |
- Tcl_Interp *interp, |
- int objc, |
- Tcl_Obj *CONST objv[] |
-){ |
- if( objc!=1 ){ |
- Tcl_WrongNumArgs(interp, 1, objv, ""); |
- return TCL_ERROR; |
- } |
- Tcl_DeleteCommand(interp, Tcl_GetString(objv[0])); |
- return TCL_OK; |
-} |
- |
-static int superlock_busy(void *pCtx, int nBusy){ |
- InterpAndScript *p = (InterpAndScript *)pCtx; |
- Tcl_Obj *pEval; /* Script to evaluate */ |
- int iVal = 0; /* Value to return */ |
- |
- pEval = Tcl_DuplicateObj(p->pScript); |
- Tcl_IncrRefCount(pEval); |
- Tcl_ListObjAppendElement(p->interp, pEval, Tcl_NewIntObj(nBusy)); |
- Tcl_EvalObjEx(p->interp, pEval, TCL_EVAL_GLOBAL); |
- Tcl_GetIntFromObj(p->interp, Tcl_GetObjResult(p->interp), &iVal); |
- Tcl_DecrRefCount(pEval); |
- |
- return iVal; |
-} |
- |
-/* |
-** Tclcmd: sqlite3demo_superlock CMDNAME PATH VFS BUSY-HANDLER-SCRIPT |
-*/ |
-static int superlock_cmd( |
- ClientData cd, |
- Tcl_Interp *interp, |
- int objc, |
- Tcl_Obj *CONST objv[] |
-){ |
- void *pLock; /* Lock context */ |
- char *zPath; |
- char *zVfs = 0; |
- InterpAndScript busy = {0, 0}; |
- int (*xBusy)(void*,int) = 0; /* Busy handler callback */ |
- int rc; /* Return code from sqlite3demo_superlock() */ |
- |
- if( objc<3 || objc>5 ){ |
- Tcl_WrongNumArgs( |
- interp, 1, objv, "CMDNAME PATH ?VFS? ?BUSY-HANDLER-SCRIPT?"); |
- return TCL_ERROR; |
- } |
- |
- zPath = Tcl_GetString(objv[2]); |
- |
- if( objc>3 ){ |
- zVfs = Tcl_GetString(objv[3]); |
- if( strlen(zVfs)==0 ) zVfs = 0; |
- } |
- if( objc>4 ){ |
- busy.interp = interp; |
- busy.pScript = objv[4]; |
- xBusy = superlock_busy; |
- } |
- |
- rc = sqlite3demo_superlock(zPath, zVfs, xBusy, &busy, &pLock); |
- assert( rc==SQLITE_OK || pLock==0 ); |
- assert( rc!=SQLITE_OK || pLock!=0 ); |
- |
- if( rc!=SQLITE_OK ){ |
- extern const char *sqlite3ErrStr(int); |
- Tcl_ResetResult(interp); |
- Tcl_AppendResult(interp, sqlite3ErrStr(rc), 0); |
- return TCL_ERROR; |
- } |
- |
- Tcl_CreateObjCommand( |
- interp, Tcl_GetString(objv[1]), superunlock_cmd, pLock, superunlock_del |
- ); |
- Tcl_SetObjResult(interp, objv[1]); |
- return TCL_OK; |
-} |
- |
-int SqliteSuperlock_Init(Tcl_Interp *interp){ |
- Tcl_CreateObjCommand(interp, "sqlite3demo_superlock", superlock_cmd, 0, 0); |
- return TCL_OK; |
-} |
-#endif |