jigaoluo / cmu15-445 Goto Github PK

// 1. In-memory cache all key-value pair
  std::vector<std::pair<KeyType, ValueType>> pair_cache;
//  pair_cache.reserve()
  assert(page_number == page_ids_cache.size());
  for (size_t page_index = 0; page_index < page_number; page_index++) {
    auto bpm_page = buffer_pool_manager_->FetchPage(page_ids_cache[page_index]);
    bpm_page->RLatch();
    auto block_page = reinterpret_cast<HashTableBlockPage<KeyType, ValueType, KeyComparator>*>(bpm_page->GetData());
    for (slot_offset_t slot_offset = 0;
         slot_offset < ((page_index == page_number - 1) ? BLOCK_ARRAY_SIZE_LAST_PAGE : BLOCK_ARRAY_SIZE_PRO_PAGE);
         slot_offset++) {
      if (block_page->IsReadable(slot_offset)) {
        pair_cache.emplace_back(block_page->KeyAt(slot_offset), block_page->ValueAt(slot_offset));
        block_page->Remove(slot_offset);
      }
    }
    bpm_page->RUnlatch();
    buffer_pool_manager_->UnpinPage(page_ids_cache[page_index], false);
  }