Lines Matching defs:nRec
56152 int nRec; /* Pages journalled since last j-header written */
56974 ** Write the nRec Field - the number of page records that follow this
56980 ** A faster alternative is to write 0xFFFFFFFF to the nRec field. When
57070 u32 *pNRec, /* OUT: Value read from the nRec field */
57104 /* Read the first three 32-bit fields of the journal header: The nRec
57605 pPager->nRec = 0;
58278 ** Call the value from the second bullet "nRec". nRec is the number of
58280 ** value of nRec from the size of the journal file. But if a power
58284 ** the value of nRec computed from the file size would be too large. For
58285 ** that reason, we always use the nRec value in the header.
58287 ** If the nRec value is 0xffffffff it means that nRec should be computed
58312 u32 nRec; /* Number of Records in the journal */
58364 rc = readJournalHdr(pPager, isHot, szJ, &nRec, &mxPg);
58372 /* If nRec is 0xffffffff, then this journal was created by a process
58375 ** the value of nRec based on this assumption.
58377 if( nRec==0xffffffff ){
58379 nRec = (int)((szJ - JOURNAL_HDR_SZ(pPager))/JOURNAL_PG_SZ(pPager));
58382 /* If nRec is 0 and this rollback is of a transaction created by this
58389 ** When rolling back a hot journal, nRec==0 always means that the next
58391 ** when doing a ROLLBACK and the nRec==0 chunk is the last chunk in
58396 if( nRec==0 && !isHot &&
58398 nRec = (int)((szJ - pPager->journalOff) / JOURNAL_PG_SZ(pPager));
58418 for(u=0; u<nRec; u++){
59090 ** database (with some additional information - the nRec field
59765 ** then the nRec field of the most recently written journal header
59778 ** <update nRec field>
59812 ** occurs after nRec is updated but before this connection writes
59833 put32bits(&zHeader[sizeof(aJournalMagic)], pPager->nRec);
59845 /* Write the nRec value into the journal file header. If in
59847 ** all data has really hit the disk before nRec is updated to mark
59852 ** for garbage data to be appended to the file, the nRec field
59879 pPager->nRec = 0;
61392 pPager->nRec = 0;
61538 pPager->nRec++;
62222 ** header with the nRec field set to 0. If such a journal is used as
82416 ** Extract the iCol-th column from the nRec-byte record in pRec. Write
82426 int nRec, /* Size of buffer pRec in bytes */
82441 if( nHdr>nRec || iHdr>=nHdr ) return SQLITE_CORRUPT_BKPT;
82451 testcase( iField==nRec );
82452 testcase( iField==nRec+1 );
82453 if( iField>nRec ) return SQLITE_CORRUPT_BKPT;
89851 u32 nRec;
89855 nRec = sqlite3BtreePayloadSize(p->pCsr->uc.pCursor);
89856 aRec = sqlite3DbMallocRaw(db, nRec);
89858 rc = sqlite3BtreePayload(p->pCsr->uc.pCursor, 0, nRec, aRec);
89860 p->pUnpacked = vdbeUnpackRecord(&p->keyinfo, nRec, aRec);
100455 u64 nRec = 0; /* Size of record in bytes */
100480 rc = vdbePmaReadVarint(pReadr, &nRec);
100483 pReadr->nKey = (int)nRec;
100484 rc = vdbePmaReadBlob(pReadr, (int)nRec, &pReadr->aKey);
220488 int nRec, /* Number of bytes in aRec */
220495 pNew = (SessionChange *)sqlite3_malloc64(sizeof(SessionChange) + nRec);
220504 pNew->nRecord = nRec;
220505 memcpy(pNew->aRecord, aRec, nRec);
220528 sqlite3_int64 nByte = nRec + pExist->nRecord + sizeof(SessionChange);
220595 nByte = sizeof(SessionChange) + pExist->nRecord + nRec;
220615 memcpy(aCsr, aRec, nRec);
220616 aCsr += nRec;
220640 memcpy(aCsr, aRec, nRec);
220641 aCsr += nRec;
220668 int nRec;
220672 while( SQLITE_ROW==sessionChangesetNext(pIter, &aRec, &nRec, 0) ){
220753 pIter->bPatchset, pExist, op, bIndirect, aRec, nRec, &pChange
221020 ** or more remote UPDATE changes. The aRec/nRec buffer contains the current
221040 u8 *aRec, int nRec, /* Local change */
221044 sessionBufferGrow(pBuf, 2+nRec+nChange, pRc);
221115 int nRec = 0;
221120 while( SQLITE_ROW==sessionChangesetNext(pIter, &aRec, &nRec, &bNew) ){
221163 sessionAppendBlob(&sOut, aRec, nRec, &rc);
221177 pCsr, nRec-(pCsr-aRec),
221183 aRec, nRec, pChange->aRecord, pChange->nRecord, &rc
221195 pChange->aRecord, pChange->nRecord, aRec, nRec, &rc
221205 sessionAppendBlob(&sOut, aRec, nRec, &rc);