Skip to content

Commit b456aba

Browse files
igchorbyrnedj
igchor
authored and
byrnedj
committed
This commit contains the additional memory tiers tests
for different pool sizes. We also use getPoolSize(pid), to get total size from all pools across allocators. It also fixes the tiering sizes (pulls changes from what was issue75 rebased commit that did not make it into upstream commits).
1 parent 5a317e7 commit b456aba

File tree

5 files changed

+161
-13
lines changed

5 files changed

+161
-13
lines changed

‎cachelib/allocator/CacheAllocator-inl.h‎

Lines changed: 30 additions & 6 deletions
Original file line numberDiff line numberDiff line change
@@ -121,6 +121,16 @@ ShmSegmentOpts CacheAllocator<CacheTrait>::createShmCacheOpts(TierId tid) {
121121
return opts;
122122
}
123123

124+
template <typename CacheTrait>
125+
size_t CacheAllocator<CacheTrait>::memoryTierSize(TierId tid) const {
126+
auto partitions = std::accumulate(memoryTierConfigs.begin(), memoryTierConfigs.end(), 0UL,
127+
[](const size_t i, const MemoryTierCacheConfig& config){
128+
return i + config.getRatio();
129+
});
130+
131+
return memoryTierConfigs[tid].calculateTierSize(config_.getCacheSize(), partitions);
132+
}
133+
124134
template <typename CacheTrait>
125135
std::vector<std::unique_ptr<MemoryAllocator>>
126136
CacheAllocator<CacheTrait>::createPrivateAllocator() {
@@ -142,14 +152,15 @@ CacheAllocator<CacheTrait>::createPrivateAllocator() {
142152
template <typename CacheTrait>
143153
std::unique_ptr<MemoryAllocator>
144154
CacheAllocator<CacheTrait>::createNewMemoryAllocator(TierId tid) {
155+
size_t tierSize = memoryTierSize(tid);
145156
return std::make_unique<MemoryAllocator>(
146157
getAllocatorConfig(config_),
147158
shmManager_
148159
->createShm(detail::kShmCacheName + std::to_string(tid),
149-
config_.getCacheSize(), config_.slabMemoryBaseAddr,
160+
tierSize, config_.slabMemoryBaseAddr,
150161
createShmCacheOpts(tid))
151162
.addr,
152-
config_.getCacheSize());
163+
tierSize);
153164
}
154165

155166
template <typename CacheTrait>
@@ -160,7 +171,7 @@ CacheAllocator<CacheTrait>::restoreMemoryAllocator(TierId tid) {
160171
shmManager_
161172
->attachShm(detail::kShmCacheName + std::to_string(tid),
162173
config_.slabMemoryBaseAddr, createShmCacheOpts(tid)).addr,
163-
config_.getCacheSize(),
174+
memoryTierSize(tid),
164175
config_.disableFullCoredump);
165176
}
166177

@@ -2368,6 +2379,16 @@ const std::string CacheAllocator<CacheTrait>::getCacheName() const {
23682379
return config_.cacheName;
23692380
}
23702381

