1.1 --- /dev/null Thu Jan 01 00:00:00 1970 +0000
1.2 +++ b/os/persistentdata/persistentstorage/sqlite3api/TEST/SRC/test4.c Fri Jun 15 03:10:57 2012 +0200
1.3 @@ -0,0 +1,716 @@
1.4 +/*
1.5 +** 2003 December 18
1.6 +**
1.7 +** The author disclaims copyright to this source code. In place of
1.8 +** a legal notice, here is a blessing:
1.9 +**
1.10 +** May you do good and not evil.
1.11 +** May you find forgiveness for yourself and forgive others.
1.12 +** May you share freely, never taking more than you give.
1.13 +**
1.14 +*************************************************************************
1.15 +** Code for testing the the SQLite library in a multithreaded environment.
1.16 +**
1.17 +** $Id: test4.c,v 1.23 2008/07/28 19:34:54 drh Exp $
1.18 +*/
1.19 +#include "sqliteInt.h"
1.20 +#include "tcl.h"
1.21 +#if defined(SQLITE_OS_UNIX) && OS_UNIX==1 && SQLITE_THREADSAFE
1.22 +#include <stdlib.h>
1.23 +#include <string.h>
1.24 +#include <pthread.h>
1.25 +#include <sched.h>
1.26 +#include <ctype.h>
1.27 +
1.28 +/*
1.29 +** Each thread is controlled by an instance of the following
1.30 +** structure.
1.31 +*/
1.32 +typedef struct Thread Thread;
1.33 +struct Thread {
1.34 + /* The first group of fields are writable by the master and read-only
1.35 + ** to the thread. */
1.36 + char *zFilename; /* Name of database file */
1.37 + void (*xOp)(Thread*); /* next operation to do */
1.38 + char *zArg; /* argument usable by xOp */
1.39 + int opnum; /* Operation number */
1.40 + int busy; /* True if this thread is in use */
1.41 +
1.42 + /* The next group of fields are writable by the thread but read-only to the
1.43 + ** master. */
1.44 + int completed; /* Number of operations completed */
1.45 + sqlite3 *db; /* Open database */
1.46 + sqlite3_stmt *pStmt; /* Pending operation */
1.47 + char *zErr; /* operation error */
1.48 + char *zStaticErr; /* Static error message */
1.49 + int rc; /* operation return code */
1.50 + int argc; /* number of columns in result */
1.51 + const char *argv[100]; /* result columns */
1.52 + const char *colv[100]; /* result column names */
1.53 +};
1.54 +
1.55 +/*
1.56 +** There can be as many as 26 threads running at once. Each is named
1.57 +** by a capital letter: A, B, C, ..., Y, Z.
1.58 +*/
1.59 +#define N_THREAD 26
1.60 +static Thread threadset[N_THREAD];
1.61 +
1.62 +
1.63 +/*
1.64 +** The main loop for a thread. Threads use busy waiting.
1.65 +*/
1.66 +static void *thread_main(void *pArg){
1.67 + Thread *p = (Thread*)pArg;
1.68 + if( p->db ){
1.69 + sqlite3_close(p->db);
1.70 + }
1.71 + sqlite3_open(p->zFilename, &p->db);
1.72 + if( SQLITE_OK!=sqlite3_errcode(p->db) ){
1.73 + p->zErr = strdup(sqlite3_errmsg(p->db));
1.74 + sqlite3_close(p->db);
1.75 + p->db = 0;
1.76 + }
1.77 + p->pStmt = 0;
1.78 + p->completed = 1;
1.79 + while( p->opnum<=p->completed ) sched_yield();
1.80 + while( p->xOp ){
1.81 + if( p->zErr && p->zErr!=p->zStaticErr ){
1.82 + sqlite3_free(p->zErr);
1.83 + p->zErr = 0;
1.84 + }
1.85 + (*p->xOp)(p);
1.86 + p->completed++;
1.87 + while( p->opnum<=p->completed ) sched_yield();
1.88 + }
1.89 + if( p->pStmt ){
1.90 + sqlite3_finalize(p->pStmt);
1.91 + p->pStmt = 0;
1.92 + }
1.93 + if( p->db ){
1.94 + sqlite3_close(p->db);
1.95 + p->db = 0;
1.96 + }
1.97 + if( p->zErr && p->zErr!=p->zStaticErr ){
1.98 + sqlite3_free(p->zErr);
1.99 + p->zErr = 0;
1.100 + }
1.101 + p->completed++;
1.102 + sqlite3_thread_cleanup();
1.103 + return 0;
1.104 +}
1.105 +
1.106 +/*
1.107 +** Get a thread ID which is an upper case letter. Return the index.
1.108 +** If the argument is not a valid thread ID put an error message in
1.109 +** the interpreter and return -1.
1.110 +*/
1.111 +static int parse_thread_id(Tcl_Interp *interp, const char *zArg){
1.112 + if( zArg==0 || zArg[0]==0 || zArg[1]!=0 || !isupper((unsigned char)zArg[0]) ){
1.113 + Tcl_AppendResult(interp, "thread ID must be an upper case letter", 0);
1.114 + return -1;
1.115 + }
1.116 + return zArg[0] - 'A';
1.117 +}
1.118 +
1.119 +/*
1.120 +** Usage: thread_create NAME FILENAME
1.121 +**
1.122 +** NAME should be an upper case letter. Start the thread running with
1.123 +** an open connection to the given database.
1.124 +*/
1.125 +static int tcl_thread_create(
1.126 + void *NotUsed,
1.127 + Tcl_Interp *interp, /* The TCL interpreter that invoked this command */
1.128 + int argc, /* Number of arguments */
1.129 + const char **argv /* Text of each argument */
1.130 +){
1.131 + int i;
1.132 + pthread_t x;
1.133 + int rc;
1.134 +
1.135 + if( argc!=3 ){
1.136 + Tcl_AppendResult(interp, "wrong # args: should be \"", argv[0],
1.137 + " ID FILENAME", 0);
1.138 + return TCL_ERROR;
1.139 + }
1.140 + i = parse_thread_id(interp, argv[1]);
1.141 + if( i<0 ) return TCL_ERROR;
1.142 + if( threadset[i].busy ){
1.143 + Tcl_AppendResult(interp, "thread ", argv[1], " is already running", 0);
1.144 + return TCL_ERROR;
1.145 + }
1.146 + threadset[i].busy = 1;
1.147 + sqlite3_free(threadset[i].zFilename);
1.148 + threadset[i].zFilename = sqlite3DbStrDup(0, argv[2]);
1.149 + threadset[i].opnum = 1;
1.150 + threadset[i].completed = 0;
1.151 + rc = pthread_create(&x, 0, thread_main, &threadset[i]);
1.152 + if( rc ){
1.153 + Tcl_AppendResult(interp, "failed to create the thread", 0);
1.154 + sqlite3_free(threadset[i].zFilename);
1.155 + threadset[i].busy = 0;
1.156 + return TCL_ERROR;
1.157 + }
1.158 + pthread_detach(x);
1.159 + return TCL_OK;
1.160 +}
1.161 +
1.162 +/*
1.163 +** Wait for a thread to reach its idle state.
1.164 +*/
1.165 +static void thread_wait(Thread *p){
1.166 + while( p->opnum>p->completed ) sched_yield();
1.167 +}
1.168 +
1.169 +/*
1.170 +** Usage: thread_wait ID
1.171 +**
1.172 +** Wait on thread ID to reach its idle state.
1.173 +*/
1.174 +static int tcl_thread_wait(
1.175 + void *NotUsed,
1.176 + Tcl_Interp *interp, /* The TCL interpreter that invoked this command */
1.177 + int argc, /* Number of arguments */
1.178 + const char **argv /* Text of each argument */
1.179 +){
1.180 + int i;
1.181 +
1.182 + if( argc!=2 ){
1.183 + Tcl_AppendResult(interp, "wrong # args: should be \"", argv[0],
1.184 + " ID", 0);
1.185 + return TCL_ERROR;
1.186 + }
1.187 + i = parse_thread_id(interp, argv[1]);
1.188 + if( i<0 ) return TCL_ERROR;
1.189 + if( !threadset[i].busy ){
1.190 + Tcl_AppendResult(interp, "no such thread", 0);
1.191 + return TCL_ERROR;
1.192 + }
1.193 + thread_wait(&threadset[i]);
1.194 + return TCL_OK;
1.195 +}
1.196 +
1.197 +/*
1.198 +** Stop a thread.
1.199 +*/
1.200 +static void stop_thread(Thread *p){
1.201 + thread_wait(p);
1.202 + p->xOp = 0;
1.203 + p->opnum++;
1.204 + thread_wait(p);
1.205 + sqlite3_free(p->zArg);
1.206 + p->zArg = 0;
1.207 + sqlite3_free(p->zFilename);
1.208 + p->zFilename = 0;
1.209 + p->busy = 0;
1.210 +}
1.211 +
1.212 +/*
1.213 +** Usage: thread_halt ID
1.214 +**
1.215 +** Cause a thread to shut itself down. Wait for the shutdown to be
1.216 +** completed. If ID is "*" then stop all threads.
1.217 +*/
1.218 +static int tcl_thread_halt(
1.219 + void *NotUsed,
1.220 + Tcl_Interp *interp, /* The TCL interpreter that invoked this command */
1.221 + int argc, /* Number of arguments */
1.222 + const char **argv /* Text of each argument */
1.223 +){
1.224 + int i;
1.225 +
1.226 + if( argc!=2 ){
1.227 + Tcl_AppendResult(interp, "wrong # args: should be \"", argv[0],
1.228 + " ID", 0);
1.229 + return TCL_ERROR;
1.230 + }
1.231 + if( argv[1][0]=='*' && argv[1][1]==0 ){
1.232 + for(i=0; i<N_THREAD; i++){
1.233 + if( threadset[i].busy ) stop_thread(&threadset[i]);
1.234 + }
1.235 + }else{
1.236 + i = parse_thread_id(interp, argv[1]);
1.237 + if( i<0 ) return TCL_ERROR;
1.238 + if( !threadset[i].busy ){
1.239 + Tcl_AppendResult(interp, "no such thread", 0);
1.240 + return TCL_ERROR;
1.241 + }
1.242 + stop_thread(&threadset[i]);
1.243 + }
1.244 + return TCL_OK;
1.245 +}
1.246 +
1.247 +/*
1.248 +** Usage: thread_argc ID
1.249 +**
1.250 +** Wait on the most recent thread_step to complete, then return the
1.251 +** number of columns in the result set.
1.252 +*/
1.253 +static int tcl_thread_argc(
1.254 + void *NotUsed,
1.255 + Tcl_Interp *interp, /* The TCL interpreter that invoked this command */
1.256 + int argc, /* Number of arguments */
1.257 + const char **argv /* Text of each argument */
1.258 +){
1.259 + int i;
1.260 + char zBuf[100];
1.261 +
1.262 + if( argc!=2 ){
1.263 + Tcl_AppendResult(interp, "wrong # args: should be \"", argv[0],
1.264 + " ID", 0);
1.265 + return TCL_ERROR;
1.266 + }
1.267 + i = parse_thread_id(interp, argv[1]);
1.268 + if( i<0 ) return TCL_ERROR;
1.269 + if( !threadset[i].busy ){
1.270 + Tcl_AppendResult(interp, "no such thread", 0);
1.271 + return TCL_ERROR;
1.272 + }
1.273 + thread_wait(&threadset[i]);
1.274 + sprintf(zBuf, "%d", threadset[i].argc);
1.275 + Tcl_AppendResult(interp, zBuf, 0);
1.276 + return TCL_OK;
1.277 +}
1.278 +
1.279 +/*
1.280 +** Usage: thread_argv ID N
1.281 +**
1.282 +** Wait on the most recent thread_step to complete, then return the
1.283 +** value of the N-th columns in the result set.
1.284 +*/
1.285 +static int tcl_thread_argv(
1.286 + void *NotUsed,
1.287 + Tcl_Interp *interp, /* The TCL interpreter that invoked this command */
1.288 + int argc, /* Number of arguments */
1.289 + const char **argv /* Text of each argument */
1.290 +){
1.291 + int i;
1.292 + int n;
1.293 +
1.294 + if( argc!=3 ){
1.295 + Tcl_AppendResult(interp, "wrong # args: should be \"", argv[0],
1.296 + " ID N", 0);
1.297 + return TCL_ERROR;
1.298 + }
1.299 + i = parse_thread_id(interp, argv[1]);
1.300 + if( i<0 ) return TCL_ERROR;
1.301 + if( !threadset[i].busy ){
1.302 + Tcl_AppendResult(interp, "no such thread", 0);
1.303 + return TCL_ERROR;
1.304 + }
1.305 + if( Tcl_GetInt(interp, argv[2], &n) ) return TCL_ERROR;
1.306 + thread_wait(&threadset[i]);
1.307 + if( n<0 || n>=threadset[i].argc ){
1.308 + Tcl_AppendResult(interp, "column number out of range", 0);
1.309 + return TCL_ERROR;
1.310 + }
1.311 + Tcl_AppendResult(interp, threadset[i].argv[n], 0);
1.312 + return TCL_OK;
1.313 +}
1.314 +
1.315 +/*
1.316 +** Usage: thread_colname ID N
1.317 +**
1.318 +** Wait on the most recent thread_step to complete, then return the
1.319 +** name of the N-th columns in the result set.
1.320 +*/
1.321 +static int tcl_thread_colname(
1.322 + void *NotUsed,
1.323 + Tcl_Interp *interp, /* The TCL interpreter that invoked this command */
1.324 + int argc, /* Number of arguments */
1.325 + const char **argv /* Text of each argument */
1.326 +){
1.327 + int i;
1.328 + int n;
1.329 +
1.330 + if( argc!=3 ){
1.331 + Tcl_AppendResult(interp, "wrong # args: should be \"", argv[0],
1.332 + " ID N", 0);
1.333 + return TCL_ERROR;
1.334 + }
1.335 + i = parse_thread_id(interp, argv[1]);
1.336 + if( i<0 ) return TCL_ERROR;
1.337 + if( !threadset[i].busy ){
1.338 + Tcl_AppendResult(interp, "no such thread", 0);
1.339 + return TCL_ERROR;
1.340 + }
1.341 + if( Tcl_GetInt(interp, argv[2], &n) ) return TCL_ERROR;
1.342 + thread_wait(&threadset[i]);
1.343 + if( n<0 || n>=threadset[i].argc ){
1.344 + Tcl_AppendResult(interp, "column number out of range", 0);
1.345 + return TCL_ERROR;
1.346 + }
1.347 + Tcl_AppendResult(interp, threadset[i].colv[n], 0);
1.348 + return TCL_OK;
1.349 +}
1.350 +
1.351 +/*
1.352 +** Usage: thread_result ID
1.353 +**
1.354 +** Wait on the most recent operation to complete, then return the
1.355 +** result code from that operation.
1.356 +*/
1.357 +static int tcl_thread_result(
1.358 + void *NotUsed,
1.359 + Tcl_Interp *interp, /* The TCL interpreter that invoked this command */
1.360 + int argc, /* Number of arguments */
1.361 + const char **argv /* Text of each argument */
1.362 +){
1.363 + int i;
1.364 + const char *zName;
1.365 +
1.366 + if( argc!=2 ){
1.367 + Tcl_AppendResult(interp, "wrong # args: should be \"", argv[0],
1.368 + " ID", 0);
1.369 + return TCL_ERROR;
1.370 + }
1.371 + i = parse_thread_id(interp, argv[1]);
1.372 + if( i<0 ) return TCL_ERROR;
1.373 + if( !threadset[i].busy ){
1.374 + Tcl_AppendResult(interp, "no such thread", 0);
1.375 + return TCL_ERROR;
1.376 + }
1.377 + thread_wait(&threadset[i]);
1.378 + switch( threadset[i].rc ){
1.379 + case SQLITE_OK: zName = "SQLITE_OK"; break;
1.380 + case SQLITE_ERROR: zName = "SQLITE_ERROR"; break;
1.381 + case SQLITE_PERM: zName = "SQLITE_PERM"; break;
1.382 + case SQLITE_ABORT: zName = "SQLITE_ABORT"; break;
1.383 + case SQLITE_BUSY: zName = "SQLITE_BUSY"; break;
1.384 + case SQLITE_LOCKED: zName = "SQLITE_LOCKED"; break;
1.385 + case SQLITE_NOMEM: zName = "SQLITE_NOMEM"; break;
1.386 + case SQLITE_READONLY: zName = "SQLITE_READONLY"; break;
1.387 + case SQLITE_INTERRUPT: zName = "SQLITE_INTERRUPT"; break;
1.388 + case SQLITE_IOERR: zName = "SQLITE_IOERR"; break;
1.389 + case SQLITE_CORRUPT: zName = "SQLITE_CORRUPT"; break;
1.390 + case SQLITE_FULL: zName = "SQLITE_FULL"; break;
1.391 + case SQLITE_CANTOPEN: zName = "SQLITE_CANTOPEN"; break;
1.392 + case SQLITE_PROTOCOL: zName = "SQLITE_PROTOCOL"; break;
1.393 + case SQLITE_EMPTY: zName = "SQLITE_EMPTY"; break;
1.394 + case SQLITE_SCHEMA: zName = "SQLITE_SCHEMA"; break;
1.395 + case SQLITE_CONSTRAINT: zName = "SQLITE_CONSTRAINT"; break;
1.396 + case SQLITE_MISMATCH: zName = "SQLITE_MISMATCH"; break;
1.397 + case SQLITE_MISUSE: zName = "SQLITE_MISUSE"; break;
1.398 + case SQLITE_NOLFS: zName = "SQLITE_NOLFS"; break;
1.399 + case SQLITE_AUTH: zName = "SQLITE_AUTH"; break;
1.400 + case SQLITE_FORMAT: zName = "SQLITE_FORMAT"; break;
1.401 + case SQLITE_RANGE: zName = "SQLITE_RANGE"; break;
1.402 + case SQLITE_ROW: zName = "SQLITE_ROW"; break;
1.403 + case SQLITE_DONE: zName = "SQLITE_DONE"; break;
1.404 + default: zName = "SQLITE_Unknown"; break;
1.405 + }
1.406 + Tcl_AppendResult(interp, zName, 0);
1.407 + return TCL_OK;
1.408 +}
1.409 +
1.410 +/*
1.411 +** Usage: thread_error ID
1.412 +**
1.413 +** Wait on the most recent operation to complete, then return the
1.414 +** error string.
1.415 +*/
1.416 +static int tcl_thread_error(
1.417 + void *NotUsed,
1.418 + Tcl_Interp *interp, /* The TCL interpreter that invoked this command */
1.419 + int argc, /* Number of arguments */
1.420 + const char **argv /* Text of each argument */
1.421 +){
1.422 + int i;
1.423 +
1.424 + if( argc!=2 ){
1.425 + Tcl_AppendResult(interp, "wrong # args: should be \"", argv[0],
1.426 + " ID", 0);
1.427 + return TCL_ERROR;
1.428 + }
1.429 + i = parse_thread_id(interp, argv[1]);
1.430 + if( i<0 ) return TCL_ERROR;
1.431 + if( !threadset[i].busy ){
1.432 + Tcl_AppendResult(interp, "no such thread", 0);
1.433 + return TCL_ERROR;
1.434 + }
1.435 + thread_wait(&threadset[i]);
1.436 + Tcl_AppendResult(interp, threadset[i].zErr, 0);
1.437 + return TCL_OK;
1.438 +}
1.439 +
1.440 +/*
1.441 +** This procedure runs in the thread to compile an SQL statement.
1.442 +*/
1.443 +static void do_compile(Thread *p){
1.444 + if( p->db==0 ){
1.445 + p->zErr = p->zStaticErr = "no database is open";
1.446 + p->rc = SQLITE_ERROR;
1.447 + return;
1.448 + }
1.449 + if( p->pStmt ){
1.450 + sqlite3_finalize(p->pStmt);
1.451 + p->pStmt = 0;
1.452 + }
1.453 + p->rc = sqlite3_prepare(p->db, p->zArg, -1, &p->pStmt, 0);
1.454 +}
1.455 +
1.456 +/*
1.457 +** Usage: thread_compile ID SQL
1.458 +**
1.459 +** Compile a new virtual machine.
1.460 +*/
1.461 +static int tcl_thread_compile(
1.462 + void *NotUsed,
1.463 + Tcl_Interp *interp, /* The TCL interpreter that invoked this command */
1.464 + int argc, /* Number of arguments */
1.465 + const char **argv /* Text of each argument */
1.466 +){
1.467 + int i;
1.468 + if( argc!=3 ){
1.469 + Tcl_AppendResult(interp, "wrong # args: should be \"", argv[0],
1.470 + " ID SQL", 0);
1.471 + return TCL_ERROR;
1.472 + }
1.473 + i = parse_thread_id(interp, argv[1]);
1.474 + if( i<0 ) return TCL_ERROR;
1.475 + if( !threadset[i].busy ){
1.476 + Tcl_AppendResult(interp, "no such thread", 0);
1.477 + return TCL_ERROR;
1.478 + }
1.479 + thread_wait(&threadset[i]);
1.480 + threadset[i].xOp = do_compile;
1.481 + sqlite3_free(threadset[i].zArg);
1.482 + threadset[i].zArg = sqlite3DbStrDup(0, argv[2]);
1.483 + threadset[i].opnum++;
1.484 + return TCL_OK;
1.485 +}
1.486 +
1.487 +/*
1.488 +** This procedure runs in the thread to step the virtual machine.
1.489 +*/
1.490 +static void do_step(Thread *p){
1.491 + int i;
1.492 + if( p->pStmt==0 ){
1.493 + p->zErr = p->zStaticErr = "no virtual machine available";
1.494 + p->rc = SQLITE_ERROR;
1.495 + return;
1.496 + }
1.497 + p->rc = sqlite3_step(p->pStmt);
1.498 + if( p->rc==SQLITE_ROW ){
1.499 + p->argc = sqlite3_column_count(p->pStmt);
1.500 + for(i=0; i<sqlite3_data_count(p->pStmt); i++){
1.501 + p->argv[i] = (char*)sqlite3_column_text(p->pStmt, i);
1.502 + }
1.503 + for(i=0; i<p->argc; i++){
1.504 + p->colv[i] = sqlite3_column_name(p->pStmt, i);
1.505 + }
1.506 + }
1.507 +}
1.508 +
1.509 +/*
1.510 +** Usage: thread_step ID
1.511 +**
1.512 +** Advance the virtual machine by one step
1.513 +*/
1.514 +static int tcl_thread_step(
1.515 + void *NotUsed,
1.516 + Tcl_Interp *interp, /* The TCL interpreter that invoked this command */
1.517 + int argc, /* Number of arguments */
1.518 + const char **argv /* Text of each argument */
1.519 +){
1.520 + int i;
1.521 + if( argc!=2 ){
1.522 + Tcl_AppendResult(interp, "wrong # args: should be \"", argv[0],
1.523 + " IDL", 0);
1.524 + return TCL_ERROR;
1.525 + }
1.526 + i = parse_thread_id(interp, argv[1]);
1.527 + if( i<0 ) return TCL_ERROR;
1.528 + if( !threadset[i].busy ){
1.529 + Tcl_AppendResult(interp, "no such thread", 0);
1.530 + return TCL_ERROR;
1.531 + }
1.532 + thread_wait(&threadset[i]);
1.533 + threadset[i].xOp = do_step;
1.534 + threadset[i].opnum++;
1.535 + return TCL_OK;
1.536 +}
1.537 +
1.538 +/*
1.539 +** This procedure runs in the thread to finalize a virtual machine.
1.540 +*/
1.541 +static void do_finalize(Thread *p){
1.542 + if( p->pStmt==0 ){
1.543 + p->zErr = p->zStaticErr = "no virtual machine available";
1.544 + p->rc = SQLITE_ERROR;
1.545 + return;
1.546 + }
1.547 + p->rc = sqlite3_finalize(p->pStmt);
1.548 + p->pStmt = 0;
1.549 +}
1.550 +
1.551 +/*
1.552 +** Usage: thread_finalize ID
1.553 +**
1.554 +** Finalize the virtual machine.
1.555 +*/
1.556 +static int tcl_thread_finalize(
1.557 + void *NotUsed,
1.558 + Tcl_Interp *interp, /* The TCL interpreter that invoked this command */
1.559 + int argc, /* Number of arguments */
1.560 + const char **argv /* Text of each argument */
1.561 +){
1.562 + int i;
1.563 + if( argc!=2 ){
1.564 + Tcl_AppendResult(interp, "wrong # args: should be \"", argv[0],
1.565 + " IDL", 0);
1.566 + return TCL_ERROR;
1.567 + }
1.568 + i = parse_thread_id(interp, argv[1]);
1.569 + if( i<0 ) return TCL_ERROR;
1.570 + if( !threadset[i].busy ){
1.571 + Tcl_AppendResult(interp, "no such thread", 0);
1.572 + return TCL_ERROR;
1.573 + }
1.574 + thread_wait(&threadset[i]);
1.575 + threadset[i].xOp = do_finalize;
1.576 + sqlite3_free(threadset[i].zArg);
1.577 + threadset[i].zArg = 0;
1.578 + threadset[i].opnum++;
1.579 + return TCL_OK;
1.580 +}
1.581 +
1.582 +/*
1.583 +** Usage: thread_swap ID ID
1.584 +**
1.585 +** Interchange the sqlite* pointer between two threads.
1.586 +*/
1.587 +static int tcl_thread_swap(
1.588 + void *NotUsed,
1.589 + Tcl_Interp *interp, /* The TCL interpreter that invoked this command */
1.590 + int argc, /* Number of arguments */
1.591 + const char **argv /* Text of each argument */
1.592 +){
1.593 + int i, j;
1.594 + sqlite3 *temp;
1.595 + if( argc!=3 ){
1.596 + Tcl_AppendResult(interp, "wrong # args: should be \"", argv[0],
1.597 + " ID1 ID2", 0);
1.598 + return TCL_ERROR;
1.599 + }
1.600 + i = parse_thread_id(interp, argv[1]);
1.601 + if( i<0 ) return TCL_ERROR;
1.602 + if( !threadset[i].busy ){
1.603 + Tcl_AppendResult(interp, "no such thread", 0);
1.604 + return TCL_ERROR;
1.605 + }
1.606 + thread_wait(&threadset[i]);
1.607 + j = parse_thread_id(interp, argv[2]);
1.608 + if( j<0 ) return TCL_ERROR;
1.609 + if( !threadset[j].busy ){
1.610 + Tcl_AppendResult(interp, "no such thread", 0);
1.611 + return TCL_ERROR;
1.612 + }
1.613 + thread_wait(&threadset[j]);
1.614 + temp = threadset[i].db;
1.615 + threadset[i].db = threadset[j].db;
1.616 + threadset[j].db = temp;
1.617 + return TCL_OK;
1.618 +}
1.619 +
1.620 +/*
1.621 +** Usage: thread_db_get ID
1.622 +**
1.623 +** Return the database connection pointer for the given thread. Then
1.624 +** remove the pointer from the thread itself. Afterwards, the thread
1.625 +** can be stopped and the connection can be used by the main thread.
1.626 +*/
1.627 +static int tcl_thread_db_get(
1.628 + void *NotUsed,
1.629 + Tcl_Interp *interp, /* The TCL interpreter that invoked this command */
1.630 + int argc, /* Number of arguments */
1.631 + const char **argv /* Text of each argument */
1.632 +){
1.633 + int i;
1.634 + char zBuf[100];
1.635 + extern int sqlite3TestMakePointerStr(Tcl_Interp*, char*, void*);
1.636 + if( argc!=2 ){
1.637 + Tcl_AppendResult(interp, "wrong # args: should be \"", argv[0],
1.638 + " ID", 0);
1.639 + return TCL_ERROR;
1.640 + }
1.641 + i = parse_thread_id(interp, argv[1]);
1.642 + if( i<0 ) return TCL_ERROR;
1.643 + if( !threadset[i].busy ){
1.644 + Tcl_AppendResult(interp, "no such thread", 0);
1.645 + return TCL_ERROR;
1.646 + }
1.647 + thread_wait(&threadset[i]);
1.648 + sqlite3TestMakePointerStr(interp, zBuf, threadset[i].db);
1.649 + threadset[i].db = 0;
1.650 + Tcl_AppendResult(interp, zBuf, (char*)0);
1.651 + return TCL_OK;
1.652 +}
1.653 +
1.654 +/*
1.655 +** Usage: thread_stmt_get ID
1.656 +**
1.657 +** Return the database stmt pointer for the given thread. Then
1.658 +** remove the pointer from the thread itself.
1.659 +*/
1.660 +static int tcl_thread_stmt_get(
1.661 + void *NotUsed,
1.662 + Tcl_Interp *interp, /* The TCL interpreter that invoked this command */
1.663 + int argc, /* Number of arguments */
1.664 + const char **argv /* Text of each argument */
1.665 +){
1.666 + int i;
1.667 + char zBuf[100];
1.668 + extern int sqlite3TestMakePointerStr(Tcl_Interp*, char*, void*);
1.669 + if( argc!=2 ){
1.670 + Tcl_AppendResult(interp, "wrong # args: should be \"", argv[0],
1.671 + " ID", 0);
1.672 + return TCL_ERROR;
1.673 + }
1.674 + i = parse_thread_id(interp, argv[1]);
1.675 + if( i<0 ) return TCL_ERROR;
1.676 + if( !threadset[i].busy ){
1.677 + Tcl_AppendResult(interp, "no such thread", 0);
1.678 + return TCL_ERROR;
1.679 + }
1.680 + thread_wait(&threadset[i]);
1.681 + sqlite3TestMakePointerStr(interp, zBuf, threadset[i].pStmt);
1.682 + threadset[i].pStmt = 0;
1.683 + Tcl_AppendResult(interp, zBuf, (char*)0);
1.684 + return TCL_OK;
1.685 +}
1.686 +
1.687 +/*
1.688 +** Register commands with the TCL interpreter.
1.689 +*/
1.690 +int Sqlitetest4_Init(Tcl_Interp *interp){
1.691 + static struct {
1.692 + char *zName;
1.693 + Tcl_CmdProc *xProc;
1.694 + } aCmd[] = {
1.695 + { "thread_create", (Tcl_CmdProc*)tcl_thread_create },
1.696 + { "thread_wait", (Tcl_CmdProc*)tcl_thread_wait },
1.697 + { "thread_halt", (Tcl_CmdProc*)tcl_thread_halt },
1.698 + { "thread_argc", (Tcl_CmdProc*)tcl_thread_argc },
1.699 + { "thread_argv", (Tcl_CmdProc*)tcl_thread_argv },
1.700 + { "thread_colname", (Tcl_CmdProc*)tcl_thread_colname },
1.701 + { "thread_result", (Tcl_CmdProc*)tcl_thread_result },
1.702 + { "thread_error", (Tcl_CmdProc*)tcl_thread_error },
1.703 + { "thread_compile", (Tcl_CmdProc*)tcl_thread_compile },
1.704 + { "thread_step", (Tcl_CmdProc*)tcl_thread_step },
1.705 + { "thread_finalize", (Tcl_CmdProc*)tcl_thread_finalize },
1.706 + { "thread_swap", (Tcl_CmdProc*)tcl_thread_swap },
1.707 + { "thread_db_get", (Tcl_CmdProc*)tcl_thread_db_get },
1.708 + { "thread_stmt_get", (Tcl_CmdProc*)tcl_thread_stmt_get },
1.709 + };
1.710 + int i;
1.711 +
1.712 + for(i=0; i<sizeof(aCmd)/sizeof(aCmd[0]); i++){
1.713 + Tcl_CreateCommand(interp, aCmd[i].zName, aCmd[i].xProc, 0, 0);
1.714 + }
1.715 + return TCL_OK;
1.716 +}
1.717 +#else
1.718 +int Sqlitetest4_Init(Tcl_Interp *interp){ return TCL_OK; }
1.719 +#endif /* SQLITE_OS_UNIX */