Import SQLite 3.7.6.3.

third_party/sqlite/src/src/test_thread.c

 /*
 ** 2007 September 9
 **
 ** 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.
 **
 *************************************************************************
 **
 ** This file contains the implementation of some Tcl commands used to
 ** test that sqlite3 database handles may be concurrently accessed by 
 ** multiple threads. Right now this only works on unix.
-**
-** $Id: test_thread.c,v 1.15 2009/03/27 12:32:56 drh Exp $
 */
 
 #include "sqliteInt.h"
 #include <tcl.h>
 
 #if SQLITE_THREADSAFE
 
 #include <errno.h>
 
 #if !defined(_MSC_VER)
@@ skipping 20 matching lines @@
 */
 typedef struct EvalEvent EvalEvent;
 struct EvalEvent {
   Tcl_Event base;          /* Base class of type Tcl_Event */
   char *zScript;           /* The script to execute. */
   Tcl_Interp *interp;      /* The interpreter to execute it in. */
 };
 
 static Tcl_ObjCmdProc sqlthread_proc;
 static Tcl_ObjCmdProc clock_seconds_proc;
-#if defined(SQLITE_OS_UNIX) && defined(SQLITE_ENABLE_UNLOCK_NOTIFY)
+#if SQLITE_OS_UNIX && defined(SQLITE_ENABLE_UNLOCK_NOTIFY)
 static Tcl_ObjCmdProc blocking_step_proc;
 static Tcl_ObjCmdProc blocking_prepare_v2_proc;
 #endif
 int Sqlitetest1_Init(Tcl_Interp *);
+int Sqlite3_Init(Tcl_Interp *);
 
 /* Functions from test1.c */
 void *sqlite3TestTextToPtr(const char *);
 const char *sqlite3TestErrorName(int);
 int getDbPointer(Tcl_Interp *, const char *, sqlite3 **);
 int sqlite3TestMakePointerStr(Tcl_Interp *, char *, void *);
 int sqlite3TestErrCode(Tcl_Interp *, sqlite3 *, int);
 
 /*
 ** Handler for events of type EvalEvent.
@@ skipping 37 matching lines @@
   Tcl_Interp *interp;
   Tcl_Obj *pRes;
   Tcl_Obj *pList;
   int rc;
   SqlThread *p = (SqlThread *)pSqlThread;
   extern int Sqlitetest_mutex_Init(Tcl_Interp*);
 
   interp = Tcl_CreateInterp();
   Tcl_CreateObjCommand(interp, "clock_seconds", clock_seconds_proc, 0, 0);
   Tcl_CreateObjCommand(interp, "sqlthread", sqlthread_proc, pSqlThread, 0);
-#if defined(SQLITE_OS_UNIX) && defined(SQLITE_ENABLE_UNLOCK_NOTIFY)
+#if SQLITE_OS_UNIX && defined(SQLITE_ENABLE_UNLOCK_NOTIFY)
   Tcl_CreateObjCommand(interp, "sqlite3_blocking_step", blocking_step_proc,0,0);
   Tcl_CreateObjCommand(interp, 
       "sqlite3_blocking_prepare_v2", blocking_prepare_v2_proc, (void *)1, 0);
   Tcl_CreateObjCommand(interp, 
       "sqlite3_nonblocking_prepare_v2", blocking_prepare_v2_proc, 0, 0);
 #endif
   Sqlitetest1_Init(interp);
   Sqlitetest_mutex_Init(interp);
+  Sqlite3_Init(interp);
 
   rc = Tcl_Eval(interp, p->zScript);
   pRes = Tcl_GetObjResult(interp);
   pList = Tcl_NewObj();
   Tcl_IncrRefCount(pList);
   Tcl_IncrRefCount(pRes);
 
   if( rc!=TCL_OK ){
     Tcl_ListObjAppendElement(interp, pList, Tcl_NewStringObj("error", -1));
     Tcl_ListObjAppendElement(interp, pList, pRes);
     postToParent(p, pList);
     Tcl_DecrRefCount(pList);
     pList = Tcl_NewObj();
   }
 
   Tcl_ListObjAppendElement(interp, pList, Tcl_NewStringObj("set", -1));
   Tcl_ListObjAppendElement(interp, pList, Tcl_NewStringObj(p->zVarname, -1));
   Tcl_ListObjAppendElement(interp, pList, pRes);
   postToParent(p, pList);
 
   ckfree((void *)p);
   Tcl_DecrRefCount(pList);
   Tcl_DecrRefCount(pRes);
   Tcl_DeleteInterp(interp);
+  while( Tcl_DoOneEvent(TCL_ALL_EVENTS|TCL_DONT_WAIT) );
+  Tcl_ExitThread(0);
   TCL_THREAD_CREATE_RETURN;
 }
 
 /*
 ** sqlthread spawn VARNAME SCRIPT
 **
 **     Spawn a new thread with its own Tcl interpreter and run the
 **     specified SCRIPT(s) in it. The thread terminates after running
 **     the script. The result of the script is stored in the variable
 **     VARNAME.
@@ skipping 220 matching lines @@
 ** is only available on UNIX for now. This is because pthread condition
 ** variables are used.
 **
 ** The source code for the C functions sqlite3_blocking_step(),
 ** blocking_step_notify() and the structure UnlockNotification is
 ** automatically extracted from this file and used as part of the
 ** documentation for the sqlite3_unlock_notify() API function. This
 ** should be considered if these functions are to be extended (i.e. to 
 ** support windows) in the future.
 */ 
-#if defined(SQLITE_OS_UNIX) && defined(SQLITE_ENABLE_UNLOCK_NOTIFY)
+#if SQLITE_OS_UNIX && defined(SQLITE_ENABLE_UNLOCK_NOTIFY)
 
 /* BEGIN_SQLITE_BLOCKING_STEP */
 /* This example uses the pthreads API */
 #include <pthread.h>
 
 /*
 ** A pointer to an instance of this structure is passed as the user-context
 ** pointer when registering for an unlock-notify callback.
 */
 typedef struct UnlockNotification UnlockNotification;
@@ skipping 201 matching lines @@
 /*
 ** End of implementation of [sqlite3_blocking_step].
 ************************************************************************/
 
 /*
 ** Register commands with the TCL interpreter.
 */
 int SqlitetestThread_Init(Tcl_Interp *interp){
   Tcl_CreateObjCommand(interp, "sqlthread", sqlthread_proc, 0, 0);
   Tcl_CreateObjCommand(interp, "clock_seconds", clock_seconds_proc, 0, 0);
-#if defined(SQLITE_OS_UNIX) && defined(SQLITE_ENABLE_UNLOCK_NOTIFY)
+#if SQLITE_OS_UNIX && defined(SQLITE_ENABLE_UNLOCK_NOTIFY)
   Tcl_CreateObjCommand(interp, "sqlite3_blocking_step", blocking_step_proc,0,0);
   Tcl_CreateObjCommand(interp, 
       "sqlite3_blocking_prepare_v2", blocking_prepare_v2_proc, (void *)1, 0);
   Tcl_CreateObjCommand(interp, 
       "sqlite3_nonblocking_prepare_v2", blocking_prepare_v2_proc, 0, 0);
 #endif
   return TCL_OK;
 }
 #else
 int SqlitetestThread_Init(Tcl_Interp *interp){
   return TCL_OK;
 }
 #endif