Home
last modified time | relevance | path

Searched refs:nWrite (Results 1 – 25 of 32) sorted by relevance

12

/sqlite-3.40.0/ext/lsm1/
H A Dlsm_str.c103 int nWrite; in lsmStringVAppendf() local
107 nWrite = vsnprintf(pStr->z + pStr->n, nAvail, zFormat, ap1); in lsmStringVAppendf()
109 if( nWrite>=nAvail ){ in lsmStringVAppendf()
110 lsmStringExtend(pStr, nWrite+1); in lsmStringVAppendf()
112 nWrite = vsnprintf(pStr->z + pStr->n, nWrite+1, zFormat, ap2); in lsmStringVAppendf()
115 pStr->n += nWrite; in lsmStringVAppendf()
H A Dlsm_win32.c290 DWORD nWrite = 0; /* Bytes written using WriteFile */ in lsmWin32OsWrite() local
291 if( !WriteFile(pWin32File->hFile, aRem, nRem, &nWrite, &overlapped) ){ in lsmWin32OsWrite()
295 assert( nWrite==0 || nWrite<=(DWORD)nRem ); in lsmWin32OsWrite()
296 if( nWrite==0 || nWrite>(DWORD)nRem ){ in lsmWin32OsWrite()
299 iOff += nWrite; in lsmWin32OsWrite()
302 aRem += nWrite; in lsmWin32OsWrite()
303 nRem -= nWrite; in lsmWin32OsWrite()
H A Dlsm_file.c390 int nWrite in lsmEnvWrite() argument
2334 int nWrite = pFS->nMetaRwSize; in lsmFsMetaPageRelease() local
2477 int nWrite = 0; in fsAppendData() local
2497 nWrite = LSM_MIN(nData, nSpace); in fsAppendData()
2498 nRem = nData - nWrite; in fsAppendData()
2499 assert( nWrite>=0 ); in fsAppendData()
2500 if( nWrite!=0 ){ in fsAppendData()
2503 iApp += nWrite; in fsAppendData()
2514 if( nWrite>0 ){ in fsAppendData()
2711 pFS->nWrite++; in lsmFsPagePersist()
[all …]
H A Dlsm_shared.c917 u32 nWrite = 0; in lsmCheckpointWrite() local
945 nWrite = lsmCheckpointNWrite((u32 *)aData, 1); in lsmCheckpointWrite()
962 nWrite = lsmCheckpointNWrite(pDb->aSnapshot, 0) - nWrite; in lsmCheckpointWrite()
973 if( pnWrite && rc==LSM_OK ) *pnWrite = nWrite; in lsmCheckpointWrite()
1959 u32 nWrite = 0; /* Number of pages checkpointed */ in lsm_checkpoint() local
1963 rc = lsmCheckpointWrite(pDb, &nWrite); in lsm_checkpoint()
1969 if( rc==LSM_OK && nWrite ){ in lsm_checkpoint()
1970 nKB = (((i64)nWrite * lsmFsPageSize(pDb->pFS)) + 1023) / 1024; in lsm_checkpoint()
H A Dlsm_sorted.c3897 memcpy(&aData[iOff], &aWrite[nWrite-nRem], nCopy); in mergeWorkerData()
4406 nWrite = mergeworker.nWork; in sortedNewToplevel()
4445 if( pnWrite ) *pnWrite = nWrite; in sortedNewToplevel()
4446 pDb->pWorker->nWrite += nWrite; in sortedNewToplevel()
5121 pWorker->nWrite += (nWork - nRemaining); in sortedWork()
5296 int nWrite = 0; /* Number of pages written */ in doLsmWork() local
5308 nWrite += nThis; in doLsmWork()
5312 }while( rc==LSM_OK && bCkpt && (nWrite<nPage || nPage<0) ); in doLsmWork()
5317 *pnWrite = nWrite; in doLsmWork()
5332 int nWrite = 0; /* Number of pages written */ in lsm_work() local
[all …]
H A Dlsm_ckpt.c471 ckptSetValue(&ckpt, CKPT_HDR_NWRITE, pSnap->nWrite, &rc); in ckptExportSnapshot()
981 pNew->nWrite = aCkpt[CKPT_HDR_NWRITE]; in lsmCheckpointDeserialize()
1234 u32 nWrite = db->pShmhdr->aSnap1[CKPT_HDR_NWRITE]; in lsmCheckpointSize() local
1235 *pnKB = (int)(( ((i64)(nWrite - nSynced) * nPgsz) + 1023) / 1024); in lsmCheckpointSize()
/sqlite-3.40.0/test/
H A Dio.test48 set ::nWrite 0
49 proc nWrite {db} {
72 nWrite db
82 lappend ret [nWrite db]
84 lappend ret [nWrite db]
86 lappend ret [nWrite db]
88 lappend ret [nWrite db]
97 nWrite db
119 nWrite db
132 nWrite db ; nSync
[all …]
/sqlite-3.40.0/ext/lsm1/lsm-test/
H A Dlsmtest1.c76 int nWrite; /* Number of writes per iteration */ member
452 int nRange = MIN(p->nIter*p->nWrite, p->nRange); in doDataTest2()
454 for(ii=0; rc==0 && ii<p->nWrite; ii++){ in doDataTest2()
455 int iKey = (i*p->nWrite + ii) % p->nRange; in doDataTest2()
492 zSystem, zData, bRecover, pTest->nRange, pTest->nWrite, pTest->nIter in getName2()
534 int nWrite; /* Number of writes per iteration */ member
576 for(ii=0; ii<p->nWrite; ii++){ in doDataTest3()
631 zSystem, p->nRange, p->nIter, p->nWrite, p->nDelete, in getName3()
H A Dlsmtest3.c122 int nWrite, /* Number of key/value pairs to write */ in testWriteDatasourceRange() argument
126 for(i=0; i<nWrite; i++){ in testWriteDatasourceRange()
135 int nWrite, /* Number of keys to delete */ in testDeleteDatasourceRange() argument
139 for(i=0; i<nWrite; i++){ in testDeleteDatasourceRange()
H A Dlsmtest_io.c62 int nWrite; member
162 pCtx->nWrite += nByte/1024; in doOneCmd()
242 printf("%dK written in %d ms\n", ctx.nWrite, testTimeGet()); in do_io()
H A Dlsmtest8.c209 const int nWrite = 2000; in doWriterCrash1() local
224 for(i=0; rc==0 && i<nWrite; i+=nStep){ in doWriterCrash1()
225 testCaseProgress(i, nWrite, testCaseNDot(), &iDot); in doWriterCrash1()
H A Dlsmtest5.c507 int nWrite = 0; /* Number of completed database writes */ in mt1Main() local
555 nWrite += dbWriteOperation(&p->param, pDb, iKey, aValue, &rc); in mt1Main()
568 testThreadSetResult(pThreadSet, iThread, 0, "r/w: %d/%d", nRead, nWrite); in mt1Main()
H A Dlsmtest_tdb3.c1216 int nWrite; in worker_main() local
1223 nWrite = 0; in worker_main()
1224 rc = lsm_work(pWorker, 0, 256, &nWrite); in worker_main()
1226 if( p->eType==LSMTEST_THREAD_WORKER && nWrite ){ in worker_main()
1229 }while( nWrite && p->pWorker ); in worker_main()
H A Dlsmtest_main.c705 int nWrite = aParam[ST_WRITE]; in do_speed_test2() local
713 testWriteDatasourceRange(pDb, pData, i*nWrite, nWrite, &rc); in do_speed_test2()
717 nContent += nWrite; in do_speed_test2()
729 int iKey = testPrngValue(i*nWrite+iFetch) % nContent; in do_speed_test2()
H A Dlsmtest2.c339 int nWrite = 0; in crash_test1() local
341 testrc = lsm_work(db, 0, nPage, &nWrite); in crash_test1()
H A Dlsmtest_tdb4.c149 int nWrite = MIN(p->nSectorSize, iSz - iSOff); in btFlushSectors() local
151 if( nWrite ){ in btFlushSectors()
159 testPrngArray(i*13, (u32*)aWrite, nWrite/sizeof(u32)); in btFlushSectors()
171 rc = p->pBt->pVfs->xWrite(p->pFile, iSOff, aWrite, nWrite); in btFlushSectors()
/sqlite-3.40.0/src/
H A Dmemjournal.c194 int nWrite = iAmt; in memjrnlWrite() local
222 while( nWrite>0 ){ in memjrnlWrite()
225 int iSpace = MIN(nWrite, p->nChunkSize - iChunkOffset); in memjrnlWrite()
248 nWrite -= iSpace; in memjrnlWrite()
H A Dtest6.c212 int nWrite = 0; in writeListSync() local
214 for(pWrite=g.pWriteList; pWrite; pWrite=pWrite->pNext) nWrite++; in writeListSync()
216 iFinal = ((iFinal<0)?-1*iFinal:iFinal)%nWrite; in writeListSync()
996 int nWrite = 0; in writeCrashObjCmd() local
1002 if( Tcl_GetIntFromObj(interp, objv[1], &nWrite) ){ in writeCrashObjCmd()
1006 devsym_crash_on_write(nWrite); in writeCrashObjCmd()
H A Dtest_demovfs.c168 size_t nWrite; /* Return value from write() */ in demoDirectWrite() local
175 nWrite = write(p->fd, zBuf, iAmt); in demoDirectWrite()
176 if( nWrite!=iAmt ){ in demoDirectWrite()
H A Dtest_devsym.c514 void devsym_crash_on_write(int nWrite){ in devsym_crash_on_write() argument
522 g.nWriteCrash = nWrite; in devsym_crash_on_write()
H A Dos_win.c2849 DWORD nWrite; /* Bytes written by each WriteFile() call */ local
2860 if( !osWriteFile(pFile->h, aRem, nRem, &nWrite, 0) ){
2862 if( !osWriteFile(pFile->h, aRem, nRem, &nWrite, &overlapped) ){
2867 assert( nWrite==0 || nWrite<=(DWORD)nRem );
2868 if( nWrite==0 || nWrite>(DWORD)nRem ){
2873 offset += nWrite;
2877 aRem += nWrite;
2878 nRem -= nWrite;
H A Dtclsqlite.c304 int nWrite = toWrite; /* Number of bytes to write */ in incrblobOutput() local
309 if( (p->iSeek+nWrite)>nBlob ){ in incrblobOutput()
313 if( nWrite<=0 ){ in incrblobOutput()
317 rc = sqlite3_blob_write(p->pBlob, (void *)buf, nWrite, p->iSeek); in incrblobOutput()
323 p->iSeek += nWrite; in incrblobOutput()
324 return nWrite; in incrblobOutput()
H A DvdbeInt.h457 u32 nWrite; /* Number of write operations that have occurred */ member
/sqlite-3.40.0/ext/misc/
H A Dfileio.c395 sqlite3_int64 nWrite = 0; in writeFile() local
403 nWrite = sqlite3_value_bytes(pData); in writeFile()
404 if( nWrite!=n ){ in writeFile()
413 sqlite3_result_int64(pCtx, nWrite); in writeFile()
H A Dzipfile.c541 int nWrite in zipfileAppendData() argument
543 if( nWrite>0 ){ in zipfileAppendData()
544 size_t n = nWrite; in zipfileAppendData()
546 n = fwrite(aWrite, 1, nWrite, pTab->pWriteFd); in zipfileAppendData()
547 if( (int)n!=nWrite ){ in zipfileAppendData()
551 pTab->szCurrent += nWrite; in zipfileAppendData()

12