Lines Matching refs:async
394 } async = { 0,0,0,0,0,1,0,0 }; variable
546 if( async.pQueueLast ){ in addAsyncWrite()
547 assert( async.pQueueFirst ); in addAsyncWrite()
548 async.pQueueLast->pNext = pWrite; in addAsyncWrite()
550 async.pQueueFirst = pWrite; in addAsyncWrite()
552 async.pQueueLast = pWrite; in addAsyncWrite()
557 async.nFile--; in addAsyncWrite()
576 if( async.nFile==0 ){ in incrOpenFileCount()
577 async.ioError = SQLITE_OK; in incrOpenFileCount()
579 async.nFile++; in incrOpenFileCount()
595 if( op!=ASYNC_CLOSE && async.ioError ){ in addNewAsyncWrite()
596 return async.ioError; in addNewAsyncWrite()
680 if( async.ioError!=SQLITE_OK ){ in asyncRead()
681 rc = async.ioError; in asyncRead()
702 for(pWrite=async.pQueueFirst; pWrite; pWrite = pWrite->pNext){ in asyncRead()
784 for(pWrite=async.pQueueFirst; pWrite; pWrite = pWrite->pNext){ in asyncFileSize()
850 AsyncLock *p = async.pLock; in findLock()
981 for(pp=&async.pLock; *pp!=pLock; pp=&((*pp)->pNext)); in unlinkAsyncFile()
1103 if( async.bLockFiles && (flags&SQLITE_OPEN_MAIN_DB) ){ in asyncOpen()
1115 pLock->pNext = async.pLock; in asyncOpen()
1116 async.pLock = pLock; in asyncOpen()
1204 for(p=async.pQueueFirst; p; p = p->pNext){ in asyncAccess()
1348 while( async.eHalt!=SQLITEASYNC_HALT_NOW ){ in asyncWriterThread()
1355 while( (p = async.pQueueFirst)==0 ){ in asyncWriterThread()
1356 if( async.eHalt!=SQLITEASYNC_HALT_NEVER ){ in asyncWriterThread()
1387 if( async.ioError!=SQLITE_OK && p->op!=ASYNC_CLOSE ){ in asyncWriterThread()
1452 async.pQueueFirst = p->pNext; in asyncWriterThread()
1494 assert( async.pQueueFirst==p ); in asyncWriterThread()
1495 for(pIter=async.pQueueFirst->pNext; pIter; pIter=pIter->pNext){ in asyncWriterThread()
1540 if( p==async.pQueueLast ){ in asyncWriterThread()
1541 async.pQueueLast = 0; in asyncWriterThread()
1545 async.pQueueFirst = p->pNext; in asyncWriterThread()
1569 async.ioError = rc; in asyncWriterThread()
1572 if( async.ioError && !async.pQueueFirst ){ in asyncWriterThread()
1574 if( 0==async.pLock ){ in asyncWriterThread()
1575 async.ioError = SQLITE_OK; in asyncWriterThread()
1583 if( !async.pQueueFirst || !async.ioError ){ in asyncWriterThread()
1586 if( async.ioDelay>0 ){ in asyncWriterThread()
1587 pVfs->xSleep(pVfs, async.ioDelay*1000); in asyncWriterThread()
1652 async.eHalt = eWhen; in sqlite3async_control()
1665 async.ioDelay = iDelay; in sqlite3async_control()
1672 if( async.nFile || async.pQueueFirst ){ in sqlite3async_control()
1677 async.bLockFiles = bLock; in sqlite3async_control()
1684 *peWhen = async.eHalt; in sqlite3async_control()
1689 *piDelay = async.ioDelay; in sqlite3async_control()
1694 *piDelay = async.bLockFiles; in sqlite3async_control()