Lines Matching refs:MmapRecordHeap_
1191 MmapRecordHeap_.push_back(&(it.second)); in ReadRecordsFromMmaps()
1193 if (MmapRecordHeap_.empty()) { in ReadRecordsFromMmaps()
1197 if (MmapRecordHeap_.size() > 1) { in ReadRecordsFromMmaps()
1198 for (const auto &it : MmapRecordHeap_) { in ReadRecordsFromMmaps()
1201 std::make_heap(MmapRecordHeap_.begin(), MmapRecordHeap_.end(), CompareRecordTime); in ReadRecordsFromMmaps()
1203 size_t heapSize = MmapRecordHeap_.size(); in ReadRecordsFromMmaps()
1205 std::pop_heap(MmapRecordHeap_.begin(), MmapRecordHeap_.begin() + heapSize, in ReadRecordsFromMmaps()
1207 MoveRecordToBuf(*MmapRecordHeap_[heapSize - 1]); in ReadRecordsFromMmaps()
1208 if (GetRecordFromMmap(*MmapRecordHeap_[heapSize - 1])) { in ReadRecordsFromMmaps()
1209 std::push_heap(MmapRecordHeap_.begin(), MmapRecordHeap_.begin() + heapSize, in ReadRecordsFromMmaps()
1217 while (GetRecordFromMmap(*MmapRecordHeap_.front())) { in ReadRecordsFromMmaps()
1218 MoveRecordToBuf(*MmapRecordHeap_.front()); in ReadRecordsFromMmaps()
1220 MmapRecordHeap_.clear(); in ReadRecordsFromMmaps()