Lines Matching refs:readers
450 std::vector<KernelRecordReader*> readers; in ReadRecordsFromKernelBuffer() local
453 readers.push_back(&reader); in ReadRecordsFromKernelBuffer()
457 if (!readers.empty()) { in ReadRecordsFromKernelBuffer()
459 if (readers.size() == 1u) { in ReadRecordsFromKernelBuffer()
461 while (readers[0]->MoveToNextRecord(record_parser_)) { in ReadRecordsFromKernelBuffer()
462 PushRecordToRecordBuffer(readers[0]); in ReadRecordsFromKernelBuffer()
469 for (auto& reader : readers) { in ReadRecordsFromKernelBuffer()
472 std::make_heap(readers.begin(), readers.end(), CompareRecordTime); in ReadRecordsFromKernelBuffer()
473 size_t size = readers.size(); in ReadRecordsFromKernelBuffer()
475 std::pop_heap(readers.begin(), readers.begin() + size, CompareRecordTime); in ReadRecordsFromKernelBuffer()
476 PushRecordToRecordBuffer(readers[size - 1]); in ReadRecordsFromKernelBuffer()
477 if (readers[size - 1]->MoveToNextRecord(record_parser_)) { in ReadRecordsFromKernelBuffer()
478 std::push_heap(readers.begin(), readers.begin() + size, CompareRecordTime); in ReadRecordsFromKernelBuffer()