Lines Matching refs:batch
453 Batch& batch = mBatches.editItemAt(batchIndex); in consume() local
454 if (canAddSample(batch, &mMsg)) { in consume()
455 batch.samples.push(mMsg); in consume()
466 batch, batch.samples.size(), outSeq, outEvent); in consume()
484 Batch& batch = mBatches.editTop(); in consume() local
485 batch.samples.push(mMsg); in consume()
521 Batch& batch = mBatches.editItemAt(i); in consumeBatch() local
523 result = consumeSamples(factory, batch, batch.samples.size(), in consumeBatch()
533 ssize_t split = findSampleNoLaterThan(batch, sampleTime); in consumeBatch()
538 result = consumeSamples(factory, batch, split + 1, outSeq, outEvent); in consumeBatch()
540 if (batch.samples.isEmpty()) { in consumeBatch()
544 next = &batch.samples.itemAt(0); in consumeBatch()
556 Batch& batch, size_t count, uint32_t* outSeq, InputEvent** outEvent) { in consumeSamples() argument
562 InputMessage& msg = batch.samples.editItemAt(i); in consumeSamples()
575 batch.samples.removeItemsAt(0, count); in consumeSamples()
881 const Batch& batch = mBatches.itemAt(i); in findBatch() local
882 const InputMessage& head = batch.samples.itemAt(0); in findBatch()
954 bool InputConsumer::canAddSample(const Batch& batch, const InputMessage *msg) { in canAddSample() argument
955 const InputMessage& head = batch.samples.itemAt(0); in canAddSample()
970 ssize_t InputConsumer::findSampleNoLaterThan(const Batch& batch, nsecs_t time) { in findSampleNoLaterThan() argument
971 size_t numSamples = batch.samples.size(); in findSampleNoLaterThan()
974 && batch.samples.itemAt(index).body.motion.eventTime <= time) { in findSampleNoLaterThan()