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