• Home
  • Raw
  • Download

Lines Matching refs:targetBatch

213         BatchBase** targetBatch, size_t* insertBatchIndex) const {  in locateInsertIndex()  argument
217 if (overBatch == *targetBatch) break; in locateInsertIndex()
222 if (!*targetBatch) break; // found insert position, quit in locateInsertIndex()
229 *targetBatch = nullptr; in locateInsertIndex()
290 OpBatch* targetBatch = mBatchLookup[batchId]; in deferUnmergeableOp() local
293 if (targetBatch) { in deferUnmergeableOp()
295 (BatchBase**)(&targetBatch), &insertBatchIndex); in deferUnmergeableOp()
298 if (targetBatch) { in deferUnmergeableOp()
299 targetBatch->batchOp(op); in deferUnmergeableOp()
302 targetBatch = allocator.create<OpBatch>(batchId, op); in deferUnmergeableOp()
303 mBatchLookup[batchId] = targetBatch; in deferUnmergeableOp()
304 mBatches.insert(mBatches.begin() + insertBatchIndex, targetBatch); in deferUnmergeableOp()
311 MergingOpBatch* targetBatch = nullptr; in deferMergeableOp() local
316 targetBatch = getResult->second; in deferMergeableOp()
317 if (!targetBatch->canMergeWith(op)) { in deferMergeableOp()
318 targetBatch = nullptr; in deferMergeableOp()
324 (BatchBase**)(&targetBatch), &insertBatchIndex); in deferMergeableOp()
326 if (targetBatch) { in deferMergeableOp()
327 targetBatch->mergeOp(op); in deferMergeableOp()
330 targetBatch = allocator.create<MergingOpBatch>(batchId, op); in deferMergeableOp()
331 mMergingBatchLookup[batchId].insert(std::make_pair(mergeId, targetBatch)); in deferMergeableOp()
333 mBatches.insert(mBatches.begin() + insertBatchIndex, targetBatch); in deferMergeableOp()