Lines Matching refs:batch

767                     Batch& batch = mBatches[batchIndex];  in consume()  local
768 if (canAddSample(batch, &mMsg)) { in consume()
769 batch.samples.push_back(mMsg); in consume()
778 const size_t count = batch.samples.size(); in consume()
780 const InputMessage& msg = batch.samples[i]; in consume()
783 batch.samples.erase(batch.samples.begin(), batch.samples.begin() + count); in consume()
789 status_t result = consumeSamples(factory, batch, batch.samples.size(), in consume()
807 Batch batch; in consume() local
808 batch.samples.push_back(mMsg); in consume()
809 mBatches.push_back(batch); in consume()
879 Batch& batch = mBatches[i]; in consumeBatch() local
881 result = consumeSamples(factory, batch, batch.samples.size(), outSeq, outEvent); in consumeBatch()
890 ssize_t split = findSampleNoLaterThan(batch, sampleTime); in consumeBatch()
895 result = consumeSamples(factory, batch, split + 1, outSeq, outEvent); in consumeBatch()
897 if (batch.samples.empty()) { in consumeBatch()
901 next = &batch.samples[0]; in consumeBatch()
913 Batch& batch, size_t count, uint32_t* outSeq, InputEvent** outEvent) { in consumeSamples() argument
919 InputMessage& msg = batch.samples[i]; in consumeSamples()
932 batch.samples.erase(batch.samples.begin(), batch.samples.begin() + count); in consumeSamples()
1301 const Batch& batch = mBatches[0]; in getPendingBatchSource() local
1302 const InputMessage& head = batch.samples[0]; in getPendingBatchSource()
1308 const Batch& batch = mBatches[i]; in findBatch() local
1309 const InputMessage& head = batch.samples[0]; in findBatch()
1384 bool InputConsumer::canAddSample(const Batch& batch, const InputMessage *msg) { in canAddSample() argument
1385 const InputMessage& head = batch.samples[0]; in canAddSample()
1400 ssize_t InputConsumer::findSampleNoLaterThan(const Batch& batch, nsecs_t time) { in findSampleNoLaterThan() argument
1401 size_t numSamples = batch.samples.size(); in findSampleNoLaterThan()
1403 while (index < numSamples && batch.samples[index].body.motion.eventTime <= time) { in findSampleNoLaterThan()
1418 for (const Batch& batch : mBatches) { in dump() local
1420 for (const InputMessage& msg : batch.samples) { in dump()