Lines Matching refs:mBatch
386 :mBatch(batch), in ReportWriter()
505 mBatch->forEachStreamingRequest([&filter, this](const sp<ReportRequest>& request) { in writeSection()
524 mBatch(batch), in Reporter()
541 mBatch->forEachListener([](const auto& listener) { listener->onReportStarted(); }); in runReport()
543 if (mBatch->hasPersistedReports()) { in runReport()
557 mBatch->forEachPersistedRequest([this, &persistedPrivacyPolicy]( in runReport()
588 mBatch->forEachPersistedRequest([](const sp<ReportRequest>& request) { in runReport()
594 mBatch->clearPersistedRequests(); in runReport()
612 mBatch->forEachStreamingRequest([](const sp<ReportRequest>& request) { in runReport()
622 mBatch->forEachStreamingRequest([](const sp<ReportRequest>& request) { in runReport()
657 mBatch->getCombinedPersistedArgs(&combinedArgs); in runReport()
674 mBatch->forEachStreamingRequest([reportId, &metadata](const sp<ReportRequest>& request) { in runReport()
687 mBatch->forEachStreamingRequest([](const sp<ReportRequest>& request) { in runReport()
693 mBatch->forEachListener([](const auto& listener) { in runReport()
697 mBatch->forEachListener([](const auto& listener) { in runReport()
710 if (!mBatch->containsSection(sectionId)) { in execute_section()
718 mBatch->forEachListener(sectionId, [sectionId](const auto& listener) { in execute_section()
745 mBatch->forEachListener(sectionId, [sectionId](const auto& listener) { in execute_section()
760 mBatch->forEachPersistedRequest([this](const sp<ReportRequest>& request) { in cancel_and_remove_failed_requests()
765 mBatch->removeRequest(request); in cancel_and_remove_failed_requests()
776 mBatch->getFailedRequests(&failed); in cancel_and_remove_failed_requests()
785 mBatch->removeRequest(request); in cancel_and_remove_failed_requests()