Lines Matching refs:batch
417 auto batch = std::make_shared<InflightBatch>(); in registerBatch() local
418 batch->mFirstFrame = frameNumber; in registerBatch()
419 batch->mBatchSize = batchSize; in registerBatch()
420 batch->mLastFrame = batch->mFirstFrame + batch->mBatchSize - 1; in registerBatch()
421 batch->mNumPartialResults = mNumPartialResults; in registerBatch()
423 batch->mBatchBufs.emplace(id, batch->mBatchSize); in registerBatch()
426 mInflightBatches.push_back(batch); in registerBatch()
454 std::shared_ptr<InflightBatch> batch = mInflightBatches[0]; in checkAndRemoveFirstBatch() local
457 Mutex::Autolock _l(batch->mLock); in checkAndRemoveFirstBatch()
458 if (batch->allDelivered()) { in checkAndRemoveFirstBatch()
459 batch->mRemoved = true; in checkAndRemoveFirstBatch()
470 std::shared_ptr<InflightBatch> batch) { in sendBatchShutterCbsLocked() argument
471 if (batch->mShutterDelivered) { in sendBatchShutterCbsLocked()
476 auto ret = mCallback->notify(batch->mShutterMsgs); in sendBatchShutterCbsLocked()
481 batch->mShutterDelivered = true; in sendBatchShutterCbsLocked()
482 batch->mShutterMsgs.clear(); in sendBatchShutterCbsLocked()
529 std::shared_ptr<InflightBatch> batch) { in sendBatchBuffersLocked() argument
530 sendBatchBuffersLocked(batch, mStreamsToBatch); in sendBatchBuffersLocked()
534 std::shared_ptr<InflightBatch> batch, const std::vector<int>& streams) { in sendBatchBuffersLocked() argument
537 auto it = batch->mBatchBufs.find(streamId); in sendBatchBuffersLocked()
538 if (it != batch->mBatchBufs.end()) { in sendBatchBuffersLocked()
555 auto it = batch->mBatchBufs.find(streamId); in sendBatchBuffersLocked()
556 if (it == batch->mBatchBufs.end()) { in sendBatchBuffersLocked()
569 results[i].frameNumber = batch->mFirstFrame + i; in sendBatchBuffersLocked()
578 auto it = batch->mBatchBufs.find(streamId); in sendBatchBuffersLocked()
579 if (it == batch->mBatchBufs.end()) { in sendBatchBuffersLocked()
599 auto it = batch->mBatchBufs.find(streamId); in sendBatchBuffersLocked()
600 if (it == batch->mBatchBufs.end()) { in sendBatchBuffersLocked()
611 std::shared_ptr<InflightBatch> batch, uint32_t lastPartialResultIdx) { in sendBatchMetadataLocked() argument
612 if (lastPartialResultIdx <= batch->mPartialResultProgress) { in sendBatchMetadataLocked()
620 for (auto& pair : batch->mResultMds) { in sendBatchMetadataLocked()
643 batch->mPartialResultProgress = lastPartialResultIdx; in sendBatchMetadataLocked()
645 batch->mResultMds.erase(partialIdx); in sendBatchMetadataLocked()
678 std::shared_ptr<InflightBatch> batch = mInflightBatches[0]; in notify() local
680 Mutex::Autolock _l(batch->mLock); in notify()
681 sendBatchShutterCbsLocked(batch); in notify()
682 sendBatchBuffersLocked(batch); in notify()
683 sendBatchMetadataLocked(batch, mNumPartialResults); in notify()
684 if (!batch->allDelivered()) { in notify()
688 batch->mRemoved = true; in notify()
697 std::shared_ptr<InflightBatch> batch = pair.second; in notify() local
699 Mutex::Autolock _l(batch->mLock); in notify()
701 if (batch->mRemoved) { in notify()
707 batch->mShutterMsgs.push_back(msg); in notify()
708 if (frameNumber == batch->mLastFrame) { in notify()
709 sendBatchShutterCbsLocked(batch); in notify()
714 if (frameNumber == batch->mLastFrame) { in notify()
769 std::shared_ptr<InflightBatch> batch = pair.second; in processCaptureResult() local
771 Mutex::Autolock _l(batch->mLock); in processCaptureResult()
773 if (batch->mRemoved) { in processCaptureResult()
782 batch->mResultMds[result.partialResult].mMds.push_back( in processCaptureResult()
790 auto it = batch->mBatchBufs.find(buffer.streamId); in processCaptureResult()
791 if (it != batch->mBatchBufs.end()) { in processCaptureResult()
816 if (result.frameNumber == batch->mLastFrame) { in processCaptureResult()
819 sendBatchMetadataLocked(batch, result.partialResult); in processCaptureResult()
823 sendBatchBuffersLocked(batch, filledStreams); in processCaptureResult()
829 if (result.frameNumber == batch->mLastFrame) { in processCaptureResult()