Function TEST

cachelib/navy/block_cache/tests/BlockCacheTest.cpp:188–245

} // namespace

TEST(BlockCache, InsertLookup) {
  std::vector<CacheEntry> log;

  std::vector<uint32_t> hits(4);
  auto policy = std::make_unique<NiceMock<MockPolicy>>(&hits);
  auto device = createMemoryDevice(kDeviceSize, nullptr /* encryption */);
  auto ex = makeJobScheduler();
  auto config = makeConfig(std::move(policy), *device);
  auto engine = makeEngine(std::move(config));
  auto driver = makeDriver(std::move(engine), std::move(ex));

  BufferGen bg;
  {
    CacheEntry e{bg.gen(8), bg.gen(800)};
    EXPECT_EQ(Status::Ok,
              driver->insertAsync(e.key(), e.value(), nullptr, 0 /* poolId */,
                                  0 /* expiryTime */));
    // Flush the first region
    driver->flush();
    Buffer value;
    uint32_t lat = 0;
    EXPECT_EQ(Status::Ok, driver->lookup(e.key(), value, lat));

    driver->getCounters({[](folly::StringPiece name, double count,
                            CounterVisitor::CounterType type) {
      if (name == "navy_bc_lookups" &&
          type == CounterVisitor::CounterType::RATE) {
        EXPECT_EQ(1, count);
      }
    }});

    EXPECT_EQ(e.value(), value.view());
    log.push_back(std::move(e));
    EXPECT_EQ(1, hits[0]);
  }

  // After 15 more we fill region fully. Before adding 16th, block cache adds
  // region to tracked.
  for (size_t i = 0; i < 16; i++) {
    CacheEntry e{bg.gen(8), bg.gen(800)};
    EXPECT_EQ(Status::Ok,
              driver->insertAsync(e.key(), e.value(), nullptr, 0 /* poolId */,
                                  0 /* expiryTime */));
    log.push_back(std::move(e));
  }
  driver->flush();

  for (size_t i = 0; i < 17; i++) {
    Buffer value;
    uint32_t lat = 0;
    EXPECT_EQ(Status::Ok, driver->lookup(log[i].key(), value, lat));
    EXPECT_EQ(log[i].value(), value.view());
  }
  EXPECT_EQ(2, hits[0]);
  EXPECT_EQ(16, hits[1]);
  EXPECT_EQ(0, hits[2]);
  EXPECT_EQ(0, hits[3]);
}