Lines Matching refs:threadset
90 static Thread threadset[N_THREAD]; variable
173 if( threadset[i].busy ){ in tcl_client_create()
177 threadset[i].busy = 1; in tcl_client_create()
178 sqlite3_free(threadset[i].zFilename); in tcl_client_create()
179 threadset[i].zFilename = sqlite3_mprintf("%s", argv[2]); in tcl_client_create()
180 threadset[i].opnum = 1; in tcl_client_create()
181 threadset[i].completed = 0; in tcl_client_create()
182 rc = pthread_create(&x, 0, client_main, &threadset[i]); in tcl_client_create()
185 sqlite3_free(threadset[i].zFilename); in tcl_client_create()
186 threadset[i].busy = 0; in tcl_client_create()
190 if( threadset[i].nServer==0 ){ in tcl_client_create()
191 threadset[i].nServer = 1; in tcl_client_create()
192 sqlite3_server_start2(&threadset[i].nServer); in tcl_client_create()
224 if( !threadset[i].busy ){ in tcl_client_wait()
228 client_wait(&threadset[i]); in tcl_client_wait()
268 if( threadset[i].busy ){ in tcl_client_halt()
269 stop_thread(&threadset[i]); in tcl_client_halt()
275 if( !threadset[i].busy ){ in tcl_client_halt()
279 stop_thread(&threadset[i]); in tcl_client_halt()
283 for(i=0; i<N_THREAD && threadset[i].busy==0; i++){} in tcl_client_halt()
287 for(i=0; i<N_THREAD && threadset[i].nServer==0; i++); in tcl_client_halt()
317 if( !threadset[i].busy ){ in tcl_client_argc()
321 client_wait(&threadset[i]); in tcl_client_argc()
322 sqlite3_snprintf(sizeof(zBuf), zBuf, "%d", threadset[i].argc); in tcl_client_argc()
349 if( !threadset[i].busy ){ in tcl_client_argv()
354 client_wait(&threadset[i]); in tcl_client_argv()
355 if( n<0 || n>=threadset[i].argc ){ in tcl_client_argv()
359 Tcl_AppendResult(interp, threadset[i].argv[n], 0); in tcl_client_argv()
385 if( !threadset[i].busy ){ in tcl_client_colname()
390 client_wait(&threadset[i]); in tcl_client_colname()
391 if( n<0 || n>=threadset[i].argc ){ in tcl_client_colname()
395 Tcl_AppendResult(interp, threadset[i].colv[n], 0); in tcl_client_colname()
423 if( !threadset[i].busy ){ in tcl_client_result()
427 client_wait(&threadset[i]); in tcl_client_result()
428 zName = sqlite3ErrName(threadset[i].rc); in tcl_client_result()
454 if( !threadset[i].busy ){ in tcl_client_error()
458 client_wait(&threadset[i]); in tcl_client_error()
459 Tcl_AppendResult(interp, threadset[i].zErr, 0); in tcl_client_error()
498 if( !threadset[i].busy ){ in tcl_client_compile()
502 client_wait(&threadset[i]); in tcl_client_compile()
503 threadset[i].xOp = do_compile; in tcl_client_compile()
504 sqlite3_free(threadset[i].zArg); in tcl_client_compile()
505 threadset[i].zArg = sqlite3_mprintf("%s", argv[2]); in tcl_client_compile()
506 threadset[i].opnum++; in tcl_client_compile()
551 if( !threadset[i].busy ){ in tcl_client_step()
555 client_wait(&threadset[i]); in tcl_client_step()
556 threadset[i].xOp = do_step; in tcl_client_step()
557 threadset[i].opnum++; in tcl_client_step()
593 if( !threadset[i].busy ){ in tcl_client_finalize()
597 client_wait(&threadset[i]); in tcl_client_finalize()
598 threadset[i].xOp = do_finalize; in tcl_client_finalize()
599 sqlite3_free(threadset[i].zArg); in tcl_client_finalize()
600 threadset[i].zArg = 0; in tcl_client_finalize()
601 threadset[i].opnum++; in tcl_client_finalize()
637 if( !threadset[i].busy ){ in tcl_client_reset()
641 client_wait(&threadset[i]); in tcl_client_reset()
642 threadset[i].xOp = do_reset; in tcl_client_reset()
643 sqlite3_free(threadset[i].zArg); in tcl_client_reset()
644 threadset[i].zArg = 0; in tcl_client_reset()
645 threadset[i].opnum++; in tcl_client_reset()
669 if( !threadset[i].busy ){ in tcl_client_swap()
673 client_wait(&threadset[i]); in tcl_client_swap()
676 if( !threadset[j].busy ){ in tcl_client_swap()
680 client_wait(&threadset[j]); in tcl_client_swap()
681 temp = threadset[i].db; in tcl_client_swap()
682 threadset[i].db = threadset[j].db; in tcl_client_swap()
683 threadset[j].db = temp; in tcl_client_swap()