101     StreamingFilterFd(uint8_t privacyPolicy, int fd, const sp<ReportRequest>& request);
110             const sp<ReportRequest>& request)  in StreamingFilterFd()  argument
112          mRequest(request) {  in StreamingFilterFd()
230         sp<ReportRequest> request = found->second;  in addPersistedReport()  local
231         request->args.merge(args);  in addPersistedReport()
261     for (vector<sp<ReportRequest>>::iterator request = mStreamingRequests.begin();  in forEachStreamingRequest()  local
262             request != mStreamingRequests.end(); request++) {  in forEachStreamingRequest()
263         func(*request);  in forEachStreamingRequest()
276     for (vector<sp<ReportRequest>>::iterator request = mStreamingRequests.begin();  in forEachListener()  local
277             request != mStreamingRequests.end(); request++) {  in forEachListener()
278         sp<IIncidentReportStatusListener> listener = (*request)->getListener();  in forEachListener()
296     for (vector<sp<ReportRequest>>::iterator request = mStreamingRequests.begin();  in forEachListener()  local
297             request != mStreamingRequests.end(); request++) {  in forEachListener()
298         if ((*request)->containsSection(sectionId)) {  in forEachListener()
299             sp<IIncidentReportStatusListener> listener = (*request)->getListener();  in forEachListener()
323     for (vector<sp<ReportRequest>>::iterator request = mStreamingRequests.begin();  in containsSection()  local
324             request != mStreamingRequests.end(); request++) {  in containsSection()
325         if ((*request)->containsSection(sectionId)) {  in containsSection()
337     for (vector<sp<ReportRequest>>::iterator request = mStreamingRequests.begin();  in transferStreamingRequests()  local
338             request != mStreamingRequests.end(); request++) {  in transferStreamingRequests()
339         that->mStreamingRequests.push_back(*request);  in transferStreamingRequests()
359     for (vector<sp<ReportRequest>>::iterator request = mStreamingRequests.begin();  in getFailedRequests()  local
360             request != mStreamingRequests.end(); request++) {  in getFailedRequests()
361         if ((*request)->getStatus() != NO_ERROR) {  in getFailedRequests()
362             requests->push_back(*request);  in getFailedRequests()
367 void ReportBatch::removeRequest(const sp<ReportRequest>& request) {  in removeRequest()  argument
370         if (it->second == request) {  in removeRequest()
377         if (*it == request) {  in removeRequest()
505     mBatch->forEachStreamingRequest([&filter, this](const sp<ReportRequest>& request) {  in writeSection()  argument
506         if (request->ok()  in writeSection()
507                 && request->args.containsSection(mCurrentSectionId,  in writeSection()
509             filter.addFd(new StreamingFilterFd(request->args.getPrivacyPolicy(),  in writeSection()
510                         request->getFd(), request));  in writeSection()
558                         const sp<ReportRequest>& request) {  in runReport()  argument
559                 mPersistedFile->addReport(request->args);  in runReport()
560                 if (request->args.getPrivacyPolicy() < persistedPrivacyPolicy) {  in runReport()
561                     persistedPrivacyPolicy = request->args.getPrivacyPolicy();  in runReport()
588             mBatch->forEachPersistedRequest([](const sp<ReportRequest>& request) {  in runReport()  argument
589                 sp<IIncidentReportStatusListener> listener = request->getListener();  in runReport()
612     mBatch->forEachStreamingRequest([](const sp<ReportRequest>& request) {  in runReport()  argument
613         status_t err = request->initGzipIfNecessary();  in runReport()
622     mBatch->forEachStreamingRequest([](const sp<ReportRequest>& request) {  in runReport()  argument
623         const vector<vector<uint8_t>>& headers = request->args.headers();  in runReport()
628             write_header_section(request->getFd(), buf->data(), buf->size());  in runReport()
674     mBatch->forEachStreamingRequest([reportId, &metadata](const sp<ReportRequest>& request) {  in runReport()  argument
677                 request->args.getPrivacyPolicy(), request);  in runReport()
678         status_t nonFatalErr = write_section(request->getFd(), FIELD_ID_METADATA,  in runReport()
687     mBatch->forEachStreamingRequest([](const sp<ReportRequest>& request) {  in runReport()  argument
688         request->closeFd();  in runReport()
760             mBatch->forEachPersistedRequest([this](const sp<ReportRequest>& request) {  in cancel_and_remove_failed_requests()  argument
761                 sp<IIncidentReportStatusListener> listener = request->getListener();  in cancel_and_remove_failed_requests()
765                 mBatch->removeRequest(request);  in cancel_and_remove_failed_requests()
777     for (sp<ReportRequest>& request: failed) {  in cancel_and_remove_failed_requests()
779                 strerror(-request->getStatus()));  in cancel_and_remove_failed_requests()
780         sp<IIncidentReportStatusListener> listener = request->getListener();  in cancel_and_remove_failed_requests()
784         request->closeFd();  // Will only close the streaming ones.  in cancel_and_remove_failed_requests()
785         mBatch->removeRequest(request);  in cancel_and_remove_failed_requests()