Lines Matching defs:batch
417 ALOGD("channel '%s' consumer ~ consumed batch event, seq=%u",
445 Batch& batch = mBatches.editItemAt(batchIndex);
446 if (canAddSample(batch, &mMsg)) {
447 batch.samples.push(mMsg);
449 ALOGD("channel '%s' consumer ~ appended to batch event",
454 // We cannot append to the batch in progress, so we need to consume
455 // the previous batch right now and defer the new message until later.
458 batch, batch.samples.size(), outSeq, outEvent);
464 ALOGD("channel '%s' consumer ~ consumed batch event and "
472 // Start a new batch if needed.
476 Batch& batch = mBatches.editTop();
477 batch.samples.push(mMsg);
479 ALOGD("channel '%s' consumer ~ started batch event",
512 Batch& batch = mBatches.editItemAt(i);
514 result = consumeSamples(factory, batch, batch.samples.size(),
521 ssize_t split = findSampleNoLaterThan(batch, sampleTime);
526 result = consumeSamples(factory, batch, split + 1, outSeq, outEvent);
528 if (batch.samples.isEmpty()) {
532 next = &batch.samples.itemAt(0);
544 Batch& batch, size_t count, uint32_t* outSeq, InputEvent** outEvent) {
550 InputMessage& msg = batch.samples.editItemAt(i);
563 batch.samples.removeItemsAt(0, count);
807 // Send finished signals for the batch sequence chain first.
837 // Send finished signal for the last message in the batch.
859 const Batch& batch = mBatches.itemAt(i);
860 const InputMessage& head = batch.samples.itemAt(0);
931 bool InputConsumer::canAddSample(const Batch& batch, const InputMessage *msg) {
932 const InputMessage& head = batch.samples.itemAt(0);
947 Batch& batch, nsecs_t time) {
948 size_t numSamples = batch.samples.size();
951 && batch.samples.itemAt(index).body.motion.eventTime <= time) {