2382+
template <typename CacheTrait>
2383+
size_t CacheAllocator<CacheTrait>::getPoolSize(PoolId poolId) const {
2384+
size_t poolSize = 0;
2385+
for (auto& allocator: allocator_) {
2386+
const auto& pool = allocator->getPool(poolId);
2387+
poolSize += pool.getPoolSize();
2388+
}
2389+
return poolSize;
2390+
}
2391+
23712392
template <typename CacheTrait>
23722393
PoolStats CacheAllocator<CacheTrait>::getPoolStats(PoolId poolId) const {
23732394
const auto& pool = allocator_[currentTier()]->getPool(poolId);
@@ -3420,9 +3441,12 @@ GlobalCacheStats CacheAllocator<CacheTrait>::getGlobalCacheStats() const {
34203441

34213442
template <typename CacheTrait>
34223443
CacheMemoryStats CacheAllocator<CacheTrait>::getCacheMemoryStats() const {
3423-
const auto configuredTotalCacheSize = allocator_[currentTier()]->getMemorySizeInclAdvised();
3424-
const auto totalCacheSize = allocator_[currentTier()]->getMemorySize();
3425-
3444+
size_t totalCacheSize = 0;
3445+
size_t configuredTotalCacheSize = 0;
3446+
for(auto& allocator: allocator_) {
3447+
totalCacheSize += allocator->getMemorySize();
3448+
configuredTotalCacheSize += allocator->getMemorySizeInclAdvised();
3449+
}
34263450
auto addSize = [this](size_t a, PoolId pid) {
34273451
return a + allocator_[currentTier()]->getPool(pid).getPoolSize();
34283452
};

‎cachelib/allocator/CacheAllocator.h‎

Lines changed: 2 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -2005,6 +2005,8 @@ class CacheAllocator : public CacheBase {
20052005
return memoryTierConfigs.size();
20062006
}
20072007

2008+
size_t memoryTierSize(TierId tid) const;
2009+
20082010
// Whether the memory allocator for this cache allocator was created on shared
20092011
// memory. The hash table, chained item hash table etc is also created on
20102012
// shared memory except for temporary shared memory mode when they're created

‎cachelib/allocator/tests/AllocatorMemoryTiersTest.cpp‎

Lines changed: 3 additions & 3 deletions
Original file line numberDiff line numberDiff line change
@@ -23,9 +23,9 @@ namespace tests {
2323
using LruAllocatorMemoryTiersTest = AllocatorMemoryTiersTest<LruAllocator>;
2424

2525
// TODO(MEMORY_TIER): add more tests with different eviction policies
26-
TEST_F(LruAllocatorMemoryTiersTest, MultiTiersValid1) {
27-
this->testMultiTiersValid1();
28-
}
26+
TEST_F(LruAllocatorMemoryTiersTest, MultiTiersInvalid) { this->testMultiTiersInvalid(); }
27+
TEST_F(LruAllocatorMemoryTiersTest, MultiTiersValid) { this->testMultiTiersValid(); }
28+
TEST_F(LruAllocatorMemoryTiersTest, MultiTiersValidMixed) { this->testMultiTiersValidMixed(); }
2929

3030
} // end of namespace tests
3131
} // end of namespace cachelib

‎cachelib/allocator/tests/AllocatorMemoryTiersTest.h‎

Lines changed: 39 additions & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -27,7 +27,7 @@ namespace tests {
2727
template <typename AllocatorT>
2828
class AllocatorMemoryTiersTest : public AllocatorTest<AllocatorT> {
2929
public:
30-
void testMultiTiersValid1() {
30+
void testMultiTiersInvalid() {
3131
typename AllocatorT::Config config;
3232
config.setCacheSize(100 * Slab::kSize);
3333
ASSERT_NO_THROW(config.configureMemoryTiers(
@@ -36,6 +36,44 @@ class AllocatorMemoryTiersTest : public AllocatorTest<AllocatorT> {
3636
MemoryTierCacheConfig::fromShm().setRatio(1).setMemBind(
3737
std::string("0"))}));
3838
}
39+
40+
void testMultiTiersValid() {
41+
typename AllocatorT::Config config;
42+
config.setCacheSize(100 * Slab::kSize);
43+
config.enableCachePersistence("/tmp");
44+
ASSERT_NO_THROW(config.configureMemoryTiers(
45+
{MemoryTierCacheConfig::fromShm().setRatio(1).setMemBind(
46+
std::string("0")),
47+
MemoryTierCacheConfig::fromShm().setRatio(1).setMemBind(
48+
std::string("0"))}));
49+
50+
auto alloc = std::make_unique<AllocatorT>(AllocatorT::SharedMemNew, config);
51+
ASSERT(alloc != nullptr);
52+
53+
auto pool = alloc->addPool("default", alloc->getCacheMemoryStats().cacheSize);
54+
auto handle = alloc->allocate(pool, "key", std::string("value").size());
55+
ASSERT(handle != nullptr);
56+
ASSERT_NO_THROW(alloc->insertOrReplace(handle));
57+
}
58+
59+
void testMultiTiersValidMixed() {
60+
typename AllocatorT::Config config;
61+
config.setCacheSize(100 * Slab::kSize);
62+
config.enableCachePersistence("/tmp");
63+
ASSERT_NO_THROW(config.configureMemoryTiers(
64+
{MemoryTierCacheConfig::fromShm().setRatio(1).setMemBind(
65+
std::string("0")),
66+
MemoryTierCacheConfig::fromShm().setRatio(1).setMemBind(
67+
std::string("0"))}));
68+
69+
auto alloc = std::make_unique<AllocatorT>(AllocatorT::SharedMemNew, config);
70+
ASSERT(alloc != nullptr);
71+
72+
auto pool = alloc->addPool("default", alloc->getCacheMemoryStats().cacheSize);
73+
auto handle = alloc->allocate(pool, "key", std::string("value").size());
74+
ASSERT(handle != nullptr);
75+
ASSERT_NO_THROW(alloc->insertOrReplace(handle));
76+
}
3977
};
4078
} // namespace tests
4179
} // namespace cachelib

‎cachelib/allocator/tests/MemoryTiersTest.cpp‎

Lines changed: 87 additions & 3 deletions
Original file line numberDiff line numberDiff line change
@@ -109,7 +109,7 @@ class MemoryTiersTest : public AllocatorTest<Allocator> {
109109
void validatePoolSize(PoolId poolId,
110110
std::unique_ptr<LruAllocator>& allocator,
111111
size_t expectedSize) {
112-
size_t actualSize = allocator->getPool(poolId).getPoolSize();
112+
size_t actualSize = allocator->getPoolSize(poolId);
113113
EXPECT_EQ(actualSize, expectedSize);
114114
}
115115

@@ -119,9 +119,9 @@ class MemoryTiersTest : public AllocatorTest<Allocator> {
119119
size_t numTiers = 2) {
120120
if (isSizeValid) {
121121
auto pool = alloc->addPool("validPoolSize", poolSize);
122-
EXPECT_LE(alloc->getPool(pool).getPoolSize(), poolSize);
122+
EXPECT_LE(alloc->getPoolSize(pool), poolSize);
123123
if (poolSize >= numTiers * Slab::kSize)
124-
EXPECT_GE(alloc->getPool(pool).getPoolSize(),
124+
EXPECT_GE(alloc->getPoolSize(pool),
125125
poolSize - numTiers * Slab::kSize);
126126
} else {
127127
EXPECT_THROW(alloc->addPool("invalidPoolSize", poolSize),
@@ -172,6 +172,90 @@ TEST_F(LruMemoryTiersTest, TestInvalid2TierConfigRatioNotSet) {
172172
TEST_F(LruMemoryTiersTest, TestInvalid2TierConfigSizesNeCacheSize) {
173173
EXPECT_THROW(createTestCacheConfig({0, 0}), std::invalid_argument);
174174
}
175+
176+
TEST_F(LruMemoryTiersTest, TestPoolAllocations) {
177+
std::vector<size_t> totalCacheSizes = {2 * GB};
178+
179+
static const size_t numExtraSizes = 4;
180+
static const size_t numExtraSlabs = 20;
181+
182+
for (size_t i = 0; i < numExtraSizes; i++) {
183+
totalCacheSizes.push_back(totalCacheSizes.back() +
184+
(folly::Random::rand64() % numExtraSlabs) *
185+
Slab::kSize);
186+
}
187+
188+
const std::string path = "/tmp/tier";
189+
Strings paths = {path + "0", path + "1"};
190+
191+
size_t min_ratio = 1;
192+
size_t max_ratio = 111;
193+
194+
static const size_t numCombinations = 100;
195+
196+
for (auto totalCacheSize : totalCacheSizes) {
197+
for (size_t k = 0; k < numCombinations; k++) {
198+
const size_t i = folly::Random::rand32() % max_ratio + min_ratio;
199+
const size_t j = folly::Random::rand32() % max_ratio + min_ratio;
200+
LruAllocatorConfig cfg =
201+
createTestCacheConfig({i, j},
202+
/* usePoisx */ true, totalCacheSize);
203+
basicCheck(cfg, totalCacheSize);
204+
205+
std::unique_ptr<LruAllocator> alloc = std::unique_ptr<LruAllocator>(
206+
new LruAllocator(LruAllocator::SharedMemNew, cfg));
207+
208+
size_t size = (folly::Random::rand64() %
209+
(alloc->getCacheMemoryStats().cacheSize - Slab::kSize)) +
210+
Slab::kSize;
211+
testAddPool(alloc, size, true);
212+
}
213+
}
214+
}
215+
216+
TEST_F(LruMemoryTiersTest, TestPoolInvalidAllocations) {
217+
std::vector<size_t> totalCacheSizes = {48 * MB, 51 * MB, 256 * MB,
218+
1 * GB, 5 * GB, 8 * GB};
219+
const std::string path = "/tmp/tier";
220+
Strings paths = {path + "0", path + "1"};
221+
222+
size_t min_ratio = 1;
223+
size_t max_ratio = 111;
224+
225+
static const size_t numCombinations = 100;
226+
227+
for (auto totalCacheSize : totalCacheSizes) {
228+
for (size_t k = 0; k < numCombinations; k++) {
229+
const size_t i = folly::Random::rand32() % max_ratio + min_ratio;
230+
const size_t j = folly::Random::rand32() % max_ratio + min_ratio;
231+
LruAllocatorConfig cfg =
232+
createTestCacheConfig({i, j},
233+
/* usePoisx */ true, totalCacheSize);
234+
235+
std::unique_ptr<LruAllocator> alloc = nullptr;
236+
try {
237+
alloc = std::unique_ptr<LruAllocator>(
238+
new LruAllocator(LruAllocator::SharedMemNew, cfg));
239+
} catch(...) {
240+
// expection only if cache too small
241+
size_t sum_ratios = std::accumulate(
242+
cfg.getMemoryTierConfigs().begin(), cfg.getMemoryTierConfigs().end(), 0UL,
243+
[](const size_t i, const MemoryTierCacheConfig& config) {
244+
return i + config.getRatio();
245+
});
246+
auto tier1slabs = cfg.getMemoryTierConfigs()[0].calculateTierSize(cfg.getCacheSize(), sum_ratios) / Slab::kSize;
247+
auto tier2slabs = cfg.getMemoryTierConfigs()[1].calculateTierSize(cfg.getCacheSize(), sum_ratios) / Slab::kSize;
248+
EXPECT_TRUE(tier1slabs <= 2 || tier2slabs <= 2);
249+
250+
continue;
251+
}
252+
253+
size_t size = (folly::Random::rand64() % (100 * GB)) +
254+
alloc->getCacheMemoryStats().cacheSize;
255+
testAddPool(alloc, size, false);
256+
}
257+
}
258+
}
175259
} // namespace tests
176260
} // namespace cachelib
177261
} // namespace facebook

0 commit comments

Comments
 (0)