Searched refs:mergeworker (Results 1 – 1 of 1) sorted by relevance
4388 mergeworker.pDb = pDb; in sortedNewToplevel()4389 mergeworker.pLevel = pNew; in sortedNewToplevel()4390 mergeworker.pCsr = pCsr; in sortedNewToplevel()4394 mergeworker.bFlush = 1; in sortedNewToplevel()4399 rc = mergeWorkerStep(&mergeworker); in sortedNewToplevel()4401 mergeWorkerShutdown(&mergeworker, &rc); in sortedNewToplevel()4406 nWrite = mergeworker.nWork; in sortedNewToplevel()4971 assert( mergeworker.nWork==0 ); in sortedWork()4978 rc = mergeWorkerStep(&mergeworker); in sortedWork()4986 && (rtTopic(mergeworker.pCsr->eType) || mergeWorkerDone(&mergeworker)) in sortedWork()[all …]