Lines Matching refs:batch
440 Batch& batch = mBatches.editItemAt(batchIndex); in consume() local
441 if (canAddSample(batch, &mMsg)) { in consume()
442 batch.samples.push(mMsg); in consume()
453 batch, batch.samples.size(), outSeq, outEvent); in consume()
471 Batch& batch = mBatches.editTop(); in consume() local
472 batch.samples.push(mMsg); in consume()
507 Batch& batch = mBatches.editItemAt(i); in consumeBatch() local
509 result = consumeSamples(factory, batch, batch.samples.size(), in consumeBatch()
516 ssize_t split = findSampleNoLaterThan(batch, sampleTime); in consumeBatch()
521 result = consumeSamples(factory, batch, split + 1, outSeq, outEvent); in consumeBatch()
523 if (batch.samples.isEmpty()) { in consumeBatch()
527 next = &batch.samples.itemAt(0); in consumeBatch()
539 Batch& batch, size_t count, uint32_t* outSeq, InputEvent** outEvent) { in consumeSamples() argument
545 InputMessage& msg = batch.samples.editItemAt(i); in consumeSamples()
558 batch.samples.removeItemsAt(0, count); in consumeSamples()
854 const Batch& batch = mBatches.itemAt(i); in findBatch() local
855 const InputMessage& head = batch.samples.itemAt(0); in findBatch()
926 bool InputConsumer::canAddSample(const Batch& batch, const InputMessage *msg) { in canAddSample() argument
927 const InputMessage& head = batch.samples.itemAt(0); in canAddSample()
942 ssize_t InputConsumer::findSampleNoLaterThan(const Batch& batch, nsecs_t time) { in findSampleNoLaterThan() argument
943 size_t numSamples = batch.samples.size(); in findSampleNoLaterThan()
946 && batch.samples.itemAt(index).body.motion.eventTime <= time) { in findSampleNoLaterThan()