segment_manager::get_ephemeral_device_config(0, 1, 0));
}).safe_then([this] {
sms.reset(new SegmentManagerGroup());
- journal = journal::make_segmented(*this, *this);
+ journal = journal::make_segmented(0, *this, *this);
rewrite_gen_t hot_tier_generations = crimson::common::get_conf<uint64_t>(
"seastore_hot_tier_generations");
rewrite_gen_t cold_tier_generations = crimson::common::get_conf<uint64_t>(
"seastore_cold_tier_generations");
epm.reset(new ExtentPlacementManager(
- hot_tier_generations, cold_tier_generations));
- cache.reset(new Cache(*epm));
+ hot_tier_generations, cold_tier_generations, 0));
+ cache.reset(new Cache(*epm, 0));
block_size = segment_manager->get_block_size();
next = segment_id_t{segment_manager->get_device_id(), 0};
void complete_commit(Transaction &t) final {}
LBAManager::mkfs_ret test_structure_setup(Transaction &t) final {
- lba_manager.reset(new BtreeLBAManager(*cache));
+ lba_manager.reset(new BtreeLBAManager(*cache, 0));
return lba_manager->mkfs(t);
}
seastar::future<> set_up_fut() final {
device = random_block_device::create_test_ephemeral(
random_block_device::DEFAULT_TEST_CBJOURNAL_SIZE, 0);
- cbj.reset(new CircularBoundedJournal(*this, device.get(), std::string()));
+ cbj.reset(new CircularBoundedJournal(0, *this, device.get(), std::string()));
block_size = device->get_block_size();
cbj->set_write_pipeline(&pipeline);
return mkfs(
rewrite_gen_t cold_tier_generations = crimson::common::get_conf<uint64_t>(
"seastore_cold_tier_generations");
epm.reset(new ExtentPlacementManager(
- hot_tier_generations, cold_tier_generations));
- cache.reset(new Cache(*epm));
+ hot_tier_generations, cold_tier_generations, 0));
+ cache.reset(new Cache(*epm, 0));
current = paddr_t::make_seg_paddr(segment_id_t(segment_manager->get_device_id(), 0), 0);
epm->test_init_no_background(segment_manager.get());
return seastar::do_with(
block_size = segment_manager->get_block_size();
sms.reset(new SegmentManagerGroup());
next = segment_id_t(segment_manager->get_device_id(), 0);
- journal = journal::make_segmented(*this, *this);
+ journal = journal::make_segmented(0, *this, *this);
journal->set_write_pipeline(&pipeline);
sms->add_segment_manager(segment_manager.get());
return journal->open_for_mkfs();
auto replay(T &&f) {
return journal->close(
).safe_then([this, f=std::move(f)]() mutable {
- journal = journal::make_segmented(*this, *this);
+ journal = journal::make_segmented(0, *this, *this);
journal->set_write_pipeline(&pipeline);
return journal->replay(std::forward<T>(std::move(f)));
}).safe_then([this] {
}
#endif
shard_stats = {};
- tm = make_transaction_manager(p_dev, sec_devices, shard_stats, true);
+ tm = make_transaction_manager(p_dev, sec_devices, shard_stats, 0, true);
epm = tm->get_epm();
lba_manager = tm->get_lba_manager();
cache = tm->get_cache();