Lines Matching refs:nRec

52803   int nRec;                   /* Pages journalled since last j-header written */
53611 ** Write the nRec Field - the number of page records that follow this
53617 ** A faster alternative is to write 0xFFFFFFFF to the nRec field. When
53707 u32 *pNRec, /* OUT: Value read from the nRec field */
53741 /* Read the first three 32-bit fields of the journal header: The nRec
54242 pPager->nRec = 0;
54861 ** Call the value from the second bullet "nRec". nRec is the number of
54863 ** value of nRec from the size of the journal file. But if a power
54867 ** the value of nRec computed from the file size would be too large. For
54868 ** that reason, we always use the nRec value in the header.
54870 ** If the nRec value is 0xffffffff it means that nRec should be computed
54895 u32 nRec; /* Number of Records in the journal */
54947 rc = readJournalHdr(pPager, isHot, szJ, &nRec, &mxPg);
54955 /* If nRec is 0xffffffff, then this journal was created by a process
54958 ** the value of nRec based on this assumption.
54960 if( nRec==0xffffffff ){
54962 nRec = (int)((szJ - JOURNAL_HDR_SZ(pPager))/JOURNAL_PG_SZ(pPager));
54965 /* If nRec is 0 and this rollback is of a transaction created by this
54972 ** When rolling back a hot journal, nRec==0 always means that the next
54974 ** when doing a ROLLBACK and the nRec==0 chunk is the last chunk in
54979 if( nRec==0 && !isHot &&
54981 nRec = (int)((szJ - pPager->journalOff) / JOURNAL_PG_SZ(pPager));
54998 for(u=0; u<nRec; u++){
55667 ** database (with some additional information - the nRec field
56329 ** then the nRec field of the most recently written journal header
56342 ** <update nRec field>
56376 ** occurs after nRec is updated but before this connection writes
56397 put32bits(&zHeader[sizeof(aJournalMagic)], pPager->nRec);
56409 /* Write the nRec value into the journal file header. If in
56411 ** all data has really hit the disk before nRec is updated to mark
56416 ** for garbage data to be appended to the file, the nRec field
56443 pPager->nRec = 0;
57943 pPager->nRec = 0;
58088 pPager->nRec++;
58772 ** header with the nRec field set to 0. If such a journal is used as
78262 ** Extract the iCol-th column from the nRec-byte record in pRec. Write
78272 int nRec, /* Size of buffer pRec in bytes */
78287 if( nHdr>nRec || iHdr>=nHdr ) return SQLITE_CORRUPT_BKPT;
78297 testcase( iField==nRec );
78298 testcase( iField==nRec+1 );
78299 if( iField>nRec ) return SQLITE_CORRUPT_BKPT;
85469 u32 nRec;
85472 nRec = sqlite3BtreePayloadSize(p->pCsr->uc.pCursor);
85473 aRec = sqlite3DbMallocRaw(db, nRec);
85475 rc = sqlite3BtreePayload(p->pCsr->uc.pCursor, 0, nRec, aRec);
85477 p->pUnpacked = vdbeUnpackRecord(&p->keyinfo, nRec, aRec);
95426 u64 nRec = 0; /* Size of record in bytes */
95451 rc = vdbePmaReadVarint(pReadr, &nRec);
95454 pReadr->nKey = (int)nRec;
95455 rc = vdbePmaReadBlob(pReadr, (int)nRec, &pReadr->aKey);
210332 int nRec, /* Number of bytes in aRec */
210339 pNew = (SessionChange *)sqlite3_malloc64(sizeof(SessionChange) + nRec);
210348 pNew->nRecord = nRec;
210349 memcpy(pNew->aRecord, aRec, nRec);
210372 sqlite3_int64 nByte = nRec + pExist->nRecord + sizeof(SessionChange);
210439 nByte = sizeof(SessionChange) + pExist->nRecord + nRec;
210459 memcpy(aCsr, aRec, nRec);
210460 aCsr += nRec;
210484 memcpy(aCsr, aRec, nRec);
210485 aCsr += nRec;
210512 int nRec;
210516 while( SQLITE_ROW==sessionChangesetNext(pIter, &aRec, &nRec, 0) ){
210597 pIter->bPatchset, pExist, op, bIndirect, aRec, nRec, &pChange
210864 ** or more remote UPDATE changes. The aRec/nRec buffer contains the current
210884 u8 *aRec, int nRec, /* Local change */
210888 sessionBufferGrow(pBuf, 2+nRec+nChange, pRc);
210959 int nRec = 0;
210964 while( SQLITE_ROW==sessionChangesetNext(pIter, &aRec, &nRec, &bNew) ){
211007 sessionAppendBlob(&sOut, aRec, nRec, &rc);
211021 pCsr, nRec-(pCsr-aRec),
211027 aRec, nRec, pChange->aRecord, pChange->nRecord, &rc
211039 pChange->aRecord, pChange->nRecord, aRec, nRec, &rc
211049 sessionAppendBlob(&sOut, aRec, nRec, &rc);