Lines Matching refs:MmapRecordHeap_
1166 MmapRecordHeap_.push_back(&(it.second)); in ReadRecordsFromMmaps()
1168 if (MmapRecordHeap_.empty()) { in ReadRecordsFromMmaps()
1172 if (MmapRecordHeap_.size() > 1) { in ReadRecordsFromMmaps()
1173 for (const auto &it : MmapRecordHeap_) { in ReadRecordsFromMmaps()
1176 std::make_heap(MmapRecordHeap_.begin(), MmapRecordHeap_.end(), CompareRecordTime); in ReadRecordsFromMmaps()
1178 size_t heapSize = MmapRecordHeap_.size(); in ReadRecordsFromMmaps()
1180 std::pop_heap(MmapRecordHeap_.begin(), MmapRecordHeap_.begin() + heapSize, in ReadRecordsFromMmaps()
1182 MoveRecordToBuf(*MmapRecordHeap_[heapSize - 1]); in ReadRecordsFromMmaps()
1183 if (GetRecordFromMmap(*MmapRecordHeap_[heapSize - 1])) { in ReadRecordsFromMmaps()
1184 std::push_heap(MmapRecordHeap_.begin(), MmapRecordHeap_.begin() + heapSize, in ReadRecordsFromMmaps()
1192 while (GetRecordFromMmap(*MmapRecordHeap_.front())) { in ReadRecordsFromMmaps()
1193 MoveRecordToBuf(*MmapRecordHeap_.front()); in ReadRecordsFromMmaps()
1195 MmapRecordHeap_.clear(); in ReadRecordsFromMmaps()