Home
last modified time | relevance | path

Searched refs:reader (Results 1 – 22 of 22) sorted by relevance

/sqlite-3.40.0/ext/lsm1/
H A Dlsm_log.c994 logReaderInit(pDb, pLog, 1, &reader); in lsmLogRecover()
1008 logReaderByte(&reader, &eType, &rc); in lsmLogRecover()
1058 bEof = logRequireCksum(&reader, nKey); in lsmLogRecover()
1089 pLog->aRegion[0].iEnd = reader.iOff-reader.buf.n+reader.iBuf; in lsmLogRecover()
1098 reader.iOff = iOff; in lsmLogRecover()
1099 reader.buf.n = reader.iBuf; in lsmLogRecover()
1121 logReaderInit(pDb, pLog, 0, &reader); in lsmLogRecover()
1129 pLog->aRegion[2].iEnd = reader.iOff - reader.buf.n + reader.iBuf; in lsmLogRecover()
1130 pLog->cksum0 = reader.cksum0; in lsmLogRecover()
1131 pLog->cksum1 = reader.cksum1; in lsmLogRecover()
[all …]
/sqlite-3.40.0/ext/fts1/
H A Dfulltext.c294 DocListReader reader; in docListUpdate() local
302 readerInit(&reader, d); in docListUpdate()
303 while( !readerAtEnd(&reader) && peekDocid(&reader)<iDocid ){ in docListUpdate()
304 skipDocument(&reader); in docListUpdate()
307 p = reader.p; in docListUpdate()
309 if( !readerAtEnd(&reader) && iDocid==peekDocid(&reader) ){ in docListUpdate()
310 skipDocument(&reader); in docListUpdate()
311 memmove(p, reader.p, docListEnd(d) - reader.p); in docListUpdate()
338 DocListReader reader; in docListSplit() local
340 readerInit(&reader, d); in docListSplit()
[all …]
H A Dfts1.c624 DocListReader reader; in docListUpdate() local
629 readerInit(&reader, d); in docListUpdate()
630 docListSpliceElement(&reader, firstDocid(pUpdate), in docListUpdate()
/sqlite-3.40.0/ext/fts2/
H A Dfts2.c3414 dlrStep(&c->reader); in fulltextNext()
4891 DLReader reader; in leafWriterStep() local
4895 dlrDestroy(&reader); in leafWriterStep()
5484 LeavesReader reader; in loadSegmentLeaf() local
5493 leavesReaderReset(&reader); in loadSegmentLeaf()
5507 LeavesReader reader; in loadSegmentLeaves() local
5514 leavesReaderReset(&reader); in loadSegmentLeaves()
5534 InteriorReader reader; in getChildrenContaining() local
6035 LeavesReader reader; member
6057 return leavesReaderTermCmp(&lr1->reader, &lr2->reader); in optLeavesReaderTermCmp()
[all …]
/sqlite-3.40.0/ext/fts3/
H A Dfts3_write.c4299 NodeReader reader; in fts3IncrmergeLoad() local
4306 if( fts3TermCmp(zKey, nKey, reader.term.a, reader.term.n)<=0 ){ in fts3IncrmergeLoad()
4347 NodeReader reader; in fts3IncrmergeLoad() local
4352 while( reader.aNode && rc==SQLITE_OK ) rc = nodeReaderNext(&reader); in fts3IncrmergeLoad()
4355 assert_fts3_nc( reader.term.n>0 || reader.aNode==0 ); in fts3IncrmergeLoad()
4357 memcpy(pNode->key.a, reader.term.a, reader.term.n); in fts3IncrmergeLoad()
4634 int res = fts3TermCmp(reader.term.a, reader.term.n, zTerm, nTerm); in fts3TruncateNode()
4640 pNew, &prev, reader.term.a, reader.term.n, in fts3TruncateNode()
4641 reader.aDoclist, reader.nDoclist in fts3TruncateNode()
4647 *piBlock = reader.iChild; in fts3TruncateNode()
[all …]
/sqlite-3.40.0/test/
H A Dwal3.test343 # already been copied to the database file, the reader grabs a special
347 # + The reader discovering that between the time when it determined
349 # that a writer has written to the log. In this case the reader should
491 # not yet been copied to the database file, the reader grabs a read
495 # + The reader discovering that between the time when it read the
497 # written to the log. In this case the reader should re-read the
518 if {$method == "xOpen"} { return "reader" }
528 if {$handle != "reader" } { return }
544 if {$handle != "reader" } { return }
H A De_walckpt.test306 # Close first the reader, then later the writer. Give up before
307 # closing the [db6] reader.
315 # Close first the writer, then later the reader. And finally the
316 # [db6] reader.
381 # Open a reader on the current database snapshot.
432 # The busy handler is not invoked (see below) and the db reader and
457 # The reader and writer have now dropped their locks. And so a
494 # The test below shows that both the reader and writer have
499 # they release the reader and writer transactions in different
H A Dthread005.test82 # One thread is a reader and the other thread a reader and a writer. The
92 # The reader thread does the following over and over as fast as possible:
109 # However, before the race-condition was fixed, if the reader's SELECT
H A Dwal2.test82 # and a reader ([db2]). For each of the 8 integer fields in the wal-index
87 # 2. Attempt to read the database using the reader. Before the reader
89 # of the integer fields (so that the reader ends up with a corrupted
92 # 3. Check that the reader recovers the wal-index and reads the correct
178 # the reader reads the corrupt wal-index header, but before it has
182 # Because the header checksum looks Ok, the reader does not run recovery,
184 # header is out-of-date, the reader reads the out-of-date snapshot.
186 # After this, the header is corrupted again and the reader is allowed
H A Dwalblock.test64 # write client is in the middle of updating it, the reader blocks until
H A Dtkt-fc62af4523.test65 # uncommitted data into the database file, the next reader will have
H A De_blobclose.test113 # A reader does not inhibit commit.
H A Dlock.test145 # connections, because UNIX supports reader/writer locks. Under windows,
H A Dspellfix.test57 reactivity reactor reactors reacts read readability readable reader readers
H A Dwalthread.test453 # reader can see an SQLITE_BUSY.
H A Dwal.test58 # wal-2.*: Test MVCC with one reader, one writer.
626 # At one point, if a reader failed to upgrade to a writer because it
H A Dfts1porter.test16617 reader reader
/sqlite-3.40.0/doc/
H A Dvfs-shm.txt63 only one reader or one writer or one checkpointer could be active at a
66 coexist with a reader, but no reader or writers could coexist with a
/sqlite-3.40.0/ext/fts5/
H A Dfts5_expr.c656 Fts5LookaheadReader reader; /* Input iterator */ member
712 fts5LookaheadReaderInit(pPoslist->p, pPoslist->n, &a[i].reader); in fts5ExprNearIsMatch()
724 iMax = a[0].reader.iPos; in fts5ExprNearIsMatch()
728 Fts5LookaheadReader *pPos = &a[i].reader; in fts5ExprNearIsMatch()
742 i64 iPos = a[i].reader.iPos; in fts5ExprNearIsMatch()
750 iMin = a[0].reader.iLookahead; in fts5ExprNearIsMatch()
752 if( a[i].reader.iLookahead < iMin ){ in fts5ExprNearIsMatch()
753 iMin = a[i].reader.iLookahead; in fts5ExprNearIsMatch()
757 if( fts5LookaheadReaderNext(&a[iAdv].reader) ) goto ismatch_out; in fts5ExprNearIsMatch()
/sqlite-3.40.0/ext/async/
H A DREADME.txt63 the vfs reader the xWrite() appears to have already completed.
/sqlite-3.40.0/ext/fts5/test/
H A Dfts5porter.test8316 read read reader reader
/sqlite-3.40.0/src/
H A Dsqlite.h.in10153 ** by the reader until a new read transaction is started.