Annotation of embedaddon/sqlite3/src/test_async.c, revision 1.1.1.1
1.1 misho 1: /*
2: ** 2005 December 14
3: **
4: ** The author disclaims copyright to this source code. In place of
5: ** a legal notice, here is a blessing:
6: **
7: ** May you do good and not evil.
8: ** May you find forgiveness for yourself and forgive others.
9: ** May you share freely, never taking more than you give.
10: **
11: *************************************************************************
12: **
13: ** This file contains a binding of the asynchronous IO extension interface
14: ** (defined in ext/async/sqlite3async.h) to Tcl.
15: */
16:
17: #define TCL_THREADS
18: #include <tcl.h>
19:
20: #ifdef SQLITE_ENABLE_ASYNCIO
21:
22: #include "sqlite3async.h"
23: #include "sqlite3.h"
24: #include <assert.h>
25:
26: /* From test1.c */
27: const char *sqlite3TestErrorName(int);
28:
29:
30: struct TestAsyncGlobal {
31: int isInstalled; /* True when async VFS is installed */
32: } testasync_g = { 0 };
33:
34: TCL_DECLARE_MUTEX(testasync_g_writerMutex);
35:
36: /*
37: ** sqlite3async_initialize PARENT-VFS ISDEFAULT
38: */
39: static int testAsyncInit(
40: void * clientData,
41: Tcl_Interp *interp,
42: int objc,
43: Tcl_Obj *CONST objv[]
44: ){
45: const char *zParent;
46: int isDefault;
47: int rc;
48:
49: if( objc!=3 ){
50: Tcl_WrongNumArgs(interp, 1, objv, "PARENT-VFS ISDEFAULT");
51: return TCL_ERROR;
52: }
53: zParent = Tcl_GetString(objv[1]);
54: if( !*zParent ) {
55: zParent = 0;
56: }
57: if( Tcl_GetBooleanFromObj(interp, objv[2], &isDefault) ){
58: return TCL_ERROR;
59: }
60:
61: rc = sqlite3async_initialize(zParent, isDefault);
62: if( rc!=SQLITE_OK ){
63: Tcl_SetObjResult(interp, Tcl_NewStringObj(sqlite3TestErrorName(rc), -1));
64: return TCL_ERROR;
65: }
66: return TCL_OK;
67: }
68:
69: /*
70: ** sqlite3async_shutdown
71: */
72: static int testAsyncShutdown(
73: void * clientData,
74: Tcl_Interp *interp,
75: int objc,
76: Tcl_Obj *CONST objv[]
77: ){
78: sqlite3async_shutdown();
79: return TCL_OK;
80: }
81:
82: static Tcl_ThreadCreateType tclWriterThread(ClientData pIsStarted){
83: Tcl_MutexLock(&testasync_g_writerMutex);
84: *((int *)pIsStarted) = 1;
85: sqlite3async_run();
86: Tcl_MutexUnlock(&testasync_g_writerMutex);
87: Tcl_ExitThread(0);
88: TCL_THREAD_CREATE_RETURN;
89: }
90:
91: /*
92: ** sqlite3async_start
93: **
94: ** Start a new writer thread.
95: */
96: static int testAsyncStart(
97: void * clientData,
98: Tcl_Interp *interp,
99: int objc,
100: Tcl_Obj *CONST objv[]
101: ){
102: volatile int isStarted = 0;
103: ClientData threadData = (ClientData)&isStarted;
104:
105: Tcl_ThreadId x;
106: const int nStack = TCL_THREAD_STACK_DEFAULT;
107: const int flags = TCL_THREAD_NOFLAGS;
108: int rc;
109:
110: rc = Tcl_CreateThread(&x, tclWriterThread, threadData, nStack, flags);
111: if( rc!=TCL_OK ){
112: Tcl_AppendResult(interp, "Tcl_CreateThread() failed", 0);
113: return TCL_ERROR;
114: }
115:
116: while( isStarted==0 ) { /* Busy loop */ }
117: return TCL_OK;
118: }
119:
120: /*
121: ** sqlite3async_wait
122: **
123: ** Wait for the current writer thread to terminate.
124: **
125: ** If the current writer thread is set to run forever then this
126: ** command would block forever. To prevent that, an error is returned.
127: */
128: static int testAsyncWait(
129: void * clientData,
130: Tcl_Interp *interp,
131: int objc,
132: Tcl_Obj *CONST objv[]
133: ){
134: int eCond;
135: if( objc!=1 ){
136: Tcl_WrongNumArgs(interp, 1, objv, "");
137: return TCL_ERROR;
138: }
139:
140: sqlite3async_control(SQLITEASYNC_GET_HALT, &eCond);
141: if( eCond==SQLITEASYNC_HALT_NEVER ){
142: Tcl_AppendResult(interp, "would block forever", (char*)0);
143: return TCL_ERROR;
144: }
145:
146: Tcl_MutexLock(&testasync_g_writerMutex);
147: Tcl_MutexUnlock(&testasync_g_writerMutex);
148: return TCL_OK;
149: }
150:
151: /*
152: ** sqlite3async_control OPTION ?VALUE?
153: */
154: static int testAsyncControl(
155: void * clientData,
156: Tcl_Interp *interp,
157: int objc,
158: Tcl_Obj *CONST objv[]
159: ){
160: int rc = SQLITE_OK;
161: int aeOpt[] = { SQLITEASYNC_HALT, SQLITEASYNC_DELAY, SQLITEASYNC_LOCKFILES };
162: const char *azOpt[] = { "halt", "delay", "lockfiles", 0 };
163: const char *az[] = { "never", "now", "idle", 0 };
164: int iVal;
165: int eOpt;
166:
167: if( objc!=2 && objc!=3 ){
168: Tcl_WrongNumArgs(interp, 1, objv, "OPTION ?VALUE?");
169: return TCL_ERROR;
170: }
171: if( Tcl_GetIndexFromObj(interp, objv[1], azOpt, "option", 0, &eOpt) ){
172: return TCL_ERROR;
173: }
174: eOpt = aeOpt[eOpt];
175:
176: if( objc==3 ){
177: switch( eOpt ){
178: case SQLITEASYNC_HALT: {
179: assert( SQLITEASYNC_HALT_NEVER==0 );
180: assert( SQLITEASYNC_HALT_NOW==1 );
181: assert( SQLITEASYNC_HALT_IDLE==2 );
182: if( Tcl_GetIndexFromObj(interp, objv[2], az, "value", 0, &iVal) ){
183: return TCL_ERROR;
184: }
185: break;
186: }
187: case SQLITEASYNC_DELAY:
188: if( Tcl_GetIntFromObj(interp, objv[2], &iVal) ){
189: return TCL_ERROR;
190: }
191: break;
192:
193: case SQLITEASYNC_LOCKFILES:
194: if( Tcl_GetBooleanFromObj(interp, objv[2], &iVal) ){
195: return TCL_ERROR;
196: }
197: break;
198: }
199:
200: rc = sqlite3async_control(eOpt, iVal);
201: }
202:
203: if( rc==SQLITE_OK ){
204: rc = sqlite3async_control(
205: eOpt==SQLITEASYNC_HALT ? SQLITEASYNC_GET_HALT :
206: eOpt==SQLITEASYNC_DELAY ? SQLITEASYNC_GET_DELAY :
207: SQLITEASYNC_GET_LOCKFILES, &iVal);
208: }
209:
210: if( rc!=SQLITE_OK ){
211: Tcl_SetObjResult(interp, Tcl_NewStringObj(sqlite3TestErrorName(rc), -1));
212: return TCL_ERROR;
213: }
214:
215: if( eOpt==SQLITEASYNC_HALT ){
216: Tcl_SetObjResult(interp, Tcl_NewStringObj(az[iVal], -1));
217: }else{
218: Tcl_SetObjResult(interp, Tcl_NewIntObj(iVal));
219: }
220:
221: return TCL_OK;
222: }
223:
224: #endif /* SQLITE_ENABLE_ASYNCIO */
225:
226: /*
227: ** This routine registers the custom TCL commands defined in this
228: ** module. This should be the only procedure visible from outside
229: ** of this module.
230: */
231: int Sqlitetestasync_Init(Tcl_Interp *interp){
232: #ifdef SQLITE_ENABLE_ASYNCIO
233: Tcl_CreateObjCommand(interp,"sqlite3async_start",testAsyncStart,0,0);
234: Tcl_CreateObjCommand(interp,"sqlite3async_wait",testAsyncWait,0,0);
235:
236: Tcl_CreateObjCommand(interp,"sqlite3async_control",testAsyncControl,0,0);
237: Tcl_CreateObjCommand(interp,"sqlite3async_initialize",testAsyncInit,0,0);
238: Tcl_CreateObjCommand(interp,"sqlite3async_shutdown",testAsyncShutdown,0,0);
239: #endif /* SQLITE_ENABLE_ASYNCIO */
240: return TCL_OK;
241: }
FreeBSD-CVSweb <freebsd-cvsweb@FreeBSD.org>
![[BACK]](/icons/cvsweb/back.gif){kind=icon}
Return to test_async.c CVS log ![[TXT]](/icons/cvsweb/text.gif){kind=icon}
![[DIR]](/icons/cvsweb/dir.gif){kind=icon}
Up to [ELWIX - Embedded LightWeight unIX -] / embedaddon / sqlite3 / src