/ Hex Artifact Content
Login

Artifact 195ab49da082053fdb0f949c114b806a49ca770a:


0000: 2f 2a 0a 2a 2a 20 32 30 30 35 20 44 65 63 65 6d  /*.** 2005 Decem
0010: 62 65 72 20 31 34 0a 2a 2a 0a 2a 2a 20 54 68 65  ber 14.**.** The
0020: 20 61 75 74 68 6f 72 20 64 69 73 63 6c 61 69 6d   author disclaim
0030: 73 20 63 6f 70 79 72 69 67 68 74 20 74 6f 20 74  s copyright to t
0040: 68 69 73 20 73 6f 75 72 63 65 20 63 6f 64 65 2e  his source code.
0050: 20 20 49 6e 20 70 6c 61 63 65 20 6f 66 0a 2a 2a    In place of.**
0060: 20 61 20 6c 65 67 61 6c 20 6e 6f 74 69 63 65 2c   a legal notice,
0070: 20 68 65 72 65 20 69 73 20 61 20 62 6c 65 73 73   here is a bless
0080: 69 6e 67 3a 0a 2a 2a 0a 2a 2a 20 20 20 20 4d 61  ing:.**.**    Ma
0090: 79 20 79 6f 75 20 64 6f 20 67 6f 6f 64 20 61 6e  y you do good an
00a0: 64 20 6e 6f 74 20 65 76 69 6c 2e 0a 2a 2a 20 20  d not evil..**  
00b0: 20 20 4d 61 79 20 79 6f 75 20 66 69 6e 64 20 66    May you find f
00c0: 6f 72 67 69 76 65 6e 65 73 73 20 66 6f 72 20 79  orgiveness for y
00d0: 6f 75 72 73 65 6c 66 20 61 6e 64 20 66 6f 72 67  ourself and forg
00e0: 69 76 65 20 6f 74 68 65 72 73 2e 0a 2a 2a 20 20  ive others..**  
00f0: 20 20 4d 61 79 20 79 6f 75 20 73 68 61 72 65 20    May you share 
0100: 66 72 65 65 6c 79 2c 20 6e 65 76 65 72 20 74 61  freely, never ta
0110: 6b 69 6e 67 20 6d 6f 72 65 20 74 68 61 6e 20 79  king more than y
0120: 6f 75 20 67 69 76 65 2e 0a 2a 2a 0a 2a 2a 2a 2a  ou give..**.****
0130: 2a 2a 2a 2a 2a 2a 2a 2a 2a 2a 2a 2a 2a 2a 2a 2a  ****************
0140: 2a 2a 2a 2a 2a 2a 2a 2a 2a 2a 2a 2a 2a 2a 2a 2a  ****************
0150: 2a 2a 2a 2a 2a 2a 2a 2a 2a 2a 2a 2a 2a 2a 2a 2a  ****************
0160: 2a 2a 2a 2a 2a 2a 2a 2a 2a 2a 2a 2a 2a 2a 2a 2a  ****************
0170: 2a 2a 2a 2a 2a 0a 2a 2a 0a 2a 2a 20 54 68 69 73  *****.**.** This
0180: 20 66 69 6c 65 20 63 6f 6e 74 61 69 6e 73 20 61   file contains a
0190: 20 62 69 6e 64 69 6e 67 20 6f 66 20 74 68 65 20   binding of the 
01a0: 61 73 79 6e 63 68 72 6f 6e 6f 75 73 20 49 4f 20  asynchronous IO 
01b0: 65 78 74 65 6e 73 69 6f 6e 20 69 6e 74 65 72 66  extension interf
01c0: 61 63 65 0a 2a 2a 20 28 64 65 66 69 6e 65 64 20  ace.** (defined 
01d0: 69 6e 20 65 78 74 2f 61 73 79 6e 63 2f 73 71 6c  in ext/async/sql
01e0: 69 74 65 33 61 73 79 6e 63 2e 68 29 20 74 6f 20  ite3async.h) to 
01f0: 54 63 6c 2e 0a 2a 2f 0a 0a 23 64 65 66 69 6e 65  Tcl..*/..#define
0200: 20 54 43 4c 5f 54 48 52 45 41 44 53 20 0a 23 69   TCL_THREADS .#i
0210: 66 20 64 65 66 69 6e 65 64 28 49 4e 43 4c 55 44  f defined(INCLUD
0220: 45 5f 53 51 4c 49 54 45 5f 54 43 4c 5f 48 29 0a  E_SQLITE_TCL_H).
0230: 23 20 20 69 6e 63 6c 75 64 65 20 22 73 71 6c 69  #  include "sqli
0240: 74 65 5f 74 63 6c 2e 68 22 0a 23 65 6c 73 65 0a  te_tcl.h".#else.
0250: 23 20 20 69 6e 63 6c 75 64 65 20 22 74 63 6c 2e  #  include "tcl.
0260: 68 22 0a 23 20 20 69 66 6e 64 65 66 20 53 51 4c  h".#  ifndef SQL
0270: 49 54 45 5f 54 43 4c 41 50 49 0a 23 20 20 20 20  ITE_TCLAPI.#    
0280: 64 65 66 69 6e 65 20 53 51 4c 49 54 45 5f 54 43  define SQLITE_TC
0290: 4c 41 50 49 0a 23 20 20 65 6e 64 69 66 0a 23 65  LAPI.#  endif.#e
02a0: 6e 64 69 66 0a 0a 23 69 66 64 65 66 20 53 51 4c  ndif..#ifdef SQL
02b0: 49 54 45 5f 45 4e 41 42 4c 45 5f 41 53 59 4e 43  ITE_ENABLE_ASYNC
02c0: 49 4f 0a 0a 23 69 6e 63 6c 75 64 65 20 22 73 71  IO..#include "sq
02d0: 6c 69 74 65 33 61 73 79 6e 63 2e 68 22 0a 23 69  lite3async.h".#i
02e0: 6e 63 6c 75 64 65 20 22 73 71 6c 69 74 65 33 2e  nclude "sqlite3.
02f0: 68 22 0a 23 69 6e 63 6c 75 64 65 20 3c 61 73 73  h".#include <ass
0300: 65 72 74 2e 68 3e 0a 0a 2f 2a 20 46 72 6f 6d 20  ert.h>../* From 
0310: 6d 61 69 6e 2e 63 20 2a 2f 0a 65 78 74 65 72 6e  main.c */.extern
0320: 20 63 6f 6e 73 74 20 63 68 61 72 20 2a 73 71 6c   const char *sql
0330: 69 74 65 33 45 72 72 4e 61 6d 65 28 69 6e 74 29  ite3ErrName(int)
0340: 3b 0a 0a 0a 73 74 72 75 63 74 20 54 65 73 74 41  ;...struct TestA
0350: 73 79 6e 63 47 6c 6f 62 61 6c 20 7b 0a 20 20 69  syncGlobal {.  i
0360: 6e 74 20 69 73 49 6e 73 74 61 6c 6c 65 64 3b 20  nt isInstalled; 
0370: 20 20 20 20 20 20 20 20 20 20 20 20 20 20 20 20                  
0380: 20 20 20 20 2f 2a 20 54 72 75 65 20 77 68 65 6e      /* True when
0390: 20 61 73 79 6e 63 20 56 46 53 20 69 73 20 69 6e   async VFS is in
03a0: 73 74 61 6c 6c 65 64 20 2a 2f 0a 7d 20 74 65 73  stalled */.} tes
03b0: 74 61 73 79 6e 63 5f 67 20 3d 20 7b 20 30 20 7d  tasync_g = { 0 }
03c0: 3b 0a 0a 54 43 4c 5f 44 45 43 4c 41 52 45 5f 4d  ;..TCL_DECLARE_M
03d0: 55 54 45 58 28 74 65 73 74 61 73 79 6e 63 5f 67  UTEX(testasync_g
03e0: 5f 77 72 69 74 65 72 4d 75 74 65 78 29 3b 0a 0a  _writerMutex);..
03f0: 2f 2a 0a 2a 2a 20 73 71 6c 69 74 65 33 61 73 79  /*.** sqlite3asy
0400: 6e 63 5f 69 6e 69 74 69 61 6c 69 7a 65 20 50 41  nc_initialize PA
0410: 52 45 4e 54 2d 56 46 53 20 49 53 44 45 46 41 55  RENT-VFS ISDEFAU
0420: 4c 54 0a 2a 2f 0a 73 74 61 74 69 63 20 69 6e 74  LT.*/.static int
0430: 20 53 51 4c 49 54 45 5f 54 43 4c 41 50 49 20 74   SQLITE_TCLAPI t
0440: 65 73 74 41 73 79 6e 63 49 6e 69 74 28 0a 20 20  estAsyncInit(.  
0450: 76 6f 69 64 20 2a 20 63 6c 69 65 6e 74 44 61 74  void * clientDat
0460: 61 2c 0a 20 20 54 63 6c 5f 49 6e 74 65 72 70 20  a,.  Tcl_Interp 
0470: 2a 69 6e 74 65 72 70 2c 0a 20 20 69 6e 74 20 6f  *interp,.  int o
0480: 62 6a 63 2c 0a 20 20 54 63 6c 5f 4f 62 6a 20 2a  bjc,.  Tcl_Obj *
0490: 43 4f 4e 53 54 20 6f 62 6a 76 5b 5d 0a 29 7b 0a  CONST objv[].){.
04a0: 20 20 63 6f 6e 73 74 20 63 68 61 72 20 2a 7a 50    const char *zP
04b0: 61 72 65 6e 74 3b 0a 20 20 69 6e 74 20 69 73 44  arent;.  int isD
04c0: 65 66 61 75 6c 74 3b 0a 20 20 69 6e 74 20 72 63  efault;.  int rc
04d0: 3b 0a 0a 20 20 69 66 28 20 6f 62 6a 63 21 3d 33  ;..  if( objc!=3
04e0: 20 29 7b 0a 20 20 20 20 54 63 6c 5f 57 72 6f 6e   ){.    Tcl_Wron
04f0: 67 4e 75 6d 41 72 67 73 28 69 6e 74 65 72 70 2c  gNumArgs(interp,
0500: 20 31 2c 20 6f 62 6a 76 2c 20 22 50 41 52 45 4e   1, objv, "PAREN
0510: 54 2d 56 46 53 20 49 53 44 45 46 41 55 4c 54 22  T-VFS ISDEFAULT"
0520: 29 3b 0a 20 20 20 20 72 65 74 75 72 6e 20 54 43  );.    return TC
0530: 4c 5f 45 52 52 4f 52 3b 0a 20 20 7d 0a 20 20 7a  L_ERROR;.  }.  z
0540: 50 61 72 65 6e 74 20 3d 20 54 63 6c 5f 47 65 74  Parent = Tcl_Get
0550: 53 74 72 69 6e 67 28 6f 62 6a 76 5b 31 5d 29 3b  String(objv[1]);
0560: 0a 20 20 69 66 28 20 21 2a 7a 50 61 72 65 6e 74  .  if( !*zParent
0570: 20 29 20 7b 0a 20 20 20 20 7a 50 61 72 65 6e 74   ) {.    zParent
0580: 20 3d 20 30 3b 0a 20 20 7d 0a 20 20 69 66 28 20   = 0;.  }.  if( 
0590: 54 63 6c 5f 47 65 74 42 6f 6f 6c 65 61 6e 46 72  Tcl_GetBooleanFr
05a0: 6f 6d 4f 62 6a 28 69 6e 74 65 72 70 2c 20 6f 62  omObj(interp, ob
05b0: 6a 76 5b 32 5d 2c 20 26 69 73 44 65 66 61 75 6c  jv[2], &isDefaul
05c0: 74 29 20 29 7b 0a 20 20 20 20 72 65 74 75 72 6e  t) ){.    return
05d0: 20 54 43 4c 5f 45 52 52 4f 52 3b 0a 20 20 7d 0a   TCL_ERROR;.  }.
05e0: 0a 20 20 72 63 20 3d 20 73 71 6c 69 74 65 33 61  .  rc = sqlite3a
05f0: 73 79 6e 63 5f 69 6e 69 74 69 61 6c 69 7a 65 28  sync_initialize(
0600: 7a 50 61 72 65 6e 74 2c 20 69 73 44 65 66 61 75  zParent, isDefau
0610: 6c 74 29 3b 0a 20 20 69 66 28 20 72 63 21 3d 53  lt);.  if( rc!=S
0620: 51 4c 49 54 45 5f 4f 4b 20 29 7b 0a 20 20 20 20  QLITE_OK ){.    
0630: 54 63 6c 5f 53 65 74 4f 62 6a 52 65 73 75 6c 74  Tcl_SetObjResult
0640: 28 69 6e 74 65 72 70 2c 20 54 63 6c 5f 4e 65 77  (interp, Tcl_New
0650: 53 74 72 69 6e 67 4f 62 6a 28 73 71 6c 69 74 65  StringObj(sqlite
0660: 33 45 72 72 4e 61 6d 65 28 72 63 29 2c 20 2d 31  3ErrName(rc), -1
0670: 29 29 3b 0a 20 20 20 20 72 65 74 75 72 6e 20 54  ));.    return T
0680: 43 4c 5f 45 52 52 4f 52 3b 0a 20 20 7d 0a 20 20  CL_ERROR;.  }.  
0690: 72 65 74 75 72 6e 20 54 43 4c 5f 4f 4b 3b 0a 7d  return TCL_OK;.}
06a0: 0a 0a 2f 2a 0a 2a 2a 20 73 71 6c 69 74 65 33 61  ../*.** sqlite3a
06b0: 73 79 6e 63 5f 73 68 75 74 64 6f 77 6e 0a 2a 2f  sync_shutdown.*/
06c0: 0a 73 74 61 74 69 63 20 69 6e 74 20 53 51 4c 49  .static int SQLI
06d0: 54 45 5f 54 43 4c 41 50 49 20 74 65 73 74 41 73  TE_TCLAPI testAs
06e0: 79 6e 63 53 68 75 74 64 6f 77 6e 28 0a 20 20 76  yncShutdown(.  v
06f0: 6f 69 64 20 2a 20 63 6c 69 65 6e 74 44 61 74 61  oid * clientData
0700: 2c 0a 20 20 54 63 6c 5f 49 6e 74 65 72 70 20 2a  ,.  Tcl_Interp *
0710: 69 6e 74 65 72 70 2c 0a 20 20 69 6e 74 20 6f 62  interp,.  int ob
0720: 6a 63 2c 0a 20 20 54 63 6c 5f 4f 62 6a 20 2a 43  jc,.  Tcl_Obj *C
0730: 4f 4e 53 54 20 6f 62 6a 76 5b 5d 0a 29 7b 0a 20  ONST objv[].){. 
0740: 20 73 71 6c 69 74 65 33 61 73 79 6e 63 5f 73 68   sqlite3async_sh
0750: 75 74 64 6f 77 6e 28 29 3b 0a 20 20 72 65 74 75  utdown();.  retu
0760: 72 6e 20 54 43 4c 5f 4f 4b 3b 0a 7d 0a 0a 73 74  rn TCL_OK;.}..st
0770: 61 74 69 63 20 54 63 6c 5f 54 68 72 65 61 64 43  atic Tcl_ThreadC
0780: 72 65 61 74 65 54 79 70 65 20 74 63 6c 57 72 69  reateType tclWri
0790: 74 65 72 54 68 72 65 61 64 28 43 6c 69 65 6e 74  terThread(Client
07a0: 44 61 74 61 20 70 49 73 53 74 61 72 74 65 64 29  Data pIsStarted)
07b0: 7b 0a 20 20 54 63 6c 5f 4d 75 74 65 78 4c 6f 63  {.  Tcl_MutexLoc
07c0: 6b 28 26 74 65 73 74 61 73 79 6e 63 5f 67 5f 77  k(&testasync_g_w
07d0: 72 69 74 65 72 4d 75 74 65 78 29 3b 0a 20 20 2a  riterMutex);.  *
07e0: 28 28 69 6e 74 20 2a 29 70 49 73 53 74 61 72 74  ((int *)pIsStart
07f0: 65 64 29 20 3d 20 31 3b 0a 20 20 73 71 6c 69 74  ed) = 1;.  sqlit
0800: 65 33 61 73 79 6e 63 5f 72 75 6e 28 29 3b 0a 20  e3async_run();. 
0810: 20 54 63 6c 5f 4d 75 74 65 78 55 6e 6c 6f 63 6b   Tcl_MutexUnlock
0820: 28 26 74 65 73 74 61 73 79 6e 63 5f 67 5f 77 72  (&testasync_g_wr
0830: 69 74 65 72 4d 75 74 65 78 29 3b 0a 20 20 54 63  iterMutex);.  Tc
0840: 6c 5f 45 78 69 74 54 68 72 65 61 64 28 30 29 3b  l_ExitThread(0);
0850: 0a 20 20 54 43 4c 5f 54 48 52 45 41 44 5f 43 52  .  TCL_THREAD_CR
0860: 45 41 54 45 5f 52 45 54 55 52 4e 3b 0a 7d 0a 0a  EATE_RETURN;.}..
0870: 2f 2a 0a 2a 2a 20 73 71 6c 69 74 65 33 61 73 79  /*.** sqlite3asy
0880: 6e 63 5f 73 74 61 72 74 0a 2a 2a 0a 2a 2a 20 53  nc_start.**.** S
0890: 74 61 72 74 20 61 20 6e 65 77 20 77 72 69 74 65  tart a new write
08a0: 72 20 74 68 72 65 61 64 2e 0a 2a 2f 0a 73 74 61  r thread..*/.sta
08b0: 74 69 63 20 69 6e 74 20 53 51 4c 49 54 45 5f 54  tic int SQLITE_T
08c0: 43 4c 41 50 49 20 74 65 73 74 41 73 79 6e 63 53  CLAPI testAsyncS
08d0: 74 61 72 74 28 0a 20 20 76 6f 69 64 20 2a 20 63  tart(.  void * c
08e0: 6c 69 65 6e 74 44 61 74 61 2c 0a 20 20 54 63 6c  lientData,.  Tcl
08f0: 5f 49 6e 74 65 72 70 20 2a 69 6e 74 65 72 70 2c  _Interp *interp,
0900: 0a 20 20 69 6e 74 20 6f 62 6a 63 2c 0a 20 20 54  .  int objc,.  T
0910: 63 6c 5f 4f 62 6a 20 2a 43 4f 4e 53 54 20 6f 62  cl_Obj *CONST ob
0920: 6a 76 5b 5d 0a 29 7b 0a 20 20 76 6f 6c 61 74 69  jv[].){.  volati
0930: 6c 65 20 69 6e 74 20 69 73 53 74 61 72 74 65 64  le int isStarted
0940: 20 3d 20 30 3b 0a 20 20 43 6c 69 65 6e 74 44 61   = 0;.  ClientDa
0950: 74 61 20 74 68 72 65 61 64 44 61 74 61 20 3d 20  ta threadData = 
0960: 28 43 6c 69 65 6e 74 44 61 74 61 29 26 69 73 53  (ClientData)&isS
0970: 74 61 72 74 65 64 3b 0a 0a 20 20 54 63 6c 5f 54  tarted;..  Tcl_T
0980: 68 72 65 61 64 49 64 20 78 3b 0a 20 20 63 6f 6e  hreadId x;.  con
0990: 73 74 20 69 6e 74 20 6e 53 74 61 63 6b 20 3d 20  st int nStack = 
09a0: 54 43 4c 5f 54 48 52 45 41 44 5f 53 54 41 43 4b  TCL_THREAD_STACK
09b0: 5f 44 45 46 41 55 4c 54 3b 0a 20 20 63 6f 6e 73  _DEFAULT;.  cons
09c0: 74 20 69 6e 74 20 66 6c 61 67 73 20 3d 20 54 43  t int flags = TC
09d0: 4c 5f 54 48 52 45 41 44 5f 4e 4f 46 4c 41 47 53  L_THREAD_NOFLAGS
09e0: 3b 0a 20 20 69 6e 74 20 72 63 3b 0a 0a 20 20 72  ;.  int rc;..  r
09f0: 63 20 3d 20 54 63 6c 5f 43 72 65 61 74 65 54 68  c = Tcl_CreateTh
0a00: 72 65 61 64 28 26 78 2c 20 74 63 6c 57 72 69 74  read(&x, tclWrit
0a10: 65 72 54 68 72 65 61 64 2c 20 74 68 72 65 61 64  erThread, thread
0a20: 44 61 74 61 2c 20 6e 53 74 61 63 6b 2c 20 66 6c  Data, nStack, fl
0a30: 61 67 73 29 3b 0a 20 20 69 66 28 20 72 63 21 3d  ags);.  if( rc!=
0a40: 54 43 4c 5f 4f 4b 20 29 7b 0a 20 20 20 20 54 63  TCL_OK ){.    Tc
0a50: 6c 5f 41 70 70 65 6e 64 52 65 73 75 6c 74 28 69  l_AppendResult(i
0a60: 6e 74 65 72 70 2c 20 22 54 63 6c 5f 43 72 65 61  nterp, "Tcl_Crea
0a70: 74 65 54 68 72 65 61 64 28 29 20 66 61 69 6c 65  teThread() faile
0a80: 64 22 2c 20 30 29 3b 0a 20 20 20 20 72 65 74 75  d", 0);.    retu
0a90: 72 6e 20 54 43 4c 5f 45 52 52 4f 52 3b 0a 20 20  rn TCL_ERROR;.  
0aa0: 7d 0a 0a 20 20 77 68 69 6c 65 28 20 69 73 53 74  }..  while( isSt
0ab0: 61 72 74 65 64 3d 3d 30 20 29 20 7b 20 2f 2a 20  arted==0 ) { /* 
0ac0: 42 75 73 79 20 6c 6f 6f 70 20 2a 2f 20 7d 0a 20  Busy loop */ }. 
0ad0: 20 72 65 74 75 72 6e 20 54 43 4c 5f 4f 4b 3b 0a   return TCL_OK;.
0ae0: 7d 0a 0a 2f 2a 0a 2a 2a 20 73 71 6c 69 74 65 33  }../*.** sqlite3
0af0: 61 73 79 6e 63 5f 77 61 69 74 0a 2a 2a 0a 2a 2a  async_wait.**.**
0b00: 20 57 61 69 74 20 66 6f 72 20 74 68 65 20 63 75   Wait for the cu
0b10: 72 72 65 6e 74 20 77 72 69 74 65 72 20 74 68 72  rrent writer thr
0b20: 65 61 64 20 74 6f 20 74 65 72 6d 69 6e 61 74 65  ead to terminate
0b30: 2e 0a 2a 2a 0a 2a 2a 20 49 66 20 74 68 65 20 63  ..**.** If the c
0b40: 75 72 72 65 6e 74 20 77 72 69 74 65 72 20 74 68  urrent writer th
0b50: 72 65 61 64 20 69 73 20 73 65 74 20 74 6f 20 72  read is set to r
0b60: 75 6e 20 66 6f 72 65 76 65 72 20 74 68 65 6e 20  un forever then 
0b70: 74 68 69 73 0a 2a 2a 20 63 6f 6d 6d 61 6e 64 20  this.** command 
0b80: 77 6f 75 6c 64 20 62 6c 6f 63 6b 20 66 6f 72 65  would block fore
0b90: 76 65 72 2e 20 20 54 6f 20 70 72 65 76 65 6e 74  ver.  To prevent
0ba0: 20 74 68 61 74 2c 20 61 6e 20 65 72 72 6f 72 20   that, an error 
0bb0: 69 73 20 72 65 74 75 72 6e 65 64 2e 20 0a 2a 2f  is returned. .*/
0bc0: 0a 73 74 61 74 69 63 20 69 6e 74 20 53 51 4c 49  .static int SQLI
0bd0: 54 45 5f 54 43 4c 41 50 49 20 74 65 73 74 41 73  TE_TCLAPI testAs
0be0: 79 6e 63 57 61 69 74 28 0a 20 20 76 6f 69 64 20  yncWait(.  void 
0bf0: 2a 20 63 6c 69 65 6e 74 44 61 74 61 2c 0a 20 20  * clientData,.  
0c00: 54 63 6c 5f 49 6e 74 65 72 70 20 2a 69 6e 74 65  Tcl_Interp *inte
0c10: 72 70 2c 0a 20 20 69 6e 74 20 6f 62 6a 63 2c 0a  rp,.  int objc,.
0c20: 20 20 54 63 6c 5f 4f 62 6a 20 2a 43 4f 4e 53 54    Tcl_Obj *CONST
0c30: 20 6f 62 6a 76 5b 5d 0a 29 7b 0a 20 20 69 6e 74   objv[].){.  int
0c40: 20 65 43 6f 6e 64 3b 0a 20 20 69 66 28 20 6f 62   eCond;.  if( ob
0c50: 6a 63 21 3d 31 20 29 7b 0a 20 20 20 20 54 63 6c  jc!=1 ){.    Tcl
0c60: 5f 57 72 6f 6e 67 4e 75 6d 41 72 67 73 28 69 6e  _WrongNumArgs(in
0c70: 74 65 72 70 2c 20 31 2c 20 6f 62 6a 76 2c 20 22  terp, 1, objv, "
0c80: 22 29 3b 0a 20 20 20 20 72 65 74 75 72 6e 20 54  ");.    return T
0c90: 43 4c 5f 45 52 52 4f 52 3b 0a 20 20 7d 0a 0a 20  CL_ERROR;.  }.. 
0ca0: 20 73 71 6c 69 74 65 33 61 73 79 6e 63 5f 63 6f   sqlite3async_co
0cb0: 6e 74 72 6f 6c 28 53 51 4c 49 54 45 41 53 59 4e  ntrol(SQLITEASYN
0cc0: 43 5f 47 45 54 5f 48 41 4c 54 2c 20 26 65 43 6f  C_GET_HALT, &eCo
0cd0: 6e 64 29 3b 0a 20 20 69 66 28 20 65 43 6f 6e 64  nd);.  if( eCond
0ce0: 3d 3d 53 51 4c 49 54 45 41 53 59 4e 43 5f 48 41  ==SQLITEASYNC_HA
0cf0: 4c 54 5f 4e 45 56 45 52 20 29 7b 0a 20 20 20 20  LT_NEVER ){.    
0d00: 54 63 6c 5f 41 70 70 65 6e 64 52 65 73 75 6c 74  Tcl_AppendResult
0d10: 28 69 6e 74 65 72 70 2c 20 22 77 6f 75 6c 64 20  (interp, "would 
0d20: 62 6c 6f 63 6b 20 66 6f 72 65 76 65 72 22 2c 20  block forever", 
0d30: 28 63 68 61 72 2a 29 30 29 3b 0a 20 20 20 20 72  (char*)0);.    r
0d40: 65 74 75 72 6e 20 54 43 4c 5f 45 52 52 4f 52 3b  eturn TCL_ERROR;
0d50: 0a 20 20 7d 0a 0a 20 20 54 63 6c 5f 4d 75 74 65  .  }..  Tcl_Mute
0d60: 78 4c 6f 63 6b 28 26 74 65 73 74 61 73 79 6e 63  xLock(&testasync
0d70: 5f 67 5f 77 72 69 74 65 72 4d 75 74 65 78 29 3b  _g_writerMutex);
0d80: 0a 20 20 54 63 6c 5f 4d 75 74 65 78 55 6e 6c 6f  .  Tcl_MutexUnlo
0d90: 63 6b 28 26 74 65 73 74 61 73 79 6e 63 5f 67 5f  ck(&testasync_g_
0da0: 77 72 69 74 65 72 4d 75 74 65 78 29 3b 0a 20 20  writerMutex);.  
0db0: 72 65 74 75 72 6e 20 54 43 4c 5f 4f 4b 3b 0a 7d  return TCL_OK;.}
0dc0: 0a 0a 2f 2a 0a 2a 2a 20 73 71 6c 69 74 65 33 61  ../*.** sqlite3a
0dd0: 73 79 6e 63 5f 63 6f 6e 74 72 6f 6c 20 4f 50 54  sync_control OPT
0de0: 49 4f 4e 20 3f 56 41 4c 55 45 3f 0a 2a 2f 0a 73  ION ?VALUE?.*/.s
0df0: 74 61 74 69 63 20 69 6e 74 20 53 51 4c 49 54 45  tatic int SQLITE
0e00: 5f 54 43 4c 41 50 49 20 74 65 73 74 41 73 79 6e  _TCLAPI testAsyn
0e10: 63 43 6f 6e 74 72 6f 6c 28 0a 20 20 76 6f 69 64  cControl(.  void
0e20: 20 2a 20 63 6c 69 65 6e 74 44 61 74 61 2c 0a 20   * clientData,. 
0e30: 20 54 63 6c 5f 49 6e 74 65 72 70 20 2a 69 6e 74   Tcl_Interp *int
0e40: 65 72 70 2c 0a 20 20 69 6e 74 20 6f 62 6a 63 2c  erp,.  int objc,
0e50: 0a 20 20 54 63 6c 5f 4f 62 6a 20 2a 43 4f 4e 53  .  Tcl_Obj *CONS
0e60: 54 20 6f 62 6a 76 5b 5d 0a 29 7b 0a 20 20 69 6e  T objv[].){.  in
0e70: 74 20 72 63 20 3d 20 53 51 4c 49 54 45 5f 4f 4b  t rc = SQLITE_OK
0e80: 3b 0a 20 20 69 6e 74 20 61 65 4f 70 74 5b 5d 20  ;.  int aeOpt[] 
0e90: 3d 20 7b 20 53 51 4c 49 54 45 41 53 59 4e 43 5f  = { SQLITEASYNC_
0ea0: 48 41 4c 54 2c 20 53 51 4c 49 54 45 41 53 59 4e  HALT, SQLITEASYN
0eb0: 43 5f 44 45 4c 41 59 2c 20 53 51 4c 49 54 45 41  C_DELAY, SQLITEA
0ec0: 53 59 4e 43 5f 4c 4f 43 4b 46 49 4c 45 53 20 7d  SYNC_LOCKFILES }
0ed0: 3b 0a 20 20 63 6f 6e 73 74 20 63 68 61 72 20 2a  ;.  const char *
0ee0: 61 7a 4f 70 74 5b 5d 20 3d 20 7b 20 22 68 61 6c  azOpt[] = { "hal
0ef0: 74 22 2c 20 22 64 65 6c 61 79 22 2c 20 22 6c 6f  t", "delay", "lo
0f00: 63 6b 66 69 6c 65 73 22 2c 20 30 20 7d 3b 0a 20  ckfiles", 0 };. 
0f10: 20 63 6f 6e 73 74 20 63 68 61 72 20 2a 61 7a 5b   const char *az[
0f20: 5d 20 3d 20 7b 20 22 6e 65 76 65 72 22 2c 20 22  ] = { "never", "
0f30: 6e 6f 77 22 2c 20 22 69 64 6c 65 22 2c 20 30 20  now", "idle", 0 
0f40: 7d 3b 0a 20 20 69 6e 74 20 69 56 61 6c 3b 0a 20  };.  int iVal;. 
0f50: 20 69 6e 74 20 65 4f 70 74 3b 0a 0a 20 20 69 66   int eOpt;..  if
0f60: 28 20 6f 62 6a 63 21 3d 32 20 26 26 20 6f 62 6a  ( objc!=2 && obj
0f70: 63 21 3d 33 20 29 7b 0a 20 20 20 20 54 63 6c 5f  c!=3 ){.    Tcl_
0f80: 57 72 6f 6e 67 4e 75 6d 41 72 67 73 28 69 6e 74  WrongNumArgs(int
0f90: 65 72 70 2c 20 31 2c 20 6f 62 6a 76 2c 20 22 4f  erp, 1, objv, "O
0fa0: 50 54 49 4f 4e 20 3f 56 41 4c 55 45 3f 22 29 3b  PTION ?VALUE?");
0fb0: 0a 20 20 20 20 72 65 74 75 72 6e 20 54 43 4c 5f  .    return TCL_
0fc0: 45 52 52 4f 52 3b 0a 20 20 7d 0a 20 20 69 66 28  ERROR;.  }.  if(
0fd0: 20 54 63 6c 5f 47 65 74 49 6e 64 65 78 46 72 6f   Tcl_GetIndexFro
0fe0: 6d 4f 62 6a 28 69 6e 74 65 72 70 2c 20 6f 62 6a  mObj(interp, obj
0ff0: 76 5b 31 5d 2c 20 61 7a 4f 70 74 2c 20 22 6f 70  v[1], azOpt, "op
1000: 74 69 6f 6e 22 2c 20 30 2c 20 26 65 4f 70 74 29  tion", 0, &eOpt)
1010: 20 29 7b 0a 20 20 20 20 72 65 74 75 72 6e 20 54   ){.    return T
1020: 43 4c 5f 45 52 52 4f 52 3b 0a 20 20 7d 0a 20 20  CL_ERROR;.  }.  
1030: 65 4f 70 74 20 3d 20 61 65 4f 70 74 5b 65 4f 70  eOpt = aeOpt[eOp
1040: 74 5d 3b 0a 0a 20 20 69 66 28 20 6f 62 6a 63 3d  t];..  if( objc=
1050: 3d 33 20 29 7b 0a 20 20 20 20 73 77 69 74 63 68  =3 ){.    switch
1060: 28 20 65 4f 70 74 20 29 7b 0a 20 20 20 20 20 20  ( eOpt ){.      
1070: 63 61 73 65 20 53 51 4c 49 54 45 41 53 59 4e 43  case SQLITEASYNC
1080: 5f 48 41 4c 54 3a 20 7b 0a 20 20 20 20 20 20 20  _HALT: {.       
1090: 20 61 73 73 65 72 74 28 20 53 51 4c 49 54 45 41   assert( SQLITEA
10a0: 53 59 4e 43 5f 48 41 4c 54 5f 4e 45 56 45 52 3d  SYNC_HALT_NEVER=
10b0: 3d 30 20 29 3b 0a 20 20 20 20 20 20 20 20 61 73  =0 );.        as
10c0: 73 65 72 74 28 20 53 51 4c 49 54 45 41 53 59 4e  sert( SQLITEASYN
10d0: 43 5f 48 41 4c 54 5f 4e 4f 57 3d 3d 31 20 29 3b  C_HALT_NOW==1 );
10e0: 0a 20 20 20 20 20 20 20 20 61 73 73 65 72 74 28  .        assert(
10f0: 20 53 51 4c 49 54 45 41 53 59 4e 43 5f 48 41 4c   SQLITEASYNC_HAL
1100: 54 5f 49 44 4c 45 3d 3d 32 20 29 3b 0a 20 20 20  T_IDLE==2 );.   
1110: 20 20 20 20 20 69 66 28 20 54 63 6c 5f 47 65 74       if( Tcl_Get
1120: 49 6e 64 65 78 46 72 6f 6d 4f 62 6a 28 69 6e 74  IndexFromObj(int
1130: 65 72 70 2c 20 6f 62 6a 76 5b 32 5d 2c 20 61 7a  erp, objv[2], az
1140: 2c 20 22 76 61 6c 75 65 22 2c 20 30 2c 20 26 69  , "value", 0, &i
1150: 56 61 6c 29 20 29 7b 0a 20 20 20 20 20 20 20 20  Val) ){.        
1160: 20 20 72 65 74 75 72 6e 20 54 43 4c 5f 45 52 52    return TCL_ERR
1170: 4f 52 3b 0a 20 20 20 20 20 20 20 20 7d 0a 20 20  OR;.        }.  
1180: 20 20 20 20 20 20 62 72 65 61 6b 3b 0a 20 20 20        break;.   
1190: 20 20 20 7d 0a 20 20 20 20 20 20 63 61 73 65 20     }.      case 
11a0: 53 51 4c 49 54 45 41 53 59 4e 43 5f 44 45 4c 41  SQLITEASYNC_DELA
11b0: 59 3a 0a 20 20 20 20 20 20 20 20 69 66 28 20 54  Y:.        if( T
11c0: 63 6c 5f 47 65 74 49 6e 74 46 72 6f 6d 4f 62 6a  cl_GetIntFromObj
11d0: 28 69 6e 74 65 72 70 2c 20 6f 62 6a 76 5b 32 5d  (interp, objv[2]
11e0: 2c 20 26 69 56 61 6c 29 20 29 7b 0a 20 20 20 20  , &iVal) ){.    
11f0: 20 20 20 20 20 20 72 65 74 75 72 6e 20 54 43 4c        return TCL
1200: 5f 45 52 52 4f 52 3b 0a 20 20 20 20 20 20 20 20  _ERROR;.        
1210: 7d 0a 20 20 20 20 20 20 20 20 62 72 65 61 6b 3b  }.        break;
1220: 0a 0a 20 20 20 20 20 20 63 61 73 65 20 53 51 4c  ..      case SQL
1230: 49 54 45 41 53 59 4e 43 5f 4c 4f 43 4b 46 49 4c  ITEASYNC_LOCKFIL
1240: 45 53 3a 0a 20 20 20 20 20 20 20 20 69 66 28 20  ES:.        if( 
1250: 54 63 6c 5f 47 65 74 42 6f 6f 6c 65 61 6e 46 72  Tcl_GetBooleanFr
1260: 6f 6d 4f 62 6a 28 69 6e 74 65 72 70 2c 20 6f 62  omObj(interp, ob
1270: 6a 76 5b 32 5d 2c 20 26 69 56 61 6c 29 20 29 7b  jv[2], &iVal) ){
1280: 0a 20 20 20 20 20 20 20 20 20 20 72 65 74 75 72  .          retur
1290: 6e 20 54 43 4c 5f 45 52 52 4f 52 3b 0a 20 20 20  n TCL_ERROR;.   
12a0: 20 20 20 20 20 7d 0a 20 20 20 20 20 20 20 20 62       }.        b
12b0: 72 65 61 6b 3b 0a 20 20 20 20 7d 0a 0a 20 20 20  reak;.    }..   
12c0: 20 72 63 20 3d 20 73 71 6c 69 74 65 33 61 73 79   rc = sqlite3asy
12d0: 6e 63 5f 63 6f 6e 74 72 6f 6c 28 65 4f 70 74 2c  nc_control(eOpt,
12e0: 20 69 56 61 6c 29 3b 0a 20 20 7d 0a 0a 20 20 69   iVal);.  }..  i
12f0: 66 28 20 72 63 3d 3d 53 51 4c 49 54 45 5f 4f 4b  f( rc==SQLITE_OK
1300: 20 29 7b 0a 20 20 20 20 72 63 20 3d 20 73 71 6c   ){.    rc = sql
1310: 69 74 65 33 61 73 79 6e 63 5f 63 6f 6e 74 72 6f  ite3async_contro
1320: 6c 28 0a 20 20 20 20 20 20 20 20 65 4f 70 74 3d  l(.        eOpt=
1330: 3d 53 51 4c 49 54 45 41 53 59 4e 43 5f 48 41 4c  =SQLITEASYNC_HAL
1340: 54 20 3f 20 53 51 4c 49 54 45 41 53 59 4e 43 5f  T ? SQLITEASYNC_
1350: 47 45 54 5f 48 41 4c 54 20 3a 0a 20 20 20 20 20  GET_HALT :.     
1360: 20 20 20 65 4f 70 74 3d 3d 53 51 4c 49 54 45 41     eOpt==SQLITEA
1370: 53 59 4e 43 5f 44 45 4c 41 59 20 3f 20 53 51 4c  SYNC_DELAY ? SQL
1380: 49 54 45 41 53 59 4e 43 5f 47 45 54 5f 44 45 4c  ITEASYNC_GET_DEL
1390: 41 59 20 3a 0a 20 20 20 20 20 20 20 20 53 51 4c  AY :.        SQL
13a0: 49 54 45 41 53 59 4e 43 5f 47 45 54 5f 4c 4f 43  ITEASYNC_GET_LOC
13b0: 4b 46 49 4c 45 53 2c 20 26 69 56 61 6c 29 3b 0a  KFILES, &iVal);.
13c0: 20 20 7d 0a 0a 20 20 69 66 28 20 72 63 21 3d 53    }..  if( rc!=S
13d0: 51 4c 49 54 45 5f 4f 4b 20 29 7b 0a 20 20 20 20  QLITE_OK ){.    
13e0: 54 63 6c 5f 53 65 74 4f 62 6a 52 65 73 75 6c 74  Tcl_SetObjResult
13f0: 28 69 6e 74 65 72 70 2c 20 54 63 6c 5f 4e 65 77  (interp, Tcl_New
1400: 53 74 72 69 6e 67 4f 62 6a 28 73 71 6c 69 74 65  StringObj(sqlite
1410: 33 45 72 72 4e 61 6d 65 28 72 63 29 2c 20 2d 31  3ErrName(rc), -1
1420: 29 29 3b 0a 20 20 20 20 72 65 74 75 72 6e 20 54  ));.    return T
1430: 43 4c 5f 45 52 52 4f 52 3b 0a 20 20 7d 0a 0a 20  CL_ERROR;.  }.. 
1440: 20 69 66 28 20 65 4f 70 74 3d 3d 53 51 4c 49 54   if( eOpt==SQLIT
1450: 45 41 53 59 4e 43 5f 48 41 4c 54 20 29 7b 0a 20  EASYNC_HALT ){. 
1460: 20 20 20 54 63 6c 5f 53 65 74 4f 62 6a 52 65 73     Tcl_SetObjRes
1470: 75 6c 74 28 69 6e 74 65 72 70 2c 20 54 63 6c 5f  ult(interp, Tcl_
1480: 4e 65 77 53 74 72 69 6e 67 4f 62 6a 28 61 7a 5b  NewStringObj(az[
1490: 69 56 61 6c 5d 2c 20 2d 31 29 29 3b 0a 20 20 7d  iVal], -1));.  }
14a0: 65 6c 73 65 7b 0a 20 20 20 20 54 63 6c 5f 53 65  else{.    Tcl_Se
14b0: 74 4f 62 6a 52 65 73 75 6c 74 28 69 6e 74 65 72  tObjResult(inter
14c0: 70 2c 20 54 63 6c 5f 4e 65 77 49 6e 74 4f 62 6a  p, Tcl_NewIntObj
14d0: 28 69 56 61 6c 29 29 3b 0a 20 20 7d 0a 0a 20 20  (iVal));.  }..  
14e0: 72 65 74 75 72 6e 20 54 43 4c 5f 4f 4b 3b 0a 7d  return TCL_OK;.}
14f0: 0a 0a 23 65 6e 64 69 66 20 20 2f 2a 20 53 51 4c  ..#endif  /* SQL
1500: 49 54 45 5f 45 4e 41 42 4c 45 5f 41 53 59 4e 43  ITE_ENABLE_ASYNC
1510: 49 4f 20 2a 2f 0a 0a 2f 2a 0a 2a 2a 20 54 68 69  IO */../*.** Thi
1520: 73 20 72 6f 75 74 69 6e 65 20 72 65 67 69 73 74  s routine regist
1530: 65 72 73 20 74 68 65 20 63 75 73 74 6f 6d 20 54  ers the custom T
1540: 43 4c 20 63 6f 6d 6d 61 6e 64 73 20 64 65 66 69  CL commands defi
1550: 6e 65 64 20 69 6e 20 74 68 69 73 0a 2a 2a 20 6d  ned in this.** m
1560: 6f 64 75 6c 65 2e 20 20 54 68 69 73 20 73 68 6f  odule.  This sho
1570: 75 6c 64 20 62 65 20 74 68 65 20 6f 6e 6c 79 20  uld be the only 
1580: 70 72 6f 63 65 64 75 72 65 20 76 69 73 69 62 6c  procedure visibl
1590: 65 20 66 72 6f 6d 20 6f 75 74 73 69 64 65 0a 2a  e from outside.*
15a0: 2a 20 6f 66 20 74 68 69 73 20 6d 6f 64 75 6c 65  * of this module
15b0: 2e 0a 2a 2f 0a 69 6e 74 20 53 71 6c 69 74 65 74  ..*/.int Sqlitet
15c0: 65 73 74 61 73 79 6e 63 5f 49 6e 69 74 28 54 63  estasync_Init(Tc
15d0: 6c 5f 49 6e 74 65 72 70 20 2a 69 6e 74 65 72 70  l_Interp *interp
15e0: 29 7b 0a 23 69 66 64 65 66 20 53 51 4c 49 54 45  ){.#ifdef SQLITE
15f0: 5f 45 4e 41 42 4c 45 5f 41 53 59 4e 43 49 4f 0a  _ENABLE_ASYNCIO.
1600: 20 20 54 63 6c 5f 43 72 65 61 74 65 4f 62 6a 43    Tcl_CreateObjC
1610: 6f 6d 6d 61 6e 64 28 69 6e 74 65 72 70 2c 22 73  ommand(interp,"s
1620: 71 6c 69 74 65 33 61 73 79 6e 63 5f 73 74 61 72  qlite3async_star
1630: 74 22 2c 74 65 73 74 41 73 79 6e 63 53 74 61 72  t",testAsyncStar
1640: 74 2c 30 2c 30 29 3b 0a 20 20 54 63 6c 5f 43 72  t,0,0);.  Tcl_Cr
1650: 65 61 74 65 4f 62 6a 43 6f 6d 6d 61 6e 64 28 69  eateObjCommand(i
1660: 6e 74 65 72 70 2c 22 73 71 6c 69 74 65 33 61 73  nterp,"sqlite3as
1670: 79 6e 63 5f 77 61 69 74 22 2c 74 65 73 74 41 73  ync_wait",testAs
1680: 79 6e 63 57 61 69 74 2c 30 2c 30 29 3b 0a 0a 20  yncWait,0,0);.. 
1690: 20 54 63 6c 5f 43 72 65 61 74 65 4f 62 6a 43 6f   Tcl_CreateObjCo
16a0: 6d 6d 61 6e 64 28 69 6e 74 65 72 70 2c 22 73 71  mmand(interp,"sq
16b0: 6c 69 74 65 33 61 73 79 6e 63 5f 63 6f 6e 74 72  lite3async_contr
16c0: 6f 6c 22 2c 74 65 73 74 41 73 79 6e 63 43 6f 6e  ol",testAsyncCon
16d0: 74 72 6f 6c 2c 30 2c 30 29 3b 0a 20 20 54 63 6c  trol,0,0);.  Tcl
16e0: 5f 43 72 65 61 74 65 4f 62 6a 43 6f 6d 6d 61 6e  _CreateObjComman
16f0: 64 28 69 6e 74 65 72 70 2c 22 73 71 6c 69 74 65  d(interp,"sqlite
1700: 33 61 73 79 6e 63 5f 69 6e 69 74 69 61 6c 69 7a  3async_initializ
1710: 65 22 2c 74 65 73 74 41 73 79 6e 63 49 6e 69 74  e",testAsyncInit
1720: 2c 30 2c 30 29 3b 0a 20 20 54 63 6c 5f 43 72 65  ,0,0);.  Tcl_Cre
1730: 61 74 65 4f 62 6a 43 6f 6d 6d 61 6e 64 28 69 6e  ateObjCommand(in
1740: 74 65 72 70 2c 22 73 71 6c 69 74 65 33 61 73 79  terp,"sqlite3asy
1750: 6e 63 5f 73 68 75 74 64 6f 77 6e 22 2c 74 65 73  nc_shutdown",tes
1760: 74 41 73 79 6e 63 53 68 75 74 64 6f 77 6e 2c 30  tAsyncShutdown,0
1770: 2c 30 29 3b 0a 23 65 6e 64 69 66 20 20 2f 2a 20  ,0);.#endif  /* 
1780: 53 51 4c 49 54 45 5f 45 4e 41 42 4c 45 5f 41 53  SQLITE_ENABLE_AS
1790: 59 4e 43 49 4f 20 2a 2f 0a 20 20 72 65 74 75 72  YNCIO */.  retur
17a0: 6e 20 54 43 4c 5f 4f 4b 3b 0a 7d 0a              n TCL_OK;.}.